From c8bb256e8642404aa8053d19ee51ab7e86a1bdf8 Mon Sep 17 00:00:00 2001 From: Sebastian Stehle Date: Mon, 17 Jul 2017 19:16:48 +0200 Subject: [PATCH] Minor performance fix --- .../MongoContentRepository_EventHandling.cs | 32 +++++++++---------- 1 file changed, 16 insertions(+), 16 deletions(-) diff --git a/src/Squidex.Domain.Apps.Read.MongoDb/Contents/MongoContentRepository_EventHandling.cs b/src/Squidex.Domain.Apps.Read.MongoDb/Contents/MongoContentRepository_EventHandling.cs index f568d756b..7cdd4a0b5 100644 --- a/src/Squidex.Domain.Apps.Read.MongoDb/Contents/MongoContentRepository_EventHandling.cs +++ b/src/Squidex.Domain.Apps.Read.MongoDb/Contents/MongoContentRepository_EventHandling.cs @@ -9,9 +9,9 @@ using System; using System.Threading.Tasks; using MongoDB.Driver; +using Squidex.Domain.Apps.Events.Apps; using Squidex.Domain.Apps.Events.Assets; using Squidex.Domain.Apps.Events.Contents; -using Squidex.Domain.Apps.Events.Schemas; using Squidex.Domain.Apps.Read.MongoDb.Utils; using Squidex.Infrastructure.CQRS.Events; using Squidex.Infrastructure.Dispatching; @@ -31,7 +31,7 @@ namespace Squidex.Domain.Apps.Read.MongoDb.Contents public string EventsFilter { - get { return "^(content-)|(schema-)|(asset-)"; } + get { return "^(content-)|(app-)|(asset-)"; } } public async Task ClearAsync() @@ -58,7 +58,7 @@ namespace Squidex.Domain.Apps.Read.MongoDb.Contents return this.DispatchActionAsync(@event.Payload, @event.Headers); } - protected Task On(SchemaCreated @event, EnvelopeHeaders headers) + protected Task On(AppCreated @event, EnvelopeHeaders headers) { return ForAppIdAsync(@event.AppId.Id, async collection => { @@ -116,18 +116,6 @@ namespace Squidex.Domain.Apps.Read.MongoDb.Contents }); } - protected Task On(AssetDeleted @event, EnvelopeHeaders headers) - { - return ForAppIdAsync(@event.AppId.Id, collection => - { - return collection.UpdateManyAsync( - Filter.And( - Filter.AnyEq(x => x.ReferencedIds, @event.AssetId), - Filter.AnyNe(x => x.ReferencedIdsDeleted, @event.AssetId)), - Update.AddToSet(x => x.ReferencedIdsDeleted, @event.AssetId)); - }); - } - protected Task On(ContentDeleted @event, EnvelopeHeaders headers) { return ForAppIdAsync(@event.AppId.Id, async collection => @@ -141,7 +129,19 @@ namespace Squidex.Domain.Apps.Read.MongoDb.Contents await collection.DeleteOneAsync(x => x.Id == headers.AggregateId()); }); } - + + protected Task On(AssetDeleted @event, EnvelopeHeaders headers) + { + return ForAppIdAsync(@event.AppId.Id, collection => + { + return collection.UpdateManyAsync( + Filter.And( + Filter.AnyEq(x => x.ReferencedIds, @event.AssetId), + Filter.AnyNe(x => x.ReferencedIdsDeleted, @event.AssetId)), + Update.AddToSet(x => x.ReferencedIdsDeleted, @event.AssetId)); + }); + } + private Task ForAppIdAsync(Guid appId, Func, Task> action) { var collection = GetCollection(appId);