ServerUpdateInitiator.cs

Go to the documentation of this file.

using System;
using System.Threading;
using System.Threading.Tasks;
 
using Tgstation.Server.Host.IO;
using Tgstation.Server.Host.Swarm;
 
namespace Tgstation.Server.Host.Core
{
    sealed class ServerUpdateInitiator : IServerUpdateInitiator
    {
        readonly ISwarmService swarmService;
 
        readonly IServerUpdater serverUpdater;
 
        public ServerUpdateInitiator(ISwarmService swarmService, IServerUpdater serverUpdater)
        {
            this.swarmService = swarmService ?? throw new ArgumentNullException(nameof(swarmService));
            this.serverUpdater = serverUpdater ?? throw new ArgumentNullException(nameof(serverUpdater));
        }
 
        public ValueTask<ServerUpdateResult> InitiateUpdate(IFileStreamProvider? fileStreamProvider, Version version, CancellationToken cancellationToken)
            => serverUpdater.BeginUpdate(swarmService, fileStreamProvider, version, cancellationToken);
    }
}