Upload thermal reading to timeseries on completion

Inject ITimeseriesService into ThermalReadingResultHandler and upload
the temperature reading after publishing the MQTT result, restoring the
legacy behaviour from the pre-refactor ThermalReadingNotificationController.

Author: aeshub

api.Tests/Services/ResultHandlers/WorkflowResultHandlers/ThermalReadingResultHandlerTests.cs

@@ -138,4 +138,40 @@ public async Task OnWorkflowCompleted_NullResultJson_PublishesMessageWithNullVal
         Assert.Null(published.Value);
         Assert.Null(published.Confidence);
     }
+
+    [Fact]
+    public async Task OnWorkflowCompleted_ValidResult_UploadsTimeseries()
+    {
+        var record = await _db.NewInspectionRecord(inspectionId: "insp-123");
+        var analysis = await _db.NewAnalysis(inspectionRecords: [record]);
+        var run = await _db.NewAnalysisRun(analysis);
+        var workflow = await _db.NewWorkflow(run, workflowType: "thermal-reading");
+        const float temperature = 23.5f;
+        workflow.ResultJson = JsonSerializer.Serialize(new { temperature = temperature });
+        await _context.SaveChangesAsync(TestContext.Current.CancellationToken);
+
+        using var scope = _factory.Services.CreateScope();
+        var handler = ResolveHandler(scope);
+
+        await handler.OnWorkflowCompleted(workflow);
+
+        var upload = Assert.Single(_factory.TimeseriesService.Uploads);
+        Assert.Equal(temperature, upload.Value);
+    }
+
+    [Fact]
+    public async Task OnWorkflowCompleted_NullResultJson_DoesNotUploadTimeseries()
+    {
+        var record = await _db.NewInspectionRecord(inspectionId: "insp-123");
+        var analysis = await _db.NewAnalysis(inspectionRecords: [record]);
+        var run = await _db.NewAnalysisRun(analysis);
+        var workflow = await _db.NewWorkflow(run, workflowType: "thermal-reading");
+
+        using var scope = _factory.Services.CreateScope();
+        var handler = ResolveHandler(scope);
+
+        await handler.OnWorkflowCompleted(workflow);
+
+        Assert.Empty(_factory.TimeseriesService.Uploads);
+    }
 }

api/Services/ResultHandlers/WorkflowResultHandlers/ThermalReadingResultHandler.cs

@@ -15,6 +15,7 @@ internal sealed class ThermalReadingResult
 public class ThermalReadingResultHandler(
     SaraDbContext context,
     IMqttPublisherService mqttPublisherService,
+    ITimeseriesService timeseriesService,
     ILogger<ThermalReadingResultHandler> logger
 ) : IWorkflowResultHandler
 {
@@ -75,5 +76,56 @@ public async Task OnWorkflowCompleted(Workflow workflow)
         }
 
         await mqttPublisherService.PublishSaraAnalysisResultAvailable(message);
+
+        await TryUploadTimeseries(workflow, inspectionRecord, result);
+    }
+
+    private async Task TryUploadTimeseries(
+        Workflow workflow,
+        InspectionRecord inspectionRecord,
+        ThermalReadingResult? result
+    )
+    {
+        if (result is null)
+        {
+            logger.LogWarning(
+                "Skipping thermal-reading timeseries upload for workflow {WorkflowId}: result is null",
+                workflow.Id
+            );
+            return;
+        }
+
+        var uploadRequest = new TriggerTimeseriesUploadRequest
+        {
+            Name =
+                $"{inspectionRecord.InstallationCode}_{inspectionRecord.Tag}_{inspectionRecord.InspectionDescription?.Replace(" ", "-")}",
+            Facility = inspectionRecord.InstallationCode,
+            ExternalId = "",
+            Description = "ThermalReading",
+            Unit = "°C",
+            AssetId = inspectionRecord.InstallationCode,
+            Value = result.Temperature,
+            Timestamp = inspectionRecord.Timestamp ?? DateTime.UtcNow,
+            Step = true,
+            Metadata = new Dictionary<string, string>
+            {
+                { "tag_id", inspectionRecord.Tag ?? "" },
+                { "inspection_description", inspectionRecord.InspectionDescription ?? "" },
+                { "robot_name", inspectionRecord.RobotName ?? "" },
+            },
+        };
+
+        try
+        {
+            await timeseriesService.TriggerTimeseriesUpload(uploadRequest);
+        }
+        catch (Exception ex)
+        {
+            logger.LogError(
+                ex,
+                "Failed to upload thermal-reading datapoint to Timeseries for workflow {WorkflowId}",
+                workflow.Id
+            );
+        }
     }
 }