#1845 add flow name to the error record written to the jobs db, creat… (#1870)

* #1845 add flow name to the error record written to the jobs db, create a getter for this data

* #1845 fix typed assignment

Author: Joe Crean

marklogic-data-hub/src/main/resources/ml-modules/root/data-hub/4/impl/run-flow-context.sjs

@@ -109,6 +109,10 @@ function getFlow() {
   return getGlobalContext().flow;
 }
 
+function getFlowName() {
+  return getFlow().name;
+}
+
 function getFlowType() {
   return getGlobalContext()['flow-type'];
 }
@@ -170,6 +174,7 @@ module.exports = {
   withOptions: withOptions,
   withTrace: withTrace,
   getFlow: getFlow,
+  getFlowName: getFlowName,
   getFlowType: getFlowType,
   getModuleUri: getModuleUri,
   getCodeFormat: getCodeFormat,

marklogic-data-hub/src/main/resources/ml-modules/root/data-hub/4/impl/run-flow-context.xqy

@@ -121,6 +121,12 @@ declare function rfc:get-flow() as element(hub:flow)
   map:get($context, "flow")
 };
 
+declare function rfc:get-flow-name() as xs:string
+{
+  let $flow as element(hub:flow) := rfc:get-flow()
+  return $flow/hub:name
+};
+
 declare function rfc:get-flow-type() as xs:string
 {
   map:get($context, "flow-type")

marklogic-data-hub/src/main/resources/ml-modules/root/data-hub/4/impl/trace-lib.sjs

@@ -196,6 +196,7 @@ function writeErrorTrace(itemContext) {
           traceId: currentTrace.traceId,
           created: currentTrace.created,
           identifier: rfc.getId(itemContext),
+          flowName: rfc.getFlowName(),
           flowType: rfc.getFlowType(),
           hasError: false,
           steps: []
@@ -231,6 +232,9 @@ function writeErrorTrace(itemContext) {
           nb.startElement("identifier");
             nb.addText(rfc.getId(itemContext).toString());
           nb.endElement();
+          nb.startElement("flowName");
+            nb.addText(rfc.getFlowName().toString());
+          nb.endElement();
           nb.startElement("flowType");
             nb.addText(rfc.getFlowType().toString());
           nb.endElement();

marklogic-data-hub/src/main/resources/ml-modules/root/data-hub/4/impl/trace-lib.xqy

@@ -240,6 +240,7 @@ declare %private function trace:write-error-trace(
                 map:entry("traceId", map:get($current-trace, "traceId")),
                 map:entry("created", map:get($current-trace, "created")),
                 map:entry("identifier", rfc:get-id($item-context)),
+                map:entry("flowName", rfc:get-flow-name() ),
                 map:entry("flowType", rfc:get-flow-type()),
                 map:entry("hasError", trace:has-errors()),
                 let $steps := json:array()
@@ -260,6 +261,7 @@ declare %private function trace:write-error-trace(
               element traceId { map:get($current-trace, "traceId") },
               element created { map:get($current-trace, "created") },
               element identifier { rfc:get-id($item-context) },
+              element flowName { rfc:get-flow-name() },
               element flowType { rfc:get-flow-type() },
               element hasError { trace:has-errors() },
               element steps {