chore(package): update standard to the latest version

Author: hulkoba

index.js

@@ -2,7 +2,7 @@ const amqp = require('amqplib')
 const redis = require('redis')
 
 const env = require('./lib/env')
-const {parseRegistryUrl, checkFollower, startChanges} = require('./lib/follow')
+const { parseRegistryUrl, checkFollower, startChanges } = require('./lib/follow')
 
 ;(async () => {
   const conn = await amqp.connect(env.AMQP_URL)

lib/env.js

@@ -1,6 +1,6 @@
 const envalid = require('envalid')
 const isEmpty = require('lodash').isEmpty
-const {str, url, json, bool, num} = envalid
+const { str, url, json, bool, num } = envalid
 
 const isNotEmpty = (value) => !isEmpty(value)
 
@@ -11,19 +11,19 @@ const urlArray = envalid.makeValidator(x => {
 })
 
 const environmentConfig = {
-  AMQP_URL: url({devDefault: 'amqp://localhost'}),
-  REGISTRY_URLS: urlArray({default: '["https://replicate.npmjs.com/registry"]'}),
-  REDIS_URL: url({default: 'redis://redis:6379', devDefault: 'redis://localhost:6379'}),
-  REDIS_SEQ_KEY: str({default: 'changes-seq'}),
-  QUEUE_NAME: str({default: 'events'}),
-  NODE_ENV: str({choices: ['development', 'staging', 'production'], devDefault: 'development'}),
-  STATSD_HOST: str({default: '172.17.0.1'}),
-  REGISTRY_CHANGE_DELAY: num({default: 1000 * 60, devDefault: 1000}),
-  IS_ENTERPRISE: bool({default: false})
+  AMQP_URL: url({ devDefault: 'amqp://localhost' }),
+  REGISTRY_URLS: urlArray({ default: '["https://replicate.npmjs.com/registry"]' }),
+  REDIS_URL: url({ default: 'redis://redis:6379', devDefault: 'redis://localhost:6379' }),
+  REDIS_SEQ_KEY: str({ default: 'changes-seq' }),
+  QUEUE_NAME: str({ default: 'events' }),
+  NODE_ENV: str({ choices: ['development', 'staging', 'production'], devDefault: 'development' }),
+  STATSD_HOST: str({ default: '172.17.0.1' }),
+  REGISTRY_CHANGE_DELAY: num({ default: 1000 * 60, devDefault: 1000 }),
+  IS_ENTERPRISE: bool({ default: false })
 }
 
 if (!process.env.IS_ENTERPRISE) {
-  environmentConfig.ROLLBAR_TOKEN_CHANGES = str({devDefault: ''})
+  environmentConfig.ROLLBAR_TOKEN_CHANGES = str({ devDefault: '' })
 }
 
 module.exports = envalid.cleanEnv(process.env, environmentConfig)

lib/follow.js

@@ -39,7 +39,7 @@ function parseRegistryUrl (registry) {
   }
 }
 
-function checkFollower ({registry, client, changes}, done) {
+function checkFollower ({ registry, client, changes }, done) {
   request({
     url: registry.url,
     json: true
@@ -57,7 +57,7 @@ function checkFollower ({registry, client, changes}, done) {
   })
 }
 
-async function handleChange ({channel, client, registry}, change) {
+async function handleChange ({ channel, client, registry }, change) {
   statsdClient.increment('change')
   statsdClient.gauge('sequence', change.seq)
   client.set(registry.seqKey, change.seq, err => {
@@ -79,14 +79,14 @@ async function handleChange ({channel, client, registry}, change) {
   try {
     await asyncTimeout(env.REGISTRY_CHANGE_DELAY, async () => {
       const payloadBuffer = Buffer.from(JSON.stringify(payload))
-      await channel.sendToQueue(env.QUEUE_NAME, payloadBuffer, {priority: 1})
+      await channel.sendToQueue(env.QUEUE_NAME, payloadBuffer, { priority: 1 })
     })
   } catch (err) {
     rollbar.error(err)
   }
 }
 
-function startChanges ({channel, client, registry}, cb) {
+function startChanges ({ channel, client, registry }, cb) {
   client.get(registry.seqKey, function (err, reply) {
     if (err) rollbar.error(err)
 
@@ -106,7 +106,7 @@ function startChanges ({channel, client, registry}, cb) {
       changes.destroy()
       cb(error || new Error('resarting'))
     })
-    changes.on('data', handleChange.bind(null, {channel, client, registry}))
+    changes.on('data', handleChange.bind(null, { channel, client, registry }))
     cb(null, changes)
   })
 }

lib/rollbar.js

@@ -1,4 +1,4 @@
-const {resolve} = require('path')
+const { resolve } = require('path')
 
 const Rollbar = require('rollbar')
 
@@ -18,5 +18,5 @@ if (enabled) {
     exitOnUncaughtException: true
   })
 } else {
-  module.exports = new Rollbar({enabled: false})
+  module.exports = new Rollbar({ enabled: false })
 }

test/follow.js

@@ -1,9 +1,9 @@
-const {EventEmitter} = require('events')
+const { EventEmitter } = require('events')
 
 const amqp = require('amqplib')
 const nock = require('nock')
 const redis = require('redis-mock')
-const {test, afterEach, tearDown} = require('tap')
+const { test, afterEach, tearDown } = require('tap')
 const proxyquire = require('proxyquire')
 
 const env = require('../lib/env')
@@ -79,7 +79,7 @@ const {
     t.plan(4)
     nock('https://skimdb.npmjs.com')
       .get('/registry')
-      .reply(200, {update_seq: 5000})
+      .reply(200, { update_seq: 5000 })
 
     const client = redis.createClient()
     client.set('gk-seq', 4000, err => {
@@ -107,7 +107,7 @@ const {
     t.plan(5)
     nock('https://skimdb.npmjs.com')
       .get('/registry')
-      .reply(200, {update_seq: 5000})
+      .reply(200, { update_seq: 5000 })
 
     const client = redis.createClient()
     client.set('gk-seq', 6000, err => {
@@ -182,7 +182,7 @@ const {
         next: '2.0.0-rc1'
       },
       versions: {
-        '1.0.0': {gitHead: 'a213fe9c'},
+        '1.0.0': { gitHead: 'a213fe9c' },
         '2.0.0-rc1': {}
       },
       registry: rawUrl
@@ -204,7 +204,7 @@ const {
       registry: {
         url,
         seqKey: 'gk-seq-2',
-        query: {token: '1234'}
+        query: { token: '1234' }
       }
     }, (err, changes) => {
       if (err) return t.ok(savedChanges.destroyed, 'destroyed')
@@ -213,7 +213,7 @@ const {
         db: url,
         since: 'now',
         include_docs: true,
-        query_params: {token: '1234'}
+        query_params: { token: '1234' }
       }, 'opts')
       changes.emit('error', new Error('restart'))
     })