X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Fmodels%2Fvideo%2Fthumbnail.ts;h=3d885f6544fe0eb1d9899fcea89504d36953ad85;hb=a35a22797c99f17924347da9a226068c3dbe4787;hp=e68a6711fe637aa996cc6f512fae174a0c0cb0fb;hpb=2735a154dc77316e584bc784c65e904df791067f;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/models/video/thumbnail.ts b/server/models/video/thumbnail.ts index e68a6711f..3d885f654 100644 --- a/server/models/video/thumbnail.ts +++ b/server/models/video/thumbnail.ts @@ -1,7 +1,10 @@ +import { remove } from 'fs-extra' import { join } from 'path' import { AfterDestroy, AllowNull, + BeforeCreate, + BeforeUpdate, BelongsTo, Column, CreatedAt, @@ -12,13 +15,15 @@ import { Table, UpdatedAt } from 'sequelize-typescript' -import { CONSTRAINTS_FIELDS, LAZY_STATIC_PATHS, STATIC_PATHS, WEBSERVER } from '../../initializers/constants' +import { buildRemoteVideoBaseUrl } from '@server/helpers/activitypub' +import { afterCommitIfTransaction } from '@server/helpers/database-utils' +import { MThumbnail, MThumbnailVideo, MVideoAccountLight } from '@server/types/models' +import { ThumbnailType } from '../../../shared/models/videos/thumbnail.type' import { logger } from '../../helpers/logger' -import { remove } from 'fs-extra' import { CONFIG } from '../../initializers/config' +import { CONSTRAINTS_FIELDS, LAZY_STATIC_PATHS, STATIC_PATHS, WEBSERVER } from '../../initializers/constants' import { VideoModel } from './video' import { VideoPlaylistModel } from './video-playlist' -import { ThumbnailType } from '../../../shared/models/videos/thumbnail.type' @Table({ tableName: 'thumbnail', @@ -29,10 +34,14 @@ import { ThumbnailType } from '../../../shared/models/videos/thumbnail.type' { fields: [ 'videoPlaylistId' ], unique: true + }, + { + fields: [ 'filename', 'type' ], + unique: true } ] }) -export class ThumbnailModel extends Model { +export class ThumbnailModel extends Model { @AllowNull(false) @Column @@ -90,7 +99,10 @@ export class ThumbnailModel extends Model { @UpdatedAt updatedAt: Date - private static types: { [ id in ThumbnailType ]: { label: string, directory: string, staticPath: string } } = { + // If this thumbnail replaced existing one, track the old name + previousThumbnailFilename: string + + private static readonly types: { [ id in ThumbnailType ]: { label: string, directory: string, staticPath: string } } = { [ThumbnailType.MINIATURE]: { label: 'miniature', directory: CONFIG.STORAGE.THUMBNAILS_DIR, @@ -103,6 +115,12 @@ export class ThumbnailModel extends Model { } } + @BeforeCreate + @BeforeUpdate + static removeOldFile (instance: ThumbnailModel, options) { + return afterCommitIfTransaction(options.transaction, () => instance.removePreviousFilenameIfNeeded()) + } + @AfterDestroy static removeFiles (instance: ThumbnailModel) { logger.info('Removing %s file %s.', ThumbnailModel.types[instance.type].label, instance.filename) @@ -112,25 +130,42 @@ export class ThumbnailModel extends Model { .catch(err => logger.error('Cannot remove thumbnail file %s.', instance.filename, err)) } - static loadByName (filename: string) { + static loadByFilename (filename: string, thumbnailType: ThumbnailType): Promise { const query = { where: { - filename + filename, + type: thumbnailType } } return ThumbnailModel.findOne(query) } - static generateDefaultPreviewName (videoUUID: string) { - return videoUUID + '.jpg' + static loadWithVideoByFilename (filename: string, thumbnailType: ThumbnailType): Promise { + const query = { + where: { + filename, + type: thumbnailType + }, + include: [ + { + model: VideoModel.unscoped(), + required: true + } + ] + } + + return ThumbnailModel.findOne(query) } - getFileUrl () { + getFileUrl (video: MVideoAccountLight) { + const staticPath = ThumbnailModel.types[this.type].staticPath + this.filename + + if (video.isOwned()) return WEBSERVER.URL + staticPath if (this.fileUrl) return this.fileUrl - const staticPath = ThumbnailModel.types[this.type].staticPath - return WEBSERVER.URL + staticPath + this.filename + // Fallback if we don't have a file URL + return buildRemoteVideoBaseUrl(video, staticPath) } getPath () { @@ -138,7 +173,22 @@ export class ThumbnailModel extends Model { return join(directory, this.filename) } + getPreviousPath () { + const directory = ThumbnailModel.types[this.type].directory + return join(directory, this.previousThumbnailFilename) + } + removeThumbnail () { return remove(this.getPath()) } + + removePreviousFilenameIfNeeded () { + if (!this.previousThumbnailFilename) return + + const previousPath = this.getPreviousPath() + remove(previousPath) + .catch(err => logger.error('Cannot remove previous thumbnail file %s.', previousPath, { err })) + + this.previousThumbnailFilename = undefined + } }