mirror of https://github.com/Squidex/squidex.git
Sebastian Stehle
4 years ago
committed by
GitHub
GitHub
28 changed files with 657 additions and 391 deletions
@ -0,0 +1,23 @@ |
|||||
|
// ==========================================================================
|
||||
|
// Squidex Headless CMS
|
||||
|
// ==========================================================================
|
||||
|
// Copyright (c) Squidex UG (haftungsbeschraenkt)
|
||||
|
// All rights reserved. Licensed under the MIT license.
|
||||
|
// ==========================================================================
|
||||
|
|
||||
|
using Xunit; |
||||
|
|
||||
|
#pragma warning disable SA1300 // Element should begin with upper-case letter
|
||||
|
#pragma warning disable MA0048 // File name must match type name
|
||||
|
|
||||
|
namespace Squidex.Domain.Apps.Entities.Contents.MongoDb |
||||
|
{ |
||||
|
[Trait("Category", "Dependencies")] |
||||
|
public class ContentsQueryDedicatedIntegrationTests : ContentsQueryTestsBase, IClassFixture<ContentsQueryDedicatedFixture> |
||||
|
{ |
||||
|
public ContentsQueryDedicatedIntegrationTests(ContentsQueryDedicatedFixture fixture) |
||||
|
: base(fixture) |
||||
|
{ |
||||
|
} |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,235 @@ |
|||||
|
// ==========================================================================
|
||||
|
// Squidex Headless CMS
|
||||
|
// ==========================================================================
|
||||
|
// Copyright (c) Squidex UG (haftungsbeschraenkt)
|
||||
|
// All rights reserved. Licensed under the MIT license.
|
||||
|
// ==========================================================================
|
||||
|
|
||||
|
using NodaTime; |
||||
|
using Squidex.Domain.Apps.Entities.Contents.Repositories; |
||||
|
using Squidex.Domain.Apps.Entities.Schemas; |
||||
|
using Squidex.Infrastructure; |
||||
|
using Squidex.Infrastructure.Queries; |
||||
|
using Xunit; |
||||
|
using F = Squidex.Infrastructure.Queries.ClrFilter; |
||||
|
|
||||
|
#pragma warning disable SA1300 // Element should begin with upper-case letter
|
||||
|
#pragma warning disable MA0048 // File name must match type name
|
||||
|
|
||||
|
namespace Squidex.Domain.Apps.Entities.Contents.MongoDb |
||||
|
{ |
||||
|
public abstract class ContentsQueryTestsBase |
||||
|
{ |
||||
|
public ContentsQueryFixtureBase _ { get; } |
||||
|
|
||||
|
protected ContentsQueryTestsBase(ContentsQueryFixtureBase fixture) |
||||
|
{ |
||||
|
_ = fixture; |
||||
|
} |
||||
|
|
||||
|
[Fact] |
||||
|
public async Task Should_verify_ids() |
||||
|
{ |
||||
|
var ids = Enumerable.Repeat(0, 50).Select(_ => DomainId.NewGuid()).ToHashSet(); |
||||
|
|
||||
|
var contents = await _.ContentRepository.QueryIdsAsync(_.RandomAppId(), ids, SearchScope.Published); |
||||
|
|
||||
|
// The IDs are random here, as it does not really matter.
|
||||
|
Assert.NotNull(contents); |
||||
|
} |
||||
|
|
||||
|
[Fact] |
||||
|
public async Task Should_query_contents_by_ids() |
||||
|
{ |
||||
|
var ids = Enumerable.Repeat(0, 50).Select(_ => DomainId.NewGuid()).ToHashSet(); |
||||
|
|
||||
|
var schemas = new List<ISchemaEntity> |
||||
|
{ |
||||
|
_.RandomSchema() |
||||
|
}; |
||||
|
|
||||
|
var contents = await _.ContentRepository.QueryAsync(_.RandomApp(), schemas, Q.Empty.WithIds(ids), SearchScope.All); |
||||
|
|
||||
|
// The IDs are random here, as it does not really matter.
|
||||
|
Assert.NotNull(contents); |
||||
|
} |
||||
|
|
||||
|
[Fact] |
||||
|
public async Task Should_query_contents_by_ids_and_schema() |
||||
|
{ |
||||
|
var ids = Enumerable.Repeat(0, 50).Select(_ => DomainId.NewGuid()).ToHashSet(); |
||||
|
|
||||
|
var contents = await _.ContentRepository.QueryAsync(_.RandomApp(), _.RandomSchema(), Q.Empty.WithIds(ids), SearchScope.All); |
||||
|
|
||||
|
// The IDs are random here, as it does not really matter.
|
||||
|
Assert.NotNull(contents); |
||||
|
} |
||||
|
|
||||
|
[Fact] |
||||
|
public async Task Should_query_contents_ids_by_filter() |
||||
|
{ |
||||
|
var filter = F.Eq("data.field1.iv", 12); |
||||
|
|
||||
|
var contents = await _.ContentRepository.QueryIdsAsync(_.RandomAppId(), _.RandomSchemaId(), filter); |
||||
|
|
||||
|
// We have a concrete query, so we expect an actual.
|
||||
|
Assert.NotEmpty(contents); |
||||
|
} |
||||
|
|
||||
|
[Fact] |
||||
|
public async Task Should_query_contents_by_filter() |
||||
|
{ |
||||
|
var query = new ClrQuery |
||||
|
{ |
||||
|
Filter = F.Eq("data.field1.iv", 12) |
||||
|
}; |
||||
|
|
||||
|
var contents = await QueryAsync(_.ContentRepository, query, 1000, 0); |
||||
|
|
||||
|
// We have a concrete query, so we expect an actual.
|
||||
|
Assert.NotEmpty(contents); |
||||
|
} |
||||
|
|
||||
|
[Fact] |
||||
|
public async Task Should_query_contents_scheduled() |
||||
|
{ |
||||
|
var time = SystemClock.Instance.GetCurrentInstant(); |
||||
|
|
||||
|
var contents = await _.ContentRepository.QueryScheduledWithoutDataAsync(time).ToListAsync(); |
||||
|
|
||||
|
// The IDs are random here, as it does not really matter.
|
||||
|
Assert.NotNull(contents); |
||||
|
} |
||||
|
|
||||
|
[Fact] |
||||
|
public async Task Should_query_contents_with_default_query() |
||||
|
{ |
||||
|
var query = new ClrQuery(); |
||||
|
|
||||
|
var contents = await QueryAsync(_.ContentRepository, query); |
||||
|
|
||||
|
// We have a concrete query, so we expect an actual result.
|
||||
|
Assert.NotEmpty(contents); |
||||
|
} |
||||
|
|
||||
|
[Fact] |
||||
|
public async Task Should_query_contents_with_default_query_and_id() |
||||
|
{ |
||||
|
var query = new ClrQuery(); |
||||
|
|
||||
|
var contents = await QueryAsync(_.ContentRepository, query, reference: DomainId.NewGuid()); |
||||
|
|
||||
|
// The IDs are random here, as it does not really matter.
|
||||
|
Assert.NotNull(contents); |
||||
|
} |
||||
|
|
||||
|
[Fact] |
||||
|
public async Task Should_query_contents_with_large_skip() |
||||
|
{ |
||||
|
var query = new ClrQuery |
||||
|
{ |
||||
|
Sort = new List<SortNode> |
||||
|
{ |
||||
|
new SortNode("data.value.iv", SortOrder.Ascending) |
||||
|
} |
||||
|
}; |
||||
|
|
||||
|
var contents = await QueryAsync(_.ContentRepository, query, 1000, 9000); |
||||
|
|
||||
|
// We have a concrete query, so we expect an actual result.
|
||||
|
Assert.NotEmpty(contents); |
||||
|
} |
||||
|
|
||||
|
[Fact] |
||||
|
public async Task Should_query_contents_with_query_fulltext() |
||||
|
{ |
||||
|
var query = new ClrQuery |
||||
|
{ |
||||
|
FullText = "hello" |
||||
|
}; |
||||
|
|
||||
|
var contents = await QueryAsync(_.ContentRepository, query); |
||||
|
|
||||
|
// The full text is resolved by another system, so we cannot verify the actual result.
|
||||
|
Assert.NotNull(contents); |
||||
|
} |
||||
|
|
||||
|
[Fact] |
||||
|
public async Task Should_query_contents_with_query_filter() |
||||
|
{ |
||||
|
var query = new ClrQuery |
||||
|
{ |
||||
|
Filter = F.Eq("data.field1.iv", 200) |
||||
|
}; |
||||
|
|
||||
|
var contents = await QueryAsync(_.ContentRepository, query, 1000, 0); |
||||
|
|
||||
|
// We have a concrete query, so we expect an actual result.
|
||||
|
Assert.NotEmpty(contents); |
||||
|
} |
||||
|
|
||||
|
[Fact] |
||||
|
public async Task Should_query_contents_with_query_filter_and_id() |
||||
|
{ |
||||
|
var query = new ClrQuery |
||||
|
{ |
||||
|
Filter = F.Eq("data.value.iv", 12) |
||||
|
}; |
||||
|
|
||||
|
var contents = await QueryAsync(_.ContentRepository, query, 1000, 0, reference: DomainId.NewGuid()); |
||||
|
|
||||
|
// We do not insert test entities with references, so we cannot verify the actual result.
|
||||
|
Assert.Empty(contents); |
||||
|
} |
||||
|
|
||||
|
[Fact] |
||||
|
public async Task Should_query_contents_with_random_count() |
||||
|
{ |
||||
|
var query = new ClrQuery |
||||
|
{ |
||||
|
Random = 40 |
||||
|
}; |
||||
|
|
||||
|
var contents = await QueryAsync(_.ContentRepository, query); |
||||
|
|
||||
|
// We do not insert test entities with references, so we cannot verify the actual.
|
||||
|
Assert.Equal(40, contents.Count); |
||||
|
} |
||||
|
|
||||
|
private async Task<IResultList<IContentEntity>> QueryAsync(IContentRepository contentRepository, |
||||
|
ClrQuery clrQuery, |
||||
|
int take = 1000, |
||||
|
int skip = 100, |
||||
|
DomainId reference = default) |
||||
|
{ |
||||
|
if (clrQuery.Take == long.MaxValue) |
||||
|
{ |
||||
|
clrQuery.Take = take; |
||||
|
} |
||||
|
|
||||
|
if (clrQuery.Skip == 0) |
||||
|
{ |
||||
|
clrQuery.Skip = skip; |
||||
|
} |
||||
|
|
||||
|
if (clrQuery.Sort == null || clrQuery.Sort.Count == 0) |
||||
|
{ |
||||
|
clrQuery.Sort = new List<SortNode> |
||||
|
{ |
||||
|
new SortNode("LastModified", SortOrder.Descending), |
||||
|
new SortNode("Id", SortOrder.Ascending) |
||||
|
}; |
||||
|
} |
||||
|
|
||||
|
var q = |
||||
|
Q.Empty |
||||
|
.WithoutTotal() |
||||
|
.WithQuery(clrQuery) |
||||
|
.WithReference(reference); |
||||
|
|
||||
|
var contents = await contentRepository.QueryAsync(_.RandomApp(), _.RandomSchema(), q, SearchScope.All); |
||||
|
|
||||
|
return contents; |
||||
|
} |
||||
|
} |
||||
|
} |
||||
Loading…
Reference in new issue