using Grpc.Core;
using MxGateway.Contracts.Proto;

namespace MxGateway.Client;

internal interface IMxGatewayClientTransport
{
    MxGatewayClientOptions Options { get; }

    MxAccessGateway.MxAccessGatewayClient? RawClient { get; }

    Task<OpenSessionReply> OpenSessionAsync(
        OpenSessionRequest request,
        CallOptions callOptions);

    Task<CloseSessionReply> CloseSessionAsync(
        CloseSessionRequest request,
        CallOptions callOptions);

    Task<MxCommandReply> InvokeAsync(
        MxCommandRequest request,
        CallOptions callOptions);

    IAsyncEnumerable<MxEvent> StreamEventsAsync(
        StreamEventsRequest request,
        CallOptions callOptions);
}