internal sealed class RdConnectionWrapper()

in src/dotnet/AspireWorker/RdConnection/RdConnectionWrapper.cs [13:88]
65 lines of code
2 McCabe index (conditional complexity)

internal sealed class RdConnectionWrapper(RdConnection rdConnection) : IRdConnectionWrapper
{
    public async Task ViewHosts(Lifetime lifetime, Action<Lifetime, string, AspireHostModel> action)
    {
        await rdConnection.DoWithModel(model => { model.AspireHosts.View(lifetime, action); });
    }

    public async Task<CreateSessionResponse?> CreateSession(AspireHostModel host, CreateSessionRequest request)
    {
        return await rdConnection.DoWithModel(_ => host.CreateSession.Sync(request));
    }

    public async Task<DeleteSessionResponse?> DeleteSession(AspireHostModel host, DeleteSessionRequest request)
    {
        return await rdConnection.DoWithModel(_ => host.DeleteSession.Sync(request));
    }

    public async Task AdviceOnProcessStarted(AspireHostModel host, Lifetime lifetime, Action<ProcessStarted> action)
    {
        await rdConnection.DoWithModel(_ => host.ProcessStarted.Advise(lifetime, action));
    }

    public async Task AdviceOnProcessTerminated(AspireHostModel host, Lifetime lifetime,
        Action<ProcessTerminated> action)
    {
        await rdConnection.DoWithModel(_ => host.ProcessTerminated.Advise(lifetime, action));
    }

    public async Task AdviceOnLogReceived(AspireHostModel host, Lifetime lifetime, Action<LogReceived> action)
    {
        await rdConnection.DoWithModel(_ => host.LogReceived.Advise(lifetime, action));
    }

    public async Task<bool> AddResource(AspireHostModel host, string resourceName, ResourceWrapper resourceWrapper)
    {
        return await rdConnection.DoWithModel(_ => host.Resources.TryAdd(resourceName, resourceWrapper));
    }

    public async Task UpsertResource(AspireHostModel host, ResourceModel resourceModel,
        Func<ResourceModel, ResourceWrapper> resourceWrapperFactory)
    {
        await rdConnection.DoWithModel(_ =>
        {
            if (host.Resources.ContainsKey(resourceModel.Name))
            {
                host.Resources[resourceModel.Name].Model.SetValue(resourceModel);
            }
            else
            {
                var resourceWrapper = resourceWrapperFactory(resourceModel);
                host.Resources.TryAdd(resourceModel.Name, resourceWrapper);
            }
        });
    }

    public async Task<bool> RemoveResource(AspireHostModel host, string resourceName)
    {
        return await rdConnection.DoWithModel(_ => host.Resources.Remove(resourceName));
    }

    public async Task ClearResources(AspireHostModel host)
    {
        await rdConnection.DoWithModel(_ => host.Resources.Clear());
    }

    public async Task ViewResources(AspireHostModel host, Lifetime lifetime,
        Action<Lifetime, string, ResourceWrapper> action)
    {
        await rdConnection.DoWithModel(_ => { host.Resources.View(lifetime, action); });
    }

    public async Task ResourceLogReceived(ResourceWrapper resource, ResourceLog resourceLog)
    {
        await rdConnection.DoWithModel(_ => resource.LogReceived(resourceLog));
    }
}