diff options
| -rw-r--r-- | http.go | 24 | ||||
| -rw-r--r-- | init.go | 6 | ||||
| -rw-r--r-- | patchset.Get.go | 4 | ||||
| -rw-r--r-- | patchset.Send.go | 2 | ||||
| -rw-r--r-- | structs.go | 1 |
5 files changed, 29 insertions, 8 deletions
@@ -42,7 +42,7 @@ func (f *Forge) HttpPost(url string, data []byte) ([]byte, error) { } func (f *Forge) LookupPBorig(check *gitpb.Repos) (*gitpb.Repos, error) { - url := forgeURL + "lookup" + url := f.forgeURL + "lookup" for repo := range check.IterByFullPath() { if repo.Namespace == "" { @@ -54,7 +54,27 @@ func (f *Forge) LookupPBorig(check *gitpb.Repos) (*gitpb.Repos, error) { } func (f *Forge) LookupPB(check *gitpb.Repos) (*gitpb.Repos, error) { - url := forgeURL + "lookup" + url := f.forgeURL + "lookup" + + queryPB := gitpb.NewRepos() + + for repo := range check.IterByFullPath() { + ns := repo.Namespace + if ns == "" { + ns = repo.GoInfo.GoPath + } + + newr := new(gitpb.Repo) + newr.Namespace = ns + + queryPB.AppendByNamespace(newr) + } + + return queryPB.SubmitReposPB(url) +} + +func (f *Forge) UpdatePB(check *gitpb.Repos) (*gitpb.Repos, error) { + url := f.forgeURL + "update" queryPB := gitpb.NewRepos() @@ -139,9 +139,11 @@ func (f *Forge) InitPB() { f.hasFullScan = true } + f.forgeURL = "https://forge.wit.com/" + if os.Getenv("FORGE_URL") != "" { - forgeURL = os.Getenv("FORGE_URL") - log.Info("got forge url", forgeURL) + f.forgeURL = os.Getenv("FORGE_URL") + log.Info("got forge url", f.forgeURL) } } diff --git a/patchset.Get.go b/patchset.Get.go index b0daf29..4ad3c48 100644 --- a/patchset.Get.go +++ b/patchset.Get.go @@ -6,10 +6,8 @@ import ( "go.wit.com/log" ) -var forgeURL string = "https://forge.wit.com/" - func (f *Forge) GetPatchesets() (*Patchsets, error) { - url := forgeURL + "GetPatchsets" + url := f.forgeURL + "GetPatchsets" log.Info("GetPatchsets() url", url) body, err := f.HttpPost(url, nil) if err != nil { diff --git a/patchset.Send.go b/patchset.Send.go index b3d4a96..489f095 100644 --- a/patchset.Send.go +++ b/patchset.Send.go @@ -40,7 +40,7 @@ func (f *Forge) SubmitDevelPatchSet(name string) (*Patchset, error) { func (f *Forge) submitPatchset(pset *Patchset) error { var url string - url = forgeURL + "patchset" + url = f.forgeURL + "patchset" msg, err := pset.Marshal() if err != nil { log.Info("proto.Marshal() failed:", err) @@ -21,6 +21,7 @@ type Forge struct { hasFullScan bool // track last scan so it can be throttled fullscan time.Time // time of the last scan so it can be throttled hostname string // your hostname + forgeURL string // URL to use to forge.wit.com // Machine *zoopb.Machine // things for virtigo to track vm's } |
