Factory ve Domain Service'ler

public interface IUserFactory
{
    Task<User> CreateWithPhoneAsync(FullName? name, Phone? phone, CancellationToken ct);
    Task<User> CreateWithEmailAsync(FullName? name, Email? email, CancellationToken ct);
    Task<User> GetOrCreateFromGoogleAsync(FullName name, Email? email, string googleUserId, CancellationToken ct);
    Task<User> GetOrCreateFromMetaAsync(FullName name, Email? email, string metaUserId, CancellationToken ct);
    Task<User> GetOrCreateFromKeycloakAsync(FullName? name, Email? email, string keycloakUserId, CancellationToken ct);
}

public async Task<User> CreateWithPhoneAsync(FullName? name, Phone? phone, CancellationToken ct)
{
    if (phone == null)
        throw new DomainException("Telefon numarası boş olamaz.");

    var result = await _uniquenessChecker.CheckPhoneUniquenessAsync(phone, ct);

    switch (result)
    {
        case UniquenessResult.Success:
            return new User(name, phone, email: null);        // internal ctor — factory içinden erişilebilir

        case UniquenessResult.AlreadyExists:
            throw new DomainException("Bu telefon numarası ile zaten aktif bir üyelik bulunmaktadır. Lütfen giriş yapınız.");

        case UniquenessResult.ExistsButNotVerified:
            throw new DomainException("Bu telefon numarasına ait bir kayıt mevcut ancak henüz doğrulanmamış. Lütfen sisteme giriş yapıp doğrulama adımını tamamlayın.");

        default:
            throw new ArgumentOutOfRangeException(nameof(result));
    }
}

private async Task<User> GetOrCreateFromExternalAsync(
    AuthProviderType provider, string externalId, FullName name, Email? email,
    Action<User, string> linkLogin, CancellationToken ct)
{
    // 1) sub eşleşmesi
    var (bySubResult, bySubUser) = await _uniquenessChecker.CheckExternalIdentityUniquenessAsync(provider, externalId, ct);
    if (bySubResult == UniquenessResult.AlreadyExists && bySubUser is not null)
    {
        linkLogin(bySubUser, externalId);
        return bySubUser;
    }

    // 2) email eşleşmesi — başka IdP'den gelmiş olabilir
    if (email is not null)
    {
        var byEmailResult = await _uniquenessChecker.CheckEmailUniquenessAsync(email, ct);
        if (byEmailResult == UniquenessResult.AlreadyExists)
        {
            var existing = await _userRepository.FirstOrDefaultAsync(new UserByEmailSpecification(email), ct);
            if (existing is not null) { linkLogin(existing, externalId); existing.VerifyEmail(); return existing; }
        }
        // ExistsButNotVerified → DomainException
    }

    // 3) Yeni kullanıcı
    var newUser = new User(name, phone: null, email);
    if (email is not null) newUser.VerifyEmail();
    linkLogin(newUser, externalId);
    return newUser;
}

public Task<User> GetOrCreateFromGoogleAsync(FullName name, Email? email, string googleUserId, CancellationToken ct)
    => GetOrCreateFromExternalAsync(
        AuthProviderType.Google, googleUserId, name, email,
        linkLogin: (u, sub) => u.AddOrUpdateGoogleLogin(sub, displayName: null),
        ct: ct);

public interface IUserUniquenessChecker
{
    Task<UniquenessResult> CheckEmailUniquenessAsync(Email email, CancellationToken ct);
    Task<UniquenessResult> CheckPhoneUniquenessAsync(Phone phone, CancellationToken ct);
    Task<(UniquenessResult, User?)> CheckExternalIdentityUniquenessAsync(AuthProviderType provider, string externalId, CancellationToken ct);
}

public enum UniquenessResult
{
    Success,               // benzersiz, oluşturulabilir
    AlreadyExists,         // doğrulanmış kayıt var
    ExistsButNotVerified   // kayıt var ama kanal doğrulanmamış
}

public class UserRegistrationService
{
    private readonly IRepository<User> _userRepository;

    public async Task<User> RegisterNewUserAsync(FullName? name, Phone? phone = null, Email? email = null, CancellationToken ct = default)
    {
        if (phone == null && email == null)
            throw new DomainException("Kayıt için telefon veya e-posta gereklidir");

        if (phone != null)
        {
            var existing = await _userRepository.FirstOrDefaultAsync(new UserByPhoneNumberSpecification(phone), ct);
            if (existing is not null)
            {
                if (!existing.IsPhoneNumberVerified)
                    throw new DomainException("Bu telefon numarasına sahip bir kullanıcı zaten mevcut fakat üyelik onayı yapılmamış. Lütfen giriş yapınız");
                throw new DomainException("Bu telefon numarasına sahip bir kullanıcı zaten mevcut");
            }
        }
        // e-posta için benzer kontrol ...

        return new User(name, phone, email);
    }
}