mirror of https://github.com/Squidex/squidex.git
12 changed files with 143 additions and 77 deletions
@ -0,0 +1,46 @@ |
|||||
|
// ==========================================================================
|
||||
|
// ContentHistoryEventsCreator.cs
|
||||
|
// Squidex Headless CMS
|
||||
|
// ==========================================================================
|
||||
|
// Copyright (c) Squidex Group
|
||||
|
// All rights reserved.
|
||||
|
// ==========================================================================
|
||||
|
|
||||
|
using System.Threading.Tasks; |
||||
|
using Squidex.Events.Contents; |
||||
|
using Squidex.Infrastructure; |
||||
|
using Squidex.Infrastructure.CQRS; |
||||
|
using Squidex.Infrastructure.CQRS.Events; |
||||
|
using Squidex.Read.History; |
||||
|
|
||||
|
namespace Squidex.Read.Contents |
||||
|
{ |
||||
|
public sealed class ContentHistoryEventsCreator : HistoryEventsCreatorBase |
||||
|
{ |
||||
|
public ContentHistoryEventsCreator(TypeNameRegistry typeNameRegistry) |
||||
|
: base(typeNameRegistry) |
||||
|
{ |
||||
|
AddEventMessage<ContentCreated>( |
||||
|
"created content element."); |
||||
|
|
||||
|
AddEventMessage<ContentUpdated>( |
||||
|
"updated content element."); |
||||
|
|
||||
|
AddEventMessage<ContentDeleted>( |
||||
|
"deleted content element."); |
||||
|
|
||||
|
AddEventMessage<ContentPublished>( |
||||
|
"published content element."); |
||||
|
|
||||
|
AddEventMessage<ContentUnpublished>( |
||||
|
"unpublished content element."); |
||||
|
} |
||||
|
|
||||
|
protected override Task<HistoryEventToStore> CreateEventCoreAsync(Envelope<IEvent> @event) |
||||
|
{ |
||||
|
var channel = $"contents.{@event.Headers.AggregateId()}"; |
||||
|
|
||||
|
return Task.FromResult(ForEvent(@event.Payload, channel)); |
||||
|
} |
||||
|
} |
||||
|
} |
||||
Loading…
Reference in new issue