[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_227":228,"_229":230},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_105":87,"_27":99,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":25,"_122":-5,"_123":-5,"_124":125},"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":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",181,"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","mic9likr-0_15m.ts","latestPath","fileId","3741bf7c-7f60-11f1-aee1-1607ee4eb77e","name","fileType","interval","content","// --- CONFIGURATION ---\nconst SUPABASE_URL = Deno.env.get(\"SUPABASE_URL\");\nconst SUPABASE_ANON_KEY = Deno.env.get(\"SUPABASE_ANON_KEY\");\nconst MESSAGE_IDS: number[] = [\n 2787,\n 2789,\n 569,\n 485,\n 566,\n 575,\n 581,\n 577,\n 576,\n];\n\nconst headers = {\n \"Content-Type\": \"application/json\",\n apikey: SUPABASE_ANON_KEY!,\n Authorization: `Bearer ${SUPABASE_ANON_KEY}`,\n};\n\nconst FILENAME = import.meta.url.split(\"/\").pop();\n\nconst CONCURRENCY_LIMIT = 1000; // Max parallel requests active at any given moment\nconst INTERVAL_DELAY = 10; // Pause (ms) before spawning the next request\n\nconst sleep = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms));\n\n// Helper function to pick a random ID from the list\nconst getRandomMessageId = (): number => {\n return MESSAGE_IDS[Math.floor(Math.random() * MESSAGE_IDS.length)];\n};\n\nasync function sendRequest(reqIndex: number) {\n const startTime = Date.now();\n const targetId = getRandomMessageId();\n\n try {\n const res = await fetch(\n `${SUPABASE_URL}/rest/v1/rpc/increment_board_like`,\n {\n method: \"POST\",\n headers,\n body: JSON.stringify({ msg_id: targetId }),\n },\n );\n\n const duration = Date.now() - startTime;\n\n if (res.ok) {\n console.log(\n `[Request #${reqIndex}] SUCCESS | ID: ${targetId} | ${duration}ms`,\n );\n } else {\n const errorText = await res.text();\n console.error(\n `[Request #${reqIndex}] FAILED | ID: ${targetId} | Status: ${res.status}`,\n );\n }\n } catch (error: any) {\n console.error(`[Request #${reqIndex}] NETWORK ERROR | ID: ${targetId}`);\n }\n}\n\nasync function startInfiniteLoop() {\n console.log(\n `Starting infinite loop across ${MESSAGE_IDS.length} randomized target IDs.`,\n );\n console.log(`Concurrency Limit: ${CONCURRENCY_LIMIT}\\n`);\n\n const executing = new Set>();\n let totalSent = 0;\n\n while (true) {\n totalSent++;\n const currentIdx = totalSent;\n\n const taskPromise = sendRequest(currentIdx).then(() => {\n executing.delete(taskPromise);\n });\n\n executing.add(taskPromise);\n\n if (executing.size >= CONCURRENCY_LIMIT) {\n await Promise.race(executing);\n }\n\n if (INTERVAL_DELAY > 0) {\n await sleep(INTERVAL_DELAY);\n }\n }\n}\n\n// Val Town entry point\nexport default async function (req?: Request): Promise {\n console.log(FILENAME);\n // Start the loop in the background so the HTTP request can return immediately\n startInfiniteLoop();\n\n return new Response(\"Loop started in background!\", { status: 200 });\n}","// --- CONFIGURATION ---\nconst SUPABASE_URL = Deno.env.get(\"SUPABASE_URL\");\nconst SUPABASE_ANON_KEY = Deno.env.get(\"SUPABASE_ANON_KEY\");\nconst MESSAGE_IDS: number[] = [\n 2787,\n 2789,\n 569,\n 485,\n 566,\n 575,\n 581,\n 577,\n 576,\n];\n\nconst headers = {\n \"Content-Type\": \"application/json\",\n apikey: SUPABASE_ANON_KEY!,\n Authorization: `Bearer ${SUPABASE_ANON_KEY}`,\n};\n\nconst FILENAME = import.meta.url.split(\"/\").pop();\n\nconst CONCURRENCY_LIMIT = 100; // Max parallel requests active at any given moment\nconst INTERVAL_DELAY = 10; // Pause (ms) before spawning the next request\n\nconst sleep = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms));\n\n// Helper function to pick a random ID from the list\nconst getRandomMessageId = (): number => {\n return MESSAGE_IDS[Math.floor(Math.random() * MESSAGE_IDS.length)];\n};\n\nasync function sendRequest(reqIndex: number) {\n const startTime = Date.now();\n const targetId = getRandomMessageId();\n\n try {\n const res = await fetch(\n `${SUPABASE_URL}/rest/v1/rpc/increment_board_like`,\n {\n method: \"POST\",\n headers,\n body: JSON.stringify({ msg_id: targetId }),\n },\n );\n\n const duration = Date.now() - startTime;\n\n if (res.ok) {\n console.log(\n `[Request #${reqIndex}] SUCCESS | ID: ${targetId} | ${duration}ms`,\n );\n } else {\n const errorText = await res.text();\n console.error(\n `[Request #${reqIndex}] FAILED | ID: ${targetId} | Status: ${res.status}`,\n );\n }\n } catch (error: any) {\n console.error(`[Request #${reqIndex}] NETWORK ERROR | ID: ${targetId}`);\n }\n}\n\nasync function startInfiniteLoop() {\n console.log(\n `Starting infinite loop across ${MESSAGE_IDS.length} randomized target IDs.`,\n );\n console.log(`Concurrency Limit: ${CONCURRENCY_LIMIT}\\n`);\n\n const executing = new Set>();\n let totalSent = 0;\n\n while (true) {\n totalSent++;\n const currentIdx = totalSent;\n\n const taskPromise = sendRequest(currentIdx).then(() => {\n executing.delete(taskPromise);\n });\n\n executing.add(taskPromise);\n\n if (executing.size >= CONCURRENCY_LIMIT) {\n await Promise.race(executing);\n }\n\n if (INTERVAL_DELAY > 0) {\n await sleep(INTERVAL_DELAY);\n }\n }\n}\n\n// Val Town entry point\nexport default async function (req?: Request): Promise {\n console.log(FILENAME);\n // Start the loop in the background so the HTTP request can return immediately\n startInfiniteLoop();\n\n return new Response(\"Loop started in background!\", { status: 200 });\n}","createdAt",["D",1784082257047],"branchVersion","branchId","471f5fd0-ed30-4b7b-9702-0d660ac1ae5c","id","bab078cf-5d5c-4405-8a12-abfcd146f77f","mic9likr",["D",1784017234760],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","2d4b7bf8-8466-47a7-8dc2-19916499db58","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f5be7-df6d-74ca-8b01-8faff883b578","tursoName","bab078cf5d5c44058a12abfcd146f77f","tursoHostname","bab078cf5d5c44058a12abfcd146f77f-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789525245864],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_104":99},"org",{"_97":96,"_98":99,"_100":99,"_18":54,"_101":102,"_103":25},"branch",{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned",216,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","robotsclank","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":222,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":223,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":224,"_81":225,"_83":226,"_85":25},"tree",[193,194,195,196,197,198,199],"files",[193,194,195,196,197,198,199],"counts",{"_182":60,"_183":184,"_185":60,"_186":187,"_188":189},"contents",[126,127,128,129,130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":178,"_32":28,"_30":31,"_136":-5,"_41":42,"_40":14,"_138":25,"_38":179,"_13":180,"_33":34,"_35":37,"_24":25,"_142":-5,"_27":181},{"_43":171,"_32":172,"_30":173,"_136":-5,"_41":42,"_40":174,"_138":25,"_38":175,"_13":176,"_33":34,"_35":36,"_24":25,"_142":-5,"_27":177},{"_43":165,"_32":166,"_30":167,"_136":-5,"_41":42,"_40":168,"_138":25,"_38":169,"_13":156,"_33":34,"_35":36,"_24":25,"_142":-5,"_27":170},{"_43":158,"_32":159,"_30":160,"_136":-5,"_41":42,"_40":161,"_138":25,"_38":162,"_13":163,"_33":34,"_35":36,"_24":25,"_142":-5,"_27":164},{"_43":151,"_32":152,"_30":153,"_136":-5,"_41":42,"_40":154,"_138":25,"_38":155,"_13":156,"_33":34,"_35":36,"_24":25,"_142":-5,"_27":157},{"_43":144,"_32":145,"_30":146,"_136":-5,"_41":42,"_40":147,"_138":25,"_38":148,"_13":149,"_33":34,"_35":36,"_24":25,"_142":-5,"_27":150},{"_43":133,"_32":134,"_30":135,"_136":-5,"_41":42,"_40":137,"_138":25,"_38":139,"_13":140,"_33":34,"_35":141,"_24":25,"_142":-5,"_27":143},"11944e82-33b2-43ae-89ca-b88db098dd2f","new-file-5370.ts","0c0a73be-7ff4-11f1-aea3-1607ee4eb77e","parentId",180,"latest",["D",1784082224283],3,"const SUPABASE_URL = Deno.env.get(\"SUPABASE_URL\");\nconst SUPABASE_ANON_KEY = Deno.env.get(\"SUPABASE_ANON_KEY\");\n\nconst MAX_LOOP: number = 15;\nconst MIN_LIKES: number = 888; // Minimum likes per message\nconst MAX_LIKES: number = 999; // Maximum likes per message\nconst PAUSE_TIME_MS: number = 0; // Pause time between batches\nconst MESSAGE_IDS: number[] = [\n 2787,\n 2789,\n 569,\n 485,\n 566,\n 575,\n 581,\n 577,\n 576,\n 720,\n 572,\n 712,\n]; // Random message IDs]\n\n// Extracts the current filename from the module's metadata URL\nconst FILENAME = import.meta.url.split(\"/\").pop();\n\nconst headers = {\n \"Content-Type\": \"application/json\",\n \"apikey\": SUPABASE_ANON_KEY!,\n \"Authorization\": `Bearer ${SUPABASE_ANON_KEY}`,\n};\n\nconst wait = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms));\n\n// Single worker request\nasync function sendLike(msgId: number) {\n const res = await fetch(`${SUPABASE_URL}/rest/v1/rpc/increment_board_like`, {\n method: \"POST\",\n headers,\n body: JSON.stringify({ msg_id: msgId }),\n });\n if (!res.ok) {\n throw new Error(`HTTP ${res.status}`);\n }\n return res.text();\n}\n\n/**\n * Executes tasks concurrently up to a defined limit using a sliding window.\n * Keeps the connection pipeline fully saturated.\n */\nasync function poolRequests(\n totalCount: number,\n concurrency: number,\n) {\n let success = 0;\n let fail = 0;\n\n const executing = new Set>();\n const promises: Promise[] = [];\n\n for (let i = 0; i < totalCount; i++) {\n const randomMsgId =\n MESSAGE_IDS[Math.floor(Math.random() * MESSAGE_IDS.length)];\n const p = sendLike(randomMsgId)\n .then(() => {\n success++;\n })\n .catch(() => {\n fail++;\n });\n\n promises.push(p);\n executing.add(p);\n\n // Remove the promise from the active pool when resolved\n const clean = () => executing.delete(p);\n p.then(clean, clean);\n\n // If pool is full, wait for the fastest request to finish\n if (executing.size >= concurrency) {\n await Promise.race(executing);\n }\n }\n\n // Wait for any remaining stragglers\n await Promise.all(promises);\n return { success, fail };\n}\n\n/**\n * Main handler\n */\nexport default async function () {\n console.log(FILENAME);\n\n for (let i = 0; i < MAX_LOOP; i++) {\n const batchSize = Math.floor(Math.random() * (MAX_LIKES - MIN_LIKES + 1)) +\n MIN_LIKES;\n\n // Set concurrency (keep-alive pipeline limit)\n const concurrency = Math.floor(Math.random() * (50 - 10 + 1)) + 10;\n\n console.log(`\\n[Batch ${i + 1}/${MAX_LOOP}]`);\n console.log(\n `Sending: ${batchSize} likes, Concurrency limit: ${concurrency}`,\n );\n\n const start = Date.now();\n try {\n const result = await poolRequests(batchSize, concurrency);\n const duration = ((Date.now() - start) / 1000).toFixed(2);\n\n console.log(\n `Success: ${result.success}, Failed: ${result.fail}, Duration: ${duration}s`,\n );\n } catch (err) {\n console.error(\"Batch failed:\", err);\n }\n\n await wait(PAUSE_TIME_MS);\n }\n}","label",[134],"eaf4d2d5-df84-43db-b129-9fabc334a765","mic9likr-5_30m.ts","5847099e-7f78-11f1-8464-1607ee4eb77e",175,["D",1784078307101],13,[145],"86f4df62-33ee-485c-bb73-ecb7cf5a6a0b","mic9likr-4_20m.ts","6d14b5ac-7f77-11f1-845c-1607ee4eb77e",174,["D",1784078300404],9,[152],"46fbb541-7bdf-499c-8cdb-6226d4e69169","mic9likr-3_15m.ts","67b0b50c-7f77-11f1-b807-1607ee4eb77e",173,["D",1784078294900],10,[159],"0bc33972-ad38-486d-80a9-9af7023657b0","mic9likr-2_30m.ts","600aacea-7f77-11f1-8965-1607ee4eb77e",172,["D",1784078289685],[166],"376e26cd-6c45-4a6b-8fbd-48c66605ae97","mic9likr-1_20m.ts","fe740972-7f76-11f1-86ca-1607ee4eb77e",171,["D",1784078283017],15,[172],"fb8ccc83-8978-4ec1-87df-ffff628e9000",["D",1784082257047],43,[28],"pulls","branches",1,"forks","envVars",{"_190":140,"_192":60},"connections",{"_190":60,"_191":60},"count","unfilledCount","emptyCount",{"_43":178,"_32":28,"_30":31,"_136":-5,"_41":42,"_40":14,"_138":25,"_38":219,"_13":180,"_33":34,"_35":37,"_24":25,"_142":-5,"_201":220,"_27":221},{"_43":171,"_32":172,"_30":173,"_136":-5,"_41":42,"_40":174,"_138":25,"_38":216,"_13":176,"_33":34,"_35":36,"_24":25,"_142":-5,"_201":217,"_27":218},{"_43":165,"_32":166,"_30":167,"_136":-5,"_41":42,"_40":168,"_138":25,"_38":213,"_13":156,"_33":34,"_35":36,"_24":25,"_142":-5,"_201":214,"_27":215},{"_43":158,"_32":159,"_30":160,"_136":-5,"_41":42,"_40":161,"_138":25,"_38":210,"_13":163,"_33":34,"_35":36,"_24":25,"_142":-5,"_201":211,"_27":212},{"_43":151,"_32":152,"_30":153,"_136":-5,"_41":42,"_40":154,"_138":25,"_38":207,"_13":156,"_33":34,"_35":36,"_24":25,"_142":-5,"_201":208,"_27":209},{"_43":144,"_32":145,"_30":146,"_136":-5,"_41":42,"_40":147,"_138":25,"_38":204,"_13":149,"_33":34,"_35":36,"_24":25,"_142":-5,"_201":205,"_27":206},{"_43":133,"_32":134,"_30":135,"_136":-5,"_41":42,"_40":137,"_138":25,"_38":200,"_13":140,"_33":34,"_35":141,"_24":25,"_142":-5,"_201":202,"_27":203},["D",1784082224283],"children",[],[134],["D",1784078307101],[],[145],["D",1784078300404],[],[152],["D",1784078294900],[],[159],["D",1784078289685],[],[166],["D",1784078283017],[],[172],["D",1784082257047],[],[28],["D",1784017234760],["D",1789525245864],{"_97":96,"_104":99},{"_97":96,"_98":99,"_100":99,"_18":54,"_101":102,"_103":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_123":260,"_261":262,"_263":264,"_265":25,"_266":25,"_267":25,"_268":269,"_270":-5,"_271":-7,"_272":-7,"_273":60,"_274":25,"_275":25,"_276":-5,"_277":25,"_278":25,"_279":25,"_280":-5},"ENV",{"_231":232,"_233":234,"_235":87,"_236":237,"_238":239,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v181