Merge pull request #1865 from annuh/issue-1596-support-aws_credential…

…_provider Add support for 'aws_credential_provider'
FriendsOfSymfony · Jul 20, 2022 · b8d71ea · b8d71ea
2 parents a4d33c1 + 43ba634
commit b8d71ea
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/src/DependencyInjection/Configuration.php b/src/DependencyInjection/Configuration.php
@@ -383,6 +383,7 @@ private function addClientsSection(ArrayNodeDefinition $rootNode)
                                         ->scalarNode('aws_secret_access_key')->end()
                                         ->scalarNode('aws_region')->end()
                                         ->scalarNode('aws_session_token')->end()
+                                        ->scalarNode('aws_credential_provider')->end()
                                         ->booleanNode('ssl')->defaultValue(false)->end()
                                         ->scalarNode('logger')
                                             ->defaultValue($this->debug ? 'fos_elastica.logger' : false)

diff --git a/src/DependencyInjection/FOSElasticaExtension.php b/src/DependencyInjection/FOSElasticaExtension.php
@@ -144,6 +144,14 @@ private function loadClients(array $clients, ContainerBuilder $container): void
         foreach ($clients as $name => $clientConfig) {
             $clientId = \sprintf('fos_elastica.client.%s', $name);
 
+            if (isset($clientConfig['connections'])) {
+                foreach ($clientConfig['connections'] as $connectionIndex => $connectionConfig) {
+                    if (isset($connectionConfig['aws_credential_provider'])) {
+                        $clientConfig['connections'][$connectionIndex]['aws_credential_provider'] = new Reference($connectionConfig['aws_credential_provider']);
+                    }
+                }
+            }
+
             $clientDef = new ChildDefinition('fos_elastica.client_prototype');
             $clientDef->replaceArgument(0, $clientConfig);
             $clientDef->replaceArgument(1, null);