i)ddlZddlmZddlmZddlmZmZmZddl m Z ddl m Z m Z ddlmZdd lmZGd d eZy) N)BaseHubConnection)AuthHubConnection)IntervalReconnectionHandlerRawReconnectionHandlerReconnectionType)Helpers)HttpTransportTypeHubProtocolEncoding)BaseHubProtocol)create_ssl_contextcXeZdZdZdZ ddedefdZ ddZdefd Z d Z d Z d efd Z y)HubConnectionBuilderzBuilder for SignalR hub connections using a fluent interface. Use :meth:`with_url` as the first call to configure url and connection options. Use :meth:`build` as the final call to obtain a ready-to-use connection. c4d|_ddi|_t|_d|_d|_d|_d|_d|_d|_ tj|_ d|_ d|_t|_t!j"|_y)Naccess_token_factoryF)hub_urloptionsdictheadershas_auth_configuredprotocolpreferred_protocolpreferred_transportreconnection_handlerkeep_alive_intervalsslcreate_default_context ssl_context enable_traceskip_negotiationproxiesr get_loggerloggerselfs [/home/work/apex_v16/venv/lib/python3.12/site-packages/signalrcore/hub_connection_builder.py__init__zHubConnectionBuilder.__init__s  #D  v #' )- "&#' $(!#% 557! %v ((* Nrrc||jdk(r td|5t|tur$t dj |j |d|jvxrt|d|_ d|jvxr|d|_ d|jvr;|jd}t|turt dt||_ d |jvrd |jvr td d |jvr>|jd d}t|tur t d t||_d |jvr?|jd d}t|t"j$ur t d ||_d|jvrI|jdd}t|tur t d|j&j)|d|jvr1|jdd}| t|s t d||_||_||j |_|S||_|S)aConfigure the hub url and options like negotiation and auth function def login(self): response = requests.post( self.login_url, json={ "username": self.email, "password": self.password },verify=False) return response.json()["token"] self.connection = HubConnectionBuilder() .with_url(self.server_url, options={ "verify_ssl": False, "access_token_factory": self.login, "headers": { "mycustomheader": "mycustomheadervalue" } }) .configure_logging(logging.ERROR) .with_automatic_reconnect({ "type": "raw", "keep_alive_interval": 10, "reconnect_interval": 5, "max_attempts": 5 }).build() Args: hub_url (string): Hub URL options ([dict], optional): [description]. Defaults to None. Raises: ValueError: If url is invalid TypeError: If options are not a dict or auth function is not callable Returns: [HubConnectionBuilder]: configured connection Nzhub_url must be a valid url.zoptions must be a dict {0}.rr! transportztransport types: verify_sslrzYYou must specify one of these two options, verify_ssl:bool or ssl_context: ssl.SSLContextzVerify ssl must be a boolz$ssl_context must be a ssl.SSLContextrz headers must be a Dict[str, str]z$access_token_factory is not function)strip ValueErrortyper TypeErrorformatrkeyscallablerr!getr rboolr rr SSLContextrupdate auth_functionr)r&rrr,valuer9s r'with_urlzHubConnectionBuilder.with_url+skX ?gmmo3;< <  4=#<-44T\\BD D  &',,.8>W%;<=  $%7',,.$H%0./  !glln,#KK 4  ?*;;#,->,?@BB+4(w||~-%7 EFFw||~- L$7;d*#$?@@#5e#<  . M48;cnn4#$JKK#( GLLN* It4;d*#$FGG ##E*%7 ' ,BD I  (' 6#>@@%2" '.t||  =D  r)c@tj||||_|S)aConfigures signalr logging Args: logging_level ([type]): logging.INFO | logging.DEBUG ... from python logging class socket_trace (bool, optional): Enables socket package trace. Defaults to False. handler ([type], optional): Custom logging handler. Defaults to None. Returns: [HubConnectionBuilder]: Instance hub with logging configured )r configure_loggerr )r& logging_level socket_tracehandlers r'configure_loggingz&HubConnectionBuilder.configure_loggings!   8( r)r"crd|jvsd|jvr td||_|S)a4configures proxies Args: proxies (dict): { "http" : "http://host:port", "https" : "https://host:port", "ftp" : "ftp://port:port" } Returns: [HubConnectionBuilder]: Instance hub with proxies configured httphttpsz$Only http and https keys are allowed)r3r/r")r&r"s r'configure_proxiesz&HubConnectionBuilder.configure_proxiess7  '7',,.+HCD D  r)ctt|tr ||_|St|tur ||_|St dt|)anChanges transport protocol from signalrcore.types import HubProtocolEncoding HubConnectionBuilder() .with_url(self.server_url, options={"verify_ssl":False}) ... .with_hub_protocol(HubProtocolEncoding.binary) ... .build() Args: protocol( MessagePackHubProtocol| JsonHubProtocol| HubProtocolEncoding): protocol instance or HubProtocolEncoding Returns: HubConnectionBuilder: instance configured zWrong protocol type ) issubclassr0r rr rr1)r&rs r'with_hub_protocolz&HubConnectionBuilder.with_hub_protocolsP* d8no 6$DMK >0 0&.D #K.tH~.>?@@r)c@|jrt|j|j|j|j |j |j|j|j|j|j|j|j St|j|j |j |j|j|j|j|j|j|j|j S)zrCreates the connection hub Returns: [BaseHubConnection]: [connection SignalR object] ) rr9urlrrrrrr"r!r r) rJrrrrrrr"r!r r)rrrr9rrrrrrr"r!r rrr%s r'buildzHubConnectionBuilder.builds&''! "00LL#'#:#:$($<$<%)%>%> ,, !%!6!6!..$($<$< > > LL#'#:#:$($<$<%)%>%>  ,, !%!6!6!..$($<$< > >r)datach|jdd}|jdd}|jdd}|jdd}|jd g}||_t|}|tjk(rt |||_|tj k(rt||_|S) aConfigures automatic reconnection https://devblogs.microsoft.com/aspnet/asp-net-core-updates-in-net-core-3-0-preview-4/ hub = HubConnectionBuilder() .with_url(self.server_url, options={"verify_ssl":False}) .configure_logging(logging.ERROR) .with_automatic_reconnect({ "type": "raw", "keep_alive_interval": 10, "reconnect_interval": 5, "max_attempts": 5 }) .build() Args: data (dict): [dict with automatic reconnection parameters] Returns: [HubConnectionBuilder]: [self object for fluent interface purposes] r0raw max_attemptsNreconnect_intervalrr intervals)r5rrrNrrintervalr)r&rLreconnect_typerOrPrrRreconnection_types r'with_automatic_reconnectz-HubConnectionBuilder.with_automatic_reconnects*&%0xx5 "XX&:A>"hh'")D %  0 9 9 9(C)D % r))N)FN) __name__ __module__ __qualname____doc__r(strrr;rArErHrKrVr)r'rr s\ +6!eeeP>B&,A>>B.T.r)r)rhub.base_hub_connectionrhub.auth_hub_connectionrtransport.reconnectionrrrhelpersr typesr r protocol.protocol_factoryr transport.sockets.utilsr objectrr\r)r'res4 66JJ967]6]r)