From 35cf9664de48f76d3671e4b93af3a809323c33fe Mon Sep 17 00:00:00 2001 From: Virgil Date: Thu, 2 Apr 2026 01:33:35 +0000 Subject: [PATCH] feat(admin): add admin hook endpoints Co-Authored-By: Virgil --- admin.go | 45 +++++++++++++++ admin_test.go | 149 ++++++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 194 insertions(+) diff --git a/admin.go b/admin.go index 6e40914..b913345 100644 --- a/admin.go +++ b/admin.go @@ -80,6 +80,51 @@ func (s *AdminService) IterEmails(ctx context.Context) iter.Seq2[types.Email, er return ListIter[types.Email](ctx, s.client, "/api/v1/admin/emails", nil) } +// ListHooks returns all global hooks (admin only). +func (s *AdminService) ListHooks(ctx context.Context) ([]types.Hook, error) { + return ListAll[types.Hook](ctx, s.client, "/api/v1/admin/hooks", nil) +} + +// IterHooks returns an iterator over all global hooks (admin only). +func (s *AdminService) IterHooks(ctx context.Context) iter.Seq2[types.Hook, error] { + return ListIter[types.Hook](ctx, s.client, "/api/v1/admin/hooks", nil) +} + +// GetHook returns a single global hook by ID (admin only). +func (s *AdminService) GetHook(ctx context.Context, id int64) (*types.Hook, error) { + path := ResolvePath("/api/v1/admin/hooks/{id}", Params{"id": int64String(id)}) + var out types.Hook + if err := s.client.Get(ctx, path, &out); err != nil { + return nil, err + } + return &out, nil +} + +// CreateHook creates a new global hook (admin only). +func (s *AdminService) CreateHook(ctx context.Context, opts *types.CreateHookOption) (*types.Hook, error) { + var out types.Hook + if err := s.client.Post(ctx, "/api/v1/admin/hooks", opts, &out); err != nil { + return nil, err + } + return &out, nil +} + +// EditHook updates an existing global hook (admin only). +func (s *AdminService) EditHook(ctx context.Context, id int64, opts *types.EditHookOption) (*types.Hook, error) { + path := ResolvePath("/api/v1/admin/hooks/{id}", Params{"id": int64String(id)}) + var out types.Hook + if err := s.client.Patch(ctx, path, opts, &out); err != nil { + return nil, err + } + return &out, nil +} + +// DeleteHook deletes a global hook (admin only). +func (s *AdminService) DeleteHook(ctx context.Context, id int64) error { + path := ResolvePath("/api/v1/admin/hooks/{id}", Params{"id": int64String(id)}) + return s.client.Delete(ctx, path) +} + // ListQuotaGroups returns all available quota groups. func (s *AdminService) ListQuotaGroups(ctx context.Context) ([]types.QuotaGroup, error) { return ListAll[types.QuotaGroup](ctx, s.client, "/api/v1/admin/quota/groups", nil) diff --git a/admin_test.go b/admin_test.go index 3ce6ec0..e487aac 100644 --- a/admin_test.go +++ b/admin_test.go @@ -224,6 +224,155 @@ func TestAdminService_ListEmails_Good(t *testing.T) { } } +func TestAdminService_ListHooks_Good(t *testing.T) { + srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { + if r.Method != http.MethodGet { + t.Errorf("expected GET, got %s", r.Method) + } + if r.URL.Path != "/api/v1/admin/hooks" { + t.Errorf("wrong path: %s", r.URL.Path) + } + w.Header().Set("X-Total-Count", "1") + json.NewEncoder(w).Encode([]types.Hook{ + {ID: 7, Type: "forgejo", URL: "https://example.com/admin-hook", Active: true}, + }) + })) + defer srv.Close() + + f := NewForge(srv.URL, "tok") + hooks, err := f.Admin.ListHooks(context.Background()) + if err != nil { + t.Fatal(err) + } + if len(hooks) != 1 { + t.Fatalf("got %d hooks, want 1", len(hooks)) + } + if hooks[0].ID != 7 || hooks[0].URL != "https://example.com/admin-hook" { + t.Errorf("unexpected hook: %+v", hooks[0]) + } +} + +func TestAdminService_CreateHook_Good(t *testing.T) { + srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { + if r.Method != http.MethodPost { + t.Errorf("expected POST, got %s", r.Method) + } + if r.URL.Path != "/api/v1/admin/hooks" { + t.Errorf("wrong path: %s", r.URL.Path) + } + var opts types.CreateHookOption + if err := json.NewDecoder(r.Body).Decode(&opts); err != nil { + t.Fatal(err) + } + if opts.Type != "forgejo" { + t.Errorf("got type=%q, want %q", opts.Type, "forgejo") + } + json.NewEncoder(w).Encode(types.Hook{ + ID: 12, + Type: opts.Type, + Active: opts.Active, + Events: opts.Events, + URL: "https://example.com/admin-hook", + }) + })) + defer srv.Close() + + f := NewForge(srv.URL, "tok") + hook, err := f.Admin.CreateHook(context.Background(), &types.CreateHookOption{ + Type: "forgejo", + Active: true, + Events: []string{"push"}, + }) + if err != nil { + t.Fatal(err) + } + if hook.ID != 12 { + t.Errorf("got id=%d, want 12", hook.ID) + } + if hook.Type != "forgejo" { + t.Errorf("got type=%q, want %q", hook.Type, "forgejo") + } +} + +func TestAdminService_GetHook_Good(t *testing.T) { + srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { + if r.Method != http.MethodGet { + t.Errorf("expected GET, got %s", r.Method) + } + if r.URL.Path != "/api/v1/admin/hooks/7" { + t.Errorf("wrong path: %s", r.URL.Path) + } + json.NewEncoder(w).Encode(types.Hook{ + ID: 7, + Type: "forgejo", + Active: true, + URL: "https://example.com/admin-hook", + }) + })) + defer srv.Close() + + f := NewForge(srv.URL, "tok") + hook, err := f.Admin.GetHook(context.Background(), 7) + if err != nil { + t.Fatal(err) + } + if hook.ID != 7 { + t.Errorf("got id=%d, want 7", hook.ID) + } +} + +func TestAdminService_EditHook_Good(t *testing.T) { + srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { + if r.Method != http.MethodPatch { + t.Errorf("expected PATCH, got %s", r.Method) + } + if r.URL.Path != "/api/v1/admin/hooks/7" { + t.Errorf("wrong path: %s", r.URL.Path) + } + var opts types.EditHookOption + if err := json.NewDecoder(r.Body).Decode(&opts); err != nil { + t.Fatal(err) + } + if !opts.Active { + t.Error("expected active=true") + } + json.NewEncoder(w).Encode(types.Hook{ + ID: 7, + Type: "forgejo", + Active: opts.Active, + URL: "https://example.com/admin-hook", + }) + })) + defer srv.Close() + + f := NewForge(srv.URL, "tok") + hook, err := f.Admin.EditHook(context.Background(), 7, &types.EditHookOption{Active: true}) + if err != nil { + t.Fatal(err) + } + if hook.ID != 7 || !hook.Active { + t.Errorf("unexpected hook: %+v", hook) + } +} + +func TestAdminService_DeleteHook_Good(t *testing.T) { + srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { + if r.Method != http.MethodDelete { + t.Errorf("expected DELETE, got %s", r.Method) + } + if r.URL.Path != "/api/v1/admin/hooks/7" { + t.Errorf("wrong path: %s", r.URL.Path) + } + w.WriteHeader(http.StatusNoContent) + })) + defer srv.Close() + + f := NewForge(srv.URL, "tok") + if err := f.Admin.DeleteHook(context.Background(), 7); err != nil { + t.Fatal(err) + } +} + func TestAdminService_ListQuotaGroups_Good(t *testing.T) { srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { if r.Method != http.MethodGet {