[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_218":219,"_220":221},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_84":67,"_85":78,"_65":-7,"_86":-5,"_13":87,"_88":89,"_11":90,"_91":92,"_93":94,"_95":-5,"_96":-5,"_97":-5,"_98":26,"_99":100,"_101":26,"_102":-5,"_103":-5,"_104":105},"routes/_app.x.$handle.$name.search.$(branch)",{"_11":12,"_13":14,"_15":-5,"_16":17},"files",[],"project",{"_18":19,"_20":21,"_22":23,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":-5,"_31":-5,"_32":33,"_34":-5,"_35":26,"_36":-5,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":-5,"_49":50,"_51":50,"_52":53,"_54":53,"_55":53,"_56":50,"_57":50,"_58":59,"_60":61,"_62":63,"_64":26},"query","handle","robotsclank","id","bab078cf-5d5c-4405-8a12-abfcd146f77f","name","mic9likr","createdAt",["D",1784017234760],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","userId","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",{"_16":17,"_83":78},"org",{"_16":17,"_77":78,"_79":78,"_32":33,"_80":81,"_82":26},"branch",{"_65":66,"_20":67,"_18":68,"_69":19,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":-5,"_75":21,"_76":17},"isOwned","version",216,"main","471f5fd0-ed30-4b7b-9702-0d660ac1ae5c","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","path","adoptOrgId",{"_18":19,"_20":21,"_22":213,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":-5,"_31":-5,"_32":33,"_34":-5,"_35":26,"_36":-5,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":45,"_46":214,"_48":-5,"_49":50,"_51":50,"_52":53,"_54":53,"_55":53,"_56":50,"_57":50,"_58":215,"_60":216,"_62":217,"_64":26},"tree",[184,185,186,187,188,189,190],[184,185,186,187,188,189,190],"counts",{"_172":39,"_173":174,"_175":39,"_176":177,"_178":179},"contents",[106,107,108,109,110,111,112],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_18":165,"_20":166,"_115":167,"_117":-5,"_118":68,"_119":168,"_120":121,"_22":169,"_65":170,"_124":125,"_126":136,"_128":26,"_129":-5,"_85":171},{"_18":158,"_20":159,"_115":160,"_117":-5,"_118":68,"_119":161,"_120":121,"_22":162,"_65":163,"_124":125,"_126":136,"_128":26,"_129":-5,"_85":164},{"_18":152,"_20":153,"_115":154,"_117":-5,"_118":68,"_119":155,"_120":121,"_22":156,"_65":143,"_124":125,"_126":136,"_128":26,"_129":-5,"_85":157},{"_18":145,"_20":146,"_115":147,"_117":-5,"_118":68,"_119":148,"_120":121,"_22":149,"_65":150,"_124":125,"_126":136,"_128":26,"_129":-5,"_85":151},{"_18":138,"_20":139,"_115":140,"_117":-5,"_118":68,"_119":141,"_120":121,"_22":142,"_65":143,"_124":125,"_126":136,"_128":26,"_129":-5,"_85":144},{"_18":131,"_20":132,"_115":133,"_117":-5,"_118":68,"_119":134,"_120":121,"_22":135,"_65":123,"_124":125,"_126":136,"_128":26,"_129":-5,"_85":137},{"_18":113,"_20":114,"_115":116,"_117":-5,"_118":68,"_119":66,"_120":121,"_22":122,"_65":123,"_124":125,"_126":127,"_128":26,"_129":-5,"_85":130},"74b0a4fa-5792-43ac-bfb4-b21ba6b375c5","new-file-4563.ts","fileId","ddb22f90-804b-11f1-ae6f-1607ee4eb77e","parentId","branchId","branchVersion","latest",true,["D",1784122236080],15,"fileType","interval","content","import https from \"node:https\";\nimport dns from \"node:dns\";\nimport crypto from \"node:crypto\";\n\n// --- CONFIGURATION ---\nconst SUPABASE_URL = \"https://kkaoerbblpuszptiibvo.supabase.co\";\nconst DOMAIN = \"kkaoerbblpuszptiibvo.supabase.co\";\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 = 10;\nconst MIN_CONCURRENCY = 5;\nconst INITIAL_CONCURRENCY = 5;\nconst CLEAR_INTERVAL_MS = 5 * 60 * 1000; // 5 minutes\nconst RUN_DURATION_MS = 30 * 1000; // 30 seconds active\nconst PAUSE_DURATION_MS = 30 * 1000; // 30 seconds paused\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;\nlet isPaused = false;\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 3 minutes\nsetInterval(resolveDns, 3 * 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 if (isPaused) return;\n\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}${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 let cycleStart = Date.now();\n\n while (true) {\n const now = Date.now();\n\n // --- Pause/Resume cycle ---\n if (now - cycleStart >= RUN_DURATION_MS) {\n isPaused = true;\n // Drain all in-flight requests before pausing so no requests run during the break\n if (activeRequests.size > 0) {\n await Promise.all(activeRequests);\n }\n console.log(\n `\\n[PAUSE] Ran for ${RUN_DURATION_MS / 1000}s — pausing for ${\n PAUSE_DURATION_MS / 1000\n }s...`,\n );\n await sleep(PAUSE_DURATION_MS);\n isPaused = false;\n console.log(`[RESUME] Resuming requests...\\n`);\n cycleStart = Date.now();\n continue;\n }\n\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(1000);\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}","deleted","label",[114],"bb56f57d-486a-48e5-bd73-c0a09276dc06","mic9likr-5_30m.ts","5847099e-7f78-11f1-8464-1607ee4eb77e",200,["D",1784086448649],"// --- 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}",[132],"742c8e68-ee90-4dd5-a591-257fa79866b7","mic9likr-4_20m.ts","6d14b5ac-7f77-11f1-845c-1607ee4eb77e",199,["D",1784086442190],11,[139],"79988ad5-93a2-4dc5-87b1-58165e59d4f2","mic9likr-3_15m.ts","67b0b50c-7f77-11f1-b807-1607ee4eb77e",198,["D",1784086434428],13,[146],"9f4689cd-3175-4c29-8900-c72f936f849b","mic9likr-2_30m.ts","600aacea-7f77-11f1-8965-1607ee4eb77e",196,["D",1784086426589],[153],"31e40a5f-81e8-48ef-838f-94a9e1d6cd88","mic9likr-1_20m.ts","fe740972-7f76-11f1-86ca-1607ee4eb77e",195,["D",1784086421601],17,[159],"7b19ef3e-a535-4b6f-ba06-8bc519118e6e","mic9likr-0_15m.ts","3741bf7c-7f60-11f1-aee1-1607ee4eb77e",194,["D",1784086415686],50,[166],"pulls","branches",1,"forks","envVars",{"_180":182,"_183":39},"connections",{"_180":39,"_181":39},"count","unfilledCount",3,"emptyCount",{"_18":165,"_20":166,"_115":167,"_117":-5,"_118":68,"_119":168,"_120":121,"_22":210,"_65":170,"_124":125,"_126":136,"_128":26,"_129":-5,"_192":211,"_85":212},{"_18":158,"_20":159,"_115":160,"_117":-5,"_118":68,"_119":161,"_120":121,"_22":207,"_65":163,"_124":125,"_126":136,"_128":26,"_129":-5,"_192":208,"_85":209},{"_18":152,"_20":153,"_115":154,"_117":-5,"_118":68,"_119":155,"_120":121,"_22":204,"_65":143,"_124":125,"_126":136,"_128":26,"_129":-5,"_192":205,"_85":206},{"_18":145,"_20":146,"_115":147,"_117":-5,"_118":68,"_119":148,"_120":121,"_22":201,"_65":150,"_124":125,"_126":136,"_128":26,"_129":-5,"_192":202,"_85":203},{"_18":138,"_20":139,"_115":140,"_117":-5,"_118":68,"_119":141,"_120":121,"_22":198,"_65":143,"_124":125,"_126":136,"_128":26,"_129":-5,"_192":199,"_85":200},{"_18":131,"_20":132,"_115":133,"_117":-5,"_118":68,"_119":134,"_120":121,"_22":195,"_65":123,"_124":125,"_126":136,"_128":26,"_129":-5,"_192":196,"_85":197},{"_18":113,"_20":114,"_115":116,"_117":-5,"_118":68,"_119":66,"_120":121,"_22":191,"_65":123,"_124":125,"_126":127,"_128":26,"_129":-5,"_192":193,"_85":194},["D",1784122236080],"children",[],[114],["D",1784086448649],[],[132],["D",1784086442190],[],[139],["D",1784086434428],[],[146],["D",1784086426589],[],[153],["D",1784086421601],[],[159],["D",1784086415686],[],[166],["D",1784017234760],["D",1789525245864],{"_16":17,"_83":78},{"_16":17,"_77":78,"_79":78,"_32":33,"_80":81,"_82":26},{"_65":66,"_20":67,"_18":68,"_69":19,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":-5,"_75":21,"_76":17},"ctx",{"_58":-5,"_103":251,"_252":253,"_254":255,"_256":26,"_257":26,"_258":26,"_259":121,"_260":-5,"_261":-7,"_262":-7,"_263":39,"_264":26,"_265":26,"_266":-5,"_267":26,"_268":26,"_269":26,"_270":-5},"ENV",{"_222":223,"_224":225,"_226":67,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250},"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"]

Search