1 import { join } from 'path'
2 import Piscina from 'piscina'
3 import { WORKER_THREADS } from '@server/initializers/constants'
4 import { downloadImage } from './workers/image-downloader'
6 const downloadImagerWorker = new Piscina({
7 filename: join(__dirname, 'workers', 'image-downloader.js'),
8 concurrentTasksPerWorker: WORKER_THREADS.DOWNLOAD_IMAGE.CONCURRENCY,
9 maxThreads: WORKER_THREADS.DOWNLOAD_IMAGE.MAX_THREADS
12 function downloadImageFromWorker (options: Parameters<typeof downloadImage>[0]): Promise<ReturnType<typeof downloadImage>> {
13 return downloadImagerWorker.run(options)
17 downloadImageFromWorker