jobs api

Pilz.Net/Api/Client/IJobsHandler.cs

@@ -0,0 +1,10 @@
+using Pilz.Net.Api.Entities;
+
+namespace Pilz.Net.Api.Client;
+
+public interface IJobsHandler
+{
+    Task<JobInfo> Execute(string name);
+    Task<JobInfo> Get(string name);
+    Task<IEnumerable<JobInfo>> GetAll();
+}

Pilz.Net/Api/Client/JobsHandler.cs

@@ -0,0 +1,22 @@
+using Pilz.Net.Api.Entities;
+using Pilz.Net.Api.Messages;
+
+namespace Pilz.Net.Api.Client;
+
+public class JobsHandler(IApiClient client) : IJobsHandler
+{
+    public async Task<IEnumerable<JobInfo>> GetAll()
+    {
+        return (await client.SendRequest<ItemMessages<JobInfo>.Items>("/jobs", HttpMethod.Get)).EnsureOk().Items;
+    }
+
+    public async Task<JobInfo> Get(string name)
+    {
+        return (await client.SendRequest<ItemMessages<JobInfo>.Item>($"/jobs/{name}", HttpMethod.Get)).EnsureOk().Item;
+    }
+
+    public async Task<JobInfo> Execute(string name)
+    {
+        return (await client.SendRequest<ItemMessages<JobInfo>.Item>($"/jobs/{name}", HttpMethod.Post)).EnsureOk().Item;
+    }
+}

Pilz.Net/Api/Entities/JobInfo.cs

@@ -0,0 +1,8 @@
+namespace Pilz.Net.Api.Entities;
+
+public class JobInfo
+{
+    public string? Name { get; set; }
+    public DateTime LastExecution { get; set; }
+    public TimeSpan Interval { get; set; }
+}

Pilz.Net/Api/Server/JobsHandler.cs

@@ -0,0 +1,45 @@
+using Pilz.Jobs;
+using Pilz.Net.Api.Entities;
+using Pilz.Net.Extensions;
+
+namespace Pilz.Net.Api.Server;
+
+public class JobsHandler(IApiServer server)
+{
+    [ApiMessageHandler("/jobs", "GET")]
+    public virtual ApiResult GetAll()
+    {
+        return server.Jobs.Jobs.Select(ToClient).ToItemsResult();
+    }
+
+    [ApiMessageHandler("/jobs/{name}", "GET")]
+    public virtual ApiResult Get(string name)
+    {
+        if (server.Jobs.Jobs.FirstOrDefault(n => n.Name == name) is not Job job)
+            return ApiResult.BadRequest();
+        return ToClient(job).ToItemResult();
+    }
+
+    [ApiMessageHandler("/jobs/{name}", "POST")]
+    public virtual ApiResult Execute(string name)
+    {
+        if (server.Jobs.Jobs.FirstOrDefault(n => n.Name == name) is not Job job)
+            return ApiResult.BadRequest();
+
+        var now = DateTime.Now;
+        job.Execute(new(server.Jobs));
+        job.LastExecution = now;
+
+        return ApiResult.Ok();
+    }
+
+    protected virtual JobInfo ToClient(Job job)
+    {
+        return new JobInfo
+        {
+            Name = job.Name,
+            Interval = job.Interval,
+            LastExecution = job.LastExecution,
+        };
+    }
+}