78 lines
4.4 KiB
Bash
78 lines
4.4 KiB
Bash
|
#!/bin/bash
|
||
|
|
########################################################################
|
||
|
|
# Author: Fred (support@qo-op.com)
|
||
|
|
# Version: 0.1
|
||
|
|
# License: AGPL-3.0 (https://choosealicense.com/licenses/agpl-3.0/)
|
||
|
|
########################################################################
|
||
|
|
# AJAX REQUEST TRACKER : ASTROPORT ON BOARDING
|
||
|
|
# GETTING : PHONE + PARRAIN + NAISSANCE
|
||
|
|
#
|
||
|
|
# DataFlow : index.html + ajaxform.js + zen_loveland_entrance.php
|
||
|
|
########################################################################
|
||
|
|
MY_PATH="`dirname \"$0\"`" # relative
|
||
|
|
MY_PATH="`( cd \"$MY_PATH\" && pwd )`" # absolutized and normalized
|
||
|
|
|
||
|
|
YOU=$(ps auxf --sort=+utime | grep -w ipfs | grep -v -E 'color=auto|grep' | tail -n 1 | cut -d " " -f 1);
|
||
|
|
IPFSNODEID=$(ipfs id -f='<id>\n')
|
||
|
|
NANODATE=$(date -u +%s%N)
|
||
|
|
|
||
|
|
if [[ -d /home/$YOU/.zen/ipfs_swarm/.$IPFSNODEID/TASK ]]; then
|
||
|
|
############################################################################"
|
||
|
|
for task in $( ls /home/$YOU/.zen/ipfs_swarm/.$IPFSNODEID/TASK/todo.*); # "done.$NANODATE" FILES
|
||
|
|
do
|
||
|
|
FTASK=$( echo $task | cut -d '/' -f 8 ) # todo.$NANODATE
|
||
|
|
TNANO=$( echo $FTASK | cut -d '.' -f 1 ) # $NANODATE
|
||
|
|
echo " .$IPFSNODEID FOUND TASK : $FTASK "
|
||
|
|
# MAKE LOCAL .$IPFSNODEID directory
|
||
|
|
mkdir -p /home/$YOU/.zen/ipfs/.$IPFSNODEID/TASK/
|
||
|
|
# TODO: CHECK BETTER NOT DONE YET and $NANODATE > $TNANO (=> detect NODES writing in the future!!)
|
||
|
|
if [[ ! -f /home/$YOU/.zen/ipfs/.$IPFSNODEID/TASK/done.$TNANO ]]; then # NOT DONE YET: NEW TASK!
|
||
|
|
tdiff=$(bc -l <<< "$NANODATE - $TNANO")
|
||
|
|
if [[ $tdiff -gt 0 ]]; then
|
||
|
|
# GET BACK MY NODE G1 Wallet authfile from my LOCAL ./wallets
|
||
|
|
echo "${GPGPASS}" | gpg -q -d --output "./NODEG1Wallet.authfile" --yes --pinentry-mode loopback --symmetric --passphrase-fd 0 "./wallets/.$IPFSNODEID/$IPFSNODEID.authfile.GPGPASS.gpg"
|
||
|
|
# DECRYPT and CAT move_g1cents VALUE
|
||
|
|
./shell/natools.py decrypt -k "./NODEG1Wallet.authfile" -i "$task" -o "/tmp/move_g1cents.$TDEST"
|
||
|
|
ZENVAL=$(cat "/tmp/move_g1cents.$TDEST")
|
||
|
|
log "__SUB:ipfs_swarm_wallets_refresh: tdiff=$tdiff .$IPFSNODEID G1 = ./NODEG1Wallet.authfile :decrypt: Found $ZENVAL Zen to ADD"
|
||
|
|
rm -f "./NODEG1Wallet.authfile"
|
||
|
|
if [[ $ZENVAL -gt 0 ]]; then
|
||
|
|
curvalue=$(cat ./wallets/$TDEST/$TDEST.g1cents)
|
||
|
|
newvalue=$(bc -l <<< "$curvalue + $ZENVAL")
|
||
|
|
echo $newvalue > ./wallets/$TDEST/$TDEST.g1cents
|
||
|
|
echo "OK.$tdiff" > ./wallets/.$IPFSNODEID/TASK/done.$TNANO
|
||
|
|
log "__SUB:ipfs_swarm_wallets_refresh: .$IPFSNODEID($FTASK) DONE! OPERATION: ($curvalue + $ZENVAL) = $newvalue Zen <=> ./wallets/$TDEST/$TDEST.g1cents:: OK"
|
||
|
|
# REFRESH ./wallets and PUBLISH
|
||
|
|
I=$(ipfs_node_wallets_add)
|
||
|
|
else
|
||
|
|
echo "KO.$tdiff" > ./wallets/.$IPFSNODEID/TASK/done.$TNANO
|
||
|
|
log "__SUB:ipfs_swarm_wallets_refresh: .$IPFSNODEID($FTASK) ERROR! BAD: ($curvalue + $ZENVAL) = $newvalue Zen <=> ./wallets/$TDEST/$TDEST.g1cents :: KO"
|
||
|
|
I=$(ipfs_node_wallets_add)
|
||
|
|
sms_SEND "$ADMINPHONE" "ADMIN! TASK ERROR: .$IPFSNODEID($FTASK) ERROR! BAD: ($curvalue + $ZENVAL) = $newvalue Zen <=> ./wallets/$TDEST/$TDEST.g1cents :: KO"
|
||
|
|
fi
|
||
|
|
else
|
||
|
|
# TODO: Bad NODE in the Future task !!! Make better BAD Node detection = Swarm Banish?
|
||
|
|
echo "KO.$tdiff" > ./wallets/.$IPFSNODEID/TASK/done.$TNANO
|
||
|
|
log "__SUB:ipfs_swarm_wallets_refresh: .$IPFSNODEID($FTASK) ERROR! DATE PROBLEM: $NANODATE < $TNANO :: KO"
|
||
|
|
I=$(ipfs_node_wallets_add)
|
||
|
|
sms_SEND "$ADMINPHONE" "ADMIN! .$IPFSNODEID($FTASK) ERROR! DATE PROBLEM: $NANODATE < $TNANO :: KO"
|
||
|
|
fi
|
||
|
|
fi
|
||
|
|
done
|
||
|
|
|
||
|
|
log "__SUB:ipfs_swarm_wallets_refresh: REMOVE OLD TASK MARKED AS DONE"
|
||
|
|
for scan in ./wallets_swarm/.Qm*/TASK/done.*; do
|
||
|
|
lscan=$(echo $scan | sed s/_swarm//g )
|
||
|
|
lid=$(echo $scan | cut -d '/' -f 3 | cut -d '.' -f 2 )
|
||
|
|
lnano=$(echo $scan | cut -d '/' -f 5 | cut -d '.' -f 2 )
|
||
|
|
if [[ "$lid" != "$IPFSNODEID" ]]; then
|
||
|
|
log "__SUB:ipfs_swarm_wallets_refresh: CLEANING done OLD TASK ${lscan} SENT to $lid ($lnano.bin)"
|
||
|
|
rm -f ./wallets/.$lid/TASK/$lnano.*
|
||
|
|
I=$(ipfs_node_wallets_add)
|
||
|
|
fi
|
||
|
|
done
|
||
|
|
else
|
||
|
|
log "__SUB:ipfs_swarm_wallets_refresh: .$IPFSNODEID :: NO TASK ! "
|
||
|
|
############################################################################"
|
||
|
|
fi
|