mirrors/utils
1
0
Fork 0
mirror of https://github.com/vbatts/utils.git synced 2024-12-04 22:45:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

slackware-sync: adding a --link-dest=

Browse source
This commit is contained in:
Vincent Batts 2016-11-29 14:25:45 -05:00
parent dab7b38f81
commit d784905c09
2 changed files with 30 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
cmd/slackware-sync/main.go
View file

@ -14,7 +14,7 @@ import (
) )
var ( var (
flSyncDir = flag.String("dir", "", "directory to sync to (this flag overrides the sync_dir in the configuration file)") flSyncDir = flag.String("dir", "", "directory to sync to (this flag overrides the syncDir in the configuration file)")
flConfigFile = flag.String("c", path.Join(os.Getenv("HOME"), ".slackware-sync.toml"), "config file for the sync") flConfigFile = flag.String("c", path.Join(os.Getenv("HOME"), ".slackware-sync.toml"), "config file for the sync")
flThreads = flag.Int("t", 1, "threads to fetch with") flThreads = flag.Int("t", 1, "threads to fetch with")
flQuiet = flag.Bool("q", false, "less output") flQuiet = flag.Bool("q", false, "less output")
@ -34,7 +34,7 @@ func main() {
config.Threads = *flThreads config.Threads = *flThreads
} }
if _, err = EnsureDirExists(config.SyncDir); err != nil { if _, err := EnsureDirExists(config.SyncDir); err != nil {
log.Fatal(err) log.Fatal(err)
} }
@ -66,7 +66,24 @@ func main() {
} }
wg.Done() wg.Done()
}() }()
cmd := exec.Command("rsync", "-avPHS", "--delete", uri.String(), dest+"/") args := []string{
"-avPHS",
"--delete",
}
if mirror.LinkDest != "" {
if linkDestMirror, ok := config.Mirrors[mirror.LinkDest]; ok {
if linkDestURL, err := url.Parse(linkDestMirror.URL); err == nil {
linkDest := path.Join(config.SyncDir, linkDestURL.Host, linkDestURL.Path)
args = append(args, "--link-dest="+linkDest+"/")
} else {
fmt.Fprintf(os.Stderr, "linkDest URL %q does not parse: %s", mirror.LinkDest, err)
}
}
}
args = append(args, uri.String())
args = append(args, dest+"/")
//fmt.Println("rsync", strings.Join(args, " "))
cmd := exec.Command("rsync", args...)
cmd.Stderr = os.Stderr // we'll want to see errors, regardless cmd.Stderr = os.Stderr // we'll want to see errors, regardless
if !*flQuiet { if !*flQuiet {
cmd.Stdout = os.Stdout cmd.Stdout = os.Stdout
@ -103,12 +120,13 @@ func EnsureDirExists(path string) (os.FileInfo, error) {
type GeneralConfig struct { type GeneralConfig struct {
Threads int `toml:"threads"` Threads int `toml:"threads"`
SyncDir string `toml:"sync_dir"` SyncDir string `toml:"syncDir"`
Mirrors map[string]Mirror Mirrors map[string]Mirror
} }
type Mirror struct { type Mirror struct {
Title string `toml:"title"` Title string `toml:"title"`
URL string `toml:"url"` URL string `toml:"url"`
Enabled bool `toml:"enabled"` Enabled bool `toml:"enabled"`
LinkDest string `toml:"linkDest"`
} }

9
cmd/slackware-sync/slackware-sync.toml
View file

@ -1,5 +1,5 @@
threads = 2 threads = 2
sync_dir = "/mnt/storage/slackware" syncDir = "/mnt/storage/slackware"
[mirrors] [mirrors]
@ -11,11 +11,12 @@ sync_dir = "/mnt/storage/slackware"
url = "rsync://slackware.osuosl.org/slackware/slackware64-current/" url = "rsync://slackware.osuosl.org/slackware/slackware64-current/"
enabled = true enabled = true
[mirrors.slackware64_14.1] [mirrors.slackware64_14_1]
url = "rsync://slackware.osuosl.org/slackware/slackware64-14.1/" url = "rsync://slackware.osuosl.org/slackware/slackware64-14.1/"
enabled = true enabled = false
[mirrors.slackware32] [mirrors.slackware32]
url = "rsync://slackware.osuosl.org/slackware/slackware-current/" url = "rsync://slackware.osuosl.org/slackware/slackware-current/"
enabled = false linkDest = "slackware64"
enabled = true