API Documentation

// Browser JavaScript WebSocket Example
const API_KEY = 'YOUR_API_KEY';
const WATCHLIST = ['AAPL', 'TSLA', 'NVDA', 'MSFT'];

const ws = new WebSocket(`wss://ws.rtpr.io?apiKey=${API_KEY}`);

ws.onopen = () => {
  console.log('✅ Connected to RTPR real-time feed');
};

ws.onmessage = (event) => {
  const message = JSON.parse(event.data);
  
  switch (message.type) {
    case 'connected':
      console.log('🟢 ' + message.message);
      // Subscribe to your watchlist after connecting
      ws.send(JSON.stringify({
        action: 'subscribe',
        tickers: WATCHLIST
      }));
      break;
    
    case 'subscribed':
      console.log('📋 Subscribed to:', message.tickers.join(', '));
      break;
      
    case 'article':
      const article = message.data;
      console.log('📰 NEW ARTICLE:', article.ticker);
      console.log('   Title:', article.title);
      console.log('   Source:', article.author);
      console.log('   Time:', article.created);
      
      // Process the article (e.g., trigger trading logic)
      processArticle(article);
      break;
      
    case 'ping':
      // Respond to keep connection alive
      ws.send(JSON.stringify({ type: 'pong' }));
      break;
      
    case 'error':
      console.error('❌ Error:', message.message);
      break;
  }
};

ws.onerror = (error) => {
  console.error('WebSocket error:', error);
};

ws.onclose = (event) => {
  console.log('🔌 Connection closed. Reconnecting in 5s...');
  setTimeout(() => reconnect(), 5000);
};

function processArticle(article) {
  // Your trading logic here
  console.log('🍎 Processing:', article.ticker, '-', article.title);
}

// Add a new ticker to your subscription at any time
function addTicker(ticker) {
  ws.send(JSON.stringify({
    action: 'subscribe',
    tickers: [ticker]
  }));
}