ComponentInterfacingAuthorityBase.cs

Go to the documentation of this file.

using System;
using System.Threading.Tasks;
 
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;
 
using Serilog.Context;
 
using Tgstation.Server.Api.Models;
using Tgstation.Server.Host.Components;
using Tgstation.Server.Host.Database;
using Tgstation.Server.Host.Utils;
 
namespace Tgstation.Server.Host.Authority.Core
{
    abstract class ComponentInterfacingAuthorityBase : AuthorityBase
    {
        readonly IInstanceManager instanceManager;
 
        protected ComponentInterfacingAuthorityBase(
            IInstanceManager instanceManager,
            IDatabaseContext databaseContext,
            ILogger<ComponentInterfacingAuthorityBase> logger)
            : base(databaseContext, logger)
        {
            this.instanceManager = instanceManager ?? throw new ArgumentNullException(nameof(instanceManager));
        }
 
        protected async ValueTask<AuthorityResponse<TResult>> WithComponentInstance<TResult>(Func<IInstanceCore, ValueTask<AuthorityResponse<TResult>>> action, long instanceId)
        {
            using var instanceReference = instanceManager.GetInstanceReference(instanceId);
            using (LogContext.PushProperty(SerilogContextHelper.InstanceReferenceContextProperty, instanceReference?.Uid))
            {
                if (instanceReference == null)
                    return Conflict<TResult>(ErrorCode.InstanceOffline);
                return await action(instanceReference);
            }
        }
    }
}