preservetube
/
auto
mirror of https://github.com/preservetube/auto.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

1 at a time and done()

This commit is contained in:
unknown 2023-05-12 20:52:36 +02:00
parent 17f8170e46
commit f7fcf871ec
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
index.js
View File

@ -89,7 +89,7 @@ async function checkChannel(channelId) {
}) })
} }
queue.process(3, async function (job, done) { queue.process(1, async function (job, done) {
const { video, id } = job.data const { video, id } = job.data
logger.info({ message: `Starting to download ${video.title}, ${id}` }) logger.info({ message: `Starting to download ${video.title}, ${id}` })
@ -111,6 +111,7 @@ queue.process(3, async function (job, done) {
await database.createDatabaseVideo(id, videoUrl) await database.createDatabaseVideo(id, videoUrl)
await redis.del(id) await redis.del(id)
return done()
} else { } else {
await redis.set(`blacklist:${id}`, 'error') await redis.set(`blacklist:${id}`, 'error')
logger.info({ message: `Couldn't find file for ${video.title}, ${id}` }) logger.info({ message: `Couldn't find file for ${video.title}, ${id}` })
@ -124,6 +125,8 @@ channelQueue.process(10, async function (job, done) {
await checkChannel(c.channel) await checkChannel(c.channel)
await redis.del(c.channel) await redis.del(c.channel)
done()
}) })
check() check()