#!/bin/sh

. ./trace.sh
. ./sql.sh

do_callbacks()
{
	(
	flock -x 200 || return 0

	trace "Entering do_callbacks()..."

	# Let's fetch all the watching addresses still being watched but not called back
	local callbacks=$(sql 'SELECT DISTINCT callback0conf, address, txid, vout, amount, confirmations, timereceived, fee, size, vsize, blockhash, blockheight, blocktime, w.id, is_replaceable FROM watching w LEFT JOIN watching_tx ON w.id = watching_id LEFT JOIN tx ON tx.id = tx_id WHERE NOT calledback0conf and watching_id NOT NULL and callback0conf NOT NULL and watching')
	trace "[do_callbacks] callbacks0conf=${callbacks}"

	local returncode
	local address
	local IFS=$'\n'
	for row in ${callbacks}
	do
		build_callback ${row}
		returncode=$?
		trace_rc ${returncode}
		if [ "${returncode}" -eq 0 ]; then
			address=$(echo "${row}" | cut -d '|' -f2)
			sql "UPDATE watching SET calledback0conf=1 WHERE address=\"${address}\""
			trace_rc $?
		fi
	done

	callbacks=$(sql 'SELECT DISTINCT callback1conf, address, txid, vout, amount, confirmations, timereceived, fee, size, vsize, blockhash, blockheight, blocktime, w.id, is_replaceable FROM watching w, watching_tx wt, tx t WHERE w.id = watching_id AND tx_id = t.id AND NOT calledback1conf and confirmations>0 and callback1conf NOT NULL and watching')
	trace "[do_callbacks] callbacks1conf=${callbacks}"

	for row in ${callbacks}
	do
		build_callback ${row}
		returncode=$?
		if [ "${returncode}" -eq 0 ]; then
			address=$(echo "${row}" | cut -d '|' -f2)
			sql "UPDATE watching SET calledback1conf=1, watching=0 WHERE address=\"${address}\""
			trace_rc $?
		fi
	done
	) 200>./.callbacks.lock
}

build_callback()
{
	trace "Entering build_callback()..."

	local row=$@
	local id
	local url
	local data
	local address
	local txid
	local vout_n
	local sent_amount
	local confirmations
	local ts_firstseen
	local fee
	local size
	local vsize
	local blockhash
	local blocktime
	local blockheight

	# callback0conf, address, txid, vout, amount, confirmations, timereceived, fee, size, vsize, blockhash, blockheight, blocktime, w.id

	trace "[build_callback] row=${row}"
	id=$(echo "${row}" | cut -d '|' -f14)
	trace "[build_callback] id=${id}"
	url=$(echo "${row}" | cut -d '|' -f1)
	trace "[build_callback] url=${url}"
	address=$(echo "${row}" | cut -d '|' -f2)
	trace "[build_callback] address=${address}"
	txid=$(echo "${row}" | cut -d '|' -f3)
	trace "[build_callback] txid=${txid}"
	vout_n=$(echo "${row}" | cut -d '|' -f4)
	trace "[build_callback] vout_n=${vout_n}"
	sent_amount=$(echo "${row}" | cut -d '|' -f5)
	trace "[build_callback] sent_amount=${sent_amount}"
	confirmations=$(echo "${row}" | cut -d '|' -f6)
	trace "[build_callback] confirmations=${confirmations}"
	ts_firstseen=$(echo "${row}" | cut -d '|' -f7)
	trace "[build_callback] ts_firstseen=${ts_firstseen}"

	# If node in pruned mode, we can't calculate the fees and then we don't want
	# to send 0.00000000 as fees but empty string to distinguish.
	fee=$(echo "${row}" | cut -d '|' -f8)
	if [ -n "${fee}" ]; then
		fee=$(echo "${fee}" | awk '{ printf "%.8f", $0 }')
	fi
	trace "[build_callback] fee=${fee}"
	size=$(echo "${row}" | cut -d '|' -f9)
	trace "[build_callback] size=${size}"
	vsize=$(echo "${row}" | cut -d '|' -f10)
	trace "[build_callback] vsize=${vsize}"
	is_replaceable=$(echo "${row}" | cut -d '|' -f15)
	trace "[build_callback] is_replaceable=${is_replaceable}"
	blockhash=$(echo "${row}" | cut -d '|' -f11)
	trace "[build_callback] blockhash=${blockhash}"
	blockheight=$(echo "${row}" | cut -d '|' -f12)
	trace "[build_callback] blockheight=${blockheight}"
	blocktime=$(echo "${row}" | cut -d '|' -f13)
	trace "[build_callback] blocktime=${blocktime}"

	data="{\"id\":\"${id}\","
	data="${data}\"address\":\"${address}\","
	data="${data}\"hash\":\"${txid}\","
	data="${data}\"vout_n\":${vout_n},"
	data="${data}\"sent_amount\":${sent_amount},"
	data="${data}\"confirmations\":${confirmations},"
	data="${data}\"received\":\"$(date -Is -d @${ts_firstseen})\","
	data="${data}\"size\":${size},"
	data="${data}\"vsize\":${vsize},"
	data="${data}\"fees\":${fee},"
	data="${data}\"is_replaceable\":${is_replaceable},"
	data="${data}\"blockhash\":\"${blockhash}\","
	if [ -z ${blocktime} ]; then
		data="${data}\"blocktime\":\"\","
	else
		data="${data}\"blocktime\":\"$(date -Is -d @${blocktime})\","
	fi
	data="${data}\"blockheight\":\"${blockheight}\"}"
	trace "[build_callback] data=${data}"

	curl_callback "${url}" "${data}"
	return $?
}

curl_callback()
{
	trace "Entering curl_callback()..."

	local url=${1}
	local data=${2}

	trace "[curl_callback] curl -H \"Content-Type: application/json\" -d \"${data}\" ${url}"
	curl -H "Content-Type: application/json" -H "X-Forwarded-Proto: https" -d "${data}" ${url}
	local returncode=$?
	trace_rc ${returncode}

	return ${returncode}
}

case "${0}" in *callbacks_job.sh) do_callbacks $@;; esac