standard

Author: feross

bin/cmd.js

@@ -1,9 +1,9 @@
 #!/usr/bin/env node
 
-var minimist = require('minimist')
-var Server = require('../').Server
+const minimist = require('minimist')
+const Server = require('../').Server
 
-var argv = minimist(process.argv.slice(2), {
+const argv = minimist(process.argv.slice(2), {
   alias: {
     h: 'help',
     p: 'port',
@@ -70,13 +70,13 @@ if (argv.help) {
 
 if (argv.silent) argv.quiet = true
 
-var allFalsy = !argv.http && !argv.udp && !argv.ws
+const allFalsy = !argv.http && !argv.udp && !argv.ws
 
 argv.http = allFalsy || argv.http
 argv.udp = allFalsy || argv.udp
 argv.ws = allFalsy || argv.ws
 
-var server = new Server({
+const server = new Server({
   http: argv.http,
   interval: argv.interval,
   stats: argv.stats,
@@ -104,41 +104,41 @@ server.on('stop', function (addr) {
   if (!argv.quiet) console.log('stop: ' + addr)
 })
 
-var hostname = {
+const hostname = {
   http: argv['http-hostname'],
   udp4: argv['udp-hostname'],
   udp6: argv['udp6-hostname']
 }
 
 server.listen(argv.port, hostname, function () {
   if (server.http && argv.http && !argv.quiet) {
-    var httpAddr = server.http.address()
-    var httpHost = httpAddr.address !== '::' ? httpAddr.address : 'localhost'
-    var httpPort = httpAddr.port
+    const httpAddr = server.http.address()
+    const httpHost = httpAddr.address !== '::' ? httpAddr.address : 'localhost'
+    const httpPort = httpAddr.port
     console.log('HTTP tracker: http://' + httpHost + ':' + httpPort + '/announce')
   }
   if (server.udp && !argv.quiet) {
-    var udpAddr = server.udp.address()
-    var udpHost = udpAddr.address
-    var udpPort = udpAddr.port
+    const udpAddr = server.udp.address()
+    const udpHost = udpAddr.address
+    const udpPort = udpAddr.port
     console.log('UDP tracker: udp://' + udpHost + ':' + udpPort)
   }
   if (server.udp6 && !argv.quiet) {
-    var udp6Addr = server.udp6.address()
-    var udp6Host = udp6Addr.address !== '::' ? udp6Addr.address : 'localhost'
-    var udp6Port = udp6Addr.port
+    const udp6Addr = server.udp6.address()
+    const udp6Host = udp6Addr.address !== '::' ? udp6Addr.address : 'localhost'
+    const udp6Port = udp6Addr.port
     console.log('UDP6 tracker: udp://' + udp6Host + ':' + udp6Port)
   }
   if (server.ws && !argv.quiet) {
-    var wsAddr = server.http.address()
-    var wsHost = wsAddr.address !== '::' ? wsAddr.address : 'localhost'
-    var wsPort = wsAddr.port
+    const wsAddr = server.http.address()
+    const wsHost = wsAddr.address !== '::' ? wsAddr.address : 'localhost'
+    const wsPort = wsAddr.port
     console.log('WebSocket tracker: ws://' + wsHost + ':' + wsPort)
   }
   if (server.http && argv.stats && !argv.quiet) {
-    var statsAddr = server.http.address()
-    var statsHost = statsAddr.address !== '::' ? statsAddr.address : 'localhost'
-    var statsPort = statsAddr.port
+    const statsAddr = server.http.address()
+    const statsHost = statsAddr.address !== '::' ? statsAddr.address : 'localhost'
+    const statsPort = statsAddr.port
     console.log('Tracker stats: http://' + statsHost + ':' + statsPort + '/stats')
   }
 })

examples/express-embed/server.js

@@ -1,27 +1,27 @@
 #!/usr/bin/env node
 
-var Server = require('../..').Server
-var express = require('express')
-var app = express()
+const Server = require('../..').Server
+const express = require('express')
+const app = express()
 
 // https://wiki.theory.org/BitTorrentSpecification#peer_id
-var whitelist = {
+const whitelist = {
   UT: true // uTorrent
 }
 
-var server = new Server({
+const server = new Server({
   http: false, // we do our own
   udp: false, // not interested
   ws: false, // not interested
   filter: function (params) {
     // black/whitelist for disallowing/allowing specific clients [default=allow all]
     // this example only allows the uTorrent client
-    var client = params.peer_id[1] + params.peer_id[2]
+    const client = params.peer_id[1] + params.peer_id[2]
     return whitelist[client]
   }
 })
 
-var onHttpRequest = server.onHttpRequest.bind(server)
+const onHttpRequest = server.onHttpRequest.bind(server)
 app.get('/announce', onHttpRequest)
 app.get('/scrape', onHttpRequest)
 

lib/client/http-tracker.js

@@ -86,7 +86,7 @@ class HTTPTracker extends Tracker {
 
     // Otherwise, wait a short time for pending requests to complete, then force
     // destroy them.
-    var timeout = setTimeout(destroyCleanup, common.DESTROY_TIMEOUT)
+    let timeout = setTimeout(destroyCleanup, common.DESTROY_TIMEOUT)
 
     // But, if all pending requests complete before the timeout fires, do cleanup
     // right away.

lib/client/udp-tracker.js

@@ -46,7 +46,7 @@ class UDPTracker extends Tracker {
 
     // Otherwise, wait a short time for pending requests to complete, then force
     // destroy them.
-    var timeout = setTimeout(destroyCleanup, common.DESTROY_TIMEOUT)
+    let timeout = setTimeout(destroyCleanup, common.DESTROY_TIMEOUT)
 
     // But, if all pending requests complete before the timeout fires, do cleanup
     // right away.

lib/client/websocket-tracker.js

@@ -134,7 +134,7 @@ class WebSocketTracker extends Tracker {
 
     // Otherwise, wait a short time for potential responses to come in from the
     // server, then force close the socket.
-    var timeout = setTimeout(destroyCleanup, common.DESTROY_TIMEOUT)
+    let timeout = setTimeout(destroyCleanup, common.DESTROY_TIMEOUT)
 
     // But, if a response comes from the server before the timeout fires, do cleanup
     // right away.

lib/common-node.js

@@ -3,7 +3,7 @@
  * These are separate from common.js so they can be skipped when bundling for the browser.
  */
 
-var querystring = require('querystring')
+const querystring = require('querystring')
 
 exports.IPV4_RE = /^[\d.]+$/
 exports.IPV6_RE = /^[\da-fA-F:]+$/
@@ -38,7 +38,7 @@ exports.REQUEST_TIMEOUT = 15000
 exports.DESTROY_TIMEOUT = 1000
 
 function toUInt32 (n) {
-  var buf = Buffer.allocUnsafe(4)
+  const buf = Buffer.allocUnsafe(4)
   buf.writeUInt32BE(n, 0)
   return buf
 }
@@ -61,7 +61,7 @@ exports.querystringParse = function (q) {
  * @return {string}
  */
 exports.querystringStringify = function (obj) {
-  var ret = querystring.stringify(obj, null, null, { encodeURIComponent: escape })
+  let ret = querystring.stringify(obj, null, null, { encodeURIComponent: escape })
   ret = ret.replace(/[@*/+]/g, function (char) {
     // `escape` doesn't encode the characters @*/+ so we do it manually
     return '%' + char.charCodeAt(0).toString(16).toUpperCase()

lib/common.js

@@ -19,5 +19,5 @@ exports.hexToBinary = function (str) {
   return Buffer.from(str, 'hex').toString('binary')
 }
 
-var config = require('./common-node')
+const config = require('./common-node')
 Object.assign(exports, config)

lib/server/parse-http.js

@@ -1,11 +1,11 @@
 module.exports = parseHttpRequest
 
-var common = require('../common')
+const common = require('../common')
 
 function parseHttpRequest (req, opts) {
   if (!opts) opts = {}
-  var s = req.url.split('?')
-  var params = common.querystringParse(s[1])
+  const s = req.url.split('?')
+  const params = common.querystringParse(s[1])
   params.type = 'http'
 
   if (opts.action === 'announce' || s[0] === '/announce') {

lib/server/parse-udp.js

@@ -1,12 +1,12 @@
 module.exports = parseUdpRequest
 
-var ipLib = require('ip')
-var common = require('../common')
+const ipLib = require('ip')
+const common = require('../common')
 
 function parseUdpRequest (msg, rinfo) {
   if (msg.length < 16) throw new Error('received packet is too short')
 
-  var params = {
+  const params = {
     connectionId: msg.slice(0, 8), // 64-bit
     action: msg.readUInt32BE(8),
     transactionId: msg.readUInt32BE(12),
@@ -29,7 +29,7 @@ function parseUdpRequest (msg, rinfo) {
     params.event = common.EVENT_IDS[msg.readUInt32BE(80)]
     if (!params.event) throw new Error('invalid event') // early return
 
-    var ip = msg.readUInt32BE(84) // optional
+    const ip = msg.readUInt32BE(84) // optional
     params.ip = ip
       ? ipLib.toString(ip)
       : rinfo.address
@@ -49,8 +49,8 @@ function parseUdpRequest (msg, rinfo) {
   } else if (params.action === common.ACTIONS.SCRAPE) { // scrape message
     if ((msg.length - 16) % 20 !== 0) throw new Error('invalid scrape message')
     params.info_hash = []
-    for (var i = 0, len = (msg.length - 16) / 20; i < len; i += 1) {
-      var infoHash = msg.slice(16 + (i * 20), 36 + (i * 20)).toString('hex') // 20 bytes
+    for (let i = 0, len = (msg.length - 16) / 20; i < len; i += 1) {
+      const infoHash = msg.slice(16 + (i * 20), 36 + (i * 20)).toString('hex') // 20 bytes
       params.info_hash.push(infoHash)
     }
   } else {
@@ -60,16 +60,16 @@ function parseUdpRequest (msg, rinfo) {
   return params
 }
 
-var TWO_PWR_32 = (1 << 16) * 2
+const TWO_PWR_32 = (1 << 16) * 2
 
 /**
  * Return the closest floating-point representation to the buffer value. Precision will be
  * lost for big numbers.
  */
 function fromUInt64 (buf) {
-  var high = buf.readUInt32BE(0) | 0 // force
-  var low = buf.readUInt32BE(4) | 0
-  var lowUnsigned = (low >= 0) ? low : TWO_PWR_32 + low
+  const high = buf.readUInt32BE(0) | 0 // force
+  const low = buf.readUInt32BE(4) | 0
+  const lowUnsigned = (low >= 0) ? low : TWO_PWR_32 + low
 
   return (high * TWO_PWR_32) + lowUnsigned
 }

lib/server/parse-websocket.js

@@ -1,6 +1,6 @@
 module.exports = parseWebSocketRequest
 
-var common = require('../common')
+const common = require('../common')
 
 function parseWebSocketRequest (socket, opts, params) {
   if (!opts) opts = {}