Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 36dc31e85b | |||
| 41f92d0670 | |||
| e9a1552e6d | |||
| 988ba4113c |
@@ -8,7 +8,7 @@
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="LiteCharms.Abstractions" Version="1.14.0" />
|
||||
<PackageReference Include="LiteCharms.Abstractions" Version="1.19.0" />
|
||||
<PackageReference Include="Microsoft.Extensions.Hosting" Version="10.0.7" />
|
||||
<PackageReference Include="Mediator.SourceGenerator" Version="3.0.2">
|
||||
<PrivateAssets>all</PrivateAssets>
|
||||
@@ -18,9 +18,9 @@
|
||||
|
||||
<!-- Lite Charms Libraries -->
|
||||
<ItemGroup>
|
||||
<PackageReference Include="LiteCharms.Extensions" Version="1.14.0" />
|
||||
<PackageReference Include="LiteCharms.Features" Version="1.14.0" />
|
||||
<PackageReference Include="LiteCharms.Models" Version="1.14.0" />
|
||||
<PackageReference Include="LiteCharms.Extensions" Version="1.19.0" />
|
||||
<PackageReference Include="LiteCharms.Features" Version="1.19.0" />
|
||||
<PackageReference Include="LiteCharms.Models" Version="1.19.0" />
|
||||
</ItemGroup>
|
||||
|
||||
<!-- Shared Global Usings -->
|
||||
|
||||
@@ -12,7 +12,7 @@ builder.Services.AddEmailServices(builder.Configuration);
|
||||
builder.Services.AddShopDatabase(builder.Configuration);
|
||||
builder.Services.AddQuartzSchedulerClient(ShopSchedulerName, builder.Configuration);
|
||||
|
||||
builder.Services.AddHostedService<Worker>();
|
||||
builder.Services.AddHostedService<JobWorker>();
|
||||
|
||||
var host = builder.Build();
|
||||
|
||||
|
||||
@@ -0,0 +1,15 @@
|
||||
using LiteCharms.Abstractions;
|
||||
using LiteCharms.Features.Notifications.Events;
|
||||
|
||||
namespace LiteCharmsScheduler.Workers
|
||||
{
|
||||
public class JobWorker(IJobOrchestrator jobOrchestrator, ILogger<JobWorker> logger) : BackgroundService
|
||||
{
|
||||
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
||||
{
|
||||
await jobOrchestrator.ScheduleAsync(ProcessEmailNotificationsEvent.Create(), "0 1 * * * ?", stoppingToken);
|
||||
|
||||
logger.LogInformation("Startup jobs scheduled");
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,17 +0,0 @@
|
||||
namespace LiteCharmsScheduler.Workers
|
||||
{
|
||||
public class Worker(ILogger<Worker> logger) : BackgroundService
|
||||
{
|
||||
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
||||
{
|
||||
while (!stoppingToken.IsCancellationRequested)
|
||||
{
|
||||
if (logger.IsEnabled(LogLevel.Information))
|
||||
{
|
||||
logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);
|
||||
}
|
||||
await Task.Delay(1000, stoppingToken);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -26,7 +26,7 @@ metadata:
|
||||
type: Opaque
|
||||
data:
|
||||
connection-string-quartz: SG9zdD0xOTIuMTY4LjEuMTcwO0RhdGFiYXNlPXNjaGVkdWxlci1kZXY7VXNlcm5hbWU9c2NoZWR1bGVyLWRldi11c2VyO1Bhc3N3b3JkPWtWVm1vV0tKM3h6Z1FYO1BlcnNpc3QgU2VjdXJpdHkgSW5mbz1UcnVl
|
||||
connection-string: SG9zdD0xOTIuMTY4LjEuMTcwO0RhdGFiYXNlPWxlYWRnZW5lcmF0b3ItZGV2O1VzZXJuYW1lPWxlYWRnZW5lcmF0b3I7UGFzc3dvcmQ9S2VLNDRsczRQWHBuYms7UGVyc2lzdCBTZWN1cml0eSBJbmZvPVRydWU=
|
||||
connection-string: SG9zdD0xOTIuMTY4LjEuMTcwO0RhdGFiYXNlPXNob3AtZGV2O1VzZXJuYW1lPXNob3AtZGV2LXVzZXI7UGFzc3dvcmQ9a1ZWbW9XS0ozeHpnUVg7UGVyc2lzdCBTZWN1cml0eSBJbmZvPVRydWU=
|
||||
discord-webhook: aHR0cHM6Ly9kaXNjb3JkLmNvbS9hcGkvd2ViaG9va3MvMTUwMDIzMzEyOTYwNzAzNjk3MC9KYzc5endwMjlxYWpLbmoyYkR3cm5GR0RJci11ZGIyV2JIUDZTYjdpT0hCTWpQSUY3Vkw5eUVHTkJUSXpSOVVWVzI0bQ==
|
||||
aspire-apikey: bWMzRzYzSzJqNVpPRXNpMEFqTW9qTFRYbTFLRVpGY3R6SUlqU3dEaVRHdXQ4cUdTa1B1V3d4R1AxUmJzY0pVbw==
|
||||
email-password: JFpTLWVJQGlYbTVNUCRhfg==
|
||||
|
||||
Reference in New Issue
Block a user