Viewing file:  AwsClientFactory.php (20 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
declare(strict_types=1);
namespace AsyncAws\Core;
use AsyncAws\AppSync\AppSyncClient;
use AsyncAws\CloudFormation\CloudFormationClient;
use AsyncAws\CloudFront\CloudFrontClient;
use AsyncAws\CloudWatch\CloudWatchClient;
use AsyncAws\CloudWatchLogs\CloudWatchLogsClient;
use AsyncAws\CodeBuild\CodeBuildClient;
use AsyncAws\CodeCommit\CodeCommitClient;
use AsyncAws\CodeDeploy\CodeDeployClient;
use AsyncAws\CognitoIdentityProvider\CognitoIdentityProviderClient;
use AsyncAws\Comprehend\ComprehendClient;
use AsyncAws\Core\Credentials\CacheProvider;
use AsyncAws\Core\Credentials\ChainProvider;
use AsyncAws\Core\Credentials\CredentialProvider;
use AsyncAws\Core\Exception\InvalidArgument;
use AsyncAws\Core\Exception\MissingDependency;
use AsyncAws\Core\Sts\StsClient;
use AsyncAws\DynamoDb\DynamoDbClient;
use AsyncAws\Ecr\EcrClient;
use AsyncAws\ElastiCache\ElastiCacheClient;
use AsyncAws\EventBridge\EventBridgeClient;
use AsyncAws\Firehose\FirehoseClient;
use AsyncAws\Iam\IamClient;
use AsyncAws\Iot\IotClient;
use AsyncAws\IotData\IotDataClient;
use AsyncAws\Kinesis\KinesisClient;
use AsyncAws\Kms\KmsClient;
use AsyncAws\Lambda\LambdaClient;
use AsyncAws\RdsDataService\RdsDataServiceClient;
use AsyncAws\Rekognition\RekognitionClient;
use AsyncAws\Route53\Route53Client;
use AsyncAws\S3\S3Client;
use AsyncAws\Scheduler\SchedulerClient;
use AsyncAws\SecretsManager\SecretsManagerClient;
use AsyncAws\Ses\SesClient;
use AsyncAws\Sns\SnsClient;
use AsyncAws\Sqs\SqsClient;
use AsyncAws\Ssm\SsmClient;
use AsyncAws\StepFunctions\StepFunctionsClient;
use AsyncAws\TimestreamQuery\TimestreamQueryClient;
use AsyncAws\TimestreamWrite\TimestreamWriteClient;
use AsyncAws\Translate\TranslateClient;
use AsyncAws\XRay\XRayClient;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;
use Symfony\Component\HttpClient\HttpClient;
use Symfony\Contracts\HttpClient\HttpClientInterface;
/**
* Factory that instantiate API clients.
*
* @author Tobias Nyholm <tobias.nyholm@gmail.com>
*/
class AwsClientFactory
{
/**
* @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(ChainProvider::createDefaultChain($this->httpClient, $this->logger));
}
public function appSync(): AppSyncClient
{
if (!class_exists(AppSyncClient::class)) {
throw MissingDependency::create('async-aws/app-sync', 'AppSync');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new AppSyncClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function cloudFormation(): CloudFormationClient
{
if (!class_exists(CloudFormationClient::class)) {
throw MissingDependency::create('async-aws/cloud-formation', 'CloudFormation');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new CloudFormationClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function cloudFront(): CloudFrontClient
{
if (!class_exists(CloudFrontClient::class)) {
throw MissingDependency::create('async-aws/cloud-front', 'CloudFront');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new CloudFrontClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function cloudWatch(): CloudWatchClient
{
if (!class_exists(CloudWatchClient::class)) {
throw MissingDependency::create('async-aws/cloud-watch', 'CloudWatch');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new CloudWatchClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function cloudWatchLogs(): CloudWatchLogsClient
{
if (!class_exists(CloudWatchLogsClient::class)) {
throw MissingDependency::create('async-aws/cloud-watch-logs', 'CloudWatchLogs');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new CloudWatchLogsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function codeBuild(): CodeBuildClient
{
if (!class_exists(CodeBuildClient::class)) {
throw MissingDependency::create('async-aws/code-build', 'CodeBuild');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new CodeBuildClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function codeCommit(): CodeCommitClient
{
if (!class_exists(CodeCommitClient::class)) {
throw MissingDependency::create('async-aws/code-commit', 'CodeCommit');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new CodeCommitClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function codeDeploy(): CodeDeployClient
{
if (!class_exists(CodeDeployClient::class)) {
throw MissingDependency::create('async-aws/code-deploy', 'CodeDeploy');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new CodeDeployClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function comprehend(): ComprehendClient
{
if (!class_exists(ComprehendClient::class)) {
throw MissingDependency::create('async-aws/comprehend', 'ComprehendClient');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new ComprehendClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function dynamoDb(): DynamoDbClient
{
if (!class_exists(DynamoDbClient::class)) {
throw MissingDependency::create('async-aws/dynamo-db', 'DynamoDb');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new DynamoDbClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function ecr(): EcrClient
{
if (!class_exists(EcrClient::class)) {
throw MissingDependency::create('async-aws/ecr', 'ECR');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new EcrClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function elastiCache(): ElastiCacheClient
{
if (!class_exists(ElastiCacheClient::class)) {
throw MissingDependency::create('async-aws/elasti-cache', 'ElastiCache');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new ElastiCacheClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function eventBridge(): EventBridgeClient
{
if (!class_exists(EventBridgeClient::class)) {
throw MissingDependency::create('async-aws/event-bridge', 'EventBridge');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new EventBridgeClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function firehose(): FirehoseClient
{
if (!class_exists(FirehoseClient::class)) {
throw MissingDependency::create('async-aws/firehose', 'Firehose');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new FirehoseClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function iam(): IamClient
{
if (!class_exists(IamClient::class)) {
throw MissingDependency::create('async-aws/iam', 'IAM');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new IamClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function iot(): IotClient
{
if (!class_exists(IotClient::class)) {
throw MissingDependency::create('async-aws/iot', 'Iot');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new IotClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function iotData(): IotDataClient
{
if (!class_exists(IotDataClient::class)) {
throw MissingDependency::create('async-aws/iot-data', 'IotData');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new IotDataClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function kinesis(): KinesisClient
{
if (!class_exists(KinesisClient::class)) {
throw MissingDependency::create('aws/kinesis', 'Kinesis');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new KinesisClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function kms(): KmsClient
{
if (!class_exists(KmsClient::class)) {
throw MissingDependency::create('aws/kms', 'Kms');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new KmsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function lambda(): LambdaClient
{
if (!class_exists(LambdaClient::class)) {
throw MissingDependency::create('async-aws/lambda', 'Lambda');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new LambdaClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function rdsDataService(): RdsDataServiceClient
{
if (!class_exists(RdsDataServiceClient::class)) {
throw MissingDependency::create('async-aws/rds-data-service', 'RdsDataService');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new RdsDataServiceClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function rekognition(): RekognitionClient
{
if (!class_exists(RekognitionClient::class)) {
throw MissingDependency::create('aws/rekognition', 'Rekognition');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new RekognitionClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function route53(): Route53Client
{
if (!class_exists(Route53Client::class)) {
throw MissingDependency::create('aws/route53', 'Route53');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new Route53Client($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function s3(): S3Client
{
if (!class_exists(S3Client::class)) {
throw MissingDependency::create('async-aws/s3', 'S3');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new S3Client($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function scheduler(): SchedulerClient
{
if (!class_exists(SchedulerClient::class)) {
throw MissingDependency::create('async-aws/scheduler', 'Scheduler');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new SchedulerClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function secretsManager(): SecretsManagerClient
{
if (!class_exists(SecretsManagerClient::class)) {
throw MissingDependency::create('async-aws/secret-manager', 'SecretsManager');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new SecretsManagerClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function ses(): SesClient
{
if (!class_exists(SesClient::class)) {
throw MissingDependency::create('async-aws/ses', 'SES');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new SesClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function sns(): SnsClient
{
if (!class_exists(SnsClient::class)) {
throw MissingDependency::create('async-aws/sns', 'SNS');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new SnsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function sqs(): SqsClient
{
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__];
}
public function ssm(): SsmClient
{
if (!class_exists(SsmClient::class)) {
throw MissingDependency::create('async-aws/ssm', 'SSM');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new SsmClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function sts(): StsClient
{
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new StsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function stepFunctions(): StepFunctionsClient
{
if (!class_exists(StepFunctionsClient::class)) {
throw MissingDependency::create('async-aws/step-functions', 'StepFunctions');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new StepFunctionsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function timestreamQuery(): TimestreamQueryClient
{
if (!class_exists(TimestreamQueryClient::class)) {
throw MissingDependency::create('async-aws/timestream-query', 'TimestreamQuery');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new TimestreamQueryClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function timestreamWrite(): TimestreamWriteClient
{
if (!class_exists(TimestreamWriteClient::class)) {
throw MissingDependency::create('async-aws/timestream-write', 'TimestreamWrite');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new TimestreamWriteClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function translate(): TranslateClient
{
if (!class_exists(TranslateClient::class)) {
throw MissingDependency::create('async-aws/translate', 'Translate');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new TranslateClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function xRay(): XRayClient
{
if (!class_exists(XRayClient::class)) {
throw MissingDependency::create('async-aws/x-ray', 'XRay');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new XRayClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
public function cognitoIdentityProvider(): CognitoIdentityProviderClient
{
if (!class_exists(CognitoIdentityProviderClient::class)) {
throw MissingDependency::create('aws/cognito-identity-provider', 'CognitoIdentityProvider');
}
if (!isset($this->serviceCache[__METHOD__])) {
$this->serviceCache[__METHOD__] = new CognitoIdentityProviderClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
}
return $this->serviceCache[__METHOD__];
}
}
|