move wormhole.twisted.transit up to wormhole.transit
This commit is contained in:
parent
4b3d53ba4e
commit
0e1a4dd513
|
@ -4,7 +4,7 @@ from tqdm import tqdm
|
||||||
from twisted.internet import reactor
|
from twisted.internet import reactor
|
||||||
from twisted.internet.defer import inlineCallbacks, returnValue
|
from twisted.internet.defer import inlineCallbacks, returnValue
|
||||||
from ..wormhole import wormhole
|
from ..wormhole import wormhole
|
||||||
from ..twisted.transit import TransitReceiver
|
from ..transit import TransitReceiver
|
||||||
from ..errors import TransferError
|
from ..errors import TransferError
|
||||||
|
|
||||||
APPID = u"lothar.com/wormhole/text-or-file-xfer"
|
APPID = u"lothar.com/wormhole/text-or-file-xfer"
|
||||||
|
|
|
@ -6,7 +6,7 @@ from twisted.internet import reactor
|
||||||
from twisted.internet.defer import inlineCallbacks, returnValue
|
from twisted.internet.defer import inlineCallbacks, returnValue
|
||||||
from ..errors import TransferError
|
from ..errors import TransferError
|
||||||
from ..wormhole import wormhole
|
from ..wormhole import wormhole
|
||||||
from ..twisted.transit import TransitSender
|
from ..transit import TransitSender
|
||||||
|
|
||||||
APPID = u"lothar.com/wormhole/text-or-file-xfer"
|
APPID = u"lothar.com/wormhole/text-or-file-xfer"
|
||||||
|
|
||||||
|
|
|
@ -1,7 +1,7 @@
|
||||||
from twisted.application import service
|
from twisted.application import service
|
||||||
from twisted.internet import reactor, defer
|
from twisted.internet import reactor, defer
|
||||||
from twisted.python import log
|
from twisted.python import log
|
||||||
from ..twisted.transit import allocate_tcp_port
|
from ..transit import allocate_tcp_port
|
||||||
from ..server.server import RelayServer
|
from ..server.server import RelayServer
|
||||||
from .. import __version__
|
from .. import __version__
|
||||||
|
|
||||||
|
|
|
@ -6,7 +6,7 @@ from twisted.internet import defer, task, endpoints, protocol, address, error
|
||||||
from twisted.internet.defer import gatherResults, inlineCallbacks
|
from twisted.internet.defer import gatherResults, inlineCallbacks
|
||||||
from twisted.python import log, failure
|
from twisted.python import log, failure
|
||||||
from twisted.test import proto_helpers
|
from twisted.test import proto_helpers
|
||||||
from ..twisted import transit
|
from .. import transit
|
||||||
from ..errors import UsageError
|
from ..errors import UsageError
|
||||||
from nacl.secret import SecretBox
|
from nacl.secret import SecretBox
|
||||||
from nacl.exceptions import CryptoError
|
from nacl.exceptions import CryptoError
|
||||||
|
|
|
@ -1,4 +1,4 @@
|
||||||
from __future__ import print_function
|
from __future__ import print_function, absolute_import
|
||||||
import re, sys, time, socket, collections
|
import re, sys, time, socket, collections
|
||||||
from binascii import hexlify, unhexlify
|
from binascii import hexlify, unhexlify
|
||||||
from zope.interface import implementer
|
from zope.interface import implementer
|
||||||
|
@ -9,9 +9,9 @@ from twisted.internet.defer import inlineCallbacks, returnValue
|
||||||
from twisted.protocols import policies
|
from twisted.protocols import policies
|
||||||
from nacl.secret import SecretBox
|
from nacl.secret import SecretBox
|
||||||
from hkdf import Hkdf
|
from hkdf import Hkdf
|
||||||
from ..errors import UsageError
|
from .errors import UsageError
|
||||||
from ..timing import DebugTiming
|
from .timing import DebugTiming
|
||||||
from . import ipaddrs
|
from .twisted import ipaddrs
|
||||||
|
|
||||||
def HKDF(skm, outlen, salt=None, CTXinfo=b""):
|
def HKDF(skm, outlen, salt=None, CTXinfo=b""):
|
||||||
return Hkdf(salt, skm).expand(CTXinfo, outlen)
|
return Hkdf(salt, skm).expand(CTXinfo, outlen)
|
|
@ -5,7 +5,7 @@ from twisted.internet.error import ConnectError
|
||||||
import txtorcon
|
import txtorcon
|
||||||
import ipaddr
|
import ipaddr
|
||||||
from ..timing import DebugTiming
|
from ..timing import DebugTiming
|
||||||
from .transit import allocate_tcp_port
|
from ..transit import allocate_tcp_port
|
||||||
|
|
||||||
class TorManager:
|
class TorManager:
|
||||||
def __init__(self, reactor, tor_socks_port=None, tor_control_port=9051,
|
def __init__(self, reactor, tor_socks_port=None, tor_control_port=9051,
|
||||||
|
|
Loading…
Reference in New Issue
Block a user