aboutsummaryrefslogtreecommitdiff
path: root/deno/mail/aws/app.ts
diff options
context:
space:
mode:
authorYuqian Yang <crupest@crupest.life>2025-07-01 17:29:07 +0800
committerYuqian Yang <crupest@crupest.life>2025-07-01 17:29:07 +0800
commitf4d60fb87f9c6d86a584eba11e6a3d17479af201 (patch)
tree37f1a7577e67acc06ddcfc918affb1ecd0df6038 /deno/mail/aws/app.ts
parent5e250ddcdbd6307989071e4ea794b1ad39e928e5 (diff)
downloadcrupest-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.ts17
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();