feat(infra): add delete endpoint for transactions with corresponding integration tests

This commit is contained in:
Stevan Freeborn
2026-03-12 17:29:41 -05:00
parent f0c63c7ded
commit e47e08b9f0
3 changed files with 156 additions and 0 deletions
@@ -0,0 +1,34 @@
namespace FiscalOS.API.Transactions.DeleteById;
internal static class Endpoint
{
private const string Route = "/{id}";
public static RouteHandlerBuilder MapDeleteEndpoint(this RouteGroupBuilder groupBuilder)
{
return groupBuilder.MapDelete(Route, HandleAsync);
}
private static async Task<IResult> HandleAsync(
HttpContext httpContext,
[FromRoute] Guid id,
[FromServices] AppDbContext appDbContext,
CancellationToken ct
)
{
var userId = httpContext.GetUserId();
var existingTransaction = await appDbContext.Transactions
.SingleOrDefaultAsync(t => t.UserId == userId && t.Id == id, ct);
if (existingTransaction is null)
{
return Results.NotFound();
}
appDbContext.Transactions.Remove(existingTransaction);
await appDbContext.SaveChangesAsync(ct);
return Results.NoContent();
}
}
@@ -1,3 +1,4 @@
using FiscalOS.API.Transactions.DeleteById;
using FiscalOS.API.Transactions.FireWebhook; using FiscalOS.API.Transactions.FireWebhook;
using FiscalOS.API.Transactions.Get; using FiscalOS.API.Transactions.Get;
using FiscalOS.API.Transactions.Webhook; using FiscalOS.API.Transactions.Webhook;
@@ -14,6 +15,7 @@ internal static class TransactionsExtensions
.RequireAuthorization(); .RequireAuthorization();
transactionsGroup.MapGetEndpoint(); transactionsGroup.MapGetEndpoint();
transactionsGroup.MapDeleteEndpoint();
transactionsGroup.MapWebhookEndpoint().AllowAnonymous(); transactionsGroup.MapWebhookEndpoint().AllowAnonymous();
if (app.Environment.IsProduction() is false) if (app.Environment.IsProduction() is false)
@@ -0,0 +1,120 @@
using Transaction = FiscalOS.Core.Transactions.Transaction;
namespace FiscalOS.API.Tests.Integration.Transactions;
public class DeleteByIdTests(TestApi testApi) : IntegrationTest(testApi)
{
private static Uri GetDeleteByIdUri(Guid id)
{
return new($"/transactions/{id}", UriKind.Relative);
}
[Fact]
public async Task DeleteById_WhenCalledAndUnauthenticated_ItShouldREturn401WithProblemDetails()
{
using var request = HttpRequestBuilder.New()
.Delete(GetDeleteByIdUri(Guid.NewGuid()))
.Build();
var response = await Client.SendAsync(request, TestContext.Current.CancellationToken);
await response.Should().BeProblemDetails(HttpStatusCode.Unauthorized);
}
[Fact]
public async Task DeleteById_WhenCalledWithNonExistentTransaction_ItShouldReturn401WithProblemDetails()
{
using var request = HttpRequestBuilder.New()
.Delete(GetDeleteByIdUri(Guid.NewGuid()))
.WithUserId(Guid.NewGuid())
.Build();
var response = await Client.SendAsync(request, TestContext.Current.CancellationToken);
await response.Should().BeProblemDetails(HttpStatusCode.NotFound);
}
[Fact]
public async Task DeleteById_WhenCalledWithTransactionIdThatDoesNotBelongToTheUser_ItShouldReturn404WithProblemDetails()
{
var user = await Api.ExecuteAsync(static async (context, ct, sp) =>
{
var passwordHasher = sp.GetRequiredService<IPasswordHasher>();
var encryptor = sp.GetRequiredService<IEncryptor>();
var user = UserBuilder.Create()
.WithInstitution(static ib =>
{
ib.WithMetadata();
ib.WithAccount(static ab =>
{
ab.WithMetadata();
ab.WithTransaction(static tb =>
{
tb.WithMetadata();
});
});
})
.Build();
await context.AddAsync(user, ct);
await context.SaveChangesAsync(ct);
return user;
}, TestContext.Current.CancellationToken);
using var request = HttpRequestBuilder.New()
.Delete(GetDeleteByIdUri(Guid.NewGuid()))
.WithUserId(Guid.NewGuid())
.Build();
var response = await Client.SendAsync(request, TestContext.Current.CancellationToken);
await response.Should().BeProblemDetails(HttpStatusCode.NotFound);
}
[Fact]
public async Task DeleteById_WhenCalledWithTransactionIdThatDoesExistAndBelongsToTheUser_ItShouldReturn204WithNoContent()
{
var user = await Api.ExecuteAsync(static async (context, ct, sp) =>
{
var passwordHasher = sp.GetRequiredService<IPasswordHasher>();
var encryptor = sp.GetRequiredService<IEncryptor>();
var user = UserBuilder.Create()
.WithInstitution(static ib =>
{
ib.WithMetadata();
ib.WithAccount(static ab =>
{
ab.WithMetadata();
ab.WithTransaction(static tb =>
{
tb.WithMetadata();
});
});
})
.Build();
await context.AddAsync(user, ct);
await context.SaveChangesAsync(ct);
return user;
}, TestContext.Current.CancellationToken);
using var request = HttpRequestBuilder.New()
.Delete(GetDeleteByIdUri(user.Transactions.First().Id))
.WithUserId(user.Id)
.Build();
var response = await Client.SendAsync(request, TestContext.Current.CancellationToken);
response.StatusCode.Should().Be(HttpStatusCode.NoContent);
var deletedTransaction = await Api.ExecuteAsync(async (context, ct) =>
{
return await context.Set<Transaction>()
.SingleOrDefaultAsync(t => t.Id == user.Transactions.First().Id, ct);
}, TestContext.Current.CancellationToken);
deletedTransaction.Should().BeNull();
}
}