iampeter/pixelplanet
1
Fork 0
forked from ppfun/pixelplanet
Code Pull Requests Activity

fix APISocketServer chat broadcast muted check

Browse Source 
add banner.png
This commit is contained in:
HF 2022-10-19 00:38:25 +02:00
parent 9a44b3a0cc
commit 7192f31549
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

BIN
promotion/banner.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 245 KiB

5
src/socket/APISocketServer.js
View File

@ -11,12 +11,13 @@ import WebSocket from 'ws';
import socketEvents from './socketEvents'; import socketEvents from './socketEvents';
import { dehydrateOnlineCounter } from './packets/server'; import { dehydrateOnlineCounter } from './packets/server';
import chatProvider, { ChatProvider } from '../core/ChatProvider'; import chatProvider from '../core/ChatProvider';
import { RegUser } from '../data/sql'; import { RegUser } from '../data/sql';
import { getIPFromRequest } from '../utils/ip'; import { getIPFromRequest } from '../utils/ip';
import { setPixelByCoords } from '../core/setPixel'; import { setPixelByCoords } from '../core/setPixel';
import logger from '../core/logger'; import logger from '../core/logger';
import { APISOCKET_KEY } from '../core/config'; import { APISOCKET_KEY } from '../core/config';
import { checkIfMuted } from '../data/redis/chat';
class APISocketServer { class APISocketServer {
@ -243,7 +244,7 @@ class APISocketServer {
/* /*
* don't send if muted * don't send if muted
*/ */
const mutedTtl = await ChatProvider.checkIfMuted(uid); const mutedTtl = await checkIfMuted(uid);
if (mutedTtl !== -2) { if (mutedTtl !== -2) {
return; return;
} }

2
src/socket/SocketServer.js
View File

@ -481,7 +481,7 @@ class SocketServer {
} }
} catch (err) { } catch (err) {
// eslint-disable-next-line max-len // eslint-disable-next-line max-len
logger.error(`Got invalid ws text message ${text}, with error: ${err.message}`); logger.error(`Got invalid ws text message ${text} from ${ws.user.ip}, with error: ${err.message}`);
} }
} }