\n\n[Download Music](${result})`;\n\n send(\"replace_response\", { text: musicResponse });\n return;\n }\n }\n\n send(\"error\", {\n text: \"❌ Music generation failed: Check POE_API_KEY\",\n allow_retry: true,\n });\n}\n\n// Intent detection\nfunction detectIntent(\n content: string,\n hasAttachments: boolean\n): { intent: string; cleanedContent: string } {\n let cleaned = content.trim();\n const lower = cleaned.toLowerCase();\n\n // Suffix-based detection\n const suffixes: Record = {\n \"--image\": \"image_generation\",\n \"--video\": \"video_generation\",\n \"--music\": \"music_generation\",\n \"--search\": \"search\",\n \"--code\": \"coding\",\n };\n\n for (const [suffix, intent] of Object.entries(suffixes)) {\n if (cleaned.endsWith(suffix)) {\n return {\n intent,\n cleanedContent: cleaned\n .substring(0, cleaned.length - suffix.length)\n .trim(),\n };\n }\n }\n\n // Prefix-based detection\n if (lower.startsWith(\"search \") || lower.startsWith(\"search for \")) {\n return {\n intent: \"search\",\n cleanedContent: cleaned.replace(/^search\\s+(for\\s+)?/i, \"\"),\n };\n }\n\n // Attachment-based detection\n if (hasAttachments) {\n if (lower.match(/\\b(image|picture|photo|analyze|describe|what)\\b/)) {\n return { intent: \"image_analysis\", cleanedContent: cleaned };\n }\n return { intent: \"file_analysis\", cleanedContent: cleaned };\n }\n\n // Content-based detection\n if (lower.match(/\\b(generate|create|draw)\\s+(image|picture)/)) {\n return { intent: \"image_generation\", cleanedContent: cleaned };\n }\n if (lower.match(/\\b(generate|create)\\s+video/)) {\n return { intent: \"video_generation\", cleanedContent: cleaned };\n }\n if (lower.match(/\\b(generate|create|compose)\\s+music/)) {\n return { intent: \"music_generation\", cleanedContent: cleaned };\n }\n if (\n lower.match(/\\b(code|program|function|script|implement|algorithm)\\b/)\n ) {\n return { intent: \"coding\", cleanedContent: cleaned };\n }\n if (lower.match(/\\b(search|find|look up|what is)\\b/)) {\n return { intent: \"search\", cleanedContent: cleaned };\n }\n\n return { intent: \"text_generation\", cleanedContent: cleaned };\n}\n\n// Main response handler\nasync function getResponse(req: Query, send: SendEventFn): Promise {\n send(\"meta\", { content_type: \"text/markdown\" });\n\n const messages = req.query.filter((m) => m.role === \"user\");\n const lastMessage = messages[messages.length - 1];\n\n if (!lastMessage) {\n send(\"text\", { text: \"How can I help you today?\" });\n send(\"done\", {});\n return;\n }\n\n const content = lastMessage.content;\n const attachments = lastMessage.attachments || [];\n const { intent, cleanedContent } = detectIntent(\n content,\n attachments.length > 0\n );\n\n try {\n switch (intent) {\n case \"image_generation\":\n await generateImage(cleanedContent, send);\n break;\n\n case \"video_generation\":\n await generateVideo(cleanedContent, send);\n break;\n\n case \"music_generation\":\n await generateMusic(cleanedContent, send);\n break;\n\n case \"coding\":\n await generateCode(cleanedContent, send);\n break;\n\n case \"search\":\n await performSearch(cleanedContent, send);\n break;\n\n case \"image_analysis\":\n const imageAtt = attachments.find((a) =>\n a.content_type?.startsWith(\"image/\")\n );\n if (imageAtt?.url) {\n await analyzeImage(imageAtt.url, cleanedContent, send);\n } else {\n send(\"error\", { text: \"Please attach an image\", allow_retry: false });\n }\n break;\n\n case \"file_analysis\":\n const fileAtt = attachments[0];\n if (fileAtt?.parsed_content) {\n await analyzeFile(\n fileAtt.parsed_content,\n fileAtt.name,\n cleanedContent,\n send\n );\n } else {\n send(\"error\", {\n text: \"Please attach a valid file\",\n allow_retry: false,\n });\n }\n break;\n\n case \"text_generation\":\n default:\n await generateText(cleanedContent, send);\n break;\n }\n } catch (error: any) {\n console.error(\"Error:\", error);\n send(\"error\", {\n text: `❌ Unexpected error: ${error.message}`,\n allow_retry: true,\n });\n }\n\n send(\"done\", {});\n}\n\n// Bot settings\nasync function getBotSettings() {\n return {\n allow_attachments: true,\n expand_text_attachments: true,\n enable_multi_bot_chat_prompting: true,\n rate_card:\n \"| Type | Price |\\n|------|-------|\\n| Total cost | 400 points/message |\",\n cost_label: \"Free\",\n };\n}\n\n// SSE encoder\nfunction encodeEvent(event: string, data: any = {}): Uint8Array {\n return new TextEncoder().encode(\n `event: ${event}\\ndata: ${JSON.stringify(data)}\\n\\n`\n );\n}\n\n// Main handler\nexport default async function (req: Request): Promise {\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204 });\n }\n\n const authResult = authenticateRequest(req);\n if (!authResult.isValid) {\n return new Response(JSON.stringify({ error: authResult.error }), {\n status: 401,\n headers: {\n \"Content-Type\": \"application/json\",\n \"WWW-Authenticate\": 'Bearer realm=\"Bot API\"',\n },\n });\n }\n\n const body = await req.json().catch(() => ({}));\n\n if (body.type === \"settings\") {\n return new Response(JSON.stringify(await getBotSettings()), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n const stream = new ReadableStream({\n start(controller) {\n const send: SendEventFn = (event, data) => {\n controller.enqueue(encodeEvent(event, data));\n };\n\n getResponse(body, send)\n .catch((error) => {\n console.error(\"Response error:\", error);\n send(\"error\", {\n text: `Fatal error: ${error.message}`,\n allow_retry: true,\n });\n })\n .finally(() => controller.close());\n },\n });\n\n return new Response(stream, {\n status: 200,\n headers: { \"Content-Type\": \"text/event-stream\" },\n });\n}",[],[186],"files",[165,184],"counts",{"_196":33,"_197":174,"_198":152,"_199":200,"_204":205},"pulls","branches","forks","envVars",{"_201":202,"_203":33},"count",11,"emptyCount","connections",{"_201":33,"_206":33},"unfilledCount","contents",[],{"_108":166,"_100":104,"_167":168,"_169":-5,"_170":153,"_171":152,"_172":124,"_110":210,"_105":174,"_175":176,"_177":178,"_179":22,"_180":-5,"_103":211},["D",1774115631948],[104],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_98":99,"_100":101,"_102":46,"_105":-7,"_103":104,"_106":220,"_163":225,"_192":234,"_176":235,"_207":238,"_239":-5,"_240":-5,"_241":-5,"_242":-5,"_243":244,"_199":-5},{"_108":109,"_100":101,"_110":221,"_112":-5,"_113":22,"_114":115,"_116":117,"_118":119,"_14":120,"_121":122,"_123":124,"_125":-5,"_126":-5,"_127":33,"_16":128,"_129":-5,"_130":-5,"_131":-5,"_132":-5,"_133":134,"_135":134,"_136":137,"_138":137,"_139":137,"_140":134,"_141":134,"_23":222,"_145":223,"_150":224,"_162":22},["D",1774115165117],{"_98":99,"_143":144},{"_98":99,"_147":144,"_14":120,"_148":149},{"_105":152,"_100":46,"_108":153,"_154":109,"_155":-5,"_156":-5,"_157":-5,"_158":-5,"_159":-5,"_160":101,"_161":99},[226,230],{"_108":166,"_100":104,"_167":168,"_169":-5,"_170":153,"_171":152,"_172":124,"_110":227,"_105":174,"_175":176,"_177":178,"_179":22,"_180":-5,"_181":228,"_103":229},["D",1774115631948],[],[104],{"_108":185,"_100":186,"_167":122,"_169":-5,"_170":153,"_171":174,"_172":124,"_110":231,"_105":33,"_175":188,"_177":189,"_179":22,"_180":-5,"_181":232,"_103":233},["D",1774115165117],[],[186],[226,230],{"_108":166,"_170":153,"_167":168,"_100":104,"_177":178,"_175":176,"_105":174,"_169":-5,"_110":236,"_171":152,"_180":-5,"_103":237},["D",1774115631948],[104],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]

OpenSourceLab

GPT-OSS-120B-Chat