PFlorek\AwsParameterStore\Reader

Complexity

Total Complexity

9

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	fromPath()	0	11	2
A	getParameters()	0	13	3
A	__construct()	0	7	2
A	getParametersByPath()	0	13	2

<?php


namespace PFlorek\AwsParameterStore;


use Aws\Result;

use Aws\Ssm\SsmClient;

use Generator;


class Reader

{

    /**

     * @var SsmClient

     */

    private $client;


    /**

     * @param SsmClient|array $client

     */

    public function __construct($client)

    {

        if (is_array($client)) {

            $client = new SsmClient($client);

        }


        $this->client = $client;

    }


    /**

     * @see https://docs.aws.amazon.com/aws-sdk-php/v3/api/api-ssm-2014-11-06.html#getparametersbypath

     * @param string $path

     * @return mixed[]

     */

    public function fromPath(string $path): array

    {

        $config = [];

        foreach ($this->getParameters($path) as $parameter) {

            $name = $parameter['Name'];

            $name = str_replace(["{$path}/", '/'], ['', '.'], $name);

            $value = $parameter['Value'];

            $config[$name] = $value;

        }


        return $config;

    }


    /**

     * @param string $path

     * @return Generator|string[][]

     */

    private function getParameters(string $path)

    {

        $nextToken = null;

        do {

            $result = $this->getParametersByPath($path, $nextToken);

            $parameters = $result['Parameters'];


            foreach ($parameters as $parameter) {

                yield $parameter;

            }


            $nextToken = $result['NextToken'] ?? null;

        } while ($nextToken);

    }


    /**

     * @see https://docs.aws.amazon.com/de_de/systems-manager/latest/APIReference/API_GetParametersByPath.html#API_GetParametersByPath_RequestParameters

     *

     * @param string $path

     * @param string|null $nextToken

     * @return Result|mixed

     */

    private function getParametersByPath(string $path, string $nextToken = null)

    {

        $args = [

            'Path' => $path,

            'Recursive' => true,

            'WithDecryption' => true,

        ];


        if ($nextToken) {

            $args['NextToken'] = $nextToken;

        }


        return $this->client->getParametersByPath($args);

    }

}