summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJeff Carr <[email protected]>2025-08-28 19:28:13 -0500
committerJeff Carr <[email protected]>2025-08-28 19:30:59 -0500
commita94208a768942cce7b5fce94ecadbbfa67119473 (patch)
tree44d3a27780b5269c0c97cab1e780fb592223304d
parent9025bf436a22a4209f1df477aee006cfaa96b270 (diff)
more dumping and redoing patchset codev0.0.17v0.0.16v0.0.15v0.0.14v0.0.13
-rw-r--r--doPatchsets.go52
-rw-r--r--http.go14
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
}