From 87484c19968010b0c1c6df4bcfe532b452cf934d Mon Sep 17 00:00:00 2001
From: Jerome Thayananthajothy <tjthavarshan@gmail.com>
Date: Sun, 29 Sep 2024 15:25:55 +0100
Subject: [PATCH] Refactor client handling to use custom async task management
 and add fluent API

---
 src/Fetch/Http/ClientHandler.php |  4 +++
 tests/Unit/FetchTest.php         | 44 ++++++++------------------------
 2 files changed, 15 insertions(+), 33 deletions(-)

diff --git a/src/Fetch/Http/ClientHandler.php b/src/Fetch/Http/ClientHandler.php
index e6291a2..0c92ca1 100644
--- a/src/Fetch/Http/ClientHandler.php
+++ b/src/Fetch/Http/ClientHandler.php
@@ -89,6 +89,10 @@ public static function handle(string $method, string $uri, array $options = [])
      */
     protected function applyOptions(array $options): void
     {
+        if (isset($options['client'])) {
+            $this->setSyncClient($options['client']);
+        }
+
         $this->options = array_merge($this->options, $options);
 
         if (isset($options['timeout'])) {
diff --git a/tests/Unit/FetchTest.php b/tests/Unit/FetchTest.php
index 75b63e8..4de1fcf 100644
--- a/tests/Unit/FetchTest.php
+++ b/tests/Unit/FetchTest.php
@@ -1,6 +1,5 @@
 <?php
 
-use Fetch\Http\ClientHandler;
 use Fetch\Http\Response;
 use GuzzleHttp\Client;
 use GuzzleHttp\Exception\RequestException;
@@ -22,10 +21,7 @@
             ->andReturn(new Response(200, [], json_encode(['success' => true])));
     });
 
-    $clientHandler = new ClientHandler();
-    $clientHandler->setSyncClient($mockClient);
-
-    $response = fetch('https://example.com');
+    $response = fetch('https://example.com', ['client' => $mockClient]);
 
     expect($response->json())->toBe(['success' => true]);
     expect($response->getStatusCode())->toBe(200);
@@ -42,10 +38,7 @@
             ->andReturn(new Response(200, [], json_encode(['async' => 'result'])));
     });
 
-    $clientHandler = new ClientHandler();
-    $clientHandler->setSyncClient($mockClient);
-
-    async(fn () => fetch('https://example.com', ['async' => true]))
+    async(fn () => fetch('https://example.com', ['client' => $mockClient]))
         ->then(function (Response $response) {
             expect($response->json())->toBe(['async' => 'result']);
             expect($response->getStatusCode())->toBe(200);
@@ -68,11 +61,9 @@
             ->andReturn(new Response(200, [], 'Headers checked'));
     });
 
-    $clientHandler = new ClientHandler();
-    $clientHandler->setSyncClient($mockClient);
-
     $response = fetch('https://example.com', [
-        'headers' => ['Authorization' => 'Bearer token']
+        'headers' => ['Authorization' => 'Bearer token'],
+        'client' => $mockClient
     ]);
 
     expect($response->text())->toBe('Headers checked');
@@ -91,11 +82,9 @@
             ->andReturn(new Response(200, [], 'Query params checked'));
     });
 
-    $clientHandler = new ClientHandler();
-    $clientHandler->setSyncClient($mockClient);
-
     $response = fetch('https://example.com', [
-        'query' => ['foo' => 'bar', 'baz' => 'qux']
+        'query' => ['foo' => 'bar', 'baz' => 'qux'],
+        'client' => $mockClient
     ]);
 
     expect($response->text())->toBe('Query params checked');
@@ -114,11 +103,8 @@
             ->andThrow(new RequestException('Timeout', new Request('GET', 'https://example.com')));
     });
 
-    $clientHandler = new ClientHandler();
-    $clientHandler->setSyncClient($mockClient);
-
     try {
-        fetch('https://example.com', ['timeout' => 1]);
+        fetch('https://example.com', ['timeout' => 1, 'client' => $mockClient]);
     } catch (RequestException $e) {
         expect($e->getMessage())->toContain('Timeout');
     }
@@ -139,10 +125,7 @@
             ->andReturn(new Response(200, [], 'Success after retry'));
     });
 
-    $clientHandler = new ClientHandler();
-    $clientHandler->setSyncClient($mockClient);
-
-    $response = fetch('https://example.com', ['retries' => 2]);
+    $response = fetch('https://example.com', ['retries' => 2, 'client' => $mockClient]);
 
     expect($response->text())->toBe('Success after retry');
 });
@@ -160,12 +143,10 @@
             ->andReturn(new Response(201, [], 'Created'));
     });
 
-    $clientHandler = new ClientHandler();
-    $clientHandler->setSyncClient($mockClient);
-
     $response = fetch('https://example.com/users', [
         'method' => 'POST',
-        'body' => json_encode(['name' => 'John'])
+        'body' => json_encode(['name' => 'John']),
+        'client' => $mockClient
     ]);
 
     expect($response->getStatusCode())->toBe(201);
@@ -187,10 +168,7 @@
             ->andReturn(new Response(200, [], 'Success after retry'));
     });
 
-    $clientHandler = new ClientHandler();
-    $clientHandler->setSyncClient($mockClient);
-
-    async(fn () => fetch('https://example.com', ['retries' => 2, 'async' => true]))
+    async(fn () => fetch('https://example.com', ['retries' => 2, 'client' => $mockClient]))
         ->then(function (Response $response) {
             expect($response->text())->toBe('Success after retry');
         })