1 files changed, 176 insertions, 0 deletions
diff --git a/MediaBrowser.Api/ScheduledTasks/ScheduledTaskService.cs b/MediaBrowser.Api/ScheduledTasks/ScheduledTaskService.cs
new file mode 100644
index 000000000..bd12454a0
--- /dev/null
+++ b/MediaBrowser.Api/ScheduledTasks/ScheduledTaskService.cs
@@ -0,0 +1,176 @@
+using MediaBrowser.Common.Extensions;
+using MediaBrowser.Common.Net;
+using MediaBrowser.Common.ScheduledTasks;
+using MediaBrowser.Common.Serialization;
+using MediaBrowser.Model.Tasks;
+using ServiceStack.ServiceHost;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.Composition;
+using System.IO;
+using System.Linq;
+using ServiceStack.Text.Controller;
+
+namespace MediaBrowser.Api.ScheduledTasks
+{
+    /// <summary>
+    /// Class GetScheduledTask
+    /// </summary>
+    [Route("/ScheduledTasks/{Id}", "GET")]
+    public class GetScheduledTask : IReturn<TaskInfo>
+    {
+        /// <summary>
+        /// Gets or sets the id.
+        /// </summary>
+        /// <value>The id.</value>
+        public Guid Id { get; set; }
+    }
+
+    /// <summary>
+    /// Class GetScheduledTasks
+    /// </summary>
+    [Route("/ScheduledTasks", "GET")]
+    public class GetScheduledTasks : IReturn<List<TaskInfo>>
+    {
+
+    }
+
+    /// <summary>
+    /// Class StartScheduledTask
+    /// </summary>
+    [Route("/ScheduledTasks/Running/{Id}", "POST")]
+    public class StartScheduledTask : IReturnVoid
+    {
+        /// <summary>
+        /// Gets or sets the id.
+        /// </summary>
+        /// <value>The id.</value>
+        public Guid Id { get; set; }
+    }
+
+    /// <summary>
+    /// Class StopScheduledTask
+    /// </summary>
+    [Route("/ScheduledTasks/Running/{Id}", "DELETE")]
+    public class StopScheduledTask : IReturnVoid
+    {
+        /// <summary>
+        /// Gets or sets the id.
+        /// </summary>
+        /// <value>The id.</value>
+        public Guid Id { get; set; }
+    }
+
+    /// <summary>
+    /// Class UpdateScheduledTaskTriggers
+    /// </summary>
+    [Route("/ScheduledTasks/{Id}/Triggers", "POST")]
+    public class UpdateScheduledTaskTriggers : IRequiresRequestStream
+    {
+        /// <summary>
+        /// Gets or sets the task id.
+        /// </summary>
+        /// <value>The task id.</value>
+        public Guid Id { get; set; }
+
+        /// <summary>
+        /// The raw Http Request Input Stream
+        /// </summary>
+        /// <value>The request stream.</value>
+        public Stream RequestStream { get; set; }
+    }
+
+    /// <summary>
+    /// Class ScheduledTasksService
+    /// </summary>
+    [Export(typeof(IRestfulService))]
+    public class ScheduledTaskService : BaseRestService
+    {
+        /// <summary>
+        /// Gets the specified request.
+        /// </summary>
+        /// <param name="request">The request.</param>
+        /// <returns>IEnumerable{TaskInfo}.</returns>
+        public object Get(GetScheduledTasks request)
+        {
+            var result = Kernel.ScheduledTasks.OrderBy(i => i.Name)
+                         .Select(ScheduledTaskHelpers.GetTaskInfo).ToList();
+
+            return ToOptimizedResult(result);
+        }
+
+        /// <summary>
+        /// Gets the specified request.
+        /// </summary>
+        /// <param name="request">The request.</param>
+        /// <returns>IEnumerable{TaskInfo}.</returns>
+        public object Get(GetScheduledTask request)
+        {
+            var task = Kernel.ScheduledTasks.FirstOrDefault(i => i.Id == request.Id);
+
+            if (task == null)
+            {
+                throw new ResourceNotFoundException("Task not found");
+            }
+
+            var result = ScheduledTaskHelpers.GetTaskInfo(task);
+
+            return ToOptimizedResult(result);
+        }
+
+        /// <summary>
+        /// Posts the specified request.
+        /// </summary>
+        /// <param name="request">The request.</param>
+        public void Post(StartScheduledTask request)
+        {
+            var task = Kernel.ScheduledTasks.FirstOrDefault(i => i.Id == request.Id);
+
+            if (task == null)
+            {
+                throw new ResourceNotFoundException("Task not found");
+            }
+
+            task.Execute();
+        }
+
+        /// <summary>
+        /// Posts the specified request.
+        /// </summary>
+        /// <param name="request">The request.</param>
+        public void Delete(StopScheduledTask request)
+        {
+            var task = Kernel.ScheduledTasks.FirstOrDefault(i => i.Id == request.Id);
+
+            if (task == null)
+            {
+                throw new ResourceNotFoundException("Task not found");
+            }
+
+            task.Cancel();
+        }
+
+        /// <summary>
+        /// Posts the specified request.
+        /// </summary>
+        /// <param name="request">The request.</param>
+        public void Post(UpdateScheduledTaskTriggers request)
+        {
+            // We need to parse this manually because we told service stack not to with IRequiresRequestStream
+            // https://code.google.com/p/servicestack/source/browse/trunk/Common/ServiceStack.Text/ServiceStack.Text/Controller/PathInfo.cs
+            var pathInfo = PathInfo.Parse(Request.PathInfo);
+            var id = new Guid(pathInfo.GetArgumentValue<string>(1));
+            
+            var task = Kernel.ScheduledTasks.FirstOrDefault(i => i.Id == id);
+
+            if (task == null)
+            {
+                throw new ResourceNotFoundException("Task not found");
+            }
+
+            var triggerInfos = JsonSerializer.DeserializeFromStream<TaskTriggerInfo[]>(request.RequestStream);
+
+            task.Triggers = triggerInfos.Select(t => ScheduledTaskHelpers.GetTrigger(t, Kernel));
+        }
+    }
+}