package com.megatim.apifdxweb.service.impl.camel.processors;

import com.megatim.fdxcommons.core.ifaces.db.ImportReferentielHelper;
import com.megatim.fdxcommons.core.ifaces.helper.ReferentielConsumptionHelper;
import com.megatim.fdxcommons.model.pojo.ReferentielToImportData;
import java.io.File;
import javax.inject.Inject;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.cdi.CdiCamelContext;

/**
 *
 * @author lenovo
 */
public class ReferentielProcessor implements Processor {

    @Inject
    private ReferentielConsumptionHelper referentielConsumptionHelper;

    @Inject
    private ImportReferentielHelper importReferentielHelper;

    @Inject
    private CdiCamelContext camelContext;

    @Override
    public void process(Exchange exchange) throws Exception {

        File file = exchange.getIn().getBody(File.class);

        ReferentielToImportData referentielToImportData = importReferentielHelper.extractData(file);

        //On enregistre les données de référentiel trouvées
        referentielConsumptionHelper.consume(referentielToImportData);

        //Envoie des données du ref vers une file
        exchange.getIn().setBody(referentielToImportData);
    }

}