Check if error is a plugin error

Author: ssambasu

marklogic-data-hub/src/main/resources/ml-modules/root/marklogic.rest.resource/flow/assets/resource.xqy

@@ -167,8 +167,12 @@ declare function post(
               "errors": $errors
             }
           }
+        let $is-plugin-error :=
+          for $error in json:array-values($errors)
+          where contains(xdmp:to-json($error)/code, "DATAHUB-PLUGIN-ERROR") or contains(xdmp:to-json($error)/formatString , "DATAHUB-PLUGIN-ERROR")
+          return fn:true()
         let $resp :=
-          if (trace:get-error-count() > 0) then
+          if (trace:get-error-count() > 0 and $is-plugin-error) then
             fn:error((),"RESTAPI-SRVEXERR", (400, "Plugin error", text{$output}))
           else
             $output

marklogic-data-hub/src/main/resources/ml-modules/root/marklogic.rest.resource/sjsFlow/assets/resource.sjs

@@ -121,7 +121,12 @@ function post(context, params, input) {
       "errors": errors
     }
     if(resp.errorCount > 0){
-        fn.error(null, "RESTAPI-SRVEXERR", Sequence.from([400, "Plugin error", resp]));
+      for (let i = 0; i < errors.length; i++) {
+         if((errors[i].stack && errors[i].stack.includes("DATAHUB-PLUGIN-ERROR"))
+         || (errors[i].name && errors[i].name.includes("DATAHUB-PLUGIN-ERROR"))) {
+           fn.error(null, "RESTAPI-SRVEXERR", Sequence.from([400, "Plugin error", resp]));
+         }
+      }
     }
   }
   else {