diff --git a/test/byline.test.js b/test/byline.test.js index 1d01e8c..fa07524 100644 --- a/test/byline.test.js +++ b/test/byline.test.js @@ -27,25 +27,25 @@ const byline = require('../lib/byline') const { assert } = chai const regEx = /\r\n|[\n\v\f\r\x85\u2028\u2029]/g -const localPath = file => path.join(__dirname, file) +const localPath = file => path.join(__dirname, 'byline', file) describe('byline', function () { it('should pipe a small file', function (done) { - const input = fs.createReadStream(localPath('byline/empty.txt')) + const input = fs.createReadStream(localPath('empty.txt')) const lineStream = byline(input) // convinience API - const output = fs.createWriteStream(localPath('byline/test.txt')) + const output = fs.createWriteStream(localPath('test.txt')) lineStream.pipe(output) output.on('close', function () { - const out = fs.readFileSync(localPath('byline/test.txt'), 'utf8') - const in_ = fs.readFileSync(localPath('byline/empty.txt'), 'utf8').replace(/\n/g, '') + const out = fs.readFileSync(localPath('test.txt'), 'utf8') + const in_ = fs.readFileSync(localPath('empty.txt'), 'utf8').replace(/\n/g, '') assert.equal(in_, out) - fs.unlinkSync(localPath('byline/test.txt')) + fs.unlinkSync(localPath('test.txt')) done() }) }) it('should work with streams2 API', function (done) { - let stream = fs.createReadStream(localPath('byline/empty.txt')) + let stream = fs.createReadStream(localPath('empty.txt')) stream = byline.createStream(stream) stream.on('readable', function () { @@ -60,7 +60,7 @@ describe('byline', function () { }) it('should ignore empty lines by default', function (done) { - const input = fs.createReadStream(localPath('byline/empty.txt')) + const input = fs.createReadStream(localPath('empty.txt')) const lineStream = byline(input) lineStream.setEncoding('utf8') @@ -70,7 +70,7 @@ describe('byline', function () { }) lineStream.on('end', function () { - let lines2 = fs.readFileSync(localPath('byline/empty.txt'), 'utf8').split(regEx) + let lines2 = fs.readFileSync(localPath('empty.txt'), 'utf8').split(regEx) lines2 = lines2.filter(function (line) { return line.length > 0 }) @@ -80,7 +80,7 @@ describe('byline', function () { }) it('should keep empty lines when keepEmptyLines is true', function (done) { - const input = fs.createReadStream(localPath('byline/empty.txt')) + const input = fs.createReadStream(localPath('empty.txt')) const lineStream = byline(input, { keepEmptyLines: true }) lineStream.setEncoding('utf8') @@ -96,7 +96,7 @@ describe('byline', function () { }) it('should not split a CRLF which spans two chunks', function (done) { - const input = fs.createReadStream(localPath('byline/CRLF.txt')) + const input = fs.createReadStream(localPath('CRLF.txt')) const lineStream = byline(input, { keepEmptyLines: true }) lineStream.setEncoding('utf8') @@ -112,12 +112,12 @@ describe('byline', function () { }) it('should read a large file', function (done) { - readFile(localPath('byline/rfc.txt'), done) + readFile(localPath('rfc.txt'), done) }) it('should read a huge file', function (done) { // Readable highWaterMark is 16384, so we test a file with more lines than this - readFile(localPath('byline/rfc_huge.txt'), done) + readFile(localPath('rfc_huge.txt'), done) }) function readFile (filename, done) { @@ -158,11 +158,11 @@ describe('byline', function () { }) it('should pause() and resume() with a huge file', function (done) { - const input = fs.createReadStream(localPath('byline/rfc_huge.txt')) + const input = fs.createReadStream(localPath('rfc_huge.txt')) const lineStream = byline(input) lineStream.setEncoding('utf8') - let lines2 = fs.readFileSync(localPath('byline/rfc_huge.txt'), 'utf8').split(regEx) + let lines2 = fs.readFileSync(localPath('rfc_huge.txt'), 'utf8').split(regEx) lines2 = lines2.filter(function (line) { return line.length > 0 }) @@ -193,8 +193,8 @@ describe('byline', function () { }) function areStreamsEqualTypes (options, callback) { - const fsStream = fs.createReadStream(localPath('byline/empty.txt'), options) - const lineStream = byline(fs.createReadStream(localPath('byline/empty.txt'), options)) + const fsStream = fs.createReadStream(localPath('empty.txt'), options) + const lineStream = byline(fs.createReadStream(localPath('empty.txt'), options)) fsStream.on('data', function (data1) { lineStream.on('data', function (data2) { assert.equal(Buffer.isBuffer(data1), Buffer.isBuffer(data2))