1 import { CacheFileObject } from '../../../shared/index'
2 import { VideoModel } from '../../models/video/video'
3 import { sequelizeTypescript } from '../../initializers'
4 import { VideoRedundancyModel } from '../../models/redundancy/video-redundancy'
6 function cacheFileActivityObjectToDBAttributes (cacheFileObject: CacheFileObject, video: VideoModel, byActor: { id?: number }) {
7 const url = cacheFileObject.url
9 const videoFile = video.VideoFiles.find(f => {
10 return f.resolution === url.height && f.fps === url.fps
13 if (!videoFile) throw new Error(`Cannot find video file ${url.height} ${url.fps} of video ${video.url}`)
16 expiresOn: new Date(cacheFileObject.expires),
17 url: cacheFileObject.id,
18 fileUrl: cacheFileObject.url.href,
20 videoFileId: videoFile.id,
25 function createCacheFile (cacheFileObject: CacheFileObject, video: VideoModel, byActor: { id?: number }) {
26 return sequelizeTypescript.transaction(async t => {
27 const attributes = cacheFileActivityObjectToDBAttributes(cacheFileObject, video, byActor)
29 return VideoRedundancyModel.create(attributes, { transaction: t })
33 function updateCacheFile (cacheFileObject: CacheFileObject, redundancyModel: VideoRedundancyModel, byActor: { id?: number }) {
34 const attributes = cacheFileActivityObjectToDBAttributes(cacheFileObject, redundancyModel.VideoFile.Video, byActor)
36 redundancyModel.set('expires', attributes.expiresOn)
37 redundancyModel.set('fileUrl', attributes.fileUrl)
39 return redundancyModel.save()
45 cacheFileActivityObjectToDBAttributes