export type RequestVideoEventSchedulerOptions = {
type: RequestVideoEventType
- videoId: string
+ videoId: number
count?: number
transaction?: Sequelize.Transaction
}
*/
const eventsPerVideoPerPod: {
[ podId: string ]: {
- [ videoRemoteId: string ]: {
+ [ videoUUID: string ]: {
views?: number
likes?: number
dislikes?: number
requestsToMakeGrouped[toPodId].ids.push(eventToProcess.id)
const eventsPerVideo = eventsPerVideoPerPod[toPodId]
- const remoteId = eventToProcess.video.remoteId
- if (!eventsPerVideo[remoteId]) eventsPerVideo[remoteId] = {}
+ const uuid = eventToProcess.video.uuid
+ if (!eventsPerVideo[uuid]) eventsPerVideo[uuid] = {}
- const events = eventsPerVideo[remoteId]
+ const events = eventsPerVideo[uuid]
if (!events[eventToProcess.type]) events[eventToProcess.type] = 0
events[eventToProcess.type] += eventToProcess.count
Object.keys(eventsPerVideoPerPod).forEach(toPodId => {
const eventsForPod = eventsPerVideoPerPod[toPodId]
- Object.keys(eventsForPod).forEach(remoteId => {
- const eventsForVideo = eventsForPod[remoteId]
+ Object.keys(eventsForPod).forEach(uuid => {
+ const eventsForVideo = eventsForPod[uuid]
Object.keys(eventsForVideo).forEach(eventType => {
requestsToMakeGrouped[toPodId].datas.push({
data: {
- remoteId,
+ uuid,
eventType: eventType as RemoteVideoEventType,
count: +eventsForVideo[eventType]
}