h JSrSSKJr SSKrSSKJr SSKJ r J r SSK J r J r SSKJrJr SSKJr SS KJrJr SS KJrJr SS KJr "S S 5r\ "\ R85"SS55r\ "\ R<\ R>\ R@5"SS55r!Sr"Sr#"SS5r$SSjr%\"\#SSS4Sjr&Sr'"SS5r(SSjr)g!\a Nf=f) z0 Utilities and helpers for simulating a network ) annotationsN)Error)directlyProvides implementer)error interfaces)TCP4ClientEndpointTCP4ServerEndpoint)ConnectionRefusedError)FactoryProtocol) MemoryReactorMemoryReactorClock)Failurec*\rSrSrSrSSjrSrSrg)TLSNegotiationc6XlX lSUlX lg)NF)obj connectStatesent readyToSend)selfrrs Y/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/test/iosim.py__init__TLSNegotiation.__init__s( 'c$SUR<S3$)NzTLSNegotiation())rrs r__repr__TLSNegotiation.__repr__"s  A..rcURRUR5(d [5UlUR 5 ggN)r iosimVerifyNativeOpenSSLErrordisconnectReasonloseConnection)rothertpts rpretendToVerifyTLSNegotiation.pretendToVerify%s9xx##EII..#5#7C    /r)rrrrNreturnstr)__name__ __module__ __qualname____firstlineno__rr!r+__static_attributes__rrrrs( /!rrc\rSrSrSrSrg) FakeAddress.zQ The default address type for the host and peer of L{FakeTransport} connections. r5N)r0r1r2r3__doc__r4r5rrr7r7.srr7c,\rSrSrSr\"\R"54Sj5rSr Sr Sr \ R"S5rSrSrSrS!SjrS"SjrS rS rS rS rS rSrSrSrSrSrSrSrSr Sr!Sr"S#Sjr#Sr$Sr%Sr&Sr'Sr(Sr)Sr*S r+g)$ FakeTransport6z A wrapper around a file-like object to make it behave as a Transport. This doesn't actually stream the file to the attached protocol, and is thus useful mainly as a utility for debugging protocols. c*[[U55$r$)intnext)counters rFakeTransport.?s T']ASrrzConnection doneNcXlX l/UlUR5UlUc [ 5nX0lUc [ 5nX@lg)at @param protocol: This transport will deliver bytes to this protocol. @type protocol: L{IProtocol} provider @param isServer: C{True} if this is the accepting side of the connection, C{False} if it is the connecting side. @type isServer: L{bool} @param hostAddress: The value to return from C{getHost}. L{None} results in a new L{FakeAddress} being created to use as the value. @type hostAddress: L{IAddress} provider or L{None} @param peerAddress: The value to return from C{getPeer}. L{None} results in a new L{FakeAddress} being created to use as the value. @type peerAddress: L{IAddress} provider or L{None} N)protocolisServerstream _nextserialserialr7 hostAddress peerAddress)rrDrErIrJs rrFakeTransport.__init__HsK"!   &&(  %-K&  %-K&rcSRUR=(a S=(d SURURRR 5$)NzFakeTransport<{},{},{}>SC)formatrErHrD __class__r0r s rr!FakeTransport.__repr__ds@(// MM !c (S KK MM # # , ,  rcUR(agURbURRU5 gURRU5 gr$) disconnectingtlstlsbufappendrF)rdatas rwriteFakeTransport.writeks<     88  KK  t $ KK  t $rcUR(a-UR(dURR5 gggr$producerstreamingProducerresumeProducingr s r_checkProducerFakeTransport._checkProducerus* ==!7!7 MM ) ) +"8=rcLXlX lU(dUR5 gg)z From abstract.FileDescriptor Nr[)rr\ streamings rregisterProducerFakeTransport.registerProducer{s#! !*  $ $ &rcSUlgr$)r\r s runregisterProducer FakeTransport.unregisterProducers  rcDUR5 UR5 gr$)rfr(r s r stopConsumingFakeTransport.stopConsumings ! rcDURSRU55 g)Nr)rXjoin)riovecs r writeSequenceFakeTransport.writeSequences 388E?#rcSUlgNTrSr s rr(FakeTransport.loseConnections !rcSUlg)zX For the time being, this is the same as loseConnection; no buffered data will be lost. TNrrr s rabortConnectionFakeTransport.abortConnections "rcURb [5nO URnURR [ U55 gr$)rTr&r'rDconnectionLostr)rerrs rreportDisconnectFakeTransport.reportDisconnects7 88 %&C''C $$WS\2rcg)z= Identify this transport/event source to the logging system. iosimr5r s r logPrefixFakeTransport.logPrefixsrcUR$r$)rJr s rgetPeerFakeTransport.getPeerrcUR$r$)rIr s rgetHostFakeTransport.getHostrrcgr$r5r s rr^FakeTransport.resumeProducing rcgr$r5r s rpauseProducingFakeTransport.pauseProducingrrc$UR5 gr$)r(r s r stopProducingFakeTransport.stopProducings rcPURU- n[X5Ul/Ulgr$)rErrTrU)rcontextFactorybeNormalrs rstartTLSFakeTransport.startTLSs%}}x/ !.? rcURnU(a/UlSRU5$URb9URR(aSURlUR$gg)z Get the pending writes from this transport, clearing them from the pending buffer. @return: the bytes written with C{transport.write} @rtype: L{bytes} rNT)rFrlrTrr)rrMs r getOutBufferFakeTransport.getOutBuffersV KK DK88A;  XX !xx## $ xxrc[U[5(aURceURR(aaURR X5 SUlUR Sso lUR U5 [U[R5 gSURl gURRU5 grq) isinstancerrTrr+rUrnrr ISSLTransportrrD dataReceived)rbufbs rbufferReceivedFakeTransport.bufferReceiveds c> * *88' ''xx}}((3"&d;""1% z'?'?@(,$ MM & &s +rcgr$r5r s rgetTcpKeepAliveFakeTransport.getTcpKeepAliverrcgr$r5r s r getTcpNoDelayFakeTransport.getTcpNoDelayrrcgr$r5r s rloseWriteConnection!FakeTransport.loseWriteConnectionrrcgr$r5renableds rsetTcpKeepAliveFakeTransport.setTcpKeepAliverrcgr$r5rs r setTcpNoDelayFakeTransport.setTcpNoDelayrr) rSrIrErJr\rDrHrFr]rTrU)NNr-)T),r0r1r2r3r9 staticmethod itertoolscountrGclosedrS disconnectedrConnectionDoner'r\r]rTrr!rXr_rcrfrirnr(rurzr~rrr^rrrrrrrrrrr4r5rrr;r;6sioo.?STK FML++,=>H C'8 %, '$""3     ,,&     rr;c[USS9$)z Create and return a new in-memory transport hooked up to the given protocol. @param clientProtocol: The client protocol to use. @type clientProtocol: L{IProtocol} provider @return: The transport. @rtype: L{FakeTransport} FrEr;)clientProtocols rmakeFakeClientrs % 88rc[USS9$)z Create and return a new in-memory transport hooked up to the given protocol. @param serverProtocol: The server protocol to use. @type serverProtocol: L{IProtocol} provider @return: The transport. @rtype: L{FakeTransport} Trr)serverProtocols rmakeFakeServerr s $ 77rc6\rSrSrSrSSjrS SjrS SjrSrg) IOPumpiz Utility to pump data between clients and servers for protocol testing. Perhaps this is a utility worthy of being in protocol.py? NcfXlX lX0lX@lXPlUc [ 5nX`lgr$)clientserverclientIOserverIOdebugrclock)rrrrrrrs rrIOPump.__init__s-     =&(E rcnSn[S5HnURX5(aSnM U$ S5e)zS Pump until there is no more input or output. Returns whether any data was moved. FiTzToo long)rangepump)rr advanceClockresult_s rflush IOPump.flush)sA tAyy--  !j 1rcU(aURRS5 UR(dU(a [S5 URR 5nUR R 5nUR R5 URR5 UR(dU(aG[S5 U(a[S[U5-5 U(a[S[U5-5 U(aURRU5 U(aUR RU5 U(dU(agURR(a{URR(d`UR(dU(a [S5 SURl SUR l UR R5 gUR R(a{UR R(d`UR(dU(a [S5 SUR l SURl URR5 gg ) z Move data back and forth, while also triggering any currently pending scheduled calls (i.e. C{callLater(0, f)}). Returns whether any data was moved. rz -- GLUG --.zC: zS: Tz* Cz* SF) radvancerprintrrrr_reprrrSrrz)rrrsDatacDatas rr IOPump.pump9s  JJ  q ! :: ,  **, **, $$& $$& :: #Jed5k)*ed5k)*  MM ( ( /  MM ( ( / E == & &t}}/I/IzzUe )-DMM &*.DMM ' MM * * , == & &t}}/I/IzzUe )-DMM &*.DMM ' MM * * ,r)rrrrrrr$FT) r0r1r2r3r9rrrr4r5rrrrs  *rrFTc URU5 URU5 [UUUUUUS9nU(aUR5 U$)as Create a new L{IOPump} connecting two protocols. @param serverProtocol: The protocol to use on the accepting side of the connection. @type serverProtocol: L{IProtocol} provider @param serverTransport: The transport to associate with C{serverProtocol}. @type serverTransport: L{FakeTransport} @param clientProtocol: The protocol to use on the initiating side of the connection. @type clientProtocol: L{IProtocol} provider @param clientTransport: The transport to associate with C{clientProtocol}. @type clientTransport: L{FakeTransport} @param debug: A flag indicating whether to log information about what the L{IOPump} is doing. @type debug: L{bool} @param greet: Should the L{IOPump} be L{flushed } once before returning to put the protocols into their post-handshake or post-server-greeting state? @type greet: L{bool} @param clock: An optional L{Clock}. Pumping the resulting L{IOPump} will also increase clock time by a small increment. @return: An L{IOPump} which connects C{serverProtocol} and C{clientProtocol} and delivers bytes between them when it is pumped. @rtype: L{IOPump} r)makeConnectionrr)rserverTransportrclientTransportrgreetrrs rconnectrfsPT!!/2!!/2    D  Krc ZU"5nU"5nU"U5n U"U5n Xx[XXyXEUS94$)a Connect a given server and client class to each other. @param ServerClass: a callable that produces the server-side protocol. @type ServerClass: 0-argument callable returning L{IProtocol} provider. @param ClientClass: like C{ServerClass} but for the other side of the connection. @type ClientClass: 0-argument callable returning L{IProtocol} provider. @param clientTransportFactory: a callable that produces the transport which will be attached to the protocol returned from C{ClientClass}. @type clientTransportFactory: callable taking (L{IProtocol}) and returning L{FakeTransport} @param serverTransportFactory: a callable that produces the transport which will be attached to the protocol returned from C{ServerClass}. @type serverTransportFactory: callable taking (L{IProtocol}) and returning L{FakeTransport} @param debug: Should this dump an escaped version of all traffic on this connection to stdout for inspection? @type debug: L{bool} @param greet: Should the L{IOPump} be L{flushed } once before returning to put the protocols into their post-handshake or post-server-greeting state? @type greet: L{bool} @param clock: An optional L{Clock}. Pumping the resulting L{IOPump} will also increase clock time by a small increment. @return: the client protocol, the server protocol, and an L{IOPump} which, when its C{pump} and C{flush} methods are called, will move data between the created client and server protocol instances. @rtype: 3-L{tuple} of L{IProtocol}, L{IProtocol}, L{IOPump} r)r) ServerClass ClientClassclientTransportFactoryserverTransportFactoryrrrcsciosios rconnectedServerAndClientrs=\  A A  #C  #C UC CCrc.UunnnnnUupxpXs:XaXH4$g)a Should the client and server described by the arguments be connected to each other, i.e. do their port numbers match? @param clientInfo: the args for connectTCP @type clientInfo: L{tuple} @param serverInfo: the args for listenTCP @type serverInfo: L{tuple} @return: If they do match, return factories for the client and server that should connect; otherwise return L{None}, indicating they shouldn't be connected. @rtype: L{None} or 2-L{tuple} of (L{ClientFactory}, L{IProtocolFactory}) Nr5) clientInfo serverInfo clientHost clientPort clientFactory clientTimeoutclientBindAddress serverPort serverFactory serverBacklogserverInterfaces r_factoriesShouldConnectrs7.  BL?Z ++rcV\rSrSrSrSSjrS S Sjjr\"\"554S Sjjr Sr g) ConnectionCompleteriz A L{ConnectionCompleter} can cause synthetic TCP connections established by L{MemoryReactor.connectTCP} and L{MemoryReactor.listenTCP} to succeed or fail. cXlg)zk Create a L{ConnectionCompleter} from a L{MemoryReactor}. @param memoryReactor: The reactor to attach to. N_reactor)r memoryReactors rrConnectionCompleter.__init__s & rc URn[UR5HupEURHn[ XV5nU(dMURR U5 UR RU5 UupURS5n U RS5n [U 5n [U 5n [U U U U UUS9nUs s $ M g)a Complete a single TCP connection established on this L{ConnectionCompleter}'s L{MemoryReactor}. @param debug: A flag; whether to dump output from the established connection to stdout. @return: a pump for the connection, or L{None} if no connection could be established. N)r) r enumerate tcpClients tcpServersrremove connectorspop buildProtocolrrr)rrrr clientIdxrr factoriesrrrrrrrs r succeedOnceConnectionCompleter.succeedOnces %.}/G/G%H !I+66 3JK 9!,,33J?!,,00;3<0M%2%@%@%FN%2%@%@%FN&4^&DO&4^&DO%,&'&'# &F"M%7&I(rcURRRS5SRURRRS5U5 g)z Fail a single TCP connection established on this L{ConnectionCompleter}'s L{MemoryReactor}. @param reason: the reason to provide that the connection failed. rN)rrrclientConnectionFailedr)rreasons rfailOnceConnectionCompleter.failOnce%sF   $$Q'*AA MM $ $ ( ( +V rrN)rrr.Noner)rboolrrr.z IOPump | None)rrr.r) r0r1r2r3r9rr rr rr4r5rrrrs* & D*11G1I)J   rrc[5n[USS5n[US5nUR[R "[ 55 U[U54$)ae Create an endpoint that can be fired on demand. @param debug: A flag; whether to dump output from the established connection to stdout. @type debug: L{bool} @return: A client endpoint, and an object that will cause one of the L{Deferred}s returned by that client endpoint. @rtype: 2-L{tuple} of (L{IStreamClientEndpoint}, L{ConnectionCompleter}) z0.0.0.0i)rr r listenr forProtocolr r)rreactorclientEndpointserverEndpoints rconnectableEndpointr1sP!"G'DAN'6N'--h78 .w7 77r)FTN)F)*r9 __future__rr OpenSSL.SSLrr& ImportErrorzope.interfacerrtwisted.internetrrtwisted.internet.endpointsr r twisted.internet.errorr twisted.internet.protocolr r twisted.internet.testingrrtwisted.python.failurerrIAddressr7 ITransport ITLSTransport IConsumerr;rrrrrrrrr5rrr(s # 79.M97F*!!& Z !" Z " "J$<$R>RSD D TD N 9 8KKf   7z*)   2Dj>: : z8G  sCC$#C$