cobox-config
Advanced tools
Comparing version 1.0.0 to 1.0.1
@@ -5,7 +5,7 @@ const pino = require('pino') | ||
module.exports = function (storage, opts = {}) { | ||
return function (name) { | ||
return function (name, suboptions = {}) { | ||
if (!process.env.PRODUCTION) return Debug | ||
const logger = pino({ name }, pino.destination(storage)) | ||
return function (...args) { | ||
if (opts.stdout) console.log(...args) | ||
if (opts.stdout || suboptions.stdout) console.log(...args) | ||
logger.info(...args) | ||
@@ -12,0 +12,0 @@ } |
{ | ||
"name": "cobox-config", | ||
"version": "1.0.0", | ||
"version": "1.0.1", | ||
"description": "load and save a cobox configuration", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -18,7 +18,7 @@ const { describe } = require('tape-plus') | ||
context.afterEach((c) => { | ||
cleanup(storage.root) | ||
cleanup(storage) | ||
}) | ||
context('default', (assert, next) => { | ||
var config = Config(storage.path) | ||
var config = Config(storage) | ||
assert.ok(config.identities.list() instanceof Array, 'identities list defaults to empty Array') | ||
@@ -38,7 +38,7 @@ assert.ok(config.groups.list() instanceof Array, 'groups list defaults to empty Array') | ||
context.afterEach((c) => { | ||
cleanup(storage.root) | ||
cleanup(storage) | ||
}) | ||
context('byKey', (assert, next) => { | ||
var config = Config(storage.path) | ||
var config = Config(storage) | ||
var group = crypto.unpack(crypto.accessKey()) | ||
@@ -52,3 +52,3 @@ var identity = crypto.keyPair() | ||
var reload = yaml.safeLoad(fs.readFileSync(path.join(storage.path, 'config.yml'))) | ||
var reload = yaml.safeLoad(fs.readFileSync(path.join(storage, 'config.yml'))) | ||
var rawGroup = reload.groups.byKey[group.publicKey.toString('hex')] | ||
@@ -63,3 +63,3 @@ var rawIdentity = reload.identities.byKey[identity.publicKey.toString('hex')] | ||
context('byName', (assert, next) => { | ||
var config = Config(storage.path) | ||
var config = Config(storage) | ||
var group = Object.assign({ name: 'group-a' }, crypto.unpack(crypto.accessKey())) | ||
@@ -73,3 +73,3 @@ var identity = Object.assign({ name: 'Alice' }, crypto.keyPair()) | ||
var reload = yaml.safeLoad(fs.readFileSync(path.join(storage.path, 'config.yml'))) | ||
var reload = yaml.safeLoad(fs.readFileSync(path.join(storage, 'config.yml'))) | ||
var rawGroup = reload.groups.byKey[group.publicKey.toString('hex')] | ||
@@ -83,3 +83,3 @@ var rawIdentity = reload.identities.byKey[identity.publicKey.toString('hex')] | ||
var reload = Config(storage.path) | ||
var reload = Config(storage) | ||
@@ -100,7 +100,7 @@ assert.same(reload._groups, config._groups, 'load groups from storage') | ||
context.afterEach((c) => { | ||
cleanup(storage.root) | ||
cleanup(storage) | ||
}) | ||
context('works with buffers or strings', (assert, next) => { | ||
var config = Config(storage.path) | ||
var config = Config(storage) | ||
var group = crypto.unpack(crypto.accessKey()) | ||
@@ -131,7 +131,7 @@ var identity = crypto.keyPair() | ||
context.afterEach((c) => { | ||
cleanup(storage.root) | ||
cleanup(storage) | ||
}) | ||
context('removes relevant entry using buffers', (assert, next) => { | ||
var config = Config(storage.path) | ||
var config = Config(storage) | ||
var group = crypto.unpack(crypto.accessKey()) | ||
@@ -155,3 +155,3 @@ var identity = crypto.keyPair() | ||
context('removes relevant entry using buffers', (assert, next) => { | ||
var config = Config(storage.path) | ||
var config = Config(storage) | ||
var group = crypto.unpack(crypto.accessKey()) | ||
@@ -175,3 +175,3 @@ var identity = crypto.keyPair() | ||
context('removes relevant entry using names', (assert, next) => { | ||
var config = Config(storage.path) | ||
var config = Config(storage) | ||
var group = Object.assign({ name: 'group-a' }, crypto.unpack(crypto.accessKey())) | ||
@@ -178,0 +178,0 @@ var identity = Object.assign({ name: 'Alice' }, crypto.keyPair()) |
const tmpdir = require('tmp').dirSync | ||
const mkdirp = require('mkdirp') | ||
const rimraf = require('rimraf') | ||
const debug = require('debug')('cobox-config') | ||
function cleanup (dir) { | ||
rimraf(dir, (err) => { | ||
debug(`[CLEANUP] ${ err ? 'failed' : 'success'}`) | ||
if (err) throw (err) | ||
}) | ||
function cleanup (dirs, cb) { | ||
if (!cb) cb = noop | ||
if (!Array.isArray(dirs)) dirs = [dirs] | ||
var pending = 1 | ||
function next (n) { | ||
var dir = dirs[n] | ||
if (!dir) return done() | ||
++pending | ||
process.nextTick(next, n + 1) | ||
rimraf(dir, (err) => { | ||
if (err) return done(err) | ||
done() | ||
}) | ||
} | ||
function done (err) { | ||
if (err) { | ||
pending = Infinity | ||
return cb(err) | ||
} | ||
if (!--pending) return cb() | ||
} | ||
next(0) | ||
} | ||
function tmp () { | ||
var root = `./tmp/` | ||
var path = `.${tmpdir().name}` | ||
var path = tmpdir().name | ||
mkdirp.sync(path) | ||
debug(`[TEMP] ${path}`) | ||
return { path, root } | ||
return path | ||
} | ||
function noop () {} | ||
module.exports = { cleanup, tmp } |
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
117770
290
0