libervia-backend: src/plugins/plugin_misc

annotate src/plugins/plugin_misc_groupblog.py @ 708:6aa71c853bf5

plugin group blog: management of extra data/rich text for blog comments

author	Goffi <goffi@goffi.org>
date	Fri, 15 Nov 2013 15:27:03 +0100
parents	890fbf2d7fdd
children	ade9997fabfa

rev	line source
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	1 #!/usr/bin/python
1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	2 # -- coding: utf-8 --
1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	3
609 84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	4 # SAT plugin for microbloging with roster access
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	5 # Copyright (C) 2009, 2010, 2011, 2012, 2013 Jérôme Poisson (goffi@goffi.org)
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	6
609 84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	7 # This program is free software: you can redistribute it and/or modify
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	8 # it under the terms of the GNU Affero General Public License as published by
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	9 # the Free Software Foundation, either version 3 of the License, or
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	10 # (at your option) any later version.
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	11
609 84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	12 # This program is distributed in the hope that it will be useful,
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	15 # GNU Affero General Public License for more details.
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	16
609 84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	17 # You should have received a copy of the GNU Affero General Public License
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	18 # along with this program. If not, see <http://www.gnu.org/licenses/>.
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	19
532 db4ae4d18f09 plugin group blog: security check + fixed publisher in personalEvent signal Goffi <goffi@goffi.org> parents: 529 diff changeset	20 from logging import debug, info, warning, error
476 b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	21 from twisted.internet import defer
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	22 from twisted.words.protocols.jabber import jid
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	23 from sat.core import exceptions
476 b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	24 from wokkel import disco, data_form, iwokkel
b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	25 from zope.interface import implements
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	26
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	27 import uuid
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	28 import urllib
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	29
476 b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	30 try:
b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	31 from twisted.words.protocols.xmlstream import XMPPHandler
b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	32 except ImportError:
b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	33 from wokkel.subprotocols import XMPPHandler
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	34
462 d9456d94cd12 plugin groupblog: next-gen group blog first draft Goffi <goffi@goffi.org> parents: 459 diff changeset	35 NS_PUBSUB = 'http://jabber.org/protocol/pubsub'
476 b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	36 NS_GROUPBLOG = 'http://goffi.org/protocol/groupblog'
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	37 NS_NODE_PREFIX = 'urn:xmpp:groupblog:'
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	38 NS_COMMENT_PREFIX = 'urn:xmpp:comments:'
462 d9456d94cd12 plugin groupblog: next-gen group blog first draft Goffi <goffi@goffi.org> parents: 459 diff changeset	39 #NS_PUBSUB_EXP = 'http://goffi.org/protocol/pubsub' #for non official features
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	40 NS_PUBSUB_EXP = NS_PUBSUB # XXX: we can't use custom namespace as Wokkel's PubSubService use official NS
462 d9456d94cd12 plugin groupblog: next-gen group blog first draft Goffi <goffi@goffi.org> parents: 459 diff changeset	41 NS_PUBSUB_ITEM_ACCESS = NS_PUBSUB_EXP + "#item-access"
d9456d94cd12 plugin groupblog: next-gen group blog first draft Goffi <goffi@goffi.org> parents: 459 diff changeset	42 NS_PUBSUB_CREATOR_JID_CHECK = NS_PUBSUB_EXP + "#creator-jid-check"
d9456d94cd12 plugin groupblog: next-gen group blog first draft Goffi <goffi@goffi.org> parents: 459 diff changeset	43 NS_PUBSUB_ITEM_CONFIG = NS_PUBSUB_EXP + "#item-config"
d9456d94cd12 plugin groupblog: next-gen group blog first draft Goffi <goffi@goffi.org> parents: 459 diff changeset	44 NS_PUBSUB_AUTO_CREATE = NS_PUBSUB + "#auto-create"
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	45 TYPE_COLLECTION = 'collection'
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	46 ACCESS_TYPE_MAP = { 'PUBLIC': 'open',
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	47 'GROUP': 'roster',
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	48 'JID': None, #JID is not yet managed
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	49 }
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	50
1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	51 PLUGIN_INFO = {
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	52 "name": "Group blogging throught collections",
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	53 "import_name": "groupblog",
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	54 "type": "MISC",
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	55 "protocols": [],
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	56 "dependencies": ["XEP-0277"],
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	57 "main": "GroupBlog",
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	58 "handler": "yes",
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	59 "description": _("""Implementation of microblogging with roster access""")
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	60 }
1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	61
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	62
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	63 class NoCompatiblePubSubServerFound(Exception):
308 ce3607b7198d plugin group blog: blog collection cleaning Goffi <goffi@goffi.org> parents: 307 diff changeset	64 pass
ce3607b7198d plugin group blog: blog collection cleaning Goffi <goffi@goffi.org> parents: 307 diff changeset	65
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	66
471 6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	67 class BadAccessTypeError(Exception):
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	68 pass
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	69
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	70
471 6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	71 class BadAccessListError(Exception):
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	72 pass
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	73
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	74
529 c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	75 class UnknownType(Exception):
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	76 pass
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	77
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	78
588 beaf6bec2fcd Remove every old-style class. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 587 diff changeset	79 class GroupBlog(object):
462 d9456d94cd12 plugin groupblog: next-gen group blog first draft Goffi <goffi@goffi.org> parents: 459 diff changeset	80 """This class use a SàT PubSub Service to manage access on microblog"""
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	81
1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	82 def __init__(self, host):
1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	83 info(_("Group blog plugin initialization"))
1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	84 self.host = host
1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	85
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	86 host.bridge.addMethod("sendGroupBlog", ".plugin", in_sign='sassa{ss}s', out_sign='',
704 3c304929af74 plugin XEP-0277, group blogs: proper asynchronous methods for sending blogs. Goffi <goffi@goffi.org> parents: 703 diff changeset	87 method=self.sendGroupBlog,
3c304929af74 plugin XEP-0277, group blogs: proper asynchronous methods for sending blogs. Goffi <goffi@goffi.org> parents: 703 diff changeset	88 async=True)
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	89
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	90 host.bridge.addMethod("sendGroupBlogComment", ".plugin", in_sign='ssa{ss}s', out_sign='',
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	91 method=self.sendGroupBlogComment,
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	92 async=True)
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	93
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	94 host.bridge.addMethod("getLastGroupBlogs", ".plugin",
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	95 in_sign='sis', out_sign='aa{ss}',
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	96 method=self.getLastGroupBlogs,
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	97 async=True)
467 47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	98
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	99 host.bridge.addMethod("getMassiveLastGroupBlogs", ".plugin",
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	100 in_sign='sasis', out_sign='a{saa{ss}}',
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	101 method=self.getMassiveLastGroupBlogs,
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	102 async=True)
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	103
621 0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	104 host.bridge.addMethod("getGroupBlogComments", ".plugin",
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	105 in_sign='sss', out_sign='aa{ss}',
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	106 method=self.getGroupBlogComments,
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	107 async=True)
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	108
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	109 host.bridge.addMethod("subscribeGroupBlog", ".plugin", in_sign='ss', out_sign='',
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	110 method=self.subscribeGroupBlog,
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	111 async=True)
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	112
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	113 host.bridge.addMethod("massiveSubscribeGroupBlogs", ".plugin", in_sign='sass', out_sign='',
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	114 method=self.massiveSubscribeGroupBlogs,
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	115 async=True)
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	116
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	117 host.trigger.add("PubSubItemsReceived", self.pubSubItemsReceivedTrigger)
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	118
476 b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	119 def getHandler(self, profile):
b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	120 return GroupBlog_handler()
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	121
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	122 @defer.inlineCallbacks
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	123 def _initialise(self, profile_key):
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	124 """Check that this data for this profile are initialised, and do it else
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	125 @param client: client of the profile
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	126 @profile_key: %(doc_profile)s"""
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	127 profile = self.host.memory.getProfileName(profile_key)
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	128 if not profile:
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	129 raise exceptions.ProfileUnknownError
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	130
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	131 client = self.host.getClient(profile)
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	132 if not client:
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	133 error(_('No client for this profile key: %s') % profile_key)
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	134 raise Exception("Unknown profile")
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	135 yield client.client_initialized # we want to be sure that the client is initialized
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	136
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	137 #we first check that we have a item-access pubsub server
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	138 if not hasattr(client, "item_access_pubsub"):
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	139 debug(_('Looking for item-access power pubsub server'))
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	140 #we don't have any pubsub server featuring item access yet
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	141 client.item_access_pubsub = None
478 f856575a62a6 plugin groupblog: fixed initialisation Goffi <goffi@goffi.org> parents: 477 diff changeset	142 client._item_access_pubsub_pending = defer.Deferred()
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	143 for entity in self.host.memory.getServerServiceEntities("pubsub", "service", profile):
476 b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	144 _disco = yield client.disco.requestInfo(entity)
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	145 #if set([NS_PUBSUB_ITEM_ACCESS, NS_PUBSUB_AUTO_CREATE, NS_PUBSUB_CREATOR_JID_CHECK]).issubset(_disco.features):
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	146 if set([NS_PUBSUB_AUTO_CREATE, NS_PUBSUB_CREATOR_JID_CHECK]).issubset(_disco.features):
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	147 info(_("item-access powered pubsub service found: [%s]") % entity.full())
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	148 client.item_access_pubsub = entity
478 f856575a62a6 plugin groupblog: fixed initialisation Goffi <goffi@goffi.org> parents: 477 diff changeset	149 client._item_access_pubsub_pending.callback(None)
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	150
618 e2c33a16d235 plugin groupblog: fixed bad inialisation check Goffi <goffi@goffi.org> parents: 617 diff changeset	151 if hasattr(client, "_item_access_pubsub_pending"):
478 f856575a62a6 plugin groupblog: fixed initialisation Goffi <goffi@goffi.org> parents: 477 diff changeset	152 #XXX: we need to wait for item access pubsub service check
534 07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	153 yield client._item_access_pubsub_pending
478 f856575a62a6 plugin groupblog: fixed initialisation Goffi <goffi@goffi.org> parents: 477 diff changeset	154 del client._item_access_pubsub_pending
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	155
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	156 if not client.item_access_pubsub:
467 47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	157 error(_("No item-access powered pubsub server found, can't use group blog"))
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	158 raise NoCompatiblePubSubServerFound
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	159
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	160 defer.returnValue((profile, client))
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	161
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	162 def pubSubItemsReceivedTrigger(self, event, profile):
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	163 """"Trigger which catch groupblogs events"""
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	164
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	165 if event.nodeIdentifier.startswith(NS_NODE_PREFIX):
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	166 # Microblog
532 db4ae4d18f09 plugin group blog: security check + fixed publisher in personalEvent signal Goffi <goffi@goffi.org> parents: 529 diff changeset	167 publisher = jid.JID(event.nodeIdentifier[len(NS_NODE_PREFIX):])
db4ae4d18f09 plugin group blog: security check + fixed publisher in personalEvent signal Goffi <goffi@goffi.org> parents: 529 diff changeset	168 origin_host = publisher.host.split('.')
db4ae4d18f09 plugin group blog: security check + fixed publisher in personalEvent signal Goffi <goffi@goffi.org> parents: 529 diff changeset	169 event_host = event.sender.host.split('.')
db4ae4d18f09 plugin group blog: security check + fixed publisher in personalEvent signal Goffi <goffi@goffi.org> parents: 529 diff changeset	170 #FIXME: basic origin check, must be improved
534 07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	171 #TODO: automatic security test
532 db4ae4d18f09 plugin group blog: security check + fixed publisher in personalEvent signal Goffi <goffi@goffi.org> parents: 529 diff changeset	172 if (not (origin_host)
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	173 or len(event_host) < len(origin_host)
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	174 or event_host[-len(origin_host):] != origin_host):
532 db4ae4d18f09 plugin group blog: security check + fixed publisher in personalEvent signal Goffi <goffi@goffi.org> parents: 529 diff changeset	175 warning("Host incoherence between %s and %s (hack attempt ?)" % (unicode(event.sender),
db4ae4d18f09 plugin group blog: security check + fixed publisher in personalEvent signal Goffi <goffi@goffi.org> parents: 529 diff changeset	176 unicode(publisher)))
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	177 return False
617 dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	178
dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	179 client = self.host.getClient(profile)
534 07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	180
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	181 def gbdataManagementMicroblog(gbdata):
890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	182 for gbdatum in gbdata:
890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	183 self.host.bridge.personalEvent(publisher.full(), "MICROBLOG", gbdatum, profile)
890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	184
890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	185 d = self._itemsConstruction(event.items, publisher, client)
890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	186 d.addCallback(gbdataManagementMicroblog)
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	187 return False
617 dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	188
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	189 elif event.nodeIdentifier.startswith(NS_COMMENT_PREFIX):
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	190 # Comment
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	191 def gbdataManagementComments(gbdata):
890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	192 for gbdatum in gbdata:
890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	193 publisher = None # FIXME: see below (_handleCommentsItems)
890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	194 self.host.bridge.personalEvent(publisher.full() if publisher else gbdatum["author"], "MICROBLOG", gbdatum, profile)
890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	195 d = self._handleCommentsItems(event.items, event.sender, event.nodeIdentifier)
890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	196 d.addCallback(gbdataManagementComments)
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	197 return False
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	198 return True
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	199
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	200 @defer.inlineCallbacks
621 0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	201 def _handleCommentsItems(self, items, service, node_identifier):
617 dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	202 """ Convert comments items to groupblog data, and send them as signals
dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	203 @param items: comments items
dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	204 @param service: jid of the PubSub service used
dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	205 @param node_identifier: comments node
621 0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	206 @return: list of group blog data
617 dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	207 """
621 0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	208 ret = []
617 dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	209 for item in items:
dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	210 publisher = "" # FIXME: publisher attribute for item in SàT pubsub is not managed yet, so
dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	211 # publisher is not checked and can be easily spoofed. This need to be fixed
dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	212 # quickly.
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	213 microblog_data = yield self.item2gbdata(item, "comment")
617 dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	214 microblog_data["service"] = service.userhost()
dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	215 microblog_data["node"] = node_identifier
dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	216 microblog_data["verified_publisher"] = "true" if publisher else "false"
621 0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	217 ret.append(microblog_data)
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	218 defer.returnValue(ret)
617 dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	219
534 07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	220 def _parseAccessData(self, microblog_data, item):
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	221 P = self.host.plugins["XEP-0060"]
660 69a8bfd266a5 core, plugins: fixed bad use of children instead of elements() for domish.Element instances. Goffi <goffi@goffi.org> parents: 621 diff changeset	222 form_elts = [child for child in item.elements() if child.name == "x"]
534 07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	223 for form_elt in form_elts:
07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	224 form = data_form.Form.fromElement(form_elt)
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	225
534 07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	226 if (form.formNamespace == NS_PUBSUB_ITEM_CONFIG):
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	227 access_model = form.get(P.OPT_ACCESS_MODEL, 'open')
534 07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	228 if access_model == "roster":
07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	229 try:
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	230 microblog_data["groups"] = '\n'.join(form.fields[P.OPT_ROSTER_GROUPS_ALLOWED].values)
534 07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	231 except KeyError:
07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	232 warning("No group found for roster access-model")
07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	233 microblog_data["groups"] = ''
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	234
534 07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	235 break
07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	236
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	237 @defer.inlineCallbacks
616 8782f94e761e plugin groupblog: comment item is specified through microblog data, there is no more a specific signal type Goffi <goffi@goffi.org> parents: 615 diff changeset	238 def item2gbdata(self, item, _type="main_item"):
534 07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	239 """ Convert item to microblog data dictionary + add access data """
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	240 microblog_data = yield self.host.plugins["XEP-0277"].item2mbdata(item)
616 8782f94e761e plugin groupblog: comment item is specified through microblog data, there is no more a specific signal type Goffi <goffi@goffi.org> parents: 615 diff changeset	241 microblog_data["type"] = _type
534 07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	242 self._parseAccessData(microblog_data, item)
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	243 defer.returnValue(microblog_data)
534 07f369ed3988 plugin group blog: item configuration data (which groups are allowed) are parsed and added to microblog data Goffi <goffi@goffi.org> parents: 532 diff changeset	244
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	245 def getNodeName(self, publisher):
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	246 """Retrieve the name of publisher's node
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	247 @param publisher: publisher's jid
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	248 @return: node's name (string)"""
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	249 return NS_NODE_PREFIX + publisher.userhost()
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	250
703 0c2c1dfb79e4 plugin group blog: renamed options parameter as extra for consistency with sendMessage Goffi <goffi@goffi.org> parents: 660 diff changeset	251 def _publishMblog(self, service, client, access_type, access_list, message, extra):
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	252 """Actually publish the message on the group blog
462 d9456d94cd12 plugin groupblog: next-gen group blog first draft Goffi <goffi@goffi.org> parents: 459 diff changeset	253 @param service: jid of the item-access pubsub service
471 6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	254 @param client: SatXMPPClient of the published
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	255 @param access_type: one of "PUBLIC", "GROUP", "JID"
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	256 @param access_list: set of entities (empty list for all, groups or jids) allowed to see the item
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	257 @param message: message to publish
703 0c2c1dfb79e4 plugin group blog: renamed options parameter as extra for consistency with sendMessage Goffi <goffi@goffi.org> parents: 660 diff changeset	258 @param extra: dict which option name as key, which can be:
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	259 - allow_comments: True to accept comments, False else (default: False)
706 80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	260 - rich: if present, contain rich text in currently selected syntax
471 6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	261 """
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	262 node_name = self.getNodeName(client.jid)
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	263 mblog_data = {'content': message}
706 80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	264 if 'rich' in extra:
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	265 mblog_data['rich'] = extra['rich']
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	266 P = self.host.plugins["XEP-0060"]
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	267 access_model_value = ACCESS_TYPE_MAP[access_type]
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	268
703 0c2c1dfb79e4 plugin group blog: renamed options parameter as extra for consistency with sendMessage Goffi <goffi@goffi.org> parents: 660 diff changeset	269 if extra.get('allow_comments', 'False').lower() == 'true':
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	270 comments_node = "%s_%s__%s" % (NS_COMMENT_PREFIX, str(uuid.uuid4()), node_name)
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	271 mblog_data['comments'] = "xmpp:%(service)s?%(query)s" % {'service': service.userhost(),
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	272 'query': urllib.urlencode([('node',comments_node.encode('utf-8'))])}
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	273 _options = {P.OPT_ACCESS_MODEL: access_model_value,
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	274 P.OPT_PERSIST_ITEMS: 1,
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	275 P.OPT_MAX_ITEMS: -1,
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	276 P.OPT_DELIVER_PAYLOADS: 1,
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	277 P.OPT_SEND_ITEM_SUBSCRIBE: 1,
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	278 P.OPT_PUBLISH_MODEL: "subscribers", #TODO: should be open if both node and item access_model are open (public node and item)
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	279 }
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	280 if access_model_value == 'roster':
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	281 _options[P.OPT_ROSTER_GROUPS_ALLOWED] = list(access_list)
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	282
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	283 # FIXME: check comments node creation success, at the moment this is a potential security risk (if the node
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	284 # already exists, the creation will silently fail, but the comments link will stay the same, linking to a
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	285 # node owned by somebody else)
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	286 defer_blog = self.host.plugins["XEP-0060"].createNode(service, comments_node, _options, profile_key=client.profile)
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	287
706 80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	288 def itemCreated(mblog_item):
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	289 form = data_form.Form('submit', formNamespace=NS_PUBSUB_ITEM_CONFIG)
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	290
706 80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	291 if access_type == "PUBLIC":
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	292 if access_list:
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	293 raise BadAccessListError("access_list must be empty for PUBLIC access")
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	294 access = data_form.Field(None, P.OPT_ACCESS_MODEL, value=access_model_value)
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	295 form.addField(access)
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	296 elif access_type == "GROUP":
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	297 access = data_form.Field(None, P.OPT_ACCESS_MODEL, value=access_model_value)
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	298 allowed = data_form.Field(None, P.OPT_ROSTER_GROUPS_ALLOWED, values=access_list)
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	299 form.addField(access)
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	300 form.addField(allowed)
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	301 mblog_item.addChild(form.toElement())
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	302 elif access_type == "JID":
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	303 raise NotImplementedError
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	304 else:
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	305 error(_("Unknown access_type"))
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	306 raise BadAccessTypeError
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	307
706 80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	308 defer_blog = self.host.plugins["XEP-0060"].publish(service, node_name, items=[mblog_item], profile_key=client.profile)
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	309 defer_blog.addErrback(self._mblogPublicationFailed)
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	310 return defer_blog
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	311
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	312 entry_d = self.host.plugins["XEP-0277"].data2entry(mblog_data, client.profile)
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	313 entry_d.addCallback(itemCreated)
80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	314 return entry_d
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	315
1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	316 def _mblogPublicationFailed(self, failure):
1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	317 #TODO
471 6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	318 return failure
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	319
703 0c2c1dfb79e4 plugin group blog: renamed options parameter as extra for consistency with sendMessage Goffi <goffi@goffi.org> parents: 660 diff changeset	320 def sendGroupBlog(self, access_type, access_list, message, extra, profile_key='@NONE@'):
471 6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	321 """Publish a microblog with given item access
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	322 @param access_type: one of "PUBLIC", "GROUP", "JID"
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	323 @param access_list: list of authorized entity (empty list for PUBLIC ACCESS,
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	324 list of groups or list of jids) for this item
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	325 @param message: microblog
703 0c2c1dfb79e4 plugin group blog: renamed options parameter as extra for consistency with sendMessage Goffi <goffi@goffi.org> parents: 660 diff changeset	326 @param extra: dict which option name as key, which can be:
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	327 - allow_comments: True to accept comments, False else (default: False)
706 80e9d3ecb272 plugin XEP-0277, group blog: rich text management for sending microblogs Goffi <goffi@goffi.org> parents: 704 diff changeset	328 - rich: if present, contain rich text in currently selected syntax
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	329 @profile_key: %(doc_profile_key)s
307 1e4575e12581 Group blog first draft Goffi <goffi@goffi.org> parents: diff changeset	330 """
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	331
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	332 def initialised(result):
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	333 profile, client = result
471 6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	334 if access_type == "PUBLIC":
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	335 if access_list:
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	336 raise Exception("Publishers list must be empty when getting microblogs for all contacts")
704 3c304929af74 plugin XEP-0277, group blogs: proper asynchronous methods for sending blogs. Goffi <goffi@goffi.org> parents: 703 diff changeset	337 return self._publishMblog(client.item_access_pubsub, client, "PUBLIC", [], message, extra)
471 6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	338 elif access_type == "GROUP":
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	339 _groups = set(access_list).intersection(client.roster.getGroups()) # We only keep group which actually exist
471 6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	340 if not _groups:
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	341 raise BadAccessListError("No valid group")
704 3c304929af74 plugin XEP-0277, group blogs: proper asynchronous methods for sending blogs. Goffi <goffi@goffi.org> parents: 703 diff changeset	342 return self._publishMblog(client.item_access_pubsub, client, "GROUP", _groups, message, extra)
471 6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	343 elif access_type == "JID":
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	344 raise NotImplementedError
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	345 else:
6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	346 error(_("Unknown access type"))
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	347 raise BadAccessTypeError
952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	348
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	349 return self._initialise(profile_key).addCallback(initialised)
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	350
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	351 def sendGroupBlogComment(self, node_url, message, extra, profile_key='@NONE@'):
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	352 """Publish a comment in the given node
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	353 @param node url: link to the comments node as specified in XEP-0277 and given in microblog data's comments key
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	354 @param message: comment
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	355 @param extra: dict which option name as key, which can be:
6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	356 - allow_comments: True to accept an other level of comments, False else (default: False)
6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	357 - rich: if present, contain rich text in currently selected syntax
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	358 @profile_key: %(doc_profile)s
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	359 """
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	360 def initialised(result):
6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	361 profile, client = result
6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	362 service, node = self.host.plugins["XEP-0277"].parseCommentUrl(node_url)
6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	363 mblog_data = {'content': message}
6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	364 if 'rich' in extra:
6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	365 mblog_data['rich'] = extra['rich']
6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	366 if 'allow_comments' in extra:
6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	367 raise NotImplementedError # TODO
6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	368 entry_d = self.host.plugins["XEP-0277"].data2entry(mblog_data, profile)
6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	369 entry_d.addCallback(lambda mblog_item: self.host.plugins["XEP-0060"].publish(service, node, items=[mblog_item], profile_key=profile))
6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	370 return entry_d
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	371
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	372 return self._initialise(profile_key).addCallback(initialised)
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	373
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	374
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	375 @defer.inlineCallbacks
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	376 def _itemsConstruction(self, items, pub_jid, client):
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	377 """ Transforms items to group blog data and manage comments node
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	378 @param items: iterable of items
621 0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	379 @param pub_jid: jid of the publisher or None to use items data
617 dafdbe28ca2f plugin group blog: comments handling (comments are automaticaly requested when a comment node is found) Goffi <goffi@goffi.org> parents: 616 diff changeset	380 @param client: SatXMPPClient instance
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	381 @return: deferred which fire list of group blog data """
621 0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	382 # TODO: use items data when pub_jid is None
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	383 ret = []
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	384 for item in items:
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	385 gbdata = yield self.item2gbdata(item)
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	386 ret.append(gbdata)
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	387 # if there is a comments node, we subscribe to it
619 1de01a2154e2 plugin group blog: getItems for comments fixed when we are the publisher of the parent node Goffi <goffi@goffi.org> parents: 618 diff changeset	388 if "comments_node" in gbdata:
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	389 try:
619 1de01a2154e2 plugin group blog: getItems for comments fixed when we are the publisher of the parent node Goffi <goffi@goffi.org> parents: 618 diff changeset	390 # every comments node must be subscribed, except if we are the publisher (we are already subscribed in this case)
1de01a2154e2 plugin group blog: getItems for comments fixed when we are the publisher of the parent node Goffi <goffi@goffi.org> parents: 618 diff changeset	391 if pub_jid.userhostJID() != client.jid.userhostJID():
1de01a2154e2 plugin group blog: getItems for comments fixed when we are the publisher of the parent node Goffi <goffi@goffi.org> parents: 618 diff changeset	392 self.host.plugins["XEP-0060"].subscribe(jid.JID(gbdata["comments_service"]), gbdata["comments_node"],
1de01a2154e2 plugin group blog: getItems for comments fixed when we are the publisher of the parent node Goffi <goffi@goffi.org> parents: 618 diff changeset	393 profile_key=client.profile)
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	394 except KeyError:
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	395 warning("Missing key for comments")
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	396 defer.returnValue(ret)
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	397
621 0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	398 def getLastGroupBlogs(self, pub_jid_s, max_items=10, profile_key='@NONE@'):
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	399 """Get the last published microblogs
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	400 @param pub_jid_s: jid of the publisher
471 6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	401 @param max_items: how many microblogs we want to get (see XEP-0060 #6.5.7)
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	402 @param profile_key: profile key
471 6cd04adddaea core: exceptions moved to core Goffi <goffi@goffi.org> parents: 470 diff changeset	403 @return: list of microblog data (dict)
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	404 """
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	405 pub_jid = jid.JID(pub_jid_s)
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	406
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	407 def initialised(result):
78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	408 profile, client = result
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	409 d = self.host.plugins["XEP-0060"].getItems(client.item_access_pubsub, self.getNodeName(pub_jid),
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	410 max_items=max_items, profile_key=profile_key)
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	411 d.addCallback(self._itemsConstruction, pub_jid, client)
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	412 d.addErrback(lambda ignore: {}) # TODO: more complete error management (log !)
476 b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	413 return d
308 ce3607b7198d plugin group blog: blog collection cleaning Goffi <goffi@goffi.org> parents: 307 diff changeset	414
465 78e67a59d51d plugin groupblog: added getLastGroupBlogs method Goffi <goffi@goffi.org> parents: 462 diff changeset	415 #TODO: we need to use the server corresponding the the host of the jid
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	416 return self._initialise(profile_key).addCallback(initialised)
462 d9456d94cd12 plugin groupblog: next-gen group blog first draft Goffi <goffi@goffi.org> parents: 459 diff changeset	417
621 0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	418 def getGroupBlogComments(self, service_s, node, profile_key='@NONE@'):
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	419 """Get all comments of given node
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	420 @param service_s: service hosting the node
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	421 @param node: comments node
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	422 @param profile_key: profile key
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	423 @return: list of microblog data (dict)
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	424 """
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	425 service = jid.JID(service_s)
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	426
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	427 def initialised(result):
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	428 profile, client = result
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	429 d = self.host.plugins["XEP-0060"].getItems(service, node,
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	430 profile_key=profile_key)
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	431 d.addCallback(self._handleCommentsItems, service, node)
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	432 d.addErrback(lambda ignore: {}) # TODO: more complete error management (log !)
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	433 return d
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	434
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	435 #TODO: we need to use the server corresponding the the host of the jid
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	436 return self._initialise(profile_key).addCallback(initialised)
621 0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	437
0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	438 def getMassiveLastGroupBlogs(self, publishers_type, publishers, max_items=10, profile_key='@NONE@'):
467 47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	439 """Get the last published microblogs for a list of groups or jids
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	440 @param publishers_type: type of the list of publishers (one of "GROUP" or "JID" or "ALL")
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	441 @param publishers: list of publishers, according to "publishers_type" (list of groups or list of jids)
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	442 @param max_items: how many microblogs we want to get
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	443 @param profile_key: profile key
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	444 """
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	445
467 47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	446 def sendResult(result):
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	447 """send result of DeferredList (list of microblogs to the calling method"""
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	448
467 47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	449 ret = {}
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	450
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	451 for (success, value) in result:
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	452 if success:
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	453 source_jid, data = value
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	454 ret[source_jid] = data
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	455
470 5c916b99d0f6 plugin groupblog, D-Bus frontend: added getLastGroupBlogs and getMassiveLastGroupBlogs Goffi <goffi@goffi.org> parents: 467 diff changeset	456 return ret
467 47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	457
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	458 def initialised(result):
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	459 profile, client = result
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	460
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	461 if publishers_type == "ALL":
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	462 contacts = client.roster.getItems()
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	463 jids = [contact.jid.userhost() for contact in contacts]
529 c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	464 elif publishers_type == "GROUP":
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	465 jids = []
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	466 for _group in publishers:
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	467 jids.extend(client.roster.getJidsFromGroup(_group))
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	468 elif publishers_type == 'JID':
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	469 jids = publishers
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	470 else:
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	471 raise UnknownType
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	472
529 c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	473 mblogs = []
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	474
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	475
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	476 for jid_s in jids:
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	477 _jid = jid.JID(jid_s)
6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	478 d = self.host.plugins["XEP-0060"].getItems(client.item_access_pubsub, self.getNodeName(_jid),
529 c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	479 max_items=max_items, profile_key=profile_key)
707 890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	480 d.addCallback(self._itemsConstruction, _jid, client)
890fbf2d7fdd plugin XEP-0277, groupblog: rich text management for receiving microblogs Goffi <goffi@goffi.org> parents: 706 diff changeset	481 d.addCallback(lambda gbdata, source_jid: (source_jid, gbdata), jid_s)
615 6f4c31192c7c plugins XEP-0060, XEP-0277, groupblog: comments implementation (first draft, not finished yet): Goffi <goffi@goffi.org> parents: 609 diff changeset	482
529 c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	483 mblogs.append(d)
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	484 dlist = defer.DeferredList(mblogs)
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	485 dlist.addCallback(sendResult)
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	486
529 c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	487 return dlist
467 47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	488
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	489 #TODO: custom exception
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	490 if publishers_type not in ["GROUP", "JID", "ALL"]:
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	491 raise Exception("Bad call, unknown publishers_type")
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	492 if publishers_type == "ALL" and publishers:
467 47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	493 raise Exception("Publishers list must be empty when getting microblogs for all contacts")
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	494 return self._initialise(profile_key).addCallback(initialised)
467 47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	495 #TODO: we need to use the server corresponding the the host of the jid
47af60767013 plugin group blog: getMassiveGroupBlog first draft Goffi <goffi@goffi.org> parents: 465 diff changeset	496
621 0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	497 def subscribeGroupBlog(self, pub_jid, profile_key='@NONE@'):
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	498 def initialised(result):
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	499 profile, client = result
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	500 d = self.host.plugins["XEP-0060"].subscribe(client.item_access_pubsub, self.getNodeName(jid.JID(pub_jid)),
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	501 profile_key=profile_key)
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	502 return d
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	503
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	504 #TODO: we need to use the server corresponding the the host of the jid
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	505 return self._initialise(profile_key).addCallback(initialised)
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	506
621 0e16288d6816 pluging groupblog: comments handling: Goffi <goffi@goffi.org> parents: 619 diff changeset	507 def massiveSubscribeGroupBlogs(self, publishers_type, publishers, profile_key='@NONE@'):
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	508 """Subscribe microblogs for a list of groups or jids
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	509 @param publishers_type: type of the list of publishers (one of "GROUP" or "JID" or "ALL")
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	510 @param publishers: list of publishers, according to "publishers_type" (list of groups or list of jids)
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	511 @param profile_key: profile key
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	512 """
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	513
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	514 def initialised(result):
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	515 profile, client = result
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	516
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	517 if publishers_type == "ALL":
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	518 contacts = client.roster.getItems()
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	519 jids = [contact.jid.userhost() for contact in contacts]
529 c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	520 elif publishers_type == "GROUP":
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	521 jids = []
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	522 for _group in publishers:
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	523 jids.extend(client.roster.getJidsFromGroup(_group))
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	524 elif publishers_type == 'JID':
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	525 jids = publishers
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	526 else:
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	527 raise UnknownType
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	528
529 c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	529 mblogs = []
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	530 for _jid in jids:
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	531 d = self.host.plugins["XEP-0060"].subscribe(client.item_access_pubsub, self.getNodeName(jid.JID(_jid)),
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	532 profile_key=profile_key)
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	533 mblogs.append(d)
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	534 dlist = defer.DeferredList(mblogs)
c18e0e108925 plugin groupblog: fixed GROUP and JID publishers_type in getMassiveLastGroupBlogs and massiveSubscribeGroupBlogs Goffi <goffi@goffi.org> parents: 480 diff changeset	535 return dlist
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	536
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	537 #TODO: custom exception
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	538 if publishers_type not in ["GROUP", "JID", "ALL"]:
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	539 raise Exception("Bad call, unknown publishers_type")
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	540 if publishers_type == "ALL" and publishers:
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	541 raise Exception("Publishers list must be empty when getting microblogs for all contacts")
708 6aa71c853bf5 plugin group blog: management of extra data/rich text for blog comments Goffi <goffi@goffi.org> parents: 707 diff changeset	542 return self._initialise(profile_key).addCallback(initialised)
477 031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	543 #TODO: we need to use the server corresponding the the host of the jid
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	544
031b0e0aaab8 plugin groupblog: subscriptions/notifications Goffi <goffi@goffi.org> parents: 476 diff changeset	545
476 b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	546 class GroupBlog_handler(XMPPHandler):
b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	547 implements(iwokkel.IDisco)
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	548
476 b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	549 def getDiscoInfo(self, requestor, target, nodeIdentifier=''):
b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	550 return [disco.DiscoFeature(NS_GROUPBLOG)]
b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	551
b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	552 def getDiscoItems(self, requestor, target, nodeIdentifier=''):
b9fd32b46306 plugin groupblog: added disco info + misc fixes Goffi <goffi@goffi.org> parents: 471 diff changeset	553 return []

Mercurial > libervia-backend

annotate src/plugins/plugin_misc_groupblog.py @ 708:6aa71c853bf5