[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_229":230,"_231":232},"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",206,"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","new-file-4563.ts","latestPath","fileId","ddb22f90-804b-11f1-ae6f-1607ee4eb77e","name","fileType","interval","content","import https from \"node:https\";\nimport dns from \"node:dns\";\n\n// --- CONFIGURATION ---\nconst SUPABASE_URL = Deno.env.get(\"SUPABASE_URL\") || \"\";\nconst DOMAIN = SUPABASE_URL ? new URL(SUPABASE_URL).hostname : \"\";\nconst SUPABASE_ANON_KEY = Deno.env.get(\"SUPABASE_ANON_KEY\") || \"\";\n\nimport https from \"https\";\nimport dns from \"dns\";\nimport crypto from \"crypto\";\n\n// --- CONFIGURATION ---\nconst DOMAIN = \"kkaoerbblpuszptiibvo.supabase.co\";\nconst SUPABASE_ANON_KEY = \"eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZSIsInJlZiI6ImtrYW9lcmJibHB1c3pwdGlpYnZvIiwicm9sZSI6ImFub24iLCJpYXQiOjE3ODI1NDY5MTMsImV4cCI6MjA5ODEyMjkxM30.Xf549NzokL9zY7AT8Jd5NYFRj81r7z2hS6i7kZbpCMw\";\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 FILENAME = import.meta.url.split(\"/\").pop();\n\nconst MAX_CONCURRENCY = 100;\nconst MIN_CONCURRENCY = 50;\nconst INITIAL_CONCURRENCY = 10;\nconst CLEAR_INTERVAL_MS = 5 * 60 * 1000; // 5 minutes\n\n// Keep-alive agent configuration for high concurrency request reuse\nconst agent = new https.Agent({\n keepAlive: true,\n maxSockets: MAX_CONCURRENCY,\n maxFreeSockets: MAX_CONCURRENCY,\n keepAliveMsecs: 60000,\n timeout: 15000,\n});\n\n// Performance Counters & State\nlet successCount = 0;\nlet failCount = 0;\nlet lastSuccessCount = 0;\nlet lastFailCount = 0;\nlet targetIps: string[] = [DOMAIN]; // Fallback to domain name\nlet backoffUntil = 0;\nlet currentConcurrency = INITIAL_CONCURRENCY;\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\n// DNS Pre-resolver & updater\nasync function resolveDns() {\n try {\n const ips = await dns.promises.resolve(DOMAIN);\n if (ips && ips.length > 0) {\n targetIps = ips;\n console.log(`Resolved ${DOMAIN} to:`, targetIps);\n }\n } catch (err) {\n console.error(`DNS Resolution failed, using hostname as fallback:`, err);\n targetIps = [DOMAIN];\n }\n}\n\n// Start periodic DNS refresh every 5 minutes\nsetInterval(resolveDns, 5 * 60 * 1000);\n\nasync function sendRequest(): Promise {\n const targetId = getRandomMessageId();\n \n // Format body for the Edge Function /like endpoint\n const postData = JSON.stringify({\n messageId: String(targetId),\n action: \"like\",\n clientId: crypto.randomUUID(), // Unique client ID per request to bypass client-level rate limits\n });\n const postDataLength = Buffer.byteLength(postData);\n\n // Pick random IP from targetIps list to load balance\n const ip = targetIps[Math.floor(Math.random() * targetIps.length)];\n\n return new Promise((resolve) => {\n const req = https.request(\n {\n host: ip,\n port: 443,\n path: \"/functions/v1/idolcamp-api/like\",\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Content-Length\": postDataLength,\n apikey: SUPABASE_ANON_KEY,\n Authorization: `Bearer ${SUPABASE_ANON_KEY}`,\n Host: DOMAIN,\n Connection: \"keep-alive\",\n },\n servername: DOMAIN, // SNI servername is required for TLS validation on IP connection\n agent,\n timeout: 10000, // 10 seconds request timeout\n },\n (res) => {\n // Consume the response body immediately\n res.resume();\n \n res.on(\"end\", () => {\n const status = res.statusCode || 0;\n if (status >= 200 && status < 300) {\n successCount++;\n resolve(true);\n } else {\n failCount++;\n \n // Check for rate-limiting or server failure status codes\n if (status === 429 || status === 520 || status === 502 || status === 503 || status === 504) {\n let backoffDelay = 5000; // default 5s backoff\n const retryAfter = res.headers[\"retry-after\"];\n if (retryAfter) {\n const parsed = parseInt(retryAfter, 10);\n if (!isNaN(parsed)) {\n backoffDelay = parsed * 1000;\n }\n }\n // Add a bit of jitter to prevent thundering herd when resuming\n const jitter = Math.floor(Math.random() * 2000);\n backoffUntil = Math.max(backoffUntil, Date.now() + backoffDelay + jitter);\n console.log(`\\n[Status ${status}] Error! Waiting ${((backoffDelay + jitter)/1000).toFixed(1)}s...`);\n }\n resolve(false);\n }\n });\n }\n );\n\n req.on(\"timeout\", () => {\n req.destroy(new Error(\"Timeout\"));\n });\n\n req.on(\"error\", () => {\n failCount++;\n // Set short backoff on network errors\n backoffUntil = Math.max(backoffUntil, Date.now() + 2000 + Math.floor(Math.random() * 1000));\n resolve(false);\n });\n\n req.write(postData);\n req.end();\n });\n}\n\n// Function to handle periodic console clearing\nfunction startConsoleClearTimer() {\n setInterval(() => {\n console.clear();\n console.log(`[${new Date().toLocaleTimeString()}] Console cleared automatically.`);\n }, CLEAR_INTERVAL_MS);\n}\n\n// Function to print throughput metrics every second\nfunction startStatusLogger() {\n const GREEN = \"\\x1b[32m\";\n const RED = \"\\x1b[31m\";\n const BLUE = \"\\x1b[34m\";\n const RESET = \"\\x1b[0m\";\n\n setInterval(() => {\n const successesThisPeriod = successCount - lastSuccessCount;\n const failuresThisPeriod = failCount - lastFailCount;\n \n const successStr = successesThisPeriod.toString().padStart(3, \" \");\n const failStr = failuresThisPeriod.toString().padStart(3, \" \");\n const concurrencyStr = currentConcurrency.toFixed(1).padStart(5, \" \");\n \n console.log(\n `${GREEN}PASS: ${successStr}${RESET} | ${RED}FAIL: ${failStr}${RESET} | ${BLUE}CONCURRENCY: ${concurrencyStr}${RESET}`\n );\n \n lastSuccessCount = successCount;\n lastFailCount = failCount;\n }, 1000);\n}\n\nasync function startInfiniteLoop() {\n await resolveDns();\n console.log(`Starting optimized likes for top pledges via Edge Function...`);\n console.log(`Initial Concurrency Limit: ${currentConcurrency}`);\n console.log(`Max Concurrency Limit: ${MAX_CONCURRENCY}`);\n console.log(`Clear Interval: ${CLEAR_INTERVAL_MS}ms\\n`);\n\n const activeRequests = new Set>();\n\n while (true) {\n const now = Date.now();\n if (now < backoffUntil) {\n await sleep(backoffUntil - now);\n continue;\n }\n\n if (activeRequests.size < currentConcurrency) {\n const p = sendRequest().then((success) => {\n activeRequests.delete(p);\n \n // AIMD Congestion Control\n if (success) {\n // Additive increase\n currentConcurrency = Math.min(MAX_CONCURRENCY, currentConcurrency + 0.05);\n } else {\n // Multiplicative decrease\n currentConcurrency = Math.max(MIN_CONCURRENCY, currentConcurrency * 0.85);\n }\n });\n activeRequests.add(p);\n } else {\n // Wait for the fastest request to complete before checking again\n await Promise.race(activeRequests);\n }\n\n // Add a tiny sleep to yield execution and prevent CPU tight looping\n if (activeRequests.size >= currentConcurrency) {\n await sleep(5000);\n }\n }\n}\n\n// Val Town entry point\nexport default async function (req?: Request): Promise {\n console.log(FILENAME);\n \n // Start timers and main loop\n startConsoleClearTimer();\n startStatusLogger();\n startInfiniteLoop();\n}","import https from \"node:https\";\nimport dns from \"node:dns\";\n\n// --- CONFIGURATION ---\nconst SUPABASE_URL = Deno.env.get(\"SUPABASE_URL\") || \"\";\nconst DOMAIN = SUPABASE_URL ? new URL(SUPABASE_URL).hostname : \"\";\nconst SUPABASE_ANON_KEY = Deno.env.get(\"SUPABASE_ANON_KEY\") || \"\";\n\nimport https from \"https\";\nimport dns from \"dns\";\nimport crypto from \"crypto\";\n\n// --- CONFIGURATION ---\nconst DOMAIN = Deno.env.get(\"SUPABASE_URL\");\nconst SUPABASE_ANON_KEY =\n \"eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZSIsInJlZiI6ImtrYW9lcmJibHB1c3pwdGlpYnZvIiwicm9sZSI6ImFub24iLCJpYXQiOjE3ODI1NDY5MTMsImV4cCI6MjA5ODEyMjkxM30.Xf549NzokL9zY7AT8Jd5NYFRj81r7z2hS6i7kZbpCMw\";\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 FILENAME = import.meta.url.split(\"/\").pop();\n\nconst MAX_CONCURRENCY = 100;\nconst MIN_CONCURRENCY = 50;\nconst INITIAL_CONCURRENCY = 10;\nconst CLEAR_INTERVAL_MS = 5 * 60 * 1000; // 5 minutes\n\n// Keep-alive agent configuration for high concurrency request reuse\nconst agent = new https.Agent({\n keepAlive: true,\n maxSockets: MAX_CONCURRENCY,\n maxFreeSockets: MAX_CONCURRENCY,\n keepAliveMsecs: 60000,\n timeout: 15000,\n});\n\n// Performance Counters & State\nlet successCount = 0;\nlet failCount = 0;\nlet lastSuccessCount = 0;\nlet lastFailCount = 0;\nlet targetIps: string[] = [DOMAIN]; // Fallback to domain name\nlet backoffUntil = 0;\nlet currentConcurrency = INITIAL_CONCURRENCY;\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\n// DNS Pre-resolver & updater\nasync function resolveDns() {\n try {\n const ips = await dns.promises.resolve(DOMAIN);\n if (ips && ips.length > 0) {\n targetIps = ips;\n console.log(`Resolved ${DOMAIN} to:`, targetIps);\n }\n } catch (err) {\n console.error(`DNS Resolution failed, using hostname as fallback:`, err);\n targetIps = [DOMAIN];\n }\n}\n\n// Start periodic DNS refresh every 5 minutes\nsetInterval(resolveDns, 5 * 60 * 1000);\n\nasync function sendRequest(): Promise {\n const targetId = getRandomMessageId();\n\n // Format body for the Edge Function /like endpoint\n const postData = JSON.stringify({\n messageId: String(targetId),\n action: \"like\",\n clientId: crypto.randomUUID(), // Unique client ID per request to bypass client-level rate limits\n });\n const postDataLength = Buffer.byteLength(postData);\n\n // Pick random IP from targetIps list to load balance\n const ip = targetIps[Math.floor(Math.random() * targetIps.length)];\n\n return new Promise((resolve) => {\n const req = https.request(\n {\n host: ip,\n port: 443,\n path: \"/functions/v1/idolcamp-api/like\",\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Content-Length\": postDataLength,\n apikey: SUPABASE_ANON_KEY,\n Authorization: `Bearer ${SUPABASE_ANON_KEY}`,\n Host: DOMAIN,\n Connection: \"keep-alive\",\n },\n servername: DOMAIN, // SNI servername is required for TLS validation on IP connection\n agent,\n timeout: 10000, // 10 seconds request timeout\n },\n (res) => {\n // Consume the response body immediately\n res.resume();\n\n res.on(\"end\", () => {\n const status = res.statusCode || 0;\n if (status >= 200 && status < 300) {\n successCount++;\n resolve(true);\n } else {\n failCount++;\n\n // Check for rate-limiting or server failure status codes\n if (\n status === 429 || status === 520 || status === 502 ||\n status === 503 || status === 504\n ) {\n let backoffDelay = 5000; // default 5s backoff\n const retryAfter = res.headers[\"retry-after\"];\n if (retryAfter) {\n const parsed = parseInt(retryAfter, 10);\n if (!isNaN(parsed)) {\n backoffDelay = parsed * 1000;\n }\n }\n // Add a bit of jitter to prevent thundering herd when resuming\n const jitter = Math.floor(Math.random() * 2000);\n backoffUntil = Math.max(\n backoffUntil,\n Date.now() + backoffDelay + jitter,\n );\n console.log(\n `\\n[Status ${status}] Error! Waiting ${\n ((backoffDelay + jitter) / 1000).toFixed(1)\n }s...`,\n );\n }\n resolve(false);\n }\n });\n },\n );\n\n req.on(\"timeout\", () => {\n req.destroy(new Error(\"Timeout\"));\n });\n\n req.on(\"error\", () => {\n failCount++;\n // Set short backoff on network errors\n backoffUntil = Math.max(\n backoffUntil,\n Date.now() + 2000 + Math.floor(Math.random() * 1000),\n );\n resolve(false);\n });\n\n req.write(postData);\n req.end();\n });\n}\n\n// Function to handle periodic console clearing\nfunction startConsoleClearTimer() {\n setInterval(() => {\n console.clear();\n console.log(\n `[${new Date().toLocaleTimeString()}] Console cleared automatically.`,\n );\n }, CLEAR_INTERVAL_MS);\n}\n\n// Function to print throughput metrics every second\nfunction startStatusLogger() {\n const GREEN = \"\\x1b[32m\";\n const RED = \"\\x1b[31m\";\n const BLUE = \"\\x1b[34m\";\n const RESET = \"\\x1b[0m\";\n\n setInterval(() => {\n const successesThisPeriod = successCount - lastSuccessCount;\n const failuresThisPeriod = failCount - lastFailCount;\n\n const successStr = successesThisPeriod.toString().padStart(3, \" \");\n const failStr = failuresThisPeriod.toString().padStart(3, \" \");\n const concurrencyStr = currentConcurrency.toFixed(1).padStart(5, \" \");\n\n console.log(\n `${GREEN}PASS: ${successStr}${RESET} | ${RED}FAIL: ${failStr}${RESET} | ${BLUE}CONCURRENCY: ${concurrencyStr}${RESET}`,\n );\n\n lastSuccessCount = successCount;\n lastFailCount = failCount;\n }, 1000);\n}\n\nasync function startInfiniteLoop() {\n await resolveDns();\n console.log(`Starting optimized likes for top pledges via Edge Function...`);\n console.log(`Initial Concurrency Limit: ${currentConcurrency}`);\n console.log(`Max Concurrency Limit: ${MAX_CONCURRENCY}`);\n console.log(`Clear Interval: ${CLEAR_INTERVAL_MS}ms\\n`);\n\n const activeRequests = new Set>();\n\n while (true) {\n const now = Date.now();\n if (now < backoffUntil) {\n await sleep(backoffUntil - now);\n continue;\n }\n\n if (activeRequests.size < currentConcurrency) {\n const p = sendRequest().then((success) => {\n activeRequests.delete(p);\n\n // AIMD Congestion Control\n if (success) {\n // Additive increase\n currentConcurrency = Math.min(\n MAX_CONCURRENCY,\n currentConcurrency + 0.05,\n );\n } else {\n // Multiplicative decrease\n currentConcurrency = Math.max(\n MIN_CONCURRENCY,\n currentConcurrency * 0.85,\n );\n }\n });\n activeRequests.add(p);\n } else {\n // Wait for the fastest request to complete before checking again\n await Promise.race(activeRequests);\n }\n\n // Add a tiny sleep to yield execution and prevent CPU tight looping\n if (activeRequests.size >= currentConcurrency) {\n await sleep(5000);\n }\n }\n}\n\n// Val Town entry point\nexport default async function (req?: Request): Promise {\n console.log(FILENAME);\n // Start timers and main loop\n startConsoleClearTimer();\n startStatusLogger();\n startInfiniteLoop();\n}","createdAt",["D",1784120505265],"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":224,"_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":225,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":226,"_81":227,"_83":228,"_85":25},"tree",[195,196,197,198,199,200,201],"files",[195,196,197,198,199,200,201],"counts",{"_183":60,"_184":185,"_186":60,"_187":188,"_189":190},"contents",[126,127,128,129,130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":176,"_32":177,"_30":178,"_134":-5,"_41":42,"_40":179,"_135":144,"_38":180,"_13":181,"_33":34,"_35":147,"_24":25,"_138":-5,"_27":182},{"_43":169,"_32":170,"_30":171,"_134":-5,"_41":42,"_40":172,"_135":144,"_38":173,"_13":174,"_33":34,"_35":147,"_24":25,"_138":-5,"_27":175},{"_43":163,"_32":164,"_30":165,"_134":-5,"_41":42,"_40":166,"_135":144,"_38":167,"_13":154,"_33":34,"_35":147,"_24":25,"_138":-5,"_27":168},{"_43":156,"_32":157,"_30":158,"_134":-5,"_41":42,"_40":159,"_135":144,"_38":160,"_13":161,"_33":34,"_35":147,"_24":25,"_138":-5,"_27":162},{"_43":149,"_32":150,"_30":151,"_134":-5,"_41":42,"_40":152,"_135":144,"_38":153,"_13":154,"_33":34,"_35":147,"_24":25,"_138":-5,"_27":155},{"_43":140,"_32":141,"_30":142,"_134":-5,"_41":42,"_40":143,"_135":144,"_38":145,"_13":146,"_33":34,"_35":147,"_24":25,"_138":-5,"_27":148},{"_43":133,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_135":25,"_38":136,"_13":137,"_33":34,"_35":37,"_24":25,"_138":-5,"_27":139},"1ac1858b-64df-4f4f-8be0-2aa5efb83b68","parentId","latest",["D",1784120505265],5,"label",[28],"bb56f57d-486a-48e5-bd73-c0a09276dc06","mic9likr-5_30m.ts","5847099e-7f78-11f1-8464-1607ee4eb77e",200,true,["D",1784086448649],15,"// --- 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}",[141],"742c8e68-ee90-4dd5-a591-257fa79866b7","mic9likr-4_20m.ts","6d14b5ac-7f77-11f1-845c-1607ee4eb77e",199,["D",1784086442190],11,[150],"79988ad5-93a2-4dc5-87b1-58165e59d4f2","mic9likr-3_15m.ts","67b0b50c-7f77-11f1-b807-1607ee4eb77e",198,["D",1784086434428],13,[157],"9f4689cd-3175-4c29-8900-c72f936f849b","mic9likr-2_30m.ts","600aacea-7f77-11f1-8965-1607ee4eb77e",196,["D",1784086426589],[164],"31e40a5f-81e8-48ef-838f-94a9e1d6cd88","mic9likr-1_20m.ts","fe740972-7f76-11f1-86ca-1607ee4eb77e",195,["D",1784086421601],17,[170],"7b19ef3e-a535-4b6f-ba06-8bc519118e6e","mic9likr-0_15m.ts","3741bf7c-7f60-11f1-aee1-1607ee4eb77e",194,["D",1784086415686],50,[177],"pulls","branches",1,"forks","envVars",{"_191":193,"_194":60},"connections",{"_191":60,"_192":60},"count","unfilledCount",3,"emptyCount",{"_43":176,"_32":177,"_30":178,"_134":-5,"_41":42,"_40":179,"_135":144,"_38":221,"_13":181,"_33":34,"_35":147,"_24":25,"_138":-5,"_203":222,"_27":223},{"_43":169,"_32":170,"_30":171,"_134":-5,"_41":42,"_40":172,"_135":144,"_38":218,"_13":174,"_33":34,"_35":147,"_24":25,"_138":-5,"_203":219,"_27":220},{"_43":163,"_32":164,"_30":165,"_134":-5,"_41":42,"_40":166,"_135":144,"_38":215,"_13":154,"_33":34,"_35":147,"_24":25,"_138":-5,"_203":216,"_27":217},{"_43":156,"_32":157,"_30":158,"_134":-5,"_41":42,"_40":159,"_135":144,"_38":212,"_13":161,"_33":34,"_35":147,"_24":25,"_138":-5,"_203":213,"_27":214},{"_43":149,"_32":150,"_30":151,"_134":-5,"_41":42,"_40":152,"_135":144,"_38":209,"_13":154,"_33":34,"_35":147,"_24":25,"_138":-5,"_203":210,"_27":211},{"_43":140,"_32":141,"_30":142,"_134":-5,"_41":42,"_40":143,"_135":144,"_38":206,"_13":146,"_33":34,"_35":147,"_24":25,"_138":-5,"_203":207,"_27":208},{"_43":133,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_135":25,"_38":202,"_13":137,"_33":34,"_35":37,"_24":25,"_138":-5,"_203":204,"_27":205},["D",1784120505265],"children",[],[28],["D",1784086448649],[],[141],["D",1784086442190],[],[150],["D",1784086434428],[],[157],["D",1784086426589],[],[164],["D",1784086421601],[],[170],["D",1784086415686],[],[177],["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":262,"_263":264,"_265":266,"_267":25,"_268":25,"_269":25,"_270":144,"_271":-5,"_272":-7,"_273":-7,"_274":60,"_275":25,"_276":25,"_277":-5,"_278":25,"_279":25,"_280":25,"_281":-5},"ENV",{"_233":234,"_235":236,"_237":87,"_238":239,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261},"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"]

Diff · v206