Update app.py
This commit is contained in:
44
app.py
44
app.py
@@ -4255,16 +4255,17 @@ def debug_socket():
|
||||
<script>
|
||||
let socket;
|
||||
let logLines = 0;
|
||||
let isPollingOnly = false;
|
||||
let isPollingOnly = true;
|
||||
|
||||
function log(msg, color = '#fff') {
|
||||
const logEl = document.getElementById('log');
|
||||
logEl.innerHTML += `[${new Date().toLocaleTimeString()}] ${msg}\n`;
|
||||
logEl.scrollTop = logEl.scrollHeight;
|
||||
logLines++;
|
||||
if (logLines > 100) {
|
||||
if (logLines > 200) {
|
||||
const lines = logEl.innerHTML.split('\\n');
|
||||
logEl.innerHTML = lines.slice(-100).join('\\n');
|
||||
logEl.innerHTML = lines.slice(-200).join('\\n');
|
||||
logLines = 200;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -4278,7 +4279,7 @@ def debug_socket():
|
||||
if (socket) socket.disconnect();
|
||||
|
||||
const transports = isPollingOnly ? ['polling'] : ['polling', 'websocket'];
|
||||
log(`Laczenie z transports: ${transports.join(', ')}`);
|
||||
log(`Laczenie transports: ${transports.join(', ')}`);
|
||||
|
||||
socket = io('', {
|
||||
transports: transports,
|
||||
@@ -4293,7 +4294,6 @@ def debug_socket():
|
||||
const transport = socket.io.engine.transport.name;
|
||||
document.getElementById('transport').textContent = transport;
|
||||
document.getElementById('sid').textContent = socket.id?.slice(0,8) + '...';
|
||||
socket.emit('requestfulllist', {listid: 1});
|
||||
});
|
||||
|
||||
socket.on('disconnect', (reason) => {
|
||||
@@ -4302,11 +4302,15 @@ def debug_socket():
|
||||
});
|
||||
|
||||
socket.on('connect_error', (err) => {
|
||||
log(`CONNECT ERROR: ${err.message} (typ: ${err.type})`, '#ffc107');
|
||||
log(`CONNECT ERROR: ${err.message} (${err.type})`, '#ffc107');
|
||||
});
|
||||
|
||||
socket.onAny((event, ...args) => {
|
||||
log(`RECEIVED ${event}: ${JSON.stringify(args)}`);
|
||||
log(`RECV ${event}: ${JSON.stringify(args).slice(0,100)}`);
|
||||
});
|
||||
|
||||
socket.io.engine.on('upgrade', (transport) => {
|
||||
log(`UPGRADE --> ${transport.name}`);
|
||||
});
|
||||
|
||||
socket.connect();
|
||||
@@ -4318,8 +4322,9 @@ def debug_socket():
|
||||
|
||||
function emitTest() {
|
||||
if (!socket?.connected) return log('Niepolaczony!', '#dc3545');
|
||||
socket.emit('additem', {listid: 1, name: 'TEST ITEM', quantity: 1});
|
||||
log('SENT: additem test');
|
||||
const now = Date.now();
|
||||
socket.emit('pingtest', now);
|
||||
log(`SENT pingtest ${now}`);
|
||||
}
|
||||
|
||||
function forcePolling() {
|
||||
@@ -4329,17 +4334,24 @@ def debug_socket():
|
||||
}
|
||||
|
||||
function simulateBackground() {
|
||||
log('Symulacja backgroundu... (zamknij/otworz karte za 30s)');
|
||||
setTimeout(() => {
|
||||
if (socket?.connected) log('Przetrwal symulacje!');
|
||||
else log('Disconnect po symulacji!');
|
||||
}, 30000);
|
||||
log('Symulacja: zamknij/otworz karte (monitoruj reconnect)');
|
||||
}
|
||||
|
||||
// Auto start z polling first
|
||||
isPollingOnly = true;
|
||||
// STATUS co 30s
|
||||
setInterval(() => {
|
||||
if (socket?.connected) {
|
||||
const transport = socket.io.engine.transport.name;
|
||||
log(`STATUS: ${transport} | SID: ${socket.id?.slice(0,8)} | RTT test --> Emit`);
|
||||
emitTest();
|
||||
} else {
|
||||
log('STATUS: Offline');
|
||||
}
|
||||
}, 30000);
|
||||
|
||||
// Auto start
|
||||
connect();
|
||||
</script>
|
||||
|
||||
</body>
|
||||
</html>
|
||||
''')
|
||||
|
||||
Reference in New Issue
Block a user