diff options
Diffstat (limited to 'http.go')
| -rw-r--r-- | http.go | 26 |
1 files changed, 26 insertions, 0 deletions
@@ -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 } |
