5_StreamOracleList.py

import asyncio
from typing import Any, Dict

from grpc import RpcError

from pyinjective.core.network import Network
from pyinjective.indexer_client import IndexerClient


async def oracle_list_event_processor(event: Dict[str, Any]):
    print(event)


def stream_error_processor(exception: RpcError):
    print(f"There was an error listening to oracle list updates ({exception})")


def stream_closed_processor():
    print("The oracle list updates stream has been closed")


async def main() -> None:
    network = Network.testnet()
    client = IndexerClient(network)

    task = asyncio.get_event_loop().create_task(
        client.listen_oracle_list_updates(
            callback=oracle_list_event_processor,
            on_end_callback=stream_closed_processor,
            on_status_callback=stream_error_processor,
            oracle_type="provider",
            symbols=["TIA"],
        )
    )

    await asyncio.sleep(delay=60)
    task.cancel()


if __name__ == "__main__":
    asyncio.get_event_loop().run_until_complete(main())