Ferrite.Data/Repositories/FileInfoRepository.cs

Rama main · réplica de lectura del repositorio original.

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

using Ferrite.TL.baseLayer.dto;

namespace Ferrite.Data.Repositories;

public class FileInfoRepository : IFileInfoRepository
{
    private readonly IKVStore _storeFiles;
    private readonly IKVStore _storeBigFiles;
    private readonly IKVStore _storeReferences;
    private readonly IKVStore _storeFileParts;
    private readonly IKVStore _storeBigFileParts;
    private readonly IKVStore _storeUploadStates;
    public FileInfoRepository(IKVStore storeFiles, IKVStore storeBigFiles,
        IKVStore storeReferences,IKVStore storeFileParts, IKVStore storeBigFileParts,
        IKVStore storeUploadStates)
    {
        _storeFiles = storeFiles;
        _storeFiles.SetSchema(new TableDefinition("ferrite", "files",
            new KeyDefinition("pk",
                new DataColumn { Name = "file_id", Type = DataType.Long })));
        _storeBigFiles = storeBigFiles;
        _storeBigFiles.SetSchema(new TableDefinition("ferrite", "big_files",
            new KeyDefinition("pk",
                new DataColumn { Name = "file_id", Type = DataType.Long })));
        _storeReferences = storeReferences;
        _storeReferences.SetSchema(new TableDefinition("ferrite", "file_references",
            new KeyDefinition("pk",
                new DataColumn { Name = "reference_bytes", Type = DataType.Bytes })));
        _storeFileParts = storeFileParts;
        _storeFileParts.SetSchema(new TableDefinition("ferrite", "file_parts",
            new KeyDefinition("pk",
                new DataColumn { Name = "file_id", Type = DataType.Long },
                new DataColumn { Name = "file_part", Type = DataType.Int })));
        _storeBigFileParts = storeBigFileParts;
        _storeBigFileParts.SetSchema(new TableDefinition("ferrite", "big_file_parts",
            new KeyDefinition("pk",
                new DataColumn { Name = "file_id", Type = DataType.Long },
                new DataColumn { Name = "file_part", Type = DataType.Int })));
        _storeUploadStates = storeUploadStates;
        _storeUploadStates.SetSchema(new TableDefinition("ferrite", "file_upload_states",
            new KeyDefinition("pk",
                new DataColumn { Name = "file_id", Type = DataType.Long },
                new DataColumn { Name = "is_big", Type = DataType.Int })));
    }

    public TLUploadedFileInfo? GetFileInfo(long fileId)
    {
        var infoBytes = _storeFiles.Get(fileId);
        if (infoBytes == null) return null;
        return new TLUploadedFileInfo(infoBytes, 0, infoBytes.Length);
    }

    public bool PutFileInfo(TLUploadedFileInfo uploadedFile)
    {
        var infoBytes = uploadedFile.AsSpan().ToArray();
        return _storeFiles.Put(infoBytes, uploadedFile.AsUploadedFileInfo().Id);
    }

    public bool PutBigFileInfo(TLUploadedFileInfo uploadedFile)
    {
        var infoBytes = uploadedFile.AsSpan().ToArray();
        return _storeBigFiles.Put(infoBytes, uploadedFile.AsUploadedFileInfo().Id);
    }

    public TLUploadedFileInfo? GetBigFileInfo(long fileId)
    {
        var infoBytes = _storeBigFiles.Get(fileId);
        if (infoBytes == null) return null;
        return new TLUploadedFileInfo(infoBytes, 0, infoBytes.Length);
    }

    public bool PutFilePart(TLFilePart part)
    {
        var partBytes = part.AsSpan().ToArray();
        return _storeFileParts.Put(partBytes, part.AsFilePart().FileId, part.AsFilePart().PartNum);
    }

    public bool PutBigFilePart(TLFilePart part)
    {
        var partBytes = part.AsSpan().ToArray();
        return _storeBigFileParts.Put(partBytes, part.AsFilePart().FileId, part.AsFilePart().PartNum);
    }

    public TLFilePart? GetFilePart(long fileId, int partNum)
    {
        var partBytes = _storeFileParts.Get(fileId, partNum);
        if (partBytes == null) return null;
        return new TLFilePart(partBytes, 0, partBytes.Length);
    }

    public TLFilePart? GetBigFilePart(long fileId, int partNum)
    {
        var partBytes = _storeBigFileParts.Get(fileId, partNum);
        if (partBytes == null) return null;
        return new TLFilePart(partBytes, 0, partBytes.Length);
    }

    public IReadOnlyCollection<TLFilePart> GetFileParts(long fileId)
    {
        List<TLFilePart> parts = new();
        var iter = _storeFileParts.Iterate(fileId);
        foreach (var partBytes in iter)
        {
            var part = new TLFilePart(partBytes, 0, partBytes.Length);
            parts.Add(part);
        }

        return parts;
    }

    public bool SaveBigFilePart(TLFilePart part)
    {
        var partBytes = part.AsSpan().ToArray();
        return _storeBigFileParts.Put(partBytes, part.AsFilePart().FileId, part.AsFilePart().PartNum);
    }

    public IReadOnlyCollection<TLFilePart> GetBigFileParts(long fileId)
    {
        List<TLFilePart> parts = new();
        var iter = _storeBigFileParts.Iterate(fileId);
        foreach (var partBytes in iter)
        {
            var part = new TLFilePart(partBytes, 0, partBytes.Length);
            parts.Add(part);
        }

        return parts;
    }

    public bool PutUploadState(TLUploadPartState state)
    {
        var stateBytes = state.AsSpan().ToArray();
        var uploadState = state.AsUploadPartState();
        return _storeUploadStates.Put(stateBytes, uploadState.FileId, uploadState.IsBig ? 1 : 0);
    }

    public TLUploadPartState? GetUploadState(long fileId, bool isBigFile)
    {
        var stateBytes = _storeUploadStates.Get(fileId, isBigFile ? 1 : 0);
        if (stateBytes == null) return null;
        return new TLUploadPartState(stateBytes, 0, stateBytes.Length);
    }

    public bool PutFileReference(TLFileReference reference)
    {
        var referenceBytes = reference.AsSpan().ToArray();
        return _storeReferences.Put(referenceBytes, 
            reference.AsFileReference().ReferenceBytes.ToArray());
    }

    public TLFileReference? GetFileReference(byte[] referenceBytes)
    {
        var reference = _storeReferences.Get(referenceBytes);
        if (reference == null) return null;
        return new TLFileReference(reference, 0 , reference.Length);
    }
}