Browse Source

Closes #187

pull/194/head
Sebastian Stehle 9 years ago
parent
commit
21e3572dbc
  1. 6
      src/Squidex.Domain.Apps.Read.MongoDb/History/MongoHistoryEventRepository.cs
  2. 11
      src/Squidex.Domain.Apps.Read/Contents/ContentHistoryEventsCreator.cs

6
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;

11
src/Squidex.Domain.Apps.Read/Contents/ContentHistoryEventsCreator.cs

@ -29,14 +29,21 @@ namespace Squidex.Domain.Apps.Read.Contents
"deleted content item.");
AddEventMessage<ContentStatusChanged>(
"change status of content item to {[Status]}.");
"changed status of content item to {[Status]}.");
}
protected override Task<HistoryEventToStore> CreateEventCoreAsync(Envelope<IEvent> @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);
}
}
}

Loading…
Cancel
Save