57d8af13ad
Add ListIter in pagination + generic Resource.Iter for streaming paginated results as iter.Seq2[T, error]. Add Iter* methods across all service files (actions, admin, branches, issues, labels, notifs, orgs, packages, pulls, releases, repos, teams, users, webhooks). Modernise cmd/forgegen with slices.Sort, maps.Keys, strings.FieldsFuncSeq. Co-Authored-By: Gemini <noreply@google.com> Co-Authored-By: Virgil <virgil@lethean.io>
59 lines
2.2 KiB
Go
59 lines
2.2 KiB
Go
package forge
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"iter"
|
|
|
|
"forge.lthn.ai/core/go-forge/types"
|
|
)
|
|
|
|
// PackageService handles package registry operations via the Forgejo API.
|
|
// No Resource embedding — paths vary by operation.
|
|
type PackageService struct {
|
|
client *Client
|
|
}
|
|
|
|
func newPackageService(c *Client) *PackageService {
|
|
return &PackageService{client: c}
|
|
}
|
|
|
|
// List returns all packages for a given owner.
|
|
func (s *PackageService) List(ctx context.Context, owner string) ([]types.Package, error) {
|
|
path := fmt.Sprintf("/api/v1/packages/%s", owner)
|
|
return ListAll[types.Package](ctx, s.client, path, nil)
|
|
}
|
|
|
|
// Iter returns an iterator over all packages for a given owner.
|
|
func (s *PackageService) Iter(ctx context.Context, owner string) iter.Seq2[types.Package, error] {
|
|
path := fmt.Sprintf("/api/v1/packages/%s", owner)
|
|
return ListIter[types.Package](ctx, s.client, path, nil)
|
|
}
|
|
|
|
// Get returns a single package by owner, type, name, and version.
|
|
func (s *PackageService) Get(ctx context.Context, owner, pkgType, name, version string) (*types.Package, error) {
|
|
path := fmt.Sprintf("/api/v1/packages/%s/%s/%s/%s", owner, pkgType, name, version)
|
|
var out types.Package
|
|
if err := s.client.Get(ctx, path, &out); err != nil {
|
|
return nil, err
|
|
}
|
|
return &out, nil
|
|
}
|
|
|
|
// Delete removes a package by owner, type, name, and version.
|
|
func (s *PackageService) Delete(ctx context.Context, owner, pkgType, name, version string) error {
|
|
path := fmt.Sprintf("/api/v1/packages/%s/%s/%s/%s", owner, pkgType, name, version)
|
|
return s.client.Delete(ctx, path)
|
|
}
|
|
|
|
// ListFiles returns all files for a specific package version.
|
|
func (s *PackageService) ListFiles(ctx context.Context, owner, pkgType, name, version string) ([]types.PackageFile, error) {
|
|
path := fmt.Sprintf("/api/v1/packages/%s/%s/%s/%s/files", owner, pkgType, name, version)
|
|
return ListAll[types.PackageFile](ctx, s.client, path, nil)
|
|
}
|
|
|
|
// IterFiles returns an iterator over all files for a specific package version.
|
|
func (s *PackageService) IterFiles(ctx context.Context, owner, pkgType, name, version string) iter.Seq2[types.PackageFile, error] {
|
|
path := fmt.Sprintf("/api/v1/packages/%s/%s/%s/%s/files", owner, pkgType, name, version)
|
|
return ListIter[types.PackageFile](ctx, s.client, path, nil)
|
|
}
|