created new connection class with ssl support. Changed Bolt construct to accept connection instead of connecting arguments.

Author: stefanak-michal

src/Bolt.php

@@ -71,14 +71,12 @@ final class Bolt
 
     /**
      * Bolt constructor
-     * @param string $ip
-     * @param int $port
-     * @param int $timeout
+     * @param IConnection $connection
      * @throws Exception
      */
-    public function __construct(string $ip = '127.0.0.1', int $port = 7687, int $timeout = 15)
+    public function __construct(IConnection $connection)
     {
-        $this->connection = new \Bolt\connection\Socket($ip, $port, $timeout);
+        $this->connection = $connection;
 
         $packerClass = "\\Bolt\\PackStream\\v" . $this->packStreamVersion . "\\Packer";
         if (!class_exists($packerClass)) {

src/connection/IConnection.php

@@ -11,6 +11,8 @@
  */
 interface IConnection
 {
+    public function __construct(string $ip = '127.0.0.1', int $port = 7687, int $timeout = 15);
+
     public function connect(): bool;
 
     public function write(string $buffer);

src/connection/Socket.php

@@ -3,6 +3,7 @@
 namespace Bolt\connection;
 
 use Bolt\Bolt;
+use Exception;
 
 /**
  * Socket class
@@ -38,9 +39,9 @@ class Socket implements IConnection
      * @param string $ip
      * @param int $port
      * @param int $timeout
-     * @throws \Exception
+     * @throws Exception
      */
-    public function __construct(string $ip, int $port, int $timeout)
+    public function __construct(string $ip = '127.0.0.1', int $port = 7687, int $timeout = 15)
     {
         if (!extension_loaded('sockets')) {
             Bolt::error('PHP Extension sockets not enabled');
@@ -54,7 +55,7 @@ public function __construct(string $ip, int $port, int $timeout)
     /**
      * Create socket connection
      * @return bool
-     * @throws \Exception
+     * @throws Exception
      */
     public function connect(): bool
     {
@@ -87,7 +88,7 @@ public function connect(): bool
     /**
      * Write buffer to socket
      * @param string $buffer
-     * @throws \Exception
+     * @throws Exception
      */
     public function write(string $buffer)
     {
@@ -119,7 +120,7 @@ public function write(string $buffer)
      * Read buffer from socket
      * @param int $length
      * @return string
-     * @throws \Exception
+     * @throws Exception
      */
     public function read(int $length = 2048): string
     {

src/connection/StreamSocket.php

@@ -0,0 +1,155 @@
+<?php
+
+
+namespace Bolt\connection;
+
+use Bolt\Bolt;
+use Exception;
+
+class StreamSocket implements IConnection
+{
+
+    /**
+     * @var string
+     */
+    private $ip;
+
+    /**
+     * @var int
+     */
+    private $port;
+
+    /**
+     * @var int
+     */
+    private $timeout;
+
+    /**
+     * @var array
+     */
+    private $sslContextOptions = [];
+
+    /**
+     * @var resource
+     */
+    private $stream;
+
+    /**
+     * StreamSocket constructor.
+     * @param string $ip
+     * @param int $port
+     * @param int $timeout
+     */
+    public function __construct(string $ip = '127.0.0.1', int $port = 7687, int $timeout = 15)
+    {
+        $this->ip = $ip;
+        $this->port = $port;
+        $this->timeout = $timeout;
+    }
+
+    /**
+     * Set SSL Context options
+     * @link https://www.php.net/manual/en/context.ssl.php
+     * @param array $options
+     */
+    public function setSslContextOptions(array $options)
+    {
+        $this->sslContextOptions = $options;
+    }
+
+    /**
+     * Connect
+     * @return bool
+     * @throws Exception
+     */
+    public function connect(): bool
+    {
+        $context = stream_context_create([
+            'socket' => [
+                'tcp_nodelay' => true,
+            ],
+            'ssl' => $this->sslContextOptions
+        ]);
+
+        $this->stream = stream_socket_client( 'tcp://' . $this->ip . ':' . $this->port, $errno, $errstr, $this->timeout, STREAM_CLIENT_CONNECT, $context);
+
+        if ($this->stream === false) {
+            Bolt::error($errstr . ' (' . $errno . ')');
+            return false;
+        }
+
+        if (!stream_set_blocking($this->stream, true)) {
+            Bolt::error('Cannot set socket into blocking mode');
+            return false;
+        }
+
+        if (!empty($this->sslContextOptions)) {
+            if (stream_socket_enable_crypto($this->stream, true, STREAM_CRYPTO_METHOD_ANY_CLIENT) !== true) {
+                Bolt::error('Enable encryption error');
+                return false;
+            }
+        }
+
+        return true;
+    }
+
+    /**
+     * Write to connection
+     * @param string $buffer
+     * @throws Exception
+     */
+    public function write(string $buffer)
+    {
+        if (Bolt::$debug)
+            $this->printHex($buffer);
+
+
+        if (fwrite($this->stream, $buffer) === false)
+            Bolt::error('Write error');
+    }
+
+    /**
+     * Read from connection
+     * @param int $length
+     * @return string
+     * @throws Exception
+     */
+    public function read(int $length = 2048): string
+    {
+        $res = fread($this->stream, $length);
+        if (empty($res))
+            Bolt::error('Read error');
+
+        if (Bolt::$debug)
+            $this->printHex($res, false);
+
+        return (string)$res;
+    }
+
+    /**
+     * Close connection
+     */
+    public function disconnect()
+    {
+        if (is_resource($this->stream))
+            stream_socket_shutdown($this->stream, STREAM_SHUT_RDWR);
+    }
+
+    /**
+     * Print buffer as HEX
+     * @param string $str
+     * @param bool $write
+     */
+    private function printHex(string $str, bool $write = true)
+    {
+        $str = implode(unpack('H*', $str));
+        echo '<pre>';
+        echo $write ? '> ' : '< ';
+        foreach (str_split($str, 8) as $chunk) {
+            echo implode(' ', str_split($chunk, 2));
+            echo '    ';
+        }
+        echo '</pre>';
+    }
+
+}