return new document instead of original

reactioncommerce · Jan 2, 2019 · 09e2b4c · 09e2b4c
1 parent ba513f9
commit 09e2b4c
Showing 1 changed file with 16 additions and 8 deletions.
diff --git a/imports/plugins/core/inventory/server/no-meteor/startup.js b/imports/plugins/core/inventory/server/no-meteor/startup.js
@@ -24,7 +24,7 @@ export default function startup(context) {
     // in some instances which causes the order not to cancel
       const orderItems = order.shipping.reduce((list, group) => [...list, ...group.items], []);
       orderItems.forEach(async (item) => {
-        const updatedItem = await collections.Products.findOneAndUpdate(
+        const { value: updatedItem } = await collections.Products.findOneAndUpdate(
           {
             _id: item.variantId
           },
@@ -33,13 +33,15 @@ export default function startup(context) {
               inventoryAvailableToSell: +item.quantity,
               inventoryQuantity: +item.quantity
             }
+          }, {
+            returnNewDocument: true
           }
         );
 
         // Update parents of supplied item
         await collections.Products.updateMany(
           {
-            _id: { $in: updatedItem.value.ancestors }
+            _id: { $in: updatedItem.ancestors }
           },
           {
             $inc: {
@@ -65,21 +67,23 @@ export default function startup(context) {
     // in some instances which causes the order not to cancel
       const orderItems = order.shipping.reduce((list, group) => [...list, ...group.items], []);
       orderItems.forEach(async (item) => {
-        const updatedItem = await collections.Products.findOneAndUpdate(
+        const { value: updatedItem } = await collections.Products.findOneAndUpdate(
           {
             _id: item.variantId
           },
           {
             $inc: {
               inventoryAvailableToSell: +item.quantity
             }
+          }, {
+            returnNewDocument: true
           }
         );
 
         // Update parents of supplied item
         await collections.Products.updateMany(
           {
-            _id: { $in: updatedItem.value.ancestors }
+            _id: { $in: updatedItem.ancestors }
           },
           {
             $inc: {
@@ -109,21 +113,23 @@ export default function startup(context) {
     // we can map over the unique productIds at the end, and update each one once
     orderItems.forEach(async (item) => {
       // Update supplied item inventory
-      const updatedItem = await collections.Products.findOneAndUpdate(
+      const { value: updatedItem } = await collections.Products.findOneAndUpdate(
         {
           _id: item.variantId
         },
         {
           $inc: {
             inventoryAvailableToSell: -item.quantity
           }
+        }, {
+          returnNewDocument: true
         }
       );
 
       // Update supplied item inventory
       await collections.Products.updateMany(
         {
-          _id: { $in: updatedItem.value.ancestors }
+          _id: { $in: updatedItem.ancestors }
         },
         {
           $inc: {
@@ -152,21 +158,23 @@ export default function startup(context) {
     // we can map over the unique productIds at the end, and update each one once
     orderItems.forEach(async (item) => {
       // Update supplied item inventory
-      const updatedItem = await collections.Products.findOneAndUpdate(
+      const { value: updatedItem } = await collections.Products.findOneAndUpdate(
         {
           _id: item.variantId
         },
         {
           $inc: {
             inventoryQuantity: -item.quantity
           }
+        }, {
+          returnNewDocument: true
         }
       );
 
       // Update supplied item inventory
       await collections.Products.updateMany(
         {
-          _id: { $in: updatedItem.value.ancestors }
+          _id: { $in: updatedItem.ancestors }
         },
         {
           $inc: {