| 1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132 |
13×
13×
13×
13×
13×
13×
1×
14×
14×
14×
6×
6×
14×
1×
8×
8×
14×
8×
14×
30×
8×
1×
1×
1×
2×
1×
8×
1×
11×
11×
11×
8×
8×
14×
11×
5×
4×
1×
10×
8×
6×
6×
5×
5×
1×
2×
4×
4×
1×
11×
11×
1×
1×
1×
10×
8×
7×
5×
3×
2×
2×
1×
13×
13×
| 'use strict'
var log = require('winston')
var async = require('async')
var _ = require('lodash')
var api = require('../api.js')
var project = require('../project.js')
var pkgLib = require('../package.js')
function flattenPackages(obj, packages) {
packages = packages || []
packages.push( _.pick(obj, ['package', 'version', 'path']) )
if (obj.dependencies) {
_.each( obj.dependencies, function(dependency) {
flattenPackages(dependency, packages)
})
}
return packages
}
function preparePackages(data) {
var modules = flattenPackages(data)
// filter exact dups
var filteredModules = _.uniq(modules, function(module) {
return module.package + module.version
})
var duplicates = _.chain(filteredModules)
.filter(function(module) {
return _.filter(filteredModules, function(x) {
return x.package === module.package && x.version !== module.version
}).length
})
.groupBy('package')
.value()
if ( _.keys(duplicates).length ) {
_.each( duplicates, function(duplicate) {
log.info( 'version conflict for ' + duplicate[0].package )
// TODO: x depends on {version}
_.each(duplicate, function(dupVersion) {
log.info( ' ' + dupVersion.version )
})
// TODO: prompt for conflict resolution
log.info( 'installing ' + _.sortByOrder(duplicate, 'version', false)[0].version + '\n')
})
}
return _.sortBy( filteredModules, ['package', 'version'] )
}
// long-term TODO: actual semver
function resolveAndInstall(name, version, cb) {
version = (!version || version === 'latest') ? '*' : version
api.resolve(name, version, function(err, data) {
if (err) return cb(err)
var packages = preparePackages(data)
, installedVersion = data.version
async.each(packages, function(obj, callback) {
pkgLib.getConfig(obj.package, function(err, pkgConfig) {
// ignore err
if ( pkgConfig ) {
if ( obj.version === pkgConfig.version ) return callback(null)
// note: object-version is resolved on the server
if ( obj.version < pkgConfig.version ) {
//TODO: prompt ?
log.info('downgrading ' + pkgConfig.name + ' from ' + pkgConfig.version + ' to ' + obj.version)
}
}
api.get(obj, function(err, buffer) {
if (err) return callback(err)
pkgLib.install(buffer, obj.package, callback)
})
})
}, function(err) {
if (err) return cb(err)
log.info('installed ' + name + '@' + installedVersion)
cb(null, installedVersion)
})
})
}
function all(mlpm) {
// TODO: async.each ?
_.forOwn(mlpm.dependencies, function(version, name) {
resolveAndInstall(name, version, function(err, __) {
if (err) return log.error(err)
})
})
}
function install(args) {
project.getConfig(function (err, mlpm) {
if ( err && !args.package ) {
log.error( 'nothing to install' )
log.info( install.usage )
return
}
if ( !args.package && mlpm ) return all( mlpm )
if ( mlpm && mlpm.name === args.package ) return log.error( 'can\'t depend on yourself ;)' )
resolveAndInstall(args.package, args.version, function(err, installedVersion) {
if (err) return log.error(err)
if ( args.save ) {
project.saveDependency(mlpm, args.package, installedVersion, function(err) {
if (err) return log.error(err)
log.info('saved ' + args.package + ' to mlpm.json')
})
}
})
})
}
install.usage = 'mlpm install [--save]\n' +
'mlpm install <package> [--save]\n' +
'mlpm install <package>@version [--save]'
module.exports.command = install
|