Allow direct use of the gatekeeper object (or whatever is actually directly exposed)
This commit is contained in:
parent
6f6993ce4c
commit
f2b8b433cc
|
@ -265,11 +265,14 @@ class TunnelRelay:
|
||||||
return transport.connection_from_str(conn_str, **kwargs)
|
return transport.connection_from_str(conn_str, **kwargs)
|
||||||
|
|
||||||
# decorator
|
# decorator
|
||||||
def connect(conn_str, cap, **kwargs):
|
def connect(conn_str, cap = None, **kwargs):
|
||||||
def prepare_resolution_handler(handler):
|
def prepare_resolution_handler(handler):
|
||||||
@During().add_handler
|
@During().add_handler
|
||||||
def handle_gatekeeper(gk):
|
def handle_gatekeeper(gk):
|
||||||
gatekeeper.resolve(gk.embeddedValue, cap)(handler)
|
if cap is None:
|
||||||
|
handler(gk.embeddedValue)
|
||||||
|
else:
|
||||||
|
gatekeeper.resolve(gk.embeddedValue, cap)(handler)
|
||||||
return transport.connection_from_str(
|
return transport.connection_from_str(
|
||||||
conn_str,
|
conn_str,
|
||||||
gatekeeper_peer = turn.ref(handle_gatekeeper),
|
gatekeeper_peer = turn.ref(handle_gatekeeper),
|
||||||
|
|
Loading…
Reference in New Issue