Refactor some `ConsensusConstants` stuff.
This commit is contained in:
Richard Kiss
parent
3264342474
commit
ef5b8b8dab
|
|
@ -59,59 +59,3 @@ class ConsensusConstants:
|
|||
|
||||
def replace(self, **changes):
|
||||
return dataclasses.replace(self, **changes)
|
||||
|
||||
|
||||
testnet_kwargs = {
|
||||
"NUMBER_OF_HEADS": 3, # The number of tips each full node keeps track of and propagates
|
||||
# DIFFICULTY_STARTING is the starting difficulty for the first epoch, which is then further
|
||||
# multiplied by another factor of 2^32, to be used in the VDF iter calculation formula.
|
||||
"DIFFICULTY_STARTING": 2 ** 20,
|
||||
"DIFFICULTY_FACTOR": 3, # The next difficulty is truncated to range [prev / FACTOR, prev * FACTOR]
|
||||
# These 3 constants must be changed at the same time
|
||||
"DIFFICULTY_EPOCH": 256, # The number of blocks per epoch
|
||||
"DIFFICULTY_WARP_FACTOR": 4, # DELAY divides EPOCH in order to warp efficiently.
|
||||
"DIFFICULTY_DELAY": 64, # EPOCH / WARP_FACTOR
|
||||
"SIGNIFICANT_BITS": 12, # The number of bits to look at in difficulty and min iters. The rest are zeroed
|
||||
"DISCRIMINANT_SIZE_BITS": 1024, # Max is 1024 (based on ClassGroupElement int size)
|
||||
"NUMBER_ZERO_BITS_CHALLENGE_SIG": 8, # H(plot signature of the challenge) must start with these many zeroes
|
||||
"BLOCK_TIME_TARGET": 300, # The target number of seconds per block
|
||||
# The proportion (denominator) of the total time that that the VDF must be run for, at a minimum
|
||||
# (1/min_iters_proportion). For example, if this is two, approximately half of the iterations
|
||||
# will be contant and required for all blocks.
|
||||
"MIN_ITERS_PROPORTION": 10,
|
||||
# For the first epoch, since we have no previous blocks, we can't estimate vdf iterations per second
|
||||
"MIN_ITERS_STARTING": (2 ** 22),
|
||||
"MAX_FUTURE_TIME": 7200, # The next block can have a timestamp of at most these many seconds more
|
||||
"NUMBER_OF_TIMESTAMPS": 11, # Than the average of the last NUMBEBR_OF_TIMESTAMPS blocks
|
||||
# If an unfinished block is more than these many seconds slower than the best unfinished block,
|
||||
# don't propagate it.
|
||||
"PROPAGATION_THRESHOLD": 300,
|
||||
# If the expected time is more than these seconds, slightly delay the propagation of the unfinished
|
||||
# block, to allow better leaders to be released first. This is a slow block.
|
||||
"PROPAGATION_DELAY_THRESHOLD": 1500,
|
||||
# Hardcoded genesis block, generated using tests/block_tools.py
|
||||
# Replace this any time the constants change.
|
||||
"GENESIS_BLOCK": b"\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x81\x8f\x0c\xec\x97\x85V`C\xfc\xe4\xf9A\xb6\xa1\xa8-@\x82`\r[v\x8f,\x86\xf1X\xc2?\xf6q\xf8\xfb\x8e\rnZ\xbaw\x11CN\xb1\xa9\xf9\xbb0\x93\x10\x8fc\xc3f&\x9b\x07>H\xf1\xa5\x841\xc8\xd9\xcaO\xd4\xb8\x93\x11\xa3\xd9\xfa\xb2U\x10\xcd\xec\x92*AA\xd9\xfd7\xcc\xf7]\xaf\x91V\xe3\x10\x1aa\x17\x00\x00\x00\xb8`\xbfL[I\x16\xd5\x01>\tw>S\xf0#8\xed\xc6\x88\xc5#=i2\x0c\x8d\xbe\x85\xeb\x8f\xee\x1b\x06a\x99\x1c\xba\xfa\xcba\xe6\x04Q\xf4\xc7\xe92RrU l\x01\xee 7)\xff\xa5\xa68\xb5\x10\xbbrQb\xb0\x01'K\xf1\x07).Z.')\xee`b\xab\x01\xa9\x82S\x91\x16\x9c\x96\x95\xaf\xe5\xe5\xca\xb7@\x03\xf4$\x87\xe6N\xd3\xfb\xd39Y4D\x91\xed\x14\xda4\xa8\xbfO@\xb4\xd3\x8d\xa9\x9f\xc5\xd4\xf1`o\x9bg\x81\x12\xb0i\xdfJ\xeb*\xd2*`\x95\xf0\xd0j\xa4\x8e\xa6\xcf\xaaHn\xd9\xfe_\xc9\xd9\x85\x8a\xa5\xe8\x1c\x9dk\xc5\xf0\xda\xfe\xd7R\xb5\xbe\x1e\xe0qw\x7f}x\xa7\xa6[\x01\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00P\xa2\xa9\x00cN 4\xf5\xb9]\xefu\t\x1a\x92\x85\xd0,\x8e\xca5\xff7N\xb3N-\x94-\xb4\xa3q[\xfd\xf0\x0b4\x8a/&#v\x19Y\\\xf8\x83o\x1b\x1b\x85\xe18\xbd\xce\xd5\x98\x11r\xaa\xd8\x1d8\xbe<Q\x9e\x00\x17sy\x96\x19\x86Go<\x1a\xa1\x94\xc6\xd2\xea\xe1~\xc4\xc8\xf6 \x83}(\xce\x86\xea\xbd\xc0\xe0\xc8_9\xe1`S\xbeZ\xc4y\x1d\xebx\xa1\x1e\"g\x16\xbbC\x0b\rhkU\x13\xf2i^[\xa8t(\x95\x00\x00\x00\x00\x82\x00F\x129)\x8a>[/\x8b\xbb\xa4\xf0\x86\x10\x93\x9b\x05\xd1\x1c$\xfc\xae\xbbI\xa8\x835Qj\xba\x87E\xf8a5t\x81i\xa6Lm\x82\xc5#C!\\f\xc5\x18\x80\x97y\xd5P\xe42\xa0\x15\x8b 6\x19l\x00\x18\xb9-\x85\x15\x9c\xed\xe4\xf2\x83j\x8d^\xca&/\xf6X@P\x8eC,\xaea\x85\x0c\xa66\x16,F\xf8\x07V\xf8\x83\xd3\x18\xd2R\xdf\xf8:\x8f\n\x85\xa6'\xb5\x8bt%\xf5\xbaz\x03\x01\x1a\xa5\xd6m\x10\xcb\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00_Y\xda\xc6Z\xb0?\x8fN^\x06\\w#Y\xc3n\xb4\x083\x1d\x01\xb4\xd8Y\xbb\xcf\xa9\xd8\t\x8a8N\xe5a\xa2\x0e\x0cM\xe8Kj\xfb99\xd4\x02\xca\xa2\x14\n\xf4\xafB%\xbf\xf8;\x83\xd7\xee&RS\x8e\x0b\xab\xfc\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x10\x00\x00\x00\x00\x00\x00\x00P\xa2\xa9\x8c-\x02\x9a\xb0\x08s^m1Z\xf5\x0f\xa7\x1d\x87`|\x92\xeb\x07\xb9\xaa\x90\xc1\xefz\xa2\x10\xf4\xf2\x8d\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00z\x91k\xdcP\xd3\xd03{\t\x98f\x8aOC\x96p3\x94g\xd7\xe9\x03\x9b\x86P\xba{\x1dO\xc1\xa0\x00\x00\x01\xd1\xa9J \x00z\x91k\xdcP\xd3\xd03{\t\x98f\x8aOC\x96p3\x94g\xd7\xe9\x03\x9b\x86P\xba{\x1dO\xc1\xa0\x00\x00\x00\x00\xa8\x81\xb2#\xdf'\xe1\x14\x94p\xa6\xd2\xa4\xe6\x0c\xf7\xd3\x0b9\xdf3C\xf8'\x98\xeb\xaf\xe8\xeef\xe5\xa8w\xd2\x94h?\x00\xe1\xb0\xd6\xee\x9a\xcb\xbeNM\x80\x17\xca(?o\xf5J\xa8\x9c\xf1\xb7\xd2\x87/\x9f\xb6\x18\xee\xf2\xf6\xcb*\xbc\xb7D\xb7\xf8\xaf\x9b\x99\xe1Z\xb0\x05\xbe\xdf\x85\x10\x0eS\x98\xd1\x14\x1b\xcf\xfe\xa5\xe0\x00\x00\x00\x00\x00\x00\x00\x00\xa1\x999\xae\xe9\xf1n\xc1\xc1\xc6q<\xe97%_\x1e\x1b\xd0>\xcd\xa8\x94\xd8;\xe4\x9f\xa7\xb1V\xa5Q\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x92.\xa5X;>\x8d\x90!Op[q\x90g\xdc,\xee\x1b!\xb7hI\x06q\xf9mq3\xd7,\xb6\x1f,qf\xa3\xdf \x8ac\xbf\x91p\xb1\xd6\xe0\x87\x0cJ\xa0\xb22z?X\x90\x0e\xa9\x85@\x0b\x90\t\x84\xd1e\xd9f\xb9U\x11\xfa+\xa2\xc8+\xa3\x0e\xdf\xcc\x04\x94\xdaC\x1c\xea\xf6\xd5\x18n\x00\x15\xa5S\x11\x00\x00\x00\x00\x04\x01A\xbap", # noqa: E501
|
||||
# Target tx count per sec
|
||||
"TX_PER_SEC": 20,
|
||||
# Size of mempool = 10x the size of block
|
||||
"MEMPOOL_BLOCK_BUFFER": 10,
|
||||
# Coinbase rewards are not spendable for 200 blocks
|
||||
"COINBASE_FREEZE_PERIOD": 200,
|
||||
# Max coin amount uint(1 << 64)
|
||||
"MAX_COIN_AMOUNT": 0xFFFFFFFFFFFFFFFF,
|
||||
# Raw size per block target = 1,000,000 bytes
|
||||
# Rax TX (single in, single out) = 219 bytes (not compressed)
|
||||
# TX = 457 vBytes
|
||||
# floor(1,000,000 / 219) * 457 = 2086662 (size in vBytes)
|
||||
# Max block cost in virtual bytes
|
||||
"MAX_BLOCK_COST": 2086662,
|
||||
# MAX block cost in clvm cost units = MAX_BLOCK_COST * CLVM_COST_RATIO_CONSTANT
|
||||
# 1 vByte = 108 clvm cost units
|
||||
"CLVM_COST_RATIO_CONSTANT": 108,
|
||||
# Max block cost in clvm cost units (MAX_BLOCK_COST * CLVM_COST_RATIO_CONSTANT)
|
||||
"MAX_BLOCK_COST_CLVM": 225359496,
|
||||
}
|
||||
|
||||
|
||||
constants = ConsensusConstants(**testnet_kwargs) # type: ignore
|
||||
|
|
|
|||
|
|
@ -0,0 +1,57 @@
|
|||
from .constants import ConsensusConstants
|
||||
|
||||
|
||||
testnet_kwargs = {
|
||||
"NUMBER_OF_HEADS": 3, # The number of tips each full node keeps track of and propagates
|
||||
# DIFFICULTY_STARTING is the starting difficulty for the first epoch, which is then further
|
||||
# multiplied by another factor of 2^32, to be used in the VDF iter calculation formula.
|
||||
"DIFFICULTY_STARTING": 2 ** 20,
|
||||
"DIFFICULTY_FACTOR": 3, # The next difficulty is truncated to range [prev / FACTOR, prev * FACTOR]
|
||||
# These 3 constants must be changed at the same time
|
||||
"DIFFICULTY_EPOCH": 256, # The number of blocks per epoch
|
||||
"DIFFICULTY_WARP_FACTOR": 4, # DELAY divides EPOCH in order to warp efficiently.
|
||||
"DIFFICULTY_DELAY": 64, # EPOCH / WARP_FACTOR
|
||||
"SIGNIFICANT_BITS": 12, # The number of bits to look at in difficulty and min iters. The rest are zeroed
|
||||
"DISCRIMINANT_SIZE_BITS": 1024, # Max is 1024 (based on ClassGroupElement int size)
|
||||
"NUMBER_ZERO_BITS_CHALLENGE_SIG": 8, # H(plot signature of the challenge) must start with these many zeroes
|
||||
"BLOCK_TIME_TARGET": 300, # The target number of seconds per block
|
||||
# The proportion (denominator) of the total time that that the VDF must be run for, at a minimum
|
||||
# (1/min_iters_proportion). For example, if this is two, approximately half of the iterations
|
||||
# will be contant and required for all blocks.
|
||||
"MIN_ITERS_PROPORTION": 10,
|
||||
# For the first epoch, since we have no previous blocks, we can't estimate vdf iterations per second
|
||||
"MIN_ITERS_STARTING": (2 ** 22),
|
||||
"MAX_FUTURE_TIME": 7200, # The next block can have a timestamp of at most these many seconds more
|
||||
"NUMBER_OF_TIMESTAMPS": 11, # Than the average of the last NUMBEBR_OF_TIMESTAMPS blocks
|
||||
# If an unfinished block is more than these many seconds slower than the best unfinished block,
|
||||
# don't propagate it.
|
||||
"PROPAGATION_THRESHOLD": 300,
|
||||
# If the expected time is more than these seconds, slightly delay the propagation of the unfinished
|
||||
# block, to allow better leaders to be released first. This is a slow block.
|
||||
"PROPAGATION_DELAY_THRESHOLD": 1500,
|
||||
# Hardcoded genesis block, generated using tests/block_tools.py
|
||||
# Replace this any time the constants change.
|
||||
"GENESIS_BLOCK": b"\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x81\x8f\x0c\xec\x97\x85V`C\xfc\xe4\xf9A\xb6\xa1\xa8-@\x82`\r[v\x8f,\x86\xf1X\xc2?\xf6q\xf8\xfb\x8e\rnZ\xbaw\x11CN\xb1\xa9\xf9\xbb0\x93\x10\x8fc\xc3f&\x9b\x07>H\xf1\xa5\x841\xc8\xd9\xcaO\xd4\xb8\x93\x11\xa3\xd9\xfa\xb2U\x10\xcd\xec\x92*AA\xd9\xfd7\xcc\xf7]\xaf\x91V\xe3\x10\x1aa\x17\x00\x00\x00\xb8`\xbfL[I\x16\xd5\x01>\tw>S\xf0#8\xed\xc6\x88\xc5#=i2\x0c\x8d\xbe\x85\xeb\x8f\xee\x1b\x06a\x99\x1c\xba\xfa\xcba\xe6\x04Q\xf4\xc7\xe92RrU l\x01\xee 7)\xff\xa5\xa68\xb5\x10\xbbrQb\xb0\x01'K\xf1\x07).Z.')\xee`b\xab\x01\xa9\x82S\x91\x16\x9c\x96\x95\xaf\xe5\xe5\xca\xb7@\x03\xf4$\x87\xe6N\xd3\xfb\xd39Y4D\x91\xed\x14\xda4\xa8\xbfO@\xb4\xd3\x8d\xa9\x9f\xc5\xd4\xf1`o\x9bg\x81\x12\xb0i\xdfJ\xeb*\xd2*`\x95\xf0\xd0j\xa4\x8e\xa6\xcf\xaaHn\xd9\xfe_\xc9\xd9\x85\x8a\xa5\xe8\x1c\x9dk\xc5\xf0\xda\xfe\xd7R\xb5\xbe\x1e\xe0qw\x7f}x\xa7\xa6[\x01\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00P\xa2\xa9\x00cN 4\xf5\xb9]\xefu\t\x1a\x92\x85\xd0,\x8e\xca5\xff7N\xb3N-\x94-\xb4\xa3q[\xfd\xf0\x0b4\x8a/&#v\x19Y\\\xf8\x83o\x1b\x1b\x85\xe18\xbd\xce\xd5\x98\x11r\xaa\xd8\x1d8\xbe<Q\x9e\x00\x17sy\x96\x19\x86Go<\x1a\xa1\x94\xc6\xd2\xea\xe1~\xc4\xc8\xf6 \x83}(\xce\x86\xea\xbd\xc0\xe0\xc8_9\xe1`S\xbeZ\xc4y\x1d\xebx\xa1\x1e\"g\x16\xbbC\x0b\rhkU\x13\xf2i^[\xa8t(\x95\x00\x00\x00\x00\x82\x00F\x129)\x8a>[/\x8b\xbb\xa4\xf0\x86\x10\x93\x9b\x05\xd1\x1c$\xfc\xae\xbbI\xa8\x835Qj\xba\x87E\xf8a5t\x81i\xa6Lm\x82\xc5#C!\\f\xc5\x18\x80\x97y\xd5P\xe42\xa0\x15\x8b 6\x19l\x00\x18\xb9-\x85\x15\x9c\xed\xe4\xf2\x83j\x8d^\xca&/\xf6X@P\x8eC,\xaea\x85\x0c\xa66\x16,F\xf8\x07V\xf8\x83\xd3\x18\xd2R\xdf\xf8:\x8f\n\x85\xa6'\xb5\x8bt%\xf5\xbaz\x03\x01\x1a\xa5\xd6m\x10\xcb\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00_Y\xda\xc6Z\xb0?\x8fN^\x06\\w#Y\xc3n\xb4\x083\x1d\x01\xb4\xd8Y\xbb\xcf\xa9\xd8\t\x8a8N\xe5a\xa2\x0e\x0cM\xe8Kj\xfb99\xd4\x02\xca\xa2\x14\n\xf4\xafB%\xbf\xf8;\x83\xd7\xee&RS\x8e\x0b\xab\xfc\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x10\x00\x00\x00\x00\x00\x00\x00P\xa2\xa9\x8c-\x02\x9a\xb0\x08s^m1Z\xf5\x0f\xa7\x1d\x87`|\x92\xeb\x07\xb9\xaa\x90\xc1\xefz\xa2\x10\xf4\xf2\x8d\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00z\x91k\xdcP\xd3\xd03{\t\x98f\x8aOC\x96p3\x94g\xd7\xe9\x03\x9b\x86P\xba{\x1dO\xc1\xa0\x00\x00\x01\xd1\xa9J \x00z\x91k\xdcP\xd3\xd03{\t\x98f\x8aOC\x96p3\x94g\xd7\xe9\x03\x9b\x86P\xba{\x1dO\xc1\xa0\x00\x00\x00\x00\xa8\x81\xb2#\xdf'\xe1\x14\x94p\xa6\xd2\xa4\xe6\x0c\xf7\xd3\x0b9\xdf3C\xf8'\x98\xeb\xaf\xe8\xeef\xe5\xa8w\xd2\x94h?\x00\xe1\xb0\xd6\xee\x9a\xcb\xbeNM\x80\x17\xca(?o\xf5J\xa8\x9c\xf1\xb7\xd2\x87/\x9f\xb6\x18\xee\xf2\xf6\xcb*\xbc\xb7D\xb7\xf8\xaf\x9b\x99\xe1Z\xb0\x05\xbe\xdf\x85\x10\x0eS\x98\xd1\x14\x1b\xcf\xfe\xa5\xe0\x00\x00\x00\x00\x00\x00\x00\x00\xa1\x999\xae\xe9\xf1n\xc1\xc1\xc6q<\xe97%_\x1e\x1b\xd0>\xcd\xa8\x94\xd8;\xe4\x9f\xa7\xb1V\xa5Q\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x92.\xa5X;>\x8d\x90!Op[q\x90g\xdc,\xee\x1b!\xb7hI\x06q\xf9mq3\xd7,\xb6\x1f,qf\xa3\xdf \x8ac\xbf\x91p\xb1\xd6\xe0\x87\x0cJ\xa0\xb22z?X\x90\x0e\xa9\x85@\x0b\x90\t\x84\xd1e\xd9f\xb9U\x11\xfa+\xa2\xc8+\xa3\x0e\xdf\xcc\x04\x94\xdaC\x1c\xea\xf6\xd5\x18n\x00\x15\xa5S\x11\x00\x00\x00\x00\x04\x01A\xbap", # noqa: E501
|
||||
# Target tx count per sec
|
||||
"TX_PER_SEC": 20,
|
||||
# Size of mempool = 10x the size of block
|
||||
"MEMPOOL_BLOCK_BUFFER": 10,
|
||||
# Coinbase rewards are not spendable for 200 blocks
|
||||
"COINBASE_FREEZE_PERIOD": 200,
|
||||
# Max coin amount uint(1 << 64)
|
||||
"MAX_COIN_AMOUNT": 0xFFFFFFFFFFFFFFFF,
|
||||
# Raw size per block target = 1,000,000 bytes
|
||||
# Rax TX (single in, single out) = 219 bytes (not compressed)
|
||||
# TX = 457 vBytes
|
||||
# floor(1,000,000 / 219) * 457 = 2086662 (size in vBytes)
|
||||
# Max block cost in virtual bytes
|
||||
"MAX_BLOCK_COST": 2086662,
|
||||
# MAX block cost in clvm cost units = MAX_BLOCK_COST * CLVM_COST_RATIO_CONSTANT
|
||||
# 1 vByte = 108 clvm cost units
|
||||
"CLVM_COST_RATIO_CONSTANT": 108,
|
||||
# Max block cost in clvm cost units (MAX_BLOCK_COST * CLVM_COST_RATIO_CONSTANT)
|
||||
"MAX_BLOCK_COST_CLVM": 225359496,
|
||||
}
|
||||
|
||||
|
||||
DEFAULT_CONSTANTS = ConsensusConstants(**testnet_kwargs) # type: ignore
|
||||
|
|
@ -1,4 +1,9 @@
|
|||
from src.consensus.constants import constants
|
||||
import pathlib
|
||||
|
||||
from typing import Dict
|
||||
|
||||
from src.consensus.constants import ConsensusConstants
|
||||
from src.consensus.default_constants import DEFAULT_CONSTANTS
|
||||
from src.farmer import Farmer
|
||||
from src.server.outbound_message import NodeType
|
||||
from src.types.peer_info import PeerInfo
|
||||
|
|
@ -13,7 +18,9 @@ from src.server.start_service import run_service
|
|||
u"".encode("idna")
|
||||
|
||||
|
||||
def service_kwargs_for_farmer(root_path):
|
||||
def service_kwargs_for_farmer(
|
||||
root_path: pathlib.Path, consensus_constants: ConsensusConstants
|
||||
) -> Dict:
|
||||
service_name = "farmer"
|
||||
config = load_config_cli(root_path, "config.yaml", service_name)
|
||||
keychain = Keychain()
|
||||
|
|
@ -24,7 +31,7 @@ def service_kwargs_for_farmer(root_path):
|
|||
|
||||
# TOD: Remove once we have pool server
|
||||
config_pool = load_config_cli(root_path, "config.yaml", "pool")
|
||||
api = Farmer(config, config_pool, keychain, constants)
|
||||
api = Farmer(config, config_pool, keychain, consensus_constants)
|
||||
|
||||
kwargs = dict(
|
||||
root_path=root_path,
|
||||
|
|
@ -43,7 +50,7 @@ def service_kwargs_for_farmer(root_path):
|
|||
|
||||
|
||||
def main():
|
||||
kwargs = service_kwargs_for_farmer(DEFAULT_ROOT_PATH)
|
||||
kwargs = service_kwargs_for_farmer(DEFAULT_ROOT_PATH, DEFAULT_CONSTANTS)
|
||||
return run_service(**kwargs)
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -1,6 +1,10 @@
|
|||
from multiprocessing import freeze_support
|
||||
import pathlib
|
||||
|
||||
from src.consensus.constants import constants
|
||||
from multiprocessing import freeze_support
|
||||
from typing import Dict
|
||||
|
||||
from src.consensus.constants import ConsensusConstants
|
||||
from src.consensus.default_constants import DEFAULT_CONSTANTS
|
||||
from src.full_node.full_node import FullNode
|
||||
from src.rpc.full_node_rpc_api import FullNodeRpcApi
|
||||
from src.server.outbound_message import NodeType
|
||||
|
|
@ -14,11 +18,13 @@ from src.server.upnp import upnp_remap_port
|
|||
u"".encode("idna")
|
||||
|
||||
|
||||
def service_kwargs_for_full_node(root_path):
|
||||
def service_kwargs_for_full_node(
|
||||
root_path: pathlib.Path, consensus_constants: ConsensusConstants
|
||||
) -> Dict:
|
||||
service_name = "full_node"
|
||||
config = load_config_cli(root_path, "config.yaml", service_name)
|
||||
|
||||
api = FullNode(config, root_path=root_path, consensus_constants=constants)
|
||||
api = FullNode(config, root_path=root_path, consensus_constants=consensus_constants)
|
||||
|
||||
async def start_callback():
|
||||
if config["enable_upnp"]:
|
||||
|
|
@ -49,7 +55,7 @@ def service_kwargs_for_full_node(root_path):
|
|||
|
||||
|
||||
def main():
|
||||
kwargs = service_kwargs_for_full_node(DEFAULT_ROOT_PATH)
|
||||
kwargs = service_kwargs_for_full_node(DEFAULT_ROOT_PATH, DEFAULT_CONSTANTS)
|
||||
return run_service(**kwargs)
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -1,4 +1,9 @@
|
|||
from src.consensus.constants import constants
|
||||
import pathlib
|
||||
|
||||
from typing import Dict
|
||||
|
||||
from src.consensus.constants import ConsensusConstants
|
||||
from src.consensus.default_constants import DEFAULT_CONSTANTS
|
||||
from src.harvester import Harvester
|
||||
from src.server.outbound_message import NodeType
|
||||
from src.types.peer_info import PeerInfo
|
||||
|
|
@ -12,7 +17,9 @@ from src.server.start_service import run_service
|
|||
u"".encode("idna")
|
||||
|
||||
|
||||
def service_kwargs_for_harvester(root_path=DEFAULT_ROOT_PATH):
|
||||
def service_kwargs_for_harvester(
|
||||
root_path: pathlib.Path, consensus_constants: ConsensusConstants
|
||||
) -> Dict:
|
||||
service_name = "harvester"
|
||||
config = load_config_cli(root_path, "config.yaml", service_name)
|
||||
|
||||
|
|
@ -20,7 +27,7 @@ def service_kwargs_for_harvester(root_path=DEFAULT_ROOT_PATH):
|
|||
PeerInfo(config["farmer_peer"]["host"], config["farmer_peer"]["port"])
|
||||
]
|
||||
|
||||
api = Harvester(root_path, constants)
|
||||
api = Harvester(root_path, consensus_constants)
|
||||
|
||||
async def start_callback():
|
||||
await api._start()
|
||||
|
|
@ -50,7 +57,7 @@ def service_kwargs_for_harvester(root_path=DEFAULT_ROOT_PATH):
|
|||
|
||||
|
||||
def main():
|
||||
kwargs = service_kwargs_for_harvester()
|
||||
kwargs = service_kwargs_for_harvester(DEFAULT_ROOT_PATH, DEFAULT_CONSTANTS)
|
||||
return run_service(**kwargs)
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -1,3 +1,9 @@
|
|||
import pathlib
|
||||
|
||||
from typing import Dict
|
||||
|
||||
from src.consensus.constants import ConsensusConstants
|
||||
from src.consensus.default_constants import DEFAULT_CONSTANTS
|
||||
from src.introducer import Introducer
|
||||
from src.server.outbound_message import NodeType
|
||||
from src.util.config import load_config_cli
|
||||
|
|
@ -9,7 +15,9 @@ from src.server.start_service import run_service
|
|||
u"".encode("idna")
|
||||
|
||||
|
||||
def service_kwargs_for_introducer(root_path=DEFAULT_ROOT_PATH):
|
||||
def service_kwargs_for_introducer(
|
||||
root_path: pathlib.Path, constants: ConsensusConstants
|
||||
) -> Dict:
|
||||
service_name = "introducer"
|
||||
config = load_config_cli(root_path, "config.yaml", service_name)
|
||||
introducer = Introducer(
|
||||
|
|
@ -40,7 +48,7 @@ def service_kwargs_for_introducer(root_path=DEFAULT_ROOT_PATH):
|
|||
|
||||
|
||||
def main():
|
||||
kwargs = service_kwargs_for_introducer()
|
||||
kwargs = service_kwargs_for_introducer(DEFAULT_ROOT_PATH, DEFAULT_CONSTANTS)
|
||||
return run_service(**kwargs)
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -1,4 +1,8 @@
|
|||
from src.consensus.constants import constants
|
||||
import pathlib
|
||||
|
||||
from typing import Dict
|
||||
|
||||
from src.consensus.default_constants import DEFAULT_CONSTANTS
|
||||
from src.timelord import Timelord
|
||||
from src.server.outbound_message import NodeType
|
||||
from src.types.peer_info import PeerInfo
|
||||
|
|
@ -11,7 +15,9 @@ from src.server.start_service import run_service
|
|||
u"".encode("idna")
|
||||
|
||||
|
||||
def service_kwargs_for_timelord(root_path):
|
||||
def service_kwargs_for_timelord(
|
||||
root_path: pathlib.Path, discriminant_size_bits: int
|
||||
) -> Dict:
|
||||
service_name = "timelord"
|
||||
config = load_config_cli(root_path, "config.yaml", service_name)
|
||||
|
||||
|
|
@ -19,7 +25,7 @@ def service_kwargs_for_timelord(root_path):
|
|||
PeerInfo(config["full_node_peer"]["host"], config["full_node_peer"]["port"])
|
||||
]
|
||||
|
||||
api = Timelord(config, constants.DISCRIMINANT_SIZE_BITS)
|
||||
api = Timelord(config, discriminant_size_bits)
|
||||
|
||||
async def start_callback():
|
||||
await api._start()
|
||||
|
|
@ -47,7 +53,9 @@ def service_kwargs_for_timelord(root_path):
|
|||
|
||||
|
||||
def main():
|
||||
kwargs = service_kwargs_for_timelord(DEFAULT_ROOT_PATH)
|
||||
kwargs = service_kwargs_for_timelord(
|
||||
DEFAULT_ROOT_PATH, DEFAULT_CONSTANTS.DISCRIMINANT_SIZE_BITS
|
||||
)
|
||||
return run_service(**kwargs)
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -1,6 +1,10 @@
|
|||
from multiprocessing import freeze_support
|
||||
import pathlib
|
||||
|
||||
from src.consensus.constants import constants as consensus_constants
|
||||
from multiprocessing import freeze_support
|
||||
from typing import Dict
|
||||
|
||||
from src.consensus.constants import ConsensusConstants
|
||||
from src.consensus.default_constants import DEFAULT_CONSTANTS
|
||||
from src.wallet.wallet_node import WalletNode
|
||||
from src.rpc.wallet_rpc_api import WalletRpcApi
|
||||
from src.server.outbound_message import NodeType
|
||||
|
|
@ -15,7 +19,9 @@ from src.types.peer_info import PeerInfo
|
|||
u"".encode("idna")
|
||||
|
||||
|
||||
def service_kwargs_for_wallet(root_path):
|
||||
def service_kwargs_for_wallet(
|
||||
root_path: pathlib.Path, consensus_constants: ConsensusConstants
|
||||
) -> Dict:
|
||||
service_name = "wallet"
|
||||
config = load_config_cli(root_path, "config.yaml", service_name)
|
||||
keychain = Keychain(testing=False)
|
||||
|
|
@ -62,7 +68,7 @@ def service_kwargs_for_wallet(root_path):
|
|||
|
||||
|
||||
def main():
|
||||
kwargs = service_kwargs_for_wallet(DEFAULT_ROOT_PATH)
|
||||
kwargs = service_kwargs_for_wallet(DEFAULT_ROOT_PATH, DEFAULT_CONSTANTS)
|
||||
return run_service(**kwargs)
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -681,14 +681,14 @@ class BlockTools:
|
|||
# Run by doing python -m tests.block_tools
|
||||
if __name__ == "__main__":
|
||||
from src.util.default_root import DEFAULT_ROOT_PATH
|
||||
from src.consensus.constants import constants as consensus_constants
|
||||
from src.consensus.default_constants import DEFAULT_CONSTANTS
|
||||
|
||||
initialize_logging("block_tools", {"log_stdout": True}, DEFAULT_ROOT_PATH)
|
||||
bt = BlockTools(root_path=DEFAULT_ROOT_PATH, real_plots=True)
|
||||
print(
|
||||
bytes(
|
||||
bt.create_genesis_block(
|
||||
consensus_constants,
|
||||
DEFAULT_CONSTANTS,
|
||||
bytes([0] * 32),
|
||||
b"0",
|
||||
bytes32(
|
||||
|
|
|
|||
|
|
@ -1,11 +1,11 @@
|
|||
from typing import Dict
|
||||
|
||||
from src.consensus.constants import constants
|
||||
from src.consensus.default_constants import DEFAULT_CONSTANTS
|
||||
from src.util.block_tools import BlockTools
|
||||
|
||||
|
||||
def make_test_constants_with_genesis(test_constants_overrides: Dict):
|
||||
test_constants = constants.replace(**test_constants_overrides)
|
||||
test_constants = make_test_constants_without_genesis(test_constants_overrides)
|
||||
|
||||
bt = BlockTools()
|
||||
|
||||
|
|
@ -20,6 +20,6 @@ def make_test_constants_with_genesis(test_constants_overrides: Dict):
|
|||
|
||||
def make_test_constants_without_genesis(test_constants_overrides: Dict):
|
||||
|
||||
test_constants = constants.replace(**test_constants_overrides)
|
||||
test_constants = DEFAULT_CONSTANTS.replace(**test_constants_overrides)
|
||||
|
||||
return test_constants
|
||||
|
|
|
|||
|
|
@ -5,7 +5,6 @@ import time
|
|||
from typing import Dict
|
||||
from secrets import token_bytes
|
||||
|
||||
from src.consensus.constants import constants
|
||||
from src.protocols import (
|
||||
full_node_protocol as fnp,
|
||||
timelord_protocol,
|
||||
|
|
@ -55,8 +54,8 @@ def event_loop():
|
|||
|
||||
@pytest.fixture(scope="module")
|
||||
async def two_nodes():
|
||||
constants = test_constants.replace(COINBASE_FREEZE_PERIOD=0)
|
||||
async for _ in setup_two_nodes(constants):
|
||||
zero_free_constants = test_constants.replace(COINBASE_FREEZE_PERIOD=0)
|
||||
async for _ in setup_two_nodes(zero_free_constants):
|
||||
yield _
|
||||
|
||||
|
||||
|
|
@ -847,7 +846,7 @@ class TestWalletProtocol:
|
|||
blocks_new[-1].get_coinbase(),
|
||||
)
|
||||
spend_bundle_bad = wallet_a.generate_signed_transaction(
|
||||
constants.MAX_COIN_AMOUNT,
|
||||
test_constants.MAX_COIN_AMOUNT,
|
||||
wallet_a.get_new_puzzlehash(),
|
||||
blocks_new[-1].get_coinbase(),
|
||||
)
|
||||
|
|
|
|||
Loading…
Reference in New Issue