New: Only sync indexers with matching app tags

Prowlarr · May 11, 2022 · af50a1d · af50a1d
1 parent 1a71375
commit af50a1d
Showing 1 changed file with 25 additions and 3 deletions.
diff --git a/src/NzbDrone.Core/Applications/ApplicationService.cs b/src/NzbDrone.Core/Applications/ApplicationService.cs
@@ -9,6 +9,7 @@
 using NzbDrone.Core.Indexers;
 using NzbDrone.Core.Messaging.Commands;
 using NzbDrone.Core.Messaging.Events;
+using NzbDrone.Core.ThingiProvider;
 using NzbDrone.Core.ThingiProvider.Events;
 
 namespace NzbDrone.Core.Applications
@@ -69,7 +70,10 @@ public void HandleAsync(ProviderAddedEvent<IIndexer> message)
 
             foreach (var app in enabledApps)
             {
-                ExecuteAction(a => a.AddIndexer((IndexerDefinition)message.Definition), app);
+                if (ShouldHandleIndexer(app.Definition, message.Definition))
+                {
+                    ExecuteAction(a => a.AddIndexer((IndexerDefinition)message.Definition), app);
+                }
             }
         }
 
@@ -157,14 +161,14 @@ private void SyncIndexers(List<IApplication> applications, List<IndexerDefinitio
 
                     if (indexerMappings.Any(x => x.IndexerId == definition.Id))
                     {
-                        if (((ApplicationDefinition)app.Definition).SyncLevel == ApplicationSyncLevel.FullSync)
+                        if (((ApplicationDefinition)app.Definition).SyncLevel == ApplicationSyncLevel.FullSync && ShouldHandleIndexer(app.Definition, indexer))
                         {
                             ExecuteAction(a => a.UpdateIndexer(definition), app);
                         }
                     }
                     else
                     {
-                        if (indexer.Enable)
+                        if (indexer.Enable && ShouldHandleIndexer(app.Definition, indexer))
                         {
                             ExecuteAction(a => a.AddIndexer(definition), app);
                         }
@@ -187,6 +191,24 @@ private void SyncIndexers(List<IApplication> applications, List<IndexerDefinitio
             }
         }
 
+        private bool ShouldHandleIndexer(ProviderDefinition app, ProviderDefinition indexer)
+        {
+            if (app.Tags.Empty())
+            {
+                _logger.Debug("No tags set for this application.");
+                return true;
+            }
+
+            if (app.Tags.Intersect(indexer.Tags).Any())
+            {
+                _logger.Debug("Application and indexer have one or more intersecting tags.");
+                return true;
+            }
+
+            _logger.Debug("{0} does not have any intersecting tags with {1}. Indexer will not be synced", app.Name, indexer.Name);
+            return false;
+        }
+
         private void ExecuteAction(Action<IApplication> applicationAction, IApplication application)
         {
             try