adding serverside npc logic and clientside entity spawner connections

Author: coderDarren

MultiplayerDemo/Assets/Scenes/SampleScene.unity

@@ -267,6 +267,7 @@ MonoBehaviour:
   m_Name: 
   m_EditorClassIdentifier: 
   test: 1
+  testPlayer: {fileID: 1941412218}
 --- !u!114 &909546264
 MonoBehaviour:
   m_ObjectHideFlags: 0
@@ -666,7 +667,7 @@ MonoBehaviour:
         timestamp: 
         x: 0
         y: 1.1
-        z: 0
+        z: 50
       rot:
         timestamp: 
         x: 0

MultiplayerDemo/Assets/Scripts/Networking/Communications/NetworkMessages.cs

@@ -12,5 +12,7 @@ public class NetworkMessages {
         public static readonly string PLAYER_LEFT = "PLAYER_LEFT";
         public static readonly string PLAYER_JOINED = "PLAYER_JOINED";
         public static readonly string PLAYER_TRANSFORM_CHANGE = "PLAYER_TRANSFORM_CHANGE";
+        public static readonly string NPC_SPAWN = "NPC_SPAWN";
+        public static readonly string NPC_EXIT = "NPC_EXIT";
     }
 }

MultiplayerDemo/Assets/Scripts/Networking/Controllers/NetworkComponent.cs

@@ -19,5 +19,10 @@ public virtual void Initialize(NetworkManager _manager) {
         // These functions to be called for Unity Event Functions 'OnEnable' and 'OnDisable' respectively
         public virtual void Enable() {}
         public virtual void Disable() {}
+
+        protected void Log(string _msg) {
+            if (!debug) return;
+            Debug.Log("["+this.GetType()+"]: "+_msg);
+        }
     }
 }

MultiplayerDemo/Assets/Scripts/Networking/Controllers/NetworkEntityHandler.cs

@@ -1,21 +1,36 @@
 using System.Collections;
 using System.Collections.Generic;
 using UnityEngine;
+using PlayNet.Models;
 
 namespace PlayNet.Networking {
     public class NetworkEntityHandler : NetworkComponent
     {
+        private Hashtable m_NPCs;
+
         public override void Initialize(NetworkManager _m) {
             base.Initialize(_m);
-            
+            m_NPCs = new Hashtable();
         }
 
         public override void Enable() {
-
+            m_Manager.Listener.npcSpawnEvt.OnEvt += OnNPCSpawn;
+            m_Manager.Listener.npcExitEvt.OnEvt += OnNPCExit;
         }
 
         public override void Disable() {
+            m_Manager.Listener.npcSpawnEvt.OnEvt -= OnNPCSpawn;
+            m_Manager.Listener.npcExitEvt.OnEvt -= OnNPCExit;
+        }
+
+        private void OnNPCSpawn(NetworkNPCData _npc) {
+            if (m_NPCs.ContainsKey(_npc.id)) return; // npc was already spawned
+            Log("NPC spawned: "+_npc.id);
+        }
 
+        private void OnNPCExit(string _id) {
+            if (!m_NPCs.ContainsKey(_id)) return; // npc already doesnt exist
+            Log("NPC exited: "+_id);
         }
     }
 }

MultiplayerDemo/Assets/Scripts/Networking/Controllers/NetworkListener.cs

@@ -27,6 +27,10 @@ public class NetworkListener : NetworkComponent
         public NetworkEvent<NetworkPlayerData> playerSpawnEvt {get; private set;}
         public NetworkEvent<NetworkTransform> playerTransformEvt {get; private set;}
     #endregion
+    #region NPCs
+        public NetworkEvent<NetworkNPCData> npcSpawnEvt {get;private set;}
+        public NetworkEvent<string> npcExitEvt {get;private set;}
+    #endregion
     // Add more events here!
 #endregion
 
@@ -55,23 +59,33 @@ private void Build() {
             playerLeaveEvt = new NetworkEvent<NetworkPlayerData>("Player left.", debug);
             playerSpawnEvt = new NetworkEvent<NetworkPlayerData>("Player entered range.", debug);
             playerTransformEvt = new NetworkEvent<NetworkTransform>("Player transform changed.", debug);
+            // npc events
+            npcSpawnEvt = new NetworkEvent<NetworkNPCData>("NPC spawned", debug);
+            npcExitEvt = new NetworkEvent<string>("NPC exited range", debug);
         }
 
+        /*
+         * Subscribe to network events and broadcast to game managers
+         */
         private void Listen() {
             // server events
             m_Manager.Socket.On(NetworkMessages.CONNECT, OnNetworkConnected);
             m_Manager.Socket.On(NetworkMessages.DISCONNECT, OnNetworkDisconnected);
-            m_Manager.Socket.On(NetworkMessages.HANDSHAKE, handshakeEvt.HandleEvt);
+            m_Manager.Socket.On(NetworkMessages.HANDSHAKE, handshakeEvt.Broadcast);
 
-            m_Manager.Socket.On(NetworkMessages.INSTANCE, instanceDataEvt.HandleEvt);
-            m_Manager.Socket.On(NetworkMessages.CHAT, chatEvt.HandleEvt);
+            m_Manager.Socket.On(NetworkMessages.INSTANCE, instanceDataEvt.Broadcast);
+            m_Manager.Socket.On(NetworkMessages.CHAT, chatEvt.Broadcast);
 
             // player events
-            m_Manager.Socket.On(NetworkMessages.PLAYER_SPAWN, playerSpawnEvt.HandleEvt);
-            m_Manager.Socket.On(NetworkMessages.PLAYER_EXIT, playerExitEvt.HandleEvt);
-            m_Manager.Socket.On(NetworkMessages.PLAYER_JOINED, playerJoinEvt.HandleEvt);
-            m_Manager.Socket.On(NetworkMessages.PLAYER_LEFT, playerLeaveEvt.HandleEvt);
-            m_Manager.Socket.On(NetworkMessages.PLAYER_TRANSFORM_CHANGE, playerTransformEvt.HandleEvt);
+            m_Manager.Socket.On(NetworkMessages.PLAYER_SPAWN, playerSpawnEvt.Broadcast);
+            m_Manager.Socket.On(NetworkMessages.PLAYER_EXIT, playerExitEvt.Broadcast);
+            m_Manager.Socket.On(NetworkMessages.PLAYER_JOINED, playerJoinEvt.Broadcast);
+            m_Manager.Socket.On(NetworkMessages.PLAYER_LEFT, playerLeaveEvt.Broadcast);
+            m_Manager.Socket.On(NetworkMessages.PLAYER_TRANSFORM_CHANGE, playerTransformEvt.Broadcast);
+
+            // npc events
+            m_Manager.Socket.On(NetworkMessages.NPC_SPAWN, npcSpawnEvt.Broadcast);
+            m_Manager.Socket.On(NetworkMessages.NPC_EXIT, npcExitEvt.Broadcast);
         }
 
         private void OnNetworkConnected(SocketIOEvent _evt) {

MultiplayerDemo/Assets/Scripts/Networking/Models/NetworkEvent.cs

@@ -29,7 +29,7 @@ public NetworkEvent(string _evtLog, bool _debug) {
             }
         }
 
-        public void HandleEvt(SocketIOEvent _evt) {
+        public void Broadcast(SocketIOEvent _evt) {
             if (m_Invalid) return;
 
             string _msg = Regex.Unescape((string)_evt.data.ToDictionary()["message"]);

MultiplayerDemo/Assets/Scripts/Networking/Models/NetworkNPCData.cs

@@ -0,0 +1,54 @@
+namespace PlayNet.Models {
+    
+    public class NetworkNPCHitInfo : NetworkModel {
+        public string id;
+        public string npcName;
+        public string playerName;
+        public int dmg;
+        public bool crit;
+        public NetworkNPCHitInfo(string _id, string _npcName, int _dmg, bool _crit) {
+            id = _id;
+            npcName = _npcName;
+            dmg = _dmg;
+            crit = _crit;
+        }
+    }
+
+    public class NetworkNPCAttackData : NetworkModel {
+        public string id;
+        public string npcName;
+        public string playerName;
+    }
+
+    public class NetworkNPCDeathData : NetworkModel {
+        public string id;
+        public string name;
+        public string[] lootRights; // array of player names who can loot
+        public NetworkNPCXpAllottment[] xpAllottment;
+    }
+
+    public class NetworkNPCXpAllottment : NetworkModel {
+        public string playerName;
+        public int xp;
+    }
+
+    public class NetworkNPCData : NetworkModel {
+        public string id;
+        public string name;
+        public int level;
+        public int maxHealth;
+        public int health;
+        public int maxEnergy;
+        public int energy;
+        public float attackSpeed;
+        public float aggroRange;
+        public bool inAttackRange;
+        public bool inCombat;
+        public bool dead;
+        public NetworkTransform transform;
+
+        public NetworkNPCData() {
+            transform = new NetworkTransform();
+        }
+    }
+}

MultiplayerDemo/Assets/Scripts/Networking/Models/NetworkNPCData.cs.meta

@@ -0,0 +1,5 @@
+{
+  "dependencies": {
+    "crypto": "^1.0.1"
+  }
+}

node_modules/.package-lock.json

@@ -21,8 +21,8 @@ class Game {
 
         // use a variable to store all players connected to the game
         // Here we initialize the scene that should be loaded for this game server
-        // The scene object loads in mobs, waypoint graphs, and shop terminals
-        this._scene = new TestScene(this);
+        // The scene object loads in npcs, waypoint graphs, and shop terminals
+        this._scene = TestScene(this);
         this._players = [];
         this._npcs = this._scene.npcs;
 
@@ -71,7 +71,44 @@ class Game {
     }
 
     /*
-     * Emits a specific instance of nearby players and nearby mobs for each player..
+     * NPCs will constantly scan for nearby players
+     * Also used to determine the range where players can see other players
+     */
+    scanNearbyPlayers(_pos, _radius) {
+        return filter(this.__obj_data_map__(this._players), _player => {
+            const _dist = new Vector3(_pos).distanceTo(new Vector3(_player.transform.pos));
+            return _dist < _radius;
+        });
+    }
+
+    /*
+     * Mobs will constantly scan for nearby players
+     * Also used to determine the range where players can see other players
+     */
+    scanNearbyPlayerSockets(_pos, _radius) {
+        const _nearbyPlayers = filter(this._players, _player => {
+            const _dist = new Vector3(_pos).distanceTo(new Vector3(_player.transform.pos));
+            return _dist < _radius;
+        });
+        return map(_nearbyPlayers, _player => {
+            return _player.socket
+        });
+    }
+
+    getPlayer(_name) {
+        return find(this.__obj_data_map__(this._players), _player => {
+            return _player.name == _name;
+        });
+    }
+
+    getPlayerRaw(_name) {
+        return find(this._players, _player => {
+            return _player.data.name == _name;
+        });
+    }
+
+    /*
+     * Emits a specific instance of nearby players and nearby npcs for each player..
      * ..based on distance
      */
     __emit_tailored_instance__() {

node_modules/crypto/README.md

@@ -0,0 +1,5 @@
+const droid = require('./droid');
+
+module.exports = {
+    droid
+}

node_modules/crypto/package.json

@@ -0,0 +1,43 @@
+const crypto = require('crypto');
+const {Vector3} = require('../util/vector');
+
+const droid = function(_level, _pos, _rot, _nameOverride=null) {
+    const _id = crypto.randomBytes(5).toString('hex');
+    _rot.y = Math.random() * 360;
+    
+    return {
+        id: _id,
+        name: _nameOverride || 'Droid',
+        level: _level,
+        maxHealth: 40*_level,
+        health: 40*_level,
+        maxEnergy: 20*_level,
+        energy: 20*_level,
+        attackSpeed: 1,
+        rechargeSpeed: 1.5,
+        aggroRange: 8,
+        retreatRange: 10,
+        attackRange: 5,
+        inCombat: false,
+        inAttackRange: false,
+        respawnTime: 5, // in seconds
+        xpReward: 50*_level,
+        xpRewardVariance: 10*_level,
+        transform: {
+            pos: new Vector3(_pos).obj,
+            rot: new Vector3(_rot).obj
+        },
+        inCombat: false,
+        healDelta: 50,
+        runSpeed: 2,
+        lootTime: 120, // 2 minutes
+        minDamage: 0.01*_level,
+        maxDamage: 0.01*_level,
+        hitRate: 0.75,
+        // !! TODO
+        // Create mob actions initializer
+        actions: []
+    }
+}
+
+module.exports = droid;