UltimateCoder/mongodb-generic-repository
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

tests for getMaxVValue and GetMinValue

Browse Source
This commit is contained in:
Sean Garrett
2023-06-25 22:27:40 +01:00
parent f7ba046f20
commit 240b61d1d2
5 changed files with 456 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
CoreUnitTests/DataAccessTests/MongoDbReaderTests/GetMaxValueAsyncTests .cs
+114
View File
@@ -0,0 +1,114 @@
using System;
using System.Collections.Generic;
using System.Linq.Expressions;
using System.Threading;
using System.Threading.Tasks;
using AutoFixture;
using CoreUnitTests.Infrastructure.Model;
using FluentAssertions;
using MongoDB.Driver;
using MongoDbGenericRepository;
using Moq;
using Xunit;
namespace CoreUnitTests.DataAccessTests.MongoDbReaderTests;
public class GetMaxValueAsyncTests : BaseReaderTests
{
private readonly Expression<Func<TestDocument, bool>> filter = x => x.SomeContent == "SomeContent";
private readonly Expression<Func<TestDocument, int>> selector = x => x.SomeValue;
[Fact]
public async Task WithFilterAndSelector_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var (context, cursor) = SetupAsyncGet(value, collection);
// Act
var result = await Sut.GetMaxValueAsync<TestDocument, Guid, int>(filter, selector);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(null), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNextAsync(CancellationToken.None), Times.Once);
result.Should().Be(value);
}
[Fact]
public async Task WithFilterAndSelectorAndCancellationToken_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var token = new CancellationToken(true);
var (context, cursor) = SetupAsyncGet(value, collection);
// Act
var result = await Sut.GetMaxValueAsync<TestDocument, Guid, int>(filter, selector, cancellationToken: token);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(null), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNextAsync(token), Times.Once);
result.Should().Be(value);
}
[Fact]
public async Task WithFilterAndSelectorAndPartitionKey_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var partitionKey = Fixture.Create<string>();
var (context, cursor) = SetupAsyncGet(value, collection, partitionKey);
// Act
var result = await Sut.GetMaxValueAsync<TestDocument, Guid, int>(filter, selector, partitionKey);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(partitionKey), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNextAsync(CancellationToken.None), Times.Once);
result.Should().Be(value);
}
[Fact]
public async Task WithFilterAndSelectorAndPartitionKeyAndCancellationToken_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var partitionKey = Fixture.Create<string>();
var token = new CancellationToken(true);
var (context, cursor) = SetupAsyncGet(value, collection, partitionKey);
// Act
var result = await Sut.GetMaxValueAsync<TestDocument, Guid, int>(filter, selector, partitionKey, token);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(partitionKey), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNextAsync(token), Times.Once);
result.Should().Be(value);
}
private (Mock<IMongoDbContext>, Mock<IAsyncCursor<TValue>>) SetupAsyncGet<TDocument, TValue>(
TValue result,
Mock<IMongoCollection<TDocument>> collection,
string partitionKey = null)
{
var asyncCursor = SetupAsyncCursor(new List<TValue> {result});
SetupFindAsync(collection, asyncCursor);
var context = MockOf<IMongoDbContext>();
context
.Setup(x => x.GetCollection<TDocument>(partitionKey))
.Returns(collection.Object);
return (context, asyncCursor);
}
}
CoreUnitTests/DataAccessTests/MongoDbReaderTests/GetMaxValueTests .cs
+114
View File
@@ -0,0 +1,114 @@
using System;
using System.Collections.Generic;
using System.Linq.Expressions;
using System.Threading;
using System.Threading.Tasks;
using AutoFixture;
using CoreUnitTests.Infrastructure.Model;
using FluentAssertions;
using MongoDB.Driver;
using MongoDbGenericRepository;
using Moq;
using Xunit;
namespace CoreUnitTests.DataAccessTests.MongoDbReaderTests;
public class GetMaxValueTests : BaseReaderTests
{
private readonly Expression<Func<TestDocument, bool>> filter = x => x.SomeContent == "SomeContent";
private readonly Expression<Func<TestDocument, int>> selector = x => x.SomeValue;
[Fact]
public void WithFilterAndSelector_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var (context, cursor) = SetupSyncGet(value, collection);
// Act
var result = Sut.GetMaxValue<TestDocument, Guid, int>(filter, selector);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(null), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNext(CancellationToken.None), Times.Once);
result.Should().Be(value);
}
[Fact]
public void WithFilterAndSelectorAndCancellationToken_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var token = new CancellationToken(true);
var (context, cursor) = SetupSyncGet(value, collection);
// Act
var result = Sut.GetMaxValue<TestDocument, Guid, int>(filter, selector, cancellationToken: token);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(null), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNext(token), Times.Once);
result.Should().Be(value);
}
[Fact]
public void WithFilterAndSelectorAndPartitionKey_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var partitionKey = Fixture.Create<string>();
var (context, cursor) = SetupSyncGet(value, collection, partitionKey);
// Act
var result = Sut.GetMaxValue<TestDocument, Guid, int>(filter, selector, partitionKey);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(partitionKey), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNext(CancellationToken.None), Times.Once);
result.Should().Be(value);
}
[Fact]
public void WithFilterAndSelectorAndPartitionKeyAndCancellationToken_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var partitionKey = Fixture.Create<string>();
var token = new CancellationToken(true);
var (context, cursor) = SetupSyncGet(value, collection, partitionKey);
// Act
var result = Sut.GetMaxValue<TestDocument, Guid, int>(filter, selector, partitionKey, token);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(partitionKey), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNext(token), Times.Once);
result.Should().Be(value);
}
private (Mock<IMongoDbContext>, Mock<IAsyncCursor<TValue>>) SetupSyncGet<TDocument, TValue>(
TValue result,
Mock<IMongoCollection<TDocument>> collection,
string partitionKey = null)
{
var asyncCursor = SetupSyncCursor(new List<TValue> {result});
SetupFindSync(collection, asyncCursor);
var context = MockOf<IMongoDbContext>();
context
.Setup(x => x.GetCollection<TDocument>(partitionKey))
.Returns(collection.Object);
return (context, asyncCursor);
}
}
CoreUnitTests/DataAccessTests/MongoDbReaderTests/GetMinValueAsyncTests .cs
+114
View File
@@ -0,0 +1,114 @@
using System;
using System.Collections.Generic;
using System.Linq.Expressions;
using System.Threading;
using System.Threading.Tasks;
using AutoFixture;
using CoreUnitTests.Infrastructure.Model;
using FluentAssertions;
using MongoDB.Driver;
using MongoDbGenericRepository;
using Moq;
using Xunit;
namespace CoreUnitTests.DataAccessTests.MongoDbReaderTests;
public class GetMinValueAsyncTests : BaseReaderTests
{
private readonly Expression<Func<TestDocument, bool>> filter = x => x.SomeContent == "SomeContent";
private readonly Expression<Func<TestDocument, int>> selector = x => x.SomeValue;
[Fact]
public async Task WithFilterAndSelector_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var (context, cursor) = SetupAsyncGet(value, collection);
// Act
var result = await Sut.GetMinValueAsync<TestDocument, Guid, int>(filter, selector);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(null), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNextAsync(CancellationToken.None), Times.Once);
result.Should().Be(value);
}
[Fact]
public async Task WithFilterAndSelectorAndCancellationToken_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var token = new CancellationToken(true);
var (context, cursor) = SetupAsyncGet(value, collection);
// Act
var result = await Sut.GetMinValueAsync<TestDocument, Guid, int>(filter, selector, cancellationToken: token);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(null), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNextAsync(token), Times.Once);
result.Should().Be(value);
}
[Fact]
public async Task WithFilterAndSelectorAndPartitionKey_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var partitionKey = Fixture.Create<string>();
var (context, cursor) = SetupAsyncGet(value, collection, partitionKey);
// Act
var result = await Sut.GetMinValueAsync<TestDocument, Guid, int>(filter, selector, partitionKey);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(partitionKey), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNextAsync(CancellationToken.None), Times.Once);
result.Should().Be(value);
}
[Fact]
public async Task WithFilterAndSelectorAndPartitionKeyAndCancellationToken_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var partitionKey = Fixture.Create<string>();
var token = new CancellationToken(true);
var (context, cursor) = SetupAsyncGet(value, collection, partitionKey);
// Act
var result = await Sut.GetMinValueAsync<TestDocument, Guid, int>(filter, selector, partitionKey, token);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(partitionKey), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNextAsync(token), Times.Once);
result.Should().Be(value);
}
private (Mock<IMongoDbContext>, Mock<IAsyncCursor<TValue>>) SetupAsyncGet<TDocument, TValue>(
TValue result,
Mock<IMongoCollection<TDocument>> collection,
string partitionKey = null)
{
var asyncCursor = SetupAsyncCursor(new List<TValue> {result});
SetupFindAsync(collection, asyncCursor);
var context = MockOf<IMongoDbContext>();
context
.Setup(x => x.GetCollection<TDocument>(partitionKey))
.Returns(collection.Object);
return (context, asyncCursor);
}
}
CoreUnitTests/DataAccessTests/MongoDbReaderTests/GetMinValueTests .cs
+114
View File
@@ -0,0 +1,114 @@
using System;
using System.Collections.Generic;
using System.Linq.Expressions;
using System.Threading;
using System.Threading.Tasks;
using AutoFixture;
using CoreUnitTests.Infrastructure.Model;
using FluentAssertions;
using MongoDB.Driver;
using MongoDbGenericRepository;
using Moq;
using Xunit;
namespace CoreUnitTests.DataAccessTests.MongoDbReaderTests;
public class GetMinValueTests : BaseReaderTests
{
private readonly Expression<Func<TestDocument, bool>> filter = x => x.SomeContent == "SomeContent";
private readonly Expression<Func<TestDocument, int>> selector = x => x.SomeValue;
[Fact]
public void WithFilterAndSelector_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var (context, cursor) = SetupSyncGet(value, collection);
// Act
var result = Sut.GetMinValue<TestDocument, Guid, int>(filter, selector);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(null), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNext(CancellationToken.None), Times.Once);
result.Should().Be(value);
}
[Fact]
public void WithFilterAndSelectorAndCancellationToken_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var token = new CancellationToken(true);
var (context, cursor) = SetupSyncGet(value, collection);
// Act
var result = Sut.GetMinValue<TestDocument, Guid, int>(filter, selector, cancellationToken: token);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(null), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNext(token), Times.Once);
result.Should().Be(value);
}
[Fact]
public void WithFilterAndSelectorAndPartitionKey_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var partitionKey = Fixture.Create<string>();
var (context, cursor) = SetupSyncGet(value, collection, partitionKey);
// Act
var result = Sut.GetMinValue<TestDocument, Guid, int>(filter, selector, partitionKey);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(partitionKey), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNext(CancellationToken.None), Times.Once);
result.Should().Be(value);
}
[Fact]
public void WithFilterAndSelectorAndPartitionKeyAndCancellationToken_GetsMatchingDocument()
{
// Arrange
var value = Fixture.Create<int>();
var collection = MockOf<IMongoCollection<TestDocument>>();
var partitionKey = Fixture.Create<string>();
var token = new CancellationToken(true);
var (context, cursor) = SetupSyncGet(value, collection, partitionKey);
// Act
var result = Sut.GetMinValue<TestDocument, Guid, int>(filter, selector, partitionKey, token);
// Assert
context.Verify(x => x.GetCollection<TestDocument>(partitionKey), Times.Once);
cursor.Verify(x => x.Current, Times.Once);
cursor.Verify(x => x.MoveNext(token), Times.Once);
result.Should().Be(value);
}
private (Mock<IMongoDbContext>, Mock<IAsyncCursor<TValue>>) SetupSyncGet<TDocument, TValue>(
TValue result,
Mock<IMongoCollection<TDocument>> collection,
string partitionKey = null)
{
var asyncCursor = SetupSyncCursor(new List<TValue> {result});
SetupFindSync(collection, asyncCursor);
var context = MockOf<IMongoDbContext>();
context
.Setup(x => x.GetCollection<TDocument>(partitionKey))
.Returns(collection.Object);
return (context, asyncCursor);
}
}
MongoDbGenericRepository/DataAccess/Base/DataAccessBase.cs
-1
View File
@@ -168,7 +168,6 @@ namespace MongoDbGenericRepository.DataAccess.Base
.Limit(1);
}
#endregion
}
}