]>
Commit | Line | Data |
---|---|---|
fc097052 C |
1 | import { ensureDir } from 'fs-extra' |
2 | import { Op } from 'sequelize' | |
3 | import { updateTorrentMetadata } from '@server/helpers/webtorrent' | |
4 | import { DIRECTORIES } from '@server/initializers/constants' | |
5 | import { moveFilesIfPrivacyChanged } from '@server/lib/video-privacy' | |
6 | import { VideoModel } from '@server/models/video/video' | |
7 | import { MVideoFullLight } from '@server/types/models' | |
8 | import { VideoPrivacy } from '@shared/models' | |
9 | import { initDatabaseModels } from '../../server/initializers/database' | |
10 | ||
11 | run() | |
12 | .then(() => process.exit(0)) | |
13 | .catch(err => { | |
14 | console.error(err) | |
15 | process.exit(-1) | |
16 | }) | |
17 | ||
18 | async function run () { | |
19 | console.log('Moving private video files in dedicated folders.') | |
20 | ||
21 | await ensureDir(DIRECTORIES.HLS_STREAMING_PLAYLIST.PRIVATE) | |
22 | await ensureDir(DIRECTORIES.VIDEOS.PRIVATE) | |
23 | ||
24 | await initDatabaseModels(true) | |
25 | ||
26 | const videos = await VideoModel.unscoped().findAll({ | |
27 | attributes: [ 'uuid' ], | |
28 | where: { | |
29 | privacy: { | |
30 | [Op.in]: [ VideoPrivacy.PRIVATE, VideoPrivacy.INTERNAL ] | |
31 | } | |
32 | } | |
33 | }) | |
34 | ||
35 | for (const { uuid } of videos) { | |
36 | try { | |
37 | console.log('Moving files of video %s.', uuid) | |
38 | ||
39 | const video = await VideoModel.loadFull(uuid) | |
40 | ||
41 | try { | |
42 | await moveFilesIfPrivacyChanged(video, VideoPrivacy.PUBLIC) | |
43 | } catch (err) { | |
44 | console.error('Cannot move files of video %s.', uuid, err) | |
45 | } | |
46 | ||
47 | try { | |
48 | await updateTorrents(video) | |
49 | } catch (err) { | |
50 | console.error('Cannot regenerate torrents of video %s.', uuid, err) | |
51 | } | |
52 | } catch (err) { | |
53 | console.error('Cannot process video %s.', uuid, err) | |
54 | } | |
55 | } | |
56 | } | |
57 | ||
58 | async function updateTorrents (video: MVideoFullLight) { | |
59 | for (const file of video.VideoFiles) { | |
60 | await updateTorrentMetadata(video, file) | |
61 | ||
62 | await file.save() | |
63 | } | |
64 | ||
65 | const playlist = video.getHLSPlaylist() | |
66 | for (const file of (playlist?.VideoFiles || [])) { | |
67 | await updateTorrentMetadata(playlist, file) | |
68 | ||
69 | await file.save() | |
70 | } | |
71 | } |