package com.megatim.fdxconsultation.core.impl.integration;

import com.megatim.fdxcommons.dao.ifaces.integration.ColumnDefinitionDAO;
import com.megatim.fdxcommons.model.integration.ColumnDefinition;
import com.megatim.fdxconsultation.core.ifaces.integration.ColumnDefinitionManager;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.function.Function;
import java.util.stream.Collectors;
import javax.ejb.EJB;
import javax.enterprise.context.Dependent;
import javax.persistence.Tuple;

/**
 *
 * @author ASUS
 */
@Dependent
public class ColumnDefinitionManagerImpl implements ColumnDefinitionManager {

    @EJB
    ColumnDefinitionDAO dao;

    @Override
    public ColumnDefinition findByNameAndReferentielAndTypeFichier(String columnName, String referentielVersion, String codeTypeFichier) {
        return getDao().findByNameAndReferentielAndTypeFichier(columnName, referentielVersion, codeTypeFichier);
    }

    @Override
    public List<ColumnDefinition> findByReferentiel(String referentielVersion) {
        return getDao().findByReferentiel(referentielVersion);
    }

    @Override
    public List<ColumnDefinition> findByReferentielAndTypeFichier(String referentielVersion, String codeTypeFichier) {
        return getDao().findByReferentielAndTypeFichier(referentielVersion, codeTypeFichier);
    }

    @Override
    public Set<String> findTypeFichierByReferentiel(String referentielVersion) {
        return getDao().findTypeFichierByReferentiel(referentielVersion);
    }

    @Override
    public ColumnDefinitionDAO getDao() {
        return dao;
    }

    @Override
    public Map<String, ColumnDefinition> getColumnsDefimitionMap(String codeTypeFichier, String referentielVersion) {
        List<ColumnDefinition> columnsDef = findByReferentielAndTypeFichier(referentielVersion, codeTypeFichier);
        return columnsDef.stream().collect(Collectors.toMap(c -> c.getName(), Function.identity()));
    }

    @Override
    public List<Tuple> byRefVersionAndByTypeFichier() {
        return dao.byRefVersionAndByTypeFichier();
    }
}