* * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. */ namespace Predis\Option; use Predis\Connection\ConnectionFactory; use Predis\Connection\ConnectionFactoryInterface; /** * Option class that returns a connection factory to be used by a client. * * @author Daniele Alessandri */ class ClientConnectionFactory extends AbstractOption { /** * {@inheritdoc} */ public function filter(ClientOptionsInterface $options, $value) { if ($value instanceof ConnectionFactoryInterface) { return $value; } if (is_array($value)) { $factory = $this->getDefault($options); foreach ($value as $scheme => $initializer) { $factory->define($scheme, $initializer); } return $factory; } if (is_string($value) && class_exists($value)) { if (!($factory = new $value()) && !$factory instanceof ConnectionFactoryInterface) { throw new \InvalidArgumentException("Class $value must be an instance of Predis\Connection\ConnectionFactoryInterface"); } return $factory; } throw new \InvalidArgumentException('Invalid value for the connections option'); } /** * {@inheritdoc} */ public function getDefault(ClientOptionsInterface $options) { return new ConnectionFactory($options->profile); } }