zood/send.go

71 lines
1.4 KiB
Go
Raw Normal View History

2024-11-15 19:25:24 -06:00
// Copyright 2024 WIT.COM Inc Licensed GPL 3.0
package main
import (
"strings"
"go.wit.com/log"
)
2024-11-16 10:31:02 -06:00
var urlbase string = "http://zookeeper.wit.com:8080"
2024-11-15 19:25:24 -06:00
func send() {
}
func pingStatus() error {
var url string
2024-11-15 20:59:42 -06:00
url = urlbase + "/status?hostname=" + me.hostname
2024-11-15 21:05:03 -06:00
msg, err := me.machine.Packages.Marshal()
2024-11-15 19:52:46 -06:00
if err != nil {
log.Info("proto.Marshal() failed:", err)
return err
}
log.Info("proto Marshal len =", len(msg))
body, err := httpPost(url, msg)
2024-11-15 19:25:24 -06:00
if err != nil {
log.Info("httpPost() failed:", err)
return err
}
test := strings.TrimSpace(string(body))
// log.Info("virtigo returned body:", test)
for _, line := range strings.Split(test, "\n") {
2024-11-15 20:59:42 -06:00
switch line {
case "upgrade":
log.Info("should upgrade now")
default:
log.Info("GOT:", line)
}
}
return nil
}
func sendMachine() error {
var url string
url = urlbase + "/machine"
msg, err := me.machine.Marshal()
if err != nil {
log.Info("proto.Marshal() failed:", err)
return err
}
log.Info("proto Marshal len =", len(msg))
body, err := httpPost(url, msg)
if err != nil {
log.Info("httpPost() failed:", err)
return err
}
test := strings.TrimSpace(string(body))
// log.Info("virtigo returned body:", test)
for _, line := range strings.Split(test, "\n") {
switch line {
case "upgrade":
log.Info("machine upgrade now")
default:
log.Info("GOT:", line)
}
2024-11-15 19:25:24 -06:00
}
return nil
}