Update main.py

main.py

@@ -1,147 +1,75 @@
-"""
-flask_messenger_single_file.py
-Advanced single-file Flask messenger optimized for mobile (PWA-ready).
+""" flask_messenger_single_file.py Advanced single-file Flask messenger optimized for mobile (PWA-ready).
 
 Features:
-- Single-file Flask + Flask-SocketIO app
-- SQLite message store
-- Real-time chat via WebSocket (Socket.IO)
-- File uploads with chunked upload support for large files
-- Direct blob upload endpoint for audio messages
-- Typing indicator, simple settings modal, avatars (DiceBear)
-- Mobile-first responsive UI embedded in the file
-
-Dependencies:
-    pip install flask flask-socketio
-Optional (better concurrency):
-    pip install eventlet
-Run:
-    python flask_messenger_single_file.py
-Notes for Android (Pydroid3):
-- If eventlet is unavailable, the app will use the 'threading' async mode.
-- Open in mobile browser: http://<device-ip>:5000
+
+Single-file Flask + Flask-SocketIO app
+
+SQLite message store
+
+Real-time chat via WebSocket (Socket.IO)
+
+File uploads with chunked upload support for large files
+
+Direct blob upload endpoint for audio messages
+
+Typing indicator, simple settings modal, avatars (DiceBear)
+
+Presence tracking (online users per room)
+
+Peer-to-peer audio calls via WebRTC (signaling over Socket.IO)
+
+Mobile-first responsive UI embedded in the file
+
+
+Dependencies: pip install flask flask-socketio eventlet
+
+Run: python flask_messenger_single_file.py
+
+Notes for deployment (Hugging Face Spaces with Gunicorn):
+
+Use eventlet worker in Gunicorn: gunicorn -k eventlet -w 1 -b 0.0.0.0:7860 main:app
+
+Ensure eventlet is in requirements.txt and eventlet.monkey_patch() is called before SocketIO creation.
+
+
 """
 
-import os
-import uuid
-import sqlite3
-import pathlib
-from datetime import datetime
-from flask import (
-    Flask,
-    request,
-    url_for,
-    send_from_directory,
-    jsonify,
-    render_template_string,
-)
-from flask_socketio import SocketIO, emit, join_room
-
-# Try to import eventlet for better Socket.IO behavior; fallback allowed
-try:
-    import eventlet  # optional
-    _HAS_EVENTLET = True
-except Exception:
-    _HAS_EVENTLET = False
-
-# Configuration
-BASE_DIR = pathlib.Path(__file__).parent.resolve()
-UPLOAD_DIR = BASE_DIR / "uploads"
-DB_PATH = BASE_DIR / "chat.db"
-STATIC_DIR = BASE_DIR / "static"
-CHUNK_TEMP = BASE_DIR / "chunk_temp"
-
-os.makedirs(UPLOAD_DIR, exist_ok=True)
-os.makedirs(STATIC_DIR, exist_ok=True)
-CHUNK_TEMP.mkdir(exist_ok=True)
-
-app = Flask(__name__)
-app.config["SECRET_KEY"] = os.environ.get("FLASK_SECRET", "dev_secret_change_me")
-app.config["UPLOAD_FOLDER"] = str(UPLOAD_DIR)
-
-# Choose async mode
-_async_mode = "eventlet" if _HAS_EVENTLET else "threading"
-socketio = SocketIO(app, cors_allowed_origins="*", async_mode=_async_mode)
-
-# --- Database helpers ---
-def init_db():
-    conn = sqlite3.connect(DB_PATH)
-    cur = conn.cursor()
-    cur.execute(
-        """
-        CREATE TABLE IF NOT EXISTS messages (
-            id TEXT PRIMARY KEY,
-            username TEXT,
-            avatar TEXT,
-            room TEXT,
-            text TEXT,
-            file_path TEXT,
-            file_name TEXT,
-            mime TEXT,
-            timestamp TEXT,
-            status TEXT
-        )
-        """
-    )
-    conn.commit()
-    conn.close()
-
-
-def save_message(msg: dict):
-    conn = sqlite3.connect(DB_PATH)
-    cur = conn.cursor()
-    cur.execute(
-        """INSERT INTO messages (id, username, avatar, room, text, file_path, file_name, mime, timestamp, status)
-                   VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)""",
-        (
-            msg["id"],
-            msg.get("username"),
-            msg.get("avatar"),
-            msg.get("room"),
-            msg.get("text"),
-            msg.get("file_path"),
-            msg.get("file_name"),
-            msg.get("mime"),
-            msg.get("timestamp"),
-            msg.get("status", "sent"),
-        ),
-    )
-    conn.commit()
-    conn.close()
-
-
-def get_recent_messages(room: str, limit: int = 200):
-    conn = sqlite3.connect(DB_PATH)
-    cur = conn.cursor()
-    cur.execute(
-        "SELECT id, username, avatar, text, file_path, file_name, mime, timestamp, status FROM messages WHERE room=? ORDER BY timestamp ASC LIMIT ?",
-        (room, limit),
-    )
-    rows = cur.fetchall()
-    conn.close()
-    out = []
-    for r in rows:
-        out.append(
-            {
-                "id": r[0],
-                "username": r[1],
-                "avatar": r[2],
-                "text": r[3],
-                "file_path": r[4],
-                "file_name": r[5],
-                "mime": r[6],
-                "timestamp": r[7],
-                "status": r[8],
-            }
-        )
-    return out
+import os import uuid import sqlite3 import pathlib from datetime import datetime from flask import ( Flask, request, url_for, send_from_directory, jsonify, render_template_string, ) from flask_socketio import SocketIO, emit, join_room, leave_room
+
+Try to import eventlet for better Socket.IO behavior; fallback allowed
+
+try: import eventlet  # optional eventlet.monkey_patch() _HAS_EVENTLET = True except Exception: _HAS_EVENTLET = False
+
+Configuration
+
+BASE_DIR = pathlib.Path(file).parent.resolve() UPLOAD_DIR = BASE_DIR / "uploads" DB_PATH = BASE_DIR / "chat.db" STATIC_DIR = BASE_DIR / "static" CHUNK_TEMP = BASE_DIR / "chunk_temp"
+
+os.makedirs(UPLOAD_DIR, exist_ok=True) os.makedirs(STATIC_DIR, exist_ok=True) CHUNK_TEMP.mkdir(exist_ok=True)
+
+app = Flask(name) app.config["SECRET_KEY"] = os.environ.get("FLASK_SECRET", "dev_secret_change_me") app.config["UPLOAD_FOLDER"] = str(UPLOAD_DIR)
+
+Choose async mode
+
+_async_mode = "eventlet" if _HAS_EVENTLET else "threading" socketio = SocketIO(app, cors_allowed_origins="*", async_mode=_async_mode)
 
+In-memory presence: {room: {username: sid}}
+
+PRESENCE = {}
+
+--- Database helpers ---
+
+def init_db(): conn = sqlite3.connect(DB_PATH) cur = conn.cursor() cur.execute( """ CREATE TABLE IF NOT EXISTS messages ( id TEXT PRIMARY KEY, username TEXT, avatar TEXT, room TEXT, text TEXT, file_path TEXT, file_name TEXT, mime TEXT, timestamp TEXT, status TEXT ) """ ) conn.commit() conn.close()
+
+def save_message(msg: dict): conn = sqlite3.connect(DB_PATH) cur = conn.cursor() cur.execute( """INSERT INTO messages (id, username, avatar, room, text, file_path, file_name, mime, timestamp, status) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)""", ( msg["id"], msg.get("username"), msg.get("avatar"), msg.get("room"), msg.get("text"), msg.get("file_path"), msg.get("file_name"), msg.get("mime"), msg.get("timestamp"), msg.get("status", "sent"), ), ) conn.commit() conn.close()
+
+def get_recent_messages(room: str, limit: int = 200): conn = sqlite3.connect(DB_PATH) cur = conn.cursor() cur.execute( "SELECT id, username, avatar, text, file_path, file_name, mime, timestamp, status FROM messages WHERE room=? ORDER BY timestamp ASC LIMIT ?", (room, limit), ) rows = cur.fetchall() conn.close() out = [] for r in rows: out.append( { "id": r[0], "username": r[1], "avatar": r[2], "text": r[3], "file_path": r[4], "file_name": r[5], "mime": r[6], "timestamp": r[7], "status": r[8], } ) return out
 
 init_db()
 
-# --- UI Template (embedded) ---
-TEMPLATE = r"""
-<!doctype html>
+--- UI Template (embedded) ---
+
+TEMPLATE = r""" <!doctype html>
+
 <html lang="ru">
 <head>
   <meta charset="utf-8" />
@@ -164,10 +92,11 @@ TEMPLATE = r"""
     .attachments{display:flex;gap:.5rem;align-items:center}
     .file-preview{max-width:160px;border-radius:8px;overflow:hidden}
     .typing{font-style:italic;color:#666;font-size:.85rem}
-    .avatar{width:36px;height:36px;border-radius:50%;object-fit:cover}
+    .avatar{width:36px;height:36px;border-radius:50%;object-fit:cover;cursor:pointer}
     .modal{display:none;position:fixed;top:0;left:0;right:0;bottom:0;align-items:center;justify-content:center;background:rgba(0,0,0,0.4)}
     .modal.show{display:flex}
     .modal-dialog{max-width:420px;width:100%}
+    .call-bar{position:fixed;left:12px;right:12px;bottom:12px;background:#fff;border-radius:10px;padding:.6rem;box-shadow:0 6px 18px rgba(0,0,0,.12);display:flex;align-items:center;gap:.6rem}
     @media (max-width:480px){ .msg{max-width:92%} header{padding:.7rem} }
   </style>
 </head>
@@ -184,27 +113,23 @@ TEMPLATE = r"""
       <div>
         <button id="btnSettings" class="btn btn-sm btn-light">Настройки</button>
       </div>
-    </header>
-
-    <div id="chat" class="chat-window" role="log" aria-live="polite"></div>
-
-    <div class="input-area">
-      <div id="typing" class="typing"></div>
-      <form id="composer" class="d-flex gap-2 align-items-center">
-        <div class="attachments d-flex align-items-center">
-          <label class="btn btn-outline-secondary btn-sm mb-0" title="Прикрепить файл">
-            📎<input id="fileInput" type="file" hidden>
-          </label>
-          <button id="recordBtn" class="btn btn-outline-danger btn-sm mb-0" type="button" title="Записать голос">🔴</button>
-        </div>
-        <input id="message" autocomplete="off" placeholder="Напишите сообщение..." class="form-control form-control-sm" />
-        <button class="btn btn-primary btn-sm" type="submit">Отправить</button>
-      </form>
+    </header><div id="chat" class="chat-window" role="log" aria-live="polite"></div>
+
+<div class="input-area">
+  <div id="typing" class="typing"></div>
+  <form id="composer" class="d-flex gap-2 align-items-center">
+    <div class="attachments d-flex align-items-center">
+      <label class="btn btn-outline-secondary btn-sm mb-0" title="Прикрепить файл">
+        📎<input id="fileInput" type="file" hidden>
+      </label>
+      <button id="recordBtn" class="btn btn-outline-danger btn-sm mb-0" type="button" title="Записать голос">🔴</button>
     </div>
-  </div>
+    <input id="message" autocomplete="off" placeholder="Напишите сообщение..." class="form-control form-control-sm" />
+    <button class="btn btn-primary btn-sm" type="submit">Отправить</button>
+  </form>
+</div>
 
-  <!-- Settings Modal -->
-  <div class="modal" id="settingsModal" aria-hidden="true">
+  </div>  <!-- Settings Modal -->  <div class="modal" id="settingsModal" aria-hidden="true">
     <div class="modal-dialog">
       <div class="modal-content bg-white rounded p-3">
         <div class="d-flex justify-content-between align-items-center mb-2">
@@ -224,17 +149,34 @@ TEMPLATE = r"""
         </div>
       </div>
     </div>
-  </div>
+  </div>  <!-- Call bar (shows during active call) -->  <div id="callBar" class="call-bar" style="display:none">
+    <div id="callParticipants">Вызов: <span id="callNames"></span></div>
+    <div style="margin-left:auto">
+      <button id="endCallBtn" class="btn btn-sm btn-danger">Завершить</button>
+    </div>
+  </div><script src="https://cdn.jsdelivr.net/npm/axios/dist/axios.min.js"></script><script src="https://cdn.socket.io/4.7.2/socket.io.min.js"></script><script>
+// Polyfill for getUserMedia in case browser exposes legacy prefixes or lacks navigator.mediaDevices
+if (!navigator.mediaDevices) {
+  navigator.mediaDevices = {};
+}
+if (!navigator.mediaDevices.getUserMedia) {
+  navigator.mediaDevices.getUserMedia = function(constraints) {
+    var getUserMedia = navigator.getUserMedia || navigator.webkitGetUserMedia || navigator.mozGetUserMedia;
+    if (!getUserMedia) {
+      return Promise.reject(new Error('getUserMedia is not implemented in this browser'));
+    }
+    return new Promise(function(resolve, reject) {
+      getUserMedia.call(navigator, constraints, resolve, reject);
+    });
+  }
+}
 
-<script src="https://cdn.jsdelivr.net/npm/axios/dist/axios.min.js"></script>
-<script src="https://cdn.socket.io/4.7.2/socket.io.min.js"></script>
-<script>
 const socket = io();
 let username = localStorage.getItem('mm_username') || '';
 let avatar = localStorage.getItem('mm_avatar') || '';
 const room = 'global';
 
-function nano(){return Math.random().toString(36).slice(2,10);}
+function nano(){return Math.random().toString(36).slice(2,10);} 
 if(!username){ username = 'User-'+ nano(); }
 if(!avatar){ avatar = 'https://api.dicebear.com/6.x/thumbs/svg?seed='+encodeURIComponent(username); }
 localStorage.setItem('mm_username', username);
@@ -243,13 +185,24 @@ localStorage.setItem('mm_avatar', avatar);
 document.getElementById('roomAvatar').src = avatar;
 document.getElementById('roomName').innerText = room;
 
-// Settings modal handlers
+// Presence & user list
+let onlineUsers = {}; // {username: true}
+
+// WebRTC state
+const RTC_CONFIG = { iceServers: [{urls: 'stun:stun.l.google.com:19302'}] };
+const peers = {}; // username -> RTCPeerConnection
+let localStream = null;
+
+// UI elements
 const btnSettings = document.getElementById('btnSettings');
 const settingsModal = document.getElementById('settingsModal');
 const closeSettings = document.getElementById('closeSettings');
 const saveSettings = document.getElementById('saveSettings');
 const setUsername = document.getElementById('setUsername');
 const setAvatar = document.getElementById('setAvatar');
+const callBar = document.getElementById('callBar');
+const callNames = document.getElementById('callNames');
+const endCallBtn = document.getElementById('endCallBtn');
 
 btnSettings.addEventListener('click', ()=>{
   setUsername.value = localStorage.getItem('mm_username') || '';
@@ -267,6 +220,7 @@ saveSettings.addEventListener('click', ()=>{
   document.getElementById('roomAvatar').src = avatar;
   settingsModal.classList.remove('show');
   settingsModal.setAttribute('aria-hidden','true');
+  socket.emit('presence_update', {room, username});
 });
 
 // load recent messages
@@ -292,7 +246,8 @@ function addMessageToDom(m){
   el.className = 'msg '+(fromMe? 'from-me':'from-other');
   const meta = document.createElement('div'); meta.className='meta';
   const avatarSrc = safeAvatarFor(m);
-  meta.innerHTML = `<img src="${avatarSrc}" class="avatar"> <strong>${m.username||'Anonymous'}</strong> · <span>${new Date(m.timestamp).toLocaleString()}</span>`;
+  // avatar img has data-username so clicking initiates a call to that user
+  meta.innerHTML = `<img src="${avatarSrc}" class="avatar" data-username="${m.username||''}" onclick="initiateCallPrompt('${m.username||''}')"> <strong>${m.username||'Anonymous'}</strong> · <span>${new Date(m.timestamp).toLocaleString()}</span>`;
   const body = document.createElement('div');
   if(m.text) {
     const p = document.createElement('div');
@@ -319,14 +274,123 @@ function addMessageToDom(m){
   chat.scrollTop = chat.scrollHeight;
 }
 
+// prompt user to call
+window.initiateCallPrompt = async function(target){
+  if(!target || target === username) return alert('Нельзя звонить себе');
+  if(!onlineUsers[target]) return alert('Пользователь офлайн');
+  const ok = confirm(target + ' — вызвать?');
+  if(!ok) return;
+  startCall(target);
+}
+
+// Socket handlers for presence & signaling
 socket.on('connect', ()=>{
   socket.emit('join', {room, username, avatar});
 });
 
-socket.on('message', (m)=>{ addMessageToDom(m); });
-socket.on('typing', (data)=>{ document.getElementById('typing').innerText = data.username ? data.username + ' печатает...' : ''; });
+socket.on('user_list', (data)=>{
+  onlineUsers = data || {};
+  // you could update UI for online users here
+});
+
+socket.on('webrtc-offer', async (data)=>{
+  // incoming offer: data={from, sdp}
+  const from = data.from;
+  const sdp = data.sdp;
+  const accept = confirm('Входящий вызов от '+from+' — принять?');
+  if(!accept){ socket.emit('webrtc-reject', {to: from, room}); return; }
+  await ensureLocalStream();
+  const pc = createPeerConnection(from);
+  await pc.setRemoteDescription(new RTCSessionDescription(sdp));
+  const answer = await pc.createAnswer();
+  await pc.setLocalDescription(answer);
+  socket.emit('webrtc-answer', {to: from, sdp: pc.localDescription, room});
+  showCallBar();
+});
+
+socket.on('webrtc-answer', async (data)=>{
+  const from = data.from; const sdp = data.sdp;
+  const pc = peers[from];
+  if(pc){ await pc.setRemoteDescription(new RTCSessionDescription(sdp)); }
+});
+
+socket.on('webrtc-ice', async (data)=>{
+  const from = data.from; const candidate = data.candidate;
+  const pc = peers[from];
+  if(pc && candidate){
+    try{ await pc.addIceCandidate(new RTCIceCandidate(candidate)); }catch(e){ console.warn('ICE add failed', e); }
+  }
+});
+
+socket.on('webrtc-reject', (data)=>{
+  alert('Вызов отклонён пользователем.');
+  stopCall();
+});
+
+// helper: ensure local audio stream
+async function ensureLocalStream(){
+  if(localStream) return localStream;
+  try{
+    localStream = await navigator.mediaDevices.getUserMedia({audio:true});
+    return localStream;
+  }catch(e){ alert('Невозможно получить доступ к микрофону: '+e.message); throw e; }
+}
+
+function createPeerConnection(peerName){
+  const pc = new RTCPeerConnection(RTC_CONFIG);
+  peers[peerName] = pc;
+  // add local tracks
+  if(localStream){ localStream.getTracks().forEach(t => pc.addTrack(t, localStream)); }
+  pc.onicecandidate = (e)=>{
+    if(e.candidate){ socket.emit('webrtc-ice', {to: peerName, candidate: e.candidate, room}); }
+  };
+  pc.ontrack = (e)=>{
+    // create or reuse audio element
+    let audio = document.getElementById('audio_'+peerName);
+    if(!audio){ audio = document.createElement('audio'); audio.id = 'audio_'+peerName; audio.autoplay = true; audio.controls = true; audio.style.display='block';
+      // append to call bar area
+      callBar.insertBefore(audio, callBar.firstChild);
+    }
+    audio.srcObject = e.streams[0];
+  };
+  pc.onconnectionstatechange = ()=>{
+    if(pc.connectionState === 'disconnected' || pc.connectionState === 'failed' || pc.connectionState === 'closed'){
+      removePeer(peerName);
+    }
+  };
+  return pc;
+}
+
+async function startCall(target){
+  await ensureLocalStream();
+  const pc = createPeerConnection(target);
+  // create offer
+  const offer = await pc.createOffer();
+  await pc.setLocalDescription(offer);
+  socket.emit('webrtc-offer', {to: target, sdp: pc.localDescription, room});
+  showCallBar(target);
+}
+
+function showCallBar(name){
+  callBar.style.display='flex';
+  if(name) callNames.innerText = name; else callNames.innerText = Object.keys(peers).join(', ');
+}
+
+function removePeer(name){
+  try{ const a = document.getElementById('audio_'+name); if(a) a.remove(); }catch(e){}
+  if(peers[name]){ try{ peers[name].close(); }catch(e){} delete peers[name]; }
+  if(Object.keys(peers).length===0){ callBar.style.display='none'; }
+}
+
+function stopCall(){
+  for(const p in peers){ try{ peers[p].close(); }catch(e){} removePeer(p); }
+  if(localStream){ localStream.getTracks().forEach(t=>t.stop()); localStream=null; }
+  callBar.style.display='none';
+  callNames.innerText='';
+}
+endCallBtn.addEventListener('click', ()=>{ stopCall(); });
 
-// composer
+// composer & uploads (unchanged behaviour)
 const composer = document.getElementById('composer');
 const messageInput = document.getElementById('message');
 const fileInput = document.getElementById('fileInput');
@@ -342,7 +406,6 @@ composer.addEventListener('submit', async (e)=>{
   const text = messageInput.value.trim();
   if(fileInput.files.length){
     const file = fileInput.files[0];
-    // Use chunked upload for large files
     const fileUrl = await uploadFileChunked(file);
     socket.emit('post_file_message', {username, avatar, room, text:'', file_path: fileUrl, file_name: file.name, mime: file.type});
     fileInput.value='';
@@ -380,7 +443,7 @@ async function uploadBlob(file){
   return r.data.url;
 }
 
-// Audio recording
+// Audio recording (voice messages)
 let mediaRecorder = null; let recordedChunks = [];
 const recordBtn = document.getElementById('recordBtn');
 recordBtn.addEventListener('click', async ()=>{
@@ -407,216 +470,67 @@ recordBtn.addEventListener('click', async ()=>{
 
 // initial load
 loadRecent();
-</script>
-</body>
+
+</script></body>
 </html>
-"""
+"""--- Server routes ---
 
-# --- Server routes ---
-
-@app.route("/")
-def index():
-    return render_template_string(TEMPLATE)
-
-
-@app.route("/manifest.json")
-def manifest():
-    data = {
-        "name": "Mobile Messenger",
-        "short_name": "Messenger",
-        "start_url": "/",
-        "display": "standalone",
-        "background_color": "#ffffff",
-        "theme_color": "#0d6efd",
-        "icons": [
-            {"src": "/static/icon-192.png", "sizes": "192x192", "type": "image/png"},
-            {"src": "/static/icon-512.png", "sizes": "512x512", "type": "image/png"},
-        ],
-    }
-    return jsonify(data)
-
-
-# --- File upload with chunking ---
-@app.route("/upload_chunk", methods=["POST"])
-def upload_chunk():
-    chunk = request.files.get("chunk")
-    file_id = request.form.get("file_id")
-    try:
-        index = int(request.form.get("index", "0"))
-    except Exception:
-        index = 0
-    total = int(request.form.get("total", "1"))
-    file_name = request.form.get("file_name") or "upload"
-    if not chunk or not file_id:
-        return ("Missing chunk or file_id", 400)
-    temp_dir = CHUNK_TEMP / file_id
-    temp_dir.mkdir(parents=True, exist_ok=True)
-    chunk_path = temp_dir / f"{index:06d}.part"
-    chunk.save(str(chunk_path))
-    return ("OK", 200)
-
-
-@app.route("/upload_complete", methods=["POST"])
-def upload_complete():
-    data = request.get_json(force=True) if request.is_json else request.form
-    file_id = data.get("file_id")
-    file_name = data.get("file_name") or f"file_{uuid.uuid4().hex}"
-    if not file_id:
-        return ("Missing file_id", 400)
-    temp_dir = CHUNK_TEMP / file_id
-    if not temp_dir.exists():
-        return ("No chunks found", 404)
-    parts = sorted(temp_dir.iterdir())
-    final_name = f"{datetime.utcnow().strftime('%Y%m%d%H%M%S')}_{uuid.uuid4().hex}_{file_name}"
-    final_path = UPLOAD_DIR / final_name
-    with open(final_path, "wb") as wf:
-        for p in parts:
-            with open(p, "rb") as rf:
-                wf.write(rf.read())
-    # cleanup
-    for p in parts:
-        try:
-            p.unlink()
-        except Exception:
-            pass
-    try:
-        temp_dir.rmdir()
-    except Exception:
-        pass
-    url = url_for("uploaded_file", filename=final_name, _external=True)
-    return jsonify({"url": url, "filename": final_name})
-
-
-# Direct blob upload (for audio messages and small files)
-@app.route("/upload_blob", methods=["POST"])
-def upload_blob():
-    f = request.files.get("file")
-    if not f:
-        return ("No file", 400)
-    safe_name = f"{datetime.utcnow().strftime('%Y%m%d%H%M%S')}_{uuid.uuid4().hex}_{secure_filename(f.filename)}"
-    path = UPLOAD_DIR / safe_name
-    f.save(str(path))
-    url = url_for("uploaded_file", filename=safe_name, _external=True)
-    return jsonify({"url": url, "filename": safe_name})
-
-
-# Serve uploaded files
-@app.route("/uploads/<path:filename>")
-def uploaded_file(filename):
-    return send_from_directory(app.config["UPLOAD_FOLDER"], filename)
-
-
-# SocketIO events
-@socketio.on("join")
-def on_join(data):
-    room = data.get("room", "global")
-    join_room(room)
-    system_avatar = "https://api.dicebear.com/6.x/thumbs/svg?seed=System"
-    emit(
-        "message",
-        {
-            "id": str(uuid.uuid4()),
-            "username": "System",
-            "avatar": system_avatar,
-            "text": f"{data.get('username')} присоединился к чату",
-            "timestamp": datetime.utcnow().isoformat(),
-            "room": room,
-        },
-        room=room,
-    )
-
-
-@socketio.on("post_message")
-def on_post_message(data):
-    msg = {
-        "id": str(uuid.uuid4()),
-        "username": data.get("username"),
-        "avatar": data.get("avatar"),
-        "room": data.get("room", "global"),
-        "text": data.get("text"),
-        "file_path": None,
-        "file_name": None,
-        "mime": None,
-        "timestamp": datetime.utcnow().isoformat(),
-        "status": "sent",
-    }
-    save_message(msg)
-    emit("message", msg, room=msg["room"])
-
-
-@socketio.on("post_file_message")
-def on_post_file_message(data):
-    # Prefer explicit file_path from client
-    file_path = data.get("file_path")
-    file_name = data.get("file_name")
-    mime = data.get("mime")
-    if not file_path and file_name:
-        # try to find file by file_name
-        found = None
-        for f in UPLOAD_DIR.iterdir():
-            if file_name and file_name in f.name:
-                found = f
-                break
-        if found:
-            file_path = url_for("uploaded_file", filename=found.name, _external=True)
-    msg = {
-        "id": str(uuid.uuid4()),
-        "username": data.get("username"),
-        "avatar": data.get("avatar"),
-        "room": data.get("room", "global"),
-        "text": data.get("text", ""),
-        "file_path": file_path,
-        "file_name": file_name,
-        "mime": mime,
-        "timestamp": datetime.utcnow().isoformat(),
-        "status": "sent",
-    }
-    save_message(msg)
-    emit("message", msg, room=msg["room"])
-
-
-@socketio.on("typing")
-def on_typing(data):
-    room = data.get("room", "global")
-    emit("typing", {"username": data.get("username")}, room=room, include_self=False)
-
-
-# history endpoint
-@app.route("/history")
-def history():
-    room = request.args.get("room", "global")
-    return jsonify(get_recent_messages(room))
-
-
-# simple static serve
-@app.route("/static/<path:p>")
-def static_files(p):
-    pth = STATIC_DIR / p
-    if pth.exists():
-        return send_from_directory(str(STATIC_DIR), p)
-    return ("", 404)
-
-
-# small helper for safe filenames (to avoid importing heavy libs)
-def secure_filename(name: str) -> str:
-    # very small sanitizer: keep alnum, dot, dash, underscore
-    keep = []
-    for ch in name:
-        if ch.isalnum() or ch in "._-":
-            keep.append(ch)
-    out = "".join(keep)
-    if not out:
-        out = f"file_{uuid.uuid4().hex}"
-    return out
-
-
-if __name__ == "__main__":
-    print("Starting Mobile Messenger on http://0.0.0.0:5000")
-    if _HAS_EVENTLET:
-        # monkey patch for eventlet (recommended if installed)
-        try:
-            eventlet.monkey_patch()
-        except Exception:
-            pass
-    # Run SocketIO server (eventlet or threading)
-    socketio.run(app, host="0.0.0.0", port=5000)
+@app.route("/") def index(): return render_template_string(TEMPLATE)
+
+@app.route("/manifest.json") def manifest(): data = { "name": "Mobile Messenger", "short_name": "Messenger", "start_url": "/", "display": "standalone", "background_color": "#ffffff", "theme_color": "#0d6efd", "icons": [ {"src": "/static/icon-192.png", "sizes": "192x192", "type": "image/png"}, {"src": "/static/icon-512.png", "sizes": "512x512", "type": "image/png"}, ], } return jsonify(data)
+
+--- File upload with chunking ---
+
+@app.route("/upload_chunk", methods=["POST"]) def upload_chunk(): chunk = request.files.get("chunk") file_id = request.form.get("file_id") try: index = int(request.form.get("index", "0")) except Exception: index = 0 total = int(request.form.get("total", "1")) file_name = request.form.get("file_name") or "upload" if not chunk or not file_id: return ("Missing chunk or file_id", 400) temp_dir = CHUNK_TEMP / file_id temp_dir.mkdir(parents=True, exist_ok=True) chunk_path = temp_dir / f"{index:06d}.part" chunk.save(str(chunk_path)) return ("OK", 200)
+
+@app.route("/upload_complete", methods=["POST"]) def upload_complete(): data = request.get_json(force=True) if request.is_json else request.form file_id = data.get("file_id") file_name = data.get("file_name") or f"file_{uuid.uuid4().hex}" if not file_id: return ("Missing file_id", 400) temp_dir = CHUNK_TEMP / file_id if not temp_dir.exists(): return ("No chunks found", 404) parts = sorted(temp_dir.iterdir()) final_name = f"{datetime.utcnow().strftime('%Y%m%d%H%M%S')}{uuid.uuid4().hex}{file_name}" final_path = UPLOAD_DIR / final_name with open(final_path, "wb") as wf: for p in parts: with open(p, "rb") as rf: wf.write(rf.read()) # cleanup for p in parts: try: p.unlink() except Exception: pass try: temp_dir.rmdir() except Exception: pass url = url_for("uploaded_file", filename=final_name, _external=True) return jsonify({"url": url, "filename": final_name})
+
+Direct blob upload (for audio messages and small files)
+
+@app.route("/upload_blob", methods=["POST"]) def upload_blob(): f = request.files.get("file") if not f: return ("No file", 400) safe_name = f"{datetime.utcnow().strftime('%Y%m%d%H%M%S')}{uuid.uuid4().hex}{secure_filename(f.filename)}" path = UPLOAD_DIR / safe_name f.save(str(path)) url = url_for("uploaded_file", filename=safe_name, _external=True) return jsonify({"url": url, "filename": safe_name})
+
+Serve uploaded files
+
+@app.route("/uploads/path:filename") def uploaded_file(filename): return send_from_directory(app.config["UPLOAD_FOLDER"], filename)
+
+SocketIO events (presence and signaling)
+
+@socketio.on("join") def on_join(data): room = data.get("room", "global") user = data.get("username") sid = request.sid if room not in PRESENCE: PRESENCE[room] = {} PRESENCE[room][user] = sid join_room(room) system_avatar = "https://api.dicebear.com/6.x/thumbs/svg?seed=System" emit( "message", { "id": str(uuid.uuid4()), "username": "System", "avatar": system_avatar, "text": f"{user} присоединился к чату", "timestamp": datetime.utcnow().isoformat(), "room": room, }, room=room, ) # broadcast updated user list emit('user_list', list(PRESENCE[room].keys()), room=room)
+
+@socketio.on('presence_update') def on_presence_update(data): room = data.get('room','global') user = data.get('username') if room not in PRESENCE: PRESENCE[room] = {} PRESENCE[room][user] = request.sid emit('user_list', list(PRESENCE[room].keys()), room=room)
+
+@socketio.on('disconnect') def on_disconnect(): sid = request.sid # find and remove user from PRESENCE for room, d in list(PRESENCE.items()): to_remove = [u for u,s in d.items() if s==sid] for u in to_remove: d.pop(u, None) emit('user_list', list(d.keys()), room=room)
+
+Signaling: offer, answer, ice, reject
+
+@socketio.on('webrtc-offer') def on_webrtc_offer(data): to = data.get('to') room = data.get('room','global') sender = data.get('from') or None sdp = data.get('sdp') target_sid = PRESENCE.get(room, {}).get(to) if target_sid: emit('webrtc-offer', {'from': sender, 'sdp': sdp}, to=target_sid)
+
+@socketio.on('webrtc-answer') def on_webrtc_answer(data): to = data.get('to') room = data.get('room','global') sender = data.get('from') or None sdp = data.get('sdp') target_sid = PRESENCE.get(room, {}).get(to) if target_sid: emit('webrtc-answer', {'from': sender, 'sdp': sdp}, to=target_sid)
+
+@socketio.on('webrtc-ice') def on_webrtc_ice(data): to = data.get('to') room = data.get('room','global') sender = data.get('from') or None candidate = data.get('candidate') target_sid = PRESENCE.get(room, {}).get(to) if target_sid: emit('webrtc-ice', {'from': sender, 'candidate': candidate}, to=target_sid)
+
+@socketio.on('webrtc-reject') def on_webrtc_reject(data): to = data.get('to') room = data.get('room','global') target_sid = PRESENCE.get(room, {}).get(to) if target_sid: emit('webrtc-reject', {}, to=target_sid)
+
+@socketio.on('post_message') def on_post_message(data): msg = { "id": str(uuid.uuid4()), "username": data.get("username"), "avatar": data.get("avatar"), "room": data.get("room", "global"), "text": data.get("text"), "file_path": None, "file_name": None, "mime": None, "timestamp": datetime.utcnow().isoformat(), "status": "sent", } save_message(msg) emit("message", msg, room=msg["room"])
+
+@socketio.on('post_file_message') def on_post_file_message(data): file_path = data.get('file_path') file_name = data.get('file_name') mime = data.get('mime') if not file_path and file_name: found = None for f in UPLOAD_DIR.iterdir(): if file_name and file_name in f.name: found = f break if found: file_path = url_for('uploaded_file', filename=found.name, _external=True) msg = { "id": str(uuid.uuid4()), "username": data.get("username"), "avatar": data.get("avatar"), "room": data.get("room", "global"), "text": data.get("text", ""), "file_path": file_path, "file_name": file_name, "mime": mime, "timestamp": datetime.utcnow().isoformat(), "status": "sent", } save_message(msg) emit("message", msg, room=msg["room"])
+
+@socketio.on('typing') def on_typing(data): room = data.get('room', 'global') emit('typing', {'username': data.get('username')}, room=room, include_self=False)
+
+history endpoint
+
+@app.route("/history") def history(): room = request.args.get("room", "global") return jsonify(get_recent_messages(room))
+
+online list endpoint
+
+@app.route('/online') def online_list(): room = request.args.get('room','global') return jsonify(list(PRESENCE.get(room, {}).keys()))
+
+simple static serve
+
+@app.route("/static/path:p") def static_files(p): pth = STATIC_DIR / p if pth.exists(): return send_from_directory(str(STATIC_DIR), p) return ("", 404)
+
+small helper for safe filenames (to avoid importing heavy libs)
+
+def secure_filename(name: str) -> str: keep = [] for ch in (name or ''): if ch.isalnum() or ch in ".-": keep.append(ch) out = "".join(keep) if not out: out = f"file{uuid.uuid4().hex}" return out
+
+if name == "main": print("Starting Mobile Messenger on http://0.0.0.0:5000") # Run SocketIO server (eventlet or threading) socketio.run(app, host="0.0.0.0", port=5000)