LINE

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_197":198,"_199":200},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_108":89,"_27":53,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":58,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",38,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","6318ae72-a7f0-11f1-bd27-1607ee4eb77e","name","fileType","http","content","//　main.ts\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport webpush from \"https://esm.sh/web-push@3.6.7\";\nimport { htmlContent } from \"./html.ts\";\nimport { jsContent } from \"./client.ts\";\nimport { gifClientJs } from \"./gif.ts\";\n\nconst TABLE = \"rtchat_messages_v3\";\nconst POLLS_TABLE = \"rtchat_polls_v1\";\nconst PRESENCE_TABLE = \"rtchat_presence_v1\";\nconst PUSH_SUB_TABLE = \"rtchat_push_subs_v1\";\n// ---- LINE 風アカウント / 友だち / グループ ----\nconst ACCOUNTS_TABLE = \"rtchat_accounts_v1\";\nconst FRIENDS_TABLE = \"rtchat_friends_v1\";\nconst GROUPS_TABLE = \"rtchat_groups_v1\";\nconst GROUP_MEMBERS_TABLE = \"rtchat_group_members_v1\";\n\n// テーブル初期化\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n room TEXT NOT NULL,\n user_id TEXT NOT NULL,\n name TEXT NOT NULL,\n body TEXT NOT NULL,\n image_url TEXT,\n created_at INTEGER NOT NULL\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${POLLS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n room TEXT NOT NULL,\n question TEXT NOT NULL,\n options TEXT NOT NULL,\n votes TEXT NOT NULL DEFAULT '{}',\n created_at INTEGER NOT NULL\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${PRESENCE_TABLE} (\n room TEXT NOT NULL,\n user_id TEXT NOT NULL,\n name TEXT NOT NULL,\n last_seen INTEGER NOT NULL,\n PRIMARY KEY (room, user_id)\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${PUSH_SUB_TABLE} (\n user_id TEXT NOT NULL,\n room TEXT NOT NULL,\n subscription TEXT NOT NULL,\n PRIMARY KEY (user_id, room)\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS vapid_keys (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n public_key TEXT NOT NULL,\n private_key TEXT NOT NULL\n )\n`);\n\n// 永続アカウント（LINE風）\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${ACCOUNTS_TABLE} (\n id TEXT PRIMARY KEY,\n token TEXT NOT NULL,\n line_id TEXT UNIQUE,\n name TEXT NOT NULL,\n avatar_url TEXT,\n status_msg TEXT,\n created_at INTEGER NOT NULL,\n updated_at INTEGER NOT NULL\n )\n`);\n\n// 友だち関係（相互に1行ずつ保存）\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${FRIENDS_TABLE} (\n account_id TEXT NOT NULL,\n friend_id TEXT NOT NULL,\n created_at INTEGER NOT NULL,\n PRIMARY KEY (account_id, friend_id)\n )\n`);\n\n// グループ\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${GROUPS_TABLE} (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n icon_url TEXT,\n created_by TEXT NOT NULL,\n created_at INTEGER NOT NULL\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${GROUP_MEMBERS_TABLE} (\n group_id TEXT NOT NULL,\n account_id TEXT NOT NULL,\n joined_at INTEGER NOT NULL,\n PRIMARY KEY (group_id, account_id)\n )\n`);\n\n// VAPID キーの取得または生成\nlet vapidKeys = { publicKey: \"\", privateKey: \"\" };\nconst vapidResult = await sqlite.execute(\n \"SELECT public_key, private_key FROM vapid_keys WHERE id = 1\",\n);\nif (vapidResult.rows && (vapidResult.rows as any[]).length > 0) {\n const row = (vapidResult.rows as any[])[0];\n vapidKeys = {\n publicKey: String(row[0] ?? row.public_key),\n privateKey: String(row[1] ?? row.private_key),\n };\n} else {\n const keys = webpush.generateVAPIDKeys();\n vapidKeys = { publicKey: keys.publicKey, privateKey: keys.privateKey };\n await sqlite.execute({\n sql:\n \"INSERT INTO vapid_keys (id, public_key, private_key) VALUES (1, ?, ?)\",\n args: [vapidKeys.publicKey, vapidKeys.privateKey],\n });\n}\nwebpush.setVapidDetails(\n \"mailto:admin@example.com\",\n vapidKeys.publicKey,\n vapidKeys.privateKey,\n);\n\nasync function ensureColumn(table: string, column: string, type: string) {\n try {\n await sqlite.execute(`ALTER TABLE ${table} ADD COLUMN ${column} ${type}`);\n } catch (_e) {\n // カラムが既に存在する場合は無視\n }\n}\n\nawait ensureColumn(TABLE, \"reply_to_id\", \"INTEGER\");\nawait ensureColumn(TABLE, \"reply_to_name\", \"TEXT\");\nawait ensureColumn(TABLE, \"reply_to_body\", \"TEXT\");\nawait ensureColumn(TABLE, \"edited_at\", \"INTEGER\");\nawait ensureColumn(TABLE, \"deleted\", \"INTEGER DEFAULT 0\");\nawait ensureColumn(TABLE, \"updated_at\", \"INTEGER\");\nawait ensureColumn(TABLE, \"poll_id\", \"INTEGER\");\nawait ensureColumn(TABLE, \"avatar_url\", \"TEXT\");\n// 既読管理用\nawait ensureColumn(PRESENCE_TABLE, \"last_read_id\", \"INTEGER DEFAULT 0\");\n\nawait sqlite.execute(\n `UPDATE ${TABLE} SET updated_at = created_at WHERE updated_at IS NULL`,\n);\n\nconst ONLINE_WINDOW_MS = 8000;\nconst SYSTEM_USER = \"system\";\n// GIPHY API キーはサーバー側の環境変数からのみ読み込み、クライアントには渡さない\nconst GIPHY_API_KEY = Deno.env.get(\"GIPHY_API_KEY\") || \"\";\n\n// ---------- 共通ヘルパー ----------\nfunction json(data: unknown, status = 200): Response {\n return new Response(JSON.stringify(data), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\nfunction col(row: any, idx: number, key: string): any {\n return row[idx] ?? row[key];\n}\nfunction genId(prefix: string, len: number): string {\n let s = \"\";\n while (s.length < len) s += Math.random().toString(36).slice(2);\n return prefix + s.slice(0, len);\n}\nfunction genToken(): string {\n return crypto.randomUUID().replace(/-/g, \"\") +\n crypto.randomUUID().replace(/-/g, \"\");\n}\nfunction isDmRoom(room: string) {\n return room.startsWith(\"dm:\");\n}\nfunction isGroupRoom(room: string) {\n return room.startsWith(\"g:\");\n}\nfunction isAccountRoom(room: string) {\n return isDmRoom(room) || isGroupRoom(room);\n}\nfunction dmMembers(room: string): string[] {\n return room.slice(3).split(\"-\").filter((s) => s.length > 0);\n}\nfunction dmRoomFor(a: string, b: string): string {\n const [x, y] = [a, b].sort();\n return \"dm:\" + x + \"-\" + y;\n}\nfunction normalizeLineId(raw: unknown): string | null {\n const s = String(raw ?? \"\").trim().toLowerCase();\n if (!s) return null;\n if (!/^[a-z0-9._-]{4,20}$/.test(s)) return \"__invalid__\";\n return s;\n}\n\ntype Account = {\n id: string;\n line_id: string | null;\n name: string;\n avatar_url: string;\n status_msg: string;\n};\nfunction accountFromRow(row: any): Account {\n return {\n id: String(col(row, 0, \"id\")),\n line_id: col(row, 1, \"line_id\") != null ? String(col(row, 1, \"line_id\")) : null,\n name: String(col(row, 2, \"name\")),\n avatar_url: col(row, 3, \"avatar_url\") ? String(col(row, 3, \"avatar_url\")) : \"\",\n status_msg: col(row, 4, \"status_msg\") ? String(col(row, 4, \"status_msg\")) : \"\",\n };\n}\nconst ACCOUNT_COLS = \"id, line_id, name, avatar_url, status_msg\";\n\nasync function getAccount(id: string): Promise {\n if (!id) return null;\n const r = await sqlite.execute({\n sql: `SELECT ${ACCOUNT_COLS} FROM ${ACCOUNTS_TABLE} WHERE id = ?`,\n args: [id],\n });\n const row = (r.rows as any[])[0];\n return row ? accountFromRow(row) : null;\n}\nasync function getAccountsByIds(ids: string[]): Promise> {\n const map: Record = {};\n const uniq = Array.from(new Set(ids.filter((s) => !!s)));\n if (uniq.length === 0) return map;\n const r = await sqlite.execute({\n sql: `SELECT ${ACCOUNT_COLS} FROM ${ACCOUNTS_TABLE} WHERE id IN (${\n uniq.map(() => \"?\").join(\",\")\n })`,\n args: uniq,\n });\n for (const row of r.rows as any[]) {\n const a = accountFromRow(row);\n map[a.id] = a;\n }\n return map;\n}\nasync function authAccount(id: unknown, token: unknown): Promise {\n if (!id || !token) return null;\n const r = await sqlite.execute({\n sql: `SELECT ${ACCOUNT_COLS} FROM ${ACCOUNTS_TABLE} WHERE id = ? AND token = ?`,\n args: [String(id), String(token)],\n });\n const row = (r.rows as any[])[0];\n return row ? accountFromRow(row) : null;\n}\nasync function isGroupMember(groupId: string, accountId: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT 1 FROM ${GROUP_MEMBERS_TABLE} WHERE group_id = ? AND account_id = ?`,\n args: [groupId, accountId],\n });\n return (r.rows as any[]).length > 0;\n}\nasync function getGroup(groupId: string) {\n const r = await sqlite.execute({\n sql: `SELECT id, name, icon_url, created_by, created_at FROM ${GROUPS_TABLE} WHERE id = ?`,\n args: [groupId],\n });\n const row = (r.rows as any[])[0];\n if (!row) return null;\n return {\n id: String(col(row, 0, \"id\")),\n name: String(col(row, 1, \"name\")),\n icon_url: col(row, 2, \"icon_url\") ? String(col(row, 2, \"icon_url\")) : \"\",\n created_by: String(col(row, 3, \"created_by\")),\n created_at: Number(col(row, 4, \"created_at\")),\n };\n}\nasync function getGroupMembers(groupId: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT a.id, a.line_id, a.name, a.avatar_url, a.status_msg\n FROM ${GROUP_MEMBERS_TABLE} m JOIN ${ACCOUNTS_TABLE} a ON a.id = m.account_id\n WHERE m.group_id = ? ORDER BY m.joined_at ASC`,\n args: [groupId],\n });\n return (r.rows as any[]).map(accountFromRow);\n}\n// dm:/g: ルームは正規アカウント＋トークンが必要。ランダムルームは誰でも OK\nasync function canAccessRoom(room: string, accountId: unknown, token: unknown): Promise {\n if (!isAccountRoom(room)) return true;\n const acct = await authAccount(accountId, token);\n if (!acct) return false;\n if (isDmRoom(room)) return dmMembers(room).includes(acct.id);\n return isGroupMember(room.slice(2), acct.id);\n}\nasync function insertSystemMessage(room: string, body: string) {\n const now = Date.now();\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE} (room, user_id, name, body, image_url, avatar_url, updated_at, created_at)\n VALUES (?, ?, ?, ?, '', '', ?, ?)`,\n args: [room, SYSTEM_USER, SYSTEM_USER, body, now, now],\n });\n}\nasync function readJson(req: Request): Promise {\n try {\n return await req.json();\n } catch (_e) {\n return {};\n }\n}\n\n// バックグラウンド用 Service Worker 本体\nconst swJsContent = `\nself.addEventListener('push', function(event) {\n let data = {};\n try { data = event.data ? event.data.json() : {}; } catch(e) { data = { body: event.data ? event.data.text() : '' }; }\n const title = data.title || '新しいメッセージ';\n const options = {\n body: data.body || '',\n icon: data.icon || undefined,\n badge: '/favicon.ico',\n tag: data.tag || 'chat-message',\n renotify: true,\n vibrate: [200, 100, 200],\n requireInteraction: false,\n data: { url: data.url || '/', room: data.room || 'lobby' }\n };\n event.waitUntil(self.registration.showNotification(title, options));\n});\nself.addEventListener('notificationclick', function(event) {\n event.notification.close();\n const targetUrl = event.notification.data && event.notification.data.url ? event.notification.data.url : '/';\n event.waitUntil(\n clients.matchAll({ type: 'window', includeUncontrolled: true }).then(function(clientList) {\n for (const client of clientList) {\n if (client.url.includes(targetUrl) && 'focus' in client) return client.focus();\n }\n if (clients.openWindow) return clients.openWindow(targetUrl);\n })\n );\n});\n`;\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname;\n\n // /sw.js を正規配信\n if (path === \"/sw.js\") {\n return new Response(swJsContent, {\n headers: {\n \"Content-Type\": \"application/javascript; charset=utf-8\",\n \"Cache-Control\": \"no-cache\",\n },\n });\n }\n\n // ===================== アカウント API =====================\n\n // --- 登録 ---\n if (path === \"/api/account/register\" && req.method === \"POST\") {\n const data = await readJson(req);\n const name = String(data.name || \"\").trim().slice(0, 40);\n if (!name) return json({ error: \"name_required\" }, 400);\n const lineId = normalizeLineId(data.line_id);\n if (lineId === \"__invalid__\") return json({ error: \"invalid_line_id\" }, 400);\n if (lineId) {\n const dup = await sqlite.execute({\n sql: `SELECT 1 FROM ${ACCOUNTS_TABLE} WHERE line_id = ?`,\n args: [lineId],\n });\n if ((dup.rows as any[]).length > 0) return json({ error: \"id_taken\" }, 409);\n }\n const id = genId(\"u\", 10);\n const token = genToken();\n const now = Date.now();\n await sqlite.execute({\n sql: `INSERT INTO ${ACCOUNTS_TABLE} (id, token, line_id, name, avatar_url, status_msg, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n id,\n token,\n lineId,\n name,\n String(data.avatar_url || \"\"),\n String(data.status_msg || \"\").slice(0, 100),\n now,\n now,\n ],\n });\n const acct = await getAccount(id);\n return json({ account: { ...acct, token } });\n }\n\n // --- 更新 ---\n if (path === \"/api/account/update\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const name = data.name != null ? String(data.name).trim().slice(0, 40) : acct.name;\n if (!name) return json({ error: \"name_required\" }, 400);\n let lineId: string | null = acct.line_id;\n if (data.line_id !== undefined) {\n const n = normalizeLineId(data.line_id);\n if (n === \"__invalid__\") return json({ error: \"invalid_line_id\" }, 400);\n if (n && n !== acct.line_id) {\n const dup = await sqlite.execute({\n sql: `SELECT 1 FROM ${ACCOUNTS_TABLE} WHERE line_id = ? AND id != ?`,\n args: [n, acct.id],\n });\n if ((dup.rows as any[]).length > 0) return json({ error: \"id_taken\" }, 409);\n }\n lineId = n;\n }\n const avatar = data.avatar_url !== undefined ? String(data.avatar_url || \"\") : acct.avatar_url;\n const status = data.status_msg !== undefined\n ? String(data.status_msg || \"\").slice(0, 100)\n : acct.status_msg;\n await sqlite.execute({\n sql: `UPDATE ${ACCOUNTS_TABLE} SET name = ?, line_id = ?, avatar_url = ?, status_msg = ?, updated_at = ? WHERE id = ?`,\n args: [name, lineId, avatar, status, Date.now(), acct.id],\n });\n return json({ account: await getAccount(acct.id) });\n }\n\n // --- 自分の情報（友だち・グループ込み） ---\n if (path === \"/api/account/me\" && req.method === \"GET\") {\n const acct = await authAccount(\n url.searchParams.get(\"account_id\"),\n url.searchParams.get(\"token\"),\n );\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n\n const fr = await sqlite.execute({\n sql: `SELECT a.id, a.line_id, a.name, a.avatar_url, a.status_msg\n FROM ${FRIENDS_TABLE} f JOIN ${ACCOUNTS_TABLE} a ON a.id = f.friend_id\n WHERE f.account_id = ? ORDER BY a.name COLLATE NOCASE ASC`,\n args: [acct.id],\n });\n const friends = (fr.rows as any[]).map(accountFromRow);\n\n const gr = await sqlite.execute({\n sql: `SELECT g.id, g.name, g.icon_url, g.created_by, g.created_at,\n (SELECT COUNT(*) FROM ${GROUP_MEMBERS_TABLE} c WHERE c.group_id = g.id) AS member_count\n FROM ${GROUP_MEMBERS_TABLE} m JOIN ${GROUPS_TABLE} g ON g.id = m.group_id\n WHERE m.account_id = ? ORDER BY g.created_at DESC`,\n args: [acct.id],\n });\n const groups = (gr.rows as any[]).map((row) => ({\n id: String(col(row, 0, \"id\")),\n name: String(col(row, 1, \"name\")),\n icon_url: col(row, 2, \"icon_url\") ? String(col(row, 2, \"icon_url\")) : \"\",\n created_by: String(col(row, 3, \"created_by\")),\n created_at: Number(col(row, 4, \"created_at\")),\n member_count: Number(col(row, 5, \"member_count\") ?? 0),\n }));\n\n return json({ account: acct, friends, groups });\n }\n\n // --- 公開プロフィール検索（LINE ID / アカウントID） ---\n if (path === \"/api/account/lookup\" && req.method === \"GET\") {\n const lineId = normalizeLineId(url.searchParams.get(\"line_id\"));\n const accountId = url.searchParams.get(\"account_id\") || \"\";\n let acct: Account | null = null;\n if (lineId && lineId !== \"__invalid__\") {\n const r = await sqlite.execute({\n sql: `SELECT ${ACCOUNT_COLS} FROM ${ACCOUNTS_TABLE} WHERE line_id = ?`,\n args: [lineId],\n });\n const row = (r.rows as any[])[0];\n acct = row ? accountFromRow(row) : null;\n } else if (accountId) {\n acct = await getAccount(accountId);\n }\n if (!acct) return json({ error: \"not_found\" }, 404);\n return json({ account: acct });\n }\n\n // --- 友だち追加（相互） ---\n if (path === \"/api/friends/add\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const friendId = String(data.friend_id || \"\");\n if (!friendId || friendId === acct.id) return json({ error: \"invalid_friend\" }, 400);\n const friend = await getAccount(friendId);\n if (!friend) return json({ error: \"not_found\" }, 404);\n const now = Date.now();\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO ${FRIENDS_TABLE} (account_id, friend_id, created_at) VALUES (?, ?, ?)`,\n args: [acct.id, friend.id, now],\n });\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO ${FRIENDS_TABLE} (account_id, friend_id, created_at) VALUES (?, ?, ?)`,\n args: [friend.id, acct.id, now],\n });\n return json({ success: true, friend, room: dmRoomFor(acct.id, friend.id) });\n }\n\n // --- グループ作成 ---\n if (path === \"/api/groups/create\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const name = String(data.name || \"\").trim().slice(0, 50);\n if (!name) return json({ error: \"name_required\" }, 400);\n const memberIds: string[] = Array.isArray(data.member_ids)\n ? data.member_ids.map((s: unknown) => String(s)).filter((s: string) => s && s !== acct.id)\n : [];\n const id = genId(\"\", 10);\n const now = Date.now();\n await sqlite.execute({\n sql: `INSERT INTO ${GROUPS_TABLE} (id, name, icon_url, created_by, created_at) VALUES (?, ?, ?, ?, ?)`,\n args: [id, name, String(data.icon_url || \"\"), acct.id, now],\n });\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO ${GROUP_MEMBERS_TABLE} (group_id, account_id, joined_at) VALUES (?, ?, ?)`,\n args: [id, acct.id, now],\n });\n const existing = await getAccountsByIds(memberIds);\n for (const mid of memberIds) {\n if (!existing[mid]) continue;\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO ${GROUP_MEMBERS_TABLE} (group_id, account_id, joined_at) VALUES (?, ?, ?)`,\n args: [id, mid, now],\n });\n }\n const names = [acct.name, ...memberIds.filter((m) => existing[m]).map((m) => existing[m].name)];\n await insertSystemMessage(\"g:\" + id, acct.name + \"がグループを作成しました。\" +\n (names.length > 1 ? \" \" + names.slice(1).join(\"、\") + \"が参加しました。\" : \"\"));\n return json({ success: true, group: await getGroup(id), room: \"g:\" + id });\n }\n\n // --- グループ参加（招待リンク） ---\n if (path === \"/api/groups/join\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const group = await getGroup(String(data.group_id || \"\"));\n if (!group) return json({ error: \"not_found\" }, 404);\n if (!(await isGroupMember(group.id, acct.id))) {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO ${GROUP_MEMBERS_TABLE} (group_id, account_id, joined_at) VALUES (?, ?, ?)`,\n args: [group.id, acct.id, Date.now()],\n });\n await insertSystemMessage(\"g:\" + group.id, acct.name + \"が参加しました。\");\n }\n return json({ success: true, group, room: \"g:\" + group.id });\n }\n\n // --- グループに友だちを招待 ---\n if (path === \"/api/groups/invite\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const group = await getGroup(String(data.group_id || \"\"));\n if (!group) return json({ error: \"not_found\" }, 404);\n if (!(await isGroupMember(group.id, acct.id))) return json({ error: \"forbidden\" }, 403);\n const memberIds: string[] = Array.isArray(data.member_ids)\n ? data.member_ids.map((s: unknown) => String(s))\n : [];\n const existing = await getAccountsByIds(memberIds);\n const added: string[] = [];\n for (const mid of memberIds) {\n if (!existing[mid]) continue;\n if (await isGroupMember(group.id, mid)) continue;\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO ${GROUP_MEMBERS_TABLE} (group_id, account_id, joined_at) VALUES (?, ?, ?)`,\n args: [group.id, mid, Date.now()],\n });\n added.push(existing[mid].name);\n }\n if (added.length > 0) {\n await insertSystemMessage(\"g:\" + group.id, acct.name + \"が\" + added.join(\"、\") + \"を招待しました。\");\n }\n return json({ success: true, added: added.length });\n }\n\n // --- グループ退会 ---\n if (path === \"/api/groups/leave\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const groupId = String(data.group_id || \"\");\n await sqlite.execute({\n sql: `DELETE FROM ${GROUP_MEMBERS_TABLE} WHERE group_id = ? AND account_id = ?`,\n args: [groupId, acct.id],\n });\n await insertSystemMessage(\"g:\" + groupId, acct.name + \"が退会しました。\");\n return json({ success: true });\n }\n\n // --- ルーム情報（ヘッダー表示・メニュー用） ---\n if (path === \"/api/room-info\" && req.method === \"GET\") {\n const room = url.searchParams.get(\"room\") || \"lobby\";\n const accountId = url.searchParams.get(\"account_id\");\n const token = url.searchParams.get(\"token\");\n if (!isAccountRoom(room)) {\n return json({ type: \"random\", room, title: \"#\" + room, icon: \"\", members: [] });\n }\n const acct = await authAccount(accountId, token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n if (isDmRoom(room)) {\n const ids = dmMembers(room);\n if (!ids.includes(acct.id)) return json({ error: \"forbidden\" }, 403);\n const map = await getAccountsByIds(ids);\n const other = ids.filter((i) => i !== acct.id).map((i) => map[i]).filter(Boolean)[0];\n return json({\n type: \"dm\",\n room,\n title: other ? other.name : \"不明なユーザー\",\n icon: other ? other.avatar_url : \"\",\n other_id: other ? other.id : \"\",\n members: ids.map((i) => map[i]).filter(Boolean),\n });\n }\n const group = await getGroup(room.slice(2));\n if (!group) return json({ error: \"not_found\" }, 404);\n if (!(await isGroupMember(group.id, acct.id))) return json({ error: \"forbidden\" }, 403);\n const members = await getGroupMembers(group.id);\n return json({\n type: \"group\",\n room,\n title: group.name,\n icon: group.icon_url,\n group_id: group.id,\n members,\n });\n }\n\n // ===================== Push =====================\n\n if (path === \"/api/subscribe\" && req.method === \"POST\") {\n try {\n const data = await req.json();\n const { user_id, room, subscription } = data;\n if (!user_id || !room || !subscription) return json({ error: \"invalid data\" }, 400);\n await sqlite.execute({\n sql: `INSERT INTO ${PUSH_SUB_TABLE} (user_id, room, subscription) VALUES (?, ?, ?)\n ON CONFLICT(user_id, room) DO UPDATE SET subscription = excluded.subscription`,\n args: [user_id, room, JSON.stringify(subscription)],\n });\n return json({ success: true });\n } catch (err) {\n return json({ error: String(err) }, 400);\n }\n }\n\n if (path === \"/api/vapid-public-key\") {\n return json({ publicKey: vapidKeys.publicKey });\n }\n\n // ===================== トーク一覧 =====================\n // ランダムルーム（匿名ID/アカウントIDどちらでも発言済み）＋ 1:1 ＋グループを統合して返す\n if (path === \"/api/rooms\" && req.method === \"GET\") {\n const anonId = url.searchParams.get(\"user_id\") || \"\";\n const acct = await authAccount(\n url.searchParams.get(\"account_id\"),\n url.searchParams.get(\"token\"),\n );\n let reads: Record = {};\n try {\n reads = JSON.parse(url.searchParams.get(\"reads\") || \"{}\") || {};\n } catch (_e) {\n reads = {};\n }\n const myIds = [anonId, acct ? acct.id : \"\"].filter((s) => !!s);\n if (myIds.length === 0) return json({ rooms: [] });\n\n type RoomEntry = {\n room: string;\n type: \"random\" | \"dm\" | \"group\";\n title: string;\n icon: string;\n member_count: number;\n created_at: number;\n };\n const entries: Record = {};\n\n // 1) ランダムルーム\n const rr = await sqlite.execute({\n sql: `SELECT DISTINCT room FROM ${TABLE}\n WHERE user_id IN (${myIds.map(() => \"?\").join(\",\")})\n AND room NOT LIKE 'dm:%' AND room NOT LIKE 'g:%'`,\n args: myIds,\n });\n for (const row of rr.rows as any[]) {\n const room = String(col(row, 0, \"room\"));\n entries[room] = { room, type: \"random\", title: \"#\" + room, icon: \"\", member_count: 0, created_at: 0 };\n }\n\n if (acct) {\n // 2) 1:1 トーク（メッセージが存在するもの）\n const dr = await sqlite.execute({\n sql: `SELECT DISTINCT room FROM ${TABLE}\n WHERE room LIKE 'dm:%' AND (room LIKE ? OR room LIKE ?)`,\n args: [\"dm:\" + acct.id + \"-%\", \"dm:%-\" + acct.id],\n });\n const otherIds: string[] = [];\n const dmRooms: string[] = [];\n for (const row of dr.rows as any[]) {\n const room = String(col(row, 0, \"room\"));\n const ids = dmMembers(room);\n if (!ids.includes(acct.id)) continue;\n const other = ids.find((i) => i !== acct.id) || acct.id;\n otherIds.push(other);\n dmRooms.push(room);\n }\n const others = await getAccountsByIds(otherIds);\n dmRooms.forEach((room, idx) => {\n const o = others[otherIds[idx]];\n entries[room] = {\n room,\n type: \"dm\",\n title: o ? o.name : \"不明なユーザー\",\n icon: o ? o.avatar_url : \"\",\n member_count: 2,\n created_at: 0,\n };\n });\n\n // 3) グループ（メッセージが無くても表示）\n const gr = await sqlite.execute({\n sql: `SELECT g.id, g.name, g.icon_url, g.created_at,\n (SELECT COUNT(*) FROM ${GROUP_MEMBERS_TABLE} c WHERE c.group_id = g.id) AS member_count\n FROM ${GROUP_MEMBERS_TABLE} m JOIN ${GROUPS_TABLE} g ON g.id = m.group_id\n WHERE m.account_id = ?`,\n args: [acct.id],\n });\n for (const row of gr.rows as any[]) {\n const room = \"g:\" + String(col(row, 0, \"id\"));\n entries[room] = {\n room,\n type: \"group\",\n title: String(col(row, 1, \"name\")),\n icon: col(row, 2, \"icon_url\") ? String(col(row, 2, \"icon_url\")) : \"\",\n member_count: Number(col(row, 4, \"member_count\") ?? 0),\n created_at: Number(col(row, 3, \"created_at\")),\n };\n }\n }\n\n const roomKeys = Object.keys(entries);\n if (roomKeys.length === 0) return json({ rooms: [] });\n const ph = roomKeys.map(() => \"?\").join(\",\");\n\n // 最新メッセージ\n const latest = await sqlite.execute({\n sql: `SELECT t.room, t.id, t.name, t.body, t.deleted, t.created_at, t.image_url, t.poll_id, t.user_id\n FROM ${TABLE} t\n INNER JOIN (SELECT room, MAX(id) AS max_id FROM ${TABLE} WHERE room IN (${ph}) GROUP BY room) l\n ON t.room = l.room AND t.id = l.max_id`,\n args: roomKeys,\n });\n const latestMap: Record = {};\n for (const row of latest.rows as any[]) {\n latestMap[String(col(row, 0, \"room\"))] = {\n last_message_id: Number(col(row, 1, \"id\")),\n last_name: String(col(row, 2, \"name\")),\n last_body: String(col(row, 3, \"body\")),\n last_deleted: Number(col(row, 4, \"deleted\") ?? 0) === 1,\n last_created_at: Number(col(row, 5, \"created_at\")),\n last_has_image: !!col(row, 6, \"image_url\"),\n last_is_poll: col(row, 7, \"poll_id\") != null,\n last_is_system: String(col(row, 8, \"user_id\")) === SYSTEM_USER,\n };\n }\n\n // 未読数（自分以外の発言で、クライアントが最後に読んだ id より新しいもの）\n const unreadMap: Record = {};\n const conds: string[] = [];\n const condArgs: (string | number)[] = [];\n for (const room of roomKeys) {\n conds.push(\"(room = ? AND id > ?)\");\n condArgs.push(room, Number(reads[room] || 0));\n }\n const ur = await sqlite.execute({\n sql: `SELECT room, COUNT(*) FROM ${TABLE}\n WHERE deleted = 0 AND user_id NOT IN (${myIds.map(() => \"?\").join(\",\")}, ?)\n AND (${conds.join(\" OR \")})\n GROUP BY room`,\n args: [...myIds, SYSTEM_USER, ...condArgs],\n });\n for (const row of ur.rows as any[]) {\n unreadMap[String(col(row, 0, \"room\"))] = Number(col(row, 1, \"COUNT(*)\") ?? row[1] ?? 0);\n }\n\n const rooms = roomKeys.map((room) => {\n const e = entries[room];\n const l = latestMap[room] || {\n last_message_id: 0,\n last_name: \"\",\n last_body: \"\",\n last_deleted: false,\n last_created_at: e.created_at,\n last_has_image: false,\n last_is_poll: false,\n last_is_system: false,\n };\n return { ...e, ...l, unread: unreadMap[room] || 0 };\n }).sort((a, b) => b.last_created_at - a.last_created_at);\n\n return json({ rooms });\n }\n\n // ===================== メッセージ =====================\n\n if (path === \"/api/messages\") {\n const room = url.searchParams.get(\"room\") || \"lobby\";\n const since = Number(url.searchParams.get(\"since\") || \"0\");\n const sinceUpdate = Number(url.searchParams.get(\"sinceUpdate\") || \"0\");\n const viewer = url.searchParams.get(\"viewer\") || \"\";\n const viewerName = url.searchParams.get(\"name\") || \"\";\n const markRead = url.searchParams.get(\"read\") === \"1\";\n\n if (isAccountRoom(room)) {\n const ok = await canAccessRoom(room, viewer, url.searchParams.get(\"token\"));\n if (!ok) return json({ error: \"forbidden\" }, 403);\n }\n\n if (viewer) {\n const now = Date.now();\n if (markRead) {\n await sqlite.execute({\n sql: `INSERT INTO ${PRESENCE_TABLE} (room, user_id, name, last_seen, last_read_id)\n VALUES (?, ?, ?, ?, (SELECT COALESCE(MAX(id), 0) FROM ${TABLE} WHERE room = ?))\n ON CONFLICT(room, user_id) DO UPDATE SET\n name = excluded.name, last_seen = excluded.last_seen,\n last_read_id = MAX(COALESCE(${PRESENCE_TABLE}.last_read_id, 0), excluded.last_read_id)`,\n args: [room, viewer, viewerName || \"名無し\", now, room],\n });\n } else {\n await sqlite.execute({\n sql: `INSERT INTO ${PRESENCE_TABLE} (room, user_id, name, last_seen, last_read_id)\n VALUES (?, ?, ?, ?, 0)\n ON CONFLICT(room, user_id) DO UPDATE SET name = excluded.name, last_seen = excluded.last_seen`,\n args: [room, viewer, viewerName || \"名無し\", now],\n });\n }\n }\n\n const result = await sqlite.execute({\n sql: `SELECT id, user_id, name, body, image_url, reply_to_id, reply_to_name, reply_to_body,\n edited_at, deleted, updated_at, poll_id, created_at, avatar_url\n FROM ${TABLE}\n WHERE room = ? AND (id > ? OR updated_at > ?)\n ORDER BY id ASC`,\n args: [room, since, sinceUpdate],\n });\n\n const rawMessages = (result.rows as any[]).map((row) => ({\n id: Number(col(row, 0, \"id\")),\n user_id: String(col(row, 1, \"user_id\")),\n name: String(col(row, 2, \"name\")),\n body: String(col(row, 3, \"body\")),\n image_url: col(row, 4, \"image_url\") ? String(col(row, 4, \"image_url\")) : \"\",\n reply_to_id: col(row, 5, \"reply_to_id\") != null ? Number(col(row, 5, \"reply_to_id\")) : null,\n reply_to_name: col(row, 6, \"reply_to_name\") != null ? String(col(row, 6, \"reply_to_name\")) : null,\n reply_to_body: col(row, 7, \"reply_to_body\") != null ? String(col(row, 7, \"reply_to_body\")) : null,\n edited_at: col(row, 8, \"edited_at\") != null ? Number(col(row, 8, \"edited_at\")) : null,\n deleted: Number(col(row, 9, \"deleted\") ?? 0) === 1,\n updated_at: Number(col(row, 10, \"updated_at\") ?? col(row, 12, \"created_at\")),\n poll_id: col(row, 11, \"poll_id\") != null ? Number(col(row, 11, \"poll_id\")) : null,\n created_at: Number(col(row, 12, \"created_at\")),\n avatar_url: col(row, 13, \"avatar_url\") ? String(col(row, 13, \"avatar_url\")) : \"\",\n }));\n\n const pollIds = rawMessages.filter((m) => m.poll_id != null).map((m) => m.poll_id as number);\n const pollMap: Record = {};\n if (pollIds.length > 0) {\n const placeholders = pollIds.map(() => \"?\").join(\",\");\n const pollResult = await sqlite.execute({\n sql: `SELECT id, question, options, votes FROM ${POLLS_TABLE} WHERE id IN (${placeholders})`,\n args: pollIds,\n });\n for (const prow of pollResult.rows as any[]) {\n const pid = Number(col(prow, 0, \"id\"));\n const question = String(col(prow, 1, \"question\"));\n const options: string[] = JSON.parse(String(col(prow, 2, \"options\")));\n const votes: Record = JSON.parse(String(col(prow, 3, \"votes\")) || \"{}\");\n const tally = options.map((text, idx) => ({\n text,\n count: Object.values(votes).filter((v) => v === idx).length,\n }));\n const total = Object.keys(votes).length;\n const myVote = viewer && Object.prototype.hasOwnProperty.call(votes, viewer) ? votes[viewer] : null;\n pollMap[pid] = { id: pid, question, options: tally, total, myVote };\n }\n }\n\n const messages = rawMessages.map((m) => ({\n ...m,\n poll: m.poll_id != null ? pollMap[m.poll_id] || null : null,\n }));\n\n const onlineResult = await sqlite.execute({\n sql: `SELECT user_id, name FROM ${PRESENCE_TABLE} WHERE room = ? AND last_seen > ? ORDER BY name ASC`,\n args: [room, Date.now() - ONLINE_WINDOW_MS],\n });\n const online = (onlineResult.rows as any[]).map((row) => ({\n user_id: String(col(row, 0, \"user_id\")),\n name: String(col(row, 1, \"name\")),\n }));\n\n // 既読情報（自分以外）\n const readResult = await sqlite.execute({\n sql: `SELECT user_id, COALESCE(last_read_id, 0) FROM ${PRESENCE_TABLE} WHERE room = ? AND user_id != ?`,\n args: [room, viewer || \"\"],\n });\n const readers = (readResult.rows as any[]).map((row) => ({\n user_id: String(row[0] ?? row.user_id),\n last_read_id: Number(row[1] ?? 0),\n }));\n\n return json({ messages, online, readers });\n }\n\n // --- メッセージ送信 ---\n if (path === \"/api/send\" && req.method === \"POST\") {\n try {\n const data = await req.json();\n const room = data.room || \"lobby\";\n const user_id = data.user_id || \"unknown\";\n const name = data.name || \"名無し\";\n const body = data.body || \"\";\n const image_url = data.image_url || \"\";\n const avatar_url = data.avatar_url || \"\";\n const reply_to_id = data.reply_to_id ? Number(data.reply_to_id) : null;\n const reply_to_name = data.reply_to_name || null;\n const reply_to_body = data.reply_to_body || null;\n const created_at = Date.now();\n\n if (isAccountRoom(room) && !(await canAccessRoom(room, user_id, data.token))) {\n return json({ error: \"forbidden\" }, 403);\n }\n if (user_id === SYSTEM_USER) return json({ error: \"forbidden\" }, 403);\n\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE} (room, user_id, name, body, image_url, avatar_url, reply_to_id, reply_to_name, reply_to_body, updated_at, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [room, user_id, name, body, image_url, avatar_url, reply_to_id, reply_to_name, reply_to_body, created_at, created_at],\n });\n\n // 通知タイトル（LINE 風）\n let pushTitle = name + \" (#\" + room + \")\";\n let pushBody = body || (image_url ? \"画像を送信しました\" : \"\");\n if (isDmRoom(room)) {\n pushTitle = name;\n } else if (isGroupRoom(room)) {\n const g = await getGroup(room.slice(2));\n pushTitle = g ? g.name : \"グループ\";\n pushBody = name + \": \" + pushBody;\n }\n\n const subsResult = await sqlite.execute({\n sql: `SELECT subscription FROM ${PUSH_SUB_TABLE} WHERE room = ? AND user_id != ?`,\n args: [room, user_id],\n });\n const roomUrl = \"/\" + (room !== \"lobby\" ? \"#\" + room : \"\");\n for (const row of subsResult.rows as any[]) {\n try {\n const sub = JSON.parse(String(row[0] ?? row.subscription));\n const payload = JSON.stringify({\n title: pushTitle,\n body: pushBody.length > 100 ? pushBody.substring(0, 100) + \"…\" : pushBody,\n tag: `msg-${room}`,\n icon: avatar_url && !avatar_url.startsWith(\"data:\") ? avatar_url : undefined,\n url: roomUrl,\n room: room,\n });\n webpush.sendNotification(sub, payload).catch((err: any) => {\n if (err.statusCode === 410 || err.statusCode === 404) {\n sqlite.execute({\n sql: `DELETE FROM ${PUSH_SUB_TABLE} WHERE subscription = ?`,\n args: [String(row[0] ?? row.subscription)],\n }).catch(() => {});\n }\n });\n } catch (_e) {\n // パースエラーなどは無視\n }\n }\n\n return json({ success: true });\n } catch (err) {\n return json({ error: String(err) }, 400);\n }\n }\n\n // --- メッセージ編集 ---\n if (path === \"/api/edit\" && req.method === \"POST\") {\n try {\n const data = await req.json();\n const id = Number(data.id);\n const user_id = data.user_id || \"\";\n const body = (data.body || \"\").trim();\n if (!id || !body) return json({ error: \"invalid request\" }, 400);\n\n const check = await sqlite.execute({\n sql: `SELECT user_id, deleted FROM ${TABLE} WHERE id = ?`,\n args: [id],\n });\n const row = (check.rows as any[])[0];\n if (!row) return json({ error: \"not found\" }, 404);\n if (String(row[0] ?? row.user_id) !== user_id) return json({ error: \"forbidden\" }, 403);\n if (Number(row[1] ?? row.deleted ?? 0) === 1) return json({ error: \"already deleted\" }, 400);\n\n const now = Date.now();\n await sqlite.execute({\n sql: `UPDATE ${TABLE} SET body = ?, edited_at = ?, updated_at = ? WHERE id = ?`,\n args: [body, now, now, id],\n });\n return json({ success: true });\n } catch (err) {\n return json({ error: String(err) }, 400);\n }\n }\n\n // --- メッセージ削除 ---\n if (path === \"/api/delete\" && req.method === \"POST\") {\n try {\n const data = await req.json();\n const id = Number(data.id);\n const user_id = data.user_id || \"\";\n const check = await sqlite.execute({\n sql: `SELECT user_id FROM ${TABLE} WHERE id = ?`,\n args: [id],\n });\n const row = (check.rows as any[])[0];\n if (!row) return json({ error: \"not found\" }, 404);\n if (String(row[0] ?? row.user_id) !== user_id) return json({ error: \"forbidden\" }, 403);\n const now = Date.now();\n await sqlite.execute({\n sql: `UPDATE ${TABLE} SET deleted = 1, updated_at = ? WHERE id = ?`,\n args: [now, id],\n });\n return json({ success: true });\n } catch (err) {\n return json({ error: String(err) }, 400);\n }\n }\n\n // --- 投票作成 ---\n if (path === \"/api/poll/create\" && req.method === \"POST\") {\n try {\n const data = await req.json();\n const room = data.room || \"lobby\";\n const user_id = data.user_id || \"unknown\";\n const name = data.name || \"名無し\";\n const avatar_url = data.avatar_url || \"\";\n const question = (data.question || \"\").trim();\n const options: string[] = Array.isArray(data.options)\n ? data.options.map((o: string) => String(o).trim()).filter((o: string) => o.length > 0)\n : [];\n if (!question || options.length < 2) return json({ error: \"invalid poll\" }, 400);\n if (isAccountRoom(room) && !(await canAccessRoom(room, user_id, data.token))) {\n return json({ error: \"forbidden\" }, 403);\n }\n\n const created_at = Date.now();\n const pollInsert = await sqlite.execute({\n sql: `INSERT INTO ${POLLS_TABLE} (room, question, options, votes, created_at) VALUES (?, ?, ?, '{}', ?)`,\n args: [room, question, JSON.stringify(options), created_at],\n });\n const pollId = Number(pollInsert.lastInsertRowid);\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE} (room, user_id, name, body, avatar_url, poll_id, updated_at, created_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [room, user_id, name, \"投票 \" + question, avatar_url, pollId, created_at, created_at],\n });\n return json({ success: true });\n } catch (err) {\n return json({ error: String(err) }, 400);\n }\n }\n\n // --- 投票 ---\n if (path === \"/api/poll/vote\" && req.method === \"POST\") {\n try {\n const data = await req.json();\n const pollId = Number(data.poll_id);\n const messageId = Number(data.message_id);\n const user_id = data.user_id || \"\";\n const optionIndex = Number(data.option_index);\n if (!pollId || !user_id || Number.isNaN(optionIndex)) return json({ error: \"invalid vote\" }, 400);\n\n const pollRow = await sqlite.execute({\n sql: `SELECT options, votes FROM ${POLLS_TABLE} WHERE id = ?`,\n args: [pollId],\n });\n const prow = (pollRow.rows as any[])[0];\n if (!prow) return json({ error: \"poll not found\" }, 404);\n const options: string[] = JSON.parse(String(prow[0] ?? prow.options));\n if (optionIndex < 0 || optionIndex >= options.length) return json({ error: \"invalid option\" }, 400);\n const votes: Record = JSON.parse(String(prow[1] ?? prow.votes) || \"{}\");\n votes[user_id] = optionIndex;\n await sqlite.execute({\n sql: `UPDATE ${POLLS_TABLE} SET votes = ? WHERE id = ?`,\n args: [JSON.stringify(votes), pollId],\n });\n if (messageId) {\n await sqlite.execute({\n sql: `UPDATE ${TABLE} SET updated_at = ? WHERE id = ?`,\n args: [Date.now(), messageId],\n });\n }\n return json({ success: true });\n } catch (err) {\n return json({ error: String(err) }, 400);\n }\n }\n\n // --- GIF検索プロキシ（GIPHY APIキーをクライアントに渡さないためのサーバー中継）---\n if (path === \"/api/gif/search\" && req.method === \"GET\") {\n try {\n if (!GIPHY_API_KEY) return json({ error: \"GIPHY_API_KEY not configured\" }, 500);\n const q = url.searchParams.get(\"q\") || \"\";\n const endpoint = q.trim()\n ? `https://api.giphy.com/v1/gifs/search?api_key=${GIPHY_API_KEY}&q=${\n encodeURIComponent(q)\n }&limit=24&rating=pg-13&lang=ja`\n : `https://api.giphy.com/v1/gifs/trending?api_key=${GIPHY_API_KEY}&limit=24&rating=pg-13`;\n\n const res = await fetch(endpoint);\n if (!res.ok) return json({ error: \"giphy request failed\" }, 502);\n const data = await res.json();\n const items = ((data.data || []) as any[]).map((g) => {\n const preview = (g.images?.fixed_width_small || g.images?.fixed_width || {}).url || \"\";\n const full = (g.images?.original || g.images?.fixed_width || {}).url || \"\";\n return { preview, full, title: g.title || \"gif\" };\n }).filter((i) => i.preview && i.full);\n\n return json({ items });\n } catch (err) {\n return json({ error: String(err) }, 500);\n }\n }\n\n // ===================== 静的配信 =====================\n if (path === \"/\" || path === \"/index.html\") {\n return new Response(htmlContent, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n }\n if (path === \"/client.js\") {\n return new Response(jsContent, {\n headers: { \"Content-Type\": \"application/javascript; charset=utf-8\", \"Cache-Control\": \"no-cache\" },\n });\n }\n if (path === \"/gif.js\") {\n return new Response(gifClientJs, {\n headers: { \"Content-Type\": \"application/javascript; charset=utf-8\", \"Cache-Control\": \"no-cache\" },\n });\n }\n\n return new Response(\"Not Found\", { status: 404 });\n}","//　main.ts\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport webpush from \"https://esm.sh/web-push@3.6.7\";\nimport { htmlContent } from \"./html.ts\";\nimport { jsContent } from \"./client.ts\";\nimport { gifClientJs } from \"./gif.ts\";\nimport { callClientJs } from \"./call.ts\";\n\nconst TABLE = \"rtchat_messages_v3\";\nconst POLLS_TABLE = \"rtchat_polls_v1\";\nconst PRESENCE_TABLE = \"rtchat_presence_v1\";\nconst PUSH_SUB_TABLE = \"rtchat_push_subs_v1\";\n// ---- LINE 風アカウント / 友だち / グループ ----\nconst ACCOUNTS_TABLE = \"rtchat_accounts_v1\";\nconst FRIENDS_TABLE = \"rtchat_friends_v1\";\nconst GROUPS_TABLE = \"rtchat_groups_v1\";\nconst GROUP_MEMBERS_TABLE = \"rtchat_group_members_v1\";\n// ---- 通話シグナリング（WebRTC / 1:1 のみ・room ごとに1通話） ----\nconst CALLS_TABLE = \"rtchat_calls_v1\";\n\n// テーブル初期化\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n room TEXT NOT NULL,\n user_id TEXT NOT NULL,\n name TEXT NOT NULL,\n body TEXT NOT NULL,\n image_url TEXT,\n created_at INTEGER NOT NULL\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${POLLS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n room TEXT NOT NULL,\n question TEXT NOT NULL,\n options TEXT NOT NULL,\n votes TEXT NOT NULL DEFAULT '{}',\n created_at INTEGER NOT NULL\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${PRESENCE_TABLE} (\n room TEXT NOT NULL,\n user_id TEXT NOT NULL,\n name TEXT NOT NULL,\n last_seen INTEGER NOT NULL,\n PRIMARY KEY (room, user_id)\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${PUSH_SUB_TABLE} (\n user_id TEXT NOT NULL,\n room TEXT NOT NULL,\n subscription TEXT NOT NULL,\n PRIMARY KEY (user_id, room)\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS vapid_keys (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n public_key TEXT NOT NULL,\n private_key TEXT NOT NULL\n )\n`);\n\n// 永続アカウント（LINE風）\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${ACCOUNTS_TABLE} (\n id TEXT PRIMARY KEY,\n token TEXT NOT NULL,\n line_id TEXT UNIQUE,\n name TEXT NOT NULL,\n avatar_url TEXT,\n status_msg TEXT,\n created_at INTEGER NOT NULL,\n updated_at INTEGER NOT NULL\n )\n`);\n\n// 友だち関係（相互に1行ずつ保存）\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${FRIENDS_TABLE} (\n account_id TEXT NOT NULL,\n friend_id TEXT NOT NULL,\n created_at INTEGER NOT NULL,\n PRIMARY KEY (account_id, friend_id)\n )\n`);\n\n// グループ\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${GROUPS_TABLE} (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n icon_url TEXT,\n created_by TEXT NOT NULL,\n created_at INTEGER NOT NULL\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${GROUP_MEMBERS_TABLE} (\n group_id TEXT NOT NULL,\n account_id TEXT NOT NULL,\n joined_at INTEGER NOT NULL,\n PRIMARY KEY (group_id, account_id)\n )\n`);\n\n// 通話シグナリング（1つの room につき現在の通話を1行だけ保持。call_seq で世代管理）\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${CALLS_TABLE} (\n room TEXT PRIMARY KEY,\n call_seq INTEGER NOT NULL DEFAULT 0,\n caller_id TEXT,\n caller_name TEXT,\n caller_avatar TEXT,\n callee_id TEXT,\n status TEXT,\n offer TEXT,\n answer TEXT,\n caller_ice TEXT DEFAULT '[]',\n callee_ice TEXT DEFAULT '[]',\n started_at INTEGER,\n updated_at INTEGER\n )\n`);\n\n// VAPID キーの取得または生成\nlet vapidKeys = { publicKey: \"\", privateKey: \"\" };\nconst vapidResult = await sqlite.execute(\n \"SELECT public_key, private_key FROM vapid_keys WHERE id = 1\",\n);\nif (vapidResult.rows && (vapidResult.rows as any[]).length > 0) {\n const row = (vapidResult.rows as any[])[0];\n vapidKeys = {\n publicKey: String(row[0] ?? row.public_key),\n privateKey: String(row[1] ?? row.private_key),\n };\n} else {\n const keys = webpush.generateVAPIDKeys();\n vapidKeys = { publicKey: keys.publicKey, privateKey: keys.privateKey };\n await sqlite.execute({\n sql:\n \"INSERT INTO vapid_keys (id, public_key, private_key) VALUES (1, ?, ?)\",\n args: [vapidKeys.publicKey, vapidKeys.privateKey],\n });\n}\nwebpush.setVapidDetails(\n \"mailto:admin@example.com\",\n vapidKeys.publicKey,\n vapidKeys.privateKey,\n);\n\nasync function ensureColumn(table: string, column: string, type: string) {\n try {\n await sqlite.execute(`ALTER TABLE ${table} ADD COLUMN ${column} ${type}`);\n } catch (_e) {\n // カラムが既に存在する場合は無視\n }\n}\n\nawait ensureColumn(TABLE, \"reply_to_id\", \"INTEGER\");\nawait ensureColumn(TABLE, \"reply_to_name\", \"TEXT\");\nawait ensureColumn(TABLE, \"reply_to_body\", \"TEXT\");\nawait ensureColumn(TABLE, \"edited_at\", \"INTEGER\");\nawait ensureColumn(TABLE, \"deleted\", \"INTEGER DEFAULT 0\");\nawait ensureColumn(TABLE, \"updated_at\", \"INTEGER\");\nawait ensureColumn(TABLE, \"poll_id\", \"INTEGER\");\nawait ensureColumn(TABLE, \"avatar_url\", \"TEXT\");\n// 既読管理用\nawait ensureColumn(PRESENCE_TABLE, \"last_read_id\", \"INTEGER DEFAULT 0\");\n\nawait sqlite.execute(\n `UPDATE ${TABLE} SET updated_at = created_at WHERE updated_at IS NULL`,\n);\n\nconst ONLINE_WINDOW_MS = 8000;\nconst SYSTEM_USER = \"system\";\n// GIPHY API キーはサーバー側の環境変数からのみ読み込み、クライアントには渡さない\nconst GIPHY_API_KEY = Deno.env.get(\"GIPHY_API_KEY\") || \"\";\n\n// ---------- 共通ヘルパー ----------\nfunction json(data: unknown, status = 200): Response {\n return new Response(JSON.stringify(data), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\nfunction col(row: any, idx: number, key: string): any {\n return row[idx] ?? row[key];\n}\nfunction genId(prefix: string, len: number): string {\n let s = \"\";\n while (s.length < len) s += Math.random().toString(36).slice(2);\n return prefix + s.slice(0, len);\n}\nfunction genToken(): string {\n return crypto.randomUUID().replace(/-/g, \"\") +\n crypto.randomUUID().replace(/-/g, \"\");\n}\nfunction isDmRoom(room: string) {\n return room.startsWith(\"dm:\");\n}\nfunction isGroupRoom(room: string) {\n return room.startsWith(\"g:\");\n}\nfunction isAccountRoom(room: string) {\n return isDmRoom(room) || isGroupRoom(room);\n}\nfunction dmMembers(room: string): string[] {\n return room.slice(3).split(\"-\").filter((s) => s.length > 0);\n}\nfunction dmRoomFor(a: string, b: string): string {\n const [x, y] = [a, b].sort();\n return \"dm:\" + x + \"-\" + y;\n}\nfunction normalizeLineId(raw: unknown): string | null {\n const s = String(raw ?? \"\").trim().toLowerCase();\n if (!s) return null;\n if (!/^[a-z0-9._-]{4,20}$/.test(s)) return \"__invalid__\";\n return s;\n}\nfunction base64ToBytes(b64: string): Uint8Array {\n const bin = atob(b64);\n const bytes = new Uint8Array(bin.length);\n for (let i = 0; i < bin.length; i++) bytes[i] = bin.charCodeAt(i);\n return bytes;\n}\n\ntype Account = {\n id: string;\n line_id: string | null;\n name: string;\n avatar_url: string;\n status_msg: string;\n};\nfunction accountFromRow(row: any): Account {\n return {\n id: String(col(row, 0, \"id\")),\n line_id: col(row, 1, \"line_id\") != null\n ? String(col(row, 1, \"line_id\"))\n : null,\n name: String(col(row, 2, \"name\")),\n avatar_url: col(row, 3, \"avatar_url\")\n ? String(col(row, 3, \"avatar_url\"))\n : \"\",\n status_msg: col(row, 4, \"status_msg\")\n ? String(col(row, 4, \"status_msg\"))\n : \"\",\n };\n}\nconst ACCOUNT_COLS = \"id, line_id, name, avatar_url, status_msg\";\n\nasync function getAccount(id: string): Promise {\n if (!id) return null;\n const r = await sqlite.execute({\n sql: `SELECT ${ACCOUNT_COLS} FROM ${ACCOUNTS_TABLE} WHERE id = ?`,\n args: [id],\n });\n const row = (r.rows as any[])[0];\n return row ? accountFromRow(row) : null;\n}\nasync function getAccountsByIds(\n ids: string[],\n): Promise> {\n const map: Record = {};\n const uniq = Array.from(new Set(ids.filter((s) => !!s)));\n if (uniq.length === 0) return map;\n const r = await sqlite.execute({\n sql: `SELECT ${ACCOUNT_COLS} FROM ${ACCOUNTS_TABLE} WHERE id IN (${\n uniq.map(() => \"?\").join(\",\")\n })`,\n args: uniq,\n });\n for (const row of r.rows as any[]) {\n const a = accountFromRow(row);\n map[a.id] = a;\n }\n return map;\n}\nasync function authAccount(\n id: unknown,\n token: unknown,\n): Promise {\n if (!id || !token) return null;\n const r = await sqlite.execute({\n sql:\n `SELECT ${ACCOUNT_COLS} FROM ${ACCOUNTS_TABLE} WHERE id = ? AND token = ?`,\n args: [String(id), String(token)],\n });\n const row = (r.rows as any[])[0];\n return row ? accountFromRow(row) : null;\n}\nasync function isGroupMember(\n groupId: string,\n accountId: string,\n): Promise {\n const r = await sqlite.execute({\n sql:\n `SELECT 1 FROM ${GROUP_MEMBERS_TABLE} WHERE group_id = ? AND account_id = ?`,\n args: [groupId, accountId],\n });\n return (r.rows as any[]).length > 0;\n}\nasync function getGroup(groupId: string) {\n const r = await sqlite.execute({\n sql:\n `SELECT id, name, icon_url, created_by, created_at FROM ${GROUPS_TABLE} WHERE id = ?`,\n args: [groupId],\n });\n const row = (r.rows as any[])[0];\n if (!row) return null;\n return {\n id: String(col(row, 0, \"id\")),\n name: String(col(row, 1, \"name\")),\n icon_url: col(row, 2, \"icon_url\") ? String(col(row, 2, \"icon_url\")) : \"\",\n created_by: String(col(row, 3, \"created_by\")),\n created_at: Number(col(row, 4, \"created_at\")),\n };\n}\nasync function getGroupMembers(groupId: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT a.id, a.line_id, a.name, a.avatar_url, a.status_msg\n FROM ${GROUP_MEMBERS_TABLE} m JOIN ${ACCOUNTS_TABLE} a ON a.id = m.account_id\n WHERE m.group_id = ? ORDER BY m.joined_at ASC`,\n args: [groupId],\n });\n return (r.rows as any[]).map(accountFromRow);\n}\n// dm:/g: ルームは正規アカウント＋トークンが必要。ランダムルームは誰でも OK\nasync function canAccessRoom(\n room: string,\n accountId: unknown,\n token: unknown,\n): Promise {\n if (!isAccountRoom(room)) return true;\n const acct = await authAccount(accountId, token);\n if (!acct) return false;\n if (isDmRoom(room)) return dmMembers(room).includes(acct.id);\n return isGroupMember(room.slice(2), acct.id);\n}\nasync function insertSystemMessage(room: string, body: string) {\n const now = Date.now();\n await sqlite.execute({\n sql:\n `INSERT INTO ${TABLE} (room, user_id, name, body, image_url, avatar_url, updated_at, created_at)\n VALUES (?, ?, ?, ?, '', '', ?, ?)`,\n args: [room, SYSTEM_USER, SYSTEM_USER, body, now, now],\n });\n}\nasync function readJson(req: Request): Promise {\n try {\n return await req.json();\n } catch (_e) {\n return {};\n }\n}\n\n// ---------- 通話シグナリングヘルパー ----------\ntype CallRow = {\n room: string;\n call_seq: number;\n caller_id: string;\n caller_name: string;\n caller_avatar: string;\n callee_id: string;\n status: string;\n offer: string;\n answer: string;\n caller_ice: string[];\n callee_ice: string[];\n started_at: number;\n updated_at: number;\n};\nasync function getCallRow(room: string): Promise {\n const r = await sqlite.execute({\n sql:\n `SELECT room, call_seq, caller_id, caller_name, caller_avatar, callee_id, status, offer, answer, caller_ice, callee_ice, started_at, updated_at\n FROM ${CALLS_TABLE} WHERE room = ?`,\n args: [room],\n });\n const row = (r.rows as any[])[0];\n if (!row) return null;\n let callerIce: string[] = [];\n let calleeIce: string[] = [];\n try {\n callerIce = JSON.parse(String(col(row, 9, \"caller_ice\") || \"[]\"));\n } catch (_e) {}\n try {\n calleeIce = JSON.parse(String(col(row, 10, \"callee_ice\") || \"[]\"));\n } catch (_e) {}\n return {\n room: String(col(row, 0, \"room\")),\n call_seq: Number(col(row, 1, \"call_seq\")),\n caller_id: String(col(row, 2, \"caller_id\") || \"\"),\n caller_name: String(col(row, 3, \"caller_name\") || \"\"),\n caller_avatar: col(row, 4, \"caller_avatar\")\n ? String(col(row, 4, \"caller_avatar\"))\n : \"\",\n callee_id: String(col(row, 5, \"callee_id\") || \"\"),\n status: String(col(row, 6, \"status\") || \"\"),\n offer: col(row, 7, \"offer\") ? String(col(row, 7, \"offer\")) : \"\",\n answer: col(row, 8, \"answer\") ? String(col(row, 8, \"answer\")) : \"\",\n caller_ice: callerIce,\n callee_ice: calleeIce,\n started_at: Number(col(row, 11, \"started_at\") ?? 0),\n updated_at: Number(col(row, 12, \"updated_at\") ?? 0),\n };\n}\n\n// バックグラウンド用 Service Worker 本体\nconst swJsContent = `\nself.addEventListener('push', function(event) {\n let data = {};\n try { data = event.data ? event.data.json() : {}; } catch(e) { data = { body: event.data ? event.data.text() : '' }; }\n const title = data.title || '新しいメッセージ';\n const options = {\n body: data.body || '',\n icon: data.icon || undefined,\n badge: '/favicon.ico',\n tag: data.tag || 'chat-message',\n renotify: true,\n vibrate: [200, 100, 200],\n requireInteraction: false,\n data: { url: data.url || '/', room: data.room || 'lobby' }\n };\n event.waitUntil(self.registration.showNotification(title, options));\n});\nself.addEventListener('notificationclick', function(event) {\n event.notification.close();\n const targetUrl = event.notification.data && event.notification.data.url ? event.notification.data.url : '/';\n event.waitUntil(\n clients.matchAll({ type: 'window', includeUncontrolled: true }).then(function(clientList) {\n for (const client of clientList) {\n if (client.url.includes(targetUrl) && 'focus' in client) return client.focus();\n }\n if (clients.openWindow) return clients.openWindow(targetUrl);\n })\n );\n});\n`;\n\n// ---------- PWA マニフェスト / アイコン ----------\n// iOS で Web Push を受け取るには「ホーム画面に追加」された PWA である必要があるため、\n// manifest.json とアイコン一式をこのアプリ自身で配信する。\nconst MANIFEST_JSON = JSON.stringify({\n name: \"LINE風チャット\",\n short_name: \"Chat\",\n start_url: \"/\",\n scope: \"/\",\n display: \"standalone\",\n background_color: \"#ffffff\",\n theme_color: \"#06c755\",\n icons: [\n { src: \"/icon-192.png\", sizes: \"192x192\", type: \"image/png\" },\n { src: \"/icon-512.png\", sizes: \"512x512\", type: \"image/png\" },\n ],\n});\n// 192x192 / 512x512 / apple-touch-icon(180x180) の緑のチャットバブルアイコン（PNG, base64）\nconst ICON_192_B64 =\n \"iVBORw0KGgoAAAANSUhEUgAAAMAAAADACAYAAABS3GwHAAAEnklEQVR4nO3b0VXbShiFUZmVRVqCQkiRUAhpKbyQh1znGmJsy5Y088/ZuwDQss6nsU2ymzpz//r03voaWM/b48uu9TUcanoxxs40tY1i819s9JyydQyb/TLDZ46tQlj9lxg+t1g7hNV+uOGzpLVCWPyHGj5rWjqEuyV/mPGztqU3tkhNhk8LS5wGN58Axk8rS2zvpgCMn9Zu3eDVARg/vbhli1cFYPz05tpNzg7A+OnVNducFYDx07u5G704AOOnijlbvSgA46eaSzd7NgDjp6pLtrvoP4WAak4G4OlPdec2/GUAxs8oTm3ZWyCiHQ3A05/RfLVpJwDR/gnA059RHdu2E4BoHwLw9Gd0nzfuBCDa3wA8/UlxuHUnANEEQLS7afL2hzz7zTsBiCYAogmAaAIg2s4HYJI5AYgmAKIJgGgCIJoAiCYAogmAaAIgmgCIJgCiCYBoAiCaAIgmAKIJgGjfWl/Amn49PLe+hGF8//mj9SWsYrj/EGP06xsphmECMPztjRBC+QAMv73KIZT+EGz8fah8H0oG8OvhufSLPqKq96NcAFVf6AQVH0ylAqj24qaqdJ9KBQBLKxNApacKde5XiQCqvJh8VOG+lQgA1tJ9ABWeInyt9/vXfQCwpq4D6P3pwWV6vo9dBwBrEwDRug2g52OT+Xq9n90GAFsQANEEQDQBEE0ARBMA0QRANAEQTQBEEwDRBEA0ARBNAEQTANEEQDQBEE0ARBMA0QRANAEQTQBEEwDRBEA0ARBNAEQTANEEQDQBEE0ARBMA0QRANAEQTQBEEwDRBEA0ARBNAEQTANEEQDQBEE0ARBMA0boN4PvPH60vgQX1ej+7DQC2IACidR1Ar8cm8/R8H7sOANbWfQA9Pz04r/f7130AsKYSAfT+FOG4CvetRADTVOPF5H9V7leZAKapzouartJ9KhUA/as0/mkqGEC1FzhJxXtTLoBp+vNCV3yxR1b1fpQMYK/qiz6ayvdhd//69N76Ipbw6+G59SXEqTz8vWEC2BPC+kYY/t5wARwSw3JGGv2hoQM4Z4lARh1GitIfglsz/voEcCXjH4MArmD84/jW+gIqMfzxOAEuZPxjEsAFjH9cAjjD+McmgBOMf3wC+ILxZxDAEcafQwCfGH8WARww/jwC+I/xZxLAZPzJ4gMw/mzRARg/0QGAAIgmAKIJgGgCIJoAiCYAogmAaAIgmgCIdvf2+LJrfRHQwtvjy84JQDQBEE0ARBMA0e6m6c+HgdYXAlvab94JQDQBEO1vAN4GkeJw604Aon0IwCnA6D5v3AlAtH8CcAowqmPbdgIQ7WgATgFG89WmnQBE+zIApwCjOLXlkyeACKju3Ia9BSLa2QCcAlR1yXYvOgFEQDWXbvbit0AioIo5W531GUAE9G7uRmd/CBYBvbpmm1d9CyQCenPtJq/+GlQE9OKWLd70dwAR0NqtG7z5D2EioJUltrfoeO9fn96X/HlwzJIP3UX/KYTTgLUtvbHVBus0YElrPVxXf2ILgVus/a5is7csQmCOrd5Ob/6eXQicsvXnyKYfWsXANLX98qS7b21EMbbevin8DdN4QJPdW9MOAAAAAElFTkSuQmCC\";\nconst ICON_512_B64 =\n \"iVBORw0KGgoAAAANSUhEUgAAAgAAAAIACAYAAAD0eNT6AAAOZElEQVR4nO3c0ZHTzBaFUQ31F6QEgUCQEAikBC/ch7kDBmyPLbekc3qvFYGtKWl/bhueFkp6+/Xjz6NfA8AIPz58eTr6NfAvf5SDGHiAZwLhGC76Dow9wH1EwfZc4A0YfICxBMF4LugABh9gX4LgcS7gSkYfoAYxsI6LdgejD1CbGLidC/UKow/Qkxi4zsW5wPADzEEInOeinDD6AHMTA7+5EIvhB0gjBMIDwPADZEsOgcg3bvgBOJUYAlFv2PADcE1SCES8UcMPwD0SQuDN0S9ga8YfgHslbMe0hZPwxwNge7OeBkz3pgw/AFuYLQSm+grA+AOwldk2Zoqame2PAkBtM5wGtD8BMP4A7G2G7WkdADP8AQDoqfsGtTzC6H7RAZhLx68E2p0AGH8Aqum4Ta0CoOMFBiBDt41qcWTR7aICkK3DVwLlTwCMPwDddNiu0gHQ4QICwDnVN6xsAFS/cADwmspbVjIAKl8wALhH1U0rFwBVLxQArFVx20oFQMULBAAjVNu4MgFQ7cIAwGiVtq5EAFS6IACwpSqbd3gAVLkQALCXCtt3aABUuAAAcISjN/CwADj6jQPA0Y7cwkMCwPgDwLOjNnH3ADD+APCnI7Zx1wAw/gBw3t4buVsAGH8AuG7PrdwlAIw/ANxmr808/P8BAAD2t3kA+PQPAPfZYzs3DQDjDwDrbL2hmwWA8QeAx2y5pX4DAACBNgkAn/4BYIytNnV4ABh/ABhri20dGgDGHwC2MXpj/QYAAAINCwCf/gFgWyO3dkgAGH8A2MeozfUVAAAEejgAfPoHgH2N2F4nAAAQ6KEA8OkfAI7x6AavDgDjDwDHemSLfQUAAIFWBYBP/wBQw9pNdgIAAIHuDgCf/gGgljXb7AQAAALdFQA+/QNATfdutBMAAAh0cwD49A8Atd2z1U4AACDQTQHg0z8A9HDrZjsBAIBAAgAAAr0aAI7/AaCXW7bbCQAABLoaAD79A0BPr224EwAACCQAACDQxQBw/A8AvV3bcicAABBIAABAoLMB4PgfAOZwadOdAABAIAEAAIH+CQDH/wAwl3Pb7gQAAAIJAAAIJAAAINAfAeD7fwCY098b7wQAAAIJAAAIJAAAINCvAPD9PwDM7XTrnQAAQCABAACBBAAABBIAABDozbL4ASAApHjZfCcAABBIAABAIAEAAIEEAAAEEgAAEEgAAEAgAQAAgZ78HwAAkMcJAAAEEgAAEEgAAEAgAQAAgQQAAAQSAAAQSAAAQCABAACBBAAABBIAABBIAABAIAEAAIEEAAAEEgAAEEgAAEAgAQAAgQQAAAQSAAAQSAAAQCABAACBBAAABBIAABBIAABAIAEAAIEEAAAEEgAAEEgAAEAgAQAAgQQAAAQSAAAQSAAAQCABAACBBAAABBIAABBIAABAIAEAAIH+O/oFMLfv7z8f/RKgtXffPh39EpjU09uvH38e/SLoz9DDvoQBjxIArGLwoQ4xwBoCgJsZfahPDHArAcCrDD/0JAa4RgBwkeGHOQgBzhEA/MPww5yEAKcEAL8YfsggBFgWAcBi+CGVEMjmfwIMZ/whl/s/mxOAUG584JTTgDxOAAIZf+Bvngt5BEAYNzlwiedDFgEQ4vv7z25u4FWeEzkEQAA3NHAPHxgyCIDJuYmBtTw/5iYAJubmBR7lOTIvATApNy0wiufJnATAhNyswGieK/MRAJNxkwJb8XyZiwCYiJsT2JrnzDwEAAAEEgCTUOXAXjxv5iAAJuBmBPbmudOfAGjOTQgcxfOnNwEAAIEEQGPqGzia51BfAqApNx1QhedRTwIAAAIJgIbUNlCN51I/AgAAAgmAZlQ2UJXnUy8CAAACCYBG1DVQnedUHwIAAAIJgCZUNdCF51UPAgAAAgmABtQ0AKMJAACG88GlPgEAAIEEQHEqGujK86s2AQAAgQQAAAQSAAAQSAAU5vszoDvPsboEAAAEEgAAEEgAAEAgAQAAgQQAAAQSAEX55SwwC8+zmgQAAAQSAAAQSAAAQCABAACBBAAABBIAABBIAABAIAEAAIEEAAAEEgAAEEgAAEAgAQAAgQQAAAQSAAAQSAAAQCABAACBBAAABBIAABBIAABAIAEAAIEEAAAEEgAAEEgAAEAgAQAAgQQAAAQSAAAQSAAAQCABAACBBAAABBIAABBIAABAIAEAAIEEAAAEEgAAEEgAAEAgAQAAgQQAAAQSAAAQSAAAQCABAACBBAAABBIAABBIAABAIAEAAIEEAAAEEgAAEEgAAEAgAQAAgQQAAAQSAAAQSAAAQCABAACBBAAABBIAABBIAABAIAEAAIEEAAAEEgAAEEgAAEAgAQAAgQQAAAQSAAAQSAAAQCABAACBBAAABBIAABBIAABAIAEAAIEEAAAEEgAAEEgAAEAgAQAAgQQAAAQSAAAQSAAAQCABAACBBAAABBIAABBIAABAIAEAAIEEAAAEEgAAEEgAAEAgAQAAgQQAAAQSAAAQSAAAQCABAACBBAAABBIAABBIAABAIAEAAIEEAAAEEgAAEEgAAEAgAQAAgQQAAAQSAAAQSAAAQCABAACBBAAABBIAABBIAABAIAFQ1Ltvn45+CQBDeJ7VJAAAIJAAAIBAAgAAAgkAAAgkAADYjB8A1iUACnPjALAVAQAAgQQAAAQSAMX5GgDoyvOrNgEAAIEEAAAEEgANOEYDuvHcqk8AAEAgAQAAgQRAE47TgC48r3oQAAAQSAA0oqqB6jyn+hAAABBIADSjroGqPJ96EQAAEEgANKSygWo8l/oRAAA8xPj3JACacsMB8AgB0JgIAI7mOdSXAABgFePfmwBozg0IwBoCYAIiANib505/AmASbkZgL543cxAAE3FTAlvznJmHAADgJsZ/LgJgMm5QAG4hACYkAoDRPFfmIwAm5WYFRvE8mZMAmJibFniU58i8BMDk3LzAGu++ffL8mJwACOAmBu7hmZFBAIRQ88AtPCdyCIAwbm7gEs+HLAIgkJscOOWEMJMACOWGB5bFB4JkAiCcmx8y+RCAAMCDAMK431mWZXl6+/Xjz6NfBLV8f//56JcAbMDwc0oAcJEQgDkYfs4RALxKCEBPhp9rBAB3EQNQm9HnVgKAVYQA1GH0WUMAMIQggP0YfEYQAGxKGMBjjD1bEQCU1zEiPLSB6vxHQDCY8Qc6EAAwkPEHuhAAMIjxBzoRADCA8Qe6EQDwIOMPdCQA4AHGH+hKAMBKxh/oTADACsYf6E4AwJ2MPzADAQB3MP7ALAQA3Mj4AzMRAHAD4w/M5r+jXwBUZviBWTkBgAuMPzAzAQBnGH9gdgIA/mL8gQQCAE4YfyCFAID/M/5AEgEAi/EH8ggA4hl/IJEAIJrxB1IJAGIZfyCZACCS8QfSCQDiGH8AAUAY4w/wTAAQw/gD/CYAiGD8Af4kAJie8Qf4lwBgasYf4DwBwLSMP8BlAoApGX+A6wQA0zH+AK8TAEzF+APcRgAwDeMPcDsBwBSMP8B9BADtGX+A+wkAWjP+AOsIANoy/gDrCQBaMv4AjxEAtGP8AR4nAGjF+AOMIQBow/gDjCMAaMH4A4wlACjP+AOMJwAAIJAAAIBAAgAAAgkAAAgkAAAgkAAAgEACAAACCQAACCQAACCQAACAQAIAAAIJAAAIJAAAIJAAAIBAAgAAAgkAAAgkAAAgkAAAgEACAAACCQAACCQAACCQAACAQG9+fPjydPSLAAD28+PDlycnAAAQSAAAQCABAACBBAAABBIAABBIAABAIAEAAIHeLMvzvwc8+oUAANt72XwnAAAQSAAAQCABAACBBAAABPoVAH4ICABzO916JwAAEEgAAEAgAQAAgf4IAL8DAIA5/b3xTgAAIJAAAIBAAgAAAv0TAH4HAABzObftTgAAIJAAAIBAZwPA1wAAMIdLm+4EAAACCQAACHQxAHwNAAC9XdtyJwAAEEgAAECgqwHgawAA6Om1DXcCAACBXg0ApwAA0Mst2+0EAAACCQAACHRTAPgaAAB6uHWznQAAQKCbA8ApAADUds9WOwEAgEB3BYBTAACo6d6NdgIAAIHuDgCnAABQy5ptdgIAAIFWBYBTAACoYe0mOwEAgECrA8ApAAAc65EtfugEQAQAwDEe3WBfAQBAoIcDwCkAAOxrxPY6AQCAQEMCwCkAAOxj1OYOOwEQAQCwrZFb6ysAAAg0NACcAgDANkZv7PATABEAAGNtsa2bfAUgAgBgjK021W8AACDQZgHgFAAAHrPllm56AiACAGCdrTd0868ARAAA3GeP7fQbAAAItEsAOAUAgNvstZm7nQCIAAC4bs+t3PUrABEAAOftvZG7/wZABADAn47YxkN+BCgCAODZUZt42L8CEAEApDtyCw/9Z4AiAIBUR2/g4f8PwNEXAAD2VmH7Dg+AZalxIQBgD1U2r0QALEudCwIAW6m0dWUCYFlqXRgAGKnaxpUKgGWpd4EA4FEVt61cACxLzQsFAGtU3bSSAbAsdS8YANyq8paVDYBlqX3hAOCa6htWOgCWpf4FBIC/ddiu8i/w1NuvH38e/RoA4JIOw/+i/AnAqU4XFoAs3TaqVQAsS78LDMD8Om5Tuxd8ylcCAByp4/C/aHcCcKrzhQegt+4b1DoAlqX/HwCAfmbYnvZv4JSvBADY0gzD/6L9CcCpmf4wANQy28ZM9WZOOQ0AYITZhv/FlG/qlBAAYI1Zh//FVF8BnDP7HxCA8RK2Y/o3eMppAADXJAz/i5g3ekoIAHAqafhfxL3hU0IAIFvi8L+IfeOnhABAluThfxF/AU4JAYC5Gf7fXIgLxADAHIz+eS7KK4QAQE+G/zoX5w5iAKA2o387F2olMQBQg9Ffx0UbQAwA7MvoP84F3IAgABjL4I/ngu5AEADcx+BvzwU+iCgAeGbsj+GiFyUQgFkY+Jr+B2+3QY2IH5dXAAAAAElFTkSuQmCC\";\nconst APPLE_TOUCH_ICON_B64 =\n \"iVBORw0KGgoAAAANSUhEUgAAALQAAAC0CAYAAAA9zQYyAAAEOklEQVR4nO3a3VEjSRCF0RYxwbgEhjBGgiGMS/DCPuwyC4yA/lVn3j7HAFFR9XWqJHEaCrh+vHvZew0s93z7cNp7DbssQMDHsEfgF/uDIj62S8W96R8RMedsGfcmLyxkxtgi7Ku1X1DMjLVFK6s9IUJmibWm9SoTWswstVZDi54KIbOFJdN69oQWM1tZ0tasoMXM1uY2NjloMXMpc1qbFLSYubSpzY0OWszsZUp7o4IWM3sb2+C3QYuZKsa0uPpP37CnL4M2nanmuyY/DVrMVPVVm64cRDkbtOlMdZ81+lfQYqaLc626chDlXdCmM918bNaEJoqgifInaNcNunrbrglNFEET5WoYXDfo77VhE5oogiaKoIlycn8miQlNFEETRdBEETRRBE0UQRNF0EQRNFEETRRBE0XQRBE0UQRNFEETRdBE+bH3Atb2dHO/9xLa+fn7195LWE3EP/iLeD3d424btIi31TXslndoMW/v6ea+5T63C7rjJnfWbb/bBN11YiTotO8tgu60oam6nEGLoKmhQ9Tlg+6wiUdS/TxKB119846q8rmUDbryplFX2aCprerAETRRSgZd9ennvYrnVDJomEvQRCkXdMW3MT5X7bzKBQ1LCJoogiaKoIkiaKIImiiCJoqgiSJoogiaKIImiqCJImiiCJoogiaKoIkiaKIImiiCJoqgiSJoogiaKIImiqCJImiiCJoogiaKoIkiaKIImiiCJoqgiSJoogiaKIImiqCJImiiCJoogiZKuaB//v619xKYoNp5lQsalhA0UUoGXe1tjPMqnlPJoGGuskFXfPr5X9XzKRs0zFE66KpT4Ogqn0vpoIeh9uYdUfXzKB/0MNTfxKPocA4tgh6GHpuZrMv+twl6GPpsappO+94q6GHotbkJuu336frx7mXvRcz1dHO/9xJidQv5VeugXwl7PV1DfhUR9Fvinq57xG/FBf2VpbEnHXyqdh8K9yLmHgQ9gpj7EPQ3xNzLj70XUJWQezKhzxBzX4L+QMy9CfoNMfcn6P+IOYOgBzEnOXzQYs5y6KDFnOewQYs50yGDFnOuwwUt5myHClrM+Q4VNPkETRRBE0XQRBE0UQRNFEETRdBEETRRBE2Uq+fbh9Pei4A1PN8+nExoogiaKIImytUw/Hv32HshsMRrwyY0UQRNlD9Bu3bQ1dt2TWiiCJoo74J27aCbj82a0ET5K2hTmi7OtXp2Qoua6j5r1JWDKJ8GbUpT1VdtfjmhRU013zXpykGUb4M2paliTIujJrSo2dvYBkdfOUTNXqa0N+kOLWoubWpzkz8UippLmdParG85RM3W5jY2+2s7UbOVJW2tEuX1493LGq/Dsa0xJFf5YcW0Zqm1Glo9RNOaKdYehqv/9G1aM9YWrWwan2nNOVsOvYtNU3Ef26XeuXe5Hoj7GPa4fpa47wo8Q4XPT/8AmY8pyT3Jp4cAAAAASUVORK5CYII=\";\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname;\n\n // /sw.js を正規配信\n if (path === \"/sw.js\") {\n return new Response(swJsContent, {\n headers: {\n \"Content-Type\": \"application/javascript; charset=utf-8\",\n \"Cache-Control\": \"no-cache\",\n },\n });\n }\n\n // PWA マニフェスト & アイコン（iOS のホーム画面追加 / Push 通知に必要）\n if (path === \"/manifest.json\") {\n return new Response(MANIFEST_JSON, {\n headers: {\n \"Content-Type\": \"application/manifest+json; charset=utf-8\",\n \"Cache-Control\": \"no-cache\",\n },\n });\n }\n if (path === \"/icon-192.png\") {\n return new Response(base64ToBytes(ICON_192_B64), {\n headers: {\n \"Content-Type\": \"image/png\",\n \"Cache-Control\": \"public, max-age=86400\",\n },\n });\n }\n if (path === \"/icon-512.png\") {\n return new Response(base64ToBytes(ICON_512_B64), {\n headers: {\n \"Content-Type\": \"image/png\",\n \"Cache-Control\": \"public, max-age=86400\",\n },\n });\n }\n if (path === \"/apple-touch-icon.png\") {\n return new Response(base64ToBytes(APPLE_TOUCH_ICON_B64), {\n headers: {\n \"Content-Type\": \"image/png\",\n \"Cache-Control\": \"public, max-age=86400\",\n },\n });\n }\n\n // ===================== アカウント API =====================\n\n // --- 登録 ---\n if (path === \"/api/account/register\" && req.method === \"POST\") {\n const data = await readJson(req);\n const name = String(data.name || \"\").trim().slice(0, 40);\n if (!name) return json({ error: \"name_required\" }, 400);\n const lineId = normalizeLineId(data.line_id);\n if (lineId === \"__invalid__\") {\n return json({ error: \"invalid_line_id\" }, 400);\n }\n if (lineId) {\n const dup = await sqlite.execute({\n sql: `SELECT 1 FROM ${ACCOUNTS_TABLE} WHERE line_id = ?`,\n args: [lineId],\n });\n if ((dup.rows as any[]).length > 0) {\n return json({ error: \"id_taken\" }, 409);\n }\n }\n const id = genId(\"u\", 10);\n const token = genToken();\n const now = Date.now();\n await sqlite.execute({\n sql:\n `INSERT INTO ${ACCOUNTS_TABLE} (id, token, line_id, name, avatar_url, status_msg, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n id,\n token,\n lineId,\n name,\n String(data.avatar_url || \"\"),\n String(data.status_msg || \"\").slice(0, 100),\n now,\n now,\n ],\n });\n const acct = await getAccount(id);\n return json({ account: { ...acct, token } });\n }\n\n // --- 更新 ---\n if (path === \"/api/account/update\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const name = data.name != null\n ? String(data.name).trim().slice(0, 40)\n : acct.name;\n if (!name) return json({ error: \"name_required\" }, 400);\n let lineId: string | null = acct.line_id;\n if (data.line_id !== undefined) {\n const n = normalizeLineId(data.line_id);\n if (n === \"__invalid__\") return json({ error: \"invalid_line_id\" }, 400);\n if (n && n !== acct.line_id) {\n const dup = await sqlite.execute({\n sql: `SELECT 1 FROM ${ACCOUNTS_TABLE} WHERE line_id = ? AND id != ?`,\n args: [n, acct.id],\n });\n if ((dup.rows as any[]).length > 0) {\n return json({ error: \"id_taken\" }, 409);\n }\n }\n lineId = n;\n }\n const avatar = data.avatar_url !== undefined\n ? String(data.avatar_url || \"\")\n : acct.avatar_url;\n const status = data.status_msg !== undefined\n ? String(data.status_msg || \"\").slice(0, 100)\n : acct.status_msg;\n await sqlite.execute({\n sql:\n `UPDATE ${ACCOUNTS_TABLE} SET name = ?, line_id = ?, avatar_url = ?, status_msg = ?, updated_at = ? WHERE id = ?`,\n args: [name, lineId, avatar, status, Date.now(), acct.id],\n });\n return json({ account: await getAccount(acct.id) });\n }\n\n // --- 自分の情報（友だち・グループ込み） ---\n if (path === \"/api/account/me\" && req.method === \"GET\") {\n const acct = await authAccount(\n url.searchParams.get(\"account_id\"),\n url.searchParams.get(\"token\"),\n );\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n\n const fr = await sqlite.execute({\n sql: `SELECT a.id, a.line_id, a.name, a.avatar_url, a.status_msg\n FROM ${FRIENDS_TABLE} f JOIN ${ACCOUNTS_TABLE} a ON a.id = f.friend_id\n WHERE f.account_id = ? ORDER BY a.name COLLATE NOCASE ASC`,\n args: [acct.id],\n });\n const friends = (fr.rows as any[]).map(accountFromRow);\n\n const gr = await sqlite.execute({\n sql: `SELECT g.id, g.name, g.icon_url, g.created_by, g.created_at,\n (SELECT COUNT(*) FROM ${GROUP_MEMBERS_TABLE} c WHERE c.group_id = g.id) AS member_count\n FROM ${GROUP_MEMBERS_TABLE} m JOIN ${GROUPS_TABLE} g ON g.id = m.group_id\n WHERE m.account_id = ? ORDER BY g.created_at DESC`,\n args: [acct.id],\n });\n const groups = (gr.rows as any[]).map((row) => ({\n id: String(col(row, 0, \"id\")),\n name: String(col(row, 1, \"name\")),\n icon_url: col(row, 2, \"icon_url\") ? String(col(row, 2, \"icon_url\")) : \"\",\n created_by: String(col(row, 3, \"created_by\")),\n created_at: Number(col(row, 4, \"created_at\")),\n member_count: Number(col(row, 5, \"member_count\") ?? 0),\n }));\n\n return json({ account: acct, friends, groups });\n }\n\n // --- 公開プロフィール検索（LINE ID / アカウントID） ---\n if (path === \"/api/account/lookup\" && req.method === \"GET\") {\n const lineId = normalizeLineId(url.searchParams.get(\"line_id\"));\n const accountId = url.searchParams.get(\"account_id\") || \"\";\n let acct: Account | null = null;\n if (lineId && lineId !== \"__invalid__\") {\n const r = await sqlite.execute({\n sql: `SELECT ${ACCOUNT_COLS} FROM ${ACCOUNTS_TABLE} WHERE line_id = ?`,\n args: [lineId],\n });\n const row = (r.rows as any[])[0];\n acct = row ? accountFromRow(row) : null;\n } else if (accountId) {\n acct = await getAccount(accountId);\n }\n if (!acct) return json({ error: \"not_found\" }, 404);\n return json({ account: acct });\n }\n\n // --- 友だち追加（相互） ---\n if (path === \"/api/friends/add\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const friendId = String(data.friend_id || \"\");\n if (!friendId || friendId === acct.id) {\n return json({ error: \"invalid_friend\" }, 400);\n }\n const friend = await getAccount(friendId);\n if (!friend) return json({ error: \"not_found\" }, 404);\n const now = Date.now();\n await sqlite.execute({\n sql:\n `INSERT OR IGNORE INTO ${FRIENDS_TABLE} (account_id, friend_id, created_at) VALUES (?, ?, ?)`,\n args: [acct.id, friend.id, now],\n });\n await sqlite.execute({\n sql:\n `INSERT OR IGNORE INTO ${FRIENDS_TABLE} (account_id, friend_id, created_at) VALUES (?, ?, ?)`,\n args: [friend.id, acct.id, now],\n });\n return json({ success: true, friend, room: dmRoomFor(acct.id, friend.id) });\n }\n\n // --- グループ作成 ---\n if (path === \"/api/groups/create\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const name = String(data.name || \"\").trim().slice(0, 50);\n if (!name) return json({ error: \"name_required\" }, 400);\n const memberIds: string[] = Array.isArray(data.member_ids)\n ? data.member_ids.map((s: unknown) => String(s)).filter((s: string) =>\n s && s !== acct.id\n )\n : [];\n const id = genId(\"\", 10);\n const now = Date.now();\n await sqlite.execute({\n sql:\n `INSERT INTO ${GROUPS_TABLE} (id, name, icon_url, created_by, created_at) VALUES (?, ?, ?, ?, ?)`,\n args: [id, name, String(data.icon_url || \"\"), acct.id, now],\n });\n await sqlite.execute({\n sql:\n `INSERT OR IGNORE INTO ${GROUP_MEMBERS_TABLE} (group_id, account_id, joined_at) VALUES (?, ?, ?)`,\n args: [id, acct.id, now],\n });\n const existing = await getAccountsByIds(memberIds);\n for (const mid of memberIds) {\n if (!existing[mid]) continue;\n await sqlite.execute({\n sql:\n `INSERT OR IGNORE INTO ${GROUP_MEMBERS_TABLE} (group_id, account_id, joined_at) VALUES (?, ?, ?)`,\n args: [id, mid, now],\n });\n }\n const names = [\n acct.name,\n ...memberIds.filter((m) => existing[m]).map((m) => existing[m].name),\n ];\n await insertSystemMessage(\n \"g:\" + id,\n acct.name + \"がグループを作成しました。\" +\n (names.length > 1\n ? \" \" + names.slice(1).join(\"、\") + \"が参加しました。\"\n : \"\"),\n );\n return json({ success: true, group: await getGroup(id), room: \"g:\" + id });\n }\n\n // --- グループ参加（招待リンク） ---\n if (path === \"/api/groups/join\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const group = await getGroup(String(data.group_id || \"\"));\n if (!group) return json({ error: \"not_found\" }, 404);\n if (!(await isGroupMember(group.id, acct.id))) {\n await sqlite.execute({\n sql:\n `INSERT OR IGNORE INTO ${GROUP_MEMBERS_TABLE} (group_id, account_id, joined_at) VALUES (?, ?, ?)`,\n args: [group.id, acct.id, Date.now()],\n });\n await insertSystemMessage(\n \"g:\" + group.id,\n acct.name + \"が参加しました。\",\n );\n }\n return json({ success: true, group, room: \"g:\" + group.id });\n }\n\n // --- グループに友だちを招待 ---\n if (path === \"/api/groups/invite\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const group = await getGroup(String(data.group_id || \"\"));\n if (!group) return json({ error: \"not_found\" }, 404);\n if (!(await isGroupMember(group.id, acct.id))) {\n return json({ error: \"forbidden\" }, 403);\n }\n const memberIds: string[] = Array.isArray(data.member_ids)\n ? data.member_ids.map((s: unknown) => String(s))\n : [];\n const existing = await getAccountsByIds(memberIds);\n const added: string[] = [];\n for (const mid of memberIds) {\n if (!existing[mid]) continue;\n if (await isGroupMember(group.id, mid)) continue;\n await sqlite.execute({\n sql:\n `INSERT OR IGNORE INTO ${GROUP_MEMBERS_TABLE} (group_id, account_id, joined_at) VALUES (?, ?, ?)`,\n args: [group.id, mid, Date.now()],\n });\n added.push(existing[mid].name);\n }\n if (added.length > 0) {\n await insertSystemMessage(\n \"g:\" + group.id,\n acct.name + \"が\" + added.join(\"、\") + \"を招待しました。\",\n );\n }\n return json({ success: true, added: added.length });\n }\n\n // --- グループ退会 ---\n if (path === \"/api/groups/leave\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const groupId = String(data.group_id || \"\");\n await sqlite.execute({\n sql:\n `DELETE FROM ${GROUP_MEMBERS_TABLE} WHERE group_id = ? AND account_id = ?`,\n args: [groupId, acct.id],\n });\n await insertSystemMessage(\"g:\" + groupId, acct.name + \"が退会しました。\");\n return json({ success: true });\n }\n\n // --- ルーム情報（ヘッダー表示・メニュー用） ---\n if (path === \"/api/room-info\" && req.method === \"GET\") {\n const room = url.searchParams.get(\"room\") || \"lobby\";\n const accountId = url.searchParams.get(\"account_id\");\n const token = url.searchParams.get(\"token\");\n if (!isAccountRoom(room)) {\n return json({\n type: \"random\",\n room,\n title: \"#\" + room,\n icon: \"\",\n members: [],\n });\n }\n const acct = await authAccount(accountId, token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n if (isDmRoom(room)) {\n const ids = dmMembers(room);\n if (!ids.includes(acct.id)) return json({ error: \"forbidden\" }, 403);\n const map = await getAccountsByIds(ids);\n const other = ids.filter((i) =>\n i !== acct.id\n ).map((i) => map[i]).filter(Boolean)[0];\n return json({\n type: \"dm\",\n room,\n title: other ? other.name : \"不明なユーザー\",\n icon: other ? other.avatar_url : \"\",\n other_id: other ? other.id : \"\",\n members: ids.map((i) => map[i]).filter(Boolean),\n });\n }\n const group = await getGroup(room.slice(2));\n if (!group) return json({ error: \"not_found\" }, 404);\n if (!(await isGroupMember(group.id, acct.id))) {\n return json({ error: \"forbidden\" }, 403);\n }\n const members = await getGroupMembers(group.id);\n return json({\n type: \"group\",\n room,\n title: group.name,\n icon: group.icon_url,\n group_id: group.id,\n members,\n });\n }\n\n // ===================== Push =====================\n\n if (path === \"/api/subscribe\" && req.method === \"POST\") {\n try {\n const data = await req.json();\n const { user_id, room, subscription } = data;\n if (!user_id || !room || !subscription) {\n return json({ error: \"invalid data\" }, 400);\n }\n await sqlite.execute({\n sql:\n `INSERT INTO ${PUSH_SUB_TABLE} (user_id, room, subscription) VALUES (?, ?, ?)\n ON CONFLICT(user_id, room) DO UPDATE SET subscription = excluded.subscription`,\n args: [user_id, room, JSON.stringify(subscription)],\n });\n return json({ success: true });\n } catch (err) {\n return json({ error: String(err) }, 400);\n }\n }\n\n if (path === \"/api/vapid-public-key\") {\n return json({ publicKey: vapidKeys.publicKey });\n }\n\n // ===================== 通話シグナリング（WebRTC / 1:1 DM のみ） =====================\n // 音声データ自体は P2P（または端末側が用意した STUN/TURN）で流れるため、\n // ここで扱うのは offer/answer/ICE candidate の橋渡しのみ（無料の Google STUN 前提の構成）。\n\n // --- 発信（オファー送信） ---\n if (path === \"/api/call/offer\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const room = String(data.room || \"\");\n const targetId = String(data.target_id || \"\");\n const offer = String(data.offer || \"\");\n if (!isDmRoom(room) || !offer || !targetId || targetId === acct.id) {\n return json({ error: \"invalid_call\" }, 400);\n }\n if (\n !dmMembers(room).includes(acct.id) || !dmMembers(room).includes(targetId)\n ) {\n return json({ error: \"forbidden\" }, 403);\n }\n const now = Date.now();\n const existing = await getCallRow(room);\n if (\n existing &&\n (existing.status === \"ringing\" || existing.status === \"accepted\") &&\n now - existing.updated_at < 60000\n ) {\n return json({ error: \"call_in_progress\" }, 409);\n }\n const nextSeq = existing ? existing.call_seq + 1 : 1;\n await sqlite.execute({\n sql:\n `INSERT INTO ${CALLS_TABLE} (room, call_seq, caller_id, caller_name, caller_avatar, callee_id, status, offer, answer, caller_ice, callee_ice, started_at, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, 'ringing', ?, NULL, '[]', '[]', ?, ?)\n ON CONFLICT(room) DO UPDATE SET call_seq = excluded.call_seq, caller_id = excluded.caller_id, caller_name = excluded.caller_name,\n caller_avatar = excluded.caller_avatar, callee_id = excluded.callee_id, status = 'ringing', offer = excluded.offer,\n answer = NULL, caller_ice = '[]', callee_ice = '[]', started_at = excluded.started_at, updated_at = excluded.updated_at`,\n args: [\n room,\n nextSeq,\n acct.id,\n acct.name,\n acct.avatar_url || \"\",\n targetId,\n offer,\n now,\n now,\n ],\n });\n\n // 着信通知（既存の Push 基盤を流用。iOS はホーム画面追加済みの場合のみ届く）\n try {\n const subsResult = await sqlite.execute({\n sql:\n `SELECT subscription FROM ${PUSH_SUB_TABLE} WHERE room = ? AND user_id != ?`,\n args: [room, acct.id],\n });\n for (const row of subsResult.rows as any[]) {\n try {\n const sub = JSON.parse(String(row[0] ?? row.subscription));\n const payload = JSON.stringify({\n title: acct.name,\n body: \"着信中...\",\n tag: `call-${room}`,\n icon: acct.avatar_url && !acct.avatar_url.startsWith(\"data:\")\n ? acct.avatar_url\n : undefined,\n url: \"/#\" + room,\n room,\n });\n webpush.sendNotification(sub, payload).catch(() => {});\n } catch (_e) {\n // パースエラー等は無視\n }\n }\n } catch (_e) {\n // 通知送信の失敗は発信そのものを妨げない\n }\n\n return json({ success: true, call_seq: nextSeq });\n }\n\n // --- 応答（アンサー送信） ---\n if (path === \"/api/call/answer\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const room = String(data.room || \"\");\n const callSeq = Number(data.call_seq);\n const answer = String(data.answer || \"\");\n const existing = await getCallRow(room);\n if (\n !existing || existing.call_seq !== callSeq ||\n existing.callee_id !== acct.id || existing.status !== \"ringing\"\n ) {\n return json({ error: \"invalid_call\" }, 400);\n }\n await sqlite.execute({\n sql:\n `UPDATE ${CALLS_TABLE} SET answer = ?, status = 'accepted', updated_at = ? WHERE room = ? AND call_seq = ?`,\n args: [answer, Date.now(), room, callSeq],\n });\n return json({ success: true });\n }\n\n // --- ICE candidate 交換 ---\n if (path === \"/api/call/ice\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const room = String(data.room || \"\");\n const callSeq = Number(data.call_seq);\n const candidate = String(data.candidate || \"\");\n const existing = await getCallRow(room);\n if (!existing || existing.call_seq !== callSeq) {\n return json({ error: \"invalid_call\" }, 400);\n }\n if (existing.caller_id !== acct.id && existing.callee_id !== acct.id) {\n return json({ error: \"forbidden\" }, 403);\n }\n const isCaller = existing.caller_id === acct.id;\n const field = isCaller ? \"caller_ice\" : \"callee_ice\";\n const list = isCaller ? existing.caller_ice : existing.callee_ice;\n list.push(candidate);\n await sqlite.execute({\n sql:\n `UPDATE ${CALLS_TABLE} SET ${field} = ?, updated_at = ? WHERE room = ? AND call_seq = ?`,\n args: [JSON.stringify(list), Date.now(), room, callSeq],\n });\n return json({ success: true });\n }\n\n // --- 終了 / 拒否 ---\n if (path === \"/api/call/end\" && req.method === \"POST\") {\n const data = await readJson(req);\n const acct = await authAccount(data.account_id, data.token);\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const room = String(data.room || \"\");\n const callSeq = Number(data.call_seq);\n const existing = await getCallRow(room);\n if (!existing || existing.call_seq !== callSeq) {\n return json({ success: true });\n }\n if (existing.caller_id !== acct.id && existing.callee_id !== acct.id) {\n return json({ error: \"forbidden\" }, 403);\n }\n const newStatus = existing.status === \"ringing\" ? \"rejected\" : \"ended\";\n await sqlite.execute({\n sql:\n `UPDATE ${CALLS_TABLE} SET status = ?, updated_at = ? WHERE room = ? AND call_seq = ?`,\n args: [newStatus, Date.now(), room, callSeq],\n });\n return json({ success: true });\n }\n\n // --- 通話状態のポーリング（signaling の受信側） ---\n if (path === \"/api/call/state\" && req.method === \"GET\") {\n const room = url.searchParams.get(\"room\") || \"\";\n const acct = await authAccount(\n url.searchParams.get(\"account_id\"),\n url.searchParams.get(\"token\"),\n );\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n if (!isDmRoom(room) || !dmMembers(room).includes(acct.id)) {\n return json({ error: \"forbidden\" }, 403);\n }\n const call = await getCallRow(room);\n return json({ call });\n }\n\n // --- 着信の常時監視用（どの画面にいても着信をポップアップさせる） ---\n if (path === \"/api/call/incoming\" && req.method === \"GET\") {\n const acct = await authAccount(\n url.searchParams.get(\"account_id\"),\n url.searchParams.get(\"token\"),\n );\n if (!acct) return json({ error: \"unauthorized\" }, 403);\n const r = await sqlite.execute({\n sql:\n `SELECT room, call_seq, caller_id, caller_name, caller_avatar, callee_id, status, offer, updated_at FROM ${CALLS_TABLE}\n WHERE callee_id = ? AND status = 'ringing' AND updated_at > ?`,\n args: [acct.id, Date.now() - 45000],\n });\n const calls = (r.rows as any[]).map((row) => ({\n room: String(col(row, 0, \"room\")),\n call_seq: Number(col(row, 1, \"call_seq\")),\n caller_id: String(col(row, 2, \"caller_id\")),\n caller_name: String(col(row, 3, \"caller_name\")),\n caller_avatar: col(row, 4, \"caller_avatar\")\n ? String(col(row, 4, \"caller_avatar\"))\n : \"\",\n offer: String(col(row, 7, \"offer\") || \"\"),\n updated_at: Number(col(row, 8, \"updated_at\")),\n }));\n return json({ calls });\n }\n\n // ===================== トーク一覧 =====================\n // ランダムルーム（匿名ID/アカウントIDどちらでも発言済み）＋ 1:1 ＋グループを統合して返す\n if (path === \"/api/rooms\" && req.method === \"GET\") {\n const anonId = url.searchParams.get(\"user_id\") || \"\";\n const acct = await authAccount(\n url.searchParams.get(\"account_id\"),\n url.searchParams.get(\"token\"),\n );\n let reads: Record = {};\n try {\n reads = JSON.parse(url.searchParams.get(\"reads\") || \"{}\") || {};\n } catch (_e) {\n reads = {};\n }\n const myIds = [anonId, acct ? acct.id : \"\"].filter((s) => !!s);\n if (myIds.length === 0) return json({ rooms: [] });\n\n type RoomEntry = {\n room: string;\n type: \"random\" | \"dm\" | \"group\";\n title: string;\n icon: string;\n member_count: number;\n created_at: number;\n };\n const entries: Record = {};\n\n // 1) ランダムルーム\n const rr = await sqlite.execute({\n sql: `SELECT DISTINCT room FROM ${TABLE}\n WHERE user_id IN (${myIds.map(() => \"?\").join(\",\")})\n AND room NOT LIKE 'dm:%' AND room NOT LIKE 'g:%'`,\n args: myIds,\n });\n for (const row of rr.rows as any[]) {\n const room = String(col(row, 0, \"room\"));\n entries[room] = {\n room,\n type: \"random\",\n title: \"#\" + room,\n icon: \"\",\n member_count: 0,\n created_at: 0,\n };\n }\n\n if (acct) {\n // 2) 1:1 トーク（メッセージが存在するもの）\n const dr = await sqlite.execute({\n sql: `SELECT DISTINCT room FROM ${TABLE}\n WHERE room LIKE 'dm:%' AND (room LIKE ? OR room LIKE ?)`,\n args: [\"dm:\" + acct.id + \"-%\", \"dm:%-\" + acct.id],\n });\n const otherIds: string[] = [];\n const dmRooms: string[] = [];\n for (const row of dr.rows as any[]) {\n const room = String(col(row, 0, \"room\"));\n const ids = dmMembers(room);\n if (!ids.includes(acct.id)) continue;\n const other = ids.find((i) => i !== acct.id) || acct.id;\n otherIds.push(other);\n dmRooms.push(room);\n }\n const others = await getAccountsByIds(otherIds);\n dmRooms.forEach((room, idx) => {\n const o = others[otherIds[idx]];\n entries[room] = {\n room,\n type: \"dm\",\n title: o ? o.name : \"不明なユーザー\",\n icon: o ? o.avatar_url : \"\",\n member_count: 2,\n created_at: 0,\n };\n });\n\n // 3) グループ（メッセージが無くても表示）\n const gr = await sqlite.execute({\n sql: `SELECT g.id, g.name, g.icon_url, g.created_at,\n (SELECT COUNT(*) FROM ${GROUP_MEMBERS_TABLE} c WHERE c.group_id = g.id) AS member_count\n FROM ${GROUP_MEMBERS_TABLE} m JOIN ${GROUPS_TABLE} g ON g.id = m.group_id\n WHERE m.account_id = ?`,\n args: [acct.id],\n });\n for (const row of gr.rows as any[]) {\n const room = \"g:\" + String(col(row, 0, \"id\"));\n entries[room] = {\n room,\n type: \"group\",\n title: String(col(row, 1, \"name\")),\n icon: col(row, 2, \"icon_url\") ? String(col(row, 2, \"icon_url\")) : \"\",\n member_count: Number(col(row, 4, \"member_count\") ?? 0),\n created_at: Number(col(row, 3, \"created_at\")),\n };\n }\n }\n\n const roomKeys = Object.keys(entries);\n if (roomKeys.length === 0) return json({ rooms: [] });\n const ph = roomKeys.map(() => \"?\").join(\",\");\n\n // 最新メッセージ\n const latest = await sqlite.execute({\n sql:\n `SELECT t.room, t.id, t.name, t.body, t.deleted, t.created_at, t.image_url, t.poll_id, t.user_id\n FROM ${TABLE} t\n INNER JOIN (SELECT room, MAX(id) AS max_id FROM ${TABLE} WHERE room IN (${ph}) GROUP BY room) l\n ON t.room = l.room AND t.id = l.max_id`,\n args: roomKeys,\n });\n const latestMap: Record = {};\n for (const row of latest.rows as any[]) {\n latestMap[String(col(row, 0, \"room\"))] = {\n last_message_id: Number(col(row, 1, \"id\")),\n last_name: String(col(row, 2, \"name\")),\n last_body: String(col(row, 3, \"body\")),\n last_deleted: Number(col(row, 4, \"deleted\") ?? 0) === 1,\n last_created_at: Number(col(row, 5, \"created_at\")),\n last_has_image: !!col(row, 6, \"image_url\"),\n last_is_poll: col(row, 7, \"poll_id\") != null,\n last_is_system: String(col(row, 8, \"user_id\")) === SYSTEM_USER,\n };\n }\n\n // 未読数（自分以外の発言で、クライアントが最後に読んだ id より新しいもの）\n const unreadMap: Record = {};\n const conds: string[] = [];\n const condArgs: (string | number)[] = [];\n for (const room of roomKeys) {\n conds.push(\"(room = ? AND id > ?)\");\n condArgs.push(room, Number(reads[room] || 0));\n }\n const ur = await sqlite.execute({\n sql: `SELECT room, COUNT(*) FROM ${TABLE}\n WHERE deleted = 0 AND user_id NOT IN (${\n myIds.map(() => \"?\").join(\",\")\n }, ?)\n AND (${conds.join(\" OR \")})\n GROUP BY room`,\n args: [...myIds, SYSTEM_USER, ...condArgs],\n });\n for (const row of ur.rows as any[]) {\n unreadMap[String(col(row, 0, \"room\"))] = Number(\n col(row, 1, \"COUNT(*)\") ?? row[1] ?? 0,\n );\n }\n\n const rooms = roomKeys.map((room) => {\n const e = entries[room];\n const l = latestMap[room] || {\n last_message_id: 0,\n last_name: \"\",\n last_body: \"\",\n last_deleted: false,\n last_created_at: e.created_at,\n last_has_image: false,\n last_is_poll: false,\n last_is_system: false,\n };\n return { ...e, ...l, unread: unreadMap[room] || 0 };\n }).sort((a, b) => b.last_created_at - a.last_created_at);\n\n return json({ rooms });\n }\n\n // ===================== メッセージ =====================\n\n if (path === \"/api/messages\") {\n const room = url.searchParams.get(\"room\") || \"lobby\";\n const since = Number(url.searchParams.get(\"since\") || \"0\");\n const sinceUpdate = Number(url.searchParams.get(\"sinceUpdate\") || \"0\");\n const viewer = url.searchParams.get(\"viewer\") || \"\";\n const viewerName = url.searchParams.get(\"name\") || \"\";\n const markRead = url.searchParams.get(\"read\") === \"1\";\n\n if (isAccountRoom(room)) {\n const ok = await canAccessRoom(\n room,\n viewer,\n url.searchParams.get(\"token\"),\n );\n if (!ok) return json({ error: \"forbidden\" }, 403);\n }\n\n if (viewer) {\n const now = Date.now();\n if (markRead) {\n await sqlite.execute({\n sql:\n `INSERT INTO ${PRESENCE_TABLE} (room, user_id, name, last_seen, last_read_id)\n VALUES (?, ?, ?, ?, (SELECT COALESCE(MAX(id), 0) FROM ${TABLE} WHERE room = ?))\n ON CONFLICT(room, user_id) DO UPDATE SET\n name = excluded.name, last_seen = excluded.last_seen,\n last_read_id = MAX(COALESCE(${PRESENCE_TABLE}.last_read_id, 0), excluded.last_read_id)`,\n args: [room, viewer, viewerName || \"名無し\", now, room],\n });\n } else {\n await sqlite.execute({\n sql:\n `INSERT INTO ${PRESENCE_TABLE} (room, user_id, name, last_seen, last_read_id)\n VALUES (?, ?, ?, ?, 0)\n ON CONFLICT(room, user_id) DO UPDATE SET name = excluded.name, last_seen = excluded.last_seen`,\n args: [room, viewer, viewerName || \"名無し\", now],\n });\n }\n }\n\n const result = await sqlite.execute({\n sql:\n `SELECT id, user_id, name, body, image_url, reply_to_id, reply_to_name, reply_to_body,\n edited_at, deleted, updated_at, poll_id, created_at, avatar_url\n FROM ${TABLE}\n WHERE room = ? AND (id > ? OR updated_at > ?)\n ORDER BY id ASC`,\n args: [room, since, sinceUpdate],\n });\n\n const rawMessages = (result.rows as any[]).map((row) => ({\n id: Number(col(row, 0, \"id\")),\n user_id: String(col(row, 1, \"user_id\")),\n name: String(col(row, 2, \"name\")),\n body: String(col(row, 3, \"body\")),\n image_url: col(row, 4, \"image_url\")\n ? String(col(row, 4, \"image_url\"))\n : \"\",\n reply_to_id: col(row, 5, \"reply_to_id\") != null\n ? Number(col(row, 5, \"reply_to_id\"))\n : null,\n reply_to_name: col(row, 6, \"reply_to_name\") != null\n ? String(col(row, 6, \"reply_to_name\"))\n : null,\n reply_to_body: col(row, 7, \"reply_to_body\") != null\n ? String(col(row, 7, \"reply_to_body\"))\n : null,\n edited_at: col(row, 8, \"edited_at\") != null\n ? Number(col(row, 8, \"edited_at\"))\n : null,\n deleted: Number(col(row, 9, \"deleted\") ?? 0) === 1,\n updated_at: Number(\n col(row, 10, \"updated_at\") ?? col(row, 12, \"created_at\"),\n ),\n poll_id: col(row, 11, \"poll_id\") != null\n ? Number(col(row, 11, \"poll_id\"))\n : null,\n created_at: Number(col(row, 12, \"created_at\")),\n avatar_url: col(row, 13, \"avatar_url\")\n ? String(col(row, 13, \"avatar_url\"))\n : \"\",\n }));\n\n const pollIds = rawMessages.filter((m) => m.poll_id != null).map((m) =>\n m.poll_id as number\n );\n const pollMap: Record = {};\n if (pollIds.length > 0) {\n const placeholders = pollIds.map(() => \"?\").join(\",\");\n const pollResult = await sqlite.execute({\n sql:\n `SELECT id, question, options, votes FROM ${POLLS_TABLE} WHERE id IN (${placeholders})`,\n args: pollIds,\n });\n for (const prow of pollResult.rows as any[]) {\n const pid = Number(col(prow, 0, \"id\"));\n const question = String(col(prow, 1, \"question\"));\n const options: string[] = JSON.parse(String(col(prow, 2, \"options\")));\n const votes: Record = JSON.parse(\n String(col(prow, 3, \"votes\")) || \"{}\",\n );\n const tally = options.map((text, idx) => ({\n text,\n count: Object.values(votes).filter((v) => v === idx).length,\n }));\n const total = Object.keys(votes).length;\n const myVote =\n viewer && Object.prototype.hasOwnProperty.call(votes, viewer)\n ? votes[viewer]\n : null;\n pollMap[pid] = { id: pid, question, options: tally, total, myVote };\n }\n }\n\n const messages = rawMessages.map((m) => ({\n ...m,\n poll: m.poll_id != null ? pollMap[m.poll_id] || null : null,\n }));\n\n const onlineResult = await sqlite.execute({\n sql:\n `SELECT user_id, name FROM ${PRESENCE_TABLE} WHERE room = ? AND last_seen > ? ORDER BY name ASC`,\n args: [room, Date.now() - ONLINE_WINDOW_MS],\n });\n const online = (onlineResult.rows as any[]).map((row) => ({\n user_id: String(col(row, 0, \"user_id\")),\n name: String(col(row, 1, \"name\")),\n }));\n\n // 既読情報（自分以外）\n const readResult = await sqlite.execute({\n sql:\n `SELECT user_id, COALESCE(last_read_id, 0) FROM ${PRESENCE_TABLE} WHERE room = ? AND user_id != ?`,\n args: [room, viewer || \"\"],\n });\n const readers = (readResult.rows as any[]).map((row) => ({\n user_id: String(row[0] ?? row.user_id),\n last_read_id: Number(row[1] ?? 0),\n }));\n\n return json({ messages, online, readers });\n }\n\n // --- メッセージ送信 ---\n if (path === \"/api/send\" && req.method === \"POST\") {\n try {\n const data = await req.json();\n const room = data.room || \"lobby\";\n const user_id = data.user_id || \"unknown\";\n const name = data.name || \"名無し\";\n const body = data.body || \"\";\n const image_url = data.image_url || \"\";\n const avatar_url = data.avatar_url || \"\";\n const reply_to_id = data.reply_to_id ? Number(data.reply_to_id) : null;\n const reply_to_name = data.reply_to_name || null;\n const reply_to_body = data.reply_to_body || null;\n const created_at = Date.now();\n\n if (\n isAccountRoom(room) && !(await canAccessRoom(room, user_id, data.token))\n ) {\n return json({ error: \"forbidden\" }, 403);\n }\n if (user_id === SYSTEM_USER) return json({ error: \"forbidden\" }, 403);\n\n await sqlite.execute({\n sql:\n `INSERT INTO ${TABLE} (room, user_id, name, body, image_url, avatar_url, reply_to_id, reply_to_name, reply_to_body, updated_at, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n room,\n user_id,\n name,\n body,\n image_url,\n avatar_url,\n reply_to_id,\n reply_to_name,\n reply_to_body,\n created_at,\n created_at,\n ],\n });\n\n // 通知タイトル（LINE 風）\n let pushTitle = name + \" (#\" + room + \")\";\n let pushBody = body || (image_url ? \"画像を送信しました\" : \"\");\n if (isDmRoom(room)) {\n pushTitle = name;\n } else if (isGroupRoom(room)) {\n const g = await getGroup(room.slice(2));\n pushTitle = g ? g.name : \"グループ\";\n pushBody = name + \": \" + pushBody;\n }\n\n const subsResult = await sqlite.execute({\n sql:\n `SELECT subscription FROM ${PUSH_SUB_TABLE} WHERE room = ? AND user_id != ?`,\n args: [room, user_id],\n });\n const roomUrl = \"/\" + (room !== \"lobby\" ? \"#\" + room : \"\");\n for (const row of subsResult.rows as any[]) {\n try {\n const sub = JSON.parse(String(row[0] ?? row.subscription));\n const payload = JSON.stringify({\n title: pushTitle,\n body: pushBody.length > 100\n ? pushBody.substring(0, 100) + \"…\"\n : pushBody,\n tag: `msg-${room}`,\n icon: avatar_url && !avatar_url.startsWith(\"data:\")\n ? avatar_url\n : undefined,\n url: roomUrl,\n room: room,\n });\n webpush.sendNotification(sub, payload).catch((err: any) => {\n if (err.statusCode === 410 || err.statusCode === 404) {\n sqlite.execute({\n sql: `DELETE FROM ${PUSH_SUB_TABLE} WHERE subscription = ?`,\n args: [String(row[0] ?? row.subscription)],\n }).catch(() => {});\n }\n });\n } catch (_e) {\n // パースエラーなどは無視\n }\n }\n\n return json({ success: true });\n } catch (err) {\n return json({ error: String(err) }, 400);\n }\n }\n\n // --- メッセージ編集 ---\n if (path === \"/api/edit\" && req.method === \"POST\") {\n try {\n const data = await req.json();\n const id = Number(data.id);\n const user_id = data.user_id || \"\";\n const body = (data.body || \"\").trim();\n if (!id || !body) return json({ error: \"invalid request\" }, 400);\n\n const check = await sqlite.execute({\n sql: `SELECT user_id, deleted FROM ${TABLE} WHERE id = ?`,\n args: [id],\n });\n const row = (check.rows as any[])[0];\n if (!row) return json({ error: \"not found\" }, 404);\n if (String(row[0] ?? row.user_id) !== user_id) {\n return json({ error: \"forbidden\" }, 403);\n }\n if (Number(row[1] ?? row.deleted ?? 0) === 1) {\n return json({ error: \"already deleted\" }, 400);\n }\n\n const now = Date.now();\n await sqlite.execute({\n sql:\n `UPDATE ${TABLE} SET body = ?, edited_at = ?, updated_at = ? WHERE id = ?`,\n args: [body, now, now, id],\n });\n return json({ success: true });\n } catch (err) {\n return json({ error: String(err) }, 400);\n }\n }\n\n // --- メッセージ削除 ---\n if (path === \"/api/delete\" && req.method === \"POST\") {\n try {\n const data = await req.json();\n const id = Number(data.id);\n const user_id = data.user_id || \"\";\n const check = await sqlite.execute({\n sql: `SELECT user_id FROM ${TABLE} WHERE id = ?`,\n args: [id],\n });\n const row = (check.rows as any[])[0];\n if (!row) return json({ error: \"not found\" }, 404);\n if (String(row[0] ?? row.user_id) !== user_id) {\n return json({ error: \"forbidden\" }, 403);\n }\n const now = Date.now();\n await sqlite.execute({\n sql: `UPDATE ${TABLE} SET deleted = 1, updated_at = ? WHERE id = ?`,\n args: [now, id],\n });\n return json({ success: true });\n } catch (err) {\n return json({ error: String(err) }, 400);\n }\n }\n\n // --- 投票作成 ---\n if (path === \"/api/poll/create\" && req.method === \"POST\") {\n try {\n const data = await req.json();\n const room = data.room || \"lobby\";\n const user_id = data.user_id || \"unknown\";\n const name = data.name || \"名無し\";\n const avatar_url = data.avatar_url || \"\";\n const question = (data.question || \"\").trim();\n const options: string[] = Array.isArray(data.options)\n ? data.options.map((o: string) => String(o).trim()).filter((\n o: string,\n ) => o.length > 0)\n : [];\n if (!question || options.length < 2) {\n return json({ error: \"invalid poll\" }, 400);\n }\n if (\n isAccountRoom(room) && !(await canAccessRoom(room, user_id, data.token))\n ) {\n return json({ error: \"forbidden\" }, 403);\n }\n\n const created_at = Date.now();\n const pollInsert = await sqlite.execute({\n sql:\n `INSERT INTO ${POLLS_TABLE} (room, question, options, votes, created_at) VALUES (?, ?, ?, '{}', ?)`,\n args: [room, question, JSON.stringify(options), created_at],\n });\n const pollId = Number(pollInsert.lastInsertRowid);\n await sqlite.execute({\n sql:\n `INSERT INTO ${TABLE} (room, user_id, name, body, avatar_url, poll_id, updated_at, created_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n room,\n user_id,\n name,\n \"投票 \" + question,\n avatar_url,\n pollId,\n created_at,\n created_at,\n ],\n });\n return json({ success: true });\n } catch (err) {\n return json({ error: String(err) }, 400);\n }\n }\n\n // --- 投票 ---\n if (path === \"/api/poll/vote\" && req.method === \"POST\") {\n try {\n const data = await req.json();\n const pollId = Number(data.poll_id);\n const messageId = Number(data.message_id);\n const user_id = data.user_id || \"\";\n const optionIndex = Number(data.option_index);\n if (!pollId || !user_id || Number.isNaN(optionIndex)) {\n return json({ error: \"invalid vote\" }, 400);\n }\n\n const pollRow = await sqlite.execute({\n sql: `SELECT options, votes FROM ${POLLS_TABLE} WHERE id = ?`,\n args: [pollId],\n });\n const prow = (pollRow.rows as any[])[0];\n if (!prow) return json({ error: \"poll not found\" }, 404);\n const options: string[] = JSON.parse(String(prow[0] ?? prow.options));\n if (optionIndex < 0 || optionIndex >= options.length) {\n return json({ error: \"invalid option\" }, 400);\n }\n const votes: Record = JSON.parse(\n String(prow[1] ?? prow.votes) || \"{}\",\n );\n votes[user_id] = optionIndex;\n await sqlite.execute({\n sql: `UPDATE ${POLLS_TABLE} SET votes = ? WHERE id = ?`,\n args: [JSON.stringify(votes), pollId],\n });\n if (messageId) {\n await sqlite.execute({\n sql: `UPDATE ${TABLE} SET updated_at = ? WHERE id = ?`,\n args: [Date.now(), messageId],\n });\n }\n return json({ success: true });\n } catch (err) {\n return json({ error: String(err) }, 400);\n }\n }\n\n // --- GIF検索プロキシ（GIPHY APIキーをクライアントに渡さないためのサーバー中継）---\n if (path === \"/api/gif/search\" && req.method === \"GET\") {\n try {\n if (!GIPHY_API_KEY) {\n return json({ error: \"GIPHY_API_KEY not configured\" }, 500);\n }\n const q = url.searchParams.get(\"q\") || \"\";\n const endpoint = q.trim()\n ? `https://api.giphy.com/v1/gifs/search?api_key=${GIPHY_API_KEY}&q=${\n encodeURIComponent(q)\n }&limit=24&rating=pg-13&lang=ja`\n : `https://api.giphy.com/v1/gifs/trending?api_key=${GIPHY_API_KEY}&limit=24&rating=pg-13`;\n\n const res = await fetch(endpoint);\n if (!res.ok) return json({ error: \"giphy request failed\" }, 502);\n const data = await res.json();\n const items = ((data.data || []) as any[]).map((g) => {\n const preview =\n (g.images?.fixed_width_small || g.images?.fixed_width || {}).url ||\n \"\";\n const full = (g.images?.original || g.images?.fixed_width || {}).url ||\n \"\";\n return { preview, full, title: g.title || \"gif\" };\n }).filter((i) => i.preview && i.full);\n\n return json({ items });\n } catch (err) {\n return json({ error: String(err) }, 500);\n }\n }\n\n // ===================== 静的配信 =====================\n if (path === \"/\" || path === \"/index.html\") {\n return new Response(htmlContent, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n }\n if (path === \"/client.js\") {\n return new Response(jsContent, {\n headers: {\n \"Content-Type\": \"application/javascript; charset=utf-8\",\n \"Cache-Control\": \"no-cache\",\n },\n });\n }\n if (path === \"/gif.js\") {\n return new Response(gifClientJs, {\n headers: {\n \"Content-Type\": \"application/javascript; charset=utf-8\",\n \"Cache-Control\": \"no-cache\",\n },\n });\n }\n if (path === \"/call.js\") {\n return new Response(callClientJs, {\n headers: {\n \"Content-Type\": \"application/javascript; charset=utf-8\",\n \"Cache-Control\": \"no-cache\",\n },\n });\n }\n\n return new Response(\"Not Found\", { status: 404 });\n}","createdAt",["D",1789191594094],"branchVersion","branchId","594e4a6a-323f-428b-9eab-672f4c3d972e","id","d1eccb4b-58a6-420b-ba51-e8d85b95fa3e","Ch",["D",1788478632137],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","690448f2-f627-4f9c-a6c5-7d7a2d115d3f","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a069a0-d469-775a-a16b-4f31aa5c28e7","tursoName","d1eccb4b58a6420bba51e8d85b95fa3e","tursoHostname","d1eccb4b58a6420bba51e8d85b95fa3e-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789448471428],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":55,"_104":105,"_106":25},"branch",{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"isOwned",43,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","nakd","handle","displayName","かんかん","avatar","https://lh3.googleusercontent.com/a/ACg8ocLI16p0WgrVPfU-N1HNs2XT2RWSbAMgVFqjPLJinXQcxWMIsA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":192,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":193,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":194,"_83":195,"_85":196,"_87":25},"tree",[175,176,177,178],"files",[175,176,177,178],"counts",{"_164":62,"_165":166,"_167":62,"_168":169,"_170":171},"contents",[129,130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":157,"_32":158,"_30":159,"_134":-5,"_41":42,"_40":160,"_135":25,"_38":161,"_13":145,"_33":146,"_35":162,"_24":25,"_138":-5,"_27":163},{"_43":149,"_32":150,"_30":151,"_134":-5,"_41":42,"_40":152,"_135":58,"_38":153,"_13":154,"_33":146,"_35":155,"_24":25,"_138":-5,"_27":156},{"_43":140,"_32":141,"_30":142,"_134":-5,"_41":42,"_40":143,"_135":25,"_38":144,"_13":145,"_33":146,"_35":147,"_24":25,"_138":-5,"_27":148},{"_43":133,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_135":58,"_38":136,"_13":137,"_33":34,"_35":37,"_24":25,"_138":98,"_27":139},"00f3abd0-9161-402b-9dfc-25e65bfa79af","parentId","latest",["D",1789191594094],8,"label",[28],"76cacc3b-d922-4c5a-9336-0b1ddbd243fd","html.ts","942a75f4-a7f0-11f1-8207-1607ee4eb77e",33,["D",1788594687420],10,"script","//　html.ts\nexport const htmlContent = `\n\n \n \n \n \n \n \n \n LINE\n \n \n \n \n \n \n \n\n

\n \n

\n ホーム\n \n \n \n

…

\n \n

アカウント切り替え

友だち0追加

グループ0作成

サービス

\n\n \n

\n トーク\n \n \n

\n \n \n

読み込み中...

\n\n \n

VOOM

VOOMは準備中です。
もうしばらくお待ちください。

ニュース

ニュースは準備中です。

ウォレット

ウォレットは準備中です。

\n\n \n

\n \n

\n \n \n

\n \n \n \n

\n 新着メッセージの通知を受け取る\n \n

まだメッセージはありません

\n \n

\n ✕\n

\n $\"添付画像プレビュー\"$ \n ✕\n

\n \n

\n\n \n

\n \n \n \n \n

\n \n

読み込み中...

\n\n \n \n

\n\n \n\n \n \n\n \n \n\n \n

\n \n \n

\n\n

\n\n \n \n \n`;\n",[141],"66eb13da-2f06-4259-89d0-4a13916ce5d9","gif.ts","aadc8198-a7f0-11f1-8a52-1607ee4eb77e",29,["D",1788566749081],6,"// gif.ts\nexport const gifClientJs = `\n(function() {\n function injectStyles() {\n var style = document.createElement(\"style\");\n style.textContent =\n \".gif-label{background:transparent;border:none;color:#3c3c43;width:36px;height:38px;border-radius:50%;cursor:pointer;display:flex;align-items:center;justify-content:center;font-size:0.68rem;font-weight:800;letter-spacing:0.02em;flex:0 0 auto;}\" +\n \".gif-label:active{background:rgba(0,0,0,0.05);}\" +\n \".gif-overlay{display:none;position:fixed;inset:0;background:rgba(0,0,0,0.45);align-items:flex-end;justify-content:center;z-index:10001;}\" +\n \".gif-overlay.show{display:flex;}\" +\n \".gif-panel{width:100%;max-width:430px;background:#ffffff;border-radius:16px 16px 0 0;display:flex;flex-direction:column;max-height:70vh;overflow:hidden;padding-bottom:env(safe-area-inset-bottom,0px);}\" +\n \".gif-panel-header{display:flex;align-items:center;gap:8px;padding:12px 14px 8px;background:#ffffff;}\" +\n \".gif-search-input{flex:1;background:#f2f2f4;border:none;color:#111111;padding:8px 14px;border-radius:8px;font-size:16px;outline:none;font-family:inherit;}\" +\n \".gif-search-input::placeholder{color:#b5b5b9;}\" +\n \".gif-close-btn{cursor:pointer;color:#8e8e93;padding:4px 8px;flex:0 0 auto;}\" +\n \".gif-grid{flex:1;overflow-y:auto;padding:10px;display:grid;grid-template-columns:repeat(3,1fr);gap:6px;}\" +\n \".gif-grid img{width:100%;height:90px;object-fit:cover;border-radius:8px;cursor:pointer;display:block;background:#f4f6f3;}\" +\n \".gif-empty{grid-column:1/-1;text-align:center;font-size:0.8rem;color:#9aa89c;padding:20px 0;}\" +\n \".gif-attribution{text-align:center;font-size:0.6rem;color:#c2c2c6;padding:4px 0 8px;}\";\n document.head.appendChild(style);\n }\n\n function injectMarkup() {\n var composer = document.getElementById(\"composer\");\n if (!composer) return null;\n var fileLabel = document.getElementById(\"fileLabel\");\n\n var gifBtn = document.createElement(\"label\");\n gifBtn.id = \"gifLabel\";\n gifBtn.className = \"gif-label\";\n gifBtn.title = \"GIFを送る\";\n gifBtn.textContent = \"GIF\";\n if (fileLabel && fileLabel.parentNode) {\n fileLabel.parentNode.insertBefore(gifBtn, fileLabel.nextSibling);\n } else {\n composer.insertBefore(gifBtn, composer.firstChild);\n }\n\n var overlay = document.createElement(\"div\");\n overlay.id = \"gifOverlay\";\n overlay.className = \"gif-overlay\";\n overlay.innerHTML =\n '

' +\n '

' +\n '' +\n '\\u2715' +\n '

' +\n '

';\n document.body.appendChild(overlay);\n return true;\n }\n\n function setup() {\n injectStyles();\n if (!injectMarkup()) return;\n\n var gifOverlay = document.getElementById(\"gifOverlay\");\n var gifSearchInput = document.getElementById(\"gifSearchInput\");\n var gifGrid = document.getElementById(\"gifGrid\");\n var gifCloseBtn = document.getElementById(\"gifCloseBtn\");\n var gifLabel = document.getElementById(\"gifLabel\");\n var searchTimer = null;\n var isComposing = false;\n var requestSeq = 0;\n var bodyScrollY = 0;\n\n function lockBodyScroll() {\n bodyScrollY = window.scrollY || window.pageYOffset || 0;\n document.body.style.position = \"fixed\";\n document.body.style.top = \"-\" + bodyScrollY + \"px\";\n document.body.style.width = \"100%\";\n }\n function unlockBodyScroll() {\n document.body.style.position = \"\";\n document.body.style.top = \"\";\n document.body.style.width = \"\";\n window.scrollTo(0, bodyScrollY);\n }\n\n function openPanel() {\n gifOverlay.classList.add(\"show\");\n lockBodyScroll();\n gifSearchInput.value = \"\";\n gifSearchInput.focus();\n search(\"\");\n }\n function closePanel() {\n clearTimeout(searchTimer);\n gifOverlay.classList.remove(\"show\");\n gifGrid.innerHTML = \"\";\n unlockBodyScroll();\n }\n\n function search(query) {\n var mySeq = ++requestSeq;\n gifGrid.innerHTML = '

\\u8AAD\\u307F\\u8FBC\\u307F\\u4E2D...

';\n // GIPHY への呼び出しはサーバー側プロキシ (/api/gif/search) 経由にして\n // API キーをクライアントに渡さないようにする\n var endpoint = \"/api/gif/search?q=\" + encodeURIComponent(query.trim());\n fetch(endpoint).then(function(res) {\n if (!res.ok) throw new Error(\"request failed: \" + res.status);\n return res.json();\n }).then(function(data) {\n if (mySeq !== requestSeq) return; // 古いリクエストの結果は破棄\n var items = (data && data.items) || [];\n if (items.length === 0) {\n gifGrid.innerHTML = '

\\u898B\\u3064\\u304B\\u308A\\u307E\\u305B\\u3093\\u3067\\u3057\\u305F

';\n return;\n }\n gifGrid.innerHTML = \"\";\n items.forEach(function(g) {\n if (!g.preview || !g.full) return;\n var img = document.createElement(\"img\");\n img.loading = \"lazy\";\n img.src = g.preview;\n img.alt = g.title || \"gif\";\n img.addEventListener(\"error\", function() {\n img.remove();\n });\n img.addEventListener(\"click\", function() {\n closePanel();\n sendGif(g.full);\n });\n gifGrid.appendChild(img);\n });\n }).catch(function(err) {\n if (mySeq !== requestSeq) return;\n console.error(err);\n gifGrid.innerHTML = '

\\u8AAD\\u307F\\u8FBC\\u307F\\u306B\\u5931\\u6557\\u3057\\u307E\\u3057\\u305F

';\n });\n }\n\n // client.js が公開する現在のアイデンティティ（匿名 / アカウント）を優先して使う\n function getIdentity() {\n if (typeof window.getChatIdentity === \"function\") return window.getChatIdentity();\n var r = location.hash.replace(/^#/, \"\");\n return {\n room: r || \"lobby\",\n user_id: localStorage.getItem(\"chatUserId\") || \"unknown\",\n name: localStorage.getItem(\"chatName\") || \"\\u540D\\u7121\\u3057\",\n avatar: localStorage.getItem(\"chatAvatar\") || \"\",\n token: \"\",\n };\n }\n\n function sendGif(fullUrl) {\n try {\n var idn = getIdentity();\n fetch(\"/api/send\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n room: idn.room,\n user_id: idn.user_id,\n name: idn.name,\n body: \"\",\n image_url: fullUrl,\n avatar_url: idn.avatar,\n token: idn.token,\n }),\n }).then(function() {\n if (typeof window.poll === \"function\") window.poll();\n }).catch(function(err) { console.error(err); });\n } catch (err) {\n console.error(err);\n }\n }\n\n gifLabel.addEventListener(\"click\", openPanel);\n gifCloseBtn.addEventListener(\"click\", closePanel);\n gifOverlay.addEventListener(\"click\", function(e) { if (e.target === gifOverlay) closePanel(); });\n document.addEventListener(\"keydown\", function(e) {\n if (e.key === \"Escape\" && gifOverlay.classList.contains(\"show\")) closePanel();\n });\n gifSearchInput.addEventListener(\"compositionstart\", function() { isComposing = true; });\n gifSearchInput.addEventListener(\"compositionend\", function() {\n isComposing = false;\n clearTimeout(searchTimer);\n var q = gifSearchInput.value;\n searchTimer = setTimeout(function() { search(q); }, 350);\n });\n gifSearchInput.addEventListener(\"input\", function() {\n if (isComposing) return;\n clearTimeout(searchTimer);\n var q = gifSearchInput.value;\n searchTimer = setTimeout(function() { search(q); }, 350);\n });\n }\n\n if (document.readyState === \"loading\") {\n document.addEventListener(\"DOMContentLoaded\", setup);\n } else {\n setup();\n }\n})();\n`;\n\nexport default async function (req: Request): Promise {\n return new Response(gifClientJs, {\n headers: {\n \"Content-Type\": \"application/javascript; charset=utf-8\",\n \"Cache-Control\": \"no-cache\",\n },\n });\n}",[150],"3850d5ed-2185-4440-b6e3-29de2d4f9a60","client.ts","9f6caee6-a7f0-11f1-b997-1607ee4eb77e",37,["D",1788594751328],"//　client.ts\nexport const jsContent = `\n/* =====================================================================\n 基本ユーティリティ\n ===================================================================== */\nfunction $(id) { return document.getElementById(id); }\nfunction escapeHtml(s) { if (s == null || s === \"\") return \"\"; return String(s).replace(/[&<>\"']/g, (c) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\", \"'\": \"'\" }[c])); }\nfunction truncateText(s, n) { if (!s) return \"\"; return s.length > n ? s.slice(0, n) + \"…\" : s; }\nfunction pad2(n) { return String(n).padStart(2, \"0\"); }\nfunction icon(name) { return ''; }\nconst DAYS = [\"日\", \"月\", \"火\", \"水\", \"木\", \"金\", \"土\"];\nfunction fmtTime(ts) { const d = new Date(ts); return d.getHours() + \":\" + pad2(d.getMinutes()); }\nfunction fmtDate(ts) { const d = new Date(ts); return (d.getMonth() + 1) + \"月\" + d.getDate() + \"日(\" + DAYS[d.getDay()] + \")\"; }\nfunction dateKey(ts) { const d = new Date(ts); return d.getFullYear() + \"-\" + d.getMonth() + \"-\" + d.getDate(); }\nfunction isToday(ts) { return dateKey(ts) === dateKey(Date.now()); }\nfunction isYesterday(ts) { const y = new Date(); y.setDate(y.getDate() - 1); return dateKey(ts) === dateKey(y.getTime()); }\nfunction fmtDateDivider(ts) {\n if (isToday(ts)) return \"今日\";\n if (isYesterday(ts)) return \"昨日\";\n const d = new Date(ts); const now = new Date();\n return (d.getFullYear() !== now.getFullYear() ? d.getFullYear() + \"年\" : \"\") + fmtDate(ts);\n}\nfunction fmtListTime(ts) {\n if (!ts) return \"\";\n if (isToday(ts)) return fmtTime(ts);\n if (isYesterday(ts)) return \"昨日\";\n const d = new Date(ts); const now = new Date();\n if (d.getFullYear() !== now.getFullYear()) return d.getFullYear() + \"/\" + (d.getMonth() + 1) + \"/\" + d.getDate();\n return (d.getMonth() + 1) + \"/\" + d.getDate();\n}\nfunction fileToBase64(file) { return new Promise((resolve, reject) => { const reader = new FileReader(); reader.readAsDataURL(file); reader.onload = () => resolve(reader.result); reader.onerror = (e) => reject(e); }); }\nasync function copyText(text) { try { await navigator.clipboard.writeText(text); return true; } catch (e) { return false; } }\n\nlet toastTimer = null;\nfunction toast(msg) {\n const t = $(\"toast\"); t.textContent = msg; t.classList.add(\"show\");\n clearTimeout(toastTimer); toastTimer = setTimeout(() => t.classList.remove(\"show\"), 2200);\n}\n\nconst AVATAR_COLORS = [\"#4a8af4\", \"#6c5ce7\", \"#00b894\", \"#f39c12\", \"#e84393\", \"#0abde3\", \"#a55eea\", \"#06c755\", \"#fd7e14\", \"#20bf6b\"];\nfunction colorForKey(key) {\n let hash = 0; const s = String(key || \"?\");\n for (let i = 0; i < s.length; i++) { hash = (hash * 31 + s.charCodeAt(i)) >>> 0; }\n return AVATAR_COLORS[hash % AVATAR_COLORS.length];\n}\nfunction buildAvatarHtml(name, avatarUrl, colorKey, cls) {\n cls = cls ? \" \" + cls : \"\";\n if (avatarUrl) return ' $\"\"$ ';\n const trimmed = (name || \"\").trim();\n const letter = escapeHtml(trimmed ? trimmed.charAt(0).toUpperCase() : \"?\");\n return '

' + letter + \"

\";\n}\nfunction buildGroupIconHtml(iconUrl, cls) {\n cls = cls ? \" \" + cls : \"\";\n if (iconUrl) return ' $\"\"$ ';\n return '

' + icon(\"people\") + \"

\";\n}\nfunction buildRoomIconHtml(r, cls) {\n if (r.type === \"group\") return buildGroupIconHtml(r.icon, cls);\n if (r.type === \"dm\") return buildAvatarHtml(r.title, r.icon, r.room, cls);\n const letter = escapeHtml((r.room || \"?\").charAt(0).toUpperCase());\n return '

' + letter + \"

\";\n}\n\nasync function apiPost(path, payload) {\n const res = await fetch(path, { method: \"POST\", headers: { \"Content-Type\": \"application/json\" }, body: JSON.stringify(payload || {}) });\n let data = {}; try { data = await res.json(); } catch (e) {}\n if (!res.ok || data.error) throw new Error(data.error || (\"HTTP \" + res.status));\n return data;\n}\nasync function apiGet(path) {\n const res = await fetch(path);\n let data = {}; try { data = await res.json(); } catch (e) {}\n if (!res.ok || data.error) throw new Error(data.error || (\"HTTP \" + res.status));\n return data;\n}\nfunction apiErrorMessage(err) {\n const m = String(err && err.message || err);\n const map = { name_required: \"名前を入力してください\", invalid_line_id: \"IDは半角英数字と . _ - で4〜20文字です\", id_taken: \"このIDは既に使われています\", not_found: \"見つかりませんでした\", unauthorized: \"アカウント認証に失敗しました\", forbidden: \"このトークに参加していません\", invalid_friend: \"自分自身は追加できません\" };\n return map[m] || (\"エラー: \" + m);\n}\n\n/* =====================================================================\n アイデンティティ（匿名 / LINEアカウント）\n ===================================================================== */\nfunction getAnonId() {\n let id = localStorage.getItem(\"chatUserId\");\n if (!id) { id = Math.random().toString(36).slice(2, 12) + Date.now().toString(36); localStorage.setItem(\"chatUserId\", id); }\n return id;\n}\nconst anonUserId = getAnonId();\nfunction loadAnonProfile() { const name = localStorage.getItem(\"chatName\"); if (!name) return null; return { name, avatar: localStorage.getItem(\"chatAvatar\") || \"\" }; }\nfunction saveAnonProfile(name, avatar) {\n localStorage.setItem(\"chatName\", name);\n if (avatar) localStorage.setItem(\"chatAvatar\", avatar); else localStorage.removeItem(\"chatAvatar\");\n anonProfile = { name, avatar: avatar || \"\" };\n}\nlet anonProfile = loadAnonProfile();\n\nfunction loadLineAccount() { try { const raw = localStorage.getItem(\"lineAccount\"); return raw ? JSON.parse(raw) : null; } catch (e) { return null; } }\nlet lineAccount = loadLineAccount();\nfunction saveLineAccount(acc) {\n if (acc) localStorage.setItem(\"lineAccount\", JSON.stringify(acc)); else localStorage.removeItem(\"lineAccount\");\n lineAccount = acc;\n}\nlet identityMode = localStorage.getItem(\"identityMode\") || \"anon\";\nfunction setIdentityMode(mode) { identityMode = mode; localStorage.setItem(\"identityMode\", mode); }\n\nfunction isAccountRoom(r) { return !!r && (r.indexOf(\"dm:\") === 0 || r.indexOf(\"g:\") === 0); }\nfunction dmRoomFor(a, b) { const s = [a, b].sort(); return \"dm:\" + s[0] + \"-\" + s[1]; }\nfunction currentIdentity() {\n const useLine = lineAccount && (identityMode === \"line\" || isAccountRoom(room));\n if (useLine) return { mode: \"line\", user_id: lineAccount.id, name: lineAccount.name || \"名無し\", avatar: lineAccount.avatar_url || \"\", token: lineAccount.token || \"\" };\n return { mode: \"anon\", user_id: anonUserId, name: (anonProfile && anonProfile.name) || \"名無し\", avatar: (anonProfile && anonProfile.avatar) || \"\", token: \"\" };\n}\nfunction myId() { return currentIdentity().user_id; }\nfunction getDisplayName() { return currentIdentity().name; }\nfunction getAvatarUrl() { return currentIdentity().avatar; }\nfunction authQuery() { return lineAccount ? \"&account_id=\" + encodeURIComponent(lineAccount.id) + \"&token=\" + encodeURIComponent(lineAccount.token) : \"\"; }\nfunction authBody() { return lineAccount ? { account_id: lineAccount.id, token: lineAccount.token } : {}; }\nwindow.getChatIdentity = function () {\n const idn = currentIdentity();\n return { room: room || \"lobby\", user_id: idn.user_id, name: idn.name, avatar: idn.avatar, token: idn.token };\n};\n\n/* =====================================================================\n Push 通知\n ===================================================================== */\nlet __pushRegistration = null;\nasync function getPushRegistration() {\n if (__pushRegistration) return __pushRegistration;\n __pushRegistration = await navigator.serviceWorker.register('/sw.js');\n return __pushRegistration;\n}\nfunction urlBase64ToUint8Array(base64String) {\n const padding = '='.repeat((4 - base64String.length % 4) % 4);\n const base64 = (base64String + padding).replace(/\\\\-/g, '+').replace(/_/g, '/');\n const rawData = window.atob(base64);\n const outputArray = new Uint8Array(rawData.length);\n for (let i = 0; i < rawData.length; ++i) outputArray[i] = rawData.charCodeAt(i);\n return outputArray;\n}\nfunction updateNotifUI() {\n const bar = $('notifBar');\n if (!bar) return;\n if (!('Notification' in window)) { bar.innerHTML = 'このブラウザは通知に対応していません'; bar.classList.add('show'); return; }\n if (Notification.permission === 'granted') { bar.classList.remove('show'); }\n else if (Notification.permission === 'denied') { bar.innerHTML = '通知がブロックされています。ブラウザ設定から許可してください'; bar.classList.add('show'); }\n else { bar.classList.add('show'); }\n}\nasync function subscribeCurrentRoom(sub) {\n const idn = currentIdentity();\n const rm = room || 'lobby';\n await fetch('/api/subscribe', { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify({ user_id: idn.user_id, room: rm, subscription: sub }) });\n}\nwindow.enablePush = async function () {\n const btn = $('enableNotifBtn');\n if (btn) { btn.disabled = true; btn.textContent = '処理中...'; }\n try {\n if (!('serviceWorker' in navigator) || !('PushManager' in window)) throw new Error('このブラウザはPush非対応です');\n if (Notification.permission === 'default') {\n const perm = await Notification.requestPermission();\n if (perm !== 'granted') throw new Error('通知が許可されませんでした');\n }\n if (Notification.permission !== 'granted') throw new Error('通知が許可されていません');\n const reg = await getPushRegistration();\n const data = await (await fetch('/api/vapid-public-key')).json();\n if (!data.publicKey) throw new Error('VAPIDキー取得失敗');\n let sub = await reg.pushManager.getSubscription();\n if (!sub) sub = await reg.pushManager.subscribe({ userVisibleOnly: true, applicationServerKey: urlBase64ToUint8Array(data.publicKey) });\n await subscribeCurrentRoom(sub);\n updateNotifUI();\n toast('通知をオンにしました');\n } catch (e) {\n console.error(e);\n toast('通知の設定に失敗: ' + e.message);\n if (btn) { btn.disabled = false; btn.textContent = '許可'; }\n updateNotifUI();\n }\n};\nasync function setupPushNotifications() {\n try {\n if (!('serviceWorker' in navigator)) return;\n if ('Notification' in window && Notification.permission === 'granted') {\n try {\n const reg = await getPushRegistration();\n const sub = await reg.pushManager.getSubscription();\n if (sub) await subscribeCurrentRoom(sub);\n } catch (e) {}\n }\n updateNotifUI();\n } catch (e) { console.error(e); }\n}\n$('enableNotifBtn').addEventListener('click', window.enablePush);\n\n/* =====================================================================\n ビューポート高さ\n ===================================================================== */\nfunction setAppHeightVar() {\n const h = (window.visualViewport && window.visualViewport.height) ? window.visualViewport.height : window.innerHeight;\n document.documentElement.style.setProperty(\"--app-height\", h + \"px\");\n}\nsetAppHeightVar();\nwindow.addEventListener(\"resize\", setAppHeightVar);\nwindow.addEventListener(\"orientationchange\", () => setTimeout(setAppHeightVar, 50));\nif (window.visualViewport) {\n window.visualViewport.addEventListener(\"resize\", setAppHeightVar);\n window.visualViewport.addEventListener(\"scroll\", setAppHeightVar);\n}\n\n/* =====================================================================\n DOM 参照 / 状態\n ===================================================================== */\nfunction getRoomFromHash() { return decodeURIComponent(location.hash.replace(/^#/, \"\")); }\nfunction randomRoomId() { return Math.random().toString(36).slice(2, 8); }\n\nlet room = \"\";\nlet roomInfo = null;\nlet readers = [];\nlet readersSig = \"\";\n\nconst messagesEl = $(\"messages\"); const composer = $(\"composer\");\nconst bodyInput = $(\"body\");\nconst roomLabel = $(\"roomLabel\"); const roomCount = $(\"roomCount\");\nconst fileInput = $(\"imageFile\"); const fileLabel = $(\"fileLabel\"); const cameraInput = $(\"cameraFile\");\nconst mentionList = $(\"mentionList\");\nconst replyPreviewBar = $(\"replyPreviewBar\"); const rpText = $(\"rpText\"); const rpCancel = $(\"rpCancel\");\nconst imagePreviewBar = $(\"imagePreviewBar\"); const imagePreviewThumb = $(\"imagePreviewThumb\"); const ipCancel = $(\"ipCancel\");\nconst scrollBottomBtn = $(\"scrollBottomBtn\");\nconst lightbox = $(\"lightbox\"); const lightboxImg = $(\"lightboxImg\");\nconst backBtn = $(\"backBtn\"); const backCount = $(\"backCount\");\nconst newChatBtn = $(\"newChatBtn\");\nconst talklistItems = $(\"talklistItems\"); const talkSearchInput = $(\"talkSearchInput\");\n\nlet lastId = 0; let lastUpdateSeen = 0; let firstLoad = true;\nlet lastRenderedDateStr = \"\"; let lastSender = null;\nlet replyingTo = null;\nlet onlineUsers = [];\nconst knownNames = new Set();\nconst msgIndex = new Map();\nconst messageData = new Map();\nlet chatPollTimer = null;\nlet currentScreen = \"talklist\";\nlet allRooms = [];\nlet pendingFile = null;\nlet homeData = { friends: [], groups: [] };\n\n/* 既読位置（トーク一覧の未読バッジ用） */\nfunction getReads() { try { return JSON.parse(localStorage.getItem(\"chatReads\") || \"{}\") || {}; } catch (e) { return {}; } }\nfunction setRead(r, id) {\n if (!r || !id) return;\n const reads = getReads();\n if ((reads[r] || 0) >= id) return;\n reads[r] = id;\n try { localStorage.setItem(\"chatReads\", JSON.stringify(reads)); } catch (e) {}\n}\n\n/* =====================================================================\n 画面遷移\n ===================================================================== */\nconst SCREEN_IDS = { home: \"screenHome\", talklist: \"screenTalklist\", timeline: \"screenTimeline\", news: \"screenNews\", wallet: \"screenWallet\", chatroom: \"screenChatroom\", webview: \"screenWebview\" };\n/* アプリ内ブラウザで開く外部サービス（URL は UI には表示しない） */\nconst SERVICE_LINKS = { animal: \"https://fruit-grower.val.run/\" };\nfunction showScreen(name) {\n if (currentScreen === \"webview\" && name !== \"webview\") wvUnload();\n Object.keys(SCREEN_IDS).forEach((k) => $(SCREEN_IDS[k]).classList.toggle(\"active\", k === name));\n $(\"tabbar\").style.display = (name === \"chatroom\" || name === \"webview\") ? \"none\" : \"flex\";\n document.querySelectorAll(\".tab-item\").forEach((el) => el.classList.toggle(\"active\", el.dataset.tab === name));\n currentScreen = name;\n}\nfunction navigateTo(name) {\n if (currentScreen === \"chatroom\" && name !== \"chatroom\") {\n stopChatPolling();\n room = \"\"; roomInfo = null;\n history.replaceState(null, \"\", location.pathname + location.search);\n }\n showScreen(name);\n if (name === \"talklist\") loadTalklist();\n if (name === \"home\") loadHome();\n}\n\n/* =====================================================================\n アプリ内ブラウザ (WebView)\n - iframe で外部サービスを LINE 風の画面内に表示する\n - URL はヘッダーに表示しない（タイトルのみ）\n ===================================================================== */\nconst wvFrame = $(\"wvFrame\"); const wvTitle = $(\"wvTitle\"); const wvProgress = $(\"wvProgress\"); const wvLoading = $(\"wvLoading\");\nlet webviewUrl = \"\"; let webviewReturnScreen = \"home\"; let wvDoneTimer = null; let wvFailsafeTimer = null;\nfunction wvSetLoading(on) {\n clearTimeout(wvDoneTimer); clearTimeout(wvFailsafeTimer);\n if (on) {\n wvProgress.classList.remove(\"done\"); wvProgress.classList.add(\"loading\");\n wvLoading.classList.remove(\"hide\");\n wvFailsafeTimer = setTimeout(() => wvSetLoading(false), 12000);\n } else {\n wvProgress.classList.remove(\"loading\"); wvProgress.classList.add(\"done\");\n wvLoading.classList.add(\"hide\");\n wvDoneTimer = setTimeout(() => wvProgress.classList.remove(\"done\"), 700);\n }\n}\nfunction wvUnload() {\n webviewUrl = \"\";\n clearTimeout(wvDoneTimer); clearTimeout(wvFailsafeTimer);\n wvProgress.classList.remove(\"loading\", \"done\");\n wvLoading.classList.remove(\"hide\");\n wvFrame.removeAttribute(\"src\");\n}\nfunction openWebview(url, title) {\n if (!url) return;\n if (currentScreen !== \"webview\") {\n webviewReturnScreen = currentScreen;\n if (currentScreen === \"chatroom\") stopChatPolling();\n }\n webviewUrl = url;\n wvTitle.textContent = title || \"\";\n wvSetLoading(true);\n wvFrame.src = url;\n showScreen(\"webview\");\n}\nfunction closeWebview() {\n const back = webviewReturnScreen || \"home\";\n webviewReturnScreen = \"home\";\n if (back === \"chatroom\" && room) { showScreen(\"chatroom\"); startChatPolling(); return; }\n navigateTo(back === \"chatroom\" || back === \"webview\" ? \"home\" : back);\n}\nwvFrame.addEventListener(\"load\", () => { if (webviewUrl) wvSetLoading(false); });\n$(\"wvBackBtn\").addEventListener(\"click\", closeWebview);\n$(\"wvReloadBtn\").addEventListener(\"click\", () => { if (!webviewUrl) return; wvSetLoading(true); wvFrame.src = webviewUrl; });\n$(\"wvExternalBtn\").addEventListener(\"click\", () => { if (webviewUrl) window.open(webviewUrl, \"_blank\", \"noopener\"); });\nwindow.openWebview = openWebview;\ndocument.querySelectorAll(\".tab-item\").forEach((btn) => {\n btn.addEventListener(\"click\", () => navigateTo(btn.dataset.tab));\n});\nbackBtn.addEventListener(\"click\", () => navigateTo(\"talklist\"));\nwindow.addEventListener(\"hashchange\", () => {\n const h = getRoomFromHash();\n if (!h) return;\n if (h.indexOf(\"add:\") === 0) { handleAddLink(h.slice(4)); return; }\n if (h !== room) openChatroom(h);\n});\n\n/* =====================================================================\n ボトムシート\n ===================================================================== */\nconst sheetOverlay = $(\"sheetOverlay\"); const sheetTitle = $(\"sheetTitle\"); const sheetBody = $(\"sheetBody\");\nfunction openSheet(title, html) { sheetBody.onclick = null; sheetTitle.textContent = title; sheetBody.innerHTML = html; sheetOverlay.classList.add(\"show\"); }\nfunction closeSheet() { sheetOverlay.classList.remove(\"show\"); sheetBody.innerHTML = \"\"; }\nsheetOverlay.addEventListener(\"click\", (e) => { if (e.target === sheetOverlay) closeSheet(); });\n$(\"sheetClose\").addEventListener(\"click\", closeSheet);\nfunction sheetItem(action, iconName, label, sub, opts) {\n opts = opts || {};\n return '\";\n}\nfunction pickRow(id, avatarHtml, name, sub, on) {\n return '

' + avatarHtml +\n '

' + escapeHtml(name) + (sub ? '

' + escapeHtml(sub) + \"

\" : \"\") + \"

\" +\n '' + icon(\"check\") + \"

\";\n}\nsheetBody.addEventListener(\"click\", (e) => {\n const pr = e.target.closest(\".pick-row\");\n if (pr && pr.dataset.toggle === \"1\") pr.classList.toggle(\"on\");\n});\n\n/* =====================================================================\n 匿名プロフィール（初回 / 編集）\n ===================================================================== */\nconst entryOverlay = $(\"entryOverlay\"); const entryTitle = $(\"entryTitle\"); const entrySub = $(\"entrySub\");\nconst entryAvatarPreview = $(\"entryAvatarPreview\"); const entryAvatarFile = $(\"entryAvatarFile\");\nconst entryNameInput = $(\"entryNameInput\"); const entryCancelBtn = $(\"entryCancelBtn\"); const entrySubmitBtn = $(\"entrySubmitBtn\");\nlet entryDraftAvatar = \"\"; let pendingFirstEntry = false;\nconst CAM_BADGE = '' + icon(\"camera\") + \"\";\nfunction renderAvatarPreview(el, draft, name) {\n if (draft) { el.innerHTML = ' $\"\"$ ' + CAM_BADGE; return; }\n const v = (name || \"\").trim();\n el.innerHTML = (v ? escapeHtml(v.charAt(0).toUpperCase()) : \"＋\") + CAM_BADGE;\n}\nfunction openEntryOverlay(editMode) {\n pendingFirstEntry = !editMode;\n entryDraftAvatar = editMode && anonProfile ? anonProfile.avatar : \"\";\n entryNameInput.value = editMode && anonProfile ? anonProfile.name : \"\";\n entryAvatarFile.value = \"\";\n renderAvatarPreview(entryAvatarPreview, entryDraftAvatar, entryNameInput.value);\n entryTitle.textContent = editMode ? \"プロフィール（匿名）\" : \"ようこそ\";\n entrySub.textContent = editMode ? \"ランダムトークで使う名前とアイコンです\" : \"名前とアイコンを設定して始めましょう\";\n entrySubmitBtn.textContent = editMode ? \"保存\" : \"はじめる\";\n entryCancelBtn.style.display = editMode ? \"block\" : \"none\";\n entryOverlay.classList.add(\"show\");\n entryNameInput.focus();\n}\nfunction closeEntryOverlay() { entryOverlay.classList.remove(\"show\"); }\nentryNameInput.addEventListener(\"input\", () => renderAvatarPreview(entryAvatarPreview, entryDraftAvatar, entryNameInput.value));\nentryAvatarFile.addEventListener(\"change\", () => {\n const file = entryAvatarFile.files[0]; if (!file) return;\n const reader = new FileReader();\n reader.onload = () => { entryDraftAvatar = reader.result; renderAvatarPreview(entryAvatarPreview, entryDraftAvatar, entryNameInput.value); };\n reader.readAsDataURL(file);\n});\nentryCancelBtn.addEventListener(\"click\", closeEntryOverlay);\nentrySubmitBtn.addEventListener(\"click\", () => {\n const name = entryNameInput.value.trim();\n if (!name) { toast(\"名前を入力してください\"); entryNameInput.focus(); return; }\n saveAnonProfile(name, entryDraftAvatar);\n closeEntryOverlay();\n if (pendingFirstEntry) { pendingFirstEntry = false; boot(); }\n else { refreshIdentityUI(); }\n});\n\n/* =====================================================================\n LINE アカウント（作成 / 編集）\n ===================================================================== */\nconst accountOverlay = $(\"accountOverlay\"); const accTitle = $(\"accTitle\"); const accSub = $(\"accSub\");\nconst accAvatarPreview = $(\"accAvatarPreview\"); const accAvatarFile = $(\"accAvatarFile\");\nconst accNameInput = $(\"accNameInput\"); const accIdInput = $(\"accIdInput\"); const accStatusInput = $(\"accStatusInput\");\nconst accCancelBtn = $(\"accCancelBtn\"); const accSubmitBtn = $(\"accSubmitBtn\");\nlet accDraftAvatar = \"\"; let afterAccountReady = null;\nfunction openAccountOverlay(cb) {\n afterAccountReady = typeof cb === \"function\" ? cb : null;\n const edit = !!lineAccount;\n accDraftAvatar = edit ? (lineAccount.avatar_url || \"\") : \"\";\n accNameInput.value = edit ? (lineAccount.name || \"\") : ((anonProfile && anonProfile.name) || \"\");\n accIdInput.value = edit ? (lineAccount.line_id || \"\") : \"\";\n accStatusInput.value = edit ? (lineAccount.status_msg || \"\") : \"\";\n accAvatarFile.value = \"\";\n renderAvatarPreview(accAvatarPreview, accDraftAvatar, accNameInput.value);\n accTitle.textContent = edit ? \"プロフィール\" : \"アカウントを作成\";\n accSub.textContent = edit ? \"友だち・グループに表示されるプロフィールです\" : \"友だち追加・グループトークに使う、この端末に保存されるアカウントです\";\n accSubmitBtn.textContent = edit ? \"保存\" : \"作成\";\n accountOverlay.classList.add(\"show\");\n accNameInput.focus();\n}\nfunction closeAccountOverlay() { accountOverlay.classList.remove(\"show\"); }\naccNameInput.addEventListener(\"input\", () => renderAvatarPreview(accAvatarPreview, accDraftAvatar, accNameInput.value));\naccAvatarFile.addEventListener(\"change\", () => {\n const file = accAvatarFile.files[0]; if (!file) return;\n const reader = new FileReader();\n reader.onload = () => { accDraftAvatar = reader.result; renderAvatarPreview(accAvatarPreview, accDraftAvatar, accNameInput.value); };\n reader.readAsDataURL(file);\n});\naccCancelBtn.addEventListener(\"click\", () => { closeAccountOverlay(); afterAccountReady = null; });\naccSubmitBtn.addEventListener(\"click\", async () => {\n const name = accNameInput.value.trim();\n if (!name) { toast(\"名前を入力してください\"); accNameInput.focus(); return; }\n const lineId = accIdInput.value.trim().toLowerCase();\n if (lineId && !/^[a-z0-9._-]{4,20}$/.test(lineId)) { toast(\"IDは半角英数字と . _ - で4〜20文字です\"); accIdInput.focus(); return; }\n accSubmitBtn.disabled = true;\n try {\n let data;\n if (lineAccount) {\n data = await apiPost(\"/api/account/update\", Object.assign({}, authBody(), { name, avatar_url: accDraftAvatar, line_id: lineId, status_msg: accStatusInput.value.trim() }));\n saveLineAccount(Object.assign({}, lineAccount, data.account));\n toast(\"プロフィールを保存しました\");\n } else {\n data = await apiPost(\"/api/account/register\", { name, avatar_url: accDraftAvatar, line_id: lineId, status_msg: accStatusInput.value.trim() });\n saveLineAccount(data.account);\n setIdentityMode(\"line\");\n toast(\"アカウントを作成しました\");\n }\n closeAccountOverlay();\n refreshIdentityUI();\n if (currentScreen === \"home\") loadHome();\n const cb = afterAccountReady; afterAccountReady = null;\n if (cb) cb();\n } catch (err) { toast(apiErrorMessage(err)); }\n finally { accSubmitBtn.disabled = false; }\n});\nfunction requireAccount(cb) {\n if (lineAccount) { cb(); return; }\n toast(\"この機能にはアカウントが必要です\");\n openAccountOverlay(cb);\n}\n\n/* =====================================================================\n ホーム画面\n ===================================================================== */\nfunction refreshIdentityUI() {\n renderHomeProfile();\n renderIdentityCard();\n}\nfunction renderHomeProfile() {\n const idn = currentIdentity();\n $(\"homeAvatar\").innerHTML = buildAvatarHtml(idn.name, idn.avatar, idn.user_id, \"xl\");\n $(\"homeName\").textContent = idn.name;\n let status = \"\";\n if (idn.mode === \"line\") status = lineAccount.status_msg || (lineAccount.line_id ? \"ID: \" + lineAccount.line_id : \"ステータスメッセージを設定\");\n else status = \"匿名ユーザー（ランダムトーク用）\";\n $(\"homeStatus\").textContent = status;\n}\nfunction renderIdentityCard() {\n const anonName = (anonProfile && anonProfile.name) || \"名無し\";\n const lineOn = !!lineAccount && identityMode === \"line\";\n let html = '

' +\n buildAvatarHtml(anonName, anonProfile && anonProfile.avatar, anonUserId, \"sm\") +\n '

' + escapeHtml(anonName) + '

匿名 · ランダムトーク向け

' +\n '' + icon(\"check\") + \"

\";\n if (lineAccount) {\n html += '

' +\n buildAvatarHtml(lineAccount.name, lineAccount.avatar_url, lineAccount.id, \"sm\") +\n '

' + escapeHtml(lineAccount.name) + '

' + (lineAccount.line_id ? \"ID: \" + escapeHtml(lineAccount.line_id) : \"友だち・グループ用アカウント\") + \"

\" +\n '' + icon(\"check\") + \"

\";\n } else {\n html += '

' +\n '

' + icon(\"user\") + \"

\" +\n '

アカウントを作成

友だち追加・グループトークが使えます

' +\n '

';\n }\n $(\"identityCard\").innerHTML = html;\n}\n$(\"identityCard\").addEventListener(\"click\", (e) => {\n const row = e.target.closest(\".identity-row\"); if (!row) return;\n const mode = row.dataset.mode;\n if (mode === \"create\") { openAccountOverlay(); return; }\n if (mode === \"line\" && !lineAccount) return;\n setIdentityMode(mode);\n refreshIdentityUI();\n toast(mode === \"line\" ? \"LINEアカウントに切り替えました\" : \"匿名ユーザーに切り替えました\");\n});\n$(\"identityHelp\").addEventListener(\"click\", () => {\n openSheet(\"アカウントの切り替え\", '

ランダムトークでは「匿名」と「アカウント」のどちらで発言するかを選べます。
1:1トーク・グループトークでは常にアカウントが使われます。

');\n});\n$(\"homeProfile\").addEventListener(\"click\", () => {\n if (currentIdentity().mode === \"line\") openAccountOverlay(); else openEntryOverlay(true);\n});\n\nasync function loadHome() {\n refreshIdentityUI();\n renderServices();\n if (!lineAccount) {\n $(\"friendsCount\").textContent = \"0\"; $(\"groupsCount\").textContent = \"0\";\n $(\"friendsList\").innerHTML = '

アカウントを作成すると友だちを追加できます

';\n $(\"groupsList\").innerHTML = '

グループトークにはアカウントが必要です

';\n return;\n }\n try {\n const data = await apiGet(\"/api/account/me?\" + authQuery().slice(1));\n if (data.account) saveLineAccount(Object.assign({}, lineAccount, data.account));\n homeData = { friends: data.friends || [], groups: data.groups || [] };\n renderFriends(); renderGroups(); refreshIdentityUI();\n } catch (err) {\n if (String(err.message) === \"unauthorized\") {\n $(\"friendsList\").innerHTML = '

アカウント情報が無効です。設定から引き継ぎコードで復元するか、新しく作成してください。

';\n } else {\n $(\"friendsList\").innerHTML = '

読み込みに失敗しました

';\n }\n }\n}\n$(\"friendsList\").addEventListener(\"click\", (e) => {\n const link = e.target.closest(\"[data-act='create-account']\"); if (link) { openAccountOverlay(); return; }\n const row = e.target.closest(\".home-row\"); if (!row) return;\n const f = homeData.friends.find((x) => x.id === row.dataset.id);\n if (f) openFriendProfileSheet(f);\n});\n$(\"groupsList\").addEventListener(\"click\", (e) => {\n const row = e.target.closest(\".home-row\"); if (!row) return;\n openChatroom(\"g:\" + row.dataset.id);\n});\nfunction renderFriends() {\n $(\"friendsCount\").textContent = String(homeData.friends.length);\n if (homeData.friends.length === 0) { $(\"friendsList\").innerHTML = '

まだ友だちがいません。右上の 友だち追加 からIDで検索、または招待リンクを送りましょう。

'; return; }\n $(\"friendsList\").innerHTML = homeData.friends.map((f) =>\n '

' + buildAvatarHtml(f.name, f.avatar_url, f.id) +\n '

' + escapeHtml(f.name) + \"

\" +\n (f.status_msg ? '

' + escapeHtml(f.status_msg) + \"

\" : \"\") + \"

\").join(\"\");\n}\nfunction renderGroups() {\n $(\"groupsCount\").textContent = String(homeData.groups.length);\n if (homeData.groups.length === 0) { $(\"groupsList\").innerHTML = '

グループはまだありません

'; return; }\n $(\"groupsList\").innerHTML = homeData.groups.map((g) =>\n '

' + buildGroupIconHtml(g.icon_url) +\n '

' + escapeHtml(g.name) + '

' + g.member_count + \"人

\").join(\"\");\n}\nfunction renderServices() {\n const items = [[\"news\", \"ニュース\", \"#3ba0f5\"], [\"wallet\", \"ウォレット\", \"#06c755\"], [\"voom\", \"VOOM\", \"#2ecc71\"], [\"paw\", \"動物\", \"#ff9f43\"], [\"poll\", \"投票\", \"#f5a623\"], [\"dice\", \"ダイス\", \"#9b59b6\"], [\"shuffle\", \"ランダム\", \"#ff6b81\"], [\"bell\", \"通知\", \"#f39c12\"], [\"gear\", \"設定\", \"#8e8e93\"]];\n $(\"servicesGrid\").innerHTML = items.map((it) => '

' + icon(it[0]) + \"

\" + it[1] + \"

\").join(\"\");\n}\n$(\"servicesGrid\").addEventListener(\"click\", (e) => {\n const s = e.target.closest(\".service\"); if (!s) return;\n const k = s.dataset.svc;\n if (k === \"news\") navigateTo(\"news\"); else if (k === \"wallet\") navigateTo(\"wallet\"); else if (k === \"voom\") navigateTo(\"timeline\");\n else if (k === \"paw\") openWebview(SERVICE_LINKS.animal, \"動物\");\n else if (k === \"shuffle\") openChatroom(randomRoomId()); else if (k === \"gear\") openSettingsSheet();\n else if (k === \"bell\") { if (window.enablePush) window.enablePush(); }\n else toast(\"トーク画面の＋から使えます\");\n});\n\nfunction openFriendProfileSheet(f) {\n openSheet(\"\", '

' + buildAvatarHtml(f.name, f.avatar_url, f.id, \"xl\") +\n '

' + escapeHtml(f.name) + \"

\" +\n '

' + escapeHtml(f.status_msg || (f.line_id ? \"ID: \" + f.line_id : \"\")) + \"

\" +\n '

' +\n '\" +\n '\" +\n '\" +\n \"

\");\n sheetBody.onclick = (e) => {\n const b = e.target.closest(\"[data-action]\"); if (!b) return;\n const a = b.dataset.action;\n if (a === \"talk\") { closeSheet(); openChatroom(dmRoomFor(lineAccount.id, f.id)); }\n else if (a === \"group\") { closeSheet(); openCreateGroupSheet([f.id]); }\n else toast(\"通話は未対応です\");\n };\n}\n\n/* ---------- 友だち追加 ---------- */\nfunction openAddFriendSheet(prefill) {\n requireAccount(() => {\n const myIdText = lineAccount.line_id ? \"ID: \" + lineAccount.line_id : \"IDが未設定です（プロフィールから設定できます）\";\n openSheet(\"友だち追加\",\n '

' +\n '

自分の情報

' +\n '

' + buildAvatarHtml(lineAccount.name, lineAccount.avatar_url, lineAccount.id) +\n '

' + escapeHtml(lineAccount.name) + '

' + escapeHtml(myIdText) + \"

\" +\n sheetItem(\"copy-invite\", \"link\", \"招待リンクをコピー\", \"リンクを開いた相手が友だちに追加できます\") +\n (lineAccount.line_id ? \"\" : sheetItem(\"set-id\", \"key\", \"IDを設定する\", \"検索で見つけてもらえるようになります\")));\n const input = $(\"afInput\"); const result = $(\"afResult\");\n async function search() {\n const q = input.value.trim().toLowerCase();\n if (!q) return;\n result.innerHTML = '

検索中...

';\n try {\n const data = await apiGet(\"/api/account/lookup?line_id=\" + encodeURIComponent(q));\n showResult(data.account);\n } catch (err) { result.innerHTML = '

見つかりませんでした

'; }\n }\n function showResult(acc) {\n if (acc.id === lineAccount.id) { result.innerHTML = '

自分自身です

'; return; }\n const already = homeData.friends.some((f) => f.id === acc.id);\n result.innerHTML = '

' + buildAvatarHtml(acc.name, acc.avatar_url, acc.id, \"lg\") +\n '

' + escapeHtml(acc.name) + '

' + escapeHtml(acc.status_msg || (acc.line_id ? \"ID: \" + acc.line_id : \"\")) + \"

\" +\n (already ? '' : '') + \"

\";\n result.querySelector(\"[data-add]\").addEventListener(\"click\", async () => {\n if (already) { closeSheet(); openChatroom(dmRoomFor(lineAccount.id, acc.id)); return; }\n try {\n const data = await apiPost(\"/api/friends/add\", Object.assign({}, authBody(), { friend_id: acc.id }));\n toast(acc.name + \" を友だちに追加しました\");\n closeSheet();\n await loadHome();\n openChatroom(data.room);\n } catch (err) { toast(apiErrorMessage(err)); }\n });\n }\n $(\"afSearch\").addEventListener(\"click\", search);\n input.addEventListener(\"keydown\", (e) => { if (e.key === \"Enter\") { e.preventDefault(); search(); } });\n sheetBody.onclick = async (e) => {\n const b = e.target.closest(\".sheet-item\"); if (!b) return;\n if (b.dataset.action === \"copy-invite\") {\n const link = location.origin + location.pathname + \"#add:\" + lineAccount.id;\n toast((await copyText(link)) ? \"招待リンクをコピーしました\" : link);\n } else if (b.dataset.action === \"set-id\") { closeSheet(); openAccountOverlay(); }\n };\n if (prefill) showResult(prefill); else input.focus();\n });\n}\n$(\"addFriendBtn\").addEventListener(\"click\", () => openAddFriendSheet());\n$(\"addFriendLink\").addEventListener(\"click\", () => openAddFriendSheet());\nasync function handleAddLink(accountId) {\n history.replaceState(null, \"\", location.pathname + location.search);\n requireAccount(async () => {\n try {\n const data = await apiGet(\"/api/account/lookup?account_id=\" + encodeURIComponent(accountId));\n if (homeData.friends.length === 0) { try { const me = await apiGet(\"/api/account/me?\" + authQuery().slice(1)); homeData = { friends: me.friends || [], groups: me.groups || [] }; } catch (e) {} }\n navigateTo(\"home\");\n openAddFriendSheet(data.account);\n } catch (err) { toast(\"ユーザーが見つかりませんでした\"); navigateTo(\"talklist\"); }\n });\n}\n\n/* ---------- グループ作成 ---------- */\nfunction openCreateGroupSheet(preselect) {\n requireAccount(async () => {\n if (homeData.friends.length === 0) { try { const me = await apiGet(\"/api/account/me?\" + authQuery().slice(1)); homeData = { friends: me.friends || [], groups: me.groups || [] }; } catch (e) {} }\n const pre = preselect || [];\n openSheet(\"グループを作成\",\n '

' +\n '

友だちを選択

' +\n (homeData.friends.length ? homeData.friends.map((f) => pickRow(f.id, buildAvatarHtml(f.name, f.avatar_url, f.id, \"sm\"), f.name, f.status_msg, pre.indexOf(f.id) >= 0)).join(\"\") : '

友だちがいません。あとから招待リンクでも参加できます。

') +\n '

');\n sheetBody.querySelectorAll(\".pick-row\").forEach((r) => { r.dataset.toggle = \"1\"; });\n $(\"cgCreate\").addEventListener(\"click\", async () => {\n const name = $(\"cgName\").value.trim();\n if (!name) { toast(\"グループ名を入力してください\"); return; }\n const ids = Array.from(sheetBody.querySelectorAll(\".pick-row.on\")).map((r) => r.dataset.id);\n try {\n const data = await apiPost(\"/api/groups/create\", Object.assign({}, authBody(), { name, member_ids: ids }));\n closeSheet();\n toast(\"グループを作成しました\");\n openChatroom(data.room);\n } catch (err) { toast(apiErrorMessage(err)); }\n });\n setTimeout(() => $(\"cgName\").focus(), 50);\n });\n}\n$(\"createGroupLink\").addEventListener(\"click\", () => openCreateGroupSheet());\n\n/* ---------- 設定 ---------- */\nfunction openSettingsSheet() {\n openSheet(\"設定\",\n sheetItem(\"anon-profile\", \"user\", \"匿名プロフィール\", \"ランダムトークで使う名前・アイコン\") +\n (lineAccount ? sheetItem(\"line-profile\", \"user\", \"アカウントプロフィール\", lineAccount.name + (lineAccount.line_id ? \" · ID: \" + lineAccount.line_id : \"\")) : sheetItem(\"line-create\", \"add-friend\", \"アカウントを作成\", \"友だち・グループトークに必要\")) +\n sheetItem(\"notif\", \"bell\", \"通知\", (\"Notification\" in window) ? (Notification.permission === \"granted\" ? \"オン\" : \"オフ\") : \"非対応\") +\n '

アカウントの引き継ぎ

' +\n (lineAccount ? sheetItem(\"export\", \"key\", \"引き継ぎコードを表示\", \"他の端末でこのアカウントを使う\") : \"\") +\n sheetItem(\"import\", \"copy\", \"引き継ぎコードで復元\", \"別端末のアカウントをこの端末で使う\") +\n (lineAccount ? sheetItem(\"logout\", \"exit\", \"この端末からアカウントを削除\", \"サーバー上のデータは残ります\", { danger: true }) : \"\"));\n sheetBody.onclick = async (e) => {\n const b = e.target.closest(\".sheet-item\"); if (!b) return;\n const a = b.dataset.action;\n if (a === \"anon-profile\") { closeSheet(); openEntryOverlay(true); }\n else if (a === \"line-profile\" || a === \"line-create\") { closeSheet(); openAccountOverlay(); }\n else if (a === \"notif\") { closeSheet(); if (window.enablePush) window.enablePush(); }\n else if (a === \"export\") {\n const code = lineAccount.id + \".\" + lineAccount.token;\n openSheet(\"引き継ぎコード\", '

このコードを他の端末の「引き継ぎコードで復元」に貼り付けてください。他人に教えないでください。

' + escapeHtml(code) + \"

\" + sheetItem(\"copy-code\", \"copy\", \"コードをコピー\"));\n sheetBody.onclick = async (ev) => { if (ev.target.closest(\"[data-action='copy-code']\")) toast((await copyText(code)) ? \"コピーしました\" : \"コピーに失敗しました\"); };\n }\n else if (a === \"import\") {\n openSheet(\"引き継ぎコードで復元\", '

');\n $(\"impBtn\").addEventListener(\"click\", async () => {\n const raw = $(\"impCode\").value.trim(); const dot = raw.indexOf(\".\");\n if (dot < 0) { toast(\"コードの形式が正しくありません\"); return; }\n const id = raw.slice(0, dot), token = raw.slice(dot + 1);\n try {\n const data = await apiGet(\"/api/account/me?account_id=\" + encodeURIComponent(id) + \"&token=\" + encodeURIComponent(token));\n saveLineAccount(Object.assign({}, data.account, { token }));\n setIdentityMode(\"line\");\n closeSheet(); toast(\"アカウントを復元しました\"); loadHome();\n } catch (err) { toast(\"復元に失敗しました。コードを確認してください\"); }\n });\n }\n else if (a === \"logout\") {\n if (!confirm(\"この端末からアカウント情報を削除しますか？\\\\n引き継ぎコードが無いと元に戻せません。\")) return;\n saveLineAccount(null); setIdentityMode(\"anon\"); closeSheet(); toast(\"削除しました\"); loadHome();\n }\n };\n}\n$(\"settingsBtn\").addEventListener(\"click\", openSettingsSheet);\n$(\"homeSearchBtn\").addEventListener(\"click\", () => { navigateTo(\"talklist\"); setTimeout(() => talkSearchInput.focus(), 50); });\n$(\"talkSearchBtn\").addEventListener(\"click\", () => talkSearchInput.focus());\n\n/* =====================================================================\n トーク一覧\n ===================================================================== */\nfunction buildRoomPreview(r) {\n if (!r.last_message_id) return r.type === \"group\" ? \"グループが作成されました\" : \"\";\n if (r.last_deleted) return \"メッセージが削除されました\";\n if (r.last_is_system) return r.last_body;\n const prefix = r.type === \"group\" && r.last_name ? r.last_name + \": \" : \"\";\n if (r.last_is_poll) return prefix + \"[投票] \" + (r.last_body || \"\").replace(/^投票 /, \"\");\n if (r.last_has_image && !r.last_body) return prefix + \"[画像]\";\n return prefix + (r.last_body || \"\");\n}\nlet talkLoading = false;\nasync function loadTalklist(silent) {\n if (talkLoading) return; talkLoading = true;\n if (!silent && allRooms.length === 0) talklistItems.innerHTML = '

読み込み中...

';\n try {\n const data = await apiGet(\"/api/rooms?user_id=\" + encodeURIComponent(anonUserId) + authQuery() + \"&reads=\" + encodeURIComponent(JSON.stringify(getReads())));\n allRooms = data.rooms || [];\n applyTalkFilter();\n updateTabBadges();\n } catch (err) {\n console.error(err);\n if (!silent) talklistItems.innerHTML = '

読み込みに失敗しました

';\n } finally { talkLoading = false; }\n}\nfunction updateTabBadges() {\n const total = allRooms.reduce((s, r) => s + (r.unread || 0), 0);\n const badge = $(\"talkTabBadge\");\n badge.textContent = total > 99 ? \"99+\" : String(total);\n badge.classList.toggle(\"show\", total > 0);\n backCount.textContent = total > 0 ? String(total) : \"\";\n}\nfunction applyTalkFilter() {\n const q = talkSearchInput.value.trim().toLowerCase();\n const list = q ? allRooms.filter((r) => (r.title || r.room).toLowerCase().includes(q) || (r.last_body || \"\").toLowerCase().includes(q)) : allRooms;\n renderTalklistItems(list);\n}\nfunction renderTalklistItems(rooms) {\n if (rooms.length === 0) {\n talklistItems.innerHTML = '

' + (allRooms.length ? \"該当するトークがありません\" : \"まだトークがありません
右上のボタンから新しいトークを始めましょう\") + \"

\";\n return;\n }\n talklistItems.innerHTML = \"\";\n rooms.forEach((r) => {\n const item = document.createElement(\"div\");\n item.className = \"talk-item\";\n const nameHtml = escapeHtml(r.title || \"#\" + r.room) + (r.type === \"group\" ? \"\" + r.member_count + \"\" : \"\");\n item.innerHTML =\n buildRoomIconHtml(r, \"lg\") +\n '

' +\n '

' + nameHtml + \"\" + (r.type === \"random\" ? 'ランダム' : \"\") + '' + fmtListTime(r.last_created_at) + \"

\" +\n '

' + escapeHtml(buildRoomPreview(r)) + '' + (r.unread > 0 ? (r.unread > 99 ? \"99+\" : r.unread) : \"\") + \"

\" +\n \"

\";\n item.addEventListener(\"click\", () => openChatroom(r.room));\n talklistItems.appendChild(item);\n });\n}\ntalkSearchInput.addEventListener(\"input\", applyTalkFilter);\nsetInterval(() => { if (currentScreen === \"talklist\" && document.visibilityState === \"visible\") loadTalklist(true); }, 6000);\n\nnewChatBtn.addEventListener(\"click\", () => {\n openSheet(\"新規トーク\",\n sheetItem(\"random\", \"shuffle\", \"ランダムトークを作成\", \"招待リンクで誰でも参加できる匿名ルーム\") +\n sheetItem(\"friend\", \"user\", \"友だちとトーク\", \"1:1のトーク\") +\n sheetItem(\"group\", \"people\", \"グループを作成\", \"複数人でトーク\"));\n sheetBody.onclick = (e) => {\n const b = e.target.closest(\".sheet-item\"); if (!b) return;\n const a = b.dataset.action; closeSheet();\n if (a === \"random\") openChatroom(randomRoomId());\n else if (a === \"group\") openCreateGroupSheet();\n else if (a === \"friend\") requireAccount(async () => {\n try { const me = await apiGet(\"/api/account/me?\" + authQuery().slice(1)); homeData = { friends: me.friends || [], groups: me.groups || [] }; } catch (e) {}\n if (homeData.friends.length === 0) { toast(\"まず友だちを追加しましょう\"); openAddFriendSheet(); return; }\n openSheet(\"友だちを選択\", homeData.friends.map((f) => '

' + buildAvatarHtml(f.name, f.avatar_url, f.id) + '

' + escapeHtml(f.name) + \"

\").join(\"\"));\n sheetBody.onclick = (ev) => { const r = ev.target.closest(\".home-row\"); if (!r) return; closeSheet(); openChatroom(dmRoomFor(lineAccount.id, r.dataset.id)); };\n });\n };\n});\n\n/* =====================================================================\n チャット画面入退室\n ===================================================================== */\nfunction resetChatState() {\n lastId = 0; lastUpdateSeen = 0; firstLoad = true; lastRenderedDateStr = \"\"; lastSender = null;\n readers = []; readersSig = \"\";\n msgIndex.clear(); messageData.clear();\n messagesEl.innerHTML = '

まだメッセージはありません

';\n replyingTo = null; showReplyPreview();\n clearImagePreview();\n bodyInput.value = \"\"; autoGrowBody(); updateComposerState();\n restoreDraft();\n}\nfunction setRoomHeader(info) {\n roomInfo = info;\n roomLabel.textContent = info ? info.title : (isAccountRoom(room) ? \"…\" : \"#\" + room);\n roomCount.textContent = info && info.type === \"group\" ? String(info.members.length) : \"\";\n}\nasync function loadRoomInfo() {\n if (!isAccountRoom(room)) { setRoomHeader({ type: \"random\", room, title: \"#\" + room, icon: \"\", members: [] }); return; }\n try {\n const info = await apiGet(\"/api/room-info?room=\" + encodeURIComponent(room) + authQuery());\n setRoomHeader(info);\n } catch (err) {\n toast(apiErrorMessage(err));\n navigateTo(\"talklist\");\n }\n}\nasync function openChatroom(r) {\n if (!r) return;\n if (isAccountRoom(r) && !lineAccount) {\n history.replaceState(null, \"\", location.pathname + location.search);\n toast(\"このトークに参加するにはアカウントが必要です\");\n openAccountOverlay(() => openChatroom(r));\n return;\n }\n if (r.indexOf(\"g:\") === 0) {\n try { await apiPost(\"/api/groups/join\", Object.assign({}, authBody(), { group_id: r.slice(2) })); }\n catch (err) { toast(apiErrorMessage(err)); history.replaceState(null, \"\", location.pathname + location.search); navigateTo(\"talklist\"); return; }\n }\n stopChatPolling();\n room = r;\n history.replaceState(null, \"\", location.pathname + location.search + \"#\" + r);\n setRoomHeader(null);\n resetChatState();\n showScreen(\"chatroom\");\n loadRoomInfo();\n startChatPolling();\n}\nfunction startChatPolling() {\n if (chatPollTimer) return;\n setupPushNotifications();\n poll();\n chatPollTimer = setInterval(poll, 1500);\n}\nfunction stopChatPolling() { if (chatPollTimer) { clearInterval(chatPollTimer); chatPollTimer = null; } }\n\n/* ---------- ルームメニュー (≡) ---------- */\n$(\"roomMenuBtn\").addEventListener(\"click\", () => {\n const info = roomInfo || { type: \"random\", members: [] };\n let html = \"\";\n if (info.type !== \"random\" && info.members && info.members.length) {\n html += '

メンバー ' + info.members.length + \"

\" +\n info.members.map((m) => '

' + buildAvatarHtml(m.name, m.avatar_url, m.id, \"sm\") + '

' + escapeHtml(m.name) + (lineAccount && m.id === lineAccount.id ? \" (自分)\" : \"\") + \"

\" + (m.status_msg ? '

' + escapeHtml(m.status_msg) + \"

\" : \"\") + \"

\").join(\"\");\n }\n if (info.type === \"random\") {\n html += '

ランダムトーク · ' + (onlineUsers.length || 1) + \"人がオンライン

\";\n html += sheetItem(\"who\", \"people\", \"オンラインのメンバーを見る\");\n }\n html += '

操作

';\n if (info.type !== \"dm\") html += sheetItem(\"invite-link\", \"link\", \"招待リンクをコピー\", info.type === \"group\" ? \"リンクを開いた人がグループに参加します\" : \"リンクを開いた人が入室できます\");\n if (info.type === \"group\") html += sheetItem(\"invite-friends\", \"add-friend\", \"友だちを招待\");\n if (info.type === \"dm\" && info.other_id) html += sheetItem(\"profile\", \"user\", \"プロフィールを見る\");\n html += sheetItem(\"notif\", \"bell\", \"通知\", (\"Notification\" in window && Notification.permission === \"granted\") ? \"オン\" : \"タップして許可\");\n if (info.type === \"group\") html += sheetItem(\"leave\", \"exit\", \"グループを退会\", \"\", { danger: true });\n openSheet(info.title || (\"#\" + room), html);\n sheetBody.onclick = async (e) => {\n const b = e.target.closest(\".sheet-item\"); if (!b) return;\n const a = b.dataset.action;\n if (a === \"invite-link\") { toast((await copyText(location.href)) ? \"招待リンクをコピーしました\" : location.href); }\n else if (a === \"who\") { closeSheet(); sendWhoCommand(); }\n else if (a === \"notif\") { closeSheet(); if (window.enablePush) window.enablePush(); }\n else if (a === \"profile\") { closeSheet(); const other = (info.members || []).find((m) => m.id === info.other_id); if (other) openFriendProfileSheet(other); }\n else if (a === \"invite-friends\") {\n try { const me = await apiGet(\"/api/account/me?\" + authQuery().slice(1)); homeData = { friends: me.friends || [], groups: me.groups || [] }; } catch (err) {}\n const memberIds = (info.members || []).map((m) => m.id);\n const cands = homeData.friends.filter((f) => memberIds.indexOf(f.id) < 0);\n openSheet(\"友だちを招待\", (cands.length ? cands.map((f) => pickRow(f.id, buildAvatarHtml(f.name, f.avatar_url, f.id, \"sm\"), f.name, f.status_msg, false)).join(\"\") : '

招待できる友だちがいません

') +\n '

');\n sheetBody.querySelectorAll(\".pick-row\").forEach((r) => { r.dataset.toggle = \"1\"; });\n sheetBody.onclick = null;\n $(\"invBtn\").addEventListener(\"click\", async () => {\n const ids = Array.from(sheetBody.querySelectorAll(\".pick-row.on\")).map((r) => r.dataset.id);\n if (!ids.length) { toast(\"友だちを選択してください\"); return; }\n try { await apiPost(\"/api/groups/invite\", Object.assign({}, authBody(), { group_id: info.group_id, member_ids: ids })); closeSheet(); toast(\"招待しました\"); loadRoomInfo(); poll(); }\n catch (err) { toast(apiErrorMessage(err)); }\n });\n }\n else if (a === \"leave\") {\n if (!confirm(\"このグループを退会しますか？\")) return;\n try { await apiPost(\"/api/groups/leave\", Object.assign({}, authBody(), { group_id: info.group_id })); closeSheet(); toast(\"退会しました\"); navigateTo(\"talklist\"); }\n catch (err) { toast(apiErrorMessage(err)); }\n }\n };\n});\n$(\"callBtn\").addEventListener(\"click\", () => toast(\"通話は未対応です\"));\n$(\"chatSearchBtn\").addEventListener(\"click\", () => {\n const q = prompt(\"トーク内を検索\");\n if (!q) return;\n const hit = Array.from(messageData.values()).reverse().find((m) => !m.deleted && (m.body || \"\").indexOf(q) >= 0);\n if (!hit) { toast(\"見つかりませんでした\"); return; }\n const entry = msgIndex.get(hit.id);\n if (entry && entry.el) { entry.el.scrollIntoView({ block: \"center\", behavior: \"smooth\" }); entry.el.classList.add(\"selected\"); setTimeout(() => entry.el.classList.remove(\"selected\"), 2500); }\n});\n\n/* =====================================================================\n 画像添付\n ===================================================================== */\nfunction setPendingFile(file) {\n pendingFile = file || null;\n if (!file) { clearImagePreview(); return; }\n fileLabel.classList.add(\"has-file\");\n const reader = new FileReader();\n reader.onload = () => { imagePreviewThumb.src = reader.result; imagePreviewBar.classList.add(\"show\"); };\n reader.readAsDataURL(file);\n updateComposerState();\n}\nfunction clearImagePreview() {\n pendingFile = null;\n fileInput.value = \"\"; cameraInput.value = \"\";\n fileLabel.classList.remove(\"has-file\");\n imagePreviewBar.classList.remove(\"show\");\n imagePreviewThumb.src = \"\";\n updateComposerState();\n}\nfileInput.addEventListener(\"change\", () => setPendingFile(fileInput.files[0]));\ncameraInput.addEventListener(\"change\", () => setPendingFile(cameraInput.files[0]));\nipCancel.addEventListener(\"click\", clearImagePreview);\nfunction updateComposerState() {\n composer.classList.toggle(\"has-text\", bodyInput.value.trim().length > 0 || !!pendingFile);\n}\n\n/* =====================================================================\n メッセージ描画\n ===================================================================== */\nfunction linkifyMentions(escapedBody) {\n return escapedBody.replace(/(^|[\\\\s\\\\u3000])@([^\\\\s\\\\u3000@]+)/g, (match, prefix, name) => prefix + '@' + name + \"\");\n}\nfunction signatureOf(m) { return JSON.stringify({ body: m.body, deleted: m.deleted, edited_at: m.edited_at, poll: m.poll, avatar_url: m.avatar_url, name: m.name }); }\nfunction buildTimeLabel(m) {\n const editedLabel = m.edited_at && !m.deleted ? '編集済み' : \"\";\n return fmtTime(m.created_at) + editedLabel;\n}\nfunction buildActionsRow(m, mine) {\n if (m.deleted) return \"\";\n let actions = '返信';\n if (m.body) actions += 'コピー';\n if (mine && m.id > 0) {\n if (!m.poll && !m.image_url) actions += '編集';\n actions += '削除';\n }\n return actions;\n}\nfunction buildPollHtml(m) {\n const poll = m.poll; const total = poll.total || 0;\n const optsHtml = poll.options.map((opt, idx) => {\n const pct = total > 0 ? Math.round((opt.count / total) * 100) : 0;\n const mine = poll.myVote === idx;\n return '';\n }).join(\"\");\n return '

' + escapeHtml(poll.question) + '

' + optsHtml + '

計 ' + total + '票

';\n}\nfunction extractColorCode(body) {\n const match = body.match(/^#([0-9a-fA-F]{3}|[0-9a-fA-F]{6})[ \\\\u3000]+([\\\\s\\\\S]+)$/);\n if (!match) return null;\n return { color: \"#\" + match[1], text: match[2] };\n}\nfunction buildBubbleInner(m) {\n if (m.deleted) return '

メッセージの送信を取り消しました

';\n let replyHtml = \"\";\n if (m.reply_to_id) replyHtml = '

' + escapeHtml(m.reply_to_name || \"\") + \"
\" + escapeHtml(truncateText(m.reply_to_body || \"\", 60)) + \"

\";\n const imgHtml = m.image_url ? ' $\"\"$ ' : \"\";\n if (m.image_url && !m.body && !m.reply_to_id && !m.poll) return '

' + imgHtml + \"

\";\n let bodyHtml;\n if (m.poll) bodyHtml = buildPollHtml(m);\n else {\n const colorInfo = extractColorCode(m.body);\n bodyHtml = colorInfo ? '' + linkifyMentions(escapeHtml(colorInfo.text)) + \"\" : linkifyMentions(escapeHtml(m.body));\n }\n return '

' + replyHtml + bodyHtml + imgHtml + \"

\";\n}\nfunction isSystem(m) { return m.user_id === \"system\"; }\nfunction createMessageElement(m) {\n if (isSystem(m)) {\n const div = document.createElement(\"div\");\n div.className = \"date-divider system-msg\"; div.dataset.id = m.id; div.textContent = m.body;\n return div;\n }\n const mine = m.user_id === myId();\n const wrap = document.createElement(\"div\");\n wrap.className = \"msg \" + (mine ? \"me\" : \"them\");\n wrap.dataset.id = m.id;\n wrap.innerHTML = '

' +\n '

';\n updateMessageElement(wrap, m);\n return wrap;\n}\nfunction updateMessageElement(wrap, m) {\n if (wrap.classList.contains(\"system-msg\")) { wrap.textContent = m.body; return; }\n const mine = m.user_id === myId();\n wrap.querySelector(\".msg-name\").textContent = mine ? \"\" : m.name;\n wrap.querySelector(\".msg-avatar-slot\").innerHTML = mine ? \"\" : buildAvatarHtml(m.name, m.avatar_url, m.user_id);\n wrap.querySelector(\".bubble-container\").innerHTML = buildBubbleInner(m);\n wrap.querySelector(\".msg-time\").innerHTML = buildTimeLabel(m);\n wrap.querySelector(\".msg-actions\").innerHTML = buildActionsRow(m, mine);\n updateReadLabel(wrap, m);\n}\nfunction readCountFor(m) {\n const me = myId();\n return readers.filter((r) => r.user_id !== me && r.user_id !== \"system\" && r.last_read_id >= m.id).length;\n}\nfunction updateReadLabel(wrap, m) {\n const el = wrap.querySelector(\".msg-read\"); if (!el) return;\n if (m.user_id !== myId() || m.id <= 0 || m.deleted) { el.textContent = \"\"; return; }\n const n = readCountFor(m);\n if (n <= 0) { el.textContent = \"\"; return; }\n el.textContent = roomInfo && roomInfo.type === \"dm\" ? \"既読\" : \"既読 \" + n;\n}\nfunction updateAllReadLabels() {\n const sig = JSON.stringify(readers);\n if (sig === readersSig) return; readersSig = sig;\n msgIndex.forEach((entry, id) => { const m = messageData.get(id); if (m && entry.el && !isSystem(m)) updateReadLabel(entry.el, m); });\n}\nfunction appendDateDividerIfNeeded(ts) {\n const dateStr = dateKey(ts);\n if (dateStr !== lastRenderedDateStr) {\n const divider = document.createElement(\"div\");\n divider.className = \"date-divider\"; divider.textContent = fmtDateDivider(ts);\n messagesEl.appendChild(divider);\n lastRenderedDateStr = dateStr; lastSender = null;\n }\n}\nfunction appendMessageElementToDOM(m) {\n if (firstLoad) { messagesEl.innerHTML = \"\"; firstLoad = false; }\n appendDateDividerIfNeeded(m.created_at);\n const el = createMessageElement(m);\n if (!isSystem(m) && m.user_id !== myId() && lastSender === m.user_id) el.classList.add(\"cont\");\n messagesEl.appendChild(el);\n lastSender = isSystem(m) ? null : m.user_id;\n msgIndex.set(m.id, { el, sig: signatureOf(m) });\n messageData.set(m.id, m);\n return el;\n}\nfunction renderSystemMessage(text) {\n const div = document.createElement(\"div\");\n div.className = \"date-divider system-msg\"; div.textContent = text;\n messagesEl.appendChild(div);\n messagesEl.scrollTop = messagesEl.scrollHeight;\n}\nfunction isNearBottom() { return messagesEl.scrollHeight - messagesEl.scrollTop - messagesEl.clientHeight < 80; }\n\nfunction render(messages) {\n const wasNearBottom = firstLoad ? true : isNearBottom();\n if (firstLoad) { messagesEl.innerHTML = \"\"; firstLoad = false; }\n const me = myId();\n if (pendingOptimistic) {\n const match = messages.find((m) => m.user_id === me && m.body === pendingOptimistic.body && (m.image_url || \"\") === (pendingOptimistic.image_url || \"\") && !msgIndex.has(m.id));\n if (match) {\n const entry = msgIndex.get(pendingOptimistic.tempId);\n if (entry && entry.el) entry.el.remove();\n msgIndex.delete(pendingOptimistic.tempId); messageData.delete(pendingOptimistic.tempId);\n pendingOptimistic = null;\n }\n }\n let maxId = lastId;\n for (const m of messages) {\n maxId = Math.max(maxId, m.id);\n if (m.updated_at) lastUpdateSeen = Math.max(lastUpdateSeen, m.updated_at);\n if (!isSystem(m)) knownNames.add(m.name);\n messageData.set(m.id, m);\n const sig = signatureOf(m);\n const existing = msgIndex.get(m.id);\n if (existing) {\n if (existing.sig !== sig && existing.el) { updateMessageElement(existing.el, m); existing.sig = sig; }\n continue;\n }\n appendMessageElementToDOM(m);\n }\n lastId = maxId;\n if (document.visibilityState === \"visible\") setRead(room, lastId);\n if (wasNearBottom) { messagesEl.scrollTop = messagesEl.scrollHeight; scrollBottomBtn.classList.remove(\"show\"); }\n else scrollBottomBtn.classList.add(\"show\");\n}\n\nmessagesEl.addEventListener(\"scroll\", () => { if (isNearBottom()) scrollBottomBtn.classList.remove(\"show\"); });\nscrollBottomBtn.addEventListener(\"click\", () => { messagesEl.scrollTop = messagesEl.scrollHeight; scrollBottomBtn.classList.remove(\"show\"); });\nmessagesEl.addEventListener(\"click\", (e) => {\n const replyBtn = e.target.closest(\".reply-btn\");\n if (replyBtn) { const m = messageData.get(Number(replyBtn.dataset.id)); if (m) { replyingTo = { id: m.id, name: m.name, body: m.body || (m.image_url ? \"[画像]\" : \"\") }; showReplyPreview(); } clearSelected(); return; }\n const copyBtn = e.target.closest(\".copy-btn\");\n if (copyBtn) { const m = messageData.get(Number(copyBtn.dataset.id)); if (m) copyText(m.body).then((ok) => toast(ok ? \"コピーしました\" : \"コピーに失敗しました\")); clearSelected(); return; }\n const editBtn = e.target.closest(\".edit-btn\");\n if (editBtn) { startEdit(editBtn.dataset.id); clearSelected(); return; }\n const deleteBtn = e.target.closest(\".delete-btn\");\n if (deleteBtn) { handleDelete(deleteBtn.dataset.id); clearSelected(); return; }\n const pollOption = e.target.closest(\".poll-option\");\n if (pollOption) { handleVote(pollOption.dataset.pollId, pollOption.dataset.messageId, pollOption.dataset.option); return; }\n const img = e.target.closest(\".msg-img\");\n if (img) { openLightbox(img.dataset.full); return; }\n const avatar = e.target.closest(\".msg-avatar-slot\");\n if (avatar) {\n const wrap = avatar.closest(\".msg\"); const m = messageData.get(Number(wrap.dataset.id));\n if (m && roomInfo && roomInfo.members) { const mem = roomInfo.members.find((x) => x.id === m.user_id); if (mem) { openFriendProfileSheet(mem); return; } }\n if (m) { insertMention(m.name, true); }\n return;\n }\n if (e.target.closest(\".edit-box\")) return;\n const bubble = e.target.closest(\".bubble\");\n if (bubble) {\n const wrap = bubble.closest(\".msg\"); const was = wrap.classList.contains(\"selected\");\n clearSelected(); if (!was) wrap.classList.add(\"selected\");\n return;\n }\n clearSelected();\n});\nfunction clearSelected() { document.querySelectorAll(\".msg.selected\").forEach((el) => el.classList.remove(\"selected\")); }\n\nfunction openLightbox(src) { lightboxImg.src = src; lightbox.classList.add(\"show\"); }\nfunction closeLightbox() { lightbox.classList.remove(\"show\"); lightboxImg.src = \"\"; }\nlightbox.addEventListener(\"click\", closeLightbox);\n\nfunction showReplyPreview() {\n if (!replyingTo) { replyPreviewBar.style.display = \"none\"; return; }\n rpText.textContent = replyingTo.name + \": \" + replyingTo.body;\n replyPreviewBar.style.display = \"flex\";\n bodyInput.focus();\n}\nrpCancel.addEventListener(\"click\", () => { replyingTo = null; showReplyPreview(); });\n\nfunction startEdit(idStr) {\n const id = Number(idStr); const m = messageData.get(id);\n if (!m || m.deleted) return;\n const entry = msgIndex.get(id); if (!entry) return;\n const bubbleContainer = entry.el.querySelector(\".bubble-container\");\n bubbleContainer.innerHTML = '

' +\n '

保存キャンセル

';\n const input = bubbleContainer.querySelector(\".edit-input\");\n input.focus(); input.setSelectionRange(input.value.length, input.value.length);\n bubbleContainer.querySelector(\".edit-cancel\").addEventListener(\"click\", () => { bubbleContainer.innerHTML = buildBubbleInner(m); });\n bubbleContainer.querySelector(\".edit-save\").addEventListener(\"click\", () => submitEdit(id, input.value));\n input.addEventListener(\"keydown\", (e) => {\n if (e.key === \"Enter\") { e.preventDefault(); submitEdit(id, input.value); }\n if (e.key === \"Escape\") { bubbleContainer.innerHTML = buildBubbleInner(m); }\n });\n}\nasync function submitEdit(id, newBody) {\n const trimmed = newBody.trim(); if (!trimmed) return;\n try {\n const data = await apiPost(\"/api/edit\", { id, user_id: myId(), body: trimmed });\n if (!data.success) { toast(\"編集に失敗しました\"); return; }\n await poll();\n } catch (err) { toast(apiErrorMessage(err)); }\n}\nasync function handleDelete(idStr) {\n const id = Number(idStr);\n if (!confirm(\"送信を取り消しますか？\")) return;\n try { await apiPost(\"/api/delete\", { id, user_id: myId() }); await poll(); }\n catch (err) { toast(apiErrorMessage(err)); }\n}\nasync function handleVote(pollIdStr, messageIdStr, optionStr) {\n try {\n await apiPost(\"/api/poll/vote\", { poll_id: Number(pollIdStr), message_id: Number(messageIdStr), user_id: myId(), option_index: Number(optionStr) });\n await poll();\n } catch (err) { toast(apiErrorMessage(err)); }\n}\n\n/* =====================================================================\n 入力欄\n ===================================================================== */\nbodyInput.addEventListener(\"input\", () => {\n updateComposerState();\n const val = bodyInput.value; const caret = bodyInput.selectionStart;\n const match = val.slice(0, caret).match(/(^|[\\\\s\\\\u3000])@([^\\\\s\\\\u3000@]*)$/);\n if (match) {\n const query = match[2].toLowerCase(); const myName = getDisplayName();\n const candidates = Array.from(knownNames).filter((n) => n !== myName && n.toLowerCase().includes(query));\n if (candidates.length > 0) { showMentionList(candidates); return; }\n }\n hideMentionList();\n});\nbodyInput.addEventListener(\"blur\", () => setTimeout(hideMentionList, 150));\nfunction autoGrowBody() { bodyInput.style.height = \"auto\"; bodyInput.style.height = Math.min(bodyInput.scrollHeight, 120) + \"px\"; }\nbodyInput.addEventListener(\"input\", autoGrowBody);\n\nfunction getDraftKey() { return \"chatDraft:\" + room; }\nfunction saveDraft() { if (!room) return; try { localStorage.setItem(getDraftKey(), bodyInput.value); } catch (e) {} }\nfunction restoreDraft() {\n if (!room) return;\n try { const saved = localStorage.getItem(getDraftKey()); if (saved) { bodyInput.value = saved; autoGrowBody(); updateComposerState(); } } catch (e) {}\n}\nfunction clearDraft() { if (!room) return; try { localStorage.removeItem(getDraftKey()); } catch (e) {} }\nbodyInput.addEventListener(\"input\", saveDraft);\nwindow.addEventListener(\"pagehide\", saveDraft);\ndocument.addEventListener(\"visibilitychange\", () => {\n if (document.visibilityState === \"hidden\") saveDraft();\n else if (currentScreen === \"chatroom\") { restoreDraft(); poll(); }\n});\nwindow.addEventListener(\"pageshow\", () => { if (currentScreen === \"chatroom\") restoreDraft(); });\nsetInterval(saveDraft, 3000);\n\nbodyInput.addEventListener(\"keydown\", (e) => {\n if (e.key === \"Enter\" && !e.shiftKey && !e.isComposing) {\n e.preventDefault();\n composer.requestSubmit ? composer.requestSubmit() : composer.dispatchEvent(new Event(\"submit\", { cancelable: true }));\n }\n});\nbodyInput.addEventListener(\"focus\", () => { setAppHeightVar(); setTimeout(() => { messagesEl.scrollTop = messagesEl.scrollHeight; }, 300); });\n$(\"micBtn\").addEventListener(\"click\", () => toast(\"音声メッセージは未対応です\"));\n$(\"emojiBtn\").addEventListener(\"click\", () => {\n const emojis = [\"😊\", \"😂\", \"🥹\", \"😍\", \"🤣\", \"😭\", \"👍\", \"🙏\", \"🎉\", \"❤️\", \"✨\", \"🔥\", \"😎\", \"🤔\", \"😴\", \"🍻\", \"☕\", \"🐶\", \"🐱\", \"🌸\"];\n openSheet(\"絵文字\", '

' + emojis.map((e) => '' + e + \"\").join(\"\") + \"

\");\n sheetBody.onclick = (e) => { const s = e.target.closest(\".emoji-pick\"); if (!s) return; bodyInput.value += s.dataset.e; updateComposerState(); autoGrowBody(); saveDraft(); };\n});\n\nfunction showMentionList(candidates) {\n mentionList.innerHTML = \"\";\n candidates.slice(0, 6).forEach((n) => {\n const item = document.createElement(\"div\");\n item.className = \"mention-item\"; item.textContent = n;\n item.addEventListener(\"mousedown\", (e) => { e.preventDefault(); insertMention(n); });\n mentionList.appendChild(item);\n });\n mentionList.style.display = \"block\";\n}\nfunction hideMentionList() { mentionList.style.display = \"none\"; mentionList.innerHTML = \"\"; }\nfunction insertMention(name, append) {\n if (append) { bodyInput.value = (bodyInput.value ? bodyInput.value.replace(/\\\\s*$/, \" \") : \"\") + \"@\" + name + \" \"; }\n else {\n const val = bodyInput.value; const caret = bodyInput.selectionStart;\n const replaced = val.slice(0, caret).replace(/@([^\\\\s\\\\u3000@]*)$/, \"@\" + name + \" \");\n bodyInput.value = replaced + val.slice(caret);\n }\n hideMentionList(); updateComposerState(); autoGrowBody(); bodyInput.focus();\n}\n\n/* ---------- ＋メニュー ---------- */\n$(\"plusBtn\").addEventListener(\"click\", () => {\n openSheet(\"\",\n sheetItem(\"poll\", \"poll\", \"投票を作成\", \"/poll 質問|選択肢1|選択肢2 でも作成できます\") +\n sheetItem(\"roll\", \"dice\", \"ダイスを振る\", \"/roll または /roll 100\") +\n sheetItem(\"who\", \"people\", \"オンラインのメンバー\", \"/who\") +\n sheetItem(\"invite\", \"link\", \"招待リンクをコピー\") +\n sheetItem(\"profile\", \"user\", \"プロフィールを編集\", \"/profile\"));\n sheetBody.onclick = async (e) => {\n const b = e.target.closest(\".sheet-item\"); if (!b) return;\n const a = b.dataset.action; closeSheet();\n if (a === \"roll\") sendRollCommand(6);\n else if (a === \"who\") sendWhoCommand();\n else if (a === \"invite\") toast((await copyText(location.href)) ? \"招待リンクをコピーしました\" : location.href);\n else if (a === \"profile\") { if (currentIdentity().mode === \"line\") openAccountOverlay(); else openEntryOverlay(true); }\n else if (a === \"poll\") openPollSheet();\n };\n});\nfunction openPollSheet() {\n openSheet(\"投票を作成\",\n '

' +\n '' +\n '' +\n '

');\n $(\"plCreate\").addEventListener(\"click\", async () => {\n const q = $(\"plQ\").value.trim();\n const opts = Array.from(sheetBody.querySelectorAll(\".pl-opt\")).map((i) => i.value.trim()).filter((s) => s);\n if (!q || opts.length < 2) { toast(\"質問と2つ以上の選択肢を入力してください\"); return; }\n closeSheet();\n await createPoll(q, opts);\n });\n setTimeout(() => $(\"plQ\").focus(), 50);\n}\n\n/* =====================================================================\n スラッシュコマンド / 送信\n ===================================================================== */\nfunction detectSlashCommand(trimmed) {\n if (trimmed === \"/roll\" || trimmed.indexOf(\"/roll \") === 0) {\n const arg = trimmed === \"/roll\" ? \"\" : trimmed.slice(6).trim();\n let max = 6; if (arg !== \"\") { const n = parseInt(arg, 10); if (!Number.isNaN(n) && n > 0) max = n; }\n return { type: \"roll\", max };\n }\n if (trimmed.indexOf(\"/poll \") === 0) return { type: \"poll\", raw: trimmed.slice(6) };\n if (trimmed === \"/who\") return { type: \"who\" };\n if (trimmed.toLowerCase() === \"/profile\") return { type: \"profile\" };\n return null;\n}\nasync function sendRollCommand(max) {\n const safeMax = max > 0 ? max : 6;\n const result = Math.floor(Math.random() * safeMax) + 1;\n bodyInput.value = \"\"; autoGrowBody(); clearDraft(); clearImagePreview();\n await sendNormalMessage(\"🎲 \" + getDisplayName() + \" のダイス: \" + result + \" (1〜\" + safeMax + \")\", null);\n}\nasync function createPoll(question, options) {\n sending = true; bodyInput.disabled = true;\n try {\n const idn = currentIdentity();\n await apiPost(\"/api/poll/create\", { room, user_id: idn.user_id, name: idn.name, avatar_url: idn.avatar, question, options, token: idn.token });\n bodyInput.value = \"\"; autoGrowBody(); clearImagePreview(); clearDraft(); updateComposerState();\n await poll();\n } catch (err) { toast(apiErrorMessage(err)); }\n finally { bodyInput.disabled = false; bodyInput.focus(); sending = false; }\n}\nasync function sendPollCommand(raw) {\n const parts = raw.split(\"|\").map((s) => s.trim()).filter((s) => s.length > 0);\n if (parts.length < 3) { toast(\"使い方: /poll 質問|選択肢1|選択肢2 （選択肢は2つ以上）\"); return; }\n await createPoll(parts[0], parts.slice(1));\n}\nasync function sendWhoCommand() {\n bodyInput.value = \"\"; autoGrowBody(); clearDraft(); updateComposerState();\n try {\n await poll();\n const names = onlineUsers.length ? onlineUsers.map((u) => u.name).join(\"、\") : \"(自分以外は今いません)\";\n renderSystemMessage(\"オンライン (\" + onlineUsers.length + \"人): \" + names);\n } catch (err) { console.error(err); }\n}\n\nlet sending = false; let tempIdCounter = 0; let pendingOptimistic = null;\nasync function sendNormalMessage(body, file) {\n sending = true; bodyInput.disabled = true;\n const currentReply = replyingTo;\n const idn = currentIdentity();\n const sendRoom = room;\n try {\n let imageUrl = \"\"; if (file) imageUrl = await fileToBase64(file);\n const tempId = --tempIdCounter; const nowTs = Date.now();\n const optimisticMsg = {\n id: tempId, user_id: idn.user_id, name: idn.name, body, image_url: imageUrl,\n reply_to_id: currentReply ? currentReply.id : null, reply_to_name: currentReply ? currentReply.name : null,\n reply_to_body: currentReply ? currentReply.body : null, edited_at: null, deleted: false,\n updated_at: nowTs, poll_id: null, poll: null, created_at: nowTs, avatar_url: idn.avatar,\n };\n knownNames.add(idn.name);\n appendMessageElementToDOM(optimisticMsg);\n messagesEl.scrollTop = messagesEl.scrollHeight; scrollBottomBtn.classList.remove(\"show\");\n pendingOptimistic = { tempId, body, image_url: imageUrl };\n bodyInput.value = \"\"; autoGrowBody(); clearImagePreview(); clearDraft(); updateComposerState();\n replyingTo = null; showReplyPreview();\n await apiPost(\"/api/send\", {\n room: sendRoom, user_id: idn.user_id, name: idn.name, body, image_url: imageUrl, avatar_url: idn.avatar, token: idn.token,\n reply_to_id: currentReply ? currentReply.id : null, reply_to_name: currentReply ? currentReply.name : null, reply_to_body: currentReply ? currentReply.body : null,\n });\n await poll();\n } catch (err) {\n console.error(err); toast(apiErrorMessage(err));\n if (pendingOptimistic) {\n const entry = msgIndex.get(pendingOptimistic.tempId);\n if (entry && entry.el) entry.el.remove();\n msgIndex.delete(pendingOptimistic.tempId); messageData.delete(pendingOptimistic.tempId);\n bodyInput.value = body; autoGrowBody(); updateComposerState();\n pendingOptimistic = null;\n }\n } finally { bodyInput.disabled = false; bodyInput.focus(); sending = false; }\n}\n\nlet polling = false;\nasync function poll() {\n if (!room || currentScreen !== \"chatroom\" || polling) return;\n polling = true;\n const pollRoom = room;\n try {\n const idn = currentIdentity();\n const res = await fetch(\"/api/messages?room=\" + encodeURIComponent(pollRoom) + \"&since=\" + lastId + \"&sinceUpdate=\" + lastUpdateSeen +\n \"&viewer=\" + encodeURIComponent(idn.user_id) + \"&name=\" + encodeURIComponent(idn.name) +\n (idn.token ? \"&token=\" + encodeURIComponent(idn.token) : \"\") + (document.visibilityState === \"visible\" ? \"&read=1\" : \"\"));\n if (res.status === 403) { toast(\"このトークに参加していません\"); navigateTo(\"talklist\"); return; }\n const data = await res.json();\n if (pollRoom !== room) return;\n if (data.online) onlineUsers = data.online;\n if (data.messages && data.messages.length) render(data.messages);\n if (data.readers) { readers = data.readers; updateAllReadLabels(); }\n } catch (err) { console.error(err); }\n finally { polling = false; }\n}\nwindow.poll = poll;\n\ncomposer.addEventListener(\"submit\", async (e) => {\n e.preventDefault(); if (sending) return;\n const trimmed = bodyInput.value.trim(); const file = pendingFile;\n if (!trimmed && !file) return;\n const cmd = detectSlashCommand(trimmed);\n if (cmd && cmd.type === \"roll\") { await sendRollCommand(cmd.max); return; }\n if (cmd && cmd.type === \"poll\") { await sendPollCommand(cmd.raw); return; }\n if (cmd && cmd.type === \"who\") { await sendWhoCommand(); return; }\n if (cmd && cmd.type === \"profile\") { bodyInput.value = \"\"; autoGrowBody(); updateComposerState(); if (currentIdentity().mode === \"line\") openAccountOverlay(); else openEntryOverlay(true); return; }\n await sendNormalMessage(trimmed, file);\n});\n\n/* =====================================================================\n 起動\n ===================================================================== */\nfunction boot() {\n refreshIdentityUI();\n const initial = getRoomFromHash();\n if (initial && initial.indexOf(\"add:\") === 0) { showScreen(\"home\"); loadHome(); handleAddLink(initial.slice(4)); return; }\n if (initial) { openChatroom(initial); loadTalklist(true); }\n else { showScreen(\"talklist\"); loadTalklist(); }\n}\nupdateNotifUI();\nif (anonProfile) boot(); else openEntryOverlay(false);\n`;\n",[158],"pulls","branches",1,"forks","envVars",{"_172":166,"_174":62},"connections",{"_172":62,"_173":62},"count","unfilledCount","emptyCount",{"_43":157,"_32":158,"_30":159,"_134":-5,"_41":42,"_40":160,"_135":25,"_38":189,"_13":145,"_33":146,"_35":162,"_24":25,"_138":-5,"_180":190,"_27":191},{"_43":149,"_32":150,"_30":151,"_134":-5,"_41":42,"_40":152,"_135":58,"_38":186,"_13":154,"_33":146,"_35":155,"_24":25,"_138":-5,"_180":187,"_27":188},{"_43":140,"_32":141,"_30":142,"_134":-5,"_41":42,"_40":143,"_135":25,"_38":183,"_13":145,"_33":146,"_35":147,"_24":25,"_138":-5,"_180":184,"_27":185},{"_43":133,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_135":58,"_38":179,"_13":137,"_33":34,"_35":37,"_24":25,"_138":98,"_180":181,"_27":182},["D",1789191594094],"children",[],[28],["D",1788594687420],[],[141],["D",1788566749081],[],[150],["D",1788594751328],[],[158],["D",1788478632137],["D",1789448471428],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":55,"_104":105,"_106":25},{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"ctx",{"_81":-5,"_126":230,"_231":232,"_233":234,"_235":25,"_236":25,"_237":25,"_238":58,"_239":-5,"_240":-7,"_241":-7,"_242":62,"_243":25,"_244":25,"_245":-5,"_246":25,"_247":25,"_248":25,"_249":-5},"ENV",{"_201":202,"_203":204,"_205":89,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229},"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 · v38