const logger = require('../helpers/logger')
const peertubeCrypto = require('../helpers/peertube-crypto')
const requests = require('../helpers/requests')
+const utils = require('../helpers/utils')
const RequestScheduler = require('./request-scheduler')
const RequestVideoQaduScheduler = require('./request-video-qadu-scheduler')
+const RequestVideoEventScheduler = require('./request-video-event-scheduler')
const ENDPOINT_ACTIONS = constants.REQUEST_ENDPOINT_ACTIONS[constants.REQUEST_ENDPOINTS.VIDEOS]
const requestScheduler = new RequestScheduler()
-const requestSchedulerVideoQadu = new RequestVideoQaduScheduler()
+const requestVideoQaduScheduler = new RequestVideoQaduScheduler()
+const requestVideoEventScheduler = new RequestVideoEventScheduler()
const friends = {
activate,
updateVideoToFriends,
reportAbuseVideoToFriend,
quickAndDirtyUpdateVideoToFriends,
+ addEventToRemoteVideo,
hasFriends,
makeFriends,
quitFriends,
removeVideoToFriends,
- sendOwnedVideosToPod
+ sendOwnedVideosToPod,
+ getRequestScheduler,
+ getRequestVideoQaduScheduler,
+ getRequestVideoEventScheduler
}
function activate () {
requestScheduler.activate()
- requestSchedulerVideoQadu.activate()
+ requestVideoQaduScheduler.activate()
+ requestVideoEventScheduler.activate()
}
function addVideoToFriends (videoData, transaction, callback) {
return createVideoQaduRequest(options, callback)
}
+function addEventToRemoteVideo (videoId, type, transaction, callback) {
+ const options = {
+ videoId,
+ type,
+ transaction
+ }
+ createVideoEventRequest(options, callback)
+}
+
function hasFriends (callback) {
db.Pod.countAll(function (err, count) {
if (err) return callback(err)
},
function flushVideoQaduRequests (callbackAsync) {
- requestSchedulerVideoQadu.flush(err => callbackAsync(err))
+ requestVideoQaduScheduler.flush(err => callbackAsync(err))
},
function getPodsList (callbackAsync) {
})
}
+function getRequestScheduler () {
+ return requestScheduler
+}
+
+function getRequestVideoQaduScheduler () {
+ return requestVideoQaduScheduler
+}
+
+function getRequestVideoEventScheduler () {
+ return requestVideoEventScheduler
+}
+
// ---------------------------------------------------------------------------
module.exports = friends
}
function createVideoQaduRequest (options, callback) {
- if (!callback) callback = function () {}
+ if (!callback) callback = utils.createEmptyCallback()
+
+ requestVideoQaduScheduler.createRequest(options, callback)
+}
+
+function createVideoEventRequest (options, callback) {
+ if (!callback) callback = utils.createEmptyCallback()
- requestSchedulerVideoQadu.createRequest(options, callback)
+ requestVideoEventScheduler.createRequest(options, callback)
}
function isMe (host) {