map interactive poi eklendi

app.py

@@ -1,329 +1,130 @@
 import os
+import math
 import gradio as gr
-import geopandas as gpd
-import folium
-
-# osmnx isteğe bağlı (fallback için)
-try:
-    import osmnx as ox
-except ImportError:
-    ox = None
-
 from huggingface_hub import InferenceClient, login
 
-# ================
-# HF TOKEN & MODEL
-# ================
+# ---- HF token & login integration ----
 HF_TOKEN = (os.environ.get("HUGGINGFACE_HUB_TOKEN", "") or "").strip()
+
 if HF_TOKEN:
     login(token=HF_TOKEN)
 else:
-    print("UYARI: HUGGINGFACE_HUB_TOKEN bulunamadı, kamuya açık modellerle sınırlı olabilirsiniz.")
+    print("UYARI: HF_TOKEN / HUGGINGFACE_HUB_TOKEN bulunamadı, gated modellere erişilemeyebilir.")
 
+# Create a single shared client (reuse across requests)
 client = InferenceClient(
     model="openai/gpt-oss-20b",
-    token=HF_TOKEN if HF_TOKEN else None,
+    token=HF_TOKEN if HF_TOKEN else None,  # will still work for public models without token
 )
 
-# =========================
-#  ÖNCEDEN HAZIRLANMIŞ OSM VERİSİ
-# =========================
-NEIGH_PATH = "data/neighborhoods.geojson"
-POIS_PATH = "data/pois.geojson"
-
-if not (os.path.exists(NEIGH_PATH) and os.path.exists(POIS_PATH)):
-    print("UYARI: data/ klasöründe neighborhoods.geojson / pois.geojson bulunamadı!")
-    neighborhoods_gdf = None
-    pois_gdf = None
-else:
-    neighborhoods_gdf = gpd.read_file(NEIGH_PATH)
-    pois_gdf = gpd.read_file(POIS_PATH)
-    print(f"{len(neighborhoods_gdf)} mahalle/semt, {len(pois_gdf)} POI yüklendi.")
-
-
-DEFAULT_TAGS = {
-    "amenity": ["school", "pharmacy", "hospital", "restaurant", "cafe", "bank"],
-    "leisure": ["park", "playground"],
-    "shop": True,
-}
-
-
-# =========================
-#  OSM / CBS FONKSİYONLARI
-# =========================
-def get_neighborhood_gdf(city: str, neighborhood: str):
-    if neighborhoods_gdf is not None:
-        mask = (
-            (neighborhoods_gdf["city"] == city)
-            & (neighborhoods_gdf["neighborhood"] == neighborhood)
-        )
-        gdf_local = neighborhoods_gdf[mask]
-        if gdf_local is not None and len(gdf_local) > 0:
-            return gdf_local
-
-    if ox is None:
-        print("OSM fallback kullanılamıyor: osmnx yüklü değil.")
-        return None
-
-    query = f"{neighborhood}, {city}, Türkiye"
-    print(f"OSM fallback: {query}")
-    try:
-        gdf_osm = ox.geocode_to_gdf(query)
-    except Exception as e:
-        print("Mahalle geocode hatası (OSM fallback):", e)
-        return None
-
-    if gdf_osm is None or len(gdf_osm) == 0:
-        return None
-
-    gdf_osm = gdf_osm.copy()
-    gdf_osm["city"] = city
-    gdf_osm["neighborhood"] = neighborhood
-    return gdf_osm
-
-
-def get_pois_within(gdf, tags=None):
-    if gdf is None:
-        return None
-
-    if tags is None:
-        tags = DEFAULT_TAGS
-
-    if pois_gdf is not None and "city" in gdf.columns and "neighborhood" in gdf.columns:
-        row = gdf.iloc[0]
-        city = row["city"]
-        neighborhood = row["neighborhood"]
-
-        mask = (
-            (pois_gdf["city"] == city)
-            & (pois_gdf["neighborhood"] == neighborhood)
-        )
-        pois_local = pois_gdf[mask]
-
-        if pois_local is not None and len(pois_local) > 0:
-            return pois_local
+# ==========================================
+#  ÖRNEK POI VERİSİ
+#  (BUNU KENDİ OSM / GEOJSON VERİNLE DEĞİŞTİREBİLİRSİN)
+# ==========================================
+POIS = [
+    {"name": "Kafemiz", "lat": 41.0380, "lon": 29.0000, "type": "cafe"},
+    {"name": "Parkımız", "lat": 41.0390, "lon": 29.0020, "type": "park"},
+    {"name": "Eczanemiz", "lat": 41.0375, "lon": 29.0010, "type": "pharmacy"},
+]
+
+# Öneri:
+# Kendi pois_gdf GeoDataFrame'inden şu şekilde liste üretebilirsin:
+# POIS = [
+#     {
+#         "name": row.get("name", "POI"),
+#         "lat": row.geometry.y,
+#         "lon": row.geometry.x,
+#         "type": row.get("amenity") or row.get("leisure") or row.get("shop")
+#     }
+#     for _, row in pois_gdf.iterrows()
+# ]
+
+
+# ==========================================
+#  HARİTADA TIKLANAN NOKTAYA EN YAKIN POI'Yİ BULMA
+# ==========================================
+def haversine(lat1, lon1, lat2, lon2):
+    """Yaklaşık metre cinsinden mesafe (küçük alanlar için yeterli)."""
+    R = 6371000  # metre
+    dlat = math.radians(lat2 - lat1)
+    dlon = math.radians(lon2 - lon1)
+    a = (
+        math.sin(dlat / 2) ** 2
+        + math.cos(math.radians(lat1))
+        * math.cos(math.radians(lat2))
+        * math.sin(dlon / 2) ** 2
+    )
+    c = 2 * math.atan2(math.sqrt(a), math.sqrt(1 - a))
+    return R * c
 
-    if ox is None:
-        print("OSM POI fallback kullanılamıyor: osmnx yüklü değil.")
-        return None
 
-    try:
-        polygon = gdf.geometry.iloc[0]
-        pois_osm = ox.features_from_polygon(polygon, tags)
-        return pois_osm
-    except Exception as e:
-        print("POI hatası (OSM fallback):", e)
+def find_nearest_poi(click_lat, click_lon, pois, max_dist_m=300):
+    """
+    Tıklanan koordinata en yakın POI'yi bul.
+    max_dist_m üstünde ise None döndür.
+    """
+    if not pois:
         return None
 
+    best = None
+    best_dist = None
 
-def summarize_pois(gdf, pois):
-    summary = {}
-
-    try:
-        area_m2 = gdf.to_crs(epsg=3857).geometry.iloc[0].area
-        summary["alan_m2"] = float(area_m2)
-        summary["alan_km2"] = float(area_m2 / 1_000_000)
-    except Exception as e:
-        print("Alan hesaplama hatası:", e)
-        summary["alan_m2"] = None
-        summary["alan_km2"] = None
-
-    if pois is None or len(pois) == 0:
-        summary["toplam_poi"] = 0
-        return summary
+    for poi in pois:
+        d = haversine(click_lat, click_lon, poi["lat"], poi["lon"])
+        if best is None or d < best_dist:
+            best = poi
+            best_dist = d
 
-    summary["toplam_poi"] = int(len(pois))
+    if best_dist is not None and best_dist <= max_dist_m:
+        best = dict(best)  # orijinal listeyi bozmamak için kopya
+        best["distance_m"] = round(best_dist, 1)
+        return best
 
-    if "amenity" in pois.columns:
-        for k, v in pois["amenity"].value_counts().to_dict().items():
-            summary[f"amenity_{k}"] = int(v)
+    return None
 
-    if "leisure" in pois.columns:
-        for k, v in pois["leisure"].value_counts().to_dict().items():
-            summary[f"leisure_{k}"] = int(v)
 
-    if "shop" in pois.columns:
-        for k, v in pois["shop"].value_counts().to_dict().items():
-            summary[f"shop_{k}"] = int(v)
+# ==========================================
+#  HARİTA TIKLAMA CALLBACK'İ
+# ==========================================
+def on_map_click(map_value, poi_state):
+    """
+    map_value: gr.Map'in değeri.
+    mode="point" olduğunda genelde [lat, lon] olarak gelir.
+    poi_state: State içindeki POI listesi.
+    """
+    if not map_value or len(map_value) < 2:
+        return "Haritada geçerli bir nokta seçilemedi.", ""
 
-    return summary
+    click_lat, click_lon = map_value[0], map_value[1]
+    poi = find_nearest_poi(click_lat, click_lon, poi_state)
 
+    if poi is None:
+        info_text = "Yakında (örn. 300 m içinde) POI bulunamadı."
+        return info_text, ""
 
-def build_stats_text(summary: dict) -> str:
-    if not summary:
-        return "Veri bulunamadı."
+    info_text = (
+        f"Seçilen POI:\n"
+        f"- Ad: {poi.get('name', 'Bilinmiyor')}\n"
+        f"- Tür: {poi.get('type', 'bilinmiyor')}\n"
+        f"- Uzaklık: {poi.get('distance_m', '?')} m"
+    )
 
-    alan = summary.get("alan_km2", 0) or 0.0
-    toplam_poi = summary.get("toplam_poi", 0)
-    okul = summary.get("amenity_school", 0)
-    park = summary.get("leisure_park", 0)
-    eczane = summary.get("amenity_pharmacy", 0)
-    cafe = summary.get("amenity_cafe", 0)
-    restoran = summary.get("amenity_restaurant", 0)
+    # LLM bağlamı
+    poi_context = (
+        "Kullanıcı haritada bir POI seçti.\n"
+        f"Ad: {poi.get('name')}\n"
+        f"Tür: {poi.get('type')}\n"
+        f"Konum: (lat={poi.get('lat')}, lon={poi.get('lon')})\n"
+        f"Tıklama noktasına uzaklık: {poi.get('distance_m', '?')} m.\n"
+        "Kullanıcı bu yerle ilgili soru sorarsa bu bilgileri kullanarak cevap ver."
+    )
 
-    lines = [
-        f"- Tahmini alan: {alan:.2f} km²",
-        f"- Toplam POI (ilgi noktası): {toplam_poi}",
-        f"- Okul sayısı: {okul}",
-        f"- Park sayısı: {park}",
-        f"- Eczane sayısı: {eczane}",
-        f"- Kafe sayısı: {cafe}",
-        f"- Restoran sayısı: {restoran}",
-    ]
-    return "\n".join(lines)
+    return info_text, poi_context
 
 
-def create_map(gdf, pois):
-    """
-    Mahalle poligonu + POI noktalarını, veri tipine göre
-    farklı katman ve renklerde gösteren Folium haritası.
-    """
-    try:
-        polygon = gdf.geometry.iloc[0]
-        centroid = polygon.centroid
-
-        m = folium.Map(location=[centroid.y, centroid.x], zoom_start=15)
-
-        # --- Mahalle poligonu (tek katman) ---
-        folium.GeoJson(
-            gdf.geometry.__geo_interface__,
-            name="Mahalle"
-        ).add_to(m)
-
-        # POI yoksa direkt döndür
-        if pois is None or len(pois) == 0:
-            folium.LayerControl().add_to(m)
-            return m._repr_html_()
-
-        # Sadece nokta geometriler
-        pois_points = pois[pois.geometry.type == "Point"].copy()
-        if len(pois_points) == 0:
-            folium.LayerControl().add_to(m)
-            return m._repr_html_()
-
-        # -------------------------
-        #  KATMAN / RENK TANIMLARI
-        # -------------------------
-        layer_defs = [
-            ("Okullar",      ("amenity", "school"),      "blue"),
-            ("Hastaneler",   ("amenity", "hospital"),    "red"),
-            ("Eczaneler",    ("amenity", "pharmacy"),    "darkred"),
-            ("Kafeler",      ("amenity", "cafe"),        "purple"),
-            ("Restoranlar",  ("amenity", "restaurant"),  "orange"),
-            ("Bankalar",     ("amenity", "bank"),        "darkblue"),
-            ("Parklar",      ("leisure", "park"),        "green"),
-            ("Oyun Alanları",("leisure", "playground"),  "lightgreen"),
-            ("Dükkanlar",    ("shop", None),             "cadetblue"),
-        ]
-
-        used_indexes = set()
-
-        for layer_name, (col, value), color in layer_defs:
-            if col not in pois_points.columns:
-                continue
-
-            if value is None:
-                mask = pois_points[col].notna()
-            else:
-                mask = (pois_points[col] == value)
-
-            layer_gdf = pois_points[mask]
-            if layer_gdf.empty:
-                continue
-
-            fg = folium.FeatureGroup(name=layer_name, show=True)
-
-            for idx, row in layer_gdf.iterrows():
-                used_indexes.add(idx)
-                lon, lat = row.geometry.x, row.geometry.y
-
-                # name kolonunda NaN / sayı vs. olabilir → str'e çevir
-                raw_name = row.get("name", layer_name[:-1] if layer_name.endswith("lar") else "POI")
-                name = str(raw_name) if raw_name is not None else "POI"
-
-                popup_lines = [name]
-
-                # biraz daha bilgi ekleyelim – hepsini str'e çeviriyoruz
-                if "amenity" in row and isinstance(row["amenity"], str):
-                    popup_lines.append(f"amenity: {row['amenity']}")
-                if "leisure" in row and isinstance(row["leisure"], str):
-                    popup_lines.append(f"leisure: {row['leisure']}")
-                if "shop" in row and isinstance(row["shop"], str):
-                    popup_lines.append(f"shop: {row['shop']}")
-
-                # HER ŞEYİN string olduğundan emin ol
-                popup_lines = [str(x) for x in popup_lines]
-                popup_text = "<br>".join(popup_lines)
-
-                folium.CircleMarker(
-                    location=[lat, lon],
-                    radius=4,
-                    color=color,
-                    fill=True,
-                    fill_opacity=0.8,
-                    popup=folium.Popup(popup_text, max_width=250),
-                ).add_to(fg)
-
-            fg.add_to(m)
-
-        # Diğer POI'ler
-        others = pois_points[~pois_points.index.isin(used_indexes)]
-        if not others.empty:
-            fg_other = folium.FeatureGroup(name="Diğer POI'ler", show=False)
-            for _, row in others.iterrows():
-                lon, lat = row.geometry.x, row.geometry.y
-                raw_name = row.get("name", "POI")
-                name = str(raw_name) if raw_name is not None else "POI"
-                folium.CircleMarker(
-                    location=[lat, lon],
-                    radius=3,
-                    color="gray",
-                    fill=True,
-                    fill_opacity=0.6,
-                    popup=name,
-                ).add_to(fg_other)
-            fg_other.add_to(m)
-
-        folium.LayerControl().add_to(m)
-        return m._repr_html_()
-
-    except Exception as e:
-        msg = f"Harita oluşturulurken hata oluştu: {repr(e)}"
-        print("HARITA HATASI:", msg)
-        return f"<pre>{msg}</pre>"
-
-
-
-# =========================
-#  GRADIO YARDIMCI FONKSİYONLARI
-# =========================
-def load_osm_context(city, neighborhood):
-    """
-    Butona basıldığında:
-    - mahalle çokgenini bul
-    - POI'leri al
-    - özet çıkar
-    - harita HTML + LLM için bağlam döndür
-    """
-    if not city or not neighborhood:
-        return "<b>Lütfen şehir ve mahalle girin.</b>", "Şehir/mahalle girilmedi.", ""
-
-    gdf = get_neighborhood_gdf(city.strip(), neighborhood.strip())
-    if gdf is None or len(gdf) == 0:
-        return "<b>Bu mahalle bulunamadı.</b>", "Bu mahalle için veri bulunamadı.", ""
-
-    pois = get_pois_within(gdf)
-    summary = summarize_pois(gdf, pois)
-    stats_text = build_stats_text(summary)
-    map_html = create_map(gdf, pois)
-
-    # LLM için bağlam:
-    llm_context = (
-        f"Şehir: {city}, Mahalle: {neighborhood}\n"
-        f"Bu mahalle için sayısal özet:\n{stats_text}"
-    )
-    return map_html, stats_text, llm_context
-
+# ==========================================
+#  LLM SOHBET FONKSİYONU
+# ==========================================
 def respond(
     message,
     history,
@@ -331,23 +132,34 @@ def respond(
     max_tokens,
     temperature,
     top_p,
-    osm_context,  # gr.State ile gelecek
+    poi_context,  # <<< harita ile seçilen POI bağlamı buradan geliyor
 ):
-    # OSM bağlamını sistem mesajına ekle
+    """
+    Streaming chat using Hugging Face Inference API.
+    History is a list of {"role": "...", "content": "..."} dicts.
+    """
+
+    # Güvenli aralığa çek (model: max 2)
+    temperature = max(0.0, min(2.0, float(temperature)))
+    top_p = max(0.0, min(1.0, float(top_p)))
+
+    # System mesajına POI bağlamını ekle
     full_system = system_message
-    if osm_context:
+    if poi_context:
         full_system += (
-            "\n\nAşağıda, konuştuğumuz mahalleyle ilgili "
-            "coğrafi ve POI istatistikleri var. "
-            "Kullanıcı soru sorarsa bunlara dayanarak cevap ver:\n"
-            f"{osm_context}"
+            "\n\nAşağıda kullanıcının haritada seçtiği yer ile ilgili bilgiler var.\n"
+            "Kullanıcı bu yer hakkında soru sorarsa bu bağlamı kullanarak cevap ver:\n"
+            f"{poi_context}"
         )
 
+    # Build messages list
     messages = [{"role": "system", "content": full_system}]
     messages.extend(history)
     messages.append({"role": "user", "content": message})
 
     response = ""
+
+    # Stream tokens from the model
     for chunk in client.chat_completion(
         messages=messages,
         max_tokens=max_tokens,
@@ -363,24 +175,28 @@ def respond(
         response += token_text
         yield response
 
-# =========================
-#  GRADIO ARAYÜZÜ
-# =========================
+
+# ==========================================
+#  GRADIO ARAYÜZÜ (SOL CHAT, SAĞ HARİTA)
+# ==========================================
 with gr.Blocks() as demo:
-    gr.Markdown("## OSM Destekli Mahalle Sohbet Botu")
+    gr.Markdown("## Haritada POI Seçen Basit Chat Botu")
 
-    # OSM bağlamını saklamak için state
-    osm_state = gr.State("")
+    # State'ler: POI listesi + seçilen POI bağlamı
+    poi_state = gr.State(POIS)
+    poi_context = gr.State("")
 
     with gr.Row():
-        # Sol: Chat
+        # SOL SÜTUN: CHAT
         with gr.Column(scale=2):
             chatbot = gr.ChatInterface(
                 respond,
                 type="messages",
+                title="Basit Chat Botu",
+                description="Küçük bir sohbet botu, HF Inference API ile çalışıyor.",
                 additional_inputs=[
                     gr.Textbox(
-                        value="Sen şehir planlama ve mahalleler hakkında bilgi veren yardımsever bir asistansın.",
+                        value="You are a friendly Chatbot.",
                         label="System message",
                     ),
                     gr.Slider(
@@ -391,8 +207,8 @@ with gr.Blocks() as demo:
                         label="Max new tokens",
                     ),
                     gr.Slider(
-                        minimum=0.0,
-                        maximum=2.0,   # <-- en fazla 2 olmalı modele gore
+                        minimum=0.0,   # 0 olabilir
+                        maximum=2.0,   # model en fazla 2'yi destekliyor
                         value=0.7,
                         step=0.1,
                         label="Temperature",
@@ -404,32 +220,39 @@ with gr.Blocks() as demo:
                         step=0.05,
                         label="Top-p (nucleus sampling)",
                     ),
-                    osm_state,  # >>> buradan respond() içine gidiyor
+                    poi_context,  # <<< respond() fonksiyonuna parametre olarak gidiyor
                 ],
             )
 
-        # Sağ: Harita + parametreler
+        # SAĞ SÜTUN: HARİTA
         with gr.Column(scale=1):
-            gr.Markdown("### Mahalle Seçimi / Harita")
+            gr.Markdown("### Haritadan POI Seç")
 
-            city_in = gr.Textbox(label="Şehir", value="İstanbul")
-            neigh_in = gr.Textbox(label="Mahalle / Semt", value="Kadıköy")
+            # POI'lerin ortalama konumunu başlangıç merkezi olarak alalım
+            if POIS:
+                center_lat = sum(p["lat"] for p in POIS) / len(POIS)
+                center_lon = sum(p["lon"] for p in POIS) / len(POIS)
+            else:
+                center_lat, center_lon = 41.038, 29.0  # fallback: İstanbul civarı
 
-            load_btn = gr.Button("Haritayı Yükle")
+            # Kullanıcı tıklayınca [lat, lon] dönen interaktif harita
+            map_comp = gr.Map(
+                label="Harita",
+                value=[center_lat, center_lon],
+                interactive=True,
+            )
 
-            map_html = gr.HTML(label="Harita")
-            stats_box = gr.Textbox(
-                label="Mahalle Özeti (LLM Bağlamı)",
-                lines=8,
+            poi_info_box = gr.Textbox(
+                label="Seçilen POI Bilgisi",
+                lines=6,
             )
 
-            # Buton: OSM verisini yükle, haritayı ve state'i güncelle
-            load_btn.click(
-                fn=load_osm_context,
-                inputs=[city_in, neigh_in],
-                outputs=[map_html, stats_box, osm_state],
+            # Haritada tıklama -> on_map_click
+            map_comp.select(
+                fn=on_map_click,
+                inputs=[map_comp, poi_state],
+                outputs=[poi_info_box, poi_context],
             )
 
 if __name__ == "__main__":
     demo.launch()
-