ó ç'ÊUc@s—ddlmZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z ddl mZmZddlmZddlmZmZmZddlmZed'krèd „Zndd lmZded „Zdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZ defd„ƒYZ!defd„ƒYZ"defd„ƒYZ#de#fd„ƒYZ$defd„ƒYZ%d d(d!„ƒYZ&e'd"kr“e%ƒZ(ee(ƒZ)ej*d#e)ƒZ+ej,ej-j.ej-j/e0ƒd$ƒej-j.ej-j/e0ƒd$ƒƒZ1ej2d%e)e1ƒZ3d&„Z4ej5e4ƒej6ƒndS()iÿÿÿÿ(tprint_functionN(t urlencode(tPopentPIPE(tSitet NOT_DONE_YET(tResource(treactortdefertssl(ttwisted_versioni ics{‡‡fd†}‡fd†‰tjƒ‰|ˆ_ˆj‡‡‡fd†ƒˆjˆƒ|j|ˆjdƒ‰ˆS(NcsˆdƒˆjtƒƒdS(N(tNoneterrbackt Exception((t _cancel_cbtd(s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyt_cancel_methods csˆjƒrˆjƒn|S(N(tactivetcancel(tresult(tcl(s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRs  cs ˆˆˆŽS(N((tignored(targstfunctkw(s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyts(RtDeferredRt addCallbacktaddBotht callLatertcallbackR (tclocktdelayRRRR((RRRRRRs4/home/travis/build/scrapy/scrapy/tests/mockserver.pyt deferLater s   (R!cCs,||jkr$||j|dƒS|SdS(Ni(R(trequesttnametdefaultttype((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pytgetarg!st LeafResourcecBseZeZd„ZRS(cs>‡fd†}tt||||Ž‰|jƒj|ƒˆS(Ncsˆjd„ƒˆjƒdS(NcSsdS(N(R (t_((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyR/s(t addErrbackR(R((R(s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyt_cancelrequest-s(R!Rt notifyFinishR)(tselfR"R tftaRR*((Rs4/home/travis/build/scrapy/scrapy/tests/mockserver.pyt deferRequest,s(t__name__t __module__tTruetisLeafR/(((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyR'(stFollowcBseZd„Zd„ZRS(c Csût|dddtƒ}t|dddtƒ}t|ddƒ}t|dd dtƒ}t|d |dtƒ}|d kr¬gt|ƒD]}tjd|ƒ^q‹}nt|t||d ƒd ƒ}tjƒ|} |j|| |j||ƒt S( NttotalidR%tshowitordertdesct maxlatencyitntrandiÿÿÿÿ( R&tinttfloattrangetrandomtrandinttmaxR/t renderRequestR( R,R"R5R6R7R9R:R(tnlisttlag((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pytrender9s .cCs„d}|jjƒ}xG|D]?}t|ƒg|d R:tdoseqs&follow %d
s(RtcopytstrRR2twritetfinish(R,R"RCtsRtnltargstr((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRBHs   (R0R1RERB(((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyR47s tDelaycBseZd„Zd„ZRS(cCsft|dddtƒ}t|dddtƒ}|rF|jdƒn|j|||j||ƒtS(NR:iR%tbt(R&R=R<RIR/t_delayedRenderR(R,R"R:RO((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyt render_GETVs cCs|jd|ƒ|jƒdS(Ns#Response delayed for %0.3f seconds (RIRJ(R,R"R:((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRQ_s(R0R1RRRQ(((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRNTs tStatuscBseZd„ZRS(cCs)t|dddtƒ}|j|ƒdS(NR:iÈR%RP(R&R<tsetResponseCode(R,R"R:((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRRfs (R0R1RR(((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRSdstRawcBs eZd„ZeZd„ZRS(cCs&d|_|j|d|j|ƒtS(Nii(tstartedWritingR/RQR(R,R"((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRRns cCsFt|ddƒ}d|_|j|ƒ|jjjƒ|jƒdS(NtrawsHTTP 1.1 200 OK i(R&RVRItchannelt transporttloseConnectionRJ(R,R"RW((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRQts   (R0R1RRt render_POSTRQ(((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRUls tEchocBseZd„ZRS(cCs9it|jjƒƒd6|jjƒd6}tj|ƒS(Ntheaderstbody(tdicttrequestHeaderstgetAllRawHeaderstcontenttreadtjsontdumps(R,R"toutput((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRR~s(R0R1RR(((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyR\|stPartialcBseZd„Zd„ZRS(cCs-|jddƒ|j|d|j|ƒtS(NsContent-Lengtht1024i(t setHeaderR/RQR(R,R"((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRRˆscCs|jdƒ|jƒdS(Nspartial content (RIRJ(R,R"((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRQs (R0R1RRRQ(((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRg†s tDropcBseZd„ZRS(cCsst|dddtƒ}|jdƒ|jj}z0|rVt|dƒrV|jƒn |jƒWd|jƒXdS(NtabortiR%s this connection will be dropped tabortConnection( R&R<RIRXRYthasattrRlRZRJ(R,R"Rkttr((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRQ”s   (R0R1RQ(((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRj’stRootcBs#eZd„Zd„Zd„ZRS(cCstj|ƒ|jdtƒƒ|jdtƒƒ|jdtƒƒ|jdtƒƒ|jdtƒƒ|jdtƒƒ|jdt ƒƒt j rt dkrd d l m}d d lm}d dlm}|jd|ƒƒ|jd||ƒ|ƒgƒƒndS(NtstatustfollowR tpartialtdropRWtechoi iiiÿÿÿÿ(tPayloadResource(tGzipEncoderFactory(tEncodingResourceWrappertpayloadtxpayload(i ii(Rt__init__tputChildRSR4RNRgRjRUR\tsixtPY2R ttwisted.web.test.test_webclientRuttwisted.web.serverRvttwisted.web.resourceRw(R,RuRvRw((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRz£s cCs|S(N((R,R#R"((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pytgetChild´scCsdS(NsScrapy mock HTTP server ((R,R"((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRE·s(R0R1RzRRE(((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyRo¡s  t MockServercBseZd„Zd„ZRS(cCsQddlm}ttjdddgdtd|ƒƒ|_|jjjƒ|S(Niÿÿÿÿ(t get_testenvs-us-mstests.mockservertstdouttenv( tscrapy.utils.testRƒRtsyst executableRtprocR„treadline(R,Rƒ((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyt __enter__½s cCs+|jjƒ|jjƒtjdƒdS(Ngš™™™™™É?(R‰tkilltwaitttimetsleep(R,texc_typet exc_valuet traceback((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyt__exit__Äs  (R0R1R‹R“(((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pyR‚»s t__main__i&#s keys/cert.pemi'#cCsBtjƒ}tjƒ}td|j|j|j|jfƒdS(Ns5Mock server running at http://%s:%d and https://%s:%d(thttpPorttgetHostt httpsPorttprintthosttport(thttpHostt httpsHost((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pytprint_listeningÔs  (i ii((7t __future__RR‡RŽR?tosRdR|tsix.moves.urllib.parseRt subprocessRRRRRR€Rttwisted.internetRRR tscrapyR R!ttwisted.internet.taskR RHR&R'R4RNRSRUR\RgRjRoR‚R0troottfactoryt listenTCPR•tDefaultOpenSSLContextFactorytpathtjointdirnamet__file__tcontextFactoryt listenSSLR—RtcallWhenRunningtrun(((s4/home/travis/build/scrapy/scrapy/tests/mockserver.pytsB<        $