Added new Async class files

Author: powerpbx

src/AsyncClient.php

@@ -0,0 +1,67 @@
+<?php
+
+namespace DigitalOceanV2;
+
+use DigitalOceanV2\Client;
+use DigitalOceanV2\HttpClient\Builder;
+use DigitalOceanV2\HttpClient\AsyncBuilder;
+use DigitalOceanV2\HttpClient\Plugin\Authentication;
+
+class AsyncClient extends Client
+{
+    private AsyncBuilder $asyncBuilder;
+
+    public function __construct(?AsyncBuilder $asyncBuilder = null, ?string $apiKey = null, ?Builder $httpClientBuilder = null)
+    {
+        parent::__construct($httpClientBuilder);
+
+        $baseUri = self::BASE_URL;
+        $headers = [
+            'Accept' => 'application/json',
+            'User-Agent' => self::USER_AGENT,
+        ];
+        if ($apiKey) {
+            $headers['Authorization'] = 'Bearer ' . $apiKey;
+        }
+        $plugins = [];
+        if ($apiKey) {
+            $plugins[] = new Authentication($apiKey);
+        }
+        $this->asyncBuilder = $asyncBuilder ?? new AsyncBuilder($baseUri, $headers, $plugins);
+    }
+
+    /**
+     * Authenticate with a token (adds Authentication plugin).
+     */
+    public function authenticate(string $token): void
+    {
+        $this->asyncBuilder = new AsyncBuilder(
+            self::BASE_URL,
+            [
+                'Accept' => 'application/json',
+                'User-Agent' => self::USER_AGENT,
+                'Authorization' => 'Bearer ' . $token
+            ],
+            [new Authentication($token)]
+        );
+    }
+
+    /**
+     * Build and execute async requests for multiple endpoints.
+     * @param array $requests Array of ['key' => 'uri']
+     * @return array Array of responses keyed by 'key'
+     */
+    public function fetchAsync(array $requests)
+    {
+        $promises = $this->asyncBuilder->buildAsyncRequests($requests);
+        return $this->asyncBuilder->waitAll($promises);
+    }
+
+    /**
+     * Get the underlying AsyncBuilder instance.
+     */
+    public function getAsyncBuilder(): AsyncBuilder
+    {
+        return $this->asyncBuilder;
+    }
+}

src/HttpClient/AsyncBuilder.php

@@ -0,0 +1,91 @@
+<?php
+namespace DigitalOceanV2\HttpClient;
+
+use Http\Client\Common\Plugin;
+use Http\Client\Common\PluginClientFactory;
+use Http\Client\Common\Plugin\HeaderDefaultsPlugin;
+use Http\Client\Common\Plugin\AddHostPlugin;
+use Http\Client\Common\PluginClient;
+use Http\Discovery\HttpAsyncClientDiscovery;
+use Http\Discovery\Psr17FactoryDiscovery;
+use Http\Message\RequestFactory;
+use Http\Promise\Promise;
+use Psr\Http\Message\RequestFactoryInterface;
+use Psr\Http\Message\UriFactoryInterface;
+
+final class AsyncBuilder extends Builder
+{
+    private $httpAsyncClient;
+    private $requestFactory;
+    private $uriFactory;
+    private $plugins;
+    private $pluginClient;
+    private $baseUri;
+
+    public function __construct(
+        ?string $baseUri = null,
+        array $defaultHeaders = [],
+        array $plugins = []
+    ) {
+        $this->httpAsyncClient = HttpAsyncClientDiscovery::find();
+        $this->requestFactory = Psr17FactoryDiscovery::findRequestFactory();
+        $this->uriFactory = Psr17FactoryDiscovery::findUriFactory();
+        $this->baseUri = $baseUri ?? 'https://api.digitalocean.com';
+
+        // Add default header plugin
+        $this->plugins = $plugins;
+        if (!empty($defaultHeaders)) {
+            $this->plugins[] = new HeaderDefaultsPlugin($defaultHeaders);
+        }
+        // Add host plugin
+        $this->plugins[] = new AddHostPlugin($this->uriFactory->createUri($this->baseUri));
+
+        // Compose plugin client for async
+        $this->pluginClient = new PluginClient($this->httpAsyncClient, $this->plugins);
+    }
+
+    public function getAsyncClient()
+    {
+        return $this->pluginClient;
+    }
+
+    public function getRequestFactory(): RequestFactoryInterface
+    {
+        return $this->requestFactory;
+    }
+
+    public function getUriFactory(): UriFactoryInterface
+    {
+        return $this->uriFactory;
+    }
+
+    /**
+     * Build async GET requests for multiple endpoints.
+     * @param array $requests Array of ['key' => 'uri']
+     * @return array Array of promises keyed by 'key'
+     */
+    public function buildAsyncRequests(array $requests)
+    {
+        $promises = [];
+        foreach ($requests as $key => $uri) {
+            $request = $this->requestFactory->createRequest('GET', $uri);
+            $promises[$key] = $this->pluginClient->sendAsyncRequest($request);
+        }
+        return $promises;
+    }
+
+    /**
+     * Wait for all promises to complete and return results.
+     * @param array $promises
+     * @return array
+     */
+    public function waitAll(array $promises)
+    {
+        // There is no PromiseSettler in php-http/promise, so we manually wait for each
+        $results = [];
+        foreach ($promises as $key => $promise) {
+            $results[$key] = $promise->wait();
+        }
+        return $results;
+    }
+}