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",31,"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; // ISO string\n} | null;\n\ntype GiftCredit = {\n gift: string;\n count: number;\n grantedAt: string;\n};\n\ntype GiftCredits = Record;\n\n// Tipe event yang dikirim ke Roblox\ntype RobloxEventType = \"spawn\" | \"blackhole\" | \"cinematic_aura\";\n\ntype RobloxEvent = {\n type: RobloxEventType;\n username: string;\n tiktokUsername?: string; // [BARU] nama TikTok pengirim gift, dibawa ke Roblox\n amount?: number; // untuk spawn\n};\n\ntype PendingGiftEvent = {\n tiktokUsername: string;\n giftName: string;\n giftCount: number;\n enqueuedAt: string;\n};\n\n// ============================================================\n// GIFT REWARD MAPPING\n// PENTING: key di bawah harus nama gift ASLI yang dikirim TikTok\n// Live (sudah dicek lewat log Val Town: \"Rose\", \"Heart Me\", \"Rosa\")\n// — bukan terjemahan/asumsi nama Indonesia.\n// Mudah ditambah: tambahkan entry baru di sini saja.\n// ============================================================\ntype RewardAction =\n | { type: \"spawn\"; amountPerGift: number }\n | { type: \"blackhole\" }\n | { type: \"cinematic_aura\" };\n\nconst GIFT_REWARDS: Record = {\n \"Rose\": { type: \"spawn\", amountPerGift: 5 },\n \"Heart Me\": { type: \"blackhole\" },\n \"Rosa\": { type: \"cinematic_aura\" },\n};\n\n// Lookup case-insensitive + trim, supaya beda kapitalisasi atau\n// spasi nyasar dari TikTok gak bikin gift di-skip diam-diam lagi.\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; // 30 detik\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, // [BARU] dibawa supaya Roblox tahu nama TikTok pengirim\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 return null;\n}\n\n// ============================================================\n// PUSH TO ROBLOX (OPEN CLOUD MESSAGING SERVICE)\n// [BARU] Pengganti sistem polling lama: alih-alih Roblox bolak-balik\n// nge-GET endpoint ini, sekarang Val Town langsung \"menembak\" data\n// ke server Roblox lewat Open Cloud Messaging Service begitu comment/\n// event tervalidasi. Blob storage (writeEventQueue dkk) TETAP jalan\n// seperti biasa supaya Panel HTML & fallback /event tidak terganggu.\n//\n// Wajib di-set di Val Town → Environment Variables:\n// ROBLOX_API_KEY = API key Open Cloud (scope: universe-messaging-service:publish)\n// ROBLOX_UNIVERSE_ID = Universe ID experience Roblox kamu\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 di environment variables, 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; // masih valid\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 if (!findReward(giftName)) {\n console.log(\n `[unmapped gift] \"${giftName}\" dari ${tiktokUsername} — tidak ada di GIFT_REWARDS`,\n );\n return;\n }\n\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, // [BARU]\n );\n if (event) {\n await pushToRoblox(event); // [BARU] tembak instan ke Roblox lewat Open Cloud\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); // [BARU]\n if (event) {\n await pushToRoblox(event); // [BARU] tembak instan ke Roblox lewat Open Cloud\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 }); // [BARU] tembak instan ke Roblox\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 — dengan Quick Admin Actions\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 // [UPDATE] Tampilkan tiktokUsername di event queue, biar gampang cek mapping-nya benar\n const eventHTML = eventQ.length\n ? eventQ\n .map(\n (e) =>\n `

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

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

— tidak ada —

`;\n\n const rewardList = Object.entries(GIFT_REWARDS)\n .map(([name, r]) => {\n const desc = r.type === \"spawn\"\n ? `spawn x${r.amountPerGift}/gift`\n : r.type === \"blackhole\"\n ? \"blackhole effect\"\n : \"cinematic + aura\";\n return `

🎁 ${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} — sekarang ikut bawa tiktokUsername

\n ${eventHTML}\n \n

\n\n

⚡ QUICK TEST (Gift + Comment otomatis)

Kirim gift (dengan nama TikTok yang kamu tentukan) lalu langsung kirim comment dengan TikTok username yang sama secara otomatis — langsung trigger ke /event tanpa perlu isi 2 box manual. Event hasilnya akan bawa nama TikTok ini.

\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 // ENDPOINT: Menghapus total seluruh database blob kembali ke kosong\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; // ISO string\n} | null;\n\ntype GiftCredit = {\n gift: string;\n count: number;\n grantedAt: string;\n};\n\ntype GiftCredits = Record;\n\n// Tipe event yang dikirim ke Roblox\ntype RobloxEventType = \"spawn\" | \"blackhole\" | \"cinematic_aura\";\n\ntype RobloxEvent = {\n type: RobloxEventType;\n username: string;\n tiktokUsername?: string; // [BARU] nama TikTok pengirim gift, dibawa ke Roblox\n amount?: number; // untuk spawn\n};\n\ntype PendingGiftEvent = {\n tiktokUsername: string;\n giftName: string;\n giftCount: number;\n enqueuedAt: string;\n};\n\n// ============================================================\n// GIFT REWARD MAPPING\n// PENTING: key di bawah harus nama gift ASLI yang dikirim TikTok\n// Live (sudah dicek lewat log Val Town: \"Rose\", \"Heart Me\", \"Rosa\")\n// — bukan terjemahan/asumsi nama Indonesia.\n// Mudah ditambah: tambahkan entry baru di sini saja.\n// ============================================================\ntype RewardAction =\n | { type: \"spawn\"; amountPerGift: number }\n | { type: \"blackhole\" }\n | { type: \"cinematic_aura\" };\n\nconst GIFT_REWARDS: Record = {\n \"Rose\": { type: \"spawn\", amountPerGift: 5 },\n \"Heart Me\": { type: \"blackhole\" },\n \"Rosa\": { type: \"cinematic_aura\" },\n};\n\n// Lookup case-insensitive + trim, supaya beda kapitalisasi atau\n// spasi nyasar dari TikTok gak bikin gift di-skip diam-diam lagi.\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; // 30 detik\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, // [BARU] dibawa supaya Roblox tahu nama TikTok pengirim\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 return null;\n}\n\n// ============================================================\n// PUSH TO ROBLOX (OPEN CLOUD MESSAGING SERVICE)\n// [BARU] Pengganti sistem polling lama: alih-alih Roblox bolak-balik\n// nge-GET endpoint ini, sekarang Val Town langsung \"menembak\" data\n// ke server Roblox lewat Open Cloud Messaging Service begitu comment/\n// event tervalidasi. Blob storage (writeEventQueue dkk) TETAP jalan\n// seperti biasa supaya Panel HTML & fallback /event tidak terganggu.\n//\n// Wajib di-set di Val Town → Environment Variables:\n// ROBLOX_API_KEY = API key Open Cloud (scope: universe-messaging-service:publish)\n// ROBLOX_UNIVERSE_ID = Universe ID experience Roblox kamu\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;54ikBB/YFUaoI6aaswO1ruDAAYIhQJswQEvJxzT01EbBarMAZXlKaGJHY2lPaUpTVXpJMU5pSXNJbXRwWkNJNkluTnBaeTB5TURJeExUQTNMVEV6VkRFNE9qVXhPalE1V2lJc0luUjVjQ0k2SWtwWFZDSjkuZXlKaGRXUWlPaUpTYjJKc2IzaEpiblJsY201aGJDSXNJbWx6Y3lJNklrTnNiM1ZrUVhWMGFHVnVkR2xqWVhScGIyNVRaWEoyYVdObElpd2lZbUZ6WlVGd2FVdGxlU0k2SWpVMGFXdENRaTlaUmxWaGIwazJZV0Z6ZDA4eGNuVkVRVUZaU1doUlNuTjNVVVYyU25oNlZEQXhSV0pDWVhKTlFTSXNJbTkzYm1WeVNXUWlPaUk0T1RZeE56TTVOemszSWl3aVpYaHdJam94TnpneU1USTFNVFEwTENKcFlYUWlPakUzT0RJeE1qRTFORFFzSW01aVppSTZNVGM0TWpFeU1UVTBOSDAuTHVhNEh3VE5QRkVJYVl1RUxqd0d0QVIwQS1HUE5Zb0VlZFBBQW5Jc3RPaUpwT2dVNkVNa3M3T01Qa3pKRDU2SExlTG1GUGg5RjRnNnZ6REQ5X18wQ05nWkJRenVWN2t2am5pV25qN0FqMUNHY0Y3c1lvbE1kb2lsMnEtZ1VyVUI0bjJoaEs0YVN0Y1ZPX1VxLTdUNDN5NWZTYW52QjdGU0I1TWFMY1hYQXZ2YjcwQVo1a0lvWHNMS2MxRjlvRUNPdThwVkNhNk5kdC10elQ4d005blRDV3oxQTlsOE10NFNmNUxPXy1WV0pVNE01eGFxMmpKLVRITlp5N3VrWGRJS0FDVUZkSF93cVN1TXBfLTVkTEVYSm9CVUpWQm04c0hBWFNNY3FQMDZVR0FfSEZucnhQZ0U5RlJKQmFzR1RHVGhkbDFKLUdjOGJFOEhDNWxFOEpNWGR3\n const universeId = process.env.ROBLOX_UNIVERSE_ID;9967684247\n\n if (!apiKey || !universeId) {\n console.log(\n \"[pushToRoblox] ROBLOX_API_KEY / ROBLOX_UNIVERSE_ID belum di-set di environment variables, 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; // masih valid\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 if (!findReward(giftName)) {\n console.log(\n `[unmapped gift] \"${giftName}\" dari ${tiktokUsername} — tidak ada di GIFT_REWARDS`,\n );\n return;\n }\n\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, // [BARU]\n );\n if (event) {\n await pushToRoblox(event); // [BARU] tembak instan ke Roblox lewat Open Cloud\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); // [BARU]\n if (event) {\n await pushToRoblox(event); // [BARU] tembak instan ke Roblox lewat Open Cloud\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 }); // [BARU] tembak instan ke Roblox\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 — dengan Quick Admin Actions\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 // [UPDATE] Tampilkan tiktokUsername di event queue, biar gampang cek mapping-nya benar\n const eventHTML = eventQ.length\n ? eventQ\n .map(\n (e) =>\n `

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

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

— tidak ada —

🎁 ${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} — sekarang ikut bawa tiktokUsername

\n ${eventHTML}\n \n

\n\n

⚡ QUICK TEST (Gift + Comment 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 · v31