From b1e6fd313ba51646d31c53fb3bbf39af17105007 Mon Sep 17 00:00:00 2001 From: TidusJar Date: Wed, 14 Nov 2018 20:06:50 +0000 Subject: [PATCH] !wip started on the request queue --- .../Jobs/Ombi/ResendFailedRequests.cs | 19 +++++++++++++++++++ src/Ombi.Store/Entities/RequestQueue.cs | 14 ++++++++++++++ 2 files changed, 33 insertions(+) create mode 100644 src/Ombi.Schedule/Jobs/Ombi/ResendFailedRequests.cs create mode 100644 src/Ombi.Store/Entities/RequestQueue.cs diff --git a/src/Ombi.Schedule/Jobs/Ombi/ResendFailedRequests.cs b/src/Ombi.Schedule/Jobs/Ombi/ResendFailedRequests.cs new file mode 100644 index 000000000..1e7b8d760 --- /dev/null +++ b/src/Ombi.Schedule/Jobs/Ombi/ResendFailedRequests.cs @@ -0,0 +1,19 @@ +using System.Threading.Tasks; +using Ombi.Store.Entities; +using Ombi.Store.Repository; + +namespace Ombi.Schedule.Jobs.Ombi +{ + public class ResendFailedRequests + { + public ResendFailedRequests(IRepository queue, IMovieSender movieSender) + { + + } + + public async Task Start() + { + + } + } +} \ No newline at end of file diff --git a/src/Ombi.Store/Entities/RequestQueue.cs b/src/Ombi.Store/Entities/RequestQueue.cs new file mode 100644 index 000000000..980bfca31 --- /dev/null +++ b/src/Ombi.Store/Entities/RequestQueue.cs @@ -0,0 +1,14 @@ +using System; +using System.ComponentModel.DataAnnotations.Schema; + +namespace Ombi.Store.Entities +{ + [Table("RequestQueue")] + public class RequestQueue : Entity + { + public int RequestId { get; set; } + public RequestType Type { get; set; } + public DateTime Dts { get; set; } + public DateTime Completed { get; set; } + } +} \ No newline at end of file