Roblox Gift Priority Panel

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_159":160,"_161":162},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_120":-5,"_20":121,"_22":122,"_123":124,"_125":126,"_25":127,"_24":-5,"_128":-5,"_129":-5,"_130":53,"_131":132,"_133":44,"_134":-5,"_135":-5,"_136":137},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","maspram07","name","roblox-queue-api","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":69,"_70":-5,"_71":72,"_73":37,"_74":44,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":82,"_83":84,"_85":86,"_87":-5,"_88":89,"_90":89,"_91":92,"_93":92,"_94":92,"_95":89,"_96":89,"_97":98,"_99":100,"_101":102,"_103":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","cfe00c3b-5158-407d-a1fa-3bafe6ea01d4","main.ts","fileId","d889b88c-5f74-11f1-b984-1607ee4eb77e","parentId","branchId","cfb10238-5f74-11f1-b984-1607ee4eb77e","branchVersion",48,"latest",true,"createdAt",["D",1784385064344],47,"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 WAITING_LIST_KEY = \"roblox_waiting_list_v3\"; // [FIX v3] gifts diakumulasi, bukan objek tunggal per user\nconst CREDIT_KEY = \"roblox_gift_credit_v2\"; // [FIX v3] array per user, bukan 1 credit per user\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\n// [FIX v3] Setiap entri waiting sekarang bisa menampung LEBIH DARI SATU\n// jenis gift dari orang yang sama, dan count-nya DIAKUMULASI (ditambah),\n// bukan ditimpa. Jadi kalau viewer A gift Rosa lalu gift Rosa lagi\n// sebelum sempat komen, count-nya jadi 2, bukan hilang jadi 1 lagi.\ntype WaitingEntry = {\n tiktokUsername: string;\n gifts: Record; // giftName -> giftCount terakumulasi\n expiresAt: string;\n};\n\ntype GiftCredit = {\n gift: string;\n count: number;\n grantedAt: string;\n};\n\n// [FIX v3] Satu user bisa punya beberapa credit (dari beberapa jenis\n// gift) yang belum diklaim, bukan cuma 1 credit terakhir.\ntype GiftCredits = Record;\n\ntype RobloxEventType =\n | \"spawn\"\n | \"blackhole\"\n | \"cinematic_aura\"\n | \"meteor_aura\"\n | \"gift_notification\";\n\ntype SpawnVariant = \"normal\" | \"giant\";\n\ntype RobloxEvent = {\n type: RobloxEventType;\n username: string;\n tiktokUsername?: string;\n giftName?: string;\n amount?: number;\n variant?: SpawnVariant;\n};\n\n// ============================================================\n// GIFT REWARD MAPPING\n// ============================================================\ntype RewardAction =\n | { type: \"spawn\"; amountPerGift: number; variant?: SpawnVariant }\n | { type: \"blackhole\" }\n | { type: \"cinematic_aura\" }\n | { type: \"meteor_aura\" };\n\nconst GIFT_REWARDS: Record = {\n \"Rose\": { type: \"spawn\", amountPerGift: 1, variant: \"giant\" },\n \"Heart Me\": { type: \"blackhole\" },\n \"Rosa\": { type: \"cinematic_aura\" },\n \"Doughnut\": { type: \"meteor_aura\" },\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 readWaitingList(): Promise {\n const raw = await blob.getJSON(WAITING_LIST_KEY);\n return Array.isArray(raw) ? raw : [];\n}\nasync function writeWaitingList(list: WaitingEntry[]): Promise {\n await blob.setJSON(WAITING_LIST_KEY, list);\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 variant: reward.variant ?? \"normal\",\n };\n }\n if (reward.type === \"blackhole\") {\n return { type: \"blackhole\", username: robloxUsername, tiktokUsername };\n }\n if (reward.type === \"cinematic_aura\") {\n // [FIX-ADIL] amount dikirim supaya Roblox trigger cinematic sebanyak\n // giftCount yang terakumulasi (Rosa x5 = 5x cinematic berturut-turut),\n // bukan cuma 1x seperti sebelumnya.\n return {\n type: \"cinematic_aura\",\n username: robloxUsername,\n tiktokUsername,\n amount: giftCount,\n };\n }\n if (reward.type === \"meteor_aura\") {\n // [FIX-ADIL] sama seperti cinematic_aura, amount menentukan jumlah\n // trigger meteor berturut-turut di Roblox.\n return {\n type: \"meteor_aura\",\n username: robloxUsername,\n tiktokUsername,\n amount: giftCount,\n };\n }\n return null;\n}\n\n// [FIX v3] Ubah isi \"gifts\" (map giftName->count) di satu waiting entry\n// menjadi daftar RobloxEvent, satu event per jenis gift (amount-nya\n// sudah terakumulasi kalau gift yang sama dikirim berkali-kali).\nfunction buildEventsFromGiftsMap(\n gifts: Record,\n robloxUsername: string,\n tiktokUsername: string,\n): RobloxEvent[] {\n const events: RobloxEvent[] = [];\n for (const [giftName, giftCount] of Object.entries(gifts)) {\n const event = buildRobloxEvent(\n giftName,\n giftCount,\n robloxUsername,\n tiktokUsername,\n );\n if (event) events.push(event);\n }\n return events;\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// [FIX] TIMEOUT SWEEP — jalan di setiap request, buang entri waiting\n// yang sudah expired dan pindahkan SEMUA gift di dalamnya (bisa lebih\n// dari satu jenis) jadi credit yang DITAMBAHKAN ke daftar credit user\n// itu, bukan menimpa credit lama.\n// ============================================================\nasync function sweepExpiredWaiting(): Promise {\n const list = await readWaitingList();\n const now = Date.now();\n const stillWaiting: WaitingEntry[] = [];\n const expired: WaitingEntry[] = [];\n\n for (const w of list) {\n if (now < new Date(w.expiresAt).getTime()) {\n stillWaiting.push(w);\n } else {\n expired.push(w);\n }\n }\n\n if (expired.length) {\n const credits = await readCredits();\n for (const w of expired) {\n const existing = credits[w.tiktokUsername] ?? [];\n for (const [giftName, giftCount] of Object.entries(w.gifts)) {\n existing.push({\n gift: giftName,\n count: giftCount,\n grantedAt: new Date().toISOString(),\n });\n }\n credits[w.tiktokUsername] = existing;\n }\n await writeCredits(credits);\n await writeWaitingList(stillWaiting);\n }\n\n return stillWaiting;\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 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 // [FIX v3] Rose, Rosa, Doughnut → setiap gift tetap dapat slot waiting\n // sendiri per tiktokUsername (paralel, tidak antre dengan user lain).\n // BEDANYA dari sebelumnya: kalau tiktokUsername yang sama gift lagi\n // sebelum slotnya diproses, gift baru DIAKUMULASI ke slot yang sama\n // (count ditambah kalau gift sejenis, atau ditambahkan sebagai entri\n // gift baru kalau jenisnya beda) — bukan menimpa/menghilangkan gift\n // sebelumnya. Timeout-nya juga di-refresh supaya user yang lagi aktif\n // gift tidak keburu expired.\n await sweepExpiredWaiting();\n const list = await readWaitingList();\n const idx = list.findIndex((w) => w.tiktokUsername === tiktokUsername);\n const expiresAt = new Date(Date.now() + WAITING_TIMEOUT_MS).toISOString();\n\n if (idx !== -1) {\n const entry = list[idx];\n entry.gifts[giftName] = (entry.gifts[giftName] ?? 0) + giftCount;\n entry.expiresAt = expiresAt; // refresh timeout selagi user masih aktif gift\n } else {\n list.push({\n tiktokUsername,\n gifts: { [giftName]: giftCount },\n expiresAt,\n });\n }\n await writeWaitingList(list);\n}\n\n// ============================================================\n// COMMENT (USERNAME) PROCESSOR\n// ============================================================\nasync function processIncomingComment(\n robloxUsername: string,\n tiktokUsername: string,\n): Promise {\n const list = await sweepExpiredWaiting();\n\n // Cari entri waiting milik tiktokUsername ini secara spesifik.\n const idx = list.findIndex((w) => w.tiktokUsername === tiktokUsername);\n if (idx !== -1) {\n const waiting = list[idx];\n // [FIX v3] proses SEMUA gift yang menumpuk di slot ini, bukan cuma satu\n const events = buildEventsFromGiftsMap(\n waiting.gifts,\n robloxUsername,\n waiting.tiktokUsername,\n );\n if (events.length) {\n const eq = await readEventQueue();\n for (const event of events) {\n await pushToRoblox(event);\n eq.push(event);\n }\n await writeEventQueue(eq);\n }\n list.splice(idx, 1);\n await writeWaitingList(list);\n return;\n }\n\n const credits = await readCredits();\n const userCredits = credits[tiktokUsername];\n if (userCredits && userCredits.length) {\n const eq = await readEventQueue();\n for (const { gift, count } of userCredits) {\n const event = buildRobloxEvent(\n gift,\n count,\n robloxUsername,\n tiktokUsername,\n );\n if (event) {\n await pushToRoblox(event);\n eq.push(event);\n }\n }\n await writeEventQueue(eq);\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// [FIX] BULK LOAD TEST — simulasi banyak viewer gift + comment\n// sekaligus, buat nge-test apakah waiting-list/akumulasi tahan pas\n// rame (banyak tiktokUsername berbeda gift hampir bersamaan).\n// Sengaja reuse processIncomingGift/processIncomingComment yang asli\n// (bukan logic duplikat) supaya hasil test representatif sama\n// perilaku produksi.\n// ============================================================\nfunction randomSuffix(len = 5): string {\n const chars = \"abcdefghijklmnopqrstuvwxyz0123456789\";\n let s = \"\";\n for (let i = 0; i < len; i++) {\n s += chars[Math.floor(Math.random() * chars.length)];\n }\n return s;\n}\n\ntype BulkTestOptions = {\n count: number;\n gift: string; // nama gift, atau \"__random__\" untuk campur semua jenis\n withComment: boolean; // langsung susulkan comment (uji alur penuh)\n delayMs: number; // jeda antar viewer, 0 = secepat mungkin\n robloxUsernames: string[]; // [FIX] username Roblox ASLI, di-cycle round-robin\n};\n\nasync function runBulkTest(opts: BulkTestOptions): Promise<\n {\n ok: true;\n count: number;\n gift: string;\n withComment: boolean;\n sample: string[];\n } | {\n ok: false;\n error: string;\n }\n> {\n const cleanedUsernames = opts.robloxUsernames\n .map((u) => u.trim())\n .filter((u) => u.length >= 3 && u.length <= 20);\n\n // [FIX] kalau withComment aktif, WAJIB ada username Roblox asli, karena\n // itu yang bakal divalidasi ke Players:GetUserIdFromNameAsync() di Roblox.\n // Username acak/ngasal tidak akan pernah nyata muncul di game.\n if (opts.withComment && !cleanedUsernames.length) {\n return {\n ok: false,\n error:\n \"Untuk test dengan comment (spawn beneran), isi minimal 1 username Roblox ASLI (3-20 karakter).\",\n };\n }\n\n const giftNames = Object.keys(GIFT_REWARDS);\n const ts = Date.now();\n const sample: string[] = [];\n\n for (let i = 1; i <= opts.count; i++) {\n const giftName = opts.gift === \"__random__\"\n ? giftNames[Math.floor(Math.random() * giftNames.length)]\n : opts.gift;\n\n // tiktokUsername boleh tetap acak — tidak divalidasi ke server manapun,\n // cuma dipakai sebagai key internal buat matching gift <-> comment.\n const tiktokUsername = `loadtest_${ts}_${i}_${randomSuffix(4)}`;\n // [FIX] username Roblox di-cycle round-robin dari daftar asli yang\n // di-supply user, BUKAN di-generate acak lagi.\n const robloxUsername = cleanedUsernames.length\n ? cleanedUsernames[(i - 1) % cleanedUsernames.length]\n : \"\";\n\n await processIncomingGift(tiktokUsername, giftName, 1);\n\n if (opts.withComment) {\n await processIncomingComment(robloxUsername, tiktokUsername);\n }\n\n if (i <= 5) {\n sample.push(\n `${tiktokUsername} → ${\n robloxUsername || \"(belum di-comment)\"\n } (${giftName})`,\n );\n }\n\n if (opts.delayMs > 0) {\n await new Promise((res) => setTimeout(res, opts.delayMs));\n }\n }\n\n return {\n ok: true,\n count: opts.count,\n gift: opts.gift,\n withComment: opts.withComment,\n sample,\n };\n}\n\n// ============================================================\n// [FIX v2] BULK SPAWN TEST — murni spam KARAKTER, TANPA gift sama\n// sekali dan TANPA lewat comment queue (jadi tidak kena cooldown 30\n// detik / anti-duplikat). Dibangun ulang total karena versi awal\n// (generate username acak seperti \"SPabc123\") TIDAK PERNAH benar-benar\n// nge-spawn apapun — Roblox script memvalidasi tiap nama lewat\n// Players:GetUserIdFromNameAsync(), dan kalau akunnya tidak nyata,\n// langsung di-skip (lihat warn \"Username tidak ditemukan / skip\").\n//\n// Solusinya: pakai username Roblox ASLI (akun kamu sendiri / alt /\n// tim), lalu tiap username itu di-duplikasi berkali-kali lewat event\n// \"spawn\" (path yang sama dipakai gift Rose, ForceDuplicate=true) —\n// jadi TIDAK kena dedup/cooldown, dan avatar-nya nyata karena\n// username-nya nyata.\n// ============================================================\nasync function runBulkSpawnTest(opts: {\n usernames: string[];\n count: number;\n delayMs: number;\n}): Promise<\n { ok: true; count: number; perUsername: Record } | {\n ok: false;\n error: string;\n }\n> {\n const cleanedUsernames = opts.usernames\n .map((u) => u.trim())\n .filter((u) => u.length >= 3 && u.length <= 20);\n\n if (!cleanedUsernames.length) {\n return {\n ok: false,\n error:\n \"Tidak ada username Roblox valid (harus 3-20 karakter, tanpa spasi/simbol).\",\n };\n }\n\n // Bagi rata jumlah spawn ke tiap username di pool\n const base = Math.floor(opts.count / cleanedUsernames.length);\n const remainder = opts.count % cleanedUsernames.length;\n const perUsername: Record = {};\n\n for (let i = 0; i < cleanedUsernames.length; i++) {\n const username = cleanedUsernames[i];\n const amount = base + (i < remainder ? 1 : 0);\n if (amount <= 0) continue;\n\n perUsername[username] = (perUsername[username] ?? 0) + amount;\n\n const event: RobloxEvent = {\n type: \"spawn\",\n username,\n amount,\n variant: \"normal\",\n };\n await pushToRoblox(event);\n const eq = await readEventQueue();\n eq.push(event);\n await writeEventQueue(eq);\n\n if (opts.delayMs > 0) {\n await new Promise((res) => setTimeout(res, opts.delayMs));\n }\n }\n\n return { ok: true, count: opts.count, perUsername };\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 waitingList: WaitingEntry[],\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 // [FIX v3] setiap waiting entry bisa punya beberapa jenis gift, tampilkan semuanya\n const waitingHTML = waitingList.length\n ? waitingList\n .map((w) => {\n const giftsStr = Object.entries(w.gifts)\n .map(([name, count]) => `${name} x${count}`)\n .join(\", \");\n return `

⏳ ${w.tiktokUsername} menunggu username Roblox (gift: ${giftsStr}) — expire: ${\n new Date(w.expiresAt).toLocaleTimeString()\n }

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

— tidak ada —

`;\n\n // [FIX v3] credits sekarang array per user\n const creditEntries = Object.entries(credits).filter(([, arr]) => arr.length);\n const totalCredits = creditEntries.reduce(\n (sum, [, arr]) => sum + arr.length,\n 0,\n );\n const creditHTML = creditEntries.length\n ? creditEntries\n .map(([u, arr]) => {\n const giftsStr = arr.map((c) => `${c.gift} x${c.count}`).join(\", \");\n return `

💳 ${u} → ${giftsStr}

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

— tidak ada —

`;\n\n const eventHTML = eventQ.length\n ? eventQ\n .map(\n (e) => {\n const icon = e.type === \"meteor_aura\"\n ? \"☄️\"\n : e.type === \"cinematic_aura\"\n ? \"🌟\"\n : e.type === \"blackhole\"\n ? \"🌌\"\n : e.type === \"spawn\"\n ? (e.variant === \"giant\" ? \"🗿\" : \"👤\")\n : \"🎁\";\n return `

${icon} type: ${e.type}${\n e.variant ? ` (${e.variant})` : \"\"\n } | 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 const desc = r.type === \"spawn\"\n ? (r.variant === \"giant\"\n ? `spawn GIANT x${r.amountPerGift}/gift`\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)\"\n : \"cinematic + aura\";\n const icon = r.type === \"meteor_aura\"\n ? \"☄️\"\n : r.type === \"cinematic_aura\"\n ? \"🌟\"\n : r.type === \"blackhole\"\n ? \"🌌\"\n : (r.type === \"spawn\" && r.variant === \"giant\")\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 const bulkGiftOptions =\n `` +\n Object.keys(GIFT_REWARDS).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 Users (aktif) — ${waitingList.length}

\n ${waitingHTML}\n

\n\n

💳 Gift Credits (tersimpan)

Total: ${totalCredits}

\n ${creditHTML}\n

\n\n

🎮 Roblox Event Queue

Menunggu diambil Roblox: ${eventQ.length}

\n ${eventHTML}\n \n

\n\n

👤 BULK SPAWN TEST (Tanpa Gift, Murni Karakter)

Spam spawn karakter langsung (path sama seperti gift Rose, anti-dedup/cooldown) — TIDAK lewat gift/waiting-list. Wajib pakai username Roblox ASLI (akun kamu/alt/tim), karena Roblox memvalidasi tiap nama ke server asli — username acak/ngasal TIDAK akan pernah nyata muncul di game. Jumlah spawn dibagi rata ke tiap username di daftar (misal 3 username, jumlah 150 → masing-masing 50x).

\n \n \n \n \n

\n\n

🧪 BULK LOAD TEST (Spam Spawn Viewer)

Simulasi banyak viewer gift + comment sekaligus, buat nge-test waiting-list/akumulasi tahan pas rame apa nggak. Menjalankan alur asli (bukan logic tiruan), tiktokUsername digenerate otomatis. Kalau centang \"langsung susulkan comment\", wajib isi username Roblox ASLI di bawah (di-cycle bergantian) — kalau cuma mau uji waiting-list-nya doang (tanpa spawn beneran), boleh kosongin & matiin centangnya.

\n \n \n \n \n \n Langsung susulkan comment (uji alur penuh gift → username, bukan cuma numpuk di waiting list)\n \n \n

⚠️ Kalau ROBLOX_API_KEY/ROBLOX_UNIVERSE_ID sudah di-set, tiap event beneran di-push ke Roblox Open Cloud — jumlah besar + delay 0 bisa kena rate limit. Kasih delay (misal 50-100ms) kalau mau nembak ratusan sekaligus ke game asli.

\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

\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 waitingList = await sweepExpiredWaiting();\n const credits = await readCredits();\n const eq = await readEventQueue();\n return new Response(panelHTML(cq, waitingList, 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 === \"/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 waitingList = await sweepExpiredWaiting();\n const credits = await readCredits();\n const eq = await readEventQueue();\n return Response.json({\n commentQueue: cq.length,\n waitingUsers: waitingList,\n giftCredits: credits,\n eventQueue: eq,\n });\n }\n\n if (path === \"/admin/bulk-spawn-test\" && method === \"POST\") {\n let body: any = {};\n try {\n body = await req.json();\n } catch {}\n\n const count = Math.max(1, Math.min(500, Number(body.count) || 100));\n const delayMs = Math.max(0, Number(body.delayMs) || 0);\n\n let usernames: string[] = [];\n if (Array.isArray(body.usernames)) {\n usernames = body.usernames.map((u: unknown) => String(u));\n } else if (typeof body.usernames === \"string\") {\n usernames = body.usernames.split(/[\\n,]+/);\n }\n\n const result = await runBulkSpawnTest({ usernames, count, delayMs });\n if (!result.ok) {\n return Response.json({ error: result.error }, { status: 400 });\n }\n return Response.json(result);\n }\n\n if (path === \"/admin/bulk-test\" && method === \"POST\") {\n let body: any = {};\n try {\n body = await req.json();\n } catch {}\n\n const count = Math.max(1, Math.min(500, Number(body.count) || 100));\n const gift = typeof body.gift === \"string\" && body.gift\n ? body.gift\n : \"__random__\";\n const withComment = body.withComment !== false;\n const delayMs = Math.max(0, Number(body.delayMs) || 0);\n\n let robloxUsernames: string[] = [];\n if (Array.isArray(body.robloxUsernames)) {\n robloxUsernames = body.robloxUsernames.map((u: unknown) => String(u));\n } else if (typeof body.robloxUsernames === \"string\") {\n robloxUsernames = body.robloxUsernames.split(/[\\n,]+/);\n }\n\n if (gift !== \"__random__\" && !findReward(gift)) {\n return Response.json({\n error: `gift \"${gift}\" tidak ada di GIFT_REWARDS`,\n }, {\n status: 400,\n });\n }\n\n const result = await runBulkTest({\n count,\n gift,\n withComment,\n delayMs,\n robloxUsernames,\n });\n if (!result.ok) {\n return Response.json({ error: result.error }, { status: 400 });\n }\n return Response.json(result);\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 writeWaitingList([]);\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}","deleted",false,"label",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":59,"_18":60},["D",1784385064344],"children",[],[35],"cfaf811a-5f74-11f1-b984-1607ee4eb77e",["D",1780509073040],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","HTTP webhook API to queue data for a Roblox game","imageUrl","userId","0542ae74-889c-4c63-8bc9-e98c3f6cb018","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e8e9a-d73a-70fc-804d-62b9d683cf94","tursoName","cfaf811a5f7411f1b9841607ee4eb77e","tursoHostname","cfaf811a5f7411f1b9841607ee4eb77e-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789500119686],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_119":115},"org",{"_11":12,"_112":113,"_114":115,"_71":72,"_116":117,"_118":53},"branch",{"_17":42,"_13":16,"_33":40,"_104":61,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":-5,"_110":14,"_111":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Maspram07","avatar","https://lh3.googleusercontent.com/a/ACg8ocJilBcHbOF3FNUBNu1MhKje7FZkjw0wnrDDi8-ltwLQ9xQJnw=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":61,"_13":14,"_45":154,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":69,"_70":-5,"_71":72,"_73":37,"_74":44,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":82,"_83":84,"_85":155,"_87":-5,"_88":89,"_90":89,"_91":92,"_93":92,"_94":92,"_95":89,"_96":89,"_97":156,"_99":157,"_101":158,"_103":53},[151],"files",[151],"counts",{"_140":78,"_141":142,"_143":78,"_31":144,"_145":146},[138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":139},[35],"pulls","branches",1,"forks",{"_147":149,"_150":78},"connections",{"_147":78,"_148":78},"count","unfilledCount",2,"emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":152,"_18":153},[],[35],["D",1780509073040],["D",1789500119686],{"_11":12,"_119":115},{"_11":12,"_112":113,"_114":115,"_71":72,"_116":117,"_118":53},{"_17":42,"_13":16,"_33":40,"_104":61,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":-5,"_110":14,"_111":12},"ctx",{"_97":-5,"_135":192,"_193":194,"_195":196,"_197":53,"_198":53,"_199":53,"_200":44,"_201":-5,"_202":-7,"_203":-7,"_204":78,"_205":53,"_206":53,"_207":-5,"_208":53,"_209":53,"_210":53,"_211":-5},"ENV",{"_163":164,"_165":166,"_167":16,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191},"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"]

Code