sascha@372: package de.intevation.flys.artifacts.services;
sascha@372: 
sascha@372: import java.io.InputStream;
sascha@372: import java.io.IOException;
sascha@947: import java.io.File;
sascha@947: import java.io.FileInputStream;
sascha@372: 
sascha@372: import java.sql.Connection;
sascha@372: import java.sql.SQLException;
sascha@372: 
sascha@372: import org.w3c.dom.Document;
sascha@372: 
sascha@372: import org.apache.log4j.Logger;
sascha@372: 
sascha@415: import java.util.Map;
sascha@415: import java.util.HashMap;
sascha@415: 
sascha@372: import de.intevation.artifacts.CallMeta;
sascha@372: import de.intevation.artifacts.ServiceFactory;
sascha@372: 
sascha@372: import de.intevation.artifactdatabase.DefaultService;
sascha@372: 
sascha@947: import de.intevation.artifacts.common.utils.Config;
sascha@372: import de.intevation.artifacts.common.utils.XMLUtils;
sascha@372: 
sascha@421: import de.intevation.artifacts.common.ArtifactNamespaceContext;
sascha@421: 
sascha@372: import de.intevation.flys.artifacts.services.meta.Builder;
sascha@372: 
sascha@372: import de.intevation.flys.backend.SessionHolder;
sascha@372: 
sascha@372: import org.hibernate.Session;
sascha@372: 
sascha@372: import org.hibernate.jdbc.Work;
sascha@372: 
sascha@372: public class MetaDataService
sascha@372: extends      DefaultService
sascha@372: {
sascha@372:     private static Logger log = Logger.getLogger(MetaDataService.class);
sascha@372: 
sascha@947:     public static final String XPATH_META_DATA_TEMPLATE =
sascha@947:         "/artifact-database/metadata/@template";
sascha@947: 
sascha@421:     public static final String XPATH_RIVER = "/art:river/text()";
sascha@415: 
sascha@372:     protected Builder builder;
sascha@372: 
sascha@372:     public MetaDataService() {
sascha@372:     }
sascha@372: 
sascha@415:     protected static Map<String, Object> extractParameters(Document data) {
sascha@415:         HashMap<String, Object> parameters = new HashMap<String, Object>();
sascha@415: 
sascha@421:         String river = XMLUtils.xpathString(
sascha@421:             data, XPATH_RIVER, ArtifactNamespaceContext.INSTANCE);
sascha@415: 
sascha@415:         if (river == null || (river = river.trim()).length() == 0) {
sascha@415:             river = "%"; // matches all rivers
sascha@415:         }
sascha@415: 
sascha@415:         parameters.put("river", river);
sascha@415: 
sascha@415:         return parameters;
sascha@415:     }
sascha@415: 
sascha@372:     @Override
sascha@372:     public Document process(
sascha@372:         Document data,
sascha@372:         Object   globalContext,
sascha@372:         CallMeta callMeta
sascha@372:     ) {
sascha@372:         log.debug("MetaDataService.process");
sascha@372: 
sascha@372:         final Document result = XMLUtils.newDocument();
sascha@372: 
sascha@372:         if (builder == null) {
sascha@372:             log.error("MetaDataService is not setup properly.");
sascha@372:             return result;
sascha@372:         }
sascha@372: 
sascha@415:         final Map<String, Object> parameters = extractParameters(data);
sascha@415: 
sascha@372:         Session session = SessionHolder.acquire();
sascha@372:         try {
sascha@372:             session.doWork(new Work() {
sascha@372:                 @Override
sascha@372:                 public void execute(Connection connection)
sascha@372:                 throws SQLException
sascha@372:                 {
sascha@372:                     log.debug("MetaDataService.execute");
sascha@415:                     builder.build(connection, result, parameters);
sascha@372:                 }
sascha@372:             });
sascha@372:         }
sascha@372:         finally {
sascha@372:             session.close();
sascha@372:             SessionHolder.release();
sascha@372:         }
sascha@372: 
sascha@372:         return result;
sascha@372:     }
sascha@372: 
sascha@372:     @Override
sascha@372:     public void setup(ServiceFactory factory, Object globalContext) {
sascha@372:         log.debug("MetaDataService.setup");
sascha@372: 
sascha@947:         String path = Config.getStringXPath(XPATH_META_DATA_TEMPLATE);
sascha@372: 
sascha@947:         if (path == null) {
sascha@947:             log.error("no path to template file given");
sascha@372:             return;
sascha@372:         }
sascha@372: 
sascha@947:         path = Config.replaceConfigDir(path);
sascha@947: 
sascha@947:         File file = new File(path);
sascha@947: 
sascha@947:         if (!file.isFile() || !file.canRead()) {
sascha@947:             log.error("Cannot open template file '" + file + "'");
sascha@947:             return;
sascha@947:         }
sascha@947: 
sascha@947:         InputStream in = null;
sascha@947: 
sascha@372:         try {
sascha@947:             in = new FileInputStream(file);
sascha@372:             Document template = XMLUtils.parseDocument(in);
sascha@372:             if (template == null) {
sascha@372:                 log.error("cannot parse meta data template");
sascha@372:             }
sascha@372:             else {
sascha@372:                 builder = new Builder(template);
sascha@372:             }
sascha@372:         }
sascha@947:         catch (IOException ioe) {
sascha@947:             log.error(ioe);
sascha@947:         }
sascha@372:         finally {
sascha@948:             if (in != null) {
sascha@948:                 try {
sascha@948:                     in.close();
sascha@948:                 }
sascha@948:                 catch (IOException ioe) {
sascha@948:                     log.error(ioe);
sascha@948:                 }
sascha@372:             }
sascha@372:         }
sascha@372:     }
sascha@372: }
sascha@372: // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :