From 0c8ebe986a56097a8ea3a8c2c9c61228f4bfcd38 Mon Sep 17 00:00:00 2001 From: Metodi Yanev Date: Mon, 16 Jun 2025 18:09:57 +0300 Subject: [PATCH 1/2] fix: pass pagination_token from entriesResponse to the recursive call in bulk unpublish getSyncEntries --- .../contentstack-bulk-publish/src/producer/unpublish.js | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/packages/contentstack-bulk-publish/src/producer/unpublish.js b/packages/contentstack-bulk-publish/src/producer/unpublish.js index 7ef259f09c..9ac1e94895 100644 --- a/packages/contentstack-bulk-publish/src/producer/unpublish.js +++ b/packages/contentstack-bulk-publish/src/producer/unpublish.js @@ -228,10 +228,11 @@ async function getSyncEntries( await bulkAction(stack, entriesResponse.items, bulkUnpublish, environment, locale, apiVersion, bulkPublishLimit, false); } - if (entriesResponse.items.length === 0) { + if (!entriesResponse.pagination_token) { if (!changedFlag) console.log('No Entries/Assets Found published on specified environment'); return resolve(); } + setTimeout(async () => { await getSyncEntries( stack, @@ -244,9 +245,11 @@ async function getSyncEntries( apiVersion, bulkPublishLimit, variantsFlag, - null, + entriesResponse.pagination_token, ); }, 3000); + + return resolve(); } catch (error) { reject(error); } From d4fd07eca68d857ff3931c7daa69455e6f5db24a Mon Sep 17 00:00:00 2001 From: Metodi Yanev Date: Fri, 4 Jul 2025 18:39:17 +0300 Subject: [PATCH 2/2] update sync final exit condition --- packages/contentstack-bulk-publish/src/producer/unpublish.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/contentstack-bulk-publish/src/producer/unpublish.js b/packages/contentstack-bulk-publish/src/producer/unpublish.js index 9ac1e94895..a28e46349f 100644 --- a/packages/contentstack-bulk-publish/src/producer/unpublish.js +++ b/packages/contentstack-bulk-publish/src/producer/unpublish.js @@ -228,7 +228,7 @@ async function getSyncEntries( await bulkAction(stack, entriesResponse.items, bulkUnpublish, environment, locale, apiVersion, bulkPublishLimit, false); } - if (!entriesResponse.pagination_token) { + if (entriesResponse.items.length === 0 && !entriesResponse.pagination_token) { if (!changedFlag) console.log('No Entries/Assets Found published on specified environment'); return resolve(); }