added log and print statements for debugging
This commit is contained in:
@@ -1,6 +1,7 @@
|
|||||||
package repomaint
|
package repomaint
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"log/slog"
|
"log/slog"
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
@@ -42,26 +43,32 @@ func (r *RepoSync) Sync() error {
|
|||||||
|
|
||||||
for _, repo := range r.repos {
|
for _, repo := range r.repos {
|
||||||
// create map of pkgname to filenames from current db
|
// create map of pkgname to filenames from current db
|
||||||
|
slog.Info("getting list of cached pkgs", "repo", repo)
|
||||||
cachedPkgs, err := r.buildMap(repo)
|
cachedPkgs, err := r.buildMap(repo)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
// pass through to cover initialization of repos
|
// pass through to cover initialization of repos
|
||||||
slog.Warn("failed to read current db", "err", err)
|
slog.Warn("failed to read current db", "err", err)
|
||||||
}
|
}
|
||||||
|
fmt.Printf("cached pkgs: %v", cachedPkgs)
|
||||||
|
|
||||||
// call cache db fetch
|
// call cache db fetch
|
||||||
|
slog.Info("refreshing databases")
|
||||||
if err := r.c.FetchDB(); err != nil {
|
if err := r.c.FetchDB(); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// pkgsToUpdate slice contains relative paths like
|
// pkgsToUpdate slice contains relative paths like
|
||||||
// <repo>/os/<arch>/filename
|
// <repo>/os/<arch>/filename
|
||||||
|
slog.Info("checking for updates")
|
||||||
pkgsToUpdate, err := r.updatablePkgs(repo, cachedPkgs)
|
pkgsToUpdate, err := r.updatablePkgs(repo, cachedPkgs)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
slog.Warn("failed to get updatable pkgs list", "err", err)
|
slog.Warn("failed to get updatable pkgs list", "err", err)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
fmt.Printf("updatable pkgs: %v", pkgsToUpdate)
|
||||||
|
|
||||||
for _, fileName := range pkgsToUpdate {
|
for _, fileName := range pkgsToUpdate {
|
||||||
|
slog.Debug("fetching pkgs", "pkg", fileName)
|
||||||
path := filepath.Join(repo, repoArch, fileName)
|
path := filepath.Join(repo, repoArch, fileName)
|
||||||
_, err := r.c.Fetch(path)
|
_, err := r.c.Fetch(path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -69,6 +76,7 @@ func (r *RepoSync) Sync() error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
slog.Info("finished pkg update")
|
||||||
|
|
||||||
// call cache cleanup
|
// call cache cleanup
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user