feat: support clickhouse timezone input in ParamValueConverterRegistry

Author: simPod

src/Param/ParamValueConverterRegistry.php

@@ -6,9 +6,11 @@
 
 use Closure;
 use DateTimeInterface;
+use DateTimeZone;
 use Psr\Http\Message\StreamInterface;
 use SimPod\ClickHouseClient\Exception\UnsupportedParamType;
 use SimPod\ClickHouseClient\Sql\Escaper;
+use SimPod\ClickHouseClient\Exception\UnsupportedParamValue;
 use SimPod\ClickHouseClient\Sql\Type;
 
 use function array_keys;
@@ -18,6 +20,8 @@
 use function implode;
 use function in_array;
 use function is_array;
+use function is_float;
+use function is_int;
 use function is_string;
 use function json_encode;
 use function sprintf;
@@ -26,13 +30,12 @@
 use function trim;
 
 /**
- * @phpstan-type Converter = Closure(mixed, Type|string|null, bool):(StreamInterface|string)
- * @phpstan-type ConverterRegistry = array<string, Converter>
+ * @phpstan-type Converter Closure(mixed, Type|string|null, bool):(StreamInterface|string)
+ * @phpstan-type ConverterRegistry array<string, Converter>
  */
-final class ParamValueConverterRegistry
+final readonly class ParamValueConverterRegistry
 {
-    /** @var list<string> */
-    private static array $caseInsensitiveTypes = [
+    private const CaseInsensitiveTypes = [
         'bool',
         'date',
         'date32',
@@ -90,10 +93,10 @@ public function __construct(array $registry = [])
 
             'bool' => static fn (bool $value) => $value,
 
-            'date' => self::dateConverter(),
-            'date32' => self::dateConverter(),
-            'datetime' => self::dateTimeConverter(),
-            'datetime32' => self::dateTimeConverter(),
+            'date' => self::dateConverter($this->clickHouseTimeZone),
+            'date32' => self::dateConverter($this->clickHouseTimeZone),
+            'datetime' => self::dateTimeConverter($this->clickHouseTimeZone),
+            'datetime32' => self::dateTimeConverter($this->clickHouseTimeZone),
             'datetime64' => static fn (DateTimeInterface|string|int|float $value) => $value instanceof DateTimeInterface
                 ? $value->format('U.u')
                 : $value,
@@ -232,7 +235,7 @@ public function get(Type|string $type): Closure
 
         $typeName  = strtolower($typeName);
         $converter = $this->registry[$typeName] ?? null;
-        if ($converter !== null && in_array($typeName, self::$caseInsensitiveTypes, true)) {
+        if ($converter !== null && in_array($typeName, self::CaseInsensitiveTypes, true)) {
             return $converter;
         }
 
@@ -271,17 +274,32 @@ private static function decimalConverter(): Closure
 
     private static function dateConverter(): Closure
     {
-        return static fn (DateTimeInterface|string|int|float $value) => $value instanceof DateTimeInterface
-            // We cannot convert to timestamp yet https://github.com/ClickHouse/ClickHouse/issues/75217
-            ? $value->format('Y-m-d')
-            : $value;
+        return static function (mixed $value) {
+            if ($value instanceof DateTimeInterface) {
+                return $value->format('Y-m-d');
+            }
+
+            if (is_string($value) || is_float($value) || is_int($value)) {
+                return $value;
+            }
+
+            throw UnsupportedParamValue::type($value);
+        };
     }
 
     private static function dateTimeConverter(): Closure
     {
-        return static fn (DateTimeInterface|string|int|float $value) => $value instanceof DateTimeInterface
-            ? $value->getTimestamp()
-            : $value;
+        return static function (mixed $value) {
+            if ($value instanceof DateTimeInterface) {
+                return $value->getTimestamp();
+            }
+
+            if (is_string($value) || is_float($value) || is_int($value)) {
+                return $value;
+            }
+
+            throw UnsupportedParamValue::type($value);
+        };
     }
 
     private static function dateIntervalConverter(): Closure