sascha@372: package de.intevation.flys.artifacts.services;
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@970: import de.intevation.artifacts.Artifact;
sascha@372: import de.intevation.artifacts.CallMeta;
sascha@966: import de.intevation.artifacts.GlobalContext;
sascha@970: import de.intevation.artifacts.ArtifactDatabase;
sascha@970: import de.intevation.artifacts.ArtifactDatabaseException;
sascha@372:
sascha@372: import de.intevation.artifactdatabase.DefaultService;
sascha@372:
sascha@372: import de.intevation.artifacts.common.utils.XMLUtils;
sascha@970: import de.intevation.artifacts.common.utils.StringUtils;
sascha@372:
sascha@421: import de.intevation.artifacts.common.ArtifactNamespaceContext;
sascha@421:
sascha@1015: import de.intevation.flys.artifacts.datacage.Recommendations;
sascha@372:
sascha@970: import de.intevation.flys.artifacts.FLYSArtifact;
sascha@970:
sascha@372: public class MetaDataService
sascha@372: extends DefaultService
sascha@372: {
sascha@372: private static Logger log = Logger.getLogger(MetaDataService.class);
sascha@372:
sascha@1015: public static final String XPATH_ARTIFACT_ID = "/art:meta/art:artifact-id/@value";
sascha@1015: public static final String XPATH_USER_ID = "/art:meta/art:user-id/@value";
sascha@1015: public static final String XPATH_OUTS = "/art:meta/art:outs/@value";
sascha@1015: public static final String XPATH_PARAMETERS = "/art:meta/art:parameters/@value";
sascha@970:
felix@1029: /** The global context key of the artifact database. */
sascha@970: public static final String ARTIFACT_DATA_BASE_KEY =
sascha@970: "global.artifact.database";
sascha@969:
sascha@372: public MetaDataService() {
sascha@372: }
sascha@372:
sascha@1015: @Override
sascha@1015: public Document process(
sascha@1015: Document data,
sascha@1015: GlobalContext globalContext,
sascha@1015: CallMeta callMeta
sascha@1015: ) {
sascha@1015: log.debug("MetaDataService.process");
sascha@415:
sascha@1015: String artifactId = XMLUtils.xpathString(
sascha@1015: data, XPATH_ARTIFACT_ID, ArtifactNamespaceContext.INSTANCE);
sascha@415:
sascha@1016: if (artifactId != null
sascha@1016: && (artifactId = artifactId.trim()).length() == 0) {
sascha@1016: artifactId = null;
sascha@1016: }
sascha@1016:
sascha@1015: String userId = XMLUtils.xpathString(
sascha@1015: data, XPATH_USER_ID, ArtifactNamespaceContext.INSTANCE);
sascha@415:
sascha@1016: if (userId != null
sascha@1016: && (userId = userId.trim()).length() == 0) {
sascha@1016: userId = null;
sascha@1016: }
sascha@1016:
sascha@1015: String outs = XMLUtils.xpathString(
sascha@1015: data, XPATH_OUTS, ArtifactNamespaceContext.INSTANCE);
sascha@1015:
sascha@1015: String parameters = XMLUtils.xpathString(
sascha@1015: data, XPATH_PARAMETERS, ArtifactNamespaceContext.INSTANCE);
sascha@1015:
sascha@1015: return doService(
sascha@1015: artifactId, userId, outs, parameters, globalContext);
sascha@415: }
sascha@415:
sascha@1015: protected static Map<String, Object> splitParameters(
sascha@974: String parameters,
sascha@974: Map<String, Object> data
sascha@974: ) {
sascha@974: if (parameters != null) {
sascha@974: String [] parts = parameters.split("\\s*;\\s*");
sascha@974: for (String part: parts) {
sascha@974: String [] kv = part.split("\\s*:\\s*");
sascha@974: if (kv.length < 2 || (kv[0] = kv[0].trim()).length() == 0) {
sascha@974: continue;
sascha@974: }
sascha@974: String [] values = kv[1].split("\\s*,\\s*");
sascha@974: data.put(kv[0], values.length == 1 ? values[0] : values);
sascha@974: }
sascha@974: }
sascha@974: return data;
sascha@974: }
sascha@974:
sascha@1015: protected Document doService(
sascha@1015: String artifactId,
sascha@1015: String userId,
sascha@970: String outsString,
sascha@974: String parameters,
sascha@970: GlobalContext globalContext
sascha@970: ) {
sascha@970: Document result = XMLUtils.newDocument();
sascha@970:
sascha@974: FLYSArtifact flysArtifact;
sascha@970:
sascha@975: if (log.isDebugEnabled()) {
sascha@1015: log.debug("artifact : " + artifactId);
sascha@1015: log.debug("user : " + userId);
sascha@1015: log.debug("outs : " + outsString);
sascha@1015: log.debug("parameters: " + parameters);
sascha@975: }
sascha@970:
sascha@1015: if (userId != null && !StringUtils.checkUUID(userId)) {
sascha@1015: log.warn("'" + userId + "' is not a UUID");
sascha@1015: return result;
sascha@1015: }
sascha@1015:
sascha@1015: if (artifactId != null) {
sascha@1015: if (!StringUtils.checkUUID(artifactId)) {
sascha@1015: log.warn("'" + artifactId + "' is not a UUID");
sascha@974: return result;
sascha@974: }
sascha@974:
sascha@974: Object dbObject =
sascha@974: (ArtifactDatabase)globalContext.get(ARTIFACT_DATA_BASE_KEY);
sascha@974:
sascha@974: if (!(dbObject instanceof ArtifactDatabase)) {
sascha@974: log.error("Cannot find artifact database");
sascha@974: return result;
sascha@974: }
sascha@974:
sascha@974: ArtifactDatabase db = (ArtifactDatabase)dbObject;
sascha@974:
sascha@974: Artifact artifact;
sascha@974:
sascha@974: try {
sascha@1015: artifact = db.getRawArtifact(artifactId);
sascha@974: }
sascha@974: catch (ArtifactDatabaseException adbe) {
sascha@974: log.warn("fetching artifact failed", adbe);
sascha@974: return result;
sascha@974: }
sascha@974:
sascha@974: if (!(artifact instanceof FLYSArtifact)) {
sascha@974: log.warn("artifact is not a FLYS artifact.");
sascha@974: return result;
sascha@974: }
sascha@974:
sascha@974: flysArtifact = (FLYSArtifact)artifact;
sascha@974: }
sascha@974: else {
sascha@974: flysArtifact = null;
sascha@970: }
sascha@970:
sascha@1015:
sascha@1015: Map<String, Object> data = splitParameters(
sascha@1015: parameters, new HashMap<String, Object>());
sascha@970:
sascha@1016: String [] outs = outsString == null
sascha@1016: ? new String [0]
sascha@1016: : outsString.split("\\s*,\\s*");
sascha@970:
sascha@1015: Recommendations rec = Recommendations.getInstance();
sascha@1015: rec.recommend(
sascha@1015: flysArtifact, userId, outs, data, result);
sascha@970:
sascha@970: return result;
sascha@970: }
sascha@372: }
sascha@372: // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :