diff --git a/apps/web/src/server/api/routers/campaign.ts b/apps/web/src/server/api/routers/campaign.ts index 7a1c22f..0e81719 100644 --- a/apps/web/src/server/api/routers/campaign.ts +++ b/apps/web/src/server/api/routers/campaign.ts @@ -17,7 +17,7 @@ import { import { validateDomainFromEmail } from "~/server/service/domain-service"; import { getDocumentUploadUrl, - isStorageConfigured + isStorageConfigured, } from "~/server/service/storage-service"; const statuses = Object.values(CampaignStatus) as [CampaignStatus]; @@ -63,8 +63,18 @@ export const campaignRouter = createTRPCRouter({ skip: offset, take: limit, }); + let time = performance.now(); + + campaignsP.then((campaigns) => { + console.log( + `Time taken to get campaigns: ${performance.now() - time} milliseconds` + ); + }); const [campaigns, count] = await Promise.all([campaignsP, countP]); + console.log( + `Time taken to get campaigns and count: ${performance.now() - time} milliseconds` + ); return { campaigns, totalPage: Math.ceil(count / limit) }; }), diff --git a/apps/web/src/server/service/campaign-service.ts b/apps/web/src/server/service/campaign-service.ts index ef2cdb6..dbfb783 100644 --- a/apps/web/src/server/service/campaign-service.ts +++ b/apps/web/src/server/service/campaign-service.ts @@ -379,7 +379,7 @@ export async function updateCampaignAnalytics( }); } -const CAMPAIGN_EMAIL_CONCURRENCY = 200; +const CAMPAIGN_EMAIL_CONCURRENCY = 50; class CampaignEmailService { private static campaignQueue = new Queue(CAMPAIGN_MAIL_PROCESSING_QUEUE, { diff --git a/apps/web/src/server/service/ses-hook-parser.ts b/apps/web/src/server/service/ses-hook-parser.ts index 39acf18..2b226e4 100644 --- a/apps/web/src/server/service/ses-hook-parser.ts +++ b/apps/web/src/server/service/ses-hook-parser.ts @@ -290,7 +290,7 @@ export class SesHookParser { }, { connection: getRedis(), - concurrency: 200, + concurrency: 50, } );