[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_217":218,"_219":220},"routes/_app.x.$handle.$name",{"_93":92,"_32":44,"_101":83,"_27":102,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":25,"_116":117,"_118":119,"_120":-5,"_121":-5,"_122":123},"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":25,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":-5,"_55":25,"_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":25},"version",8,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":20,"_34":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":20,"_34":35},"deleted",false,"deletedHere","path","README.md","latestPath","fileId","968ed912-32c9-11f1-a726-42dde27851f2","name","fileType","content","# MyEnergi\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**.","# 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**.","createdAt",["D",1775599523712],"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":25},"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":213,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":-5,"_55":25,"_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":214,"_77":215,"_79":216,"_81":25},"tree",[180,182,183,184,185,186],"files",[180,181,182,183,184,185,186],"counts",{"_170":59,"_171":134,"_172":59,"_173":174,"_175":176},"contents",[124,125,126,127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_42":164,"_32":165,"_30":166,"_133":-5,"_40":41,"_39":134,"_135":119,"_37":167,"_13":59,"_33":168,"_34":-5,"_24":25,"_139":-5,"_27":169},{"_42":160,"_32":28,"_30":31,"_133":-5,"_40":41,"_39":14,"_135":25,"_37":161,"_13":162,"_33":20,"_34":36,"_24":25,"_139":-5,"_27":163},{"_42":154,"_32":155,"_30":156,"_133":-5,"_40":41,"_39":134,"_135":119,"_37":157,"_13":59,"_33":158,"_34":102,"_24":25,"_139":-5,"_27":159},{"_42":147,"_32":148,"_30":149,"_133":-5,"_40":41,"_39":134,"_135":119,"_37":150,"_13":59,"_33":151,"_34":152,"_24":25,"_139":-5,"_27":153},{"_42":141,"_32":142,"_30":143,"_133":-5,"_40":41,"_39":134,"_135":119,"_37":144,"_13":59,"_33":137,"_34":145,"_24":25,"_139":-5,"_27":146},{"_42":130,"_32":131,"_30":132,"_133":-5,"_40":41,"_39":134,"_135":119,"_37":136,"_13":59,"_33":137,"_34":138,"_24":25,"_139":-5,"_27":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],"1a3c6104-32c9-11f1-b67e-42dde27851f2","main.ts","019d69db-4edb-71aa-bf6a-361ec37c5ea2",["D",1775597473119],"script",[155],"e041a298-32cd-11f1-834a-42dde27851f2",["D",1775599523712],4,[28],"1a3c5f4c-32c9-11f1-b67e-42dde27851f2","lib","019d69db-4edb-71aa-bf6a-31b6e3588e65",["D",1775597473119],"directory",[165],"pulls","branches","forks","envVars",{"_177":59,"_179":59},"connections",{"_177":59,"_178":59},"count","unfilledCount","emptyCount",{"_42":164,"_32":165,"_30":166,"_133":-5,"_40":41,"_39":134,"_135":119,"_37":210,"_13":59,"_33":168,"_34":-5,"_24":25,"_139":-5,"_188":211,"_27":212},{"_42":203,"_32":204,"_30":205,"_133":166,"_40":41,"_39":134,"_135":25,"_37":206,"_13":59,"_33":158,"_34":207,"_24":25,"_139":-5,"_188":208,"_27":209},{"_42":160,"_32":28,"_30":31,"_133":-5,"_40":41,"_39":14,"_135":25,"_37":200,"_13":162,"_33":20,"_34":36,"_24":25,"_139":-5,"_188":201,"_27":202},{"_42":154,"_32":155,"_30":156,"_133":-5,"_40":41,"_39":134,"_135":119,"_37":197,"_13":59,"_33":158,"_34":102,"_24":25,"_139":-5,"_188":198,"_27":199},{"_42":147,"_32":148,"_30":149,"_133":-5,"_40":41,"_39":134,"_135":119,"_37":194,"_13":59,"_33":151,"_34":152,"_24":25,"_139":-5,"_188":195,"_27":196},{"_42":141,"_32":142,"_30":143,"_133":-5,"_40":41,"_39":134,"_135":119,"_37":191,"_13":59,"_33":137,"_34":145,"_24":25,"_139":-5,"_188":192,"_27":193},{"_42":130,"_32":131,"_30":132,"_133":-5,"_40":41,"_39":134,"_135":119,"_37":187,"_13":59,"_33":137,"_34":138,"_24":25,"_139":-5,"_188":189,"_27":190},["D",1775597473119],"children",[],[131],["D",1775597473119],[],[142],["D",1775597473119],[],[148],["D",1775597473119],[],[155],["D",1775599523712],[],[28],"1a3c2de2-32c9-11f1-b67e-42dde27851f2","myenergi.ts","019d69db-4edb-71aa-bf6a-2fadde21fc1e",["D",1775597473119],"import md5 from \"npm:blueimp-md5\";\n\nexport type ZappiMode = \"fast\" | \"eco\" | \"eco_plus\" | \"stop\";\n\ntype MyEnergiEnv = {\n hubSerial: string;\n apiKey: string;\n zappiSerial: string;\n apiToken?: string;\n defaultOnMode: ZappiMode;\n cronOnMode: ZappiMode;\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\nexport function getEnv(): MyEnergiEnv {\n return {\n hubSerial: getRequiredEnv(\"MYENERGI_HUB_SERIAL\"),\n apiKey: getRequiredEnv(\"MYENERGI_API_KEY\"),\n zappiSerial: getRequiredEnv(\"ZAPPI_SERIAL\"),\n apiToken: Deno.env.get(\"ZAPPI_API_TOKEN\") ?? 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 };\n}\n\nexport function isAuthorized(req: Request): boolean {\n const token = Deno.env.get(\"ZAPPI_API_TOKEN\");\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 modePath(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 statusPath(zappiSerial: string): string {\n return `/cgi-jstatus-Z${zappiSerial}`;\n}\n\nexport async function setZappiMode(mode: ZappiMode) {\n const { zappiSerial } = getEnv();\n const host = await resolveServerHost();\n const url = `https://${host}${modePath(zappiSerial, mode)}`;\n\n const res = await digestFetch(url);\n const body = await safeJson(res);\n const statusValue =\n typeof body === \"object\" && body !== null && \"status\" in body\n ? (body as Record).status\n : undefined;\n\n const ok = res.ok && (statusValue === 0 || statusValue === \"0\");\n\n return {\n ok,\n mode,\n host,\n statusCode: res.status,\n raw: body,\n };\n}\n\nexport async function getZappiStatus() {\n const { zappiSerial } = getEnv();\n const host = await resolveServerHost();\n const url = `https://${host}${statusPath(zappiSerial)}`;\n\n const res = await digestFetch(url);\n const body = await safeJson(res);\n\n const zappi = typeof body === \"object\" && body !== null && \"zappi\" in body\n ? Array.isArray((body as Record).zappi)\n ? ((body as Record).zappi as unknown[])[0]\n : (body as Record).zappi\n : null;\n\n const rawMode = zappi && typeof zappi === \"object\" && \"zmo\" in zappi\n ? Number((zappi as Record).zmo)\n : 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 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}",[],[165,204],["D",1775597473119],[181],[165],["D",1775597473119],{"_93":92,"_100":96},{"_93":92,"_94":-5,"_95":96,"_18":53,"_97":98,"_99":25},{"_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,"_121":250,"_251":252,"_253":254,"_255":25,"_256":25,"_257":25,"_258":119,"_259":-5,"_260":-7,"_261":-7,"_262":59,"_263":25,"_264":25,"_265":-5,"_266":25,"_267":25,"_268":25,"_269":-5},"ENV",{"_221":222,"_223":224,"_225":83,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237,"_238":239,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249},"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 · v8