Files
Marc Schier 724757122b Add recycling simulator and plastics/rubber companion packages (#4772)
# Description

Add a generic, company-neutral recycling simulation sample and reusable
plastics/rubber companion-model packages. One durable causal coordinator
and ten separately launched OPC UA process views provide deterministic
material balances, finite buffers, genealogy, utilities, quality
holds/disposition, authenticated controls and crash recovery. Process
views consume committed state instead of running independent
simulations.

Real companion-model equipment instances use DI/Machinery/AMB discovery,
Machine Vision, Pumps/Scales, granulate drying, extrusion, filtration
and pelletizing. Vendor/process extensions remain sample-local.
Connectors and WoT conversion are out of scope. **External
source-contract parity and complete deployment qualification are not
claimed complete.**

The sample and managed tests target **.NET 8, 9 and 10**. The
consolidated [recycling guide](samples/Recycling/README.md) explains the
actual composition, simulation, observation paths and exposed data; the
application-directory README points to that guide.

Typed client member extensions are emitted at build time through the
default-false `ModelSourceGeneratorClientAccessorsOnly` opt-in.
Extrusion uses it for all twelve parts instead of checked-in generated
C# and a Python generator. The shared client runtime retains typed
values, quality, timestamps and streaming behavior.

### Package layout

Six packages contain fourteen models in two model-producing assemblies:

| Specifications | Model | Typed client | Server runtime |
| --- | --- | --- | --- |
| OPC 40083 and OPC 40082-6 | `Opc.Ua.PlasticsRubber` |
`Opc.Ua.PlasticsRubber.Client` | `Opc.Ua.PlasticsRubber.Server` |
| OPC 40084 parts 1–12 | `Opc.Ua.Extrusion` | `Opc.Ua.Extrusion.Client`
| `Opc.Ua.Extrusion.Server` |

NuGet IDs use the `OPCFoundation.NetStandard.` prefix. All six packages
are registered in `.azurepipelines/expected-packages.txt` and the
generated preview-pack solution. Granulate-drying code lives in
`GranulateDrying` folders in the PlasticsRubber projects; extrusion uses
per-part folders. There are no standalone granulate-drying or per-part
extrusion packages. Published model identities and CLR namespaces remain
distinct and unchanged.

The common 1.03 interface is independently authored on the explicitly
MIT-licensed 1.02 implementation basis; the official 1.03 XML is not
redistributed. The other imported models retain their individual MIT
notices. All 42 pinned model, identifier and basis files retain their
manifest-backed bytes, including their staged Git blobs. No formal
companion certification is claimed; the disputed Filter profile is not
advertised.

## Related Issues

No tracking issue is currently linked.

## Checklist

_Put an `x` in the boxes that apply. You can complete these step by step
after opening the PR._

- [ ] I have signed the
[CLA](https://opcfoundation.org/license/cla/ContributorLicenseAgreementv1.0.pdf)
and read the
[CONTRIBUTING](https://github.com/OPCFoundation/UA-.NETStandard/blob/master/CONTRIBUTING.md)
doc.
- [ ] I have added tests that prove my fix is effective or that my
feature works and increased code coverage.
- [x] I have added all necessary documentation.
- [x] I have verified that my changes do not introduce (new) build or
analyzer warnings.
- [ ] I ran **all** tests locally using the **UA.slnx** solution against
at least .net **framework** and .net **10**, and all passed.
- [ ] I fixed **all** failing and flaky tests in the CI pipelines and
**all** CodeQL warnings.
- [x] I have addressed **all** PR feedback received.

Current-head CI and coverage remain pending; the full local `UA.slnx`
test matrix is not claimed complete.
2026-10-15 07:00:58 +02:00

244 lines
9.9 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.Collections.Generic;
using System.Linq;
using NUnit.Framework;
using Opc.Ua.Gpos;
using Opc.Ua.Rsl;
namespace Opc.Ua.Positioning.Tests
{
[TestFixture]
[Category("Positioning")]
public sealed class ModelGenerationTests
{
[Test]
public void GeneratedNamespacesAndIdentifiersMatchSpecifications()
{
Assert.Multiple(() =>
{
Assert.That(
Rsl.Namespaces.RSL,
Is.EqualTo("http://opcfoundation.org/UA/RSL/"));
Assert.That(
Gpos.Namespaces.GPOS,
Is.EqualTo("http://opcfoundation.org/UA/GPOS/"));
Assert.That(Rsl.ObjectTypes.SpatialObjectType, Is.EqualTo(1002));
Assert.That(Rsl.Objects.RelativeSpatialLocations, Is.EqualTo(5001));
Assert.That(Gpos.ObjectTypes.ZoneType, Is.EqualTo(1005));
Assert.That(Gpos.Objects.GlobalLocations, Is.EqualTo(5013));
});
}
/// <summary>
/// Checks published declarations and distinct inherited identities across both models.
/// </summary>
[Test]
public void GeneratedLoadersPopulateBothModels()
{
var context = new SystemContext(telemetry: null!)
{
NamespaceUris = new NamespaceTable()
};
ushort rslIndex = context.NamespaceUris.GetIndexOrAppend(Rsl.Namespaces.RSL);
ushort gposIndex = context.NamespaceUris.GetIndexOrAppend(Gpos.Namespaces.GPOS);
var nodes = new NodeStateCollection();
nodes.AddOpcUaRsl(context);
int rslCount = CountNodes(context, nodes);
nodes.AddOpcUaGpos(context);
int totalCount = CountNodes(context, nodes);
NodeState locationType = nodes.Single(node =>
node.NodeId == new NodeId(Gpos.VariableTypes.GlobalLocationType, gposIndex));
BaseInstanceState? inheritedBase = locationType.FindChild(
context, new QualifiedName(Rsl.BrowseNames.Base, rslIndex));
Assert.That(inheritedBase, Is.Not.Null);
Assert.Multiple(() =>
{
// Includes the NamespaceMetadata objects (under Server/Namespaces)
// and the GPOS TypeDictionary variables (under OPCBinarySchema /
// OPCXmlSchema). Both are linked to their ns=0 parent only by an
// inverse HasComponent and used to be dropped by the NodeSet import.
Assert.That(rslCount, Is.EqualTo(54));
// The inherited Base must not borrow RSL's 6002 in GPOS, where it identifies NamespaceUri.
Assert.That(totalCount, Is.EqualTo(124));
Assert.That(inheritedBase!.NodeId.IdType, Is.EqualTo(IdType.String));
Assert.That(inheritedBase.NodeId.NamespaceIndex, Is.EqualTo(gposIndex));
Assert.That(inheritedBase.NodeId, Is.Not.EqualTo(new NodeId(6002, gposIndex)));
Assert.That(
nodes.Any(node => node.NodeId == NodeId.Create(
Rsl.Objects.RelativeSpatialLocations,
Rsl.Namespaces.RSL,
context.NamespaceUris)),
Is.True);
Assert.That(
nodes.Any(node => node.NodeId == NodeId.Create(
Gpos.Objects.GlobalLocations,
Gpos.Namespaces.GPOS,
context.NamespaceUris)),
Is.True);
});
}
/// <summary>
/// Counts unique declarations without hiding conflicting identifiers.
/// </summary>
private static int CountNodes(
ISystemContext context,
NodeStateCollection roots)
{
var visited = new Dictionary<NodeId, NodeState>();
foreach (NodeState root in roots)
{
CountNode(context, root, visited);
}
return visited.Count;
}
/// <summary>
/// Traverses child declarations and validates repeated references to a node.
/// </summary>
private static void CountNode(
ISystemContext context,
NodeState node,
Dictionary<NodeId, NodeState> visited)
{
if (visited.TryGetValue(node.NodeId, out NodeState? prior))
{
Assert.Multiple(() =>
{
Assert.That(node.NodeClass, Is.EqualTo(prior.NodeClass), node.NodeId.ToString());
Assert.That(node.BrowseName, Is.EqualTo(prior.BrowseName), node.NodeId.ToString());
});
return;
}
visited.Add(node.NodeId, node);
var children = new List<BaseInstanceState>();
node.GetChildren(context, children);
foreach (BaseInstanceState child in children)
{
CountNode(context, child, visited);
}
}
[Test]
public void GeneratedFactoriesMaterializeMandatoryChildren()
{
var context = new SystemContext(telemetry: null!)
{
NamespaceUris = new NamespaceTable()
};
context.NamespaceUris.GetIndexOrAppend(Rsl.Namespaces.RSL);
context.NamespaceUris.GetIndexOrAppend(Gpos.Namespaces.GPOS);
CartesianFrameAngleOrientationState frame =
context.CreateInstanceOfCartesianFrameAngleOrientationType();
GlobalLocationState location =
context.CreateInstanceOfGlobalLocationType();
ZoneState zone = context.CreateInstanceOfZoneType();
Assert.Multiple(() =>
{
Assert.That(frame.Base, Is.Not.Null);
Assert.That(frame.Position, Is.Not.Null);
Assert.That(frame.Orientation, Is.Not.Null);
Assert.That(location.Base, Is.Not.Null);
Assert.That(location.Position, Is.Not.Null);
Assert.That(location.Position!.Longitude, Is.Not.Null);
Assert.That(location.Position.Latitude, Is.Not.Null);
Assert.That(location.Position.SourceId, Is.Not.Null);
Assert.That(zone.ZoneId, Is.Not.Null);
});
}
[Test]
public void GposOptionalFieldsUseEncodingMasks()
{
var position = new GlobalPositionDataType
{
EncodingMask =
(uint)S3DGeographicCoordinateDataTypeFields.Elevation |
(uint)GlobalPositionDataTypeFields.Accuracy |
(uint)GlobalPositionDataTypeFields.Floor,
Longitude = 8.0,
Latitude = 47.0,
Elevation = 500.0,
Accuracy = 0.1,
Floor = 2.0f
};
var location = new GlobalLocationDataType
{
EncodingMask =
(uint)GlobalLocationDataTypeFields.Orientation,
Position = position,
Orientation = new ThreeDOrientation { C = 90.0 }
};
Assert.Multiple(() =>
{
Assert.That(position.Elevation, Is.EqualTo(500.0));
Assert.That(position.Accuracy, Is.EqualTo(0.1));
Assert.That(position.Floor, Is.EqualTo(2.0f));
Assert.That(location.Position, Is.SameAs(position));
Assert.That(location.Orientation.C, Is.EqualTo(90.0));
});
}
[Test]
public void DerivedGlobalPositionSharesEncodingMaskWithGeographicBase()
{
var position = new GlobalPositionDataType
{
EncodingMask =
(uint)GlobalPositionDataTypeFields.Elevation |
(uint)GlobalPositionDataTypeFields.Accuracy,
Longitude = 8.0,
Latitude = 47.0,
Elevation = 500.0,
Accuracy = 0.1
};
S3DGeographicCoordinateDataType geographic = position;
Assert.Multiple(() =>
{
Assert.That(
geographic.EncodingMask,
Is.EqualTo(position.EncodingMask));
Assert.That(
geographic.EncodingMask &
(uint)S3DGeographicCoordinateDataTypeFields.Elevation,
Is.Not.Zero);
});
}
}
}