// SPDX-License-Identifier: AGPL-3.0-or-later
// Copyright (C) 2022-2026 Aykut Alparslan KOC

using System.Text;
using Ferrite.TL;
using Ferrite.TL.baseLayer.dto;

namespace Ferrite.Data.Repositories;

public class AuthorizationRepository : IAuthorizationRepository
{
    private readonly IKVStore _store;
    private readonly IKVStore _storeExported;
    private readonly IKVStore _storeImported;
    public AuthorizationRepository(IKVStore store, IKVStore storeExported, IKVStore storeImported)
    {
        _store = store;
        _store.SetSchema(new TableDefinition("ferrite", "authorizations",
            new KeyDefinition("pk",
                new DataColumn { Name = "auth_key_id", Type = DataType.Long },
                new DataColumn { Name = "phone", Type = DataType.String }),
            new KeyDefinition("by_phone",
                new DataColumn { Name = "phone", Type = DataType.String },
                new DataColumn { Name = "auth_key_id", Type = DataType.Long })));
        _storeExported = storeExported;
        _storeExported.SetSchema(new TableDefinition("ferrite", "exported_authorizations",
            new KeyDefinition("pk",
                new DataColumn { Name = "user_id", Type = DataType.Long },
                new DataColumn { Name = "data", Type = DataType.Bytes })));
        _storeImported = storeImported;
        _storeImported.SetSchema(new TableDefinition("ferrite", "imported_authorizations",
            new KeyDefinition("pk",
                new DataColumn { Name = "auth_key_id", Type = DataType.Long })));
    }
    public bool PutAuthorization(TLAuthInfo info)
    {
        var authInfo = info.AsAuthInfo();
        return _store.Put(info.AsSpan().ToArray(), authInfo.AuthKeyId, Encoding.UTF8.GetString(authInfo.Phone));
    }

    public TLAuthInfo? GetAuthorization(long authKeyId)
    {
        var infoBytes = _store.Get(authKeyId);
        if (infoBytes == null) return null;
        return new TLAuthInfo(infoBytes, 0, infoBytes.Length);
    }

    public async ValueTask<TLAuthInfo?> GetAuthorizationAsync(long authKeyId)
    {
        var infoBytes =  await _store.GetAsync(authKeyId);
        if (infoBytes == null) return null;
        return new TLAuthInfo(infoBytes, 0, infoBytes.Length);
    }

    public IReadOnlyList<TLAuthInfo> GetAuthorizations(string phone)
    {
        List<TLAuthInfo> infos = new();
        var authorizations = _store.IterateBySecondaryIndex("by_phone", phone);
        foreach (var auth in authorizations)
        {
            infos.Add(new TLAuthInfo(auth, 0, auth.Length));
        }

        return infos;
    }

    public async ValueTask<IReadOnlyList<TLAuthInfo>> GetAuthorizationsAsync(string phone)
    {
        List<TLAuthInfo> infos = new();
        var authorizations = _store.IterateBySecondaryIndexAsync("by_phone", phone);
        await foreach (var auth in authorizations)
        {
            infos.Add(new TLAuthInfo(auth, 0, auth.Length));
        }

        return infos;
    }

    public IReadOnlyList<TLAuthInfo> GetAuthorizations() => _store.Iterate()
        .Select(bytes => new TLAuthInfo(bytes, 0, bytes.Length))
        .ToArray();

    public bool DeleteAuthorization(long authKeyId)
    {
        _storeImported.Delete(authKeyId);
        return _store.Delete(authKeyId);
    }

    public bool PutImportedAuthorization(long authKeyId, long sourceAuthKeyId)
    {
        return _storeImported.Put(BitConverter.GetBytes(sourceAuthKeyId), authKeyId);
    }

    public async ValueTask<long?> GetImportSourceAsync(long authKeyId)
    {
        var sourceBytes = await _storeImported.GetAsync(authKeyId);
        if (sourceBytes is not { Length: sizeof(long) }) return null;
        return BitConverter.ToInt64(sourceBytes);
    }

    public bool PutExportedAuthorization(TLExportedAuthInfo exportedInfo)
    {
        var exported = exportedInfo.AsExportedAuthInfo();
        return _storeExported.Put(exportedInfo.AsSpan().ToArray(), exported.UserId, exported.Data.ToArray());
    }

    public TLExportedAuthInfo? GetExportedAuthorization(long userId, byte[] data)
    {
        var exportedBytes = _storeExported.Get(userId, data);
        if (exportedBytes == null) return null;
        return new TLExportedAuthInfo(exportedBytes, 0 , exportedBytes.Length);
    }

    public async ValueTask<TLExportedAuthInfo?> GetExportedAuthorizationAsync(long userId, byte[] data)
    {
        var exportedBytes = await _storeExported.GetAsync(userId, data);
        if (exportedBytes == null) return null;
        return new TLExportedAuthInfo(exportedBytes, 0 , exportedBytes.Length);
    }
}