fixed #344

Author: paxtonhare

marklogic-data-hub/src/main/resources/scaffolding/harmonize/sjs/collector.sjs

@@ -6,7 +6,8 @@
  * @return - an array of ids or uris
  */
 function collect(options) {
-  return cts.uris(null, null, cts.trueQuery());
+  // by default we return the URIs in the same collection as the Flow name
+  return cts.uris(null, null, cts.collectionQuery(options.flow));
 }
 
 module.exports = {

marklogic-data-hub/src/main/resources/scaffolding/harmonize/xqy/collector.xqy

@@ -14,6 +14,7 @@ declare option xdmp:mapping "false";
 declare function plugin:collect(
   $options as map:map) as xs:string*
 {
-  cts:uris((), (), cts:true-query())
+  (: by default we return the URIs in the same collection as the Flow name :)
+  cts:uris((), (), cts:collection-query(map:get($options, "flow")))
 };