feat: add global forward address list (#288)

worker/src/email/index.ts

@@ -1,5 +1,6 @@
 import { Context } from "hono";
 
+import { getEnvStringList } from "../utils";
 import { sendMailToTelegram } from "../telegram_api";
 import { Bindings, HonoCustomType } from "../types";
 import { auto_reply } from "./auto_reply";
@@ -25,6 +26,16 @@ async function email(message: ForwardableEmailMessage, env: Bindings, ctx: Execu
         console.log(`Failed save message from ${message.from} to ${message.to}`);
     }
 
+    // forward email
+    try {
+        const forwardAddressList = getEnvStringList(env.FORWARD_ADDRESS_LIST)
+        for (const forwardAddress of forwardAddressList) {
+            await message.forward(forwardAddress);
+        }
+    } catch (error) {
+        console.log("forward email error", error);
+    }
+
     // send email to telegram
     try {
         await sendMailToTelegram(

worker/src/types.d.ts

@@ -21,6 +21,7 @@ export type Bindings = {
     DEFAULT_SEND_BALANCE: number | string | undefined
     ADMIN_CONTACT: string | undefined
     COPYRIGHT: string | undefined
+    FORWARD_ADDRESS_LIST: string | string[] | undefined
 
     // dkim
     DKIM_SELECTOR: string | undefined

worker/src/utils.ts

@@ -129,6 +129,23 @@ export const getAdminPasswords = (c: Context<HonoCustomType>): string[] => {
     return c.env.ADMIN_PASSWORDS.filter((item) => item.length > 0);
 }
 
+export const getEnvStringList = (value: string | string[] | undefined): string[] => {
+    if (!value) {
+        return [];
+    }
+    // check if is an array, if not use json.parse
+    if (!Array.isArray(value)) {
+        try {
+            const res = JSON.parse(value) as string[];
+            return res.filter((item) => item.length > 0);
+        } catch (e) {
+            console.error("Failed to parse ADMIN_PASSWORDS", e);
+            return [];
+        }
+    }
+    return value.filter((item) => item.length > 0);
+}
+
 export const sendAdminInternalMail = async (
     c: Context<HonoCustomType>, toMail: string, subject: string, text: string
 ): Promise<boolean> => {

worker/wrangler.toml.template

@@ -47,6 +47,8 @@ ENABLE_AUTO_REPLY = false
 # DKIM_PRIVATE_KEY = ""
 # telegram bot
 # TG_MAX_ACCOUNTS = 5
+# global forward address list, if set, all emails will be forwarded to these addresses
+# FORWARD_ADDRESS_LIST = ["xxx@xxx.com"]
 
 [[d1_databases]]
 binding = "DB"