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

Convert hard tabs to soft.

Browse source
This commit is contained in:
Henrik Hautakoski 2022-01-04 09:54:34 +01:00
parent 1cbf8a06e6
commit b93f56f05c
2 changed files with 100 additions and 100 deletions
Download patch file Download diff file Expand all files Collapse all files

94
compile.sh
View file

@ -5,19 +5,19 @@ SYSTEMS=( windows linux freebsd )
ARCHS=( 386 amd64 amd64p32 arm arm64 ) ARCHS=( 386 amd64 amd64p32 arm arm64 )
function usage() { function usage() {
echo "Usage: ${0##*/} [ -h|--help ] [ --target <system> ] [ -a|--arch <arch> ] [ -p|--package ]" echo "Usage: ${0##*/} [ -h|--help ] [ --target <system> ] [ -a|--arch <arch> ] [ -p|--package ]"
echo "" echo ""
echo " Valid systems:" echo " Valid systems:"
for i in "${SYSTEMS[@]}"; do for i in "${SYSTEMS[@]}"; do
echo " * ${i}" echo " * ${i}"
done done
echo "" echo ""
echo " Valid architectures:" echo " Valid architectures:"
for i in "${ARCHS[@]}"; do for i in "${ARCHS[@]}"; do
echo " * ${i}" echo " * ${i}"
done done
echo "" echo ""
exit 1 exit 1
} }
options=$(getopt -n "${0##*/}" -o "ht:a:p" -l "help,target:,arch:,package" -- "$@") options=$(getopt -n "${0##*/}" -o "ht:a:p" -l "help,target:,arch:,package" -- "$@")
@ -30,47 +30,47 @@ MAKE_TARGET="all"
while true; do while true; do
case $1 in case $1 in
-p|--package) -p|--package)
MAKE_TARGET="package_deb" MAKE_TARGET="package_deb"
;; ;;
-t|--target) -t|--target)
shift shift
REGEX=$(echo "${SYSTEMS[@]}" | sed 's/[[:space:]]/|/g') REGEX=$(echo "${SYSTEMS[@]}" | sed 's/[[:space:]]/|/g')
[[ ! "$1" =~ ^($REGEX)$ ]] && { [[ ! "$1" =~ ^($REGEX)$ ]] && {
echo "Incorrect system '$1' provided" echo "Incorrect system '$1' provided"
usage usage
} }
export GOOS=$1 export GOOS=$1
;; ;;
-a|--arch) -a|--arch)
shift shift
REGEX=$(echo "${ARCHS[@]}" | sed 's/[[:space:]]/|/g') REGEX=$(echo "${ARCHS[@]}" | sed 's/[[:space:]]/|/g')
[[ ! "$1" =~ ^($REGEX)$ ]] && { [[ ! "$1" =~ ^($REGEX)$ ]] && {
echo "Incorrect architecture '$1' provided" echo "Incorrect architecture '$1' provided"
usage usage
} }
export GOARCH=$1 export GOARCH=$1
;; ;;
-h|--help) usage ;; -h|--help) usage ;;
--) shift --) shift
break break
;; ;;
esac esac
shift shift
done done
MESSAGE="" MESSAGE=""
if [ ! -z "${GOOS}" ]; then if [ ! -z "${GOOS}" ]; then
# Hack to select the right package :) # Hack to select the right package :)
if [ "${MAKE_TARGET}" == "package_deb" ] && [ "${GOOS}" == "freebsd" ]; then if [ "${MAKE_TARGET}" == "package_deb" ] && [ "${GOOS}" == "freebsd" ]; then
MAKE_TARGET="package_freebsd" MAKE_TARGET="package_freebsd"
fi fi
MESSAGE="[\e[34m::\e[0m] Crosscompiling for: ${GOOS}" MESSAGE="[\e[34m::\e[0m] Crosscompiling for: ${GOOS}"
fi fi
if [ ! -z "${GOARCH}" ]; then if [ ! -z "${GOARCH}" ]; then
MESSAGE="${MESSAGE} (${GOARCH})" MESSAGE="${MESSAGE} (${GOARCH})"
fi fi

106
src/cmd/main.go
View file

@ -2,69 +2,69 @@
package main package main
import ( import (
"fmt" "fmt"
"strings" "strings"
log "github.com/inconshreveable/log15" log "github.com/inconshreveable/log15"
"github.com/pborman/getopt/v2" "github.com/pborman/getopt/v2"
"github.com/onrik/ethrpc" "github.com/onrik/ethrpc"
"github.com/eosswedenorg-go/haproxy" "github.com/eosswedenorg-go/haproxy"
"github.com/eosswedenorg-go/tcp_server" "github.com/eosswedenorg-go/tcp_server"
) )
var logger log.Logger var logger log.Logger
func onConnect(c *tcp_server.Client) { func onConnect(c *tcp_server.Client) {
logger.Info("Client connected", "addr", c.Addr.String()) logger.Info("Client connected", "addr", c.Addr.String())
} }
func onTcpMessage(c *tcp_server.Client, message string) { func onTcpMessage(c *tcp_server.Client, message string) {
status := haproxy.HealthCheckDown status := haproxy.HealthCheckDown
client := ethrpc.New(strings.TrimSpace(message)) client := ethrpc.New(strings.TrimSpace(message))
resp, err := client.EthSyncing() resp, err := client.EthSyncing()
if err == nil { if err == nil {
if resp.IsSyncing == false { if resp.IsSyncing == false {
status = haproxy.HealthCheckUp status = haproxy.HealthCheckUp
} }
} else { } else {
logger.Warn(err.Error()) logger.Warn(err.Error())
} }
logger.Info("Node status", "status", status) logger.Info("Node status", "status", status)
// Report status to HAproxy // Report status to HAproxy
c.WriteString(fmt.Sprintln(status)) c.WriteString(fmt.Sprintln(status))
c.Close() c.Close()
} }
func onDisconnect(c *tcp_server.Client, err error) { func onDisconnect(c *tcp_server.Client, err error) {
if err == nil { if err == nil {
logger.Info("Client disconnected", "addr", c.Addr.String()) logger.Info("Client disconnected", "addr", c.Addr.String())
} else { } else {
logger.Warn("Client disconnected", "addr", c.Addr.String(), "err", err) logger.Warn("Client disconnected", "addr", c.Addr.String(), "err", err)
} }
} }
func argv_listen_addr() string { func argv_listen_addr() string {
var addr string var addr string
argv := getopt.Args() argv := getopt.Args()
if len(argv) > 0 { if len(argv) > 0 {
addr = argv[0] addr = argv[0]
} else { } else {
addr = "127.0.0.1" addr = "127.0.0.1"
} }
addr += ":" addr += ":"
if len(argv) > 1 { if len(argv) > 1 {
addr += argv[1] addr += argv[1]
} else { } else {
addr += "1301" addr += "1301"
} }
return addr return addr
} }
func main() { func main() {
@ -76,7 +76,7 @@ func main() {
getopt.FlagLong(&printUsage, "help", 'h', "Print this help text") getopt.FlagLong(&printUsage, "help", 'h', "Print this help text")
getopt.FlagLong(&printVersion, "version", 'v', "Print version") getopt.FlagLong(&printVersion, "version", 'v', "Print version")
getopt.Parse() getopt.Parse()
if printUsage { if printUsage {
getopt.Usage() getopt.Usage()
@ -90,19 +90,19 @@ func main() {
logger = log.New() logger = log.New()
addr := argv_listen_addr() addr := argv_listen_addr()
server := tcp_server.New(argv_listen_addr()) server := tcp_server.New(argv_listen_addr())
logger.Info(fmt.Sprintf("Listening on: %s", addr)) logger.Info(fmt.Sprintf("Listening on: %s", addr))
// TCP Client sends message. // TCP Client sends message.
server.OnConnect(onConnect) server.OnConnect(onConnect)
server.OnMessage(onTcpMessage) server.OnMessage(onTcpMessage)
server.OnDisconnect(onDisconnect) server.OnDisconnect(onDisconnect)
err := server.Listen() err := server.Listen()
if err != nil { if err != nil {
logger.Error(err.Error()) logger.Error(err.Error())
} }
} }