Ñò :è¥Oc@s}ddklZddkZddkZddklZddklZd ZdZ e Z d„Z de fd „ƒYZdS( iÿÿÿÿ(texportedN(tsleepi(tzephyrtSubscriptionManagericCs\| p|ddjodS||idƒ idƒ}t|ƒdjo t|ƒSdS(Nit!t#t,i(tNonetfindtsplittlenttuple(tsttripplet((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pyt parse_subscBs¿eZddfZeid„Zd„Zd„Zed„ƒZ ee d„ƒZ ee d„ƒZ ee d „ƒZ ee d „ƒZee d „ƒZee d „ƒZed „ƒZRS(s%me%t*tmessagecCsbytiƒ|_Wn,tj o tdƒtiƒ|_nX||_||_|iƒdS(Ni(Rt Subscriptionst subscriptionstIOErrorRtusernametzsubfiletload_or_create_zsubs(tselfRR((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pyt__init__s   cCsPt|iddƒiiƒ}z'|~}|id„|iDƒƒWdQXdS(Ntwi€css&x|]}di|ƒdVqWdS(Rs N(tjoin(t.0tsub((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pys 's (topenRt__exit__t __enter__t writelinesR(Rt_[1]tf((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pytsave%s,c Csžtii|iƒp|i|iƒSt|iƒiiƒ}zT|~}xD|i ƒD]6}t |ƒ}|dj o|i |dt ƒqZqZWWdQXdS(NR#(tostpathtisfileRtsett DEFAULT_SUBSRRRt xreadlinesRRtaddtFalse(RR!R"tlineR((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pyR)s&   cCs t|iƒS(sGet a list of subscriptions.(tlistR(R((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pytget3scCsg|iƒy|ii|ƒWn-tj o!tdƒ|ii|ƒnX|o|iƒntS(sSet the subscriptions.i(tclearRtupdateRRR#tTrue(RRR#((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pyR'8s  cCscy|iiƒWn*tj otdƒ|iiƒnX|ot|idƒiƒntS(sClear the subscriptions.iR(RR/RRRRtcloseR1(RR#((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pyR/Js cCs—t|ƒ}y|ii|ƒWn[tj otStj o<tdƒy|ii|ƒWq~tj otSXnX|o|iƒntS(sRemove the given subscription.i( R RtremovetKeyErrorR+RRR#R1(Rt subscriptionR#((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pyR3Xs   c CsÀt|ƒ}||ijotSy|ii|ƒWn-tj o!tdƒ|ii|ƒnX|oPt|iddƒii ƒ}z'|~}|i di |ƒdƒWdQXndS(sAdd the given subscription.itai€Rs N( R RR+R*RRRRRRtwriteR(RR5R#R!R"((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pyR*ms  ,cCsˆ|id„|Dƒƒ}|pdSy|ii|ƒWn-tj o!tdƒ|ii|ƒnX|o|iƒnt|ƒS(sRemove all given subscriptions.cssx|]}t|ƒVqWdS(N(R (RR ((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pys ‚s Ni(t intersectionRtdifference_updateRRR#R (RRR#((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pyt removeAlls c CsÈtd„|Dƒƒ|i}|pdSy|ii|ƒWn-tj o!tdƒ|ii|ƒnX|oJt|idƒiiƒ}z$|~}|i d„|DƒƒWdQXnt |ƒS(sAdd all given subscriptions.cssx|]}t|ƒVqWdS(N(R (RR ((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pys ”s iiR6css&x|]}di|ƒdVqWdS(Rs N(R(RR((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pys ¡s N( R'RR0RRRRRRR R (RRR#R!R"((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pytaddAll‘s )!cCst|ƒ|ijS(s<Returns true if the user is subscribed to the given triplet.(R R(RR5((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pyt isSubscribed¤s(s%me%RR(smessageRs%me%(t__name__t __module__R(tsettingstZSUBSRR#RRR.tSAVER'R/R3R*R:R;R<(((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pyRs&    (sSubscriptionManager(tserverRR?R$ttimeRtRt__all__tTIMEOUTR+RARtobjectR(((sG/mit/zmobile/testing/lib/python2.6/site-packages/zserv/subscriptions.pyts