Turn on and off button thingy

src/Elektrifikatsiya/Elektrifikatsiya/Elektrifikatsiya.csproj

@@ -42,6 +42,7 @@
 		<PackageReference Include="Blazorise.Icons.Material" Version="1.2.0" />
 		<PackageReference Include="BCrypt.Net-Next" Version="4.0.3" />
 		<PackageReference Include="FluentResults" Version="3.15.2" />
+		<PackageReference Include="HiveMQtt" Version="0.1.10" />
 		<PackageReference Include="Microsoft.EntityFrameworkCore" Version="7.0.4" />
 		<PackageReference Include="Microsoft.EntityFrameworkCore.Sqlite" Version="7.0.4" />
 		<PackageReference Include="Microsoft.EntityFrameworkCore.Tools" Version="7.0.4">

src/Elektrifikatsiya/Elektrifikatsiya/Models/Device.cs

@@ -1,8 +1,6 @@
 using System.ComponentModel.DataAnnotations;
 using System.ComponentModel.DataAnnotations.Schema;
 using System.Net;
-using Microsoft.AspNetCore.Razor.TagHelpers;
-using Microsoft.AspNetCore.Server.IIS.Core;
 
 namespace Elektrifikatsiya.Models;
 
@@ -26,7 +24,7 @@ public class Device
     public string Room { get; set; }
 
     [NotMapped]
-    public bool Available { get; set; }
+    public bool Enabled { get; set; }
 
     public Device(string macAddress, string name, IPAddress address, User user, string room)
     {
@@ -37,17 +35,22 @@ public class Device
         Room = room;
     }
 
-    public static Device CopyDevice(Device device) => new Device(device.MacAddress, device.Name, device.IpAddress, device.User, device.Room);
+    public Device CopyDevice()
+    {
+        return new Device(MacAddress, Name, IpAddress, User, Room);
+    }
 
     public void OverwiteDevice(Device overwriter)
     {
-        this.Room = overwriter.Room;
-        this.Available = overwriter.Available;
-        this.PowerUsage = overwriter.PowerUsage;
-        this.Name = overwriter.Name;
-        this.User = overwriter.User;
-        this.MacAddress = overwriter.MacAddress;
-        this.IpAddress = overwriter.IpAddress;
+        Room = overwriter.Room;
+        Enabled = overwriter.Enabled;
+        PowerUsage = overwriter.PowerUsage;
+        Name = overwriter.Name;
+        User = overwriter.User;
+        MacAddress = overwriter.MacAddress;
+        IpAddress = overwriter.IpAddress;
     }
-    private Device(){}
+
+    private Device()
+    { }
 }

src/Elektrifikatsiya/Elektrifikatsiya/Pages/Dashboard.razor

@@ -9,6 +9,7 @@
 @inject IVersionProvider VersionProvider
 
 @inject IDeviceStatusService DeviceStatusService;
+@inject IDeviceManagmentService DeviceManagmentService;
 
 <Div>
     <Row Padding="Padding.Is3">
@@ -50,9 +51,8 @@
                                     </Row>
                                 </Column>
                                 <Column ColumnSize="ColumnSize.Is4">
-									<Button Position="Position.Absolute.Top.Is50.Start.Is50.Translate.Middle" Color="Color.Primary"Primary Outline>
-										<!--TODO: This button should change color-->
-										<BarIcon IconName="IconName.Bolt" />
+                                    <Button Clicked="() => Switch(context.Item)" Position="Position.Absolute.Top.Is50.Start.Is50.Translate.Middle" Color="Color.Primary" Primary Outline>
+                                        <BarIcon TextColor="(context.Item.Enabled?TextColor.Success:TextColor.Danger)" IconName="IconName.Bolt" />
                                     </Button>
                                 </Column>
                             </Row>
@@ -94,83 +94,3 @@
         </Column>
     </Row>
 </Div>
-
-
-@code {
-	//TODO: insert new event here if plug produces one
-	List<Event> events = new List<Event>() { new Event("Placeholder", "Placeholder", DateTime.Now), new Event("Placeholder", "Placeholder", DateTime.Now), new Event("Placeholder", "Placeholder", DateTime.Now) };
-	//TODO: insert new Device here if user adds one
-	List<Device> plugs = new List<Device>();
-	//code for graph
-	LineChart<double> lineChart;
-
-	protected override void OnInitialized()
-	{
-		plugs = DeviceStatusService.GetDevices().ValueOrDefault ?? new List<Device>();
-
-		DeviceStatusService.OnDeviceStatusChanged += (_, e) =>
-		{
-			InvokeAsync(StateHasChanged);
-		};
-	}
-
-	protected override async Task OnAfterRenderAsync(bool firstRender)
-	{
-		if (firstRender)
-		{
-			await HandleRedraw();
-		}
-	}
-
-	async Task HandleRedraw()
-	{
-		labels.Clear();
-		await lineChart.Clear();
-		await lineChart.AddLabelsDatasetsAndUpdate(labels, await GetLineChartDataset());
-	}
-
-	//TODO: insert dataset of current and last voltage usages
-	async Task<LineChartDataset<double>> GetLineChartDataset()
-	{
-		return new LineChartDataset<double>
-			{
-				Label = "Wattage",
-				Data = await RandomizeData(),
-				Fill = true,
-				PointRadius = 3,
-				CubicInterpolationMode = "monotone",
-			};
-	}
-
-	List<string> labels = new List<string>();
-
-	async Task<List<double>> RandomizeData()
-	{
-		PrometheusQuery promQueryer = new PrometheusQuery("http://localhost:9090");
-
-		string plugnames = "";
-		foreach (Device device in plugs)
-		{
-			plugnames += $"shellyplug-s-{device.MacAddress}/relay/0|";
-		}
-
-		if(string.IsNullOrEmpty(plugnames))
-		{
-			return new();
-		}
-
-		plugnames = plugnames[0..^1];
-
-		Debug.WriteLine($$"""sum(power{sensor=~"{{plugnames}}"})[1h:1m]""");
-
-		PrometheusDataWrapper? deviceData = (await promQueryer.Query($$"""sum(power{sensor=~"{{plugnames}}"})[1h:1m]"""))?.Data;
-
-		var r = new Random(DateTime.Now.Millisecond);
-
-		return deviceData?.MatrixTypeToTimestampFloatTuple().ValueOrDefault?.Select(x =>
-		{
-			labels.Add(DateTimeOffset.FromUnixTimeSeconds(long.Parse($"1{x.Item1}0")).UtcDateTime.ToLocalTime().ToShortTimeString());
-			return x.Item2;
-		}).ToList() ?? new List<double>();
-	}
-}

src/Elektrifikatsiya/Elektrifikatsiya/Pages/Dashboard.razor.cs

@@ -1,23 +1,97 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Threading.Tasks;
-using Microsoft.AspNetCore.Components;
-using System.Net.Http;
-using Microsoft.AspNetCore.Authorization;
-using Microsoft.AspNetCore.Components.Authorization;
-using Microsoft.AspNetCore.Components.Forms;
-using Microsoft.AspNetCore.Components.Routing;
-using Microsoft.AspNetCore.Components.Web;
-using Microsoft.AspNetCore.Components.Web.Virtualization;
-using Microsoft.JSInterop;
-using Elektrifikatsiya;
-using Blazorise;
+using Blazorise.Charts;
+
+using Elektrifikatsiya.Models;
+using Elektrifikatsiya.Utilities;
+
+using System.Diagnostics;
+using System.Text;
+
+namespace Elektrifikatsiya.Pages;
 
-namespace Elektrifikatsiya.Pages
-{
 public partial class Dashboard
 {
+    //TODO: insert new event here if plug produces one
+    private readonly List<Event> events = new List<Event>() { new Event("Placeholder", "Placeholder", DateTime.Now), new Event("Placeholder", "Placeholder", DateTime.Now), new Event("Placeholder", "Placeholder", DateTime.Now) };
 
+    //TODO: insert new Device here if user adds one
+    private List<Device> plugs = new List<Device>();
+
+    //code for graph
+    private LineChart<double> lineChart;
+
+    protected override void OnInitialized()
+    {
+        plugs = DeviceStatusService.GetDevices().ValueOrDefault ?? new List<Device>();
+
+        DeviceStatusService.OnDeviceStatusChanged += (_, e) =>
+        {
+            _ = InvokeAsync(StateHasChanged);
+        };
+    }
+
+    protected override async Task OnAfterRenderAsync(bool firstRender)
+    {
+        if (firstRender)
+        {
+            await HandleRedraw();
+        }
+    }
+
+    private async Task Switch(Device device)
+    {
+        device.Enabled = !device.Enabled;
+        _ = await DeviceManagmentService.UpdateDevice(device);
+    }
+
+    private async Task HandleRedraw()
+    {
+        labels.Clear();
+        await lineChart.Clear();
+        await lineChart.AddLabelsDatasetsAndUpdate(labels, await GetLineChartDataset());
+    }
+
+    //TODO: insert dataset of current and last voltage usages
+    private async Task<LineChartDataset<double>> GetLineChartDataset()
+    {
+        return new LineChartDataset<double>
+        {
+            Label = "Wattage",
+            Data = await DeviceData(),
+            Fill = true,
+            PointRadius = 3,
+            CubicInterpolationMode = "monotone",
+        };
+    }
+
+    private readonly List<string> labels = new List<string>();
+
+    private async Task<List<double>> DeviceData()
+    {
+        PrometheusQuery promQueryer = new PrometheusQuery("http://localhost:9090");
+
+        StringBuilder builder = new();
+        foreach (Device device in plugs)
+        {
+            _ = builder.Append($"shellyplug-s-{device.MacAddress}/relay/0|");
+        }
+
+        if (builder.Length <= 1)
+        {
+            return new();
+        }
+
+        string plugnames = builder.ToString()[..^1];
+
+        Debug.WriteLine($$"""sum(power{sensor=~"{{plugnames}}"})[1h:1m]""");
+
+        PrometheusDataWrapper? deviceData = (await promQueryer.Query($$"""sum(power{sensor=~"{{plugnames}}"})[1h:1m]"""))?.Data;
+
+        Random r = new Random(DateTime.Now.Millisecond);
+
+        return deviceData?.MatrixTypeToTimestampFloatTuple().ValueOrDefault?.Select(x =>
+        {
+            labels.Add(DateTimeOffset.FromUnixTimeSeconds(long.Parse($"1{x.Item1}0")).UtcDateTime.ToLocalTime().ToShortTimeString());
+            return x.Item2;
+        }).ToList() ?? new List<double>();
     }
 }

src/Elektrifikatsiya/Elektrifikatsiya/Pages/Settings.razor

@@ -172,7 +172,7 @@
 	{
 		hideButtonSettings = !hideButtonSettings;
 		SelectedDevice = device;
-		DeviceCopy = Device.CopyDevice(device);
+		DeviceCopy = device.CopyDevice();
 	}
 
 	private void OnSave()

src/Elektrifikatsiya/Elektrifikatsiya/Program.cs

@@ -8,6 +8,9 @@ using Elektrifikatsiya.Models;
 using Elektrifikatsiya.Services;
 using Elektrifikatsiya.Services.Implementations;
 
+using HiveMQtt.Client;
+using HiveMQtt.Client.Options;
+
 using Microsoft.EntityFrameworkCore;
 
 WebApplicationBuilder builder = WebApplication.CreateBuilder(args);
@@ -18,6 +21,19 @@ builder.Services.AddServerSideBlazor();
 builder.Services.AddHttpContextAccessor();
 builder.Services.AddHostedService<UpdateService>();
 builder.Services.AddSingleton<IDeviceStatusService, DeviceStatusService>();
+builder.Services.AddSingleton<IHiveMQClient, HiveMQClient>((provider)=>
+{
+	HiveMQClientOptions options = new()
+	{
+		Host = "localhost",
+		Port = 1883,
+		UseTLS = false,
+	};
+
+	HiveMQClient client =  new(options);
+	client.ConnectAsync().ConfigureAwait(false);
+	return client;
+});
 builder.Services.AddTransient<IDeviceManagmentService, DeviceManagmentService>();
 builder.Services.AddScoped<IAuthenticationService, AuthenticationService>();
 builder.Services.AddScoped<IAuthorizationService, AuthorizationService>();

src/Elektrifikatsiya/Elektrifikatsiya/Services/Implementations/DeviceManagmentService.cs

@@ -3,9 +3,13 @@ using Elektrifikatsiya.Models;
 
 using FluentResults;
 
+using HiveMQtt.Client;
+using HiveMQtt.Client.Results;
+
+using Microsoft.EntityFrameworkCore;
+
 using System.Net;
 using System.Net.NetworkInformation;
-using Microsoft.EntityFrameworkCore;
 
 namespace Elektrifikatsiya.Services.Implementations;
 
@@ -14,13 +18,15 @@ public class DeviceManagmentService : IDeviceManagmentService
     private readonly IServiceScopeFactory serviceScopeFactory;
     private readonly IDeviceStatusService deviceStatusService;
     private readonly ILogger<DeviceManagmentService> logger;
+    private readonly IHiveMQClient hiveMQClient;
     private readonly HttpClient httpClient;
 
-    public DeviceManagmentService(IServiceScopeFactory serviceScopeFactory, IDeviceStatusService deviceStatusService, ILogger<DeviceManagmentService> logger, HttpClient httpClient)
+    public DeviceManagmentService(IServiceScopeFactory serviceScopeFactory, IDeviceStatusService deviceStatusService, ILogger<DeviceManagmentService> logger, IHiveMQClient hiveMQClient, HttpClient httpClient)
     {
         this.serviceScopeFactory = serviceScopeFactory;
         this.deviceStatusService = deviceStatusService;
         this.logger = logger;
+        this.hiveMQClient = hiveMQClient;
         this.httpClient = httpClient;
     }
 
@@ -151,13 +157,22 @@ public class DeviceManagmentService : IDeviceManagmentService
         using IServiceScope scope = serviceScopeFactory.CreateScope();
         MainDatabaseContext mainDatabaseContext = scope.ServiceProvider.GetRequiredService<MainDatabaseContext>();
 
-        Result result = deviceStatusService.UpdateDeviceStatus(device);
+        Result<Device> getDeviceResult = GetDevice(device.MacAddress);
 
-        if (result.IsFailed)
+        if (getDeviceResult.IsFailed)
         {
-            return result;
+            return getDeviceResult.ToResult();
         }
 
+        Result updateDeviceResult = deviceStatusService.UpdateDeviceStatus(device);
+
+        if (updateDeviceResult.IsFailed)
+        {
+            return updateDeviceResult;
+        }
+
+        PublishResult res = await hiveMQClient.PublishAsync($"shellies/shellyplug-s-{device.MacAddress}/relay/0/command", device.Enabled ? "on" : "off");
+
         _ = mainDatabaseContext.Update(device);
 
         return await Result.Try(Task () => mainDatabaseContext.SaveChangesAsync());

src/Elektrifikatsiya/Elektrifikatsiya/Services/Implementations/DeviceStatusService.cs

@@ -7,6 +7,7 @@ namespace Elektrifikatsiya.Services.Implementations;
 public class DeviceStatusService : IDeviceStatusService
 {
     private readonly ILogger<DeviceStatusService> logger;
+
     public event EventHandler<DeviceStatusChagedEventArgs>? OnDeviceStatusChanged;
 
     private readonly Dictionary<string, Device> devices = new();
@@ -15,6 +16,7 @@ public class DeviceStatusService : IDeviceStatusService
     {
         this.logger = logger;
     }
+
     public Result<List<Device>> GetDevices()
     {
         return devices.Values.ToList();
@@ -30,7 +32,7 @@ public class DeviceStatusService : IDeviceStatusService
         }
 
         modDevice.PowerUsage = device.PowerUsage;
-        modDevice.Available = device.Available;
+        modDevice.Enabled = device.Enabled;
         modDevice.IpAddress = device.IpAddress;
         modDevice.Name = device.Name;
 

src/Elektrifikatsiya/Elektrifikatsiya/Services/Implementations/UpdateService.cs

@@ -1,6 +1,7 @@
 using Elektrifikatsiya.Database;
 using Elektrifikatsiya.Models;
 using Elektrifikatsiya.Utilities;
+
 using FluentResults;
 
 using Microsoft.EntityFrameworkCore;
@@ -49,12 +50,14 @@ public class UpdateService : IHostedService, IDisposable
         PrometheusQuery promQueryer = new PrometheusQuery("http://localhost:9090");
         foreach (Device device in getDeviceStatusResult.Value)
         {
-			PrometheusDataWrapper? deviceData = (await promQueryer.Query($"power{{sensor=\"shellyplug-s-{device.MacAddress}/relay/0\"}}"))?.Data;
+            PrometheusDataWrapper? devicePowerData = (await promQueryer.Query($"power{{sensor=\"shellyplug-s-{device.MacAddress}/relay/0\"}}"))?.Data;
+            PrometheusDataWrapper? deviceStatusData = (await promQueryer.Query($"state{{sensor=\"shellyplug-s-{device.MacAddress}/relay\"}}"))?.Data;
 
-			if (deviceData is not null)
+            if (devicePowerData is not null && deviceStatusData is not null)
             {
-				device.PowerUsage = deviceData.VectorTypeToTimestampFloatTuple()?.ValueOrDefault.Item2 ?? 0;
-                deviceStatusService.UpdateDeviceStatus(device);
+                device.PowerUsage = devicePowerData.VectorTypeToTimestampFloatTuple()?.ValueOrDefault.Item2 ?? 0;
+                device.Enabled = (deviceStatusData.VectorTypeToTimestampFloatTuple()?.ValueOrDefault.Item2 ?? 0) == 1;
+                _ = deviceStatusService.UpdateDeviceStatus(device);
             }
         }
     }