Zeus Cloud
-
- {% with messages = get_flashed_messages() %}
- {% if messages %}
- {% for message in messages %}
-
'''
- return render_template_string(html)
+ return render_template_string(html, is_authenticated=is_authenticated, username=username, unread_count=unread_count, user_count=user_count, private_unread_count=private_unread_count, is_online=is_online)
+
+@app.route('/logout')
+def logout():
+ data = load_data()
+ username = session.get('username', None)
+ if username:
+ update_last_seen(data, username)
+ session.pop('username', None)
+ return redirect(url_for('feed'))
-@app.route('/dashboard', methods=['GET', 'POST'])
-def dashboard():
+@app.route('/toggle_like/{{ message }}
- {% endfor %}
- {% endif %}
- {% endwith %}
+
+
-
- Login
+ {{% with messages = get_flashed_messages() %}} + {{% if messages %}} + {{% for message in messages %}} +{{{{ message }}}}
+ {{% endfor %}}
+ {{% endif %}}
+ {{% endwith %}}
+
+ Don't have an account? Register
Нет аккаунта? Зарегистрируйтесь
-
Zeus Cloud Dashboard
-Пользователь: {{ username }}
- {% with messages = get_flashed_messages() %} - {% if messages %} - {% for message in messages %} -{{ message }}
- {% endfor %}
- {% endif %}
- {% endwith %}
-
-
-
-
- Ваши файлы
-
- {% for file in user_files %}
- ', methods=['GET', 'POST'])
+def post_page(post_id):
+ data = load_data()
+ username = session.get('username', None)
+ if username:
+ update_last_seen(data, username)
+ post = next((p for p in data['posts'] if p['id'] == post_id), None)
+ if not post:
+ return "Post not found", 404
+
+ is_authenticated = 'username' in session
+ unread_count = get_unread_count(data, username) if is_authenticated else 0
+ private_unread_count = get_private_unread_count(data, username) if is_authenticated else 0
+ user_count = len(data['users'])
+ is_online = is_user_online(data, username) if is_authenticated else False
+ post['views'] = post.get('views', 0) + 1 #Increment views
+ save_data(data)
+
+ if request.method == 'POST' and is_authenticated:
+ if 'comment' in request.form:
+ comment_text = request.form.get('comment')
+ if comment_text:
+ post['comments'] = post.get('comments', []) + [{
+ 'user': username,
+ 'text': comment_text,
+ 'date': datetime.now().isoformat() # Use ISO 8601 format
+ }]
+ save_data(data)
+ # Redirect to the same page to prevent form resubmission
+ return redirect(url_for('post_page', post_id=post_id))
+
+ html = f'''
+
+
+
+
+
+
+ {{{{ post['title'] }}}} - Content Hub
+
+
+
+
+
+ {NAV_HTML}
+
+ /')
-def download_file(file_path, filename):
+@app.route('/profile', methods=['GET', 'POST'])
+def profile():
if 'username' not in session:
- flash('Пожалуйста, войдите!')
+ flash('Login to view your profile!')
return redirect(url_for('login'))
-
+
+ data = load_data()
username = session['username']
+ update_last_seen(data, username)
+ user_posts = sorted([p for p in data['posts'] if p['uploader'] == username], key=lambda x: datetime.fromisoformat(x['upload_date']), reverse=True)
+ is_authenticated = 'username' in session
+ unread_count = get_unread_count(data, username)
+ private_unread_count = get_private_unread_count(data, username)
+ user_count = len(data['users'])
+ is_online = is_user_online(data, username)
+
+ total_views = sum(post.get('views', 0) for post in user_posts)
+ total_likes = sum(len(post.get('likes', [])) for post in user_posts)
+ user_data = data['users'].get(username, {})
+ bio = user_data.get('bio', '')
+ link = user_data.get('link', '')
+ avatar = user_data.get('avatar', None)
+ last_seen = user_data.get('last_seen', 'Never')
+
+ if request.method == 'POST':
+ if 'delete_post' in request.form:
+ post_id = request.form.get('post_id')
+ if post_id:
+ # Find and remove the post
+ data['posts'] = [p for p in data['posts'] if p['id'] != post_id or p['uploader'] != username]
+ save_data(data)
+ return redirect(url_for('profile')) # Redirect after deletion
+
+ elif 'update_profile' in request.form:
+ bio = request.form.get('bio', '')
+ link = request.form.get('link', '')
+ avatar_file = request.files.get('avatar')
+
+ if avatar_file and avatar_file.filename:
+ filename = secure_filename(avatar_file.filename)
+ temp_path = os.path.join('uploads', filename)
+ os.makedirs('uploads', exist_ok=True)
+ avatar_file.save(temp_path)
+
+ api = HfApi()
+ avatar_path = f"avatars/{username}/{filename}"
+ api.upload_file(
+ path_or_fileobj=temp_path,
+ path_in_repo=avatar_path,
+ repo_id=REPO_ID,
+ repo_type="dataset",
+ token=HF_TOKEN_WRITE,
+ commit_message=f"Avatar uploaded for {username}"
+ )
+ data['users'][username]['avatar'] = avatar_path
+ # Clean up the temporary file
+ if os.path.exists(temp_path):
+ os.remove(temp_path)
+
+ data['users'][username]['bio'] = bio
+ data['users'][username]['link'] = link
+ save_data(data)
+ return redirect(url_for('profile')) # Redirect after update
+
+ html = f'''
+
+
+
+
+
+
+ Profile - {{{{ username }}}} - Content Hub
+
+
+
+
+
+ {NAV_HTML}
+
+ ', methods=['GET'])
+def user_profile(username):
data = load_data()
+ current_user = session.get('username', None)
+ if current_user:
+ update_last_seen(data, current_user)
if username not in data['users']:
- session.pop('username', None)
- flash('Пользователь не найден!')
- return redirect(url_for('login'))
-
- user_files = data['users'][username]['files']
- if not any(file['path'] == file_path for file in user_files):
- flash('У вас нет доступа к этому файлу!')
- return redirect(url_for('dashboard'))
-
- file_url = f"https://huggingface.co/datasets/{REPO_ID}/resolve/main/{file_path}"
- response = requests.get(file_url)
-
- if response.status_code == 200:
- file_content = BytesIO(response.content)
- return send_file(
- file_content,
- as_attachment=True,
- download_name=filename,
- mimetype='application/octet-stream'
- )
- else:
- flash('Ошибка при скачивании файла!')
- return redirect(url_for('dashboard'))
+ return "User not found", 404
+
+ user_posts = sorted([p for p in data['posts'] if p['uploader'] == username], key=lambda x: datetime.fromisoformat(x['upload_date']), reverse=True)
+ is_authenticated = 'username' in session
+ unread_count = get_unread_count(data, current_user) if is_authenticated else 0
+ private_unread_count = get_private_unread_count(data, current_user) if is_authenticated else 0
+ user_count = len(data['users'])
+ is_online = is_user_online(data, current_user) if is_authenticated else False
+
+ total_views = sum(post.get('views', 0) for post in user_posts)
+ total_likes = sum(len(post.get('likes', [])) for post in user_posts)
+ user_data = data['users'].get(username, {})
+ bio = user_data.get('bio', '')
+ link = user_data.get('link', '')
+ avatar = user_data.get('avatar', None)
+ last_seen = user_data.get('last_seen', 'Never')
+ user_online = is_user_online(data, username)
+
+ html = f'''
+
+
+
+
+
+
+ {{{{ username }}}}'s Profile - Content Hub
+
+
+
+
+
+ {NAV_HTML}
+
+ Upload Content - Content Hub
+
+
+
+
+
+ {NAV_HTML}
+
+ General Chat - Content Hub
+
+
+
+
+
+ {NAV_HTML}
+
+ Админ-панель - Zeus Cloud
+
+ Users - Content Hub
-
+
+
+ {NAV_HTML}
+
- {% if file['type'] == 'video' %}
-
- {% elif file['type'] == 'image' %}
- ![{{ file['filename'] }}](https://huggingface.co/datasets/{{ repo_id }}/resolve/main/{{ file['path'] }})
- {% else %}
-
- {% endfor %}
- {% if not user_files %}
- {{ file['filename'] }}
- {% endif %} -{{ file['upload_date'] }}
- Скачать - Удалить -У вас пока нет загруженных файлов.
+ + {NAV_HTML} + +
+ {% for post in posts %}
+
-
+ {% if post['type'] == 'video' %}
+
+
+ {% else %}
+ ![{{ post['title'] }}](https://huggingface.co/datasets/{{ repo_id }}/resolve/main/{{ post['type'] }}s/{{ post['filename'] }})
{% endif %}
+
+
- Выйти
-
+
+ {{ post['likes']|length }}
+
+ {{ post['comments']|length }}
+
+ {{ post['views'] }}
+
+
+ {% for comment in post.get('comments', []) %}
+
+
+ {{ comment['user'] }}: {{ comment['text'] }}
+
+ {% endfor %}
+ {% if is_authenticated %}
+
+ {% endif %}
+
-
+ {% endfor %}
+
+
+'''
+ return render_template_string(html,
+ posts=posts,
+ is_authenticated=is_authenticated,
+ username=username,
+ repo_id=REPO_ID,
+ unread_count=unread_count,
+ user_count=user_count,
+ private_unread_count=private_unread_count,
+ is_online=is_online,
+ is_user_online=lambda u: is_user_online(data, u),
+ data=data)
- // Обработка выхода
- document.getElementById('logout-btn').addEventListener('click', function(e) {
- e.preventDefault();
- localStorage.removeItem('zeusCredentials');
- window.location.href = '/logout';
- });
+@app.route('/post/
+
+
+ ![{{{{ post['title'] }}}}](https://huggingface.co/datasets/{{{{ repo_id }}}}/resolve/main/{{{{ post['type'] }}}}s/{{{{ post['filename'] }}}})
+ {{% endif %}}
+
+ {{{{ post['title'] }}}}
+ {{% if post['type'] == 'video' %}} + + {{% else %}} +{{{{ post['description'] }}}}
+By: {{{{ post['uploader'] }}}} | {{{{ post['upload_date'] }}}}
+Views: {{{{ post['views'] }}}} | Likes: {{{{ post['likes']|length }}}}
+ {{% if is_authenticated %}} + + + {{% endif %}} +Comments
+ {{% for comment in post.get('comments', []) %}} +
+
+ {{% endfor %}}
+ Back to Feed
+ {{% if not is_authenticated %}}
+ {{{{ comment['user'] }}}} ({{{{ comment['date'] }}}}): {{{{ comment['text'] }}}}
+Login to like and comment.
+ {{% endif %}} +
+ ![]()
+
+
'''
- return render_template_string(html, username=username, user_files=user_files, repo_id=REPO_ID)
+ return render_template_string(html, post=post, repo_id=REPO_ID, is_authenticated=is_authenticated, username=username, unread_count=unread_count, user_count=user_count, private_unread_count=private_unread_count, is_online=is_online, is_user_online=lambda u: is_user_online(data, u),data=data)
-@app.route('/download/
+
+
+ {{% if avatar %}}
+ 
+ {{% else %}}
+
+ {{% endif %}}
+
+
+
+
+ {{{{ username }}}}
+{{{{ bio }}}}
+ {{% if link %}} + + {{% endif %}} +Total Views: {{{{ total_views }}}} | Total Likes: {{{{ total_likes }}}}
+Last Seen: {{{{ last_seen }}}}
+Edit Profile
+
+
+
+
+ My Posts
+
+ {{% for post in user_posts %}}
+
+
+
+ {{% if post['type'] == 'video' %}}
+
+ {{% else %}}
+
+ {{% endif %}}
+
+ {{% endfor %}}
+ {{% if not user_posts %}}
+ {{{{ post['title'] }}}}
+ +{{{{ post['description']|truncate(100) }}}}
+{{{{ post['upload_date'] }}}} | Views: {{{{ post['views'] }}}} | Likes: {{{{ post['likes']|length }}}}
+ +You haven't uploaded any posts yet.
+ {{% endif %}} +
+ ![]()
+
+
+
+
+'''
+ return render_template_string(html,
+ username=username,
+ user_posts=user_posts,
+ bio=bio,
+ link=link,
+ avatar=avatar,
+ total_views=total_likes=total_likes,
+ last_seen=last_seen,
+ is_authenticated=is_authenticated,
+ repo_id=REPO_ID,
+ unread_count=unread_count,
+ user_count=user_count,
+ private_unread_count=private_unread_count,
+ is_online=is_online)
+
+@app.route('/user/
+
+
+ {{% if avatar %}}
+
+ {{% else %}}
+
+ {{% endif %}}
+
+
+
+ {{{{ username }}}}
+{{{{ bio }}}}
+ {{% if link %}} + + {{% endif %}} +Total Views: {{{{ total_views }}}} | Total Likes: {{{{ total_likes }}}}
+Last Seen: {{{{ last_seen }}}}
+ {{% if is_authenticated and current_user != username %}} + Send Message + {{% endif %}} +Posts
+
+ {{% for post in user_posts %}}
+
+
+
+ {{% if post['type'] == 'video' %}}
+
+ {{% else %}}
+
+ {{% endif %}}
+
+ {{% endfor %}}
+ {{% if not user_posts %}}
+ {{{{ post['title'] }}}}
+ +{{{{ post['description']|truncate(100) }}}}
+{{{{ post['upload_date'] }}}} | Views: {{{{ post['views'] }}}} | Likes: {{{{ post['likes']|length }}}}
+This user hasn't uploaded any posts yet.
+ {{% endif %}} +
+ ![]()
+
+
+
+
+'''
+ return render_template_string(html,
+ username=username,
+ user_posts=user_posts,
+ bio=bio,
+ link=link,
+ avatar=avatar,
+ total_views=total_views,
+ total_likes=total_likes,
+ last_seen=last_seen,
+ is_authenticated=is_authenticated,
+ current_user=current_user,
+ repo_id=REPO_ID,
+ unread_count=unread_count,
+ user_count=user_count,
+ private_unread_count=private_unread_count,
+ is_online=is_online,
+ user_online=user_online)
+
+@app.route('/upload', methods=['GET', 'POST'])
+def upload():
if 'username' not in session:
- flash('Пожалуйста, войдите!')
+ flash('Login to upload content!')
return redirect(url_for('login'))
-
- username = session['username']
+
data = load_data()
- if username not in data['users']:
- session.pop('username', None)
- flash('Пользователь не найден!')
- return redirect(url_for('login'))
-
- user_files = data['users'][username]['files']
- file_to_delete = next((file for file in user_files if file['path'] == file_path), None)
-
- if not file_to_delete:
- flash('Файл не найден!')
- return redirect(url_for('dashboard'))
-
- try:
+ username = session['username']
+ update_last_seen(data, username)
+ is_authenticated = 'username' in session
+ unread_count = get_unread_count(data, username)
+ private_unread_count = get_private_unread_count(data, username)
+ user_count = len(data['users'])
+ is_online = is_user_online(data, username)
+
+ if request.method == 'POST':
+ title = request.form.get('title')
+ description = request.form.get('description')
+ file = request.files.get('file')
+
+ if not file or not title:
+ flash('Title and file are required!')
+ return redirect(url_for('upload'))
+
+ filename = secure_filename(file.filename)
+ temp_path = os.path.join('uploads', filename)
+ os.makedirs('uploads', exist_ok=True)
+ file.save(temp_path)
+
+ file_type = 'video' if filename.lower().endswith(('.mp4', '.mov', '.avi')) else 'photo'
api = HfApi()
- api.delete_file(
+ file_path = f"{file_type}s/{username}/{filename}" # Include username in path
+ api.upload_file(
+ path_or_fileobj=temp_path,
path_in_repo=file_path,
repo_id=REPO_ID,
repo_type="dataset",
token=HF_TOKEN_WRITE,
- commit_message=f"Удален файл {file_path} для {username}"
+ commit_message=f"{file_type.capitalize()} uploaded by {username}"
)
- data['users'][username]['files'] = [f for f in user_files if f['path'] != file_path]
+ # Generate unique post ID. Important for avoiding collisions
+ post_id = str(random.randint(100000, 999999))
+ while any(p['id'] == post_id for p in data['posts']):
+ post_id = str(random.randint(100000, 999999))
+
+ data['posts'].append({
+ 'id': post_id,
+ 'title': title,
+ 'description': description,
+ 'filename': f"{username}/{filename}", # Store relative path
+ 'type': file_type,
+ 'uploader': username,
+ 'upload_date': datetime.now().isoformat(), # Use ISO 8601
+ 'views': 0,
+ 'likes': [],
+ 'comments': []
+ })
save_data(data)
- flash('Файл успешно удален!')
- except Exception as e:
- logging.error(f"Ошибка при удалении файла: {e}")
- flash('Ошибка при удалении файла!')
-
- return redirect(url_for('dashboard'))
-@app.route('/logout')
-def logout():
- session.pop('username', None)
- return redirect(url_for('login'))
+ if os.path.exists(temp_path):
+ os.remove(temp_path)
+
+ return redirect(url_for('profile')) # Redirect to profile after upload
+
+
+ html = f'''
+
+
+
+
+
+
+
+
+
+
+
+'''
+ return render_template_string(html,
+ username=username,
+ is_authenticated=is_authenticated,
+ repo_id=REPO_ID,
+ unread_count=unread_count,
+ user_count=user_count,
+ private_unread_count=private_unread_count,
+ is_online=is_online)
+@app.route('/chat', methods=['GET', 'POST'])
+def chat():
+ data = load_data()
+ username = session.get('username', None)
+ if username:
+ update_last_seen(data, username)
+ is_authenticated = 'username' in session
+ chat_messages = data['general_chat']
+
+ if is_authenticated:
+ data['users'][username]['last_chat_visit'] = datetime.now().isoformat() # Update last visit
+ save_data(data)
+
+ unread_count = get_unread_count(data, username) if is_authenticated else 0
+ private_unread_count = get_private_unread_count(data, username) if is_authenticated else 0
+ user_count = len(data['users'])
+ is_online = is_user_online(data, username) if is_authenticated else False
+
+ if request.method == 'POST' and is_authenticated:
+ message = request.form.get('message')
+ file = request.files.get('file')
+ post_id = request.form.get('post_id') #Get post
+
+ message_data = {
+ 'sender': username,
+ 'time': datetime.now().isoformat() # Use ISO 8601 format
+ }
+
+ if message:
+ message_data['text'] = message
+
+ if file and file.filename:
+ filename = secure_filename(file.filename)
+ temp_path = os.path.join('uploads', filename)
+ os.makedirs('uploads', exist_ok=True)
+ file.save(temp_path)
+
+ file_type = 'video' if filename.lower().endswith(('.mp4', '.mov', '.avi')) else 'photo'
+ api = HfApi()
+ file_path = f"chat_files/general/{filename}" # Store in chat_files
+ api.upload_file(
+ path_or_fileobj=temp_path,
+ path_in_repo=file_path,
+ repo_id=REPO_ID,
+ repo_type="dataset",
+ token=HF_TOKEN_WRITE,
+ commit_message=f"Chat file uploaded by {username}"
+ )
+ message_data['file'] = file_path
+ message_data['file_type'] = file_type
+ if os.path.exists(temp_path):
+ os.remove(temp_path)
+
+ # Handle post sharing
+ if post_id:
+ post = next((p for p in data['posts'] if p['id'] == post_id and p['uploader'] == username), None)
+ if(post):
+ message_data['post_id'] = post_id
+
+ if 'text' in message_data or 'file' in message_data or 'post_id' in message_data :
+ data['general_chat'].append(message_data)
+ save_data(data)
+
+ return redirect(url_for('chat')) # Redirect after sending
+
+
+ html = f'''
+
+
+
+
+
+
+
+
+ Upload Content
+ {{% with messages = get_flashed_messages() %}} + {{% if messages %}} + {{% for message in messages %}} +{{{{ message }}}}
+ {{% endfor %}}
+ {{% endif %}}
+ {{% endwith %}}
+
+
+
+
+
+
+
+
+ General Chat
+
+ {{% for message in chat_messages %}}
+
+ {{% if is_authenticated %}}
+
+ {{% else %}}
+
+
+ {{% if message['sender'] == username %}}
+ {{% if avatar %}}
+
+ {{% else %}}
+
+ {{% endif %}}
+ {{% else %}}
+ {{% if data['users'][message['sender']].get('avatar') %}}
+
+ {{% else %}}
+
+ {{% endif %}}
+ {{% endif %}}
+
+
+ {{% endfor %}}
+
+ {{{{ message['sender'] }}}}
+
+ {{% if 'text' in message %}}
+ 
+ {{% endif %}}
+ {{% endif %}}
+
+ {{% if 'post_id' in message %}}
+ {{% with post = posts|selectattr('id', 'equalto', message['post_id'])|first %}}
+ {{% if post %}}
+
+ {{{{ message['text'] }}}}
+ {{% endif %}} + {{% if 'file' in message %}} + {{% if message['file_type'] == 'video' %}} + + {{% else %}} +Shared: {{{{ post['title'] }}}}
+ {{% endif %}} + {{% endwith %}} + {{% endif %}} + {{{{ message['time'] }}}} +Login to send messages.
+ {{% endif %}} +
+ ![]()
+
+
+
+
+'''
+ user_posts = [p for p in data['posts'] if p['uploader'] == username] if is_authenticated else [] # Get user's posts
+ avatar = data['users'][username].get('avatar') if is_authenticated else None
+ return render_template_string(html,
+ chat_messages=chat_messages,
+ username=username,
+ is_authenticated=is_authenticated,
+ repo_id=REPO_ID,
+ posts=data['posts'],
+ user_posts=user_posts,
+ unread_count=unread_count,
+ user_count=user_count,
+ private_unread_count=private_unread_count,
+ is_online=is_online,
+ is_user_online=lambda u: is_user_online(data, u),
+ data=data,
+ avatar=avatar)
-# Новая админ-панель
-@app.route('/admhosto')
-def admin_panel():
+@app.route('/users', methods=['GET', 'POST'])
+def users():
data = load_data()
- users = data['users']
-
- html = '''
+ username = session.get('username', None)
+ if username:
+ update_last_seen(data, username)
+
+ is_authenticated = 'username' in session
+ unread_count = get_unread_count(data, username) if is_authenticated else 0
+ private_unread_count = get_private_unread_count(data, username) if is_authenticated else 0
+ user_count = len(data['users'])
+ is_online = is_user_online(data, username) if is_authenticated else False
+
+ search_query = request.form.get('search', '').strip().lower() if request.method == 'POST' else ''
+ user_list = [(user, data['users'][user].get('avatar'), is_user_online(data, user))
+ for user in data['users'] if not search_query or search_query in user.lower()]
+
+ html = f'''
-
- ')
-def admin_user_files(username):
data = load_data()
- if username not in data['users']:
- flash('Пользователь не найден!')
- return redirect(url_for('admin_panel'))
-
- user_files = sorted(data['users'][username]['files'], key=lambda x: x['upload_date'], reverse=True)
-
- html = '''
+ username = session['username']
+ update_last_seen(data, username)
+ is_authenticated = 'username' in session
+ unread_count = get_unread_count(data, username)
+ private_unread_count = get_private_unread_count(data, username)
+ user_count = len(data['users'])
+ is_online = is_user_online(data, username)
+
+ dialogs = {}
+ for chat_key, messages in data['private_chats'].items():
+ user1, user2 = chat_key.split('_')
+ if username not in (user1, user2):
+ continue
+ other_user = user1 if user2 == username else user2
+ last_message = messages[-1] if messages else None # Get the last message
+ # Count unread messages in this dialog
+ unread = sum(1 for msg in messages if datetime.fromisoformat(msg['time']) > datetime.fromisoformat(data['users'][username]['last_private_visit']) and msg['sender'] != username)
+ dialogs[other_user] = {
+ 'last_message': last_message,
+ 'unread': unread,
+ 'avatar': data['users'][other_user].get('avatar'),
+ 'online': is_user_online(data, other_user) # Check if the other user is online
+ }
+
+ html = f'''
- Файлы пользователя {{ username }} - Zeus Cloud
+
+ Messages - Content Hub
-
+
+
+ {NAV_HTML}
+
Админ-панель Zeus Cloud
-Список пользователей
-
- {% for username, user_data in users.items() %}
+
+
'''
- return render_template_string(html, users=users)
+ return render_template_string(html,
+ user_list=user_list,
+ username=username,
+ is_authenticated=is_authenticated,
+ repo_id=REPO_ID,
+ unread_count=unread_count,
+ user_count=user_count,
+ private_unread_count=private_unread_count,
+ is_online=is_online,
+ search_query=search_query)
+
+@app.route('/messages', methods=['GET'])
+def messages():
+ if 'username' not in session:
+ flash('Login to view messages!')
+ return redirect(url_for('login'))
-@app.route('/admhosto/user/
+
Users ({{{{ user_count }}}})
+
+
+
+
+ {{% for user, avatar, online in user_list %}}
+ {{% if user != username %}}
+
- {{ username }}
-
+ {{% else %}}
+
+ {{% endif %}}
+
- {% endfor %}
- {% if not users %}
- Дата регистрации: {{ user_data['created_at'] }}
-Количество файлов: {{ user_data['files'] | length }}
+ {{% if avatar %}} +Пользователей пока нет.
- {% endif %} + {{% endif %}} + {{% endfor %}}
-
Файлы пользователя: {{ username }}
- {% with messages = get_flashed_messages() %} - {% if messages %} - {% for message in messages %} -{{ message }}
- {% endfor %}
- {% endif %}
- {% endwith %}
-
- {% for file in user_files %}
-
- {% if file['type'] == 'video' %}
-
- {% elif file['type'] == 'image' %}
-
- {% else %}
-
- {{ file['filename'] }}
- {% endif %} -{{ file['upload_date'] }}
- Скачать +
+
- Назад к списку пользователей
Messages
+
+ {{% for other_user, info in dialogs.items() %}}
+
+ {{% if info.avatar %}}
+ 
+ {{% else %}}
+
+ {{% endif %}}
+
- {% endfor %}
- {% if not user_files %}
-
+ {{{{ other_user }}}}
+
+ {{% if info.last_message %}}
+
+ {{% if info.unread > 0 %}}
+ {{{{ info.unread }}}}
+ {{% endif %}}
{{{{ info.last_message['time'] }}}}: + {{% if 'text' in info.last_message %}}{{{{ info.last_message['text']|truncate(30) }}}}{{% elif 'file' in info.last_message %}}File{{% elif 'post_id' in info.last_message %}}Post{{% endif %}}
+ {{% endif %}} +У пользователя пока нет файлов.
- {% endif %} + {{% endfor %}} + {{% if not dialogs %}} +No messages yet.
+ {{% endif %}} +
-
+
+
+
+'''
+ return render_template_string(html,
+ dialogs=dialogs,
+ username=username,
+ is_authenticated=is_authenticated,
+ repo_id=REPO_ID,
+ unread_count=unread_count,
+ user_count=user_count,
+ private_unread_count=private_unread_count,
+ is_online=is_online)
+
+@app.route('/chat/', methods=['GET', 'POST'])
+def private_chat(recipient):
+ if 'username' not in session:
+ flash('Login to chat!')
+ return redirect(url_for('login'))
+
+ data = load_data()
+ username = session['username']
+ update_last_seen(data, username)
+ if recipient not in data['users']:
+ return "User not found", 404
+
+ is_authenticated = 'username' in session
+ unread_count = get_unread_count(data, username)
+ private_unread_count = get_private_unread_count(data, username)
+ user_count = len(data['users'])
+ is_online = is_user_online(data, username)
+
+ #Update last visit time for private chat
+ data['users'][username]['last_private_visit'] = datetime.now().isoformat()
+ save_data(data)
+
+ chat_key = f"{min(username, recipient)}_{max(username, recipient)}"
+ if chat_key not in data['private_chats']:
+ data['private_chats'][chat_key] = []
+ private_messages = data['private_chats'][chat_key]
+
+ if request.method == 'POST':
+ message = request.form.get('message')
+ file = request.files.get('file')
+ post_id = request.form.get('post_id')
+
+ message_data = {
+ 'sender': username,
+ 'time': datetime.now().isoformat() # Use ISO 8601 format
+ }
+
+ if message:
+ message_data['text'] = message
+
+ if file and file.filename:
+ filename = secure_filename(file.filename)
+ temp_path = os.path.join('uploads', filename)
+ os.makedirs('uploads', exist_ok=True)
+ file.save(temp_path)
+
+ file_type = 'video' if filename.lower().endswith(('.mp4', '.mov', '.avi')) else 'photo'
+ api = HfApi()
+ file_path = f"chat_files/private/{chat_key}/{filename}" # Store in chat_files
+ api.upload_file(
+ path_or_fileobj=temp_path,
+ path_in_repo=file_path,
+ repo_id=REPO_ID,
+ repo_type="dataset",
+ token=HF_TOKEN_WRITE,
+ commit_message=f"Private chat file uploaded by {username} to {recipient}"
+ )
+ message_data['file'] = file_path
+ message_data['file_type'] = file_type
+ if os.path.exists(temp_path):
+ os.remove(temp_path)
+ # Handle post sharing logic
+ if post_id:
+ post = next((p for p in data['posts'] if p['id'] == post_id and p['uploader'] == username), None)
+ if(post):
+ message_data['post_id'] = post_id
+
+ if 'text' in message_data or 'file' in message_data or 'post_id' in message_data:
+ data['private_chats'][chat_key].append(message_data)
+ save_data(data)
+
+ return redirect(url_for('private_chat', recipient=recipient)) #Redirect after send
+
+ recipient_avatar = data['users'][recipient].get('avatar') # Get recipient's avatar
+ recipient_online = is_user_online(data, recipient)
+ avatar = data['users'][username].get('avatar') if is_authenticated else None
+ html = f'''
+
+
+
+
+
+
+ Chat with {{{{ recipient }}}} - Content Hub
+
+
+
+
+
+ {NAV_HTML}
+
+
+
+
+
+
+ {{% if recipient_avatar %}}
+
+
+ {{% if recipient_avatar %}}
+ 
+ {{% else %}}
+
+ {{% endif %}}
+ Chat with {{{{ recipient }}}}
+
+
+ {{% for message in private_messages %}}
+
+
+
+ {{% if message['sender'] == username %}}
+ {{% if avatar %}}
+
+ {{% else %}}
+
+ {{% endif %}}
+ {{% else %}}
+ {{% if recipient_avatar %}}
+
+ {{% else %}}
+
+ {{% endif %}}
+ {{% endif %}}
+
+
+ {{% endfor %}}
+
+ {{{{ message['sender'] }}}}
+
+ {{% if 'text' in message %}}
+
+ {{% endif %}}
+ {{% endif %}}
+ {{% if 'post_id' in message %}}
+ {{% with post = posts|selectattr('id', 'equalto', message['post_id'])|first %}}
+ {{% if post %}}
+
+ {{{{ message['text'] }}}}
+ {{% endif %}} + {{% if 'file' in message %}} + {{% if message['file_type'] == 'video' %}} + + {{% else %}} +Shared: {{{{ post['title'] }}}}
+ {{% endif %}} + {{% endwith %}} + {{% endif %}} + {{{{ message['time'] }}}} +
+ ![]()
+
+
'''
- return render_template_string(html, username=username, user_files=user_files, repo_id=REPO_ID)
-
+ user_posts = [p for p in data['posts'] if p['uploader'] == username] #For the post sharing feature
+ return render_template_string(html,
+ private_messages=private_messages,
+ recipient=recipient,
+ username=username,
+ is_authenticated=is_authenticated,
+ repo_id=REPO_ID,
+ posts=data['posts'],
+ user_posts=user_posts,
+ unread_count=unread_count,
+ user_count=user_count,
+ private_unread_count=private_unread_count,
+ is_online=is_online,
+ is_user_online=lambda u: is_user_online(data, u),
+ recipient_avatar=recipient_avatar,
+ recipient_online=recipient_online,
+ avatar=avatar)
if __name__ == '__main__':
threading.Thread(target=periodic_backup, daemon=True).start()
- app.run(debug=True, host='0.0.0.0', port=7860)
\ No newline at end of file
+ app.run(debug=False, host='0.0.0.0', port=7860)
+
+