using MxGateway.Client;
using MxGateway.Contracts.Proto;

namespace MxGateway.Client.Cli;

internal sealed class MxGatewayCliClientAdapter(MxGatewayClient client) : IMxGatewayCliClient
{
    public Task<OpenSessionReply> OpenSessionAsync(
        OpenSessionRequest request,
        CancellationToken cancellationToken)
    {
        return client.OpenSessionRawAsync(request, cancellationToken);
    }

    public Task<CloseSessionReply> CloseSessionAsync(
        CloseSessionRequest request,
        CancellationToken cancellationToken)
    {
        return client.CloseSessionRawAsync(request, cancellationToken);
    }

    public Task<MxCommandReply> InvokeAsync(
        MxCommandRequest request,
        CancellationToken cancellationToken)
    {
        return client.InvokeAsync(request, cancellationToken);
    }

    public IAsyncEnumerable<MxEvent> StreamEventsAsync(
        StreamEventsRequest request,
        CancellationToken cancellationToken)
    {
        return client.StreamEventsAsync(request, cancellationToken);
    }

    public ValueTask DisposeAsync()
    {
        return client.DisposeAsync();
    }
}