Adding unit tests to Recording Redis Version changes

Author: vaishalitvv

src/VirtualClient/VirtualClient.Actions.UnitTests/Redis/RedisServerExecutorTests.cs

@@ -3,15 +3,20 @@
 
 namespace VirtualClient.Actions
 {
+    using Microsoft.Extensions.DependencyInjection;
+    using Moq;
+    using NUnit.Framework;
     using System;
     using System.Collections.Generic;
+    using System.IO;
+    using System.Linq;
     using System.Net;
+    using System.Text;
+    using System.Text.RegularExpressions;
     using System.Threading;
     using System.Threading.Tasks;
-    using Microsoft.Extensions.DependencyInjection;
-    using Moq;
-    using NUnit.Framework;
     using VirtualClient.Actions.Memtier;
+    using VirtualClient.Common;
     using VirtualClient.Common.Telemetry;
     using VirtualClient.Contracts;
 
@@ -21,13 +26,19 @@ public class RedisServerExecutorTests
     {
         private MockFixture fixture;
         private DependencyPath mockRedisPackage;
+        private InMemoryProcess memoryProcess;
 
         [SetUp]
         public void SetupTests()
         {
             this.fixture = new MockFixture();
             this.fixture.Setup(PlatformID.Unix);
-
+            this.memoryProcess = new InMemoryProcess
+            {
+                ExitCode = 0,
+                OnStart = () => true,
+                OnHasExited = () => true
+            };
             this.mockRedisPackage = new DependencyPath("redis", this.fixture.GetPackagePath("redis"));
 
             this.fixture.Parameters = new Dictionary<string, IConvertible>()
@@ -83,6 +94,11 @@ public async Task RedisMemtierServerExecutorExecutesExpectedProcessWhenBindingTo
 
                 this.fixture.ProcessManager.OnCreateProcess = (exe, arguments, workingDirectory) =>
                 {
+                    if (arguments.Contains("redis-cli INFO SERVER"))
+                    {
+                        this.memoryProcess.StandardOutput = new ConcurrentBuffer(new StringBuilder("redis_version:7.0.15"));
+                        return this.memoryProcess;
+                    }
                     expectedCommands.Remove($"{exe} {arguments}");
                     return this.fixture.Process;
                 };
@@ -113,6 +129,11 @@ public async Task RedisMemtierServerExecutorExecutesExpectedProcessWhenBindingTo
 
                 this.fixture.ProcessManager.OnCreateProcess = (exe, arguments, workingDirectory) =>
                 {
+                    if (arguments.Contains("redis-cli INFO SERVER"))
+                    {
+                        this.memoryProcess.StandardOutput = new ConcurrentBuffer(new StringBuilder("redis_version:7.0.15"));
+                        return this.memoryProcess;
+                    }
                     expectedCommands.Remove($"{exe} {arguments}");
                     return this.fixture.Process;
                 };
@@ -140,6 +161,11 @@ public async Task RedisMemtierServerExecutorExecutesExpectedProcessWhenNotBindin
 
                 this.fixture.ProcessManager.OnCreateProcess = (exe, arguments, workingDirectory) =>
                 {
+                    if (arguments.Contains("redis-cli INFO SERVER"))
+                    {
+                        this.memoryProcess.StandardOutput = new ConcurrentBuffer(new StringBuilder("redis_version:7.0.15"));
+                        return this.memoryProcess;
+                    }
                     expectedCommands.Remove($"{exe} {arguments}");
                     return this.fixture.Process;
                 };
@@ -149,6 +175,37 @@ public async Task RedisMemtierServerExecutorExecutesExpectedProcessWhenNotBindin
             }
         }
 
+        [Test]
+        public async Task RedisServerExecutorCapturesRedisVersionSuccessfully()
+        {
+            using (var executor = new TestRedisServerExecutor(this.fixture.Dependencies, this.fixture.Parameters))
+            {
+                this.fixture.ProcessManager.OnCreateProcess = (command, arguments, workingDirectory) =>
+                {
+                    if (arguments.Contains("redis-cli INFO SERVER"))
+                    {
+                        this.memoryProcess.StandardOutput = new ConcurrentBuffer(new StringBuilder("redis_version:7.0.15"));
+                    }
+                    return this.memoryProcess;
+                };
+
+                // Act
+                await executor.ExecuteAsync(CancellationToken.None);
+
+                // Assert
+                var messages = this.fixture.Logger.MessagesLogged($"{nameof(TestRedisServerExecutor)}.RedisVersionCaptured");
+                Assert.IsNotEmpty(messages, "Expected at least one log message indicating the Redis version was captured2.");
+                bool versionCapturedCorrectly = messages.Any(msg =>
+                {
+                    var eventContext = msg.Item3 as EventContext;
+                    return eventContext != null &&
+                           eventContext.Properties.ContainsKey("redisVersion") &&
+                           eventContext.Properties["redisVersion"].ToString() == "7.0.15";
+                });
+                Assert.IsTrue(versionCapturedCorrectly, "The Redis version '7.0.15' was not captured correctly in the logs.");
+            }
+        }
+
         private class TestRedisServerExecutor : RedisServerExecutor
         {
             public TestRedisServerExecutor(IServiceCollection services, IDictionary<string, IConvertible> parameters = null)