Refactor endpoint Procedures to Commands for CQRS alignment

Renamed Insert/Update/DeleteEndpointProcedure classes to their
respective Command counterparts to follow CQRS conventions.
Updated controller actions, handlers, InsertObjectProcedure,
and related unit tests to use the new Command types.
No functional changes were made; this is a naming refactor.
This commit is contained in:
2026-03-24 11:38:22 +01:00
parent 5df36d94e0
commit 4999beda3b
6 changed files with 16 additions and 16 deletions

View File

@@ -16,7 +16,7 @@ public class EndpointsController(IMediator mediator) : ControllerBase
/// <returns>The created ENDPOINT identifier.</returns>
[HttpPost]
[ProducesResponseType(StatusCodes.Status201Created)]
public async Task<IActionResult> Post([FromBody] InsertEndpointProcedure procedure, CancellationToken cancel)
public async Task<IActionResult> Post([FromBody] InsertEndpointCommand procedure, CancellationToken cancel)
{
var id = await mediator.Send(procedure, cancel);
return StatusCode(StatusCodes.Status201Created, id);
@@ -30,7 +30,7 @@ public class EndpointsController(IMediator mediator) : ControllerBase
/// <returns>No content on success.</returns>
[HttpPut]
[ProducesResponseType(StatusCodes.Status204NoContent)]
public async Task<IActionResult> Put([FromBody] UpdateEndpointProcedure procedure, CancellationToken cancel)
public async Task<IActionResult> Put([FromBody] UpdateEndpointCommand procedure, CancellationToken cancel)
{
await mediator.Send(procedure, cancel);
return NoContent();
@@ -44,7 +44,7 @@ public class EndpointsController(IMediator mediator) : ControllerBase
/// <returns>No content on success.</returns>
[HttpDelete]
[ProducesResponseType(StatusCodes.Status204NoContent)]
public async Task<IActionResult> Delete([FromBody] DeleteEndpointProcedure procedure, CancellationToken cancel)
public async Task<IActionResult> Delete([FromBody] DeleteEndpointCommand procedure, CancellationToken cancel)
{
await mediator.Send(procedure, cancel);
return NoContent();

View File

@@ -25,7 +25,7 @@ public record InsertObjectProcedure : IRequest<long>
internal string? AddedWho { get; private set; } = "ReC.API";
public InsertActionProcedure Action { get; set; } = new();
public InsertEndpointProcedure Endpoint { get; set; } = new();
public InsertEndpointCommand Endpoint { get; set; } = new();
public InsertEndpointAuthCommand EndpointAuth { get; set; } = new();
public InsertProfileProcedure Profile { get; set; } = new();
public InsertResultProcedure Result { get; set; } = new();

View File

@@ -3,7 +3,7 @@ using ReC.Application.Common.Procedures.DeleteProcedure;
namespace ReC.Application.Endpoints.Commands;
public record DeleteEndpointProcedure : IDeleteProcedure
public record DeleteEndpointCommand : IDeleteProcedure
{
/// <summary>
/// Start GUID/ID (inclusive)
@@ -21,9 +21,9 @@ public record DeleteEndpointProcedure : IDeleteProcedure
public bool Force { get; set; }
}
public class DeleteEndpointProcedureHandler(ISender sender) : IRequestHandler<DeleteEndpointProcedure, int>
public class DeleteEndpointProcedureHandler(ISender sender) : IRequestHandler<DeleteEndpointCommand, int>
{
public async Task<int> Handle(DeleteEndpointProcedure request, CancellationToken cancel)
public async Task<int> Handle(DeleteEndpointCommand request, CancellationToken cancel)
{
return await sender.Send(new DeleteObjectProcedure
{

View File

@@ -3,16 +3,16 @@ using ReC.Application.Common.Procedures.InsertProcedure;
namespace ReC.Application.Endpoints.Commands;
public record InsertEndpointProcedure : IInsertProcedure
public record InsertEndpointCommand : IInsertProcedure
{
public bool? Active { get; set; }
public string? Description { get; set; }
public string? Uri { get; set; }
}
public class InsertEndpointProcedureHandler(ISender sender) : IRequestHandler<InsertEndpointProcedure, long>
public class InsertEndpointProcedureHandler(ISender sender) : IRequestHandler<InsertEndpointCommand, long>
{
public async Task<long> Handle(InsertEndpointProcedure request, CancellationToken cancel)
public async Task<long> Handle(InsertEndpointCommand request, CancellationToken cancel)
{
return await sender.Send(new InsertObjectProcedure
{

View File

@@ -4,16 +4,16 @@ using ReC.Application.Common.Procedures.UpdateProcedure.Dto;
namespace ReC.Application.Endpoints.Commands;
public record UpdateEndpointProcedure : IUpdateProcedure<UpdateEndpointDto>
public record UpdateEndpointCommand : IUpdateProcedure<UpdateEndpointDto>
{
public long Id { get; set; }
public UpdateEndpointDto Data { get; set; } = null!;
}
public class UpdateEndpointProcedureHandler(ISender sender) : IRequestHandler<UpdateEndpointProcedure, int>
public class UpdateEndpointProcedureHandler(ISender sender) : IRequestHandler<UpdateEndpointCommand, int>
{
public async Task<int> Handle(UpdateEndpointProcedure request, CancellationToken cancel)
public async Task<int> Handle(UpdateEndpointCommand request, CancellationToken cancel)
{
return await sender.Send(new UpdateObjectProcedure
{

View File

@@ -23,7 +23,7 @@ public class EndpointProcedureTests : RecApplicationTestBase
[Test]
public async Task InsertEndpointProcedure_runs_via_mediator()
{
var procedure = new InsertEndpointProcedure { Active = true, Description = "desc", Uri = "http://example" };
var procedure = new InsertEndpointCommand { Active = true, Description = "desc", Uri = "http://example" };
var (sender, scope) = CreateScopedSender();
using var _ = scope;
@@ -35,7 +35,7 @@ public class EndpointProcedureTests : RecApplicationTestBase
[Test]
public async Task UpdateEndpointProcedure_runs_via_mediator()
{
var procedure = new UpdateEndpointProcedure { Data = { Active = false, Description = "updated", Uri = "http://updated" }, Id = 12 };
var procedure = new UpdateEndpointCommand { Data = { Active = false, Description = "updated", Uri = "http://updated" }, Id = 12 };
var (sender, scope) = CreateScopedSender();
using var _ = scope;
@@ -47,7 +47,7 @@ public class EndpointProcedureTests : RecApplicationTestBase
[Test]
public async Task DeleteEndpointProcedure_runs_via_mediator()
{
var procedure = new DeleteEndpointProcedure { Start = 1, End = 2, Force = true };
var procedure = new DeleteEndpointCommand { Start = 1, End = 2, Force = true };
var (sender, scope) = CreateScopedSender();
using var _ = scope;