mirror of
https://github.com/kennethreitz-archive/python-convore.git
synced 2026-06-05 23:40:18 +00:00
Adi Sieker
ef36a7a07c
The live api call now returns a list of dicts.The dicts contain the kind and a corresponding object.
83 lines
2.2 KiB
Python
83 lines
2.2 KiB
Python
# -*- coding: utf-8 -*-
|
|
"""
|
|
convore.core
|
|
~~~~~~~~~~~
|
|
|
|
This module implements the main Convore wrapper.
|
|
|
|
:copyright: (c) 2011 by Kenneth Reitz.
|
|
:license: ISC, see LICENSE for more details.
|
|
"""
|
|
|
|
from convore.packages.anyjson import deserialize
|
|
|
|
import api
|
|
import models
|
|
|
|
|
|
__title__ = 'convore'
|
|
__version__ = '0.0.1'
|
|
__build__ = 0x000001
|
|
__author__ = 'Kenneth Reitz'
|
|
__license__ = 'ISC'
|
|
__copyright__ = 'Copyright 2011 Kenneth Reitz'
|
|
__docformat__ = 'restructuredtext'
|
|
|
|
__all__ = ('Convore',)
|
|
|
|
|
|
LIVE_TYPES = {
|
|
'read': models.Read,
|
|
'message': models.Message,
|
|
'topic': models.Topic,
|
|
'login': models.Login,
|
|
'logout': models.Logout,
|
|
}
|
|
|
|
class Convore(object):
|
|
"""The main Convore interface object."""
|
|
|
|
def __init__(self, username, password):
|
|
self.username = username
|
|
api.login(username, password)
|
|
|
|
self.groups = api.Groups()
|
|
|
|
def account_verify(self):
|
|
r = api.get('account', 'verify')
|
|
if r.status_code == 200:
|
|
return True
|
|
else:
|
|
return False
|
|
|
|
def live(self, cursor=None):
|
|
params= {}
|
|
next_cursor = None
|
|
|
|
live_messages = list()
|
|
if cursor <> None:
|
|
params['cursor'] = cursor
|
|
|
|
r = api.get('live', params=params)
|
|
|
|
try:
|
|
for data in deserialize(r.content)['messages']:
|
|
class_ = LIVE_TYPES[data['kind']]
|
|
message = class_()
|
|
message.import_from_api(data)
|
|
if data['kind'] == 'read':
|
|
group = self.groups.get(data['group_id'])
|
|
message.topic = group.topics.get(data['topic_id'])
|
|
elif data['kind'] == 'topic':
|
|
message.group = self.groups.get(data['group_id'])
|
|
elif data['kind'] == 'message':
|
|
group = self.groups.get(data['group'])
|
|
message.topic = group.topics.get(data['topic']['id'])
|
|
|
|
live_messages.append({'kind': data['kind'],
|
|
'message': message})
|
|
next_cursor = data['_id']
|
|
except KeyError:
|
|
pass
|
|
return (live_messages, next_cursor)
|