// Copyright 2025 The NATS Authors
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

// Ported from:
//   golang/nats-server/server/jetstream_benchmark_test.go      (11 Benchmark* functions)
//   golang/nats-server/server/jetstream_jwt_test.go             (9 tests)
//   golang/nats-server/server/jetstream_versioning_test.go      (2 tests)
//   golang/nats-server/server/jetstream_meta_benchmark_test.go  (2 Benchmark* functions)
//   golang/nats-server/server/jetstream_cluster_long_test.go    (4 tests)
//   golang/nats-server/server/jetstream_sourcing_scaling_test.go (1 test)

namespace ZB.MOM.NatsNet.Server.IntegrationTests.JetStream;

/// <summary>
/// Integration tests ported from JetStream benchmark, JWT, versioning, meta-benchmark,
/// cluster-long, and sourcing-scaling Go test files (29 tests total).
/// </summary>
[Trait("Category", "Integration")]
public sealed class JetStreamMiscTests
{
    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamConsume_SyncPushConsumer_ShouldConsumeAllMessages() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamConsume_AsyncPushConsumer_ShouldDeliverAllMessages() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamConsumeFilteredContiguous_SingleFilter_ShouldConsumeAllMessages() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamConsumeFilteredContiguous_TwoFilters_ShouldConsumeAllMessages() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamConsumeWithFilters_DomainFilteredConsumer_ShouldDeliverCorrectly() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamPublish_SyncPublisher_ShouldPublishSuccessfully() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamPublish_AsyncPublisher_ShouldPublishSuccessfully() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamPublish_MultiSubject_ShouldPublishToAllSubjects() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamPublish_ClusteredR3_ShouldPublishSuccessfully() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamConsume_PullDurableConsumer_ShouldConsumeAllMessages() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamConsume_PullEphemeralConsumer_ShouldConsumeAllMessages() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamJwtLimits_AccountLimitsShouldBeAppliedFromJwt() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamJwtDisallowBearer_BearerTokenShouldBeRejected() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamJwtMove_TieredR3_ShouldMoveStreamBetweenClusters() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamJwtMove_TieredR1_ShouldMoveStreamBetweenClusters() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamJwtMove_NonTieredR3_ShouldMoveStreamBetweenClusters() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamJwtMove_NonTieredR1_ShouldMoveStreamBetweenClusters() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamJwtClusteredTiers_TieredLimitsShouldBeEnforced() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamJwtClusteredTiersChange_UpdatedLimitsShouldBeApplied() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamJwt_AllRemainingCases_RequireJwtInfrastructure() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamVersioning_InternalMetadataFunctions_ShouldBehaveCorrectly() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamMetadataMutations_MetadataShouldPersistAcrossOperations() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamCreate_ConcurrentStreamCreation_ShouldSucceedWithoutErrors() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void JetStreamCreateConsumers_ConcurrentConsumerCreation_ShouldSucceedWithoutErrors() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void LongKvPutWithServerRestarts_ShouldContinueSuccessfullyUnderNodeRestarts() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void LongNrgChainOfBlocks_ShouldConvergeCorrectlyUnderFaults() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void LongClusterWorkQueueMessagesNotSkipped_AllMessagesShouldBeDelivered() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void LongClusterJetStreamKeyValueSync_KvStoreShouldBeConsistentAcrossCluster() { }

    [Fact(Skip = "deferred: requires running NATS server")]
    public void StreamSourcingScalingManyBenchmark_ShouldScaleWithManySources() { }
}