{apiKey}:

{secretKey}`,\n );\n\n try {\n const response = await fetch(\"https://api.mailjet.com/v3.1/send\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Basic ${authHeader}`,\n },\n body: JSON.stringify({ Messages: [message] }),\n });\n\n if (response.ok) {\n return { success: true };\n }\n\n const data = await response.json();\n return {\n success: false,\n error: data.ErrorMessage || `Mailjet HTTP ${response.status}`,\n };\n } catch (err: any) {\n return { success: false, error: err.message };\n }\n}\n\nfunction buildBatchEmailHtml(\n waypointName: string,\n pings: WaypointPing[],\n batchStart: string,\n batchEnd: string,\n): string {\n const sorted = [...pings].sort(\n (a, b) =>\n new Date(a.correctedTime).getTime() - new Date(b.correctedTime).getTime(),\n );\n\n const rows = sorted\n .map((ping, index) => {\n const corrTime = new Date(ping.correctedTime).toLocaleTimeString(\n \"en-AU\",\n {\n hour: \"2-digit\",\n minute: \"2-digit\",\n second: \"2-digit\",\n hour12: true,\n },\n );\n const speedStr = ping.speed != null\n ? `${ping.speed.toFixed(1)} km/h`\n : \"N/A\";\n const mapsLink =\n `https://maps.google.com/?q=

{ping.latitude},

{ping.longitude}`;\n const bgColor = index % 2 === 0 ? \"#f9fafb\" : \"#ffffff\";\n\n return `\n \n ${\n stripNonLatin1(ping.teamName)\n }\n #${\n stripNonLatin1(ping.carNumber)\n }\n ${corrTime}\n ${speedStr}\n ${\n ping.distance.toFixed(0)\n }m\n Map\n \n `;\n })\n .join(\"\");\n\n const startTime = new Date(batchStart).toLocaleTimeString(\"en-AU\", {\n hour: \"2-digit\",\n minute: \"2-digit\",\n hour12: true,\n });\n const endTime = new Date(batchEnd).toLocaleTimeString(\"en-AU\", {\n hour: \"2-digit\",\n minute: \"2-digit\",\n hour12: true,\n });\n\n return `\n

\n [WAYPOINT] ${stripNonLatin1(waypointName)}\n

\n Batch Report: ${startTime} -$ {endTime} | ${sorted.length} team(s) passed\n

\n \n \n \n \n \n \n \n \n \n \n \n \n \n ${rows}\n \n

Team	Car#	Time	Speed	Dist	Map

\n \n

\n Generated by Rally Batch Reporter - ${\n new Date().toLocaleString(\"en-AU\")\n }\n

\n `;\n}\n\nexport default async function handler(req: Request): Promise {\n if (req.method === \"OPTIONS\") {\n return new Response(null, {\n status: 204,\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n },\n });\n }\n\n const url = new URL(req.url);\n const path = url.pathname;\n\n if (\n req.method === \"POST\" && (path === \"/ping\" || path === \"/\" || path === \"\")\n ) {\n try {\n const body = await req.json();\n\n if (body.to && body.subject && body.html) {\n const recipients = Array.isArray(body.to) ? body.to : [body.to];\n const bccList = body.bcc\n ? (Array.isArray(body.bcc) ? body.bcc : [body.bcc])\n : undefined;\n\n const result = await sendMailjetEmail(\n recipients,\n body.subject,\n body.html,\n bccList,\n );\n\n if (result.success) {\n return jsonResponse({\n success: true,\n message: \"Email sent successfully\",\n });\n } else {\n return jsonResponse({ success: false, error: result.error }, 500);\n }\n }\n\n if (!body.waypointName || !body.teamName) {\n return jsonResponse(\n { error: \"Missing required fields: waypointName, teamName\" },\n 400,\n );\n }\n\n const ping: WaypointPing = {\n id: crypto.randomUUID(),\n teamName: body.teamName || \"Unknown\",\n carNumber: body.carNumber || \"N/A\",\n waypointName: body.waypointName,\n waypointId: body.waypointId || \"\",\n detectionTime: body.detectionTime || new Date().toISOString(),\n correctedTime: body.correctedTime || body.detectionTime ||\n new Date().toISOString(),\n speed: body.speed ?? null,\n latitude: body.latitude || 0,\n longitude: body.longitude || 0,\n distance: body.distance || 0,\n phoneNumber: body.phoneNumber || \"\",\n receivedAt: new Date().toISOString(),\n };\n\n const pings = await getPings();\n pings.push(ping);\n await savePings(pings);\n\n return jsonResponse({\n success: true,\n message:\n `Ping received for

{ping.teamName} at

{ping.waypointName}`,\n pendingCount: pings.length,\n });\n } catch (err: any) {\n return jsonResponse({ error: \"Invalid request: \" + err.message }, 400);\n }\n }\n\n if (req.method === \"GET\" && path === \"/batch\") {\n const secret = Deno.env.get(\"BATCH_SECRET\");\n if (secret) {\n const authParam = url.searchParams.get(\"secret\");\n const authHeader = req.headers.get(\"Authorization\");\n if (authParam !== secret && authHeader !== `Bearer ${secret}`) {\n return jsonResponse({ error: \"Unauthorized\" }, 401);\n }\n }\n\n const rallyBossEmail = \"waypointtracker@gmail.com\";\n const pings = await getPings();\n\n if (pings.length === 0) {\n return jsonResponse({\n success: true,\n message: \"No pending pings to send\",\n emailsSent: 0,\n });\n }\n\n const grouped: Record = {};\n for (const ping of pings) {\n const key = ping.waypointName;\n if (!grouped[key]) grouped[key] = [];\n grouped[key].push(ping);\n }\n\n const allTimes = pings.map((p) => p.receivedAt);\n const batchStart = allTimes.sort()[0];\n const batchEnd = new Date().toISOString();\n\n let emailsSent = 0;\n const errors: string[] = [];\n\n const recipients = rallyBossEmail\n .split(\",\")\n .map((e) => e.trim())\n .filter((e) => e.includes(\"@\"));\n\n for (const [waypointName, waypointPings] of Object.entries(grouped)) {\n const subject =\n `[WAYPOINT]

{waypointName} -

{waypointPings.length} team(s) | Batch Report`;\n const html = buildBatchEmailHtml(\n waypointName,\n waypointPings,\n batchStart,\n batchEnd,\n );\n\n const result = await sendMailjetEmail(recipients, subject, html);\n\n if (result.success) {\n emailsSent++;\n } else {\n errors.push(\n `

{waypointName}:

{result.error}`,\n );\n }\n }\n\n if (emailsSent > 0) {\n await savePings([]);\n await blob.setJSON(LAST_BATCH_KEY, { time: batchEnd });\n\n const history = await getHistory();\n history.unshift({\n sentAt: batchEnd,\n waypointCount: Object.keys(grouped).length,\n pingCount: pings.length,\n emailsSent,\n });\n await saveHistory(history);\n }\n\n return jsonResponse({\n success: emailsSent > 0,\n message:\n `Batch complete:

{emailsSent} email(s) sent for

{Object.keys(grouped).length} waypoint(s), ${pings.length} total pings`,\n emailsSent,\n waypointCount: Object.keys(grouped).length,\n pingCount: pings.length,\n errors: errors.length > 0 ? errors : undefined,\n });\n }\n\n if (req.method === \"GET\" && path === \"/status\") {\n const pings = await getPings();\n let lastBatchTime = null;\n try {\n const lastBatch = await blob.getJSON(LAST_BATCH_KEY);\n lastBatchTime = (lastBatch as { time: string })?.time || null;\n } catch {}\n\n const byWaypoint: Record = {};\n for (const ping of pings) {\n byWaypoint[ping.waypointName] = (byWaypoint[ping.waypointName] || 0) + 1;\n }\n\n return jsonResponse({\n pendingPings: pings.length,\n byWaypoint,\n lastBatchSent: lastBatchTime,\n serverTime: new Date().toISOString(),\n });\n }\n\n if (req.method === \"GET\" && path === \"/history\") {\n const history = await getHistory();\n return jsonResponse({ history });\n }\n\n if (req.method === \"POST\" && path === \"/clear\") {\n await savePings([]);\n return jsonResponse({\n success: true,\n message: \"All pending pings cleared\",\n });\n }\n\n return jsonResponse({\n error: \"Unknown endpoint\",\n endpoints: {\n \"POST /ping\": \"Submit a waypoint detection\",\n \"GET /batch\": \"Trigger batch email send\",\n \"GET /status\": \"Show pending pings and last batch time\",\n \"GET /history\": \"Show batch send history\",\n \"POST /clear\": \"Clear all pending pings\",\n },\n }, 404);\n}","label",[75],"pulls","branches","forks","envVars",{"_288":84,"_290":20},"connections",{"_288":20,"_289":20},"count","unfilledCount","emptyCount",{"_44":273,"_13":75,"_73":74,"_54":-5,"_46":47,"_274":197,"_275":267,"_48":292,"_50":190,"_76":124,"_277":278,"_78":24,"_279":-5,"_293":294,"_250":295},["D",1781784640921],"children",[],[75],["D",1781372405754],{"_11":12,"_249":81},{"_11":12,"_244":245,"_80":81,"_25":79,"_246":247,"_248":24},{"_50":197,"_13":16,"_44":47,"_236":202,"_237":-5,"_238":-5,"_239":-5,"_240":-5,"_241":-5,"_242":14,"_243":12},"ctx",{"_62":-5,"_269":333,"_334":335,"_336":337,"_338":24,"_339":24,"_340":24,"_341":267,"_342":-5,"_343":-7,"_344":-7,"_345":20,"_346":24,"_347":24,"_348":-5,"_349":24,"_350":24,"_351":24,"_352":-5},"ENV",{"_304":305,"_306":307,"_308":16,"_309":310,"_311":312,"_313":314,"_315":316,"_317":318,"_319":320,"_321":322,"_323":324,"_325":326,"_327":328,"_329":330,"_331":332},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]