B
EDb) @ s d dl mZ d dlmZmZ d dlmZmZ d dlm Z d dl
T d dl T d dl m
Z
d dlmZ d dlmZ d d lZd d lZd d lZd d lZd dlT d d
lmZ G d d d eZd S )
)global_service_collection)
get_type_info
validate_type)
attachment extract_attachment_reference)
TypeConverter)*)AttachmentHandler)CustomResponse)debugN)settingsc @ s0 e Zd ZdZdd Zdd Zdd Zdd Zd
S )
Dispatchera
The dispatcher class handles the communication between the service interface and
the user functionality. This happens in dispatch_request()
1. It recieves the raw protocol data and attempts to parse it using the service
interface's request handler. If successful a req_dict (request dictionary) is returned.
2. The request dictionary is parsed to call_method() where the arguments are converted to
fit the user defined method.
3. If the call to the user defined method is successful the result is converted to a
res_dict (response dictionary) in result_to_dict()
4. The response dictionary is passed to the service interface's response handler and
returned as raw protocol data.
c C s || _ || _||| _|| _d S )N)response_encodingsinstifacelogging)selfr Zifclassr r r 7G:\easytimepro\master/mysite/ladon\server\dispatcher.py__init__# s
zDispatcher.__init__c C s g }x| D ]}|d |d kr^d|kr>||d g7 }n t| j | jjd|d qt|d tkrRg }t|d d } | rx|d |d D ] }
||d d |
||dg7 }qW n|d d t krxr|d |d D ]&}
|t
|
|| j | j | jjg7 }qW n6x4|d |d D ] }
|| |
|d d g7 }q"W ||g7 }qt|d } |d |d } | r||d | ||dg7 }q|d t kr|t
| || j | j | jjg7 }q|| | |d g7 }qW |j
j} t| t t d}
t|
|j
j }| jt@ r*|d |j
j|d
f g7 }| jt@ rH|d t| g7 }| jt@ r\t }|jrd |i}|| t||d
||}nt||d
| }| jt@ r|dd
tt | |S )z
call_method converts the res_dict delivered from an interface
to the type of arguments expected by the service method.
tc is the TypeConverter associated to the service method.
nameargsdefaultz Parameter "%s" is not optionaltyper )Z
prime_dicttc export_dictr z Method:%s.%s
methodnamezRequestDict:%sZLADON_METHOD_TCzExecutionTime:%s) r UndefinedServiceMethodr _interface_namer servicenamer listr r r r Zfrom_unicode_stringsinfoZ
modulename
__import__globalslocalsgetattrr ZLOG_REQUEST_ACCESSZLOG_REQUEST_DICTstrZLOG_EXECUTION_TIMEtimeZ
_has_keywordsupdateinsert)r methodreq_dictr r log_liner argarg_list type_infoitemvalZmnameZservice_moduleZservice_class_instancestartkwresultr r r call_method) s\ "
zDispatcher.call_methodc C sh |j j|j j| d}|j}t|}|dkr6ttgt |r
g } | |d< t|d }||krhdS |rx|D ]}
| |
||g7 } qrW nz|d t krxl|D ]>}
t |
t kst | j
| jjdt |
| ||
g7 } qW n$xN|D ]}
| ||
|d g7 } qW n*|t kr$|||d< n||||d< n|
|||d< | jt@ rd|dt| g7 }|S )zv
Convert the result of a method call to it's dictionary representation.
tc is a TypeConverter
)r
servicenumberr* Nr4 r zAttachment expected got: %szResponseDict:%s)r! r r6 r Z_rtyper r tuplecountr __dict__r ZAttachmentExpectedr r r Zadd_attachmentZto_unicode_stringr ZLOG_RESPONSE_DICTr& ) r r* r4 r response_attachmentsr, res_dicttypr/ Z result_listr0 r r r result_to_dictj s<
zDispatcher.result_to_dictc
C s g }yt |d< d\}}y d|kr6d|kr6|dd}W n Y nX | jj|| jd}tjrhtd| |d }| j |}|st
| j | jj d | t
|j|j| j d
}| |||||}W n tk
rd } z||d d }
t| tr | jj| || j|
d } nH|d kr6| jjtt| || j|
d } n | jjtt| || j|
d } | S d } ~ X Y nX t|trv|S | j||||d |d
} d |kr|d | d< d|kr|d | d< | jj | | jd} | j rt dd | | S )Nr: )NNs 1 &s &)encodingzdispatch_request=r z.Service method "%s" is not declared in service)r? Zallow_unsafe_conversionZonly_strings_to_unicodeZmirror)r?
reflection)r, r@ idz %s ) r replacer Z
parse_requestr r DEBUGprintr r* r r r r Z _encodingZ_allow_unsafe_conversionZstringify_res_dictr5 Exceptionget
isinstanceZ ServiceFaultZbuild_fault_responseZ ClientFaultr& Z ServerFaultr
r= Zbuild_responser r join)
r Z request_datar r, r r* r+ r r4 er@ Zresponser; r r r dispatch_request sX
zDispatcher.dispatch_requestN)__name__
__module__ __qualname____doc__r r5 r= rK r r r r r
s
A+r
)Z!mysite.ladon.ladonizer.collectionr Zmysite.ladon.typesr r Z mysite.ladon.types.attachmentr r Z mysite.ladon.types.typeconverterr Z"mysite.ladon.exceptions.dispatcherZ mysite.ladon.exceptions.serviceZ#mysite.ladon.tools.multiparthandlerr Z"mysite.ladon.server.customresponser
Zmysite.ladon.tools.logr osre tracebackr' Zmysite.ladon.serverZ django.confr objectr
r r r r s