source: vlo/branches/vlo-3.3-oeaw/vlo-importer/src/main/java/eu/clarin/cmdi/vlo/importer/PostProcessorsWithVocabularyMap.java @ 6581

package eu.clarin.cmdi.vlo.importer;

import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.Reader;
import java.util.Map;
import java.util.Map.Entry;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import eu.clarin.cmdi.vlo.pojo.VariantsMap;
import eu.clarin.cmdi.vlo.transformers.VariantsMapMarshaller;

/* 
 * abstract class that encapsulates common map creation from mapping files
 * for some postprocessors like LanguageCodePostProcessor*
 * 
 * brings one more level in class hierarchy between interface PostPorcessor and concrete implementations
 * 
 * @author dostojic
 * 
 */

public abstract class PostProcessorsWithVocabularyMap implements PostProcessor{
        
         private final static Logger LOG = LoggerFactory.getLogger(PostProcessorsWithVocabularyMap.class);
                 
         
         /*
          * returns specific static map and should call createControlledVocabularyMap 
          */
         protected abstract Map<String, String> getVocabularyMap();
         
                 
         protected Map<String, String> createControlledVocabularyMap(String mapUrl) {
                 VariantsMap map = getMappingFromFile(mapUrl);
         return map.getInvertedMap();
          }
         
         protected VariantsMap getMappingFromFile(String mapUrl){
                 try {
                        
                        LOG.info("Reading vocabulary file from: {}", mapUrl);
                    // load records from file
                        // in the future this should be loaded from CLAVAS directly and the file only used as fallback                  
                        InputStream is = PostProcessorsWithVocabularyMap.class.getClassLoader().getResourceAsStream(mapUrl);
                        Reader reader = new InputStreamReader(is, "UTF-8");
                        return VariantsMapMarshaller.unmarshal(reader);                 
             } catch (Exception e) {
            throw new RuntimeException("Cannot instantiate postProcessor:", e);
         }
         }
         
         // for debug purposes
         public void printMap(){
                 LOG.info("map contains {} entries", getVocabularyMap().size());
                 for(Entry<String, String> e: getVocabularyMap().entrySet()){
                         LOG.info("Key <{}> will be mapped to <{}>", e.getKey(), e.getValue());
                 }
         }
         
        


}