\n MANGO PHONK SUITE // MERCURY\n

\n \n \n

\n Amount of tokens to gen\n \n

\n \n

\n STATUS: IDLE\n

\n\n \n

MERCURY CHAT

\n \n \n

\n Select Token\n \n

\n Model\n

\n \n

\n\n \n

Waiting for input...
Ensure you have a valid token selected.

\n\n \n

\n \n \n

\n\n \n \n \n `;\n}\n\n// ================= BACKEND LOGIC =================\n\nconst API_BASE = \"https://chat.inceptionlabs.ai/api/v1\";\nconst CHAT_URL = \"https://chat.inceptionlabs.ai/api/chat/completions\";\n\nconst BROWSER_HEADERS = {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36\",\n \"Origin\": \"https://chat.inceptionlabs.ai\",\n \"Referer\": \"https://chat.inceptionlabs.ai/\",\n \"Accept\": \"application/json\",\n \"Content-Type\": \"application/json\",\n};\n\nasync function runThread(\n threadId: number,\n loops: number,\n send: (data: any) => void,\n) {\n const mustard = 67;\n send({ type: \"SYSTEM\", thread: threadId, msg: `thread started` });\n\n for (let i = 0; i < loops; i++) {\n const email = `z${Date.now()}t${threadId}m${i}@x.x`;\n const name = `B${i}`;\n const password = `Mango${mustard}!`;\n\n try {\n const res = await fetch(`${API_BASE}/auths/signup`, {\n method: \"POST\",\n headers: BROWSER_HEADERS,\n body: JSON.stringify({\n name: name,\n email: email,\n password: password,\n profile_image_url: \"\",\n role: \"user\",\n }),\n });\n\n const d = await res.json().catch(() => null);\n\n if (d && d.token) {\n send({ type: \"SUCCESS\", thread: threadId, msg: `TOKEN: ${d.token}` });\n } else {\n const errDetail = d && d.detail ? d.detail : \"No token returned\";\n send({ type: \"ERROR\", thread: threadId, msg: errDetail });\n }\n } catch (e) {\n send({ type: \"ERROR\", thread: threadId, msg: e.message });\n }\n await new Promise((r) => setTimeout(r, 200));\n }\n}\n\n// --- Chat Proxies ---\n\nfunction generateRandomString(length: number) {\n const chars =\n \"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789\";\n let result = \"\";\n for (let i = 0; i < length; i++) {\n result += chars.charAt(Math.floor(Math.random() * chars.length));\n }\n return result;\n}\n\n// Initialize chat with the first message structure to satisfy backend state\nasync function createChat(\n token: string,\n model: string,\n messageContent: string,\n messageId: string,\n) {\n const nowSecs = Math.floor(Date.now() / 1000);\n const nowMillis = Date.now();\n\n const res = await fetch(`${API_BASE}/chats/new`, {\n method: \"POST\",\n headers: {\n ...BROWSER_HEADERS,\n \"Authorization\": `Bearer ${token}`,\n },\n body: JSON.stringify({\n chat: {\n id: \"\",\n title: \"New Chat\",\n models: [model],\n params: {},\n history: {\n messages: {\n [messageId]: {\n id: messageId,\n parentId: null,\n childrenIds: [],\n role: \"user\",\n content: messageContent,\n timestamp: nowSecs,\n models: [model],\n },\n },\n currentId: messageId,\n },\n messages: [\n {\n id: messageId,\n parentId: null,\n childrenIds: [],\n role: \"user\",\n content: messageContent,\n timestamp: nowSecs,\n models: [model],\n },\n ],\n tags: [],\n timestamp: nowMillis,\n },\n }),\n });\n\n if (!res.ok) {\n const err = await res.text();\n throw new Error(`Failed to create chat: ${res.status} ${err}`);\n }\n const data = await res.json();\n return data.id;\n}\n\nasync function chatStream(token: string, model: string, message: string) {\n // ID generation\n const messageId = crypto.randomUUID();\n\n // 1. Create a new Chat (with the message already inside)\n // This is the critical step that was failing with 403 previously\n const chat_id = await createChat(token, model, message, messageId);\n\n const session_id = generateRandomString(20);\n\n // 2. Send Completion Request\n const upstreamRes = await fetch(CHAT_URL, {\n method: \"POST\",\n headers: {\n ...BROWSER_HEADERS,\n \"Authorization\": `Bearer ${token}`,\n },\n body: JSON.stringify({\n stream: true,\n model: model,\n messages: [{ role: \"user\", content: message }],\n session_id: session_id,\n chat_id: chat_id,\n id: messageId,\n }),\n });\n\n return upstreamRes;\n}\n\nexport default async function (req: Request) {\n const url = new URL(req.url);\n\n if (req.method === \"GET\") {\n return new Response(getHtml(), {\n headers: { \"Content-Type\": \"text/html\" },\n });\n }\n\n if (req.method === \"POST\" && url.searchParams.get(\"action\") === \"run\") {\n const { amount = 1 } = await req.json();\n const totalAmount = Math.max(Number(amount), 1);\n const maxThreads = 10;\n const threadCount = Math.min(totalAmount, maxThreads);\n const baseLoops = Math.floor(totalAmount / threadCount);\n const remainder = totalAmount % threadCount;\n\n const stream = new ReadableStream({\n async start(controller) {\n const encoder = new TextEncoder();\n const send = (data: any) => {\n const msg = JSON.stringify(data) + \"\\n\";\n controller.enqueue(encoder.encode(msg));\n };\n const promises = [];\n for (let i = 0; i < threadCount; i++) {\n const loops = i < remainder ? baseLoops + 1 : baseLoops;\n if (loops > 0) promises.push(runThread(i + 1, loops, send));\n }\n await Promise.all(promises);\n controller.close();\n },\n });\n return new Response(stream, { headers: { \"Content-Type\": \"text/plain\" } });\n }\n\n if (req.method === \"POST\" && url.searchParams.get(\"action\") === \"chat\") {\n const { token, model, message } = await req.json();\n\n let upstream;\n try {\n upstream = await chatStream(token, model, message);\n } catch (e) {\n return new Response(JSON.stringify({ error: e.message }), {\n status: 500,\n });\n }\n\n if (!upstream.ok) {\n const err = await upstream.text();\n return new Response(\"Upstream Error: \" + upstream.status + \" \" + err, {\n status: 500,\n });\n }\n\n const transformer = new TransformStream({\n async transform(chunk, controller) {\n const text = new TextDecoder().decode(chunk);\n const lines = text.split(\"\\n\");\n for (const line of lines) {\n if (!line.trim() || !line.startsWith(\"data: \")) continue;\n\n const jsonStr = line.replace(\"data: \", \"\").trim();\n if (jsonStr === \"[DONE]\") continue;\n\n try {\n const json = JSON.parse(jsonStr);\n const delta = json.choices?.[0]?.delta;\n\n if (delta) {\n const payload: any = {};\n\n if (delta.reasoning_content) {\n payload.reasoning = delta.reasoning_content;\n }\n if (delta.content) {\n payload.content = delta.content;\n }\n\n if (payload.reasoning || payload.content) {\n controller.enqueue(\n new TextEncoder().encode(JSON.stringify(payload) + \"\\n\"),\n );\n }\n }\n } catch (e) {}\n }\n },\n });\n\n return new Response(upstream.body.pipeThrough(transformer), {\n headers: { \"Content-Type\": \"text/plain\" },\n });\n }\n\n return new Response(\"Not Found\", { status: 404 });\n}","deleted","label","wow",[99],"permalink","https://www.val.town/x/omni/sleepphonk/code/main.ts","extension","actionData","errors"]