const { Client } = require('ssh2');
const fs = require('fs');
const path = require('path');

const conn = new Client();
const localDir = path.join(__dirname, 'dist', 'build', 'h5');
const remoteDir = '/www/huishou/dist/build/h5';

function uploadDir(sftp, local, remote, cb) {
  fs.readdir(local, { withFileTypes: true }, (err, entries) => {
    if (err) { cb(err); return; }
    let done = 0, hasErr = false;
    if (entries.length === 0) { cb(null); return; }
    entries.forEach(e => {
      const lp = path.join(local, e.name);
      const rp = remote + '/' + e.name;
      if (e.isDirectory()) {
        sftp.mkdir(rp, { recursive: true }, (me) => {
          if (me && me.code !== 4) console.log('mkdir err:', me);
          uploadDir(sftp, lp, rp, (de) => {
            if (de) { hasErr = true; cb(de); }
            if (++done === entries.length && !hasErr) cb(null);
          });
        });
      } else {
        fs.readFile(lp, (re, content) => {
          if (re) { hasErr = true; cb(re); return; }
          sftp.createWriteStream(rp).on('close', () => {
            if (++done === entries.length && !hasErr) cb(null);
          }).on('error', (we) => { hasErr = true; cb(we); }).end(content);
        });
      }
    });
  });
}

conn.on('ready', () => {
  conn.exec(`rm -rf ${remoteDir}/*`, () => {
    conn.sftp((err, sftp) => {
      if (err) { console.log('SFTP err:', err); conn.end(); return; }
      uploadDir(sftp, localDir, remoteDir, (err2) => {
        if (err2) { console.log('上传失败:', err2); }
        else {
          console.log('上传成功');
          conn.exec('/www/server/nginx/sbin/nginx -s reload', () => {
            console.log('Nginx已重启');
            sftp.end();
            conn.end();
          });
        }
      });
    });
  });
});

conn.connect({ host: 'hs.yifenbao.cn', port: 22, username: 'root', password: 'Torch1112' });