'use strict'
|
|
const assert = require('chai').assert
|
const fs = require('fs')
|
const path = require('path')
|
const Promise = require('bluebird')
|
const request = require('request')
|
const stream = require('stream')
|
|
const modulePath = '../src'
|
|
suite('integration:', () => {
|
let log
|
|
setup(() => {
|
log = {}
|
})
|
|
test('require does not throw', () => {
|
assert.doesNotThrow(() => {
|
require(modulePath)
|
})
|
})
|
|
test('require returns object', () => {
|
assert.isObject(require(modulePath))
|
})
|
|
suite('require:', () => {
|
let bfj
|
|
setup(() => {
|
bfj = require(modulePath)
|
})
|
|
test('walk function is exported', () => {
|
assert.isFunction(bfj.walk)
|
})
|
|
test('walk expects one argument', () => {
|
assert.lengthOf(bfj.walk, 1)
|
})
|
|
test('match function is exported', () => {
|
assert.isFunction(bfj.match)
|
})
|
|
test('match expects two arguments', () => {
|
assert.lengthOf(bfj.match, 2)
|
})
|
|
test('parse function is exported', () => {
|
assert.isFunction(bfj.parse)
|
})
|
|
test('parse expects one argument', () => {
|
assert.lengthOf(bfj.parse, 1)
|
})
|
|
test('read function is exported', () => {
|
assert.isFunction(bfj.read)
|
})
|
|
test('read expects two arguments', () => {
|
assert.lengthOf(bfj.read, 2)
|
})
|
|
test('eventify function is exported', () => {
|
assert.isFunction(bfj.eventify)
|
})
|
|
test('eventify expects one argument', () => {
|
assert.lengthOf(bfj.eventify, 1)
|
})
|
|
test('streamify function is exported', () => {
|
assert.isFunction(bfj.streamify)
|
})
|
|
test('streamify expects one argument', () => {
|
assert.lengthOf(bfj.streamify, 1)
|
})
|
|
test('stringify function is exported', () => {
|
assert.isFunction(bfj.stringify)
|
})
|
|
test('stringify expects two arguments', () => {
|
assert.lengthOf(bfj.stringify, 2)
|
})
|
|
test('write function is exported', () => {
|
assert.isFunction(bfj.write)
|
})
|
|
test('write expects two arguments', () => {
|
assert.lengthOf(bfj.write, 3)
|
})
|
|
test('events are exported', () => {
|
assert.deepEqual(bfj.events, require('../src/events'))
|
})
|
|
suite('read object:', () => {
|
let failed, file, result, error
|
|
setup(() => {
|
failed = false
|
file = path.join(__dirname, 'data.json')
|
fs.writeFileSync(file, JSON.stringify({
|
foo: [ 'b', 'a', 'r' ],
|
baz: null,
|
qux: 3.14159265359e42
|
}, null, '\t'))
|
return bfj.read(file)
|
.then(res => {
|
result = res
|
})
|
.catch(err => {
|
failed = true
|
error = err
|
})
|
})
|
|
teardown(() => {
|
fs.unlinkSync(file)
|
})
|
|
test('result was correct', () => {
|
assert.isFalse(failed)
|
assert.isUndefined(error)
|
assert.isObject(result)
|
assert.lengthOf(Object.keys(result), 3)
|
assert.isArray(result.foo)
|
assert.lengthOf(result.foo, 3)
|
assert.strictEqual(result.foo[0], 'b')
|
assert.strictEqual(result.foo[1], 'a')
|
assert.strictEqual(result.foo[2], 'r')
|
assert.isNull(result.baz)
|
assert.strictEqual(result.qux, 3.14159265359e42)
|
})
|
})
|
|
suite('read value:', () => {
|
let failed, file, result, error
|
|
setup(() => {
|
failed = false
|
file = path.join(__dirname, 'data.json')
|
fs.writeFileSync(file, '"foo"')
|
return bfj.read(file)
|
.then(res => {
|
result = res
|
})
|
.catch(err => {
|
failed = true
|
error = err
|
})
|
})
|
|
teardown(() => {
|
fs.unlinkSync(file)
|
})
|
|
test('result was correct', () => {
|
assert.isFalse(failed)
|
assert.isUndefined(error)
|
assert.strictEqual(result, 'foo')
|
})
|
})
|
|
suite('read error:', () => {
|
let failed, file, result, error
|
|
setup(() => {
|
failed = false
|
file = path.join(__dirname, 'data.json')
|
fs.writeFileSync(file, '"foo" "bar"')
|
return bfj.read(file)
|
.then(res => result = res)
|
.catch(err => {
|
failed = true
|
error = err
|
})
|
})
|
|
teardown(() => {
|
fs.unlinkSync(file)
|
})
|
|
test('result was correct', () => {
|
assert.isTrue(failed)
|
assert.isUndefined(result)
|
assert.instanceOf(error, Error)
|
})
|
})
|
|
suite('read missing file:', () => {
|
let failed, file, result, error
|
|
setup(() => {
|
failed = false
|
file = path.join(__dirname, 'missing.json')
|
assert.isFalse(fs.existsSync(file))
|
return bfj.read(file)
|
.then(res => result = res)
|
.catch(err => {
|
failed = true
|
error = err
|
})
|
})
|
|
test('result was correct', () => {
|
assert.isTrue(failed)
|
assert.isUndefined(result)
|
assert.instanceOf(error, Error)
|
})
|
})
|
|
suite('match predicate:', () => {
|
let file, results, errors
|
|
setup(done => {
|
file = path.join(__dirname, 'data.json')
|
fs.writeFileSync(file, JSON.stringify({
|
foo: 'bar',
|
baz: 'qux',
|
wibble: 'blee'
|
}))
|
results = []
|
errors = []
|
const datastream = bfj.match(fs.createReadStream(file), (k, v) => k === 'baz' || v === 'blee')
|
datastream.on('data', item => results.push(item))
|
datastream.on('error', error => errors.push(error))
|
datastream.on('end', done)
|
})
|
|
test('the correct properties were matched', () => {
|
assert.deepEqual([ 'qux', 'blee' ], results)
|
})
|
|
test('no errors occurred', () => {
|
assert.deepEqual(errors, [])
|
})
|
})
|
|
suite('match nested:', () => {
|
let file, results, errors
|
|
setup(done => {
|
file = path.join(__dirname, 'data.json')
|
fs.writeFileSync(file, JSON.stringify({
|
foo: {
|
bar: 'baz'
|
}
|
}))
|
results = []
|
errors = []
|
const datastream = bfj.match(fs.createReadStream(file), () => true)
|
datastream.on('data', item => results.push(item))
|
datastream.on('error', error => errors.push(error))
|
datastream.on('end', done)
|
})
|
|
test('the correct properties were matched', () => {
|
assert.deepEqual([ 'baz', { bar: 'baz' }, { foo: { bar: 'baz' } } ], results)
|
})
|
|
test('no errors occurred', () => {
|
assert.deepEqual(errors, [])
|
})
|
})
|
|
suite('match ndjson:', () => {
|
let file, results, errors
|
|
setup(done => {
|
file = path.join(__dirname, 'data.ndjson')
|
fs.writeFileSync(file, [
|
JSON.stringify([ 'a', 'b' ]),
|
JSON.stringify(null),
|
'',
|
'',
|
JSON.stringify('wibble')
|
].join('\n'))
|
results = []
|
errors = []
|
const datastream = bfj.match(fs.createReadStream(file), () => true, { ndjson: true })
|
datastream.on('data', item => results.push(item))
|
datastream.on('error', error => errors.push(error))
|
datastream.on('end', done)
|
})
|
|
test('the correct properties were matched', () => {
|
assert.deepEqual([ 'a', 'b', [ 'a', 'b' ], 'wibble' ], results)
|
})
|
|
test('no errors occurred', () => {
|
assert.deepEqual(errors, [])
|
})
|
})
|
|
suite('parse request:', () => {
|
let error, result
|
|
setup(done => {
|
const jsonstream = new stream.PassThrough()
|
request({ url: 'https://gitlab.com/philbooth/bfj/raw/master/package.json' })
|
.pipe(bfj.unpipe((err, res) => {
|
error = err
|
result = res
|
done()
|
}))
|
})
|
|
test('result was correct', () => {
|
assert.isNull(error)
|
assert.deepEqual(result, require('../package.json'))
|
})
|
})
|
|
suite('parse NDJSON:', () => {
|
let failed, file, results
|
|
setup(() => {
|
failed = false
|
file = path.join(__dirname, 'data.ndjson')
|
results = []
|
fs.writeFileSync(file, [
|
JSON.stringify([ 'b', 'a', 'r' ]),
|
JSON.stringify(null),
|
'',
|
'',
|
JSON.stringify('wibble')
|
].join('\n'))
|
const stream = fs.createReadStream(file)
|
return bfj.parse(stream, { ndjson: true })
|
.then(result => {
|
results.push(result)
|
return bfj.parse(stream, { ndjson: true })
|
})
|
.then(result => {
|
results.push(result)
|
return bfj.parse(stream, { ndjson: true })
|
})
|
.then(result => {
|
results.push(result)
|
return bfj.parse(stream, { ndjson: true })
|
})
|
.then(result => {
|
results.push(result)
|
return bfj.parse(stream, { ndjson: true })
|
})
|
.then(result => results.push(result))
|
.catch(e => {
|
failed = true
|
})
|
})
|
|
teardown(() => {
|
fs.unlinkSync(file)
|
})
|
|
test('results were correct', () => {
|
assert.isFalse(failed)
|
assert.lengthOf(results, 5)
|
assert.deepEqual(results, [
|
[ 'b', 'a', 'r' ],
|
null,
|
'wibble',
|
undefined,
|
undefined
|
])
|
})
|
})
|
|
suite('stringify value:', () => {
|
let result
|
|
setup(() => {
|
return bfj.stringify(new Promise(resolve => {
|
setTimeout(resolve.bind(null, 'foo\t"\nbar'), 20)
|
}))
|
.then(res => result = res)
|
})
|
|
test('result was correct', () => {
|
assert.strictEqual(result, '"foo\\t\\"\\nbar"')
|
})
|
})
|
|
suite('write object:', () => {
|
let failed, file, result
|
|
setup(() => {
|
failed = false
|
file = path.join(__dirname, 'data.json')
|
return bfj.write(
|
file,
|
{ foo: [ 'b', 'a', 'r' ], baz: null, qux: 3.14159265359e42 }
|
)
|
.then(() => {
|
result = fs.readFileSync(file, { encoding: 'utf8' })
|
})
|
.catch(error => {
|
failed = true
|
result = error
|
})
|
})
|
|
teardown(() => {
|
fs.unlinkSync(file)
|
})
|
|
test('did not fail', () => {
|
assert.isFalse(failed)
|
})
|
|
test('result was correct', () => {
|
assert.strictEqual(result, '{"foo":["b","a","r"],"baz":null,"qux":3.14159265359e+42}')
|
})
|
})
|
})
|
})
|
