1:  2:  3:  4:  5:  6:  7:  8:  9: 10: 11: 12: 13: 14: 15: 16: 17: 18: 19: 20: 21: 22: 23: 24: 25: 26: 27: 28: 29: 30: 31: 32: 33: 34: 35: 36: 37: 38: 39: 40: 41: 42: 43: 44: 45: 46: 47: 48: 49: 50: 51: 52: 53: 54: 55: 56: 57: 58: 59: 60: 61: 62: 63: 64: 65: 66: 67: 68: 69: 70: 71: 72: 73: 74: 75: 76: 77: 78: 79: 80: 81: 82: 83: 84: 85: 86: 87: 88: 89: 90: 91: 92: 93: 94: 95: 96: 

<?php


namespace SAREhub\Client\Amqp;


use SAREhub\Commons\Misc\EnvironmentHelper;
use SAREhub\Commons\Misc\InvokableProvider;
use SAREhub\Commons\Secret\SecretValueProvider;

class EnvAmqpConnectionOptionsProvider extends InvokableProvider
{
    const ENV_HOST = "HOST";
    const ENV_PORT = "PORT";
    const ENV_VHOST = "VHOST";

    const ENV_USER = "USER";
    const ENV_PASSWORD_SECRET = "PASSWORD_SECRET";

    const ENV_SSL_ENABLED = "SSL_ENABLED";
    const ENV_SSL_VERIFY_PEER = "SSL_VERIFY_PEER";
    const ENV_SSL_VERIFY_PEER_NAME = "SSL_VERIFY_PEER_NAME";

    const ENV_CONNECTION_TIMEOUT = "CONNECTION_TIMEOUT";
    const ENV_READ_WRITE_TIMEOUT = "READ_WRITE_TIMEOUT";

    const ENV_KEEPALIVE = "KEEPALIVE";
    const ENV_HEARTBEAT = "HEARTBEAT";

    const ENV_SCHEMA = [
        self::ENV_HOST => "",
        self::ENV_PORT => 5671,
        self::ENV_VHOST => "",
        self::ENV_USER => "",
        self::ENV_PASSWORD_SECRET => "",

        self::ENV_SSL_ENABLED => true,
        self::ENV_SSL_VERIFY_PEER => false,
        self::ENV_SSL_VERIFY_PEER_NAME => false,

        self::ENV_CONNECTION_TIMEOUT => AmqpConnectionOptions::DEFAULT_CONNECTION_TIMEOUT,
        self::ENV_READ_WRITE_TIMEOUT => (AmqpConnectionOptions::DEFAULT_HEARTBEAT * 2) + 1,
        self::ENV_KEEPALIVE => false,
        self::ENV_HEARTBEAT => AmqpConnectionOptions::DEFAULT_HEARTBEAT
    ];

    const DEFAULT_ENV_VAR_PREFIX = "AMQP_";

    /**
     * @var string
     */
    private $envVarPrefix;

    /**
     * @var array
     */
    private $envSchema;

    /**
     * @var SecretValueProvider
     */
    private $secretValueProvider;

    public function __construct(
        SecretValueProvider $secretValueProvider,
        $envVarPrefix = self::DEFAULT_ENV_VAR_PREFIX,
        array $envSchema = []
    )
    {
        $this->envVarPrefix = $envVarPrefix;
        $this->envSchema = array_merge(self::ENV_SCHEMA, $envSchema);
        $this->secretValueProvider = $secretValueProvider;
    }

    /**
     * @return AmqpConnectionOptions
     * @throws \SAREhub\Commons\Secret\SecretValueNotFoundException
     */
    public function get(): AmqpConnectionOptions
    {
        $env = EnvironmentHelper::getVars($this->envSchema, $this->envVarPrefix);

        return AmqpConnectionOptions::newInstance()
            ->withHost($env[self::ENV_HOST])
            ->withVhost($env[self::ENV_VHOST])
            ->withPort($env[self::ENV_PORT])
            ->withUser($env[self::ENV_USER])
            ->withPassword($this->secretValueProvider->get($env[self::ENV_PASSWORD_SECRET]))
            ->withSsl((bool)$env[self::ENV_SSL_ENABLED])
            ->withSslVerifyPeer((bool)$env[self::ENV_SSL_VERIFY_PEER])
            ->withSslVerifyPeerName((bool)$env[self::ENV_SSL_VERIFY_PEER_NAME])
            ->withConnectionTimeout($env[self::ENV_CONNECTION_TIMEOUT])
            ->withReadWriteTimeout($env[self::ENV_READ_WRITE_TIMEOUT])
            ->withHeartbeat($env[self::ENV_HEARTBEAT]);
    }
}