releases/ClaudeDo
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases 3 Wiki Activity

feat(worker): add WorkerLog SignalR event

Browse Source
This commit is contained in:
mika kuns
2026-04-23 14:19:04 +02:00
parent 80f6669585
commit 0a7fcae137
2 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/ClaudeDo.Worker/Hub/HubBroadcaster.cs
View File

@@ -1,3 +1,4 @@
using ClaudeDo.Data.Models;
using Microsoft.AspNetCore.SignalR; using Microsoft.AspNetCore.SignalR;
namespace ClaudeDo.Worker.Hub; namespace ClaudeDo.Worker.Hub;
@@ -28,4 +29,7 @@ public sealed class HubBroadcaster
public Task RunCreated(string taskId, int runNumber, bool isRetry) => public Task RunCreated(string taskId, int runNumber, bool isRetry) =>
_hub.Clients.All.SendAsync("RunCreated", taskId, runNumber, isRetry); _hub.Clients.All.SendAsync("RunCreated", taskId, runNumber, isRetry);
public Task WorkerLog(string message, WorkerLogLevel level, DateTime timestampUtc) =>
_hub.Clients.All.SendAsync("WorkerLog", message, level, timestampUtc);
} }

5
src/ClaudeDo.Worker/Program.cs
View File

@@ -20,7 +20,10 @@ builder.Services.AddDbContextFactory<ClaudeDoDbContext>(opt =>
builder.Services.AddSingleton(cfg); builder.Services.AddSingleton(cfg);
builder.Services.AddHostedService<StaleTaskRecovery>(); builder.Services.AddHostedService<StaleTaskRecovery>();
builder.Services.AddSignalR(); builder.Services.AddSignalR().AddJsonProtocol(options =>
{
options.PayloadSerializerOptions.Converters.Add(new System.Text.Json.Serialization.JsonStringEnumConverter());
});
// Runner stack. // Runner stack.
builder.Services.AddSingleton<IClaudeProcess, ClaudeProcess>(); builder.Services.AddSingleton<IClaudeProcess, ClaudeProcess>();