refactor
This commit is contained in:
Sebastian
91
check-health.sh
Executable file
91
check-health.sh
Executable file
@@ -0,0 +1,91 @@
|
|||||||
|
#!/bin/bash
|
||||||
|
|
||||||
|
RPC_URL="$1"
|
||||||
|
ref="$2"
|
||||||
|
|
||||||
|
response_file=$(mktemp)
|
||||||
|
|
||||||
|
http_status_code=$(curl --ipv4 -m 1 -s -X POST -w "%{http_code}" -o "$response_file" -H "Content-Type: application/json" --data '{"jsonrpc":"2.0","method":"eth_getBlockByNumber","params":["latest", false],"id":1}' $RPC_URL)
|
||||||
|
|
||||||
|
if [ $? -eq 0 ]; then
|
||||||
|
if [[ $http_status_code -eq 200 ]]; then
|
||||||
|
response=$(cat "$response_file")
|
||||||
|
latest_block_timestamp=$(echo "$response" | jq -r '.result.timestamp')
|
||||||
|
latest_block_timestamp_decimal=$((16#${latest_block_timestamp#0x}))
|
||||||
|
current_time=$(date +%s)
|
||||||
|
time_difference=$((current_time - latest_block_timestamp_decimal))
|
||||||
|
|
||||||
|
rm "$response_file"
|
||||||
|
|
||||||
|
if [ -n "$ref" ]; then
|
||||||
|
latest_block_number=$(echo "$response" | jq -r '.result.number')
|
||||||
|
latest_block_hash=$(echo "$response" | jq -r '.result.hash')
|
||||||
|
response_file2=$(mktemp)
|
||||||
|
|
||||||
|
http_status_code2=$(curl --ipv4 -m 1 -s -X POST -w "%{http_code}" -o "$response_file2" -H "Content-Type: application/json" --data "{\"jsonrpc\":\"2.0\",\"method\":\"eth_getBlockByNumber\",\"params\":[\"$latest_block_number\", false],\"id\":1}" $ref)
|
||||||
|
if [ $? -eq 0 ]; then
|
||||||
|
if [[ $http_status_code2 -eq 200 ]]; then
|
||||||
|
response2=$(cat "$response_file2")
|
||||||
|
latest_block_hash2=$(echo "$response2" | jq -r '.result.hash')
|
||||||
|
|
||||||
|
rm "$response_file2"
|
||||||
|
|
||||||
|
if [ "$latest_block_hash" == "$latest_block_hash2" ]; then
|
||||||
|
response_file3=$(mktemp)
|
||||||
|
|
||||||
|
http_status_code=$(curl --ipv4 -m 1 -s -X POST -w "%{http_code}" -o "$response_file3" -H "Content-Type: application/json" --data "{\"jsonrpc\":\"2.0\",\"method\":\"eth_getBlockByNumber\",\"params\":[\"latest\", false],\"id\":1}" $ref)
|
||||||
|
|
||||||
|
if [ $? -eq 0 ]; then
|
||||||
|
if [[ $http_status_code -eq 200 ]]; then
|
||||||
|
response3=$(cat "$response_file3")
|
||||||
|
latest_block_timestamp3=$(echo "$response3" | jq -r '.result.timestamp')
|
||||||
|
latest_block_timestamp_decimal3=$((16#${latest_block_timestamp3#0x}))
|
||||||
|
time_difference3=$(( latest_block_timestamp_decimal3 - latest_block_timestamp_decimal ))
|
||||||
|
|
||||||
|
rm "$response_file3"
|
||||||
|
|
||||||
|
if [ $time_difference3 -lt 2 ]; then
|
||||||
|
echo "online"
|
||||||
|
exit 0
|
||||||
|
elif [ $time_difference3 -lt 5 ]; then
|
||||||
|
echo "lagging"
|
||||||
|
exit 0
|
||||||
|
else
|
||||||
|
echo "syncing"
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
else
|
||||||
|
echo "forked"
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
|
||||||
|
echo "unverified"
|
||||||
|
exit 1
|
||||||
|
elif [ $time_difference -lt 60 ]; then
|
||||||
|
echo "online"
|
||||||
|
exit 0
|
||||||
|
else
|
||||||
|
echo "behind"
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
elif [[ $http_status_code -eq 404 ]]; then
|
||||||
|
echo "offline"
|
||||||
|
exit 1
|
||||||
|
elif [[ $http_status_code -eq 401 ]]; then
|
||||||
|
echo "unauthorized"
|
||||||
|
exit 1
|
||||||
|
elif [[ $http_status_code -eq 500 ]]; then
|
||||||
|
echo "error"
|
||||||
|
exit 1
|
||||||
|
else
|
||||||
|
echo "Unexpected HTTP status code: $http_status_code"
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
else
|
||||||
|
echo "timeout"
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
105
sync-status.sh
105
sync-status.sh
@@ -9,7 +9,6 @@ while IFS= read -r line; do
|
|||||||
blacklist+=("$line")
|
blacklist+=("$line")
|
||||||
done < "$BASEPATH/path-blacklist.txt"
|
done < "$BASEPATH/path-blacklist.txt"
|
||||||
|
|
||||||
#pathlist=$(cat $BASEPATH/$1.yml | grep -oP "(?<=stripprefix\.prefixes).*\"" | cut -d'=' -f2- | sed 's/.$//')
|
|
||||||
pathlist=$(cat $BASEPATH/$1.yml | grep -oP "(?<=PathPrefix).*\"" | cut -d'`' -f2-2)
|
pathlist=$(cat $BASEPATH/$1.yml | grep -oP "(?<=PathPrefix).*\"" | cut -d'`' -f2-2)
|
||||||
|
|
||||||
for path in $pathlist; do
|
for path in $pathlist; do
|
||||||
@@ -22,21 +21,6 @@ for path in $pathlist; do
|
|||||||
|
|
||||||
if $include; then
|
if $include; then
|
||||||
RPC_URL="https://$DOMAIN$path"
|
RPC_URL="https://$DOMAIN$path"
|
||||||
response_file=$(mktemp)
|
|
||||||
|
|
||||||
http_status_code=$(curl --ipv4 -m 1 -s -X POST -w "%{http_code}" -o "$response_file" -H "Content-Type: application/json" --data '{"jsonrpc":"2.0","method":"eth_getBlockByNumber","params":["latest", false],"id":1}' $RPC_URL)
|
|
||||||
|
|
||||||
if [ $? -eq 0 ]; then
|
|
||||||
|
|
||||||
if [[ $http_status_code -eq 200 ]]; then
|
|
||||||
|
|
||||||
response=$(cat "$response_file")
|
|
||||||
latest_block_timestamp=$(echo "$response" | jq -r '.result.timestamp')
|
|
||||||
latest_block_timestamp_decimal=$((16#${latest_block_timestamp#0x}))
|
|
||||||
current_time=$(date +%s)
|
|
||||||
time_difference=$((current_time - latest_block_timestamp_decimal))
|
|
||||||
|
|
||||||
rm "$response_file"
|
|
||||||
|
|
||||||
ref=''
|
ref=''
|
||||||
if [ -n "$2" ]; then
|
if [ -n "$2" ]; then
|
||||||
@@ -47,88 +31,11 @@ for path in $pathlist; do
|
|||||||
ref=$($BASEPATH/reference-rpc-endpoint.sh $chain_id_decimal)
|
ref=$($BASEPATH/reference-rpc-endpoint.sh $chain_id_decimal)
|
||||||
fi
|
fi
|
||||||
|
|
||||||
if [ -n "$ref" ]; then
|
# Call the health check script with RPC_URL and ref
|
||||||
# echo "do a quick fitness test"
|
$BASEPATH/check-health.sh "$RPC_URL" "$ref"
|
||||||
# use the proxy to normalize responses from different implementations of eth endpoints.
|
exit $?
|
||||||
# make the proxy exit on a mismatch
|
|
||||||
# push a few seconds of ethspam | versus through the proxy to give it a chance to hit a mismatch
|
|
||||||
|
|
||||||
latest_block_number=$(echo "$response" | jq -r '.result.number')
|
|
||||||
latest_block_hash=$(echo "$response" | jq -r '.result.hash')
|
|
||||||
response_file2=$(mktemp)
|
|
||||||
|
|
||||||
http_status_code2=$(curl --ipv4 -m 1 -s -X POST -w "%{http_code}" -o "$response_file2" -H "Content-Type: application/json" --data "{\"jsonrpc\":\"2.0\",\"method\":\"eth_getBlockByNumber\",\"params\":[\"$latest_block_number\", false],\"id\":1}" $ref)
|
|
||||||
if [ $? -eq 0 ]; then
|
|
||||||
if [[ $http_status_code2 -eq 200 ]]; then
|
|
||||||
response2=$(cat "$response_file2")
|
|
||||||
latest_block_hash2=$(echo "$response2" | jq -r '.result.hash')
|
|
||||||
|
|
||||||
rm "$response_file2"
|
|
||||||
|
|
||||||
if [ "$latest_block_hash" == "$latest_block_hash2" ]; then
|
|
||||||
response_file3=$(mktemp)
|
|
||||||
|
|
||||||
http_status_code=$(curl --ipv4 -m 1 -s -X POST -w "%{http_code}" -o "$response_file3" -H "Content-Type: application/json" --data "{\"jsonrpc\":\"2.0\",\"method\":\"eth_getBlockByNumber\",\"params\":[\"latest\", false],\"id\":1}" $ref)
|
|
||||||
|
|
||||||
if [ $? -eq 0 ]; then
|
|
||||||
if [[ $http_status_code -eq 200 ]]; then
|
|
||||||
response3=$(cat "$response_file3")
|
|
||||||
latest_block_timestamp3=$(echo "$response3" | jq -r '.result.timestamp')
|
|
||||||
latest_block_timestamp_decimal3=$((16#${latest_block_timestamp3#0x}))
|
|
||||||
time_difference3=$(( latest_block_timestamp_decimal3 - latest_block_timestamp_decimal ))
|
|
||||||
|
|
||||||
rm "$response_file3"
|
|
||||||
|
|
||||||
if [ $time_difference3 -lt 2 ]; then
|
|
||||||
echo "online"
|
|
||||||
exit 0
|
|
||||||
elif [ $time_difference3 -lt 5 ]; then
|
|
||||||
echo "lagging"
|
|
||||||
exit 0
|
|
||||||
else
|
|
||||||
#echo "syncing ($(./catchup.sh $1))"
|
|
||||||
echo "syncing"
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
else
|
|
||||||
echo "forked"
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
|
|
||||||
echo "unverified"
|
|
||||||
exit 1
|
|
||||||
elif [ $time_difference -lt 60 ]; then
|
|
||||||
echo "online"
|
|
||||||
exit 0
|
|
||||||
else
|
|
||||||
echo "behind"
|
|
||||||
#echo "behind ($(./catchup.sh $1))"
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
elif [[ $http_status_code -eq 404 ]]; then
|
|
||||||
echo "offline"
|
|
||||||
exit 1
|
|
||||||
elif [[ $http_status_code -eq 401 ]]; then
|
|
||||||
echo "unauthorized"
|
|
||||||
exit 1
|
|
||||||
elif [[ $http_status_code -eq 500 ]]; then
|
|
||||||
echo "error"
|
|
||||||
exit 1
|
|
||||||
else
|
|
||||||
echo "Unexpected HTTP status code: $http_status_code"
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
else
|
|
||||||
echo "timeout"
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
|
|
||||||
break
|
|
||||||
else
|
|
||||||
echo "not found"
|
|
||||||
fi
|
fi
|
||||||
done
|
done
|
||||||
|
|
||||||
|
echo "not found"
|
||||||
|
exit 1
|
||||||
|
|||||||
Reference in New Issue
Block a user