mirror of
https://github.com/Rucknium/misc-research.git
synced 2024-11-16 15:58:03 +00:00
182 lines
6.4 KiB
R
182 lines
6.4 KiB
R
|
|
sapply(c("data.table", "RJSONIO", "RCurl"),
|
|
FUN = function(x) {
|
|
if (!suppressWarnings(require(x, character.only = TRUE))) {
|
|
tryCatch(suppressWarnings(install.packages(x)),
|
|
error = function(e) {
|
|
suppressWarnings(install.packages(x, lib = Sys.getenv('R_LIBS_USER')))
|
|
}
|
|
)
|
|
}
|
|
return(TRUE)
|
|
})
|
|
# Attempt to install packages
|
|
|
|
|
|
script.args <- commandArgs(trailingOnly = TRUE)
|
|
|
|
stopifnot(length(script.args) == 3)
|
|
|
|
block.start <- as.numeric(script.args[1])
|
|
block.stop <- as.numeric(script.args[2])
|
|
stopifnot(block.start < block.stop)
|
|
blockchain.stats.utility.location <- script.args[3]
|
|
|
|
# Modified from TownforgeR::tf_rpc_curl function
|
|
xmr.rpc <- function(
|
|
url.rpc = "http://127.0.0.1:18081/json_rpc",
|
|
method = "",
|
|
params = list(),
|
|
userpwd = "",
|
|
num.as.string = FALSE,
|
|
nonce.as.string = FALSE,
|
|
keep.trying.rpc = FALSE,
|
|
curl = RCurl::getCurlHandle(),
|
|
...
|
|
){
|
|
|
|
json.ret <- RJSONIO::toJSON(
|
|
list(
|
|
jsonrpc = "2.0",
|
|
id = "0",
|
|
method = method,
|
|
params = params
|
|
), digits = 50
|
|
)
|
|
|
|
rcp.ret <- tryCatch(RCurl::postForm(url.rpc,
|
|
.opts = list(
|
|
userpwd = userpwd,
|
|
postfields = json.ret,
|
|
httpheader = c('Content-Type' = 'application/json', Accept = 'application/json')
|
|
# https://stackoverflow.com/questions/19267261/timeout-while-reading-csv-file-from-url-in-r
|
|
),
|
|
curl = curl
|
|
), error = function(e) {NULL})
|
|
|
|
if (keep.trying.rpc && length(rcp.ret) == 0) {
|
|
while (length(rcp.ret) == 0) {
|
|
rcp.ret <- tryCatch(RCurl::postForm(url.rpc,
|
|
.opts = list(
|
|
userpwd = userpwd,
|
|
postfields = json.ret,
|
|
httpheader = c('Content-Type' = 'application/json', Accept = 'application/json')
|
|
# https://stackoverflow.com/questions/19267261/timeout-while-reading-csv-file-from-url-in-r
|
|
),
|
|
curl = curl
|
|
), error = function(e) {NULL})
|
|
}
|
|
}
|
|
|
|
if (is.null(rcp.ret)) {
|
|
stop("Cannot connect to monerod. Is monerod running?")
|
|
}
|
|
|
|
if (num.as.string) {
|
|
rcp.ret <- gsub("(: )([-0123456789.]+)([,\n\r])", "\\1\"\\2\"\\3", rcp.ret )
|
|
}
|
|
|
|
if (nonce.as.string & ! num.as.string) {
|
|
rcp.ret <- gsub("(\"nonce\": )([-0123456789.]+)([,\n\r])", "\\1\"\\2\"\\3", rcp.ret )
|
|
}
|
|
|
|
RJSONIO::fromJSON(rcp.ret, asText = TRUE) # , simplify = FALSE
|
|
}
|
|
|
|
|
|
get.coinbase.tx.size <- function(miner_tx_hash, curl = RCurl::getCurlHandle()) {
|
|
|
|
rcp.ret <- RCurl::postForm("http://127.0.0.1:18081/get_transactions",
|
|
.opts = list(
|
|
postfields = paste0('{"txs_hashes":["', miner_tx_hash, '"]}'),
|
|
httpheader = c('Content-Type' = 'application/json', Accept = 'application/json')
|
|
),
|
|
curl = curl
|
|
)
|
|
|
|
rcp.ret <- RJSONIO::fromJSON(rcp.ret, asText = TRUE)
|
|
nchar(rcp.ret$txs[[1]]$pruned_as_hex) / 2
|
|
# Reference:
|
|
# https://libera.monerologs.net/monero-dev/20221231
|
|
# https://github.com/monero-project/monero/pull/8691
|
|
# https://github.com/monero-project/monero/issues/8311
|
|
}
|
|
|
|
cat("\nmonero-blockchain-stats starting to gather aggregate tx output data...\n")
|
|
|
|
blockchain.stats <- system(paste0(blockchain.stats.utility.location,
|
|
" --with-outputs --block-start=", block.start, " --block-stop=", block.stop), intern = TRUE)
|
|
|
|
tf <- tempfile()
|
|
writeLines(blockchain.stats[(grep("# DATA", blockchain.stats) + 1):length(blockchain.stats)], tf)
|
|
blockchain.stats <- read.delim(tf)
|
|
colnames(blockchain.stats) <- gsub("[.]", "_per_", colnames(blockchain.stats))
|
|
|
|
blockchain.stats$OutTotal <- round(blockchain.stats$Txs_per_Day * blockchain.stats$OutAvg)
|
|
|
|
cat("monero-blockchain-stats finished gathering aggregate tx output data.\n")
|
|
cat("\nStart gathering p2pool tx output data...\n")
|
|
|
|
blocks <- block.start:block.stop
|
|
|
|
detect.p2pool <- vector("list", length(blocks))
|
|
|
|
curl.handle <- RCurl::getCurlHandle()
|
|
|
|
for (i in seq_along(blocks)) {
|
|
|
|
block.data <- xmr.rpc(method = "get_block",
|
|
params = list(height = blocks[i]), curl = curl.handle)$result
|
|
|
|
miner_tx_hash <- block.data$miner_tx_hash
|
|
|
|
block.data <- RJSONIO::fromJSON(block.data$json, asText = TRUE)
|
|
|
|
coinbase.tx.size <- get.coinbase.tx.size(miner_tx_hash, curl = curl.handle)
|
|
|
|
detect.p2pool[[i]] <- data.table::data.table(
|
|
block_height = blocks[i],
|
|
timestamp = block.data$timestamp,
|
|
is_p2pool = grepl("(X3X32X)|(X3X32$)", paste0(block.data$miner_tx$extra, collapse = "X")),
|
|
# tx_extra with "3" followed by "32" indicates merge mining with p2pool
|
|
n_outputs = length(block.data$miner_tx$vout),
|
|
tx_size_bytes = coinbase.tx.size
|
|
)
|
|
if (blocks[i] %% 1000 == 0) {
|
|
cat("Block", blocks[i], "processed\n")
|
|
}
|
|
}
|
|
|
|
detect.p2pool <- data.table::rbindlist(detect.p2pool)
|
|
|
|
detect.p2pool$is_p2pool[detect.p2pool$n_outputs == 1] <- FALSE
|
|
# Remove false positives
|
|
|
|
write.csv(blockchain.stats, paste0("blockchain-stats-", block.start, "-to-", block.stop, ".csv"), row.names = FALSE)
|
|
cat("\n", paste0("blockchain-stats-", block.start, "-to-", block.stop, ".csv"), " created\n", sep = "")
|
|
write.csv(detect.p2pool, paste0("miner-payouts-", block.start, "-to-", block.stop, ".csv"), row.names = FALSE)
|
|
cat(paste0("miner-payouts-", block.start, "-to-", block.stop, ".csv"), " created\n", sep = "")
|
|
|
|
cat("\nTotal number of blocks: ", nrow(detect.p2pool), "\n", sep = "")
|
|
cat("Number of blocks found by p2pool: ", sum(detect.p2pool$is_p2pool),
|
|
" (", round(100 * sum(detect.p2pool$is_p2pool) / nrow(detect.p2pool), 2), "% of total)", "\n", sep ="")
|
|
|
|
cat("Summary statistics on number of payout outputs per block found by p2pool:\n")
|
|
print(summary(detect.p2pool$n_outputs[detect.p2pool$is_p2pool]))
|
|
|
|
|
|
cat("Total number of transaction outputs: ",
|
|
formatC(round(sum(blockchain.stats$OutTotal)), format = "f", big.mark = ",", digits = 0), "\n", sep = "")
|
|
|
|
cat("Number of p2pool payout transaction outputs: ",
|
|
formatC(sum(detect.p2pool$n_outputs[detect.p2pool$is_p2pool]), format = "f", big.mark = ",", digits = 0),
|
|
" (", round(100 * sum(detect.p2pool$n_outputs[detect.p2pool$is_p2pool]) / sum(blockchain.stats$OutTotal), 2), "% of total)", "\n", sep ="")
|
|
|
|
cat("Total number of bytes (i.e. blockchain size on disk) within chosen blocks interval: ",
|
|
formatC(round(sum(blockchain.stats$Bytes_per_Day)), format = "f", big.mark = ",", digits = 0), "\n", sep = "")
|
|
|
|
cat("Total number of bytes of p2pool coinbase transactions: ",
|
|
formatC(sum(detect.p2pool$tx_size_bytes[detect.p2pool$is_p2pool]), format = "f", big.mark = ",", digits = 0),
|
|
" (", round(100 * sum(detect.p2pool$tx_size_bytes[detect.p2pool$is_p2pool]) / sum(blockchain.stats$Bytes_per_Day), 2), "% of total)", "\n", sep ="")
|
|
|
|
|