fix: mark prev published revision as unpublished (createFrom mutati…

…on) (#4258)
webiny · Sep 10, 2024 · b1856b1 · b1856b1
1 parent 420cc08
commit b1856b1
Show file tree

Hide file tree

Showing 3 changed files with 56 additions and 2 deletions.
diff --git a/packages/api-headless-cms-ddb-es/src/operations/entry/index.ts b/packages/api-headless-cms-ddb-es/src/operations/entry/index.ts
@@ -314,6 +314,30 @@ export const createEntriesStorageOperations = (
                     ...publishedKeys
                 })
             );
+
+            // Unpublish previously published revision (if any).
+            const [publishedRevisionStorageEntry] = await dataLoaders.getPublishedRevisionByEntryId(
+                {
+                    model,
+                    ids: [entry.id]
+                }
+            );
+
+            if (publishedRevisionStorageEntry) {
+                items.push(
+                    entity.putBatch({
+                        ...publishedRevisionStorageEntry,
+                        PK: createPartitionKey({
+                            id: publishedRevisionStorageEntry.id,
+                            locale: model.locale,
+                            tenant: model.tenant
+                        }),
+                        SK: createRevisionSortKey(publishedRevisionStorageEntry),
+                        TYPE: createRecordType(),
+                        status: CONTENT_ENTRY_STATUS.UNPUBLISHED
+                    })
+                );
+            }
         }
 
         try {

diff --git a/packages/api-headless-cms-ddb/src/operations/entry/index.ts b/packages/api-headless-cms-ddb/src/operations/entry/index.ts
@@ -245,8 +245,10 @@ export const createEntriesStorageOperations = (
         /**
          * We need to:
          *  - create the main entry item
-         *  - update the last entry item to a current one
-         *  - update the published entry item to a current one (if the entry is published)
+         *  - update the latest entry item to the current one
+         *  - if the entry's status was set to "published":
+         *      - update the published entry item to the current one
+         *      - unpublish previously published revision (if any)
          */
         const items = [
             entity.putBatch({
@@ -279,6 +281,22 @@ export const createEntriesStorageOperations = (
                     GSI1_SK: createGSISortKey(storageEntry)
                 })
             );
+
+            // Unpublish previously published revision (if any).
+            const publishedRevisionStorageEntry = await getPublishedRevisionByEntryId(model, entry);
+            if (publishedRevisionStorageEntry) {
+                items.push(
+                    entity.putBatch({
+                        ...publishedRevisionStorageEntry,
+                        PK: partitionKey,
+                        SK: createRevisionSortKey(publishedRevisionStorageEntry),
+                        TYPE: createType(),
+                        status: CONTENT_ENTRY_STATUS.UNPUBLISHED,
+                        GSI1_PK: createGSIPartitionKey(model, "A"),
+                        GSI1_SK: createGSISortKey(publishedRevisionStorageEntry)
+                    })
+                );
+            }
         }
 
         try {

diff --git a/packages/api-headless-cms/__tests__/contentAPI/contentEntriesOnByMetaFieldsOverrides.test.ts b/packages/api-headless-cms/__tests__/contentAPI/contentEntriesOnByMetaFieldsOverrides.test.ts
@@ -163,5 +163,17 @@ describe("Content entries - Entry Meta Fields Overrides", () => {
 
         const { data: listEntriesRead } = await readIdentityA.listTestEntries();
         expect(listEntriesRead[0].id).toEndWith("#0003");
+
+        // Extra check - ensure the previous revision is no longer published.
+        const { data: firstPublishedRevision } = await manageIdentityA.getTestEntry({
+            revision: `${rev.entryId}#0001`
+        });
+
+        const { data: secondPublishedRevision } = await manageIdentityA.getTestEntry({
+            revision: `${rev.entryId}#0001`
+        });
+
+        expect(firstPublishedRevision.meta.status).toBe("unpublished");
+        expect(secondPublishedRevision.meta.status).toBe("unpublished");
     });
 });