Robosats/robosats
1
0
Fork 0
mirror of https://github.com/RoboSats/robosats.git synced 2025-07-19 01:03:20 +00:00
Code Issues Packages Projects Releases Wiki Activity
robosats/scripts/traditional/regtest-nodes
jerryfletcher21 bff872130d traditional environment
2025-05-28 17:32:04 +02:00

1439 lines
39 KiB
Bash
Executable File
Raw Blame History

#!/bin/sh
_command_exist() {
if command -v "$1" >/dev/null 2>&1; then
return 0
else
echo "error: $1 command not found" >&2
return 1
fi
}
_function_exist() {
if command -V "$1" 2>/dev/null | grep -qwi function >/dev/null 2>&1; then
return 0
else
echo "error: function $1 not set" >&2
return 1
fi
}
_create_dir() {
if [ ! -e "$1" ]; then
mkdir -p "$1" || return "$?"
elif [ ! -d "$1" ]; then
echo "error: $1 is not a directory" >&2
return 1
fi
}
# if $2 is provided use it as default
# otherwise return error when not found
_get_env_var() {
if ! env_var="$(dotenv -f ".env" get "$1" 2>/dev/null)"; then
if [ "$#" -ge 2 ]; then
env_var="$2"
else
echo "error: getting $1 from .env" >&2
return 1
fi
fi
printf "%s\n" "$env_var"
return 0
}
# transform relative path into absolute and remove trailing slashes
_get_env_var_path() {
env_var="$(_get_env_var "$@")" || return "$?"
real_path="$(realpath -m "$env_var")" || return "$?"
printf "%s\n" "$real_path"
return 0
}
# extract the port from an env variable
_get_env_var_port() {
env_var="$(_get_env_var "$@")" || return "$?"
printf "%s\n" "$env_var" |
rev |
cut -d ":" -f 1 |
rev
return 0
}
_nodes_environment_set() {
if [ ! -f "scripts/traditional/regtest-nodes" ]; then
echo "error: source this script from the project root" >&2
return 1
fi
if [ ! -f ".env" ]; then
echo "error: .env is not present" >&2
return 1
fi
if ! _command_exist dotenv; then
return 1
fi
TESTING="$(_get_env_var TESTING false)" || return "$?"
case "$(printf "%s\n" "$TESTING" | tr '[:upper:]' '[:lower:]')" in
true|yes|on|1)
TESTING=true
;;
*)
TESTING=false
;;
esac
RUNSERVER_PORT="$(_get_env_var "RUNSERVER_PORT")" || return "$?"
cln_set=false
lnd_set=false
LNVENDOR_COORD="$(_get_env_var LNVENDOR)" || return "$?"
LNVENDOR_COORD="$(printf "%s\n" "$LNVENDOR_COORD" | tr '[:upper:]' '[:lower:]')"
case "$LNVENDOR_COORD" in
cln) cln_set=true ;;
lnd) lnd_set=true ;;
*)
echo "error: LNVENDOR can be cln or lnd" >&2
return 1
;;
esac
LNVENDOR_USER="$(_get_env_var LNVENDOR_USER)" || return "$?"
LNVENDOR_USER="$(printf "%s\n" "$LNVENDOR_USER" | tr '[:upper:]' '[:lower:]')"
case "$LNVENDOR_USER" in
cln) cln_set=true ;;
lnd) lnd_set=true ;;
*)
echo "error: LNVENDOR_USER can be cln or lnd" >&2
return 1
;;
esac
if [ "$TESTING" = true ] && [ "$LNVENDOR_USER" != "lnd" ]; then
echo "error: LNVENDOR_USER should be lnd when running tests" >&2
return 1
fi
BITCOIND_BIN="$(_get_env_var_path "BITCOIND_BIN")" || return "$?"
BITCOIN_CLI_BIN="$(_get_env_var_path "BITCOIN_CLI_BIN")" || return "$?"
if [ "$cln_set" = true ]; then
LIGHTNINGD_BIN="$(_get_env_var_path "LIGHTNINGD_BIN")" || return "$?"
LIGHTNING_CLI_BIN="$(_get_env_var_path "LIGHTNING_CLI_BIN")" || return "$?"
HOLDINVOICE_PLUGIN_BIN="$(_get_env_var_path "HOLDINVOICE_PLUGIN_BIN")" || return "$?"
fi
if [ "$lnd_set" = true ]; then
LND_BIN="$(_get_env_var_path "LND_BIN")" || return "$?"
LNCLI_BIN="$(_get_env_var_path "LNCLI_BIN")" || return "$?"
fi
REGTEST_NODES_DIR="$(_get_env_var_path "TRADITIONAL_NODES_DIR")" || return "$?"
REGTEST_LOGS_DIR="$(_get_env_var_path "TRADITIONAL_LOGS_DIR")" || return "$?"
ROBOAUTO_GIT_DIR="$(_get_env_var_path "ROBOAUTO_GIT_DIR" false)" || return "$?"
BITCOIN_REGTEST_RPC_PORT="$(_get_env_var_port "BITCOIND_RPCURL")" || return "$?"
BITCOIN_REGTEST_RPC_USER="$(_get_env_var "BITCOIND_RPCUSER")" || return "$?"
BITCOIN_REGTEST_RPC_PASS="$(_get_env_var "BITCOIND_RPCPASSWORD")" || return "$?"
BITCOIN_REGTEST_ZMQ_BLOCK_PORT="$(_get_env_var "BITCOIN_TEST_ZMQ_BLOCK_PORT")" || return "$?"
BITCOIN_REGTEST_ZMQ_TX_PORT="$(_get_env_var "BITCOIN_TEST_ZMQ_TX_PORT")" || return "$?"
if [ "$cln_set" = true ]; then
CLN_COORD_GRPC_PORT="$(_get_env_var_port "CLN_GRPC_HOST")" || return "$?"
CLN_COORD_HOLD_PORT="$(_get_env_var_port "CLN_GRPC_HOLD_HOST")" || return "$?"
CLN_COORD_LISTEN_PORT="$(_get_env_var "CLN_TEST_COORD_LISTEN_PORT")" || return "$?"
CLN_USER_GRPC_PORT="$(_get_env_var "CLN_TEST_USER_GRPC_PORT")" || return "$?"
CLN_USER_LISTEN_PORT="$(_get_env_var "CLN_TEST_USER_LISTEN_PORT")" || return "$?"
fi
if [ "$lnd_set" = true ]; then
LND_COORD_RPC_PORT="$(_get_env_var_port "LND_GRPC_HOST")" || return "$?"
LND_COORD_LISTEN_PORT="$(_get_env_var "LND_TEST_COORD_LISTEN_PORT")" || return "$?"
LND_COORD_REST_PORT="$(_get_env_var "LND_TEST_COORD_REST_PORT")" || return "$?"
LND_USER_RPC_PORT="$(_get_env_var "LND_TEST_USER_GRPC_PORT")" || return "$?"
LND_USER_LISTEN_PORT="$(_get_env_var "LND_TEST_USER_LISTEN_PORT")" || return "$?"
LND_USER_REST_PORT="$(_get_env_var "LND_TEST_USER_REST_PORT")" || return "$?"
fi
if [ -z "$BITCOIND_BIN" ]; then
BITCOIND_BIN="bitcoind"
fi
if ! _command_exist "$BITCOIND_BIN"; then
return 1
fi
if [ -z "$BITCOIN_CLI_BIN" ]; then
BITCOIN_CLI_BIN="bitcoin-cli"
fi
if ! _command_exist "$BITCOIN_CLI_BIN"; then
return 1
fi
if [ "$cln_set" = true ]; then
if [ -z "$LIGHTNINGD_BIN" ]; then
LIGHTNINGD_BIN="lightningd"
fi
if ! _command_exist "$LIGHTNINGD_BIN"; then
return 1
fi
if [ -z "$LIGHTNING_CLI_BIN" ]; then
LIGHTNING_CLI_BIN="lightning-cli"
fi
if ! _command_exist "$LIGHTNING_CLI_BIN"; then
return 1
fi
if [ -z "$HOLDINVOICE_PLUGIN_BIN" ]; then
echo "error: $HOLDINVOICE_PLUGIN_BIN not set" >&2
return 1
fi
if [ ! -f "$HOLDINVOICE_PLUGIN_BIN" ]; then
echo "error: $HOLDINVOICE_PLUGIN_BIN plugin not found" >&2
return 1
fi
fi
if [ "$lnd_set" = true ]; then
if [ -z "$LND_BIN" ]; then
LND_BIN="lnd"
fi
if ! _command_exist "$LND_BIN"; then
return 1
fi
if [ -z "$LNCLI_BIN" ]; then
LNCLI_BIN="lncli"
fi
if ! _command_exist "$LNCLI_BIN"; then
return 1
fi
fi
if [ -z "$REGTEST_NODES_DIR" ]; then
echo "error: REGTEST_NODES_DIR not set" >&2
return 1
fi
_create_dir "$REGTEST_NODES_DIR" || return "$?"
if [ -z "$REGTEST_LOGS_DIR" ]; then
echo "error: REGTEST_LOGS_DIR not set" >&2
return 1
fi
_create_dir "$REGTEST_LOGS_DIR" || return "$?"
BITCOIN_DIR="$REGTEST_NODES_DIR/bitcoin"
ROBOAUTO_DIR="$REGTEST_NODES_DIR/roboauto"
if [ "$cln_set" = true ]; then
CLN_COORD_DIR="$REGTEST_NODES_DIR/cln-coord"
CLN_USER_DIR="$REGTEST_NODES_DIR/cln-user"
cln_coor_dir_env="$(_get_env_var_path "CLN_DIR")" || return "$?"
if [ "$cln_coor_dir_env" != "$CLN_COORD_DIR/regtest" ]; then
echo "error: CLN_DIR not consistent with REGTEST_NODES_DIR" >&2
return 1
fi
fi
if [ "$lnd_set" = true ]; then
LND_COORD_DIR="$REGTEST_NODES_DIR/lnd-coord"
LND_USER_DIR="$REGTEST_NODES_DIR/lnd-user"
lnd_coord_dir_env="$(_get_env_var_path "LND_DIR")" || return "$?"
if [ "$lnd_coord_dir_env" != "$LND_COORD_DIR" ]; then
echo "error: LND_DIR not consistent with REGTEST_NODES_DIR" >&2
return 1
fi
correct_macaroon_path="data/chain/bitcoin/regtest/admin.macaroon"
macaroon_path="$(
_get_env_var "MACAROON_PATH"
)" || return "$?"
if [ "$macaroon_path" != "$correct_macaroon_path" ]; then
echo "error: MACAROON_PATH should be $correct_macaroon_path" >&2
return 1
fi
lnd_test_coord_macaroon_path="$(
_get_env_var_path "LND_TEST_COORD_MACAROON_PATH"
)" || return "$?"
if [ \
"$lnd_test_coord_macaroon_path" != \
"$LND_COORD_DIR/$correct_macaroon_path" \
]; then
echo "error: LND_TEST_COORD_MACAROON_PATH not consistent with REGTEST_NODES_DIR" >&2
return 1
fi
lnd_test_user_macaroon_path="$(
_get_env_var_path "LND_TEST_USER_MACAROON_PATH"
)" || return "$?"
if [ \
"$lnd_test_user_macaroon_path" != \
"$LND_USER_DIR/$correct_macaroon_path" \
]; then
echo "error: LND_TEST_USER_MACAROON_PATH not consistent with REGTEST_NODES_DIR" >&2
return 1
fi
fi
}
_pgrep_bitcoin_regtest() {
pgrep -f "$BITCOIND_BIN -datadir=$BITCOIN_DIR -regtest -daemon" >/dev/null
}
_bitcoin_regtest_check_started() {
if ! _pgrep_bitcoin_regtest; then
echo "error: bitcoin regtest not started" >&2
return 1
fi
if ! _function_exist btc_reg; then
return 1
fi
return 0
}
bitcoin_regtest_mine() {
_bitcoin_regtest_check_started || return "$?"
if [ "$#" -lt 2 ]; then
return 1
fi
if [ "$2" = "new" ]; then
if ! new_address="$(btc_reg getnewaddress)"; then
echo "error: could not create new address" >&2
return 1
fi
else
new_address="$2"
fi
if ! new_block_hash="$(
btc_reg -named generatetoaddress nblocks="$1" address="$new_address" |
jq -r '.[-1]'
)"; then
echo "error: could not generate to $new_address" >&2
return 1
fi
while [ "$(btc_reg getbestblockhash)" != "$new_block_hash" ]; do
echo "waiting for $1 blocks to be mined..."
sleep 1
done
unset new_block_hash
echo "mined $1 blocks to $new_address"
unset new_address
}
bitcoin_regtest_start() {
_create_dir "$BITCOIN_DIR" || return "$?"
echo "writing bitcoin regtest config"
cat << EOF > "$BITCOIN_DIR/bitcoin.conf"
txindex=1
rest=1
server=1
logips=1
listenonion=0
zmqpubrawblock=tcp://127.0.0.1:$BITCOIN_REGTEST_ZMQ_BLOCK_PORT
zmqpubrawtx=tcp://127.0.0.1:$BITCOIN_REGTEST_ZMQ_TX_PORT
[regtest]
rpcport=$BITCOIN_REGTEST_RPC_PORT
rpcuser=$BITCOIN_REGTEST_RPC_USER
rpcpassword=$BITCOIN_REGTEST_RPC_PASS
EOF
if ! _pgrep_bitcoin_regtest; then
echo "starting bitcoin regtest"
if ! "$BITCOIND_BIN" -datadir="$BITCOIN_DIR" -regtest -daemon >/dev/null; then
echo "error: starting bitcoind regtest daemon" >&2
return 1
fi
else
echo "bitcoin regtest already started"
fi
btc_reg() {
"$BITCOIN_CLI_BIN" \
-datadir="$BITCOIN_DIR" \
-regtest \
-rpcuser="$BITCOIN_REGTEST_RPC_USER" \
-rpcpassword="$BITCOIN_REGTEST_RPC_PASS" \
"$@"
}
# wait for bitcoin to start
while ! btc_reg ping >/dev/null 2>&1; do
echo "waiting for bitcoind regtes to start..."
sleep 1
done
# check if default wallet exists
if
! btc_reg listwalletdir |
jq -r '.wallets[] | .name' |
grep "^default$" >/dev/null 2>&1
then
if ! btc_reg -named createwallet \
wallet_name=default \
disable_private_keys=false \
blank=false \
avoid_reuse=false \
descriptors=true \
load_on_startup=true \
external_signer=false >/dev/null
then
echo "error: could not create default wallet" >&2
return 1
fi
echo "default bitcoind wallet successfully created"
fi
# check if default wallet is loaded
if
! btc_reg listwallets |
jq -r '.[]' |
grep "^default$" >/dev/null 2>&1
then
if ! btc_reg loadwallet default; then
echo "error: could not load default wallet" >&2
return 1
fi
echo "default bitcoind wallet successfully loaded"
fi
bitcoin_regtest_mine 1 "new" || return "$?"
while [ "$(btc_reg getblockchaininfo | jq -r '.initialblockdownload')" != false ]; do
echo "waiting for bitcoind regtes to download blocks..."
sleep 1
done
echo "bitcoin regtest started, data directory is $BITCOIN_DIR"
echo "btc_reg function set"
}
_bitcoin_regtest_stop() {
if ! _pgrep_bitcoin_regtest; then
echo "bitcoin regtest already stopped"
else
if
! "$BITCOIN_CLI_BIN" \
-datadir="$BITCOIN_DIR" \
-regtest \
stop >/dev/null
then
echo "error: bitcoin regtest not stopped" >&2
fi
while _pgrep_bitcoin_regtest; do
echo "waiting for bitcoin regtest to stop..."
sleep 1
done
echo "bitcoin regtest stopped"
fi
}
bitcoin_regtest_stop_and_remove() {
_bitcoin_regtest_stop || return "$?"
if [ ! -e "$BITCOIN_DIR" ]; then
echo "bitcoin directory not present"
else
if ! rm -rf "$BITCOIN_DIR"; then
echo "error: removing bitcoin directory $BITCOIN_DIR"
return 1
fi
echo "removed bitcoin directory $BITCOIN_DIR"
fi
}
_pgrep_cln_coord() {
pgrep -f \
"$LIGHTNINGD_BIN --lightning-dir=$CLN_COORD_DIR --regtest --daemon" \
>/dev/null
}
cln_coord_start() {
_bitcoin_regtest_check_started || return "$?"
_create_dir "$CLN_COORD_DIR" || return "$?"
echo "writing cln coordinator config"
cat << EOF > "$CLN_COORD_DIR/config"
bitcoin-cli=$BITCOIN_CLI_BIN
bitcoin-datadir=$BITCOIN_DIR
bitcoin-rpcuser=$BITCOIN_REGTEST_RPC_USER
bitcoin-rpcpassword=$BITCOIN_REGTEST_RPC_PASS
bitcoin-rpcport=$BITCOIN_REGTEST_RPC_PORT
alias=cln-coordinator
rgb=100000
fee-base=0
fee-per-satoshi=0
min-capacity-sat=990000
ignore-fee-limits=true
funding-confirms=1
max-concurrent-htlcs=64
max-dust-htlc-exposure-msat=1000000000
cltv-delta=144
cltv-final=144
bitcoin-retry-timeout=120
database-upgrade=true
log-file=lightning.log
addr=localhost:$CLN_COORD_LISTEN_PORT
grpc-port=$CLN_COORD_GRPC_PORT
important-plugin=$HOLDINVOICE_PLUGIN_BIN
grpc-hold-port=$CLN_COORD_HOLD_PORT
disable-plugin=clnrest
disable-plugin=wss-proxy
EOF
if ! _pgrep_cln_coord; then
echo "starting cln coordinator"
if
! "$LIGHTNINGD_BIN" \
--lightning-dir="$CLN_COORD_DIR" \
--regtest \
--daemon \
>/dev/null
then
echo "error: starting cln coordinator daemon" >&2
return 1
fi
else
echo "cln coordinator already started"
fi
cln_coord() {
"$LIGHTNING_CLI_BIN" \
--lightning-dir="$CLN_COORD_DIR" \
--regtest \
"$@"
}
while [ \
"$(cln_coord getinfo | jq -r '.blockheight')" -ne \
"$(btc_reg getblockcount)" \
]; do
echo "waiting for cln coordinator to sync with the chain..."
sleep 1
done
echo "cln coordinator started, data directory is $CLN_COORD_DIR"
echo "cln_coord function set"
}
_cln_coord_stop() {
if ! _pgrep_cln_coord; then
echo "cln coordinator already stopped"
else
if
! "$LIGHTNING_CLI_BIN" \
--lightning-dir="$CLN_COORD_DIR" \
--regtest \
stop >/dev/null
then
echo "error: cln coordinator not stopped" >&2
fi
while _pgrep_cln_coord; do
echo "waiting for cln coordinator to stop..."
sleep 1
done
echo "cln coordinator stopped"
fi
}
cln_coord_stop_and_remove() {
_cln_coord_stop || return "$?"
if [ ! -e "$CLN_COORD_DIR" ]; then
echo "cln coordinator directory not present"
else
if ! rm -rf "$CLN_COORD_DIR"; then
echo "error: removing cln coordinator directory $CLN_COORD_DIR"
return 1
fi
echo "removed cln coordinator directory $CLN_COORD_DIR"
fi
}
_pgrep_cln_user() {
pgrep -f \
"$LIGHTNINGD_BIN --lightning-dir=$CLN_USER_DIR --regtest --daemon" \
>/dev/null
}
cln_user_start() {
_bitcoin_regtest_check_started || return "$?"
_create_dir "$CLN_USER_DIR" || return "$?"
echo "writing cln user config"
cat << EOF > "$CLN_USER_DIR/config"
bitcoin-cli=$BITCOIN_CLI_BIN
bitcoin-datadir=$BITCOIN_DIR
bitcoin-rpcuser=$BITCOIN_REGTEST_RPC_USER
bitcoin-rpcpassword=$BITCOIN_REGTEST_RPC_PASS
bitcoin-rpcport=$BITCOIN_REGTEST_RPC_PORT
alias=cln-user
rgb=200000
fee-base=0
fee-per-satoshi=0
min-capacity-sat=990000
ignore-fee-limits=true
funding-confirms=1
max-concurrent-htlcs=64
max-dust-htlc-exposure-msat=1000000000
cltv-delta=144
cltv-final=144
bitcoin-retry-timeout=120
database-upgrade=true
log-file=lightning.log
addr=localhost:$CLN_USER_LISTEN_PORT
grpc-port=$CLN_USER_GRPC_PORT
disable-plugin=clnrest
disable-plugin=wss-proxy
EOF
if ! _pgrep_cln_user; then
echo "starting cln user"
if
! "$LIGHTNINGD_BIN" \
--lightning-dir="$CLN_USER_DIR" \
--regtest \
--daemon \
>/dev/null
then
echo "error: starting cln user daemon" >&2
return 1
fi
else
echo "cln user already started"
fi
cln_user() {
"$LIGHTNING_CLI_BIN" \
--lightning-dir="$CLN_USER_DIR" \
--regtest \
"$@"
}
while [ \
"$(cln_user getinfo | jq -r '.blockheight')" -ne \
"$(btc_reg getblockcount)" \
]; do
echo "waiting for cln user to sync with the chain..."
sleep 1
done
echo "cln user started, data directory is $CLN_USER_DIR"
echo "cln_user function set"
}
_cln_user_stop() {
if ! _pgrep_cln_user; then
echo "cln user already stopped"
else
if
! "$LIGHTNING_CLI_BIN" \
--lightning-dir="$CLN_USER_DIR" \
--regtest \
stop >/dev/null
then
echo "error: cln user not stopped" >&2
fi
while _pgrep_cln_user; do
echo "waiting for cln user to stop..."
sleep 1
done
echo "cln user stopped"
fi
}
cln_user_stop_and_remove() {
_cln_user_stop || return "$?"
if [ ! -e "$CLN_USER_DIR" ]; then
echo "cln user directory not present"
else
if ! rm -rf "$CLN_USER_DIR"; then
echo "error: removing cln user directory $CLN_USER_DIR"
return 1
fi
echo "removed cln user directory $CLN_USER_DIR"
fi
}
_pgrep_lnd_coord() {
pgrep -f "$LND_BIN --lnddir=$LND_COORD_DIR --bitcoin.regtest" >/dev/null
}
lnd_coord_start() {
_bitcoin_regtest_check_started || return "$?"
_create_dir "$LND_COORD_DIR" || return "$?"
echo "writing lnd coordinator config"
cat << EOF > "$LND_COORD_DIR/lnd.conf"
[Application Options]
listen=localhost:$LND_COORD_LISTEN_PORT
rpclisten=localhost:$LND_COORD_RPC_PORT
restlisten=localhost:$LND_COORD_REST_PORT
no-rest-tls=true
tlsdisableautofill=true
noseedbackup=true
maxpendingchannels=16
minchansize=20000
alias=lnd-coordinator
color=#300000
[Bitcoin]
bitcoin.node=bitcoind
bitcoin.defaultchanconfs=1
bitcoin.basefee=0
bitcoin.feerate=0
[Bitcoind]
bitcoind.dir=$BITCOIN_DIR
bitcoind.config=$BITCOIN_DIR/bitcoin.conf
bitcoind.rpchost=localhost:$BITCOIN_REGTEST_RPC_PORT
bitcoind.rpcuser=$BITCOIN_REGTEST_RPC_USER
bitcoind.rpcpass=$BITCOIN_REGTEST_RPC_PASS
bitcoind.zmqpubrawblock=tcp://127.0.0.1:$BITCOIN_REGTEST_ZMQ_BLOCK_PORT
bitcoind.zmqpubrawtx=tcp://127.0.0.1:$BITCOIN_REGTEST_ZMQ_TX_PORT
[protocol]
protocol.wumbo-channels=true
EOF
if ! _pgrep_lnd_coord; then
echo "starting lnd coordinator"
"$LND_BIN" \
--lnddir="$LND_COORD_DIR" \
--bitcoin.regtest \
>"$REGTEST_LOGS_DIR/lnd-coord" 2>&1 &
else
echo "lnd coordinator already started"
fi
lnd_coord() {
"$LNCLI_BIN" \
--lnddir="$LND_COORD_DIR" \
--network regtest \
--rpcserver localhost:"$LND_COORD_RPC_PORT" \
"$@"
}
while [ "$(lnd_coord getinfo 2>/dev/null | jq -r '.synced_to_chain')" != true ]; do
echo "waiting for lnd coordinator to sync with the chain..."
sleep 1
done
# while [ "$(lnd_coord getinfo 2>/dev/null | jq -r '.synced_to_graph')" != true ]; do
# echo "waiting for lnd coordinator to sync with the graph..."
# sleep 1
# done
echo "lnd coordinator started, data directory is $LND_COORD_DIR"
echo "lnd_coord function set"
}
_lnd_coord_stop() {
if ! _pgrep_lnd_coord; then
echo "lnd coordinator already stopped"
else
if
! "$LNCLI_BIN" \
--lnddir="$LND_COORD_DIR" \
--network regtest \
--rpcserver localhost:"$LND_COORD_RPC_PORT" \
stop >/dev/null
then
echo "error: lnd coordinator not stopped" >&2
fi
while _pgrep_lnd_coord; do
echo "waiting for lnd coordinator to stop..."
sleep 1
done
echo "lnd coordinator stopped"
fi
}
lnd_coord_stop_and_remove() {
_lnd_coord_stop || return "$?"
if [ ! -e "$LND_COORD_DIR" ]; then
echo "lnd coordinator directory not present"
else
if ! rm -rf "$LND_COORD_DIR"; then
echo "error: removing lnd coordinator directory $LND_COORD_DIR"
return 1
fi
echo "removed lnd coordinator directory $LND_COORD_DIR"
fi
}
_pgrep_lnd_user() {
pgrep -f "$LND_BIN --lnddir=$LND_USER_DIR --bitcoin.regtest" >/dev/null
}
lnd_user_start() {
_bitcoin_regtest_check_started || return "$?"
_create_dir "$LND_USER_DIR" || return "$?"
echo "writing lnd user config"
cat << EOF > "$LND_USER_DIR/lnd.conf"
[Application Options]
listen=localhost:$LND_USER_LISTEN_PORT
rpclisten=localhost:$LND_USER_RPC_PORT
restlisten=localhost:$LND_USER_REST_PORT
no-rest-tls=true
tlsdisableautofill=true
noseedbackup=true
maxpendingchannels=16
minchansize=20000
alias=lnd-user
color=#400000
[Bitcoin]
bitcoin.node=bitcoind
bitcoin.defaultchanconfs=1
bitcoin.basefee=0
bitcoin.feerate=0
[Bitcoind]
bitcoind.dir=$BITCOIN_DIR
bitcoind.config=$BITCOIN_DIR/bitcoin.conf
bitcoind.rpchost=localhost:$BITCOIN_REGTEST_RPC_PORT
bitcoind.rpcuser=$BITCOIN_REGTEST_RPC_USER
bitcoind.rpcpass=$BITCOIN_REGTEST_RPC_PASS
bitcoind.zmqpubrawblock=tcp://127.0.0.1:$BITCOIN_REGTEST_ZMQ_BLOCK_PORT
bitcoind.zmqpubrawtx=tcp://127.0.0.1:$BITCOIN_REGTEST_ZMQ_TX_PORT
[protocol]
protocol.wumbo-channels=true
EOF
if ! _pgrep_lnd_user; then
echo "starting lnd user"
"$LND_BIN" \
--lnddir="$LND_USER_DIR" \
--bitcoin.regtest \
>"$REGTEST_LOGS_DIR/lnd-user" 2>&1 &
else
echo "lnd user already started"
fi
lnd_user() {
"$LNCLI_BIN" \
--lnddir="$LND_USER_DIR" \
--network regtest \
--rpcserver localhost:"$LND_USER_RPC_PORT" \
"$@"
}
while [ "$(lnd_user getinfo 2>/dev/null | jq -r '.synced_to_chain')" != true ]; do
echo "waiting for lnd user to sync with the chain..."
sleep 1
done
# while [ "$(lnd_user getinfo 2>/dev/null | jq -r '.synced_to_graph')" != true ]; do
# echo "waiting for lnd user to sync with the graph..."
# sleep 1
# done
echo "lnd user started, data directory is $LND_USER_DIR"
echo "lnd_user function set"
}
_lnd_user_stop() {
if ! _pgrep_lnd_user; then
echo "lnd user already stopped"
else
if
! "$LNCLI_BIN" \
--lnddir="$LND_USER_DIR" \
--network regtest \
--rpcserver localhost:"$LND_USER_RPC_PORT" \
stop >/dev/null
then
echo "error: lnd user not stopped" >&2
fi
while _pgrep_lnd_user; do
echo "waiting for lnd user to stop..."
sleep 1
done
echo "lnd user stopped"
fi
}
lnd_user_stop_and_remove() {
_lnd_user_stop || return "$?"
if [ ! -e "$LND_USER_DIR" ]; then
echo "lnd user directory not present"
else
if ! rm -rf "$LND_USER_DIR"; then
echo "error: removing lnd user directory $LND_USER_DIR"
return 1
fi
echo "removed lnd user directory $LND_USER_DIR"
fi
}
_mine_blocks_coordinator() {
coord_node="$1"
case "$coord_node" in
cln)
if ! coord_address="$(
cln_coord -k newaddr addresstype=p2tr | jq -r '.p2tr'
)"; then
echo "error: generating cln coordinator address" >&2
return 1
fi
;;
lnd)
if ! coord_address="$(
lnd_coord newaddress p2tr | jq -r '.address'
)"; then
echo "error: generating lnd coordinator address" >&2
return 1
fi
;;
esac
bitcoin_regtest_mine 101 "$coord_address" || return "$?"
unset user_address
}
_robosats_regtest_channel_create_cln_user() {
if [ "$#" -lt 1 ]; then
echo "error: insert coordinator node" >&2
return 1
fi
coord_node="$1"
shift 1
_bitcoin_regtest_check_started || return "$?"
case "$coord_node" in
cln)
if ! _pgrep_cln_coord; then
echo "error: cln coordinator not started" >&2
return 1
fi
if ! _function_exist cln_coord; then
return 1
fi
coord_id="$(cln_coord getinfo | jq -r '.id')"
coord_port="$CLN_COORD_LISTEN_PORT"
;;
lnd)
if ! _pgrep_lnd_coord; then
echo "error: cln coordinator not started" >&2
return 1
fi
if ! _function_exist lnd_coord; then
return 1
fi
coord_id="$(lnd_coord getinfo | jq -r '.identity_pubkey')"
coord_port="$LND_COORD_LISTEN_PORT"
;;
*)
echo "error: coordinator node can only be cln and lnd" >&2
return 1
;;
esac
if ! _pgrep_cln_user; then
echo "error: cln user not started" >&2
return 1
fi
if ! _function_exist cln_user; then
return 1
fi
if ! cln_user connect "$coord_id"@localhost:"$coord_port" >/dev/null; then
echo "error: connection lightning nodes" >&2
return 1
fi
echo "lightning nodes connected"
# check if channel not already present
if [ "$(
cln_user listpeerchannels "$coord_id" |
jq -r '.channels | length'
)" -ge 1 ]; then
echo "lightning nodes already have a channel, not opening a new one"
else
echo "mining blocks to coordinator $coord_node"
_mine_blocks_coordinator "$coord_node" || return "$?"
previous_output_number="$(cln_user listfunds | jq -r '.outputs | length')"
if ! user_address="$(cln_user -k newaddr addresstype=p2tr | jq -r '.p2tr')"; then
echo "error: generating user address" >&2
return 1
fi
echo "mining blocks to user cln"
bitcoin_regtest_mine 101 "$user_address" || return "$?"
unset user_address
while [ \
"$(cln_user listfunds | jq -r '.outputs | length')" -le \
"$previous_output_number" \
]; do
echo "waiting for cln user to see the new blocks..."
sleep 5
done
while [ "$(cln_user listfunds | jq -r '.outputs[0].status')" != "confirmed" ]; do
echo "waiting for cln user funds to mature..."
sleep 1
done
unset previous_output_number
if ! cln_user -k fundchannel \
id="$coord_id" \
amount=1btc \
feerate=10000perkb \
announce=true \
>/dev/null
then
echo "error: funding lightning channel" >&2
return 1
fi
echo "lightning channel created"
bitcoin_regtest_mine 10 "new" || return "$?"
while [ "$(
cln_user listpeerchannels "$coord_id" |
jq -r '.channels | length'
)" -lt 1 ]; do
echo "waiting for channel to confirm..."
sleep 1
done
echo "lightning channel opened"
fi
while [ "$(
cln_user listpeerchannels "$coord_id" |
jq -r '.channels[].state'
)" != "CHANNELD_NORMAL" ]; do
echo "waiting for channel to be active..."
sleep 5
done
echo "lightning channel is active"
unset coord_port
unset coord_id
unset coord_node
}
_robosats_regtest_channel_create_lnd_user() {
if [ "$#" -lt 1 ]; then
echo "error: insert coordinator node" >&2
return 1
fi
coord_node="$1"
shift 1
_bitcoin_regtest_check_started || return "$?"
case "$coord_node" in
cln)
if ! _pgrep_cln_coord; then
echo "error: cln coordinator not started" >&2
return 1
fi
if ! _function_exist cln_coord; then
return 1
fi
coord_id="$(cln_coord getinfo | jq -r '.id')"
coord_port="$CLN_COORD_LISTEN_PORT"
;;
lnd)
if ! _pgrep_lnd_coord; then
echo "error: cln coordinator not started" >&2
return 1
fi
if ! _function_exist lnd_coord; then
return 1
fi
coord_id="$(lnd_coord getinfo | jq -r '.identity_pubkey')"
coord_port="$LND_COORD_LISTEN_PORT"
;;
*)
echo "error: coordinator node can only be cln and lnd" >&2
return 1
;;
esac
if ! _pgrep_lnd_user; then
echo "error: lnd user not started" >&2
return 1
fi
if ! _function_exist lnd_user; then
return 1
fi
already_connected=false
for pub_key in $(lnd_user listpeers | jq -r '.peers[].pub_key'); do
if [ "$pub_key" = "$coord_id" ]; then
already_connected=true
break
fi
done
unset pub_key
if [ "$already_connected" = false ]; then
if ! lnd_user connect "$coord_id"@localhost:"$coord_port" >/dev/null; then
echo "error: connection lightning nodes" >&2
return 1
fi
fi
unset already_connected
echo "lightning nodes connected"
# check if channel not already present
if [ "$(
lnd_user listchannels --peer "$coord_id" |
jq -r '.channels | length'
)" -ge 1 ]; then
echo "lightning nodes already have a channel, not opening a new one"
else
echo "mining blocks to coordinator $coord_node"
_mine_blocks_coordinator "$coord_node" || return "$?"
previous_output_number="$(lnd_user listunspent | jq -r '.utxos | length')"
if ! user_address="$(lnd_user newaddress p2tr | jq -r '.address')"; then
echo "error: generating user address" >&2
return 1
fi
echo "mining blocks to user lnd"
bitcoin_regtest_mine 101 "$user_address" || return "$?"
unset user_address
while [ \
"$(lnd_user listunspent | jq -r '.utxos | length')" -le \
"$previous_output_number" \
]; do
echo "waiting for lnd user to see the new blocks..."
sleep 5
done
while [ "$(lnd_user listunspent | jq -r '.utxos[0].confirmations')" -lt 100 ]; do
echo "waiting for lnd user funds to mature..."
sleep 1
done
unset previous_output_number
if ! lnd_user openchannel \
--node_key "$coord_id" \
--local_amt "100000000" \
--sat_per_vbyte "10" \
--min_confs "1" \
--channel_type "anchors" \
>/dev/null
then
echo "error: funding lightning channel" >&2
return 1
fi
echo "lightning channel created"
bitcoin_regtest_mine 10 "new" || return "$?"
while [ "$(
lnd_user listchannels --peer "$coord_id" |
jq -r '.channels | length'
)" -lt 1 ]; do
echo "waiting for channel to confirm..."
sleep 1
done
echo "lightning channel opened"
fi
while [ "$(
lnd_user listchannels --peer "$coord_id" |
jq -r '.channels[].active'
)" != true ]; do
echo "waiting for channel to be active..."
sleep 5
done
echo "lightning channel is active"
unset coord_port
unset coord_id
unset coord_node
}
robosats_regtest_channel_create() {
if [ "$#" -lt 1 ]; then
echo "error: insert coordinator node" >&2
return 1
fi
coord_node="$1"
shift 1
if [ "$#" -lt 1 ]; then
echo "error: insert user node" >&2
return 1
fi
user_node="$1"
shift 1
case "$coord_node" in
cln|lnd) ;;
*)
echo "error: $coord_node should be cln or lnd" >&2
return 1
;;
esac
case "$user_node" in
cln)
_robosats_regtest_channel_create_cln_user "$coord_node"
;;
lnd)
_robosats_regtest_channel_create_lnd_user "$coord_node"
;;
*)
echo "error: $user_node should be cln or lnd" >&2
return 1
;;
esac
unset user_node
unset coord_node
}
roboauto_regtest_setup() {
if [ "$ROBOAUTO_GIT_DIR" = false ]; then
echo "error: roboauto is disable, set ROBOAUTO_GIT_DIR in .env to activate it" >&2
return 1
fi
_command_exist roboauto || return "$?"
_create_dir "$ROBOAUTO_DIR" || return "$?"
ra_reg() {
roboauto \
--config-dir "$REGTEST_NODES_DIR/roboauto" \
--data-dir "$REGTEST_NODES_DIR/roboauto" \
"$@"
}
echo "writing roboauto regtest config"
cat << EOF > "$ROBOAUTO_DIR/config.ini"
[federation]
exp = None
sau = None
tos = None
tbl = None
bve = None
loc = "http://127.0.0.1:$RUNSERVER_PORT"
EOF
case "$LNVENDOR_USER" in
cln)
roboauto_cln_script="$ROBOAUTO_GIT_DIR/data/lightning-node-core-lightning"
if [ ! -f "$roboauto_cln_script" ]; then
echo "error: roboauto cln script not found in $ROBOAUTO_GIT_DIR" >&2
return 1
fi
search_data=$(cat << EOF
lightning-cli "\$@"
EOF
)
new_data=$(cat << EOF
"$LIGHTNING_CLI_BIN" \
--lightning-dir="$CLN_USER_DIR" \
--regtest \
"\$@"
EOF
)
sed "s|$search_data|$new_data|" \
"$roboauto_cln_script" > "$ROBOAUTO_DIR/lightning-node" || \
return "$?"
echo "roboauto cln node script set up"
;;
lnd)
roboauto_lnd_script="$ROBOAUTO_GIT_DIR/data/lightning-node-lnd"
if [ ! -f "$roboauto_lnd_script" ]; then
echo "error: roboauto lnd script not found in $ROBOAUTO_GIT_DIR" >&2
return 1
fi
search_data=$(cat << EOF
lncli "\$@"
EOF
)
new_data=$(cat << EOF
"$LNCLI_BIN" \
--lnddir="$LND_USER_DIR" \
--network regtest \
--rpcserver localhost:"$LND_USER_RPC_PORT" \
"\$@"
EOF
)
sed "s|$search_data|$new_data|" \
"$roboauto_lnd_script" > "$ROBOAUTO_DIR/lightning-node" || \
return "$?"
echo "roboauto lnd node script set up"
;;
esac
if ! chmod u+x "$ROBOAUTO_DIR/lightning-node"; then
echo "error: changing file mode on roboauto lightning-node" >&2
return 1
fi
}
roboauto_regtest_remove() {
if ! rm -rf "$ROBOAUTO_DIR"; then
echo "error: removing roboauto directory $ROBOAUTO_DIR" >&2
return 1
fi
}
robosats_regtest_stop_all() {
_lnd_user_stop
_lnd_coord_stop
_cln_user_stop
_cln_coord_stop
_bitcoin_regtest_stop
}
robosats_regtest_stop_and_remove_all() {
roboauto_regtest_remove
lnd_user_stop_and_remove
lnd_coord_stop_and_remove
cln_user_stop_and_remove
cln_coord_stop_and_remove
bitcoin_regtest_stop_and_remove
}
_node_test_setup() {
bitcoin_regtest_start || return "$?"
bitcoin_regtest_mine 1 "new" || return "$?"
printf "\n"
case "$LNVENDOR_COORD" in
cln)
cln_coord_start || return "$?"
;;
lnd)
lnd_coord_start || return "$?"
;;
esac
printf "\n"
case "$LNVENDOR_USER" in
cln)
cln_user_start || return "$?"
;;
lnd)
lnd_user_start || return "$?"
;;
esac
}
_node_server_setup() {
_node_test_setup || return "$?"
printf "\n"
robosats_regtest_channel_create \
"$LNVENDOR_COORD" "$LNVENDOR_USER" || return "$?"
if [ "$ROBOAUTO_GIT_DIR" != false ]; then
printf "\n"
roboauto_regtest_setup
fi
}
_robosats_regtest_info_print() {
cat << EOF
regtest nodes directory is $REGTEST_NODES_DIR
available command:
bitcoin_regtest_start
bitcoin_regtest_stop_and_remove
bitcoin_regtest_mine number-of-blocks <address>|new
cln_coord_start
cln_coord_stop_and_remove
cln_user_start
cln_user_stop_and_remove
lnd_coord_start
lnd_coord_stop_and_remove
lnd_user_start
lnd_user_stop_and_remove
roboauto_regtest_setup
roboauto_regtest_remove
robosats_regtest_stop_all
robosats_regtest_stop_and_remove_all
robosats_regtest_channel_create cln|lnd cln|lnd
EOF
}
_nodes_main() {
_nodes_environment_set || return "$?"
# if shell is bash and script is sourced source also bash completions
if [ -n "$BASH_VERSION" ]; then
case "$0" in
/*|./*|../*) ;;
*)
if [ -f "scripts/traditional/robosats.bash-completion" ]; then
# shellcheck disable=SC1091
. scripts/traditional/robosats.bash-completion
fi
if
[ "$ROBOAUTO_GIT_DIR" != false ] &&
[ -f "$ROBOAUTO_GIT_DIR/completions/roboauto.bash-completion" ]
then
# shellcheck disable=SC1091
# shellcheck disable=SC3044
. "$ROBOAUTO_GIT_DIR/completions/roboauto.bash-completion" &&
complete -F __roboauto_completion ra_reg
fi
;;
esac
fi
if [ "$#" -lt 1 ]; then
_robosats_regtest_info_print || return "$?"
else
case "$1" in
-h|--help)
cat << EOF
regtest-nodes [server|test]
EOF
return 0
;;
test)
_robosats_regtest_info_print || return "$?"
printf "\n"
_node_test_setup || return "$?"
;;
server)
_robosats_regtest_info_print || return "$?"
printf "\n"
_node_server_setup || return "$?"
;;
*)
echo "error: action $1 not recognized" >&2
return 1
;;
esac
fi
}
_nodes_main "$@"
Reference in New Issue View Git Blame Copy Permalink