Update app.py

app.py

@@ -6,88 +6,80 @@ import xml.etree.ElementTree as ET
 import schedule
 import time
 import threading
-from huggingface_hub import HfApi, create_repo, hf_hub_download
 import warnings
-import pandas as pd
 from docx import Document
-import spaces
 from google.oauth2.service_account import Credentials
 from googleapiclient.discovery import build
 from googleapiclient.http import MediaIoBaseDownload
 import io
 from requests.packages.urllib3.exceptions import InsecureRequestWarning
-warnings.simplefilter('ignore', InsecureRequestWarning)
 from fastapi import FastAPI, Response
 from fastapi.middleware.cors import CORSMiddleware
-
-
-# Prompt dosyasını import et
+warnings.simplefilter('ignore', InsecureRequestWarning)
 from prompts import get_prompt_content_only
-
-# Enhanced features import et (sadece temel özellikler)
-from enhanced_features import (
-    initialize_enhanced_features, process_image_message, 
-    handle_comparison_request
-)
+from enhanced_features import initialize_enhanced_features, process_image_message, handle_comparison_request
 from image_renderer import extract_product_info_for_gallery, format_message_with_images
-
-# Import conversation tracker
 from conversation_tracker import add_conversation
 
-# === JSON dashboard için yardımcılar ===
 def save_conversations_json():
-    """
-    conversation_tracker.load_conversations() çıktısını
-    hem köke hem public/ altına yazar. Dashboard bunları aynı origin'den çeker
-    ya da standalone HTML CORS açık /api uçlarından alır.
-    """
     try:
         from conversation_tracker import load_conversations
         convs = load_conversations()
-        # kök
         with open("conversations.json", "w", encoding="utf-8") as f:
             json.dump(convs, f, ensure_ascii=False, indent=2)
-        # public/
         os.makedirs("public", exist_ok=True)
         with open("public/conversations.json", "w", encoding="utf-8") as f:
             json.dump(convs, f, ensure_ascii=False, indent=2)
-        print("conversations.json ve public/conversations.json güncellendi.")
     except Exception as e:
         print(f"conversations.json yazma hatası: {e}")
 
-# Import smart warehouse with GPT intelligence and price
 try:
-    from smart_warehouse_with_price import get_warehouse_stock_smart_with_price
-    get_warehouse_stock_smart = get_warehouse_stock_smart_with_price
-except ImportError:
-    try:
-        from smart_warehouse import get_warehouse_stock_smart
-    except ImportError:
-        get_warehouse_stock_smart = None
+    from improved_chatbot import ImprovedChatbot
+    USE_IMPROVED_SEARCH = True
+except ImportError as e:
+    print(f"DEBUG - Improved chatbot not available: {e}, using basic search")
+    USE_IMPROVED_SEARCH = False
+
+LOG_FILE = '/data/chat_logs.txt' if os.path.exists('/data') else 'chat_logs.txt'
+print(f"Dosya yolu: {os.path.abspath(LOG_FILE)}")
+API_URL = "https://api.openai.com/v1/chat/completions"
+OPENAI_API_KEY = os.getenv("OPENAI_API_KEY")
+if not OPENAI_API_KEY:
+    print("Hata: OPENAI_API_KEY çevre değişkeni ayarlanmamış!")
+
+GOOGLE_CREDENTIALS_PATH = os.getenv("GOOGLE_CREDENTIALS_PATH")
+GOOGLE_FOLDER_ID = "1bE8aMj8-eFGftjMPOF8bKQJAhfHa0BN8"
+file_lock = threading.Lock()
+history_lock = threading.Lock()
+global_chat_history = []
+document_content = ""
+products = []
+improved_bot = None
 
 def get_warehouse_stock(product_name):
-    """Use GPT intelligence to find warehouse stock"""
-    # First try GPT-powered search
-    if get_warehouse_stock_smart:
-        result = get_warehouse_stock_smart(product_name)
-        if result:
-            return result
-    
-    # Fallback to old method
+    try:
+        from smart_warehouse_with_price import get_warehouse_stock_smart_with_price
+        s = get_warehouse_stock_smart_with_price(product_name)
+        if s:
+            return s
+    except Exception:
+        try:
+            from smart_warehouse import get_warehouse_stock_smart
+            s = get_warehouse_stock_smart(product_name)
+            if s:
+                return s
+        except Exception:
+            pass
     return get_warehouse_stock_old(product_name)
 
-# OLD warehouse stock finder - general algorithm
 def get_warehouse_stock_old(product_name):
-    """Smart warehouse stock finder with general algorithm"""
     try:
         import re
-        
-        # Get XML with retry
         xml_text = None
         for attempt in range(3):
             try:
                 url = 'https://video.trek-turkey.com/bizimhesap-warehouse-xml-b2b-api-v2.php'
-                timeout_val = 10 + (attempt * 5)  # 10, 15, 20 seconds
+                timeout_val = 10 + (attempt * 5)
                 response = requests.get(url, verify=False, timeout=timeout_val)
                 xml_text = response.text
                 break
@@ -96,30 +88,18 @@ def get_warehouse_stock_old(product_name):
                     return None
             except Exception:
                 return None
-        
-        # Turkish normalize
         def normalize(text):
             tr_map = {'ı': 'i', 'ğ': 'g', 'ü': 'u', 'ş': 's', 'ö': 'o', 'ç': 'c', 'İ': 'i', 'I': 'i'}
             text = text.lower()
             for tr, en in tr_map.items():
                 text = text.replace(tr, en)
             return text
-        
-        # Parse query
         query = normalize(product_name.strip()).replace('(2026)', '').replace('(2025)', '').strip()
         words = query.split()
-        
-        # Find size markers (S, M, L, etc.)
         sizes = ['s', 'm', 'l', 'xl', 'xs', 'xxl', 'ml']
         size = next((w for w in words if w in sizes), None)
-        
-        # Smart filtering: Keep only meaningful product identifiers
         product_words = []
-        
-        # If query is very short (like "hangi boyu"), skip it
-        if len(words) <= 2 and not any(w.isdigit() for w in words):
-            pass
-        else:
+        if len(words) > 2 or any(w.isdigit() for w in words):
             for word in words:
                 if word in sizes:
                     continue
@@ -139,49 +119,35 @@ def get_warehouse_stock_old(product_name):
                     if consonants <= 2:
                         continue
                     product_words.append(word)
-        
-        print(f"DEBUG - Searching: {' '.join(product_words)}, Size: {size}")
-        
-        # Find all Product blocks in XML
-        product_pattern = r'<Product>(.*?)</Product>'
-        all_products = re.findall(product_pattern, xml_text, re.DOTALL)
-        
-        print(f"DEBUG - Total products in XML: {len(all_products)}")
-        
+        import re as _re
+        all_products = _re.findall(r'<Product>(.*?)</Product>', xml_text, _re.DOTALL)
         best_match = None
         for product_block in all_products:
-            name_match = re.search(r'<ProductName><!\[CDATA\[(.*?)\]\]></ProductName>', product_block)
+            name_match = _re.search(r'<ProductName><!\[CDATA\[(.*?)\]\]></ProductName>', product_block)
             if not name_match:
                 continue
-                
             product_name_in_xml = name_match.group(1)
             normalized_xml_name = normalize(product_name_in_xml)
-            
             match = True
             for word in product_words:
                 if word not in normalized_xml_name:
                     if not (word.isdigit() and any(f"{prev}{word}" in normalized_xml_name or f"{prev} {word}" in normalized_xml_name for prev in product_words if not prev.isdigit())):
                         match = False
                         break
-            
             if match:
                 if size:
-                    variant_match = re.search(r'<ProductVariant><!\[CDATA\[(.*?)\]\]></ProductVariant>', product_block)
+                    variant_match = _re.search(r'<ProductVariant><!\[CDATA\[(.*?)\]\]></ProductVariant>', product_block)
                     if variant_match:
                         variant = variant_match.group(1)
                         if variant.upper().startswith(f'{size.upper()}-'):
-                            print(f"DEBUG - Found match: {product_name_in_xml} - {variant}")
                             best_match = product_block
                             break
                 else:
                     best_match = product_block
                     break
-        
         if best_match:
             warehouse_info = []
-            warehouse_regex = r'<Warehouse>.*?<Name><!\[CDATA\[(.*?)\]\]></Name>.*?<Stock>(.*?)</Stock>.*?</Warehouse>'
-            warehouses = re.findall(warehouse_regex, best_match, re.DOTALL)
-            
+            warehouses = _re.findall(r'<Warehouse>.*?<Name><!\[CDATA\[(.*?)\]\]></Name>.*?<Stock>(.*?)</Stock>.*?</Warehouse>', best_match, _re.DOTALL)
             for wh_name, wh_stock in warehouses:
                 try:
                     stock = int(wh_stock.strip())
@@ -197,284 +163,186 @@ def get_warehouse_stock_old(product_name):
                         else:
                             display = wh_name
                         warehouse_info.append(f"{display}: Mevcut")
-                except:
+                except Exception:
                     pass
-            
             return warehouse_info if warehouse_info else ["Hiçbir mağazada mevcut değil"]
         else:
-            print(f"DEBUG - No match found for {' '.join(product_words)}")
             return ["Hiçbir mağazada mevcut değil"]
-            
     except Exception as e:
         print(f"Warehouse error: {e}")
         return None
 
-# Import improved product search
-try:
-    from improved_chatbot import ImprovedChatbot
-    USE_IMPROVED_SEARCH = True
-    print("DEBUG - Improved chatbot loaded successfully")
-except ImportError as e:
-    print(f"DEBUG - Improved chatbot not available: {e}, using basic search")
-    USE_IMPROVED_SEARCH = False
-
-# Gradio uyarılarını bastır
-warnings.filterwarnings("ignore", category=UserWarning, module="gradio.components.chatbot")
-
-# Log dosyası adı ve yolu
-LOG_FILE = '/data/chat_logs.txt' if os.path.exists('/data') else 'chat_logs.txt'
-print(f"Dosya yolu: {os.path.abspath(LOG_FILE)}")
-
-# API ayarları
-API_URL = "https://api.openai.com/v1/chat/completions"
-OPENAI_API_KEY = os.getenv("OPENAI_API_KEY")
-if not OPENAI_API_KEY:
-    print("Hata: OPENAI_API_KEY çevre değişkeni ayarlanmamış!")
-
-# Trek bisiklet ürünlerini çekme
-url = 'https://www.trekbisiklet.com.tr/output/8582384479'
-response = requests.get(url, verify=False, timeout=30)
-if response.status_code == 200 and response.content:
-    root = ET.fromstring(response.content)
-else:
-    print(f"HTTP hatası: {response.status_code}")
-    root = None
-
-products = []
-if root is not None:
-    for item in root.findall('item'):
-        rootlabel_elem = item.find('rootlabel')
-        stock_elem = item.find('stockAmount')
-        if rootlabel_elem is None or stock_elem is None:
-            continue
-            
-        name_words = rootlabel_elem.text.lower().split()
-        name = name_words[0]
-        full_name = ' '.join(name_words)
-        
-        stock_amount = "stokta" if stock_elem.text and stock_elem.text > '0' else "stokta değil"
-        
-        if stock_amount == "stokta":
-            price_elem = item.find('priceTaxWithCur')
-            price_str = price_elem.text if price_elem is not None and price_elem.text else "Fiyat bilgisi yok"
-            price_eft_elem = item.find('priceEft')
-            price_eft_str = price_eft_elem.text if price_eft_elem is not None and price_eft_elem.text else ""
-            price_rebate_elem = item.find('priceRebateWithTax')
-            price_rebate_str = price_rebate_elem.text if price_rebate_elem is not None and price_rebate_elem.text else ""
-            price_rebate_money_order_elem = item.find('priceRebateWithMoneyOrderWithTax')
-            price_rebate_money_order_str = price_rebate_money_order_elem.text if price_rebate_money_order_elem is not None and price_rebate_money_order_elem.text else ""
-            
-            try:
-                price_float = float(price_str)
-                if price_float > 200000:
-                    price = str(round(price_float / 5000) * 5000)
-                elif price_float > 30000:
-                    price = str(round(price_float / 1000) * 1000)
-                elif price_float > 10000:
-                    price = str(round(price_float / 100) * 100)
-                else:
-                    price = str(round(price_float / 10) * 10)
-            except (ValueError, TypeError):
-                price = price_str
-            
-            if price_eft_str:
-                try:
-                    price_eft_float = float(price_eft_str)
-                    if price_eft_float > 200000:
-                        price_eft = str(round(price_eft_float / 5000) * 5000)
-                    elif price_eft_float > 30000:
-                        price_eft = str(round(price_eft_float / 1000) * 1000)
-                    elif price_eft_float > 10000:
-                        price_eft = str(round(price_eft_float / 100) * 100)
-                    else:
-                        price_eft = str(round(price_eft_float / 10) * 10)
-                except (ValueError, TypeError):
-                    price_eft = price_eft_str
-            else:
-                price_eft = ""
-            
-            if price_rebate_str:
-                try:
-                    price_rebate_float = float(price_rebate_str)
-                    if price_rebate_float > 200000:
-                        price_rebate = str(round(price_rebate_float / 5000) * 5000)
-                    elif price_rebate_float > 30000:
-                        price_rebate = str(round(price_rebate_float / 1000) * 1000)
-                    elif price_rebate_float > 10000:
-                        price_rebate = str(round(price_rebate_float / 100) * 100)
-                    else:
-                        price_rebate = str(round(price_rebate_float / 10) * 10)
-                except (ValueError, TypeError):
-                    price_rebate = price_rebate_str
-            else:
-                price_rebate = ""
-            
-            if price_rebate_money_order_str:
+def load_products():
+    out = []
+    try:
+        url = 'https://www.trekbisiklet.com.tr/output/8582384479'
+        response = requests.get(url, verify=False, timeout=30)
+        if response.status_code != 200 or not response.content:
+            return out
+        root = ET.fromstring(response.content)
+        for item in root.findall('item'):
+            rootlabel_elem = item.find('rootlabel')
+            stock_elem = item.find('stockAmount')
+            if rootlabel_elem is None or stock_elem is None or rootlabel_elem.text is None:
+                continue
+            name_words = rootlabel_elem.text.lower().split()
+            if not name_words:
+                continue
+            name = name_words[0]
+            full_name = ' '.join(name_words)
+            stock_amount = "stokta" if stock_elem.text and stock_elem.text > '0' else "stokta değil"
+            if stock_amount == "stokta":
+                price_elem = item.find('priceTaxWithCur')
+                price_str = price_elem.text if price_elem is not None and price_elem.text else "Fiyat bilgisi yok"
+                price_eft_elem = item.find('priceEft')
+                price_eft_str = price_eft_elem.text if price_eft_elem is not None and price_eft_elem.text else ""
+                price_rebate_elem = item.find('priceRebateWithTax')
+                price_rebate_str = price_rebate_elem.text if price_rebate_elem is not None and price_rebate_elem.text else ""
+                price_rebate_money_order_elem = item.find('priceRebateWithMoneyOrderWithTax')
+                price_rebate_money_order_str = price_rebate_money_order_elem.text if price_rebate_money_order_elem is not None and price_rebate_money_order_elem.text else ""
                 try:
-                    price_rebate_money_order_float = float(price_rebate_money_order_str)
-                    if price_rebate_money_order_float > 200000:
-                        price_rebate_money_order = str(round(price_rebate_money_order_float / 5000) * 5000)
-                    elif price_rebate_money_order_float > 30000:
-                        price_rebate_money_order = str(round(price_rebate_money_order_float / 1000) * 1000)
-                    elif price_rebate_money_order_float > 10000:
-                        price_rebate_money_order = str(round(price_rebate_money_order_float / 100) * 100)
+                    price_float = float(price_str)
+                    if price_float > 200000:
+                        price = str(round(price_float / 5000) * 5000)
+                    elif price_float > 30000:
+                        price = str(round(price_float / 1000) * 1000)
+                    elif price_float > 10000:
+                        price = str(round(price_float / 100) * 100)
                     else:
-                        price_rebate_money_order = str(round(price_rebate_money_order_float / 10) * 10)
-                except (ValueError, TypeError):
-                    price_rebate_money_order = price_rebate_money_order_str
-            else:
-                price_rebate_money_order = ""
-            
-            product_url_elem = item.find('productLink')
-            product_url = product_url_elem.text if product_url_elem is not None and product_url_elem.text else ""
-            product_info = [stock_amount, price, product_url, price_eft, price_rebate, price_rebate_money_order]
-            
-            image_elem = item.find('picture1Path')
-            if image_elem is not None and image_elem.text:
-                product_info.append(image_elem.text)
+                        price = str(round(price_float / 10) * 10)
+                except Exception:
+                    price = price_str
+                if price_eft_str:
+                    try:
+                        price_eft_float = float(price_eft_str)
+                        if price_eft_float > 200000:
+                            price_eft = str(round(price_eft_float / 5000) * 5000)
+                        elif price_eft_float > 30000:
+                            price_eft = str(round(price_eft_float / 1000) * 1000)
+                        elif price_eft_float > 10000:
+                            price_eft = str(round(price_eft_float / 100) * 100)
+                        else:
+                            price_eft = str(round(price_eft_float / 10) * 10)
+                    except Exception:
+                        price_eft = price_eft_str
+                else:
+                    price_eft = ""
+                if price_rebate_str:
+                    try:
+                        price_rebate_float = float(price_rebate_str)
+                        if price_rebate_float > 200000:
+                            price_rebate = str(round(price_rebate_float / 5000) * 5000)
+                        elif price_rebate_float > 30000:
+                            price_rebate = str(round(price_rebate_float / 1000) * 1000)
+                        elif price_rebate_float > 10000:
+                            price_rebate = str(round(price_rebate_float / 100) * 100)
+                        else:
+                            price_rebate = str(round(price_rebate_float / 10) * 10)
+                    except Exception:
+                        price_rebate = price_rebate_str
+                else:
+                    price_rebate = ""
+                if price_rebate_money_order_str:
+                    try:
+                        price_rebate_money_order_float = float(price_rebate_money_order_str)
+                        if price_rebate_money_order_float > 200000:
+                            price_rebate_money_order = str(round(price_rebate_money_order_float / 5000) * 5000)
+                        elif price_rebate_money_order_float > 30000:
+                            price_rebate_money_order = str(round(price_rebate_money_order_float / 1000) * 1000)
+                        elif price_rebate_money_order_float > 10000:
+                            price_rebate_money_order = str(round(price_rebate_money_order_float / 100) * 100)
+                        else:
+                            price_rebate_money_order = str(round(price_rebate_money_order_float / 10) * 10)
+                    except Exception:
+                        price_rebate_money_order = price_rebate_money_order_str
+                else:
+                    price_rebate_money_order = ""
+                product_url_elem = item.find('productLink')
+                product_url = product_url_elem.text if product_url_elem is not None and product_url_elem.text else ""
+                product_info = [stock_amount, price, product_url, price_eft, price_rebate, price_rebate_money_order]
+                image_elem = item.find('picture1Path')
+                if image_elem is not None and image_elem.text:
+                    product_info.append(image_elem.text)
+                else:
+                    product_info.append("")
             else:
-                product_info.append("")
-        else:
-            product_info = [stock_amount]
-        
-        products.append((name, product_info, full_name))
-
-print(f"Toplam {len(products)} ürün yüklendi.")
-
-# Initialize enhanced features
-initialize_enhanced_features(OPENAI_API_KEY, products)
-
-# İlk başta dosyaları oluştur (boşsa)
-save_conversations_json()
-
-# Initialize improved chatbot if available
-improved_bot = None
-if USE_IMPROVED_SEARCH:
-    try:
-        improved_bot = ImprovedChatbot(products)
-        print("Improved product search initialized successfully")
+                product_info = [stock_amount]
+            out.append((name, product_info, full_name))
     except Exception as e:
-        print(f"Failed to initialize improved search: {e}")
-        USE_IMPROVED_SEARCH = False
+        print(f"Ürün yükleme hatası: {e}")
+    return out
 
-# Google Drive API ayarları
-GOOGLE_CREDENTIALS_PATH = os.getenv("GOOGLE_CREDENTIALS_PATH")
-GOOGLE_FOLDER_ID = "1bE8aMj8-eFGftjMPOF8bKQJAhfHa0BN8"
-
-# Global değişkenler
-file_lock = threading.Lock()
-history_lock = threading.Lock()
-global_chat_history = []
-document_content = ""
-
-# Google Drive'dan döküman indirme fonksiyonu
 def download_documents_from_drive():
     global document_content
-    
     if not GOOGLE_CREDENTIALS_PATH:
         print("Google credentials dosyası bulunamadı.")
         return
-    
     try:
         credentials = Credentials.from_service_account_file(GOOGLE_CREDENTIALS_PATH)
         service = build('drive', 'v3', credentials=credentials)
-        
-        results = service.files().list(
-            q=f"'{GOOGLE_FOLDER_ID}' in parents",
-            fields="files(id, name, mimeType)"
-        ).execute()
-        
+        results = service.files().list(q=f"'{GOOGLE_FOLDER_ID}' in parents", fields="files(id, name, mimeType)").execute()
         files = results.get('files', [])
         all_content = []
-        
         for file in files:
-            print(f"İndiriliyor: {file['name']}")
-            if file['mimeType'] == 'application/vnd.openxmlformats-officedocument.wordprocessingml.document':
+            if file.get('mimeType') == 'application/vnd.openxmlformats-officedocument.wordprocessingml.document':
                 request = service.files().get_media(fileId=file['id'])
                 file_io = io.BytesIO()
                 downloader = MediaIoBaseDownload(file_io, request)
-                
                 done = False
                 while done is False:
                     status, done = downloader.next_chunk()
-                
                 file_io.seek(0)
                 doc = Document(file_io)
-                
                 content = f"\n=== {file['name']} ===\n"
                 for paragraph in doc.paragraphs:
                     if paragraph.text.strip():
                         content += paragraph.text + "\n"
-                
                 all_content.append(content)
-        
         document_content = "\n".join(all_content)
-        print(f"Toplam {len(files)} döküman yüklendi.")
-        
     except Exception as e:
         print(f"Google Drive'dan döküman indirme hatası: {e}")
 
-# Döküman indirme işlemini arka planda çalıştır
-document_thread = threading.Thread(target=download_documents_from_drive, daemon=True)
-document_thread.start()
-
-# Log dosyasını zamanla temizleme fonksiyonu
 def clear_log_file():
     try:
         if os.path.exists(LOG_FILE):
             with file_lock:
                 with open(LOG_FILE, 'w', encoding='utf-8') as f:
                     f.write("Log dosyası temizlendi.\n")
-            print("Log dosyası temizlendi.")
     except Exception as e:
         print(f"Log dosyası temizleme hatası: {e}")
 
-# Zamanlanmış görevleri çalıştırma fonksiyonu
 def run_scheduler(chat_history):
     schedule.every().day.at("03:00").do(clear_log_file)
     while True:
         schedule.run_pending()
         time.sleep(60)
 
-# Chatbot fonksiyonu
 def chatbot_fn(user_message, history, image=None):
     if history is None:
         history = []
-    
     warehouse_stock_data = None
-    print(f"DEBUG - Getting warehouse stock FIRST for: {user_message}")
     try:
         warehouse_stock_data = get_warehouse_stock(user_message)
-        if warehouse_stock_data:
-            print(f"DEBUG - Warehouse stock found: {warehouse_stock_data[:2]}...")
-        else:
-            print(f"DEBUG - No warehouse stock data returned")
     except Exception as e:
         print(f"DEBUG - Warehouse stock error at start: {e}")
-
     try:
         if image is not None:
             user_message = process_image_message(image, user_message)
-        
         comparison_result = handle_comparison_request(user_message)
         if comparison_result:
             yield comparison_result
             return
     except Exception as e:
         print(f"Enhanced features error: {e}")
-
     try:
         with file_lock:
             with open(LOG_FILE, 'a', encoding='utf-8') as f:
                 f.write(f"User: {user_message}\n")
     except Exception as e:
         print(f"Dosya yazma hatası (Kullanıcı): {e}")
-
     system_messages = get_prompt_content_only()
-
     if document_content:
         system_messages.append({"role": "system", "content": f"Dökümanlardan gelen bilgiler: {document_content}"})
-    
     product_found_improved = False
     if USE_IMPROVED_SEARCH and improved_bot:
         try:
@@ -486,41 +354,24 @@ def chatbot_fn(user_message, history, image=None):
                     for store_info in warehouse_stock_data:
                         warehouse_info += f"• {store_info}\n"
                     enhanced_response += warehouse_info
-                    print(f"DEBUG - Added warehouse stock to improved search response")
                 elif warehouse_stock_data == ["Hiçbir mağazada mevcut değil"]:
                     enhanced_response += f"\n\n🏪 MAĞAZA STOK BİLGİLERİ: Hiçbir mağazada mevcut değil"
-                    print(f"DEBUG - No stock available (improved search)")
-                
-                system_messages.append({
-                    "role": "system",
-                    "content": f"ÜRÜN BİLGİSİ:\n{enhanced_response}\n\nBu bilgileri kullanarak kullanıcıya yardımcı ol."
-                })
+                system_messages.append({"role": "system", "content": f"ÜRÜN BİLGİSİ:\n{enhanced_response}\n\nBu bilgileri kullanarak kullanıcıya yardımcı ol."})
                 product_found_improved = True
         except Exception as e:
             print(f"Improved search error: {e}")
-    
     if not product_found_improved:
-        print(f"DEBUG chatbot_fn - Using warehouse stock data for: {user_message}")
         if warehouse_stock_data and warehouse_stock_data != ["Hiçbir mağazada mevcut değil"]:
             warehouse_info = f"🏪 MAĞAZA STOK BİLGİLERİ:\n"
             for store_info in warehouse_stock_data:
                 warehouse_info += f"• {store_info}\n"
-            system_messages.append({
-                "role": "system", 
-                "content": f"GÜNCEL STOK DURUMU:\n{warehouse_info}\n\nBu bilgileri kullanarak kullanıcıya hangi mağazada stok olduğunu söyle."
-            })
-            print(f"DEBUG - Using warehouse stock data")
+            system_messages.append({"role": "system", "content": f"GÜNCEL STOK DURUMU:\n{warehouse_info}\n\nBu bilgileri kullanarak kullanıcıya hangi mağazada stok olduğunu söyle."})
         elif warehouse_stock_data == ["Hiçbir mağazada mevcut değil"]:
-            system_messages.append({
-                "role": "system",
-                "content": "🏪 MAĞAZA STOK BİLGİLERİ: Sorduğunuz ürün hiçbir mağazada mevcut değil."
-            })
-            print(f"DEBUG - Product not available in any store")
-        else:
-            print(f"DEBUG - No warehouse stock data available")
-
+            system_messages.append({"role": "system", "content": "🏪 MAĞAZA STOK BİLGİLERİ: Sorduğunuz ürün hiçbir mağazada mevcut değil."})
     messages = system_messages + history + [{"role": "user", "content": user_message}]
-
+    if not OPENAI_API_KEY:
+        yield "API anahtarı eksik."
+        return
     payload = {
         "model": "gpt-4.1",
         "messages": messages,
@@ -535,14 +386,11 @@ def chatbot_fn(user_message, history, image=None):
         "Content-Type": "application/json",
         "Authorization": f"Bearer {OPENAI_API_KEY}"
     }
-    
     response = requests.post(API_URL, headers=headers, json=payload, stream=True)
     if response.status_code != 200:
         yield "Bir hata oluştu."
         return
-
     partial_response = ""
-    
     for chunk in response.iter_lines():
         if not chunk:
             continue
@@ -559,46 +407,49 @@ def chatbot_fn(user_message, history, image=None):
                 print(f"JSON parse hatası: {e} - Chunk: {chunk_str}")
         elif chunk_str == "data: [DONE]":
             break
-    
     final_response = extract_product_info_for_gallery(partial_response)
     yield final_response
-
     try:
         with file_lock:
             with open(LOG_FILE, 'a', encoding='utf-8') as f:
                 f.write(f"Bot: {partial_response}\n")
     except Exception as e:
         print(f"Dosya yazma hatası (Bot): {e}")
-
     with history_lock:
         global_chat_history.append({"role": "user", "content": user_message})
         global_chat_history.append({"role": "assistant", "content": partial_response})
 
-# Slow echo (test için)
 def slow_echo(message, history):
     for i in range(len(message)):
         time.sleep(0.05)
         yield "You typed: " + message[: i + 1]
 
-# Kullanım modu
 USE_SLOW_ECHO = False
 chat_fn = slow_echo if USE_SLOW_ECHO else chatbot_fn
 
-if not USE_SLOW_ECHO:
-    scheduler_thread = threading.Thread(target=run_scheduler, args=(global_chat_history,), daemon=True)
-    scheduler_thread.start()
-    
-# Trek markasına özel tema (kısaltılmış)
-trek_theme = gr.themes.Base(
-    primary_hue="red",
-    secondary_hue="slate",
-    neutral_hue="slate",
-    radius_size=gr.themes.sizes.radius_sm,
-    spacing_size=gr.themes.sizes.spacing_md,
-    text_size=gr.themes.sizes.text_sm
-)
+if 'APP_INIT_DONE' not in globals():
+    APP_INIT_DONE = True
+    products = load_products()
+    print(f"Toplam {len(products)} ürün yüklendi.")
+    initialize_enhanced_features(OPENAI_API_KEY, products)
+    save_conversations_json()
+    if GOOGLE_CREDENTIALS_PATH:
+        document_thread = threading.Thread(target=download_documents_from_drive, daemon=True)
+        document_thread.start()
+    else:
+        print("Google credentials dosyası bulunamadı.")
+    if not USE_SLOW_ECHO:
+        scheduler_thread = threading.Thread(target=run_scheduler, args=(global_chat_history,), daemon=True)
+        scheduler_thread.start()
+    if USE_IMPROVED_SEARCH:
+        try:
+            improved_bot = ImprovedChatbot(products)
+            print("Improved product search initialized successfully")
+        except Exception as e:
+            print(f"Failed to initialize improved search: {e}")
+            USE_IMPROVED_SEARCH = False
+
 custom_css = """
-/* temel stiller (kısaltılmış) */
 .gradio-container, .gradio-container * { font-family: 'Segoe UI', 'SF Pro Text', 'Roboto', -apple-system, BlinkMacSystemFont, 'Helvetica Neue', Arial, sans-serif !important; font-size: 0.6rem !important; }
 """
 
@@ -610,15 +461,8 @@ def enhanced_chatbot_fn(message, history, image):
 with gr.Blocks(css=custom_css, theme="soft", title="Trek Asistanı", head=storage_js) as demo:
     gr.Markdown("# 🚲 Trek Asistanı AI")
     gr.Markdown("**Akıllı özellikler:** Ürün karşılaştırması ve detaylı ürün bilgileri sunuyorum.")
-    
     chatbot = gr.Chatbot(height=600, elem_id="chatbot", show_label=False, type="messages")
-    
-    msg = gr.Textbox(
-        placeholder="Trek bisikletleri hakkında soru sorun...",
-        show_label=False,
-        elem_id="msg-input"
-    )
-    
+    msg = gr.Textbox(placeholder="Trek bisikletleri hakkında soru sorun...", show_label=False, elem_id="msg-input")
     def respond(message, chat_history):
         if not message.strip():
             return "", chat_history
@@ -626,11 +470,9 @@ with gr.Blocks(css=custom_css, theme="soft", title="Trek Asistanı", head=storag
             chat_history = []
         chat_history.append({"role": "user", "content": message})
         yield "", chat_history
-        
         formatted_history = []
         for m in chat_history[:-1]:
             formatted_history.append(m)
-        
         try:
             response_generator = chatbot_fn(message, formatted_history, None)
             response = ""
@@ -641,13 +483,11 @@ with gr.Blocks(css=custom_css, theme="soft", title="Trek Asistanı", head=storag
                 else:
                     chat_history[-1]["content"] = response
                 yield "", chat_history
-            
             try:
                 add_conversation(message, response)
-                save_conversations_json()  # JSON’u Space kökü ve public/ altına yaz
+                save_conversations_json()
             except Exception as e:
                 print(f"Error saving conversation: {e}")
-            
         except Exception as e:
             error_msg = f"Üzgünüm, bir hata oluştu: {str(e)}"
             print(f"Chat error: {e}")
@@ -656,18 +496,14 @@ with gr.Blocks(css=custom_css, theme="soft", title="Trek Asistanı", head=storag
             else:
                 chat_history[-1]["content"] = error_msg
             yield "", chat_history
-    
     msg.submit(respond, [msg, chatbot], [msg, chatbot], show_progress=True)
-    
     with gr.Accordion("📊 Konuşma Geçmişi (JSON)", open=False):
         with gr.Row():
             refresh_json_btn = gr.Button("🔄 Yenile", scale=1)
             download_json_btn = gr.Button("💾 JSON İndir", scale=1)
             view_dashboard_btn = gr.Button("📈 Dashboard'u Aç", scale=1)
-        
         json_display = gr.JSON(label="Konuşmalar", elem_id="json_viewer")
         download_file = gr.File(label="İndir", visible=False)
-        
         def get_conversations_json():
             from conversation_tracker import load_conversations
             convs = load_conversations()
@@ -675,11 +511,9 @@ with gr.Blocks(css=custom_css, theme="soft", title="Trek Asistanı", head=storag
             with open("temp_conversations.json", "w", encoding="utf-8") as f:
                 json_module.dump(convs, f, ensure_ascii=False, indent=2)
             return convs
-        
         def download_conversations():
             get_conversations_json()
             return gr.update(visible=True, value="temp_conversations.json")
-        
         def open_dashboard():
             return gr.HTML("""
                 <div style='padding: 20px; background: linear-gradient(135deg, #667eea 0%, #764ba2 100%); border-radius: 10px; color: white;'>
@@ -690,24 +524,16 @@ with gr.Blocks(css=custom_css, theme="soft", title="Trek Asistanı", head=storag
                     </ol>
                 </div>
             """)
-        
         refresh_json_btn.click(get_conversations_json, outputs=json_display)
         download_conversations_btn = download_json_btn
         download_conversations_btn.click(download_conversations, outputs=download_file)
         view_dashboard_btn.click(open_dashboard, outputs=json_display)
         demo.load(get_conversations_json, outputs=json_display)
 
-# -------------------------
-# CORS açık API + Gradio mount
-# -------------------------
-from fastapi import FastAPI, Response
-from fastapi.middleware.cors import CORSMiddleware
-import uvicorn
-
 api = FastAPI()
 api.add_middleware(
     CORSMiddleware,
-    allow_origins=["*"],      # Standalone HTML için tüm originlere izin
+    allow_origins=["*"],
     allow_credentials=False,
     allow_methods=["GET"],
     allow_headers=["*"],
@@ -732,7 +558,4 @@ def api_public_conversations():
     body, code = _read_json_safely("public/conversations.json")
     return Response(content=body, media_type="application/json", status_code=code)
 
-# Gradio arayüzünü FastAPI altına mount et
 app = gr.mount_gradio_app(api, demo, path="/")
-
-