import pprint
import logging
+import util.coroutines as coroutines
import gvoice.backend as backend
import gvoice.conversations as conversations
+@coroutines.func_sink
+@coroutines.expand_positional
+def updates(conv, ids):
+ print ids
+
+
def main():
logging.basicConfig(level=logging.DEBUG)
b = backend.GVoiceBackend()
b.login(username, password)
- c = conversations.Conversations(b)
-
- c.update(force=True)
- for key in c.get_conversations():
- print "="*50
- print key
- for conv in c.get_conversation(key).conversations:
- pprint.pprint(conv.to_dict())
+ c = conversations.Conversations(b.get_texts)
+ c.updateSignalHandler.register_sink(updates)
+
+ c.load("/home/epage/.telepathy-theonering/cache/eopage/texts.cache")
+ if True:
+ c.update(force=True)
+ else:
+ c.update(force=False)
+ if False:
+ for key in c.get_conversations():
+ print "="*50
+ print key
+ for conv in c.get_conversation(key).conversations:
+ pprint.pprint(conv.to_dict())
if __name__ == "__main__":