diff --git a/deploy/learning_monitor.py b/deploy/learning_monitor.py index 59aa30210..22fb697b5 100644 --- a/deploy/learning_monitor.py +++ b/deploy/learning_monitor.py @@ -1,3 +1,4 @@ +import json import sys import json import os.path @@ -14,6 +15,7 @@ from nucypher.network.middleware import RestMiddleware from nucypher.network.nodes import FleetStateTracker from nucypher.utilities.logging import SimpleObserver + websocket_service = hey_joe.WebSocketService("127.0.0.1", 9000) globalLogPublisher.addObserver(SimpleObserver()) @@ -39,11 +41,17 @@ class Moe(Character): """ tracker_class = MonitoringTracker _SHORT_LEARNING_DELAY = .5 + _LONG_LEARNING_DELAY = 30 + LEARNING_TIMEOUT = 10 + _ROUNDS_WITHOUT_NODES_AFTER_WHICH_TO_SLOW_DOWN = 25 def remember_node(self, *args, **kwargs): new_node_or_none = super().remember_node(*args, **kwargs) if new_node_or_none: - hey_joe.send({new_node_or_none.checksum_public_address: MonitoringTracker.abridged_node_details(new_node_or_none)}, "nodes") + hey_joe.send( + {new_node_or_none.checksum_public_address: MonitoringTracker.abridged_node_details(new_node_or_none)}, + "nodes") + return new_node_or_none def learn_from_teacher_node(self, *args, **kwargs): teacher = self.current_teacher_node(cycle=False) @@ -80,9 +88,6 @@ websocket_service.register_followup("nodes", send_nodes) @rest_app.route("/") def status(): - # for node in monitor.known_nodes: - # hey_joe.send(node.status_json(), topic="nodes") - return render_template('monitor.html')