Added localDB features, and reorganised the folder structure.

Author: Vincent Cantin

unity-project/Assets/example/TestLocalDB.cs

@@ -0,0 +1,99 @@
+using UnityEngine;
+using System.Collections;
+
+public class TestLocalDB : MonoBehaviour {
+
+	public string serverUrl = "ws://localhost:3000/websocket";
+	public bool logMessages;
+
+	private DdpConnection ddpConnection;
+	private LocalDB localDB;
+	private JsonObjectCollection friendCollection;
+
+	public void Start() {
+		ddpConnection = new DdpConnection(serverUrl);
+		ddpConnection.logMessages = logMessages;
+
+		ddpConnection.OnConnected += (DdpConnection connection) => {
+			Debug.Log("Connected.");
+		};
+
+		ddpConnection.OnDisconnected += (DdpConnection connection) => {
+			Debug.Log("Disconnected.");
+
+			StartCoroutine(CoroutineHelper.GetInstance().RunAfter(() => {
+				Debug.Log("Try to reconnect ...");
+				connection.Connect();
+			}, 2.0f));
+		};
+
+		ddpConnection.OnError += (DdpError error) => {
+			Debug.Log("Error: " + error.errorCode + " " + error.reason);
+		};
+
+		localDB = new LocalDB((db, collectionName) => {
+			return new JsonObjectCollection(db, collectionName);
+		}, ddpConnection);
+
+		friendCollection = (JsonObjectCollection) localDB.GetCollection("friends");
+		friendCollection.OnAdded += (id, fields) => {
+			Debug.Log("Added docId " + id);
+		};
+
+		friendCollection.OnRemoved += (id) => {
+			Debug.Log("Removed docId " + id);
+		};
+
+		friendCollection.OnChanged += (id, fields, cleared) => {
+			Debug.Log("Changed docId " + id +
+				" fields: " + fields +
+				" cleared:" + cleared);
+		};
+	}
+
+	private Subscription friendSub;
+
+	public void Update() {
+		if (Input.GetKeyDown(KeyCode.C)) {
+			Debug.Log("Connecting ...");
+			ddpConnection.Connect();
+		}
+
+		if (Input.GetKeyDown(KeyCode.V)) {
+			ddpConnection.Close();
+		}
+
+		if (Input.GetKeyDown(KeyCode.S)) {
+			friendSub = ddpConnection.Subscribe("friends");
+			friendSub.OnReady = (Subscription obj) => {
+				Debug.Log("Ready subscription: " + obj.id);
+			};
+		}
+
+		if (Input.GetKeyDown(KeyCode.U)) {
+			ddpConnection.Unsubscribe(friendSub);
+		}
+
+		if (Input.GetKeyDown(KeyCode.R)) {
+			ddpConnection.Call("friends.removeAll");
+		}
+
+		if (Input.GetKeyDown(KeyCode.F)) {
+			MethodCall methodCall = ddpConnection.Call("friends.create", JSONObject.CreateStringObject("Coco"));
+			methodCall.OnUpdated = (MethodCall obj) => {
+				Debug.Log("Updated, methodId=" + obj.id);
+			};
+			methodCall.OnResult = (MethodCall obj) => {
+				Debug.Log("Result = " + obj.result);
+			};
+		}
+
+		if (Input.GetKeyDown(KeyCode.D)) {
+			foreach (var entry in friendCollection.documents) {
+				Debug.Log(entry.Key + " " + entry.Value);
+			}
+		}
+
+	}
+
+}

unity-project/Assets/example/TestLocalDB.cs.meta

@@ -0,0 +1,214 @@
+%YAML 1.1
+%TAG !u! tag:unity3d.com,2011:
+--- !u!29 &1
+SceneSettings:
+  m_ObjectHideFlags: 0
+  m_PVSData: 
+  m_PVSObjectsArray: []
+  m_PVSPortalsArray: []
+  m_OcclusionBakeSettings:
+    smallestOccluder: 5
+    smallestHole: 0.25
+    backfaceThreshold: 100
+--- !u!104 &2
+RenderSettings:
+  m_ObjectHideFlags: 0
+  serializedVersion: 6
+  m_Fog: 0
+  m_FogColor: {r: 0.5, g: 0.5, b: 0.5, a: 1}
+  m_FogMode: 3
+  m_FogDensity: 0.01
+  m_LinearFogStart: 0
+  m_LinearFogEnd: 300
+  m_AmbientSkyColor: {r: 0.212, g: 0.227, b: 0.259, a: 1}
+  m_AmbientEquatorColor: {r: 0.114, g: 0.125, b: 0.133, a: 1}
+  m_AmbientGroundColor: {r: 0.047, g: 0.043, b: 0.035, a: 1}
+  m_AmbientIntensity: 1
+  m_AmbientMode: 3
+  m_SkyboxMaterial: {fileID: 0}
+  m_HaloStrength: 0.5
+  m_FlareStrength: 1
+  m_FlareFadeSpeed: 3
+  m_HaloTexture: {fileID: 0}
+  m_SpotCookie: {fileID: 10001, guid: 0000000000000000e000000000000000, type: 0}
+  m_DefaultReflectionMode: 0
+  m_DefaultReflectionResolution: 128
+  m_ReflectionBounces: 1
+  m_ReflectionIntensity: 1
+  m_CustomReflection: {fileID: 0}
+  m_Sun: {fileID: 0}
+--- !u!157 &3
+LightmapSettings:
+  m_ObjectHideFlags: 0
+  serializedVersion: 6
+  m_GIWorkflowMode: 1
+  m_LightmapsMode: 1
+  m_GISettings:
+    serializedVersion: 2
+    m_BounceScale: 1
+    m_IndirectOutputScale: 1
+    m_AlbedoBoost: 1
+    m_TemporalCoherenceThreshold: 1
+    m_EnvironmentLightingMode: 0
+    m_EnableBakedLightmaps: 0
+    m_EnableRealtimeLightmaps: 0
+  m_LightmapEditorSettings:
+    serializedVersion: 3
+    m_Resolution: 2
+    m_BakeResolution: 40
+    m_TextureWidth: 1024
+    m_TextureHeight: 1024
+    m_AOMaxDistance: 1
+    m_Padding: 2
+    m_CompAOExponent: 0
+    m_LightmapParameters: {fileID: 0}
+    m_TextureCompression: 1
+    m_FinalGather: 0
+    m_FinalGatherRayCount: 1024
+    m_ReflectionCompression: 2
+  m_LightingDataAsset: {fileID: 0}
+  m_RuntimeCPUUsage: 25
+--- !u!196 &4
+NavMeshSettings:
+  serializedVersion: 2
+  m_ObjectHideFlags: 0
+  m_BuildSettings:
+    serializedVersion: 2
+    agentRadius: 0.5
+    agentHeight: 2
+    agentSlope: 45
+    agentClimb: 0.4
+    ledgeDropHeight: 0
+    maxJumpAcrossDistance: 0
+    accuratePlacement: 0
+    minRegionArea: 2
+    cellSize: 0.16666667
+    manualCellSize: 0
+  m_NavMeshData: {fileID: 0}
+--- !u!1 &327968603
+GameObject:
+  m_ObjectHideFlags: 0
+  m_PrefabParentObject: {fileID: 0}
+  m_PrefabInternal: {fileID: 0}
+  serializedVersion: 4
+  m_Component:
+  - 4: {fileID: 327968608}
+  - 20: {fileID: 327968607}
+  - 92: {fileID: 327968606}
+  - 124: {fileID: 327968605}
+  - 81: {fileID: 327968604}
+  m_Layer: 0
+  m_Name: Main Camera
+  m_TagString: MainCamera
+  m_Icon: {fileID: 0}
+  m_NavMeshLayer: 0
+  m_StaticEditorFlags: 0
+  m_IsActive: 1
+--- !u!81 &327968604
+AudioListener:
+  m_ObjectHideFlags: 0
+  m_PrefabParentObject: {fileID: 0}
+  m_PrefabInternal: {fileID: 0}
+  m_GameObject: {fileID: 327968603}
+  m_Enabled: 1
+--- !u!124 &327968605
+Behaviour:
+  m_ObjectHideFlags: 0
+  m_PrefabParentObject: {fileID: 0}
+  m_PrefabInternal: {fileID: 0}
+  m_GameObject: {fileID: 327968603}
+  m_Enabled: 1
+--- !u!92 &327968606
+Behaviour:
+  m_ObjectHideFlags: 0
+  m_PrefabParentObject: {fileID: 0}
+  m_PrefabInternal: {fileID: 0}
+  m_GameObject: {fileID: 327968603}
+  m_Enabled: 1
+--- !u!20 &327968607
+Camera:
+  m_ObjectHideFlags: 0
+  m_PrefabParentObject: {fileID: 0}
+  m_PrefabInternal: {fileID: 0}
+  m_GameObject: {fileID: 327968603}
+  m_Enabled: 1
+  serializedVersion: 2
+  m_ClearFlags: 1
+  m_BackGroundColor: {r: 0.19215687, g: 0.3019608, b: 0.4745098, a: 0.019607844}
+  m_NormalizedViewPortRect:
+    serializedVersion: 2
+    x: 0
+    y: 0
+    width: 1
+    height: 1
+  near clip plane: 0.3
+  far clip plane: 1000
+  field of view: 60
+  orthographic: 1
+  orthographic size: 5
+  m_Depth: -1
+  m_CullingMask:
+    serializedVersion: 2
+    m_Bits: 4294967295
+  m_RenderingPath: -1
+  m_TargetTexture: {fileID: 0}
+  m_TargetDisplay: 0
+  m_TargetEye: 3
+  m_HDR: 0
+  m_OcclusionCulling: 1
+  m_StereoConvergence: 10
+  m_StereoSeparation: 0.022
+  m_StereoMirrorMode: 0
+--- !u!4 &327968608
+Transform:
+  m_ObjectHideFlags: 0
+  m_PrefabParentObject: {fileID: 0}
+  m_PrefabInternal: {fileID: 0}
+  m_GameObject: {fileID: 327968603}
+  m_LocalRotation: {x: 0, y: 0, z: 0, w: 1}
+  m_LocalPosition: {x: 0, y: 0, z: -10}
+  m_LocalScale: {x: 1, y: 1, z: 1}
+  m_Children: []
+  m_Father: {fileID: 0}
+  m_RootOrder: 0
+--- !u!1 &810825833
+GameObject:
+  m_ObjectHideFlags: 0
+  m_PrefabParentObject: {fileID: 0}
+  m_PrefabInternal: {fileID: 0}
+  serializedVersion: 4
+  m_Component:
+  - 4: {fileID: 810825835}
+  - 114: {fileID: 810825834}
+  m_Layer: 0
+  m_Name: testLocalDB
+  m_TagString: Untagged
+  m_Icon: {fileID: 0}
+  m_NavMeshLayer: 0
+  m_StaticEditorFlags: 0
+  m_IsActive: 1
+--- !u!114 &810825834
+MonoBehaviour:
+  m_ObjectHideFlags: 0
+  m_PrefabParentObject: {fileID: 0}
+  m_PrefabInternal: {fileID: 0}
+  m_GameObject: {fileID: 810825833}
+  m_Enabled: 1
+  m_EditorHideFlags: 0
+  m_Script: {fileID: 11500000, guid: 648d04024ae1b424fa00aa49ab9465e8, type: 3}
+  m_Name: 
+  m_EditorClassIdentifier: 
+  serverUrl: ws://localhost:3000/websocket
+  logMessages: 0
+--- !u!4 &810825835
+Transform:
+  m_ObjectHideFlags: 0
+  m_PrefabParentObject: {fileID: 0}
+  m_PrefabInternal: {fileID: 0}
+  m_GameObject: {fileID: 810825833}
+  m_LocalRotation: {x: 0, y: 0, z: 0, w: 1}
+  m_LocalPosition: {x: 0, y: 0, z: 0}
+  m_LocalScale: {x: 1, y: 1, z: 1}
+  m_Children: []
+  m_Father: {fileID: 0}
+  m_RootOrder: 1

unity-project/Assets/example/test-local-db.unity

@@ -38,7 +38,7 @@ private void HandleLoginResult(MethodCall loginCall) {
 		if (error == null) {
 			JSONObject result = loginCall.result;
 			isLogged = true;
-			this.username = username;
+			this.username = result["username"].str;
 			this.userId = result["id"].str;
 			this.token = result["token"].str;
 			this.tokenExpiration = result["tokenExpires"].GetDateTime();

unity-project/Assets/example/test-local-db.unity.meta

@@ -4,6 +4,10 @@
 using System.Collections;
 using System.Collections.Generic;
 
+/*
+ * DDP protocol:
+ *   https://github.com/meteor/meteor/blob/master/packages/ddp/DDP.md
+ */
 public class DdpConnection : IDisposable {
 
 	// The possible values for the "msg" field.
@@ -86,11 +90,11 @@ public enum ConnectionState {
 
 	public delegate void OnConnectedDelegate(DdpConnection connection);
 	public delegate void OnDisconnectedDelegate(DdpConnection connection);
-	public delegate void OnAddedDelegate(string collection, string id, JSONObject fields);
-	public delegate void OnChangedDelegate(string collection, string id, JSONObject fields, JSONObject cleared);
-	public delegate void OnRemovedDelegate(string collection, string id);
-	public delegate void OnAddedBeforeDelegate(string collection, string id, JSONObject fields, string before);
-	public delegate void OnMovedBeforeDelegate(string collection, string id, string before);
+	public delegate void OnAddedDelegate(string collection, string docId, JSONObject fields);
+	public delegate void OnChangedDelegate(string collection, string docId, JSONObject fields, JSONObject cleared);
+	public delegate void OnRemovedDelegate(string collection, string docId);
+	public delegate void OnAddedBeforeDelegate(string collection, string docId, JSONObject fields, string before);
+	public delegate void OnMovedBeforeDelegate(string collection, string docId, string before);
 	public delegate void OnErrorDelegate(DdpError error);
 
 	public event OnConnectedDelegate OnConnected;