diff --git a/src/Squidex.Domain.Apps.Read.MongoDb/History/MongoHistoryEventRepository.cs b/src/Squidex.Domain.Apps.Read.MongoDb/History/MongoHistoryEventRepository.cs index 53368fd51..6b0464bc3 100644 --- a/src/Squidex.Domain.Apps.Read.MongoDb/History/MongoHistoryEventRepository.cs +++ b/src/Squidex.Domain.Apps.Read.MongoDb/History/MongoHistoryEventRepository.cs @@ -83,10 +83,14 @@ namespace Squidex.Domain.Apps.Read.MongoDb.History if (message != null) { - await Collection.CreateAsync((SquidexEvent)@event.Payload, @event.Headers, entity => + var appEvent = (AppEvent)@event.Payload; + + await Collection.CreateAsync(appEvent, @event.Headers, entity => { entity.Id = Guid.NewGuid(); + entity.AppId = appEvent.AppId.Id; + entity.Version = @event.Headers.EventStreamNumber(); entity.Channel = message.Channel; diff --git a/src/Squidex.Domain.Apps.Read/Contents/ContentHistoryEventsCreator.cs b/src/Squidex.Domain.Apps.Read/Contents/ContentHistoryEventsCreator.cs index 6ffea3aea..866917d8b 100644 --- a/src/Squidex.Domain.Apps.Read/Contents/ContentHistoryEventsCreator.cs +++ b/src/Squidex.Domain.Apps.Read/Contents/ContentHistoryEventsCreator.cs @@ -29,14 +29,21 @@ namespace Squidex.Domain.Apps.Read.Contents "deleted content item."); AddEventMessage( - "change status of content item to {[Status]}."); + "changed status of content item to {[Status]}."); } protected override Task CreateEventCoreAsync(Envelope @event) { var channel = $"contents.{@event.Headers.AggregateId()}"; - return Task.FromResult(ForEvent(@event.Payload, channel)); + var result = ForEvent(@event.Payload, channel); + + if (@event.Payload is ContentStatusChanged contentStatusChanged) + { + result = result.AddParameter("Status", contentStatusChanged.Status); + } + + return Task.FromResult(result); } } }