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 BLACK_LIST

Browse Source
This commit is contained in:
dreamhunter2333
2023-08-24 15:22:03 +08:00
parent 12a16e711a
commit 0487284245
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
worker/src/email.js
+7
View File
@@ -1,6 +1,11 @@
const PostalMime = require("postal-mime"); const PostalMime = require("postal-mime");
async function email(message, env, ctx) { async function email(message, env, ctx) {
if (env.BLACK_LIST && env.BLACK_LIST.split(",").some(word => message.from.includes(word))) {
message.setReject("Missing from address");
console.log(`Reject message from ${message.from} to ${message.to}`);
return;
}
if (!env.PREFIX || (message.to && message.to.startsWith(env.PREFIX))) { if (!env.PREFIX || (message.to && message.to.startsWith(env.PREFIX))) {
const reader = message.raw.getReader(); const reader = message.raw.getReader();
const decoder = new TextDecoder("utf-8"); const decoder = new TextDecoder("utf-8");
@@ -21,9 +26,11 @@ async function email(message, env, ctx) {
).bind(message.from, message.to, parsedEmail.subject || "", parsedEmail.html).run(); ).bind(message.from, message.to, parsedEmail.subject || "", parsedEmail.html).run();
if (!success) { if (!success) {
message.setReject(`Failed save message to ${message.to}`); message.setReject(`Failed save message to ${message.to}`);
console.log(`Failed save message from ${message.from} to ${message.to}`);
} }
} else { } else {
message.setReject(`Unknown address ${message.to}`); message.setReject(`Unknown address ${message.to}`);
console.log(`Unknown address ${message.to}`);
} }
} }