Update to Angular RC 1

[github/Chocobozzz/PeerTube.git] / server / lib / webtorrentProcess.js

diff --git a/server/lib/webtorrentProcess.js b/server/lib/webtorrentProcess.js
index 7da52523a74703377e7ee597f1f66b5d908e4eec..be7ac5bb4c48853897c507baf291f0a3ac1a7c68 100644 (file)
--- a/server/lib/webtorrentProcess.js
+++ b/server/lib/webtorrentProcess.js
@@ -1,61 +1,61 @@
 'use strict'
 
-var WebTorrent = require('webtorrent')
-var ipc = require('node-ipc')
+const WebTorrent = require('webtorrent')
+const ipc = require('node-ipc')
 
 function webtorrent (args) {
   if (args.length !== 3) {
     throw new Error('Wrong arguments number: ' + args.length + '/3')
   }
 
-  var host = args[1]
-  var port = args[2]
-  var nodeKey = 'webtorrentnode' + port
-  var processKey = 'webtorrentprocess' + port
+  const host = args[1]
+  const port = args[2]
+  const nodeKey = 'webtorrentnode' + port
+  const processKey = 'webtorrentprocess' + port
 
   ipc.config.silent = true
   ipc.config.id = processKey
 
   if (host === 'client' && port === '1') global.WEBTORRENT_ANNOUNCE = []
   else global.WEBTORRENT_ANNOUNCE = 'ws://' + host + ':' + port + '/tracker/socket'
-  var wt = new WebTorrent({ dht: false })
+  const wt = new WebTorrent({ dht: false })
 
   function seed (data) {
-    var args = data.args
-    var path = args.path
-    var _id = data._id
+    const args = data.args
+    const path = args.path
+    const _id = data._id
 
     wt.seed(path, { announceList: '' }, function (torrent) {
-      var to_send = {
+      const toSend = {
         magnetUri: torrent.magnetURI
       }
 
-      ipc.of[nodeKey].emit(nodeKey + '.seedDone.' + _id, to_send)
+      ipc.of[nodeKey].emit(nodeKey + '.seedDone.' + _id, toSend)
     })
   }
 
   function add (data) {
-    var args = data.args
-    var magnetUri = args.magnetUri
-    var _id = data._id
+    const args = data.args
+    const magnetUri = args.magnetUri
+    const _id = data._id
 
     wt.add(magnetUri, function (torrent) {
-      var to_send = {
+      const toSend = {
         files: []
       }
 
       torrent.files.forEach(function (file) {
-        to_send.files.push({ path: file.path })
+        toSend.files.push({ path: file.path })
       })
 
-      ipc.of[nodeKey].emit(nodeKey + '.addDone.' + _id, to_send)
+      ipc.of[nodeKey].emit(nodeKey + '.addDone.' + _id, toSend)
     })
   }
 
   function remove (data) {
-    var args = data.args
-    var magnetUri = args.magnetUri
-    var _id = data._id
+    const args = data.args
+    const magnetUri = args.magnetUri
+    const _id = data._id
 
     try {
       wt.remove(magnetUri, callback)
@@ -65,8 +65,8 @@ function webtorrent (args) {
     }
 
     function callback () {
-      var to_send = {}
-      ipc.of[nodeKey].emit(nodeKey + '.removeDone.' + _id, to_send)
+      const toSend = {}
+      ipc.of[nodeKey].emit(nodeKey + '.removeDone.' + _id, toSend)
     }
   }
 
@@ -83,7 +83,7 @@ function webtorrent (args) {
   })
 
   process.on('uncaughtException', function (e) {
-    ipc.of[nodeKey].emit(processKey + '.exception', { exception: e })
+    ipc.of[nodeKey].emit(processKey + '.exception', { exception: e.toString() })
   })
 }