Shogi/Shogi.Api/Repositories/QueryRepository.cs

using Dapper;
using Shogi.Contracts.Api;
using Shogi.Contracts.Types;
using System.Data;
using System.Data.SqlClient;

namespace Shogi.Api.Repositories;

public class QueryRepository : IQueryRespository
{
    private readonly string connectionString;

    public QueryRepository(IConfiguration configuration)
    {
        var connectionString = configuration.GetConnectionString("ShogiDatabase") ?? throw new InvalidOperationException("No database configured for QueryRepository.");
        this.connectionString = connectionString;
    }

    public async Task<ReadSessionsPlayerCountResponse> ReadSessionPlayerCount(string playerName)
    {
        using var connection = new SqlConnection(connectionString);

        var results = await connection.QueryMultipleAsync(
            "session.ReadSessionPlayerCount",
            new { PlayerName = playerName },
            commandType: System.Data.CommandType.StoredProcedure);

        var joinedSessions = await results.ReadAsync<SessionMetadata>();
        var otherSessions = await results.ReadAsync<SessionMetadata>();
        return new ReadSessionsPlayerCountResponse
        {
            PlayerHasJoinedSessions = joinedSessions.ToList(),
            AllOtherSessions = otherSessions.ToList()
        };
    }

    /// <summary>
    /// </summary>
    /// <returns>A <see cref="ValueTuple"/> with Item1 as player 1 and Item2 as player 2.</returns>
    public async Task<(User Player1, User? Player2)?> GetUsersForSession(string sessionName)
    {
        using var connection = new SqlConnection(connectionString);
        var results = await connection.QueryAsync<(string Player1Name, string Player1DisplayName, string Player2Name, string Player2DisplayName)>(
            "session.ReadUsersBySession",
            new { SessionName = sessionName },
            commandType: CommandType.StoredProcedure);

        if (results.Any())
        {
            var (Player1Name, Player1DisplayName, Player2Name, Player2DisplayName) = results.First();
            var p1 = new User(Player1Name, Player1DisplayName);
            var p2 = Player2Name != null
                ? new User(Player2Name, Player2DisplayName)
                : null;
            return (p1, p2);
        }
        return null;
    }
}

public interface IQueryRespository
{
    Task<(User Player1, User? Player2)?> GetUsersForSession(string sessionName);
    Task<ReadSessionsPlayerCountResponse> ReadSessionPlayerCount(string playerName);
}