Update app.py

app.py

@@ -1,3 +1,5 @@
+--- START OF FILE app (36).py ---
+
 import flask
 from flask import Flask, render_template_string, request, redirect, url_for, session, flash, send_file, jsonify, Response
 from flask_caching import Cache
@@ -20,8 +22,9 @@ DATA_FILE = 'cloudeng_data_tma.json'
 REPO_ID = "Eluza133/Z1e1u"
 HF_TOKEN_WRITE = os.getenv("HF_TOKEN")
 HF_TOKEN_READ = os.getenv("HF_TOKEN_READ") or HF_TOKEN_WRITE
-TELEGRAM_BOT_TOKEN = os.getenv("TELEGRAM_BOT_TOKEN", "6750208873:AAE2hvPlJ99dBdhGa_Brre0IIpUdOvXxHt4")
+TELEGRAM_BOT_TOKEN = os.getenv("TELEGRAM_BOT_TOKEN", "6750208873:AAE2hvPlS99dBdhGa_Brre0IIpUdOvXxHt4")
 ADMIN_TELEGRAM_ID = os.getenv("ADMIN_TELEGRAM_ID", "YOUR_ADMIN_TELEGRAM_USER_ID_HERE")
+BOT_USERNAME = os.getenv("BOT_USERNAME", "ZeusCloudBot")
 
 ADMIN_USERNAME = os.getenv("ADMIN_USERNAME", "admin")
 ADMIN_PASSWORD = os.getenv("ADMIN_PASSWORD", "zeusadminpass")
@@ -238,7 +241,6 @@ def load_data():
 
         return data
     except Exception as e:
-        logging.error(f"Error loading data: {e}")
         return {'users': {}}
 
 def save_data(data):
@@ -248,7 +250,6 @@ def save_data(data):
         upload_db_to_hf()
         cache.clear()
     except Exception as e:
-        logging.error(f"Error saving data: {e}")
         raise
 
 def upload_db_to_hf():
@@ -261,7 +262,7 @@ def upload_db_to_hf():
             commit_message=f"Backup {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}"
         )
     except Exception as e:
-        logging.error(f"Error uploading database: {e}")
+        pass
 
 def download_db_from_hf():
     if not HF_TOKEN_READ:
@@ -277,7 +278,6 @@ def download_db_from_hf():
         if not os.path.exists(DATA_FILE):
             with open(DATA_FILE, 'w', encoding='utf-8') as f: json.dump({'users': {}}, f)
     except Exception as e:
-        logging.error(f"Error downloading database: {e}")
         if not os.path.exists(DATA_FILE):
             with open(DATA_FILE, 'w', encoding='utf-8') as f: json.dump({'users': {}}, f)
 
@@ -389,7 +389,6 @@ def auth_via_telegram():
             try:
                 save_data(data)
             except Exception as e:
-                 logging.error(f"Save data error for new TMA user {tma_user_id_str}: {e}")
                  return jsonify({'status': 'error', 'message': 'Ошибка сохранения данных нового пользователя.'}), 500
 
         session['telegram_user_id'] = tma_user_id_str
@@ -399,7 +398,6 @@ def auth_via_telegram():
         return jsonify({'status': 'success', 'redirect_url': url_for('tma_dashboard')})
 
     except Exception as e:
-        logging.error(f"Error in auth_via_telegram: {e}")
         return jsonify({'status': 'error', 'message': 'Внутренняя ошибка сервера при авторизации.'}), 500
 
 TMA_DASHBOARD_HTML_TEMPLATE = '''
@@ -416,9 +414,7 @@ TMA_DASHBOARD_HTML_TEMPLATE = '''
     {% endif %}
 </p>
 {% if not user_data.unlimited_storage %}
-    <form method="POST" action="{{ url_for('tma_buy_unlimited') }}" style="display: contents;">
-        <button type="submit" class="btn" style="background: var(--secondary); margin-left: 0; margin-bottom: 10px;">Купить безлимит за 20 ⭐️</button>
-    </form>
+    <button type="button" class="btn" style="background: var(--secondary); margin-left: 0; margin-bottom: 10px;" onclick="buyUnlimitedStorage('{{ tma_user_id }}', '{{ bot_username }}')">Купить безлимит за 2000 ⭐️</button>
 {% endif %}
 {% with messages = get_flashed_messages(with_categories=true) %}{% if messages %}
     {% for category, message in messages %}<div class="flash {{ category }}">{{ message }}</div>{% endfor %}
@@ -519,10 +515,8 @@ TMA_DASHBOARD_HTML_TEMPLATE = '''
 
     function tmaDownloadFile(downloadUrl, filename) {
         if (window.Telegram && window.Telegram.WebApp && Telegram.WebApp.openLink) {
-            console.log(`Attempting TMA download for: ${filename} via URL: ${downloadUrl}`);
             Telegram.WebApp.openLink(downloadUrl);
         } else {
-            console.warn("Telegram.WebApp.openLink not available, or not in TMA environment. Attempting fallback download.");
             const link = document.createElement('a');
             link.href = downloadUrl;
             link.setAttribute('download', filename);
@@ -556,6 +550,16 @@ TMA_DASHBOARD_HTML_TEMPLATE = '''
       });
     }
     document.getElementById('logout-btn').addEventListener('click', function(e) { e.preventDefault(); window.location.href = "{{ url_for('tma_logout') }}"; });
+
+    function buyUnlimitedStorage(userId, botUsername) {
+        if (!Telegram.WebApp.openLink) {
+            Telegram.WebApp.showAlert('Telegram Web App Link opening is not available.');
+            return;
+        }
+        const deepLink = `https://t.me/${botUsername}?start=buy_unlimited_stars_${userId}`;
+        Telegram.WebApp.openLink(deepLink);
+        Telegram.WebApp.showAlert('Вас перенаправит в чат с ботом для оплаты. После оплаты свяжитесь с администратором для актива��ии безлимитного хранилища.');
+    }
 </script></body></html>
 '''
 
@@ -658,7 +662,7 @@ def tma_dashboard():
                     else:
                         errors_list.append(f"Ошибка добавления метаданных для {original_filename}.")
                         try: api.delete_file(path_in_repo=hf_path, repo_id=REPO_ID, repo_type="dataset", token=HF_TOKEN_WRITE)
-                        except Exception as del_err: logging.error(f"Failed to delete orphaned file {hf_path} from HF Hub: {del_err}")
+                        except Exception as del_err: pass
                 except Exception as e:
                     errors_list.append(f"Ошибка загрузки файла {original_filename}: {e}")
                 finally:
@@ -692,7 +696,8 @@ def tma_dashboard():
         breadcrumbs=breadcrumbs, repo_id_js=REPO_ID, HF_TOKEN_READ_js=HF_TOKEN_READ,
         hf_file_url_jinja=lambda path, download=False: f"https://huggingface.co/datasets/{REPO_ID}/resolve/main/{path}{'?download=true' if download else ''}",
         is_tma_user_admin_flag=is_admin_tma(),
-        user_data=user_data, storage_used_formatted=storage_used_formatted)
+        user_data=user_data, storage_used_formatted=storage_used_formatted,
+        tma_user_id=tma_user_id, bot_username=BOT_USERNAME)
 
 
 @app.route('/tma_buy_unlimited', methods=['POST'])
@@ -709,16 +714,8 @@ def tma_buy_unlimited():
         session.clear()
         flash('Пользователь не найден.', 'error')
         return redirect(url_for('tma_entry_page'))
-
-    if str(tma_user_id) == str(ADMIN_TELEGRAM_ID):
-        user_data['unlimited_storage'] = True
-        try:
-            save_data(data)
-            flash('ВНИМАНИЕ (АДМИН): Безлимитное хранилище активировано для этого пользователя.', 'success')
-        except Exception as e:
-            flash(f'Ошибка сохранения данных при активации безлимита: {e}', 'error')
-    else:
-        flash('Для получения безлимитного хранилища оплатите 20 Telegram Stars через официальный платеж. (Текущая версия: обратитесь к администратору для активации).', 'info')
+    
+    flash('Для получения безлимитного хранилища оплатите 2000 Telegram Stars через бота. После оплаты свяжитесь с администратором для активации.', 'info')
 
     return redirect(url_for('tma_dashboard'))
 
@@ -833,10 +830,8 @@ def download_tma(file_id):
         return resp
 
     except requests.exceptions.RequestException as e:
-        logging.error(f"Error downloading file {original_filename} (ID: {file_id}) from HF: {e}")
         flash(f'Ошибка скачивания файла: {e}', 'error')
     except Exception as e:
-        logging.error(f"Internal error during download {original_filename} (ID: {file_id}): {e}")
         flash(f'Внутренняя ошибка при скачивании: {e}', 'error')
     return redirect(redirect_url)
 
@@ -1201,7 +1196,6 @@ def admin_delete_user(tma_user_id_str):
     except hf_utils.HfHubHTTPError as e:
          if e.response.status_code != 404: 
              flash(f'Ошибка удаления файлов пользователя {tma_user_id_str} с сервера: {e}. Пользователь из базы не удален.', 'error'); return redirect(url_for('admin_panel'))
-         logging.info(f"Folder {user_folder_path_on_hf} not found on HF Hub for user {tma_user_id_str} or was already empty, proceeding with DB deletion.")
     except Exception as e:
         flash(f'Ошибка удаления файлов пользователя {tma_user_id_str} с сервера: {e}. Пользователь из базы не удален.', 'error'); return redirect(url_for('admin_panel'))
     
@@ -1260,11 +1254,16 @@ def admin_delete_file(tma_user_id_str_form, file_id):
 
 
 if __name__ == '__main__':
-    if not HF_TOKEN_WRITE: logging.warning("HF_TOKEN (write access) is not set. Uploads/deletions/backups will fail.")
-    if not HF_TOKEN_READ: logging.warning("HF_TOKEN_READ is not set. Using HF_TOKEN. Downloads/previews might fail for private repos if HF_TOKEN also lacks read.")
-    if ADMIN_TELEGRAM_ID == "YOUR_ADMIN_TELEGRAM_USER_ID_HERE": logging.warning("ADMIN_TELEGRAM_ID is not set. TMA admin features might not work as expected for specific users.")
-    if ADMIN_USERNAME == "admin" and ADMIN_PASSWORD == "zeusadminpass":
-        logging.warning("Using default admin username/password for browser admin panel. Please change ADMIN_USERNAME and ADMIN_PASSWORD environment variables.")
+    if os.getenv("HF_TOKEN") is None:
+        pass
+    if os.getenv("HF_TOKEN_READ") is None:
+        pass
+    if os.getenv("ADMIN_TELEGRAM_ID") == "YOUR_ADMIN_TELEGRAM_USER_ID_HERE":
+        pass
+    if os.getenv("ADMIN_USERNAME") == "admin" and os.getenv("ADMIN_PASSWORD") == "zeusadminpass":
+        pass
+    if os.getenv("BOT_USERNAME") == "ZeusCloudBot":
+        pass
 
 
     if HF_TOKEN_WRITE: