OracleDistributedSynchronizationProvider.cs

using System.Data;

namespace Medallion.Threading.Oracle;

/// <summary>
/// Implements <see cref="IDistributedLockProvider"/> for <see cref="OracleDistributedLock"/>
/// and <see cref="IDistributedUpgradeableReaderWriterLockProvider"/> for <see cref="OracleDistributedReaderWriterLock"/>
/// </summary>
public sealed class OracleDistributedSynchronizationProvider : IDistributedLockProvider, IDistributedUpgradeableReaderWriterLockProvider
{
    private readonly Func<string, bool, OracleDistributedLock> _lockFactory;
    private readonly Func<string, bool, OracleDistributedReaderWriterLock> _readerWriterLockFactory;

    /// <summary>
    /// Constructs a provider that connects with <paramref name="connectionString"/> and <paramref name="options"/>.
    /// </summary>
    public OracleDistributedSynchronizationProvider(string connectionString, Action<OracleConnectionOptionsBuilder>? options = null)
    {
        if (connectionString == null) { throw new ArgumentNullException(nameof(connectionString)); }

        this._lockFactory = (name, exactName) => new OracleDistributedLock(name, connectionString, options, exactName);
        this._readerWriterLockFactory = (name, exactName) => new OracleDistributedReaderWriterLock(name, connectionString, options, exactName);
    }

    /// <summary>
    /// Constructs a provider that connects with <paramref name="connection"/>.
    /// </summary>
    public OracleDistributedSynchronizationProvider(IDbConnection connection)
    {
        if (connection == null) { throw new ArgumentNullException(nameof(connection)); }

        this._lockFactory = (name, exactName) => new OracleDistributedLock(name, connection, exactName);
        this._readerWriterLockFactory = (name, exactName) => new OracleDistributedReaderWriterLock(name, connection, exactName);
    }

    /// <summary>
    /// Creates a <see cref="OracleDistributedLock"/> with the provided <paramref name="name"/>. Unless <paramref name="exactName"/> 
    /// is specified, invalid names will be escaped/hashed.
    /// </summary>
    public OracleDistributedLock CreateLock(string name, bool exactName = false) => this._lockFactory(name, exactName);

    IDistributedLock IDistributedLockProvider.CreateLock(string name) => this.CreateLock(name);

    /// <summary>
    /// Creates a <see cref="OracleDistributedReaderWriterLock"/> with the provided <paramref name="name"/>. Unless <paramref name="exactName"/> 
    /// is specified, invalid names will be escaped/hashed.
    /// </summary>
    public OracleDistributedReaderWriterLock CreateReaderWriterLock(string name, bool exactName = false) => this._readerWriterLockFactory(name, exactName);

    IDistributedUpgradeableReaderWriterLock IDistributedUpgradeableReaderWriterLockProvider.CreateUpgradeableReaderWriterLock(string name) =>
        this.CreateReaderWriterLock(name);

    IDistributedReaderWriterLock IDistributedReaderWriterLockProvider.CreateReaderWriterLock(string name) =>
        this.CreateReaderWriterLock(name);
}