ANTM/Assets/Systems/DataSystem/Scripts/Tools/Firebase/FirebaseQueue.cs

using System;

namespace SimpleFirebaseUnity
{
	using MiniJSON;

	public class FirebaseQueue {

		#region FIREBASE COMMAND QUEUE

		const string SERVER_VALUE_TIMESTAMP = "{\".sv\": \"timestamp\"}";

		protected enum FirebaseCommand
		{
			Get = 0,
			Set = 1,
			Update = 2,
			Push = 3,
			Delete = 4
		}

		protected class CommandLinkedList {
			public FirebaseDatabase firebase;
			FirebaseCommand command;
			string param;
			object obj;
			public CommandLinkedList next;

			public CommandLinkedList(FirebaseDatabase _firebase, FirebaseCommand _command, string _param, object _obj = null){
				firebase = _firebase;
				command = _command;
				param = _param;
				obj = _obj;
				next = null;
			}

			public CommandLinkedList(FirebaseDatabase _firebase, FirebaseCommand _command, FirebaseParam firebaseParam, object _obj = null){
				firebase = _firebase;
				command = _command;
				param = firebaseParam.Parameter;
				obj = _obj;
				next = null;
			}

			public void AddNext(CommandLinkedList _next){
				next = _next;
			}

			public void DoCommand()
			{
				switch (command) {
				case FirebaseCommand.Get:
					firebase.GetValue (param);
					break;
				case FirebaseCommand.Set:
					firebase.SetValue (obj, param);
					break;
				case FirebaseCommand.Update:
					firebase.UpdateValue (obj, param);
					break;
				case FirebaseCommand.Push:
					firebase.Push (obj, param);
					break;
				case FirebaseCommand.Delete:
					firebase.Delete (param);
					break;
				}
			}
		}

		public Action OnQueueFinished;

		protected CommandLinkedList head;
		protected CommandLinkedList tail;
		protected bool autoStart;
		protected int count;

		protected void AddQueue(FirebaseDatabase firebase, FirebaseCommand command, string param, object obj = null)
		{
			CommandLinkedList commandNode =  new CommandLinkedList (firebase, command, param, obj);

			if (head == null) {
				head = commandNode;
				tail = commandNode;

				if (autoStart)
					head.DoCommand();
			} else {
				tail.next = commandNode;
				tail = commandNode;
			}

			++count;
		}

		protected void ClearQueueTopDown(CommandLinkedList node)
		{
			CommandLinkedList temp = node.next;
			node.next = null;
			ClearQueueTopDown (temp);
		}

		protected void StartNextCommand(){
			head = head.next;
			if (head != null)
				head.DoCommand ();
			else {
				tail = null;

				if (OnQueueFinished != null)
					OnQueueFinished ();
			}
		}

		protected void OnSuccess(FirebaseDatabase sender, DataSnapshot snapshot)
		{
			--count;
			StartNextCommand ();
			ClearCallbacks (sender);
		}

		protected void OnFailed(FirebaseDatabase sender, FirebaseError err)
		{
			--count;
			StartNextCommand ();
			ClearCallbacks (sender);
		}

		protected void ClearCallbacks(FirebaseDatabase sender)
		{
			sender.OnGetSuccess -= OnSuccess;
			sender.OnGetFailed -= OnFailed;
			sender.OnUpdateSuccess -= OnSuccess;
			sender.OnUpdateFailed -= OnFailed;
			sender.OnPushSuccess -= OnSuccess;
			sender.OnPushFailed -= OnFailed;
			sender.OnDeleteSuccess -= OnSuccess;
			sender.OnDeleteFailed -= OnFailed;
		}

		#endregion

		#region PUBLIC FUNCTIONS

		/// <summary>
		/// Initializes a new instance of the <see cref="SimpleFirebaseUnity.FirebaseQueueManager"/> class.
		/// </summary>
		/// <param name="_autoStart">If set to <c>true</c> auto start when a queue added.</param>
		public FirebaseQueue(bool _autoStart = true)
		{
			autoStart = _autoStart;
			count = 0;
		}

		/// <summary>
		/// Gets the number of request in queue.
		/// </summary>
		/// <value>The count.</value>
		public int Count
		{
			get {
				return count;
			}
		}

		/// <summary>
		/// Determines whether the queue is empty.
		/// </summary>
		/// <returns><c>true</c> if this instance is empty; otherwise, <c>false</c>.</returns>
		public bool IsEmpty()
		{
			return (count == 0);
		}

		/// <summary>
		/// Adds Firebase Get request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueueGet(FirebaseDatabase firebase, string param = "")
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnGetSuccess += OnSuccess;
			temp.OnGetFailed += OnFailed;
			AddQueue (temp, FirebaseCommand.Get, param);
		}

		/// <summary>
		/// Adds Firebase Get request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueueGet(FirebaseDatabase firebase, FirebaseParam param)
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnGetSuccess += OnSuccess;
			temp.OnGetFailed += OnFailed;
			AddQueue (temp, FirebaseCommand.Get, param.Parameter);
		}


		/// <summary>
		/// Adds Firebase Set request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="val">Value.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueueSet(FirebaseDatabase firebase, object val, string param = "")
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnSetSuccess += OnSuccess;
			temp.OnSetFailed += OnFailed;
			AddQueue (temp, FirebaseCommand.Set, param, val);
		}

		/// <summary>
		/// Adds Firebase Set request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="val">Value.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueueSet(FirebaseDatabase firebase, object val, FirebaseParam param)
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnSetSuccess += OnSuccess;
			temp.OnSetFailed += OnFailed;
			AddQueue (temp, FirebaseCommand.Set, param.Parameter, val);
		}

		/// <summary>
		/// Adds Firebase Set request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="json">Json.</param>
		/// <param name="isJson">If set to <c>true</c> is json.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueueSet(FirebaseDatabase firebase, string json, bool isJson, string param = "")
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnSetSuccess += OnSuccess;
			temp.OnSetFailed += OnFailed;
			if (!isJson)
				AddQueue (temp, FirebaseCommand.Set, param, json);
			else
				AddQueue (temp, FirebaseCommand.Set, param, Json.Deserialize(json));
		}

		/// <summary>
		/// Adds Firebase Set request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="json">Json.</param>
		/// <param name="isJson">If set to <c>true</c> is json.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueueSet(FirebaseDatabase firebase, string json, bool isJson, FirebaseParam param)
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnSetSuccess += OnSuccess;
			temp.OnSetFailed += OnFailed;
			if (!isJson)
				AddQueue (temp, FirebaseCommand.Set, param.Parameter, json);
			else
				AddQueue (temp, FirebaseCommand.Set, param.Parameter, Json.Deserialize(json));
		}

		/// <summary>
		/// Adds Firebase Update request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="val">Value.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueueUpdate(FirebaseDatabase firebase, object val, string param = "")
		{
			firebase.OnUpdateSuccess += OnSuccess;
			firebase.OnUpdateFailed += OnFailed;
			AddQueue (firebase, FirebaseCommand.Update, param, val);
		}

		/// <summary>
		/// Adds Firebase Update request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="val">Value.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueueUpdate(FirebaseDatabase firebase, object val, FirebaseParam param)
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnUpdateSuccess += OnSuccess;
			temp.OnUpdateFailed += OnFailed;
			AddQueue (temp, FirebaseCommand.Update, param.Parameter, val);
		}

		/// <summary>
		/// Adds Firebase Update request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="json">Json.</param>
		/// <param name="isJson">If set to <c>true</c> is json.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueueUpdate(FirebaseDatabase firebase, string json, bool isJson, string param = "")
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnUpdateSuccess += OnSuccess;
			temp.OnUpdateFailed += OnFailed;
			if (!isJson)
				AddQueue (temp, FirebaseCommand.Update, param, json);
			else
				AddQueue (temp, FirebaseCommand.Update, param, Json.Deserialize(json));
		}

		/// <summary>
		/// Adds Firebase Update request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="json">Json.</param>
		/// <param name="isJson">If set to <c>true</c> is json.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueueUpdate(FirebaseDatabase firebase, string json, bool isJson, FirebaseParam param)
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnUpdateSuccess += OnSuccess;
			temp.OnUpdateFailed += OnFailed;
			if (!isJson)
				AddQueue (temp, FirebaseCommand.Update, param.Parameter, json);
			else
				AddQueue (temp, FirebaseCommand.Update, param.Parameter, Json.Deserialize(json));
		}

		/// <summary>
		/// Adds Firebase Push request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="val">Value.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueuePush(FirebaseDatabase firebase, object val, string param = "")
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnPushSuccess += OnSuccess;
			temp.OnPushFailed += OnFailed;
			AddQueue (temp, FirebaseCommand.Push, param, val);
		}

		/// <summary>
		/// Adds Firebase Push request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="val">Value.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueuePush(FirebaseDatabase firebase, object val, FirebaseParam param)
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnPushSuccess += OnSuccess;
			temp.OnPushFailed += OnFailed;
			AddQueue (temp, FirebaseCommand.Push, param.Parameter, val);
		}

		/// <summary>
		/// Adds Firebase Push request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="json">Json.</param>
		/// <param name="isJson">If set to <c>true</c> is json.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueuePush(FirebaseDatabase firebase, string json, bool isJson, string param = "")
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnPushSuccess += OnSuccess;
			temp.OnPushFailed += OnFailed;
			if (!isJson)
				AddQueue (temp, FirebaseCommand.Push, param, json);
			else
				AddQueue (temp, FirebaseCommand.Push, param, Json.Deserialize(json));
		}

		/// <summary>
		/// Adds Firebase Push request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="json">Json.</param>
		/// <param name="isJson">If set to <c>true</c> is json.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueuePush(FirebaseDatabase firebase, string json, bool isJson, FirebaseParam param)
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnPushSuccess += OnSuccess;
			temp.OnPushFailed += OnFailed;
			if (!isJson)
				AddQueue (temp, FirebaseCommand.Push, param.Parameter, json);
			else
				AddQueue (temp, FirebaseCommand.Push, param.Parameter, Json.Deserialize(json));
		}

		/// <summary>
		/// Adds Firebase Delete request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueueDelete(FirebaseDatabase firebase, string param = "")
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnDeleteSuccess += OnSuccess;
			temp.OnDeleteFailed += OnFailed;
			AddQueue (temp, FirebaseCommand.Delete, param);
		}

		/// <summary>
		/// Adds Firebase Delete request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="param">Parameter.</param>
		public void AddQueueDelete(FirebaseDatabase firebase, FirebaseParam param)
		{
			FirebaseDatabase temp = firebase.Copy (true);
			temp.OnDeleteSuccess += OnSuccess;
			temp.OnDeleteFailed += OnFailed;
			AddQueue (temp, FirebaseCommand.Delete, param.Parameter);
		}

		/// <summary>
		/// Adds Firebase Set Time Stamp request to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="keyName">Time stamp key name.</param>
		public void AddQueueSetTimeStamp(FirebaseDatabase firebase, string keyName)
		{
			FirebaseDatabase temp = firebase.Child (keyName, false);
			AddQueueSet (temp, SERVER_VALUE_TIMESTAMP, true, "print=silent");
		}

		/// <summary>
		/// Adds Firebase Set Time Stamp request with callback to queue.
		/// </summary>
		/// <param name="firebase">Firebase.</param>
		/// <param name="keyName">Key name.</param>
		/// <param name="_OnSuccess">On success callback.</param>
		/// <param name="_OnFailed">On fail callback.</param>
		public void AddQueueSetTimeStamp(FirebaseDatabase firebase, string keyName, Action<FirebaseDatabase, DataSnapshot> _OnSuccess, Action<FirebaseDatabase, FirebaseError> _OnFailed)
		{
			FirebaseDatabase temp = firebase.Child (keyName);
			temp.OnSetSuccess += _OnSuccess;
			temp.OnSetFailed += _OnFailed;

			AddQueueSet (temp, SERVER_VALUE_TIMESTAMP, true);
		}


		/// <summary>
		/// Force stop the command queue chain and clears the queue.
		/// </summary>
		public void ForceClearQueue()
		{
			ClearQueueTopDown (head);
		}


		#endregion
	}
}