[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_163":164,"_165":166},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_61":133,"_16":-7,"_134":-5,"_17":135,"_136":137,"_28":138,"_21":139,"_23":140,"_141":-5,"_142":-5,"_143":-5,"_144":36,"_145":146,"_147":34,"_148":-5,"_149":-5,"_150":151},"routes/_app.x.$handle.$name._index",{"_11":12,"_13":14,"_15":-7,"_16":-7,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-7,"_26":-5,"_27":-5,"_28":29,"_30":-5,"_31":-5,"_32":-5,"_33":34,"_35":36,"_37":34},"handle","wttdotm","name","nyc-webcam","branchName","version","project",{"_39":78,"_13":14,"_50":79,"_80":-5,"_81":36,"_82":83,"_84":83,"_85":86,"_87":-5,"_88":89,"_90":-5,"_91":36,"_92":-5,"_93":-5,"_94":67,"_95":96,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":102,"_103":102,"_104":105,"_106":105,"_107":105,"_108":102,"_109":102,"_110":111,"_112":113,"_114":115,"_116":36},"tags",[],"counts",{"_66":67,"_68":69,"_70":67,"_71":72,"_73":74},"contents",[63],"readme","upstream","pull","files",[38],"preview","ahead","behind","showHomeCustomizationHint",true,"showHTTPPreviewSettingsHint",false,"hasHTTPFiles",{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":34,"_50":51,"_16":52,"_53":54,"_55":56,"_57":36,"_58":-5,"_59":60,"_61":62},"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","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