diff --git a/Shokofin/SignalR/Interfaces/IFileMatchedEventArgs.cs b/Shokofin/SignalR/Interfaces/IFileMatchedEventArgs.cs
new file mode 100644
index 00000000..d008802e
--- /dev/null
+++ b/Shokofin/SignalR/Interfaces/IFileMatchedEventArgs.cs
@@ -0,0 +1,49 @@
+using System.Collections.Generic;
+using System.Text.Json.Serialization;
+
+namespace Shokofin.SignalR.Interfaces;
+
+public interface IFileEventArgs
+{
+    /// <summary>
+    /// Shoko file id.
+    /// </summary>
+    int FileId { get; }
+
+    /// <summary>
+    /// The ID of the new import folder the event was detected in.
+    /// </summary>
+    /// <value></value>
+    int ImportFolderId { get; }
+
+    /// <summary>
+    /// The relative path of the new file from the import folder base location.
+    /// </summary>
+    string RelativePath { get; }
+
+    /// <summary>
+    /// Cross references of episodes linked to this file.
+    /// </summary>
+    List<FileCrossReference> CrossReferences { get; }
+
+    public class FileCrossReference
+    {
+        /// <summary>
+        /// Shoko episode id.
+        /// </summary>
+        [JsonPropertyName("EpisodeID")]
+        public int EpisodeId { get; set; }
+
+        /// <summary>
+        /// Shoko series id.
+        /// </summary>
+        [JsonPropertyName("SeriesID")]
+        public int SeriesId { get; set; }
+
+        /// <summary>
+        /// Shoko group id.
+        /// </summary>
+        [JsonPropertyName("GroupID")]
+        public int GroupId { get; set; }
+    }
+}
\ No newline at end of file
diff --git a/Shokofin/SignalR/Models/EpisodeInfoUpdatedEventArgs.cs b/Shokofin/SignalR/Models/EpisodeInfoUpdatedEventArgs.cs
index 43fccb8b..fb13d620 100644
--- a/Shokofin/SignalR/Models/EpisodeInfoUpdatedEventArgs.cs
+++ b/Shokofin/SignalR/Models/EpisodeInfoUpdatedEventArgs.cs
@@ -1,3 +1,4 @@
+using System.Collections.Generic;
 using System.Text.Json.Serialization;
 
 namespace Shokofin.SignalR.Models;
@@ -5,20 +6,42 @@ namespace Shokofin.SignalR.Models;
 public class EpisodeInfoUpdatedEventArgs
 {
     /// <summary>
-    /// Shoko episode id.
+    /// The update reason.
+    /// </summary>
+    public UpdateReason Reason { get; set; }
+    /// <summary>
+    /// The provider metadata source.
+    /// </summary>
+    [JsonPropertyName("Source")]
+    public string ProviderName { get; set; } = string.Empty;
+
+    /// <summary>
+    /// The provided metadata episode id.
     /// </summary>
     [JsonPropertyName("EpisodeID")]
-    public int EpisodeId { get; set; }
+    public int ProviderId { get; set; }
 
     /// <summary>
-    /// Shoko series id.
+    /// The provided metadata series id.
     /// </summary>
     [JsonPropertyName("SeriesID")]
-    public int SeriesId { get; set; }
+    public int ProviderSeriesId { get; set; }
+
+    /// <summary>
+    /// Shoko episode ids affected by this update.
+    /// </summary>
+    [JsonPropertyName("ShokoEpisodeIDs")]
+    public List<int> EpisodeIds { get; set; } = new();
+
+    /// <summary>
+    /// Shoko series ids affected by this update.
+    /// </summary>
+    [JsonPropertyName("ShokoSeriesIDs")]
+    public List<int> SeriesIds { get; set; } = new();
 
     /// <summary>
-    /// Shoko group id.
+    /// Shoko group ids affected by this update.
     /// </summary>
-    [JsonPropertyName("GroupID")]
-    public int GroupId { get; set; }
+    [JsonPropertyName("ShokoGroupIDs")]
+    public List<int> GroupIds { get; set; } = new();
 }
\ No newline at end of file
diff --git a/Shokofin/SignalR/Models/FileEventArgs.cs b/Shokofin/SignalR/Models/FileEventArgs.cs
index 5a4e69a1..1968d4e4 100644
--- a/Shokofin/SignalR/Models/FileEventArgs.cs
+++ b/Shokofin/SignalR/Models/FileEventArgs.cs
@@ -1,8 +1,10 @@
+using System.Collections.Generic;
 using System.Text.Json.Serialization;
+using Shokofin.SignalR.Interfaces;
 
 namespace Shokofin.SignalR.Models;
 
-public class FileEventArgs
+public class FileEventArgs : IFileEventArgs
 {
     /// <summary>
     /// Shoko file id.
@@ -22,4 +24,9 @@ public class FileEventArgs
     /// </summary>
     [JsonPropertyName("RelativePath")]
     public string RelativePath  { get; set; } = string.Empty;
+
+    /// <summary>
+    /// Cross references of episodes linked to this file.
+    /// </summary>
+    public List<IFileEventArgs.FileCrossReference> CrossReferences { get; set; } = new();
 }
diff --git a/Shokofin/SignalR/Models/FileMatchedEventArgs.cs b/Shokofin/SignalR/Models/FileMatchedEventArgs.cs
index f1067c66..efe4ade0 100644
--- a/Shokofin/SignalR/Models/FileMatchedEventArgs.cs
+++ b/Shokofin/SignalR/Models/FileMatchedEventArgs.cs
@@ -1,34 +1,33 @@
 using System.Collections.Generic;
 using System.Text.Json.Serialization;
+using Shokofin.SignalR.Interfaces;
 
 namespace Shokofin.SignalR.Models;
 
-public class FileMatchedEventArgs : FileEventArgs
+public class FileMatchedEventArgsV1 : IFileEventArgs
 {
     /// <summary>
-    /// Cross references of episodes linked to this file.
+    /// Shoko file id.
     /// </summary>
-    [JsonPropertyName("CrossRefs")]
-    public List<FileCrossReference> CrossReferences { get; set; } = new();
+    [JsonPropertyName("FileID")]
+    public int FileId { get; set; }
 
-    public class FileCrossReference
-    {
-        /// <summary>
-        /// Shoko episode id.
-        /// </summary>
-        [JsonPropertyName("EpisodeID")]
-        public int EpisodeId { get; set; }
+    /// <summary>
+    /// The ID of the import folder the event was detected in.
+    /// </summary>
+    /// <value></value>
+    [JsonPropertyName("ImportFolderID")]
+    public int ImportFolderId { get; set; }
 
-        /// <summary>
-        /// Shoko series id.
-        /// </summary>
-        [JsonPropertyName("SeriesID")]
-        public int SeriesId { get; set; }
+    /// <summary>
+    /// The relative path of the file from the import folder base location.
+    /// </summary>
+    [JsonPropertyName("RelativePath")]
+    public string RelativePath  { get; set; } = string.Empty;
 
-        /// <summary>
-        /// Shoko group id.
-        /// </summary>
-        [JsonPropertyName("GroupID")]
-        public int GroupId { get; set; }
-    }
+    /// <summary>
+    /// Cross references of episodes linked to this file.
+    /// </summary>
+    [JsonPropertyName("CrossRefs")]
+    public List<IFileEventArgs.FileCrossReference> CrossReferences { get; set; } = new();
 }
\ No newline at end of file
diff --git a/Shokofin/SignalR/Models/FileMovedEventArgs.cs b/Shokofin/SignalR/Models/FileMovedEventArgs.cs
index b1247725..c54ee78a 100644
--- a/Shokofin/SignalR/Models/FileMovedEventArgs.cs
+++ b/Shokofin/SignalR/Models/FileMovedEventArgs.cs
@@ -3,7 +3,7 @@
 
 namespace Shokofin.SignalR.Models;
 
-public class FileMovedEventArgs : IFileRelocationEventArgs
+public class FileMovedEventArgsV1 : IFileRelocationEventArgs
 {
     /// <summary>
     /// Shoko file id.
@@ -37,3 +37,18 @@ public class FileMovedEventArgs : IFileRelocationEventArgs
     [JsonPropertyName("OldRelativePath")]
     public string PreviousRelativePath { get; set; } = string.Empty;
 }
+
+public class FileMovedEventArgs: FileEventArgs, IFileRelocationEventArgs
+{
+    /// <summary>
+    /// The ID of the old import folder the event was detected in.
+    /// </summary>
+    /// <value></value>
+    [JsonPropertyName("PreviousImportFolderID")]
+    public int PreviousImportFolderId { get; set; }
+
+    /// <summary>
+    /// The relative path of the old file from the import folder base location.
+    /// </summary>
+    public string PreviousRelativePath { get; set; } = string.Empty;
+}
diff --git a/Shokofin/SignalR/Models/FileRenamedEventArgs.cs b/Shokofin/SignalR/Models/FileRenamedEventArgs.cs
index 9db248f6..997a08d2 100644
--- a/Shokofin/SignalR/Models/FileRenamedEventArgs.cs
+++ b/Shokofin/SignalR/Models/FileRenamedEventArgs.cs
@@ -3,8 +3,27 @@
 
 namespace Shokofin.SignalR.Models;
 
-public class FileRenamedEventArgs : FileEventArgs, IFileRelocationEventArgs
+public class FileRenamedEventArgsV1 : IFileRelocationEventArgs
 {
+    /// <summary>
+    /// Shoko file id.
+    /// </summary>
+    [JsonPropertyName("FileID")]
+    public int FileId { get; set; }
+
+    /// <summary>
+    /// The ID of the import folder the event was detected in.
+    /// </summary>
+    /// <value></value>
+    [JsonPropertyName("ImportFolderID")]
+    public int ImportFolderId { get; set; }
+
+    /// <summary>
+    /// The relative path of the file from the import folder base location.
+    /// </summary>
+    [JsonPropertyName("RelativePath")]
+    public string RelativePath  { get; set; } = string.Empty;
+
     /// <summary>
     /// The new File name.
     /// </summary>
@@ -17,10 +36,29 @@ public class FileRenamedEventArgs : FileEventArgs, IFileRelocationEventArgs
     [JsonPropertyName("OldFileName")]
     public string PreviousFileName  { get; set; } = string.Empty;
 
-    public int PreviousImportFolderId { get; set; }
+
+    /// <inheritdoc/>
+    public int PreviousImportFolderId => ImportFolderId;
+
+    /// <inheritdoc/>
+    public string PreviousRelativePath => RelativePath[^FileName.Length] + PreviousFileName;
+}
+
+public class FileRenamedEventArgs : FileEventArgs, IFileRelocationEventArgs
+{
+    /// <summary>
+    /// The new File name.
+    /// </summary>
+    public string FileName  { get; set; } = string.Empty;
 
     /// <summary>
-    /// The relative path of the old file from the import folder base location.
+    /// The old file name.
     /// </summary>
+    public string PreviousFileName  { get; set; } = string.Empty;
+
+    /// <inheritdoc/>
+    public int PreviousImportFolderId => ImportFolderId;
+
+    /// <inheritdoc/>
     public string PreviousRelativePath => RelativePath[^FileName.Length] + PreviousFileName;
 }
\ No newline at end of file
diff --git a/Shokofin/SignalR/Models/SeriesInfoUpdatedEventArgs.cs b/Shokofin/SignalR/Models/SeriesInfoUpdatedEventArgs.cs
index 7bab9b68..824d2bc1 100644
--- a/Shokofin/SignalR/Models/SeriesInfoUpdatedEventArgs.cs
+++ b/Shokofin/SignalR/Models/SeriesInfoUpdatedEventArgs.cs
@@ -1,3 +1,4 @@
+using System.Collections.Generic;
 using System.Text.Json.Serialization;
 
 namespace Shokofin.SignalR.Models;
@@ -5,14 +6,31 @@ namespace Shokofin.SignalR.Models;
 public class SeriesInfoUpdatedEventArgs
 {
     /// <summary>
-    /// Shoko series id.
+    /// The update reason.
+    /// </summary>
+    public UpdateReason Reason { get; set; }
+
+    /// <summary>
+    /// The provider metadata source.
+    /// </summary>
+    [JsonPropertyName("Source")]
+    public string ProviderName { get; set; } = string.Empty;
+
+    /// <summary>
+    /// The provided metadata series id.
     /// </summary>
     [JsonPropertyName("SeriesID")]
-    public int SeriesId { get; set; }
+    public int ProviderId { get; set; }
+
+    /// <summary>
+    /// Shoko series ids affected by this update.
+    /// </summary>
+    [JsonPropertyName("ShokoSeriesIDs")]
+    public List<int> SeriesIds { get; set; } = new();
 
     /// <summary>
-    /// Shoko group id.
+    /// Shoko group ids affected by this update.
     /// </summary>
-    [JsonPropertyName("GroupID")]
-    public int GroupId { get; set; }
+    [JsonPropertyName("ShokoGroupIDs")]
+    public List<int> GroupIds { get; set; } = new();
 }
\ No newline at end of file
diff --git a/Shokofin/SignalR/Models/UpdateReason.cs b/Shokofin/SignalR/Models/UpdateReason.cs
new file mode 100644
index 00000000..a3f003e8
--- /dev/null
+++ b/Shokofin/SignalR/Models/UpdateReason.cs
@@ -0,0 +1,13 @@
+
+using System.Text.Json.Serialization;
+
+namespace Shokofin.SignalR.Models;
+
+[JsonConverter(typeof(JsonStringEnumConverter))]
+public enum UpdateReason
+{
+    None = 0,
+    Added = 1,
+    Updated = 2,
+    Removed = 3,
+}
\ No newline at end of file
diff --git a/Shokofin/SignalR/SignalRConnectionManager.cs b/Shokofin/SignalR/SignalRConnectionManager.cs
index 954db286..5676b376 100644
--- a/Shokofin/SignalR/SignalRConnectionManager.cs
+++ b/Shokofin/SignalR/SignalRConnectionManager.cs
@@ -6,6 +6,7 @@
 using Microsoft.AspNetCore.SignalR.Client;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
+using Shokofin.API.Models;
 using Shokofin.Configuration;
 using Shokofin.Resolvers;
 using Shokofin.SignalR.Interfaces;
@@ -15,6 +16,14 @@ namespace Shokofin.SignalR;
 
 public class SignalRConnectionManager : IDisposable
 {
+    private static ComponentVersion? ServerVersion =>
+        Plugin.Instance.Configuration.ServerVersion;
+
+    private static readonly DateTime EventChangedDate = DateTime.Parse("2024-04-01T04:04:00.000Z");
+
+    private static bool UseOlderEvents =>
+        ServerVersion != null && ((ServerVersion.ReleaseChannel == ReleaseChannel.Stable && ServerVersion.Version == "4.2.2.0") || (ServerVersion.ReleaseDate.HasValue && ServerVersion.ReleaseDate.Value < EventChangedDate));
+
     private const string HubUrl = "/signalr/aggregate?feeds=shoko";
 
     private readonly ILogger<SignalRConnectionManager> Logger;
@@ -76,10 +85,18 @@ private async Task ConnectAsync(PluginConfiguration config)
         connection.On<SeriesInfoUpdatedEventArgs>("ShokoEvent:SeriesUpdated", OnSeriesInfoUpdated);
 
         // Attach file events.
-        connection.On<FileMatchedEventArgs>("ShokoEvent:FileMatched", OnFileMatched);
-        connection.On<FileMovedEventArgs>("ShokoEvent:FileMoved", OnFileMoved);
-        connection.On<FileRenamedEventArgs>("ShokoEvent:FileRenamed", OnFileRenamed);
-        connection.On<FileEventArgs>("ShokoEvent:FileDeleted", OnFileDeleted);
+        if (UseOlderEvents) {
+            connection.On<FileMatchedEventArgsV1>("ShokoEvent:FileMatched", OnFileMatched);
+            connection.On<FileMovedEventArgsV1>("ShokoEvent:FileMoved", OnFileRelocated);
+            connection.On<FileRenamedEventArgsV1>("ShokoEvent:FileRenamed", OnFileRelocated);
+            connection.On<FileEventArgs>("ShokoEvent:FileDeleted", OnFileDeleted);
+        }
+        else {
+            connection.On<FileEventArgs>("ShokoEvent:FileMatched", OnFileMatched);
+            connection.On<FileMovedEventArgs>("ShokoEvent:FileMoved", OnFileRelocated);
+            connection.On<FileRenamedEventArgs>("ShokoEvent:FileRenamed", OnFileRelocated);
+            connection.On<FileEventArgs>("ShokoEvent:FileDeleted", OnFileDeleted);
+        }
 
         try {
             await connection.StartAsync().ConfigureAwait(false);
@@ -181,10 +198,10 @@ private static string ConstructKey(PluginConfiguration config)
 
     #region File Events
 
-    private void OnFileMatched(FileMatchedEventArgs eventArgs)
+    private void OnFileMatched(IFileEventArgs eventArgs)
     {
         Logger.LogDebug(
-            "File matched; {ImportFolderIdB} {PathB} (File={FileId})",
+            "File matched; {ImportFolderId} {Path} (File={FileId})",
             eventArgs.ImportFolderId,
             eventArgs.RelativePath,
             eventArgs.FileId
@@ -222,13 +239,7 @@ private void OnFileRelocated(IFileRelocationEventArgs eventArgs)
         // the links broke, and if the newly generated links is not in the list provided by the base items, then remove the broken link.
     }
 
-    private void OnFileMoved(FileMovedEventArgs eventArgs)
-        => OnFileRelocated(eventArgs);
-
-    private void OnFileRenamed(FileRenamedEventArgs eventArgs)
-        => OnFileRelocated(eventArgs);
-
-    private void OnFileDeleted(FileEventArgs eventArgs)
+    private void OnFileDeleted(IFileEventArgs eventArgs)
     {
         Logger.LogDebug(
             "File deleted; {ImportFolderIdB} {PathB} (File={FileId})",
@@ -253,10 +264,14 @@ private void OnFileDeleted(FileEventArgs eventArgs)
     private void OnEpisodeInfoUpdated(EpisodeInfoUpdatedEventArgs eventArgs)
     {
         Logger.LogDebug(
-            "Episode updated. (Episode={EpisodeId},Series={SeriesId},Group={GroupId})",
-            eventArgs.EpisodeId,
-            eventArgs.SeriesId,
-            eventArgs.GroupId
+            "{ProviderName} episode {ProviderId} ({ProviderSeriesId}) dispatched event {UpdateReason}. (Episode={EpisodeId},Series={SeriesId},Group={GroupId})",
+            eventArgs.ProviderName,
+            eventArgs.ProviderId,
+            eventArgs.ProviderSeriesId,
+            eventArgs.Reason,
+            eventArgs.EpisodeIds,
+            eventArgs.SeriesIds,
+            eventArgs.GroupIds
         );
 
         // Refresh all epoisodes and movies linked to the episode.
@@ -265,9 +280,12 @@ private void OnEpisodeInfoUpdated(EpisodeInfoUpdatedEventArgs eventArgs)
     private void OnSeriesInfoUpdated(SeriesInfoUpdatedEventArgs eventArgs)
     {
         Logger.LogDebug(
-            "Series updated. (Series={SeriesId},Group={GroupId})",
-            eventArgs.SeriesId,
-            eventArgs.GroupId
+            "{ProviderName} series {ProviderId} dispatched event {UpdateReason}. (Series={SeriesId},Group={GroupId})",
+            eventArgs.ProviderName,
+            eventArgs.ProviderId,
+            eventArgs.Reason,
+            eventArgs.SeriesIds,
+            eventArgs.GroupIds
         );
 
         // look up the series/season/movie, then check the media folder they're