ó ÃæX^c@sžddlmZddlmZddljZddlZddd„ƒYZddd„ƒYZddd „ƒYZ d dd „ƒYZ d dd „ƒYZ dS(iÿÿÿÿ(tetree(t SimpleLoggerNt DataContainercBsbeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z RS( cCsgg|_d|_d|_d|_tjdƒ|_d|_d|_ t |_ t |_ t |_ dS(Ntresponse(t timestampDatatNonetjobIdtloggerIdtauthRtElementtresponseRootNodetresponseTypeNodet missingValuetFalsetinvalidXMLFlagt bulk_insertt overwrite(tself((s3/var/www/titaniumci/src/containers/DataContainer.pyt__init__s        cCs‚tj|ƒ}|jdƒ}|dks6|gkrH|jdƒ}n|jddƒjƒdkrltnt|_|jddƒjƒdkr™tnt|_ |jddƒjƒdkrÆtnt|_ |jdƒ|_ |j d krýd|_ dS|j dkrt|_ dS|jd ƒ|_|jd krGd |_ dS|jdkrct|_ dSx|D]}tƒ}|j|ƒ|j r¬tjjd ƒt|_ dS|j dkrþtjjd |j jƒƒ|j|jd |j jƒƒqjn|jikrjxZ|jjƒD]F\}}tjjd |jƒƒ|j|j|d |jƒƒqWn|jj|ƒqjWdS(Ns .//setDatas .//setdataRtfalsettruetbulkt ignoreVersiontslidtRt INVALID_XMLt MISSSING_tMISSING_(Rt fromstringtfindRtgettlowertTrueR RRtignore_versionRR RRt TimestampDatat readFromXMLtsettingstloggerterrortuppertresponseAppendDataNodet timestamptmissingDeviceDatatitemstresponseAppendDeviceNodeRtappend(RtxmlMsgtroottsetDatatdttsdatatktv((s3/var/www/titaniumci/src/containers/DataContainer.pytreadSetXMLRequestsL---          'cCstj|ƒ}dS(N(RR(RR.R/((s3/var/www/titaniumci/src/containers/DataContainer.pytreadGetXMLRequestMsc Cs x|jD]}d|jd}|jj|ƒ}|gkrjtjdd|jƒ}|jj|ƒn |d}x¡|jD]–}tjdd|jƒ}|j|j |jgƒkrÒtjdd d ƒ}n(tjdd ||jj |jƒƒ}|j|ƒ|j|ƒq~Wq WdS( Ns //data[@ts='s']tdatattsitdevicetsdidtstatustcodetSUCCESS( RR)R txpathRR R-t deviceDatatdeviceIdR( Rt listDBErrorsttsDatatsstrt dataNodeListtdataNodetdevR1tsc((s3/var/www/titaniumci/src/containers/DataContainer.pytwriteXMLSetResponseQs  ( cCsdS(N((R((s3/var/www/titaniumci/src/containers/DataContainer.pytwriteXMLGetResponsehscCstj|ƒ|_dS(N(RR R (RtrespType((s3/var/www/titaniumci/src/containers/DataContainer.pytsetResponseTypelscCs#tj|ƒ}|jj|ƒdS(N(RR R R-(RR8R7((s3/var/www/titaniumci/src/containers/DataContainer.pyR(pscCsŽtjdd|ƒ}tjdd|ƒ}|j|ƒ|jjdƒ}|gkr}tjdd|ƒ}|jj|ƒn|j|ƒdS(NR9R:R;R<s//data[@ts=ts]R7R8(RR R-R R>(RR8R:R<t deviceNodet statusNodeRE((s3/var/www/titaniumci/src/containers/DataContainer.pyR,us  cCs)tjdd|ƒ}|jj|ƒdS(NR;R<(RR R R-(RR<t statusCode((s3/var/www/titaniumci/src/containers/DataContainer.pytresponseAppendStatusCodeNodescCs#|jj|jƒtj|jƒS(N(R R-R Rttostring(R((s3/var/www/titaniumci/src/containers/DataContainer.pytgetResponseMsg…s( t__name__t __module__RR5R6RHRIRKR(R,RORQ(((s3/var/www/titaniumci/src/containers/DataContainer.pyRs  1      R"cBseZdd„Zd„ZRS(cCs:||_g|_d|_i|_t|_g|_dS(N(R)R?RR R*R RtinvalidXMLDeviceData(RR)((s3/var/www/titaniumci/src/containers/DataContainer.pyRs      cCsó|jdƒ}|dkr(d|_dS|dkrAt|_dStjj|dƒ}|jddƒ}|jdƒ|_ xr|D]j}t ƒ}|j |ƒ|jdkrÅ|j|j |j s …'0