Messaging Feed

amqp://op-<slug>:<password>@mq.ticktock.bet:5672/<slug>

{priority}.{prematch}.{live}.{msg_type}.{sport}.{source}:{entity}.{event_id}.{node_id}

# All live messages (odds + settlements + fixture changes)
hi.-.live.#

# Only odds changes
hi.-.live.odds_change.#

# All messages for a specific match
hi.-.live.*.3.od:match.2588141.-

# Everything including alive heartbeats
#

<odds_change product="2" timestamp="1711234567890"
             event_id="od:match:2588141"
             tt_match_id="98deb7ef-def9-47d4-854c-a13618952f99">
  <odds>
    <market id="1001"
            tt_market_id="a3f1b2c4-5678-4d9e-b012-abcdef123456"
            type="headshot_opening"
            specifiers="map=1|round=5"
            status="1"
            textEN="First kill is a headshot — Round 5"
            textRU="Первое убийство хедшотом — Раунд 5">
      <outcome id="1" active="1" odds="2.10" probabilities="0.41000" />
    </market>
    <market id="1013"
            tt_market_id="b7e2c3d5-6789-4e0f-c123-bcdef2345678"
            type="grenade_kill"
            specifiers="map=1|round=5"
            status="1"
            textEN="Grenade kill in Round 5"
            textRU="Убийство гранатой в раунде 5">
      <outcome id="1" active="1" odds="7.40" probabilities="0.10000" />
    </market>
    <market id="1050"
            tt_market_id="c8f3d4e6-7890-4f1a-d234-cdef34567890"
            type="bomb_planted"
            specifiers="map=1|round=5"
            status="1"
            textEN="Bomb planted — Round 5"
            textRU="Бомба заложена — Раунд 5">
      <outcome id="1" active="1" odds="1.85" probabilities="0.47000" />
    </market>
  </odds>
</odds_change>

<bet_settlement product="2" timestamp="1711234590123"
                event_id="od:match:2588141"
                tt_match_id="98deb7ef-def9-47d4-854c-a13618952f99">
  <outcomes>
    <market id="1013"
            tt_market_id="b7e2c3d5-6789-4e0f-c123-bcdef2345678"
            type="grenade_kill"
            specifiers="map=1|round=5"
            status="-3"
            textEN="Grenade kill in Round 5"
            textRU="Убийство гранатой в раунде 5">
      <outcome id="1" result="1"/>
    </market>
  </outcomes>
</bet_settlement>

<outcome id="1" result="0" void_factor="1.0"/>

<bet_cancel product="2" timestamp="1711234600000"
            event_id="od:match:2588141"
            tt_match_id="98deb7ef-def9-47d4-854c-a13618952f99">
  <market id="1013"
          tt_market_id="b7e2c3d5-6789-4e0f-c123-bcdef2345678"
          type="grenade_kill"
          specifiers="map=1|round=5"
          void_reason_id="4"
          void_reason_params="custom=not_played"
          textEN="Grenade kill in Round 5"
          textRU="Убийство гранатой в раунде 5" />
</bet_cancel>

<rollback_bet_settlement product="2" timestamp="1711234610000"
                         event_id="od:match:2588141"
                         tt_match_id="98deb7ef-def9-47d4-854c-a13618952f99">
  <market id="1013"
          tt_market_id="b7e2c3d5-6789-4e0f-c123-bcdef2345678"
          type="grenade_kill"
          specifiers="map=1|round=5" />
</rollback_bet_settlement>

<fixture_change product="2" timestamp="1711234500000"
                event_id="od:match:2588141"
                tt_match_id="98deb7ef-def9-47d4-854c-a13618952f99"
                change_type="1"/>

<alive product="2" timestamp="1711234570000" subscribed="1"/>

import asyncio
import aio_pika
from xml.etree import ElementTree


AMQP_URL = "amqp://op-acme-sports:<password>@mq.ticktock.bet:5672/acme-sports"
EXCHANGE = "ttfeed"


async def main():
    connection = await aio_pika.connect_robust(AMQP_URL)
    channel = await connection.channel()

    exchange = await channel.declare_exchange(
        EXCHANGE, aio_pika.ExchangeType.TOPIC, durable=True, passive=True,
    )

    queue = await channel.declare_queue("ticktock-all", durable=True)
    await queue.bind(exchange, routing_key="hi.-.live.#")
    await queue.bind(exchange, routing_key="-.-.-.alive.-.-.-.-")

    async with queue.iterator() as q:
        async for message in q:
            async with message.process():
                xml_body = message.body.decode()
                routing_key = message.routing_key
                # Extract message type from 4th section of routing key
                msg_type = routing_key.split(".")[3] if routing_key else "unknown"

                if msg_type == "odds_change":
                    root = ElementTree.fromstring(xml_body)
                    event_id = root.get("event_id")
                    for market in root.findall(".//market"):
                        status = market.get("status")
                        text = market.get("textEN")
                        if status == "-1":
                            suspend_market(market.get("id"))
                        elif status == "1":
                            for outcome in market.findall("outcome"):
                                update_odds(market.get("id"), text, outcome.get("odds"))

                elif msg_type == "bet_settlement":
                    root = ElementTree.fromstring(xml_body)
                    for market in root.findall(".//market"):
                        for outcome in market.findall("outcome"):
                            grade_bet(market.get("id"), outcome.get("result"))

                elif msg_type == "alive":
                    pass  # heartbeat — feed is healthy


asyncio.run(main())