using Medallion.Threading;
using Medallion.Threading.Redis;
using System;
using System.Threading;
using System.Threading.Tasks;

namespace ApiTools.Core
{
    public static class DistributedLock
    {
        public static ValueTask<IDistributedSynchronizationHandle> TryAcquireAsync(
            this IDistributedLockProvider provider,
            string lockKey, TimeSpan timeout, CancellationToken cancellationToken = default)
        {
            lockKey = $"DistributedLock:{lockKey}";
            var @lock = provider.CreateLock(lockKey);
            return @lock.TryAcquireAsync(timeout, cancellationToken);
        }
    }
}