Closes #121

src/Squidex.Domain.Apps.Read.MongoDb/Webhooks/MongoWebhookRepository.cs

@@ -8,6 +8,7 @@
 
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 using MongoDB.Bson;
@@ -44,6 +45,13 @@ namespace Squidex.Domain.Apps.Read.MongoDb.Webhooks
         }
 
         public async Task<IReadOnlyList<IWebhookEntity>> QueryByAppAsync(Guid appId)
+        {
+            var entities = await Collection.Find(x => x.AppId == appId).ToListAsync();
+
+            return entities.OfType<IWebhookEntity>().ToList();
+        }
+
+        public async Task<IReadOnlyList<IWebhookEntity>> QueryCachedByAppAsync(Guid appId)
         {
             await EnsureWebooksLoadedAsync();
 

src/Squidex.Domain.Apps.Read/Webhooks/Repositories/IWebhookRepository.cs

@@ -17,5 +17,7 @@ namespace Squidex.Domain.Apps.Read.Webhooks.Repositories
         Task TraceSentAsync(Guid webhookId, WebhookResult result, TimeSpan elapsed);
 
         Task<IReadOnlyList<IWebhookEntity>> QueryByAppAsync(Guid appId);
+
+        Task<IReadOnlyList<IWebhookEntity>> QueryCachedByAppAsync(Guid appId);
     }
 }

src/Squidex.Domain.Apps.Read/Webhooks/WebhookEnqueuer.cs

@@ -75,7 +75,7 @@ namespace Squidex.Domain.Apps.Read.Webhooks
             {
                 var eventType = typeNameRegistry.GetName(@event.Payload.GetType());
 
-                var webhooks = await webhookRepository.QueryByAppAsync(contentEvent.AppId.Id);
+                var webhooks = await webhookRepository.QueryCachedByAppAsync(contentEvent.AppId.Id);
 
                 var matchingWebhooks = webhooks.Where(w => w.Schemas.Any(s => Matchs(s, contentEvent))).ToList();
 

tests/Squidex.Domain.Apps.Read.Tests/Webhooks/WebhookEnqueuerTests.cs

@@ -71,7 +71,7 @@ namespace Squidex.Domain.Apps.Read.Webhooks
             var webhook1 = CreateWebhook(1);
             var webhook2 = CreateWebhook(2);
 
-            A.CallTo(() => webhookRepository.QueryByAppAsync(appId.Id))
+            A.CallTo(() => webhookRepository.QueryCachedByAppAsync(appId.Id))
                 .Returns(new List<IWebhookEntity> { webhook1, webhook2 });
 
             await sut.On(@event);