|
1 | | -// here be dragons |
2 | | -// TODO: this is horrible and needs to be refactored ASAP |
3 | | -let utils = require('../utils/utils.js'); |
4 | 1 | let fs = require('../core/fs.js'); |
5 | 2 |
|
| 3 | +let PluginManager = require('live-plugin-manager').PluginManager; |
| 4 | + |
6 | 5 | class Npm { |
7 | 6 |
|
8 | 7 | constructor(options) { |
9 | 8 | this.logger = options.logger; |
10 | 9 | } |
11 | 10 |
|
12 | | - downloadFromGit(registryJSON, packageName, version, returnContent, callback) { |
13 | | - let repoName = registryJSON.repository.url.replace("git+https://github.com/", "").replace(".git",""); |
14 | | - let gitHead = registryJSON.gitHead; |
15 | | - |
16 | | - if (!gitHead) { |
17 | | - this.logger.error("Could not download " + packageName + " " + version); |
18 | | - return callback("error"); |
19 | | - } |
20 | | - |
21 | | - let fileLocation = "https://raw.githubusercontent.com/" + repoName + "/" + gitHead + "/dist/web3.min.js"; |
22 | | - |
23 | | - let packageDirectory = './.embark/versions/' + packageName + '/' + version + '/'; |
24 | | - if (fs.existsSync(packageDirectory + "/" + packageName + ".js")) { |
25 | | - if (returnContent) { |
26 | | - let distFile = packageDirectory + packageName + ".js"; |
27 | | - callback(null, fs.readFileSync(distFile).toString()); |
28 | | - } else { |
29 | | - callback(null, packageDirectory); |
30 | | - } |
31 | | - } else { |
32 | | - fs.mkdirpSync(packageDirectory); |
33 | | - this.logger.info("downloading " + packageName + " " + version + "...."); |
34 | | - |
35 | | - utils.downloadFile(fileLocation, packageDirectory + "/" + packageName + ".js", function() { |
36 | | - utils.extractTar(packageDirectory + "/" + packageName + ".js", packageDirectory, function() { |
37 | | - if (returnContent) { |
38 | | - let distFile = packageDirectory + packageName + ".js"; |
39 | | - callback(null, fs.readFileSync(distFile).toString()); |
40 | | - } else { |
41 | | - callback(null, packageDirectory); |
42 | | - } |
43 | | - }); |
44 | | - }); |
45 | | - } |
46 | | - } |
47 | | - |
48 | | - downloadFromNpm(registryJSON, packageName, version, returnContent, callback) { |
49 | | - let tarball = registryJSON.dist.tarball; |
50 | | - |
| 11 | + getPackageVersion(packageName, version, callback) { |
51 | 12 | let packageDirectory = './.embark/versions/' + packageName + '/' + version + '/'; |
52 | | - if (fs.existsSync(packageDirectory + "/downloaded_package.tgz") && fs.existsSync(packageDirectory + "package.json")) { |
53 | | - if (returnContent) { |
54 | | - let distFile = packageDirectory + returnContent; |
55 | | - callback(null, fs.readFileSync(distFile).toString()); |
56 | | - } else { |
57 | | - callback(null, packageDirectory); |
58 | | - } |
59 | | - } else { |
60 | | - fs.mkdirpSync(packageDirectory); |
61 | | - this.logger.info("downloading " + packageName + " " + version + "...."); |
62 | | - |
63 | | - utils.downloadFile(tarball, packageDirectory + "/downloaded_package.tgz", function() { |
64 | | - utils.extractTar(packageDirectory + "/downloaded_package.tgz", packageDirectory, function() { |
65 | | - if (returnContent) { |
66 | | - let distFile = packageDirectory + returnContent; |
67 | | - callback(null, fs.readFileSync(distFile).toString()); |
68 | | - } else { |
69 | | - callback(null, packageDirectory); |
70 | | - } |
71 | | - }); |
72 | | - }); |
73 | | - } |
74 | | - } |
75 | 13 |
|
76 | | - // TODO: callback should accept an error |
77 | | - getPackageVersion(packageName, version, returnContent, getFromGit, callback) { |
78 | | - let self = this; |
79 | | - let npmRegistry = "https://registry.npmjs.org/" + packageName + "/" + version; |
80 | | - let packageDirectory = './.embark/versions/' + packageName + '/' + version + '/'; |
| 14 | + let manager = new PluginManager({pluginsPath: packageDirectory}); |
81 | 15 |
|
82 | | - if (fs.existsSync(packageDirectory) && fs.existsSync(packageDirectory + "package.json")) { |
83 | | - let content; |
84 | | - if (getFromGit && returnContent) { |
85 | | - let distFile = packageDirectory + packageName + ".js"; |
86 | | - content = fs.readFileSync(distFile).toString(); |
87 | | - } else if (returnContent) { |
88 | | - let distFile = packageDirectory + returnContent; |
89 | | - content = fs.readFileSync(distFile).toString(); |
90 | | - } else { |
91 | | - content = packageDirectory; |
92 | | - } |
93 | | - return callback(null, content); |
| 16 | + if (fs.existsSync(packageDirectory + packageName)) { |
| 17 | + return callback(null, packageDirectory + packageName); |
94 | 18 | } |
95 | 19 |
|
96 | | - utils.httpsGet(npmRegistry, function (err, body) { |
97 | | - if (err) { |
98 | | - if (err.code === 'ENOTFOUND') { |
99 | | - return callback("can't reach " + err.hostname + " to download " + packageName + " " + version + " - are you connected to the internet?"); |
100 | | - } |
101 | | - return callback(err); |
102 | | - } |
103 | | - let registryJSON = JSON.parse(body); |
104 | | - |
105 | | - if (getFromGit) { |
106 | | - self.downloadFromGit(registryJSON, packageName, version, returnContent, callback); |
107 | | - } else { |
108 | | - self.downloadFromNpm(registryJSON, packageName, version, returnContent, callback); |
109 | | - } |
110 | | - }); |
| 20 | + this.logger.info("downloading " + packageName + " " + version + "...."); |
| 21 | + manager.install(packageName, version).then((result) => { |
| 22 | + callback(null , result.location); |
| 23 | + }).catch(callback); |
111 | 24 | } |
112 | 25 | } |
113 | 26 |
|
|
0 commit comments