mirror of
https://github.com/OPCFoundation/UA-.NETStandard.git
synced 2026-10-20 08:41:51 +08:00
01d7162313
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`.
182 lines
7.3 KiB
C#
182 lines
7.3 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 System.Collections.Generic;
|
|
|
|
namespace Opc.Ua.Server.StateMachines
|
|
{
|
|
/// <summary>
|
|
/// Immutable snapshot of a Part 16 finite state machine definition.
|
|
/// Produced by <see cref="StateMachineBuilder{TState}"/> (snapshot
|
|
/// of the mutable holder taken on first read) and exposed via
|
|
/// <see cref="FluentFiniteStateMachineState.Definition"/> for
|
|
/// introspection.
|
|
/// </summary>
|
|
public sealed class StateMachineDefinition
|
|
{
|
|
internal StateMachineDefinition(
|
|
IReadOnlyList<StateMachineStateDefinition> states,
|
|
IReadOnlyList<StateMachineTransitionDefinition> transitions,
|
|
IReadOnlyList<StateMachineCauseMapping> causeMappings,
|
|
uint? initialStateId,
|
|
string elementNamespaceUri)
|
|
{
|
|
States = states;
|
|
Transitions = transitions;
|
|
CauseMappings = causeMappings;
|
|
InitialStateId = initialStateId;
|
|
ElementNamespaceUri = elementNamespaceUri;
|
|
}
|
|
|
|
/// <summary>
|
|
/// The set of states declared on the state machine.
|
|
/// </summary>
|
|
public IReadOnlyList<StateMachineStateDefinition> States { get; }
|
|
|
|
/// <summary>
|
|
/// The set of transitions declared on the state machine.
|
|
/// </summary>
|
|
public IReadOnlyList<StateMachineTransitionDefinition> Transitions { get; }
|
|
|
|
/// <summary>
|
|
/// The list of (cause method id, from state, transition) tuples
|
|
/// used by the runtime to resolve a transition for an inbound
|
|
/// method call.
|
|
/// </summary>
|
|
public IReadOnlyList<StateMachineCauseMapping> CauseMappings { get; }
|
|
|
|
/// <summary>
|
|
/// The initial state's numeric id, or <c>null</c> when none was
|
|
/// designated. Concrete state machines apply this on activation.
|
|
/// </summary>
|
|
public uint? InitialStateId { get; }
|
|
|
|
/// <summary>
|
|
/// The namespace URI that qualifies the state and transition
|
|
/// browse names + node ids in the OPC UA address space.
|
|
/// Defaults to <c>http://opcfoundation.org/UA/</c>.
|
|
/// </summary>
|
|
public string ElementNamespaceUri { get; }
|
|
}
|
|
|
|
/// <summary>
|
|
/// Definition of a single state in a Part 16 state machine.
|
|
/// </summary>
|
|
/// <param name="Id">The state's numeric id (used as the
|
|
/// <c>StateNumber</c> property and the <c>NodeId</c> identifier
|
|
/// when applicable).</param>
|
|
/// <param name="BrowseName">The state's localized browse name.</param>
|
|
/// <param name="IsInitial">Whether this state is the starting
|
|
/// state for the machine.</param>
|
|
public sealed record StateMachineStateDefinition(
|
|
uint Id,
|
|
string BrowseName,
|
|
bool IsInitial = false);
|
|
|
|
/// <summary>
|
|
/// Definition of a transition between two states.
|
|
/// </summary>
|
|
/// <param name="Id">The transition's numeric id.</param>
|
|
/// <param name="BrowseName">The transition's browse name.</param>
|
|
/// <param name="FromStateId">The source state id.</param>
|
|
/// <param name="ToStateId">The destination state id.</param>
|
|
/// <param name="HasEffect">Whether the transition fires a
|
|
/// <c>TransitionEventType</c>. Defaults to <c>true</c>.</param>
|
|
public sealed record StateMachineTransitionDefinition(
|
|
uint Id,
|
|
string BrowseName,
|
|
uint FromStateId,
|
|
uint ToStateId,
|
|
bool HasEffect = true);
|
|
|
|
/// <summary>
|
|
/// Maps a cause (method NodeId) plus current state to the
|
|
/// transition that should fire. Used by
|
|
/// <c>FiniteStateMachineState.GetTransitionForCause</c> at runtime.
|
|
/// </summary>
|
|
/// <param name="CauseId">The cause (method) numeric id.</param>
|
|
/// <param name="FromStateId">The current state id.</param>
|
|
/// <param name="TransitionId">The transition that fires.</param>
|
|
public sealed record StateMachineCauseMapping(
|
|
uint CauseId,
|
|
uint FromStateId,
|
|
uint TransitionId);
|
|
|
|
/// <summary>
|
|
/// Internal mutable holder for a state machine definition. The
|
|
/// unified <see cref="StateMachineBuilder{TState}"/> populates an
|
|
/// instance of this type as the user chains
|
|
/// <c>AddState</c> / <c>AddTransition</c> / <c>OnCause</c> calls,
|
|
/// and <see cref="FluentFiniteStateMachineState"/> reads its
|
|
/// runtime tables through it (with invalidate-on-mutation cached
|
|
/// projections for hot-path access).
|
|
/// </summary>
|
|
internal sealed class MutableStateMachineDefinition
|
|
{
|
|
public readonly List<StateMachineStateDefinition> States = [];
|
|
public readonly List<StateMachineTransitionDefinition> Transitions = [];
|
|
public readonly List<StateMachineCauseMapping> CauseMappings = [];
|
|
public uint? InitialStateId;
|
|
public string ElementNamespaceUri = Types.Namespaces.OpcUa;
|
|
|
|
/// <summary>
|
|
/// Version is bumped on every mutation; projections cache by version.
|
|
/// </summary>
|
|
public int Version;
|
|
|
|
public bool Frozen;
|
|
|
|
public void EnsureNotFrozen()
|
|
{
|
|
if (Frozen)
|
|
{
|
|
throw new InvalidOperationException(
|
|
"The state-machine definition has been frozen; " +
|
|
"no further AddState / AddTransition / OnCause / " +
|
|
"UseElementNamespace calls are permitted after the " +
|
|
"first lifecycle method (OnEnterState / OnExitState / " +
|
|
"OnTransition / OnBeforeTransition / WithCause / " +
|
|
"WithTimedTransition) or after the StateMachine has " +
|
|
"been read.");
|
|
}
|
|
}
|
|
|
|
public StateMachineDefinition Snapshot()
|
|
{
|
|
return new StateMachineDefinition(
|
|
[.. States],
|
|
[.. Transitions],
|
|
[.. CauseMappings],
|
|
InitialStateId,
|
|
ElementNamespaceUri);
|
|
}
|
|
}
|
|
}
|