parcelvoy/platform
1
0
Fork 0
mirror of https://fast.feibisi.com/https://github.com/parcelvoy/platform.git synced 2025-09-01 12:26:08 +08:00
Code Issues Projects Packages Wiki Activity Actions

chore: record invalid user ids

Browse source
This commit is contained in:
Chris Anderson 2025-08-11 16:44:22 -05:00
parent e98231e449
commit b5036b7313
1 changed files with 19 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

27
apps/platform/src/campaigns/CampaignService.ts
View file

@ -362,7 +362,7 @@ export const populateSendList = async (campaign: SentCampaign) => {
const progressCacheKey = CacheKeys.populationProgress(campaign)
const totalCacheKey = CacheKeys.populationTotal(campaign)
const insertRows = async (rows: CampaignSendParams[]) => {
const insertRows = async (rows: CampaignSendParams[]): Promise<number[]> => {
try {
await App.main.db.transaction(async (trx) => {
await CampaignSend.query(trx)
@ -372,18 +372,29 @@ export const populateSendList = async (campaign: SentCampaign) => {
})
} catch (error: any) {
const invalidUserIds: number[] = []
// If foreign key error, retry in smaller chunks
if (error.errno === 1452 && rows.length > 1) {
const size = Math.max(1, Math.floor(rows.length / 2))
const batches = batch(rows, size)
for (const items of batches) {
await insertRows(items)
if (error.errno === 1452) {
if (rows.length > 1) {
const size = Math.max(1, Math.floor(rows.length / 2))
const batches = batch(rows, size)
for (const items of batches) {
const userIds = await insertRows(items)
invalidUserIds.push(...userIds)
}
return invalidUserIds
}
// Is related to the user_id foreign key
if (error.sqlMessage.includes('campaign_sends_user_id_foreign')) {
return rows.map(r => r.user_id)
}
return
}
logger.error({ error, campaignId: campaign.id }, 'campaign:generate:progress:error')
logger.error({ error, invalidUserIds, campaignId: campaign.id }, 'campaign:generate:progress:error')
}
return []
}
await processUsers({