torrent timeout

Author: eltharynd

README.md

@@ -239,6 +239,7 @@ services:
       - TORRENT_USER=<your-username-here>
       - TORRENT_PASSWORD=<your-password-here>
       - TORRENT_CLIENT=qbittorrent
+      #- TORRENT_CLIENT_TIMEOUT=10
       #- TORRENT_CATEGORY_FORCE=false
       #- TORRENT_CATEGORY=onepacerr
       #- TORRENT_CATEGORY_ONCE_COMPLETED=completed
@@ -425,10 +426,11 @@ If you set `LIBRARY_MEDIA_SERVER=false`, you can instead generate those files re
 | ⭐ `TORRENT_URL` | `http://localhost:8080` | Your torrent API URL. |
 | ⭐ `TORRENT_USER` | _None_ | Your torrent API username. |
 | ⭐ `TORRENT_PASSWORD` | _None_ | Your torrent API password. |
+| `TORRENT_CLIENT_TIMEOUT` | 10 | Seconds to wait for torrent client to respond to requests, increase if you have a LOT of torrents. |
 | `TORRENT_CATEGORY_FORCE` | `false` | If `true`, when trying to add a torrent also forces a category update if torrent already exists with a different category. |
 | `TORRENT_CATEGORY` | `onepacerr` | Creates downloads with this category, also filters completed torrents using this. |
 | `TORRENT_CATEGORY_ONCE_COMPLETED` | `completed` | After processing completed downloads, changes the torrent category to this one. |
-| `TORRENT_CHECK_INTERVAL` | `60` | Seconds between checking for completed downloads. |
+| `TORRENT_CHECK_INTERVAL` | 60 | Seconds between checking for completed downloads. |
 
 ---
 
@@ -450,7 +452,7 @@ If you set `LIBRARY_MEDIA_SERVER=false`, you can instead generate those files re
 | `METADATA_URL` | `https://raw.githubusercontent.com/ladyisatis/one-pace-metadata/refs/heads/v2/metadata/data.json` | Metadata url (untested with different ones). |
 | `METADATA_LANGUAGE` | `en` | Currently only language supported. |
 | `METADATA_POSTER_SET` | `default` | Currently `default` equals `piratezekk`. There are also `official` and `mizzoufan523` available. If a set is missing a poster it uses `default`. |
-| `METADATA_CHECK_INTERVAL` | `3600` | Seconds between checking for new metadata. |
+| `METADATA_CHECK_INTERVAL` | 3600 | Seconds between checking for new metadata. |
 
 ---
 

sample.env

@@ -125,6 +125,8 @@ TORRENT_PASSWORD=<your-password-here>
 
 # Your torrent client. Will be used in the future to use different clients rather tnax qBittorrent.
 TORRENT_CLIENT=qbittorrent
+# Seconds to wait for torrent client to respond to requests, increase if you have a LOT of torrents.
+TORRENT_CLIENT_TIMEOUT=10
 
 # If `true`, when trying to add a torrent also forces a category update if torrent already exists with a different category.
 TORRENT_CATEGORY_FORCE=false

src/environment.ts

@@ -103,6 +103,8 @@ export default {
 	TORRENT_PASSWORD: process.env.TORRENT_PASSWORD || `password`,
 
 	TORRENT_CLIENT: process.env.TORRENT_CLIENT || `qbittorrent`,
+	TORRENT_CLIENT_TIMEOUT:
+		Number.parseInt(process.env.TORRENT_CLIENT_TIMEOUT || '10') * 1000,
 
 	TORRENT_CATEGORY_FORCE: /true/i.test(
 		process.env.TORRENT_CATEGORY_FORCE || 'false',

src/index.ts

@@ -68,7 +68,7 @@ const startApp = async () => {
 			e instanceof LabelsDisabledInDelugeError ||
 			e instanceof TorrentConnectionError
 		) {
-			Logger.debug(`Error handled, no need tO crash...`)
+			Logger.debug(`Error handled, no need to crash...`)
 		} else {
 			Logger.error('APPLICATION CRASHED UNEXPECTEDLY...')
 			Logger.error(e)

src/metadata/metadata.controller.ts

@@ -18,6 +18,7 @@ import {
 
 export class MetadataController {
 	private metadata: Metadata
+	private reprocess: boolean
 
 	private TVShowNFO
 	private seasonNFOs = {}
@@ -37,12 +38,25 @@ export class MetadataController {
 				Logger.info(`Newer Metadata found!`)
 				this.metadata = metadata
 				newMetadata = true
+			} else if (this.reprocess) {
+				Logger.info(`Reprocessing Metadata due to previous errors!`)
+				this.reprocess = false
+				newMetadata = true
 			}
 		} catch (e) {
 			Logger.error(`Error refreshing Metadata, will retry...`)
 			Logger.error(e)
 		}
 
+		try {
+			if (newMetadata) await this.processMetadataEpisodes()
+		} catch (e) {
+			//TODO refactor checkMetadataDownloaded and create a queue of failedToProcess to only retry those
+			Logger.error(
+				`Unexpected error encountered when processing metadata, we will attempt to reprocess it again next cycle...`,
+			)
+			this.reprocess = true
+		}
 		if (newMetadata) await this.processMetadataEpisodes()
 
 		setTimeout(async () => {

src/torrent/clients/deluge.controller.ts

@@ -18,7 +18,10 @@ export class DelugeController implements ITorrentController {
 		username: string
 		password: string
 	}) {
-		this.client = new Deluge(options)
+		this.client = new Deluge({
+			...options,
+			timeout: environment.TORRENT_CLIENT_TIMEOUT,
+		})
 	}
 
 	public async addTorrent(

src/torrent/clients/qbittorrent.controller.ts

@@ -22,7 +22,10 @@ export class qBittorrentController implements ITorrentController {
 		username: string
 		password: string
 	}) {
-		this.client = new QBittorrent(options)
+		this.client = new QBittorrent({
+			...options,
+			timeout: environment.TORRENT_CLIENT_TIMEOUT,
+		})
 	}
 
 	public async addTorrent(