Feature/cron (#299)

* Update nugets and docs for cron jobs

* Initial implementation of cron jobs plugin

AspNetCore.PluginManager.Solution.sln

@@ -119,6 +119,8 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "workflows", "workflows", "{
 EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "ISSUE_TEMPLATE", "ISSUE_TEMPLATE", "{054AB9E6-B61B-416E-9680-8F470C38D767}"
 EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Cron.Plugin", "Plugins\Cron.Plugin\Cron.Plugin.csproj", "{B0503DFC-C6A5-4D44-9B66-F9FB3786E7DE}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -297,6 +299,10 @@ Global
 		{33E06D80-EEED-491E-A212-7C5E6688A37D}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{33E06D80-EEED-491E-A212-7C5E6688A37D}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{33E06D80-EEED-491E-A212-7C5E6688A37D}.Release|Any CPU.Build.0 = Release|Any CPU
+		{B0503DFC-C6A5-4D44-9B66-F9FB3786E7DE}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{B0503DFC-C6A5-4D44-9B66-F9FB3786E7DE}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{B0503DFC-C6A5-4D44-9B66-F9FB3786E7DE}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{B0503DFC-C6A5-4D44-9B66-F9FB3786E7DE}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

DAL/PluginManager.DAL.TextFiles/Internal/Constants.cs

@@ -61,6 +61,8 @@ internal static class Constants
 		public const string TableNameFAQ = "FAQGroups";
 		public const string TableNameFAQItem = "FAQItems";
 
+		public const string TableNameCronJobs = "CronJobs";
+
 		public const string DomainDownloads = "Downloads";
 		public const string TableNameDownloadCategories = "DownloadCategories";
 		public const string TableNameDownloadItems = "DownloadItems";

DAL/PluginManager.DAL.TextFiles/PluginInitialisation.cs

@@ -30,7 +30,6 @@
 using Middleware.Accounts;
 using Middleware.DynamicContent;
 using Middleware.Helpdesk;
-using Middleware.Interfaces;
 
 using PluginManager.Abstractions;
 using PluginManager.DAL.TextFiles.Providers;
@@ -92,6 +91,8 @@ public void AfterConfigure(in IApplicationBuilder app)
 			_ = app.ApplicationServices.GetService<ISimpleDBOperations<ContentPageDataRow>>();
 			_ = app.ApplicationServices.GetService<ISimpleDBOperations<ContentPageItemDataRow>>();
 
+			_ = app.ApplicationServices.GetService<ISimpleDBOperations<CronJobDataRow>>();
+
 			_ = app.ApplicationServices.GetService<ISimpleDBOperations<ExternalUsersDataRow>>();
 
 			_ = app.ApplicationServices.GetService<ISimpleDBOperations<FeedbackDataRow>>();
@@ -176,6 +177,8 @@ public void BeforeConfigureServices(in IServiceCollection services)
 			services.AddSingleton(typeof(TableRowDefinition), typeof(ContentPageDataRow));
 			services.AddSingleton(typeof(TableRowDefinition), typeof(ContentPageItemDataRow));
 
+			services.AddSingleton(typeof(TableRowDefinition), typeof(CronJobDataRow));
+
 			services.AddSingleton(typeof(TableRowDefinition), typeof(ExternalUsersDataRow));
 
 			services.AddSingleton(typeof(TableRowDefinition), typeof(FeedbackDataRow));
@@ -236,6 +239,7 @@ public void BeforeConfigureServices(in IServiceCollection services)
 			services.AddSingleton<IBlogProvider, BlogProvider>();
 			services.AddSingleton<IClaimsProvider, ClaimsProvider>();
 			services.AddSingleton<ICountryProvider, CountryProvider>();
+			services.AddSingleton<ICronJobProvider, CronJobProvider>();
 			services.AddSingleton<IDownloadProvider, DownloadProvider>();
 			services.AddSingleton<IDynamicContentProvider, DynamicContentProvider>();
 			services.AddSingleton<IHelpdeskProvider, HelpdeskProvider>();

DAL/PluginManager.DAL.TextFiles/PluginManager.DAL.TextFiles.csproj

@@ -30,7 +30,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <None Include="readme.md" Pack="true" PackagePath=""/>
+    <None Include="readme.md" Pack="true" PackagePath="" />
   </ItemGroup>	
 
   <ItemGroup>

DAL/PluginManager.DAL.TextFiles/Providers/CronJobProvider.cs

@@ -0,0 +1,78 @@
+/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
+ *  .Net Core Plugin Manager is distributed under the GNU General Public License version 3 and  
+ *  is also available under alternative licenses negotiated directly with Simon Carter.  
+ *  If you obtained Service Manager under the GPL, then the GPL applies to all loadable 
+ *  Service Manager modules used on your system as well. The GPL (version 3) is 
+ *  available at https://opensource.org/licenses/GPL-3.0
+ *
+ *  This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
+ *  without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+ *  See the GNU General Public License for more details.
+ *
+ *  The Original Code was created by Simon Carter (s1cart3r@gmail.com)
+ *
+ *  Copyright (c) 2024 Simon Carter.  All Rights Reserved.
+ *
+ *  Product:  PluginManager.DAL.TextFiles
+ *  
+ *  File: CronProvider.cs
+ *
+ *  Purpose:  ICronProvider for text based storage
+ *
+ *  Date        Name                Reason
+ *  25/08/2024  Simon Carter        Initially Created
+ *
+ * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
+using Middleware;
+
+using PluginManager.DAL.TextFiles.Tables;
+
+using SharedPluginFeatures;
+
+using SimpleDB;
+
+namespace PluginManager.DAL.TextFiles.Providers
+{
+	internal sealed class CronJobProvider : ICronJobProvider
+	{
+		private readonly ISimpleDBOperations<CronJobDataRow> _cronJobSettings;
+
+		public CronJobProvider(ISimpleDBOperations<CronJobDataRow> cronJobSettings)
+		{
+			_cronJobSettings = cronJobSettings ?? throw new ArgumentNullException(nameof(cronJobSettings));
+		}
+
+		public DateTime GetLastRun(ICronJob cronJob)
+		{
+			CronJobDataRow cronJobDataRow = GetOrCreateCronJobDataRow(cronJob);
+
+			return new DateTime(cronJobDataRow.LastRunTicks, DateTimeKind.Utc);
+		}
+
+		public void SetLastRun(ICronJob cronJob, DateTime lastRun)
+		{
+			CronJobDataRow cronJobDataRow = GetOrCreateCronJobDataRow(cronJob);
+			cronJobDataRow.LastRunTicks = lastRun.Ticks;
+			_cronJobSettings.Update(cronJobDataRow);
+		}
+
+		private CronJobDataRow GetOrCreateCronJobDataRow(ICronJob cronJob)
+		{
+			CronJobDataRow cronJobDataRow = _cronJobSettings.Select(cj => cj.JobId.Equals(cronJob.JobId) && cj.Name.Equals(cronJob.Name)).FirstOrDefault();
+
+			if (cronJobDataRow == null)
+			{
+				cronJobDataRow = new()
+				{
+					JobId = cronJob.JobId,
+					Name = cronJob.Name,
+					UpdatedTicks = DateTime.MinValue.Ticks
+				};
+
+				_cronJobSettings.Insert(cronJobDataRow);
+			}
+
+			return cronJobDataRow;
+		}
+	}
+}

DAL/PluginManager.DAL.TextFiles/Tables/CronJob/CronJobDataRow.cs

@@ -0,0 +1,79 @@
+/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
+ *  .Net Core Plugin Manager is distributed under the GNU General Public License version 3 and  
+ *  is also available under alternative licenses negotiated directly with Simon Carter.  
+ *  If you obtained Service Manager under the GPL, then the GPL applies to all loadable 
+ *  Service Manager modules used on your system as well. The GPL (version 3) is 
+ *  available at https://opensource.org/licenses/GPL-3.0
+ *
+ *  This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
+ *  without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+ *  See the GNU General Public License for more details.
+ *
+ *  The Original Code was created by Simon Carter (s1cart3r@gmail.com)
+ *
+ *  Copyright (c) 2024 Simon Carter.  All Rights Reserved.
+ *
+ *  Product:  PluginManager.DAL.TextFiles
+ *  
+ *  File: CronJobDataRow.cs
+ *
+ *  Purpose:  Row definition for Table for cron jobs
+ *
+ *  Date        Name                Reason
+ *  26/08/2024  Simon Carter        Initially Created
+ *
+ * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
+using SimpleDB;
+
+namespace PluginManager.DAL.TextFiles.Tables
+{
+	[Table(Constants.TableNameCronJobs, CompressionType.None, CachingStrategy.SlidingMemory, WriteStrategy.Forced)]
+	internal sealed class CronJobDataRow : TableRowDefinition
+	{
+		private Guid _jobId;
+		private string _name;
+		private long _lastRunTicks;
+
+		public Guid JobId
+		{
+			get => _jobId;
+
+			set
+			{
+				if (_jobId == value)
+					return;
+
+				_jobId = value;
+				Update();
+			}
+		}
+
+		public string Name
+		{
+			get => _name;
+
+			set
+			{
+				if (_name == value)
+					return;
+
+				_name = value;
+				Update();
+			}
+		}
+
+		public long LastRunTicks
+		{
+			get => _lastRunTicks;
+
+			set
+			{
+				if (_lastRunTicks == value)
+					return;
+
+				_lastRunTicks = value;
+				Update();
+			}
+		}
+	}
+}

Demo/NetCorePluginDemoWebsite/AspNetCore.PluginManager.DemoWebsite.csproj

@@ -66,6 +66,7 @@
   </ItemGroup>
 
   <ItemGroup>
+    <ProjectReference Include="..\..\Plugins\Cron.Plugin\Cron.Plugin.csproj" />
     <ProjectReference Include="..\..\Plugins\Resources.Plugin\Resources.Plugin.csproj" />
     <ProjectReference Include="..\..\SharedPluginFeatures\SharedPluginFeatures.csproj" />
     <ProjectReference Include="..\..\NetCorePluginManager\AspNetCore.PluginManager.csproj" />

Demo/NetCorePluginDemoWebsite/Program.cs

@@ -23,6 +23,7 @@
  *  22/09/2018  Simon Carter        Initially Created
  *
  * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
+using System;
 using System.Diagnostics.CodeAnalysis;
 
 using AspNetCore.PluginManager.DemoWebsite.Classes;
@@ -36,6 +37,8 @@
 
 using Shared.Classes;
 
+using SharedPluginFeatures;
+
 using rp = Resources.Plugin;
 
 namespace AspNetCore.PluginManager.DemoWebsite
@@ -49,6 +52,7 @@ public static void Main(string[] args)
 			ThreadManager.MaximumPoolSize = 500;
 			ThreadManager.MaximumRunningThreads = 50;
 			ThreadManager.ThreadCpuChangeNotification = 0;
+			ThreadManager.ThreadHangTimeout = TimeSpan.FromMinutes(5);
 
 			// add plugins which need to be loaded first in a specific order
 			PluginManagerService.UsePlugin(typeof(ApiAuthorization.Plugin.PluginInitialisation));
@@ -93,6 +97,7 @@ public static void Main(string[] args)
 				PluginManagerService.UsePlugin(typeof(DynamicContent.Plugin.PluginInitialisation));
 				PluginManagerService.UsePlugin(typeof(rp.PluginInitialisation));
 				PluginManagerService.UsePlugin(typeof(SearchPlugin.PluginInitialisation));
+				PluginManagerService.UsePlugin(typeof(Cron.Plugin.PluginInitialisation));
 
 				CreateWebHostBuilder(args).Build().Run();
 			}

Demo/NetCorePluginDemoWebsite/Settings/CronData/CronData.dat

@@ -0,0 +1 @@
+[]

Directory.Build.props

@@ -3,8 +3,9 @@
   <Import Project="$([MSBuild]::GetPathOfFileAbove('Directory.Build.props', '$(MSBuildThisFileDirectory)../'))"  Condition="'$(ImportByWildcardBeforeMicrosoftCommonTargets)' == 'true' and exists('$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\$(MSBuildThisFile)\ImportBefore')"/>
 
   <PropertyGroup>
-    <RunAnalyzersDuringBuild>false</RunAnalyzersDuringBuild>
-    <NoWarn>1701;1702;8032;8981;S125;S6967;S6964;S6670;S6934;S3267;IDE0290</NoWarn>
+    <RunAnalyzers>true</RunAnalyzers>
+    <RunAnalyzersDuringBuild>true</RunAnalyzersDuringBuild>
+    <NoWarn>1701;1702;8032;8981;S125;S6967;S6964;S6670;S6934;S3267;S3431;IDE0290</NoWarn>
     <TreatWarningsAsErrors>true</TreatWarningsAsErrors>
     <SignAssembly>false</SignAssembly>
     <AssemblyOriginatorKeyFile>Shared.Key.pfx</AssemblyOriginatorKeyFile>
@@ -35,8 +36,8 @@
   </PropertyGroup>
 
   <PropertyGroup>
-    <SharedVer>3.15.0</SharedVer>
-    <SharedWinVer>1.5.0</SharedWinVer>
+    <SharedVer>3.16.0</SharedVer>
+    <SharedWinVer>1.6.0</SharedWinVer>
   </PropertyGroup>
 
   <PropertyGroup>

Docs/Custom/Cron.Plugin/Cron.Plugin.Classes/MasterCronThread/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/Cron.Plugin/Cron.Plugin.Provider/DefaultCronData/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/Cron.Plugin/Cron.Plugin/CronExtender/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/Cron.Plugin/Cron.Plugin/CronSettings/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/Cron.Plugin/Cron.Plugin/PluginInitialisation/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/Cron.Plugin/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/Middleware/Middleware/ICronJobProvider/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/Middleware/Middleware/ICronProvider/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/SharedPluginFeatures/SharedPluginFeatures.BaseClasses/CronJob/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/SharedPluginFeatures/SharedPluginFeatures.BaseClasses/DailyCronJob/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/SharedPluginFeatures/SharedPluginFeatures/CronJobSettings/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/SharedPluginFeatures/SharedPluginFeatures/CronPriority/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/SharedPluginFeatures/SharedPluginFeatures/CronRepeatFrequencyType/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/SharedPluginFeatures/SharedPluginFeatures/CronTrigger/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/SharedPluginFeatures/SharedPluginFeatures/ICronJob/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Custom/SharedPluginFeatures/SharedPluginFeatures/ICronJobSettings/SortOrder.dat

@@ -0,0 +1 @@
+5000

Docs/Settings/Files.dat

@@ -39,4 +39,5 @@ ImageManager.Plugin.xml
 DynamicContent.Plugin.xml
 ApiAuthorization.Plugin.xml
 Resources.Plugin.xml
-SimpleDb.xml
+SimpleDb.xml
+CronJob.Plugin.xml