Update app.py

app.py

@@ -2,15 +2,25 @@ from flask import Flask, render_template_string, request, redirect, url_for
 import json
 import os
 import logging
+import threading
+import time
+from datetime import datetime
+from huggingface_hub import HfApi, hf_hub_download
 
 app = Flask(__name__)
 DATA_FILE = 'products.json'
 
+# --- Настройки Hugging Face ---
+REPO_ID = "Testbase1/testsett"  # Замените на ваш репозиторий
+HF_TOKEN_WRITE = os.getenv("HF_TOKEN")  # Токен для записи (загрузки)
+HF_TOKEN_READ = os.getenv("HF_TOKEN_READ")  # Токен для чтения (скачивания)
+
 # Настройка логирования
 logging.basicConfig(level=logging.DEBUG)
 
-# Загрузка данных из JSON-файла
+# --- Функции для работы с JSON ---
 def load_data():
+    """Загружает данные из JSON-файла."""
     if os.path.exists(DATA_FILE):
         try:
             with open(DATA_FILE, 'r', encoding='utf-8') as file:
@@ -19,13 +29,12 @@ def load_data():
             logging.error("Ошибка: Невозможно декодировать JSON файл.")
             return []
     else:
-        # Создание пустого файла, если его нет
         with open(DATA_FILE, 'w', encoding='utf-8') as file:
             json.dump([], file, ensure_ascii=False, indent=4)
         return []
 
-# Сохранение данных в JSON-файл
 def save_data(data):
+    """Сохраняет данные в JSON-файл."""
     try:
         with open(DATA_FILE, 'w', encoding='utf-8') as file:
             json.dump(data, file, ensure_ascii=False, indent=4)
@@ -33,7 +42,45 @@ def save_data(data):
         logging.error(f"Ошибка при сохранении данных: {e}")
         raise
 
-# Главная страница каталога
+# --- Функции для резервного копирования ---
+def upload_db_to_hf():
+    """Загружает JSON-файл базы данных в репозиторий Hugging Face."""
+    try:
+        api = HfApi()
+        api.upload_file(
+            path_or_fileobj=DATA_FILE,
+            path_in_repo=DATA_FILE,
+            repo_id=REPO_ID,
+            repo_type="dataset",
+            token=HF_TOKEN_WRITE,
+            commit_message=f"Автоматическое резервное копирование базы данных {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}"
+        )
+        logging.info("Резервная копия JSON базы успешно загружена на Hugging Face.")
+    except Exception as e:
+        logging.error(f"Ошибка при загрузке резервной копии: {e}")
+
+def download_db_from_hf():
+    """Скачивает JSON-файл базы данных из репозитория Hugging Face."""
+    try:
+        hf_hub_download(
+            repo_id=REPO_ID,
+            filename=DATA_FILE,
+            repo_type="dataset",
+            token=HF_TOKEN_READ,
+            local_dir=".",
+            local_dir_use_symlinks=False
+        )
+        logging.info("JSON база успешно скачана из Hugging Face.")
+    except Exception as e:
+        logging.error(f"Ошибка при скачивании JSON базы: {e}")
+
+def periodic_backup():
+    """Периодически вызывает функцию upload_db_to_hf() каждые 100 секунд."""
+    while True:
+        upload_db_to_hf()
+        time.sleep(100)
+
+# --- Маршруты приложения ---
 @app.route('/')
 def catalog():
     products = load_data()
@@ -83,7 +130,6 @@ def catalog():
     '''
     return render_template_string(catalog_html, products=products)
 
-# Админ-панель для добавления товаров
 @app.route('/admin', methods=['GET', 'POST'])
 def admin():
     if request.method == 'POST':
@@ -95,13 +141,11 @@ def admin():
 
         if name and price and description:
             try:
-                # Обработка запятой в числе
-                price = float(price.replace(',', '.'))  # Заменяем запятую на точку (если есть)
+                price = float(price.replace(',', '.'))
             except ValueError:
                 logging.error("Ошибка: Цена должна быть числом.")
                 return "Ошибка: Цена должна быть числом.", 400
 
-            # Загрузка текущих данных
             products = load_data()
             products.append({
                 'name': name,
@@ -109,7 +153,6 @@ def admin():
                 'description': description
             })
 
-            # Сохранение данных
             try:
                 save_data(products)
             except Exception as e:
@@ -165,16 +208,6 @@ def admin():
             button:hover {
                 background-color: #218838;
             }
-            .product-list {
-                margin-top: 20px;
-            }
-            .product-item {
-                background-color: #fff;
-                border: 1px solid #ddd;
-                padding: 10px;
-                margin-bottom: 10px;
-                border-radius: 5px;
-            }
         </style>
     </head>
     <body>
@@ -192,19 +225,37 @@ def admin():
             <button type="submit">Добавить товар</button>
         </form>
 
-        <div class="product-list">
-            <h2>Список товаров</h2>
-            {% for product in products %}
-            <div class="product-item">
-                <strong>{{ product['name'] }}</strong> - {{ product['price'] }} руб.
-                <p>{{ product['description'] }}</p>
-            </div>
-            {% endfor %}
-        </div>
+        <h2>Управление базой данных</h2>
+        
+        <!-- Кнопки для резервной копии и скачивания -->
+        <form method="POST" action="{{ url_for('backup') }}">
+          <button type="submit">Создать резервную копию</button>
+        </form>
+
+        <form method="GET" action="{{ url_for('download') }}">
+          <button type="submit">Скачать базу данных</button>
+        </form>
+
     </body>
     </html>
     '''
-    return render_template_string(admin_html, products=products)
+    return render_template_string(admin_html)
+
+@app.route('/backup', methods=['POST'])
+def backup():
+    """Маршрут для создания резервной копии."""
+    upload_db_to_hf()
+    return "Резервная копия успешно создана.", 200
+
+@app.route('/download', methods=['GET'])
+def download():
+    """Маршрут для скачивания базы данных."""
+    download_db_from_hf()
+    return "База данных успешно скачана.", 200
 
 if __name__ == '__main__':
-    app.run(debug=True, host='0.0.0.0', port=7860)
+    # Запуск фонового потока для периодического резервного копирования
+    backup_thread = threading.Thread(target=periodic_backup, daemon=True)
+    backup_thread.start()
+
+    app.run(debug=True, host='0.0.0.0', port=7860)