Use Swoole\Http\Client when coroutines=false

- coroutines=true: Uses Swoole\Coroutine\Http\Client (default)
- coroutines=false: Uses Swoole\Http\Client (sync/blocking)

Updated type hints to support both client types via union types.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: abnegate

src/Adapter/Swoole.php

@@ -6,7 +6,7 @@
 
 use CURLFile;
 use Swoole\Coroutine;
-use Swoole\Coroutine\Http\Client as SwooleClient;
+use Swoole\Coroutine\Http\Client as CoClient;
 use Throwable;
 use Utopia\Fetch\Adapter;
 use Utopia\Fetch\Chunk;
@@ -15,13 +15,13 @@
 
 /**
  * Swoole Adapter
- * HTTP adapter using Swoole's coroutine HTTP client
+ * HTTP adapter using Swoole's HTTP client
  * @package Utopia\Fetch\Adapter
  */
 class Swoole implements Adapter
 {
     /**
-     * @var array<string, SwooleClient>
+     * @var array<string, CoClient|\Swoole\Http\Client>
      */
     private array $clients = [];
 
@@ -38,7 +38,7 @@ class Swoole implements Adapter
     /**
      * Create a new Swoole adapter
      *
-     * @param bool $coroutines If true, automatically wraps requests in a coroutine scheduler when not already in a coroutine context. Set to false when running inside a Swoole server.
+     * @param bool $coroutines If true, uses Swoole\Coroutine\Http\Client. If false, uses Swoole\Http\Client (sync/blocking).
      * @param bool $keepAlive Enable HTTP keep-alive for connection reuse
      * @param int $socketBufferSize Socket buffer size in bytes
      * @param bool $httpCompression Enable HTTP compression (gzip, br)
@@ -99,13 +99,13 @@ public function __construct(
     }
 
     /**
-     * Check if Swoole is available
+     * Check if Swoole coroutine client is available
      *
      * @return bool
      */
     public static function isAvailable(): bool
     {
-        return class_exists(SwooleClient::class);
+        return class_exists(CoClient::class) || class_exists(\Swoole\Http\Client::class);
     }
 
     /**
@@ -114,14 +114,19 @@ public static function isAvailable(): bool
      * @param string $host
      * @param int $port
      * @param bool $ssl
-     * @return SwooleClient
+     * @return CoClient|\Swoole\Http\Client
      */
-    private function getClient(string $host, int $port, bool $ssl): SwooleClient
+    private function getClient(string $host, int $port, bool $ssl): object
     {
         $key = "{$host}:{$port}:" . ($ssl ? '1' : '0');
 
         if (!isset($this->clients[$key])) {
-            $this->clients[$key] = new SwooleClient($host, $port, $ssl);
+            if ($this->coroutines) {
+                $this->clients[$key] = new CoClient($host, $port, $ssl);
+            } else {
+                /** @phpstan-ignore-next-line */
+                $this->clients[$key] = new \Swoole\Http\Client($host, $port, $ssl);
+            }
         }
 
         return $this->clients[$key];
@@ -148,12 +153,12 @@ private function closeClient(string $host, int $port, bool $ssl): void
     /**
      * Configure body data on the client
      *
-     * @param SwooleClient $client
+     * @param CoClient|\Swoole\Http\Client $client
      * @param mixed $body
      * @param array<string, string> $headers
      * @return void
      */
-    private function configureBody(SwooleClient $client, mixed $body, array $headers): void
+    private function configureBody(object $client, mixed $body, array $headers): void
     {
         if ($body === null) {
             return;
@@ -374,12 +379,12 @@ public function send(
             throw new Exception('Swoole extension is not installed');
         }
 
-        // If coroutines are disabled or we're already in a coroutine, execute directly
+        // If using sync client or already in a coroutine, execute directly
         if (!$this->coroutines || Coroutine::getCid() > 0) {
             return $this->executeRequest($url, $method, $body, $headers, $options, $chunkCallback);
         }
 
-        // Wrap in coroutine scheduler
+        // Wrap in coroutine scheduler for coroutine client
         $response = null;
         $exception = null;