Barnabas Dispatcher Pro

BARNABAS_MONOLITH_v32

\n \n

Credentials (YAML)

Sender Email

Sender Name

Subject

\n HTML Content\n \n

Preview...

Recipients (Up to 200k)

\n\n

\n AUTO-RESUME (CRON)\n

Runtime (m)

Batch

Interval (s)

Fail Pause

\n\n

\n \n \n

0 / 0

\n\n

\n\n \n\n`,\n { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } },\n );\n}\n\n// --- ENGINE ---\nasync function runEngine(data: any, selfUrl: string) {\n if (data.action === \"PAUSE\") return;\n const start = Date.now();\n let fails = 0;\n\n while (true) {\n // 45s Burst Limit\n if (Date.now() - start > 45000) {\n if (data.cronOn && data.runTime > 0.8) {\n fetch(selfUrl, {\n method: \"POST\",\n body: JSON.stringify({\n ...data,\n emails: \"\",\n runTime: data.runTime - 0.8,\n }),\n }).catch(() => {});\n }\n break;\n }\n\n const batch = await sqlite.execute(\n \"SELECT id, email FROM vt_q WHERE status = 'pending' LIMIT ?\",\n [data.batchSize],\n );\n if (batch.rows.length === 0) break;\n\n const emails = batch.rows.map((r) => r[1]);\n const success = await callScaleway(data.config, emails);\n\n if (!success) {\n fails++;\n if (fails >= data.failLimit) {\n await sqlite.execute(\"INSERT INTO vt_l (log_text) VALUES (?)\", [\n \"SYSTEM - PAUSED DUE TO FAIL LIMIT\",\n ]);\n break;\n }\n } else fails = 0;\n\n for (const row of batch.rows) {\n const [id, email] = row;\n const log = `${email} - ${success ? \"SUCCESS\" : \"FAIL\"}`;\n await sqlite.execute(\"UPDATE vt_q SET status = ? WHERE id = ?\", [\n success ? \"sent\" : \"failed\",\n id,\n ]);\n await sqlite.execute(\"INSERT INTO vt_l (log_text) VALUES (?)\", [log]);\n }\n await new Promise((r) => setTimeout(r, data.interval * 1000));\n }\n}\n\nasync function callScaleway(c: any, emails: string[]) {\n try {\n const res = await fetch(\n \"https://api.scaleway.com/transactional-email/v1alpha1/regions/fr-par/emails\",\n {\n method: \"POST\",\n headers: {\n \"X-Auth-Token\": c.secret_key.trim(),\n \"X-Auth-Access-Key\": c.access_key.trim(),\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n project_id: c.default_project_id.trim(),\n from: { email: c.senderEmail.trim(), name: c.senderName.trim() },\n to: emails.map((e) => ({ email: e.trim() })),\n subject: c.subject.trim(),\n html: c.htmlContent.trim(),\n }),\n },\n );\n return res.status < 300;\n } catch (e) {\n return false;\n }\n}","deleted","label",[102],"permalink","https://www.val.town/x/bus/sendermail/code/main.ts","extension","actionData","errors"]