/*
 * Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
 * Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
 */
package com.megatim.apifdxweb.service.impl.scheduler;

import com.megatim.apifdxweb.model.camel.historique.ConsumedFilesHistory;
import com.megatim.apifdxweb.service.impl.camel.config.CamelRouteConfiguration;
import com.megatim.apifdxweb.tools.AppContext;
import java.io.File;
import java.util.List;
import javax.enterprise.context.Dependent;
import javax.inject.Inject;
import com.megatim.apifdxweb.service.ifaces.scheduler.DeleteConsumedFilesJob;
import com.megatim.apifdxweb.core.ifaces.camel.historique.ConsumedFilesHistoryManager;
import com.megatim.apifdxweb.model.camel.historique.ConsumedFileType;

/**
 *
 * @author ASUS
 */
@Dependent
public class DeleteConsumedFilesJobImpl implements DeleteConsumedFilesJob {

    @Inject
    ConsumedFilesHistoryManager manager;

    @Override
    public void deleteConsumedFilesInFolder() throws Exception {
        String dataPath = new CamelRouteConfiguration(AppContext.PROPERTY_FILE_PATH).getLocalConfiguration().fichierLocalPath();
        String referentielPath = new CamelRouteConfiguration(AppContext.PROPERTY_FILE_PATH).getLocalConfiguration().referentielLocalPath();
        List<ConsumedFilesHistory> consumedFiles = manager.notDeleted();

        consumedFiles.stream().forEach(cf -> {
            String filePath = cf.getConsumedFileType().equals(ConsumedFileType.DONNEES) ? dataPath : referentielPath;
            File file = new File(filePath, cf.getFileName());

            if (!file.exists() || file.exists() && file.delete()) {
                cf.setDeletedInFolder(true);
                manager.save(cf);
            }
        });
    }

}