Update app.py

app.py

@@ -14,112 +14,170 @@ st.set_page_config(page_title="Schlaeger Forrestdale TechDocAIA", layout="wide",
 st.title("📄 Schlaeger Forrestdale Document Assistant")
 st.caption("Explore City of Armadale construction documents using AI + OCR 🧐")
 
-# ------------------ Load API Key and Assistant ID ------------------
-OPENAI_API_KEY = os.environ.get("OPENAI_API_KEY")
-ASSISTANT_ID = os.environ.get("ASSISTANT_ID")
+# ------------------ Tabs ------------------
+tab1, tab2 = st.tabs(["📑 Contract", "📁 Technical"])
 
-if not OPENAI_API_KEY or not ASSISTANT_ID:
-    st.error("❌ Missing secrets. Please set both OPENAI_API_KEY and ASSISTANT_ID in Hugging Face Space secrets.")
+# ------------------ API Key ------------------
+OPENAI_API_KEY = os.environ.get("OPENAI_API_KEY")
+if not OPENAI_API_KEY:
+    st.error("❌ OPENAI_API_KEY missing in environment variables.")
     st.stop()
-
 client = OpenAI(api_key=OPENAI_API_KEY)
 
-# ------------------ Session State Initialization ------------------
-if "messages" not in st.session_state:
-    st.session_state.messages = []
-if "thread_id" not in st.session_state:
-    st.session_state.thread_id = None
-if "pending_prompt" not in st.session_state:
-    st.session_state.pending_prompt = None
-if "results" not in st.session_state:
-    st.session_state.results = []
-if "lightbox_url" not in st.session_state:
-    st.session_state.lightbox_url = None
-
-# ------------------ Sidebar ------------------
-st.sidebar.header("ℹ️ Information")
-if st.sidebar.button("🧹 Clear Chat"):
-    st.session_state.messages = []
-    st.session_state.thread_id = None
-    st.session_state.pending_prompt = None
-    st.session_state.results = []
-    st.session_state.lightbox_url = None
-    st.rerun()
-
-# ------------------ Chat Input ------------------
-user_prompt = st.chat_input("Ask about plans, drawings or components")
-if user_prompt:
-    st.session_state.messages.append({"role": "user", "content": user_prompt})
-
-# ------------------ Assistant Query ------------------
-if st.session_state.messages and st.session_state.messages[-1]["role"] == "user":
-    try:
-        if st.session_state.thread_id is None:
-            thread = client.beta.threads.create()
-            st.session_state.thread_id = thread.id
-
-        client.beta.threads.messages.create(
-            thread_id=st.session_state.thread_id,
-            role="user",
-            content=st.session_state.messages[-1]["content"]
-        )
-
-        run = client.beta.threads.runs.create(
-            thread_id=st.session_state.thread_id,
-            assistant_id=ASSISTANT_ID
-        )
-
-        with st.spinner("🤖 Parsing and responding..."):
-            while True:
-                run_status = client.beta.threads.runs.retrieve(
-                    thread_id=st.session_state.thread_id,
-                    run_id=run.id
-                )
-                if run_status.status in ("completed", "failed", "cancelled"):
-                    break
-                time.sleep(1)
-
-        if run_status.status != "completed":
-            st.error(f"⚠️ Assistant failed: {run_status.status}")
-        else:
-            messages = client.beta.threads.messages.list(thread_id=st.session_state.thread_id)
-            for message in reversed(messages.data):
-                if message.role == "assistant":
-                    assistant_reply = message.content[0].text.value
-                    st.session_state.messages.append({"role": "assistant", "content": assistant_reply})
-                    try:
-                        json_data = json.loads(assistant_reply.strip("`json "))
-                        st.session_state.results = json_data
-                    except:
-                        st.session_state.results = []
-                    break
-        st.rerun()
-    except Exception as e:
-        st.error(f"❌ Error: {e}")
-
-# ------------------ Sorting and Filters ------------------
-if st.session_state.results:
+# ------------------ Contract Tab ------------------
+with tab1:
+    ASSISTANT_ID = "asst_KsQRedoJUnEeStzfox1o06lO"
+
+    if "contract_messages" not in st.session_state:
+        st.session_state.contract_messages = []
+    if "contract_thread_id" not in st.session_state:
+        st.session_state.contract_thread_id = None
+    if "contract_image_url" not in st.session_state:
+        st.session_state.contract_image_url = None
+
+    user_input = st.chat_input("Ask about contract clauses, terms, or obligations")
+    if user_input:
+        st.session_state.contract_messages.append({"role": "user", "content": user_input})
+
+    if st.session_state.contract_messages and st.session_state.contract_messages[-1]["role"] == "user":
+        try:
+            if st.session_state.contract_thread_id is None:
+                thread = client.beta.threads.create()
+                st.session_state.contract_thread_id = thread.id
+
+            client.beta.threads.messages.create(
+                thread_id=st.session_state.contract_thread_id,
+                role="user",
+                content=st.session_state.contract_messages[-1]["content"]
+            )
+
+            run = client.beta.threads.runs.create(
+                thread_id=st.session_state.contract_thread_id,
+                assistant_id=ASSISTANT_ID
+            )
+
+            with st.spinner("🤖 Thinking..."):
+                while True:
+                    run_status = client.beta.threads.runs.retrieve(
+                        thread_id=st.session_state.contract_thread_id,
+                        run_id=run.id
+                    )
+                    if run_status.status in ("completed", "failed", "cancelled"):
+                        break
+                    time.sleep(1)
+
+            if run_status.status == "completed":
+                messages = client.beta.threads.messages.list(thread_id=st.session_state.contract_thread_id)
+                for msg in reversed(messages.data):
+                    if msg.role == "assistant":
+                        content = msg.content[0].text.value
+                        st.session_state.contract_messages.append({"role": "assistant", "content": content})
+
+                        match = re.search(r'Document Reference:\s*(.*?),\s*Page\s*(\d+)', content)
+                        if match:
+                            doc_name = match.group(1).strip()
+                            page = int(match.group(2))
+                            page_str = f"{page:04d}"
+                            folder = quote(doc_name)
+                            img_url = f"https://raw.githubusercontent.com/AndrewLORTech/c2ozschlaegerforrestdale/main/{folder}/{folder}_page_{page_str}.png"
+                            st.session_state.contract_image_url = img_url
+                        break
+        except Exception as e:
+            st.error(f"Error: {e}")
+
+    for m in st.session_state.contract_messages:
+        with st.chat_message(m["role"]):
+            st.markdown(m["content"], unsafe_allow_html=True)
+
+    if st.session_state.contract_image_url:
+        st.image(st.session_state.contract_image_url, caption="📄 Referenced Contract Page", use_container_width=True)
+
+# ------------------ Technical Tab ------------------
+with tab2:
+    ASSISTANT_ID = "asst_DjvuWBc7tCvMbAhY7n1em4BZ"
+
+    if "tech_messages" not in st.session_state:
+        st.session_state.tech_messages = []
+    if "tech_thread_id" not in st.session_state:
+        st.session_state.tech_thread_id = None
+    if "tech_results" not in st.session_state:
+        st.session_state.tech_results = []
+
+    st.session_state.tech_lightbox = None
+
+    tech_prompt = st.chat_input("Ask about plans, drawings or components")
+    if tech_prompt:
+        st.session_state.tech_messages.append({"role": "user", "content": tech_prompt})
+
+    if st.session_state.tech_messages and st.session_state.tech_messages[-1]["role"] == "user":
+        try:
+            if st.session_state.tech_thread_id is None:
+                thread = client.beta.threads.create()
+                st.session_state.tech_thread_id = thread.id
+
+            client.beta.threads.messages.create(
+                thread_id=st.session_state.tech_thread_id,
+                role="user",
+                content=st.session_state.tech_messages[-1]["content"]
+            )
+
+            run = client.beta.threads.runs.create(
+                thread_id=st.session_state.tech_thread_id,
+                assistant_id=ASSISTANT_ID
+            )
+
+            with st.spinner("🔍 Searching technical drawings..."):
+                while True:
+                    run_status = client.beta.threads.runs.retrieve(
+                        thread_id=st.session_state.tech_thread_id,
+                        run_id=run.id
+                    )
+                    if run_status.status in ("completed", "failed", "cancelled"):
+                        break
+                    time.sleep(1)
+
+            if run_status.status == "completed":
+                messages = client.beta.threads.messages.list(thread_id=st.session_state.tech_thread_id)
+                for msg in reversed(messages.data):
+                    if msg.role == "assistant":
+                        content = msg.content[0].text.value
+                        st.session_state.tech_messages.append({"role": "assistant", "content": content})
+                        try:
+                            json_data = json.loads(content.strip("`json "))
+                            st.session_state.tech_results = json_data
+                        except:
+                            st.session_state.tech_results = []
+                        break
+        except Exception as e:
+            st.error(f"❌ Technical Assistant Error: {e}")
+
     with st.expander("🔧 Options (Filter + Pagination)", expanded=False):
-        disciplines = sorted(set(d.get("discipline", "") for d in st.session_state.results))
+        disciplines = sorted(set(d.get("discipline", "") for d in st.session_state.tech_results))
         selected_discipline = st.selectbox("🌍 Filter by discipline", ["All"] + disciplines)
         page_size = 8
         page_num = st.number_input("Page", min_value=1, step=1, value=1)
 
-    filtered_results = [r for r in st.session_state.results if selected_discipline == "All" or r.get("discipline") == selected_discipline]
-    paged = filtered_results[(page_num - 1) * page_size : page_num * page_size]
-
-    st.markdown("---")
-    st.subheader("📂 Drawing Results")
-    cols = st.columns(4)
-
-    for i, item in enumerate(paged):
-        with cols[i % 4]:
-            st.markdown(f"**{item['drawing_number']}**")
-            st.markdown(f"_Discipline: {item['discipline']}_")
-            st.caption(item.get("summary", ""))
-            for url in item.get("images", [])[:1]:
-                st.image(url, caption=item['drawing_number'], use_container_width=True)
-else:
-    for msg in st.session_state.messages:
-        with st.chat_message(msg["role"]):
-            st.markdown(msg["content"], unsafe_allow_html=True)
+    if st.session_state.tech_results:
+        st.subheader("📂 Drawing Results")
+        filtered = [r for r in st.session_state.tech_results if selected_discipline == "All" or r.get("discipline") == selected_discipline]
+        paged = filtered[(page_num - 1) * page_size : page_num * page_size]
+        cols = st.columns(4)
+
+        for i, item in enumerate(paged):
+            with cols[i % 4]:
+                st.markdown(f"**📁 {item['drawing_number']} ({item['discipline']})**")
+                st.caption(item.get("summary", ""))
+                for url in item.get("images", [])[:1]:
+                    if st.button("🖼️ View Drawing Details", key=f"thumb_{i}"):
+                        st.session_state.tech_lightbox = url
+                    st.image(url, caption=f"{item['drawing_number']} - Page 1", use_container_width=True)
+
+        if st.session_state.tech_lightbox:
+            st.image(st.session_state.tech_lightbox, caption="🔍 Enlarged Drawing Preview", use_container_width=True)
+            if st.button("❌ Close Preview"):
+                st.session_state.tech_lightbox = None
+                st.rerun()
+    else:
+        for msg in st.session_state.tech_messages:
+            with st.chat_message(msg["role"]):
+                st.markdown(msg["content"], unsafe_allow_html=True)