From 2c6dbc287c8fa4742a3eb956c00ca3c97a957ba6 Mon Sep 17 00:00:00 2001 From: PhatPhuckDave Date: Sat, 21 Dec 2024 11:16:21 +0100 Subject: [PATCH] Use kkdai downloader --- downloader/downloaders/utils.go | 2 +- downloader/main.go | 14 ++++++++------ 2 files changed, 9 insertions(+), 7 deletions(-) diff --git a/downloader/downloaders/utils.go b/downloader/downloaders/utils.go index 6b73759..c78199a 100644 --- a/downloader/downloaders/utils.go +++ b/downloader/downloaders/utils.go @@ -8,4 +8,4 @@ const OUTPUT_DIR = "C:/Users/Administrator/ytdlpVideos" var ongoingDownloads = make(map[string]struct{}) var ongoingDownloadsMutex = &sync.Mutex{} -const DOWNLOAD_WORKERS = 4 +const DOWNLOAD_WORKERS = 2 diff --git a/downloader/main.go b/downloader/main.go index 90437fd..969a5ed 100644 --- a/downloader/main.go +++ b/downloader/main.go @@ -36,7 +36,9 @@ func init() { log.Lmicroseconds|log.Lshortfile) } -var downloader downloaders.Downloader = &downloaders.YTDLPRawDownloader{} +//var downloader downloaders.Downloader = &downloaders.YTDLPRawDownloader{} +var downloader downloaders.Downloader = &downloaders.KidaiDownloader{} +//var downloader downloaders.Downloader = &downloaders.YTDLPLibDownloader{} type DLHandler struct{} @@ -76,11 +78,11 @@ func (*DLHandler) HandleMessage(message *nsq.Message) error { } func main() { - //err := downloader.Download("https://www.youtube.com/watch?v=SiKjprtiPaw") - //if err != nil { - // Error.Printf("Error downloading: %v", err) - //} - //return +// err := downloader.Download("https://www.youtube.com/watch?v=SiKjprtiPaw") +// if err != nil { +// Error.Printf("Error downloading: %v", err) +// } +// return config := nsq.NewConfig() config.MaxAttempts = 5