[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_153":154,"_155":156},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_116":-5,"_20":117,"_22":118,"_119":120,"_121":122,"_25":123,"_24":-5,"_124":-5,"_125":-5,"_126":53,"_127":128,"_129":44,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","wttdotm","name","nyc-webcam","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":69,"_70":-5,"_71":72,"_73":-5,"_74":53,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":-5,"_82":-5,"_83":-5,"_84":-5,"_85":86,"_87":86,"_88":89,"_90":89,"_91":89,"_92":86,"_93":86,"_94":95,"_96":97,"_98":99,"_100":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","b759ad83-13f1-4ca8-845e-9b90b6114991","webcam.http.ts","fileId","f7e5155a-605a-11f1-9985-1607ee4eb77e","parentId","branchId","46515997-607b-45f6-9b2f-f309ff614de7","branchVersion",12,"latest",true,"createdAt",["D",1780672126789],11,"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 at any fps

\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

Code