Skip to content

read paged order list from MongoDB #48

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
PetkovskiM merged 2 commits into from
Aug 24, 2026
Merged

read paged order list from MongoDB #48

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
e397d5d
read paged order list from MongoDB
MilePrivate Aug 17, 2026
39c4c9e
align order query tests with read model
MilePrivate Aug 18, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
226 changes: 181 additions & 45 deletions OrderProcessing.Api.Tests/Infrastructure/TestOrderReadModelReader.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
using OrderProcessing.Api.Features.Orders.Queries.ReadModel;
using OrderProcessing.Api.DTOs.Orders;
using OrderProcessing.Api.Features.Orders.Queries.ReadModel;
using OrderProcessing.ReadModels.Orders;

namespace OrderProcessing.Api.Tests.Infrastructure;
Expand All @@ -9,53 +10,188 @@ public sealed class TestOrderReadModelReader : IOrderReadModelReader

public Task<OrderReadModel?> GetByIdAsync(int orderId, CancellationToken cancellationToken)
{
if (orderId != ExistingOrderId)
cancellationToken.ThrowIfCancellationRequested();

var order = CreateOrders().SingleOrDefault(order => order.OrderId == orderId);
return Task.FromResult(order);
}

public Task<OrderReadModelPage> GetPageAsync(OrderQueryParameters parameters, CancellationToken cancellationToken)
{
cancellationToken.ThrowIfCancellationRequested();

IEnumerable<OrderReadModel> query = CreateOrders();

query = ApplyFilters(query, parameters);

var totalCount = query.Count();

query = ApplySorting(query, parameters);

var orders = query
.Skip((parameters.Page - 1) * parameters.PageSize)
.Take(parameters.PageSize)
.ToList();

return Task.FromResult(
new OrderReadModelPage(orders, totalCount));
}

private static IEnumerable<OrderReadModel> ApplyFilters(IEnumerable<OrderReadModel> query, OrderQueryParameters parameters)
{
if (parameters.CustomerId.HasValue)
{
query = query.Where(order => order.CustomerId == parameters.CustomerId.Value);
}

if (parameters.Status.HasValue)
{
var status = parameters.Status.Value.ToString();

query = query.Where(order =>
string.Equals(
order.Status,
status,
StringComparison.OrdinalIgnoreCase));
}

if (parameters.CreatedFromUtc.HasValue)
{
query = query.Where(order => order.CreatedAtUtc >= parameters.CreatedFromUtc.Value);
}

if (parameters.CreatedToUtc.HasValue)
{
return Task.FromResult<OrderReadModel?>(null);
query = query.Where(order => order.CreatedAtUtc <= parameters.CreatedToUtc.Value);
}

return Task.FromResult<OrderReadModel?>(new OrderReadModel
return query;
}

private static IEnumerable<OrderReadModel> ApplySorting(IEnumerable<OrderReadModel> query, OrderQueryParameters parameters)
{
return (parameters.SortBy, parameters.SortDirection) switch
{
(OrderSortBy.Id, SortDirection.Ascending) =>
query.OrderBy(order => order.OrderId),

(OrderSortBy.Id, SortDirection.Descending) =>
query.OrderByDescending(order => order.OrderId),

(OrderSortBy.TotalAmount, SortDirection.Ascending) =>
query
.OrderBy(order => order.TotalAmount)
.ThenBy(order => order.OrderId),

(OrderSortBy.TotalAmount, SortDirection.Descending) =>
query
.OrderByDescending(order => order.TotalAmount)
.ThenByDescending(order => order.OrderId),

(OrderSortBy.CreatedAtUtc, SortDirection.Ascending) =>
query
.OrderBy(order => order.CreatedAtUtc)
.ThenBy(order => order.OrderId),

_ =>
query
.OrderByDescending(order => order.CreatedAtUtc)
.ThenByDescending(order => order.OrderId)
};
}

private static IReadOnlyList<OrderReadModel> CreateOrders()
{
return
[
CreateOrder(
orderId: ExistingOrderId,
customerId: TestDataSeeder.CustomerId,
customerName: "Integration Test Customer",
status: "Pending",
quantity: 1,
createdAtUtc: new DateTime(
2026,
8,
1,
10,
0,
0,
DateTimeKind.Utc)),

CreateOrder(
orderId: 88002,
customerId: TestDataSeeder.CustomerId,
customerName: "Integration Test Customer",
status: "Completed",
quantity: 2,
createdAtUtc: new DateTime(
2026,
8,
2,
10,
0,
0,
DateTimeKind.Utc),
completedAtUtc: new DateTime(
2026,
8,
2,
11,
0,
0,
DateTimeKind.Utc)),

CreateOrder(
orderId: 88003,
customerId: TestDataSeeder.SecondCustomerId,
customerName: "Second Integration Test Customer",
status: "Pending",
quantity: 3,
createdAtUtc: new DateTime(
2026,
8,
3,
10,
0,
0,
DateTimeKind.Utc))
];
}

private static OrderReadModel CreateOrder(
int orderId,
int customerId,
string customerName,
string status,
int quantity,
DateTime createdAtUtc,
DateTime? completedAtUtc = null)
{
const decimal unitPrice = 24.99m;

return new OrderReadModel
{
OrderId = orderId,
CustomerId = customerId,
CustomerName = customerName,
Status = status,
TotalAmount = unitPrice * quantity,
CreatedAtUtc = createdAtUtc,
CompletedAtUtc = completedAtUtc,
LastUpdatedAtUtc =
completedAtUtc ?? createdAtUtc,
Items =
[
new OrderItemReadModel
{
OrderId = ExistingOrderId,
CustomerId =
TestDataSeeder.CustomerId,
CustomerName =
"Integration Test Customer",
Status = "Pending",
TotalAmount = 24.99m,
CreatedAtUtc =
new DateTime(
2026,
8,
1,
10,
0,
0,
DateTimeKind.Utc),

LastUpdatedAtUtc =
new DateTime(
2026,
8,
1,
10,
0,
0,
DateTimeKind.Utc),

Items =
[
new OrderItemReadModel
{
ProductId =
TestDataSeeder.ProductId,
ProductName =
"Integration Test Product",
Quantity = 1,
UnitPrice = 24.99m,
LineTotal = 24.99m
}
]
});
ProductId = TestDataSeeder.ProductId,
ProductName = "Integration Test Product",
Quantity = quantity,
UnitPrice = unitPrice,
LineTotal = unitPrice * quantity
}
]
};
}
}
12 changes: 0 additions & 12 deletions OrderProcessing.Api.Tests/Integration/ApiIntegrationTests.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -69,11 +69,6 @@ public async Task CancelOrder_RestoresProductStock()
[Fact]
public async Task GetOrders_ReturnsPagedResponse()
{
// Arrange
await CreateTestOrderAsync();
await CreateTestOrderAsync();
await CreateTestOrderAsync();

// Act
var response = await Client.GetAsync(
"/api/orders?page=1&pageSize=2");
Expand All @@ -97,13 +92,6 @@ public async Task GetOrders_ReturnsPagedResponse()
[Fact]
public async Task GetOrders_WhenCustomerFilterProvided_ReturnsOnlyMatchingOrders()
{
// Arrange
await CreateTestOrderAsync(
customerId: TestDataSeeder.CustomerId);

await CreateTestOrderAsync(
customerId: TestDataSeeder.SecondCustomerId);

// Act
var response = await Client.GetAsync(
$"/api/orders?customerId={TestDataSeeder.SecondCustomerId}");
Expand Down
8 changes: 7 additions & 1 deletion OrderProcessing.Api.Tests/Unit/GetOrderByIdQueryHadlerTests.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
using OrderProcessing.Api.Entities;
using OrderProcessing.Api.DTOs.Orders;
using OrderProcessing.Api.Entities;
using OrderProcessing.Api.Exceptions;
using OrderProcessing.Api.Features.Orders.Queries.GetOrderById;
using OrderProcessing.Api.Features.Orders.Queries.ReadModel;
Expand Down Expand Up @@ -84,6 +85,11 @@ public FakeOrderReadModelReader(OrderReadModel? order)
{
return Task.FromResult(_order?.OrderId == orderId ? _order : null);
}

public Task<OrderReadModelPage> GetPageAsync(OrderQueryParameters parameters, CancellationToken cancellationToken)
{
return Task.FromResult(new OrderReadModelPage([], 0));
}
}
}
}
Loading