astroport/zen/g1_SURVEY.sh

#!/bin/bash
########################################################################
# Author: Fred (support@qo-op.com)
# Version: 1.0
# License: AGPL-3.0 (https://choosealicense.com/licenses/agpl-3.0/)
########################################################################
MY_PATH="`dirname \"$0\"`"              # relative
MY_PATH="`( cd \"$MY_PATH\" && pwd )`"  # absolutized and normalized
ME="${0##*/}"
echo "
########################################################################
# \\///
# qo-op
############# $ME DELAY
########################################################################
# ex: ./$ME \"10 days\"
# Survey Node G1 Wallet for TX/IN Commands in received comments ...
########################################################################

               _(_)_                     _(_)_                      
   @@@@       (_)@(_)        @@@@       (_)@(_)        @@@@         
  @@()@@ wWWWw  (_)\        @@()@@ wWWWw  (_)\        @@()@@ wWWWw  
   @@@@  (___)     \|/       @@@@  (___)     \|/       @@@@  (___)  
    /      Y       \|         /      Y       \|         /      Y    
 \ |     \ |/       | /    \ |     \ |/       | /    \ |     \ |/   
 \\|//   \\|///  \\\|//    \\|//   \\|///  \\\|//    \\|//   \\|/// 
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
# [ASTROPORT](https://astroport.com)
########################################################################
"
DELAY="$1"

IPFSNODEID=$(ipfs id -f='<id>\n')
[[ $IPFSNODEID == "" ]] && echo "$USER Please Install IPFS !!" && exit 1
[[ ! -d ~/.zen/g1_TX_inputs ]] && mkdir -p ~/.zen/g1_TX_inputs # Directory containing G1 blockchain incoming TX Scan
[[ ! -d ~/.zen/ipfs ]] && mkdir -p ~/.zen/ipfs # Directory where NODE store SMS & other Channel Wallets 
[[ ! -d ~/.zen/ipfs_swarm ]] && mkdir -p ~/.zen/ipfs_swarm # Local copy of all SSB friends IPFS Nodes published ipfs

#########################################################################################################
# GET G1 PUBKEY FROM SCUTTLEBUTT or $2 (DEBUG)
[[ $DELAY == "" ]] && DELAY="30 days" && echo "*** HELP ***" && echo "./$ME \"duration\" (default $DELAY)" && echo "************" && echo
DELAYUNIT=$(echo $DELAY | cut -d ' ' -f 2)

# NODE_G1PUBKEY=$2 # DEBUG
if [[ $NODE_G1PUBKEY == "" ]]; then
	if [[ -f ~/.ssb/secret ]]; then
		ssbpub=$(cat ~/.ssb/secret | grep public\" | cut -d ' ' -f 4 | cut -d '.' -f 1 | sed s/\"//g)
		ssbpriv=$(cat ~/.ssb/secret | grep private\" | cut -d ' ' -f 4 | cut -d '.' -f 1 | sed s/\"//g)
		NODE_G1PUBKEY=$(echo $ssbpub | base64 -d | base58)
		NODE_G1PRIVKEY=$(echo $ssbpriv | base64 -d | base58)
		if [[ ! -f  ~/.ssb/secret.dunikey ]]; then
			echo "pub: $NODE_G1PUBKEY" > ~/.ssb/secret.dunikey
			echo "sec: $NODE_G1PRIVKEY" >> ~/.ssb/secret.dunikey
		fi
	else
		NODE_G1PUBKEY=$(cat ~/.ssb/secret.dunikey | grep 'pub:' | cut -d ' ' -f 2)
		NODE_G1PRIVKEY=$(cat ~/.ssb/secret.dunikey | grep 'sec:' | cut -d ' ' -f 2)
	fi
fi
[[ "$NODE_G1PUBKEY" == "" ]] && echo "$USER Missing  ~/.ssb/secret : Please Install Scuttlebutt server !" && exit 1;

#########################################################################################################
echo "======================================="
echo "IPFS Node ID = $IPFSNODEID
                            __                  
 _|_  _  _|  |\ | _  _| _  /__/|      _.|| __|_ 
(_| |(/_(_|< | \|(_)(_|(/_ \_| | \/\/(_|||(/_|_ 
last $DELAY
                                                
G1 PUBKEY = $NODE_G1PUBKEY
SSB ID = %$ssbpub.ed25519

"

# PREPARE TIMESTAMP LIMITS
TIMEBEFORE=$(date -u --date="-$DELAY" +"%s")
TIMESTAMP=$(date -u +"%s")
# GET DUNITER SERVER
DUNITERNODE=$($MY_PATH/tools/duniter_getnode.sh)
DUNITERURL="https://$DUNITERNODE"
# GET BLOCKCHAIN TX FOR TIME WINDOW
curl -s $DUNITERURL/tx/history/$NODE_G1PUBKEY/times/$TIMEBEFORE/$TIMESTAMP > /tmp/g1_TX.scan.txt
TXNB=$(cat /tmp/g1_TX.scan.txt | wc -l)

echo "
$DUNITERURL/tx/history/$NODE_G1PUBKEY/times/$TIMEBEFORE/$TIMESTAMP
   ___                      
    |\/  ._    ._ _ |_  _ ._ 
G1  |/\  | ||_|| | ||_)(/_|  
$TXNB

"

# Choose between "history.received" OR "history.pending" depending on DELAY  
if [[ $DELAYUNIT != "minutes" && $DELAYUNIT != "minute" ]]; then

	# HOW MANY TX DO WE HAVE...
	TXnb=$(cat /tmp/g1_TX.scan.txt | jq '.history.received[].hash' | wc -l)
	echo "DETECTED $TXnb TX... Checking TX/IN..."
	# PARSE $TXnb TX
	line=1
	while [[ $line -le $TXnb ]]; do
		# GET TX HASH
		TXhash=$(cat /tmp/g1_TX.scan.txt | jq -r '.history.received[].hash' | head -n $line | tail -n 1 )
		# IT IS A NEW TX?
		if [[ ! -f ~/.zen/g1_TX_inputs/zen.$TXhash ]]; then
			# GET LAST TX ISSUER
			ISSUER=$(cat /tmp/g1_TX.scan.txt | jq -r '.history.received[].issuers[0]' | head -n $line | tail -n 1)
			[[ $ISSUER == $NODE_G1PUBKEY ]] && ((line++)) && continue ## TX/OUT CONTINUE
			echo $ISSUER > ~/.zen/g1_TX_inputs/zen.$TXhash
			# GET OUTPUTS AND MAKE ZEN=G1*100 SUM
			ZEN=$(cat /tmp/g1_TX.scan.txt | jq -r '.history.received[].outputs[]' | grep $NODE_G1PUBKEY | head -n $line | tail -n 1 | cut -d ':' -f 1)
			# GET COMMENT
			COMMENT=$(cat /tmp/g1_TX.scan.txt | jq '.history.received' | jq -r '.[].comment' | head -n $line | tail -n 1)
			# echo "TX-IN $ISSUER => $NODE_G1PUBKEY"
			echo "Received $ZEN Zen From $ISSUER :: $COMMENT :: ($TXhash)"
			CMD=$(echo "$COMMENT" | awk '{print toupper($1)}')

echo "
___  ___     _   ___  _                   
 |\/  | |\ ||_)| ||  |_) _  _ _ o   _  _| 
 |/\ _|_| \||  |_||  | \(/_(_(/_|\/(/_(_| 
                                          
"
# Add CASE for received here

			###### CREATE ZEN VALUE IN IPFS #########
			[[ $CMD == "ZEN" ]] && $MY_PATH/zen_MAKE.sh $ZEN $TXhash $ISSUER
			############################################

		fi
		((line++))
	done


else


    # MINUTE DELAY = pending // TODO: if anyone succeed in passing $VAR in jq command, both can be merge...
	# HOW MANY TX DO WE HAVE...
	TXnb=$(cat /tmp/g1_TX.scan.txt | jq '.history.pending[].hash' | wc -l)
	echo "DETECTED $TXnb TX... Checking TX/IN..."
	# PARSE $TXnb TX
	line=1
	while [[ $line -le $TXnb ]]; do
		TXhash=$(cat /tmp/g1_TX.scan.txt | jq -r '.history.pending[].hash' | head -n $line | tail -n 1)
		# IT IS A NEW TX/IN?
		if [[ ! -f ~/.zen/g1_TX_inputs/zen.$TXhash ]]; then
			# GET LAST RX ISSUER
			ISSUER=$(cat /tmp/g1_TX.scan.txt | jq -r '.history.pending[].issuers[0]' | head -n $line | tail -n 1)
			[[ $ISSUER == $NODE_G1PUBKEY ]] && ((line++)) && continue ## TX/OUT CONTINUE
			echo $ISSUER > ~/.zen/g1_TX_inputs/zen.$TXhash
			# GET OUTPUTS AND MAKE ZEN SUM
			ZEN=$(cat /tmp/g1_TX.scan.txt | jq -r '.history.pending[].outputs[]' | grep $NODE_G1PUBKEY | head -n $line | tail -n 1 | cut -d ':' -f 1)
			# GET COMMENT
			COMMENT=$(cat /tmp/g1_TX.scan.txt | jq '.history.pending' | jq -r '.[].comment' | head -n $line | tail -n 1)
			# echo "TX-IN $ISSUER => $NODE_G1PUBKEY"
			echo "Pending $ZEN Zen From $ISSUER :: $COMMENT :: ($TXhash)"
			CMD=$(echo "$COMMENT" | awk '{print toupper($1)}')

echo "
___  ___     _   ___  _                 
 |\/  | |\ ||_)| ||  |_)_ ._  _|o._  _  
 |/\ _|_| \||  |_||  | (/_| |(_||| |(_| 
                                     _| 
"
# Add CASE for pending here

			###### CREATE ZEN VALUE IN IPFS #########
			[[ $CMD == "ZEN" ]] && $MY_PATH/zen_MAKE.sh $ZEN $TXhash $ISSUER
			############################################

		fi
		((line++))
	done
fi

echo "FINISH !
               __                                      
|\ | _  _| _  /__/| \    /_.|| __|_ |_  _.| _.._  _ _  
| \|(_)(_|(/_ \_| |  \/\/(_|||(/_|_ |_)(_||(_|| |(_(/_ 
                                                       
silkaj -p $DUNITERNODE balance $NODE_G1PUBKEY

"
exit 0