Update app.py

app.py

@@ -3,8 +3,14 @@ import os
 import json
 import requests
 import xml.etree.ElementTree as ET
+import schedule
+import time
+import threading
 from huggingface_hub import HfApi, create_repo
 
+# Global değişken: sohbet geçmişi (otomatik kayıt için kullanılacak)
+global_chat_history = []
+
 # Dosya yolu: Kalıcı depolama için öncelik, yoksa geçici dizin
 LOG_FILE = '/persistent-storage/chat_logs.txt'
 persistent_dir = '/persistent-storage'
@@ -50,6 +56,7 @@ if not hfapi:
 create_repo("BF", token=hfapi, repo_type="space", space_sdk="gradio", exist_ok=True)
 
 def predict(system_msg, inputs, top_p, temperature, chat_counter, chatbot=None, history=None):
+    global global_chat_history
     if chatbot is None:
         chatbot = []
     if history is None:
@@ -144,8 +151,12 @@ def predict(system_msg, inputs, top_p, temperature, chat_counter, chatbot=None,
             chat.append({"role": "assistant", "content": partial_words})
         elif partial_words and chat and chat[-1]["role"] == "assistant":
             chat[-1] = {"role": "assistant", "content": partial_words}
+        # Global sohbet geçmişini güncelle
+        global_chat_history = chatbot.copy()
         yield chat, history, chat_counter
     print(f"Son chatbot durumu: {chatbot}")
+    # Son durumda da güncelleme yap
+    global_chat_history = chatbot.copy()
     return chatbot, history, chat_counter
 
 def save_chat(chatbot):
@@ -167,11 +178,6 @@ def reset_textbox():
 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.
-    
-    Args:
-repo_id (str): Repository kimliği (örn. "SamiKoen/BF").
-        hf_token (str): Hugging Face API token'ınız.
-        local_log_file (str): Yüklenecek log dosyasının yolu.
     """
     api = HfApi(token=hf_token)
     try:
@@ -193,6 +199,28 @@ def save_chat_and_upload(chatbot):
     upload_logs_to_hf(HF_REPO_ID, hfapi)
     return save_status
 
+# Otomatik kayıt fonksiyonu (schedule ile çağrılacak)
+def scheduled_save():
+    global global_chat_history
+    if global_chat_history:
+        print("Otomatik kayıt tetiklendi.")
+        save_chat_and_upload(global_chat_history)
+
+# Scheduler'ı arka planda çalıştıracak fonksiyon
+def run_scheduler():
+    while True:
+        schedule.run_pending()
+        time.sleep(1)
+
+# Belirli saatlerde otomatik kayıt (örn. 12:00, 18:00 ve 23:00)
+schedule.every().day.at("12:00").do(scheduled_save)
+schedule.every().day.at("18:00").do(scheduled_save)
+schedule.every().day.at("23:00").do(scheduled_save)
+
+# Scheduler'ı daemon thread ile başlatıyoruz
+scheduler_thread = threading.Thread(target=run_scheduler, daemon=True)
+scheduler_thread.start()
+
 # Gradio arayüzü
 demo_css = """
 #send_button, #save_button {
@@ -272,5 +300,4 @@ with gr.Blocks(css=demo_css, theme=theme) as demo:
         send_button.click(predict, [system_msg, inputs, top_p, temperature, chat_counter, chatbot, state], [chatbot, state, chat_counter])
         send_button.click(reset_textbox, [], [inputs])
         
-
-demo.queue(max_size=10).launch(debug=True)
+demo.queue(max_size=10).launch(debug=True)