add corsair v4 device

Project-Aurora/AuroraDeviceManager/AuroraDeviceManager.csproj

@@ -75,6 +75,10 @@
             <HintPath>.\RGB.NET.Devices.OpenRGB.dll</HintPath>
             <Private>true</Private>
         </Reference>
+        <Reference Include="RGB.NET.Devices.Corsair">
+            <HintPath>.\RGB.NET.Devices.Corsair.dll</HintPath>
+            <Private>true</Private>
+        </Reference>
         <Reference Include="RGB.NET.Devices.Bloody">
             <HintPath>.\RGB.NET.Devices.Bloody.dll</HintPath>
             <Private>true</Private>

Project-Aurora/AuroraDeviceManager/Devices/RGBNet/Implementations/NewCorsairRgbNetDevice.cs

@@ -0,0 +1,92 @@
+using AuroraDeviceManager.Utils;
+using Common.Devices;
+using Common.Utils;
+using RGB.NET.Core;
+using RGB.NET.Devices.Corsair;
+
+namespace AuroraDeviceManager.Devices.RGBNet.Implementations;
+
+public class NewCorsairRgbNetDevice : RgbNetDevice
+{
+    protected override CorsairDeviceProvider Provider => CorsairDeviceProvider.Instance;
+
+    public override string DeviceName => "Corsair v4 (RGB.NET)";
+
+    protected override void RegisterVariables(VariableRegistry variableRegistry)
+    {
+        base.RegisterVariables(variableRegistry);
+
+        variableRegistry.Register($"{DeviceName}_exclusive", false, "Request exclusive control");
+    }
+
+    public override bool HotplugEnabled()
+    {
+        return true;
+    }
+
+    protected override bool OnShutdown()
+    {
+        base.OnShutdown();
+
+        return !App.Closing;
+    }
+
+    protected override async Task ConfigureProvider(CancellationToken cancellationToken)
+    {
+        await base.ConfigureProvider(cancellationToken);
+
+        var waitSessionUnlock = await DesktopUtils.WaitSessionUnlock();
+        if (waitSessionUnlock)
+        {
+            Global.Logger.Information("Waiting for Corsair to load after unlock");
+            await Task.Delay(5000, cancellationToken);
+        }
+
+        var isIcueRunning = ProcessUtils.IsProcessRunning("icue");
+        if (!isIcueRunning)
+        {
+            throw new DeviceProviderException(new ApplicationException("iCUE is not running!"), false);
+        }
+
+        if (!IsNamedPipeOpen("iCUESDKv4"))
+        {
+            throw new DeviceProviderException(new ApplicationException("iCUE SDK not started yet!"), false);
+        }
+
+        var exclusive = Global.DeviceConfig.VarRegistry.GetVariable<bool>($"{DeviceName}_exclusive");
+
+        CorsairDeviceProvider.ExclusiveAccess = exclusive;
+        CorsairDeviceProvider.ConnectionTimeout = new TimeSpan(0, 0, 5);
+
+        Provider.SessionStateChanged += SessionStateChanged;
+    }
+
+
+    private void SessionStateChanged(object? sender, CorsairSessionState e)
+    {
+        if (e != CorsairSessionState.Closed) return;
+        Provider.SessionStateChanged -= SessionStateChanged;
+
+        IsInitialized = false;
+    }
+
+    private static bool IsNamedPipeOpen(string pipeName)
+    {
+        try
+        {
+            using var fileStream = new FileStream(@"\\.\pipe\" + pipeName, FileMode.Open, FileAccess.ReadWrite, FileShare.None);
+            // If the FileStream can be opened, the named pipe exists and is open
+            return true;
+        }
+        catch (IOException)
+        {
+            // IOException will be thrown if the pipe does not exist or is not available
+            return false;
+        }
+        catch (UnauthorizedAccessException)
+        {
+            // Handle access issues if necessary
+            return false;
+        }
+    }
+}

Project-Aurora/AuroraDeviceManager/Devices/RGBNet/RgbNetDevice.cs

@@ -198,6 +198,10 @@ private void RemapDeviceKeys(Dictionary<string, DeviceRemap> rgbNetConfigDevices
     [MethodImpl(MethodImplOptions.Synchronized)]
     protected override Task Shutdown()
     {
+        if (!IsInitialized)
+        {
+            return Task.CompletedTask;
+        }
         if (!OnShutdown())
         {
             return Task.CompletedTask;