Changes in file structures.

app.py

@@ -1,109 +0,0 @@
-import streamlit as st
-import requests
-import uuid
-
-st.set_page_config(page_title="Text2SQL Agent", layout="wide")
-
-BACKEND_URL = "http://localhost:8000"
-
-if "user_id" not in st.session_state:
-    st.session_state.user_id = str(uuid.uuid4())[:8]
-
-if "thread_id" not in st.session_state:
-    st.session_state.thread_id = str(uuid.uuid4())
-
-if "db_connected" not in st.session_state:
-    st.session_state.db_connected = False
-
-if "connection_url" not in st.session_state:
-    st.session_state.connection_url = ""
-
-if "messages" not in st.session_state:
-    st.session_state.messages = []
-
-st.sidebar.markdown("---")
-st.sidebar.subheader("Database")
-
-connection_url_input = st.sidebar.text_input(
-    "Database connection URL",
-    value=st.session_state.connection_url,
-    type="password",
-    disabled=st.session_state.db_connected,
-    placeholder="postgresql://user:pass@host:5432/dbname",
-)
-
-if not st.session_state.db_connected:
-    if st.sidebar.button("Connect database", use_container_width=True):
-        if not connection_url_input.strip():
-            st.sidebar.error("Enter a connection URL first.")
-        else:
-            with st.spinner("Ingesting schema..."):
-                try:
-                    resp = requests.post(
-                        f"{BACKEND_URL}/upload",
-                        json={
-                            "connection_url": connection_url_input,
-                            "user_id": st.session_state.user_id,
-                        },
-                        timeout=60,
-                    )
-                    resp.raise_for_status()
-                    st.session_state.connection_url = connection_url_input
-                    st.session_state.db_connected = True
-                    st.sidebar.success("Database connected.")
-                    st.rerun()
-                except requests.exceptions.RequestException as e:
-                    st.sidebar.error(f"Upload failed: {e}")
-else:
-    st.sidebar.success("Database connected.")
-    if st.sidebar.button("Disconnect / change database", use_container_width=True):
-        st.session_state.db_connected = False
-        st.session_state.connection_url = ""
-        st.session_state.messages = []
-        st.session_state.thread_id = str(uuid.uuid4())
-        st.rerun()
-
-st.sidebar.markdown("---")
-if st.sidebar.button("Clear conversation", use_container_width=True):
-    st.session_state.messages = []
-    st.session_state.thread_id = str(uuid.uuid4())
-    st.rerun()
-
-st.title("Text2SQL Agent")
-
-if not st.session_state.db_connected:
-    st.info("Connect a database from the sidebar to start chatting.")
-    st.stop()
-
-for msg in st.session_state.messages:
-    with st.chat_message(msg["role"]):
-        st.markdown(msg["content"])
-
-user_input = st.chat_input("Ask a question about your data...")
-
-if user_input:
-    st.session_state.messages.append({"role": "user", "content": user_input})
-    with st.chat_message("user"):
-        st.markdown(user_input)
-
-    with st.chat_message("assistant"):
-        with st.spinner("Thinking..."):
-            try:
-                resp = requests.post(
-                    f"{BACKEND_URL}/chat",
-                    json={
-                        "connection_url": st.session_state.connection_url,
-                        "message": user_input,
-                        "user_id": st.session_state.user_id,
-                        "thread_id": st.session_state.thread_id,
-                    },
-                    timeout=120,
-                )
-                resp.raise_for_status()
-                answer = resp.json().get("response", "No response received.")
-            except requests.exceptions.RequestException as e:
-                answer = f"Error reaching the agent: {e}"
-
-            st.markdown(answer)
-
-    st.session_state.messages.append({"role": "assistant", "content": answer})