wipe unactive videos every 15 minutes
This commit is contained in:
		
							parent
							
								
									d07d2a3a36
								
							
						
					
					
						commit
						e965682e33
					
				| 
						 | 
					@ -16,9 +16,18 @@ redis.on('ready', async function () {
 | 
				
			||||||
    const filteredKeys = keys.filter(key => !key.startsWith('blacklist:'))
 | 
					    const filteredKeys = keys.filter(key => !key.startsWith('blacklist:'))
 | 
				
			||||||
    if (filteredKeys.length) await redis.del(filteredKeys)
 | 
					    if (filteredKeys.length) await redis.del(filteredKeys)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    const files = await fs.readdirSync('videos')
 | 
					    setInterval(async () => {
 | 
				
			||||||
 | 
					        const files = fs.readdirSync('videos')
 | 
				
			||||||
        const webmFiles = files.filter((file) => file.endsWith('.webm'))
 | 
					        const webmFiles = files.filter((file) => file.endsWith('.webm'))
 | 
				
			||||||
    webmFiles.forEach((f) => fs.unlinkSync(`videos/${f}`))
 | 
					        webmFiles.forEach(async (f) => {
 | 
				
			||||||
 | 
					            const videoId = f.replace('.webm', '')
 | 
				
			||||||
 | 
					            const isActive = await redis.get(videoId)
 | 
				
			||||||
 | 
					            if (!isActive) {
 | 
				
			||||||
 | 
					                fs.unlinkSync(`./videos/${f}`)
 | 
				
			||||||
 | 
					                logger.info({ message: `deleted file ${f} because there is no active download of it` })
 | 
				
			||||||
 | 
					            }
 | 
				
			||||||
 | 
					        })
 | 
				
			||||||
 | 
					    }, 5*60000)
 | 
				
			||||||
})
 | 
					})
 | 
				
			||||||
 | 
					
 | 
				
			||||||
module.exports = redis
 | 
					module.exports = redis
 | 
				
			||||||
		Loading…
	
		Reference in New Issue