' + 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\n// ★追加: トーク一覧の開閉・描画・遷移\nfunction fmtRoomListTime(ts) {\n const d = new Date(ts);\n const now = new Date();\n const sameDay = d.getFullYear() === now.getFullYear() && d.getMonth() === now.getMonth() && d.getDate() === now.getDate();\n return sameDay ? fmtTime(ts) : fmtDate(ts);\n}\nfunction buildRoomPreview(r) {\n if (r.last_deleted) return \"（メッセージは削除されました）\";\n if (r.last_is_poll) return \"📊 \" + (r.last_body || \"投票\");\n if (r.last_has_image && !r.last_body) return \"📷 画像\";\n return r.last_body || \"\";\n}\nasync function openRoomList() {\n roomListOverlay.classList.add(\"show\");\n roomListItems.innerHTML = '

読み込み中...

';\n try {\n const res = await fetch(\"/api/rooms?user_id=\" + encodeURIComponent(myUserId));\n const data = await res.json();\n const rooms = data.rooms || [];\n if (rooms.length === 0) {\n roomListItems.innerHTML = '

まだ参加したトークがありません

';\n return;\n }\n roomListItems.innerHTML = \"\";\n rooms.forEach((r) => {\n const item = document.createElement(\"div\");\n item.className = \"roomlist-item\" + (r.room === room ? \" current\" : \"\");\n const color = colorForKey(r.room);\n const letter = escapeHtml((r.room || \"?\").charAt(0).toUpperCase());\n item.innerHTML =\n '

' + letter + \"

\" +\n '

' +\n '

#' + escapeHtml(r.room) + \"

\" +\n '

' + escapeHtml(buildRoomPreview(r)) + \"

\" +\n \"

\" +\n '

' + fmtRoomListTime(r.last_created_at) + \"

\";\n item.addEventListener(\"click\", () => {\n if (r.room === room) { closeRoomList(); return; }\n location.hash = r.room;\n location.reload();\n });\n roomListItems.appendChild(item);\n });\n } catch (err) {\n console.error(err);\n roomListItems.innerHTML = '

読み込みに失敗しました

';\n }\n}\nfunction closeRoomList() { roomListOverlay.classList.remove(\"show\"); }\nroomListBtn.addEventListener(\"click\", openRoomList);\nroomListCloseBtn.addEventListener(\"click\", closeRoomList);\nroomListOverlay.addEventListener(\"click\", (e) => { if (e.target === roomListOverlay) closeRoomList(); });\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 extractColorCode(body) {\n // 例: \"#ff0000 こんにちは\" のように\n // 先頭が「#カラーコード + 半角/全角スペース」の場合にマッチ\n const match = body.match(/^#([0-9a-fA-F]{3}|[0-9a-fA-F]{6})[ \\\\u3000]+([\\\\s\\\\S]+)$/);\n if (!match) return null;\n return { color: \"#\" + match[1], text: match[2] };\n}\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\n let bodyHtml;\n if (m.poll) {\n bodyHtml = buildPollHtml(m);\n } else {\n const colorInfo = extractColorCode(m.body);\n if (colorInfo) {\n bodyHtml = '' +\n linkifyMentions(escapeHtml(colorInfo.text)) + '';\n } else {\n bodyHtml = linkifyMentions(escapeHtml(m.body));\n }\n }\n\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 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.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 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);\n\n// ★追加: 入力中テキストの下書き保存（Android等でタブが裏で再読み込みされても復元できるように）\nfunction getDraftKey() { return \"chatDraft:\" + room; }\nfunction saveDraft() {\n try { localStorage.setItem(getDraftKey(), bodyInput.value); } catch (e) { /* ignore */ }\n}\nfunction restoreDraft() {\n try {\n const saved = localStorage.getItem(getDraftKey());\n if (saved) { bodyInput.value = saved; autoGrowBody(); }\n } catch (e) { /* ignore */ }\n}\nfunction clearDraft() {\n try { localStorage.removeItem(getDraftKey()); } catch (e) { /* ignore */ }\n}\nbodyInput.addEventListener(\"input\", saveDraft);\nwindow.addEventListener(\"pagehide\", saveDraft);\ndocument.addEventListener(\"visibilitychange\", () => {\n if (document.visibilityState === \"hidden\") {\n saveDraft();\n } else {\n // ★追加: 画面に戻ってきたタイミングでも下書きを復元\n // （Androidがバックグラウンドでページのフォーム内容だけ破棄した場合の対策）\n restoreDraft();\n }\n});\n// ★追加: bfcache（ブラウザの高速復元）からページが戻ってきた際にも復元\nwindow.addEventListener(\"pageshow\", () => {\n restoreDraft();\n});\n// ★追加: 念のため数秒おきにも自動保存（何らかの理由でイベントが発火しない場合の保険）\nsetInterval(saveDraft, 3000);\n\nbodyInput.addEventListener(\"keydown\", (e) => {\n if (e.key === \"Enter\" && !e.shiftKey && !e.isComposing) {\n e.preventDefault();\n composer.requestSubmit ? composer.requestSubmit() : composer.dispatchEvent(new Event(\"submit\", { cancelable: true }));\n }\n});\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.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(); clearDraft();\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(); clearDraft();\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\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\n const 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 pendingOptimistic = { tempId, body, image_url: imageUrl };\n\n bodyInput.value = \"\"; autoGrowBody(); clearImagePreview(); clearDraft();\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.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 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 === \"profile\") { bodyInput.value = \"\"; autoGrowBody(); openEntryOverlay(true); return; }\n\n await sendNormalMessage(trimmed, file);\n});\n\n// --- 起動処理 ---\nrenderProfileBar();\nrestoreDraft();\nif (currentProfile) {\n startApp();\n} else {\n openEntryOverlay(false);\n}\n`;","label",[18],"pulls","branches","forks","envVars",{"_168":26,"_170":26},"connections",{"_168":26,"_169":26},"count","unfilledCount","emptyCount",{"_33":205,"_13":206,"_63":207,"_43":-5,"_35":36,"_153":208,"_154":93,"_37":209,"_39":26,"_65":210,"_157":-5,"_67":24,"_159":-5,"_184":211,"_17":212},{"_33":152,"_13":18,"_63":64,"_43":-5,"_35":36,"_153":73,"_154":93,"_37":202,"_39":156,"_65":66,"_157":158,"_67":24,"_159":-5,"_184":203,"_17":204},{"_33":194,"_13":195,"_63":196,"_43":-5,"_35":36,"_153":197,"_154":93,"_37":198,"_39":156,"_65":66,"_157":199,"_67":24,"_159":-5,"_184":200,"_17":201},{"_33":187,"_13":188,"_63":91,"_43":-5,"_35":36,"_153":116,"_154":93,"_37":189,"_39":190,"_65":182,"_157":191,"_67":24,"_159":12,"_184":192,"_17":193},{"_33":176,"_13":177,"_63":178,"_43":-5,"_35":36,"_153":179,"_154":93,"_37":180,"_39":181,"_65":182,"_157":183,"_67":24,"_159":-5,"_184":185,"_17":186},"b506928f-0a77-498c-a59c-3f8cb12860f1","new-file-2477.ts","94a8c60a-8b0a-11f1-88cc-1607ee4eb77e",86,["D",1785303099451],4,"http","export const gifClientJs = `\n(function() {\n var GIPHY_API_KEY = \"lYkxiVmRBDaztLVDK7p1cqKd4EUVFMhq\";\n\n function injectStyles() {\n var style = document.createElement(\"style\");\n style.textContent =\n \".gif-label{background:transparent;border:none;color:#8a8a92;padding:8px;border-radius:999px;cursor:pointer;display:flex;align-items:center;justify-content:center;font-size:0.72rem;font-weight:700;flex:0 0 auto;}\" +\n \".gif-label:hover{background:rgba(0,0,0,0.05);color:#2f7cf6;}\" +\n \".gif-overlay{display:none;position:fixed;inset:0;background:rgba(0,0,0,0.5);align-items:flex-end;justify-content:center;z-index:10001;}\" +\n \".gif-overlay.show{display:flex;}\" +\n \".gif-panel{width:100%;max-width:480px;background:#ffffff;border-radius:16px 16px 0 0;display:flex;flex-direction:column;max-height:70vh;overflow:hidden;}\" +\n \".gif-panel-header{display:flex;align-items:center;gap:8px;padding:10px 12px;border-bottom:1px solid #e5e5ea;}\" +\n \".gif-search-input{flex:1;background:#f2f3f5;border:1px solid transparent;color:#1c1c1e;padding:8px 14px;border-radius:20px;font-size:16px;outline:none;}\" +\n \".gif-search-input:focus-visible{border-color:#2f7cf6;background:#ffffff;}\" +\n \".gif-close-btn{cursor:pointer;color:#b6b6bd;padding:4px 8px;flex:0 0 auto;}\" +\n \".gif-grid{flex:1;overflow-y:auto;padding:10px;display:grid;grid-template-columns:repeat(3,1fr);gap:6px;}\" +\n \".gif-grid img{width:100%;height:90px;object-fit:cover;border-radius:8px;cursor:pointer;display:block;background:#f2f3f5;}\" +\n \".gif-empty{grid-column:1/-1;text-align:center;font-size:0.8rem;color:#b6b6bd;padding:20px 0;}\";\n document.head.appendChild(style);\n }\n\n function injectMarkup() {\n var composer = document.getElementById(\"composer\");\n if (!composer) return null;\n var fileLabel = document.getElementById(\"fileLabel\");\n\n var gifBtn = document.createElement(\"label\");\n gifBtn.id = \"gifLabel\";\n gifBtn.className = \"gif-label\";\n gifBtn.title = \"GIFを送る\";\n gifBtn.textContent = \"GIF\";\n if (fileLabel && fileLabel.parentNode) {\n fileLabel.parentNode.insertBefore(gifBtn, fileLabel.nextSibling);\n } else {\n composer.insertBefore(gifBtn, composer.firstChild);\n }\n\n var overlay = document.createElement(\"div\");\n overlay.id = \"gifOverlay\";\n overlay.className = \"gif-overlay\";\n overlay.innerHTML =\n '

' +\n '

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

' +\n '

';\n document.body.appendChild(overlay);\n return true;\n }\n\n function setup() {\n injectStyles();\n if (!injectMarkup()) return;\n\n var gifOverlay = document.getElementById(\"gifOverlay\");\n var gifSearchInput = document.getElementById(\"gifSearchInput\");\n var gifGrid = document.getElementById(\"gifGrid\");\n var gifCloseBtn = document.getElementById(\"gifCloseBtn\");\n var gifLabel = document.getElementById(\"gifLabel\");\n var searchTimer = null;\n\n function openPanel() {\n gifOverlay.classList.add(\"show\");\n gifSearchInput.value = \"\";\n gifSearchInput.focus();\n search(\"\");\n }\n function closePanel() {\n gifOverlay.classList.remove(\"show\");\n gifGrid.innerHTML = \"\";\n }\n function search(query) {\n gifGrid.innerHTML = '

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

';\n var endpoint = query.trim()\n ? \"https://api.giphy.com/v1/gifs/search?api_key=\" + GIPHY_API_KEY + \"&q=\" + encodeURIComponent(query) + \"&limit=24&rating=pg-13&lang=ja\"\n : \"https://api.giphy.com/v1/gifs/trending?api_key=\" + GIPHY_API_KEY + \"&limit=24&rating=pg-13\";\n fetch(endpoint).then(function(res) { return res.json(); }).then(function(data) {\n var items = data.data || [];\n if (items.length === 0) {\n gifGrid.innerHTML = '

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

';\n return;\n }\n gifGrid.innerHTML = \"\";\n items.forEach(function(g) {\n var preview = (g.images && (g.images.fixed_width_small || g.images.fixed_width) || {}).url || \"\";\n var full = (g.images && (g.images.original || g.images.fixed_width) || {}).url || \"\";\n if (!preview || !full) return;\n var img = document.createElement(\"img\");\n img.src = preview;\n img.alt = g.title || \"gif\";\n img.addEventListener(\"click\", function() {\n closePanel();\n sendGif(full);\n });\n gifGrid.appendChild(img);\n });\n }).catch(function(err) {\n console.error(err);\n gifGrid.innerHTML = '

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

';\n });\n }\n function getCurrentRoom() {\n var r = location.hash.replace(/^#/, \"\");\n return r || \"lobby\";\n }\n function getCurrentUserId() {\n return localStorage.getItem(\"chatUserId\") || \"unknown\";\n }\n function getCurrentName() {\n return localStorage.getItem(\"chatName\") || \"\\u540D\\u7121\\u3057\";\n }\n function getCurrentAvatar() {\n return localStorage.getItem(\"chatAvatar\") || \"\";\n }\n\n function sendGif(fullUrl) {\n try {\n fetch(\"/api/send\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n room: getCurrentRoom(),\n user_id: getCurrentUserId(),\n name: getCurrentName(),\n body: \"\",\n image_url: fullUrl,\n avatar_url: getCurrentAvatar(),\n }),\n }).then(function() {\n if (typeof window.poll === \"function\") window.poll();\n }).catch(function(err) { console.error(err); });\n } catch (err) {\n console.error(err);\n }\n }\n\n gifLabel.addEventListener(\"click\", openPanel);\n gifCloseBtn.addEventListener(\"click\", closePanel);\n gifOverlay.addEventListener(\"click\", function(e) { if (e.target === gifOverlay) closePanel(); });\n gifSearchInput.addEventListener(\"input\", function() {\n clearTimeout(searchTimer);\n var q = gifSearchInput.value;\n searchTimer = setTimeout(function() { search(q); }, 350);\n });\n }\n\n if (document.readyState === \"loading\") {\n document.addEventListener(\"DOMContentLoaded\", setup);\n } else {\n setup();\n }\n})();\n`;\n\nexport default async function (req: Request): Promise {\n return new Response(gifClientJs, {\n headers: {\n \"Content-Type\": \"application/javascript; charset=utf-8\",\n \"Cache-Control\": \"no-cache\",\n },\n });\n}","children",[],[177],"c5065ac4-5765-4b85-914b-f5bdf41a28c9","main.ts",["D",1786524362893],63,"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport webpush from \"https://esm.sh/web-push@3.6.7\";\nimport { htmlContent } from \"./html.ts\";\nimport { jsContent } from \"./client.ts\";\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/rooms\" && req.method === \"GET\") {\n const user_id = url.searchParams.get(\"user_id\") || \"\";\n if (!user_id) {\n return new Response(JSON.stringify({ rooms: [] }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n // 自分が一度でも発言したルームそれぞれについて、\n // ルーム内で最新のメッセージ（誰の発言でもOK）を1件ずつ取得する\n const result = await sqlite.execute({\n sql: `\n SELECT t.room, t.id, t.name, t.body, t.deleted, t.created_at, t.image_url, t.poll_id\n FROM ${TABLE} t\n INNER JOIN (\n SELECT room, MAX(id) AS max_id\n FROM ${TABLE}\n WHERE room IN (SELECT DISTINCT room FROM ${TABLE} WHERE user_id = ?)\n GROUP BY room\n ) latest ON t.room = latest.room AND t.id = latest.max_id\n ORDER BY t.created_at DESC\n `,\n args: [user_id],\n });\n\n const rooms = (result.rows as any[]).map((row) => ({\n room: String(row[0] ?? row.room),\n last_message_id: Number(row[1] ?? row.id),\n last_name: String(row[2] ?? row.name),\n last_body: String(row[3] ?? row.body),\n last_deleted: Number(row[4] ?? row.deleted ?? 0) === 1,\n last_created_at: Number(row[5] ?? row.created_at),\n last_has_image: !!(row[6] ?? row.image_url),\n last_is_poll: (row[7] ?? row.poll_id) != null,\n }));\n\n return new Response(JSON.stringify({ rooms }), {\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}",[],[188],"dbfb0605-d457-49b4-a3bc-10dfe48b6d65","html.ts","124f7df4-962a-11f1-b4d9-1607ee4eb77e",95,["D",1786524316830],"export const htmlContent = `\n\n \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 \n \n \n`;",[],[195],["D",1786524335099],[],[18],"448f6559-491e-4722-bc41-d8f8093be278","untitled-folder-35","afd79a8a-8ae9-11f1-9a23-1607ee4eb77e",61,["D",1785287170723],"directory",[],[206],["D",1785220063684],{"_11":12,"_130":70},{"_11":12,"_125":126,"_69":70,"_30":68,"_127":128,"_129":24},{"_39":116,"_13":16,"_33":36,"_117":80,"_118":-5,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":14,"_124":12},"ctx",{"_53":-5,"_149":250,"_251":252,"_253":254,"_255":24,"_256":24,"_257":24,"_258":93,"_259":-5,"_260":-7,"_261":-7,"_262":26,"_263":24,"_264":24,"_265":-5,"_266":24,"_267":24,"_268":24,"_269":-5},"ENV",{"_221":222,"_223":224,"_225":16,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237,"_238":239,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249},"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"]

History · client.ts