import json
import pprint
import httpx
import asyncio

# # import src.knowledge_bases.pipeline as Pipeline

# # asyncio.run(Pipeline.main())

# from src.data_sources.coin_gecko import CoinGecko
# from src.data_sources.cryptocompare import CryptoCompare

# cgc = CoinGecko()

# pprint.pprint(cgc.get_trending_coin_list())


from src.libs.rpc_client import rpc_call

# response = rpc_call(method_name="getSwapSources")

async def main():
    method_name = 'getSwapSources'

    try:
        response = await rpc_call(method_name)
        if response is not None:
            print("RPC call successful!")
            print(response)
        else:
            print("RPC call failed.")
    except httpx.RequestError as e:
        print(f"Error in main function: {e}")

asyncio.run(main())
# web: docker-compose up --build
# web: python -m chainlit run chatxbt-assistant.py -h --port 8080