feat(reload): 增加从ykit服务拉取插件功能

Author: yuhaoju

lib/commands/reload.js

@@ -1,12 +1,70 @@
 'use strict';
 
 var Manager = require('../modules/manager.js');
+var child_process = require('child_process');
+var requireg = require('requireg');
+var request = require('request');
+var semver = require('semver');
 
 exports.usage = "重载插件";
 
+exports.setOptions = function (optimist) {
+    optimist.alias('h', 'host');
+    optimist.describe('h', '拉取插件服务地址');
+};
+
 exports.run = function (options) {
+    var host = 'http://' + (options.h || options.host || '192.168.237.71:9999/download');
 
+    // 重载全局插件
     Manager.reloadRC();
 
-    success('Complete!');
+    // 检查devDependencies中的ykit-config-{name}
+    var packageJsonContent = JSON.parse(fs.readFileSync('./package.json', { encoding: 'utf-8' }));
+    var ykitModuleReg = /^(@[^\/]+\/)(ykit\-(\w+)\-[\w\-]+)$/;
+
+    var willInstallPackages = [];
+
+    if (packageJsonContent.devDependencies) {
+        (function () {
+            var devDependencies = packageJsonContent.devDependencies;
+            Object.keys(devDependencies).map(function (depName, i) {
+                if (ykitModuleReg.test(depName) && !requireg.resolve(depName)) {
+                    var version = devDependencies[depName];
+                    var packagePath = './node_modules/@qnpm';
+
+                    if (semver.valid(version)) {
+                        (function () {
+                            // 确保存在@qnpm目录
+                            mkdirp.sync(packagePath);
+
+                            var tarName = depName + '@' + version + '.tar.gz';
+                            var extractPath = sysPath.join(process.cwd(), './node_modules/', tarName);
+                            var downloadPath = host + '/' + tarName;
+                            var downloadStream = request(downloadPath).pipe(fs.createWriteStream(extractPath));
+
+                            log('downloading ' + extractPath);
+                            downloadStream.on('finish', function (e) {
+                                if (e) {
+                                    return error(e);
+                                }
+
+                                log('extracting ' + extractPath);
+                                child_process.exec('cd ./node_modules/@qnpm/ && tar -xf ' + extractPath, function (e, stdout, errout) {
+                                    if (e) {
+                                        return error(e);
+                                    }
+
+                                    success('complete!');
+                                    fs.unlinkSync(extractPath);
+                                });
+                            });
+                        })();
+                    } else {
+                        error(depName + '版本号必须确定，如0.1.0');
+                    }
+                }
+            });
+        })();
+    }
 };

package.json

@@ -22,22 +22,22 @@
     "globby": "^5.0.0",
     "html-loader": "^0.4.3",
     "inquirer": "^1.1.1",
-    "jerryproxy-ykit": "^1.0.42",
+    "jerryproxy-ykit": "^1.0.55",
     "js-yaml": "^3.6.1",
     "json-loader": "^0.5.4",
     "json5": "^0.5.0",
     "left-pad": "^1.1.0",
-    "less": "^2.7.1",
-    "less-loader": "^2.2.3",
     "livereload": "^0.4.1",
     "loader-utils": "^0.2.15",
     "mkdirp": "^0.5.1",
     "moment": "^2.14.1",
     "optimist": "^0.6.1",
     "replacestream": "^4.0.0",
+    "request": "^2.75.0",
     "require-uncached": "^1.0.2",
     "requireg": "^0.1.5",
     "right-pad": "^1.0.0",
+    "semver": "^5.3.0",
     "serve-index": "^1.8.0",
     "serve-static": "^1.11.1",
     "style-loader": "^0.13.1",

src/commands/reload.js

@@ -1,12 +1,66 @@
 'use strict';
 
-let Manager = require('../modules/manager.js');
+const Manager = require('../modules/manager.js')
+const child_process = require('child_process')
+const requireg = require('requireg')
+const request = require('request')
+const semver = require('semver')
 
-exports.usage = "重载插件";
+exports.usage = "重载插件"
+
+exports.setOptions = (optimist) => {
+    optimist.alias('h', 'host')
+    optimist.describe('h', '拉取插件服务地址')
+};
 
 exports.run = (options) => {
+    const host = 'http://' + (options.h || options.host || '192.168.237.71:9999/download')
 
+    // 重载全局插件
     Manager.reloadRC();
 
-    success('Complete!');
+    // 检查devDependencies中的ykit-config-{name}
+    const packageJsonContent = JSON.parse(fs.readFileSync('./package.json', {encoding: 'utf-8'}))
+    const ykitModuleReg = /^(@[^\/]+\/)(ykit\-(\w+)\-[\w\-]+)$/
+
+    let willInstallPackages = []
+
+    if(packageJsonContent.devDependencies) {
+        const devDependencies = packageJsonContent.devDependencies
+        Object.keys(devDependencies).map((depName, i) => {
+            if(ykitModuleReg.test(depName) && !requireg.resolve(depName)) {
+                const version = devDependencies[depName]
+                const packagePath = './node_modules/@qnpm'
+
+                if(semver.valid(version)) {
+                    // 确保存在@qnpm目录
+                    mkdirp.sync(packagePath)
+
+                    const tarName = depName + '@' + version + '.tar.gz'
+                    const extractPath = sysPath.join(process.cwd(), './node_modules/', tarName)
+                    const downloadPath = host + '/' + tarName
+                    const downloadStream = request(downloadPath).pipe(fs.createWriteStream(extractPath))
+
+                    log('downloading ' + extractPath)
+                    downloadStream.on('finish', (e) => {
+                        if(e) {
+                            return error(e)
+                        }
+
+                        log('extracting ' + extractPath)
+                        child_process.exec('cd ./node_modules/@qnpm/ && tar -xf ' + extractPath, (e, stdout, errout) => {
+                            if(e) {
+                                return error(e)
+                            }
+
+                            success('complete!')
+                            fs.unlinkSync(extractPath)
+                        })
+                    })
+                } else {
+                    error(depName + '版本号必须确定，如0.1.0')
+                }
+            }
+        })
+    }
 };