Use Unity UI. Text and Buttons for debug

Author: brean

unity-project/Assets/example/TestDdpAccount.cs

@@ -156,7 +156,13 @@ public void Update() {
             {
                 string log = logQueue.Dequeue();
                 Debug.Log(log);
-                DebugText.text = log + "\n" + DebugText.text;
+                string[] original = DebugText.text.Split('\n');
+                List<string> logMessages = new List<string>();
+                for (int i = 0; i < Mathf.Min(original.Length, 10); i++)
+                {
+                    logMessages.Add(original[i]);
+                }
+                DebugText.text = log + "\n" + string.Join("\n", logMessages);
             }
         }
 

unity-project/Assets/example/TestDdpClient.cs

@@ -22,132 +22,198 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 	SOFTWARE.
 */
 
-using UnityEngine;
+using UnityEngine;
 using System.Collections;
 using Moulin.DDP;
+using System;
+using UnityEngine.UI;
+using System.Collections.Generic;
 
 public class TestDdpClient : MonoBehaviour {
+    public Text DebugText;
 
-	public string serverUrl = "ws://localhost:3000/websocket";
+    public string serverUrl = "ws://localhost:3000/websocket";
 	public bool logMessages;
 
 	private DdpConnection ddpConnection;
+    private Queue<string> logQueue;
 
-	public void Start() {
+    public void Start() {
 		Application.runInBackground = true; // Let the game run when the editor is not focused.
 
-		ddpConnection = new DdpConnection(serverUrl);
+        this.DebugText.text = "";
+        logQueue = new Queue<string>();
+        ddpConnection = new DdpConnection(serverUrl);
 		ddpConnection.logMessages = logMessages;
+        ddpConnection.OnDebugMessage += AddDebugText;
 
-		ddpConnection.OnConnected += (DdpConnection connection) => {
-			Debug.Log("Connected.");
+        ddpConnection.OnConnected += (DdpConnection connection) => {
+            AddDebugText("Connected.");
 
 			StartCoroutine(MyCoroutine());
 		};
 
 		ddpConnection.OnDisconnected += (DdpConnection connection) => {
-			Debug.Log("Disconnected.");
+            AddDebugText("Disconnected.");
 
 			StartCoroutine(CoroutineHelper.GetInstance().RunAfter(() => {
-				Debug.Log("Try to reconnect ...");
+                AddDebugText("Try to reconnect ...");
 				connection.ConnectAsync();
 			}, 2.0f));
 		};
 
 		ddpConnection.OnConnectionClosed += (DdpConnection connection) => {
-			Debug.Log("Connection closed.");
+            AddDebugText("Connection closed.");
 		};
 
 		ddpConnection.OnError += (DdpError error) => {
-			Debug.Log("Error: " + error.errorCode + " " + error.reason);
+            AddDebugText("Error: " + error.errorCode + " " + error.reason);
 		};
 
 		ddpConnection.OnAdded += (collection, id, fields) => {
-			Debug.Log("Added docId " + id +
+            AddDebugText("Added docId " + id +
 				" in collection " + collection);
 		};
 
 		ddpConnection.OnRemoved += (collection, id) => {
-			Debug.Log("Removed docId " + id +
+            AddDebugText("Removed docId " + id +
 				" in collection " + collection);
 		};
 
 		ddpConnection.OnChanged += (collection, id, fields, cleared) => {
-			Debug.Log("Changed docId " + id +
+            AddDebugText("Changed docId " + id +
 				" in collection " + collection +
 				" fields: " + fields +
 				" cleared:" + cleared);
 		};
 
 		ddpConnection.OnAddedBefore += (collection, id, fields, before) => {
-			Debug.Log("Added docId " + id +
+            AddDebugText("Added docId " + id +
 				" before docId " + before +
 				" in collection " + collection +
 				" fields: " + fields);
 		};
 
 		ddpConnection.OnMovedBefore += (collection, id, before) => {
-			Debug.Log("Moved docId " + id +
+            AddDebugText("Moved docId " + id +
 				" before docId " + before +
 				" in collection " + collection);
 		};
 
 	}
 
-	private Subscription friendSub;
-
-	public void Update() {
-		if (Input.GetKeyDown(KeyCode.C)) {
-			Debug.Log("Connecting ...");
-			ddpConnection.ConnectAsync();
+    public void Connect()
+    {
+        AddDebugText("Connecting ...");
+        ddpConnection.ConnectAsync();
+    }
+
+    public void Disconnect()
+    {
+        AddDebugText("Closing connection ...");
+        ddpConnection.Close();
+    }
+
+    public void Subscribe()
+    {
+        friendSub = ddpConnection.Subscribe("friends");
+        friendSub.OnReady = (Subscription obj) => {
+            AddDebugText("Ready subscription: " + obj.id);
+        };
+    }
+
+    public void Unsubscribe()
+    {
+        ddpConnection.Unsubscribe(friendSub);
+    }
+
+    public void RemoveAll()
+    {
+        ddpConnection.Call("friends.removeAll");
+    }
+
+    public void CreateFriends()
+    {
+        MethodCall methodCall = ddpConnection.Call("friends.create", JSONObject.CreateStringObject("Coco"));
+        methodCall.OnUpdated = (MethodCall obj) => {
+            AddDebugText("Updated, methodId=" + obj.id);
+        };
+        methodCall.OnResult = (MethodCall obj) => {
+            AddDebugText("Result = " + obj.result);
+        };
+    }
+
+    public void CallAdd()
+    {
+        MethodCall methodCall = ddpConnection.Call("friends.add", JSONObject.Create(19), JSONObject.Create(23));
+        methodCall.OnUpdated = (MethodCall obj) => {
+            AddDebugText("Updated, methodId=" + obj.id);
+        };
+        methodCall.OnResult = (MethodCall obj) => {
+            AddDebugText("Result = " + obj.result);
+        };
+    }
+
+    private Subscription friendSub;
+
+    public void AddDebugText(string text)
+    {
+        logQueue.Enqueue(text);
+    }
+
+
+    public void Update()
+    {
+        if (logQueue != null)
+        {
+            while (logQueue.Count > 0)
+            {
+                string log = logQueue.Dequeue();
+                Debug.Log(log);
+                string[] original = DebugText.text.Split('\n');
+                List<string> logMessages = new List<string>();
+                for (int i = 0; i < Mathf.Min(original.Length, 10); i++)
+                {
+                    logMessages.Add(original[i]);
+                }
+                DebugText.text = log + "\n" + string.Join("\n", logMessages);
+            }
+        }
+
+        if (Input.GetKeyDown(KeyCode.C)) {
+            Connect();
 		}
 
 		if (Input.GetKeyDown(KeyCode.V)) {
-			Debug.Log("Closing connection ...");
-			ddpConnection.Close();
+            Disconnect();
 		}
 
 		if (Input.GetKeyDown(KeyCode.S)) {
-			friendSub = ddpConnection.Subscribe("friends");
-			friendSub.OnReady = (Subscription obj) => {
-				Debug.Log("Ready subscription: " + obj.id);
-			};
+            Subscribe();
 		}
 
 		if (Input.GetKeyDown(KeyCode.U)) {
-			ddpConnection.Unsubscribe(friendSub);
+            Unsubscribe();
 		}
 
 		if (Input.GetKeyDown(KeyCode.R)) {
-			ddpConnection.Call("friends.removeAll");
+            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);
-			};
+            CreateFriends();
 		}
 
 		if (Input.GetKeyDown(KeyCode.A)) {
-			MethodCall methodCall = ddpConnection.Call("friends.add", JSONObject.Create(7), JSONObject.Create(5));
-			methodCall.OnUpdated = (MethodCall obj) => {
-				Debug.Log("Updated, methodId=" + obj.id);
-			};
-			methodCall.OnResult = (MethodCall obj) => {
-				Debug.Log("Result = " + obj.result);
-			};
+            CallAdd();
 		}
 
 	}
 
-	private IEnumerator MyCoroutine() {
+    private IEnumerator MyCoroutine() {
 		MethodCall methodCall = ddpConnection.Call("friends.add", JSONObject.Create(19), JSONObject.Create(23));
 		yield return methodCall.WaitForResult();
-		Debug.Log("(19 + 23)'s call has a result: " + methodCall.result.i);
+        AddDebugText("(19 + 23)'s call has a result: " + methodCall.result.i);
 	}
 
 }