dive4elements/river: artifacts/src/main/java/org/dive4elements/river/artifacts/D4EArtifact.java comparison

comparison artifacts/src/main/java/org/dive4elements/river/artifacts/D4EArtifact.java @ 6140:60b94dec104b

Add handling of bound artifacts. When an artifact is bound to an out its facets will only be shown in that Out. They will be removed in the blackboard pass and marked as incompatible by the AttributeWriter

author	Andre Heinecke <aheinecke@intevation.de>
date	Fri, 31 May 2013 15:29:30 +0200
parents	af13ceeba52a
children	cc7df824d5c4

comparison

equal deleted inserted replaced

-:7c2a30198592
+:60b94dec104b
 "/art:action/art:template/@uuid";
 public static final String XPATH_FILTER =
 "/art:action/art:filter/art:out";
-public static final Pattern CONTAINS_OUT =
-Pattern.compile( "^(.*):OUT=(.+)$");
 /** Path to 'ids' (data) in doc that comes from datacage. */
 public static final String XPATH_IDS = "/art:action/art:ids/@value";
+/** Path to 'target_out' (data) in doc that comes from datacage. */
+public static final String XPATH_TARGET_OUT = "/art:action/art:target_out/@value";
 /** The constant string that shows that an operation was successful. */
 public static final String OPERATION_SUCCESSFUL = "SUCCESS";
 /** The constant string that shows that an operation failed. */
 * Used to generates "view" on the facets (hides facets not matching the
 * filter in output of collection);  out -&gt; facets.
 */
 protected Map<String, List<Facet>> filterFacets;
-protected String boundToOut;
+private String boundToOut;
 /**
 * The default constructor that creates an empty D4EArtifact.
 */
 ArtifactFactory factory,
 Object          context,
 CallMeta        callMeta,
 Document        data)
 {
-boolean debug = log.isDebugEnabled();
+log.debug("Setup this artifact with the uuid: " + identifier);
-if (debug) {
-log.debug("Setup this artifact with the uuid: " + identifier);
-}
 super.setup(identifier, factory, context, callMeta, data);
 RiverContext flysContext = RiverUtils.getFlysContext(context);
 List<State> states = getStates(context);
 String name = getName();
-if (debug) {
+log.debug("setup(): Set initial state for artifact '" + name + "'");
-log.debug("setup(): Set initial state for artifact '" + name + "'");
-}
 if (states == null) {
 log.error("No states found from which an initial "
 + "state could be picked.");
 }
 extractOut(data);
 }
 protected void extractOut(Document data) {
-log.debug("extractOut");
+String targetOut = XMLUtils.xpathString(data, XPATH_TARGET_OUT,
-String ids = XMLUtils.xpathString(data, XPATH_IDS,
 ArtifactNamespaceContext.INSTANCE);
+if (targetOut.isEmpty()) {
-log.debug("ids: '" + ids + "'");
+targetOut = null;
-if (ids != null) {
+}
-Matcher m = CONTAINS_OUT.matcher(ids);
-if (m.matches()) {
+setBoundToOut(targetOut);
-boundToOut = m.group(2);
-log.debug("Bound to out :'" + boundToOut + "'");
-}
-else {
-log.debug("does not match");
-}
-}
 }
 /**
 * Return the value of id element in Datacage data document.
 * @param data Document as passed by datacage.
 * @return the id element value of data document.
 */
 public static String getDatacageIDValue(Document data) {
 String ids = XMLUtils.xpathString(data, XPATH_IDS,
 ArtifactNamespaceContext.INSTANCE);
-if (ids != null) {
-Matcher m = CONTAINS_OUT.matcher(ids);
-if (m.matches()) {
-ids = m.group(1);
-}
-}
 return ids;
 }
 * Get facet as stored internally, with equalling name and index than given
 * facet.
 * @param facet that defines index and name of facet searched.
 * @return facet instance or null if not found.
 */
-public Facet getNativeFacet(Facet facet) {
+public Facet getNativeFacet(Facet facet, String outName) {
 String name  = facet.getName();
 int    index = facet.getIndex();
+if (getBoundToOut() != null && !getBoundToOut().isEmpty() &&
+!getBoundToOut().equals(outName)) {
+log.debug(name + ": not returning facets for " + outName +
+" because bound to " + getBoundToOut());
+return null;
+}
+log.debug("Facet: " + facet.getName());
+log.debug("Bound to out: " + getBoundToOut());
+log.debug("OutName: " + outName);
 for (List<Facet> fs: facets.values()) {
 for (Facet f: fs) {
 if (f.getIndex() == index && f.getName().equals(name)) {
 return f;
 *
 * @param id ID to map the facets to
 * @param facets List of facets to be stored
 */
 protected void addFacets(String id, List<Facet> facets) {
+for (Facet fac : facets) {
+fac.setBoundToOut(getBoundToOut());
+}
 this.facets.put(id, facets);
 }
 /**
 protected void dumpArtifact() {
 log.debug("++++++++++++++ DUMP ARTIFACT DATA +++++++++++++++++");
 // Include uuid, type, name
 log.debug(" - Name: " + getName());
 log.debug(" - UUID: " + identifier());
-log.debug(" - Class: " + this.getClass().getName());
+log.debug(" - Class: " + getClass().getName());
+log.debug(" - BoundToOut: " + getBoundToOut());
 log.debug("------ DUMP DATA ------");
 Collection<StateData> allData = data.values();
 for (StateData d: allData) {
 for (Map.Entry<String, List<Facet>> entry: facets.entrySet()) {
 String out = entry.getKey();
 List<Facet> fs = entry.getValue();
 for (Facet f: fs) {
 log.debug("  # " + out + " : " + f.getName());
+log.debug("  # boundToOut : " + f.getBoundToOut());
 }
 }
 log.debug("######## FACETS END ########");
 }
 * Return the Facets which a state provides
 * @param stateid String that identifies the state
 * @return List of Facets belonging to the state identifier
 */
 protected List<Facet> getFacets(String stateid) {
-return this.facets.get(stateid);
+return facets.get(stateid);
 }
 public String getBoundToOut() {
 return boundToOut;
 }
+/**
+* Binds this artifact and all its facet to an out
+*/
+public void setBoundToOut(String out) {
+boundToOut = out;
+for (List<Facet> stateFacets: facets.values()) {
+for (Facet fac: stateFacets) {
+fac.setBoundToOut(out);
+}
+}
+}
 }
 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

Mercurial > dive4elements > river

comparison artifacts/src/main/java/org/dive4elements/river/artifacts/D4EArtifact.java @ 6140:60b94dec104b