mirror of
https://github.com/git-pkgs/proxy.git
synced 2026-08-23 04:14:57 -04:00
272e6d9040* Bump go tool golangci-lint to v2.13.1
The .golangci.yml goconst.ignore-tests setting was added in v2.12.0
(golangci/golangci-lint#6480). On the previously pinned v2.10.1,
config verify fails with "additional properties 'ignore-tests' not
allowed" and the setting is silently ignored at run time, so goconst
counts test-file literals toward min-occurrences.
* Apply gofmt and CutSuffix simplification
- gofmt -w internal/server/health_test.go
- Replace HasSuffix+TrimSuffix with CutSuffix in ParseSize
* Remove dead code and migrate tests off legacy Filesystem storage
Migrate the three test call sites of storage.NewFilesystem to
storage.OpenBucket("file://...") and drop the deprecated
StorageConfig.Path field from test configs, then delete code that
deadcode reports as unreachable from cmd/proxy:
- internal/storage/filesystem.go and its tests
- storage.HashingReader
- enrichment.Service.BulkCheckVulnerabilities and NormalizeLicense
- server.ActiveRequestsMiddleware (no-op body; the real tracking
is the inline r.Use at server.go:226)
- mirror.RegistrySource (unimplemented stub)
metrics.UpdateCircuitBreakerState and RecordCircuitBreakerTrip are
kept because #275 wires them.
Update the CONTRIBUTING.md storage section to reflect blob.go.
80 lines
2.7 KiB
Go
80 lines
2.7 KiB
Go
// Package storage provides artifact storage backends for the proxy cache.
|
|
//
|
|
// Storage backends are accessed via gocloud.dev/blob URLs:
|
|
//
|
|
// - file:///path/to/dir - Local filesystem storage
|
|
// - s3://bucket-name - Amazon S3
|
|
// - s3://bucket?endpoint=http://localhost:9000 - S3-compatible (MinIO)
|
|
//
|
|
// Use OpenBucket to create a storage backend from a URL.
|
|
package storage
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"io"
|
|
"time"
|
|
)
|
|
|
|
const dirPermissions = 0755
|
|
|
|
var (
|
|
ErrNotFound = errors.New("artifact not found")
|
|
|
|
// ErrSignedURLUnsupported is returned by SignedURL when the backend
|
|
// cannot generate presigned URLs (e.g. local filesystem).
|
|
ErrSignedURLUnsupported = errors.New("signed URLs not supported by storage backend")
|
|
)
|
|
|
|
// ObjectInfo contains metadata for a stored object.
|
|
type ObjectInfo struct {
|
|
Path string
|
|
Size int64
|
|
ModTime time.Time
|
|
}
|
|
|
|
// Storage defines the interface for artifact storage backends.
|
|
type Storage interface {
|
|
// Store writes content from r to the given path.
|
|
// Returns the number of bytes written and the SHA256 hash of the content.
|
|
Store(ctx context.Context, path string, r io.Reader) (size int64, hash string, err error)
|
|
|
|
// Open returns a reader for the content at path.
|
|
// The caller must close the reader when done.
|
|
// Returns ErrNotFound if the path does not exist.
|
|
Open(ctx context.Context, path string) (io.ReadCloser, error)
|
|
|
|
// Exists returns true if content exists at path.
|
|
Exists(ctx context.Context, path string) (bool, error)
|
|
|
|
// Delete removes the content at path.
|
|
// Returns nil if the path does not exist.
|
|
Delete(ctx context.Context, path string) error
|
|
|
|
// Size returns the size in bytes of content at path.
|
|
// Returns ErrNotFound if the path does not exist.
|
|
Size(ctx context.Context, path string) (int64, error)
|
|
|
|
// SignedURL returns a presigned URL granting time-limited GET access to path.
|
|
// Returns ErrSignedURLUnsupported if the backend cannot generate presigned URLs.
|
|
SignedURL(ctx context.Context, path string, expiry time.Duration) (string, error)
|
|
|
|
// UsedSpace returns the total bytes used by all stored content.
|
|
UsedSpace(ctx context.Context) (int64, error)
|
|
|
|
// URL returns the storage backend URL (e.g. "file:///path" or "s3://bucket").
|
|
URL() string
|
|
|
|
// Close releases any resources held by the storage backend.
|
|
Close() error
|
|
}
|
|
|
|
// ArtifactPath builds a storage path for an artifact.
|
|
// Format: {ecosystem}/{namespace}/{name}/{version}/{filename}
|
|
// For packages without namespace: {ecosystem}/{name}/{version}/{filename}
|
|
func ArtifactPath(ecosystem, namespace, name, version, filename string) string {
|
|
if namespace != "" {
|
|
return ecosystem + "/" + namespace + "/" + name + "/" + version + "/" + filename
|
|
}
|
|
return ecosystem + "/" + name + "/" + version + "/" + filename
|
|
}
|