import asyncio
from quicr_cython import AsyncClient, ClientConfig, TrackName

async def main():
    # Configure the client
    config = ClientConfig(
        connect_uri="moqt://relay.example.com:443",
        endpoint_id="my-client"
    )

    # Connect to the relay
    async with AsyncClient(config) as client:
        track = TrackName(["example", "chat"], "messages")

        # Subscribe to messages
        async with client.subscriber(track) as sub:
            async for obj in sub:
                print(f"Received: {obj.data.decode()}")
                if obj.data == b"quit":
                    break

asyncio.run(main())

import asyncio
from quicr_cython import AsyncClient, ClientConfig, TrackName, TrackMode

async def publish_messages():
    config = ClientConfig(connect_uri="moqt://relay.example.com:443")

    async with AsyncClient(config) as client:
        track = TrackName(["example", "chat"], "messages")

        async with client.publisher(track, track_mode=TrackMode.STREAM) as pub:
            # Publish with auto-sequencing
            await pub.publish(b"Hello, world!")
            await pub.publish(b"Another message")

            # Start a new group
            await pub.new_group()
            await pub.publish(b"First message in new group")

asyncio.run(publish_messages())

import asyncio
from quicr_cython import AsyncClient, ClientConfig, TrackName

async def fetch_history():
    config = ClientConfig(connect_uri="moqt://relay.example.com:443")

    async with AsyncClient(config) as client:
        track = TrackName(["example", "chat"], "messages")

        # Fetch groups 0-10
        async with client.fetcher(track, start_group=0, end_group=10) as fetch:
            async for obj in fetch:
                print(f"Historical message: {obj.data.decode()}")

asyncio.run(fetch_history())

from quicr_cython import (
    Client, ClientConfig, TrackName, TrackMode,
    ObjectHeaders, PublishObjectStatus
)

# Create and connect client
config = ClientConfig(connect_uri="moqt://relay.example.com:443")
client = Client(config)
client.connect()

# Create a publish track
track_name = TrackName(["example", "video"], "stream1")
publisher = client.create_publish_track(
    track_name,
    track_mode=TrackMode.STREAM,
    default_priority=1,
    default_ttl=5000
)

# Activate publishing
client.publish_track(publisher)

# Publish objects
headers = ObjectHeaders(group_id=0, object_id=0, payload_length=100)
data = b"video frame data..."
status = publisher.publish_object(headers, data)

if status == PublishObjectStatus.OK:
    print("Published successfully")

# Cleanup
client.unpublish_track(publisher)
client.disconnect()