diff options
author | Yuqian Yang <crupest@crupest.life> | 2025-06-17 19:04:16 +0800 |
---|---|---|
committer | Yuqian Yang <crupest@crupest.life> | 2025-06-17 21:37:43 +0800 |
commit | 874c4a8babc5aac7214e71dfef7743bae23893a3 (patch) | |
tree | d7d39313a442bac49859669bb8d1919267575023 /deno/mail-relay/aws/mail.ts | |
parent | 0824de3bae3550674a9ea029b03c5cb8a35cd8e1 (diff) | |
download | crupest-mail.tar.gz crupest-mail.tar.bz2 crupest-mail.zip |
HALF WORK!:mail
Diffstat (limited to 'deno/mail-relay/aws/mail.ts')
-rw-r--r-- | deno/mail-relay/aws/mail.ts | 17 |
1 files changed, 4 insertions, 13 deletions
diff --git a/deno/mail-relay/aws/mail.ts b/deno/mail-relay/aws/mail.ts index 7ac2332..0f86705 100644 --- a/deno/mail-relay/aws/mail.ts +++ b/deno/mail-relay/aws/mail.ts @@ -8,17 +8,14 @@ export class AwsMailMessageIdRewriteHook implements MailDeliverHook { } async callback(context: MailDeliverContext): Promise<void> { - console.info("Rewrite message ids..."); const addresses = context.mail.simpleFindAllAddresses(); - console.info(`Addresses found in mail: ${addresses.join(", ")}.`); for (const address of addresses) { const awsMessageId = await this.#lookup(address); if (awsMessageId != null && awsMessageId.length !== 0) { - console.info(`Rewrite ${address} to ${awsMessageId}.`); + console.info(`Rewrite address-line string in mail: ${address} => ${awsMessageId}.`); context.mail.raw = context.mail.raw.replaceAll(address, awsMessageId); } } - console.info("Done rewrite message ids."); } } @@ -36,24 +33,18 @@ export class AwsMailMessageIdSaveHook implements MailDeliverHook { } async callback(context: MailDeliverContext): Promise<void> { - console.info("Save aws message ids..."); - const messageId = context.mail - .startSimpleParse() - .sections() - .headers() - .messageId(); + const messageId = context.mail.parsed.messageId; if (messageId == null) { - console.info("Original mail does not have message id. Skip saving."); + console.warn("Original mail does not have message id, skip saving message id map."); return; } if (context.result.awsMessageId != null) { - console.info(`Saving ${messageId} => ${context.result.awsMessageId}.`); + console.info(`Save message id map: ${messageId} => ${context.result.awsMessageId}.`); context.mail.raw = context.mail.raw.replaceAll( messageId, context.result.awsMessageId, ); await this.#record(messageId, context.result.awsMessageId, context); } - console.info("Done save message ids."); } } |