8'h:RddlmZmZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z  dZdd lmZdd lmZmZmZdd lmZdd lmZddlZddlZddlmZddlmZddlmZddl m!Z!ddl"m#Z#m$Z$dZ%dZ&dZ'dZ(dZ)GddejTZ*ddZ+y#e$rd ZYYwxYw))absolute_importprint_function)wraps)IStreamClientEndpoint)UNIXClientEndpoint)TCP4ClientEndpoint)Failure)ReactorNotRunningT)SSL4ClientEndpoint)optionsForClientTLSCertificateOptions Certificate)IOpenSSLClientConnectionCreator)SSLFN)WampWebSocketClientFactory)WampRawSocketClientFactory) component)Session)create_transport_serializerscreate_transport_serializer) Componentruncnt}|Dcgc]}||vs|j|r|c}Scc}w)zM Return a list with unique elements from sequence, preserving order. )setadd)seqseenxs V/var/www/html/trade_iq/venv/lib/python3.12/site-packages/autobahn/twisted/component.py _unique_listr ?s/ 5D @!atmDHHQKA @@ @s 222c|jd}|ddj|ddDcgc]}|jc}zScc}w)N_r)splitjoin capitalize)snakepartsss r_camel_case_from_snake_caser+GsB KK E 8bgguQRyA!q||~AB BBAsA c B|jdk(r/t|}t||j||j}n<|jdk(r&t |j d}t||}nJd|jjD]\}} |jdi||i|S#ttf$r[ |jdit||in9#ttf$r'tdj|j||wxYwYwxYw) z3 Create a WAMP-over-XXX transport factory. websocket)url serializersproxy rawsocketr) serializershould not arrive herez"Unknown {} transport option: {}={})typerrr.r0rr/roptionsitemssetProtocolOptions TypeErrorKeyErrorr+ ValueErrorformat)reactor transportsession_factoryr/factoryr2kvs r_create_transport_factoryrCLs8~~%29= ,  #//   < '01F1Fq1IJ ,_T 0//u!!'')1  &G & & 0!Q 0 N8$  ***215q9x(  8?? PQSTU  s*B44DC"!D"6DDDcztj|r t|}|S|ddk(r|jdd}|dvrtdj ||d}t |t jk7r#tdj t ||d }t |t jvr#td j t ||jd d }t |t jvr#td j t ||jdd}|rts tdtj|r t|}n5t|tr|jD] } | dvstdj | |jd|} t | t jk7rtdj | d} |jdd} | @tj t j"t%| dj'} t)| | }nFt|t*r|}n3|dur t)|}n#tdj t ||dk(rt-|||||}|S|dk(r tdJd|j/dr ddl} | j3||}|S|dk(rt7||||}|S|dk(r dd!lm}|||||}|SJd|dd#k(r0|d$}t=|jd d }t?|||}|SJd#t4$rtd j |wxYw#t4$r td"wxYw)%zI Create a Twisted client endpoint for a WAMP-over-XXX transport. r5tcpversion)rGz6invalid IP version {} in client endpoint configurationhostz9invalid type {} for host in client endpoint configurationportz9invalid type {} for port in client endpoint configurationtimeout zG)'4IH O 43 351'*ahh $']*+[\\]s0M>$N%>$N"%N:cReZdZdZej ZeZ dZ dZ dZ ddZ y)rz A component establishes a transport and attached a session to a realm using the transport for communication. The transports a component tries to use can be configured, as well as the auto-reconnect strategy. cDtrt|tjSy)z Internal helper. This is so we can just return False if we didn't import any TLS/SSL libraries. Otherwise, returns True if this is an OpenSSL.SSL.Error F)rZr\rError)selfes r _is_ssl_errorzComponent._is_ssl_errors a+ +c tj|ryt|trSd|vrN|d}t|ttfryt j|ryt|t rytdytd)NrMzb'tls' configuration must be a dict, CertificateOptions or IOpenSSLClientConnectionCreator providerzI'endpoint' configuration must be a dict or IStreamClientEndpoint provider)rrUr\r]boolrr r;)rqrjrMs r_check_native_endpointz Component._check_native_endpoints + +H 5  $ '!v&cD$<04??D%78$D" rtcRt||}jr+t|djdjdd}nt|j}|j |}fd}fd} t j ||dt j |d| |S)z Create and connect a WAMP-over-XXX transport. :param done: is a Deferred/Future from the parent which we should signal upon error if it is not done yet (XXX maybe an "on_error" callable instead?) rErIrJ)r5rIrJcV|jtfd}||_y)Ncn|}tjstj||SN)txaio is_calledreject)failrtndoneorigs rlostzFComponent._connect_transport..on_connect_success..lost/s+4jt,LLt, rt)connectionLostr)protorrrs @ron_connect_successz8Component._connect_transport..on_connect_success%s0''D 4[   $(E rtc\xjdz c_tj|y)Nr$)connect_failuresr|r~)errrr>s ron_connect_failurez8Component._connect_transport..on_connect_failure7s"  & &! + & LLs #rtN)rCr0rmrjconnectr| add_callbacks) rqr=r>r?rtransport_factorytransport_endpointdrrs ` ` r_connect_transportzComponent._connect_transports6gy/Z ??!;!%OOF3%OOF3" ".done_callbackts> c7 # II;SI I  LLN    s7 AA)twisted.internet.taskrr| start_loggingrr_run) components log_levelrrrs @rrrTsF,,  ),    C )..:}56rt)info), __future__rr functoolsrtwisted.internet.interfacesrrgrrtwisted.python.failurer twisted.internet.errorr rZr twisted.internet.sslr r rrOpenSSLrrfrWr|autobahn.twisted.websocketrautobahn.twisted.rawsocketr autobahn.wamprautobahn.twisted.wamprautobahn.wamp.serializerrr__all__r r+rCrmrrr4rtrrs87=99*4 D=YYK  AA#)^ AC $NfRu) ##u)p(7Q  DsBB&%B&