app.py

import streamlit as st
from openai import OpenAI
import time
import os
import uuid
import firebase_admin
from firebase_admin import credentials, firestore

# ------------------ Authentication ------------------
VALID_USERS = {
    "[email protected]": "Pass.123",
}

def login():
    st.title("🔐 Login Required")
    email = st.text_input("Email")
    password = st.text_input("Password", type="password")
    if st.button("Login"):
        if VALID_USERS.get(email) == password:
            st.session_state.authenticated = True
            st.rerun()
        else:
            st.error("❌ Incorrect email or password.")

if "authenticated" not in st.session_state:
    st.session_state.authenticated = False

if not st.session_state.authenticated:
    login()
    st.stop()

# 🔐 Firebase setup
if not firebase_admin._apps:
    cred = credentials.Certificate("firebase-service-account.json")
    firebase_admin.initialize_app(cred)

db = firestore.client()

# 🔐 OpenAI setup
openai_key = os.getenv("openai_key")
assistant_id = os.getenv("ASSISTANT_ID")
client = OpenAI(api_key=openai_key)

# 🌐 Streamlit Config
st.set_page_config(page_title="Motus AI Assistant", layout="wide")

# 🎯 Session + User ID
if "user_id" not in st.session_state:
    st.session_state["user_id"] = str(uuid.uuid4())
user_id = st.session_state["user_id"]

# 🖼️ Motus Branding + Styling
st.markdown("""
    <style>
    .block-container {padding-top: 1rem; padding-bottom: 0rem;}
    header {visibility: hidden;}
    .stChatMessage { max-width: 85%; border-radius: 12px; padding: 10px; margin-bottom: 12px; }
    .stChatMessage[data-testid="stChatMessage-user"] {
        background: #f4f4f4; color: #000000;
    }
    .stChatMessage[data-testid="stChatMessage-assistant"] {
        background: #013D52; color: #ffffff;
    }
    .stChatMessage strong { color: #E2003C; }
    </style>
""", unsafe_allow_html=True)

st.markdown("""
    <div style='text-align: center; margin-top: 20px; margin-bottom: -10px;'>
        <span style='display: inline-flex; align-items: center; gap: 8px;'>
            <svg xmlns="http://www.w3.org/2000/svg" width="160" height="50" viewBox="0 0 173.457 54.497">
                <g id="g-motus">
                    <path d="M41.31,87.813A13.457,13.457,0,1,1,54.767,101.27..." fill="#013d52"></path>
                </g>
                <g id="g-icon">
                    <path d="M463.17,17.088,439,37.37,455.636,0l9.321,12.3L469.314.641l8.131,10.734L459.291,27.47Z" transform="translate(-303.988)" fill="#E2003C"></path>
                </g>
            </svg>
            <span style='font-size: 12px; color: gray;'>Powered by Motus Holdings</span>
        </span>
    </div>
""", unsafe_allow_html=True)

# 🔁 Get or create a thread ID
def get_or_create_thread_id():
    doc_ref = db.collection("users").document(user_id)
    doc = doc_ref.get()
    if doc.exists:
        return doc.to_dict()["thread_id"]
    else:
        thread = client.beta.threads.create()
        doc_ref.set({"thread_id": thread.id, "created_at": firestore.SERVER_TIMESTAMP})
        return thread.id

# 💾 Save a message
def save_message(role, content):
    db.collection("users").document(user_id).collection("messages").add({
        "role": role,
        "content": content,
        "timestamp": firestore.SERVER_TIMESTAMP
    })

# 💬 Display chat history
def display_chat_history():
    messages = db.collection("users").document(user_id).collection("messages").order_by("timestamp").stream()
    for msg in list(messages)[::-1]:
        data = msg.to_dict()
        if data["role"] == "user":
            st.markdown(f"<div class='stChatMessage' data-testid='stChatMessage-user'>👤 <strong>You:</strong> {data['content']}</div>", unsafe_allow_html=True)
        else:
            st.markdown(f"<div class='stChatMessage' data-testid='stChatMessage-assistant'><strong>Motus Assistant:</strong> {data['content']}</div>", unsafe_allow_html=True)

# 🚀 Main Chat UI
input_col, clear_col = st.columns([9, 1])
with input_col:
    user_input = st.chat_input("Type your message here...")

with clear_col:
    if st.button("🗑️", key="clear-chat", help="Clear Chat"):
        try:
            user_doc_ref = db.collection("users").document(user_id)
            for msg in user_doc_ref.collection("messages").stream():
                msg.reference.delete()
            user_doc_ref.delete()
            st.session_state.clear()
            st.rerun()
        except Exception as e:
            st.error(f"Failed to clear chat: {e}")

thread_id = get_or_create_thread_id()
display_chat_history()

if user_input:
    client.beta.threads.messages.create(thread_id=thread_id, role="user", content=user_input)
    save_message("user", user_input)

    with st.spinner("Thinking and typing... 💭"):
        run = client.beta.threads.runs.create(thread_id=thread_id, assistant_id=assistant_id)
        while True:
            run_status = client.beta.threads.runs.retrieve(thread_id=thread_id, run_id=run.id)
            if run_status.status == "completed":
                break
            time.sleep(1)

    messages_response = client.beta.threads.messages.list(thread_id=thread_id)
    latest_response = sorted(messages_response.data, key=lambda x: x.created_at)[-1]
    assistant_message = latest_response.content[0].text.value

    save_message("assistant", assistant_message)
    time.sleep(0.5)
    st.rerun()