handle estate operator events

TransactionProcessor.BusinessLogic/EventHandling/ReadModelDomainEventHandler.cs

@@ -24,7 +24,9 @@ public async Task<Result> Handle(IDomainEvent domainEvent,
                 EstateDomainEvents.EstateCreatedEvent de => this.HandleSpecificDomainEvent(de, cancellationToken),
                 EstateDomainEvents.SecurityUserAddedToEstateEvent de => this.EstateReportingRepository.AddEstateSecurityUser(de, cancellationToken),
                 EstateDomainEvents.EstateReferenceAllocatedEvent de => this.EstateReportingRepository.UpdateEstate(de, cancellationToken),
-
+                EstateDomainEvents.OperatorAddedToEstateEvent de => this.EstateReportingRepository.AddEstateOperator(de, cancellationToken),
+                EstateDomainEvents.OperatorRemovedFromEstateEvent de => this.EstateReportingRepository.RemoveOperatorFromEstate(de, cancellationToken),
+
                 OperatorDomainEvents.OperatorCreatedEvent de => this.EstateReportingRepository.AddOperator(de, cancellationToken),
                 OperatorDomainEvents.OperatorNameUpdatedEvent de => this.EstateReportingRepository.UpdateOperator(de, cancellationToken),
                 OperatorDomainEvents.OperatorRequireCustomMerchantNumberChangedEvent de => this.EstateReportingRepository.UpdateOperator(de, cancellationToken),

TransactionProcessor.Database/Contexts/EstateManagementGenericContext.cs

@@ -56,7 +56,9 @@ public EstateManagementContext(DbContextOptions dbContextOptions) : base(dbConte
     public DbSet<Operator> Operators { get; set; }
 
     public DbSet<Estate> Estates { get; set; }
-
+
+    public DbSet<EstateOperator> EstateOperators { get; set; }
+
     public DbSet<EstateSecurityUser> EstateSecurityUsers { get; set; }
 
     public virtual DbSet<FileImportLogFile> FileImportLogFiles { get; set; }
@@ -314,7 +316,8 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
                     .SetupSettlementSummary()
                     .SetupTransactionHistory()
                     .SetupTodaysTransactions()
-                    .SetupTransactionTimings();
+                    .SetupTransactionTimings()
+                    .SetupEstateOperator();
 
         modelBuilder.SetupViewEntities();
 

TransactionProcessor.Database/Contexts/Extensions.cs

@@ -77,6 +77,16 @@ public static ModelBuilder SetupEstate(this ModelBuilder modelBuilder){
         return modelBuilder;
     }
 
+    public static ModelBuilder SetupEstateOperator(this ModelBuilder modelBuilder)
+    {
+        modelBuilder.Entity<EstateOperator>().HasKey(t => new {
+            t.EstateId,
+            t.OperatorId
+        });
+
+        return modelBuilder;
+    }
+
     public static ModelBuilder SetupOperator(this ModelBuilder modelBuilder)
     {
         modelBuilder.Entity<Operator>().HasKey(t => new {

TransactionProcessor.Database/Entities/EstateOperator.cs

@@ -0,0 +1,17 @@
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace TransactionProcessor.Database.Entities;
+
+[Table("estateoperator")]
+public class EstateOperator
+{
+    #region Properties
+
+    public Guid EstateId { get; set; }
+
+    public Guid OperatorId { get; set; }
+
+    public Boolean? IsDeleted { get; set; }
+
+    #endregion
+}