\n\n\n\n\n\nYes! The stocks are going up.\n`;\nconsole.log(EventSource);\nasync function* forward(query: QueryRequest, botName: string, accessKey: string) {\n console.log(query, botName, accessKey);\n const req = new Request(`https://api.poe.com/bot/${botName}`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${accessKey}`,\n \"Accept\": \"text/event-stream\",\n },\n });\n\n for await (const event of fetchEventSource(req)) {\n console.log(event);\n }\n}\n\nasync function* fetchEventSource(request: Request) {\n const response = await fetch(request);\n console.log(response.status, response.statusText);\n if (!response.ok) {\n console.log(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 console.log(\"reading line, line\");\n if (line.startsWith(\"event: \")) {\n currentEvent = line.slice(7);\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 yield {\n event: currentEvent,\n data: JSON.parse(currentData),\n };\n // Reset for the next event\n currentEvent = \"\";\n currentData = \"\";\n }\n }\n }\n}\n\nexport default bot({\n async *handleMessage(query, { req }) {\n const lines = html.split(\"\\n\");\n yield lines[0] + \"\\n\";\n await sleep(2000);\n yield lines.slice(1).join(\"\\n\") + \"\\n\";\n yield events.done();\n },\n\n settings: {\n server_bot_dependencies: {\n \"GPT-4o\": 1,\n },\n allow_attachments: true,\n introduction_message: \"hello\",\n },\n});","deleted","label",[100],"permalink","https://www.val.town/x/jeffreyyoung/poisedOrangeJellyfish/code/main.tsx","extension","actionData","errors"]