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

18 KiB
Raw Permalink Blame History

Extrusion servers and clients

The Opc.Ua.Extrusion.Server and Opc.Ua.Extrusion.Client packages implement the reusable runtime for OPC 40084 parts 1–12, version 2.00. Each device keeps its real generated companion type. They are not twelve names for an extruder, and the abstract ExtrusionDeviceType is never instantiated.

The runtime is a view of an actual device/controller. It has no production timer, random values, automatic counter increments, or material-flow simulator. Applications supply asynchronous authorities for commands and publish absolute committed observations.

Contents

Packages and ownership

One Opc.Ua.Extrusion model assembly owns all twelve parts' standard namespaces, identifiers, generated states, structures, method proxies and event records. The family consists of exactly three extrusion packages:

Package Responsibility
Opc.Ua.Extrusion All twelve unmodified MIT-licensed OPC 40084 v2 models and generated interfaces.
Opc.Ua.PlasticsRubber.Server / .Client Shared OPC 40083 start/stop, monitoring/control, maintenance, configuration, MES, production-dataset and file behavior.
Opc.Ua.Extrusion.Server Concrete instance construction, exact optional-feature selection, instance identity, extrusion state projection, line jobs, cutter completion and events.
Opc.Ua.Extrusion.Client Discovery, generated device proxies, model-derived typed variable accessors, placeholder enumeration, common workflows and generated event decoding.

Source is organized by specification part: GeneralTypes, Line, Extruder, HaulOff, MeltPump, Filter, Die, Pelletizer, Cutter, Calibrator, Corrugator and Calender. Model inputs, generated client accessors and part-specific runtime entrypoints use those folders. CLR namespaces and per-part compiled loaders remain distinct; consumers reference the three family packages, not per-device packages.

The common model's provenance is distinct: it is an independently authored 1.03-compatible interface on the licensed 1.02 basis, not a redistributed official 1.03 XML. See the packaged licenses/CompanionModels.NOTICE.txt and the model manifest.

One DI/Machinery node manager owns both models and instances. Standalone hosting uses that same owner; composition does not register another DI manager. AMB remains a sidecar, with the real extrusion object registered as an asset.

Standalone and composed hosting

services.AddOpcUa()
    .AddServer(options =>
    {
        options.ApplicationName = "Extrusion server";
        options.ApplicationUri = "urn:example:extrusion:server";
        options.EndpointUrls.Add("opc.tcp://localhost:4840/Extrusion");
    })
    .AddExtrusion(options =>
        options.InstanceNamespaceUri = "urn:example:extrusion:instances")
    .ConfigureExtrusion(async (context, ct) =>
    {
        var options = new ExtrusionDeviceOptions(new ExtrusionIdentity(
            "Example", "E-1", new LocalizedText("Extruder"),
            "urn:example:extruder:E-1", "Controller"))
        {
            LineId = "Line-1",
            Commands = context.GetRequiredService<IExtrusionCommandProvider>()
        };
        options.Features
            .WithInstances("TemperatureZones/TemperatureZone_<Nr>", 3)
            .Include("BarrelId");

        ExtrusionDevice<Extruder_InterfaceState> extruder =
            await context.Runtime.CreateExtruderAsync(
                options, cancellationToken: ct);
        // Retain the typed handle in the application's device registry.
    });

For an existing owner, replace AddExtrusion(...) with:

builder
    .AddMachinery(options => options.Parts = MachineryParts.BuildingBlocks)
    .AddExtrusionToMachinery()
    .AddAssetManagement()
    .ConfigureExtrusion(async (context, ct) =>
    {
        ExtrusionDevice<Filter_InterfaceState> filter =
            await context.Runtime.CreateFilterAsync(filterOptions, cancellationToken: ct);
        await context.GetRequiredService<IAssetManagement>()
            .RegisterAssetAsync(filter.AsNode(), cancellationToken: ct);
    });

Do not also call AddOpcUaDi or register a second Machinery owner. Custom owners load MachineryModelProvider(MachineryParts.BuildingBlocks) and ExtrusionModelProvider, then use ConfigureExtrusionFor<TManager>. Outside dependency injection, use ExtrusionRuntime.Create(existingManager). The same runtime is returned on subsequent calls. A custom owner releases its Machinery resources through DisposeMachineryResourcesAsync.

Runtime disposal stops its commands, subscriptions' data sources, temporary file bindings and other owned resources. Device nodes themselves belong to the node manager. Injected hardware/persistence providers remain application-owned.

Concrete devices and feature selection

Typed constructors exist for Line, Extruder, HaulOff, MeltPump, Filter, Die, Pelletizer, Cutter, Calibrator, Corrugator and Calender. Constructor identities generate the standard device BrowseName and stable application-namespace NodeIds. Child identity uses the BrowseName namespace URI, not a numeric namespace-table position.

ExtrusionFeatures uses the actual compiled declarations:

  • Mandatory members always exist.
  • Include("path") selects an optional subtree.
  • IncludeAll() selects applicable optional members, not imaginary equipment.
  • WithInstances(".../<Nr>", count) supplies the actual number of repeated instances. It creates required children, but does not implicitly turn on every optional control on those instances.
  • Exclude("path") removes a selected optional subtree; excluding mandatory members is an error.
  • Misspelled paths, impossible counts, duplicate identities and absent required providers are errors, not silently ignored options.

Examples:

filterOptions.Features
    .WithInstances("FilterPackage_<Nr>", 2)
    .WithInstances("FilterPackage_<Nr>/ScreenPackage_<Nr>", 3)
    .Include("FilterPackage_<Nr>/BackflushCounter")
    .Include("FilterPackage_<Nr>/BackflushTime")
    .Include("BackflushPressure");

calenderOptions.Features
    .IncludeAll()
    .WithInstances("Rolls/Roll_<Nr>", 3)
    .WithInstances("Gaps/Gap_<Nr>", 2)
    .WithInstances("Rolls/Roll_<Nr>/PeripheralDevices/CleaningSystem_<Nr>", 1);

Repeated names follow the relevant part, starting at 001; generic measuring containers are refined to names such as MeltPressure_001, MeltTemperatureZone_001 and ScrewTemperature_001. Cutter always contains real mandatory CuttingProduct instances, five by default; a different positive count is selectable. No literal placeholder names are published.

Line deliberately omits inherited Target and Strand as required by OPC 40084-2 §6.2. Job groups/jobs are created through their typed protocol with complete metadata, not by configuring anonymous placeholder counts.

Providers and committed state

IExtrusionCommandProvider receives ExtrusionCommand, including the original request ISystemContext, the actual device and member, and the exact command kind. Authorization runs before execution. Forwarding adapters must preserve that user's authorization; the runtime does not substitute its startup/service identity.

Writes and output resets require committed values from the authority. Opening/closing a clamp and manual/sample-cut requests can acknowledge an accepted request before physical completion, but do not fabricate clamp feedback, a completed cut, or counter changes.

Common controllers are supplied through ExtrusionDeviceOptions.Common: IStartDeviceProvider, IMonitoredParameterProvider, IClosedLoopControlProvider, IMaintenanceProvider, IMachineConfigurationProvider, IMesMessageProvider, IProductionDatasetProvider, and an explicit IPlasticsRubberAccessPolicy. The common package owns their protocols. Selecting a command-bearing capability without its authority fails creation.

Observation publication is independent of an awaited hardware command, allowing an authoritative coordinator to deliver its committed state before replying to a forwarded command.

Common parameter and controller settings are snapshot-owned too. A successful setting command does not publish its requested value: the previous observation remains until ApplySnapshotAsync supplies committed data. Later observations cannot be overwritten by an older write completion. Reads and parameter-limit validation use the committed image; file-transfer and other protocol-owned state retain their existing bindings.

await extruder.State.ApplyAsync(
    new ExtrusionOperatingSnapshot(
        committedRevision,
        MachineryItemStateValue.Executing,
        MachineryOperationModeValue.Processing,
        ExtrusionExecutingState.ControlledRun,
        sourceTimestamp),
    [
        new ExtrusionValue(extruder.Node.IsPresent!.NodeId,
            new DataValue(Variant.From(true), StatusCodes.Good, sourceTimestamp)),
        new ExtrusionValue(extruder.Node.BarrelId!.NodeId,
            new DataValue(Variant.From(barrelId), quality, sourceTimestamp))
    ],
    cancellationToken);

For arbitrary selected generated variables, use ApplySnapshotAsync. A snapshot is validated before publication. Repeating the same revision and values is idempotent; stale or conflicting revisions are rejected. Values retain their quality and source time. Unobserved physical values start with BadWaitingForInitialData, not a fabricated Good zero.

The item state, operation mode and execution substate remain distinct. When the item is not Executing, the execution submachine's CurrentState and LastTransition report BadStateNotActive (OPC 40084-1 §6.3). Repeated observations of the same state preserve the last transition and its committed transition time. The core Part 16 dispatcher supplies state projection; no alternative state model is substituted.

Units and monitoring

Known standard dimensions receive UNECE engineering units, including Celsius, bar, millimetre, micrometre, square centimetre, kilogram/hour, metre/second, kilowatt, ampere and percent. Configure application-defined dimensions explicitly with ExtrusionUnits.Configure before publication. Do not attach a unit to a number whose actual physical dimension is different.

Common monitoring is driven by the same committed actual value and quality. Lower relative tolerances are signed negative offsets: for a nominal value of 190, LowerTolerance = -8 means a lower boundary of 182. A second lower tolerance must be at or below the first. They are not positive magnitudes. The common package validates these rules and owns automatic monitoring, sensitivity, suppression, controlled setpoints/ramps and PID tuning.

Extrusion line jobs and production

ExtrusionJobController implements OPC 40084-2 §8:

  • Group IDs are unique within a line; job IDs are unique within a group.
  • Strand and sequence are one-based. Duplicate sequence positions on a strand are rejected, and a strand cannot have two locally active jobs.
  • Standard configuration IDs are 1–7 with Double values; vendor IDs start at 100. Unspecified settings receive the group's offered defaults.
  • Group metadata retains dataset names, material/lot/hopper mappings, priorities and planned times. Cross-server reference validation belongs to the injected authority rather than guessing from an incomplete local address space.
  • Start, interrupt, finish and remove operations are authorized, state-checked and committed through IExtrusionJobProvider.
  • Structural changes update NodeVersion and emit model-change events.
  • Status events are emitted from JobGroups while retaining the actual group/job as SourceNode.
  • Absolute production snapshots carry the actual unit/quality and lot completion facts. Restoration baselines can have empty event lists. Replays cannot increment counters or repeat those events.
  • A bad active strand prevents the line from claiming good product. True-to-false quality changes create real common MessageCondition alarms using the core condition lifecycle, without falsely stopping the machine.

Status commands update that active-job quality constraint immediately; interrupting or finishing the last bad active job allows a later committed good-quality observation.

The wire AddJob argument is named ProductName; the corresponding job variable is ProductId. The generated wire spelling is retained. These are not Machinery/ISA-95 job orders, and the runtime does not replace their semantics.

LineControl.RequestMaterialAsync emits the standard material-information request even when optional JobGroups is absent.

For Cutter, Cuts.ApplyAsync(ExtrusionCutCommit) publishes the absolute ActualOutput/TotalOutput, actual active product and one generated CutEvent per committed physical cut. The hardware authority owns cutting-product sequencing, sample-cut timing, wall thickening and waste cutting. Calling ManualCut alone does not manufacture a completed cut.

Typed clients

services.AddOpcUa().AddClient(clientOptions).AddExtrusionClient();
ExtrusionClient client = await services
    .GetRequiredService<Func<CancellationToken, Task<ExtrusionClient>>>()(ct);

await foreach (ExtrusionDeviceEntry device in client.DiscoverAsync(
    cancellationToken: ct))
{
    // TypeDefinition is the actual sibling or vendor subtype, not an inferred label.
}

Extruder_InterfaceTypeClient extruder = client.Extruder(extruderId);
ClientRead<bool> present = await extruder.IsPresentVariable().ReadAsync(ct);
await extruder.LineIdVariable().WriteAsync("Line-1", ct);

JobGroupsTypeClient groups = await client.Line(lineId).JobsAsync(ct);
await foreach (JobGroupTypeClient group in groups.EnumerateJobGroupAsync(ct))
{
    await foreach (JobTypeClient job in group.EnumerateJobAsync(ct))
    {
        ClientRead<JobStatusEnumeration> status = await job.StatusVariable().ReadAsync(ct);
    }
}

await foreach (ExtrusionEvent notification in client.ObserveEventsAsync(
    lineId, cancellationToken: ct))
{
    // Generated JobStatusChangedEventTypeRecord, UnitFinishedEventTypeRecord,
    // CutEventTypeRecord, common condition/logbook records, etc.
}

Every concrete entrypoint returns its actual generated proxy. Generated child accessors expose drives, monitored parameters, zones, materials, users, common maintenance and all remaining optional objects. Model-derived extensions supply 141 typed variable accessors and 17 typed placeholder enumerators from the unchanged licensed declarations. Their codecs use exact native/generated types, not reflection or boxed-value conversion. The client project opts into ModelSourceGeneratorClientAccessorsOnly, so Roslyn emits these extensions during the build; no generated C# or Python generation step is checked in.

The reusable ClientVariable<T>, ClientRead<T> and client-model access helpers live in Opc.Ua.Client. See the source generator options to enable the same extensions for another companion model.

ReadAsync returns ClientRead<T> with the original DataValue; bad quality and source timestamps are not discarded. ObserveAsync uses the existing bounded streaming subscription. Disposing an observation removes its monitored item, not another caller's shared session.

Dataset/file workflow

ProductionDatasetClient datasets =
    await client.Extruder(extruderId).ProductionDatasetsAsync(ct);
await datasets.UploadAsync(
    new ProductionDatasetWriteOptionsType
    {
        Storage = StorageEnumeration.FILE_SYSTEM,
        Name = "production-settings",
        Components = selectedComponentCodes
    },
    sourceStream,
    information,
    ct);
await datasets.LoadAsync(
    StorageEnumeration.PRODUCTION, "production-settings", selectedComponentCodes, ct);

This delegates to the common chapter-20 implementation and the existing temporary-file/FileType clients. Production and preparation are separate layers; frozen checks, per-session handles, bounded files, metadata exchange, component selection and commit semantics remain the common protocol. Binding preserves independently selected active/preparation optional members.

Supported parts

Support refers to model and protocol functionality with the required providers, not a certification claim.

Part Name Support
40084-1 General types Supported
40084-2 Extrusion line Supported
40084-3 Extruder Supported
40084-4 Haul-off Supported
40084-5 Melt pump Supported
40084-6 Filter Partial
40084-7 Die Supported
40084-8 Pelletizer Supported
40084-9 Cutter Supported
40084-10 Calibrator Supported
40084-11 Corrugator Supported
40084-12 Calender Supported

Hardware-specific closed-loop algorithms, physical clamp motion, filter backflushing, feeder/dosing behavior and cutter motion are implemented by the explicit asynchronous providers, not fabricated in the package. Selecting them does not grant authority to operate actual equipment.

Filter profile discrepancy

The published OPC 40084-6 v2.00 §9.2.2 table references OPC 40084-5 Basic, although part 6 defines Filter and its own Filter conformance unit. This runtime implements the real Filter model and does not advertise that disputed profile. It does not modify the standard XML, insert a fictional melt pump or interpret a loaded MeltPump type as a physical MeltPump instance. Other copied equipment names in prose likewise do not change wire types.

No formal OPC Foundation certification is claimed. Loading a namespace, packing a NuGet package, static member coverage and passing tests are different evidence.