Update app.py

app.py

@@ -5,10 +5,6 @@ import requests
 import xml.etree.ElementTree as ET
 from huggingface_hub import HfApi, create_repo
 
-
-
-
-
 # Dosya yolu: Kalıcı depolama için öncelik, yoksa geçici dizin
 LOG_FILE = '/persistent-storage/chat_logs.txt'
 persistent_dir = '/persistent-storage'
@@ -29,22 +25,28 @@ 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)
 root = ET.fromstring(response.content)
 
 products = []
-
 for item in root.findall('item'):
-    if item.find('isOptionOfAProduct').text == '1':
-        if item.find('stockAmount').text > '0':
-            name_words = item.find('rootlabel').text.lower().split()
-            name = name_words[0]
-            full_name = ' '.join(name_words)
-            stockAmount = "stokta"
-            price = item.find('priceWithTax').text
-            item_info = (stockAmount, price)
-            products.append((name, item_info, full_name))
+    if item.find('isOptionOfAProduct').text == '1' and item.find('stockAmount').text > '0':
+        name_words = item.find('rootlabel').text.lower().split()
+        name = name_words[0]
+        full_name = ' '.join(name_words)
+        stockAmount = "stokta"
+        price = item.find('priceWithTax').text
+        item_info = (stockAmount, price)
+        products.append((name, item_info, full_name))
+
+# HF_TOKEN ayarı ve repository oluşturma
+HF_TOKEN = os.getenv("HF_TOKEN")
+if not HF_TOKEN:
+    raise ValueError("HF_TOKEN ortam değişkeni ayarlanmamış!")
+# Burada repo adınızı kullanıcı adınızla uyumlu şekilde belirleyin
+create_repo("BF", token=HF_TOKEN, repo_type="space", space_sdk="gradio", exist_ok=True)
 
 def predict(system_msg, inputs, top_p, temperature, chat_counter, chatbot=None, history=None):
     if chatbot is None:
@@ -59,13 +61,11 @@ def predict(system_msg, inputs, top_p, temperature, chat_counter, chatbot=None,
     print(f"System message: {system_msg}")
     
     multi_turn_message = [
-        {"role": "system", "content": "Bir önceki sohbeti unut. Vereceğin ürün bilgisi, bu bilginin içinde yan yana yazmıyorsa veya arada başka bilgiler yazıyor ise, o bilgiyi vermeyeceksin çünkü o bilgi yanlıştır. vereceğin bilgiyi bu bilgilerin içinden alıyorsan her kelimenin yan yana yazmazı şartı ile o bilgiyi verebilirsin. Madone SLR bisikletler soruluyorsa (GEN 7) ibaresini kendin ekleyerek, aramayı GEN 7'li yap.Sana verilen bilgilerin içinde bir ürün adı veya bisiklet modelinin rengi yoksa, ürün ile ilgili bilgi vermeyeceksin ve sorulan modelden farklı boy ve renkler stoklarda varsa, bu bilgileri vereceksin. Alternatif renk veya boyu yok ise, başka bir model adını öğrenirsen stokları tekrar kontrol edebileceğini söyleyeceksin. Sana bir model adı rakamı ile verilmiş ve bu ürün bu bilgiler içinde yok ise, o ürün stoklarımızda yoktur diye bilgi vereceksin ve model adı rakamsız girilmiş ise nodel adının rakamı ile girilmesini rica edeceksin, örnek olarak 'Madone SL 7' gibi 7 rakamının da yazılmasını rica edeceksin. Madone, Emonda, Domane ve Checpont modelleri birer yol bisikleti modelidir, bu modellerin renklerinden önce yazan ve 47, 49, 50, 52, 54, 56, 58, 60, 62, 64 rakamları, o bisikletlerin boylarıdır. Bu bilgi içindeki renkler ise o ürünlerin renkleridir. Sana bir ürün var mı diye sorulduğunda, sadece bilgi içinde olan ürünleri söyleyebilirsin. Stoklarımızda yok ise o ürün ile ilgili bilgi vermeyeceksin. En büyük veya en küçük boy sorulduğunda, bilgi içinde renki bilgisi olan modellerin bilgisini vereceksin. Gerçek zamanlı stok bilgilerine erişme yeteneğin var. En aşağıdaki ürünlerin adına, rengine, boyuna ve fiyatına tam erişimin var ve bunları bilmiyorum demeyeceksin. Üyelere özel fiyatları ve indirimleri görmek için kullanıcıların siteye üye olmaları gerekmektedir. Sen bir AI Trek marka bisiklet uzmanı, bilir kişisi ve asistanısın.Trek ve Electra bisikletler konusunda uzmanım.İzmir'de yeni bir mağazamız açılıyor. Mağazamız Nisan 2025 ayında açılmış olacak. Yeri is Alsancak'da. İstanbul'da üç Trek mağazamız var: Caddebostan, Ortaköy ve Sarıyer. Ortaköy maidği 10.00-19.00 saatleri arasında açık. ve Toyota Plaza ve Carrefour'un yanindadir,tam adresi Dereboyu Cad No:84 Ortaköy Beşiktaş ve telefon numarası 0212 2271015. Caddebostan mağazası, Prof. Dr. Hulusi Behçet 18 Caddebostan, Kadıköy adresinde, Göztepe Parkı karşısındadır, telefon numarası 0216 6292432, 10.00-19.00 saatleri arasında açık. Tüm mağazalar Pazar günü kapalıdır. Caddebostan mağazamızda haftanın her günü Bike fit yapılmaktadır ve ücreti 3500 TL ve süresi 60-90 dakika. Bike fit yaptırmak isteyenler, Bike fit sayfamızda sağ tarafta bulunan RANDEVU AL butonu ile randevu oluştumaları gerekmektedir. Sarıyer mağazamızın adresi şöyledir: Mareşal Fevzi Çakmak Cad. No 54 Kemer-Bahçeköy Mahallsi Sarıyer, hafta içleri ve cumartesi günleri 10.00 ile 19.00 saatleri arasında hizmet vermektedir. Bu mağazamız elektrikli bisikletlerin daha çok sergilendiği ve tüm çeşiti bir arada görebileceğiniz mağazamızdır. Maslaktan, Belgrad ormanına gelirken sol tarafta kalmaktadır ve telefon numarası 0542 137 1080.."},
+        {"role": "system", "content": "Bir önceki sohbeti unut. Vereceğin ürün bilgisi, bu bilginin içinde yan yana yazmıyorsa veya arada başka bilgiler yazıyor ise, o bilgiyi vermeyeceksin çünkü o bilgi yanlıştır. ... (uzun metin)"}
     ]
-   
-    messages = multi_turn_message.copy()
     
+    messages = multi_turn_message.copy()
     input_words = [str(word).lower() for word in inputs.split()]
-    
     for product_info in products:
         if product_info[0] in input_words:
             new_msg = f"{product_info[2]} {product_info[1][0]} ve fiyatı EURO {product_info[1][1]}"
@@ -73,10 +73,7 @@ def predict(system_msg, inputs, top_p, temperature, chat_counter, chatbot=None,
             messages.append({"role": "system", "content": new_msg})
     
     for data in chatbot:
-        if data["role"] == "user":
-            messages.append({"role": "user", "content": data["content"]})
-        elif data["role"] == "assistant":
-            messages.append({"role": "assistant", "content": data["content"]})
+        messages.append({"role": data["role"], "content": data["content"]})
     
     messages.append({"role": "user", "content": inputs})
     
@@ -103,9 +100,7 @@ def predict(system_msg, inputs, top_p, temperature, chat_counter, chatbot=None,
     except Exception as e:
         print(f"Dosya yazma hatası (Kullanıcı): {e}")
     
-    # Chatbot'a kullanıcı mesajını ekle
     chatbot.append({"role": "user", "content": inputs})
-    
     response = requests.post(API_URL, headers=headers, json=payload, stream=True)
     print(f"Logging: Response code - {response.status_code}")
     if response.status_code != 200:
@@ -114,14 +109,12 @@ def predict(system_msg, inputs, top_p, temperature, chat_counter, chatbot=None,
     
     partial_words = ""
     counter = 0
-    
     for chunk in response.iter_lines():
         counter += 1
         if not chunk:
             continue
         chunk_str = chunk.decode('utf-8')
         print(f"Chunk {counter}: {chunk_str}")
-        
         if chunk_str.startswith("data: ") and chunk_str != "data: [DONE]":
             try:
                 chunk_data = json.loads(chunk_str[6:])
@@ -144,16 +137,12 @@ def predict(system_msg, inputs, top_p, temperature, chat_counter, chatbot=None,
                         print(f"Bot yanıtı dosyaya yazıldı: {partial_words}")
                 except Exception as e:
                     print(f"Dosya yazma hatası (Bot): {e}")
-        
-        # Chatbot içeriğini güncelle ve yield ile gönder
         chat = chatbot.copy()
         if partial_words and chat and chat[-1]["role"] == "user":
             chat.append({"role": "assistant", "content": partial_words})
         elif partial_words and chat and chat[-1]["role"] == "assistant":
             chat[-1] = {"role": "assistant", "content": partial_words}
-        
         yield chat, history, chat_counter
-
     print(f"Son chatbot durumu: {chatbot}")
     return chatbot, history, chat_counter
 
@@ -173,12 +162,6 @@ def save_chat(chatbot):
 def reset_textbox():
     return gr.update(value='')
 
-from huggingface_hub import HfApi, create_repo
-
-# Repository oluşturma (eğer mevcut değilse)
-HF_TOKEN = os.getenv("HF_TOKEN")
-create_repo("BF", token=HF_TOKEN, repo_type="space", exist_ok=True)
-
 def upload_logs_to_hf(repo_id: str, hf_token: str, local_log_file: str = "chat_logs.txt"):
     """
     Log dosyasını Hugging Face Hub repository'sine yükler.
@@ -189,7 +172,6 @@ def upload_logs_to_hf(repo_id: str, hf_token: str, local_log_file: str = "chat_l
         local_log_file (str): Yüklenecek log dosyasının yolu.
     """
     api = HfApi(token=hf_token)
-    
     try:
         api.upload_file(
             path_or_fileobj=local_log_file,
@@ -202,30 +184,13 @@ def upload_logs_to_hf(repo_id: str, hf_token: str, local_log_file: str = "chat_l
     except Exception as e:
         print(f"Log dosyası yüklenirken hata oluştu: {e}")
 
-
 def save_chat_and_upload(chatbot):
-    # Sohbeti kaydetme işlemini burada yapın
     save_status = save_chat(chatbot)
-    # Log dosyasını Hugging Face Hub'a yükleyin
     HF_REPO_ID = "SamiKoen/BF"  # Kendi repo kimliğinizi girin.
-    HF_TOKEN = os.getenv("HF_TOKEN")  # Token'ı ortam değişkeni olarak alabilirsiniz.
+    HF_TOKEN = os.getenv("HF_TOKEN")
     upload_logs_to_hf(HF_REPO_ID, HF_TOKEN)
-    
     return save_status
 
-from huggingface_hub import HfApi, create_repo
-
-# HF_TOKEN'ı ortam değişkeninden alıyoruz
-HF_TOKEN = os.getenv("HF_TOKEN")
-if not HF_TOKEN:
-    raise ValueError("HF_TOKEN ortam değişkeni ayarlanmamış!")
-
-# Repository oluşturma (space_sdk parametresi eklenmiş)
-create_repo("BF", token=HF_TOKEN, repo_type="space", space_sdk="gradio", exist_ok=True)
-
-
-
-
 # Gradio arayüzü
 demo_css = """
 #send_button, #save_button {