wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Creating a status endpoint to return the available transports.

Browse Source
This commit is contained in:
filipi87
2026-05-07 15:53:15 -03:00
parent 3fa193b983
commit 1eade184f1
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/pipecat/runner/run.py
View File

@@ -235,13 +235,20 @@ def _configure_server_app(args: argparse.Namespace):
def _setup_unified_start_route( def _setup_unified_start_route(
app: FastAPI, args: argparse.Namespace, active_sessions: dict[str, dict[str, Any]] app: FastAPI, args: argparse.Namespace, active_sessions: dict[str, dict[str, Any]]
): ):
"""Register the unified POST /start endpoint. """Register the unified POST /start and GET /status endpoints.
Handles WebRTC, Daily, and telephony transport start flows. Clients specify Handles WebRTC, Daily, and telephony transport start flows. Clients specify
which transport they want via the ``transport`` field in the request body. which transport they want via the ``transport`` field in the request body.
When ``-t`` was passed on the command line, requests for any other transport When ``-t`` was passed on the command line, requests for any other transport
are rejected with HTTP 400. are rejected with HTTP 400.
""" """
ALL_TRANSPORTS = ["webrtc", "daily", *TELEPHONY_TRANSPORTS]
@app.get("/status")
async def status():
"""Return the transports supported by this runner instance."""
transports = [args.transport] if args.transport is not None else ALL_TRANSPORTS
return {"status": "ready", "transports": transports}
class IceServer(TypedDict, total=False): class IceServer(TypedDict, total=False):
urls: str | list[str] urls: str | list[str]