389f5a0378
Communication Layer (WP-1–5): - 8 message patterns with correlation IDs, per-pattern timeouts - Central/Site communication actors, transport heartbeat config - Connection failure handling (no central buffering, debug streams killed) Data Connection Layer (WP-6–14, WP-34): - Connection actor with Become/Stash lifecycle (Connecting/Connected/Reconnecting) - OPC UA + LmxProxy adapters behind IDataConnection - Auto-reconnect, bad quality propagation, transparent re-subscribe - Write-back, tag path resolution with retry, health reporting - Protocol extensibility via DataConnectionFactory Site Runtime (WP-15–25, WP-32–33): - ScriptActor/ScriptExecutionActor (triggers, concurrent execution, blocking I/O dispatcher) - AlarmActor/AlarmExecutionActor (ValueMatch/RangeViolation/RateOfChange, in-memory state) - SharedScriptLibrary (inline execution), ScriptRuntimeContext (API) - ScriptCompilationService (Roslyn, forbidden API enforcement, execution timeout) - Recursion limit (default 10), call direction enforcement - SiteStreamManager (per-subscriber bounded buffers, fire-and-forget) - Debug view backend (snapshot + stream), concurrency serialization - Local artifact storage (4 SQLite tables) Health Monitoring (WP-26–28): - SiteHealthCollector (thread-safe counters, connection state) - HealthReportSender (30s interval, monotonic sequence numbers) - CentralHealthAggregator (offline detection 60s, online recovery) Site Event Logging (WP-29–31): - SiteEventLogger (SQLite, 6 event categories, ISO 8601 UTC) - EventLogPurgeService (30-day retention, 1GB cap) - EventLogQueryService (filters, keyword search, keyset pagination) 541 tests pass, zero warnings.
78 lines
2.6 KiB
C#
78 lines
2.6 KiB
C#
using Akka.Actor;
|
|
using Akka.TestKit.Xunit2;
|
|
using NSubstitute;
|
|
using ScadaLink.Commons.Interfaces.Protocol;
|
|
using ScadaLink.Commons.Messages.DataConnection;
|
|
using ScadaLink.DataConnectionLayer.Actors;
|
|
|
|
namespace ScadaLink.DataConnectionLayer.Tests;
|
|
|
|
/// <summary>
|
|
/// WP-34: Tests for DataConnectionManagerActor routing and lifecycle.
|
|
/// </summary>
|
|
public class DataConnectionManagerActorTests : TestKit
|
|
{
|
|
private readonly IDataConnectionFactory _mockFactory;
|
|
private readonly DataConnectionOptions _options;
|
|
|
|
public DataConnectionManagerActorTests()
|
|
: base(@"akka.loglevel = DEBUG")
|
|
{
|
|
_mockFactory = Substitute.For<IDataConnectionFactory>();
|
|
_options = new DataConnectionOptions
|
|
{
|
|
ReconnectInterval = TimeSpan.FromMilliseconds(100),
|
|
TagResolutionRetryInterval = TimeSpan.FromMilliseconds(200)
|
|
};
|
|
}
|
|
|
|
[Fact]
|
|
public void WriteToUnknownConnection_ReturnsError()
|
|
{
|
|
var manager = Sys.ActorOf(Props.Create(() =>
|
|
new DataConnectionManagerActor(_mockFactory, _options)));
|
|
|
|
manager.Tell(new WriteTagRequest(
|
|
"corr1", "nonexistent", "tag1", 42, DateTimeOffset.UtcNow));
|
|
|
|
var response = ExpectMsg<WriteTagResponse>();
|
|
Assert.False(response.Success);
|
|
Assert.Contains("Unknown connection", response.ErrorMessage);
|
|
}
|
|
|
|
[Fact]
|
|
public void SubscribeToUnknownConnection_ReturnsError()
|
|
{
|
|
var manager = Sys.ActorOf(Props.Create(() =>
|
|
new DataConnectionManagerActor(_mockFactory, _options)));
|
|
|
|
manager.Tell(new SubscribeTagsRequest(
|
|
"corr1", "inst1", "nonexistent", ["tag1"], DateTimeOffset.UtcNow));
|
|
|
|
var response = ExpectMsg<SubscribeTagsResponse>();
|
|
Assert.False(response.Success);
|
|
Assert.Contains("Unknown connection", response.ErrorMessage);
|
|
}
|
|
|
|
[Fact]
|
|
public void CreateConnection_UsesFactory()
|
|
{
|
|
var mockAdapter = Substitute.For<IDataConnection>();
|
|
mockAdapter.ConnectAsync(Arg.Any<IDictionary<string, string>>(), Arg.Any<CancellationToken>())
|
|
.Returns(Task.CompletedTask);
|
|
_mockFactory.Create("OpcUa", Arg.Any<IDictionary<string, string>>())
|
|
.Returns(mockAdapter);
|
|
|
|
var manager = Sys.ActorOf(Props.Create(() =>
|
|
new DataConnectionManagerActor(_mockFactory, _options)));
|
|
|
|
manager.Tell(new CreateConnectionCommand(
|
|
"conn1", "OpcUa", new Dictionary<string, string>()));
|
|
|
|
// Factory should have been called
|
|
AwaitCondition(() =>
|
|
_mockFactory.ReceivedCalls().Any(c => c.GetMethodInfo().Name == "Create"),
|
|
TimeSpan.FromSeconds(2));
|
|
}
|
|
}
|