style(lib): Fix lint issues after project metafile and tooling update

Author: digitalsadhu

lib/reader.js

@@ -7,7 +7,7 @@ const { dedupe, sort, setOrder } = require('./util');
 const assert = require('assert');
 
 module.exports = class Reader extends Readable {
-    constructor (streams) {
+    constructor(streams) {
         super();
 
         assert(
@@ -25,7 +25,10 @@ module.exports = class Reader extends Readable {
             'Expected any/all arguments given to Reader constructor to be subclasses of Stream.'
         );
 
-        assert(streams.length, 'Expected at least one stream to be provided to new Reader(). Got none.');
+        assert(
+            streams.length,
+            'Expected at least one stream to be provided to new Reader(). Got none.'
+        );
 
         const merged = mergeStream();
 
@@ -73,7 +76,7 @@ module.exports = class Reader extends Readable {
         });
     }
 
-    _read () {
+    _read() {
         return this.data.resume();
     }
 };

lib/util.js

@@ -2,31 +2,31 @@
 
 const { Transform } = require('readable-stream');
 
-function compareByOrder (a, b) {
+function compareByOrder(a, b) {
     if (a.order === b.order) {
         return 0;
     }
     return a.order > b.order ? 1 : -1;
 }
 
 class Dedupe extends Transform {
-    constructor () {
+    constructor() {
         super({
             objectMode: true,
         });
 
         this.rows = new Map();
     }
 
-    _transform (chunk, enc, callback) {
+    _transform(chunk, enc, callback) {
         if (chunk && chunk.id) {
             this.rows.set(chunk.id, chunk);
         }
 
         callback();
     }
 
-    _flush (callback) {
+    _flush(callback) {
         Array.from(this.rows.values())
             .sort(compareByOrder)
             .forEach(row => this.push(row));
@@ -35,37 +35,37 @@ class Dedupe extends Transform {
 }
 
 class SetOrder extends Transform {
-    constructor (index) {
+    constructor(index) {
         super({
             objectMode: true,
         });
 
         this.index = index;
     }
 
-    _transform (chunk, enc, callback) {
+    _transform(chunk, enc, callback) {
         chunk.order = this.index;
         callback(null, chunk);
     }
 }
 
 class Sort extends Transform {
-    constructor () {
+    constructor() {
         super({
             objectMode: true,
         });
 
         this.rows = new Map();
     }
 
-    _transform (chunk, enc, callback) {
+    _transform(chunk, enc, callback) {
         if (chunk && chunk.order != null) {
             this.rows.set(chunk.order, chunk);
         }
         callback();
     }
 
-    _flush (callback) {
+    _flush(callback) {
         Array.from(this.rows.values())
             .sort(compareByOrder)
             .forEach(row => this.push(row));
@@ -74,13 +74,13 @@ class Sort extends Transform {
 }
 
 module.exports = {
-    dedupe () {
+    dedupe() {
         return new Dedupe();
     },
-    setOrder (index) {
+    setOrder(index) {
         return new SetOrder(index);
     },
-    sort () {
+    sort() {
         return new Sort();
     },
     compareByOrder,

test/reader.test.js

@@ -8,7 +8,7 @@ const path = require('path');
 const { sort, dedupe, compareByOrder } = require('../lib/util');
 const { Readable, PassThrough } = require('readable-stream');
 
-function createSlowStream (sink, filePath, timeout = 1000) {
+function createSlowStream(sink, filePath, timeout = 1000) {
     const myStream = new PassThrough();
 
     process.nextTick(() => myStream.emit('file found', filePath));
@@ -202,7 +202,7 @@ test('SortAndDedupe() rows without id value dropped', done => {
     const values = [{ id: 'asd' }, { x: '' }, { id: 'sdf' }];
     const stream = new Readable({
         objectMode: true,
-        read () {
+        read() {
             if (values.length === 0) {
                 this.push(null);
                 return;
@@ -231,7 +231,12 @@ test('new Reader([s1,s2,s3,s4]) ensure dedupe and correct css concat order', don
     const feedStream3 = sink.reader('c.json');
     const feedStream4 = sink.reader('d.json');
 
-    const reader = new Reader([feedStream1, feedStream2, feedStream3, feedStream4]);
+    const reader = new Reader([
+        feedStream1,
+        feedStream2,
+        feedStream3,
+        feedStream4,
+    ]);
 
     reader.on('pipeline ready', () => {
         const bundle = [];
@@ -258,7 +263,12 @@ test('new Reader([s1,s2,s3,s4]) operates correctly under slow speed conditions',
     const feedStream3 = createSlowStream(sink, 'c.json', 500);
     const feedStream4 = createSlowStream(sink, 'd.json', 100);
 
-    const reader = new Reader([feedStream1, feedStream2, feedStream3, feedStream4]);
+    const reader = new Reader([
+        feedStream1,
+        feedStream2,
+        feedStream3,
+        feedStream4,
+    ]);
 
     reader.on('pipeline ready', () => {
         const bundle = [];
@@ -281,10 +291,15 @@ test('compareByOrder(a, b) a and b are the same', () => {
 
 test('sort() transform operating on stream items without order property', done => {
     expect.assertions(1);
-    const items = [{ order: 1 }, { order: null }, { order: undefined }, { noOrder: 'hi' }];
+    const items = [
+        { order: 1 },
+        { order: null },
+        { order: undefined },
+        { noOrder: 'hi' },
+    ];
     const stream = new Readable({
         objectMode: true,
-        read () {
+        read() {
             if (!items.length) {
                 this.push(null);
                 return;