Add core EF Core entities and configurations

Author: johnsimons

src/ServiceControl.Persistence.Sql.Core/Entities/ArchiveOperationEntity.cs

@@ -0,0 +1,19 @@
+namespace ServiceControl.Persistence.Sql.Core.Entities;
+
+using System;
+
+public class ArchiveOperationEntity
+{
+    public Guid Id { get; set; }
+    public string RequestId { get; set; } = null!;
+    public string GroupName { get; set; } = null!;
+    public int ArchiveType { get; set; }  // ArchiveType enum as int
+    public int ArchiveState { get; set; }  // ArchiveState enum as int
+    public int TotalNumberOfMessages { get; set; }
+    public int NumberOfMessagesArchived { get; set; }
+    public int NumberOfBatches { get; set; }
+    public int CurrentBatch { get; set; }
+    public DateTime Started { get; set; }
+    public DateTime? Last { get; set; }
+    public DateTime? CompletionTime { get; set; }
+}

src/ServiceControl.Persistence.Sql.Core/Entities/CustomCheckEntity.cs

@@ -0,0 +1,14 @@
+namespace ServiceControl.Persistence.Sql.Core.Entities;
+
+public class CustomCheckEntity
+{
+    public Guid Id { get; set; }
+    public string CustomCheckId { get; set; } = null!;
+    public string? Category { get; set; }
+    public int Status { get; set; } // 0 = Pass, 1 = Fail
+    public DateTime ReportedAt { get; set; }
+    public string? FailureReason { get; set; }
+    public string EndpointName { get; set; } = null!;
+    public Guid HostId { get; set; }
+    public string Host { get; set; } = null!;
+}

src/ServiceControl.Persistence.Sql.Core/Entities/EndpointSettingsEntity.cs

@@ -0,0 +1,7 @@
+namespace ServiceControl.Persistence.Sql.Core.Entities;
+
+public class EndpointSettingsEntity
+{
+    public required string Name { get; set; }
+    public bool TrackInstances { get; set; }
+}

src/ServiceControl.Persistence.Sql.Core/Entities/EventLogItemEntity.cs

@@ -0,0 +1,14 @@
+namespace ServiceControl.Persistence.Sql.Core.Entities;
+
+using System;
+
+public class EventLogItemEntity
+{
+    public Guid Id { get; set; }
+    public required string Description { get; set; }
+    public int Severity { get; set; }
+    public DateTime RaisedAt { get; set; }
+    public string? RelatedTo { get; set; } // Stored as JSON array
+    public string? Category { get; set; }
+    public string? EventType { get; set; }
+}

src/ServiceControl.Persistence.Sql.Core/Entities/ExternalIntegrationDispatchRequestEntity.cs

@@ -0,0 +1,10 @@
+namespace ServiceControl.Persistence.Sql.Core.Entities;
+
+using System;
+
+public class ExternalIntegrationDispatchRequestEntity
+{
+    public long Id { get; set; }
+    public string DispatchContextJson { get; set; } = null!;
+    public DateTime CreatedAt { get; set; }
+}

src/ServiceControl.Persistence.Sql.Core/Entities/FailedErrorImportEntity.cs

@@ -0,0 +1,10 @@
+namespace ServiceControl.Persistence.Sql.Core.Entities;
+
+using System;
+
+public class FailedErrorImportEntity
+{
+    public Guid Id { get; set; }
+    public string MessageJson { get; set; } = null!; // FailedTransportMessage as JSON
+    public string? ExceptionInfo { get; set; }
+}

src/ServiceControl.Persistence.Sql.Core/Entities/FailedMessageEntity.cs

@@ -0,0 +1,37 @@
+namespace ServiceControl.Persistence.Sql.Core.Entities;
+
+using System;
+using ServiceControl.MessageFailures;
+
+public class FailedMessageEntity
+{
+    public Guid Id { get; set; }
+    public string UniqueMessageId { get; set; } = null!;
+    public FailedMessageStatus Status { get; set; }
+
+    // JSON columns for complex nested data
+    public string ProcessingAttemptsJson { get; set; } = null!;
+    public string FailureGroupsJson { get; set; } = null!;
+
+    // Denormalized fields from FailureGroups for efficient filtering
+    // PrimaryFailureGroupId is the first group ID from FailureGroupsJson array
+    public string? PrimaryFailureGroupId { get; set; }
+
+    // Denormalized fields from the last processing attempt for efficient querying
+    public string? MessageId { get; set; }
+    public string? MessageType { get; set; }
+    public DateTime? TimeSent { get; set; }
+    public string? SendingEndpointName { get; set; }
+    public string? ReceivingEndpointName { get; set; }
+    public string? ExceptionType { get; set; }
+    public string? ExceptionMessage { get; set; }
+    public string? QueueAddress { get; set; }
+    public int? NumberOfProcessingAttempts { get; set; }
+    public DateTime? LastProcessedAt { get; set; }
+    public string? ConversationId { get; set; }
+
+    // Performance metrics for sorting and filtering
+    public TimeSpan? CriticalTime { get; set; }
+    public TimeSpan? ProcessingTime { get; set; }
+    public TimeSpan? DeliveryTime { get; set; }
+}

src/ServiceControl.Persistence.Sql.Core/Entities/FailedMessageRetryEntity.cs

@@ -0,0 +1,11 @@
+namespace ServiceControl.Persistence.Sql.Core.Entities;
+
+using System;
+
+public class FailedMessageRetryEntity
+{
+    public Guid Id { get; set; }
+    public string FailedMessageId { get; set; } = null!;
+    public string? RetryBatchId { get; set; }
+    public int StageAttempts { get; set; }
+}

src/ServiceControl.Persistence.Sql.Core/Entities/GroupCommentEntity.cs

@@ -0,0 +1,10 @@
+namespace ServiceControl.Persistence.Sql.Core.Entities;
+
+using System;
+
+public class GroupCommentEntity
+{
+    public Guid Id { get; set; }
+    public string GroupId { get; set; } = null!;
+    public string Comment { get; set; } = null!;
+}

src/ServiceControl.Persistence.Sql.Core/Entities/KnownEndpointEntity.cs

@@ -0,0 +1,11 @@
+namespace ServiceControl.Persistence.Sql.Core.Entities;
+
+public class KnownEndpointEntity
+{
+    public Guid Id { get; set; }
+    public string EndpointName { get; set; } = null!;
+    public Guid HostId { get; set; }
+    public string Host { get; set; } = null!;
+    public string HostDisplayName { get; set; } = null!;
+    public bool Monitored { get; set; }
+}