Update message-bus and use AmphpPostgresTransaction as TTransaction

Author: vudaltsov

composer.lock

@@ -6,6 +6,7 @@
 
 use Amp\Postgres\PostgresByteA;
 use Amp\Postgres\PostgresLink;
+use Amp\Postgres\PostgresTransaction as AmphpPostgresTransaction;
 use Thesis\MessageBus\Envelope;
 use Thesis\MessageBus\Persistence\Outbox;
 use Thesis\MessageBus\Persistence\OutboxDoesNotExist;
@@ -14,7 +15,7 @@
 
 /**
  * @api
- * @implements StorageSetup<PostgresTransaction>
+ * @implements StorageSetup<AmphpPostgresTransaction>
  */
 final readonly class PostgresStorage implements StorageSetup
 {
@@ -44,7 +45,7 @@ public function setup(): void
     public function beginTransaction(): Transaction
     {
         return new PostgresTransaction(
-            transaction: $this->connection->beginTransaction(),
+            wrappedTransaction: $this->connection->beginTransaction(),
             outboxTable: $this->outboxTable,
         );
     }

src/PostgresStorage.php

@@ -14,21 +14,22 @@
 
 /**
  * @api
+ * @implements Transaction<AmphpPostgresTransaction>
  */
 final readonly class PostgresTransaction implements Transaction
 {
     /**
      * @param non-empty-string $outboxTable
      */
     public function __construct(
-        public AmphpPostgresTransaction $transaction,
+        public AmphpPostgresTransaction $wrappedTransaction,
         private string $outboxTable,
     ) {}
 
     public function commit(Outbox $outbox): void
     {
         try {
-            $result = $this->transaction->execute(
+            $result = $this->wrappedTransaction->execute(
                 <<<SQL
                     insert into {$this->outboxTable} (endpoint, message_id, envelopes)
                     values (?, ?, ?)
@@ -45,7 +46,7 @@ public function commit(Outbox $outbox): void
                 throw new OutboxAlreadyExists();
             }
 
-            $this->transaction->commit();
+            $this->wrappedTransaction->commit();
         } catch (SqlTransactionError $exception) {
             throw new TransactionClosed(previous: $exception);
         }
@@ -54,7 +55,7 @@ public function commit(Outbox $outbox): void
     public function rollback(): void
     {
         try {
-            $this->transaction->rollback();
+            $this->wrappedTransaction->rollback();
         } catch (SqlTransactionError $exception) {
             throw new TransactionClosed(previous: $exception);
         }