-;(function () {
- 'use strict'
-
- var async = require('async')
- var config = require('config')
- var fs = require('fs')
- var request = require('request')
-
- var constants = require('../initializers/constants')
- var logger = require('../helpers/logger')
- var peertubeCrypto = require('../helpers/peertubeCrypto')
- var Pods = require('../models/pods')
- var poolRequests = require('../lib/poolRequests')
- var requests = require('../helpers/requests')
- var Videos = require('../models/videos')
-
- var http = config.get('webserver.https') ? 'https' : 'http'
- var host = config.get('webserver.host')
- var port = config.get('webserver.port')
-
- var pods = {
- addVideoToFriends: addVideoToFriends,
- hasFriends: hasFriends,
- makeFriends: makeFriends,
- quitFriends: quitFriends,
- removeVideoToFriends: removeVideoToFriends
- }
+'use strict'
+
+var async = require('async')
+var config = require('config')
+var fs = require('fs')
+var request = require('request')
+
+var constants = require('../initializers/constants')
+var logger = require('../helpers/logger')
+var peertubeCrypto = require('../helpers/peertubeCrypto')
+var Pods = require('../models/pods')
+var poolRequests = require('../lib/poolRequests')
+var requests = require('../helpers/requests')
+var Videos = require('../models/videos')
+
+var http = config.get('webserver.https') ? 'https' : 'http'
+var host = config.get('webserver.host')
+var port = config.get('webserver.port')
+
+var pods = {
+ addVideoToFriends: addVideoToFriends,
+ hasFriends: hasFriends,
+ makeFriends: makeFriends,
+ quitFriends: quitFriends,
+ removeVideoToFriends: removeVideoToFriends
+}
+
+function addVideoToFriends (video) {
+ // To avoid duplicates
+ var id = video.name + video.magnetUri
+ // ensure namePath is null
+ video.namePath = null
+ poolRequests.addRequest(id, 'add', video)
+}
+
+function hasFriends (callback) {
+ Pods.count(function (err, count) {
+ if (err) return callback(err)
+
+ var has_friends = (count !== 0)
+ callback(null, has_friends)
+ })
+}
+
+function makeFriends (callback) {
+ var pods_score = {}
+
+ logger.info('Make friends!')
+ fs.readFile(peertubeCrypto.getCertDir() + 'peertube.pub', 'utf8', function (err, cert) {
+ if (err) {
+ logger.error('Cannot read public cert.')
+ return callback(err)
+ }