tAdd mempool histogram feature - electrum-personal-server - Maximally lightweight electrum server for a single user
HTML git clone https://git.parazyd.org/electrum-personal-server
DIR Log
DIR Files
DIR Refs
DIR README
---
DIR commit 15d18bca49fffc15e18f07124ad3b83243b38ecf
DIR parent 37a92a9b0d79b2f22b744510d920e86843eddf4a
HTML Author: chris-belcher <chris-belcher@users.noreply.github.com>
Date: Thu, 3 May 2018 20:57:49 +0100
Add mempool histogram feature
Code is almost entirely copied from the ElectrumX implementation
Diffstat:
M server.py | 25 ++++++++++++++++++++++++-
1 file changed, 24 insertions(+), 1 deletion(-)
---
DIR diff --git a/server.py b/server.py
t@@ -2,6 +2,7 @@
import socket, time, json, datetime, struct, binascii, ssl, os, os.path
from configparser import ConfigParser, NoSectionError, NoOptionError
+from collections import defaultdict
import traceback, sys, platform
from electrumpersonalserver.jsonrpc import JsonRpc, JsonRpcError
t@@ -200,7 +201,29 @@ def handle_query(sock, line, rpc, txmonitor):
debug("tx broadcast result = " + str(result))
send_response(sock, query, result)
elif method == "mempool.get_fee_histogram":
- result = [] #TODO not handling, sending empty
+ mempool = rpc.call("getrawmempool", [True])
+
+ #algorithm copied from the relevant place in ElectrumX
+ #https://github.com/kyuupichan/electrumx/blob/e92c9bd4861c1e35989ad2773d33e01219d33280/server/mempool.py
+ fee_hist = defaultdict(int)
+ for txid, details in mempool.items():
+ fee_rate = 1e8*details["fee"] // details["size"]
+ fee_hist[fee_rate] += details["size"]
+
+ l = list(reversed(sorted(fee_hist.items())))
+ out = []
+ size = 0
+ r = 0
+ binsize = 100000
+ for fee, s in l:
+ size += s
+ if size + r > binsize:
+ out.append((fee, size))
+ r += size - binsize
+ size = 0
+ binsize *= 1.1
+
+ result = out
send_response(sock, query, result)
elif method == "blockchain.estimatefee":
estimate = rpc.call("estimatesmartfee", [query["params"][0]])