mirror of
https://github.com/git-pkgs/proxy.git
synced 2026-11-09 15:49:16 -05:00
e9aa078a85
A pkg:git version can now be a tag as well as a full commit ID. With a version, the submodules the commit records are mirrored at the commits it pins, from the upstream.git hosts serving them; one no host serves is skipped with a warning.
49 lines
1.6 KiB
Go
49 lines
1.6 KiB
Go
package mirror
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
|
|
"github.com/git-pkgs/proxy/internal/gitcache"
|
|
)
|
|
|
|
// GitMirrorer caches Git repositories for pkg:git items. location is the
|
|
// repository's host and path, such as codeberg.org/forgejo/forgejo, and
|
|
// version a full commit ID or a tag, or empty to cache the repository's
|
|
// branches and tags only.
|
|
type GitMirrorer interface {
|
|
Mirror(ctx context.Context, location, version string) (gitcache.MirrorResult, error)
|
|
}
|
|
|
|
// UnavailableGit fails every pkg:git item with Reason.
|
|
type UnavailableGit struct {
|
|
Reason string
|
|
}
|
|
|
|
func (u UnavailableGit) Mirror(context.Context, string, string) (gitcache.MirrorResult, error) {
|
|
return gitcache.MirrorResult{}, errors.New(u.Reason)
|
|
}
|
|
|
|
var errNoGitUpstream = errors.New("git repositories are mirrored from upstream.git, and none is configured")
|
|
|
|
// mirrorGit caches a pkg:git repository, and the commit its version names
|
|
// with the submodules it pins, in the cache /git serves clones from.
|
|
func (m *Mirror) mirrorGit(ctx context.Context, pv PackageVersion, tracker *progressTracker) {
|
|
if m.Git == nil {
|
|
m.recordFailure(tracker, pv, errNoGitUpstream)
|
|
return
|
|
}
|
|
result, err := m.Git.Mirror(ctx, pv.Name, pv.Version)
|
|
if err != nil {
|
|
m.recordFailure(tracker, pv, err)
|
|
return
|
|
}
|
|
if result.Cached {
|
|
tracker.skipped.Add(1)
|
|
m.logger.Debug("already cached", "ecosystem", pv.Ecosystem, "name", pv.Name, "version", pv.Version)
|
|
return
|
|
}
|
|
tracker.completed.Add(1)
|
|
tracker.bytes.Add(result.Bytes)
|
|
m.logger.Info("mirrored", "ecosystem", pv.Ecosystem, "name", pv.Name, "version", pv.Version, "size", result.Bytes)
|
|
}
|