GSS2Rework/GSS2.Core/Hardware/LightsService.cs

using System.Drawing;
using System.Runtime.CompilerServices;

using Microsoft.Extensions.Logging;

using Grpc.Core;
using Grpc.Net.Client;

using GSS2.LightsControl.CSharpClient;
using GSS2.Core.Abstractions;

namespace GSS2.Core.Hardware;

public class LightsService
{
    public record LightsServiceConfiguration : ServiceConfigurationBase
    {
        public static LightsServiceConfiguration Default => new LightsServiceConfiguration
        {
            ServerAddress = "localhost:50051"
        };

        public string ServerAddress { get; set; } = string.Empty;
    }

    private readonly ILogger<LightsService> _logger;
    private readonly LightsServiceConfiguration _configuration;
    private readonly Lights.LightsClient _client;

    public LightsService(ILogger<LightsService> logger, LightsServiceConfiguration? configuration = null)
    {
        _logger = logger;

        _logger.LogInformation("Initialization");

        try
        {
            if (configuration is null)
            {
                configuration = LightsServiceConfiguration.Default;
                _logger.LogWarning("Configuration not set. Using default configuration.");
            }
            _configuration = configuration;
            _logger.LogInformation("Using following configuration: \n{}", _configuration.ToString("\n", 4));

            _client = new Lights.LightsClient(GrpcChannel.ForAddress(_configuration.ServerAddress));
        }
        catch (Exception e)
        {
            _logger.LogCritical(e, "An exception occurred while initialization");
            throw;
        }

        _logger.LogInformation("Initialized");
    }

    public async Task Run(CancellationToken cancellationToken)
    {
        _logger.LogInformation("LightsService started");

        while (!cancellationToken.IsCancellationRequested)
        {
            await PingAsync(cancellationToken);
            try
            {
                await Task.Delay(TimeSpan.FromMinutes(1), cancellationToken);
            }
            catch (TaskCanceledException)
            {
                break;
            }
        }

        _logger.LogInformation("LightsService stopped");
    }

    private void SendRequest<T>(Func<T, Metadata, DateTime?, CancellationToken, Empty> method, T request, CancellationToken cancellationToken = default, [CallerMemberName] string sender = "")
    {
        try
        {
#pragma warning disable CS8625
            method.Invoke(request, null, null, cancellationToken); ;
#pragma warning restore CS8625
            _logger.LogTrace("Request \"{}\" sent", sender);
        }
        catch (RpcException ex)
        {
            _logger.LogWarning(ex, "Request \"{}\" RPC error", sender);
        }
        catch (Exception ex)
        {
            _logger.LogWarning(ex, "Request \"{}\" Unexpected error", method);
        }
    }
    private async Task SendRequestAsync<T>(Func<T, Metadata, DateTime?, CancellationToken, AsyncUnaryCall<Empty>> method, T request, CancellationToken cancellationToken = default, [CallerMemberName] string sender = "")
    {
        try
        {
#pragma warning disable CS8625
            await method.Invoke(request, null, null, cancellationToken); ;
#pragma warning restore CS8625
            _logger.LogTrace("Request \"{}\" sent", sender);
        }
        catch (RpcException ex)
        {
            _logger.LogWarning(ex, "Request \"{}\" RPC error", sender);
        }
        catch (Exception ex)
        {
            _logger.LogWarning(ex, "Request \"{}\" Unexpected error", method);
        }
    }

    public void Ping(CancellationToken cancellationToken = default) => SendRequest(_client.Ping, new Empty(), cancellationToken);
    public void Disconnect(CancellationToken cancellationToken = default) => SendRequest(_client.Disconnect, new Empty(), cancellationToken);
    public void Off(CancellationToken cancellationToken = default) => SendRequest(_client.SetOff, new Empty(), cancellationToken);
    public void StaticColor(double brightness, Color color, CancellationToken cancellationToken = default) => SendRequest(_client.SetStaticColor, new StaticColorRequest
    {
        Brightness = brightness,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);
    public void StaticGradient2(double brightness, Color leftColor, Color rightColor, CancellationToken cancellationToken = default) => SendRequest(_client.SetStaticGradient2, new StaticGradient2Request
    {
        Brightness = brightness,
        LeftR = leftColor.R,
        LeftG = leftColor.G,
        LeftB = leftColor.B,
        RightR = rightColor.R,
        RightG = rightColor.G,
        RightB = rightColor.B
    }, cancellationToken);
    public void StaticGradient3(double brightness, Color leftColor, Color middleColor, Color rightColor, CancellationToken cancellationToken = default) => SendRequest(_client.SetStaticGradient3, new StaticGradient3Request
    {
        Brightness = brightness,
        LeftR = leftColor.R,
        LeftG = leftColor.G,
        LeftB = leftColor.B,
        MiddleR = middleColor.R,
        MiddleG = middleColor.G,
        MiddleB = middleColor.B,
        RightR = rightColor.R,
        RightG = rightColor.G,
        RightB = rightColor.B
    }, cancellationToken);
    public void StaticRainbow(double brightness, CancellationToken cancellationToken = default) => SendRequest(_client.SetStaticRainbow, new StaticRainbowRequest
    {
        Brightness = brightness
    }, cancellationToken);
    public void BreathingColor(double brightness, double speed, Color color, CancellationToken cancellationToken = default) => SendRequest(_client.SetBreathingColor, new BreathingColorRequest
    {
        Brightness = brightness,
        Speed = speed,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);
    public void BreathingGradient2(double brightness, double speed, Color leftColor, Color rightColor, CancellationToken cancellationToken = default) => SendRequest(_client.SetBreathingGradient2, new BreathingGradient2Request
    {
        Brightness = brightness,
        Speed = speed,
        LeftR = leftColor.R,
        LeftG = leftColor.G,
        LeftB = leftColor.B,
        RightR = rightColor.R,
        RightG = rightColor.G,
        RightB = rightColor.B
    }, cancellationToken);
    public void BreathingGradient3(double brightness, double speed, Color leftColor, Color middleColor, Color rightColor, CancellationToken cancellationToken = default) => SendRequest(_client.SetBreathingGradient3, new BreathingGradient3Request
    {
        Brightness = brightness,
        Speed = speed,
        LeftR = leftColor.R,
        LeftG = leftColor.G,
        LeftB = leftColor.B,
        MiddleR = middleColor.R,
        MiddleG = middleColor.G,
        MiddleB = middleColor.B,
        RightR = rightColor.R,
        RightG = rightColor.G,
        RightB = rightColor.B
    }, cancellationToken);
    public void BreathingRainbow(double brightness, double speed, CancellationToken cancellationToken = default) => SendRequest(_client.SetBreathingRainbow, new BreathingRainbowRequest
    {
        Brightness = brightness,
        Speed = speed
    }, cancellationToken);
    public void RunningColor(double brightness, double speed, int length, int fade, Color color, CancellationToken cancellationToken = default) => SendRequest(_client.SetRunningColor, new RunningColorRequest
    {
        Brightness = brightness,
        Speed = speed,
        Length = length,
        Fade = fade,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);
    public void RunningGradient2(double brightness, double speed, Color leftColor, Color rightColor, CancellationToken cancellationToken = default) => SendRequest(_client.SetRunningGradient2, new RunningGradient2Request
    {
        Brightness = brightness,
        Speed = speed,
        LeftR = leftColor.R,
        LeftG = leftColor.G,
        LeftB = leftColor.B,
        RightR = rightColor.R,
        RightG = rightColor.G,
        RightB = rightColor.B
    }, cancellationToken);
    public void RunningGradient3(double brightness, double speed, Color leftColor, Color middleColor, Color rightColor, CancellationToken cancellationToken = default) => SendRequest(_client.SetRunningGradient3, new RunningGradient3Request
    {
        Brightness = brightness,
        Speed = speed,
        LeftR = leftColor.R,
        LeftG = leftColor.G,
        LeftB = leftColor.B,
        MiddleR = middleColor.R,
        MiddleG = middleColor.G,
        MiddleB = middleColor.B,
        RightR = rightColor.R,
        RightG = rightColor.G,
        RightB = rightColor.B
    }, cancellationToken);
    public void RunningRainbow(double brightness, double speed, CancellationToken cancellationToken = default) => SendRequest(_client.SetRunningRainbow, new RunningRainbowRequest
    {
        Brightness = brightness,
        Speed = speed
    }, cancellationToken);
    public void Snake(double brightness, double speed, int headLength, int tailLength, Color headColor, Color tailColor, CancellationToken cancellationToken = default) => SendRequest(_client.SetSnake, new SnakeRequest
    {
        Brightness = brightness,
        Speed = speed,
        HeadLength = headLength,
        TailLength = tailLength,
        HeadR = headColor.R,
        HeadG = headColor.G,
        HeadB = headColor.B,
        TailR = tailColor.R,
        TailG = tailColor.G,
        TailB = tailColor.B
    }, cancellationToken);
    public void Fire(double brightness, double speed, Color color, CancellationToken cancellationToken = default) => SendRequest(_client.SetFire, new FireRequest
    {
        Brightness = brightness,
        Speed = speed,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);
    public void Snowfall(double brightness, double speed, Color color, CancellationToken cancellationToken = default) => SendRequest(_client.SetSnowfall, new SnowfallRequest
    {
        Brightness = brightness,
        Speed = speed,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);
    public void Flash(double brightness, double speed, Color color, CancellationToken cancellationToken = default) => SendRequest(_client.SetFlash, new FlashRequest
    {
        Brightness = brightness,
        Speed = speed,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);
    public void Load(double brightness, double speed, double percent, double lastPercent, Color color, CancellationToken cancellationToken = default) => SendRequest(_client.SetLoad, new LoadRequest
    {
        Brightness = brightness,
        Speed = speed,
        Percent = percent,
        LastPercent = lastPercent,
        R = color.R,
        G = color.G,
        B = color.B,
    }, cancellationToken);
    public void CpuLoad(double brightness, double speed, Color color, CancellationToken cancellationToken = default) => SendRequest(_client.SetCpuLoad, new CpuLoadRequest
    {
        Brightness = brightness,
        Speed = speed,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);

    public async Task PingAsync(CancellationToken cancellationToken = default) => await SendRequestAsync(_client.PingAsync, new Empty(), cancellationToken);
    public async Task DisconnectAsync(CancellationToken cancellationToken = default) => await SendRequestAsync(_client.DisconnectAsync, new Empty(), cancellationToken);
    public async Task OffAsync(CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetOffAsync, new Empty(), cancellationToken);
    public async Task StaticColorAsync(double brightness, Color color, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetStaticColorAsync, new StaticColorRequest
    {
        Brightness = brightness,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);
    public async Task StaticGradient2Async(double brightness, Color leftColor, Color rightColor, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetStaticGradient2Async, new StaticGradient2Request
    {
        Brightness = brightness,
        LeftR = leftColor.R,
        LeftG = leftColor.G,
        LeftB = leftColor.B,
        RightR = rightColor.R,
        RightG = rightColor.G,
        RightB = rightColor.B
    }, cancellationToken);
    public async Task StaticGradient3Async(double brightness, Color leftColor, Color middleColor, Color rightColor, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetStaticGradient3Async, new StaticGradient3Request
    {
        Brightness = brightness,
        LeftR = leftColor.R,
        LeftG = leftColor.G,
        LeftB = leftColor.B,
        MiddleR = middleColor.R,
        MiddleG = middleColor.G,
        MiddleB = middleColor.B,
        RightR = rightColor.R,
        RightG = rightColor.G,
        RightB = rightColor.B
    }, cancellationToken);
    public async Task StaticRainbowAsync(double brightness, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetStaticRainbowAsync, new StaticRainbowRequest
    {
        Brightness = brightness
    }, cancellationToken);
    public async Task BreathingColorAsync(double brightness, double speed, Color color, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetBreathingColorAsync, new BreathingColorRequest
    {
        Brightness = brightness,
        Speed = speed,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);
    public async Task BreathingGradient2Async(double brightness, double speed, Color leftColor, Color rightColor, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetBreathingGradient2Async, new BreathingGradient2Request
    {
        Brightness = brightness,
        Speed = speed,
        LeftR = leftColor.R,
        LeftG = leftColor.G,
        LeftB = leftColor.B,
        RightR = rightColor.R,
        RightG = rightColor.G,
        RightB = rightColor.B
    }, cancellationToken);
    public async Task BreathingGradient3Async(double brightness, double speed, Color leftColor, Color middleColor, Color rightColor, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetBreathingGradient3Async, new BreathingGradient3Request
    {
        Brightness = brightness,
        Speed = speed,
        LeftR = leftColor.R,
        LeftG = leftColor.G,
        LeftB = leftColor.B,
        MiddleR = middleColor.R,
        MiddleG = middleColor.G,
        MiddleB = middleColor.B,
        RightR = rightColor.R,
        RightG = rightColor.G,
        RightB = rightColor.B
    }, cancellationToken);
    public async Task BreathingRainbowAsync(double brightness, double speed, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetBreathingRainbowAsync, new BreathingRainbowRequest
    {
        Brightness = brightness,
        Speed = speed
    }, cancellationToken);
    public async Task RunningColorAsync(double brightness, double speed, int length, int fade, Color color, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetRunningColorAsync, new RunningColorRequest
    {
        Brightness = brightness,
        Speed = speed,
        Length = length,
        Fade = fade,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);
    public async Task RunningGradient2Async(double brightness, double speed, Color leftColor, Color rightColor, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetRunningGradient2Async, new RunningGradient2Request
    {
        Brightness = brightness,
        Speed = speed,
        LeftR = leftColor.R,
        LeftG = leftColor.G,
        LeftB = leftColor.B,
        RightR = rightColor.R,
        RightG = rightColor.G,
        RightB = rightColor.B
    }, cancellationToken);
    public async Task RunningGradient3Async(double brightness, double speed, Color leftColor, Color middleColor, Color rightColor, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetRunningGradient3Async, new RunningGradient3Request
    {
        Brightness = brightness,
        Speed = speed,
        LeftR = leftColor.R,
        LeftG = leftColor.G,
        LeftB = leftColor.B,
        MiddleR = middleColor.R,
        MiddleG = middleColor.G,
        MiddleB = middleColor.B,
        RightR = rightColor.R,
        RightG = rightColor.G,
        RightB = rightColor.B
    }, cancellationToken);
    public async Task RunningRainbowAsync(double brightness, double speed, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetRunningRainbowAsync, new RunningRainbowRequest
    {
        Brightness = brightness,
        Speed = speed
    }, cancellationToken);
    public async Task SnakeAsync(double brightness, double speed, int headLength, int tailLength, Color headColor, Color tailColor, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetSnakeAsync, new SnakeRequest
    {
        Brightness = brightness,
        Speed = speed,
        HeadLength = headLength,
        TailLength = tailLength,
        HeadR = headColor.R,
        HeadG = headColor.G,
        HeadB = headColor.B,
        TailR = tailColor.R,
        TailG = tailColor.G,
        TailB = tailColor.B
    }, cancellationToken);
    public async Task FireAsync(double brightness, double speed, Color color, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetFireAsync, new FireRequest
    {
        Brightness = brightness,
        Speed = speed,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);
    public async Task SnowfallAsync(double brightness, double speed, Color color, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetSnowfallAsync, new SnowfallRequest
    {
        Brightness = brightness,
        Speed = speed,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);
    public async Task FlashAsync(double brightness, double speed, Color color, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetFlashAsync, new FlashRequest
    {
        Brightness = brightness,
        Speed = speed,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);
    public async Task LoadAsync(double brightness, double speed, double percent, double lastPercent, Color color, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetLoadAsync, new LoadRequest
    {
        Brightness = brightness,
        Speed = speed,
        Percent = percent,
        LastPercent = lastPercent,
        R = color.R,
        G = color.G,
        B = color.B,
    }, cancellationToken);
    public async Task CpuLoadAsync(double brightness, double speed, Color color, CancellationToken cancellationToken = default) => await SendRequestAsync(_client.SetCpuLoadAsync, new CpuLoadRequest
    {
        Brightness = brightness,
        Speed = speed,
        R = color.R,
        G = color.G,
        B = color.B
    }, cancellationToken);
}