Register IInstanceAndEventsRepository (#572)

Altinn · Nov 28, 2024 · 9c637c6 · 9c637c6
1 parent e739508
commit 9c637c6
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/src/Storage/Controllers/ProcessController.cs b/src/Storage/Controllers/ProcessController.cs
@@ -132,6 +132,16 @@ public async Task<ActionResult<Instance>> PutInstanceAndEvents(
                 return NotFound();
             }
 
+            foreach (InstanceEvent instanceEvent in processStateUpdate.Events ?? [])
+            {
+                if (string.IsNullOrWhiteSpace(instanceEvent.InstanceId))
+                {
+                    instanceEvent.InstanceId = $"{instanceOwnerPartyId}/{instanceGuid}";
+                }
+
+                instanceEvent.Created = instanceEvent.Created?.ToUniversalTime() ?? DateTime.UtcNow;
+            }
+
             ProcessState processState = processStateUpdate.State;
 
             var (action, taskId) = ActionMapping(processState, existingInstance);

diff --git a/src/Storage/Repository/ServiceCollectionExtensions.cs b/src/Storage/Repository/ServiceCollectionExtensions.cs
@@ -22,6 +22,7 @@ public static IServiceCollection AddRepositoriesPostgreSQL(this IServiceCollecti
             .AddSingleton<IDataRepository, PgDataRepository>()
             .AddSingleton<IInstanceEventRepository, PgInstanceEventRepository>()
             .AddSingleton<IInstanceRepository, PgInstanceRepository>()
+            .AddSingleton<IInstanceAndEventsRepository, PgInstanceAndEventsRepository>()
             .AddSingleton<IBlobRepository, BlobRepository>()
             .AddSingleton<IA2Repository, PgA2Repository>()
             .AddNpgsqlDataSource(connectionString, builder => builder.EnableParameterLogging(logParameters).EnableDynamicJson());