Update dependencies and formatting

SOHU-Co · Feb 27, 2019 · f9f73f3 · f9f73f3
1 parent e977410
commit f9f73f3
Show file tree

Hide file tree

Showing 3 changed files with 42 additions and 59 deletions.
diff --git a/lib/commitStream.js b/lib/commitStream.js
@@ -19,10 +19,10 @@ var DEFAULTS = {
 class CommitStream extends Transform {
   constructor (client, topics, groupId, options) {
     options = options || {};
-    let parentOptions = _.defaults({highWaterMark: options.highWaterMark}, {objectMode: true});
+    let parentOptions = _.defaults({ highWaterMark: options.highWaterMark }, { objectMode: true });
     super(parentOptions);
 
-    this.options = _.defaults((options || {}), DEFAULTS);
+    this.options = _.defaults(options || {}, DEFAULTS);
     this.client = client;
     this.topicPartionOffsets = this.buildTopicData(_.cloneDeep(topics));
 
@@ -36,9 +36,12 @@ class CommitStream extends Transform {
     this.autoCommitIntervalTimer = null;
 
     if (this.autoCommit && this.autoCommitIntervalMs) {
-      this.autoCommitIntervalTimer = setInterval(function () {
-        this.commit();
-      }.bind(this), this.autoCommitIntervalMs);
+      this.autoCommitIntervalTimer = setInterval(
+        function () {
+          this.commit();
+        }.bind(this),
+        this.autoCommitIntervalMs
+      );
     }
 
     this.messageCount = 0;
@@ -132,7 +135,9 @@ class CommitStream extends Transform {
 
     let topicPartionOffsets = self.topicPartionOffsets;
 
-    let commits = topicPartionOffsets.filter(function (partition) { return partition.offset !== 0; });
+    let commits = topicPartionOffsets.filter(function (partition) {
+      return partition.offset !== 0;
+    });
 
     if (commits.length) {
       self.committing = true;

diff --git a/package.json b/package.json
@@ -19,9 +19,9 @@
   "types": "types/index.d.ts",
   "license": "MIT",
   "dependencies": {
-    "async": "^2.5.0",
+    "async": "^2.6.2",
     "binary": "~0.3.0",
-    "bl": "^1.2.0",
+    "bl": "^2.2.0",
     "buffer-crc32": "~0.2.5",
     "buffermaker": "~1.2.0",
     "debug": "^2.1.3",
@@ -40,17 +40,17 @@
     "snappy": "^6.0.1"
   },
   "devDependencies": {
-    "@types/node": "^10.5.2",
+    "@types/node": "^10.12.27",
     "coveralls": "^2.11.12",
     "doctoc": "^1.2.0",
-    "eslint": "^3.17.1",
-    "eslint-config-semistandard": "^11.0.0",
-    "eslint-config-standard": "^10.2.1",
+    "eslint": "^5.14.1",
+    "eslint-config-semistandard": "^13.0.0",
+    "eslint-config-standard": "^12.0.0",
     "eslint-plugin-dependencies": "^2.2.0",
-    "eslint-plugin-import": "^2.2.0",
-    "eslint-plugin-node": "^4.2.2",
-    "eslint-plugin-promise": "^3.4.0",
-    "eslint-plugin-standard": "^3.0.1",
+    "eslint-plugin-import": "^2.16.0",
+    "eslint-plugin-node": "^8.0.1",
+    "eslint-plugin-promise": "^4.0.1",
+    "eslint-plugin-standard": "^4.0.0",
     "execa": "^0.6.1",
     "istanbul": "^0.4.4",
     "mocha": "^3.1.0",
@@ -59,7 +59,7 @@
     "should": "^6.0.0",
     "sinon": "^2.0.0",
     "through2": "^2.0.3",
-    "tslint": "^5.10.0",
+    "tslint": "^5.13.0",
     "tslint-config-semistandard": "^7.0.0",
     "typescript": "^2.8.3"
   },

diff --git a/test/assignment/test.range.js b/test/assignment/test.range.js
@@ -6,34 +6,20 @@ const should = require('should');
 
 describe('Range Assignment', function () {
   const topicPartition = {
-    'RebalanceTopic': [
-      '0',
-      '1',
-      '2'
-    ],
-    'RebalanceTest': [
-      '0',
-      '1',
-      '2'
-    ]
+    RebalanceTopic: ['0', '1', '2'],
+    RebalanceTest: ['0', '1', '2']
   };
 
   const groupMembers = [
     {
-      'subscription': [
-        'RebalanceTopic',
-        'RebalanceTest'
-      ],
-      'version': 0,
-      'id': 'consumer1'
+      subscription: ['RebalanceTopic', 'RebalanceTest'],
+      version: 0,
+      id: 'consumer1'
     },
     {
-      'subscription': [
-        'RebalanceTopic',
-        'RebalanceTest'
-      ],
-      'version': 0,
-      'id': 'consumer2'
+      subscription: ['RebalanceTopic', 'RebalanceTest'],
+      version: 0,
+      id: 'consumer2'
     }
   ];
 
@@ -65,12 +51,9 @@ describe('Range Assignment', function () {
   it('should partition two topics of three partitions between three consumers', function (done) {
     const gm = groupMembers.slice(0);
     gm.push({
-      'subscription': [
-        'RebalanceTopic',
-        'RebalanceTest'
-      ],
-      'version': 0,
-      'id': 'consumer3'
+      subscription: ['RebalanceTopic', 'RebalanceTest'],
+      version: 0,
+      id: 'consumer3'
     });
 
     range.assign(topicPartition, gm, function (error, result) {
@@ -99,21 +82,16 @@ describe('Range Assignment', function () {
 
   it('should partition two topics of three partitions between four consumers', function (done) {
     const gm = groupMembers.slice(0);
-    gm.push({
-      'subscription': [
-        'RebalanceTopic',
-        'RebalanceTest'
-      ],
-      'version': 0,
-      'id': 'consumer3'
-    },
+    gm.push(
+      {
+        subscription: ['RebalanceTopic', 'RebalanceTest'],
+        version: 0,
+        id: 'consumer3'
+      },
       {
-        'subscription': [
-          'RebalanceTopic',
-          'RebalanceTest'
-        ],
-        'version': 0,
-        'id': 'consumer4'
+        subscription: ['RebalanceTopic', 'RebalanceTest'],
+        version: 0,
+        id: 'consumer4'
       }
     );