namespace NATS.Server.Clustering.Tests;

public class RouteWireSubscriptionProtocolTests
{
    [Fact]
    public async Task RSplus_RSminus_frames_propagate_remote_interest_over_socket()
    {
        await using var fx = await RouteFixture.StartTwoNodeClusterAsync();

        await fx.SendRouteSubFrameAsync("foo.*");
        (await fx.ServerAHasRemoteInterestAsync("foo.bar")).ShouldBeTrue();

        await fx.SendRouteUnsubFrameAsync("foo.*");
        (await fx.ServerAHasRemoteInterestAsync("foo.bar", expected: false)).ShouldBeFalse();
    }
}