fix(product): Return updated collections (#12354)

Collection updates without a `products` payload were not returned from the service layer due to an incorrect early return

Fixes SUP-1488

.changeset/fair-turtles-end.md

@@ -0,0 +1,5 @@
+---
+"@medusajs/product": patch
+---
+
+fix(product): Return updated collections

packages/modules/product/integration-tests/__tests__/product-module-service/product-collections.spec.ts

@@ -384,6 +384,22 @@ moduleIntegrationTestRunner<IProductModuleService>({
           )
         })
 
+        it("should respond with collections when products are updated", async () => {
+          const collections = await service.updateProductCollections(
+            collectionId,
+            {
+              title: "Updated Collection",
+            }
+          )
+
+          expect(collections).toEqual(
+            expect.objectContaining({
+              id: collectionId,
+              title: "Updated Collection",
+            })
+          )
+        })
+
         it("should throw an error when an id does not exist", async () => {
           let error
 

packages/modules/product/src/services/product-module-service.ts

@@ -1188,9 +1188,12 @@ export default class ProductModuleService
     )
 
     const collections: InferEntityType<typeof ProductCollection>[] = []
+    const toUpdate: {
+      selector: ProductTypes.FilterableProductProps
+      data: ProductTypes.UpdateProductDTO
+    }[] = []
 
-    const updateSelectorAndData = updatedCollections.flatMap(
+    updatedCollections.forEach((collectionData) => {
-      (collectionData) => {
       const input = normalizedInput.find((c) => c.id === collectionData.id)
       const productsToUpdate = (input as any)?.products
 
@@ -1199,26 +1202,24 @@ export default class ProductModuleService
       }
       const associateSelector = {}
 
-        if (!!productsToUpdate?.length) {
+      if (isDefined(productsToUpdate)) {
         const productIds = productsToUpdate.map((p) => p.id)
 
         dissociateSelector["id"] = { $nin: productIds }
         associateSelector["id"] = { $in: productIds }
-        } else if (!isDefined(productsToUpdate)) {
-          return []
       }
 
-        const result: Record<string, any>[] = [
+      if (isPresent(dissociateSelector["id"])) {
-          {
+        toUpdate.push({
           selector: dissociateSelector,
           data: {
             collection_id: null,
           },
-          },
+        })
-        ]
+      }
 
-        if (isPresent(associateSelector)) {
+      if (isPresent(associateSelector["id"])) {
-          result.push({
+        toUpdate.push({
           selector: associateSelector,
           data: {
             collection_id: collectionData.id,
@@ -1230,13 +1231,10 @@ export default class ProductModuleService
         ...collectionData,
         products: productsToUpdate ?? [],
       } as InferEntityType<typeof ProductCollection>)
+    })
 
-        return result
+    if (toUpdate.length) {
-      }
+      await this.productService_.update(toUpdate, sharedContext)
-    )
-
-    if (updateSelectorAndData.length) {
-      await this.productService_.update(updateSelectorAndData, sharedContext)
     }
 
     return collections