forks/peertube
1
0
Fork 0
Code Releases Activity

Stop live before removing files

Browse source
This commit is contained in:
Chocobozzz 2023-09-01 13:16:27 +02:00
parent d38a49463f
commit a1d9318066
No known key found for this signature in database
GPG key ID: 583A612D890159BE
1 changed files with 14 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
server/server/models/video/video.ts
View file

@ -796,6 +796,20 @@ export class VideoModel extends Model<Partial<AttributesOnly<VideoModel>>> {
InternalEventEmitter.Instance.emit('video-deleted', { video }) InternalEventEmitter.Instance.emit('video-deleted', { video })
} }
@BeforeDestroy
static stopLiveIfNeeded (instance: VideoModel) {
if (!instance.isLive) return
logger.info('Stopping live of video %s after video deletion.', instance.uuid)
LiveManager.Instance.stopSessionOf(instance.uuid, null)
}
@BeforeDestroy
static invalidateCache (instance: VideoModel) {
ModelCache.Instance.invalidateCache('video', instance.id)
}
@BeforeDestroy @BeforeDestroy
static async sendDelete (instance: MVideoAccountLight, options: { transaction: Transaction }) { static async sendDelete (instance: MVideoAccountLight, options: { transaction: Transaction }) {
if (!instance.isOwned()) return undefined if (!instance.isOwned()) return undefined
@ -848,20 +862,6 @@ export class VideoModel extends Model<Partial<AttributesOnly<VideoModel>>> {
return undefined return undefined
} }
@BeforeDestroy
static stopLiveIfNeeded (instance: VideoModel) {
if (!instance.isLive) return
logger.info('Stopping live of video %s after video deletion.', instance.uuid)
LiveManager.Instance.stopSessionOf(instance.uuid, null)
}
@BeforeDestroy
static invalidateCache (instance: VideoModel) {
ModelCache.Instance.invalidateCache('video', instance.id)
}
@BeforeDestroy @BeforeDestroy
static async saveEssentialDataToAbuses (instance: VideoModel, options) { static async saveEssentialDataToAbuses (instance: VideoModel, options) {
const tasks: Promise<any>[] = [] const tasks: Promise<any>[] = []