diff --git a/lbrynet/lbrynet_daemon/LBRYDaemon.py b/lbrynet/lbrynet_daemon/LBRYDaemon.py index 687f23f73..a6a2d3066 100644 --- a/lbrynet/lbrynet_daemon/LBRYDaemon.py +++ b/lbrynet/lbrynet_daemon/LBRYDaemon.py @@ -1359,7 +1359,7 @@ class LBRYDaemon(jsonrpc.JSONRPC): reflector_server = random.choice(REFLECTOR_SERVERS) reflector_address, reflector_port = reflector_server[0], reflector_server[1] log.info("Start reflector client") - factory = reflector.LBRYFileReflectorClientFactory( + factory = reflector.ClientFactory( self.session.blob_manager, self.lbry_file_manager.stream_info_manager, stream_hash @@ -1378,7 +1378,7 @@ class LBRYDaemon(jsonrpc.JSONRPC): reflector_server = random.choice(REFLECTOR_SERVERS) reflector_address, reflector_port = reflector_server[0], reflector_server[1] log.info("Start reflector client") - factory = reflector.LBRYBlobReflectorClientFactory( + factory = reflector.BlobClientFactory( self.session.blob_manager, blob_hashes ) diff --git a/lbrynet/lbrynet_daemon/LBRYPublisher.py b/lbrynet/lbrynet_daemon/LBRYPublisher.py index b69df8176..ec7b908dc 100644 --- a/lbrynet/lbrynet_daemon/LBRYPublisher.py +++ b/lbrynet/lbrynet_daemon/LBRYPublisher.py @@ -78,7 +78,7 @@ class Publisher(object): reflector_server = random.choice(REFLECTOR_SERVERS) reflector_address, reflector_port = reflector_server[0], reflector_server[1] log.info("Reflecting new publication") - factory = reflector.LBRYFileReflectorClientFactory( + factory = reflector.ClientFactory( self.session.blob_manager, self.lbry_file_manager.stream_info_manager, self.stream_hash diff --git a/lbrynet/reflector/__init__.py b/lbrynet/reflector/__init__.py index 32291c0b0..d810cb10a 100644 --- a/lbrynet/reflector/__init__.py +++ b/lbrynet/reflector/__init__.py @@ -1,2 +1,3 @@ from lbrynet.reflector.server.server import ReflectorServerFactory as ServerFactory -from lbrynet.reflector.client.client import LBRYFileReflectorClientFactory, LBRYBlobReflectorClientFactory +from lbrynet.reflector.client.client import LBRYFileReflectorClientFactory as ClientFactory +from lbrynet.reflector.client.client import LBRYBlobReflectorClientFactory as BlobClientFactory