Debug issue preparations

fsprojects · Oct 9, 2023 · 245072b · 245072b
1 parent cbb9fa5
commit 245072b
Show file tree

Hide file tree

Showing 2 changed files with 38 additions and 35 deletions.
diff --git a/tests/IntegrationTests/Chunks.fs b/tests/IntegrationTests/Chunks.fs
@@ -16,8 +16,8 @@ open Serilog
 [<Tests>]
 let tests =
     testList "Chunks" [
-        
-        testTask "Two chunks-message delivered successfully" {
+
+        ftestTask "Two chunks-message delivered successfully" {
             Log.Debug("Started Two chunks-message delivered successfully")
             let client = getClient()
             let topicName = "public/default/topic-" + Guid.NewGuid().ToString("N")
@@ -30,14 +30,14 @@ let tests =
                     .EnableBatching(false)
                     .EnableChunking(true)
                     .CompressionType(CompressionType.Snappy)
-                    .CreateAsync() 
+                    .CreateAsync()
 
             let! (consumer :  IConsumer<byte[]>) =
                 client.NewConsumer()
                     .Topic(topicName)
                     .ConsumerName(name)
                     .SubscriptionName("test-subscription")
-                    .SubscribeAsync() 
+                    .SubscribeAsync()
 
             let payload = Array.zeroCreate 10_000_000
             Random().NextBytes(payload)
@@ -48,23 +48,23 @@ let tests =
             let! msgId =
                 producer.NewMessage(payload)
                 |> producer.SendAsync
-                
-                
+
+
             let! (msg : Message<byte[]>) =
                 consumer.ReceiveAsync()
-                
-            
+
+
             Expect.equal "" msgId msg.MessageId
-            Expect.equal "" 1uy msg.Data.[1] 
-            Expect.equal "" 1uy msg.Data.[8_000_000] 
-            Expect.equal "" 0uy msg.Data.[0] 
-            Expect.equal "" 0uy msg.Data.[9_000_000] 
-        
-            do! consumer.UnsubscribeAsync() 
+            Expect.equal "" 1uy msg.Data.[1]
+            Expect.equal "" 1uy msg.Data.[8_000_000]
+            Expect.equal "" 0uy msg.Data.[0]
+            Expect.equal "" 0uy msg.Data.[9_000_000]
+
+            do! consumer.UnsubscribeAsync()
             do! Task.Delay 100
             Log.Debug("Ended Two chunks-message delivered successfully")
         }
-        
+
         testTask "Two parallel chunks-message delivered successfully with short queue" {
             Log.Debug("Started Two parallel chunks-message delivered successfully with short queue")
             let client = getClient()
@@ -77,24 +77,24 @@ let tests =
                     .ProducerName(name + "1")
                     .EnableBatching(false)
                     .EnableChunking(true)
-                    .CreateAsync() 
+                    .CreateAsync()
 
             let! (producer2 : IProducer<byte[]>) =
                 client.NewProducer()
                     .Topic(topicName)
                     .ProducerName(name + "2")
                     .EnableBatching(false)
                     .EnableChunking(true)
-                    .CreateAsync() 
-            
+                    .CreateAsync()
+
             let! (consumer : IConsumer<byte[]>) =
                 client.NewConsumer()
                     .Topic(topicName)
                     .ConsumerName(name)
                     .SubscriptionName("test-subscription")
                     .MaxPendingChunkedMessage(1)
                     .AckTimeout(TimeSpan.FromMilliseconds(1000.0))
-                    .SubscribeAsync() 
+                    .SubscribeAsync()
 
             let payload1 = Array.zeroCreate 10_000_000
             let payload2 = Array.zeroCreate 10_000_000
@@ -106,8 +106,8 @@ let tests =
                 [| producer1.NewMessage(payload1)|> producer1.SendAsync
                    producer2.NewMessage(payload2)|> producer2.SendAsync |]
                 |> Task.WhenAll
-                
-                 
+
+
             let! ([| msg1; msg2 |] : Message<byte[]>[]) =
                 [| task {
                        let! msg = consumer.ReceiveAsync()
@@ -120,9 +120,9 @@ let tests =
                         return msg
                    } |]
                 |> Task.WhenAll
-                
-            
-            let [ one; two ] = 
+
+
+            let [ one; two ] =
                 if msg1.Data.[0] = 0uy then
                     [ msg1; msg2 ]
                 else
@@ -137,10 +137,10 @@ let tests =
             Expect.equal "" 0uy two.Data.[8_000_000]
             Expect.equal "" 1uy two.Data.[0]
             Expect.equal "" 1uy two.Data.[9_000_000]
-         
-            do! consumer.UnsubscribeAsync() 
+
+            do! consumer.UnsubscribeAsync()
             do! Task.Delay 100
-             
+
             Log.Debug("Ended Two parallel chunks-message delivered successfully with short queue")
         }
 
@@ -157,19 +157,19 @@ let tests =
                     .EnableBatching(false)
                     .EnableChunking(true)
                     .CompressionType(CompressionType.Snappy)
-                    .CreateAsync() 
+                    .CreateAsync()
 
             let! (consumer :  IConsumer<byte[]>) =
                 client.NewConsumer()
                     .Topic(topicName)
                     .ConsumerName(name)
                     .StartMessageIdInclusive()
                     .SubscriptionName("test-subscription")
-                    .SubscribeAsync() 
+                    .SubscribeAsync()
 
             let payload = Array.zeroCreate 10_000_000
             Random().NextBytes(payload)
-            
+
             let! (msgIds: MessageId[]) =
                 [| for i in 0 .. 9 do
                      producer.NewMessage(payload)
@@ -183,19 +183,19 @@ let tests =
             for i in 1 .. 9 do
                 let! (msgAfterSeek : Message<byte[]>) = consumer.ReceiveAsync()
                 Expect.equal "" msgIds.[i] msgAfterSeek.MessageId
-        
+
             do! consumer.UnsubscribeAsync()
-            
+
             let! (reader :  IReader<byte[]>) =
                 client.NewReader()
                     .Topic(topicName)
                     .StartMessageIdInclusive()
                     .StartMessageId(msgIds.[1])
                     .CreateAsync()
-                    
+
             let! (readMsg : Message<byte[]>) = reader.ReadNextAsync()
-            Expect.equal "" msgIds.[1] readMsg.MessageId      
-            
+            Expect.equal "" msgIds.[1] readMsg.MessageId
+
             Log.Debug("Ended Seek chunk messages and receive correctly")
         }
     ]
diff --git a/tests/IntegrationTests/IntegrationTests.fsproj b/tests/IntegrationTests/IntegrationTests.fsproj
@@ -8,6 +8,9 @@
   <PropertyGroup>
     <NoWarn>3186</NoWarn>
   </PropertyGroup>
+  <PropertyGroup Condition=" '$(Configuration)' == 'Debug' ">
+    <DefineConstants>TRACE;NOTLS</DefineConstants>
+  </PropertyGroup>
   <ItemGroup>
     <Compile Include="Expect.fs" />
     <Compile Include="Common.fs" />