\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}","deleted","label",[103],"permalink","https://www.val.town/x/OpenSourceLab/GPT-OSS-120B-Chat/code/main.tsx","extension","actionData","errors"]