stream-lines - npm Package Compare versions

Comparing version 1.1.7 to 1.1.8

index.js

@@ -1,1 +0,97 @@
-module.exports = require('./lib/line-stream');
+var through = require('through3')
+  , LF = '\n'.charCodeAt(0);
+
+/**
+ *  Reads stream buffers and writes arrays of lines.
+ *
+ *  Designed to be piped to another transform stream that
+ *  operates on the array of lines.
+ *
+ *  ## Options
+ *
+ *  @param encoding The encoding to use when converting buffers to strings.
+ */
+function Line(options) {
+  options = options || {};
+  this.encoding = options.encoding || 'utf8';
+  this.eol = /\r?\n/;
+  if(options.buffer) {
+    this.body = [];
+  }
+  this.options = options;
+}
+
+/**
+ *  Transform function.
+ */
+function transform(chunk, encoding, cb) {
+  var lines = []
+    , i = 0
+    , s = 0
+    , b
+    , line;
+
+  if(Array.isArray(chunk)) {
+    lines = chunk;
+  }else if(typeof chunk === 'string') {
+    lines = chunk.split(this.eol);
+  }else if(Buffer.isBuffer(chunk)) {
+
+    if(this.buffer && this.buffer.length) {
+      chunk = Buffer.concat(
+        [this.buffer, chunk], this.buffer.length + chunk.length);
+    }
+
+    while((b = chunk[i]) !== undefined) {
+      if(b === LF) {
+        line = new Buffer(i - s);
+        chunk.copy(line, 0, s, i);
+        s = i + 1;
+        lines.push(line.toString(this.encoding));
+        this.buffer = new Buffer(chunk.length - i - 1);
+        chunk.copy(this.buffer, 0, i + 1);
+      } 
+      i++;
+    } 
+
+    // nothing was found
+    if(!line) {
+      this.buffer = chunk;
+    }
+  }else{
+    return cb(new Error('line stream accepts buffers or strings'));
+  }
+
+  // how to handle the lines
+  if(this.body) {
+    this.body = this.body.concat(lines);
+  }else{
+    this.push(lines);
+    this.emit('lines', lines);
+  }
+  cb();
+}
+
+function flush(cb) {
+  var lines = [];
+
+  // unterminated last line, need to flush it
+  if(this.buffer) {
+    lines = [this.buffer.toString(this.encoding)];
+    if(this.body) {
+      this.body = this.body.concat(lines);
+    }else{
+      this.push(lines);
+    }
+  }
+  // buffered array of all lines
+  if(this.body) {
+    this.push(this.body);
+  }
+
+  this.emit('lines', this.body || lines);
+  this.buffer = null;
+  cb();
+}
+
+module.exports = through.transform(transform, flush, {ctor: Line});

package.json

 {
   "name": "stream-lines",
   "description": "Line transform stream, reads bytes writes arrays of lines.",
-  "version": "1.1.7",
+  "version": "1.1.8",
   "author": "muji <[e-mail]>",
@@ -34,4 +34,4 @@ "license": "MIT",
     "readme": "mdp --force -v",
-    "test": "NODE_ENV=test mocha -- test/spec",
-    "cover": "NODE_ENV=test istanbul cover --root ./lib _mocha -- test/spec",
+    "test": "NODE_ENV=test mocha -- ${SPEC:-test/spec}",
+    "cover": "NODE_ENV=test istanbul cover _mocha -- ${SPEC:-test/spec}",
     "coveralls": "cat ./coverage/lcov.info | ./node_modules/coveralls/bin/coveralls.js"
@@ -38,0 +38,0 @@ },

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

7491

decreased by-4.94%

Number of package files

9

decreased by-10%

Lines of code

86

decreased by-8.51%

No dependency changes