Register IInstanceAndEventsRepository

src/Storage/Controllers/ProcessController.cs

@@ -25,7 +25,7 @@
     /// </summary>
     [Route("storage/api/v1/instances/{instanceOwnerPartyId:int}/{instanceGuid:guid}/process")]
     [ApiController]
     public class ProcessController : ControllerBase
     {
         private readonly IInstanceRepository _instanceRepository;
         private readonly IInstanceEventRepository _instanceEventRepository;
@@ -132,6 +132,15 @@
                 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);
@@ -234,7 +243,7 @@
             existingInstance.LastChanged = DateTime.UtcNow;
         }
 
         private (string Action, string TaskId) ActionMapping(ProcessState processState, Instance existingInstance)
         {
             string taskId = null;
             string altinnTaskType = existingInstance.Process?.CurrentTask?.AltinnTaskType;

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());