colyseus/colyseus-haxe#40

Author: endel

Assets/Plugins/Colyseus/Serializer/Schema/Schema.cs

@@ -80,9 +80,8 @@ public class DataChange
 	public delegate void KeyValueEventHandler<T, K>(T value, K key);
 	public delegate void OnRemoveEventHandler();
 
-	public interface ISchemaCollection
+	public interface ISchemaCollection : IRef
 	{
-		void MoveEventHandlers(ISchemaCollection previousInstance);
 		void InvokeOnAdd(object item, object index);
 		void InvokeOnChange(object item, object index);
 		void InvokeOnRemove(object item, object index);
@@ -115,6 +114,8 @@ public interface IRef
 
 		object GetByIndex(int index);
 		void DeleteByIndex(int index);
+
+		void MoveEventHandlers(IRef previousInstance);
 	}
 
 	public class Schema : IRef
@@ -176,6 +177,21 @@ public object this[string propertyName]
 			return fieldChildTypes;
 		}
 
+		public void MoveEventHandlers(IRef previousInstance)
+		{
+			OnChange = ((Schema)previousInstance).OnChange;
+			OnRemove = ((Schema)previousInstance).OnRemove;
+
+			foreach (var item in ((Schema)previousInstance).fieldsByIndex)
+			{
+				var child = GetByIndex(item.Key);
+				if (child is IRef)
+				{
+					((IRef)child).MoveEventHandlers((IRef)previousInstance.GetByIndex(item.Key));
+				}
+			}
+		}
+
 		public void Decode(byte[] bytes, Iterator it = null, ReferenceTracker refs = null)
 		{
 			var decode = Decoder.GetInstance();
@@ -349,8 +365,7 @@ public void Decode(byte[] bytes, Iterator it = null, ReferenceTracker refs = nul
 
 							if (previousValue != null)
 							{
-								((Schema)value).OnChange = ((Schema)previousValue).OnChange;
-								((Schema)value).OnRemove = ((Schema)previousValue).OnRemove;
+								((Schema)value).MoveEventHandlers((Schema)previousValue);
 
 								if (
 									((IRef)previousValue).__refId > 0 &&

Assets/Plugins/Colyseus/Serializer/Schema/Types/ArraySchema.cs

@@ -4,7 +4,7 @@
 
 namespace Colyseus.Schema
 {
-	public class ArraySchema<T> : ISchemaCollection, IRef
+	public class ArraySchema<T> : ISchemaCollection
 	{
 		public Dictionary<int, T> Items;
 		public event KeyValueEventHandler<T, int> OnAdd;
@@ -159,7 +159,7 @@ public void TriggerAll()
 			}
 		}
 
-		public void MoveEventHandlers(ISchemaCollection previousInstance)
+		public void MoveEventHandlers(IRef previousInstance)
 		{
 			OnAdd = ((ArraySchema<T>)previousInstance).OnAdd;
 			OnChange = ((ArraySchema<T>)previousInstance).OnChange;

Assets/Plugins/Colyseus/Serializer/Schema/Types/MapSchema.cs

@@ -5,7 +5,7 @@
 
 namespace Colyseus.Schema
 {
-	public class MapSchema<T> : ISchemaCollection, IRef
+	public class MapSchema<T> : ISchemaCollection
 	{
 		public OrderedDictionary Items = new OrderedDictionary();
 		public event KeyValueEventHandler<T, string> OnAdd;
@@ -225,7 +225,7 @@ public void TriggerAll()
 			}
 		}
 
-		public void MoveEventHandlers(ISchemaCollection previousInstance)
+		public void MoveEventHandlers(IRef previousInstance)
 		{
 			OnAdd = ((MapSchema<T>)previousInstance).OnAdd;
 			OnChange = ((MapSchema<T>)previousInstance).OnChange;

Server/package.json

@@ -14,7 +14,7 @@
   },
   "dependencies": {
     "@colyseus/social": "^0.10.0",
-    "colyseus": "^0.14.0",
+    "colyseus": "^0.14.1",
     "cors": "^2.8.5",
     "express": "^4.13.3",
     "express-jwt": "^5.3.1",