[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_218":219,"_220":221},"routes/_app.x.$handle.$name",{"_125":124,"_36":76,"_133":115,"_31":61,"_13":14,"_134":-5,"_11":135,"_136":137,"_138":139,"_140":141,"_142":143,"_25":-5,"_144":-5,"_145":-5,"_146":29,"_147":148,"_149":150,"_151":-5,"_152":-5,"_153":154},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_74":75,"_36":76,"_41":77,"_78":-5,"_79":29,"_80":81,"_82":81,"_83":-5,"_84":-5,"_18":85,"_86":-5,"_87":29,"_88":-5,"_89":-5,"_90":91,"_92":93,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":99,"_100":99,"_101":102,"_103":102,"_104":102,"_105":99,"_106":99,"_107":108,"_109":110,"_111":112,"_113":29},"version",1,"changes",[19,20,21,22,23,24],"aiChatInfo","userId",{"_25":68,"_27":-7,"_28":29,"_30":29,"_31":69,"_33":69},{"_25":63,"_27":-7,"_28":29,"_30":29,"_31":64,"_33":64},{"_25":57,"_27":-7,"_28":29,"_30":29,"_31":58,"_33":58},{"_25":51,"_27":-7,"_28":29,"_30":29,"_31":52,"_33":52},{"_25":46,"_27":-7,"_28":29,"_30":29,"_31":47,"_33":47},{"_25":26,"_27":-7,"_28":29,"_30":29,"_31":32,"_33":32},"file",{"_34":35,"_36":32,"_37":38,"_39":40,"_41":42,"_43":14,"_44":45,"_28":29},"previous","deleted",false,"deletedHere","path","zappiCronOn.ts","latestPath","fileId","019d69db-4edb-71aa-bf6a-41017e07a8ee","name","fileType","interval","content","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}","createdAt",["D",1775597473119],"branchVersion","branchId","1a2c1a2e-32c9-11f1-b67e-42dde27851f2",{"_34":48,"_36":47,"_37":38,"_39":49,"_41":50,"_43":14,"_44":45,"_28":29},"zappiCronOff.ts","019d69db-4edb-71aa-bf6a-3c371bcf34d0","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}",["D",1775597473119],{"_34":53,"_36":52,"_37":54,"_39":55,"_41":56,"_43":14,"_44":45,"_28":29},"zappiApi.ts","019d69db-4edb-71aa-bf6a-3ac0e6cafbdb","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}",["D",1775597473119],{"_34":59,"_36":58,"_37":60,"_39":61,"_41":62,"_43":14,"_44":45,"_28":29},"main.ts","019d69db-4edb-71aa-bf6a-361ec37c5ea2","script","",["D",1775597473119],{"_34":65,"_36":64,"_37":66,"_39":-5,"_41":67,"_43":14,"_44":45,"_28":29},"lib","019d69db-4edb-71aa-bf6a-31b6e3588e65","directory",["D",1775597473119],{"_34":70,"_36":71,"_37":60,"_39":72,"_41":73,"_43":14,"_44":45,"_28":29},"lib/myenergi.ts","019d69db-4edb-71aa-bf6a-2fadde21fc1e","myenergi.ts","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}",["D",1775597473119],"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",{"_125":124,"_132":128},"org",{"_125":124,"_126":-5,"_127":128,"_18":85,"_129":130,"_131":29},"branch",{"_13":114,"_36":115,"_74":45,"_116":75,"_117":-5,"_118":-5,"_119":-5,"_120":-5,"_121":-5,"_122":76,"_123":124},"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",{"_74":75,"_36":76,"_41":214,"_78":-5,"_79":29,"_80":81,"_82":81,"_83":-5,"_84":-5,"_18":85,"_86":-5,"_87":29,"_88":-5,"_89":-5,"_90":91,"_92":93,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":99,"_100":99,"_101":102,"_103":102,"_104":102,"_105":99,"_106":99,"_107":215,"_109":216,"_111":217,"_113":29},"tree",[188,190,191,192,193],"files",[188,189,190,191,192,193],"counts",{"_178":91,"_179":14,"_180":91,"_181":182,"_183":184},"contents",[155,156,157,158,159],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_74":175,"_36":64,"_34":65,"_161":-5,"_44":45,"_43":14,"_162":150,"_41":176,"_13":91,"_37":66,"_39":-5,"_28":29,"_164":-5,"_31":177},{"_74":172,"_36":58,"_34":59,"_161":-5,"_44":45,"_43":14,"_162":150,"_41":173,"_13":91,"_37":60,"_39":61,"_28":29,"_164":-5,"_31":174},{"_74":169,"_36":52,"_34":53,"_161":-5,"_44":45,"_43":14,"_162":150,"_41":170,"_13":91,"_37":54,"_39":55,"_28":29,"_164":-5,"_31":171},{"_74":166,"_36":47,"_34":48,"_161":-5,"_44":45,"_43":14,"_162":150,"_41":167,"_13":91,"_37":38,"_39":49,"_28":29,"_164":-5,"_31":168},{"_74":160,"_36":32,"_34":35,"_161":-5,"_44":45,"_43":14,"_162":150,"_41":163,"_13":91,"_37":38,"_39":40,"_28":29,"_164":-5,"_31":165},"1a3c7130-32c9-11f1-b67e-42dde27851f2","parentId","latest",["D",1775597473119],"label",[32],"1a3c6e56-32c9-11f1-b67e-42dde27851f2",["D",1775597473119],[47],"1a3c62a8-32c9-11f1-b67e-42dde27851f2",["D",1775597473119],[52],"1a3c6104-32c9-11f1-b67e-42dde27851f2",["D",1775597473119],[58],"1a3c5f4c-32c9-11f1-b67e-42dde27851f2",["D",1775597473119],[64],"pulls","branches","forks","envVars",{"_185":91,"_187":91},"connections",{"_185":91,"_186":91},"count","unfilledCount","emptyCount",{"_74":175,"_36":64,"_34":65,"_161":-5,"_44":45,"_43":14,"_162":150,"_41":211,"_13":91,"_37":66,"_39":-5,"_28":29,"_164":-5,"_195":212,"_31":213},{"_74":207,"_36":71,"_34":70,"_161":65,"_44":45,"_43":14,"_162":29,"_41":208,"_13":91,"_37":60,"_39":72,"_28":29,"_164":-5,"_195":209,"_31":210},{"_74":172,"_36":58,"_34":59,"_161":-5,"_44":45,"_43":14,"_162":150,"_41":204,"_13":91,"_37":60,"_39":61,"_28":29,"_164":-5,"_195":205,"_31":206},{"_74":169,"_36":52,"_34":53,"_161":-5,"_44":45,"_43":14,"_162":150,"_41":201,"_13":91,"_37":54,"_39":55,"_28":29,"_164":-5,"_195":202,"_31":203},{"_74":166,"_36":47,"_34":48,"_161":-5,"_44":45,"_43":14,"_162":150,"_41":198,"_13":91,"_37":38,"_39":49,"_28":29,"_164":-5,"_195":199,"_31":200},{"_74":160,"_36":32,"_34":35,"_161":-5,"_44":45,"_43":14,"_162":150,"_41":194,"_13":91,"_37":38,"_39":40,"_28":29,"_164":-5,"_195":196,"_31":197},["D",1775597473119],"children",[],[32],["D",1775597473119],[],[47],["D",1775597473119],[],[52],["D",1775597473119],[],[58],"1a3c2de2-32c9-11f1-b67e-42dde27851f2",["D",1775597473119],[],[64,71],["D",1775597473119],[189],[64],["D",1775597473119],{"_125":124,"_132":128},{"_125":124,"_126":-5,"_127":128,"_18":85,"_129":130,"_131":29},{"_13":114,"_36":115,"_74":45,"_116":75,"_117":-5,"_118":-5,"_119":-5,"_120":-5,"_121":-5,"_122":76,"_123":124},"ctx",{"_107":-5,"_152":251,"_252":253,"_254":255,"_256":29,"_257":29,"_258":29,"_259":150,"_260":-5,"_261":-7,"_262":-7,"_263":91,"_264":29,"_265":29,"_266":-5,"_267":29,"_268":29,"_269":29,"_270":-5},"ENV",{"_222":223,"_224":225,"_226":115,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v1