aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/models/request-video-event.js
diff options
context:
space:
mode:
Diffstat (limited to 'server/models/request-video-event.js')
-rw-r--r--server/models/request-video-event.js172
1 files changed, 0 insertions, 172 deletions
diff --git a/server/models/request-video-event.js b/server/models/request-video-event.js
deleted file mode 100644
index 9ebeaec90..000000000
--- a/server/models/request-video-event.js
+++ /dev/null
@@ -1,172 +0,0 @@
1'use strict'
2
3/*
4 Request Video events (likes, dislikes, views...)
5*/
6
7const values = require('lodash/values')
8
9const constants = require('../initializers/constants')
10const customVideosValidators = require('../helpers/custom-validators').videos
11
12// ---------------------------------------------------------------------------
13
14module.exports = function (sequelize, DataTypes) {
15 const RequestVideoEvent = sequelize.define('RequestVideoEvent',
16 {
17 type: {
18 type: DataTypes.ENUM(values(constants.REQUEST_VIDEO_EVENT_TYPES)),
19 allowNull: false
20 },
21 count: {
22 type: DataTypes.INTEGER,
23 allowNull: false,
24 validate: {
25 countValid: function (value) {
26 const res = customVideosValidators.isVideoEventCountValid(value)
27 if (res === false) throw new Error('Video event count is not valid.')
28 }
29 }
30 }
31 },
32 {
33 updatedAt: false,
34 indexes: [
35 {
36 fields: [ 'videoId' ]
37 }
38 ],
39 classMethods: {
40 associate,
41
42 listWithLimitAndRandom,
43
44 countTotalRequests,
45 removeAll,
46 removeByRequestIdsAndPod
47 }
48 }
49 )
50
51 return RequestVideoEvent
52}
53
54// ------------------------------ STATICS ------------------------------
55
56function associate (models) {
57 this.belongsTo(models.Video, {
58 foreignKey: {
59 name: 'videoId',
60 allowNull: false
61 },
62 onDelete: 'CASCADE'
63 })
64}
65
66function countTotalRequests (callback) {
67 const query = {}
68 return this.count(query).asCallback(callback)
69}
70
71function listWithLimitAndRandom (limitPods, limitRequestsPerPod, callback) {
72 const self = this
73 const Pod = this.sequelize.models.Pod
74
75 // We make a join between videos and authors to find the podId of our video event requests
76 const podJoins = 'INNER JOIN "Videos" ON "Videos"."authorId" = "Authors"."id" ' +
77 'INNER JOIN "RequestVideoEvents" ON "RequestVideoEvents"."videoId" = "Videos"."id"'
78
79 Pod.listRandomPodIdsWithRequest(limitPods, 'Authors', podJoins, function (err, podIds) {
80 if (err) return callback(err)
81
82 // We don't have friends that have requests
83 if (podIds.length === 0) return callback(null, [])
84
85 const query = {
86 order: [
87 [ 'id', 'ASC' ]
88 ],
89 include: [
90 {
91 model: self.sequelize.models.Video,
92 include: [
93 {
94 model: self.sequelize.models.Author,
95 include: [
96 {
97 model: self.sequelize.models.Pod,
98 where: {
99 id: {
100 $in: podIds
101 }
102 }
103 }
104 ]
105 }
106 ]
107 }
108 ]
109 }
110
111 self.findAll(query).asCallback(function (err, requests) {
112 if (err) return callback(err)
113
114 const requestsGrouped = groupAndTruncateRequests(requests, limitRequestsPerPod)
115 return callback(err, requestsGrouped)
116 })
117 })
118}
119
120function removeByRequestIdsAndPod (ids, podId, callback) {
121 const query = {
122 where: {
123 id: {
124 $in: ids
125 }
126 },
127 include: [
128 {
129 model: this.sequelize.models.Video,
130 include: [
131 {
132 model: this.sequelize.models.Author,
133 where: {
134 podId
135 }
136 }
137 ]
138 }
139 ]
140 }
141
142 this.destroy(query).asCallback(callback)
143}
144
145function removeAll (callback) {
146 // Delete all requests
147 this.truncate({ cascade: true }).asCallback(callback)
148}
149
150// ---------------------------------------------------------------------------
151
152function groupAndTruncateRequests (events, limitRequestsPerPod) {
153 const eventsGrouped = {}
154
155 events.forEach(function (event) {
156 const pod = event.Video.Author.Pod
157
158 if (!eventsGrouped[pod.id]) eventsGrouped[pod.id] = []
159
160 if (eventsGrouped[pod.id].length < limitRequestsPerPod) {
161 eventsGrouped[pod.id].push({
162 id: event.id,
163 type: event.type,
164 count: event.count,
165 video: event.Video,
166 pod
167 })
168 }
169 })
170
171 return eventsGrouped
172}