gsadmin/AutopilotMonitor
1
0
Fork 0
mirror of https://github.com/okieselbach/AutopilotMonitor.git synced 2026-10-24 12:42:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

better session count increment 404 handling

Browse Source
This commit is contained in:
Oliver Kieselbach
2026-03-19 15:23:45 +01:00
parent 22dc8c9e79
commit 2496cb9db6
2 changed files with 14 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Agent/AutopilotMonitor.Agent/buildcounter.txt
+1 -1
View File
@@ -1 +1 @@
506
509
src/Backend/AutopilotMonitor.Functions/Services/TableStorageService.Sessions.cs
+13 -7
View File
@@ -1134,8 +1134,14 @@ namespace AutopilotMonitor.Functions.Services
try
{
var tableClient = _tableServiceClient.GetTableClient(Constants.TableNames.Sessions);
var entity = await tableClient.GetEntityAsync<TableEntity>(tenantId, sessionId);
var currentCount = entity.Value.GetInt32("EventCount") ?? 0;
var entityResponse = await tableClient.GetEntityIfExistsAsync<TableEntity>(tenantId, sessionId);
if (!entityResponse.HasValue)
{
_logger.LogWarning("Session {SessionId} not found when incrementing event count — session may have been cleaned up or not yet registered", sessionId);
return;
}
var entity = entityResponse.Value!;
var currentCount = entity.GetInt32("EventCount") ?? 0;
var update = new TableEntity(tenantId, sessionId)
{
@@ -1149,7 +1155,7 @@ namespace AutopilotMonitor.Functions.Services
}
// Align StartedAt with the earliest event timestamp provided by the caller
var currentStartedAt = entity.Value.GetDateTimeOffset("StartedAt")?.UtcDateTime ?? DateTime.MaxValue;
var currentStartedAt = entity.GetDateTimeOffset("StartedAt")?.UtcDateTime ?? DateTime.MaxValue;
if (earliestEventTimestamp.HasValue && earliestEventTimestamp.Value < currentStartedAt)
{
update["StartedAt"] = EnsureUtc(earliestEventTimestamp.Value);
@@ -1158,18 +1164,18 @@ namespace AutopilotMonitor.Functions.Services
// Track the most recent event timestamp for excessive data sender detection
if (latestEventTimestamp.HasValue)
{
var currentLastEventAt = entity.Value.GetDateTimeOffset("LastEventAt")?.UtcDateTime;
var currentLastEventAt = entity.GetDateTimeOffset("LastEventAt")?.UtcDateTime;
if (!currentLastEventAt.HasValue || latestEventTimestamp.Value > currentLastEventAt.Value)
update["LastEventAt"] = EnsureUtc(latestEventTimestamp.Value);
}
await tableClient.UpdateEntityAsync(update, entity.Value.ETag, TableUpdateMode.Merge);
await tableClient.UpdateEntityAsync(update, entity.ETag, TableUpdateMode.Merge);
// Dual-write: merge the same fields into SessionsIndex
var indexRowKey = entity.Value.GetString("IndexRowKey");
var indexRowKey = entity.GetString("IndexRowKey");
if (string.IsNullOrEmpty(indexRowKey))
{
var incStartedAt = entity.Value.GetDateTimeOffset("StartedAt")?.UtcDateTime;
var incStartedAt = entity.GetDateTimeOffset("StartedAt")?.UtcDateTime;
if (incStartedAt.HasValue)
indexRowKey = ComputeIndexRowKey(incStartedAt.Value, sessionId);
}