From adcd6edfcba894db7882de5af2f713cf4461771c Mon Sep 17 00:00:00 2001 From: Alex Grintsvayg Date: Fri, 23 Mar 2018 19:19:14 -0400 Subject: [PATCH] a very simple dht node script --- scripts/simple_dht_node.py | 39 ++++++++++++++++++++++++++++++++++++++ 1 file changed, 39 insertions(+) create mode 100755 scripts/simple_dht_node.py diff --git a/scripts/simple_dht_node.py b/scripts/simple_dht_node.py new file mode 100755 index 000000000..209f15385 --- /dev/null +++ b/scripts/simple_dht_node.py @@ -0,0 +1,39 @@ +#!/usr/bin/env python + +from lbrynet.core import log_support +import logging.handlers +import sys +import time +from pprint import pprint + +from twisted.internet import defer, reactor +from lbrynet.dht.node import Node +import lbrynet.dht.constants +import lbrynet.dht.datastore +from lbrynet.tests.util import random_lbry_hash + +log = logging.getLogger(__name__) + + +@defer.inlineCallbacks +def run(): + node = Node(externalIP='127.0.0.1', udpPort=21215) + node.startNetwork() + yield node.joinNetwork([("127.0.0.1", 21216)]) + node2 = Node(externalIP='127.0.0.1', udpPort=21217) + node2.startNetwork() + yield node2.joinNetwork([("127.0.0.1", 21216)]) + log.info("Shutting down...") + reactor.callLater(0, reactor.stop) + + +def main(): + log_support.configure_console(level='DEBUG') + log_support.configure_twisted() + reactor.callLater(0, run) + log.info("Running reactor") + reactor.run() + + +if __name__ == '__main__': + sys.exit(main())