GithubBackup/cloudflare_temp_email
1
0
Fork 0
mirror of https://github.com/dreamhunter2333/cloudflare_temp_email.git synced 2026-09-05 23:47:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: add resend for send mail (#275)

Browse Source
This commit is contained in:
Dream Hunter
2024-05-26 15:30:18 +08:00
committed by GitHub
parent 3b6736924b
commit 8dc9d32a7e
1 changed files with 15 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
worker/src/mails_api/send_mail_api.ts
+15 -9
View File
@@ -86,7 +86,7 @@ const sendMailByResend = async (
if (error) { if (error) {
throw new Error(`Resend error: ${error.name} ${error.message}`); throw new Error(`Resend error: ${error.name} ${error.message}`);
} }
console.log(`Resend success: ${data}`); console.log(`Resend success: ${JSON.stringify(data)}`);
} }
const sendMailByMailChannels = async ( const sendMailByMailChannels = async (
@@ -193,13 +193,17 @@ export const sendMail = async (
const resendEnabled = c.env.RESEND_TOKEN || c.env[ const resendEnabled = c.env.RESEND_TOKEN || c.env[
`RESEND_TOKEN_${mailDomain.replace(/\./g, "_").toUpperCase()}` `RESEND_TOKEN_${mailDomain.replace(/\./g, "_").toUpperCase()}`
]; ];
let sendByVerifiedAddressList = false;
if (c.env.SEND_MAIL) { if (c.env.SEND_MAIL) {
const verifiedAddressList = await getJsonSetting(c, CONSTANTS.VERIFIED_ADDRESS_LIST_KEY) || []; const verifiedAddressList = await getJsonSetting(c, CONSTANTS.VERIFIED_ADDRESS_LIST_KEY) || [];
if (verifiedAddressList.includes(to_mail)) { if (verifiedAddressList.includes(to_mail)) {
await sendMailToVerifyAddress(c, address, reqJson); await sendMailToVerifyAddress(c, address, reqJson);
return; sendByVerifiedAddressList = true;
} }
} }
if (sendByVerifiedAddressList) {
// do not update balance
}
// send by resend // send by resend
else if (resendEnabled) { else if (resendEnabled) {
await sendMailByResend(c, address, reqJson); await sendMailByResend(c, address, reqJson);
@@ -209,15 +213,17 @@ export const sendMail = async (
await sendMailByMailChannels(c, address, reqJson); await sendMailByMailChannels(c, address, reqJson);
} }
// update balance // update balance
try { if (!sendByVerifiedAddressList) {
const { success } = await c.env.DB.prepare( try {
`UPDATE address_sender SET balance = balance - 1 where address = ?` const { success } = await c.env.DB.prepare(
).bind(address).run(); `UPDATE address_sender SET balance = balance - 1 where address = ?`
if (!success) { ).bind(address).run();
if (!success) {
console.warn(`Failed to update balance for ${address}`);
}
} catch (e) {
console.warn(`Failed to update balance for ${address}`); console.warn(`Failed to update balance for ${address}`);
} }
} catch (e) {
console.warn(`Failed to update balance for ${address}`);
} }
// save to sendbox // save to sendbox
try { try {