[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_214":215,"_216":217},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_102":84,"_27":103,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":120,"_121":-5,"_122":-5,"_123":124},"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":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",36,"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","registryServer.ts","latestPath","fileId","d2d24ba8-18ba-11f1-84fb-42dde27851f2","name","fileType","http","content","// @valtown/http\n// Val Server 1 — Registry (SIPS + CAU)\n// Lumina Energia Demo | Customer: Carlos Garcia Martinez\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst SIPS_KEY = \"retailflow_sips_records\";\nconst CAU_KEY = \"retailflow_cau_records\";\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_no: string;\n meter_remote_configurable: boolean;\n existing_pv_rooftop: boolean;\n retailer_id: string;\n retailer_name: string;\n retailer_email: string;\n distributor: string;\n distribution_zone: string;\n cnmc_license: string;\n};\n\ntype CAURecord = {\n cau: string;\n cups: string;\n holder_id: string;\n generation_technology: string;\n installed_capacity_kw: number;\n modality: string;\n issued_at: string;\n valid_until: string;\n status: string;\n};\n\n// ─────────────────────────────────────────\n// SEED DATA\n// Correct CUPS: ES0031406000045001JN0F (from bill)\n// Wrong CUPS submitted by customer: ES0031406000045001JN0G (last char G vs F)\n// ─────────────────────────────────────────\nconst SEED_SIPS: SIPSRecord[] = [\n {\n cups: \"ES0031406000045001JN0F\",\n holder_id: \"52847163K\",\n holder_name: \"Carlos Garcia Martinez\",\n connection_point_status: \"active\",\n pv_rooftop_attributes_allowed: true,\n contracted_capacity_kw: 3.45,\n supply_voltage: \"230 V AC, Single Phase\",\n supply_frequency: \"50 Hz\",\n tariff: \"2.0TD\",\n municipality: \"Madrid\",\n address: \"Calle Gran Via, 32, 4B\",\n postcode: \"28013\",\n meter_type: \"bidirectional_smart\",\n meter_no: \"MTR-20250100347\",\n meter_remote_configurable: true,\n existing_pv_rooftop: false,\n retailer_id: \"RET-00471\",\n retailer_name: \"Lumina Energia S.A.\",\n retailer_email: \"facturacion@luminaenergia.es\",\n distributor: \"Iberdrola Distribucion Electrica S.A.U.\",\n distribution_zone: \"Zone 3 - Madrid Metropolitan Area\",\n cnmc_license: \"COR-2018-00471\",\n },\n // ES0031406000045001JN0G (wrong CUPS) intentionally NOT in list → INEXISTENT\n];\n\nconst SEED_CAU: CAURecord[] = [\n {\n cau: \"CAU-2024-00142\",\n cups: \"ES0031406000045001JN0F\",\n holder_id: \"52847163K\",\n generation_technology: \"Photovoltaic\",\n installed_capacity_kw: 3.0,\n modality: \"SinCompensacion\",\n issued_at: \"2024-06-01\",\n valid_until: \"2034-06-01\",\n status: \"active\",\n },\n];\n\nasync function getSIPS(): Promise {\n const raw = await blob.getJSON(SIPS_KEY);\n return Array.isArray(raw) && raw.length > 0 ? raw : SEED_SIPS;\n}\n\nasync function getCAU(): Promise {\n const raw = await blob.getJSON(CAU_KEY);\n return Array.isArray(raw) && raw.length > 0 ? raw : SEED_CAU;\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 SIPS records\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && (path === \"/\" || path === \"\")) {\n const records = await getSIPS();\n return json({ count: records.length, records });\n }\n\n // ─────────────────────────────────────────\n // GET /sips/lookup?cups=\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/sips/lookup\")) {\n const cups = url.searchParams.get(\"cups\");\n if (!cups) return json({ error: \"Missing required parameter: cups\" }, 400);\n\n const records = await getSIPS();\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 });\n }\n return json({ status: \"EXISTS\", cups, record });\n }\n\n // ─────────────────────────────────────────\n // GET /sips/match?cups=&holder_id=\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 if (!cups || !holder_id) {\n return json(\n { error: \"Missing required parameters: cups, holder_id\" },\n 400,\n );\n }\n\n const records = await getSIPS();\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 });\n }\n\n const match = record.holder_id === holder_id;\n return json({\n status: match ? \"MATCH\" : \"MISMATCH\",\n cups,\n holder_id_submitted: holder_id,\n holder_id_registered: record.holder_id,\n });\n }\n\n // ─────────────────────────────────────────\n // GET /sips/status?cups=\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/sips/status\")) {\n const cups = url.searchParams.get(\"cups\");\n if (!cups) return json({ error: \"Missing required parameter: cups\" }, 400);\n\n const records = await getSIPS();\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 });\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 meter_remote_configurable: record.meter_remote_configurable,\n });\n }\n\n // ─────────────────────────────────────────\n // POST /sips/update — write activation data\n // ─────────────────────────────────────────\n if (req.method === \"POST\" && path.endsWith(\"/sips/update\")) {\n try {\n const body = await req.json();\n const { cups, ...updates } = body;\n if (!cups) return json({ error: \"Missing required field: cups\" }, 400);\n\n const records = await getSIPS();\n const index = records.findIndex((r) => r.cups === cups);\n if (index === -1) return json({ status: \"INEXISTENT\", cups }, 404);\n\n records[index] = { ...records[index], ...updates };\n await blob.setJSON(SIPS_KEY, records);\n return json({\n status: \"UPDATED\",\n cups,\n updatedFields: Object.keys(updates),\n record: records[index],\n });\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // ─────────────────────────────────────────\n // GET /cau/lookup?cau= OR ?cups=\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/cau/lookup\")) {\n const cau = url.searchParams.get(\"cau\");\n const cups = url.searchParams.get(\"cups\");\n if (!cau && !cups) {\n return json({ error: \"Missing required parameter: cau or cups\" }, 400);\n }\n\n const records = await getCAU();\n const record = cau\n ? records.find((r) => r.cau === cau)\n : records.find((r) => r.cups === cups);\n\n if (!record) {\n return json({ status: \"INEXISTENT\", message: \"CAU record not found\" });\n }\n return json({ status: \"EXISTS\", record });\n }\n\n // ─────────────────────────────────────────\n // POST /cau/issue — register new CAU\n // ─────────────────────────────────────────\n if (req.method === \"POST\" && path.endsWith(\"/cau/issue\")) {\n try {\n const body = await req.json();\n const records = await getCAU();\n records.push({ ...body, issued_at: new Date().toISOString() });\n await blob.setJSON(CAU_KEY, records);\n return json({ status: \"ISSUED\", record: body }, 201);\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // ─────────────────────────────────────────\n // DELETE /sips/reset\n // ─────────────────────────────────────────\n if (req.method === \"DELETE\" && path.endsWith(\"/sips/reset\")) {\n await blob.setJSON(SIPS_KEY, SEED_SIPS);\n return json({ status: \"reset\", count: SEED_SIPS.length });\n }\n\n // ─────────────────────────────────────────\n // DELETE /cau/reset\n // ─────────────────────────────────────────\n if (req.method === \"DELETE\" && path.endsWith(\"/cau/reset\")) {\n await blob.setJSON(CAU_KEY, SEED_CAU);\n return json({ status: \"reset\", count: SEED_CAU.length });\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}","// @valtown/http\n// Val Server 1 — Registry (SIPS + CAU)\n// Lumina Energia Demo | Customer: Carlos Garcia Martinez\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst SIPS_KEY = \"retailflow_sips_records\";\nconst CAU_KEY = \"retailflow_cau_records\";\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_no: string;\n meter_remote_configurable: boolean;\n existing_pv_rooftop: boolean;\n retailer_id: string;\n retailer_name: string;\n retailer_email: string;\n distributor: string;\n distribution_zone: string;\n cnmc_license: string;\n};\n\ntype CAURecord = {\n cau: string;\n cups: string;\n holder_id: string;\n generation_technology: string;\n installed_capacity_kw: number;\n modality: string;\n issued_at: string;\n valid_until: string;\n status: string;\n};\n\n// ─────────────────────────────────────────\n// SEED DATA\n// Correct CUPS: ES0031406000045001JN0F (from bill)\n// Wrong CUPS submitted by customer: ES0031406000045001JN0G (last char G vs F)\n// ─────────────────────────────────────────\nconst SEED_SIPS: SIPSRecord[] = [\n {\n cups: \"ES0031406000045001JN0F\",\n holder_id: \"52847163V\",\n holder_name: \"Carlos Garcia Martinez\",\n connection_point_status: \"active\",\n pv_rooftop_attributes_allowed: true,\n contracted_capacity_kw: 3.45,\n supply_voltage: \"230 V AC, Single Phase\",\n supply_frequency: \"50 Hz\",\n tariff: \"2.0TD\",\n municipality: \"Madrid\",\n address: \"Calle Gran Via, 32, 4B\",\n postcode: \"28013\",\n meter_type: \"bidirectional_smart\",\n meter_no: \"MTR-20250100347\",\n meter_remote_configurable: true,\n existing_pv_rooftop: false,\n retailer_id: \"RET-00471\",\n retailer_name: \"Lumina Energia S.A.\",\n retailer_email: \"facturacion@luminaenergia.es\",\n distributor: \"Iberdrola Distribucion Electrica S.A.U.\",\n distribution_zone: \"Zone 3 - Madrid Metropolitan Area\",\n cnmc_license: \"COR-2018-00471\",\n },\n // ES0031406000045001JN0G (wrong CUPS) intentionally NOT in list → INEXISTENT\n];\n\nconst SEED_CAU: CAURecord[] = [\n {\n cau: \"CAU-2024-00142\",\n cups: \"ES0031406000045001JN0F\",\n holder_id: \"52847163K\",\n generation_technology: \"Photovoltaic\",\n installed_capacity_kw: 3.0,\n modality: \"SinCompensacion\",\n issued_at: \"2024-06-01\",\n valid_until: \"2034-06-01\",\n status: \"active\",\n },\n];\n\nasync function getSIPS(): Promise {\n const raw = await blob.getJSON(SIPS_KEY);\n return Array.isArray(raw) && raw.length > 0 ? raw : SEED_SIPS;\n}\n\nasync function getCAU(): Promise {\n const raw = await blob.getJSON(CAU_KEY);\n return Array.isArray(raw) && raw.length > 0 ? raw : SEED_CAU;\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 SIPS records\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && (path === \"/\" || path === \"\")) {\n const records = await getSIPS();\n return json({ count: records.length, records });\n }\n\n // ─────────────────────────────────────────\n // GET /sips/lookup?cups=\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/sips/lookup\")) {\n const cups = url.searchParams.get(\"cups\");\n if (!cups) return json({ error: \"Missing required parameter: cups\" }, 400);\n\n const records = await getSIPS();\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 });\n }\n return json({ status: \"EXISTS\", cups, record });\n }\n\n // ─────────────────────────────────────────\n // GET /sips/match?cups=&holder_id=\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 if (!cups || !holder_id) {\n return json(\n { error: \"Missing required parameters: cups, holder_id\" },\n 400,\n );\n }\n\n const records = await getSIPS();\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 });\n }\n\n const match = record.holder_id === holder_id;\n return json({\n status: match ? \"MATCH\" : \"MISMATCH\",\n cups,\n holder_id_submitted: holder_id,\n holder_id_registered: record.holder_id,\n });\n }\n\n // ─────────────────────────────────────────\n // GET /sips/status?cups=\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/sips/status\")) {\n const cups = url.searchParams.get(\"cups\");\n if (!cups) return json({ error: \"Missing required parameter: cups\" }, 400);\n\n const records = await getSIPS();\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 });\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 meter_remote_configurable: record.meter_remote_configurable,\n });\n }\n\n // ─────────────────────────────────────────\n // POST /sips/update — write activation data\n // ─────────────────────────────────────────\n if (req.method === \"POST\" && path.endsWith(\"/sips/update\")) {\n try {\n const body = await req.json();\n const { cups, ...updates } = body;\n if (!cups) return json({ error: \"Missing required field: cups\" }, 400);\n\n const records = await getSIPS();\n const index = records.findIndex((r) => r.cups === cups);\n if (index === -1) return json({ status: \"INEXISTENT\", cups }, 404);\n\n records[index] = { ...records[index], ...updates };\n await blob.setJSON(SIPS_KEY, records);\n return json({\n status: \"UPDATED\",\n cups,\n updatedFields: Object.keys(updates),\n record: records[index],\n });\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // ─────────────────────────────────────────\n // GET /cau/lookup?cau= OR ?cups=\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/cau/lookup\")) {\n const cau = url.searchParams.get(\"cau\");\n const cups = url.searchParams.get(\"cups\");\n if (!cau && !cups) {\n return json({ error: \"Missing required parameter: cau or cups\" }, 400);\n }\n\n const records = await getCAU();\n const record = cau\n ? records.find((r) => r.cau === cau)\n : records.find((r) => r.cups === cups);\n\n if (!record) {\n return json({ status: \"INEXISTENT\", message: \"CAU record not found\" });\n }\n return json({ status: \"EXISTS\", record });\n }\n\n // ─────────────────────────────────────────\n // POST /cau/issue — register new CAU\n // ─────────────────────────────────────────\n if (req.method === \"POST\" && path.endsWith(\"/cau/issue\")) {\n try {\n const body = await req.json();\n const records = await getCAU();\n records.push({ ...body, issued_at: new Date().toISOString() });\n await blob.setJSON(CAU_KEY, records);\n return json({ status: \"ISSUED\", record: body }, 201);\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // ─────────────────────────────────────────\n // DELETE /sips/reset\n // ─────────────────────────────────────────\n if (req.method === \"DELETE\" && path.endsWith(\"/sips/reset\")) {\n await blob.setJSON(SIPS_KEY, SEED_SIPS);\n return json({ status: \"reset\", count: SEED_SIPS.length });\n }\n\n // ─────────────────────────────────────────\n // DELETE /cau/reset\n // ─────────────────────────────────────────\n if (req.method === \"DELETE\" && path.endsWith(\"/cau/reset\")) {\n await blob.setJSON(CAU_KEY, SEED_CAU);\n return json({ status: \"reset\", count: SEED_CAU.length });\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}","createdAt",["D",1772877546734],"branchVersion","branchId","c937468e-18ba-11f1-84fb-42dde27851f2","id","c936de06-18ba-11f1-84fb-42dde27851f2","RetailFlow",["D",1772732594353],"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","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_101":97},"org",{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned",50,"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":210,"_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":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":211,"_78":212,"_80":213,"_82":25},"tree",[185,186,187,188,189,190],"files",[185,186,187,188,189,190],"counts",{"_174":60,"_175":176,"_177":60,"_178":179,"_180":181},"contents",[125,126,127,128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":167,"_32":168,"_30":169,"_134":-5,"_41":42,"_40":170,"_136":120,"_38":171,"_13":147,"_33":34,"_35":172,"_24":25,"_140":-5,"_27":173},{"_43":160,"_32":161,"_30":162,"_134":-5,"_41":42,"_40":163,"_136":120,"_38":164,"_13":147,"_33":34,"_35":165,"_24":25,"_140":-5,"_27":166},{"_43":153,"_32":154,"_30":155,"_134":-5,"_41":42,"_40":156,"_136":120,"_38":157,"_13":147,"_33":34,"_35":158,"_24":25,"_140":-5,"_27":159},{"_43":150,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_136":120,"_38":151,"_13":138,"_33":34,"_35":37,"_24":25,"_140":-5,"_27":152},{"_43":142,"_32":143,"_30":144,"_134":-5,"_41":42,"_40":145,"_136":120,"_38":146,"_13":147,"_33":34,"_35":148,"_24":25,"_140":-5,"_27":149},{"_43":131,"_32":132,"_30":133,"_134":-5,"_41":42,"_40":135,"_136":25,"_38":137,"_13":138,"_33":34,"_35":139,"_24":25,"_140":-5,"_27":141},"d8dcb144-18df-11f1-b96f-42dde27851f2","wfStatus.ts","024a6c80-18bb-11f1-84fb-42dde27851f2","parentId",35,"latest",["D",1772748512003],6,"// @valtown/http\n// Val Server 2 — Application State Store\n// Lumina Energia Demo | Tracks full application lifecycle stage by stage\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst KEY = \"lumina_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: any;\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 const parts = path.split(\"/\").filter(Boolean);\n\n // ─────────────────────────────────────────\n // GET / — list all applications\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && parts.length === 0) {\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\" && parts.length === 1) {\n const application_id = parts[0];\n const apps = await getApplications();\n const app = apps.find((a) => a.application_id === application_id);\n if (!app) {\n return json({ error: \"Application not found\", application_id }, 404);\n }\n return json(app);\n }\n\n // ─────────────────────────────────────────\n // POST / — create new application\n // ─────────────────────────────────────────\n if (req.method === \"POST\" && parts.length === 0) {\n try {\n const body = await req.json();\n if (!body.application_id) {\n return json({ error: \"Missing required field: application_id\" }, 400);\n }\n\n const apps = await getApplications();\n if (apps.find((a) => a.application_id === body.application_id)) {\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 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, overall_status? }\n // ─────────────────────────────────────────\n if (req.method === \"PATCH\" && parts.length === 2 && parts[1] === \"stage\") {\n try {\n const application_id = parts[0];\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 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 app.stages.push(updatedStage);\n } else {\n app.stages[stageIndex] = {\n ...app.stages[stageIndex],\n ...updatedStage,\n data: { ...app.stages[stageIndex].data, ...body.data },\n };\n }\n\n app.current_stage = body.stage_number;\n if (body.overall_status) app.overall_status = body.overall_status;\n app.updated_at = new Date().toISOString();\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 // ─────────────────────────────────────────\n if (req.method === \"PATCH\" && parts.length === 1) {\n try {\n const application_id = parts[0];\n const body = await req.json();\n\n const apps = await getApplications();\n const index = apps.findIndex((a) => a.application_id === application_id);\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,\n stages: apps[index].stages,\n created_at: apps[index].created_at,\n updated_at: new Date().toISOString(),\n };\n\n await saveApplications(apps);\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 /:application_id — delete single\n // ─────────────────────────────────────────\n if (req.method === \"DELETE\" && parts.length === 1) {\n const application_id = parts[0];\n const apps = await getApplications();\n const filtered = apps.filter((a) => a.application_id !== application_id);\n if (filtered.length === apps.length) {\n return json({ error: \"Application not found\" }, 404);\n }\n await saveApplications(filtered);\n return json({ status: \"deleted\", application_id });\n }\n\n // ─────────────────────────────────────────\n // DELETE / — clear all\n // ─────────────────────────────────────────\n if (req.method === \"DELETE\" && parts.length === 0) {\n await saveApplications([]);\n return json({ status: \"cleared\" });\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}","label",[132],"4073ef7c-18bb-11f1-b406-42dde27851f2","validationServer.ts","31ef94ec-18bb-11f1-87b8-42dde27851f2",22,["D",1772732794437],4,"// @valtown/http\n// Val Server 4 — Validation (DNI/NIE/Passport + SEPA/IBAN)\n// Lumina Energia Demo | Stateless — no blob storage\n\nexport default async function handler(req: Request) {\n const url = new URL(req.url);\n const path = url.pathname;\n\n // ─────────────────────────────────────────\n // GET / — service info\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && (path === \"/\" || path === \"\")) {\n return json({\n service: \"Lumina Energia — Validation Service\",\n endpoints: [\n \"GET /dni/validate?id=52847163K\",\n \"GET /sepa/validate?iban=ES9121000418450200051332\",\n ],\n });\n }\n\n // ─────────────────────────────────────────\n // GET /dni/validate?id=52847163K\n // Validates Spanish DNI, NIE or Passport\n // Demo: 52847163K → VALID DNI\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/dni/validate\")) {\n const raw = url.searchParams.get(\"id\");\n if (!raw) return json({ error: \"Missing required parameter: id\" }, 400);\n\n const id = raw.toUpperCase().trim();\n const type = detectIDType(id);\n\n if (type === \"UNKNOWN\") {\n return json({\n status: \"INVALID\",\n id,\n type: \"UNKNOWN\",\n reason: \"Format not recognised as DNI, NIE or Passport\",\n });\n }\n\n const valid = type === \"DNI\"\n ? validateDNI(id)\n : type === \"NIE\"\n ? validateNIE(id)\n : validatePassport(id);\n\n return json({\n status: valid ? \"VALID\" : \"INVALID\",\n id,\n type,\n reason: valid\n ? `${type} format and checksum verified`\n : `${type} checksum failed — control letter does not match number sequence`,\n });\n }\n\n // ─────────────────────────────────────────\n // GET /sepa/validate?iban=ES9121000418450200051332\n // Validates IBAN checksum (MOD97) + SEPA country\n // Demo: ES9121000418450200051332 → VALID\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/sepa/validate\")) {\n const raw = url.searchParams.get(\"iban\");\n if (!raw) return json({ error: \"Missing required parameter: iban\" }, 400);\n\n const iban = raw.replace(/\\s+/g, \"\").toUpperCase();\n const country = iban.slice(0, 2);\n const lengthValid = validateIBANLength(iban);\n const checksumValid = validateMOD97(iban);\n const sepaCountry = isSepaCountry(country);\n const valid = lengthValid && checksumValid && sepaCountry;\n\n return json({\n status: valid ? \"VALID\" : \"INVALID\",\n iban,\n masked: maskIBAN(iban),\n country,\n sepa_country: sepaCountry,\n length_valid: lengthValid,\n checksum_valid: checksumValid,\n reason: !sepaCountry\n ? `Country ${country} is not in the SEPA zone`\n : !lengthValid\n ? `IBAN length invalid for country ${country}`\n : !checksumValid\n ? \"MOD97 checksum failed — IBAN number is incorrect\"\n : \"IBAN is valid and SEPA-compliant\",\n });\n }\n\n return new Response(\"Not Found\", { status: 404 });\n}\n\n// ─────────────────────────────────────────\n// DNI / NIE Helpers\n// ─────────────────────────────────────────\nconst DNI_LETTERS = \"TRWAGMYFPDXBNJZSQVHLCKE\";\n\nfunction detectIDType(id: string): \"DNI\" | \"NIE\" | \"PASSPORT\" | \"UNKNOWN\" {\n if (/^\\d{8}[A-Z]$/.test(id)) return \"DNI\";\n if (/^[XYZ]\\d{7}[A-Z]$/.test(id)) return \"NIE\";\n if (/^[A-Z]{3}\\d{6}[A-Z]?$/.test(id)) return \"PASSPORT\";\n return \"UNKNOWN\";\n}\n\nfunction validateDNI(dni: string): boolean {\n const number = parseInt(dni.slice(0, 8), 10);\n const letter = dni.slice(-1);\n return DNI_LETTERS[number % 23] === letter;\n}\n\nfunction validateNIE(nie: string): boolean {\n const prefixMap: Record = { X: \"0\", Y: \"1\", Z: \"2\" };\n const normalized = prefixMap[nie[0]] + nie.slice(1, -1);\n const number = parseInt(normalized, 10);\n const letter = nie.slice(-1);\n return DNI_LETTERS[number % 23] === letter;\n}\n\nfunction validatePassport(passport: string): boolean {\n return /^[A-Z]{3}\\d{6}[A-Z]?$/.test(passport);\n}\n\n// ─────────────────────────────────────────\n// IBAN / SEPA Helpers\n// ─────────────────────────────────────────\nconst IBAN_LENGTHS: Record = {\n ES: 24,\n DE: 22,\n FR: 27,\n IT: 27,\n NL: 18,\n PT: 25,\n BE: 16,\n AT: 20,\n CH: 21,\n GB: 22,\n PL: 28,\n SE: 24,\n};\n\nconst SEPA_COUNTRIES = new Set([\n \"AT\",\n \"BE\",\n \"BG\",\n \"CH\",\n \"CY\",\n \"CZ\",\n \"DE\",\n \"DK\",\n \"EE\",\n \"ES\",\n \"FI\",\n \"FR\",\n \"GB\",\n \"GR\",\n \"HR\",\n \"HU\",\n \"IE\",\n \"IS\",\n \"IT\",\n \"LI\",\n \"LT\",\n \"LU\",\n \"LV\",\n \"MC\",\n \"MT\",\n \"NL\",\n \"NO\",\n \"PL\",\n \"PT\",\n \"RO\",\n \"SE\",\n \"SI\",\n \"SK\",\n \"SM\",\n \"VA\",\n]);\n\nfunction validateIBANLength(iban: string): boolean {\n const expected = IBAN_LENGTHS[iban.slice(0, 2)];\n return expected ? iban.length === expected : iban.length >= 15;\n}\n\nfunction validateMOD97(iban: string): boolean {\n const rearranged = iban.slice(4) + iban.slice(0, 4);\n const numeric = rearranged\n .split(\"\")\n .map((c) => {\n const code = c.charCodeAt(0);\n return code >= 65 ? (code - 55).toString() : c;\n })\n .join(\"\");\n\n let remainder = 0;\n for (const chunk of numeric.match(/.{1,9}/g) || []) {\n remainder = parseInt(`${remainder}${chunk}`, 10) % 97;\n }\n return remainder === 1;\n}\n\nfunction isSepaCountry(country: string): boolean {\n return SEPA_COUNTRIES.has(country);\n}\n\nfunction maskIBAN(iban: string): string {\n return iban.slice(0, 4) + \" **** **** \" + iban.slice(-4);\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}",[143],"478c0928-1a0c-11f1-8f29-42dde27851f2",["D",1772877546734],[28],"8157e3ea-18bb-11f1-a1e9-42dde27851f2","operations.ts","7a6f58f6-18bb-11f1-a785-42dde27851f2",27,["D",1772732903301],"// @valtown/http\n// Val Server 6 — Operations (Meter Activation + Field Scheduler + Case Management)\n// Lumina Energia Demo | Post-approval execution actions\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst METER_KEY = \"lumina_meter_activations\";\nconst SCHEDULER_KEY = \"lumina_field_jobs\";\nconst CASE_KEY = \"lumina_cases\";\n\ntype MeterActivation = {\n activation_id: string;\n application_id: string;\n cups: string;\n meter_no: string;\n activation_type: \"remote\" | \"onsite\";\n status: \"pending\" | \"in_progress\" | \"completed\" | \"failed\";\n requested_at: string;\n completed_at: string | null;\n effective_date: string | null;\n notes: string;\n};\n\ntype FieldJob = {\n job_id: string;\n application_id: string;\n cups: string;\n job_type: string;\n address: string;\n scheduled_date: string;\n technician: string | null;\n status: \"scheduled\" | \"in_progress\" | \"completed\" | \"cancelled\";\n created_at: string;\n completed_at: string | null;\n activities: { name: string; status: \"pending\" | \"completed\" }[];\n};\n\ntype Case = {\n case_id: string;\n application_id: string;\n cups: string;\n opened_at: string;\n closed_at: string | null;\n status: \"open\" | \"closed\";\n resolution: string | null;\n};\n\nasync function get(key: string): Promise {\n const raw = await blob.getJSON(key);\n return Array.isArray(raw) ? raw : [];\n}\n\nasync function save(key: string, data: T[]): Promise {\n await blob.setJSON(key, data);\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 / — service overview\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && (path === \"/\" || path === \"\")) {\n const meters = await get(METER_KEY);\n const jobs = await get(SCHEDULER_KEY);\n const cases = await get(CASE_KEY);\n return json({\n service: \"Lumina Energia — Operations Service\",\n counts: {\n meter_activations: meters.length,\n field_jobs: jobs.length,\n cases: cases.length,\n },\n });\n }\n\n // ═══════════════════════════════════════════\n // METER ACTIVATION\n // ═══════════════════════════════════════════\n\n // POST /meter/activate\n // Body: { application_id, cups, meter_no, activation_type, effective_date }\n if (req.method === \"POST\" && path.endsWith(\"/meter/activate\")) {\n try {\n const body = await req.json();\n const {\n application_id,\n cups,\n meter_no,\n activation_type,\n effective_date,\n } = body;\n\n if (!application_id || !cups || !activation_type) {\n return json({\n error:\n \"Missing required fields: application_id, cups, activation_type\",\n }, 400);\n }\n\n const records = await get(METER_KEY);\n const activation_id = `ACT-${application_id}-${Date.now()}`;\n\n const newRecord: MeterActivation = {\n activation_id,\n application_id,\n cups,\n meter_no: meter_no || \"MTR-20250100347\",\n activation_type,\n status: activation_type === \"remote\" ? \"completed\" : \"scheduled\",\n requested_at: new Date().toISOString(),\n completed_at: activation_type === \"remote\"\n ? new Date().toISOString()\n : null,\n effective_date: effective_date || null,\n notes: activation_type === \"remote\"\n ? \"Remote activation completed via smart meter\"\n : \"On-site activation — field job scheduled\",\n };\n\n records.push(newRecord);\n await save(METER_KEY, records);\n\n return json({ status: \"ACTIVATED\", activation: newRecord }, 201);\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // GET /meter/status?application_id=\n if (req.method === \"GET\" && path.endsWith(\"/meter/status\")) {\n const application_id = url.searchParams.get(\"application_id\");\n if (!application_id) {\n return json({ error: \"Missing required parameter: application_id\" }, 400);\n }\n\n const records = await get(METER_KEY);\n const record = records.find((r) => r.application_id === application_id);\n if (!record) return json({ status: \"NOT_FOUND\" }, 404);\n return json(record);\n }\n\n // ═══════════════════════════════════════════\n // FIELD SCHEDULER\n // ═══════════════════════════════════════════\n\n // POST /scheduler/create\n // Body: { application_id, cups, job_type, address, scheduled_date, activities[] }\n if (req.method === \"POST\" && path.endsWith(\"/scheduler/create\")) {\n try {\n const body = await req.json();\n const {\n application_id,\n cups,\n job_type,\n address,\n scheduled_date,\n activities,\n } = body;\n\n if (!application_id || !cups || !job_type || !scheduled_date) {\n return json({\n error:\n \"Missing required fields: application_id, cups, job_type, scheduled_date\",\n }, 400);\n }\n\n const jobs = await get(SCHEDULER_KEY);\n const job_id = `JOB-${application_id}-${Date.now()}`;\n\n const newJob: FieldJob = {\n job_id,\n application_id,\n cups,\n job_type,\n address: address || \"Calle Gran Via, 32, 4B, 28013 Madrid\",\n scheduled_date,\n technician: null,\n status: \"scheduled\",\n created_at: new Date().toISOString(),\n completed_at: null,\n activities: (activities || []).map((a: string) => ({\n name: a,\n status: \"pending\",\n })),\n };\n\n jobs.push(newJob);\n await save(SCHEDULER_KEY, jobs);\n\n return json({ status: \"SCHEDULED\", job: newJob }, 201);\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // PATCH /scheduler/update\n // Body: { job_id, status, technician?, completed_at?, activities? }\n if (req.method === \"PATCH\" && path.endsWith(\"/scheduler/update\")) {\n try {\n const body = await req.json();\n const { job_id, ...updates } = body;\n if (!job_id) {\n return json({ error: \"Missing required field: job_id\" }, 400);\n }\n\n const jobs = await get(SCHEDULER_KEY);\n const index = jobs.findIndex((j) => j.job_id === job_id);\n if (index === -1) return json({ error: \"Job not found\", job_id }, 404);\n\n jobs[index] = { ...jobs[index], ...updates };\n if (updates.status === \"completed\") {\n jobs[index].completed_at = new Date().toISOString();\n }\n\n await save(SCHEDULER_KEY, jobs);\n return json({ status: \"UPDATED\", job: jobs[index] });\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // GET /scheduler/status?application_id=\n if (req.method === \"GET\" && path.endsWith(\"/scheduler/status\")) {\n const application_id = url.searchParams.get(\"application_id\");\n if (!application_id) {\n return json({ error: \"Missing required parameter: application_id\" }, 400);\n }\n\n const jobs = await get(SCHEDULER_KEY);\n const job = jobs.find((j) => j.application_id === application_id);\n if (!job) return json({ status: \"NOT_FOUND\" }, 404);\n return json(job);\n }\n\n // ═══════════════════════════════════════════\n // CASE MANAGEMENT\n // ═══════════════════════════════════════════\n\n // POST /case/create\n // Body: { application_id, cups }\n if (req.method === \"POST\" && path.endsWith(\"/case/create\")) {\n try {\n const body = await req.json();\n const { application_id, cups } = body;\n if (!application_id || !cups) {\n return json(\n { error: \"Missing required fields: application_id, cups\" },\n 400,\n );\n }\n\n const cases = await get(CASE_KEY);\n const case_id = `CASE-${application_id}-${Date.now()}`;\n\n const newCase: Case = {\n case_id,\n application_id,\n cups,\n opened_at: new Date().toISOString(),\n closed_at: null,\n status: \"open\",\n resolution: null,\n };\n\n cases.push(newCase);\n await save(CASE_KEY, cases);\n\n return json({ status: \"CREATED\", case: newCase }, 201);\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // PATCH /case/close\n // Body: { application_id, resolution }\n if (req.method === \"PATCH\" && path.endsWith(\"/case/close\")) {\n try {\n const body = await req.json();\n const { application_id, resolution } = body;\n if (!application_id) {\n return json({ error: \"Missing required field: application_id\" }, 400);\n }\n\n const cases = await get(CASE_KEY);\n const index = cases.findIndex((c) => c.application_id === application_id);\n if (index === -1) {\n return json({ error: \"Case not found\", application_id }, 404);\n }\n\n cases[index].status = \"closed\";\n cases[index].closed_at = new Date().toISOString();\n cases[index].resolution = resolution || \"Resolved\";\n\n await save(CASE_KEY, cases);\n return json({ status: \"CLOSED\", case: cases[index] });\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // GET /case/status?application_id=\n if (req.method === \"GET\" && path.endsWith(\"/case/status\")) {\n const application_id = url.searchParams.get(\"application_id\");\n if (!application_id) {\n return json({ error: \"Missing required parameter: application_id\" }, 400);\n }\n\n const cases = await get(CASE_KEY);\n const c = cases.find((x) => x.application_id === application_id);\n if (!c) return json({ status: \"NOT_FOUND\" }, 404);\n return json(c);\n }\n\n // ─────────────────────────────────────────\n // DELETE /reset — clear all operations data\n // ─────────────────────────────────────────\n if (req.method === \"DELETE\" && path.endsWith(\"/reset\")) {\n await save(METER_KEY, []);\n await save(SCHEDULER_KEY, []);\n await save(CASE_KEY, []);\n return json({\n status: \"reset\",\n cleared: [\"meter_activations\", \"field_jobs\", \"cases\"],\n });\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}",[154],"287f78e6-18bb-11f1-8211-42dde27851f2","customerService.ts","1c8259fa-18bb-11f1-b775-42dde27851f2",17,["D",1772732754244],"// @valtown/http\n// Val Server 3 — Customer Services (CRM + OTP)\n// Lumina Energia Demo | Customer: Carlos Garcia Martinez\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst CRM_KEY = \"lumina_crm_customers\";\nconst OTP_KEY = \"lumina_otp_sessions\";\n\ntype Contract = {\n contract_id: string;\n cups: string;\n supply_type: string;\n tariff: string;\n contracted_power_kw: number;\n status: string;\n start_date: string;\n end_date: string | null;\n};\n\ntype Customer = {\n customer_id: string;\n customer_name: string;\n email: string;\n phone: string;\n type: \"existing\" | \"new\";\n since: string;\n contracts: Contract[];\n payment_history: {\n total_invoices: number;\n paid_on_time: number;\n late_payments: number;\n unpaid: number;\n unpaid_amount_eur: number;\n credit_score: string;\n };\n billing: {\n account_holder: string;\n iban: string;\n billing_address: string;\n };\n vulnerable_customer: boolean;\n notes: string;\n};\n\ntype OTPSession = {\n session_id: string;\n application_id: string;\n phone: string;\n otp: string;\n created_at: string;\n expires_at: string;\n verified: boolean;\n verified_at: string | null;\n};\n\n// ─────────────────────────────────────────\n// SEED DATA — Carlos Garcia Martinez\n// From Lumina Energia electricity bill LUM-2025-038471\n// ─────────────────────────────────────────\nconst SEED_CUSTOMERS: Customer[] = [\n {\n customer_id: \"52847163K\",\n customer_name: \"Carlos Garcia Martinez\",\n email: \"carlos.garcia@gmail.com\",\n phone: \"+34612345678\",\n type: \"existing\",\n since: \"2022-01-01\",\n contracts: [\n {\n contract_id: \"LUM-CTR-2022-00291\",\n cups: \"ES0031406000045001JN0F\",\n supply_type: \"Electricity\",\n tariff: \"2.0TD\",\n contracted_power_kw: 3.45,\n status: \"active\",\n start_date: \"2022-01-01\",\n end_date: null,\n },\n ],\n payment_history: {\n total_invoices: 38,\n paid_on_time: 38,\n late_payments: 0,\n unpaid: 0,\n unpaid_amount_eur: 0,\n credit_score: \"excellent\",\n },\n billing: {\n account_holder: \"Carlos Garcia Martinez\",\n iban: \"ES9121000418450200051332\",\n billing_address: \"Calle Gran Via, 32, 4B, 28013 Madrid\",\n },\n vulnerable_customer: false,\n notes:\n \"Existing Lumina Energia customer since 2022. Perfect payment record.\",\n },\n];\n\nasync function getCustomers(): Promise {\n const raw = await blob.getJSON(CRM_KEY);\n return Array.isArray(raw) && raw.length > 0 ? raw : SEED_CUSTOMERS;\n}\n\nasync function getOTPSessions(): Promise {\n const raw = await blob.getJSON(OTP_KEY);\n return Array.isArray(raw) ? raw : [];\n}\n\nfunction generateOTP(): string {\n return Math.floor(1000 + Math.random() * 9000).toString();\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 customers\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && (path === \"/\" || path === \"\")) {\n const customers = await getCustomers();\n return json({ count: customers.length, customers });\n }\n\n // ─────────────────────────────────────────\n // GET /crm/lookup?customer_id=52847163K\n // Full customer profile + history\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/crm/lookup\")) {\n const customer_id = url.searchParams.get(\"customer_id\");\n if (!customer_id) {\n return json({ error: \"Missing required parameter: customer_id\" }, 400);\n }\n\n const customers = await getCustomers();\n const customer = customers.find((c) => c.customer_id === customer_id);\n\n if (!customer) {\n return json({\n status: \"NEW_CUSTOMER\",\n customer_id,\n message: \"No records found — customer is new\",\n });\n }\n\n return json({ status: \"EXISTING_CUSTOMER\", customer_id, customer });\n }\n\n // ─────────────────────────────────────────\n // GET /crm/debts?customer_id=52847163K\n // Unpaid debt summary only\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/crm/debts\")) {\n const customer_id = url.searchParams.get(\"customer_id\");\n if (!customer_id) {\n return json({ error: \"Missing required parameter: customer_id\" }, 400);\n }\n\n const customers = await getCustomers();\n const customer = customers.find((c) => c.customer_id === customer_id);\n\n if (!customer) {\n return json({\n status: \"NEW_CUSTOMER\",\n customer_id,\n unpaid: 0,\n unpaid_amount_eur: 0,\n });\n }\n\n return json({\n status: \"FOUND\",\n customer_id,\n unpaid: customer.payment_history.unpaid,\n unpaid_amount_eur: customer.payment_history.unpaid_amount_eur,\n credit_score: customer.payment_history.credit_score,\n has_debt: customer.payment_history.unpaid > 0,\n });\n }\n\n // ─────────────────────────────────────────\n // POST /otp/send\n // Body: { application_id, phone }\n // Generates and stores OTP session (mock — logs OTP in response for demo)\n // ─────────────────────────────────────────\n if (req.method === \"POST\" && path.endsWith(\"/otp/send\")) {\n try {\n const body = await req.json();\n const { application_id, phone } = body;\n if (!application_id || !phone) {\n return json(\n { error: \"Missing required fields: application_id, phone\" },\n 400,\n );\n }\n\n const otp = generateOTP();\n const now = new Date();\n const expires = new Date(now.getTime() + 10 * 60 * 1000); // 10 min\n\n const session: OTPSession = {\n session_id: `OTP-${application_id}-${now.getTime()}`,\n application_id,\n phone,\n otp,\n created_at: now.toISOString(),\n expires_at: expires.toISOString(),\n verified: false,\n verified_at: null,\n };\n\n const sessions = await getOTPSessions();\n sessions.push(session);\n await blob.setJSON(OTP_KEY, sessions);\n\n return json({\n status: \"SENT\",\n session_id: session.session_id,\n phone,\n expires_at: session.expires_at,\n // Exposed for demo purposes only — remove in production\n demo_otp: otp,\n message: `OTP sent to ${phone}. Valid for 10 minutes.`,\n }, 201);\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // ─────────────────────────────────────────\n // POST /otp/verify\n // Body: { session_id, otp }\n // ─────────────────────────────────────────\n if (req.method === \"POST\" && path.endsWith(\"/otp/verify\")) {\n try {\n const body = await req.json();\n const { session_id, otp } = body;\n if (!session_id || !otp) {\n return json({ error: \"Missing required fields: session_id, otp\" }, 400);\n }\n\n const sessions = await getOTPSessions();\n const index = sessions.findIndex((s) => s.session_id === session_id);\n\n if (index === -1) {\n return json(\n { status: \"NOT_FOUND\", message: \"OTP session not found\" },\n 404,\n );\n }\n\n const session = sessions[index];\n\n if (session.verified) {\n return json({ status: \"ALREADY_VERIFIED\", session_id });\n }\n\n if (new Date() > new Date(session.expires_at)) {\n return json({\n status: \"EXPIRED\",\n session_id,\n message: \"OTP has expired\",\n }, 400);\n }\n\n if (session.otp !== otp) {\n return json(\n { status: \"INVALID\", session_id, message: \"Incorrect OTP\" },\n 400,\n );\n }\n\n sessions[index].verified = true;\n sessions[index].verified_at = new Date().toISOString();\n await blob.setJSON(OTP_KEY, sessions);\n\n return json({\n status: \"VERIFIED\",\n session_id,\n application_id: session.application_id,\n verified_at: sessions[index].verified_at,\n message: \"Contract signed successfully via OTP\",\n });\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // ─────────────────────────────────────────\n // DELETE /crm/reset\n // ─────────────────────────────────────────\n if (req.method === \"DELETE\" && path.endsWith(\"/crm/reset\")) {\n await blob.setJSON(CRM_KEY, SEED_CUSTOMERS);\n return json({ status: \"reset\", count: SEED_CUSTOMERS.length });\n }\n\n // ─────────────────────────────────────────\n // DELETE /otp/reset\n // ─────────────────────────────────────────\n if (req.method === \"DELETE\" && path.endsWith(\"/otp/reset\")) {\n await blob.setJSON(OTP_KEY, []);\n return json({ status: \"reset\", sessions_cleared: true });\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}",[161],"291e9d4e-18c6-11f1-a1f5-42dde27851f2","atrServer.ts","18a85fae-18c6-11f1-b0f0-42dde27851f2",32,["D",1772737479754],"// @valtown/http\n// Val Server 5 — ATR Lifecycle (Store + Status)\n// Lumina Energia Demo | XML generated by LLM, stored and tracked here\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst ATR_KEY = \"lumina_atr_requests\";\n\ntype ATRRecord = {\n atr_id: string;\n application_id: string;\n cups: string;\n submitted_by: string;\n submitted_at: string;\n status: \"pending\" | \"under_review\" | \"approved\" | \"rejected\";\n dso_response_at: string | null;\n rejection_reasons: string[];\n effective_date: string | null;\n xml_content: string;\n xml_updated_at: string;\n};\n\nasync function getATRRecords(): Promise {\n const raw = await blob.getJSON(ATR_KEY);\n return Array.isArray(raw) ? raw : [];\n}\n\nasync function saveATRRecords(records: ATRRecord[]): Promise {\n await blob.setJSON(ATR_KEY, records);\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 ATR requests\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && (path === \"/\" || path === \"\")) {\n const records = await getATRRecords();\n return json({ count: records.length, records });\n }\n\n // ─────────────────────────────────────────\n // GET /atr/status?application_id=\n // Returns status + elapsed time since submission\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/atr/status\")) {\n const application_id = url.searchParams.get(\"application_id\");\n const atr_id = url.searchParams.get(\"atr_id\");\n\n if (!application_id && !atr_id) {\n return json({\n error: \"Missing required parameter: application_id or atr_id\",\n }, 400);\n }\n\n const records = await getATRRecords();\n const record = application_id\n ? records.find((r) => r.application_id === application_id)\n : records.find((r) => r.atr_id === atr_id);\n\n if (!record) {\n return json(\n { status: \"NOT_FOUND\", message: \"ATR request not found\" },\n 404,\n );\n }\n\n return json({\n atr_id: record.atr_id,\n application_id: record.application_id,\n cups: record.cups,\n status: record.status,\n submitted_at: record.submitted_at,\n submitted_by: record.submitted_by,\n elapsed: getElapsed(record.submitted_at),\n dso_response_at: record.dso_response_at,\n effective_date: record.effective_date,\n rejection_reasons: record.rejection_reasons,\n });\n }\n\n // ─────────────────────────────────────────\n // GET /atr/xml?application_id=\n // Returns raw XML for display in analyst screen\n // ─────────────────────────────────────────\n if (req.method === \"GET\" && path.endsWith(\"/atr/xml\")) {\n const application_id = url.searchParams.get(\"application_id\");\n if (!application_id) {\n return json({ error: \"Missing required parameter: application_id\" }, 400);\n }\n\n const records = await getATRRecords();\n const record = records.find((r) => r.application_id === application_id);\n if (!record) return json({ status: \"NOT_FOUND\" }, 404);\n\n return new Response(record.xml_content, {\n status: 200,\n headers: { \"Content-Type\": \"application/xml\" },\n });\n }\n\n // ─────────────────────────────────────────\n // POST /atr/submit\n // Retailer submits LLM-generated ATR XML to DSO\n // Body: { application_id, cups, submitted_by, xml_content }\n // ─────────────────────────────────────────\n if (req.method === \"POST\" && path.endsWith(\"/atr/submit\")) {\n try {\n const body = await req.json();\n const { application_id, cups, submitted_by, xml_content } = body;\n\n if (!application_id || !cups || !submitted_by || !xml_content) {\n return json({\n error:\n \"Missing required fields: application_id, cups, submitted_by, xml_content\",\n }, 400);\n }\n\n const records = await getATRRecords();\n const existing = records.find((r) => r.application_id === application_id);\n\n if (existing) {\n return json({\n error: \"ATR already submitted for this application\",\n atr_id: existing.atr_id,\n }, 409);\n }\n\n const atr_id = `ATR-${application_id}-${Date.now()}`;\n const now = new Date().toISOString();\n\n const newRecord: ATRRecord = {\n atr_id,\n application_id,\n cups,\n submitted_by,\n submitted_at: now,\n status: \"pending\",\n dso_response_at: null,\n rejection_reasons: [],\n effective_date: null,\n xml_content,\n xml_updated_at: now,\n };\n\n records.push(newRecord);\n await saveATRRecords(records);\n\n return json({ status: \"SUBMITTED\", atr_id, submitted_at: now }, 201);\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // ─────────────────────────────────────────\n // PATCH /atr/respond\n // DSO approves or rejects ATR\n // Body: { atr_id, status, rejection_reasons?, effective_date? }\n // ─────────────────────────────────────────\n if (req.method === \"PATCH\" && path.endsWith(\"/atr/respond\")) {\n try {\n const body = await req.json();\n const { atr_id, status, rejection_reasons, effective_date } = body;\n\n if (!atr_id || !status) {\n return json({ error: \"Missing required fields: atr_id, status\" }, 400);\n }\n\n if (![\"approved\", \"rejected\", \"under_review\"].includes(status)) {\n return json({\n error: \"status must be approved, rejected or under_review\",\n }, 400);\n }\n\n const records = await getATRRecords();\n const index = records.findIndex((r) => r.atr_id === atr_id);\n if (index === -1) return json({ error: \"ATR not found\", atr_id }, 404);\n\n records[index].status = status;\n records[index].dso_response_at = new Date().toISOString();\n records[index].rejection_reasons = rejection_reasons || [];\n records[index].effective_date = effective_date || null;\n\n await saveATRRecords(records);\n\n return json({\n status: \"UPDATED\",\n atr_id,\n atr_status: records[index].status,\n dso_response_at: records[index].dso_response_at,\n effective_date: records[index].effective_date,\n rejection_reasons: records[index].rejection_reasons,\n });\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // ─────────────────────────────────────────\n // PATCH /atr/xml\n // Update XML after correction and resubmit\n // Body: { application_id, xml_content }\n // ─────────────────────────────────────────\n if (req.method === \"PATCH\" && path.endsWith(\"/atr/xml\")) {\n try {\n const body = await req.json();\n const { application_id, xml_content } = body;\n\n if (!application_id || !xml_content) {\n return json({\n error: \"Missing required fields: application_id, xml_content\",\n }, 400);\n }\n\n const records = await getATRRecords();\n const index = records.findIndex((r) =>\n r.application_id === application_id\n );\n if (index === -1) {\n return json({ error: \"ATR not found\", application_id }, 404);\n }\n\n records[index].xml_content = xml_content;\n records[index].xml_updated_at = new Date().toISOString();\n records[index].status = \"pending\";\n records[index].dso_response_at = null;\n records[index].rejection_reasons = [];\n\n await saveATRRecords(records);\n\n return json({\n status: \"UPDATED\",\n application_id,\n atr_id: records[index].atr_id,\n xml_updated_at: records[index].xml_updated_at,\n });\n } catch (err: any) {\n return json({ error: err.message || \"Invalid JSON\" }, 400);\n }\n }\n\n // ─────────────────────────────────────────\n // DELETE /atr/reset\n // ─────────────────────────────────────────\n if (req.method === \"DELETE\" && path.endsWith(\"/atr/reset\")) {\n await saveATRRecords([]);\n return json({ status: \"reset\" });\n }\n\n return new Response(\"Not Found\", { status: 404 });\n}\n\n// ─────────────────────────────────────────\n// Helpers\n// ─────────────────────────────────────────\nfunction getElapsed(\n submittedAt: string,\n): { days: number; hours: number; label: string } {\n const totalHours = Math.floor(\n (Date.now() - new Date(submittedAt).getTime()) / (1000 * 60 * 60),\n );\n const days = Math.floor(totalHours / 24);\n const hours = totalHours % 24;\n return { days, hours, label: `${days}d ${hours}h since submission` };\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}",[168],"pulls","branches",1,"forks","envVars",{"_182":60,"_184":60},"connections",{"_182":60,"_183":60},"count","unfilledCount","emptyCount",{"_43":167,"_32":168,"_30":169,"_134":-5,"_41":42,"_40":170,"_136":120,"_38":207,"_13":147,"_33":34,"_35":172,"_24":25,"_140":-5,"_192":208,"_27":209},{"_43":160,"_32":161,"_30":162,"_134":-5,"_41":42,"_40":163,"_136":120,"_38":204,"_13":147,"_33":34,"_35":165,"_24":25,"_140":-5,"_192":205,"_27":206},{"_43":153,"_32":154,"_30":155,"_134":-5,"_41":42,"_40":156,"_136":120,"_38":201,"_13":147,"_33":34,"_35":158,"_24":25,"_140":-5,"_192":202,"_27":203},{"_43":150,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_136":120,"_38":198,"_13":138,"_33":34,"_35":37,"_24":25,"_140":-5,"_192":199,"_27":200},{"_43":142,"_32":143,"_30":144,"_134":-5,"_41":42,"_40":145,"_136":120,"_38":195,"_13":147,"_33":34,"_35":148,"_24":25,"_140":-5,"_192":196,"_27":197},{"_43":131,"_32":132,"_30":133,"_134":-5,"_41":42,"_40":135,"_136":25,"_38":191,"_13":138,"_33":34,"_35":139,"_24":25,"_140":-5,"_192":193,"_27":194},["D",1772748512003],"children",[],[132],["D",1772732794437],[],[143],["D",1772877546734],[],[28],["D",1772732903301],[],[154],["D",1772732754244],[],[161],["D",1772737479754],[],[168],["D",1772732594353],{"_94":93,"_101":97},{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_122":247,"_248":249,"_250":251,"_252":25,"_253":25,"_254":25,"_255":120,"_256":-5,"_257":-7,"_258":-7,"_259":60,"_260":25,"_261":25,"_262":-5,"_263":25,"_264":25,"_265":25,"_266":-5},"ENV",{"_218":219,"_220":221,"_222":84,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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 · v36