nimbus-eth1-blobs/scripts/run-geth-session.sh

#! /bin/sh

self=${GETH_SESSION_SELF:-`basename "$0"`}

# Network name (used below for easy setup)
name=${GETH_SESSION_NAME:-ropsten}

# Digits, instance id appended to directory name
instance=${GETH_SESSION_INSTANCE:-0}

# Unique geth TCP/UDP communication port => base_port + instance
base_port=${GETH_SESSION_BASE_PORT:-30303}

# Geth sync mode, full, snap, or light
syncmode=${GETH_SESSION_SYNCMODE:-full}

# Git branch to use with "build" command
case "$name" in
kiln) git_branch=${GETH_GIT_BRANCH:-merge-kiln-v2} ;;
*)    git_branch=${GETH_GIT_BRANCH:-master}
esac

# Unique log data and database folder (relative to current directory)
datadir=${GETH_SESSION_DATADIR:-./datadir-geth-$name$instance}

# Enable local Geth services
server_api=${GETH_SERVER_API:-no}

# Adding generic options
optargs=${GETH_SESSION_OPTARGS:-''}
# optargs=${GETH_SESSION_OPTARGS:-"$optargs xxxxx"}

# ------------------------------------------------------------------------------
# No need to change, below
# ------------------------------------------------------------------------------

# Geth server interface
test yes != $server_api || {
    optargs="$optargs --ws"
    optargs="$optargs --http"
    optargs="$optargs --ws.api=engine,eth,web3,net,debug"
    optargs="$optargs --http.api=engine,eth,web3,net,debug"
    optargs="$optargs --http.corsdomain=*"
    optargs="$optargs --authrpc.jwtsecret=./jwtsecret"
    optargs="$optargs --http.port=`expr    8545 + $instance \* 10`"
    optargs="$optargs --ws.port=`expr      8546 + $instance \* 10`"
    optargs="$optargs --authrpc.port=`expr 8551 + $instance \* 10`"
}

# Unique geth TCP/UDP communication port
port=`expr $base_port + $instance`

# Fixed session keys depending on port
session_key=`echo $port |
  awk '{for(n=0;n<32;n++){a=a"10"}print substr(a$1,1+length($1))}'`

# Name of custom genesis
genesis_json=geth-$name.json

# Per-network bootstrap nodes
enodes_kiln="\
enode://c354db99124f0faf677ff0e75c3cbbd568b2febc186af664e0c51ac435609badedc67a18a63adb64dacc1780a28dcefebfc29b83fd1a3f4aa3c0eb161364cf94@164.92.130.5:30303"

enodes_mainshadow1="\
enode://36ad5c6e0a10e58234cf9e17bd07107f1ed69659d27d3f0510bc9d8c109d6898d4bb7e20a64e69ee13fc8cc67e0a7291a09f6efd5a6ee26b26ad99d8f8458717@157.230.27.43:30303,\
enode://3121479bdb80ad8addab60694083ee83706e47c05523cdda4cbdaf5683794d67b3dbcad848a085dd823d9fb60df3483b50459950d5d9ec23e3373e7bd58e5819@165.227.100.193:30303,\
enode://06899e1abf67b53dd0c6e10dafa238c7b71e361583353c928fed2aa7642d05e3d7755cb3f934bfdcf4fe563996720fb8c74de356d5dda0329b65d1d23a389c90@143.110.188.48:30303"

# Log spooler capacity settings
logfile_max=80000000
num_backlogs=40

# Base directory for finding objects in the Geth file system
find_prefix="`dirname $0` . .. ../.. go-ethereum nimbus-eth1-blobs"

# Sub-find directory for various items
find_geth=". .. build/bin"
find_genesis=". .. custom-network"

# ------------------------------------------------------------------------------
# Helpers
# ------------------------------------------------------------------------------

# Find executable file
find_exe() { # Syntax: <exe-name> <subdir> ...
    exe="$1"
    shift
    {
	for pfx in $find_prefix; do
	    for sub; do
		find -L \
		     "$pfx/$sub" \
		     -maxdepth 3 -type f -name "$exe" -perm /111 -print \
		     2>/dev/null
	    done
	done |
	    # Beware, this is slow. On the other hand, uncommenting the
	    # next line dumps all possible matches to the console.
	    #tee /dev/tty |
	    xargs -n1 realpath 2>/dev/null
	# provide argument file name as default
	echo "$exe"
    } |	sed -eq
}

# Find non-executable file
find_file() { # Syntax: <file-name> <subdir> ...
    file="$1"
    shift
    {
	for pfx in $find_prefix; do
	    for sub; do
		find -L \
		     "$pfx/$sub" \
		     -maxdepth 3 -type f -name "$file" -print \
		     2>/dev/null
	    done |
		# Beware, this is slow. On the other hand, uncommenting the
		# next line dumps all possible matches to the console.
		#tee /dev/tty |
		xargs -n1 realpath 2>/dev/null
	done
	# provide argument file name as default
	echo "$file"
    } | sed -eq
}

stripColors() {
  if ansi2txt </dev/null 2>/dev/null
  then
      ansi2txt
  else
      cat
  fi
}

# Find pid of running svlogd command
get_pid_svlogd() {
    ps x|
	grep \
	    -e "svlogd $datadir/log" \
        |
	grep -v \
	     -e vim \
	     -e grep \
        |
	awk '$1 != '"$$"'{print $1}'
}

# Find pid of running svlogd and geth command
get_pids() {
    ps x|
	grep \
	    -e "geth --datadir=./data --port=$port" \
	    -e "svlogd $datadir/log" \
        |
	grep -v \
	     -e vim \
	     -e grep \
        |
	awk '$1 != '"$$"'{print $1}'
}

# ------------------------------------------------------------------------------
# Command line parsing and man page
# ------------------------------------------------------------------------------

nohup=no
start=no
stop=no
flush=no
logs=no
help=no
build=no
enode=no
attch=no

test $# -ne 0 ||
    help=yes

for arg
do
    case "$arg" in
    build)
	build=yes
	;;
    enode)
	enode=yes
	;;
    attach)
	attch=yes
	;;
    stop)
	stop=yes
	;;
    flush)
	flush=yes
	;;
    start)
	start=yes
	;;
    daemon)
	nohup=yes
	start=yes
	;;
    logs)
	logs=yes
	;;
    help|'')
	help=yes
	;;
  *)
      exec >&2
      echo "Usage: $self [help] [stop] [flush] [daemon|start|enode|attach] [logs]"
      exit 2
  esac
done


test yes != "$help" || {
    cat <<EOF
$self:
   Available commands (can be combined irrespective of order):
      logs    resume console logging (as descibed above)
      flush   delete all log and blockchain data
      build   re-compile geth version

   Mutually exclusive commands:
      stop    stop the Geth session (as descibed above)
      start   start the Geth session in the foreground
      daemon  background session (without termninating on logout, e.g. from ssh)
      enode   print enode of running geth
      attach  attach console to running Geth
EOF
    exit
}

# ------------------------------------------------------------------------------
# MAIN
# ------------------------------------------------------------------------------

# Check for logger program availability
(svlogd 2>&1|grep -i 'usage: svlogd' >/dev/null) || {
    exec >&2
    echo "*** $self: This script needs a working \"svlogd\" program. On Debian,"
    echo "                    this is provided by the \"runit\" package."
    exit 2
}

# Stop running sessions by sending termination signal
test yes != "$stop" || {
    # set -x
    pids=`get_pids`
    test -z "$pids" || {
	(set -x; kill -TERM $pids)
	sleep 1
	pids=`get_pids`
	test -z "$pids" || {
	    (set -x; kill -KILL $pids)
	    sleep 1
	}
	echo
    }
}

# Clean up
test yes != "$flush" || {
    d=`basename $datadir`
    test \! -d $datadir || (set -x; rm -rf $datadir)
}

# Stop here after clean up when terminating a session
test yes != "$stop" || {
    exit
}

if [ yes = "$nohup" ]
then
    true
elif [ yes != "$flush" -a yes != "$build" ]
then
    # Set logging unless deamon enabled or build
    logs=yes
fi

# Rebuild Getn version
test yes != "$build" || (
    set -x
    git checkout "$git_branch"
    git pull origin "$git_branch"
    make geth
) || exit

# Print enode of other session
test yes != "$enode" || {
    geth=`find_exe geth $find_geth`
    echo admin.nodeInfo |
	$geth --datadir "$datadir/data" attach |
	sed \
	    -e '/enode:/!d' \
	    -e 's/^[^"]*"\(.*\)".*/\1/'
    exit
}

# Attach console to other session
test yes != "$enode" || {
    geth=`find_exe geth $find_geth`
    set -x
    $geth --datadir "$datadir/data" attach
    exit
}

# Start a new geth session in the background
test yes != "$start" || (
  mkdir -p $datadir/log $datadir/data

  geth=`find_exe geth $find_geth`
  init_data=no

  case "$name" in
  kiln)
      optargs="$optargs --networkid=1337802"
      optargs="$optargs --bootnodes=$enodes_kiln"
      init_data=yes
      ;;
  mainshadow1)
      optargs="$optargs --networkid=1"
      optargs="$optargs --bootnodes=$enodes_mainshadow1"
      init_data=yes
      ;;
  *)  optargs="$optargs --$name"
  esac

  # RPC authorisation seed, might not be needed though
  test -s "$datadir/jwtsecret" || (
      umask 377
      rm -f "$datadir/jwtsecret"
      {
	  echo 0x
	  openssl rand -hex 32
	  # echo $session_key
      } | tr -d '\n' > "$datadir/jwtsecret"
  )
  # Initialise genesis on data store
  test yes != "$init_data" || {
      test -d "$datadir/data/$name" || (
	  genesis=`find_file $genesis_json $find_genesis`
	  set -x
	  $geth init "$genesis" --datadir "$datadir/data" 
      )
  }

  test yes != "$nohup" || {
     trap "echo '*** $self: NOHUP ignored'" HUP
     trap "echo '*** $self: terminating ..';exit"  INT TERM QUIT
  }
  (
    cd $datadir

    mv ./log/config ./log/config~ 2>/dev/null || true
    {
       echo s$logfile_max
       echo n$num_backlogs
    } >./log/config

    set -x
    ${geth:-geth} \
	--datadir=./data \
	--port=$port \
	--syncmode=$syncmode \
	$optargs \
	--nodekeyhex="$session_key" \
	--verbosity=5 \
	--log.debug \
	2>&1

  ) | stripColors | svlogd $datadir/log
) &

# After starting a session, make sure that svlogd is re-loaded in order
# to read the config file (woul not tdo it right on the start)
test yes != "$start" || {
    sleep 1
    pid=`get_pid_svlogd`
    test -z "$pid" || kill -HUP $pid
    echo
}

# Logging ...
test yes != "$logs" || {
  mkdir -p $datadir/log/
  touch $datadir/log/current |
  tail -F $datadir/log/current |

    # Filter out chaff on console data
    grep -v \
      -e '>> [NPF]' \
      -e '<< [NPF]'
}

# ------------------------------------------------------------------------------
# End
# ------------------------------------------------------------------------------