aljaz/cyphernode
1
0
Fork 0
mirror of https://github.com/aljazceru/cyphernode.git synced 2026-01-31 10:14:35 +01:00
Code Issues Packages Projects Releases Wiki Activity

manage_missed_conf optimized greatly

Browse Source
This commit is contained in:
kexkey
2021-10-07 11:48:43 -04:00
parent ae2929cde9
commit 8442d4b053
1 changed files with 40 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
proxy_docker/app/script/manage_missed_conf.sh
View File

@@ -36,9 +36,12 @@ manage_missed_conf() {
# Maybe we missed confirmations, because we were down or no network or
# whatever, so we look at what might be missed and do confirmations.
# The strategy here: get the list of watched addresses, see if they received something on the Bitcoin node,
# and for each ones that received something after the watching timestamp, we kinda missed them...
trace "[Entering manage_missed_conf()]"
local watches=$(sql 'SELECT DISTINCT address, w.inserted_ts FROM watching w LEFT JOIN watching_tx ON w.id = watching_id LEFT JOIN tx t ON t.id = tx_id WHERE watching AND imported AND (tx_id IS NULL OR t.confirmations=0)')
local watches=$(sql 'SELECT DISTINCT address FROM watching w LEFT JOIN watching_tx ON w.id = watching_id LEFT JOIN tx t ON t.id = tx_id WHERE watching AND imported AND (tx_id IS NULL OR t.confirmations=0) ORDER BY address')
trace "[manage_missed_conf] watches=${watches}"
if [ ${#watches} -eq 0 ]; then
trace "[manage_missed_conf] Nothing missed!"
@@ -46,6 +49,24 @@ manage_missed_conf() {
fi
local received
local received_addresses
local received_watches
data='{"method":"listreceivedbyaddress","params":[0,false,true]}'
received=$(send_to_watcher_node "${data}")
received_addresses=$(echo "${received}" | jq -r ".result[].address" | sort)
trace "[manage_missed_conf] received_addresses=${received_addresses}"
# Let's extract addresses that are in the watches list as well as in the received_addresses list
echo "${watches}" > watches-$$
echo "${received_addresses}" > received_addresses-$$
received_watches=$(comm -12 watches-$$ received_addresses-$$)
trace "[manage_missed_conf] received_watches=${received_watches}"
rm watches-$$ received_addresses-$$
local received
local received_address
local watching
local latesttxid
local tx
local blocktime
@@ -58,23 +79,31 @@ manage_missed_conf() {
local txid
local txids
local IFS=$'\n'
for row in ${watches}
for address in ${received_watches}
do
# Let's get confirmed received txs for the address
address=$(echo "${row}" | cut -d '|' -f1)
inserted_ts=$(date -d "$(echo "${row}" | cut -d '|' -f2)" +"%s")
trace "[manage_missed_conf] address=${address}"
watching=$(sql 'SELECT address, inserted_ts FROM watching WHERE address="'${address}'"')
trace "[manage_missed_conf] watching=${watching}"
if [ ${#watching} -eq 0 ]; then
trace "[manage_missed_conf] Nothing missed!"
continue
fi
data='{"method":"listreceivedbyaddress","params":[0, false, true, "'${address}'"]}'
received=$(send_to_watcher_node ${data} | jq '.result[0]')
if [ "${received}" = "null" ]; then
# Let's get confirmed received txs for the address
# address=$(echo "${watches}" | cut -d '|' -f1)
inserted_ts=$(date -d "$(echo "${watching}" | cut -d '|' -f2)" +"%s")
trace "[manage_missed_conf] inserted_ts=${inserted_ts}"
received_address=$(echo "${received}" | jq -Mc ".result | map(select(.address==\"${address}\" and .confirmations>0))[0]")
trace "[manage_missed_conf] received_address=${received_address}"
if [ "${received_address}" = "null" ]; then
# Not confirmed while we were away...
trace "[manage_missed_conf] Nothing missed here"
else
# We got something confirmed
# Let's find out if it was confirmed after being watched
trace "[manage_missed_conf] We got something confirmed"
latesttxid=$(echo "${received}" | jq -r ".txids | last")
latesttxid=$(echo "${received_address}" | jq -r ".txids | last")
trace "[manage_missed_conf] latesttxid=${latesttxid}"
data='{"method":"gettransaction","params":["'${latesttxid}'"]}'
tx=$(send_to_watcher_node ${data})
blocktime=$(echo "${tx}" | jq '.result.blocktime')
@@ -86,7 +115,7 @@ manage_missed_conf() {
trace "[manage_missed_conf] inserted_ts=${inserted_ts}"
trace "[manage_missed_conf] confirmations=${confirmations}"
if [ "${txtime}" -gt "${inserted_ts}" ]; then
if [ "${txtime}" -gt "${inserted_ts}" ] && [ "${confirmations}" -gt "0" ]; then
# Mined after watch, we missed it!
trace "[manage_missed_conf] Mined after watch, we missed it!"
confirmation "${latesttxid}" "true"