Dump ftp folder (Node.js)

ftp-dump.js

require('dotenv').config()
const ftp = require('ftp')
const fs = require('fs')
const { promisify } = require('util')

const env = {
  host: process.env.FTP_HOST,
  user: process.env.FTP_USER,
  password: process.env.FTP_PASS,
  folder: process.env.FTP_FOLDER || '/'
}

if (!env.host) {
  return console.log('No FTP_HOST provided')
}

if (!env.user) {
  return console.log('No FTP_USER provided')
}

if (!env.password) {
  return console.log('No FTP_PASS provided')
}

const client = new ftp()
client.asyncList = promisify(client.list)
client.asyncGet = promisify(client.get)

async function getElements(folder) {
  const result = await client.asyncList(folder)

  return result.map(({ name, type }) => ({ name, isFolder: type === 'd' }))
}

const downloadFile = async (file, path) => {
  const backupFolder = `./backup/`
  await fs.promises.mkdir(backupFolder, { recursive: true });

  return new Promise((res) => {
    const ws = fs.createWriteStream(path);
    file.pipe(ws);
    file.on('end', () => { res(); console.log(`${path} downloaded`) });
  })
}

const handleReady = async (folder = env.folder) => {
  try {
    const elements = await getElements(folder)
    for (const { name, isFolder } of elements) {
      if (isFolder) {
        const backupFolder = `./backup/${folder + name}`.replace(env.folder, '')
        await fs.promises.mkdir(backupFolder, { recursive: true });
        await handleReady(folder + name + "/")
      } else {
        const filePath = `./backup/${folder + name}`.replace(env.folder, '')
        if (!fs.existsSync(filePath)) {
          const file = await client.asyncGet(folder + name)
          await downloadFile(file, filePath)
        } else {
          console.log(`${filePath} has been downloaded already`)
        }
      }
    }

    if (folder === env.folder) {
      console.log('Backup is ready')
      client.end()
    }
  } catch (error) {
    console.log(error)
  }
}


try {
  client.connect({
    host: env.host,
    password: env.password,
    user: env.user,
  })

  client.on('ready', handleReady);
} catch (error) {
  console.log('Something went wrong')
}