vendor/shopware/core/Framework/Adapter/Filesystem/Adapter/AwsS3v3Factory.php line 14

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\Adapter\Filesystem\Adapter;
  5. use Aws\S3\S3Client;
  6. use League\Flysystem\AdapterInterface;
  7. use League\Flysystem\AwsS3v3\AwsS3Adapter;
  8. use Shopware\Core\Framework\Log\Package;
  9. use Symfony\Component\OptionsResolver\OptionsResolver;
  11. #[Package('core')]
  12. class AwsS3v3Factory implements AdapterFactoryInterface
  13. {
  14.     public function create(array $config): AdapterInterface
  15.     {
  16.         $options = $this->resolveS3Options($config);
  18.         $client = new S3Client($options);
  20.         return new AwsS3Adapter($client, $options['bucket'], $options['root'], $options['options'], false);
  21.     }
  23.     public function getType(): string
  24.     {
  25.         return 'amazon-s3';
  26.     }
  28.     private function resolveS3Options(array $definition): array
  29.     {
  30.         $options = new OptionsResolver();
  32.         $options->setRequired(['bucket', 'region']);
  33.         $options->setDefined(['credentials', 'version', 'root', 'options', 'endpoint', 'use_path_style_endpoint', 'url']);
  35.         $options->setAllowedTypes('credentials', 'array');
  36.         $options->setAllowedTypes('region', 'string');
  37.         $options->setAllowedTypes('version', 'string');
  38.         $options->setAllowedTypes('root', 'string');
  39.         $options->setAllowedTypes('options', 'array');
  40.         $options->setAllowedTypes('endpoint', 'string');
  41.         $options->setAllowedTypes('use_path_style_endpoint', 'bool');
  43.         $options->setDefault('version', 'latest');
  44.         $options->setDefault('root', '');
  45.         $options->setDefault('options', []);
  47.         $config = $options->resolve($definition);
  49.         if (\array_key_exists('credentials', $config)) {
  50.             $config['credentials'] = $this->resolveCredentialsOptions($config['credentials']);
  51.         }
  53.         return $config;
  54.     }
  56.     private function resolveCredentialsOptions(array $credentials): array
  57.     {
  58.         $options = new OptionsResolver();
  60.         $options->setRequired(['key', 'secret']);
  62.         $options->setAllowedTypes('key', 'string');
  63.         $options->setAllowedTypes('secret', 'string');
  65.         return $options->resolve($credentials);
  66.     }
  67. }