WebSocketLive Streaming

import { FinlightApi } from 'finlight-client';

const client = new FinlightApi({
  apiKey: 'your-api-key',
},
{
  takeover: true,
});

// Standard endpoint (enriched data)
client.websocket.connect(
  {
    query: 'AI AND ticker:NVDA',
    language: 'en',
    extended: true,
    includeCompanies: true,
  },
  (article) => {
    console.log('Live article:', article);
  },
);

// Raw endpoint (maximum speed, no enrichments)
client.websocket.connectRaw(
  {
    query: 'AI AND ticker:NVDA',
    language: 'en',
  },
  (article) => {
    console.log('Raw article:', article);
  },
);

import asyncio

from finlight_client import FinlightApi, ApiConfig
from finlight_client.models import GetArticlesWebSocketParams

def on_article(data):
    print(data)


async def main():
    client = FinlightApi(
        config=ApiConfig(
            api_key="YOUR_API_KEY"
        ),
        websocket_config=WebSocketConfig(
            takeover=True
        )
    )

    payload = GetArticlesWebSocketParams(
        query="nvidia", extended=False
    )

    # Standard endpoint (enriched data)
    await client.websocket.connect(
        request_payload=payload,
        on_article=on_article
    )

    # Raw endpoint (maximum speed, no enrichments)
    await client.websocket.connect_raw(
        request_payload=payload,
        on_article=on_article
    )


if __name__ == "__main__":
    asyncio.run(main())