Update app.py

app.py

@@ -79,7 +79,7 @@ def predict(system_msg, inputs, top_p, temperature, chat_counter, chatbot=[], hi
     history.append(inputs)
     print(f"Logging: Payload is - {payload}")
     
-    # Kullanıcı mesajını anında yazma (isteğe bağlı)
+    # Kullanıcı mesajını anında yazma
     try:
         with open(LOG_FILE, 'a', encoding='utf-8') as f:
             f.write(f"User: {inputs}\n")
@@ -91,40 +91,59 @@ def predict(system_msg, inputs, top_p, temperature, chat_counter, chatbot=[], hi
     print(f"Logging: Response code - {response.status_code}")
     if response.status_code != 200:
         print(f"API hatası: {response.text}")
+        yield chatbot, history, chat_counter, response  # Hata durumunda erken çıkış
     
     token_counter = 0
     partial_words = ""
     counter = 0
     for chunk in response.iter_lines():
-        if counter == 0:
-            counter += 1
+        counter += 1
+        if not chunk:
             continue
-        if chunk:
-            chunk = chunk.decode('utf-8')
-            print(f"Chunk: {chunk}")
-            if len(chunk) > 12 and "content" in json.loads(chunk[6:])['choices'][0]['delta']:
-                partial_words += json.loads(chunk[6:])['choices'][0]["delta"]["content"]
-                print(f"Partial words: {partial_words}")
-                if token_counter == 0:
-                    history.append(" " + partial_words)
+        chunk_str = chunk.decode('utf-8')
+        print(f"Chunk {counter}: {chunk_str}")
+        
+        # Veri akışını kontrol et
+        if chunk_str.startswith("data: ") and chunk_str != "data: [DONE]":
+            try:
+                chunk_data = json.loads(chunk_str[6:])  # "data: " önekini çıkar
+                delta = chunk_data['choices'][0]['delta']
+                if 'content' in delta:
+                    content = delta['content']
+                    partial_words += content
+                    print(f"İçerik eklendi: {content}")
+                    print(f"Güncel partial_words: {partial_words}")
                 else:
-                    history[-1] = partial_words
-                chat = [(history[i], history[i + 1]) for i in range(0, len(history) - 1, 2)]
-                token_counter += 1
-                yield chat, history, chat_counter, response
-
-    # Bot yanıtını anında yazma (isteğe bağlı)
-    try:
-        with open(LOG_FILE, 'a', encoding='utf-8') as f:
-            f.write(f"Bot: {partial_words}\n")
-            print(f"Bot yanıtı dosyaya yazıldı: {partial_words}")
-    except Exception as e:
-        print(f"Dosya yazma hatası (Bot): {e}")
+                    print("Bu chunk içerik içermiyor (delta boş veya başka bilgi taşıyor)")
+            except json.JSONDecodeError as e:
+                print(f"JSON parse hatası: {e} - Chunk: {chunk_str}")
+        elif chunk_str == "data: [DONE]":
+            print("Akış tamamlandı: [DONE] alındı")
+        
+        # Chatbot güncellemesi
+        if partial_words:
+            if token_counter == 0:
+                history.append(" " + partial_words)
+            else:
+                history[-1] = partial_words
+            chat = [(history[i], history[i + 1]) for i in range(0, len(history) - 1, 2)]
+            token_counter += 1
+            yield chat, history, chat_counter, response
+
+    # Bot yanıtını dosyaya yazma
+    if partial_words:
+        try:
+            with open(LOG_FILE, 'a', encoding='utf-8') as f:
+                f.write(f"Bot: {partial_words}\n")
+                print(f"Bot yanıtı dosyaya yazıldı: {partial_words}")
+        except Exception as e:
+            print(f"Dosya yazma hatası (Bot): {e}")
+    else:
+        print("Uyarı: partial_words boş, bot yanıtı yazılamadı!")
 
 def save_chat(chatbot):
+    """ Sohbeti dosyaya kaydetme fonksiyonu """
     file_path = os.path.abspath(LOG_FILE)
-    if not chatbot:
-        return f"Hata: Kaydedilecek sohbet yok!\nDosya: {file_path}"
     try:
         with open(LOG_FILE, 'a', encoding='utf-8') as f:
             f.write("\n--- Kayıt Edilen Sohbet ---\n")
@@ -140,8 +159,6 @@ def save_chat(chatbot):
 def reset_textbox():
     return gr.update(value='')
 
-
-
 # Gradio arayüzü
 demo_css = """
 #send_button, #save_button {
@@ -210,22 +227,17 @@ with gr.Blocks(css=demo_css, theme=theme) as demo:
                 save_button = gr.Button(value="Kayıt Et", elem_id="save_button")
         
         state = gr.State([])
-        save_status = gr.Textbox(label="Kayıt Durumu", interactive=False)  # Kayıt durumu için geri bildirim
+        save_status = gr.Textbox(label="Kayıt Durumu", interactive=False)
         
         with gr.Accordion("", open=False, visible=False):
             top_p = gr.Slider(minimum=0, maximum=1.0, value=0.5, step=0.05, interactive=False, visible=False)
             temperature = gr.Slider(minimum=0, maximum=5.0, value=0.1, step=0.1, interactive=False, visible=False)
             chat_counter = gr.Number(value=0, visible=False, precision=0)
         
-        # ENTER tuşuyla gönderme
         inputs.submit(predict, [system_msg, inputs, top_p, temperature, chat_counter, chatbot, state], [chatbot, state, chat_counter])
         inputs.submit(reset_textbox, [], [inputs])
-        
-        # Gönder butonu
         send_button.click(predict, [system_msg, inputs, top_p, temperature, chat_counter, chatbot, state], [chatbot, state, chat_counter])
         send_button.click(reset_textbox, [], [inputs])
-        
-        # Kayıt Et butonu
         save_button.click(save_chat, [chatbot], [save_status])
 
 demo.queue(max_size=10).launch(debug=True)