Create app.py

app.py

@@ -0,0 +1,207 @@
+"""
+Main Flask application for the AI call assistant system.
+"""
+
+from flask import Flask, request
+from twilio.twiml.voice_response import VoiceResponse, Gather
+import os
+import requests
+import json
+import logging
+from datetime import datetime
+from utils import transcribe_audio, classify_intent, get_rag_response, text_to_speech, get_fallback_response
+
+# Configure logging
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
+    handlers=[
+        logging.FileHandler("call_assistant.log"),
+        logging.StreamHandler()
+    ]
+)
+logger = logging.getLogger(__name__)
+
+app = Flask(__name__)
+
+# Twilio credentials
+TWILIO_ACCOUNT_SID = "ACacb8e8cc6de0f7d6c6b9c9f252a38c67"
+TWILIO_AUTH_TOKEN = "1b2826409367e9799262553538489e54"
+TWILIO_PHONE_NUMBER = "+19704064410"
+
+# Hugging Face Space URL
+HF_SPACE_URL = "https://huggingface.co/spaces/iajitpanday/vBot-1.5"
+
+# Session storage (in production, replace with a database)
+call_sessions = {}
+
+@app.route("/", methods=['GET'])
+def index():
+    return "AI Call Assistant is running!"
+
+@app.route("/answer", methods=['POST'])
+def answer_call():
+    """Handle incoming Twilio calls"""
+    call_sid = request.values.get('CallSid')
+    caller = request.values.get('From', 'Unknown')
+    
+    logger.info(f"Received call from {caller} with SID: {call_sid}")
+    
+    # Initialize session for this call
+    call_sessions[call_sid] = {
+        'caller': caller,
+        'start_time': datetime.now().isoformat(),
+        'conversation': []
+    }
+    
+    response = VoiceResponse()
+    
+    # Welcome message
+    response.say("Hello! Thank you for calling. How can I help you today?")
+    
+    # Gather speech input
+    gather = Gather(input='speech', 
+                   action='/process_speech', 
+                   method='POST', 
+                   speechTimeout='auto', 
+                   speechModel='phone_call',
+                   language='en-US')
+    
+    response.append(gather)
+    
+    # If no input is received
+    response.say("I didn't hear anything. Please call back when you're ready.")
+    response.hangup()
+    
+    return str(response)
+
+@app.route("/process_speech", methods=['POST'])
+def process_speech():
+    """Process speech input from the caller"""
+    call_sid = request.values.get('CallSid')
+    speech_result = request.values.get('SpeechResult', '')
+    
+    logger.info(f"Call {call_sid} - Speech input: {speech_result}")
+    
+    if call_sid in call_sessions:
+        call_sessions[call_sid]['conversation'].append({
+            'role': 'user',
+            'content': speech_result,
+            'timestamp': datetime.now().isoformat()
+        })
+    
+    # Process with Whisper for better transcription (optional if Twilio's is good enough)
+    recording_url = request.values.get('RecordingUrl')
+    if recording_url:
+        enhanced_transcription = transcribe_audio(recording_url)
+        if enhanced_transcription and len(enhanced_transcription) > len(speech_result):
+            speech_result = enhanced_transcription
+    
+    # Classify intent and get response
+    intent, confidence = classify_intent(speech_result)
+    
+    logger.info(f"Call {call_sid} - Detected intent: {intent} (confidence: {confidence})")
+    
+    # Get response from RAG system
+    if confidence >= 0.6:
+        response_text = get_rag_response(speech_result, intent, HF_SPACE_URL)
+    else:
+        response_text = get_fallback_response()
+    
+    if call_sid in call_sessions:
+        call_sessions[call_sid]['conversation'].append({
+            'role': 'assistant',
+            'content': response_text,
+            'timestamp': datetime.now().isoformat()
+        })
+    
+    # Create TwiML response
+    response = VoiceResponse()
+    response.say(response_text)
+    
+    # Ask if there's anything else
+    response.redirect('/anything_else')
+    
+    return str(response)
+
+@app.route("/anything_else", methods=['POST'])
+def anything_else():
+    """Ask if there's anything else the caller needs help with"""
+    call_sid = request.values.get('CallSid')
+    
+    response = VoiceResponse()
+    
+    response.say("Is there anything else I can help you with today?")
+    
+    # Gather speech input
+    gather = Gather(input='speech', 
+                   action='/handle_followup', 
+                   method='POST', 
+                   speechTimeout='auto', 
+                   speechModel='phone_call')
+    response.append(gather)
+    
+    # If no input is received
+    response.say("Thank you for calling. Have a great day!")
+    response.hangup()
+    
+    return str(response)
+
+@app.route("/handle_followup", methods=['POST'])
+def handle_followup():
+    """Handle the caller's follow-up response"""
+    call_sid = request.values.get('CallSid')
+    speech_result = request.values.get('SpeechResult', '')
+    
+    logger.info(f"Call {call_sid} - Follow-up response: {speech_result}")
+    
+    # Simple yes/no detection
+    if any(word in speech_result.lower() for word in ["yes", "yeah", "sure", "please", "correct"]):
+        response = VoiceResponse()
+        response.say("Great! How else can I help you today?")
+        
+        # Gather speech input again
+        gather = Gather(input='speech', 
+                       action='/process_speech', 
+                       method='POST', 
+                       speechTimeout='auto', 
+                       speechModel='phone_call')
+        response.append(gather)
+        
+        # If no input is received
+        response.say("I didn't hear anything. Thank you for calling. Goodbye!")
+        response.hangup()
+        
+    else:
+        response = VoiceResponse()
+        response.say("Thank you for calling. Have a great day!")
+        
+        # Save conversation log before hanging up
+        if call_sid in call_sessions:
+            call_sessions[call_sid]['end_time'] = datetime.now().isoformat()
+            # In production, save this to a database
+            logger.info(f"Call {call_sid} completed - Conversation log saved")
+        
+        response.hangup()
+    
+    return str(response)
+
+@app.route("/call_status", methods=['POST'])
+def call_status():
+    """Handle call status updates from Twilio"""
+    call_sid = request.values.get('CallSid')
+    call_status = request.values.get('CallStatus')
+    
+    logger.info(f"Call {call_sid} status: {call_status}")
+    
+    # If call ended abnormally, save the log
+    if call_status in ['completed', 'busy', 'failed', 'no-answer', 'canceled']:
+        if call_sid in call_sessions:
+            call_sessions[call_sid]['end_time'] = datetime.now().isoformat()
+            call_sessions[call_sid]['final_status'] = call_status
+            # In production, save this to a database
+    
+    return "OK"
+
+if __name__ == "__main__":
+    app.run(debug=True, host='0.0.0.0', port=5000)