vendor/symfony/dependency-injection/EnvVarProcessor.php line 136

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Component\DependencyInjection;
  14. use Symfony\Component\DependencyInjection\Exception\EnvNotFoundException;
  15. use Symfony\Component\DependencyInjection\Exception\ParameterCircularReferenceException;
  16. use Symfony\Component\DependencyInjection\Exception\RuntimeException;
  18. /**
  19.  * @author Nicolas Grekas <p@tchwork.com>
  20.  */
  21. class EnvVarProcessor implements EnvVarProcessorInterface
  22. {
  23.     private $container;
  24.     private $loaders;
  25.     private $loadedVars = [];
  27.     /**
  28.      * @param EnvVarLoaderInterface[] $loaders
  29.      */
  30.     public function __construct(ContainerInterface $container, \Traversable $loaders = null)
  31.     {
  32.         $this->container = $container;
  33.         $this->loaders = $loaders ?? new \ArrayIterator();
  34.     }
  36.     /**
  37.      * {@inheritdoc}
  38.      */
  39.     public static function getProvidedTypes()
  40.     {
  41.         return [
  42.             'base64' => 'string',
  43.             'bool' => 'bool',
  44.             'not' => 'bool',
  45.             'const' => 'bool|int|float|string|array',
  46.             'csv' => 'array',
  47.             'file' => 'string',
  48.             'float' => 'float',
  49.             'int' => 'int',
  50.             'json' => 'array',
  51.             'key' => 'bool|int|float|string|array',
  52.             'url' => 'array',
  53.             'query_string' => 'array',
  54.             'resolve' => 'string',
  55.             'default' => 'bool|int|float|string|array',
  56.             'string' => 'string',
  57.             'trim' => 'string',
  58.             'require' => 'bool|int|float|string|array',
  59.         ];
  60.     }
  62.     /**
  63.      * {@inheritdoc}
  64.      */
  65.     public function getEnv(string $prefix, string $name, \Closure $getEnv)
  66.     {
  67.         $i = strpos($name, ':');
  69.         if ('key' === $prefix) {
  70.             if (false === $i) {
  71.                 throw new RuntimeException(sprintf('Invalid env "key:%s": a key specifier should be provided.', $name));
  72.             }
  74.             $next = substr($name, $i + 1);
  75.             $key = substr($name, 0, $i);
  76.             $array = $getEnv($next);
  78.             if (!\is_array($array)) {
  79.                 throw new RuntimeException(sprintf('Resolved value of "%s" did not result in an array value.', $next));
  80.             }
  82.             if (!isset($array[$key]) && !\array_key_exists($key, $array)) {
  83.                 throw new EnvNotFoundException(sprintf('Key "%s" not found in %s (resolved from "%s").', $key, json_encode($array), $next));
  84.             }
  86.             return $array[$key];
  87.         }
  89.         if ('default' === $prefix) {
  90.             if (false === $i) {
  91.                 throw new RuntimeException(sprintf('Invalid env "default:%s": a fallback parameter should be provided.', $name));
  92.             }
  94.             $next = substr($name, $i + 1);
  95.             $default = substr($name, 0, $i);
  97.             if ('' !== $default && !$this->container->hasParameter($default)) {
  98.                 throw new RuntimeException(sprintf('Invalid env fallback in "default:%s": parameter "%s" not found.', $name, $default));
  99.             }
  101.             try {
  102.                 $env = $getEnv($next);
  104.                 if ('' !== $env && null !== $env) {
  105.                     return $env;
  106.                 }
  107.             } catch (EnvNotFoundException $e) {
  108.                 // no-op
  109.             }
  111.             return '' === $default ? null : $this->container->getParameter($default);
  112.         }
  114.         if ('file' === $prefix || 'require' === $prefix) {
  115.             if (!\is_scalar($file = $getEnv($name))) {
  116.                 throw new RuntimeException(sprintf('Invalid file name: env var "%s" is non-scalar.', $name));
  117.             }
  118.             if (!is_file($file)) {
  119.                 throw new EnvNotFoundException(sprintf('File "%s" not found (resolved from "%s").', $file, $name));
  120.             }
  122.             if ('file' === $prefix) {
  123.                 return file_get_contents($file);
  124.             } else {
  125.                 return require $file;
  126.             }
  127.         }
  129.         $returnNull = false;
  130.         if ('' === $prefix) {
  131.             $returnNull = true;
  132.             $prefix = 'string';
  133.         }
  135.         if (false !== $i || 'string' !== $prefix) {
  136.             $env = $getEnv($name);
  137.         } elseif (isset($_ENV[$name])) {
  138.             $env = $_ENV[$name];
  139.         } elseif (isset($_SERVER[$name]) && !str_starts_with($name, 'HTTP_')) {
  140.             $env = $_SERVER[$name];
  141.         } elseif (false === ($env = getenv($name)) || null === $env) { // null is a possible value because of thread safety issues
  142.             foreach ($this->loadedVars as $vars) {
  143.                 if (false !== $env = ($vars[$name] ?? false)) {
  144.                     break;
  145.                 }
  146.             }
  148.             if (false === $env || null === $env) {
  149.                 $loaders = $this->loaders;
  150.                 $this->loaders = new \ArrayIterator();
  152.                 try {
  153.                     $i = 0;
  154.                     $ended = true;
  155.                     $count = $loaders instanceof \Countable ? $loaders->count() : 0;
  156.                     foreach ($loaders as $loader) {
  157.                         if (\count($this->loadedVars) > $i++) {
  158.                             continue;
  159.                         }
  160.                         $this->loadedVars[] = $vars = $loader->loadEnvVars();
  161.                         if (false !== $env = $vars[$name] ?? false) {
  162.                             $ended = false;
  163.                             break;
  164.                         }
  165.                     }
  166.                     if ($ended || $count === $i) {
  167.                         $loaders = $this->loaders;
  168.                     }
  169.                 } catch (ParameterCircularReferenceException $e) {
  170.                     // skip loaders that need an env var that is not defined
  171.                 } finally {
  172.                     $this->loaders = $loaders;
  173.                 }
  174.             }
  176.             if (false === $env || null === $env) {
  177.                 if (!$this->container->hasParameter("env($name)")) {
  178.                     throw new EnvNotFoundException(sprintf('Environment variable not found: "%s".', $name));
  179.                 }
  181.                 $env = $this->container->getParameter("env($name)");
  182.             }
  183.         }
  185.         if (null === $env) {
  186.             if ($returnNull) {
  187.                 return null;
  188.             }
  190.             if (!isset($this->getProvidedTypes()[$prefix])) {
  191.                 throw new RuntimeException(sprintf('Unsupported env var prefix "%s".', $prefix));
  192.             }
  194.             if (!\in_array($prefix, ['string', 'bool', 'not', 'int', 'float'], true)) {
  195.                 return null;
  196.             }
  197.         }
  199.         if (null !== $env && !\is_scalar($env)) {
  200.             throw new RuntimeException(sprintf('Non-scalar env var "%s" cannot be cast to "%s".', $name, $prefix));
  201.         }
  203.         if ('string' === $prefix) {
  204.             return (string) $env;
  205.         }
  207.         if (\in_array($prefix, ['bool', 'not'], true)) {
  208.             $env = (bool) (filter_var($env, \FILTER_VALIDATE_BOOLEAN) ?: filter_var($env, \FILTER_VALIDATE_INT) ?: filter_var($env, \FILTER_VALIDATE_FLOAT));
  210.             return 'not' === $prefix ? !$env : $env;
  211.         }
  213.         if ('int' === $prefix) {
  214.             if (null !== $env && false === $env = filter_var($env, \FILTER_VALIDATE_INT) ?: filter_var($env, \FILTER_VALIDATE_FLOAT)) {
  215.                 throw new RuntimeException(sprintf('Non-numeric env var "%s" cannot be cast to int.', $name));
  216.             }
  218.             return (int) $env;
  219.         }
  221.         if ('float' === $prefix) {
  222.             if (null !== $env && false === $env = filter_var($env, \FILTER_VALIDATE_FLOAT)) {
  223.                 throw new RuntimeException(sprintf('Non-numeric env var "%s" cannot be cast to float.', $name));
  224.             }
  226.             return (float) $env;
  227.         }
  229.         if ('const' === $prefix) {
  230.             if (!\defined($env)) {
  231.                 throw new RuntimeException(sprintf('Env var "%s" maps to undefined constant "%s".', $name, $env));
  232.             }
  234.             return \constant($env);
  235.         }
  237.         if ('base64' === $prefix) {
  238.             return base64_decode(strtr($env, '-_', '+/'));
  239.         }
  241.         if ('json' === $prefix) {
  242.             $env = json_decode($env, true);
  244.             if (\JSON_ERROR_NONE !== json_last_error()) {
  245.                 throw new RuntimeException(sprintf('Invalid JSON in env var "%s": ', $name).json_last_error_msg());
  246.             }
  248.             if (null !== $env && !\is_array($env)) {
  249.                 throw new RuntimeException(sprintf('Invalid JSON env var "%s": array or null expected, "%s" given.', $name, get_debug_type($env)));
  250.             }
  252.             return $env;
  253.         }
  255.         if ('url' === $prefix) {
  256.             $parsedEnv = parse_url($env);
  258.             if (false === $parsedEnv) {
  259.                 throw new RuntimeException(sprintf('Invalid URL in env var "%s".', $name));
  260.             }
  261.             if (!isset($parsedEnv['scheme'], $parsedEnv['host'])) {
  262.                 throw new RuntimeException(sprintf('Invalid URL env var "%s": schema and host expected, "%s" given.', $name, $env));
  263.             }
  264.             $parsedEnv += [
  265.                 'port' => null,
  266.                 'user' => null,
  267.                 'pass' => null,
  268.                 'path' => null,
  269.                 'query' => null,
  270.                 'fragment' => null,
  271.             ];
  273.             // remove the '/' separator
  274.             $parsedEnv['path'] = '/' === ($parsedEnv['path'] ?? '/') ? '' : substr($parsedEnv['path'], 1);
  276.             return $parsedEnv;
  277.         }
  279.         if ('query_string' === $prefix) {
  280.             $queryString = parse_url($env, \PHP_URL_QUERY) ?: $env;
  281.             parse_str($queryString, $result);
  283.             return $result;
  284.         }
  286.         if ('resolve' === $prefix) {
  287.             return preg_replace_callback('/%%|%([^%\s]+)%/', function ($match) use ($name, $getEnv) {
  288.                 if (!isset($match[1])) {
  289.                     return '%';
  290.                 }
  292.                 if (str_starts_with($match[1], 'env(') && str_ends_with($match[1], ')') && 'env()' !== $match[1]) {
  293.                     $value = $getEnv(substr($match[1], 4, -1));
  294.                 } else {
  295.                     $value = $this->container->getParameter($match[1]);
  296.                 }
  298.                 if (!\is_scalar($value)) {
  299.                     throw new RuntimeException(sprintf('Parameter "%s" found when resolving env var "%s" must be scalar, "%s" given.', $match[1], $name, get_debug_type($value)));
  300.                 }
  302.                 return $value;
  303.             }, $env);
  304.         }
  306.         if ('csv' === $prefix) {
  307.             return str_getcsv($env, ',', '"', \PHP_VERSION_ID >= 70400 ? '' : '\\');
  308.         }
  310.         if ('trim' === $prefix) {
  311.             return trim($env);
  312.         }
  314.         throw new RuntimeException(sprintf('Unsupported env var prefix "%s" for env name "%s".', $prefix, $name));
  315.     }
  316. }