|
72
|
1 #!/usr/bin/python |
|
|
2 # -*- coding: utf-8 -*- |
|
|
3 |
|
|
4 """ |
|
|
5 SAT plugin for managing xep-0045 |
|
|
6 Copyright (C) 2009, 2010 Jérôme Poisson (goffi@goffi.org) |
|
|
7 |
|
|
8 This program is free software: you can redistribute it and/or modify |
|
|
9 it under the terms of the GNU General Public License as published by |
|
|
10 the Free Software Foundation, either version 3 of the License, or |
|
|
11 (at your option) any later version. |
|
|
12 |
|
|
13 This program is distributed in the hope that it will be useful, |
|
|
14 but WITHOUT ANY WARRANTY; without even the implied warranty of |
|
|
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|
|
16 GNU General Public License for more details. |
|
|
17 |
|
|
18 You should have received a copy of the GNU General Public License |
|
|
19 along with this program. If not, see <http://www.gnu.org/licenses/>. |
|
|
20 """ |
|
|
21 |
|
|
22 from logging import debug, info, warning, error |
|
|
23 from twisted.words.xish import domish |
|
|
24 from twisted.internet import protocol, defer, threads, reactor |
|
|
25 from twisted.words.protocols.jabber import client, jid, xmlstream |
|
|
26 from twisted.words.protocols.jabber import error as jab_error |
|
|
27 from twisted.words.protocols.jabber.xmlstream import IQ |
|
|
28 import os.path |
|
|
29 import pdb |
|
|
30 |
|
|
31 from zope.interface import implements |
|
|
32 |
|
|
33 from wokkel import disco, iwokkel, muc |
|
|
34 |
|
|
35 from base64 import b64decode |
|
|
36 from hashlib import sha1 |
|
|
37 from time import sleep |
|
|
38 |
|
|
39 try: |
|
|
40 from twisted.words.protocols.xmlstream import XMPPHandler |
|
|
41 except ImportError: |
|
|
42 from wokkel.subprotocols import XMPPHandler |
|
|
43 |
|
|
44 AVATAR_PATH = "/avatars" |
|
|
45 |
|
|
46 IQ_GET = '/iq[@type="get"]' |
|
|
47 NS_VCARD = 'vcard-temp' |
|
|
48 VCARD_REQUEST = IQ_GET + '/vCard[@xmlns="' + NS_VCARD + '"]' #TODO: manage requests |
|
|
49 |
|
|
50 PRESENCE = '/presence' |
|
|
51 NS_VCARD_UPDATE = 'vcard-temp:x:update' |
|
|
52 VCARD_UPDATE = PRESENCE + '/x[@xmlns="' + NS_VCARD_UPDATE + '"]' |
|
|
53 |
|
|
54 PLUGIN_INFO = { |
|
|
55 "name": "XEP 0045 Plugin", |
|
|
56 "import_name": "XEP_0045", |
|
|
57 "type": "XEP", |
|
|
58 "protocols": ["XEP-0045"], |
|
|
59 "dependencies": [], |
|
|
60 "main": "XEP_0045", |
|
|
61 "handler": "yes", |
|
|
62 "description": _("""Implementation of Multi-User Chat""") |
|
|
63 } |
|
|
64 |
|
|
65 class XEP_0045(): |
|
|
66 |
|
|
67 def __init__(self, host): |
|
|
68 info(_("Plugin XEP_0045 initialization")) |
|
|
69 self.host = host |
|
|
70 self.clients={} |
|
|
71 host.bridge.addMethod("joinMUC", ".communication", in_sign='ssss', out_sign='', method=self.join) |
|
73
|
72 host.bridge.addSignal("roomJoined", ".communication", signature='ssasss') #args: room_id, room_service, room_nicks, user_nick, profile |
|
72
|
73 |
|
|
74 def __check_profile(self, profile): |
|
|
75 if not profile or not self.clients.has_key(profile) or not self.host.isConnected(profile): |
|
|
76 error (_('Unknown or disconnected profile')) |
|
|
77 if self.clients.has_key(profile): |
|
|
78 del self.clients[profile] |
|
|
79 return False |
|
|
80 return True |
|
|
81 |
|
|
82 def __room_joined(self, room, profile): |
|
|
83 """Called when the user is in the requested room""" |
|
|
84 print "room joined (profile = %s)" % profile |
|
|
85 room_jid = room.roomIdentifier+'@'+room.service |
|
|
86 self.clients[profile].joined_rooms[room_jid] = room |
|
|
87 self.host.bridge.roomJoined(room.roomIdentifier, room.service, room.roster.keys(), room.nick, profile) |
|
|
88 |
|
|
89 def __err_joining_room(self, failure, profile): #, profile): |
|
|
90 """Called when something is going wrong when joining the room""" |
|
|
91 error ("Error when joining the room") |
|
|
92 pdb.set_trace() |
|
|
93 |
|
|
94 def join(self, service, roomId, nick, profile_key='@DEFAULT@'): |
|
|
95 profile = self.host.memory.getProfileName(profile_key) |
|
|
96 if not self.__check_profile(profile): |
|
|
97 return |
|
|
98 room_jid = roomId+'@'+service |
|
|
99 if self.clients[profile].joined_rooms.has_key(room_jid): |
|
|
100 warning(_('%(profile)s is already in room %(room_jid)s') % {'profile':profile, 'room_jid':room_jid}) |
|
|
101 return |
|
|
102 info (_("[%(profile)s] is joining room %(room)s with nick %(nick)s") % {'profile':profile,'room':roomId+'@'+service, 'nick':nick}) |
|
|
103 self.clients[profile].join(service, roomId, nick).addCallbacks(self.__room_joined, self.__err_joining_room, callbackKeywords={'profile':profile}, errbackKeywords={'profile':profile}) |
|
|
104 |
|
|
105 def getHandler(self, profile): |
|
|
106 #reactor.callLater(15,self.join,"conference.necton2.int", "test", "Goffi \o/", profile) |
|
|
107 self.clients[profile] = SatMUCClient(self) |
|
|
108 return self.clients[profile] |
|
|
109 |
|
|
110 |
|
|
111 |
|
|
112 class SatMUCClient (muc.MUCClient): |
|
|
113 #implements(iwokkel.IDisco) |
|
|
114 |
|
|
115 def __init__(self, plugin_parent): |
|
|
116 self.plugin_parent = plugin_parent |
|
|
117 self.host = plugin_parent.host |
|
|
118 muc.MUCClient.__init__(self) |
|
|
119 self.joined_rooms = {} #FIXME gof: check if necessary |
|
|
120 print "init SatMUCClient OK" |
|
|
121 |
|
|
122 def receivedGroupChat(self, room, user, body): |
|
|
123 debug('receivedGroupChat: room=%s user=%s body=%s', room, user, body) |
|
|
124 |
|
|
125 |
|
|
126 #def connectionInitialized(self): |
|
|
127 #pass |
|
|
128 |
|
|
129 #def getDiscoInfo(self, requestor, target, nodeIdentifier=''): |
|
|
130 #return [disco.DiscoFeature(NS_VCARD)] |
|
|
131 |
|
|
132 #def getDiscoItems(self, requestor, target, nodeIdentifier=''): |
|
|
133 #return [] |
|
|
134 |
