trigger Listen() callbacks on initial state. closes #31

Author: endel

Assets/Plugins/Colyseus/DeltaListener/Compare.cs

@@ -133,11 +133,29 @@ protected static void Generate(IndexedDictionary<string, object> mirror, Indexed
 					List<string> addPath = new List<string>(path);
 					addPath.Add((string) key);
 
+					var newVal = obj [key];
+					if (newVal != null) {
+						var newValType = newVal.GetType ();
+
+						// compare deeper additions
+						if (
+							!newValType.IsPrimitive && 
+							newValType != typeof(string)
+						) {
+							if (newVal is IDictionary) {
+								Generate(new IndexedDictionary<string, object>(), newVal as IndexedDictionary<string, object>, patches, addPath);
+
+							} else if (newVal is IList) {
+								Generate(new List<object>(), newVal as List<object>, patches, addPath);
+							}
+						}
+					}
+
 					patches.Add(new PatchObject
 					{
 						operation = "add",
 						path = addPath.ToArray(),
-						value = obj[key]
+						value = newVal
 					});
 				}
 			}

Assets/Tests/DeltaContainerTest.cs

@@ -190,6 +190,32 @@ public void ListenRemoveArray() {
 		Assert.AreEqual (3, listenCalls);
 	}
 
+	[Test]
+	public void ListenInitialState() {
+		var container = new DeltaContainer (new IndexedDictionary<string, object>());
+		var listenCalls = 0;
+
+		container.Listen ("players/:id/position/:attribute", (DataChange change) => {
+			listenCalls++;
+		});
+
+		container.Listen ("turn", (DataChange change) => {
+			listenCalls++;
+		});
+
+		container.Listen ("game/turn", (DataChange change) => {
+			listenCalls++;
+		});
+
+		container.Listen ("messages/:number", (DataChange change) => {
+			listenCalls++;
+		});
+
+		container.Set (GetRawData ());
+
+		Assert.AreEqual (9, listenCalls);
+	}
+
 	protected IndexedDictionary<string, object> GetRawData () {
 		var data = new IndexedDictionary<string, object> ();
 		var players = new IndexedDictionary<string, object> ();