From 4a13c36da50f6b3171d817edebefe96ba85dc666 Mon Sep 17 00:00:00 2001 From: kamtschatka Date: Mon, 28 Oct 2024 02:51:00 +0100 Subject: feature: Archive videos using yt-dlp. Fixes #215 (#525) * Allow downloading more content from a webpage and index it #215 Added a worker that allows downloading videos depending on the environment variables refactored the code a bit added new video asset updated documentation * Some tweaks * Drop the dependency on the yt-dlp wrapper * Update openapi specs * Dont log an error when the url is not supported * Better handle supported websites that dont download anything --------- Co-authored-by: Mohamed Bassem --- apps/workers/index.ts | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) (limited to 'apps/workers/index.ts') diff --git a/apps/workers/index.ts b/apps/workers/index.ts index f9a05e59..3b5896e4 100644 --- a/apps/workers/index.ts +++ b/apps/workers/index.ts @@ -10,30 +10,39 @@ import { CrawlerWorker } from "./crawlerWorker"; import { shutdownPromise } from "./exit"; import { OpenAiWorker } from "./openaiWorker"; import { SearchIndexingWorker } from "./searchWorker"; +import { VideoWorker } from "./videoWorker"; async function main() { logger.info(`Workers version: ${serverConfig.serverVersion ?? "not set"}`); runQueueDBMigrations(); - const [crawler, openai, search, tidyAssets] = [ + const [crawler, openai, search, tidyAssets, video] = [ await CrawlerWorker.build(), OpenAiWorker.build(), SearchIndexingWorker.build(), TidyAssetsWorker.build(), + VideoWorker.build(), ]; await Promise.any([ - Promise.all([crawler.run(), openai.run(), search.run(), tidyAssets.run()]), + Promise.all([ + crawler.run(), + openai.run(), + search.run(), + tidyAssets.run(), + video.run(), + ]), shutdownPromise, ]); logger.info( - "Shutting down crawler, openai, tidyAssets and search workers ...", + "Shutting down crawler, openai, tidyAssets, video and search workers ...", ); crawler.stop(); openai.stop(); search.stop(); tidyAssets.stop(); + video.stop(); } main(); -- cgit v1.2.3-70-g09d2