ó üR‹_c@sædZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z dZ ddZ ejejZd d „Zd e fd „ƒYZed krâe eejƒZejeƒndS(s^ Functional tests from version 1.1 of the sync storage protocol. This file is a copy of the functional tests from sync1.1, minimally edited to run against the sync1.5 server. They're here to help verify that sync1.1 clients can still sync successfully agains the sync1.5 server if they stick to the parts of the spec that were in use in practice. iÿÿÿÿN(tDecimal(tStorageFunctionalTestCase(trun_live_functional_testsit*iôi cCs/djgt|ƒD]}tjtƒ^qƒS(Nt(tjointrangetrandomtchoicet_ASCII(tsizeti((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pytrandtextstTestOldStoragecBséeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z d „Z d „Zd „Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„ZRS(cCstt|ƒjƒd|j|_|jj|jddidd6ƒx,dD]$}|jj|jd |gƒqNWxLtd ƒD]>}|jj |jdt |ƒidd6ƒt j dƒqƒWxLtdƒD]>}|jj |jdt |ƒidd6ƒt j dƒqÒWdS(Ns/1.5/%ds/storagetheaderst1sX-Confirm-Deletetclienttcryptotformsthistorytxxx_col1txxx_col2s /storage/is/storage/xxx_col1/txxxtpayloadg{®Gáz”?is/storage/xxx_col2/(RRRRRR( tsuperR tsetUptuser_idtroottapptdeletet post_jsonRtput_jsontstrttimetsleep(tselftnametitem((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyR%s "cCsk|jj|jdƒ}|j}|jƒ}|jt|ƒdƒ|jt|j dƒt|ƒƒdS(Ns/info/collectionsisX-Weave-Records( RtgetRtjsontkeyst assertTruetlent assertEqualstintR(R#tresptresR(((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_get_collections9s   cCso|jj|jdƒ}|j}|jƒ}|jƒ|j|ddgƒ|jt|jdƒdƒdS(Ns/info/collection_countsiisX-Weave-Recordsi( RR&RR'tvaluestsortR+R,R(R#R-R.R0((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_get_collection_count@s    cCsM|jj|jdƒ}|j}|j|gƒ|jj|jdƒ}|j}|jƒ|j|dddddgƒ|jt|jdƒd ƒ|jj|jd ƒ}|j}|jƒ|j|ddgƒ|jj|jdƒid d 6d d6}|jj |jd|ƒ}|j}tj |ƒ}t j dƒidd 6d d6}|jj |jd|ƒ}|j}tj |ƒ}|j ||kƒ|jj|jd|ƒ}|j}|j|dgƒ|jj|jdƒ}|j}|djƒ}|jƒd ddg} |j|| ƒ|jj|jdƒ}|j}|j t|tƒƒ|jj|jdƒg} x;tdƒD]-} it| ƒd 6d d6}| j|ƒq™W|jj|jd| ƒ|jj|jdƒ}|j}|jt|ƒdƒ|jj|jdƒ}|j}|j t|ƒdkƒ|jj|jdƒxbd"d#d$fD]Q\} } i| d 6d d6| d6}|jj|jd|gƒt j dƒq~W|jj|jd ƒ}|j}|j|dddgƒ|jj|jd!ƒ}|j}|j|dddgƒdS(%Ns /storage/col3s/storage/xxx_col2t0Rt2t3t4sX-Weave-Recordsis/storage/xxx_col2?ids=1,3t128tidtxRs/storage/xxx_col2/128g333333Ó?t129s/storage/xxx_col2/129s/storage/xxx_col2?newer=%ss/storage/xxx_col2?full=1itmodifiedi s/storage/xxx_col2?limit=2ii ii"i t sortindexgš™™™™™¹?s/storage/xxx_col2?sort=newests/storage/xxx_col2?sort=index(R3i(Ri"(R4i (RR&RR'R+R1R,RRRtdumpsR!R"R)R(t isinstancetlistRR tappendRR*(R#R-R.twbottstftstts2tfts2R(twantedtwbosR tindexR<((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_get_collectionHst                cCs|jj|jdƒ}|j|jjdƒddƒ|j}|jƒ|j|ddddd gƒ|jj|jdd dgƒ}|j|jjdƒdd ƒg|jj ƒjd ƒD]}tj |ƒ^qÆ}|jƒ|j|ddddd gƒdS(Ns/storage/xxx_col2t;isapplication/jsonR3RR4R5R6RtAcceptsapplication/newliness (RKsapplication/newlines( RR&RR+t content_typetsplitR'R1tbodytstriptloads(R#R.tline((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_alternative_formats§s    4 cCs†|jj|jdƒ}|j}|jƒ}|jƒ|j|dddgƒ|j|ddƒ|jj|jdddƒdS( Ns/storage/xxx_col2/1R8R;RRs/storage/xxx_col2/99tstatusi”(RR&RR'R(R1R+(R#R.R(((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyt test_get_itemºs   cCs¾itd6}|jj|jd|ƒ|jj|jdƒ}|j}|j|dtƒidd6}|jj|jd|ƒ|jj|jdƒ}|j}|j|ddƒdS(NRs/storage/xxx_col2/12345tYYY(t_PLDRRRR&R'R+(R#RAR.((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyt test_set_itemÆs    cCsêidd6td6}idd6td6}||g}|jj|jd|ƒ|jj|jdƒ}|j}|j|dtƒ|jj|jdƒ}|j}|j|dtƒidd6dd6}id d6td6}||g}|jj|jd|ƒ|jj|jd ƒ}|j}|j|dtƒ|jj|jdƒ}|j}|j|ddƒid d6td6}id d6td6d d6}||g}|jj|jd|ƒ|jj|jdddƒdS(Nt12R8Rt13s/storage/xxx_col2s/storage/xxx_col2/12s/storage/xxx_col2/13tXyXt14s/storage/xxx_col2/14tonettwotFAILR<s/storage/xxx_col2/twoRSi”(RVRRRR&R'R+(R#twbo1twbo2RGR.((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_set_collectionÕs4        cCsÐ|jj|jdddgƒidd6dd6}id d6td6}||g}|jj|jd |ƒ|jj|jd ƒ}|j}|d }t|dƒt|dƒ}|j||d ƒdS(Ns/storageRsX-Confirm-DeleteRRYR8RZRR[s/storage/xxx_col2s/info/collection_usageRg@(sX-Confirm-DeleteR( RRRRVRR&R'R*t assertEqual(R#R_R`RGR.tusaget xxx_col2_sizeRF((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_collection_usageús    cCs§|jj|jdƒidd6td6}idd6td6}idd6td6}|||g}|jj|jd|ƒ|jj|jdƒ}|jt|jƒdƒ|jj|jdƒ|jj|jdƒ}|jt|jƒdƒ|jj|jd|ƒ|jj|jd ƒ|jj|jdƒ}|jt|jƒd ƒ|jj|jd ƒ|jj|jdƒ}|jt|jƒdƒdS( Ns/storage/xxx_col2RXR8RRYR[iis/storage/xxx_col2?ids=12,14is/storage/xxx_col2?ids=13( RRRRVRR&R+R*R'(R#R_R`twbo3RGR.((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_delete_collection s$cCs|jj|jdƒidd6td6}idd6td6}idd6td6}|||g}|jj|jd|ƒ|jj|jdƒ}|jt|jƒdƒ|jj|jdƒ|jj|jdƒ}|jt|jƒd ƒ|jj|jd d d ƒdS( Ns/storage/xxx_col2RXR8RRYR[is/storage/xxx_col2/13is/storage/xxx_col2/12982RSi”( RRRRVRR&R+R*R'(R#R_R`RfRGR.((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_delete_item'scCsí|jj|jdƒidd6td6}idd6td6}idd6td6}|||g}|jj|jd|ƒ|jj|jdƒ}|jt|jƒdƒitd6}|jj |jd|ƒ|jj |jd |ƒ|jj|jdƒ}|j|jdtƒ|jj|jd ƒ}|j|jdtƒ|jj|jd d dgƒ}tj |j ƒ}|jj|jdƒj}|j|gƒ|jj|jdddƒ|jj|jd ddƒdS(Ns/storage/xxx_col2RXR8RRYR[is/storage/meta/globals/storage/tabs/homes/storageRsX-Confirm-DeleteRRSi”(sX-Confirm-DeleteR( RRRRVRR&R+R*R'RRPRN(R#R_R`RfRGR.RAtitems((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_delete_storage<s,  cCsQ|jr dStjƒ}|jj|jdƒ}t|t|jdƒƒ}|j|dkƒit d6}tjƒ}|jj |jd|ƒ}t|t|jdƒƒ}|j|dkƒidd6t d6}id d6t d6}||g}tjƒ}|jj |jd|ƒ}|jt|t|jdƒƒdkƒdS( Ns/storage/xxx_col2sX-Weave-Timestampgš™™™™™¹?Rs/storage/xxx_col2/12345gš™™™™™É?i R8i ( tdistantR!RR&RtabstfloatRR)RVRR(R#tnowR.tdiffRAR_R`RG((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_x_weave_timestamp]s$       cCsxitd6}|jj|jd|ƒ}tj|jƒd}|jj|jd|ddt|ƒfgddƒdS(NRs/storage/xxx_col2/12345ièRsX-If-Unmodified-SinceRSiœ(RVRRRR'RPRNR (R#RARB((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_ifunmodifiedsincevs  cCs™|jj|jdƒ}|j\}}itd6}|jj|jd|ƒ|jj|jdƒ}|j\}}|j||ttƒdƒdS(Ns /info/quotaRs/storage/xxx_col2/12345g@(RR&RR'RVRR+R*(R#R.told_usedtquotaRAtused((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyt test_quota~s cCsq|jj|jdƒitd6dd6}|jj|jd|ƒ}tjdƒ|jj|jdƒ}|j|j gƒitd6dd6}|jj|jd|ƒ}|jj|jdƒ}|jt |j ƒd ƒ|jj|jd|ƒ|jj|jdƒ}|jt |j ƒd ƒtjd ƒ|jj|jdƒ}|jt |j ƒdƒdS( Ns/storage/xxx_col2Ritttls/storage/xxx_col2/12345gš™™™™™ñ?is/storage/xxx_col2/123456igÍÌÌÌÌÌ@( RRRRVRR!R"R&R+R'R*(R#RAR.((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_get_collection_ttl‡s   cCsgtdƒD] }it|ƒd6td6^q }|jj|jd|ƒ}|j}d}x8|D]0}|jj|jd|tƒfd d ƒqeWd j gtd ƒD]}tdƒ^q¬ƒ}|jj|jd |ƒ}|j |jgƒ|jj|jdd dƒdS(Ni R8Rs/storage/xxx_col2tnewertlimittoffsets/storage/xxx_col2?%s=%sRSit,ids/storage/xxx_col2?ids=%ss/storage/xxx_col2?blabla=1iÈ(RxRyRz( RR RVRRRR'R&R RR+(R#R RGR.targstargtids((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_weird_argsŸs3   .cCsÑgtdƒD]}id|d6td6^q }|jj|jd|ƒ}|j}djgtdƒD]}d|^qiƒ}|jj|jd|ƒ|jj|jd|ƒ}|j |jgƒdS( Nis'{6820f3ca-6e8a-4ff4-8af7-8b3625d7d65%d}R8Rs/storage/passwordsR{is/storage/passwords?ids=%s( RRVRRRR'RRR&Rb(R#R RGR.R~((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_guid_deletionµs.  #cCs!|jj|jdddƒdS(Ns'/info/collections?client=FxHome&v=1.1b2RSiÈ(RR&R(R#((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyt test_metricsÅsc Cs…|jj|jdƒ}tj|jdtƒ}g}tdƒ}xu|D]m}|d}y|j||j |ƒƒWn0t k r©d}||j7}t |ƒ‚nX|j |ƒqJW|j ƒt|dƒ}|jj|jd|ƒ} | j} | j ƒy|j| dd gƒWn_t k r€d |}|d |jj|jdƒj7}|d t|ƒ7}t |ƒ‚nXdS( Ns/storage/xxx_col2?full=1t use_decimals1.00R;scould not quantize iýÿÿÿs/storage/xxx_col2?newer=%sR5R6sStamp used: %st s Stamps received: %s(RR&RR'RPRNtTrueRRbtquantizet BaseExceptiontAssertionErrorR@R1RmR+R ( R#R-RGtstampst two_placeRAtstamptmsgRBR.((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyt test_roundingÊs4          cCsidd6td6}idd6td6}||g}|jj|jd|ƒ}tj|jdtƒd}tj dƒid d6td6}id d6td6}||g}|jj|jd|ƒ}|jj |jd |ƒ}|j}|j ƒ|j |d d gƒdS( NRR8RR4s/storage/xxx_mehR‚R;gš™™™™™É?R5R6s/storage/xxx_meh?newer=%s( RVRRRR'RPRNR„R!R"R&R1R+(R#R_R`RGR.RBRftwbo4((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_strict_newerõs     cCsidd6td6}idd6td6}||g}|jj|jd|ƒ}tj|jdtƒd}tj dƒid d6td6}id d6td6}||g}|jj|jd|ƒ|jj |jd |ƒ}|j}|j ƒ|j |d d gƒdS( NRR8RR4s /storage/tabsR‚R;gš™™™™™É?R5R6s/storage/tabs?newer=%s( RVRRRR'RPRNR„R!R"R&R1R+(R#R_R`RGR.RBRfR((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_strict_newer_tabs s     cCsdd}|jj|jd|ddƒ}|jt|jƒtƒd}|jj|jd|ddƒ}|jt|jƒtƒiddgd6id d 6d 6}|jj|jd|ddƒ}|jt|jƒtƒd }|jj|jd |ddƒ}|jt|jƒtƒd}|jj|jd |ddƒ}|jt|jƒtƒdS(Ntnotawbos/storage/xxx_col2/invalidRSii*RR4R8R6R5Rtnotalists/storage/xxx_col2(RRRR+R,RNtWEAVE_INVALID_WBOR(R#RAR.RG((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyttest_handling_of_invalid_json%s(  !   cCs©idd6dd6}|jj|jd|ƒ}xrtdƒD]d}|jj|jdƒj}|jj|jd|ƒ}|jt|jƒt|j dƒƒq=WdS(NtTESTR8tDATARs/storage/xxx_col2/TESTiÈsX-Weave-Timestamp( RRRtxrangeR&R'R+RmRNR(R#RAR.R ((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyt+test_that_put_reports_consistent_timestampsGscCsŠidd6dd6}|jj|jd|ƒtjdƒ|jj|jdddƒidd6d d6}|jj|jd|ƒdS( NtXYZRiRvs/storage/xxx_col2/TESTg{®Gáz”?RSi”i*(RRRR!R"R&(R#tbso((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyt2test_that_expired_items_can_be_overwritten_via_PUTSs  (t__name__t __module__RR/R2RIRRRTRWRaReRgRhRjRpRqRuRwRR€RRŒRŽRR“R—Rš(((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyR #s2    _   %    !       +   " t__main__(t__doc__tsysR!Rtstringt simplejsonR'tdecimalRt$syncstorage.tests.functional.supportRRR’RVt ascii_letterstdigitsR R R R›targvR.texit(((sf/var/www/syncserver/local/lib/python2.7/site-packages/syncstorage/tests/functional/test_old_storage.pyt s$       ÿÿ>