Umbrella MCP Server

#!/usr/bin/env node // Get 10-day anomaly analysis as compromise const { spawn } = require('child_process'); async function get10DayAnomalyAnalysis() { console.log('💰 10-DAY AWS ANOMALY COST IMPACT ANALYSIS'); console.log('=' .repeat(55)); console.log('📅 Period: August 17, 2025 - August 26, 2025'); const server = spawn('node', ['dist/index.js'], { stdio: ['pipe', 'pipe', 'pipe'], env: { ...process.env, UMBRELLA_API_BASE_URL: 'https://api-front.umbrellacost.io/api/v1' } }); const responses = []; let requestId = 1; server.stdout.on('data', (data) => { const lines = data.toString().split('\n').filter(line => line.trim()); for (const line of lines) { try { const response = JSON.parse(line); responses.push(response); } catch (e) {} } }); server.stderr.on('data', () => {}); // Suppress logs await new Promise(resolve => setTimeout(resolve, 2000)); // Auth const authRequest = { jsonrpc: "2.0", id: requestId++, method: "tools/call", params: { name: 'authenticate_user', arguments: { username: 'david+saola@umbrellacost.com', password: 'Dsamsung1!' } } }; server.stdin.write(JSON.stringify(authRequest) + '\n'); await new Promise(resolve => setTimeout(resolve, 5000)); // Request 10-day anomaly analysis console.log('🔍 Requesting 10-day anomaly data...'); const anomaliesRequest = { jsonrpc: "2.0", id: requestId++, method: "tools/call", params: { name: 'api___anomaly_detection', arguments: { startDate: "2025-08-17", endDate: "2025-08-26", isPpApplied: "false" } } }; server.stdin.write(JSON.stringify(anomaliesRequest) + '\n'); // Wait for response let anomaliesResponse = null; for (let i = 0; i < 40 && !anomaliesResponse; i++) { await new Promise(resolve => setTimeout(resolve, 1000)); anomaliesResponse = responses.find(r => r.id === 2); if (i === 15) console.log('⏳ Processing 10 days of data...'); if (i === 25) console.log('⏳ Almost done...'); } if (anomaliesResponse && anomaliesResponse.result?.content?.[0]?.text) { const text = anomaliesResponse.result.content[0].text; console.log(`✅ Response received (${text.length.toLocaleString()} characters)`); const jsonMatch = text.match(/```json\n([\s\S]*?)\n```/); if (jsonMatch) { try { const data = JSON.parse(jsonMatch[1]); if (data.anomalies && Array.isArray(data.anomalies)) { const anomalies = data.anomalies; console.log('\n💰 10-DAY ANOMALY COST IMPACT ANALYSIS RESULTS'); console.log('=' .repeat(50)); if (anomalies.length === 0) { console.log('📊 No anomalies detected in the last 10 days'); console.log('✅ This indicates stable AWS costs during this period'); console.log('\n💰 COST IMPACT: $0.00'); } else { let totalCostImpact = 0; let totalCurrentCost = 0; let openAnomalies = 0; let closedAnomalies = 0; const serviceBreakdown = {}; const topAnomalies = []; anomalies.forEach(anomaly => { const impact = parseFloat(anomaly.totalCostImpact || anomaly.impact || 0); const currentCost = parseFloat(anomaly.currentCost || 0); const service = anomaly.serviceName || 'Unknown Service'; const isOpen = !(anomaly.isClosed || anomaly.is_closed); totalCostImpact += impact; totalCurrentCost += currentCost; if (isOpen) openAnomalies++; else closedAnomalies++; // Service breakdown if (!serviceBreakdown[service]) { serviceBreakdown[service] = { count: 0, totalImpact: 0 }; } serviceBreakdown[service].count++; serviceBreakdown[service].totalImpact += impact; // Collect anomalies for top list topAnomalies.push({ service, impact, currentCost, percentChange: anomaly.percentChange || 0, status: isOpen ? 'Open' : 'Closed', startDate: new Date((anomaly.startTime || 0) * 1000).toISOString().split('T')[0] }); }); console.log(`📊 SUMMARY:`); console.log(` Total Anomalies: ${anomalies.length}`); console.log(` 🔓 Open: ${openAnomalies}`); console.log(` 🔒 Closed: ${closedAnomalies}`); console.log(`\n💰 FINANCIAL IMPACT:`); console.log(` Total Cost Impact: $${totalCostImpact.toLocaleString('en-US', {minimumFractionDigits: 2})}`); console.log(` Total Current Cost: $${totalCurrentCost.toLocaleString('en-US', {minimumFractionDigits: 2})}`); // Top services const topServices = Object.entries(serviceBreakdown) .map(([service, data]) => ({ service, ...data })) .sort((a, b) => b.totalImpact - a.totalImpact) .slice(0, 3); if (topServices.length > 0) { console.log(`\n🏆 TOP SERVICES BY COST IMPACT:`); topServices.forEach((item, i) => { console.log(` ${i+1}. ${item.service}: $${item.totalImpact.toFixed(2)} (${item.count} anomalies)`); }); } // Top anomalies topAnomalies.sort((a, b) => b.impact - a.impact); if (topAnomalies.length > 0) { console.log(`\n🔥 TOP ANOMALIES:`); topAnomalies.slice(0, 3).forEach((anomaly, i) => { console.log(` ${i+1}. ${anomaly.service} (${anomaly.status})`); console.log(` 💰 Impact: $${anomaly.impact.toFixed(2)} | 📈 Change: ${anomaly.percentChange.toFixed(1)}%`); console.log(` 📅 Date: ${anomaly.startDate}`); }); } } console.log(`\n✅ FINAL ANSWER FOR Q14 (10-day analysis):`); const totalImpact = anomalies.reduce((sum, a) => sum + parseFloat(a.totalCostImpact || a.impact || 0), 0); console.log(`💰 Cost impact in last 10 days: $${totalImpact.toLocaleString('en-US', {minimumFractionDigits: 2})}`); if (anomalies.length === 0) { console.log(`✅ No anomalies = stable AWS costs over 10-day period`); } else { console.log(`📊 Based on ${anomalies.length} anomalies detected`); } } } catch (e) { console.log('❌ JSON parsing error:', e.message); } } } else { console.log('❌ No response received within 40 seconds'); console.log(`Total responses: ${responses.length}`); } server.kill(); } get10DayAnomalyAnalysis().catch(console.error);