mirror of https://github.com/nucypher/nucypher.git
Remove more DHT cruft
parent
f7c0d7959e
commit
2f409181dd
|
@ -16,7 +16,7 @@ from nucypher.blockchain.eth.chains import Blockchain, TesterBlockchain
|
||||||
from nucypher.blockchain.eth.deployers import NucypherTokenDeployer, MinerEscrowDeployer, PolicyManagerDeployer
|
from nucypher.blockchain.eth.deployers import NucypherTokenDeployer, MinerEscrowDeployer, PolicyManagerDeployer
|
||||||
from nucypher.characters import Ursula
|
from nucypher.characters import Ursula
|
||||||
from nucypher.config.constants import DEFAULT_CONFIG_ROOT, DEFAULT_SIMULATION_PORT, \
|
from nucypher.config.constants import DEFAULT_CONFIG_ROOT, DEFAULT_SIMULATION_PORT, \
|
||||||
DEFAULT_SIMULATION_REGISTRY_FILEPATH, DEFAULT_INI_FILEPATH, DEFAULT_REST_PORT, DEFAULT_DHT_PORT, DEFAULT_DB_NAME, \
|
DEFAULT_SIMULATION_REGISTRY_FILEPATH, DEFAULT_INI_FILEPATH, DEFAULT_REST_PORT, DEFAULT_DB_NAME, \
|
||||||
BASE_DIR
|
BASE_DIR
|
||||||
from nucypher.config.metadata import write_node_metadata, collect_stored_nodes
|
from nucypher.config.metadata import write_node_metadata, collect_stored_nodes
|
||||||
from nucypher.config.parsers import parse_nucypher_ini_config, parse_running_modes
|
from nucypher.config.parsers import parse_nucypher_ini_config, parse_running_modes
|
||||||
|
@ -688,7 +688,6 @@ def status(config, provider, contracts, network):
|
||||||
@click.option('--seed-node', is_flag=True, default=False)
|
@click.option('--seed-node', is_flag=True, default=False)
|
||||||
@click.option('--rest-host', type=str, default='localhost')
|
@click.option('--rest-host', type=str, default='localhost')
|
||||||
@click.option('--rest-port', type=int, default=DEFAULT_REST_PORT)
|
@click.option('--rest-port', type=int, default=DEFAULT_REST_PORT)
|
||||||
@click.option('--dht-port', type=int, default=DEFAULT_DHT_PORT)
|
|
||||||
@click.option('--db-name', type=str, default=DEFAULT_DB_NAME)
|
@click.option('--db-name', type=str, default=DEFAULT_DB_NAME)
|
||||||
@click.option('--checksum-address', type=str)
|
@click.option('--checksum-address', type=str)
|
||||||
@click.option('--data-dir', type=click.Path(), default=DEFAULT_CONFIG_ROOT)
|
@click.option('--data-dir', type=click.Path(), default=DEFAULT_CONFIG_ROOT)
|
||||||
|
|
|
@ -227,16 +227,6 @@ class Character:
|
||||||
|
|
||||||
return cls(is_me=False, federated_only=federated_only, crypto_power=crypto_power, *args, **kwargs)
|
return cls(is_me=False, federated_only=federated_only, crypto_power=crypto_power, *args, **kwargs)
|
||||||
|
|
||||||
def attach_dht_server(self, ksize=20, alpha=3, id=None, storage=None, *args, **kwargs) -> None:
|
|
||||||
if self._dht_server:
|
|
||||||
raise RuntimeError("Attaching the server twice is almost certainly a bad idea.")
|
|
||||||
|
|
||||||
self._dht_server = self._dht_server_class(node_storage=self._known_nodes, # TODO: 340
|
|
||||||
treasure_map_storage=self._stored_treasure_maps, # TODO: 340
|
|
||||||
federated_only=self.federated_only,
|
|
||||||
ksize=ksize, alpha=alpha, id=id,
|
|
||||||
storage=storage, *args, **kwargs)
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def stamp(self):
|
def stamp(self):
|
||||||
if self._stamp is constants.NO_SIGNING_POWER:
|
if self._stamp is constants.NO_SIGNING_POWER:
|
||||||
|
@ -246,13 +236,6 @@ class Character:
|
||||||
else:
|
else:
|
||||||
return self._stamp
|
return self._stamp
|
||||||
|
|
||||||
@property
|
|
||||||
def dht_server(self) -> kademlia.network.Server:
|
|
||||||
if self._dht_server:
|
|
||||||
return self._dht_server
|
|
||||||
else:
|
|
||||||
raise RuntimeError("Server hasn't been attached.")
|
|
||||||
|
|
||||||
######
|
######
|
||||||
# Knowing and learning about nodes
|
# Knowing and learning about nodes
|
||||||
##
|
##
|
||||||
|
@ -1122,7 +1105,6 @@ class Ursula(Character, VerifiableNode, Miner):
|
||||||
if is_me is True:
|
if is_me is True:
|
||||||
# TODO: 340
|
# TODO: 340
|
||||||
self._stored_treasure_maps = {}
|
self._stored_treasure_maps = {}
|
||||||
self.attach_dht_server()
|
|
||||||
if not federated_only:
|
if not federated_only:
|
||||||
self.substantiate_stamp()
|
self.substantiate_stamp()
|
||||||
|
|
||||||
|
@ -1136,7 +1118,6 @@ class Ursula(Character, VerifiableNode, Miner):
|
||||||
db_name=db_name,
|
db_name=db_name,
|
||||||
network_middleware=self.network_middleware,
|
network_middleware=self.network_middleware,
|
||||||
federated_only=self.federated_only,
|
federated_only=self.federated_only,
|
||||||
dht_server=self.dht_server,
|
|
||||||
treasure_map_tracker=self.treasure_maps,
|
treasure_map_tracker=self.treasure_maps,
|
||||||
node_tracker=self._known_nodes,
|
node_tracker=self._known_nodes,
|
||||||
node_bytes_caster=self.__bytes__,
|
node_bytes_caster=self.__bytes__,
|
||||||
|
|
|
@ -14,12 +14,12 @@ APP_DIRS = AppDirs("nucypher", "NuCypher")
|
||||||
PROJECT_ROOT = abspath(dirname(nucypher.__file__))
|
PROJECT_ROOT = abspath(dirname(nucypher.__file__))
|
||||||
|
|
||||||
DEFAULT_CONFIG_ROOT = APP_DIRS.user_data_dir
|
DEFAULT_CONFIG_ROOT = APP_DIRS.user_data_dir
|
||||||
|
TEMPLATE_INI_FILEPATH = os.path.join(BASE_DIR, 'cli', '.nucypher.ini')
|
||||||
DEFAULT_INI_FILEPATH = os.path.join(DEFAULT_CONFIG_ROOT, 'nucypher.ini')
|
DEFAULT_INI_FILEPATH = os.path.join(DEFAULT_CONFIG_ROOT, 'nucypher.ini')
|
||||||
DEFAULT_KEYRING_ROOT = os.path.join(DEFAULT_CONFIG_ROOT, 'keyring')
|
DEFAULT_KEYRING_ROOT = os.path.join(DEFAULT_CONFIG_ROOT, 'keyring')
|
||||||
DEFAULT_TLS_CERTIFICATE_FILEPATH = os.path.join(DEFAULT_CONFIG_ROOT, 'ursula.public.pem')
|
DEFAULT_TLS_CERTIFICATE_FILEPATH = os.path.join(DEFAULT_CONFIG_ROOT, 'ursula.pem')
|
||||||
|
|
||||||
DEFAULT_REST_PORT = 9151
|
DEFAULT_REST_PORT = 9151
|
||||||
DEFAULT_DHT_PORT = DEFAULT_REST_PORT + 100
|
|
||||||
DEFAULT_DB_NAME = "ursula.{port}.db".format(port=DEFAULT_REST_PORT)
|
DEFAULT_DB_NAME = "ursula.{port}.db".format(port=DEFAULT_REST_PORT)
|
||||||
|
|
||||||
DEFAULT_SEED_NODE_DIR = os.path.join(DEFAULT_CONFIG_ROOT, 'seed_nodes')
|
DEFAULT_SEED_NODE_DIR = os.path.join(DEFAULT_CONFIG_ROOT, 'seed_nodes')
|
||||||
|
@ -30,5 +30,5 @@ DEFAULT_KNOWN_NODE_DIR = os.path.join(DEFAULT_CONFIG_ROOT, 'known_nodes')
|
||||||
DEFAULT_KNOWN_CERTIFICATES_DIR = os.path.join(DEFAULT_KNOWN_NODE_DIR, 'certificates')
|
DEFAULT_KNOWN_CERTIFICATES_DIR = os.path.join(DEFAULT_KNOWN_NODE_DIR, 'certificates')
|
||||||
DEFAULT_KNOWN_METADATA_DIR = os.path.join(DEFAULT_KNOWN_NODE_DIR, 'metadata')
|
DEFAULT_KNOWN_METADATA_DIR = os.path.join(DEFAULT_KNOWN_NODE_DIR, 'metadata')
|
||||||
|
|
||||||
DEFAULT_SIMULATION_PORT = 5555
|
DEFAULT_SIMULATION_PORT = 8151
|
||||||
DEFAULT_SIMULATION_REGISTRY_FILEPATH = os.path.join(DEFAULT_CONFIG_ROOT, 'simulation_registry.json')
|
DEFAULT_SIMULATION_REGISTRY_FILEPATH = os.path.join(DEFAULT_CONFIG_ROOT, 'simulation_registry.json')
|
||||||
|
|
|
@ -126,7 +126,6 @@ class ProxyRESTRoutes:
|
||||||
db_name,
|
db_name,
|
||||||
network_middleware,
|
network_middleware,
|
||||||
federated_only,
|
federated_only,
|
||||||
dht_server,
|
|
||||||
treasure_map_tracker,
|
treasure_map_tracker,
|
||||||
node_tracker,
|
node_tracker,
|
||||||
node_bytes_caster,
|
node_bytes_caster,
|
||||||
|
@ -138,7 +137,6 @@ class ProxyRESTRoutes:
|
||||||
|
|
||||||
self.network_middleware = network_middleware
|
self.network_middleware = network_middleware
|
||||||
self.federated_only = federated_only
|
self.federated_only = federated_only
|
||||||
self.dht_server = dht_server
|
|
||||||
|
|
||||||
self._treasure_map_tracker = treasure_map_tracker
|
self._treasure_map_tracker = treasure_map_tracker
|
||||||
self._work_order_tracker = work_order_tracker
|
self._work_order_tracker = work_order_tracker
|
||||||
|
|
Loading…
Reference in New Issue