using Akka.Actor;
using Akka.Cluster;
using Akka.Configuration;

namespace ZB.MOM.WW.Secrets.Replicator.AkkaDotNet.Tests.DependencyInjection;

/// <summary>
/// One self-joined single-node cluster shared by a test class — the miniature app node the
/// replication actor's DistributedPubSub mediator needs. Tests that spawn the actor must give each
/// container its own <c>Secrets:Replication:ActorName</c>, since actor names are unique per system.
/// </summary>
public sealed class SingleNodeClusterFixture : IAsyncLifetime
{
    /// <summary>The joined, Up actor system.</summary>
    public ActorSystem System { get; private set; } = null!;

    /// <inheritdoc />
    public async Task InitializeAsync()
    {
        System = ActorSystem.Create("zb-secrets-order", ConfigurationFactory.ParseString("""
            akka {
              loglevel = WARNING
              actor.provider = cluster
              remote.dot-netty.tcp {
                hostname = "127.0.0.1"
                public-hostname = "127.0.0.1"
                port = 0
              }
            }
            """).WithFallback(AkkaSecretsReplication.SerializationConfig));

        Cluster cluster = Cluster.Get(System);
        cluster.Join(cluster.SelfAddress);

        DateTime deadline = DateTime.UtcNow + TimeSpan.FromSeconds(20);
        while (cluster.State.Members.All(m => m.Status != MemberStatus.Up))
        {
            if (DateTime.UtcNow > deadline)
            {
                throw new TimeoutException("Single-node cluster never reached Up.");
            }

            await Task.Delay(100);
        }
    }

    /// <inheritdoc />
    public async Task DisposeAsync() => await System.Terminate();
}