Rename FetchEmailsQuery to ReadEmailQuery
Renamed `FetchEmailsQuery` to `ReadEmailQuery` across the codebase, including its handler, validator, and usages in `EmailController`. Updated method signatures, dependencies, and XML documentation to reflect the new naming convention. Adjusted `ILogger` dependency in the handler to match the renamed class.
This commit is contained in:
@@ -14,7 +14,7 @@ namespace DigitalData.MessagingService.Application.EmailReceiving.Queries;
|
|||||||
/// <summary>
|
/// <summary>
|
||||||
/// Query to fetch emails from an IMAP mailbox.
|
/// Query to fetch emails from an IMAP mailbox.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public record FetchEmailsQuery : IRequest<IEnumerable<ReceivedEmailDto>>
|
public record ReadEmailQuery : IRequest<IEnumerable<ReceivedEmailDto>>
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Identifies the email account to use.
|
/// Identifies the email account to use.
|
||||||
@@ -27,9 +27,9 @@ public record FetchEmailsQuery : IRequest<IEnumerable<ReceivedEmailDto>>
|
|||||||
public MailSearchFilter Mail { get; init; } = new();
|
public MailSearchFilter Mail { get; init; } = new();
|
||||||
}
|
}
|
||||||
|
|
||||||
public class FetchEmailsQueryHandler(IImapEmailService ImapService, ILogger<FetchEmailsQueryHandler> Logger, IRepository<EmailAccount> Repo) : IRequestHandler<FetchEmailsQuery, IEnumerable<ReceivedEmailDto>>
|
public class ReadEmailQueryHandler(IImapEmailService ImapService, ILogger<ReadEmailQueryHandler> Logger, IRepository<EmailAccount> Repo) : IRequestHandler<ReadEmailQuery, IEnumerable<ReceivedEmailDto>>
|
||||||
{
|
{
|
||||||
public async Task<IEnumerable<ReceivedEmailDto>> Handle(FetchEmailsQuery request, CancellationToken cancellationToken)
|
public async Task<IEnumerable<ReceivedEmailDto>> Handle(ReadEmailQuery request, CancellationToken cancellationToken)
|
||||||
{
|
{
|
||||||
var accounts = await Repo.FindAsync(request.Account.Id is int id ? x => x.Id == id : x => x.Username == request.Account.Username, cancellationToken: cancellationToken);
|
var accounts = await Repo.FindAsync(request.Account.Id is int id ? x => x.Id == id : x => x.Username == request.Account.Username, cancellationToken: cancellationToken);
|
||||||
|
|
||||||
@@ -5,9 +5,9 @@ using FluentValidation;
|
|||||||
namespace DigitalData.MessagingService.Application.EmailReceiving.Validators;
|
namespace DigitalData.MessagingService.Application.EmailReceiving.Validators;
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Validates a <see cref="FetchEmailsQuery"/> before it is handled by <see cref="FetchEmailsQueryHandler"/>.
|
/// Validates a <see cref="ReadEmailQuery"/> before it is handled by <see cref="ReadEmailQueryHandler"/>.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public class FetchEmailsQueryValidator : AbstractValidator<FetchEmailsQuery>
|
public class FetchEmailsQueryValidator : AbstractValidator<ReadEmailQuery>
|
||||||
{
|
{
|
||||||
public FetchEmailsQueryValidator()
|
public FetchEmailsQueryValidator()
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -92,7 +92,7 @@ public class EmailController(IMediator mediator) : ControllerBase
|
|||||||
[ProducesResponseType(StatusCodes.Status200OK)]
|
[ProducesResponseType(StatusCodes.Status200OK)]
|
||||||
[ProducesResponseType(StatusCodes.Status400BadRequest)]
|
[ProducesResponseType(StatusCodes.Status400BadRequest)]
|
||||||
[ProducesResponseType(StatusCodes.Status404NotFound)]
|
[ProducesResponseType(StatusCodes.Status404NotFound)]
|
||||||
public async Task<IActionResult> FetchEmails([FromQuery] FetchEmailsQuery query, [FromQuery] OnlyFilter? only = null, CancellationToken cancellationToken = default)
|
public async Task<IActionResult> FetchEmails([FromQuery] ReadEmailQuery query, [FromQuery] OnlyFilter? only = null, CancellationToken cancellationToken = default)
|
||||||
{
|
{
|
||||||
var emails = await mediator.Send(query, cancellationToken);
|
var emails = await mediator.Send(query, cancellationToken);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user