extract-stackers.sh•3.05 kB
#!/bin/bash
############################################################
# Script to extract all STX addresses that are stacking
# in a particular reward cycle, given access to a node's
# debug log file.
#
# Usage: ./extract-stackers.sh REWARD-CYCLE < DEBUG-LOG-FILE
############################################################
set -oue pipefail
FIRST_BLOCK=666050
REWARD_CYCLE_LENGTH=2100
# DEBG [1635829849.697968] [src/chainstate/stacks/db/accounts.rs:298] [chains-coordinator] PoX lock 604260000 uSTX (new balance 6104) until burnchain block height 689150 for Standard(StandardPrincipalData(SP2WGGG8E7NVFA0W4YZ87M6R09TNJ33CEBAXB9QPB))
# DEBG [1635941010.356021] [src/chainstate/stacks/db/accounts.rs:298] [chains-coordinator] PoX lock 12622260119595 uSTX (new balance 0) until burnchain block height 714350 for Contract(QualifiedContractIdentifier { issuer: StandardPrincipalData(SP2C2YFP12AJZB4MABJBAJ55XECVS7E4PMMZ89YZR), name: ContractName("arkadiko-stacker-v1-1") })
#
# becomes
#
# {"type";"stacker", "locked":"604260000","until":"689150","address":"SP2WGGG8E7NVFA0W4YZ87M6R09TNJ33CEBAXB9QPB"}
# {"type":"stacker", "locked":"12622260119595","until":"714350","address":"SP2C2YFP12AJZB4MABJBAJ55XECVS7E4PMMZ89YZR.arkadiko-stacker-v1-1"}
extract_stacker() {
# stdin: a DEBUG-level logfile
# stdout: JSON describing each PoX lock event
gawk '
{
num_locked = $7
until = $16
addr_field = "";
for (i = 18; i <= NF; i++) {
if ($i != "") {
addr_field = addr_field " " $i
}
}
found = 0
address = ""
is_contract = match(addr_field, /QualifiedContractIdentifier \{ issuer: StandardPrincipalData\(([^)]+)\), name: ContractName\("([^"]+)"\)/, parts)
if (is_contract) {
address = parts[1] "." parts[2]
found = 1
}
else {
is_standard = match(addr_field, /Standard\(StandardPrincipalData\(([^)]+)\)\)/, parts)
if (is_standard) {
address = parts[1]
found = 1
}
}
if (found) {
printf "{\"address\":\"" address "\",\"type\":\"stacker\",\"locked\":\"" num_locked "\",\"until\":\"" until "\"}\n"
}
}
'
}
block_height_to_reward_cycle() {
# $1: burnchain block height
# stdin: none
# stdout: reward cycle
local block_height="$1"
echo $(( ($block_height - $FIRST_BLOCK) / $REWARD_CYCLE_LENGTH ))
}
stacking_in_reward_cycle() {
# $1: reward cycle number
# stdin: output from extract_stacker
# stdout: the JSON blobs that are stacking within this reward cycle
local target_reward_cycle="$1"
local json=""
local reward_cycle=0
local first_block=0
local until_ht=0
while IFS= read -r json; do
until_ht="$(echo "$json" | jq -rc '.until')"
reward_cycle="$(block_height_to_reward_cycle "$until_ht")"
# echo >&2 "Until reward cycle $reward_cycle: $json"
if (( "$reward_cycle" > "$target_reward_cycle" )); then
echo "$json"
fi
done
return 0
}
target_reward_cycle="$1"
grep ' PoX lock ' | extract_stacker | stacking_in_reward_cycle "$target_reward_cycle"