[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_180":181,"_182":183},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":86,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":122,"_123":124,"_125":25,"_126":127,"_128":59,"_129":-5,"_130":-5,"_131":132},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":55,"_18":56,"_57":31,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",2,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.tsx","latestPath","fileId","019f649d-e26c-731e-8bbf-ecff16b8dd27","name","fileType","http","content","import process from \"node:process\";\nconst BASE_COST = 150;\nconst USD_PER_POINT = 30 / 1_000_000;\nconst RERANK_MODELS = [\"cohere/rerank-v3.5\", \"rerank-4-fast\", \"rerank-4-fast-pro\"] as const;\nconst GROQ_MODELS = [\n \"compound-mini\",\n \"compound\",\n \"meta-llama/llama-4-scout-17b-16e-instruct\",\n \"llama-3.3-70b-versatile\",\n] as const;\nfunction verifyBotKey(req: Request): boolean {\n const botKey = process.env.BOT_ACCESS_KEY;\n if (!botKey) return false;\n const authHeader = req.headers.get(\"Authorization\") ?? \"\";\n const token = authHeader.startsWith(\"Bearer \")\n ? authHeader.slice(7).trim()\n : authHeader.trim();\n return token === botKey;\n}\nfunction formatUSD(amount: number): string {\n if (amount === 0) return \"$0.00\";\n const fixed = amount.toFixed(6);\n const trimmed = fixed\n .replace(/(\\.\\d*?[1-9])0+$/, \"$1\")\n .replace(/\\.00$/, \".00\");\n return `$${trimmed}`;\n}\ninterface SearchResult {\n title: string;\n url: string;\n snippet: string;\n quotes: string[];\n relevanceScore: number;\n source: string;\n timestamp?: string;\n}\nfunction extractRelevantQuotes(content: string, query: string): string[] {\n const quotes: string[] = [];\n const queryTerms = query.toLowerCase().split(/\\s+/).filter((t) => t.length > 2);\n const sentences = content\n .split(/[.!?]+/)\n .map((s) => s.trim())\n .filter((s) => s.length > 20);\n sentences.forEach((sentence) => {\n const lowerSentence = sentence.toLowerCase();\n const matchCount = queryTerms.filter((term) =>\n lowerSentence.includes(term)\n ).length;\n if (matchCount >= Math.min(2, queryTerms.length)) {\n const cleanQuote = sentence.replace(/\\s+/g, \" \").trim();\n if (cleanQuote.length > 30 && cleanQuote.length < 300)\n quotes.push(cleanQuote);\n }\n });\n return [...new Set(quotes)].slice(0, 5);\n}\nfunction calculateRelevance(content: string, query: string): number {\n const lowerContent = content.toLowerCase();\n const queryTerms = query.toLowerCase().split(/\\s+/);\n let score = 0;\n queryTerms.forEach((term) => {\n const regex = new RegExp(`\\\\b${term}\\\\b`, \"gi\");\n const matches = lowerContent.match(regex);\n if (matches) score += matches.length * 2;\n });\n if (lowerContent.includes(query.toLowerCase())) score += 20;\n return Math.min(score, 100);\n}\nasync function searchBrave(query: string): Promise {\n const results: SearchResult[] = [];\n const apiKey = process.env.BRAVE_API_KEY;\n if (!apiKey) return results;\n try {\n const response = await fetch(\n `https://api.search.brave.com/res/v1/web/search?q=${encodeURIComponent(query)}&count=10`,\n {\n headers: {\n Accept: \"application/json\",\n \"X-Subscription-Token\": apiKey,\n },\n signal: AbortSignal.timeout(8000),\n }\n );\n if (response.ok) {\n const data = await response.json();\n (data.web?.results ?? []).forEach((r: any) => {\n const content = `${r.title} ${r.description}`;\n results.push({\n title: r.title,\n url: r.url,\n snippet: r.description || \"\",\n quotes: extractRelevantQuotes(content, query),\n relevanceScore: calculateRelevance(content, query),\n source: new URL(r.url).hostname,\n timestamp: r.age || new Date().toISOString(),\n });\n });\n }\n } catch (error) {\n console.error(\"Brave search failed:\", error);\n }\n return results;\n}\nasync function searchSerper(query: string): Promise {\n const results: SearchResult[] = [];\n const serperKey = process.env.SERPER_API_KEY;\n if (!serperKey) return results;\n try {\n const response = await fetch(\"https://google.serper.dev/search\", {\n method: \"POST\",\n headers: {\n \"X-API-KEY\": serperKey,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ q: query, num: 10 }),\n signal: AbortSignal.timeout(8000),\n });\n if (response.ok) {\n const data = await response.json();\n (data.organic ?? []).forEach((r: any) => {\n const content = `${r.title} ${r.snippet}`;\n results.push({\n title: r.title,\n url: r.link,\n snippet: r.snippet || \"\",\n quotes: extractRelevantQuotes(content, query),\n relevanceScore: calculateRelevance(content, query),\n source: new URL(r.link).hostname,\n });\n });\n }\n } catch (error) {\n console.error(\"Serper failed:\", error);\n }\n return results;\n}\nasync function searchGoogleCustom(query: string): Promise {\n const results: SearchResult[] = [];\n const apiKey = process.env.GOOGLE_API_KEY;\n const cx = process.env.GOOGLE_CX;\n if (!apiKey || !cx) return results;\n try {\n const response = await fetch(\n `https://www.googleapis.com/customsearch/v1?key=${apiKey}&cx=${cx}&q=${encodeURIComponent(query)}&num=10`,\n { signal: AbortSignal.timeout(8000) }\n );\n if (response.ok) {\n const data = await response.json();\n (data.items ?? []).forEach((item: any) => {\n const content = `${item.title} ${item.snippet}`;\n results.push({\n title: item.title,\n url: item.link,\n snippet: item.snippet || \"\",\n quotes: extractRelevantQuotes(content, query),\n relevanceScore: calculateRelevance(content, query),\n source: new URL(item.link).hostname,\n });\n });\n }\n } catch (error) {\n console.error(\"Google Custom Search failed:\", error);\n }\n return results;\n}\nasync function gatherResults(query: string): Promise {\n const variations = [query, `${query} explained`, `${query} latest research`];\n const tasks = variations.flatMap((q) => [\n searchBrave(q),\n searchSerper(q),\n searchGoogleCustom(q),\n ]);\n const settled = await Promise.allSettled(tasks);\n const all: SearchResult[] = [];\n settled.forEach((r) => {\n if (r.status === \"fulfilled\") all.push(...r.value);\n });\n return all\n .filter((r, idx, arr) => arr.findIndex((t) => t.url === r.url) === idx)\n .sort((a, b) => b.relevanceScore - a.relevanceScore)\n .slice(0, 20);\n}\n// Stage 1: OpenRouter Cohere rerank — returns results re-sorted by neural relevance.\n// Tries RERANK_MODELS in order; throws if all fail.\nasync function rerankWithOpenRouter(\n query: string,\n results: SearchResult[]\n): Promise {\n const apiKey = process.env.OPENROUTER_API_KEY;\n if (!apiKey) throw new Error(\"OPENROUTER_API_KEY not set\");\n const documents = results.map((r) => `${r.title}\\n${r.snippet}`);\n let lastError: Error | null = null;\n for (const model of RERANK_MODELS) {\n try {\n const response = await fetch(\"https://openrouter.ai/api/v1/rerank\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n \"HTTP-Referer\": \"https://deep-search.app\",\n \"X-Title\": \"Deep Search Engine\",\n },\n body: JSON.stringify({\n model,\n query,\n documents,\n top_n: Math.min(15, results.length),\n }),\n signal: AbortSignal.timeout(12000),\n });\n if (!response.ok) {\n const body = await response.text().catch(() => \"\");\n throw new Error(`OpenRouter rerank ${model} HTTP ${response.status}: ${body}`);\n }\n const data = await response.json();\n const ranked: SearchResult[] = (data.results ?? [])\n .sort((a: any, b: any) => b.relevance_score - a.relevance_score)\n .map((r: any) => ({\n ...results[r.index],\n relevanceScore: Math.round(r.relevance_score * 100),\n }));\n if (ranked.length > 0) return ranked;\n throw new Error(`${model} returned empty results`);\n } catch (err) {\n lastError = err as Error;\n console.error(`Rerank ${model} failed:`, err);\n }\n }\n throw lastError ?? new Error(\"All rerank models exhausted\");\n}\n// Stage 2: Groq synthesis — iterates keys × models, returns on first success.\nasync function synthesizeWithGroq(\n query: string,\n results: SearchResult[]\n): Promise {\n const groqKeys = [\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) as string[];\n if (groqKeys.length === 0) throw new Error(\"No GROQ_API_KEY set\");\n const systemPrompt =\n \"You are a deep search analyst. Synthesize search results into a comprehensive, structured report with key findings, relevant quotes, and source attributions. Prioritize accuracy and depth.\";\n const userPrompt =\n `Query: \"${query}\"\\n\\nSearch Results (${results.length} sources):\\n` +\n `${JSON.stringify(results, null, 2)}\\n\\n` +\n `Produce:\\n1. Executive summary\\n2. Key findings with direct quotes\\n3. Source credibility breakdown\\n4. Conclusion and knowledge gaps`;\n for (const model of GROQ_MODELS) {\n for (const apiKey of groqKeys) {\n try {\n const response = await fetch(\n \"https://api.groq.com/openai/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model,\n messages: [\n { role: \"system\", content: systemPrompt },\n { role: \"user\", content: userPrompt },\n ],\n stream: false,\n max_tokens: 8192,\n temperature: 0.3,\n }),\n signal: AbortSignal.timeout(30000),\n }\n );\n if (!response.ok)\n throw new Error(`Groq ${model} HTTP ${response.status}`);\n const data = await response.json();\n const text: string = data.choices?.[0]?.message?.content ?? \"\";\n if (text.length > 0) return text;\n } catch (err) {\n console.error(`Groq ${model} failed:`, err);\n }\n }\n }\n throw new Error(\"All Groq models exhausted\");\n}\n// Stage 3 (final fallback): raw Brave-only dump with no AI synthesis.\nasync function braveFallback(\n query: string,\n send: SendEventFn\n): Promise {\n const results = await searchBrave(query);\n if (results.length === 0) {\n send(\"text\", {\n text:\n `❌ No results found. Try:\\n` +\n `- Refining query terms\\n` +\n `- More specific keywords\\n` +\n `- Different phrasing\\n\\n` +\n `**Alternative engines:**\\n` +\n `- [Google](https://www.google.com/search?q=${encodeURIComponent(query)})\\n` +\n `- [Bing](https://www.bing.com/search?q=${encodeURIComponent(query)})\\n` +\n `- [DuckDuckGo](https://duckduckgo.com/?q=${encodeURIComponent(query)})`,\n });\n return;\n }\n send(\"text\", {\n text: `## 📋 Brave Search Results (${results.length} sources)\\n\\n`,\n });\n results.forEach((result, idx) => {\n send(\"text\", {\n text:\n `### ${idx + 1}. ${result.title}\\n` +\n `**Source:** ${result.source} | **Relevance:** ${result.relevanceScore}%\\n` +\n `**URL:** ${result.url}\\n\\n` +\n `**Snippet:** ${result.snippet.substring(0, 200)}...\\n\\n` +\n `**Key Quotes:**\\n${result.quotes.map((q) => `> \"${q}\"`).join(\"\\n\\n\")}\\n\\n` +\n `---\\n\\n`,\n });\n });\n send(\"text\", {\n text: `\\n\\n## 🔗 Sources\\n${results\n .map((r, i) => `${i + 1}. [${r.source}](${r.url})`)\n .join(\"\\n\")}\\n`,\n });\n}\nasync function getResponse(req: Query, send: SendEventFn) {\n send(\"meta\", { content_type: \"text/markdown\", suggested_replies: true });\n const searchQuery =\n req.query[req.query.length - 1].content;\n send(\"text\", { text: `🔍 Deep Search Initiated...\\n\\n` });\n send(\"text\", { text: `⏳ Gathering results in parallel...\\n\\n` });\n let gathered: SearchResult[] = [];\n try {\n gathered = await gatherResults(searchQuery);\n send(\"text\", {\n text: `✅ Collected ${gathered.length} deduplicated results\\n\\n`,\n });\n } catch (err) {\n send(\"text\", {\n text: `⚠️ Search aggregation error: ${(err as Error).message}\\n\\n`,\n });\n }\n if (gathered.length === 0) {\n send(\"text\", { text: `🔄 Falling back to Brave direct search...\\n\\n` });\n await braveFallback(searchQuery, send);\n send(\"done\", {});\n return;\n }\n // Stage 1: rerank\n let ranked = gathered;\n try {\n send(\"text\", { text: `🎯 Reranking with Cohere...\\n\\n` });\n ranked = await rerankWithOpenRouter(searchQuery, gathered);\n send(\"text\", {\n text: `✅ Reranked to ${ranked.length} top results\\n\\n`,\n });\n } catch (err) {\n console.error(\"Rerank pipeline failed:\", err);\n send(\"text\", {\n text: `⚠️ Rerank unavailable — using heuristic scores\\n\\n`,\n });\n ranked = gathered.slice(0, 15);\n }\n // Stage 2: Groq synthesis\n send(\"text\", { text: `🤖 Synthesizing with Groq...\\n\\n` });\n try {\n const analysis = await synthesizeWithGroq(searchQuery, ranked);\n send(\"text\", { text: analysis });\n send(\"text\", {\n text: `\\n\\n## 🔗 Sources\\n${ranked\n .map((r, i) => `${i + 1}. [${r.source}](${r.url})`)\n .join(\"\\n\")}\\n`,\n });\n } catch (err) {\n console.error(\"Groq synthesis failed:\", err);\n send(\"text\", {\n text: `⚠️ AI synthesis failed — falling back to Brave raw results\\n\\n`,\n });\n await braveFallback(searchQuery, send);\n }\n send(\"done\", {});\n}\nasync function getBotSettings(): Promise {\n const costUSD = BASE_COST * USD_PER_POINT;\n const rateCard =\n \"| Type | Rate (USD) | Rate (Points) |\\n\" +\n \"|------|--------------|------------|\\n\" +\n `| Total Cost | ${formatUSD(costUSD)}/message | ${BASE_COST} points |\\n`;\n return {\n allow_attachments: false,\n expand_text_attachments: false,\n enable_multi_bot_chat_prompting: true,\n enable_suggested_replies: true,\n rate_card: rateCard,\n supports_system_messages: true,\n suggested_replies: true,\n };\n}\ntype BotSettings = {\n allow_attachments?: boolean;\n expand_text_attachments?: boolean;\n enable_multi_bot_chat_prompting?: boolean;\n enable_suggested_replies?: boolean;\n rate_card?: string;\n supports_system_messages?: boolean;\n suggested_replies?: boolean;\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: { type: \"like\" | \"dislike\"; reason?: string }[];\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};\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};\ntype SendEventFn = (\n eventName: EventName,\n data: Events[EventName]\n) => void;\nfunction encodeEvent(event: string, data: any = {}) {\n return new TextEncoder().encode(\n `event: ${event}\\ndata: ${JSON.stringify(data)}\\n\\n`\n );\n}\nexport default async function (req: Request): Promise {\n if (!verifyBotKey(req)) {\n return new Response(JSON.stringify({ error: \"Unauthorized\" }), {\n status: 401,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n const reqBody = await req.json().catch((e) => {\n console.error(\"body parse error\", e);\n return {};\n });\n console.log(\"body\", reqBody);\n if (reqBody.type === \"settings\") {\n return new Response(JSON.stringify(await getBotSettings()), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n const body = new ReadableStream({\n start(controller) {\n const send = (event: any, data: any) => {\n controller.enqueue(encodeEvent(event, data));\n };\n return getResponse(reqBody, send)\n .catch((e) => console.error(\"getResponse error\", e))\n .finally(() => controller.close());\n },\n });\n return new Response(body, {\n status: 200,\n headers: { \"Content-Type\": \"text/event-stream\" },\n });\n}","import process from \"node:process\";\nconst BASE_COST = 150;\nconst USD_PER_POINT = 30 / 1_000_000;\nconst RERANK_MODELS = [\"cohere/rerank-v3.5\", \"rerank-4-fast\", \"rerank-4-fast-pro\"] as const;\nconst GROQ_MODELS = [\n \"compound-mini\",\n \"compound\",\n \"meta-llama/llama-4-scout-17b-16e-instruct\",\n \"llama-3.3-70b-versatile\",\n] as const;\nfunction verifyBotKey(req: Request): boolean {\n const botKey = process.env.BOT_ACCESS_KEY;\n if (!botKey) return false;\n const authHeader = req.headers.get(\"Authorization\") ?? \"\";\n const token = authHeader.startsWith(\"Bearer \")\n ? authHeader.slice(7).trim()\n : authHeader.trim();\n return token === botKey;\n}\nfunction formatUSD(amount: number): string {\n if (amount === 0) return \"$0.00\";\n const fixed = amount.toFixed(6);\n const trimmed = fixed\n .replace(/(\\.\\d*?[1-9])0+$/, \"$1\")\n .replace(/\\.00$/, \".00\");\n return `$${trimmed}`;\n}\ninterface SearchResult {\n title: string;\n url: string;\n snippet: string;\n quotes: string[];\n relevanceScore: number;\n source: string;\n timestamp?: string;\n}\nfunction extractRelevantQuotes(content: string, query: string): string[] {\n const quotes: string[] = [];\n const queryTerms = query.toLowerCase().split(/\\s+/).filter((t) => t.length > 2);\n const sentences = content\n .split(/[.!?]+/)\n .map((s) => s.trim())\n .filter((s) => s.length > 20);\n sentences.forEach((sentence) => {\n const lowerSentence = sentence.toLowerCase();\n const matchCount = queryTerms.filter((term) =>\n lowerSentence.includes(term)\n ).length;\n if (matchCount >= Math.min(2, queryTerms.length)) {\n const cleanQuote = sentence.replace(/\\s+/g, \" \").trim();\n if (cleanQuote.length > 30 && cleanQuote.length < 300)\n quotes.push(cleanQuote);\n }\n });\n return [...new Set(quotes)].slice(0, 5);\n}\nfunction calculateRelevance(content: string, query: string): number {\n const lowerContent = content.toLowerCase();\n const queryTerms = query.toLowerCase().split(/\\s+/);\n let score = 0;\n queryTerms.forEach((term) => {\n const regex = new RegExp(`\\\\b${term}\\\\b`, \"gi\");\n const matches = lowerContent.match(regex);\n if (matches) score += matches.length * 2;\n });\n if (lowerContent.includes(query.toLowerCase())) score += 20;\n return Math.min(score, 100);\n}\nasync function searchBrave(query: string): Promise {\n const results: SearchResult[] = [];\n const apiKey = process.env.BRAVE_API_KEY;\n if (!apiKey) return results;\n try {\n const response = await fetch(\n `https://api.search.brave.com/res/v1/web/search?q=${encodeURIComponent(query)}&count=10`,\n {\n headers: {\n Accept: \"application/json\",\n \"X-Subscription-Token\": apiKey,\n },\n signal: AbortSignal.timeout(8000),\n }\n );\n if (response.ok) {\n const data = await response.json();\n (data.web?.results ?? []).forEach((r: any) => {\n const content = `${r.title} ${r.description}`;\n results.push({\n title: r.title,\n url: r.url,\n snippet: r.description || \"\",\n quotes: extractRelevantQuotes(content, query),\n relevanceScore: calculateRelevance(content, query),\n source: new URL(r.url).hostname,\n timestamp: r.age || new Date().toISOString(),\n });\n });\n }\n } catch (error) {\n console.error(\"Brave search failed:\", error);\n }\n return results;\n}\nasync function searchSerper(query: string): Promise {\n const results: SearchResult[] = [];\n const serperKey = process.env.SERPER_API_KEY;\n if (!serperKey) return results;\n try {\n const response = await fetch(\"https://google.serper.dev/search\", {\n method: \"POST\",\n headers: {\n \"X-API-KEY\": serperKey,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ q: query, num: 10 }),\n signal: AbortSignal.timeout(8000),\n });\n if (response.ok) {\n const data = await response.json();\n (data.organic ?? []).forEach((r: any) => {\n const content = `${r.title} ${r.snippet}`;\n results.push({\n title: r.title,\n url: r.link,\n snippet: r.snippet || \"\",\n quotes: extractRelevantQuotes(content, query),\n relevanceScore: calculateRelevance(content, query),\n source: new URL(r.link).hostname,\n });\n });\n }\n } catch (error) {\n console.error(\"Serper failed:\", error);\n }\n return results;\n}\nasync function searchGoogleCustom(query: string): Promise {\n const results: SearchResult[] = [];\n const apiKey = process.env.GOOGLE_API_KEY;\n const cx = process.env.GOOGLE_CX;\n if (!apiKey || !cx) return results;\n try {\n const response = await fetch(\n `https://www.googleapis.com/customsearch/v1?key=${apiKey}&cx=${cx}&q=${encodeURIComponent(query)}&num=10`,\n { signal: AbortSignal.timeout(8000) }\n );\n if (response.ok) {\n const data = await response.json();\n (data.items ?? []).forEach((item: any) => {\n const content = `${item.title} ${item.snippet}`;\n results.push({\n title: item.title,\n url: item.link,\n snippet: item.snippet || \"\",\n quotes: extractRelevantQuotes(content, query),\n relevanceScore: calculateRelevance(content, query),\n source: new URL(item.link).hostname,\n });\n });\n }\n } catch (error) {\n console.error(\"Google Custom Search failed:\", error);\n }\n return results;\n}\nasync function gatherResults(query: string): Promise {\n const variations = [query, `${query} explained`, `${query} latest research`];\n const tasks = variations.flatMap((q) => [\n searchBrave(q),\n searchSerper(q),\n searchGoogleCustom(q),\n ]);\n const settled = await Promise.allSettled(tasks);\n const all: SearchResult[] = [];\n settled.forEach((r) => {\n if (r.status === \"fulfilled\") all.push(...r.value);\n });\n return all\n .filter((r, idx, arr) => arr.findIndex((t) => t.url === r.url) === idx)\n .sort((a, b) => b.relevanceScore - a.relevanceScore)\n .slice(0, 20);\n}\n// Stage 1: OpenRouter Cohere rerank — returns results re-sorted by neural relevance.\n// Tries RERANK_MODELS in order; throws if all fail.\nasync function rerankWithOpenRouter(\n query: string,\n results: SearchResult[]\n): Promise {\n const apiKey = process.env.OPENROUTER_API_KEY;\n if (!apiKey) throw new Error(\"OPENROUTER_API_KEY not set\");\n const documents = results.map((r) => `${r.title}\\n${r.snippet}`);\n let lastError: Error | null = null;\n for (const model of RERANK_MODELS) {\n try {\n const response = await fetch(\"https://openrouter.ai/api/v1/rerank\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n \"HTTP-Referer\": \"https://deep-search.app\",\n \"X-Title\": \"Deep Search Engine\",\n },\n body: JSON.stringify({\n model,\n query,\n documents,\n top_n: Math.min(15, results.length),\n }),\n signal: AbortSignal.timeout(12000),\n });\n if (!response.ok) {\n const body = await response.text().catch(() => \"\");\n throw new Error(`OpenRouter rerank ${model} HTTP ${response.status}: ${body}`);\n }\n const data = await response.json();\n const ranked: SearchResult[] = (data.results ?? [])\n .sort((a: any, b: any) => b.relevance_score - a.relevance_score)\n .map((r: any) => ({\n ...results[r.index],\n relevanceScore: Math.round(r.relevance_score * 100),\n }));\n if (ranked.length > 0) return ranked;\n throw new Error(`${model} returned empty results`);\n } catch (err) {\n lastError = err as Error;\n console.error(`Rerank ${model} failed:`, err);\n }\n }\n throw lastError ?? new Error(\"All rerank models exhausted\");\n}\n// Stage 2: Groq synthesis — iterates keys × models, returns on first success.\nasync function synthesizeWithGroq(\n query: string,\n results: SearchResult[]\n): Promise {\n const groqKeys = [\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) as string[];\n if (groqKeys.length === 0) throw new Error(\"No GROQ_API_KEY set\");\n const systemPrompt =\n \"You are a deep search analyst. Synthesize search results into a comprehensive, structured report with key findings, relevant quotes, and source attributions. Prioritize accuracy and depth.\";\n const userPrompt =\n `Query: \"${query}\"\\n\\nSearch Results (${results.length} sources):\\n` +\n `${JSON.stringify(results, null, 2)}\\n\\n` +\n `Produce:\\n1. Executive summary\\n2. Key findings with direct quotes\\n3. Source credibility breakdown\\n4. Conclusion and knowledge gaps`;\n for (const model of GROQ_MODELS) {\n for (const apiKey of groqKeys) {\n try {\n const response = await fetch(\n \"https://api.groq.com/openai/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model,\n messages: [\n { role: \"system\", content: systemPrompt },\n { role: \"user\", content: userPrompt },\n ],\n stream: false,\n max_tokens: 8192,\n temperature: 0.3,\n }),\n signal: AbortSignal.timeout(30000),\n }\n );\n if (!response.ok)\n throw new Error(`Groq ${model} HTTP ${response.status}`);\n const data = await response.json();\n const text: string = data.choices?.[0]?.message?.content ?? \"\";\n if (text.length > 0) return text;\n } catch (err) {\n console.error(`Groq ${model} failed:`, err);\n }\n }\n }\n throw new Error(\"All Groq models exhausted\");\n}\n// Stage 3 (final fallback): raw Brave-only dump with no AI synthesis.\nasync function braveFallback(\n query: string,\n send: SendEventFn\n): Promise {\n const results = await searchBrave(query);\n if (results.length === 0) {\n send(\"text\", {\n text:\n `❌ No results found. Try:\\n` +\n `- Refining query terms\\n` +\n `- More specific keywords\\n` +\n `- Different phrasing\\n\\n` +\n `**Alternative engines:**\\n` +\n `- [Google](https://www.google.com/search?q=${encodeURIComponent(query)})\\n` +\n `- [Bing](https://www.bing.com/search?q=${encodeURIComponent(query)})\\n` +\n `- [DuckDuckGo](https://duckduckgo.com/?q=${encodeURIComponent(query)})`,\n });\n return;\n }\n send(\"text\", {\n text: `## 📋 Search Results (${results.length} sources)\\n\\n`,\n });\n results.forEach((result, idx) => {\n send(\"text\", {\n text:\n `### ${idx + 1}. ${result.title}\\n` +\n `**Source:** ${result.source} | **Relevance:** ${result.relevanceScore}%\\n` +\n `**URL:** ${result.url}\\n\\n` +\n `**Snippet:** ${result.snippet.substring(0, 200)}...\\n\\n` +\n `**Key Quotes:**\\n${result.quotes.map((q) => `> \"${q}\"`).join(\"\\n\\n\")}\\n\\n` +\n `---\\n\\n`,\n });\n });\n send(\"text\", {\n text: `\\n\\n## 🔗 Sources\\n${results\n .map((r, i) => `${i + 1}. [${r.source}](${r.url})`)\n .join(\"\\n\")}\\n`,\n });\n}\nasync function getResponse(req: Query, send: SendEventFn) {\n send(\"meta\", { content_type: \"text/markdown\", suggested_replies: true });\n const searchQuery =\n req.query[req.query.length - 1].content;\n send(\"text\", { text: `🔍 Deep Search Initiated...\\n\\n` });\n send(\"text\", { text: `⏳ Gathering results in parallel...\\n\\n` });\n let gathered: SearchResult[] = [];\n try {\n gathered = await gatherResults(searchQuery);\n send(\"text\", {\n text: `✅ Collected ${gathered.length} deduplicated results\\n\\n`,\n });\n } catch (err) {\n send(\"text\", {\n text: `⚠️ Search aggregation error: ${(err as Error).message}\\n\\n`,\n });\n }\n if (gathered.length === 0) {\n send(\"text\", { text: `🔄 Falling back to direct search...\\n\\n` });\n await braveFallback(searchQuery, send);\n send(\"done\", {});\n return;\n }\n // Stage 1: rerank — falls back to heuristic scores silently on failure,\n // without surfacing that rerank was unavailable.\n let ranked = gathered;\n try {\n send(\"text\", { text: `🎯 Reranking results...\\n\\n` });\n ranked = await rerankWithOpenRouter(searchQuery, gathered);\n send(\"text\", {\n text: `✅ Reranked to ${ranked.length} top results\\n\\n`,\n });\n } catch (err) {\n console.error(\"Rerank pipeline failed:\", err);\n ranked = gathered.slice(0, 15);\n }\n // Stage 2: Groq synthesis — falls back to raw results silently on failure,\n // without surfacing that synthesis was unavailable.\n send(\"text\", { text: `🤖 Synthesizing findings...\\n\\n` });\n try {\n const analysis = await synthesizeWithGroq(searchQuery, ranked);\n send(\"text\", { text: analysis });\n send(\"text\", {\n text: `\\n\\n## 🔗 Sources\\n${ranked\n .map((r, i) => `${i + 1}. [${r.source}](${r.url})`)\n .join(\"\\n\")}\\n`,\n });\n } catch (err) {\n console.error(\"Groq synthesis failed:\", err);\n await braveFallback(searchQuery, send);\n }\n send(\"done\", {});\n}\nasync function getBotSettings(): Promise {\n const costUSD = BASE_COST * USD_PER_POINT;\n const rateCard =\n \"| Type | Rate (USD) | Rate (Points) |\\n\" +\n \"|------|--------------|------------|\\n\" +\n `| Total Cost | ${formatUSD(costUSD)}/message | ${BASE_COST} points |\\n`;\n return {\n allow_attachments: false,\n expand_text_attachments: false,\n enable_multi_bot_chat_prompting: true,\n enable_suggested_replies: true,\n rate_card: rateCard,\n supports_system_messages: true,\n suggested_replies: true,\n };\n}\ntype BotSettings = {\n allow_attachments?: boolean;\n expand_text_attachments?: boolean;\n enable_multi_bot_chat_prompting?: boolean;\n enable_suggested_replies?: boolean;\n rate_card?: string;\n supports_system_messages?: boolean;\n suggested_replies?: boolean;\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: { type: \"like\" | \"dislike\"; reason?: string }[];\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};\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};\ntype SendEventFn = (\n eventName: EventName,\n data: Events[EventName]\n) => void;\nfunction encodeEvent(event: string, data: any = {}) {\n return new TextEncoder().encode(\n `event: ${event}\\ndata: ${JSON.stringify(data)}\\n\\n`\n );\n}\nexport default async function (req: Request): Promise {\n if (!verifyBotKey(req)) {\n return new Response(JSON.stringify({ error: \"Unauthorized\" }), {\n status: 401,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n const reqBody = await req.json().catch((e) => {\n console.error(\"body parse error\", e);\n return {};\n });\n console.log(\"body\", reqBody);\n if (reqBody.type === \"settings\") {\n return new Response(JSON.stringify(await getBotSettings()), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n const body = new ReadableStream({\n start(controller) {\n const send = (event: any, data: any) => {\n controller.enqueue(encodeEvent(event, data));\n };\n return getResponse(reqBody, send)\n .catch((e) => console.error(\"getResponse error\", e))\n .finally(() => controller.close());\n },\n });\n return new Response(body, {\n status: 200,\n headers: { \"Content-Type\": \"text/event-stream\" },\n });\n}","createdAt",["D",1787314785487],"branchVersion","branchId","287b289d-f02e-47e6-842e-50863c8f85ba","id","9618bf5e-c409-45a7-875b-9ccfedf9a082","Quick-AI-Search",["D",1784099496482],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","https://poe.com/Rerank-v3-5","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/e11c524a-524a-4bae-88a9-d680555e0800/square512?exp=1789592399&sig=e5dea7c09588d35217903514b18c1a4034ce37d4d9220fb7a49df1e8e74ebf98","01995b22-1b41-771e-a0ac-a4cfc92d3606","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01995b22-1b41-771e-a0ac-a96f3508eae1","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":56,"_105":106,"_107":25},"branch",{"_13":14,"_32":86,"_43":42,"_87":44,"_88":89,"_90":91,"_92":50,"_93":94,"_95":96,"_97":45,"_98":99},"isOwned","main","projectId","forkedBranchId","ea966810-4ab9-11f1-a7f0-ee650bb23af1","forkedBranchVersion",3,"forkedProjectPrivacy","forkedProjectId","ea919bbe-4ab9-11f1-a7f0-ee650bb23af1","forkedProjectOrgId","0199868b-003e-768d-ad69-6ce312a92bd0","projectName","userHandle","MadeiInGermany","handle","displayName","Made in Germany","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/e077fc84-719f-4dd3-3403-3eb925812100/square512?exp=1789592399&sig=a3e146fb5c83cb2a5027def8b72497cdd10c75518566c837c071679c0541698f","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":176,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":55,"_18":56,"_57":31,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":177,"_81":178,"_83":179,"_85":25},"tree",[167,168],"files",[167,168],"counts",{"_156":63,"_157":147,"_158":63,"_159":160,"_161":162},"contents",[141,142],"upstreamProject",{"_43":94,"_32":45,"_52":53,"_54":55,"_49":50,"_79":139},"upstreamBranch",{"_43":89,"_38":133,"_134":135,"_32":86,"_87":94,"_13":91,"_88":-5,"_90":-5,"_136":137,"_47":-5,"_85":25,"_49":50,"_98":138,"_64":96,"_97":45},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1778229778990],"updatedAt",["D",1778232933631],"lockfileKey","1778498155218-esm.town_v_OpenSourceLab_Quick-AI-Search@3-main","OpenSourceLab",{"_100":138,"_108":140},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/101fb856-5036-4f58-57d7-593d55643401/square512?exp=1789592399&sig=61f94ff1d03c90c179d67a7cd919ec179a9348a4b930df872b540da5a0efc47d",{"_43":150,"_32":151,"_30":152,"_144":-5,"_41":42,"_40":147,"_145":59,"_38":153,"_13":63,"_33":20,"_35":154,"_24":25,"_148":-5,"_27":155},{"_43":143,"_32":28,"_30":31,"_144":-5,"_41":42,"_40":14,"_145":59,"_38":146,"_13":147,"_33":34,"_35":37,"_24":25,"_148":-5,"_27":149},"49220038-5f3e-4b67-b85c-21a3cf8e6ef2","parentId","latest",["D",1787314785487],1,"label",[28],"56c64a7f-4026-4591-8d47-27ef0cb7952a","Readme.txt","019f649d-e26c-731e-8bbf-ea9b3b17170e",["D",1784099496482],"- Implement BOT_ACCESS_KEY to authentificate\n- https://openrouter.ai/cohere/rerank-4-pro",[151],"pulls","branches","forks","envVars",{"_163":165,"_166":63},"connections",{"_163":63,"_164":63},"count","unfilledCount",7,"emptyCount",{"_43":150,"_32":151,"_30":152,"_144":-5,"_41":42,"_40":147,"_145":59,"_38":173,"_13":63,"_33":20,"_35":154,"_24":25,"_148":-5,"_170":174,"_27":175},{"_43":143,"_32":28,"_30":31,"_144":-5,"_41":42,"_40":14,"_145":59,"_38":169,"_13":147,"_33":34,"_35":37,"_24":25,"_148":-5,"_170":171,"_27":172},["D",1787314785487],"children",[],[28],["D",1784099496482],[],[151],["D",1784099496482],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":56,"_105":106,"_107":25},{"_13":14,"_32":86,"_43":42,"_87":44,"_88":89,"_90":91,"_92":50,"_93":94,"_95":96,"_97":45,"_98":99},"ctx",{"_79":-5,"_130":213,"_214":215,"_216":217,"_218":25,"_219":25,"_220":25,"_221":59,"_222":-5,"_223":-7,"_224":-7,"_225":63,"_226":25,"_227":25,"_228":-5,"_229":25,"_230":25,"_231":25,"_232":-5},"ENV",{"_184":185,"_186":187,"_188":86,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","RENDER_GIT_BRANCH","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","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v2