using MongoDB.Bson;

namespace FozFc.Api.Infrastructure.Mongo;

/// <summary>
/// Generic, schema-less document access over any collection. Returns raw BSON
/// documents (with <c>_id</c>); callers normalize for output at the API boundary.
/// </summary>
public interface IDocumentRepository
{
    Task<IReadOnlyList<BsonDocument>> FindAsync(string collection, BsonDocument filter, BsonDocument? sort, int limit, CancellationToken ct = default);

    Task<BsonDocument?> GetByIdAsync(string collection, string id, CancellationToken ct = default);

    Task<BsonDocument?> FindOneByFieldAsync(string collection, string field, BsonValue value, CancellationToken ct = default);

    Task InsertAsync(string collection, BsonDocument document, CancellationToken ct = default);

    /// <summary>Create-or-merge by id. Sets <c>createdAt</c> on insert and, optionally, <c>updatedAt</c>.</summary>
    Task<BsonDocument> UpsertAsync(string collection, string id, BsonDocument body, bool setUpdatedAt, CancellationToken ct = default);

    /// <summary>Update an existing document. Returns false when no document matched.</summary>
    Task<bool> UpdateAsync(string collection, string id, BsonDocument body, CancellationToken ct = default);

    Task DeleteAsync(string collection, string id, CancellationToken ct = default);
}