feat: Mark rebuild job progress signals as ISystemSignal

Elders · Jul 22, 2022 · ea0ab90 · ea0ab90
1 parent e67f25d
commit ea0ab90
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 8 deletions.
diff --git a/src/Elders.Cronus/Projections/Rebuilding/ProgressTracker.cs b/src/Elders.Cronus/Projections/Rebuilding/ProgressTracker.cs
@@ -1,5 +1,4 @@
 using System;
-using System.Linq;
 using System.Collections.Generic;
 using System.Threading.Tasks;
 using Elders.Cronus.EventStore;
@@ -12,7 +11,7 @@ public class ProgressTracker
     {
         private readonly string tenant;
         private readonly IMessageCounter messageCounter;
-        private readonly IPublisher<ISignal> signalPublisher;
+        private readonly IPublisher<ISystemSignal> signalPublisher;
         private readonly ProjectionVersionHelper projectionVersionHelper;
         private readonly ILogger<ProgressTracker> logger;
 
@@ -21,7 +20,7 @@ public class ProgressTracker
         public ulong TotalEvents { get; set; }
 
 
-        public ProgressTracker(IMessageCounter messageCounter, CronusContext context, IPublisher<ISignal> signalPublisher, ProjectionVersionHelper projectionVersionHelper, ILogger<ProgressTracker> logger)
+        public ProgressTracker(IMessageCounter messageCounter, CronusContext context, IPublisher<ISystemSignal> signalPublisher, ProjectionVersionHelper projectionVersionHelper, ILogger<ProgressTracker> logger)
         {
             tenant = context.Tenant;
             this.messageCounter = messageCounter;

diff --git a/src/Elders.Cronus/Projections/Rebuilding/RebuildProjection_Job.cs b/src/Elders.Cronus/Projections/Rebuilding/RebuildProjection_Job.cs
@@ -12,7 +12,7 @@ namespace Elders.Cronus.Projections.Rebuilding
 {
     public sealed class RebuildProjection_Job : CronusJob<RebuildProjection_JobData>
     {
-        private readonly IPublisher<ISignal> signalPublisher;
+        private readonly IPublisher<ISystemSignal> signalPublisher;
         private readonly IInitializableProjectionStore projectionStoreInitializer;
         private readonly IRebuildingProjectionRepository rebuildingRepository;
         private readonly EventToAggregateRootId eventToAggregateIndex;
@@ -25,7 +25,7 @@ public sealed class RebuildProjection_Job : CronusJob<RebuildProjection_JobData>
             ProgressTracker progressTracker,
             ProjectionVersionHelper projectionVersionHelper,
             EventToAggregateRootId eventToAggregateIndex,
-            IPublisher<ISignal> signalPublisher,
+            IPublisher<ISystemSignal> signalPublisher,
             ILogger<RebuildProjection_Job> logger)
             : base(logger)
         {

diff --git a/src/Elders.Cronus/Projections/Signals/RebuildProjectionFinished.cs b/src/Elders.Cronus/Projections/Signals/RebuildProjectionFinished.cs
@@ -3,7 +3,7 @@
 namespace Elders.Cronus.Projections
 {
     [DataContract(Name = "b248432b-451c-4894-84f2-c5ac5bc35139")]
-    public class RebuildProjectionFinished : ISignal
+    public class RebuildProjectionFinished : ISystemSignal
     {
         public RebuildProjectionFinished() { }
 

diff --git a/src/Elders.Cronus/Projections/Signals/RebuildProjectionProgress.cs b/src/Elders.Cronus/Projections/Signals/RebuildProjectionProgress.cs
@@ -3,7 +3,7 @@
 namespace Elders.Cronus.Projections
 {
     [DataContract(Name = "373f4ff0-cb6f-499e-9fa5-1666ccc00689")]
-    public class RebuildProjectionProgress : ISignal
+    public class RebuildProjectionProgress : ISystemSignal
     {
         public RebuildProjectionProgress() { }
 

diff --git a/src/Elders.Cronus/Projections/Signals/RebuildProjectionStarted.cs b/src/Elders.Cronus/Projections/Signals/RebuildProjectionStarted.cs
@@ -3,7 +3,7 @@
 namespace Elders.Cronus.Projections
 {
     [DataContract(Name = "b03199e7-2752-48b7-93de-c45ad18b55bf")]
-    public class RebuildProjectionStarted : ISignal
+    public class RebuildProjectionStarted : ISystemSignal
     {
         public RebuildProjectionStarted() { }