Update app.py

app.py

@@ -84,38 +84,45 @@ def download_db_from_hf(specific_file=None, retries=DOWNLOAD_RETRIES, delay=DOWN
                     force_download=True,
                     resume_download=False
                 )
+                logging.info(f"Successfully downloaded {file_name} to {local_path}")
                 success = True
                 break
             except RepositoryNotFoundError:
+                 logging.error(f"Repository {REPO_ID} not found. Cannot download file.")
                  return False
             except HfHubHTTPError as e:
                 if e.response.status_code == 404:
+                    logging.warning(f"{file_name} not found in repo. Will try to create a local empty one if needed.")
                     if attempt == 0 and not os.path.exists(file_name):
                         try:
                             if file_name == DATA_FILE:
                                 with open(file_name, 'w', encoding='utf-8') as f:
                                     json.dump({}, f)
+                                logging.info(f"Created empty local file: {file_name}")
                         except Exception as create_e:
-                            pass
+                            logging.error(f"Could not create local empty file {file_name}: {create_e}")
                     success = False
                     break
                 else:
-                    pass
+                    logging.error(f"HTTP error downloading {file_name} on attempt {attempt+1}: {e}")
             except requests.exceptions.RequestException as e:
-                 pass
+                 logging.error(f"Network error downloading {file_name} on attempt {attempt+1}: {e}")
             except Exception as e:
-                 pass
+                 logging.error(f"An unexpected error occurred downloading {file_name} on attempt {attempt+1}: {e}")
 
             if attempt < retries:
+                logging.info(f"Retrying download of {file_name} in {delay} seconds...")
                 time.sleep(delay)
 
         if not success:
+            logging.error(f"Failed to download {file_name} after {retries+1} attempts.")
             all_successful = False
 
     return all_successful
 
 def upload_db_to_hf(specific_file=None):
     if not HF_TOKEN_WRITE:
+        logging.warning("HF_TOKEN_WRITE not set. Skipping upload to Hugging Face.")
         return
     try:
         api = HfApi()
@@ -132,17 +139,19 @@ def upload_db_to_hf(specific_file=None):
                         token=HF_TOKEN_WRITE,
                         commit_message=f"Sync {file_name} {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}"
                     )
+                    logging.info(f"Successfully uploaded {file_name} to Hugging Face.")
                 except Exception as e:
-                     pass
+                     logging.error(f"Failed to upload {file_name} to Hugging Face: {e}")
             else:
-                pass
+                logging.warning(f"File {file_name} not found locally. Skipping upload.")
     except Exception as e:
-        pass
+        logging.error(f"An unexpected error occurred during the upload process: {e}")
 
 def periodic_backup():
     backup_interval = 1800
     while True:
         time.sleep(backup_interval)
+        logging.info("Starting periodic backup...")
         upload_db_to_hf()
 
 def load_data():
@@ -150,15 +159,19 @@ def load_data():
         with open(DATA_FILE, 'r', encoding='utf-8') as f:
             data = json.load(f)
         if not isinstance(data, dict):
+            logging.warning(f"{DATA_FILE} does not contain a dictionary. Resetting to empty.")
             data = {}
     except (FileNotFoundError, json.JSONDecodeError):
+        logging.warning(f"{DATA_FILE} not found or corrupted. Attempting to download from Hugging Face.")
         if download_db_from_hf(specific_file=DATA_FILE):
             try:
                 with open(DATA_FILE, 'r', encoding='utf-8') as f:
                     data = json.load(f)
                 if not isinstance(data, dict):
+                    logging.warning(f"Downloaded {DATA_FILE} is not a dictionary. Resetting to empty.")
                     data = {}
             except (FileNotFoundError, json.JSONDecodeError):
+                logging.error(f"Failed to load {DATA_FILE} even after download. Using empty data.")
                 data = {}
         else:
             data = {}
@@ -168,9 +181,11 @@ def save_data(data):
     try:
         with open(DATA_FILE, 'w', encoding='utf-8') as file:
             json.dump(data, file, ensure_ascii=False, indent=4)
-        upload_db_to_hf(specific_file=DATA_FILE)
+        upload_thread = threading.Thread(target=upload_db_to_hf, kwargs={'specific_file': DATA_FILE})
+        upload_thread.daemon = True
+        upload_thread.start()
     except Exception as e:
-        pass
+        logging.error(f"Error in save_data: {e}")
 
 def is_chat_active(env_id):
     data = get_env_data(env_id)
@@ -251,11 +266,14 @@ def save_env_data(env_id, env_data):
 
 def configure_gemini():
     if not GOOGLE_API_KEY:
+        logging.warning("GOOGLE_API_KEY is not set. Gemini AI features will be disabled.")
         return False
     try:
         genai.configure(api_key=GOOGLE_API_KEY)
+        logging.info("Google Gemini AI configured successfully.")
         return True
     except Exception as e:
+        logging.error(f"Failed to configure Google Gemini AI: {e}")
         return False
 
 def generate_ai_description_from_image(image_data, language):
@@ -268,6 +286,7 @@ def generate_ai_description_from_image(image_data, language):
         image_stream = io.BytesIO(image_data)
         image = Image.open(image_stream).convert('RGB')
     except Exception as e:
+        logging.error(f"Error processing image for AI description: {e}")
         raise ValueError(f"Не удалось обработать изображение. Убедитесь, что это действительный файл изображения.")
 
     base_prompt = "Напиши большой и красивый, содержательный рекламный пост минимум на 1000 символов со смайликами и 25 тематических хэштегов с ключевыми словами разных вариантов, чтобы мои клиенты могли найти меня в поиске Instagram, Google и т.д. по ключевым словам. Пост пиши исключительно под товар, который на фото, без адресов и номеров телефона."
@@ -299,6 +318,7 @@ def generate_ai_description_from_image(image_data, language):
                 return response.text
 
     except Exception as e:
+        logging.error(f"Error during AI content generation: {e}")
         if "API key not valid" in str(e):
              raise ValueError("Внутренняя ошибка конфигурации API.")
         elif " Billing account not found" in str(e):
@@ -404,6 +424,7 @@ def generate_chat_response(message, chat_history_from_client, env_id):
         return generated_text
 
     except Exception as e:
+        logging.error(f"Error generating chat response: {e}")
         if "API key not valid" in str(e):
              return "Внутренняя ошибка конфигурации API."
         elif " Billing account not found" in str(e):
@@ -2055,11 +2076,13 @@ ADMIN_TEMPLATE = '''
             .item .description { font-size: 0.85rem; color: #999; max-height: 60px; overflow: hidden; text-overflow: ellipsis; }
             .item-actions { margin-top: 15px; display: flex; gap: 10px; flex-wrap: wrap; align-items: center; }
             .edit-form-container { margin-top: 15px; padding: 20px; background: #E0F2F1; border: 1px dashed #B2DFDB; border-radius: 6px; display: none; }
-            details { background-color: #fdfdff; border: 1px solid #e0e0e0; border-radius: 8px; margin-bottom: 20px; }
-            details > summary { cursor: pointer; font-weight: 600; color: var(--bg-medium); display: block; padding: 15px; border-bottom: 1px solid #e0e0e0; list-style: none; position: relative; }
+            details { background-color: #fdfdff; border-radius: 8px; margin-bottom: 10px; }
+            details:not(.section) { border: 1px solid #e0e0e0; }
+            details > summary { cursor: pointer; font-weight: 600; color: var(--bg-medium); display: block; padding: 15px; list-style: none; position: relative; }
+            details:not(.section) > summary { border-bottom: 1px solid #e0e0e0; }
+            details[open] > summary { border-bottom: 1px solid #e0e0e0; }
             details > summary::after { content: '\\f078'; font-family: 'Font Awesome 6 Free'; font-weight: 900; position: absolute; right: 20px; top: 50%; transform: translateY(-50%); transition: transform 0.2s ease; color: var(--bg-medium); }
             details[open] > summary::after { transform: translateY(-50%) rotate(180deg); }
-            details[open] > summary { border-bottom: 1px solid #e0e0e0; }
             details .form-content { padding: 20px; }
             .color-input-group { display: flex; align-items: center; gap: 10px; margin-bottom: 8px; }
             .color-input-group input { flex-grow: 1; margin: 0; }
@@ -2121,7 +2144,8 @@ ADMIN_TEMPLATE = '''
                      <p>Чат <strong>активен</strong>. Срок действия истекает: <strong class="{{ 'status-indicator expires-soon' if chat_status.expires_soon else '' }}">{{ chat_status.expires_date }}</strong></p>
                  {% else %}
                      <p>Чат <strong>неактивен</strong>. {% if chat_status.expires_date %}Срок действия истек: {{ chat_status.expires_date }}{% endif %}</p>
-                     <p style="color: var(--danger);">Для возобновления работы чат-бота, активируйте его в <a href="{{ url_for('admhosto') }}">главной админ-панели</a>.</p>
+                     <p>Для активации или продления чат-бота, пожалуйста, свяжитесь с администратором.</p>
+                     <a href="https://wa.me/77472479197" class="button add-button" target="_blank" style="margin-top: 10px;"><i class="fab fa-whatsapp"></i> Написать администратору</a>
                  {% endif %}
             </div>
 
@@ -2183,20 +2207,22 @@ ADMIN_TEMPLATE = '''
 
 
             <div class="section">
-                <h2><i class="fas fa-comments"></i> Диалоги с {{ settings.chat_name }}</h2>
-                <div class="item-list">
-                    {% if chats %}
-                        {% for chat_id, chat_data in chats.items()|sort(reverse=True) %}
-                        <div class="chat-log-item" onclick="viewChat('{{ chat_id }}')">
-                            <strong>ID Диалога:</strong> {{ chat_id }}
-                            <br>
-                            <small>Сообщений: {{ chat_data|length }} | Последнее сообщение: {{ chat_data[-1].timestamp if chat_data and 'timestamp' in chat_data[-1] else 'N/A' }}</small>
-                        </div>
-                        {% endfor %}
-                    {% else %}
-                        <p>Пока не было ни одного диалога.</p>
-                    {% endif %}
-                </div>
+                <details>
+                    <summary><h2><i class="fas fa-comments"></i> Диалоги с {{ settings.chat_name }}</h2></summary>
+                    <div class="item-list" style="margin-top: 20px;">
+                        {% if chats %}
+                            {% for chat_id, chat_data in chats.items()|sort(reverse=True) %}
+                            <div class="chat-log-item" onclick="viewChat('{{ chat_id }}')">
+                                <strong>ID Диалога:</strong> {{ chat_id }}
+                                <br>
+                                <small>Сообщений: {{ chat_data|length }} | Последнее сообщение: {{ chat_data[-1].timestamp if chat_data and 'timestamp' in chat_data[-1] else 'N/A' }}</small>
+                            </div>
+                            {% endfor %}
+                        {% else %}
+                            <p>Пока не было ни одного диалога.</p>
+                        {% endif %}
+                    </div>
+                </details>
             </div>
 
             <div class="flex-container">
@@ -2820,6 +2846,7 @@ def create_order(env_id):
             })
             total_price += price * quantity
         except (ValueError, TypeError) as e:
+            logging.error(f"Invalid cart item format: {e}")
             return jsonify({"error": "Неверная цена или количество в товаре."}), 400
 
     order_id = f"{datetime.now().strftime('%Y%m%d%H%M%S')}-{uuid4().hex[:6]}"
@@ -2844,6 +2871,7 @@ def create_order(env_id):
         return jsonify({"order_id": order_id}), 201
 
     except Exception as e:
+        logging.error(f"Server error while creating order: {e}")
         return jsonify({"error": "Ошибка сервера при сохранении заказа."}), 500
 
 @app.route('/<env_id>/order/<order_id>')
@@ -2931,8 +2959,8 @@ def admin(env_id):
                             if old_avatar:
                                 try:
                                     api.delete_files(repo_id=REPO_ID, paths_in_repo=[f"avatars/{old_avatar}"], repo_type="dataset", token=HF_TOKEN_WRITE)
-                                except Exception:
-                                    pass
+                                except Exception as e:
+                                    logging.warning(f"Could not delete old avatar {old_avatar}: {e}")
 
                             ext = os.path.splitext(avatar_file.filename)[1].lower()
                             avatar_filename = f"avatar_{env_id}_{int(time.time())}{ext}"
@@ -2952,6 +2980,7 @@ def admin(env_id):
                             flash("Аватар чата успешно обновлен.", 'success')
                         except Exception as e:
                             flash(f"Ошибка при загрузке аватара: {e}", 'error')
+                            logging.error(f"Error uploading avatar: {e}")
                     else:
                         flash("HF_TOKEN (write) не настроен. Аватар не был загружен.", "warning")
 
@@ -3015,6 +3044,7 @@ def admin(env_id):
                                 uploaded_count += 1
                             except Exception as e:
                                 flash(f"Ошибка при загрузке фото {photo.filename}.", 'error')
+                                logging.error(f"Error uploading photo {photo.filename}: {e}")
                                 if os.path.exists(temp_path):
                                     try: os.remove(temp_path)
                                     except OSError: pass
@@ -3024,7 +3054,7 @@ def admin(env_id):
                          if os.path.exists(uploads_dir) and not os.listdir(uploads_dir):
                              os.rmdir(uploads_dir)
                     except OSError as e:
-                        pass
+                        logging.warning(f"Could not remove temp upload directory: {e}")
                 elif not HF_TOKEN_WRITE and photos_files and any(f.filename for f in photos_files):
                     flash("HF_TOKEN (write) не настроен. Фотографии не были загружены.", "warning")
 
@@ -3098,6 +3128,7 @@ def admin(env_id):
                                 uploaded_count += 1
                             except Exception as e:
                                 flash(f"Ошибка при загрузке нового фото {photo.filename}.", 'error')
+                                logging.error(f"Error uploading new photo {photo.filename}: {e}")
                                 if os.path.exists(temp_path):
                                      try: os.remove(temp_path)
                                      except OSError: pass
@@ -3105,7 +3136,7 @@ def admin(env_id):
                          if os.path.exists(uploads_dir) and not os.listdir(uploads_dir):
                              os.rmdir(uploads_dir)
                     except OSError as e:
-                        pass
+                        logging.warning(f"Could not remove temp upload directory: {e}")
 
                     if new_photos_list:
                         old_photos = product_to_edit.get('photos', [])
@@ -3121,6 +3152,7 @@ def admin(env_id):
                                 )
                             except Exception as e:
                                 flash("Не удалось удалить старые фотографии с сервера. Новые фото загружены.", "warning")
+                                logging.warning(f"Could not delete old photos for product {product_to_edit['name']}: {e}")
                         product_to_edit['photos'] = new_photos_list
                         flash("Фотографии товара успешно обновлены.", "success")
                     elif uploaded_count == 0 and any(f.filename for f in photos_files):
@@ -3155,6 +3187,7 @@ def admin(env_id):
                         )
                     except Exception as e:
                          flash(f"Не удалось удалить фото для товара '{product_name}' с сервера. Товар удален локально.", "warning")
+                         logging.warning(f"Could not delete photos for product {product_name}: {e}")
                 elif photos_to_delete and not HF_TOKEN_WRITE:
                     flash(f"Товар '{product_name}' удален локально, но фото не удалены с сервера (токен не задан).", "warning")
 
@@ -3168,6 +3201,7 @@ def admin(env_id):
             return redirect(url_for('admin', env_id=env_id))
 
         except Exception as e:
+             logging.error(f"An internal error occurred in admin POST action '{action}': {e}")
              flash(f"Произошла внутренняя ошибка при выполнении действия '{action}'. Подробности в логе сервера.", 'error')
              return redirect(url_for('admin', env_id=env_id))
 
@@ -3228,6 +3262,7 @@ def handle_generate_description_ai():
     except ValueError as ve:
         return jsonify({"error": str(ve)}), 400
     except Exception as e:
+        logging.error(f"Internal server error during AI description generation: {e}")
         return jsonify({"error": f"Внутренняя ошибка сервера: {e}"}), 500
 
 @app.route('/<env_id>/chat_with_ai', methods=['POST'])
@@ -3261,6 +3296,7 @@ def handle_chat_with_ai(env_id):
         
         return jsonify({"text": ai_response_text})
     except Exception as e:
+        logging.error(f"Error in chat handler: {e}")
         return jsonify({"error": f"Ошибка чата: {e}"}), 500
 
 @app.route('/<env_id>/chat')
@@ -3302,6 +3338,7 @@ def force_upload(env_id):
         flash("Данные успешно загружены на Hugging Face.", 'success')
     except Exception as e:
         flash(f"Ошибка при загрузке на Hugging Face: {e}", 'error')
+        logging.error(f"Error during forced upload: {e}")
     return redirect(url_for('admin', env_id=env_id))
 
 @app.route('/<env_id>/force_download', methods=['POST'])
@@ -3313,6 +3350,7 @@ def force_download(env_id):
             flash("Не удалось скачать данные с Hugging Face после нескольких попыток. Проверьте логи.", 'error')
     except Exception as e:
         flash(f"Ошибка при скачивании с Hugging Face: {e}", 'error')
+        logging.error(f"Error during forced download: {e}")
     return redirect(url_for('admin', env_id=env_id))
 
 if __name__ == '__main__':
@@ -3323,8 +3361,9 @@ if __name__ == '__main__':
     if HF_TOKEN_WRITE:
         backup_thread = threading.Thread(target=periodic_backup, daemon=True)
         backup_thread.start()
+        logging.info("Periodic backup thread started.")
     else:
-        pass
+        logging.warning("HF_TOKEN_WRITE not set, periodic backups are disabled.")
 
     port = int(os.environ.get('PORT', 7860))
     app.run(debug=False, host='0.0.0.0', port=port)