recieve a gitpb.Repos protobufv0.0.5

3 files changed, 25 insertions, 1 deletions

diff --git a/Makefile b/Makefile
index 758dc1b..4228b70 100644
--- a/Makefile
+++ b/Makefile
@@ -27,7 +27,7 @@ install:
 
 log:
 	@#systemctl status forged.service
-	journalctl -f -xeu forged.service
+	journalctl -n 100 -f -xeu forged.service
 
 enable:
 	systemctl enable forged.service
diff --git a/doPatchsets.go b/doPatchsets.go
index 53e2789..55a1f0a 100644
--- a/doPatchsets.go
+++ b/doPatchsets.go
@@ -9,6 +9,7 @@ import (
 
 	"go.wit.com/lib/gui/shell"
 	"go.wit.com/lib/protobuf/forgepb"
+	"go.wit.com/lib/protobuf/gitpb"
 	"go.wit.com/log"
 )
 
@@ -164,3 +165,18 @@ func savePatchset(w http.ResponseWriter, msg []byte) {
 	regfile.Write(msg)
 	regfile.Close()
 }
+
+func lookupRepos(w http.ResponseWriter, msg []byte) (*gitpb.Repos, error) {
+	log.Info("proto.Unmarshal() try message len", len(msg))
+	m := gitpb.NewRepos()
+	if err := m.Unmarshal(msg); err != nil {
+		log.Info("gitpb.Repos.Unmarshal() failed. len(msg) =", len(msg), err)
+		return m, err
+	}
+	log.Info("GOT repos:", len(msg))
+	for repo := range m.IterAll() {
+		log.Infof("repo:%s,%s\n", repo.Namespace, repo.FullPath)
+		// fmt.Fprintln(w, "repo:", repo.FullPath, repo.Namespace)
+	}
+	return m, nil
+}
diff --git a/http.go b/http.go
index fae1800..030983e 100644
--- a/http.go
+++ b/http.go
@@ -38,10 +38,18 @@ func okHandler(w http.ResponseWriter, r *http.Request) {
 		listPatchsets(w)
 		return
 	}
+
 	if route == "/patchset" {
 		savePatchset(w, msg)
 		return
 	}
+
+	if route == "/lookup" {
+		// repos, err := lookupRepos(w, msg)
+		lookupRepos(w, msg)
+		return
+	}
+
 	if route == "/GetPatchsets" {
 		doSendPatchsets(w)
 		return