tools
/
out-of-tree
1
0
Fork 0
Code Releases Activity

feat: support for ignoring packages exists on the mirror

master
dump_stack() 2023-05-15 13:12:56 +00:00
parent d118ab03c3
commit 346e24db6b
Signed by: dump_stack
GPG Key ID: BE44DA8C062D87DC
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
distro.go
View File

@ -8,6 +8,8 @@ import (
"github.com/cavaliergopher/grab/v3"
"github.com/rs/zerolog/log"
"code.dumpstack.io/tools/out-of-tree/cache"
"code.dumpstack.io/tools/out-of-tree/config"
"code.dumpstack.io/tools/out-of-tree/distro/debian"
"code.dumpstack.io/tools/out-of-tree/distro/debian/snapshot"
"code.dumpstack.io/tools/out-of-tree/fs"
@ -48,6 +50,8 @@ func (cmd *DebianCacheCmd) Run() (err error) {
type DebianGetDebCmd struct {
Path string `help:"path to download directory" type:"existingdir" default:"./"`
Regexp string `help:"match deb pkg names by regexp" default:".*"`
IgnoreCached bool `help:"ignore packages found on remote mirror"`
}
func (cmd DebianGetDebCmd) Run() (err error) {
@ -68,6 +72,7 @@ func (cmd DebianGetDebCmd) Run() (err error) {
if !re.MatchString(pkg.Deb.Name) {
continue
}
packages = append(packages, pkg)
}
}
@ -79,6 +84,15 @@ func (cmd DebianGetDebCmd) Run() (err error) {
defer os.RemoveAll(tmp)
for _, pkg := range packages {
if cmd.IgnoreCached {
log.Debug().Msgf("check cache for %s", pkg.Deb.Name)
found, _ := cache.PackageURL(config.Debian, pkg.Deb.URL)
if found {
log.Debug().Msgf("%s already cached", pkg.Deb.Name)
continue
}
}
target := filepath.Join(cmd.Path, filepath.Base(pkg.Deb.URL))
if fs.PathExists(target) {