[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_237":238,"_239":240},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_178":-5,"_20":179,"_22":180,"_181":182,"_183":184,"_26":185,"_24":186,"_187":-5,"_188":-5,"_189":55,"_190":191,"_192":46,"_193":-5,"_194":-5,"_195":196},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5,"_32":-5},"handle","garmeeh","name","MyEnergi","branchName","main","version","path","lib","project",{"_34":125,"_13":14,"_47":126,"_127":-5,"_128":55,"_129":130,"_131":130,"_132":-5,"_133":-5,"_134":135,"_136":-5,"_137":55,"_138":-5,"_139":-5,"_140":60,"_141":142,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":148,"_149":148,"_150":151,"_152":151,"_153":151,"_154":148,"_155":148,"_156":157,"_158":159,"_160":161,"_162":55},"tree",[63,64,65,66,67,68,69],"file",{"_34":58,"_13":19,"_37":40,"_39":-5,"_41":42,"_43":49,"_45":46,"_47":59,"_17":60,"_50":61,"_52":-5,"_54":55,"_56":-5,"_18":62},"contents",[33],"upstream","pull","ahead","behind","envVars",{"_34":35,"_13":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_17":49,"_50":51,"_52":53,"_54":55,"_56":-5,"_18":57},"id","e7ac40c4-39cb-11f1-ad41-42b51c65c3df","myenergi.ts","fileId","019d69db-4edb-71aa-bf6a-2fadde21fc1e","parentId","019d69db-4edb-71aa-bf6a-31b6e3588e65","branchId","1a2c1a2e-32c9-11f1-b67e-42dde27851f2","branchVersion",9,"latest",true,"createdAt",["D",1776368335290],1,"fileType","script","content","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}","deleted",false,"label",[19,36],"1a3c5f4c-32c9-11f1-b67e-42dde27851f2",["D",1775597473119],0,"directory",[19],{"_34":58,"_13":19,"_37":40,"_39":-5,"_41":42,"_43":49,"_45":46,"_47":118,"_17":60,"_50":61,"_52":-5,"_54":55,"_56":-5,"_76":119,"_18":120},{"_34":110,"_13":111,"_37":112,"_39":-5,"_41":42,"_43":113,"_45":46,"_47":114,"_17":106,"_50":24,"_52":115,"_54":55,"_56":-5,"_76":116,"_18":117},{"_34":101,"_13":102,"_37":103,"_39":-5,"_41":42,"_43":104,"_45":46,"_47":105,"_17":106,"_50":90,"_52":107,"_54":55,"_56":-5,"_76":108,"_18":109},{"_34":94,"_13":95,"_37":96,"_39":-5,"_41":42,"_43":49,"_45":46,"_47":97,"_17":60,"_50":51,"_52":98,"_54":55,"_56":-5,"_76":99,"_18":100},{"_34":86,"_13":87,"_37":88,"_39":-5,"_41":42,"_43":49,"_45":46,"_47":89,"_17":60,"_50":90,"_52":91,"_54":55,"_56":-5,"_76":92,"_18":93},{"_34":79,"_13":80,"_37":81,"_39":-5,"_41":42,"_43":49,"_45":46,"_47":82,"_17":60,"_50":74,"_52":83,"_54":55,"_56":-5,"_76":84,"_18":85},{"_34":70,"_13":71,"_37":72,"_39":-5,"_41":42,"_43":49,"_45":46,"_47":73,"_17":60,"_50":74,"_52":75,"_54":55,"_56":-5,"_76":77,"_18":78},"1a3c7130-32c9-11f1-b67e-42dde27851f2","zappiCronOn.ts","019d69db-4edb-71aa-bf6a-41017e07a8ee",["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}","children",[],[71],"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}",[],[80],"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}",[],[87],"1a3c6104-32c9-11f1-b67e-42dde27851f2","main.ts","019d69db-4edb-71aa-bf6a-361ec37c5ea2",["D",1775597473119],"",[],[95],"910f6dfc-39cd-11f1-abb6-42b51c65c3df","eddiApi.ts","f3ccba64-39cb-11f1-a1d1-42b51c65c3df",15,["D",1776369048976],5,"import {\n getEddiStatus,\n getEddiTemperature,\n handleEddiEvent,\n isAuthorized,\n startEddiBoost,\n stopEddiBoost,\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\nfunction parseTarget(value: unknown): 1 | 2 | 11 | 12 | undefined {\n return value === 1 || value === 2 || value === 11 || value === 12\n ? value\n : undefined;\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: \"eddi-control\",\n routes: [\n \"GET /api/eddi/status\",\n \"GET /api/eddi/temperature\",\n \"POST /api/eddi/boost/start\",\n \"POST /api/eddi/boost/stop\",\n \"POST /api/events\",\n ],\n auth: \"Authorization: Bearer or x-api-key header\",\n targets: {\n 1: \"Heater 1\",\n 2: \"Heater 2\",\n 11: \"Relay 1\",\n 12: \"Relay 2\",\n },\n });\n }\n\n if (path.startsWith(\"/api/\") && !isAuthorized(req)) {\n return unauthorizedResponse();\n }\n\n try {\n if (path === \"/api/eddi/status\" && method === \"GET\") {\n return json(await getEddiStatus());\n }\n\n if (path === \"/api/eddi/temperature\" && method === \"GET\") {\n return json(await getEddiTemperature());\n }\n\n if (path === \"/api/eddi/boost/start\" && method === \"POST\") {\n const body = await readJson(req);\n\n const target = body && typeof body === \"object\"\n ? parseTarget((body as { target?: unknown }).target)\n : undefined;\n\n const durationMinutes = body &&\n typeof body === \"object\" &&\n typeof (body as { durationMinutes?: unknown }).durationMinutes ===\n \"number\"\n ? Math.floor((body as { durationMinutes: number }).durationMinutes)\n : undefined;\n\n return json(await startEddiBoost({ target, durationMinutes }));\n }\n\n if (path === \"/api/eddi/boost/stop\" && method === \"POST\") {\n const body = await readJson(req);\n\n const target = body && typeof body === \"object\"\n ? parseTarget((body as { target?: unknown }).target)\n : undefined;\n\n return json(await stopEddiBoost({ target }));\n }\n\n if (path === \"/api/events\" && method === \"POST\") {\n const body = await readJson(req);\n return json(await handleEddiEvent(body));\n }\n\n return json({ ok: false, error: \"Not found\" }, 404);\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}",[],[102],"e5cd11ea-39ce-11f1-b853-42b51c65c3df","README.md","968ed912-32c9-11f1-a726-42dde27851f2",16,["D",1776369620652],"# Automate MyEnergi\n\nA Val Town project for automating myenergi **Zappi** and **Eddi** devices using\nthe raw myenergi API. It includes secure API endpoints, scheduled cron jobs, and\nexamples for turning Zappi charging on or off, changing charge modes, reading\nEddi temperature, triggering Eddi boosts, and building custom myenergi\nautomation workflows.\n\nYou will need the following environment variables:\n\n```\nMYENERGI_HUB_SERIAL=\nMYENERGI_API_KEY=\nMYENERGI_API_TOKEN=\nZAPPI_SERIAL=\nZAPPI_CRON_ON_MODE=eco_plus\nZAPPI_DEFAULT_ON_MODE=eco_plus\nEDDI_SERIAL=\nEDDI_DEFAULT_TARGET=1\n```\n\nSet the cron/default mode to your preferred setting. `EDDI_DEFAULT_TARGET`\ncontrols which heater/relay output is used when a boost call doesn't specify one\n(`1` = Heater 1, `2` = Heater 2, `11` = Relay 1, `12` = Relay 2).\n\n`ZAPPI_SERIAL` and `EDDI_SERIAL` are each optional — set whichever devices you\nactually have. Calls to an endpoint for a device you haven't configured will\nreturn an error.\n\n`lib/myenergi.ts` = reusable myenergi client and auth logic. `zappiApi.ts` and\n`eddiApi.ts` = the HTTP API layers. You can call these from workflows, telegram\nbots etc, or use the existing cron files to run on a schedule. There is two cron\nfiles for Zappi. You can reference these for Eddi if needed.\n\n# myenergi API notes for Zappi and Eddi automation\n\n## Overview\n\nThis project integrates with the **myenergi API** to automate **Zappi** chargers\nand **Eddi** hot water diverters.\n\nAt the time of writing, myenergi says the API **exists but is not officially\nsupported** and was originally developed for internal use. Their help centre\ndirects developers to the community forum for help and examples.\n\nThis README focuses on the parts needed for simple Zappi and Eddi 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** (if using a Zappi)\n- your **Eddi serial number** (if using an Eddi)\n\nIn this project, those are typically stored as:\n\n- `MYENERGI_HUB_SERIAL`\n- `MYENERGI_API_KEY`\n- `ZAPPI_SERIAL`\n- `EDDI_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\n 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\n devices. If you do not see the **Advanced** option, myenergi says you are\n 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**\nplus 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\n 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## Eddi serial\n\nFor a standard Eddi, the serial number can be found:\n\n- on the **label on the 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\nserial number as the device** acting as vHub, which can make the hub/device\ndistinction a bit confusing.\n\n---\n\n## Authentication\n\nThe raw API flow commonly used by community integrations uses **HTTP Digest\nAuthentication** 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`\nresponse header to determine the correct backend host. This is commonly used\nbecause 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\nparts relevant to Zappi and Eddi 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\ndevices 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### Specific Eddi\n\n`/cgi-jstatus-E`\n\nExample:\n\n`/cgi-jstatus-E20088888`\n\nThis is the most useful status endpoint for a single-Eddi 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### Common Eddi fields\n\nFrom the documented community response structure, common fields include:\n\n- `sno` = serial number\n- `bsm` = boost state (`1` = boosting)\n- `tp1` = temperature probe 1 (°C, `127` means \"not connected\")\n- `tp2` = temperature probe 2 (°C, `127` means \"not connected\")\n- `rbc` = relay board connected\n- `r1a` / `r2a` = relay 1 / relay 2 active\n- `r1b` / `r2b` = relay 1 / relay 2 boost type\n- `dat` / `tim` = device date and time\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\nreference.\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) Zappi 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) Eddi boost endpoints\n\nEddi boosts use a separate endpoint shape that takes a target output and a\nduration in minutes.\n\n### Start boost\n\n`/cgi-eddi-boost-E-10--`\n\nExample — boost Heater 1 for 60 minutes:\n\n`/cgi-eddi-boost-E20088888-10-1-60`\n\n### Stop boost\n\n`/cgi-eddi-boost-E-1--0`\n\n### Target mapping\n\nCommunity documentation maps the target parameter to:\n\n- `1` = Heater 1\n- `2` = Heater 2\n- `11` = Relay 1\n- `12` = Relay 2\n\nSuccessful boost calls return the same `{ \"status\": 0, \"statustext\": \"\" }` shape\nas Zappi control calls.\n\n---\n\n## 5) 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\nExamples:\n\n- `/cgi-jdayhour-Z-YYYY-M-D`\n- `/cgi-jdayhour-E-YYYY-M-D`\n\nThese are more useful for reporting and analysis than for simple device 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\n```bash\ncurl --digest -u HUB_SERIAL:API_KEY \\\n -H 'accept: application/json' \\\n 'https://HOST/cgi-jstatus-EEDDI_SERIAL'\n```\n\nThis matches myenergi's official guidance that access uses the hub serial and\nAPI 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=\nEDDI_SERIAL=\n```\n\nThese values come from the official myenergi account/device flow described\nabove. Set only the device serials you actually have.\n\nIf your service exposes its own HTTP endpoint, you will usually also add your\nown app-level secret, for example:\n\n```text\nMYENERGI_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\n come from community reverse-engineering rather than a polished supported\n 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\n gateway/device relationship may not be obvious.\n- Eddi temperature probes report `127` when no probe is connected — treat that\n as \"unavailable\" rather than a real reading.\n- Because the API is unsupported, it is safest to treat undocumented behaviour\n as subject to change. That last point is an inference from myenergi's support\n position.\n\n---\n\n## Summary\n\nFor simple Zappi and Eddi automation, the minimum useful setup is:\n\n- hub / gateway serial\n- API key\n- Zappi and/or Eddi serial\n- Digest auth\n- `cgi-jstatus-Z` / `cgi-jstatus-E` for reads\n- `cgi-zappi-mode-Z-...` for Zappi mode changes\n- `cgi-eddi-boost-E-...` for Eddi boosts",[],[111],["D",1775597473119],[121],[19],{"_34":35,"_13":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":122,"_17":49,"_50":51,"_52":53,"_54":55,"_56":-5,"_76":123,"_18":124},["D",1776368335290],[],[19,36],"1a08ce70-32c9-11f1-b67e-42dde27851f2",["D",1775597473119],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","019d1cc1-92fb-71ad-9b61-d5698079c76c","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019d1cc1-92fb-71ad-9b61-db35e95292d3","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_177":173},"org",{"_11":12,"_171":-5,"_172":173,"_134":135,"_174":175,"_176":55},"branch",{"_17":113,"_13":16,"_34":42,"_163":125,"_164":-5,"_165":-5,"_166":-5,"_167":-5,"_168":-5,"_169":14,"_170":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zQk1mY1NxVmY4UkxBZFVYcTJFcm9zR3RoYkYifQ","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_34":125,"_13":14,"_47":233,"_127":-5,"_128":55,"_129":130,"_131":130,"_132":-5,"_133":-5,"_134":135,"_136":-5,"_137":55,"_138":-5,"_139":-5,"_140":60,"_141":142,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":148,"_149":148,"_150":151,"_152":151,"_153":151,"_154":148,"_155":148,"_156":234,"_158":235,"_160":236,"_162":55},[209,211,212,213,214,215,216],"files",[209,210,211,212,213,214,215,216],"counts",{"_200":60,"_201":49,"_202":60,"_32":203,"_204":205},[198],{"_34":58,"_13":19,"_37":40,"_39":-5,"_41":42,"_43":49,"_45":46,"_47":59,"_17":60,"_50":61,"_52":-5,"_54":55,"_56":-5,"_18":197},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},[19],{"_34":35,"_13":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_17":49,"_50":51,"_52":53,"_54":55,"_56":-5,"_18":199},[19,36],"pulls","branches","forks",{"_206":60,"_208":60},"connections",{"_206":60,"_207":60},"count","unfilledCount","emptyCount",{"_34":58,"_13":19,"_37":40,"_39":-5,"_41":42,"_43":49,"_45":46,"_47":118,"_17":60,"_50":61,"_52":-5,"_54":55,"_56":-5,"_76":231,"_18":232},{"_34":35,"_13":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":122,"_17":49,"_50":51,"_52":53,"_54":55,"_56":-5,"_76":229,"_18":230},{"_34":110,"_13":111,"_37":112,"_39":-5,"_41":42,"_43":113,"_45":46,"_47":114,"_17":106,"_50":24,"_52":115,"_54":55,"_56":-5,"_76":227,"_18":228},{"_34":101,"_13":102,"_37":103,"_39":-5,"_41":42,"_43":104,"_45":46,"_47":105,"_17":106,"_50":90,"_52":107,"_54":55,"_56":-5,"_76":225,"_18":226},{"_34":94,"_13":95,"_37":96,"_39":-5,"_41":42,"_43":49,"_45":46,"_47":97,"_17":60,"_50":51,"_52":98,"_54":55,"_56":-5,"_76":223,"_18":224},{"_34":86,"_13":87,"_37":88,"_39":-5,"_41":42,"_43":49,"_45":46,"_47":89,"_17":60,"_50":90,"_52":91,"_54":55,"_56":-5,"_76":221,"_18":222},{"_34":79,"_13":80,"_37":81,"_39":-5,"_41":42,"_43":49,"_45":46,"_47":82,"_17":60,"_50":74,"_52":83,"_54":55,"_56":-5,"_76":219,"_18":220},{"_34":70,"_13":71,"_37":72,"_39":-5,"_41":42,"_43":49,"_45":46,"_47":73,"_17":60,"_50":74,"_52":75,"_54":55,"_56":-5,"_76":217,"_18":218},[],[71],[],[80],[],[87],[],[95],[],[102],[],[111],[],[19,36],[210],[19],["D",1775597473119],{"_11":12,"_177":173},{"_11":12,"_171":-5,"_172":173,"_134":135,"_174":175,"_176":55},{"_17":113,"_13":16,"_34":42,"_163":125,"_164":-5,"_165":-5,"_166":-5,"_167":-5,"_168":-5,"_169":14,"_170":12},"ctx",{"_156":-5,"_194":270,"_271":272,"_273":274,"_275":55,"_276":55,"_277":55,"_278":46,"_279":-5,"_280":-7,"_281":-7,"_282":60,"_283":55,"_284":55,"_285":-5,"_286":55,"_287":55,"_288":55,"_289":-5},"ENV",{"_241":242,"_243":244,"_245":16,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263,"_264":265,"_266":267,"_268":269},"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"]