Rewrite locker API

Author: antonkomarev

src/Locker/AdvisoryLockSessionLevel.php

@@ -16,6 +16,9 @@
 use Cog\DbLocker\LockId\PostgresLockId;
 use PDO;
 
+/**
+ * @internal
+ */
 final class AdvisoryLockSessionLevel
 {
     private bool $isReleased = false;

src/Locker/AdvisoryLockTransactionLevel.php

@@ -0,0 +1,24 @@
+<?php
+
+/*
+ * This file is part of PHP DB Locker.
+ *
+ * (c) Anton Komarev <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Cog\DbLocker\Locker;
+
+/**
+ * @internal
+ */
+final class AdvisoryLockTransactionLevel
+{
+    public function __construct(
+        public readonly bool $wasAcquired,
+    ) {}
+}

src/Locker/PostgresAdvisoryLocker.php

@@ -20,7 +20,29 @@
 final class PostgresAdvisoryLocker
 {
     /**
-     * Acquire a transaction-level advisory lock with a configurable acquisition type and mode.
+     * Acquire a transaction-level advisory lock with configurable wait and access modes.
+     *
+     * TODO: Cover with tests
+     */
+    public function acquireTransactionLevelLockHandler(
+        PDO $dbConnection,
+        PostgresLockId $postgresLockId,
+        PostgresAdvisoryLockWaitModeEnum $waitMode = PostgresAdvisoryLockWaitModeEnum::NonBlocking,
+        PostgresLockAccessModeEnum $accessMode = PostgresLockAccessModeEnum::Exclusive,
+    ): AdvisoryLockTransactionLevel {
+        return new AdvisoryLockTransactionLevel(
+            wasAcquired: $this->acquireLock(
+                $dbConnection,
+                $postgresLockId,
+                PostgresAdvisoryLockLevelEnum::Transaction,
+                $waitMode,
+                $accessMode,
+            ),
+        );
+    }
+
+    /**
+     * Acquire a transaction-level advisory lock with configurable wait and access modes.
      */
     public function acquireTransactionLevelLock(
         PDO $dbConnection,
@@ -38,7 +60,7 @@ public function acquireTransactionLevelLock(
     }
 
     /**
-     * Acquire a session-level advisory lock with a configurable wait & access modes.
+     * Acquire a session-level advisory lock with configurable wait and access modes.
      *
      * TODO: Write that transaction-level is recommended.
      * TODO: Cover with tests
@@ -65,7 +87,7 @@ public function acquireSessionLevelLockHandler(
     }
 
     /**
-     * Acquire a session-level advisory lock with a configurable wait & access modes.
+     * Acquire a session-level advisory lock with configurable wait and access modes.
      *
      * TODO: Write that transaction-level is recommended.
      */