dohertj2/lmxopcua
1
0
Fork 0
Code Issues 1 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

test(controlplane): self-join cluster + DistributedPubSub extension in test harness

Browse Source
This commit is contained in:
Joseph Doherty
2026-05-26 04:53:25 -04:00
parent 9582e448d5
commit 9f61cd5989
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
tests/Server/ZB.MOM.WW.OtOpcUa.ControlPlane.Tests/Harness/ControlPlaneTestHarness.cs
View File

@@ -1,3 +1,4 @@
using Akka.Cluster;
using Akka.TestKit.Xunit2; using Akka.TestKit.Xunit2;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
using ZB.MOM.WW.OtOpcUa.Configuration; using ZB.MOM.WW.OtOpcUa.Configuration;
@@ -18,6 +19,9 @@ public abstract class ControlPlaneActorTestBase : TestKit
protected static string AkkaTestHocon => @" protected static string AkkaTestHocon => @"
akka { akka {
loglevel = ""WARNING"" loglevel = ""WARNING""
extensions = [
""Akka.Cluster.Tools.PublishSubscribe.DistributedPubSubExtensionProvider, Akka.Cluster.Tools""
]
actor { actor {
provider = ""Akka.Cluster.ClusterActorRefProvider, Akka.Cluster"" provider = ""Akka.Cluster.ClusterActorRefProvider, Akka.Cluster""
} }
@@ -30,10 +34,18 @@ akka {
roles = [""admin""] roles = [""admin""]
min-nr-of-members = 1 min-nr-of-members = 1
run-coordinated-shutdown-when-down = off run-coordinated-shutdown-when-down = off
pub-sub.role = """"
} }
}"; }";
protected ControlPlaneActorTestBase() : base(AkkaTestHocon) { } protected ControlPlaneActorTestBase() : base(AkkaTestHocon)
{
// Self-join so the cluster transitions to Up and DistributedPubSub forms.
var cluster = Akka.Cluster.Cluster.Get(Sys);
cluster.Join(cluster.SelfAddress);
AwaitCondition(() => cluster.State.Members.Any(m => m.Status == MemberStatus.Up),
TimeSpan.FromSeconds(5));
}
protected static IDbContextFactory<OtOpcUaConfigDbContext> NewInMemoryDbFactory(string? dbName = null) protected static IDbContextFactory<OtOpcUaConfigDbContext> NewInMemoryDbFactory(string? dbName = null)
{ {