Add matchFailuresAsNew query parameter

Author: ammsalme

src/api.json

@@ -70,6 +70,14 @@
               "default": false
             }
           },
+          {
+            "name": "matchFailuresAsNew",
+            "description": "Handle merge jobs where are all matches fail matchValidation as new.",
+            "in": "query",
+            "schema": {
+              "type": "boolean"
+            }
+          },
           {
             "name": "cataloger",
             "description": "Cataloger name to use while operating on a record. Note: requires admin rights to use",
@@ -309,6 +317,14 @@
               "default": false
             }
           },
+          {
+            "name": "matchFailuresAsNew",
+            "description": "Handle merge jobs where are all matches fail matchValidation as new.",
+            "in": "query",
+            "schema": {
+              "type": "boolean"
+            }
+          },
           {
             "name": "cataloger",
             "description": "Cataloger name to use while operating on a record. Note: requires admin rights to use",

src/api.yaml

@@ -231,6 +231,12 @@ paths:
           schema:
             type: boolean
             default: false
+        - name: matchFailuresAsNew
+          description: >-
+            Handle merge jobs where are all matches fail matchValidation as new
+          in: query
+          schema:
+            type: boolean
         - name: cataloger
           description: >-
             Cataloger name to use while operating on a record. Note: requires admin rights to use
@@ -404,6 +410,12 @@ paths:
           schema:
             type: boolean
             default: false
+        - name: matchFailuresAsNew
+          description: >-
+            Handle merge jobs where are all matches fail matchValidation as new
+          in: query
+          schema:
+            type: boolean
         - name: pRejectFile
           description: Error log file location
           in: query

src/interfaces/bulk.js

@@ -328,7 +328,7 @@ export default async function ({mongoUri, amqpUrl, allowedLibs}) {
     const paramUnique = queryParams.unique ? parseBoolean(queryParams.unique) : undefined;
     const paramMerge = queryParams.merge ? parseBoolean(queryParams.merge) : undefined;
     const paramSkipLowValidation = queryParams.skipLowValidation ? parseBoolean(queryParams.skipLowValidateLow) : undefined;
-
+    const paramMatchFailuresAsNew = queryParams.matchFailuresAsNew ? parseBoolean(queryParams.matchFailuresAsNew) : undefined;
 
     if (paramValidate === false && (paramUnique || paramMerge)) {
       logger.debug(`Query parameter validate=0 is not valid with query parameters unique=1 and/or merge=1`);
@@ -354,6 +354,7 @@ export default async function ({mongoUri, amqpUrl, allowedLibs}) {
       failOnError: queryParams.failOnError === undefined ? false : parseBoolean(queryParams.failOnError),
       // bulk skips changes that won't change the database record as default
       skipNoChangeUpdates: queryParams.skipNoChangeUpdates === undefined ? true : parseBoolean(queryParams.skipNoChangeUpdates),
+      matchFailuresAsNew: paramMatchFailuresAsNew,
       prio: false
     };
 

src/routes/prio.js

@@ -116,6 +116,7 @@ export default async ({sruUrl, amqpUrl, mongoUri, pollWaitTime, recordType, requ
         failOnError: null,
         // Prio forces updates as default, even if the update would not make changes to the database record
         skipNoChangeUpdates: req.query.skipNoChangeUpdates === undefined ? false : parseBoolean(req.query.skipNoChangeUpdates),
+        matchFailuresAsNew: req.query.matchFailuresAsNew === undefined ? undefined : parseBoolean(req.query.matchFailuresAsNew),
         prio: true
       };
 

src/routes/queryUtils.js

@@ -24,6 +24,7 @@ export function checkQueryParams(req, res, next) {
     {name: 'skipLowValidation', value: queryParams.skipLowValidation ? (/^(?:1|0|true|false)$/ui).test(queryParams.skipLowValidation) : true},
     {name: 'failOnError', value: queryParams.failOnError ? (/^(?:1|0|true|false)$/ui).test(queryParams.failOnError) : true},
     {name: 'skipNoChangeUpdates', value: queryParams.skipNoChangeUpdates ? (/^(?:1|0|true|false)$/ui).test(queryParams.skipNoChangeUpdates) : true},
+    {name: 'maatchFailuresAsNew', value: queryParams.matchFailuresAsNew ? (/^(?:1|0|true|false)$/ui).test(queryParams.matchFailuresAsNew) : true},
     {name: 'pRejectFile', value: queryParams.pRejectFile ? (/^[a-z|A-Z|0-9|/|.|_|-]{0,100}$/u).test(queryParams.pRejectFile) : true},
     {name: 'pLogFile', value: queryParams.pLogFile ? (/^[a-z|A-Z|0-9|/|.|_|-]{0,100}$/u).test(queryParams.pLogFile) : true},
     {name: 'pCatalogerIn', value: queryParams.pCatalogerIn ? (/^(?:0|false|undefined|[A-Z|0-9|_|-]{0,10}$)/u).test(queryParams.pCatalogerIn) : true},