Add ENV to disable inventory auto-publish

imports/plugins/core/catalog/server/no-meteor/mutations/hashProduct.js

@@ -36,15 +36,9 @@ const variantFieldsThatNeedPublishing = [
   "compareAtPrice",
   "height",
   "index",
-  "inventoryManagement",
-  "inventoryPolicy",
-  "inventoryInStock",
   "isDeleted",
-  "isLowQuantity",
-  "isSoldOut",
   "isVisible",
   "length",
-  "lowInventoryWarningThreshold",
   "metafields",
   "minOrderQuantity",
   "optionTitle",

imports/plugins/core/inventory/register.js

@@ -1,8 +1,38 @@
 import Reaction from "/imports/plugins/core/core/server/Reaction";
+import config from "./server/config";
 import startup from "./server/no-meteor/startup";
 import schemas from "./server/no-meteor/schemas";
 import xformCatalogBooleanFilters from "./server/no-meteor/utils/xformCatalogBooleanFilters";
 
+const publishedProductFields = [];
+
+// These require manual publication always
+const publishedProductVariantFields = [
+  "inventoryManagement",
+  "inventoryPolicy"
+];
+
+// Additional fields require manual publication only if they are
+// not auto-published on every variant update.
+if (!config.AUTO_PUBLISH_INVENTORY_FIELDS) {
+  publishedProductFields.push(
+    "inventoryAvailableToSell",
+    "inventoryInStock",
+    "isBackorder",
+    "isLowQuantity",
+    "isSoldOut"
+  );
+
+  publishedProductVariantFields.push(
+    "inventoryAvailableToSell",
+    "inventoryInStock",
+    "isBackorder",
+    "isLowQuantity",
+    "isSoldOut",
+    "lowInventoryWarningThreshold"
+  );
+}
+
 Reaction.registerPackage({
   label: "Inventory",
   name: "reaction-inventory",
@@ -13,5 +43,9 @@ Reaction.registerPackage({
   },
   graphQL: {
     schemas
+  },
+  catalog: {
+    publishedProductFields,
+    publishedProductVariantFields
   }
 });

imports/plugins/core/inventory/server/config.js

@@ -0,0 +1,5 @@
+import envalid, { bool } from "envalid";
+
+export default envalid.cleanEnv(process.env, {
+  AUTO_PUBLISH_INVENTORY_FIELDS: bool({ default: true })
+});

imports/plugins/core/inventory/server/no-meteor/startup.js

@@ -1,5 +1,6 @@
-import updateCatalogProductInventoryStatus from "/imports/plugins/core/catalog/server/no-meteor/utils/updateCatalogProductInventoryStatus";
+import config from "../config";
 import getVariantInventoryNotAvailableToSellQuantity from "./utils/getVariantInventoryNotAvailableToSellQuantity";
+import updateCatalogProductInventoryStatus from "./utils/updateCatalogProductInventoryStatus";
 import updateParentInventoryFields from "./utils/updateParentInventoryFields";
 
 /**
@@ -197,7 +198,7 @@ export default function startup(context) {
 
   appEvents.on("afterVariantUpdate", async ({ _id, field }) => {
     // If the updated field was `inventoryInStock`, adjust `inventoryAvailableToSell` quantities
-    if (field === "inventoryInStock") {
+    if (field === "inventoryInStock" || field === "lowInventoryWarningThreshold") {
       const doc = await collections.Products.findOne({ _id });
 
       // Get reserved inventory - the inventory currently in an unprocessed order
@@ -221,7 +222,9 @@ export default function startup(context) {
       await updateParentInventoryFields(doc, collections);
 
       // Publish inventory to catalog
-      await updateCatalogProductInventoryStatus(doc.ancestors[0], collections);
+      if (config.AUTO_PUBLISH_INVENTORY_FIELDS) {
+        await updateCatalogProductInventoryStatus(doc.ancestors[0], collections);
+      }
     }
   });
 }

imports/plugins/core/inventory/server/no-meteor/utils/getProductInventoryAvailableToSellQuantity.js

@@ -3,9 +3,9 @@ import getVariants from "/imports/plugins/core/catalog/server/no-meteor/utils/ge
 /**
  *
  * @method getProductInventoryAvailableToSellQuantity
- * @summary Get the number of product variants still avalible to sell. This calculates based off of `inventoryAvailableToSell`.
- * This function can take only a top product ID and a mongo collection as params to return the product
- * `inventoryAvailableToSell` quantity, which is a calculation of the sum of all variant `inventoryAvailableToSell` quantities.
+ * @summary This function can take only a top product ID and a mongo collection as params to return the product
+ *   `inventoryAvailableToSell` quantity, which is a calculation of the sum of all variant
+ *   `inventoryAvailableToSell` quantities.
  * @param {Object} productId - A top level product variant object.
  * @param {Object} collections - Raw mongo collections.
  * @param {Object[]} variants - Array of product variant option objects.

imports/plugins/core/inventory/server/no-meteor/utils/getProductInventoryInStockQuantity.js

@@ -3,9 +3,8 @@ import getVariants from "/imports/plugins/core/catalog/server/no-meteor/utils/ge
 /**
  *
  * @method getProductInventoryInStockQuantity
- * @summary Get the number of product variants still avalible to sell. This calculates based off of `inventoryInStock`.
- * This function can take only a top product ID and a mongo collection as params to return the product
- * `inventoryInStock` quantity, which is a calculation of the sum of all variant `inventoryInStock` quantities.
+ * @summary This function can take only a top product ID and a mongo collection as params to return the product
+ *   `inventoryInStock` quantity, which is a calculation of the sum of all variant `inventoryInStock` quantities.
  * @param {Object} productId - A top level product variant object.
  * @param {Object} collections - Raw mongo collections.
  * @param {Object[]} variants - Array of product variant option objects.

imports/plugins/core/inventory/server/no-meteor/utils/getVariantInventoryAvailableToSellQuantity.js

@@ -3,7 +3,7 @@ import getVariants from "/imports/plugins/core/catalog/server/no-meteor/utils/ge
 /**
  *
  * @method getVariantInventoryAvailableToSellQuantity
- * @summary Get the number of product variants still avalible to sell. This calculates based off of `inventoryAvailableToSell`.
+ * @summary Get the number of product variants still av to sell. This calculates based off of `inventoryAvailableToSell`.
  * This function can take only a top level variant object and a mongo collection as params to return the product
  * variant quantity. This method can also take a top level variant, mongo collection and an array of
  * product variant options as params to skip the db lookup and return the variant quantity

imports/plugins/core/catalog/server/no-meteor/utils/updateCatalogProductInventoryStatus.js → imports/plugins/core/inventory/server/no-meteor/utils/updateCatalogProductInventoryStatus.js

@@ -1,8 +1,8 @@
 import Logger from "@reactioncommerce/logger";
 import _ from "lodash";
-import isBackorder from "/imports/plugins/core/inventory/server/no-meteor/utils/isBackorder";
-import isLowQuantity from "/imports/plugins/core/inventory/server/no-meteor/utils/isLowQuantity";
-import isSoldOut from "/imports/plugins/core/inventory/server/no-meteor/utils/isSoldOut";
+import isBackorder from "./isBackorder";
+import isLowQuantity from "./isLowQuantity";
+import isSoldOut from "./isSoldOut";
 
 /**
  *

imports/plugins/core/catalog/server/no-meteor/utils/updateCatalogProductInventoryStatus.test.js → imports/plugins/core/inventory/server/no-meteor/utils/updateCatalogProductInventoryStatus.test.js

@@ -1,7 +1,7 @@
 import mockContext from "/imports/test-utils/helpers/mockContext";
-import { rewire as rewire$isBackorder, restore as restore$isBackorder } from "/imports/plugins/core/inventory/server/no-meteor/utils/isBackorder";
-import { rewire as rewire$isLowQuantity, restore as restore$isLowQuantity } from "/imports/plugins/core/inventory/server/no-meteor/utils/isLowQuantity";
-import { rewire as rewire$isSoldOut, restore as restore$isSoldOut } from "/imports/plugins/core/inventory/server/no-meteor/utils/isSoldOut";
+import { rewire as rewire$isBackorder, restore as restore$isBackorder } from "./isBackorder";
+import { rewire as rewire$isLowQuantity, restore as restore$isLowQuantity } from "./isLowQuantity";
+import { rewire as rewire$isSoldOut, restore as restore$isSoldOut } from "./isSoldOut";
 import updateCatalogProductInventoryStatus from "./updateCatalogProductInventoryStatus";
 
 const mockCollections = { ...mockContext.collections };

imports/plugins/core/inventory/server/no-meteor/utils/updateParentInventoryFields.js

@@ -1,6 +1,6 @@
-import getTopLevelVariant from "/imports/plugins/core/catalog/server/no-meteor/utils/getTopLevelVariant";
-import getProductInventoryAvailableToSellQuantity from "./getProductInventoryAvailableToSellQuantity.js";
+import getProductInventoryAvailableToSellQuantity from "./getProductInventoryAvailableToSellQuantity";
 import getProductInventoryInStockQuantity from "./getProductInventoryInStockQuantity";
+import getTopLevelVariant from "./getTopLevelVariant";
 import getVariantInventoryAvailableToSellQuantity from "./getVariantInventoryAvailableToSellQuantity";
 import getVariantInventoryInStockQuantity from "./getVariantInventoryInStockQuantity";