Fix SftpAdapter not overwriting a file when moving

Author: matt

src/AdapterTestUtilities/FilesystemAdapterTestCase.php

@@ -643,6 +643,37 @@ public function moving_a_file(): void
         });
     }
 
+    /**
+     * @test
+     */
+    public function moving_a_file_and_overwriting(): void
+    {
+        $this->runScenario(function() {
+            $adapter = $this->adapter();
+            $adapter->write(
+                'source.txt',
+                'contents to be moved',
+                new Config([Config::OPTION_VISIBILITY => Visibility::PUBLIC])
+            );
+            $adapter->write(
+                'destination.txt',
+                'contents to be overwritten',
+                new Config([Config::OPTION_VISIBILITY => Visibility::PUBLIC])
+            );
+            $adapter->move('source.txt', 'destination.txt', new Config());
+            $this->assertFalse(
+                $adapter->fileExists('source.txt'),
+                'After moving a file should no longer exist in the original location.'
+            );
+            $this->assertTrue(
+                $adapter->fileExists('destination.txt'),
+                'After moving, a file should be present at the new location.'
+            );
+            $this->assertEquals(Visibility::PUBLIC, $adapter->visibility('destination.txt')->visibility());
+            $this->assertEquals('contents to be moved', $adapter->read('destination.txt'));
+        });
+    }
+
     /**
      * @test
      */

src/PhpseclibV3/SftpAdapter.php

@@ -318,9 +318,24 @@ public function move(string $source, string $destination, Config $config): void
             throw UnableToMoveFile::fromLocationTo($source, $destination, $exception);
         }
 
-        if ( ! $connection->rename($sourceLocation, $destinationLocation)) {
-            throw UnableToMoveFile::fromLocationTo($source, $destination);
+        if ($connection->rename($sourceLocation, $destinationLocation)) {
+            return;
+        }
+
+        // Overwrite existing file / dir
+        if ($connection->is_file($destinationLocation)) {
+            $this->delete($destination);
+            if ($connection->rename($sourceLocation, $destinationLocation)) {
+                return;
+            }
+        } elseif ($connection->is_dir($destinationLocation)) {
+            $this->deleteDirectory($destination);
+            if ($connection->rename($sourceLocation, $destinationLocation)) {
+                return;
+            }
         }
+
+        throw UnableToMoveFile::fromLocationTo($source, $destination);
     }
 
     public function copy(string $source, string $destination, Config $config): void