import bot, { events, QueryRequest, sleep } from "https://esm.town/v/jeffreyyoung/poe_bot"; const html = `

Yes! The stocks are going up. `; console.log(EventSource); async function* forward(query: QueryRequest, botName: string, accessKey: string) { console.log(query, botName, accessKey); const req = new Request(`https://api.poe.com/bot/${botName}`, { method: "POST", headers: { "Content-Type": "application/json", "Authorization": `Bearer ${accessKey}`, "Accept": "text/event-stream", }, }); for await (const event of fetchEventSource(req)) { console.log(event); } } async function* fetchEventSource(request: Request) { const response = await fetch(request); console.log(response.status, response.statusText); if (!response.ok) { console.log(await response.text()); return; } const reader = response.body.getReader(); const decoder = new TextDecoder(); let currentEvent = ""; let currentData = ""; while (true) { const { done, value } = await reader.read(); if (done) break; const chunk = decoder.decode(value, { stream: true }); const lines = chunk.split("\n"); for (const line of lines) { console.log("reading line, line"); if (line.startsWith("event: ")) { currentEvent = line.slice(7); } else if (line.startsWith("data: ")) { currentData = line.slice(6); } // If we have both an event and data, yield them if (currentEvent && currentData) { yield { event: currentEvent, data: JSON.parse(currentData), }; // Reset for the next event currentEvent = ""; currentData = ""; } } } } export default bot({ async *handleMessage(query, { req }) { const lines = html.split("\n"); yield lines[0] + "\n"; await sleep(2000); yield lines.slice(1).join("\n") + "\n"; yield events.done(); }, settings: { server_bot_dependencies: { "GPT-4o": 1, }, allow_attachments: true, introduction_message: "hello", }, });

poisedOrangeJellyfish

Version 3