#!/bin/bash

# command info
if [ $# -eq 0 ] || [ "$1" = "-h" ] || [ "$1" = "-help" ]; then
 echo "monitor and troubleshot the c-lightning network"
 echo "cl.monitor.sh [mainnet|testnet|signet] status"
 echo "cl.monitor.sh [mainnet|testnet|signet] config"
 echo "cl.monitor.sh [mainnet|testnet|signet] info"
 echo "cl.monitor.sh [mainnet|testnet|signet] wallet"
 exit 1
fi

# check if started with sudo
if [ "$EUID" -ne 0 ]; then 
  echo "error='run as root'"
  exit 1
fi

# set based on network type (using own mapping to be able to run without calling sudo -u bitcoin)
if [ "$1" == "mainnet" ]; then
  clConfigDir="/home/bitcoin/.lightning"
  lightningcli_alias="/usr/local/bin/lightning-cli --lightning-dir=/home/bitcoin/.lightning --conf=${clConfigDir}/config"
  blockchainHeightKey="btc_mainnet_blocks_verified"
  netprefix=""
elif [ "$1" == "testnet" ]; then
  clConfigDir="/home/bitcoin/.lightning/testnet"
  lightningcli_alias="/usr/local/bin/lightning-cli --lightning-dir=/home/bitcoin/.lightning --conf=${clConfigDir}/config"
  blockchainHeightKey="btc_testnet_blocks_verified"
  netprefix="t"
elif [ "$1" == "signet" ]; then
  clConfigDir="/home/bitcoin/.lightning/signet"
  lightningcli_alias="/usr/local/bin/lightning-cli --lightning-dir=/home/bitcoin/.lightning --conf=${clConfigDir}/config"
  blockchainHeightKey="btc_signet_blocks_verified"
  netprefix="s"
else
  echo "error='not supported net'"
  exit 1
fi

######################################################
# STATUS
# check general status info
######################################################

if [ "$2" = "status" ]; then

  cl_version=$($lightningcli_alias --version 2>/dev/null | cut -d ' ' -f3)
  cl_running=$(systemctl status ${netprefix}lightningd 2>/dev/null | grep -c "active (running)")
  cl_ready="0"
  cl_online="0"
  cl_locked="0"
  cl_error_short=""
  cl_error_full=""
  
  if [ "${cl_running}" = "0" ]; then
    # check if error because wallet is locked
    # the next release will have soecific error code for decryption  error
    # https://github.com/ElementsProject/lightning/pull/4908
    source /mnt/hdd/raspiblitz.conf
    # password file is on the disk if encrypted and auto-unlock is enabled
    passwordFile="/dev/shm/.${netprefix}cl.pw"
    if grep -Eq "${netprefix}clEncryptedHSM=on" /mnt/hdd/raspiblitz.conf;then
      if grep -Eq "${netprefix}clAutoUnlock=on" /mnt/hdd/raspiblitz.conf;then
        passwordFile=/home/bitcoin/.${netprefix}cl.pw
      fi
    fi
    clError=$(sudo journalctl -n5 -u ${netprefix}lightningd)
 
    # cases from 'cl.hsmtool.sh unlock'
    if \
    [ "$(eval echo \$${netprefix}clEncryptedHSM)" = "on" ] && [ ! -f $passwordFile ] || \
    [ $(echo "${clError}" | \
     grep -c 'encrypted-hsm: Could not read pass from stdin.') -gt 0 ] || \
    [ $(echo "${clError}" | \
     grep -c 'hsm_secret is encrypted, you need to pass the --encrypted-hsm startup option.') -gt 0 ] || \
    [ $(echo "${clError}" | \
      grep -c 'Wrong password for encrypted hsm_secret.') -gt 0 ]; then
    
      # signal wallet locked
      cl_locked="1"
      # dont report it as error
      cl_error_short=""
      cl_error_full=""
    fi

  elif [ "${cl_running}" != "0" ]; then
    cl_running="1"

    # test connection - record win & fail info
    randStr=$(echo "$RANDOM")
    rm /var/cache/raspiblitz/.cl-${randStr}.out 2>/dev/null
    rm /var/cache/raspiblitz/.cl-${randStr}.error 2>/dev/null
    touch /var/cache/raspiblitz/.cl-${randStr}.out
    touch /var/cache/raspiblitz/.cl-${randStr}.error
    echo "# ${lightningcli_alias} getinfo"
    $lightningcli_alias getinfo 1>/var/cache/raspiblitz/.cl-${randStr}.out 2>/var/cache/raspiblitz/.cl-${randStr}.error
    winData=$(cat /var/cache/raspiblitz/.cl-${randStr}.out 2>/dev/null)
    failData=$(cat /var/cache/raspiblitz/.cl-${randStr}.error 2>/dev/null)
    rm /var/cache/raspiblitz/.cl-${randStr}.out
    rm /var/cache/raspiblitz/.cl-${randStr}.error

    # check for errors
    if [ "${failData}" != "" ]; then
      cl_ready="0"
      cl_error_short=""
      cl_error_full=$(echo ${failData} | tr -d "'" | tr -d '"')

    # check results if proof for online
    else
      cl_ready="1"
      connections=$( echo "${winData}" | grep "num_peers\"" | tr -cd '[[:digit:]]')
      if [ "${connections}" != "" ] && [ "${connections}" != "0" ]; then
        cl_online="1"
      fi
    fi

  fi 

  # print results
  echo "ln_cl_version='${cl_version}'"
  echo "ln_cl_running='${cl_running}'"
  echo "ln_cl_ready='${cl_ready}'"
  echo "ln_cl_online='${cl_online}'"
  echo "ln_cl_locked='${cl_locked}'"
  echo "ln_cl_error_short='${cl_error_short}'"
  echo "ln_cl_error_full='${cl_error_full}'"

  exit 0
fi   

######################################################
# CONFIG
######################################################

if [ "$2" = "config" ]; then

  # get data
  clConfigData=$(cat $clConfigDir/config)
  if [ "${clConfigData}" == "" ]; then
    echo "error='no config'"
    exit 1
  fi

  # no usesul data to monitor in config yet

  exit 1
fi


######################################################
# INFO
######################################################

if [ "$2" = "info" ]; then

  # raw data demo:
  # sudo /usr/local/bin/lightning-cli --lightning-dir=/home/bitcoin/.lightning --conf=/home/bitcoin/.lightning/config getinfo

  # get data
  command="sudo -u bitcoin $lightningcli_alias getinfo"
  ln_getInfo=$(${command} 2>/dev/null)
  if [ "${ln_getInfo}" == "" ]; then
    echo "command='${command}'"
    echo "error='no data'"
    exit 1
  fi

  # parse data
  cl_alias=$(echo "${ln_getInfo}" | grep '"alias":' | cut -d '"' -f4)
  port=$(echo "${ln_getInfo}" | grep '"port":' | cut -d: -f2 | tail -1 | bc)
  pubkey=$(echo "${ln_getInfo}" | grep '"id":' | cut -d '"' -f4)
  address=$(echo "${ln_getInfo}" | grep '.onion' | cut -d '"' -f4)
  if [ ${#address} -eq 0 ]; then
    address=$(echo "${ln_getInfo}" | grep '"ipv4"' -A 1 | tail -1 | cut -d '"' -f4)
  fi
  cl_address="${pubkey}@${address}:${port}"
  cl_tor=$(echo "${cl_address}" | grep -c ".onion")
  cl_channels_pending=$(echo "${ln_getInfo}" | jq -r '.num_pending_channels')
  cl_channels_active=$(echo "${ln_getInfo}" | jq -r '.num_active_channels')
  cl_channels_inactive=$(echo "${ln_getInfo}" | jq -r '.num_inactive_channels')
  cl_channels_total=$(( cl_channels_pending + cl_channels_active + cl_channels_inactive ))
  cl_peers=$(echo "${ln_getInfo}" | jq -r '.num_peers')
  cl_fees_collected_msat=$(echo "${ln_getInfo}" |  jq -r '.fees_collected_msat')

  # calculate with cached value if c-lightning is fully synced
  source <(/home/admin/_cache.sh get ${blockchainHeightKey})
  #echo "#blockchainHeightKey(${!blockchainHeightKey})"
  blockheight="${!blockchainHeightKey}"
  #echo "#blockheight(${blockheight})"
  cl_sync_height=$(echo "${ln_getInfo}" | jq .blockheight)
  #echo "#cl_sync_height(${cl_sync_height})"
  cl_sync_chain=""
  cl_sync_progress=""
  if [ "${blockheight}" != "" ]; then
    cl_sync_progress=$(echo "scale=2; $cl_sync_height*100/$blockheight" | bc)
    # needs to be at least "two blocks behind" to be considered not synced
    blockheight=$(($blockheight - 1))
    if [ ${blockheight} -gt ${cl_sync_height} ];then
      cl_sync_chain=0
    else
      cl_sync_chain=1
    fi
  fi

  # recovery info
  source <(/home/admin/config.scripts/cl.backup.sh $1 recoverymode status)
  cl_recovery_mode="${recoverymode}"
  cl_recovery_done="0"
  if [ "${cl_recovery_mode}" == "1" ]; then
    scanning=$(echo "${ln_getInfo}" | grep "warning_lightningd_sync" | grep "Still loading latest blocks from bitcoind." -c)
    if [ "${cl_recovery_mode}" == "1" ] && [ "${scanning}" == "0" ] && [ "${cl_sync_chain}" == "1" ]; then
      cl_recovery_done="1"
    fi
  fi

  # print data
  echo "ln_cl_alias='${cl_alias}'"
  echo "ln_cl_address='${cl_address}'"
  echo "ln_cl_tor='${cl_tor}'"
  echo "ln_cl_peers='${cl_peers}'"
  echo "ln_cl_sync_chain='${cl_sync_chain}'"
  echo "ln_cl_sync_progress='${cl_sync_progress}'"
  echo "ln_cl_channels_pending='${cl_channels_pending}'"
  echo "ln_cl_channels_active='${cl_channels_active}'"
  echo "ln_cl_channels_inactive='${cl_channels_inactive}'"
  echo "ln_cl_channels_total='${cl_channels_total}'"
  echo "ln_cl_fees_total='${cl_fees_collected_msat//[^0-9.]/}'"
  echo "ln_cl_recovery_mode='${cl_recovery_mode}'"
  echo "ln_cl_recovery_done='${cl_recovery_done}'"
  exit 0
  
fi

######################################################
# WALLETS (FUNDS)
######################################################

if [ "$2" = "wallet" ]; then

  # raw data demo:
  # /usr/local/bin/lightning-cli --lightning-dir=/home/bitcoin/.lightning --conf=/home/bitcoin/.lightning/config listfunds

  # get data
  sudo -u bitcoin
  command="sudo -u bitcoin $lightningcli_alias listfunds"
  cl_listfunds=$(${command} 2>/dev/null)
  if [ "${cl_listfunds}" == "" ]; then
    echo "command='${command}'"
    echo "error='no data'"
    exit 1
  fi

  ln_walletbalance=0
  for i in $(echo "$cl_listfunds" | jq .outputs[] | jq 'select(.status=="confirmed")' | grep value | awk '{print $2}' | cut -d, -f1);do
    ln_walletbalance=$((ln_walletbalance+i))
  done
  ln_walletbalance_wait=0
  for i in $(echo "$cl_listfunds" | jq .outputs[] | jq 'select(.status=="unconfirmed")' | grep value | awk '{print $2}' | cut -d, -f1);do
    ln_walletbalance_wait=$((ln_walletbalance_wait+i))
  done
  ln_closedchannelbalance=0
  for i in $(echo "$cl_listfunds" | jq .channels[] | jq 'select(.state=="ONCHAIN")' | grep channel_sat | awk '{print $2}' | cut -d, -f1);do
    ln_closedchannelbalance=$((ln_closedchannelbalance+i))
  done
  ln_pendingonchain=$((ln_walletbalance_wait+ln_closedchannelbalance))
  if [ ${#ln_pendingonchain} -gt 0 ]; then ln_pendingonchain="(+${ln_pendingonchain})"; fi
  ln_channelbalance=0
  for i in $(echo "$cl_listfunds" |jq .channels[]|jq 'select(.state=="CHANNELD_NORMAL")'|grep channel_sat|awk '{print $2}'|cut -d, -f1);do
    ln_channelbalance=$((ln_channelbalance+i))
  done
  if [ ${#ln_channelbalance} -eq 0 ];then
    ln_channelbalance=0
  fi
  ln_channelbalance_all=0
  for i in $(echo "$cl_listfunds" |jq .channels[]|grep channel_sat|awk '{print $2}'|cut -d, -f1);do
    ln_channelbalance_all=$((ln_channelbalance_all+i))
  done
  ln_channelbalance_pending=$((ln_channelbalance_all-ln_channelbalance-ln_closedchannelbalance))
  if [ ${#ln_channelbalance_pending} -gt 0 ]; then ln_channelbalance_pending=" (+${ln_channelbalance_pending})"; fi
  
  # print data
  echo "ln_cl_wallet_onchain_balance='${ln_walletbalance//[^0-9.]/}'"
  echo "ln_cl_wallet_onchain_pending='${ln_pendingonchain//[^0-9.]/}'"
  echo "ln_cl_wallet_channels_balance='${ln_channelbalance//[^0-9.]/}'"
  echo "ln_cl_wallet_channels_pending='${ln_channelbalance_pending//[^0-9.]/}'"
  exit 0

fi

echo "FAIL - Unknown Parameter $2"
exit 1