summaryrefslogtreecommitdiff
path: root/http.go
diff options
context:
space:
mode:
Diffstat (limited to 'http.go')
-rw-r--r--http.go26
1 files changed, 26 insertions, 0 deletions
diff --git a/http.go b/http.go
index af3d16f..6f40f0a 100644
--- a/http.go
+++ b/http.go
@@ -32,6 +32,24 @@ func okHandler(w http.ResponseWriter, r *http.Request) {
return
}
+ if route == "/machine" {
+ var m *zoopb.Machine
+ m = new(zoopb.Machine)
+ if err := m.Unmarshal(msg); err != nil {
+ log.Info("proto.Unmarshal() failed on wire message len", len(msg), "from", hostname)
+ return
+ }
+ if m.Packages == nil {
+ log.Info("Unmarshal worked with msg len", len(msg), "from", m.Hostname)
+ log.Info(m.Hostname, "sent machine")
+ } else {
+
+ log.Info("Unmarshal worked with msg len", len(msg), "from", m.Hostname)
+ log.Info(m.Hostname, "has", m.Packages.Len(), "packages installed")
+ }
+ return
+ }
+
if route == "/status" {
if hostname == "" {
// ignore junk
@@ -47,6 +65,14 @@ func okHandler(w http.ResponseWriter, r *http.Request) {
log.Info("Unmarshal worked with msg len", len(msg), "from", hostname)
log.Info(hostname, "has", packs.Len(), "packages installed")
+ fmt.Fprintln(w, "upgrade")
+
+ m := me.machines.FindByName(hostname)
+ if m == nil {
+ log.Info("did not find", hostname)
+ } else {
+ log.Info("found", hostname)
+ }
return
}