From 2cd7d517e8dc6f83cf7acf95c6ee35a40ed3cf2c Mon Sep 17 00:00:00 2001
From: Sebastian Stehle <sebastian@squidex.io>
Date: Mon, 25 Feb 2019 12:30:36 +0100
Subject: [PATCH] Filter for property.

---
 .../EventSourcing/CosmosDbEventCommit.cs                        | 1 -
 .../EventSourcing/CosmosDbEventStore.cs                         | 1 -
 src/Squidex.Infrastructure.Azure/EventSourcing/FilterBuilder.cs | 2 +-
 3 files changed, 1 insertion(+), 3 deletions(-)

diff --git a/src/Squidex.Infrastructure.Azure/EventSourcing/CosmosDbEventCommit.cs b/src/Squidex.Infrastructure.Azure/EventSourcing/CosmosDbEventCommit.cs
index 761123f68..7e104f2c9 100644
--- a/src/Squidex.Infrastructure.Azure/EventSourcing/CosmosDbEventCommit.cs
+++ b/src/Squidex.Infrastructure.Azure/EventSourcing/CosmosDbEventCommit.cs
@@ -7,7 +7,6 @@
 
 using System;
 using Newtonsoft.Json;
-using NodaTime;
 
 namespace Squidex.Infrastructure.EventSourcing
 {
diff --git a/src/Squidex.Infrastructure.Azure/EventSourcing/CosmosDbEventStore.cs b/src/Squidex.Infrastructure.Azure/EventSourcing/CosmosDbEventStore.cs
index 0adcadc73..d25052b78 100644
--- a/src/Squidex.Infrastructure.Azure/EventSourcing/CosmosDbEventStore.cs
+++ b/src/Squidex.Infrastructure.Azure/EventSourcing/CosmosDbEventStore.cs
@@ -11,7 +11,6 @@ using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.Azure.Documents;
 using Microsoft.Azure.Documents.Client;
-using Newtonsoft.Json;
 
 namespace Squidex.Infrastructure.EventSourcing
 {
diff --git a/src/Squidex.Infrastructure.Azure/EventSourcing/FilterBuilder.cs b/src/Squidex.Infrastructure.Azure/EventSourcing/FilterBuilder.cs
index 98eed6335..0de29581f 100644
--- a/src/Squidex.Infrastructure.Azure/EventSourcing/FilterBuilder.cs
+++ b/src/Squidex.Infrastructure.Azure/EventSourcing/FilterBuilder.cs
@@ -92,7 +92,7 @@ namespace Squidex.Infrastructure.EventSourcing
 
         private static void ForProperty(this List<string> filters, SqlParameterCollection parameters, string property, object value)
         {
-            filters.Add($"e.events.headers.{property} = @value");
+            filters.Add($"ARRAY_CONTAINS(e.events, {{ \"headers\": {{ \"{property}\": @value }} }}, true)");
 
             parameters.Add(new SqlParameter("@value", value));
         }