Update app.py
This commit is contained in:
74
app.py
74
app.py
@@ -4246,7 +4246,6 @@ def debug_socket():
|
||||
<button onclick="connect()">Polacz</button>
|
||||
<button onclick="disconnect()">Rozlacz</button>
|
||||
<button onclick="emitTest()">Emit Test</button>
|
||||
<button onclick="simulateBackground()">Symuluj background (30s)</button>
|
||||
<button onclick="forcePolling()">Force Polling</button>
|
||||
|
||||
<h3>Logi:</h3>
|
||||
@@ -4259,7 +4258,8 @@ def debug_socket():
|
||||
|
||||
function log(msg, color = '#fff') {
|
||||
const logEl = document.getElementById('log');
|
||||
logEl.innerHTML += `[${new Date().toLocaleTimeString()}] ${msg}\n`;
|
||||
const time = new Date().toLocaleTimeString();
|
||||
logEl.innerHTML += `[${time}] ${msg}\n`;
|
||||
logEl.scrollTop = logEl.scrollHeight;
|
||||
logLines++;
|
||||
if (logLines > 200) {
|
||||
@@ -4276,10 +4276,13 @@ def debug_socket():
|
||||
}
|
||||
|
||||
function connect() {
|
||||
if (socket) socket.disconnect();
|
||||
if (socket) {
|
||||
socket.disconnect();
|
||||
socket = null;
|
||||
}
|
||||
|
||||
const transports = isPollingOnly ? ['polling'] : ['polling', 'websocket'];
|
||||
log(`Laczenie transports: ${transports.join(', ')}`);
|
||||
log(`Polaczenie z: ${transports.join(', ')}`);
|
||||
|
||||
socket = io('', {
|
||||
transports: transports,
|
||||
@@ -4288,75 +4291,78 @@ def debug_socket():
|
||||
forceNew: true
|
||||
});
|
||||
|
||||
socket.on('connect', () => {
|
||||
log('CONNECTED OK', '#28a745');
|
||||
socket.on('connect', function() {
|
||||
log('CONNECTED OK');
|
||||
updateStatus(true);
|
||||
const transport = socket.io.engine.transport.name;
|
||||
document.getElementById('transport').textContent = transport;
|
||||
document.getElementById('sid').textContent = socket.id?.slice(0,8) + '...';
|
||||
try {
|
||||
const transport = socket.io.engine.transport.name;
|
||||
document.getElementById('transport').textContent = transport;
|
||||
document.getElementById('sid').textContent = socket.id.substring(0,8) + '...';
|
||||
} catch(e) {
|
||||
log('Transport info error: ' + e.message);
|
||||
}
|
||||
socket.emit('requestfulllist', {listid: 1});
|
||||
});
|
||||
|
||||
socket.on('disconnect', (reason) => {
|
||||
log(`DISCONNECTED: ${reason}`, '#dc3545');
|
||||
socket.on('disconnect', function(reason) {
|
||||
log('DISCONNECTED: ' + reason);
|
||||
updateStatus(false);
|
||||
});
|
||||
|
||||
socket.on('connect_error', (err) => {
|
||||
log(`CONNECT ERROR: ${err.message} (${err.type})`, '#ffc107');
|
||||
socket.on('connect_error', function(err) {
|
||||
log('CONNECT ERROR: ' + err.message + ' (' + (err.type || 'unknown') + ')');
|
||||
});
|
||||
|
||||
socket.onAny((event, ...args) => {
|
||||
log(`RECV ${event}: ${JSON.stringify(args).slice(0,100)}`);
|
||||
});
|
||||
|
||||
socket.io.engine.on('upgrade', (transport) => {
|
||||
log(`UPGRADE --> ${transport.name}`);
|
||||
socket.onAny(function(event, ...args) {
|
||||
log('RECV ' + event + ': ' + JSON.stringify(args).substring(0,100));
|
||||
});
|
||||
|
||||
socket.connect();
|
||||
}
|
||||
|
||||
function disconnect() {
|
||||
if (socket) socket.disconnect();
|
||||
if (socket) {
|
||||
socket.disconnect();
|
||||
socket = null;
|
||||
}
|
||||
}
|
||||
|
||||
function emitTest() {
|
||||
if (!socket?.connected) return log('Niepolaczony!', '#dc3545');
|
||||
if (!socket || !socket.connected) {
|
||||
log('Niepolaczony!');
|
||||
return;
|
||||
}
|
||||
const now = Date.now();
|
||||
socket.emit('pingtest', now);
|
||||
log(`SENT pingtest ${now}`);
|
||||
log('SENT pingtest ' + now);
|
||||
}
|
||||
|
||||
function forcePolling() {
|
||||
isPollingOnly = !isPollingOnly;
|
||||
log(`Polling only: ${isPollingOnly}`);
|
||||
log('Polling only: ' + isPollingOnly);
|
||||
connect();
|
||||
}
|
||||
|
||||
function simulateBackground() {
|
||||
log('Symulacja: zamknij/otworz karte (monitoruj reconnect)');
|
||||
}
|
||||
|
||||
// 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`);
|
||||
// STATUS check co 30s
|
||||
setInterval(function() {
|
||||
if (socket && socket.connected) {
|
||||
const transport = socket.io.engine ? socket.io.engine.transport.name : 'unknown';
|
||||
log('STATUS OK: ' + transport + ' | SID: ' + (socket.id ? socket.id.substring(0,8) : 'none'));
|
||||
emitTest();
|
||||
} else {
|
||||
log('STATUS: Offline');
|
||||
}
|
||||
}, 30000);
|
||||
|
||||
// Auto start
|
||||
// Start
|
||||
connect();
|
||||
</script>
|
||||
|
||||
</body>
|
||||
</html>
|
||||
''')
|
||||
|
||||
|
||||
|
||||
# =========================================================================================
|
||||
# SOCKET.IO
|
||||
# =========================================================================================
|
||||
|
||||
Reference in New Issue
Block a user