[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_107":108,"_109":110},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","plusjade","name","app-clarkview","path","lib/deviceStore.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":-5,"_61":44,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":73,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":85,"_86":87,"_88":89,"_90":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/plusjade/app-clarkview/code/lib/deviceStore.ts","extension","id","b251330c-043e-4860-99d1-960b66467e3d","deviceStore.ts","fileId","dbcd5358-a706-11f1-ac24-1607ee4eb77e","parentId","01a01c4d-2bf2-7199-84aa-883b3a9a9d0b","branchId","9635267c-e84d-4621-be8a-af9e5052d6d5","branchVersion",346,"latest",true,"createdAt",["D",1789505418345],"version",7,"fileType","script","content","// Device-centric persistence for browser inspection and source assignment.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { SourceKind } from \"./sourceStore.ts\";\nimport {\n parseStoredPresentation,\n type WidgetPresentation,\n} from \"./presentation.ts\";\n\nexport type DeviceSummary = {\n id: number;\n installId: string;\n name: string;\n createdAt: string;\n updatedAt: string;\n sourceCount: number;\n};\n\nexport type DeviceSourceView = {\n assignmentId: number;\n enabled: boolean;\n sourceId: number;\n kind: SourceKind;\n name: string;\n description: string;\n settings: unknown;\n settingsSchema: unknown;\n createdAt: string;\n updatedAt: string;\n};\n\nexport type DeviceDetail = DeviceSummary & {\n presentation: WidgetPresentation;\n tzOffsetSeconds: number | null;\n sources: DeviceSourceView[];\n};\n\nexport type AvailableSource = {\n id: number;\n kind: SourceKind;\n name: string;\n description: string;\n settingsSchema: unknown;\n};\n\nfunction parseJson(raw: string | null): unknown {\n if (raw == null) return {};\n try {\n return JSON.parse(raw);\n } catch {\n return raw;\n }\n}\n\nfunction nowIso(): string {\n return new Date().toISOString();\n}\n\nfunction mapSourceRow(row: {\n assignment_id: number;\n enabled: number;\n source_id: number;\n kind: SourceKind;\n name: string;\n description: string;\n settings: string;\n settings_schema: string;\n assignment_created_at: string;\n assignment_updated_at: string;\n}): DeviceSourceView {\n return {\n assignmentId: row.assignment_id,\n enabled: row.enabled === 1,\n sourceId: row.source_id,\n kind: row.kind,\n name: row.name,\n description: row.description,\n settings: parseJson(row.settings),\n settingsSchema: parseJson(row.settings_schema),\n createdAt: row.assignment_created_at,\n updatedAt: row.assignment_updated_at,\n };\n}\n\nexport async function listDevices(): Promise {\n const result = await sqlite.execute(`\n SELECT\n d.id, d.install_id, d.name, d.created_at, d.updated_at,\n COUNT(ds.id) AS source_count\n FROM devices d\n LEFT JOIN device_sources ds ON ds.device_id = d.id\n GROUP BY d.id\n ORDER BY d.name COLLATE NOCASE, d.id\n `);\n return (result.rows as {\n id: number; install_id: string; name: string; created_at: string;\n updated_at: string; source_count: number;\n }[]).map((row) => ({\n id: row.id,\n installId: row.install_id,\n name: row.name,\n createdAt: row.created_at,\n updatedAt: row.updated_at,\n sourceCount: Number(row.source_count),\n }));\n}\n\nexport async function getDevice(id: number): Promise {\n const result = await sqlite.execute({\n sql: `\n SELECT\n d.id, d.install_id, d.name, d.created_at, d.updated_at, d.presentation, d.last_tz_offset_seconds,\n ds.id AS assignment_id, ds.settings, ds.enabled,\n ds.created_at AS assignment_created_at,\n ds.updated_at AS assignment_updated_at,\n s.id AS source_id, s.kind, s.name AS source_name, s.description, s.settings_schema\n FROM devices d\n LEFT JOIN device_sources ds ON ds.device_id = d.id\n LEFT JOIN sources s ON s.id = ds.source_id\n WHERE d.id = ?\n ORDER BY s.id\n `,\n args: [id],\n });\n const rows = result.rows as {\n id: number; install_id: string; name: string; created_at: string; updated_at: string;\n presentation: string; last_tz_offset_seconds: number | null;\n assignment_id: number | null; settings: string | null; enabled: number;\n assignment_created_at: string | null; assignment_updated_at: string | null;\n source_id: number | null; kind: SourceKind | null; source_name: string | null; description: string | null;\n settings_schema: string | null;\n }[];\n const first = rows[0];\n if (!first) return null;\n\n const sources = rows.flatMap((row) => {\n if (\n row.assignment_id == null || row.source_id == null ||\n row.settings == null || row.assignment_created_at == null ||\n row.assignment_updated_at == null || row.kind == null ||\n row.description == null || row.settings_schema == null\n ) return [];\n return [mapSourceRow({\n assignment_id: row.assignment_id,\n enabled: row.enabled,\n source_id: row.source_id,\n kind: row.kind,\n name: row.source_name ?? row.kind,\n description: row.description,\n settings: row.settings,\n settings_schema: row.settings_schema,\n assignment_created_at: row.assignment_created_at,\n assignment_updated_at: row.assignment_updated_at,\n })];\n });\n\n return {\n id: first.id,\n installId: first.install_id,\n name: first.name,\n createdAt: first.created_at,\n updatedAt: first.updated_at,\n sourceCount: sources.length,\n presentation: parseStoredPresentation(first.presentation),\n tzOffsetSeconds: first.last_tz_offset_seconds,\n sources,\n };\n}\n\nexport async function getDeviceByInstallId(installId: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT id FROM devices WHERE install_id = ?\",\n args: [installId],\n });\n const row = result.rows[0] as { id: number } | undefined;\n return row ? getDevice(Number(row.id)) : null;\n}\n\n// The widget reports its offset on every resolve, so the parent infers it rather\n// than asking anyone to configure it. Reminders need it to compose the same items\n// the widget sees and to name a local clock time.\n//\n// Two properties matter here. It is conditional: resolve is the hot read path, and\n// an unconditional write would turn every widget refresh into one. And it is\n// best-effort: capturing a timezone must never fail a feed request.\nconst TZ_REFRESH_SECONDS = 6 * 60 * 60;\n\nexport async function recordDeviceTimeZone(\n installId: string,\n offsetSeconds: number | null,\n): Promise {\n if (offsetSeconds == null) return;\n const stale = new Date(Date.now() - TZ_REFRESH_SECONDS * 1000).toISOString();\n try {\n await sqlite.execute({\n sql: `UPDATE devices SET last_tz_offset_seconds = ?, last_tz_seen_at = ?\n WHERE install_id = ?\n AND (last_tz_offset_seconds IS NOT ?\n OR last_tz_seen_at IS NULL\n OR last_tz_seen_at < ?)`,\n args: [offsetSeconds, nowIso(), installId, offsetSeconds, stale],\n });\n } catch {\n // The columns arrive with the reminder schema; a feed read predating it still serves.\n }\n}\n\nexport async function renameDevice(id: number, name: string): Promise {\n const result = await sqlite.execute({\n sql: \"UPDATE devices SET name = ?, updated_at = ? WHERE id = ?\",\n args: [name, nowIso(), id],\n });\n return result.rowsAffected === 1;\n}\n\nexport type MergeDeviceResult =\n | { ok: true; targetId: number }\n | { ok: false; reason: \"origin\" | \"target\" | \"same\" };\n\n// A reinstalled app pairs into a fresh row, stranding the configuration the\n// person already built. Merging keeps the configured (target) row and moves the\n// live install id onto it, so assignments, presentation, name and browser URL\n// all survive; the origin row is dropped. The install id — not the row id — is\n// what the widget and the token tables key on, which is why adoption is enough.\nexport async function mergeDeviceInto(\n originId: number,\n targetId: number,\n): Promise {\n if (originId === targetId) return { ok: false, reason: \"same\" };\n\n const result = await sqlite.execute({\n sql: \"SELECT id, install_id FROM devices WHERE id IN (?, ?)\",\n args: [originId, targetId],\n });\n const rows = result.rows as { id: number; install_id: string }[];\n const origin = rows.find((row) => Number(row.id) === originId);\n const target = rows.find((row) => Number(row.id) === targetId);\n if (!origin) return { ok: false, reason: \"origin\" };\n if (!target) return { ok: false, reason: \"target\" };\n\n // Deleting the origin first frees the unique install id the target adopts;\n // one batch keeps the target from ever pointing at a retired install.\n await sqlite.batch([\n { sql: \"DELETE FROM devices WHERE id = ?\", args: [originId] },\n {\n sql: \"UPDATE devices SET install_id = ?, updated_at = ? WHERE id = ?\",\n args: [origin.install_id, nowIso(), targetId],\n },\n {\n sql: \"DELETE FROM device_push_tokens WHERE device_id = ?\",\n args: [target.install_id],\n },\n {\n sql: \"DELETE FROM device_alert_tokens WHERE device_id = ?\",\n args: [target.install_id],\n },\n ]);\n return { ok: true, targetId };\n}\n\nexport async function updateDevicePresentation(\n id: number,\n presentation: WidgetPresentation,\n): Promise {\n const result = await sqlite.execute({\n sql: \"UPDATE devices SET presentation = ?, updated_at = ? WHERE id = ?\",\n args: [JSON.stringify(presentation), nowIso(), id],\n });\n return result.rowsAffected === 1;\n}\n\nexport async function listAvailableSources(deviceId: number): Promise {\n const result = await sqlite.execute({\n sql: `\n SELECT s.id, s.kind, s.name AS source_name, s.description, s.settings_schema\n FROM sources s\n WHERE EXISTS (SELECT 1 FROM devices WHERE id = ?) AND NOT EXISTS (\n SELECT 1 FROM device_sources ds\n WHERE ds.device_id = ? AND ds.source_id = s.id\n )\n ORDER BY s.kind COLLATE NOCASE, s.id\n `,\n args: [deviceId, deviceId],\n });\n return (result.rows as {\n id: number; kind: SourceKind; source_name: string; description: string; settings_schema: string;\n }[]).map((row) => ({\n id: row.id,\n kind: row.kind,\n name: row.source_name,\n description: row.description,\n settingsSchema: parseJson(row.settings_schema),\n }));\n}\n\nexport async function getDeviceSource(\n deviceId: number,\n assignmentId: number,\n): Promise {\n const result = await sqlite.execute({\n sql: `\n SELECT\n ds.id AS assignment_id, ds.settings, ds.enabled,\n ds.created_at AS assignment_created_at,\n ds.updated_at AS assignment_updated_at,\n s.id AS source_id, s.kind, s.name AS source_name, s.description, s.settings_schema\n FROM device_sources ds\n JOIN sources s ON s.id = ds.source_id\n WHERE ds.device_id = ? AND ds.id = ?\n `,\n args: [deviceId, assignmentId],\n });\n const row = result.rows[0] as {\n assignment_id: number; enabled: number; source_id: number; kind: SourceKind; source_name: string; description: string;\n settings: string; settings_schema: string;\n assignment_created_at: string; assignment_updated_at: string;\n } | undefined;\n return row ? mapSourceRow({...row,name:row.source_name}) : null;\n}\n\nexport async function addDeviceSource(\n deviceId: number,\n sourceId: number,\n settings: unknown,\n enabled = true,\n): Promise {\n const timestamp = nowIso();\n const results = await sqlite.batch([\n {\n sql: `\n INSERT INTO device_sources\n (device_id, source_id, settings, created_at, updated_at, enabled)\n SELECT ?, s.id, ?, ?, ?, ?\n FROM sources s\n WHERE s.id = ?\n AND EXISTS (SELECT 1 FROM devices d WHERE d.id = ?)\n AND NOT EXISTS (\n SELECT 1 FROM device_sources ds\n WHERE ds.device_id = ? AND ds.source_id = s.id\n )\n RETURNING id\n `,\n args: [\n deviceId, JSON.stringify(settings), timestamp, timestamp, enabled ? 1 : 0,\n sourceId, deviceId, deviceId,\n ],\n },\n {\n sql: \"UPDATE devices SET updated_at = ? WHERE id = ? AND changes() = 1\",\n args: [timestamp, deviceId],\n },\n ]);\n const row = results[0].rows[0] as { id: number } | undefined;\n return row ? Number(row.id) : null;\n}\n\nexport async function updateDeviceSource(\n deviceId: number,\n assignmentId: number,\n settings: unknown,\n): Promise {\n const timestamp = nowIso();\n const results = await sqlite.batch([\n {\n sql: `\n UPDATE device_sources\n SET settings = ?, updated_at = ?\n WHERE device_id = ? AND id = ?\n `,\n args: [JSON.stringify(settings), timestamp, deviceId, assignmentId],\n },\n {\n sql: `\n UPDATE devices SET updated_at = ?\n WHERE id = ? AND EXISTS (\n SELECT 1 FROM device_sources\n WHERE device_id = ? AND id = ?\n )\n `,\n args: [timestamp, deviceId, deviceId, assignmentId],\n },\n ]);\n return results[0].rowsAffected === 1;\n}\n\n// State changes do not contact the source, so an unavailable source can be disabled.\nexport async function setDeviceSourceEnabled(\n deviceId: number,\n assignmentId: number,\n enabled: boolean,\n): Promise {\n const timestamp = nowIso();\n const results = await sqlite.batch([\n {\n sql: \"UPDATE device_sources SET enabled=?, updated_at=? WHERE device_id=? AND id=?\",\n args: [enabled ? 1 : 0, timestamp, deviceId, assignmentId],\n },\n {\n sql: `UPDATE devices SET updated_at=?, reminders_built_at=NULL\n WHERE id=? AND changes()=1`,\n args: [timestamp, deviceId],\n },\n ]);\n return results[0].rowsAffected === 1;\n}\n\nexport async function removeDeviceSource(\n deviceId: number,\n assignmentId: number,\n): Promise {\n const timestamp = nowIso();\n const results = await sqlite.batch([\n {\n sql: \"DELETE FROM device_sources WHERE device_id = ? AND id = ?\",\n args: [deviceId, assignmentId],\n },\n {\n sql: \"UPDATE devices SET updated_at = ? WHERE id = ?\",\n args: [timestamp, deviceId],\n },\n ]);\n return results[0].rowsAffected === 1;\n}\n\n","deleted",false,"label",[47,24],"lib","27c7d349-8dc0-4ddf-8288-3f5cab6fe8a0",["D",1787009561780],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","The main web app and server API for Clark View","imageUrl","userId","b0a8da26-58e7-4d19-8b5c-eedf487df9a9","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","5a10edca-919b-4a78-babb-71908f69af93","tursoName","27c7d3498dc04ddf82883f5cab6fe8a0","tursoHostname","27c7d3498dc04ddf82883f5cab6fe8a0-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789532458193],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_106":102},"org",{"_9":10,"_100":-5,"_101":102,"_58":59,"_103":104,"_105":44},"branch",{"_37":32,"_11":91,"_22":30,"_92":48,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":12,"_99":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yVHpab25kTlBTM3M3WmpCa3NMSTd5akVwWksuanBlZyJ9","tier","free","canRestrictVals","profileImageUrl","ctx",{"_84":-5,"_140":141,"_142":143,"_144":145,"_146":44,"_147":44,"_148":44,"_149":34,"_150":-5,"_151":-7,"_152":-7,"_153":65,"_154":44,"_155":44,"_156":-5,"_157":44,"_158":44,"_159":44,"_160":-5},"ENV",{"_111":112,"_113":114,"_115":91,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]