mirror of
https://github.com/Chia-Network/chia-blockchain.git
synced 2026-08-24 10:05:29 -05:00
Jack NelsonandGitHub
0bc54ae08b
* create new test.simulator module to allow other packages to use the simulator without it crashing. also tiny QOL fixes * change user mode sim plot filter Now only plots matching the user set fingerprint are loaded, this decreases the chance of user error. * fix small oops in configure * oops * fix lint * isort, who dis * move folder over to chia/simulator also change mypy settings again
89 lines
3.3 KiB
Python
89 lines
3.3 KiB
Python
import asyncio
|
|
import logging
|
|
from typing import Tuple
|
|
|
|
import aiohttp
|
|
from cryptography import x509
|
|
from cryptography.hazmat.backends import default_backend
|
|
from cryptography.hazmat.primitives import hashes, serialization
|
|
|
|
from chia.protocols.shared_protocol import capabilities, protocol_version
|
|
from chia.server.outbound_message import NodeType
|
|
from chia.server.server import ChiaServer, ssl_context_for_client
|
|
from chia.server.ws_connection import WSChiaConnection
|
|
from chia.simulator.time_out_assert import time_out_assert
|
|
from chia.ssl.create_ssl import generate_ca_signed_cert
|
|
from chia.types.blockchain_format.sized_bytes import bytes32
|
|
from chia.types.peer_info import PeerInfo
|
|
from chia.util.ints import uint16
|
|
|
|
log = logging.getLogger(__name__)
|
|
|
|
|
|
async def disconnect_all(server: ChiaServer) -> None:
|
|
cons = list(server.all_connections.values())[:]
|
|
for con in cons:
|
|
await con.close()
|
|
|
|
|
|
async def disconnect_all_and_reconnect(server: ChiaServer, reconnect_to: ChiaServer, self_hostname: str) -> bool:
|
|
await disconnect_all(server)
|
|
return await server.start_client(PeerInfo(self_hostname, uint16(reconnect_to._port)), None)
|
|
|
|
|
|
async def add_dummy_connection(
|
|
server: ChiaServer, self_hostname: str, dummy_port: int, type: NodeType = NodeType.FULL_NODE
|
|
) -> Tuple[asyncio.Queue, bytes32]:
|
|
timeout = aiohttp.ClientTimeout(total=10)
|
|
session = aiohttp.ClientSession(timeout=timeout)
|
|
incoming_queue: asyncio.Queue = asyncio.Queue()
|
|
dummy_crt_path = server._private_key_path.parent / "dummy.crt"
|
|
dummy_key_path = server._private_key_path.parent / "dummy.key"
|
|
generate_ca_signed_cert(
|
|
server.chia_ca_crt_path.read_bytes(), server.chia_ca_key_path.read_bytes(), dummy_crt_path, dummy_key_path
|
|
)
|
|
ssl_context = ssl_context_for_client(
|
|
server.chia_ca_crt_path, server.chia_ca_key_path, dummy_crt_path, dummy_key_path
|
|
)
|
|
pem_cert = x509.load_pem_x509_certificate(dummy_crt_path.read_bytes(), default_backend())
|
|
der_cert = x509.load_der_x509_certificate(pem_cert.public_bytes(serialization.Encoding.DER), default_backend())
|
|
peer_id = bytes32(der_cert.fingerprint(hashes.SHA256()))
|
|
url = f"wss://{self_hostname}:{server._port}/ws"
|
|
ws = await session.ws_connect(url, autoclose=True, autoping=True, ssl=ssl_context)
|
|
wsc = WSChiaConnection(
|
|
type,
|
|
ws,
|
|
server._port,
|
|
log,
|
|
True,
|
|
False,
|
|
self_hostname,
|
|
incoming_queue,
|
|
lambda x, y: x,
|
|
peer_id,
|
|
100,
|
|
30,
|
|
local_capabilities_for_handshake=capabilities,
|
|
)
|
|
await wsc.perform_handshake(server._network_id, protocol_version, dummy_port, NodeType.FULL_NODE)
|
|
return incoming_queue, peer_id
|
|
|
|
|
|
async def connect_and_get_peer(server_1: ChiaServer, server_2: ChiaServer, self_hostname: str) -> WSChiaConnection:
|
|
"""
|
|
Connect server_2 to server_1, and get return the connection in server_1.
|
|
"""
|
|
await server_2.start_client(PeerInfo(self_hostname, uint16(server_1._port)))
|
|
|
|
async def connected():
|
|
for node_id_c, _ in server_1.all_connections.items():
|
|
if node_id_c == server_2.node_id:
|
|
return True
|
|
return False
|
|
|
|
await time_out_assert(10, connected, True)
|
|
for node_id, wsc in server_1.all_connections.items():
|
|
if node_id == server_2.node_id:
|
|
return wsc
|
|
assert False
|