src/api/v1.go: rename file to eosio_v1.go

src/api/eosio_v1.go

@@ -0,0 +1,76 @@
+
+package api
+
+import (
+    "fmt"
+    "github.com/eosswedenorg/eosio-api-healthcheck/src/utils"
+    "github.com/eosswedenorg-go/haproxy/agentcheck"
+    "github.com/eosswedenorg-go/eosapi"
+)
+
+type EosioV1 struct {
+    utils.Time
+    params eosapi.ReqParams
+    block_time float64
+}
+
+func NewEosioV1(url string, host string, block_time float64) EosioV1 {
+    return EosioV1{
+        params: eosapi.ReqParams{
+            Url: url,
+            Host: host,
+        },
+        block_time: block_time,
+    }
+}
+
+func (e EosioV1) LogInfo() LogParams {
+    p := LogParams{
+        "type", "eosio-v1",
+        "url", e.params.Url,
+    }
+
+    if len(e.params.Host) > 0 {
+        p.Add("host", e.params.Host)
+    }
+
+    p.Add("block_time", e.block_time)
+
+    return p
+}
+
+func (e EosioV1) Call() (agentcheck.Response, string) {
+
+    info, err := eosapi.GetInfo(e.params)
+    if err != nil {
+        resp := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "")
+        return resp, err.Error()
+    }
+
+    // Check HTTP Status Code
+    if info.HTTPStatusCode > 299 {
+
+        resp := agentcheck.NewStatusMessageResponse(agentcheck.Down, "")
+
+        msg := "Taking offline because %v was received from backend"
+        return resp, fmt.Sprintf(msg, info.HTTPStatusCode)
+    }
+
+    // Validate head block.
+    diff := e.GetTime().Sub(info.HeadBlockTime).Seconds()
+
+    if diff > e.block_time {
+
+        resp := agentcheck.NewStatusMessageResponse(agentcheck.Down, "")
+
+        msg := "Taking offline because head block is lagging %.0f seconds"
+        return resp, fmt.Sprintf(msg, diff)
+    } else if diff < -e.block_time {
+
+        resp := agentcheck.NewStatusMessageResponse(agentcheck.Down, "")
+
+        msg := "Taking offline because head block is %.0f seconds into the future"
+        return resp, fmt.Sprintf(msg, diff)
+    }
+    return agentcheck.NewStatusResponse(agentcheck.Up), "OK"
+}