[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_103":85,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":121,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",11,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","webcam.http.ts","latestPath","fileId","f7e5155a-605a-11f1-9985-1607ee4eb77e","name","fileType","http","content","import { blob } from \"https://esm.town/v/std/blob\";\n\nconst WEBCAM_URL =\n \"https://webcams.nyctmc.org/api/cameras/1e60ade7-c760-48cf-acd9-d9d6cbfa9420/image\";\n\nconst CLEANUP_AGE_MS = 4 * 60 * 1000;\nconst CLIP_DURATION_MS = 3 * 60 * 1000;\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname;\n\n const corsHeaders = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n };\n\n if (req.method === \"OPTIONS\") {\n return new Response(null, { headers: corsHeaders });\n }\n\n if (req.method === \"GET\" && path === \"/\") {\n return new Response(getPageHTML(), {\n headers: { ...corsHeaders, \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n }\n\n if (req.method === \"POST\" && path === \"/save\") {\n try {\n const body = await req.json();\n const imageUrl = body.url || body.imageUrl;\n const timestamp = body.timestamp || Date.now();\n const imgResp = await fetch(imageUrl);\n if (!imgResp.ok) {\n return new Response(\n JSON.stringify({ ok: false, error: \"Failed to fetch image: \" + imgResp.status }),\n { status: 502, headers: { ...corsHeaders, \"Content-Type\": \"application/json\" } },\n );\n }\n const imgBuffer = await imgResp.arrayBuffer();\n const key = \"webcam-\" + timestamp + \".jpg\";\n await blob.set(key, new Uint8Array(imgBuffer));\n cleanupOldBlobs().catch((e) => console.error(\"Cleanup error:\", e));\n return new Response(\n JSON.stringify({ ok: true, key, ts: timestamp }),\n { headers: { ...corsHeaders, \"Content-Type\": \"application/json\" } },\n );\n } catch (e) {\n return new Response(\n JSON.stringify({ ok: false, error: String(e) }),\n { status: 500, headers: { ...corsHeaders, \"Content-Type\": \"application/json\" } },\n );\n }\n }\n\n if (path === \"/capture\") {\n try {\n const ts = Date.now();\n const imgUrl = WEBCAM_URL + \"?t=\" + ts;\n const imgResp = await fetch(imgUrl);\n if (!imgResp.ok) throw new Error(\"Fetch failed: \" + imgResp.status);\n const imgBuffer = await imgResp.arrayBuffer();\n const key = \"webcam-\" + ts + \".jpg\";\n await blob.set(key, new Uint8Array(imgBuffer));\n cleanupOldBlobs().catch((e) => console.error(\"Cleanup error:\", e));\n return new Response(\n JSON.stringify({ ok: true, key, ts }),\n { headers: { ...corsHeaders, \"Content-Type\": \"application/json\" } },\n );\n } catch (e) {\n return new Response(\n JSON.stringify({ ok: false, error: String(e) }),\n { status: 500, headers: { ...corsHeaders, \"Content-Type\": \"application/json\" } },\n );\n }\n }\n\n if (req.method === \"GET\" && path === \"/blobs\") {\n try {\n const rawKeys = await blob.list(\"webcam-\");\n const allKeys: string[] = (Array.isArray(rawKeys) ? rawKeys : []).map((k: any) =>\n typeof k === \"string\" ? k : (k && typeof k === \"object\" ? (k as any).key ?? String(k) : String(k))\n );\n const now = Date.now();\n const recentKeys = allKeys\n .map((key: string) => {\n const match = key.match(/^webcam-(\\d+)\\.jpg$/);\n if (!match) return null;\n return { key, ts: parseInt(match[1]) };\n })\n .filter((item): item is { key: string; ts: number } =>\n item !== null && (now - item.ts) <= CLIP_DURATION_MS\n )\n .sort((a, b) => a.ts - b.ts);\n return new Response(JSON.stringify(recentKeys), {\n headers: { ...corsHeaders, \"Content-Type\": \"application/json\" },\n });\n } catch (e) {\n return new Response(\n JSON.stringify({ ok: false, error: String(e) }),\n { status: 500, headers: { ...corsHeaders, \"Content-Type\": \"application/json\" } },\n );\n }\n }\n\n if (req.method === \"GET\" && path.startsWith(\"/blob/\")) {\n const blobKey = path.slice(6);\n try {\n const data = await blob.get(blobKey);\n if (data instanceof Response) {\n const h = new Headers(corsHeaders);\n h.set(\"Cache-Control\", \"public, max-age=31536000\");\n return new Response(data.body, { headers: h, status: data.status });\n }\n return new Response(data, {\n headers: { ...corsHeaders, \"Content-Type\": \"image/jpeg\", \"Cache-Control\": \"public, max-age=31536000\" },\n });\n } catch {\n return new Response(\"Not found\", { status: 404, headers: corsHeaders });\n }\n }\n\n return new Response(\"Not found\", { status: 404, headers: corsHeaders });\n}\n\nasync function cleanupOldBlobs() {\n const rawKeys = await blob.list(\"webcam-\");\n const allKeys: string[] = (Array.isArray(rawKeys) ? rawKeys : []).map((k: any) =>\n typeof k === \"string\" ? k : (k && typeof k === \"object\" ? (k as any).key ?? String(k) : String(k))\n );\n const now = Date.now();\n const stale = allKeys.filter((key: string) => {\n const match = key.match(/^webcam-(\\d+)\\.jpg$/);\n return match && (now - parseInt(match[1])) > CLEANUP_AGE_MS;\n });\n if (stale.length > 0) {\n await Promise.all(stale.map((key: string) => blob.delete(key)));\n console.log(\"Cleaned up \" + stale.length + \" stale blobs\");\n }\n}\n\nfunction getPageHTML(): string {\n const wu = WEBCAM_URL;\n return `\n\n\n\n\nNYC Webcam Timelapse\n\n\n\n

📷 NYC Webcam Timelapse

Snapshots every 2s · 4-min rolling window · clips up to 3 min

\n\n

🔴 Live Feed

Connecting to webcam...

\n \n

\n Frames: 0\n Last: --\n Recording\n \n

\n\n

🎬 Timelapse Clip

\n FPS:\n \n \n

\n \n \n \n

\n\n

Diff · v11