aboutsummaryrefslogtreecommitdiffhomepage
path: root/assets/php/vendor/react/socket/src/SecureConnector.php
diff options
context:
space:
mode:
Diffstat (limited to 'assets/php/vendor/react/socket/src/SecureConnector.php')
-rwxr-xr-xassets/php/vendor/react/socket/src/SecureConnector.php64
1 files changed, 0 insertions, 64 deletions
diff --git a/assets/php/vendor/react/socket/src/SecureConnector.php b/assets/php/vendor/react/socket/src/SecureConnector.php
deleted file mode 100755
index f04183d..0000000
--- a/assets/php/vendor/react/socket/src/SecureConnector.php
+++ /dev/null
@@ -1,64 +0,0 @@
-<?php
-
-namespace React\Socket;
-
-use React\EventLoop\LoopInterface;
-use React\Promise;
-use BadMethodCallException;
-use InvalidArgumentException;
-use UnexpectedValueException;
-
-final class SecureConnector implements ConnectorInterface
-{
- private $connector;
- private $streamEncryption;
- private $context;
-
- public function __construct(ConnectorInterface $connector, LoopInterface $loop, array $context = array())
- {
- $this->connector = $connector;
- $this->streamEncryption = new StreamEncryption($loop, false);
- $this->context = $context;
- }
-
- public function connect($uri)
- {
- if (!function_exists('stream_socket_enable_crypto')) {
- return Promise\reject(new BadMethodCallException('Encryption not supported on your platform (HHVM < 3.8?)')); // @codeCoverageIgnore
- }
-
- if (strpos($uri, '://') === false) {
- $uri = 'tls://' . $uri;
- }
-
- $parts = parse_url($uri);
- if (!$parts || !isset($parts['scheme']) || $parts['scheme'] !== 'tls') {
- return Promise\reject(new InvalidArgumentException('Given URI "' . $uri . '" is invalid'));
- }
-
- $uri = str_replace('tls://', '', $uri);
- $context = $this->context;
-
- $encryption = $this->streamEncryption;
- return $this->connector->connect($uri)->then(function (ConnectionInterface $connection) use ($context, $encryption) {
- // (unencrypted) TCP/IP connection succeeded
-
- if (!$connection instanceof Connection) {
- $connection->close();
- throw new UnexpectedValueException('Base connector does not use internal Connection class exposing stream resource');
- }
-
- // set required SSL/TLS context options
- foreach ($context as $name => $value) {
- stream_context_set_option($connection->stream, 'ssl', $name, $value);
- }
-
- // try to enable encryption
- return $encryption->enable($connection)->then(null, function ($error) use ($connection) {
- // establishing encryption failed => close invalid connection and return error
- $connection->close();
- throw $error;
- });
- });
- }
-}