eosswedenorg/antelope-api-healthcheck
1
0
Fork 0
mirror of https://github.com/eosswedenorg/antelope-api-healthcheck synced 2026-07-03 11:53:43 +02:00
Code Releases Activity

src/server.go: don't fallback to v1 api, return error on invalid api instead.

Browse source
This commit is contained in:
Henrik Hautakoski 2022-02-21 13:34:45 +01:00
parent f6aabb7ed8
commit be945886e4
No known key found for this signature in database
GPG key ID: 608414D93E862CCD
1 changed files with 12 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

18
src/server.go
View file

@ -17,16 +17,16 @@ type arguments struct {
block_time int block_time int
} }
func createApi(a *arguments) api.ApiInterface { func createApi(a *arguments) (api.ApiInterface, error) {
switch a.api { switch a.api {
case "contract": case "v1":
return api.NewEosioContract(a.url, float64(a.block_time)) return api.NewEosioV1(eosapi.ReqParams{Url: a.url, Host: a.host}, float64(a.block_time)), nil
case "v2": case "v2":
return api.NewEosioV2(eosapi.ReqParams{Url: a.url, Host: a.host}, int64(a.block_time / 2)) return api.NewEosioV2(eosapi.ReqParams{Url: a.url, Host: a.host}, int64(a.block_time / 2)), nil
} }
return api.NewEosioV1(eosapi.ReqParams{Url: a.url, Host: a.host}, float64(a.block_time)) return nil, fmt.Errorf("Invalid API '%s'", a.api)
} }
// onTcpMessage callback function // onTcpMessage callback function
@ -77,7 +77,13 @@ func onTcpMessage(c *tcp_server.Client, args string) {
// Check api. // Check api.
// ------------------- // -------------------
healthCheckApi := createApi(&a) healthCheckApi, err := createApi(&a)
if err != nil {
logger.Warn("Agent request error", "message", err)
c.WriteString(fmt.Sprintf("%s#%s\n", haproxy.HealthCheckFailed, err))
c.Close()
return
}
status, msg := healthCheckApi.Call() status, msg := healthCheckApi.Call()