Update app.py

app.py

@@ -16,16 +16,17 @@ DB_FILENAME = "auth_system.db"
 HF_TOKEN_WRITE = os.getenv("HF_TOKEN")      # Токен для записи (загрузки)
 HF_TOKEN_READ = os.getenv("HF_TOKEN_READ")    # Токен для чтения (скачивания)
 
-# Глобальные переменные для подключения к базе данных.
+# Глобальные переменные для подключения к базе данных
 conn = None
 c = None
 
 def init_db_connection():
-    """Открывает новое соединение с базой данных и сохраняет его в глобальных переменных."""
+    """Открывает новое соединение с базой данных с увеличенным таймаутом."""
     global conn, c
     if conn is not None:
         conn.close()
-    conn = sqlite3.connect(DB_FILENAME, check_same_thread=False)
+    # Устанавливаем timeout=30 секунд, чтобы операции ожидали освобождения блокировки
+    conn = sqlite3.connect(DB_FILENAME, check_same_thread=False, timeout=30)
     c = conn.cursor()
 
 # --- Создание таблиц, если они не существуют ---
@@ -112,10 +113,13 @@ def upload_db_to_hf():
 
 # --- Функция периодического резервного копирования ---
 def periodic_backup():
-    """Запускает бесконечный цикл резервного копирования с интервалом в 15 секунд."""
+    """
+    Запускает бесконечный цикл резервного копирования с интервалом в 30 минут.
+    Здесь не используются глобальные подключения, поскольку функция только читает файл.
+    """
     while True:
         upload_db_to_hf()
-        time.sleep(1800)
+        time.sleep(1800)  # 30 минут = 1800 секунд
 
 # --- Вспомогательные функции ---
 def generate_token():
@@ -398,7 +402,6 @@ def main():
     download_success = download_db_from_hf()
     if download_success:
         st.success("База данных успешно скачана из Hugging Face!")
-        # Изменяем права доступа, чтобы база стала доступна для записи
         try:
             os.chmod(DB_FILENAME, 0o666)
             st.info("Права доступа к базе данных изменены (read-write).")
@@ -414,7 +417,7 @@ def main():
     # Переинициализируем соединение с базой данных после изменения прав доступа
     init_db_connection()
 
-    # Проверка существования таблицы "users"
+    # Проверка наличия таблицы "users". Если отсутствует, создаём таблицы.
     try:
         c.execute("SELECT * FROM users LIMIT 1")
     except sqlite3.OperationalError as e:
@@ -436,7 +439,6 @@ def main():
     if st.session_state.logged_in:
         st.sidebar.title(f"Привет, {st.session_state.username}!")
         option = st.sidebar.selectbox("Выберите действие", ["Добавить товар", "Отпуск товара", "Редактировать товары", "Отчет за месяц", "Выйти"])
-
         if option == "Добавить товар":
             add_product()
         elif option == "Отпуск товара":
@@ -459,8 +461,7 @@ def main():
 
 if __name__ == "__main__":
     main()
-    # Ждем 15 секунд после скачивания/инициализации базы данных
+    # Ждем 15 секунд после инициализации базы данных, затем запускаем фоновый поток резервного копирования
     time.sleep(15)
-    # Запускаем фоновый поток резервного копирования
     backup_thread = threading.Thread(target=periodic_backup, daemon=True)
     backup_thread.start()