1 import cors from 'cors'
2 import express from 'express'
3 import { VideosTorrentCache } from '@server/lib/files-cache/videos-torrent-cache'
4 import { MActorImage } from '@server/types/models'
5 import { HttpStatusCode } from '../../shared/models/http/http-error-codes'
6 import { logger } from '../helpers/logger'
7 import { ACTOR_IMAGES_SIZE, LAZY_STATIC_PATHS, STATIC_MAX_AGE } from '../initializers/constants'
8 import { VideosCaptionCache, VideosPreviewCache } from '../lib/files-cache'
9 import { actorImagePathUnsafeCache, downloadActorImageFromWorker } from '../lib/local-actor'
10 import { asyncMiddleware } from '../middlewares'
11 import { ActorImageModel } from '../models/actor/actor-image'
13 const lazyStaticRouter = express.Router()
15 lazyStaticRouter.use(cors())
18 LAZY_STATIC_PATHS.AVATARS + ':filename',
19 asyncMiddleware(getActorImage)
23 LAZY_STATIC_PATHS.BANNERS + ':filename',
24 asyncMiddleware(getActorImage)
28 LAZY_STATIC_PATHS.PREVIEWS + ':filename',
29 asyncMiddleware(getPreview)
33 LAZY_STATIC_PATHS.VIDEO_CAPTIONS + ':filename',
34 asyncMiddleware(getVideoCaption)
38 LAZY_STATIC_PATHS.TORRENTS + ':filename',
39 asyncMiddleware(getTorrent)
42 // ---------------------------------------------------------------------------
50 // ---------------------------------------------------------------------------
52 async function getActorImage (req: express.Request, res: express.Response, next: express.NextFunction) {
53 const filename = req.params.filename
55 if (actorImagePathUnsafeCache.has(filename)) {
56 return res.sendFile(actorImagePathUnsafeCache.get(filename), { maxAge: STATIC_MAX_AGE.SERVER })
59 const image = await ActorImageModel.loadByName(filename)
60 if (!image) return res.status(HttpStatusCode.NOT_FOUND_404).end()
62 if (image.onDisk === false) {
63 if (!image.fileUrl) return res.status(HttpStatusCode.NOT_FOUND_404).end()
65 logger.info('Lazy serve remote actor image %s.', image.fileUrl)
68 await downloadActorImageFromWorker({
69 filename: image.filename,
70 fileUrl: image.fileUrl,
71 size: getActorImageSize(image),
75 logger.warn('Cannot process remote actor image %s.', image.fileUrl, { err })
76 return res.status(HttpStatusCode.NOT_FOUND_404).end()
81 .catch(err => logger.error('Cannot save new actor image disk state.', { err }))
84 const path = image.getPath()
86 actorImagePathUnsafeCache.set(filename, path)
88 return res.sendFile(path, { maxAge: STATIC_MAX_AGE.LAZY_SERVER }, (err: any) => {
91 // It seems this actor image is not on the disk anymore
92 if (err.status === HttpStatusCode.NOT_FOUND_404 && !image.isOwned()) {
93 logger.error('Cannot lazy serve actor image %s.', filename, { err })
95 actorImagePathUnsafeCache.delete(filename)
99 .catch(err => logger.error('Cannot save new actor image disk state.', { err }))
106 function getActorImageSize (image: MActorImage): { width: number, height: number } {
107 if (image.width && image.height) {
109 height: image.height,
114 return ACTOR_IMAGES_SIZE[image.type][0]
117 async function getPreview (req: express.Request, res: express.Response) {
118 const result = await VideosPreviewCache.Instance.getFilePath(req.params.filename)
119 if (!result) return res.status(HttpStatusCode.NOT_FOUND_404).end()
121 return res.sendFile(result.path, { maxAge: STATIC_MAX_AGE.LAZY_SERVER })
124 async function getVideoCaption (req: express.Request, res: express.Response) {
125 const result = await VideosCaptionCache.Instance.getFilePath(req.params.filename)
126 if (!result) return res.status(HttpStatusCode.NOT_FOUND_404).end()
128 return res.sendFile(result.path, { maxAge: STATIC_MAX_AGE.LAZY_SERVER })
131 async function getTorrent (req: express.Request, res: express.Response) {
132 const result = await VideosTorrentCache.Instance.getFilePath(req.params.filename)
133 if (!result) return res.status(HttpStatusCode.NOT_FOUND_404).end()
135 // Torrents still use the old naming convention (video uuid + .torrent)
136 return res.sendFile(result.path, { maxAge: STATIC_MAX_AGE.SERVER })