feat(orderdesk): inventory update skipping

Author: ndvo

src/foxy/DataStoreBase.js

@@ -1,5 +1,11 @@
+const config = require("../../config.js");
+
 class DataStoreBase {
 
+  skipUpdate = {
+    inventory: []
+  }
+
   constructor() {
     const abstractMethods = [
       'fetchItems',
@@ -12,6 +18,20 @@ class DataStoreBase {
     if (unimplemented.length) {
       throw new TypeError(unimplemented.join(',') + " must be overriden");
     }
+    this.skipFromEnv();
+  }
+
+  /**
+   * Autoconfigures the instance to skip the validation of prices and inventory
+   * of items with codes listed in the configured environment variables.
+   */
+  skipFromEnv() {
+    if (config.datastore.skipUpdate.inventory === '__ALL__') {
+      this.skipUpdate.inventory.all = true;
+    }
+    this.skipUpdate.inventory.concat(
+      (config.datastore.skipUpdate.inventory || '').split(',')
+    );
   }
 
   /**

src/functions/datastore-integration-orderdesk/DataStore.js

@@ -101,9 +101,17 @@ class DataStore extends DataStoreBase {
   /**
    * Update inventory items in OrderDesk
    *
-   * @param {Array<OrderDeskItem>} items to be updated
+   * It won't update any items if the skip update inventory option is set to __ALL__.
+   * It won't update any items whose codes are set in skip update inventory option.
+   *
+   * @param {Array<OrderDeskItem>} items to be updated.
+   * @returns {Object} the OrderDesk response.
    */
   async updateInventoryItems(items) {
+    if (this.skipUpdate.inventory.all) {
+      return {};
+    }
+    items = items.filter(i => !this.skipUpdate.inventory.includes(i.code));
     const invalid = items.filter((i) => !this.validateInventoryItem(i));
     if (invalid.length) {
       throw new Error("Invalid inventory items for update", invalid.join(','));

src/functions/datastore-integration-orderdesk/webhook.js

@@ -41,18 +41,26 @@ async function prePayment(body) {
  * Process a transaction/created Foxy Webhook.
  *
  * @param {Object} body the parsed body of the Foxy request.
- * @returns {}
+ * @returns {Response}
  */
 async function transactionCreated(body) {
-  const datastore = getDataStore();
-  const pairs = await buildPairs(body, FoxyWebhook, datastore);
-  const updated = pairs.map(p => ({...p[1],
-    stock: Number(p[1].inventory) - Number(p[0].quantity), // Notice that OrderDesk inventory field is "stock"
-  }));
-  const result = await datastore.updateInventoryItems(updated);
-  if (result.status === 'success') {
+  if (config.datastore.skipUpdate.inventory === '__ALL__' ) {
     return response();
-  } else {
+  }
+  try {
+    const datastore = getDataStore();
+    const pairs = await buildPairs(body, FoxyWebhook, datastore);
+    const updated = pairs.map(p => ({...p[1],
+      stock: Number(p[1].inventory) - Number(p[0].quantity), // Notice that OrderDesk inventory field is "stock"
+    }));
+    const result = await datastore.updateInventoryItems(updated);
+    if (result.status === 'success') {
+      return response();
+    } else {
+      return response('Internal Server Error', 500);
+    }
+  } catch (e) {
+    console.error('Could not update inventory', e.name, e.message);
     return response('Internal Server Error', 500);
   }
 }