Files
UA-.NETStandard/tests/Opc.Ua.Robotics.Tests/BinPickingTargetProviderTests.cs
Marc SchierandCopilot da7412c429 Add native xRegistry events and distinct Resource versions (#4396)
## Summary

- support the xRegistry 0.6.0 distinct Resource/Version hierarchy:
  `Registry -> Group -> Resource -> Versions -> Version`
- instantiate stable logical Resource nodes separately from exact
Version nodes
  while preserving existing Version NodeIds
- delegate logical Resource FileType operations and Version-view
metadata to the
selected default Version with handle pinning and shared writer
reservations
- make Resource and Version delete behavior role-stable and use
`MetaEpoch` /
  `Epoch` respectively
- use stable Resource SourceNodes, exact Version SourceNodes and the
  `Server -> Registry -> Group -> Resource -> Version` notifier chain
- keep a model-metadata-gated client fallback for 0.5 flat Servers; 0.6
Servers
  expose no legacy aliases
- target `HasWoTProjection` at the real stable logical Resource node
- use `AsyncCustomNodeManager` for the registration, fast-path, and
federation managers,
  with awaited lifecycle, node mutations, event delivery, and cleanup
- handle startup rollback, reentrant deletion callbacks, undisclosed
file handles,
  and retryable cleanup without blocking unrelated file operations

## Authoritative dependencies

- companion specification: OPCF-Members/spec-drafts#32 at
  `d3399fca025025a73e5a6b599f850a81d985c060`
- OPC UA binding: xregistry/spec#568
- xRegistry event semantics: xregistry/spec#563, merged as
  `66ee31e47fbadff6ab982ae1516f7d9065e46b64`
- companion NodeSet SHA-256:
  `369f5f3f1814b333e4eeb52bfb4b6a730cdff372505a5f91a54c94f0016ac4cf`

## Review feedback

- keep the WoT Connectivity information-model designation at `1.1`;
draft revisions update the publication date without changing the model
version
- eliminate all 198 unique CA1861 diagnostics across 54 files and remove
seven obsolete project suppressions
- fix the analyzer-clean touched-path CA1307 and the hierarchy follow-up
CA1846/CA1851 diagnostics without dropping legacy-TFM compatibility

- recover the reconcile queue after callback faults/cancellation and
continue accepted pending changes
- remove migration guidance for the xRegistry managers, which are new in
2.0

## Compatibility

- public WoT Connectivity model designation remains `1.1`
- generated event-record ABI, constructors, options, NodeIds, and stored
documents remain compatible
- the generic xRegistry managers are new in 2.0 and implement
`IAsyncNodeManager`;
use `IAsyncNodeManagerFactory` and the async lifecycle hooks (see
`docs\XRegistry.md`)
- persistence schema and document blobs remain compatible unless noted
below

## Validation

- merge validation at `980422f76` with upstream `e8bec27d5`: 454
targeted WoT/materialization/model/registry cases and all 327 XRegistry
cases passed on both net10.0 and net48; all 29 net10 aggregation sample
cases passed
- feedback regressions at `308e8ba74`: 55 targeted queue and live
registry event/projection/lifecycle cases passed on each of net10.0 and
net48
- prior CI: all 266 checks passed at `6489a0908`; the unchanged Ubuntu
Core certificate-counter test and dependent jobs passed on the one-time
retry ([run 34117304035, attempt
2](https://github.com/OPCFoundation/UA-.NETStandard/actions/runs/34117304035/attempts/2))
- `Opc.Ua.XRegistry.Tests` — 327 passed on net10.0 and net48 for
migration commit `32c914aaf`
- `Opc.Ua.WotCon.Tests` net10.0 — 1348 passed
- `Opc.Ua.WotCon.Bindings.Tests` net10.0 — 683 passed
- `Opc.Ua.SourceGeneration.Core.Tests` net10.0 — 3807 passed, 8 skipped
- `Opc.Ua.SourceGeneration.Tests` net10.0 — 145 passed
- `Opc.Ua.SourceGeneration.Stack.Tests` net10.0 — 94 passed
- affected XRegistry and WoT client/server projects build successfully
- xRegistry NodeSet is byte-identical to the companion artifact
- repository-wide CA1861 inventory — 198 unique diagnostics across 54
files reduced to zero
- targeted changed-fixture validation — 1,098 passed, 3 skipped, 0
failed
- constrained full `UA.slnx` net10.0 Release build — CA1861 = 0
- `Opc.Ua.XRegistry.Client` net472 and netstandard2.1 builds — 0
warnings, 0 errors
- independent shared-array safety review — no significant issues
- `git diff --check`

The final review regressions cover concurrent reconcile/open, synthetic
logical
handle collisions across default switches, cross-session Close
isolation,
shared writer reservations, logical FileType property/change
propagation,
logical Labels delegation, role-fixed deletion, event sources,
model-version
gating, and stable `HasWoTProjection` targets.

The companion specification and protocol binding are reviewed in the
linked PRs above.

---------

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>
Copilot-Session: 5c79a1ed-6dab-4522-a9fc-6548caa78ad5
Copilot-Session: b605797f-a97a-4cd0-8f12-016d33c2fd88
Copilot-Session: 7ef369a5-2307-4f71-8a11-15af0e72f240
Copilot-Session: e716d455-8397-4d22-9c5a-398847ab7317
2026-09-08 04:46:40 +00:00

214 lines
8.5 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 NUnit.Framework;
using Opc.Ua;
using Opc.Ua.Vision;
using Vision.BinPickingCell;
namespace Opc.Ua.Robotics.Tests
{
[TestFixture]
public class BinPickingTargetProviderTests
{
[Test]
public void OnServerStaleTargetFallsBackToCurrentWorldState()
{
var worldState = new BinPickingWorldState();
var provider = CreateProvider(worldState, BinPickingInferenceLocation.OnServer);
provider.PublishWorldState(
"old-result",
DateTimeUtc.From(DateTime.UtcNow - TimeSpan.FromMinutes(1)),
worldState.Snapshot());
bool resolved = provider.TryResolve("RedCube", out BinPickingTarget target);
Assert.Multiple(() =>
{
Assert.That(resolved, Is.True);
Assert.That(target.ResultId, Is.EqualTo("simulation-world-state"));
Assert.That(target.SourceFrameId, Is.EqualTo("world"));
Assert.That(target.WorldX, Is.EqualTo(0.520).Within(1e-9));
Assert.That(target.WorldY, Is.EqualTo(-0.080).Within(1e-9));
});
}
[Test]
public void OffServerStaleTargetIsNotReplacedWithSimulationTruth()
{
var worldState = new BinPickingWorldState();
var provider = CreateProvider(worldState, BinPickingInferenceLocation.EdgeOffServer);
provider.PublishWorldState(
"old-result",
DateTimeUtc.From(DateTime.UtcNow - TimeSpan.FromMinutes(1)),
worldState.Snapshot());
Assert.That(provider.TryResolve("RedCube", out _), Is.False);
}
[Test]
public void OffServerDetectionComposesCameraPoseAndPreservesProvenance()
{
var worldState = new BinPickingWorldState();
var provider = CreateProvider(worldState, BinPickingInferenceLocation.EdgeOffServer);
BinPickingPart red = BinPickingPartsCatalog.TryGet("RedCube")!;
VisionDetectionDataType detection = Detection(
red.ClassLabel,
"camera_eih",
red.InitialWorldPosition[0],
red.InitialWorldPosition[1],
red.InitialWorldPosition[2]);
provider.PublishDetections(
"agent-result",
DateTimeUtc.From(DateTime.UtcNow),
new[] { detection }.ToArrayOf(),
IdentityCamera(),
"camera_eih");
bool resolved = provider.TryResolve(red.ClassLabel, out BinPickingTarget target);
Assert.Multiple(() =>
{
Assert.That(resolved, Is.True);
Assert.That(target.ResultId, Is.EqualTo("agent-result"));
Assert.That(target.SourceFrameId, Is.EqualTo("camera_eih"));
Assert.That(target.WorldX, Is.EqualTo(red.InitialWorldPosition[0]).Within(1e-9));
Assert.That(target.WorldY, Is.EqualTo(red.InitialWorldPosition[1]).Within(1e-9));
Assert.That(target.WorldZ, Is.EqualTo(red.InitialWorldPosition[2]).Within(1e-9));
});
}
[Test]
public void OffServerDetectionRejectsAnUncalibratedSourceFrame()
{
var worldState = new BinPickingWorldState();
var provider = CreateProvider(worldState, BinPickingInferenceLocation.EdgeOffServer);
BinPickingPart red = BinPickingPartsCatalog.TryGet("RedCube")!;
VisionDetectionDataType detection = Detection(
red.ClassLabel,
"wrong_camera",
red.InitialWorldPosition[0],
red.InitialWorldPosition[1],
red.InitialWorldPosition[2]);
ServiceResultException? exception = Assert.Throws<ServiceResultException>(() =>
provider.PublishDetections(
"agent-result",
DateTimeUtc.From(DateTime.UtcNow),
new[] { detection }.ToArrayOf(),
IdentityCamera(),
"camera_eih"));
Assert.Multiple(() =>
{
Assert.That(exception!.StatusCode, Is.EqualTo((StatusCode)StatusCodes.BadInvalidArgument));
Assert.That(provider.TryResolve(red.ClassLabel, out _), Is.False);
});
}
[Test]
public void OffServerDetectionBatchRejectsResidualWithoutPublishingEarlierTargets()
{
var worldState = new BinPickingWorldState();
var provider = CreateProvider(worldState, BinPickingInferenceLocation.EdgeOffServer);
BinPickingPart red = BinPickingPartsCatalog.TryGet("RedCube")!;
BinPickingPart green = BinPickingPartsCatalog.TryGet("GreenCylinder")!;
VisionDetectionDataType[] detections =
[
Detection(
red.ClassLabel,
"camera_eih",
red.InitialWorldPosition[0],
red.InitialWorldPosition[1],
red.InitialWorldPosition[2]),
Detection(
green.ClassLabel,
"camera_eih",
green.InitialWorldPosition[0] + 0.20,
green.InitialWorldPosition[1],
green.InitialWorldPosition[2])
];
_ = Assert.Throws<ServiceResultException>(() =>
provider.PublishDetections(
"agent-result",
DateTimeUtc.From(DateTime.UtcNow),
detections.ToArrayOf(),
IdentityCamera(),
"camera_eih"));
Assert.That(provider.TryResolve(red.ClassLabel, out _), Is.False);
}
private static BinPickingTargetProvider CreateProvider(
BinPickingWorldState worldState,
BinPickingInferenceLocation inferenceLocation)
{
return new BinPickingTargetProvider(
worldState,
new BinPickingCellOptions { InferenceLocation = inferenceLocation });
}
private static VisionDetectionDataType Detection(
string classLabel,
string frameId,
double x,
double y,
double z)
{
return new VisionDetectionDataType
{
ClassLabel = classLabel,
Confidence = 0.99,
HasPose = true,
Pose = new VisionPose3DDataType
{
FrameId = frameId,
Position = new[] { x, y, z }.ToArrayOf(),
Orientation = s_doubleValues1.ToArrayOf()
}
};
}
private static VisionPose3DDataType IdentityCamera()
{
return new VisionPose3DDataType
{
FrameId = "world",
Position = s_doubleValues2.ToArrayOf(),
Orientation = s_doubleValues1.ToArrayOf()
};
}
private static readonly double[] s_doubleValues1 = [0.0, 0.0, 0.0, 1.0];
private static readonly double[] s_doubleValues2 = [0.0, 0.0, 0.0];
}
}