summaryrefslogtreecommitdiff
path: root/http.go
diff options
context:
space:
mode:
Diffstat (limited to 'http.go')
-rw-r--r--http.go35
1 files changed, 14 insertions, 21 deletions
diff --git a/http.go b/http.go
index 363ab71..37843f4 100644
--- a/http.go
+++ b/http.go
@@ -19,15 +19,16 @@ func cleanURL(url string) string {
func okHandler(w http.ResponseWriter, r *http.Request) {
var route string
route = cleanURL(r.URL.Path)
+ log.HttpMode(w)
+ defer log.HttpMode(nil)
if route == "/uptime" {
ok, s := uptimeCheck()
+ log.Info(s)
if ok {
- log.Info("Handling URL:", route, "cluster is ok", s)
- fmt.Fprintln(w, s)
+ log.Info("Handling URL:", route, "cluster is ok")
} else {
- log.Info("Handling URL:", route, "cluster is not right yet", s)
- fmt.Fprintln(w, s)
+ log.Info("Handling URL:", route, "cluster is not right yet")
}
return
}
@@ -36,50 +37,44 @@ func okHandler(w http.ResponseWriter, r *http.Request) {
hostname := r.URL.Query().Get("hostname")
if hostname == "" {
log.Warn("start failed. hostname is blank", cleanURL(r.URL.Path))
- fmt.Fprintln(w, "start failed. hostname is blank", cleanURL(r.URL.Path))
return
}
log.Warn("hostname is", hostname)
- fmt.Fprintln(w, "hostname is", hostname)
// log.Warn("Handling URL:", tmp, "start droplet", start)
result, err := Start(hostname)
if err == nil {
- fmt.Fprintln(w, result)
- fmt.Fprintln(w, hostname, "started output ok")
- fmt.Fprintln(w, hostname, "need to parse the output here")
- fmt.Fprintln(w, hostname, "todo: switch to protobuf here")
+ log.Info(result)
+ log.Info(hostname, "started output ok")
+ log.Info(hostname, "need to parse the output here")
+ log.Info(hostname, "todo: switch to protobuf here")
} else {
- fmt.Fprintln(w, result)
- fmt.Fprintln(w, err)
- fmt.Fprintln(w, hostname, "start failed")
+ log.Info(result)
+ log.Info(err)
+ log.Info(hostname, "start failed")
}
return
}
if route == "/import" {
log.Info("virtigo import starts here")
- fmt.Fprintln(w, "virtigo import starts here")
result, err := importDomain(w, r)
if err != nil {
log.Info("virtigo import failed")
log.Info(result)
- fmt.Fprintln(w, "virtigo import failed")
- fmt.Fprintln(w, result)
return
}
log.Info("virtigo import worked")
- fmt.Fprintln(w, "virtigo import worked")
return
}
// toggle poll logging
if route == "/poll" {
if POLL.Get() {
- fmt.Fprintln(w, "POLL is true")
+ log.Info("POLL is true")
POLL.SetBool(false)
} else {
- fmt.Fprintln(w, "POLL is false")
+ log.Info("POLL is false")
POLL.SetBool(true)
}
return
@@ -117,7 +112,6 @@ func okHandler(w http.ResponseWriter, r *http.Request) {
if route == "/quit" {
log.Warn("writing out config file and exiting virtigo")
- fmt.Fprintln(w, "writing out config file and exiting virtigo")
if err := me.cluster.ConfigSave(); err != nil {
log.Info("configsave error", err)
} else {
@@ -140,7 +134,6 @@ func okHandler(w http.ResponseWriter, r *http.Request) {
}
log.Warn("BAD URL =", route)
- fmt.Fprintln(w, "BAD URL tmp =", route)
}
// write a file out to the http socket