[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_201":202,"_203":204},"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",22,"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","validationServer.ts","latestPath","fileId","31ef94ec-18bb-11f1-87b8-42dde27851f2","name","fileType","http","content","// Learn more: https://docs.val.town/vals/http/\nexport default async function (req: Request): Promise {\n return Response.json({ ok: true })\n}","// @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}","createdAt",["D",1772732794437],"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":197,"_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":198,"_78":199,"_80":200,"_82":25},"tree",[176,177,178,179,180],"files",[176,177,178,179,180],"counts",{"_166":60,"_167":155,"_168":60,"_169":170,"_171":172},"contents",[125,126,127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":159,"_32":160,"_30":161,"_133":-5,"_41":42,"_40":162,"_135":120,"_38":163,"_13":143,"_33":34,"_35":164,"_24":25,"_139":-5,"_27":165},{"_43":152,"_32":153,"_30":154,"_133":-5,"_41":42,"_40":155,"_135":25,"_38":156,"_13":60,"_33":157,"_35":103,"_24":25,"_139":-5,"_27":158},{"_43":145,"_32":146,"_30":147,"_133":-5,"_41":42,"_40":148,"_135":25,"_38":149,"_13":143,"_33":34,"_35":150,"_24":25,"_139":-5,"_27":151},{"_43":141,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_135":120,"_38":142,"_13":143,"_33":34,"_35":37,"_24":25,"_139":-5,"_27":144},{"_43":130,"_32":131,"_30":132,"_133":-5,"_41":42,"_40":134,"_135":25,"_38":136,"_13":137,"_33":34,"_35":138,"_24":25,"_139":-5,"_27":140},"0f5848a2-18bb-11f1-b990-42dde27851f2","wfStatus.ts","024a6c80-18bb-11f1-84fb-42dde27851f2","parentId",12,"latest",["D",1772732712046],5,"// @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: Record;\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",[131],"4073ef7c-18bb-11f1-b406-42dde27851f2",["D",1772732794437],4,[28],"eaa0d75e-18ba-11f1-b990-42dde27851f2","registryServer.ts","d2d24ba8-18ba-11f1-84fb-42dde27851f2",6,["D",1772732650448],"// @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 = \"sips_records\";\nconst CAU_KEY = \"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}",[146],"c93cfb42-18ba-11f1-84fb-42dde27851f2","main.ts","c93cfc0a-18ba-11f1-84fb-42dde27851f2",1,["D",1772732594431],"script",[153],"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}",[160],"pulls","branches","forks","envVars",{"_173":60,"_175":60},"connections",{"_173":60,"_174":60},"count","unfilledCount","emptyCount",{"_43":159,"_32":160,"_30":161,"_133":-5,"_41":42,"_40":162,"_135":120,"_38":194,"_13":143,"_33":34,"_35":164,"_24":25,"_139":-5,"_182":195,"_27":196},{"_43":152,"_32":153,"_30":154,"_133":-5,"_41":42,"_40":155,"_135":25,"_38":191,"_13":60,"_33":157,"_35":103,"_24":25,"_139":-5,"_182":192,"_27":193},{"_43":145,"_32":146,"_30":147,"_133":-5,"_41":42,"_40":148,"_135":25,"_38":188,"_13":143,"_33":34,"_35":150,"_24":25,"_139":-5,"_182":189,"_27":190},{"_43":141,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_135":120,"_38":185,"_13":143,"_33":34,"_35":37,"_24":25,"_139":-5,"_182":186,"_27":187},{"_43":130,"_32":131,"_30":132,"_133":-5,"_41":42,"_40":134,"_135":25,"_38":181,"_13":137,"_33":34,"_35":138,"_24":25,"_139":-5,"_182":183,"_27":184},["D",1772732712046],"children",[],[131],["D",1772732794437],[],[28],["D",1772732650448],[],[146],["D",1772732594431],[],[153],["D",1772732754244],[],[160],["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":234,"_235":236,"_237":238,"_239":25,"_240":25,"_241":25,"_242":120,"_243":-5,"_244":-7,"_245":-7,"_246":60,"_247":25,"_248":25,"_249":-5,"_250":25,"_251":25,"_252":25,"_253":-5},"ENV",{"_205":206,"_207":208,"_209":84,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233},"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 · v22