diff --git a/src/ClaudeDo.Worker/Hub/HubBroadcaster.cs b/src/ClaudeDo.Worker/Hub/HubBroadcaster.cs index e927ef3..0483fbc 100644 --- a/src/ClaudeDo.Worker/Hub/HubBroadcaster.cs +++ b/src/ClaudeDo.Worker/Hub/HubBroadcaster.cs @@ -1,9 +1,10 @@ using ClaudeDo.Data.Models; +using ClaudeDo.Worker.Prime; using Microsoft.AspNetCore.SignalR; namespace ClaudeDo.Worker.Hub; -public sealed class HubBroadcaster +public sealed class HubBroadcaster : IPrimeBroadcaster { private readonly IHubContext _hub; @@ -47,4 +48,10 @@ public sealed class HubBroadcaster public Task PlanningCompleted(string planningTaskId) => _hub.Clients.All.SendAsync("PlanningCompleted", planningTaskId); + + public Task PrimeFired(Guid scheduleId, bool success, string message, DateTimeOffset firedAt) => + _hub.Clients.All.SendAsync("PrimeFired", scheduleId, success, message, firedAt); + + Task IPrimeBroadcaster.PrimeFiredAsync(Guid scheduleId, bool success, string message, DateTimeOffset firedAt) => + PrimeFired(scheduleId, success, message, firedAt); }