Syncinc to Azure Samples

.gitignore

@@ -430,4 +430,5 @@ baseline_results/
 tests/load/sessions/
 tests/load/results/
 infra/terraform/main.tfvars.json
-provider.conf.json
+provider.conf.json
+.archive

CHANGELOG.md

@@ -6,6 +6,54 @@ All notable changes to the **Azure Real-Time (ART) Agent Accelerator** are docum
 
 ---
 
+## [2.0.0-beta.1] - 2026-01-04
+
+### 🎯 Scenario Builder & Voice Handler Refactoring
+
+This release introduces the visual **Scenario Builder** for designing multi-agent workflows, comprehensive **VoiceHandler refactoring** with unified lifecycle management, and significant improvements to deployment scripts and telemetry.
+
+### Added
+
+- **Scenario Builder UI** — Visual graph-based editor for designing agent workflows with drag-and-drop node placement, edge connections, and handoff condition patterns
+- **Canvas Panning** — Infinite canvas navigation with drag-to-pan and reset-to-center controls
+- **Handoff Condition Patterns** — Pre-built templates (Authentication, Fraud/Security, Escalation, Technical Support, etc.) for common handoff scenarios
+- **Unified HandoffService** — Consolidated handoff logic across orchestrators for consistent behavior
+- **Evaluation Framework** — Model evaluation playground with A/B testing capabilities and comprehensive metrics
+- **VoiceHandler Migration** — Refactored MediaHandler into unified VoiceHandler with proper lifecycle management
+- **Responses API Infrastructure** — Dual model configuration support with GPT-4o and GPT-4.1
+- **Comprehensive Test Suite** — New tests for VoiceLive handler, cascade orchestrator, DTMF processor, and scenario orchestration contracts
+
+### Enhanced
+
+- **OpenTelemetry Consolidation** — Proper span hierarchy and lazy metrics initialization with shared metrics factory
+- **TTS Processing** — Text sanitization and sentence boundary detection for improved audio quality
+- **LiveOrchestrator** — Enhanced user message history management and context-only session updates without redundant UI broadcasts
+- **Deployment Scripts** — Pre/post-provisioning hooks with Azure CLI extension checks, EasyAuth configuration, and improved preflight checks
+- **Logging Consistency** — Standardized logging levels (info→debug) across connection manager, warmable pool, Redis, and speech modules
+- **AZD Hook Testing** — Dev Container testing workflow with environment validation and summary reporting
+- **Documentation** — Updated quickstart guide with demo profile creation, agent builder screenshots, and troubleshooting guidance
+
+### Fixed
+
+- **Redis Connection Handling** — Added error handling for connection issues with proper recovery
+- **Duplicate UI Updates** — LiveOrchestrator now omits redundant session_updated broadcasts during context-only updates
+- **Environment Logic** — Corrected pull_request event handling in Azure deployment workflow
+- **Terraform State Locks** — Added troubleshooting guidance for state lock errors with remote/local fix options
+- **Container Memory Formats** — Normalized memory configurations in deployment workflows
+
+### Infrastructure
+
+- **CI/CD Improvements** — Reusable workflow templates, parallel AZD hook testing across Linux/macOS/Windows
+- **GitHub PAT Support** — Optional PAT secret with enhanced environment variable handling
+- **Documentation Workflow** — Updated with deployment badges and improved navigation
+
+### Removed
+
+- **Deprecated Latency Tools** — Removed `latency_analytics.py`, `latency_tool.py`, `latency_tool_compat.py`, `latency_tool_v2.py` and related files (replaced by OpenTelemetry-based metrics)
+- **Backend IP Restrictions** — Removed configuration and related outputs
+
+---
+
 ## [2.0.0-beta] - 2025-12-19
 
 ### 🎉 Beta Release: Unified Agent & Scenario Framework

Makefile

@@ -146,10 +146,11 @@ generate_audio:
 	$(UV_BIN) run python $(SCRIPTS_LOAD_DIR)/utils/audio_generator.py --max-turns 5
 
 # WebSocket endpoint load testing (current approach)
-# DEPLOYED_URL = 
+# PIPELINE: cascade (default) or voicelive
 HOST = localhost:8010
+PIPELINE = cascade
 run_load_test_acs_media:
-	@echo "Running load test (override with e.g. make run_load_test URL=ws://host USERS=10 SPAWN_RATE=2 TIME=30s EXTRA_ARGS='--headless')"
+	@echo "Running ACS media load test (PIPELINE=$(PIPELINE))"
 	$(eval WS_URL ?= ws://$(HOST)/api/v1/media/stream)
 	$(eval USERS ?= 15)
 	$(eval SPAWN_RATE ?= 2)
@@ -163,20 +164,21 @@ run_load_test_acs_media:
 	fi
 	@echo "🚀 Starting Locust load test..."
 	@echo "   Host: $(WS_URL)"
+	@echo "   Pipeline: $(PIPELINE)"
 	@echo "   Users: $(USERS)"
 	@echo "   Spawn Rate: $(SPAWN_RATE) users/sec"
 	@echo "   Duration: $(TIME)"
 	@echo ""
-	locust -f $(SCRIPTS_LOAD_DIR)/locustfile.acs_media.py \
+	PIPELINE=$(PIPELINE) locust -f $(SCRIPTS_LOAD_DIR)/locustfile.acs_media.py \
 		--host=$(WS_URL) \
 		--users $(USERS) \
 		--spawn-rate $(SPAWN_RATE) \
 		--run-time $(TIME) \
 		--headless \
 		$(EXTRA_ARGS)
 
-run_load_test_realtime_conversation:
-	@echo "Running load test (override with e.g. make run_load_test URL=ws://host USERS=10 SPAWN_RATE=2 TIME=30s EXTRA_ARGS='--headless')"
+run_load_test_browser_conversation:
+	@echo "Running browser conversation load test (PIPELINE=$(PIPELINE))"
 	$(eval WS_URL ?= ws://$(HOST)/api/v1/realtime/conversation)
 	$(eval USERS ?= 15)
 	$(eval SPAWN_RATE ?= 2)
@@ -190,11 +192,12 @@ run_load_test_realtime_conversation:
 	fi
 	@echo "🚀 Starting Locust load test..."
 	@echo "   Host: $(WS_URL)"
+	@echo "   Pipeline: $(PIPELINE)"
 	@echo "   Users: $(USERS)"
 	@echo "   Spawn Rate: $(SPAWN_RATE) users/sec"
 	@echo "   Duration: $(TIME)"
 	@echo ""
-	locust -f $(SCRIPTS_LOAD_DIR)/locustfile.realtime_conversation.py \
+	PIPELINE=$(PIPELINE) locust -f $(SCRIPTS_LOAD_DIR)/locustfile.browser_conversation.py \
 		--host=$(WS_URL) \
 		--users $(USERS) \
 		--spawn-rate $(SPAWN_RATE) \
@@ -568,8 +571,8 @@ help:
 	@echo ""
 	@echo "⚡ Load Testing:"
 	@echo "  generate_audio                   Generate PCM audio files for load testing"
-	@echo "  run_load_test_acs_media          Run ACS media WebSocket load test (HOST=$(HOST))"
-	@echo "  run_load_test_realtime_conversation  Run realtime conversation WebSocket load test"
+	@echo "  run_load_test_acs_media          Run ACS media WebSocket load test (PIPELINE=$(PIPELINE))"
+	@echo "  run_load_test_browser_conversation  Run browser conversation WebSocket load test"
 	@echo ""
 	@echo "📞 Azure Communication Services:"
 	@echo "  purchase_acs_phone_number        Purchase ACS phone number and store in env file"
@@ -591,7 +594,8 @@ help:
 	@echo "  PHONE                            Phone number for testing (default: +18165019907)"
 	@echo ""
 	@echo "💡 Load Testing Parameters:"
-	@echo "  Override with: make run_load_test_acs_media HOST=your-host USERS=10 SPAWN_RATE=2 TIME=30s"
+	@echo "  Override with: make run_load_test_acs_media HOST=your-host USERS=10 PIPELINE=voicelive"
+	@echo "  • PIPELINE: Orchestration mode - cascade (default) or voicelive"
 	@echo "  • WS_URL: WebSocket URL (derived from HOST)"
 	@echo "  • USERS: Number of concurrent users (default: 15)"
 	@echo "  • SPAWN_RATE: Users spawned per second (default: 2)"

apps/artagent/backend/api/swagger_docs.py

@@ -38,42 +38,37 @@ def generate_tags(self) -> list[dict[str, str]]:
                 "description": "ACS webhook callbacks and call event processing (connected, disconnected, DTMF, etc.)",
             },
             # ═══════════════════════════════════════════════════════════════════
-            # Media & WebSocket Streaming
+            # Browser Operations
             # ═══════════════════════════════════════════════════════════════════
-            {
-                "name": "ACS Media Session",
-                "description": "Azure Communication Services media streaming for phone calls (Speech Cascade mode)",
-            },
-            {
-                "name": "Browser Communication",
-                "description": "Browser-based voice conversations via WebSocket (Voice Live SDK or Speech Cascade)",
-            },
             {
                 "name": "Browser Status",
                 "description": "Browser service status and active WebSocket connection statistics",
             },
+            # ═══════════════════════════════════════════════════════════════════
+            # Session Operations
+            # ═══════════════════════════════════════════════════════════════════
             {
-                "name": "WebSocket",
-                "description": "WebSocket transport endpoints for real-time audio streaming and dashboard relay",
+                "name": "Session Management",
+                "description": "Session history, metadata, and session lifecycle controls",
             },
             # ═══════════════════════════════════════════════════════════════════
-            # Metrics & Telemetry
+            # Metrics
             # ═══════════════════════════════════════════════════════════════════
             {
                 "name": "Session Metrics",
                 "description": "Session telemetry, latency statistics, and turn-level metrics for active conversations",
             },
-            {
-                "name": "Telemetry",
-                "description": "OpenTelemetry-based observability data and performance metrics",
-            },
             # ═══════════════════════════════════════════════════════════════════
             # Agent Configuration
             # ═══════════════════════════════════════════════════════════════════
             {
                 "name": "Agent Builder",
                 "description": "Dynamic agent creation, template management, and session-scoped agent configuration",
             },
+            {
+                "name": "Scenario Builder",
+                "description": "Scenario builder utilities for creating, validating, and managing scenario definitions",
+            },
             {
                 "name": "Scenarios",
                 "description": "Multi-agent scenario definitions with handoff routing and orchestration modes",