feat: add emotes support

client/src/emote.js

@@ -2,6 +2,7 @@ import $ from "jquery";
 import { GameConfig } from "../../shared/gameConfig";
 import * as PIXI from "pixi.js";
 import { coldet } from "../../shared/utils/coldet";
+import { util } from "../../shared/utils/util";
 import { v2 } from "../../shared/utils/v2";
 import { math } from "../../shared/utils/math";
 import { device } from "./device";

client/src/game.js

@@ -97,6 +97,8 @@ export class Game {
                     joinMessage.proxy = false; //* !/.*surviv\.io$/.test(window.location.hostname);
                     joinMessage.otherProxy = false; //* !proxy.authLocation();
                     joinMessage.bot = false;
+                    joinMessage.emotes = _this.config.get("loadout").emotes;
+
                     _this.sendMessage(net.MsgType.Join, joinMessage, 8192);
                 };
                 this.ws.onmessage = function(e) {

server/src/game.ts

@@ -14,7 +14,21 @@ import { GameConfig } from "../../shared/gameConfig";
 import net from "../../shared/net";
 import { type Explosion } from "./objects/explosion";
 import { type Msg } from "../../shared/netTypings";
-
+import { EmotesDefs } from "../../shared/defs/gameObjects/emoteDefs";
+
+export class Emote {
+    playerId: number;
+    position: Vec2;
+    type: string;
+    isPing: boolean;
+
+    constructor(playerId: number, position: Vec2, type: string, isPing: boolean) {
+        this.playerId = playerId;
+        this.position = position;
+        this.type = type;
+        this.isPing = isPing;
+    }
+}
 export class Game {
     stopped = false;
     allowJoin = true;
@@ -68,6 +82,8 @@ export class Game {
 
     logger: Logger;
 
+    emotes = new Set<Emote>();
+
     constructor(id: number, config: ConfigType) {
         this.id = id;
         this.logger = new Logger(`Game #${this.id}`);
@@ -107,8 +123,17 @@ export class Game {
         // this.serializationCache.update(this);
 
         for (const player of this.connectedPlayers) {
+            if (this.emotes.size) {
+                for (const emote of this.emotes) {
+                    if (emote.playerId === player.id || !emote.isPing) {
+                        player.emotes.add(emote);
+                    }
+                }
+            }
+
             player.sendMsgs();
         }
+        if (this.emotes.size) this.emotes = new Set<Emote>();
 
         //
         // reset stuff
@@ -217,6 +242,20 @@ export class Game {
             player.name = name;
             player.joinedTime = Date.now();
 
+            const emotes = joinMsg.emotes;
+            for (let i = 0; i < emotes.length; i++) {
+                const emote = emotes[i];
+                if ((i < 4 && emote === "")) {
+                    player.loadout.emotes.push("emote_logoswine");
+                    continue;
+                }
+
+                if (EmotesDefs[emote as keyof typeof EmotesDefs] === undefined &&
+                    emote != "") {
+                    player.loadout.emotes.push("emote_logoswine");
+                } else player.loadout.emotes.push(emote);
+            }
+
             this.newPlayers.push(player);
             this.grid.addObject(player);
             this.connectedPlayers.add(player);
@@ -225,6 +264,12 @@ export class Game {
             this.aliveCountDirty = true;
             break;
         }
+        case net.MsgType.Emote: {
+            const emoteMsg = new net.EmoteMsg();
+            emoteMsg.deserialize(stream);
+
+            this.emotes.add(new Emote(player.id, emoteMsg.pos, emoteMsg.type, emoteMsg.isPing));
+        }
         }
     }
 

server/src/objects/player.ts

@@ -1,5 +1,5 @@
 import { type WebSocket } from "uWebSockets.js";
-import { type Game } from "../game";
+import { type Emote, type Game } from "../game";
 import { GameConfig } from "../../../shared/gameConfig";
 import { collider } from "../../../shared/utils/collider";
 import { type Vec2, v2 } from "../../../shared/utils/v2";
@@ -201,9 +201,11 @@ export class Player extends BaseGameObject {
     loadout = {
         heal: "heal_basic",
         boost: "boost_basic",
-        emotes: [...GameConfig.defaultEmoteLoadout]
+        emotes: [] as string[]
     };
 
+    emotes = new Set<Emote>();
+
     damageTaken = 0;
     damageDealt = 0;
     joinedTime = 0;
@@ -418,6 +420,11 @@ export class Player extends BaseGameObject {
         updateMsg.activePlayerData = this;
         updateMsg.playerInfos = this._firstUpdate ? [...this.game.players] : this.game.newPlayers;
 
+        for (const emote of this.emotes) {
+            updateMsg.emotes.push(emote);
+        }
+
+        if (this.emotes.size) this.emotes = new Set();
         let newBullets = [];
         const extendedRadius = 1.1 * radius;
         const radiusSquared = extendedRadius * extendedRadius;

shared/net.js

@@ -888,6 +888,10 @@ class JoinMsg {
          * @type {boolean}
          */
         this.bot = false;
+        /**
+         * @type {string[]}
+         */
+        this.emotes = [];
     }
 
     /**
@@ -904,7 +908,13 @@ class JoinMsg {
         this.proxy = s.readBoolean();
         this.otherProxy = s.readBoolean();
         this.bot = s.readBoolean();
-        s.readAlignToNextByte();
+        this.emotes = [];
+        const count = s.readUint8();
+
+        for (let i = 0; i < count; i++) {
+            const emote = s.readGameType();
+            this.emotes.push(emote);
+        }
     }
 
     /**
@@ -921,6 +931,11 @@ class JoinMsg {
         s.writeBoolean(this.proxy);
         s.writeBoolean(this.otherProxy);
         s.writeBoolean(this.bot);
+
+        s.writeUint8(this.emotes.length);
+        for (const emote of this.emotes) {
+            s.writeGameType(emote);
+        }
         s.writeAlignToNextByte();
     }
 }
@@ -1140,7 +1155,7 @@ class EmoteMsg {
         this.pos = s.readVec(0, 0, 1024, 1024, 16);
         this.type = s.readGameType();
         this.isPing = s.readBoolean();
-        s.readBits(6);
+        s.readBits(5);
     }
 }
 
@@ -1163,7 +1178,6 @@ class JoinedMsg {
         s.writeUint8(this.teamMode);
         s.writeUint16(this.playerId);
         s.writeBoolean(this.started);
-
         s.writeUint8(this.emotes.length);
         for (const emote of this.emotes) {
             s.writeGameType(emote);
@@ -1177,7 +1191,8 @@ class JoinedMsg {
         this.teamMode = s.readUint8();
         this.playerId = s.readUint16();
         this.started = s.readBoolean();
-        for (let count = s.readUint8(), i = 0; i < count; i++) {
+        const count = s.readUint8();
+        for (let i = 0; i < count; i++) {
             const emote = s.readGameType();
             this.emotes.push(emote);
         }
@@ -1612,6 +1627,9 @@ class UpdateMsg {
         this.groupStatusDirty = false;
         this.bullets = [];
         this.explosions = [];
+        /**
+        * @type {Emote[]}
+        */
         this.emotes = [];
         this.planes = [];
         this.airstrikeZones = [];