1234567891011121314151617181920212223242526272829 |
- 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;
- }
- }
|