[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_228":229,"_230":231},"routes/_app.x.$handle.$name",{"_93":92,"_32":44,"_101":83,"_26":36,"_13":14,"_102":-5,"_11":103,"_104":105,"_106":107,"_108":109,"_110":111,"_20":-5,"_112":-5,"_113":-5,"_114":24,"_115":116,"_117":118,"_119":-5,"_120":-5,"_121":122},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":76,"_77":78,"_79":80,"_81":24},"version",10,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":29},"file",{"_30":31,"_32":27,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","new-file-5636.ts","latestPath","eddiApi.ts","fileId","f3ccba64-39cb-11f1-a1d1-42b51c65c3df","name","fileType","script","content","","createdAt",["D",1776368355655],"branchVersion","branchId","1a2c1a2e-32c9-11f1-b67e-42dde27851f2","id","1a08ce70-32c9-11f1-b67e-42dde27851f2","MyEnergi",["D",1775597473119],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","019d1cc1-92fb-71ad-9b61-d5698079c76c","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019d1cc1-92fb-71ad-9b61-db35e95292d3","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_93":92,"_100":96},"org",{"_93":92,"_94":-5,"_95":96,"_18":53,"_97":98,"_99":24},"branch",{"_13":82,"_32":83,"_42":41,"_84":43,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":44,"_91":92},"isOwned",16,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","garmeeh","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zQk1mY1NxVmY4UkxBZFVYcTJFcm9zR3RoYkYifQ","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_32":44,"_37":224,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":225,"_77":226,"_79":227,"_81":24},"tree",[186,188,189,190,191,192,193],"files",[186,187,188,189,190,191,192,193],"counts",{"_176":59,"_177":134,"_178":59,"_179":180,"_181":182},"contents",[123,124,125,126,127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_42":170,"_32":171,"_30":172,"_133":-5,"_40":41,"_39":134,"_135":118,"_37":173,"_13":59,"_33":174,"_35":-5,"_23":24,"_139":-5,"_26":175},{"_42":162,"_32":163,"_30":164,"_133":-5,"_40":41,"_39":165,"_135":24,"_37":166,"_13":167,"_33":20,"_35":168,"_23":24,"_139":-5,"_26":169},{"_42":157,"_32":158,"_30":159,"_133":-5,"_40":41,"_39":134,"_135":118,"_37":160,"_13":59,"_33":34,"_35":36,"_23":24,"_139":-5,"_26":161},{"_42":154,"_32":27,"_30":31,"_133":-5,"_40":41,"_39":14,"_135":24,"_37":155,"_13":59,"_33":34,"_35":36,"_23":24,"_139":-5,"_26":156},{"_42":147,"_32":148,"_30":149,"_133":-5,"_40":41,"_39":134,"_135":118,"_37":150,"_13":59,"_33":151,"_35":152,"_23":24,"_139":-5,"_26":153},{"_42":141,"_32":142,"_30":143,"_133":-5,"_40":41,"_39":134,"_135":118,"_37":144,"_13":59,"_33":137,"_35":145,"_23":24,"_139":-5,"_26":146},{"_42":130,"_32":131,"_30":132,"_133":-5,"_40":41,"_39":134,"_135":118,"_37":136,"_13":59,"_33":137,"_35":138,"_23":24,"_139":-5,"_26":140},"1a3c7130-32c9-11f1-b67e-42dde27851f2","zappiCronOn.ts","019d69db-4edb-71aa-bf6a-41017e07a8ee","parentId",1,"latest",["D",1775597473119],"interval","import { getEnv, setZappiMode } from \"./lib/myenergi.ts\";\n\nexport default async function (_interval: Interval) {\n const { cronOnMode } = getEnv();\n const result = await setZappiMode(cronOnMode);\n console.log(\"zappiCronOn\", result);\n return result;\n}","label",[131],"1a3c6e56-32c9-11f1-b67e-42dde27851f2","zappiCronOff.ts","019d69db-4edb-71aa-bf6a-3c371bcf34d0",["D",1775597473119],"import { turnOff } from \"./lib/myenergi.ts\";\n\nexport default async function (_interval: Interval) {\n const result = await turnOff();\n console.log(\"zappiCronOff\", result);\n return result;\n}",[142],"1a3c62a8-32c9-11f1-b67e-42dde27851f2","zappiApi.ts","019d69db-4edb-71aa-bf6a-3ac0e6cafbdb",["D",1775597473119],"http","import {\n getZappiStatus,\n handleEvent,\n isAuthorized,\n setZappiMode,\n turnOff,\n turnOn,\n unauthorizedResponse,\n} from \"./lib/myenergi.ts\";\n\nasync function readJson(req: Request): Promise {\n try {\n return await req.json();\n } catch {\n return null;\n }\n}\n\nfunction json(data: unknown, status = 200): Response {\n return new Response(JSON.stringify(data, null, 2), {\n status,\n headers: {\n \"content-type\": \"application/json; charset=utf-8\",\n \"cache-control\": \"no-store\",\n },\n });\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname;\n const method = req.method.toUpperCase();\n\n if (path === \"/\" && method === \"GET\") {\n return json({\n ok: true,\n service: \"zappi-control\",\n routes: [\n \"GET /api/zappi/status\",\n \"POST /api/zappi/on\",\n \"POST /api/zappi/off\",\n \"POST /api/zappi/mode\",\n \"POST /api/events\",\n ],\n auth: \"Authorization: Bearer or x-api-key header\",\n });\n }\n\n if (path.startsWith(\"/api/\") && !isAuthorized(req)) {\n return unauthorizedResponse();\n }\n\n try {\n if (path === \"/api/zappi/status\" && method === \"GET\") {\n return json(await getZappiStatus());\n }\n\n if (path === \"/api/zappi/on\" && method === \"POST\") {\n return json(await turnOn());\n }\n\n if (path === \"/api/zappi/off\" && method === \"POST\") {\n return json(await turnOff());\n }\n\n if (path === \"/api/zappi/mode\" && method === \"POST\") {\n const body = await readJson(req);\n const mode = body && typeof body === \"object\"\n ? (body as { mode?: string }).mode\n : undefined;\n\n if (\n mode !== \"fast\" &&\n mode !== \"eco\" &&\n mode !== \"eco_plus\" &&\n mode !== \"stop\"\n ) {\n return json(\n {\n ok: false,\n error:\n \"Body must be { mode: 'fast' | 'eco' | 'eco_plus' | 'stop' }\",\n },\n 400,\n );\n }\n\n return json(await setZappiMode(mode));\n }\n\n if (path === \"/api/events\" && method === \"POST\") {\n const body = await readJson(req);\n return json(await handleEvent(body));\n }\n\n return json(\n {\n ok: false,\n error: \"Not found\",\n },\n 404,\n );\n } catch (error) {\n console.error(error);\n\n return json(\n {\n ok: false,\n error: error instanceof Error ? error.message : String(error),\n },\n 500,\n );\n }\n}",[148],"f3ccb9b0-39cb-11f1-a1d1-42b51c65c3df",["D",1776368355655],[27],"1a3c6104-32c9-11f1-b67e-42dde27851f2","main.ts","019d69db-4edb-71aa-bf6a-361ec37c5ea2",["D",1775597473119],[158],"e041a298-32cd-11f1-834a-42dde27851f2","README.md","968ed912-32c9-11f1-a726-42dde27851f2",8,["D",1775599523712],4,"# Automate MyEnergi\n\nA Val Town project for automating a myenergi Zappi charger using the raw myenergi API. It includes secure API endpoints, scheduled cron jobs, and examples for turning Zappi charging on or off, changing charge modes, and building custom myenergi automation workflows.\n\nYou will need the following environment variables:\n\n```\nZAPPI_CRON_ON_MODE=eco_plus\nZAPPI_DEFAULT_ON_MODE=eco_plus\nZAPPI_API_TOKEN=\nZAPPI_SERIAL=\nMYENERGI_API_KEY=\nMYENERGI_HUB_SERIAL=\n```\n\nSet the cron/default mode to your preferred setting.\n\n`lib/myenergi.ts` = reusable myenergi client and auth logic `zappiApi.ts` = the\nHTTP API layer. You can call this from workflows, telegram bots etc\n\nor use the existing zappi cron files to run on a cron.\n\nHere’s a cleaner README-style version you can drop into the Val Town project.\n\n# myenergi API notes for Zappi automation\n\n## Overview\n\nThis project integrates with the **myenergi API** to automate a **Zappi** charger.\n\nAt the time of writing, myenergi says the API **exists but is not officially supported** and was originally developed for internal use. Their help centre directs developers to the community forum for help and examples.\n\nThis README focuses on the parts needed for simple Zappi automation:\n\n* where to get the API key\n* which serial numbers you need\n* how authentication works\n* the main status and control endpoints\n* the caveats to be aware of\n\n---\n\n## What you need\n\nFor the raw API flow used in this project, you need:\n\n* your **gateway / hub serial number**\n* an **API key**\n* your **Zappi serial number**\n\nIn this project, those are typically stored as:\n\n* `MYENERGI_HUB_SERIAL`\n* `MYENERGI_API_KEY`\n* `ZAPPI_SERIAL`\n\n---\n\n## Getting the API key\n\nTo generate an API key:\n\n1. Log in to **myaccount.myenergi.com** with the **same account that originally registered the devices**\n2. Go to **Products**\n3. At the top of the device list, open the **Gateway Device**\n4. Click **Advanced** (small key icon)\n5. Click **Generate new API key**\n\nImportant notes:\n\n* The API key is only available in the account that originally registered the devices. If you do not see the **Advanced** option, myenergi says you are probably logged into a shared or different account.\n* Generating a new API key **invalidates the old one immediately**.\n* The new key is shown **once only**, so copy it straight away.\n\n---\n\n## Finding the serial numbers\n\n## Hub / gateway serial\n\nmyenergi’s official guidance says API access requires the **hub serial number** plus the API key. The “Gateway Device” may be:\n\n* a physical **myenergi hub**\n* or another myenergi device acting as the gateway if it has built-in internet connectivity\n\n## Zappi serial\n\nFor a standard Zappi, the serial number can be found:\n\n* on the **label on the left side** of the unit\n* on the device under **Menu → Information**\n* in the app under **Menu → Settings → Device Settings**\n\n## vHub note\n\nIf you are using **vHub**, it can appear in the device list with the **same serial number as the device** acting as vHub, which can make the hub/device distinction a bit confusing.\n\n---\n\n## Authentication\n\nThe raw API flow commonly used by community integrations uses **HTTP Digest Authentication** with:\n\n* realm `\"MyEnergi Telemetry\"`\n* `qop=\"auth\"`\n* `algorithm=\"MD5\"`\n\nFor current usage, the typical credentials are:\n\n* **username** = hub / gateway serial number\n* **password** = API key\n\n---\n\n## Base URL / server selection\n\nCommunity integrations generally resolve the backend in one of two ways:\n\n### Legacy host pattern\n\nUse the last digit of the hub serial:\n\n`https://s.myenergi.net/`\n\n### Director lookup\n\nCall `https://director.myenergi.net/` first and read the `x_myenergi-asn` response header to determine the correct backend host. This is commonly used because myenergi has moved users onto newer hosts such as `s18.myenergi.net`.\n\nIn practice, newer integrations usually prefer the **director lookup** approach.\n\n---\n\n## Main API areas\n\nThe API surface is broader than what is listed here, but these are the main parts relevant to Zappi automation.\n\n## 1) Status endpoints\n\n### All devices\n\n`/cgi-jstatus-*`\n\nReturns current status for the myenergi ecosystem and can include arrays for devices such as `zappi`, `eddi`, and others.\n\n### Zappi-only aggregate\n\n`/cgi-jstatus-Z`\n\nUseful when you only care about Zappi data.\n\n### Specific Zappi\n\n`/cgi-jstatus-Z`\n\nExample:\n\n`/cgi-jstatus-Z10077777`\n\nThis is the most useful status endpoint for a single-Zappi automation flow.\n\n### Common Zappi fields\n\nFrom the documented community response structure, common fields include:\n\n* `sno` = serial number\n* `sta` = status\n* `zmo` = Zappi mode\n* `grd` = grid power\n* `vol` = supply voltage\n* `che` = charging / delivered energy related value\n* `mgl` = minimum green level\n\nThe documented `zmo` mode mapping is:\n\n* `1` = Fast\n* `2` = Eco\n* `3` = Eco+\n* `4` = Stopped\n\n---\n\n## 2) Zappi control endpoints\n\nThese are the key endpoints for simple mode switching.\n\n### Fast\n\n`/cgi-zappi-mode-Z-1-0-0-0000`\n\n### Eco\n\n`/cgi-zappi-mode-Z-2-0-0-0000`\n\n### Eco+\n\n`/cgi-zappi-mode-Z-3-0-0-0000`\n\n### Stop\n\n`/cgi-zappi-mode-Z-4-0-0-0000`\n\nThese mappings are widely documented in the reverse-engineered app API reference.\n\n### Practical on/off mapping\n\nFor most automations:\n\n* **On** = `fast`, `eco`, or `eco_plus`\n* **Off** = `stop`\n\n---\n\n## 3) Boost endpoints\n\n### Manual boost\n\n`/cgi-zappi-mode-Z-0-10-5-0000`\n\nThe documented example corresponds to a **5 kWh** manual boost.\n\n### Smart boost\n\n`/cgi-zappi-mode-Z-0-11-5-1400`\n\nThe documented example corresponds to **5 kWh**, completed by **14:00**.\n\n### Stop boost\n\n`/cgi-zappi-mode-Z-0-2-0-0000`\n\n### Typical success response\n\nSuccessful control calls are commonly documented as returning:\n\n```json\n{\n \"status\": 0,\n \"statustext\": \"\"\n}\n```\n\n---\n\n## 4) Other useful endpoints\n\n### Unlock charger\n\n`/cgi-jlock--01000000`\n\n### Minimum green level\n\nExamples:\n\n* `/cgi-set-min-green-Z-60`\n* `/cgi-set-min-green-Z-100`\n\n### Phase setting\n\nExamples:\n\n* `/cgi-zappi-phase-setting-Z-0`\n* `/cgi-zappi-phase-setting-Z-1`\n* `/cgi-zappi-phase-setting-Z-2`\n\nCommunity documentation maps these to:\n\n* `0` = single phase\n* `1` = three phase\n* `2` = auto\n\n### Historical / reporting endpoints\n\nExample:\n\n`/cgi-jdayhour-Z-YYYY-M-D`\n\nThese are more useful for reporting and analysis than for simple charger control.\n\n---\n\n## Example request shape\n\nA typical request flow is:\n\n1. Resolve the correct backend host\n2. Authenticate using **Digest auth**\n3. Call a status or control endpoint\n\nExample shape:\n\n```bash\ncurl --digest -u HUB_SERIAL:API_KEY \\\n -H 'accept: application/json' \\\n 'https://HOST/cgi-jstatus-ZZAPPI_SERIAL'\n```\n\nThis matches myenergi’s official guidance that access uses the hub serial and API key, plus the community-documented Digest auth flow.\n\n---\n\n## Recommended environment variables\n\nFor a small automation service, these are the key values:\n\n```text\nMYENERGI_HUB_SERIAL=\nMYENERGI_API_KEY=\nZAPPI_SERIAL=\n```\n\nThese values come from the official myenergi account/device flow described above.\n\nIf your service exposes its own HTTP endpoint, you will usually also add your own app-level secret, for example:\n\n```text\nZAPPI_API_TOKEN=\n```\n\nThat token is **your own application secret**, not a myenergi value.\n\n---\n\n## Caveats\n\n* myenergi says the API is **not officially supported** today.\n* The key-generation flow is official, but many of the concrete endpoints above come from community reverse-engineering rather than a polished supported developer portal.\n* Regenerating the API key immediately invalidates the old one.\n* If vHub is involved, serial numbers can be slightly confusing because the gateway/device relationship may not be obvious.\n* Because the API is unsupported, it is safest to treat undocumented behaviour as subject to change. That last point is an inference from myenergi’s support position.\n\n---\n\n## Summary\n\nFor simple Zappi automation, the minimum useful setup is:\n\n* hub / gateway serial\n* API key\n* Zappi serial\n* Digest auth\n* `cgi-jstatus-Z` for reads\n* `cgi-zappi-mode-Z-...` for mode changes\n\nIf you want, I can also turn this into a slightly more polished GitHub-style README with sections like **Setup**, **Testing**, and **Troubleshooting**.",[163],"1a3c5f4c-32c9-11f1-b67e-42dde27851f2","lib","019d69db-4edb-71aa-bf6a-31b6e3588e65",["D",1775597473119],"directory",[171],"pulls","branches","forks","envVars",{"_183":59,"_185":59},"connections",{"_183":59,"_184":59},"count","unfilledCount","emptyCount",{"_42":170,"_32":171,"_30":172,"_133":-5,"_40":41,"_39":134,"_135":118,"_37":221,"_13":59,"_33":174,"_35":-5,"_23":24,"_139":-5,"_195":222,"_26":223},{"_42":213,"_32":214,"_30":215,"_133":172,"_40":41,"_39":216,"_135":118,"_37":217,"_13":134,"_33":34,"_35":218,"_23":24,"_139":-5,"_195":219,"_26":220},{"_42":162,"_32":163,"_30":164,"_133":-5,"_40":41,"_39":165,"_135":24,"_37":210,"_13":167,"_33":20,"_35":168,"_23":24,"_139":-5,"_195":211,"_26":212},{"_42":157,"_32":158,"_30":159,"_133":-5,"_40":41,"_39":134,"_135":118,"_37":207,"_13":59,"_33":34,"_35":36,"_23":24,"_139":-5,"_195":208,"_26":209},{"_42":154,"_32":27,"_30":31,"_133":-5,"_40":41,"_39":14,"_135":24,"_37":204,"_13":59,"_33":34,"_35":36,"_23":24,"_139":-5,"_195":205,"_26":206},{"_42":147,"_32":148,"_30":149,"_133":-5,"_40":41,"_39":134,"_135":118,"_37":201,"_13":59,"_33":151,"_35":152,"_23":24,"_139":-5,"_195":202,"_26":203},{"_42":141,"_32":142,"_30":143,"_133":-5,"_40":41,"_39":134,"_135":118,"_37":198,"_13":59,"_33":137,"_35":145,"_23":24,"_139":-5,"_195":199,"_26":200},{"_42":130,"_32":131,"_30":132,"_133":-5,"_40":41,"_39":134,"_135":118,"_37":194,"_13":59,"_33":137,"_35":138,"_23":24,"_139":-5,"_195":196,"_26":197},["D",1775597473119],"children",[],[131],["D",1775597473119],[],[142],["D",1775597473119],[],[148],["D",1776368355655],[],[27],["D",1775597473119],[],[158],["D",1775599523712],[],[163],"e7ac40c4-39cb-11f1-ad41-42b51c65c3df","myenergi.ts","019d69db-4edb-71aa-bf6a-2fadde21fc1e",9,["D",1776368335290],"import md5 from \"npm:blueimp-md5\";\n\nexport type ZappiMode = \"fast\" | \"eco\" | \"eco_plus\" | \"stop\";\nexport type EddiTarget = 1 | 2 | 11 | 12;\n\ntype MyEnergiEnv = {\n hubSerial: string;\n apiKey: string;\n zappiSerial?: string;\n eddiSerial?: string;\n apiToken?: string;\n defaultOnMode: ZappiMode;\n cronOnMode: ZappiMode;\n defaultEddiTarget: EddiTarget;\n};\n\ntype DigestChallenge = {\n realm: string;\n nonce: string;\n qop?: string;\n opaque?: string;\n algorithm?: string;\n};\n\nlet cachedServerHost: string | null = null;\n\nconst MODE_TO_CODE: Record = {\n fast: \"1\",\n eco: \"2\",\n eco_plus: \"3\",\n stop: \"4\",\n};\n\nconst MODE_FROM_CODE: Record = {\n 1: \"fast\",\n 2: \"eco\",\n 3: \"eco_plus\",\n 4: \"stop\",\n};\n\nfunction getRequiredEnv(name: string): string {\n const value = Deno.env.get(name);\n if (!value) {\n throw new Error(`Missing environment variable: ${name}`);\n }\n return value;\n}\n\nfunction normalizeMode(\n value: string | undefined | null,\n fallback: ZappiMode,\n): ZappiMode {\n if (\n value === \"fast\" || value === \"eco\" || value === \"eco_plus\" ||\n value === \"stop\"\n ) {\n return value;\n }\n return fallback;\n}\n\nfunction normalizeEddiTarget(\n value: string | undefined | null,\n fallback: EddiTarget,\n): EddiTarget {\n const n = Number(value);\n if (n === 1 || n === 2 || n === 11 || n === 12) return n;\n return fallback;\n}\n\nexport function getEnv(): MyEnergiEnv {\n return {\n hubSerial: getRequiredEnv(\"MYENERGI_HUB_SERIAL\"),\n apiKey: getRequiredEnv(\"MYENERGI_API_KEY\"),\n zappiSerial: Deno.env.get(\"ZAPPI_SERIAL\") ?? undefined,\n eddiSerial: Deno.env.get(\"EDDI_SERIAL\") ?? undefined,\n apiToken: Deno.env.get(\"MYENERGI_API_TOKEN\") ??\n Deno.env.get(\"ZAPPI_API_TOKEN\") ??\n undefined,\n defaultOnMode: normalizeMode(\n Deno.env.get(\"ZAPPI_DEFAULT_ON_MODE\"),\n \"eco_plus\",\n ),\n cronOnMode: normalizeMode(\n Deno.env.get(\"ZAPPI_CRON_ON_MODE\"),\n normalizeMode(Deno.env.get(\"ZAPPI_DEFAULT_ON_MODE\"), \"eco_plus\"),\n ),\n defaultEddiTarget: normalizeEddiTarget(\n Deno.env.get(\"EDDI_DEFAULT_TARGET\"),\n 1,\n ),\n };\n}\n\nfunction requireZappiSerial(): string {\n const { zappiSerial } = getEnv();\n if (!zappiSerial) {\n throw new Error(\"Missing environment variable: ZAPPI_SERIAL\");\n }\n return zappiSerial;\n}\n\nfunction requireEddiSerial(): string {\n const { eddiSerial } = getEnv();\n if (!eddiSerial) {\n throw new Error(\"Missing environment variable: EDDI_SERIAL\");\n }\n return eddiSerial;\n}\n\nexport function isAuthorized(req: Request): boolean {\n const token = getEnv().apiToken;\n if (!token) return false;\n\n const auth = req.headers.get(\"authorization\");\n if (auth?.startsWith(\"Bearer \")) {\n return auth.slice(\"Bearer \".length) === token;\n }\n\n const xApiKey = req.headers.get(\"x-api-key\");\n return xApiKey === token;\n}\n\nexport function unauthorizedResponse(): Response {\n return Response.json(\n {\n ok: false,\n error: \"Unauthorized\",\n },\n { status: 401 },\n );\n}\n\nfunction buildLegacyHost(hubSerial: string): string {\n return `s${hubSerial.slice(-1)}.myenergi.net`;\n}\n\nfunction parseDigestChallenge(header: string): DigestChallenge {\n const trimmed = header.replace(/^Digest\\s+/i, \"\");\n const out: Record = {};\n\n for (const match of trimmed.matchAll(/(\\w+)=(\"([^\"]*)\"|([^,]+))/g)) {\n const key = match[1];\n const value = match[3] ?? match[4] ?? \"\";\n out[key] = value.trim();\n }\n\n if (!out.realm || !out.nonce) {\n throw new Error(`Invalid digest challenge: ${header}`);\n }\n\n return {\n realm: out.realm,\n nonce: out.nonce,\n qop: out.qop?.split(\",\")[0]?.trim(),\n opaque: out.opaque,\n algorithm: out.algorithm,\n };\n}\n\nfunction randomHex(bytes = 8): string {\n const arr = crypto.getRandomValues(new Uint8Array(bytes));\n return [...arr].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nfunction buildDigestAuthorization(params: {\n username: string;\n password: string;\n method: string;\n uri: string;\n challenge: DigestChallenge;\n}): string {\n const { username, password, method, uri, challenge } = params;\n\n const nc = \"00000001\";\n const cnonce = randomHex(8);\n const qop = challenge.qop || \"auth\";\n\n const ha1 = md5(`${username}:${challenge.realm}:${password}`);\n const ha2 = md5(`${method}:${uri}`);\n const response = md5(\n `${ha1}:${challenge.nonce}:${nc}:${cnonce}:${qop}:${ha2}`,\n );\n\n const parts = [\n `Digest username=\"${username}\"`,\n `realm=\"${challenge.realm}\"`,\n `nonce=\"${challenge.nonce}\"`,\n `uri=\"${uri}\"`,\n `qop=${qop}`,\n `nc=${nc}`,\n `cnonce=\"${cnonce}\"`,\n `response=\"${response}\"`,\n ];\n\n if (challenge.opaque) {\n parts.push(`opaque=\"${challenge.opaque}\"`);\n }\n if (challenge.algorithm) {\n parts.push(`algorithm=${challenge.algorithm}`);\n }\n\n return parts.join(\", \");\n}\n\nasync function digestFetch(\n url: string,\n init: RequestInit = {},\n): Promise {\n const env = getEnv();\n const firstHeaders = new Headers(init.headers);\n if (!firstHeaders.has(\"accept\")) {\n firstHeaders.set(\"accept\", \"application/json\");\n }\n\n const first = await fetch(url, {\n ...init,\n headers: firstHeaders,\n });\n\n if (first.status !== 401) {\n return first;\n }\n\n const challengeHeader = first.headers.get(\"www-authenticate\");\n if (!challengeHeader) {\n throw new Error(\"Expected WWW-Authenticate header from myenergi\");\n }\n\n const challenge = parseDigestChallenge(challengeHeader);\n const parsedUrl = new URL(url);\n const method = init.method ?? \"GET\";\n const uri = `${parsedUrl.pathname}${parsedUrl.search}`;\n\n const authHeader = buildDigestAuthorization({\n username: env.hubSerial,\n password: env.apiKey,\n method,\n uri,\n challenge,\n });\n\n const secondHeaders = new Headers(init.headers);\n secondHeaders.set(\"accept\", \"application/json\");\n secondHeaders.set(\"authorization\", authHeader);\n\n return fetch(url, {\n ...init,\n headers: secondHeaders,\n });\n}\n\nasync function safeJson(response: Response): Promise {\n const text = await response.text();\n try {\n return JSON.parse(text);\n } catch {\n return text;\n }\n}\n\nasync function resolveServerHost(): Promise {\n if (cachedServerHost) return cachedServerHost;\n\n const { hubSerial } = getEnv();\n const fallback = buildLegacyHost(hubSerial);\n\n try {\n const res = await digestFetch(\n \"https://director.myenergi.net/cgi-jstatus-*\",\n );\n const host = res.headers.get(\"x_myenergi-asn\");\n cachedServerHost = host || fallback;\n } catch {\n cachedServerHost = fallback;\n }\n\n return cachedServerHost;\n}\n\nfunction zappiModePath(zappiSerial: string, mode: ZappiMode): string {\n const modeCode = MODE_TO_CODE[mode];\n return `/cgi-zappi-mode-Z${zappiSerial}-${modeCode}-0-0-0000`;\n}\n\nfunction zappiStatusPath(zappiSerial: string): string {\n return `/cgi-jstatus-Z${zappiSerial}`;\n}\n\nfunction eddiStatusPath(eddiSerial: string): string {\n return `/cgi-jstatus-E${eddiSerial}`;\n}\n\nfunction eddiBoostPath(\n eddiSerial: string,\n boostOn: 0 | 1 | 10,\n target: EddiTarget,\n durationMinutes: number,\n): string {\n return `/cgi-eddi-boost-E${eddiSerial}-${boostOn}-${target}-${durationMinutes}`;\n}\n\nfunction extractFirstArrayItemOrObject(\n body: unknown,\n key: string,\n): Record | null {\n if (!body || typeof body !== \"object\" || !(key in body)) {\n return null;\n }\n\n const value = (body as Record)[key];\n\n if (Array.isArray(value)) {\n const first = value[0];\n return first && typeof first === \"object\"\n ? (first as Record)\n : null;\n }\n\n return value && typeof value === \"object\"\n ? (value as Record)\n : null;\n}\n\nfunction numberOrNull(value: unknown): number | null {\n const n = Number(value);\n return Number.isFinite(n) ? n : null;\n}\n\nfunction temperatureOrNull(value: unknown): number | null {\n const n = numberOrNull(value);\n if (n === null || n === 127) return null;\n return n;\n}\n\nfunction buildIsoTimestamp(\n dat?: string | null,\n tim?: string | null,\n): string | null {\n if (!dat || !tim) return null;\n\n const parts = dat.split(\"-\");\n if (parts.length !== 3) return null;\n\n const [dd, mm, yyyy] = parts;\n const iso = `${yyyy}-${mm}-${dd}T${tim}Z`;\n const d = new Date(iso);\n\n return Number.isNaN(d.getTime()) ? null : d.toISOString();\n}\n\nexport async function setZappiMode(mode: ZappiMode) {\n const zappiSerial = requireZappiSerial();\n const host = await resolveServerHost();\n const url = `https://${host}${zappiModePath(zappiSerial, mode)}`;\n\n const res = await digestFetch(url);\n const body = await safeJson(res);\n\n const statusValue =\n typeof body === \"object\" && body !== null && \"status\" in body\n ? (body as Record).status\n : undefined;\n\n return {\n ok: res.ok && (statusValue === 0 || statusValue === \"0\"),\n mode,\n host,\n statusCode: res.status,\n raw: body,\n };\n}\n\nexport async function getZappiStatus() {\n const zappiSerial = requireZappiSerial();\n const host = await resolveServerHost();\n const url = `https://${host}${zappiStatusPath(zappiSerial)}`;\n\n const res = await digestFetch(url);\n const body = await safeJson(res);\n const zappi = extractFirstArrayItemOrObject(body, \"zappi\");\n\n const rawMode = zappi ? numberOrNull(zappi.zmo) : null;\n const dat = zappi && typeof zappi.dat === \"string\" ? zappi.dat : null;\n const tim = zappi && typeof zappi.tim === \"string\" ? zappi.tim : null;\n\n return {\n ok: res.ok,\n host,\n statusCode: res.status,\n mode: rawMode && MODE_FROM_CODE[rawMode] ? MODE_FROM_CODE[rawMode] : null,\n rawMode,\n status: zappi ? numberOrNull(zappi.sta) : null,\n gridWatts: zappi ? numberOrNull(zappi.grd) : null,\n voltage: zappi ? numberOrNull(zappi.vol) : null,\n chargeEnergy: zappi ? numberOrNull(zappi.che) : null,\n minimumGreenLevel: zappi ? numberOrNull(zappi.mgl) : null,\n timestamp: buildIsoTimestamp(dat, tim),\n zappi,\n raw: body,\n };\n}\n\nexport async function turnOn() {\n const { defaultOnMode } = getEnv();\n return setZappiMode(defaultOnMode);\n}\n\nexport async function turnOff() {\n return setZappiMode(\"stop\");\n}\n\nexport async function handleEvent(event: unknown) {\n if (!event || typeof event !== \"object\") {\n throw new Error(\"Invalid event payload\");\n }\n\n const payload = event as Record;\n const type = payload.type;\n\n switch (type) {\n case \"zappi.on\":\n return turnOn();\n\n case \"zappi.off\":\n return turnOff();\n\n case \"zappi.mode\": {\n const mode = payload.mode;\n if (\n mode !== \"fast\" &&\n mode !== \"eco\" &&\n mode !== \"eco_plus\" &&\n mode !== \"stop\"\n ) {\n throw new Error(\"Invalid mode\");\n }\n return setZappiMode(mode);\n }\n\n case \"zappi.status\":\n return getZappiStatus();\n\n default:\n throw new Error(`Unsupported event type: ${String(type)}`);\n }\n}\n\nexport async function getEddiStatus() {\n const eddiSerial = requireEddiSerial();\n const host = await resolveServerHost();\n const url = `https://${host}${eddiStatusPath(eddiSerial)}`;\n\n const res = await digestFetch(url);\n const body = await safeJson(res);\n const eddi = extractFirstArrayItemOrObject(body, \"eddi\");\n\n const rawBoostState = eddi ? numberOrNull(eddi.bsm) : null;\n const tp1 = eddi ? temperatureOrNull(eddi.tp1) : null;\n const tp2 = eddi ? temperatureOrNull(eddi.tp2) : null;\n const currentTempC = tp1 ?? tp2;\n\n return {\n ok: res.ok,\n host,\n statusCode: res.status,\n boosting: rawBoostState === 1,\n rawBoostState,\n currentTempC,\n temperatureProbe1C: tp1,\n temperatureProbe2C: tp2,\n relayBoardConnected: eddi ? numberOrNull(eddi.rbc) === 1 : null,\n relay1Active: eddi ? numberOrNull(eddi.r1a) === 1 : null,\n relay2Active: eddi ? numberOrNull(eddi.r2a) === 1 : null,\n relay1BoostType: eddi ? numberOrNull(eddi.r1b) : null,\n relay2BoostType: eddi ? numberOrNull(eddi.r2b) : null,\n eddi,\n raw: body,\n };\n}\n\nexport async function getEddiTemperature() {\n const status = await getEddiStatus();\n\n return {\n ok: status.ok,\n host: status.host,\n statusCode: status.statusCode,\n currentTempC: status.currentTempC,\n temperatureProbe1C: status.temperatureProbe1C,\n temperatureProbe2C: status.temperatureProbe2C,\n };\n}\n\nexport async function startEddiBoost(options?: {\n target?: EddiTarget;\n durationMinutes?: number;\n}) {\n const { defaultEddiTarget } = getEnv();\n const eddiSerial = requireEddiSerial();\n const host = await resolveServerHost();\n\n const target = options?.target ?? defaultEddiTarget;\n const durationMinutes = Math.max(\n 1,\n Math.floor(options?.durationMinutes ?? 60),\n );\n\n const url = `https://${host}${\n eddiBoostPath(eddiSerial, 10, target, durationMinutes)\n }`;\n const res = await digestFetch(url);\n const body = await safeJson(res);\n\n const statusValue =\n typeof body === \"object\" && body !== null && \"status\" in body\n ? (body as Record).status\n : undefined;\n\n return {\n ok: res.ok && (statusValue === 0 || statusValue === \"0\"),\n host,\n statusCode: res.status,\n action: \"start_boost\",\n target,\n durationMinutes,\n raw: body,\n };\n}\n\nexport async function stopEddiBoost(options?: {\n target?: EddiTarget;\n}) {\n const { defaultEddiTarget } = getEnv();\n const eddiSerial = requireEddiSerial();\n const host = await resolveServerHost();\n\n const target = options?.target ?? defaultEddiTarget;\n\n const url = `https://${host}${eddiBoostPath(eddiSerial, 1, target, 0)}`;\n const res = await digestFetch(url);\n const body = await safeJson(res);\n\n const statusValue =\n typeof body === \"object\" && body !== null && \"status\" in body\n ? (body as Record).status\n : undefined;\n\n return {\n ok: res.ok && (statusValue === 0 || statusValue === \"0\"),\n host,\n statusCode: res.status,\n action: \"stop_boost\",\n target,\n raw: body,\n };\n}\n\nexport async function handleEddiEvent(event: unknown) {\n if (!event || typeof event !== \"object\") {\n throw new Error(\"Invalid event payload\");\n }\n\n const payload = event as Record;\n const type = payload.type;\n\n switch (type) {\n case \"eddi.status\":\n return getEddiStatus();\n\n case \"eddi.temperature\":\n return getEddiTemperature();\n\n case \"eddi.boost.start\": {\n const durationMinutes = typeof payload.durationMinutes === \"number\"\n ? payload.durationMinutes\n : undefined;\n\n const target =\n payload.target === 1 || payload.target === 2 || payload.target === 11 ||\n payload.target === 12\n ? payload.target\n : undefined;\n\n return startEddiBoost({ target, durationMinutes });\n }\n\n case \"eddi.boost.stop\": {\n const target =\n payload.target === 1 || payload.target === 2 || payload.target === 11 ||\n payload.target === 12\n ? payload.target\n : undefined;\n\n return stopEddiBoost({ target });\n }\n\n default:\n throw new Error(`Unsupported event type: ${String(type)}`);\n }\n}",[],[171,214],["D",1775597473119],[187],[171],["D",1775597473119],{"_93":92,"_100":96},{"_93":92,"_94":-5,"_95":96,"_18":53,"_97":98,"_99":24},{"_13":82,"_32":83,"_42":41,"_84":43,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":44,"_91":92},"ctx",{"_75":-5,"_120":261,"_262":263,"_264":265,"_266":24,"_267":24,"_268":24,"_269":118,"_270":-5,"_271":-7,"_272":-7,"_273":59,"_274":24,"_275":24,"_276":-5,"_277":24,"_278":24,"_279":24,"_280":-5},"ENV",{"_232":233,"_234":235,"_236":83,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v10