Function TestHookEventsHandlerReturnsPayloads

internal/api/httpapi/hooks_test.go:347–387

(t *testing.T)

}

func TestHookEventsHandlerReturnsPayloads(t *testing.T) {
	t.Parallel()

	homePaths := newTestHomePaths(t)
	observer := stubObserver{
		QueryHookEventsFn: func(_ context.Context, filter hookspkg.EventFilter) ([]hookspkg.EventDescriptor, error) {
			if filter.Family != hookspkg.HookEventFamilyTool {
				t.Fatalf("filter.Family = %q, want %q", filter.Family, hookspkg.HookEventFamilyTool)
			}
			if !filter.SyncOnly {
				t.Fatal("filter.SyncOnly = false, want true")
			}
			return []hookspkg.EventDescriptor{
				{
					Event:         hookspkg.HookToolPreCall,
					Family:        hookspkg.HookEventFamilyTool,
					SyncEligible:  true,
					PayloadSchema: "ToolPreCallPayload",
					PatchSchema:   "ToolCallPatch",
				},
			}, nil
		},
	}

	engine := newTestRouter(t, newTestHandlers(t, stubSessionManager{}, observer, homePaths))
	recorder := performRequest(t, engine, http.MethodGet, "/api/hooks/events?family=tool&sync_only=true", nil)
	if recorder.Code != http.StatusOK {
		t.Fatalf("status = %d, want %d; body=%s", recorder.Code, http.StatusOK, recorder.Body.String())
	}

	var response struct {
		Events []contract.HookEventPayload `json:"events"`
	}
	decodeJSONResponse(t, recorder, &response)
	if got, want := len(response.Events), 1; got != want {
		t.Fatalf("len(events) = %d, want %d", got, want)
	}
	if response.Events[0].Event != hookspkg.HookToolPreCall.String() || !response.Events[0].SyncEligible {
		t.Fatalf("events[0] = %#v", response.Events[0])
	}
}

func TestHookEventsHandlerRejectsInvalidFamily(t *testing.T) {
	t.Parallel()