aboutsummaryrefslogtreecommitdiff
path: root/deno/mail-relay/aws/mail.ts
diff options
context:
space:
mode:
authorYuqian Yang <crupest@crupest.life>2025-06-17 19:04:16 +0800
committerYuqian Yang <crupest@crupest.life>2025-06-17 21:37:43 +0800
commit874c4a8babc5aac7214e71dfef7743bae23893a3 (patch)
treed7d39313a442bac49859669bb8d1919267575023 /deno/mail-relay/aws/mail.ts
parent0824de3bae3550674a9ea029b03c5cb8a35cd8e1 (diff)
downloadcrupest-874c4a8babc5aac7214e71dfef7743bae23893a3.tar.gz
crupest-874c4a8babc5aac7214e71dfef7743bae23893a3.tar.bz2
crupest-874c4a8babc5aac7214e71dfef7743bae23893a3.zip
HALF WORK!:mail
Diffstat (limited to 'deno/mail-relay/aws/mail.ts')
-rw-r--r--deno/mail-relay/aws/mail.ts17
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.");
}
}