Add ability to proactively close FTP and SFTP connections.

src/Ftp/FtpAdapter.php

@@ -30,14 +30,15 @@
 use function error_clear_last;
 use function error_get_last;
 use function ftp_chdir;
+use function ftp_close;
 use function is_string;
 
 class FtpAdapter implements FilesystemAdapter
 {
     private const SYSTEM_TYPE_WINDOWS = 'windows';
     private const SYSTEM_TYPE_UNIX = 'unix';
 
-    private FtpConnectionProvider $connectionProvider;
+    private ConnectionProvider $connectionProvider;
     private ConnectivityChecker $connectivityChecker;
 
     /**
@@ -55,7 +56,7 @@ class FtpAdapter implements FilesystemAdapter
 
     public function __construct(
         private FtpConnectionOptions $connectionOptions,
-        FtpConnectionProvider $connectionProvider = null,
+        ConnectionProvider $connectionProvider = null,
         ConnectivityChecker $connectivityChecker = null,
         VisibilityConverter $visibilityConverter = null,
         MimeTypeDetector $mimeTypeDetector = null,
@@ -104,6 +105,13 @@ private function connection()
         return $this->connection;
     }
 
+    public function disconnect(): void
+    {
+        if ($this->hasFtpConnection()) {
+            ftp_close($this->connection);
+        }
+    }
+
     private function isPureFtpdServer(): bool
     {
         if ($this->isPureFtpdServer !== null) {

src/Ftp/FtpAdapterTest.php

@@ -26,8 +26,13 @@ protected static function createFilesystemAdapter(): FilesystemAdapter
        ]);
 
         static::$connectivityChecker = new ConnectivityCheckerThatCanFail(new NoopCommandConnectivityChecker());
+        static::$connectionProvider = new StubConnectionProvider(new FtpConnectionProvider());
 
-        return new FtpAdapter($options, null, static::$connectivityChecker);
+        return new FtpAdapter(
+            $options,
+            static::$connectionProvider,
+            static::$connectivityChecker,
+        );
     }
 
     /**
@@ -50,6 +55,21 @@ public function disconnect_after_destruct(): void
         $this->assertFalse((new NoopCommandConnectivityChecker())->isConnected($connection));
     }
 
+    /**
+     * @test
+     */
+    public function it_can_disconnect(): void
+    {
+        /** @var FtpAdapter $adapter */
+        $adapter = $this->adapter();
+
+        $this->assertFalse($adapter->fileExists('not-existing.file'));
+
+        self::assertTrue(static::$connectivityChecker->isConnected(static::$connectionProvider->connection));
+        $adapter->disconnect();
+        self::assertFalse(static::$connectivityChecker->isConnected(static::$connectionProvider->connection));
+    }
+
     /**
      * @test
      */

src/Ftp/FtpAdapterTestCase.php

@@ -4,6 +4,7 @@
 
 namespace League\Flysystem\Ftp;
 
+use Ftp\StubConnectionProvider;
 use Generator;
 use League\Flysystem\AdapterTestUtilities\FilesystemAdapterTestCase;
 use League\Flysystem\Config;
@@ -37,6 +38,11 @@ protected function setUp(): void
      */
     protected static $connectivityChecker;
 
+    /**
+     * @var StubConnectionProvider
+     */
+    protected static $connectionProvider;
+
     /**
      * @after
      */

src/Ftp/StubConnectionProvider.php

@@ -0,0 +1,18 @@
+<?php
+declare(strict_types=1);
+
+namespace League\Flysystem\Ftp;
+
+class StubConnectionProvider implements ConnectionProvider
+{
+    public mixed $connection;
+
+    public function __construct(private ConnectionProvider $provider)
+    {
+    }
+
+    public function createConnection(FtpConnectionOptions $options)
+    {
+        return $this->connection = $this->provider->createConnection($options);
+    }
+}

src/PhpseclibV3/ConnectionProvider.php

@@ -6,6 +6,9 @@
 
 use phpseclib3\Net\SFTP;
 
+/**
+ * @method void disconnect()
+ */
 interface ConnectionProvider
 {
     public function provideConnection(): SFTP;

src/PhpseclibV3/SftpAdapter.php

@@ -58,6 +58,11 @@ public function fileExists(string $path): bool
         }
     }
 
+    public function disconnect(): void
+    {
+        $this->connectionProvider->disconnect();
+    }
+
     public function directoryExists(string $path): bool
     {
         $location = $this->prefixer->prefixDirectoryPath($path);

src/PhpseclibV3/SftpAdapterTest.php

@@ -30,7 +30,7 @@ public static function setUpBeforeClass(): void
     }
 
     /**
-     * @var ConnectionProvider
+     * @var StubSftpConnectionProvider
      */
     private static $connectionProvider;
 
@@ -214,9 +214,26 @@ public function list_contents_directory_does_not_exist(): void
         $this->assertCount(0, iterator_to_array($contents));
     }
 
-    private static function connectionProvider(): ConnectionProvider
+    /**
+     * @test
+     */
+    public function it_can_proactively_close_a_connection(): void
+    {
+        /** @var SftpAdapter $adapter */
+        $adapter = $this->adapter();
+
+        self::assertFalse($adapter->fileExists('does not exists at all'));
+
+        self::assertTrue(static::$connectionProvider->connection->isConnected());
+
+        $adapter->disconnect();
+
+        self::assertFalse(static::$connectionProvider->connection->isConnected());
+    }
+
+    private static function connectionProvider(): StubSftpConnectionProvider
     {
-        if ( ! static::$connectionProvider instanceof ConnectionProvider) {
+        if ( ! static::$connectionProvider instanceof StubSftpConnectionProvider) {
             static::$connectionProvider = new StubSftpConnectionProvider('localhost', 'foo', 'pass', 2222);
         }
 
@@ -229,8 +246,7 @@ private static function connectionProvider(): ConnectionProvider
     private function adapterWithInvalidRoot(): SftpAdapter
     {
         $provider = static::connectionProvider();
-        $adapter = new SftpAdapter($provider, '/invalid');
 
-        return $adapter;
+        return new SftpAdapter($provider, '/invalid');
     }
 }

src/PhpseclibV3/SftpConnectionProvider.php

@@ -83,6 +83,13 @@ public function provideConnection(): SFTP
         return $this->connection = $connection;
     }
 
+    public function disconnect(): void
+    {
+        if ($this->connection) {
+            $this->connection->disconnect();
+        }
+    }
+
     private function setupConnection(): SFTP
     {
         $connection = new SFTP($this->host, $this->port, $this->timeout);

src/PhpseclibV3/StubSftpConnectionProvider.php

@@ -9,9 +9,9 @@
 class StubSftpConnectionProvider implements ConnectionProvider
 {
     /**
-     * @var SftpStub
+     * @var SftpStub|null
      */
-    private $connection;
+    public $connection;
 
     public function __construct(
         private string $host,
@@ -21,6 +21,13 @@ public function __construct(
     ) {
     }
 
+    public function disconnect(): void
+    {
+        if ($this->connection) {
+            $this->connection->disconnect();
+        }
+    }
+
     public function provideConnection(): SFTP
     {
         if ( ! $this->connection instanceof SFTP) {