schema serializer ported to csharp/unity3d

Author: endel

Assets/ColyseusClient.cs

@@ -5,6 +5,7 @@
 using System.Collections.Generic;
 using System;
 using Colyseus;
+using Colyseus.Schema;
 
 using GameDevWare.Serialization;
 
@@ -18,10 +19,9 @@ public class ColyseusClient : MonoBehaviour {
 	public string roomName = "demo";
 
 	protected Client client;
-	protected Room room;
+	protected Room<State> room;
 
-	// map of players
-	protected Dictionary<string, GameObject> players = new Dictionary<string, GameObject>();
+	protected IndexedDictionary<Player, GameObject> players = new IndexedDictionary<Player, GameObject>();
 
 	// Use this for initialization
 	IEnumerator Start () {
@@ -68,7 +68,7 @@ void ConnectToServer ()
 
 	void JoinRoom ()
 	{
-		room = client.Join(roomName, new Dictionary<string, object>()
+		room = client.Join<State>(roomName, new Dictionary<string, object>()
 		{
 			{ "create", true }
 		});
@@ -85,10 +85,9 @@ void JoinRoom ()
 			Debug.Log("Joined room successfully.");
 			m_SessionIdText.text = "sessionId: " + room.SessionId;
 
-			room.Listen("players/:id", OnPlayerChange, true);
-			room.Listen("players/:id/:axis", OnPlayerMove);
-			room.Listen("messages/:number", OnMessageAdded);
-			room.Listen(OnChangeFallback);
+			room.State.players.OnAdd += OnPlayerAdd;
+			room.State.players.OnRemove += OnPlayerRemove;
+			room.State.players.OnChange += OnPlayerMove;
 
 			PlayerPrefs.SetString("sessionId", room.SessionId);
 			PlayerPrefs.Save();
@@ -107,7 +106,7 @@ void ReJoinRoom ()
 			return;
 		}
 
-		room = client.ReJoin(roomName, sessionId);
+		room = client.ReJoin<State>(roomName, sessionId);
 
 		room.OnReadyToConnect += (sender, e) => {
 			Debug.Log("Ready to connect to room!");
@@ -119,10 +118,7 @@ void ReJoinRoom ()
 			m_SessionIdText.text = "sessionId: " + room.SessionId;
 
 			// only register listeners after OnJoin.
-			room.Listen("players/:id", OnPlayerChange, true);
-			room.Listen("players/:id/:axis", OnPlayerMove);
-			room.Listen("messages/:number", OnMessageAdded);
-			room.Listen(OnChangeFallback);
+			// TODO: ????
 		};
 
 		room.OnStateChange += OnStateChangeHandler;
@@ -134,7 +130,7 @@ void LeaveRoom()
 		room.Leave(false);
 
 		// Destroy player entities
-		foreach (KeyValuePair<string, GameObject> entry in players)
+		foreach (KeyValuePair<Player, GameObject> entry in players)
 		{
 			Destroy(entry.Value);
 		}
@@ -160,71 +156,42 @@ void OnMessage (object sender, MessageEventArgs e)
 		Debug.Log(message);
 	}
 
-	void OnStateChangeHandler (object sender, StateChangeEventArgs e)
+	void OnStateChangeHandler (object sender, StateChangeEventArgs<State> e)
 	{
 		// Setup room first state
 		Debug.Log("State has been updated!");
 	}
 
-	void OnPlayerChange (DataChange change)
+	void OnPlayerAdd(object sender, KeyValueEventArgs<Player, string> item)
 	{
-		Debug.Log ("OnPlayerChange");
-		Debug.Log (change.operation);
-		Debug.Log (change.path["id"]);
-//		Debug.Log (change.value);
+		GameObject cube = GameObject.CreatePrimitive(PrimitiveType.Cube);
 
-		if (change.operation == "add") {
-			IndexedDictionary<string, object> value = (IndexedDictionary<string, object>) change.value;
+		Debug.Log("Player add! x => " + item.Value.x + ", y => " + item.Value.y);
 
-			GameObject cube = GameObject.CreatePrimitive (PrimitiveType.Cube);
+		cube.transform.position = new Vector3(item.Value.x, item.Value.y, 0);
 
-			cube.transform.position = new Vector3 (Convert.ToSingle(value ["x"]), Convert.ToSingle(value ["y"]), 0);
-
-			// add "player" to map of players by id.
-			players.Add (change.path ["id"], cube);
-
-		} else if (change.operation == "remove") {
-			// remove player from scene
-			GameObject cube;
-			players.TryGetValue (change.path ["id"], out cube);
-			Destroy (cube);
-
-			players.Remove (change.path ["id"]);
-		}
+		// add "player" to map of players
+		players.Add(item.Value, cube);
 	}
 
-	void OnPlayerMove (DataChange change)
+	void OnPlayerRemove(object sender, KeyValueEventArgs<Player, string> item)
 	{
-//		Debug.Log ("OnPlayerMove");
-//		Debug.Log ("playerId: " + change.path["id"] + ", Axis: " + change.path["axis"]);
-//		Debug.Log (change.value);
-
 		GameObject cube;
-		players.TryGetValue (change.path ["id"], out cube);
+		players.TryGetValue(item.Value, out cube);
+		Destroy(cube);
 
-		cube.transform.Translate (new Vector3 (Convert.ToSingle(change.value), 0, 0));
+		players.Remove(item.Value);
 	}
 
-	void OnPlayerRemoved (DataChange change)
-	{
-//		Debug.Log ("OnPlayerRemoved");
-//		Debug.Log (change.path);
-//		Debug.Log (change.value);
-	}
 
-	void OnMessageAdded (DataChange change)
+	void OnPlayerMove (object sender, KeyValueEventArgs<Player, string> item)
 	{
-//		Debug.Log ("OnMessageAdded");
-//		Debug.Log (change.path["number"]);
-//		Debug.Log (change.value);
-	}
+		GameObject cube;
+		players.TryGetValue (item.Value, out cube);
 
-	void OnChangeFallback (PatchObject change)
-	{
-//		Debug.Log ("OnChangeFallback");
-//		Debug.Log (change.operation);
-//		Debug.Log (change.path);
-//		Debug.Log (change.value);
+		Debug.Log(item.Value.x);
+
+		cube.transform.Translate (new Vector3 (item.Value.x, item.Value.y, 0));
 	}
 
 	void OnApplicationQuit()