Can I Close FTP Connection

[WeMissing]

No API For Closing Connection！

[Mylogo]

Alright, will be implemented!

[WeMissing]

Thanks ，I has Added a function As :

const FtpClient = require('ftp') let SftpClient = require('ssh2-sftp-client'); const fs = require('fs')

class FileSystem {

}

class FileInfo { constructor(original) { this.original = original } getName() { return this.original.name } getSize() { return this.original.size } }

// credits going to https://geedew.com/remove-a-directory-that-is-not-empty-in-nodejs/ var deleteFolderRecursive = function(path) { if( fs.existsSync(path) ) { fs.readdirSync(path).forEach(function(file,index){ var curPath = path + "/" + file; if(fs.lstatSync(curPath).isDirectory()) { // recurse deleteFolderRecursive(curPath); } else { // delete file fs.unlinkSync(curPath); } }); fs.rmdirSync(path); } };

class LocalFileSystem extends FileSystem { constructor() { super() } static create() { return new Promise((resolve, reject) => { return resolve(new LocalFileSystem()) }) } async list(path) { return new Promise((resolve, reject) => { fs.readdir(path, async (err, files) => { if (err) { return reject(err) } await Promise.all( files.map(fileName => new Promise((res, reject) => { fs.stat(path + fileName, (err, stats) => { if (err) { return reject(err) } stats.name = fileName res(new LocalFileInfo(stats)) }) })) ).then(res => { resolve(res) }).catch(err => { reject(err) }) }) }) } put(src, toPath) { return new Promise((resolve, reject) => { try { const writeStream = fs.createWriteStream(toPath) src.pipe(writeStream) resolve(true) } catch (e) { reject(e) } }) } get(path) { return new Promise((resolve, reject) => { try { const readStream = fs.createReadStream(path) resolve(readStream) } catch (e) { reject(e) } }) } mkdir(path, recursive) { return fs.mkdir(path, { recursive }) } rmdir(path, recursive) { if (!recursive) return fs.rmdir(path) return new Promise((resolve, reject) => { try { deleteFolderRecursive(path) resolve(true) } catch (e) { reject(e) } }) } delete(path) { return new Promise((resolve, reject) => { fs.unlink(path, err => { if (err) { return reject(err) } resolve(true) }) }) } rename(oldPath, newPath) { return new Promise((resolve, reject) => { fs.rename(oldPath, newPath, err => { if (err) { return reject(err) } resolve(true) }) }) } // stats cannot be used with the current FTP library... so this feature will be left out for now // stat(path) { // return new Promise((resolve, reject) => { // fs.stat(path, (err, stats) => { // if (err) { // return reject(err) // } // resolve(new LocalFileInfo(stats)) // }) // }) // } }

class LocalFileInfo extends FileInfo { isDirectory() { return this.original.isDirectory() } }

class FtpFileSystem extends FileSystem { constructor(client) { super() this.client = client } static async create(host, port, user, password) { const c = new FtpClient() return new Promise((resolve, reject) => { c.on('ready', () => { resolve(new FtpFileSystem(c)) }) c.once('error', (err) => { reject(err) }) c.connect({ host, port, user, password }) }) } list(path) { return new Promise((resolve, reject) => { this.client.list(path, (err, listing) => { if (err) { return reject(err) } resolve(listing.map(l => new FtpFileInfo(l))) }) }) } put(src, toPath) { return new Promise((resolve, reject) => { this.client.put(src, toPath, (err) => { if (err) { reject(err) } resolve(true) }) }) } get(path) { return new Promise((resolve, reject) => { this.client.get(path, (err, stream) => { if (err) { return reject(err) } resolve(stream) }) }) } mkdir(path, recursive) { return new Promise((resolve, reject) => { this.client.mkdir(path, recursive, err => { if (err) { return reject(err) } resolve(true) }) }) } rmdir(path, recursive) { return new Promise((resolve, reject) => { this.client.rmdir(path, recursive, err => { if (err) { return reject(err) } resolve(1) }) }) } delete(path) { return new Promise((resolve, reject) => { this.client.delete(path, err => { if (err) { return reject(err) } resolve(path) }) }) } close() { return new Promise((resolve, reject) => { this.client.end(); resolve(true) }) } rename(oldPath, newPath) { return new Promise((resolve, reject) => { this.client.rename(oldPath, newPath, (err) => { if (err) { return reject(err) } resolve(true) }) }) } }

class FtpFileInfo extends FileInfo { constructor(original) { super(original) } isDirectory() { return this.original.type === 'd' } }

class SftpFileSystem extends FileSystem { constructor(client) { super() this.client = client } static async create(host, port, user, password) { const c = new SftpClient() return new Promise((resolve, reject) => { c.connect({ host, port, username: user, password }).then(() => { resolve(new SftpFileSystem(c)) }).catch(err => { reject(err) }) }) } async list(path) { return new Promise((resolve, reject) => { this.client.list(path) .then(paths => { resolve(paths.map(it => new SftpFileInfo(it))) }).catch(err => { reject(err) }) }) } put(src, toPath) { return this.client.put(src, toPath) } get(path) { return new Promise((resolve, reject) => { try { resolve(this.client.sftp.createReadStream(path)) } catch (e) { reject(e) } }) } mkdir(path, recursive) { return this.client.mkdir(path, recursive) } rmdir(path, recursive) { return this.client.rmdir(path, recursive) } delete(path) { return this.client.delete(path) } close() { return new Promise((resolve, reject) => { this.client.end(); resolve(true) }) } rename(oldPath, newPath) { return this.client.rename(oldPath, newPath) } }

class SftpFileInfo extends FileInfo { constructor(original) { super(original) } isDirectory() { return this.original.type === 'd' } }

module.exports = { FileSystem, FileInfo, LocalFileSystem, FtpFileSystem, SftpFileSystem, SftpFileInfo }