fix: enables rebuilding of projections that don't have a live version

Elders · Jun 16, 2022 · 943701d · 943701d
1 parent 6744357
commit 943701d
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/src/Elders.Cronus/Projections/Versioning/ProjectionVersionManager.cs b/src/Elders.Cronus/Projections/Versioning/ProjectionVersionManager.cs
@@ -50,12 +50,11 @@ public void Replay(string hash, IProjectionVersioningPolicy policy)
             }
         }
 
-        public void Rebuild(string hash)
+        public void Rebuild(string hash, IProjectionVersioningPolicy policy)
         {
-            ProjectionVersion currentLiveVersion = state.Versions.GetLive();
-
-            if (CanRebuild(currentLiveVersion))
+            if (CanRebuild(hash))
             {
+                ProjectionVersion currentLiveVersion = state.Versions.GetNext(policy, hash);
                 var timebox = GetVersionRequestTimebox(hash);
                 RequestVersion(state.Id, currentLiveVersion.WithStatus(ProjectionStatus.Rebuilding), timebox);
             }
@@ -114,12 +113,13 @@ private bool CanReplay(string hash, IProjectionVersioningPolicy policy)
             return (doesntHaveBuildingVersion && isVersionable) || (doesntHaveBuildingVersion && isVersionable == false && isNewHashTheLiveOne == false);
         }
 
-        private bool CanRebuild(ProjectionVersion currentLiveVersion)
+        private bool CanRebuild(string hash)
         {
+            ProjectionVersion currentLiveVersion = state.Versions.GetLive();
             if (currentLiveVersion is null)
-                return false;
+                return true;
 
-            bool hashMatchesCurrentLiveVersion = currentLiveVersion.Hash.Equals(currentLiveVersion.Hash);
+            bool hashMatchesCurrentLiveVersion = currentLiveVersion.Hash.Equals(hash);
             bool hasRebuildingVersion = state.Versions.HasRebuildingVersion();
 
             return hashMatchesCurrentLiveVersion && hasRebuildingVersion == false;

diff --git a/src/Elders.Cronus/Projections/Versioning/ProjectionVersionManagerAppService.cs b/src/Elders.Cronus/Projections/Versioning/ProjectionVersionManagerAppService.cs
@@ -42,7 +42,7 @@ public Task HandleAsync(ReplayProjection command)
 
         public Task HandleAsync(RebuildProjectionCommand command)
         {
-            return UpdateAsync(command.Id, ar => ar.Rebuild(command.Hash));
+            return UpdateAsync(command.Id, ar => ar.Rebuild(command.Hash, projectionVersioningPolicy));
         }
 
         public Task HandleAsync(FinalizeProjectionVersionRequest command)