using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using BTCPayServer.Data;
using Microsoft.EntityFrameworkCore;
using NBitcoin;
using NBXplorer.Models;

namespace BTCPayServer.Payments.PayJoin
{
    public class PayJoinRepository
    {
        private readonly ApplicationDbContextFactory _dbContextFactory;

        public PayJoinRepository(ApplicationDbContextFactory dbContextFactory)
        {
            _dbContextFactory = dbContextFactory;
        }
        public async Task<bool> TryLock(OutPoint outpoint)
        {
            using var ctx = _dbContextFactory.CreateContext();
            ctx.PayjoinLocks.Add(new PayjoinLock()
            {
                Id = outpoint.ToString()
            });
            try
            {
                return await ctx.SaveChangesAsync() == 1;
            }
            catch (DbUpdateException)
            {
                return false;
            }
        }

        public async Task<bool> TryUnlock(params OutPoint[] outPoints)
        {
            using var ctx = _dbContextFactory.CreateContext();
            foreach (OutPoint outPoint in outPoints)
            {
                ctx.PayjoinLocks.Remove(new PayjoinLock()
                {
                    Id = outPoint.ToString()
                });
            }
            try
            {
                return await ctx.SaveChangesAsync() == outPoints.Length;
            }
            catch (DbUpdateException)
            {
                return false;
            }
        }

        public async Task<bool> TryLockInputs(OutPoint[] outPoints)
        {
            using var ctx = _dbContextFactory.CreateContext();
            foreach (OutPoint outPoint in outPoints)
            {
                ctx.PayjoinLocks.Add(new PayjoinLock()
                {
                    // Random flag so it does not lock same id
                    // as the lock utxo
                    Id = "K-" + outPoint.ToString()
                });
            }
            try
            {
                return await ctx.SaveChangesAsync() == outPoints.Length;
            }
            catch (DbUpdateException)
            {
                return false;
            }
        }
    }
}