Browse Source

Filter for property.

pull/349/head
Sebastian Stehle 7 years ago
parent
commit
2cd7d517e8
  1. 1
      src/Squidex.Infrastructure.Azure/EventSourcing/CosmosDbEventCommit.cs
  2. 1
      src/Squidex.Infrastructure.Azure/EventSourcing/CosmosDbEventStore.cs
  3. 2
      src/Squidex.Infrastructure.Azure/EventSourcing/FilterBuilder.cs

1
src/Squidex.Infrastructure.Azure/EventSourcing/CosmosDbEventCommit.cs

@ -7,7 +7,6 @@
using System;
using Newtonsoft.Json;
using NodaTime;
namespace Squidex.Infrastructure.EventSourcing
{

1
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
{

2
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));
}

Loading…
Cancel
Save