fix appveyor
This commit is contained in:
parent
487ef6516e
commit
1e87767a0c
2 changed files with 5 additions and 6 deletions
|
@ -14,8 +14,6 @@ from lbrynet.file_manager import EncryptedFileManager
|
||||||
from lbrynet.tests import mocks
|
from lbrynet.tests import mocks
|
||||||
from lbrynet.tests.util import mk_db_and_blob_dir, rm_db_and_blob_dir
|
from lbrynet.tests.util import mk_db_and_blob_dir, rm_db_and_blob_dir
|
||||||
|
|
||||||
from lbrynet.tests.mocks import Node
|
|
||||||
|
|
||||||
|
|
||||||
class TestReflector(unittest.TestCase):
|
class TestReflector(unittest.TestCase):
|
||||||
def setUp(self):
|
def setUp(self):
|
||||||
|
@ -62,7 +60,7 @@ class TestReflector(unittest.TestCase):
|
||||||
wallet=wallet,
|
wallet=wallet,
|
||||||
blob_tracker_class=mocks.BlobAvailabilityTracker,
|
blob_tracker_class=mocks.BlobAvailabilityTracker,
|
||||||
external_ip="127.0.0.1",
|
external_ip="127.0.0.1",
|
||||||
dht_node_class=Node,
|
dht_node_class=mocks.Node,
|
||||||
hash_announcer=mocks.Announcer()
|
hash_announcer=mocks.Announcer()
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -83,7 +81,7 @@ class TestReflector(unittest.TestCase):
|
||||||
wallet=wallet,
|
wallet=wallet,
|
||||||
blob_tracker_class=mocks.BlobAvailabilityTracker,
|
blob_tracker_class=mocks.BlobAvailabilityTracker,
|
||||||
external_ip="127.0.0.1",
|
external_ip="127.0.0.1",
|
||||||
dht_node_class=Node,
|
dht_node_class=mocks.Node,
|
||||||
hash_announcer=mocks.Announcer()
|
hash_announcer=mocks.Announcer()
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
|
@ -25,10 +25,11 @@ class FakeLBRYFile(object):
|
||||||
|
|
||||||
|
|
||||||
class Node(object):
|
class Node(object):
|
||||||
def __init__(self, peer_finder=None, peer_manager=None, **kwargs):
|
def __init__(self, peer_finder=None, peer_manager=None, dht_node_port=None, peer_port=3333, **kwargs):
|
||||||
self.peer_finder = peer_finder
|
self.peer_finder = peer_finder
|
||||||
self.peer_manager = peer_manager
|
self.peer_manager = peer_manager
|
||||||
self.peerPort = 3333
|
self.peerPort = peer_port
|
||||||
|
self.udpPort = dht_node_port
|
||||||
|
|
||||||
def joinNetwork(self, *args):
|
def joinNetwork(self, *args):
|
||||||
return defer.succeed(True)
|
return defer.succeed(True)
|
||||||
|
|
Loading…
Reference in a new issue