New: Backend changes for new UI

2026-04-20 21:55:03 -04:00 · 2018-11-23 02:03:32 -05:00
parent e9eebd3ce6
commit 65efa15551
485 changed files with 11177 additions and 2233 deletions
@@ -0,0 +1,79 @@
+using NzbDrone.Core.Datastore;
+using NzbDrone.Core.Datastore.Events;
+using NzbDrone.Core.Messaging.Events;
+using NzbDrone.SignalR;
+using Radarr.Http.REST;
+
+namespace Radarr.Http
+{
+    public abstract class RadarrRestModuleWithSignalR<TResource, TModel> : RadarrRestModule<TResource>, IHandle<ModelEvent<TModel>>
+        where TResource : RestResource, new()
+        where TModel : ModelBase, new()
+    {
+        private readonly IBroadcastSignalRMessage _signalRBroadcaster;
+
+        protected RadarrRestModuleWithSignalR(IBroadcastSignalRMessage signalRBroadcaster)
+        {
+            _signalRBroadcaster = signalRBroadcaster;
+        }
+
+        protected RadarrRestModuleWithSignalR(IBroadcastSignalRMessage signalRBroadcaster, string resource)
+            : base(resource)
+        {
+            _signalRBroadcaster = signalRBroadcaster;
+        }
+
+        public void Handle(ModelEvent<TModel> message)
+        {
+            if (message.Action == ModelAction.Deleted || message.Action == ModelAction.Sync)
+            {
+                BroadcastResourceChange(message.Action);
+            }
+
+            BroadcastResourceChange(message.Action, message.Model.Id);
+        }
+
+        protected void BroadcastResourceChange(ModelAction action, int id)
+        {
+            if (action == ModelAction.Deleted)
+            {
+                BroadcastResourceChange(action, new TResource {Id = id});
+            }
+            else
+            {
+                var resource = GetResourceById(id);
+                BroadcastResourceChange(action, resource);
+            }
+        }
+
+        protected void BroadcastResourceChange(ModelAction action, TResource resource)
+        {
+            if (GetType().Namespace.Contains("V2"))
+            {
+                var signalRMessage = new SignalRMessage
+                                     {
+                                         Name = Resource,
+                                         Body = new ResourceChangeMessage<TResource>(resource, action),
+                                         Action = action
+                                     };
+
+                _signalRBroadcaster.BroadcastMessage(signalRMessage);
+            }
+        }
+     
+        protected void BroadcastResourceChange(ModelAction action)
+        {
+            if (GetType().Namespace.Contains("V2"))
+            {
+                var signalRMessage = new SignalRMessage
+                                     {
+                                         Name = Resource,
+                                         Body = new ResourceChangeMessage<TResource>(action),
+                                         Action = action
+                                     };
+
+                _signalRBroadcaster.BroadcastMessage(signalRMessage);
+            }
+        }
+    }
+}