【C#/Blazor】実務Webアプリ開発編 (31)CQRSとは？コマンドとクエリを分ける理由 ～集約は変更を守る境界、読み取りは境界をまたぐ～

src/
├── MentorApp.Application/
│   ├── Contracts/
│   │   └── Queries/
│   │       └── IMentorshipQueryService.cs  ← クエリ（今回）
│   └── Mentorships/
│       └── MentorshipService.cs  ← コマンド
├── MentorApp.Domain/
│   └── Models/
│       └── Mentorships/
│           ├── IMentorshipRepository.cs  ← コマンド
│           └── Mentorship.cs  ← コマンド
└── MentorApp.Infrastructure/
    └── Persistence/
        ├── Queries/
        │   └── MentorshipQueryService.cs  ← クエリ（今回）
        └── Repositories/
            └── MentorshipRepository.cs  ← コマンド

    public async Task<Mentorship> CompleteMentorshipAsync(
        Guid mentorshipId,
        CurrentUser currentUser,
        CancellationToken cancellationToken = default)
    {
        // …（例外処理の殻・2 行省略）
            await using var uow = await unitOfWorkFactory.CreateAsync(cancellationToken);

            var mentorship = await uow.Mentorships.FindByIdAsync(mentorshipId, cancellationToken)
                ?? throw new KeyNotFoundException($"メンタリング関係が見つかりません: {mentorshipId}");

            var isMentor = currentUser.Role == Role.Mentor && mentorship.MentorUserId == currentUser.UserId;
            if (currentUser.Role != Role.Admin && !isMentor)
                throw new UnauthorizedAccessException("このメンタリングを完了する権限がありません。");

            var now = timeProvider.GetUtcNow();
            mentorship.Complete(now);
            await uow.SaveChangesAsync(cancellationToken);

            // …（ログ・3 行省略）

            return mentorship;
        // …（例外処理・6 行省略）
    }

    public void Complete(DateTimeOffset endedAt)
    {
        if (Status != MentorshipStatus.Active)
            throw new InvalidOperationException("Active 状態の Mentorship のみ完了にできます。");

        Status = MentorshipStatus.Completed;
        EndedAt = endedAt;
    }

/// <summary>
/// メンタリング集約のリポジトリインターフェイス（Command側）
/// </summary>
/// <remarks>
/// <para>
/// Domain 層で定義し、Infrastructure 層が実装する（依存性逆転の原則）。
/// </para>
/// <para>
/// CQRSパターンにおけるCommand側の責務を担当。
/// 状態変更の前処理（取得→更新）に使用し、一覧取得などのQuery操作は
/// Application層のIMentorshipQueryServiceが担当する。
/// </para>
/// <para>
/// 別集約（User）のIncludeは行わない。表示用途での結合は
/// QueryService側で行う。
/// </para>
/// </remarks>
public interface IMentorshipRepository
{
    public Task<Mentorship?> FindByIdAsync(Guid id, CancellationToken cancellationToken = default);

    public Task<bool> HasActiveMentorshipAsync(
        Guid mentorUserId,
        Guid menteeUserId,
        CancellationToken cancellationToken = default);

    public Task<bool> HasAnyActiveMentorshipByUserIdAsync(
        Guid userId,
        CancellationToken cancellationToken = default);

    public Task<Mentorship?> FindByMentorAndMenteeAsync(
        Guid mentorUserId,
        Guid menteeUserId,
        CancellationToken cancellationToken = default);

    public Task AddAsync(Mentorship mentorship, CancellationToken cancellationToken = default);

    public void Delete(Mentorship mentorship);
}

    public async Task<IReadOnlyList<MentorshipDto>> GetAccessibleAsync(
        CurrentUser currentUser,
        Guid? filterByUserId = null,
        CancellationToken cancellationToken = default)
    {
        await using var dbContext = await dbContextFactory.CreateDbContextAsync(cancellationToken);

        var query = dbContext.Mentorships.AsNoTracking();

        // …（読む範囲の絞り込み・11 行省略）

        return await query
            .OrderByDescending(m => m.StartedAt)
            .Select(m => new MentorshipDto(
                m.Id,
                // …（ID・状態・日時・4 行省略）
                m.MentorUser!.DisplayName,
                m.MenteeUserId,
                m.MenteeUser!.DisplayName))
            .ToListAsync(cancellationToken);
    }

public record MentorshipDto(
    Guid Id,
    MentorshipStatus Status,
    DateTimeOffset StartedAt,
    DateTimeOffset? EndedAt,
    Guid MentorUserId,
    string MentorDisplayName,
    Guid MenteeUserId,
    string MenteeDisplayName);