Edit File: test_xmlrpc.cpython-36.pyc
3 �k�`ۋ � @ s( d dl Z d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ G dd� de j�Z G d d � d e j�Z G d d � d e j�Z G d d� de j�Z G dd� de j�Z G dd� de j�ZG dd� de j�ZG dd� de j�ZG dd� de j�ZG dd� de j�ZG dd � d �ZG d d � d e�ZG d d � d �ZdS )!� N)�DummySupervisor)� DummyRequest)�DummySupervisorRPCNamespace)� xmlrpclib)�httplibc @ s e Zd Zdd� Zdd� ZdS )�GetFaultDescriptionTestsc C s* ddl m} |j|jj�}| j|d� d S )Nr )�xmlrpc�SHUTDOWN_STATE)� supervisorr �getFaultDescription�Faultsr � assertEqual)�selfr �desc� r �!/usr/lib/python3.6/test_xmlrpc.py�(test_returns_description_for_known_fault s zAGetFaultDescriptionTests.test_returns_description_for_known_faultc C s& ddl m} |jd�}| j|d� d S )Nr )r i?B ZUNKNOWN)r r r r )r r r r r r �&test_returns_unknown_for_unknown_fault s z?GetFaultDescriptionTests.test_returns_unknown_for_unknown_faultN)�__name__� __module__� __qualname__r r r r r r r s r c @ s6 e Zd Zdd� Zd dd�Zdd� Zdd � Zd d � ZdS ) � RPCErrorTestsc C s ddl m} |S )Nr )�RPCError)�supervisor.xmlrpcr )r r r r r �_getTargetClass s z RPCErrorTests._getTargetClassNc C s | j � ||�S )N)r )r �code�extrar r r �_makeOne s zRPCErrorTests._makeOnec C s, ddl m} | j|jj�}| j|jd� d S )Nr )r �FAILED)r r r r r r �text)r r �er r r �#test_sets_text_with_fault_name_only s z1RPCErrorTests.test_sets_text_with_fault_name_onlyc C s. ddl m} | j|jjd�}| j|jd� d S )Nr )r Zoopsz FAILED: oops)r r r r r r r )r r r r r r �(test_sets_text_with_fault_name_and_extra" s z6RPCErrorTests.test_sets_text_with_fault_name_and_extrac C s8 ddl m} | j|jjd�}| jt|�d|jj � d S )Nr )r z /nonexistentz%code=%r, text='NO_FILE: /nonexistent')r r r r ZNO_FILEr �str)r r r r r r � test___str___shows_code_and_text' s z.RPCErrorTests.test___str___shows_code_and_text)N)r r r r r r! r" r$ r r r r r s r c @ s e Zd Zdd� ZdS )�XMLRPCMarshallingTestsc C sX ddl m} |jd�}| j|tjddd�� tjdd�}|j|�}| j|tj|�� d S )Nr )r � T)Zmethodresponse�foo)r& )r r Zxmlrpc_marshalr r �dumps�Fault)r r �dataZfaultr r r �test_xmlrpc_marshal/ s z*XMLRPCMarshallingTests.test_xmlrpc_marshalN)r r r r+ r r r r r% . s r% c @ s| e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd S ) �XMLRPCHandlerTestsc C s ddl m} |S )Nr )�supervisor_xmlrpc_handler)r r- )r r- r r r r 8 s z"XMLRPCHandlerTests._getTargetClassc C s | j � ||�S )N)r )r � supervisord� subinterfacesr r r r < s zXMLRPCHandlerTests._makeOnec C sL t � }dt� fg}| j||�}| j|j|� ddlm} | j|jj|� d S )Nr r )�RootRPCInterface) r r r r r. r r0 Z rpcinterface� __class__)r r r/ �handlerr0 r r r � test_ctor? s z XMLRPCHandlerTests.test_ctorc C s\ G dd� d�}t � }dt� fg}| j||�}| j|j|d��d� | j|j|d��d� d S )Nc @ s e Zd Zdd� ZdS )z4XMLRPCHandlerTests.test_match.<locals>.DummyRequest2c S s || _ d S )N)�uri)r r4 r r r �__init__I s z=XMLRPCHandlerTests.test_match.<locals>.DummyRequest2.__init__N)r r r r5 r r r r � DummyRequest2H s r6 r z/RPC2Tz/nopeF)r r r r �match)r r6 r r/ r2 r r r � test_matchG s z XMLRPCHandlerTests.test_matchc C s� t � }dt� fg}| j||�}tjd d�}tdd d d �}|j||� |jjj }| j t |�d� | j |d d� | j |d d � | j t |j �d� |j d }| j tjtj|� d S )Nr �a�bzsupervisor.noSuchMethodz /what/ever� z0XML-RPC method called: supervisor.noSuchMethod()r& zKXML-RPC method supervisor.noSuchMethod() returned fault: [1] UNKNOWN_METHODr )r9 r: ������)r r r r r( r �continue_request�options�loggerr* r �len� producers� assertRaisesr) �loads)r r r/ r2 r* �request�logdata� xml_responser r r �"test_continue_request_nosuchmethodQ s z5XMLRPCHandlerTests.test_continue_request_nosuchmethodc C s� t � }dt� fg}| j||�}tjf d�}tdd d d �}|j||� |jjj }| j t |�d� | j |d d� | j |d d� | j t |j �d� |j d }tj |�}dd lm} | j |d d | � | j |jd � | j |jd d � | j |jd t |�� d S )Nr zsupervisor.getAPIVersionz /what/everr; z1XML-RPC method called: supervisor.getAPIVersion()r& z?XML-RPC method supervisor.getAPIVersion() returned successfullyr )� API_VERSIONTz Content-Typeztext/xmlzContent-Lengthr< r= )r r r r r( r r> r? r@ r* r rA rB rD �supervisor.rpcinterfacerI �_done�headers) r r r/ r2 r* rE rF rG �responserI r r r �#test_continue_request_methodsuccessc s( z6XMLRPCHandlerTests.test_continue_request_methodsuccessc C s� t � }dt� fg}| j||�}d}tdd d d �}|j||� |jjj}| jt |�d� | j|d d� | j|d d� | jt |j �d� |j d }t j |�}dd l m} | j|d d | � | j|jd � | j|jd d � | j|jd t |�� d S )Nr zp<?xml version="1.0" encoding="UTF-8"?><methodCall><methodName>supervisor.getAPIVersion</methodName></methodCall>z /what/everr; z1XML-RPC method called: supervisor.getAPIVersion()r& z?XML-RPC method supervisor.getAPIVersion() returned successfullyr )rI Tz Content-Typeztext/xmlzContent-Lengthr< r= )r r r r r> r? r@ r* r rA rB r rD rJ rI rK rL ) r r r/ r2 r* rE rF rG rM rI r r r �*test_continue_request_no_params_in_requesty s( z=XMLRPCHandlerTests.test_continue_request_no_params_in_requestc C s� t � }dt� fg}| j||�}d}tdd d d �}|j||� |jjj}| jt |�d� | j |d j d�� | j t |�|d k� | j |d j d�� | j|jd� d S ) Nr zX<?xml version="1.0" encoding="UTF-8"?><methodCall><methodName></methodName></methodCall>z /what/everr& r zXML-RPC request datazis invalid: no method namei� )r r r r r> r? r@ r* r rA � assertTrue� startswith�repr�endswith�_error)r r r/ r2 r* rE rF r r r �1test_continue_request_400_if_method_name_is_empty� s zDXMLRPCHandlerTests.test_continue_request_400_if_method_name_is_emptyc C s� t � }dt� fg}| j||�}d}tdd d d �}|j||� |jjj}| jt |�d� | j |d j d�� | j t |�|d k� | j |d j d�� | j|jd� d S ) Nr z#this is not an xml-rpc request bodyz /what/everr& r zXML-RPC request datazis invalid: unmarshallablei� )r r r r r> r? r@ r* r rA rP rQ rR rS rT )r r r/ r2 r* rE rF r r r �1test_continue_request_400_if_loads_raises_not_xml� s zDXMLRPCHandlerTests.test_continue_request_400_if_loads_raises_not_xmlc C s� t � }dt� fg}| j||�}d}tdd d d �}|j||� |jjj}| jt |�d� | j |d j d�� | j t |�|d k� | j |d j d�� | j|jd� d S ) Nr z&<methodName></methodName><junk></junk>z /what/everr& r zXML-RPC request datazis invalid: unmarshallablei� )r r r r r> r? r@ r* r rA rP rQ rR rS rT )r r r/ r2 r* rE rF r r r �3test_continue_request_400_if_loads_raises_weird_xml� s zFXMLRPCHandlerTests.test_continue_request_400_if_loads_raises_weird_xmlc C s� t � }dt� fg}| j||�}tjf d�}tdd d d �}|j||� |jjj }| j t |�d� | j |d d� | j d|d k� | j t |�|d k� | j d |d k� | j d |d k� | j |jd � d S ) Nr zsupervisor.raiseErrorz /what/everr; r z.XML-RPC method called: supervisor.raiseError()zunexpected exceptionr& � TracebackzValueError: errori� )r r r r r( r r> r? r@ r* r rA rP rR rT )r r r/ r2 r* rE rF r r r �<test_continue_request_500_if_rpcinterface_method_call_raises� s zOXMLRPCHandlerTests.test_continue_request_500_if_rpcinterface_method_call_raisesc C s� t � }dt� fg}| j||�}tjf d�}tdd d d �}|j||� |jjj }| j t |�d� | j |d d� | j |d d� | j d |d k� | j t |�|d k� | j d |d k� | j d |d k� | j |jd � d S )Nr z"supervisor.getXmlRpcUnmarshallablez /what/ever� r z;XML-RPC method called: supervisor.getXmlRpcUnmarshallable()r& zIXML-RPC method supervisor.getXmlRpcUnmarshallable() returned successfullyzunexpected exceptionr; rX zTypeError: cannot marshali� )r r r r r( r r> r? r@ r* r rA rP rR rT )r r r/ r2 r* rE rF r r r �0test_continue_request_500_if_xmlrpc_dumps_raises� s" zCXMLRPCHandlerTests.test_continue_request_500_if_xmlrpc_dumps_raisesc C s� G dd� dt �}t� }dt� fd|� fg}| j||�}tjf d�}tdd d d �}|j||� |jj j }| j t |�d� | j |d d� | j |d d � | j t |j �d � | j |jd � d S )Nc @ s e Zd Zdd� ZdS )zUXMLRPCHandlerTests.test_continue_request_value_is_function.<locals>.DummyRPCNamespacec S s dd� }d|_ |S )Nc S s dS )Nr& r )r r r r �inner� s zhXMLRPCHandlerTests.test_continue_request_value_is_function.<locals>.DummyRPCNamespace.foo.<locals>.innerg�������?)�delay)r r\ r r r r' � s zYXMLRPCHandlerTests.test_continue_request_value_is_function.<locals>.DummyRPCNamespace.fooN)r r r r' r r r r �DummyRPCNamespace� s r^ r �ns1zns1.fooz /what/everr; z XML-RPC method called: ns1.foo()r& z.XML-RPC method ns1.foo() returned successfullyr Fr< r= )�objectr r r r r( r r> r? r@ r* r rA rB rK )r r^ r r/ r2 r* rE rF r r r �'test_continue_request_value_is_function� s z:XMLRPCHandlerTests.test_continue_request_value_is_functionc C s2 d}t � }dt� fg}| j||�}|j|�}|\}}dd l}| j|d� | j|d d� | j|d d� | j|d d � | j|d d � | j|d d � | j|d d� | j|d d!� | j|d |jdddddd�� | j|d d� | j|d d dd�� | j|d d dd d g� | j|d d di gi� d S )"Na� <?xml version="1.0"?> <methodCall> <methodName>examples.getStateName</methodName> <params> <param> <value><i4>41</i4></value> </param> <param> <value><string>foo</string></value> </param> <param> <value><string></string></value> </param> <param> <!-- xml-rpc spec allows strings without <string> tag --> <value>bar</value> </param> <param> <value></value> </param> <param> <value><boolean>1</boolean></value> </param> <param> <value><double>-12.214</double></value> </param> <param> <value> <dateTime.iso8601>19980717T14:08:55</dateTime.iso8601> </value> </param> <param> <value><base64>eW91IGNhbid0IHJlYWQgdGhpcyE=</base64></value> </param> <param> <struct> <member><name>j</name><value><i4>5</i4></value></member> <member><name>k</name><value>abc</value></member> </struct> </param> <param> <array> <data> <value><i4>12</i4></value> <value><string>abc</string></value> <value>def</value> <value><i4>34</i4></value> </data> </array> </param> <param> <struct> <member> <name>k</name> <value><array><data> <value><i4>1</i4></value> <struct></struct> </data></array></value> </member> </struct> </param> </params> </methodCall> r r zexamples.getStateName�) r& r' r; � rZ Zbar� � T� g!�rh�m(@� i� � � � �7 zyou can't read this!� �abc)�j�k� � �def�" � ro g!�rh�m(�)r r r rD �datetimer ) r �sr r/ r2 �result�params�methodru r r r � test_iterparse_loads_methodcall� s( @ z2XMLRPCHandlerTests.test_iterparse_loads_methodcallN)r r r r r r3 r8 rH rN rO rU rV rW rY r[ ra rz r r r r r, 7 s r, c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )� TraverseTestsc C sP ddl m} G dd� d�}G dd� d�}|� }|� |_| j|j|j|dg � d S )Nr )r c @ s e Zd ZdS )zFTraverseTests.test_security_disallows_underscore_methods.<locals>.RootN)r r r r r r r �RootQ s r| c @ s e Zd Zdd� ZdS )zCTraverseTests.test_security_disallows_underscore_methods.<locals>.Ac S s dS )NTr )r r r r �_dangerT s zKTraverseTests.test_security_disallows_underscore_methods.<locals>.A._dangerN)r r r r} r r r r �AS s r~ z a._danger)r r r9 rC r �traverse)r r r| r~ �rootr r r �*test_security_disallows_underscore_methodsO s z8TraverseTests.test_security_disallows_underscore_methodsc C sh ddl m} G dd� d�}G dd� d�}G dd� d�}|� }|� |_|� |j_| j|j|j|d g � d S ) Nr )r c @ s e Zd ZdS )zDTraverseTests.test_security_disallows_object_traversal.<locals>.RootN)r r r r r r r r| ] s r| c @ s e Zd ZdS )zATraverseTests.test_security_disallows_object_traversal.<locals>.AN)r r r r r r r r~ _ s r~ c @ s e Zd Zdd� ZdS )zATraverseTests.test_security_disallows_object_traversal.<locals>.Bc S s dS )NTr )r r r r �dangerb s zHTraverseTests.test_security_disallows_object_traversal.<locals>.B.dangerN)r r r r� r r r r �Ba s r� z a.b.danger)r r r9 r: rC r r )r r r| r~ r� r� r r r �(test_security_disallows_object_traversal[ s z6TraverseTests.test_security_disallows_object_traversalc C s: ddl m} G dd� d�}|� }| j|j|j|dd � d S )Nr )r c @ s e Zd ZdS )z9TraverseTests.test_namespace_name_not_found.<locals>.RootN)r r r r r r r r| l s r| znotfound.hello)r r rC r r )r r r| r� r r r � test_namespace_name_not_foundj s z+TraverseTests.test_namespace_name_not_foundc C sP ddl m} G dd� d�}G dd� d�}|� }|� |_| j|j|j|dg � d S )Nr )r c @ s e Zd ZdS )z6TraverseTests.test_method_name_not_found.<locals>.RootN)r r r r r r r r| t s r| c @ s e Zd ZdS )z3TraverseTests.test_method_name_not_found.<locals>.AN)r r r r r r r r~ v s r~ z a.notfound)r r r9 rC r r )r r r| r~ r� r r r �test_method_name_not_foundr s z(TraverseTests.test_method_name_not_foundc C sh ddl m} G dd� d�}G dd� d�}G dd� d�}|� }|� |_|� |j_| j|j|j|d g � d S ) Nr )r c @ s e Zd ZdS )zGTraverseTests.test_method_name_exists_but_is_not_a_method.<locals>.RootN)r r r r r r r r| s r| c @ s e Zd ZdS )zDTraverseTests.test_method_name_exists_but_is_not_a_method.<locals>.AN)r r r r r r r r~ � s r~ c @ s e Zd ZdS )zDTraverseTests.test_method_name_exists_but_is_not_a_method.<locals>.BN)r r r r r r r r� � s r� za.b)r r r9 r: rC r r )r r r| r~ r� r� r r r �+test_method_name_exists_but_is_not_a_method} s z9TraverseTests.test_method_name_exists_but_is_not_a_methodc C sT ddl m} G dd� d�}G dd� d�}|� }|� |_| j|j|j|ddd g� d S ) Nr )r c @ s e Zd ZdS )z+TraverseTests.test_bad_params.<locals>.RootN)r r r r r r r r| � s r| c @ s e Zd Zdd� ZdS )z(TraverseTests.test_bad_params.<locals>.Ac S s d| S )NzHello %sr )r �namer r r �hello� s z.TraverseTests.test_bad_params.<locals>.A.helloN)r r r r� r r r r r~ � s r~ za.hello�therer )r r r9 rC r r )r r r| r~ r� r r r �test_bad_params� s z TraverseTests.test_bad_paramsc C sV ddl m} G dd� d�}G dd� d�}|� }|� |_|j|ddg�}| j|d � d S ) Nr )r c @ s e Zd ZdS )z(TraverseTests.test_success.<locals>.RootN)r r r r r r r r| � s r| c @ s e Zd Zdd� ZdS )z%TraverseTests.test_success.<locals>.Ac S s d| S )NzHello %sr )r r� r r r r� � s z+TraverseTests.test_success.<locals>.A.helloN)r r r r� r r r r r~ � s r~ za.hellor� z Hello there)r r r9 r r )r r r| r~ r� rw r r r � test_success� s zTraverseTests.test_successN) r r r r� r� r� r� r� r� r� r r r r r{ N s r{ c @ s\ e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dS )�SupervisorTransportTestsc C s ddl m} |S )Nr )�SupervisorTransport)r r� )r r� r r r r � s z(SupervisorTransportTests._getTargetClassc O s | j � ||�S )N)r )r �arg�kwr r r r � s z!SupervisorTransportTests._makeOnec C sT ddl m} | jddd�}|j� }| jt||j�� | j|jd� | j|j d� d S )Nr )r �user�passzunix:///foo/bar� localhostz/foo/bar) r r r �_get_connectionrP � isinstanceZUnixStreamHTTPConnectionr �hostZ socketfile)r r � transport�connr r r �test_ctor_unix� s z'SupervisorTransportTests.test_ctor_unixc C s | j t| jddd� d S )Nr� r� zunknown:///foo/bar)rC � ValueErrorr )r r r r �test_ctor_unknown� s z*SupervisorTransportTests.test_ctor_unknownc C sH | j ddd�}|j� }| jt|tj�� | j|jd� | j|jd� d S )Nr� r� zhttp://127.0.0.1:9001/z 127.0.0.1i)# ) r r� rP r� r �HTTPConnectionr r� �port)r r� r� r r r � test__get_connection_http_9001� s z7SupervisorTransportTests.test__get_connection_http_9001c C sH | j ddd�}|j� }| jt|tj�� | j|jd� | j|jd� d S )Nr� r� zhttp://127.0.0.1/z 127.0.0.1�P ) r r� rP r� r r� r r� r� )r r� r� r r r � test__get_connection_http_80� s z5SupervisorTransportTests.test__get_connection_http_80c s` | j ddd�}tdd�� � fdd�}||_| jtj|jdd d� | j|jd � | j� j d � d S ) Nr� r� zhttp://127.0.0.1/i� rc c s � S )Nr r )� dummy_connr r �getconn� s zGSupervisorTransportTests.test_request_non_200_response.<locals>.getconnr� �/T) r �DummyConnectionr� rC r � ProtocolErrorrE r � connection�closed)r r� r� r )r� r � test_request_non_200_response� s z6SupervisorTransportTests.test_request_non_200_responsec s� | j ddd�}tdd�� � fdd�}||_| jtj|jdd d� | j|jd � | j� j d � | j� j d d � | j� j d d � | j� j d d� | j� j d d d� | j� j d d d� | j� j d d d� | j� j d d d� d S )Nr� r� zhttp://127.0.0.1/i� rc c s � S )Nr r )r� r r r� � s zCSupervisorTransportTests.test_request_400_response.<locals>.getconnr� r� Tr �POSTr& r; � rZ zContent-Length�0z Content-Typeztext/xml� AuthorizationzBasic dXNlcjpwYXNz�Accept) r r� r� rC r r� rE r r� r� � requestargs)r r� r� r )r� r �test_request_400_response� s z2SupervisorTransportTests.test_request_400_responsec s� | j ddd�}d}td|�� � fdd�}||_|jdd d �}| j|j� � | j� jd � | j� jd d � | j� jd d � | j� jd d� | j� jd d d� | j� jd d d� | j� jd d d� | j� jd d d� | j|d� d S )Nr� r� zhttp://127.0.0.1/z�<?xml version="1.0"?> <methodResponse> <params> <param> <value><string>South Dakota</string></value> </param> </params> </methodResponse>�� c s � S )Nr r )r� r r r� � s zCSupervisorTransportTests.test_request_200_response.<locals>.getconnr� r� rc Fr r� r& r; r� rZ zContent-Lengthr� z Content-Typeztext/xmlr� zBasic dXNlcjpwYXNzr� � South Dakota)r� )r r� r� rE r r� r� r� )r r� rM r� rw r )r� r �test_request_200_response� s" z2SupervisorTransportTests.test_request_200_responsec sP | j ddd�}tdd�� � fdd�}||_|jdd d � |j� | j� j� d S ) Nr� r� zhttp://127.0.0.1/r� zH<?xml version="1.0"?> <methodResponse><params/></methodResponse>c s � S )Nr r )r� r r r� s z4SupervisorTransportTests.test_close.<locals>.getconnr� r� rc )r r� r� rE �closerP r� )r r� r� r )r� r � test_close� s z#SupervisorTransportTests.test_closeN) r r r r r r� r� r� r� r� r� r� r� r r r r r� � s r� c @ sv e Zd Zdd� Zd dd�Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� ZdS ) �TestDeferredXMLRPCResponsec C s ddl m} |S )Nr )�DeferredXMLRPCResponse)r r� )r r� r r r r s z*TestDeferredXMLRPCResponse._getTargetClassNc C s: |d krt d d d d d �}|d kr,t� }d|_| j� ||�S )Nr& )r �Dummyr] r )r rE �callbackr r r r s z#TestDeferredXMLRPCResponse._makeOnec C sV t � }d|_| jd|d�}| j|j|� | j|jd� | j|jd� | j|jd� d S )Nr& rE )rE r� g �?F)r� r] r r r� rE �finished)r r� �instr r r r3 s z$TestDeferredXMLRPCResponse.test_ctorc C s& | j � }d|_|j� }| j|d� d S )NTrc )r r� �morer )r r� rw r r r �test_more_finished s z-TestDeferredXMLRPCResponse.test_more_finishedc s> ddl m� � fdd�}d|_| j|d�}| j|j� � � d S )Nr )� NOT_DONE_YETc s � S )Nr r )r� r r r� ( s zTTestDeferredXMLRPCResponse.test_more_callback_returns_not_done_yet.<locals>.callbackr& )r� )�supervisor.httpr� r] r r r� )r r� r� r )r� r �'test_more_callback_returns_not_done_yet& s zBTestDeferredXMLRPCResponse.test_more_callback_returns_not_done_yetc sz ddl m�m� � �fdd�}d|_| j|d�}| j|j� d � | jt|jj �d� | j d|jj d k� | j |j � d S )Nr )r r c s �� j ��d S )N)�UNKNOWN_METHODr )r r r r r� 0 s zOTestDeferredXMLRPCResponse.test_more_callback_raises_RPCError.<locals>.callbackr& )r� r� ) r r r r] r r r� rA rE rB rP r� )r r� r� r )r r r �"test_more_callback_raises_RPCError. s z=TestDeferredXMLRPCResponse.test_more_callback_raises_RPCErrorc C sd dd� }d|_ | j|d�}| j|j� d � | jt|jj�d� | jd|jjd k� | j|j� d S )Nc S s dS )Nrm r r r r r r� : s zMTestDeferredXMLRPCResponse.test_more_callback_returns_value.<locals>.callbackr& )r� rm r ) r] r r r� rA rE rB rP r� )r r� r� r r r � test_more_callback_returns_value9 s z;TestDeferredXMLRPCResponse.test_more_callback_returns_valuec C s� dd� }d|_ | j|d�}| j|j� d � | j|jjd� | j|j� |jjj j j }| jt |�d� |d \}}| j|d� | jd|k� d S ) Nc S s t d��d S )Nr' )r� r r r r r� D s z[TestDeferredXMLRPCResponse.test_more_callback_raises_unexpected_exception.<locals>.callbackr& )r� i� r z XML-RPC response callback errorrX ) r] r r r� rE rT rP r� ZchannelZserverr@ �loggedrA )r r� r� r� �src�msgr r r �.test_more_callback_raises_unexpected_exceptionC s zITestDeferredXMLRPCResponse.test_more_callback_raises_unexpected_exceptionc C sT | j � }d|j_|jjjd� |jd� | jt|jj�d� | j|jj d d� d S )Nz1.0zConnection: keep-aliverm r& � Connectionz Keep-Alive) r rE �version�header�append� getresponser rA rB rL )r r� r r r �'test_getresponse_http_10_with_keepaliveQ s zBTestDeferredXMLRPCResponse.test_getresponse_http_10_with_keepalivec C sF | j � }d|j_|jd� | jt|jj�d� | j|jjd d� d S )Nz1.0rm r& r� r� )r rE r� r� r rA rB rL )r r� r r r �%test_getresponse_http_10_no_keepaliveY s z@TestDeferredXMLRPCResponse.test_getresponse_http_10_no_keepalivec C sD | j � }d|j_|jd� | jt|jj�d� | jd|jjk� d S )Nz1.1rm r& r� ) r rE r� r� r rA rB rP rL )r r� r r r �&test_getresponse_http_11_without_close` s zATestDeferredXMLRPCResponse.test_getresponse_http_11_without_closec C sT | j � }|jjjd� d|j_|jd� | jt|jj�d� | j|jj d d� d S )NzConnection: closez1.1rm r& r� r� ) r rE r� r� r� r� r rA rB rL )r r� r r r �#test_getresponse_http_11_with_closeg s z>TestDeferredXMLRPCResponse.test_getresponse_http_11_with_closec C sF | j � }d |j_|jd� | jt|jj�d� | j|jjd d� d S )Nrm r& r� r� )r rE r� r� r rA rB rL )r r� r r r � test_getresponse_http_unknowno s z8TestDeferredXMLRPCResponse.test_getresponse_http_unknown)NN)r r r r r r3 r� r� r� r� r� r� r� r� r� r� r r r r r� s r� c @ s� e Zd Zf fdd�Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#S )$� TestSystemNamespaceRPCInterfacec C s ddl m} ||�S )Nr )�SystemNamespaceRPCInterface)r r� )r Z namespacesr� r r r r w s z(TestSystemNamespaceRPCInterface._makeOnec C s( | j � }|j� }| j|ddddg� d S )Nzsystem.listMethodszsystem.methodHelpzsystem.methodSignaturezsystem.multicall)r � listMethodsr )r r� rw r r r �test_listMethods_gardenpath{ s z;TestSystemNamespaceRPCInterface.test_listMethods_gardenpathc C sH G dd� dt �}|� }| jd|fg�}|j� }| j|dddddg� d S ) Nc @ s e Zd Zdd� Zdd� ZdS )z_TestSystemNamespaceRPCInterface.test_listMethods_omits_underscore_attrs.<locals>.DummyNamespacec S s d S )Nr )r r r r r' � s zcTestSystemNamespaceRPCInterface.test_listMethods_omits_underscore_attrs.<locals>.DummyNamespace.fooc S s d S )Nr )r r r r �_bar� s zdTestSystemNamespaceRPCInterface.test_listMethods_omits_underscore_attrs.<locals>.DummyNamespace._barN)r r r r' r� r r r r �DummyNamespace� s r� r_ zns1.foozsystem.listMethodszsystem.methodHelpzsystem.methodSignaturezsystem.multicall)r` r r� r )r r� r_ r� rw r r r �'test_listMethods_omits_underscore_attrs� s zGTestSystemNamespaceRPCInterface.test_listMethods_omits_underscore_attrsc C s$ | j � }|jd�}| jd|k� d S )Nzsystem.listMethods�array)r � methodHelprP )r r� rw r r r � test_methodHelp_known_method� s z<TestSystemNamespaceRPCInterface.test_methodHelp_known_methodc C s( ddl m} | j� }| j||jd� d S )Nr )r z wont.be.found)r r r rC r� )r r r� r r r � test_methodHelp_unknown_method� s z>TestSystemNamespaceRPCInterface.test_methodHelp_unknown_methodc C s& | j � }|jd�}| j|ddg� d S )Nzsystem.methodSignaturer� �string)r �methodSignaturer )r r� rw r r r �!test_methodSignature_known_method� s zATestSystemNamespaceRPCInterface.test_methodSignature_known_methodc C s( ddl m} | j� }| j||jd� d S )Nr )r z wont.be.found)r r r rC r� )r r r� r r r �#test_methodSignature_unknown_method� s zCTestSystemNamespaceRPCInterface.test_methodSignature_unknown_methodc C sF ddl m} G dd� dt�}|� }| jd|fg�}| j||jd� d S )Nr )r c @ s e Zd Zdd� ZdS )zYTestSystemNamespaceRPCInterface.test_methodSignature_with_bad_sig.<locals>.DummyNamespacec S s dS )z @param string name The thingNr )r r r r r' � s z]TestSystemNamespaceRPCInterface.test_methodSignature_with_bad_sig.<locals>.DummyNamespace.fooN)r r r r' r r r r r� � s r� r_ zns1.foo)r r r` r rC r� )r r r� r_ r� r r r �!test_methodSignature_with_bad_sig� s zATestSystemNamespaceRPCInterface.test_methodSignature_with_bad_sigc C sB ddl m} | j� }ddig}|j|�}| j||jdd�g� d S )Nr )r � methodNamezsystem.multicallz:INCORRECT_PARAMETERS: Recursive system.multicall forbidden)� faultCode� faultString)r r r � multicallr �INCORRECT_PARAMETERS)r r r� �calls�resultsr r r �#test_multicall_faults_for_recursion� s zCTestSystemNamespaceRPCInterface.test_multicall_faults_for_recursionc C s> ddl m} | j� }i g}|j|�}| j||jdd�g� d S )Nr )r z#INCORRECT_PARAMETERS: No methodName)r� r� )r r r r� r r� )r r r� r� r� r r r �,test_multicall_faults_for_missing_methodName� s zLTestSystemNamespaceRPCInterface.test_multicall_faults_for_missing_methodNamec C sB ddl m} | j� }ddig}|j|�}| j||jdd�g� d S )Nr )r r� zbad.stopProcessr� )r� r� )r r r r� r r� )r r r� r� r� r r r �2test_multicall_faults_for_methodName_bad_namespace� s zRTestSystemNamespaceRPCInterface.test_multicall_faults_for_methodName_bad_namespacec C s` ddl m} G dd� dt�}|� }| jd|fg�}ddig}|j|�}| j||jdd �g� d S ) Nr )r c @ s e Zd ZdS )zoTestSystemNamespaceRPCInterface.test_multicall_faults_for_methodName_good_ns_bad_method.<locals>.DummyNamespaceN)r r r r r r r r� � s r� r_ r� zns1.badr� )r� r� )r r r` r r� r r� )r r r� r_ r� r� r� r r r �7test_multicall_faults_for_methodName_good_ns_bad_method� s zWTestSystemNamespaceRPCInterface.test_multicall_faults_for_methodName_good_ns_bad_methodc C s& | j � }g }|j|�}| j|g � d S )N)r r� r )r r� r� r� r r r �4test_multicall_returns_empty_results_for_empty_calls� s zTTestSystemNamespaceRPCInterface.test_multicall_returns_empty_results_for_empty_callsc C sh G dd� dt �}|� }| jd|fg�}ddgd�ddgd�ddgd�g}|j|�}| j|dddg� d S ) Nc @ s e Zd Zdd� ZdS )znTestSystemNamespaceRPCInterface.test_multicall_performs_noncallback_functions_serially.<locals>.DummyNamespacec S s |S )z @param string name Process namer )r r� r r r �say� s zrTestSystemNamespaceRPCInterface.test_multicall_performs_noncallback_functions_serially.<locals>.DummyNamespace.sayN)r r r r� r r r r r� � s r� r_ zns1.sayZAlvin)r� rx ZSimonZTheodore)r` r r� r )r r� r_ r� r� r� r r r �6test_multicall_performs_noncallback_functions_serially� s zVTestSystemNamespaceRPCInterface.test_multicall_performs_noncallback_functions_seriallyc s� dd l �ddlm�m� G � ��fdd�dt�}|� }| jd|fg�}ddiddig}|j|�}� jd d �}� jd t d �}| j |||g� d S ) Nr )r r c s& e Zd Z� �fdd�Z�fdd�ZdS )zeTestSystemNamespaceRPCInterface.test_multicall_catches_noncallback_exceptions.<locals>.DummyNamespacec s �� j d��d S )Nr' )�BAD_NAME)r )r r r r �bad_name� s znTestSystemNamespaceRPCInterface.test_multicall_catches_noncallback_exceptions.<locals>.DummyNamespace.bad_namec s t � j��d S )N)�OSError�ENOENT)r )�errnor r �os_error s znTestSystemNamespaceRPCInterface.test_multicall_catches_noncallback_exceptions.<locals>.DummyNamespace.os_errorN)r r r r� r� r )r r r� r r r� � s r� r_ r� z ns1.bad_namez ns1.os_errorz BAD_NAME: foo)r� r� z FAILED: %s:2) r� r r r r` r r� r� r r� r )r r� r_ r� r� r� r� r� r )r r r� r �-test_multicall_catches_noncallback_exceptions� s zMTestSystemNamespaceRPCInterface.test_multicall_catches_noncallback_exceptionsc s� dd l �ddlm�m� ddlm} G � ��fdd�dt�}|� }| jd|fg�}ddidd ig}|j|�}|}x||kr�|� }qrW � j d d �}� j d t d �} | j ||| g� d S ) Nr )r r )r� c s& e Zd Z� �fdd�Z�fdd�ZdS )zbTestSystemNamespaceRPCInterface.test_multicall_catches_callback_exceptions.<locals>.DummyNamespacec s � �fdd�}|S )Nc s �� j d��d S )Nr' )r� r )r r r r r\ s zzTestSystemNamespaceRPCInterface.test_multicall_catches_callback_exceptions.<locals>.DummyNamespace.bad_name.<locals>.innerr )r r\ )r r r r r� s zkTestSystemNamespaceRPCInterface.test_multicall_catches_callback_exceptions.<locals>.DummyNamespace.bad_namec s � fdd�}|S )Nc s t � j��d S )N)r� r� r )r� r r r\ s zzTestSystemNamespaceRPCInterface.test_multicall_catches_callback_exceptions.<locals>.DummyNamespace.os_error.<locals>.innerr )r r\ )r� r r r� s zkTestSystemNamespaceRPCInterface.test_multicall_catches_callback_exceptions.<locals>.DummyNamespace.os_errorN)r r r r� r� r )r r r� r r r� s r� r_ r� z ns1.bad_namez ns1.os_errorz BAD_NAME: foo)r� r� z FAILED: %s:2) r� r r r r� r� r` r r� r� r r� r ) r r� r� r_ r� r� r� r� r� r� r )r r r� r �*test_multicall_catches_callback_exceptions s zJTestSystemNamespaceRPCInterface.test_multicall_catches_callback_exceptionsc s� ddl m� G � fdd�dt�}|� }| jd|fg�}dddid �d ddid �g}|j|�}� }x|� krr|� }qbW | j|d d g� d S ) Nr )r� c s, e Zd Z� fdd�Z� fdd�Zdd� ZdS )zkTestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_serially.<locals>.DummyNamespacec s � � � dg| _ dg| _d S )Nz stop resultz start result)� stop_results� start_results)r )r� r r r5 + s ztTestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_serially.<locals>.DummyNamespace.__init__c s �� fdd�}|S )Nc s �j jd�} | � k rd�_| S )Nr T)r� �pop�stopped)rw )r� r r r r\ 0 s z�TestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_serially.<locals>.DummyNamespace.stopProcess.<locals>.innerr )r r� r\ )r� )r r � stopProcess/ s zwTestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_serially.<locals>.DummyNamespace.stopProcessc s � fdd�}|S )Nc s � j std��� jjd�S )NzThis should not raiser )r� � Exceptionr� r� r )r r r r\ 7 s z�TestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_serially.<locals>.DummyNamespace.startProcess.<locals>.innerr )r r� r\ r )r r � startProcess6 s zxTestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_serially.<locals>.DummyNamespace.startProcessN)r r r r5 r� r� r )r� r r r� * s r� r_ zns1.stopProcessr� r' )r� rx zns1.startProcessz stop resultz start result)r� r� r` r r� r )r r� r_ r� r� r� r� r )r� r �3test_multicall_performs_callback_functions_serially( s zSTestSystemNamespaceRPCInterface.test_multicall_performs_callback_functions_seriallyN)r r r r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r� v s" r� c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) � Test_gettagsc C s ddl m} ||�S )Nr )�gettags)r r )r Zcommentr r r r �_callFUTI s zTest_gettags._callFUTc C s" d}| j |�}| j|ddg� d S )Nz@foor rc r' )r NNNrc )r r' rc rc rc )r r )r �linesrw r r r �test_one_atpartM s z Test_gettags.test_one_atpartc C s" d}| j |�}| j|ddg� d S )Nz @foo arrayr rc r' r� )r NNNrc )r r' r� rc rc )r r )r r rw r r r �test_two_atpartsU s z Test_gettags.test_two_atpartsc C s" d}| j |�}| j|ddg� d S ) Nz@foo array namer rc r' r� r� )r NNNrc )r r' r� r� rc )r r )r r rw r r r �test_three_atparts] s z Test_gettags.test_three_atpartsc C s" d}| j |�}| j|dd g� d S ) Nz@foo array name textr rc r' r� r� r )r NNNrc )r r' r� r� r )r r )r r rw r r r �test_four_atpartse s z Test_gettags.test_four_atpartsN)r r r r r r r r r r r r r� H s r� c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �Test_capped_intc C s ddl m} ||�S )Nr )� capped_int)r r )r �valuer r r r r n s zTest_capped_int._callFUTc C s | j | jd�d� d S )NZ42�* )r r )r r r r � test_converts_value_to_integerr s z.Test_capped_int.test_converts_value_to_integerc C s* ddl m} | j| j|jd �|j� d S )Nr )r r& )�supervisor.compatr r r ZMININT)r r r r r � test_caps_value_below_minintu s z,Test_capped_int.test_caps_value_below_minintc C s* ddl m} | j| j|jd �|j� d S )Nr )r r& )r r r r ZMAXINT)r r r r r � test_caps_value_above_maxinty s z,Test_capped_int.test_caps_value_above_maxintN)r r r r r r r r r r r r m s r c @ s e Zd Zd dd�Zdd� ZdS ) � DummyResponser� rc �reasonc C s || _ || _|| _d S )N)�status�bodyr )r r r r r r r r5 s zDummyResponse.__init__c C s | j S )N)r )r r r r �read� s zDummyResponse.readN)r� rc r )r r r r5 r r r r r r ~ s r c @ s e Zd ZdS )r� N)r r r r r r r r� � s r� c @ s2 e Zd ZdZddd�Zdd� Zd d � Zd d � Zd S )r� Fr� rc r c C s t |||�| _d S )N)r rM )r r r r r r r r5 � s zDummyConnection.__init__c C s | j S )N)rM )r r r r r� � s zDummyConnection.getresponsec O s || _ || _d S )N)r� Z requestkw)r r� r� r r r rE � s zDummyConnection.requestc C s d| _ d S )NT)r� )r r r r r� � s zDummyConnection.closeN)r� rc r )r r r r� r5 r� rE r� r r r r r� � s r� )ZunittestZsupervisor.tests.baser r r r r r ZTestCaser r r% r, r{ r� r� r� r� r r r` r� r� r r r r �<module> s* Ugl S%
Back to File Manager