Files
Marc Schier 01d7162313 Part 9 Alarms & Conditions: complete server + client implementation (#3805)
Complete implementation of **OPC UA Part 9 ΓÇö Alarms & Conditions** for
both server and client, **OPC UA Part 16 ΓÇö State Machines** (generic
extensible client + server API), and the supporting infrastructure
(source-generated event records, source-generated ObjectType proxies,
`IAsyncEnumerable` streaming subscriptions, address-space model change
tracking, per-node `INodeCache` invalidation, unified DI integration).

### Server-side (Part 9 complete)

- **`AlarmConditionState`** ΓÇö every Part 9 method wired automatically
in `OnAfterCreate`: `Silence`, `Suppress`/`Suppress2`,
`Unsuppress`/`Unsuppress2`, `RemoveFromService`/`RemoveFromService2`,
`PlaceInService`/`PlaceInService2`, `Reset`/`Reset2`,
`GetGroupMemberships`. Each method generates the spec-mandated audit
event and supports an optional veto-delegate hook.
- **Latched alarms** ΓÇö `ActiveState` reflects real process state;
`LatchedState` persists until explicit `Reset` (with full precondition
validation).
- **Re-alarming** ΓÇö
`ProcessReAlarm`/`ResetReAlarmRepeatCount`/`IsReAlarmEnabled` helpers
(opt-in, no hidden timer).
- **Audible alarms** ΓÇö `UpdateAudibleState` for
`AudibleEnabled`/`AudibleSound`/`SilenceState` lifecycle.
- **Suppression + groups** ΓÇö `AlarmGroup`, `AlarmSuppressionEngine`
(with first-in-group), `AlarmRateTracker` (for `AlarmMetricsType`).
- **Spec-compliance fixes** ΓÇö `SuppressedOrShelved` now includes
`OutOfServiceState`; `GetRetainState` includes `LatchedState`;
`EffectiveDisplayName` composition includes `OutOfServiceState` +
`LatchedState`.

### Client-side Part 9 API

- **`AlarmClient`** ΓÇö typed Part 9 operations. Each method delegates
to the matching source-generated `*TypeClient` proxy
(`ConditionTypeClient`, `AcknowledgeableConditionTypeClient`,
`AlarmConditionTypeClient`, `DialogConditionTypeClient`,
`ShelvedStateMachineTypeClient`) ΓÇö one source of truth for every
method NodeId.
- **Interface hierarchy** — `IConditionOperations` →
`IAcknowledgeableConditionOperations` → `IAlarmOperations` +
`IDialogConditionOperations`.
- **Source-generated event records** ΓÇö new `EventRecordGenerator`
(alongside `ObjectTypeProxyGenerator`) emits `{Type}TypeRecord` per OPC
UA event type: `ConditionTypeRecord` →
`AcknowledgeableConditionTypeRecord` → `AlarmConditionTypeRecord` →
`LimitAlarmTypeRecord`/`ExclusiveLimitAlarmTypeRecord`/… all the way
to vendor subtypes. **Vendor alarm types get records automatically.**
- **`AlarmEventDecoder`** ΓÇö decodes `EventNotification.Fields` into
the most-specific generated record.
- **`AlarmEventFilterBuilder`** ΓÇö fluent builder for Part 9
`EventFilter`s.
- **`ISession.GetAlarmClient(telemetry)`** convenience extension.

### Part 16 state machines (generic, extensible)

- **Client**: extension methods on the source-generated
`StateMachineTypeClient` / `FiniteStateMachineTypeClient` ΓÇö
`GetCurrentStateAsync`, `ObserveFiniteTransitionsAsync`
(`IAsyncEnumerable<FiniteStateSnapshot>`), `WaitForStateAsync`,
`GetAvailableStatesAsync` / `GetAvailableTransitionsAsync`. **Vendor
proxies inherit the API automatically** through the generated
inheritance chain.
- **Server**: `StateMachineBuilder` (fluent: `AddState` /
`AddTransition` / `OnCause` / validation) +
`FluentFiniteStateMachineState` ΓÇö declare a Part 16 state machine
without subclassing the abstract base.
- **Alarms alignment**: `AlarmClient.GetShelvingStateAsync` /
`ObserveShelvingTransitionsAsync` surface the API for every alarm's
`ShelvingState` child.

### IAsyncEnumerable streaming subscription

- **`IStreamingSubscription`** with
`SubscribeDataChangesAsync`/`SubscribeEventsAsync` returning
`IAsyncEnumerable<T>` (Channel-backed).
- **`ManagedSession.DefaultStreaming`** ΓÇö lazy shared subscription;
disposed with the session.
- **Helpers** ΓÇö `TakeUntilAsync`, `WithTimeoutAsync`, `TakeAsync`,
`BufferedAsync` for state-machine waits and bounded observation windows.
- **`AlarmStreamExtensions`** ΓÇö
`SubscribeAlarmsAsync`/`SubscribeConditionsAsync`/`SubscribeDialogsAsync`
returning the source-generated record types.

### Address-space model change tracking

- **Server**: `RaiseGeneralModelChangeEvent` on both `CustomNodeManager`
and `AsyncCustomNodeManager`; `ModelChangeAggregator` (in
`Opc.Ua.Server.NodeManager`, used by every node manager) batches changes
per service call; **auto-emit** from `CreateNode`/`DeleteNode` (opt-out
via `ModelChangeEmissionEnabled = false`).
- **Client**: `IModelChangeTracker` subscribes to
`BaseModelChangeEventType` via the streaming subscription, decodes
`ModelChangeStructureDataType` payloads, invalidates the `INodeCache`
per-node.
- **`INodeCache.InvalidateNode(NodeId)`** ΓÇö new interface member (true
per-node eviction in `NodeCache`).
- **`ManagedSession.EnableModelChangeTrackingAsync()`** +
`ManagedSessionOptions.ModelChangeTracking` +
`ManagedSessionBuilder.WithModelChangeTracking()` fluent method.

### Dependency Injection integration

- **`services.AddOpcUa().AddClient(...).AddAlarms()`** ΓÇö registers
`AlarmClientFactory` so DI-hosted apps can resolve a Part 9 client per
session without `new`-ing one manually.
- Cross-link added to the unified DI surface (`AddServer` / `AddClient`
/ `AddComplexTypes` / `AddGdsServer` / `AddLdsServer` /
`AddWotConServer`).

### Quickstart server modernization

- `Quickstarts.Servers/Alarms/AlarmNodeManager.cs` ported to
`AsyncCustomNodeManager` and demonstrates the new `AlarmGroup` +
`AlarmSuppressionEngine` end-to-end via a writable `MaintenanceMode`
boolean that suppresses every member alarm.

### Documentation

- New: `Docs/AlarmsAndConditions.md`, `Docs/StreamingSubscription.md`,
`Docs/ModelChangeTracking.md`, `Docs/StateMachines.md` ΓÇö full
developer guides.
- Updated: `Docs/DependencyInjection.md` (`AddAlarms()` row + section),
`Docs/README.md` index, `Docs/MigrationGuide.md` (Part 9 / Part 16 /
model change tracking sections covering behavior changes + breaking API
surface).
- Sample: `Applications/ConsoleReferenceClient/AlarmClientSample.cs`.
2026-05-29 23:24:53 +02:00

355 lines
14 KiB
C#

/* ========================================================================
* Copyright (c) 2005-2025 The OPC Foundation, Inc. All rights reserved.
*
* OPC Foundation MIT License 1.00
*
* Permission is hereby granted, free of charge, to any person
* obtaining a copy of this software and associated documentation
* files (the "Software"), to deal in the Software without
* restriction, including without limitation the rights to use,
* copy, modify, merge, publish, distribute, sublicense, and/or sell
* copies of the Software, and to permit persons to whom the
* Software is furnished to do so, subject to the following
* conditions:
*
* The above copyright notice and this permission notice shall be
* included in all copies or substantial portions of the Software.
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
* OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
* HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
* WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
* OTHER DEALINGS IN THE SOFTWARE.
*
* The complete license agreement can be found here:
* http://opcfoundation.org/License/MIT/1.00/
* ======================================================================*/
using System;
using Moq;
using NUnit.Framework;
using Opc.Ua.Server.StateMachines;
namespace Opc.Ua.Server.Tests.StateMachines
{
/// <summary>
/// Unit tests for definition-mode chaining on the unified
/// <see cref="StateMachineBuilder{TState}"/>. Validation,
/// freeze semantics, and the <see cref="FluentFiniteStateMachineState"/>
/// table projections are covered here.
/// </summary>
[TestFixture]
[Category("Server")]
[Category("StateMachines")]
[Parallelizable]
public sealed class StateMachineBuilderTests
{
private ServerSystemContext m_context = null!;
[SetUp]
public void SetUp()
{
m_context = StateMachineTestFixtures.CreateContext();
}
[Test]
public void StateMachineGetterThrowsWhenNoStatesDeclared()
{
StateMachineBuilder<FluentFiniteStateMachineState> b =
StateMachineTestFixtures.NewBuilder(m_context);
Assert.That(() => _ = b.StateMachine,
Throws.TypeOf<InvalidOperationException>());
}
[Test]
public void DuplicateStateIdThrows()
{
StateMachineBuilder<FluentFiniteStateMachineState> b =
StateMachineTestFixtures.NewBuilder(m_context);
b.AddState(1, "Off");
Assert.That(() => b.AddState(1, "Off2"),
Throws.ArgumentException);
}
[Test]
public void DuplicateTransitionIdThrows()
{
StateMachineBuilder<FluentFiniteStateMachineState> b =
StateMachineTestFixtures.NewBuilder(m_context);
b.AddState(1, "Off")
.AddState(2, "On")
.AddTransition(10, "OffToOn", from: 1, to: 2);
Assert.That(() => b.AddTransition(10, "OffToOn2", from: 2, to: 1),
Throws.ArgumentException);
}
[Test]
public void TransitionWithUnknownFromStateFailsAtFreeze()
{
StateMachineBuilder<FluentFiniteStateMachineState> b =
StateMachineTestFixtures.NewBuilder(m_context)
.AddState(1, "Off")
.AddTransition(10, "OffToOn", from: 99, to: 1);
Assert.That(() => _ = b.StateMachine,
Throws.TypeOf<InvalidOperationException>());
}
[Test]
public void CauseMappingWithUnknownTransitionFailsAtFreeze()
{
StateMachineBuilder<FluentFiniteStateMachineState> b =
StateMachineTestFixtures.NewBuilder(m_context)
.AddState(1, "Off")
.OnCause(causeId: 100, from: 1, transition: 999);
Assert.That(() => _ = b.StateMachine,
Throws.TypeOf<InvalidOperationException>());
}
[Test]
public void TwoInitialStatesThrows()
{
StateMachineBuilder<FluentFiniteStateMachineState> b =
StateMachineTestFixtures.NewBuilder(m_context);
b.AddState(1, "Off", isInitial: true);
Assert.That(() => b.AddState(2, "On", isInitial: true),
Throws.InvalidOperationException);
}
[Test]
public void BuildProducesExpectedDefinition()
{
FluentFiniteStateMachineState sm =
StateMachineTestFixtures.NewBuilder(m_context)
.AddState(1, "Off", isInitial: true)
.AddState(2, "On")
.AddTransition(10, "OffToOn", from: 1, to: 2)
.AddTransition(20, "OnToOff", from: 2, to: 1)
.OnCause(causeId: 100, from: 1, transition: 10)
.OnCause(causeId: 200, from: 2, transition: 20)
.StateMachine;
StateMachineDefinition def = sm.Definition;
Assert.That(def.States, Has.Count.EqualTo(2));
Assert.That(def.Transitions, Has.Count.EqualTo(2));
Assert.That(def.CauseMappings, Has.Count.EqualTo(2));
Assert.That(def.InitialStateId, Is.EqualTo(1u));
}
[TestCase("")]
[TestCase(null)]
public void AddStateWithEmptyBrowseNameThrowsArgumentException(string browseName)
{
StateMachineBuilder<FluentFiniteStateMachineState> b =
StateMachineTestFixtures.NewBuilder(m_context);
Assert.That(() => b.AddState(1, browseName!),
Throws.ArgumentException);
}
[TestCase("")]
[TestCase(null)]
public void AddTransitionWithEmptyBrowseNameThrowsArgumentException(string browseName)
{
StateMachineBuilder<FluentFiniteStateMachineState> b =
StateMachineTestFixtures.NewBuilder(m_context)
.AddState(1, "Off")
.AddState(2, "On");
Assert.That(() => b.AddTransition(10, browseName!, from: 1, to: 2),
Throws.ArgumentException);
}
[Test]
public void AddTransitionWithDanglingToStateFailsAtFreeze()
{
StateMachineBuilder<FluentFiniteStateMachineState> b =
StateMachineTestFixtures.NewBuilder(m_context)
.AddState(1, "Off")
.AddTransition(10, "OffToGhost", from: 1, to: 99);
Assert.That(() => _ = b.StateMachine,
Throws.TypeOf<InvalidOperationException>());
}
[TestCase("")]
[TestCase(null)]
public void UseElementNamespaceWithNullOrEmptyThrowsArgumentException(string namespaceUri)
{
StateMachineBuilder<FluentFiniteStateMachineState> b =
StateMachineTestFixtures.NewBuilder(m_context);
Assert.That(() => b.UseElementNamespace(namespaceUri!),
Throws.ArgumentException);
}
[Test]
public void UseElementNamespacePropagatesToDefinition()
{
const string customUri = "urn:test:custom";
FluentFiniteStateMachineState sm =
StateMachineTestFixtures.NewBuilder(m_context)
.UseElementNamespace(customUri)
.AddState(1, "Off", isInitial: true)
.StateMachine;
Assert.That(sm.Definition.ElementNamespaceUri, Is.EqualTo(customUri));
}
[Test]
public void AddStateInitialTrueTwiceWithSameIdDoesNotResetInitialState()
{
StateMachineBuilder<FluentFiniteStateMachineState> b =
StateMachineTestFixtures.NewBuilder(m_context);
b.AddState(1, "Off", isInitial: true);
Assert.That(() => b.AddState(1, "Off", isInitial: true),
Throws.ArgumentException);
b.AddState(2, "On");
Assert.That(b.StateMachine.Definition.InitialStateId,
Is.EqualTo(1u));
}
[Test]
public void HasEffectFalseSurvivesBuildAndIsReflectedOnDefinitionTransitions()
{
FluentFiniteStateMachineState sm =
StateMachineTestFixtures.NewBuilder(m_context)
.AddState(1, "Off", isInitial: true)
.AddState(2, "On")
.AddTransition(10, "OffToOn", from: 1, to: 2, hasEffect: false)
.AddTransition(20, "OnToOff", from: 2, to: 1)
.StateMachine;
StateMachineTransitionDefinition silent = null!;
StateMachineTransitionDefinition loud = null!;
foreach (StateMachineTransitionDefinition t in sm.Definition.Transitions)
{
if (t.Id == 10u)
{
silent = t;
}
if (t.Id == 20u)
{
loud = t;
}
}
Assert.That(silent, Is.Not.Null);
Assert.That(silent.HasEffect, Is.False);
Assert.That(loud, Is.Not.Null);
Assert.That(loud.HasEffect, Is.True);
}
[Test]
public void DefinitionMethodsThrowAfterFreeze()
{
StateMachineBuilder<FluentFiniteStateMachineState> b =
StateMachineTestFixtures.NewBuilder(m_context);
b.AddState(1, "Off", isInitial: true);
_ = b.StateMachine;
Assert.That(() => b.AddState(2, "On"),
Throws.InvalidOperationException);
Assert.That(() => b.AddTransition(10, "x", 1, 1),
Throws.InvalidOperationException);
Assert.That(() => b.OnCause(1, 1, 1),
Throws.InvalidOperationException);
Assert.That(() => b.UseElementNamespace("urn:x"),
Throws.InvalidOperationException);
}
[Test]
public void ForThrowsForDefinitionMethods()
{
FluentFiniteStateMachineState sm =
StateMachineTestFixtures.NewBuilder(m_context)
.AddState(1, "Off", isInitial: true)
.StateMachine;
var lifecycle =
StateMachineBuilder.For(sm, m_context);
Assert.That(() => lifecycle.AddState(2, "On"),
Throws.InvalidOperationException);
}
[Test]
public void DuplicateCauseMappingFailsAtFreeze()
{
StateMachineBuilder<FluentFiniteStateMachineState> b =
StateMachineTestFixtures.NewBuilder(m_context)
.AddState(1, "Off", isInitial: true)
.AddState(2, "On")
.AddTransition(10, "OffToOn", from: 1, to: 2)
.AddTransition(11, "OffToOn2", from: 1, to: 2)
.OnCause(causeId: 100, from: 1, transition: 10)
.OnCause(causeId: 100, from: 1, transition: 11);
Assert.That(() => _ = b.StateMachine,
Throws.InvalidOperationException);
}
[Test]
public void UseElementNamespacePropagatesToRuntimeCurrentStateNodeId()
{
const string customUri = "urn:test:custom-ns";
// The element namespace must be registered with the
// context's NamespaceUris for OnAfterCreate to resolve a
// non-default ElementNamespaceIndex.
ushort registeredIndex = m_context.NamespaceUris.GetIndexOrAppend(customUri);
FluentFiniteStateMachineState sm =
StateMachineTestFixtures.NewBuilder(m_context)
.UseElementNamespace(customUri)
.AddState(1, "Off", isInitial: true)
.AddState(2, "On")
.WithInitialState(1)
.StateMachine;
// The CurrentState.Id NodeId should now use the custom
// namespace index — proving that UseElementNamespace
// applied before NodeState.Create cached it.
NodeId stateId = sm.CurrentState!.Id!.Value;
Assert.That(stateId.NamespaceIndex, Is.EqualTo(registeredIndex),
"ElementNamespaceUri override must take effect before " +
"OnAfterCreate caches ElementNamespaceIndex.");
}
}
/// <summary>
/// Shared setup for state-machine builder tests — produces a
/// minimal <see cref="ServerSystemContext"/> and a builder ready
/// for definition-mode chaining.
/// </summary>
internal static class StateMachineTestFixtures
{
public static ServerSystemContext CreateContext()
{
var mockServer = new Mock<IServerInternal>();
var namespaceTable = new NamespaceTable();
mockServer.Setup(s => s.NamespaceUris).Returns(namespaceTable);
mockServer.Setup(s => s.ServerUris).Returns(new StringTable());
mockServer.Setup(s => s.TypeTree).Returns(new TypeTable(namespaceTable));
mockServer.Setup(s => s.Factory).Returns(EncodeableFactory.Create());
// Telemetry: a plain Moq instance is enough — the
// TelemetryExtensions.CreateLogger&lt;T&gt;() extension falls
// back to a no-op LoggerFactory when GetLoggerFactory()
// returns null.
mockServer.Setup(s => s.Telemetry)
.Returns(new Mock<ITelemetryContext>().Object);
return new ServerSystemContext(mockServer.Object);
}
public static StateMachineBuilder<FluentFiniteStateMachineState> NewBuilder(
ISystemContext context, uint nodeIdNumber = 5000)
{
return StateMachineBuilder.Create(
parent: null,
context: context,
nodeId: new NodeId(nodeIdNumber, 1),
browseName: new QualifiedName("TestStateMachine", 1));
}
}
}