.

access.js

@@ -8,10 +8,11 @@ const qs = require("qs");
 const fs = require("fs");
 const path = require("path");
 const { NodeSSH } = require("node-ssh");
+const SftpClient = require("ssh2-sftp-client");
 const { exec } = require("child_process");
 const { spawn } = require("child_process");
-const progressStream = require("progress-stream");
 const ProgressBar = require("progress");
+const Multiprogress = require("multi-progress");
 const config = require("./config.json");
 const servers = require("./servers.json");
 
@@ -186,6 +187,7 @@ const getAccess = (dev) => {
 //     console.log(`build finished with code ${code}`);
 
 // });
+let multi = new Multiprogress(process.stdout);
 new Promise((resolve, reject) => {
     checkSessionId()
         .then(() => {
@@ -197,11 +199,14 @@ new Promise((resolve, reject) => {
                 resolve();
             });
         });
-})
-    .then(() => {
-        return getAccess(6908);
-    })
-    .then((res) => {
+}).then(() => {
+    upload(servers[0].id);
+    // upload(servers[5].id);
+    // upload(servers[6].id);
+});
+
+const upload = (dev) => {
+    return getAccess(dev).then((res) => {
         console.log(res);
 
         const buffer = Buffer.from(
@@ -217,20 +222,27 @@ new Promise((resolve, reject) => {
             console.log(accessJson);
 
             const ssh = new NodeSSH();
+
             ssh.connect({
                 host: accessJson.Host,
                 username: accessJson.User,
                 password: accessJson.PWD,
             })
                 .then(() => {
+                    ssh.connection.on("error", (err) => {
+                        console.log("sftp err", err);
+                    });
                     ssh.connection.sftp((err, sftp) => {
                         if (err) throw err;
+                        // var stat = fs.statSync(
+                        //     path.resolve(config.projectDir, "build.tar.gz")
+                        // );
                         var stat = fs.statSync(
-                            path.resolve(config.projectDir, "build.tar.gz")
+                            "/Users/drew/Desktop/DBQNL.jpeg"
                         );
                         let size = stat.size;
                         let uploadedSize = 0;
-                        var bar = new ProgressBar(
+                        var bar = multi.newBar(
                             "  uploading [:bar] :rate/bps :percent :etas",
                             {
                                 complete: "=",
@@ -239,51 +251,35 @@ new Promise((resolve, reject) => {
                                 total: size,
                             }
                         );
+                        // let readStream = fs.createReadStream(
+                        //     path.resolve(config.projectDir, "build.tar.gz")
+                        // );
                         let readStream = fs.createReadStream(
-                            path.resolve(config.projectDir, "build.tar.gz")
+                            "/Users/drew/Desktop/DBQNL.jpeg"
+                        );
+                        let writeStream = sftp.createWriteStream(
+                            "/home/admin/123.tar.gz"
                         );
                         readStream.on("data", function (buffer) {
                             uploadedSize += buffer.length;
                             bar.tick(buffer.length);
+                            if (uploadedSize === size) {
+                                console.log("finish");
+                                setTimeout(() => {
+                                    sftp.end();
+                                }, 400);
+                            }
                         });
 
                         // Some other events you might want for your code
-                        readStream.on("end", function () {
-                            console.log("Event: end");
-                        });
-                        readStream.on("close", function () {
-                            console.log("Event: close");
-                        });
-                        readStream.pipe(
-                            sftp.createWriteStream("/home/admin/123.tar.gz")
-                        );
+                        readStream.on("end", function () {});
+                        readStream.on("close", function () {});
+                        readStream.pipe(writeStream);
                     });
-                    // ssh.putFile(
-                    //     path.resolve(config.projectDir, "build.tar.gz"),
-                    //     "/home/admin/build.tar.gz",
-                    //     undefined,
-                    //     {
-                    //         step: (total_transferred, chunk, total) => {
-                    //             console.log(
-                    //                 "Uploaded",
-                    //                 total_transferred,
-                    //                 "of",
-                    //                 total
-                    //             );
-                    //         },
-                    //     }
-                    // ).then(
-                    //     function () {
-                    //         console.log("The File thing is done");
-                    //     },
-                    //     function (error) {
-                    //         console.log("Something's wrong");
-                    //         console.log(error);
-                    //     }
-                    // );
                 })
                 .catch((e) => {
-                    console.log(e);
+                    console.log("err", e);
                 });
         });
     });
+};

package.json

@@ -2,6 +2,7 @@
   "dependencies": {
     "axios": "^0.21.4",
     "crypto-js": "^4.1.1",
+    "multi-progress": "^4.0.0",
     "node-html-parser": "^4.1.4",
     "node-ssh": "^12.0.0",
     "progress": "^2.0.3",
@@ -9,6 +10,7 @@
     "qs": "^6.10.1",
     "request": "^2.88.2",
     "ssh2": "^1.4.0",
+    "ssh2-sftp-client": "^7.0.4",
     "vorpal": "^1.12.0"
   }
 }

yarn.lock

@@ -90,6 +90,11 @@ boolbase@^1.0.0:
   resolved "https://registry.yarnpkg.com/boolbase/-/boolbase-1.0.0.tgz#68dff5fbe60c51eb37725ea9e3ed310dcc1e776e"
   integrity sha1-aN/1++YMUes3cl6p4+0xDcwed24=
 
+buffer-from@^1.0.0:
+  version "1.1.2"
+  resolved "https://registry.nlark.com/buffer-from/download/buffer-from-1.1.2.tgz#2b146a6fd72e80b4f55d255f35ed59a3a9a41bd5"
+  integrity sha1-KxRqb9cugLT1XSVfNe1Zo6mkG9U=
+
 call-bind@^1.0.0:
   version "1.0.2"
   resolved "https://registry.yarnpkg.com/call-bind/-/call-bind-1.0.2.tgz#b1d4e89e688119c3c9a903ad30abb2f6a919be3c"
@@ -138,6 +143,16 @@ combined-stream@^1.0.6, combined-stream@~1.0.6:
   dependencies:
     delayed-stream "~1.0.0"
 
+concat-stream@^2.0.0:
+  version "2.0.0"
+  resolved "https://registry.nlark.com/concat-stream/download/concat-stream-2.0.0.tgz#414cf5af790a48c60ab9be4527d56d5e41133cb1"
+  integrity sha1-QUz1r3kKSMYKub5FJ9VtXkETPLE=
+  dependencies:
+    buffer-from "^1.0.0"
+    inherits "^2.0.3"
+    readable-stream "^3.0.2"
+    typedarray "^0.0.6"
+
 core-js@^2.4.0, core-js@^2.5.0:
   version "2.6.12"
   resolved "https://registry.yarnpkg.com/core-js/-/core-js-2.6.12.tgz#d9333dfa7b065e347cc5682219d6f690859cc2ec"
@@ -236,6 +251,11 @@ entities@^2.0.0:
   resolved "https://registry.yarnpkg.com/entities/-/entities-2.2.0.tgz#098dc90ebb83d8dffa089d55256b351d34c4da55"
   integrity sha512-p92if5Nz619I0w+akJrLZH0MX0Pb5DX39XOwQTtXSdQQOaYH03S1uIQp4mhOZtAXrxq4ViO67YTiLBo2638o9A==
 
+err-code@^2.0.2:
+  version "2.0.3"
+  resolved "https://registry.nlark.com/err-code/download/err-code-2.0.3.tgz#23c2f3b756ffdfc608d30e27c9a941024807e7f9"
+  integrity sha1-I8Lzt1b/38YI0w4nyalBAkgH5/k=
+
 escape-string-regexp@^1.0.2, escape-string-regexp@^1.0.5:
   version "1.0.5"
   resolved "https://registry.yarnpkg.com/escape-string-regexp/-/escape-string-regexp-1.0.5.tgz#1b61c0562190a8dff6ae3bb2cf0200ca130b86d4"
@@ -370,7 +390,7 @@ in-publish@^2.0.0:
   resolved "https://registry.yarnpkg.com/in-publish/-/in-publish-2.0.1.tgz#948b1a535c8030561cea522f73f78f4be357e00c"
   integrity sha512-oDM0kUSNFC31ShNxHKUyfZKy8ZeXZBWMjMdZHKLOk13uvT27VTL/QzRGfRUcevJhpkZAvlhPYuXkF7eNWrtyxQ==
 
-inherits@~2.0.3:
+inherits@^2.0.3, inherits@~2.0.3:
   version "2.0.4"
   resolved "https://registry.nlark.com/inherits/download/inherits-2.0.4.tgz#0fa2c64f932917c3433a0ded55363aae37416b7c"
   integrity sha1-D6LGT5MpF8NDOg3tVTY6rjdBa3w=
@@ -492,6 +512,11 @@ minimist@^1.2.0:
   resolved "https://registry.yarnpkg.com/minimist/-/minimist-1.2.5.tgz#67d66014b66a6a8aaa0c083c5fd58df4e4e97602"
   integrity sha512-FM9nNUYrRBAELZQT3xeZQ7fmMOBg6nWNmJKTcgsJeaLstP/UODVpGsr5OhXhhXg6f+qtJ8uiZ+PUxkDWcgIXLw==
 
+multi-progress@^4.0.0:
+  version "4.0.0"
+  resolved "https://registry.nlark.com/multi-progress/download/multi-progress-4.0.0.tgz#a14dd4e4da14f6a7cc2e1a5c0abd8b005dd23923"
+  integrity sha1-oU3U5NoU9qfMLhpcCr2LAF3SOSM=
+
 mute-stream@0.0.5:
   version "0.0.5"
   resolved "https://registry.yarnpkg.com/mute-stream/-/mute-stream-0.0.5.tgz#8fbfabb0a98a253d3184331f9e8deb7372fac6c0"
@@ -589,6 +614,14 @@ progress@^2.0.3:
   resolved "https://registry.nlark.com/progress/download/progress-2.0.3.tgz#7e8cf8d8f5b8f239c1bc68beb4eb78567d572ef8"
   integrity sha1-foz42PW48jnBvGi+tOt4Vn1XLvg=
 
+promise-retry@^2.0.1:
+  version "2.0.1"
+  resolved "https://registry.npm.taobao.org/promise-retry/download/promise-retry-2.0.1.tgz#ff747a13620ab57ba688f5fc67855410c370da22"
+  integrity sha1-/3R6E2IKtXumiPX8Z4VUEMNw2iI=
+  dependencies:
+    err-code "^2.0.2"
+    retry "^0.12.0"
+
 psl@^1.1.28:
   version "1.8.0"
   resolved "https://registry.yarnpkg.com/psl/-/psl-1.8.0.tgz#9326f8bcfb013adcc005fdff056acce020e51c24"
@@ -611,6 +644,15 @@ qs@~6.5.2:
   resolved "https://registry.yarnpkg.com/qs/-/qs-6.5.2.tgz#cb3ae806e8740444584ef154ce8ee98d403f3e36"
   integrity sha512-N5ZAX4/LxJmF+7wN74pUD6qAh9/wnvdQcjq9TZjevvXzSUo7bfmw91saqMjzGS2xq91/odN2dW/WOl7qQHNDGA==
 
+readable-stream@^3.0.2:
+  version "3.6.0"
+  resolved "https://registry.nlark.com/readable-stream/download/readable-stream-3.6.0.tgz#337bbda3adc0706bd3e024426a286d4b4b2c9198"
+  integrity sha1-M3u9o63AcGvT4CRCaihtS0sskZg=
+  dependencies:
+    inherits "^2.0.3"
+    string_decoder "^1.1.1"
+    util-deprecate "^1.0.1"
+
 readable-stream@~2.3.6:
   version "2.3.7"
   resolved "https://registry.nlark.com/readable-stream/download/readable-stream-2.3.7.tgz#1eca1cf711aef814c04f62252a36a62f6cb23b57"
@@ -677,6 +719,11 @@ restore-cursor@^1.0.1:
     exit-hook "^1.0.0"
     onetime "^1.0.0"
 
+retry@^0.12.0:
+  version "0.12.0"
+  resolved "https://registry.nlark.com/retry/download/retry-0.12.0.tgz#1b42a6266a21f07421d1b0b54b7dc167b01c013b"
+  integrity sha1-G0KmJmoh8HQh0bC1S33BZ7AcATs=
+
 run-async@^0.1.0:
   version "0.1.0"
   resolved "https://registry.yarnpkg.com/run-async/-/run-async-0.1.0.tgz#c8ad4a5e110661e402a7d21b530e009f25f8e389"
@@ -689,7 +736,7 @@ rx-lite@^3.1.2:
   resolved "https://registry.yarnpkg.com/rx-lite/-/rx-lite-3.1.2.tgz#19ce502ca572665f3b647b10939f97fd1615f102"
   integrity sha1-Gc5QLKVyZl87ZHsQk5+X/RYV8QI=
 
-safe-buffer@^5.0.1, safe-buffer@^5.1.2:
+safe-buffer@^5.0.1, safe-buffer@^5.1.2, safe-buffer@~5.2.0:
   version "5.2.1"
   resolved "https://registry.yarnpkg.com/safe-buffer/-/safe-buffer-5.2.1.tgz#1eaf9fa9bdb1fdd4ec75f58f9cdb4e6b7827eec6"
   integrity sha512-rp3So07KcdmmKbGvgaNxQSJr7bGVSVk5S9Eq1F+ppbRo70+YeaDxkw5Dd8NPN+GD6bjnYm2VuPuCXmpuYvmCXQ==
@@ -740,6 +787,15 @@ speedometer@~1.0.0:
   resolved "https://registry.nlark.com/speedometer/download/speedometer-1.0.0.tgz#cd671cb06752c22bca3370e2f334440be4fc62e2"
   integrity sha1-zWccsGdSwivKM3Di8zREC+T8YuI=
 
+ssh2-sftp-client@^7.0.4:
+  version "7.0.4"
+  resolved "https://registry.nlark.com/ssh2-sftp-client/download/ssh2-sftp-client-7.0.4.tgz#1e3182fa6a123f5d65429b2f62a76f1e9780907d"
+  integrity sha1-HjGC+moSP11lQpsvYqdvHpeAkH0=
+  dependencies:
+    concat-stream "^2.0.0"
+    promise-retry "^2.0.1"
+    ssh2 "^1.4.0"
+
 ssh2@^1.1.0, ssh2@^1.4.0:
   version "1.4.0"
   resolved "https://registry.yarnpkg.com/ssh2/-/ssh2-1.4.0.tgz#e32e8343394364c922bad915a5a7fecd67d0f5c5"
@@ -775,6 +831,13 @@ string-width@^1.0.1:
     is-fullwidth-code-point "^1.0.0"
     strip-ansi "^3.0.0"
 
+string_decoder@^1.1.1:
+  version "1.3.0"
+  resolved "https://registry.nlark.com/string_decoder/download/string_decoder-1.3.0.tgz#42f114594a46cf1a8e30b0a84f56c78c3edac21e"
+  integrity sha1-QvEUWUpGzxqOMLCoT1bHjD7awh4=
+  dependencies:
+    safe-buffer "~5.2.0"
+
 string_decoder@~1.1.1:
   version "1.1.1"
   resolved "https://registry.nlark.com/string_decoder/download/string_decoder-1.1.1.tgz#9cf1611ba62685d7030ae9e4ba34149c3af03fc8"
@@ -827,6 +890,11 @@ tweetnacl@^0.14.3, tweetnacl@~0.14.0:
   resolved "https://registry.yarnpkg.com/tweetnacl/-/tweetnacl-0.14.5.tgz#5ae68177f192d4456269d108afa93ff8743f4f64"
   integrity sha1-WuaBd/GS1EViadEIr6k/+HQ/T2Q=
 
+typedarray@^0.0.6:
+  version "0.0.6"
+  resolved "https://registry.npm.taobao.org/typedarray/download/typedarray-0.0.6.tgz#867ac74e3864187b1d3d47d996a78ec5c8830777"
+  integrity sha1-hnrHTjhkGHsdPUfZlqeOxciDB3c=
+
 uri-js@^4.2.2:
   version "4.4.1"
   resolved "https://registry.yarnpkg.com/uri-js/-/uri-js-4.4.1.tgz#9b1a52595225859e55f669d928f88c6c57f2a77e"
@@ -834,7 +902,7 @@ uri-js@^4.2.2:
   dependencies:
     punycode "^2.1.0"
 
-util-deprecate@~1.0.1:
+util-deprecate@^1.0.1, util-deprecate@~1.0.1:
   version "1.0.2"
   resolved "https://registry.nlark.com/util-deprecate/download/util-deprecate-1.0.2.tgz#450d4dc9fa70de732762fbd2d4a28981419a0ccf"
   integrity sha1-RQ1Nyfpw3nMnYvvS1KKJgUGaDM8=