fix: positional parameters docblock for postgresql client

phpunit.xml.dist

@@ -62,6 +62,12 @@
         <testsuite name="lib-doctrine-dbal-bulk-integration">
             <directory>src/lib/doctrine-dbal-bulk/tests/Flow/Doctrine/Bulk/Tests/Integration</directory>
         </testsuite>
+        <testsuite name="lib-dremel-unit">
+            <directory>src/lib/dremel/tests/Flow/Dremel/Tests/Unit</directory>
+        </testsuite>
+        <testsuite name="lib-dremel-integration">
+            <directory>src/lib/dremel/tests/Flow/Dremel/Tests/Integration</directory>
+        </testsuite>
         <testsuite name="lib-filesystem-unit">
             <directory>src/lib/filesystem/tests/Flow/Filesystem/Tests/Unit</directory>
         </testsuite>
@@ -203,6 +209,9 @@
         <testsuite name="bridge-telemetry-otlp-integration">
             <directory>src/bridge/telemetry/otlp/tests/Flow/Bridge/Telemetry/OTLP/Tests/Integration</directory>
         </testsuite>
+        <testsuite name="adapter-avro-integration">
+            <directory>src/adapter/etl-adapter-avro/tests/Flow/ETL/Adapter/Avro/Tests/Integration</directory>
+        </testsuite>
         <testsuite name="adapter-chartjs-unit">
             <directory>src/adapter/etl-adapter-chartjs/tests/Flow/ETL/Adapter/ChartJS/Tests/Unit</directory>
         </testsuite>
@@ -262,6 +271,12 @@
         <testsuite name="adapter-parquet-integration">
             <directory>src/adapter/etl-adapter-parquet/tests/Flow/ETL/Adapter/Parquet/Tests/Integration</directory>
         </testsuite>
+        <testsuite name="adapter-postgresql-unit">
+            <directory>src/adapter/etl-adapter-postgresql/tests/Flow/ETL/Adapter/PostgreSql/Tests/Unit</directory>
+        </testsuite>
+        <testsuite name="adapter-postgresql-integration">
+            <directory>src/adapter/etl-adapter-postgresql/tests/Flow/ETL/Adapter/PostgreSql/Tests/Integration</directory>
+        </testsuite>
         <testsuite name="adapter-text-integration">
             <directory>src/adapter/etl-adapter-text/tests/Flow/ETL/Adapter/Text/Tests/Integration</directory>
         </testsuite>

src/adapter/etl-adapter-postgresql/src/Flow/ETL/Adapter/PostgreSql/PostgreSqlCursorExtractor.php

@@ -32,7 +32,7 @@ final class PostgreSqlCursorExtractor implements Extractor
     private ?Schema $schema = null;
 
     /**
-     * @param array<int, mixed> $parameters
+     * @param list<mixed> $parameters
      */
     public function __construct(
         private readonly Client $client,

src/adapter/etl-adapter-postgresql/src/Flow/ETL/Adapter/PostgreSql/PostgreSqlKeySetExtractor.php

@@ -22,7 +22,7 @@ final class PostgreSqlKeySetExtractor implements Extractor
     private ?Schema $schema = null;
 
     /**
-     * @param array<int, mixed> $parameters
+     * @param list<mixed> $parameters
      */
     public function __construct(
         private readonly Client $client,

src/adapter/etl-adapter-postgresql/src/Flow/ETL/Adapter/PostgreSql/PostgreSqlLimitOffsetExtractor.php

@@ -21,7 +21,7 @@ final class PostgreSqlLimitOffsetExtractor implements Extractor
     private ?Schema $schema = null;
 
     /**
-     * @param array<int, mixed> $parameters
+     * @param list<mixed> $parameters
      */
     public function __construct(
         private readonly Client $client,

src/adapter/etl-adapter-postgresql/src/Flow/ETL/Adapter/PostgreSql/functions.php

@@ -20,7 +20,7 @@
  *
  * @param Client $client PostgreSQL client
  * @param Sql|string $query SQL query to execute (wrapped in DECLARE CURSOR)
- * @param array<int, mixed> $parameters Positional parameters for the query
+ * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
  */
 #[DocumentationDSL(module: Module::POSTGRESQL, type: DSLType::EXTRACTOR)]
 function from_pgsql_cursor(
@@ -39,7 +39,7 @@ function from_pgsql_cursor(
  *
  * @param Client $client PostgreSQL client
  * @param Sql|string $query SQL query to execute (must have ORDER BY clause)
- * @param array<int, mixed> $parameters Positional parameters for the query
+ * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
  */
 #[DocumentationDSL(module: Module::POSTGRESQL, type: DSLType::EXTRACTOR)]
 function from_pgsql_limit_offset(
@@ -59,7 +59,7 @@ function from_pgsql_limit_offset(
  * @param Client $client PostgreSQL client
  * @param Sql|string $query SQL query to execute (must have ORDER BY matching keyset columns)
  * @param KeySet $keySet Columns to use for keyset pagination
- * @param array<int, mixed> $parameters Positional parameters for the query
+ * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
  */
 #[DocumentationDSL(module: Module::POSTGRESQL, type: DSLType::EXTRACTOR)]
 function from_pgsql_key_set(

src/lib/postgresql/src/Flow/PostgreSql/Client/Client.php

@@ -44,7 +44,7 @@ public function converters() : ValueConverters;
      * Use cursor->map() to map rows to objects.
      *
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      */
@@ -55,7 +55,7 @@ public function cursor(Sql|string $sql, array $parameters = []) : Cursor;
      * Returns the number of affected rows.
      *
      * @param Sql|string $sql SQL statement or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      */
@@ -66,7 +66,7 @@ public function execute(Sql|string $sql, array $parameters = []) : int;
      * Useful for analyzing query performance.
      *
      * @param Sql|string $sql SQL query to explain
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      * @param null|ExplainConfig $config EXPLAIN configuration (defaults to forAnalysis())
      *
      * @throws QueryException
@@ -78,7 +78,7 @@ public function explain(Sql|string $sql, array $parameters = [], ?ExplainConfig
      * Returns null if no rows found.
      *
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      *
@@ -90,7 +90,7 @@ public function fetch(Sql|string $sql, array $parameters = []) : ?array;
      * Fetch all rows from query result.
      *
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      *
@@ -105,7 +105,7 @@ public function fetchAll(Sql|string $sql, array $parameters = []) : array;
      *
      * @param RowMapper<T> $mapper Mapper to apply to each row
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      *
@@ -125,7 +125,7 @@ public function fetchAllInto(
      *
      * @param RowMapper<T> $mapper Mapper to apply to the row
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      *
@@ -142,7 +142,7 @@ public function fetchInto(
      * Use when you expect zero or one result (e.g., optional lookup by unique column).
      *
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      * @throws TooManyRowsException When the result contains more than one row
@@ -159,7 +159,7 @@ public function fetchOne(Sql|string $sql, array $parameters = []) : ?array;
      *
      * @param RowMapper<T> $mapper Mapper to apply to the row
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      * @throws TooManyRowsException When the result contains more than one row
@@ -177,7 +177,7 @@ public function fetchOneInto(
      * Ideal for COUNT(*), MAX(), MIN(), etc.
      *
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      */
@@ -187,7 +187,7 @@ public function fetchScalar(Sql|string $sql, array $parameters = []) : mixed;
      * Fetch a single boolean value from the first column of first row.
      *
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      */
@@ -197,7 +197,7 @@ public function fetchScalarBool(Sql|string $sql, array $parameters = []) : bool;
      * Fetch a single float value from the first column of first row.
      *
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      */
@@ -208,7 +208,7 @@ public function fetchScalarFloat(Sql|string $sql, array $parameters = []) : floa
      * Ideal for COUNT(*), MAX(), MIN(), etc.
      *
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      */
@@ -218,7 +218,7 @@ public function fetchScalarInt(Sql|string $sql, array $parameters = []) : int;
      * Fetch a single string value from the first column of first row.
      *
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      */
@@ -229,7 +229,7 @@ public function fetchScalarString(Sql|string $sql, array $parameters = []) : str
      * Use when you expect precisely one result (e.g., SELECT by primary key, INSERT ... RETURNING).
      *
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      * @throws NoResultException When the result is empty
@@ -247,7 +247,7 @@ public function fetchSingle(Sql|string $sql, array $parameters = []) : array;
      *
      * @param RowMapper<T> $mapper Mapper to apply to the row
      * @param Sql|string $sql SQL query or query builder with $1, $2, ... placeholders
-     * @param array<int, mixed> $parameters Positional parameters
+     * @param list<mixed> $parameters Values bound by position to $1, $2, ... placeholders; wrap with {@see \Flow\PostgreSql\DSL\typed()} to force a specific PostgreSQL type
      *
      * @throws QueryException
      * @throws NoResultException When the result is empty

src/lib/postgresql/src/Flow/PostgreSql/Client/Infrastructure/PgSql/PgSqlClient.php

@@ -530,7 +530,7 @@ private function assertConnected() : void
     }
 
     /**
-     * @param array<int, mixed> $parameters
+     * @param list<mixed> $parameters
      */
     private function buildContext(Sql|string $sql, array $parameters) : Context
     {
@@ -542,7 +542,7 @@ private function buildContext(Sql|string $sql, array $parameters) : Context
     }
 
     /**
-     * @param array<int, mixed> $parameters
+     * @param list<mixed> $parameters
      *
      * @return array<int, null|string>
      */
@@ -643,7 +643,7 @@ private function extractError(Connection $connection, ?Result $result) : Postgre
     }
 
     /**
-     * @param array<int, mixed> $parameters
+     * @param list<mixed> $parameters
      */
     private function query(Sql|string $sql, array $parameters) : Result
     {

src/lib/postgresql/src/Flow/PostgreSql/Client/Query.php

@@ -9,7 +9,7 @@
 final readonly class Query
 {
     /**
-     * @param array<int, mixed> $parameters
+     * @param list<mixed> $parameters
      */
     public function __construct(
         private Sql|string $sql,
@@ -18,7 +18,7 @@ public function __construct(
     }
 
     /**
-     * @return array<int, mixed>
+     * @return list<mixed>
      */
     public function parameters() : array
     {

src/lib/postgresql/src/Flow/PostgreSql/Client/Telemetry/TraceableClient.php

@@ -498,7 +498,7 @@ public function wait(int $milliseconds) : ?Notification
     }
 
     /**
-     * @param array<int, mixed> $parameters
+     * @param list<mixed> $parameters
      *
      * @return array<string, array<bool|float|int|string>|bool|float|int|string>
      */
@@ -623,7 +623,7 @@ private function completeTransactionSpan(int $nestingLevel, SpanStatus $status,
     }
 
     /**
-     * @param array<int, mixed> $parameters
+     * @param list<mixed> $parameters
      */
     private function logQuery(string $query, array $parameters) : void
     {
@@ -688,7 +688,7 @@ private function recordRowCount(int $rowCount, QueryAttributes $queryAttrs) : vo
     /**
      * @template T
      *
-     * @param array<int, mixed> $parameters
+     * @param list<mixed> $parameters
      * @param callable(): T $operation
      * @param null|callable(T): int $rowCountExtractor
      *

src/lib/postgresql/src/Flow/PostgreSql/Client/Telemetry/TraceableCursor.php

@@ -35,7 +35,7 @@ final class TraceableCursor implements Cursor
     private ?Tracer $tracer = null;
 
     /**
-     * @param array<int, mixed> $parameters
+     * @param list<mixed> $parameters
      */
     public function __construct(
         private readonly Cursor $cursor,

src/lib/telemetry/tests/Flow/Telemetry/Tests/Unit/Propagation/SuperglobalCarrierTest.php

@@ -40,6 +40,12 @@ protected function setUp() : void
         $_GET = [];
         $_POST = [];
         $_COOKIE = [];
+
+        foreach ($_SERVER as $key => $_) {
+            if (\is_string($key) && \str_starts_with($key, 'HTTP_')) {
+                unset($_SERVER[$key]);
+            }
+        }
     }
 
     protected function tearDown() : void