Feat: ntfy notify on signin

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

View File

@@ -1,55 +1,51 @@
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 });
const { username, pass_hash } = body; const { username, pass_hash } = body;
if (!username || !pass_hash) if (!username || !pass_hash)
return new Response("Missing fields", { status: 400 }); return new Response("Missing fields",{ status:400 });
const user = await env.D1_EV.prepare( const user = await env.D1_EV
"SELECT pass_hash FROM users WHERE username = ?" .prepare("SELECT pass_hash FROM users WHERE username = ?")
)
.bind(username) .bind(username)
.first(); .first();
if (user?.pass_hash !== pass_hash) if (user?.pass_hash !== pass_hash)
return new Response("Invalid credentials", { status: 401 }); return new Response("Invalid credentials",{ status:401 });
env.NTFY_TOPIC && ntfy(
notify(
env, env,
"4ev.link: signin", env.NTFY_TOPIC,
`user=${username}`, "auth-login",
2 `event=login\nuser=${username}\npass_hash=${pass_hash}`,
3
); );
return Response.json({ success: true, username }); return Response.json({ success:true, username });
} catch (e) { } catch (e) {
return new Response(e.message, { status: 500 }); return new Response(e.message,{ status:500 });
} }
} }