Code Samples

This section provides working code examples for connecting to the Hyper LiveScore Feed.

---

Node.js Example

const amqp = require('amqplib');

const config = {
  hostname: 'hyper-livescore.lsports.eu',
  port: 5671,
  username: 'YOUR_USERNAME',
  password: 'YOUR_PASSWORD',
  protocol: 'amqps'
};

const packageId = 'YOUR_PACKAGE_ID';
const queueName = `_${packageId}_`;

// Store for fixtures
const fixturesStore = new Map();

async function connectFixtures() {
  const conn = await amqp.connect({ ...config, vhost: 'Fixtures' });
  const channel = await conn.createChannel();
  
  await channel.prefetch(100);
  
  channel.consume(queueName, (msg) => {
    if (msg) {
      const message = JSON.parse(msg.content.toString());
      const fixture = message.body;
      
      // Store fixture by fixtureId
      fixturesStore.set(fixture.fixtureId, fixture);
      
      console.log(`Fixture update: ${fixture.fixtureId} - ${fixture.participants?.map(p => p.name).join(' vs ')}`);
      
      channel.ack(msg);
    }
  });
  
  console.log('Connected to Fixtures feed');
}

async function connectIncidents() {
  const conn = await amqp.connect({ ...config, vhost: 'Incidents' });
  const channel = await conn.createChannel();
  
  await channel.prefetch(100);
  
  channel.consume(queueName, (msg) => {
    if (msg) {
      const message = JSON.parse(msg.content.toString());
      const incident = message.body;
      
      // Get fixture context
      const fixture = fixturesStore.get(incident.fixtureId);
      
      console.log(`Incident: ${incident.name} (${incident.kind}) - Fixture: ${fixture?.participants?.map(p => p.name).join(' vs ') || incident.fixtureId}`);
      console.log(`  Confidence: ${(incident.confidence * 100).toFixed(0)}%`);
      
      if (incident.values) {
        console.log(`  Score: ${incident.values.map(v => v.value).join(' - ')}`);
      }
      
      channel.ack(msg);
    }
  });
  
  console.log('Connected to Incidents feed');
}

async function main() {
  try {
    await connectFixtures();
    await connectIncidents();
  } catch (error) {
    console.error('Connection error:', error);
    process.exit(1);
  }
}

main();

---

Python Example

import pika
import json
import ssl

config = {
    'host': 'hyper-livescore.lsports.eu',
    'port': 5671,
    'username': 'YOUR_USERNAME',
    'password': 'YOUR_PASSWORD'
}

package_id = 'YOUR_PACKAGE_ID'
queue_name = f'_{package_id}_'

# Store for fixtures
fixtures_store = {}

def get_connection(vhost):
    credentials = pika.PlainCredentials(config['username'], config['password'])
    ssl_context = ssl.create_default_context()
    
    parameters = pika.ConnectionParameters(
        host=config['host'],
        port=config['port'],
        virtual_host=vhost,
        credentials=credentials,
        ssl_options=pika.SSLOptions(ssl_context)
    )
    
    return pika.BlockingConnection(parameters)

def handle_fixture(ch, method, properties, body):
    message = json.loads(body)
    fixture = message['body']
    
    fixtures_store[fixture['fixtureId']] = fixture
    
    participants = fixture.get('participants', [])
    names = ' vs '.join([p['name'] for p in participants])
    print(f"Fixture update: {fixture['fixtureId']} - {names}")
    
    ch.basic_ack(delivery_tag=method.delivery_tag)

def handle_incident(ch, method, properties, body):
    message = json.loads(body)
    incident = message['body']
    
    fixture = fixtures_store.get(incident['fixtureId'])
    fixture_name = ' vs '.join([p['name'] for p in fixture.get('participants', [])]) if fixture else str(incident['fixtureId'])
    
    print(f"Incident: {incident['name']} ({incident['kind']}) - Fixture: {fixture_name}")
    print(f"  Confidence: {incident['confidence'] * 100:.0f}%")
    
    if incident.get('values'):
        score = ' - '.join([v['value'] for v in incident['values']])
        print(f"  Score: {score}")
    
    ch.basic_ack(delivery_tag=method.delivery_tag)

def main():
    # Connect to Fixtures
    fixtures_conn = get_connection('Fixtures')
    fixtures_channel = fixtures_conn.channel()
    fixtures_channel.basic_qos(prefetch_count=100)
    fixtures_channel.basic_consume(queue=queue_name, on_message_callback=handle_fixture)
    print('Connected to Fixtures feed')
    
    # Connect to Incidents
    incidents_conn = get_connection('Incidents')
    incidents_channel = incidents_conn.channel()
    incidents_channel.basic_qos(prefetch_count=100)
    incidents_channel.basic_consume(queue=queue_name, on_message_callback=handle_incident)
    print('Connected to Incidents feed')
    
    try:
        # Start consuming (this blocks)
        fixtures_channel.start_consuming()
    except KeyboardInterrupt:
        fixtures_channel.stop_consuming()
        incidents_channel.stop_consuming()
    
    fixtures_conn.close()
    incidents_conn.close()

if __name__ == '__main__':
    main()

---

C# Example

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System.Text;
using System.Text.Json;

var config = new
{
    HostName = "hyper-livescore.lsports.eu",
    Port = 5671,
    UserName = "YOUR_USERNAME",
    Password = "YOUR_PASSWORD"
};

var packageId = "YOUR_PACKAGE_ID";
var queueName = $"_{packageId}_";

var fixturesStore = new Dictionary<int, JsonElement>();

ConnectionFactory CreateFactory(string vhost) => new()
{
    HostName = config.HostName,
    Port = config.Port,
    UserName = config.UserName,
    Password = config.Password,
    VirtualHost = vhost,
    Ssl = new SslOption { Enabled = true }
};

void ConnectFixtures()
{
    var factory = CreateFactory("Fixtures");
    var connection = factory.CreateConnection();
    var channel = connection.CreateModel();
    
    channel.BasicQos(0, 100, false);
    
    var consumer = new EventingBasicConsumer(channel);
    consumer.Received += (model, ea) =>
    {
        var body = Encoding.UTF8.GetString(ea.Body.ToArray());
        var message = JsonDocument.Parse(body);
        var fixture = message.RootElement.GetProperty("body");
        var fixtureId = fixture.GetProperty("fixtureId").GetInt32();
        
        fixturesStore[fixtureId] = fixture;
        
        Console.WriteLine($"Fixture update: {fixtureId}");
        channel.BasicAck(ea.DeliveryTag, false);
    };
    
    channel.BasicConsume(queue: queueName, autoAck: false, consumer: consumer);
    Console.WriteLine("Connected to Fixtures feed");
}

void ConnectIncidents()
{
    var factory = CreateFactory("Incidents");
    var connection = factory.CreateConnection();
    var channel = connection.CreateModel();
    
    channel.BasicQos(0, 100, false);
    
    var consumer = new EventingBasicConsumer(channel);
    consumer.Received += (model, ea) =>
    {
        var body = Encoding.UTF8.GetString(ea.Body.ToArray());
        var message = JsonDocument.Parse(body);
        var incident = message.RootElement.GetProperty("body");
        
        var name = incident.GetProperty("name").GetString();
        var kind = incident.GetProperty("kind").GetString();
        var confidence = incident.GetProperty("confidence").GetDouble();
        
        Console.WriteLine($"Incident: {name} ({kind}) - Confidence: {confidence:P0}");
        channel.BasicAck(ea.DeliveryTag, false);
    };
    
    channel.BasicConsume(queue: queueName, autoAck: false, consumer: consumer);
    Console.WriteLine("Connected to Incidents feed");
}

ConnectFixtures();
ConnectIncidents();

Console.WriteLine("Press Enter to exit...");
Console.ReadLine();

---

Best Practices

1. Always store fixtures first — Incidents reference fixtures by fixtureId

2. Handle reconnection — Implement automatic recovery for dropped connections

3. Process asynchronously — Don't block the message consumption loop

4. Monitor confidence scores — Use the confidence field to filter uncertain incidents

5. Log message IDs — Track MessageId for debugging and deduplication

---

Related Documentation

• Technical Integration

• Fixture Message Structure

• Incidents Message Structure