Make sure AwsClient is useful (#184)

* Make sure AwsClient is useful

* Dont extend AbstractClient

* Rebase

Author: Nyholm

AwsClient.php

@@ -5,28 +5,81 @@
 namespace AsyncAws\Core;
 
 use AsyncAws\CloudFormation\CloudFormationClient;
+use AsyncAws\Core\Credentials\CacheProvider;
+use AsyncAws\Core\Credentials\ChainProvider;
+use AsyncAws\Core\Credentials\ConfigurationProvider;
+use AsyncAws\Core\Credentials\CredentialProvider;
+use AsyncAws\Core\Credentials\IniFileProvider;
+use AsyncAws\Core\Credentials\InstanceProvider;
+use AsyncAws\Core\Exception\InvalidArgument;
 use AsyncAws\Core\Exception\MissingDependency;
-use AsyncAws\Core\Exception\RuntimeException;
 use AsyncAws\Core\Sts\StsClient;
+use AsyncAws\Lambda\LambdaClient;
 use AsyncAws\S3\S3Client;
 use AsyncAws\Ses\SesClient;
+use AsyncAws\Sns\SnsClient;
 use AsyncAws\Sqs\SqsClient;
+use Psr\Log\LoggerInterface;
+use Psr\Log\NullLogger;
+use Symfony\Component\HttpClient\HttpClient;
+use Symfony\Contracts\HttpClient\HttpClientInterface;
 
 /**
  * Base API client that instantiate other API classes if needed.
  *
  * @author Tobias Nyholm <[email protected]>
  */
-class AwsClient extends AbstractApi
+class AwsClient
 {
     /**
      * @var array
      */
     private $serviceCache;
 
+    /**
+     * @var HttpClientInterface
+     */
+    private $httpClient;
+
+    /**
+     * @var Configuration
+     */
+    private $configuration;
+
+    /**
+     * @var CredentialProvider
+     */
+    private $credentialProvider;
+
+    /**
+     * @var LoggerInterface|null
+     */
+    private $logger;
+
+    /**
+     * @param Configuration|array $configuration
+     */
+    public function __construct($configuration = [], ?CredentialProvider $credentialProvider = null, ?HttpClientInterface $httpClient = null, ?LoggerInterface $logger = null)
+    {
+        if (\is_array($configuration)) {
+            $configuration = Configuration::create($configuration);
+        } elseif (!$configuration instanceof Configuration) {
+            throw new InvalidArgument(sprintf('Second argument to "%s::__construct()" must be an array or an instance of "%s"', __CLASS__, Configuration::class));
+        }
+
+        $this->httpClient = $httpClient ?? HttpClient::create();
+        $this->logger = $logger ?? new NullLogger();
+        $this->configuration = $configuration;
+        $this->credentialProvider = $credentialProvider ?? new CacheProvider(new ChainProvider([
+            new ConfigurationProvider(),
+            new IniFileProvider($this->logger),
+            new InstanceProvider($this->httpClient, $this->logger),
+        ]));
+    }
+
     public function cloudFormation(): CloudFormationClient
     {
-        if (!class_exists(S3Client::class)) {
+        if (!class_exists(CloudFormationClient::class)) {
             throw MissingDependency::create('async-aws/cloud-formation', 'CloudFormation');
         }
 
@@ -37,14 +90,14 @@ public function cloudFormation(): CloudFormationClient
         return $this->serviceCache[__METHOD__];
     }
 
-    public function sts(): StsClient
+    public function lambda(): LambdaClient
     {
-        if (!class_exists(StsClient::class)) {
-            throw MissingDependency::create('async-aws/core', 'STS');
+        if (!class_exists(LambdaClient::class)) {
+            throw MissingDependency::create('async-aws/lambda', 'Lambda');
         }
 
         if (!isset($this->serviceCache[__METHOD__])) {
-            $this->serviceCache[__METHOD__] = new StsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
+            $this->serviceCache[__METHOD__] = new LambdaClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
         }
 
         return $this->serviceCache[__METHOD__];
@@ -76,33 +129,42 @@ public function ses(): SesClient
         return $this->serviceCache[__METHOD__];
     }
 
-    public function sqs(): SqsClient
+    public function sns(): SnsClient
     {
-        if (!class_exists(SqsClient::class)) {
-            throw MissingDependency::create('async-aws/sqs', 'SQS');
+        if (!class_exists(SnsClient::class)) {
+            throw MissingDependency::create('async-aws/sns', 'SNS');
         }
 
         if (!isset($this->serviceCache[__METHOD__])) {
-            $this->serviceCache[__METHOD__] = new SqsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
+            $this->serviceCache[__METHOD__] = new SnsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
         }
 
         return $this->serviceCache[__METHOD__];
     }
 
-    protected function getServiceCode(): string
+    public function sts(): StsClient
     {
-        // This will never work on the base API. .
-        throw new RuntimeException(sprintf('The $endpoint parameter is required on "%s::request()".', __CLASS__));
-    }
+        if (!class_exists(StsClient::class)) {
+            throw MissingDependency::create('async-aws/core', 'STS');
+        }
 
-    protected function getSignatureScopeName(): string
-    {
-        // This will never work on the base API. .
-        throw new RuntimeException(\sprintf('The signing name is required on "%s".', __CLASS__));
+        if (!isset($this->serviceCache[__METHOD__])) {
+            $this->serviceCache[__METHOD__] = new StsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
+        }
+
+        return $this->serviceCache[__METHOD__];
     }
 
-    protected function getSignatureVersion(): string
+    public function sqs(): SqsClient
     {
-        return 'v4';
+        if (!class_exists(SqsClient::class)) {
+            throw MissingDependency::create('async-aws/sqs', 'SQS');
+        }
+
+        if (!isset($this->serviceCache[__METHOD__])) {
+            $this->serviceCache[__METHOD__] = new SqsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
+        }
+
+        return $this->serviceCache[__METHOD__];
     }
 }