Copy ${url}
Go to poe.com/create_bot
Click \"Server bot\"
Paste the copied endpoint into the \"Server URL\" field

\n`;\n\nexport function createBot(bot: BotBase): { handleRequest: Handler } {\n async function handleRequest(req: Request): Promise {\n const reqBody = await req.json().catch(e => null);\n if (!reqBody) {\n return new Response(instructions(req.url), {\n status: 200,\n headers: {\n \"Content-Type\": \"text/html\",\n },\n });\n }\n if (reqBody.type === \"settings\") {\n const body: SettingsRequest = reqBody;\n let settingsResponse = await Promise.resolve()\n .then(() => {\n if (typeof bot.settings === \"function\") {\n return bot.settings(body, { req });\n }\n return bot.settings;\n });\n return new Response(JSON.stringify({ ...settingsResponse, message: settingsResponse.introduction_message }), {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n },\n });\n }\n if (reqBody.type === \"query\") {\n const body: QueryRequest = reqBody;\n const stream = new ReadableStream({\n start(controller) {\n (async function() {\n for await (const event of bot.handleMessage(body, { req }, { events, sleep })) {\n if (typeof event === \"string\") {\n controller.enqueue(encodeEvent(\"text\", { text: event }));\n continue;\n } else if (!event || !event.event) {\n console.log(\"no event...\", event);\n continue;\n }\n controller.enqueue(encodeEvent(event.event, event.data));\n }\n })().finally(() => {\n controller.close();\n });\n },\n });\n return new Response(stream, {\n status: 200,\n headers: {\n \"Content-Type\": \"text/event-stream\",\n },\n });\n }\n console.log(\"unknown request\", reqBody);\n return new Response(\"oops\");\n }\n\n return {\n handleRequest,\n };\n}\n\nexport function sleep(timeInMs: number) {\n return new Promise(resolve => setTimeout(resolve, timeInMs));\n}\n\nfunction encodeEvent(event: string, data: any = {}) {\n return new TextEncoder().encode(`event: ${event}\\ndata: ${JSON.stringify(data)}\\n\\n`);\n}\n\nexport default function serve(bot: BotBase): Handler {\n return createBot(bot).handleRequest;\n}\n\n/**\n * Forwards a query to a poe hosted bot, like \"GPT-4o\"\n */\nexport async function* forward(\n { query, toBotName, accessKey }: { query: QueryRequest; toBotName: string; accessKey: string },\n): AsyncIterable {\n const req = new Request(`https://api.poe.com/bot/${toBotName}`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${accessKey}`,\n \"Accept\": \"text/event-stream\",\n },\n body: JSON.stringify(query),\n });\n\n for await (const event of fetchEventSource(req)) {\n yield event as PoeBotServerSentEvent;\n }\n}\n\nasync function* fetchEventSource(request: Request): AsyncIterable<{ event: string; data: any }> {\n const response = await fetch(request);\n\n if (!response.ok) {\n console.log(\"poe_bot api error\", response.status, response.statusText, await response.text());\n return;\n }\n const reader = response.body.getReader();\n const decoder = new TextDecoder();\n\n let currentEvent = \"\";\n let currentData = \"\";\n\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n\n const chunk = decoder.decode(value, { stream: true });\n const lines = chunk.split(\"\\n\");\n\n for (const line of lines) {\n if (line.startsWith(\"event: \")) {\n currentEvent = line.slice(7).trim();\n } else if (line.startsWith(\"data: \")) {\n currentData = line.slice(6);\n }\n\n // If we have both an event and data, yield them\n if (currentEvent && currentData) {\n try {\n yield {\n event: currentEvent,\n data: JSON.parse(currentData),\n };\n } catch (e) {\n console.error(\"poe_bot\", \"error parsing\", e, { event: currentEvent, data: currentData });\n }\n // Reset for the next event\n currentEvent = \"\";\n currentData = \"\";\n }\n }\n }\n}","deleted","label",[99],"permalink","https://www.val.town/x/jeffreyyoung/poe_bot/code/main.tsx","extension","actionData","errors"]