aboutsummaryrefslogtreecommitdiff
path: root/deno/mail-relay/aws/mail.ts
diff options
context:
space:
mode:
authorYuqian Yang <crupest@crupest.life>2025-06-16 01:53:32 +0800
committerYuqian Yang <crupest@crupest.life>2025-06-16 01:53:32 +0800
commite5509b819a2798077232fb014926e7abc7bf9edc (patch)
tree38f89f2a9fcb13b003328c6667bc32aa66e9fae1 /deno/mail-relay/aws/mail.ts
parentb4a5820f57a6b5aa72e068e318705fcbeb0c3302 (diff)
downloadcrupest-e5509b819a2798077232fb014926e7abc7bf9edc.tar.gz
crupest-e5509b819a2798077232fb014926e7abc7bf9edc.tar.bz2
crupest-e5509b819a2798077232fb014926e7abc7bf9edc.zip
mail: add save aws message id mail.
Diffstat (limited to 'deno/mail-relay/aws/mail.ts')
-rw-r--r--deno/mail-relay/aws/mail.ts14
1 files changed, 12 insertions, 2 deletions
diff --git a/deno/mail-relay/aws/mail.ts b/deno/mail-relay/aws/mail.ts
index cc05d23..7ac2332 100644
--- a/deno/mail-relay/aws/mail.ts
+++ b/deno/mail-relay/aws/mail.ts
@@ -25,7 +25,13 @@ export class AwsMailMessageIdRewriteHook implements MailDeliverHook {
export class AwsMailMessageIdSaveHook implements MailDeliverHook {
readonly #record;
- constructor(record: (original: string, aws: string) => Promise<void>) {
+ constructor(
+ record: (
+ original: string,
+ aws: string,
+ context: MailDeliverContext,
+ ) => Promise<void>,
+ ) {
this.#record = record;
}
@@ -42,7 +48,11 @@ export class AwsMailMessageIdSaveHook implements MailDeliverHook {
}
if (context.result.awsMessageId != null) {
console.info(`Saving ${messageId} => ${context.result.awsMessageId}.`);
- await this.#record(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.");
}