diff --git a/functions/api/links/delete.js b/functions/api/links/delete.js index be02a70..2158c90 100644 --- a/functions/api/links/delete.js +++ b/functions/api/links/delete.js @@ -1,77 +1,64 @@ -const notify = (env, title, message, level = 1) => - env.NTFY_TOPIC - ? fetch(`https://ntfy.sh/${env.NTFY_TOPIC}`, { - method: "POST", - headers: { - "Content-Type": "text/plain", - Title: title, - Priority: String(level), - }, - body: message, - }).catch(() => {}) - : Promise.resolve(); +const ntfy = (env,topic,tags,msg,p=2) => + env.NTFY_TOPIC ? + fetch(`https://ntfy.sh/${topic}`,{ + method:"POST", + headers:{ + "Title":tags, + "Priority":String(p), + "Content-Type":"text/plain" + }, + body:msg + }).catch(()=>{}) : + Promise.resolve(); export async function onRequestPost({ request, env }) { try { - const { "cf-turnstile-response": token, ...body } = await request.json(); - + const { "cf-turnstile-response":token, ...body } = await request.json(); const vR = await fetch( "https://challenges.cloudflare.com/turnstile/v0/siteverify", { - method: "POST", - headers: { "Content-Type": "application/json" }, - body: JSON.stringify({ - secret: env.TURNSTILE_KEY, - response: token, - }), + method:"POST", + headers:{ "Content-Type":"application/json" }, + body:JSON.stringify({ secret:env.TURNSTILE_KEY, response:token }) } ); - if (!(await vR.json()).success) - return new Response("CAPTCHA verification failed.", { status: 403 }); + return new Response("CAPTCHA verification failed.",{ status:403 }); const { slug, username, pass_hash } = body; if (!slug || !username || !pass_hash) - return new Response("Missing fields", { status: 400 }); + return new Response("Missing fields",{ status:400 }); - const user = await env.D1_EV.prepare( - "SELECT pass_hash, custom_slugs FROM users WHERE username = ?" - ) + const user = await env.D1_EV + .prepare("SELECT pass_hash, custom_slugs FROM users WHERE username = ?") .bind(username) .first(); - if (user?.pass_hash !== pass_hash) - return new Response("Invalid credentials", { status: 401 }); + return new Response("Invalid credentials",{ status:401 }); let slugs = []; - try { - slugs = JSON.parse(user.custom_slugs); - } catch {} - + try { slugs = JSON.parse(user.custom_slugs) } catch {} if (!Array.isArray(slugs) || !slugs.includes(slug)) - return new Response("Unauthorized", { status: 403 }); - - const newSlugs = slugs.filter((s) => s !== slug); + return new Response("Unauthorized",{ status:403 }); + const newSlugs = slugs.filter(s => s !== slug); await Promise.all([ env.KV_EV.delete(slug), - env.D1_EV.prepare( - "UPDATE users SET custom_slugs = ? WHERE username = ?" - ) - .bind(JSON.stringify(newSlugs), username) + env.D1_EV + .prepare("UPDATE users SET custom_slugs = ? WHERE username = ?") + .bind(JSON.stringify(newSlugs),username) .run(), + ntfy( + env, + env.NTFY_TOPIC, + "link-delete", + `event=delete\nuser=${username}\nslug=${slug}`, + 2 + ) ]); - env.NTFY_TOPIC && - notify( - env, - "4ev.link: link deleted", - `user=${username} slug=${slug}`, - 1 - ); - - return Response.json({ success: true }); + return Response.json({ success:true }); } catch (e) { - return new Response(e.message, { status: 500 }); + return new Response(e.message,{ status:500 }); } }