run.py

#!/usr/bin/env python3
"""
Voice Vibe Coding - Single Command Runner
Starts webhook server and orchestrator together for seamless operation.
"""

import os
import sys
import subprocess
import signal
import time
from pathlib import Path

# Process tracking
processes = []

def signal_handler(sig, frame):
    """Clean shutdown on Ctrl+C"""
    print("\n\n🛑 Shutting down Voice Vibe Coding...")
    for proc in processes:
        proc.terminate()
    sys.exit(0)

def main():
    print("🎙️ Voice Vibe Coding - Starting All Services")
    print("=" * 50)
    print()

    # Register signal handler for clean shutdown
    signal.signal(signal.SIGINT, signal_handler)

    # Check if venv is activated
    if not hasattr(sys, 'real_prefix') and not (hasattr(sys, 'base_prefix') and sys.base_prefix != sys.prefix):
        print("⚠️  Virtual environment not activated!")
        print("   Run: source venv/bin/activate")
        print("   Then: python run.py")
        sys.exit(1)

    # Start webhook server
    print("🌐 Starting webhook server on port 5001...")
    webhook_proc = subprocess.Popen(
        [sys.executable, "webhook_server.py"],
        stdout=subprocess.PIPE,
        stderr=subprocess.PIPE,
        text=True
    )
    processes.append(webhook_proc)
    time.sleep(2)  # Give it time to start

    # Check if webhook server started successfully
    if webhook_proc.poll() is not None:
        print("❌ Webhook server failed to start")
        sys.exit(1)
    print("✅ Webhook server running")
    print()

    print("📞 Voice Vibe Coding is ready!")
    print()
    print("Service Status:")
    print("  • Webhook Server: http://localhost:5001")
    print("  • Pre-call webhook: http://localhost:5001/precall")
    print("  • Post-call webhook: http://localhost:5001/elevenlabs-webhook")
    print()
    print("When a call comes in, the orchestrator will automatically start.")
    print()
    print("📋 Monitoring:")
    print("  • Webhook logs: logs/webhook_server.log")
    print("  • Pipeline logs: logs/pipeline_*.log")
    print()
    print("Press Ctrl+C to stop all services")
    print()

    # Keep running and monitor processes
    try:
        while True:
            # Check if webhook server died
            if webhook_proc.poll() is not None:
                print("❌ Webhook server stopped unexpectedly")
                break
            time.sleep(1)
    except KeyboardInterrupt:
        pass

if __name__ == "__main__":
    main()