Prevent authentication after a failed STARTTLS handshake

src/Connection/ImapConnection.php

@@ -216,7 +216,11 @@ public function startTls(): void
 
         $this->assertTaggedResponse($tag);
 
-        $this->stream->setSocketSetCrypto(true, STREAM_CRYPTO_METHOD_TLS_CLIENT);
+        if ($this->stream->setSocketSetCrypto(true, STREAM_CRYPTO_METHOD_TLS_CLIENT) !== true) {
+            $this->disconnect();
+
+            throw new ImapConnectionFailedException('Unable to establish TLS encryption.');
+        }
     }
 
     /**

tests/Unit/Connection/ImapConnectionTest.php

@@ -166,6 +166,32 @@
     $connection->startTls();
 })->throws(ImapCommandException::class, 'IMAP command "TAG1 STARTTLS" failed. Response: "TAG1 BAD TLS negotiation failed"');
 
+test('start tls disconnects when encryption is not established', function (bool|int $result) {
+    $stream = new class($result) extends FakeStream
+    {
+        public function __construct(protected bool|int $result) {}
+
+        public function setSocketSetCrypto(bool $enabled, ?int $method): bool|int
+        {
+            return $this->result;
+        }
+    };
+
+    $stream->feed([
+        '* OK Welcome to IMAP',
+        'TAG1 OK Begin TLS negotiation now',
+    ]);
+
+    $connection = new ImapConnection($stream);
+    $connection->connect('imap.example.com');
+
+    expect(fn () => $connection->startTls())->toThrow(ImapConnectionFailedException::class);
+    expect($connection->connected())->toBeFalse();
+
+    $stream->assertWritten('TAG1 STARTTLS');
+    $stream->assertNotWritten('LOGOUT');
+})->with([false, 0]);
+
 test('done', function () {
     $stream = new FakeStream;
     $stream->open();

tests/Unit/MailboxTest.php

@@ -1,7 +1,9 @@
 <?php
 
 use DirectoryTree\ImapEngine\Connection\ImapConnection;
+use DirectoryTree\ImapEngine\Connection\Streams\FakeStream;
 use DirectoryTree\ImapEngine\Exceptions\ImapCommandException;
+use DirectoryTree\ImapEngine\Exceptions\ImapConnectionFailedException;
 use DirectoryTree\ImapEngine\Folder;
 use DirectoryTree\ImapEngine\Mailbox;
 
@@ -99,6 +101,41 @@
     ]));
 })->throws(ImapCommandException::class, 'IMAP command "TAG1 LOGIN [redacted] [redacted]" failed. Response: "TAG1 BAD Authentication failed"');
 
+test('connect does not authenticate when the tls handshake fails', function (bool|int $result, string $authentication) {
+    $stream = new class($result) extends FakeStream
+    {
+        public function __construct(protected bool|int $result) {}
+
+        public function setSocketSetCrypto(bool $enabled, ?int $method): bool|int
+        {
+            return $this->result;
+        }
+    };
+
+    $stream->feed([
+        '* OK Welcome to IMAP',
+        'TAG1 OK Begin TLS negotiation now',
+        'TAG2 OK Authenticated',
+    ]);
+
+    $mailbox = Mailbox::make([
+        'host' => 'imap.example.com',
+        'encryption' => 'starttls',
+        'authentication' => $authentication,
+        'username' => 'foo',
+        'password' => 'bar',
+    ]);
+
+    expect(fn () => $mailbox->connect(new ImapConnection($stream)))
+        ->toThrow(ImapConnectionFailedException::class);
+
+    expect($mailbox->connected())->toBeFalse();
+
+    $stream->assertWritten('TAG1 STARTTLS');
+    $stream->assertNotWritten('LOGIN');
+    $stream->assertNotWritten('AUTHENTICATE');
+})->with([false, 0])->with(['plain', 'oauth']);
+
 test('folders', function () {
     $mailbox = Mailbox::make();