nextcloud / server

apps/files_external/lib/Lib/Storage/FTP.php

Indentation +345 added lines, -345 removed lines

@@ -31,349 +31,349 @@
 use OCP\Files\StorageNotAvailableException;
 
 class FTP extends Common {
-	use CopyDirectory;
-
-	private $root;
-	private $host;
-	private $password;
-	private $username;
-	private $secure;
-	private $port;
-	private $utf8Mode;
-
-	/** @var FtpConnection|null */
-	private $connection;
-
-	public function __construct($params) {
-		if (isset($params['host']) && isset($params['user']) && isset($params['password'])) {
-			$this->host = $params['host'];
-			$this->username = $params['user'];
-			$this->password = $params['password'];
-			if (isset($params['secure'])) {
-				if (is_string($params['secure'])) {
-					$this->secure = ($params['secure'] === 'true');
-				} else {
-					$this->secure = (bool)$params['secure'];
-				}
-			} else {
-				$this->secure = false;
-			}
-			$this->root = isset($params['root']) ? '/' . ltrim($params['root']) : '/';
-			$this->port = $params['port'] ?? 21;
-			$this->utf8Mode = isset($params['utf8']) && $params['utf8'];
-		} else {
-			throw new \Exception('Creating ' . self::class . ' storage failed, required parameters not set');
-		}
-	}
-
-	public function __destruct() {
-		$this->connection = null;
-	}
-
-	protected function getConnection(): FtpConnection {
-		if (!$this->connection) {
-			try {
-				$this->connection = new FtpConnection(
-					$this->secure,
-					$this->host,
-					$this->port,
-					$this->username,
-					$this->password
-				);
-			} catch (\Exception $e) {
-				throw new StorageNotAvailableException("Failed to create ftp connection", 0, $e);
-			}
-			if ($this->utf8Mode) {
-				if (!$this->connection->setUtf8Mode()) {
-					throw new StorageNotAvailableException("Could not set UTF-8 mode");
-				}
-			}
-		}
-
-		return $this->connection;
-	}
-
-	public function getId() {
-		return 'ftp::' . $this->username . '@' . $this->host . '/' . $this->root;
-	}
-
-	protected function buildPath($path) {
-		return rtrim($this->root . '/' . $path, '/');
-	}
-
-	public static function checkDependencies() {
-		if (function_exists('ftp_login')) {
-			return true;
-		} else {
-			return ['ftp'];
-		}
-	}
-
-	public function filemtime($path) {
-		$result = $this->getConnection()->mdtm($this->buildPath($path));
-
-		if ($result === -1) {
-			if ($this->is_dir($path)) {
-				$list = $this->getConnection()->mlsd($this->buildPath($path));
-				if (!$list) {
-					\OC::$server->getLogger()->warning("Unable to get last modified date for ftp folder ($path), failed to list folder contents");
-					return time();
-				}
-				$currentDir = current(array_filter($list, function ($item) {
-					return $item['type'] === 'cdir';
-				}));
-				if ($currentDir) {
-					[$modify] = explode('.', $currentDir['modify'] ?? '', 2);
-					$time = \DateTime::createFromFormat('YmdHis', $modify);
-					if ($time === false) {
-						throw new \Exception("Invalid date format for directory: $currentDir");
-					}
-					return $time->getTimestamp();
-				} else {
-					\OC::$server->getLogger()->warning("Unable to get last modified date for ftp folder ($path), folder contents doesn't include current folder");
-					return time();
-				}
-			} else {
-				return false;
-			}
-		} else {
-			return $result;
-		}
-	}
-
-	public function filesize($path): false|int|float {
-		$result = $this->getConnection()->size($this->buildPath($path));
-		if ($result === -1) {
-			return false;
-		} else {
-			return $result;
-		}
-	}
-
-	public function rmdir($path) {
-		if ($this->is_dir($path)) {
-			$result = $this->getConnection()->rmdir($this->buildPath($path));
-			// recursive rmdir support depends on the ftp server
-			if ($result) {
-				return $result;
-			} else {
-				return $this->recursiveRmDir($path);
-			}
-		} elseif ($this->is_file($path)) {
-			return $this->unlink($path);
-		} else {
-			return false;
-		}
-	}
-
-	/**
-	 * @param string $path
-	 * @return bool
-	 */
-	private function recursiveRmDir($path): bool {
-		$contents = $this->getDirectoryContent($path);
-		$result = true;
-		foreach ($contents as $content) {
-			if ($content['mimetype'] === FileInfo::MIMETYPE_FOLDER) {
-				$result = $result && $this->recursiveRmDir($path . '/' . $content['name']);
-			} else {
-				$result = $result && $this->getConnection()->delete($this->buildPath($path . '/' . $content['name']));
-			}
-		}
-		$result = $result && $this->getConnection()->rmdir($this->buildPath($path));
-
-		return $result;
-	}
-
-	public function test() {
-		try {
-			return $this->getConnection()->systype() !== false;
-		} catch (\Exception $e) {
-			return false;
-		}
-	}
-
-	public function stat($path) {
-		if (!$this->file_exists($path)) {
-			return false;
-		}
-		return [
-			'mtime' => $this->filemtime($path),
-			'size' => $this->filesize($path),
-		];
-	}
-
-	public function file_exists($path) {
-		if ($path === '' || $path === '.' || $path === '/') {
-			return true;
-		}
-		return $this->filetype($path) !== false;
-	}
-
-	public function unlink($path) {
-		switch ($this->filetype($path)) {
-			case 'dir':
-				return $this->rmdir($path);
-			case 'file':
-				return $this->getConnection()->delete($this->buildPath($path));
-			default:
-				return false;
-		}
-	}
-
-	public function opendir($path) {
-		$files = $this->getConnection()->nlist($this->buildPath($path));
-		return IteratorDirectory::wrap($files);
-	}
-
-	public function mkdir($path) {
-		if ($this->is_dir($path)) {
-			return false;
-		}
-		return $this->getConnection()->mkdir($this->buildPath($path)) !== false;
-	}
-
-	public function is_dir($path) {
-		if ($path === "") {
-			return true;
-		}
-		if ($this->getConnection()->chdir($this->buildPath($path)) === true) {
-			$this->getConnection()->chdir('/');
-			return true;
-		} else {
-			return false;
-		}
-	}
-
-	public function is_file($path) {
-		return $this->filesize($path) !== false;
-	}
-
-	public function filetype($path) {
-		if ($this->is_dir($path)) {
-			return 'dir';
-		} elseif ($this->is_file($path)) {
-			return 'file';
-		} else {
-			return false;
-		}
-	}
-
-	public function fopen($path, $mode) {
-		$useExisting = true;
-		switch ($mode) {
-			case 'r':
-			case 'rb':
-				return $this->readStream($path);
-			case 'w':
-			case 'w+':
-			case 'wb':
-			case 'wb+':
-				$useExisting = false;
-				// no break
-			case 'a':
-			case 'ab':
-			case 'r+':
-			case 'a+':
-			case 'x':
-			case 'x+':
-			case 'c':
-			case 'c+':
-				//emulate these
-				if ($useExisting and $this->file_exists($path)) {
-					if (!$this->isUpdatable($path)) {
-						return false;
-					}
-					$tmpFile = $this->getCachedFile($path);
-				} else {
-					if (!$this->isCreatable(dirname($path))) {
-						return false;
-					}
-					$tmpFile = \OC::$server->getTempManager()->getTemporaryFile();
-				}
-				$source = fopen($tmpFile, $mode);
-				return CallbackWrapper::wrap($source, null, null, function () use ($tmpFile, $path) {
-					$this->writeStream($path, fopen($tmpFile, 'r'));
-					unlink($tmpFile);
-				});
-		}
-		return false;
-	}
-
-	public function writeStream(string $path, $stream, int $size = null): int {
-		if ($size === null) {
-			$stream = CountWrapper::wrap($stream, function ($writtenSize) use (&$size) {
-				$size = $writtenSize;
-			});
-		}
-
-		$this->getConnection()->fput($this->buildPath($path), $stream);
-		fclose($stream);
-
-		return $size;
-	}
-
-	public function readStream(string $path) {
-		$stream = fopen('php://temp', 'w+');
-		$result = $this->getConnection()->fget($stream, $this->buildPath($path));
-		rewind($stream);
-
-		if (!$result) {
-			fclose($stream);
-			return false;
-		}
-		return $stream;
-	}
-
-	public function touch($path, $mtime = null) {
-		if ($this->file_exists($path)) {
-			return false;
-		} else {
-			$this->file_put_contents($path, '');
-			return true;
-		}
-	}
-
-	public function rename($source, $target) {
-		$this->unlink($target);
-		return $this->getConnection()->rename($this->buildPath($source), $this->buildPath($target));
-	}
-
-	public function getDirectoryContent($directory): \Traversable {
-		$files = $this->getConnection()->mlsd($this->buildPath($directory));
-		$mimeTypeDetector = \OC::$server->getMimeTypeDetector();
-
-		foreach ($files as $file) {
-			$name = $file['name'];
-			if ($file['type'] === 'cdir' || $file['type'] === 'pdir') {
-				continue;
-			}
-			$permissions = Constants::PERMISSION_ALL - Constants::PERMISSION_CREATE;
-			$isDir = $file['type'] === 'dir';
-			if ($isDir) {
-				$permissions += Constants::PERMISSION_CREATE;
-			}
-
-			$data = [];
-			$data['mimetype'] = $isDir ? FileInfo::MIMETYPE_FOLDER : $mimeTypeDetector->detectPath($name);
-
-			// strip fractional seconds
-			[$modify] = explode('.', $file['modify'], 2);
-			$mtime = \DateTime::createFromFormat('YmdGis', $modify);
-			$data['mtime'] = $mtime === false ? time() : $mtime->getTimestamp();
-			if ($isDir) {
-				$data['size'] = -1; //unknown
-			} elseif (isset($file['size'])) {
-				$data['size'] = $file['size'];
-			} else {
-				$data['size'] = $this->filesize($directory . '/' . $name);
-			}
-			$data['etag'] = uniqid();
-			$data['storage_mtime'] = $data['mtime'];
-			$data['permissions'] = $permissions;
-			$data['name'] = $name;
-
-			yield $data;
-		}
-	}
+    use CopyDirectory;
+
+    private $root;
+    private $host;
+    private $password;
+    private $username;
+    private $secure;
+    private $port;
+    private $utf8Mode;
+
+    /** @var FtpConnection|null */
+    private $connection;
+
+    public function __construct($params) {
+        if (isset($params['host']) && isset($params['user']) && isset($params['password'])) {
+            $this->host = $params['host'];
+            $this->username = $params['user'];
+            $this->password = $params['password'];
+            if (isset($params['secure'])) {
+                if (is_string($params['secure'])) {
+                    $this->secure = ($params['secure'] === 'true');
+                } else {
+                    $this->secure = (bool)$params['secure'];
+                }
+            } else {
+                $this->secure = false;
+            }
+            $this->root = isset($params['root']) ? '/' . ltrim($params['root']) : '/';
+            $this->port = $params['port'] ?? 21;
+            $this->utf8Mode = isset($params['utf8']) && $params['utf8'];
+        } else {
+            throw new \Exception('Creating ' . self::class . ' storage failed, required parameters not set');
+        }
+    }
+
+    public function __destruct() {
+        $this->connection = null;
+    }
+
+    protected function getConnection(): FtpConnection {
+        if (!$this->connection) {
+            try {
+                $this->connection = new FtpConnection(
+                    $this->secure,
+                    $this->host,
+                    $this->port,
+                    $this->username,
+                    $this->password
+                );
+            } catch (\Exception $e) {
+                throw new StorageNotAvailableException("Failed to create ftp connection", 0, $e);
+            }
+            if ($this->utf8Mode) {
+                if (!$this->connection->setUtf8Mode()) {
+                    throw new StorageNotAvailableException("Could not set UTF-8 mode");
+                }
+            }
+        }
+
+        return $this->connection;
+    }
+
+    public function getId() {
+        return 'ftp::' . $this->username . '@' . $this->host . '/' . $this->root;
+    }
+
+    protected function buildPath($path) {
+        return rtrim($this->root . '/' . $path, '/');
+    }
+
+    public static function checkDependencies() {
+        if (function_exists('ftp_login')) {
+            return true;
+        } else {
+            return ['ftp'];
+        }
+    }
+
+    public function filemtime($path) {
+        $result = $this->getConnection()->mdtm($this->buildPath($path));
+
+        if ($result === -1) {
+            if ($this->is_dir($path)) {
+                $list = $this->getConnection()->mlsd($this->buildPath($path));
+                if (!$list) {
+                    \OC::$server->getLogger()->warning("Unable to get last modified date for ftp folder ($path), failed to list folder contents");
+                    return time();
+                }
+                $currentDir = current(array_filter($list, function ($item) {
+                    return $item['type'] === 'cdir';
+                }));
+                if ($currentDir) {
+                    [$modify] = explode('.', $currentDir['modify'] ?? '', 2);
+                    $time = \DateTime::createFromFormat('YmdHis', $modify);
+                    if ($time === false) {
+                        throw new \Exception("Invalid date format for directory: $currentDir");
+                    }
+                    return $time->getTimestamp();
+                } else {
+                    \OC::$server->getLogger()->warning("Unable to get last modified date for ftp folder ($path), folder contents doesn't include current folder");
+                    return time();
+                }
+            } else {
+                return false;
+            }
+        } else {
+            return $result;
+        }
+    }
+
+    public function filesize($path): false|int|float {
+        $result = $this->getConnection()->size($this->buildPath($path));
+        if ($result === -1) {
+            return false;
+        } else {
+            return $result;
+        }
+    }
+
+    public function rmdir($path) {
+        if ($this->is_dir($path)) {
+            $result = $this->getConnection()->rmdir($this->buildPath($path));
+            // recursive rmdir support depends on the ftp server
+            if ($result) {
+                return $result;
+            } else {
+                return $this->recursiveRmDir($path);
+            }
+        } elseif ($this->is_file($path)) {
+            return $this->unlink($path);
+        } else {
+            return false;
+        }
+    }
+
+    /**
+     * @param string $path
+     * @return bool
+     */
+    private function recursiveRmDir($path): bool {
+        $contents = $this->getDirectoryContent($path);
+        $result = true;
+        foreach ($contents as $content) {
+            if ($content['mimetype'] === FileInfo::MIMETYPE_FOLDER) {
+                $result = $result && $this->recursiveRmDir($path . '/' . $content['name']);
+            } else {
+                $result = $result && $this->getConnection()->delete($this->buildPath($path . '/' . $content['name']));
+            }
+        }
+        $result = $result && $this->getConnection()->rmdir($this->buildPath($path));
+
+        return $result;
+    }
+
+    public function test() {
+        try {
+            return $this->getConnection()->systype() !== false;
+        } catch (\Exception $e) {
+            return false;
+        }
+    }
+
+    public function stat($path) {
+        if (!$this->file_exists($path)) {
+            return false;
+        }
+        return [
+            'mtime' => $this->filemtime($path),
+            'size' => $this->filesize($path),
+        ];
+    }
+
+    public function file_exists($path) {
+        if ($path === '' || $path === '.' || $path === '/') {
+            return true;
+        }
+        return $this->filetype($path) !== false;
+    }
+
+    public function unlink($path) {
+        switch ($this->filetype($path)) {
+            case 'dir':
+                return $this->rmdir($path);
+            case 'file':
+                return $this->getConnection()->delete($this->buildPath($path));
+            default:
+                return false;
+        }
+    }
+
+    public function opendir($path) {
+        $files = $this->getConnection()->nlist($this->buildPath($path));
+        return IteratorDirectory::wrap($files);
+    }
+
+    public function mkdir($path) {
+        if ($this->is_dir($path)) {
+            return false;
+        }
+        return $this->getConnection()->mkdir($this->buildPath($path)) !== false;
+    }
+
+    public function is_dir($path) {
+        if ($path === "") {
+            return true;
+        }
+        if ($this->getConnection()->chdir($this->buildPath($path)) === true) {
+            $this->getConnection()->chdir('/');
+            return true;
+        } else {
+            return false;
+        }
+    }
+
+    public function is_file($path) {
+        return $this->filesize($path) !== false;
+    }
+
+    public function filetype($path) {
+        if ($this->is_dir($path)) {
+            return 'dir';
+        } elseif ($this->is_file($path)) {
+            return 'file';
+        } else {
+            return false;
+        }
+    }
+
+    public function fopen($path, $mode) {
+        $useExisting = true;
+        switch ($mode) {
+            case 'r':
+            case 'rb':
+                return $this->readStream($path);
+            case 'w':
+            case 'w+':
+            case 'wb':
+            case 'wb+':
+                $useExisting = false;
+                // no break
+            case 'a':
+            case 'ab':
+            case 'r+':
+            case 'a+':
+            case 'x':
+            case 'x+':
+            case 'c':
+            case 'c+':
+                //emulate these
+                if ($useExisting and $this->file_exists($path)) {
+                    if (!$this->isUpdatable($path)) {
+                        return false;
+                    }
+                    $tmpFile = $this->getCachedFile($path);
+                } else {
+                    if (!$this->isCreatable(dirname($path))) {
+                        return false;
+                    }
+                    $tmpFile = \OC::$server->getTempManager()->getTemporaryFile();
+                }
+                $source = fopen($tmpFile, $mode);
+                return CallbackWrapper::wrap($source, null, null, function () use ($tmpFile, $path) {
+                    $this->writeStream($path, fopen($tmpFile, 'r'));
+                    unlink($tmpFile);
+                });
+        }
+        return false;
+    }
+
+    public function writeStream(string $path, $stream, int $size = null): int {
+        if ($size === null) {
+            $stream = CountWrapper::wrap($stream, function ($writtenSize) use (&$size) {
+                $size = $writtenSize;
+            });
+        }
+
+        $this->getConnection()->fput($this->buildPath($path), $stream);
+        fclose($stream);
+
+        return $size;
+    }
+
+    public function readStream(string $path) {
+        $stream = fopen('php://temp', 'w+');
+        $result = $this->getConnection()->fget($stream, $this->buildPath($path));
+        rewind($stream);
+
+        if (!$result) {
+            fclose($stream);
+            return false;
+        }
+        return $stream;
+    }
+
+    public function touch($path, $mtime = null) {
+        if ($this->file_exists($path)) {
+            return false;
+        } else {
+            $this->file_put_contents($path, '');
+            return true;
+        }
+    }
+
+    public function rename($source, $target) {
+        $this->unlink($target);
+        return $this->getConnection()->rename($this->buildPath($source), $this->buildPath($target));
+    }
+
+    public function getDirectoryContent($directory): \Traversable {
+        $files = $this->getConnection()->mlsd($this->buildPath($directory));
+        $mimeTypeDetector = \OC::$server->getMimeTypeDetector();
+
+        foreach ($files as $file) {
+            $name = $file['name'];
+            if ($file['type'] === 'cdir' || $file['type'] === 'pdir') {
+                continue;
+            }
+            $permissions = Constants::PERMISSION_ALL - Constants::PERMISSION_CREATE;
+            $isDir = $file['type'] === 'dir';
+            if ($isDir) {
+                $permissions += Constants::PERMISSION_CREATE;
+            }
+
+            $data = [];
+            $data['mimetype'] = $isDir ? FileInfo::MIMETYPE_FOLDER : $mimeTypeDetector->detectPath($name);
+
+            // strip fractional seconds
+            [$modify] = explode('.', $file['modify'], 2);
+            $mtime = \DateTime::createFromFormat('YmdGis', $modify);
+            $data['mtime'] = $mtime === false ? time() : $mtime->getTimestamp();
+            if ($isDir) {
+                $data['size'] = -1; //unknown
+            } elseif (isset($file['size'])) {
+                $data['size'] = $file['size'];
+            } else {
+                $data['size'] = $this->filesize($directory . '/' . $name);
+            }
+            $data['etag'] = uniqid();
+            $data['storage_mtime'] = $data['mtime'];
+            $data['permissions'] = $permissions;
+            $data['name'] = $name;
+
+            yield $data;
+        }
+    }
 }

apps/files_external/lib/Lib/Storage/FtpConnection.php

Indentation +210 added lines, -210 removed lines

@@ -27,214 +27,214 @@
  * Low level wrapper around the ftp functions that smooths over some difference between servers
  */
 class FtpConnection {
-	/** @var resource|\FTP\Connection */
-	private $connection;
-
-	public function __construct(bool $secure, string $hostname, int $port, string $username, string $password) {
-		if ($secure) {
-			$connection = ftp_ssl_connect($hostname, $port);
-		} else {
-			$connection = ftp_connect($hostname, $port);
-		}
-
-		if ($connection === false) {
-			throw new \Exception("Failed to connect to ftp");
-		}
-
-		if (ftp_login($connection, $username, $password) === false) {
-			throw new \Exception("Failed to connect to login to ftp");
-		}
-
-		ftp_pasv($connection, true);
-		$this->connection = $connection;
-	}
-
-	public function __destruct() {
-		if ($this->connection) {
-			ftp_close($this->connection);
-		}
-		$this->connection = null;
-	}
-
-	public function setUtf8Mode(): bool {
-		$response = ftp_raw($this->connection, "OPTS UTF8 ON");
-		return substr($response[0], 0, 3) === '200';
-	}
-
-	public function fput(string $path, $handle) {
-		return @ftp_fput($this->connection, $path, $handle, FTP_BINARY);
-	}
-
-	public function fget($handle, string $path) {
-		return @ftp_fget($this->connection, $handle, $path, FTP_BINARY);
-	}
-
-	public function mkdir(string $path) {
-		return @ftp_mkdir($this->connection, $path);
-	}
-
-	public function chdir(string $path) {
-		return @ftp_chdir($this->connection, $path);
-	}
-
-	public function delete(string $path) {
-		return @ftp_delete($this->connection, $path);
-	}
-
-	public function rmdir(string $path) {
-		return @ftp_rmdir($this->connection, $path);
-	}
-
-	public function rename(string $source, string $target) {
-		return @ftp_rename($this->connection, $source, $target);
-	}
-
-	public function mdtm(string $path): int {
-		$result = @ftp_mdtm($this->connection, $path);
-
-		// filezilla doesn't like empty path with mdtm
-		if ($result === -1 && $path === "") {
-			$result = @ftp_mdtm($this->connection, "/");
-		}
-		return $result;
-	}
-
-	public function size(string $path) {
-		return @ftp_size($this->connection, $path);
-	}
-
-	public function systype() {
-		return @ftp_systype($this->connection);
-	}
-
-	public function nlist(string $path) {
-		$files = @ftp_nlist($this->connection, $path);
-		return array_map(function ($name) {
-			if (strpos($name, '/') !== false) {
-				$name = basename($name);
-			}
-			return $name;
-		}, $files);
-	}
-
-	public function mlsd(string $path) {
-		$files = @ftp_mlsd($this->connection, $path);
-
-		if ($files !== false) {
-			return array_map(function ($file) {
-				if (strpos($file['name'], '/') !== false) {
-					$file['name'] = basename($file['name']);
-				}
-				return $file;
-			}, $files);
-		} else {
-			// not all servers support mlsd, in those cases we parse the raw list ourselves
-			$rawList = @ftp_rawlist($this->connection, '-aln ' . $path);
-			if ($rawList === false) {
-				return false;
-			}
-			return $this->parseRawList($rawList, $path);
-		}
-	}
-
-	// rawlist parsing logic is based on the ftp implementation from https://github.com/thephpleague/flysystem
-	private function parseRawList(array $rawList, string $directory): array {
-		return array_map(function ($item) use ($directory) {
-			return $this->parseRawListItem($item, $directory);
-		}, $rawList);
-	}
-
-	private function parseRawListItem(string $item, string $directory): array {
-		$isWindows = preg_match('/^[0-9]{2,4}-[0-9]{2}-[0-9]{2}/', $item);
-
-		return $isWindows ? $this->parseWindowsItem($item, $directory) : $this->parseUnixItem($item, $directory);
-	}
-
-	private function parseUnixItem(string $item, string $directory): array {
-		$item = preg_replace('#\s+#', ' ', $item, 7);
-
-		if (count(explode(' ', $item, 9)) !== 9) {
-			throw new \RuntimeException("Metadata can't be parsed from item '$item' , not enough parts.");
-		}
-
-		[$permissions, /* $number */, /* $owner */, /* $group */, $size, $month, $day, $time, $name] = explode(' ', $item, 9);
-		if ($name === '.') {
-			$type = 'cdir';
-		} elseif ($name === '..') {
-			$type = 'pdir';
-		} else {
-			$type = substr($permissions, 0, 1) === 'd' ? 'dir' : 'file';
-		}
-
-		$parsedDate = (new \DateTime())
-			->setTimestamp(strtotime("$month $day $time"));
-		$tomorrow = (new \DateTime())->add(new \DateInterval("P1D"));
-
-		// since the provided date doesn't include the year, we either set it to the correct year
-		// or when the date would otherwise be in the future (by more then 1 day to account for timezone errors)
-		// we use last year
-		if ($parsedDate > $tomorrow) {
-			$parsedDate = $parsedDate->sub(new \DateInterval("P1Y"));
-		}
-
-		$formattedDate = $parsedDate
-			->format('YmdHis');
-
-		return [
-			'type' => $type,
-			'name' => $name,
-			'modify' => $formattedDate,
-			'perm' => $this->normalizePermissions($permissions),
-			'size' => (int)$size,
-		];
-	}
-
-	private function normalizePermissions(string $permissions) {
-		$isDir = substr($permissions, 0, 1) === 'd';
-		// remove the type identifier and only use owner permissions
-		$permissions = substr($permissions, 1, 4);
-
-		// map the string rights to the ftp counterparts
-		$filePermissionsMap = ['r' => 'r', 'w' => 'fadfw'];
-		$dirPermissionsMap = ['r' => 'e', 'w' => 'flcdmp'];
-
-		$map = $isDir ? $dirPermissionsMap : $filePermissionsMap;
-
-		return array_reduce(str_split($permissions), function ($ftpPermissions, $permission) use ($map) {
-			if (isset($map[$permission])) {
-				$ftpPermissions .= $map[$permission];
-			}
-			return $ftpPermissions;
-		}, '');
-	}
-
-	private function parseWindowsItem(string $item, string $directory): array {
-		$item = preg_replace('#\s+#', ' ', trim($item), 3);
-
-		if (count(explode(' ', $item, 4)) !== 4) {
-			throw new \RuntimeException("Metadata can't be parsed from item '$item' , not enough parts.");
-		}
-
-		[$date, $time, $size, $name] = explode(' ', $item, 4);
-
-		// Check for the correct date/time format
-		$format = strlen($date) === 8 ? 'm-d-yH:iA' : 'Y-m-dH:i';
-		$formattedDate = \DateTime::createFromFormat($format, $date . $time)->format('YmdGis');
-
-		if ($name === '.') {
-			$type = 'cdir';
-		} elseif ($name === '..') {
-			$type = 'pdir';
-		} else {
-			$type = ($size === '<DIR>') ? 'dir' : 'file';
-		}
-
-		return [
-			'type' => $type,
-			'name' => $name,
-			'modify' => $formattedDate,
-			'perm' => ($type === 'file') ? 'adfrw' : 'flcdmpe',
-			'size' => (int)$size,
-		];
-	}
+    /** @var resource|\FTP\Connection */
+    private $connection;
+
+    public function __construct(bool $secure, string $hostname, int $port, string $username, string $password) {
+        if ($secure) {
+            $connection = ftp_ssl_connect($hostname, $port);
+        } else {
+            $connection = ftp_connect($hostname, $port);
+        }
+
+        if ($connection === false) {
+            throw new \Exception("Failed to connect to ftp");
+        }
+
+        if (ftp_login($connection, $username, $password) === false) {
+            throw new \Exception("Failed to connect to login to ftp");
+        }
+
+        ftp_pasv($connection, true);
+        $this->connection = $connection;
+    }
+
+    public function __destruct() {
+        if ($this->connection) {
+            ftp_close($this->connection);
+        }
+        $this->connection = null;
+    }
+
+    public function setUtf8Mode(): bool {
+        $response = ftp_raw($this->connection, "OPTS UTF8 ON");
+        return substr($response[0], 0, 3) === '200';
+    }
+
+    public function fput(string $path, $handle) {
+        return @ftp_fput($this->connection, $path, $handle, FTP_BINARY);
+    }
+
+    public function fget($handle, string $path) {
+        return @ftp_fget($this->connection, $handle, $path, FTP_BINARY);
+    }
+
+    public function mkdir(string $path) {
+        return @ftp_mkdir($this->connection, $path);
+    }
+
+    public function chdir(string $path) {
+        return @ftp_chdir($this->connection, $path);
+    }
+
+    public function delete(string $path) {
+        return @ftp_delete($this->connection, $path);
+    }
+
+    public function rmdir(string $path) {
+        return @ftp_rmdir($this->connection, $path);
+    }
+
+    public function rename(string $source, string $target) {
+        return @ftp_rename($this->connection, $source, $target);
+    }
+
+    public function mdtm(string $path): int {
+        $result = @ftp_mdtm($this->connection, $path);
+
+        // filezilla doesn't like empty path with mdtm
+        if ($result === -1 && $path === "") {
+            $result = @ftp_mdtm($this->connection, "/");
+        }
+        return $result;
+    }
+
+    public function size(string $path) {
+        return @ftp_size($this->connection, $path);
+    }
+
+    public function systype() {
+        return @ftp_systype($this->connection);
+    }
+
+    public function nlist(string $path) {
+        $files = @ftp_nlist($this->connection, $path);
+        return array_map(function ($name) {
+            if (strpos($name, '/') !== false) {
+                $name = basename($name);
+            }
+            return $name;
+        }, $files);
+    }
+
+    public function mlsd(string $path) {
+        $files = @ftp_mlsd($this->connection, $path);
+
+        if ($files !== false) {
+            return array_map(function ($file) {
+                if (strpos($file['name'], '/') !== false) {
+                    $file['name'] = basename($file['name']);
+                }
+                return $file;
+            }, $files);
+        } else {
+            // not all servers support mlsd, in those cases we parse the raw list ourselves
+            $rawList = @ftp_rawlist($this->connection, '-aln ' . $path);
+            if ($rawList === false) {
+                return false;
+            }
+            return $this->parseRawList($rawList, $path);
+        }
+    }
+
+    // rawlist parsing logic is based on the ftp implementation from https://github.com/thephpleague/flysystem
+    private function parseRawList(array $rawList, string $directory): array {
+        return array_map(function ($item) use ($directory) {
+            return $this->parseRawListItem($item, $directory);
+        }, $rawList);
+    }
+
+    private function parseRawListItem(string $item, string $directory): array {
+        $isWindows = preg_match('/^[0-9]{2,4}-[0-9]{2}-[0-9]{2}/', $item);
+
+        return $isWindows ? $this->parseWindowsItem($item, $directory) : $this->parseUnixItem($item, $directory);
+    }
+
+    private function parseUnixItem(string $item, string $directory): array {
+        $item = preg_replace('#\s+#', ' ', $item, 7);
+
+        if (count(explode(' ', $item, 9)) !== 9) {
+            throw new \RuntimeException("Metadata can't be parsed from item '$item' , not enough parts.");
+        }
+
+        [$permissions, /* $number */, /* $owner */, /* $group */, $size, $month, $day, $time, $name] = explode(' ', $item, 9);
+        if ($name === '.') {
+            $type = 'cdir';
+        } elseif ($name === '..') {
+            $type = 'pdir';
+        } else {
+            $type = substr($permissions, 0, 1) === 'd' ? 'dir' : 'file';
+        }
+
+        $parsedDate = (new \DateTime())
+            ->setTimestamp(strtotime("$month $day $time"));
+        $tomorrow = (new \DateTime())->add(new \DateInterval("P1D"));
+
+        // since the provided date doesn't include the year, we either set it to the correct year
+        // or when the date would otherwise be in the future (by more then 1 day to account for timezone errors)
+        // we use last year
+        if ($parsedDate > $tomorrow) {
+            $parsedDate = $parsedDate->sub(new \DateInterval("P1Y"));
+        }
+
+        $formattedDate = $parsedDate
+            ->format('YmdHis');
+
+        return [
+            'type' => $type,
+            'name' => $name,
+            'modify' => $formattedDate,
+            'perm' => $this->normalizePermissions($permissions),
+            'size' => (int)$size,
+        ];
+    }
+
+    private function normalizePermissions(string $permissions) {
+        $isDir = substr($permissions, 0, 1) === 'd';
+        // remove the type identifier and only use owner permissions
+        $permissions = substr($permissions, 1, 4);
+
+        // map the string rights to the ftp counterparts
+        $filePermissionsMap = ['r' => 'r', 'w' => 'fadfw'];
+        $dirPermissionsMap = ['r' => 'e', 'w' => 'flcdmp'];
+
+        $map = $isDir ? $dirPermissionsMap : $filePermissionsMap;
+
+        return array_reduce(str_split($permissions), function ($ftpPermissions, $permission) use ($map) {
+            if (isset($map[$permission])) {
+                $ftpPermissions .= $map[$permission];
+            }
+            return $ftpPermissions;
+        }, '');
+    }
+
+    private function parseWindowsItem(string $item, string $directory): array {
+        $item = preg_replace('#\s+#', ' ', trim($item), 3);
+
+        if (count(explode(' ', $item, 4)) !== 4) {
+            throw new \RuntimeException("Metadata can't be parsed from item '$item' , not enough parts.");
+        }
+
+        [$date, $time, $size, $name] = explode(' ', $item, 4);
+
+        // Check for the correct date/time format
+        $format = strlen($date) === 8 ? 'm-d-yH:iA' : 'Y-m-dH:i';
+        $formattedDate = \DateTime::createFromFormat($format, $date . $time)->format('YmdGis');
+
+        if ($name === '.') {
+            $type = 'cdir';
+        } elseif ($name === '..') {
+            $type = 'pdir';
+        } else {
+            $type = ($size === '<DIR>') ? 'dir' : 'file';
+        }
+
+        return [
+            'type' => $type,
+            'name' => $name,
+            'modify' => $formattedDate,
+            'perm' => ($type === 'file') ? 'adfrw' : 'flcdmpe',
+            'size' => (int)$size,
+        ];
+    }
 }