presence: effects

src/Api/PubnubApi/EndPoint/Presence/HeartbeatOperation.cs

@@ -0,0 +1,57 @@
+using System;
+using System.Collections.Generic;
+using System.Globalization;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace PubnubApi.EndPoint
+{
+	public class HeartbeatOperation : PubnubCoreBase
+	{
+        private readonly PNConfiguration config;
+        private readonly IJsonPluggableLibrary jsonLibrary;
+        private readonly IPubnubUnitTest unit;
+        private readonly IPubnubLog pubnubLog;
+        private readonly TelemetryManager pubnubTelemetryMgr;
+        private Dictionary<string, object> userState;
+
+        public HeartbeatOperation(PNConfiguration pubnubConfig, IJsonPluggableLibrary jsonPluggableLibrary, IPubnubUnitTest pubnubUnit, IPubnubLog log, TelemetryManager telemetryManager, EndPoint.TokenManager tokenManager, Pubnub instance) : base(pubnubConfig, jsonPluggableLibrary, pubnubUnit, log, telemetryManager, tokenManager, instance)
+        {
+            config = pubnubConfig;
+            jsonLibrary = jsonPluggableLibrary;
+            unit = pubnubUnit;
+            pubnubLog = log;
+            pubnubTelemetryMgr = telemetryManager;
+
+            PubnubInstance = instance;
+        }      
+
+        internal async Task<PNStatus> HeartbeatRequest<T>(string[] channels, string[] channelGroups) {
+            PNStatus resp = null;
+            try
+            {
+                //string channelsJsonState = BuildJsonUserState(channels, channelGroups, false);    // TODO: State handling through configuration flag
+
+                IUrlRequestBuilder urlBuilder = new UrlRequestBuilder(config, jsonLibrary, unit, pubnubLog, pubnubTelemetryMgr, null, "");
+                Uri request = urlBuilder.BuildPresenceHeartbeatRequest("GET", "", channels, channelGroups, "");
+                RequestState<T> pubnubRequestState = new RequestState<T>();
+                pubnubRequestState.Channels = channels;
+                pubnubRequestState.ChannelGroups = channelGroups;
+                pubnubRequestState.ResponseType = PNOperationType.PNHeartbeatOperation;
+                pubnubRequestState.TimeQueued = DateTime.Now;
+
+                await UrlProcessRequest<T>(request, pubnubRequestState, false).ContinueWith(r =>
+                {
+                    resp = r.Result.Item2;
+                }, TaskContinuationOptions.ExecuteSynchronously).ConfigureAwait(false);
+            }
+            catch(Exception ex)
+            {
+                LoggingMethod.WriteToLog(pubnubLog, string.Format(CultureInfo.InvariantCulture, "DateTime {0} HeartbeatOperation=> HeartbeatRequest \n channel(s)={1} \n cg(s)={2} \n Exception Details={3}", DateTime.Now.ToString(CultureInfo.InvariantCulture), string.Join(",", channels.OrderBy(x => x).ToArray()), string.Join(",", channelGroups.OrderBy(x => x).ToArray()), ex), config.LogVerbosity);
+                return new PNStatus(ex, PNOperationType.PNHeartbeatOperation, PNStatusCategory.PNUnknownCategory, channels, channelGroups);
+            }
+            return resp;
+        }
+
+	}
+}

src/Api/PubnubApi/EndPoint/Presence/HereNowOperation.cs

@@ -1,7 +1,5 @@
 using System;
 using System.Collections.Generic;
-using System.Linq;
-using System.Text;
 using System.Threading.Tasks;
 using System.Threading;
 using System.Net;
@@ -11,182 +9,170 @@
 
 namespace PubnubApi.EndPoint
 {
-    public class HereNowOperation : PubnubCoreBase
-    {
-        private readonly PNConfiguration config;
-        private readonly IJsonPluggableLibrary jsonLibrary;
-        private readonly IPubnubUnitTest unit;
-        private readonly IPubnubLog pubnubLog;
-        private readonly EndPoint.TelemetryManager pubnubTelemetryMgr;
-
-        private string[] channelNames;
-        private string[] channelGroupNames;
-        private bool includeUserState;
-        private bool includeChannelUUIDs = true;
-        private PNCallback<PNHereNowResult> savedCallback;
-        private Dictionary<string, object> queryParam;
-
-        public HereNowOperation(PNConfiguration pubnubConfig, IJsonPluggableLibrary jsonPluggableLibrary, IPubnubUnitTest pubnubUnit, IPubnubLog log, EndPoint.TelemetryManager telemetryManager, EndPoint.TokenManager tokenManager, Pubnub instance) : base(pubnubConfig, jsonPluggableLibrary, pubnubUnit, log, telemetryManager, tokenManager, instance)
-        {
-            config = pubnubConfig;
-            jsonLibrary = jsonPluggableLibrary;
-            unit = pubnubUnit;
-            pubnubLog = log;
-            pubnubTelemetryMgr = telemetryManager;
-        }
-
-        public HereNowOperation Channels(string[] channels)
-        {
-            this.channelNames = channels;
-            return this;
-        }
-
-        public HereNowOperation ChannelGroups(string[] channelGroups)
-        {
-            this.channelGroupNames = channelGroups;
-            return this;
-        }
-
-        public HereNowOperation IncludeState(bool includeState)
-        {
-            this.includeUserState = includeState;
-            return this;
-        }
-
-        public HereNowOperation IncludeUUIDs(bool includeUUIDs)
-        {
-            this.includeChannelUUIDs = includeUUIDs;
-            return this;
-        }
-
-        public HereNowOperation QueryParam(Dictionary<string, object> customQueryParam)
-        {
-            this.queryParam = customQueryParam;
-            return this;
-        }
-
-        [Obsolete("Async is deprecated, please use Execute instead.")]
-        public void Async(PNCallback<PNHereNowResult> callback)
-        {
-            Execute(callback);
-        }
-
-        public void Execute(PNCallback<PNHereNowResult> callback)
-        {
+	public class HereNowOperation : PubnubCoreBase
+	{
+		private readonly PNConfiguration config;
+		private readonly IJsonPluggableLibrary jsonLibrary;
+		private readonly IPubnubUnitTest unit;
+		private readonly IPubnubLog pubnubLog;
+		private readonly EndPoint.TelemetryManager pubnubTelemetryMgr;
+		private string[] channelNames;
+		private string[] channelGroupNames;
+		private bool includeUserState;
+		private bool includeChannelUUIDs = true;
+		private PNCallback<PNHereNowResult> savedCallback;
+		private Dictionary<string, object> queryParam;
+
+		public HereNowOperation(PNConfiguration pubnubConfig, IJsonPluggableLibrary jsonPluggableLibrary, IPubnubUnitTest pubnubUnit, IPubnubLog log, EndPoint.TelemetryManager telemetryManager, EndPoint.TokenManager tokenManager, Pubnub instance) : base(pubnubConfig, jsonPluggableLibrary, pubnubUnit, log, telemetryManager, tokenManager, instance)
+		{
+			config = pubnubConfig;
+			jsonLibrary = jsonPluggableLibrary;
+			unit = pubnubUnit;
+			pubnubLog = log;
+			pubnubTelemetryMgr = telemetryManager;
+		}
+
+		public HereNowOperation Channels(string[] channels)
+		{
+			this.channelNames = channels;
+			return this;
+		}
+
+		public HereNowOperation ChannelGroups(string[] channelGroups)
+		{
+			this.channelGroupNames = channelGroups;
+			return this;
+		}
+
+		public HereNowOperation IncludeState(bool includeState)
+		{
+			this.includeUserState = includeState;
+			return this;
+		}
+
+		public HereNowOperation IncludeUUIDs(bool includeUUIDs)
+		{
+			this.includeChannelUUIDs = includeUUIDs;
+			return this;
+		}
+
+		public HereNowOperation QueryParam(Dictionary<string, object> customQueryParam)
+		{
+			this.queryParam = customQueryParam;
+			return this;
+		}
+
+		[Obsolete("Async is deprecated, please use Execute instead.")]
+		public void Async(PNCallback<PNHereNowResult> callback)
+		{
+			Execute(callback);
+		}
+
+		public void Execute(PNCallback<PNHereNowResult> callback)
+		{
 #if NETFX_CORE || WINDOWS_UWP || UAP || NETSTANDARD10 || NETSTANDARD11 || NETSTANDARD12
             Task.Factory.StartNew(() =>
             {
                 this.savedCallback = callback;
                 HereNow(this.channelNames, this.channelGroupNames, this.includeChannelUUIDs, this.includeUserState, this.queryParam, callback);
             }, CancellationToken.None, TaskCreationOptions.PreferFairness, TaskScheduler.Default).ConfigureAwait(false);
 #else
-            new Thread(() =>
-            {
-                this.savedCallback = callback;
-                HereNow(this.channelNames, this.channelGroupNames, this.includeChannelUUIDs, this.includeUserState, this.queryParam, callback);
-            })
-            { IsBackground = true }.Start();
+			new Thread(() => {
+				this.savedCallback = callback;
+				HereNow(this.channelNames, this.channelGroupNames, this.includeChannelUUIDs, this.includeUserState, this.queryParam, callback);
+			}) { IsBackground = true }.Start();
 #endif
-        }
+		}
 
-        public async Task<PNResult<PNHereNowResult>> ExecuteAsync()
-        {
-            return await HereNow(this.channelNames, this.channelGroupNames, this.includeChannelUUIDs, this.includeUserState, this.queryParam).ConfigureAwait(false);
-        }
+		public async Task<PNResult<PNHereNowResult>> ExecuteAsync()
+		{
+			return await HereNow(this.channelNames, this.channelGroupNames, this.includeChannelUUIDs, this.includeUserState, this.queryParam).ConfigureAwait(false);
+		}
 
 
-        internal void Retry()
-        {
+		internal void Retry()
+		{
 #if NETFX_CORE || WINDOWS_UWP || UAP || NETSTANDARD10 || NETSTANDARD11 || NETSTANDARD12
             Task.Factory.StartNew(() =>
             {
                 HereNow(this.channelNames, this.channelGroupNames, this.includeChannelUUIDs, this.includeUserState, this.queryParam, savedCallback);
             }, CancellationToken.None, TaskCreationOptions.PreferFairness, TaskScheduler.Default).ConfigureAwait(false);
 #else
-            new Thread(() =>
-            {
-                HereNow(this.channelNames, this.channelGroupNames, this.includeChannelUUIDs, this.includeUserState, this.queryParam, savedCallback);
-            })
-            { IsBackground = true }.Start();
+			new Thread(() => {
+				HereNow(this.channelNames, this.channelGroupNames, this.includeChannelUUIDs, this.includeUserState, this.queryParam, savedCallback);
+			}) { IsBackground = true }.Start();
 #endif
-        }
-
-        internal void HereNow(string[] channels, string[] channelGroups, bool showUUIDList, bool includeUserState, Dictionary<string, object> externalQueryParam, PNCallback<PNHereNowResult> callback)
-        {
-
-            IUrlRequestBuilder urlBuilder = new UrlRequestBuilder(config, jsonLibrary, unit, pubnubLog, pubnubTelemetryMgr, (PubnubInstance != null && !string.IsNullOrEmpty(PubnubInstance.InstanceId) && PubnubTokenMgrCollection.ContainsKey(PubnubInstance.InstanceId)) ? PubnubTokenMgrCollection[PubnubInstance.InstanceId] : null, (PubnubInstance != null) ? PubnubInstance.InstanceId : "");
-
-            Uri request = urlBuilder.BuildHereNowRequest("GET", "", channels, channelGroups, showUUIDList, includeUserState, externalQueryParam);
-
-            RequestState<PNHereNowResult> requestState = new RequestState<PNHereNowResult>();
-            requestState.Channels = channels;
-            requestState.ChannelGroups = channelGroups;
-            requestState.ResponseType = PNOperationType.PNHereNowOperation;
-            requestState.Reconnect = false;
-            requestState.PubnubCallback = callback;
-            requestState.EndPointOperation = this;
-
-            UrlProcessRequest(request, requestState, false).ContinueWith(r =>
-            {
-                string json = r.Result.Item1;
-                if (!string.IsNullOrEmpty(json))
-                {
-                    List<object> result = ProcessJsonResponse(requestState, json);
-                    ProcessResponseCallbacks(result, requestState);
-                }
-            }, TaskContinuationOptions.ExecuteSynchronously).Wait();
-        }
-
-        internal async Task<PNResult<PNHereNowResult>> HereNow(string[] channels, string[] channelGroups, bool showUUIDList, bool includeUserState, Dictionary<string, object> externalQueryParam)
-        {
-            PNResult<PNHereNowResult> ret = new PNResult<PNHereNowResult>();
-
-            IUrlRequestBuilder urlBuilder = new UrlRequestBuilder(config, jsonLibrary, unit, pubnubLog, pubnubTelemetryMgr, (PubnubInstance != null && !string.IsNullOrEmpty(PubnubInstance.InstanceId) && PubnubTokenMgrCollection.ContainsKey(PubnubInstance.InstanceId)) ? PubnubTokenMgrCollection[PubnubInstance.InstanceId] : null, (PubnubInstance != null) ? PubnubInstance.InstanceId : "");
-
-            Uri request = urlBuilder.BuildHereNowRequest("GET", "", channels, channelGroups, showUUIDList, includeUserState, externalQueryParam);
-
-            RequestState<PNHereNowResult> requestState = new RequestState<PNHereNowResult>();
-            requestState.Channels = channels;
-            requestState.ChannelGroups = channelGroups;
-            requestState.ResponseType = PNOperationType.PNHereNowOperation;
-            requestState.Reconnect = false;
-            requestState.EndPointOperation = this;
-
-            Tuple<string, PNStatus> JsonAndStatusTuple = await UrlProcessRequest(request, requestState, false).ConfigureAwait(false);
-            ret.Status = JsonAndStatusTuple.Item2;
-            string json = JsonAndStatusTuple.Item1;
-            if (!string.IsNullOrEmpty(json))
-            {
-                List<object> resultList = ProcessJsonResponse(requestState, json);
-                ResponseBuilder responseBuilder = new ResponseBuilder(config, jsonLibrary, pubnubLog);
-                PNHereNowResult responseResult = responseBuilder.JsonToObject<PNHereNowResult>(resultList, true);
-                if (responseResult != null)
-                {
-                    ret.Result = responseResult;
-                }
-            }
-
-            return ret;
-        }
-
-
-        internal void CurrentPubnubInstance(Pubnub instance)
-        {
-            PubnubInstance = instance;
-
-            if (!ChannelRequest.ContainsKey(instance.InstanceId))
-            {
-                ChannelRequest.GetOrAdd(instance.InstanceId, new ConcurrentDictionary<string, HttpWebRequest>());
-            }
-            if (!ChannelInternetStatus.ContainsKey(instance.InstanceId))
-            {
-                ChannelInternetStatus.GetOrAdd(instance.InstanceId, new ConcurrentDictionary<string, bool>());
-            }
-            if (!ChannelGroupInternetStatus.ContainsKey(instance.InstanceId))
-            {
-                ChannelGroupInternetStatus.GetOrAdd(instance.InstanceId, new ConcurrentDictionary<string, bool>());
-            }
-        }
-
-    }
+		}
+
+		internal void HereNow(string[] channels, string[] channelGroups, bool showUUIDList, bool includeUserState, Dictionary<string, object> externalQueryParam, PNCallback<PNHereNowResult> callback)
+		{
+
+			IUrlRequestBuilder urlBuilder = new UrlRequestBuilder(config, jsonLibrary, unit, pubnubLog, pubnubTelemetryMgr, (PubnubInstance != null && !string.IsNullOrEmpty(PubnubInstance.InstanceId) && PubnubTokenMgrCollection.ContainsKey(PubnubInstance.InstanceId)) ? PubnubTokenMgrCollection[PubnubInstance.InstanceId] : null, (PubnubInstance != null) ? PubnubInstance.InstanceId : "");
+
+			Uri request = urlBuilder.BuildHereNowRequest("GET", "", channels, channelGroups, showUUIDList, includeUserState, externalQueryParam);
+
+			RequestState<PNHereNowResult> requestState = new RequestState<PNHereNowResult>();
+			requestState.Channels = channels;
+			requestState.ChannelGroups = channelGroups;
+			requestState.ResponseType = PNOperationType.PNHereNowOperation;
+			requestState.Reconnect = false;
+			requestState.PubnubCallback = callback;
+			requestState.EndPointOperation = this;
+
+			UrlProcessRequest(request, requestState, false).ContinueWith(r => {
+				string json = r.Result.Item1;
+				if (!string.IsNullOrEmpty(json)) {
+					List<object> result = ProcessJsonResponse(requestState, json);
+					ProcessResponseCallbacks(result, requestState);
+				}
+			}, TaskContinuationOptions.ExecuteSynchronously).Wait();
+		}
+
+		internal async Task<PNResult<PNHereNowResult>> HereNow(string[] channels, string[] channelGroups, bool showUUIDList, bool includeUserState, Dictionary<string, object> externalQueryParam)
+		{
+			PNResult<PNHereNowResult> ret = new PNResult<PNHereNowResult>();
+
+			IUrlRequestBuilder urlBuilder = new UrlRequestBuilder(config, jsonLibrary, unit, pubnubLog, pubnubTelemetryMgr, (PubnubInstance != null && !string.IsNullOrEmpty(PubnubInstance.InstanceId) && PubnubTokenMgrCollection.ContainsKey(PubnubInstance.InstanceId)) ? PubnubTokenMgrCollection[PubnubInstance.InstanceId] : null, (PubnubInstance != null) ? PubnubInstance.InstanceId : "");
+
+			Uri request = urlBuilder.BuildHereNowRequest("GET", "", channels, channelGroups, showUUIDList, includeUserState, externalQueryParam);
+
+			RequestState<PNHereNowResult> requestState = new RequestState<PNHereNowResult>();
+			requestState.Channels = channels;
+			requestState.ChannelGroups = channelGroups;
+			requestState.ResponseType = PNOperationType.PNHereNowOperation;
+			requestState.Reconnect = false;
+			requestState.EndPointOperation = this;
+
+			Tuple<string, PNStatus> JsonAndStatusTuple = await UrlProcessRequest(request, requestState, false).ConfigureAwait(false);
+			ret.Status = JsonAndStatusTuple.Item2;
+			string json = JsonAndStatusTuple.Item1;
+			if (!string.IsNullOrEmpty(json)) {
+				List<object> resultList = ProcessJsonResponse(requestState, json);
+				ResponseBuilder responseBuilder = new ResponseBuilder(config, jsonLibrary, pubnubLog);
+				PNHereNowResult responseResult = responseBuilder.JsonToObject<PNHereNowResult>(resultList, true);
+				if (responseResult != null) {
+					ret.Result = responseResult;
+				}
+			}
+
+			return ret;
+		}
+
+
+		internal void CurrentPubnubInstance(Pubnub instance)
+		{
+			PubnubInstance = instance;
+
+			if (!ChannelRequest.ContainsKey(instance.InstanceId)) {
+				ChannelRequest.GetOrAdd(instance.InstanceId, new ConcurrentDictionary<string, HttpWebRequest>());
+			}
+			if (!ChannelInternetStatus.ContainsKey(instance.InstanceId)) {
+				ChannelInternetStatus.GetOrAdd(instance.InstanceId, new ConcurrentDictionary<string, bool>());
+			}
+			if (!ChannelGroupInternetStatus.ContainsKey(instance.InstanceId)) {
+				ChannelGroupInternetStatus.GetOrAdd(instance.InstanceId, new ConcurrentDictionary<string, bool>());
+			}
+		}
+
+	}
 }