aknuth/email-amazon
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

no markAsBlocked,

Browse Source
This commit is contained in:
Andreas Knuth
2026-04-12 20:43:37 -05:00
parent bed6c2a398
commit 9862689c0c
1 changed files with 32 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

58
email-worker-nodejs/src/worker/message-processor.ts
View File

@@ -26,7 +26,7 @@ import { BlocklistChecker } from '../email/blocklist.js';
import { BounceHandler } from '../email/bounce-handler.js'; import { BounceHandler } from '../email/bounce-handler.js';
import { parseEmail, isProcessedByWorker } from '../email/parser.js'; import { parseEmail, isProcessedByWorker } from '../email/parser.js';
import { RulesProcessor } from '../email/rules-processor.js'; import { RulesProcessor } from '../email/rules-processor.js';
import { config } from '../config.js';
// --------------------------------------------------------------------------- // ---------------------------------------------------------------------------
// Processor // Processor
// --------------------------------------------------------------------------- // ---------------------------------------------------------------------------
@@ -258,34 +258,40 @@ export class MessageProcessor {
if (totalHandled === recipients.length) { if (totalHandled === recipients.length) {
if (blockedRecipients.length === recipients.length) { if (blockedRecipients.length === recipients.length) {
// All blocked // All blocked — im Standby kein S3 anfassen
try { if (!config.standbyMode) {
await this.s3.markAsBlocked( try {
domain, await this.s3.markAsBlocked(
messageId, domain,
blockedRecipients, messageId,
fromAddrFinal, blockedRecipients,
workerName, fromAddrFinal,
); workerName,
await this.s3.deleteBlockedEmail(domain, messageId, workerName); );
} catch (err: any) { await this.s3.deleteBlockedEmail(domain, messageId, workerName);
log(`⚠ Failed to handle blocked email: ${err.message ?? err}`, 'ERROR', workerName); } catch (err: any) {
return false; log(`⚠ Failed to handle blocked email: ${err.message ?? err}`, 'ERROR', workerName);
return false;
}
} }
} else if (successful.length > 0) { } else if (successful.length > 0) {
await this.s3.markAsProcessed( if (!config.standbyMode) {
domain, await this.s3.markAsProcessed(
messageId, domain,
workerName, messageId,
failedPermanent.length > 0 ? failedPermanent : undefined, workerName,
); failedPermanent.length > 0 ? failedPermanent : undefined,
);
}
} else if (failedPermanent.length > 0) { } else if (failedPermanent.length > 0) {
await this.s3.markAsAllInvalid( if (!config.standbyMode) {
domain, await this.s3.markAsAllInvalid(
messageId, domain,
failedPermanent, messageId,
workerName, failedPermanent,
); workerName,
);
}
} }
// Summary // Summary