feat: Add Voice Mode API with WebSocket support and VAD processing for real-time audio interaction

.gitattributes

@@ -33,3 +33,4 @@ Dockerfile text
 *.svg binary
 *.csv binary
 *.wav binary
+*.raw binary

pyproject.toml

@@ -108,6 +108,8 @@ dependencies = [
     "crewai==0.102.0",
     "mcp>=0.9.1",
     "uv>=0.5.7",
+    "webrtcvad>=2.0.10",
+    "scipy>=1.14.1",
     "ag2>=0.1.0",
     "scrapegraph-py>=1.12.0",
     "pydantic-ai>=0.0.19",

src/backend/base/langflow/api/router.py

@@ -9,12 +9,14 @@
     flows_router,
     folders_router,
     login_router,
+    mcp_router,
     monitor_router,
     starter_projects_router,
     store_router,
     users_router,
     validate_router,
     variables_router,
+    voice_mode_router,
 )
 from langflow.api.v2 import files_router as files_router_v2
 
@@ -39,5 +41,7 @@
 router.include_router(monitor_router)
 router.include_router(folders_router)
 router.include_router(starter_projects_router)
+router.include_router(voice_mode_router)
+router.include_router(mcp_router)
 
 router_v2.include_router(files_router_v2)

src/backend/base/langflow/api/v1/__init__.py

@@ -12,6 +12,7 @@
 from langflow.api.v1.users import router as users_router
 from langflow.api.v1.validate import router as validate_router
 from langflow.api.v1.variable import router as variables_router
+from langflow.api.v1.voice_mode import router as voice_mode_router
 
 __all__ = [
     "api_key_router",
@@ -28,4 +29,5 @@
     "users_router",
     "validate_router",
     "variables_router",
+    "voice_mode_router",
 ]

src/backend/base/langflow/api/v1/mcp.py

@@ -44,6 +44,7 @@
 
     logger.debug("MCP module loaded - debug logging enabled")
 
+enable_progress_notifications = None
 
 router = APIRouter(prefix="/mcp", tags=["mcp"])
 
@@ -177,10 +178,11 @@
 
 
 @server.call_tool()
-async def handle_call_tool(
-    name: str, arguments: dict, *, enable_progress_notifications: bool = Depends(get_enable_progress_notifications)
-) -> list[types.TextContent]:
+async def handle_call_tool(name: str, arguments: dict) -> list[types.TextContent]:
     """Handle tool execution requests."""
+    global enable_progress_notifications
+    if enable_progress_notifications is None:
+        enable_progress_notifications = get_settings_service().settings.mcp_server_enable_progress_notifications
     try:
         session = await anext(get_session())
         background_tasks = BackgroundTasks()