feat(api): Max conns can be configured through env

Author: TriPSs

apps/api/src/shared/config/config.service.ts

@@ -20,6 +20,7 @@ export class ConfigService {
   public static readonly OPENSUBTITLES_PASSWORD: string = 'OPENSUBTITLES_PASSWORD'
   public static readonly SUBTITLES_LANGUAGES: string = 'SUBTITLES_LANGUAGES'
   public static readonly MAX_CONCURRENT_DOWNLOADS: string = 'MAX_CONCURRENT_DOWNLOADS'
+  public static readonly MAX_CONNS: string = 'MAX_CONNS'
   public static readonly TRAKT_KEY: string = 'TRAKT_KEY'
 
   private readonly envConfig: { [key: string]: string }
@@ -111,6 +112,9 @@ export class ConfigService {
 
       [ConfigService.MAX_CONCURRENT_DOWNLOADS]: Joi.number()
         .default(1),
+
+      [ConfigService.MAX_CONNS]: Joi.number()
+        .default(35),
     })
 
     const { error, value: validatedEnvConfig } = envVarsSchema.validate(envConfig, { stripUnknown: true })

apps/api/src/shared/torrent/torrent.service.ts

@@ -33,6 +33,11 @@ export class TorrentService implements OnApplicationBootstrap {
    */
   private readonly maxConcurrent
 
+  /**
+   * Maximum of concurrent connections
+   */
+  private readonly maxConns
+
   /**
    * All the different supported formats
    */
@@ -93,6 +98,7 @@ export class TorrentService implements OnApplicationBootstrap {
     private readonly episodesService: EpisodesService
   ) {
     this.maxConcurrent = this.configService.get(ConfigService.MAX_CONCURRENT_DOWNLOADS)
+    this.maxConns = this.configService.get(ConfigService.MAX_CONNS)
   }
 
   /**
@@ -117,7 +123,7 @@ export class TorrentService implements OnApplicationBootstrap {
     this.logger.log('Creating new WebTorrent client')
 
     this.webTorrent = new WebTorrent({
-      maxConns: 35
+      maxConns: this.maxConns
     })
 
     this.webTorrent.on('error', (err) => {