Bug Fix

Author: dcodesdev

apps/backend/src/cron/processQueuedCampaigns.ts

@@ -229,11 +229,24 @@ export const processQueuedCampaigns = cronJob(
                 data: messagesToCreate,
               })
 
-              await tx.campaign.update({
-                where: { id: campaign.id },
-                data: { status: "SENDING" },
+              const subscribersLeft = await tx.subscriber.count({
+                where: {
+                  Messages: { none: { campaignId: campaign.id } },
+                  ListSubscribers: {
+                    some: {
+                      unsubscribedAt: null,
+                    },
+                  },
+                },
               })
 
+              if (subscribersLeft === 0) {
+                await tx.campaign.update({
+                  where: { id: campaign.id },
+                  data: { status: "SENDING" },
+                })
+              }
+
               console.log(
                 `Cron job: Created ${messagesToCreate.length} messages for campaign ${campaign.id}.`
               )

package.json

@@ -1,5 +1,5 @@
 {
-  "version": "0.5.7",
+  "version": "0.5.8",
   "name": "letterspace",
   "private": true,
   "scripts": {