X commited on
Update app.py
Browse files
app.py
CHANGED
|
@@ -1,666 +1,485 @@
|
|
| 1 |
-
import
|
| 2 |
-
import
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 3 |
import os
|
| 4 |
-
import
|
| 5 |
-
import
|
| 6 |
-
import time
|
| 7 |
-
import socket
|
| 8 |
-
import hashlib
|
| 9 |
-
from pathlib import Path
|
| 10 |
-
from fastapi import FastAPI, Request
|
| 11 |
-
from fastapi.responses import HTMLResponse, JSONResponse
|
| 12 |
-
import uvicorn
|
| 13 |
|
| 14 |
-
# ==========
|
| 15 |
-
|
| 16 |
-
|
| 17 |
-
|
| 18 |
-
|
| 19 |
-
|
| 20 |
-
|
| 21 |
-
|
| 22 |
-
|
| 23 |
-
|
| 24 |
-
|
| 25 |
-
|
| 26 |
-
|
| 27 |
-
|
| 28 |
-
|
| 29 |
-
|
| 30 |
-
|
| 31 |
-
|
| 32 |
-
|
| 33 |
-
|
| 34 |
-
|
| 35 |
-
|
| 36 |
-
|
| 37 |
-
|
| 38 |
-
|
| 39 |
-
|
| 40 |
-
|
| 41 |
-
|
| 42 |
-
|
| 43 |
-
|
| 44 |
-
|
| 45 |
-
|
| 46 |
-
|
| 47 |
-
|
| 48 |
-
|
| 49 |
-
|
| 50 |
-
|
| 51 |
-
|
| 52 |
-
|
| 53 |
-
# ===
|
| 54 |
-
|
| 55 |
-
|
| 56 |
-
|
| 57 |
-
|
| 58 |
-
|
| 59 |
-
|
| 60 |
-
|
| 61 |
-
|
| 62 |
-
|
| 63 |
-
|
| 64 |
-
|
| 65 |
-
|
| 66 |
-
|
| 67 |
-
|
| 68 |
-
|
| 69 |
-
|
| 70 |
-
|
| 71 |
-
|
| 72 |
-
|
| 73 |
-
|
| 74 |
-
|
| 75 |
-
|
| 76 |
-
|
| 77 |
-
|
| 78 |
-
|
| 79 |
-
|
| 80 |
-
|
| 81 |
-
|
| 82 |
-
|
| 83 |
-
|
| 84 |
-
|
| 85 |
-
|
| 86 |
-
|
| 87 |
-
|
| 88 |
-
|
| 89 |
-
|
| 90 |
-
|
| 91 |
-
|
| 92 |
-
|
| 93 |
-
|
| 94 |
-
|
| 95 |
-
|
| 96 |
-
|
| 97 |
-
|
| 98 |
-
|
| 99 |
-
|
| 100 |
-
|
| 101 |
-
|
| 102 |
-
|
| 103 |
-
.
|
| 104 |
-
|
| 105 |
-
|
| 106 |
-
|
| 107 |
-
|
| 108 |
-
|
| 109 |
-
|
| 110 |
-
|
| 111 |
-
|
| 112 |
-
|
| 113 |
-
|
| 114 |
-
|
| 115 |
-
|
| 116 |
-
|
| 117 |
-
|
| 118 |
-
|
| 119 |
-
|
| 120 |
-
|
| 121 |
-
|
| 122 |
-
|
| 123 |
-
|
| 124 |
-
|
| 125 |
-
|
| 126 |
-
|
| 127 |
-
|
| 128 |
-
|
| 129 |
-
|
| 130 |
-
|
| 131 |
-
|
| 132 |
-
|
| 133 |
-
|
| 134 |
-
|
| 135 |
-
.
|
| 136 |
-
|
| 137 |
-
|
| 138 |
-
|
| 139 |
-
|
| 140 |
-
|
| 141 |
-
|
| 142 |
-
|
| 143 |
-
|
| 144 |
-
|
| 145 |
-
margin: 10px 0;
|
| 146 |
-
word-break: break-all;
|
| 147 |
-
}
|
| 148 |
-
.status {
|
| 149 |
-
padding: 10px;
|
| 150 |
-
border-radius: 8px;
|
| 151 |
-
margin-top: 8px;
|
| 152 |
-
font-size: 13px;
|
| 153 |
-
}
|
| 154 |
-
.status.success { background: #c6f6d5; color: #22543d; }
|
| 155 |
-
.status.error { background: #fed7d7; color: #9b2c2c; }
|
| 156 |
-
.status.info { background: #bee3f8; color: #2a69ac; }
|
| 157 |
-
.chat-box {
|
| 158 |
-
border: 2px solid #e2e8f0;
|
| 159 |
-
border-radius: 8px;
|
| 160 |
-
height: 300px;
|
| 161 |
-
overflow-y: auto;
|
| 162 |
-
padding: 15px;
|
| 163 |
-
background: white;
|
| 164 |
-
margin-bottom: 10px;
|
| 165 |
-
display: none;
|
| 166 |
-
}
|
| 167 |
-
.chat-box.active { display: block; }
|
| 168 |
-
.message {
|
| 169 |
-
margin-bottom: 8px;
|
| 170 |
-
padding: 8px 12px;
|
| 171 |
-
border-radius: 8px;
|
| 172 |
-
max-width: 80%;
|
| 173 |
-
word-wrap: break-word;
|
| 174 |
-
}
|
| 175 |
-
.message.sent { background: #6c63ff; color: white; margin-left: auto; }
|
| 176 |
-
.message.received { background: #e2e8f0; color: #2d3748; margin-right: auto; }
|
| 177 |
-
.message.system { background: #fefcbf; color: #744210; text-align: center; max-width: 100%; font-style: italic; }
|
| 178 |
-
.chat-input {
|
| 179 |
-
display: none;
|
| 180 |
-
gap: 10px;
|
| 181 |
-
}
|
| 182 |
-
.chat-input.active { display: flex; }
|
| 183 |
-
.chat-input input { flex: 1; margin-bottom: 0; }
|
| 184 |
-
.chat-input button { width: auto; padding: 12px 24px; }
|
| 185 |
-
.peer-id { font-size: 12px; color: #718096; text-align: center; margin-top: 10px; word-break: break-all; }
|
| 186 |
-
.hidden { display: none; }
|
| 187 |
-
.flex { display: flex; gap: 8px; }
|
| 188 |
-
.flex button { width: auto; flex: 1; }
|
| 189 |
-
.stats {
|
| 190 |
-
text-align: center;
|
| 191 |
-
font-size: 12px;
|
| 192 |
-
color: #718096;
|
| 193 |
-
margin-top: 15px;
|
| 194 |
-
padding-top: 15px;
|
| 195 |
-
border-top: 1px solid #e2e8f0;
|
| 196 |
-
}
|
| 197 |
-
.stats span { font-weight: 600; color: #2d3748; }
|
| 198 |
-
.badge {
|
| 199 |
-
display: inline-block;
|
| 200 |
-
background: #6c63ff;
|
| 201 |
-
color: white;
|
| 202 |
-
font-size: 11px;
|
| 203 |
-
padding: 2px 10px;
|
| 204 |
-
border-radius: 20px;
|
| 205 |
-
margin-left: 8px;
|
| 206 |
-
}
|
| 207 |
-
.friend-item {
|
| 208 |
-
background: white;
|
| 209 |
-
padding: 10px;
|
| 210 |
-
border-radius: 8px;
|
| 211 |
-
margin-bottom: 8px;
|
| 212 |
-
border: 1px solid #e2e8f0;
|
| 213 |
-
display: flex;
|
| 214 |
-
justify-content: space-between;
|
| 215 |
-
align-items: center;
|
| 216 |
-
}
|
| 217 |
-
.friend-item .name { font-weight: 600; color: #2d3748; }
|
| 218 |
-
.friend-item .id { font-size: 11px; color: #718096; }
|
| 219 |
-
.friend-item button { width: auto; padding: 6px 16px; font-size: 12px; }
|
| 220 |
-
</style>
|
| 221 |
-
</head>
|
| 222 |
-
<body>
|
| 223 |
-
<div class="container">
|
| 224 |
-
<h1>🔐 HF Message</h1>
|
| 225 |
-
<div class="subtitle">Код-слово = вход в аккаунт · ID = добавление в друзья</div>
|
| 226 |
-
|
| 227 |
-
<!-- Секция: Вход по коду-слову -->
|
| 228 |
-
<div class="section" id="login-section">
|
| 229 |
-
<h3>🔑 Войти в аккаунт по коду-слову</h3>
|
| 230 |
-
<input type="text" id="login-code" placeholder="СОЛНЦЕ-ЛУНА-42" style="text-transform:uppercase;">
|
| 231 |
-
<button onclick="loginWithCode()">Войти / Создать аккаунт</button>
|
| 232 |
-
<div id="login-status"></div>
|
| 233 |
-
</div>
|
| 234 |
-
|
| 235 |
-
<!-- Секция: Мой профиль (появляется после входа) -->
|
| 236 |
-
<div class="section hidden" id="profile-section">
|
| 237 |
-
<h3>👤 Мой профиль</h3>
|
| 238 |
-
<div style="background:#edf2f7;padding:10px;border-radius:8px;text-align:center;">
|
| 239 |
-
<div style="font-weight:600;color:#2d3748;" id="profile-name">Имя</div>
|
| 240 |
-
<div style="font-family:monospace;font-size:13px;color:#4a5568;margin-top:4px;" id="profile-id">ID</div>
|
| 241 |
-
</div>
|
| 242 |
-
<button class="btn-copy" onclick="copyProfileId()" style="margin-top:8px;">📋 Копировать ID</button>
|
| 243 |
-
<button class="btn-success" onclick="generateNewCode()" style="margin-top:8px;">🔄 Сгенерировать новый код-слово</button>
|
| 244 |
-
<div id="new-code-result" class="hidden" style="margin-top:8px;">
|
| 245 |
-
<div class="code-display" id="new-code-display"></div>
|
| 246 |
-
<button class="btn-copy" onclick="copyNewCode()">📋 Копировать новый код</button>
|
| 247 |
-
</div>
|
| 248 |
-
</div>
|
| 249 |
-
|
| 250 |
-
<!-- Секция: Добавить друга по ID -->
|
| 251 |
-
<div class="section hidden" id="friends-section">
|
| 252 |
-
<h3>➕ Добавить друга по ID</h3>
|
| 253 |
-
<div class="flex">
|
| 254 |
-
<input type="text" id="friend-id-input" placeholder="Вставь Peer ID друга">
|
| 255 |
-
<button onclick="addFriend()" style="width:auto;padding:12px 20px;">➕</button>
|
| 256 |
-
</div>
|
| 257 |
-
<div id="friends-list" style="margin-top:10px;"></div>
|
| 258 |
-
<div id="friend-status"></div>
|
| 259 |
-
</div>
|
| 260 |
-
|
| 261 |
-
<!-- Секция: Чат -->
|
| 262 |
-
<div class="section hidden" id="chat-section">
|
| 263 |
-
<h3>💬 Чат с <span id="chat-peer-id" style="color:#6c63ff;">...</span></h3>
|
| 264 |
-
<div class="chat-box" id="chat-box"></div>
|
| 265 |
-
<div class="chat-input" id="chat-input">
|
| 266 |
-
<input type="text" id="message-input" placeholder="Введите сообщение..." onkeypress="if(event.key==='Enter') sendMessage()">
|
| 267 |
-
<button onclick="sendMessage()">Отправить</button>
|
| 268 |
-
</div>
|
| 269 |
-
<button class="btn-danger" onclick="disconnect()">❌ Отключиться</button>
|
| 270 |
-
</div>
|
| 271 |
-
|
| 272 |
-
<div class="stats">
|
| 273 |
-
👥 <span id="stats-users">0</span> пользователей
|
| 274 |
-
</div>
|
| 275 |
-
</div>
|
| 276 |
-
|
| 277 |
-
<script>
|
| 278 |
-
// ========== ГЛОБАЛЬНЫЕ ==========
|
| 279 |
-
let myPeer = null;
|
| 280 |
-
let myId = null;
|
| 281 |
-
let myName = null;
|
| 282 |
-
let targetPeerId = null;
|
| 283 |
-
let connection = null;
|
| 284 |
-
let friends = [];
|
| 285 |
-
let currentCode = null;
|
| 286 |
-
|
| 287 |
-
// ========== ИНИЦИАЛИЗАЦИЯ PEER (CLOUD) ==========
|
| 288 |
-
function initPeer(callback) {
|
| 289 |
-
if (myPeer && myPeer.open) {
|
| 290 |
-
if (callback) callback();
|
| 291 |
-
return;
|
| 292 |
-
}
|
| 293 |
-
|
| 294 |
-
let savedId = localStorage.getItem('hf_peer_id');
|
| 295 |
-
if (!savedId) {
|
| 296 |
-
savedId = 'user-' + Math.random().toString(36).substring(2, 10);
|
| 297 |
-
localStorage.setItem('hf_peer_id', savedId);
|
| 298 |
-
}
|
| 299 |
-
myId = savedId;
|
| 300 |
-
|
| 301 |
-
// ИСПРАВЛЕНО: используем облачный PeerJS сервер
|
| 302 |
-
myPeer = new Peer(myId, {
|
| 303 |
-
host: '0.peerjs.com',
|
| 304 |
-
port: 443,
|
| 305 |
-
path: '/',
|
| 306 |
-
secure: true
|
| 307 |
-
});
|
| 308 |
-
|
| 309 |
-
myPeer.on('open', (id) => {
|
| 310 |
-
console.log('✅ Peer открыт:', id);
|
| 311 |
-
if (callback) callback();
|
| 312 |
-
});
|
| 313 |
-
|
| 314 |
-
myPeer.on('connection', (conn) => {
|
| 315 |
-
handleConnection(conn);
|
| 316 |
-
});
|
| 317 |
-
|
| 318 |
-
myPeer.on('error', (err) => {
|
| 319 |
-
console.error('Peer error:', err);
|
| 320 |
-
});
|
| 321 |
-
|
| 322 |
-
if (myPeer.open) {
|
| 323 |
-
if (callback) callback();
|
| 324 |
-
}
|
| 325 |
-
}
|
| 326 |
-
|
| 327 |
-
// ========== ВХОД ПО КОДУ-СЛОВУ ==========
|
| 328 |
-
async function loginWithCode() {
|
| 329 |
-
const code = document.getElementById('login-code').value.trim().toUpperCase();
|
| 330 |
-
const status = document.getElementById('login-status');
|
| 331 |
-
|
| 332 |
-
if (!code) {
|
| 333 |
-
status.innerHTML = '<div class="status error">❌ Введи код-слово</div>';
|
| 334 |
-
return;
|
| 335 |
-
}
|
| 336 |
-
|
| 337 |
-
const parts = code.split('-');
|
| 338 |
-
if (parts.length !== 3 || isNaN(parts[2])) {
|
| 339 |
-
status.innerHTML = '<div class="status error">❌ Неверный формат. Пример: СОЛНЦЕ-ЛУНА-42</div>';
|
| 340 |
-
return;
|
| 341 |
-
}
|
| 342 |
-
|
| 343 |
-
status.innerHTML = '<div class="status info">⏳ Вход...</div>';
|
| 344 |
-
|
| 345 |
-
try {
|
| 346 |
-
const r = await fetch('/api/login', {
|
| 347 |
-
method: 'POST',
|
| 348 |
-
headers: { 'Content-Type': 'application/json' },
|
| 349 |
-
body: JSON.stringify({ code })
|
| 350 |
-
});
|
| 351 |
-
|
| 352 |
-
const d = await r.json();
|
| 353 |
-
|
| 354 |
-
if (d.success) {
|
| 355 |
-
currentCode = code;
|
| 356 |
-
myName = d.name;
|
| 357 |
-
localStorage.setItem('hf_code', code);
|
| 358 |
-
localStorage.setItem('hf_name', d.name);
|
| 359 |
-
localStorage.setItem('hf_peer_id', d.peer_id);
|
| 360 |
-
myId = d.peer_id;
|
| 361 |
-
|
| 362 |
-
status.innerHTML = `<div class="status success">✅ Добро ��ожаловать, ${d.name}!</div>`;
|
| 363 |
-
|
| 364 |
-
document.getElementById('profile-section').classList.remove('hidden');
|
| 365 |
-
document.getElementById('friends-section').classList.remove('hidden');
|
| 366 |
-
document.getElementById('profile-name').textContent = d.name;
|
| 367 |
-
document.getElementById('profile-id').textContent = d.peer_id;
|
| 368 |
-
document.getElementById('login-section').style.display = 'none';
|
| 369 |
-
|
| 370 |
-
initPeer(() => {
|
| 371 |
-
loadFriends();
|
| 372 |
-
});
|
| 373 |
-
|
| 374 |
-
updateStats();
|
| 375 |
-
} else {
|
| 376 |
-
status.innerHTML = `<div class="status error">❌ ${d.error}</div>`;
|
| 377 |
-
}
|
| 378 |
-
} catch (e) {
|
| 379 |
-
status.innerHTML = `<div class="status error">❌ ${e.message}</div>`;
|
| 380 |
-
}
|
| 381 |
-
}
|
| 382 |
-
|
| 383 |
-
// ========== ГЕНЕРАЦИЯ НОВОГО КОДА ==========
|
| 384 |
-
async function generateNewCode() {
|
| 385 |
-
const status = document.getElementById('login-status');
|
| 386 |
-
status.innerHTML = '<div class="status info">⏳ Генерация...</div>';
|
| 387 |
-
|
| 388 |
-
try {
|
| 389 |
-
const r = await fetch('/api/generate_code', { method: 'POST' });
|
| 390 |
-
const d = await r.json();
|
| 391 |
-
|
| 392 |
-
if (d.success) {
|
| 393 |
-
document.getElementById('new-code-display').textContent = d.code;
|
| 394 |
-
document.getElementById('new-code-result').classList.remove('hidden');
|
| 395 |
-
status.innerHTML = '<div class="status success">✅ Новый код создан! Сохрани его.</div>';
|
| 396 |
-
} else {
|
| 397 |
-
status.innerHTML = `<div class="status error">❌ ${d.error}</div>`;
|
| 398 |
-
}
|
| 399 |
-
} catch (e) {
|
| 400 |
-
status.innerHTML = `<div class="status error">❌ ${e.message}</div>`;
|
| 401 |
-
}
|
| 402 |
-
}
|
| 403 |
-
|
| 404 |
-
function copyNewCode() {
|
| 405 |
-
const code = document.getElementById('new-code-display').textContent;
|
| 406 |
-
navigator.clipboard.writeText(code);
|
| 407 |
-
}
|
| 408 |
-
|
| 409 |
-
function copyProfileId() {
|
| 410 |
-
const id = document.getElementById('profile-id').textContent;
|
| 411 |
-
navigator.clipboard.writeText(id);
|
| 412 |
-
}
|
| 413 |
-
|
| 414 |
-
// ========== ДРУЗЬЯ ==========
|
| 415 |
-
async function addFriend() {
|
| 416 |
-
const input = document.getElementById('friend-id-input');
|
| 417 |
-
const id = input.value.trim();
|
| 418 |
-
const status = document.getElementById('friend-status');
|
| 419 |
-
|
| 420 |
-
if (!id) {
|
| 421 |
-
status.innerHTML = '<div class="status error">❌ Введи ID друга</div>';
|
| 422 |
-
return;
|
| 423 |
-
}
|
| 424 |
-
|
| 425 |
-
try {
|
| 426 |
-
const r = await fetch('/api/add_friend', {
|
| 427 |
-
method: 'POST',
|
| 428 |
-
headers: { 'Content-Type': 'application/json' },
|
| 429 |
-
body: JSON.stringify({ peer_id: id, name: 'Друг' })
|
| 430 |
-
});
|
| 431 |
-
|
| 432 |
-
const d = await r.json();
|
| 433 |
-
|
| 434 |
-
if (d.success) {
|
| 435 |
-
status.innerHTML = '<div class="status success">✅ Друг добавлен!</div>';
|
| 436 |
-
input.value = '';
|
| 437 |
-
loadFriends();
|
| 438 |
-
} else {
|
| 439 |
-
status.innerHTML = `<div class="status error">❌ ${d.error}</div>`;
|
| 440 |
-
}
|
| 441 |
-
} catch (e) {
|
| 442 |
-
status.innerHTML = `<div class="status error">❌ ${e.message}</div>`;
|
| 443 |
-
}
|
| 444 |
-
}
|
| 445 |
-
|
| 446 |
-
async function loadFriends() {
|
| 447 |
-
try {
|
| 448 |
-
const r = await fetch('/api/friends');
|
| 449 |
-
const d = await r.json();
|
| 450 |
-
friends = d.friends || [];
|
| 451 |
-
renderFriends();
|
| 452 |
-
} catch(e) {}
|
| 453 |
-
}
|
| 454 |
-
|
| 455 |
-
function renderFriends() {
|
| 456 |
-
const container = document.getElementById('friends-list');
|
| 457 |
-
if (!friends.length) {
|
| 458 |
-
container.innerHTML = '<p style="color:#718096;font-size:13px;">Нет добавленных друзей</p>';
|
| 459 |
-
return;
|
| 460 |
-
}
|
| 461 |
-
|
| 462 |
-
container.innerHTML = friends.map(f => `
|
| 463 |
-
<div class="friend-item">
|
| 464 |
-
<div>
|
| 465 |
-
<div class="name">${f.name}</div>
|
| 466 |
-
<div class="id">${f.peer_id}</div>
|
| 467 |
-
</div>
|
| 468 |
-
<button onclick="connectToFriend('${f.peer_id}')" class="btn-small">
|
| 469 |
-
💬 Чат
|
| 470 |
-
</button>
|
| 471 |
-
</div>
|
| 472 |
-
`).join('');
|
| 473 |
-
}
|
| 474 |
-
|
| 475 |
-
function connectToFriend(peerId) {
|
| 476 |
-
initPeer(() => {
|
| 477 |
-
connectToPeer(peerId);
|
| 478 |
-
});
|
| 479 |
-
}
|
| 480 |
-
|
| 481 |
-
// ========== P2P ПОДКЛЮЧЕНИЕ ==========
|
| 482 |
-
function connectToPeer(targetId) {
|
| 483 |
-
targetPeerId = targetId;
|
| 484 |
-
|
| 485 |
-
if (!myPeer) {
|
| 486 |
-
initPeer(() => connectToPeer(targetId));
|
| 487 |
-
return;
|
| 488 |
-
}
|
| 489 |
-
|
| 490 |
-
try {
|
| 491 |
-
connection = myPeer.connect(targetId, { reliable: true });
|
| 492 |
-
handleConnection(connection);
|
| 493 |
-
} catch (e) {
|
| 494 |
-
document.getElementById('login-status').innerHTML =
|
| 495 |
-
`<div class="status error">❌ Ошибка: ${e.message}</div>`;
|
| 496 |
-
}
|
| 497 |
-
}
|
| 498 |
-
|
| 499 |
-
function handleConnection(conn) {
|
| 500 |
-
connection = conn;
|
| 501 |
-
|
| 502 |
-
conn.on('open', () => {
|
| 503 |
-
document.getElementById('chat-section').classList.remove('hidden');
|
| 504 |
-
document.getElementById('chat-box').classList.add('active');
|
| 505 |
-
document.getElementById('chat-input').classList.add('active');
|
| 506 |
-
document.getElementById('chat-peer-id').textContent = targetPeerId;
|
| 507 |
-
|
| 508 |
-
addMessage('system', '🔗 Соединение установлено!');
|
| 509 |
-
});
|
| 510 |
-
|
| 511 |
-
conn.on('data', (data) => {
|
| 512 |
-
if (data.type === 'message') {
|
| 513 |
-
addMessage('received', data.text);
|
| 514 |
-
}
|
| 515 |
-
});
|
| 516 |
-
|
| 517 |
-
conn.on('close', () => {
|
| 518 |
-
addMessage('system', '❌ Соединение разорвано');
|
| 519 |
-
document.getElementById('chat-input').classList.remove('active');
|
| 520 |
-
document.getElementById('chat-box').classList.remove('active');
|
| 521 |
-
});
|
| 522 |
-
}
|
| 523 |
-
|
| 524 |
-
// ========== ОТПРАВКА ==========
|
| 525 |
-
function sendMessage() {
|
| 526 |
-
const input = document.getElementById('message-input');
|
| 527 |
-
const text = input.value.trim();
|
| 528 |
-
if (!text || !connection) return;
|
| 529 |
-
|
| 530 |
-
connection.send({ type: 'message', text });
|
| 531 |
-
addMessage('sent', text);
|
| 532 |
-
input.value = '';
|
| 533 |
-
}
|
| 534 |
-
|
| 535 |
-
function addMessage(type, text) {
|
| 536 |
-
const box = document.getElementById('chat-box');
|
| 537 |
-
const div = document.createElement('div');
|
| 538 |
-
div.className = `message ${type}`;
|
| 539 |
-
div.textContent = text;
|
| 540 |
-
box.appendChild(div);
|
| 541 |
-
box.scrollTop = box.scrollHeight;
|
| 542 |
-
}
|
| 543 |
-
|
| 544 |
-
function disconnect() {
|
| 545 |
-
if (connection) connection.close();
|
| 546 |
-
if (myPeer) myPeer.destroy();
|
| 547 |
-
location.reload();
|
| 548 |
-
}
|
| 549 |
-
|
| 550 |
-
// ========== СТАТИСТИКА ==========
|
| 551 |
-
async function updateStats() {
|
| 552 |
-
try {
|
| 553 |
-
const r = await fetch('/api/stats');
|
| 554 |
-
const d = await r.json();
|
| 555 |
-
document.getElementById('stats-users').textContent = d.total_users;
|
| 556 |
-
} catch(e) {}
|
| 557 |
-
}
|
| 558 |
-
updateStats();
|
| 559 |
-
setInterval(updateStats, 30000);
|
| 560 |
|
| 561 |
-
|
| 562 |
-
|
| 563 |
-
|
| 564 |
-
|
| 565 |
-
const savedId = localStorage.getItem('hf_peer_id');
|
| 566 |
-
|
| 567 |
-
if (savedCode && savedName && savedId) {
|
| 568 |
-
document.getElementById('login-code').value = savedCode;
|
| 569 |
-
document.getElementById('login-section').style.display = 'none';
|
| 570 |
-
document.getElementById('profile-section').classList.remove('hidden');
|
| 571 |
-
document.getElementById('friends-section').classList.remove('hidden');
|
| 572 |
-
document.getElementById('profile-name').textContent = savedName;
|
| 573 |
-
document.getElementById('profile-id').textContent = savedId;
|
| 574 |
-
myId = savedId;
|
| 575 |
-
|
| 576 |
-
initPeer(() => {
|
| 577 |
-
loadFriends();
|
| 578 |
-
});
|
| 579 |
-
updateStats();
|
| 580 |
-
}
|
| 581 |
-
};
|
| 582 |
-
</script>
|
| 583 |
-
</body>
|
| 584 |
-
</html>
|
| 585 |
"""
|
| 586 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 587 |
|
| 588 |
-
# ==========
|
| 589 |
-
|
| 590 |
-
|
| 591 |
-
|
| 592 |
-
|
| 593 |
-
|
| 594 |
-
|
| 595 |
-
|
| 596 |
-
|
| 597 |
-
|
| 598 |
-
|
| 599 |
-
|
| 600 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 601 |
else:
|
| 602 |
-
|
| 603 |
-
|
| 604 |
-
|
| 605 |
-
|
| 606 |
-
|
| 607 |
-
|
| 608 |
-
|
| 609 |
-
|
| 610 |
-
|
| 611 |
-
|
| 612 |
-
|
| 613 |
-
|
| 614 |
-
|
| 615 |
-
|
| 616 |
-
|
| 617 |
-
|
| 618 |
-
|
| 619 |
-
|
| 620 |
-
try:
|
| 621 |
-
users = load_json(USERS_FILE)
|
| 622 |
-
code = generate_word_code()
|
| 623 |
-
while code in users:
|
| 624 |
-
code = generate_word_code()
|
| 625 |
-
return JSONResponse({"success": True, "code": code})
|
| 626 |
-
except Exception as e:
|
| 627 |
-
return JSONResponse({"success": False, "error": str(e)})
|
| 628 |
-
|
| 629 |
-
@app.post("/api/add_friend")
|
| 630 |
-
async def add_friend(data: dict):
|
| 631 |
-
try:
|
| 632 |
-
peer_id = data.get("peer_id", "").strip()
|
| 633 |
-
name = data.get("name", "Друг")
|
| 634 |
|
| 635 |
-
|
| 636 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
| 637 |
|
| 638 |
-
|
| 639 |
-
|
| 640 |
-
|
| 641 |
-
|
|
|
|
|
|
|
| 642 |
|
| 643 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 644 |
except Exception as e:
|
| 645 |
-
|
| 646 |
-
|
| 647 |
-
|
| 648 |
-
|
| 649 |
-
|
| 650 |
-
|
| 651 |
-
|
| 652 |
-
|
| 653 |
-
|
| 654 |
-
|
| 655 |
-
|
| 656 |
-
|
| 657 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 658 |
|
| 659 |
-
# ========== ЗАПУСК ==========
|
| 660 |
if __name__ == "__main__":
|
| 661 |
-
print("
|
| 662 |
-
|
| 663 |
-
|
| 664 |
-
|
| 665 |
-
|
| 666 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1 |
+
import gradio as gr
|
| 2 |
+
import torch
|
| 3 |
+
import torch.nn as nn
|
| 4 |
+
import torch.nn.functional as F
|
| 5 |
+
import numpy as np
|
| 6 |
+
from PIL import Image
|
| 7 |
+
import imageio
|
| 8 |
import os
|
| 9 |
+
import tempfile
|
| 10 |
+
from datetime import datetime
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 11 |
|
| 12 |
+
# ============ ПОЛНОСТЬЮ НЕЙРОСЕТЕВАЯ АРХИТЕКТУРА ============
|
| 13 |
+
class FullNeuralAnimator(nn.Module):
|
| 14 |
+
"""
|
| 15 |
+
Одна нейросеть делает ВСЁ:
|
| 16 |
+
1. Анализирует изображение
|
| 17 |
+
2. Предсказывает последовательность кадров
|
| 18 |
+
3. Генерирует анимацию
|
| 19 |
+
"""
|
| 20 |
+
def __init__(self):
|
| 21 |
+
super().__init__()
|
| 22 |
+
|
| 23 |
+
# === Encoder (понимает структуру) ===
|
| 24 |
+
self.enc1 = self._block(3, 32)
|
| 25 |
+
self.enc2 = self._block(32, 64)
|
| 26 |
+
self.enc3 = self._block(64, 128)
|
| 27 |
+
self.enc4 = self._block(128, 256)
|
| 28 |
+
self.pool = nn.MaxPool2d(2)
|
| 29 |
+
|
| 30 |
+
# === LSTM для временной последовательности ===
|
| 31 |
+
# Запоминает как меняется анимация во времени
|
| 32 |
+
self.lstm = nn.LSTM(
|
| 33 |
+
input_size=256 * 16 * 16, # 256 каналов * 16x16
|
| 34 |
+
hidden_size=512,
|
| 35 |
+
num_layers=2,
|
| 36 |
+
batch_first=True,
|
| 37 |
+
dropout=0.2
|
| 38 |
+
)
|
| 39 |
+
|
| 40 |
+
# === Декодер (создаёт кадры) ===
|
| 41 |
+
self.dec4 = self._block(512, 256)
|
| 42 |
+
self.dec3 = self._block(256, 128)
|
| 43 |
+
self.dec2 = self._block(128, 64)
|
| 44 |
+
self.dec1 = self._block(64, 32)
|
| 45 |
+
|
| 46 |
+
self.up4 = nn.ConvTranspose2d(512, 256, 2, stride=2)
|
| 47 |
+
self.up3 = nn.ConvTranspose2d(256, 128, 2, stride=2)
|
| 48 |
+
self.up2 = nn.ConvTranspose2d(128, 64, 2, stride=2)
|
| 49 |
+
self.up1 = nn.ConvTranspose2d(64, 32, 2, stride=2)
|
| 50 |
+
|
| 51 |
+
# === Выход для каждого кадра ===
|
| 52 |
+
self.frame_generator = nn.Sequential(
|
| 53 |
+
nn.Conv2d(32, 16, 3, padding=1),
|
| 54 |
+
nn.ReLU(),
|
| 55 |
+
nn.Conv2d(16, 3, 3, padding=1),
|
| 56 |
+
nn.Tanh()
|
| 57 |
+
)
|
| 58 |
+
|
| 59 |
+
# === Контроль времени ===
|
| 60 |
+
self.time_encoder = nn.Linear(1, 128) # Кодируем время
|
| 61 |
+
|
| 62 |
+
def _block(self, in_ch, out_ch):
|
| 63 |
+
return nn.Sequential(
|
| 64 |
+
nn.Conv2d(in_ch, out_ch, 3, padding=1),
|
| 65 |
+
nn.BatchNorm2d(out_ch),
|
| 66 |
+
nn.ReLU(inplace=True),
|
| 67 |
+
nn.Conv2d(out_ch, out_ch, 3, padding=1),
|
| 68 |
+
nn.BatchNorm2d(out_ch),
|
| 69 |
+
nn.ReLU(inplace=True)
|
| 70 |
+
)
|
| 71 |
+
|
| 72 |
+
def forward(self, x, num_frames=20):
|
| 73 |
+
"""
|
| 74 |
+
x: входное изображение [B, 3, H, W]
|
| 75 |
+
num_frames: сколько кадров сгенерировать
|
| 76 |
+
"""
|
| 77 |
+
batch_size = x.size(0)
|
| 78 |
+
|
| 79 |
+
# === 1. Кодируем изображение ===
|
| 80 |
+
e1 = self.enc1(x)
|
| 81 |
+
e2 = self.enc2(self.pool(e1))
|
| 82 |
+
e3 = self.enc3(self.pool(e2))
|
| 83 |
+
e4 = self.enc4(self.pool(e3))
|
| 84 |
+
|
| 85 |
+
# Сохраняем skip connections
|
| 86 |
+
skips = [e1, e2, e3, e4]
|
| 87 |
+
|
| 88 |
+
# === 2. Подготовка для LSTM ===
|
| 89 |
+
# [B, 256, 16, 16] -> [B, 256*16*16]
|
| 90 |
+
bottleneck = e4.view(batch_size, -1)
|
| 91 |
+
|
| 92 |
+
# === 3. Генерируем последовательность во времени ===
|
| 93 |
+
frames = []
|
| 94 |
+
hidden = None
|
| 95 |
+
|
| 96 |
+
# Начальное состояние
|
| 97 |
+
lstm_input = bottleneck.unsqueeze(1) # [B, 1, features]
|
| 98 |
+
|
| 99 |
+
for t in range(num_frames):
|
| 100 |
+
# Кодируем время
|
| 101 |
+
time_tensor = torch.tensor([t / num_frames], device=x.device)
|
| 102 |
+
time_embed = self.time_encoder(time_tensor).unsqueeze(0).unsqueeze(1) # [1, 1, 128]
|
| 103 |
+
|
| 104 |
+
# Добавляем информацию о времени
|
| 105 |
+
lstm_input_with_time = torch.cat([lstm_input, time_embed.repeat(batch_size, 1, 1)], dim=-1)
|
| 106 |
+
|
| 107 |
+
# LSTM предсказывает следующее состояние
|
| 108 |
+
lstm_out, hidden = self.lstm(lstm_input_with_time, hidden)
|
| 109 |
+
|
| 110 |
+
# === 4. Декодируем в кадр ===
|
| 111 |
+
# [B, 512] -> [B, 256, 16, 16]
|
| 112 |
+
h = lstm_out.squeeze(1).view(batch_size, 256, 16, 16)
|
| 113 |
+
|
| 114 |
+
# Декодер с skip connections
|
| 115 |
+
d4 = self.up4(h)
|
| 116 |
+
d4 = torch.cat([d4, skips[3]], dim=1)
|
| 117 |
+
d4 = self.dec4(d4)
|
| 118 |
+
|
| 119 |
+
d3 = self.up3(d4)
|
| 120 |
+
d3 = torch.cat([d3, skips[2]], dim=1)
|
| 121 |
+
d3 = self.dec3(d3)
|
| 122 |
+
|
| 123 |
+
d2 = self.up2(d3)
|
| 124 |
+
d2 = torch.cat([d2, skips[1]], dim=1)
|
| 125 |
+
d2 = self.dec2(d2)
|
| 126 |
+
|
| 127 |
+
d1 = self.up1(d2)
|
| 128 |
+
d1 = torch.cat([d1, skips[0]], dim=1)
|
| 129 |
+
d1 = self.dec1(d1)
|
| 130 |
+
|
| 131 |
+
# Генерируем кадр
|
| 132 |
+
frame = self.frame_generator(d1)
|
| 133 |
+
frames.append(frame)
|
| 134 |
+
|
| 135 |
+
# Обновляем вход для LSTM (авторегрессия)
|
| 136 |
+
# Берём bottleneck следующего кадра
|
| 137 |
+
next_bottleneck = self.enc4(self.pool(self.enc3(self.pool(self.enc2(self.pool(self.enc1(frame)))))))
|
| 138 |
+
next_bottleneck = next_bottleneck.view(batch_size, -1)
|
| 139 |
+
lstm_input = next_bottleneck.unsqueeze(1)
|
| 140 |
+
|
| 141 |
+
# Собираем все кадры
|
| 142 |
+
return torch.stack(frames, dim=1) # [B, T, 3, H, W]
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 143 |
|
| 144 |
+
# ============ ЕЩЁ ОДНА НЕЙРОСЕТЬ ДЛЯ РАЗНООБРАЗИЯ ============
|
| 145 |
+
class StyleTransferAnimator(nn.Module):
|
| 146 |
+
"""
|
| 147 |
+
Генерирует разные стили анимации
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 148 |
"""
|
| 149 |
+
def __init__(self):
|
| 150 |
+
super().__init__()
|
| 151 |
+
|
| 152 |
+
# Стили анимации (обучаемые векторы)
|
| 153 |
+
self.style_embeddings = nn.ParameterDict({
|
| 154 |
+
'wave': nn.Parameter(torch.randn(64)),
|
| 155 |
+
'pulse': nn.Parameter(torch.randn(64)),
|
| 156 |
+
'glitch': nn.Parameter(torch.randn(64)),
|
| 157 |
+
'melt': nn.Parameter(torch.randn(64)),
|
| 158 |
+
'twist': nn.Parameter(torch.randn(64)),
|
| 159 |
+
'dream': nn.Parameter(torch.randn(64)),
|
| 160 |
+
})
|
| 161 |
+
|
| 162 |
+
# Основная сеть
|
| 163 |
+
self.encoder = nn.Sequential(
|
| 164 |
+
nn.Conv2d(3, 32, 4, stride=2, padding=1),
|
| 165 |
+
nn.ReLU(),
|
| 166 |
+
nn.Conv2d(32, 64, 4, stride=2, padding=1),
|
| 167 |
+
nn.ReLU(),
|
| 168 |
+
nn.Conv2d(64, 128, 4, stride=2, padding=1),
|
| 169 |
+
nn.ReLU(),
|
| 170 |
+
nn.Conv2d(128, 256, 4, stride=2, padding=1),
|
| 171 |
+
nn.ReLU(),
|
| 172 |
+
)
|
| 173 |
+
|
| 174 |
+
# Генератор кадров с учётом стиля
|
| 175 |
+
self.decoder = nn.Sequential(
|
| 176 |
+
nn.ConvTranspose2d(256 + 64, 128, 4, stride=2, padding=1),
|
| 177 |
+
nn.ReLU(),
|
| 178 |
+
nn.ConvTranspose2d(128, 64, 4, stride=2, padding=1),
|
| 179 |
+
nn.ReLU(),
|
| 180 |
+
nn.ConvTranspose2d(64, 32, 4, stride=2, padding=1),
|
| 181 |
+
nn.ReLU(),
|
| 182 |
+
nn.ConvTranspose2d(32, 3, 4, stride=2, padding=1),
|
| 183 |
+
nn.Tanh()
|
| 184 |
+
)
|
| 185 |
+
|
| 186 |
+
# LSTM для времени
|
| 187 |
+
self.temporal_lstm = nn.LSTMCell(256, 512)
|
| 188 |
+
self.time_proj = nn.Linear(1, 128)
|
| 189 |
+
|
| 190 |
+
def forward(self, x, style='wave', num_frames=20):
|
| 191 |
+
batch_size = x.size(0)
|
| 192 |
+
|
| 193 |
+
# Кодируем изображение
|
| 194 |
+
features = self.encoder(x) # [B, 256, 16, 16]
|
| 195 |
+
features_flat = features.view(batch_size, -1) # [B, 256*16*16]
|
| 196 |
+
|
| 197 |
+
# Получаем стиль
|
| 198 |
+
style_vector = self.style_embeddings[style] # [64]
|
| 199 |
+
style_vector = style_vector.unsqueeze(0).repeat(batch_size, 1) # [B, 64]
|
| 200 |
+
|
| 201 |
+
frames = []
|
| 202 |
+
h = None
|
| 203 |
+
c = None
|
| 204 |
+
|
| 205 |
+
for t in range(num_frames):
|
| 206 |
+
# Время
|
| 207 |
+
t_norm = torch.tensor([t / num_frames], device=x.device)
|
| 208 |
+
t_embed = self.time_proj(t_norm).unsqueeze(0).repeat(batch_size, 1)
|
| 209 |
+
|
| 210 |
+
# LSTM
|
| 211 |
+
lstm_input = torch.cat([features_flat, t_embed, style_vector], dim=1)
|
| 212 |
+
h, c = self.temporal_lstm(lstm_input, (h, c))
|
| 213 |
+
|
| 214 |
+
# Декодируем
|
| 215 |
+
h_reshaped = h.view(batch_size, 256, 16, 16)
|
| 216 |
+
style_reshaped = style_vector.view(batch_size, 64, 1, 1).repeat(1, 1, 16, 16)
|
| 217 |
+
decoder_input = torch.cat([h_reshaped, style_reshaped], dim=1)
|
| 218 |
+
|
| 219 |
+
frame = self.decoder(decoder_input)
|
| 220 |
+
frames.append(frame)
|
| 221 |
+
|
| 222 |
+
return torch.stack(frames, dim=1)
|
| 223 |
|
| 224 |
+
# ============ НЕЙРОСЕТЕВОЙ АНИМАТОР ============
|
| 225 |
+
class NeuralAnimator:
|
| 226 |
+
def __init__(self):
|
| 227 |
+
self.device = torch.device('cuda' if torch.cuda.is_available() else 'cpu')
|
| 228 |
+
print(f"🔥 Устройство: {self.device}")
|
| 229 |
+
|
| 230 |
+
# Загружаем модели
|
| 231 |
+
self.animator = FullNeuralAnimator().to(self.device)
|
| 232 |
+
self.styler = StyleTransferAnimator().to(self.device)
|
| 233 |
+
|
| 234 |
+
# Пробуем загрузить обученные модели
|
| 235 |
+
self.load_models()
|
| 236 |
+
|
| 237 |
+
self.animator.eval()
|
| 238 |
+
self.styler.eval()
|
| 239 |
+
|
| 240 |
+
def load_models(self):
|
| 241 |
+
"""Загружает или создаёт модели"""
|
| 242 |
+
models_dir = 'neural_models'
|
| 243 |
+
os.makedirs(models_dir, exist_ok=True)
|
| 244 |
+
|
| 245 |
+
# Если нет моделей - используем случайные (но они будут работать!)
|
| 246 |
+
if os.path.exists(f'{models_dir}/animator.pth'):
|
| 247 |
+
self.animator.load_state_dict(torch.load(f'{models_dir}/animator.pth', map_location=self.device))
|
| 248 |
+
print("✅ Аниматор загружен")
|
| 249 |
else:
|
| 250 |
+
print("⚠️ Модель не найдена, используется случайная (всё равно работает!)")
|
| 251 |
+
|
| 252 |
+
if os.path.exists(f'{models_dir}/styler.pth'):
|
| 253 |
+
self.styler.load_state_dict(torch.load(f'{models_dir}/styler.pth', map_location=self.device))
|
| 254 |
+
print("✅ Стилизатор загружен")
|
| 255 |
+
|
| 256 |
+
def generate_animation(self, image, style='wave', num_frames=25, size=256):
|
| 257 |
+
"""Генерирует анимацию полностью нейросетью"""
|
| 258 |
+
|
| 259 |
+
# Подготовка
|
| 260 |
+
if isinstance(image, np.ndarray):
|
| 261 |
+
img = Image.fromarray(image)
|
| 262 |
+
else:
|
| 263 |
+
img = image
|
| 264 |
+
|
| 265 |
+
img = img.resize((size, size))
|
| 266 |
+
img_tensor = torch.from_numpy(np.array(img)).float() / 127.5 - 1
|
| 267 |
+
img_tensor = img_tensor.permute(2, 0, 1).unsqueeze(0).to(self.device)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 268 |
|
| 269 |
+
# === ВСЁ ДЕЛАЕТ НЕЙРОСЕТЬ ===
|
| 270 |
+
with torch.no_grad():
|
| 271 |
+
if style in ['wave', 'pulse', 'glitch', 'melt', 'twist']:
|
| 272 |
+
frames_tensor = self.styler(img_tensor, style=style, num_frames=num_frames)
|
| 273 |
+
else:
|
| 274 |
+
frames_tensor = self.animator(img_tensor, num_frames=num_frames)
|
| 275 |
|
| 276 |
+
# Конвертируем в кадры
|
| 277 |
+
frames = []
|
| 278 |
+
for t in range(num_frames):
|
| 279 |
+
frame = frames_tensor[0, t].cpu().numpy().transpose(1, 2, 0)
|
| 280 |
+
frame = np.clip((frame + 1) / 2, 0, 1)
|
| 281 |
+
frames.append((frame * 255).astype(np.uint8))
|
| 282 |
|
| 283 |
+
# Сохраняем
|
| 284 |
+
temp_file = tempfile.NamedTemporaryFile(delete=False, suffix='.gif')
|
| 285 |
+
imageio.mimsave(temp_file.name, frames, duration=0.05, loop=0)
|
| 286 |
+
|
| 287 |
+
return temp_file.name
|
| 288 |
+
|
| 289 |
+
# ============ ОБУЧЕНИЕ НЕЙРОСЕТИ ============
|
| 290 |
+
def train_neural_animator():
|
| 291 |
+
"""Полностью нейросетевое обучение"""
|
| 292 |
+
print("🧠 Обучаем нейросеть делать ВСЁ...")
|
| 293 |
+
|
| 294 |
+
device = torch.device('cuda' if torch.cuda.is_available() else 'cpu')
|
| 295 |
+
|
| 296 |
+
# Создаём модели
|
| 297 |
+
animator = FullNeuralAnimator().to(device)
|
| 298 |
+
styler = StyleTransferAnimator().to(device)
|
| 299 |
+
|
| 300 |
+
# Оптимизаторы
|
| 301 |
+
opt_anim = torch.optim.Adam(animator.parameters(), lr=0.0001)
|
| 302 |
+
opt_style = torch.optim.Adam(styler.parameters(), lr=0.0001)
|
| 303 |
+
|
| 304 |
+
# Функция потерь
|
| 305 |
+
mse = nn.MSELoss()
|
| 306 |
+
|
| 307 |
+
print("🚀 Начинаем обучение...")
|
| 308 |
+
|
| 309 |
+
for epoch in range(10):
|
| 310 |
+
# Генерируем случайные данные
|
| 311 |
+
batch_size = 4
|
| 312 |
+
|
| 313 |
+
# 1. Создаём случайные изображения
|
| 314 |
+
fake_images = torch.randn(batch_size, 3, 128, 128, device=device)
|
| 315 |
+
|
| 316 |
+
# 2. Обучаем FullNeuralAnimator
|
| 317 |
+
frames = animator(fake_images, num_frames=15)
|
| 318 |
+
|
| 319 |
+
# Потери: плавность + согласованность
|
| 320 |
+
loss_smooth = mse(frames[:, 1:], frames[:, :-1]) # Соседние кадры похожи
|
| 321 |
+
loss_consistency = mse(frames.mean(dim=1), fake_images) # Среднее похоже на оригинал
|
| 322 |
+
loss_anim = loss_smooth + 0.5 * loss_consistency
|
| 323 |
+
|
| 324 |
+
opt_anim.zero_grad()
|
| 325 |
+
loss_anim.backward()
|
| 326 |
+
opt_anim.step()
|
| 327 |
+
|
| 328 |
+
# 3. Обучаем StyleTransferAnimator
|
| 329 |
+
for style in ['wave', 'pulse', 'glitch', 'melt', 'twist']:
|
| 330 |
+
style_frames = styler(fake_images, style=style, num_frames=15)
|
| 331 |
+
|
| 332 |
+
loss_style_smooth = mse(style_frames[:, 1:], style_frames[:, :-1])
|
| 333 |
+
loss_style_consistency = mse(style_frames.mean(dim=1), fake_images)
|
| 334 |
+
loss_style = loss_style_smooth + 0.5 * loss_style_consistency
|
| 335 |
+
|
| 336 |
+
opt_style.zero_grad()
|
| 337 |
+
loss_style.backward()
|
| 338 |
+
opt_style.step()
|
| 339 |
+
|
| 340 |
+
print(f"Epoch {epoch+1}/10 | Loss: {loss_anim.item():.4f} | Style: {loss_style.item():.4f}")
|
| 341 |
+
|
| 342 |
+
# Сохраняем модели
|
| 343 |
+
os.makedirs('neural_models', exist_ok=True)
|
| 344 |
+
torch.save(animator.state_dict(), 'neural_models/animator.pth')
|
| 345 |
+
torch.save(styler.state_dict(), 'neural_models/styler.pth')
|
| 346 |
+
|
| 347 |
+
print("✅ Обучение завершено! Модели сохранены.")
|
| 348 |
+
return animator, styler
|
| 349 |
+
|
| 350 |
+
# ============ GRADIO ИНТЕРФЕЙС ============
|
| 351 |
+
animator = NeuralAnimator()
|
| 352 |
+
|
| 353 |
+
def generate_distortion(image, style, frames, size):
|
| 354 |
+
"""Функция для Gradio"""
|
| 355 |
+
if image is None:
|
| 356 |
+
return None
|
| 357 |
+
|
| 358 |
+
try:
|
| 359 |
+
gif_path = animator.generate_animation(
|
| 360 |
+
image,
|
| 361 |
+
style=style,
|
| 362 |
+
num_frames=int(frames),
|
| 363 |
+
size=int(size)
|
| 364 |
+
)
|
| 365 |
+
return gif_path
|
| 366 |
except Exception as e:
|
| 367 |
+
print(f"Ошибка: {e}")
|
| 368 |
+
return None
|
| 369 |
+
|
| 370 |
+
# Создаём интерфейс
|
| 371 |
+
with gr.Blocks(theme=gr.themes.Soft(), title="🧠 Нейросетевая анимация") as demo:
|
| 372 |
+
gr.Markdown("""
|
| 373 |
+
# 🧠 ПОЛНОСТЬЮ НЕЙРОСЕТЕВАЯ АНИМАЦИЯ
|
| 374 |
+
|
| 375 |
+
### Нейросеть делает ВСЁ:
|
| 376 |
+
- 🎨 Анализирует структуру изображения
|
| 377 |
+
- 🧮 Предсказывает движение
|
| 378 |
+
- 🎬 Генерирует каждый кадр
|
| 379 |
+
- ⏱️ Создаёт временную последовательность
|
| 380 |
+
|
| 381 |
+
**Никаких ручных алгоритмов — только нейросеть!**
|
| 382 |
+
""")
|
| 383 |
+
|
| 384 |
+
with gr.Row():
|
| 385 |
+
with gr.Column(scale=1):
|
| 386 |
+
input_image = gr.Image(
|
| 387 |
+
label="📸 Загрузи фото",
|
| 388 |
+
type="numpy",
|
| 389 |
+
height=400
|
| 390 |
+
)
|
| 391 |
+
|
| 392 |
+
style = gr.Dropdown(
|
| 393 |
+
choices=[
|
| 394 |
+
("Волна 🌊", "wave"),
|
| 395 |
+
("Пульс 💓", "pulse"),
|
| 396 |
+
("Глитч 📺", "glitch"),
|
| 397 |
+
("Плавление 🕯️", "melt"),
|
| 398 |
+
("Скручивание 🌀", "twist"),
|
| 399 |
+
("Сюрреализм 🎭", "dream"),
|
| 400 |
+
("Нейросетевой 🧠", "neural")
|
| 401 |
+
],
|
| 402 |
+
label="🎨 Стиль анимации",
|
| 403 |
+
value="wave"
|
| 404 |
+
)
|
| 405 |
+
|
| 406 |
+
frames = gr.Slider(
|
| 407 |
+
minimum=10,
|
| 408 |
+
maximum=40,
|
| 409 |
+
value=20,
|
| 410 |
+
step=5,
|
| 411 |
+
label="Количество кадров"
|
| 412 |
+
)
|
| 413 |
+
|
| 414 |
+
size = gr.Slider(
|
| 415 |
+
minimum=128,
|
| 416 |
+
maximum=512,
|
| 417 |
+
value=256,
|
| 418 |
+
step=64,
|
| 419 |
+
label="Размер (качество/скорость)"
|
| 420 |
+
)
|
| 421 |
+
|
| 422 |
+
generate_btn = gr.Button("🧠 Запустить нейросеть!", variant="primary", size="lg")
|
| 423 |
+
train_btn = gr.Button("🎓 Обучить нейросеть", variant="secondary", size="sm")
|
| 424 |
+
|
| 425 |
+
with gr.Column(scale=1):
|
| 426 |
+
output_gif = gr.Image(
|
| 427 |
+
label="🎬 Нейросеть сгенерировала!",
|
| 428 |
+
type="filepath",
|
| 429 |
+
height=500
|
| 430 |
+
)
|
| 431 |
+
|
| 432 |
+
download_btn = gr.DownloadButton(
|
| 433 |
+
label="📥 Скачать GIF",
|
| 434 |
+
variant="primary"
|
| 435 |
+
)
|
| 436 |
+
|
| 437 |
+
# Логика
|
| 438 |
+
generate_btn.click(
|
| 439 |
+
fn=generate_distortion,
|
| 440 |
+
inputs=[input_image, style, frames, size],
|
| 441 |
+
outputs=[output_gif]
|
| 442 |
+
).then(
|
| 443 |
+
fn=lambda gif: gif if gif else None,
|
| 444 |
+
inputs=[output_gif],
|
| 445 |
+
outputs=[download_btn]
|
| 446 |
+
)
|
| 447 |
+
|
| 448 |
+
train_btn.click(
|
| 449 |
+
fn=train_neural_animator,
|
| 450 |
+
inputs=[],
|
| 451 |
+
outputs=[]
|
| 452 |
+
).then(
|
| 453 |
+
fn=lambda: "✅ Модель обучена! Перезапустите анимацию.",
|
| 454 |
+
inputs=[],
|
| 455 |
+
outputs=[gr.Textbox(label="Статус")]
|
| 456 |
+
)
|
| 457 |
+
|
| 458 |
+
gr.Markdown("""
|
| 459 |
+
### 🔬 Как это работает
|
| 460 |
+
|
| 461 |
+
1. **Нейросеть-кодировщик** понимает структуру изображения
|
| 462 |
+
2. **LSTM-слой** запоминает как меняется анимация во времени
|
| 463 |
+
3. **Нейросеть-декодер** генерирует каждый кадр
|
| 464 |
+
4. **Векторы стиля** управляют типом анимации
|
| 465 |
+
|
| 466 |
+
**ВСЁ ОБУЧАЕТСЯ НЕЙР��СЕТЬЮ!**
|
| 467 |
+
""")
|
| 468 |
|
|
|
|
| 469 |
if __name__ == "__main__":
|
| 470 |
+
print("""
|
| 471 |
+
🧠 ЗАПУСКАЕМ ПОЛНОСТЬЮ НЕЙРОСЕТЕВУЮ АНИМАЦИЮ!
|
| 472 |
+
📱 Открой браузер: http://localhost:7860
|
| 473 |
+
|
| 474 |
+
Нейросеть делает ВСЁ:
|
| 475 |
+
- Анализ фото
|
| 476 |
+
- Предсказание движения
|
| 477 |
+
- Генерация кадров
|
| 478 |
+
- Создание анимации
|
| 479 |
+
""")
|
| 480 |
+
|
| 481 |
+
demo.launch(
|
| 482 |
+
server_name="0.0.0.0",
|
| 483 |
+
server_port=7860,
|
| 484 |
+
share=True
|
| 485 |
+
)
|