yetangitu/Peertube
1
0
Fork 0
mirror of https://github.com/Chocobozzz/PeerTube.git synced 2025-10-06 03:50:26 +02:00
Code Issues Releases Wiki Activity

Migrate eslint to v9

Browse source
This commit is contained in:
Chocobozzz 2025-05-06 16:02:38 +02:00
parent bad8ea2c2e
commit 034e1bf328
No known key found for this signature in database
GPG key ID: 583A612D890159BE
106 changed files with 2130 additions and 1445 deletions
Download patch file Download diff file Expand all files Collapse all files

80
server/core/lib/job-queue/job-queue.ts
View file

@ -77,34 +77,34 @@ import { processVideoTranscription } from './handlers/video-transcription.js'
import { processVideosViewsStats } from './handlers/video-views-stats.js'
export type CreateJobArgument =
{ type: 'activitypub-http-broadcast', payload: ActivitypubHttpBroadcastPayload } |
{ type: 'activitypub-http-broadcast-parallel', payload: ActivitypubHttpBroadcastPayload } |
{ type: 'activitypub-http-unicast', payload: ActivitypubHttpUnicastPayload } |
{ type: 'activitypub-http-fetcher', payload: ActivitypubHttpFetcherPayload } |
{ type: 'activitypub-cleaner', payload: {} } |
{ type: 'activitypub-follow', payload: ActivitypubFollowPayload } |
{ type: 'video-file-import', payload: VideoFileImportPayload } |
{ type: 'video-transcoding', payload: VideoTranscodingPayload } |
{ type: 'email', payload: EmailPayload } |
{ type: 'transcoding-job-builder', payload: TranscodingJobBuilderPayload } |
{ type: 'video-import', payload: VideoImportPayload } |
{ type: 'activitypub-refresher', payload: RefreshPayload } |
{ type: 'videos-views-stats', payload: {} } |
{ type: 'video-live-ending', payload: VideoLiveEndingPayload } |
{ type: 'actor-keys', payload: ActorKeysPayload } |
{ type: 'video-redundancy', payload: VideoRedundancyPayload } |
{ type: 'video-studio-edition', payload: VideoStudioEditionPayload } |
{ type: 'manage-video-torrent', payload: ManageVideoTorrentPayload } |
{ type: 'move-to-object-storage', payload: MoveStoragePayload } |
{ type: 'move-to-file-system', payload: MoveStoragePayload } |
{ type: 'video-channel-import', payload: VideoChannelImportPayload } |
{ type: 'after-video-channel-import', payload: AfterVideoChannelImportPayload } |
{ type: 'notify', payload: NotifyPayload } |
{ type: 'federate-video', payload: FederateVideoPayload } |
{ type: 'create-user-export', payload: CreateUserExportPayload } |
{ type: 'generate-video-storyboard', payload: GenerateStoryboardPayload } |
{ type: 'import-user-archive', payload: ImportUserArchivePayload } |
{ type: 'video-transcription', payload: VideoTranscriptionPayload }
| { type: 'activitypub-http-broadcast', payload: ActivitypubHttpBroadcastPayload }
| { type: 'activitypub-http-broadcast-parallel', payload: ActivitypubHttpBroadcastPayload }
| { type: 'activitypub-http-unicast', payload: ActivitypubHttpUnicastPayload }
| { type: 'activitypub-http-fetcher', payload: ActivitypubHttpFetcherPayload }
| { type: 'activitypub-cleaner', payload: {} }
| { type: 'activitypub-follow', payload: ActivitypubFollowPayload }
| { type: 'video-file-import', payload: VideoFileImportPayload }
| { type: 'video-transcoding', payload: VideoTranscodingPayload }
| { type: 'email', payload: EmailPayload }
| { type: 'transcoding-job-builder', payload: TranscodingJobBuilderPayload }
| { type: 'video-import', payload: VideoImportPayload }
| { type: 'activitypub-refresher', payload: RefreshPayload }
| { type: 'videos-views-stats', payload: {} }
| { type: 'video-live-ending', payload: VideoLiveEndingPayload }
| { type: 'actor-keys', payload: ActorKeysPayload }
| { type: 'video-redundancy', payload: VideoRedundancyPayload }
| { type: 'video-studio-edition', payload: VideoStudioEditionPayload }
| { type: 'manage-video-torrent', payload: ManageVideoTorrentPayload }
| { type: 'move-to-object-storage', payload: MoveStoragePayload }
| { type: 'move-to-file-system', payload: MoveStoragePayload }
| { type: 'video-channel-import', payload: VideoChannelImportPayload }
| { type: 'after-video-channel-import', payload: AfterVideoChannelImportPayload }
| { type: 'notify', payload: NotifyPayload }
| { type: 'federate-video', payload: FederateVideoPayload }
| { type: 'create-user-export', payload: CreateUserExportPayload }
| { type: 'generate-video-storyboard', payload: GenerateStoryboardPayload }
| { type: 'import-user-archive', payload: ImportUserArchivePayload }
| { type: 'video-transcription', payload: VideoTranscriptionPayload }
export type CreateJobOptions = {
delay?: number
@ -182,7 +182,6 @@ const jobTypes: JobType[] = [
const silentFailure = new Set<JobType>([ 'activitypub-http-unicast' ])
class JobQueue {
private static instance: JobQueue
private workers: { [id in JobType]?: Worker } = {}
@ -214,7 +213,9 @@ class JobQueue {
connection: Redis.getRedisClientOptions('FlowProducer'),
prefix: this.jobRedisPrefix
})
this.flowProducer.on('error', err => { logger.error('Error in flow producer', { err }) })
this.flowProducer.on('error', err => {
logger.error('Error in flow producer', { err })
})
this.addRepeatableJobs()
}
@ -237,7 +238,7 @@ class JobQueue {
return timeoutPromise(p, timeout)
}
const processor = async (jobArg: Job<any>) => {
const processor = async (jobArg: Job) => {
const job = await Hooks.wrapObject(jobArg, 'filter:job-queue.process.params', { type: handlerName })
return Hooks.wrapPromiseFun(handler, job, 'filter:job-queue.process.result')
@ -258,7 +259,9 @@ class JobQueue {
}
})
worker.on('error', err => { logger.error('Error in job worker %s.', handlerName, { err }) })
worker.on('error', err => {
logger.error('Error in job worker %s.', handlerName, { err })
})
this.workers[handlerName] = worker
}
@ -270,7 +273,9 @@ class JobQueue {
}
const queue = new Queue(handlerName, queueOptions)
queue.on('error', err => { logger.error('Error in job queue %s.', handlerName, { err }) })
queue.on('error', err => {
logger.error('Error in job queue %s.', handlerName, { err })
})
this.queues[handlerName] = queue
@ -286,7 +291,9 @@ class JobQueue {
}
const queueEvents = new QueueEvents(handlerName, queueEventsOptions)
queueEvents.on('error', err => { logger.error('Error in job queue events %s.', handlerName, { err }) })
queueEvents.on('error', err => {
logger.error('Error in job queue events %s.', handlerName, { err })
})
this.queueEvents[handlerName] = queueEvents
}
@ -345,7 +352,7 @@ class JobQueue {
createJobAsync (options: CreateJobArgument & CreateJobOptions): void {
this.createJob(options)
.catch(err => logger.error('Cannot create job.', { err, options }))
.catch(err => logger.error('Cannot create job.', { err, options }))
}
createJob (options: CreateJobArgument & CreateJobOptions | undefined) {
@ -557,5 +564,6 @@ class JobQueue {
// ---------------------------------------------------------------------------
export {
JobQueue, jobTypes
JobQueue,
jobTypes
}