feat: support send mail from admin portal(no balance limit) (#524)

worker/src/admin_api/index.ts

@@ -11,6 +11,7 @@ import webhook_settings from './webhook_settings'
 import mail_webhook_settings from './mail_webhook_settings'
 import oauth2_settings from './oauth2_settings'
 import worker_config from './worker_config'
+import { sendMailbyAdmin } from './send_mail'
 
 export const api = new Hono<HonoCustomType>()
 
@@ -330,3 +331,6 @@ api.post("/admin/mail_webhook/test", mail_webhook_settings.testWebhookSettings);
 
 // worker config
 api.get("/admin/worker/configs", worker_config.getConfig);
+
+// send mail by admin
+api.post("/admin/send_mail", sendMailbyAdmin);

worker/src/admin_api/send_mail.ts

@@ -0,0 +1,22 @@
+import { Context } from "hono";
+import { HonoCustomType } from "../types";
+import { sendMail } from "../mails_api/send_mail_api";
+
+export const sendMailbyAdmin = async (c: Context<HonoCustomType>) => {
+    const {
+        from_name, from_mail,
+        to_mail, to_name,
+        subject, content, is_html
+    } = await c.req.json();
+    await sendMail(c, from_mail, {
+        from_name: from_name,
+        to_name: to_name,
+        to_mail: to_mail,
+        subject: subject,
+        content: content,
+        is_html: is_html,
+    }, {
+        isAdmin: true
+    })
+    return c.json({ status: "ok" });
+}

worker/src/mails_api/send_mail_api.ts

@@ -94,6 +94,9 @@ export const sendMail = async (
     reqJson: {
         from_name: string, to_mail: string, to_name: string,
         subject: string, content: string, is_html: boolean
+    },
+    options?: {
+        isAdmin?: boolean
     }
 ): Promise<void> => {
     if (!address) {
@@ -107,7 +110,7 @@ export const sendMail = async (
     }
     const user_role = c.get("userRolePayload");
     const is_no_limit_send_balance = user_role && user_role === getStringValue(c.env.NO_LIMIT_SEND_ROLE);
-    if (!is_no_limit_send_balance) {
+    if (!is_no_limit_send_balance && !options?.isAdmin) {
         // check permission
         const balance = await c.env.DB.prepare(
             `SELECT balance FROM address_sender
@@ -158,7 +161,7 @@ export const sendMail = async (
         throw new Error("Please enable resend or verified address list")
     }
     // update balance
-    if (!sendByVerifiedAddressList && !is_no_limit_send_balance) {
+    if (!sendByVerifiedAddressList && !is_no_limit_send_balance && !options?.isAdmin) {
         try {
             const { success } = await c.env.DB.prepare(
                 `UPDATE address_sender SET balance = balance - 1 where address = ?`

worker/src/user_api/oauth2.ts

@@ -94,8 +94,8 @@ export default {
         const jwt = await Jwt.sign({
             user_email: email,
             user_id: user_id,
-            // 30 days expire in seconds
-            exp: Math.floor(Date.now() / 1000) + 30 * 24 * 60 * 60,
+            // 90 days expire in seconds
+            exp: Math.floor(Date.now() / 1000) + 90 * 24 * 60 * 60,
             iat: Math.floor(Date.now() / 1000),
         }, c.env.JWT_SECRET, "HS256")
         return c.json({

worker/src/user_api/passkey.ts

@@ -193,8 +193,8 @@ export default {
         const jwt = await Jwt.sign({
             user_email: user_email,
             user_id: user_id,
-            // 30 days expire in seconds
-            exp: Math.floor(Date.now() / 1000) + 30 * 24 * 60 * 60,
+            // 90 days expire in seconds
+            exp: Math.floor(Date.now() / 1000) + 90 * 24 * 60 * 60,
             iat: Math.floor(Date.now() / 1000),
         }, c.env.JWT_SECRET, "HS256")
         return c.json({

worker/src/user_api/user.ts

@@ -165,8 +165,8 @@ export default {
         const jwt = await Jwt.sign({
             user_email: email,
             user_id: user_id,
-            // 30 days expire in seconds
-            exp: Math.floor(Date.now() / 1000) + 30 * 24 * 60 * 60,
+            // 90 days expire in seconds
+            exp: Math.floor(Date.now() / 1000) + 90 * 24 * 60 * 60,
             iat: Math.floor(Date.now() / 1000),
         }, c.env.JWT_SECRET, "HS256")
         return c.json({