diff options
author | Chocobozzz <me@florianbigard.com> | 2023-06-06 15:59:51 +0200 |
---|---|---|
committer | Chocobozzz <me@florianbigard.com> | 2023-06-29 10:19:33 +0200 |
commit | f162d32da098aa55f6de2367142faa166edb7c08 (patch) | |
tree | 31c6a96972994171853cb6c4e0b88b63241f8979 /server/lib/files-cache/video-previews-simple-file-cache.ts | |
parent | a673d9e848e51186602548a621e05925663b98be (diff) | |
download | PeerTube-f162d32da098aa55f6de2367142faa166edb7c08.tar.gz PeerTube-f162d32da098aa55f6de2367142faa166edb7c08.tar.zst PeerTube-f162d32da098aa55f6de2367142faa166edb7c08.zip |
Support lazy download thumbnails
Diffstat (limited to 'server/lib/files-cache/video-previews-simple-file-cache.ts')
-rw-r--r-- | server/lib/files-cache/video-previews-simple-file-cache.ts | 58 |
1 files changed, 58 insertions, 0 deletions
diff --git a/server/lib/files-cache/video-previews-simple-file-cache.ts b/server/lib/files-cache/video-previews-simple-file-cache.ts new file mode 100644 index 000000000..a05e80e16 --- /dev/null +++ b/server/lib/files-cache/video-previews-simple-file-cache.ts | |||
@@ -0,0 +1,58 @@ | |||
1 | import { join } from 'path' | ||
2 | import { FILES_CACHE } from '../../initializers/constants' | ||
3 | import { VideoModel } from '../../models/video/video' | ||
4 | import { AbstractSimpleFileCache } from './shared/abstract-simple-file-cache' | ||
5 | import { doRequestAndSaveToFile } from '@server/helpers/requests' | ||
6 | import { ThumbnailModel } from '@server/models/video/thumbnail' | ||
7 | import { ThumbnailType } from '@shared/models' | ||
8 | import { logger } from '@server/helpers/logger' | ||
9 | |||
10 | class VideoPreviewsSimpleFileCache extends AbstractSimpleFileCache <string> { | ||
11 | |||
12 | private static instance: VideoPreviewsSimpleFileCache | ||
13 | |||
14 | private constructor () { | ||
15 | super() | ||
16 | } | ||
17 | |||
18 | static get Instance () { | ||
19 | return this.instance || (this.instance = new this()) | ||
20 | } | ||
21 | |||
22 | async getFilePathImpl (filename: string) { | ||
23 | const thumbnail = await ThumbnailModel.loadWithVideoByFilename(filename, ThumbnailType.PREVIEW) | ||
24 | if (!thumbnail) return undefined | ||
25 | |||
26 | if (thumbnail.Video.isOwned()) return { isOwned: true, path: thumbnail.getPath() } | ||
27 | |||
28 | return this.loadRemoteFile(thumbnail.Video.uuid) | ||
29 | } | ||
30 | |||
31 | // Key is the video UUID | ||
32 | protected async loadRemoteFile (key: string) { | ||
33 | const video = await VideoModel.loadFull(key) | ||
34 | if (!video) return undefined | ||
35 | |||
36 | if (video.isOwned()) throw new Error('Cannot load remote preview of owned video.') | ||
37 | |||
38 | const preview = video.getPreview() | ||
39 | const destPath = join(FILES_CACHE.PREVIEWS.DIRECTORY, preview.filename) | ||
40 | const remoteUrl = preview.getOriginFileUrl(video) | ||
41 | |||
42 | try { | ||
43 | await doRequestAndSaveToFile(remoteUrl, destPath) | ||
44 | |||
45 | logger.debug('Fetched remote preview %s to %s.', remoteUrl, destPath) | ||
46 | |||
47 | return { isOwned: false, path: destPath } | ||
48 | } catch (err) { | ||
49 | logger.info('Cannot fetch remote preview file %s.', remoteUrl, { err }) | ||
50 | |||
51 | return undefined | ||
52 | } | ||
53 | } | ||
54 | } | ||
55 | |||
56 | export { | ||
57 | VideoPreviewsSimpleFileCache | ||
58 | } | ||