2 Request Video for Quick And Dirty Updates like:
7 We can't put it in the same system than basic requests for efficiency.
8 Moreover we don't want to slow down the basic requests with a lot of views/likes/dislikes requests.
9 So we put it an independant request scheduler.
12 import { values } from 'lodash'
13 import * as Sequelize from 'sequelize'
15 import { REQUEST_VIDEO_QADU_TYPES } from '../initializers'
17 import { addMethodsToModel } from './utils'
19 RequestVideoQaduClass,
20 RequestVideoQaduInstance,
21 RequestVideoQaduAttributes,
23 RequestVideoQaduMethods
24 } from './request-video-qadu-interface'
26 let RequestVideoQadu: Sequelize.Model<RequestVideoQaduInstance, RequestVideoQaduAttributes>
27 let countTotalRequests: RequestVideoQaduMethods.CountTotalRequests
28 let listWithLimitAndRandom: RequestVideoQaduMethods.ListWithLimitAndRandom
29 let removeByRequestIdsAndPod: RequestVideoQaduMethods.RemoveByRequestIdsAndPod
30 let removeAll: RequestVideoQaduMethods.RemoveAll
32 export default function (sequelize, DataTypes) {
33 RequestVideoQadu = sequelize.define('RequestVideoQadu',
36 type: DataTypes.ENUM(values(REQUEST_VIDEO_QADU_TYPES)),
53 const classMethods = [
56 listWithLimitAndRandom,
59 removeByRequestIdsAndPod
61 addMethodsToModel(RequestVideoQadu, classMethods)
63 return RequestVideoQadu
66 // ------------------------------ STATICS ------------------------------
68 function associate (models) {
69 RequestVideoQadu.belongsTo(models.Pod, {
77 RequestVideoQadu.belongsTo(models.Video, {
86 countTotalRequests = function (callback) {
88 return RequestVideoQadu.count(query).asCallback(callback)
91 listWithLimitAndRandom = function (limitPods, limitRequestsPerPod, callback) {
92 const Pod = RequestVideoQadu['sequelize'].models.Pod
94 Pod.listRandomPodIdsWithRequest(limitPods, 'RequestVideoQadus', function (err, podIds) {
95 if (err) return callback(err)
97 // We don't have friends that have requests
98 if (podIds.length === 0) return callback(null, [])
103 model: RequestVideoQadu['sequelize'].models.Pod,
111 model: RequestVideoQadu['sequelize'].models.Video
116 RequestVideoQadu.findAll(query).asCallback(function (err, requests) {
117 if (err) return callback(err)
119 const requestsGrouped = groupAndTruncateRequests(requests, limitRequestsPerPod)
120 return callback(err, requestsGrouped)
125 removeByRequestIdsAndPod = function (ids, podId, callback) {
135 RequestVideoQadu.destroy(query).asCallback(callback)
138 removeAll = function (callback) {
139 // Delete all requests
140 RequestVideoQadu.truncate({ cascade: true }).asCallback(callback)
143 // ---------------------------------------------------------------------------
145 function groupAndTruncateRequests (requests, limitRequestsPerPod) {
146 const requestsGrouped = {}
148 requests.forEach(function (request) {
149 const pod = request.Pod
151 if (!requestsGrouped[pod.id]) requestsGrouped[pod.id] = []
153 if (requestsGrouped[pod.id].length < limitRequestsPerPod) {
154 requestsGrouped[pod.id].push({
156 video: request.Video,
162 return requestsGrouped