Download plugin have progress status

DiscordBotWebUI/Components/CustomTags/ProgressDialog.razor

@@ -0,0 +1,32 @@
+@using DiscordBotWebUI.ServerCommunication.Sockets
+@inject DialogService DialogService
+
+<RadzenProgressBar Value="progressValue" ShowValue="false"/>
+
+@code {
+    private float progressValue = 0f;
+    
+    [Parameter]
+    public string ProgressUrl { get; set; }
+    
+    [Parameter]
+    public string FirstMessage { get; set; }
+
+    protected override async Task OnInitializedAsync()
+    {
+        
+        WebSocketClientService service = new WebSocketClientService();
+        await service.ConnectAsync(ProgressUrl);
+        await Task.Delay(1000);
+        await service.SendMessageAsync(FirstMessage);
+        service.OnMessageReceived += (msg) =>
+        {
+            progressValue = float.Parse(msg);
+            StateHasChanged();
+        };
+        await service.ReceiveMessages();
+        await Task.Delay(500);
+        DialogService.Close();
+    }
+
+}

DiscordBotWebUI/Components/Pages/SidebarPages/PluginMarket.razor

@@ -2,6 +2,7 @@
 @using DiscordBotWebUI.Components.CustomTags
 @using DiscordBotWebUI.Models
 @using DiscordBotWebUI.ServerCommunication
+@inject DialogService DialogService
 
 <Marketplace PluginModels="_PluginModels" OnPluginDownloadClick="OnModelSelected"/>
 
@@ -20,12 +21,22 @@
         });
         if(!response.Success)
         {
-
             Console.WriteLine(response.Message);
             return;
         }
 
-        Console.WriteLine("Plugin installed");
+        await DialogService.OpenAsync<ProgressDialog>($"Installing {itemName}", new Dictionary<string, object>()
+        {
+            {"ProgressUrl", "/plugin/download/progress"},
+            {"FirstMessage", itemName}
+        }, new DialogOptions()
+        {
+            Draggable = false,
+            CloseDialogOnEsc = false,
+            CloseDialogOnOverlayClick = false,
+            ShowClose = false
+        });
+
     }
 
     protected override async Task OnInitializedAsync()

DiscordBotWebUI/ServerCommunication/Sockets/WebSocketClientService.cs

@@ -0,0 +1,47 @@
+using System;
+using System.Net.WebSockets;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace DiscordBotWebUI.ServerCommunication.Sockets;
+
+public class WebSocketClientService
+{
+    private ClientWebSocket _webSocket;
+    public event Action<string> OnMessageReceived;
+
+    private readonly string _BaseUrl = "ws://localhost:5055";
+
+    public async Task ConnectAsync(string uri)
+    {
+        _webSocket = new ClientWebSocket();
+        await _webSocket.ConnectAsync(new Uri(_BaseUrl + uri), CancellationToken.None);
+        Console.WriteLine("Connected to WebSocket server.");
+    }
+
+    public async Task SendMessageAsync(string message)
+    {
+        var messageBytes = Encoding.UTF8.GetBytes(message);
+        await _webSocket.SendAsync(new ArraySegment<byte>(messageBytes), WebSocketMessageType.Text, true, CancellationToken.None);
+    }
+
+    public async Task ReceiveMessages()
+    {
+        byte[] buffer = new byte[102400];
+        while (_webSocket.State == WebSocketState.Open)
+        {
+            var result = await _webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
+            if (result.MessageType == WebSocketMessageType.Close)
+            {
+                await _webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, "Closing", CancellationToken.None);
+                Console.WriteLine("WebSocket connection closed.");
+            }
+            else
+            {
+                string receivedMessage = Encoding.UTF8.GetString(buffer, 0, result.Count);
+                OnMessageReceived?.Invoke(receivedMessage);
+            }
+        }
+    }
+}