Rename project from "test-interface" to "kora" and update dependencies: replace Twilio with Plivo.

app.py

@@ -6,9 +6,9 @@ import time
 import urllib.parse
 from http.server import BaseHTTPRequestHandler, HTTPServer
 
+import plivo
 import streamlit as st
 from dotenv import load_dotenv
-from twilio.rest import Client
 
 # --- Setup logging ---
 logging.basicConfig(level=logging.INFO)
@@ -16,15 +16,14 @@ logging.basicConfig(level=logging.INFO)
 # --- Load environment variables ---
 load_dotenv()
 
-# --- Setup Twilio ---
+# --- Setup plivo ---
 try:
-    TWILIO_SID = os.getenv("TWILIO_SID")
-    TWILIO_AUTH_TOKEN = os.getenv("TWILIO_AUTH_TOKEN")
-    TWILIO_PHONE_NUMBER = os.getenv("TWILIO_PHONE_NUMBER")
+    PLIVO_AUTH_ID = os.getenv("PLIVO_AUTH_ID")
+    PLIVO_AUTH_TOKEN = os.getenv("PLIVO_AUTH_TOKEN")
     KORA_PHONE_NUMBER = os.getenv("KORA_PHONE_NUMBER")
-    client = Client(TWILIO_SID, TWILIO_AUTH_TOKEN)
+    client = plivo.RestClient(auth_id=PLIVO_AUTH_ID, auth_token=PLIVO_AUTH_TOKEN)
 except Exception as e:
-    st.error(f"Error setting up Twilio: {e}")
+    st.error(f"Error setting up plivo: {e}")
 
 # --- Thread lock for SQLite access ---
 db_lock = threading.Lock()
@@ -59,13 +58,13 @@ class SMSWebhookHandler(BaseHTTPRequestHandler):
 
             logging.info(f"Webhook received: {data}")
             # Handle incoming SMS
-            body = data.get("Body", [""])[0]
+            message_text = data.get("Text", [""])[0]
 
-            if body:
+            if message_text:
                 with db_lock:
                     c.execute(
                         "INSERT INTO messages (sender, text) VALUES (?, ?)",
-                        ("assistant", body),
+                        (KORA_PHONE_NUMBER, message_text),
                     )
                     conn.commit()
 
@@ -86,7 +85,7 @@ class SMSWebhookHandler(BaseHTTPRequestHandler):
 def run_webhook_server():
     try:
         server = HTTPServer(("", 8502), SMSWebhookHandler)
-        logging.info("Webhook server started on port 8080")
+        logging.info("Webhook server started on port 8502")
         server.serve_forever()
     except Exception as e:
         logging.error(f"Error starting webhook server: {e}")
@@ -104,14 +103,21 @@ if not hasattr(st, "webhook_server_started"):
 # --- Streamlit UI ---
 st.title("📲 Chat with KORA")
 
+PLIVO_PHONE_NUMBER = st.text_input(
+    "Enter your phone number to chat with KORA", value="+13602304837", max_chars=15
+)
+
 # Display chat history
 try:
     with db_lock:
         messages = c.execute(
-            "SELECT sender, text FROM messages ORDER BY timestamp ASC"
+            "SELECT sender, text FROM messages where sender IN (?, ?) ORDER BY timestamp ASC",
+            (PLIVO_PHONE_NUMBER, KORA_PHONE_NUMBER),
         ).fetchall()
     for sender, text in messages:
-        st.chat_message("user" if sender == "user" else "assistant").write(text)
+        st.chat_message("user" if sender == PLIVO_PHONE_NUMBER else "assistant").write(
+            text
+        )
 except sqlite3.Error as e:
     st.error(f"Error fetching messages: {e}")
 
@@ -121,35 +127,36 @@ if prompt := st.chat_input("Type your message..."):
         # Save to DB
         with db_lock:
             c.execute(
-                "INSERT INTO messages (sender, text) VALUES (?, ?)", ("user", prompt)
+                "INSERT INTO messages (sender, text) VALUES (?, ?)",
+                (PLIVO_PHONE_NUMBER, prompt),
             )
             conn.commit()
 
         # Show in UI
         st.chat_message("user").write(prompt)
 
-        # Send via Twilio
+        # Send via plivo
         client.messages.create(
-            body=prompt, from_=TWILIO_PHONE_NUMBER, to=KORA_PHONE_NUMBER
+            text=prompt, src=PLIVO_PHONE_NUMBER, dst=KORA_PHONE_NUMBER
         )
-
-        # Periodically check for new messages from the assistant
-        def check_for_new_messages():
-            while True:
-                try:
-                    with db_lock:
-                        latest_message = c.execute(
-                            "SELECT sender, text FROM messages ORDER BY timestamp DESC LIMIT 1"
-                        ).fetchone()
-                        if latest_message and latest_message[0] == "assistant":
-                            st.chat_message("assistant").write(latest_message[1])
-                            break
-                except sqlite3.Error as e:
-                    logging.error(f"Error checking for new messages: {e}")
-                time.sleep(5)
-
-        check_for_new_messages()
     except sqlite3.Error as e:
         st.error(f"Error saving message to database: {e}")
     except Exception as e:
-        st.error(f"Error sending message via Twilio: {e}")
+        st.error(f"Error sending message via plivo: {e}")
+
+
+def check_for_new_messages():
+    while True:
+        try:
+            with db_lock:
+                latest_message = c.execute(
+                    "SELECT sender, text FROM messages ORDER BY timestamp DESC LIMIT 1"
+                ).fetchone()
+                if latest_message and latest_message[0] == KORA_PHONE_NUMBER:
+                    st.chat_message("assistant").write(latest_message[1])
+        except sqlite3.Error as e:
+            logging.error(f"Error checking for new messages: {e}")
+        time.sleep(5)
+
+
+check_for_new_messages()

pyproject.toml

@@ -1,5 +1,5 @@
 [tool.poetry]
-name = "test-interface"
+name = "kora"
 version = "0.1.0"
 description = ""
 authors = ["Kanha Upadhyay <kanha.upadhyay@sifars.com>"]
@@ -8,8 +8,8 @@ readme = "README.md"
 [tool.poetry.dependencies]
 python = "3.12.*"
 streamlit = "^1.44.1"
-twilio = "^9.5.2"
 python-dotenv = "^1.1.0"
+plivo = "^4.58.6"
 
 
 [build-system]

requirements.txt

@@ -1,3 +1,3 @@
 streamlit==1.44.1
-twilio==9.5.2
+plivo==4.58.6
 python-dotenv==1.1.0