feat(graphql-api): Update every 0,5 seconds

Author: TriPSs

apps/graphql-api/src/shared/search/adapters/1337x.search-adapter.ts

@@ -23,7 +23,11 @@ export class OneThreeThreeSevenXSearchAdapater extends SearchAdapter {
     'SeekNDstroy',
     'Cristie',
     'mazemaze16',
-    'TeamRocker'
+    'TeamRocker',
+    'YIFY',
+    'PMEDIA',
+    'bone111',
+    'Silmarillion'
   ]
   /**
    * Search for a episode
@@ -39,13 +43,13 @@ export class OneThreeThreeSevenXSearchAdapater extends SearchAdapter {
         category: 'TV'
       })
 
+      // Get all the torrents from trusted uploaders and validate if the
+      // season and episode format is in the torrent
       const foundTorrents = torrents.filter((torrent) =>
         this.trustedUploaders.includes(torrent.uploader) &&
         torrent.title.toUpperCase().includes(this.buildSeasonEpisodeString(episode).toUpperCase())
       )
 
-      console.log(torrents)
-
       const results = await Promise.all(
         foundTorrents.map((torrent) => this.formatTorrent(torrent, domain))
       )

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

@@ -365,10 +365,7 @@ export class TorrentService {
       this.removeFromTorrents(download, true)
 
       let searchedSubs = false
-      let lastUpdate = {
-        progress: null,
-        numPeers: null
-      }
+      let lastUpdate = null
 
       // Keep track if we updated the episode of movie with the new status
       let updatedItem = false
@@ -429,17 +426,12 @@ export class TorrentService {
           this.subtitlesService.searchForSubtitles(download, file)
         }
 
-        // Only update every 0.5 %
-        if (lastUpdate.progress === null
-          || (lastUpdate.progress + 0.5) < newProgress
-          || lastUpdate.numPeers !== torrent.numPeers
-        ) {
+        const now = Date.now()
+        // Only update 0,5 seconds
+        if (lastUpdate === null || (lastUpdate + 5000) < now) {
           this.logger.debug(`[${download._id}]: Progress ${newProgress.toFixed(1)}% at ${formatKbToString(torrent.downloadSpeed)}`)
 
-          lastUpdate = {
-            progress: newProgress,
-            numPeers: torrent.numPeers
-          }
+          lastUpdate = now
 
           // Don't update if we are already updating
           if (!updatingModel) {