Videospace2

Sleeping

App Files Files Community

Aleksmorshen commited on 11 days ago

Commit

f79000e

verified ·

1 Parent(s): 7b1743c

Create app.py

Browse files

Files changed (1) hide show

app.py +236 -0

app.py ADDED Viewed

	@@ -0,0 +1,236 @@

+from flask import Flask, render_template, request, redirect, url_for, jsonify
+import random
+import string
+import json
+from flask_socketio import SocketIO, join_room, leave_room
+app = Flask(__name__)
+app.config['SECRET_KEY'] = 'your-secret-key-here'
+socketio = SocketIO(app)
+# Хранилище комнат и пользователей
+rooms = {}
+# Генерация 15-значного токена
+def generate_token():
+    return ''.join(random.choices(string.ascii_letters + string.digits, k=15))
+# Главная страница
+@app.route('/')
+def index():
+    return render_template('index.html')
+# Создание новой комнаты
+@app.route('/create', methods=['POST'])
+def create_room():
+    token = generate_token()
+    rooms[token] = {
+        'users': [],
+        'max_users': 5
+    }
+    return redirect(url_for('room', token=token))
+# Вход в существующую комнату
+@app.route('/join', methods=['POST'])
+def join():
+    token = request.form.get('token')
+    if token in rooms and len(rooms[token]['users']) < rooms[token]['max_users']:
+        return redirect(url_for('room', token=token))
+    return "Комната не найдена или переполнена", 404
+# Страница комнаты
+@app.route('/room/<token>')
+def room(token):
+    if token not in rooms:
+        return redirect(url_for('index'))
+    return render_template('room.html', token=token)
+# WebSocket события
+@socketio.on('join')
+def handle_join(data):
+    token = data['token']
+    username = data['username']
+    if token in rooms and len(rooms[token]['users']) < rooms[token]['max_users']:
+        join_room(token)
+        rooms[token]['users'].append(username)
+        socketio.emit('user_joined', {
+            'username': username,
+            'users': rooms[token]['users']
+        }, room=token)
+@socketio.on('leave')
+def handle_leave(data):
+    token = data['token']
+    username = data['username']
+    if token in rooms and username in rooms[token]['users']:
+        leave_room(token)
+        rooms[token]['users'].remove(username)
+        socketio.emit('user_left', {
+            'username': username,
+            'users': rooms[token]['users']
+        }, room=token)
+        if len(rooms[token]['users']) == 0:
+            del rooms[token]
+@socketio.on('signal')
+def handle_signal(data):
+    socketio.emit('signal', data, room=data['token'], skip_sid=request.sid)
+# Шаблоны HTML
+@app.route('/templates/index.html')
+def index_template():
+    return '''<!DOCTYPE html>
+<html>
+<head>
+    <title>Видеоконференция</title>
+    <style>
+        body { font-family: Arial, sans-serif; text-align: center; padding: 50px; }
+        button, input { padding: 10px; margin: 5px; }
+    </style>
+</head>
+<body>
+    <h1>Видеоконференция</h1>
+    <form action="/create" method="post">
+        <button type="submit">Создать комнату</button>
+    </form>
+    <form action="/join" method="post">
+        <input type="text" name="token" placeholder="Введите токен комнаты" required>
+        <button type="submit">Войти в комнату</button>
+    </form>
+</body>
+</html>'''
+@app.route('/templates/room.html')
+def room_template():
+    return '''<!DOCTYPE html>
+<html>
+<head>
+    <title>Комната {{ token }}</title>
+    <style>
+        .video-grid { display: grid; grid-template-columns: repeat(auto-fit, minmax(300px, 1fr)); gap: 10px; padding: 20px; }
+        video { width: 100%; background: black; }
+        #users { margin: 10px; }
+    </style>
+</head>
+<body>
+    <h1>Комната: {{ token }}</h1>
+    <div id="users"></div>
+    <div class="video-grid" id="video-grid"></div>
+    <button onclick="leaveRoom()">Покинуть комнату</button>
+    <script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/4.5.1/socket.io.js"></script>
+    <script>
+        const socket = io.connect('http://localhost:7860');
+        const token = '{{ token }}';
+        let localStream;
+        const peers = {};
+        const username = 'User_' + Math.random().toString(36).substr(2, 5);
+        // Получение видео/аудио потока
+        navigator.mediaDevices.getUserMedia({ video: true, audio: true })
+            .then(stream => {
+                localStream = stream;
+                addVideoStream(stream, username, true);
+                socket.emit('join', { token: token, username: username });
+            });
+        // Добавление видео в сетку
+        function addVideoStream(stream, user, muted = false) {
+            const video = document.createElement('video');
+            video.srcObject = stream;
+            video.addEventListener('loadedmetadata', () => {
+                video.play();
+            });
+            if (muted) video.muted = true;
+            video.dataset.user = user;
+            document.getElementById('video-grid').appendChild(video);
+        }
+        // Создание peer соединения
+        function connectToNewUser(user) {
+            const peer = new RTCPeerConnection();
+            peers[user] = peer;
+            localStream.getTracks().forEach(track => {
+                peer.addTrack(track, localStream);
+            });
+            peer.ontrack = event => {
+                addVideoStream(event.streams[0], user);
+            };
+            peer.onicecandidate = event => {
+                if (event.candidate) {
+                    socket.emit('signal', { token: token, to: user, signal: { type: 'candidate', candidate: event.candidate } });
+                }
+            };
+            peer.createOffer()
+                .then(offer => peer.setLocalDescription(offer))
+                .then(() => {
+                    socket.emit('signal', { token: token, to: user, signal: peer.localDescription });
+                });
+        }
+        // Обработка сигналов
+        socket.on('signal', data => {
+            const peer = peers[data.from] || new RTCPeerConnection();
+            peers[data.from] = peer;
+            if (data.signal.type === 'offer') {
+                peer.setRemoteDescription(new RTCSessionDescription(data.signal));
+                localStream.getTracks().forEach(track => peer.addTrack(track, localStream));
+                peer.ontrack = event => {
+                    addVideoStream(event.streams[0], data.from);
+                };
+                peer.onicecandidate = event => {
+                    if (event.candidate) {
+                        socket.emit('signal', { token: token, to: data.from, signal: { type: 'candidate', candidate: event.candidate } });
+                    }
+                };
+                peer.createAnswer()
+                    .then(answer => peer.setLocalDescription(answer))
+                    .then(() => {
+                        socket.emit('signal', { token: token, to: data.from, signal: peer.localDescription });
+                    });
+            } else if (data.signal.type === 'answer') {
+                peer.setRemoteDescription(new RTCSessionDescription(data.signal));
+            } else if (data.signal.type === 'candidate') {
+                peer.addIceCandidate(new RTCIceCandidate(data.signal.candidate));
+            }
+        });
+        // Обновление списка пользователей
+        socket.on('user_joined', data => {
+            document.getElementById('users').innerText = 'Пользователи: ' + data.users.join(', ');
+            if (data.username !== username) {
+                connectToNewUser(data.username);
+            }
+        });
+        socket.on('user_left', data => {
+            document.getElementById('users').innerText = 'Пользователи: ' + data.users.join(', ');
+            if (peers[data.username]) {
+                peers[data.username].close();
+                delete peers[data.username];
+                document.querySelector(`video[data-user="${data.username}"]`).remove();
+            }
+        });
+        function leaveRoom() {
+            socket.emit('leave', { token: token, username: username });
+            localStream.getTracks().forEach(track => track.stop());
+            window.location.href = '/';
+        }
+    </script>
+</body>
+</html>'''
+if __name__ == '__main__':
+    socketio.run(app, host='0.0.0.0', port=7860, debug=True)