lint++

Author: fredericosilva

extensions/cli-ext-insight-journal/ReadlineTransform.js

@@ -10,64 +10,64 @@ import { Transform } from 'stream';
  * @param {Boolean} opts.skipEmpty - if line is empty string, skip it (default: false)
  */
 class ReadlineTransform extends Transform {
-  constructor(options) {
-    const opts = options || {};
-    opts.objectMode = true;
-    super(opts);
-    this._brRe = opts.breakMatcher || /\r?\n/;
-    this._ignoreEndOfBreak = 'ignoreEndOfBreak' in opts ? Boolean(opts.ignoreEndOfBreak) : true;
-    this._skipEmpty = Boolean(opts.skipEmpty);
-    this._buf = null;
-  }
-
-  _transform(chunk, encoding, cb) {
-    let str;
-    if (Buffer.isBuffer(chunk) || encoding === 'buffer') {
-      str = chunk.toString('utf8');
-    } else {
-      str = chunk;
+    constructor(options) {
+        const opts = options || {};
+        opts.objectMode = true;
+        super(opts);
+        this._brRe = opts.breakMatcher || /\r?\n/;
+        this._ignoreEndOfBreak = 'ignoreEndOfBreak' in opts ? Boolean(opts.ignoreEndOfBreak) : true;
+        this._skipEmpty = Boolean(opts.skipEmpty);
+        this._buf = null;
     }
 
-    try {
-      if (this._buf !== null) {
-        this._buf += str;  
-      } else {
-        this._buf = str;  
-      }
+    _transform(chunk, encoding, cb) {
+        let str;
+        if (Buffer.isBuffer(chunk) || encoding === 'buffer') {
+            str = chunk.toString('utf8');
+        } else {
+            str = chunk;
+        }
 
-      const lines = this._buf.split(this._brRe);
-      const lastIndex = lines.length - 1;
-      for (let i = 0; i < lastIndex; i++) {
-        this._writeItem(lines[i]);
-      }
+        try {
+            if (this._buf !== null) {
+                this._buf += str;
+            } else {
+                this._buf = str;
+            }
 
-      const lastLine = lines[lastIndex];
-      if (lastLine.length) {
-        this._buf = lastLine;
-      } else if (!this._ignoreEndOfBreak) {
-        this._buf = '';
-      } else {
-        this._buf = null;
-      }
-      cb();
-    } catch(err) {
-      cb(err); // invalid data type;
+            const lines = this._buf.split(this._brRe);
+            const lastIndex = lines.length - 1;
+            for (let i = 0; i < lastIndex; i++) {
+                this._writeItem(lines[i]);
+            }
+
+            const lastLine = lines[lastIndex];
+            if (lastLine.length) {
+                this._buf = lastLine;
+            } else if (!this._ignoreEndOfBreak) {
+                this._buf = '';
+            } else {
+                this._buf = null;
+            }
+            return cb();
+        } catch (err) {
+            return cb(err); // invalid data type;
+        }
     }
-  }
 
-  _flush(cb) {
-    if (this._buf !== null) {
-      this._writeItem(this._buf);
-      this._buf = null;
+    _flush(cb) {
+        if (this._buf !== null) {
+            this._writeItem(this._buf);
+            this._buf = null;
+        }
+        cb();
     }
-    cb();
-  }
 
-  _writeItem(line) {
-    if (line.length > 0 || !this._skipEmpty) {
-      this.push(line);
+    _writeItem(line) {
+        if (line.length > 0 || !this._skipEmpty) {
+            this.push(line);
+        }
     }
-  }
 }
 
 export default ReadlineTransform;

extensions/cli-ext-insight-journal/logger.js

@@ -44,7 +44,7 @@ export default new Command({
                 },
             }))
         ;
-        
+
         const response = await opts.http.post(`https://${log.fqdn}/log`, {
             body: inStream,
             headers: { authorization: `Bearer ${token}` },

extensions/cli-ext-insight-journal/stream.js

@@ -29,7 +29,7 @@ export default new Command({
             ? process.stdout
             : fs.createWriteStream(optsAll['log-file-output'])
         ;
-        
+
         const logResp = await opts.api
             .get(openapi.getUrl(`/insight/pl-waw-1/project/${optsAll.project}/journal/${optsAll.journal}`));
         const log = logResp.bodyJson;