\n );\n}\n\n// --- Sessions Tab ---\n\nfunction EditableNameCell({ value, onSave }: { value: string | null; onSave: (name: string | null) => void }) {\n const [editing, setEditing] = useState(false);\n const [draft, setDraft] = useState(value ?? \"\");\n\n if (!editing) {\n return (\n { setDraft(value ?? \"\"); setEditing(true); }}\n >\n {value || \"—\"}\n \n );\n }\n\n return (\n setDraft((e.target as HTMLInputElement).value)}\n onKeyDown={(e) => {\n if (e.key === \"Enter\") {\n const trimmed = draft.trim();\n onSave(trimmed || null);\n setEditing(false);\n } else if (e.key === \"Escape\") {\n setEditing(false);\n }\n }}\n onBlur={() => {\n const trimmed = draft.trim();\n onSave(trimmed || null);\n setEditing(false);\n }}\n />\n );\n}\n\nfunction SessionsTab() {\n const [sessions, setSessions] = useState([]);\n const [loading, setLoading] = useState(true);\n const [checked, setChecked] = useState([]);\n\n const load = useCallback(async () => {\n setLoading(true);\n const res = await adminFetch(\"/sessions\");\n const data = await res.json();\n setSessions(data.sessions);\n setChecked([]);\n setLoading(false);\n }, []);\n\n useEffect(() => { load(); }, [load]);\n\n const toggleCheck = (id: string) => {\n setChecked((prev) =>\n prev.includes(id) ? prev.filter((x) => x !== id) : [...prev, id]\n );\n };\n\n const handleMerge = async () => {\n if (checked.length < 2) return;\n const [winnerId, ...loserIds] = checked;\n const confirmed = confirm(\n `Merge ${loserIds.length} session(s) into ${winnerId}? The first-checked session is the winner. The others will be removed.`\n );\n if (!confirmed) return;\n await adminFetch(\"/sessions/merge\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ winnerId, loserIds }),\n });\n load();\n };\n\n const handleStop = async (userId: string) => {\n if (!confirm(`Stop session for ${userId}? This resets to idle but keeps the row.`)) return;\n await adminFetch(`/sessions/${encodeURIComponent(userId)}/stop`, { method: \"POST\" });\n load();\n };\n\n const handleDelete = async (userId: string) => {\n if (!confirm(`Delete session for ${userId}?`)) return;\n await adminFetch(`/sessions/${encodeURIComponent(userId)}`, { method: \"DELETE\" });\n setSessions((prev) => prev.filter((s) => s.userId !== userId));\n };\n\n const columns: Column[] = [\n {\n key: \"_check\",\n header: \"\",\n render: (s) => (\n toggleCheck(s.userId)}\n />\n ),\n },\n { key: \"userId\", header: \"User ID\", render: (s) => {s.userId} },\n { key: \"displayName\", header: \"Name\", render: (s) => (\n {\n setSessions((prev) => prev.map((x) => x.userId === s.userId ? { ...x, displayName: name } : x));\n await adminFetch(`/sessions/${encodeURIComponent(s.userId)}/display-name`, {\n method: \"PUT\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ displayName: name }),\n });\n }}\n />\n )},\n { key: \"mode\", header: \"Mode\" },\n { key: \"sessionIntent\", header: \"Intent\", render: (s) => s.sessionIntent || \"—\" },\n { key: \"passphrase\", header: \"Passphrase\", render: (s) => {s.passphrase || \"—\"} },\n { key: \"workStartTime\", header: \"Work Start\", render: (s) => {formatTimestamp(s.workStartTime)} },\n { key: \"sessionStartedAt\", header: \"Session Start\", render: (s) => {formatTimestamp(s.sessionStartedAt)} },\n {\n key: \"_actions\", header: \"\", render: (s) => (\n \n {s.mode !== \"idle\" && (\n \n )}\n \n \n ),\n },\n ];\n\n return (\n

\n {checked.length >= 2 && (\n

\n \n Merge sessions\n \n \n First checked is the winner; rest will be merged into it.\n \n

\n )}\n s.userId}\n loading={loading}\n emptyMessage=\"No sessions.\"\n />\n

\n );\n}\n\n// --- Groups Tab ---\n\nfunction GroupsTab() {\n const [groups, setGroups] = useState([]);\n const [loading, setLoading] = useState(true);\n\n const load = useCallback(async () => {\n setLoading(true);\n const res = await adminFetch(\"/groups\");\n const data = await res.json();\n setGroups(data.groups);\n setLoading(false);\n }, []);\n\n useEffect(() => { load(); }, [load]);\n\n const handleDissolve = async (passphrase: string) => {\n if (!confirm(`Dissolve group \"${passphrase}\"? Members will be ungrouped.`)) return;\n await adminFetch(`/groups/${encodeURIComponent(passphrase)}`, { method: \"DELETE\" });\n setGroups((prev) => prev.filter((g) => g.passphrase !== passphrase));\n };\n\n const columns: Column[] = [\n { key: \"passphrase\", header: \"Passphrase\", render: (g) => {g.passphrase} },\n { key: \"memberCount\", header: \"Members\" },\n { key: \"members\", header: \"Member Names\", render: (g) => {g.members} },\n {\n key: \"_actions\", header: \"\", render: (g) => (\n \n ),\n },\n ];\n\n return (\n g.passphrase}\n loading={loading}\n emptyMessage=\"No groups.\"\n />\n );\n}\n\n// --- History Tab ---\n\nfunction HistoryTab() {\n const [history, setHistory] = useState([]);\n const [loading, setLoading] = useState(true);\n\n const load = useCallback(async () => {\n setLoading(true);\n const res = await adminFetch(\"/history\");\n const data = await res.json();\n setHistory(data.history);\n setLoading(false);\n }, []);\n\n useEffect(() => { load(); }, [load]);\n\n const handleDelete = async (id: number) => {\n if (!confirm(\"Delete this history entry?\")) return;\n await adminFetch(`/history/${id}`, { method: \"DELETE\" });\n setHistory((prev) => prev.filter((h) => h.id !== id));\n };\n\n const columns: Column[] = [\n { key: \"id\", header: \"ID\", render: (h) => {h.id} },\n { key: \"intent\", header: \"Intent\", render: (h) => h.intent || \"—\" },\n { key: \"workTime\", header: \"Work\", render: (h) => formatMinutes(h.workTime) },\n { key: \"breakTime\", header: \"Break\", render: (h) => formatMinutes(h.breakTime) },\n { key: \"startedAt\", header: \"Started\", render: (h) => {formatTimestamp(h.startedAt)} },\n { key: \"endedAt\", header: \"Ended\", render: (h) => {formatTimestamp(h.endedAt)} },\n {\n key: \"_actions\", header: \"\", render: (h) => (\n \n ),\n },\n ];\n\n return (\n h.id}\n loading={loading}\n emptyMessage=\"No history.\"\n />\n );\n}\n\n// --- Users Tab ---\n\nfunction UsersTab() {\n const [users, setUsers] = useState([]);\n const [loading, setLoading] = useState(true);\n const [checked, setChecked] = useState([]);\n\n const load = useCallback(async () => {\n setLoading(true);\n const res = await adminFetch(\"/users\");\n const data = await res.json();\n setUsers(data.users);\n setChecked([]);\n setLoading(false);\n }, []);\n\n useEffect(() => { load(); }, [load]);\n\n const toggleCheck = (id: string) => {\n setChecked((prev) =>\n prev.includes(id) ? prev.filter((x) => x !== id) : [...prev, id]\n );\n };\n\n const handleMerge = async () => {\n if (checked.length !== 2) return;\n const [winnerId, loserId] = checked;\n const winner = users.find((u) => u.id === winnerId);\n const loser = users.find((u) => u.id === loserId);\n if (!winner || !loser) return;\n const confirmed = confirm(\n `Merge ${loser.email} into ${winner.email}? The first-checked user is the winner and keeps their account. The other's history will be re-attributed and their account deleted.`\n );\n if (!confirmed) return;\n await adminFetch(\"/users/merge\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ winnerId, loserId }),\n });\n load();\n };\n\n const columns: Column[] = [\n {\n key: \"_check\",\n header: \"\",\n render: (u) => (\n toggleCheck(u.id)}\n disabled={checked.length === 2 && !checked.includes(u.id)}\n />\n ),\n },\n { key: \"email\", header: \"Email\", render: (u) => {u.email} },\n { key: \"createdAt\", header: \"Created\", render: (u) => {formatTimestamp(u.createdAt)} },\n { key: \"tokenCount\", header: \"Owner Tokens\", render: (u) => {u.tokenCount} },\n ];\n\n return (\n

\n {checked.length === 2 && (\n

\n \n Merge selected\n \n \n First checked is the winner; second checked will be deleted.\n \n

\n )}\n u.id}\n loading={loading}\n emptyMessage=\"No users.\"\n />\n

\n );\n}\n\n// --- Event Log Tab ---\n\nfunction EventLogTab() {\n const [events, setEvents] = useState([]);\n const [loading, setLoading] = useState(true);\n\n const load = useCallback(async () => {\n setLoading(true);\n const res = await adminFetch(\"/events\");\n const data = await res.json();\n setEvents(data.events);\n setLoading(false);\n }, []);\n\n useEffect(() => { load(); }, [load]);\n\n const handleDelete = async (id: number) => {\n if (!confirm(\"Delete this event?\")) return;\n await adminFetch(`/events/${id}`, { method: \"DELETE\" });\n setEvents((prev) => prev.filter((e) => e.id !== id));\n };\n\n const eventLabels: Record = {\n work_started: \"Started working\",\n break_started: \"Took a break\",\n work_resumed: \"Resumed working\",\n interruption: \"Interrupted\",\n big_break_started: \"Big break\",\n session_reset: \"Session reset\",\n break_fraction_changed: \"Fraction changed\",\n intent_set: \"Set intent\",\n intent_cleared: \"Cleared intent\",\n tagtime_ping: \"TagTime ping\",\n };\n\n const columns: Column[] = [\n { key: \"id\", header: \"ID\", render: (e) => {e.id} },\n { key: \"displayName\", header: \"User\", render: (e) => {e.displayName || e.userId.slice(0, 12)} },\n { key: \"eventType\", header: \"Event\", render: (e) => {eventLabels[e.eventType] ?? e.eventType} },\n { key: \"timestamp\", header: \"Time\", render: (e) => {formatTimestamp(e.timestamp)} },\n { key: \"metadata\", header: \"Metadata\", render: (e) => {e.metadata || \"—\"} },\n { key: \"passphrase\", header: \"Group\", render: (e) => {e.passphrase || \"—\"} },\n {\n key: \"_actions\", header: \"\", render: (e) => (\n \n ),\n },\n ];\n\n return (\n e.id}\n loading={loading}\n emptyMessage=\"No events.\"\n />\n );\n}\n\n// --- TagTime Tab ---\n\nimport { nextPingAfter, resetCache, gap, lcg } from \"../shared/tagtime.ts\";\n\nfunction TagTimeTab() {\n const TEST_VECTORS = [1533748817, 1533754341, 1533758980, 1533759940];\n\n // Run verification against rimple reference\n const verificationResults: { input: number; expected: number; got: number; pass: boolean }[] = [];\n resetCache();\n for (let i = 0; i < TEST_VECTORS.length - 1; i++) {\n const prev = TEST_VECTORS[i];\n const expected = TEST_VECTORS[i + 1];\n const result = nextPingAfter(prev + 1);\n verificationResults.push({ input: prev, expected, got: result.time, pass: result.time === expected });\n }\n\n // Check init: nextPingAfter at the exact epoch ping\n resetCache();\n const initResult = nextPingAfter(TEST_VECTORS[0]);\n const initPass = initResult.time === TEST_VECTORS[0];\n\n // Current schedule info\n const nowSec = Math.floor(Date.now() / 1000);\n resetCache();\n const nextPing = nextPingAfter(nowSec);\n\n // Find last ping (ping before now)\n resetCache();\n let lastPingTime = TEST_VECTORS[0];\n let lastPingState = 11193462;\n {\n let cur = nextPingAfter(nowSec - 86400); // start from 1 day ago\n let prev = cur;\n while (cur.time <= nowSec) {\n prev = cur;\n cur = nextPingAfter(cur.time + 1);\n }\n lastPingTime = prev.time;\n lastPingState = prev.state;\n }\n\n // Recent past pings (last 5)\n const pastPings: number[] = [];\n {\n resetCache();\n // Walk back from lastPingTime to collect 5\n const candidates: number[] = [];\n let cur = nextPingAfter(lastPingTime - 5 * 2700 * 3); // generous lookback\n while (cur.time <= nowSec) {\n candidates.push(cur.time);\n cur = nextPingAfter(cur.time + 1);\n }\n pastPings.push(...candidates.slice(-5));\n }\n\n // Next 5 future pings\n const futurePings: number[] = [];\n {\n let cur = nextPing;\n for (let i = 0; i < 5; i++) {\n futurePings.push(cur.time);\n cur = nextPingAfter(cur.time + 1);\n }\n }\n\n const fmtTime = (unixSec: number) => new Date(unixSec * 1000).toLocaleString();\n\n return (\n

Schedule Verification (rimple test vectors)

\n {initPass ? \"PASS\" : \"FAIL\"}\n init({TEST_VECTORS[0]}) = {initResult.time}\n

\n {verificationResults.map((r, i) => (\n

\n {r.pass ? \"PASS\" : \"FAIL\"}\n \n nextPingAfter({r.input} + 1) = {r.got}\n {!r.pass && (expected {r.expected})}\n \n

\n ))}\n

\n\n

Current Schedule

Next ping: {fmtTime(nextPing.time)} ({nextPing.time})

Last ping: {fmtTime(lastPingTime)} ({lastPingTime})

LCG state: {nextPing.state}

\n\n

Recent Pings

\n {pastPings.map((t) => (\n

{fmtTime(t)} ({t})

\n ))}\n

\n\n

Upcoming Pings

\n {futurePings.map((t) => (\n

{fmtTime(t)} ({t})

\n ))}\n

\n );\n}\n\n// --- Settings Tab ---\n\nconst PRESETS: Record }> = {\n test: {\n label: \"Test values\",\n description: \"Low thresholds & fast decay — staleness triggers within seconds\",\n values: {\n wBreaks: \"0.6\", wTime: \"0.4\", tauBreaks: \"1.0\", tauTime: \"2.0\",\n showThresholdWorking: \"0.3\", showThresholdBreaking: \"0.1\", prominentThreshold: \"0.2\",\n },\n },\n realistic: {\n label: \"Realistic values\",\n description: \"Production defaults — staleness builds over ~90 min / 2 breaks\",\n values: {\n wBreaks: \"0.6\", wTime: \"0.4\", tauBreaks: \"2.0\", tauTime: \"90.0\",\n showThresholdWorking: \"0.8\", showThresholdBreaking: \"0.3\", prominentThreshold: \"0.6\",\n },\n },\n};\n\nconst STALENESS_FIELDS = [\n { key: \"wBreaks\", label: \"Weight: breaks (wBreaks)\", default: \"0.6\", group: \"Computation\", help: \"How much break count contributes to staleness (0–1). Higher = breaks matter more.\" },\n { key: \"wTime\", label: \"Weight: time (wTime)\", default: \"0.4\", group: \"Computation\", help: \"How much elapsed time contributes to staleness (0–1). Should sum to 1 with wBreaks.\" },\n { key: \"tauBreaks\", label: \"Tau: breaks (tauBreaks)\", default: \"2.0\", group: \"Computation\", help: \"Break count decay constant. Lower = staleness rises faster per break.\" },\n { key: \"tauTime\", label: \"Tau: time in minutes (tauTime)\", default: \"90.0\", group: \"Computation\", help: \"Time decay constant in minutes. Lower = staleness rises faster over time.\" },\n { key: \"showThresholdWorking\", label: \"Show threshold (working)\", default: \"0.8\", group: \"Display\", help: \"Minimum staleness to show the hint while working.\" },\n { key: \"showThresholdBreaking\", label: \"Show threshold (breaking)\", default: \"0.3\", group: \"Display\", help: \"Minimum staleness to show the hint while on a break.\" },\n { key: \"prominentThreshold\", label: \"Prominent threshold\", default: \"0.6\", group: \"Display\", help: \"Staleness level at which the hint becomes visually prominent (yellow) during breaks.\" },\n] as const;\n\nfunction SettingsTab() {\n const [values, setValues] = useState>({});\n const [saved, setSaved] = useState>({});\n const [loading, setLoading] = useState(true);\n const [saving, setSaving] = useState(false);\n const [feedback, setFeedback] = useState<{ type: \"success\" | \"error\"; message: string } | null>(null);\n\n const load = useCallback(async () => {\n setLoading(true);\n try {\n const res = await adminFetch(\"/config\");\n const data = await res.json();\n setValues(data.config || {});\n setSaved(data.config || {});\n } catch {\n setFeedback({ type: \"error\", message: \"Failed to load config\" });\n }\n setLoading(false);\n }, []);\n\n useEffect(() => { load(); }, [load]);\n\n const handleSave = async () => {\n setSaving(true);\n setFeedback(null);\n try {\n const changed = STALENESS_FIELDS.filter((f) => {\n const current = values[f.key] ?? \"\";\n const prev = saved[f.key] ?? \"\";\n return current !== prev;\n });\n for (const field of changed) {\n await adminFetch(\"/config\", {\n method: \"PUT\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ key: field.key, value: values[field.key] }),\n });\n }\n setSaved({ ...values });\n setFeedback({ type: \"success\", message: `Saved ${changed.length} change${changed.length !== 1 ? \"s\" : \"\"}.` });\n } catch {\n setFeedback({ type: \"error\", message: \"Failed to save config\" });\n }\n setSaving(false);\n };\n\n if (loading) return

;\n\n const groups = [...new Set(STALENESS_FIELDS.map((f) => f.group))];\n\n const hasChanges = STALENESS_FIELDS.some((f) => (values[f.key] ?? \"\") !== (saved[f.key] ?? \"\"));\n\n const applyPreset = (presetKey: string) => {\n setValues((prev) => ({ ...prev, ...PRESETS[presetKey].values }));\n };\n\n return (\n

\n Staleness measures how likely it is that a user's stated intent has gone stale.\n It combines break count and elapsed time via{\" \"}\n staleness = wBreaks * (1 − e^{−breaks/tauBreaks}) + wTime * (1 − e^{−minutes/tauTime}).\n When staleness crosses a display threshold, the app shows a \"still working on …?\" hint.\n

\n\n

Presets

\n {Object.entries(PRESETS).map(([key, preset]) => (\n applyPreset(key)}\n title={preset.description}\n class=\"px-3 py-1.5 text-sm border border-gray-300 rounded hover:bg-gray-50\"\n >\n {preset.label}\n \n ))}\n

\n\n {groups.map((group) => (\n

{group}

\n {STALENESS_FIELDS.filter((f) => f.group === group).map((field) => (\n

\n {field.label}\n setValues((prev) => ({ ...prev, [field.key]: v }))}\n size=\"sm\"\n className=\"w-full\"\n />\n

\n ))}\n

\n ))}\n\n

\n \n {saving ? \"Saving...\" : \"Save\"}\n \n {feedback && (\n \n {feedback.message}\n \n )}\n

\n );\n}\n\n// --- Admin Dashboard ---\n\nfunction AdminDashboard() {\n const [tab, setTab] = useState<\"sessions\" | \"groups\" | \"history\" | \"events\" | \"settings\" | \"users\" | \"tagtime\">(\"sessions\");\n\n const handleLogout = async () => {\n try { await adminFetch(\"/logout\", { method: \"POST\" }); } catch {}\n clearToken();\n window.location.reload();\n };\n\n const tabs = [\n { id: \"sessions\" as const, label: \"Sessions\" },\n { id: \"groups\" as const, label: \"Groups\" },\n { id: \"history\" as const, label: \"History\" },\n { id: \"events\" as const, label: \"Event Log\" },\n { id: \"settings\" as const, label: \"Settings\" },\n { id: \"users\" as const, label: \"Users\" },\n { id: \"tagtime\" as const, label: \"TagTime\" },\n ];\n\n return (\n \n

Admin Dashboard

\n \n

\n\n setTab(id as typeof tab)}\n variant=\"underline\"\n className=\"mb-4\"\n />\n\n

\n {tab === \"sessions\" && }\n {tab === \"groups\" && }\n {tab === \"history\" && }\n {tab === \"events\" && }\n {tab === \"settings\" && }\n {tab === \"users\" && }\n {tab === \"tagtime\" && }\n

\n \n );\n}\n\n// --- App Root ---\n\nfunction App() {\n const [authenticated, setAuthenticated] = useState(!!getToken());\n\n if (!authenticated) {\n return setAuthenticated(true)} />;\n }\n\n return ;\n}\n\nconst root = createRoot(document.getElementById(\"root\")!);\nroot.render();\n","deleted","label",[187,188,170],"src","frontend","permalink","https://www.val.town/x/ozanatgreenpt/thirdTimer/code/src/frontend/admin.tsx","extension","actionData","errors"]

Admin Login

Schedule Verification (rimple test vectors)

Current Schedule

Recent Pings

Upcoming Pings

Presets

{group}

Admin Dashboard