[SymfonyBundle] feat: Add support for MaxResults on SSMVault (#1672)

feat: Add support for MaxResults on SSMVault

To reduce the number of requests sent to SSM

Author: tyx

CHANGELOG.md

@@ -5,6 +5,7 @@
 ### Changed
 
 - Adding `async-aws/s3` 2.0, `async-aws/sqs` 2.0, `async-aws/ssm` 2.0 in dev dependencies
+- Adding `max_results` option in `secrets` configuration
 
 ## 1.12.0
 

src/DependencyInjection/AsyncAwsExtension.php

@@ -48,6 +48,7 @@ public function load(array $configs, ContainerBuilder $container): void
      *          enabled: bool,
      *          client: string|null,
      *          path: string|null,
+     *          max_results: int|null,
      *          recursive: bool,
      *          cache: array{enabled: bool, pool: string, ttl: int},
      *     },
@@ -215,6 +216,7 @@ private function addServiceDefinition(ContainerBuilder $container, string $name,
      *          client: string|null,
      *          path: string|null,
      *          recursive: bool,
+     *          max_results: int|null,
      *          cache: array{enabled: bool, pool: string, ttl: int},
      *     },
      *     clients: array<string, array{type: string, ...}>,
@@ -257,6 +259,7 @@ private function registerEnvLoader(ContainerBuilder $container, array $config):
                 new Reference('async_aws.client.' . $client),
                 $config['secrets']['path'],
                 $config['secrets']['recursive'],
+                $config['secrets']['max_results'],
             ]);
 
         if ($config['secrets']['cache']['enabled']) {

src/DependencyInjection/Configuration.php

@@ -48,6 +48,7 @@ public function getConfigTreeBuilder(): TreeBuilder
                     ->children()
                         ->scalarNode('path')->info('Path to the parameters.')->defaultNull()->end()
                         ->booleanNode('recursive')->info('Retrieve all parameters within a hierarchy.')->defaultValue(true)->end()
+                        ->integerNode('max_results')->info('The maximum number of items for each ssm call. Maximum value of 50.')->min(1)->max(50)->defaultNull()->end()
                         ->scalarNode('client')->info('Name of the SSM client. When null, use the default SSM configuration.')->defaultNull()->end()
                         ->arrayNode('cache')
                             ->canBeEnabled()

src/Secrets/SsmVault.php

@@ -23,11 +23,17 @@ class SsmVault implements EnvVarLoaderInterface
      */
     private $recursive;
 
-    public function __construct(SsmClient $client, ?string $path, bool $recursive)
+    /**
+     * @var int|null
+     */
+    private $maxResults;
+
+    public function __construct(SsmClient $client, ?string $path, bool $recursive, ?int $maxResults = null)
     {
         $this->client = $client;
         $this->path = $path ?? '/';
         $this->recursive = $recursive;
+        $this->maxResults = $maxResults;
     }
 
     public function loadEnvVars(): array
@@ -36,6 +42,7 @@ public function loadEnvVars(): array
             'Path' => $this->path,
             'Recursive' => $this->recursive,
             'WithDecryption' => true,
+            'MaxResults' => $this->maxResults,
         ]);
 
         $secrets = [];

tests/Unit/DependencyInjection/ConfigurationTest.php

@@ -39,6 +39,7 @@ public function testDefaultValues(): void
                     'pool' => 'cache.system',
                     'ttl' => 600,
                 ],
+                'max_results' => null,
             ],
         ]);
     }

tests/Unit/Secrets/SsmVaultTest.php

@@ -36,4 +36,23 @@ public function provideParameters(): iterable
         yield 'remove trailing' => ['/my_app/', '/my_app/foo', ['FOO' => 'value']];
         yield 'recursive' => [null, '/foo/bar', ['FOO_BAR' => 'value']];
     }
+
+    public function testMaxResults()
+    {
+        $maxResults = 50;
+        $client = $this->createMock(SsmClient::class);
+        $ssmVault = new SsmVault($client, '/', true, $maxResults);
+
+        $client->expects(self::once())
+            ->method('getParametersByPath')
+            ->with([
+                'Path' => '/',
+                'Recursive' => true,
+                'WithDecryption' => true,
+                'MaxResults' => $maxResults,
+            ])
+            ->willReturn(ResultMockFactory::create(GetParametersByPathResult::class, ['Parameters' => [new Parameter(['Name' => 'foo', 'Value' => 'value'])]]));
+
+        $ssmVault->loadEnvVars();
+    }
 }