[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_222":223,"_224":225},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_105":87,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":123,"_124":-5,"_125":-5,"_126":127},"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":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",54,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":37,"_35":36,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","SMEFLOW.ts","latestPath","fileId","b0a77e9a-2468-11f1-bf8b-42dde27851f2","name","fileType","script","content","// Learn more: https://docs.val.town/vals/http/\nexport default async function (req: Request): Promise {\n return Response.json({ ok: true })\n}","http","createdAt",["D",1774016763436],"branchVersion","branchId","3ee44cc0-f74a-11f0-b0eb-42dde27851f2","id","3ee3e668-f74a-11f0-b0eb-42dde27851f2","WF",["D",1769055870320],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","019be3ee-b210-72df-b0b7-1c63b5f83da1","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019be3ee-b210-72df-b0b7-20f942b1694c","tursoName","3ee3e668f74a11f0b0eb42dde27851f2","tursoHostname","3ee3e668f74a11f0b0eb42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789542098478],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_104":100},"org",{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":25},"branch",{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned",56,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","gflow","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM4YjVwUVVEZWJ2b0RPYVpYSHBhNXRUQmEwdSJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":217,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":218,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":219,"_81":220,"_83":221,"_85":25},"tree",[192,193,194,195,196,197],"files",[192,193,194,195,196,197],"counts",{"_181":60,"_182":183,"_184":60,"_185":186,"_187":188},"contents",[128,129,130,131,132,133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":173,"_32":174,"_30":175,"_137":-5,"_41":42,"_40":176,"_139":123,"_38":177,"_13":178,"_33":37,"_35":179,"_24":25,"_143":-5,"_27":180},{"_43":165,"_32":166,"_30":167,"_137":-5,"_41":42,"_40":168,"_139":123,"_38":169,"_13":170,"_33":37,"_35":171,"_24":25,"_143":-5,"_27":172},{"_43":161,"_32":28,"_30":31,"_137":-5,"_41":42,"_40":14,"_139":25,"_38":162,"_13":163,"_33":37,"_35":36,"_24":25,"_143":-5,"_27":164},{"_43":153,"_32":154,"_30":155,"_137":-5,"_41":42,"_40":156,"_139":123,"_38":157,"_13":158,"_33":37,"_35":159,"_24":25,"_143":-5,"_27":160},{"_43":145,"_32":146,"_30":147,"_137":-5,"_41":42,"_40":148,"_139":123,"_38":149,"_13":150,"_33":37,"_35":151,"_24":25,"_143":-5,"_27":152},{"_43":134,"_32":135,"_30":136,"_137":-5,"_41":42,"_40":138,"_139":123,"_38":140,"_13":141,"_33":37,"_35":142,"_24":25,"_143":-5,"_27":144},"d647c156-f75d-11f0-9158-42dde27851f2","main.ts","3ee70b0e-f74a-11f0-b0eb-42dde27851f2","parentId",6,"latest",["D",1769064284722],5,"import { blob } from \"https://esm.town/v/std/blob\";\n\n// Normalize key to snake_case\nfunction normalizeKey(key: string): string {\n return String(key).toLowerCase().replace(/[\\s-]/g, \"_\");\n}\n\n// Format complex details as readable bullet points\nfunction formatDetails(details: any): string {\n if (typeof details !== \"object\" || details === null) {\n return String(details);\n }\n\n if (Array.isArray(details)) {\n return details.map((v) =>\n typeof v === \"object\" ? JSON.stringify(v) : String(v)\n ).join(\"\\n\");\n }\n\n const lines: string[] = [];\n for (const [key, value] of Object.entries(details)) {\n const label = key.replace(/_/g, \" \").replace(/-/g, \" \")\n .split(\" \").map((w) => w.charAt(0).toUpperCase() + w.slice(1)).join(\" \");\n\n let displayValue: string;\n if (typeof value === \"object\" && value !== null) {\n displayValue = JSON.stringify(value);\n } else if (Array.isArray(value)) {\n displayValue = value.join(\", \");\n } else {\n displayValue = String(value);\n }\n\n lines.push(`• ${label}: ${displayValue}`);\n }\n\n return lines.join(\"\\n\");\n}\n\n// Normalize the raw data_from_user into a clean structure\nfunction normalizeData(rawData: any): Record {\n const collected: Record = {};\n\n // Handle string input (JSON string)\n let parsed = rawData;\n if (typeof rawData === \"string\") {\n try {\n parsed = JSON.parse(rawData);\n } catch {\n // Not valid JSON - treat as plain text\n return { service_requirements: rawData };\n }\n }\n\n // Ensure array\n if (!Array.isArray(parsed)) {\n parsed = parsed ? [parsed] : [];\n }\n\n for (const item of parsed) {\n if (typeof item !== \"object\" || item === null) {\n // Non-object item\n if (!collected.other_data) collected.other_data = [];\n collected.other_data.push(String(item));\n continue;\n }\n\n // Check for categorized format: {\"category\": \"...\", \"details\": {...}}\n if (\"category\" in item && \"details\" in item) {\n const category = normalizeKey(item.category);\n const details = item.details;\n\n // Store formatted details\n if (typeof details === \"object\" && details !== null) {\n collected[category] = formatDetails(details);\n\n // Detect move/migrate actions\n const action = (details.action || \"\").toLowerCase();\n if ([\"migrate\", \"move\", \"relocate\", \"transfer\"].includes(action)) {\n collected.is_move_to_new_address = true;\n }\n } else {\n collected[category] = String(details);\n }\n } else {\n // Flat key-value format: {\"field\": \"value\", ...}\n for (const [key, value] of Object.entries(item)) {\n const normKey = normalizeKey(key);\n\n if (typeof value === \"object\" && value !== null) {\n collected[normKey] = formatDetails(value);\n } else if (Array.isArray(value)) {\n collected[normKey] = value.join(\", \");\n } else if (typeof value === \"boolean\") {\n collected[normKey] = value;\n } else {\n // Append if exists, otherwise set\n if (normKey in collected && typeof collected[normKey] === \"string\") {\n collected[normKey] += \"\\n\" + String(value);\n } else {\n collected[normKey] = String(value);\n }\n }\n }\n }\n }\n\n // Clean up other_data\n if (collected.other_data && Array.isArray(collected.other_data)) {\n collected.other_data = collected.other_data.join(\"\\n\");\n }\n\n return collected;\n}\n\nexport default async function (req: Request): Promise {\n const headers = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n \"Content-Type\": \"application/json\",\n };\n\n if (req.method === \"OPTIONS\") {\n return new Response(null, { headers });\n }\n\n let allData = await blob.getJSON(\"ai_collected_data\") || {};\n\n // POST - Store and normalize data\n if (req.method === \"POST\") {\n try {\n const body = await req.json();\n const requestId = body.request_id;\n\n if (!requestId) {\n return Response.json({ error: \"Missing request_id\", success: false }, {\n status: 400,\n headers,\n });\n }\n\n // Normalize the raw data\n const rawData = body.data_from_user || body.collected_data ||\n body.ai_response || {};\n const normalized = normalizeData(rawData);\n\n // Merge with existing data\n const existing = allData[requestId] || {};\n const existingCollected = existing.collected_data || {};\n const mergedCollected = { ...existingCollected, ...normalized };\n\n // Store\n allData[requestId] = {\n collected_data: mergedCollected,\n collected_at: new Date().toISOString(),\n source: \"ai_agent\",\n fields_collected: Object.keys(mergedCollected),\n update_count: (existing.update_count || 0) + 1,\n };\n\n await blob.setJSON(\"ai_collected_data\", allData);\n\n return Response.json({\n success: true,\n request_id: requestId,\n fields_collected: Object.keys(mergedCollected),\n }, { headers });\n } catch (e) {\n return Response.json({ error: String(e), success: false }, {\n status: 500,\n headers,\n });\n }\n }\n\n // DELETE\n if (req.method === \"DELETE\") {\n const url = new URL(req.url);\n const requestId = url.searchParams.get(\"request_id\");\n\n if (requestId && allData[requestId]) {\n delete allData[requestId];\n await blob.setJSON(\"ai_collected_data\", allData);\n return Response.json({ success: true, deleted: requestId }, { headers });\n }\n\n if (url.searchParams.get(\"all\") === \"true\") {\n await blob.setJSON(\"ai_collected_data\", {});\n return Response.json({ success: true, deleted: \"all\" }, { headers });\n }\n\n return Response.json({ success: false, error: \"Not found\" }, {\n status: 404,\n headers,\n });\n }\n\n // GET\n const url = new URL(req.url);\n const requestId = url.searchParams.get(\"request_id\");\n\n if (requestId) {\n return Response.json(allData[requestId] || null, { headers });\n }\n\n return Response.json(allData, { headers });\n}","label",[135],"e3b96f6a-0531-11f1-a979-42dde27851f2","credflow.ts","bd815076-0273-11f1-a046-42dde27851f2",29,["D",1770584725716],10,"// @valtown/http\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst KEY = \"credit_call_data\";\n\n// Define your data type\ntype CallData = {\n application_id: string | null;\n call_objective: string | null;\n call_questions: string[];\n documents_to_request: string[];\n missing_or_unverified_items: any[];\n created_at: string;\n};\n\nexport default async function handler(req: Request) {\n if (req.method === \"POST\") {\n try {\n const data = await req.json();\n const payload: CallData = {\n application_id: data.application_id ?? null,\n call_objective: data.call_objective ?? null,\n call_questions: data.call_questions ?? [],\n documents_to_request: data.documents_to_request ?? [],\n missing_or_unverified_items: data.missing_or_unverified_items ?? [],\n created_at: new Date().toISOString(),\n };\n\n const rawData = await blob.getJSON(KEY);\n let existing: CallData[] = Array.isArray(rawData) ? rawData : [];\n\n existing.push(payload);\n\n await blob.setJSON(KEY, existing);\n\n return new Response(\n JSON.stringify({ status: \"ok\", count: existing.length }),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } },\n );\n } catch (err: any) {\n console.error(\"POST error:\", err);\n return new Response(\n JSON.stringify({ error: err.message || \"Invalid JSON\" }),\n { status: 400, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n }\n\n if (req.method === \"GET\") {\n const rawData = await blob.getJSON(KEY);\n const data: CallData[] = Array.isArray(rawData) ? rawData : [];\n return new Response(\n JSON.stringify(data),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n // 🔥 CLEAR ALL RECORDS\n if (req.method === \"DELETE\") {\n await blob.setJSON(KEY, []);\n return new Response(\n JSON.stringify({ status: \"cleared\" }),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n return new Response(\"Method Not Allowed\", { status: 405 });\n}",[146],"93a52604-0509-11f1-b7f9-42dde27851f2","appStatus.ts","fc3c6c86-04f0-11f1-977f-42dde27851f2",28,["D",1770567411504],11,"// @valtown/http\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst BLOB_KEY = \"app-status.json\";\n\ntype Item = {\n application_id: string;\n stage: string;\n updated_at: number;\n};\n\nasync function readStore(): Promise {\n try {\n const data = await blob.get(BLOB_KEY);\n if (!data) return [];\n\n const text = await data.text();\n return JSON.parse(text);\n } catch {\n return [];\n }\n}\n\nasync function writeStore(items: Item[]) {\n await blob.set(\n BLOB_KEY,\n new TextEncoder().encode(JSON.stringify(items)),\n );\n}\n\nexport default async function handler(req: Request): Promise {\n // POST — upsert by application_id\n if (req.method === \"POST\") {\n let body;\n try {\n body = await req.json();\n } catch {\n return new Response(\"Invalid JSON\", { status: 400 });\n }\n\n const { application_id, stage } = body ?? {};\n\n if (\n typeof application_id !== \"string\" ||\n typeof stage !== \"string\"\n ) {\n return new Response(\n \"application_id and stage must be strings\",\n { status: 400 },\n );\n }\n\n const items = await readStore();\n\n const updated = items.filter(\n (i) => i.application_id !== application_id,\n );\n\n updated.push({\n application_id,\n stage,\n updated_at: Date.now(),\n });\n\n await writeStore(updated);\n\n return new Response(\n JSON.stringify({ ok: true }),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n // GET — list all items\n if (req.method === \"GET\") {\n const items = await readStore();\n return new Response(\n JSON.stringify(items, null, 2),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n // DELETE — clear all\n if (req.method === \"DELETE\") {\n await writeStore([]);\n return new Response(\n JSON.stringify({ ok: true, cleared: true }),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n return new Response(\"Method Not Allowed\", { status: 405 });\n}",[154],"b9a33048-2468-11f1-8780-42dde27851f2",["D",1774016763436],3,[28],"eb3c776e-17ab-11f1-8331-42dde27851f2","B2C-rooftop-pv.ts","af749256-122f-11f1-8947-42dde27851f2",48,["D",1772616257849],9,"// @valtown/http\n// SIPS Mock Database — DSO B2CFlow Demo\n// Handles: CUPS lookup, Holder ID match, Connection Point status\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst KEY = \"sips_records\";\n\n// ─────────────────────────────────────────\n// MOCK SIPS RECORDS\n// One wrong CUPS (what the consumer submitted) → INEXISTENT\n// One correct CUPS (what the consumer should have submitted) → EXISTS\n// ─────────────────────────────────────────\nconst SEED_RECORDS: SIPSRecord[] = [\n {\n cups: \"ES0031605077564984WF\", // correct CUPS (from CIE cert)\n holder_id: \"B12345678\",\n holder_name: \"María Elena Rodríguez Fernández\",\n connection_point_status: \"active\",\n pv_rooftop_attributes_allowed: true,\n contracted_capacity_kw: 5.75,\n supply_voltage: \"230 V AC, Single Phase\",\n supply_frequency: \"50 Hz\",\n tariff: \"2.0TD\",\n municipality: \"Madrid\",\n address: \"Calle Mayor, 47, 3rd Floor B\",\n postcode: \"28013\",\n meter_type: \"bidirectional_smart\",\n meter_remote_configurable: true,\n existing_pv_rooftop: false,\n retailer_id: \"RET-00291\",\n retailer_name: \"Endesa Energía S.A.\",\n retailer_email: \"activaciones@endesa.es\",\n },\n // NOTE: ES0039401234568790AB (submitted by consumer) is intentionally\n // NOT in this list → will return INEXISTENT\n];\n\ntype SIPSRecord = {\n cups: string;\n holder_id: string;\n holder_name: string;\n connection_point_status: string;\n pv_rooftop_attributes_allowed: boolean;\n contracted_capacity_kw: number;\n supply_voltage: string;\n supply_frequency: string;\n tariff: string;\n municipality: string;\n address: string;\n postcode: string;\n meter_type: string;\n meter_remote_configurable: boolean;\n existing_pv_rooftop: boolean;\n retailer_id: string;\n retailer_name: string;\n retailer_email: string;\n};\n\n// Seed blob if empty\nasync function getSIPSRecords(): Promise {\n const raw = await blob.getJSON(KEY);\n if (!Array.isArray(raw) || raw.length === 0) {\n await blob.setJSON(KEY, SEED_RECORDS);\n return SEED_RECORDS;\n }\n return raw as SIPSRecord[];\n}\n\nexport default async function handler(req: Request) {\n const url = new URL(req.url);\n const path = url.pathname;\n\n // ─────────────────────────────────────────\n // GET /sips/lookup?cups=ES...\n // Returns full record if found, or INEXISTENT\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/sips/lookup\")) {\n const cups = url.searchParams.get(\"cups\");\n\n if (!cups) {\n return json({ error: \"Missing required parameter: cups\" }, 400);\n }\n\n const records = await getSIPSRecords();\n const record = records.find((r) => r.cups === cups);\n\n if (!record) {\n return json({\n status: \"INEXISTENT\",\n cups,\n message: \"CUPS not found in SIPS database\",\n }, 200);\n }\n\n return json({\n status: \"EXISTS\",\n cups,\n record,\n }, 200);\n }\n\n // ─────────────────────────────────────────\n // GET /sips/match?cups=ES...&holder_id=B...\n // Checks if CUPS and Holder ID are registered together\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/sips/match\")) {\n const cups = url.searchParams.get(\"cups\");\n const holder_id = url.searchParams.get(\"holder_id\");\n\n if (!cups || !holder_id) {\n return json(\n { error: \"Missing required parameters: cups, holder_id\" },\n 400,\n );\n }\n\n const records = await getSIPSRecords();\n const record = records.find((r) => r.cups === cups);\n\n if (!record) {\n return json({\n status: \"INEXISTENT\",\n cups,\n message: \"CUPS not found in SIPS database\",\n }, 200);\n }\n\n const match = record.holder_id === holder_id;\n\n return json({\n status: match ? \"MATCH\" : \"MISMATCH\",\n cups,\n holder_id_submitted: holder_id,\n holder_id_registered: record.holder_id,\n message: match\n ? \"CUPS and Holder ID match in SIPS\"\n : `Holder ID mismatch: submitted ${holder_id}, registered ${record.holder_id}`,\n }, 200);\n }\n\n // ─────────────────────────────────────────\n // GET /sips/status?cups=ES...\n // Returns connection point status and whether PV attributes can be added\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/sips/status\")) {\n const cups = url.searchParams.get(\"cups\");\n\n if (!cups) {\n return json({ error: \"Missing required parameter: cups\" }, 400);\n }\n\n const records = await getSIPSRecords();\n const record = records.find((r) => r.cups === cups);\n\n if (!record) {\n return json({\n status: \"INEXISTENT\",\n cups,\n message: \"CUPS not found in SIPS database\",\n }, 200);\n }\n\n return json({\n status: \"EXISTS\",\n cups,\n connection_point_status: record.connection_point_status,\n pv_rooftop_attributes_allowed: record.pv_rooftop_attributes_allowed,\n existing_pv_rooftop: record.existing_pv_rooftop,\n meter_type: record.meter_type,\n contracted_capacity_kw: record.contracted_capacity_kw,\n meter_remote_configurable: record.meter_remote_configurable,\n message: record.pv_rooftop_attributes_allowed\n ? \"Connection point is active and allows PV rooftop attributes\"\n : \"Connection point does not allow PV rooftop attributes to be added\",\n }, 200);\n }\n\n // ─────────────────────────────────────────\n // POST /sips/update — write activation data back to SIPS\n // Called at Stage 7 after analyst approval\n // ─────────────────────────────────────────\n if (req.method === \"POST\" && path.endsWith(\"/sips/update\")) {\n try {\n const body = await req.json();\n const { cups, ...updates } = body;\n\n if (!cups) {\n return json({ error: \"Missing required field: cups\" }, 400);\n }\n\n const records = await getSIPSRecords();\n const index = records.findIndex((r) => r.cups === cups);\n\n if (index === -1) {\n return json({\n status: \"INEXISTENT\",\n cups,\n message: \"CUPS not found — cannot update\",\n }, 404);\n }\n\n records[index] = { ...records[index], ...updates };\n await blob.setJSON(KEY, records);\n\n return json({\n status: \"UPDATED\",\n cups,\n updatedFields: Object.keys(updates),\n record: records[index],\n }, 200);\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // ─────────────────────────────────────────\n // GET /sips/all — return all records (debug/admin)\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/sips/all\")) {\n const records = await getSIPSRecords();\n return json({ count: records.length, records }, 200);\n }\n\n // ─────────────────────────────────────────\n // GET / — return all records (base domain)\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && (path === \"/\" || path === \"\")) {\n const records = await getSIPSRecords();\n return json({ count: records.length, records }, 200);\n }\n\n // ─────────────────────────────────────────\n // DELETE /sips/reset — reset to seed data\n // ─────────────────────────────────────────\n if (req.method === \"DELETE\" && path.endsWith(\"/sips/reset\")) {\n await blob.setJSON(KEY, SEED_RECORDS);\n return json({ status: \"reset\", count: SEED_RECORDS.length }, 200);\n }\n\n return new Response(\"Not Found\", { status: 404 });\n}\n\n// ─────────────────────────────────────────\n// Helper\n// ─────────────────────────────────────────\nfunction json(data: unknown, status = 200): Response {\n return new Response(JSON.stringify(data), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}",[166],"c1d584a0-17bb-11f1-a376-42dde27851f2","B2C-app-status.ts","75604baa-13e7-11f1-9fa7-42dde27851f2",50,["D",1772623060335],7,"// @valtown/http\n// B2CFlow Application State Store\n// Tracks application lifecycle stage by stage for real-time UI polling\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst KEY = \"b2cflow_applications\";\n\ntype Stage = {\n stage_number: number;\n stage_name?: string;\n status: \"pending\" | \"in_progress\" | \"completed\" | \"failed\";\n started_at?: string;\n completed_at?: string;\n data: Record | String;\n};\n\ntype Application = {\n application_id: string;\n current_stage: number;\n overall_status:\n | \"submitted\"\n | \"validating\"\n | \"awaiting_info\"\n | \"awaiting_decision\"\n | \"accepted\"\n | \"rejected\"\n | \"activating\"\n | \"activated\"\n | \"closed\";\n created_at: string;\n updated_at: string;\n stages: Stage[];\n};\n\nasync function getApplications(): Promise {\n const raw = await blob.getJSON(KEY);\n return Array.isArray(raw) ? raw : [];\n}\n\nasync function saveApplications(apps: Application[]): Promise {\n await blob.setJSON(KEY, apps);\n}\n\nexport default async function handler(req: Request) {\n const url = new URL(req.url);\n const path = url.pathname;\n\n // ─────────────────────────────────────────\n // GET / — list all applications\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && (path === \"/\" || path === \"\")) {\n const apps = await getApplications();\n return json({ count: apps.length, applications: apps });\n }\n\n // ─────────────────────────────────────────\n // GET /:application_id — get single application\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.split(\"/\").length === 2) {\n const application_id = path.split(\"/\")[1];\n const apps = await getApplications();\n const app = apps.find((a) => a.application_id === application_id);\n\n if (!app) {\n return json({ error: \"Application not found\", application_id }, 404);\n }\n\n return json(app);\n }\n\n // ─────────────────────────────────────────\n // POST / — create new application\n // Body: { application_id, ...any initial fields }\n // ─────────────────────────────────────────\n if (req.method === \"POST\" && (path === \"/\" || path === \"\")) {\n try {\n const body = await req.json();\n\n if (!body.application_id) {\n return json({ error: \"Missing required field: application_id\" }, 400);\n }\n\n const apps = await getApplications();\n const exists = apps.find((a) => a.application_id === body.application_id);\n\n if (exists) {\n return json({\n error: \"Application already exists\",\n application_id: body.application_id,\n }, 409);\n }\n\n const newApp: Application = {\n application_id: body.application_id,\n current_stage: 1,\n overall_status: \"submitted\",\n created_at: new Date().toISOString(),\n updated_at: new Date().toISOString(),\n stages: [\n {\n stage_number: 1,\n stage_name: \"Form Submission\",\n status: \"completed\",\n started_at: new Date().toISOString(),\n completed_at: new Date().toISOString(),\n data: body,\n },\n ],\n };\n\n apps.push(newApp);\n await saveApplications(apps);\n\n return json({ status: \"created\", application: newApp }, 201);\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // ─────────────────────────────────────────\n // PATCH /:application_id/stage — add or update a stage\n // Body: { stage_number, stage_name?, status, data }\n // ─────────────────────────────────────────\n if (req.method === \"PATCH\" && path.endsWith(\"/stage\")) {\n try {\n const application_id = path.split(\"/\")[1];\n const body = await req.json();\n\n if (!body.stage_number || !body.status || !body.data) {\n return json({\n error: \"Missing required fields: stage_number, status, data\",\n }, 400);\n }\n\n const apps = await getApplications();\n const index = apps.findIndex((a) => a.application_id === application_id);\n\n if (index === -1) {\n return json({ error: \"Application not found\", application_id }, 404);\n }\n\n const app = apps[index];\n const stageIndex = app.stages.findIndex((s) =>\n s.stage_number === body.stage_number\n );\n\n const updatedStage: Stage = {\n stage_number: body.stage_number,\n stage_name: body.stage_name,\n status: body.status,\n started_at: body.status === \"in_progress\"\n ? new Date().toISOString()\n : app.stages[stageIndex]?.started_at,\n completed_at: body.status === \"completed\" || body.status === \"failed\"\n ? new Date().toISOString()\n : undefined,\n data: body.data,\n };\n\n if (stageIndex === -1) {\n // New stage — push\n app.stages.push(updatedStage);\n } else {\n // Existing stage — merge data, update status\n app.stages[stageIndex] = {\n ...app.stages[stageIndex],\n ...updatedStage,\n data: {\n ...app.stages[stageIndex].data,\n ...body.data,\n },\n };\n }\n\n // Update top-level current_stage and overall_status\n app.current_stage = body.stage_number;\n if (body.overall_status) {\n app.overall_status = body.overall_status;\n }\n app.updated_at = new Date().toISOString();\n\n apps[index] = app;\n await saveApplications(apps);\n\n return json({ status: \"updated\", application: app });\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // ─────────────────────────────────────────\n // PATCH /:application_id — update top-level fields only\n // Body: { overall_status?, current_stage?, ...any top level fields }\n // ─────────────────────────────────────────\n if (req.method === \"PATCH\" && path.split(\"/\").length === 2) {\n try {\n const application_id = path.split(\"/\")[1];\n const body = await req.json();\n\n const apps = await getApplications();\n const index = apps.findIndex((a) => a.application_id === application_id);\n\n if (index === -1) {\n return json({ error: \"Application not found\", application_id }, 404);\n }\n\n apps[index] = {\n ...apps[index],\n ...body,\n application_id: apps[index].application_id, // prevent overwrite\n stages: apps[index].stages, // prevent overwrite\n created_at: apps[index].created_at, // prevent overwrite\n updated_at: new Date().toISOString(),\n };\n\n await saveApplications(apps);\n\n return json({ status: \"updated\", application: apps[index] });\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // ─────────────────────────────────────────\n // DELETE / — clear all applications\n // ─────────────────────────────────────────\n if (req.method === \"DELETE\" && (path === \"/\" || path === \"\")) {\n await saveApplications([]);\n return json({ status: \"cleared\" });\n }\n\n // ─────────────────────────────────────────\n // DELETE /:application_id — delete single application\n // ─────────────────────────────────────────\n if (req.method === \"DELETE\" && path.split(\"/\").length === 2) {\n const application_id = path.split(\"/\")[1];\n const apps = await getApplications();\n const filtered = apps.filter((a) => a.application_id !== application_id);\n\n if (filtered.length === apps.length) {\n return json({ error: \"Application not found\", application_id }, 404);\n }\n\n await saveApplications(filtered);\n return json({ status: \"deleted\", application_id });\n }\n\n return new Response(\"Not Found\", { status: 404 });\n}\n\nfunction json(data: unknown, status = 200): Response {\n return new Response(JSON.stringify(data, null, 2), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}",[174],"pulls","branches",1,"forks","envVars",{"_189":60,"_191":60},"connections",{"_189":60,"_190":60},"count","unfilledCount","emptyCount",{"_43":173,"_32":174,"_30":175,"_137":-5,"_41":42,"_40":176,"_139":123,"_38":214,"_13":178,"_33":37,"_35":179,"_24":25,"_143":-5,"_199":215,"_27":216},{"_43":165,"_32":166,"_30":167,"_137":-5,"_41":42,"_40":168,"_139":123,"_38":211,"_13":170,"_33":37,"_35":171,"_24":25,"_143":-5,"_199":212,"_27":213},{"_43":161,"_32":28,"_30":31,"_137":-5,"_41":42,"_40":14,"_139":25,"_38":208,"_13":163,"_33":37,"_35":36,"_24":25,"_143":-5,"_199":209,"_27":210},{"_43":153,"_32":154,"_30":155,"_137":-5,"_41":42,"_40":156,"_139":123,"_38":205,"_13":158,"_33":37,"_35":159,"_24":25,"_143":-5,"_199":206,"_27":207},{"_43":145,"_32":146,"_30":147,"_137":-5,"_41":42,"_40":148,"_139":123,"_38":202,"_13":150,"_33":37,"_35":151,"_24":25,"_143":-5,"_199":203,"_27":204},{"_43":134,"_32":135,"_30":136,"_137":-5,"_41":42,"_40":138,"_139":123,"_38":198,"_13":141,"_33":37,"_35":142,"_24":25,"_143":-5,"_199":200,"_27":201},["D",1769064284722],"children",[],[135],["D",1770584725716],[],[146],["D",1770567411504],[],[154],["D",1774016763436],[],[28],["D",1772616257849],[],[166],["D",1772623060335],[],[174],["D",1769055870320],["D",1789542098478],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_125":255,"_256":257,"_258":259,"_260":25,"_261":25,"_262":25,"_263":123,"_264":-5,"_265":-7,"_266":-7,"_267":60,"_268":25,"_269":25,"_270":-5,"_271":25,"_272":25,"_273":25,"_274":-5},"ENV",{"_226":227,"_228":229,"_230":87,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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"]

Diff · v54