Add timelord healthcheck (#41)

* Add timelord healthcheck

* Fmt

Author: cmmarslender

internal/healthcheck/healthcheck.go

@@ -26,6 +26,9 @@ type Healthcheck struct {
 
 	// Last time we got a successful DNS response
 	lastDNSTime time.Time
+
+	// Time we got a good response from the timelord
+	lastTimelordTime time.Time
 }
 
 // NewHealthcheck returns a new instance of healthcheck
@@ -73,6 +76,7 @@ func (h *Healthcheck) StartServer() error {
 
 	http.HandleFunc("/full_node", h.fullNodeHealthcheck())
 	http.HandleFunc("/seeder", h.seederHealthcheck())
+	http.HandleFunc("/timelord", h.timelordHealthcheck())
 	return http.ListenAndServe(fmt.Sprintf(":%d", h.healthcheckPort), nil)
 }
 
@@ -105,8 +109,6 @@ func (h *Healthcheck) walletReceive(resp *types.WebsocketResponse) {}
 
 func (h *Healthcheck) crawlerReceive(resp *types.WebsocketResponse) {}
 
-func (h *Healthcheck) timelordReceive(resp *types.WebsocketResponse) {}
-
 func (h *Healthcheck) harvesterReceive(resp *types.WebsocketResponse) {}
 
 func (h *Healthcheck) farmerReceive(resp *types.WebsocketResponse) {}
@@ -139,4 +141,3 @@ func timeMetricHealthcheckHelper(lastTime time.Time, w http.ResponseWriter, r *h
 		}
 	}
 }
-

internal/healthcheck/timelord.go

@@ -0,0 +1,27 @@
+package healthcheck
+
+import (
+	"net/http"
+	"time"
+
+	"github.com/chia-network/go-chia-libs/pkg/types"
+)
+
+// timelordReceive gets timelord events
+func (h *Healthcheck) timelordReceive(resp *types.WebsocketResponse) {
+	switch resp.Command {
+	case "finished_pot":
+		h.lastTimelordTime = time.Now()
+	case "skipping_peak":
+		// Fastest timelord
+	case "new_peak":
+		// Not Fastest Timelord
+	}
+}
+
+// timelordHealthcheck endpoint for the timelord service as a whole
+func (h *Healthcheck) timelordHealthcheck() func(http.ResponseWriter, *http.Request) {
+	return func(w http.ResponseWriter, r *http.Request) {
+		timeMetricHealthcheckHelper(h.lastTimelordTime, w, r)
+	}
+}