Update src/app.py

src/app.py

@@ -7,13 +7,6 @@ import json
 import streamlit as st
 import requests
 
-# In Hugging Face, 127.0.0.1 is used because the services are in the same container.
-# Scanning from environmental variables for AWS or Docker Compose.
-# app.py (Arayüz)
-import os
-import streamlit as st
-
-# 127.0.0.1 yerine 0.0.0.0 kullanarak Docker içindeki iç ağ sorununu çözüyoruz
 API_URL = "http://127.0.0.1:8000"
 
 # ─────────────────────────────────────────────────────────────
@@ -32,19 +25,18 @@ desteklenecektir.
 • Bal ve diğer arıcılık ürünlerinin işlenmesi ve paketlenmesi için, yararlanıcı, başvuru sırasında 5996 sayılı Veteriner
 Hizmetleri, Bitki Sağlığı, Gıda ve Yem Kanununa uygun gerekli üretim ve kayıt sertifikalarına sahip olmalıdır. Yeni
 işletmeler için bu prosedür nihai ödeme talebi sırasında tamamlanmalıdır.
-
 **Kaynak:** Tedbir 302 - Başvuru Çağrı Rehberi""",
         "sources": []
     },
     "Başvuru için gerekli belgeler nelerdir?": {
-        "answer": """Başvuru sahibi aşağıdaki bilgi ve belgeleri “Başvuru Paketi” şeklinde sunmak zorundadır.
+        "answer": """Başvuru sahibi aşağıdaki bilgi ve belgeleri "Başvuru Paketi" şeklinde sunmak zorundadır.
 Başvuru Paketi;
 (a) Başvuru Formu ve ekleri,
 (b) İ ş Planı,
-(c) Teknik Proje’den oluşmaktadır.
-“Başvuru Paketi”nin içeriğinde yer alan belgelere ilişkin ayrıntılı bilgiler ve dikkat edilmesi gereken hususlar TKDK
-web adresinde (www.tkdk.gov.tr) yayımlanan “Başvuru Paketi İçeriği”nde belirtilmiştir.
-İçerisinde “Başvuru Formu, Seçilen ve Seçilmeyen Teklifler, İş Planı ve Teknik Proje” yer almayan başvuru paketleri
+(c) Teknik Proje'den oluşmaktadır.
+"Başvuru Paketi"nin içeriğinde yer alan belgelere ilişkin ayrıntılı bilgiler ve dikkat edilmesi gereken hususlar TKDK
+web adresinde (www.tkdk.gov.tr) yayımlanan "Başvuru Paketi İçeriği"nde belirtilmiştir.
+İçerisinde "Başvuru Formu, Seçilen ve Seçilmeyen Teklifler, İş Planı ve Teknik Proje" yer almayan başvuru paketleri
 TKDK tarafından teslim alınmayacak ve başvuru kaydı yapılmayacaktır.
 Başvuru paketleri hazırlanırken, TKDK web adresinde (www.tkdk.gov.tr) yayımlanan;
 • Yatırım Kapsamında Uyulması Gereken Koşullar,
@@ -53,9 +45,7 @@ Başvuru paketleri hazırlanırken, TKDK web adresinde (www.tkdk.gov.tr) yayıml
 • İ ş Planı Hazırlama Rehberi,
 • Görünürlük Rehberi.
 • Bilgilendirme Dokümanlarında belirtilen hususlar dikkate alınmalıdır.
-
 Belge listesi başvurulan tedbir ve sektöre göre değişmektedir. Güncel ve kesin liste için ilgili çağrı rehberini incelemenizi tavsiye ederiz.
-
 **Kaynak:** Tedbir 101/103/302 - Başvuru Çağrı Rehberleri""",
         "sources": []
     },
@@ -64,7 +54,6 @@ Belge listesi başvurulan tedbir ve sektöre göre değişmektedir. Güncel ve k
 Paketinde (ÖTP) belirtilen verileri doğrulamak ve yatırımın uygulama süresi
 boyunca faydalanıcıya ait taahhütlerin ve yükümlülüklerin yerine getirilip
 getirilmediğini kontrol etmektir.
-
 **Kaynak:** IPARD III - Ödeme Öncesi Yerinde Kontrol Süreci Ve E3 Harcama Beyani Formu İçin Yönlendirici Rehber""",
         "sources": []
     },
@@ -88,15 +77,12 @@ if "legal_accept" not in st.session_state:
 if not st.session_state.legal_accept:
     st.markdown("""
     ## ⚠️ Kullanım Bilgilendirmesi
-
     Bu uygulama IPARD III belgeleri üzerinde çalışan **yapay zeka destekli bir bilgi sistemidir**.
-
     - Verilen yanıtlar otomatik oluşturulur.
     - Resmi kurum görüşü değildir.
     - Nihai ve bağlayıcı bilgi TKDK resmi belgeleridir.
     - Bu sistem bağımsız geliştirilmiştir ve kurumla resmi bir bağı yoktur.
     - Yalnızca kamuya açık belgeler kullanılır.
-
     Devam ederek bu koşulları kabul etmiş olursunuz.
     """)
 
@@ -126,7 +112,6 @@ st.markdown("""
 # Title and Warning
 # ─────────────────────────────────────────────────────────────
 st.markdown('<div class="main-header"><h1>🌾 IPARD III Belge Asistanı</h1><p>🤖 Yapay zeka destekli belge arama ve özetleme sistemi</p></div>', unsafe_allow_html=True)
-
 st.markdown('<div class="disclaimer">⚠️ <b>Sorumluluk Reddi:</b> Bu uygulama bağımsız bir sistemdir. Yanıtlar otomatiktir ve <b>resmi kurum görüşü değildir</b>. Nihai bilgi için <a href="https://www.tkdk.gov.tr" target="_blank">tkdk.gov.tr</a> esas alınmalıdır.</div>', unsafe_allow_html=True)
 
 # ─────────────────────────────────────────────────────────────
@@ -149,7 +134,6 @@ with st.sidebar:
     ]:
         if st.button(ex, use_container_width=True):
             if ex in HARDCODED_ANSWERS:
-                # Direkt hardcoded cevabı göster, API çağrısı yapma
                 hardcoded = HARDCODED_ANSWERS[ex]
                 st.session_state.history.insert(0, {
                     "query": ex,
@@ -165,36 +149,69 @@ with st.sidebar:
 # ─────────────────────────────────────────────────────────────
 # Question Input and Processing
 # ─────────────────────────────────────────────────────────────
-if "history" not in st.session_state: st.session_state.history = []
+if "history" not in st.session_state:
+    st.session_state.history = []
 
 query = st.text_area("Sorunuz", value=st.session_state.get("query_input", ""), height=90, placeholder="IPARD III hakkında merak ettiğiniz her şeyi sorabilirsiniz...")
 submit = st.button("🔍 Yapay Zekaya Sor", use_container_width=True)
 
 if submit and query.strip():
     st.session_state["query_input"] = ""
+    st.markdown(f"**🙋 Soru:** {query}")
+    answer_placeholder = st.empty()
+    answer_text = ""
+    sources_received = []
+    elapsed_ms = 0
+    success = False
+
     try:
-        # If the model in the backend expects a 'measure', we send it accordingly.
-        with requests.post(f"{API_URL}/query/stream", json={"query": query, "measure": selected_tedbir, "doc_type": selected_doc_type}, stream=True, timeout=120) as resp:
+        with requests.post(
+            f"{API_URL}/query/stream",
+            json={"query": query, "measure": selected_tedbir, "doc_type": selected_doc_type},
+            stream=True,
+            timeout=120
+        ) as resp:
             resp.raise_for_status()
-            st.markdown(f"**🙋 Soru:** {query}")
-            answer_placeholder = st.empty()
-            answer_text = ""
-            sources_received = []
 
             for line in resp.iter_lines():
-                if not line: continue
+                if not line:
+                    continue
                 line = line.decode("utf-8")
-                if not line.startswith("data: "): continue
+                if not line.startswith("data: "):
+                    continue
                 event = json.loads(line[6:])
 
-                if event["type"] == "sources": sources_received = event["sources"]
+                if event["type"] == "sources":
+                    sources_received = event["sources"]
                 elif event["type"] == "token":
                     answer_text += event["text"]
-                    answer_placeholder.markdown(f'<div class="answer-box">{answer_text}▌</div>', unsafe_allow_html=True)
+                    answer_placeholder.markdown(
+                        f'<div class="answer-box">{answer_text}▌</div>',
+                        unsafe_allow_html=True
+                    )
                 elif event["type"] == "done":
-                    answer_placeholder.markdown(f'<div class="answer-box">{answer_text}</div>', unsafe_allow_html=True)
-                    st.session_state.history.insert(0, {"query": query, "answer": answer_text, "sources": sources_received, "elapsed": event.get("elapsed_ms", 0)})
-                    st.rerun()
+                    elapsed_ms = event.get("elapsed_ms", 0)
+                    success = True
+                elif event["type"] == "error":
+                    st.error(f"Hata: {event.get('detail', 'Bilinmeyen hata')}")
+                    break
+
+        # Streaming bitti, son hali göster ve history'e ekle
+        if answer_text:
+            answer_placeholder.markdown(
+                f'<div class="answer-box">{answer_text}</div>',
+                unsafe_allow_html=True
+            )
+            st.session_state.history.insert(0, {
+                "query": query,
+                "answer": answer_text,
+                "sources": sources_received,
+                "elapsed": elapsed_ms
+            })
+            st.rerun()
+        elif success and not answer_text:
+            answer_placeholder.warning("Model boş cevap döndürdü.")
+
     except Exception as e:
         st.error(f"Bağlantı hatası: {e}. Lütfen servislerin çalıştığından emin olun.")
 
@@ -207,7 +224,6 @@ for item in st.session_state.history:
         st.markdown(f'<div class="answer-box">{item["answer"]}</div>', unsafe_allow_html=True)
         with st.expander(f"📄 Kaynaklar ({len(item['sources'])})"):
             for s in item["sources"]:
-                # hybrid_score zaten 0-1 arası normalize (rerank %60 + rrf %40)
                 norm  = s.get("hybrid_score") or max(0.0, min(1.0, (s.get("rerank_score", 0) - (-10)) / 12))
                 pct   = int(norm * 100)
                 color = "#2d8a45" if pct >= 60 else "#e6a817" if pct >= 40 else "#c0392b"