SemianiakaVY/BotSharp
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

remove dependency of IEventPublisher in CrontabWatcher

Browse source
This commit is contained in:
Haiping Chen 2025-01-29 06:16:40 -06:00
parent c2f4de14fe
commit 93d1f34786
1 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/Infrastructure/BotSharp.Core.Crontab/Services/CrontabWatcher.cs
View file

@ -46,7 +46,7 @@ public class CrontabWatcher : BackgroundService
var cron = services.GetRequiredService<ICrontabService>();
var crons = await cron.GetCrontable();
var publisher = services.GetRequiredService<IEventPublisher>();
var publisher = services.GetService<IEventPublisher>();
foreach (var item in crons)
{
@ -88,8 +88,16 @@ public class CrontabWatcher : BackgroundService
{
_logger.LogInformation($"The current time matches the cron expression {item}");
await publisher.PublishAsync($"Crontab:{item.Title}", item.Cron);
// cron.ScheduledTimeArrived(item);
if (publisher != null)
{
await publisher.PublishAsync($"Crontab:{item.Title}", item.Cron);
}
else
{
var scope = _services.CreateScope();
cron = scope.ServiceProvider.GetRequiredService<ICrontabService>();
cron.ScheduledTimeArrived(item);
}
}
}
catch (Exception ex)