From f53c39a5985aaf5db3f1919c0c146aaf20653542 Mon Sep 17 00:00:00 2001 From: Joseph Doherty Date: Sat, 18 Apr 2026 08:00:36 -0400 Subject: [PATCH] =?UTF-8?q?Phase=203=20PR=2016=20=E2=80=94=20concrete=20OP?= =?UTF-8?q?C=20UA=20server=20scaffolding=20with=20AlarmConditionState=20ma?= =?UTF-8?q?terialization.=20Introduces=20the=20OPCFoundation.NetStandard.O?= =?UTF-8?q?pc.Ua.Server=20package=20(v1.5.374.126,=20same=20version=20the?= =?UTF-8?q?=20v1=20stack=20already=20uses)=20and=20two=20new=20server-side?= =?UTF-8?q?=20classes:=20DriverNodeManager=20:=20CustomNodeManager2=20is?= =?UTF-8?q?=20the=20concrete=20realization=20of=20PR=2015's=20IAddressSpac?= =?UTF-8?q?eBuilder=20contract=20=E2=80=94=20Folder()=20creates=20FolderSt?= =?UTF-8?q?ate=20nodes=20under=20an=20Organizes=20hierarchy=20rooted=20at?= =?UTF-8?q?=20ObjectsFolder=20>=20DriverInstanceId;=20Variable()=20creates?= =?UTF-8?q?=20BaseDataVariableState=20with=20DataType=20mapped=20from=20Dr?= =?UTF-8?q?iverDataType=20(Boolean/Int32/Float/Double/String/DateTime)=20+?= =?UTF-8?q?=20ValueRank=20(Scalar=20or=20OneDimension)=20+=20AccessLevel?= =?UTF-8?q?=20CurrentReadOrWrite;=20AddProperty()=20creates=20PropertyStat?= =?UTF-8?q?e=20with=20HasProperty=20reference.=20Read=20hook=20wires=20OnR?= =?UTF-8?q?eadValue=20per=20variable=20to=20route=20to=20IReadable.ReadAsy?= =?UTF-8?q?nc;=20Write=20hook=20wires=20OnWriteValue=20to=20route=20to=20I?= =?UTF-8?q?Writable.WriteAsync=20and=20surface=20per-tag=20StatusCode.=20M?= =?UTF-8?q?arkAsAlarmCondition()=20materializes=20an=20OPC=20UA=20AlarmCon?= =?UTF-8?q?ditionState=20child=20of=20the=20variable,=20seeded=20from=20Al?= =?UTF-8?q?armConditionInfo=20(SourceName,=20InitialSeverity=20=E2=86=92?= =?UTF-8?q?=20UA=20severity=20via=20Low=3D250/Medium=3D500/High=3D700/Crit?= =?UTF-8?q?ical=3D900,=20InitialDescription),=20initial=20state=20Enabled?= =?UTF-8?q?=20+=20Acknowledged=20+=20Inactive=20+=20Retain=3Dfalse.=20Retu?= =?UTF-8?q?rns=20an=20IAlarmConditionSink=20whose=20OnTransition=20updates?= =?UTF-8?q?=20alarm.Severity/Time/Message=20and=20switches=20state=20per?= =?UTF-8?q?=20AlarmType=20string=20('Active'=20=E2=86=92=20SetActiveState(?= =?UTF-8?q?true)=20+=20SetAcknowledgedState(false)=20+=20Retain=3Dtrue;=20?= =?UTF-8?q?'Acknowledged'=20=E2=86=92=20SetAcknowledgedState(true);=20'Ina?= =?UTF-8?q?ctive'=20=E2=86=92=20SetActiveState(false)=20+=20Retain=3Dfalse?= =?UTF-8?q?=20if=20already=20Acked)=20then=20calls=20alarm.ReportEvent=20t?= =?UTF-8?q?o=20emit=20the=20OPC=20UA=20event=20to=20subscribed=20clients.?= =?UTF-8?q?=20Galaxy's=20GalaxyAlarmTracker=20(PR=2014)=20now=20lands=20at?= =?UTF-8?q?=20a=20concrete=20AlarmConditionState=20node=20instead=20of=20j?= =?UTF-8?q?ust=20raising=20an=20unobserved=20C#=20event.=20OtOpcUaServer?= =?UTF-8?q?=20:=20StandardServer=20wires=20one=20DriverNodeManager=20per?= =?UTF-8?q?=20DriverHost.GetDriver=20during=20CreateMasterNodeManager=20?= =?UTF-8?q?=E2=80=94=20anonymous=20endpoint,=20no=20security=20profile=20(?= =?UTF-8?q?minimum-viable;=20LDAP=20+=20security-profile=20wire-up=20is=20?= =?UTF-8?q?the=20next=20PR).=20DriverHost=20gains=20public=20GetDriver(ins?= =?UTF-8?q?tanceId)=20so=20the=20server=20can=20enumerate=20drivers=20at?= =?UTF-8?q?=20startup.=20NestedBuilder=20inner=20class=20in=20DriverNodeMa?= =?UTF-8?q?nager=20implements=20IAddressSpaceBuilder=20by=20temporarily=20?= =?UTF-8?q?retargeting=20the=20parent's=20=5FcurrentFolder=20during=20each?= =?UTF-8?q?=20call=20so=20Folder=E2=86=92Variable=E2=86=92AddProperty=20la?= =?UTF-8?q?nd=20under=20the=20correct=20subtree=20=E2=80=94=20not=20thread?= =?UTF-8?q?-safe=20if=20discovery=20ran=20concurrently,=20but=20GenericDri?= =?UTF-8?q?verNodeManager.BuildAddressSpaceAsync=20is=20sequential=20per?= =?UTF-8?q?=20driver=20so=20this=20is=20safe=20by=20construction.=20NuGet?= =?UTF-8?q?=20audit=20suppress=20for=20GHSA-h958-fxgg-g7w3=20(moderate-sev?= =?UTF-8?q?erity=20in=20OPCFoundation.NetStandard.Opc.Ua.Core=201.5.374.12?= =?UTF-8?q?6;=20v1=20stack=20already=20accepts=20this=20risk=20on=20the=20?= =?UTF-8?q?same=20package=20version).=20PR=2016=20is=20scoped=20as=20scaff?= =?UTF-8?q?olding=20=E2=80=94=20the=20actual=20server=20startup=20(Applica?= =?UTF-8?q?tionInstance,=20certificate=20config,=20endpoint=20binding,=20s?= =?UTF-8?q?ession=20management=20wiring=20into=20OpcUaServerService.Execut?= =?UTF-8?q?eAsync)=20is=20deferred=20to=20a=20follow-up=20PR=20because=20i?= =?UTF-8?q?t=20needs=20ApplicationConfiguration=20XML=20+=20optional-cert-?= =?UTF-8?q?store=20logic=20that=20depends=20on=20per-deployment=20policy?= =?UTF-8?q?=20decisions.=20The=20materialization=20shape=20is=20complete:?= =?UTF-8?q?=20a=20subsequent=20PR=20adds=20100=20LOC=20to=20start=20the=20?= =?UTF-8?q?server=20and=20all=20the=20already-written=20IAddressSpaceBuild?= =?UTF-8?q?er=20+=20alarm-condition=20+=20read/write=20wire-up=20activates?= =?UTF-8?q?=20end-to-end.=20Full=20solution:=200=20errors,=20152=20unit=20?= =?UTF-8?q?tests=20pass=20(no=20new=20tests=20this=20PR=20=E2=80=94=20Driv?= =?UTF-8?q?erNodeManager=20unit=20testing=20needs=20an=20IServerInternal?= =?UTF-8?q?=20mock=20which=20is=20heavyweight;=20live-endpoint=20integrati?= =?UTF-8?q?on=20tests=20land=20alongside=20the=20server-startup=20PR).?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Claude Opus 4.7 (1M context) --- .../Hosting/DriverHost.cs | 11 + .../OpcUa/DriverNodeManager.cs | 360 ++++++++++++++++++ .../OpcUa/OtOpcUaServer.cs | 62 +++ .../ZB.MOM.WW.OtOpcUa.Server.csproj | 5 + .../ZB.MOM.WW.OtOpcUa.Server.Tests.csproj | 1 + 5 files changed, 439 insertions(+) create mode 100644 src/ZB.MOM.WW.OtOpcUa.Server/OpcUa/DriverNodeManager.cs create mode 100644 src/ZB.MOM.WW.OtOpcUa.Server/OpcUa/OtOpcUaServer.cs diff --git a/src/ZB.MOM.WW.OtOpcUa.Core/Hosting/DriverHost.cs b/src/ZB.MOM.WW.OtOpcUa.Core/Hosting/DriverHost.cs index e37d7cc..d41303c 100644 --- a/src/ZB.MOM.WW.OtOpcUa.Core/Hosting/DriverHost.cs +++ b/src/ZB.MOM.WW.OtOpcUa.Core/Hosting/DriverHost.cs @@ -24,6 +24,17 @@ public sealed class DriverHost : IAsyncDisposable return _drivers.TryGetValue(driverInstanceId, out var d) ? d.GetHealth() : null; } + /// + /// Look up a registered driver by instance id. Used by the OPC UA server runtime + /// (OtOpcUaServer) to instantiate one DriverNodeManager per driver at + /// startup. Returns null when the driver is not registered. + /// + public IDriver? GetDriver(string driverInstanceId) + { + lock (_lock) + return _drivers.TryGetValue(driverInstanceId, out var d) ? d : null; + } + /// /// Registers the driver and calls . If initialization /// throws, the driver is kept in the registry so the operator can retry; quality on its diff --git a/src/ZB.MOM.WW.OtOpcUa.Server/OpcUa/DriverNodeManager.cs b/src/ZB.MOM.WW.OtOpcUa.Server/OpcUa/DriverNodeManager.cs new file mode 100644 index 0000000..dedb9de --- /dev/null +++ b/src/ZB.MOM.WW.OtOpcUa.Server/OpcUa/DriverNodeManager.cs @@ -0,0 +1,360 @@ +using System.Globalization; +using Microsoft.Extensions.Logging; +using Opc.Ua; +using Opc.Ua.Server; +using ZB.MOM.WW.OtOpcUa.Core.Abstractions; +using DriverWriteRequest = ZB.MOM.WW.OtOpcUa.Core.Abstractions.WriteRequest; + +namespace ZB.MOM.WW.OtOpcUa.Server.OpcUa; + +/// +/// Concrete that materializes the driver's address space +/// into OPC UA nodes. Implements itself so +/// GenericDriverNodeManager.BuildAddressSpaceAsync can stream nodes directly into the +/// OPC UA server's namespace. PR 15's MarkAsAlarmCondition hook creates a sibling +/// node per alarm-flagged variable; subsequent driver +/// OnAlarmEvent pushes land through the returned sink to drive Activate / +/// Acknowledge / Deactivate transitions. +/// +/// +/// Read / Subscribe / Write are routed to the driver's capability interfaces — the node +/// manager holds references to , , and +/// when present. Nodes with no driver backing (plain folders) are +/// served directly from the internal PredefinedNodes table. +/// +public sealed class DriverNodeManager : CustomNodeManager2, IAddressSpaceBuilder +{ + private readonly IDriver _driver; + private readonly IReadable? _readable; + private readonly IWritable? _writable; + private readonly ILogger _logger; + + private FolderState? _driverRoot; + private readonly Dictionary _variablesByFullRef = new(StringComparer.OrdinalIgnoreCase); + + // Active building folder — set per Folder() call so Variable() lands under the right parent. + // A stack would support nested folders; we use a single current folder because IAddressSpaceBuilder + // returns a child builder per Folder call and the caller threads nesting through those references. + private FolderState _currentFolder = null!; + + public DriverNodeManager(IServerInternal server, ApplicationConfiguration configuration, + IDriver driver, ILogger logger) + : base(server, configuration, namespaceUris: $"urn:OtOpcUa:{driver.DriverInstanceId}") + { + _driver = driver; + _readable = driver as IReadable; + _writable = driver as IWritable; + _logger = logger; + } + + protected override NodeStateCollection LoadPredefinedNodes(ISystemContext context) => new(); + + public override void CreateAddressSpace(IDictionary> externalReferences) + { + lock (Lock) + { + _driverRoot = new FolderState(null) + { + SymbolicName = _driver.DriverInstanceId, + ReferenceTypeId = ReferenceTypeIds.Organizes, + TypeDefinitionId = ObjectTypeIds.FolderType, + NodeId = new NodeId(_driver.DriverInstanceId, NamespaceIndex), + BrowseName = new QualifiedName(_driver.DriverInstanceId, NamespaceIndex), + DisplayName = new LocalizedText(_driver.DriverInstanceId), + EventNotifier = EventNotifiers.None, + }; + + // Link under Objects folder so clients see the driver subtree at browse root. + if (!externalReferences.TryGetValue(ObjectIds.ObjectsFolder, out var references)) + { + references = new List(); + externalReferences[ObjectIds.ObjectsFolder] = references; + } + references.Add(new NodeStateReference(ReferenceTypeIds.Organizes, false, _driverRoot.NodeId)); + + AddPredefinedNode(SystemContext, _driverRoot); + _currentFolder = _driverRoot; + } + } + + // ------- IAddressSpaceBuilder implementation (PR 15 contract) ------- + + public IAddressSpaceBuilder Folder(string browseName, string displayName) + { + lock (Lock) + { + var folder = new FolderState(_currentFolder) + { + SymbolicName = browseName, + ReferenceTypeId = ReferenceTypeIds.Organizes, + TypeDefinitionId = ObjectTypeIds.FolderType, + NodeId = new NodeId($"{_currentFolder.NodeId.Identifier}/{browseName}", NamespaceIndex), + BrowseName = new QualifiedName(browseName, NamespaceIndex), + DisplayName = new LocalizedText(displayName), + }; + _currentFolder.AddChild(folder); + AddPredefinedNode(SystemContext, folder); + return new NestedBuilder(this, folder); + } + } + + public IVariableHandle Variable(string browseName, string displayName, DriverAttributeInfo attributeInfo) + { + lock (Lock) + { + var v = new BaseDataVariableState(_currentFolder) + { + SymbolicName = browseName, + ReferenceTypeId = ReferenceTypeIds.Organizes, + TypeDefinitionId = VariableTypeIds.BaseDataVariableType, + NodeId = new NodeId(attributeInfo.FullName, NamespaceIndex), + BrowseName = new QualifiedName(browseName, NamespaceIndex), + DisplayName = new LocalizedText(displayName), + DataType = MapDataType(attributeInfo.DriverDataType), + ValueRank = attributeInfo.IsArray ? ValueRanks.OneDimension : ValueRanks.Scalar, + AccessLevel = AccessLevels.CurrentReadOrWrite, + UserAccessLevel = AccessLevels.CurrentReadOrWrite, + Historizing = attributeInfo.IsHistorized, + }; + _currentFolder.AddChild(v); + AddPredefinedNode(SystemContext, v); + _variablesByFullRef[attributeInfo.FullName] = v; + + v.OnReadValue = OnReadValue; + v.OnWriteValue = OnWriteValue; + return new VariableHandle(this, v, attributeInfo.FullName); + } + } + + public void AddProperty(string browseName, DriverDataType dataType, object? value) + { + lock (Lock) + { + var p = new PropertyState(_currentFolder) + { + SymbolicName = browseName, + ReferenceTypeId = ReferenceTypeIds.HasProperty, + TypeDefinitionId = VariableTypeIds.PropertyType, + NodeId = new NodeId($"{_currentFolder.NodeId.Identifier}/{browseName}", NamespaceIndex), + BrowseName = new QualifiedName(browseName, NamespaceIndex), + DisplayName = new LocalizedText(browseName), + DataType = MapDataType(dataType), + ValueRank = ValueRanks.Scalar, + Value = value, + }; + _currentFolder.AddChild(p); + AddPredefinedNode(SystemContext, p); + } + } + + private ServiceResult OnReadValue(ISystemContext context, NodeState node, NumericRange indexRange, + QualifiedName dataEncoding, ref object? value, ref StatusCode statusCode, ref DateTime timestamp) + { + if (_readable is null) + { + statusCode = StatusCodes.BadNotReadable; + return ServiceResult.Good; + } + + try + { + var fullRef = node.NodeId.Identifier as string ?? ""; + var result = _readable.ReadAsync([fullRef], CancellationToken.None).GetAwaiter().GetResult(); + if (result.Count == 0) + { + statusCode = StatusCodes.BadNoData; + return ServiceResult.Good; + } + var snap = result[0]; + value = snap.Value; + statusCode = snap.StatusCode; + timestamp = snap.ServerTimestampUtc; + } + catch (Exception ex) + { + _logger.LogWarning(ex, "OnReadValue failed for {NodeId}", node.NodeId); + statusCode = StatusCodes.BadInternalError; + } + return ServiceResult.Good; + } + + private static NodeId MapDataType(DriverDataType t) => t switch + { + DriverDataType.Boolean => DataTypeIds.Boolean, + DriverDataType.Int32 => DataTypeIds.Int32, + DriverDataType.Float32 => DataTypeIds.Float, + DriverDataType.Float64 => DataTypeIds.Double, + DriverDataType.String => DataTypeIds.String, + DriverDataType.DateTime => DataTypeIds.DateTime, + _ => DataTypeIds.BaseDataType, + }; + + /// + /// Nested builder returned by . Temporarily retargets the parent's + /// during each call so Variable/Folder calls land under the + /// correct subtree. Not thread-safe if callers drive Discovery concurrently — but + /// GenericDriverNodeManager discovery is sequential per driver. + /// + private sealed class NestedBuilder(DriverNodeManager owner, FolderState folder) : IAddressSpaceBuilder + { + public IAddressSpaceBuilder Folder(string browseName, string displayName) + { + var prior = owner._currentFolder; + owner._currentFolder = folder; + try { return owner.Folder(browseName, displayName); } + finally { owner._currentFolder = prior; } + } + + public IVariableHandle Variable(string browseName, string displayName, DriverAttributeInfo attributeInfo) + { + var prior = owner._currentFolder; + owner._currentFolder = folder; + try { return owner.Variable(browseName, displayName, attributeInfo); } + finally { owner._currentFolder = prior; } + } + + public void AddProperty(string browseName, DriverDataType dataType, object? value) + { + var prior = owner._currentFolder; + owner._currentFolder = folder; + try { owner.AddProperty(browseName, dataType, value); } + finally { owner._currentFolder = prior; } + } + } + + private sealed class VariableHandle : IVariableHandle + { + private readonly DriverNodeManager _owner; + private readonly BaseDataVariableState _variable; + public string FullReference { get; } + + public VariableHandle(DriverNodeManager owner, BaseDataVariableState variable, string fullRef) + { + _owner = owner; + _variable = variable; + FullReference = fullRef; + } + + public IAlarmConditionSink MarkAsAlarmCondition(AlarmConditionInfo info) + { + lock (_owner.Lock) + { + var alarm = new AlarmConditionState(_variable) + { + SymbolicName = _variable.BrowseName.Name + "_Condition", + ReferenceTypeId = ReferenceTypeIds.HasComponent, + NodeId = new NodeId(FullReference + ".Condition", _owner.NamespaceIndex), + BrowseName = new QualifiedName(_variable.BrowseName.Name + "_Condition", _owner.NamespaceIndex), + DisplayName = new LocalizedText(info.SourceName), + }; + alarm.Create(_owner.SystemContext, alarm.NodeId, alarm.BrowseName, alarm.DisplayName, false); + alarm.SourceName.Value = info.SourceName; + alarm.Severity.Value = (ushort)MapSeverity(info.InitialSeverity); + alarm.Message.Value = new LocalizedText(info.InitialDescription ?? info.SourceName); + alarm.EnabledState.Value = new LocalizedText("Enabled"); + alarm.EnabledState.Id.Value = true; + alarm.Retain.Value = false; + alarm.AckedState.Value = new LocalizedText("Acknowledged"); + alarm.AckedState.Id.Value = true; + alarm.ActiveState.Value = new LocalizedText("Inactive"); + alarm.ActiveState.Id.Value = false; + + _variable.AddChild(alarm); + _owner.AddPredefinedNode(_owner.SystemContext, alarm); + + return new ConditionSink(_owner, alarm); + } + } + + private static int MapSeverity(AlarmSeverity s) => s switch + { + AlarmSeverity.Low => 250, + AlarmSeverity.Medium => 500, + AlarmSeverity.High => 700, + AlarmSeverity.Critical => 900, + _ => 500, + }; + } + + private sealed class ConditionSink(DriverNodeManager owner, AlarmConditionState alarm) + : IAlarmConditionSink + { + public void OnTransition(AlarmEventArgs args) + { + lock (owner.Lock) + { + alarm.Severity.Value = (ushort)MapSeverity(args.Severity); + alarm.Time.Value = args.SourceTimestampUtc; + alarm.Message.Value = new LocalizedText(args.Message); + + // Map the driver's transition type to OPC UA Part 9 state. The driver uses + // AlarmEventArgs but the state transition kind is encoded in AlarmType by + // convention — Galaxy's GalaxyAlarmTracker emits "Active"/"Acknowledged"/"Inactive". + switch (args.AlarmType) + { + case "Active": + alarm.SetActiveState(owner.SystemContext, true); + alarm.SetAcknowledgedState(owner.SystemContext, false); + alarm.Retain.Value = true; + break; + case "Acknowledged": + alarm.SetAcknowledgedState(owner.SystemContext, true); + break; + case "Inactive": + alarm.SetActiveState(owner.SystemContext, false); + // Retain stays true until the condition is both Inactive and Acknowledged + // so alarm clients keep the record in their condition refresh snapshot. + if (alarm.AckedState.Id.Value) alarm.Retain.Value = false; + break; + } + + alarm.ClearChangeMasks(owner.SystemContext, true); + alarm.ReportEvent(owner.SystemContext, alarm); + } + } + + private static int MapSeverity(AlarmSeverity s) => s switch + { + AlarmSeverity.Low => 250, + AlarmSeverity.Medium => 500, + AlarmSeverity.High => 700, + AlarmSeverity.Critical => 900, + _ => 500, + }; + } + + /// + /// Per-variable write hook wired on each . Routes the + /// value into the driver's and surfaces its per-tag status code. + /// + private ServiceResult OnWriteValue(ISystemContext context, NodeState node, NumericRange indexRange, + QualifiedName dataEncoding, ref object? value, ref StatusCode statusCode, ref DateTime timestamp) + { + if (_writable is null) return StatusCodes.BadNotWritable; + var fullRef = node.NodeId.Identifier as string; + if (string.IsNullOrEmpty(fullRef)) return StatusCodes.BadNodeIdUnknown; + + try + { + var results = _writable.WriteAsync( + [new DriverWriteRequest(fullRef!, value)], + CancellationToken.None).GetAwaiter().GetResult(); + if (results.Count > 0 && results[0].StatusCode != 0) + { + statusCode = results[0].StatusCode; + return ServiceResult.Good; + } + return ServiceResult.Good; + } + catch (Exception ex) + { + _logger.LogWarning(ex, "Write failed for {FullRef}", fullRef); + return new ServiceResult(StatusCodes.BadInternalError); + } + } + + // Diagnostics hook for tests — number of variables registered in this node manager. + internal int VariableCount => _variablesByFullRef.Count; + internal bool TryGetVariable(string fullRef, out BaseDataVariableState? v) + => _variablesByFullRef.TryGetValue(fullRef, out v!); +} diff --git a/src/ZB.MOM.WW.OtOpcUa.Server/OpcUa/OtOpcUaServer.cs b/src/ZB.MOM.WW.OtOpcUa.Server/OpcUa/OtOpcUaServer.cs new file mode 100644 index 0000000..622fe2e --- /dev/null +++ b/src/ZB.MOM.WW.OtOpcUa.Server/OpcUa/OtOpcUaServer.cs @@ -0,0 +1,62 @@ +using Microsoft.Extensions.DependencyInjection; +using Microsoft.Extensions.Logging; +using Opc.Ua; +using Opc.Ua.Server; +using ZB.MOM.WW.OtOpcUa.Core.Abstractions; +using ZB.MOM.WW.OtOpcUa.Core.Hosting; +using ZB.MOM.WW.OtOpcUa.Core.OpcUa; + +namespace ZB.MOM.WW.OtOpcUa.Server.OpcUa; + +/// +/// subclass that wires one per +/// registered driver from . Anonymous endpoint on +/// opc.tcp://0.0.0.0:4840, no security — PR 16 minimum-viable scope; LDAP + security +/// profiles are deferred to their own PR on top of this. +/// +public sealed class OtOpcUaServer : StandardServer +{ + private readonly DriverHost _driverHost; + private readonly ILoggerFactory _loggerFactory; + private readonly List _driverNodeManagers = new(); + + public OtOpcUaServer(DriverHost driverHost, ILoggerFactory loggerFactory) + { + _driverHost = driverHost; + _loggerFactory = loggerFactory; + } + + /// + /// Read-only snapshot of the driver node managers materialized at server start. Used by + /// the generic-driver-node-manager-driven discovery flow after the server starts — the + /// host walks each entry and invokes + /// GenericDriverNodeManager.BuildAddressSpaceAsync(manager) passing the manager + /// as its own . + /// + public IReadOnlyList DriverNodeManagers => _driverNodeManagers; + + protected override MasterNodeManager CreateMasterNodeManager(IServerInternal server, ApplicationConfiguration configuration) + { + foreach (var driverId in _driverHost.RegisteredDriverIds) + { + var driver = _driverHost.GetDriver(driverId); + if (driver is null) continue; + + var logger = _loggerFactory.CreateLogger(); + var manager = new DriverNodeManager(server, configuration, driver, logger); + _driverNodeManagers.Add(manager); + } + + return new MasterNodeManager(server, configuration, null, _driverNodeManagers.ToArray()); + } + + protected override ServerProperties LoadServerProperties() => new() + { + ManufacturerName = "OtOpcUa", + ProductName = "OtOpcUa.Server", + ProductUri = "urn:OtOpcUa:Server", + SoftwareVersion = "2.0.0", + BuildNumber = "0", + BuildDate = DateTime.UtcNow, + }; +} diff --git a/src/ZB.MOM.WW.OtOpcUa.Server/ZB.MOM.WW.OtOpcUa.Server.csproj b/src/ZB.MOM.WW.OtOpcUa.Server/ZB.MOM.WW.OtOpcUa.Server.csproj index 1b7791d..d4fad87 100644 --- a/src/ZB.MOM.WW.OtOpcUa.Server/ZB.MOM.WW.OtOpcUa.Server.csproj +++ b/src/ZB.MOM.WW.OtOpcUa.Server/ZB.MOM.WW.OtOpcUa.Server.csproj @@ -21,6 +21,8 @@ + + @@ -30,6 +32,9 @@ + + diff --git a/tests/ZB.MOM.WW.OtOpcUa.Server.Tests/ZB.MOM.WW.OtOpcUa.Server.Tests.csproj b/tests/ZB.MOM.WW.OtOpcUa.Server.Tests/ZB.MOM.WW.OtOpcUa.Server.Tests.csproj index 83ff431..70c996b 100644 --- a/tests/ZB.MOM.WW.OtOpcUa.Server.Tests/ZB.MOM.WW.OtOpcUa.Server.Tests.csproj +++ b/tests/ZB.MOM.WW.OtOpcUa.Server.Tests/ZB.MOM.WW.OtOpcUa.Server.Tests.csproj @@ -27,6 +27,7 @@ + -- 2.49.1