From fde780869eddd1f2765c9de3c17c38d67fa76174 Mon Sep 17 00:00:00 2001 From: Jeff Carr Date: Wed, 2 Jul 2025 12:53:34 -0500 Subject: [PATCH] recieve a gitpb.Repos protobuf --- Makefile | 2 +- doPatchsets.go | 16 ++++++++++++++++ http.go | 8 ++++++++ 3 files changed, 25 insertions(+), 1 deletion(-) 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