[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_213":214,"_215":216},"routes/_app.x.$handle.$name",{"_93":92,"_32":44,"_101":83,"_27":36,"_13":14,"_102":-5,"_11":103,"_104":105,"_106":107,"_108":109,"_110":111,"_20":-5,"_112":-5,"_113":-5,"_114":26,"_115":116,"_117":24,"_118":-5,"_119":-5,"_120":121},"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":26,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":-5,"_55":26,"_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":26},"version",2,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":26,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":26},"previous","deleted",true,"deletedHere",false,"path","new-file-83.ts","latestPath","fileId","62983e32-32c9-11f1-a0a4-42dde27851f2","name","fileType","script","content","","createdAt",["D",1775597594905],"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":26},"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":209,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":-5,"_55":26,"_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":210,"_77":211,"_79":212,"_81":26},"tree",[176,178,179,180,181,182],"files",[176,177,178,179,180,181,182],"counts",{"_166":59,"_167":132,"_168":59,"_169":170,"_171":172},"contents",[122,123,124,125,126,127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":160,"_32":161,"_30":162,"_131":-5,"_40":41,"_39":132,"_133":24,"_37":163,"_13":59,"_33":164,"_35":-5,"_23":26,"_137":-5,"_27":165},{"_42":155,"_32":156,"_30":157,"_131":-5,"_40":41,"_39":132,"_133":24,"_37":158,"_13":59,"_33":34,"_35":36,"_23":26,"_137":-5,"_27":159},{"_42":152,"_32":28,"_30":31,"_131":-5,"_40":41,"_39":14,"_133":26,"_37":153,"_13":59,"_33":34,"_35":36,"_23":26,"_137":-5,"_27":154},{"_42":145,"_32":146,"_30":147,"_131":-5,"_40":41,"_39":132,"_133":24,"_37":148,"_13":59,"_33":149,"_35":150,"_23":26,"_137":-5,"_27":151},{"_42":139,"_32":140,"_30":141,"_131":-5,"_40":41,"_39":132,"_133":24,"_37":142,"_13":59,"_33":135,"_35":143,"_23":26,"_137":-5,"_27":144},{"_42":128,"_32":129,"_30":130,"_131":-5,"_40":41,"_39":132,"_133":24,"_37":134,"_13":59,"_33":135,"_35":136,"_23":26,"_137":-5,"_27":138},"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",[129],"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}",[140],"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}",[146],"62983d56-32c9-11f1-a0a4-42dde27851f2",["D",1775597594905],[28],"1a3c6104-32c9-11f1-b67e-42dde27851f2","main.ts","019d69db-4edb-71aa-bf6a-361ec37c5ea2",["D",1775597473119],[156],"1a3c5f4c-32c9-11f1-b67e-42dde27851f2","lib","019d69db-4edb-71aa-bf6a-31b6e3588e65",["D",1775597473119],"directory",[161],"pulls","branches","forks","envVars",{"_173":59,"_175":59},"connections",{"_173":59,"_174":59},"count","unfilledCount","emptyCount",{"_42":160,"_32":161,"_30":162,"_131":-5,"_40":41,"_39":132,"_133":24,"_37":206,"_13":59,"_33":164,"_35":-5,"_23":26,"_137":-5,"_184":207,"_27":208},{"_42":199,"_32":200,"_30":201,"_131":162,"_40":41,"_39":132,"_133":26,"_37":202,"_13":59,"_33":34,"_35":203,"_23":26,"_137":-5,"_184":204,"_27":205},{"_42":155,"_32":156,"_30":157,"_131":-5,"_40":41,"_39":132,"_133":24,"_37":196,"_13":59,"_33":34,"_35":36,"_23":26,"_137":-5,"_184":197,"_27":198},{"_42":152,"_32":28,"_30":31,"_131":-5,"_40":41,"_39":14,"_133":26,"_37":193,"_13":59,"_33":34,"_35":36,"_23":26,"_137":-5,"_184":194,"_27":195},{"_42":145,"_32":146,"_30":147,"_131":-5,"_40":41,"_39":132,"_133":24,"_37":190,"_13":59,"_33":149,"_35":150,"_23":26,"_137":-5,"_184":191,"_27":192},{"_42":139,"_32":140,"_30":141,"_131":-5,"_40":41,"_39":132,"_133":24,"_37":187,"_13":59,"_33":135,"_35":143,"_23":26,"_137":-5,"_184":188,"_27":189},{"_42":128,"_32":129,"_30":130,"_131":-5,"_40":41,"_39":132,"_133":24,"_37":183,"_13":59,"_33":135,"_35":136,"_23":26,"_137":-5,"_184":185,"_27":186},["D",1775597473119],"children",[],[129],["D",1775597473119],[],[140],["D",1775597473119],[],[146],["D",1775597594905],[],[28],["D",1775597473119],[],[156],"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}",[],[161,200],["D",1775597473119],[177],[161],["D",1775597473119],{"_93":92,"_100":96},{"_93":92,"_94":-5,"_95":96,"_18":53,"_97":98,"_99":26},{"_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,"_119":246,"_247":248,"_249":250,"_251":26,"_252":26,"_253":26,"_254":24,"_255":-5,"_256":-7,"_257":-7,"_258":59,"_259":26,"_260":26,"_261":-5,"_262":26,"_263":26,"_264":26,"_265":-5},"ENV",{"_217":218,"_219":220,"_221":83,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237,"_238":239,"_240":241,"_242":243,"_244":245},"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 · v2