🔍 JSON Endpoint Tracker

\n view source\n

Add Endpoint

\n \n \n \n \n

\n\n \n \n",[],[148,189],["D",1775709431907],[174],[148],"85b4e1c6-3428-11f1-baa5-42b51c65c3df","queries.ts","366e7a14-33ce-11f1-8aa1-42b51c65c3df",13,["D",1775748407159],4,"script","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nexport interface Endpoint {\n id: number;\n name: string;\n url: string;\n alert_email: string | null;\n created_at: string;\n}\n\nexport interface Check {\n id: number;\n endpoint_id: number;\n status: number;\n response_time_ms: number;\n is_valid_json: number;\n response_body: string | null;\n changed: number;\n error: string | null;\n checked_at: string;\n}\n\nexport async function getAllEndpoints(): Promise {\n const res = await sqlite.execute(`SELECT * FROM endpoints ORDER BY created_at DESC`);\n return res.rows as unknown as Endpoint[];\n}\n\nexport async function getEndpointById(id: number): Promise {\n const res = await sqlite.execute({ sql: `SELECT * FROM endpoints WHERE id = ?`, args: [id] });\n return (res.rows as unknown as Endpoint[])[0] ?? null;\n}\n\nexport async function getLatestCheck(endpointId: number): Promise {\n const res = await sqlite.execute({\n sql: `SELECT * FROM checks WHERE endpoint_id = ? ORDER BY checked_at DESC LIMIT 1`,\n args: [endpointId],\n });\n return (res.rows as unknown as Check[])[0] ?? null;\n}\n\nexport async function getCheckHistory(endpointId: number, limit = 20): Promise {\n const res = await sqlite.execute({\n sql: `SELECT * FROM checks WHERE endpoint_id = ? ORDER BY checked_at DESC LIMIT ?`,\n args: [endpointId, limit],\n });\n return res.rows as unknown as Check[];\n}\n\nexport async function performCheck(endpoint: Endpoint): Promise {\n const start = Date.now();\n let status = 0;\n let isValidJson = false;\n let responseBody: string | null = null;\n let errorMsg: string | null = null;\n\n try {\n const res = await fetch(endpoint.url, { signal: AbortSignal.timeout(8000) });\n status = res.status;\n const elapsed = Date.now() - start;\n const text = await res.text();\n try {\n JSON.parse(text);\n isValidJson = true;\n responseBody = text;\n } catch {\n responseBody = text.slice(0, 2000); // store first 2kb even if invalid\n }\n\n // Compare with last check to detect changes\n const prev = await getLatestCheck(endpoint.id);\n const changed = prev && prev.response_body !== null && isValidJson\n ? (prev.response_body !== responseBody ? 1 : 0)\n : 0;\n\n const ins = await sqlite.execute({\n sql: `INSERT INTO checks (endpoint_id, status, response_time_ms, is_valid_json, response_body, changed, error)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [endpoint.id, status, elapsed, isValidJson ? 1 : 0, responseBody, changed, null],\n });\n\n const check: Check = {\n id: Number(ins.lastInsertRowid),\n endpoint_id: endpoint.id,\n status,\n response_time_ms: elapsed,\n is_valid_json: isValidJson ? 1 : 0,\n response_body: responseBody,\n changed,\n error: null,\n checked_at: new Date().toISOString(),\n };\n\n // Send alert if changed and alert_email configured\n if (changed && endpoint.alert_email) {\n await sendChangeAlert(endpoint, check, prev!);\n }\n\n return check;\n } catch (e: any) {\n errorMsg = e.message;\n const elapsed = Date.now() - start;\n const ins = await sqlite.execute({\n sql: `INSERT INTO checks (endpoint_id, status, response_time_ms, is_valid_json, response_body, changed, error)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [endpoint.id, 0, elapsed, 0, null, 0, errorMsg],\n });\n\n const prev = await getLatestCheck(endpoint.id);\n const wasUp = prev && !prev.error;\n if (wasUp && endpoint.alert_email) {\n await sendDownAlert(endpoint, errorMsg);\n }\n\n return {\n id: Number(ins.lastInsertRowid),\n endpoint_id: endpoint.id,\n status: 0,\n response_time_ms: elapsed,\n is_valid_json: 0,\n response_body: null,\n changed: 0,\n error: errorMsg,\n checked_at: new Date().toISOString(),\n };\n }\n}\n\nasync function sendChangeAlert(endpoint: Endpoint, check: Check, prev: Check) {\n const prevParsed = tryParse(prev.response_body);\n const newParsed = tryParse(check.response_body);\n await email({\n to: endpoint.alert_email!,\n subject: `[JSON Tracker] Change detected: ${endpoint.name}`,\n text: [\n `A change was detected in the JSON response for: ${endpoint.name}`,\n `URL: ${endpoint.url}`,\n `Checked at: ${check.checked_at}`,\n ``,\n `--- Previous response ---`,\n JSON.stringify(prevParsed, null, 2),\n ``,\n `--- New response ---`,\n JSON.stringify(newParsed, null, 2),\n ].join(\"\\n\"),\n });\n}\n\nasync function sendDownAlert(endpoint: Endpoint, error: string) {\n await email({\n to: endpoint.alert_email!,\n subject: `[JSON Tracker] Endpoint down: ${endpoint.name}`,\n text: [\n `Endpoint is unreachable: ${endpoint.name}`,\n `URL: ${endpoint.url}`,\n `Error: ${error}`,\n `Time: ${new Date().toISOString()}`,\n ].join(\"\\n\"),\n });\n}\n\nfunction tryParse(body: string | null | undefined) {\n if (!body) return null;\n try { return JSON.parse(body); } catch { return body; }\n}\n",[],[155,199],"2b5ef374-33ce-11f1-96e9-42b51c65c3df","migrations.ts","2b5ef41e-33ce-11f1-96e9-42b51c65c3df",["D",1775709600896],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function runMigrations() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS endpoints (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n url TEXT NOT NULL,\n alert_email TEXT,\n created_at TEXT DEFAULT (datetime('now'))\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS checks (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n endpoint_id INTEGER,\n status INTEGER,\n response_time_ms INTEGER,\n is_valid_json INTEGER,\n response_body TEXT,\n changed INTEGER DEFAULT 0,\n error TEXT,\n checked_at TEXT DEFAULT (datetime('now'))\n )\n `);\n\n // Migrate existing endpoints table: add alert_email if missing\n try {\n await sqlite.execute(`ALTER TABLE endpoints ADD COLUMN alert_email TEXT`);\n } catch { /* column already exists */ }\n\n // Migrate existing checks table: add response_body if missing\n try {\n await sqlite.execute(`ALTER TABLE checks ADD COLUMN response_body TEXT`);\n } catch { /* column already exists */ }\n\n // Migrate existing checks table: add changed if missing\n try {\n await sqlite.execute(`ALTER TABLE checks ADD COLUMN changed INTEGER DEFAULT 0`);\n } catch { /* column already exists */ }\n}\n",[],[155,209],["D",1775709600896],[171,172],[155],["D",1775709144649],["D",1789464074488],{"_16":17,"_86":82},{"_16":17,"_80":-5,"_81":82,"_33":34,"_83":84,"_85":26},{"_68":69,"_20":70,"_18":71,"_72":19,"_73":-5,"_74":-5,"_75":-5,"_76":-5,"_77":-5,"_78":21,"_79":17},"ctx",{"_61":-5,"_107":256,"_257":258,"_259":260,"_261":26,"_262":26,"_263":26,"_264":38,"_265":-5,"_266":-7,"_267":-7,"_268":42,"_269":26,"_270":26,"_271":-5,"_272":26,"_273":26,"_274":26,"_275":-5},"ENV",{"_227":228,"_229":230,"_231":70,"_232":233,"_234":235,"_236":237,"_238":239,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255},"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"]

Search