aboutsummaryrefslogtreecommitdiff
path: root/Jellyfin.Api/WebSocketListeners/ScheduledTasksWebSocketListener.cs
diff options
context:
space:
mode:
Diffstat (limited to 'Jellyfin.Api/WebSocketListeners/ScheduledTasksWebSocketListener.cs')
-rw-r--r--Jellyfin.Api/WebSocketListeners/ScheduledTasksWebSocketListener.cs117
1 files changed, 58 insertions, 59 deletions
diff --git a/Jellyfin.Api/WebSocketListeners/ScheduledTasksWebSocketListener.cs b/Jellyfin.Api/WebSocketListeners/ScheduledTasksWebSocketListener.cs
index 7c6ce3273..a9df2d671 100644
--- a/Jellyfin.Api/WebSocketListeners/ScheduledTasksWebSocketListener.cs
+++ b/Jellyfin.Api/WebSocketListeners/ScheduledTasksWebSocketListener.cs
@@ -7,78 +7,77 @@ using MediaBrowser.Model.Session;
using MediaBrowser.Model.Tasks;
using Microsoft.Extensions.Logging;
-namespace Jellyfin.Api.WebSocketListeners
+namespace Jellyfin.Api.WebSocketListeners;
+
+/// <summary>
+/// Class ScheduledTasksWebSocketListener.
+/// </summary>
+public class ScheduledTasksWebSocketListener : BasePeriodicWebSocketListener<IEnumerable<TaskInfo>, WebSocketListenerState>
{
/// <summary>
- /// Class ScheduledTasksWebSocketListener.
+ /// Gets or sets the task manager.
/// </summary>
- public class ScheduledTasksWebSocketListener : BasePeriodicWebSocketListener<IEnumerable<TaskInfo>, WebSocketListenerState>
- {
- /// <summary>
- /// Gets or sets the task manager.
- /// </summary>
- /// <value>The task manager.</value>
- private readonly ITaskManager _taskManager;
+ /// <value>The task manager.</value>
+ private readonly ITaskManager _taskManager;
- /// <summary>
- /// Initializes a new instance of the <see cref="ScheduledTasksWebSocketListener"/> class.
- /// </summary>
- /// <param name="logger">Instance of the <see cref="ILogger{ScheduledTasksWebSocketListener}"/> interface.</param>
- /// <param name="taskManager">Instance of the <see cref="ITaskManager"/> interface.</param>
- public ScheduledTasksWebSocketListener(ILogger<ScheduledTasksWebSocketListener> logger, ITaskManager taskManager)
- : base(logger)
- {
- _taskManager = taskManager;
+ /// <summary>
+ /// Initializes a new instance of the <see cref="ScheduledTasksWebSocketListener"/> class.
+ /// </summary>
+ /// <param name="logger">Instance of the <see cref="ILogger{ScheduledTasksWebSocketListener}"/> interface.</param>
+ /// <param name="taskManager">Instance of the <see cref="ITaskManager"/> interface.</param>
+ public ScheduledTasksWebSocketListener(ILogger<ScheduledTasksWebSocketListener> logger, ITaskManager taskManager)
+ : base(logger)
+ {
+ _taskManager = taskManager;
- _taskManager.TaskExecuting += OnTaskExecuting;
- _taskManager.TaskCompleted += OnTaskCompleted;
- }
+ _taskManager.TaskExecuting += OnTaskExecuting;
+ _taskManager.TaskCompleted += OnTaskCompleted;
+ }
- /// <inheritdoc />
- protected override SessionMessageType Type => SessionMessageType.ScheduledTasksInfo;
+ /// <inheritdoc />
+ protected override SessionMessageType Type => SessionMessageType.ScheduledTasksInfo;
- /// <inheritdoc />
- protected override SessionMessageType StartType => SessionMessageType.ScheduledTasksInfoStart;
+ /// <inheritdoc />
+ protected override SessionMessageType StartType => SessionMessageType.ScheduledTasksInfoStart;
- /// <inheritdoc />
- protected override SessionMessageType StopType => SessionMessageType.ScheduledTasksInfoStop;
+ /// <inheritdoc />
+ protected override SessionMessageType StopType => SessionMessageType.ScheduledTasksInfoStop;
- /// <summary>
- /// Gets the data to send.
- /// </summary>
- /// <returns>Task{IEnumerable{TaskInfo}}.</returns>
- protected override Task<IEnumerable<TaskInfo>> GetDataToSend()
- {
- return Task.FromResult(_taskManager.ScheduledTasks
- .OrderBy(i => i.Name)
- .Select(ScheduledTaskHelpers.GetTaskInfo)
- .Where(i => !i.IsHidden));
- }
+ /// <summary>
+ /// Gets the data to send.
+ /// </summary>
+ /// <returns>Task{IEnumerable{TaskInfo}}.</returns>
+ protected override Task<IEnumerable<TaskInfo>> GetDataToSend()
+ {
+ return Task.FromResult(_taskManager.ScheduledTasks
+ .OrderBy(i => i.Name)
+ .Select(ScheduledTaskHelpers.GetTaskInfo)
+ .Where(i => !i.IsHidden));
+ }
- /// <inheritdoc />
- protected override void Dispose(bool dispose)
- {
- _taskManager.TaskExecuting -= OnTaskExecuting;
- _taskManager.TaskCompleted -= OnTaskCompleted;
+ /// <inheritdoc />
+ protected override void Dispose(bool dispose)
+ {
+ _taskManager.TaskExecuting -= OnTaskExecuting;
+ _taskManager.TaskCompleted -= OnTaskCompleted;
- base.Dispose(dispose);
- }
+ base.Dispose(dispose);
+ }
- private async void OnTaskCompleted(object? sender, TaskCompletionEventArgs e)
- {
- e.Task.TaskProgress -= OnTaskProgress;
- await SendData(true).ConfigureAwait(false);
- }
+ private async void OnTaskCompleted(object? sender, TaskCompletionEventArgs e)
+ {
+ e.Task.TaskProgress -= OnTaskProgress;
+ await SendData(true).ConfigureAwait(false);
+ }
- private async void OnTaskExecuting(object? sender, GenericEventArgs<IScheduledTaskWorker> e)
- {
- await SendData(true).ConfigureAwait(false);
- e.Argument.TaskProgress += OnTaskProgress;
- }
+ private async void OnTaskExecuting(object? sender, GenericEventArgs<IScheduledTaskWorker> e)
+ {
+ await SendData(true).ConfigureAwait(false);
+ e.Argument.TaskProgress += OnTaskProgress;
+ }
- private async void OnTaskProgress(object? sender, GenericEventArgs<double> e)
- {
- await SendData(false).ConfigureAwait(false);
- }
+ private async void OnTaskProgress(object? sender, GenericEventArgs<double> e)
+ {
+ await SendData(false).ConfigureAwait(false);
}
}