feat: enhance agent workflows and configurations

- Updated OTEL configuration in instrumentation.ts to prevent double instrumentation.
- Refactored Dane agent to use new webScraperTool and updated model to 'google/gemini-3-flash-preview'.
- Commented out unused tools in editorAgent.ts and noteTakerAgent.ts for clarity.
- Removed outdated agent-experiments.ts file and added new experiments with logging for various agents.
- Improved error handling in repo-ingestion-workflow.ts for better clarity on scan results.
- Updated target audience checks in content-review-workflow.ts for more robust validation.
- Adjusted output processor limits in weather-agent.ts for performance optimization.
- Cleaned up whitespace in changelog.ts and other workflow files for consistency.

Author: ssdeanx

instrumentation.ts

@@ -1,5 +1,27 @@
 import { registerOTel } from "@vercel/otel";
 
+/**
+ * OTEL configuration is primarily handled by Mastra in `src/mastra/index.ts`.
+ *
+ * To avoid double instrumentation or conflicting exporters, Vercel's `registerOTel`
+ * is only used when explicitly enabled via the `VERCEL_OTEL_ENABLED` env flag.
+ *
+ * When `VERCEL_OTEL_ENABLED` is not set to `"true"`, this file becomes a no-op
+ * and Mastra's OTEL/exporter configuration is the single source of truth.
+ */
+const VERCEL_OTEL_ENABLED = process.env.VERCEL_OTEL_ENABLED === "true";
+
 export function register() {
-  registerOTel({ serviceName: "ai" });
+  if (!VERCEL_OTEL_ENABLED) {
+    // Rely on Mastra's OTEL/exporter configuration in `src/mastra/index.ts`.
+    // Intentionally do **not** call `registerOTel` here to prevent
+    // duplicate instrumentation and conflicting OTEL SDK instances.
+    return;
+  }
+
+  // When explicitly enabled, use Vercel's OTEL setup.
+  // Keep the service name aligned with Mastra's configuration (`"ai"`).
+  registerOTel({
+    serviceName: "ai",
+  });
 }

src/mastra/agents/dane.ts

@@ -6,6 +6,7 @@ import { execaTool } from '../tools/execa-tool'
 import type { GoogleGenerativeAIProviderOptions } from '@ai-sdk/google'
 import type { RequestContext } from '@mastra/core/request-context'
 import { TokenLimiterProcessor } from '@mastra/core/processors'
+import { webScraperTool } from '../tools'
 
 export interface DaneContext {
     userId?: string
@@ -191,19 +192,19 @@ export const dane = new Agent({
         google: {
           thinkingConfig: {
             includeThoughts: true,
-            thinkingBudget: -1,
+            thinkingLevel: 'high',
           },
           responseModalities: ['TEXT'],
         } satisfies GoogleGenerativeAIProviderOptions,
       }
     }
   },
-  model: googleAIFlashLite,
+  model: 'google/gemini-3-flash-preview',
   memory: pgMemory,
   tools: {
     execaTool,
     browserTool,
-    googleSearch,
+    webScraperTool,
     listEvents,
   },
   outputProcessors: [new TokenLimiterProcessor(1048576)]

src/mastra/agents/editorAgent.ts

@@ -120,7 +120,7 @@ Tailor your editing style to the content type:
     return google.chat('gemini-2.5-flash-preview-09-2025')
   },
   memory: pgMemory,
-  tools: [],
+//  tools: [],
   scorers: {
 
   },

src/mastra/agents/noteTakerAgent.ts

@@ -1,17 +1,17 @@
 import { Agent } from "@mastra/core/agent";
 import { GoogleVoice } from "@mastra/voice-google";
-import { pgMemory, pgQueryTool } from '../config';
+import { pgMemory } from '../config';
 
-const instructions = `
+const instructions1 = `
 You are an AI note assistant tasked with providing concise, structured summaries of their content... // omitted for brevity
 `;
 
 export const noteTakerAgent = new Agent({
   id: "noteTakerAgent",
   name: "Note Taker Agent",
-  instructions: instructions,
+  instructions: instructions1,
   memory: pgMemory,
-  tools: [pgQueryTool],
+//  tools: [],
   model: "google/gemini-2.5-flash-lite-preview-09-2025",
   voice: new GoogleVoice(), // Add OpenAI voice provider with default configuration
 });

src/mastra/agents/weather-agent.ts

@@ -2,7 +2,6 @@ import { Agent } from '@mastra/core/agent';
 import type { RequestContext } from '@mastra/core/request-context'
 import { googleAI, googleAIFlashLite, googleAIPro } from '../config/google';
 import { pgMemory } from '../config/pg-storage';
-import { scorers } from '../scorers/weather-scorer';
 import { mdocumentChunker } from '../tools/document-chunking.tool';
 import { weatherTool } from '../tools/weather-tool';
 import { webScraperTool } from '../tools/web-scraper-tool';
@@ -62,7 +61,7 @@ export const weatherAgent = new Agent({
   scorers: {
 
   },
-  outputProcessors: [new TokenLimiterProcessor(1048576)],
+  outputProcessors: [new TokenLimiterProcessor(128000)],
   memory: pgMemory,
   options: {},
   maxRetries: 5

…/mastra/experiments/agent-experiments.ts src/mastra/evals/agent-experiments.tssrc/mastra/experiments/agent-experiments.ts renamed to src/mastra/evals/agent-experiments.ts src/mastra/experiments/agent-experiments.ts renamed to src/mastra/evals/agent-experiments.ts

@@ -9,22 +9,10 @@ import { evaluationAgent } from '../agents/evaluationAgent'
 import { imageToCsvAgent } from '../agents/image_to_csv'
 import { csvToExcalidrawAgent } from '../agents/csv_to_excalidraw'
 import { weatherAgent } from '../agents/weather-agent'
-import {
-    structureScorer,
-    creativityScorer,
-    sqlValidityScorer,
-    toneConsistencyScorer,
-    responseQualityScorer,
-    scriptFormatScorer,
-    pacingScorer,
-    financialDataScorer,
-    sourceDiversityScorer,
-    csvValidityScorer,
-    factualityScorer
-} from '../scorers'
+import { log } from '../config/logger';
 
 export async function runContentStrategistExperiment() {
-    console.log('Running Content Strategist Experiment...')
+    log.info('Running Content Strategist Experiment', { event: 'Running Content Strategist Experiment' })
     const results = await runEvals({
         target: contentStrategistAgent,
         data: [
@@ -38,14 +26,14 @@ export async function runContentStrategistExperiment() {
                 input: 'Plan a blog series for a B2B SaaS accounting tool. Target audience: CFOs. Tone: Professional and authoritative.'
             }
         ],
-        scorers: [structureScorer, creativityScorer, toneConsistencyScorer]
+        scorers: []
     })
-    console.log('Content Strategist Experiment Results:', JSON.stringify(results, null, 2))
+    log.info('Content Strategist Experiment Results', { results: JSON.stringify(results, null, 2) })
     return results
 }
 
 export async function runCopywriterExperiment() {
-    console.log('Running Copywriter Experiment...')
+    log.info('Running Copywriter Experiment...')
     const results = await runEvals({
         target: copywriterAgent,
         data: [
@@ -59,14 +47,14 @@ export async function runCopywriterExperiment() {
                 input: 'Write a product description for a luxury watch. Tone: Sophisticated and elegant.',
             }
         ],
-        scorers: [toneConsistencyScorer, creativityScorer, responseQualityScorer]
+        scorers: []
     })
-    console.log('Copywriter Experiment Results:', JSON.stringify(results, null, 2))
+    log.info('Copywriter Experiment Results:', { results: JSON.stringify(results, null, 2) })
     return results
 }
 
 export async function runScriptWriterExperiment() {
-    console.log('Running Script Writer Experiment...')
+    log.info('Running Script Writer Experiment...')
     const results = await runEvals({
         target: scriptWriterAgent,
         data: [
@@ -77,14 +65,14 @@ export async function runScriptWriterExperiment() {
                 input: 'Create a YouTube intro for a tech review channel.',
             }
         ],
-        scorers: [scriptFormatScorer, pacingScorer, creativityScorer]
+        scorers: []
     })
-    console.log('Script Writer Experiment Results:', JSON.stringify(results, null, 2))
+    log.info('Script Writer Experiment Results:', { results: JSON.stringify(results, null, 2) })
     return results
 }
 
 export async function runStockAnalysisExperiment() {
-    console.log('Running Stock Analysis Experiment...')
+    log.info('Running Stock Analysis Experiment...')
     const results = await runEvals({
         target: stockAnalysisAgent,
         data: [
@@ -95,14 +83,14 @@ export async function runStockAnalysisExperiment() {
                 input: 'Should I buy TSLA right now?',
             }
         ],
-        scorers: [financialDataScorer, responseQualityScorer, sourceDiversityScorer]
+        scorers: []
     })
-    console.log('Stock Analysis Experiment Results:', JSON.stringify(results, null, 2))
+    log.info('Stock Analysis Experiment Results:', { results: JSON.stringify(results, null, 2) })
     return results
 }
 
 export async function runReportAgentExperiment() {
-    console.log('Running Report Agent Experiment...')
+    log.info('Running Report Agent Experiment...')
     const results = await runEvals({
         target: reportAgent,
         data: [
@@ -113,74 +101,74 @@ export async function runReportAgentExperiment() {
                 input: 'Summarize the key findings from the user research interviews.',
             }
         ],
-        scorers: [structureScorer, responseQualityScorer, factualityScorer]
+        scorers: []
     })
-    console.log('Report Agent Experiment Results:', JSON.stringify(results, null, 2))
+    log.info('Report Agent Experiment Results:', { results: JSON.stringify(results, null, 2) })
     return results
 }
 
 export async function runLearningExtractionExperiment() {
-    console.log('Running Learning Extraction Experiment...')
+    log.info('Running Learning Extraction Experiment...')
     const results = await runEvals({
         target: learningExtractionAgent,
         data: [
             {
                 input: 'Extract key learning points from this article about Rust ownership.'
             }
         ],
-        scorers: [responseQualityScorer, factualityScorer]
+        scorers: []
     })
-    console.log('Learning Extraction Experiment Results:', JSON.stringify(results, null, 2))
-    return results
+        log.info('Learning Extraction Experiment Results:', { results: JSON.stringify(results, null, 2) })
+        return results
 }
 
 export async function runEvaluationAgentExperiment() {
-    console.log('Running Evaluation Agent Experiment...')
+    log.info('Running Evaluation Agent Experiment...')
     const results = await runEvals({
         target: evaluationAgent,
         data: [
             {
                 input: 'Evaluate this python code for efficiency: def fib(n): return n if n < 2 else fib(n-1) + fib(n-2)',
             }
         ],
-        scorers: [responseQualityScorer, structureScorer]
+        scorers: []
     })
-    console.log('Evaluation Agent Experiment Results:', JSON.stringify(results, null, 2))
+    log.info('Evaluation Agent Experiment Results:', { results: JSON.stringify(results, null, 2) })
     return results
 }
 
 export async function runImageToCsvExperiment() {
-    console.log('Running Image to CSV Experiment...')
+    log.info('Running Image to CSV Experiment...')
     const results = await runEvals({
         target: imageToCsvAgent,
         data: [
             {
                 input: 'https://raw.githubusercontent.com/datasciencedojo/datasets/master/titanic.csv',
             }
         ],
-        scorers: [csvValidityScorer, structureScorer]
+        scorers: []
     })
-    console.log('Image to CSV Experiment Results:', JSON.stringify(results, null, 2))
+    log.info('Image to CSV Experiment Results:', { results: JSON.stringify(results, null, 2) })
     return results
 }
 
 export async function runCsvToExcalidrawExperiment() {
-    console.log('Running CSV to Excalidraw Experiment...')
+    log.info('Running CSV to Excalidraw Experiment...')
     const results = await runEvals({
         target: csvToExcalidrawAgent,
         data: [
             {
                 input: 'id,label,x,y\n1,Start,0,0\n2,Process,100,0\n3,End,200,0',
             }
         ],
-        scorers: [structureScorer, responseQualityScorer]
+        scorers: []
     })
-    console.log('CSV to Excalidraw Experiment Results:', JSON.stringify(results, null, 2))
+    log.info('CSV to Excalidraw Experiment Results:', { results: JSON.stringify(results, null, 2) })
     return results
 }
 
 export async function runWeatherAgentExperiment() {
-    console.log('Running Weather Agent Experiment...')
+    log.info('Running Weather Agent Experiment...')
     const results = await runEvals({
         target: weatherAgent,
         data: [
@@ -191,9 +179,9 @@ export async function runWeatherAgentExperiment() {
                 input: 'Forecast for London tomorrow.',
             }
         ],
-        scorers: [factualityScorer, responseQualityScorer]
+        scorers: []
     })
-    console.log('Weather Agent Experiment Results:', JSON.stringify(results, null, 2))
+    log.info('Weather Agent Experiment Results:', { results: JSON.stringify(results, null, 2) })
     return results
 }
 

src/mastra/workflows/changelog.ts

@@ -219,7 +219,7 @@ const stepA1 = createStep({
       id: 'stepA1',
     });
 
-    
+
     return {
       message: combinedChangelog,
     };
@@ -314,7 +314,7 @@ const stepA2 = createStep({
     try {
       const result = await agent.generate(prompt, {
         toolsets: {
-          slack: tools,
+//          slack: tools,
         },
       });
 
@@ -330,7 +330,7 @@ const stepA2 = createStep({
         id: 'stepA2',
       });
 
-      
+
       return {
         message: result.text,
       };
@@ -347,7 +347,7 @@ const stepA2 = createStep({
         id: 'stepA2',
       });
 
-      
+
       return {
         message: e as string,
       };

src/mastra/workflows/content-review-workflow.ts

@@ -126,7 +126,7 @@ const researchTopicStep = createStep({
         })
 
         const prompt = `Research the topic "${inputData.topic}" for a ${inputData.contentType}
-        ${inputData.targetAudience ? `targeting ${inputData.targetAudience}` : ''}.
+        ${inputData.targetAudience !== undefined && inputData.targetAudience !== null && inputData.targetAudience.trim().length > 0 ? `targeting ${inputData.targetAudience}` : ''}.
         Provide a summary, key points, relevant sources, and interesting facts.`;
 
         const stream = await agent.stream(prompt, {
@@ -261,7 +261,7 @@ const draftContentStep = createStep({
 
         Research Summary: ${inputData.research.summary}
         Key Points to Cover: ${inputData.research.keyPoints.join(', ')}
-        ${inputData.targetAudience ? `Target Audience: ${inputData.targetAudience}` : ''}
+        ${inputData.targetAudience !== undefined && inputData.targetAudience !== null && inputData.targetAudience.trim().length > 0 ? `Target Audience: ${inputData.targetAudience}` : ''}
 
         Create engaging, well-structured content.`;
 

src/mastra/workflows/financial-report-workflow.ts

@@ -757,7 +757,7 @@ const analyzeDataStep = createStep({
         }));
       }
 
-      
+
       const result: z.infer<typeof analysisResultSchema> = {
         stocks: inputData.stocks,
         analysis: {

src/mastra/workflows/repo-ingestion-workflow.ts

@@ -98,11 +98,12 @@ const scanStep = createStep({
       );
 
       // Type guard to narrow to the success shape
-      const isScanSuccess = (r: any): r is { success: boolean; tree?: GitTreeItem[]; error?: string } =>
-        (Boolean(r)) && typeof r === 'object' && 'success' in r;
+      const isScanSuccess = (r: unknown): r is { success: boolean; tree?: GitTreeItem[]; error?: string } =>
+        r !== null && typeof r === 'object' && 'success' in r;
 
       if (!isScanSuccess(scanResultRaw) || !scanResultRaw.success || !scanResultRaw.tree) {
-        throw new Error(`Failed to scan GitHub repo: ${(scanResultRaw as any)?.error ?? 'unknown error'}`);
+        const errorMessage = isScanSuccess(scanResultRaw) ? (scanResultRaw.error ?? 'unknown error') : 'unknown error';
+        throw new Error(`Failed to scan GitHub repo: ${errorMessage}`);
       }
 
       // At this point, scanResultRaw.tree is present
@@ -229,7 +230,7 @@ const ingestStep = createStep({
             }
 
             const successResult = result as { success: boolean; content?: string; encoding?: string; sha?: string; size?: number; error?: string };
-            if (!successResult.success || !successResult.content) {
+            if (!successResult.success || successResult.content === null || successResult.content === undefined || successResult.content === '') {
               throw new Error(`Failed to fetch file from GitHub: ${successResult.error}`);
             }
             content = successResult.content;