Fix silly error.

giorgi1324 · Nov 14, 2024 · 95c3b28 · 95c3b28
1 parent 06d0281
commit 95c3b28
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/src/producer/src/Features/Crawlers/Dmm/DebridMediaManagerCrawler.cs b/src/producer/src/Features/Crawlers/Dmm/DebridMediaManagerCrawler.cs
@@ -106,11 +106,10 @@ await Parallel.ForEachAsync(batchProcessables.Select(t => t.InfoHash), options,
 
         var decodedJson = LZString.DecompressFromEncodedURIComponent(encodedJson.Value);
 
-        List<ExtractedDMMContent?> torrents = new();
+        JsonElement arrayToProcess;
         try
         {
             var json = JsonDocument.Parse(decodedJson);
-            JsonElement arrayToProcess;
 
             if (json.RootElement.ValueKind == JsonValueKind.Object &&
                 json.RootElement.TryGetProperty("torrents", out var torrentsProperty) &&
@@ -125,7 +124,7 @@ await Parallel.ForEachAsync(batchProcessables.Select(t => t.InfoHash), options,
             else
             {
                 logger.LogWarning("Unexpected JSON format in {Name}", name);
-                return null;
+                return [];
             }
         }
         catch (Exception ex)
@@ -134,6 +133,12 @@ await Parallel.ForEachAsync(batchProcessables.Select(t => t.InfoHash), options,
             return [];
         }
 
+        var torrents = await arrayToProcess.EnumerateArray()
+            .ToAsyncEnumerable()
+            .Select(ParsePageContent)
+            .Where(t => t is not null)
+            .ToListAsync();
+
         if (torrents.Count == 0)
         {
             logger.LogWarning("No torrents found in {Name}", name);