feat: make sure a projection state exists when updating desired state

Informatievlaanderen · Aug 13, 2019 · 1fc1b38 · 1fc1b38
1 parent eb06213
commit 1fc1b38
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/src/Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner/RunnerDbContext.cs b/src/Be.Vlaanderen.Basisregisters.ProjectionHandling.Runner/RunnerDbContext.cs
@@ -54,6 +54,16 @@ public async Task UpdateProjectionDesiredState(string projectionName, string use
         {
             var projectionStateItem = await ProjectionStates.SingleOrDefaultAsync(item => item.Name == projectionName, cancellationToken);
 
+            if (projectionStateItem == null)
+            {
+                projectionStateItem = new ProjectionStateItem
+                {
+                    Name = projectionName,
+                    Position = -1L
+                };
+                await ProjectionStates.AddAsync(projectionStateItem, cancellationToken);
+            }
+
             projectionStateItem.DesiredState = userRequestedState;
             projectionStateItem.DesiredStateChangedAt = DateTimeOffset.UtcNow;
         }