adding writer plugin to scaffolding

updating to 8.0-5
adding hr-hub example
turning off debug logging by default

Author: paxtonhare

examples/hr-hub/input/EmployeeTables/DeptTable.csv

@@ -0,0 +1,6 @@
+dept_num,dept_name
+1,Sales
+2,Marketing
+3,Engineering
+4,R&D
+5,Training

examples/hr-hub/input/EmployeeTables/EmployeeTable.csv

@@ -0,0 +1,21 @@
+/*
+ * Collect IDs plugin
+ *
+ * @param options - a map containing options. Options are sent from Java
+ *
+ * @return - an array of ids or uris
+ */
+function collect(options) {
+  var y = [];
+  for (var x of fn.collection()) {
+    var empid = x.root.content.emp_id;
+    if (empid) {
+      y.push(empid);
+    }
+  }
+  return fn.distinctValues(xdmp.arrayValues(y));
+}
+
+module.exports = {
+  collect: collect
+};

examples/hr-hub/input/EmployeeTables/SalaryTable.csv

@@ -0,0 +1,33 @@
+/*
+ * Create Content Plugin
+ *
+ * @param id       - the identifier returned by the collector
+ * @param content  - your final content
+ * @param headers  - an array of header objects
+ * @param triples  - an array of triples
+ * @param options  - an object containing options. Options are sent from Java
+ *
+ * @return - your content
+ */
+function createContent(id, content, headers, triples, 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
+};

examples/hr-hub/plugins/entities/Employee/conformance/create-employees/collector/collector.sjs

@@ -0,0 +1 @@
+<?xml version="1.0" ?><flow xmlns="http://marklogic.com/data-hub"><name>create-employees</name><entity>Employee</entity><type>conformance</type><complexity>simple</complexity><data-format>application/json</data-format><plugins></plugins></flow>

examples/hr-hub/plugins/entities/Employee/conformance/create-employees/content/content.sjs

@@ -0,0 +1,18 @@
+/*
+ * Create Headers Plugin
+ *
+ * @param id       - the identifier returned by the collector
+ * @param content  - your final content
+ * @param headers  - an array of header objects
+ * @param triples  - an array of triples
+ * @param options  - an object containing options. Options are sent from Java
+ *
+ * @return - an array of header objects
+ */
+function createHeaders(id, content, headers, triples, options) {
+  return [];
+}
+
+module.exports = {
+  createHeaders: createHeaders
+};

examples/hr-hub/plugins/entities/Employee/conformance/create-employees/create-employees.xml

@@ -0,0 +1,19 @@
+/*
+ * Create Triples Plugin
+ *
+ * @param id       - the identifier returned by the collector
+ * @param content  - your final content
+ * @param headers  - an array of header objects
+ * @param triples  - an array of triples
+ * @param options  - an object containing options. Options are sent from Java
+ *
+ * @return - an array of triples
+ */
+function createTriples(id, content, headers, triples, options) {
+  return [];
+}
+
+module.exports = {
+  createTriples: createTriples
+};
+

examples/hr-hub/plugins/entities/Employee/conformance/create-employees/headers/headers.sjs

@@ -0,0 +1,17 @@
+/*~
+ * Writer Plugin
+ *
+ * @param id       - the identifier returned by the collector
+ * @param envelope - the final envelope
+ * @param options  - a map containing options. Options are sent from Java
+ *
+ * @return - zero or more header nodes
+ */
+function write(id, content, options) {
+  xdmp.documentInsert('/employees/' + id + '.json', content);
+}
+
+module.exports = {
+  write: write
+};
+

examples/hr-hub/plugins/entities/Employee/conformance/create-employees/triples/triples.sjs

@@ -0,0 +1,18 @@
+/*
+ * Create Content Plugin
+ *
+ * @param id       - the identifier returned by the collector
+ * @param content  - your final content
+ * @param headers  - an array of header objects
+ * @param triples  - an array of triples
+ * @param options  - an object containing options. Options are sent from Java
+ *
+ * @return - your content
+ */
+function createContent(id, content, headers, triples, options) {
+  return content;
+}
+
+module.exports = {
+  createContent: createContent
+};