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}","createdAt",["D",1740178358727],"version",47,"currentUserHasLiked","likeCount","forkCount","referenceCount",33,"dependencyCount","commentCount","prCount","mergedPr",{"_130":131,"_132":133},"handle","jeffreyyoung","profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yYlBiWmVId3NYSFQ1VmtnTTZSQ1BCM082Tk0ifQ","forkedVal","interval","slug","jeffreyyoung/poe_bot","description","// copied from https://github.com/poe-platform/fastapi_poe/blob/72e0ffdd00553d24ef23755138ca9b8d5f08b201/src/fastapi_poe/types.py","versions",[142,145,149,153,157,161,165,169,173,177,181,185,189,193,197,200,204,208,212,216,220,224,228,232,236,240,244,248,252,256,260,264,268,272,276,280,284,288,292,296,300,304,308,312,316,320,323,327],{"_118":119,"_143":-5,"_116":144,"_113":111},"prId",["D",1740178358727],{"_118":146,"_143":-5,"_116":147,"_113":148},46,["D",1726794958303],"e4672854-76ed-11ef-8cd1-de64eea55b61",{"_118":150,"_143":-5,"_116":151,"_113":152},45,["D",1724360857507],"8f44e3a4-60ca-11ef-b6bd-de64eea55b61",{"_118":154,"_143":-5,"_116":155,"_113":156},44,["D",1723969885851],"4200aaf6-5d3c-11ef-9fb7-de64eea55b61",{"_118":158,"_143":-5,"_116":159,"_113":160},43,["D",1723969856203],"30565df0-5d3c-11ef-9fb7-de64eea55b61",{"_118":162,"_143":-5,"_116":163,"_113":164},42,["D",1723969842323],"280ec9ac-5d3c-11ef-ba3e-de64eea55b61",{"_118":166,"_143":-5,"_116":167,"_113":168},41,["D",1723969837912],"256dd652-5d3c-11ef-8288-de64eea55b61",{"_118":170,"_143":-5,"_116":171,"_113":172},40,["D",1723969836711],"24b6a5b8-5d3c-11ef-870d-de64eea55b61",{"_118":174,"_143":-5,"_116":175,"_113":176},39,["D",1723968992258],"2d611e2a-5d3a-11ef-ac29-de64eea55b61",{"_118":178,"_143":-5,"_116":179,"_113":180},38,["D",1723968968150],"1f02b262-5d3a-11ef-8dcb-de64eea55b61",{"_118":182,"_143":-5,"_116":183,"_113":184},37,["D",1723968940035],"0e4092c8-5d3a-11ef-b0b7-de64eea55b61",{"_118":186,"_143":-5,"_116":187,"_113":188},36,["D",1723954981354],"8e3ad16c-5d19-11ef-935d-de64eea55b61",{"_118":190,"_143":-5,"_116":191,"_113":192},35,["D",1723954981201],"8e23825a-5d19-11ef-a35e-de64eea55b61",{"_118":194,"_143":-5,"_116":195,"_113":196},34,["D",1723954980919],"8df872cc-5d19-11ef-9a58-de64eea55b61",{"_118":124,"_143":-5,"_116":198,"_113":199},["D",1723954980647],"8dceee52-5d19-11ef-9b23-de64eea55b61",{"_118":201,"_143":-5,"_116":202,"_113":203},32,["D",1723954601820],"ac02e7ee-5d18-11ef-8822-de64eea55b61",{"_118":205,"_143":-5,"_116":206,"_113":207},31,["D",1723954467971],"5c3ad1fe-5d18-11ef-8b5b-de64eea55b61",{"_118":209,"_143":-5,"_116":210,"_113":211},30,["D",1723954462588],"59058470-5d18-11ef-8b5b-de64eea55b61",{"_118":213,"_143":-5,"_116":214,"_113":215},29,["D",1723954461683],"587b91ac-5d18-11ef-a316-de64eea55b61",{"_118":217,"_143":-5,"_116":218,"_113":219},28,["D",1723954453826],"53cc9a02-5d18-11ef-bb5c-de64eea55b61",{"_118":221,"_143":-5,"_116":222,"_113":223},27,["D",1723954453291],"537ae55e-5d18-11ef-b6a0-de64eea55b61",{"_118":225,"_143":-5,"_116":226,"_113":227},26,["D",1723954447425],"4ffbfc56-5d18-11ef-a316-de64eea55b61",{"_118":229,"_143":-5,"_116":230,"_113":231},25,["D",1723954383654],"29f90e9a-5d18-11ef-ae20-de64eea55b61",{"_118":233,"_143":-5,"_116":234,"_113":235},24,["D",1723954377600],"265d4f6c-5d18-11ef-9a83-de64eea55b61",{"_118":237,"_143":-5,"_116":238,"_113":239},23,["D",1723954377362],"263905d0-5d18-11ef-873e-de64eea55b61",{"_118":241,"_143":-5,"_116":242,"_113":243},22,["D",1723954376894],"25f190ec-5d18-11ef-921b-de64eea55b61",{"_118":245,"_143":-5,"_116":246,"_113":247},21,["D",1723954163576],"a6cbec04-5d17-11ef-bbf5-de64eea55b61",{"_118":249,"_143":-5,"_116":250,"_113":251},20,["D",1723954129271],"9259613e-5d17-11ef-8c3f-de64eea55b61",{"_118":253,"_143":-5,"_116":254,"_113":255},19,["D",1723954085198],"78145efa-5d17-11ef-97d2-de64eea55b61",{"_118":257,"_143":-5,"_116":258,"_113":259},18,["D",1723953558180],"3df3c018-5d16-11ef-a5dc-de64eea55b61",{"_118":261,"_143":-5,"_116":262,"_113":263},17,["D",1723953516022],"24d2e99c-5d16-11ef-90ae-de64eea55b61",{"_118":265,"_143":-5,"_116":266,"_113":267},16,["D",1723953511663],"2239fcca-5d16-11ef-b6b9-de64eea55b61",{"_118":269,"_143":-5,"_116":270,"_113":271},15,["D",1723801191729],"7c7882d8-5bb3-11ef-89a7-de64eea55b61",{"_118":273,"_143":-5,"_116":274,"_113":275},14,["D",1723801191376],"7c429768-5bb3-11ef-a5c9-de64eea55b61",{"_118":277,"_143":-5,"_116":278,"_113":279},13,["D",1723801191133],"7c1d9b84-5bb3-11ef-89a7-de64eea55b61",{"_118":281,"_143":-5,"_116":282,"_113":283},12,["D",1723801190956],"7c025f18-5bb3-11ef-baf5-de64eea55b61",{"_118":285,"_143":-5,"_116":286,"_113":287},11,["D",1723801177314],"73e0e552-5bb3-11ef-baf5-de64eea55b61",{"_118":289,"_143":-5,"_116":290,"_113":291},10,["D",1723798265120],"ac13600a-5bac-11ef-bec7-de64eea55b61",{"_118":293,"_143":-5,"_116":294,"_113":295},9,["D",1723798189641],"7f16085a-5bac-11ef-91e1-de64eea55b61",{"_118":297,"_143":-5,"_116":298,"_113":299},8,["D",1723798144276],"640c0bcc-5bac-11ef-91e1-de64eea55b61",{"_118":301,"_143":-5,"_116":302,"_113":303},7,["D",1723708928439],"ab43c1c2-5adc-11ef-b472-de64eea55b61",{"_118":305,"_143":-5,"_116":306,"_113":307},6,["D",1723708293057],"308c2434-5adb-11ef-ac1c-de64eea55b61",{"_118":309,"_143":-5,"_116":310,"_113":311},5,["D",1723708190013],"f320e4e0-5ada-11ef-9bcb-de64eea55b61",{"_118":313,"_143":-5,"_116":314,"_113":315},4,["D",1723708078567],"b0b37b7c-5ada-11ef-b77d-de64eea55b61",{"_118":317,"_143":-5,"_116":318,"_113":319},3,["D",1723707899872],"4630ceda-5ada-11ef-adea-de64eea55b61",{"_118":91,"_143":-5,"_116":321,"_113":322},["D",1723707375228],"0d7aa198-5ad9-11ef-b84c-de64eea55b61",{"_118":324,"_143":-5,"_116":325,"_113":326},1,["D",1723707232014],"b81dcf72-5ad8-11ef-8606-de64eea55b61",{"_118":32,"_143":-5,"_116":328,"_113":329},["D",1723707104028],"6bd4b108-5ad8-11ef-b112-de64eea55b61","recentThread","breadcrumbs","comments",[],"isOwner","routes/_app.v.$handle.$name.versions.$(version)",{"_94":337,"_338":339,"_95":340},"single","redirect","/v/jeffreyyoung/poe_bot/versions",{"_113":176,"_114":341,"_118":174,"_116":342,"_343":100,"_101":102,"_108":109,"_130":131,"_11":97,"_344":-5,"_345":-5,"_346":-5,"_334":26,"_136":137},"export type Events = {\n meta: {\n content_type: ContentType;\n refetch_settings: boolean;\n linkify: boolean;\n suggested_replies: boolean;\n };\n text: {\n text: string;\n };\n replace_response: {\n text: string;\n };\n suggested_reply: {\n text: string;\n };\n error: {\n allow_retry: boolean;\n text?: string;\n raw_response?: string;\n error_type?: string;\n };\n done: {};\n};\n\nexport const events = {\n text: (text: string) => ({ event: \"text\", data: { text } }) as PoeBotServerSentEvent<\"text\">,\n meta: (data: Events[\"meta\"]) => ({ event: \"meta\", data }) as PoeBotServerSentEvent<\"meta\">,\n replace: (text: string) =>\n ({ event: \"replace_response\", data: { text } }) as PoeBotServerSentEvent<\"replace_response\">,\n error: (data: Events[\"error\"]) => ({ event: \"error\", data }) as PoeBotServerSentEvent<\"error\">,\n done: () => ({ event: \"done\", data: {} }) as PoeBotServerSentEvent<\"done\">,\n};\n\nexport type PoeBotServerSentEvent = {\n event: Key;\n data: Events[Key];\n};\n\n// copied from https://github.com/poe-platform/fastapi_poe/blob/72e0ffdd00553d24ef23755138ca9b8d5f08b201/src/fastapi_poe/types.py\n\nexport type Identifier = string;\nexport type FeedbackType = \"like\" | \"dislike\";\nexport type ContentType = \"text/markdown\" | \"text/plain\";\nexport type ErrorType = \"user_message_too_long\";\n\nexport interface MessageFeedback {\n type: FeedbackType;\n reason?: string;\n}\n\nexport interface Attachment {\n url: string;\n content_type: string;\n name: string;\n parsed_content?: string;\n}\n\nexport interface ProtocolMessage {\n role: \"system\" | \"user\" | \"bot\";\n sender_id?: string;\n content: string;\n content_type: ContentType;\n timestamp: number;\n message_id: string;\n feedback: MessageFeedback[];\n attachments: Attachment[];\n}\n\nexport interface RequestContext {\n http_request: Request;\n}\n\nexport interface BaseRequest {\n version: string;\n type: \"query\" | \"settings\" | \"report_feedback\" | \"report_error\";\n}\n\nexport interface QueryRequest extends BaseRequest {\n query: ProtocolMessage[];\n user_id: Identifier;\n conversation_id: Identifier;\n message_id: Identifier;\n metadata: Identifier;\n api_key: string;\n access_key: string;\n temperature: number;\n skip_system_prompt: boolean;\n logit_bias: Record;\n stop_sequences: string[];\n language_code: string;\n bot_query_id: Identifier;\n}\n\nexport interface SettingsRequest extends BaseRequest {}\n\nexport interface ReportFeedbackRequest extends BaseRequest {\n message_id: Identifier;\n user_id: Identifier;\n conversation_id: Identifier;\n feedback_type: FeedbackType;\n}\n\nexport interface ReportErrorRequest extends BaseRequest {\n message: string;\n metadata: Record;\n}\n\nexport type SettingsResponse = Partial<{\n context_clear_window_secs?: number;\n allow_user_context_clear?: boolean;\n server_bot_dependencies: Record;\n allow_attachments?: boolean;\n introduction_message?: string;\n expand_text_attachments?: boolean;\n enable_image_comprehension?: boolean;\n enforce_author_role_alternation?: boolean;\n enable_multi_bot_chat_prompting?: boolean;\n}>;\n\nexport interface AttachmentUploadResponse {\n inline_ref?: string;\n attachment_url?: string;\n}\n\nexport interface PartialResponse {\n text: string;\n data?: Record;\n raw_response?: any;\n full_prompt?: string;\n request_id?: string;\n is_suggested_reply: boolean;\n is_replace_response: boolean;\n}\n\nexport interface ErrorResponse extends PartialResponse {\n allow_retry: boolean;\n error_type?: ErrorType;\n}\n\nexport interface MetaResponse extends PartialResponse {\n linkify: boolean;\n suggested_replies: boolean;\n content_type: ContentType;\n refetch_settings: boolean;\n}\n\nexport interface ToolDefinition {\n type: string;\n function: {\n name: string;\n description: string;\n parameters: {\n type: string;\n properties: Record;\n required?: string[];\n };\n };\n}\n\nexport interface ToolCallDefinition {\n id: string;\n type: string;\n function: {\n name: string;\n arguments: string;\n };\n}\n\nexport interface ToolResultDefinition {\n role: string;\n name: string;\n tool_call_id: string;\n content: string;\n}\n\nexport interface ToolResult {\n id: string;\n type: string;\n function: {\n name: string;\n arguments: string;\n };\n result: {\n content: string;\n };\n}\n\ntype Utils = {\n events: typeof events;\n sleep: typeof sleep;\n};\n\nexport type BotBase = {\n handleMessage(request: QueryRequest, ctx: Ctx, utils: Utils): AsyncIterable;\n settings: SettingsResponse | ((request: SettingsRequest, ctx: Ctx) => Promise | SettingsResponse);\n};\n\nexport type ValTownCtx = {\n req: Request;\n};\n\ntype Handler = (req: Request) => Promise;\n\nconst instructions = `\nTo setup this bot with Poe:\n

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

poe_bot

Version 39