start UpdatePB()

http.go

@@ -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()
 

init.go

@@ -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")
+		f.forgeURL = os.Getenv("FORGE_URL")
-		log.Info("got forge url", forgeURL)
+		log.Info("got forge url", f.forgeURL)
 	}
 }
 

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 {

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)

structs.go

@@ -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
 }