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: remove support for old format.

Browse source
This commit is contained in:
Henrik Hautakoski 2022-08-15 13:34:49 +02:00
parent b1f39ea9fe
commit 303995ffda
No known key found for this signature in database
GPG key ID: 608414D93E862CCD
1 changed files with 13 additions and 54 deletions
Download patch file Download diff file Expand all files Collapse all files

67
src/server.go
View file

@ -4,7 +4,6 @@ import (
"fmt" "fmt"
"strings" "strings"
"strconv" "strconv"
"github.com/eosswedenorg/eosio-api-healthcheck/src/utils"
"github.com/eosswedenorg/eosio-api-healthcheck/src/api" "github.com/eosswedenorg/eosio-api-healthcheck/src/api"
"github.com/eosswedenorg-go/eosapi" "github.com/eosswedenorg-go/eosapi"
"github.com/eosswedenorg-go/haproxy/agentcheck" "github.com/eosswedenorg-go/haproxy/agentcheck"
@ -59,63 +58,23 @@ func onTcpMessage(c *tcp_server.Client, args string) {
return return
} }
// Old format: <url> <num_blocks> <api_version> <host> // 1. Api
if utils.IsUrl(split[0]) { a.api = split[0]
logger.Warn("Deprecated format. Please change to the new format: <api>|<url>[|<num_blocks>|<host>]") // 2. url (scheme + ip/domain + port)
a.url = split[1]
// 1. url (scheme + ip/domain + port) // 3. num blocks
a.url = split[0] if len(split) > 2 {
num, err := strconv.ParseInt(split[2], 10, 32)
// 2. num blocks if err == nil {
if len(split) > 1 { a.num_blocks = int(num)
num, err := strconv.ParseInt(split[1], 10, 32)
if err == nil {
a.num_blocks = int(num)
}
} }
}
// 3. api_version // 4. Host
if len(split) > 2 { if len(split) > 3 {
a.api = split[2] a.host = split[3]
}
// 4. Host
if len(split) > 3 {
a.host = split[3]
}
} else {
if len(split) < 2 {
msg := "Invalid number of parameters in agent request"
logger.Warn("Agent request error", "message", msg, "args", split)
resp := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "")
c.WriteString(resp.String())
c.Close()
return
}
// 1. Api
a.api = split[0]
// 2. url (scheme + ip/domain + port)
a.url = split[1]
// 3. num blocks
if len(split) > 2 {
num, err := strconv.ParseInt(split[2], 10, 32)
if err == nil {
a.num_blocks = int(num)
}
}
// 4. Host
if len(split) > 3 {
a.host = split[3]
}
} }
// Check api. // Check api.