Update app.py

app.py

@@ -2,195 +2,380 @@ import gradio as gr
 import os
 import json
 import requests
-import warnings
+import xml.etree.ElementTree as ET
+import schedule
 import time
 import threading
-import tempfile
-import base64
-from huggingface_hub import HfApi, create_repo
-import subprocess
+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
 
-# Gradio uyarılarını bastır
+# Suppress Gradio warnings
 warnings.filterwarnings("ignore", category=UserWarning, module="gradio.components.chatbot")
 
-# Log dosyası adı ve yolu
+# Log file name and path
 LOG_FILE = '/data/chat_logs.txt' if os.path.exists('/data') else 'chat_logs.txt'
-print(f"Dosya yolu: {os.path.abspath(LOG_FILE)}")
+print(f"File path: {os.path.abspath(LOG_FILE)}")
 
-# API ayarları
+# API settings
 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ış!")
-
-# Azure Speech API ayarları
-SPEECH_KEY = os.getenv("AZURE_SPEECH_KEY")
-SPEECH_REGION = os.getenv("AZURE_SPEECH_REGION", "westeurope")
+    print("Error: OPENAI_API_KEY environment variable not set!")
 
-if not SPEECH_KEY:
-    print("Hata: AZURE_SPEECH_KEY çevre değişkeni ayarlanmamış!")
+# Fetch Trek bicycle products
+url = 'https://www.trekbisiklet.com.tr/output/8582384479'
+response = requests.get(url)
+root = ET.fromstring(response.content)
 
-# Hugging Face token
-hfapi = os.getenv("hfapi")
-if not hfapi:
-    print("Uyarı: hfapi ortam değişkeni ayarlanmamış! Log dosyası yüklenemeyecek.")
-
-if hfapi:
-    try:
-        create_repo("BF", token=hfapi, repo_type="space", space_sdk="gradio", exist_ok=True)
-    except Exception as e:
-        print(f"HF repo oluşturma hatası: {e}")
-
-global_chat_history = []  # Tüm sohbet geçmişi
-history_lock = threading.Lock()  # Global geçmiş için kilit
-file_lock = threading.Lock()  # Dosya yazma için kilit
-last_logged_index = 0  # Son kaydedilen mesaj indeksi
-
-# Azure Speech REST API ile metin-konuşma dönüşümü
-def text_to_speech_azure_rest(text, output_file="response.mp3"):
-    try:
-        url = f"https://{SPEECH_REGION}.tts.speech.microsoft.com/cognitiveservices/v1"
-        headers = {
-            "Ocp-Apim-Subscription-Key": SPEECH_KEY,
-            "Content-Type": "application/ssml+xml",
-            "X-Microsoft-OutputFormat": "audio-16khz-128kbitrate-mono-mp3"
-        }
+products = []
+for item in root.findall('item'):
+    # Get all products, then check stock status
+    name_words = item.find('rootlabel').text.lower().split()
+    name = name_words[0]
+    full_name = ' '.join(name_words)
+    
+    stock_amount = "stokta" if item.find('stockAmount').text > '0' else "stokta değil"
+    
+    # We don't add price/link info for out-of-stock products
+    if stock_amount == "stokta":
+        # Get normal price
+        price_str = item.find('priceTaxWithCur').text if item.find('priceTaxWithCur') is not None else "Fiyat bilgisi yok"
         
-        ssml = f"""
-        <speak version='1.0' xml:lang='tr-TR'>
-            <voice xml:lang='tr-TR' name='tr-TR-EmelNeural'>
-                {text}
-            </voice>
-        </speak>
-        """
+        # Get EFT price (wire transfer discounted original price)
+        price_eft_str = item.find('priceEft').text if item.find('priceEft') is not None else ""
         
-        response = requests.post(url, headers=headers, data=ssml.encode('utf-8'))
+        # Get discounted price (promotional price)
+        price_rebate_str = item.find('priceRebateWithTax').text if item.find('priceRebateWithTax') is not None else ""
         
-        if response.status_code == 200:
-            with open(output_file, "wb") as file:
-                file.write(response.content)
-            
-            # Dosyayı binary olarak oku
-            with open(output_file, "rb") as file:
-                audio_data = file.read()
-            
-            # Gradio için dönüş formatı
-            return (16000, audio_data)
-        else:
-            print(f"Azure TTS hatası: {response.status_code} - {response.text}")
-            return None
-    except Exception as e:
-        print(f"Ses sentezleme hatası: {e}")
-        return None
-
-# Azure Speech REST API ile konuşma-metin dönüşümü
-def speech_to_text_azure_rest(audio_data):
-    try:
-        # Geçici ses dosyası oluştur
-        with tempfile.NamedTemporaryFile(suffix='.wav', delete=False) as temp_file:
-            temp_file_path = temp_file.name
-            
-            if isinstance(audio_data, tuple):
-                # Gradio'dan gelen (sample_rate, data) formatı
-                sample_rate, data = audio_data
-                with open(temp_file_path, 'wb') as f:
-                    f.write(data)
-            else:
-                # Doğrudan binary veri
-                with open(temp_file_path, 'wb') as f:
-                    f.write(audio_data)
+        # Get wire transfer discounted promotional price
+        price_rebate_money_order_str = item.find('priceRebateWithMoneyOrderWithTax').text if item.find('priceRebateWithMoneyOrderWithTax') is not None else ""
         
-        url = f"https://{SPEECH_REGION}.stt.speech.microsoft.com/speech/recognition/conversation/cognitiveservices/v1"
-        params = {
-            "language": "tr-TR",
-            "format": "detailed"
-        }
-        headers = {
-            "Ocp-Apim-Subscription-Key": SPEECH_KEY,
-            "Content-Type": "audio/wav"
-        }
+        # Round normal price
+        try:
+            price_float = float(price_str)
+            # If price is above 200000, round to nearest 5000
+            if price_float > 200000:
+                price = str(round(price_float / 5000) * 5000)
+            # If price is above 30000, round to nearest 1000
+            elif price_float > 30000:
+                price = str(round(price_float / 1000) * 1000)
+            # If price is above 10000, round to nearest 100
+            elif price_float > 10000:
+                price = str(round(price_float / 100) * 100)
+            # Otherwise round to nearest 10
+            else:
+                price = str(round(price_float / 10) * 10)
+        except (ValueError, TypeError):
+            price = price_str  # Keep as is if can't be converted to number
         
-        with open(temp_file_path, 'rb') as audio_file:
-            response = requests.post(url, params=params, headers=headers, data=audio_file)
+        # Round wire transfer discounted original price (if any)
+        if price_eft_str:
+            try:
+                price_eft_float = float(price_eft_str)
+                # If price is above 200000, round to nearest 5000
+                if price_eft_float > 200000:
+                    price_eft = str(round(price_eft_float / 5000) * 5000)
+                # If price is above 30000, round to nearest 1000
+                elif price_eft_float > 30000:
+                    price_eft = str(round(price_eft_float / 1000) * 1000)
+                # If price is above 10000, round to nearest 100
+                elif price_eft_float > 10000:
+                    price_eft = str(round(price_eft_float / 100) * 100)
+                # Otherwise round to nearest 10
+                else:
+                    price_eft = str(round(price_eft_float / 10) * 10)
+            except (ValueError, TypeError):
+                price_eft = price_eft_str
+        else:
+            # If wire transfer discounted price not provided, calculate 2.5% discount from original price
+            try:
+                price_eft_float = price_float * 0.975  # 2.5% discount
+                # If price is above 200000, round to nearest 5000
+                if price_eft_float > 200000:
+                    price_eft = str(round(price_eft_float / 5000) * 5000)
+                # If price is above 30000, round to nearest 1000
+                elif price_eft_float > 30000:
+                    price_eft = str(round(price_eft_float / 1000) * 1000)
+                # If price is above 10000, round to nearest 100
+                elif price_eft_float > 10000:
+                    price_eft = str(round(price_eft_float / 100) * 100)
+                # Otherwise round to nearest 10
+                else:
+                    price_eft = str(round(price_eft_float / 10) * 10)
+            except (ValueError, TypeError):
+                price_eft = ""
         
-        # Geçici dosyayı temizle
+        # Round discounted price
         try:
-            os.unlink(temp_file_path)
-        except:
-            pass
+            if price_rebate_str:
+                price_rebate_float = float(price_rebate_str)
+                # If price is above 200000, round to nearest 5000
+                if price_rebate_float > 200000:
+                    price_rebate = str(round(price_rebate_float / 5000) * 5000)
+                # If price is above 30000, round to nearest 1000
+                elif price_rebate_float > 30000:
+                    price_rebate = str(round(price_rebate_float / 1000) * 1000)
+                # If price is above 10000, round to nearest 100
+                elif price_rebate_float > 10000:
+                    price_rebate = str(round(price_rebate_float / 100) * 100)
+                # Otherwise round to nearest 10
+                else:
+                    price_rebate = str(round(price_rebate_float / 10) * 10)
+            else:
+                price_rebate = ""
+        except (ValueError, TypeError):
+            price_rebate = price_rebate_str
         
-        if response.status_code == 200:
-            result = response.json()
-            if result.get("RecognitionStatus") == "Success":
-                return result.get("DisplayText", "")
+        # Round wire transfer discounted promotional price
+        try:
+            if price_rebate_money_order_str:
+                price_rebate_money_order_float = float(price_rebate_money_order_str)
+                # If price is above 200000, round to nearest 5000
+                if price_rebate_money_order_float > 200000:
+                    price_rebate_money_order = str(round(price_rebate_money_order_float / 5000) * 5000)
+                # If price is above 30000, round to nearest 1000
+                elif price_rebate_money_order_float > 30000:
+                    price_rebate_money_order = str(round(price_rebate_money_order_float / 1000) * 1000)
+                # If price is above 10000, round to nearest 100
+                elif price_rebate_money_order_float > 10000:
+                    price_rebate_money_order = str(round(price_rebate_money_order_float / 100) * 100)
+                # Otherwise round to nearest 10
+                else:
+                    price_rebate_money_order = str(round(price_rebate_money_order_float / 10) * 10)
             else:
-                print(f"Konuşma tanıma başarısız: {result.get('RecognitionStatus')}")
-                return "Konuşma tanınamadı. Lütfen tekrar deneyin veya yazarak iletişim kurun."
-        else:
-            print(f"Azure STT hatası: {response.status_code} - {response.text}")
-            return "Ses tanıma servisi hatası. Lütfen yazarak iletişim kurun."
+                price_rebate_money_order = ""
+        except (ValueError, TypeError):
+            price_rebate_money_order = price_rebate_money_order_str
+        
+        # Get only product link, not image link
+        product_link = item.find('productLink').text if item.find('productLink') is not None else ""
+        
+        # Combine all price information
+        item_info = (stock_amount, price, product_link, price_eft, price_rebate, price_rebate_money_order)
+    else:
+        # For out-of-stock products, only indicate stock status, don't provide price and link info
+        item_info = (stock_amount, "", "", "", "", "")
+    
+    products.append((name, item_info, full_name))
+
+# Hugging Face token
+hfapi = os.getenv("hfapi")
+if not hfapi:
+    raise ValueError("hfapi environment variable not set!")
+
+create_repo("BF", token=hfapi, repo_type="space", space_sdk="gradio", exist_ok=True)
+
+global_chat_history = []  # All chat history
+history_lock = threading.Lock()  # Lock for global history
+file_lock = threading.Lock()  # Lock for file writing
+last_logged_index = 0  # Last saved message index
+
+# Google Drive authentication (Service Account from Secrets)
+SCOPES = ['https://www.googleapis.com/auth/drive.readonly']
+
+def authenticate_google_drive():
+    service_account_json = os.getenv("SERVICE_ACCOUNT_JSON")
+    if not service_account_json:
+        raise ValueError("SERVICE_ACCOUNT_JSON environment variable not found!")
+    
+    try:
+        json_data = json.loads(service_account_json)
+        print("JSON successfully parsed:", json_data.keys())
+        print("Private key content:", json_data.get("private_key"))
+        creds = Credentials.from_service_account_info(json_data, scopes=SCOPES)
+    except json.JSONDecodeError as e:
+        raise ValueError(f"Invalid JSON from Secrets: {e}")
     except Exception as e:
-        print(f"Konuşma tanıma hatası: {e}")
-        return "Ses dönüştürme sırasında bir hata oluştu. Lütfen yazarak iletişim kurun."
+        raise ValueError(f"Authentication error: {e}")
+    
+    return build('drive', 'v3', credentials=creds)
+
+def download_file_from_drive(service, file_id, file_name):
+    request = service.files().get_media(fileId=file_id)
+    fh = io.BytesIO()
+    downloader = MediaIoBaseDownload(fh, request)
+    done = False
+    while done is False:
+        status, done = downloader.next_chunk()
+    fh.seek(0)
+    with open(file_name, 'wb') as f:
+        f.write(fh.read())
+    return file_name
+
+# Pull documents from Google Drive and process
+document_content = ""
+service = authenticate_google_drive()
+
+try:
+    # Excel file from Google Drive
+    excel_file_id = "test10rgiGp5y5ZYU0dpRvps2t0t1dEzjW8LK"  # Example Excel file ID, add your own ID
+    excel_file = download_file_from_drive(service, excel_file_id, "veriler.xlsx")
+    df = pd.read_excel(excel_file)
+    excel_text = df.to_string()
+    document_content += excel_text + "\n"
+except Exception as e:
+    print(f"Google Drive Excel reading error: {e}")
+
+try:
+    # Word file from Google Drive
+    word_file_id = "9I8H7G6F5E4D3C2B1A"  # Example Word file ID, add your own ID
+    word_file = download_file_from_drive(service, word_file_id, "aciklamalar.docx")
+    doc = Document(word_file)
+    word_text = "\n".join([para.text for para in doc.paragraphs])
+    document_content += word_text
+except Exception as e:
+    print(f"Google Drive Word reading error: {e}")
 
-# Zamanlanmış log kaydı ve yükleme
 def run_scheduler(chat_history_ref):
-    import schedule
-    
     def scheduled_save_and_upload():
         global last_logged_index
         if chat_history_ref:
-            print(f"Zamanlayıcı tetiklendi: {time.strftime('%Y-%m-%d %H:%M:%S')}")
+            print(f"Timer triggered: {time.strftime('%Y-%m-%d %H:%M:%S')}")
             try:
-                with file_lock:  # Dosya yazma kilidi
+                with file_lock:  # File writing lock
                     with open(LOG_FILE, 'a', encoding='utf-8') as f:
-                        f.write("\n--- Zamanlanmış Kayıt: {} ---\n".format(time.strftime("%Y-%m-%d %H:%M:%S")))
-                        with history_lock:  # Geçmiş kilidi
+                        f.write("\n--- Scheduled Save: {} ---\n".format(time.strftime("%Y-%m-%d %H:%M:%S")))
+                        with history_lock:  # History lock
                             new_messages = chat_history_ref[last_logged_index:]
                             for msg in new_messages:
                                 if msg["role"] in ["user", "assistant"]:
                                     f.write(f"{msg['role'].capitalize()}: {msg['content']}\n")
-                            last_logged_index = len(chat_history_ref)  # Son indeksi güncelle
-                    print(f"Sohbet dosyaya kaydedildi: {os.path.abspath(LOG_FILE)}")
+                            last_logged_index = len(chat_history_ref)  # Update last index
+                    print(f"Chat saved to file: {os.path.abspath(LOG_FILE)}")
             except Exception as e:
-                print(f"Kayıt hatası: {e}")
-                return
+                print(f"Save error: {e}")
+                time.sleep(5)  # Wait before retrying
+                return  # Early exit for retry
 
-            if hfapi:
-                HF_REPO_ID = "SamiKoen/BF"
-                api = HfApi(token=hfapi)
-                for attempt in range(3):  # 3 kez tekrar deneme
-                    try:
-                        with file_lock:
-                            api.upload_file(
-                                path_or_fileobj=LOG_FILE,
-                                path_in_repo="chat_logs.txt",
-                                repo_id=HF_REPO_ID,
-                                repo_type="space",
-                                commit_message="Otomatik log güncellemesi - {}".format(time.strftime("%Y-%m-%d %H:%M:%S"))
-                            )
-                        print(f"Log dosyası HF'ye yüklendi: {LOG_FILE}")
-                        break
-                    except Exception as e:
-                        print(f"HF yükleme hatası (deneme {attempt+1}/3): {e}")
-                        time.sleep(5)
-                else:
-                    print("HF yükleme başarısız, tüm denemeler tamamlandı.")
-            print(f"Zamanlanmış işlem tamamlandı: {time.strftime('%H:%M:%S')}")
+            HF_REPO_ID = "SamiKoen/BF"
+            api = HfApi(token=hfapi)
+            for attempt in range(3):  # Try 3 times
+                try:
+                    with file_lock:
+                        api.upload_file(
+                            path_or_fileobj=LOG_FILE,
+                            path_in_repo="chat_logs.txt",
+                            repo_id=HF_REPO_ID,
+                            repo_type="space",
+                            commit_message="Automatic log update - {}".format(time.strftime("%Y-%m-%d %H:%M:%S"))
+                        )
+                    print(f"Log file uploaded to HF: {LOG_FILE}")
+                    break
+                except Exception as e:
+                    print(f"HF upload error (attempt {attempt+1}/3): {e}")
+                    time.sleep(5)
+            else:
+                print("HF upload failed, all attempts completed.")
+            print(f"Scheduled task completed: {time.strftime('%H:%M:%S')}")
 
-    # Günlük zamanlanmış görevler
     schedule.every().day.at("11:32").do(scheduled_save_and_upload)
     schedule.every().day.at("15:15").do(scheduled_save_and_upload)
+    schedule.every().day.at("15:30").do(scheduled_save_and_upload)
     schedule.every().day.at("17:32").do(scheduled_save_and_upload)
+    schedule.every().day.at("19:15").do(scheduled_save_and_upload)
     schedule.every().day.at("21:30").do(scheduled_save_and_upload)
-    print("Zamanlayıcı başlatıldı")
-    
+    print("Timer started")
     while True:
         schedule.run_pending()
         time.sleep(60)
 
-# GPT API kullanarak chatbot yanıtı oluşturma
-def get_chatbot_response(messages):
+# Define system messages for the chatbot
+def get_system_messages():
+    return [
+        {"role": "system", "content": "Sen bir AI Trek marka bisiklet uzmanı, bilir kişisi ve asistanısın."},
+        # Additional system messages would go here
+    ]
+
+@spaces.GPU(duration=1200)
+def chatbot_fn(user_message, history):
+    if history is None:
+        history = []
+
+    # Log: Add user message
+    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"File writing error (User): {e}")
+
+    # System messages
+    system_messages = get_system_messages()
+
+    # Add document data to system messages
+    if document_content:
+        system_messages.append({"role": "system", "content": f"Document information: {document_content}"})
+
+    # Add product info if mentioned in user message
+    input_words = user_message.lower().split()
+    for product_info in products:
+        if product_info[0] in input_words:
+            if product_info[1][0] == "stokta":
+                # Check for promotional price
+                has_campaign = product_info[1][4] and product_info[1][4] != ""
+                
+                # Original price is always shown
+                normal_price = f"Original price: {product_info[1][1]} TL"
+                
+                # Promotional price info
+                rebate_price = ""
+                discount_info = ""
+                eft_price = ""
+                rebate_money_order_price = ""
+                
+                if has_campaign:
+                    # If product is on sale, show promotional price
+                    rebate_price = f"\nPromotional price: {product_info[1][4]} TL"
+                    
+                    # Calculate discount amount
+                    try:
+                        original_price = float(product_info[1][1].replace(',', '.'))
+                        campaign_price = float(product_info[1][4].replace(',', '.'))
+                        discount_amount = original_price - campaign_price
+                        
+                        # Show discount amount if greater than 0
+                        if discount_amount > 0:
+                            # Apply rounding rules for discount amount
+                            if discount_amount > 200000:
+                                discount_amount_rounded = round(discount_amount / 5000) * 5000
+                            elif discount_amount > 30000:
+                                discount_amount_rounded = round(discount_amount / 1000) * 1000
+                            elif discount_amount > 10000:
+                                discount_amount_rounded = round(discount_amount / 100) * 100
+                            else:
+                                discount_amount_rounded = round(discount_amount / 10) * 10
+                                
+                            # Discount info
+                            discount_info = f"\nDiscount amount: {discount_amount_rounded:.0f} TL"
+                    except (ValueError, TypeError):
+                        discount_info = ""
+                    
+                    # Show wire transfer discounted promotional price
+                    rebate_money_order_price = ""
+                else:
+                    # If not on sale, show wire transfer discounted normal price
+                    if product_info[1][3] and product_info[1][3] != "":
+                        eft_price = f"\nWire transfer price: {product_info[1][3]} TL"
+                
+                # Product link
+                product_link = f"\nProduct link: {product_info[1][2]}"
+                
+                # Combine all information
+                new_msg = f"{product_info[2]} {product_info[1][0]}\n{normal_price}{rebate_price}{discount_info}{eft_price}{rebate_money_order_price}{product_link}"
+            else:
+                # If product is out of stock, only indicate stock status
+                new_msg = f"{product_info[2]} {product_info[1][0]}"
+            system_messages.append({"role": "system", "content": new_msg})
+
+    messages = system_messages + history + [{"role": "user", "content": user_message}]
+
     payload = {
         "model": "gpt-4.5-preview",
         "messages": messages,
@@ -208,8 +393,9 @@ def get_chatbot_response(messages):
     
     response = requests.post(API_URL, headers=headers, json=payload, stream=True)
     if response.status_code != 200:
-        return "API hatası: Yanıt alınamadı."
-    
+        yield "An error occurred."
+        return
+
     partial_response = ""
     
     for chunk in response.iter_lines():
@@ -224,181 +410,96 @@ def get_chatbot_response(messages):
                     partial_response += delta['content']
                     yield partial_response
             except json.JSONDecodeError as e:
-                print(f"JSON parse hatası: {e} - Chunk: {chunk_str}")
+                print(f"JSON parse error: {e} - Chunk: {chunk_str}")
         elif chunk_str == "data: [DONE]":
             break
-    
-    return partial_response
-
-# Soru gönderildikten sonra metin kutusunu temizleme
-def clear_textbox():
-    return ""
 
-# Ses girişi işleme
-def process_audio_input(audio):
-    if audio is None:
-        return "Ses kaydedilemedi. Lütfen tekrar deneyin veya yazarak iletişim kurun."
-    
-    user_message = speech_to_text_azure_rest(audio)
-    return user_message if user_message else "Ses tanınamadı. Lütfen tekrar deneyin veya yazarak iletişim kurun."
-
-# Ana chatbot fonksiyonu
-def chatbot_fn(user_message, history):
-    if history is None:
-        history = []
-    
-    # Eğer hiç mesaj yoksa hata döndür
-    if not user_message:
-        return history, None
-    
-    # Log: Kullanıcı mesajın�� ekle
+    # Log: Add assistant response
     try:
         with file_lock:
             with open(LOG_FILE, 'a', encoding='utf-8') as f:
-                f.write(f"User: {user_message}\n")
+                f.write(f"Bot: {partial_response}\n")
     except Exception as e:
-        print(f"Dosya yazma hatası (Kullanıcı): {e}")
-    
-    # Sistem mesajları
-    system_messages = [
-        {"role": "system", "content": "Sen bir AI Trek marka bisiklet uzmanı, bilir kişisi ve asistanısın. Trek ve Electra bisikletler konusunda uzmanım. Kullanıcılara nazik ve yardımcı şekilde cevap ver."},
-        {"role": "system", "content": "Türkiye'deki Trek mağazaları: İstanbul'da üç Trek mağazamız var: Caddebostan, Ortaköy ve Sarıyer. İzmir'de yeni bir mağazamız Nisan 2025'te açılacak."}
-    ]
-    
-    # Chabot geçmişi için doğru formatta dönüşüm yap
-    formatted_history = []
-    for i in range(0, len(history), 2):
-        if i+1 < len(history):
-            formatted_history.append({"role": "user", "content": history[i][0]})
-            formatted_history.append({"role": "assistant", "content": history[i][1]})
-    
-    # Mesaj dizisini oluştur
-    messages = system_messages + formatted_history + [{"role": "user", "content": user_message}]
-    
-    # Chatbot yanıtını al
-    response_text = ""
+        print(f"File writing error (Bot): {e}")
+
+    # Update global history
+    with history_lock:
+        global_chat_history.append({"role": "user", "content": user_message})
+        global_chat_history.append({"role": "assistant", "content": partial_response})
+
+# Text-to-speech function
+def text_to_speech(text):
+    # You can implement TTS functionality here
+    # This is a placeholder for actual TTS implementation
+    return None
+
+# Speech-to-text function
+def speech_to_text(audio):
+    # You can implement STT functionality here
+    # This is a placeholder for actual STT implementation
     try:
-        for partial_response in get_chatbot_response(messages):
-            response_text = partial_response
+        # Use an STT model to convert audio to text
+        # This is a placeholder
+        transcription = "Placeholder transcription"
+        return transcription
     except Exception as e:
-        print(f"Yanıt alma hatası: {e}")
-        response_text = "Üzgünüm, yanıt alınırken bir hata oluştu. Lütfen tekrar deneyin."
+        print(f"Speech recognition error: {e}")
+        return ""
+
+# Function to handle voice input
+def voice_input_handler(audio, history):
+    # Convert speech to text
+    text = speech_to_text(audio)
+    if not text:
+        return "I couldn't understand that. Please try again.", history
     
-    # Geçmişi güncelle
-    history.append((user_message, response_text))
+    # Get chatbot response using the text
+    response_generator = chatbot_fn(text, history)
     
-    # Yanıtı ses dosyasına dönüştür
-    audio_response = None
-    try:
-        if SPEECH_KEY:
-            audio_response = text_to_speech_azure_rest(response_text)
-    except Exception as e:
-        print(f"Ses oluşturma hatası: {e}")
+    # Get the final response
+    response = None
+    for r in response_generator:
+        response = r
     
-    # Log: Asistan cevabını ekle
-    try:
-        with file_lock:
-            with open(LOG_FILE, 'a', encoding='utf-8') as f:
-                f.write(f"Bot: {response_text}\n")
-    except Exception as e:
-        print(f"Dosya yazma hatası (Bot): {e}")
+    return text, history + [{"role": "user", "content": text}, {"role": "assistant", "content": response}]
+
+# Initialize scheduler thread
+scheduler_thread = threading.Thread(target=run_scheduler, args=(global_chat_history,), daemon=True)
+scheduler_thread.start()
+
+# Create Gradio interface with voice capabilities
+with gr.Blocks() as demo:
+    gr.Markdown("# Trek Voice Assistant")
     
-    # Global geçmişi güncelle
-    with history_lock:
-        global_chat_history.append({"role": "user", "content": user_message})
-        global_chat_history.append({"role": "assistant", "content": response_text})
+    with gr.Tab("Text Chat"):
+        chatbot = gr.ChatInterface(
+            fn=chatbot_fn,
+            title="Trek Assistant",
+            theme="default",
+            type="messages",
+            flagging_mode="manual",
+            flagging_options=["Correct", "Incorrect", "Not sure", "Other"],
+            save_history=True
+        )
     
-    return history, audio_response
-
-# Gradio arayüzü
-def create_interface():
-    with gr.Blocks(theme="default") as demo:
-        gr.Markdown("# Trek Sesli Asistanı")
-        gr.Markdown("Mikrofonla konuşmak için ses kaydedebilir veya metin mesajı gönderebilirsiniz.")
-        
-        chatbot = gr.Chatbot(height=600)
+    with gr.Tab("Voice Chat"):
+        chat_history = gr.State([])
         
         with gr.Row():
-            msg = gr.Textbox(
-                placeholder="Mesajınızı yazın...", 
-                lines=2,
-                interactive=True,
-                scale=4
-            )
-            send_btn = gr.Button("Gönder", scale=1)
-        
+            with gr.Column(scale=4):
+                display = gr.Chatbot(height=400)
+            
         with gr.Row():
-            audio_input = gr.Audio(
-                sources=["microphone"], 
-                type="blob", 
-                label="Sesli Soru Kaydet"
-            )
-            clear = gr.Button("Temizle")
-        
-        audio_output = gr.Audio(label="Sesli Yanıt", autoplay=True)
-        
-        status_text = gr.Markdown("Sistem hazır. Mesajınızı yazabilir veya sesli soru kaydedebilirsiniz.")
-        
-        # Event handlers
-        msg.submit(chatbot_fn, [msg, chatbot], [chatbot, audio_output]).then(
-            clear_textbox, None, [msg]
-        ).then(
-            lambda: "Mesajınız gönderildi ve yanıtlandı.",
-            None, 
-            [status_text]
-        )
-        
-        send_btn.click(chatbot_fn, [msg, chatbot], [chatbot, audio_output]).then(
-            clear_textbox, None, [msg]
-        ).then(
-            lambda: "Mesajınız gönderildi ve yanıtlandı.",
-            None, 
-            [status_text]
-        )
-        
-        # Ses girişi olduğunda
+            audio_input = gr.Audio(source="microphone", type="filepath", label="Speak")
+            clear_btn = gr.Button("Clear")
+            
         audio_input.change(
-            process_audio_input, 
-            [audio_input], 
-            [msg]
-        ).then(
-            lambda: "Ses tanıma tamamlandı. 'Gönder' butonuna basın veya Enter tuşuna basın.",
-            None,
-            [status_text]
-        )
-        
-        clear.click(lambda: None, None, chatbot, queue=False).then(
-            lambda: "Sohbet geçmişi temizlendi.",
-            None,
-            [status_text]
+            fn=voice_input_handler,
+            inputs=[audio_input, chat_history],
+            outputs=[display, chat_history]
         )
         
-        gr.Markdown("### Trek Bisiklet Asistanı - Sesli İletişim")
-        gr.Markdown("Trek bisikletler hakkında sorularınızı sesli veya yazılı olarak sorabilirsiniz.")
-    
-    return demo
-
-# Ortam değişkenlerini kontrol et
-def check_environment():
-    missing_vars = []
-    if not OPENAI_API_KEY:
-        missing_vars.append("OPENAI_API_KEY")
-    if not SPEECH_KEY:
-        missing_vars.append("AZURE_SPEECH_KEY")
-    
-    if missing_vars:
-        print(f"Uyarı: Aşağıdaki ortam değişkenleri eksik: {', '.join(missing_vars)}")
-        print("Eksik değişkenler ilgili özelliklerin çalışmamasına neden olabilir.")
-
-# Çevre değişkenlerini kontrol et
-check_environment()
-
-# Scheduler thread'i başlat
-scheduler_thread = threading.Thread(target=run_scheduler, args=(global_chat_history,), daemon=True)
-scheduler_thread.start()
-
-# Arayüzü oluştur ve başlat
-demo = create_interface()
+        clear_btn.click(lambda: ([], []), outputs=[display, chat_history])
 
 if __name__ == "__main__":
-    demo.launch(debug=True)
+    demo.launch(debug=True, enable_queue=True)