fix: Update bulk action handlers to use correct payload structure with versioned links

Author: ivo-toby

src/handlers/bulk-action-handlers.ts

@@ -26,6 +26,16 @@ interface BulkActionResponse {
   error?: any
 }
 
+// Define the correct types for bulk action payloads
+interface VersionedLink {
+  sys: {
+    type: "Link"
+    linkType: "Entry" | "Asset"
+    id: string
+    version?: number
+  }
+}
+
 type BulkUnpublishParams = BulkPublishParams
 
 type BulkValidateParams = {
@@ -41,6 +51,45 @@ export const bulkActionHandlers = {
 
     const contentfulClient = await getContentfulClient()
 
+    // Get the current version of each entity
+    const entityVersions: VersionedLink[] = await Promise.all(
+      args.entities.map(async (entity) => {
+        try {
+          // Get the current version of the entity
+          const currentEntity = entity.sys.type === "Entry" 
+            ? await contentfulClient.entry.get({
+                spaceId,
+                environmentId,
+                entryId: entity.sys.id
+              })
+            : await contentfulClient.asset.get({
+                spaceId,
+                environmentId,
+                assetId: entity.sys.id
+              });
+          
+          return {
+            sys: {
+              type: "Link",
+              linkType: entity.sys.type,
+              id: entity.sys.id,
+              version: currentEntity.sys.version
+            }
+          };
+        } catch (error) {
+          console.error(`Error fetching entity ${entity.sys.id}: ${error}`);
+          // Return without version if we can't get it
+          return {
+            sys: {
+              type: "Link",
+              linkType: entity.sys.type,
+              id: entity.sys.id
+            }
+          };
+        }
+      })
+    );
+
     // Create the bulk action
     const bulkAction = await contentfulClient.bulkAction.publish(
       {
@@ -52,13 +101,7 @@ export const bulkActionHandlers = {
           sys: {
             type: "Array",
           },
-          items: args.entities.map((entity) => ({
-            sys: {
-              type: "Link",
-              linkType: entity.sys.type,
-              id: entity.sys.id,
-            },
-          })),
+          items: entityVersions,
         },
       },
     )
@@ -99,6 +142,45 @@ export const bulkActionHandlers = {
 
     const contentfulClient = await getContentfulClient()
 
+    // Get the current version of each entity
+    const entityVersions: VersionedLink[] = await Promise.all(
+      args.entities.map(async (entity) => {
+        try {
+          // Get the current version of the entity
+          const currentEntity = entity.sys.type === "Entry" 
+            ? await contentfulClient.entry.get({
+                spaceId,
+                environmentId,
+                entryId: entity.sys.id
+              })
+            : await contentfulClient.asset.get({
+                spaceId,
+                environmentId,
+                assetId: entity.sys.id
+              });
+          
+          return {
+            sys: {
+              type: "Link",
+              linkType: entity.sys.type,
+              id: entity.sys.id,
+              version: currentEntity.sys.version
+            }
+          };
+        } catch (error) {
+          console.error(`Error fetching entity ${entity.sys.id}: ${error}`);
+          // Return without version if we can't get it
+          return {
+            sys: {
+              type: "Link",
+              linkType: entity.sys.type,
+              id: entity.sys.id
+            }
+          };
+        }
+      })
+    );
+
     // Create the bulk action
     const bulkAction = await contentfulClient.bulkAction.unpublish(
       {
@@ -110,13 +192,7 @@ export const bulkActionHandlers = {
           sys: {
             type: "Array",
           },
-          items: args.entities.map((entity) => ({
-            sys: {
-              type: "Link",
-              linkType: entity.sys.type,
-              id: entity.sys.id,
-            },
-          })),
+          items: entityVersions,
         },
       },
     )
@@ -157,6 +233,39 @@ export const bulkActionHandlers = {
 
     const contentfulClient = await getContentfulClient()
 
+    // Get the current version of each entry
+    const entityVersions: VersionedLink[] = await Promise.all(
+      args.entryIds.map(async (id) => {
+        try {
+          // Get the current version of the entry
+          const currentEntry = await contentfulClient.entry.get({
+            spaceId,
+            environmentId,
+            entryId: id
+          });
+          
+          return {
+            sys: {
+              type: "Link",
+              linkType: "Entry",
+              id,
+              version: currentEntry.sys.version
+            }
+          };
+        } catch (error) {
+          console.error(`Error fetching entry ${id}: ${error}`);
+          // Return without version if we can't get it
+          return {
+            sys: {
+              type: "Link",
+              linkType: "Entry",
+              id
+            }
+          };
+        }
+      })
+    );
+
     // Create the bulk action
     const bulkAction = await contentfulClient.bulkAction.validate(
       {
@@ -168,13 +277,7 @@ export const bulkActionHandlers = {
           sys: {
             type: "Array",
           },
-          items: args.entryIds.map((id) => ({
-            sys: {
-              type: "Link",
-              linkType: "Entry",
-              id,
-            },
-          })),
+          items: entityVersions,
         },
       },
     )