sonar

Author: izadoesdev

apps/api/src/ai/agents.ts

@@ -13,7 +13,7 @@ import { buildReflectionInstructions } from "./prompts/reflection";
 import { buildTriageInstructions } from "./prompts/triage";
 import { executeSqlQueryTool } from "./tools/execute-sql-query";
 import { getTopPagesTool } from "./tools/get-top-pages";
-import { webSearchTool } from "./tools/web-search";
+import { competitorAnalysisTool, webSearchTool } from "./tools/web-search";
 
 /**
  * Tools available to analytics agents.
@@ -22,6 +22,7 @@ const analyticsTools = {
     get_top_pages: getTopPagesTool,
     execute_sql_query: executeSqlQueryTool,
     web_search: webSearchTool,
+    competitor_analysis: competitorAnalysisTool,
     ...(Object.keys(memoryTools).length > 0 ? memoryTools : {}),
 } as const;
 
@@ -30,6 +31,7 @@ const analyticsTools = {
  */
 const triageTools = {
     web_search: webSearchTool,
+    competitor_analysis: competitorAnalysisTool,
     ...(Object.keys(memoryTools).length > 0 ? memoryTools : {}),
 } as const;
 

apps/api/src/ai/config/models.ts

@@ -18,13 +18,22 @@ export const openrouter = createOpenRouter({
  */
 export const models = {
 	/** Fast, cheap model for routing/triage decisions */
-	triage: openrouter.chat(process.env.AI_TRIAGE_MODEL ?? "anthropic/claude-haiku-4.5"),
+	triage: openrouter.chat(
+		process.env.AI_TRIAGE_MODEL ?? "anthropic/claude-haiku-4.5"
+	),
 
 	/** Balanced model for most analytical tasks */
-	analytics: openrouter.chat(process.env.AI_ANALYTICS_MODEL ?? "anthropic/claude-haiku-4.5"),
+	analytics: openrouter.chat(
+		process.env.AI_ANALYTICS_MODEL ?? "anthropic/claude-haiku-4.5"
+	),
 
 	/** High-capability model for complex reasoning and reflection */
-	advanced: openrouter.chat(process.env.AI_ADVANCED_MODEL ?? "anthropic/claude-sonnet-4.5"),
+	advanced: openrouter.chat(
+		process.env.AI_ADVANCED_MODEL ?? "anthropic/claude-sonnet-4.5"
+	),
+
+	/** Perplexity model for real-time web search and competitor analysis */
+	perplexity: openrouter.chat("perplexity/sonar-pro"),
 } as const;
 
 export type ModelKey = keyof typeof models;

apps/api/src/ai/prompts/analytics.ts

@@ -18,9 +18,11 @@ const ANALYTICS_RULES = `<agent-specific-rules>
 **Tools Usage:**
 - Use get_top_pages for page analytics
 - Use execute_sql_query for custom analytics queries
+- Use competitor_analysis for real-time competitor insights, market trends, and industry analysis with citations
 - Use memory tools (search_memory, add_memory) to remember user preferences and past analysis patterns
 - CRITICAL: execute_sql_query must ONLY use SELECT/WITH and parameter placeholders (e.g., {limit:UInt32}) with values passed via params. websiteId is automatically included. Never interpolate strings.
 - Example: execute_sql_query({ websiteId: "<use website_id from context>", sql: "SELECT ... WHERE client_id = {websiteId:String}", params: { limit: 10 } })
+- Example competitor analysis: competitor_analysis({ query: "competitors to example.com in web analytics", context: "Our website tracks user behavior and performance metrics" })
 - Example memory: search_memory({ query: "user's preferred metrics" })
 
 **Insights & Recommendations:**

apps/api/src/ai/prompts/triage.ts

@@ -14,6 +14,7 @@ databunny: End-to-end website analytics. Analyze traffic, visitors, page views,
 const ROUTING_RULES = `<routing-rules>
 - You are a single Databunny model. Never mention other experts or handoffs.
 - Always respond directly using the available tools.
+- For competitor analysis, use competitor_analysis tool for real-time market insights with citations.
 - Keep replies concise and action-oriented; avoid "I'll link you" phrasing.
 - Do not use emojis.
 </routing-rules>`;

apps/api/src/ai/tools/web-search.ts

@@ -1,6 +1,7 @@
 import FirecrawlApp from "@mendable/firecrawl-js";
-import { tool } from "ai";
+import { generateText, tool } from "ai";
 import { z } from "zod";
+import { models } from "../config/models";
 
 /**
  * Web search tool using Firecrawl for scraping and crawling websites.
@@ -28,3 +29,39 @@ export const webSearchTool = tool({
         return crawlResponse;
     },
 });
+
+/**
+ * Competitor analysis tool using Perplexity for real-time web search and analysis.
+ * Provides grounded insights with citations about competitors and market trends.
+ */
+export const competitorAnalysisTool = tool({
+    description:
+        "Analyze competitors, market trends, and industry insights using real-time web search with citations",
+    inputSchema: z.object({
+        query: z
+            .string()
+            .min(1)
+            .max(500)
+            .describe(
+                "The competitor analysis query (e.g., 'competitors to example.com in analytics space')"
+            ),
+        context: z
+            .string()
+            .optional()
+            .describe("Additional context about what you're analyzing"),
+    }),
+    execute: async ({ query, context }) => {
+        const fullQuery = context ? `${query}. Context: ${context}` : query;
+
+        const result = await generateText({
+            model: models.perplexity,
+            prompt: fullQuery,
+        });
+
+        return {
+            analysis: result.text || "",
+            sources: (result as any).sources || [],
+            query: fullQuery,
+        };
+    },
+});