# Real-Time Crypto News Aggregation Intelligence API 🚀 The latest crypto news aggregated, tagged and analysed for impact and relevancy from over 50 different news sources in real-time as they happen. We transform raw cryptocurrency news into actionable trading intelligence with our AI-powered analysis API. Get real-time market sentiment, impact scoring, and bull/bear signals to make informed investment decisions. ## 🌟 Why Choose our API? - **⚡ Real-time Processing**: News analyzed and delivered within seconds of publication - **🧠 AI-Powered Intelligence**: Advanced sentiment analysis with comprehensive market impact scoring - **📊 Market Impact Scoring**: Quantified relevance ratings (0-1 scale) for every news piece - **🎯 Signal Generation**: Clear bull/bear indicators for trading strategies - **🔄 Live Updates**: WebSocket support for instant notifications - **📱 Developer-Friendly**: Clean JSON responses with comprehensive data structure ## 🚀 Quick Start ### 1. Authentication ```javascript const headers = { 'X-RapidAPI-Key': 'YOUR_API_KEY', 'X-RapidAPI-Host': 'YOUR_RAPIDAPI_HOST' }; ``` ### 2. Your First Request ```javascript fetch('/api/news?limit=5', { headers }) .then(response => response.json()) .then(data => console.log(data)); ``` ### 3. Sample Response ```json { "items": [ { "_id": "507f1f77bcf86cd799439011", "title": "Bitcoin ETF Approval Leads to Market Rally", "link": "https://example.com/bitcoin-etf-approval", "description": "Major cryptocurrency ETF gets regulatory approval...", "content": "Full article content...", "markdownContent": "**Bitcoin ETF Approval** leads to...", "plainText": "Bitcoin ETF Approval leads to increased institutional investment...", "pubDate": "2024-01-15T10:30:00Z", "categories": ["Cryptocurrency", "Regulation"], "tags": ["bitcoin", "etf", "regulation"], "author": "John Doe", "imageUrl": "https://example.com/image.jpg", "isBull": true, "source": { "_id": "507f1f77bcf86cd799439012", "domain": "cryptonews.com", "websiteTitle": "Crypto News" }, "analysis": { "summary": "Bitcoin ETF approval leads to increased institutional investment and market optimism.", "marketImpactScore": 0.9, "cryptoRelevanceScore": 1.0, "sentimentScore": 0.8, "tags": ["bullish_prediction", "etfs", "market_situation"] } } ], "pagination": { "total": 1250, "page": 1, "limit": 10, "hasMore": true } } ``` ## 📋 API Endpoints ### 🔥 Live News Feed ``` GET /api/news ``` Retrieve paginated live cryptocurrency news items with real-time sentiment analysis. News items are sorted by publication date (newest first). **Parameters:** - `page` (optional): Page number for pagination (starts from 1, default: 1) - `limit` (optional): Number of items per page (1-50, default: 10) ### 📈 Top Impact News ``` GET /api/top-news ``` Retrieve top cryptocurrency news items based on market impact, crypto relevance, and sentiment scores. News items are ranked by a composite relevance score and filtered by time interval. **Parameters:** - `interval` (required): Time interval for news filtering - `6h` - Last 6 hours - `24h` - Last 24 hours - `7d` - Last 7 days ### 🎯 Bull/Bear Sentiment Analysis ``` GET /api/bulls-bears ``` Retrieve cryptocurrency news items categorized by bull/bear sentiment with market impact filtering. Only includes news items with high market impact scores (≥0.8). **Parameters:** - `interval` (required): Time interval for news filtering (`6h`, `24h`, `7d`) **Response includes:** - `bullNews`: Array of bullish news items (sentiment score > 0) - `bearNews`: Array of bearish news items (sentiment score ≤ 0) - `totalBullCount`: Total count of bullish news items in the time period - `totalBearCount`: Total count of bearish news items in the time period ### 🔍 System Health Check ``` GET /api/status ``` Simple health check endpoint to verify API and database connectivity. Returns system status, uptime, and service health information. **Example Response:** ```json { "status": "healthy", "timestamp": "2024-01-15T10:30:00Z", "version": "1.0.0", "services": { "database": "connected", "api": "running" }, "uptime": 3600.5, "environment": "production" } ``` ## 📊 Data Structure Deep Dive ### News Item Object Every news article contains comprehensive metadata and AI analysis: ```typescript interface NewsItem { _id: string; // Unique identifier title: string; // Article headline link: string; // Original article URL description: string; // Article summary content?: string; // Full HTML content markdownContent?: string; // Markdown formatted content plainText?: string; // Plain text version pubDate: string; // Publication timestamp (ISO 8601) categories: string[]; // News categories tags: string[]; // Keywords/tags author?: string; // Article author imageUrl?: string; // Featured image URL isBull: boolean; // Bull/bear signal source: NewsSource; // Source information analysis: NewsAnalysis; // AI analysis results publishedAt?: string; // Real-time feed timestamp } ``` ### AI Analysis Object Our proprietary AI analysis provides multiple scoring dimensions: ```typescript interface NewsAnalysis { summary: string; // AI-generated summary marketImpactScore: number; // 0-1 scale (market impact) cryptoRelevanceScore: number; // 0-1 scale (crypto relevance) sentimentScore: number; // -1 to 1 (bearish to bullish) tags: AnalysisTag[]; // Categorization tags } type AnalysisTag = | "bearish_prediction" | "bullish_prediction" | "market_situation" | "new_coins" | "coin_pump" | "coin_dump" | "innovation" | "new_product" | "regulation" | "earnings_staking" | "large_purchase" | "large_sell" | "whale_movement" | "etfs"; ``` ### News Source Information ```typescript interface NewsSource { _id: string; // Source identifier domain: string; // Source domain websiteTitle: string; // Source name websiteUrl?: string; // Source homepage contentSourceType?: string; // "rss" | "crawler" | "unknown" isActive?: boolean; // Source status } ``` ## 💡 Use Cases & Examples ### 🤖 Trading Bot Integration ```python import requests import json class Client: def __init__(self, api_key, host): self.headers = { "X-RapidAPI-Key": api_key, "X-RapidAPI-Host": host } self.base_url = "/api" def get_bullish_signals(self, interval="24h", min_impact=0.8): """Get high-impact bullish news for trading signals""" response = requests.get( f"{self.base_url}/bulls-bears?interval={interval}", headers=self.headers ) data = response.json() # Filter by minimum impact score high_impact_bulls = [ article for article in data['bullNews'] if article['analysis']['marketImpactScore'] >= min_impact ] return { 'signals': high_impact_bulls, 'count': len(high_impact_bulls), 'market_sentiment': 'BULLISH' if data['totalBullCount'] > data['totalBearCount'] else 'BEARISH' } def monitor_market_sentiment(self, interval="6h"): """Monitor overall market sentiment trends""" response = requests.get( f"{self.base_url}/bulls-bears?interval={interval}", headers=self.headers ) data = response.json() bull_ratio = data['totalBullCount'] / (data['totalBullCount'] + data['totalBearCount']) return { 'bull_ratio': bull_ratio, 'sentiment': 'BULLISH' if bull_ratio > 0.6 else 'BEARISH' if bull_ratio < 0.4 else 'NEUTRAL', 'confidence': abs(bull_ratio - 0.5) * 2 # 0-1 confidence score } # Usage example client = Client("YOUR_API_KEY", "YOUR_RAPIDAPI_HOST") signals = client.get_bullish_signals(interval="24h", min_impact=0.9) print(f"Found {signals['count']} high-impact bullish signals") ``` ### 📱 React Dashboard Component ```javascript import React, { useState, useEffect } from 'react'; const CryptoNewsDashboard = () => { const [topNews, setTopNews] = useState([]); const [sentiment, setSentiment] = useState(null); const [loading, setLoading] = useState(true); const API_HEADERS = { 'X-RapidAPI-Key': process.env.REACT_APP_API_KEY, 'X-RapidAPI-Host': process.env.REACT_APP_RAPIDAPI_HOST }; useEffect(() => { const fetchData = async () => { try { // Fetch top news const newsResponse = await fetch( '/api/top-news?interval=24h', { headers: API_HEADERS } ); const newsData = await newsResponse.json(); setTopNews(newsData.items.slice(0, 5)); // Fetch sentiment analysis const sentimentResponse = await fetch( '/api/bulls-bears?interval=24h', { headers: API_HEADERS } ); const sentimentData = await sentimentResponse.json(); const totalNews = sentimentData.totalBullCount + sentimentData.totalBearCount; const bullishPercentage = (sentimentData.totalBullCount / totalNews) * 100; setSentiment({ bullish: sentimentData.totalBullCount, bearish: sentimentData.totalBearCount, bullishPercentage: bullishPercentage.toFixed(1), trend: bullishPercentage > 60 ? 'BULLISH' : bullishPercentage < 40 ? 'BEARISH' : 'NEUTRAL' }); setLoading(false); } catch (error) { console.error('Error fetching data:', error); setLoading(false); } }; fetchData(); const interval = setInterval(fetchData, 300000); // Refresh every 5 minutes return () => clearInterval(interval); }, []); if (loading) return

Loading crypto intelligence...

; return (

Market Sentiment (24h)

{sentiment.trend} {sentiment.bullishPercentage}% Bullish

🐂 {sentiment.bullish} Bullish

🐻 {sentiment.bearish} Bearish

Top Impact News

{topNews.map((article) => (

{article.title}

{article.source.websiteTitle} {new Date(article.pubDate).toLocaleDateString()}

<label>Impact:</label>

{(article.analysis.marketImpactScore * 100).toFixed(0)}%

<label>Sentiment:</label>

{article.isBull ? '🐂 BULL' : '🐻 BEAR'}

{(article.analysis.sentimentScore * 100).toFixed(0)}%

{article.analysis.summary}

{article.analysis.tags.map((tag) => ( {tag.replace('_', ' ')} ))}

))}

); }; export default CryptoNewsDashboard; ``` ### 📊 Portfolio Risk Assessment ```javascript class PortfolioRiskAnalyzer { constructor(apiKey, host) { this.apiKey = apiKey; this.host = host; this.baseUrl = '/api'; } async assessPortfolioRisk(holdings, timeframe = '24h') { const riskFactors = []; const opportunities = []; // Get current market sentiment const sentimentData = await this.fetchSentiment(timeframe); const topNews = await this.fetchTopNews(timeframe); // Analyze overall market conditions const marketRisk = this.calculateMarketRisk(sentimentData); // Check for specific risks in news for (const article of topNews.items) { const risk = this.analyzeNewsRisk(article, holdings); if (risk.level !== 'LOW') { riskFactors.push(risk); } const opportunity = this.analyzeNewsOpportunity(article, holdings); if (opportunity.potential > 0.7) { opportunities.push(opportunity); } } return { overallRisk: marketRisk, specificRisks: riskFactors, opportunities: opportunities, recommendations: this.generateRecommendations(marketRisk, riskFactors, opportunities) }; } async fetchSentiment(timeframe) { const response = await fetch( ```${this.baseUrl}/bulls-bears?interval=${timeframe}```, { headers: { 'X-RapidAPI-Key': this.apiKey, 'X-RapidAPI-Host': this.host } } ); return response.json(); } async fetchTopNews(timeframe) { const response = await fetch( ```${this.baseUrl}/top-news?interval=${timeframe}```, { headers: { 'X-RapidAPI-Key': this.apiKey, 'X-RapidAPI-Host': this.host } } ); return response.json(); } calculateMarketRisk(sentimentData) { const totalNews = sentimentData.totalBullCount + sentimentData.totalBearCount; const bearishRatio = sentimentData.totalBearCount / totalNews; let riskLevel = 'LOW'; let riskScore = bearishRatio; if (bearishRatio > 0.7) { riskLevel = 'HIGH'; } else if (bearishRatio > 0.5) { riskLevel = 'MEDIUM'; } return { level: riskLevel, score: riskScore, bearishNews: sentimentData.totalBearCount, bullishNews: sentimentData.totalBullCount, sentiment: bearishRatio > 0.6 ? 'BEARISH' : bearishRatio < 0.4 ? 'BULLISH' : 'NEUTRAL' }; } analyzeNewsRisk(article, holdings) { const relevantTags = ['regulation', 'large_sell', 'bearish_prediction', 'coin_dump']; const hasRiskTags = article.analysis.tags.some(tag => relevantTags.includes(tag)); if (!hasRiskTags || article.analysis.marketImpactScore < 0.7) { return { level: 'LOW', score: 0 }; } // Check if news affects portfolio holdings const affectedHoldings = holdings.filter(holding => article.tags.some(tag => tag.toLowerCase().includes(holding.toLowerCase()) || article.title.toLowerCase().includes(holding.toLowerCase()) ) ); let riskLevel = 'MEDIUM'; if (article.analysis.marketImpactScore > 0.9 && article.analysis.sentimentScore < -0.5) { riskLevel = 'HIGH'; } return { level: riskLevel, score: article.analysis.marketImpactScore * Math.abs(article.analysis.sentimentScore), article: { title: article.title, link: article.link, impact: article.analysis.marketImpactScore, sentiment: article.analysis.sentimentScore }, affectedHoldings, reason: ```${article.analysis.tags.join(', ')} detected with high market impact``` }; } analyzeNewsOpportunity(article, holdings) { const opportunityTags = ['bullish_prediction', 'innovation', 'large_purchase', 'coin_pump']; const hasOpportunityTags = article.analysis.tags.some(tag => opportunityTags.includes(tag)); if (!hasOpportunityTags || article.analysis.sentimentScore < 0.5) { return { potential: 0 }; } return { potential: article.analysis.marketImpactScore * article.analysis.sentimentScore, article: { title: article.title, link: article.link, impact: article.analysis.marketImpactScore, sentiment: article.analysis.sentimentScore }, tags: article.analysis.tags, reason: ```Strong bullish signals detected: ${article.analysis.tags.join(', ')}``` }; } generateRecommendations(marketRisk, risks, opportunities) { const recommendations = []; if (marketRisk.level === 'HIGH') { recommendations.push({ type: 'RISK_MANAGEMENT', priority: 'HIGH', action: 'Consider reducing position sizes or implementing stop-losses', reason: ```High market bearish sentiment detected (${marketRisk.bearishNews} bearish vs ${marketRisk.bullishNews} bullish news)``` }); } if (risks.length > 3) { recommendations.push({ type: 'PORTFOLIO_REVIEW', priority: 'MEDIUM', action: 'Review portfolio diversification', reason: ```Multiple risk factors detected across ${risks.length} news items``` }); } if (opportunities.length > 0) { const topOpportunity = opportunities.reduce((max, opp) => opp.potential > max.potential ? opp : max ); recommendations.push({ type: 'OPPORTUNITY', priority: 'MEDIUM', action: 'Consider strategic position increases', reason: ```Strong bullish signals detected: ${topOpportunity.reason}```, relatedNews: topOpportunity.article }); } return recommendations; } } // Usage example const analyzer = new PortfolioRiskAnalyzer('YOUR_API_KEY', 'YOUR_RAPIDAPI_HOST'); const portfolio = ['BTC', 'ETH', 'ADA', 'DOT']; analyzer.assessPortfolioRisk(portfolio, '24h') .then(assessment => { console.log('Portfolio Risk Assessment:', assessment); // Display high-priority recommendations assessment.recommendations .filter(rec => rec.priority === 'HIGH') .forEach(rec => { console.log(```⚠️ ${rec.action}: ${rec.reason}```); }); }); ``` ## ⚡ Rate Limiting & Performance ### Rate Limits Please be mindful of request frequency to ensure optimal performance for all users. The API implements intelligent rate limiting based on usage patterns. **Best Practices:** - Cache responses when possible (news data is updated every few seconds) - Use appropriate `limit` parameters to avoid over-fetching - Implement exponential backoff for error handling - Consider WebSocket connections for real-time updates instead of polling ### Performance Optimization Tips 1. **Efficient Pagination** ```javascript // Good: Fetch only what you need const response = await fetch('/api/news?limit=20&page=1'); // Avoid: Over-fetching data const response = await fetch('/api/news?limit=100'); // Unless you need all 100 ``` 2. **Smart Caching Strategy** ```javascript class Cache { constructor(ttl = 300000) { // 5 minutes default TTL this.cache = new Map(); this.ttl = ttl; } async get(key, fetchFunction) { const cached = this.cache.get(key); if (cached && Date.now() - cached.timestamp < this.ttl) { return cached.data; } const data = await fetchFunction(); this.cache.set(key, { data, timestamp: Date.now() }); return data; } } const cache = new Cache(); const topNews = await cache.get('top-news-24h', () => fetch('/api/top-news?interval=24h').then(r => r.json()) ); ``` 3. **Error Handling & Retries** ```javascript async function fetchWithRetry(url, options, maxRetries = 3) { for (let i = 0; i < maxRetries; i++) { try { const response = await fetch(url, options); if (response.status === 429) { // Rate limited const delay = Math.pow(2, i) * 1000; // Exponential backoff await new Promise(resolve => setTimeout(resolve, delay)); continue; } if (!response.ok) { throw new Error(```HTTP ${response.status}: ${response.statusText}```); } return await response.json(); } catch (error) { if (i === maxRetries - 1) throw error; const delay = Math.pow(2, i) * 1000; await new Promise(resolve => setTimeout(resolve, delay)); } } } ``` ## 🔧 Error Handling The API returns standard HTTP status codes and structured error responses: ### Common Error Responses **400 Bad Request** ```json { "error": "Invalid time interval. Must be one of: 6h, 24h, 7d" } ``` **429 Too Many Requests** ```json { "error": "Rate limit exceeded. Please try again later.", "retryAfter": 60 } ``` **500 Internal Server Error** ```json { "error": "Internal server error. Please try again later." } ``` ### Error Handling Best Practices ```javascript async function handleApiCall(url, options) { try { const response = await fetch(url, options); if (!response.ok) { const errorData = await response.json(); switch (response.status) { case 400: throw new Error(```Invalid request: ${errorData.error}```); case 429: throw new Error(```Rate limited. Retry after ${errorData.retryAfter} seconds```); case 500: throw new Error('Service temporarily unavailable'); default: throw new Error(```API error: ${errorData.error}```); } } return await response.json(); } catch (error) { console.error('API call failed:', error.message); throw error; } } ``` ## 🚀 Getting Started Checklist - [ ] Sign up for RapidAPI account - [ ] Subscribe to our API plan - [ ] Get your API key from RapidAPI dashboard - [ ] Test connection with `/api/status` endpoint - [ ] Fetch your first news with `/api/news` - [ ] Explore sentiment analysis with `/api/bulls-bears` - [ ] Implement error handling and rate limiting - [ ] Set up caching for production use - [ ] Consider WebSocket integration for real-time updates and contact us for access ## 📞 Support & Community - **GitHub**: [https://github.com/degola](https://github.com/degola) - **Issues**: Report bugs and feature requests via GitHub Issues - **License**: MIT License - see [LICENSE](https://opensource.org/licenses/MIT) --- **Ready to transform your crypto trading with intelligent news analysis?** Start building with our API today! 🚀