Joseph Doherty
7b0b9c7365
Solution + 23 src projects + 26 test projects renamed; folders, csproj, namespaces, and ScadaLinkDbContext/ScadaBridgeDbContext class updated. ActorSystem "scadalink" → "scadabridge", Akka seed-node URLs migrated. SQL roles/logins, LDAP domains, CLI command name, and CLI config dir (~/.scadalink → ~/.scadabridge) also renamed. Build green; 5 Host.Tests fail awaiting SQL login rename in next commit. Pre-existing StaleTagMonitor timing flakes unchanged. Rename script committed at tools/rename-to-scadabridge.sh.
78 lines
3.6 KiB
C#
78 lines
3.6 KiB
C#
using Akka.Actor;
|
|
using Akka.TestKit.Xunit2;
|
|
using Microsoft.Extensions.DependencyInjection;
|
|
using Microsoft.Extensions.Logging.Abstractions;
|
|
using Microsoft.Extensions.Options;
|
|
using NSubstitute;
|
|
using ZB.MOM.WW.ScadaBridge.Commons.Entities.Instances;
|
|
using ZB.MOM.WW.ScadaBridge.Commons.Entities.Sites;
|
|
using ZB.MOM.WW.ScadaBridge.Commons.Interfaces.Repositories;
|
|
using ZB.MOM.WW.ScadaBridge.Communication;
|
|
using ZB.MOM.WW.ScadaBridge.Communication.Actors;
|
|
using ZB.MOM.WW.ScadaBridge.Communication.Grpc;
|
|
|
|
namespace ZB.MOM.WW.ScadaBridge.Communication.Tests;
|
|
|
|
/// <summary>
|
|
/// Tests for DebugStreamService session lifecycle.
|
|
/// </summary>
|
|
public class DebugStreamServiceTests : TestKit
|
|
{
|
|
[Fact]
|
|
public async Task StartStreamAsync_StreamTerminatesBeforeSnapshot_ThrowsMeaningfulException()
|
|
{
|
|
// Regression test for Communication-001. When the debug stream terminates before
|
|
// the initial snapshot arrives, StartStreamAsync used to let the raw
|
|
// InvalidOperationException from onTerminatedWrapper escape its
|
|
// OperationCanceledException-only catch — the caller saw an untranslated exception
|
|
// and the failure path did not deterministically tear the bridge actor down.
|
|
// The fix catches any failure, tells the bridge actor StopDebugStream, and throws
|
|
// a descriptive exception that names the instance and wraps the underlying cause.
|
|
var instance = new Instance("Site1.Pump01") { Id = 7, SiteId = 3 };
|
|
var site = new Site("Site One", "site-1")
|
|
{
|
|
Id = 3,
|
|
GrpcNodeAAddress = "http://localhost:5100",
|
|
GrpcNodeBAddress = "http://localhost:5200"
|
|
};
|
|
|
|
var instanceRepo = Substitute.For<ITemplateEngineRepository>();
|
|
instanceRepo.GetInstanceByIdAsync(7, Arg.Any<CancellationToken>()).Returns(instance);
|
|
var siteRepo = Substitute.For<ISiteRepository>();
|
|
siteRepo.GetSiteByIdAsync(3, Arg.Any<CancellationToken>()).Returns(site);
|
|
|
|
var services = new ServiceCollection();
|
|
services.AddScoped(_ => instanceRepo);
|
|
services.AddScoped(_ => siteRepo);
|
|
using var provider = services.BuildServiceProvider();
|
|
|
|
var commProbe = CreateTestProbe();
|
|
var commService = new CommunicationService(
|
|
Options.Create(new CommunicationOptions()),
|
|
NullLogger<CommunicationService>.Instance);
|
|
commService.SetCommunicationActor(commProbe.Ref);
|
|
|
|
using var grpcFactory = new SiteStreamGrpcClientFactory(NullLoggerFactory.Instance);
|
|
var service = new DebugStreamService(
|
|
commService, provider, grpcFactory, NullLogger<DebugStreamService>.Instance);
|
|
service.SetActorSystem(Sys);
|
|
|
|
// Act — start the stream; it blocks awaiting the initial snapshot.
|
|
var startTask = service.StartStreamAsync(instanceId: 7, onEvent: _ => { }, onTerminated: () => { });
|
|
|
|
// The bridge actor's PreStart sends SubscribeDebugViewRequest to the comm actor;
|
|
// the envelope's sender is the bridge actor itself.
|
|
commProbe.ExpectMsg<SiteEnvelope>(TimeSpan.FromSeconds(5));
|
|
var bridgeActor = commProbe.LastSender;
|
|
|
|
// Simulate the site terminating the stream before any snapshot is delivered.
|
|
bridgeActor.Tell(new DebugStreamTerminated("site-1", "corr"));
|
|
|
|
// Assert — a descriptive exception that names the instance and wraps the cause,
|
|
// not the raw "terminated before snapshot received" InvalidOperationException.
|
|
var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => startTask);
|
|
Assert.Contains("Site1.Pump01", ex.Message);
|
|
Assert.NotNull(ex.InnerException);
|
|
}
|
|
}
|