hRSrSSKrSSKJr SSKJr SSKJrJrJ r J r SSK J r J r Jr SSKJr SSKJrJr SSKJr SS KJrJrJr S rS rS r"S S\ 5r"SS5r"SS\R>5r "SS\ 5r!Sr""SS\RF5r$Sr%"SS\RL5r'"SS5r(/SQr)g)z A generic resource for publishing objects via XML-RPC. Maintainer: Itamar Shtull-Trauring @var Fault: See L{xmlrpclib.Fault} @type Fault: L{xmlrpclib.Fault} N)urlparse)BinaryBooleanDateTimeFault)defererrorprotocol)Logger)failurereflect) nativeString)httpresourceserverABcSUlU$)a4 Decorator to cause the request to be passed as the first argument to the method. If an I{xmlrpc_} method is wrapped with C{withRequest}, the request object is passed as the first argument to that method. For example:: @withRequest def xmlrpc_echo(self, request, s): return s @since: 10.2 T) withRequest)fs Y/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/web/xmlrpc.pyrr"sAM Hc\rSrSrSrSrg)NoSuchFunction5z) There is no function by the given name. N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rrrrr5srrc$\rSrSrSrSrSrSrg)Handler;a$ Handle a XML-RPC request and store the state for a request in progress. Override the run() method and return result using self.result, a Deferred. We require this class since we're not using threads, so we can't encapsulate state in a running function if we're going to have to wait for results. For example, lets say we want to authenticate against twisted.cred, run a LDAP query and then pass its result to a database query, all as a result of a single XML-RPC command. We'd use a Handler instance to store the state of the running command. cbXl[R"5UlUR"U6 gN)rrDeferredresultrun)selfrargss r__init__Handler.__init__Ls  nn&  $rcLURR[S55 g)NzImplement run() in subclasses)r)errbackNotImplementedError)r+r,s rr* Handler.runQs /0OPQr)rr)N)rrrr r!r-r*r"rrrr$r$;s  Rrr$c~\rSrSrSrSrSrSrSrSr \ "5r SSjr S r S rS rS rS rSSjrSrSrSrSrg)XMLRPCVa A resource that implements XML-RPC. You probably want to connect this to '/RPC2'. Methods published can return XML-RPC serializable results, Faults, Binary, Boolean, DateTime, Deferreds, or Handler instances. By default methods beginning with 'xmlrpc_' are published. Sub-handlers for prefixed methods (e.g., system.listMethods) can be added with putSubHandler. By default, prefixes are separated with a '.'. Override self.separator to change this. @ivar allowNone: Permit XML translating of Python constant None. @type allowNone: C{bool} @ivar useDateTime: Present C{datetime} values as C{datetime.datetime} objects? @type useDateTime: C{bool} rr.)POSTch[RRU5 0UlXlX lgr')rResourcer- subHandlers allowNone useDateTime)r+r<r=s rr-XMLRPC.__init__ws)""4("&rc X RU'gr')__dict__)r+namevalues r __setattr__XMLRPC.__setattr__}s# drc X RU'gr')r;)r+prefixhandlers r putSubHandlerXMLRPC.putSubHandlers#* rc:URRUS5$r')r;get)r+rFs r getSubHandlerXMLRPC.getSubHandlers##FD11rcH[URR55$r')listr;keysr+s rgetSubHandlerPrefixesXMLRPC.getSubHandlerPrefixessD$$))+,,rcjURRSS5 URSS5 [R"URR 5UR S9up#URU5n/nUR5RUR5 [USS5(a[R"XA/UQ76nO[R"U/UQ76nURUR5 URUR X5 [(R*$!["a*nUR!Xq5 SnA[(R*$SnAff=f![$aCn[#UR&SU35nUR!Xq5 SnA[(R*$SnAff=f)Nrs content-typetext/xml; charset=utf-8 use_datetimerFzCan't deserialize input: )contentseek setHeader xmlrpclibloadsreadr=lookupProcedure notifyFinish addErrbackappendgetattrr maybeDeferred _ebRender addCallback _cbRenderr ExceptionFAILUREr NOT_DONE_YET) r+requestr, functionPathfunctionresponseFaileddres r render_POSTXMLRPC.render_POSTslQ"/+EF G!*$$&T5E5E" D G// ="$$$&11.2G2GH8]E::++HEEA++H>9EEr)r<r;r=)FFr')rrrr r!rrhisLeafrallowedMethodsr r~r-rCrHrLrRrprfrdr^rr"rrrr4r4Vs]0IG FIN 8D' $+2-#:6, %NFrr4cp\rSrSrSrSrSrS//\lSrSS//\lSr SS/SS//\ lS r g ) XMLRPCIntrospectiona Implement the XML-RPC Introspection API. By default, the methodHelp method returns the 'help' method attribute, if it exists, otherwise the __doc__ method attribute, if it exists, otherwise the empty string. To enable the methodSignature method, add a 'signature' method attribute containing a list of lists. See methodSignature's documentation for the format. Note the type strings should be XML-RPC types, not Python types. c:[RU5 Xlg)z Implement Introspection support for an XMLRPC server. @param parent: the XMLRPC server to add Introspection support to. @type parent: L{XMLRPC} N)r4r-_xmlrpc_parent)r+parents rr-XMLRPCIntrospection.__init__s $rc/nURS4/nU(aURS5up4URUR5Vs/sHoTU-PM sn5 URUR 5Vs/sH%nUR U5XE-UR -4PM' sn5 U(aMU$s snfs snf)z? Return a list of the method names implemented by this server. rwr)rpopextendrrRrLr)r+ functionstodoobjrFrAs rxmlrpc_listMethods&XMLRPCIntrospection.xmlrpc_listMethodss $$b)*((1+KC   8J8J8LM8Ltm8LM N KK!$ 9 9 ; ;&&t,fmcmm.KL ; dNs B9;,B>arraycURRU5n[USS5=(d [USS5=(d S$)zG Return a documentation string describing the use of the given method. helpNr!rwrr^rbr+methods rxmlrpc_methodHelp%XMLRPCIntrospection.xmlrpc_methodHelp!s=$$44V<vvt,V 40PVTVVrstringcdURRU5n[USS5=(d S$)z Return a list of type signatures. Each type signature is a list of the form [rtype, type1, type2, ...] where rtype is the return type and typeN is the type of the Nth argument. If no signature information is available, the empty string is returned. signatureNrwrrs rxmlrpc_methodSignature*XMLRPCIntrospection.xmlrpc_methodSignature*s.$$44V<v{D17R7r)rN) rrrr r!r-rrrrr"rrrrrs[ %"&-I; W%-h#7"8 8 ( 8($rrc:URS[U55 g)z Add Introspection support to an XMLRPC server. @param xmlrpc: the XMLRPC server to add Introspection support to. @type xmlrpc: L{XMLRPC} systemN)rHr)xmlrpcs raddIntrospectionr<s #6v#>?rc,\rSrSrSrSrSrSrSrg) QueryProtocoliFcSUlURSURR5 UR SS5 UR SURR 5 UR SS5 URR nUR SS[U54-5 URR(atS RURRURR/5nS RS [R"U5/5nUR S U5 UR5 URRU5 g) Nr8s User-AgentsTwisted/XMLRPClibsHosts Content-typerUsContent-lengthrv:rsBasic s Authorization) _response sendCommandfactorypath sendHeaderhostpayloadr|userjoinpasswordbase64 b64encode endHeaders transportr})r+rauth authHeaders rconnectionMadeQueryProtocol.connectionMadeGs $,,"3"34  ';< !2!23 )CD,,&& )5CL?+BC <<  99dll//1F1FGHD9f.>.>t.D"EFJ OO,j 9  W%rcHUS:waURRX#5 gg)Ns200)r badStatus)r+versionstatusmessages r handleStatusQueryProtocol.handleStatusWs! V  LL " "6 3 rcDURR5 Xlg)z Handle the XML-RPC response received from the server. Specifically, disconnect from the server and store the XML-RPC response so that it can be properly handled when the disconnect is finished. N)rloseConnectionr)r+contentss rhandleResponseQueryProtocol.handleResponse[s %%'!rcXUR[R[R5(dURR SU5 [ RRX5 URb/URSso l URRU5 gg)z The connection to the server has been lost. If we have a full response from the server, then parse it and fired a Deferred with the return value or C{Fault} that the server gave us. N) checkr ConnectionDoneConnectionLostrclientConnectionLostr HTTPClientconnectionLostr parseResponse)r+reasonresponses rrQueryProtocol.connectionLostfsx||E00%2F2FGG LL - -dF ; &&t4 >> %'+~~t $Hn LL & &x 0 &r)rN) rrrr rrrrr"rrrrrFs& 4 " 1rrzP %s %s cL\rSrSrSrSr\rS SjrSr Sr \ r Sr Sr g) QueryFactoryi~a} XML-RPC Client Factory @ivar path: The path portion of the URL to which to post method calls. @type path: L{bytes} @ivar host: The value to use for the Host HTTP header. @type host: L{bytes} @ivar user: The username with which to authenticate with the server when making calls. @type user: L{bytes} or L{None} @ivar password: The password with which to authenticate with the server when making calls. @type password: L{bytes} or L{None} @ivar useDateTime: Accept datetime values as datetime.datetime objects. also passed to the underlying xmlrpclib implementation. Defaults to C{False}. @type useDateTime: C{bool} Nc @XsUlUlXEsUlUl[U[ R "XvS94-Ul[UR[5(a URRS5Ul[R"U5Ul Xlg)a @param method: The name of the method to call. @type method: C{str} @param allowNone: allow the use of None values in parameters. It's passed to the underlying xmlrpclib implementation. Defaults to C{False}. @type allowNone: C{bool} or L{None} @param args: the arguments to pass to the method. @type args: C{tuple} @param canceller: A 1-argument callable passed to the deferred as the canceller callback. @type canceller: callable or L{None} )rtruN)rrrrpayloadTemplater[ryrrxrzr{rr(deferredr=) r+rrrrrr<r, cancellerr=s rr-QueryFactory.__init__s8 $ 49#'  4=&  OOD 7*    dllC ( (<<..v6DLy1 &rcHUR(dg[R"XRS9SSnURSso0lUR U5 g![ a: URSso0lUR [R"55 gf=f)NrVr) rr[r\r=callback BaseExceptionr0r Failure)r+rrrs rrQueryFactory.parseResponses}}  ( x>N>NOPQRSTUH '+mmT #Hm   h '  0&*mmT #Hm   W__. / 0s$AAB! B!chURb%URSso0lURU5 ggr')rr0)r+_rrs rr!QueryFactory.clientConnectionLosts/ == $&*mmT #Hm   V $ %rc^URSso0lUR[X55 gr')rr0 ValueError)r+rrrs rrQueryFactory.badStatuss%"&---F45r)rrrrrr=r)NNFrNF)rrrr r!rrr r-rrclientConnectionFailedrr"rrrrr~sD.HH %'N (% 26rrc8\rSrSrSr\rSSjrSrSr g)Proxyiaa A Proxy for making remote XML-RPC calls. Pass the URL of the remote XML-RPC server to the constructor. Use C{proxy.callRemote('foobar', *args)} to call remote method 'foobar' with *args. @ivar user: The username with which to authenticate with the server when making calls. If specified, overrides any username information embedded in C{url}. If not specified, a value may be taken from C{url} if present. @type user: L{bytes} or L{None} @ivar password: The password with which to authenticate with the server when making calls. If specified, overrides any password information embedded in C{url}. If not specified, a value may be taken from C{url} if present. @type password: L{bytes} or L{None} @ivar allowNone: allow the use of None values in parameters. It's passed to the underlying L{xmlrpclib} implementation. Defaults to C{False}. @type allowNone: C{bool} or L{None} @ivar useDateTime: Accept datetime values as datetime.datetime objects. also passed to the underlying L{xmlrpclib} implementation. Defaults to C{False}. @type useDateTime: C{bool} @ivar connectTimeout: Number of seconds to wait before assuming the connection has failed. @type connectTimeout: C{float} @ivar _reactor: The reactor used to create connections. @type _reactor: Object providing L{twisted.internet.interfaces.IReactorTCP} @ivar queryFactory: Object returning a factory for XML-RPC protocol. Use this for testing, or to manipulate the XML-RPC parsing behavior. For example, you may set this to a custom "debugging" factory object that reimplements C{parseResponse} in order to log the raw XML-RPC contents from the server before continuing on with parsing. Another possibility is to implement your own XML-RPC marshaller here to handle non-standard XML-RPC traffic. @type queryFactory: L{twisted.web.xmlrpc.QueryFactory} NcUcSSKJn [U5upppU RS5n[ U5S:XaNUR S5RS5nUR S5UlUR S5UlOS=UlUlUSRS5nUR S5Ul [UR S55Ul Xl URS;aSUl US :HUl UbX lUbX0lX@lXPlX`lXplg![a SUlNf=f![a SUl N|f=f) a( @param url: The URL to which to post method calls. Calls will be made over SSL if the scheme is HTTPS. If netloc contains username or password information, these will be used to authenticate, as long as the C{user} and C{password} arguments are not specified. @type url: L{bytes} Nr)reactor@r)rN/shttps)twisted.internetrrrr|rrrrrintportrsecurer<r=connectTimeout_reactor)r+urlrrr<r=rrschemenetlocrparamsqueryfragment netlocPartsuserpasshostports rr-Proxy.__init__ s@$ ? 08@ 5ell4( { q "q)//5H QDI % ( Q )- ,DI q>''-LLO  HLLO,DI 99 #DI(  I  $M"&, +! % $  % DI s$0D1E1EEEEc ^^UU4SjnURURURUURURUR UUUR 5 mUR(aSSKJ n UR[UR5S9nURR[UR5UR=(d STUURS9mTR"$URR![UR5UR=(d STURS9mTR"$)a Call remote XML-RPC C{method} with given arguments. @return: a L{defer.Deferred} that will fire with the method response, or a failure if the method failed. Generally, the failure type will be L{Fault}, but you can also have an C{IndexError} on some buggy servers giving empty responses. If the deferred is cancelled before the request completes, the connection is closed and the deferred will fire with a L{defer.CancelledError}. c4>STlTR5 gr')r disconnect)rn connectorrs rcancel Proxy.callRemote..cancelKs#G   "rr)ssl)hostnamei)timeoutP) queryFactoryrrrrr<r=rrroptionsForClientTLSrr connectSSLrr connectTCPr)r+rr,rrcontextFactoryrrs @@r callRemoteProxy.callRemote=s ### II II  II MM NN        ;; , 44l499>U4VN 00TYY'  S++ 1I  00TYY' R++ 1I r) rr<rrrrrrr=r)NNFFg>@N) rrrr r!rrr-rr"rrrrrs.-^ L 1 f0 rr)r4r$rrrrrr)*r!r xmlrpc.clientclientr[ urllib.parserrrrrrrr r twisted.loggerr twisted.pythonr r twisted.python.compatr twisted.webrrrrrhrrr$r:r4rrrrr ClientFactoryrr__all__rrrr%s !!::33!+./.   &U RR6^FX  ^FBB&BJ@-1DOO-1`W68))W6tU U p r