Added host support

Author: TwoTenPvP

MLAPI/MonoBehaviours/Core/NetworkedBehaviour.cs

@@ -82,12 +82,14 @@ private void OnDestroy()
 
         public void SendToServer(string messageType, string channelName, byte[] data)
         {
-            if(isServer)
+            if (isServer)
             {
-                Debug.LogWarning("MLAPI: Sending messages from server to server is not yet supported");
-                return;
+                NetworkingManager.singleton.InvokeMessageHandlers(messageType, data, -1);
+            }
+            else
+            {
+                NetworkingManager.singleton.Send(NetworkingManager.singleton.serverClientId, messageType, channelName, data);
             }
-            NetworkingManager.singleton.Send(NetworkingManager.singleton.serverClientId, messageType, channelName, data);
         }
 
         public void SendToLocalClient(string messageType, string channelName, byte[] data)

MLAPI/MonoBehaviours/Core/NetworkingManager.cs

@@ -139,6 +139,17 @@ internal static void OnDestroyObject(uint networkId)
             singleton.releasedNetworkObjectIds.Push(networkId);
         }
 
+        internal void InvokeMessageHandlers(string messageType, byte[] data, int clientId)
+        {
+            if(!messageTypes.ContainsKey(messageType) || !messageCallbacks.ContainsKey(messageTypes[messageType]))
+                return;
+
+            foreach (KeyValuePair<int, Action<int, byte[]>> pair in messageCallbacks[messageTypes[messageType]])
+            {
+                pair.Value(clientId, data);
+            }
+        }
+
         internal int AddIncomingMessageHandler(string name, Action<int, byte[]> action)
         {
             if(messageTypes.ContainsKey(name))
@@ -566,6 +577,17 @@ private void HandleIncomingData(int connectonId, byte[] data)
 
         internal void Send(int clientId, string messageType, string channelName, byte[] data)
         {
+            if(isHost && clientId == -1)
+            {
+                //Host trying to send data to it's own client
+                InvokeMessageHandlers(messageType, data, clientId);
+                return;
+            }
+            else if(clientId == -1)
+            {
+                //Client trying to send data to host
+                clientId = serverClientId;
+            }
             using (MemoryStream stream = new MemoryStream())
             {
                 using (BinaryWriter writer = new BinaryWriter(stream))
@@ -597,7 +619,18 @@ internal void Send(int[] clientIds, string messageType, string channelName, byte
                 int channel = channels[channelName];
                 for (int i = 0; i < clientIds.Length; i++)
                 {
-                    NetworkTransport.Send(hostId, clientIds[i], channel, dataToSend, size, out error);
+                    int clientId = clientIds[i];
+                    if (isHost && clientId == -1)
+                    {
+                        InvokeMessageHandlers(messageType, data, clientId);
+                        continue;
+                    }
+                    else if (clientId == -1)
+                    {
+                        //Client trying to send data to host
+                        clientId = serverClientId;
+                    }
+                    NetworkTransport.Send(hostId, clientId, channel, dataToSend, size, out error);
                 }
             }
         }
@@ -618,7 +651,18 @@ internal void Send(List<int> clientIds, string messageType, string channelName,
                 int channel = channels[channelName];
                 for (int i = 0; i < clientIds.Count; i++)
                 {
-                    NetworkTransport.Send(hostId, clientIds[i], channel, dataToSend, size, out error);
+                    int clientId = clientIds[i];
+                    if (isHost && clientId == -1)
+                    {
+                        InvokeMessageHandlers(messageType, data, clientId);
+                        continue;
+                    }
+                    else if (clientId == -1)
+                    {
+                        //Client trying to send data to host
+                        clientId = serverClientId;
+                    }
+                    NetworkTransport.Send(hostId, clientId, channel, dataToSend, size, out error);
                 }
             }
         }
@@ -639,7 +683,19 @@ internal void Send(string messageType, string channelName, byte[] data)
                 int channel = channels[channelName];
                 foreach (KeyValuePair<int, NetworkedClient> pair in connectedClients)
                 {
-                    NetworkTransport.Send(hostId, pair.Key, channel, dataToSend, size, out error);
+                    int clientId = pair.Key;
+                    if(isHost && pair.Key == -1)
+                    {
+                        InvokeMessageHandlers(messageType, data, pair.Key);
+                        continue;
+                    }
+                    else if (clientId == -1)
+                    {
+                        //Client trying to send data to host
+                        clientId = serverClientId;
+                    }
+                    NetworkTransport.Send(hostId, clientId, channel, dataToSend, size, out error);
+                    
                 }
             }
         }
@@ -662,7 +718,18 @@ internal void Send(string messageType, string channelName, byte[] data, int clie
                 {
                     if (pair.Key == clientIdToIgnore)
                         continue;
-                    NetworkTransport.Send(hostId, pair.Key, channel, dataToSend, size, out error);
+                    int clientId = pair.Key;
+                    if (isHost && pair.Key == -1)
+                    {
+                        InvokeMessageHandlers(messageType, data, clientId);
+                        continue;
+                    }
+                    else if (clientId == -1)
+                    {
+                        //Client trying to send data to host
+                        clientId = serverClientId;
+                    }
+                    NetworkTransport.Send(hostId, clientId, channel, dataToSend, size, out error);
                 }
             }
         }

README.md

@@ -20,6 +20,7 @@ It's licenced under the MIT licence :D
 * Serializer (both for the library to speed up and to allow structs to be sent easily)
 * SyncVars (allow variables to automatically be synced to new clients and current clients when it's changed)
 * Message compression
+* Host support (Client hosts the server) (done)
 
 That's all I can think of right now. But there is more to come, especially if people show intrest in the project.