feat(scheduling): add RegisterSchedulerServices DI extension

Author: tgiachi

src/SquidStd.Services.Core/Extensions/RegisterSchedulerServicesExtension.cs

@@ -0,0 +1,32 @@
+using DryIoc;
+using SquidStd.Abstractions.Extensions.Config;
+using SquidStd.Abstractions.Extensions.Services;
+using SquidStd.Core.Data.Timing;
+using SquidStd.Core.Interfaces.Scheduling;
+using SquidStd.Services.Core.Services.Scheduling;
+
+namespace SquidStd.Services.Core.Extensions;
+
+/// <summary>
+/// Extension methods for registering the SquidStd cron scheduler.
+/// </summary>
+public static class RegisterSchedulerServicesExtension
+{
+    /// <param name="container">Container that receives the scheduler registrations.</param>
+    extension(IContainer container)
+    {
+        /// <summary>
+        /// Registers the timer wheel pump and the cron scheduler. Must be called after
+        /// <c>RegisterCoreServices</c> so that <c>ITimerService</c> and <c>IJobSystem</c> exist.
+        /// </summary>
+        /// <returns>The same container for chaining.</returns>
+        public IContainer RegisterSchedulerServices()
+        {
+            container.RegisterConfigSection("timerWheelPump", static () => new TimerWheelPumpConfig(), -90);
+            container.RegisterStdService<TimerWheelPumpService, TimerWheelPumpService>(-1);
+            container.RegisterStdService<ICronScheduler, CronSchedulerService>(-1);
+
+            return container;
+        }
+    }
+}

tests/SquidStd.Tests/Services/Core/Scheduling/CronSchedulerRegistrationTests.cs

@@ -0,0 +1,30 @@
+using DryIoc;
+using SquidStd.Core.Data.Jobs;
+using SquidStd.Core.Data.Timing;
+using SquidStd.Core.Interfaces.Jobs;
+using SquidStd.Core.Interfaces.Scheduling;
+using SquidStd.Core.Interfaces.Timing;
+using SquidStd.Services.Core.Extensions;
+using SquidStd.Services.Core.Services;
+using SquidStd.Services.Core.Services.Scheduling;
+
+namespace SquidStd.Tests.Services.Core.Scheduling;
+
+public class CronSchedulerRegistrationTests
+{
+    [Fact]
+    public void RegisterSchedulerServices_ResolvesSchedulerAndPump()
+    {
+        var container = new Container();
+        container.RegisterInstance(new TimerWheelConfig());
+        container.RegisterInstance(new TimerWheelPumpConfig());
+        container.RegisterInstance(new JobsConfig { WorkerThreadCount = 1 });
+        container.Register<ITimerService, TimerWheelService>(Reuse.Singleton);
+        container.Register<IJobSystem, JobSystemService>(Reuse.Singleton);
+
+        container.RegisterSchedulerServices();
+
+        Assert.NotNull(container.Resolve<ICronScheduler>());
+        Assert.NotNull(container.Resolve<TimerWheelPumpService>());
+    }
+}