Tracker scripts

.gitignore

@@ -1,6 +1,6 @@
 .DS_Store
 node_modules
-env.sh
+.env.sh
 public/javascripts/vendor
 /sources
 /.tmp

lib/api.js

@@ -9,7 +9,7 @@ class API {
  let stdout = ''
  let stderr = ''
 
- console.log(`Running %s with arguments %s`, script, args.join(' '))
+ // console.log(`Running %s with arguments %s`, script, args.join(' '))
 
  proc.stdout.on('data', data => (stdout += String(data)))
  proc.stderr.on('data', data => (stderr += String(data)))
@@ -65,6 +65,20 @@ class API {
 
  this.exec(process.env.SCRIPT_REMOVE_TORRENTS, args, callback)
  }
+
+ addWhitelistedHashes(hashes, callback) {
+ const args = hashes.reduce((acc, hash) => acc.concat(['-h', hash]), args)
+ this.exec(process.env.SCRIPT_TRACKER_ADD_TORRENTS, args, callback)
+ }
+
+ removeWhitelistedHashes(hashes, callback) {
+ const args = hashes.reduce((acc, hash) => acc.concat(['-h', hash]), args)
+ this.exec(process.env.SCRIPT_TRACKER_REMOVE_TORRENTS, args, callback)
+ }
+
+ restartTracker(callback) {
+ this.exec(process.env.SCRIPT_TRACKER_RESTART, callback)
+ }
 }
 
 // const callback = (err, data) => {

routes/torrents.js

@@ -26,9 +26,17 @@ router.post('/new', (req, res) => {
  const response = JSON.parse(data)
  const { hash } = response.data
 
- db.createTorrent(fileName, hash, (error3, result) => {
+ api.addWhitelistedHashes([hash], error3 => {
  if (error3) return res.send({ error: error3, data: {} })
- res.send(result)
+
+ api.restartTracker(error4 => {
+ if (error4) return res.send({ error: error4, data: {} })
+
+ db.createTorrent(fileName, hash, (error5, result) => {
+ if (error5) return res.send({ error: error5, data: {} })
+ res.send(result)
+ })
+ })
  })
  })
  })