Room MCP

pip install mcp httpx

import asyncio

import httpx
from mcp import ClientSession
from mcp.client.streamable_http import streamable_http_client

MCP_URL = "https://api.corvic.live/mcp/"
ACCESS_TOKEN = "<YOUR_ACCESS_TOKEN>"  # load from env/secrets, do not hard-code
ROOM_ID = "<YOUR_ROOM_ID>"


async def run():
    headers = {"Authorization": f"Bearer {ACCESS_TOKEN}"}

    async with (
        httpx.AsyncClient(
            headers=headers,
            follow_redirects=True,
        ) as httpx_client,
        streamable_http_client(MCP_URL, http_client=httpx_client) as (read, write, _),
    ):
        async with ClientSession(read, write) as session:
            await session.initialize()

            # 1. List the workflows (data apps) in this room (paginated).
            data_apps = await session.call_tool(
                "list_data_apps",
                arguments={"room_id": ROOM_ID, "entries_per_page": 5, "cursor": None},
            )
            print(data_apps.content[0].text)

            # 2. Pick a data_app_id from the response above, then list its
            #    feature views. Each entry includes a parquet `url`.
            # data_app_id = "<DATA_APP_ID>"
            # feature_views = await session.call_tool(
            #     "list_feature_views",
            #     arguments={"data_app_id": data_app_id, "entries_per_page": 5, "cursor": None},
            # )
            # print(feature_views.content[0].text)

            # 3. Download a feature view's parquet payload using the same
            #    Bearer token the MCP server accepts.
            # parquet_bytes = (await httpx_client.get(feature_view_url)).content


asyncio.run(run())