EnvelopeGenerator/EnvelopeGenerator.Application/Histories/Commands/CreateHistoryCommand.cs

using DigitalData.Core.Abstraction.Application.Repository;
using EnvelopeGenerator.Application.Model;
using EnvelopeGenerator.Domain.Entities;
using MediatR;
using Microsoft.EntityFrameworkCore;
using EnvelopeGenerator.Application.Extensions;
using EnvelopeGenerator.Domain.Constants;

namespace EnvelopeGenerator.Application.Histories.Commands;

/// <summary>
/// 
/// </summary>
public record CreateHistoryCommand : EnvelopeReceiverQueryBase, IRequest<long?>
{
    /// <summary>
    /// 
    /// </summary>
    public int? EnvelopeId { get; set; }

    /// <summary>
    /// 
    /// </summary>
    public string? UserReference { get; set; }

    /// <summary>
    /// 
    /// </summary>
    public EnvelopeStatus Status { get; set; }

    /// <summary>
    /// 
    /// </summary>
    public DateTime AddedWhen { get; } = DateTime.Now;

    /// <summary>
    /// 
    /// </summary>
    public DateTime ActionDate => AddedWhen;

    /// <summary>
    /// 
    /// </summary>
    public string? Comment { get; set; }
}

/// <summary>
/// 
/// </summary>
public class CreateHistoryCommandHandler : IRequestHandler<CreateHistoryCommand, long?>
{
    private readonly IRepository<EnvelopeHistory> _repo;

    /// <summary>
    /// 
    /// </summary>
    /// <param name="repo"></param>
    public CreateHistoryCommandHandler(IRepository<EnvelopeHistory> repo)
    {
        _repo = repo;
    }

    /// <summary>
    /// 
    /// </summary>
    /// <param name="request"></param>
    /// <param name="cancel"></param>
    /// <returns></returns>
    public async Task<long?> Handle(CreateHistoryCommand request, CancellationToken cancel)
    {
        // create entitiy
        await _repo.CreateAsync(request, cancel);

        // check if created
        var query = _repo.ReadOnly();

        query = request.EnvelopeId is null
            ? query.Where(request.Envelope)
            : query.Where(h => h.EnvelopeId == request.EnvelopeId);

        query = request.UserReference is null
            ? query.Where(request.Receiver)
            : query.Where(h => h.UserReference == request.UserReference);

        var record = await query
            .Where(h => h.ActionDate == request.ActionDate)
            .SingleOrDefaultAsync(cancel);

        return record?.Id;
    }
}