test: move tests around

package.json

@@ -53,7 +53,8 @@
     "ignore": [
       "dist",
       "docs",
-      "test/dist"
+      "test/dist",
+      "test/fixtures"
     ]
   },
   "files": [

scripts/export-m3u8s.js

@@ -6,7 +6,7 @@ const path = require('path');
 
 const basePath = path.resolve(__dirname, '..');
 const testDataDir = path.join(basePath, 'test');
-const manifestDir = path.join(basePath, 'test', 'fixtures', 'm3u8');
+const manifestDir = path.join(basePath, 'test', 'fixtures', 'integration');
 const manifestFilepath = path.join(testDataDir, 'dist', 'test-manifests.js');
 const expectedFilepath = path.join(testDataDir, 'dist', 'test-expected.js');
 
@@ -32,9 +32,9 @@ const build = function() {
         // strip leading spaces and the trailing '+'
         .slice(4, -3);
       manifests += ',\n';
-    } else if (extname === '.json') {
+    } else if (extname === '.js') {
       // append the expected parse
-      expected += '  "' + path.basename(file, '.json') + '": ';
+      expected += '  "' + path.basename(file, '.js') + '": ';
       expected += fs.readFileSync(file, 'utf8');
       expected += ',\n';
     } else {

test/line-stream.test.js

@@ -0,0 +1,80 @@
+import {LineStream} from '../src';
+import QUnit from 'qunit';
+
+QUnit.module('LineStream', {
+  beforeEach() {
+    this.lineStream = new LineStream();
+  }
+});
+QUnit.test('empty inputs produce no tokens', function(assert) {
+  let data = false;
+
+  this.lineStream.on('data', function() {
+    data = true;
+  });
+  this.lineStream.push('');
+  assert.ok(!data, 'no tokens were produced');
+});
+QUnit.test('splits on newlines', function(assert) {
+  const lines = [];
+
+  this.lineStream.on('data', function(line) {
+    lines.push(line);
+  });
+  this.lineStream.push('#EXTM3U\nmovie.ts\n');
+
+  assert.strictEqual(2, lines.length, 'two lines are ready');
+  assert.strictEqual('#EXTM3U', lines.shift(), 'the first line is the first token');
+  assert.strictEqual('movie.ts', lines.shift(), 'the second line is the second token');
+});
+QUnit.test('empty lines become empty strings', function(assert) {
+  const lines = [];
+
+  this.lineStream.on('data', function(line) {
+    lines.push(line);
+  });
+  this.lineStream.push('\n\n');
+
+  assert.strictEqual(2, lines.length, 'two lines are ready');
+  assert.strictEqual('', lines.shift(), 'the first line is empty');
+  assert.strictEqual('', lines.shift(), 'the second line is empty');
+});
+QUnit.test('handles lines broken across appends', function(assert) {
+  const lines = [];
+
+  this.lineStream.on('data', function(line) {
+    lines.push(line);
+  });
+  this.lineStream.push('#EXTM');
+  assert.strictEqual(0, lines.length, 'no lines are ready');
+
+  this.lineStream.push('3U\nmovie.ts\n');
+  assert.strictEqual(2, lines.length, 'two lines are ready');
+  assert.strictEqual('#EXTM3U', lines.shift(), 'the first line is the first token');
+  assert.strictEqual('movie.ts', lines.shift(), 'the second line is the second token');
+});
+QUnit.test('stops sending events after deregistering', function(assert) {
+  const temporaryLines = [];
+  const temporary = function(line) {
+    temporaryLines.push(line);
+  };
+  const permanentLines = [];
+  const permanent = function(line) {
+    permanentLines.push(line);
+  };
+
+  this.lineStream.on('data', temporary);
+  this.lineStream.on('data', permanent);
+  this.lineStream.push('line one\n');
+  assert.strictEqual(
+    temporaryLines.length,
+    permanentLines.length,
+    'both callbacks receive the event'
+  );
+
+  assert.ok(this.lineStream.off('data', temporary), 'a listener was removed');
+  this.lineStream.push('line two\n');
+  assert.strictEqual(1, temporaryLines.length, 'no new events are received');
+  assert.strictEqual(2, permanentLines.length, 'new events are still received');
+});
+