[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_228":229,"_230":231},"routes/_app.x.$handle.$name",{"_126":125,"_36":74,"_135":116,"_31":136,"_13":14,"_137":-5,"_11":138,"_139":140,"_141":142,"_143":144,"_145":146,"_24":-5,"_147":-5,"_148":-5,"_149":29,"_150":151,"_152":55,"_153":-5,"_154":-5,"_155":156},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_72":73,"_36":74,"_42":75,"_76":-5,"_77":29,"_78":79,"_80":79,"_81":-5,"_82":-5,"_18":83,"_84":35,"_85":55,"_86":-5,"_87":-5,"_88":89,"_90":91,"_92":93,"_94":95,"_96":97,"_98":-5,"_99":100,"_101":100,"_102":103,"_104":103,"_105":103,"_106":100,"_107":100,"_108":109,"_110":111,"_112":113,"_114":29},"version",353,"changes",[19,20,21,22,23],"aiChatInfo","userId",{"_24":65,"_26":66,"_28":55,"_30":55,"_31":67,"_33":67},{"_24":60,"_26":-7,"_28":55,"_30":29,"_31":61,"_33":61},{"_24":54,"_26":-7,"_28":55,"_30":29,"_31":56,"_33":56},{"_24":47,"_26":48,"_28":29,"_30":29,"_31":49,"_33":49},{"_24":25,"_26":27,"_28":29,"_30":29,"_31":32,"_33":32},"file",{"_34":35,"_36":32,"_37":38,"_39":41,"_42":43,"_44":14,"_45":46,"_28":29},"previous",{"_34":35,"_36":32,"_37":38,"_39":40},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","e746b2fa-a4ff-11f1-8cae-1607ee4eb77e","name","fileType","http","content","// ver.3.4 FINAL SINGLE-FILE\n// YouTube Live 자동 감지 + 매일 06:00 KST 1회 초기화\n// /history 자동/관리자/실행자 기록 + JSON API + 동시성 + 중복 제거\n//\n// ver.3.4 변경사항:\n// - [버그수정] History 페이지가 존재하지 않는 엔드포인트(?history=1)를 호출하던 문제 수정 → /api/history 사용\n// - /youtube-check 응답에 마지막 초기화 시각(lastResetTime)과 주체(lastResetBy: 나이트봇/관리자/자동초기화 등) 추가\n// - History 페이지에는 이미 초기화 주체가 표시되고 있었음(historySourceLabel) — 그대로 유지\n// - 모니터/관리자/히스토리 3개 페이지의 \"새로고침 (수동)\" 버튼 제거 (자동 새로고침만 유지)\n//\n// IMPORTANT (Val Town):\n// 이 파일 하나에 HTTP와 CRON 두 Trigger를 연결해서 사용한다.\n// - HTTP Trigger: /monitor, /admin, /history, /api/*, /youtube-check\n// - CRON Trigger: 같은 파일을 1분(Pro) 또는 15분(Free) 간격으로 실행\n// Val Town Cron은 UTC 기준이며 코드 내부에서 KST 06:00을 판정한다.\n// 따라서 별도의 YouTube_Live_AutoReset_Cron.ts 파일은 필요 없다.\n//\n// /youtube-check?secret=... 는 수동 점검용이고,\n// 자동 초기화는 CRON Trigger가 직접 runYouTubeAutoReset()을 호출한다.\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nconst EMOJI_MAP: Record = {\n \"금연\": \"🚭\",\n \"흡연\": \"🚬\",\n \"먹어\": \"🍚\",\n \"먹지마\": \"🚫\",\n \"짠\": \"🍻\",\n \"오늘의 재미\": \"🤣\",\n \"무서움 지수\": \"👻\",\n \"문어\": \"🐙\",\n \"꽃게\": \"🦀\",\n \"소라\": \"🐚\",\n};\n\n// 현재 사용하는 정식 채널명\nconst PRIMARY_CHANNEL = \"암본이수혁aguking\";\n\n// 기존에 사용하던 채널명\nconst LEGACY_CHANNELS = [\n \"암본이수혁 aguking\",\n];\n\n// 채널 표시 이름\nconst CHANNEL_NAME_MAP: Record = {\n [PRIMARY_CHANNEL]: PRIMARY_CHANNEL,\n \"암본이수혁 aguking\": PRIMARY_CHANNEL,\n};\n\nconst AUTO_REFRESH_INTERVAL_MS = 15000;\n\nfunction label(item: string): string {\n const emoji = EMOJI_MAP[item];\n return emoji ? `${emoji} ${item}` : item;\n}\n\nfunction channelLabel(ch: string): string {\n return CHANNEL_NAME_MAP[ch] || ch;\n}\n\n// ─────────────────────────────────────────────\n// Channel Validation Helpers (Patched)\n// ─────────────────────────────────────────────\n\nconst MAX_CHANNEL_LENGTH = 100;\nconst MAX_ITEM_LENGTH = 100;\n\n// ── NFC 정규화 헬퍼 (신규) ──\n// Twitch/Nightbot 클라이언트에 따라 한글이 조합형(NFD)으로 전달되는 경우가 있어\n// 문자열 비교(===)가 실패하는 문제를 방지하기 위해 항상 완성형(NFC)으로 통일한다.\nfunction toNfc(value: string): string {\n try {\n return String(value ?? \"\").normalize(\"NFC\");\n } catch {\n return String(value ?? \"\");\n }\n}\n\nfunction normalizeChannel(channel: string): string {\n const trimmed = toNfc(String(channel ?? \"\").trim());\n if (trimmed === \"암본이수혁 aguking\") return PRIMARY_CHANNEL;\n return trimmed || PRIMARY_CHANNEL;\n}\n\nfunction isSafeChannelName(channel: string): boolean {\n return (\n typeof channel === \"string\" &&\n channel.length > 0 &&\n channel.length <= MAX_CHANNEL_LENGTH &&\n !/[\\x00-\\x1F\\x7F]/.test(channel)\n );\n}\n\nfunction isSafeItemName(item: string): boolean {\n return (\n typeof item === \"string\" &&\n item.length > 0 &&\n item.length <= MAX_ITEM_LENGTH &&\n !/[\\x00-\\x1F\\x7F]/.test(item)\n );\n}\n\n// ─────────────────────────────────────────────\n// Monitor HTML\n// ─────────────────────────────────────────────\n\nconst MONITOR_HTML = `\n\n\n\n\nStack Monitoring\n\n\n\n\n\n

\n\n\n\n

\n\n채널\n\n

\n \n\n \n

\n\n

\n\n\n\n

\n\n

\n 불러오는 중...\n

\n\n\n\n

\n\n\n\n\n`;\n\n// ─────────────────────────────────────────────\n// Admin HTML\n// ─────────────────────────────────────────────\n\nconst ADMIN_HTML = `\n\n\n\n\nStack Admin\n\n\n\n\n\n

\n\n

Stack Admin · aguking-stack

\n\n

\n\n\n \n Maintenance mode\n\n\n

\n 상태 확인 중...\n

\n\n

\n\n채널\n\n

\n \n\n \n

\n\n

\n\n\n\n

\n\n

\n 불러오는 중...\n

\n\n\n\n

\n\n\n\n\n`;\n\n// ─────────────────────────────────────────────\n// History HTML\n// ─────────────────────────────────────────────\n\nconst HISTORY_HTML = `\n\n\n\n\nStack History\n\n\n\n\n\n

\n\n\n\n

\n\n채널\n\n

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

\n\n

\n\n\n\n

\n\n

\n기록을 불러오는 중...\n

\n\n

\n\n\n\n\n\n\n`;\n\n// ─────────────────────────────────────────────\n// ─────────────────────────────────────────────\n// ver. 3 core: security + concurrency + JSON API + dedupe\n// ─────────────────────────────────────────────\n\ntype AdminAccount = {\n username: string;\n password: string;\n};\n\nfunction getAdminAccounts(): Map {\n const rawAccounts = Deno.env.get(\"ADMIN_ACCOUNTS\") || \"\";\n const accounts = new Map();\n\n for (const entry of rawAccounts.split(\",\")) {\n const separatorIndex = entry.indexOf(\":\");\n if (separatorIndex <= 0) continue;\n\n const username = toNfc(entry.slice(0, separatorIndex).trim());\n const password = entry.slice(separatorIndex + 1).trim();\n if (username && password) accounts.set(username, password);\n }\n\n return accounts;\n}\n\nfunction timingSafeEqualText(a: string, b: string): boolean {\n const left = new TextEncoder().encode(a);\n const right = new TextEncoder().encode(b);\n let diff = left.length ^ right.length;\n const length = Math.max(left.length, right.length);\n\n for (let i = 0; i < length; i++) {\n diff |= (left[i] || 0) ^ (right[i] || 0);\n }\n\n return diff === 0;\n}\n\nasync function sha256Hex(value: string): Promise {\n const data = new TextEncoder().encode(value);\n const digest = await crypto.subtle.digest(\"SHA-256\", data);\n return Array.from(new Uint8Array(digest))\n .map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n}\n\nasync function getAuthenticatedAdminUser(req: Request): Promise {\n const accounts = getAdminAccounts();\n if (!accounts.size) return null;\n\n const authHeader = req.headers.get(\"authorization\") || \"\";\n if (!authHeader.startsWith(\"Basic \")) return null;\n\n try {\n const decoded = atob(authHeader.slice(\"Basic \".length));\n const separatorIndex = decoded.indexOf(\":\");\n if (separatorIndex < 0) return null;\n\n const inputUser = toNfc(decoded.slice(0, separatorIndex).trim());\n const inputPassword = decoded.slice(separatorIndex + 1);\n const stored = accounts.get(inputUser);\n if (!stored) return null;\n\n const valid = stored.startsWith(\"sha256$\")\n ? timingSafeEqualText(\n await sha256Hex(inputPassword),\n stored.slice(\"sha256$\".length),\n )\n : timingSafeEqualText(inputPassword, stored);\n\n return valid ? inputUser : null;\n } catch {\n return null;\n }\n}\n\nasync function checkAuth(req: Request): Promise {\n return (await getAuthenticatedAdminUser(req)) !== null;\n}\n\nconst STACK_API_SECRET = Deno.env.get(\"STACK_API_SECRET\") || \"\";\n\nfunction checkStackApiKey(req: Request): boolean {\n if (!STACK_API_SECRET) return false;\n const headerKey = req.headers.get(\"x-stack-key\") || \"\";\n return !!headerKey && timingSafeEqualText(headerKey, STACK_API_SECRET);\n}\n\nasync function checkStackCommandAuth(req: Request): Promise {\n if (await checkAuth(req)) return true;\n return checkStackApiKey(req);\n}\n\nfunction unauthorizedResponse(): Response {\n return jsonResponse({ ok: false, error: \"인증이 필요합니다.\" }, 401, {\n \"WWW-Authenticate\": 'Basic realm=\"Admin Area\", charset=\"UTF-8\"',\n });\n}\n\nfunction forbiddenResponse(): Response {\n return jsonResponse({ ok: false, error: \"권한이 없습니다.\" }, 403);\n}\n\nfunction jsonResponse(\n body: unknown,\n status = 200,\n extraHeaders: Record = {},\n): Response {\n return new Response(JSON.stringify(body), {\n status,\n headers: {\n \"content-type\": \"application/json; charset=utf-8\",\n \"cache-control\": \"no-store\",\n \"x-content-type-options\": \"nosniff\",\n \"referrer-policy\": \"no-referrer\",\n ...extraHeaders,\n },\n });\n}\n\nfunction textResponse(\n body: string,\n status = 200,\n extraHeaders: Record = {},\n): Response {\n return new Response(body, {\n status,\n headers: {\n \"content-type\": \"text/plain; charset=utf-8\",\n \"cache-control\": \"no-store\",\n \"x-content-type-options\": \"nosniff\",\n \"referrer-policy\": \"no-referrer\",\n ...extraHeaders,\n },\n });\n}\n\nfunction htmlResponse(html: string): Response {\n return new Response(html, {\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n \"cache-control\": \"no-store\",\n \"x-content-type-options\": \"nosniff\",\n \"referrer-policy\": \"no-referrer\",\n },\n });\n}\n\n// ─────────────────────────────────────────────\n// Maintenance\n// ─────────────────────────────────────────────\n\nconst MAINTENANCE_KEY = \"system_maintenance\";\nconst MAINTENANCE_MESSAGE = \"🚧 스택봇 점검중입니다.\";\n\nasync function getMaintenanceMode(\n blob: { getJSON: (k: string) => Promise },\n): Promise {\n try {\n const value = await blob.getJSON(MAINTENANCE_KEY) as\n | { on?: boolean }\n | null;\n return value?.on === true;\n } catch {\n return false;\n }\n}\n\nasync function setMaintenanceMode(\n blob: { setJSON: (k: string, v: unknown) => Promise },\n on: boolean,\n): Promise {\n await blob.setJSON(MAINTENANCE_KEY, { on: !!on });\n}\n\n// ─────────────────────────────────────────────\n// Validation / parsing\n// ─────────────────────────────────────────────\n\nfunction roundAmount(n: number): number {\n return Math.round(n * 1e6) / 1e6;\n}\n\nfunction parsePositiveAmount(value: unknown): number | null {\n const s = String(value ?? \"\").trim();\n if (!/^\\d+(?:\\.\\d+)?$/.test(s)) return null;\n\n const n = Number(s);\n if (!Number.isFinite(n) || n <= 0 || n > 1_000_000_000) return null;\n return roundAmount(n);\n}\n\ntype ParsedCommandAmount = {\n item: string;\n amount: number;\n valid: boolean;\n debug: {\n tokens: string[];\n lastToken: string | null;\n treatedLastAsAmount: boolean;\n };\n};\n\nfunction endsWithBareNumber(item: string): boolean {\n return /(^|\\s)-?\\d+(?:\\.\\d+)?$/.test(item.trim());\n}\n\nfunction splitItemAndAmount(rest: string[]): ParsedCommandAmount {\n const tokens = rest.map((token) => toNfc(token.trim())).filter(Boolean);\n if (!tokens.length) {\n return {\n item: \"\",\n amount: 1,\n valid: true,\n debug: { tokens, lastToken: null, treatedLastAsAmount: false },\n };\n }\n if (tokens.length === 1) {\n return {\n item: tokens[0],\n amount: 1,\n valid: true,\n debug: { tokens, lastToken: tokens[0], treatedLastAsAmount: false },\n };\n }\n\n const last = tokens[tokens.length - 1];\n if (!/^-?(?:\\d+(?:\\.\\d+)?)$/.test(last)) {\n return {\n item: tokens.join(\" \"),\n amount: 1,\n valid: true,\n debug: { tokens, lastToken: last, treatedLastAsAmount: false },\n };\n }\n\n const amount = parsePositiveAmount(last);\n if (amount === null) {\n return {\n item: tokens.slice(0, -1).join(\" \"),\n amount: 0,\n valid: false,\n debug: { tokens, lastToken: last, treatedLastAsAmount: true },\n };\n }\n return {\n item: tokens.slice(0, -1).join(\" \"),\n amount,\n valid: true,\n debug: { tokens, lastToken: last, treatedLastAsAmount: true },\n };\n}\n\nfunction validateChannel(raw: unknown): string | null {\n const value = normalizeChannel(String(raw ?? \"\"));\n return isSafeChannelName(value) ? value : null;\n}\n\nfunction normalizeItem(raw: unknown): string {\n return toNfc(String(raw ?? \"\").trim());\n}\n\nfunction sanitizeStack(input: unknown): Record {\n const out: Record = Object.create(null);\n if (!input || typeof input !== \"object\" || Array.isArray(input)) return out;\n\n for (\n const [rawItem, rawValue] of Object.entries(\n input as Record,\n )\n ) {\n const item = normalizeItem(rawItem);\n const value = Number(rawValue);\n if (!isSafeItemName(item) || !Number.isFinite(value) || value <= 0) {\n continue;\n }\n out[item] = roundAmount((out[item] || 0) + value);\n }\n return out;\n}\n\n// ─────────────────────────────────────────────\n// History: bounded + normalized + exact-duplicate removal\n// ─────────────────────────────────────────────\n\nconst MAX_HISTORY_ENTRIES = 200;\nconst MIGRATION_DONE_KEY = \"migration_v3_done\";\n\ninterface HistoryEntry {\n id?: string;\n time: string;\n action: \"추가\" | \"차감\" | \"삭제\" | \"초기화\";\n item?: string;\n source?: \"nightbot\" | \"admin\" | \"api\" | \"youtube-auto\";\n actor?: string;\n amount?: number;\n count?: number;\n}\n\nfunction historyFingerprint(entry: HistoryEntry): string {\n return JSON.stringify([\n entry.time,\n entry.action,\n entry.source || \"\",\n entry.actor || \"\",\n entry.item || \"\",\n entry.amount ?? null,\n entry.count ?? null,\n ]);\n}\n\nfunction sanitizeHistory(input: unknown): HistoryEntry[] {\n if (!Array.isArray(input)) return [];\n\n const seen = new Set();\n const out: HistoryEntry[] = [];\n\n for (const raw of input) {\n if (!raw || typeof raw !== \"object\") continue;\n const e = raw as Partial;\n if (typeof e.time !== \"string\") continue;\n if (![\"추가\", \"차감\", \"삭제\", \"초기화\"].includes(e.action || \"\")) continue;\n\n const item = e.item === undefined ? undefined : normalizeItem(e.item);\n if (item !== undefined && !isSafeItemName(item)) continue;\n\n const amount = e.amount === undefined ? undefined : Number(e.amount);\n const count = e.count === undefined ? undefined : Number(e.count);\n if (amount !== undefined && (!Number.isFinite(amount) || amount <= 0)) {\n continue;\n }\n if (count !== undefined && (!Number.isFinite(count) || count < 0)) continue;\n\n const clean: HistoryEntry = {\n id: typeof e.id === \"string\" ? e.id : undefined,\n time: e.time,\n action: e.action as HistoryEntry[\"action\"],\n ...(typeof e.source === \"string\"\n ? { source: e.source as HistoryEntry[\"source\"] }\n : {}),\n ...(typeof e.actor === \"string\" ? { actor: e.actor.slice(0, 100) } : {}),\n ...(item === undefined ? {} : { item }),\n ...(amount === undefined ? {} : { amount: roundAmount(amount) }),\n ...(count === undefined ? {} : { count: roundAmount(count) }),\n };\n\n const fp = historyFingerprint(clean);\n if (seen.has(fp)) continue;\n seen.add(fp);\n out.push(clean);\n }\n\n return out\n .sort((a, b) => new Date(a.time).getTime() - new Date(b.time).getTime())\n .slice(-MAX_HISTORY_ENTRIES);\n}\n\nasync function readHistory(\n blob: { getJSON: (k: string) => Promise },\n channel: string,\n): Promise {\n try {\n return sanitizeHistory(await blob.getJSON(`history_${channel}`));\n } catch {\n return [];\n }\n}\n\n// 사람이 읽기 좋은 \"누가 초기화했는지\" 라벨.\n// History에 실제로 기록된 source/actor를 그대로 재사용하므로,\n// 나이트봇/관리자/자동초기화(YouTube) 어떤 경로로 초기화되었든 정확하게 반영된다.\nfunction historyActorLabel(entry: HistoryEntry): string {\n if (entry.source === \"youtube-auto\") return \"자동초기화 (YouTube)\";\n if (entry.source === \"admin\") {\n return entry.actor\n ? `관리자 (${entry.actor})`\n : \"관리자\";\n }\n if (entry.source === \"nightbot\") return \"나이트봇\";\n if (entry.source === \"api\") {\n return entry.actor\n ? `API (${entry.actor})`\n : \"API\";\n }\n return \"알 수 없음\";\n}\n\n// 채널의 History에서 가장 최근 \"초기화\" 기록을 찾아 시각/주체를 반환한다.\nasync function getLastResetInfo(\n blob: { getJSON: (k: string) => Promise },\n channel: string,\n): Promise<{ time: string; by: string } | null> {\n const history = await readHistory(blob, channel);\n for (let i = history.length - 1; i >= 0; i--) {\n if (history[i].action === \"초기화\") {\n return { time: history[i].time, by: historyActorLabel(history[i]) };\n }\n }\n return null;\n}\n\nasync function appendHistory(\n blob: {\n getJSON: (k: string) => Promise;\n setJSON: (k: string, v: unknown) => Promise;\n },\n channel: string,\n entry: HistoryEntry,\n): Promise {\n const history = await readHistory(blob, channel);\n const clean: HistoryEntry = {\n ...entry,\n source: entry.source,\n actor: entry.actor,\n item: entry.item === undefined ? undefined : normalizeItem(entry.item),\n amount: entry.amount === undefined ? undefined : roundAmount(entry.amount),\n count: entry.count === undefined ? undefined : roundAmount(entry.count),\n };\n\n const fp = historyFingerprint(clean);\n if (!history.some((e) => historyFingerprint(e) === fp)) {\n history.push(clean);\n }\n\n await blob.setJSON(`history_${channel}`, sanitizeHistory(history));\n}\n\nfunction formatStack(stack: Record): string {\n const keys = Object.keys(stack);\n if (!keys.length) return \"🤖 현재 스택 없음.\";\n return keys.map((k) => `${label(k)} ${roundAmount(stack[k])}`).join(\", \");\n}\n\n// ─────────────────────────────────────────────\n// Legacy data migration / dedupe\n// ─────────────────────────────────────────────\n\nasync function migrateLegacyChannelData(\n blob: {\n getJSON: (k: string) => Promise;\n setJSON: (k: string, v: unknown) => Promise;\n delete: (k: string) => Promise;\n },\n): Promise {\n const newStackKey = `stack_${PRIMARY_CHANNEL}`;\n const newHistoryKey = `history_${PRIMARY_CHANNEL}`;\n let newStack = sanitizeStack(\n await blob.getJSON(newStackKey).catch(() => null),\n );\n let newHistory = sanitizeHistory(\n await blob.getJSON(newHistoryKey).catch(() => null),\n );\n\n for (const legacyChannel of LEGACY_CHANNELS) {\n const legacyStackKey = `stack_${legacyChannel}`;\n const legacyHistoryKey = `history_${legacyChannel}`;\n const legacyStack = sanitizeStack(\n await blob.getJSON(legacyStackKey).catch(() => null),\n );\n const legacyHistory = sanitizeHistory(\n await blob.getJSON(legacyHistoryKey).catch(() => null),\n );\n\n for (const [item, value] of Object.entries(legacyStack)) {\n newStack[item] = roundAmount((newStack[item] || 0) + value);\n }\n newHistory = sanitizeHistory(newHistory.concat(legacyHistory));\n\n await blob.delete(legacyStackKey).catch(() => {});\n await blob.delete(legacyHistoryKey).catch(() => {});\n }\n\n await blob.setJSON(newStackKey, sanitizeStack(newStack));\n await blob.setJSON(newHistoryKey, sanitizeHistory(newHistory));\n}\n\n// ─────────────────────────────────────────────\n// Unified stack action engine (single source of truth)\n// ─────────────────────────────────────────────\n\ntype StackAction = \"추가\" | \"차감\" | \"삭제\" | \"초기화\";\n\ntype ActionResult = {\n ok: boolean;\n action?: StackAction;\n channel: string;\n item?: string;\n amount?: number;\n count?: number;\n stack: Record;\n message: string;\n error?: string;\n};\n\nasync function readStack(\n blob: { getJSON: (k: string) => Promise },\n channel: string,\n): Promise> {\n try {\n return sanitizeStack(await blob.getJSON(`stack_${channel}`));\n } catch {\n return Object.create(null);\n }\n}\n\nasync function writeStack(\n blob: { setJSON: (k: string, v: unknown) => Promise },\n channel: string,\n stack: Record,\n): Promise {\n await blob.setJSON(`stack_${channel}`, sanitizeStack(stack));\n}\n\nasync function applyStackAction(\n blob: {\n getJSON: (k: string) => Promise;\n setJSON: (k: string, v: unknown) => Promise;\n delete: (k: string) => Promise;\n },\n channel: string,\n action: StackAction,\n rawItem?: unknown,\n rawAmount?: unknown,\n historyMeta: Pick = {},\n): Promise {\n const item = normalizeItem(rawItem);\n const amount = rawAmount === undefined ? 1 : parsePositiveAmount(rawAmount);\n const stack = await readStack(blob, channel);\n\n if (action === \"초기화\") {\n await blob.delete(`stack_${channel}`);\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action: \"초기화\",\n ...historyMeta,\n });\n return {\n ok: true,\n action,\n channel,\n stack: Object.create(null),\n message: \"스택을 초기화했습니다.\",\n };\n }\n\n if (!item) {\n return {\n ok: false,\n channel,\n stack,\n message: \"항목을 입력해주세요.\",\n error: \"INVALID_ITEM\",\n };\n }\n if (!isSafeItemName(item)) {\n return {\n ok: false,\n channel,\n stack,\n message: \"항목 이름은 1~100 자로 입력해주세요.\",\n error: \"INVALID_ITEM\",\n };\n }\n if (amount === null) {\n return {\n ok: false,\n channel,\n item,\n stack,\n message: \"수량은 0 보다 큰 숫자만 입력할 수 있습니다.\",\n error: \"INVALID_AMOUNT\",\n };\n }\n\n if (action === \"추가\") {\n const next = roundAmount((stack[item] || 0) + amount);\n stack[item] = next;\n await writeStack(blob, channel, stack);\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action,\n item,\n amount,\n count: next,\n ...historyMeta,\n });\n return {\n ok: true,\n action,\n channel,\n item,\n amount,\n count: next,\n stack,\n message: `${label(item)} ${next}`,\n };\n }\n\n if (action === \"차감\") {\n if (!(item in stack)) {\n return {\n ok: false,\n action,\n channel,\n item,\n amount,\n stack,\n message: `${label(item)} 항목이 없습니다.`,\n error: \"NOT_FOUND\",\n };\n }\n const next = roundAmount(stack[item] - amount);\n if (next <= 0) {\n delete stack[item];\n await writeStack(blob, channel, stack);\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action,\n item,\n amount,\n count: 0,\n ...historyMeta,\n });\n return {\n ok: true,\n action,\n channel,\n item,\n amount,\n count: 0,\n stack,\n message: `${label(item)} 0 이하가 되어 삭제했습니다.`,\n };\n }\n stack[item] = next;\n await writeStack(blob, channel, stack);\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action,\n item,\n amount,\n count: next,\n ...historyMeta,\n });\n return {\n ok: true,\n action,\n channel,\n item,\n amount,\n count: next,\n stack,\n message: `${label(item)} ${next}`,\n };\n }\n\n if (!(item in stack)) {\n return {\n ok: false,\n action,\n channel,\n item,\n stack,\n message: `${label(item)} 항목이 없습니다.`,\n error: \"NOT_FOUND\",\n };\n }\n delete stack[item];\n await writeStack(blob, channel, stack);\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action,\n item,\n ...historyMeta,\n });\n return {\n ok: true,\n action,\n channel,\n item,\n stack,\n message: `${label(item)} 삭제했습니다.`,\n };\n}\n\n// ─────────────────────────────────────────────\n// Concurrency: serialize every mutation by normalized channel.\n// NOTE: this protects concurrent requests handled by the same runtime.\n// A distributed blob backend would need native CAS/transaction support for\n// cross-instance atomicity; this version never pretends the in-memory lock is distributed.\n// ─────────────────────────────────────────────\n\nconst channelLocks = new Map>();\n\nasync function withChannelLock(\n channel: string,\n task: () => Promise,\n): Promise {\n const previous = channelLocks.get(channel) || Promise.resolve();\n let release!: () => void;\n const current = new Promise((resolve) => {\n release = resolve;\n });\n channelLocks.set(channel, current);\n await previous;\n try {\n return await task();\n } finally {\n release();\n if (channelLocks.get(channel) === current) channelLocks.delete(channel);\n }\n}\n\n// ─────────────────────────────────────────────\n// JSON API helpers\n// ─────────────────────────────────────────────\n\nconst MAX_JSON_BODY_BYTES = 16 * 1024;\n\nasync function readJsonBody(\n req: Request,\n): Promise | null> {\n const contentLength = Number(req.headers.get(\"content-length\") || 0);\n if (Number.isFinite(contentLength) && contentLength > MAX_JSON_BODY_BYTES) {\n return null;\n }\n try {\n const text = await req.text();\n if (new TextEncoder().encode(text).byteLength > MAX_JSON_BODY_BYTES) {\n return null;\n }\n const body = JSON.parse(text);\n return body && typeof body === \"object\" && !Array.isArray(body)\n ? body as Record\n : null;\n } catch {\n return null;\n }\n}\n\nfunction sameOrigin(req: Request, url: URL): boolean {\n const origin = req.headers.get(\"origin\");\n const referer = req.headers.get(\"referer\");\n const valid = (value: string | null) => {\n if (!value) return false;\n try {\n return new URL(value).origin === url.origin;\n } catch {\n return false;\n }\n };\n return valid(origin) || valid(referer);\n}\n\nfunction getValidatedChannel(raw: unknown): string | null {\n const value = toNfc(String(raw ?? \"\").trim());\n // normalizeChannel() intentionally falls back to PRIMARY_CHANNEL for UI defaults,\n // but an API request must explicitly provide a channel.\n if (!value || !isSafeChannelName(value)) return null;\n return normalizeChannel(value);\n}\n\nasync function handleStackJsonApi(req: Request, url: URL, blob: {\n getJSON: (k: string) => Promise;\n setJSON: (k: string, v: unknown) => Promise;\n delete: (k: string) => Promise;\n}): Promise {\n if (req.method === \"GET\") {\n const channel = getValidatedChannel(url.searchParams.get(\"ch\"));\n if (!channel) {\n return jsonResponse(\n { ok: false, error: \"유효하지 않은 채널명입니다.\" },\n 400,\n );\n }\n return await withChannelLock(channel, async () => {\n const stack = await readStack(blob, channel);\n return jsonResponse({\n ok: true,\n channel,\n stack,\n items: Object.entries(stack).map(([item, count]) => ({ item, count })),\n });\n });\n }\n\n if (req.method !== \"POST\") {\n return jsonResponse({ ok: false, error: \"Method Not Allowed\" }, 405, {\n Allow: \"GET, POST\",\n });\n }\n\n if (!(await checkStackCommandAuth(req))) return forbiddenResponse();\n if (!sameOrigin(req, url) && !checkStackApiKey(req)) {\n return forbiddenResponse();\n }\n\n const body = await readJsonBody(req);\n if (!body) {\n return jsonResponse({\n ok: false,\n error: \"JSON body가 올바르지 않거나 너무 큽니다.\",\n }, 400);\n }\n\n const channel = getValidatedChannel(body.channel);\n if (!channel) {\n return jsonResponse(\n { ok: false, error: \"유효하지 않은 채널명입니다.\" },\n 400,\n );\n }\n\n const action = toNfc(String(body.action ?? \"\")) as StackAction;\n if (![\"추가\", \"차감\", \"삭제\", \"초기화\"].includes(action)) {\n return jsonResponse(\n { ok: false, error: \"지원하지 않는 action입니다.\" },\n 400,\n );\n }\n\n const adminUser = await getAuthenticatedAdminUser(req);\n const historyMeta: Pick = adminUser\n ? { source: \"admin\", actor: adminUser }\n : { source: \"api\", actor: \"API Key\" };\n\n return await withChannelLock(channel, async () => {\n const result = await applyStackAction(\n blob,\n channel,\n action,\n body.item,\n body.amount,\n historyMeta,\n );\n return jsonResponse(result, result.ok ? 200 : 400);\n });\n}\n\nasync function handleHistoryJsonApi(\n req: Request,\n url: URL,\n blob: { getJSON: (k: string) => Promise },\n): Promise {\n if (req.method !== \"GET\") {\n return jsonResponse({ ok: false, error: \"Method Not Allowed\" }, 405, {\n Allow: \"GET\",\n });\n }\n const channel = getValidatedChannel(url.searchParams.get(\"ch\"));\n if (!channel) {\n return jsonResponse(\n { ok: false, error: \"유효하지 않은 채널명입니다.\" },\n 400,\n );\n }\n const history = await readHistory(blob, channel);\n return jsonResponse({ ok: true, channel, history });\n}\n\n// ─────────────────────────────────────────────\n// YouTube Live 자동 초기화 (매일 06:00 KST 기준)\n// ─────────────────────────────────────────────\n\nconst YOUTUBE_CHANNEL_ID = \"UC1LiqB9tfyRge5fZ2-7BTVQ\";\nconst YOUTUBE_STACK_CHANNEL = PRIMARY_CHANNEL;\nconst YOUTUBE_API_KEY = Deno.env.get(\"YOUTUBE_API_KEY\") || \"\";\nconst YOUTUBE_AUTO_RESET_KEY = \"youtube_live_auto_reset\";\n\ntype YouTubeLiveState = {\n videoId?: string;\n wasLive?: boolean;\n lastResetDate?: string;\n};\n\nconst KST_OFFSET_MS = 9 * 60 * 60 * 1000;\nconst YOUTUBE_RESET_HOUR_KST = 6;\nconst YOUTUBE_RESET_MINUTE_KST = 0;\n\nfunction isYouTubeResetTimeReachedKst(nowMs = Date.now()): boolean {\n const kst = new Date(nowMs + KST_OFFSET_MS);\n const hour = kst.getUTCHours();\n const minute = kst.getUTCMinutes();\n\n return (\n hour > YOUTUBE_RESET_HOUR_KST ||\n (hour === YOUTUBE_RESET_HOUR_KST &&\n minute >= YOUTUBE_RESET_MINUTE_KST)\n );\n}\n\nfunction getYouTubeResetDateKey(nowMs = Date.now()): string {\n const kst = new Date(nowMs + KST_OFFSET_MS);\n\n if (!isYouTubeResetTimeReachedKst(nowMs)) {\n kst.setUTCDate(kst.getUTCDate() - 1);\n }\n\n return kst.toISOString().slice(0, 10);\n}\n\nasync function getYouTubeLiveVideoId(): Promise {\n if (!YOUTUBE_API_KEY) return null;\n\n const youtubeUrl = new URL(\n \"https://www.googleapis.com/youtube/v3/search\",\n );\n\n youtubeUrl.searchParams.set(\"part\", \"id\");\n youtubeUrl.searchParams.set(\"channelId\", YOUTUBE_CHANNEL_ID);\n youtubeUrl.searchParams.set(\"eventType\", \"live\");\n youtubeUrl.searchParams.set(\"type\", \"video\");\n youtubeUrl.searchParams.set(\"maxResults\", \"1\");\n youtubeUrl.searchParams.set(\"key\", YOUTUBE_API_KEY);\n\n try {\n const response = await fetch(youtubeUrl);\n if (!response.ok) return null;\n\n const data = await response.json() as {\n items?: Array<{ id?: { videoId?: string } }>;\n };\n\n return data.items?.[0]?.id?.videoId || null;\n } catch {\n return null;\n }\n}\n\nasync function getYouTubeLiveState(\n blobStore: { getJSON: (key: string) => Promise },\n): Promise {\n try {\n return (\n (await blobStore.getJSON(YOUTUBE_AUTO_RESET_KEY)) as\n | YouTubeLiveState\n | null\n ) || {};\n } catch {\n return {};\n }\n}\n\nasync function setYouTubeLiveState(\n blobStore: {\n setJSON: (key: string, value: unknown) => Promise;\n },\n state: YouTubeLiveState,\n): Promise {\n await blobStore.setJSON(YOUTUBE_AUTO_RESET_KEY, state);\n}\n\n/**\n * YouTube 자동 초기화의 단일 실행 엔진.\n *\n * Cron으로 실행할 때도, /youtube-check를 수동 호출할 때도\n * 반드시 이 함수 하나만 사용한다.\n *\n * 규칙:\n * - YouTube Live가 아니면 초기화하지 않는다.\n * - KST 06:00 이전에는 초기화하지 않는다.\n * - KST 06:00 이후 해당 업무 날짜에 최초 1회만 초기화한다.\n * - 같은 날짜에 Cron이 여러 번 실행되어도 중복 초기화하지 않는다.\n * - /history에는 실행자/출처를 명시한다.\n */\nasync function runYouTubeAutoReset(\n blobStore: {\n getJSON: (key: string) => Promise;\n setJSON: (key: string, value: unknown) => Promise;\n delete: (key: string) => Promise;\n },\n): Promise<{\n ok: boolean;\n live: boolean;\n reset: boolean;\n resetTimeReached: boolean;\n videoId: string | null;\n resetDate: string | null;\n channel: string;\n reason?: string;\n}> {\n if (!YOUTUBE_API_KEY) {\n return {\n ok: false,\n live: false,\n reset: false,\n resetTimeReached: isYouTubeResetTimeReachedKst(),\n videoId: null,\n resetDate: null,\n channel: YOUTUBE_STACK_CHANNEL,\n reason: \"YOUTUBE_API_KEY 환경변수가 설정되지 않았습니다.\",\n };\n }\n\n return await withChannelLock(YOUTUBE_STACK_CHANNEL, async () => {\n const liveVideoId = await getYouTubeLiveVideoId();\n const previous = await getYouTubeLiveState(blobStore);\n const todayKst = getYouTubeResetDateKey();\n const resetTimeReached = isYouTubeResetTimeReachedKst();\n\n if (!liveVideoId) {\n await setYouTubeLiveState(blobStore, {\n ...previous,\n wasLive: false,\n });\n\n return {\n ok: true,\n live: false,\n reset: false,\n resetTimeReached,\n videoId: null,\n resetDate: previous.lastResetDate || null,\n channel: YOUTUBE_STACK_CHANNEL,\n reason: \"현재 YouTube Live가 아닙니다.\",\n };\n }\n\n if (!resetTimeReached) {\n await setYouTubeLiveState(blobStore, {\n ...previous,\n videoId: liveVideoId,\n wasLive: true,\n });\n\n return {\n ok: true,\n live: true,\n reset: false,\n resetTimeReached: false,\n videoId: liveVideoId,\n resetDate: previous.lastResetDate || null,\n channel: YOUTUBE_STACK_CHANNEL,\n reason: \"06:00 KST 이전이므로 초기화하지 않았습니다.\",\n };\n }\n\n if (previous.lastResetDate === todayKst) {\n await setYouTubeLiveState(blobStore, {\n ...previous,\n videoId: liveVideoId,\n wasLive: true,\n });\n\n return {\n ok: true,\n live: true,\n reset: false,\n resetTimeReached: true,\n videoId: liveVideoId,\n resetDate: todayKst,\n channel: YOUTUBE_STACK_CHANNEL,\n reason: \"오늘 이미 자동 초기화되었습니다.\",\n };\n }\n\n // 초기화와 기록은 같은 채널 lock 안에서 순서대로 처리한다.\n await blobStore.delete(`stack_${YOUTUBE_STACK_CHANNEL}`);\n\n await appendHistory(blobStore, YOUTUBE_STACK_CHANNEL, {\n time: new Date().toISOString(),\n action: \"초기화\",\n source: \"youtube-auto\",\n actor: \"YouTube 자동 초기화\",\n });\n\n await setYouTubeLiveState(blobStore, {\n videoId: liveVideoId,\n wasLive: true,\n lastResetDate: todayKst,\n });\n\n return {\n ok: true,\n live: true,\n reset: true,\n resetTimeReached: true,\n videoId: liveVideoId,\n resetDate: todayKst,\n channel: YOUTUBE_STACK_CHANNEL,\n };\n });\n}\n\n// ─────────────────────────────────────────────\n// Main\n// ─────────────────────────────────────────────\n\ntype HttpOrCronInput =\n | Request\n | {\n lastRunAt?: Date;\n };\n\nfunction isRequestInput(value: HttpOrCronInput): value is Request {\n return value instanceof Request;\n}\n\nexport default async function (\n input: HttpOrCronInput,\n): Promise {\n const { blob } = await import(\"https://esm.town/v/std/blob\");\n\n // ───────────────────────────────────────────\n // Cron entry\n //\n // 같은 Stack_Admin_ver3.3.ts 파일에 CRON Trigger를 붙이면\n // 별도 YouTube Cron 파일 없이 이 파일 자체가 자동 감시기가 된다.\n // Val Town Cron은 Interval 객체를 넘기므로 Request가 아니면 Cron으로 판정한다.\n // ───────────────────────────────────────────\n if (!isRequestInput(input)) {\n const result = await runYouTubeAutoReset(blob);\n const lastReset = await getLastResetInfo(blob, YOUTUBE_STACK_CHANNEL);\n const payload = {\n ...result,\n lastResetTime: lastReset?.time || null,\n lastResetBy: lastReset?.by || null,\n };\n console.log(\n JSON.stringify({\n type: \"youtube-auto-reset\",\n ...payload,\n }),\n );\n return JSON.stringify(payload);\n }\n\n const req = input;\n const url = new URL(req.url);\n\n // One-time migration is itself serialized so two cold-start requests cannot\n // intentionally run the migration in parallel inside this runtime.\n await withChannelLock(\"__migration__\", async () => {\n let migrationDone = false;\n try {\n const state = await blob.getJSON(MIGRATION_DONE_KEY);\n migrationDone = state === true ||\n (state as { done?: boolean } | null)?.done === true;\n } catch {}\n if (!migrationDone) {\n await migrateLegacyChannelData(blob);\n await blob.setJSON(MIGRATION_DONE_KEY, { done: true, version: 3 });\n }\n });\n\n if (url.pathname === \"/admin\") {\n if (!(await checkAuth(req))) return unauthorizedResponse();\n return htmlResponse(ADMIN_HTML);\n }\n if (url.pathname === \"/monitor\") return htmlResponse(MONITOR_HTML);\n if (url.pathname === \"/history\") return htmlResponse(HISTORY_HTML);\n\n if (url.pathname === \"/api/stack\") {\n if (await getMaintenanceMode(blob) && req.method !== \"GET\") {\n return jsonResponse({ ok: false, error: MAINTENANCE_MESSAGE }, 503);\n }\n return handleStackJsonApi(req, url, blob);\n }\n\n if (url.pathname === \"/api/history\") {\n return handleHistoryJsonApi(req, url, blob);\n }\n\n if (url.pathname === \"/admin/maintenance-status\") {\n if (!(await checkAuth(req))) return unauthorizedResponse();\n return jsonResponse({ ok: true, on: await getMaintenanceMode(blob) });\n }\n\n if (url.pathname === \"/admin/maintenance\" && req.method === \"POST\") {\n if (!(await checkAuth(req))) return unauthorizedResponse();\n if (!sameOrigin(req, url)) return forbiddenResponse();\n const body = await readJsonBody(req);\n if (!body || typeof body.on !== \"boolean\") {\n return jsonResponse(\n { ok: false, error: \"on(boolean)이 필요합니다.\" },\n 400,\n );\n }\n await setMaintenanceMode(blob, body.on);\n return jsonResponse({ ok: true, on: body.on });\n }\n\n if (url.pathname === \"/youtube-check\") {\n const checkSecret = Deno.env.get(\"YOUTUBE_CHECK_SECRET\") || \"\";\n if (!checkSecret) {\n return jsonResponse({\n ok: false,\n error: \"YOUTUBE_CHECK_SECRET 환경변수가 설정되지 않았습니다.\",\n }, 500);\n }\n\n const supplied = req.headers.get(\"x-youtube-check-secret\") ||\n url.searchParams.get(\"secret\") ||\n \"\";\n\n if (!timingSafeEqualText(supplied, checkSecret)) {\n return forbiddenResponse();\n }\n\n const result = await runYouTubeAutoReset(blob);\n const lastReset = await getLastResetInfo(blob, YOUTUBE_STACK_CHANNEL);\n\n return jsonResponse({\n ...result,\n lastResetTime: lastReset?.time || null,\n lastResetBy: lastReset?.by || null,\n });\n }\n\n // Legacy Nightbot/text API. Kept only for compatibility; all state mutation\n // goes through the same applyStackAction() engine as the JSON API.\n const requestedQuery = toNfc((url.searchParams.get(\"q\") || \"\").trim());\n const rawChannel = toNfc((url.searchParams.get(\"ch\") || \"\").trim());\n const channel = getValidatedChannel(rawChannel);\n\n if (!channel) return textResponse(\"채널명을 입력해주세요.\", 400);\n if (requestedQuery && !(await checkStackCommandAuth(req))) {\n return forbiddenResponse();\n }\n if (await getMaintenanceMode(blob)) {\n return textResponse(MAINTENANCE_MESSAGE, 503);\n }\n\n const adminUser = requestedQuery\n ? await getAuthenticatedAdminUser(req)\n : null;\n const historyMeta: Pick = adminUser\n ? { source: \"admin\", actor: adminUser }\n : { source: \"nightbot\", actor: \"Nightbot\" };\n\n return await withChannelLock(channel, async () => {\n if (!requestedQuery) {\n return textResponse(formatStack(await readStack(blob, channel)));\n }\n\n const parts = requestedQuery.split(/\\s+/);\n const command = parts[0];\n\n if (command === \"기록초기화\") {\n if (!(await checkStackCommandAuth(req))) return forbiddenResponse();\n await blob.delete(`history_${channel}`);\n return textResponse(\"기록 (History) 을 초기화했습니다.\");\n }\n\n if (command === \"추가\" || command === \"차감\" || command === \"빼기\") {\n const parsed = splitItemAndAmount(parts.slice(1));\n if (!parsed.item) {\n return textResponse(\n command === \"추가\"\n ? \"사용법 : !스택 추가 [항목] [숫자 (생략가능, 소수 가능)]\"\n : \"사용법 : !스택 차감 (빼기) [항목] [숫자 (생략가능, 소수 가능)]\",\n );\n }\n if (!parsed.valid) {\n return textResponse(\n `수량은 0 보다 큰 숫자만 입력할 수 있습니다. (인식된 수량 토큰: \"${\n parsed.debug.lastToken ?? \"\"\n }\")`,\n );\n }\n if (command === \"추가\" && endsWithBareNumber(parsed.item)) {\n return textResponse(\n `항목 이름(\"${parsed.item}\") 끝에 숫자가 포함되어 있어 추가하지 않았습니다.`,\n );\n }\n\n const result = await applyStackAction(\n blob,\n channel,\n command === \"추가\" ? \"추가\" : \"차감\",\n parsed.item,\n parsed.amount,\n historyMeta,\n );\n return textResponse(result.message, result.ok ? 200 : 400);\n }\n\n if (command === \"삭제\") {\n const item = parts.slice(1).join(\" \");\n const result = await applyStackAction(\n blob,\n channel,\n \"삭제\",\n item,\n undefined,\n historyMeta,\n );\n return textResponse(result.message, result.ok ? 200 : 400);\n }\n\n if (command === \"초기화\") {\n const result = await applyStackAction(\n blob,\n channel,\n \"초기화\",\n undefined,\n undefined,\n historyMeta,\n );\n return textResponse(result.message, result.ok ? 200 : 400);\n }\n\n return textResponse(\n \"알 수 없는 명령입니다. (추가/차감/삭제/초기화/기록초기화 지원)\",\n 400,\n );\n });\n}","// Update. 2026-09-05. ver. 2.3 - 전송 테스트\n//\n// 변경사항\n// 1. \"암본이수혁 aguking\" → \"암본이수혁aguking\" 통일\n// 2. 기존 데이터 자동 마이그레이션\n// 3. Admin 403 문제 수정 — credentials: \"same-origin\" 유지\n// 4. Admin API 오류 표시 개선\n// 5. 음수/0 수량 입력 방지\n// 6. Monitor / History / Admin / YouTube 자동 초기화 유지\n// 7. [수정] /monitor, /admin 에서 API 호출 경로 문제 해결 — window.location.origin 사용\n// 8. [수정] 채널명 검증 강화 — 빈 문자열, 100 자 초과, 제어 문자 차단\n// 9. [수정] normalizeChannel 안전 처리 — 빈 값이면 PRIMARY_CHANNEL 반환\n//\n// 보안\n// - Stack API: 관리자 Basic Auth + Nightbot key 호환\n// - Admin Basic 인증\n// - YouTube check secret fail-closed\n// - Admin maintenance Origin / Referer 검증\n// - DOM textContent 기반 렌더링\n//\n// Nightbot\n// !스택 $(urlfetch $(eval `https://aguking-stack.val.run/?ch=${encodeURIComponent(\"$(channel)\")}&q=${encodeURIComponent(\"$(querystring)\")}&key=A`))\n//\n// Timer\n// $(urlfetch $(eval `https://aguking-stack.val.run/?ch=${encodeURIComponent(\"$(channel)\")}&q=&key=A`))\n\nconst EMOJI_MAP: Record = {\n \"금연\": \"🚭\",\n \"흡연\": \"🚬\",\n \"먹어\": \"🍚\",\n \"먹지마\": \"🚫\",\n \"짠\": \"🍻\",\n \"오늘의 재미\": \"🤣\",\n \"무서움 지수\": \"👻\",\n};\n\n// 현재 사용하는 정식 채널명\nconst PRIMARY_CHANNEL = \"암본이수혁aguking\";\n\n// 기존에 사용하던 채널명\nconst LEGACY_CHANNELS = [\n \"암본이수혁 aguking\",\n];\n\n// 채널 표시 이름\nconst CHANNEL_NAME_MAP: Record = {\n [PRIMARY_CHANNEL]: PRIMARY_CHANNEL,\n \"암본이수혁 aguking\": PRIMARY_CHANNEL,\n};\n\nconst AUTO_REFRESH_INTERVAL_MS = 15000;\n\nfunction label(item: string): string {\n const emoji = EMOJI_MAP[item];\n return emoji ? `${emoji} ${item}` : item;\n}\n\nfunction channelLabel(ch: string): string {\n return CHANNEL_NAME_MAP[ch] || ch;\n}\n\n// ─────────────────────────────────────────────\n// Monitor HTML\n// ─────────────────────────────────────────────\n\nconst MONITOR_HTML = `\n\n\n\n\nStack Monitoring\n\n\n\n\n\n

\n\n\n\n

\n\n채널\n\n

\n \n\n \n

\n\n

\n\n\n\n

\n\n

\n 불러오는 중...\n

\n\n\n\n

\n\n

Stack Admin · aguking-stack

\n\n

\n\n\n \n Maintenance mode\n\n\n

\n 상태 확인 중...\n

\n\n

\n\n채널\n\n

\n \n\n \n

\n\n

\n\n\n\n

\n\n

\n 불러오는 중...\n

\n\n\n\n

\n\n\n\n\n`;\n\n// ─────────────────────────────────────────────\n// History HTML (기존 유지, API 경로만 동일하게 수정)\n// ─────────────────────────────────────────────\n\nconst HISTORY_HTML = `\n\n\n\n\nStack History\n\n\n\n\n\n

\n\n\n\n

\n\n채널\n\n

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

\n\n

\n\n\n\n

\n\n

\n기록을 불러오는 중...\n

\n\n

\n\n\n\n\n\n\n`;\n\n// ─────────────────────────────────────────────\n// 관리자 인증\n// ─────────────────────────────────────────────\n\ntype AdminAccount = {\n username: string;\n password: string;\n};\n\nfunction getAdminAccounts(): Map {\n const rawAccounts = Deno.env.get(\"ADMIN_ACCOUNTS\") || \"\";\n const accounts = new Map();\n\n for (const entry of rawAccounts.split(\",\")) {\n const separatorIndex = entry.indexOf(\":\");\n if (separatorIndex <= 0) continue;\n\n const username = entry.slice(0, separatorIndex).trim();\n const password = entry.slice(separatorIndex + 1).trim();\n\n if (username && password) {\n accounts.set(username, password);\n }\n }\n\n return accounts;\n}\n\nfunction timingSafeEqualText(a: string, b: string): boolean {\n const left = new TextEncoder().encode(a);\n const right = new TextEncoder().encode(b);\n let diff = left.length ^ right.length;\n const length = Math.max(left.length, right.length);\n\n for (let i = 0; i < length; i++) {\n diff |= (left[i] || 0) ^ (right[i] || 0);\n }\n\n return diff === 0;\n}\n\nasync function sha256Hex(value: string): Promise {\n const data = new TextEncoder().encode(value);\n const digest = await crypto.subtle.digest(\"SHA-256\", data);\n return Array.from(new Uint8Array(digest))\n .map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n}\n\nasync function checkAuth(req: Request): Promise {\n const accounts = getAdminAccounts();\n if (!accounts.size) return false;\n\n const authHeader = req.headers.get(\"authorization\") || \"\";\n if (!authHeader.startsWith(\"Basic \")) return false;\n\n try {\n const decoded = atob(authHeader.slice(\"Basic \".length));\n const separatorIndex = decoded.indexOf(\":\");\n if (separatorIndex < 0) return false;\n\n const inputUser = decoded.slice(0, separatorIndex).trim();\n const inputPassword = decoded.slice(separatorIndex + 1);\n const stored = accounts.get(inputUser);\n if (!stored) return false;\n\n if (stored.startsWith(\"sha256$\")) {\n const expectedHash = stored.slice(\"sha256$\".length);\n const actualHash = await sha256Hex(inputPassword);\n return timingSafeEqualText(actualHash, expectedHash);\n }\n\n return timingSafeEqualText(inputPassword, stored);\n } catch {\n return false;\n }\n}\n\n// ─────────────────────────────────────────────\n// Stack API 인증\n// ─────────────────────────────────────────────\n\nconst STACK_API_SECRET = Deno.env.get(\"STACK_API_SECRET\") || \"\";\n\nfunction checkStackApiKey(req: Request): boolean {\n if (!STACK_API_SECRET) return false;\n\n const headerKey = req.headers.get(\"x-stack-key\");\n if (headerKey) return timingSafeEqualText(headerKey, STACK_API_SECRET);\n\n const url = new URL(req.url);\n const queryKey = url.searchParams.get(\"key\");\n return !!queryKey && timingSafeEqualText(queryKey, STACK_API_SECRET);\n}\n\nasync function checkStackCommandAuth(req: Request): Promise {\n if (await checkAuth(req)) return true;\n return checkStackApiKey(req);\n}\n\nfunction forbiddenResponse(): Response {\n return new Response(\"권한이 없습니다.\", {\n status: 403,\n headers: { \"content-type\": \"text/plain; charset=utf-8\" },\n });\n}\n\nfunction unauthorizedResponse(): Response {\n return new Response(\"인증이 필요합니다.\", {\n status: 401,\n headers: {\n \"content-type\": \"text/plain; charset=utf-8\",\n \"WWW-Authenticate\": 'Basic realm=\"Admin Area\", charset=\"UTF-8\"',\n },\n });\n}\n\nfunction htmlResponse(html: string): Response {\n return new Response(html, {\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n \"cache-control\": \"no-store\",\n \"x-content-type-options\": \"nosniff\",\n \"referrer-policy\": \"no-referrer\",\n },\n });\n}\n\n// ─────────────────────────────────────────────\n// Maintenance\n// ─────────────────────────────────────────────\n\nconst MAINTENANCE_KEY = \"system_maintenance\";\nconst MAINTENANCE_MESSAGE = \"⚙ 스택명령어 점검중입니다.\";\n\nasync function getMaintenanceMode(\n blob: { getJSON: (k: string) => Promise },\n): Promise {\n try {\n const v = await blob.getJSON(MAINTENANCE_KEY) as { on?: boolean } | null;\n return !!v?.on;\n } catch {\n return false;\n }\n}\n\nasync function setMaintenanceMode(\n blob: { setJSON: (k: string, v: unknown) => Promise },\n on: boolean,\n): Promise {\n await blob.setJSON(MAINTENANCE_KEY, { on });\n}\n\n// ─────────────────────────────────────────────\n// 수량 / 항목명 파싱\n// ─────────────────────────────────────────────\n\nfunction roundAmount(n: number): number {\n return Math.round(n * 1e6) / 1e6;\n}\n\nfunction parsePositiveAmount(value: string): number | null {\n const s = String(value).trim();\n if (!/^\\\\d+(?:\\\\.\\\\d+)?$/.test(s)) return null;\n\n const n = Number(s);\n if (!Number.isFinite(n) || n <= 0) return null;\n\n return roundAmount(n);\n}\n\ntype ParsedCommandAmount = {\n item: string;\n amount: number;\n valid: boolean;\n debug: {\n tokens: string[];\n lastToken: string | null;\n treatedLastAsAmount: boolean;\n };\n};\n\nfunction endsWithBareNumber(item: string): boolean {\n return /(^|\\\\s)-?\\\\d+(?:\\\\.\\\\d+)?$/.test(item.trim());\n}\n\nfunction splitItemAndAmount(rest: string[]): ParsedCommandAmount {\n const tokens = rest.map((token) => token.trim()).filter(Boolean);\n\n if (tokens.length === 0) {\n return {\n item: \"\",\n amount: 1,\n valid: true,\n debug: { tokens, lastToken: null, treatedLastAsAmount: false },\n };\n }\n\n if (tokens.length === 1) {\n return {\n item: tokens[0],\n amount: 1,\n valid: true,\n debug: { tokens, lastToken: tokens[0], treatedLastAsAmount: false },\n };\n }\n\n const last = tokens[tokens.length - 1];\n const lastLooksNumeric = /^-?(?:\\\\d+(?:\\\\.\\\\d+)?)$/.test(last);\n\n if (!lastLooksNumeric) {\n return {\n item: tokens.join(\" \"),\n amount: 1,\n valid: true,\n debug: { tokens, lastToken: last, treatedLastAsAmount: false },\n };\n }\n\n const amount = parsePositiveAmount(last);\n\n if (amount === null) {\n return {\n item: tokens.slice(0, -1).join(\" \"),\n amount: 0,\n valid: false,\n debug: { tokens, lastToken: last, treatedLastAsAmount: true },\n };\n }\n\n return {\n item: tokens.slice(0, -1).join(\" \"),\n amount,\n valid: true,\n debug: { tokens, lastToken: last, treatedLastAsAmount: true },\n };\n}\n\n// ─────────────────────────────────────────────\n// History\n// ─────────────────────────────────────────────\n\nconst MAX_HISTORY_ENTRIES = 200;\nconst MIGRATION_DONE_KEY = \"migration_v1_done\";\n\ninterface HistoryEntry {\n time: string;\n action: \"추가\" | \"차감\" | \"삭제\" | \"초기화\";\n item?: string;\n amount?: number;\n count?: number;\n}\n\nasync function appendHistory(\n blob: {\n getJSON: (k: string) => Promise;\n setJSON: (k: string, v: unknown) => Promise;\n },\n channel: string,\n entry: HistoryEntry,\n): Promise {\n const key = `history_${channel}`;\n let history: HistoryEntry[] = [];\n\n try {\n const existing = await blob.getJSON(key);\n if (Array.isArray(existing)) {\n history = existing as HistoryEntry[];\n }\n } catch {\n history = [];\n }\n\n history.push(entry);\n\n if (history.length > MAX_HISTORY_ENTRIES) {\n history = history.slice(history.length - MAX_HISTORY_ENTRIES);\n }\n\n await blob.setJSON(key, history);\n}\n\nfunction formatStack(stack: Record): string {\n const keys = Object.keys(stack);\n if (!keys.length) return \"저장된 항목이 없습니다.\";\n\n return keys\n .map((k) => `${label(k)} ${roundAmount(stack[k])}`)\n .join(\", \");\n}\n\n// ─────────────────────────────────────────────\n// 채널명 정규화 (수정됨)\n// ─────────────────────────────────────────────\n\nfunction normalizeChannel(channel: string): string {\n const trimmed = String(channel || \"\").trim();\n if (trimmed === \"암본이수혁 aguking\") return PRIMARY_CHANNEL;\n // 빈 문자열이면 기본 채널명 반환\n return trimmed || PRIMARY_CHANNEL;\n}\n\nconst MAX_CHANNEL_LENGTH = 100;\nconst MAX_ITEM_LENGTH = 100;\n\nfunction isSafeChannelName(channel: string): boolean {\n return (\n typeof channel === \"string\" &&\n channel.length > 0 &&\n channel.length <= MAX_CHANNEL_LENGTH &&\n !/[\\\\u0000-\\\\u001F\\\\u007F]/.test(channel)\n );\n}\n\nfunction isSafeItemName(item: string): boolean {\n return (\n typeof item === \"string\" &&\n item.length > 0 &&\n item.length <= MAX_ITEM_LENGTH &&\n !/[\\\\u0000-\\\\u001F\\\\u007F]/.test(item)\n );\n}\n\n// ─────────────────────────────────────────────\n// 기존 데이터 자동 마이그레이션\n// ─────────────────────────────────────────────\n\nasync function migrateLegacyChannelData(\n blob: {\n getJSON: (k: string) => Promise;\n setJSON: (k: string, v: unknown) => Promise;\n delete: (k: string) => Promise;\n },\n): Promise {\n const newStackKey = `stack_${PRIMARY_CHANNEL}`;\n const newHistoryKey = `history_${PRIMARY_CHANNEL}`;\n\n let newStack: Record = Object.create(null);\n let newHistory: HistoryEntry[] = [];\n\n try {\n const existing = await blob.getJSON(newStackKey);\n if (existing && typeof existing === \"object\" && !Array.isArray(existing)) {\n newStack = Object.assign(\n Object.create(null),\n existing as Record,\n );\n }\n } catch {}\n\n try {\n const existing = await blob.getJSON(newHistoryKey);\n if (Array.isArray(existing)) {\n newHistory = existing as HistoryEntry[];\n }\n } catch {}\n\n let stackChanged = false;\n let historyChanged = false;\n\n for (const legacyChannel of LEGACY_CHANNELS) {\n const legacyStackKey = `stack_${legacyChannel}`;\n const legacyHistoryKey = `history_${legacyChannel}`;\n\n let legacyStack: Record | null = null;\n let legacyHistory: HistoryEntry[] | null = null;\n\n try {\n const existing = await blob.getJSON(legacyStackKey);\n if (\n existing && typeof existing === \"object\" && !Array.isArray(existing)\n ) {\n legacyStack = existing as Record;\n }\n } catch {}\n\n try {\n const existing = await blob.getJSON(legacyHistoryKey);\n if (Array.isArray(existing)) {\n legacyHistory = existing as HistoryEntry[];\n }\n } catch {}\n\n if (legacyStack) {\n for (const [item, value] of Object.entries(legacyStack)) {\n const n = Number(value);\n if (Number.isFinite(n) && n > 0) {\n newStack[item] = roundAmount((newStack[item] || 0) + n);\n stackChanged = true;\n }\n }\n await blob.delete(legacyStackKey);\n }\n\n if (legacyHistory) {\n newHistory = newHistory.concat(legacyHistory);\n historyChanged = true;\n await blob.delete(legacyHistoryKey);\n }\n }\n\n if (stackChanged) {\n await blob.setJSON(newStackKey, newStack);\n }\n\n if (historyChanged) {\n newHistory = newHistory\n .filter((e) => e && typeof e.time === \"string\")\n .sort((a, b) => new Date(a.time).getTime() - new Date(b.time).getTime())\n .slice(-MAX_HISTORY_ENTRIES);\n\n await blob.setJSON(newHistoryKey, newHistory);\n }\n}\n\n// ─────────────────────────────────────────────\n// YouTube Live 자동 초기화\n// ─────────────────────────────────────────────\n\nconst YOUTUBE_CHANNEL_ID = \"UC1LiqB9tfyRge5fZ2-7BTVQ\";\nconst YOUTUBE_STACK_CHANNEL = PRIMARY_CHANNEL;\nconst YOUTUBE_API_KEY = Deno.env.get(\"YOUTUBE_API_KEY\") || \"\";\nconst YOUTUBE_AUTO_RESET_KEY = \"youtube_live_auto_reset\";\n\ntype YouTubeLiveState = {\n videoId?: string;\n wasLive?: boolean;\n lastResetDate?: string;\n};\n\nconst KST_OFFSET_MS = 9 * 60 * 60 * 1000;\n\nfunction getKstDateKey(): string {\n const kst = new Date(Date.now() + KST_OFFSET_MS);\n return kst.toISOString().slice(0, 10);\n}\n\nasync function getYouTubeLiveVideoId(): Promise {\n if (!YOUTUBE_API_KEY) return null;\n\n const youtubeUrl = new URL(\"https://www.googleapis.com/youtube/v3/search\");\n youtubeUrl.searchParams.set(\"part\", \"id\");\n youtubeUrl.searchParams.set(\"channelId\", YOUTUBE_CHANNEL_ID);\n youtubeUrl.searchParams.set(\"eventType\", \"live\");\n youtubeUrl.searchParams.set(\"type\", \"video\");\n youtubeUrl.searchParams.set(\"maxResults\", \"1\");\n youtubeUrl.searchParams.set(\"key\", YOUTUBE_API_KEY);\n\n try {\n const response = await fetch(youtubeUrl);\n if (!response.ok) return null;\n\n const data = await response.json() as {\n items?: Array<{ id?: { videoId?: string } }>;\n };\n\n return data.items?.[0]?.id?.videoId || null;\n } catch {\n return null;\n }\n}\n\nasync function getYouTubeLiveState(\n blob: { getJSON: (key: string) => Promise },\n): Promise {\n try {\n return (await blob.getJSON(YOUTUBE_AUTO_RESET_KEY)) as YouTubeLiveState ||\n {};\n } catch {\n return {};\n }\n}\n\nasync function setYouTubeLiveState(\n blob: { setJSON: (key: string, value: unknown) => Promise },\n state: YouTubeLiveState,\n): Promise {\n await blob.setJSON(YOUTUBE_AUTO_RESET_KEY, state);\n}\n\n// ─────────────────────────────────────────────\n// Main\n// ─────────────────────────────────────────────\n\nconst channelLocks = new Map>();\n\nasync function withChannelLock(\n channel: string,\n task: () => Promise,\n): Promise {\n const previous = channelLocks.get(channel) || Promise.resolve();\n let release!: () => void;\n const current = new Promise((resolve) => {\n release = resolve;\n });\n channelLocks.set(channel, current);\n\n await previous;\n try {\n return await task();\n } finally {\n release();\n if (channelLocks.get(channel) === current) {\n channelLocks.delete(channel);\n }\n }\n}\n\nexport default async function (req: Request): Promise {\n const { blob } = await import(\"https://esm.town/v/std/blob\");\n\n const url = new URL(req.url);\n\n let migrationDone = false;\n try {\n const state = await blob.getJSON(MIGRATION_DONE_KEY);\n migrationDone = state === true ||\n (state as { done?: boolean } | null)?.done === true;\n } catch {}\n\n if (!migrationDone) {\n await migrateLegacyChannelData(blob);\n await blob.setJSON(MIGRATION_DONE_KEY, { done: true, version: 1 });\n }\n\n if (url.pathname === \"/admin\") {\n if (!(await checkAuth(req))) return unauthorizedResponse();\n return htmlResponse(ADMIN_HTML);\n }\n\n if (url.pathname === \"/monitor\") {\n return htmlResponse(MONITOR_HTML);\n }\n\n if (url.pathname === \"/history\") {\n return htmlResponse(HISTORY_HTML);\n }\n\n if (url.pathname === \"/youtube-check\") {\n const checkSecret = Deno.env.get(\"YOUTUBE_CHECK_SECRET\") || \"\";\n\n if (!checkSecret) {\n return new Response(\n \"YouTube check is disabled: missing YOUTUBE_CHECK_SECRET\",\n {\n status: 500,\n headers: { \"content-type\": \"text/plain; charset=utf-8\" },\n },\n );\n }\n\n const suppliedCheckSecret = req.headers.get(\"x-youtube-check-secret\") ||\n url.searchParams.get(\"secret\") ||\n \"\";\n\n if (!timingSafeEqualText(suppliedCheckSecret, checkSecret)) {\n return new Response(\"권한이 없습니다.\", {\n status: 403,\n headers: { \"content-type\": \"text/plain; charset=utf-8\" },\n });\n }\n\n if (!YOUTUBE_API_KEY) {\n return new Response(\n JSON.stringify({\n ok: false,\n error: \"YOUTUBE_API_KEY 환경변수가 설정되지 않았습니다.\",\n }),\n {\n status: 500,\n headers: { \"content-type\": \"application/json; charset=utf-8\" },\n },\n );\n }\n\n const liveVideoId = await getYouTubeLiveVideoId();\n const previous = await getYouTubeLiveState(blob);\n const todayKst = getKstDateKey();\n\n if (!liveVideoId) {\n await setYouTubeLiveState(blob, { ...previous, wasLive: false });\n\n return new Response(\n JSON.stringify({\n ok: true,\n live: false,\n reset: false,\n resetDate: previous.lastResetDate || null,\n channel: YOUTUBE_STACK_CHANNEL,\n }),\n { headers: { \"content-type\": \"application/json; charset=utf-8\" } },\n );\n }\n\n const shouldReset = previous.lastResetDate !== todayKst;\n\n if (shouldReset) {\n await blob.delete(`stack_${YOUTUBE_STACK_CHANNEL}`);\n await appendHistory(blob, YOUTUBE_STACK_CHANNEL, {\n time: new Date().toISOString(),\n action: \"초기화\",\n });\n }\n\n await setYouTubeLiveState(blob, {\n videoId: liveVideoId,\n wasLive: true,\n lastResetDate: shouldReset ? todayKst : previous.lastResetDate,\n });\n\n return new Response(\n JSON.stringify({\n ok: true,\n live: true,\n reset: shouldReset,\n videoId: liveVideoId,\n resetDate: shouldReset ? todayKst : previous.lastResetDate,\n channel: YOUTUBE_STACK_CHANNEL,\n }),\n { headers: { \"content-type\": \"application/json; charset=utf-8\" } },\n );\n }\n\n if (url.pathname === \"/admin/maintenance-status\") {\n if (!(await checkAuth(req))) return unauthorizedResponse();\n\n const on = await getMaintenanceMode(blob);\n return new Response(JSON.stringify({ on }), {\n headers: { \"content-type\": \"application/json; charset=utf-8\" },\n });\n }\n\n if (url.pathname === \"/admin/maintenance\" && req.method === \"POST\") {\n if (!(await checkAuth(req))) return unauthorizedResponse();\n\n const origin = req.headers.get(\"origin\");\n const referer = req.headers.get(\"referer\");\n\n const isSameOrigin = (value: string | null): boolean => {\n if (!value) return false;\n try {\n return new URL(value).origin === url.origin;\n } catch {\n return false;\n }\n };\n\n if (!isSameOrigin(origin) && !isSameOrigin(referer)) {\n return new Response(\"Forbidden: cross-origin request\", { status: 403 });\n }\n\n let body: { on?: boolean } = {};\n try {\n body = await req.json();\n } catch {\n body = {};\n }\n\n const on = body.on === true;\n await setMaintenanceMode(blob, on);\n\n return new Response(JSON.stringify({ on }), {\n headers: { \"content-type\": \"application/json; charset=utf-8\" },\n });\n }\n\n if (url.searchParams.get(\"history\") === \"1\") {\n const historyChannel = normalizeChannel(\n url.searchParams.get(\"ch\") || \"default\",\n );\n\n let history: HistoryEntry[] = [];\n try {\n const existing = await blob.getJSON(`history_${historyChannel}`);\n if (Array.isArray(existing)) {\n history = existing as HistoryEntry[];\n }\n } catch {\n history = [];\n }\n\n return new Response(JSON.stringify(history), {\n headers: { \"content-type\": \"application/json; charset=utf-8\" },\n });\n }\n\n if (await getMaintenanceMode(blob)) {\n return new Response(MAINTENANCE_MESSAGE, {\n headers: { \"content-type\": \"text/plain; charset=utf-8\" },\n });\n }\n\n const requestedQuery = (url.searchParams.get(\"q\") || \"\").trim();\n\n if (requestedQuery && !(await checkStackCommandAuth(req))) {\n return forbiddenResponse();\n }\n\n // ─────────────────────────────────────────────\n // 채널명 검증 (수정됨) — raw 값 먼저 검사\n // ─────────────────────────────────────────────\n const rawChannel = (url.searchParams.get(\"ch\") || \"\").trim();\n\n if (!rawChannel) {\n return new Response(\"채널명을 입력해주세요.\", {\n status: 400,\n headers: { \"content-type\": \"text/plain; charset=utf-8\" },\n });\n }\n\n if (\n rawChannel.length > MAX_CHANNEL_LENGTH ||\n /[\\\\u0000-\\\\u001F\\\\u007F]/.test(rawChannel)\n ) {\n return new Response(\"채널명은 1~100 자로 입력해주세요.\", {\n status: 400,\n headers: { \"content-type\": \"text/plain; charset=utf-8\" },\n });\n }\n\n const channelForLock = normalizeChannel(rawChannel);\n\n return await withChannelLock(channelForLock, async () => {\n const channel = normalizeChannel(rawChannel);\n const key = `stack_${channel}`;\n\n let stack: Record = Object.create(null);\n\n try {\n const existing = await blob.getJSON(key);\n if (\n existing && typeof existing === \"object\" && !Array.isArray(existing)\n ) {\n stack = Object.assign(\n Object.create(null),\n existing as Record,\n );\n }\n } catch {\n stack = {};\n }\n\n let stackSanitized = false;\n\n for (const item of Object.keys(stack)) {\n const n = Number(stack[item]);\n\n if (!Number.isFinite(n) || n <= 0) {\n delete stack[item];\n stackSanitized = true;\n } else {\n const rounded = roundAmount(n);\n if (rounded !== stack[item]) {\n stack[item] = rounded;\n stackSanitized = true;\n }\n }\n }\n\n if (stackSanitized) {\n await blob.setJSON(key, stack);\n }\n\n let responseText: string;\n\n if (query === \"\") {\n responseText = formatStack(stack);\n } else {\n const parts = query.split(/\\\\s+/);\n const command = parts[0];\n\n if (command === \"추가\") {\n const parsed = splitItemAndAmount(parts.slice(1));\n\n if (!parsed.item) {\n responseText =\n \"사용법 : !스택 추가 [항목] [숫자 (생략가능, 소수 가능)]\";\n } else if (!parsed.valid) {\n responseText = `수량은 0 보다 큰 숫자만 입력할 수 있습니다. ` +\n `(받은 값: \"${query}\", 인식된 수량 토큰: \"${\n parsed.debug.lastToken ?? \"\"\n }\")`;\n } else if (!isSafeItemName(parsed.item)) {\n responseText = \"항목 이름은 1~100 자로 입력해주세요.\";\n } else if (endsWithBareNumber(parsed.item)) {\n responseText =\n `항목 이름(\"${parsed.item}\") 끝에 숫자가 포함되어 있어 추가하지 않았습니다. ` +\n `항목 이름과 수량을 분리해서 다시 입력해주세요. (받은 값: \"${query}\")`;\n } else {\n const current = Number(stack[parsed.item] || 0);\n stack[parsed.item] = roundAmount(\n Math.max(0, current + parsed.amount),\n );\n\n await blob.setJSON(key, stack);\n\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action: \"추가\",\n item: parsed.item,\n amount: parsed.amount,\n count: stack[parsed.item],\n });\n\n responseText = `${label(parsed.item)} ${stack[parsed.item]}`;\n }\n } else if (command === \"차감\" || command === \"빼기\") {\n const parsed = splitItemAndAmount(parts.slice(1));\n\n if (!parsed.item) {\n responseText =\n \"사용법 : !스택 차감 (빼기) [항목] [숫자 (생략가능, 소수 가능)]\";\n } else if (!parsed.valid) {\n responseText = `수량은 0 보다 큰 숫자만 입력할 수 있습니다. ` +\n `(받은 값: \"${query}\", 인식된 수량 토큰: \"${\n parsed.debug.lastToken ?? \"\"\n }\")`;\n } else if (!isSafeItemName(parsed.item)) {\n responseText = \"항목 이름은 1~100 자로 입력해주세요.\";\n } else if (!(parsed.item in stack)) {\n responseText = `${label(parsed.item)} 항목이 없습니다.`;\n } else {\n const current = Number(stack[parsed.item]);\n const next = roundAmount(current - parsed.amount);\n\n if (next <= 0) {\n delete stack[parsed.item];\n await blob.setJSON(key, stack);\n\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action: \"차감\",\n item: parsed.item,\n amount: parsed.amount,\n count: 0,\n });\n\n responseText = `${label(parsed.item)} 0 이하가 되어 삭제했습니다.`;\n } else {\n stack[parsed.item] = next;\n await blob.setJSON(key, stack);\n\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action: \"차감\",\n item: parsed.item,\n amount: parsed.amount,\n count: next,\n });\n\n responseText = `${label(parsed.item)} ${next}`;\n }\n }\n } else if (command === \"삭제\") {\n const item = parts.slice(1).join(\" \");\n\n if (!item) {\n responseText = \"사용법 : !스택 삭제 [항목]\";\n } else if (!isSafeItemName(item)) {\n responseText = \"항목 이름은 1~100 자로 입력해주세요.\";\n } else if (!(item in stack)) {\n responseText = `${label(item)} 항목이 없습니다.`;\n } else {\n delete stack[item];\n await blob.setJSON(key, stack);\n\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action: \"삭제\",\n item,\n });\n\n responseText = `${label(item)} 삭제했습니다.`;\n }\n } else if (command === \"초기화\") {\n await blob.delete(key);\n\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action: \"초기화\",\n });\n\n responseText = \"스택을 초기화했습니다.\";\n } else if (command === \"기록초기화\") {\n await blob.delete(`history_${channel}`);\n responseText = \"기록 (History) 을 초기화했습니다.\";\n } else {\n responseText =\n \"알 수 없는 명령입니다. (추가/차감/삭제/초기화/기록초기화 지원)\";\n }\n }\n\n return new Response(responseText, {\n headers: { \"content-type\": \"text/plain; charset=utf-8\" },\n });\n });\n}\n","createdAt",["D",1788836063223],"branchVersion","branchId","a669a274-1d8e-4aec-b258-6ada72f2e9bb",{"_34":50,"_36":49,"_37":38,"_39":52,"_42":53,"_44":14,"_45":46,"_28":29},{"_34":50,"_36":49,"_37":38,"_39":51},"excel.ts","b6c0703c-a863-11f1-85c1-1607ee4eb77e","// ver.3.4 FINAL SINGLE-FILE\n// YouTube Live 자동 감지 + 매일 06:00 KST 1회 초기화\n// /history 자동/관리자/실행자 기록 + JSON API + 동시성 + 중복 제거\n//\n// ver.3.4 변경사항:\n// - [버그수정] History 페이지가 존재하지 않는 엔드포인트(?history=1)를 호출하던 문제 수정 → /api/history 사용\n// - /youtube-check 응답에 마지막 초기화 시각(lastResetTime)과 주체(lastResetBy: 나이트봇/관리자/자동초기화 등) 추가\n// - History 페이지에는 이미 초기화 주체가 표시되고 있었음(historySourceLabel) — 그대로 유지\n// - 모니터/관리자/히스토리 3개 페이지의 \"새로고침 (수동)\" 버튼 제거 (자동 새로고침만 유지)\n//\n// IMPORTANT (Val Town):\n// 이 파일 하나에 HTTP와 CRON 두 Trigger를 연결해서 사용한다.\n// - HTTP Trigger: /monitor, /admin, /history, /api/*, /youtube-check\n// - CRON Trigger: 같은 파일을 1분(Pro) 또는 15분(Free) 간격으로 실행\n// Val Town Cron은 UTC 기준이며 코드 내부에서 KST 06:00을 판정한다.\n// 따라서 별도의 YouTube_Live_AutoReset_Cron.ts 파일은 필요 없다.\n//\n// /youtube-check?secret=... 는 수동 점검용이고,\n// 자동 초기화는 CRON Trigger가 직접 runYouTubeAutoReset()을 호출한다.\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nconst EMOJI_MAP: Record = {\n \"금연\": \"🚭\",\n \"흡연\": \"🚬\",\n \"먹어\": \"🍚\",\n \"먹지마\": \"🚫\",\n \"짠\": \"🍻\",\n \"오늘의 재미\": \"🤣\",\n \"무서움 지수\": \"👻\",\n \"문어\": \"🐙\",\n \"꽃게\": \"🦀\",\n \"소라\": \"🐚\",\n};\n\n// 현재 사용하는 정식 채널명\nconst PRIMARY_CHANNEL = \"암본이수혁aguking\";\n\n// 기존에 사용하던 채널명\nconst LEGACY_CHANNELS = [\n \"암본이수혁 aguking\",\n];\n\n// 채널 표시 이름\nconst CHANNEL_NAME_MAP: Record = {\n [PRIMARY_CHANNEL]: PRIMARY_CHANNEL,\n \"암본이수혁 aguking\": PRIMARY_CHANNEL,\n};\n\nconst AUTO_REFRESH_INTERVAL_MS = 15000;\n\nfunction label(item: string): string {\n const emoji = EMOJI_MAP[item];\n return emoji ? `${emoji} ${item}` : item;\n}\n\nfunction channelLabel(ch: string): string {\n return CHANNEL_NAME_MAP[ch] || ch;\n}\n\n// ─────────────────────────────────────────────\n// Channel Validation Helpers (Patched)\n// ─────────────────────────────────────────────\n\nconst MAX_CHANNEL_LENGTH = 100;\nconst MAX_ITEM_LENGTH = 100;\n\n// ── NFC 정규화 헬퍼 (신규) ──\n// Twitch/Nightbot 클라이언트에 따라 한글이 조합형(NFD)으로 전달되는 경우가 있어\n// 문자열 비교(===)가 실패하는 문제를 방지하기 위해 항상 완성형(NFC)으로 통일한다.\nfunction toNfc(value: string): string {\n try {\n return String(value ?? \"\").normalize(\"NFC\");\n } catch {\n return String(value ?? \"\");\n }\n}\n\nfunction normalizeChannel(channel: string): string {\n const trimmed = toNfc(String(channel ?? \"\").trim());\n if (trimmed === \"암본이수혁 aguking\") return PRIMARY_CHANNEL;\n return trimmed || PRIMARY_CHANNEL;\n}\n\nfunction isSafeChannelName(channel: string): boolean {\n return (\n typeof channel === \"string\" &&\n channel.length > 0 &&\n channel.length <= MAX_CHANNEL_LENGTH &&\n !/[\\x00-\\x1F\\x7F]/.test(channel)\n );\n}\n\nfunction isSafeItemName(item: string): boolean {\n return (\n typeof item === \"string\" &&\n item.length > 0 &&\n item.length <= MAX_ITEM_LENGTH &&\n !/[\\x00-\\x1F\\x7F]/.test(item)\n );\n}\n\n// ─────────────────────────────────────────────\n// Monitor HTML\n// ─────────────────────────────────────────────\n\nconst MONITOR_HTML = `\n\n\n\n\nStack Monitoring\n\n\n\n\n\n

\n\n\n\n

\n\n채널\n\n

\n \n\n \n

\n\n

\n\n\n\n

\n\n

\n 불러오는 중...\n

\n\n\n\n

\n\n

Stack Admin · aguking-stack

\n\n

\n\n\n \n Maintenance mode\n\n\n

\n 상태 확인 중...\n

\n\n

\n\n채널\n\n

\n \n\n \n

\n\n

\n\n\n\n

\n\n

\n 불러오는 중...\n

\n\n\n\n

\n\n채널\n\n

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

\n\n

\n\n\n\n

\n\n

\n기록을 불러오는 중...\n

\n\n

\n\n\n\n\n\n\n`;\n\n// ─────────────────────────────────────────────\n// ─────────────────────────────────────────────\n// ver. 3 core: security + concurrency + JSON API + dedupe\n// ─────────────────────────────────────────────\n\ntype AdminAccount = {\n username: string;\n password: string;\n};\n\nfunction getAdminAccounts(): Map {\n const rawAccounts = Deno.env.get(\"ADMIN_ACCOUNTS\") || \"\";\n const accounts = new Map();\n\n for (const entry of rawAccounts.split(\",\")) {\n const separatorIndex = entry.indexOf(\":\");\n if (separatorIndex <= 0) continue;\n\n const username = toNfc(entry.slice(0, separatorIndex).trim());\n const password = entry.slice(separatorIndex + 1).trim();\n if (username && password) accounts.set(username, password);\n }\n\n return accounts;\n}\n\nfunction timingSafeEqualText(a: string, b: string): boolean {\n const left = new TextEncoder().encode(a);\n const right = new TextEncoder().encode(b);\n let diff = left.length ^ right.length;\n const length = Math.max(left.length, right.length);\n\n for (let i = 0; i < length; i++) {\n diff |= (left[i] || 0) ^ (right[i] || 0);\n }\n\n return diff === 0;\n}\n\nasync function sha256Hex(value: string): Promise {\n const data = new TextEncoder().encode(value);\n const digest = await crypto.subtle.digest(\"SHA-256\", data);\n return Array.from(new Uint8Array(digest))\n .map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n}\n\nasync function getAuthenticatedAdminUser(req: Request): Promise {\n const accounts = getAdminAccounts();\n if (!accounts.size) return null;\n\n const authHeader = req.headers.get(\"authorization\") || \"\";\n if (!authHeader.startsWith(\"Basic \")) return null;\n\n try {\n const decoded = atob(authHeader.slice(\"Basic \".length));\n const separatorIndex = decoded.indexOf(\":\");\n if (separatorIndex < 0) return null;\n\n const inputUser = toNfc(decoded.slice(0, separatorIndex).trim());\n const inputPassword = decoded.slice(separatorIndex + 1);\n const stored = accounts.get(inputUser);\n if (!stored) return null;\n\n const valid = stored.startsWith(\"sha256$\")\n ? timingSafeEqualText(\n await sha256Hex(inputPassword),\n stored.slice(\"sha256$\".length),\n )\n : timingSafeEqualText(inputPassword, stored);\n\n return valid ? inputUser : null;\n } catch {\n return null;\n }\n}\n\nasync function checkAuth(req: Request): Promise {\n return (await getAuthenticatedAdminUser(req)) !== null;\n}\n\nconst STACK_API_SECRET = Deno.env.get(\"STACK_API_SECRET\") || \"\";\n\nfunction checkStackApiKey(req: Request): boolean {\n if (!STACK_API_SECRET) return false;\n\n const headerKey = req.headers.get(\"x-stack-key\") || \"\";\n if (headerKey && timingSafeEqualText(headerKey, STACK_API_SECRET)) {\n return true;\n }\n\n // Nightbot의 $(urlfetch ...) 커스텀 명령은 커스텀 헤더를 붙일 수 없어\n // URL 쿼리 파라미터로만 인증할 수 있다. 로그/리퍼러 노출 위험은 있지만\n // Nightbot 연동을 위해 계속 지원한다. 가능하면 헤더 방식(x-stack-key)을\n // 우선 사용하고, 이 경로는 Nightbot 전용으로만 쓰는 걸 권장.\n const url = new URL(req.url);\n const queryKey = url.searchParams.get(\"key\") || \"\";\n return !!queryKey && timingSafeEqualText(queryKey, STACK_API_SECRET);\n}\n\nasync function checkStackCommandAuth(req: Request): Promise {\n if (await checkAuth(req)) return true;\n return checkStackApiKey(req);\n}\n\nfunction unauthorizedResponse(): Response {\n return jsonResponse({ ok: false, error: \"인증이 필요합니다.\" }, 401, {\n \"WWW-Authenticate\": 'Basic realm=\"Admin Area\", charset=\"UTF-8\"',\n });\n}\n\nfunction forbiddenResponse(): Response {\n return jsonResponse({ ok: false, error: \"권한이 없습니다.\" }, 403);\n}\n\nfunction jsonResponse(\n body: unknown,\n status = 200,\n extraHeaders: Record = {},\n): Response {\n return new Response(JSON.stringify(body), {\n status,\n headers: {\n \"content-type\": \"application/json; charset=utf-8\",\n \"cache-control\": \"no-store\",\n \"x-content-type-options\": \"nosniff\",\n \"referrer-policy\": \"no-referrer\",\n ...extraHeaders,\n },\n });\n}\n\nfunction textResponse(\n body: string,\n status = 200,\n extraHeaders: Record = {},\n): Response {\n return new Response(body, {\n status,\n headers: {\n \"content-type\": \"text/plain; charset=utf-8\",\n \"cache-control\": \"no-store\",\n \"x-content-type-options\": \"nosniff\",\n \"referrer-policy\": \"no-referrer\",\n ...extraHeaders,\n },\n });\n}\n\nfunction htmlResponse(html: string): Response {\n return new Response(html, {\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n \"cache-control\": \"no-store\",\n \"x-content-type-options\": \"nosniff\",\n \"referrer-policy\": \"no-referrer\",\n },\n });\n}\n\n// ─────────────────────────────────────────────\n// Maintenance\n// ─────────────────────────────────────────────\n\nconst MAINTENANCE_KEY = \"system_maintenance\";\nconst MAINTENANCE_MESSAGE = \"🚧 스택봇 점검중입니다.\";\n\nasync function getMaintenanceMode(\n blob: { getJSON: (k: string) => Promise },\n): Promise {\n try {\n const value = await blob.getJSON(MAINTENANCE_KEY) as\n | { on?: boolean }\n | null;\n return value?.on === true;\n } catch {\n return false;\n }\n}\n\nasync function setMaintenanceMode(\n blob: { setJSON: (k: string, v: unknown) => Promise },\n on: boolean,\n): Promise {\n await blob.setJSON(MAINTENANCE_KEY, { on: !!on });\n}\n\n// ─────────────────────────────────────────────\n// Validation / parsing\n// ─────────────────────────────────────────────\n\nfunction roundAmount(n: number): number {\n return Math.round(n * 1e6) / 1e6;\n}\n\nfunction parsePositiveAmount(value: unknown): number | null {\n const s = String(value ?? \"\").trim();\n if (!/^\\d+(?:\\.\\d+)?$/.test(s)) return null;\n\n const n = Number(s);\n if (!Number.isFinite(n) || n <= 0 || n > 1_000_000_000) return null;\n return roundAmount(n);\n}\n\ntype ParsedCommandAmount = {\n item: string;\n amount: number;\n valid: boolean;\n debug: {\n tokens: string[];\n lastToken: string | null;\n treatedLastAsAmount: boolean;\n };\n};\n\nfunction endsWithBareNumber(item: string): boolean {\n return /(^|\\s)-?\\d+(?:\\.\\d+)?$/.test(item.trim());\n}\n\nfunction splitItemAndAmount(rest: string[]): ParsedCommandAmount {\n const tokens = rest.map((token) => toNfc(token.trim())).filter(Boolean);\n if (!tokens.length) {\n return {\n item: \"\",\n amount: 1,\n valid: true,\n debug: { tokens, lastToken: null, treatedLastAsAmount: false },\n };\n }\n if (tokens.length === 1) {\n return {\n item: tokens[0],\n amount: 1,\n valid: true,\n debug: { tokens, lastToken: tokens[0], treatedLastAsAmount: false },\n };\n }\n\n const last = tokens[tokens.length - 1];\n if (!/^-?(?:\\d+(?:\\.\\d+)?)$/.test(last)) {\n return {\n item: tokens.join(\" \"),\n amount: 1,\n valid: true,\n debug: { tokens, lastToken: last, treatedLastAsAmount: false },\n };\n }\n\n const amount = parsePositiveAmount(last);\n if (amount === null) {\n return {\n item: tokens.slice(0, -1).join(\" \"),\n amount: 0,\n valid: false,\n debug: { tokens, lastToken: last, treatedLastAsAmount: true },\n };\n }\n return {\n item: tokens.slice(0, -1).join(\" \"),\n amount,\n valid: true,\n debug: { tokens, lastToken: last, treatedLastAsAmount: true },\n };\n}\n\nfunction validateChannel(raw: unknown): string | null {\n const value = normalizeChannel(String(raw ?? \"\"));\n return isSafeChannelName(value) ? value : null;\n}\n\nfunction normalizeItem(raw: unknown): string {\n return toNfc(String(raw ?? \"\").trim());\n}\n\nfunction sanitizeStack(input: unknown): Record {\n const out: Record = Object.create(null);\n if (!input || typeof input !== \"object\" || Array.isArray(input)) return out;\n\n for (\n const [rawItem, rawValue] of Object.entries(\n input as Record,\n )\n ) {\n const item = normalizeItem(rawItem);\n const value = Number(rawValue);\n if (!isSafeItemName(item) || !Number.isFinite(value) || value <= 0) {\n continue;\n }\n out[item] = roundAmount((out[item] || 0) + value);\n }\n return out;\n}\n\n// ─────────────────────────────────────────────\n// History: bounded + normalized + exact-duplicate removal\n// ─────────────────────────────────────────────\n\nconst MAX_HISTORY_ENTRIES = 200;\nconst MIGRATION_DONE_KEY = \"migration_v3_done\";\n\ninterface HistoryEntry {\n id?: string;\n time: string;\n action: \"추가\" | \"차감\" | \"삭제\" | \"초기화\";\n item?: string;\n source?: \"nightbot\" | \"admin\" | \"api\" | \"youtube-auto\";\n actor?: string;\n amount?: number;\n count?: number;\n}\n\nfunction historyFingerprint(entry: HistoryEntry): string {\n return JSON.stringify([\n entry.time,\n entry.action,\n entry.source || \"\",\n entry.actor || \"\",\n entry.item || \"\",\n entry.amount ?? null,\n entry.count ?? null,\n ]);\n}\n\nfunction sanitizeHistory(input: unknown): HistoryEntry[] {\n if (!Array.isArray(input)) return [];\n\n const seen = new Set();\n const out: HistoryEntry[] = [];\n\n for (const raw of input) {\n if (!raw || typeof raw !== \"object\") continue;\n const e = raw as Partial;\n if (typeof e.time !== \"string\") continue;\n if (![\"추가\", \"차감\", \"삭제\", \"초기화\"].includes(e.action || \"\")) continue;\n\n const item = e.item === undefined ? undefined : normalizeItem(e.item);\n if (item !== undefined && !isSafeItemName(item)) continue;\n\n const amount = e.amount === undefined ? undefined : Number(e.amount);\n const count = e.count === undefined ? undefined : Number(e.count);\n if (amount !== undefined && (!Number.isFinite(amount) || amount <= 0)) {\n continue;\n }\n if (count !== undefined && (!Number.isFinite(count) || count < 0)) continue;\n\n const clean: HistoryEntry = {\n id: typeof e.id === \"string\" ? e.id : undefined,\n time: e.time,\n action: e.action as HistoryEntry[\"action\"],\n ...(typeof e.source === \"string\"\n ? { source: e.source as HistoryEntry[\"source\"] }\n : {}),\n ...(typeof e.actor === \"string\" ? { actor: e.actor.slice(0, 100) } : {}),\n ...(item === undefined ? {} : { item }),\n ...(amount === undefined ? {} : { amount: roundAmount(amount) }),\n ...(count === undefined ? {} : { count: roundAmount(count) }),\n };\n\n const fp = historyFingerprint(clean);\n if (seen.has(fp)) continue;\n seen.add(fp);\n out.push(clean);\n }\n\n return out\n .sort((a, b) => new Date(a.time).getTime() - new Date(b.time).getTime())\n .slice(-MAX_HISTORY_ENTRIES);\n}\n\nasync function readHistory(\n blob: { getJSON: (k: string) => Promise },\n channel: string,\n): Promise {\n try {\n return sanitizeHistory(await blob.getJSON(`history_${channel}`));\n } catch {\n return [];\n }\n}\n\n// 사람이 읽기 좋은 \"누가 초기화했는지\" 라벨.\n// History에 실제로 기록된 source/actor를 그대로 재사용하므로,\n// 나이트봇/관리자/자동초기화(YouTube) 어떤 경로로 초기화되었든 정확하게 반영된다.\n// UTC ISO 문자열을 \"YYYY-MM-DD HH:mm:ss\" 형태의 KST(한국시간) 문자열로 변환.\nconst KST_TIME_FORMATTER = new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: \"Asia/Seoul\",\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n hour: \"2-digit\",\n minute: \"2-digit\",\n second: \"2-digit\",\n hour12: false,\n});\n\nfunction toKstString(iso: string): string {\n try {\n const parts = Object.fromEntries(\n KST_TIME_FORMATTER.formatToParts(new Date(iso)).map((\n p,\n ) => [p.type, p.value]),\n );\n return `${parts.year}-${parts.month}-${parts.day} ${parts.hour}:${parts.minute}:${parts.second} (KST)`;\n } catch {\n return iso;\n }\n}\n\nfunction historyActorLabel(entry: HistoryEntry): string {\n if (entry.source === \"youtube-auto\") return \"자동초기화 (YouTube)\";\n if (entry.source === \"admin\") {\n return entry.actor\n ? `관리자 (${entry.actor})`\n : \"관리자\";\n }\n if (entry.source === \"nightbot\") return \"나이트봇\";\n if (entry.source === \"api\") {\n return entry.actor\n ? `API (${entry.actor})`\n : \"API\";\n }\n return \"알 수 없음\";\n}\n\n// 채널의 History에서 가장 최근 \"초기화\" 기록을 찾아 시각/주체를 반환한다.\nasync function getLastResetInfo(\n blob: { getJSON: (k: string) => Promise },\n channel: string,\n): Promise<{ time: string; by: string } | null> {\n const history = await readHistory(blob, channel);\n for (let i = history.length - 1; i >= 0; i--) {\n if (history[i].action === \"초기화\") {\n return { time: history[i].time, by: historyActorLabel(history[i]) };\n }\n }\n return null;\n}\n\nasync function appendHistory(\n blob: {\n getJSON: (k: string) => Promise;\n setJSON: (k: string, v: unknown) => Promise;\n },\n channel: string,\n entry: HistoryEntry,\n): Promise {\n const history = await readHistory(blob, channel);\n const clean: HistoryEntry = {\n ...entry,\n source: entry.source,\n actor: entry.actor,\n item: entry.item === undefined ? undefined : normalizeItem(entry.item),\n amount: entry.amount === undefined ? undefined : roundAmount(entry.amount),\n count: entry.count === undefined ? undefined : roundAmount(entry.count),\n };\n\n const fp = historyFingerprint(clean);\n if (!history.some((e) => historyFingerprint(e) === fp)) {\n history.push(clean);\n }\n\n await blob.setJSON(`history_${channel}`, sanitizeHistory(history));\n}\n\nfunction formatStack(stack: Record): string {\n const keys = Object.keys(stack);\n if (!keys.length) return \"🤖 현재 스택 없음.\";\n return keys.map((k) => `${label(k)} ${roundAmount(stack[k])}`).join(\", \");\n}\n\n// ─────────────────────────────────────────────\n// Legacy data migration / dedupe\n// ─────────────────────────────────────────────\n\nasync function migrateLegacyChannelData(\n blob: {\n getJSON: (k: string) => Promise;\n setJSON: (k: string, v: unknown) => Promise;\n delete: (k: string) => Promise;\n },\n): Promise {\n const newStackKey = `stack_${PRIMARY_CHANNEL}`;\n const newHistoryKey = `history_${PRIMARY_CHANNEL}`;\n let newStack = sanitizeStack(\n await blob.getJSON(newStackKey).catch(() => null),\n );\n let newHistory = sanitizeHistory(\n await blob.getJSON(newHistoryKey).catch(() => null),\n );\n\n for (const legacyChannel of LEGACY_CHANNELS) {\n const legacyStackKey = `stack_${legacyChannel}`;\n const legacyHistoryKey = `history_${legacyChannel}`;\n const legacyStack = sanitizeStack(\n await blob.getJSON(legacyStackKey).catch(() => null),\n );\n const legacyHistory = sanitizeHistory(\n await blob.getJSON(legacyHistoryKey).catch(() => null),\n );\n\n for (const [item, value] of Object.entries(legacyStack)) {\n newStack[item] = roundAmount((newStack[item] || 0) + value);\n }\n newHistory = sanitizeHistory(newHistory.concat(legacyHistory));\n\n await blob.delete(legacyStackKey).catch(() => {});\n await blob.delete(legacyHistoryKey).catch(() => {});\n }\n\n await blob.setJSON(newStackKey, sanitizeStack(newStack));\n await blob.setJSON(newHistoryKey, sanitizeHistory(newHistory));\n}\n\n// ─────────────────────────────────────────────\n// Unified stack action engine (single source of truth)\n// ─────────────────────────────────────────────\n\ntype StackAction = \"추가\" | \"차감\" | \"삭제\" | \"초기화\";\n\ntype ActionResult = {\n ok: boolean;\n action?: StackAction;\n channel: string;\n item?: string;\n amount?: number;\n count?: number;\n stack: Record;\n message: string;\n error?: string;\n};\n\nasync function readStack(\n blob: { getJSON: (k: string) => Promise },\n channel: string,\n): Promise> {\n try {\n return sanitizeStack(await blob.getJSON(`stack_${channel}`));\n } catch {\n return Object.create(null);\n }\n}\n\nasync function writeStack(\n blob: { setJSON: (k: string, v: unknown) => Promise },\n channel: string,\n stack: Record,\n): Promise {\n await blob.setJSON(`stack_${channel}`, sanitizeStack(stack));\n}\n\nasync function applyStackAction(\n blob: {\n getJSON: (k: string) => Promise;\n setJSON: (k: string, v: unknown) => Promise;\n delete: (k: string) => Promise;\n },\n channel: string,\n action: StackAction,\n rawItem?: unknown,\n rawAmount?: unknown,\n historyMeta: Pick = {},\n): Promise {\n const item = normalizeItem(rawItem);\n const amount = rawAmount === undefined ? 1 : parsePositiveAmount(rawAmount);\n const stack = await readStack(blob, channel);\n\n if (action === \"초기화\") {\n await blob.delete(`stack_${channel}`);\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action: \"초기화\",\n ...historyMeta,\n });\n return {\n ok: true,\n action,\n channel,\n stack: Object.create(null),\n message: \"스택을 초기화했습니다.\",\n };\n }\n\n if (!item) {\n return {\n ok: false,\n channel,\n stack,\n message: \"항목을 입력해주세요.\",\n error: \"INVALID_ITEM\",\n };\n }\n if (!isSafeItemName(item)) {\n return {\n ok: false,\n channel,\n stack,\n message: \"항목 이름은 1~100 자로 입력해주세요.\",\n error: \"INVALID_ITEM\",\n };\n }\n if (amount === null) {\n return {\n ok: false,\n channel,\n item,\n stack,\n message: \"수량은 0 보다 큰 숫자만 입력할 수 있습니다.\",\n error: \"INVALID_AMOUNT\",\n };\n }\n\n if (action === \"추가\") {\n const next = roundAmount((stack[item] || 0) + amount);\n stack[item] = next;\n await writeStack(blob, channel, stack);\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action,\n item,\n amount,\n count: next,\n ...historyMeta,\n });\n return {\n ok: true,\n action,\n channel,\n item,\n amount,\n count: next,\n stack,\n message: `${label(item)} ${next}`,\n };\n }\n\n if (action === \"차감\") {\n if (!(item in stack)) {\n return {\n ok: false,\n action,\n channel,\n item,\n amount,\n stack,\n message: `${label(item)} 항목이 없습니다.`,\n error: \"NOT_FOUND\",\n };\n }\n const next = roundAmount(stack[item] - amount);\n if (next <= 0) {\n delete stack[item];\n await writeStack(blob, channel, stack);\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action,\n item,\n amount,\n count: 0,\n ...historyMeta,\n });\n return {\n ok: true,\n action,\n channel,\n item,\n amount,\n count: 0,\n stack,\n message: `${label(item)} 0 이하가 되어 삭제했습니다.`,\n };\n }\n stack[item] = next;\n await writeStack(blob, channel, stack);\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action,\n item,\n amount,\n count: next,\n ...historyMeta,\n });\n return {\n ok: true,\n action,\n channel,\n item,\n amount,\n count: next,\n stack,\n message: `${label(item)} ${next}`,\n };\n }\n\n if (!(item in stack)) {\n return {\n ok: false,\n action,\n channel,\n item,\n stack,\n message: `${label(item)} 항목이 없습니다.`,\n error: \"NOT_FOUND\",\n };\n }\n delete stack[item];\n await writeStack(blob, channel, stack);\n await appendHistory(blob, channel, {\n time: new Date().toISOString(),\n action,\n item,\n ...historyMeta,\n });\n return {\n ok: true,\n action,\n channel,\n item,\n stack,\n message: `${label(item)} 삭제했습니다.`,\n };\n}\n\n// ─────────────────────────────────────────────\n// Concurrency: serialize every mutation by normalized channel.\n// NOTE: this protects concurrent requests handled by the same runtime.\n// A distributed blob backend would need native CAS/transaction support for\n// cross-instance atomicity; this version never pretends the in-memory lock is distributed.\n// ─────────────────────────────────────────────\n\nconst channelLocks = new Map>();\n\nasync function withChannelLock(\n channel: string,\n task: () => Promise,\n): Promise {\n const previous = channelLocks.get(channel) || Promise.resolve();\n let release!: () => void;\n const current = new Promise((resolve) => {\n release = resolve;\n });\n channelLocks.set(channel, current);\n await previous;\n try {\n return await task();\n } finally {\n release();\n if (channelLocks.get(channel) === current) channelLocks.delete(channel);\n }\n}\n\n// ─────────────────────────────────────────────\n// JSON API helpers\n// ─────────────────────────────────────────────\n\nconst MAX_JSON_BODY_BYTES = 16 * 1024;\n\nasync function readJsonBody(\n req: Request,\n): Promise | null> {\n const contentLength = Number(req.headers.get(\"content-length\") || 0);\n if (Number.isFinite(contentLength) && contentLength > MAX_JSON_BODY_BYTES) {\n return null;\n }\n try {\n const text = await req.text();\n if (new TextEncoder().encode(text).byteLength > MAX_JSON_BODY_BYTES) {\n return null;\n }\n const body = JSON.parse(text);\n return body && typeof body === \"object\" && !Array.isArray(body)\n ? body as Record\n : null;\n } catch {\n return null;\n }\n}\n\nfunction sameOrigin(req: Request, url: URL): boolean {\n const origin = req.headers.get(\"origin\");\n const referer = req.headers.get(\"referer\");\n const valid = (value: string | null) => {\n if (!value) return false;\n try {\n return new URL(value).origin === url.origin;\n } catch {\n return false;\n }\n };\n return valid(origin) || valid(referer);\n}\n\nfunction getValidatedChannel(raw: unknown): string | null {\n const value = toNfc(String(raw ?? \"\").trim());\n // normalizeChannel() intentionally falls back to PRIMARY_CHANNEL for UI defaults,\n // but an API request must explicitly provide a channel.\n if (!value || !isSafeChannelName(value)) return null;\n return normalizeChannel(value);\n}\n\nasync function handleStackJsonApi(req: Request, url: URL, blob: {\n getJSON: (k: string) => Promise;\n setJSON: (k: string, v: unknown) => Promise;\n delete: (k: string) => Promise;\n}): Promise {\n if (req.method === \"GET\") {\n const channel = getValidatedChannel(url.searchParams.get(\"ch\"));\n if (!channel) {\n return jsonResponse(\n { ok: false, error: \"유효하지 않은 채널명입니다.\" },\n 400,\n );\n }\n return await withChannelLock(channel, async () => {\n const stack = await readStack(blob, channel);\n return jsonResponse({\n ok: true,\n channel,\n stack,\n items: Object.entries(stack).map(([item, count]) => ({ item, count })),\n });\n });\n }\n\n if (req.method !== \"POST\") {\n return jsonResponse({ ok: false, error: \"Method Not Allowed\" }, 405, {\n Allow: \"GET, POST\",\n });\n }\n\n if (!(await checkStackCommandAuth(req))) return forbiddenResponse();\n if (!sameOrigin(req, url) && !checkStackApiKey(req)) {\n return forbiddenResponse();\n }\n\n const body = await readJsonBody(req);\n if (!body) {\n return jsonResponse({\n ok: false,\n error: \"JSON body가 올바르지 않거나 너무 큽니다.\",\n }, 400);\n }\n\n const channel = getValidatedChannel(body.channel);\n if (!channel) {\n return jsonResponse(\n { ok: false, error: \"유효하지 않은 채널명입니다.\" },\n 400,\n );\n }\n\n const action = toNfc(String(body.action ?? \"\")) as StackAction;\n if (![\"추가\", \"차감\", \"삭제\", \"초기화\"].includes(action)) {\n return jsonResponse(\n { ok: false, error: \"지원하지 않는 action입니다.\" },\n 400,\n );\n }\n\n const adminUser = await getAuthenticatedAdminUser(req);\n const historyMeta: Pick = adminUser\n ? { source: \"admin\", actor: adminUser }\n : { source: \"api\", actor: \"API Key\" };\n\n return await withChannelLock(channel, async () => {\n const result = await applyStackAction(\n blob,\n channel,\n action,\n body.item,\n body.amount,\n historyMeta,\n );\n return jsonResponse(result, result.ok ? 200 : 400);\n });\n}\n\nasync function handleHistoryJsonApi(\n req: Request,\n url: URL,\n blob: { getJSON: (k: string) => Promise },\n): Promise {\n if (req.method !== \"GET\") {\n return jsonResponse({ ok: false, error: \"Method Not Allowed\" }, 405, {\n Allow: \"GET\",\n });\n }\n const channel = getValidatedChannel(url.searchParams.get(\"ch\"));\n if (!channel) {\n return jsonResponse(\n { ok: false, error: \"유효하지 않은 채널명입니다.\" },\n 400,\n );\n }\n const history = await readHistory(blob, channel);\n return jsonResponse({ ok: true, channel, history });\n}\n\n// ─────────────────────────────────────────────\n// YouTube Live 자동 초기화 (매일 06:00 KST 기준)\n// ─────────────────────────────────────────────\n\nconst YOUTUBE_CHANNEL_ID = \"UC1LiqB9tfyRge5fZ2-7BTVQ\";\nconst YOUTUBE_STACK_CHANNEL = PRIMARY_CHANNEL;\nconst YOUTUBE_API_KEY = Deno.env.get(\"YOUTUBE_API_KEY\") || \"\";\nconst YOUTUBE_AUTO_RESET_KEY = \"youtube_live_auto_reset\";\n\ntype YouTubeLiveState = {\n videoId?: string;\n wasLive?: boolean;\n lastResetDate?: string;\n};\n\nconst KST_OFFSET_MS = 9 * 60 * 60 * 1000;\nconst YOUTUBE_RESET_HOUR_KST = 6;\nconst YOUTUBE_RESET_MINUTE_KST = 0;\n\nfunction isYouTubeResetTimeReachedKst(nowMs = Date.now()): boolean {\n const kst = new Date(nowMs + KST_OFFSET_MS);\n const hour = kst.getUTCHours();\n const minute = kst.getUTCMinutes();\n\n return (\n hour > YOUTUBE_RESET_HOUR_KST ||\n (hour === YOUTUBE_RESET_HOUR_KST &&\n minute >= YOUTUBE_RESET_MINUTE_KST)\n );\n}\n\nfunction getYouTubeResetDateKey(nowMs = Date.now()): string {\n const kst = new Date(nowMs + KST_OFFSET_MS);\n\n if (!isYouTubeResetTimeReachedKst(nowMs)) {\n kst.setUTCDate(kst.getUTCDate() - 1);\n }\n\n return kst.toISOString().slice(0, 10);\n}\n\nasync function getYouTubeLiveVideoId(): Promise {\n if (!YOUTUBE_API_KEY) return null;\n\n const youtubeUrl = new URL(\n \"https://www.googleapis.com/youtube/v3/search\",\n );\n\n youtubeUrl.searchParams.set(\"part\", \"id\");\n youtubeUrl.searchParams.set(\"channelId\", YOUTUBE_CHANNEL_ID);\n youtubeUrl.searchParams.set(\"eventType\", \"live\");\n youtubeUrl.searchParams.set(\"type\", \"video\");\n youtubeUrl.searchParams.set(\"maxResults\", \"1\");\n youtubeUrl.searchParams.set(\"key\", YOUTUBE_API_KEY);\n\n try {\n const response = await fetch(youtubeUrl);\n if (!response.ok) return null;\n\n const data = await response.json() as {\n items?: Array<{ id?: { videoId?: string } }>;\n };\n\n return data.items?.[0]?.id?.videoId || null;\n } catch {\n return null;\n }\n}\n\nasync function getYouTubeLiveState(\n blobStore: { getJSON: (key: string) => Promise },\n): Promise {\n try {\n return (\n (await blobStore.getJSON(YOUTUBE_AUTO_RESET_KEY)) as\n | YouTubeLiveState\n | null\n ) || {};\n } catch {\n return {};\n }\n}\n\nasync function setYouTubeLiveState(\n blobStore: {\n setJSON: (key: string, value: unknown) => Promise;\n },\n state: YouTubeLiveState,\n): Promise {\n await blobStore.setJSON(YOUTUBE_AUTO_RESET_KEY, state);\n}\n\n/**\n * YouTube 자동 초기화의 단일 실행 엔진.\n *\n * Cron으로 실행할 때도, /youtube-check를 수동 호출할 때도\n * 반드시 이 함수 하나만 사용한다.\n *\n * 규칙:\n * - YouTube Live가 아니면 초기화하지 않는다.\n * - KST 06:00 이전에는 초기화하지 않는다.\n * - KST 06:00 이후 해당 업무 날짜에 최초 1회만 초기화한다.\n * - 같은 날짜에 Cron이 여러 번 실행되어도 중복 초기화하지 않는다.\n * - /history에는 실행자/출처를 명시한다.\n */\nasync function runYouTubeAutoReset(\n blobStore: {\n getJSON: (key: string) => Promise;\n setJSON: (key: string, value: unknown) => Promise;\n delete: (key: string) => Promise;\n },\n): Promise<{\n ok: boolean;\n live: boolean;\n reset: boolean;\n resetTimeReached: boolean;\n videoId: string | null;\n resetDate: string | null;\n channel: string;\n reason?: string;\n}> {\n if (!YOUTUBE_API_KEY) {\n return {\n ok: false,\n live: false,\n reset: false,\n resetTimeReached: isYouTubeResetTimeReachedKst(),\n videoId: null,\n resetDate: null,\n channel: YOUTUBE_STACK_CHANNEL,\n reason: \"YOUTUBE_API_KEY 환경변수가 설정되지 않았습니다.\",\n };\n }\n\n return await withChannelLock(YOUTUBE_STACK_CHANNEL, async () => {\n const liveVideoId = await getYouTubeLiveVideoId();\n const previous = await getYouTubeLiveState(blobStore);\n const todayKst = getYouTubeResetDateKey();\n const resetTimeReached = isYouTubeResetTimeReachedKst();\n\n if (!liveVideoId) {\n await setYouTubeLiveState(blobStore, {\n ...previous,\n wasLive: false,\n });\n\n return {\n ok: true,\n live: false,\n reset: false,\n resetTimeReached,\n videoId: null,\n resetDate: previous.lastResetDate || null,\n channel: YOUTUBE_STACK_CHANNEL,\n reason: \"현재 YouTube Live가 아닙니다.\",\n };\n }\n\n if (!resetTimeReached) {\n await setYouTubeLiveState(blobStore, {\n ...previous,\n videoId: liveVideoId,\n wasLive: true,\n });\n\n return {\n ok: true,\n live: true,\n reset: false,\n resetTimeReached: false,\n videoId: liveVideoId,\n resetDate: previous.lastResetDate || null,\n channel: YOUTUBE_STACK_CHANNEL,\n reason: \"06:00 KST 이전이므로 초기화하지 않았습니다.\",\n };\n }\n\n if (previous.lastResetDate === todayKst) {\n await setYouTubeLiveState(blobStore, {\n ...previous,\n videoId: liveVideoId,\n wasLive: true,\n });\n\n return {\n ok: true,\n live: true,\n reset: false,\n resetTimeReached: true,\n videoId: liveVideoId,\n resetDate: todayKst,\n channel: YOUTUBE_STACK_CHANNEL,\n reason: \"오늘 이미 자동 초기화되었습니다.\",\n };\n }\n\n // 초기화와 기록은 같은 채널 lock 안에서 순서대로 처리한다.\n await blobStore.delete(`stack_${YOUTUBE_STACK_CHANNEL}`);\n\n await appendHistory(blobStore, YOUTUBE_STACK_CHANNEL, {\n time: new Date().toISOString(),\n action: \"초기화\",\n source: \"youtube-auto\",\n actor: \"YouTube 자동 초기화\",\n });\n\n await setYouTubeLiveState(blobStore, {\n videoId: liveVideoId,\n wasLive: true,\n lastResetDate: todayKst,\n });\n\n return {\n ok: true,\n live: true,\n reset: true,\n resetTimeReached: true,\n videoId: liveVideoId,\n resetDate: todayKst,\n channel: YOUTUBE_STACK_CHANNEL,\n };\n });\n}\n\n// ─────────────────────────────────────────────\n// Main\n// ─────────────────────────────────────────────\n\ntype HttpOrCronInput =\n | Request\n | {\n lastRunAt?: Date;\n };\n\nfunction isRequestInput(value: HttpOrCronInput): value is Request {\n return value instanceof Request;\n}\n\nexport default async function (\n input: HttpOrCronInput,\n): Promise {\n const { blob } = await import(\"https://esm.town/v/std/blob\");\n\n // ───────────────────────────────────────────\n // Cron entry\n //\n // 같은 Stack_Admin_ver3.3.ts 파일에 CRON Trigger를 붙이면\n // 별도 YouTube Cron 파일 없이 이 파일 자체가 자동 감시기가 된다.\n // Val Town Cron은 Interval 객체를 넘기므로 Request가 아니면 Cron으로 판정한다.\n // ───────────────────────────────────────────\n if (!isRequestInput(input)) {\n const result = await runYouTubeAutoReset(blob);\n const lastReset = await getLastResetInfo(blob, YOUTUBE_STACK_CHANNEL);\n const payload = {\n ...result,\n lastResetTime: lastReset ? toKstString(lastReset.time) : null,\n lastResetBy: lastReset?.by || null,\n };\n console.log(\n JSON.stringify({\n type: \"youtube-auto-reset\",\n ...payload,\n }),\n );\n return JSON.stringify(payload);\n }\n\n const req = input;\n const url = new URL(req.url);\n\n // One-time migration is itself serialized so two cold-start requests cannot\n // intentionally run the migration in parallel inside this runtime.\n await withChannelLock(\"__migration__\", async () => {\n let migrationDone = false;\n try {\n const state = await blob.getJSON(MIGRATION_DONE_KEY);\n migrationDone = state === true ||\n (state as { done?: boolean } | null)?.done === true;\n } catch {}\n if (!migrationDone) {\n await migrateLegacyChannelData(blob);\n await blob.setJSON(MIGRATION_DONE_KEY, { done: true, version: 3 });\n }\n });\n\n if (url.pathname === \"/admin\") {\n if (!(await checkAuth(req))) return unauthorizedResponse();\n return htmlResponse(ADMIN_HTML);\n }\n if (url.pathname === \"/monitor\") return htmlResponse(MONITOR_HTML);\n if (url.pathname === \"/history\") return htmlResponse(HISTORY_HTML);\n\n if (url.pathname === \"/api/stack\") {\n if (await getMaintenanceMode(blob) && req.method !== \"GET\") {\n return jsonResponse({ ok: false, error: MAINTENANCE_MESSAGE }, 503);\n }\n return handleStackJsonApi(req, url, blob);\n }\n\n if (url.pathname === \"/api/history\") {\n return handleHistoryJsonApi(req, url, blob);\n }\n\n if (url.pathname === \"/admin/maintenance-status\") {\n if (!(await checkAuth(req))) return unauthorizedResponse();\n return jsonResponse({ ok: true, on: await getMaintenanceMode(blob) });\n }\n\n if (url.pathname === \"/admin/maintenance\" && req.method === \"POST\") {\n if (!(await checkAuth(req))) return unauthorizedResponse();\n if (!sameOrigin(req, url)) return forbiddenResponse();\n const body = await readJsonBody(req);\n if (!body || typeof body.on !== \"boolean\") {\n return jsonResponse(\n { ok: false, error: \"on(boolean)이 필요합니다.\" },\n 400,\n );\n }\n await setMaintenanceMode(blob, body.on);\n return jsonResponse({ ok: true, on: body.on });\n }\n\n if (url.pathname === \"/youtube-check\") {\n const checkSecret = Deno.env.get(\"YOUTUBE_CHECK_SECRET\") || \"\";\n if (!checkSecret) {\n return jsonResponse({\n ok: false,\n error: \"YOUTUBE_CHECK_SECRET 환경변수가 설정되지 않았습니다.\",\n }, 500);\n }\n\n const supplied = req.headers.get(\"x-youtube-check-secret\") ||\n url.searchParams.get(\"secret\") ||\n \"\";\n\n if (!timingSafeEqualText(supplied, checkSecret)) {\n return forbiddenResponse();\n }\n\n const result = await runYouTubeAutoReset(blob);\n const lastReset = await getLastResetInfo(blob, YOUTUBE_STACK_CHANNEL);\n\n return jsonResponse({\n ...result,\n lastResetTime: lastReset ? toKstString(lastReset.time) : null,\n lastResetBy: lastReset?.by || null,\n });\n }\n\n // Legacy Nightbot/text API. Kept only for compatibility; all state mutation\n // goes through the same applyStackAction() engine as the JSON API.\n const requestedQuery = toNfc((url.searchParams.get(\"q\") || \"\").trim());\n const rawChannel = toNfc((url.searchParams.get(\"ch\") || \"\").trim());\n const channel = getValidatedChannel(rawChannel);\n\n if (!channel) return textResponse(\"채널명을 입력해주세요.\", 400);\n if (requestedQuery && !(await checkStackCommandAuth(req))) {\n return forbiddenResponse();\n }\n if (await getMaintenanceMode(blob)) {\n return textResponse(MAINTENANCE_MESSAGE, 503);\n }\n\n const adminUser = requestedQuery\n ? await getAuthenticatedAdminUser(req)\n : null;\n const historyMeta: Pick = adminUser\n ? { source: \"admin\", actor: adminUser }\n : { source: \"nightbot\", actor: \"Nightbot\" };\n\n return await withChannelLock(channel, async () => {\n if (!requestedQuery) {\n return textResponse(formatStack(await readStack(blob, channel)));\n }\n\n const parts = requestedQuery.split(/\\s+/);\n const command = parts[0];\n\n if (command === \"기록초기화\") {\n if (!(await checkStackCommandAuth(req))) return forbiddenResponse();\n await blob.delete(`history_${channel}`);\n return textResponse(\"기록 (History) 을 초기화했습니다.\");\n }\n\n if (command === \"추가\" || command === \"차감\" || command === \"빼기\") {\n const parsed = splitItemAndAmount(parts.slice(1));\n if (!parsed.item) {\n return textResponse(\n command === \"추가\"\n ? \"사용법 : !스택 추가 [항목] [숫자 (생략가능, 소수 가능)]\"\n : \"사용법 : !스택 차감 (빼기) [항목] [숫자 (생략가능, 소수 가능)]\",\n );\n }\n if (!parsed.valid) {\n return textResponse(\n `수량은 0 보다 큰 숫자만 입력할 수 있습니다. (인식된 수량 토큰: \"${\n parsed.debug.lastToken ?? \"\"\n }\")`,\n );\n }\n if (command === \"추가\" && endsWithBareNumber(parsed.item)) {\n return textResponse(\n `항목 이름(\"${parsed.item}\") 끝에 숫자가 포함되어 있어 추가하지 않았습니다.`,\n );\n }\n\n const result = await applyStackAction(\n blob,\n channel,\n command === \"추가\" ? \"추가\" : \"차감\",\n parsed.item,\n parsed.amount,\n historyMeta,\n );\n return textResponse(result.message, result.ok ? 200 : 400);\n }\n\n if (command === \"삭제\") {\n const item = parts.slice(1).join(\" \");\n const result = await applyStackAction(\n blob,\n channel,\n \"삭제\",\n item,\n undefined,\n historyMeta,\n );\n return textResponse(result.message, result.ok ? 200 : 400);\n }\n\n if (command === \"초기화\") {\n const result = await applyStackAction(\n blob,\n channel,\n \"초기화\",\n undefined,\n undefined,\n historyMeta,\n );\n return textResponse(result.message, result.ok ? 200 : 400);\n }\n\n return textResponse(\n \"알 수 없는 명령입니다. (추가/차감/삭제/초기화/기록초기화 지원)\",\n 400,\n );\n });\n}","// aguking-excel.val.run\n// val.town HTTP val - 나이트봇 연동 엑셀(이름별 수량) 관리\n//\n// 사용법 (나이트봇 명령):\n// !엑셀 -> 현재 목록 조회 (항목별 랜덤 이모지 포함)\n// !엑셀 추가 홍길동 10 -> GET /?ch=채널명&q=추가 홍길동 10\n// !엑셀 차감 홍길동 3 -> GET /?ch=채널명&q=차감 홍길동 3\n// !엑셀 삭제 홍길동 -> GET /?ch=채널명&q=삭제 홍길동\n// !엑셀 초기화 -> GET /?ch=채널명&q=초기화\n//\n// 웹에서 https://aguking-excel.val.run/?ch=채널명 으로 접속하면\n// 랜덤 이모지가 포함된 목록을 볼 수 있고, /admin에서는 추가·차감·삭제·초기화가 가능합니다.\n// q 파라미터가 없으면 HTML 화면을 반환합니다.\n// q=처럼 비어 있으면 나이트봇용 전체 목록을 반환합니다.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TABLE = \"excel_items\";\nconst DEFAULT_CHANNEL = \"암본이수혁aguking\";\nconst DECIMAL_PLACES = 6;\nconst SCALE = 1_000_000;\n\nconst EMOJIS = [\n \"🍎\",\n \"🍏\",\n \"🍓\",\n \"🍒\",\n \"🍋\",\n \"🧅\",\n \"🥔\",\n \"🧄\",\n \"🌽\",\n \"🥕\",\n \"👑\",\n \"💎\",\n \"⚔️\",\n \"🐉\",\n \"🔥\",\n \"🦁\",\n \"🐯\",\n \"🐺\",\n \"🦊\",\n \"🐻\",\n \"🎲\",\n \"⭐\",\n \"✨\",\n \"💫\",\n \"🌈\",\n \"🎯\",\n \"🏆\",\n \"🎮\",\n \"🎁\",\n \"🚀\",\n \"📦\",\n \"🔹\",\n \"🎉\",\n \"✅\",\n];\n\ntype Item = { name: string; qty: number };\n\ntype Command =\n | { command: \"추가\" | \"차감\"; name?: string; amount: number }\n | { command: \"삭제\"; name?: string }\n | { command: \"초기화\" }\n | { command: \"unknown\" };\n\nfunction round6(value: number): number {\n return Math.round((value + Number.EPSILON) * SCALE) / SCALE;\n}\n\nfunction formatQty(value: number): string {\n const safe = Number.isFinite(value) ? round6(value) : 0;\n return safe.toFixed(DECIMAL_PLACES).replace(/\\.?0+$/, \"\");\n}\n\nfunction parseAmount(raw: string | undefined): number {\n const value = Number(raw);\n return Number.isFinite(value) && value > 0 ? round6(value) : 1;\n}\n\nfunction getRandomEmoji(): string {\n return EMOJIS[Math.floor(Math.random() * EMOJIS.length)];\n}\n\nfunction escapeHtml(value: string): string {\n return value\n .replaceAll(\"&\", \"&\")\n .replaceAll(\"<\", \"<\")\n .replaceAll(\">\", \">\")\n .replaceAll('\"', \""\")\n .replaceAll(\"'\", \"'\");\n}\n\nfunction readResultValue(result: any, row: any, column: string): unknown {\n if (row && typeof row === \"object\" && !Array.isArray(row) && column in row) {\n return row[column];\n }\n\n const columns = Array.isArray(result.columns) ? result.columns : [];\n const index = columns.findIndex(\n (item: unknown) => String(item).toLowerCase() === column.toLowerCase(),\n );\n\n return index >= 0 && row ? row[index] : undefined;\n}\n\nasync function ensureTable(): Promise {\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS ${TABLE} (\n channel TEXT NOT NULL,\n name TEXT NOT NULL,\n qty REAL NOT NULL DEFAULT 0,\n PRIMARY KEY (channel, name)\n )`,\n );\n}\n\nasync function getItems(channel: string): Promise {\n const result: any = await sqlite.execute({\n sql: `SELECT name, qty\n FROM ${TABLE}\n WHERE channel = ?\n ORDER BY CASE WHEN name = '국고' THEN 1 ELSE 0 END ASC,\n rowid ASC`,\n args: [channel],\n });\n\n return (result.rows || [])\n .map((row: any) => ({\n name: String(readResultValue(result, row, \"name\") ?? \"\").trim(),\n qty: round6(Number(readResultValue(result, row, \"qty\")) || 0),\n }))\n .filter((item: Item) => item.name !== \"\");\n}\n\nasync function listItemsText(channel: string): Promise {\n const items = await getItems(channel);\n\n return items.length\n ? items\n .map(\n (item) => `${getRandomEmoji()} ${item.name} ${formatQty(item.qty)}`,\n )\n .join(\", \")\n : \"✨ 아직 비어 있어요. 항목을 추가해 주세요!\";\n}\n\nasync function addItem(\n channel: string,\n name: string,\n amount: number,\n): Promise {\n if (name === \"국고\") {\n // 1) 기존 국고 수량 읽기\n const result: any = await sqlite.execute({\n sql: `SELECT qty FROM ${TABLE} WHERE channel = ? AND name = ?`,\n args: [channel, name],\n });\n\n const oldQty = result.rows?.length\n ? round6(Number(readResultValue(result, result.rows[0], \"qty\")) || 0)\n : 0;\n\n const newQty = round6(oldQty + amount);\n\n // 2) 기존 국고 삭제 (있으면)\n if (result.rows?.length) {\n await sqlite.execute({\n sql: `DELETE FROM ${TABLE} WHERE channel = ? AND name = ?`,\n args: [channel, name],\n });\n }\n\n // 3) 새 행으로 INSERT → rowid 가 가장 큰 값이 되어 맨 뒤로 감\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE} (channel, name, qty) VALUES (?, ?, ?)`,\n args: [channel, name, newQty],\n });\n\n return newQty;\n }\n\n // 일반 항목: 기존 로직 유지 (중복 시 합산)\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE} (channel, name, qty) VALUES (?, ?, ?)\n ON CONFLICT(channel, name)\n DO UPDATE SET qty = ROUND(qty + excluded.qty, 6)`,\n args: [channel, name, amount],\n });\n\n const result: any = await sqlite.execute({\n sql: `SELECT qty FROM ${TABLE} WHERE channel = ? AND name = ?`,\n args: [channel, name],\n });\n\n return round6(Number(readResultValue(result, result.rows[0], \"qty\")) || 0);\n}\n\nasync function subtractItem(\n channel: string,\n name: string,\n amount: number,\n): Promise {\n const result: any = await sqlite.execute({\n sql: `SELECT qty FROM ${TABLE} WHERE channel = ? AND name = ?`,\n args: [channel, name],\n });\n\n if (!result.rows?.length) return null;\n\n const current = round6(\n Number(readResultValue(result, result.rows[0], \"qty\")) || 0,\n );\n const next = Math.max(0, round6(current - amount));\n\n if (name === \"국고\") {\n // 국고는 삭제 후 재 INSERT 로 rowid 갱신 (항상 맨 뒤)\n await sqlite.execute({\n sql: `DELETE FROM ${TABLE} WHERE channel = ? AND name = ?`,\n args: [channel, name],\n });\n\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE} (channel, name, qty) VALUES (?, ?, ?)`,\n args: [channel, name, next],\n });\n } else {\n // 일반 항목은 그냥 업데이트\n await sqlite.execute({\n sql: `UPDATE ${TABLE} SET qty = ? WHERE channel = ? AND name = ?`,\n args: [next, channel, name],\n });\n }\n\n return next;\n}\n\nasync function deleteItem(channel: string, name: string): Promise {\n await sqlite.execute({\n sql: `DELETE FROM ${TABLE} WHERE channel = ? AND name = ?`,\n args: [channel, name],\n });\n}\n\nasync function resetChannel(channel: string): Promise {\n await sqlite.execute({\n sql: `DELETE FROM ${TABLE} WHERE channel = ?`,\n args: [channel],\n });\n}\n\nfunction parseCommand(q: string): Command {\n const parts = q.trim().split(/\\s+/);\n const command = parts[0] || \"\";\n\n if (command === \"추가\" || command === \"차감\") {\n return {\n command,\n name: parts[1],\n amount: parseAmount(parts[2]),\n };\n }\n\n if (command === \"삭제\") {\n return {\n command,\n name: parts[1],\n };\n }\n\n if (command === \"초기화\") {\n return { command };\n }\n\n return { command: \"unknown\" };\n}\n\nasync function handleCommand(channel: string, q: string): Promise {\n if (!q.trim()) {\n return await listItemsText(channel);\n }\n\n const parsed = parseCommand(q);\n\n switch (parsed.command) {\n case \"추가\": {\n if (!parsed.name) return \"사용법: 추가 이름 수량\";\n\n const qty = await addItem(channel, parsed.name, parsed.amount);\n return `${parsed.name} 추가됨 (현재 ${formatQty(qty)})`;\n }\n\n case \"차감\": {\n if (!parsed.name) return \"사용법: 차감 이름 수량\";\n\n const qty = await subtractItem(channel, parsed.name, parsed.amount);\n\n return qty === null\n ? `${parsed.name} 항목이 없습니다.`\n : `${parsed.name} 차감됨 (현재 ${formatQty(qty)})`;\n }\n\n case \"삭제\": {\n if (!parsed.name) return \"사용법: 삭제 이름\";\n\n await deleteItem(channel, parsed.name);\n return `${parsed.name} 삭제됨`;\n }\n\n case \"초기화\":\n await resetChannel(channel);\n return \"전체 초기화 완료\";\n\n default:\n return \"알 수 없는 명령어입니다. (추가/차감/삭제/초기화)\";\n }\n}\n\nfunction checkAuth(req: Request): boolean {\n const accounts = new Map();\n\n for (const entry of (Deno.env.get(\"ADMIN_ACCOUNTS\") || \"\").split(\",\")) {\n const index = entry.indexOf(\":\");\n\n if (index > 0) {\n accounts.set(\n entry.slice(0, index).trim(),\n entry.slice(index + 1).trim(),\n );\n }\n }\n\n if (!accounts.size) return false;\n\n const header = req.headers.get(\"authorization\") || \"\";\n if (!header.startsWith(\"Basic \")) return false;\n\n try {\n const decoded = atob(header.slice(6));\n const index = decoded.indexOf(\":\");\n\n return index >= 0 &&\n accounts.get(decoded.slice(0, index).trim()) === decoded.slice(index + 1);\n } catch {\n return false;\n }\n}\n\nfunction refreshControlsHtml(channel: string): string {\n return `\n Auto\n \n \n \n \n \n\n \n\n `;\n}\n\nconst COMMON_CSS = `\n body {\n background: #0f1115;\n color: #eee;\n font-family: sans-serif;\n padding: 24px;\n }\n\n a { color: #9ab5ff; }\n\n table {\n width: 100%;\n border-collapse: collapse;\n background: #181b21;\n margin-top: 16px;\n }\n\n th, td {\n padding: 12px;\n text-align: left;\n border-bottom: 1px solid #2a2e37;\n }\n\n th { color: #9aa0a6; }\n\n .top-controls {\n position: fixed;\n top: 18px;\n right: 18px;\n display: flex;\n align-items: center;\n gap: 10px;\n z-index: 10;\n }\n\n .page-link {\n display: inline-flex;\n align-items: center;\n min-height: 38px;\n padding: 0 12px;\n box-sizing: border-box;\n border: 1px solid #3c4657;\n border-radius: 7px;\n color: #eaf0ff;\n background: #202631;\n text-decoration: none;\n font-size: 14px;\n font-weight: 700;\n }\n\n .page-link:hover {\n background: #303947;\n }\n\n .auto-toggle {\n display: inline-flex;\n align-items: center;\n gap: 8px;\n cursor: pointer;\n user-select: none;\n color: #c9ced8;\n font-size: 14px;\n }\n\n .auto-label {\n font-weight: 700;\n letter-spacing: .2px;\n }\n\n .auto-toggle input {\n position: absolute;\n width: 1px;\n height: 1px;\n opacity: 0;\n pointer-events: none;\n }\n\n .toggle-track {\n width: 42px;\n height: 24px;\n padding: 3px;\n box-sizing: border-box;\n border-radius: 999px;\n background: #343943;\n border: 1px solid #4b5260;\n transition: background .2s ease, border-color .2s ease;\n }\n\n .toggle-knob {\n display: block;\n width: 16px;\n height: 16px;\n border-radius: 50%;\n background: #fff;\n box-shadow: 0 1px 3px rgba(0, 0, 0, .45);\n transform: translateX(0);\n transition: transform .2s ease;\n }\n\n .auto-toggle input:checked + .toggle-track {\n background: #2a8a4b;\n border-color: #48b96b;\n }\n\n .auto-toggle input:checked + .toggle-track .toggle-knob {\n transform: translateX(16px);\n }\n\n .auto-toggle input:focus-visible + .toggle-track {\n outline: 2px solid #8fb1ff;\n outline-offset: 3px;\n }\n\n .manual-refresh {\n min-height: 38px;\n padding: 8px 12px;\n border: 1px solid #3c4657;\n border-radius: 7px;\n cursor: pointer;\n color: #eaf0ff;\n background: #263a63;\n font-weight: 700;\n }\n\n .manual-refresh:hover {\n background: #31508d;\n }\n`;\n\nfunction renderViewPage(channel: string, items: Item[]): string {\n const rows = items\n .map(\n (item) =>\n `${getRandomEmoji()} ${escapeHtml(item.name)}${\n formatQty(item.qty)\n }`,\n )\n .join(\"\");\n\n const adminUrl = `/admin?ch=${encodeURIComponent(channel)}`;\n\n return `\n\n\n \n \n 엑셀 - ${escapeHtml(channel)}\n \n\n\n

엑셀 - ${escapeHtml(channel)}

\n Admin\n ${refreshControlsHtml(channel)}\n

\n ${\n rows\n ? `\n \n ${rows}\n

이름	수량

`\n : \"

✨ 아직 비어 있어요. 항목을 추가해 주세요!

\"\n }\n\n`;\n}\n\nfunction renderAdminPage(channel: string, items: Item[]): string {\n const rows = items\n .map((item) => {\n const name = JSON.stringify(item.name);\n\n return `\n ${escapeHtml(item.name)}\n ${formatQty(item.qty)}\n \n \n \n \n \n `;\n })\n .join(\"\");\n\n const listUrl = `/?ch=${encodeURIComponent(channel)}`;\n\n return `\n\n\n \n \n 엑셀 관리 - ${escapeHtml(channel)}\n \n\n\n

엑셀 관리 - ${escapeHtml(channel)}

\n Monitoring\n ${refreshControlsHtml(channel)}\n

\n\n \n\n ${\n rows\n ? `\n \n ${rows}\n

이름	수량	관리

`\n : \"

✨ 아직 비어 있어요. 항목을 추가해 주세요! 항목이 없습니다.

\"\n }\n\n \n\n`;\n}\n\nexport default async function (req: Request): Promise {\n await ensureTable();\n\n const url = new URL(req.url);\n const channel = url.searchParams.get(\"ch\")?.trim() || DEFAULT_CHANNEL;\n const q = url.searchParams.get(\"q\");\n const isAdmin = url.pathname === \"/admin\";\n\n if (isAdmin && !checkAuth(req)) {\n return new Response(\"관리자 인증이 필요합니다.\", {\n status: 401,\n headers: {\n \"content-type\": \"text/plain; charset=utf-8\",\n \"www-authenticate\": 'Basic realm=\"Excel Admin\", charset=\"UTF-8\"',\n },\n });\n }\n\n if (q !== null) {\n return new Response(await handleCommand(channel, q), {\n headers: {\n \"content-type\": \"text/plain; charset=utf-8\",\n },\n });\n }\n\n const items = await getItems(channel);\n const html = isAdmin\n ? renderAdminPage(channel, items)\n : renderViewPage(channel, items);\n\n return new Response(html, {\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n },\n });\n}",["D",1788836063223],{"_34":57,"_36":56,"_37":24,"_39":58,"_42":59,"_44":14,"_45":46,"_28":29},true,"deno.json","989d6efa-ab30-11f1-96a5-1607ee4eb77e","{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/98f62cee78e85bfc47c62ed703777c6bc8794f1c/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": true,\n \"types\": [\"https://www.val.town/types/valtown.d.ts\"],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"include\": [\"deno:/https/esm.town/**/*\"],\n \"rules\": {\n \"exclude\": [\"no-explicit-any\"]\n }\n },\n \"node_modules_dir\": false,\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-temporal\": true,\n \"unstable-worker-options\": true,\n \"unstable-sloppy-imports\": true\n }\n}",["D",1788836063223],{"_34":62,"_36":61,"_37":24,"_39":63,"_42":64,"_44":14,"_45":46,"_28":29},".vtignore","989d544c-ab30-11f1-96a5-1607ee4eb77e",".git\n.vscode\n.cursorrules\n.DS_Store\nnode_modules\nvendor",["D",1788836063223],{"_34":68,"_36":67,"_37":69,"_39":70,"_42":71,"_44":14,"_45":46,"_28":55},{"_34":68,"_36":67,"_37":69,"_39":70},"cron.ts","333ab092-ab2e-11f1-8330-1607ee4eb77e","interval","import handler from \"./main.ts\";\n\nexport default async function (interval: Interval) {\n console.log(\"Cron 실행:\", interval);\n\n // main.ts의 default export는 Request가 아니면 자동으로\n // YouTube 자동 초기화(runYouTubeAutoReset) 분기를 타도록 만들어져 있음\n const result = await handler(interval);\n console.log(\"YouTube 자동 초기화 결과:\", result);\n}",["D",1788836063223],"id","9d4dc10d-0136-4985-94f6-6b0bf535e31e","Aguking_Stack",["D",1787817154621],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","d7bd44ad-648e-46fe-b25e-97dc3e998420","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a04226-b52a-76ab-bc3d-16937b891876","tursoName","9d4dc10d0136498594f66b0bf535e31e","tursoHostname","9d4dc10d0136498594f66b0bf535e31e-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789497078049],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_126":125,"_134":130},"org",{"_126":125,"_127":128,"_129":130,"_18":83,"_131":132,"_133":29},"branch",{"_13":115,"_36":116,"_72":46,"_117":73,"_118":-5,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":74,"_124":125},"isOwned",405,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Steven_Jin","handle","displayName","Steven-J-KY","avatar","https://avatars.githubusercontent.com/u/321694553?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_72":73,"_36":74,"_42":223,"_76":-5,"_77":29,"_78":79,"_80":79,"_81":-5,"_82":-5,"_18":83,"_84":35,"_85":55,"_86":-5,"_87":-5,"_88":89,"_90":91,"_92":93,"_94":95,"_96":224,"_98":-5,"_99":100,"_101":100,"_102":103,"_104":103,"_105":103,"_106":100,"_107":100,"_108":225,"_110":226,"_112":227,"_114":29},"tree",[202,203,204,205,206],"files",[202,203,204,205,206],"counts",{"_190":89,"_191":192,"_193":89,"_194":195,"_196":197},"contents",[157,158,159,160,161],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_72":187,"_36":61,"_34":62,"_165":-5,"_45":46,"_44":14,"_167":29,"_42":188,"_13":89,"_37":24,"_39":63,"_28":29,"_171":-5,"_31":189},{"_72":184,"_36":56,"_34":57,"_165":-5,"_45":46,"_44":14,"_167":29,"_42":185,"_13":89,"_37":24,"_39":58,"_28":29,"_171":-5,"_31":186},{"_72":179,"_36":49,"_34":50,"_165":-5,"_45":46,"_44":14,"_167":29,"_42":180,"_13":181,"_37":38,"_39":52,"_28":29,"_171":182,"_31":183},{"_72":174,"_36":32,"_34":35,"_165":-5,"_45":46,"_44":14,"_167":29,"_42":175,"_13":176,"_37":38,"_39":41,"_28":29,"_171":177,"_31":178},{"_72":162,"_36":163,"_34":164,"_165":-5,"_45":46,"_44":166,"_167":55,"_42":168,"_13":169,"_37":38,"_39":170,"_28":29,"_171":172,"_31":173},"9c961185-c175-4dcd-a379-789e7bc06f59","youtube-notice-bot.ts","31ef2e96-a5e5-11f1-aa35-1607ee4eb77e","parentId",342,"latest",["D",1788834627060],28,"/**\n * YouTube Live Stream Viewer for Val Town\n * 암본이수혁 (aguking) 유튜브 채널의 라이브 방송을 볼 수 있는 화면\n */\n\nconst CHANNEL_ID = \"UC1LiqB9tfyRge5fZ2-7BTVQ\";\nconst CHANNEL_NAME = \"암본이수혁 (aguking)\";\nconst CHANNEL_URL =\n \"https://www.youtube.com/@%EC%97%B0%EC%97%94%ED%84%B0%EC%9D%B4%EC%88%98%ED%98%81\";\nconst CHECK_INTERVAL_MS = 15 * 60_000;\n\ntype LiveResult =\n | { live: true; videoId: string; title: string }\n | { live: false; reason?: string };\n\nasync function findCurrentLive(): Promise {\n const apiKey = Deno.env.get(\"YOUTUBE_API_KEY\")?.trim();\n\n if (!apiKey) {\n return {\n live: false,\n reason: \"Val Town Secrets에 YOUTUBE_API_KEY가 설정되지 않았습니다.\",\n };\n }\n\n const params = new URLSearchParams({\n part: \"snippet\",\n channelId: CHANNEL_ID,\n eventType: \"live\",\n type: \"video\",\n order: \"date\",\n maxResults: \"1\",\n key: apiKey,\n });\n\n try {\n const response = await fetch(\n `https://www.googleapis.com/youtube/v3/search?${params.toString()}`,\n );\n\n if (!response.ok) {\n const detail = await response.text();\n console.error(\"YouTube API error:\", response.status, detail);\n return {\n live: false,\n reason:\n `YouTube API 요청 오류 (${response.status}). API 키와 YouTube Data API v3 활성화 상태를 확인하세요.`,\n };\n }\n\n const data = await response.json();\n const item = data.items?.[0];\n const videoId = item?.id?.videoId;\n\n if (!videoId || !/^[A-Za-z0-9_-]{11}$/.test(videoId)) {\n return { live: false };\n }\n\n return {\n live: true,\n videoId,\n title: item?.snippet?.title || \"YouTube Live\",\n };\n } catch (error) {\n console.error(\"YouTube API request failed:\", error);\n return {\n live: false,\n reason: \"YouTube API 연결에 실패했습니다. 잠시 후 다시 시도합니다.\",\n };\n }\n}\n\nfunction escapeHtml(value: string): string {\n return value.replace(/[&<>'\"]/g, (character) => {\n const entities: Record = {\n \"&\": \"&\",\n \"<\": \"<\",\n \">\": \">\",\n \"'\": \"'\",\n '\"': \""\",\n };\n return entities[character];\n });\n}\n\nfunction renderPage(origin: string): string {\n const liveApiUrl = `${origin}?api=live`;\n\n return `\n\n\n \n \n \n ${escapeHtml(CHANNEL_NAME)} 라이브\n \n\n\n

🎬 ${escapeHtml(CHANNEL_NAME)}

YouTube 라이브 시청 · 채팅

라이브 상태 확인 중…

\n\n

라이브 상태를 확인하고 있습니다

잠시만 기다려 주세요.

\n \n

\n\n

15분마다 새 라이브 여부를 자동으로 확인합니다.

\n YouTube 채널에서 열기\n

\n\n \n

\n\n \n\n`;\n}\n\nexport default async function handler(request: Request): Promise {\n const url = new URL(request.url);\n\n if (url.searchParams.get(\"api\") === \"live\") {\n return Response.json(await findCurrentLive(), {\n headers: { \"cache-control\": \"no-store\" },\n });\n }\n\n return new Response(renderPage(url.origin), {\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n \"cache-control\": \"no-store\",\n },\n });\n}","label","aguking-live",[163],"26d27aa4-bccc-4b47-805a-3aec55c19e73",["D",1788836063223],186,"aguking-stack",[32],"c1fc70af-82aa-4dfb-ae03-410944f96c7d",["D",1788836063223],2,"aguking-excel",[49],"4d3ddeb9-aa55-4700-b8e3-7203c805d1e6",["D",1788836063223],[56],"a9c4589d-b4a3-4ce4-b3b6-15b09cb19707",["D",1788836063223],[61],"pulls","branches",1,"forks","envVars",{"_198":200,"_201":89},"connections",{"_198":89,"_199":89},"count","unfilledCount",8,"emptyCount",{"_72":187,"_36":61,"_34":62,"_165":-5,"_45":46,"_44":14,"_167":29,"_42":220,"_13":89,"_37":24,"_39":63,"_28":29,"_171":-5,"_208":221,"_31":222},{"_72":184,"_36":56,"_34":57,"_165":-5,"_45":46,"_44":14,"_167":29,"_42":217,"_13":89,"_37":24,"_39":58,"_28":29,"_171":-5,"_208":218,"_31":219},{"_72":179,"_36":49,"_34":50,"_165":-5,"_45":46,"_44":14,"_167":29,"_42":214,"_13":181,"_37":38,"_39":52,"_28":29,"_171":182,"_208":215,"_31":216},{"_72":174,"_36":32,"_34":35,"_165":-5,"_45":46,"_44":14,"_167":29,"_42":211,"_13":176,"_37":38,"_39":41,"_28":29,"_171":177,"_208":212,"_31":213},{"_72":162,"_36":163,"_34":164,"_165":-5,"_45":46,"_44":166,"_167":55,"_42":207,"_13":169,"_37":38,"_39":170,"_28":29,"_171":172,"_208":209,"_31":210},["D",1788834627060],"children",[],[163],["D",1788836063223],[],[32],["D",1788836063223],[],[49],["D",1788836063223],[],[56],["D",1788836063223],[],[61],["D",1787817154621],["D",1789497078049],{"_126":125,"_134":130},{"_126":125,"_127":128,"_129":130,"_18":83,"_131":132,"_133":29},{"_13":115,"_36":116,"_72":46,"_117":73,"_118":-5,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":74,"_124":125},"ctx",{"_108":-5,"_154":261,"_262":263,"_264":265,"_266":29,"_267":29,"_268":29,"_269":55,"_270":-5,"_271":-7,"_272":-7,"_273":89,"_274":29,"_275":29,"_276":-5,"_277":29,"_278":29,"_279":29,"_280":-5},"ENV",{"_232":233,"_234":235,"_236":116,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260},"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"]

Stack Monitoring · aguking-stack

Stack Admin · aguking-stack

\nStack History\n · \naguking-stack\n

Stack Monitoring · aguking-stack

Stack Admin · aguking-stack

\nStack History\n · \naguking-stack\n

Stack Monitoring · aguking-stack

Stack Admin · aguking-stack

\nStack History\n · \naguking-stack\n

엑셀 - ${escapeHtml(channel)}

엑셀 관리 - ${escapeHtml(channel)}

🎬 ${escapeHtml(CHANNEL_NAME)}

Diff · v353