EEMS/TestSignalRClient/HubSender.cs

using Microsoft.AspNetCore.SignalR.Client;
using System.Threading.Channels;
using System.Threading.Tasks;
using Universal;

namespace TestSignalRClient;

internal class HubSender : SenderBase
{
    public bool Initialize(string ip, int port, string hub, int retry = 40)
    {
        if (_hubConnection is not null)
            return false;

        HubConnection temp = new HubConnectionBuilder()
            .WithUrl($"http://{ip}:{port}/{hub}")
            .WithAutomaticReconnect()
            .Build();

        //temp.On<byte, Mini8Data>("UpdateMini8", UpdateMini8);
        //temp.On<byte, byte, ChannelData>("UpdateSingleChannel", receiver.UpdateSingleChannel);
        //temp.On<byte, List<ChannelData>>("UpdateChannel", receiver.UpdateChannels);
        //temp.On<TemperatureConfig>("UpdateFiles", receiver.UpdateFiles);
        //temp.On("ClearFiles", receiver.ClearFiles);
        //temp.On<byte, Mini8Address>("UpdateAddress", receiver.UpdateAddress);
        //temp.On<TemperatureConfig>("CurrentFile", receiver.CurrentFile);
        //temp.On<byte, byte, float>("AlarmNotify", receiver.AlarmNotify);
        //temp.On<byte, byte>("AlarmTcBrockenNotify", receiver.AlarmTcBrockenNotify);
        //temp.On<byte, bool>("Mini8Connect", receiver.Mini8Connect);
        //temp.On<int, DateTime>("UpdateDataBaseInfo", receiver.UpdateDataBaseInfo);
        //temp.On<byte, byte, ChannelData>("ChannelDataUpdate", receiver.ChannelDataUpdate);

        //temp.ServerTimeout = TimeSpan.FromSeconds(5.0);


        for (int i = 1; i <= retry; i++)
        {
            try
            {
                temp.StartAsync().Wait();
                _hubConnection = temp;
                break;
            }
            catch
            {
                if (i == retry)
                    return false;
                Thread.Sleep(1000);
            }
        }

        return true;
    }

    public async Task<bool> SendFile(Guid guid, MemoryStream stream)
    {
        if (!stream.Split(out List<byte[]>? buffer, 8192) || buffer is null)
            return false;

        for (int i = 0; i < buffer.Count; i++)
        {
            if (!await base.Send<Guid, byte[], int, int>("FilePack", guid, buffer[i], i + 1, buffer.Count))
                return false;
        }  
        return true;
    }
}