fix: migrate module paths to dappco.re

CLAUDE.md

@@ -33,9 +33,9 @@ The library is a flat package (`package forge`) with a layered design:
 
 5. **`config.go`** — Config resolution: flags > env (`FORGE_URL`, `FORGE_TOKEN`) > defaults (`http://localhost:3000`).
 
-6. **`forge.go`** — Top-level `Forge` struct aggregating all 18 service fields. Created via `NewForge(url, token)` or `NewForgeFromConfig(flagURL, flagToken)`.
+6. **`forge.go`** — Top-level `Forge` struct aggregating all 20 service fields. Created via `NewForge(url, token)` or `NewForgeFromConfig(flagURL, flagToken)`.
 
-7. **Service files** (`repos.go`, `issues.go`, etc.) — Each service struct embeds `Resource[T,C,U]` for standard CRUD, then adds hand-written action methods (e.g. `Fork`, `Pin`, `MirrorSync`). 18 services total: repos, issues, pulls, orgs, users, teams, admin, branches, releases, labels, webhooks, notifications, packages, actions, contents, wiki, commits, misc.
+7. **Service files** (`repos.go`, `issues.go`, etc.) — Each service struct embeds `Resource[T,C,U]` for standard CRUD, then adds hand-written action methods (e.g. `Fork`, `Pin`, `MirrorSync`). 20 services total: repos, issues, pulls, orgs, users, teams, admin, branches, releases, labels, webhooks, notifications, packages, actions, contents, wiki, commits, milestones, misc, activitypub.
 
 8. **`types/`** — Generated Go types from `swagger.v1.json` (229 types). The `//go:generate` directive lives in `types/generate.go`. **Do not hand-edit generated type files** — modify `cmd/forgegen/` instead.
 

actions.go

@@ -2,15 +2,22 @@ package forge
 
 import (
 	"context"
-	"fmt"
 	"iter"
+	"net/url"
+	"strconv"
 
+	core "dappco.re/go/core"
 	"dappco.re/go/core/forge/types"
 )
 
 // ActionsService handles CI/CD actions operations across repositories and
-// organisations — secrets, variables, and workflow dispatches.
+// organisations — secrets, variables, workflow dispatches, and tasks.
 // No Resource embedding — heterogeneous endpoints across repo and org levels.
+//
+// Usage:
+//
+//	f := forge.NewForge("https://forge.lthn.ai", "token")
+//	_, err := f.Actions.ListRepoSecrets(ctx, "core", "go-forge")
 type ActionsService struct {
 	client *Client
 }
@@ -21,82 +28,239 @@ func newActionsService(c *Client) *ActionsService {
 
 // ListRepoSecrets returns all secrets for a repository.
 func (s *ActionsService) ListRepoSecrets(ctx context.Context, owner, repo string) ([]types.Secret, error) {
-	path := fmt.Sprintf("/api/v1/repos/%s/%s/actions/secrets", owner, repo)
+	path := ResolvePath("/api/v1/repos/{owner}/{repo}/actions/secrets", pathParams("owner", owner, "repo", repo))
 	return ListAll[types.Secret](ctx, s.client, path, nil)
 }
 
 // IterRepoSecrets returns an iterator over all secrets for a repository.
 func (s *ActionsService) IterRepoSecrets(ctx context.Context, owner, repo string) iter.Seq2[types.Secret, error] {
-	path := fmt.Sprintf("/api/v1/repos/%s/%s/actions/secrets", owner, repo)
+	path := ResolvePath("/api/v1/repos/{owner}/{repo}/actions/secrets", pathParams("owner", owner, "repo", repo))
 	return ListIter[types.Secret](ctx, s.client, path, nil)
 }
 
 // CreateRepoSecret creates or updates a secret in a repository.
 // Forgejo expects a PUT with {"data": "secret-value"} body.
 func (s *ActionsService) CreateRepoSecret(ctx context.Context, owner, repo, name string, data string) error {
-	path := fmt.Sprintf("/api/v1/repos/%s/%s/actions/secrets/%s", owner, repo, name)
+	path := ResolvePath("/api/v1/repos/{owner}/{repo}/actions/secrets/{secretname}", pathParams("owner", owner, "repo", repo, "secretname", name))
 	body := map[string]string{"data": data}
 	return s.client.Put(ctx, path, body, nil)
 }
 
 // DeleteRepoSecret removes a secret from a repository.
 func (s *ActionsService) DeleteRepoSecret(ctx context.Context, owner, repo, name string) error {
-	path := fmt.Sprintf("/api/v1/repos/%s/%s/actions/secrets/%s", owner, repo, name)
+	path := ResolvePath("/api/v1/repos/{owner}/{repo}/actions/secrets/{secretname}", pathParams("owner", owner, "repo", repo, "secretname", name))
 	return s.client.Delete(ctx, path)
 }
 
 // ListRepoVariables returns all action variables for a repository.
 func (s *ActionsService) ListRepoVariables(ctx context.Context, owner, repo string) ([]types.ActionVariable, error) {
-	path := fmt.Sprintf("/api/v1/repos/%s/%s/actions/variables", owner, repo)
+	path := ResolvePath("/api/v1/repos/{owner}/{repo}/actions/variables", pathParams("owner", owner, "repo", repo))
 	return ListAll[types.ActionVariable](ctx, s.client, path, nil)
 }
 
 // IterRepoVariables returns an iterator over all action variables for a repository.
 func (s *ActionsService) IterRepoVariables(ctx context.Context, owner, repo string) iter.Seq2[types.ActionVariable, error] {
-	path := fmt.Sprintf("/api/v1/repos/%s/%s/actions/variables", owner, repo)
+	path := ResolvePath("/api/v1/repos/{owner}/{repo}/actions/variables", pathParams("owner", owner, "repo", repo))
 	return ListIter[types.ActionVariable](ctx, s.client, path, nil)
 }
 
 // CreateRepoVariable creates a new action variable in a repository.
 // Forgejo expects a POST with {"value": "var-value"} body.
 func (s *ActionsService) CreateRepoVariable(ctx context.Context, owner, repo, name, value string) error {
-	path := fmt.Sprintf("/api/v1/repos/%s/%s/actions/variables/%s", owner, repo, name)
+	path := ResolvePath("/api/v1/repos/{owner}/{repo}/actions/variables/{variablename}", pathParams("owner", owner, "repo", repo, "variablename", name))
 	body := types.CreateVariableOption{Value: value}
 	return s.client.Post(ctx, path, body, nil)
 }
 
+// UpdateRepoVariable updates an existing action variable in a repository.
+func (s *ActionsService) UpdateRepoVariable(ctx context.Context, owner, repo, name string, opts *types.UpdateVariableOption) error {
+	path := ResolvePath("/api/v1/repos/{owner}/{repo}/actions/variables/{variablename}", pathParams("owner", owner, "repo", repo, "variablename", name))
+	return s.client.Put(ctx, path, opts, nil)
+}
+
 // DeleteRepoVariable removes an action variable from a repository.
 func (s *ActionsService) DeleteRepoVariable(ctx context.Context, owner, repo, name string) error {
-	path := fmt.Sprintf("/api/v1/repos/%s/%s/actions/variables/%s", owner, repo, name)
+	path := ResolvePath("/api/v1/repos/{owner}/{repo}/actions/variables/{variablename}", pathParams("owner", owner, "repo", repo, "variablename", name))
 	return s.client.Delete(ctx, path)
 }
 
 // ListOrgSecrets returns all secrets for an organisation.
 func (s *ActionsService) ListOrgSecrets(ctx context.Context, org string) ([]types.Secret, error) {
-	path := fmt.Sprintf("/api/v1/orgs/%s/actions/secrets", org)
+	path := ResolvePath("/api/v1/orgs/{org}/actions/secrets", pathParams("org", org))
 	return ListAll[types.Secret](ctx, s.client, path, nil)
 }
 
 // IterOrgSecrets returns an iterator over all secrets for an organisation.
 func (s *ActionsService) IterOrgSecrets(ctx context.Context, org string) iter.Seq2[types.Secret, error] {
-	path := fmt.Sprintf("/api/v1/orgs/%s/actions/secrets", org)
+	path := ResolvePath("/api/v1/orgs/{org}/actions/secrets", pathParams("org", org))
 	return ListIter[types.Secret](ctx, s.client, path, nil)
 }
 
 // ListOrgVariables returns all action variables for an organisation.
 func (s *ActionsService) ListOrgVariables(ctx context.Context, org string) ([]types.ActionVariable, error) {
-	path := fmt.Sprintf("/api/v1/orgs/%s/actions/variables", org)
+	path := ResolvePath("/api/v1/orgs/{org}/actions/variables", pathParams("org", org))
 	return ListAll[types.ActionVariable](ctx, s.client, path, nil)
 }
 
 // IterOrgVariables returns an iterator over all action variables for an organisation.
 func (s *ActionsService) IterOrgVariables(ctx context.Context, org string) iter.Seq2[types.ActionVariable, error] {
-	path := fmt.Sprintf("/api/v1/orgs/%s/actions/variables", org)
+	path := ResolvePath("/api/v1/orgs/{org}/actions/variables", pathParams("org", org))
 	return ListIter[types.ActionVariable](ctx, s.client, path, nil)
 }
 
+// GetOrgVariable returns a single action variable for an organisation.
+func (s *ActionsService) GetOrgVariable(ctx context.Context, org, name string) (*types.ActionVariable, error) {
+	path := ResolvePath("/api/v1/orgs/{org}/actions/variables/{variablename}", pathParams("org", org, "variablename", name))
+	var out types.ActionVariable
+	if err := s.client.Get(ctx, path, &out); err != nil {
+		return nil, err
+	}
+	return &out, nil
+}
+
+// CreateOrgVariable creates a new action variable in an organisation.
+func (s *ActionsService) CreateOrgVariable(ctx context.Context, org, name, value string) error {
+	path := ResolvePath("/api/v1/orgs/{org}/actions/variables/{variablename}", pathParams("org", org, "variablename", name))
+	body := types.CreateVariableOption{Value: value}
+	return s.client.Post(ctx, path, body, nil)
+}
+
+// UpdateOrgVariable updates an existing action variable in an organisation.
+func (s *ActionsService) UpdateOrgVariable(ctx context.Context, org, name string, opts *types.UpdateVariableOption) error {
+	path := ResolvePath("/api/v1/orgs/{org}/actions/variables/{variablename}", pathParams("org", org, "variablename", name))
+	return s.client.Put(ctx, path, opts, nil)
+}
+
+// DeleteOrgVariable removes an action variable from an organisation.
+func (s *ActionsService) DeleteOrgVariable(ctx context.Context, org, name string) error {
+	path := ResolvePath("/api/v1/orgs/{org}/actions/variables/{variablename}", pathParams("org", org, "variablename", name))
+	return s.client.Delete(ctx, path)
+}
+
+// CreateOrgSecret creates or updates a secret in an organisation.
+func (s *ActionsService) CreateOrgSecret(ctx context.Context, org, name, data string) error {
+	path := ResolvePath("/api/v1/orgs/{org}/actions/secrets/{secretname}", pathParams("org", org, "secretname", name))
+	body := map[string]string{"data": data}
+	return s.client.Put(ctx, path, body, nil)
+}
+
+// DeleteOrgSecret removes a secret from an organisation.
+func (s *ActionsService) DeleteOrgSecret(ctx context.Context, org, name string) error {
+	path := ResolvePath("/api/v1/orgs/{org}/actions/secrets/{secretname}", pathParams("org", org, "secretname", name))
+	return s.client.Delete(ctx, path)
+}
+
+// ListUserVariables returns all action variables for the authenticated user.
+func (s *ActionsService) ListUserVariables(ctx context.Context) ([]types.ActionVariable, error) {
+	return ListAll[types.ActionVariable](ctx, s.client, "/api/v1/user/actions/variables", nil)
+}
+
+// IterUserVariables returns an iterator over all action variables for the authenticated user.
+func (s *ActionsService) IterUserVariables(ctx context.Context) iter.Seq2[types.ActionVariable, error] {
+	return ListIter[types.ActionVariable](ctx, s.client, "/api/v1/user/actions/variables", nil)
+}
+
+// GetUserVariable returns a single action variable for the authenticated user.
+func (s *ActionsService) GetUserVariable(ctx context.Context, name string) (*types.ActionVariable, error) {
+	path := ResolvePath("/api/v1/user/actions/variables/{variablename}", pathParams("variablename", name))
+	var out types.ActionVariable
+	if err := s.client.Get(ctx, path, &out); err != nil {
+		return nil, err
+	}
+	return &out, nil
+}
+
+// CreateUserVariable creates a new action variable for the authenticated user.
+func (s *ActionsService) CreateUserVariable(ctx context.Context, name, value string) error {
+	path := ResolvePath("/api/v1/user/actions/variables/{variablename}", pathParams("variablename", name))
+	body := types.CreateVariableOption{Value: value}
+	return s.client.Post(ctx, path, body, nil)
+}
+
+// UpdateUserVariable updates an existing action variable for the authenticated user.
+func (s *ActionsService) UpdateUserVariable(ctx context.Context, name string, opts *types.UpdateVariableOption) error {
+	path := ResolvePath("/api/v1/user/actions/variables/{variablename}", pathParams("variablename", name))
+	return s.client.Put(ctx, path, opts, nil)
+}
+
+// DeleteUserVariable removes an action variable for the authenticated user.
+func (s *ActionsService) DeleteUserVariable(ctx context.Context, name string) error {
+	path := ResolvePath("/api/v1/user/actions/variables/{variablename}", pathParams("variablename", name))
+	return s.client.Delete(ctx, path)
+}
+
+// CreateUserSecret creates or updates a secret for the authenticated user.
+func (s *ActionsService) CreateUserSecret(ctx context.Context, name, data string) error {
+	path := ResolvePath("/api/v1/user/actions/secrets/{secretname}", pathParams("secretname", name))
+	body := map[string]string{"data": data}
+	return s.client.Put(ctx, path, body, nil)
+}
+
+// DeleteUserSecret removes a secret for the authenticated user.
+func (s *ActionsService) DeleteUserSecret(ctx context.Context, name string) error {
+	path := ResolvePath("/api/v1/user/actions/secrets/{secretname}", pathParams("secretname", name))
+	return s.client.Delete(ctx, path)
+}
+
 // DispatchWorkflow triggers a workflow run.
 func (s *ActionsService) DispatchWorkflow(ctx context.Context, owner, repo, workflow string, opts map[string]any) error {
-	path := fmt.Sprintf("/api/v1/repos/%s/%s/actions/workflows/%s/dispatches", owner, repo, workflow)
+	path := ResolvePath("/api/v1/repos/{owner}/{repo}/actions/workflows/{workflowname}/dispatches", pathParams("owner", owner, "repo", repo, "workflowname", workflow))
 	return s.client.Post(ctx, path, opts, nil)
 }
+
+// ListRepoTasks returns a single page of action tasks for a repository.
+func (s *ActionsService) ListRepoTasks(ctx context.Context, owner, repo string, opts ListOptions) (*types.ActionTaskResponse, error) {
+	path := ResolvePath("/api/v1/repos/{owner}/{repo}/actions/tasks", pathParams("owner", owner, "repo", repo))
+
+	if opts.Page > 0 || opts.Limit > 0 {
+		u, err := url.Parse(path)
+		if err != nil {
+			return nil, core.E("ActionsService.ListRepoTasks", "forge: parse path", err)
+		}
+		q := u.Query()
+		if opts.Page > 0 {
+			q.Set("page", strconv.Itoa(opts.Page))
+		}
+		if opts.Limit > 0 {
+			q.Set("limit", strconv.Itoa(opts.Limit))
+		}
+		u.RawQuery = q.Encode()
+		path = u.String()
+	}
+
+	var out types.ActionTaskResponse
+	if err := s.client.Get(ctx, path, &out); err != nil {
+		return nil, err
+	}
+	return &out, nil
+}
+
+// IterRepoTasks returns an iterator over all action tasks for a repository.
+func (s *ActionsService) IterRepoTasks(ctx context.Context, owner, repo string) iter.Seq2[types.ActionTask, error] {
+	return func(yield func(types.ActionTask, error) bool) {
+		const limit = 50
+		var seen int64
+		for page := 1; ; page++ {
+			resp, err := s.ListRepoTasks(ctx, owner, repo, ListOptions{Page: page, Limit: limit})
+			if err != nil {
+				yield(*new(types.ActionTask), err)
+				return
+			}
+			for _, item := range resp.Entries {
+				if !yield(*item, nil) {
+					return
+				}
+				seen++
+			}
+			if resp.TotalCount > 0 {
+				if seen >= resp.TotalCount {
+					return
+				}
+				continue
+			}
+			if len(resp.Entries) < limit {
+				return
+			}
+		}
+	}
+}