[{"_1":2,"_177":-5,"_178":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","8db0b2d8d0bd6b473e966ef7e1d70facc527d8ea","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_154":155,"_174":175,"_176":-5},"handle","gflow","name","RetailFlow","path","operations.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":-5,"_112":-5,"_12":113,"_114":-5,"_115":20,"_116":-5,"_117":-5,"_118":33,"_14":119,"_120":-5,"_121":-5,"_122":-5,"_123":124,"_125":124,"_126":127,"_128":127,"_129":127,"_130":124,"_131":124,"_23":132,"_135":136,"_140":141,"_153":20},"id","c936de06-18ba-11f1-84fb-42dde27851f2","createdAt",["D",1772732594353],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","019be3ee-b210-72df-b0b7-1c63b5f83da1","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","019be3ee-b210-72df-b0b7-20f942b1694c","tursoName","tursoHostname","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_133":134},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM4YjVwUVVEZWJ2b0RPYVpYSHBhNXRUQmEwdSJ9","org",{"_95":96,"_137":134,"_12":113,"_138":139},"avatar","tier","free","branch",{"_142":143,"_97":45,"_103":144,"_145":104,"_146":-5,"_147":-5,"_148":-5,"_149":-5,"_150":-5,"_151":98,"_152":96},"version",35,"c937468e-18ba-11f1-84fb-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":156,"_97":100,"_157":158,"_159":-5,"_160":144,"_161":162,"_163":164,"_105":165,"_142":166,"_167":168,"_169":170,"_171":20,"_172":-5,"_99":173},"8157e3ea-18bb-11f1-a1e9-42dde27851f2","fileId","7a6f58f6-18bb-11f1-a785-42dde27851f2","parentId","branchId","branchVersion",27,"latest",true,["D",1772732903301],4,"fileType","http","content","// @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}","deleted","label",[100],"permalink","https://www.val.town/x/gflow/RetailFlow/code/operations.ts","extension","actionData","errors"]