Added test to fix realtimeworkflow queue messages

ably · Apr 26, 2023 · 43b8d14 · 43b8d14
1 parent 4826de7
commit 43b8d14
Showing 1 changed file with 26 additions and 0 deletions.
diff --git a/src/IO.Ably.Tests.Shared/Realtime/PresenceSandboxSpecs.cs b/src/IO.Ably.Tests.Shared/Realtime/PresenceSandboxSpecs.cs
@@ -1649,6 +1649,32 @@ public async Task ChannelStateCondition_WhenQueueMessagesIsFalse_WhenChannelIsIn
                     client.Close();
                 }
 
+                [Theory]
+                [ProtocolData]
+                [Trait("spec", "RTP16b")]
+                public async Task ChannelStateCondition_WhenQueueMessagesIsFalse_RealtimeWorkflowQueueShouldntAllowMessagesToPublish(Protocol protocol)
+                {
+                    var client = await GetRealtimeClient(protocol, (options, settings) =>
+                    {
+                        options.ClientId = "RTP16b";
+                        options.QueueMessages = false;
+                    });
+                    var channel = GetRandomChannel(client, "RTP16a");
+
+                    await client.WaitForState(ConnectionState.Connected);
+                    client.Workflow.QueueCommand(SetDisconnectedStateCommand.Create(null));
+                    await client.WaitForState(ConnectionState.Disconnected);
+
+                    channel.Presence.Enter(client.Connection.State.ToString(), (b, info) => { });
+
+                    Presence.QueuedPresenceMessage[] presenceMessages = channel.Presence.PendingPresenceQueue.ToArray();
+
+                    presenceMessages.Should().HaveCount(0);
+
+                    // clean up
+                    client.Close();
+                }
+
                 [Theory]
                 [ProtocolData]
                 [Trait("spec", "RTP16b")]