Added leave effect handler

Author: budgetpreneur

src/Api/PubnubApi/EventEngine/Subscribe/Effects/LeaveEffectHandler.cs

@@ -0,0 +1,34 @@
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Newtonsoft.Json;
+using PubnubApi.EndPoint;
+using PubnubApi.PubnubEventEngine.Core;
+using PubnubApi.PubnubEventEngine.Subscribe.Invocations;
+
+namespace PubnubApi.PubnubEventEngine.Subscribe.Effects {
+	internal class LeaveEffectHandler : Core.IEffectHandler<LeaveInvocation> {
+		private SubscribeManager2 manager;
+		private EventQueue eventQueue;
+
+		public LeaveEffectHandler(SubscribeManager2 manager, EventQueue eventQueue) {
+			this.manager = manager;
+			this.eventQueue = eventQueue;
+		}
+
+		public async Task Run(LeaveInvocation invocation) {
+			// TODO identity method for unsubscribe all
+			//var resp = null;//await manager.UnsubscribeRequest<string>(
+			//	PNOperationType.PNSubscribeOperation,
+			//	invocation.Channels.ToArray(),
+			//	invocation.ChannelGroups.ToArray(),
+			//);
+
+			
+		}
+
+		public async Task Cancel() {
+			//manager.LeaveRequestCancellation();
+		}
+	}
+}

src/Api/PubnubApi/EventEngine/Subscribe/Invocations/SubscriptionInvocations.cs

@@ -66,4 +66,11 @@ internal class ReceiveReconnectInvocation: Core.IEffectInvocation
 	}
 
 	internal class CancelReceiveReconnectInvocation: ReceiveReconnectInvocation, Core.IEffectCancelInvocation { }
+
+	internal class LeaveInvocation: Core.IEffectInvocation 
+	{ 
+		public IEnumerable<string> Channels;
+		public IEnumerable<string> ChannelGroups;
+	}
+	internal class CancelLeaveInvocation : LeaveInvocation, Core.IEffectCancelInvocation { }
 }

src/Api/PubnubApi/EventEngine/Subscribe/States/UnsubscribedState.cs

@@ -9,7 +9,8 @@ internal class UnsubscribedState : Core.State
     {
         public IEnumerable<string> Channels;
         public IEnumerable<string> ChannelGroups;
-        public override IEnumerable<IEffectInvocation> OnEntry { get; } = null;
+        public override IEnumerable<IEffectInvocation> OnEntry => new LeaveInvocation()
+            { Channels = this.Channels, ChannelGroups = this.ChannelGroups }.AsArray();
         public override IEnumerable<IEffectInvocation> OnExit { get; } = null;
 
         public override TransitionResult Transition(Core.IEvent e)

src/Api/PubnubApi/EventEngine/Subscribe/SubscribeEventEngine.cs

@@ -15,6 +15,10 @@ public SubscribeEventEngine(SubscribeManager2 subscribeManager) {
 			dispatcher.Register<Invocations.HandshakeInvocation, Effects.HandshakeEffectHandler>(handshakeHandler);
 			dispatcher.Register<Invocations.CancelHandshakeInvocation, Effects.HandshakeEffectHandler>(handshakeHandler);
 
+			var leaveHandler = new Effects.LeaveEffectHandler(subscribeManager, eventQueue);
+			dispatcher.Register<Invocations.LeaveInvocation, Effects.LeaveEffectHandler>(leaveHandler);
+			dispatcher.Register<Invocations.CancelLeaveInvocation, Effects.LeaveEffectHandler>(leaveHandler);
+
 			currentState = new UnsubscribedState();
 		}
 	}

src/Api/PubnubApiPCL/PubnubApiPCL.csproj

@@ -229,6 +229,7 @@
     <Compile Include="..\PubnubApi\EventEngine\ReceivingEffectHandler.cs" Link="EventEngine\ReceivingEffectHandler.cs" />
     <Compile Include="..\PubnubApi\EventEngine\State.cs" Link="EventEngine\State.cs" />
     <Compile Include="..\PubnubApi\EventEngine\Subscribe\Effects\HandshakeEffectHandler.cs" Link="EventEngine\Subscribe\Effects\HandshakeEffectHandler.cs" />
+    <Compile Include="..\PubnubApi\EventEngine\Subscribe\Effects\LeaveEffectHandler.cs" Link="EventEngine\Subscribe\Effects\LeaveEffectHandler.cs" />
     <Compile Include="..\PubnubApi\EventEngine\Subscribe\Events\SubscriptionEvents.cs" Link="EventEngine\Subscribe\Events\SubscriptionEvents.cs" />
     <Compile Include="..\PubnubApi\EventEngine\Subscribe\Invocations\SubscriptionInvocations.cs" Link="EventEngine\Subscribe\Invocations\SubscriptionInvocations.cs" />
     <Compile Include="..\PubnubApi\EventEngine\Subscribe\States\HandshakeFailedState.cs" Link="EventEngine\Subscribe\States\HandshakeFailedState.cs" />

src/Api/PubnubApiUWP/PubnubApiUWP.csproj

@@ -346,6 +346,7 @@
     <Compile Include="..\PubnubApi\EventEngine\ReceivingEffectHandler.cs" Link="EventEngine\ReceivingEffectHandler.cs" />
     <Compile Include="..\PubnubApi\EventEngine\State.cs" Link="EventEngine\State.cs" />
     <Compile Include="..\PubnubApi\EventEngine\Subscribe\Effects\HandshakeEffectHandler.cs" Link="EventEngine\Subscribe\Effects\HandshakeEffectHandler.cs" />
+    <Compile Include="..\PubnubApi\EventEngine\Subscribe\Effects\LeaveEffectHandler.cs" Link="EventEngine\Subscribe\Effects\LeaveEffectHandler.cs" />
     <Compile Include="..\PubnubApi\EventEngine\Subscribe\Events\SubscriptionEvents.cs" Link="EventEngine\Subscribe\Events\SubscriptionEvents.cs" />
     <Compile Include="..\PubnubApi\EventEngine\Subscribe\Invocations\SubscriptionInvocations.cs" Link="EventEngine\Subscribe\Invocations\SubscriptionInvocations.cs" />
     <Compile Include="..\PubnubApi\EventEngine\Subscribe\States\HandshakeFailedState.cs" Link="EventEngine\Subscribe\States\HandshakeFailedState.cs" />