using System.Drawing; using System.Runtime.CompilerServices; using Grpc.Core; using Grpc.Net.Client; using GSS2.LightsControl.CSharpClient; using Microsoft.Extensions.Logging; namespace GSS2.Core.Hardware; public class LightsService { public class LightsServiceConfiguration() { public static LightsServiceConfiguration Default => new LightsServiceConfiguration { ServerAddress = "localhost:50051" }; public string ServerAddress { get; set; } = string.Empty; } private readonly ILogger _logger; private readonly LightsServiceConfiguration _configuration; private readonly Lights.LightsClient _client; public LightsService(ILogger logger, LightsServiceConfiguration? configuration = null) { _logger = logger; _logger.LogInformation("Lights initialization"); if (configuration is null) { _logger.LogWarning("Lights configuration not set. Using default configuration."); _configuration = LightsServiceConfiguration.Default; } else { _configuration = configuration; } _logger.LogDebug(@$"Lights use following configuration: ServerAddress: {_configuration.ServerAddress} "); _client = new Lights.LightsClient(GrpcChannel.ForAddress(_configuration.ServerAddress)); } 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(Func 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(Func> 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); }