summaryrefslogtreecommitdiff
path: root/internal/api/events_test.go
diff options
context:
space:
mode:
authorPeter Stone <thepeterstone@gmail.com>2026-06-03 23:01:39 +0000
committerPeter Stone <thepeterstone@gmail.com>2026-06-03 23:01:39 +0000
commit68cf1e24dd2ca2612b72babc4b35280cd3512f92 (patch)
tree14b73f21570a2f42ae729ca7e9676de6628d6819 /internal/api/events_test.go
parentb28cfc6ff288d083f6c8e9c055b69bfcadbceccc (diff)
parent7388337d3be5cc7f65ef547e30b2e39884dd165b (diff)
merge: integrate oss branch — budget gating, MCP back-channel, events, loopback-only bind
Key features from OSS branch: - Budget gating: rolling per-provider spend caps with BUDGET_EXCEEDED task state - Agent MCP back-channel: runners mint tokens; /mcp endpoint resolves them - Chatbot MCP server at /chatbot/mcp (requires api_token in config) - Event timeline: unified event stream replacing ad-hoc question/summary flows - Loopback-only default bind (127.0.0.1:8484); external_bind_allowed=true to expose - repository_url required on task creation (enforces traceability) - Auto-checker: spawns verification task after each execution Conflict resolutions: - serve.go: keep cfg.Runners.XEnabled() conditional registration from main + agentRegistry from oss - config.go: keep RunnersConfig from main + BudgetConfig/ExternalBindAllowed from oss - server.go: handleStaticFiles (base-path rewrite) kept; deduplicated duplicate from both sides - executor/claude.go: accepted oss deletion (ClaudeRunner replaced by ContainerRunner) - container_test.go: added noopChannel + AgentChannel parameter to Run call Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
Diffstat (limited to 'internal/api/events_test.go')
-rw-r--r--internal/api/events_test.go94
1 files changed, 94 insertions, 0 deletions
diff --git a/internal/api/events_test.go b/internal/api/events_test.go
new file mode 100644
index 0000000..456b6d8
--- /dev/null
+++ b/internal/api/events_test.go
@@ -0,0 +1,94 @@
+package api
+
+import (
+ "encoding/json"
+ "net/http"
+ "net/http/httptest"
+ "strconv"
+ "testing"
+
+ "github.com/thepeterstone/claudomator/internal/event"
+ "github.com/thepeterstone/claudomator/internal/task"
+)
+
+func TestListTaskEvents_ReturnsStreamInSeqOrder(t *testing.T) {
+ srv, store := testServer(t)
+ createTaskWithState(t, store, "ev-task", task.StateReady)
+
+ req := httptest.NewRequest("GET", "/api/tasks/ev-task/events", nil)
+ w := httptest.NewRecorder()
+ srv.Handler().ServeHTTP(w, req)
+
+ if w.Code != http.StatusOK {
+ t.Fatalf("status: want 200, got %d; body %s", w.Code, w.Body.String())
+ }
+ var events []*event.Event
+ if err := json.Unmarshal(w.Body.Bytes(), &events); err != nil {
+ t.Fatalf("unmarshal: %v", err)
+ }
+ if len(events) == 0 {
+ t.Fatal("expected state-change events from the walk to READY")
+ }
+ for i := 1; i < len(events); i++ {
+ if events[i].Seq <= events[i-1].Seq {
+ t.Errorf("events not in ascending seq order: %d then %d", events[i-1].Seq, events[i].Seq)
+ }
+ }
+}
+
+func TestListTaskEvents_SinceSeqFilters(t *testing.T) {
+ srv, store := testServer(t)
+ createTaskWithState(t, store, "ev-since", task.StateReady)
+
+ all := getEvents(t, srv, "ev-since", "")
+ if len(all) < 2 {
+ t.Skipf("need at least 2 events to test since_seq, got %d", len(all))
+ }
+ firstSeq := all[0].Seq
+ rest := getEvents(t, srv, "ev-since", "?since_seq="+itoa(firstSeq))
+ for _, e := range rest {
+ if e.Seq <= firstSeq {
+ t.Errorf("since_seq=%d returned event with seq %d", firstSeq, e.Seq)
+ }
+ }
+}
+
+func TestListTaskEvents_NotFound(t *testing.T) {
+ srv, _ := testServer(t)
+ req := httptest.NewRequest("GET", "/api/tasks/missing/events", nil)
+ w := httptest.NewRecorder()
+ srv.Handler().ServeHTTP(w, req)
+ if w.Code != http.StatusNotFound {
+ t.Errorf("want 404, got %d", w.Code)
+ }
+}
+
+func TestListTaskEvents_InvalidSinceSeq(t *testing.T) {
+ srv, store := testServer(t)
+ createTaskWithState(t, store, "ev-bad", task.StateReady)
+ req := httptest.NewRequest("GET", "/api/tasks/ev-bad/events?since_seq=abc", nil)
+ w := httptest.NewRecorder()
+ srv.Handler().ServeHTTP(w, req)
+ if w.Code != http.StatusBadRequest {
+ t.Errorf("want 400, got %d", w.Code)
+ }
+}
+
+func getEvents(t *testing.T, srv *Server, taskID, query string) []*event.Event {
+ t.Helper()
+ req := httptest.NewRequest("GET", "/api/tasks/"+taskID+"/events"+query, nil)
+ w := httptest.NewRecorder()
+ srv.Handler().ServeHTTP(w, req)
+ if w.Code != http.StatusOK {
+ t.Fatalf("getEvents %s%s: status %d", taskID, query, w.Code)
+ }
+ var events []*event.Event
+ if err := json.Unmarshal(w.Body.Bytes(), &events); err != nil {
+ t.Fatalf("getEvents unmarshal: %v", err)
+ }
+ return events
+}
+
+func itoa(n int64) string {
+ return strconv.FormatInt(n, 10)
+}