ibex35-mcp

Instructions

Implementation Reference

• src/analytics.ts:361-425 (handler)

  The primary handler function for the 'analyze_trends' tool. It processes different analysis types ('company_trend', 'sector_trend', 'market_trend', 'correlation_analysis') by fetching relevant data from the database, performing calculations, and optionally generating forecasts.
  async analyzeTrends(analysisType: string, target: string, period: number = 30, includeForecast: boolean = false): Promise<any> { try { const analysis = { analysis_type: analysisType, target: target, period_days: period, timestamp: new Date().toISOString(), trend_data: null, forecast: null, insights: [] }; switch (analysisType) { case 'company_trend': const company = await this.db.getCompanyBySymbol(target); if (!company) throw new Error(`Company ${target} not found`); const historical = await this.db.getHistoricalPrices(company.id, period); analysis.trend_data = this.analyzePriceTrend(historical); analysis.insights = this.generateTrendInsights(analysis.trend_data, company); if (includeForecast) { analysis.forecast = this.generateSimpleForecast(historical); } break; case 'sector_trend': const sectorCompanies = await this.db.getCompaniesBySector(target); const sectorPerformance = await this.analyzeCompanyPerformances(sectorCompanies, period); analysis.trend_data = { sector: target, companies_analyzed: sectorCompanies.length, average_performance: sectorPerformance.reduce((sum, p) => sum + (p.period_change || 0), 0) / sectorPerformance.length, best_performer: sectorPerformance[0], worst_performer: sectorPerformance[sectorPerformance.length - 1], volatility_measure: this.calculateSectorVolatility(sectorPerformance) }; break; case 'market_trend': const allCompanies = await this.db.getAllCompanies(); const marketPerformance = await this.analyzeCompanyPerformances(allCompanies.slice(0, 20), period); // Limit for performance analysis.trend_data = { market: 'IBEX 35', companies_analyzed: marketPerformance.length, market_direction: this.determineMarketDirection(marketPerformance), sector_performance: await this.getSectorCorrelationAnalysis(period), volatility_index: this.calculateMarketVolatility(marketPerformance) }; break; case 'correlation_analysis': const correlationData = await this.getSectorCorrelationAnalysis(period); analysis.trend_data = { ...correlationData, correlation_insights: this.generateCorrelationInsights(correlationData) }; break; } return analysis; } catch (error) { throw new Error(`Trend analysis failed: ${error}`); } }
• src/index.ts:406-433 (registration)

  Registration of the 'analyze_trends' tool in the MCP server's tool list, including its name, description, and input schema.
  name: 'analyze_trends', description: 'Analyze trends in stock prices, market performance, or sector movements over time', inputSchema: { type: 'object', properties: { analysis_type: { type: 'string', enum: ['company_trend', 'sector_trend', 'market_trend', 'correlation_analysis'], description: 'Type of trend analysis to perform', }, target: { type: 'string', description: 'Company symbol, sector name, or "market" for overall analysis', }, period: { type: 'number', description: 'Number of days to analyze', default: 30, }, include_forecast: { type: 'boolean', description: 'Whether to include simple trend forecast', default: false, }, }, required: ['analysis_type', 'target'], }, },
• src/index.ts:665-672 (handler)

  Dispatch handler in the main server that routes 'analyze_trends' tool calls to the AnalyticsManager's analyzeTrends method.
  case 'analyze_trends': result = await this.analytics.analyzeTrends( (args as any)?.analysis_type, (args as any)?.target, (args as any)?.period || 30, (args as any)?.include_forecast || false ); break;