// ReportHub — Cloudflare Worker v2 // CORS enabled · Date range filtering · Firebase Storage // ── CORS Headers ───────────────────────────────────── const CORS_HEADERS = { "Access-Control-Allow-Origin": "*", "Access-Control-Allow-Methods": "GET, POST, OPTIONS", "Access-Control-Allow-Headers": "Content-Type", }; export default { async fetch(req, env) { // Handle CORS preflight if (req.method === "OPTIONS") return new Response(null, { status: 204, headers: CORS_HEADERS }); const url = new URL(req.url); // POST /sync — manual trigger with optional date range if (req.method==="POST" && url.pathname==="/sync") { const { subject, after, before, types } = await req.json().catch(()=>({})); const result = await pullAll(env, subject, after, before, types); return corsJson({ ok:true, ...result }); } // GET /sync — sync all schedules if (url.pathname==="/sync") { const result = await pullAll(env); return corsJson({ ok:true, ...result }); } return new Response("ReportHub Worker v2 ✅", { headers: CORS_HEADERS }); } }; async function pull(sched, tok, env, after, before) { // Build Gmail query with optional date range let q = `subject:"${sched.q}" has:attachment is:unread`; if (after) q += ` after:${after.replace(/-/g,"/")}`; if (before) q += ` before:${before.replace(/-/g,"/")}`; const { messages=[] } = await fetch( `https://gmail.googleapis.com/...?q=${encodeURIComponent(q)}`, { headers:{ Authorization:`Bearer ${tok}` } } ).then(r=>r.json()); let files = []; for (const { id } of messages) files = files.concat(await processMsg(id, sched, tok, env)); return { found: messages.length, files }; } // ... processMsg → Firebase Storage + Firestore // ... getToken → OAuth refresh // ... getFirebaseToken → Service Account JWT // // See full worker.js for complete source