[{"_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",{"_11":12,"_13":14,"_91":-7,"_92":93,"_29":-7,"_94":-5,"_15":95,"_96":97,"_98":99,"_100":101,"_102":103,"_104":-5,"_105":-5,"_106":-5,"_107":38,"_108":109,"_110":111,"_112":-5,"_113":-5,"_114":115},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","cpaulsen5891","name","ais-proxy","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":-5,"_62":63,"_64":63,"_65":66,"_67":66,"_68":66,"_69":63,"_70":63,"_71":72,"_73":74,"_75":76,"_77":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","e53bb83d-7c90-4f7b-aec1-5a40666bb97f","createdAt",["D",1781700563557],"updatedAt",["D",1781879843131],"main","projectId","4ba7ef53-bff5-46f0-b72b-4be89b9d1e0d","version",29,"forkedBranchId","forkedBranchVersion","lockfileKey","1781879843236-esm.town_v_cpaulsen5891_ais-proxy@29-main","deletedAt",["D",1781700563551],"legacyEnvVars",false,"privacy","public","httpPrivacy","description","Collapse Horizon AIS proxy endpoint.","imageUrl","userId","8c5bf5c7-e8ff-4c1c-8e0f-978729e1a9b1","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019ed291-fa6e-72ae-a8f5-6626f3f3a93a","tursoName","4ba7ef53bff546f0b72b4be89b9d1e0d","tursoHostname","4ba7ef53bff546f0b72b4be89b9d1e0d-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789558275908],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_90":86},"org",{"_11":12,"_83":84,"_85":86,"_45":46,"_87":88,"_89":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_78":-5,"_79":-5,"_80":-5,"_81":14,"_82":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","C R Paul","avatar","https://lh3.googleusercontent.com/a/ACg8ocK4HQKzxkriEkQ-l0ASodEQP1Wd1XwDksPAKbRNTBRjyNBcVA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_20":28,"_13":14,"_22":149,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":56,"_57":58,"_59":150,"_61":-5,"_62":63,"_64":63,"_65":66,"_67":66,"_68":66,"_69":63,"_70":63,"_71":151,"_73":152,"_75":153,"_77":38},"tree",[144],"files",[144],"counts",{"_134":52,"_17":135,"_136":52,"_137":138,"_139":140},"contents",[116],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_20":117,"_13":118,"_119":120,"_121":-5,"_122":21,"_123":30,"_124":111,"_22":125,"_29":126,"_127":128,"_129":130,"_131":38,"_132":-5,"_92":133},"be34b9ad-ae4c-4adc-b1e2-e2ec5ba8bf8a","main.ts","fileId","f7625152-6a4a-11f1-82aa-1607ee4eb77e","parentId","branchId","branchVersion","latest",["D",1781879843131],28,"fileType","http","content","import { blob } from \"https://esm.town/v/std/blob\";\n\nconst STORE_KEY = \"ais_maritime_memory_v1\";\nconst MAX_AGE_MS = 45 * 60 * 1000;\nconst WINDOW_MS = 35_000;\n\nconst REGIONS = [\n { id: \"hormuz\", name: \"Persian Gulf & Hormuz\", box: [[22, 47], [31, 61]] },\n { id: \"red_sea\", name: \"Red Sea / Bab el-Mandeb\", box: [[8, 38], [23, 45]] },\n { id: \"suez\", name: \"Eastern Mediterranean & Suez\", box: [[27, 25], [37, 37]] },\n { id: \"panama\", name: \"Caribbean & Panama Gateway\", box: [[5, -85], [15, -74]] },\n { id: \"malacca\", name: \"Strait of Malacca\", box: [[0, 95], [8, 105]] },\n { id: \"taiwan\", name: \"Taiwan Strait\", box: [[20, 117], [27, 123]] },\n { id: \"south_china_sea\", name: \"South China Sea\", box: [[0, 105], [25, 123]] },\n { id: \"great_lakes\", name: \"Great Lakes\", box: [[41, -93], [49, -75]] },\n { id: \"north_atlantic\", name: \"North Atlantic Trade Lanes\", box: [[25, -80], [65, 15]] },\n { id: \"mediterranean\", name: \"Mediterranean Basin\", box: [[30, -6], [46, 37]] },\n { id: \"indian_ocean\", name: \"Indian Ocean Trade Corridor\", box: [[-15, 45], [30, 100]] },\n { id: \"japan\", name: \"Japan Sea Lanes\", box: [[30, 125], [46, 150]] },\n { id: \"gulf_mexico\", name: \"Gulf of Mexico\", box: [[18, -98], [31, -80]] },\n { id: \"black_sea\", name: \"Black Sea Grain / Conflict Zone\", box: [[40, 27], [48, 42]] },\n];\n\nfunction classifyShipType(code: number | null | undefined): string {\n if (code == null || code === 0) return \"Unknown / Not Reported\";\n if (code >= 20 && code <= 29) return \"Wing-in-Ground Craft\";\n if (code === 30) return \"Fishing\";\n if (code === 31 || code === 32 || code === 52) return \"Tug / Tow\";\n if (code === 35) return \"Military (self-reported)\";\n if (code === 36 || code === 37) return \"Pleasure Craft / Sailing\";\n if (code >= 40 && code <= 49) return \"High-Speed Craft\";\n if (code >= 60 && code <= 69) return \"Passenger\";\n if (code >= 70 && code <= 79) return \"Cargo\";\n if (code >= 80 && code <= 89) return \"Tanker\";\n if (code >= 90 && code <= 99) return \"Other / Special Craft\";\n return \"Other / Special Craft\";\n}\n\nconst SHIP_TYPE_CATEGORIES = [\n \"Cargo\", \"Tanker\", \"Passenger\", \"Fishing\", \"Tug / Tow\",\n \"Military (self-reported)\", \"Pleasure Craft / Sailing\",\n \"High-Speed Craft\", \"Wing-in-Ground Craft\", \"Other / Special Craft\",\n \"Unknown / Not Reported\",\n];\n\nfunction inside(lat: number, lon: number, box: number[][]) {\n return lat >= box[0][0] && lat <= box[1][0] &&\n lon >= box[0][1] && lon <= box[1][1];\n}\n\nfunction initRegion(r: any) {\n const typeCounts: Record = {};\n SHIP_TYPE_CATEGORIES.forEach(c => typeCounts[c] = 0);\n\n return {\n id: r.id,\n name: r.name,\n vessels: 0,\n avgSpeed: 0,\n slowMoving: 0,\n stopped: 0,\n congestion: 0,\n activityScore: 0,\n speedSum: 0,\n typeCounts,\n classifiedCount: 0,\n };\n}\n\nexport default async function(req: Request): Promise {\n const key = Deno.env.get(\"AISSTREAM_API_KEY\");\n\n if (!key) {\n return Response.json({\n ok: false,\n error: \"Missing AISSTREAM_API_KEY\",\n apiKeyLoaded: false,\n }, { status: 500 });\n }\n\n const url = new URL(req.url);\n const reset = url.searchParams.get(\"reset\") === \"true\";\n const now = Date.now();\n\n const memory: any = reset\n ? null\n : await blob.getJSON(STORE_KEY).catch(() => null);\n\n const knownTypes = new Map();\n const lastPositions = new Map();\n\n if (memory?.knownTypes) {\n for (const [mmsi, item] of Object.entries(memory.knownTypes)) {\n const v: any = item;\n if (now - (v.lastUpdate || 0) <= MAX_AGE_MS) {\n knownTypes.set(String(mmsi), Number(v.typeCode));\n }\n }\n }\n\n if (memory?.lastPositions) {\n for (const [mmsi, item] of Object.entries(memory.lastPositions)) {\n const v: any = item;\n if (now - (v.lastUpdate || 0) <= MAX_AGE_MS) {\n lastPositions.set(String(mmsi), v);\n }\n }\n }\n\n let rawMessages = 0;\n let parsedPositions = 0;\n let staticDataMessages = 0;\n let wsOpened = false;\n let wsClosed = false;\n let wsError = false;\n\n const ws = new WebSocket(\"wss://stream.aisstream.io/v0/stream\");\n\n await new Promise((resolve) => {\n let done = false;\n\n const finish = () => {\n if (done) return;\n done = true;\n try { ws.close(); } catch {}\n resolve();\n };\n\n const timer = setTimeout(finish, WINDOW_MS + 5000);\n\n ws.onopen = () => {\n wsOpened = true;\n\n ws.send(JSON.stringify({\n APIKey: key,\n BoundingBoxes: REGIONS.map(r => r.box),\n FilterMessageTypes: [\n \"PositionReport\",\n \"StandardClassBPositionReport\",\n \"ExtendedClassBPositionReport\",\n \"ShipStaticData\",\n ],\n }));\n };\n\n ws.onmessage = async (event) => {\n rawMessages++;\n\n try {\n const text = typeof event.data === \"string\"\n ? event.data\n : await event.data.text();\n\n const msg = JSON.parse(text);\n const meta = msg.MetaData || {};\n const message = msg.Message || {};\n const mmsi = String(meta.MMSI ?? \"\");\n\n if (!mmsi) return;\n\n if (message.ShipStaticData) {\n staticDataMessages++;\n\n const typeCode = Number(\n message.ShipStaticData.Type ??\n message.ShipStaticData.ShipType\n );\n\n if (Number.isFinite(typeCode)) {\n knownTypes.set(mmsi, typeCode);\n }\n\n return;\n }\n\n const pos =\n message.PositionReport ||\n message.StandardClassBPositionReport ||\n message.ExtendedClassBPositionReport;\n\n if (!pos) return;\n\n const lat = Number(meta.latitude ?? pos.Latitude);\n const lon = Number(meta.longitude ?? pos.Longitude);\n const speed = Number(pos.Sog ?? 0);\n\n if (!Number.isFinite(lat) || !Number.isFinite(lon)) return;\n\n parsedPositions++;\n\n lastPositions.set(mmsi, {\n mmsi,\n lat,\n lon,\n speed: Number.isFinite(speed) ? speed : 0,\n lastUpdate: Date.now(),\n });\n } catch {}\n };\n\n ws.onerror = () => {\n wsError = true;\n clearTimeout(timer);\n finish();\n };\n\n ws.onclose = () => {\n wsClosed = true;\n clearTimeout(timer);\n finish();\n };\n });\n\n await blob.setJSON(STORE_KEY, {\n updated: new Date().toISOString(),\n knownTypes: Object.fromEntries(\n [...knownTypes.entries()].map(([mmsi, typeCode]) => [\n mmsi,\n { typeCode, lastUpdate: now },\n ])\n ),\n lastPositions: Object.fromEntries(lastPositions.entries()),\n });\n\n const stats: any = {};\n for (const r of REGIONS) stats[r.id] = initRegion(r);\n\n const seen = new Set();\n\n for (const [mmsi, p] of lastPositions.entries()) {\n if (now - (p.lastUpdate || 0) > MAX_AGE_MS) continue;\n\n for (const r of REGIONS) {\n if (!inside(p.lat, p.lon, r.box)) continue;\n\n const unique = `${r.id}:${mmsi}`;\n if (seen.has(unique)) continue;\n seen.add(unique);\n\n const s = stats[r.id];\n s.vessels++;\n s.speedSum += p.speed || 0;\n\n if (p.speed > 0 && p.speed < 5) s.slowMoving++;\n if (p.speed === 0) s.stopped++;\n\n s.avgSpeed = +(s.speedSum / s.vessels).toFixed(1);\n s.congestion = Math.min(100, Math.round(Math.log10(s.vessels + 1) * 25));\n\n const slowRatio = s.vessels ? s.slowMoving / s.vessels : 0;\n const stoppedRatio = s.vessels ? s.stopped / s.vessels : 0;\n\n s.activityScore = Math.min(100, Math.round(\n s.congestion + slowRatio * 30 + stoppedRatio * 20\n ));\n\n const typeCode = knownTypes.get(mmsi);\n const category = classifyShipType(typeCode);\n\n s.typeCounts[category] = (s.typeCounts[category] || 0) + 1;\n\n if (category !== \"Unknown / Not Reported\") {\n s.classifiedCount++;\n }\n }\n }\n\n const regions = Object.values(stats).map((s: any) => ({\n id: s.id,\n name: s.name,\n vessels: s.vessels,\n avgSpeed: s.avgSpeed,\n slowMoving: s.slowMoving,\n stopped: s.stopped,\n congestion: s.congestion,\n activityScore: s.activityScore,\n typeCounts: s.typeCounts,\n classifiedCount: s.classifiedCount,\n classifiedPct: s.vessels\n ? Math.round((s.classifiedCount / s.vessels) * 100)\n : 0,\n }));\n\n const totals = regions.reduce((a: any, s: any) => {\n a.vessels += s.vessels;\n a.slowMoving += s.slowMoving;\n a.stopped += s.stopped;\n a.classified += s.classifiedCount;\n return a;\n }, { vessels: 0, slowMoving: 0, stopped: 0, classified: 0 });\n\n const fleetTypeCounts: Record = {};\n SHIP_TYPE_CATEGORIES.forEach(c => fleetTypeCounts[c] = 0);\n\n regions.forEach((r: any) => {\n SHIP_TYPE_CATEGORIES.forEach(c => {\n fleetTypeCounts[c] += r.typeCounts[c] || 0;\n });\n });\n\n const topActivityZones = [...regions]\n .sort((a: any, b: any) => b.vessels - a.vessels)\n .slice(0, 8);\n\n const topActivityScores = [...regions]\n .sort((a: any, b: any) => b.activityScore - a.activityScore)\n .slice(0, 8);\n\n return Response.json({\n ok: true,\n source: \"AISStream via Val Town + Blob Memory\",\n mode: \"persistent vessel memory using recent positions + real AIS ShipStaticData\",\n apiKeyLoaded: true,\n memory: reset ? \"reset\" : \"loaded\",\n rememberedVessels: lastPositions.size,\n rememberedTypes: knownTypes.size,\n websocket: {\n opened: wsOpened,\n closed: wsClosed,\n error: wsError,\n },\n windowSeconds: Math.round(WINDOW_MS / 1000),\n rawMessages,\n parsedPositions,\n staticDataMessages,\n totals,\n classifiedPctOverall: totals.vessels\n ? Math.round((totals.classified / totals.vessels) * 100)\n : 0,\n fleetTypeCounts,\n regions,\n topActivityZones,\n topActivityScores,\n caveats: [\n \"Blob memory stores recent vessel positions and ShipStaticData for 45 minutes.\",\n \"Vessel type comes from AIS ShipStaticData, not from geography.\",\n \"Military means AIS ShipType code 35 only and will undercount real military traffic.\",\n \"Activity score is heuristic, not a threat model.\",\n ],\n updated: new Date().toISOString(),\n }, {\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Cache-Control\": \"no-store\",\n },\n });\n}","deleted","label",[118],"pulls",1,"forks","envVars",{"_141":135,"_143":52},"connections",{"_141":52,"_142":52},"count","unfilledCount","emptyCount",{"_20":117,"_13":118,"_119":120,"_121":-5,"_122":21,"_123":30,"_124":111,"_22":145,"_29":126,"_127":128,"_129":130,"_131":38,"_132":-5,"_146":147,"_92":148},["D",1781879843131],"children",[],[118],["D",1781700563551],["D",1789558275908],{"_11":12,"_90":86},{"_11":12,"_83":84,"_85":86,"_45":46,"_87":88,"_89":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_78":-5,"_79":-5,"_80":-5,"_81":14,"_82":12},"ctx",{"_71":-5,"_113":187,"_188":189,"_190":191,"_192":38,"_193":38,"_194":38,"_195":111,"_196":-5,"_197":-7,"_198":-7,"_199":52,"_200":38,"_201":38,"_202":-5,"_203":38,"_204":38,"_205":38,"_206":-5},"ENV",{"_158":159,"_160":161,"_162":26,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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"]

Branches1

Branches
1