#!/bin/bash

scanTxWallets() {
	local REGEX_PUBKEYS="[a-zA-Z0-9]{42,44}"

	# On vérifie le cache existant et on démarre au dernier bloc en cache
	if ls $SCRIPTPATH/cache/walletsUp-* > /dev/null 2>&1; then
		local startFile=$(ls $SCRIPTPATH/cache/walletsUp-* | tail -n1)
		local startIter=$(echo "$startFile" | awk -F '-' '{ print $NF }')
		local startBloc=$(head -n1 "$startFile")
		wallets=$(tail -n +2 "$startFile" | sed '/---/Q' | sort -u)
		local walletsAuj=$(cat "$startFile" | sed -e '1,/---/d' | sed '/---/Q' | grep .)$'\n'
		local nbrMembersYesterday=$(cat "$startFile" | sed -e '1,/---/d' | sed -e '1,/---/d' | sed '/---/Q' | grep . | cut -d '|' -f 1)
		local blockDateLast=$(cat "$startFile" | sed -e '1,/---/d' | sed -e '1,/---/d' | sed '/---/Q' | grep . | cut -d '|' -f 2)

##kopa		[[ $lastBloc == $startBloc ]] && return 10
		rm $startFile
	else
		local startIter=0
		local startBloc=0
		echo "[" > $SCRIPTPATH/db/recus.json
	fi

	incExec=1
	for i in ${!TXBLOCKS[*]}; do
		startExec=$(($(date +%s%N)/1000000))
		bloc=${TXBLOCKS[$i]}
		[[ -z $bloc ]] && break
		[[ $startIter != 0 && $i -le $startIter ]] && continue
#		[[ $bloc -lt 5243 ]] && continue #kopa
		sleep 0.05

		# Récupère la date et l'objet transaction du bloc courant
		blocFull=$(curl -s ${DUNITER}/blockchain/block/$bloc)
		until blocBrut=$(echo $blocFull | jq -r '.' 2>/dev/null); do
			[[ $isWeb != "web" ]] && echo -e "i: $i\n$blocFull"
			sleep 2
			blocFull=$(curl -s ${DUNITER}/blockchain/block/$bloc)
		done
		[[ -z "$blocBrut" ]] && continue

		# Récupération de la date du block
		blockDate=$(jq '.medianTime' <<<"$blocBrut")
		blockDate=$(date -d"@$blockDate" +%y-%m-%d -u)
		local walletsReceivedBloc=$(jq '.transactions[]' <<<"$blocBrut")

		# Si cette itération provient d'un cache, alors on aggrège la dernière date
		if [[ $startBloc != 0 ]]; then
			lastDate=$(cat db/recus.json | jq -r '.[].date' | tail -n1)
			echo -e "IFCACHE\t - $bloc - $blockDate - $lastDate" >> tata #kopa
			if [[ "$blockDate" == "$lastDate" ]]; then
				valueReceivedW=$(cat db/recus.json | jq -r '.[].rWallets' | tail -n1 | xargs echo 100* | bc)
				valueReceivedM=$(cat db/recus.json | jq -r '.[].rMembers' | tail -n1 | xargs echo 100* | bc)
				valueSentW=$(cat db/recus.json | jq -r '.[].sWallets' | tail -n1 | xargs echo 100* | bc)
				valueSentM=$(cat db/recus.json | jq -r '.[].sMembers' | tail -n1 | xargs echo 100* | bc)

				local recusJson=$(head -n -11 db/recus.json)
				echo "$recusJson" > $SCRIPTPATH/db/recus.json
			else
				local recusJson=$(head -n -2 db/recus.json)
				echo -e "$recusJson\n   }," > $SCRIPTPATH/db/recus.json
			fi
			#unset recusJson
			startBloc=0
		fi

		# Sélectionne les ligne SIG en retirant les issuers
		OIFS="$IFS"
		IFS='{'
		for j in $walletsReceivedBloc; do
			[[ -z $j ]] && continue
			local wIssuers=$(echo "{$j" | jq -r '.issuers[0]')
			local walletsReceivedTodayTmp+=$(echo "{$j" | jq -r '.outputs[]' | grep -v "$wIssuers" | awk -F: '{print $3 "|" $1}' | sed 's/SIG(//g' | tr -d ')')$'\n'
			local sumRBloc=$(echo "{$j" | jq -r '.outputs[]' | grep -v "$wIssuers" | awk -F: '{ print $1 }' | awk '{s+=$1} END {print s}')
			[[ $sumRBloc ]] && local walletsSentTodayTmp+=$wIssuers'|'$sumRBloc'\n'
		done
		IFS="$OIFS"
		local walletsSentToday=$(echo -e "$walletsSentTodayTmp" | head -n -1)
		local walletsReceivedBloc=$(echo -e "$walletsReceivedTodayTmp" | head -n -1)
		unset walletsReceivedTodayTmp walletsSentTodayTmp

		# Exporte les valeurs de la journée dans le fichier JSON
		jsonify() {
            [[ -z $valueReceivedW ]] && valueReceivedW=0 || valueReceivedW=$(echo "scale=2; $valueReceivedW/100" | bc)
            [[ -z $valueReceivedM ]] && valueReceivedM=0 || valueReceivedM=$(echo "scale=2; $valueReceivedM/100" | bc)
			[[ -z $valueSentM ]] && valueSentM=0 || valueSentM=$(echo "scale=2; $valueSentM/100" | bc)
			[[ -z $valueSentW ]] && valueSentW=0 || valueSentW=$(echo "scale=2; $valueSentW/100" | bc)
			[[ -z $nbrMembersToday ]] && nbrMembersToday=0
			[[ -z $nbrWallets ]] && nbrWallets=0
			[[ -z $UDToday ]] && UDToday=0

            local jsonTPL=$(sed s/_DATE/$blockDateLast/g $SCRIPTPATH/tpl/recus.json)
			local jsonTPL=$(sed s/_UDTODAY/$UDToday/g <<< $jsonTPL)
            local jsonTPL=$(sed s/_RWALLETS/$valueReceivedW/g <<< $jsonTPL)
			local jsonTPL=$(sed s/_SWALLETS/$valueSentW/g <<< $jsonTPL)
            local jsonTPL=$(sed s/_RMEMBERS/$valueReceivedM/g <<< $jsonTPL)
			local jsonTPL=$(sed s/_SMEMBERS/$valueSentM/g <<< $jsonTPL)
			local jsonTPL=$(sed s/_NBRMEMBERS/$nbrMembersToday/g <<< $jsonTPL)
			local jsonTPL=$(sed s/_NBRWALLETS/$nbrWallets/g <<< $jsonTPL)
            echo -e "$jsonTPL" | tr -d '\\' >> $SCRIPTPATH/db/recus.json
		}

		# Stock les clés publiques de ce bloc dans la variable $wallets
		walletsAuj+=$(echo "$walletsReceivedBloc" | grep -Eo $REGEX_PUBKEYS)$'\n'

		# Si le date du bloc courant est différente du bloc précedent, alors on stock les valeurs journalières
		applyToday() {
			[[ -z $wallets ]] && wallets="#"
			WALLETS=$(echo -e "$wallets" | grep .)
			nbrWallets=$(echo -e "$walletsAuj" | sort -u | awk 'NF' | grep -v "$membresPubkeys" | grep -v "$WALLETS" | wc -l)

			# Calcul du nombre de nouveaux membres à ce block
			nbrMembersTotalToday=$(jq '.membersCount' <<<"$blocBrut")
			[[ -z $nbrMembersYesterday ]] && nbrMembersYesterday=0
			nbrMembersToday=$(($nbrMembersTotalToday-$nbrMembersYesterday))
			
			# Récupération de la masse monétaire à ce block
			#monetaryMassTotalToday=$(jq '.monetaryMass' <<<"$blocBrut")
			#monetaryMassTotalToday=$(echo "scale=2; $monetaryMassTotalToday/100" | bc)
			#[[ -z $monetaryMassYesterday ]] && monetaryMassYesterday=0
			#monetaryMassToday=$(echo "scale=2; $monetaryMassTotalToday-$monetaryMassYesterday" | bc)
			#monetaryMassYesterday=$monetaryMassTotalToday

			# Obtention du dividende à ce block
			udBlock=$(for i in $udBlocs; do [[ $i -ge $bloc ]] && echo $lastBloc && break; lastBloc=$i; done)
			UDToday=$(curl -s ${DUNITER}/blockchain/block/$udBlock | jq '.dividend')
			UDToday=$(echo "scale=2; $UDToday/100" | bc)

			jsonify
		}
		if [[ -n $blockDateLast && $blockDateLast != $blockDate ]]; then
			if [[ -z $recusJson ]]; then
				applyToday
			else
				# Calcul du nombre de nouveaux membres à ce block
				nbrMembersTotalToday=$(jq '.membersCount' <<<"$blocBrut")
				[[ -z $nbrMembersYesterday ]] && nbrMembersYesterday=0
				nbrMembersToday=$(($nbrMembersTotalToday-$nbrMembersYesterday))
			fi

			[[ $wallets == "#" ]] && unset wallets
			wallets+=$'\n'"$walletsAuj"
			wallets=$(echo -e "$wallets" | sort -u | grep .)$'\n'
			nbrMembersYesterday=$nbrMembersTotalToday
			unset valueReceivedM valueReceivedW valueSentM valueSentW walletsAuj
			echo -e "INLOOP\t - $bloc - $blockDateLast - $nbrMembersYesterday" >> tata #kopa
		fi
		unset recusJson

		# Sauvegarde la date de ce bloc pour l'itération suivante
		blockDateLast=$blockDate

		# Ajoute la valeur des transactions reçus de ce bloc au reste de la journée
		for k in $walletsReceivedBloc; do
		    local pubkey=$(echo $k | awk -F '|' '{ print $1 }')
		    local value=$(echo $k | awk -F '|' '{ print $2 }')

		    if [[ $(echo "$membresPubkeys" | grep $pubkey) ]]; then
		        #valueReceivedM=$(($valueReceivedM+$value))
				[[ -z $valueReceivedM ]] && valueReceivedM=0
				valueReceivedM=$(echo "$valueReceivedM+$value" | bc)
		        pubkeyReceiveM+=${pubkey}\\n
		    else
		        #valueReceivedW=$(($valueReceivedW+$value))
				[[ -z $valueReceivedW ]] && valueReceivedW=0
				valueReceivedW=$(echo "$valueReceivedW+$value" | bc)
		        pubkeyReceiveW+=${pubkey}\\n
		    fi
		done

		# Ajoute la valeur des transactions envoyés de ce bloc au reste de la journée
		for k in $walletsSentToday; do
		    local pubkey=$(echo $k | awk -F '|' '{ print $1 }')
		    local value=$(echo $k | awk -F '|' '{ print $2 }')

		    if [[ $(echo "$membresPubkeys" | grep $pubkey) ]]; then
		        #valueSentM=$(($valueSentM+$value))
				[[ -z $valueSentM ]] && valueSentM=0
				valueSentM=$(echo "$valueSentM+$value" | bc)
		        pubkeySentM+=${pubkey}\\n
		    else
		        #valueSentW=$(($valueSentW+$value))
				[[ -z $valueSentW ]] && valueSentW=0
				valueSentW=$(echo "$valueSentW+$value" | bc)
		        pubkeySentW+=${pubkey}\\n
		    fi
		done

		# Affiche la progression de la boucle si on est pas en mode web
		progress=$(echo "scale=1; $bloc*100/$lastBloc/1" | bc)
		endExec=$(($(date +%s%N)/1000000))
		timeExec=$(echo "scale=3; ($endExec-$startExec)/1000" | bc)
		#[[ -z $midTimeExec ]] && midTimeExec=$timeExec
		[[ $incExec9 == 50 || $incExec == 1 ]] && incExec=1 && midTimeExecCum=0
		midTimeExecCum=$(echo "scale=3; $midTimeExecCum+$timeExec" | bc)
		midTimeExec=$(echo "scale=3; $midTimeExecCum/$incExec" | bc)
		((incExec++))
		if [[ $isWeb != "web" ]]; then
			clear
			echo "Heure de début: $startTime"
			echo
			echo "Scan en cours: $progress% - $bloc/$lastBloc"
			echo "Date: $blockDate"
			echo "Temps d'execution: $midTimeExec"
		else
			echo "Scan des blocs avec transactions en cours ..."
		fi

		[[ $i -ge $1 ]] && break #kopa
	done

	[[ $blockDateLast == $blockDate ]] && applyToday && echo -e "END\t\t - $bloc - $blockDate - $nbrMembersYesterday" >> tata #kopa

	# Retire la dernière virgule et ajoute le crochet de fin de JSON
	sed -i '$ s/,//g' $SCRIPTPATH/db/recus.json
	echo "]" >> $SCRIPTPATH/db/recus.json

	# On supprime les doublons et les lignes vides
	wallets=$(echo -e "$wallets" | sort -u | awk 'NF')
	# On écrit les pubkeys avec transaction dans un fichier de cache pour la prochaine itération
	[[ ! -d $SCRIPTPATH/cache ]] && mkdir $SCRIPTPATH/cache
	echo -e "$lastBloc\n$wallets\n---\n$walletsAuj\n---\n$nbrMembersYesterday|$blockDateLast" > $SCRIPTPATH/cache/walletsUp-$i
}