[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_188":189,"_190":191},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_70":139,"_40":-7,"_140":-5,"_17":141,"_142":143,"_144":145,"_146":147,"_148":149,"_150":-5,"_151":152,"_153":154,"_155":48,"_156":157,"_158":26,"_159":-5,"_160":-5,"_161":162},"routes/_app.x.$handle.$name.compare.$branch",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":30,"_31":-5},"handle","supgiuts","name","CHATGPT_AND_GEMINI_TEST","branchName","main","project",{"_32":58,"_13":14,"_34":100,"_46":-5,"_101":48,"_49":50,"_102":50,"_103":-5,"_104":-5,"_105":106,"_107":-5,"_108":48,"_109":-5,"_110":-5,"_111":112,"_53":113,"_114":-5,"_115":-5,"_116":-5,"_117":-5,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_127":128,"_129":130,"_131":28,"_47":48},"ahead",29,"behind",2,"diff",{"_63":64,"_65":66,"_67":68},"hasChanges",true,"sourceBranch",{"_40":56,"_13":16,"_32":57,"_38":58,"_42":33,"_43":59,"_60":50,"_61":39,"_62":54,"_55":14,"_51":12},"targetBranch",{"_32":33,"_34":35,"_36":37,"_13":16,"_38":39,"_40":41,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":48,"_49":50,"_51":52,"_53":54,"_55":14},"pull","id","e8da16c2-2325-11f1-8cec-42dde27851f2","createdAt",["D",1773878115256],"updatedAt",["D",1775657145857],"projectId","e8d962fe-2325-11f1-8cec-42dde27851f2","version",50,"forkedBranchId","forkedBranchVersion","lockfileKey","1775657146573-esm.town_v_zyloxtube_CHATGPT_AND_GEMINI_TEST@50-main","deletedAt","isOwned",false,"privacy","public","userHandle","zyloxtube","orgId","019cafbe-8b86-71df-9b53-9e95fda7747a","projectName",30,"85a62a94-32db-11f1-b89e-42b51c65c3df","859f732a-32db-11f1-b89e-42b51c65c3df",48,"forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","added",[],"deleted",[],"modified",[69],{"_70":71,"_72":73,"_74":75},"path","main.ts","targetFile",{"_32":93,"_13":71,"_77":94,"_79":-5,"_80":33,"_81":59,"_82":48,"_34":95,"_40":96,"_84":85,"_86":97,"_65":48,"_88":-5,"_89":-7,"_70":98,"_91":99},"sourceFile",{"_32":76,"_13":71,"_77":78,"_79":-5,"_80":57,"_81":56,"_82":26,"_34":83,"_40":20,"_84":85,"_86":87,"_65":48,"_88":-5,"_89":-7,"_70":90,"_91":92},"ac7ca840-32e6-11f1-8712-42b51c65c3df","fileId","019d6a54-05f3-720c-a56c-622e855ed2a9","parentId","branchId","branchVersion","latest",["D",1775610174278],"fileType","http","content","// No external serve import needed for modern Deno environments\nexport default async function (req: Request): Promise {\n // 1. Handle CORS Preflight (Important for web tools)\n if (req.method === \"OPTIONS\") {\n return new Response(null, {\n status: 204,\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n },\n });\n }\n\n const url = new URL(req.url);\n const prompt = url.searchParams.get(\"message\") ||\n \"A cool neon cyberpunk city\";\n\n try {\n // STEP 1: Generate a Temp Email via API (No browser needed)\n const emailRes = await fetch(\n \"https://www.1secmail.com/api/v1/?action=genRandomMailbox&count=1\",\n );\n const [tempEmail] = await emailRes.json();\n const [username, domain] = tempEmail.split(\"@\");\n\n /**\n * NOTE: Vidu.com uses Google OAuth or official API Keys.\n * Automating \"Sign Up\" with a temp mail requires spoofing their internal API.\n * Below is the integration for their ACTUAL Video Generation API.\n */\n const VIDU_API_KEY = Deno.env.get(\"VIDU_API_KEY\");\n\n if (!VIDU_API_KEY) {\n // If no key is found, we return the temp info so you can use it manually\n return new Response(\n JSON.stringify({\n success: true,\n status: \"Information Ready\",\n temp_email: tempEmail,\n instruction:\n \"Use the email above to sign up at Vidu.com. Once you have a key, add VIDU_API_KEY to your env vars.\",\n prompt_queued: prompt,\n }),\n {\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n }\n\n // STEP 2: Trigger Video Generation (Vidu Q3 Turbo)\n const viduRes = await fetch(\n \"https://platform.vidu.com/v1/video/generations\",\n {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${VIDU_API_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"viduq3-turbo\",\n prompt: prompt,\n resolution: \"720p\",\n duration: 5,\n }),\n },\n );\n\n const data = await viduRes.json();\n\n return new Response(\n JSON.stringify({\n success: true,\n requestId: data.id || data.requestId,\n email_used: tempEmail,\n message: \"Vidu Q3 generation started successfully.\",\n }),\n {\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n } catch (err: any) {\n return new Response(\n JSON.stringify({ success: false, error: err.message }),\n {\n status: 500,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n }\n}","label","children",[71],"contentHash","0ca7d4f1c4d2b78aced7a3eb9e6c45a37115574290325394d13f78690a117948","6bad1c4e-311c-11f1-a377-42dde27851f2","e8dc570c-2325-11f1-8cec-42dde27851f2",["D",1775413356038],47,"import { delay } from \"https://deno.land/std@0.200.0/async/delay.ts\";\n\n// Configuration\nconst API_BASE = \"https://api.guerrillamail.com/ajax.php\";\nconst MAX_POLL_ATTEMPTS = 150;\nconst POLL_INTERVAL_MS = 1000;\n\n// Proxy Configuration\ninterface ProxyConfig {\n host: string;\n port: number;\n protocol?: \"http\" | \"https\";\n country?: string;\n speed?: number;\n}\n\ninterface ProcessState {\n sidToken: string | null;\n seq: number;\n seenIds: Set;\n foundCode: boolean;\n currentEmail: string | null;\n attempts: number;\n interval: number | null;\n cookies: string[];\n selectedModel: string;\n}\n\n// IP Rotator Class\nclass IPRotator {\n private proxies: ProxyConfig[] = [];\n private currentIndex = 0;\n private requestCount = 0;\n private requestsPerProxy = 2; // Rotate after every 2 requests\n private failedProxies: Set = new Set();\n private userAgents: string[] = [\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n \"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n \"Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36\",\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:109.0) Gecko/20100101 Firefox/119.0\",\n \"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/17.1 Safari/605.1.15\",\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/119.0.0.0 Safari/537.36 Edg/119.0.0.0\",\n ];\n\n constructor(proxies?: ProxyConfig[]) {\n if (proxies && proxies.length > 0) {\n this.proxies = proxies;\n }\n }\n\n async initializeProxies(): Promise {\n console.log(\"🌐 Fetching fresh proxies...\");\n this.proxies = await this.fetchFreeProxies();\n\n if (this.proxies.length === 0) {\n console.log(\n \"⚠️ No proxies fetched, using fallback mode (no proxy rotation)\",\n );\n this.proxies = this.getFallbackProxies();\n }\n\n console.log(`✅ Loaded ${this.proxies.length} proxies for rotation`);\n\n // Test proxies and remove slow ones\n await this.testProxies();\n }\n\n private async fetchFreeProxies(): Promise {\n const proxies: ProxyConfig[] = [];\n const proxySources = [\n {\n url:\n \"https://api.proxyscrape.com/v2/?request=displayproxies&protocol=http&timeout=5000&country=all&ssl=all&anonymity=all\",\n parser: (text: string) => {\n const lines = text.split(\"\\n\");\n for (const line of lines) {\n const match = line.match(\n /(\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}):(\\d+)/,\n );\n if (match) {\n proxies.push({\n host: match[1],\n port: parseInt(match[2]),\n protocol: \"http\",\n });\n }\n }\n },\n },\n {\n url:\n \"https://raw.githubusercontent.com/TheSpeedX/PROXY-List/master/http.txt\",\n parser: (text: string) => {\n const lines = text.split(\"\\n\");\n for (const line of lines) {\n const match = line.match(\n /(\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}):(\\d+)/,\n );\n if (match) {\n proxies.push({\n host: match[1],\n port: parseInt(match[2]),\n protocol: \"http\",\n });\n }\n }\n },\n },\n {\n url:\n \"https://raw.githubusercontent.com/roosterkid/openproxylist/main/HTTPS_RAW.txt\",\n parser: (text: string) => {\n const lines = text.split(\"\\n\");\n for (const line of lines) {\n const match = line.match(\n /(\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}):(\\d+)/,\n );\n if (match) {\n proxies.push({\n host: match[1],\n port: parseInt(match[2]),\n protocol: \"https\",\n });\n }\n }\n },\n },\n {\n url: \"https://www.proxy-list.download/api/v1/get?type=http\",\n parser: (text: string) => {\n try {\n const data = JSON.parse(text);\n if (data.LIST) {\n for (const proxy of data.LIST) {\n proxies.push({\n host: proxy.ip,\n port: parseInt(proxy.port),\n protocol: \"http\",\n });\n }\n }\n } catch (e) {}\n },\n },\n ];\n\n for (const source of proxySources) {\n try {\n console.log(`📡 Fetching proxies from: ${source.url.split(\"/\")[2]}`);\n const controller = new AbortController();\n const timeoutId = setTimeout(() => controller.abort(), 10000);\n\n const response = await fetch(source.url, { signal: controller.signal });\n clearTimeout(timeoutId);\n\n if (response.ok) {\n const text = await response.text();\n source.parser(text);\n console.log(` ✅ Got ${proxies.length} proxies so far`);\n }\n\n if (proxies.length >= 30) break;\n } catch (error) {\n console.log(` ⚠️ Failed to fetch from source: ${error.message}`);\n }\n }\n\n // Remove duplicates\n const uniqueProxies = new Map();\n for (const proxy of proxies) {\n const key = `${proxy.host}:${proxy.port}`;\n if (!uniqueProxies.has(key)) {\n uniqueProxies.set(key, proxy);\n }\n }\n\n return Array.from(uniqueProxies.values()).slice(0, 50);\n }\n\n private getFallbackProxies(): ProxyConfig[] {\n // Fallback proxies (these are public, but might be slow)\n return [\n { host: \"104.16.110.100\", port: 80, protocol: \"http\" },\n { host: \"104.16.110.101\", port: 80, protocol: \"http\" },\n { host: \"104.16.110.102\", port: 80, protocol: \"http\" },\n { host: \"104.16.110.103\", port: 80, protocol: \"http\" },\n { host: \"104.16.110.104\", port: 80, protocol: \"http\" },\n ];\n }\n\n private async testProxies(): Promise {\n console.log(\"🧪 Testing proxies (this may take a moment)...\");\n const workingProxies: ProxyConfig[] = [];\n const testUrl = \"https://httpbin.org/ip\";\n\n for (const proxy of this.proxies.slice(0, 20)) {\n try {\n const startTime = Date.now();\n const response = await this.fetchWithProxy(testUrl, proxy, {\n timeout: 5000,\n });\n const latency = Date.now() - startTime;\n\n if (response.ok) {\n proxy.speed = latency;\n workingProxies.push(proxy);\n console.log(` ✅ Proxy ${proxy.host}:${proxy.port} - ${latency}ms`);\n }\n } catch (error) {\n // Proxy failed\n }\n }\n\n if (workingProxies.length > 0) {\n // Sort by speed\n workingProxies.sort((a, b) => (a.speed || 9999) - (b.speed || 9999));\n this.proxies = workingProxies;\n console.log(`✅ ${this.proxies.length} working proxies ready`);\n } else {\n console.log(\n \"⚠️ No working proxies found, using direct connections with IP rotation headers\",\n );\n this.proxies = [];\n }\n }\n\n private async fetchWithProxy(\n url: string,\n proxy: ProxyConfig,\n options: any = {},\n ): Promise {\n const proxyUrl = `${\n proxy.protocol || \"http\"\n }://${proxy.host}:${proxy.port}`;\n\n // For Deno, we need to use a different approach since native proxy support is limited\n // We'll use a proxy service approach\n const controller = new AbortController();\n const timeoutId = setTimeout(\n () => controller.abort(),\n options.timeout || 30000,\n );\n\n try {\n const response = await fetch(url, {\n ...options,\n signal: controller.signal,\n headers: {\n ...options.headers,\n \"X-Forwarded-For\": this.getRandomIP(),\n \"X-Real-IP\": this.getRandomIP(),\n \"Via\": \"1.1 proxy\",\n },\n });\n clearTimeout(timeoutId);\n return response;\n } catch (error) {\n clearTimeout(timeoutId);\n throw error;\n }\n }\n\n async fetchWithRotation(\n url: string,\n options: RequestInit = {},\n ): Promise {\n // Rotate proxy if needed\n if (this.proxies.length > 0) {\n if (this.requestCount >= this.requestsPerProxy) {\n this.rotateProxy();\n this.requestCount = 0;\n }\n\n const proxy = this.getCurrentProxy();\n this.requestCount++;\n\n // Add random delay between requests to avoid detection\n await delay(Math.random() * 1000 + 500);\n\n try {\n return await this.fetchWithProxy(url, proxy, options);\n } catch (error) {\n console.log(\n `⚠️ Proxy ${proxy.host}:${proxy.port} failed, marking as dead`,\n );\n this.failedProxies.add(`${proxy.host}:${proxy.port}`);\n this.rotateProxy();\n return this.fetchWithRotation(url, options);\n }\n }\n\n // No proxies available, use direct connection with rotating headers\n return this.fetchWithRotatingHeaders(url, options);\n }\n\n private async fetchWithRotatingHeaders(\n url: string,\n options: RequestInit = {},\n ): Promise {\n const randomUserAgent =\n this.userAgents[Math.floor(Math.random() * this.userAgents.length)];\n const randomIP = this.getRandomIP();\n\n // Add random delay\n await delay(Math.random() * 1000 + 500);\n\n return await fetch(url, {\n ...options,\n headers: {\n ...options.headers,\n \"User-Agent\": randomUserAgent,\n \"X-Forwarded-For\": randomIP,\n \"X-Real-IP\": randomIP,\n \"Accept-Language\": \"en-US,en;q=0.9,\" + this.getRandomLanguage(),\n \"Cache-Control\": \"no-cache\",\n \"Pragma\": \"no-cache\",\n },\n });\n }\n\n private getCurrentProxy(): ProxyConfig {\n return this.proxies[this.currentIndex % this.proxies.length];\n }\n\n private rotateProxy(): void {\n this.currentIndex = (this.currentIndex + 1) % this.proxies.length;\n console.log(\n `🔄 Rotated to proxy ${this.currentIndex + 1}/${this.proxies.length}`,\n );\n }\n\n private getRandomIP(): string {\n return `${Math.floor(Math.random() * 255)}.${\n Math.floor(Math.random() * 255)\n }.${Math.floor(Math.random() * 255)}.${Math.floor(Math.random() * 255)}`;\n }\n\n private getRandomLanguage(): string {\n const languages = [\n \"fr-FR;q=0.8\",\n \"de-DE;q=0.7\",\n \"es-ES;q=0.6\",\n \"ja-JP;q=0.5\",\n \"zh-CN;q=0.4\",\n ];\n return languages[Math.floor(Math.random() * languages.length)];\n }\n}\n\n// Initialize state\nconst state: ProcessState = {\n sidToken: null,\n seq: 0,\n seenIds: new Set(),\n foundCode: false,\n currentEmail: null,\n attempts: 0,\n interval: null,\n cookies: [],\n selectedModel: \"gemini_3_pro\",\n};\n\n// Initialize IP rotator\nconst ipRotator = new IPRotator();\n\n// Main function with model selection\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const message = url.searchParams.get(\"message\") ||\n \"who are you and what model are you\";\n const modelParam = url.searchParams.get(\"model\");\n\n // Set the model (any string is accepted)\n if (modelParam) {\n state.selectedModel = modelParam;\n console.log(`🤖 Using model: ${state.selectedModel}`);\n } else {\n console.log(`🤖 Using default model: ${state.selectedModel}`);\n }\n\n console.log(`🚀 Starting process with message: \"${message}\"`);\n\n try {\n // Initialize IP rotator with proxies\n await ipRotator.initializeProxies();\n\n // Step 1: Generate temporary email\n await generateEmail();\n\n if (!state.currentEmail || !state.sidToken) {\n throw new Error(\"Failed to generate email\");\n }\n\n console.log(`📧 Email Created: ${state.currentEmail}`);\n\n // Step 2: Send login request\n await sendLoginRequest();\n console.log(\"📤 Login request sent. Starting deep polling...\");\n\n // Step 3: Poll for verification code\n const code = await pollForVerificationCode();\n console.log(`🔑 Code Extracted Successfully: ${code}`);\n\n // Step 4: Complete login with verification code\n await sendVerificationCode(code);\n\n // Step 5: Get conversation ID and send message\n const response = await fetchChatDataAndSendMessage(message);\n\n return new Response(\n JSON.stringify({\n success: true,\n email: state.currentEmail,\n model: state.selectedModel,\n response: response,\n message: \"Process completed successfully\",\n }),\n {\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n } catch (error) {\n console.error(`❌ Fatal Error: ${error.message}`);\n return new Response(\n JSON.stringify({\n success: false,\n error: error.message,\n email: state.currentEmail,\n model: state.selectedModel,\n stack: error.stack,\n }),\n {\n status: 500,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n },\n );\n } finally {\n // Cleanup interval if exists\n if (state.interval) {\n clearInterval(state.interval);\n state.interval = null;\n }\n }\n}\n\n// Generate temporary email\nasync function generateEmail(): Promise {\n try {\n const response = await ipRotator.fetchWithRotation(\n `${API_BASE}?f=get_email_address`,\n );\n if (!response.ok) {\n throw new Error(`HTTP ${response.status}: ${response.statusText}`);\n }\n const data = await response.json();\n\n if (data.email_addr) {\n state.sidToken = data.sid_token;\n state.seq = 0;\n state.currentEmail = data.email_addr;\n } else {\n throw new Error(\"No email address in response\");\n }\n } catch (error) {\n console.error(\"Error generating email:\", error);\n throw error;\n }\n}\n\n// Send initial login request\nasync function sendLoginRequest(): Promise {\n if (!state.currentEmail) {\n throw new Error(\"No email available\");\n }\n\n try {\n console.log(`📤 Sending login request for: ${state.currentEmail}`);\n\n const response = await ipRotator.fetchWithRotation(\n \"https://chatbotsplace.com/api/auth/email-finish-login\",\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Accept\": \"application/json\",\n \"Origin\": \"https://chatbotsplace.com\",\n \"Referer\": \"https://chatbotsplace.com/\",\n },\n body: JSON.stringify({\n email: state.currentEmail,\n verificationMode: \"link\",\n continueUrl: \"https://chatbotsplace.com/purchase\",\n locale: \"en\",\n }),\n },\n );\n\n const setCookie = response.headers.get(\"set-cookie\");\n if (setCookie) {\n state.cookies.push(setCookie);\n }\n\n const data = await response.json();\n\n if (!response.ok || data.success !== true) {\n throw new Error(`Login request failed: ${JSON.stringify(data)}`);\n }\n\n console.log(\"✅ Login request sent successfully\");\n } catch (error) {\n console.error(\"Error sending login request:\", error);\n throw error;\n }\n}\n\n// Poll for verification code\nasync function pollForVerificationCode(): Promise {\n for (let attempt = 0; attempt < MAX_POLL_ATTEMPTS; attempt++) {\n try {\n await delay(POLL_INTERVAL_MS);\n\n const checkResponse = await ipRotator.fetchWithRotation(\n `${API_BASE}?f=check_email&sid_token=${\n encodeURIComponent(state.sidToken!)\n }&seq=${encodeURIComponent(state.seq)}`,\n );\n\n if (!checkResponse.ok) continue;\n\n const checkData = await checkResponse.json();\n\n if (typeof checkData.seq !== \"undefined\") {\n state.seq = checkData.seq;\n }\n\n const list = checkData.list || [];\n\n for (const mail of list) {\n if (state.seenIds.has(mail.mail_id)) continue;\n\n if (\n mail.mail_subject?.includes(\"Sign in\") ||\n mail.mail_subject?.includes(\"verification\")\n ) {\n console.log(`📨 Email found at attempt ${attempt}!`);\n console.log(`📧 Subject: ${mail.mail_subject}`);\n state.seenIds.add(mail.mail_id);\n\n const emailResponse = await ipRotator.fetchWithRotation(\n `${API_BASE}?f=fetch_email&email_id=${\n encodeURIComponent(mail.mail_id)\n }&sid_token=${encodeURIComponent(state.sidToken!)}`,\n );\n\n const emailData = await emailResponse.json();\n const body = emailData.mail_body || emailData.mail_excerpt || \"\";\n\n console.log(`📄 Email content length: ${body.length} characters`);\n console.log(`📄 Email preview: ${body.substring(0, 300)}...`);\n\n const code = extractVerificationCode(body);\n if (code) {\n console.log(`✅ Code found: ${code}`);\n return code;\n } else {\n console.log(\n `⚠️ No valid code found in this email, continuing to poll...`,\n );\n }\n }\n }\n\n if (attempt % 10 === 0 && attempt > 0) {\n console.log(`⏳ Still waiting for email... (${attempt}s passed)`);\n console.log(`📊 Current inbox has ${list.length} emails`);\n }\n } catch (error) {\n console.log(`⚠️ Polling hiccup at attempt ${attempt}: ${error.message}`);\n }\n }\n\n throw new Error(\"TIMEOUT: Email didn't arrive after 150 seconds. Try again.\");\n}\n\n// Send verification code\nasync function sendVerificationCode(code: string): Promise {\n if (!state.currentEmail) {\n throw new Error(\"No email available\");\n }\n\n try {\n console.log(`📤 Sending verification code: ${code}`);\n\n const response = await ipRotator.fetchWithRotation(\n \"https://chatbotsplace.com/api/auth/login-code\",\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Accept\": \"application/json\",\n \"Origin\": \"https://chatbotsplace.com\",\n \"Referer\": \"https://chatbotsplace.com/\",\n },\n body: JSON.stringify({\n email: state.currentEmail,\n code: code,\n locale: \"en\",\n }),\n },\n );\n\n const setCookie = response.headers.get(\"set-cookie\");\n if (setCookie) {\n state.cookies.push(setCookie);\n }\n\n const data = await response.json();\n\n if (!response.ok || data.success !== true) {\n throw new Error(`Verification failed: ${JSON.stringify(data)}`);\n }\n\n console.log(\"✅ Verification successful!\");\n state.foundCode = true;\n } catch (error) {\n console.error(\"Error sending verification code:\", error);\n throw error;\n }\n}\n\n// Fetch chat data and send message\nasync function fetchChatDataAndSendMessage(message: string): Promise {\n try {\n // Get conversation ID\n const cid = await getConversationId();\n\n // Send message with selected model\n const messageId = await sendChatMessage(message, cid);\n\n // Get response stream\n const response = await fetchPromptStream(messageId, cid);\n\n return response;\n } catch (error) {\n console.error(\"Error in chat process:\", error);\n throw error;\n }\n}\n\n// Get conversation ID from chat data\nasync function getConversationId(): Promise {\n const url =\n \"https://chatbotsplace.com/chat/gemini_mini/__data.json?x-sveltekit-invalidated=01\";\n const cookieHeader = state.cookies.join(\"; \");\n\n console.log(`📡 Fetching conversation data...`);\n console.log(`🍪 Using ${state.cookies.length} cookies`);\n\n const response = await ipRotator.fetchWithRotation(url, {\n headers: {\n \"Cookie\": cookieHeader,\n \"Accept\": \"application/json\",\n },\n });\n\n if (!response.ok) {\n throw new Error(`Failed to fetch conversation data: ${response.status}`);\n }\n\n const data = await response.json();\n\n if (data.type === \"redirect\" && data.location) {\n const cidMatch = data.location.match(/cid=([^&]+)/);\n if (cidMatch) {\n const cid = cidMatch[1];\n console.log(`🎯 Conversation ID: ${cid}`);\n return cid;\n }\n }\n\n // Try alternative extraction methods\n if (data.cid) {\n console.log(`🎯 Found CID in data: ${data.cid}`);\n return data.cid;\n }\n\n throw new Error(\"Could not extract Conversation ID (CID)\");\n}\n\n// Send message to chat with any model\nasync function sendChatMessage(message: string, cid: string): Promise {\n console.log(`📤 Sending message to model: ${state.selectedModel}`);\n console.log(`💬 Message: ${message}`);\n\n const response = await ipRotator.fetchWithRotation(\n \"https://chatbotsplace.com/api/chatgpt\",\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Cookie\": state.cookies.join(\"; \"),\n \"Accept\": \"application/json\",\n \"Origin\": \"https://chatbotsplace.com\",\n \"Referer\": \"https://chatbotsplace.com/\",\n },\n body: JSON.stringify({\n message: message,\n conversationId: cid,\n version: state.selectedModel,\n uploadImageUrls: [],\n uploadFileKeys: [],\n flow: \"chat\",\n }),\n },\n );\n\n if (!response.ok) {\n const errorText = await response.text();\n throw new Error(`Chat API failed (${response.status}): ${errorText}`);\n }\n\n const data = await response.json();\n\n if (!data.messageId) {\n throw new Error(\"No messageId found in chat response\");\n }\n\n console.log(`✅ Message sent, messageId: ${data.messageId}`);\n return data.messageId;\n}\n\n// Fetch prompt stream response\nasync function fetchPromptStream(\n messageId: string,\n cid: string,\n): Promise {\n const url =\n `https://chatbotsplace.com/api/prompt-stream?messageId=${messageId}&conversationId=${cid}`;\n console.log(`\\n📡 Fetching response from model: ${state.selectedModel}`);\n\n const response = await ipRotator.fetchWithRotation(url, {\n headers: {\n \"Cookie\": state.cookies.join(\"; \"),\n \"Accept\": \"*/*\",\n },\n });\n\n if (!response.ok) {\n throw new Error(`Failed to fetch prompt stream: ${response.status}`);\n }\n\n const contentType = response.headers.get(\"content-type\");\n let result = \"\";\n\n console.log(\"\\n💬 MODEL RESPONSE:\");\n console.log(\"============================\");\n\n if (contentType?.includes(\"application/json\")) {\n const data = await response.json();\n result = JSON.stringify(data, null, 2);\n console.log(result);\n } else if (\n contentType?.includes(\"text/event-stream\") ||\n contentType?.includes(\"text/plain\")\n ) {\n const text = await response.text();\n result = text;\n console.log(text);\n } else {\n const text = await response.text();\n result = text.substring(0, 1000);\n console.log(result + (text.length > 1000 ? \"...\" : \"\"));\n }\n\n console.log(\"\\n============================\\n\");\n console.log(\n `🎉 Process completed successfully with model: ${state.selectedModel}!`,\n );\n\n return result;\n}\n\n// Extract verification code from email content\nfunction extractVerificationCode(text: string): string | null {\n if (!text) return null;\n\n const isValidCode = (code: string): boolean => {\n return code !== \"000000\" && /^\\d{6}$/.test(code);\n };\n\n // Fixed patterns - removed 'g' flag for matchAll compatibility\n const patterns = [\n /verification code[:\\s]*\\n?\\s*(\\d{6})/i,\n /code[:\\s]*\\n?\\s*(\\d{6})/i,\n /is[:\\s]*\\n?\\s*(\\d{6})/i,\n /:[\\s]*\\n?\\s*(\\d{6})/i,\n /(\\d{6})\\s*\\n/i,\n ];\n\n // Try each pattern\n for (const pattern of patterns) {\n const match = text.match(pattern);\n if (match && match[1] && isValidCode(match[1])) {\n console.log(`🔍 Found code with pattern: ${pattern}`);\n return match[1];\n }\n }\n\n // Look for isolated 6-digit numbers\n const lines = text.split(\"\\n\");\n for (const line of lines) {\n const trimmed = line.trim();\n if (/^\\d{6}$/.test(trimmed) && isValidCode(trimmed)) {\n console.log(`🔍 Found isolated code: ${trimmed}`);\n return trimmed;\n }\n }\n\n // Find all 6-digit numbers and pick the most likely one\n const sixDigitMatches = text.match(/\\b\\d{6}\\b/g);\n if (sixDigitMatches) {\n const validCodes = sixDigitMatches.filter(isValidCode);\n if (validCodes.length > 0) {\n console.log(\n `🔍 Found ${validCodes.length} valid codes: ${validCodes.join(\", \")}`,\n );\n\n // Try to find code with verification context\n for (const code of validCodes) {\n const codeIndex = text.indexOf(code);\n const contextBefore = text.substring(\n Math.max(0, codeIndex - 30),\n codeIndex,\n );\n if (contextBefore.match(/code|verification|is|:/i)) {\n console.log(`🔍 Selected code with verification context: ${code}`);\n return code;\n }\n }\n\n // Return the first valid code if no context found\n console.log(`🔍 Returning first valid code: ${validCodes[0]}`);\n return validCodes[0];\n }\n }\n\n console.log(\"⚠️ No valid 6-digit verification code found in email\");\n return null;\n}",[71],"d46b7ebfcd35cee41f3e8c8b7dba6eb5b6891fca1e4b322163c79d0f893c5721",["D",1775605384584],"legacyEnvVars","httpPrivacy","description","imageUrl","userId","354e939b-24ff-4bc9-af4c-5a8b2bffd038","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"019d6a53-8d6f-77f3-9947-7150bec31642","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_138":134},"org",{"_11":12,"_132":-5,"_133":134,"_105":106,"_135":136,"_137":48},"branch","displayName","avatar","https://avatars.githubusercontent.com/u/259479501?v=4","tier","free","canRestrictVals","profileImageUrl","","adoptOrgId",{"_32":58,"_13":14,"_34":184,"_46":-5,"_101":48,"_49":50,"_102":50,"_103":-5,"_104":-5,"_105":106,"_107":-5,"_108":48,"_109":-5,"_110":-5,"_111":112,"_53":113,"_114":-5,"_115":-5,"_116":-5,"_117":-5,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_127":185,"_129":186,"_131":187,"_47":48},"tree",[181],"files",[181],"counts",{"_170":112,"_171":172,"_173":112,"_174":175,"_176":177},"contents",[167],"file","upstreamProject",{"_32":39,"_13":14,"_103":-5,"_104":-5,"_49":50,"_127":165},"upstreamBranch",{"_32":33,"_34":163,"_36":164,"_13":16,"_38":39,"_40":41,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":48,"_49":50,"_51":52,"_53":54,"_55":14},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1773878115256],["D",1775657145857],{"_11":52,"_138":166},"https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zQU9zYjVaSTVPM2UxMVU0UndTTm9mdkxCbkgifQ",{"_32":76,"_13":71,"_77":78,"_79":-5,"_80":57,"_81":56,"_82":26,"_34":168,"_40":20,"_84":85,"_86":87,"_65":48,"_88":-5,"_70":169},["D",1775610174278],[71],"pulls","branches",1,"forks","envVars",{"_178":112,"_180":112},"connections",{"_178":112,"_179":112},"count","unfilledCount","emptyCount",{"_32":76,"_13":71,"_77":78,"_79":-5,"_80":57,"_81":56,"_82":26,"_34":83,"_40":20,"_84":85,"_86":87,"_65":48,"_88":-5,"_89":182,"_70":183},[],[71],["D",1775605384584],{"_11":12,"_138":134},{"_11":12,"_132":-5,"_133":134,"_105":106,"_135":136,"_137":48},{"_40":56,"_13":16,"_32":57,"_38":58,"_42":33,"_43":59,"_60":50,"_61":39,"_62":54,"_55":14,"_51":12},"ctx",{"_127":-5,"_160":221,"_222":223,"_224":225,"_226":48,"_227":48,"_228":48,"_229":26,"_230":-5,"_231":-7,"_232":-7,"_233":112,"_234":48,"_235":48,"_236":-5,"_237":48,"_238":48,"_239":48,"_240":-5},"ENV",{"_192":193,"_194":195,"_196":16,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220},"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"]

Compare

Mergesupgiuts/mainintozyloxtube/main

Hmain.ts+63-818