[{"_1":2,"_181":-5,"_182":-5},"loaderData",{"_3":4,"_96":97},"root",{"_5":6,"_37":38,"_69":70},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20,"_36":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isBusinessOrgMember","isHigherTownieTier","ENV",{"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","7d99597163ee6d2ecd75e0020d9771df6719deb7","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","API_URL","https://api.val.town","clerkState",{"_71":72},"__internal_clerk_state",{"_73":74,"_75":48,"_76":77,"_78":77,"_79":20,"_80":77,"_81":77,"_82":77,"_83":77,"_84":85,"_94":20,"_95":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_86":20,"_19":20,"_87":77,"_88":89,"_90":77,"_91":48,"_92":20,"_93":77},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_98":99,"_100":101,"_102":103,"_104":105,"_162":163,"_178":179,"_180":-5},"handle","MadeiInGermany","name","Kimi-K2-0905-Omni","path","main.tsx","project",{"_106":107,"_100":101,"_108":109,"_110":-5,"_111":20,"_112":113,"_114":115,"_116":117,"_12":118,"_119":120,"_121":122,"_123":-5,"_124":-5,"_125":33,"_14":126,"_127":-5,"_128":-5,"_129":-5,"_130":-5,"_131":132,"_133":132,"_134":135,"_136":135,"_137":135,"_138":132,"_139":132,"_23":140,"_143":144,"_148":149,"_161":20},"id","44b47602-253f-11f1-884e-42dde27851f2","createdAt",["D",1774108909042],"deletedAt","legacyEnvVars","privacy","public","description","https://poe.com/Kimi-K2-0905-Vers","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/ba74ce79-8546-42bd-1d21-042a5912d200/square512","01995b22-1b41-771e-a0ac-a4cfc92d3606","pinnedFileId","019d1121-9e7c-70ee-b8c2-d70421b4ba4d","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","01995b22-1b41-771e-a0ac-a96f3508eae1","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_98":99,"_141":142},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/a46b91d4-4b2a-48c3-0c37-9c04ea652a00/square512","org",{"_98":99,"_145":142,"_12":118,"_146":147},"avatar","tier","free","branch",{"_150":151,"_100":46,"_106":152,"_153":107,"_154":-5,"_155":-5,"_156":-5,"_157":-5,"_158":-5,"_159":101,"_160":99},"version",1,"44be0ab4-253f-11f1-884e-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_106":164,"_100":103,"_165":120,"_166":-5,"_167":152,"_168":151,"_169":122,"_108":170,"_150":33,"_171":172,"_173":174,"_175":20,"_176":-5,"_102":177},"44c34402-253f-11f1-884e-42dde27851f2","fileId","parentId","branchId","branchVersion","latest",["D",1774108909042],"fileType","http","content","/** ***** https://poe.com/Kimi-K2-0905-Vers-02 *****/\nimport process from \"node:process\";\n\nconst BASE_COST = 16500;\nconst BOT_KEY = process.env.BOT_KEY;\n\nasync function analyzeMediaWithGemini(\n fileUrl: string, \n contentType: string, \n apiKeys: string[],\n userInstruction: string = \"\"\n): Promise {\n let lastError: Error | null = null;\n\n for (let keyIndex = 0; keyIndex < apiKeys.length; keyIndex++) {\n const apiKey = apiKeys[keyIndex];\n \n try {\n const fileResponse = await fetch(fileUrl);\n if (!fileResponse.ok) {\n throw new Error(`Failed to fetch file: ${fileResponse.status}`);\n }\n \n const fileBuffer = await fileResponse.arrayBuffer();\n const base64File = Buffer.from(fileBuffer).toString('base64');\n const mimeType = fileResponse.headers.get('content-type') || contentType;\n\n // Use the user's instruction as the prompt for all media types\n const prompt = userInstruction || \"Attached file: \";\n\n const response = await fetch(\n `https://generativelanguage.googleapis.com/v1beta/models/gemini-flash-latest:generateContent?key=${apiKey}`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n contents: [{\n parts: [\n {\n text: prompt\n },\n {\n inline_data: {\n mime_type: mimeType,\n data: base64File\n }\n }\n ]\n }],\n generationConfig: {\n temperature: 0.4,\n maxOutputTokens: 9048,\n }\n }),\n }\n );\n\n if (!response.ok) {\n const errorText = await response.text();\n const error = new Error(`Gemini API error: ${response.status} - ${errorText}`);\n \n // If it's a rate limit or auth error, try next key\n if (response.status === 429 || response.status === 401) {\n console.warn(`Gemini API key ${keyIndex + 1} failed with status ${response.status}, trying next key`);\n lastError = error;\n continue;\n }\n \n throw error;\n }\n\n const result = await response.json();\n const analysisText = result.candidates?.[0]?.content?.parts?.[0]?.text;\n \n if (!analysisText) {\n const error = new Error(\"No analysis text returned from Gemini\");\n lastError = error;\n continue;\n }\n\n return analysisText;\n } catch (error) {\n console.error(`Error analyzing media with Gemini API key ${keyIndex + 1}:`, error);\n lastError = error as Error;\n \n // If it's not the last key, continue to next key\n if (keyIndex < apiKeys.length - 1) {\n console.warn(`Trying next Gemini API key after error`);\n continue;\n }\n }\n }\n\n // If we've exhausted all keys, throw the last error\n throw lastError || new Error(\"All Gemini API keys failed\");\n}\n\nasync function getResponse(req: Query, send: SendEventFn) {\n send(\"meta\", { \n content_type: \"text/markdown\",\n suggested_replies: true \n });\n\n const supportedAttachments = req.query[req.query.length - 1]?.attachments?.filter(\n att => {\n const ct = att.content_type.toLowerCase();\n return ct.startsWith('image/') || \n ct.startsWith('audio/') || \n ct.startsWith('video/') ||\n ct.includes('spreadsheet') ||\n ct.includes('excel') ||\n ct.includes('sheet');\n }\n ) || [];\n\n let mediaAnalysis = \"\";\n \n if (supportedAttachments.length > 0) {\n const geminiApiKeys = [\n process.env.GEMINI_API_KEY,\n process.env.GEMINI_API_KEY2,\n process.env.GEMINI_API_KEY3,\n process.env.GEMINI_API_KEY4,\n ].filter(Boolean);\n \n if (geminiApiKeys.length === 0) {\n send(\"error\", {\n text: \"Error: No Gemini API keys configured for media analysis\",\n allow_retry: false,\n });\n send(\"done\", {});\n return;\n }\n\n try {\n send(\"text\", { text: \"*Analyzing...*\\n\\n\" });\n \n // Get user instruction from latest message\n const userInstruction = req.query[req.query.length - 1]?.content || \"\";\n \n const analyses = await Promise.all(\n supportedAttachments.map(async (att, index) => {\n const fileType = att.content_type.startsWith('image/') ? 'Image' :\n att.content_type.startsWith('audio/') ? 'Audio' :\n att.content_type.startsWith('video/') ? 'Video' : 'Excel/Spreadsheet';\n \n const analysis = await analyzeMediaWithGemini(att.url, att.content_type, geminiApiKeys, userInstruction);\n return supportedAttachments.length > 1 \n ? `**${fileType} ${index + 1} (${att.name || 'unnamed'}):**\\n${analysis}`\n : `**${fileType} (${att.name || 'unnamed'}):**\\n${analysis}`;\n })\n );\n \n mediaAnalysis = analyses.join(\"\\n\\n---\\n\\n\");\n send(\"text\", { text: `${mediaAnalysis}\\n\\n---\\n\\n` });\n } catch (error) {\n send(\"error\", {\n text: `Error analyzing media: ${error.message}`,\n allow_retry: true,\n });\n send(\"done\", {});\n return;\n }\n }\n\n // Build messages for the LLM\n const messages = req.query.map((msg) => {\n let content = msg.content;\n \n // If this message has media attachments, prepend the analysis\n const msgMedia = msg.attachments?.filter(att => {\n const ct = att.content_type.toLowerCase();\n return ct.startsWith('image/') || \n ct.startsWith('audio/') || \n ct.startsWith('video/') ||\n ct.includes('spreadsheet') ||\n ct.includes('excel') ||\n ct.includes('sheet');\n });\n \n if (msgMedia && msgMedia.length > 0 && mediaAnalysis) {\n content = `${mediaAnalysis}]\\n\\nUser query: ${content}`;\n }\n \n return {\n role: msg.role === \"bot\"\n ? \"assistant\"\n : msg.role as \"user\" | \"assistant\" | \"system\",\n content: content,\n };\n });\n\n const modelsConfig = [\n { model: \"moonshotai/kimi-k2:free\", provider: \"openrouter\" },\n { model: \"moonshotai/kimi-k2\", provider: \"openrouter\" },\n { model: \"moonshotai/kimi-k2-0905\", provider: \"openrouter\" },\n { model: \"moonshotai/kimi-k2-instruct-0905\", provider: \"groq\" },\n { model: \"moonshotai/kimi-k2-instruct\", provider: \"groq\" },\n { model: \"llama-3.3-70b-versatile\", provider: \"groq\" },\n { model: \"llama3-70b-8192\", provider: \"groq\" },\n { model: \"llama3-8b-8192\", provider: \"groq\" }\n ];\n\n const openrouterApiKeys = [\n process.env.OPENROUTER_API_KEY,\n process.env.OPENROUTER_API_KEY2,\n process.env.OPENROUTER_API_KEY3,\n process.env.OPENROUTER_API_KEY4,\n ].filter(Boolean);\n\n const groqApiKeys = [\n process.env.GROQ_API_KEY,\n process.env.GROQ_API_KEY2,\n process.env.GROQ_API_KEY3,\n process.env.GROQ_API_KEY4,\n ].filter(Boolean);\n\n if (openrouterApiKeys.length === 0 && groqApiKeys.length === 0) {\n send(\"error\", {\n text: \"Error: No API keys configured\",\n allow_retry: false,\n });\n send(\"done\", {});\n return;\n }\n\n for (let i = 0; i < modelsConfig.length; i++) {\n const { model, provider } = modelsConfig[i];\n const apiKeys = provider === \"openrouter\" ? openrouterApiKeys : groqApiKeys;\n const apiUrl = provider === \"openrouter\" \n ? \"https://openrouter.ai/api/v1/chat/completions\"\n : \"https://api.groq.com/openai/v1/chat/completions\";\n \n if (apiKeys.length === 0) {\n console.warn(`No ${provider} API keys available, skipping ${model}`);\n continue;\n }\n\n for (let keyIndex = 0; keyIndex < apiKeys.length; keyIndex++) {\n const apiKey = apiKeys[keyIndex];\n let response: Response | null = null;\n let reader: ReadableStreamDefaultReader | null = null;\n\n try {\n response = await fetch(apiUrl, {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: model,\n messages: messages,\n stream: true,\n max_tokens: 11048,\n temperature: 0.7,\n }),\n });\n\n if (!response.ok) {\n const errorText = await response.text().catch(() => \"Unknown error\");\n console.error(\n `Model ${model} (${provider}) with API key ${keyIndex + 1} failed with status ${response.status}: ${errorText}`,\n );\n if (response.status === 429 || response.status === 401) {\n if (keyIndex < apiKeys.length - 1) {\n console.warn(`Trying next ${provider} API key after ${response.status} error`);\n continue;\n }\n }\n if (keyIndex === apiKeys.length - 1) {\n if (i === modelsConfig.length - 1) {\n throw new Error(\n `All models and API keys failed. Last error: ${response.status} - ${errorText}`,\n );\n }\n console.warn(`Trying next model after ${model} failure with all keys`);\n break;\n }\n continue;\n }\n\n if (!response.body) {\n if (keyIndex === apiKeys.length - 1) {\n if (i === modelsConfig.length - 1) {\n throw new Error(\"No response body from any model or API key\");\n }\n console.warn(`No response body from ${model}, trying next model`);\n break;\n }\n console.warn(`No response body with ${provider} API key ${keyIndex + 1}, trying next key`);\n continue;\n }\n\n reader = response.body.getReader();\n const decoder = new TextDecoder();\n let buffer = \"\";\n\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n\n buffer += decoder.decode(value, { stream: true });\n const lines = buffer.split(\"\\n\");\n buffer = lines.pop() || \"\";\n\n for (const line of lines) {\n if (line.startsWith(\"data: \")) {\n const data = line.slice(6).trim();\n if (data === \"[DONE]\") continue;\n if (!data) continue;\n\n try {\n const parsed = JSON.parse(data);\n const content = parsed.choices?.[0]?.delta?.content;\n if (content) {\n send(\"text\", { text: content });\n }\n } catch (e) {\n console.error(\"Parse error:\", e, \"Data:\", data);\n }\n }\n }\n }\n\n reader.releaseLock();\n\n const suggestions = [];\n suggestions.forEach(text => {\n send(\"suggested_reply\", { text });\n });\n\n send(\"done\", {});\n return;\n } catch (error) {\n if (reader) {\n try {\n reader.releaseLock();\n } catch (e) {\n console.warn(\"Error releasing reader lock:\", e);\n }\n reader = null;\n }\n\n if (response?.body) {\n try {\n await response.body.cancel();\n } catch (e) {\n console.warn(\"Error canceling response body:\", e);\n }\n }\n\n if (keyIndex === apiKeys.length - 1 && i === modelsConfig.length - 1) {\n console.error(\"All models and API keys failed:\", error);\n send(\"error\", {\n text: `Error: ${error.message}`,\n allow_retry: true,\n });\n send(\"done\", {});\n return;\n }\n\n console.warn(\n `Model ${model} (${provider}) with API key ${keyIndex + 1} failed:`,\n error.message,\n keyIndex < apiKeys.length - 1 ? \"- trying next key\" : \"- trying next model\",\n );\n }\n }\n }\n\n send(\"done\", {});\n}\n\nasync function getBotSettings(): Promise {\n const rateCard = \"| Type | Price |\\n\" +\n \"|------|------|\\n\" +\n \"| Message Cost | 16500 points |\\n\";\n const costLabel = `16500 points`;\n\n return {\n allow_attachments: true,\n enable_suggested_replies: true,\n rate_card: rateCard,\n cost_label: costLabel,\n supports_system_messages: true,\n suggested_replies: true\n };\n}\n\nconst sleep = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms));\n\ntype BotSettings = {\n allow_attachments?: boolean;\n enable_suggested_replies?: boolean;\n rate_card?: string;\n cost_label?: string;\n supports_system_messages?: boolean;\n suggested_replies?: boolean;\n};\n\ntype Query = {\n version: string;\n type: \"query\";\n query: {\n role: \"system\" | \"user\" | \"bot\";\n content: string;\n content_type: string;\n timestamp: number;\n message_id: string;\n feedback: {\n type: \"like\" | \"dislike\";\n reason?: string;\n }[];\n attachments: {\n url: string;\n content_type: string;\n name: string;\n parsed_content?: string;\n }[];\n }[];\n message_id: string;\n user_id: string;\n conversation_id: string;\n metadata: string;\n language_code: string;\n};\n\ntype Events = {\n meta: { content_type: string; suggested_replies?: boolean };\n text: { text: string };\n replace_response: { text: string };\n suggested_reply: { text: string };\n error: { allow_retry?: boolean; text: string };\n done: {};\n};\n\ntype SendEventFn = (\n eventName: EventName,\n data: Events[EventName],\n) => void;\n\nfunction encodeEvent(event: string, data: any = {}) {\n return new TextEncoder().encode(\n `event: ${event}\\ndata: ${JSON.stringify(data)}\\n\\n`,\n );\n}\n\nexport default async function (req: Request): Promise {\n // Authentication check\n const authHeader = req.headers.get(\"Authorization\");\n \n if (!BOT_KEY) {\n console.error(\"BOT_KEY not configured in environment variables\");\n return new Response(\n JSON.stringify({ error: \"Bot authentication not configured\" }),\n {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n }\n );\n }\n\n if (!authHeader || authHeader !== `Bearer ${BOT_KEY}`) {\n console.warn(\"Unauthorized access attempt\");\n return new Response(\n JSON.stringify({ error: \"Unauthorized\" }),\n {\n status: 401,\n headers: { \"Content-Type\": \"application/json\" },\n }\n );\n }\n\n const reqBody = await req.json().catch((e) => {\n console.error(\"body parse error\", e);\n return {};\n });\n\n console.log(\"body\", reqBody);\n\n if (reqBody.type === \"settings\") {\n return new Response(JSON.stringify(await getBotSettings()), {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n },\n });\n }\n\n const body = new ReadableStream({\n start(controller) {\n const send = (event, data) => {\n controller.enqueue(encodeEvent(event, data));\n };\n\n return getResponse(reqBody, send)\n .catch((e) => console.error(\"get response error\", e))\n .finally(() => controller.close());\n },\n });\n\n return new Response(body, {\n status: 200,\n headers: {\n \"Content-Type\": \"text/event-stream\",\n },\n });\n}","deleted","label",[103],"permalink","https://www.val.town/x/MadeiInGermany/Kimi-K2-0905-Omni/code/main.tsx","extension","actionData","errors"]