54 lines
1.4 KiB
JavaScript
54 lines
1.4 KiB
JavaScript
const { forEach, fromCallback } = require('promise-toolbox')
|
|
const fs = require('fs')
|
|
|
|
const ROOT_DIR = `${__dirname}/..`
|
|
|
|
const _getPackages = scope => {
|
|
const inScope = scope !== undefined
|
|
const dir = `${ROOT_DIR}/${inScope ? scope : 'packages'}`
|
|
return fromCallback(cb => fs.readdir(dir, cb)).then(names =>
|
|
names.map(name => ({
|
|
dir: `${dir}/${name}`,
|
|
name: inScope ? `${scope}/${name}` : name,
|
|
}))
|
|
)
|
|
}
|
|
|
|
exports.getPackages = (readPackageJson = false) => {
|
|
const p = Promise.all([
|
|
_getPackages(),
|
|
_getPackages('@xen-orchestra'),
|
|
]).then(pkgs => {
|
|
pkgs = [].concat(...pkgs) // flatten
|
|
return readPackageJson
|
|
? Promise.all(pkgs.map(pkg =>
|
|
readFile(`${pkg.dir}/package.json`).then(data => {
|
|
pkg.package = JSON.parse(data)
|
|
return pkg
|
|
}, noop)
|
|
)).then(pkgs => pkgs.filter(pkg => pkg !== undefined))
|
|
: pkgs
|
|
})
|
|
p.forEach = fn => p.then(pkgs => forEach.call(pkgs, fn))
|
|
p.map = fn => p.then(pkgs => Promise.all(pkgs.map(fn))).then(noop)
|
|
return p
|
|
}
|
|
|
|
const noop = exports.noop = () => {}
|
|
|
|
const readFile = exports.readFile = file => fromCallback(cb =>
|
|
fs.readFile(file, 'utf8', cb)
|
|
)
|
|
|
|
exports.unlink = path => fromCallback(cb =>
|
|
fs.unlink(path, cb)
|
|
).catch(error => {
|
|
if (error.code !== 'ENOENT') {
|
|
throw error
|
|
}
|
|
})
|
|
|
|
exports.writeFile = (file, data) => fromCallback(cb =>
|
|
fs.writeFile(file, data, cb)
|
|
)
|