Ñò @ó¥Oc@s7ddkZddklZddkZddkZddkZddklZddkl Z ddk l Z l Z ddk l Z ddklZddkZdd klZeid d „ƒeieƒZdZd„Zd„Zd„Zd„Zd„Zd efd„ƒYZd e fd„ƒYZdS(iÿÿÿÿN(texported(tizip(twraps(tThreadtRLock(ttime(tdatetimei(tzephyrtBOOLcCs |djS(t0((tv((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytstFiltert Messengercstˆƒ‡fd†ƒ}|S(Ncs/|iiiƒzˆ|||ŽSWdQXdS(N(tlockt__exit__t __enter__(tselftargstkwargs(tfunc(sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytdos(R(RR((RsC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytsyncscstˆƒ‡fd†ƒ}|S(Nc s~|iiiƒzcy4|iiƒˆ|||Ž}|iiƒ|SWn(tj o}|iiƒ|‚nXWdQXdS(N(RRRtdbtcommitt BaseExceptiontrollback(RRRtrte(R(sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyRs   (R(RR((RsC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyt transactions cCsŒ|djo:tii|ƒp#titi|tidƒƒqGnti|dtidt ƒ}d„|_ |i dƒ|i ƒ|S(sÆ Either open an existing db or create a new one. Arguments: path - the path to the database. the database does not need to exist but the parent directory must. s:memory:i€t detect_typestcheck_same_threadcSs ttd„|iDƒ|ƒƒS(cssx|]}|dVqWdS(iN((t.0tc((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pys >s (tdictRt description(tcursortrow((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyR >ssCREATE TABLE IF NOT EXISTS messages ( id INTEGER NOT NULL PRIMARY KEY, sender TEXT NOT NULL, auth BOOL NOT NULL DEFAULT 1, signature TEXT NOT NULL DEFAULT "", message TEXT NOT NULL, read BOOL NOT NULL DEFAULT 0, cls TEXT NOT NULL DEFAULT "message", instance TEXT NOT NULL DEFAULT "personal", user TEXT DEFAULT NULL, timestamp TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP )( tostpathtisfiletclosetopentO_CREATtsqlite3tconnecttPARSE_DECLTYPEStFalset row_factorytexecuteR(R'R((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytopen_or_create_db(s '   cCsdd|ddS(Nt(s?,is?)((tnum((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyt gen_paramsNscCs|S(((tx((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyR RscBseZdZd&Zhedfd6edfd 6ed fd 6ed fd 6edfd6d„dfd6edfd6edfd6Zed„ƒZd„Z d„Z ddd„Z ddd„Z d„Z d„Zd „Zddd!„Zd"„Zd#„Zddd$„Zddd%„ZRS('sS A filter that is an or of its clauses anded with its parent (recursivly). tfidt_objst _query_listt_wheret_dnfscls=?tclss instance=?tinstancesuser=?tuserssender=?tsendersread=?treadcCs d|dS(t%((tm((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyR bssmessage LIKE ?tmessages timestamp > ?tafters timestamp < ?tbeforecCsdid„|DƒƒS(Ns OR css"x|]}di|ƒVqWdS(s AND N(tjoin(R R!((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pys is (RF(tdnf((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytparseDNFgscs×ttd„|Dƒƒƒˆ_| p h|jo:ttƒƒˆ_dˆ_dˆ_dˆ_dˆ_nft‡fd†|DƒŒ\ˆ_ˆ_t ˆit ƒƒˆ_ˆi ˆiƒˆ_dˆiˆ_dS(sýInitialize a new Filter Arguments: f - a filter {"field": "value", ... } Filter clause: { field: field-name, regex: bool, value: search-value, } css%x|]}t|iƒƒVqWdS(N(t frozensett iteritems(R tclause((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pys xs tc3s?x8|]1}td„‡fd†|iƒDƒDƒŒVqWdS(css1x*|]#\\}}}||ƒ|fVqWdS(N((R tttlR ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pys ƒs c3s,x%|]\}}ˆi||fVqWdS(N(tFIELDS(R tfR (R(sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pys „s N(RRJ(R RK(R(sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pys ‚s s WHERE N((( thashRIR7R8R9R:tNoneR;RtsumttupleRH(Rtclauses((RsC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyt__init__ls      cCs|iS(N(R7(R((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyt__hash__ŒsiiÿÿÿÿcCs*|id||if|i||fƒS(Ns7%s FROM messages %s ORDER BY timestamp LIMIT ? OFFSET ?(R1R:R8(RRtactiontoffsettperpage((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyt applyQueryscCs|i|d||ƒiƒS(NsSELECT *(R[tfetchall(RRRYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytget•scCs|id|i|iƒiS(NsDELETE FROM messages(R1R:R8trowcount(RR((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytdelete˜scCs|id|i|iƒiS(NsUPDATE messages SET read=1(R1R:R8R^(RR((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytmarkRead›scCs|id|i|iƒiS(NsUPDATE messages SET read=0(R1R:R8R^(RR((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyt markUnreadžscCs |i|d||ƒiƒdS(NsSELECT count(*) AS totalttotal(R[tfetchone(RRRYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytcount¡scCs:d|i}|i||iƒiƒ}|d|dfS(s5 Returns (unread_count, total_count) sê SELECT count(*) AS total, count(unread) AS unread FROM ( SELECT nullif(read, 1) AS unread FROM messages %s ) tunreadRb(R:R1R8Rc(RRtquerytresult((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytcounts¤s cCs´|i|ƒ\}}|djo d|fS|iod|i}nd}d|}|iod|i|f}n d|}d|}|i||id ƒiƒd |fS( sÍ selects the offset of the oldest unread zephyr using a query similar to SELECT count(*) AS offset FROM messages WHERE col1=val1 AND col2=val2 AND timestamp < ( SELECT timestamp FROM messages WHERE col1=val1 AND col2=val2 AND read=0 ORDER BY timestamp LIMIT 1 ) If there are no unread messages, uses -1 Returns (offset, total_count) iiÿÿÿÿs(%s) AND read=0sread=0sOSELECT timestamp FROM messages WHERE (%s) AND read=0 ORDER BY timestamp LIMIT 1s(%s) AND timestamp < (%s)stimestamp < (%s)s0SELECT count(*) AS offset FROM messages WHERE %siRY(RhR;R1R8Rc(RRReRbtsubquery_wheretsubqueryt query_whereRf((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytoldestUnreadOffset³s       cCs5g}|i|d||ƒD]}||dq~S(Ns SELECT idtid(R[(RRRYRZt_[1]ti((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytgetIDsÖscCs8ht|iƒd6|i|||ƒd6|d6|d6S(NtfiltertmessagesRZRY(tstrR7R](RRRYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytfilterResponseÚs (sfids_objss _query_lists_wheres_dnf(t__name__t __module__t__doc__t __slots__trettintROt staticmethodRHRVRWR[R]R_R`RaRdRhRlRpRt(((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyR Us0            #cBs6eZeid„Zd„Zd„Zed„ƒZed„ƒZ e e dddd„ƒƒZ e d„ƒZe e d d d „ƒƒZe e dd „ƒƒZe ed „ƒƒZe ed d d„ƒƒZe d d d„ƒZe ed d d„ƒƒZe ed d d„ƒƒZe d„ƒZe ed„ƒƒZe ed„ƒƒZe edd d d„ƒƒZd„Ze e d d d„ƒƒZe e d d d„ƒƒZe e d d d„ƒƒZe e d d d„ƒƒZe e d d d„ƒƒZe e dd„ƒƒZ e e d„ƒƒZ!RS(cCsDtt|ƒiƒt|ƒ|_||_h|_tƒ|_dS(N( tsuperR RVR2RtusernametfiltersRR(RR}tdb_path((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyRVãs   cCsQx=to5tidtƒ}|djoPn|i|ƒqWtidƒdS(NtblocksStopping receiving thread.(tTrueRtreceiveRRt store_znoticetloggertinfo(Rtz((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytrunês cCstiƒ|iƒdS(N(Rt interruptRF(R((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytquitòs cGs|iidt|ƒƒS(s Stores a message and returns its ID. >>> messenger = Messenger("ME", ":memory:") >>> messenger.store_messages( >>> ("SENDER", "MESSAGE", "CLASS", "INSTANCE", "USER"), >>> ("SENDER", "MESSAGE2", "CLASS", "INSTANCE", "USER") >>> ) sQINSERT INTO messages(sender, message, cls, instance, user) VALUES (?, ?, ?, ?, ?)(Rt executemanytiter(RRr((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytstore_messages÷s c Cs*|idjodS|iodSd}d}t|iƒdjo|id}n5t|iƒdjo|id}|id}n|iidt|iddƒ|it|ddƒt|ddƒt|i ddƒt|i ddƒt|i ddƒpdt i|iptƒƒfƒS(NiRLiisvINSERT INTO messages(sender, auth, signature, message, cls, instance, user, timestamp) VALUES (?, ?, ?, ?, ?, ?, ?, ?)sutf-8treplace(tkindtopcodetlentfieldsRR1tunicodeR?tauthR<R=t recipientRRRt fromtimestampR(Rtznoticetmsgtsig((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyRƒs*   RCtpersonalc Cs]tid|d|d|ddtidƒ|fƒ}|iƒ|o|i|ƒntS(sJ Send a zephyr. Arguments: message - The message content cls - the message class (defaults to "message") instance - the message instance (defaults to "personal") user - the destination user (None means everyone) >>> messenger = Messenger("ME", ":memory:") # Send a message to -c help -i linux >>> messenger.send("This is a really short message.", "help", "linux") # Send a message to bsw >>> messenger.send("This is a really short message.", "message", "personal", "bsw") R<R=R”RCs%s%st signature(RtZNoticet preferencest getVariabletsendRƒR(RRCR<R=R>R–((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyRž$s  cGs)t|Œ}||i|i>> fid = messenger.filterMessages({"cls": "help", "read": False}) # Get the messages that match the filter >>> messenger.get(fid) (R R~R7Rs(RtmessageFiltersRP((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytfilterMessagesCs iiÿÿÿÿcCs#|it|ƒi|i||ƒS(sž Get the messages that match fid. Arguments: fid - the filter's ID offset - the first item to return from the matched messages. A negitive offset will index backwards. perpage - The maximum number of of results to return. Passing a negative number returns all results. >>> from . import subscriptions >>> m = Messenger(subscriptions.SubscriptionManager("ME"), "ME") >>> m.store_message( >>> message = { >>> "id": int, >>> "timestamp": int, >>> "cls": str, >>> "instance": str, >>> "message": str, >>> "user": str, # the destination user >>> "sender": str # the sender >>> } # Returns: >>> return_value = { >>> "filter": int, # The filter used to generate the result. >>> "offset": int, # The offset of the first result returned. >>> "perpage": int, # The number of results requested. >>> "messages": list # A list of message dictionaries. >>> } (R~RzRtR(RR7RYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyR]Ys"cCstS(sh Returns True if there is a message that matches messageFilter newer than last. (R(Rtlastt messageFilter((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pythasNew~scCs8|pdS|iidtt|ƒƒt|ƒƒiS(sQ Deletes the given messages. Returns the number deleted. is!DELETE FROM messages WHERE id IN (RR1R5RRTR^(Rtids((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyR_ˆscCsh|djp |djo-|i|it|ƒi|i||ƒƒS|it|ƒi|iƒSdS(sf Delete the messages that match the given filter. Returns the number deleted. iN(R_R~RzRpR(RR7RYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyt deleteFilter”s-cCs:|djo|i|ƒS|djo|i|ƒSdS(NR@Re(tmarkFilterReadtmarkFilterUnread(RtstatusR7RYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyt markFilter s  cCsh|djp |djo-|i|it|ƒi|i||ƒƒS|it|ƒi|iƒSdS(sE Mark all of the messages that match a filter with the given status. iN(R`R~RzRpR(RR7RYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyR¦§s-cCsh|djp |djo-|i|it|ƒi|i||ƒƒS|it|ƒi|iƒSdS(sE Mark all of the messages that match a filter with the given status. iN(RaR~RzRpR(RR7RYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyR§°s-cCs4|djo |iƒS|djo |iƒSdS(s" Mark the given messages as read. R@ReN(R`Ra(RR¨R¤((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytmarkºs   cCs8|pdS|iidtt|ƒƒt|ƒƒiS(Nis'UPDATE messages SET read=1 WHERE id IN (RR1R5RRTR^(RR¤((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyR`ÂscCs8|pdS|iidtt|ƒƒt|ƒƒiS(Nis'UPDATE messages SET read=0 WHERE id IN (RR1R5RRTR^(RR¤((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyRaÉscCs#|it|ƒi|i||ƒS(s9 Get all of the message ids that match the given filter. (R~RzRpR(RR7RYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyRpÐscsntidƒ‰tidƒ‰‡‡fd†}g}|D]}|||ƒq;~}|idd„ƒ|S(s8 Star and hide a given list of classes. sstarred-classesshidden-classescs,|dˆj|d<|dˆj|d<|S(NR<tstarredthidden((titem(tstarred_classesthidden_classes(sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytprocessàstkeycSs |d S(R«((R­((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyR æs(RœRtsort(RtclassesR°RnR!((R®R¯sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyt starAndHideÖs 'cCs"|iid|||fƒiƒS(sé List the instances with messages in a given class. Returns: [{ instance: instance, unread: unread_count, total: total_count, }, ] s- SELECT instance, COUNT(*) AS total, COUNT(unread) AS unread FROM (SELECT cls, instance, nullif(read, 1) AS unread, timestamp FROM messages) WHERE cls=? GROUP BY instance ORDER BY MAX(timestamp) DESC LIMIT ? OFFSET ? (RR1R\(RR<RYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyt getInstancesés cCs"|iid|||fƒiƒS(sé List the instances with messages in a given class. Returns: [{ instance: instance, unread: unread_count, total: total_count, }, ] s> SELECT instance, COUNT(*) AS total, COUNT(unread) AS unread FROM (SELECT cls, instance, read, nullif(read, 1) AS unread, timestamp FROM messages) WHERE cls=? AND read=0 GROUP BY instance ORDER BY MAX(timestamp) DESC LIMIT ? OFFSET ? (RR1R\(RR<RYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytgetUnreadInstancess cCs"|i|iid||fƒƒS(s  List the classes with messages. Returns: [{ cls: class, unread: unread_count, total: total_count, starred: true if the class is starred, }, ] s SELECT cls, COUNT(*) AS total, COUNT(unread) AS unread FROM (SELECT cls, nullif(read, 1) AS unread, timestamp FROM messages) GROUP BY cls ORDER BY MAX(timestamp) DESC LIMIT ? OFFSET ? (R´RR1(RRYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyt getClassesscCs"|i|iid||fƒƒS(s  List the classes with messages. Returns: [{ cls: class, unread: unread_count, total: total_count, starred: true if the class is starred, }, ] s  SELECT cls, COUNT(*) AS total, COUNT(unread) AS unread FROM (SELECT cls, read, nullif(read, 1) AS unread, timestamp FROM messages) WHERE read=0 GROUP BY cls ORDER BY MAX(timestamp) DESC LIMIT ? OFFSET ? (R´RR1(RRYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytgetUnreadClasses1scCs%|iiddd||fƒiƒS(s List the users that have sent personals. Returns: [ { sender: sender, unread: unread_count, total: total_count, }, ... ] s“ SELECT sender, COUNT(*) AS total, COUNT(unread) AS unread FROM ( SELECT sender, read, nullif(read, 1) AS unread, timestamp, cls, instance, user FROM messages WHERE user IS NOT NULL AND instance=? AND cls=? ) GROUP BY sender ORDER BY MAX(timestamp) DESC LIMIT ? OFFSET ? R™RC(RR1R\(RRYRZ((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyt getPersonalsKs cCsI|dj o|it|ƒi|iƒS|iidƒiƒdSdS(s1 Get the number of messages that match a filter. s&SELECT COUNT(*) AS total FROM messagesRbN(RRR~RzRdRR1Rc(RR7((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytgetCountfs cCs|it|ƒi|iƒS(sú Gets the offset of the oldest unread message that matches a filter, or -1 if there are no unread messages. Produces undefined behavior if the filter contains a condition on read. Returns (offset, total_count) (R~RzRlR(RR7((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pytgetOldestUnreadOffsetos N("RuRvtsettingst ZEPHYR_DBRVR‡R‰RRŒRƒRRRRRžR R]R£R_R¥R©R¦R§RªR`RaRpR´RµR¶R·R¸R¹RºR»(((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyR âsr  #   (sFilters Messenger(tloggingtserverRR¼RœR,t itertoolsRt functoolsRt threadingRRRRR&RLRtregister_convertert getLoggerRuR„t__all__RRR2R5RytobjectR R (((sC/mit/zmobile/testing/lib/python2.6/site-packages/zserv/messenger.pyts(      &