Files
Marc Schier 4756e7c245 DI (OPC 10000-100) with samples (Pump, SW Update), fluent API gap closures and model dependency implementation (#3808)
This PR implements the **OPC UA Device Integration (DI, OPC 10000-100)**
companion-spec library trio (`Opc.Ua.Di` / `Opc.Ua.Di.Server` /
`Opc.Ua.Di.Client`) plus a worked example
(`Applications/MinimalPumpServer`) demonstrating the OPC 40223 Pumps
companion specification end-to-end with full simulation. It also closes
11 fluent-API gaps in `Opc.Ua.Server.Fluent`, three source-generator
bugs, integrates the DI layer into the unified `services.AddOpcUa()`
Microsoft.Extensions DI hosting pattern, and adds 250+ new tests.

**Worked example — `Applications/MinimalPumpServer/`**
- AOT-compatible console host using `Host.CreateApplicationBuilder` +
`AddOpcUa()`.
- `PumpNodeManager` inherits from `DiNodeManager`; multi-namespace (DI +
Machinery + Pumps) via runtime NodeSet2 loading and
`ModelLoaderBuilder`.
- Demonstrates declarative second-pump creation via
`.ConfigureDevicesFor<PumpNodeManager>(...)` and software-package
seeding from the same configurator.
- Full simulation: pressure, temperatures, power, flow, efficiency,
level, cavitation/overheat fault injection, alarm setup, NAMUR-style
supervision.

**Documentation**
- `Docs/Opc.Ua.Di/` — README, DeviceBuilder, Hosting, LockService,
SoftwareUpdate, ClientHelpers (6 new developer guides).
- `Docs/Opc.Ua.Di/ComplianceMatrix.md` — every DI declaration mapped to
In-v1 / Generated / Deferred / Excluded.
- `Docs/CompanionSpecLibraries.md` — packaging guide for new
companion-spec libraries.
- `Docs/FluentApiGaps.md` — historical record of G1–G11.
- `Docs/SourceGeneratedNodeManagers.md` updated for richer node
managers.
- `Docs/plans/StateMachineBuilder.md` — deferred state-machine builder
design.
2026-06-04 05:57:57 +02:00

180 lines
7.0 KiB
C#

/* ========================================================================
* Copyright (c) 2005-2026 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.Runtime.CompilerServices;
using Opc.Ua.SourceGeneration.Dependency;
namespace Opc.Ua.SourceGeneration
{
/// <summary>
/// Information read from a referenced assembly's
/// <see cref="ModelDependencyAttribute"/>. Value-type equatable so the
/// incremental source-generator cache keys behave correctly.
/// </summary>
public readonly struct ModelDependencyReference : IEquatable<ModelDependencyReference>
{
/// <summary>
/// Create a reference.
/// </summary>
public ModelDependencyReference(
string assemblyName,
string modelUri,
string prefix,
string version,
string publicationDate,
string name = null,
string payload = null)
{
AssemblyName = assemblyName ?? string.Empty;
ModelUri = modelUri ?? string.Empty;
Prefix = prefix ?? string.Empty;
Version = version ?? string.Empty;
PublicationDate = publicationDate ?? string.Empty;
Name = name ?? string.Empty;
Payload = payload ?? string.Empty;
}
/// <summary>
/// Returns true when the entry has both a model URI and a C# prefix.
/// </summary>
public bool IsValid => ModelUri.Length != 0 && Prefix.Length != 0;
/// <summary>
/// The assembly the attribute was read from.
/// </summary>
public string AssemblyName { get; }
/// <summary>
/// The OPC UA model URI recorded in the attribute.
/// </summary>
public string ModelUri { get; }
/// <summary>
/// The C# namespace the assembly used for this model's generated types.
/// </summary>
public string Prefix { get; }
/// <summary>
/// The model version string (may be empty).
/// </summary>
public string Version { get; }
/// <summary>
/// The model publication date (ISO-8601; may be empty).
/// </summary>
public string PublicationDate { get; }
/// <summary>The C# identifier used for the model's name constant inside
/// the referenced assembly's <c>Namespaces</c> class (may be empty).</summary>
public string Name { get; }
/// <summary>
/// Base64-encoded Deflate-compressed <c>ModelDependencyV1</c>
/// payload. Empty on transitive-dependency entries; non-empty
/// only on the producing assembly's self-declaration entry.
/// </summary>
public string Payload { get; }
/// <summary>
/// Decodes and memoises the <see cref="Payload"/> as a
/// <see cref="ModelDependencyV1"/>. Returns <c>null</c> when the
/// payload is empty, malformed, or carries an unknown version.
/// </summary>
/// <remarks>
/// Memoisation is keyed on the payload string to avoid re-decoding
/// the same multi-kilobyte byte block when the same dependency
/// flows through Roslyn's incremental cache multiple times.
/// </remarks>
public ModelDependencyV1 GetDependency()
{
if (string.IsNullOrEmpty(Payload))
{
return null;
}
return s_decoded.GetValue(Payload, DecodePayload);
}
private static ModelDependencyV1 DecodePayload(string payload)
{
return ModelDependencyV1.FromBase64Payload(payload);
}
private static readonly ConditionalWeakTable<string, ModelDependencyV1> s_decoded
= new ConditionalWeakTable<string, ModelDependencyV1>();
/// <inheritdoc/>
public bool Equals(ModelDependencyReference other)
{
return
string.Equals(AssemblyName, other.AssemblyName, StringComparison.Ordinal) &&
string.Equals(ModelUri, other.ModelUri, StringComparison.Ordinal) &&
string.Equals(Prefix, other.Prefix, StringComparison.Ordinal) &&
string.Equals(Version, other.Version, StringComparison.Ordinal) &&
string.Equals(PublicationDate, other.PublicationDate, StringComparison.Ordinal) &&
string.Equals(Name, other.Name, StringComparison.Ordinal) &&
string.Equals(Payload, other.Payload, StringComparison.Ordinal);
}
/// <inheritdoc/>
public override bool Equals(object obj)
{
return obj is ModelDependencyReference other && Equals(other);
}
/// <inheritdoc/>
public override int GetHashCode()
{
unchecked
{
int hash = StringComparer.Ordinal.GetHashCode(AssemblyName);
hash = (hash * 397) ^ StringComparer.Ordinal.GetHashCode(ModelUri);
hash = (hash * 397) ^ StringComparer.Ordinal.GetHashCode(Prefix);
hash = (hash * 397) ^ StringComparer.Ordinal.GetHashCode(Version);
hash = (hash * 397) ^ StringComparer.Ordinal.GetHashCode(PublicationDate);
hash = (hash * 397) ^ StringComparer.Ordinal.GetHashCode(Name);
hash = (hash * 397) ^ StringComparer.Ordinal.GetHashCode(Payload);
return hash;
}
}
/// <inheritdoc/>
public static bool operator ==(ModelDependencyReference left, ModelDependencyReference right)
{
return left.Equals(right);
}
/// <inheritdoc/>
public static bool operator !=(ModelDependencyReference left, ModelDependencyReference right)
{
return !left.Equals(right);
}
}
}