diff options
author | Yuqian Yang <crupest@crupest.life> | 2025-07-01 17:29:07 +0800 |
---|---|---|
committer | Yuqian Yang <crupest@crupest.life> | 2025-07-01 17:29:07 +0800 |
commit | f4d60fb87f9c6d86a584eba11e6a3d17479af201 (patch) | |
tree | 37f1a7577e67acc06ddcfc918affb1ecd0df6038 /deno/mail/aws/app.ts | |
parent | 5e250ddcdbd6307989071e4ea794b1ad39e928e5 (diff) | |
download | crupest-f4d60fb87f9c6d86a584eba11e6a3d17479af201.tar.gz crupest-f4d60fb87f9c6d86a584eba11e6a3d17479af201.tar.bz2 crupest-f4d60fb87f9c6d86a584eba11e6a3d17479af201.zip |
mail: remove 'aws' of aws message id map.
Diffstat (limited to 'deno/mail/aws/app.ts')
-rw-r--r-- | deno/mail/aws/app.ts | 17 |
1 files changed, 7 insertions, 10 deletions
diff --git a/deno/mail/aws/app.ts b/deno/mail/aws/app.ts index 6c7ede7..7e16488 100644 --- a/deno/mail/aws/app.ts +++ b/deno/mail/aws/app.ts @@ -13,14 +13,10 @@ import { DbService } from "../db.ts"; import { createHono, createInbound, createSmtp, sendMail } from "../app.ts"; import { DovecotMailDeliverer } from "../dovecot.ts"; import { MailDeliverer } from "../mail.ts"; -import { - AwsMailMessageIdRewriteHook, - AwsMailMessageIdSaveHook, -} from "./mail.ts"; +import { MessageIdRewriteHook, MessageIdSaveHook } from "../mail.ts"; import { AwsMailDeliverer } from "./deliver.ts"; import { AwsMailFetcher, LiveMailNotFoundError } from "./fetch.ts"; - const PREFIX = "crupest-mail-server"; const CONFIG_DEFINITIONS = { dataPath: { @@ -105,12 +101,12 @@ function createOutbound( ) { const deliverer = new AwsMailDeliverer(awsOptions); deliverer.preHooks.push( - new AwsMailMessageIdRewriteHook(db.messageIdToAws.bind(db)), + new MessageIdRewriteHook(db.messageIdToNew.bind(db)), ); deliverer.postHooks.push( - new AwsMailMessageIdSaveHook( - async (original, aws, context) => { - await db.addMessageIdMap({ message_id: original, aws_message_id: aws }); + new MessageIdSaveHook( + async (original, new_message_id, context) => { + await db.addMessageIdMap({ message_id: original, new_message_id }); void local?.saveNewSent(context.logTag, context.mail, original); }, ), @@ -240,7 +236,8 @@ function createServerServices() { } async function serve(cron: boolean = false) { - const { config, fetcher, inbound, smtp, dbService, hono } = createServerServices(); + const { config, fetcher, inbound, smtp, dbService, hono } = + createServerServices(); await dbService.migrate(); |