updating hr-hub example

Author: paxtonhare

examples/hr-hub/README.md

@@ -14,7 +14,7 @@ The data are separated into 2 folders under the input/ folder.
 ```
 
 # TLDR; How do I run it?
-Check out the [HR Hub Tutorial](https://marklogic-community.github.io/marklogic-data-hub/) on the Datahub Site.
+Check out the [HR Hub Tutorial](https://marklogic-community.github.io/marklogic-data-hub/getting-started-1x) on the Datahub Site.
 
 # Global Corp
 Global Corp has exported the Employee data from a relational database. They are provided to you as csv files, one for each table.

examples/hr-hub/plugins/entities/Employee/Employee.entity.json

@@ -0,0 +1,14 @@
+{
+  "info" : {
+    "title" : "Employee",
+    "version" : "0.0.1"
+  },
+  "definitions" : {
+    "Employee" : {
+      "required" : [ ],
+      "rangeIndex" : [ ],
+      "wordLexicon" : [ ],
+      "properties" : { }
+    }
+  }
+}

examples/hr-hub/plugins/entities/Employee/harmonize/harmonize-acme-tech/content/content.sjs

@@ -1,29 +1,29 @@
-/*
- * Create Content Plugin
- *
- * @param id         - the identifier returned by the collector
- * @param options    - an object containing options. Options are sent from Java
- *
- * @return - your content
- */
-function createContent(id, options) {
-  var doc = cts.doc(id);
-  var root = doc.root;
-
-  // for xml we need to use xpath
-  if (root && xdmp.nodeKind(root) === 'element') {
-    return root.xpath('/*:envelope/*:content/node()');
-  }
-  // for json we need to return the content
-  else if (root && root.content) {
-    return root.content;
-  }
-  // for everything else
-  else {
-    return doc;
-  }
-}
-
-module.exports = {
-  createContent: createContent
-};
+/*
+ * Create Content Plugin
+ *
+ * @param id         - the identifier returned by the collector
+ * @param options    - an object containing options. Options are sent from Java
+ *
+ * @return - your content
+ */
+function createContent(id, options) {
+  var doc = cts.doc(id);
+  var root = doc.root;
+
+  // for xml we need to use xpath
+  if (root && xdmp.nodeKind(root) === 'element') {
+    return root.xpath('/*:envelope/*:instance/node()');
+  }
+  // for json we need to return the instance
+  else if (root && root.envelope && root.envelope.instance) {
+    return root.envelope.instance;
+  }
+  // for everything else
+  else {
+    return doc;
+  }
+}
+
+module.exports = {
+  createContent: createContent
+};

examples/hr-hub/plugins/entities/Employee/harmonize/harmonize-acme-tech/writer/writer.sjs

@@ -8,7 +8,7 @@
  * @return - nothing
  */
 function write(id, envelope, options) {
-  xdmp.documentInsert(id, envelope, [], ['json-employee']);
+  xdmp.documentInsert(id, envelope, xdmp.defaultPermissions(), options.flow);
 }
 
 module.exports = write;

examples/hr-hub/plugins/entities/Employee/harmonize/harmonize-global-corp/collector/collector.sjs

@@ -1,23 +1,24 @@
-/*
- * Collect IDs plugin
- *
- * @param options - a map containing options. Options are sent from Java
- *
- * @return - an array of ids or uris
- */
-function collect(options) {
-
-  // grab a list of the unique employee IDs out of the JSON data
-  var y = [];
-  for (var x of fn.collection('load-global-corp')) {
-    var empid = x.root.content.emp_id;
-    if (empid) {
-      y.push(empid);
-    }
-  }
-  return fn.distinctValues(xdmp.arrayValues(y));
-}
-
-module.exports = {
-  collect: collect
-};
+/*
+ * Collect IDs plugin
+ *
+ * @param options - a map containing options. Options are sent from Java
+ *
+ * @return - an array of ids or uris
+ */
+function collect(options) {
+
+  // grab a list of the unique employee IDs out of the JSON data
+  // This is a really bad way to do this. Use a range index instead
+  var y = [];
+  for (var x of fn.collection('load-global-corp')) {
+    var empid = x.root.envelope.instance.emp_id;
+    if (empid) {
+      y.push(empid);
+    }
+  }
+  return fn.distinctValues(xdmp.arrayValues(y));
+}
+
+module.exports = {
+  collect: collect
+};

examples/hr-hub/plugins/entities/Employee/harmonize/harmonize-global-corp/content/content.sjs

@@ -1,30 +1,30 @@
-/*
- * Create Content Plugin
- *
- * @param id         - the identifier returned by the collector
- * @param options    - an object containing options. Options are sent from Java
- *
- * @return - your content
- */
-function createContent(id, options) {
-  // start with an empty object
-  content = {};
-
-  // find the documents matching the given employee id
-  for (var doc of cts.search(cts.jsonPropertyValueQuery('emp_id', id))) {
-
-    // merge the keys and values from the found document into content
-    for (var key in doc.root.content) {
-      if (doc.root.content.hasOwnProperty(key)) {
-        content[key] = doc.root.content[key];
-      }
-    }
-  }
-
-  // return the merged content
-  return content;
-}
-
-module.exports = {
-  createContent: createContent
-};
+/*
+ * Create Content Plugin
+ *
+ * @param id         - the identifier returned by the collector
+ * @param options    - an object containing options. Options are sent from Java
+ *
+ * @return - your content
+ */
+function createContent(id, options) {
+  // start with an empty object
+  content = {};
+
+  // find the documents matching the given employee id
+  for (var doc of cts.search(cts.jsonPropertyValueQuery('emp_id', id))) {
+
+    // merge the keys and values from the found document into content
+    for (var key in doc.root.envelope.instance) {
+      if (doc.root.envelope.instance.hasOwnProperty(key)) {
+        content[key] = doc.root.envelope.instance[key];
+      }
+    }
+  }
+
+  // return the merged content
+  return content;
+}
+
+module.exports = {
+  createContent: createContent
+};

examples/hr-hub/plugins/entities/Employee/harmonize/harmonize-global-corp/writer/writer.sjs

@@ -8,7 +8,7 @@
  * @return - nothing
  */
 function write(id, envelope, options) {
-  xdmp.documentInsert('/employees/' + id + '.json', envelope);
+  xdmp.documentInsert('/employees/' + id + '.json', envelope, xdmp.defaultPermissions(), options.flow);
 }
 
 module.exports = write;