Uploaded

Dockerfile

@@ -1,19 +1,18 @@
-# Use a slim, official Python image
+# Use a stable, official Python image
 FROM python:3.10-slim
 
-# Set the working directory inside the container
+# Set the working directory
 WORKDIR /app
 
-# Copy the requirements file and install dependencies
-# This leverages Docker caching to speed up future builds
+# Copy requirements and install them to leverage Docker caching
 COPY requirements.txt .
 RUN pip install --no-cache-dir -r requirements.txt
 
-# Copy the rest of your application files into the container
+# Copy the rest of the application files
 COPY . .
 
-# Expose the port that Hugging Face uses
+# Expose the port Hugging Face uses for Streamlit apps
 EXPOSE 7860
 
-# Command to run the application using a production-grade server
-CMD ["gunicorn", "--bind", "0.0.0.0:7860", "webhook_server:app"]
+# Command to run the unified application
+CMD ["streamlit", "run", "app.py", "--server.port=7860", "--server.address=0.0.0.0"]

app.py

@@ -0,0 +1,179 @@
+import os
+import json
+import threading
+import streamlit as st
+import gspread
+import google.generativeai as genai
+from flask import Flask, request, jsonify
+from oauth2client.service_account import ServiceAccountCredentials
+from vapi import Vapi
+from datetime import datetime
+
+# --- Configuration Loading ---
+def load_and_set_config():
+    """Loads configuration from a single Hugging Face secret (JSON) and sets them as environment variables."""
+    config_json_str = os.getenv("APP_CONFIG_JSON")
+    if not config_json_str:
+        st.error("FATAL: The 'APP_CONFIG_JSON' secret is not set in your Space settings!")
+        st.stop()
+        
+    config = json.loads(config_json_str)
+    for key, value in config.items():
+        os.environ[key] = str(value)
+    return config
+
+# --- VAPI Call Logic ---
+def place_vapi_call(config, customer_number, raw_intent, target_name):
+    # Process intent to generate a good first message
+    genai.configure(api_key=config["GEMINI_API_KEY"])
+    model = genai.GenerativeModel('gemini-1.5-flash')
+    
+    prompt_details = f"The user's raw intent is: '{raw_intent}'."
+    if target_name:
+        prompt_details += f" They are calling a person named '{target_name}'."
+        
+    gemini_prompt = f"""
+    Based on the user's intent, generate a single, natural, and polite opening sentence for a phone call.
+    {prompt_details}
+    If a name is provided, start by asking for them. Example: "Hello, may I please speak with {target_name}?" followed by the reason.
+    If no name is provided, use a generic opening. Example: "Hello, I'm calling on behalf of a user to inquire about something."
+    Your output should be ONLY the single sentence string.
+    """
+    
+    try:
+        response = model.generate_content(gemini_prompt)
+        first_message = response.text.strip()
+    except Exception as e:
+        st.error(f"Error with Gemini: {e}")
+        return None
+
+    # Place the actual call
+    try:
+        vapi = Vapi(token=config["VAPI_API_KEY"])
+        system_prompt = "You are a helpful and polite AI assistant named Alex. Your first sentence has already been spoken. You are now in an active conversation. Listen carefully and respond naturally. Continue the conversation in the language the other person is speaking (English or Hindi)."
+        
+        return vapi.calls.create(
+            assistant_id=config["VAPI_ASSISTANT_ID"],
+            phone_number_id=config["VAPI_PHONE_NUMBER_ID"],
+            customer={"number": customer_number},
+            assistant={
+                "serverUrl": config["WEBHOOK_SERVER_URL"],
+                "firstMessage": first_message,
+                "voice": {"provider": "11labs", "voiceId": "pola", "speed": 0.9},
+                "model": {"provider": "openai", "model": "gpt-4o", "messages": [{"role": "system", "content": system_prompt}]},
+                "metadata": {"raw_intent": f"{raw_intent} (for {target_name})"}
+            }
+        )
+    except Exception as e:
+        st.error(f"An error occurred placing the Vapi call: {e}")
+        return None
+
+# --- FLASK WEBHOOK (Runs in the Background) ---
+flask_app = Flask(__name__)
+
+def log_to_google_sheet(row_data, config):
+    try:
+        print("[Log] Attempting to log to Google Sheets...")
+        if not os.path.exists("credentials.json"):
+            print("[Log] FATAL: 'credentials.json' not found.")
+            return
+
+        creds = ServiceAccountCredentials.from_json_keyfile_name("credentials.json", ["https://spreadsheets.google.com/feeds", 'https://www.googleapis.com/auth/spreadsheets', "https://www.googleapis.com/auth/drive.file", "https://www.googleapis.com/auth/drive"])
+        client = gspread.authorize(creds)
+        
+        sheet = client.open(config["GOOGLE_SHEET_NAME"]).sheet1
+        sheet.append_row(row_data)
+        print(f"[Log] Successfully logged call data.")
+    except Exception as e:
+        print(f"[Log] !!! An error occurred during Google Sheets logging: {e} !!!")
+
+@flask_app.route("/webhook", methods=['POST'])
+def webhook_handler():
+    print(f"\n--- Webhook received POST request from Vapi at {datetime.now()} ---")
+    try:
+        payload = request.json
+        if payload.get('message', {}).get('type') == 'hang':
+            call_data = payload.get('message', {}).get('call', {})
+            row_to_insert = [
+                call_data.get("id", "N/A"), datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
+                call_data.get("customer", {}).get("number", "N/A"), call_data.get("metadata", {}).get("raw_intent", "N/A"),
+                payload.get('message', {}).get('endedReason', 'N/A'), call_data.get('summary', 'No summary provided.'),
+                "Yes" if "follow-up" in call_data.get('summary', '').lower() else "No",
+                json.dumps(call_data.get('transcript', []), indent=2)
+            ]
+            config = json.loads(os.getenv("APP_CONFIG_JSON"))
+            log_to_google_sheet(row_to_insert, config)
+    except Exception as e:
+        print(f"Error in webhook handler: {e}")
+    return jsonify({'status': 'success'}), 200
+
+def run_flask():
+    # Running on a different port than Streamlit
+    flask_app.run(host="0.0.0.0", port=8080)
+
+# --- STREAMLIT UI (Main Application) ---
+def run_streamlit():
+    st.set_page_config(page_title="Voice AI Coordinator", layout="centered")
+
+    # Custom CSS for a pleasing look
+    st.markdown("""
+        <style>
+            .stApp {
+                background-color: #f0f2f5;
+            }
+            .stForm {
+                background-color: white;
+                padding: 2em;
+                border-radius: 10px;
+                box-shadow: 0 4px 12px rgba(0,0,0,0.1);
+            }
+            .stButton>button {
+                width: 100%;
+                border: none;
+                border-radius: 5px;
+                padding: 10px;
+                font-weight: bold;
+                color: white;
+                background-color: #ff4b4b;
+            }
+        </style>
+    """, unsafe_allow_html=True)
+
+    st.title("🚀 Voice AI Coordination Tool")
+    st.markdown("A unified interface to deploy intelligent voice agents on your behalf.")
+
+    # Load configuration
+    try:
+        config = load_and_set_config()
+    except Exception as e:
+        st.error(f"Failed to load configuration. Please ensure APP_CONFIG_JSON secret is set correctly. Error: {e}")
+        st.stop()
+
+    with st.form(key="call_form"):
+        st.subheader("📞 Place a New Call")
+        target_name = st.text_input("Whom are you calling? (Optional)", placeholder="e.g., Jane Doe")
+        phone_number = st.text_input("Phone Number (with country code)", placeholder="+911234567890")
+        raw_intent = st.text_area("Reason for Calling", placeholder="Ask if they would prefer tea or coffee", height=100)
+        
+        submit_button = st.form_submit_button(label="Deploy Call")
+
+    if submit_button:
+        if not phone_number or not raw_intent:
+            st.warning("Please provide a phone number and a reason for the call.")
+        else:
+            with st.spinner("Processing intent and placing call..."):
+                call_response = place_vapi_call(config, phone_number, raw_intent, target_name)
+                if call_response and call_response.id:
+                    st.success(f"✅ Call deployed successfully! Call ID: {call_response.id}")
+                    st.info("The call is being connected. Once it ends, the data will be logged to your Google Sheet.")
+                    st.balloons()
+                else:
+                    st.error("❌ Failed to deploy the call. Please check the Space logs for errors.")
+
+if __name__ == "__main__":
+    # Run Flask in a background daemon thread
+    flask_thread = threading.Thread(target=run_flask, daemon=True)
+    flask_thread.start()
+    
+    # Run the main Streamlit app
+    run_streamlit()

requirements.txt

@@ -1,4 +1,7 @@
-Flask
+streamlit
+flask
 gspread
 oauth2client
-gunicorn
+vapi-python
+google-generativeai
+python-dotenv

webhook_server.py

@@ -1,86 +0,0 @@
-import os
-import json
-import gspread
-from oauth2client.service_account import ServiceAccountCredentials
-from flask import Flask, request, jsonify
-from datetime import datetime
-
-app = Flask(__name__)
-
-HTML_TEMPLATE = """
-<!DOCTYPE html><html lang="en"><head><meta charset="UTF-8"><meta name="viewport" content="width=device-width, initial-scale=1.0"><title>Vapi Webhook Server Status</title><style>body {{ font-family: -apple-system, BlinkMacSystemFont, "Segoe UI", Roboto, Helvetica, Arial, sans-serif; display: flex; justify-content: center; align-items: center; height: 100vh; margin: 0; background-color: #f0f2f5; }} .container {{ text-align: center; padding: 40px; background-color: white; border-radius: 12px; box-shadow: 0 4px 20px rgba(0,0,0,0.1); }} .status {{ display: inline-block; padding: 12px 24px; background-color: #28a745; color: white; font-size: 20px; font-weight: 600; border-radius: 8px; margin-bottom: 20px; }} h1 {{ color: #333; }} p {{ color: #555; font-size: 16px; }} code {{ background-color: #e9ecef; padding: 4px 8px; border-radius: 4px; font-family: "SF Mono", "Fira Code", "Fira Mono", "Roboto Mono", monospace; }}</style></head><body><div class="container"><div class="status">Live</div><h1>Your Vapi Webhook Server is Running!</h1><p>This server is successfully deployed and ready to receive requests from Vapi.</p><p>Use the following full URL in your application's configuration:</p><code>{full_webhook_url}</code></div></body></html>
-"""
-
-def log_to_google_sheet(row_data):
-    """A dedicated, robust function to handle Google Sheets logging with extreme verbosity."""
-    try:
-        # --- STAGE 1: CHECK FOR CREDENTIALS FILE ---
-        print("[Log] Stage 1: Checking for 'credentials.json' file...")
-        if not os.path.exists("credentials.json"):
-            print("[Log] FATAL ERROR: 'credentials.json' was not found. Have you uploaded it to the Space?")
-            return
-        print("[Log] Stage 1 SUCCESS: 'credentials.json' found.")
-
-        # --- STAGE 2: AUTHENTICATE WITH GOOGLE ---
-        print("[Log] Stage 2: Authenticating with Google using the credentials file...")
-        scope = ["https://spreadsheets.google.com/feeds", 'https://www.googleapis.com/auth/spreadsheets',
-                 "https://www.googleapis.com/auth/drive.file", "https://www.googleapis.com/auth/drive"]
-        creds = ServiceAccountCredentials.from_json_keyfile_name("credentials.json", scope)
-        client = gspread.authorize(creds)
-        print("[Log] Stage 2 SUCCESS: Google Authentication successful.")
-
-        # --- STAGE 3: CHECK FOR SHEET NAME ---
-        print("[Log] Stage 3: Checking for GOOGLE_SHEET_NAME secret...")
-        sheet_name = os.getenv("GOOGLE_SHEET_NAME")
-        if not sheet_name:
-            print("[Log] FATAL ERROR: The GOOGLE_SHEET_NAME secret is not set in your Space settings.")
-            return
-        print(f"[Log] Stage 3 SUCCESS: Found sheet name secret: '{sheet_name}'.")
-        
-        # --- STAGE 4: OPEN THE SHEET ---
-        print(f"[Log] Stage 4: Attempting to open Google Sheet '{sheet_name}'...")
-        sheet = client.open(sheet_name).sheet1
-        print("[Log] Stage 4 SUCCESS: Successfully opened the sheet.")
-        
-        # --- STAGE 5: APPEND THE ROW ---
-        print(f"[Log] Stage 5: Appending row data: {row_data}")
-        sheet.append_row(row_data)
-        print("[Log] Stage 5 SUCCESS: Row appended successfully!")
-
-    except Exception as e:
-        print(f"\n!!!!!!!!!!!!!! [Log] A CRITICAL ERROR OCCURRED DURING GOOGLE SHEETS LOGGING !!!!!!!!!!!!!!")
-        print(f"ERROR DETAILS: {e}")
-        print("This is likely due to one of three reasons:")
-        print("1. The `credentials.json` file is missing or malformed.")
-        print("2. The GOOGLE_SHEET_NAME secret in your Space does not EXACTLY match your sheet's name.")
-        print("3. You have not SHARED your Google Sheet with the `client_email` from the credentials file.\n")
-
-@app.route('/', methods=['GET'])
-def root():
-    host = request.host_url
-    full_url = f"{host}webhook"
-    return HTML_TEMPLATE.format(full_webhook_url=full_url)
-
-@app.route('/webhook', methods=['POST'])
-def webhook_handler():
-    print(f"\n--- Webhook received POST request from Vapi at {datetime.now()} ---")
-    try:
-        payload = request.json
-        if payload.get('message', {}).get('type') == 'hang':
-            print("Received 'hang' event. Preparing to log call details...")
-            call_data = payload.get('message', {}).get('call', {})
-            row_to_insert = [
-                call_data.get("id", "N/A"), datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
-                call_data.get("customer", {}).get("number", "N/A"), call_data.get("metadata", {}).get("raw_intent", "N/A"),
-                payload.get('message', {}).get('endedReason', 'N/A'), call_data.get('summary', 'No summary provided.'),
-                "Yes" if "follow-up" in call_data.get('summary', '').lower() else "No",
-                json.dumps(call_data.get('transcript', []), indent=2)
-            ]
-            log_to_google_sheet(row_to_insert)
-    except Exception as e:
-        print(f"An error occurred in the main webhook handler: {e}")
-    return jsonify({'status': 'success'}), 200
-
-if __name__ == "__main__":
-    port = int(os.environ.get("PORT", 7860))
-    app.run(host="0.0.0.0", port=port)