WebSocket API Documentation

import websocket
import json

token = 'YOUR_AUTH_TOKEN'
ws_url = f'wss://dev.stocknews.live/ws?token={token}'

def on_message(ws, message):
    data = json.loads(message)
    
    if data['type'] == 'connected':
        print('Authenticated:', data['subscription'])
    elif data['type'] == 'news':
        news = data['data']
        print(f"News for {news['ticker']}: {news['sentimentLabel']}")
        print(f"Summary: {news['summary']}")
        print(f"Price: {news['priceFormatted']}")
        
        # Process the news data
        handle_news_update(news)

def on_error(ws, error):
    print('WebSocket error:', error)

def on_close(ws):
    print('Connection closed')

def on_open(ws):
    print('Connected to StockNews WebSocket')

def handle_news_update(news):
    # Your custom logic here
    if news['sentimentScore'] > 0.7:
        print('Bullish signal detected!')

ws = websocket.WebSocketApp(
    ws_url,
    on_message=on_message,
    on_error=on_error,
    on_close=on_close,
    on_open=on_open
)

ws.run_forever()

<?php
use Ratchet\Client\WebSocket;
use React\EventLoop\Factory;

require __DIR__ . '/vendor/autoload.php';

$token = 'YOUR_AUTH_TOKEN';
$wsUrl = "wss://dev.stocknews.live/ws?token={$token}";

$loop = Factory::create();

\Ratchet\Client\connect($wsUrl, [], [], $loop)
    ->then(function(WebSocket $conn) {
        echo "Connected to StockNews WebSocket\n";
        
        $conn->on('message', function($msg) use ($conn) {
            $data = json_decode($msg, true);
            
            if ($data['type'] === 'connected') {
                echo "Authenticated: " . json_encode($data['subscription']) . "\n";
            } elseif ($data['type'] === 'news') {
                $news = $data['data'];
                echo "News for {$news['ticker']}: {$news['sentimentLabel']}\n";
                echo "Summary: {$news['summary']}\n";
                echo "Price: {$news['priceFormatted']}\n";
                
                // Process the news data
                handleNewsUpdate($news);
            }
        });
        
        $conn->on('close', function($code = null, $reason = null) {
            echo "Connection closed ({$code} - {$reason})\n";
        });
    }, function(\Exception $e) {
        echo "Could not connect: {$e->getMessage()}\n";
    });

function handleNewsUpdate($news) {
    // Your custom logic here
    if ($news['sentimentScore'] > 0.7) {
        echo "Bullish signal detected!\n";
    }
}

$loop->run();
?>

const token = 'YOUR_AUTH_TOKEN';
const ws = new WebSocket(`wss://dev.stocknews.live/ws?token=${token}`);

ws.onopen = () => {
    console.log('Connected to StockNews WebSocket');
};

ws.onmessage = (event) => {
    const message = JSON.parse(event.data);
    
    if (message.type === 'connected') {
        console.log('Authenticated:', message.subscription);
    } else if (message.type === 'news') {
        const news = message.data;
        console.log(`News for ${news.ticker}:`, news.sentimentLabel);
        console.log('Summary:', news.summary);
        console.log('Price:', news.priceFormatted);
        
        // Update UI or process data
        displayNews(news);
    }
};

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

ws.onclose = () => {
    console.log('Connection closed');
    // Optionally reconnect
    setTimeout(() => {
        connectWebSocket();
    }, 5000);
};

function displayNews(news) {
    // Update your UI with the news data
    const newsElement = document.createElement('div');
    newsElement.innerHTML = `
        <h3>${news.ticker} - ${news.sentimentLabel}</h3>
        <p>${news.summary}</p>
        <p>Price: ${news.priceFormatted}</p>
    `;
    document.getElementById('news-feed').appendChild(newsElement);
}