feat(tcp): support TLS/SSL

Signed-off-by: azjezz <azjezz@protonmail.com>

composer.json

@@ -16,6 +16,7 @@
         "ext-mbstring": "*",
         "ext-sodium": "*",
         "ext-intl": "*",
+        "ext-openssl": "*",
         "revolt/event-loop": "^1.0.1"
     },
     "require-dev": {

docs/README.md

@@ -52,6 +52,7 @@
 - [Psl\Str\Byte](./component/str-byte.md)
 - [Psl\Str\Grapheme](./component/str-grapheme.md)
 - [Psl\TCP](./component/tcp.md)
+- [Psl\TCP\TLS](./component/tcp-tls.md)
 - [Psl\Trait](./component/trait.md)
 - [Psl\Type](./component/type.md)
 - [Psl\Unix](./component/unix.md)

docs/component/tcp-tls.md

@@ -0,0 +1,21 @@
+<!--
+    This markdown file was generated using `docs/documenter.php`.
+
+    Any edits to it will likely be lost.
+-->
+
+[*index](./../README.md)
+
+---
+
+### `Psl\TCP\TLS` Component
+
+#### `Classes`
+
+- [Certificate](./../../src/Psl/TCP/TLS/Certificate.php#L16)
+- [ConnectOptions](./../../src/Psl/TCP/TLS/ConnectOptions.php#L34)
+- [HashingAlgorithm](./../../src/Psl/TCP/TLS/HashingAlgorithm.php#L15)
+- [SecurityLevel](./../../src/Psl/TCP/TLS/SecurityLevel.php#L18)
+- [Version](./../../src/Psl/TCP/TLS/Version.php#L10)
+
+

docs/component/tcp.md

@@ -12,7 +12,7 @@
 
 #### `Functions`
 
-- [connect](./../../src/Psl/TCP/connect.php#L18)
+- [connect](./../../src/Psl/TCP/connect.php#L37)
 
 #### `Classes`
 

docs/documenter.php

@@ -222,6 +222,7 @@ function get_all_components(): array
         'Psl\\Str\\Byte',
         'Psl\\Str\\Grapheme',
         'Psl\\TCP',
+        'Psl\\TCP\\TLS',
         'Psl\\Trait',
         'Psl\\Type',
         'Psl\\Unix',

examples/channel/bounded.php

@@ -30,9 +30,8 @@
 
     for ($i = 0; $i < 10; $i++) {
         $file = File\open_read_only(__FILE__);
-        $reader = new IO\Reader($file);
-        while (!$reader->isEndOfFile()) {
-            $byte = $reader->readByte();
+        while (!$file->reachedEndOfDataSource()) {
+            $byte = $file->readFixedSize(1);
 
             $sender->send($byte);
         }

examples/tcp/basic-http-client.php

@@ -2,28 +2,45 @@
 
 declare(strict_types=1);
 
-namespace Psl\Example\TCP;
-
 use Psl\Async;
 use Psl\IO;
+use Psl\Str;
 use Psl\TCP;
 
 require __DIR__ . '/../../vendor/autoload.php';
 
-function fetch(string $host, string $path): string
+Async\main(static function(): void {
+    [$headers, $content] = fetch('https://psalm.dev/');
+
+    $output = IO\error_handle() ?? IO\output_handle();
+
+    $output->writeAll($headers);
+    $output->writeAll("\n");
+    $output->writeAll($content);
+});
+
+function fetch(string $url): array
 {
-    $client = TCP\connect($host, 80);
-    $client->writeAll("GET {$path} HTTP/1.1\r\nHost: $host\r\nConnection: close\r\n\r\n");
-    $response = $client->readAll();
-    $client->close();
+    $parsed_url = parse_url($url);
+    $host = $parsed_url['host'];
+    $port = $parsed_url['scheme'] === 'https' ? 443 : 80;
+    $path = $parsed_url['path'] ?? '/';
 
-    return $response;
-}
+    $options = TCP\ConnectOptions::create();
+    if ($port === 443) {
+        $options = $options->withTLSConnectOptions(
+            TCP\TLS\ConnectOptions::default()->withPeerName($host),
+        );
+    }
 
-Async\main(static function (): int {
-    $response = fetch('example.com', '/');
+    $client = TCP\connect($host, $port, $options);
+    $client->writeAll("GET $path HTTP/1.1\r\nHost: $host\r\nConnection: close\r\n\r\n");
 
-    IO\write_error_line($response);
+    $response = $client->readAll();
 
-    return 0;
-});
+    $position = Str\search($response, "\r\n\r\n");
+    $headers = Str\slice($response, 0, $position);
+    $content = Str\slice($response, $position + 4);
+
+    return [$headers, $content];
+}

src/Psl/File/ReadHandle.php

@@ -39,6 +39,14 @@ public function __construct(string $file)
         parent::__construct($this->readHandle);
     }
 
+    /**
+     * {@inheritDoc}
+     */
+    public function reachedEndOfDataSource(): bool
+    {
+        return $this->readHandle->reachedEndOfDataSource();
+    }
+
     /**
      * {@inheritDoc}
      */

src/Psl/File/ReadWriteHandle.php

@@ -67,6 +67,14 @@ public function __construct(string $file, WriteMode $write_mode = WriteMode::Ope
         parent::__construct($this->readWriteHandle);
     }
 
+    /**
+     * {@inheritDoc}
+     */
+    public function reachedEndOfDataSource(): bool
+    {
+        return $this->readWriteHandle->reachedEndOfDataSource();
+    }
+
     /**
      * {@inheritDoc}
      */

src/Psl/IO/CloseReadStreamHandle.php

@@ -23,6 +23,14 @@ public function __construct(mixed $stream)
         $this->handle = new Internal\ResourceHandle($stream, read: true, write: false, seek: false, close: true);
     }
 
+    /**
+     * {@inheritDoc}
+     */
+    public function reachedEndOfDataSource(): bool
+    {
+        return $this->handle->reachedEndOfDataSource();
+    }
+
     /**
      * {@inheritDoc}
      */

src/Psl/IO/CloseReadWriteStreamHandle.php

@@ -24,6 +24,14 @@ public function __construct(mixed $stream)
         $this->handle = new Internal\ResourceHandle($stream, read: true, write: true, seek: false, close: true);
     }
 
+    /**
+     * {@inheritDoc}
+     */
+    public function reachedEndOfDataSource(): bool
+    {
+        return $this->handle->reachedEndOfDataSource();
+    }
+
     /**
      * {@inheritDoc}
      */

src/Psl/IO/CloseSeekReadStreamHandle.php

@@ -23,6 +23,14 @@ public function __construct(mixed $stream)
         $this->handle = new Internal\ResourceHandle($stream, read: true, write: false, seek: true, close: true);
     }
 
+    /**
+     * {@inheritDoc}
+     */
+    public function reachedEndOfDataSource(): bool
+    {
+        return $this->handle->reachedEndOfDataSource();
+    }
+
     /**
      * {@inheritDoc}
      */

src/Psl/IO/CloseSeekReadWriteStreamHandle.php

@@ -24,6 +24,14 @@ public function __construct(mixed $stream)
         $this->handle = new Internal\ResourceHandle($stream, read: true, write: true, seek: true, close: true);
     }
 
+    /**
+     * {@inheritDoc}
+     */
+    public function reachedEndOfDataSource(): bool
+    {
+        return $this->handle->reachedEndOfDataSource();
+    }
+
     /**
      * {@inheritDoc}
      */