the-biergarten-app/web/backend/Infrastructure/Infrastructure.Sql/DefaultSqlConnectionFactory.cs

using System.Data.Common;
using Microsoft.Data.SqlClient;
using Microsoft.Extensions.Configuration;

namespace Infrastructure.Sql;

/// <summary>
///     Default <see cref="ISqlConnectionFactory" /> implementation that creates SQL Server connections,
///     resolving the connection string from environment variables or application configuration.
/// </summary>
public class DefaultSqlConnectionFactory(IConfiguration configuration) : ISqlConnectionFactory
{
    private readonly string _connectionString = GetConnectionString(configuration);

    /// <inheritdoc />
    public DbConnection CreateConnection()
    {
        return new SqlConnection(_connectionString);
    }

    /// <summary>
    ///     Resolves the SQL Server connection string, preferring (in order): the <c>DB_CONNECTION_STRING</c>
    ///     configuration value, a connection string built from individual <c>DB_*</c> configuration values,
    ///     and finally the <c>"Default"</c> connection string from configuration.
    /// </summary>
    /// <exception cref="InvalidOperationException">Thrown when no connection string can be resolved from any source.</exception>
    private static string GetConnectionString(IConfiguration configuration)
    {
        // Check for full connection string first
        string? fullConnectionString = configuration["DB_CONNECTION_STRING"];
        if (!string.IsNullOrEmpty(fullConnectionString))
            return fullConnectionString;

        // Try to build from individual configuration values (preferred method for Docker)
        try
        {
            return SqlConnectionStringHelper.BuildConnectionString(configuration);
        }
        catch (InvalidOperationException)
        {
            // Fall back to configuration-based connection string if env vars are not set
            string? connString = configuration.GetConnectionString("Default");
            if (!string.IsNullOrEmpty(connString))
                return connString;

            throw new InvalidOperationException(
                "Database connection string not configured. Set DB_CONNECTION_STRING or DB_SERVER, DB_NAME, DB_USER, DB_PASSWORD env vars or ConnectionStrings:Default."
            );
        }
    }
}