Skip to content

Commit

Permalink
simplify self_hostname. It doesn't need to depend on initial-config.y…
Browse files Browse the repository at this point in the history
…aml -> create_block_tools() -> global variable bt (#10371)
  • Loading branch information
arvidn committed Feb 25, 2022
1 parent ae61ed7 commit bf4a632
Show file tree
Hide file tree
Showing 7 changed files with 47 additions and 47 deletions.
2 changes: 1 addition & 1 deletion tests/core/test_farmer_harvester_rpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -237,7 +237,7 @@ async def test_farmer_get_pool_state(environment):
"launcher_id": "ae4ef3b9bfe68949691281a015a9c16630fc8f66d48c19ca548fb80768791afa",
"owner_public_key": "aa11e92274c0f6a2449fd0c7cfab4a38f943289dbe2214c808b36390c34eacfaa1d4c8f3c6ec582ac502ff32228679a0", # noqa
"payout_instructions": "c2b08e41d766da4116e388357ed957d04ad754623a915f3fd65188a8746cf3e8",
"pool_url": "localhost",
"pool_url": self_hostname,
"p2_singleton_puzzle_hash": "16e4bac26558d315cded63d4c5860e98deb447cc59146dd4de06ce7394b14f17",
"target_puzzle_hash": "344587cf06a39db471d2cc027504e8688a0a67cce961253500c956c73603fd58",
}
Expand Down
30 changes: 14 additions & 16 deletions tests/pools/test_pool_rpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -102,13 +102,12 @@ async def one_wallet_node_and_rpc(self):

api_user = WalletRpcApi(wallet_node_0)
config = bt.config
hostname = config["self_hostname"]
daemon_port = config["daemon_port"]
test_rpc_port = find_available_listen_port("rpc_port")

rpc_cleanup = await start_rpc_server(
api_user,
hostname,
self_hostname,
daemon_port,
test_rpc_port,
lambda x: None,
Expand Down Expand Up @@ -136,13 +135,12 @@ async def setup(self, two_wallet_nodes):
pool_ph = pool_ph_record.puzzle_hash
api_user = WalletRpcApi(wallet_node_0)
config = bt.config
hostname = config["self_hostname"]
daemon_port = config["daemon_port"]
test_rpc_port = find_available_listen_port("rpc_port")

rpc_cleanup = await start_rpc_server(
api_user,
hostname,
self_hostname,
daemon_port,
test_rpc_port,
lambda x: None,
Expand Down Expand Up @@ -199,7 +197,7 @@ async def test_create_new_pool_wallet_self_farm(self, one_wallet_node_and_rpc, f
assert False
await time_out_assert(10, wallet_is_synced, True, wallet_node_0, full_node_api)
creation_tx: TransactionRecord = await client.create_new_pool_wallet(
our_ph, "", 0, "localhost:5000", "new", "SELF_POOLING", fee
our_ph, "", 0, f"{self_hostname}:5000", "new", "SELF_POOLING", fee
)
await time_out_assert(
10,
Expand Down Expand Up @@ -278,7 +276,7 @@ async def test_create_new_pool_wallet_farm_to_pool(self, one_wallet_node_and_rpc
assert False

creation_tx: TransactionRecord = await client.create_new_pool_wallet(
our_ph, "http://pool.example.com", 10, "localhost:5000", "new", "FARMING_TO_POOL", fee
our_ph, "http://pool.example.com", 10, f"{self_hostname}:5000", "new", "FARMING_TO_POOL", fee
)
await time_out_assert(
10,
Expand Down Expand Up @@ -356,10 +354,10 @@ async def test_create_multiple_pool_wallets(self, one_wallet_node_and_rpc, fee,
assert False

creation_tx: TransactionRecord = await client.create_new_pool_wallet(
our_ph_1, "", 0, "localhost:5000", "new", "SELF_POOLING", fee
our_ph_1, "", 0, f"{self_hostname}:5000", "new", "SELF_POOLING", fee
)
creation_tx_2: TransactionRecord = await client.create_new_pool_wallet(
our_ph_1, "localhost", 12, "localhost:5000", "new", "FARMING_TO_POOL", fee
our_ph_1, self_hostname, 12, f"{self_hostname}:5000", "new", "FARMING_TO_POOL", fee
)

await time_out_assert(
Expand Down Expand Up @@ -427,7 +425,7 @@ async def test_create_multiple_pool_wallets(self, one_wallet_node_and_rpc, fee,
for i in range(22):
await time_out_assert(10, wallet_is_synced, True, wallet_node_0, full_node_api)
creation_tx_3: TransactionRecord = await client.create_new_pool_wallet(
our_ph_1, "localhost", 5, "localhost:5000", "new", "FARMING_TO_POOL", fee
our_ph_1, self_hostname, 5, f"{self_hostname}:5000", "new", "FARMING_TO_POOL", fee
)
await time_out_assert(
10,
Expand Down Expand Up @@ -485,7 +483,7 @@ async def test_absorb_self(self, one_wallet_node_and_rpc, fee, trusted):

await time_out_assert(10, wallet_is_synced, True, wallet_node_0, full_node_api)
creation_tx: TransactionRecord = await client.create_new_pool_wallet(
our_ph, "", 0, "localhost:5000", "new", "SELF_POOLING", fee
our_ph, "", 0, f"{self_hostname}:5000", "new", "SELF_POOLING", fee
)

await time_out_assert(
Expand Down Expand Up @@ -602,7 +600,7 @@ async def test_absorb_pooling(self, one_wallet_node_and_rpc, fee, trusted):
# Balance stars at 6 XCH
assert (await wallet_0.get_confirmed_balance()) == 6000000000000
creation_tx: TransactionRecord = await client.create_new_pool_wallet(
our_ph, "http://123.45.67.89", 10, "localhost:5000", "new", "FARMING_TO_POOL", fee
our_ph, "http://123.45.67.89", 10, f"{self_hostname}:5000", "new", "FARMING_TO_POOL", fee
)

await time_out_assert(
Expand Down Expand Up @@ -761,10 +759,10 @@ async def test_self_pooling_to_pooling(self, setup, fee, trusted):
assert False

creation_tx: TransactionRecord = await client.create_new_pool_wallet(
our_ph, "", 0, "localhost:5000", "new", "SELF_POOLING", fee
our_ph, "", 0, f"{self_hostname}:5000", "new", "SELF_POOLING", fee
)
creation_tx_2: TransactionRecord = await client.create_new_pool_wallet(
our_ph, "", 0, "localhost:5000", "new", "SELF_POOLING", fee
our_ph, "", 0, f"{self_hostname}:5000", "new", "SELF_POOLING", fee
)

await time_out_assert(
Expand Down Expand Up @@ -895,7 +893,7 @@ async def have_chia():
await time_out_assert(10, wallet_is_synced, True, wallet_nodes[0], full_node_api)

creation_tx: TransactionRecord = await client.create_new_pool_wallet(
our_ph, "", 0, "localhost:5000", "new", "SELF_POOLING", fee
our_ph, "", 0, f"{self_hostname}:5000", "new", "SELF_POOLING", fee
)

await time_out_assert(
Expand Down Expand Up @@ -1018,7 +1016,7 @@ async def have_chia():
await time_out_assert(10, wallet_is_synced, True, wallet_nodes[0], full_node_api)

creation_tx: TransactionRecord = await client.create_new_pool_wallet(
pool_a_ph, "https://pool-a.org", 5, "localhost:5000", "new", "FARMING_TO_POOL", fee
pool_a_ph, "https://pool-a.org", 5, f"{self_hostname}:5000", "new", "FARMING_TO_POOL", fee
)

await time_out_assert(
Expand Down Expand Up @@ -1121,7 +1119,7 @@ async def have_chia():
await time_out_assert(10, wallet_is_synced, True, wallet_nodes[0], full_node_api)

creation_tx: TransactionRecord = await client.create_new_pool_wallet(
pool_a_ph, "https://pool-a.org", 5, "localhost:5000", "new", "FARMING_TO_POOL", fee
pool_a_ph, "https://pool-a.org", 5, f"{self_hostname}:5000", "new", "FARMING_TO_POOL", fee
)

await time_out_assert(
Expand Down
4 changes: 3 additions & 1 deletion tests/setup_nodes.py
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,9 @@ def cleanup_keyring(keyring: TempKeyring):
atexit.register(cleanup_keyring, temp_keyring) # Attempt to cleanup the temp keychain
bt = create_block_tools(constants=test_constants, keychain=keychain)

self_hostname = bt.config["self_hostname"]
# if you have a system that has an unusual hostname for localhost and you want
# to run the tests, change this constant
self_hostname = "localhost"


def constants_for_dic(dic):
Expand Down
28 changes: 14 additions & 14 deletions tests/wallet/cat_wallet/test_cat_wallet.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
from chia.wallet.transaction_record import TransactionRecord
from chia.wallet.wallet_info import WalletInfo
from tests.pools.test_pool_rpc import wallet_is_synced
from tests.setup_nodes import setup_simulators_and_wallets
from tests.setup_nodes import self_hostname, setup_simulators_and_wallets
from tests.time_out_assert import time_out_assert


Expand Down Expand Up @@ -65,7 +65,7 @@ async def test_cat_creation(self, two_wallet_nodes, trusted):
else:
wallet_node.config["trusted_peers"] = {}

await server_2.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_2.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)
for i in range(0, num_blocks):
await full_node_api.farm_new_transaction_block(FarmNewBlockProtocol(ph))
await full_node_api.farm_new_transaction_block(FarmNewBlockProtocol(32 * b"0"))
Expand Down Expand Up @@ -137,8 +137,8 @@ async def test_cat_spend(self, two_wallet_nodes, trusted):
else:
wallet_node.config["trusted_peers"] = {}
wallet_node_2.config["trusted_peers"] = {}
await server_2.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_3.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_2.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)
await server_3.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)

for i in range(0, num_blocks):
await full_node_api.farm_new_transaction_block(FarmNewBlockProtocol(ph))
Expand Down Expand Up @@ -234,7 +234,7 @@ async def test_get_wallet_for_asset_id(self, two_wallet_nodes, trusted):
wallet_node.config["trusted_peers"] = {full_node_server.node_id.hex(): full_node_server.node_id.hex()}
else:
wallet_node.config["trusted_peers"] = {}
await server_2.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_2.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)

for i in range(0, num_blocks):
await full_node_api.farm_new_transaction_block(FarmNewBlockProtocol(ph))
Expand Down Expand Up @@ -291,8 +291,8 @@ async def test_cat_doesnt_see_eve(self, two_wallet_nodes, trusted):
else:
wallet_node.config["trusted_peers"] = {}
wallet_node_2.config["trusted_peers"] = {}
await server_2.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_3.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_2.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)
await server_3.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)

for i in range(0, num_blocks):
await full_node_api.farm_new_transaction_block(FarmNewBlockProtocol(ph))
Expand Down Expand Up @@ -398,9 +398,9 @@ async def test_cat_spend_multiple(self, three_wallet_nodes, trusted):
wallet_node_0.config["trusted_peers"] = {}
wallet_node_1.config["trusted_peers"] = {}
wallet_node_2.config["trusted_peers"] = {}
await wallet_server_0.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await wallet_server_1.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await wallet_server_2.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await wallet_server_0.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)
await wallet_server_1.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)
await wallet_server_2.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)

for i in range(0, num_blocks):
await full_node_api.farm_new_transaction_block(FarmNewBlockProtocol(ph))
Expand Down Expand Up @@ -534,8 +534,8 @@ async def test_cat_max_amount_send(self, two_wallet_nodes, trusted):
else:
wallet_node.config["trusted_peers"] = {}
wallet_node_2.config["trusted_peers"] = {}
await server_2.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_3.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_2.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)
await server_3.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)

for i in range(0, num_blocks):
await full_node_api.farm_new_transaction_block(FarmNewBlockProtocol(ph))
Expand Down Expand Up @@ -663,8 +663,8 @@ async def test_cat_hint(self, two_wallet_nodes, trusted):
else:
wallet_node.config["trusted_peers"] = {}
wallet_node_2.config["trusted_peers"] = {}
await server_2.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_3.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_2.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)
await server_3.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)

for i in range(0, num_blocks):
await full_node_api.farm_new_transaction_block(FarmNewBlockProtocol(ph))
Expand Down
6 changes: 3 additions & 3 deletions tests/wallet/cat_wallet/test_trades.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
from chia.wallet.trading.trade_status import TradeStatus
from chia.wallet.transaction_record import TransactionRecord
from tests.pools.test_pool_rpc import wallet_is_synced
from tests.setup_nodes import setup_simulators_and_wallets
from tests.setup_nodes import self_hostname, setup_simulators_and_wallets
from tests.time_out_assert import time_out_assert


Expand Down Expand Up @@ -65,8 +65,8 @@ async def wallets_prefarm(two_wallet_nodes, trusted):
wallet_node_0.config["trusted_peers"] = {}
wallet_node_1.config["trusted_peers"] = {}

await wallet_server_0.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await wallet_server_1.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await wallet_server_0.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)
await wallet_server_1.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)

for i in range(0, farm_blocks):
await full_node_api.farm_new_transaction_block(FarmNewBlockProtocol(ph0))
Expand Down
20 changes: 10 additions & 10 deletions tests/wallet/did_wallet/test_did.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
from chia.simulator.simulator_protocol import FarmNewBlockProtocol
from chia.types.peer_info import PeerInfo
from chia.util.ints import uint16, uint32, uint64
from tests.setup_nodes import setup_simulators_and_wallets
from tests.setup_nodes import self_hostname, setup_simulators_and_wallets
from chia.wallet.did_wallet.did_wallet import DIDWallet
from chia.types.blockchain_format.program import Program
from blspy import AugSchemeMPL
Expand Down Expand Up @@ -64,9 +64,9 @@ async def test_creation_from_backup_file(self, three_wallet_nodes):
ph1 = await wallet_1.get_new_puzzlehash()
ph2 = await wallet_2.get_new_puzzlehash()

await server_0.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_1.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_2.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_0.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)
await server_1.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)
await server_2.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)

for i in range(1, num_blocks):
await full_node_api.farm_new_transaction_block(FarmNewBlockProtocol(ph))
Expand Down Expand Up @@ -185,8 +185,8 @@ async def test_did_recovery_with_multiple_backup_dids(self, two_wallet_nodes):

ph = await wallet.get_new_puzzlehash()

await server_2.start_client(PeerInfo("localhost", uint16(server_1._port)), None)
await server_3.start_client(PeerInfo("localhost", uint16(server_1._port)), None)
await server_2.start_client(PeerInfo(self_hostname, uint16(server_1._port)), None)
await server_3.start_client(PeerInfo(self_hostname, uint16(server_1._port)), None)

for i in range(1, num_blocks):
await full_node_1.farm_new_transaction_block(FarmNewBlockProtocol(ph))
Expand Down Expand Up @@ -292,8 +292,8 @@ async def test_did_recovery_with_empty_set(self, two_wallet_nodes):

ph = await wallet.get_new_puzzlehash()

await server_2.start_client(PeerInfo("localhost", uint16(server_1._port)), None)
await server_3.start_client(PeerInfo("localhost", uint16(server_1._port)), None)
await server_2.start_client(PeerInfo(self_hostname, uint16(server_1._port)), None)
await server_3.start_client(PeerInfo(self_hostname, uint16(server_1._port)), None)

for i in range(1, num_blocks):
await full_node_1.farm_new_transaction_block(FarmNewBlockProtocol(ph))
Expand Down Expand Up @@ -339,8 +339,8 @@ async def test_did_attest_after_recovery(self, two_wallet_nodes):
wallet2 = wallet_node_2.wallet_state_manager.main_wallet
ph = await wallet.get_new_puzzlehash()

await server_2.start_client(PeerInfo("localhost", uint16(server_1._port)), None)
await server_3.start_client(PeerInfo("localhost", uint16(server_1._port)), None)
await server_2.start_client(PeerInfo(self_hostname, uint16(server_1._port)), None)
await server_3.start_client(PeerInfo(self_hostname, uint16(server_1._port)), None)
for i in range(1, num_blocks):
await full_node_1.farm_new_transaction_block(FarmNewBlockProtocol(ph))

Expand Down
4 changes: 2 additions & 2 deletions tests/wallet/rpc/test_wallet_rpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -67,8 +67,8 @@ async def test_wallet_rpc(self, two_wallet_nodes, trusted):
ph = await wallet.get_new_puzzlehash()
ph_2 = await wallet_2.get_new_puzzlehash()

await server_2.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_3.start_client(PeerInfo("localhost", uint16(full_node_server._port)), None)
await server_2.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)
await server_3.start_client(PeerInfo(self_hostname, uint16(full_node_server._port)), None)

if trusted:
wallet_node.config["trusted_peers"] = {full_node_server.node_id.hex(): full_node_server.node_id.hex()}
Expand Down

0 comments on commit bf4a632

Please sign in to comment.