ReC/src/ReC.Application/RecActions/Commands/CreateRecActionCommand.cs

using DigitalData.Core.Abstraction.Application.Repository;
using DigitalData.Core.Exceptions;
using MediatR;
using ReC.Application.Endpoints.Commands;
using ReC.Domain.Entities;

namespace ReC.Application.RecActions.Commands;

public record CreateRecActionCommand : IRequest
{
    public long ProfileId { get; init; }

    public bool Active { get; init; } = true;

    public long? EndpointId { get; set; }

    public string? EndpointUri { get; init; }

    public string Type { get; init; } = null!;

    public string? HeaderQuery { get; init; }

    public string BodyQuery { get; init; } = null!;

    public byte Sequence { get; set; } = 1;

    public long? EndpointAuthId { get; set; }
}

public class CreateRecActionCommandHandler(ISender sender, IRepository<RecAction> repo) : IRequestHandler<CreateRecActionCommand>
{
    public async Task Handle(CreateRecActionCommand request, CancellationToken cancel)
    {
        if(request.EndpointId is null)
            if(request.EndpointUri is string endpointUri)
            {
                var endpoint = await sender.Send(new ObtainEndpointCommand { Uri = endpointUri }, cancel);
                request.EndpointId = endpoint.Id;
            }
            else
                throw new BadRequestException("Either EndpointId or EndpointUri must be provided.");

        await repo.CreateAsync(request, cancel);
    }
}