280 add documentdb interoperability

app/lib/database-configuration.js

@@ -145,7 +145,6 @@
     if (attackObject.stix.type === 'x-mitre-collection') {
       if (invalidIds.includes(attackObject.stix.id)) {
         attackObject.stix.id = validId;
-        // eslint-disable-next-line no-await-in-loop
         await attackObject.save();
         collectionUpdates += 1;
       }
@@ -160,7 +159,6 @@
         }
       }
       if (attackObjectUpdated) {
-        // eslint-disable-next-line no-await-in-loop
         await attackObject.save();
         objectUpdates += 1;
       }
@@ -190,7 +188,6 @@
     }
 
     if (collectionIndexUpdated) {
-      // eslint-disable-next-line no-await-in-loop
       await collectionIndex.save();
       collectionIndexUpdates += 1;
     }
@@ -247,7 +244,7 @@
             const newMarkingDefinition = new MarkingDefinition(newMarkingDefinitionData);
             await newMarkingDefinition.save();
             logger.info(`Created static marking definition ${newMarkingDefinition.stix.name}`);
           } catch (err) {
             logger.error(
               `Unable to create static marking definition ${staticMarkingDefinition.name}`,
             );
@@ -255,7 +252,7 @@
         }
       }
     }
   } catch (err) {
     logger.error('Unable to parse static marking definitions');
   }
 }

app/lib/database-connection.js

@@ -14,6 +14,9 @@ exports.initializeConnection = async function (options) {
 
   const mongoose = require('mongoose');
 
+  // Set `strictQuery` to `true` to omit unknown fields in queries.
+  mongoose.set('strictQuery', true);
+
   // Configure mongoose to use ES6 promises
   mongoose.Promise = global.Promise;
 

app/lib/database-in-memory.js

@@ -11,6 +11,9 @@ exports.initializeConnection = async function () {
 
   const uri = mongod.getUri();
 
+  // Set `strictQuery` to `true` to omit unknown fields in queries.
+  mongoose.set('strictQuery', true);
+
   // Configure mongoose to use ES6 promises
   mongoose.Promise = global.Promise;
 
@@ -39,7 +42,6 @@ exports.clearDatabase = async function () {
 
   for (const key in collections) {
     const collection = collections[key];
-    // eslint-disable-next-line no-await-in-loop
     await collection.deleteMany();
   }
 };

app/lib/regex.js

@@ -1,15 +1,17 @@
 'use strict';
 
+const logger = require('../lib/logger');
+
 exports.sanitizeRegex = function (expression) {
   // Compile the expression. If it's valid, return the expression. Otherwise, return an empty string.
   try {
     // Escapes all regex characters so they are treated like literal characters rather than special regex characters
-    // eslint-disable-next-line no-useless-escape
     expression = expression.replace(/[.*+?^${}()|[\]\\]/g, '\\$&');
     // eslint-disable-next-line no-new
     new RegExp(expression);
     return expression;
   } catch (err) {
+    logger.warn(err);
     return '';
   }
 };

app/repository/_abstract.repository.js

@@ -75,8 +75,8 @@ class AbstractRepository {
    * @param {*} modified The modification date for the document.
    * @returns {Object} The removed document.
    */
-  async findOneAndRemove(stixId, modified) {
-    throw new NotImplementedError(this.constructor.name, 'findOneAndRemove');
+  async findOneAndDelete(stixId, modified) {
+    throw new NotImplementedError(this.constructor.name, 'findOneAndDelete');
   }
 
   /**