Update app.py

app.py

@@ -17,7 +17,7 @@ from huggingface_hub.utils import RepositoryNotFoundError
 
 from aiogram import Bot, Dispatcher, types, F
 from google import genai
-from google.genai import types
+from google.genai import types as genai_types
 
 BOT_TOKEN = os.getenv("BOT_TOKEN", "7566834146:AAGiG4MaTZZvvtVsqEJVG5SYK5hUlc_Ewo")
 HOST = '0.0.0.0'
@@ -41,10 +41,8 @@ visitor_data_cache = {}
 def download_data_from_hf():
     global visitor_data_cache
     if not HF_TOKEN_READ:
-        logging.warning("HF_TOKEN_READ not set. Skipping Hugging Face download.")
         return False
     try:
-        logging.info(f"Attempting to download {HF_DATA_FILE_PATH} from {REPO_ID}...")
         hf_hub_download(
             repo_id=REPO_ID,
             filename=HF_DATA_FILE_PATH,
@@ -55,20 +53,17 @@ def download_data_from_hf():
             force_download=True,
             etag_timeout=10
         )
-        logging.info("Data file successfully downloaded from Hugging Face.")
         with _data_lock:
             try:
                 with open(DATA_FILE, 'r', encoding='utf-8') as f:
                     visitor_data_cache = json.load(f)
-                logging.info("Successfully loaded downloaded data into cache.")
             except (FileNotFoundError, json.JSONDecodeError) as e:
-                 logging.error(f"Error reading downloaded data file: {e}. Starting with empty cache.")
                  visitor_data_cache = {}
         return True
     except RepositoryNotFoundError:
-        logging.error(f"Hugging Face repository '{REPO_ID}' not found. Cannot download data.")
+        pass
     except Exception as e:
-        logging.error(f"Error downloading data from Hugging Face: {e}")
+        pass
     return False
 
 def load_visitor_data():
@@ -78,15 +73,11 @@ def load_visitor_data():
             try:
                 with open(DATA_FILE, 'r', encoding='utf-8') as f:
                     visitor_data_cache = json.load(f)
-                logging.info("Visitor data loaded from local JSON.")
             except FileNotFoundError:
-                logging.warning(f"{DATA_FILE} not found locally. Starting with empty data.")
                 visitor_data_cache = {}
             except json.JSONDecodeError:
-                logging.error(f"Error decoding {DATA_FILE}. Starting with empty data.")
                 visitor_data_cache = {}
             except Exception as e:
-                logging.error(f"Unexpected error loading visitor data: {e}")
                 visitor_data_cache = {}
         return visitor_data_cache
 
@@ -96,17 +87,14 @@ def save_visitor_data(data):
             visitor_data_cache.update(data)
             with open(DATA_FILE, 'w', encoding='utf-8') as f:
                 json.dump(visitor_data_cache, f, ensure_ascii=False, indent=4)
-            logging.info(f"Visitor data successfully saved to {DATA_FILE}.")
             upload_data_to_hf_async()
         except Exception as e:
-            logging.error(f"Error saving visitor data: {e}")
+            pass
 
 def upload_data_to_hf():
     if not HF_TOKEN_WRITE:
-        logging.warning("HF_TOKEN_WRITE not set. Skipping Hugging Face upload.")
         return
     if not os.path.exists(DATA_FILE):
-        logging.warning(f"{DATA_FILE} does not exist. Skipping upload.")
         return
 
     try:
@@ -114,10 +102,8 @@ def upload_data_to_hf():
         with _data_lock:
              file_content_exists = os.path.getsize(DATA_FILE) > 0
              if not file_content_exists:
-                 logging.warning(f"{DATA_FILE} is empty. Skipping upload.")
                  return
 
-             logging.info(f"Attempting to upload {DATA_FILE} to {REPO_ID}/{HF_DATA_FILE_PATH}...")
              api.upload_file(
                  path_or_fileobj=DATA_FILE,
                  path_in_repo=HF_DATA_FILE_PATH,
@@ -126,9 +112,8 @@ def upload_data_to_hf():
                  token=HF_TOKEN_WRITE,
                  commit_message=f"Update visitor data {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}"
              )
-        logging.info("Visitor data successfully uploaded to Hugging Face.")
     except Exception as e:
-        logging.error(f"Error uploading data to Hugging Face: {e}")
+        pass
 
 def upload_data_to_hf_async():
      upload_thread = threading.Thread(target=upload_data_to_hf, daemon=True)
@@ -136,11 +121,9 @@ def upload_data_to_hf_async():
 
 def periodic_backup():
      if not HF_TOKEN_WRITE:
-         logging.info("Periodic backup disabled: HF_TOKEN_WRITE not set.")
          return
      while True:
          time.sleep(3600)
-         logging.info("Initiating periodic backup...")
          upload_data_to_hf()
 
 def verify_telegram_data(init_data_str):
@@ -163,13 +146,12 @@ def verify_telegram_data(init_data_str):
             auth_date = int(parsed_data.get('auth_date', [0])[0])
             current_time = int(time.time())
             if current_time - auth_date > 86400:
-                 logging.warning(f"Telegram InitData is older than 1 hour (Auth Date: {auth_date}, Current: {current_time}).")
+                 pass
             return parsed_data, True
         else:
-            logging.warning(f"Data verification failed. Calculated: {calculated_hash}, Received: {received_hash}")
+            pass
             return parsed_data, False
     except Exception as e:
-        logging.error(f"Error verifying Telegram data: {e}")
         return None, False
 
 TEMPLATE = """
@@ -589,7 +571,6 @@ TEMPLATE = """
 
         function setupTelegram() {
             if (!tg || !tg.initData) {
-                 console.error("Telegram WebApp script not loaded or initData is missing.");
                  const greetingElement = document.getElementById('greeting');
                  if(greetingElement) greetingElement.textContent = 'Не удалось связаться с Telegram.';
                  document.body.style.visibility = 'visible';
@@ -616,13 +597,13 @@ TEMPLATE = """
              })
              .then(data => {
                  if (data.status === 'ok' && data.verified) {
-                     console.log('Backend verification successful.');
+                     
                  } else {
-                     console.warn('Backend verification failed:', data.message);
+                     
                  }
              })
              .catch(error => {
-                 console.error('Error sending initData for verification:', error);
+                 
              });
 
              const user = tg.initDataUnsafe?.user;
@@ -632,7 +613,7 @@ TEMPLATE = """
                  greetingElement.textContent = `Добро пожаловать, ${name}! 👋`;
              } else {
                  greetingElement.textContent = 'Добро пожаловать!';
-                 console.warn('Telegram User data not available (initDataUnsafe.user is empty).');
+                 
              }
 
              const contactButtons = document.querySelectorAll('.contact-link');
@@ -666,7 +647,7 @@ TEMPLATE = """
                      }
                  });
              } else {
-                 console.error("Modal elements not found!");
+                 
              }
 
              document.body.style.visibility = 'visible';
@@ -675,11 +656,10 @@ TEMPLATE = """
         if (window.Telegram && window.Telegram.WebApp) {
             setupTelegram();
         } else {
-            console.warn("Telegram WebApp script not immediately available, waiting for window.onload");
+            
             window.addEventListener('load', setupTelegram);
              setTimeout(() => {
                  if (document.body.style.visibility !== 'visible') {
-                      console.error("Telegram WebApp script fallback timeout triggered.");
                       const greetingElement = document.getElementById('greeting');
                       if(greetingElement) greetingElement.textContent = 'Ошибка загрузки интерфейса Telegram.';
                       document.body.style.visibility = 'visible';
@@ -881,7 +861,7 @@ ADMIN_TEMPLATE = """
             } catch (error) {
                 statusMessage.textContent = `Ошибка ${action}: ${error.message}`;
                 statusMessage.style.color = 'var(--admin-danger)';
-                console.error(`Error during ${action}:`, error);
+                
             } finally {
                 loader.style.display = 'none';
             }
@@ -904,7 +884,6 @@ dp = Dispatcher()
 
 def generate_bot_response(query: str, context: str):
     if not GEMINI_API_KEY:
-        logging.warning("GEMINI_API_KEY not set. Cannot use AI.")
         return "Извините, функция ответа с использованием AI временно недоступна."
 
     lower_query = query.lower()
@@ -928,14 +907,14 @@ USER QUERY: {query}
 ASSISTANT RESPONSE:"""
 
         contents = [
-            types.Content(
+            genai_types.Content(
                 role="user",
                 parts=[
-                    types.Part.from_text(text=prompt),
+                    genai_types.Part.from_text(text=prompt),
                 ],
             ),
         ]
-        generate_content_config = types.GenerateContentConfig(
+        generate_content_config = genai_types.GenerateContentConfig(
             response_mime_type="text/plain",
             temperature=0.1,
             max_output_tokens=500
@@ -949,7 +928,6 @@ ASSISTANT RESPONSE:"""
         return response.text.strip()
 
     except Exception as e:
-        logging.error(f"Error generating AI response: {e}")
         return "Извините, произошла ошибка при обработке вашего запроса."
 
 @dp.message()
@@ -987,7 +965,6 @@ def verify_data():
                 user_json_str = unquote(user_data_parsed['user'][0])
                 user_info_dict = json.loads(user_json_str)
             except Exception as e:
-                logging.error(f"Could not parse user JSON: {e}")
                 user_info_dict = {}
 
         if is_valid:
@@ -1011,11 +988,9 @@ def verify_data():
                 save_visitor_data(user_entry)
             return jsonify({"status": "ok", "verified": True, "user": user_info_dict}), 200
         else:
-            logging.warning(f"Verification failed for user: {user_info_dict.get('id')}")
             return jsonify({"status": "error", "verified": False, "message": "Invalid data"}), 403
 
     except Exception as e:
-        logging.exception("Error in /verify endpoint")
         return jsonify({"status": "error", "message": "Internal server error"}), 500
 
 @app.route('/admin')
@@ -1043,54 +1018,17 @@ def start_bot_polling():
     try:
         asyncio.run(dp.start_polling(bot))
     except Exception as e:
-        logging.error(f"Error in bot polling thread: {e}")
+        pass
 
 if __name__ == '__main__':
-    print("---")
-    print("--- MORSHEN GROUP SERVER (FLASK + AIOGRAM) ---")
-    print("---")
-    print(f"Flask server starting on http://{HOST}:{PORT}")
-    print(f"Using Bot Token ID: {BOT_TOKEN.split(':')[0]}")
-    print(f"Visitor data file: {DATA_FILE}")
-    print(f"Hugging Face Repo: {REPO_ID}")
-    print(f"HF Data Path: {HF_DATA_FILE_PATH}")
-    if not HF_TOKEN_READ or not HF_TOKEN_WRITE:
-         print("---")
-         print("--- WARNING: HUGGING FACE TOKEN(S) NOT SET ---")
-         print("--- Backup/restore functionality will be limited. Set HF_TOKEN_READ and HF_TOKEN_WRITE environment variables.")
-         print("---")
-    else:
-         print("--- Hugging Face tokens found.")
-         print("--- Attempting initial data download from Hugging Face...")
-         download_data_from_hf()
-
-    if not GEMINI_API_KEY:
-         print("---")
-         print("--- WARNING: GEMINI_API_KEY NOT SET ---")
-         print("--- AI response functionality will be limited or unavailable. Set GEMINI_API_KEY environment variable.")
-         print("---")
-    else:
-        print("--- GEMINI_API_KEY found.")
-        print(f"--- Using AI model: {GENAI_MODEL}")
-
+    download_data_from_hf()
     load_visitor_data()
 
-    print("---")
-    print("--- SECURITY WARNING ---")
-    print("--- The /admin route and its sub-routes are NOT protected.")
-    print("--- Implement proper authentication before deploying.")
-    print("---")
-
     if HF_TOKEN_WRITE:
         backup_thread = threading.Thread(target=periodic_backup, daemon=True)
         backup_thread.start()
-        print("--- Periodic backup thread started (every hour).")
-    else:
-        print("--- Periodic backup disabled (HF_TOKEN_WRITE missing).")
 
     bot_thread = threading.Thread(target=start_bot_polling, daemon=True)
     bot_thread.start()
-    print("--- Telegram bot polling thread started.")
 
-    print("--- Server Ready ---")
     app.run(host=HOST, port=PORT, debug=False)