]>
Commit | Line | Data |
---|---|---|
6d472b40 | 1 | |
f6d6e7f8 | 2 | import { logger, loggerTagsFactory } from '@server/helpers/logger' |
f6d6e7f8 | 3 | import { SCHEDULER_INTERVALS_MS } from '@server/initializers/constants' |
6d472b40 | 4 | import { uploadx } from '../uploadx' |
f6d6e7f8 | 5 | import { AbstractScheduler } from './abstract-scheduler' |
6 | ||
7 | const lTags = loggerTagsFactory('scheduler', 'resumable-upload', 'cleaner') | |
8 | ||
9 | export class RemoveDanglingResumableUploadsScheduler extends AbstractScheduler { | |
10 | ||
11 | private static instance: AbstractScheduler | |
12 | private lastExecutionTimeMs: number | |
13 | ||
61953742 | 14 | protected schedulerIntervalMs = SCHEDULER_INTERVALS_MS.REMOVE_DANGLING_RESUMABLE_UPLOADS |
f6d6e7f8 | 15 | |
16 | private constructor () { | |
17 | super() | |
18 | ||
19 | this.lastExecutionTimeMs = new Date().getTime() | |
20 | } | |
21 | ||
22 | protected async internalExecute () { | |
6d472b40 | 23 | logger.debug('Removing dangling resumable uploads', lTags()) |
f6d6e7f8 | 24 | |
6d472b40 | 25 | const now = new Date().getTime() |
f6d6e7f8 | 26 | |
27 | try { | |
6d472b40 C |
28 | // Remove files that were not updated since the last execution |
29 | await uploadx.storage.purge(now - this.lastExecutionTimeMs) | |
f6d6e7f8 | 30 | } catch (error) { |
31 | logger.error('Failed to handle file during resumable video upload folder cleanup', { error, ...lTags() }) | |
32 | } finally { | |
6d472b40 | 33 | this.lastExecutionTimeMs = now |
f6d6e7f8 | 34 | } |
35 | } | |
36 | ||
37 | static get Instance () { | |
38 | return this.instance || (this.instance = new this()) | |
39 | } | |
40 | } |