update after review

pagopa · Dec 20, 2024 · 2f1c8a5 · 2f1c8a5
1 parent f8b597f
commit 2f1c8a5
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 9 deletions.
diff --git a/.changeset/heavy-points-clean.md b/.changeset/heavy-points-clean.md
diff --git a/packages/active-campaign-client/.env.example b/packages/active-campaign-client/.env.example
@@ -9,6 +9,7 @@ AC_RESYNC_TIMEOUT_IN_MS=1000
 # Only needed run import script locally
 AWS_ACCESS_KEY_ID=AWS_ACCESS_KEY_ID
 AWS_SECRET_ACCESS_KEY=AWS_SECRET_ACCESS_KEY
+USERS_TO_IMPORT_LIMIT=5 #optional only for local testing
 
 TEST_AC_BASE_URL=your_account_url
 TEST_AC_API_KEY=your_api_key

diff --git a/packages/active-campaign-client/src/scripts/sync_all_users.ts b/packages/active-campaign-client/src/scripts/sync_all_users.ts
@@ -108,10 +108,11 @@ async function main() {
     return true;
   });
 
-  // limit uniqueUsersAndWebinars to 10
-  const limitedUniqueUsersAndWebinars = uniqueUsersAndWebinars
+  const usersToImportLimit = !!process.env.USERS_TO_IMPORT_LIMIT && parseInt(process.env.USERS_TO_IMPORT_LIMIT);
+  const limitedUniqueUsersAndWebinars = usersToImportLimit ? uniqueUsersAndWebinars
     .filter((userAndWebinars) => userAndWebinars.subscribedWebinars.length > 0)
-    .slice(0, 2);
+    .slice(0, usersToImportLimit)
+    : uniqueUsersAndWebinars;
 
   const acPayload = limitedUniqueUsersAndWebinars.map((userAndWebinars, index) => ({
     contact: {
@@ -146,4 +147,4 @@ async function main() {
 main().catch(error => {
   console.error('Error executing script:', error);
   process.exit(1);
-});
+});