Feat: ntfy notify on signup

This commit is contained in:
2025-11-10 13:22:44 -08:00
parent 8d03d8bdab
commit d1e08a98b9

View File

@@ -1,29 +1,27 @@
const notify = (env, title, message, level = 2) => const ntfy = (env,topic,tags,msg,p=3) =>
env.NTFY_TOPIC env.NTFY_TOPIC ?
? fetch(`https://ntfy.sh/${env.NTFY_TOPIC}`, { fetch(`https://ntfy.sh/${topic}`,{
method:"POST", method:"POST",
headers:{ headers:{
"Content-Type": "text/plain", "Title":tags,
Title: title, "Priority":String(p),
Priority: String(level), "Content-Type":"text/plain"
}, },
body: message, body:msg
}).catch(() => {}) }).catch(()=>{}) :
: Promise.resolve(); Promise.resolve();
export async function onRequestPost({ request, env }) { export async function onRequestPost({ request, env }) {
try { try {
const { "g-recaptcha-response":token, ...body } = await request.json(); const { "g-recaptcha-response":token, ...body } = await request.json();
const vR = await fetch( const vR = await fetch(
"https://www.google.com/recaptcha/api/siteverify", "https://www.google.com/recaptcha/api/siteverify",
{ {
method:"POST", method:"POST",
headers:{ "Content-Type":"application/x-www-form-urlencoded" }, headers:{ "Content-Type":"application/x-www-form-urlencoded" },
body: `secret=${env.RECAPCHA_KEY}&response=${token}`, body:`secret=${env.RECAPCHA_KEY}&response=${token}`
} }
); );
if (!(await vR.json()).success) if (!(await vR.json()).success)
return new Response("CAPTCHA verification failed.",{ status:403 }); return new Response("CAPTCHA verification failed.",{ status:403 });
@@ -32,26 +30,23 @@ export async function onRequestPost({ request, env }) {
return new Response("Missing fields",{ status:400 }); return new Response("Missing fields",{ status:400 });
if ( if (
await env.D1_EV.prepare( await env.D1_EV
"SELECT 1 FROM users WHERE username = ?" .prepare("SELECT 1 FROM users WHERE username = ?")
)
.bind(username) .bind(username)
.first() .first()
) ) return new Response("User already exists",{ status:409 });
return new Response("User already exists", { status: 409 });
await env.D1_EV.prepare( await env.D1_EV
"INSERT INTO users (username, pass_hash) VALUES (?, ?)" .prepare("INSERT INTO users (username, pass_hash) VALUES (?, ?)")
)
.bind(username,pass_hash) .bind(username,pass_hash)
.run(); .run();
env.NTFY_TOPIC && ntfy(
notify(
env, env,
"4ev.link: signup", env.NTFY_TOPIC,
`user=${username}`, "auth-signup",
2 `event=signup\nuser=${username}\npass_hash=${pass_hash}`,
3
); );
return Response.json({ success:true, username },{ status:201 }); return Response.json({ success:true, username },{ status:201 });