From a94208a768942cce7b5fce94ecadbbfa67119473 Mon Sep 17 00:00:00 2001 From: Jeff Carr Date: Thu, 28 Aug 2025 19:28:13 -0500 Subject: [PATCH] more dumping and redoing patchset code --- doPatchsets.go | 52 -------------------------------------------------- http.go | 14 +++++++++++++- 2 files changed, 13 insertions(+), 53 deletions(-) diff --git a/doPatchsets.go b/doPatchsets.go index 9ad2395..19e4815 100644 --- a/doPatchsets.go +++ b/doPatchsets.go @@ -14,58 +14,6 @@ import ( "google.golang.org/protobuf/proto" ) -func doSendPatchsets(w http.ResponseWriter) { - // log.HttpMode(w) - // defer log.HttpMode(nil) - - dirname := filepath.Join(LIBDIR, "patchset/") - // Open the directory - entries, err := os.ReadDir(dirname) - if err != nil { - log.Printf("Error reading directory: %v\n", err) - return - } - - var psets *forgepb.Patchsets - psets = forgepb.NewPatchsets() // this sets the proper handshake protobuf UUID - - // Iterate through the directory entries - for _, entry := range entries { - // Check if the entry is a file and matches the *.pb pattern - if !entry.IsDir() && filepath.Ext(entry.Name()) == ".pb" { - bytes, err := os.ReadFile(filepath.Join(dirname, entry.Name())) - if err != nil { - fmt.Fprintln(w, entry.Name(), err) - fmt.Println(entry.Name(), err) - continue - } - var p *forgepb.Patchset - p = new(forgepb.Patchset) - err = p.Unmarshal(bytes) - if err != nil { - fmt.Fprintln(w, entry.Name(), err) - fmt.Println(entry.Name(), err) - continue - } - - psets.Append(p) - } - } - - // marshal the protobuf to xfer over the socket - data, err := psets.Marshal() - if err != nil { - log.Info("patchsets.Marshal() to wire failed", err) - return - } - - start := time.Now() - log.Info("going to w.Write(data) with len", len(data)) - w.Write(data) - age := shell.FormatDuration(time.Since(start)) - log.Printf("Done with xfer in (%s). happy hacking!\n", age) -} - func getPatchset(w http.ResponseWriter, pbname string) { if pbname == "" { fmt.Fprintf(w, "filename was empty") diff --git a/http.go b/http.go index eb4e14c..2bf81af 100644 --- a/http.go +++ b/http.go @@ -5,7 +5,9 @@ import ( "io/ioutil" "net/http" "strings" + "time" + "go.wit.com/lib/gui/shell" "go.wit.com/log" ) @@ -84,7 +86,17 @@ func okHandler(w http.ResponseWriter, r *http.Request) { } if route == "/GetPatchsets" { - doSendPatchsets(w) + data, err := me.forge.Patchsets.Marshal() + if err != nil { + log.Info("patchsets.Marshal() to wire failed", err) + return + } + + start := time.Now() + log.Info("going to w.Write(data) with len", len(data)) + w.Write(data) + age := shell.FormatDuration(time.Since(start)) + log.Printf("Done with xfer in (%s). happy hacking!\n", age) return }