From f4d60fb87f9c6d86a584eba11e6a3d17479af201 Mon Sep 17 00:00:00 2001 From: Yuqian Yang Date: Tue, 1 Jul 2025 17:29:07 +0800 Subject: mail: remove 'aws' of aws message id map. --- deno/mail/aws/mail.ts | 59 --------------------------------------------------- 1 file changed, 59 deletions(-) delete mode 100644 deno/mail/aws/mail.ts (limited to 'deno/mail/aws/mail.ts') diff --git a/deno/mail/aws/mail.ts b/deno/mail/aws/mail.ts deleted file mode 100644 index 26f3ea0..0000000 --- a/deno/mail/aws/mail.ts +++ /dev/null @@ -1,59 +0,0 @@ -import { MailDeliverContext, MailDeliverHook } from "../mail.ts"; - -export class AwsMailMessageIdRewriteHook implements MailDeliverHook { - readonly #lookup; - - constructor(lookup: (origin: string) => Promise) { - this.#lookup = lookup; - } - - async callback(context: MailDeliverContext): Promise { - const addresses = context.mail.simpleFindAllAddresses(); - for (const address of addresses) { - const awsMessageId = await this.#lookup(address); - if (awsMessageId != null && awsMessageId.length !== 0) { - console.info( - context.logTag, - `Rewrite address-line string in mail: ${address} => ${awsMessageId}.`, - ); - context.mail.raw = context.mail.raw.replaceAll(address, awsMessageId); - } - } - } -} - -export class AwsMailMessageIdSaveHook implements MailDeliverHook { - readonly #record; - - constructor( - record: ( - original: string, - aws: string, - context: MailDeliverContext, - ) => Promise, - ) { - this.#record = record; - } - - async callback(context: MailDeliverContext): Promise { - const { messageId } = context.mail.parsed; - if (messageId == null) { - console.warn( - context.logTag, - "Original mail doesn't have message id, skip saving message id map.", - ); - return; - } - if (context.result.awsMessageId != null) { - console.info( - context.logTag, - `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); - } - } -} -- cgit v1.2.3