Goldev.Core.MediatR 8.2.0

Goldev.Core.MediatR

Пакет для работы с MediatR

Примеры использования

• Подключение

services.AddMediatR<Program>() // Настройка DI

• Модель запроса

/// <summary>
/// Модель запроса с возвращаемым значением
/// </summary>
public class TestQueryModel : IRequestModel<int> // указываем тип возвращаемого значения
{
    /// <summary>
    /// Параметр запроса
    /// </summary>
    public int QueryParameter { get; init; } = new Random().Next();
}

/// <summary>
/// Модель запроса без возвращаемого значения
/// </summary>
public class TestCommandModel : IRequestModel
{
    /// <summary>
    /// Параметр запроса
    /// </summary>
    public int CommandParameter { get; init; } = new Random().Next();
}

• Реализация хендлера

/// <summary>
/// Хендлер с возвращаемым значением
/// </summary>
public class TestQueryHandler : AbstractQueryHandler<TestQueryModel, int>
{
    public TestQueryHandler(
        ILogger<TestQueryHandler> logger,
        IMediator mediator)  // Опционально (требуется если будем использовать MediatorSendAsync)
        : base(logger, mediator) 
    {
        ErrorMessage = "Ошибка"; // По умолчанию: "Во время обработки запроса произошла ошибка"
        ErrorLog = "Ошибка в хендлере {name} при значении {value}"; // По умолчанию: "В хендлере {name} произошла ошибка", где name имя хендлера (TestQueryHandler)
        ErrorLogParams = x => [nameof(TestQueryHandler), x.QueryParameter];   
        ErrorStatusCode = HttpStatusCode.InternalServerError; // По умолчанию: InternalServerError
    }

    public async override Task<IHandleResult<int>> HandleAsync(TestQueryModel query, CancellationToken cancellationToken)
    {
        if (query.QueryParameter % 5 == 0)
        {
            return await Error(new Exception(), "Ошибка вышла", "Вышла ошибка при значении {val} в хендлере {handler}", query.QueryParameter, nameof(TestQueryHandler)); 
        }

        if (query.QueryParameter % 2 == 0)
        {
            return await BadRequest("Что то не то");
        }

        // Вызов медиатера
        await MediatorSendAsync(new TestCommandModel()
        {
        }, cancellationToken); // В случае обработки с ошибкой, внешний хендлер тоже завершится с ошибкой

        // Вызов медиатера
        int response = await MediatorSendAsync(new TestQueryModel()
        {
        }, cancellationToken); // В случае обработки с ошибкой, внешний хендлер тоже завершится с ошибкой

        int result = (query.QueryParameter * 10) % 100007;

        return await Ok(result, "всё ок при значении {v}", HttpStatusCode.OK, query.QueryParameter);
    }
}

/// <summary>
/// Хендлер без возвращаемого значения
/// </summary>
public class TestCommandHandler : AbstractCommandHandler<TestCommandModel>
{
    public TestCommandHandler(
        ILogger<TestQueryHandler> logger,
        IMediator mediator) // Опционально (требуется если будем использовать MediatorSendAsync)
        : base(logger, mediator)
    {
        ErrorMessage = "Ошибка"; // По умолчанию: "Во время обработки запроса произошла ошибка"
        ErrorLog = "Ошибка в хендлере {name} при значении {value}"; // По умолчанию: "В хендлере {name} произошла ошибка", где name имя хендлера (TestQueryHandler)
        ErrorLogParams = x => [nameof(TestQueryHandler), x.CommandParameter];
        ErrorStatusCode = System.Net.HttpStatusCode.InternalServerError; // По умолчанию: InternalServerError
    }

    public override async Task<IHandleResult> HandleAsync(TestCommandModel command, CancellationToken cancellationToken)
    {
        // Вызов медиатера
        int response = await MediatorSendAsync(new TestQueryModel()
        {
        }, cancellationToken); // В случае обработки с ошибкой, внешний хендлер тоже завершится с ошибкой

        // Вызов медиатера
        await MediatorSendAsync(new TestCommandModel()
        {
        }, cancellationToken); // В случае обработки с ошибкой, внешний хендлер тоже завершится с ошибкой

        if (response % 3 == 0)
        {
            // Выйти с ошибкой пользователя
            return await BadRequest("Что то не то", "Что то не то со значением {res}", HttpStatusCode.BadRequest, response);
        }

        if (response % 11 == 0)
        {
            // Выбросить ошибку
            return await Error(new Exception(), "Ошибка вышла", "Вышла ошибка при значении {val} в хендлере {handler}", HttpStatusCode.BadRequest, response, nameof(TestCommandHandler));
        }

        return await Ok("всё ок при значении {v}", HttpStatusCode.OK, command.CommandParameter);
    }
}

• Использование

ResponseModel response = await _mediator.Send(new TestCommandModel()
{
    CommandParameter = 123
});

bool isError = response.IsError;        // Флаг, говорящий, завершилась ли обработка с ошибкой
string message = response.ErrorText;    // сообщения об ошибке (опционально) 

HttpStatusCode httpCode = response.HttpStatusCode; // Код ответа
int intCode = response.ResponseCode; // Код ответа в виде числа

ResponseModel<int> response = await _mediator.Send(new TestQueryModel()
{
    QueryParameter = 123
});

int result = response.Response;         // Результат выполнения
bool isError = response.IsError;        // Флаг, говорящий, завершилась ли обработка с ошибкой
string message = response.ErrorText;    // сообщения об ошибке (опционально) 

HttpStatusCode httpCode = response.HttpStatusCode; // Код ответа
int intCode = response.ResponseCode; // Код ответа в виде числа

• Маппинг результатов с ошибкой

ResponseModel<int> response;

response = await _mediator.Send(new TestQueryModel()
{
	QueryParameter = 123
});

ResponseModel responseModelSimple = response.ErrorResponse(); // из ResponseModel<TSource> в ResponseModel
ResponseModel<double> responseModelGeneric1 = response.ErrorResponse<int, double>(); // из ResponseModel<TSource> в ResponseModel<TDestanation>
ResponseModel<double> responseModelGeneric2 = responseModelSimple.ErrorResponse<double>(); // из ResponseModel в ResponseModel<TSource>