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

try to fix maintenance function

Browse Source
This commit is contained in:
Oliver Kieselbach
2026-02-15 22:43:59 +01:00
parent 22f2151b7a
commit 2d44899eb5
1 changed files with 47 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Backend/AutopilotMonitor.Functions/Services/TableStorageService.cs
+47 -21
View File
@@ -604,8 +604,11 @@ namespace AutopilotMonitor.Functions.Services
/// </summary>
private SessionSummary MapToSessionSummary(TableEntity entity)
{
var startedAt = entity.GetDateTime("StartedAt") ?? DateTime.UtcNow;
var completedAt = entity.GetDateTime("CompletedAt");
// All typed getters (GetInt32, GetDateTime, etc.) throw InvalidOperationException
// when a property exists but has a different type (e.g. legacy data stored as string
// instead of int). Use safe helpers to handle type mismatches gracefully.
var startedAt = SafeGetDateTime(entity, "StartedAt") ?? DateTime.UtcNow;
var completedAt = SafeGetDateTime(entity, "CompletedAt");
// Parse status with error handling and case-insensitivity
var statusString = entity.GetString("Status") ?? "InProgress";
@@ -615,23 +618,6 @@ namespace AutopilotMonitor.Functions.Services
status = SessionStatus.Unknown;
}
// CurrentPhase was previously stored as enum string, now stored as int.
// GetInt32 throws InvalidOperationException if the property exists but is not Int32,
// so fall back to parsing the string representation for legacy data.
int currentPhase = 0;
try
{
currentPhase = entity.GetInt32("CurrentPhase") ?? 0;
}
catch (InvalidOperationException)
{
var phaseString = entity.GetString("CurrentPhase");
if (phaseString != null && Enum.TryParse<EnrollmentPhase>(phaseString, ignoreCase: true, out var parsed))
{
currentPhase = (int)parsed;
}
}
return new SessionSummary
{
SessionId = entity.RowKey,
@@ -642,11 +628,11 @@ namespace AutopilotMonitor.Functions.Services
Model = entity.GetString("Model") ?? string.Empty,
StartedAt = startedAt,
CompletedAt = completedAt,
CurrentPhase = currentPhase,
CurrentPhase = SafeGetInt32(entity, "CurrentPhase") ?? 0,
CurrentPhaseDetail = entity.GetString("CurrentPhaseDetail") ?? string.Empty,
Status = status,
FailureReason = entity.GetString("FailureReason") ?? string.Empty,
EventCount = entity.GetInt32("EventCount") ?? 0,
EventCount = SafeGetInt32(entity, "EventCount") ?? 0,
DurationSeconds = completedAt.HasValue
? (int)(completedAt.Value - startedAt).TotalSeconds
: (int)(DateTime.UtcNow - startedAt).TotalSeconds,
@@ -654,6 +640,46 @@ namespace AutopilotMonitor.Functions.Services
};
}
/// <summary>
/// Safely reads an Int32 property from a TableEntity.
/// Returns null instead of throwing when the property has a different type (legacy data).
/// </summary>
private int? SafeGetInt32(TableEntity entity, string key)
{
try
{
return entity.GetInt32(key);
}
catch (InvalidOperationException)
{
_logger.LogWarning("Property '{Key}' on entity {PK}/{RK} is not Int32, attempting string parse", key, entity.PartitionKey, entity.RowKey);
var str = entity.GetString(key);
if (str != null && int.TryParse(str, out var parsed))
return parsed;
return null;
}
}
/// <summary>
/// Safely reads a DateTime property from a TableEntity.
/// Returns null instead of throwing when the property has a different type (legacy data).
/// </summary>
private DateTime? SafeGetDateTime(TableEntity entity, string key)
{
try
{
return entity.GetDateTime(key);
}
catch (InvalidOperationException)
{
_logger.LogWarning("Property '{Key}' on entity {PK}/{RK} is not DateTime, attempting string parse", key, entity.PartitionKey, entity.RowKey);
var str = entity.GetString(key);
if (str != null && DateTime.TryParse(str, out var parsed))
return parsed;
return null;
}
}
/// <summary>
/// Deletes a session from storage
/// </summary>