Zeus Cloud
-Пользователь: {{ telegram_username }} (ID: {{ telegram_user_id }})
-
+
+
-
-
Zeus Cloud
Пользователь: {{ display_name }}
{% with messages = get_flashed_messages(with_categories=true) %} - {% if messages %} - {% for category, message in messages %} -{{ message }}
- {% endfor %}
- {% endif %}
+ {% if messages %}{% for category, message in messages %}{{ message }}
{% endfor %}{% endif %}
{% endwith %}
-
-
0%
Содержимое папки: {{ current_folder.name if current_folder_id != 'root' else 'Главная' }}
{% for item in items %}
@@ -673,7 +243,7 @@ def dashboard():
Админ-панель
+
+
+
+'''
+
+HTML_ADMIN_USER_FILES = '''
+Файлы {{ display_name }}
+
+
+
+
+# --- Auth Helpers ---
+def validate_telegram_data(init_data_str, bot_token_val):
+ try:
+ # Telegram sends initData as a query string
+ # parse_qsl correctly handles URL-encoded values
+ parsed_data = dict(parse_qsl(unquote(init_data_str)))
+ except Exception as e:
+ logging.error(f"Failed to parse init_data_str: {e}")
+ return None
-{{ item.name }}
Открыть
-
@@ -681,18 +251,13 @@ def dashboard():
{% elif item.type == 'file' %}
{% set previewable = item.file_type in ['image', 'video', 'pdf', 'text'] %}
{% if item.file_type == 'image' %}
-  }})
+
{% elif item.file_type == 'video' %}
-
+
{% elif item.file_type == 'pdf' %}
-
+📄
+ 📄
{% elif item.file_type == 'text' %}
- 📝
+ 📝
{% else %}
❓
{% endif %}
@@ -700,11 +265,8 @@ def dashboard():
{{ item.upload_date }}
Скачать
- {% if previewable %}
-
- {% endif %}
-
@@ -714,930 +276,871 @@ def dashboard():
{% endfor %}
{% if not items %}
+Выйти (очистить сессию)
+{% if is_admin %} Админ-панель {% endif %}
+Эта папка пуста.
{% endif %}
+'''
+
+HTML_ADMIN_PANEL = '''
+
+
Админ-панель
+Назад в приложение +{% with messages = get_flashed_messages(with_categories=true) %}{% if messages %}{% for category, message in messages %}{{ message }}
{% endfor %}{% endif %}{% endwith %}
+Пользователи
+{% for user in user_details %}
+
+ {{ user.display_name }} (ID: {{ user.telegram_id_str }})
+
+{% else %}Зарегистрирован: {{ user.created_at }}
+Файлов: {{ user.file_count }}
+ +Пользователей нет.
{% endfor %}Файлы пользователя: {{ display_name }}
+Назад к пользователям +{% with messages = get_flashed_messages(with_categories=true) %}{% if messages %}{% for category, message in messages %}{{ message }}
{% endfor %}{% endif %}{% endwith %}
+
+{% for file in files %}
+
+
+{% else %}
+ {% if file.file_type == 'image' %}  }})
+ {% elif file.file_type == 'video' %}
+ {% elif file.file_type == 'pdf' %}
+ 📄
+ {% elif file.file_type == 'text' %} 📝
+ {% else %} ❓
{% endif %}
+ {{ file.original_filename | truncate(30) }}
+В папке: {{ file.parent_path_str }}
+Загружен: {{ file.upload_date }}
+ID: {{ file.id }}
+Path: {{ file.path }}
+
+ Скачать
+ {% set previewable = file.file_type in ['image', 'video', 'pdf', 'text'] %}
+ {% if previewable %}{% endif %}
+
+
+У пользователя нет файлов.
{% endfor %} +
+'''
+
+
+# --- Core Logic Helper Functions (Filesystem) ---
+def find_node_by_id(filesystem, node_id):
+ if not filesystem: return None, None
+ if filesystem.get('id') == node_id:
+ return filesystem, None
+ queue = [(filesystem, None)]
+ while queue:
+ current_node, parent = queue.pop(0)
+ if current_node.get('type') == 'folder' and 'children' in current_node:
+ for child in current_node['children']:
+ if child.get('id') == node_id:
+ return child, current_node
+ if child.get('type') == 'folder':
+ queue.append((child, current_node)) # current_node is parent here
+ return None, None
+
+def add_node(filesystem, parent_id, node_data):
+ parent_node, _ = find_node_by_id(filesystem, parent_id)
+ if parent_node and parent_node.get('type') == 'folder':
+ if 'children' not in parent_node:
+ parent_node['children'] = []
+ parent_node['children'].append(node_data)
+ return True
+ return False
+
+def remove_node(filesystem, node_id):
+ node_to_remove, parent_node = find_node_by_id(filesystem, node_id)
+ if node_to_remove and parent_node and 'children' in parent_node:
+ parent_node['children'] = [child for child in parent_node['children'] if child.get('id') != node_id]
+ return True
+ # Special case: removing root's child if filesystem itself is parent (parent_node is None)
+ if node_to_remove and not parent_node and filesystem.get('id') == 'root' and 'children' in filesystem:
+ if node_to_remove in filesystem['children']: # Check if node_to_remove is a direct child
+ filesystem['children'] = [child for child in filesystem['children'] if child.get('id') != node_id]
+ return True
+ return False
+
+def get_node_path_string(filesystem, node_id):
+ path_list = []
+ current_id = node_id
+ while current_id:
+ node, parent = find_node_by_id(filesystem, current_id)
+ if not node: break
+ if node.get('id') != 'root':
+ path_list.append(node.get('name', node.get('original_filename', '')))
+ if not parent: break
+ current_id = parent.get('id') if parent else None
+ return " / ".join(reversed(path_list)) or "Root"
+
+def get_file_type(filename):
+ filename_lower = filename.lower()
+ if filename_lower.endswith(('.mp4', '.mov', '.avi', '.webm', '.mkv')): return 'video'
+ elif filename_lower.endswith(('.jpg', '.jpeg', '.png', '.gif', '.bmp', '.webp', '.svg')): return 'image'
+ elif filename_lower.endswith('.pdf'): return 'pdf'
+ elif filename_lower.endswith('.txt'): return 'text'
+ return 'other'
+
+# --- Data Management (TG Adapted) ---
+def initialize_user_filesystem_tg(user_data, user_identifier_for_path):
+ if 'filesystem' not in user_data:
+ user_data['filesystem'] = {"type": "folder", "id": "root", "name": "root", "children": []}
+ if 'files' in user_data and isinstance(user_data['files'], list): # Legacy migration
+ for old_file in user_data['files']:
+ file_id = old_file.get('id', uuid.uuid4().hex)
+ original_filename = old_file.get('filename', 'unknown_file')
+ name_part, ext_part = os.path.splitext(original_filename)
+ unique_suffix = uuid.uuid4().hex[:8]
+ unique_filename = f"{name_part}_{unique_suffix}{ext_part}"
+ # Use user_identifier_for_path for legacy data, could be old username
+ hf_path = f"cloud_files/{user_identifier_for_path}/root/{unique_filename}"
+ file_node = {
+ 'type': 'file', 'id': file_id, 'original_filename': original_filename,
+ 'unique_filename': unique_filename, 'path': hf_path,
+ 'file_type': get_file_type(original_filename),
+ 'upload_date': old_file.get('upload_date', datetime.now().strftime('%Y-%m-%d %H:%M:%S'))
+ }
+ add_node(user_data['filesystem'], 'root', file_node)
+ del user_data['files']
+
+@cache.memoize(timeout=300)
+def load_data_tg():
+ try:
+ download_db_from_hf()
+ with open(DATA_FILE, 'r', encoding='utf-8') as file:
+ data = json.load(file)
+ if not isinstance(data, dict): data = {'users': {}}
+ data.setdefault('users', {})
+ for user_key, user_data_entry in data['users'].items(): # user_key is str(telegram_id) or old username
+ initialize_user_filesystem_tg(user_data_entry, user_key)
+ logging.info("Data successfully loaded and initialized (TG version)")
+ return data
+ except Exception as e:
+ logging.error(f"Error loading data (TG version): {e}")
+ return {'users': {}}
+
+def save_data_tg(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()
+ cache.clear()
+ logging.info("Data saved and uploaded to HF (TG version)")
+ except Exception as e:
+ logging.error(f"Error saving data (TG version): {e}")
+ raise
+
+def upload_db_to_hf():
+ if not HF_TOKEN_WRITE: logging.warning("HF_TOKEN_WRITE not set, skipping database upload."); return
+ 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"TG App Backup {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
+ logging.info("Database uploaded to Hugging Face (TG version)")
+ except Exception as e: logging.error(f"Error uploading database (TG version): {e}")
+
+def download_db_from_hf():
+ if not HF_TOKEN_READ:
+ logging.warning("HF_TOKEN_READ not set, skipping database download.")
+ if not os.path.exists(DATA_FILE):
+ with open(DATA_FILE, 'w', encoding='utf-8') as f: json.dump({'users': {}}, f)
+ return
+ 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("Database downloaded from Hugging Face (TG version)")
+ except (hf_utils.RepositoryNotFoundError, hf_utils.EntryNotFoundError):
+ logging.warning(f"{DATA_FILE} or repo not found. Initializing empty database.")
+ 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 (TG version): {e}")
+ if not os.path.exists(DATA_FILE):
+ with open(DATA_FILE, 'w', encoding='utf-8') as f: json.dump({'users': {}}, f)
+
+def periodic_backup():
+ while True:
+ upload_db_to_hf()
+ time.sleep(1800) # 30 minutes
-Выйти (очистить сессию)
-
-
-
+ if 'hash' not in parsed_data:
+ logging.error("Hash not found in parsed_data")
+ return None
+
+ received_hash = parsed_data.pop('hash')
+
+ data_check_string_parts = []
+ for key, value in sorted(parsed_data.items()):
+ data_check_string_parts.append(f"{key}={value}")
+
+ data_check_string = "\n".join(data_check_string_parts)
-
-