# HG changeset patch
# User Ingo Weinzierl <ingo.weinzierl@intevation.de>
# Date 1299680037 0
# Node ID e0ded17a484646c2c807d2cbc4095c7805a7faa4
# Parent  5243ac559e16c14e4cbbc328956dd3c471f1862b
Implemented the feed() operation.

flys-artifacts/trunk@1442 c6561f87-3c4e-4783-a992-168aeb5c3f6f

diff -r 5243ac559e16 -r e0ded17a4846 flys-artifacts/ChangeLog
--- a/flys-artifacts/ChangeLog	Wed Mar 09 14:07:03 2011 +0000
+++ b/flys-artifacts/ChangeLog	Wed Mar 09 14:13:57 2011 +0000
@@ -1,3 +1,16 @@
+2011-03-09  Ingo Weinzierl <ingo@intevation.de>
+
+	* src/main/java/de/intevation/flys/artifacts/WINFOArtifact.java:
+	  Implemented the abstract method getName(). It returns the constant
+	  'winfo' string.
+
+	* src/main/java/de/intevation/flys/artifacts/FLYSArtifact.java:
+	  Implemented the feed action. The data of an incoming feed() operation is
+	  stored in StateData objects that are saved in a map in the artifact.
+
+	  NOTE: There is no input validation and no i18n of error messages (see
+	  TODO).
+
 2011-03-09  Ingo Weinzierl <ingo@intevation.de>
 
 	* TODO: This file contains some open points that need to be done.
diff -r 5243ac559e16 -r e0ded17a4846 flys-artifacts/src/main/java/de/intevation/flys/artifacts/FLYSArtifact.java
--- a/flys-artifacts/src/main/java/de/intevation/flys/artifacts/FLYSArtifact.java	Wed Mar 09 14:07:03 2011 +0000
+++ b/flys-artifacts/src/main/java/de/intevation/flys/artifacts/FLYSArtifact.java	Wed Mar 09 14:13:57 2011 +0000
@@ -1,10 +1,17 @@
 package de.intevation.flys.artifacts;
 
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
+
+import javax.xml.xpath.XPathConstants;
 
 import org.apache.log4j.Logger;
 
 import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+import org.w3c.dom.Node;
+import org.w3c.dom.NodeList;
 
 import de.intevation.artifacts.ArtifactFactory;
 import de.intevation.artifacts.CallContext;
@@ -13,6 +20,7 @@
 import de.intevation.artifacts.common.utils.XMLUtils;
 
 import de.intevation.artifactdatabase.DefaultArtifact;
+import de.intevation.artifactdatabase.data.DefaultStateData;
 import de.intevation.artifactdatabase.data.StateData;
 import de.intevation.artifactdatabase.state.State;
 import de.intevation.artifactdatabase.state.StateEngine;
@@ -31,8 +39,9 @@
     private static Logger logger = Logger.getLogger(FLYSArtifact.class);
 
 
-    /** The XPath to the name of the artifact in its configuration. */
-    public static final String XPATH_ARTIFACT_NAME = "@name";
+    /** The XPath that points to the input data elements of the FEED document.*/
+    public static final String XPATH_FEED_INPUT =
+        "/art:action/art:data/art:input";
 
 
     /** The identifier of the current state. */
@@ -41,6 +50,39 @@
     /** The name of the artifact.*/
     protected String name;
 
+    /** The data that have been inserted into this artifact.*/
+    protected Map<String, StateData> data;
+
+
+    /**
+     * The default constructor that creates an empty FLYSArtifact.
+     */
+    public FLYSArtifact() {
+        data = new HashMap<String, StateData>();
+    }
+
+
+    /**
+     * Returns the name of the concrete artifact.
+     *
+     * @return the name of the concrete artifact.
+     */
+    public abstract String getName();
+
+
+    /**
+     * Returns the FLYSContext from context object.
+     *
+     * @param context The CallContext or the FLYSContext.
+     *
+     * @return the FLYSContext.
+     */
+    protected FLYSContext getFlysContext(Object context) {
+        return context instanceof FLYSContext
+            ? (FLYSContext) context
+            : (FLYSContext) ((CallContext) context).globalContext();
+    }
+
 
     /**
      * Initialize the artifact and insert new data if <code>data</code> contains
@@ -62,14 +104,13 @@
 
         super.setup(identifier, factory, context, data);
 
-        String name = XMLUtils.xpathString(
-            data, XPATH_ARTIFACT_NAME, ArtifactNamespaceContext.INSTANCE);
-        setName(name);
-
         FLYSContext flysContext = (FLYSContext) context;
         StateEngine engine      = (StateEngine) flysContext.get(
             FLYSContext.STATE_ENGINE_KEY);
 
+        String name = getName();
+
+        logger.debug("Set initial state for artifact '" + name + "'");
         List<State> states = engine.getStates(name);
 
         setCurrentState(states.get(0));
@@ -86,32 +127,29 @@
      */
     @Override
     public Document feed(Document target, CallContext context) {
-        Document result = XMLUtils.newDocument();
-
-        // TODO IMPLEMENT ME
-
-        return result;
-    }
-
+        Document doc = XMLUtils.newDocument();
 
-    /**
-     * This method returns the name of the concrete artifact.
-     *
-     * @return the name of the concrete artifact.
-     */
-    public String getName() {
-        return name;
-    }
+        XMLUtils.ElementCreator creator = new XMLUtils.ElementCreator(
+            doc,
+            ArtifactNamespaceContext.NAMESPACE_URI,
+            ArtifactNamespaceContext.NAMESPACE_PREFIX);
 
-
+        Element result = creator.create("result");
+        doc.appendChild(result);
 
-    /**
-     * This method sets the name of this artifact.
-     *
-     * @param name the name for this artifact.
-     */
-    protected void setName(String name) {
-        this.name = name;
+        try {
+            saveData(target, XPATH_FEED_INPUT);
+            creator.addAttr(result, "type", "SUCCESS", true);
+        }
+        catch (IllegalArgumentException iae) {
+            creator.addAttr(result, "type", "FAILURE", true);
+
+            // TODO I18N this message - getMessage() returns a lookup string, no
+            // human readable error message
+            result.setTextContent(iae.getMessage());
+        }
+
+        return doc;
     }
 
 
@@ -135,7 +173,6 @@
     }
 
 
-
     /**
      * Set the current state of this artifact. <b>NOTE</b>We don't store the
      * State object itself - which is not necessary - but its identifier. So
@@ -155,7 +192,7 @@
      * @return the current State of the artifact.
      */
     protected State getCurrentState(Object context) {
-        FLYSContext flysContext = (FLYSContext) context;
+        FLYSContext flysContext = getFlysContext(context);
         StateEngine engine      = (StateEngine) flysContext.get(
             FLYSContext.STATE_ENGINE_KEY);
 
@@ -164,17 +201,57 @@
 
 
     /**
-     * This method extracts the data that is contained in the FEED document.
+     * Adds a new StateData item to the data pool of this artifact.
+     *
+     * @param name the name of the data object.
+     * @param data the data object itself.
+     */
+    protected void addData(String name, StateData data) {
+        this.data.put(name, data);
+    }
+
+
+    /**
+     * This method stores the data that is contained in the FEED document.
      *
      * @param feed The FEED document.
      * @param xpath The XPath that points to the data nodes.
-     *
-     * @return a StateData array.
      */
-    public StateData[] extractData(Document feed, String xpath) {
+    public void saveData(Document feed, String xpath)
+    throws IllegalArgumentException
+    {
+        if (feed == null || xpath == null || xpath.length() == 0) {
+            throw new IllegalArgumentException("feed.no.input.data");
+        }
 
-        // TODO IMPLEMENT ME
-        return null;
+        NodeList nodes = (NodeList) XMLUtils.xpath(
+            feed,
+            xpath,
+            XPathConstants.NODESET,
+            ArtifactNamespaceContext.INSTANCE);
+
+        if (nodes == null || nodes.getLength() == 0) {
+            throw new IllegalArgumentException("feed.no.input.data");
+        }
+
+        int count = nodes.getLength();
+        logger.debug("Try to save " + count + " data items.");
+
+        for (int i = 0; i < count; i++) {
+            Node node = nodes.item(i);
+
+            String name = XMLUtils.xpathString(
+                node, "@art:name", ArtifactNamespaceContext.INSTANCE);
+            String value = XMLUtils.xpathString(
+                node, "@art:value", ArtifactNamespaceContext.INSTANCE);
+
+            if (name != null && value != null) {
+                logger.debug("Save data item for '" + name + "' : " + value);
+
+                // TODO ADD INPUT VALIDATION!
+                addData(name, new DefaultStateData(name, null, null, value));
+            }
+        }
     }
 }
 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :
diff -r 5243ac559e16 -r e0ded17a4846 flys-artifacts/src/main/java/de/intevation/flys/artifacts/WINFOArtifact.java
--- a/flys-artifacts/src/main/java/de/intevation/flys/artifacts/WINFOArtifact.java	Wed Mar 09 14:07:03 2011 +0000
+++ b/flys-artifacts/src/main/java/de/intevation/flys/artifacts/WINFOArtifact.java	Wed Mar 09 14:13:57 2011 +0000
@@ -31,6 +31,10 @@
     private static Logger logger = Logger.getLogger(WINFOArtifact.class);
 
 
+    /** The name of the artifact.*/
+    public static final String ARTIFACT_NAME = "winfo";
+
+
     /**
      * The default constructor.
      */
@@ -85,5 +89,15 @@
 
         return description;
     }
+
+
+    /**
+     * Returns the name of the concrete artifact.
+     *
+     * @return the name of the concrete artifact.
+     */
+    public String getName() {
+        return ARTIFACT_NAME;
+    }
 }
 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :