Spaces:

jjmandog
/

jays-mobile-wash

Runtime error

App Files Files Community

jjmandog commited on Jun 18

Commit

2662b83

verified ·

1 Parent(s): 5dc0181

Update app.py

Browse files

Files changed (1) hide show

app.py +296 -530

app.py CHANGED Viewed

@@ -1,34 +1,24 @@
 #!/usr/bin/env python3
 """
-🚗 JAY'S MOBILE WASH - COMPLETE 3-FILE AI SYSTEM
-iPhone Forwarding + AI Assistant + Dashboard - ALL IN ONE!
 """
 import os
 import json
 import requests
 import logging
-from datetime import datetime, timedelta
-from flask import Flask, request, jsonify, render_template_string
-from flask_cors import CORS
-from flask_socketio import SocketIO, emit
 import threading
-from threading import Lock
-from collections import defaultdict
 import time
 # Load environment variables
 from dotenv import load_dotenv
 load_dotenv()
-# Initialize Flask app
-app = Flask(__name__)
-app.config['SECRET_KEY'] = os.environ.get('SECRET_KEY', 'jays-mobile-wash-2025')
-# Enable CORS and SocketIO
-CORS(app)
-socketio = SocketIO(app, cors_allowed_origins="*")
 # Configuration
 SIGNALWIRE_PROJECT_ID = os.environ.get('SIGNALWIRE_PROJECT_ID', '')
 SIGNALWIRE_AUTH_TOKEN = os.environ.get('SIGNALWIRE_AUTH_TOKEN', '')
@@ -69,9 +59,11 @@ try:
         )
         print("✅ SignalWire initialized")
     else:
-        print("⚠️ SignalWire credentials not found")
 except ImportError:
     print("⚠️ SignalWire library not available")
 # Logging setup
 logging.basicConfig(level=logging.INFO)
@@ -90,7 +82,9 @@ class SystemState:
             'active_calls': {},
             'active_sms': {},
             'start_time': datetime.now(),
-            'status': 'healthy'
         }
     def get(self, key):
@@ -108,6 +102,18 @@ class SystemState:
     def get_all(self):
         with self._lock:
             return self._data.copy()
 # Initialize system state
 system_state = SystemState()
@@ -152,11 +158,6 @@ class SimpleAI:
     def generate_response(self, user_input, context=None):
         """Generate AI response"""
-        # Check cache first
-        cache_key = f"{user_input[:50]}_{context.get('forwarded', False) if context else False}"
-        if cache_key in self.response_cache:
-            return self.response_cache[cache_key]
         intent = self.detect_intent(user_input)
         sentiment = self.analyze_sentiment(user_input)
@@ -196,8 +197,6 @@ class SimpleAI:
             except Exception as e:
                 logger.warning(f"DeepSeek failed: {e}")
-        # Cache and return
-        self.response_cache[cache_key] = response
         return response
     def get_deepseek_response(self, prompt, context=None):
@@ -247,386 +246,14 @@ BUSINESS INFO:
 # Initialize AI processor
 ai = SimpleAI()
-# ===== INLINE HTML TEMPLATE =====
-DASHBOARD_HTML = """
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>{{ business_name }} - AI Dashboard</title>
-    <style>
-        * { margin: 0; padding: 0; box-sizing: border-box; }
-        body {
-            font-family: 'Segoe UI', Tahoma, Geneva, Verdana, sans-serif;
-            background: linear-gradient(135deg, #667eea 0%, #764ba2 100%);
-            color: white;
-            min-height: 100vh;
-            overflow-x: hidden;
-        }
-        .container { max-width: 1400px; margin: 0 auto; padding: 20px; }
-        .header {
-            text-align: center;
-            margin-bottom: 40px;
-            background: rgba(255,255,255,0.1);
-            padding: 30px;
-            border-radius: 20px;
-            backdrop-filter: blur(10px);
-        }
-        .header h1 {
-            color: #fff;
-            font-size: 3em;
-            text-shadow: 0 0 30px rgba(255,255,255,0.5);
-            margin-bottom: 10px;
-        }
-        .header p {
-            font-size: 1.2em;
-            opacity: 0.9;
-            color: #e0e0e0;
-        }
-        .stats-grid {
-            display: grid;
-            grid-template-columns: repeat(auto-fit, minmax(280px, 1fr));
-            gap: 25px;
-            margin-bottom: 40px;
-        }
-        .stat-card {
-            background: linear-gradient(145deg, rgba(255,255,255,0.15), rgba(255,255,255,0.05));
-            border: 1px solid rgba(255,255,255,0.2);
-            border-radius: 20px;
-            padding: 30px;
-            text-align: center;
-            backdrop-filter: blur(15px);
-            transition: all 0.3s ease;
-            position: relative;
-            overflow: hidden;
-        }
-        .stat-card:hover {
-            transform: translateY(-5px);
-            box-shadow: 0 15px 35px rgba(0,0,0,0.3);
-        }
-        .stat-card::before {
-            content: '';
-            position: absolute;
-            top: 0;
-            left: -100%;
-            width: 100%;
-            height: 100%;
-            background: linear-gradient(90deg, transparent, rgba(255,255,255,0.2), transparent);
-            transition: left 0.5s;
-        }
-        .stat-card:hover::before {
-            left: 100%;
-        }
-        .stat-number {
-            font-size: 2.5em;
-            font-weight: bold;
-            color: #4facfe;
-            margin-bottom: 10px;
-            text-shadow: 0 0 20px rgba(79, 172, 254, 0.5);
-        }
-        .stat-label {
-            color: #ffffff;
-            font-size: 1.1em;
-            opacity: 0.9;
-        }
-        .status-indicator {
-            display: inline-block;
-            width: 14px;
-            height: 14px;
-            border-radius: 50%;
-            margin-right: 10px;
-            position: relative;
-        }
-        .status-healthy {
-            background: #00ff88;
-            animation: pulse 2s infinite;
-        }
-        .status-warning { background: #ffaa00; }
-        .status-error { background: #ff4757; }
-        .config-section {
-            background: linear-gradient(145deg, rgba(255,255,255,0.1), rgba(255,255,255,0.05));
-            border: 1px solid rgba(255,255,255,0.15);
-            border-radius: 15px;
-            padding: 30px;
-            margin-bottom: 30px;
-            backdrop-filter: blur(10px);
-        }
-        .config-section h3 {
-            color: #4facfe;
-            margin-bottom: 20px;
-            font-size: 1.4em;
-            display: flex;
-            align-items: center;
-        }
-        .config-item {
-            display: flex;
-            justify-content: space-between;
-            margin: 15px 0;
-            padding: 10px 0;
-            border-bottom: 1px solid rgba(255,255,255,0.1);
-        }
-        .config-item:last-child {
-            border-bottom: none;
-        }
-        .services-grid {
-            display: grid;
-            grid-template-columns: repeat(auto-fit, minmax(250px, 1fr));
-            gap: 20px;
-        }
-        .service-card {
-            background: linear-gradient(145deg, rgba(79, 172, 254, 0.2), rgba(79, 172, 254, 0.1));
-            border: 1px solid rgba(79, 172, 254, 0.3);
-            border-radius: 15px;
-            padding: 20px;
-            text-align: center;
-            transition: all 0.3s ease;
-        }
-        .service-card:hover {
-            transform: scale(1.05);
-            box-shadow: 0 10px 25px rgba(79, 172, 254, 0.3);
-        }
-        .service-name {
-            font-weight: bold;
-            margin-bottom: 10px;
-            color: #ffffff;
-        }
-        .service-description {
-            font-size: 0.9em;
-            opacity: 0.8;
-            margin-bottom: 15px;
-            color: #e0e0e0;
-        }
-        .price {
-            font-size: 1.8em;
-            font-weight: bold;
-            color: #00ff88;
-            text-shadow: 0 0 15px rgba(0, 255, 136, 0.5);
-        }
-        .live-indicator {
-            background: #ff4757;
-            color: white;
-            padding: 5px 15px;
-            border-radius: 20px;
-            font-size: 0.8em;
-            animation: blink 1.5s infinite;
-            margin-left: 10px;
-        }
-        .footer {
-            text-align: center;
-            margin-top: 50px;
-            padding: 20px;
-            color: rgba(255,255,255,0.7);
-            border-top: 1px solid rgba(255,255,255,0.1);
-        }
-        @keyframes pulse {
-            0% {
-                box-shadow: 0 0 0 0 rgba(0, 255, 136, 0.7);
-                transform: scale(1);
-            }
-            70% {
-                box-shadow: 0 0 0 10px rgba(0, 255, 136, 0);
-                transform: scale(1.1);
-            }
-            100% {
-                box-shadow: 0 0 0 0 rgba(0, 255, 136, 0);
-                transform: scale(1);
-            }
-        }
-        @keyframes blink {
-            0%, 50% { opacity: 1; }
-            51%, 100% { opacity: 0.3; }
-        }
-        .emoji { font-size: 1.2em; margin-right: 10px; }
-        .webhook-info {
-            background: rgba(255, 193, 7, 0.1);
-            border: 1px solid rgba(255, 193, 7, 0.3);
-            border-radius: 10px;
-            padding: 15px;
-            margin-top: 20px;
-        }
-        .webhook-url {
-            font-family: 'Courier New', monospace;
-            background: rgba(0,0,0,0.3);
-            padding: 8px 12px;
-            border-radius: 5px;
-            color: #4facfe;
-            word-break: break-all;
-        }
-    </style>
-    <script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/4.0.1/socket.io.js"></script>
-</head>
-<body>
-    <div class="container">
-        <div class="header">
-            <h1>🚗 {{ business_name }}</h1>
-            <p>iPhone Forwarding AI Assistant System</p>
-            <span class="live-indicator">🔴 LIVE</span>
-        </div>
-        <div class="stats-grid">
-            <div class="stat-card">
-                <div class="stat-number" id="calls-today">{{ stats.calls_today }}</div>
-                <div class="stat-label"><span class="emoji">📞</span>Calls Today</div>
-            </div>
-            <div class="stat-card">
-                <div class="stat-number" id="sms-today">{{ stats.sms_today }}</div>
-                <div class="stat-label"><span class="emoji">📱</span>SMS Today</div>
-            </div>
-            <div class="stat-card">
-                <div class="stat-number" id="calls-forwarded">{{ stats.calls_forwarded }}</div>
-                <div class="stat-label"><span class="emoji">🔄</span>Calls Forwarded</div>
-            </div>
-            <div class="stat-card">
-                <div class="stat-number" id="ai-responses">{{ stats.ai_responses }}</div>
-                <div class="stat-label"><span class="emoji">🤖</span>AI Responses</div>
-            </div>
-            <div class="stat-card">
-                <div class="stat-number" id="revenue-today">${{ "%.2f"|format(stats.revenue_today) }}</div>
-                <div class="stat-label"><span class="emoji">💰</span>Revenue Today</div>
-            </div>
-            <div class="stat-card">
-                <div class="stat-number" id="uptime">{{ stats.uptime_hours }}h</div>
-                <div class="stat-label"><span class="emoji">⏱️</span>System Uptime</div>
-            </div>
-        </div>
-        <div class="config-section">
-            <h3><span class="emoji">📞</span>iPhone Forwarding Configuration</h3>
-            <div class="config-item">
-                <span><strong>Jay's iPhone:</strong></span>
-                <span>{{ jay_phone }}</span>
-            </div>
-            <div class="config-item">
-                <span><strong>AI Assistant Number:</strong></span>
-                <span>{{ ai_phone }}</span>
-            </div>
-            <div class="config-item">
-                <span><strong>Forwarding Status:</strong></span>
-                <span>
-                    <span class="status-indicator {{ 'status-healthy' if forwarding_enabled else 'status-error' }}"></span>
-                    {{ 'Enabled' if forwarding_enabled else 'Disabled' }}
-                </span>
-            </div>
-            <div class="config-item">
-                <span><strong>Forwarding Delay:</strong></span>
-                <span>{{ forwarding_delay }} seconds</span>
-            </div>
-            <div class="webhook-info">
-                <strong>📡 SignalWire Webhook URLs:</strong><br>
-                <div style="margin-top: 10px;">
-                    <strong>Voice Webhook:</strong><br>
-                    <div class="webhook-url">{{ request.url_root }}voice/incoming</div>
-                </div>
-                <div style="margin-top: 10px;">
-                    <strong>SMS Webhook:</strong><br>
-                    <div class="webhook-url">{{ request.url_root }}sms/incoming</div>
-                </div>
-            </div>
-        </div>
-        <div class="config-section">
-            <h3><span class="emoji">🔧</span>System Status</h3>
-            <div class="config-item">
-                <span><strong>SignalWire:</strong></span>
-                <span>
-                    <span class="status-indicator {{ 'status-healthy' if signalwire_configured else 'status-error' }}"></span>
-                    {{ 'Connected' if signalwire_configured else 'Not Configured' }}
-                </span>
-            </div>
-            <div class="config-item">
-                <span><strong>DeepSeek AI:</strong></span>
-                <span>
-                    <span class="status-indicator {{ 'status-healthy' if deepseek_configured else 'status-warning' }}"></span>
-                    {{ 'Connected' if deepseek_configured else 'Fallback Mode' }}
-                </span>
-            </div>
-            <div class="config-item">
-                <span><strong>Active Calls:</strong></span>
-                <span id="active-calls">{{ stats.active_calls }}</span>
-            </div>
-            <div class="config-item">
-                <span><strong>Active SMS:</strong></span>
-                <span id="active-sms">{{ stats.active_sms }}</span>
-            </div>
-        </div>
-        <div class="config-section">
-            <h3><span class="emoji">💼</span>Services & Pricing</h3>
-            <div class="services-grid">
-                {% for service_id, service in services.items() %}
-                <div class="service-card">
-                    <div class="service-name">{{ service.name }}</div>
-                    <div class="service-description">{{ service.description }}</div>
-                    <div class="price">${{ "%.0f"|format(service.price) }}</div>
-                </div>
-                {% endfor %}
-            </div>
-        </div>
-        <div class="footer">
-            <p>🔄 Real-time updates every 30 seconds | Built with ❤️ for {{ business_name }}</p>
-            <p style="margin-top: 10px; font-size: 0.9em;">🚀 3-File iPhone Forwarding AI System | Powered by DeepSeek & SignalWire</p>
-        </div>
-    </div>
-    <script>
-        // Socket.IO connection for real-time updates
-        const socket = io();
-        socket.on('connect', function() {
-            console.log('🔗 Connected to AI system');
-        });
-        socket.on('stats_broadcast', function(data) {
-            console.log('📊 Stats update received');
-            document.getElementById('calls-today').textContent = data.calls_today || 0;
-            document.getElementById('sms-today').textContent = data.sms_today || 0;
-            document.getElementById('calls-forwarded').textContent = data.calls_forwarded || 0;
-            document.getElementById('ai-responses').textContent = data.ai_responses || 0;
-            document.getElementById('active-calls').textContent = Object.keys(data.active_calls || {}).length;
-            document.getElementById('active-sms').textContent = Object.keys(data.active_sms || {}).length;
-        });
-        // Auto-refresh stats every 30 seconds
-        setInterval(function() {
-            fetch('/api/stats')
-                .then(response => response.json())
-                .then(data => {
-                    document.getElementById('calls-today').textContent = data.calls_today;
-                    document.getElementById('sms-today').textContent = data.sms_today;
-                    document.getElementById('calls-forwarded').textContent = data.calls_forwarded;
-                    document.getElementById('ai-responses').textContent = data.ai_responses;
-                    document.getElementById('active-calls').textContent = data.active_calls;
-                    document.getElementById('active-sms').textContent = data.active_sms;
-                })
-                .catch(error => console.error('⚠️ Stats update failed:', error));
-        }, 30000);
-        // Add some visual feedback
-        document.addEventListener('DOMContentLoaded', function() {
-            console.log('🚗 Jay\'s Mobile Wash AI Dashboard Loaded');
-            // Add click effects to stat cards
-            document.querySelectorAll('.stat-card').forEach(card => {
-                card.addEventListener('click', function() {
-                    this.style.transform = 'scale(0.95)';
-                    setTimeout(() => {
-                        this.style.transform = '';
-                    }, 150);
-                });
-            });
-        });
-    </script>
-</body>
-</html>
-"""
-# ===== VOICE WEBHOOKS =====
-@app.route('/voice/incoming', methods=['POST'])
 def handle_voice():
-    """Handle incoming voice calls with iPhone forwarding"""
     try:
         if not signalwire_client or not VoiceResponse:
             return "Service unavailable", 503
@@ -639,20 +266,20 @@ def handle_voice():
         # Detect forwarding
         is_forwarded = bool(forwarded_from) or (to_number == SIGNALWIRE_PHONE)
-        logger.info(f"📞 Call: {from_number} → {to_number}, Forwarded: {is_forwarded}")
         # Update stats
         system_state.increment('calls_today')
         if is_forwarded:
             system_state.increment('calls_forwarded')
-        # Store active call
-        system_state.get_all()['active_calls'][call_sid] = {
-            'from': from_number,
-            'forwarded': is_forwarded,
-            'start': datetime.now().isoformat()
-        }
         response = VoiceResponse()
         # Greeting
@@ -684,7 +311,7 @@ def handle_voice():
         response.dial(JAY_PHONE, timeout=30)
         return str(response)
-@app.route('/voice/process', methods=['POST'])
 def process_speech():
     """Process customer speech"""
     try:
@@ -693,8 +320,6 @@ def process_speech():
         speech_result = request.form.get('SpeechResult', '')
         confidence = float(request.form.get('Confidence', '0.0'))
-        logger.info(f"🎤 Speech: {speech_result} (conf: {confidence:.2f})")
         if not speech_result or confidence < 0.4:
             response = VoiceResponse()
             response.say("I didn't understand clearly. Let me connect you with Jay.", voice='alice')
@@ -738,9 +363,7 @@ def process_speech():
         response.dial(JAY_PHONE, timeout=30)
         return str(response)
-# ===== SMS WEBHOOKS =====
-@app.route('/sms/incoming', methods=['POST'])
 def handle_sms():
     """Handle incoming SMS"""
     try:
@@ -748,7 +371,14 @@ def handle_sms():
         from_number = request.form.get('From')
         message_body = request.form.get('Body', '').strip()
-        logger.info(f"📱 SMS from {from_number}: {message_body[:50]}...")
         system_state.increment('sms_today')
@@ -765,13 +395,12 @@ def handle_sms():
             'jay' in message_body.lower()):
             response_text = f"I'll have Jay respond to you personally. For immediate assistance, call {JAY_PHONE}."
-            # TODO: Notify Jay
             return send_sms(response_text, from_number)
         # Generate AI response
         ai_response = ai.generate_response(message_body, {'sms': True})
-        # Optimize for SMS (160 char limit)
         if len(ai_response) > 320:
             ai_response = ai_response[:317] + "..."
@@ -792,71 +421,22 @@ def send_sms(message, to_number):
                 from_=SIGNALWIRE_PHONE,
                 to=to_number
             )
-            logger.info(f"📤 SMS sent to {to_number}")
         return str(MessagingResponse()) if MessagingResponse else ""
     except Exception as e:
         logger.error(f"SMS send error: {e}")
         return ""
-# ===== WEB INTERFACE =====
-@app.route('/')
-def dashboard():
-    """Main dashboard with inline HTML"""
-    try:
-        stats = system_state.get_all()
-        uptime = datetime.now() - stats['start_time']
-        dashboard_data = {
-            'business_name': BUSINESS_NAME,
-            'jay_phone': JAY_PHONE,
-            'ai_phone': SIGNALWIRE_PHONE,
-            'forwarding_enabled': FORWARDING_ENABLED,
-            'forwarding_delay': FORWARDING_DELAY,
-            'stats': {
-                'calls_today': stats['calls_today'],
-                'sms_today': stats['sms_today'],
-                'calls_forwarded': stats['calls_forwarded'],
-                'ai_responses': stats['ai_responses'],
-                'revenue_today': stats['revenue_today'],
-                'uptime_hours': int(uptime.total_seconds() / 3600),
-                'active_calls': len(stats['active_calls']),
-                'active_sms': len(stats['active_sms']),
-                'status': stats['status']
-            },
-            'services': SERVICES,
-            'signalwire_configured': bool(signalwire_client),
-            'deepseek_configured': bool(DEEPSEEK_API_KEY),
-            'request': request
-        }
-        return render_template_string(DASHBOARD_HTML, **dashboard_data)
-    except Exception as e:
-        logger.error(f"Dashboard error: {e}")
-        return f"<h1>Dashboard Error: {e}</h1>", 500
-@app.route('/api/stats')
-def api_stats():
-    """API endpoint for real-time stats"""
-    stats = system_state.get_all()
-    uptime = datetime.now() - stats['start_time']
-    return jsonify({
-        'calls_today': stats['calls_today'],
-        'sms_today': stats['sms_today'],
-        'calls_forwarded': stats['calls_forwarded'],
-        'ai_responses': stats['ai_responses'],
-        'revenue_today': stats['revenue_today'],
-        'uptime_seconds': int(uptime.total_seconds()),
-        'active_calls': len(stats['active_calls']),
-        'active_sms': len(stats['active_sms']),
-        'status': stats['status'],
-        'timestamp': datetime.now().isoformat()
-    })
-@app.route('/health')
 def health_check():
     """Health check endpoint"""
     health = {
@@ -866,55 +446,244 @@ def health_check():
         'uptime': int((datetime.now() - system_state.get_all()['start_time']).total_seconds()),
         'timestamp': datetime.now().isoformat()
     }
-    status_code = 200 if health['signalwire'] else 503
-    return jsonify(health), status_code
-# ===== SOCKETIO EVENTS =====
-@socketio.on('connect')
-def handle_connect():
-    emit('status', {'message': 'Connected to Jay\'s Mobile Wash AI'})
-    logger.info("🔗 Client connected")
-@socketio.on('request_stats')
-def handle_stats_request():
     stats = system_state.get_all()
-    emit('stats_update', stats)
-# ===== BACKGROUND TASKS =====
-def broadcast_stats():
-    """Broadcast stats every 30 seconds"""
-    while True:
-        try:
-            stats = system_state.get_all()
-            socketio.emit('stats_broadcast', stats)
-            time.sleep(30)
-        except Exception as e:
-            logger.error(f"Broadcast error: {e}")
-            time.sleep(60)
-# Start background thread
-stats_thread = threading.Thread(target=broadcast_stats, daemon=True)
-stats_thread.start()
-# ===== ERROR HANDLERS =====
-@app.errorhandler(404)
-def not_found(error):
-    return jsonify({'error': 'Not found'}), 404
-@app.errorhandler(500)
-def internal_error(error):
-    logger.error(f"Internal error: {error}")
-    return jsonify({'error': 'Internal server error'}), 500
-# ===== STARTUP =====
-if __name__ == '__main__':
     print("\n" + "="*60)
-    print("🚗 JAY'S MOBILE WASH AI SYSTEM - 3 FILE VERSION")
     print("="*60)
     print(f"📞 Jay's Phone: {JAY_PHONE}")
     print(f"🤖 AI Phone: {SIGNALWIRE_PHONE}")
@@ -922,16 +691,13 @@ if __name__ == '__main__':
     print(f"🌐 SignalWire: {'✅ Connected' if signalwire_client else '❌ Not configured'}")
     print(f"🧠 DeepSeek: {'✅ Connected' if DEEPSEEK_API_KEY else '❌ Not configured'}")
     print("="*60)
-    print("🚀 Starting server on http://0.0.0.0:7860")
-    print("📊 Dashboard: http://localhost:7860")
-    print("📡 Health Check: http://localhost:7860/health")
     print("="*60)
-    # Run the app
-    socketio.run(
-        app,
-        host='0.0.0.0',
-        port=7860,
-        debug=False,
-        use_reloader=False
     )

 #!/usr/bin/env python3
 """
+🚗 JAY'S MOBILE WASH - HUGGINGFACE SPACES COMPATIBLE
+iPhone Forwarding + AI Assistant - Optimized for HuggingFace deployment
 """
 import os
 import json
 import requests
 import logging
 import threading
 import time
+from datetime import datetime, timedelta
+from collections import defaultdict
+from threading import Lock
+import gradio as gr
 # Load environment variables
 from dotenv import load_dotenv
 load_dotenv()
 # Configuration
 SIGNALWIRE_PROJECT_ID = os.environ.get('SIGNALWIRE_PROJECT_ID', '')
 SIGNALWIRE_AUTH_TOKEN = os.environ.get('SIGNALWIRE_AUTH_TOKEN', '')
         )
         print("✅ SignalWire initialized")
     else:
+        print("⚠️ SignalWire credentials not configured")
 except ImportError:
     print("⚠️ SignalWire library not available")
+except Exception as e:
+    print(f"⚠️ SignalWire error: {e}")
 # Logging setup
 logging.basicConfig(level=logging.INFO)
             'active_calls': {},
             'active_sms': {},
             'start_time': datetime.now(),
+            'status': 'healthy',
+            'call_log': [],
+            'sms_log': []
         }
     def get(self, key):
     def get_all(self):
         with self._lock:
             return self._data.copy()
+    def add_call_log(self, entry):
+        with self._lock:
+            self._data['call_log'].insert(0, entry)
+            if len(self._data['call_log']) > 50:
+                self._data['call_log'] = self._data['call_log'][:50]
+    def add_sms_log(self, entry):
+        with self._lock:
+            self._data['sms_log'].insert(0, entry)
+            if len(self._data['sms_log']) > 50:
+                self._data['sms_log'] = self._data['sms_log'][:50]
 # Initialize system state
 system_state = SystemState()
     def generate_response(self, user_input, context=None):
         """Generate AI response"""
         intent = self.detect_intent(user_input)
         sentiment = self.analyze_sentiment(user_input)
             except Exception as e:
                 logger.warning(f"DeepSeek failed: {e}")
         return response
     def get_deepseek_response(self, prompt, context=None):
 # Initialize AI processor
 ai = SimpleAI()
+# Flask app for webhooks (runs in background)
+from flask import Flask, request
+flask_app = Flask(__name__)
+@flask_app.route('/voice/incoming', methods=['POST'])
 def handle_voice():
+    """Handle incoming voice calls"""
     try:
         if not signalwire_client or not VoiceResponse:
             return "Service unavailable", 503
         # Detect forwarding
         is_forwarded = bool(forwarded_from) or (to_number == SIGNALWIRE_PHONE)
+        # Log the call
+        call_entry = {
+            'time': datetime.now().strftime('%H:%M:%S'),
+            'from': from_number,
+            'type': 'Forwarded Call' if is_forwarded else 'Direct Call',
+            'status': 'Incoming'
+        }
+        system_state.add_call_log(call_entry)
         # Update stats
         system_state.increment('calls_today')
         if is_forwarded:
             system_state.increment('calls_forwarded')
         response = VoiceResponse()
         # Greeting
         response.dial(JAY_PHONE, timeout=30)
         return str(response)
+@flask_app.route('/voice/process', methods=['POST'])
 def process_speech():
     """Process customer speech"""
     try:
         speech_result = request.form.get('SpeechResult', '')
         confidence = float(request.form.get('Confidence', '0.0'))
         if not speech_result or confidence < 0.4:
             response = VoiceResponse()
             response.say("I didn't understand clearly. Let me connect you with Jay.", voice='alice')
         response.dial(JAY_PHONE, timeout=30)
         return str(response)
+@flask_app.route('/sms/incoming', methods=['POST'])
 def handle_sms():
     """Handle incoming SMS"""
     try:
         from_number = request.form.get('From')
         message_body = request.form.get('Body', '').strip()
+        # Log the SMS
+        sms_entry = {
+            'time': datetime.now().strftime('%H:%M:%S'),
+            'from': from_number,
+            'message': message_body[:50] + '...' if len(message_body) > 50 else message_body,
+            'status': 'Received'
+        }
+        system_state.add_sms_log(sms_entry)
         system_state.increment('sms_today')
             'jay' in message_body.lower()):
             response_text = f"I'll have Jay respond to you personally. For immediate assistance, call {JAY_PHONE}."
             return send_sms(response_text, from_number)
         # Generate AI response
         ai_response = ai.generate_response(message_body, {'sms': True})
+        # Optimize for SMS
         if len(ai_response) > 320:
             ai_response = ai_response[:317] + "..."
                 from_=SIGNALWIRE_PHONE,
                 to=to_number
             )
+            # Log sent SMS
+            sms_entry = {
+                'time': datetime.now().strftime('%H:%M:%S'),
+                'from': 'AI Assistant',
+                'message': message[:50] + '...' if len(message) > 50 else message,
+                'status': 'Sent'
+            }
+            system_state.add_sms_log(sms_entry)
         return str(MessagingResponse()) if MessagingResponse else ""
     except Exception as e:
         logger.error(f"SMS send error: {e}")
         return ""
+@flask_app.route('/health')
 def health_check():
     """Health check endpoint"""
     health = {
         'uptime': int((datetime.now() - system_state.get_all()['start_time']).total_seconds()),
         'timestamp': datetime.now().isoformat()
     }
+    return health
+# Gradio Interface Functions
+def get_dashboard_data():
+    """Get current dashboard data"""
     stats = system_state.get_all()
+    uptime = datetime.now() - stats['start_time']
+    dashboard_html = f"""
+    <div style="font-family: Arial, sans-serif; padding: 20px; background: linear-gradient(135deg, #667eea 0%, #764ba2 100%); border-radius: 15px; color: white;">
+        <h1 style="text-align: center; margin-bottom: 30px;">🚗 {BUSINESS_NAME} - AI Dashboard</h1>
+        <div style="display: grid; grid-template-columns: repeat(auto-fit, minmax(200px, 1fr)); gap: 20px; margin-bottom: 30px;">
+            <div style="background: rgba(255,255,255,0.15); padding: 20px; border-radius: 10px; text-align: center;">
+                <h2 style="color: #4facfe; font-size: 2em; margin: 0;">{stats['calls_today']}</h2>
+                <p style="margin: 5px 0 0 0;">📞 Calls Today</p>
+            </div>
+            <div style="background: rgba(255,255,255,0.15); padding: 20px; border-radius: 10px; text-align: center;">
+                <h2 style="color: #4facfe; font-size: 2em; margin: 0;">{stats['sms_today']}</h2>
+                <p style="margin: 5px 0 0 0;">📱 SMS Today</p>
+            </div>
+            <div style="background: rgba(255,255,255,0.15); padding: 20px; border-radius: 10px; text-align: center;">
+                <h2 style="color: #4facfe; font-size: 2em; margin: 0;">{stats['calls_forwarded']}</h2>
+                <p style="margin: 5px 0 0 0;">🔄 Calls Forwarded</p>
+            </div>
+            <div style="background: rgba(255,255,255,0.15); padding: 20px; border-radius: 10px; text-align: center;">
+                <h2 style="color: #4facfe; font-size: 2em; margin: 0;">{stats['ai_responses']}</h2>
+                <p style="margin: 5px 0 0 0;">🤖 AI Responses</p>
+            </div>
+        </div>
+        <div style="background: rgba(255,255,255,0.1); padding: 20px; border-radius: 10px; margin-bottom: 20px;">
+            <h3 style="color: #4facfe; margin-bottom: 15px;">📞 iPhone Forwarding Status</h3>
+            <p><strong>Jay's iPhone:</strong> {JAY_PHONE}</p>
+            <p><strong>AI Assistant Number:</strong> {SIGNALWIRE_PHONE}</p>
+            <p><strong>Forwarding:</strong> {'✅ Enabled' if FORWARDING_ENABLED else '❌ Disabled'}</p>
+            <p><strong>Delay:</strong> {FORWARDING_DELAY} seconds</p>
+            <p><strong>SignalWire:</strong> {'✅ Connected' if signalwire_client else '❌ Not configured'}</p>
+            <p><strong>DeepSeek AI:</strong> {'✅ Connected' if DEEPSEEK_API_KEY else '⚠️ Fallback mode'}</p>
+        </div>
+        <div style="background: rgba(255,255,255,0.1); padding: 20px; border-radius: 10px;">
+            <h3 style="color: #4facfe; margin-bottom: 15px;">💼 Services & Pricing</h3>
+            <div style="display: grid; grid-template-columns: repeat(auto-fit, minmax(200px, 1fr)); gap: 15px;">
+    """
+    for service_id, service in SERVICES.items():
+        dashboard_html += f"""
+                <div style="background: rgba(79, 172, 254, 0.2); padding: 15px; border-radius: 8px; text-align: center;">
+                    <h4 style="margin: 0 0 5px 0; color: white;">{service['name']}</h4>
+                    <p style="margin: 0 0 10px 0; font-size: 0.9em; opacity: 0.8;">{service['description']}</p>
+                    <p style="margin: 0; font-size: 1.5em; font-weight: bold; color: #00ff88;">${service['price']:.0f}</p>
+                </div>
+        """
+    dashboard_html += """
+            </div>
+        </div>
+    </div>
+    """
+    return dashboard_html
+def get_call_log():
+    """Get recent call log"""
+    stats = system_state.get_all()
+    call_log = stats.get('call_log', [])
+    if not call_log:
+        return "No calls logged yet."
+    log_html = """
+    <div style="font-family: Arial, sans-serif;">
+        <h3>📞 Recent Calls</h3>
+        <div style="max-height: 300px; overflow-y: auto;">
+    """
+    for call in call_log[:10]:  # Show last 10 calls
+        log_html += f"""
+            <div style="background: #f5f5f5; padding: 10px; margin: 5px 0; border-radius: 5px; border-left: 4px solid #4facfe;">
+                <strong>{call['time']}</strong> | {call['from']} | {call['type']} | {call['status']}
+            </div>
+        """
+    log_html += "</div></div>"
+    return log_html
+def get_sms_log():
+    """Get recent SMS log"""
+    stats = system_state.get_all()
+    sms_log = stats.get('sms_log', [])
+    if not sms_log:
+        return "No SMS logged yet."
+    log_html = """
+    <div style="font-family: Arial, sans-serif;">
+        <h3>📱 Recent SMS</h3>
+        <div style="max-height: 300px; overflow-y: auto;">
+    """
+    for sms in sms_log[:10]:  # Show last 10 SMS
+        log_html += f"""
+            <div style="background: #f5f5f5; padding: 10px; margin: 5px 0; border-radius: 5px; border-left: 4px solid #00ff88;">
+                <strong>{sms['time']}</strong> | {sms['from']}<br>
+                <em>{sms['message']}</em> | {sms['status']}
+            </div>
+        """
+    log_html += "</div></div>"
+    return log_html
+def test_ai_response(message):
+    """Test AI response generation"""
+    if not message.strip():
+        return "Please enter a message to test."
+    try:
+        intent = ai.detect_intent(message)
+        sentiment = ai.analyze_sentiment(message)
+        response = ai.generate_response(message, {'test': True})
+        result = f"""
+        <div style="font-family: Arial, sans-serif; padding: 15px; background: #f9f9f9; border-radius: 10px;">
+            <h3>AI Response Test</h3>
+            <p><strong>Customer Message:</strong> {message}</p>
+            <p><strong>Detected Intent:</strong> {intent}</p>
+            <p><strong>Sentiment:</strong> {sentiment['label']} ({sentiment['score']:.2f})</p>
+            <div style="background: #e3f2fd; padding: 10px; border-radius: 5px; margin-top: 10px;">
+                <strong>AI Response:</strong><br>
+                {response}
+            </div>
+        </div>
+        """
+        return result
+    except Exception as e:
+        return f"Error testing AI response: {e}"
+# Start Flask app in background thread
+def run_flask():
+    flask_app.run(host='0.0.0.0', port=7860, debug=False)
+flask_thread = threading.Thread(target=run_flask, daemon=True)
+flask_thread.start()
+# Create Gradio Interface
+with gr.Blocks(
+    title=f"{BUSINESS_NAME} - AI Dashboard",
+    theme=gr.themes.Soft(),
+    css="""
+    .gradio-container {
+        background: linear-gradient(135deg, #667eea 0%, #764ba2 100%);
+    }
+    """
+) as interface:
+    gr.Markdown(f"""
+    # 🚗 {BUSINESS_NAME} - iPhone Forwarding AI System
+    **Real-time dashboard for your AI assistant with iPhone call forwarding**
+    📞 **Jay's iPhone:** {JAY_PHONE}
+    🤖 **AI Assistant:** {SIGNALWIRE_PHONE}
+    🔄 **Forwarding:** {'✅ Enabled' if FORWARDING_ENABLED else '❌ Disabled'}
+    """)
+    with gr.Tabs():
+        with gr.Tab("📊 Dashboard"):
+            dashboard_display = gr.HTML(value=get_dashboard_data())
+            refresh_btn = gr.Button("🔄 Refresh Dashboard", variant="primary")
+            refresh_btn.click(fn=get_dashboard_data, outputs=dashboard_display)
+        with gr.Tab("📞 Call Log"):
+            call_log_display = gr.HTML(value=get_call_log())
+            refresh_calls_btn = gr.Button("🔄 Refresh Calls", variant="secondary")
+            refresh_calls_btn.click(fn=get_call_log, outputs=call_log_display)
+        with gr.Tab("📱 SMS Log"):
+            sms_log_display = gr.HTML(value=get_sms_log())
+            refresh_sms_btn = gr.Button("🔄 Refresh SMS", variant="secondary")
+            refresh_sms_btn.click(fn=get_sms_log, outputs=sms_log_display)
+        with gr.Tab("🧪 Test AI"):
+            with gr.Row():
+                with gr.Column():
+                    test_message = gr.Textbox(
+                        label="Test Message",
+                        placeholder="Enter a customer message to test AI response...",
+                        lines=3
+                    )
+                    test_btn = gr.Button("🤖 Test AI Response", variant="primary")
+                with gr.Column():
+                    test_result = gr.HTML(label="AI Response")
+            test_btn.click(fn=test_ai_response, inputs=test_message, outputs=test_result)
+        with gr.Tab("ℹ️ Setup Info"):
+            gr.Markdown(f"""
+            ## 🔧 Webhook Configuration
+            **Set these URLs in your SignalWire dashboard:**
+            - **Voice Webhook:** `https://YOUR-SPACE-NAME.hf.space/voice/incoming`
+            - **SMS Webhook:** `https://YOUR-SPACE-NAME.hf.space/sms/incoming`
+            ## 📱 iPhone Setup
+            **On Jay's iPhone:**
+            1. Go to **Settings** → **Phone** → **Call Forwarding**
+            2. Turn **ON** Call Forwarding
+            3. Set forward number to: `{SIGNALWIRE_PHONE}`
+            4. Choose: Forward when **unanswered** after {FORWARDING_DELAY} seconds
+            ## 🎯 How It Works
+            1. Customer calls Jay's iPhone: `{JAY_PHONE}`
+            2. iPhone rings for {FORWARDING_DELAY} seconds
+            3. If no answer → forwards to AI: `{SIGNALWIRE_PHONE}`
+            4. AI handles call with forwarding awareness
+            5. Can escalate back to Jay if needed
+            ## 📊 System Status
+            - **SignalWire:** {'✅ Connected' if signalwire_client else '❌ Not configured'}
+            - **DeepSeek AI:** {'✅ Connected' if DEEPSEEK_API_KEY else '⚠️ Using fallback responses'}
+            - **Health Check:** [/health](./health)
+            """)
+    # Auto-refresh every 30 seconds
+    interface.load(fn=get_dashboard_data, outputs=dashboard_display, every=30)
+    interface.load(fn=get_call_log, outputs=call_log_display, every=30)
+    interface.load(fn=get_sms_log, outputs=sms_log_display, every=30)
+# Launch the interface
+if __name__ == "__main__":
     print("\n" + "="*60)
+    print("🚗 JAY'S MOBILE WASH AI SYSTEM")
     print("="*60)
     print(f"📞 Jay's Phone: {JAY_PHONE}")
     print(f"🤖 AI Phone: {SIGNALWIRE_PHONE}")
     print(f"🌐 SignalWire: {'✅ Connected' if signalwire_client else '❌ Not configured'}")
     print(f"🧠 DeepSeek: {'✅ Connected' if DEEPSEEK_API_KEY else '❌ Not configured'}")
     print("="*60)
+    print("🚀 Starting Gradio interface...")
+    print("📞 Flask webhooks running on port 7860")
     print("="*60)
+    interface.launch(
+        server_name="0.0.0.0",
+        server_port=7860,
+        share=False,
+        show_error=True
     )