8989
9090from bitdust .dht import dht_records
9191
92+ from bitdust .main import events
93+
9294from bitdust .p2p import lookup
9395
9496from bitdust .services import driver
@@ -420,6 +422,7 @@ def init(self):
420422 self .active_router_url = None
421423 self .handshaked_routers = []
422424 self .server_code = None
425+ self .device_name = None
423426
424427 def state_changed (self , oldstate , newstate , event , * args , ** kwargs ):
425428 """
@@ -438,6 +441,7 @@ def to_json(self, short=True):
438441 'url' : self .active_router_url ,
439442 'connected_routers' : self .handshaked_routers ,
440443 'server_code' : self .server_code ,
444+ 'device_name' : self .device_name ,
441445 })
442446 return ret
443447
@@ -759,6 +763,7 @@ def doGenerateServerCode(self, *args, **kwargs):
759763 self .server_code = BITDUST_WEB_SOCKET_SERVER_CODE_GENERATED .strip ()
760764 else :
761765 self .server_code = cipher .generate_digits (6 , as_text = True )
766+ events .send ('web-socket-handshake-started' , data = self .to_json ())
762767 if _Debug :
763768 lg .args (_DebugLevel , server_code = self .server_code )
764769
@@ -807,6 +812,7 @@ def doWaitClientCodeInput(self, *args, **kwargs):
807812 """
808813 Action method.
809814 """
815+ events .send ('web-socket-handshake-proceeding' , data = self .to_json ())
810816 BITDUST_WEB_SOCKET_CLIENT_CODE_INPUT = os .environ .get ('BITDUST_WEB_SOCKET_CLIENT_CODE_INPUT' , None )
811817 if BITDUST_WEB_SOCKET_CLIENT_CODE_INPUT :
812818 self .on_client_code_input_received (BITDUST_WEB_SOCKET_CLIENT_CODE_INPUT .strip ())
0 commit comments