aboutsummaryrefslogtreecommitdiff
path: root/MediaBrowser.Api/ScheduledTasks/ScheduledTasksWebSocketListener.cs
diff options
context:
space:
mode:
authorWWWesten <4700006+WWWesten@users.noreply.github.com>2021-11-01 23:43:29 +0500
committerGitHub <noreply@github.com>2021-11-01 23:43:29 +0500
commit0a14279e2a21bcb9654a06a2d49e1e4f0cc5329c (patch)
treee1b1bd603b011ca98e5793e356326bf4a35a7050 /MediaBrowser.Api/ScheduledTasks/ScheduledTasksWebSocketListener.cs
parentf2817fef743eeb75a00782ceea363b2d3e7dc9f2 (diff)
parent76eeb8f655424d295e73ced8349c6fefee6ddb12 (diff)
Merge branch 'jellyfin:master' into master
Diffstat (limited to 'MediaBrowser.Api/ScheduledTasks/ScheduledTasksWebSocketListener.cs')
-rw-r--r--MediaBrowser.Api/ScheduledTasks/ScheduledTasksWebSocketListener.cs79
1 files changed, 0 insertions, 79 deletions
diff --git a/MediaBrowser.Api/ScheduledTasks/ScheduledTasksWebSocketListener.cs b/MediaBrowser.Api/ScheduledTasks/ScheduledTasksWebSocketListener.cs
deleted file mode 100644
index b0c4b29c1..000000000
--- a/MediaBrowser.Api/ScheduledTasks/ScheduledTasksWebSocketListener.cs
+++ /dev/null
@@ -1,79 +0,0 @@
-using System.Collections.Generic;
-using System.Linq;
-using System.Threading;
-using System.Threading.Tasks;
-using MediaBrowser.Controller.Net;
-using MediaBrowser.Model.Events;
-using MediaBrowser.Model.Tasks;
-using Microsoft.Extensions.Logging;
-
-namespace MediaBrowser.Api.ScheduledTasks
-{
- /// <summary>
- /// Class ScheduledTasksWebSocketListener
- /// </summary>
- public class ScheduledTasksWebSocketListener : BasePeriodicWebSocketListener<IEnumerable<TaskInfo>, WebSocketListenerState>
- {
- /// <summary>
- /// Gets or sets the task manager.
- /// </summary>
- /// <value>The task manager.</value>
- private ITaskManager TaskManager { get; set; }
-
- /// <summary>
- /// Gets the name.
- /// </summary>
- /// <value>The name.</value>
- protected override string Name => "ScheduledTasksInfo";
-
- /// <summary>
- /// Initializes a new instance of the <see cref="ScheduledTasksWebSocketListener" /> class.
- /// </summary>
- public ScheduledTasksWebSocketListener(ILogger logger, ITaskManager taskManager)
- : base(logger)
- {
- TaskManager = taskManager;
-
- TaskManager.TaskExecuting += TaskManager_TaskExecuting;
- TaskManager.TaskCompleted += TaskManager_TaskCompleted;
- }
-
- void TaskManager_TaskCompleted(object sender, TaskCompletionEventArgs e)
- {
- SendData(true);
- e.Task.TaskProgress -= Argument_TaskProgress;
- }
-
- void TaskManager_TaskExecuting(object sender, GenericEventArgs<IScheduledTaskWorker> e)
- {
- SendData(true);
- e.Argument.TaskProgress += Argument_TaskProgress;
- }
-
- void Argument_TaskProgress(object sender, GenericEventArgs<double> e)
- {
- SendData(false);
- }
-
- /// <summary>
- /// Gets the data to send.
- /// </summary>
- /// <param name="state">The state.</param>
- /// <returns>Task{IEnumerable{TaskInfo}}.</returns>
- protected override Task<IEnumerable<TaskInfo>> GetDataToSend(WebSocketListenerState state, CancellationToken cancellationToken)
- {
- return Task.FromResult(TaskManager.ScheduledTasks
- .OrderBy(i => i.Name)
- .Select(ScheduledTaskHelpers.GetTaskInfo)
- .Where(i => !i.IsHidden));
- }
-
- protected override void Dispose(bool dispose)
- {
- TaskManager.TaskExecuting -= TaskManager_TaskExecuting;
- TaskManager.TaskCompleted -= TaskManager_TaskCompleted;
-
- base.Dispose(dispose);
- }
- }
-}