fix static methodes of ChatProvider

src/core/ChatProvider.js

@@ -94,7 +94,7 @@ export class ChatProvider {
       },
       raw: true,
     });
-    [this.infoUserId] = infoUser;
+    this.infoUserId = infoUser[0].id;
     name = EVENT_USER_NAME;
     const eventUser = await RegUser.findOrCreate({
       attributes: [
@@ -108,7 +108,7 @@ export class ChatProvider {
       },
       raw: true,
     });
-    [this.eventUserId] = eventUser;
+    this.eventUserId = eventUser[0].id;
   }
 
   userHasChannelAccess(user, cid, write = false) {
@@ -173,7 +173,7 @@ export class ChatProvider {
       const filter = this.filters[i];
       const count = (message.match(filter.regexp) || []).length;
       if (count >= filter.matches) {
-        ChatProvider.mute(name, channelId, 30);
+        this.mute(name, channelId, 30);
         return 'Ow no! Spam protection decided to mute you';
       }
     }
@@ -200,19 +200,19 @@ export class ChatProvider {
       if (cmd === 'mute') {
         const timeMin = Number(args.slice(-1));
         if (Number.isNaN(timeMin)) {
-          return ChatProvider.mute(args.join(' '), channelId);
+          return this.mute(args.join(' '), channelId);
         }
-        return ChatProvider.mute(
+        return this.mute(
           args.slice(0, -1).join(' '),
           channelId,
           timeMin,
         );
       } if (cmd === 'unmute') {
-        return ChatProvider.unmute(args.join(' '), channelId);
+        return this.unmute(args.join(' '), channelId);
       } if (cmd === 'mutec' && args[0]) {
         const cc = args[0].toLowerCase();
         this.mutedCountries.push(cc);
-        webSockets.broadcastChatMessage(
+        this.broadcastChatMessage(
           'info',
           `Country ${cc} has been muted`,
           channelId,
@@ -225,7 +225,7 @@ export class ChatProvider {
           return `Country ${cc} is not muted`;
         }
         this.mutedCountries = this.mutedCountries.filter((c) => c !== cc);
-        webSockets.broadcastChatMessage(
+        this.broadcastChatMessage(
           'info',
           `Country ${cc} has been unmuted`,
           channelId,
@@ -243,14 +243,7 @@ export class ChatProvider {
       return 'Your country is temporary muted from chat';
     }
 
-    this.chatMessageBuffer.addMessage(
+    this.broadcastChatMessage(
-      name,
-      message,
-      channelId,
-      id,
-      displayCountry,
-    );
-    webSockets.broadcastChatMessage(
       name,
       message,
       channelId,
@@ -288,9 +281,9 @@ export class ChatProvider {
     );
   }
 
-  static automute(name, channelId) {
+  automute(name, channelId) {
-    ChatProvider.mute(name, channelId, 60);
+    this.mute(name, channelId, 60);
-    webSockets.broadcastChatMessage(
+    this.broadcastChatMessage(
       'info',
       `${name} has been muted for spam for 60min`,
       channelId,
@@ -304,7 +297,7 @@ export class ChatProvider {
     return ttl;
   }
 
-  static async mute(plainName, channelId, timeMin = null) {
+  async mute(plainName, channelId, timeMin = null) {
     const name = (plainName.startsWith('@')) ? plainName.substr(1) : plainName;
     const id = await User.name2Id(name);
     if (!id) {
@@ -315,7 +308,7 @@ export class ChatProvider {
       const ttl = timeMin * 60;
       await redis.setAsync(key, '', 'EX', ttl);
       if (timeMin !== 600 && timeMin !== 60) {
-        webSockets.broadcastChatMessage(
+        this.broadcastChatMessage(
           'info',
           `${name} has been muted for ${timeMin}min`,
           channelId,
@@ -324,7 +317,7 @@ export class ChatProvider {
       }
     } else {
       await redis.setAsync(key, '');
-      webSockets.broadcastChatMessage(
+      this.broadcastChatMessage(
         'info',
         `${name} has been muted forever`,
         channelId,
@@ -335,7 +328,7 @@ export class ChatProvider {
     return null;
   }
 
-  static async unmute(plainName, channelId) {
+  async unmute(plainName, channelId) {
     const name = (plainName.startsWith('@')) ? plainName.substr(1) : plainName;
     const id = await User.name2Id(name);
     if (!id) {
@@ -346,7 +339,7 @@ export class ChatProvider {
     if (delKeys !== 1) {
       return `User ${name} is not muted`;
     }
-    webSockets.broadcastChatMessage(
+    this.broadcastChatMessage(
       'info',
       `${name} has been unmuted`,
       channelId,

src/socket/SocketServer.js

@@ -19,7 +19,7 @@ import DeRegisterMultipleChunks from './packets/DeRegisterMultipleChunks';
 import ChangedMe from './packets/ChangedMe';
 import OnlineCounter from './packets/OnlineCounter';
 
-import chatProvider, { ChatProvider } from '../core/ChatProvider';
+import chatProvider from '../core/ChatProvider';
 import authenticateClient from './verifyClient';
 import WebSocketEvents from './WebSocketEvents';
 import webSockets from './websockets';
@@ -301,7 +301,7 @@ class SocketServer extends WebSocketEvents {
             ws.message_repeat += 1;
             if (ws.message_repeat >= 4) {
               logger.info(`User ${ws.name} got automuted`);
-              ChatProvider.automute(ws.name, channelId);
+              chatProvider.automute(ws.name, channelId);
               ws.message_repeat = 0;
             }
           } else {