Sistemas que operan
cuando tu negocio
no puede fallar.

// QBSoft IT/OT Bridge — OPC UA → MQTT (Sparkplug B)
// Lee tags del PLC y publica al broker contextualizado por línea

public sealed class PlcBridgeService(
    IOpcUaClient opc,
    IMqttPublisher mqtt,
    ILineContext ctx,
    ILogger<PlcBridgeService> log) : BackgroundService
{
    protected override async Task ExecuteAsync(CancellationToken ct)
    {
        var subscription = await opc.SubscribeAsync(
            PlcTags.Critical,
            samplingMs: 250, ct);

        await foreach (var batch in subscription.ReadAllAsync(ct))
        {
            var enriched = batch.Select(tag => new SparkplugMetric
            {
                Name      = ctx.Resolve(tag.NodeId),  // PLC03/Linea3/Temp → bldg/A/L3/temp
                Value     = tag.Value,
                Quality   = tag.StatusCode.ToSparkplug(),
                Timestamp = tag.SourceTimestamp
            });

            await mqtt.PublishAsync("spBv1.0/qbsoft/DDATA/planta-norte",
                enriched, qos: 1, ct);

            log.LogDebug("Pushed {Count} tags to MQTT", batch.Count);
        }
    }
}