using Application.Services.Database;
using MongoDB.Bson;
using MongoDB.Driver;

namespace Infrastructure.Services.MongoDB;

public class MongoDbService : IMongoDbService
{
    private readonly IMongoDatabase _database;

    public MongoDbService(string connectionString)
    {
        var settings = MongoClientSettings.FromConnectionString(connectionString);
        settings.ServerApi = new ServerApi(ServerApiVersion.V1);
        var _database = new MongoClient(settings);
        
        try {
            var result = _database.GetDatabase("admin").RunCommand<BsonDocument>(new BsonDocument("ping", 1));
            Console.WriteLine("Pinged your deployment. You successfully connected to MongoDB!");
        } catch (Exception ex) {
            Console.WriteLine(ex);
        }
    }

    public IMongoCollection<T> GetCollection<T>(string collectionName)
    {
        return _database.GetCollection<T>(collectionName);
    }

    public async Task<List<T>> FindAsync<T>(string collectionName, List<(string FieldName, string Value)> criteria)
    {
        var collection = _database.GetCollection<T>(collectionName);

        var filters = new List<FilterDefinition<T>>();
        foreach (var (FieldName, Value) in criteria) filters.Add(Builders<T>.Filter.Eq(FieldName, Value));

        var combinedFilter = Builders<T>.Filter.And(filters);

        return await collection.Find(combinedFilter).ToListAsync();
    }

    public async Task AddAsync<T>(string collectionName, T document)
    {
        var collection = _database.GetCollection<T>(collectionName);
        await collection.InsertOneAsync(document);
    }

    public async Task ModifyAsync<T>(string collectionName, string keyField, string keyValue, T document)
    {
        var collection = _database.GetCollection<T>(collectionName);
        var filter = Builders<T>.Filter.Eq(keyField, keyValue);
        await collection.ReplaceOneAsync(filter, document, new ReplaceOptions { IsUpsert = true });
    }

    public async Task DeleteAsync<T>(string collectionName, string keyField, string keyValue)
    {
        var collection = _database.GetCollection<T>(collectionName);
        var filter = Builders<T>.Filter.Eq(keyField, keyValue);
        await collection.DeleteOneAsync(filter);
    }
}