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

dumb issue

This commit is contained in:
localhost 2025-03-31 08:34:50 +02:00
parent c5b3b589a9
commit ffc74f3c1e
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/router/websocket.ts
View File

@ -145,21 +145,21 @@ app.ws('/savechannel', {
const videos = await getChannelVideos(channelId); const videos = await getChannelVideos(channelId);
for (const video of videos.slice(0, 5)) { for (const video of videos.slice(0, 5)) {
if (!video || (await redis.get(video.id)) || (await redis.get(`blacklist:${video.id}`))) continue; if (!video || (await redis.get(video.video_id)) || (await redis.get(`blacklist:${video.video_id}`))) continue;
const already = await db.selectFrom('videos') const already = await db.selectFrom('videos')
.select('id') .select('id')
.where('id', '=', video.id) .where('id', '=', video.video_id)
.executeTakeFirst() .executeTakeFirst()
if (already) continue if (already) continue
ws.send(`DATA - Processing video: ${video.title.text}`); ws.send(`DATA - Processing video: ${video.title.text}`);
await redis.set(video.id, 'downloading', 'EX', 300); await redis.set(video.video_id, 'downloading', 'EX', 300);
const downloadResult = await downloadVideo(ws, video.id); const downloadResult = await downloadVideo(ws, video.video_id);
if (!downloadResult.fail) await handleUpload(ws, video.id, true); if (!downloadResult.fail) await handleUpload(ws, video.video_id, true);
await redis.del(video.id); await redis.del(video.video_id);
ws.send(`DATA - Created video page for ${video.title.text}`) ws.send(`DATA - Created video page for ${video.title.text}`)
} }