Merge branch 'feat-adapters' of github.com:utopia-php/fetch into feat-adapters

Author: abnegate

.github/workflows/tests.yml

@@ -29,8 +29,7 @@ jobs:
 
       - name: Start Server
         run: |
-          docker compose up -d
-          sleep 5
+          docker compose up -d --wait --wait-timeout 30
 
       - name: Run Tests
         run: docker compose exec -T php vendor/bin/phpunit --configuration phpunit.xml

src/Adapter/Swoole.php

@@ -15,6 +15,8 @@
 use Utopia\Fetch\Options\Swoole as SwooleOptions;
 use Utopia\Fetch\Response;
 
+use function Swoole\Coroutine\run;
+
 /**
  * Swoole Adapter
  * HTTP adapter using Swoole's HTTP client
@@ -261,7 +263,7 @@ private function executeRequest(
 
             if (!$success) {
                 $errorCode = $client->errCode;
-                $errorMsg = socket_strerror($errorCode);
+                $errorMsg = $client->errMsg;
                 $this->closeClient($host, $port, $ssl);
                 throw new Exception("Request failed: {$errorMsg} (Code: {$errorCode})");
             }
@@ -367,8 +369,7 @@ public function send(
         $response = null;
         $exception = null;
 
-        $coRun = 'Swoole\\Coroutine\\run';
-        $coRun(function () use ($url, $method, $body, $headers, $options, $chunkCallback, &$response, &$exception) {
+        run(function () use ($url, $method, $body, $headers, $options, $chunkCallback, &$response, &$exception) {
             try {
                 $response = $this->executeRequest($url, $method, $body, $headers, $options, $chunkCallback);
             } catch (Throwable $e) {

src/Client.php

@@ -297,7 +297,7 @@ public function fetch(
             $body = match ($this->headers['content-type']) {
                 self::CONTENT_TYPE_APPLICATION_JSON => $this->jsonEncode($body),
                 self::CONTENT_TYPE_APPLICATION_FORM_URLENCODED, self::CONTENT_TYPE_MULTIPART_FORM_DATA => self::flatten($body),
-                self::CONTENT_TYPE_GRAPHQL => isset($body['query']) && is_string($body['query']) ? $body['query'] : throw new Exception('GraphQL body must contain a "query" field with a string value'),
+                self::CONTENT_TYPE_GRAPHQL => isset($body['query']) && is_string($body['query']) ? $body['query'] : $this->jsonEncode($body),
                 default => $body,
             };
         }