fix: make code up to date

.eslintignore

@@ -1 +1,2 @@
 /node_modules/
+dist/

.eslintrc.json

@@ -1,3 +1,4 @@
 {
-	"extends": "6river/typescript"
+	"extends": "6river/typescript",
+	"parser": "@typescript-eslint/parser"
 }

e2e/component.test.js

@@ -1,13 +1,12 @@
-let should = require('chai').should();
-let app = require('./server');
-let request = require('supertest');
-var spy = require('sinon').spy;
-let stream = require('stream');
-let http = require('http');
-let uuid = require('uuid');
+const should = require('chai').should();
+const app = require('./server');
+const request = require('supertest');
+const spy = require('sinon').spy;
+const stream = require('stream');
+const http = require('http');
+const uuid = require('uuid');
 
 describe('loopback-component-changestreamer', () => {
-
 	let Foo;
 	let Bar;
 
@@ -21,9 +20,10 @@ describe('loopback-component-changestreamer', () => {
 
 		changesUrl = app.settings.url + 'changes';
 		messages = [];
+		// eslint-disable-next-line
 		outStream = stream.PassThrough();
 		outStream.on('data', (chunk) => {
-			let textChunk = chunk.toString('utf8');
+			const textChunk = chunk.toString('utf8');
 			messages.push(textChunk);
 		});
 	});
@@ -35,27 +35,28 @@ describe('loopback-component-changestreamer', () => {
 	context('initialize connection', () => {
 		it('should set SSE headers', (done) => {
 			request(app).get('/changes')
-				.expect('Content-Type', /text\/event-stream/)
-				.expect('Connection', 'keep-alive')
-				.expect('Cache-Control', 'no-cache')
-				.expect('Access-Control-Allow-Origin', '*')
-				.expect(200, done);
+			.expect('Content-Type', /text\/event-stream/)
+			.expect('Connection', 'keep-alive')
+			.expect('Cache-Control', 'no-cache')
+			.expect('Access-Control-Allow-Origin', '*')
+			.expect(200, done);
 		});
 
 		it('set user headers', (done) => {
 			const fooID = uuid.v4();
-			let foo = {id: fooID, foo: 'habba'};
+			const foo = {id: fooID, foo: 'habba'};
 			http.get(changesUrl, (res) => {
 				res.pipe(outStream);
 			});
 			request(app).post('/api/Foos')
-			  .set('X-Auth-Request-User','test@gmail.com')
-				.send(foo)
-				.expect(200)
-				.then(response => {
-					messages[1].should.equal(`data: {"seqNo":0,"modelName":"Foo","kind":"create","target":"${fooID}","meta":{"headers":{"x-auth-request-user":"test@gmail.com"}},"data":{"id":"${fooID}","foo":"habba"}}\n\n`);
-					done();
-				});
+			  .set('X-Auth-Request-User', 'test@gmail.com')
+			.send(foo)
+			.expect(200)
+			.then((response) => {
+				// eslint-disable-next-line
+				messages[1].should.equal(`data: {"seqNo":0,"modelName":"Foo","kind":"create","target":"${fooID}","meta":{"headers":{"x-auth-request-user":"test@gmail.com"}},"data":{"id":"${fooID}","foo":"habba"}}\n\n`);
+				done();
+			});
 		});
 
 		it('should write retry timout as first parameter', (done) => {
@@ -79,33 +80,32 @@ describe('loopback-component-changestreamer', () => {
 				// create a model
 				Foo.create({id: fooID, foo: 'habba'});
 				// makes another model using new/save
-				let bar = new Bar({id: barID, bar: 'bahha'});
+				const bar = new Bar({id: barID, bar: 'bahha'});
 				bar.save();
 			});
 			setTimeout(() => {
 				messages.length.should.be.equal(3);
+				// eslint-disable-next-line
 				messages[1].should.equal(`data: {"seqNo":0,"modelName":"Foo","kind":"create","target":"${fooID}","meta":{"headers":[]},"data":{"id":"${fooID}","foo":"habba"}}\n\n`);
+				// eslint-disable-next-line
 				messages[2].should.equal(`data: {"seqNo":1,"modelName":"Bar","kind":"create","target":"${barID}","meta":{"headers":[]},"data":{"id":"${barID}","bar":"bahha"}}\n\n`);
 				done();
 			}, 2000);
 		});
 	});
 
 	context('statistics', () => {
-
 		it('should print statistics', (done) => {
 			request(app).get('/changes/stat')
-				.expect('Content-Type', /application\/json/)
-				.expect(200, {
-					connections: 0,
-					seqNo: 0
-				}, done);
+			.expect('Content-Type', /application\/json/)
+			.expect(200, {
+				connections: 0,
+				seqNo: 0,
+			}, done);
 		});
-
 	});
 
 	context('with existing models', () => {
-
 		let fooID;
 		let barID;
 		let foo;
@@ -130,6 +130,7 @@ describe('loopback-component-changestreamer', () => {
 				});
 				setTimeout(() => {
 					messages.length.should.be.equal(2);
+					// eslint-disable-next-line
 					messages[1].should.equal(`data: {"seqNo":2,"modelName":"Foo","kind":"update","target":"${fooID}","meta":{"headers":[]},"data":{"id":"${fooID}","foo":"baz"}}\n\n`);
 					done();
 				}, 2000);
@@ -140,16 +141,15 @@ describe('loopback-component-changestreamer', () => {
 			it('should write change event with kind = remove', (done) => {
 				http.get(changesUrl, (res) => {
 					res.pipe(outStream);
-					bar.destroy()
+					bar.destroy();
 				});
 				setTimeout(() => {
 					messages.length.should.be.equal(2);
+					// eslint-disable-next-line
 					messages[1].should.equal(`data: {"seqNo":2,"modelName":"Bar","kind":"remove","target":"${barID}","where":{"id":"${barID}"},"meta":{"headers":[]},"data":{"id":"${barID}","bar":"bar"}}\n\n`);
 					done();
 				}, 2000);
 			});
 		});
 	});
-
-
 });

e2e/helper.js

@@ -1,6 +1,4 @@
-'use strict';
-
-let chai = require('chai');
-let sinonChai = require('sinon-chai');
+const chai = require('chai');
+const sinonChai = require('sinon-chai');
 
 chai.use(sinonChai);

e2e/models/bar.js

@@ -1,4 +1,2 @@
-'use strict';
-
 module.exports = function(Bar) {
-}
+};

e2e/models/foo.js

@@ -1,4 +1,2 @@
-'use strict';
-
 module.exports = function(Foo) {
-}
+};

e2e/server.js

@@ -1,16 +1,18 @@
-let loopback = require('loopback');
-let boot = require('loopback-boot');
+const loopback = require('loopback');
+const boot = require('loopback-boot');
 
-let app = module.exports = loopback();
+const app = module.exports = loopback();
 
 // Bootstrap the application, configure models, datasources and middleware.
 // Sub-apps like REST API are mounted via boot scripts.
 boot(app, __dirname, function(err) {
-	if (err) { throw err; }
+	if (err) {
+		throw err;
+	}
 });
 
 app.start = (done) => {
-	let listener = app.listen(() => {
+	const listener = app.listen(() => {
 		app.stop = function(cb) {
 			listener.close(cb);
 		};