style: getting linting to pass

src/client.js

@@ -47,7 +47,7 @@ const Client = function (url, options) {
   this._messageCallbacks[C.TOPIC.ERROR] = this._onErrorMessage.bind(this)
 }
 
-Emitter(Client.prototype)
+Emitter(Client.prototype) // eslint-disable-line
 
 /**
  * Send authentication parameters to the client to fully open
@@ -251,7 +251,7 @@ Client.prototype._getOptions = function (options) {
  * @public
  * @returns {void}
  */
-function createDeepstream(url, options) {
+function createDeepstream (url, options) {
   return new Client(url, options)
 }
 

src/constants/merge-strategies.js

@@ -4,13 +4,13 @@ module.exports = {
   /**
   *  Choose the server's state over the client's
   **/
-  REMOTE_WINS(record, remoteValue, remoteVersion, callback) {
+  REMOTE_WINS (record, remoteValue, remoteVersion, callback) {
     callback(null, remoteValue)
   },
   /**
   *  Choose the local state over the server's
   **/
-  LOCAL_WINS(record, remoteValue, remoteVersion, callback) {
+  LOCAL_WINS (record, remoteValue, remoteVersion, callback) {
     callback(null, record.get())
   }
 }

src/message/connection.js

@@ -67,7 +67,7 @@ Connection.prototype.getState = function () {
  * @returns {void}
  */
 Connection.prototype.authenticate = function (authParams, callback) {
-  if(typeof authParams !== 'object') {
+  if (typeof authParams !== 'object') {
     this._client._$onError(C.TOPIC.ERROR, C.EVENT.INVALID_AUTH_MSG, 'authParams is not an object')
     return
   }
@@ -272,7 +272,7 @@ Connection.prototype._checkHeartBeat = function () {
     this._client._$onError(
       C.TOPIC.CONNECTION,
       C.EVENT.CONNECTION_ERROR,
-      'heartbeat not received in the last ' + heartBeatTolerance + ' milliseconds')
+      `heartbeat not received in the last ${heartBeatTolerance} milliseconds`)
     this._endpoint.close()
   }
 }
@@ -453,8 +453,8 @@ Connection.prototype._handleAuthResponse = function (message) {
       if (this._authCallback) {
         this._authCallback(false, 'invalid authentication message')
       }
-      
-      return;
+
+      return
     } else {
       this._setState(C.CONNECTION_STATE.AWAITING_AUTHENTICATION)
     }

src/record/anonymous-record.js

@@ -1,4 +1,5 @@
 'use strict'
+/* eslint-disable prefer-rest-params, prefer-spread */
 
 const Record = require('./record')
 const EventEmitter = require('component-emitter2')
@@ -29,7 +30,7 @@ const AnonymousRecord = function (recordHandler) {
   this._proxyMethod('discard')
 }
 
-EventEmitter(AnonymousRecord.prototype)
+EventEmitter(AnonymousRecord.prototype) // eslint-disable-line
 
 /**
  * Proxies the actual record's get method. It is valid

src/record/json-path.js

@@ -14,18 +14,18 @@ const cache = Object.create(null)
  */
 module.exports.get = function (data, path, deepCopy) {
   const tokens = tokenize(path)
-
+  let value = data
   for (let i = 0; i < tokens.length; i++) {
-    if (data === undefined) {
+    if (value === undefined) {
       return undefined
     }
-    if (typeof data !== 'object') {
+    if (typeof value !== 'object') {
       throw new Error('invalid data or path')
     }
-    data = data[tokens[i]]
+    value = data[tokens[i]]
   }
 
-  return deepCopy !== false ? utils.deepCopy(data) : data
+  return deepCopy !== false ? utils.deepCopy(value) : value
 }
 
 /**
@@ -76,7 +76,7 @@ module.exports.set = function (data, path, value, deepCopy) {
  * @param  {boolean} deepCopy
  * @return {Mixed}
  */
-function patch(oldValue, newValue, deepCopy) {
+function patch (oldValue, newValue, deepCopy) {
   let i
   let j
   if (oldValue === null || newValue === null) {
@@ -132,7 +132,7 @@ function patch(oldValue, newValue, deepCopy) {
  *
  * @returns Array of tokens
  */
-function tokenize(path) {
+function tokenize (path) {
   if (cache[path]) {
     return cache[path]
   }

src/record/list.js

@@ -1,4 +1,5 @@
 'use strict'
+/* eslint-disable prefer-rest-params */
 
 const EventEmitter = require('component-emitter2')
 const Record = require('./record')
@@ -45,7 +46,7 @@ const List = function (recordHandler, name, options) {
   this.whenReady = this._record.whenReady.bind(this)
 }
 
-EventEmitter(List.prototype)
+EventEmitter(List.prototype) // eslint-disable-line
 
 /**
  * Returns the array of list entries or an

src/record/record.js

@@ -1,4 +1,5 @@
 'use strict'
+/* eslint-disable prefer-spread, prefer-rest-params */
 
 const jsonPath = require('./json-path')
 const ResubscribeNotifier = require('../utils/resubscribe-notifier')
@@ -66,7 +67,7 @@ const Record = function (name, recordOptions, connection, options, client) {
   this._sendRead()
 }
 
-EventEmitter(Record.prototype)
+EventEmitter(Record.prototype) // eslint-disable-line
 
 /**
  * Set a merge strategy to resolve any merge conflicts that may occur due
@@ -137,7 +138,7 @@ Record.prototype.set = function (pathOrData, dataOrCallback, callback) {
     } else if (typeof pathOrData === 'object' && typeof dataOrCallback === 'function') {
       // set( data, callback )
       data = pathOrData
-      callback = dataOrCallback
+      callback = dataOrCallback // eslint-disable-line
     } else {
       throw new Error('invalid argument path')
     }
@@ -150,8 +151,8 @@ Record.prototype.set = function (pathOrData, dataOrCallback, callback) {
     data = dataOrCallback
   }
 
-  if(!path && (data === null || typeof data !== 'object')) {
-      throw new Error('invalid arguments, scalar values cannot be set without path');
+  if (!path && (data === null || typeof data !== 'object')) {
+    throw new Error('invalid arguments, scalar values cannot be set without path')
   }
 
   if (this._checkDestroyed('set')) {
@@ -207,6 +208,7 @@ Record.prototype.set = function (pathOrData, dataOrCallback, callback) {
  * @public
  * @returns {void}
  */
+// eslint-disable-next-line
 Record.prototype.subscribe = function (path, callback, triggerNow) {
   const args = this._normalizeArguments(arguments)
 
@@ -249,6 +251,7 @@ Record.prototype.subscribe = function (path, callback, triggerNow) {
  * @public
  * @returns {void}
  */
+// eslint-disable-next-line
 Record.prototype.unsubscribe = function (pathOrCallback, callback) {
   const args = this._normalizeArguments(arguments)
 

src/utils/ack-timeout-registry.js

@@ -24,7 +24,7 @@ const AckTimeoutRegistry = function (client, options) {
   client.on('connectionStateChanged', this._onConnectionStateChanged.bind(this))
 }
 
-EventEmitter(AckTimeoutRegistry.prototype)
+EventEmitter(AckTimeoutRegistry.prototype) // eslint-disable-line
 
 /**
  * Add an entry