Fixed: Refresh tags after updating autotags

pull/10409/head
Bogdan 4 months ago
parent f3ce0ac620
commit e688dfadf7

@ -2,6 +2,7 @@ using System.Collections.Generic;
using System.Linq; using System.Linq;
using NzbDrone.Common.Cache; using NzbDrone.Common.Cache;
using NzbDrone.Common.Extensions; using NzbDrone.Common.Extensions;
using NzbDrone.Core.Messaging.Events;
using NzbDrone.Core.Movies; using NzbDrone.Core.Movies;
using NzbDrone.Core.RootFolders; using NzbDrone.Core.RootFolders;
@ -22,14 +23,18 @@ namespace NzbDrone.Core.AutoTagging
{ {
private readonly IAutoTaggingRepository _repository; private readonly IAutoTaggingRepository _repository;
private readonly RootFolderService _rootFolderService; private readonly RootFolderService _rootFolderService;
private readonly IEventAggregator _eventAggregator;
private readonly ICached<Dictionary<int, AutoTag>> _cache; private readonly ICached<Dictionary<int, AutoTag>> _cache;
public AutoTaggingService(IAutoTaggingRepository repository, public AutoTaggingService(IAutoTaggingRepository repository,
RootFolderService rootFolderService, RootFolderService rootFolderService,
IEventAggregator eventAggregator,
ICacheManager cacheManager) ICacheManager cacheManager)
{ {
_repository = repository; _repository = repository;
_rootFolderService = rootFolderService; _rootFolderService = rootFolderService;
_eventAggregator = eventAggregator;
_cache = cacheManager.GetCache<Dictionary<int, AutoTag>>(typeof(AutoTag), "autoTags"); _cache = cacheManager.GetCache<Dictionary<int, AutoTag>>(typeof(AutoTag), "autoTags");
} }
@ -51,13 +56,17 @@ namespace NzbDrone.Core.AutoTagging
public void Update(AutoTag autoTag) public void Update(AutoTag autoTag)
{ {
_repository.Update(autoTag); _repository.Update(autoTag);
_cache.Clear(); _cache.Clear();
_eventAggregator.PublishEvent(new AutoTagsUpdatedEvent());
} }
public AutoTag Insert(AutoTag autoTag) public AutoTag Insert(AutoTag autoTag)
{ {
var result = _repository.Insert(autoTag); var result = _repository.Insert(autoTag);
_cache.Clear(); _cache.Clear();
_eventAggregator.PublishEvent(new AutoTagsUpdatedEvent());
return result; return result;
} }
@ -65,7 +74,9 @@ namespace NzbDrone.Core.AutoTagging
public void Delete(int id) public void Delete(int id)
{ {
_repository.Delete(id); _repository.Delete(id);
_cache.Clear(); _cache.Clear();
_eventAggregator.PublishEvent(new AutoTagsUpdatedEvent());
} }
public List<AutoTag> AllForTag(int tagId) public List<AutoTag> AllForTag(int tagId)

@ -0,0 +1,8 @@
using NzbDrone.Common.Messaging;
namespace NzbDrone.Core.AutoTagging
{
public class AutoTagsUpdatedEvent : IEvent
{
}
}

@ -1,5 +1,6 @@
using System.Collections.Generic; using System.Collections.Generic;
using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Mvc;
using NzbDrone.Core.AutoTagging;
using NzbDrone.Core.Datastore.Events; using NzbDrone.Core.Datastore.Events;
using NzbDrone.Core.Messaging.Events; using NzbDrone.Core.Messaging.Events;
using NzbDrone.Core.Tags; using NzbDrone.Core.Tags;
@ -11,7 +12,9 @@ using Radarr.Http.REST.Attributes;
namespace Radarr.Api.V3.Tags namespace Radarr.Api.V3.Tags
{ {
[V3ApiController] [V3ApiController]
public class TagController : RestControllerWithSignalR<TagResource, Tag>, IHandle<TagsUpdatedEvent> public class TagController : RestControllerWithSignalR<TagResource, Tag>,
IHandle<TagsUpdatedEvent>,
IHandle<AutoTagsUpdatedEvent>
{ {
private readonly ITagService _tagService; private readonly ITagService _tagService;
@ -59,5 +62,11 @@ namespace Radarr.Api.V3.Tags
{ {
BroadcastResourceChange(ModelAction.Sync); BroadcastResourceChange(ModelAction.Sync);
} }
[NonAction]
public void Handle(AutoTagsUpdatedEvent message)
{
BroadcastResourceChange(ModelAction.Sync);
}
} }
} }

Loading…
Cancel
Save