[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_181":182,"_183":184},"routes/_app.x.$handle.$name",{"_97":96,"_33":46,"_106":87,"_28":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":27,"_121":122,"_123":25,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_33":46,"_39":47,"_48":-5,"_49":27,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":25,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":27},"version",67,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":27,"_28":29,"_30":29},"file",{"_31":32,"_33":29,"_34":38,"_36":37,"_39":40,"_41":14,"_42":43,"_24":27},"previous",{"_31":32,"_33":29,"_34":35,"_36":37},"deleted",true,"deletedHere",false,"path","new-file-4676.ts","latestPath","fileId","83aab014-8ae9-11f1-957a-1607ee4eb77e","name","fileType","script","content","// ============================================\n// notification-sound.ts - 通知音機能追加ファイル\n// 使い方: main.ts の htmlContent 内でとして読み込むか、\n// client.js の poll() の後にこのコードを統合する\n// ============================================\n\n// --- 1. バックエンド側: /sound.js 配信ルートを main.ts に追加してください ---\n// main.ts の export default async function の最後、return Not Found の直前に追加:\n/*\n if (url.pathname === \"/sound.js\") {\n return new Response(soundJsContent, {\n headers: { \"Content-Type\": \"application/javascript; charset=utf-8\" },\n });\n }\n if (url.pathname === \"/notify.mp3\" || url.pathname === \"/notify.wav\") {\n // 必要なら自前音声を配信する場合\n return new Response(\"Not Found\", { status: 404 });\n }\n*/\n\n// --- 2. フロントエンド側: sound.js の中身 ---\nconst soundJsContent = `\n// notification-sound.js\n(function() {\n // 設定\n const SOUND_ENABLED_KEY = \"chatSoundEnabled\";\n const SOUND_VOLUME_KEY = \"chatSoundVolume\";\n const DEFAULT_VOLUME = 0.6;\n\n let audioContext = null;\n let isEnabled = localStorage.getItem(SOUND_ENABLED_KEY) !== \"false\"; // デフォON\n let volume = parseFloat(localStorage.getItem(SOUND_VOLUME_KEY) || DEFAULT_VOLUME);\n let lastPlayedAt = 0;\n const COOLDOWN_MS = 800; // 連投時の連打防止\n\n // Web Audio APIでピロン音を生成（外部ファイル不要）\n function playBeep(type = \"message\") {\n if (!isEnabled) return;\n const now = Date.now();\n if (now - lastPlayedAt < COOLDOWN_MS) return;\n lastPlayedAt = now;\n\n try {\n if (!audioContext) {\n audioContext = new (window.AudioContext || window.webkitAudioContext)();\n }\n if (audioContext.state === \"suspended\") {\n audioContext.resume();\n }\n\n const ctx = audioContext;\n const masterGain = ctx.createGain();\n masterGain.gain.value = volume;\n masterGain.connect(ctx.destination);\n\n if (type === \"message\") {\n // ピロン♪ 2音\n const osc1 = ctx.createOscillator();\n const gain1 = ctx.createGain();\n osc1.type = \"sine\";\n osc1.frequency.value = 880; // A5\n gain1.gain.setValueAtTime(0, ctx.currentTime);\n gain1.gain.linearRampToValueAtTime(0.8, ctx.currentTime + 0.02);\n gain1.gain.exponentialRampToValueAtTime(0.01, ctx.currentTime + 0.25);\n osc1.connect(gain1).connect(masterGain);\n osc1.start();\n osc1.stop(ctx.currentTime + 0.25);\n\n const osc2 = ctx.createOscillator();\n const gain2 = ctx.createGain();\n osc2.type = \"sine\";\n osc2.frequency.value = 1320; // E6\n gain2.gain.setValueAtTime(0, ctx.currentTime + 0.12);\n gain2.gain.linearRampToValueAtTime(0.8, ctx.currentTime + 0.14);\n gain2.gain.exponentialRampToValueAtTime(0.01, ctx.currentTime + 0.5);\n osc2.connect(gain2).connect(masterGain);\n osc2.start(ctx.currentTime + 0.12);\n osc2.stop(ctx.currentTime + 0.5);\n } else if (type === \"mention\") {\n // メンション用は3音で目立たせる\n [880, 1108, 1320].forEach((freq, i) => {\n const osc = ctx.createOscillator();\n const g = ctx.createGain();\n osc.type = \"sine\";\n osc.frequency.value = freq;\n const t = ctx.currentTime + i * 0.12;\n g.gain.setValueAtTime(0, t);\n g.gain.linearRampToValueAtTime(0.9, t + 0.02);\n g.gain.exponentialRampToValueAtTime(0.01, t + 0.3);\n osc.connect(g).connect(masterGain);\n osc.start(t);\n osc.stop(t + 0.3);\n });\n }\n } catch (e) {\n console.warn(\"Sound play failed:\", e);\n }\n }\n\n // 外部mp3を使いたい場合のフォールバック再生\n function playFile(url = \"/notify.mp3\") {\n if (!isEnabled) return;\n try {\n const audio = new Audio(url);\n audio.volume = volume;\n audio.play().catch(()=>{});\n } catch {}\n }\n\n // UI: ヘッダーにサウンドON/OFFトグルを追加\n function injectSoundToggle() {\n const header = document.querySelector(\"header\");\n if (!header || document.getElementById(\"soundToggle\")) return;\n\n const btn = document.createElement(\"button\");\n btn.id = \"soundToggle\";\n btn.type = \"button\";\n btn.title = isEnabled ? \"通知音ON\" : \"通知音OFF\";\n btn.textContent = isEnabled ? \"🔔\" : \"🔕\";\n btn.style.cssText = \"margin-left:6px;background:rgba(0,0,0,0.06);border:1px solid var(--divider);border-radius:999px;padding:4px 10px;cursor:pointer;font-size:0.85rem;\";\n btn.onclick = () => {\n isEnabled = !isEnabled;\n localStorage.setItem(SOUND_ENABLED_KEY, String(isEnabled));\n btn.textContent = isEnabled ? \"🔔\" : \"🔕\";\n btn.title = isEnabled ? \"通知音ON\" : \"通知音OFF\";\n if (isEnabled) {\n // ユーザー操作直後なので音が鳴らせる\n playBeep(\"message\");\n }\n };\n header.appendChild(btn);\n\n // 長押しで音量調整\n btn.addEventListener(\"contextmenu\", (e) => {\n e.preventDefault();\n const v = prompt(\"音量 0.0〜1.0\", String(volume));\n if (v !== null) {\n const nv = Math.min(1, Math.max(0, parseFloat(v) || 0));\n volume = nv;\n localStorage.setItem(SOUND_VOLUME_KEY, String(nv));\n playBeep(\"message\");\n }\n });\n }\n\n // 既存のpoll/renderをフックして新着検知\n let lastKnownMaxId = 0;\n let myId = localStorage.getItem(\"chatUserId\") || \"\";\n let myName = localStorage.getItem(\"chatName\") || \"\";\n\n // メッセージ監視\n function hookRender() {\n // 元のrender関数をラップ\n const checkAndWrap = () => {\n if (typeof window.render === \"function\" && !window.render._hooked) {\n const orig = window.render;\n window.render = function(messages) {\n const newMessages = messages.filter(m => m.id > lastKnownMaxId && m.user_id !== myId);\n orig.apply(this, arguments);\n if (newMessages.length > 0 && lastKnownMaxId !== 0) {\n // 自分宛メンションがあるか\n const hasMention = newMessages.some(m => m.body && m.body.includes(\"@\" + myName));\n // タブが非表示 or ウィンドウにフォーカスが無い時のみ鳴らす、にしたい場合は下の条件を有効化\n // const shouldSound = document.hidden || !document.hasFocus();\n const shouldSound = true; // 常に鳴らすならtrue\n if (shouldSound) {\n if (hasMention) playBeep(\"mention\");\n else playBeep(\"message\");\n }\n }\n // max更新\n messages.forEach(m => { if (m.id > lastKnownMaxId) lastKnownMaxId = m.id; });\n };\n window.render._hooked = true;\n console.log(\"[sound] render hooked\");\n }\n };\n\n // 既存のpollでもmaxIdを拾う\n setInterval(() => {\n if (typeof lastId !== \"undefined\" && lastId > lastKnownMaxId) {\n // 初回は鳴らさない\n if (lastKnownMaxId === 0) {\n lastKnownMaxId = lastId;\n }\n }\n myId = localStorage.getItem(\"chatUserId\") || myId;\n myName = localStorage.getItem(\"chatName\") || myName;\n }, 1000);\n\n setInterval(checkAndWrap, 1000);\n checkAndWrap();\n }\n\n // 初回ユーザー操作でAudioContextを解錠 (ブラウザの自動再生対策)\n function unlockAudio() {\n if (!audioContext) {\n try { audioContext = new (window.AudioContext || window.webkitAudioContext)(); } catch {}\n }\n if (audioContext && audioContext.state === \"suspended\") {\n audioContext.resume();\n }\n document.removeEventListener(\"click\", unlockAudio);\n document.removeEventListener(\"keydown\", unlockAudio);\n }\n document.addEventListener(\"click\", unlockAudio, { once: false });\n document.addEventListener(\"keydown\", unlockAudio, { once: false });\n\n // 起動\n window.addEventListener(\"DOMContentLoaded\", () => {\n injectSoundToggle();\n hookRender();\n });\n // すでにDOMが読み込まれてたら即実行\n if (document.readyState !== \"loading\") {\n injectSoundToggle();\n hookRender();\n }\n\n // 外部から呼び出し可能に\n window.ChatSound = {\n play: playBeep,\n playFile: playFile,\n toggle: () => { isEnabled = !isEnabled; localStorage.setItem(SOUND_ENABLED_KEY, String(isEnabled)); return isEnabled; },\n isEnabled: () => isEnabled,\n setVolume: (v) => { volume = v; localStorage.setItem(SOUND_VOLUME_KEY, String(v)); }\n };\n})();\n`;\n\n// --- 3. main.ts への組み込み例 (差分) ---\n/*\n // htmlContent のの直前やの直前に追加\n \n\n // もしくは htmlContent 内の既存のの後に追加\n*/\n\n// エクスポート用にファイルとして保存する場合は、この文字列をそのまま /sound.js として返す\nexport const notificationSoundFile = soundJsContent;","interval","createdAt",["D",1785287281050],"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","3ba0dce4-8a4e-11f1-b5a8-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019fa766-f010-73f2-920a-31044edf22b4","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_105":101},"org",{"_97":96,"_98":99,"_100":101,"_18":56,"_102":103,"_104":27},"branch",{"_13":86,"_33":87,"_44":43,"_88":45,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":46,"_95":96},"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",{"_44":45,"_33":46,"_39":177,"_48":-5,"_49":27,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":25,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":178,"_81":179,"_83":180,"_85":27},"tree",[164,165,166],"files",[164,165,166],"counts",{"_153":63,"_154":155,"_156":63,"_157":158,"_159":160},"contents",[128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":146,"_33":147,"_31":148,"_132":-5,"_42":43,"_41":149,"_133":25,"_39":150,"_13":63,"_34":151,"_36":-5,"_24":27,"_136":-5,"_28":152},{"_44":138,"_33":139,"_31":58,"_132":-5,"_42":43,"_41":140,"_133":27,"_39":141,"_13":142,"_34":143,"_36":144,"_24":27,"_136":96,"_28":145},{"_44":131,"_33":29,"_31":32,"_132":-5,"_42":43,"_41":14,"_133":27,"_39":134,"_13":135,"_34":38,"_36":37,"_24":27,"_136":-5,"_28":137},"607ccd4b-df5f-403a-bfa1-fd4b0c611a56","parentId","latest",["D",1785287281050],6,"label",[29],"38bccee8-6ae5-4b58-9811-312f8e19e0c9","main.ts",56,["D",1785286663390],48,"http","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\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\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 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 notifications: Promise[] = [];\n for (const row of subsResult.rows as any[]) {\n try {\n const sub = JSON.parse(String(row[0] ?? row.subscription));\n notifications.push(\n webpush.sendNotification(\n sub,\n JSON.stringify({\n title: name,\n body: body.length > 100 ? body.substring(0, 100) + \"…\" : body,\n tag: `msg-${room}`,\n icon: avatar_url || undefined,\n }),\n ).catch((err: any) => {\n if (err.statusCode === 410) {\n sqlite.execute({\n sql: `DELETE FROM ${PUSH_SUB_TABLE} WHERE subscription = ?`,\n args: [String(row[0] ?? row.subscription)],\n }).catch(() => {});\n }\n }),\n );\n } catch (e) {\n // パースエラーなどは無視\n }\n }\n Promise.allSettled(notifications);\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\nconst serviceWorkerCode = `\nself.addEventListener('push', function(event) {\n const data = event.data ? event.data.json() : {};\n event.waitUntil(\n self.registration.showNotification(data.title || '新しいメッセージ', {\n body: data.body || '',\n icon: data.icon || '/favicon.ico',\n badge: '/favicon.ico',\n tag: data.tag || 'chat',\n requireInteraction: false\n })\n );\n});\n\nself.addEventListener('notificationclick', function(event) {\n event.notification.close();\n event.waitUntil(\n clients.matchAll({ type: 'window', includeUncontrolled: true }).then(function(clientList) {\n for (const client of clientList) {\n if (client.url === '/' && 'focus' in client) {\n return client.focus();\n }\n }\n if (clients.openWindow) {\n return clients.openWindow('/');\n }\n })\n );\n});\n`;\n\nconst jsContent = `\n// --- Service Worker 登録と Push 通知設定 ---\nasync function setupPushNotifications() {\n if (!('serviceWorker' in navigator) || !('PushManager' in window)) return;\n \n try {\n const blob = new Blob([serviceWorkerCode], { type: 'application/javascript' });\n const swUrl = URL.createObjectURL(blob);\n const registration = await navigator.serviceWorker.register(swUrl);\n \n if (Notification.permission === 'default') {\n await Notification.requestPermission();\n }\n \n if (Notification.permission === 'granted') {\n let subscription = await registration.pushManager.getSubscription();\n \n if (!subscription) {\n const res = await fetch('/api/vapid-public-key');\n const data = await res.json();\n if (data.publicKey) {\n const convertedKey = urlBase64ToUint8Array(data.publicKey);\n subscription = await registration.pushManager.subscribe({\n userVisibleOnly: true,\n applicationServerKey: convertedKey\n });\n \n await fetch('/api/subscribe', {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({\n user_id: myUserId,\n room: room,\n subscription: subscription\n })\n });\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`;",[139],"448f6559-491e-4722-bc41-d8f8093be278","untitled-folder-35","afd79a8a-8ae9-11f1-9a23-1607ee4eb77e",61,["D",1785287170723],"directory",[147],"pulls","branches",1,"forks","envVars",{"_161":63,"_163":63},"connections",{"_161":63,"_162":63},"count","unfilledCount","emptyCount",{"_44":146,"_33":147,"_31":148,"_132":-5,"_42":43,"_41":149,"_133":25,"_39":174,"_13":63,"_34":151,"_36":-5,"_24":27,"_136":-5,"_168":175,"_28":176},{"_44":138,"_33":139,"_31":58,"_132":-5,"_42":43,"_41":140,"_133":27,"_39":171,"_13":142,"_34":143,"_36":144,"_24":27,"_136":96,"_168":172,"_28":173},{"_44":131,"_33":29,"_31":32,"_132":-5,"_42":43,"_41":14,"_133":27,"_39":167,"_13":135,"_34":38,"_36":37,"_24":27,"_136":-5,"_168":169,"_28":170},["D",1785287281050],"children",[],[29],["D",1785286663390],[],[139],["D",1785287170723],[],[147],["D",1785220063684],{"_97":96,"_105":101},{"_97":96,"_98":99,"_100":101,"_18":56,"_102":103,"_104":27},{"_13":86,"_33":87,"_44":43,"_88":45,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":46,"_95":96},"ctx",{"_79":-5,"_125":214,"_215":216,"_217":218,"_219":27,"_220":27,"_221":27,"_222":25,"_223":-5,"_224":-7,"_225":-7,"_226":63,"_227":27,"_228":27,"_229":-5,"_230":27,"_231":27,"_232":27,"_233":-5},"ENV",{"_185":186,"_187":188,"_189":87,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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 · v67