gsadmin/KoalaSync
1
0
Fork 0
mirror of https://github.com/Shik3i/KoalaSync.git synced 2026-08-22 00:46:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: suppress seek events when solo, add moz-extension CORS, add server logging

Browse Source
This commit is contained in:
Koala
2026-05-26 01:05:56 +02:00
parent 6db8fdbf75
commit db11812bd6
3 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
extension/background.js
+9
View File
@@ -1167,6 +1167,15 @@ async function handleAsyncMessage(message, sender, sendResponse) {
}, FORCE_SYNC_TIMEOUT); }, FORCE_SYNC_TIMEOUT);
} }
addToHistory(message.action, 'You'); addToHistory(message.action, 'You');
const isNonEssentialEvent = message.action === EVENTS.PLAY || message.action === EVENTS.PAUSE || message.action === EVENTS.SEEK;
const hasOtherPeers = currentRoom && Array.isArray(currentRoom.peers) && currentRoom.peers.length > 0;
if (isNonEssentialEvent && !hasOtherPeers) {
sendResponse({ status: 'ok_solo' });
return;
}
emit(message.action, { ...message.payload, peerId }); emit(message.action, { ...message.payload, peerId });
sendResponse({ status: 'ok' }); sendResponse({ status: 'ok' });
}; };
package.json
+1 -1
View File
@@ -1,6 +1,6 @@
{ {
"name": "koalasync", "name": "koalasync",
"version": "1.8.5", "version": "1.8.6",
"description": "KoalaSync Build Scripts", "description": "KoalaSync Build Scripts",
"private": true, "private": true,
"scripts": { "scripts": {
server/index.js
+6 -1
View File
@@ -44,9 +44,10 @@ const httpServer = createServer(app);
const io = new Server(httpServer, { const io = new Server(httpServer, {
cors: { cors: {
origin: (origin, callback) => { origin: (origin, callback) => {
if (!origin || origin === 'https://sync.koalastuff.net' || origin.startsWith('chrome-extension://')) { if (!origin || origin === 'https://sync.koalastuff.net' || origin.startsWith('chrome-extension://') || origin.startsWith('moz-extension://')) {
callback(null, true); callback(null, true);
} else { } else {
log('CORS', `Rejected origin: ${origin}`);
callback(new Error('Not allowed by CORS')); callback(new Error('Not allowed by CORS'));
} }
}, },
@@ -296,6 +297,7 @@ io.on('connection', (socket) => {
const ip = socket._clientIp || socket.handshake.address; const ip = socket._clientIp || socket.handshake.address;
if (!checkAuthRate(ip, roomId)) { if (!checkAuthRate(ip, roomId)) {
log('AUTH', `Auth rate limit blocked ${ip} from room ${roomId.substring(0, 3)}***`);
socket.emit(EVENTS.ERROR, { message: "Too many failed attempts. Try again later." }); socket.emit(EVENTS.ERROR, { message: "Too many failed attempts. Try again later." });
return; return;
} }
@@ -317,6 +319,7 @@ io.on('connection', (socket) => {
roomCreationLocks.set(roomId, lockPromise); roomCreationLocks.set(roomId, lockPromise);
try { try {
if (rooms.size >= MAX_ROOMS) { if (rooms.size >= MAX_ROOMS) {
log('ROOM', `Server at capacity: ${rooms.size}/${MAX_ROOMS} rooms — rejecting join`);
socket.emit(EVENTS.ERROR, { message: "Server capacity reached" }); socket.emit(EVENTS.ERROR, { message: "Server capacity reached" });
return; return;
} }
@@ -343,11 +346,13 @@ io.on('connection', (socket) => {
if (room.passwordHash) { if (room.passwordHash) {
if (!password || !(await bcrypt.compare(password, room.passwordHash))) { if (!password || !(await bcrypt.compare(password, room.passwordHash))) {
recordAuthFailure(ip, roomId); recordAuthFailure(ip, roomId);
log('AUTH', `Invalid password from ${ip} for room ${roomId.substring(0, 3)}***`);
socket.emit(EVENTS.ERROR, { message: "Invalid password" }); socket.emit(EVENTS.ERROR, { message: "Invalid password" });
return; return;
} }
} }
if (room.peers.size >= MAX_PEERS_PER_ROOM) { if (room.peers.size >= MAX_PEERS_PER_ROOM) {
log('ROOM', `Room full (${room.peers.size}/${MAX_PEERS_PER_ROOM}): ${roomId.substring(0, 3)}***`);
socket.emit(EVENTS.ERROR, { message: "Room full" }); socket.emit(EVENTS.ERROR, { message: "Room full" });
return; return;
} }