forked from LBRYCommunity/lbry-sdk
updated all references to point to new reflector location
This commit is contained in:
parent
fe2476b5aa
commit
f1f0917063
9 changed files with 13 additions and 14 deletions
|
@ -28,7 +28,7 @@ from lbrynet.dht import node, hashannouncer
|
||||||
from lbrynet.file_manager.EncryptedFileManager import EncryptedFileManager
|
from lbrynet.file_manager.EncryptedFileManager import EncryptedFileManager
|
||||||
from lbrynet.lbry_file.client.EncryptedFileDownloader import EncryptedFileSaverFactory
|
from lbrynet.lbry_file.client.EncryptedFileDownloader import EncryptedFileSaverFactory
|
||||||
from lbrynet.lbry_file.client.EncryptedFileOptions import add_lbry_file_to_sd_identifier
|
from lbrynet.lbry_file.client.EncryptedFileOptions import add_lbry_file_to_sd_identifier
|
||||||
from lbrynet.reflector import ServerFactory as reflector_server_factory
|
from lbrynet.extras.reflector import ServerFactory as reflector_server_factory
|
||||||
|
|
||||||
from lbrynet.core.utils import generate_id
|
from lbrynet.core.utils import generate_id
|
||||||
|
|
||||||
|
|
|
@ -27,7 +27,7 @@ from lbrynet.schema.decode import smart_decode
|
||||||
# TODO: importing this when internet is disabled raises a socket.gaierror
|
# TODO: importing this when internet is disabled raises a socket.gaierror
|
||||||
from lbrynet.core.system_info import get_lbrynet_version
|
from lbrynet.core.system_info import get_lbrynet_version
|
||||||
from lbrynet import conf
|
from lbrynet import conf
|
||||||
from lbrynet.reflector import reupload
|
from lbrynet.extras.reflector import reupload
|
||||||
from lbrynet.daemon.Components import d2f, f2d
|
from lbrynet.daemon.Components import d2f, f2d
|
||||||
from lbrynet.daemon.Components import WALLET_COMPONENT, DATABASE_COMPONENT, DHT_COMPONENT, BLOB_COMPONENT
|
from lbrynet.daemon.Components import WALLET_COMPONENT, DATABASE_COMPONENT, DHT_COMPONENT, BLOB_COMPONENT
|
||||||
from lbrynet.daemon.Components import STREAM_IDENTIFIER_COMPONENT, FILE_MANAGER_COMPONENT, RATE_LIMITER_COMPONENT
|
from lbrynet.daemon.Components import STREAM_IDENTIFIER_COMPONENT, FILE_MANAGER_COMPONENT, RATE_LIMITER_COMPONENT
|
||||||
|
|
|
@ -63,7 +63,6 @@ If the transfer was not successful (False), the blob is re-added to the needed_b
|
||||||
Blob requests continue for each of the blobs the client has queued to send, when completed
|
Blob requests continue for each of the blobs the client has queued to send, when completed
|
||||||
the client disconnects.
|
the client disconnects.
|
||||||
"""
|
"""
|
||||||
|
from .server.server import ReflectorServerFactory as ServerFactory
|
||||||
from lbrynet.reflector.server.server import ReflectorServerFactory as ServerFactory
|
from .client.client import EncryptedFileReflectorClientFactory as ClientFactory
|
||||||
from lbrynet.reflector.client.client import EncryptedFileReflectorClientFactory as ClientFactory
|
from .client.blob import BlobReflectorClientFactory as BlobClientFactory
|
||||||
from lbrynet.reflector.client.blob import BlobReflectorClientFactory as BlobClientFactory
|
|
||||||
|
|
|
@ -5,7 +5,7 @@ from twisted.protocols.basic import FileSender
|
||||||
from twisted.internet.protocol import Protocol, ClientFactory
|
from twisted.internet.protocol import Protocol, ClientFactory
|
||||||
from twisted.internet import defer, error
|
from twisted.internet import defer, error
|
||||||
|
|
||||||
from lbrynet.reflector.common import IncompleteResponse, REFLECTOR_V2
|
from lbrynet.extras.reflector.common import IncompleteResponse, REFLECTOR_V2
|
||||||
|
|
||||||
|
|
||||||
log = logging.getLogger(__name__)
|
log = logging.getLogger(__name__)
|
||||||
|
|
|
@ -6,8 +6,8 @@ from twisted.protocols.basic import FileSender
|
||||||
from twisted.internet.protocol import Protocol, ClientFactory
|
from twisted.internet.protocol import Protocol, ClientFactory
|
||||||
from twisted.internet import defer, error
|
from twisted.internet import defer, error
|
||||||
|
|
||||||
from lbrynet.reflector.common import IncompleteResponse, ReflectorRequestError
|
from lbrynet.extras.reflector.common import IncompleteResponse, ReflectorRequestError
|
||||||
from lbrynet.reflector.common import REFLECTOR_V1, REFLECTOR_V2
|
from lbrynet.extras.reflector.common import REFLECTOR_V1, REFLECTOR_V2
|
||||||
|
|
||||||
log = logging.getLogger(__name__)
|
log = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
|
|
@ -2,7 +2,7 @@ import random
|
||||||
|
|
||||||
from twisted.internet import reactor, defer
|
from twisted.internet import reactor, defer
|
||||||
from lbrynet import conf
|
from lbrynet import conf
|
||||||
from lbrynet.reflector import ClientFactory, BlobClientFactory
|
from . import ClientFactory, BlobClientFactory
|
||||||
|
|
||||||
|
|
||||||
def _is_ip(host):
|
def _is_ip(host):
|
||||||
|
|
|
@ -7,8 +7,8 @@ from lbrynet.core.utils import is_valid_blobhash
|
||||||
from lbrynet.core.Error import DownloadCanceledError, InvalidBlobHashError
|
from lbrynet.core.Error import DownloadCanceledError, InvalidBlobHashError
|
||||||
from lbrynet.core.StreamDescriptor import BlobStreamDescriptorReader
|
from lbrynet.core.StreamDescriptor import BlobStreamDescriptorReader
|
||||||
from lbrynet.core.StreamDescriptor import save_sd_info
|
from lbrynet.core.StreamDescriptor import save_sd_info
|
||||||
from lbrynet.reflector.common import REFLECTOR_V1, REFLECTOR_V2
|
from lbrynet.extras.reflector.common import REFLECTOR_V1, REFLECTOR_V2
|
||||||
from lbrynet.reflector.common import ReflectorRequestError, ReflectorClientVersionError
|
from lbrynet.extras.reflector.common import ReflectorRequestError, ReflectorClientVersionError
|
||||||
|
|
||||||
|
|
||||||
log = logging.getLogger(__name__)
|
log = logging.getLogger(__name__)
|
||||||
|
|
|
@ -7,7 +7,7 @@ from binascii import hexlify, unhexlify
|
||||||
|
|
||||||
from twisted.internet import defer, task, reactor
|
from twisted.internet import defer, task, reactor
|
||||||
from twisted.python.failure import Failure
|
from twisted.python.failure import Failure
|
||||||
from lbrynet.reflector.reupload import reflect_file
|
from lbrynet.extras.reflector.reupload import reflect_file
|
||||||
from lbrynet.file_manager.EncryptedFileDownloader import ManagedEncryptedFileDownloader
|
from lbrynet.file_manager.EncryptedFileDownloader import ManagedEncryptedFileDownloader
|
||||||
from lbrynet.file_manager.EncryptedFileDownloader import ManagedEncryptedFileDownloaderFactory
|
from lbrynet.file_manager.EncryptedFileDownloader import ManagedEncryptedFileDownloaderFactory
|
||||||
from lbrynet.core.StreamDescriptor import EncryptedFileStreamType, get_sd_info
|
from lbrynet.core.StreamDescriptor import EncryptedFileStreamType, get_sd_info
|
||||||
|
|
|
@ -4,7 +4,7 @@ from binascii import hexlify
|
||||||
from twisted.internet import defer, error
|
from twisted.internet import defer, error
|
||||||
from twisted.trial import unittest
|
from twisted.trial import unittest
|
||||||
from lbrynet.core.StreamDescriptor import get_sd_info
|
from lbrynet.core.StreamDescriptor import get_sd_info
|
||||||
from lbrynet import reflector
|
from lbrynet.extras import reflector
|
||||||
from lbrynet.core import BlobManager, PeerManager
|
from lbrynet.core import BlobManager, PeerManager
|
||||||
from lbrynet.core import StreamDescriptor
|
from lbrynet.core import StreamDescriptor
|
||||||
from lbrynet.file_manager import EncryptedFileCreator
|
from lbrynet.file_manager import EncryptedFileCreator
|
||||||
|
|
Loading…
Reference in a new issue