From c2e0e8e80b5831996da38efbfaa4bb206875bf40 Mon Sep 17 00:00:00 2001 From: Jeff Carr Date: Sun, 7 Sep 2025 19:14:20 -0500 Subject: start using a standard http PB --- handlePatches.go | 26 ++++++++++++++++++++++++++ 1 file changed, 26 insertions(+) (limited to 'handlePatches.go') diff --git a/handlePatches.go b/handlePatches.go index 730d04f..5d07924 100644 --- a/handlePatches.go +++ b/handlePatches.go @@ -5,10 +5,30 @@ import ( "strings" "go.wit.com/lib/protobuf/forgepb" + "go.wit.com/lib/protobuf/gitpb" "go.wit.com/lib/protobuf/httppb" "go.wit.com/log" ) +func addNewPatches(pb *forgepb.Patches, reqPB *httppb.HttpRequest) *forgepb.Patches { + newPatchesPB := new(forgepb.Patches) + for newpatch := range pb.IterAll() { + me.forge.AddNewPatch(newpatch) + newPatchesPB.Append(newpatch) + } + return newPatchesPB +} + +func sendPendingPatches(pb *forgepb.Patches, reqPB *httppb.HttpRequest) *forgepb.Patches { + allPatchesPB := new(forgepb.Patches) + for pset := range me.forge.Patchsets.IterAll() { + for newpatch := range pset.Patches.IterAll() { + allPatchesPB.Append(newpatch) + } + } + return allPatchesPB +} + func handlePatches(w http.ResponseWriter, pb *forgepb.Patches) error { route := pb.HttpRequest.Route @@ -23,6 +43,12 @@ func handlePatches(w http.ResponseWriter, pb *forgepb.Patches) error { return nil } +func makeReposPB(reqPB *httppb.HttpRequest) (*gitpb.Repos, error) { + pb := gitpb.NewRepos() + err := pb.Unmarshal(reqPB.Body) + return pb, err +} + func makePatchesPB(reqPB *httppb.HttpRequest) (*forgepb.Patches, error) { pb := forgepb.NewPatches() err := pb.Unmarshal(reqPB.Body) -- cgit v1.2.3