helper methods added + bug fixes + optimization

Author: AncientEntity

Assets/EntityNetworkingSystems/Scripts/NetBackbone/NetClient.cs

@@ -155,6 +155,20 @@ public void SendPacket(Packet packet)//, bool queuedPacket = false)
 
             if(NetTools.isSingleplayer)
             {
+                if(packet.packetSendType == Packet.sendType.proximity)
+                {
+                    if(NetServer.serverInstance.connections.Count > 0)
+                    {
+                        if(Vector3.Distance(packet.packetPosition.ToVec3(), NetServer.serverInstance.connections[0].proximityPosition) > NetServer.serverInstance.connections[0].loadProximity)
+                        {
+                            return;
+                        }
+                    }
+                }
+                //if(packet.packetType == Packet.pType.netVarEdit && ((NetworkFieldPacket)packet.GetPacketData()).immediateOnSelf)
+                //{
+                //    return; //basically would be a double sync. No reason to.
+                //}
                 UnityPacketHandler.instance.QueuePacket(packet);
                 return;
             }

Assets/EntityNetworkingSystems/Scripts/NetBackbone/NetServer.cs

@@ -27,10 +27,10 @@ public class NetServer
         public string modDir = "spacewar";
         public string gameDesc = "spacewar";
         public string mapName = "world1";
-
+        [Space]
+        public List<NetworkPlayer> connections = new List<NetworkPlayer>();
 
         TcpListener server = null;
-        List<NetworkPlayer> connections = new List<NetworkPlayer>();
         List<Thread> connThreads = new List<Thread>();
         Thread connectionHandler = null;
         Thread packetSendHandler = null;
@@ -199,7 +199,7 @@ public void ConnectionHandler()
                 Thread connThread = new Thread(() => ClientHandler(netClient));
                 connThread.Start();
 
-                //onPlayerConnect.Invoke(netClient);
+                NetTools.onPlayerJoin.Invoke(netClient);
             }
             Debug.Log("NetServer.ConnectionHandler() thread has successfully finished.");
         }
@@ -287,7 +287,7 @@ public void ClientHandler(NetworkPlayer client)
                 }
 
                 //Send whatever remains in it otherwise 99 or less packets will be lost.
-                Debug.Log(tempPackets.Count);
+                //Debug.Log(tempPackets.Count);
                 Packet lastMulti = new Packet(Packet.pType.multiPacket, Packet.sendType.nonbuffered, new PacketListPacket(tempPackets));
                 lastMulti.sendToAll = false;
                 SendPacket(client, lastMulti);
@@ -409,6 +409,20 @@ public void SendPacket(NetworkPlayer player, Packet packet)//, bool queuedPacket
             //    queuedSendingPackets.Add(packet, player);
             //    return;
             //}
+
+            //if(packet.packetType == Packet.pType.netVarEdit && player.clientID == NetTools.clientID)
+            //{
+            //    return; //No need to double sync it.
+            //}
+
+            if (packet.packetSendType == Packet.sendType.proximity)
+            {
+                if(Vector3.Distance(player.proximityPosition,packet.packetPosition.ToVec3()) >= player.loadProximity)
+                {
+                    return;
+                }
+            }
+
             if (NetTools.isSingleplayer)
             {
                 UnityPacketHandler.instance.QueuePacket(packet);
@@ -511,16 +525,29 @@ byte[] RecieveSizeSpecificData(int byteCountToGet, NetworkStream netStream)
         //    return message;
         //}
 
+        public NetworkPlayer GetPlayerByID(int id)
+        {
+            foreach(NetworkPlayer player in connections)
+            {
+                if(player.clientID == id)
+                {
+                    return player;
+                }
+            }
+            return null;
+        }
+
 
     }
 
+    [System.Serializable]
     public class NetworkPlayer
     {
         public int clientID = -1;
         public TcpClient tcpClient;
         public NetworkStream netStream;
         public Vector3 proximityPosition = Vector3.zero;
-        public float loadProximity = 10f;
+        public float loadProximity = 15f;
         public Thread threadHandlingClient;
 
         public NetworkPlayer(TcpClient client)

Assets/EntityNetworkingSystems/Scripts/NetBackbone/NetTools.cs

@@ -15,6 +15,7 @@ public class NetTools : MonoBehaviour
         public static bool isClient = false;
         public static bool isSingleplayer = false;
 
+        public static PlayerJoinEvent onPlayerJoin = new PlayerJoinEvent();
         public static UnityEvent onJoinServer = new UnityEvent(); //Gets ran when the login packet finishes :D
         public static UnityEvent onBufferedCompletion = new UnityEvent(); //Gets ran when the buffered packets complete.
 
@@ -87,10 +88,7 @@ public static GameObject NetInstantiate(int prefabDomain, int prefabID, Vector3
             nObj.sharedObject = gOID.isShared;
 
             nObj.Initialize();
-            if (NetTools.isServer)
-            {
-                nObj.DoRpcFieldInitialization();
-            }
+            nObj.DoRpcFieldInitialization();
             if (nObj.onNetworkStart != null)
             {
                 nObj.onNetworkStart.Invoke();
@@ -197,4 +195,9 @@ public static bool IsMultiplayerGame()
 
     }
 
+    public class PlayerJoinEvent : UnityEvent<NetworkPlayer>
+    {
+
+    }
 }
+