feat(adminui): F15.2 batch 3 — Equipment + Tag CRUD (operator surfaces)
Some checks failed
v2-ci / build (push) Failing after 44s
v2-ci / unit-tests (tests/Core/ZB.MOM.WW.OtOpcUa.Cluster.Tests) (push) Has been skipped
v2-ci / unit-tests (tests/Server/ZB.MOM.WW.OtOpcUa.ControlPlane.Tests) (push) Has been skipped
v2-ci / unit-tests (tests/Server/ZB.MOM.WW.OtOpcUa.OpcUaServer.Tests) (push) Has been skipped
v2-ci / unit-tests (tests/Server/ZB.MOM.WW.OtOpcUa.Runtime.Tests) (push) Has been skipped
v2-ci / unit-tests (tests/Server/ZB.MOM.WW.OtOpcUa.Security.Tests) (push) Has been skipped
v2-ci / integration (push) Has been skipped

The two most-edited entities for daily operator workflows. Both follow the
same single-page edit-or-create pattern from batches 1 + 2 with RowVersion
optimistic concurrency.

- EquipmentEdit.razor   /clusters/{id}/equipment/{new|EquipmentId}
  - EquipmentId is system-generated on create (decision #125): EQ-{first
    12 hex chars of a new EquipmentUuid}.
  - UNS line + driver instance selects are scoped to the cluster.
  - All 9 OPC 40010 identification fields surfaced as an optional panel.
  - MachineCode uniqueness checked client-side before EF unique index
    enforces it server-side.
- TagEdit.razor         /clusters/{id}/tags/{new|TagId}
  - Equipment vs FolderPath input switches based on the selected
    driver's namespace kind — Equipment-kind requires EquipmentId,
    SystemPlatform-kind requires FolderPath (decision #110 invariant
    enforced client-side; sp_ValidateDraft re-enforces server-side at
    deploy).
  - DataType select uses the OPC UA built-in primitive type names.
  - TagConfig validated as JSON pre-flight.

ClusterEquipment + ClusterTags list pages get New / Edit affordances.

All 9 integration tests still green.
This commit is contained in:
Joseph Doherty
2026-05-26 08:22:51 -04:00
parent 45740578c9
commit 2662ac08e4
4 changed files with 636 additions and 0 deletions

View File

@@ -8,6 +8,7 @@
<div class="d-flex justify-content-between align-items-center mb-3">
<h4 class="mb-0">Equipment &middot; <span class="mono">@ClusterId</span></h4>
<a href="/clusters/@ClusterId/equipment/new" class="btn btn-primary btn-sm">New equipment</a>
</div>
<ClusterNav ClusterId="@ClusterId" ActiveTab="equipment" />
@@ -43,6 +44,7 @@ else
<th>Driver</th>
<th>UNS line</th>
<th>Identification</th>
<th></th>
</tr>
</thead>
<tbody>
@@ -59,6 +61,7 @@ else
@if (!string.IsNullOrWhiteSpace(e.Manufacturer)) { <span>@e.Manufacturer</span> }
@if (!string.IsNullOrWhiteSpace(e.Model)) { <span class="ms-1">/ @e.Model</span> }
</td>
<td><a href="/clusters/@ClusterId/equipment/@e.EquipmentId" class="btn btn-sm btn-outline-primary">Edit</a></td>
</tr>
}
</tbody>

View File

@@ -8,6 +8,7 @@
<div class="d-flex justify-content-between align-items-center mb-3">
<h4 class="mb-0">Tags &middot; <span class="mono">@ClusterId</span></h4>
<a href="/clusters/@ClusterId/tags/new" class="btn btn-primary btn-sm">New tag</a>
</div>
<ClusterNav ClusterId="@ClusterId" ActiveTab="tags" />
@@ -52,6 +53,7 @@ else
<th>Access</th>
<th>Folder</th>
<th>Poll group</th>
<th></th>
</tr>
</thead>
<tbody>
@@ -66,6 +68,7 @@ else
<td>@t.AccessLevel</td>
<td class="text-muted small">@(t.FolderPath ?? "")</td>
<td>@(t.PollGroupId ?? "—")</td>
<td><a href="/clusters/@ClusterId/tags/@t.TagId" class="btn btn-sm btn-outline-primary">Edit</a></td>
</tr>
}
</tbody>

View File

@@ -0,0 +1,310 @@
@page "/clusters/{ClusterId}/equipment/new"
@page "/clusters/{ClusterId}/equipment/{EquipmentId}"
@* Equipment CRUD. EquipmentId is system-generated (decision #125) — operator picks Name +
MachineCode + UnsLine + Driver; the EquipmentId is derived from the EquipmentUuid on create.
OPC 40010 identification fields (Manufacturer, Model, etc.) are all optional. *@
@attribute [Microsoft.AspNetCore.Authorization.Authorize]
@rendermode RenderMode.InteractiveServer
@using Microsoft.AspNetCore.Components.Forms
@using Microsoft.EntityFrameworkCore
@using System.ComponentModel.DataAnnotations
@using ZB.MOM.WW.OtOpcUa.Configuration
@using ZB.MOM.WW.OtOpcUa.Configuration.Entities
@inject IDbContextFactory<OtOpcUaConfigDbContext> DbFactory
@inject NavigationManager Nav
<div class="d-flex justify-content-between align-items-center mb-3">
<h4 class="mb-0">@(IsNew ? "New equipment" : "Edit equipment") &middot; <span class="mono">@ClusterId</span></h4>
<a href="/clusters/@ClusterId/equipment" class="btn btn-outline-secondary btn-sm">Cancel</a>
</div>
<ClusterNav ClusterId="@ClusterId" ActiveTab="equipment" />
@if (!_loaded)
{
<p>Loading…</p>
}
else if (!IsNew && _existing is null)
{
<section class="panel notice rise" style="animation-delay:.02s">
Equipment <span class="mono">@EquipmentId</span> was not found.
</section>
}
else
{
<EditForm Model="_form" OnValidSubmit="SubmitAsync" FormName="equipmentEdit">
<DataAnnotationsValidator />
<section class="panel rise" style="animation-delay:.02s">
<div class="panel-head">Identity</div>
<div style="padding:1rem">
@if (!IsNew)
{
<div class="mb-3">
<label class="form-label">EquipmentId</label>
<input class="form-control form-control-sm mono" value="@EquipmentId" disabled />
<div class="form-text">System-generated; never operator-edited.</div>
</div>
}
<div class="row">
<div class="col-md-6 mb-3">
<label class="form-label" for="name">Name</label>
<InputText id="name" @bind-Value="_form.Name" class="form-control form-control-sm mono"
placeholder="machine-01" />
<div class="form-text">UNS level 5 segment; lowercase letters, digits, dashes, up to 32 chars.</div>
</div>
<div class="col-md-6 mb-3">
<label class="form-label" for="machinecode">MachineCode</label>
<InputText id="machinecode" @bind-Value="_form.MachineCode" class="form-control form-control-sm mono"
placeholder="machine_001" />
</div>
</div>
<div class="row">
<div class="col-md-6 mb-3">
<label class="form-label" for="line">UNS line</label>
<InputSelect id="line" @bind-Value="_form.UnsLineId" class="form-select form-select-sm">
<option value="">— pick a line —</option>
@foreach (var l in _lines)
{
<option value="@l.UnsLineId">@l.UnsAreaId / @l.UnsLineId &mdash; @l.Name</option>
}
</InputSelect>
</div>
<div class="col-md-6 mb-3">
<label class="form-label" for="driver">Driver instance</label>
<InputSelect id="driver" @bind-Value="_form.DriverInstanceId" class="form-select form-select-sm">
<option value="">— pick a driver —</option>
@foreach (var d in _drivers)
{
<option value="@d.DriverInstanceId">@d.DriverInstanceId &mdash; @d.Name (@d.DriverType)</option>
}
</InputSelect>
</div>
</div>
<div class="row">
<div class="col-md-6 mb-3">
<label class="form-label" for="ztag">ZTag (ERP)</label>
<InputText id="ztag" @bind-Value="_form.ZTag" class="form-control form-control-sm" />
<div class="form-text">Unique fleet-wide via ExternalIdReservation.</div>
</div>
<div class="col-md-6 mb-3">
<label class="form-label" for="sap">SAPID</label>
<InputText id="sap" @bind-Value="_form.SAPID" class="form-control form-control-sm" />
</div>
</div>
<div class="mb-3">
<label class="form-label">Enabled</label>
<div class="form-check form-switch">
<InputCheckbox @bind-Value="_form.Enabled" class="form-check-input" />
<label class="form-check-label">Surface in deployments</label>
</div>
</div>
</div>
</section>
<section class="panel rise mt-3" style="animation-delay:.08s">
<div class="panel-head">OPC 40010 identification (optional)</div>
<div style="padding:1rem">
<div class="row">
<div class="col-md-4 mb-3"><label class="form-label">Manufacturer</label><InputText @bind-Value="_form.Manufacturer" class="form-control form-control-sm" /></div>
<div class="col-md-4 mb-3"><label class="form-label">Model</label><InputText @bind-Value="_form.Model" class="form-control form-control-sm" /></div>
<div class="col-md-4 mb-3"><label class="form-label">SerialNumber</label><InputText @bind-Value="_form.SerialNumber" class="form-control form-control-sm" /></div>
</div>
<div class="row">
<div class="col-md-3 mb-3"><label class="form-label">HardwareRevision</label><InputText @bind-Value="_form.HardwareRevision" class="form-control form-control-sm" /></div>
<div class="col-md-3 mb-3"><label class="form-label">SoftwareRevision</label><InputText @bind-Value="_form.SoftwareRevision" class="form-control form-control-sm" /></div>
<div class="col-md-3 mb-3"><label class="form-label">Year of construction</label><InputNumber @bind-Value="_form.YearOfConstruction" class="form-control form-control-sm" /></div>
<div class="col-md-3 mb-3"><label class="form-label">AssetLocation</label><InputText @bind-Value="_form.AssetLocation" class="form-control form-control-sm" /></div>
</div>
<div class="row">
<div class="col-md-6 mb-3"><label class="form-label">ManufacturerUri</label><InputText @bind-Value="_form.ManufacturerUri" class="form-control form-control-sm mono" /></div>
<div class="col-md-6 mb-3"><label class="form-label">DeviceManualUri</label><InputText @bind-Value="_form.DeviceManualUri" class="form-control form-control-sm mono" /></div>
</div>
</div>
</section>
@if (!string.IsNullOrWhiteSpace(_error))
{
<div class="panel notice mt-3" style="border-color:var(--alert)">@_error</div>
}
<div class="mt-3 d-flex gap-2">
<button type="submit" class="btn btn-primary" disabled="@_busy">
@if (_busy) { <span class="spinner-border spinner-border-sm me-1"></span> }
@(IsNew ? "Create" : "Save changes")
</button>
<a href="/clusters/@ClusterId/equipment" class="btn btn-outline-secondary">Cancel</a>
@if (!IsNew)
{
<button type="button" class="btn btn-outline-danger ms-auto" @onclick="DeleteAsync" disabled="@_busy">Delete</button>
}
</div>
</EditForm>
}
@code {
[Parameter] public string ClusterId { get; set; } = "";
[Parameter] public string? EquipmentId { get; set; }
private bool IsNew => string.IsNullOrEmpty(EquipmentId);
private FormModel _form = new();
private Equipment? _existing;
private List<UnsLine> _lines = new();
private List<DriverInstance> _drivers = new();
private bool _loaded;
private bool _busy;
private string? _error;
protected override async Task OnInitializedAsync()
{
await using var db = await DbFactory.CreateDbContextAsync();
var areaIds = await db.UnsAreas.AsNoTracking()
.Where(a => a.ClusterId == ClusterId).Select(a => a.UnsAreaId).ToListAsync();
_lines = await db.UnsLines.AsNoTracking()
.Where(l => areaIds.Contains(l.UnsAreaId))
.OrderBy(l => l.UnsAreaId).ThenBy(l => l.UnsLineId)
.ToListAsync();
_drivers = await db.DriverInstances.AsNoTracking()
.Where(d => d.ClusterId == ClusterId)
.OrderBy(d => d.DriverInstanceId)
.ToListAsync();
if (!IsNew)
{
_existing = await db.Equipment.AsNoTracking()
.FirstOrDefaultAsync(e => e.EquipmentId == EquipmentId);
if (_existing is not null)
{
_form = new FormModel
{
Name = _existing.Name,
MachineCode = _existing.MachineCode,
UnsLineId = _existing.UnsLineId,
DriverInstanceId = _existing.DriverInstanceId,
ZTag = _existing.ZTag,
SAPID = _existing.SAPID,
Manufacturer = _existing.Manufacturer,
Model = _existing.Model,
SerialNumber = _existing.SerialNumber,
HardwareRevision = _existing.HardwareRevision,
SoftwareRevision = _existing.SoftwareRevision,
YearOfConstruction = _existing.YearOfConstruction,
AssetLocation = _existing.AssetLocation,
ManufacturerUri = _existing.ManufacturerUri,
DeviceManualUri = _existing.DeviceManualUri,
Enabled = _existing.Enabled,
RowVersion = _existing.RowVersion,
};
}
}
_loaded = true;
}
private async Task SubmitAsync()
{
_busy = true; _error = null;
try
{
if (string.IsNullOrEmpty(_form.UnsLineId)) { _error = "Pick a UNS line."; return; }
if (string.IsNullOrEmpty(_form.DriverInstanceId)) { _error = "Pick a driver instance."; return; }
await using var db = await DbFactory.CreateDbContextAsync();
if (IsNew)
{
var uuid = Guid.NewGuid();
var equipmentId = $"EQ-{uuid.ToString("N")[..12]}";
if (await db.Equipment.AnyAsync(e => e.MachineCode == _form.MachineCode))
{ _error = $"MachineCode '{_form.MachineCode}' already exists in this fleet."; return; }
db.Equipment.Add(new Equipment
{
EquipmentId = equipmentId,
EquipmentUuid = uuid,
DriverInstanceId = _form.DriverInstanceId,
UnsLineId = _form.UnsLineId,
Name = _form.Name,
MachineCode = _form.MachineCode,
ZTag = string.IsNullOrWhiteSpace(_form.ZTag) ? null : _form.ZTag,
SAPID = string.IsNullOrWhiteSpace(_form.SAPID) ? null : _form.SAPID,
Manufacturer = _form.Manufacturer,
Model = _form.Model,
SerialNumber = _form.SerialNumber,
HardwareRevision = _form.HardwareRevision,
SoftwareRevision = _form.SoftwareRevision,
YearOfConstruction = _form.YearOfConstruction,
AssetLocation = _form.AssetLocation,
ManufacturerUri = _form.ManufacturerUri,
DeviceManualUri = _form.DeviceManualUri,
Enabled = _form.Enabled,
});
}
else
{
var entity = await db.Equipment.FirstOrDefaultAsync(e => e.EquipmentId == EquipmentId);
if (entity is null) { _error = "Row no longer exists."; return; }
db.Entry(entity).Property(e => e.RowVersion).OriginalValue = _form.RowVersion;
entity.DriverInstanceId = _form.DriverInstanceId;
entity.UnsLineId = _form.UnsLineId;
entity.Name = _form.Name;
entity.MachineCode = _form.MachineCode;
entity.ZTag = string.IsNullOrWhiteSpace(_form.ZTag) ? null : _form.ZTag;
entity.SAPID = string.IsNullOrWhiteSpace(_form.SAPID) ? null : _form.SAPID;
entity.Manufacturer = _form.Manufacturer;
entity.Model = _form.Model;
entity.SerialNumber = _form.SerialNumber;
entity.HardwareRevision = _form.HardwareRevision;
entity.SoftwareRevision = _form.SoftwareRevision;
entity.YearOfConstruction = _form.YearOfConstruction;
entity.AssetLocation = _form.AssetLocation;
entity.ManufacturerUri = _form.ManufacturerUri;
entity.DeviceManualUri = _form.DeviceManualUri;
entity.Enabled = _form.Enabled;
}
await db.SaveChangesAsync();
Nav.NavigateTo($"/clusters/{ClusterId}/equipment");
}
catch (DbUpdateConcurrencyException) { _error = "Another user changed this equipment while you were editing."; }
catch (Exception ex) { _error = ex.Message; }
finally { _busy = false; }
}
private async Task DeleteAsync()
{
if (IsNew) return;
_busy = true; _error = null;
try
{
await using var db = await DbFactory.CreateDbContextAsync();
var entity = await db.Equipment.FirstOrDefaultAsync(e => e.EquipmentId == EquipmentId);
if (entity is null) { Nav.NavigateTo($"/clusters/{ClusterId}/equipment"); return; }
db.Entry(entity).Property(e => e.RowVersion).OriginalValue = _form.RowVersion;
db.Equipment.Remove(entity);
await db.SaveChangesAsync();
Nav.NavigateTo($"/clusters/{ClusterId}/equipment");
}
catch (DbUpdateConcurrencyException) { _error = "Another user changed this equipment while you were viewing it."; }
catch (Exception ex) { _error = $"Delete failed: {ex.Message}. Likely because tags or virtual tags reference this equipment — remove them first."; }
finally { _busy = false; }
}
private sealed class FormModel
{
[Required, RegularExpression("^[a-z0-9-]{1,32}$", ErrorMessage = "Lowercase letters, digits, dashes only; max 32 chars.")]
public string Name { get; set; } = "";
[Required] public string MachineCode { get; set; } = "";
[Required] public string UnsLineId { get; set; } = "";
[Required] public string DriverInstanceId { get; set; } = "";
public string? ZTag { get; set; }
public string? SAPID { get; set; }
public string? Manufacturer { get; set; }
public string? Model { get; set; }
public string? SerialNumber { get; set; }
public string? HardwareRevision { get; set; }
public string? SoftwareRevision { get; set; }
public short? YearOfConstruction { get; set; }
public string? AssetLocation { get; set; }
public string? ManufacturerUri { get; set; }
public string? DeviceManualUri { get; set; }
public bool Enabled { get; set; } = true;
public byte[] RowVersion { get; set; } = [];
}
}

View File

@@ -0,0 +1,320 @@
@page "/clusters/{ClusterId}/tags/new"
@page "/clusters/{ClusterId}/tags/{TagId}"
@* Tag CRUD. EquipmentId is required when the chosen driver's namespace is Equipment-kind,
forbidden when SystemPlatform-kind (decision #110); the form switches between
"pick equipment" and "FolderPath input" based on namespace kind. *@
@attribute [Microsoft.AspNetCore.Authorization.Authorize]
@rendermode RenderMode.InteractiveServer
@using Microsoft.AspNetCore.Components.Forms
@using Microsoft.EntityFrameworkCore
@using System.ComponentModel.DataAnnotations
@using ZB.MOM.WW.OtOpcUa.Configuration
@using ZB.MOM.WW.OtOpcUa.Configuration.Entities
@using ZB.MOM.WW.OtOpcUa.Configuration.Enums
@inject IDbContextFactory<OtOpcUaConfigDbContext> DbFactory
@inject NavigationManager Nav
<div class="d-flex justify-content-between align-items-center mb-3">
<h4 class="mb-0">@(IsNew ? "New tag" : "Edit tag") &middot; <span class="mono">@ClusterId</span></h4>
<a href="/clusters/@ClusterId/tags" class="btn btn-outline-secondary btn-sm">Cancel</a>
</div>
<ClusterNav ClusterId="@ClusterId" ActiveTab="tags" />
@if (!_loaded)
{
<p>Loading…</p>
}
else if (!IsNew && _existing is null)
{
<section class="panel notice rise" style="animation-delay:.02s">
Tag <span class="mono">@TagId</span> was not found.
</section>
}
else
{
<EditForm Model="_form" OnValidSubmit="SubmitAsync" FormName="tagEdit">
<DataAnnotationsValidator />
<section class="panel rise" style="animation-delay:.02s">
<div class="panel-head">Identity</div>
<div style="padding:1rem">
<div class="row">
<div class="col-md-6 mb-3">
<label class="form-label" for="tagId">TagId</label>
<InputText id="tagId" @bind-Value="_form.TagId" disabled="@(!IsNew)"
class="form-control form-control-sm mono"
placeholder="tag-line3-temp-01" />
</div>
<div class="col-md-6 mb-3">
<label class="form-label" for="name">Name</label>
<InputText id="name" @bind-Value="_form.Name" class="form-control form-control-sm"
placeholder="Temperature setpoint" />
</div>
</div>
<div class="row">
<div class="col-md-6 mb-3">
<label class="form-label" for="driver">Driver instance</label>
<InputSelect id="driver" @bind-Value="_form.DriverInstanceId" class="form-select form-select-sm">
<option value="">— pick a driver —</option>
@foreach (var d in _drivers)
{
<option value="@d.DriverInstanceId">@d.DriverInstanceId &mdash; @d.Name</option>
}
</InputSelect>
</div>
<div class="col-md-6 mb-3">
<label class="form-label" for="dtype">Data type</label>
<InputSelect id="dtype" @bind-Value="_form.DataType" class="form-select form-select-sm">
@foreach (var dt in DataTypes)
{
<option value="@dt">@dt</option>
}
</InputSelect>
</div>
</div>
@{ var driverNamespace = ResolveDriverNamespace(_form.DriverInstanceId); }
@if (driverNamespace?.Kind == NamespaceKind.Equipment)
{
<div class="mb-3">
<label class="form-label" for="equipment">Equipment</label>
<InputSelect id="equipment" @bind-Value="_form.EquipmentId" class="form-select form-select-sm">
<option value="">— pick equipment —</option>
@foreach (var e in _equipment.Where(e => e.DriverInstanceId == _form.DriverInstanceId))
{
<option value="@e.EquipmentId">@e.MachineCode &mdash; @e.Name</option>
}
</InputSelect>
</div>
}
else if (driverNamespace?.Kind == NamespaceKind.SystemPlatform)
{
<div class="mb-3">
<label class="form-label" for="folder">FolderPath (SystemPlatform namespace)</label>
<InputText id="folder" @bind-Value="_form.FolderPath" class="form-control form-control-sm mono"
placeholder="GalaxyArea/Machine_001" />
<div class="form-text">Galaxy hierarchy preserved as v1 expressed it — no UNS rule.</div>
</div>
}
else if (!string.IsNullOrEmpty(_form.DriverInstanceId))
{
<div class="text-muted small mb-3">Pick a driver to see its namespace kind.</div>
}
<div class="row">
<div class="col-md-6 mb-3">
<label class="form-label" for="access">Access level</label>
<InputSelect id="access" @bind-Value="_form.AccessLevel" class="form-select form-select-sm">
<option value="@TagAccessLevel.Read">Read</option>
<option value="@TagAccessLevel.ReadWrite">ReadWrite</option>
</InputSelect>
</div>
<div class="col-md-6 mb-3">
<label class="form-label">WriteIdempotent</label>
<div class="form-check form-switch">
<InputCheckbox @bind-Value="_form.WriteIdempotent" class="form-check-input" />
<label class="form-check-label">Safe to retry writes (decision #4445)</label>
</div>
</div>
</div>
<div class="mb-3">
<label class="form-label" for="pgroup">PollGroupId (optional)</label>
<InputText id="pgroup" @bind-Value="_form.PollGroupId" class="form-control form-control-sm mono" />
</div>
</div>
</section>
<section class="panel rise mt-3" style="animation-delay:.08s">
<div class="panel-head">Tag config (JSON)</div>
<div style="padding:1rem">
<InputTextArea @bind-Value="_form.TagConfig" rows="8"
class="form-control form-control-sm mono"
placeholder='{ "register": 40001, "scale": 0.1 }' />
<div class="form-text">Schemaless per driver type — register / address / scaling / byte-order. Validated server-side at deploy.</div>
</div>
</section>
@if (!string.IsNullOrWhiteSpace(_error))
{
<div class="panel notice mt-3" style="border-color:var(--alert)">@_error</div>
}
<div class="mt-3 d-flex gap-2">
<button type="submit" class="btn btn-primary" disabled="@_busy">
@if (_busy) { <span class="spinner-border spinner-border-sm me-1"></span> }
@(IsNew ? "Create" : "Save changes")
</button>
<a href="/clusters/@ClusterId/tags" class="btn btn-outline-secondary">Cancel</a>
@if (!IsNew)
{
<button type="button" class="btn btn-outline-danger ms-auto" @onclick="DeleteAsync" disabled="@_busy">Delete</button>
}
</div>
</EditForm>
}
@code {
private static readonly string[] DataTypes =
["Boolean", "SByte", "Byte", "Int16", "UInt16", "Int32", "UInt32",
"Int64", "UInt64", "Float", "Double", "String", "DateTime", "Guid", "ByteString"];
[Parameter] public string ClusterId { get; set; } = "";
[Parameter] public string? TagId { get; set; }
private bool IsNew => string.IsNullOrEmpty(TagId);
private FormModel _form = new();
private Tag? _existing;
private List<DriverInstance> _drivers = new();
private List<Equipment> _equipment = new();
private Dictionary<string, Namespace> _namespacesByDriverInstance = new();
private bool _loaded;
private bool _busy;
private string? _error;
protected override async Task OnInitializedAsync()
{
await using var db = await DbFactory.CreateDbContextAsync();
_drivers = await db.DriverInstances.AsNoTracking()
.Where(d => d.ClusterId == ClusterId)
.OrderBy(d => d.DriverInstanceId)
.ToListAsync();
var namespaces = await db.Namespaces.AsNoTracking()
.Where(n => n.ClusterId == ClusterId)
.ToListAsync();
var nsById = namespaces.ToDictionary(n => n.NamespaceId);
_namespacesByDriverInstance = _drivers.ToDictionary(
d => d.DriverInstanceId,
d => nsById.TryGetValue(d.NamespaceId, out var ns) ? ns : namespaces.First());
var driverIds = _drivers.Select(d => d.DriverInstanceId).ToHashSet();
_equipment = await db.Equipment.AsNoTracking()
.Where(e => driverIds.Contains(e.DriverInstanceId))
.OrderBy(e => e.MachineCode)
.ToListAsync();
if (!IsNew)
{
_existing = await db.Tags.AsNoTracking()
.FirstOrDefaultAsync(t => t.TagId == TagId);
if (_existing is not null)
{
_form = new FormModel
{
TagId = _existing.TagId,
Name = _existing.Name,
DriverInstanceId = _existing.DriverInstanceId,
EquipmentId = _existing.EquipmentId,
FolderPath = _existing.FolderPath,
DataType = _existing.DataType,
AccessLevel = _existing.AccessLevel,
WriteIdempotent = _existing.WriteIdempotent,
PollGroupId = _existing.PollGroupId,
TagConfig = _existing.TagConfig,
RowVersion = _existing.RowVersion,
};
}
}
else
{
_form.DataType = "Float";
_form.AccessLevel = TagAccessLevel.Read;
_form.TagConfig = "{}";
}
_loaded = true;
}
private Namespace? ResolveDriverNamespace(string driverId) =>
string.IsNullOrEmpty(driverId) ? null
: _namespacesByDriverInstance.TryGetValue(driverId, out var ns) ? ns : null;
private async Task SubmitAsync()
{
_busy = true; _error = null;
try
{
if (string.IsNullOrEmpty(_form.DriverInstanceId)) { _error = "Pick a driver."; return; }
var ns = ResolveDriverNamespace(_form.DriverInstanceId);
if (ns?.Kind == NamespaceKind.Equipment && string.IsNullOrEmpty(_form.EquipmentId))
{ _error = "Driver lives in an Equipment-kind namespace — pick an equipment."; return; }
if (ns?.Kind == NamespaceKind.SystemPlatform && !string.IsNullOrEmpty(_form.EquipmentId))
{ _error = "Driver lives in a SystemPlatform namespace — EquipmentId must be empty (use FolderPath)."; return; }
try { using var _ = System.Text.Json.JsonDocument.Parse(_form.TagConfig); }
catch { _error = "TagConfig is not valid JSON."; return; }
await using var db = await DbFactory.CreateDbContextAsync();
if (IsNew)
{
if (await db.Tags.AnyAsync(t => t.TagId == _form.TagId))
{ _error = $"Tag '{_form.TagId}' already exists."; return; }
db.Tags.Add(new Tag
{
TagId = _form.TagId,
DriverInstanceId = _form.DriverInstanceId,
EquipmentId = string.IsNullOrEmpty(_form.EquipmentId) ? null : _form.EquipmentId,
Name = _form.Name,
FolderPath = string.IsNullOrWhiteSpace(_form.FolderPath) ? null : _form.FolderPath,
DataType = _form.DataType,
AccessLevel = _form.AccessLevel,
WriteIdempotent = _form.WriteIdempotent,
PollGroupId = string.IsNullOrWhiteSpace(_form.PollGroupId) ? null : _form.PollGroupId,
TagConfig = _form.TagConfig,
});
}
else
{
var entity = await db.Tags.FirstOrDefaultAsync(t => t.TagId == TagId);
if (entity is null) { _error = "Row no longer exists."; return; }
db.Entry(entity).Property(e => e.RowVersion).OriginalValue = _form.RowVersion;
entity.DriverInstanceId = _form.DriverInstanceId;
entity.EquipmentId = string.IsNullOrEmpty(_form.EquipmentId) ? null : _form.EquipmentId;
entity.Name = _form.Name;
entity.FolderPath = string.IsNullOrWhiteSpace(_form.FolderPath) ? null : _form.FolderPath;
entity.DataType = _form.DataType;
entity.AccessLevel = _form.AccessLevel;
entity.WriteIdempotent = _form.WriteIdempotent;
entity.PollGroupId = string.IsNullOrWhiteSpace(_form.PollGroupId) ? null : _form.PollGroupId;
entity.TagConfig = _form.TagConfig;
}
await db.SaveChangesAsync();
Nav.NavigateTo($"/clusters/{ClusterId}/tags");
}
catch (DbUpdateConcurrencyException) { _error = "Another user changed this tag while you were editing."; }
catch (Exception ex) { _error = ex.Message; }
finally { _busy = false; }
}
private async Task DeleteAsync()
{
if (IsNew) return;
_busy = true; _error = null;
try
{
await using var db = await DbFactory.CreateDbContextAsync();
var entity = await db.Tags.FirstOrDefaultAsync(t => t.TagId == TagId);
if (entity is null) { Nav.NavigateTo($"/clusters/{ClusterId}/tags"); return; }
db.Entry(entity).Property(e => e.RowVersion).OriginalValue = _form.RowVersion;
db.Tags.Remove(entity);
await db.SaveChangesAsync();
Nav.NavigateTo($"/clusters/{ClusterId}/tags");
}
catch (DbUpdateConcurrencyException) { _error = "Another user changed this tag while you were viewing it."; }
catch (Exception ex) { _error = ex.Message; }
finally { _busy = false; }
}
private sealed class FormModel
{
[Required, RegularExpression("^[A-Za-z0-9_-]+$")] public string TagId { get; set; } = "";
[Required] public string Name { get; set; } = "";
[Required] public string DriverInstanceId { get; set; } = "";
public string? EquipmentId { get; set; }
public string? FolderPath { get; set; }
[Required] public string DataType { get; set; } = "Float";
public TagAccessLevel AccessLevel { get; set; } = TagAccessLevel.Read;
public bool WriteIdempotent { get; set; }
public string? PollGroupId { get; set; }
[Required] public string TagConfig { get; set; } = "{}";
public byte[] RowVersion { get; set; } = [];
}
}