alphaIntelligence_newsSentiments
Fetch market news and sentiment data for specific stocks, crypto, or forex symbols, filtered by topics and time periods to analyze financial market sentiment.
Instructions
Fetches market news and sentiment data from Alpha Vantage.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| tickersList | No | List of stock/crypto/forex symbols (e.g., ["AAPL", "GOOGL"]). | |
| topics | No | Specific topics to filter news for (e.g., "technology", "earnings"). | |
| time_from | No | Start time for news articles (YYYYMMDDTHHMM format). | |
| time_to | No | End time for news articles (YYYYMMDDTHHMM format). | |
| sort | No | Sort order for results. | LATEST |
| limit | No | Number of results to return (1-1000). |
Implementation Reference
- src/index.ts:38-115 (handler)Core handler function that executes all AVantage-based MCP tools, including alphaIntelligence_newsSentiments. Manages API key resolution, AVantage client lifecycle via resourceManager, invokes the specific library method, handles errors, and returns JSON data.async function executeAvantageTool<TArgs, TResult>( toolName: string, args: TArgs, context: Context<Record<string, unknown> | undefined>, // Use the imported Context type directly avantageMethod: ( av: AVantage, args: TArgs ) => Promise<{ error?: boolean; reason?: string; data?: TResult }> ): Promise<string> { logger.info(`Executing '${toolName}' tool for request ID: ${context}`); logger.debug(`Args for ${toolName}: ${JSON.stringify(args)}`); // --- Authentication & Resource Management --- // Access extraArgs safely - it might be null or undefined const extraArgsApiKey = context.extraArgs?.apiKey as string | undefined; const apiKey = extraArgsApiKey || config.apiKey; if (!apiKey) { logger.error(`'${toolName}' failed: Alpha Vantage API key missing.`); throw new UserError(apiKeyErrorMessage); } logger.debug( `Using AV API key (source: ${extraArgsApiKey ? "extraArgs" : "environment"}) for ${toolName}` ); try { // Get or create AVantage instance managed by ResourceManager const av = await resourceManager.getResource<AVantage>( apiKey, // Cache key is the resolved API key "avantage_client", // Type identifier for logging async (key) => { // Factory Function logger.info( `Creating new AVantage instance for key ending ...${key.slice(-4)}` ); // AVantage library reads AV_PREMIUM from process.env internally return new AVantage(key); }, async (avInstance) => { // Cleanup Function (no-op needed for AVantage) logger.debug(`Destroying AVantage instance (no-op)`); } ); // --- Library Call --- const result = await avantageMethod(av, args); // --- Response Handling --- if (result.error) { logger.warn( `'${toolName}' failed. Reason from avantage: ${result.reason}` ); throw new UserError(result.reason || `Tool '${toolName}' failed.`); } if (result.data === undefined || result.data === null) { logger.warn(`'${toolName}' completed successfully but returned no data.`); return "null"; // Return string "null" for empty data } logger.info(`'${toolName}' completed successfully.`); // Stringify the data part of the response return JSON.stringify(result.data); } catch (error: any) { logger.error( `Error during execution of '${toolName}': ${error.message}`, error ); // If it's already a UserError, rethrow it if (error instanceof UserError) { throw error; } // Otherwise, wrap it in a UserError throw new UserError( `An unexpected error occurred while executing tool '${toolName}': ${error.message}` ); } }
- src/schemas.ts:12-19 (schema)Zod schema defining the input parameters for the alphaIntelligence_newsSentiments tool, including optional tickers, topics, time range, sort order, and limit.export const NewsSentimentsParamsSchema = z.object({ tickersList: z.array(z.string()).optional().describe('List of stock/crypto/forex symbols (e.g., ["AAPL", "GOOGL"]).'), topics: z.string().optional().describe('Specific topics to filter news for (e.g., "technology", "earnings").'), time_from: z.string().optional().describe('Start time for news articles (YYYYMMDDTHHMM format).'), time_to: z.string().optional().describe('End time for news articles (YYYYMMDDTHHMM format).'), sort: z.enum(['LATEST', 'EARLIEST', 'RELEVANCE']).default('LATEST').optional().describe('Sort order for results.'), limit: z.number().int().min(1).max(1000).default(50).optional().describe('Number of results to return (1-1000).'), }).describe('Parameters for fetching market news and sentiment data.')
- src/index.ts:121-136 (registration)Registers the MCP tool 'alphaIntelligence_newsSentiments' on the FastMCP server, linking the schema, description, and specific execution logic that calls the AVantage library's newsSentiments method via the generic handler.// --- Alpha Intelligence Tools --- server.addTool({ name: "alphaIntelligence_newsSentiments", description: "Fetches market news and sentiment data from Alpha Vantage.", parameters: schemas.NewsSentimentsParamsSchema, execute: ( args, context // Let type be inferred ) => executeAvantageTool( "alphaIntelligence_newsSentiments", args, context, (av, params) => av.alphaIntelligence.newsSentiments(params) ), });