RestServerClient.cs

Go to the documentation of this file.

using System;
using System.Threading;
using System.Threading.Tasks;
 
using Microsoft.AspNetCore.SignalR.Client;
using Microsoft.Extensions.Logging;
 
using Tgstation.Server.Api;
using Tgstation.Server.Api.Hubs;
using Tgstation.Server.Api.Models.Response;
 
namespace Tgstation.Server.Client
{
    sealed class RestServerClient : IRestServerClient
    {
        public Uri Url => apiClient.Url;
 
        public TokenResponse Token
        {
            get => apiClient.Headers.Token ?? throw new InvalidOperationException("apiClient.Headers.Token was null!");
            set => apiClient.Headers = new ApiHeaders(apiClient.Headers.UserAgent!, value);
        }
 
        public TimeSpan Timeout
        {
            get => apiClient.Timeout;
            set => apiClient.Timeout = value;
        }
 
        public IInstanceManagerClient Instances { get; }
 
        public IAdministrationClient Administration { get; }
 
        public IUsersClient Users { get; }
 
        public IUserGroupsClient Groups { get; }
 
        public ITransferClient Transfer => apiClient;
 
        readonly IApiClient apiClient;
 
        public RestServerClient(IApiClient apiClient)
        {
            this.apiClient = apiClient ?? throw new ArgumentNullException(nameof(apiClient));
 
            Instances = new InstanceManagerClient(apiClient);
            Users = new UsersClient(apiClient);
            Administration = new AdministrationClient(apiClient);
            Groups = new UserGroupsClient(apiClient);
        }
 
        public ValueTask DisposeAsync() => apiClient.DisposeAsync();
 
        public ValueTask<ServerInformationResponse> ServerInformation(CancellationToken cancellationToken) => apiClient.Read<ServerInformationResponse>(Routes.ApiRoot, cancellationToken);
 
        public void AddRequestLogger(IRequestLogger requestLogger) => apiClient.AddRequestLogger(requestLogger);
 
        public ValueTask<IAsyncDisposable> SubscribeToJobUpdates(
            IJobsHub jobsReceiver,
            IRetryPolicy? retryPolicy,
            Action<ILoggingBuilder>? loggingConfigureAction,
            CancellationToken cancellationToken)
            => apiClient.CreateHubConnection(jobsReceiver, retryPolicy, loggingConfigureAction, cancellationToken);
    }
}