[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_167":168,"_169":170},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_105":86,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":58,"_123":-5,"_124":-5,"_125":126},"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":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",76,"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","3ba0dce4-8a4e-11f1-b5a8-1607ee4eb77e","name","fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport webpush from \"https://esm.sh/web-push@3.6.7\";\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\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// 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(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(\"reply_to_id\", \"INTEGER\");\nawait ensureColumn(\"reply_to_name\", \"TEXT\");\nawait ensureColumn(\"reply_to_body\", \"TEXT\");\nawait ensureColumn(\"edited_at\", \"INTEGER\");\nawait ensureColumn(\"deleted\", \"INTEGER DEFAULT 0\");\nawait ensureColumn(\"updated_at\", \"INTEGER\");\nawait ensureColumn(\"poll_id\", \"INTEGER\");\nawait ensureColumn(\"avatar_url\", \"TEXT\");\n\nawait sqlite.execute(\n `UPDATE ${TABLE} SET updated_at = created_at WHERE updated_at IS NULL`,\n);\n\nconst ONLINE_WINDOW_MS = 8000;\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\n // ★追加: /sw.js を正規配信（Blob登録をやめてこれを使う）\n if (url.pathname === \"/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: Push 購読登録 ---\n if (url.pathname === \"/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 new Response(JSON.stringify({ error: \"invalid data\" }), {\n status: 400,\n });\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 new Response(JSON.stringify({ success: true }));\n } catch (err) {\n return new Response(JSON.stringify({ error: String(err) }), {\n status: 400,\n });\n }\n }\n\n // --- API: VAPID公開鍵の取得 (Web Push通知用) ---\n if (url.pathname === \"/api/vapid-public-key\") {\n return new Response(JSON.stringify({ publicKey: vapidKeys.publicKey }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n // --- API: メッセージ取得 ---\n if (url.pathname === \"/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\n if (viewer) {\n const now = Date.now();\n await sqlite.execute({\n sql: `INSERT INTO ${PRESENCE_TABLE} (room, user_id, name, last_seen)\n VALUES (?, ?, ?, ?)\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 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(row[0] ?? row.id),\n user_id: String(row[1] ?? row.user_id),\n name: String(row[2] ?? row.name),\n body: String(row[3] ?? row.body),\n image_url: (row[4] ?? row.image_url)\n ? String(row[4] ?? row.image_url)\n : \"\",\n reply_to_id: (row[5] ?? row.reply_to_id) != null\n ? Number(row[5] ?? row.reply_to_id)\n : null,\n reply_to_name: (row[6] ?? row.reply_to_name) != null\n ? String(row[6] ?? row.reply_to_name)\n : null,\n reply_to_body: (row[7] ?? row.reply_to_body) != null\n ? String(row[7] ?? row.reply_to_body)\n : null,\n edited_at: (row[8] ?? row.edited_at) != null\n ? Number(row[8] ?? row.edited_at)\n : null,\n deleted: Number(row[9] ?? row.deleted ?? 0) === 1,\n updated_at: Number(\n row[10] ?? row.updated_at ?? row[12] ?? row.created_at,\n ),\n poll_id: (row[11] ?? row.poll_id) != null\n ? Number(row[11] ?? row.poll_id)\n : null,\n created_at: Number(row[12] ?? row.created_at),\n avatar_url: (row[13] ?? row.avatar_url)\n ? String(row[13] ?? row.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\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\n for (const prow of pollResult.rows as any[]) {\n const pid = Number(prow[0] ?? prow.id);\n const question = String(prow[1] ?? prow.question);\n const options: string[] = JSON.parse(String(prow[2] ?? prow.options));\n const votes: Record = JSON.parse(\n String(prow[3] ?? prow.votes) || \"{}\",\n );\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\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(row[0] ?? row.user_id),\n name: String(row[1] ?? row.name),\n }));\n\n return new Response(JSON.stringify({ messages, online }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n // --- API: メッセージ送信 ---\n if (url.pathname === \"/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 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 // ★修正: バックグラウンド通知用に room URL を付与、410/404 なら購読削除\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\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: name + \" (#\" + room + \")\",\n body: body.length > 100 ? body.substring(0, 100) + \"…\" : body,\n tag: `msg-${room}`,\n icon: 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 new Response(JSON.stringify({ success: true }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n return new Response(JSON.stringify({ error: String(err) }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n // --- API: メッセージ編集 ---\n if (url.pathname === \"/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\n if (!id || !body) {\n return new Response(JSON.stringify({ error: \"invalid request\" }), {\n status: 400,\n });\n }\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) {\n return new Response(JSON.stringify({ error: \"not found\" }), {\n status: 404,\n });\n }\n if (String(row[0] ?? row.user_id) !== user_id) {\n return new Response(JSON.stringify({ error: \"forbidden\" }), {\n status: 403,\n });\n }\n if (Number(row[1] ?? row.deleted ?? 0) === 1) {\n return new Response(JSON.stringify({ error: \"already deleted\" }), {\n status: 400,\n });\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\n return new Response(JSON.stringify({ success: true }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n return new Response(JSON.stringify({ error: String(err) }), {\n status: 400,\n });\n }\n }\n\n // --- API: メッセージ削除 ---\n if (url.pathname === \"/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\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) {\n return new Response(JSON.stringify({ error: \"not found\" }), {\n status: 404,\n });\n }\n if (String(row[0] ?? row.user_id) !== user_id) {\n return new Response(JSON.stringify({ error: \"forbidden\" }), {\n status: 403,\n });\n }\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\n return new Response(JSON.stringify({ success: true }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n return new Response(JSON.stringify({ error: String(err) }), {\n status: 400,\n });\n }\n }\n\n // --- API: 投票作成 ---\n if (url.pathname === \"/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\n if (!question || options.length < 2) {\n return new Response(JSON.stringify({ error: \"invalid poll\" }), {\n status: 400,\n });\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\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\n return new Response(JSON.stringify({ success: true }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n return new Response(JSON.stringify({ error: String(err) }), {\n status: 400,\n });\n }\n }\n\n // --- API: 投票 ---\n if (url.pathname === \"/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\n if (!pollId || !user_id || Number.isNaN(optionIndex)) {\n return new Response(JSON.stringify({ error: \"invalid vote\" }), {\n status: 400,\n });\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) {\n return new Response(JSON.stringify({ error: \"poll not found\" }), {\n status: 404,\n });\n }\n\n const options: string[] = JSON.parse(String(prow[0] ?? prow.options));\n if (optionIndex < 0 || optionIndex >= options.length) {\n return new Response(JSON.stringify({ error: \"invalid option\" }), {\n status: 400,\n });\n }\n\n const votes: Record = JSON.parse(\n String(prow[1] ?? prow.votes) || \"{}\",\n );\n votes[user_id] = optionIndex;\n\n await sqlite.execute({\n sql: `UPDATE ${POLLS_TABLE} SET votes = ? WHERE id = ?`,\n args: [JSON.stringify(votes), pollId],\n });\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\n return new Response(JSON.stringify({ success: true }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n return new Response(JSON.stringify({ error: String(err) }), {\n status: 400,\n });\n }\n }\n\n // --- HTML配信 ---\n if (url.pathname === \"/\" || url.pathname === \"/index.html\") {\n return new Response(htmlContent, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n }\n\n // --- JavaScript配信 ---\n if (url.pathname === \"/client.js\") {\n return new Response(jsContent, {\n headers: { \"Content-Type\": \"application/javascript; charset=utf-8\" },\n });\n }\n\n return new Response(\"Not Found\", { status: 404 });\n}\n\n// ==========================================\n// 静的ファイルの内容\n// ==========================================\n\nconst htmlContent = `\n\n \n \n \n \n リアルタイムチャット\n \n \n \n \n \n \n

あああ

#lobby

\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\nconst jsContent = `\n// --- Service Worker 登録と Push 通知設定（バックグラウンド対応版） ---\nasync function setupPushNotifications() {\n if (!('serviceWorker' in navigator) || !('PushManager' in window)) {\n console.log('Push not supported');\n return;\n }\n try {\n // ★修正: Blobではなく /sw.js を正規登録。これでタブを閉じても生きる\n const registration = await navigator.serviceWorker.register('/sw.js');\n console.log('SW registered');\n\n const notifBar = document.getElementById('notifBar');\n const notifStatus = document.getElementById('notifStatus');\n const enableBtn = document.getElementById('enableNotifBtn');\n\n function updateUI() {\n if (Notification.permission === 'granted') {\n if (notifBar) notifBar.classList.remove('show');\n if (notifStatus) notifStatus.textContent = '🔔';\n } else if (Notification.permission === 'denied') {\n if (notifBar) notifBar.classList.remove('show');\n if (notifStatus) notifStatus.textContent = '🔕';\n } else {\n if (notifBar) notifBar.classList.add('show');\n if (notifStatus) notifStatus.textContent = '';\n }\n }\n updateUI();\n\n async function subscribe() {\n if (Notification.permission === 'default') {\n const perm = await Notification.requestPermission();\n if (perm !== 'granted') { updateUI(); return; }\n }\n if (Notification.permission !== 'granted') { updateUI(); return; }\n const res = await fetch('/api/vapid-public-key');\n const data = await res.json();\n if (!data.publicKey) throw new Error('no vapid key');\n const convertedKey = urlBase64ToUint8Array(data.publicKey);\n let subscription = await registration.pushManager.getSubscription();\n if (!subscription) {\n subscription = await registration.pushManager.subscribe({ userVisibleOnly: true, applicationServerKey: convertedKey });\n }\n await fetch('/api/subscribe', {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ user_id: myUserId, room: room, subscription: subscription })\n });\n console.log('Subscribed to push');\n updateUI();\n }\n\n if (enableBtn) enableBtn.addEventListener('click', subscribe);\n\n // 自動再購読（room変更対応）\n if (Notification.permission === 'granted') {\n const sub = await registration.pushManager.getSubscription();\n if (sub) {\n await fetch('/api/subscribe', {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ user_id: myUserId, room: room, subscription: sub })\n });\n } else {\n // 許可済みなのに購読が無いなら裏で購読\n await subscribe();\n }\n }\n\n } catch (err) {\n console.error('Push notification setup failed:', err);\n }\n}\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) {\n outputArray[i] = rawData.charCodeAt(i);\n }\n return outputArray;\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\nfunction getRoom() {\n let room = location.hash.replace(/^#/, \"\");\n if (!room) { room = Math.random().toString(36).slice(2, 8); location.hash = room; }\n return room;\n}\nfunction getUserId() {\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 room = getRoom(); const myUserId = getUserId();\nconst messagesEl = document.getElementById(\"messages\"); const composer = document.getElementById(\"composer\");\nconst bodyInput = document.getElementById(\"body\");\nconst roomLabel = document.getElementById(\"roomLabel\"); const invite = document.getElementById(\"invite\");\nconst fileInput = document.getElementById(\"imageFile\"); const fileLabel = document.getElementById(\"fileLabel\");\nconst mentionList = document.getElementById(\"mentionList\");\nconst replyPreviewBar = document.getElementById(\"replyPreviewBar\");\nconst rpText = document.getElementById(\"rpText\");\nconst rpCancel = document.getElementById(\"rpCancel\");\nconst imagePreviewBar = document.getElementById(\"imagePreviewBar\");\nconst imagePreviewThumb = document.getElementById(\"imagePreviewThumb\");\nconst ipCancel = document.getElementById(\"ipCancel\");\nconst scrollBottomBtn = document.getElementById(\"scrollBottomBtn\");\nconst lightbox = document.getElementById(\"lightbox\");\nconst lightboxImg = document.getElementById(\"lightboxImg\");\n\nconst profileBar = document.getElementById(\"profileBar\");\nconst profileAvatarDisplay = document.getElementById(\"profileAvatarDisplay\");\nconst profileNameDisplay = document.getElementById(\"profileNameDisplay\");\nconst entryOverlay = document.getElementById(\"entryOverlay\");\nconst entryTitle = document.getElementById(\"entryTitle\");\nconst entrySub = document.getElementById(\"entrySub\");\nconst entryAvatarPreview = document.getElementById(\"entryAvatarPreview\");\nconst entryAvatarFile = document.getElementById(\"entryAvatarFile\");\nconst entryNameInput = document.getElementById(\"entryNameInput\");\nconst entryCancelBtn = document.getElementById(\"entryCancelBtn\");\nconst entrySubmitBtn = document.getElementById(\"entrySubmitBtn\");\n\nroomLabel.textContent = \"#\" + room;\n\nlet lastId = 0; let lastUpdateSeen = 0; let firstLoad = true; let sending = false;\nlet lastRenderedDateStr = \"\";\nlet replyingTo = null;\nlet onlineUsers = [];\nconst knownNames = new Set();\nconst msgIndex = new Map();\nconst messageData = new Map();\n\nconst AVATAR_COLORS = [\"#2f7cf6\", \"#5856d6\", \"#34c759\", \"#ff9500\", \"#ff2d55\", \"#00b8d9\", \"#af52de\", \"#8a8a92\"];\nfunction colorForKey(key) {\n let hash = 0;\n 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) {\n if (avatarUrl) return ' $\"avatar\"$ ';\n const trimmed = (name || \"\").trim();\n const letter = escapeHtml(trimmed ? trimmed.charAt(0).toUpperCase() : \"?\");\n const color = colorForKey(colorKey || name || \"?\");\n return '

' + letter + \"

\";\n}\n\nfunction loadProfile() {\n const name = localStorage.getItem(\"chatName\");\n if (!name) return null;\n const avatar = localStorage.getItem(\"chatAvatar\") || \"\";\n return { name, avatar };\n}\nfunction saveProfileToStorage(name, avatar) {\n localStorage.setItem(\"chatName\", name);\n if (avatar) { localStorage.setItem(\"chatAvatar\", avatar); } else { localStorage.removeItem(\"chatAvatar\"); }\n}\nlet currentProfile = loadProfile();\nfunction getDisplayName() { return (currentProfile && currentProfile.name) || \"名無し\"; }\nfunction getAvatarUrl() { return (currentProfile && currentProfile.avatar) || \"\"; }\nfunction renderProfileBar() {\n profileAvatarDisplay.innerHTML = buildAvatarHtml(getDisplayName(), getAvatarUrl(), myUserId);\n profileNameDisplay.textContent = getDisplayName();\n}\n\nlet entryDraftAvatar = \"\";\nlet appStarted = false;\n\nfunction updateEntryAvatarPreview() {\n if (entryDraftAvatar) {\n entryAvatarPreview.innerHTML = ' $\"avatar$ ';\n return;\n }\n const v = (entryNameInput.value || \"\").trim();\n entryAvatarPreview.innerHTML = v ? escapeHtml(v.charAt(0).toUpperCase()) : \"＋\";\n}\n\nfunction openEntryOverlay(editMode) {\n entryDraftAvatar = editMode ? getAvatarUrl() : \"\";\n entryNameInput.value = editMode ? getDisplayName() : \"\";\n entryAvatarFile.value = \"\";\n updateEntryAvatarPreview();\n entryTitle.textContent = editMode ? \"プロフィール設定\" : \"ようこそ\";\n entrySub.textContent = editMode ? \"名前とアイコンを変更できます\" : \"名前とアイコンを設定して入室してください\";\n entrySubmitBtn.textContent = editMode ? \"保存\" : \"入室する\";\n entryCancelBtn.style.display = editMode ? \"inline-block\" : \"none\";\n entryOverlay.classList.add(\"show\");\n entryNameInput.focus();\n}\nfunction closeEntryOverlay() { entryOverlay.classList.remove(\"show\"); }\n\nentryNameInput.addEventListener(\"input\", updateEntryAvatarPreview);\nentryAvatarFile.addEventListener(\"change\", () => {\n const file = entryAvatarFile.files[0];\n if (!file) return;\n const reader = new FileReader();\n reader.onload = () => { entryDraftAvatar = reader.result; updateEntryAvatarPreview(); };\n reader.readAsDataURL(file);\n});\nentryCancelBtn.addEventListener(\"click\", () => { closeEntryOverlay(); });\nentrySubmitBtn.addEventListener(\"click\", () => {\n const name = entryNameInput.value.trim();\n if (!name) { alert(\"名前を入力してください\"); entryNameInput.focus(); return; }\n saveProfileToStorage(name, entryDraftAvatar);\n currentProfile = { name, avatar: entryDraftAvatar };\n renderProfileBar();\n closeEntryOverlay();\n if (!appStarted) { startApp(); }\n});\nprofileBar.addEventListener(\"click\", () => { openEntryOverlay(true); });\n\nfunction startApp() {\n appStarted = true;\n setupPushNotifications();\n poll();\n setInterval(poll, 1500);\n}\n\nfunction clearImagePreview() {\n fileInput.value = \"\";\n fileLabel.classList.remove(\"has-file\");\n imagePreviewBar.classList.remove(\"show\");\n imagePreviewThumb.src = \"\";\n}\nfileInput.addEventListener(\"change\", () => {\n const file = fileInput.files[0];\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});\nipCancel.addEventListener(\"click\", () => { clearImagePreview(); });\ninvite.addEventListener(\"click\", async (e) => {\n e.stopPropagation();\n try {\n await navigator.clipboard.writeText(location.href); invite.textContent = \"コピーしました！\";\n setTimeout(() => { invite.textContent = \"招待リンクをコピー\"; }, 1800);\n } catch (err) { console.error(err); }\n});\n\nfunction fmtTime(ts) { const d = new Date(ts); return d.getHours().toString().padStart(2, \"0\") + \":\" + d.getMinutes().toString().padStart(2, \"0\"); }\nfunction fmtDate(ts) {\n const d = new Date(ts);\n const days = [\"日\", \"月\", \"火\", \"水\", \"木\", \"金\", \"土\"];\n return (d.getMonth() + 1) + \"月\" + d.getDate() + \"日(\" + days[d.getDay()] + \")\";\n}\nfunction escapeHtml(s) { if (!s) return \"\"; return s.replace(/[&<>\"']/g, (c) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\", \"'\": \"'\" }[c])); }\nfunction truncateText(s, n) { if (!s) return \"\"; return s.length > n ? s.slice(0, n) + \"…\" : s; }\nfunction linkifyMentions(escapedBody) {\n return escapedBody.replace(/(^|[\\\\s\\\\u3000])@([^\\\\s\\\\u3000@]+)/g, (match, prefix, name) => prefix + '@' + name + \"\");\n}\nfunction fileToBase64(file) { return new Promise((resolve, reject) => { const reader = new FileReader(); reader.readAsDataURL(file); reader.onload = () => resolve(reader.result); reader.onerror = (error) => reject(error); }); }\n\nfunction signatureOf(m) {\n return JSON.stringify({ body: m.body, deleted: m.deleted, edited_at: m.edited_at, poll: m.poll, avatar_url: m.avatar_url });\n}\n\nfunction buildTimeLabel(m) {\n const editedLabel = m.edited_at && !m.deleted ? '編集済み' : \"\";\n return fmtTime(m.created_at) + editedLabel;\n}\n\nfunction buildActionsRow(m, mine) {\n if (m.deleted) return \"\";\n let actions = '返信';\n if (mine) {\n actions += '編集';\n actions += '削除';\n }\n return actions;\n}\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) + '

' +\n '

' + optsHtml + '

' +\n '

計 ' + total + '票

';\n}\n\nfunction buildBubbleInner(m) {\n if (m.deleted) return '

このメッセージは削除されました

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

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

\";\n }\n let imgHtml = \"\";\n if (m.image_url) imgHtml = ' $\"uploaded$ ';\n const bodyHtml = m.poll ? buildPollHtml(m) : linkifyMentions(escapeHtml(m.body));\n return '

' + replyHtml + bodyHtml + imgHtml + '

';\n}\n\nfunction createMessageElement(m) {\n const mine = m.user_id === myUserId;\n const wrap = document.createElement(\"div\");\n wrap.className = \"msg \" + (mine ? \"me\" : \"them\");\n wrap.dataset.id = m.id;\n\n const nameLabel = document.createElement(\"div\"); nameLabel.className = \"msg-name\";\n const row = document.createElement(\"div\"); row.className = \"msg-row\";\n const avatarSlot = document.createElement(\"div\"); avatarSlot.className = \"msg-avatar-slot\";\n const bubbleContainer = document.createElement(\"div\"); bubbleContainer.className = \"bubble-container\";\n const timeLabel = document.createElement(\"div\"); timeLabel.className = \"msg-time\";\n const actionsRow = document.createElement(\"div\"); actionsRow.className = \"msg-actions\";\n row.appendChild(avatarSlot);\n row.appendChild(bubbleContainer);\n row.appendChild(timeLabel);\n wrap.appendChild(nameLabel);\n wrap.appendChild(row);\n wrap.appendChild(actionsRow);\n\n updateMessageElement(wrap, m);\n return wrap;\n}\n\nfunction updateMessageElement(wrap, m) {\n const mine = m.user_id === myUserId;\n wrap.querySelector(\".msg-name\").innerHTML = mine ? \"\" : escapeHtml(m.name);\n const avatarSlot = wrap.querySelector(\".msg-avatar-slot\");\n if (avatarSlot) avatarSlot.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}\n\nfunction isPartyMessage(m) { return m.body === \"🎉\"; }\n\nfunction triggerParty() {\n const colors = [\"#ffb454\", \"#ff7b5c\", \"#ffd9a0\", \"#f6ecda\", \"#ff9d6b\", \"#b6a6d9\"];\n for (let i = 0; i < 40; i++) {\n const el = document.createElement(\"div\");\n el.className = \"confetti-piece\";\n el.style.left = (Math.random() * 100) + \"vw\";\n el.style.background = colors[Math.floor(Math.random() * colors.length)];\n el.style.animationDuration = (2.5 + Math.random() * 1.5) + \"s\";\n el.style.animationDelay = (Math.random() * 0.3) + \"s\";\n document.body.appendChild(el);\n setTimeout(() => el.remove(), 4300);\n }\n}\n\nfunction renderSystemMessage(text) {\n const div = document.createElement(\"div\");\n div.className = \"date-divider system-msg\";\n div.textContent = text;\n messagesEl.appendChild(div);\n messagesEl.scrollTop = messagesEl.scrollHeight;\n}\n\nfunction isNearBottom() {\n return messagesEl.scrollHeight - messagesEl.scrollTop - messagesEl.clientHeight < 80;\n}\n\nfunction render(messages) {\n const wasNearBottom = firstLoad ? true : isNearBottom();\n if (firstLoad) { messagesEl.innerHTML = \"\"; firstLoad = false; }\n\n if (pendingOptimistic) {\n const match = messages.find((m) =>\n m.user_id === myUserId &&\n m.body === pendingOptimistic.body &&\n (m.image_url || \"\") === (pendingOptimistic.image_url || \"\") &&\n !msgIndex.has(m.id)\n );\n if (match) {\n if (pendingOptimistic.isParty) {\n msgIndex.set(match.id, { el: null, sig: \"party\" });\n } else if (pendingOptimistic.tempId != null) {\n const entry = msgIndex.get(pendingOptimistic.tempId);\n if (entry && entry.el) { entry.el.remove(); }\n msgIndex.delete(pendingOptimistic.tempId);\n messageData.delete(pendingOptimistic.tempId);\n }\n pendingOptimistic = null;\n }\n }\n\n for (const m of messages) {\n lastId = Math.max(lastId, m.id);\n if (m.updated_at) lastUpdateSeen = Math.max(lastUpdateSeen, m.updated_at);\n\n if (isPartyMessage(m) && !msgIndex.has(m.id)) {\n msgIndex.set(m.id, { el: null, sig: \"party\" });\n triggerParty();\n continue;\n }\n\n knownNames.add(m.name);\n messageData.set(m.id, m);\n\n const sig = signatureOf(m);\n const existing = msgIndex.get(m.id);\n\n if (existing) {\n if (existing.sig !== sig && existing.el) {\n updateMessageElement(existing.el, m);\n existing.sig = sig;\n }\n continue;\n }\n\n const dateStr = fmtDate(m.created_at);\n if (dateStr !== lastRenderedDateStr) {\n const divider = document.createElement(\"div\");\n divider.className = \"date-divider\";\n divider.textContent = dateStr;\n messagesEl.appendChild(divider);\n lastRenderedDateStr = dateStr;\n }\n\n const el = createMessageElement(m);\n messagesEl.appendChild(el);\n msgIndex.set(m.id, { el, sig });\n }\n\n if (wasNearBottom) {\n messagesEl.scrollTop = messagesEl.scrollHeight;\n scrollBottomBtn.classList.remove(\"show\");\n } else {\n scrollBottomBtn.classList.add(\"show\");\n }\n}\n\nmessagesEl.addEventListener(\"scroll\", () => {\n if (isNearBottom()) { scrollBottomBtn.classList.remove(\"show\"); }\n});\nscrollBottomBtn.addEventListener(\"click\", () => {\n messagesEl.scrollTop = messagesEl.scrollHeight;\n scrollBottomBtn.classList.remove(\"show\");\n});\n\nmessagesEl.addEventListener(\"click\", (e) => {\n const replyBtn = e.target.closest(\".reply-btn\");\n if (replyBtn) { replyingTo = { id: replyBtn.dataset.id, name: replyBtn.dataset.name, body: replyBtn.dataset.body }; showReplyPreview(); return; }\n const editBtn = e.target.closest(\".edit-btn\");\n if (editBtn) { startEdit(editBtn.dataset.id); return; }\n const deleteBtn = e.target.closest(\".delete-btn\");\n if (deleteBtn) { handleDelete(deleteBtn.dataset.id); 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});\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);\n const m = messageData.get(id);\n if (!m || m.deleted) return;\n const entry = msgIndex.get(id);\n if (!entry) return;\n\n const bubbleContainer = entry.el.querySelector(\".bubble-container\");\n const original = m.body;\n\n bubbleContainer.innerHTML =\n '

' +\n '

保存キャンセル

';\n\n const input = bubbleContainer.querySelector(\".edit-input\");\n input.focus();\n input.setSelectionRange(input.value.length, input.value.length);\n\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}\n\nasync function submitEdit(id, newBody) {\n const trimmed = newBody.trim();\n if (!trimmed) return;\n try {\n const res = await fetch(\"/api/edit\", {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ id, user_id: myUserId, body: trimmed }),\n });\n const data = await res.json();\n if (!data.success) { alert(\"編集に失敗しました: \" + (data.error || \"unknown\")); return; }\n await poll();\n } catch (err) { console.error(err); }\n}\n\nasync function handleDelete(idStr) {\n const id = Number(idStr);\n if (!confirm(\"このメッセージを削除しますか？\")) return;\n try {\n const res = await fetch(\"/api/delete\", {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ id, user_id: myUserId }),\n });\n const data = await res.json();\n if (!data.success) { alert(\"削除に失敗しました: \" + (data.error || \"unknown\")); return; }\n await poll();\n } catch (err) { console.error(err); }\n}\n\nasync function handleVote(pollIdStr, messageIdStr, optionStr) {\n try {\n await fetch(\"/api/poll/vote\", {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n poll_id: Number(pollIdStr), message_id: Number(messageIdStr),\n user_id: myUserId, option_index: Number(optionStr),\n }),\n });\n await poll();\n } catch (err) { console.error(err); }\n}\n\nbodyInput.addEventListener(\"input\", () => {\n const val = bodyInput.value;\n const caret = bodyInput.selectionStart;\n const uptoCaret = val.slice(0, caret);\n const match = uptoCaret.match(/(^|[\\\\s\\\\u3000])@([^\\\\s\\\\u3000@]*)$/);\n if (match) {\n const query = match[2].toLowerCase();\n 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); });\n\nfunction autoGrowBody() {\n bodyInput.style.height = \"auto\";\n bodyInput.style.height = Math.min(bodyInput.scrollHeight, 120) + \"px\";\n}\nbodyInput.addEventListener(\"input\", autoGrowBody);\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});\n\nbodyInput.addEventListener(\"focus\", () => {\n setAppHeightVar();\n setTimeout(() => { bodyInput.scrollIntoView({ block: \"end\", behavior: \"smooth\" }); }, 300);\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) {\n const val = bodyInput.value; const caret = bodyInput.selectionStart;\n const uptoCaret = val.slice(0, caret);\n const replaced = uptoCaret.replace(/@([^\\\\s\\\\u3000@]*)$/, \"@\" + name + \" \");\n bodyInput.value = replaced + val.slice(caret);\n hideMentionList(); bodyInput.focus();\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;\n 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 === \"/party\") return { type: \"party\" };\n if (trimmed.toLowerCase() === \"/profile\") return { type: \"profile\" };\n return null;\n}\n\nasync function sendRollCommand(max) {\n const safeMax = max > 0 ? max : 6;\n const result = Math.floor(Math.random() * safeMax) + 1;\n const text = \"🎲 \" + getDisplayName() + \" のダイス: \" + result + \" (1〜\" + safeMax + \")\";\n clearImagePreview();\n await sendNormalMessage(text, null);\n}\n\nasync function sendPollCommand(raw) {\n const parts = raw.split(\"|\").map((s) => s.trim()).filter((s) => s.length > 0);\n if (parts.length < 3) {\n alert(\"使い方: /poll 質問|選択肢1|選択肢2|選択肢3\\\\n(「|」で区切ってください。選択肢は2つ以上)\");\n return;\n }\n const question = parts[0]; const options = parts.slice(1);\n sending = true; bodyInput.disabled = true;\n try {\n await fetch(\"/api/poll/create\", {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ room, user_id: myUserId, name: getDisplayName(), avatar_url: getAvatarUrl(), question, options }),\n });\n bodyInput.value = \"\"; autoGrowBody(); clearImagePreview();\n await poll();\n } catch (err) { console.error(err); } finally { bodyInput.disabled = false; bodyInput.focus(); sending = false; }\n}\n\nasync function sendWhoCommand() {\n bodyInput.value = \"\"; autoGrowBody();\n sending = true; bodyInput.disabled = true;\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); } finally { bodyInput.disabled = false; bodyInput.focus(); sending = false; }\n}\n\nasync function sendPartyCommand() {\n clearImagePreview();\n await sendNormalMessage(\"🎉\", null);\n}\n\nlet tempIdCounter = 0;\nlet pendingOptimistic = null;\n\nfunction appendMessageElementToDOM(m) {\n if (firstLoad) { messagesEl.innerHTML = \"\"; firstLoad = false; }\n const dateStr = fmtDate(m.created_at);\n if (dateStr !== lastRenderedDateStr) {\n const divider = document.createElement(\"div\");\n divider.className = \"date-divider\";\n divider.textContent = dateStr;\n messagesEl.appendChild(divider);\n lastRenderedDateStr = dateStr;\n }\n const el = createMessageElement(m);\n messagesEl.appendChild(el);\n msgIndex.set(m.id, { el, sig: signatureOf(m) });\n messageData.set(m.id, m);\n return el;\n}\n\nasync function sendNormalMessage(body, file) {\n sending = true; bodyInput.disabled = true;\n const currentReply = replyingTo;\n try {\n let imageUrl = \"\"; if (file) imageUrl = await fileToBase64(file);\n const isPartyBody = body === \"🎉\";\n\n let tempId = null;\n if (isPartyBody) {\n triggerParty();\n } else {\n tempId = --tempIdCounter;\n const nowTs = Date.now();\n const optimisticMsg = {\n id: tempId, user_id: myUserId, name: getDisplayName(), 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: getAvatarUrl(),\n };\n knownNames.add(optimisticMsg.name);\n appendMessageElementToDOM(optimisticMsg);\n messagesEl.scrollTop = messagesEl.scrollHeight;\n scrollBottomBtn.classList.remove(\"show\");\n }\n pendingOptimistic = { tempId, body, image_url: imageUrl, isParty: isPartyBody };\n\n bodyInput.value = \"\"; autoGrowBody(); clearImagePreview();\n replyingTo = null; showReplyPreview();\n\n await fetch(\"/api/send\", {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n room, user_id: myUserId, name: getDisplayName(), body, image_url: imageUrl,\n avatar_url: getAvatarUrl(),\n reply_to_id: currentReply ? currentReply.id : null,\n reply_to_name: currentReply ? currentReply.name : null,\n reply_to_body: currentReply ? currentReply.body : null,\n }),\n });\n await poll();\n } catch (err) {\n console.error(err);\n if (pendingOptimistic) {\n if (!pendingOptimistic.isParty && pendingOptimistic.tempId != null) {\n const entry = msgIndex.get(pendingOptimistic.tempId);\n if (entry && entry.el) { entry.el.remove(); }\n msgIndex.delete(pendingOptimistic.tempId);\n messageData.delete(pendingOptimistic.tempId);\n }\n if (!pendingOptimistic.isParty) { bodyInput.value = body; autoGrowBody(); }\n pendingOptimistic = null;\n }\n } finally { bodyInput.disabled = false; bodyInput.focus(); sending = false; }\n}\n\nasync function poll() {\n try {\n const res = await fetch(\n \"/api/messages?room=\" + encodeURIComponent(room) +\n \"&since=\" + lastId + \"&sinceUpdate=\" + lastUpdateSeen +\n \"&viewer=\" + encodeURIComponent(myUserId) +\n \"&name=\" + encodeURIComponent(getDisplayName()),\n );\n const data = await res.json();\n if (data.online) { onlineUsers = data.online; }\n if (data.messages && data.messages.length) { render(data.messages); }\n } catch (err) { console.error(err); }\n}\n\ncomposer.addEventListener(\"submit\", async (e) => {\n e.preventDefault(); if (sending) return;\n const trimmed = bodyInput.value.trim(); const file = fileInput.files[0];\n if (!trimmed && !file) return;\n\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 === \"party\") { await sendPartyCommand(); return; }\n if (cmd && cmd.type === \"profile\") { bodyInput.value = \"\"; autoGrowBody(); openEntryOverlay(true); return; }\n\n await sendNormalMessage(trimmed, file);\n});\n\n// --- 起動処理 ---\nrenderProfileBar();\nif (currentProfile) {\n startApp();\n} else {\n openEntryOverlay(false);\n}\n`;","import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport webpush from \"https://esm.sh/web-push@3.6.7\";\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\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE} (id INTEGER PRIMARY KEY AUTOINCREMENT, room TEXT NOT NULL, user_id TEXT NOT NULL, name TEXT NOT NULL, body TEXT NOT NULL, image_url TEXT, created_at INTEGER NOT NULL)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${POLLS_TABLE} (id INTEGER PRIMARY KEY AUTOINCREMENT, room TEXT NOT NULL, question TEXT NOT NULL, options TEXT NOT NULL, votes TEXT NOT NULL DEFAULT '{}', created_at INTEGER NOT NULL)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${PRESENCE_TABLE} (room TEXT NOT NULL, user_id TEXT NOT NULL, name TEXT NOT NULL, last_seen INTEGER NOT NULL, PRIMARY KEY (room, user_id))`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${PUSH_SUB_TABLE} (user_id TEXT NOT NULL, room TEXT NOT NULL, subscription TEXT NOT NULL, PRIMARY KEY (user_id, room))`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS vapid_keys (id INTEGER PRIMARY KEY CHECK (id = 1), public_key TEXT NOT NULL, private_key TEXT NOT NULL)`);\n\nlet vapidKeys = { publicKey: \"\", privateKey: \"\" };\nconst vapidResult = await sqlite.execute(\"SELECT public_key, private_key FROM vapid_keys WHERE id = 1\");\nif (vapidResult.rows && (vapidResult.rows as any[]).length > 0) {\n const row = (vapidResult.rows as any[])[0];\n vapidKeys = { publicKey: String(row[0] ?? row.public_key), privateKey: String(row[1] ?? row.private_key) };\n} else {\n const keys = webpush.generateVAPIDKeys();\n vapidKeys = { publicKey: keys.publicKey, privateKey: keys.privateKey };\n await sqlite.execute({ sql: \"INSERT INTO vapid_keys (id, public_key, private_key) VALUES (1, ?, ?)\", args: [vapidKeys.publicKey, vapidKeys.privateKey] });\n}\nwebpush.setVapidDetails(\"mailto:admin@example.com\", vapidKeys.publicKey, vapidKeys.privateKey);\n\nasync function ensureColumn(c: string, t: string) { try { await sqlite.execute(`ALTER TABLE ${TABLE} ADD COLUMN ${c} ${t}`); } catch {} }\nawait ensureColumn(\"reply_to_id\", \"INTEGER\");\nawait ensureColumn(\"reply_to_name\", \"TEXT\");\nawait ensureColumn(\"reply_to_body\", \"TEXT\");\nawait ensureColumn(\"edited_at\", \"INTEGER\");\nawait ensureColumn(\"deleted\", \"INTEGER DEFAULT 0\");\nawait ensureColumn(\"updated_at\", \"INTEGER\");\nawait ensureColumn(\"poll_id\", \"INTEGER\");\nawait ensureColumn(\"avatar_url\", \"TEXT\");\nawait sqlite.execute(`UPDATE ${TABLE} SET updated_at = created_at WHERE updated_at IS NULL`);\nconst ONLINE_WINDOW_MS = 8000;\n\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 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(clients.matchAll({ type: 'window', includeUncontrolled: true }).then(function(list) {\n for (const c of list) { if (c.url.includes(targetUrl) && 'focus' in c) return c.focus(); }\n if (clients.openWindow) return clients.openWindow(targetUrl);\n }));\n});\n`;\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n if (url.pathname === \"/sw.js\") return new Response(swJsContent, { headers: { \"Content-Type\": \"application/javascript; charset=utf-8\", \"Cache-Control\": \"no-cache\" } });\n if (url.pathname === \"/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 new Response(JSON.stringify({ error: \"invalid data\" }), { status: 400 });\n await sqlite.execute({ sql: `INSERT INTO ${PUSH_SUB_TABLE} (user_id, room, subscription) VALUES (?, ?, ?) ON CONFLICT(user_id, room) DO UPDATE SET subscription = excluded.subscription`, args: [user_id, room, JSON.stringify(subscription)] });\n return new Response(JSON.stringify({ success: true }));\n } catch (err) { return new Response(JSON.stringify({ error: String(err) }), { status: 400 }); }\n }\n if (url.pathname === \"/api/vapid-public-key\") return new Response(JSON.stringify({ publicKey: vapidKeys.publicKey }), { headers: { \"Content-Type\": \"application/json\" } });\n if (url.pathname === \"/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 if (viewer) {\n const now = Date.now();\n await sqlite.execute({ sql: `INSERT INTO ${PRESENCE_TABLE} (room, user_id, name, last_seen) VALUES (?, ?, ?, ?) ON CONFLICT(room, user_id) DO UPDATE SET name = excluded.name, last_seen = excluded.last_seen`, args: [room, viewer, viewerName || \"名無し\", now] });\n }\n const result = await sqlite.execute({ sql: `SELECT id, user_id, name, body, image_url, reply_to_id, reply_to_name, reply_to_body, edited_at, deleted, updated_at, poll_id, created_at, avatar_url FROM ${TABLE} WHERE room = ? AND (id > ? OR updated_at > ?) ORDER BY id ASC`, args: [room, since, sinceUpdate] });\n const rawMessages = (result.rows as any[]).map((row) => ({\n id: Number(row[0] ?? row.id), user_id: String(row[1] ?? row.user_id), name: String(row[2] ?? row.name), body: String(row[3] ?? row.body), image_url: (row[4] ?? row.image_url) ? String(row[4] ?? row.image_url) : \"\", reply_to_id: (row[5] ?? row.reply_to_id) != null ? Number(row[5] ?? row.reply_to_id) : null, reply_to_name: (row[6] ?? row.reply_to_name) != null ? String(row[6] ?? row.reply_to_name) : null, reply_to_body: (row[7] ?? row.reply_to_body) != null ? String(row[7] ?? row.reply_to_body) : null, edited_at: (row[8] ?? row.edited_at) != null ? Number(row[8] ?? row.edited_at) : null, deleted: Number(row[9] ?? row.deleted ?? 0) === 1, updated_at: Number(row[10] ?? row.updated_at ?? row[12] ?? row.created_at), poll_id: (row[11] ?? row.poll_id) != null ? Number(row[11] ?? row.poll_id) : null, created_at: Number(row[12] ?? row.created_at), avatar_url: (row[13] ?? row.avatar_url) ? String(row[13] ?? row.avatar_url) : \"\",\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({ sql: `SELECT id, question, options, votes FROM ${POLLS_TABLE} WHERE id IN (${placeholders})`, args: pollIds });\n for (const prow of pollResult.rows as any[]) {\n const pid = Number(prow[0] ?? prow.id); const question = String(prow[1] ?? prow.question); const options: string[] = JSON.parse(String(prow[2] ?? prow.options)); const votes: Record = JSON.parse(String(prow[3] ?? prow.votes) || \"{}\"); const tally = options.map((text, idx) => ({ text, count: Object.values(votes).filter((v) => v === idx).length })); const total = Object.keys(votes).length; const myVote = viewer && Object.prototype.hasOwnProperty.call(votes, viewer) ? votes[viewer] : null; pollMap[pid] = { id: pid, question, options: tally, total, myVote };\n }\n }\n const messages = rawMessages.map((m) => ({ ...m, poll: m.poll_id != null ? pollMap[m.poll_id] || null : null }));\n const onlineResult = await sqlite.execute({ sql: `SELECT user_id, name FROM ${PRESENCE_TABLE} WHERE room = ? AND last_seen > ? ORDER BY name ASC`, args: [room, Date.now() - ONLINE_WINDOW_MS] });\n const online = (onlineResult.rows as any[]).map((row) => ({ user_id: String(row[0] ?? row.user_id), name: String(row[1] ?? row.name) }));\n return new Response(JSON.stringify({ messages, online }), { headers: { \"Content-Type\": \"application/json\" } });\n }\n if (url.pathname === \"/api/send\" && req.method === \"POST\") {\n try {\n const data = await req.json();\n const room = data.room || \"lobby\"; const user_id = data.user_id || \"unknown\"; const name = data.name || \"名無し\"; const body = data.body || \"\"; const image_url = data.image_url || \"\"; const avatar_url = data.avatar_url || \"\"; const reply_to_id = data.reply_to_id ? Number(data.reply_to_id) : null; const reply_to_name = data.reply_to_name || null; const reply_to_body = data.reply_to_body || null; const created_at = Date.now();\n await sqlite.execute({ 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) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`, args: [room, user_id, name, body, image_url, avatar_url, reply_to_id, reply_to_name, reply_to_body, created_at, created_at] });\n const subsResult = await sqlite.execute({ sql: `SELECT subscription FROM ${PUSH_SUB_TABLE} WHERE room = ? AND user_id != ?`, args: [room, user_id] });\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({ title: name + \" (#\" + room + \")\", body: body.length > 100 ? body.substring(0, 100) + \"…\" : body, tag: `msg-${room}`, icon: avatar_url || undefined, url: roomUrl, room: room });\n webpush.sendNotification(sub, payload).catch((err: any) => { if (err.statusCode === 410 || err.statusCode === 404) { sqlite.execute({ sql: `DELETE FROM ${PUSH_SUB_TABLE} WHERE subscription = ?`, args: [String(row[0] ?? row.subscription)] }).catch(() => {}); } });\n } catch {}\n }\n return new Response(JSON.stringify({ success: true }), { headers: { \"Content-Type\": \"application/json\" } });\n } catch (err) { return new Response(JSON.stringify({ error: String(err) }), { status: 400, headers: { \"Content-Type\": \"application/json\" } }); }\n }\n if (url.pathname === \"/api/edit\" && req.method === \"POST\") {\n try { const data = await req.json(); const id = Number(data.id); const user_id = data.user_id || \"\"; const body = (data.body || \"\").trim(); if (!id || !body) return new Response(JSON.stringify({ error: \"invalid request\" }), { status: 400 }); const check = await sqlite.execute({ sql: `SELECT user_id, deleted FROM ${TABLE} WHERE id = ?`, args: [id] }); const row = (check.rows as any[])[0]; if (!row) return new Response(JSON.stringify({ error: \"not found\" }), { status: 404 }); if (String(row[0] ?? row.user_id) !== user_id) return new Response(JSON.stringify({ error: \"forbidden\" }), { status: 403 }); if (Number(row[1] ?? row.deleted ?? 0) === 1) return new Response(JSON.stringify({ error: \"already deleted\" }), { status: 400 }); const now = Date.now(); await sqlite.execute({ sql: `UPDATE ${TABLE} SET body = ?, edited_at = ?, updated_at = ? WHERE id = ?`, args: [body, now, now, id] }); return new Response(JSON.stringify({ success: true }), { headers: { \"Content-Type\": \"application/json\" } }); } catch (err) { return new Response(JSON.stringify({ error: String(err) }), { status: 400 }); }\n }\n if (url.pathname === \"/api/delete\" && req.method === \"POST\") {\n try { const data = await req.json(); const id = Number(data.id); const user_id = data.user_id || \"\"; const check = await sqlite.execute({ sql: `SELECT user_id FROM ${TABLE} WHERE id = ?`, args: [id] }); const row = (check.rows as any[])[0]; if (!row) return new Response(JSON.stringify({ error: \"not found\" }), { status: 404 }); if (String(row[0] ?? row.user_id) !== user_id) return new Response(JSON.stringify({ error: \"forbidden\" }), { status: 403 }); const now = Date.now(); await sqlite.execute({ sql: `UPDATE ${TABLE} SET deleted = 1, updated_at = ? WHERE id = ?`, args: [now, id] }); return new Response(JSON.stringify({ success: true }), { headers: { \"Content-Type\": \"application/json\" } }); } catch (err) { return new Response(JSON.stringify({ error: String(err) }), { status: 400 }); }\n }\n if (url.pathname === \"/api/poll/create\" && req.method === \"POST\") {\n try { const data = await req.json(); const room = data.room || \"lobby\"; const user_id = data.user_id || \"unknown\"; const name = data.name || \"名無し\"; const avatar_url = data.avatar_url || \"\"; const question = (data.question || \"\").trim(); const options: string[] = Array.isArray(data.options) ? data.options.map((o: string) => String(o).trim()).filter((o: string) => o.length > 0) : []; if (!question || options.length < 2) return new Response(JSON.stringify({ error: \"invalid poll\" }), { status: 400 }); const created_at = Date.now(); const pollInsert = await sqlite.execute({ sql: `INSERT INTO ${POLLS_TABLE} (room, question, options, votes, created_at) VALUES (?, ?, ?, '{}', ?)`, args: [room, question, JSON.stringify(options), created_at] }); const pollId = Number(pollInsert.lastInsertRowid); await sqlite.execute({ sql: `INSERT INTO ${TABLE} (room, user_id, name, body, avatar_url, poll_id, updated_at, created_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?)`, args: [room, user_id, name, \"投票 \" + question, avatar_url, pollId, created_at, created_at] }); return new Response(JSON.stringify({ success: true }), { headers: { \"Content-Type\": \"application/json\" } }); } catch (err) { return new Response(JSON.stringify({ error: String(err) }), { status: 400 }); }\n }\n if (url.pathname === \"/api/poll/vote\" && req.method === \"POST\") {\n try { const data = await req.json(); const pollId = Number(data.poll_id); const messageId = Number(data.message_id); const user_id = data.user_id || \"\"; const optionIndex = Number(data.option_index); if (!pollId || !user_id || Number.isNaN(optionIndex)) return new Response(JSON.stringify({ error: \"invalid vote\" }), { status: 400 }); const pollRow = await sqlite.execute({ sql: `SELECT options, votes FROM ${POLLS_TABLE} WHERE id = ?`, args: [pollId] }); const prow = (pollRow.rows as any[])[0]; if (!prow) return new Response(JSON.stringify({ error: \"poll not found\" }), { status: 404 }); const options: string[] = JSON.parse(String(prow[0] ?? prow.options)); if (optionIndex < 0 || optionIndex >= options.length) return new Response(JSON.stringify({ error: \"invalid option\" }), { status: 400 }); const votes: Record = JSON.parse(String(prow[1] ?? prow.votes) || \"{}\"); votes[user_id] = optionIndex; await sqlite.execute({ sql: `UPDATE ${POLLS_TABLE} SET votes = ? WHERE id = ?`, args: [JSON.stringify(votes), pollId] }); if (messageId) await sqlite.execute({ sql: `UPDATE ${TABLE} SET updated_at = ? WHERE id = ?`, args: [Date.now(), messageId] }); return new Response(JSON.stringify({ success: true }), { headers: { \"Content-Type\": \"application/json\" } }); } catch (err) { return new Response(JSON.stringify({ error: String(err) }), { status: 400 }); }\n }\n if (url.pathname === \"/\" || url.pathname === \"/index.html\") return new Response(htmlContent, { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } });\n if (url.pathname === \"/client.js\") return new Response(jsContent, { headers: { \"Content-Type\": \"application/javascript; charset=utf-8\" } });\n return new Response(\"Not Found\", { status: 404 });\n}\n\nconst htmlContent = `\n\n\n\n\nリアルタイムチャット\n\n\n\n\n

あああ

#lobby

\n🔔 タブを閉じても通知を受け取るには有効化が必要です\n\n

(タップで編集)招待リンクをコピー

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

\n\n

ようこそ

名前とアイコンを設定して入室してください

＋

\n\n\n`;\n\nconst jsContent = `\nasync function setupPushNotifications() {\n const notifBar = document.getElementById('notifBar');\n const enableBtn = document.getElementById('enableNotifBtn');\n console.log('[Push] setup start', 'SW' in navigator, 'PushManager' in window, 'Notification' in window);\n \n if (!('serviceWorker' in navigator) || !('PushManager' in window) || !('Notification' in window)) {\n console.log('[Push] not supported');\n if (notifBar) notifBar.innerHTML = '⚠️ このブラウザはバックグラウンド通知に非対応です';\n return;\n }\n\n // 初期状態は必ずバーを表示（許可済みなら後で消す）\n if (notifBar) notifBar.classList.remove('hide');\n\n function updateUI() {\n console.log('[Push] permission:', Notification.permission);\n if (Notification.permission === 'granted') {\n if (notifBar) notifBar.classList.add('hide');\n } else if (Notification.permission === 'denied') {\n if (notifBar) notifBar.innerHTML = '🔕 通知がブロックされています。ブラウザの設定から許可してください';\n } else {\n if (notifBar) {\n notifBar.classList.remove('hide');\n // 初期HTMLを復元（deniedで上書きされた場合）\n if (!document.getElementById('enableNotifBtn')) {\n notifBar.innerHTML = '🔔 タブを閉じても通知を受け取るには有効化が必要です';\n document.getElementById('enableNotifBtn').addEventListener('click', subscribe);\n }\n }\n }\n }\n\n async function subscribe() {\n try {\n console.log('[Push] subscribe clicked');\n if (Notification.permission === 'default') {\n const perm = await Notification.requestPermission();\n console.log('[Push] requestPermission result:', perm);\n if (perm !== 'granted') { updateUI(); return; }\n }\n if (Notification.permission !== 'granted') { updateUI(); return; }\n\n console.log('[Push] registering /sw.js');\n const registration = await navigator.serviceWorker.register('/sw.js');\n console.log('[Push] SW registered', registration);\n\n const res = await fetch('/api/vapid-public-key');\n const data = await res.json();\n console.log('[Push] vapid key ok', !!data.publicKey);\n const convertedKey = urlBase64ToUint8Array(data.publicKey);\n\n let subscription = await registration.pushManager.getSubscription();\n if (!subscription) {\n console.log('[Push] creating new subscription');\n subscription = await registration.pushManager.subscribe({ userVisibleOnly: true, applicationServerKey: convertedKey });\n }\n console.log('[Push] subscription', subscription);\n\n const saveRes = await fetch('/api/subscribe', {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ user_id: myUserId, room: room, subscription: subscription })\n });\n console.log('[Push] save result', await saveRes.text());\n updateUI();\n alert('通知が有効になりました！タブを閉じても届きます');\n } catch (err) {\n console.error('[Push] subscribe failed', err);\n alert('通知の有効化に失敗: ' + err);\n }\n }\n\n if (enableBtn) enableBtn.addEventListener('click', subscribe);\n\n // 許可済みなら自動で再登録\n if (Notification.permission === 'granted') {\n try {\n const registration = await navigator.serviceWorker.register('/sw.js');\n const sub = await registration.pushManager.getSubscription();\n if (sub) {\n await fetch('/api/subscribe', {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ user_id: myUserId, room: room, subscription: sub })\n });\n console.log('[Push] auto re-subscribed');\n }\n updateUI();\n } catch (e) { console.error(e); }\n } else {\n updateUI();\n }\n}\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}\n\nfunction setAppHeightVar() { const h = (window.visualViewport && window.visualViewport.height) ? window.visualViewport.height : window.innerHeight; document.documentElement.style.setProperty(\"--app-height\", h + \"px\"); }\nsetAppHeightVar(); window.addEventListener(\"resize\", setAppHeightVar);\nfunction getRoom() { let room = location.hash.replace(/^#/, \"\"); if (!room) { room = Math.random().toString(36).slice(2, 8); location.hash = room; } return room; }\nfunction getUserId() { let id = localStorage.getItem(\"chatUserId\"); if (!id) { id = Math.random().toString(36).slice(2, 12) + Date.now().toString(36); localStorage.setItem(\"chatUserId\", id); } return id; }\nconst room = getRoom(); const myUserId = getUserId();\nconst messagesEl = document.getElementById(\"messages\"); const composer = document.getElementById(\"composer\");\nconst bodyInput = document.getElementById(\"body\"); const roomLabel = document.getElementById(\"roomLabel\"); const invite = document.getElementById(\"invite\");\nconst fileInput = document.getElementById(\"imageFile\"); const mentionList = document.getElementById(\"mentionList\");\nconst replyPreviewBar = document.getElementById(\"replyPreviewBar\"); const rpText = document.getElementById(\"rpText\"); const rpCancel = document.getElementById(\"rpCancel\");\nconst imagePreviewBar = document.getElementById(\"imagePreviewBar\"); const imagePreviewThumb = document.getElementById(\"imagePreviewThumb\"); const ipCancel = document.getElementById(\"ipCancel\");\nconst scrollBottomBtn = document.getElementById(\"scrollBottomBtn\"); const lightbox = document.getElementById(\"lightbox\"); const lightboxImg = document.getElementById(\"lightboxImg\");\nconst profileBar = document.getElementById(\"profileBar\"); const profileAvatarDisplay = document.getElementById(\"profileAvatarDisplay\"); const profileNameDisplay = document.getElementById(\"profileNameDisplay\");\nconst entryOverlay = document.getElementById(\"entryOverlay\"); const entryTitle = document.getElementById(\"entryTitle\"); const entrySub = document.getElementById(\"entrySub\"); const entryAvatarPreview = document.getElementById(\"entryAvatarPreview\"); const entryAvatarFile = document.getElementById(\"entryAvatarFile\"); const entryNameInput = document.getElementById(\"entryNameInput\"); const entryCancelBtn = document.getElementById(\"entryCancelBtn\"); const entrySubmitBtn = document.getElementById(\"entrySubmitBtn\");\nroomLabel.textContent = \"#\" + room;\nlet lastId = 0; let lastUpdateSeen = 0; let firstLoad = true; let sending = false; let lastRenderedDateStr = \"\"; let replyingTo = null; let onlineUsers = []; const knownNames = new Set(); const msgIndex = new Map(); const messageData = new Map();\nconst AVATAR_COLORS = [\"#2f7cf6\", \"#5856d6\", \"#34c759\", \"#ff9500\", \"#ff2d55\", \"#00b8d9\", \"#af52de\", \"#8a8a92\"];\nfunction colorForKey(key) { let h = 0; const s = String(key || \"?\"); for (let i = 0; i < s.length; i++) { h = (h * 31 + s.charCodeAt(i)) >>> 0; } return AVATAR_COLORS[h % AVATAR_COLORS.length]; }\nfunction buildAvatarHtml(name, avatarUrl, colorKey) { if (avatarUrl) return '

'; const t = (name || \"\").trim(); const l = escapeHtml(t ? t.charAt(0).toUpperCase() : \"?\"); const c = colorForKey(colorKey || name || \"?\"); return '

' + l + \"

\"; }\nfunction loadProfile() { const n = localStorage.getItem(\"chatName\"); if (!n) return null; return { name: n, avatar: localStorage.getItem(\"chatAvatar\") || \"\" }; }\nfunction saveProfileToStorage(name, avatar) { localStorage.setItem(\"chatName\", name); if (avatar) localStorage.setItem(\"chatAvatar\", avatar); else localStorage.removeItem(\"chatAvatar\"); }\nlet currentProfile = loadProfile();\nfunction getDisplayName() { return (currentProfile && currentProfile.name) || \"名無し\"; }\nfunction getAvatarUrl() { return (currentProfile && currentProfile.avatar) || \"\"; }\nfunction renderProfileBar() { profileAvatarDisplay.innerHTML = buildAvatarHtml(getDisplayName(), getAvatarUrl(), myUserId); profileNameDisplay.textContent = getDisplayName(); }\nlet entryDraftAvatar = \"\"; let appStarted = false;\nfunction updateEntryAvatarPreview() { if (entryDraftAvatar) { entryAvatarPreview.innerHTML = '

'; return; } const v = (entryNameInput.value || \"\").trim(); entryAvatarPreview.innerHTML = v ? escapeHtml(v.charAt(0).toUpperCase()) : \"＋\"; }\nfunction openEntryOverlay(editMode) { entryDraftAvatar = editMode ? getAvatarUrl() : \"\"; entryNameInput.value = editMode ? getDisplayName() : \"\"; entryAvatarFile.value = \"\"; updateEntryAvatarPreview(); entryTitle.textContent = editMode ? \"プロフィール設定\" : \"ようこそ\"; entrySub.textContent = editMode ? \"名前とアイコンを変更できます\" : \"名前とアイコンを設定して入室してください\"; entrySubmitBtn.textContent = editMode ? \"保存\" : \"入室する\"; entryCancelBtn.style.display = editMode ? \"inline-block\" : \"none\"; entryOverlay.classList.add(\"show\"); entryNameInput.focus(); }\nfunction closeEntryOverlay() { entryOverlay.classList.remove(\"show\"); }\nentryNameInput.addEventListener(\"input\", updateEntryAvatarPreview);\nentryAvatarFile.addEventListener(\"change\", () => { const f = entryAvatarFile.files[0]; if (!f) return; const r = new FileReader(); r.onload = () => { entryDraftAvatar = r.result; updateEntryAvatarPreview(); }; r.readAsDataURL(f); });\nentryCancelBtn.addEventListener(\"click\", () => closeEntryOverlay());\nentrySubmitBtn.addEventListener(\"click\", () => { const name = entryNameInput.value.trim(); if (!name) { alert(\"名前を入力してください\"); return; } saveProfileToStorage(name, entryDraftAvatar); currentProfile = { name, avatar: entryDraftAvatar }; renderProfileBar(); closeEntryOverlay(); if (!appStarted) startApp(); });\nprofileBar.addEventListener(\"click\", () => openEntryOverlay(true));\nfunction startApp() { appStarted = true; setupPushNotifications(); poll(); setInterval(poll, 1500); }\nfunction clearImagePreview() { fileInput.value = \"\"; imagePreviewBar.classList.remove(\"show\"); imagePreviewThumb.src = \"\"; }\nfileInput.addEventListener(\"change\", () => { const f = fileInput.files[0]; if (!f) { clearImagePreview(); return; } const r = new FileReader(); r.onload = () => { imagePreviewThumb.src = r.result; imagePreviewBar.classList.add(\"show\"); }; r.readAsDataURL(f); });\nipCancel.addEventListener(\"click\", () => clearImagePreview());\ninvite.addEventListener(\"click\", async (e) => { e.stopPropagation(); try { await navigator.clipboard.writeText(location.href); invite.textContent = \"コピーしました！\"; setTimeout(() => { invite.textContent = \"招待リンクをコピー\"; }, 1800); } catch {} });\nfunction fmtTime(ts) { const d = new Date(ts); return d.getHours().toString().padStart(2, \"0\") + \":\" + d.getMinutes().toString().padStart(2, \"0\"); }\nfunction fmtDate(ts) { const d = new Date(ts); const days = [\"日\",\"月\",\"火\",\"水\",\"木\",\"金\",\"土\"]; return (d.getMonth()+1)+\"月\"+d.getDate()+\"日(\"+days[d.getDay()]+\")\"; }\nfunction escapeHtml(s) { if (!s) return \"\"; return s.replace(/[&<>\"']/g, (c) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\", \"'\": \"'\" }[c])); }\nfunction truncateText(s, n) { if (!s) return \"\"; return s.length > n ? s.slice(0, n) + \"…\" : s; }\nfunction linkifyMentions(e) { return e.replace(/(^|[\\\\s\\\\u3000])@([^\\\\s\\\\u3000@]+)/g, (m,p,n) => p + '@' + n + \"\"); }\nfunction fileToBase64(file) { return new Promise((res, rej) => { const r = new FileReader(); r.readAsDataURL(file); r.onload = () => res(r.result); r.onerror = rej; }); }\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 }); }\nfunction buildTimeLabel(m) { const editedLabel = m.edited_at && !m.deleted ? '編集済み' : \"\"; return fmtTime(m.created_at) + editedLabel; }\nfunction buildActionsRow(m, mine) { if (m.deleted) return \"\"; let a = '返信'; if (mine) { a += '編集削除'; } return a; }\nfunction buildPollHtml(m) { const poll = m.poll; const total = poll.total || 0; const optsHtml = poll.options.map((opt, idx) => { const pct = total > 0 ? Math.round((opt.count / total) * 100) : 0; const mine = poll.myVote === idx; return ''; }).join(\"\"); return '

投票 ' + escapeHtml(poll.question) + '

' + optsHtml + '

計 ' + total + '票

'; }\nfunction buildBubbleInner(m) { if (m.deleted) return '

このメッセージは削除されました

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

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

\"; } let imgHtml = \"\"; if (m.image_url) imgHtml = '

'; const bodyHtml = m.poll ? buildPollHtml(m) : linkifyMentions(escapeHtml(m.body)); return '

' + replyHtml + bodyHtml + imgHtml + '

'; }\nfunction createMessageElement(m) { const mine = m.user_id === myUserId; const wrap = document.createElement(\"div\"); wrap.className = \"msg \" + (mine ? \"me\" : \"them\"); wrap.dataset.id = m.id; const nameLabel = document.createElement(\"div\"); nameLabel.className = \"msg-name\"; const row = document.createElement(\"div\"); row.className = \"msg-row\"; const avatarSlot = document.createElement(\"div\"); avatarSlot.className = \"msg-avatar-slot\"; const bubbleContainer = document.createElement(\"div\"); bubbleContainer.className = \"bubble-container\"; const timeLabel = document.createElement(\"div\"); timeLabel.className = \"msg-time\"; const actionsRow = document.createElement(\"div\"); actionsRow.className = \"msg-actions\"; row.appendChild(avatarSlot); row.appendChild(bubbleContainer); row.appendChild(timeLabel); wrap.appendChild(nameLabel); wrap.appendChild(row); wrap.appendChild(actionsRow); updateMessageElement(wrap, m); return wrap; }\nfunction updateMessageElement(wrap, m) { const mine = m.user_id === myUserId; wrap.querySelector(\".msg-name\").innerHTML = mine ? \"\" : escapeHtml(m.name); const avatarSlot = wrap.querySelector(\".msg-avatar-slot\"); if (avatarSlot) avatarSlot.innerHTML = mine ? \"\" : buildAvatarHtml(m.name, m.avatar_url, m.user_id); wrap.querySelector(\".bubble-container\").innerHTML = buildBubbleInner(m); wrap.querySelector(\".msg-time\").innerHTML = buildTimeLabel(m); wrap.querySelector(\".msg-actions\").innerHTML = buildActionsRow(m, mine); }\nfunction triggerParty() { const colors = [\"#ffb454\",\"#ff7b5c\",\"#ffd9a0\",\"#f6ecda\",\"#ff9d6b\",\"#b6a6d9\"]; for (let i=0;i<40;i++){ const el=document.createElement(\"div\"); el.className=\"confetti-piece\"; el.style.left=(Math.random()*100)+\"vw\"; el.style.background=colors[Math.floor(Math.random()*colors.length)]; el.style.animationDuration=(2.5+Math.random()*1.5)+\"s\"; el.style.animationDelay=(Math.random()*0.3)+\"s\"; document.body.appendChild(el); setTimeout(()=>el.remove(),4300);} }\nfunction renderSystemMessage(text) { const div=document.createElement(\"div\"); div.className=\"date-divider system-msg\"; div.textContent=text; messagesEl.appendChild(div); messagesEl.scrollTop=messagesEl.scrollHeight; }\nfunction isNearBottom() { return messagesEl.scrollHeight - messagesEl.scrollTop - messagesEl.clientHeight < 80; }\nfunction render(messages) {\n const wasNearBottom = firstLoad ? true : isNearBottom();\n if (firstLoad) { messagesEl.innerHTML = \"\"; firstLoad = false; }\n if (pendingOptimistic) {\n const match = messages.find((m) => m.user_id === myUserId && m.body === pendingOptimistic.body && (m.image_url||\"\") === (pendingOptimistic.image_url||\"\") && !msgIndex.has(m.id));\n if (match) { if (pendingOptimistic.isParty) { msgIndex.set(match.id, { el: null, sig: \"party\" }); } else if (pendingOptimistic.tempId != null) { const entry = msgIndex.get(pendingOptimistic.tempId); if (entry && entry.el) entry.el.remove(); msgIndex.delete(pendingOptimistic.tempId); messageData.delete(pendingOptimistic.tempId); } pendingOptimistic = null; }\n }\n for (const m of messages) {\n lastId = Math.max(lastId, m.id); if (m.updated_at) lastUpdateSeen = Math.max(lastUpdateSeen, m.updated_at);\n if (m.body === \"🎉\" && !msgIndex.has(m.id)) { msgIndex.set(m.id, { el: null, sig: \"party\" }); triggerParty(); continue; }\n knownNames.add(m.name); messageData.set(m.id, m);\n const sig = signatureOf(m); const existing = msgIndex.get(m.id);\n if (existing) { if (existing.sig !== sig && existing.el) { updateMessageElement(existing.el, m); existing.sig = sig; } continue; }\n const dateStr = fmtDate(m.created_at);\n if (dateStr !== lastRenderedDateStr) { const divider = document.createElement(\"div\"); divider.className=\"date-divider\"; divider.textContent=dateStr; messagesEl.appendChild(divider); lastRenderedDateStr=dateStr; }\n const el = createMessageElement(m); messagesEl.appendChild(el); msgIndex.set(m.id, { el, sig });\n }\n if (wasNearBottom) { messagesEl.scrollTop = messagesEl.scrollHeight; scrollBottomBtn.classList.remove(\"show\"); } else { scrollBottomBtn.classList.add(\"show\"); }\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\"); if (replyBtn) { replyingTo = { id: replyBtn.dataset.id, name: replyBtn.dataset.name, body: replyBtn.dataset.body }; showReplyPreview(); return; }\n const editBtn = e.target.closest(\".edit-btn\"); if (editBtn) { startEdit(editBtn.dataset.id); return; }\n const deleteBtn = e.target.closest(\".delete-btn\"); if (deleteBtn) { handleDelete(deleteBtn.dataset.id); return; }\n const pollOption = e.target.closest(\".poll-option\"); if (pollOption) { handleVote(pollOption.dataset.pollId, pollOption.dataset.messageId, pollOption.dataset.option); return; }\n const img = e.target.closest(\".msg-img\"); if (img) { openLightbox(img.dataset.full); return; }\n});\nfunction openLightbox(src) { lightboxImg.src = src; lightbox.classList.add(\"show\"); }\nfunction closeLightbox() { lightbox.classList.remove(\"show\"); lightboxImg.src = \"\"; }\nlightbox.addEventListener(\"click\", closeLightbox);\nfunction showReplyPreview() { if (!replyingTo) { replyPreviewBar.style.display = \"none\"; return; } rpText.textContent = replyingTo.name + \": \" + replyingTo.body; replyPreviewBar.style.display = \"flex\"; bodyInput.focus(); }\nrpCancel.addEventListener(\"click\", () => { replyingTo = null; showReplyPreview(); });\nfunction startEdit(idStr) { const id = Number(idStr); const m = messageData.get(id); if (!m || m.deleted) return; const entry = msgIndex.get(id); if (!entry) return; const bubbleContainer = entry.el.querySelector(\".bubble-container\"); const original = m.body; bubbleContainer.innerHTML = '

保存キャンセル

'; const input = bubbleContainer.querySelector(\".edit-input\"); input.focus(); bubbleContainer.querySelector(\".edit-cancel\").addEventListener(\"click\", () => { bubbleContainer.innerHTML = buildBubbleInner(m); }); bubbleContainer.querySelector(\".edit-save\").addEventListener(\"click\", () => submitEdit(id, input.value)); input.addEventListener(\"keydown\", (e) => { if (e.key === \"Enter\") { e.preventDefault(); submitEdit(id, input.value); } if (e.key === \"Escape\") { bubbleContainer.innerHTML = buildBubbleInner(m); } }); }\nasync function submitEdit(id, newBody) { const trimmed = newBody.trim(); if (!trimmed) return; try { const res = await fetch(\"/api/edit\", { method: \"POST\", headers: { \"Content-Type\": \"application/json\" }, body: JSON.stringify({ id, user_id: myUserId, body: trimmed }) }); const data = await res.json(); if (!data.success) { alert(\"編集に失敗しました: \" + (data.error||\"unknown\")); return; } await poll(); } catch(err){ console.error(err); } }\nasync function handleDelete(idStr) { const id = Number(idStr); if (!confirm(\"このメッセージを削除しますか？\")) return; try { const res = await fetch(\"/api/delete\", { method: \"POST\", headers: { \"Content-Type\": \"application/json\" }, body: JSON.stringify({ id, user_id: myUserId }) }); const data = await res.json(); if (!data.success) { alert(\"削除に失敗しました: \" + (data.error||\"unknown\")); return; } await poll(); } catch(err){ console.error(err); } }\nasync function handleVote(pollIdStr, messageIdStr, optionStr) { try { await fetch(\"/api/poll/vote\", { method: \"POST\", headers: { \"Content-Type\": \"application/json\" }, body: JSON.stringify({ poll_id: Number(pollIdStr), message_id: Number(messageIdStr), user_id: myUserId, option_index: Number(optionStr) }) }); await poll(); } catch(err){ console.error(err); } }\nbodyInput.addEventListener(\"input\", () => { const val = bodyInput.value; const caret = bodyInput.selectionStart; const uptoCaret = val.slice(0, caret); const match = uptoCaret.match(/(^|[\\\\s\\\\u3000])@([^\\\\s\\\\u3000@]*)$/); if (match) { const query = match[2].toLowerCase(); const myName = getDisplayName(); const candidates = Array.from(knownNames).filter((n) => n !== myName && n.toLowerCase().includes(query)); if (candidates.length > 0) { showMentionList(candidates); return; } } hideMentionList(); });\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);\nbodyInput.addEventListener(\"keydown\", (e) => { if (e.key === \"Enter\" && !e.shiftKey && !e.isComposing) { e.preventDefault(); composer.requestSubmit ? composer.requestSubmit() : composer.dispatchEvent(new Event(\"submit\", { cancelable: true })); } });\nfunction showMentionList(candidates) { mentionList.innerHTML = \"\"; candidates.slice(0,6).forEach((n) => { const item = document.createElement(\"div\"); item.className=\"mention-item\"; item.textContent=n; item.style.padding=\"6px 10px\"; item.style.cursor=\"pointer\"; item.addEventListener(\"mousedown\", (e) => { e.preventDefault(); insertMention(n); }); mentionList.appendChild(item); }); mentionList.style.display=\"block\"; }\nfunction hideMentionList() { mentionList.style.display=\"none\"; mentionList.innerHTML=\"\"; }\nfunction insertMention(name) { const val = bodyInput.value; const caret = bodyInput.selectionStart; const uptoCaret = val.slice(0, caret); const replaced = uptoCaret.replace(/@([^\\\\s\\\\u3000@]*)$/, \"@\" + name + \" \"); bodyInput.value = replaced + val.slice(caret); hideMentionList(); bodyInput.focus(); }\nfunction detectSlashCommand(trimmed) { if (trimmed === \"/roll\" || trimmed.indexOf(\"/roll \") === 0) { const arg = trimmed === \"/roll\" ? \"\" : trimmed.slice(6).trim(); let max = 6; if (arg !== \"\") { const n = parseInt(arg,10); if (!Number.isNaN(n) && n>0) max=n; } return { type: \"roll\", max }; } if (trimmed.indexOf(\"/poll \") === 0) return { type: \"poll\", raw: trimmed.slice(6) }; if (trimmed === \"/who\") return { type: \"who\" }; if (trimmed === \"/party\") return { type: \"party\" }; if (trimmed.toLowerCase() === \"/profile\") return { type: \"profile\" }; return null; }\nasync function sendRollCommand(max) { const safeMax = max > 0 ? max : 6; const result = Math.floor(Math.random()*safeMax)+1; const text = \"🎲 \" + getDisplayName() + \" のダイス: \" + result + \" (1〜\" + safeMax + \")\"; clearImagePreview(); await sendNormalMessage(text, null); }\nasync function sendPollCommand(raw) { const parts = raw.split(\"|\").map((s)=>s.trim()).filter((s)=>s.length>0); if (parts.length < 3) { alert(\"使い方: /poll 質問|選択肢1|選択肢2|選択肢3\"); return; } const question = parts[0]; const options = parts.slice(1); sending = true; bodyInput.disabled = true; try { await fetch(\"/api/poll/create\", { method: \"POST\", headers: { \"Content-Type\": \"application/json\" }, body: JSON.stringify({ room, user_id: myUserId, name: getDisplayName(), avatar_url: getAvatarUrl(), question, options }) }); bodyInput.value=\"\"; autoGrowBody(); clearImagePreview(); await poll(); } catch(err){ console.error(err); } finally { bodyInput.disabled=false; bodyInput.focus(); sending=false; } }\nasync function sendWhoCommand() { bodyInput.value=\"\"; autoGrowBody(); sending=true; bodyInput.disabled=true; try { await poll(); const names = onlineUsers.length ? onlineUsers.map((u)=>u.name).join(\"、\") : \"(自分以外は今いません)\"; renderSystemMessage(\"オンライン (\"+onlineUsers.length+\"人): \"+names); } catch(err){ console.error(err); } finally { bodyInput.disabled=false; bodyInput.focus(); sending=false; } }\nasync function sendPartyCommand() { clearImagePreview(); await sendNormalMessage(\"🎉\", null); }\nlet tempIdCounter = 0; let pendingOptimistic = null;\nfunction appendMessageElementToDOM(m) { if (firstLoad) { messagesEl.innerHTML = \"\"; firstLoad = false; } const dateStr = fmtDate(m.created_at); if (dateStr !== lastRenderedDateStr) { const divider = document.createElement(\"div\"); divider.className=\"date-divider\"; divider.textContent=dateStr; messagesEl.appendChild(divider); lastRenderedDateStr=dateStr; } const el = createMessageElement(m); messagesEl.appendChild(el); msgIndex.set(m.id, { el, sig: signatureOf(m) }); messageData.set(m.id, m); return el; }\nasync function sendNormalMessage(body, file) {\n sending = true; bodyInput.disabled = true; const currentReply = replyingTo;\n try {\n let imageUrl = \"\"; if (file) imageUrl = await fileToBase64(file);\n const isPartyBody = body === \"🎉\";\n let tempId = null;\n if (isPartyBody) { triggerParty(); } else { tempId = --tempIdCounter; const nowTs = Date.now(); const optimisticMsg = { id: tempId, user_id: myUserId, name: getDisplayName(), body, image_url: imageUrl, reply_to_id: currentReply ? currentReply.id : null, reply_to_name: currentReply ? currentReply.name : null, reply_to_body: currentReply ? currentReply.body : null, edited_at: null, deleted: false, updated_at: nowTs, poll_id: null, poll: null, created_at: nowTs, avatar_url: getAvatarUrl() }; knownNames.add(optimisticMsg.name); appendMessageElementToDOM(optimisticMsg); messagesEl.scrollTop = messagesEl.scrollHeight; scrollBottomBtn.classList.remove(\"show\"); }\n pendingOptimistic = { tempId, body, image_url: imageUrl, isParty: isPartyBody };\n bodyInput.value = \"\"; autoGrowBody(); clearImagePreview(); replyingTo = null; showReplyPreview();\n await fetch(\"/api/send\", { method: \"POST\", headers: { \"Content-Type\": \"application/json\" }, body: JSON.stringify({ room, user_id: myUserId, name: getDisplayName(), body, image_url: imageUrl, avatar_url: getAvatarUrl(), reply_to_id: currentReply ? currentReply.id : null, reply_to_name: currentReply ? currentReply.name : null, reply_to_body: currentReply ? currentReply.body : null }) });\n await poll();\n } catch(err){ console.error(err); if (pendingOptimistic) { if (!pendingOptimistic.isParty && pendingOptimistic.tempId != null) { const entry = msgIndex.get(pendingOptimistic.tempId); if (entry && entry.el) entry.el.remove(); msgIndex.delete(pendingOptimistic.tempId); messageData.delete(pendingOptimistic.tempId); } if (!pendingOptimistic.isParty) { bodyInput.value = body; autoGrowBody(); } pendingOptimistic = null; } } finally { bodyInput.disabled = false; bodyInput.focus(); sending = false; }\n}\nasync function poll() {\n try { const res = await fetch(\"/api/messages?room=\" + encodeURIComponent(room) + \"&since=\" + lastId + \"&sinceUpdate=\" + lastUpdateSeen + \"&viewer=\" + encodeURIComponent(myUserId) + \"&name=\" + encodeURIComponent(getDisplayName())); const data = await res.json(); if (data.online) onlineUsers = data.online; if (data.messages && data.messages.length) render(data.messages); } catch(err){ console.error(err); }\n}\ncomposer.addEventListener(\"submit\", async (e) => {\n e.preventDefault(); if (sending) return;\n const trimmed = bodyInput.value.trim(); const file = fileInput.files[0]; 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 === \"party\") { await sendPartyCommand(); return; }\n if (cmd && cmd.type === \"profile\") { bodyInput.value = \"\"; autoGrowBody(); openEntryOverlay(true); return; }\n await sendNormalMessage(trimmed, file);\n});\nrenderProfileBar();\nif (currentProfile) { startApp(); } else { openEntryOverlay(false); }\n`;","createdAt",["D",1785289613066],"branchVersion","branchId","758fe5b1-f114-4051-9e6c-af0e9af14c01","id","532fc9a5-baab-49d6-af82-56a01ca31fd6","my-first-val",["D",1785220063684],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","This is just a chat app… or so it claims. There’s nothing here.","imageUrl","9f3bac8a-d43d-4ccf-9505-cf0f141186f8","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019fa766-f010-73f2-920a-31044edf22b4","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":55,"_101":102,"_103":25},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",97,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","nznp","handle","displayName","AbyssalFractal","avatar","https://avatars.githubusercontent.com/u/308141039?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":163,"_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":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":164,"_80":165,"_82":166,"_84":25},"tree",[154,155],"files",[154,155],"counts",{"_143":62,"_144":145,"_146":62,"_147":148,"_149":150},"contents",[127,128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":136,"_32":137,"_30":138,"_130":-5,"_41":42,"_40":139,"_131":58,"_38":140,"_13":62,"_33":141,"_35":-5,"_24":25,"_134":-5,"_27":142},{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":25,"_38":132,"_13":133,"_33":34,"_35":37,"_24":25,"_134":95,"_27":135},"13537ddf-9ec2-4f20-9ae6-bf36b73aedcf","parentId","latest",["D",1785289613066],53,"label",[28],"448f6559-491e-4722-bc41-d8f8093be278","untitled-folder-35","afd79a8a-8ae9-11f1-9a23-1607ee4eb77e",61,["D",1785287170723],"directory",[137],"pulls","branches",1,"forks","envVars",{"_151":62,"_153":62},"connections",{"_151":62,"_152":62},"count","unfilledCount","emptyCount",{"_43":136,"_32":137,"_30":138,"_130":-5,"_41":42,"_40":139,"_131":58,"_38":160,"_13":62,"_33":141,"_35":-5,"_24":25,"_134":-5,"_157":161,"_27":162},{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":25,"_38":156,"_13":133,"_33":34,"_35":37,"_24":25,"_134":95,"_157":158,"_27":159},["D",1785289613066],"children",[],[28],["D",1785287170723],[],[137],["D",1785220063684],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":55,"_101":102,"_103":25},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_124":200,"_201":202,"_203":204,"_205":25,"_206":25,"_207":25,"_208":58,"_209":-5,"_210":-7,"_211":-7,"_212":62,"_213":25,"_214":25,"_215":-5,"_216":25,"_217":25,"_218":25,"_219":-5},"ENV",{"_171":172,"_173":174,"_175":86,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199},"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 · v76