Roblox Gift Priority Panel

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_160":161,"_162":163},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_108":89,"_27":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":58,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",41,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","d889b88c-5f74-11f1-b984-1607ee4eb77e","name","fileType","http","content","import { blob } from \"https://esm.town/v/std/blob\";\n\n// ============================================================\n// STORAGE KEYS\n// ============================================================\nconst COMMENT_KEY = \"roblox_comment_queue_v2\";\nconst GIFT_KEY = \"roblox_gift_queue_v1\";\nconst WAITING_KEY = \"roblox_waiting_user_v1\";\nconst CREDIT_KEY = \"roblox_gift_credit_v1\";\nconst EVENT_KEY = \"roblox_event_queue_v1\";\n\n// ============================================================\n// TYPES\n// ============================================================\ntype CommentItem = {\n username: string;\n tiktokUsername: string;\n createdAt: string;\n};\n\ntype GiftItem = {\n username: string;\n gift: string;\n count: number;\n createdAt: string;\n};\n\ntype WaitingUser = {\n tiktokUsername: string;\n giftName: string;\n giftCount: number;\n expiresAt: string;\n} | null;\n\ntype GiftCredit = {\n gift: string;\n count: number;\n grantedAt: string;\n};\n\ntype GiftCredits = Record;\n\n// [TAMBAH] meteor_aura ditambahkan ke RobloxEventType\ntype RobloxEventType =\n | \"spawn\"\n | \"blackhole\"\n | \"cinematic_aura\"\n | \"meteor_aura\" // [TAMBAH] event type untuk gift Doughnut\n | \"gift_notification\";\n\ntype RobloxEvent = {\n type: RobloxEventType;\n username: string;\n tiktokUsername?: string;\n giftName?: string;\n amount?: number;\n};\n\ntype PendingGiftEvent = {\n tiktokUsername: string;\n giftName: string;\n giftCount: number;\n enqueuedAt: string;\n};\n\n// ============================================================\n// GIFT REWARD MAPPING\n// ============================================================\ntype RewardAction =\n | { type: \"spawn\"; amountPerGift: number }\n | { type: \"blackhole\" }\n | { type: \"cinematic_aura\" }\n | { type: \"meteor_aura\" }; // [TAMBAH]\n\nconst GIFT_REWARDS: Record = {\n \"Rose\": { type: \"spawn\", amountPerGift: 20 },\n \"Heart Me\": { type: \"blackhole\" },\n \"Rosa\": { type: \"cinematic_aura\" },\n \"Doughnut\": { type: \"meteor_aura\" }, // [TAMBAH] 30 coin → meteor strike\n};\n\nfunction findReward(giftName: string): RewardAction | null {\n const target = giftName.trim().toLowerCase();\n for (const key of Object.keys(GIFT_REWARDS)) {\n if (key.toLowerCase() === target) return GIFT_REWARDS[key];\n }\n return null;\n}\n\nconst WAITING_TIMEOUT_MS = 30_000;\n\n// ============================================================\n// STORAGE HELPERS\n// ============================================================\nasync function readComment(): Promise {\n return (await blob.getJSON(COMMENT_KEY)) ?? [];\n}\nasync function writeComment(q: CommentItem[]): Promise {\n await blob.setJSON(COMMENT_KEY, q);\n}\n\nasync function readGift(): Promise {\n const raw = await blob.getJSON(GIFT_KEY);\n return Array.isArray(raw) ? raw : [];\n}\nasync function writeGift(q: GiftItem[]): Promise {\n await blob.setJSON(GIFT_KEY, q);\n}\n\nasync function readWaiting(): Promise {\n return (await blob.getJSON(WAITING_KEY)) ?? null;\n}\nasync function writeWaiting(w: WaitingUser): Promise {\n await blob.setJSON(WAITING_KEY, w);\n}\n\nasync function readCredits(): Promise {\n return (await blob.getJSON(CREDIT_KEY)) ?? {};\n}\nasync function writeCredits(c: GiftCredits): Promise {\n await blob.setJSON(CREDIT_KEY, c);\n}\n\nasync function readEventQueue(): Promise {\n const raw = await blob.getJSON(EVENT_KEY);\n return Array.isArray(raw) ? raw : [];\n}\nasync function writeEventQueue(q: RobloxEvent[]): Promise {\n await blob.setJSON(EVENT_KEY, q);\n}\n\n// ============================================================\n// GIFT REWARD ENGINE\n// ============================================================\nfunction buildRobloxEvent(\n giftName: string,\n giftCount: number,\n robloxUsername: string,\n tiktokUsername: string,\n): RobloxEvent | null {\n const reward = findReward(giftName);\n if (!reward) return null;\n\n if (reward.type === \"spawn\") {\n return {\n type: \"spawn\",\n username: robloxUsername,\n tiktokUsername,\n amount: reward.amountPerGift * giftCount,\n };\n }\n if (reward.type === \"blackhole\") {\n return { type: \"blackhole\", username: robloxUsername, tiktokUsername };\n }\n if (reward.type === \"cinematic_aura\") {\n return { type: \"cinematic_aura\", username: robloxUsername, tiktokUsername };\n }\n // [TAMBAH] build event untuk meteor_aura\n if (reward.type === \"meteor_aura\") {\n return { type: \"meteor_aura\", username: robloxUsername, tiktokUsername };\n }\n return null;\n}\n\n// ============================================================\n// PUSH TO ROBLOX (OPEN CLOUD MESSAGING SERVICE)\n// ============================================================\nasync function pushToRoblox(\n payload: RobloxEvent | {\n type: \"comment\";\n username: string;\n tiktokUsername: string;\n },\n): Promise {\n const apiKey = process.env.ROBLOX_API_KEY;\n const universeId = process.env.ROBLOX_UNIVERSE_ID;\n\n if (!apiKey || !universeId) {\n console.log(\n \"[pushToRoblox] ROBLOX_API_KEY / ROBLOX_UNIVERSE_ID belum di-set, push dilewati.\",\n );\n return;\n }\n\n try {\n const res = await fetch(\n `https://apis.roblox.com/messaging-service/v1/universes/${universeId}/topics/LiveTikTokSpawns`,\n {\n method: \"POST\",\n headers: {\n \"x-api-key\": apiKey,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ message: JSON.stringify(payload) }),\n },\n );\n\n if (!res.ok) {\n const errText = await res.text().catch(() => \"\");\n console.log(\n `[pushToRoblox] gagal push (HTTP ${res.status}): ${errText} | payload: ${\n JSON.stringify(payload)\n }`,\n );\n }\n } catch (err) {\n console.log(\"[pushToRoblox] error saat fetch ke Roblox Open Cloud:\", err);\n }\n}\n\n// ============================================================\n// TIMEOUT CHECK\n// ============================================================\nasync function resolveWaiting(waiting: WaitingUser): Promise {\n if (!waiting) return null;\n\n const now = Date.now();\n if (now < new Date(waiting.expiresAt).getTime()) return waiting;\n\n const credits = await readCredits();\n credits[waiting.tiktokUsername] = {\n gift: waiting.giftName,\n count: waiting.giftCount,\n grantedAt: new Date().toISOString(),\n };\n await writeCredits(credits);\n await writeWaiting(null);\n return null;\n}\n\n// ============================================================\n// GIFT PROCESSOR\n// ============================================================\nasync function processIncomingGift(\n tiktokUsername: string,\n giftName: string,\n giftCount: number,\n): Promise {\n const reward = findReward(giftName);\n if (!reward) {\n console.log(\n `[unmapped gift] \"${giftName}\" dari ${tiktokUsername} — tidak ada di GIFT_REWARDS`,\n );\n return;\n }\n\n // Kirim gift_notification ke Roblox (untuk semua gift)\n await pushToRoblox({\n type: \"gift_notification\",\n username: tiktokUsername,\n tiktokUsername: tiktokUsername,\n giftName: giftName,\n amount: giftCount,\n });\n\n // Blackhole langsung trigger tanpa nunggu comment username Roblox\n if (reward.type === \"blackhole\") {\n const event: RobloxEvent = {\n type: \"blackhole\",\n username: tiktokUsername,\n tiktokUsername: tiktokUsername,\n };\n await pushToRoblox(event);\n const eq = await readEventQueue();\n eq.push(event);\n await writeEventQueue(eq);\n return;\n }\n\n // [TAMBAH] Doughnut (meteor_aura) butuh comment username Roblox, sama seperti Rosa\n // Rose, Rosa, Doughnut → masuk waiting / gift queue\n const rawWaiting = await readWaiting();\n const waiting = await resolveWaiting(rawWaiting);\n\n if (!waiting) {\n const expiresAt = new Date(Date.now() + WAITING_TIMEOUT_MS).toISOString();\n await writeWaiting({ tiktokUsername, giftName, giftCount, expiresAt });\n } else {\n const gq = await readGift();\n gq.push({\n username: tiktokUsername,\n gift: giftName,\n count: giftCount,\n createdAt: new Date().toISOString(),\n });\n await writeGift(gq);\n }\n}\n\n// ============================================================\n// COMMENT (USERNAME) PROCESSOR\n// ============================================================\nasync function processIncomingComment(\n robloxUsername: string,\n tiktokUsername: string,\n): Promise {\n const rawWaiting = await readWaiting();\n const waiting = await resolveWaiting(rawWaiting);\n\n if (waiting && waiting.tiktokUsername === tiktokUsername) {\n const event = buildRobloxEvent(\n waiting.giftName,\n waiting.giftCount,\n robloxUsername,\n waiting.tiktokUsername,\n );\n if (event) {\n await pushToRoblox(event);\n const eq = await readEventQueue();\n eq.push(event);\n await writeEventQueue(eq);\n }\n await writeWaiting(null);\n\n await promoteNextGiftFromQueue();\n return;\n }\n\n const credits = await readCredits();\n if (credits[tiktokUsername]) {\n const { gift, count } = credits[tiktokUsername];\n const event = buildRobloxEvent(gift, count, robloxUsername, tiktokUsername);\n if (event) {\n await pushToRoblox(event);\n const eq = await readEventQueue();\n eq.push(event);\n await writeEventQueue(eq);\n }\n delete credits[tiktokUsername];\n await writeCredits(credits);\n return;\n }\n\n const cq = await readComment();\n cq.push({\n username: robloxUsername,\n tiktokUsername,\n createdAt: new Date().toISOString(),\n });\n await writeComment(cq);\n await pushToRoblox({\n type: \"comment\",\n username: robloxUsername,\n tiktokUsername,\n });\n}\n\n// ============================================================\n// PROMOTE NEXT GIFT FROM QUEUE\n// ============================================================\nasync function promoteNextGiftFromQueue(): Promise {\n const gq = await readGift();\n if (!gq.length) return;\n\n const next = gq.shift();\n if (!next) return;\n await writeGift(gq);\n\n if (!findReward(next.gift)) {\n await promoteNextGiftFromQueue();\n return;\n }\n\n const expiresAt = new Date(Date.now() + WAITING_TIMEOUT_MS).toISOString();\n await writeWaiting({\n tiktokUsername: next.username,\n giftName: next.gift,\n giftCount: next.count,\n expiresAt,\n });\n}\n\n// ============================================================\n// REQUEST BODY PARSERS\n// ============================================================\nasync function getCommentData(req: Request) {\n const url = new URL(req.url);\n let username = url.searchParams.get(\"username\") || \"\";\n let tiktokUsername = url.searchParams.get(\"tiktokUsername\") || \"\";\n\n if (!username) {\n try {\n const body = await req.clone().json();\n username = body.username || \"\";\n tiktokUsername = body.tiktokUsername || \"\";\n } catch {}\n }\n if (!username) {\n try {\n const form = await req.clone().formData();\n username = form.get(\"username\")?.toString() || \"\";\n tiktokUsername = form.get(\"tiktokUsername\")?.toString() || \"\";\n } catch {}\n }\n if (!username) {\n try {\n username = (await req.text()).trim();\n } catch {}\n }\n\n return { username: username.trim(), tiktokUsername: tiktokUsername.trim() };\n}\n\nasync function getGiftData(req: Request) {\n const url = new URL(req.url);\n let username = url.searchParams.get(\"username\") || \"\";\n let gift = url.searchParams.get(\"gift\") || \"\";\n let count = url.searchParams.get(\"count\") || \"1\";\n\n if (!gift) {\n try {\n const body = await req.clone().json();\n username = username || body.username || \"\";\n gift = gift || body.gift || \"\";\n count = count || body.count || \"1\";\n } catch {}\n }\n if (!gift) {\n try {\n const form = await req.clone().formData();\n username = username || form.get(\"username\")?.toString() || \"\";\n gift = gift || form.get(\"gift\")?.toString() || \"\";\n count = count || form.get(\"count\")?.toString() || \"1\";\n } catch {}\n }\n\n return {\n username: username.trim(),\n gift: gift.trim(),\n count: Number(count) || 1,\n };\n}\n\n// ============================================================\n// PANEL HTML\n// ============================================================\nfunction panelHTML(\n commentQ: CommentItem[],\n giftQ: GiftItem[],\n waiting: WaitingUser,\n credits: GiftCredits,\n eventQ: RobloxEvent[],\n) {\n const commentList = commentQ\n .map(\n (v) =>\n `

💬 ${v.username} (TikTok: ${\n v.tiktokUsername || \"-\"\n })

`,\n )\n .join(\"\");\n\n const giftList = giftQ\n .map(\n (v) => `

🎁 ${v.username} - ${v.gift} x${v.count}

`,\n )\n .join(\"\");\n\n const waitingHTML = waiting\n ? `

⏳ ${waiting.tiktokUsername} menunggu username Roblox (gift: ${waiting.giftName} x${waiting.giftCount}) — expire: ${\n new Date(waiting.expiresAt).toLocaleTimeString()\n }

`\n : `

— tidak ada —

`;\n\n const creditEntries = Object.entries(credits);\n const creditHTML = creditEntries.length\n ? creditEntries\n .map(([u, c]) =>\n `

💳 ${u} → ${c.gift} x${c.count}

`\n )\n .join(\"\")\n : `

— tidak ada —

`;\n\n // [TAMBAH] meteor_aura diberi label khusus di event log\n const eventHTML = eventQ.length\n ? eventQ\n .map(\n (e) => {\n // [TAMBAH] ikon khusus per event type\n const icon = e.type === \"meteor_aura\"\n ? \"☄️\"\n : e.type === \"cinematic_aura\"\n ? \"🌟\"\n : e.type === \"blackhole\"\n ? \"🌌\"\n : e.type === \"spawn\"\n ? \"👤\"\n : \"🎁\";\n return `

${icon} type: ${e.type} | roblox: ${e.username} | tiktok: ${\n e.tiktokUsername || \"-\"\n }${e.giftName ? ` | gift: ${e.giftName}` : \"\"}${\n e.amount != null ? ` | amount: ${e.amount}` : \"\"\n }

`;\n },\n )\n .join(\"\")\n : `

— tidak ada —

`;\n\n const rewardList = Object.entries(GIFT_REWARDS)\n .map(([name, r]) => {\n // [TAMBAH] deskripsi untuk meteor_aura\n const desc = r.type === \"spawn\"\n ? `spawn x${r.amountPerGift}/gift`\n : r.type === \"blackhole\"\n ? \"blackhole effect (langsung trigger)\"\n : r.type === \"meteor_aura\"\n ? \"meteor strike cinematic (perlu ketik username)\" // [TAMBAH]\n : \"cinematic + aura\";\n // [TAMBAH] ikon per reward type\n const icon = r.type === \"meteor_aura\"\n ? \"☄️\"\n : r.type === \"cinematic_aura\"\n ? \"🌟\"\n : r.type === \"blackhole\"\n ? \"🌌\"\n : \"🎁\";\n return `

${icon} ${name} → ${desc}

`;\n })\n .join(\"\");\n\n const giftOptions = Object.keys(GIFT_REWARDS)\n .map((g) => ``)\n .join(\"\");\n\n return `\n\n\nRoblox Gift Priority Panel\n\n\n

🛠️ Quick Admin Actions

\n \n

\n\n

🗺️ Gift Reward Mapping

\n ${rewardList}\n

\n\n

⏳ Waiting User (aktif)

\n ${waitingHTML}\n

\n\n

💳 Gift Credits (tersimpan)

Total: ${creditEntries.length}

\n ${creditHTML}\n

\n\n

🎮 Roblox Event Queue

Menunggu diambil Roblox: ${eventQ.length}

\n ${eventHTML}\n \n

\n\n

☄️ QUICK TEST METEOR / DOUGHNUT

Simulasi viewer gift Doughnut (30 coin) → meteor strike. Masukkan TikTok username + username Roblox target.

\n \n \n \n

\n\n

⚡ QUICK TEST (Gift + Comment otomatis)

Kirim gift lalu langsung kirim comment dengan TikTok username yang sama secara otomatis.

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

\n\n

💬 COMMENT TEST

Simulasikan viewer mengirim username Roblox mereka via komentar TikTok

\n \n \n \n

Queue comment biasa: ${commentQ.length}

${commentList}

\n\n

🎁 GIFT TEST

Simulasikan viewer mengirim gift. Gift yg dikenal: ${\n Object.keys(GIFT_REWARDS).join(\", \")\n }

\n \n \n \n \n

Gift queue (menunggu): ${giftQ.length}

${giftList}

\n\n\n`;\n}\n\n// ============================================================\n// MAIN HANDLER\n// ============================================================\nexport default async function handler(req: Request) {\n const url = new URL(req.url);\n const path = url.pathname;\n const method = req.method.toUpperCase();\n\n if (path === \"/\" && method === \"GET\") {\n const cq = await readComment();\n const gq = await readGift();\n const waiting = await readWaiting();\n const credits = await readCredits();\n const eq = await readEventQueue();\n return new Response(panelHTML(cq, gq, waiting, credits, eq), {\n headers: { \"Content-Type\": \"text/html\" },\n });\n }\n\n if (path === \"/comment\" && method === \"POST\") {\n const data = await getCommentData(req);\n if (!data.username) {\n return Response.json({ error: \"empty username\" }, { status: 400 });\n }\n await processIncomingComment(data.username, data.tiktokUsername);\n return Response.json({ ok: true });\n }\n\n if (path === \"/comment\" && method === \"GET\") {\n const q = await readComment();\n if (!q.length) return Response.json({ username: null });\n const item = q.shift()!;\n await writeComment(q);\n return Response.json({\n username: item.username,\n tiktokUsername: item.tiktokUsername ?? \"\",\n });\n }\n\n if (path === \"/gift\" && method === \"POST\") {\n const data = await getGiftData(req);\n if (!data.gift) {\n return Response.json({ error: \"gift name is empty\" }, { status: 400 });\n }\n const tiktokUsername = data.username || \"TikTok Viewer\";\n await processIncomingGift(tiktokUsername, data.gift, data.count);\n return Response.json({ ok: true });\n }\n\n if (path === \"/gift\" && method === \"GET\") {\n const q = await readGift();\n if (!q.length) return Response.json({ username: null });\n const item = q.shift()!;\n await writeGift(q);\n return Response.json({\n username: item.username,\n gift: item.gift,\n count: item.count,\n });\n }\n\n if (path === \"/event\" && method === \"GET\") {\n const eq = await readEventQueue();\n if (!eq.length) return Response.json({ type: null });\n const item = eq.shift()!;\n await writeEventQueue(eq);\n return Response.json(item);\n }\n\n if (path === \"/status\" && method === \"GET\") {\n const cq = await readComment();\n const gq = await readGift();\n const waiting = await readWaiting();\n const credits = await readCredits();\n const eq = await readEventQueue();\n return Response.json({\n commentQueue: cq.length,\n giftQueue: gq.length,\n waitingUser: waiting,\n giftCredits: credits,\n eventQueue: eq,\n });\n }\n\n if (path === \"/admin/clear-events\" && method === \"POST\") {\n await writeEventQueue([]);\n return Response.json({ ok: true });\n }\n\n if (path === \"/admin/clear-all\" && method === \"POST\") {\n await writeComment([]);\n await writeGift([]);\n await writeWaiting(null);\n await writeCredits({});\n await writeEventQueue([]);\n return Response.json({\n ok: true,\n message: \"All storage keys cleared successfully\",\n });\n }\n\n return Response.json({ error: \"not found\" }, { status: 404 });\n}","import { blob } from \"https://esm.town/v/std/blob\";\n\n// ============================================================\n// STORAGE KEYS\n// ============================================================\nconst COMMENT_KEY = \"roblox_comment_queue_v2\";\nconst GIFT_KEY = \"roblox_gift_queue_v1\";\nconst WAITING_KEY = \"roblox_waiting_user_v1\";\nconst CREDIT_KEY = \"roblox_gift_credit_v1\";\nconst EVENT_KEY = \"roblox_event_queue_v1\";\n\n// ============================================================\n// TYPES\n// ============================================================\ntype CommentItem = {\n username: string;\n tiktokUsername: string;\n createdAt: string;\n};\n\ntype GiftItem = {\n username: string;\n gift: string;\n count: number;\n createdAt: string;\n};\n\ntype WaitingUser = {\n tiktokUsername: string;\n giftName: string;\n giftCount: number;\n expiresAt: string;\n} | null;\n\ntype GiftCredit = {\n gift: string;\n count: number;\n grantedAt: string;\n};\n\ntype GiftCredits = Record;\n\n// [TAMBAH] meteor_aura ditambahkan ke RobloxEventType\ntype RobloxEventType =\n | \"spawn\"\n | \"blackhole\"\n | \"cinematic_aura\"\n | \"meteor_aura\" // [TAMBAH] event type untuk gift Doughnut\n | \"gift_notification\";\n\ntype RobloxEvent = {\n type: RobloxEventType;\n username: string;\n tiktokUsername?: string;\n giftName?: string;\n amount?: number;\n};\n\ntype PendingGiftEvent = {\n tiktokUsername: string;\n giftName: string;\n giftCount: number;\n enqueuedAt: string;\n};\n\n// ============================================================\n// GIFT REWARD MAPPING\n// ============================================================\ntype RewardAction =\n | { type: \"spawn\"; amountPerGift: number }\n | { type: \"blackhole\" }\n | { type: \"cinematic_aura\" }\n | { type: \"meteor_aura\" }; // [TAMBAH]\n\nconst GIFT_REWARDS: Record = {\n \"Rose\": { type: \"spawn\", amountPerGift: 50 },\n \"Heart Me\": { type: \"blackhole\" },\n \"Rosa\": { type: \"cinematic_aura\" },\n \"Doughnut\": { type: \"meteor_aura\" }, // [TAMBAH] 30 coin → meteor strike\n};\n\nfunction findReward(giftName: string): RewardAction | null {\n const target = giftName.trim().toLowerCase();\n for (const key of Object.keys(GIFT_REWARDS)) {\n if (key.toLowerCase() === target) return GIFT_REWARDS[key];\n }\n return null;\n}\n\nconst WAITING_TIMEOUT_MS = 30_000;\n\n// ============================================================\n// STORAGE HELPERS\n// ============================================================\nasync function readComment(): Promise {\n return (await blob.getJSON(COMMENT_KEY)) ?? [];\n}\nasync function writeComment(q: CommentItem[]): Promise {\n await blob.setJSON(COMMENT_KEY, q);\n}\n\nasync function readGift(): Promise {\n const raw = await blob.getJSON(GIFT_KEY);\n return Array.isArray(raw) ? raw : [];\n}\nasync function writeGift(q: GiftItem[]): Promise {\n await blob.setJSON(GIFT_KEY, q);\n}\n\nasync function readWaiting(): Promise {\n return (await blob.getJSON(WAITING_KEY)) ?? null;\n}\nasync function writeWaiting(w: WaitingUser): Promise {\n await blob.setJSON(WAITING_KEY, w);\n}\n\nasync function readCredits(): Promise {\n return (await blob.getJSON(CREDIT_KEY)) ?? {};\n}\nasync function writeCredits(c: GiftCredits): Promise {\n await blob.setJSON(CREDIT_KEY, c);\n}\n\nasync function readEventQueue(): Promise {\n const raw = await blob.getJSON(EVENT_KEY);\n return Array.isArray(raw) ? raw : [];\n}\nasync function writeEventQueue(q: RobloxEvent[]): Promise {\n await blob.setJSON(EVENT_KEY, q);\n}\n\n// ============================================================\n// GIFT REWARD ENGINE\n// ============================================================\nfunction buildRobloxEvent(\n giftName: string,\n giftCount: number,\n robloxUsername: string,\n tiktokUsername: string,\n): RobloxEvent | null {\n const reward = findReward(giftName);\n if (!reward) return null;\n\n if (reward.type === \"spawn\") {\n return {\n type: \"spawn\",\n username: robloxUsername,\n tiktokUsername,\n amount: reward.amountPerGift * giftCount,\n };\n }\n if (reward.type === \"blackhole\") {\n return { type: \"blackhole\", username: robloxUsername, tiktokUsername };\n }\n if (reward.type === \"cinematic_aura\") {\n return { type: \"cinematic_aura\", username: robloxUsername, tiktokUsername };\n }\n // [TAMBAH] build event untuk meteor_aura\n if (reward.type === \"meteor_aura\") {\n return { type: \"meteor_aura\", username: robloxUsername, tiktokUsername };\n }\n return null;\n}\n\n// ============================================================\n// PUSH TO ROBLOX (OPEN CLOUD MESSAGING SERVICE)\n// ============================================================\nasync function pushToRoblox(\n payload: RobloxEvent | {\n type: \"comment\";\n username: string;\n tiktokUsername: string;\n },\n): Promise {\n const apiKey = process.env.ROBLOX_API_KEY;\n const universeId = process.env.ROBLOX_UNIVERSE_ID;\n\n if (!apiKey || !universeId) {\n console.log(\n \"[pushToRoblox] ROBLOX_API_KEY / ROBLOX_UNIVERSE_ID belum di-set, push dilewati.\",\n );\n return;\n }\n\n try {\n const res = await fetch(\n `https://apis.roblox.com/messaging-service/v1/universes/${universeId}/topics/LiveTikTokSpawns`,\n {\n method: \"POST\",\n headers: {\n \"x-api-key\": apiKey,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ message: JSON.stringify(payload) }),\n },\n );\n\n if (!res.ok) {\n const errText = await res.text().catch(() => \"\");\n console.log(\n `[pushToRoblox] gagal push (HTTP ${res.status}): ${errText} | payload: ${\n JSON.stringify(payload)\n }`,\n );\n }\n } catch (err) {\n console.log(\"[pushToRoblox] error saat fetch ke Roblox Open Cloud:\", err);\n }\n}\n\n// ============================================================\n// TIMEOUT CHECK\n// ============================================================\nasync function resolveWaiting(waiting: WaitingUser): Promise {\n if (!waiting) return null;\n\n const now = Date.now();\n if (now < new Date(waiting.expiresAt).getTime()) return waiting;\n\n const credits = await readCredits();\n credits[waiting.tiktokUsername] = {\n gift: waiting.giftName,\n count: waiting.giftCount,\n grantedAt: new Date().toISOString(),\n };\n await writeCredits(credits);\n await writeWaiting(null);\n return null;\n}\n\n// ============================================================\n// GIFT PROCESSOR\n// ============================================================\nasync function processIncomingGift(\n tiktokUsername: string,\n giftName: string,\n giftCount: number,\n): Promise {\n const reward = findReward(giftName);\n if (!reward) {\n console.log(\n `[unmapped gift] \"${giftName}\" dari ${tiktokUsername} — tidak ada di GIFT_REWARDS`,\n );\n return;\n }\n\n // Kirim gift_notification ke Roblox (untuk semua gift)\n await pushToRoblox({\n type: \"gift_notification\",\n username: tiktokUsername,\n tiktokUsername: tiktokUsername,\n giftName: giftName,\n amount: giftCount,\n });\n\n // Blackhole langsung trigger tanpa nunggu comment username Roblox\n if (reward.type === \"blackhole\") {\n const event: RobloxEvent = {\n type: \"blackhole\",\n username: tiktokUsername,\n tiktokUsername: tiktokUsername,\n };\n await pushToRoblox(event);\n const eq = await readEventQueue();\n eq.push(event);\n await writeEventQueue(eq);\n return;\n }\n\n // [TAMBAH] Doughnut (meteor_aura) butuh comment username Roblox, sama seperti Rosa\n // Rose, Rosa, Doughnut → masuk waiting / gift queue\n const rawWaiting = await readWaiting();\n const waiting = await resolveWaiting(rawWaiting);\n\n if (!waiting) {\n const expiresAt = new Date(Date.now() + WAITING_TIMEOUT_MS).toISOString();\n await writeWaiting({ tiktokUsername, giftName, giftCount, expiresAt });\n } else {\n const gq = await readGift();\n gq.push({\n username: tiktokUsername,\n gift: giftName,\n count: giftCount,\n createdAt: new Date().toISOString(),\n });\n await writeGift(gq);\n }\n}\n\n// ============================================================\n// COMMENT (USERNAME) PROCESSOR\n// ============================================================\nasync function processIncomingComment(\n robloxUsername: string,\n tiktokUsername: string,\n): Promise {\n const rawWaiting = await readWaiting();\n const waiting = await resolveWaiting(rawWaiting);\n\n if (waiting && waiting.tiktokUsername === tiktokUsername) {\n const event = buildRobloxEvent(\n waiting.giftName,\n waiting.giftCount,\n robloxUsername,\n waiting.tiktokUsername,\n );\n if (event) {\n await pushToRoblox(event);\n const eq = await readEventQueue();\n eq.push(event);\n await writeEventQueue(eq);\n }\n await writeWaiting(null);\n\n await promoteNextGiftFromQueue();\n return;\n }\n\n const credits = await readCredits();\n if (credits[tiktokUsername]) {\n const { gift, count } = credits[tiktokUsername];\n const event = buildRobloxEvent(gift, count, robloxUsername, tiktokUsername);\n if (event) {\n await pushToRoblox(event);\n const eq = await readEventQueue();\n eq.push(event);\n await writeEventQueue(eq);\n }\n delete credits[tiktokUsername];\n await writeCredits(credits);\n return;\n }\n\n const cq = await readComment();\n cq.push({\n username: robloxUsername,\n tiktokUsername,\n createdAt: new Date().toISOString(),\n });\n await writeComment(cq);\n await pushToRoblox({\n type: \"comment\",\n username: robloxUsername,\n tiktokUsername,\n });\n}\n\n// ============================================================\n// PROMOTE NEXT GIFT FROM QUEUE\n// ============================================================\nasync function promoteNextGiftFromQueue(): Promise {\n const gq = await readGift();\n if (!gq.length) return;\n\n const next = gq.shift();\n if (!next) return;\n await writeGift(gq);\n\n if (!findReward(next.gift)) {\n await promoteNextGiftFromQueue();\n return;\n }\n\n const expiresAt = new Date(Date.now() + WAITING_TIMEOUT_MS).toISOString();\n await writeWaiting({\n tiktokUsername: next.username,\n giftName: next.gift,\n giftCount: next.count,\n expiresAt,\n });\n}\n\n// ============================================================\n// REQUEST BODY PARSERS\n// ============================================================\nasync function getCommentData(req: Request) {\n const url = new URL(req.url);\n let username = url.searchParams.get(\"username\") || \"\";\n let tiktokUsername = url.searchParams.get(\"tiktokUsername\") || \"\";\n\n if (!username) {\n try {\n const body = await req.clone().json();\n username = body.username || \"\";\n tiktokUsername = body.tiktokUsername || \"\";\n } catch {}\n }\n if (!username) {\n try {\n const form = await req.clone().formData();\n username = form.get(\"username\")?.toString() || \"\";\n tiktokUsername = form.get(\"tiktokUsername\")?.toString() || \"\";\n } catch {}\n }\n if (!username) {\n try {\n username = (await req.text()).trim();\n } catch {}\n }\n\n return { username: username.trim(), tiktokUsername: tiktokUsername.trim() };\n}\n\nasync function getGiftData(req: Request) {\n const url = new URL(req.url);\n let username = url.searchParams.get(\"username\") || \"\";\n let gift = url.searchParams.get(\"gift\") || \"\";\n let count = url.searchParams.get(\"count\") || \"1\";\n\n if (!gift) {\n try {\n const body = await req.clone().json();\n username = username || body.username || \"\";\n gift = gift || body.gift || \"\";\n count = count || body.count || \"1\";\n } catch {}\n }\n if (!gift) {\n try {\n const form = await req.clone().formData();\n username = username || form.get(\"username\")?.toString() || \"\";\n gift = gift || form.get(\"gift\")?.toString() || \"\";\n count = count || form.get(\"count\")?.toString() || \"1\";\n } catch {}\n }\n\n return {\n username: username.trim(),\n gift: gift.trim(),\n count: Number(count) || 1,\n };\n}\n\n// ============================================================\n// PANEL HTML\n// ============================================================\nfunction panelHTML(\n commentQ: CommentItem[],\n giftQ: GiftItem[],\n waiting: WaitingUser,\n credits: GiftCredits,\n eventQ: RobloxEvent[],\n) {\n const commentList = commentQ\n .map(\n (v) =>\n `

💬 ${v.username} (TikTok: ${\n v.tiktokUsername || \"-\"\n })

`,\n )\n .join(\"\");\n\n const giftList = giftQ\n .map(\n (v) => `

🎁 ${v.username} - ${v.gift} x${v.count}

`,\n )\n .join(\"\");\n\n const waitingHTML = waiting\n ? `

⏳ ${waiting.tiktokUsername} menunggu username Roblox (gift: ${waiting.giftName} x${waiting.giftCount}) — expire: ${\n new Date(waiting.expiresAt).toLocaleTimeString()\n }

`\n : `

— tidak ada —

`;\n\n const creditEntries = Object.entries(credits);\n const creditHTML = creditEntries.length\n ? creditEntries\n .map(([u, c]) =>\n `

💳 ${u} → ${c.gift} x${c.count}

`\n )\n .join(\"\")\n : `

— tidak ada —

`;\n },\n )\n .join(\"\")\n : `

— tidak ada —

${icon} ${name} → ${desc}

`;\n })\n .join(\"\");\n\n const giftOptions = Object.keys(GIFT_REWARDS)\n .map((g) => ``)\n .join(\"\");\n\n return `\n\n\nRoblox Gift Priority Panel\n\n\n

🛠️ Quick Admin Actions

\n \n

\n\n

🗺️ Gift Reward Mapping

\n ${rewardList}\n

\n\n

⏳ Waiting User (aktif)

\n ${waitingHTML}\n

\n\n

💳 Gift Credits (tersimpan)

Total: ${creditEntries.length}

\n ${creditHTML}\n

\n\n

🎮 Roblox Event Queue

Menunggu diambil Roblox: ${eventQ.length}

\n ${eventHTML}\n \n

\n\n

☄️ QUICK TEST METEOR / DOUGHNUT

Simulasi viewer gift Doughnut (30 coin) → meteor strike. Masukkan TikTok username + username Roblox target.

\n \n \n \n

\n\n

⚡ QUICK TEST (Gift + Comment otomatis)

Kirim gift lalu langsung kirim comment dengan TikTok username yang sama secara otomatis.

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

\n\n

💬 COMMENT TEST

Simulasikan viewer mengirim username Roblox mereka via komentar TikTok

\n \n \n \n

Queue comment biasa: ${commentQ.length}

${commentList}

\n\n

🎁 GIFT TEST

Simulasikan viewer mengirim gift. Gift yg dikenal: ${\n Object.keys(GIFT_REWARDS).join(\", \")\n }

\n \n \n \n \n

Gift queue (menunggu): ${giftQ.length}

${giftList}

Diff · v41