package main import ( "os" "time" "go.wit.com/lib/gui/shell" "go.wit.com/lib/protobuf/forgepb" "go.wit.com/lib/protobuf/gitpb" "go.wit.com/log" ) func forceReleaseVersion(repo *gitpb.Repo) { if argv.Minor { // if v1.2.3 change to v.1.3.0 repo.IncrementTargetMinor() } else { // if v1.2.3 change to v.1.2.4 if repo.IncrementTargetRevision() { // worked ok } else { log.Info("Failed to increment target revision", repo.GetFullPath()) os.Exit(-1) } } } func rePrepareRelease() { // reload the config me.forge = forgepb.Init() me.found = new(gitpb.Repos) now := time.Now() me.forge.RillFuncError(rillRestore) // slowRestore() log.Printf("showRestore() (%d total repos) took:%s\n", me.forge.Repos.Len(), shell.FormatDuration(time.Since(now))) all := me.forge.Repos.SortByFullPath() for all.Scan() { check := all.Next() if me.forge.Config.IsReadOnly(check.GetGoPath()) { // can't release readonly repos continue } // if master != lastTag, always increment master := check.GetMasterVersion() lastTag := check.GetLastTag() if master != lastTag { forceReleaseVersion(check) me.found.AppendByGoPath(check) continue } if alreadyDone(check) { // means it was already published // protects against logic errors that might result // in an infinite loop log.Info("WARNING already done", check.GetGoPath()) log.Info("WARNING already done", check.GetGoPath()) log.Info("WARNING already done", check.GetGoPath()) continue } if argv.Quick != nil { // if argv has 'quick' don't do anything // that doesn't actually have a patch if master == lastTag { continue } } if argv.Protobuf && check.GetRepoType() == "protobuf" { // if --protobuf, this will force upgrade each one forceReleaseVersion(check) me.found.AppendByGoPath(check) continue } // if the repo is a go binary or plugin for a new release for // any library version change // if check.GetRepoType() == "binary" || check.GetRepoType() == "plugin" { // check if the package dependancies changed, if so, re-publish if me.forge.FinalGoDepsCheckOk(check, false) { log.Printf("go.sum is perfect! %s\n", check.GetGoPath()) continue } log.Printf("dependancy checks indicate a new release is needed for %s\n", check.GetGoPath()) forceReleaseVersion(check) me.found.AppendByGoPath(check) // } } me.forge.PrintHumanTable(me.found) } func printDone() { for _, gopath := range me.done { log.Info("printDone() THESE WERE PUBLISHED", gopath) } log.Sleep(1) } func alreadyDone(repo *gitpb.Repo) bool { for _, gopath := range me.done { // log.Info("WARNING already done", gopath, repo.GetGoPath()) // log.Info("WARNING already done", gopath, repo.GetGoPath()) // log.Info("WARNING already done", gopath, repo.GetGoPath()) if repo.GetGoPath() == gopath { log.Info("FOUND. RETURN TRUE. already done", gopath, repo.GetGoPath()) return true } } return false }