StrangeTools/CompressService/CompServ.ClientLibrary/CompServHubClient.cs

using static CompServ.CompServConst;

namespace CompServ.ClientLibrary;

public class CompServHubClient(string server) : CompServClient(server, ApiPathHubRootForCheckAlive, AliveMessageHub)
{
    public async Task RegisterWorker(int port, int ratio)
    {
        var msg = ModelExtensionMethod.BuildWorkerRegisterRequestMessage(port, ratio);
        var httpResponseMessage = await new HttpClient() { BaseAddress = ServerUri }.SendAsync(msg);
        httpResponseMessage.EnsureSuccessStatusCode();
    }

    public async Task UnRegisterWorker(int port)
    {
        var msg = ModelExtensionMethod.BuildWorkerUnRegisterRequestMessage(port);
        var httpResponseMessage = await new HttpClient() { BaseAddress = ServerUri }.SendAsync(msg);
        httpResponseMessage.EnsureSuccessStatusCode();
    }

    public async Task<string> GetWorker()
    {
        var msg = ModelExtensionMethod.BuildClientGetWorkerRequest();
        var httpResponseMessage = await new HttpClient() { BaseAddress = ServerUri }.SendAsync(msg);
        httpResponseMessage.EnsureSuccessStatusCode();
        var workerUrl = await httpResponseMessage.Content.ReadAsStringAsync();
        return workerUrl;
    }
}