🎬 ${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",[133],"224d910f-96b9-4e62-973c-6073d375d6e3",["D",1789007374390],[27],"cfd2bd8b-8a58-47c2-849e-a0dae48fdfa7","main.ts",362,["D",1788970911433],193,"// ver.3.4 FINAL SINGLE-FILE\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\n// Monitor/Admin/History 세 페이지가 동일하게 쓰는 클라이언트 JS.\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\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\n// blob.getJSON을 감싸는 공통 헬퍼. 파싱/네트워크 오류 시 fallback을 반환한다.\n// (같은 try/catch 패턴이 여러 함수에 중복되어 있던 것을 하나로 통합.)\nasync function safeGetJSON(\n blobStore: { getJSON: (k: string) => Promise },\n key: string,\n fallback: T,\n): Promise {\n try {\n return ((await blobStore.getJSON(key)) as T) ?? fallback;\n } catch {\n return fallback;\n }\n}\n\nasync function getMaintenanceMode(\n blob: { getJSON: (k: string) => Promise },\n): Promise {\n const value = await safeGetJSON<{ on?: boolean } | null>(\n blob,\n MAINTENANCE_KEY,\n null,\n );\n return value?.on === true;\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 return sanitizeHistory(await safeGetJSON(blob, `history_${channel}`, null));\n}\n\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\n// 사람이 읽기 좋은 \"누가 초기화했는지\" 라벨.\n// History에 실제로 기록된 source를 그대로 재사용하므로,\n// nightbot/admin/자동초기화(YouTube) 어떤 경로로 초기화되었든 정확하게 반영된다.\n// 실제 로그인 아이디(예: 오탈자가 섞인 \"Adm1n\" 같은 값)는 절대 노출하지 않고,\n// 항상 고정된 표기(admin / nightbot)만 보여준다.\nfunction historyActorLabel(entry: HistoryEntry): string {\n if (entry.source === \"youtube-auto\") return \"자동초기화 (YouTube)\";\n if (entry.source === \"admin\") return \"admin\";\n if (entry.source === \"nightbot\") return \"nightbot\";\n if (entry.source === \"api\") {\n return entry.actor ? `API (${entry.actor})` : \"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 return sanitizeStack(await safeGetJSON(blob, `stack_${channel}`, null));\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 getYouTubeLiveStatus(): Promise<\n { videoId: string | null; apiError: boolean }\n> {\n if (!YOUTUBE_API_KEY) return { videoId: null, apiError: true };\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\n if (!response.ok) {\n // 쿼터 초과/5xx 등 API 오류 — \"방송 종료\"로 오판하지 않도록 구분해서 알린다.\n return { videoId: null, apiError: true };\n }\n\n const data = await response.json() as {\n items?: Array<{ id?: { videoId?: string } }>;\n };\n\n return { videoId: data.items?.[0]?.id?.videoId || null, apiError: false };\n } catch {\n // 네트워크 오류 등 — 위와 동일하게 \"일시 오류\"로 취급한다.\n return { videoId: null, apiError: true };\n }\n}\n\nasync function getYouTubeLiveState(\n blobStore: { getJSON: (key: string) => Promise },\n): Promise {\n return (await safeGetJSON(\n blobStore,\n YOUTUBE_AUTO_RESET_KEY,\n null,\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 * - 06:00 KST를 \"하루\"의 기준으로 사용한다 (getYouTubeResetDateKey).\n * - 06:00에 도달했다는 사실만으로는 절대 초기화하지 않는다.\n * 예) 05:00에 시작한 방송이 06:00을 통과해도 초기화 ❌\n * 같은 방송이 계속 유지돼도 초기화 ❌\n * 같은 방송 ID로 재연결(끊김→재접속)돼도 초기화 ❌\n * - \"방송 ID가 이전과 다른 새 방송\"이 06:00 이후 시작된 경우에만,\n * 해당 업무 날짜에 최초 1회 초기화한다.\n * - 같은 날짜에 새 방송이 여러 번 시작돼도 그날 이미 초기화했다면\n * 추가로 초기화하지 않는다.\n * - YouTube API 호출이 일시적으로 실패한 경우, 방송이 실제로\n * 끝난 것인지 알 수 없으므로 저장된 상태(wasLive/videoId 등)를\n * 건드리지 않고 그대로 둔다.\n * - /history에는 실행자/출처(source: \"youtube-auto\")를 명시한다.\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 { videoId: liveVideoId, apiError } = await getYouTubeLiveStatus();\n const previous = await getYouTubeLiveState(blobStore);\n const todayKst = getYouTubeResetDateKey();\n const resetTimeReached = isYouTubeResetTimeReachedKst();\n\n // API 오류: 실제 방송 상태를 알 수 없으므로 상태를 그대로 보존한다.\n if (apiError) {\n return {\n ok: false,\n live: previous.wasLive ?? false,\n reset: false,\n resetTimeReached,\n videoId: previous.videoId || null,\n resetDate: previous.lastResetDate || null,\n channel: YOUTUBE_STACK_CHANNEL,\n reason:\n \"YouTube API 호출에 일시적으로 실패했습니다. 이전 상태를 유지합니다.\",\n };\n }\n\n if (!liveVideoId) {\n // 방송 종료(또는 미방송). videoId는 그대로 남겨서, 같은 방송이\n // 재연결됐을 때 \"새 방송\"으로 오인하지 않도록 한다.\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 const isNewBroadcast = previous.videoId !== liveVideoId;\n const alreadyResetToday = previous.lastResetDate === todayKst;\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 (!isNewBroadcast) {\n // 같은 방송 ID가 계속되거나(06:00을 그대로 통과) 재연결된 경우.\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: previous.lastResetDate || null,\n channel: YOUTUBE_STACK_CHANNEL,\n reason:\n \"동일한 방송(재연결 포함)이 이어지고 있어 초기화하지 않았습니다.\",\n };\n }\n\n if (alreadyResetToday) {\n // 새 방송이 시작됐지만, 오늘 이미 자동 초기화가 1회 발생함.\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\n // 06:00 이후 + 방송 ID가 바뀐 새 방송 + 오늘 아직 미실행 → 초기화 실행.\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 reason: \"새 방송 감지 — 금일 최초 1회 초기화를 실행했습니다.\",\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 // 나이트봇의 $(urlfetch ...)는 2xx가 아닌 응답의 본문을 표시하지 않으므로\n // 아래 레거시 텍스트 API의 모든 응답은 상태 코드 200으로 통일한다.\n if (!channel) return textResponse(\"채널명을 입력해주세요.\", 200);\n if (requestedQuery && !(await checkStackCommandAuth(req))) {\n return forbiddenResponse();\n }\n if (await getMaintenanceMode(blob)) {\n // Nightbot의 $(urlfetch ...)는 응답이 2xx가 아니면 본문을 표시하지 않고\n // \"Remote Server Returned Code ###\" 형태의 자체 오류 메시지를 출력한다.\n // 점검 문구가 채팅창에 보이도록 상태 코드는 200으로 반환한다.\n return textResponse(MAINTENANCE_MESSAGE, 200);\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, 200);\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, 200);\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, 200);\n }\n\n return textResponse(\n \"알 수 없는 명령입니다. (추가/차감/삭제/초기화)\",\n 200,\n );\n });\n}","aguking-stack",[149],"c1fc70af-82aa-4dfb-ae03-410944f96c7d","excel.ts","b6c0703c-a863-11f1-85c1-1607ee4eb77e",353,["D",1788836063223],2,"// 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}","aguking-excel",[157],"pulls","branches",1,"forks","envVars",{"_173":175,"_176":61},"connections",{"_173":61,"_174":61},"count","unfilledCount",6,"emptyCount",{"_42":156,"_32":157,"_30":158,"_135":-5,"_40":41,"_39":159,"_137":24,"_37":191,"_13":161,"_33":140,"_35":162,"_23":24,"_142":163,"_182":192,"_26":193},{"_42":148,"_32":149,"_30":55,"_135":-5,"_40":41,"_39":150,"_137":24,"_37":188,"_13":152,"_33":140,"_35":153,"_23":24,"_142":154,"_182":189,"_26":190},{"_42":145,"_32":27,"_30":31,"_135":-5,"_40":41,"_39":14,"_137":24,"_37":185,"_13":61,"_33":34,"_35":36,"_23":24,"_142":-5,"_182":186,"_26":187},{"_42":132,"_32":133,"_30":134,"_135":-5,"_40":41,"_39":136,"_137":57,"_37":181,"_13":139,"_33":140,"_35":141,"_23":24,"_142":143,"_182":183,"_26":184},["D",1788834627060],"children",[],[133],["D",1789007374390],[],[27],["D",1788970911433],[],[149],["D",1788836063223],[],[157],["D",1787817154621],["D",1789497078049],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},{"_13":87,"_32":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"ctx",{"_80":-5,"_125":232,"_233":234,"_235":236,"_237":24,"_238":24,"_239":24,"_240":57,"_241":-5,"_242":-7,"_243":-7,"_244":61,"_245":24,"_246":24,"_247":-5,"_248":24,"_249":24,"_250":24,"_251":-5},"ENV",{"_203":204,"_205":206,"_207":88,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231},"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 Admin · aguking-stack

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

엑셀 - ${escapeHtml(channel)}

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

Diff · v363