Merge pull request #2 from rpiontik/new-api

New API

Author: rpiontik

README.md

@@ -130,6 +130,11 @@ npx archpkg remove dochub-examples
 npx archpkg clean
 ```
 
+# Переменные среды
+
+* **ARCHPKG_CACHE_FOLDER** - путь к директории кэширования. По умолчанию: <ползовательская директория>/.archpkg
+* **ARCHPKG_REPO_SERVER** - сервер репозитория. По умолчанию: https://registry.dochub.info/
+* **ARCHPKG_DOWNLOAD_CERT** - пусть к ssl-сертификату для скачивания пакетов. По умолчанию не установлено.
 
 # Лицензия 
 

cli/downloader.js

@@ -0,0 +1,65 @@
+const zlib = require('zlib');
+const tar = require("tar");
+
+// Реализует функцию загрузки и распаковки пакетов
+module.exports = function (context) {
+    const fs = context.fs;
+    const log = context.log;
+
+    return {
+        makeDownloadParams(url, method = 'GET') {
+            if (context.env.downloadCert) {
+                return {
+                    method,
+                    url,
+                    agentOptions: {
+                        ca: context.env.downloadCert
+                    }
+                };
+            } else return url;
+        },
+
+        async downloadAndUnzip(url, tmpFolder) {
+            return new Promise((success, reject) => {
+                // Создаем временную папку для скачивания
+                const tryFolder = `${tmpFolder}__`;
+                fs.existsSync(tryFolder) && fs.rmSync(tryFolder, { recursive: true });
+                fs.mkdirSync(tryFolder, { recursive: true });
+
+                log.begin(`Downloading ${url}...`);
+                let totalBytes = 0;
+                let receivedBytes = 0;
+                
+                context.request(this.makeDownloadParams(url))
+                    .on('response', (data) => {
+                        totalBytes = parseInt(data.headers['content-length']);
+                        if (data.statusCode === 404)
+                            reject(`Package unavailable on URL ${url}`);
+                        if ((data.statusCode < 200) || data.statusCode > 300)
+                            reject(`Error of downloading package from [${url}]. Response with code ${data.statusCode}.`);
+                        log.progressBegin();
+                    })
+                    .on('data', (chunk) => {
+                        receivedBytes += chunk.length;
+                        log.progress(receivedBytes, totalBytes);
+                    })
+                    .on('end', (chunk) => {
+                        log.progressEnd();
+                        log.end('Done.');
+                    })
+                    .on('error', reject)
+                    //.pipe(unzipper.Extract({ path: tmpFolder }))
+                    .pipe(zlib.createGunzip())
+                    .pipe(tar.x({
+                        strip: 1,
+                        C: tryFolder
+                    }))
+                    .on('error', reject)
+                    .on('close', () => {
+                        fs.renameSync(tryFolder, tmpFolder);
+                        success(tmpFolder);
+                    });
+            });
+        }
+    }
+}

cli/log.js

@@ -0,0 +1,39 @@
+
+module.exports = function () {
+    return {
+        level: 0,
+        begin(info) {
+            console.log(this.getMargin(), info);
+            this.level++;
+        },
+        end(info) {
+            console.info(this.getMargin(), `\x1b[32m${info}\x1b[0m`);
+            this.level && this.level--;
+        },
+        getMargin() {
+            return "||||||||||||||||||||||||||||||||||||||||||||||||||||||||".slice(0, this.level) + '-';
+        },
+        debug(info) {
+            console.log(this.getMargin(), info);
+        },
+        error(info) {
+            console.error(this.getMargin(), `\x1b[31m${info}\x1b[0m`);
+        },
+        success(info) {
+            console.info(this.getMargin(), `\x1b[32m${info}\x1b[0m`);
+        },
+        progressBegin() {
+        },
+        progress(value, total) {
+            if (total) {
+                const percentage = ((value * 100) / total).toFixed(2);
+                process.stdout.write(`\r${this.getMargin()} [${percentage}%] ${value}  bytes out of ${total}  bytes.`);
+            } else {
+                process.stdout.write(`\r${this.getMargin()} Recieved ${value} bytes.`);
+            }
+        },
+        progressEnd() {
+            process.stdout.write('\r\n');
+        },
+    };
+}