erebion/libervia-backend
Watch
1
0
Fork
You've already forked libervia-backend
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

plugin xep-0277: added getLastMicroblogs method

Browse source
This commit is contained in:
Goffi 2011-02-21 01:38:16 +01:00
commit 95b6400f98
1 changed files with 52 additions and 30 deletions
Download patch file Download diff file Expand all files Collapse all files

82
src/plugins/plugin_xep_0277.py
View file

@ -39,7 +39,7 @@ PLUGIN_INFO = {
"import_name": "XEP-0277",
"type": "XEP",
"protocols": [],
"dependencies": ["XEP-0163"],
"dependencies": ["XEP-0163","XEP-0060"],
"main": "XEP_0277",
"handler": "no",
"description": _("""Implementation of microblogging Protocol""")
@ -51,38 +51,53 @@ class XEP_0277():
info(_("Microblogging plugin initialization"))
self.host = host
self.host.plugins["XEP-0163"].addPEPEvent("MICROBLOG", NS_MICROBLOG, self.microblogCB, self.sendMicroblog)
host.bridge.addMethod("getLastMicroblogs", ".communication",
in_sign='sis', out_sign='aa{ss}',
method=self.getLastMicroblogs,
async = True,
doc = { 'summary':'retrieve items',
'param_0':'jid: publisher of wanted microblog',
'param_1':'max_items: see XEP-0060 #6.5.7',
'param_2':'%(doc_profile)s',
'return':'list of microblog data (dict)'
})
def _item2mbdata(self, item):
"""Convert an XML Item to microblog data used in bridge API
@param item: domish.Element of microblog item
@return: microblog data (dictionary)"""
try:
entry_elt = filter (lambda x:x.name == "entry", item.children)[0]
except KeyError:
warning(_('No entry element in microblog item'))
return
_entry = Entry().import_xml(entry_elt.toXml().encode('utf-8'))
microblog_data={}
try:
microblog_data['content'] = _entry.title.text
if len(_entry.authors):
microblog_data['author'] = _entry.authors[0].name.text
microblog_data['timestamp'] = str(int(_entry.updated.tf))
microblog_data['id'] = item['id']
except AttributeError, KeyError:
error(_('Error while parsing atom entry for microblogging event'))
return {}
##XXX: workaround for Jappix behaviour
if not 'author' in microblog_data:
from xe import NestElement
try:
author=NestElement('author')
author.import_xml(str(_entry))
microblog_data['author'] = author.nick.text
except:
error(_('Cannot find author'))
##end workaround Jappix
return microblog_data
def microblogCB(self, itemsEvent, profile):
_entry = None
for item in itemsEvent.items:
try:
entry_elt = filter (lambda x:x.name == "entry", item.children)[0]
except KeyError:
warning(_('No entry element in microblog item'))
return
_entry = Entry().import_xml(entry_elt.toXml().encode('utf-8'))
microblog_data={}
try:
microblog_data['content'] = _entry.title.text
if len(_entry.authors):
microblog_data['author'] = _entry.authors[0].name.text
microblog_data['timestamp'] = str(int(_entry.updated.tf))
microblog_data['id'] = item['id']
except AttributeError, KeyError:
error(_('Error while parsing atom entry for microblogging event'))
return
##XXX: workaround for Jappix behaviour
if not 'author' in microblog_data:
from xe import NestElement
try:
author=NestElement('author')
author.import_xml(str(_entry))
microblog_data['author'] = author.nick.text
except:
error(_('Cannot find author'))
##end workaround Jappix
microblog_data = self._item2mbdata(item)
self.host.bridge.personalEvent(itemsEvent.sender.full(), "MICROBLOG", microblog_data, profile)
def sendMicroblog(self, data, profile):
@ -109,3 +124,10 @@ class XEP_0277():
self.host.plugins["XEP-0060"].publish(None, NS_MICROBLOG, [item], profile_key = profile)
return 0
def getLastMicroblogs(self, pub_jid, max_items=1, profile_key='@DEFAULT@', callback=None, errback=None):
assert(callback)
d = self.host.plugins["XEP-0060"].getItems(jid.JID(pub_jid), NS_MICROBLOG, max_items=max_items, profile_key=profile_key)
d.addCallbacks(lambda items: callback(map(self._item2mbdata, items)), errback)