Mercurial > libervia-web
annotate libervia.tac @ 323:0b7934e75e76
misc: reorganization of the file panels.py + clean the modules import:
- some existing modules were not found during JS runtime (panels.py was too large?)
- the *Panel classes of panels.py that do not reference "host" have been moved to base_panels.py
- cleaned the import in various files
author | souliane <souliane@mailoo.org> |
---|---|
date | Sat, 04 Jan 2014 00:17:46 +0100 |
parents | c12c9a1acf2f |
children | 36927be51481 |
rev | line source |
---|---|
0 | 1 #!/usr/bin/python |
2 # -*- coding: utf-8 -*- | |
3 | |
4 """ | |
5 Libervia: a Salut à Toi frontend | |
165 | 6 Copyright (C) 2011, 2012, 2013 Jérôme Poisson <goffi@goffi.org> |
0 | 7 |
8 This program is free software: you can redistribute it and/or modify | |
9 it under the terms of the GNU Affero 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 Affero General Public License for more details. | |
17 | |
18 You should have received a copy of the GNU Affero General Public License | |
19 along with this program. If not, see <http://www.gnu.org/licenses/>. | |
20 """ | |
21 | |
22 from twisted.application import internet, service | |
23 from twisted.internet import glib2reactor | |
24 glib2reactor.install() | |
25 from twisted.internet import reactor, defer | |
26 from twisted.web import server | |
27 from twisted.web import error as weberror | |
28 from twisted.web.static import File | |
61 | 29 from twisted.web.resource import Resource, NoResource |
172
631556a64850
server side: added root redirection to libervia.html
Goffi <goffi@goffi.org>
parents:
165
diff
changeset
|
30 from twisted.web.util import Redirect |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
31 from twisted.python.components import registerAdapter |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
32 from twisted.python.failure import Failure |
10 | 33 from twisted.words.protocols.jabber.jid import JID |
0 | 34 from txjsonrpc.web import jsonrpc |
35 from txjsonrpc import jsonrpclib | |
323
0b7934e75e76
misc: reorganization of the file panels.py + clean the modules import:
souliane <souliane@mailoo.org>
parents:
318
diff
changeset
|
36 |
46 | 37 from logging import debug, info, warning, error |
127 | 38 import re, glob |
39 import os.path, sys | |
40 import tempfile, shutil, uuid | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
41 from zope.interface import Interface, Attribute, implements |
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
42 from xml.dom import minidom |
323
0b7934e75e76
misc: reorganization of the file panels.py + clean the modules import:
souliane <souliane@mailoo.org>
parents:
318
diff
changeset
|
43 |
317
bbadd490e63c
misc: gather the constants in a single file, as it is done for other frontends
souliane <souliane@mailoo.org>
parents:
309
diff
changeset
|
44 from constants import Const |
323
0b7934e75e76
misc: reorganization of the file panels.py + clean the modules import:
souliane <souliane@mailoo.org>
parents:
318
diff
changeset
|
45 from server_side.blog import MicroBlog |
0b7934e75e76
misc: reorganization of the file panels.py + clean the modules import:
souliane <souliane@mailoo.org>
parents:
318
diff
changeset
|
46 from sat_frontends.bridge.DBus import DBusBridgeFrontend, BridgeExceptionNoService |
318
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
47 from sat.core.i18n import _, D_ |
10 | 48 |
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
49 |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
50 class ISATSession(Interface): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
51 profile = Attribute("Sat profile") |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
52 jid = Attribute("JID associated with the profile") |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
53 |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
54 class SATSession(object): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
55 implements(ISATSession) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
56 def __init__(self, session): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
57 self.profile = None |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
58 self.jid = None |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
59 |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
60 class LiberviaSession(server.Session): |
317
bbadd490e63c
misc: gather the constants in a single file, as it is done for other frontends
souliane <souliane@mailoo.org>
parents:
309
diff
changeset
|
61 sessionTimeout = Const.TIMEOUT |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
62 |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
63 def __init__(self, *args, **kwargs): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
64 self.__lock = False |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
65 server.Session.__init__(self, *args, **kwargs) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
66 |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
67 def lock(self): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
68 """Prevent session from expiring""" |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
69 self.__lock = True |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
70 self._expireCall.reset(sys.maxint) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
71 |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
72 def unlock(self): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
73 """Allow session to expire again, and touch it""" |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
74 self.__lock = False |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
75 self.touch() |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
76 |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
77 def touch(self): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
78 if not self.__lock: |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
79 server.Session.touch(self) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
80 |
59
d0fa4e96a5e4
server side: 404 error is now sent instead of directory listing when requesting a directory
Goffi <goffi@goffi.org>
parents:
57
diff
changeset
|
81 class ProtectedFile(File): |
d0fa4e96a5e4
server side: 404 error is now sent instead of directory listing when requesting a directory
Goffi <goffi@goffi.org>
parents:
57
diff
changeset
|
82 """A File class which doens't show directory listing""" |
d0fa4e96a5e4
server side: 404 error is now sent instead of directory listing when requesting a directory
Goffi <goffi@goffi.org>
parents:
57
diff
changeset
|
83 |
d0fa4e96a5e4
server side: 404 error is now sent instead of directory listing when requesting a directory
Goffi <goffi@goffi.org>
parents:
57
diff
changeset
|
84 def directoryListing(self): |
d0fa4e96a5e4
server side: 404 error is now sent instead of directory listing when requesting a directory
Goffi <goffi@goffi.org>
parents:
57
diff
changeset
|
85 return NoResource() |
d0fa4e96a5e4
server side: 404 error is now sent instead of directory listing when requesting a directory
Goffi <goffi@goffi.org>
parents:
57
diff
changeset
|
86 |
46 | 87 class SATActionIDHandler(object): |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
88 """Manage SàT action action_id lifecycle""" |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
89 ID_LIFETIME = 30 #after this time (in seconds), action_id will be suppressed and action result will be ignored |
46 | 90 |
91 def __init__(self): | |
92 self.waiting_ids = {} | |
93 | |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
94 def waitForId(self, callback, action_id, profile, *args, **kwargs): |
46 | 95 """Wait for an action result |
96 @param callback: method to call when action gave a result back | |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
97 @param action_id: action_id to wait for |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
98 @param profile: %(doc_profile)s |
46 | 99 @param *args: additional argument to pass to callback |
100 @param **kwargs: idem""" | |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
101 action_tuple = (action_id, profile) |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
102 self.waiting_ids[action_tuple] = (callback, args, kwargs) |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
103 reactor.callLater(self.ID_LIFETIME, self.purgeID, action_tuple) |
46 | 104 |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
105 def purgeID(self, action_tuple): |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
106 """Called when an action_id has not be handled in time""" |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
107 if action_tuple in self.waiting_ids: |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
108 warning ("action of action_id %s [%s] has not been managed, action_id is now ignored" % action_tuple) |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
109 del self.waiting_ids[action_tuple] |
46 | 110 |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
111 def actionResultCb(self, answer_type, action_id, data, profile): |
46 | 112 """Manage the actionResult signal""" |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
113 action_tuple = (action_id, profile) |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
114 if action_tuple in self.waiting_ids: |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
115 callback, args, kwargs = self.waiting_ids[action_tuple] |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
116 del self.waiting_ids[action_tuple] |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
117 callback(answer_type, action_id, data, *args, **kwargs) |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
118 |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
119 class JSONRPCMethodManager(jsonrpc.JSONRPC): |
0 | 120 |
121 def __init__(self, sat_host): | |
122 jsonrpc.JSONRPC.__init__(self) | |
123 self.sat_host=sat_host | |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
124 |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
125 def asyncBridgeCall(self, method_name, *args, **kwargs): |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
126 """Call an asynchrone bridge method and return a deferred |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
127 @param method_name: name of the method as a unicode |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
128 @return: a deferred which trigger the result |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
129 |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
130 """ |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
131 d = defer.Deferred() |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
132 |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
133 def _callback(*args): |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
134 if not args: |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
135 d.callback(None) |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
136 else: |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
137 if len(args) != 1: |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
138 Exception("Multiple return arguments not supported") |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
139 d.callback(args[0]) |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
140 |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
141 def _errback(result): |
317
bbadd490e63c
misc: gather the constants in a single file, as it is done for other frontends
souliane <souliane@mailoo.org>
parents:
309
diff
changeset
|
142 d.errback(Failure(jsonrpclib.Fault(Const.ERRNUM_BRIDGE_ERRBACK, unicode(result)))) |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
143 |
277
ea2d4f464b5a
server side: fixed bad async bridge calls management
Goffi <goffi@goffi.org>
parents:
275
diff
changeset
|
144 kwargs["callback"] = _callback |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
145 kwargs["errback"] = _errback |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
146 getattr(self.sat_host.bridge, method_name)(*args, **kwargs) |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
147 return d |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
148 |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
149 |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
150 class MethodHandler(JSONRPCMethodManager): |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
151 |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
152 def __init__(self, sat_host): |
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
153 JSONRPCMethodManager.__init__(self, sat_host) |
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
154 self.authorized_params = None |
0 | 155 |
156 def render(self, request): | |
1 | 157 self.session = request.getSession() |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
158 profile = ISATSession(self.session).profile |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
159 if not profile: |
0 | 160 #user is not identified, we return a jsonrpc fault |
161 parsed = jsonrpclib.loads(request.content.read()) | |
317
bbadd490e63c
misc: gather the constants in a single file, as it is done for other frontends
souliane <souliane@mailoo.org>
parents:
309
diff
changeset
|
162 fault = jsonrpclib.Fault(Const.ERRNUM_LIBERVIA, "Not allowed") #FIXME: define some standard error codes for libervia |
0 | 163 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc')) |
164 return jsonrpc.JSONRPC.render(self, request) | |
19 | 165 |
166 def jsonrpc_getProfileJid(self): | |
167 """Return the jid of the profile""" | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
168 sat_session = ISATSession(self.session) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
169 profile = sat_session.profile |
61 | 170 sat_session.jid = JID(self.sat_host.bridge.getParamA("JabberID", "Connection", profile_key=profile)) |
171 return sat_session.jid.full() | |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
172 |
156 | 173 def jsonrpc_disconnect(self): |
174 """Disconnect the profile""" | |
175 sat_session = ISATSession(self.session) | |
176 profile = sat_session.profile | |
177 self.sat_host.bridge.disconnect(profile) | |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
178 |
0 | 179 def jsonrpc_getContacts(self): |
180 """Return all passed args.""" | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
181 profile = ISATSession(self.session).profile |
1 | 182 return self.sat_host.bridge.getContacts(profile) |
20 | 183 |
54
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
184 def jsonrpc_addContact(self, entity, name, groups): |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
185 """Subscribe to contact presence, and add it to the given groups""" |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
186 profile = ISATSession(self.session).profile |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
187 self.sat_host.bridge.addContact(entity, profile) |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
188 self.sat_host.bridge.updateContact(entity, name, groups, profile) |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
189 |
55
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
190 def jsonrpc_delContact(self, entity): |
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
191 """Remove contact from contacts list""" |
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
192 profile = ISATSession(self.session).profile |
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
193 self.sat_host.bridge.delContact(entity, profile) |
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
194 |
57
e552a67b933d
Contact update + add dedication in About dialog
Goffi <goffi@goffi.org>
parents:
55
diff
changeset
|
195 def jsonrpc_updateContact(self, entity, name, groups): |
e552a67b933d
Contact update + add dedication in About dialog
Goffi <goffi@goffi.org>
parents:
55
diff
changeset
|
196 """Update contact's roster item""" |
e552a67b933d
Contact update + add dedication in About dialog
Goffi <goffi@goffi.org>
parents:
55
diff
changeset
|
197 profile = ISATSession(self.session).profile |
e552a67b933d
Contact update + add dedication in About dialog
Goffi <goffi@goffi.org>
parents:
55
diff
changeset
|
198 self.sat_host.bridge.updateContact(entity, name, groups, profile) |
e552a67b933d
Contact update + add dedication in About dialog
Goffi <goffi@goffi.org>
parents:
55
diff
changeset
|
199 |
54
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
200 def jsonrpc_subscription(self, sub_type, entity, name, groups): |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
201 """Confirm (or infirm) subscription, |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
202 and setup user roster in case of subscription""" |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
203 profile = ISATSession(self.session).profile |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
204 self.sat_host.bridge.subscription(sub_type, entity, profile) |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
205 if sub_type == 'subscribed': |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
206 self.sat_host.bridge.updateContact(entity, name, groups, profile) |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
207 |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
208 def jsonrpc_getWaitingSub(self): |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
209 """Return list of room already joined by user""" |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
210 profile = ISATSession(self.session).profile |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
211 return self.sat_host.bridge.getWaitingSub(profile) |
54
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
212 |
279
2d6bd975a72d
browser_side: set your own presence status and display those of others
souliane <souliane@mailoo.org>
parents:
277
diff
changeset
|
213 def jsonrpc_setStatus(self, presence, status): |
2d6bd975a72d
browser_side: set your own presence status and display those of others
souliane <souliane@mailoo.org>
parents:
277
diff
changeset
|
214 """Change the presence and/or status |
2d6bd975a72d
browser_side: set your own presence status and display those of others
souliane <souliane@mailoo.org>
parents:
277
diff
changeset
|
215 @param presence: value from ("", "chat", "away", "dnd", "xa") |
2d6bd975a72d
browser_side: set your own presence status and display those of others
souliane <souliane@mailoo.org>
parents:
277
diff
changeset
|
216 @param status: any string to describe your status |
2d6bd975a72d
browser_side: set your own presence status and display those of others
souliane <souliane@mailoo.org>
parents:
277
diff
changeset
|
217 """ |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
218 profile = ISATSession(self.session).profile |
279
2d6bd975a72d
browser_side: set your own presence status and display those of others
souliane <souliane@mailoo.org>
parents:
277
diff
changeset
|
219 self.sat_host.bridge.setPresence('', presence, 0, {'': status}, profile) |
20 | 220 |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
221 |
297
19bcd39c77f6
server side: sendMessage is now async
Goffi <goffi@goffi.org>
parents:
296
diff
changeset
|
222 def jsonrpc_sendMessage(self, to_jid, msg, subject, type_, options={}): |
19 | 223 """send message""" |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
224 profile = ISATSession(self.session).profile |
297
19bcd39c77f6
server side: sendMessage is now async
Goffi <goffi@goffi.org>
parents:
296
diff
changeset
|
225 return self.asyncBridgeCall("sendMessage", to_jid, msg, subject, type_, options, profile) |
0 | 226 |
297
19bcd39c77f6
server side: sendMessage is now async
Goffi <goffi@goffi.org>
parents:
296
diff
changeset
|
227 def jsonrpc_sendMblog(self, type_, dest, text, extra={}): |
201
aa76793da353
server + browser: message warning level/sending refactoring:
Goffi <goffi@goffi.org>
parents:
179
diff
changeset
|
228 """ Send microblog message |
297
19bcd39c77f6
server side: sendMessage is now async
Goffi <goffi@goffi.org>
parents:
296
diff
changeset
|
229 @param type_: one of "PUBLIC", "GROUP" |
201
aa76793da353
server + browser: message warning level/sending refactoring:
Goffi <goffi@goffi.org>
parents:
179
diff
changeset
|
230 @param dest: destinees (list of groups, ignored for "PUBLIC") |
aa76793da353
server + browser: message warning level/sending refactoring:
Goffi <goffi@goffi.org>
parents:
179
diff
changeset
|
231 @param text: microblog's text |
aa76793da353
server + browser: message warning level/sending refactoring:
Goffi <goffi@goffi.org>
parents:
179
diff
changeset
|
232 """ |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
233 profile = ISATSession(self.session).profile |
259
a20815c75c15
server_side: extra data is now added for sendMblog, allowing to send rich text with the 'rich' key.
Goffi <goffi@goffi.org>
parents:
258
diff
changeset
|
234 extra['allow_comments'] = 'True' |
a20815c75c15
server_side: extra data is now added for sendMblog, allowing to send rich text with the 'rich' key.
Goffi <goffi@goffi.org>
parents:
258
diff
changeset
|
235 |
309
05e264e96a1c
browser_side: make unibox optional
souliane <souliane@mailoo.org>
parents:
308
diff
changeset
|
236 if not type_: # auto-detect |
05e264e96a1c
browser_side: make unibox optional
souliane <souliane@mailoo.org>
parents:
308
diff
changeset
|
237 type_ = "PUBLIC" if dest == [] else "GROUP" |
05e264e96a1c
browser_side: make unibox optional
souliane <souliane@mailoo.org>
parents:
308
diff
changeset
|
238 |
297
19bcd39c77f6
server side: sendMessage is now async
Goffi <goffi@goffi.org>
parents:
296
diff
changeset
|
239 if type_ in ("PUBLIC", "GROUP") and text: |
19bcd39c77f6
server side: sendMessage is now async
Goffi <goffi@goffi.org>
parents:
296
diff
changeset
|
240 if type_ == "PUBLIC": |
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
241 #This text if for the public microblog |
133
4ad621df9e34
browser side: group blog is now used to send all microblogs
Goffi <goffi@goffi.org>
parents:
132
diff
changeset
|
242 print "sending public blog" |
259
a20815c75c15
server_side: extra data is now added for sendMblog, allowing to send rich text with the 'rich' key.
Goffi <goffi@goffi.org>
parents:
258
diff
changeset
|
243 return self.sat_host.bridge.sendGroupBlog("PUBLIC", [], text, extra, profile) |
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
244 else: |
133
4ad621df9e34
browser side: group blog is now used to send all microblogs
Goffi <goffi@goffi.org>
parents:
132
diff
changeset
|
245 print "sending group blog" |
259
a20815c75c15
server_side: extra data is now added for sendMblog, allowing to send rich text with the 'rich' key.
Goffi <goffi@goffi.org>
parents:
258
diff
changeset
|
246 return self.sat_host.bridge.sendGroupBlog("GROUP", [dest], text, extra, profile) |
202
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
247 else: |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
248 raise Exception("Invalid data") |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
249 |
282
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
250 def jsonrpc_deleteMblog(self, pub_data, comments): |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
251 """Delete a microblog node |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
252 @param pub_data: a tuple (service, comment node identifier, item identifier) |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
253 @param comments: comments node identifier (for main item) or False |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
254 """ |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
255 profile = ISATSession(self.session).profile |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
256 return self.sat_host.bridge.deleteGroupBlog(pub_data, comments if comments else '', profile) |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
257 |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
258 def jsonrpc_updateMblog(self, pub_data, comments, message, extra={}): |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
259 """Modify a microblog node |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
260 @param pub_data: a tuple (service, comment node identifier, item identifier) |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
261 @param comments: comments node identifier (for main item) or False |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
262 @param message: new message |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
263 @param extra: dict which option name as key, which can be: |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
264 - allow_comments: True to accept an other level of comments, False else (default: False) |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
265 - rich: if present, contain rich text in currently selected syntax |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
266 """ |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
267 profile = ISATSession(self.session).profile |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
268 if comments: |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
269 extra['allow_comments'] = 'True' |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
270 return self.sat_host.bridge.updateGroupBlog(pub_data, comments if comments else '', message, extra, profile) |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
271 |
261
3df0c3634c29
browser side: management of extra data for sendMblogComment, allowing to send rich text for comments
Goffi <goffi@goffi.org>
parents:
259
diff
changeset
|
272 def jsonrpc_sendMblogComment(self, node, text, extra={}): |
202
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
273 """ Send microblog message |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
274 @param node: url of the comments node |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
275 @param text: comment |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
276 """ |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
277 profile = ISATSession(self.session).profile |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
278 if node and text: |
261
3df0c3634c29
browser side: management of extra data for sendMblogComment, allowing to send rich text for comments
Goffi <goffi@goffi.org>
parents:
259
diff
changeset
|
279 return self.sat_host.bridge.sendGroupBlogComment(node, text, extra, profile) |
201
aa76793da353
server + browser: message warning level/sending refactoring:
Goffi <goffi@goffi.org>
parents:
179
diff
changeset
|
280 else: |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
281 raise Exception("Invalid data") |
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
282 |
132
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
283 def jsonrpc_getLastMblogs(self, publisher_jid, max_item): |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
284 """Get last microblogs posted by a contact |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
285 @param publisher_jid: jid of the publisher |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
286 @param max_item: number of items to ask |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
287 @return list of microblog data (dict)""" |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
288 profile = ISATSession(self.session).profile |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
289 d = self.asyncBridgeCall("getLastGroupBlogs", publisher_jid, max_item, profile) |
132
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
290 return d |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
291 |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
292 def jsonrpc_getMassiveLastMblogs(self, publishers_type, publishers_list, max_item): |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
293 """Get lasts microblogs posted by several contacts at once |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
294 @param publishers_type: one of "ALL", "GROUP", "JID" |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
295 @param publishers_list: list of publishers type (empty list of all, list of groups or list of jids) |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
296 @param max_item: number of items to ask |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
297 @return: dictionary key=publisher's jid, value=list of microblog data (dict)""" |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
298 profile = ISATSession(self.session).profile |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
299 d = self.asyncBridgeCall("getMassiveLastGroupBlogs", publishers_type, publishers_list, max_item, profile) |
135
ceef355156de
server + browser side: groupblog subscription + fixed blog insertion order
Goffi <goffi@goffi.org>
parents:
133
diff
changeset
|
300 self.sat_host.bridge.massiveSubscribeGroupBlogs(publishers_type, publishers_list, profile) |
132
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
301 return d |
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
302 |
202
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
303 def jsonrpc_getMblogComments(self, service, node): |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
304 """Get all comments of given node |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
305 @param service: jid of the service hosting the node |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
306 @param node: comments node |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
307 """ |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
308 profile = ISATSession(self.session).profile |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
309 d = self.asyncBridgeCall("getGroupBlogComments", service, node, profile) |
202
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
310 return d |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
311 |
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
312 |
20 | 313 def jsonrpc_getPresenceStatus(self): |
314 """Get Presence information for connected contacts""" | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
315 profile = ISATSession(self.session).profile |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
316 return self.sat_host.bridge.getPresenceStatus(profile) |
20 | 317 |
123 | 318 def jsonrpc_getHistory(self, from_jid, to_jid, size, between): |
19 | 319 """Return history for the from_jid/to_jid couple""" |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
320 sat_session = ISATSession(self.session) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
321 profile = sat_session.profile |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
322 sat_jid = sat_session.jid |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
323 if not sat_jid: |
19 | 324 error("No jid saved for this profile") |
325 return {} | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
326 if JID(from_jid).userhost() != sat_jid.userhost() and JID(to_jid).userhost() != sat_jid.userhost(): |
19 | 327 error("Trying to get history from a different jid, maybe a hack attempt ?") |
328 return {} | |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
329 d = self.asyncBridgeCall("getHistory", from_jid, to_jid, size, between, profile) |
123 | 330 def show(result_dbus): |
331 result = [] | |
332 for line in result_dbus: | |
333 #XXX: we have to do this stupid thing because Python D-Bus use its own types instead of standard types | |
334 # and txJsonRPC doesn't accept D-Bus types, resulting in a empty query | |
235
b304cdf13a3b
browser and server side: XHTML handling, first draft:
Goffi <goffi@goffi.org>
parents:
229
diff
changeset
|
335 timestamp, from_jid, to_jid, message, mess_type, extra = line |
b304cdf13a3b
browser and server side: XHTML handling, first draft:
Goffi <goffi@goffi.org>
parents:
229
diff
changeset
|
336 result.append((float(timestamp), unicode(from_jid), unicode(to_jid), unicode(message), unicode(mess_type), dict(extra))) |
123 | 337 return result |
338 d.addCallback(show) | |
339 return d | |
19 | 340 |
50 | 341 def jsonrpc_joinMUC(self, room_jid, nick): |
266
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
342 """Join a Multi-User Chat room |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
343 @room_jid: leave empty string to generate a unique name |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
344 """ |
50 | 345 profile = ISATSession(self.session).profile |
346 try: | |
266
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
347 if room_jid != "": |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
348 room_jid = JID(room_jid).userhost() |
50 | 349 except: |
350 warning('Invalid room jid') | |
351 return | |
266
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
352 d = self.asyncBridgeCall("joinMUC", room_jid, nick, {}, profile) |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
353 return d |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
354 |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
355 def jsonrpc_inviteMUC(self, contact_jid, room_jid): |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
356 """Invite a user to a Multi-User Chat room""" |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
357 profile = ISATSession(self.session).profile |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
358 try: |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
359 room_jid = JID(room_jid).userhost() |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
360 except: |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
361 warning('Invalid room jid') |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
362 return |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
363 room_id = room_jid.split("@")[0] |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
364 service = room_jid.split("@")[1] |
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
365 self.sat_host.bridge.inviteMUC(contact_jid, service, room_id, {}, profile) |
50 | 366 |
179
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
367 def jsonrpc_mucLeave(self, room_jid): |
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
368 """Quit a Multi-User Chat room""" |
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
369 profile = ISATSession(self.session).profile |
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
370 try: |
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
371 room_jid = JID(room_jid) |
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
372 except: |
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
373 warning('Invalid room jid') |
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
374 return |
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
375 self.sat_host.bridge.mucLeave(room_jid.userhost(), profile) |
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
376 |
121 | 377 def jsonrpc_getRoomsJoined(self): |
30
7684e3ceb12d
server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents:
24
diff
changeset
|
378 """Return list of room already joined by user""" |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
379 profile = ISATSession(self.session).profile |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
380 return self.sat_host.bridge.getRoomsJoined(profile) |
30
7684e3ceb12d
server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents:
24
diff
changeset
|
381 |
268
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
382 def jsonrpc_launchTarotGame(self, other_players, room_jid=""): |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
383 """Create a room, invite the other players and start a Tarot game |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
384 @param room_jid: leave empty string to generate a unique room name |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
385 """ |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
386 profile = ISATSession(self.session).profile |
268
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
387 try: |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
388 if room_jid != "": |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
389 room_jid = JID(room_jid).userhost() |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
390 except: |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
391 warning('Invalid room jid') |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
392 return |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
393 self.sat_host.bridge.tarotGameLaunch(other_players, room_jid, profile) |
11
331c093e4eb3
magicBox is now able to send global microblog
Goffi <goffi@goffi.org>
parents:
10
diff
changeset
|
394 |
36 | 395 def jsonrpc_getTarotCardsPaths(self): |
396 """Give the path of all the tarot cards""" | |
77 | 397 _join = os.path.join |
398 _media_dir = _join(self.sat_host.media_dir,'') | |
317
bbadd490e63c
misc: gather the constants in a single file, as it is done for other frontends
souliane <souliane@mailoo.org>
parents:
309
diff
changeset
|
399 return map(lambda x: _join(Const.MEDIA_DIR, x[len(_media_dir):]), glob.glob(_join(_media_dir, Const.CARDS_DIR, '*_*.png'))); |
36 | 400 |
37
b306aa090438
Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents:
36
diff
changeset
|
401 def jsonrpc_tarotGameReady(self, player, referee): |
b306aa090438
Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents:
36
diff
changeset
|
402 """Tell to the server that we are ready to start the game""" |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
403 profile = ISATSession(self.session).profile |
153
ada146bac8fe
server side: fixed tarotGameReady call
Goffi <goffi@goffi.org>
parents:
151
diff
changeset
|
404 self.sat_host.bridge.tarotGameReady(player, referee, profile) |
36 | 405 |
37
b306aa090438
Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents:
36
diff
changeset
|
406 def jsonrpc_tarotGameContratChoosed(self, player_nick, referee, contrat): |
b306aa090438
Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents:
36
diff
changeset
|
407 """Tell to the server that we are ready to start the game""" |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
408 profile = ISATSession(self.session).profile |
37
b306aa090438
Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents:
36
diff
changeset
|
409 self.sat_host.bridge.tarotGameContratChoosed(player_nick, referee, contrat, profile) |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
410 |
39
305e81c7a32c
Tarot game: a game can now be finished
Goffi <goffi@goffi.org>
parents:
38
diff
changeset
|
411 def jsonrpc_tarotGamePlayCards(self, player_nick, referee, cards): |
128 | 412 """Tell to the server the cards we want to put on the table""" |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
413 profile = ISATSession(self.session).profile |
39
305e81c7a32c
Tarot game: a game can now be finished
Goffi <goffi@goffi.org>
parents:
38
diff
changeset
|
414 self.sat_host.bridge.tarotGamePlayCards(player_nick, referee, cards, profile) |
36 | 415 |
268
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
416 def jsonrpc_launchRadioCollective(self, invited, room_jid=""): |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
417 """Create a room, invite people, and start a radio collective |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
418 @param room_jid: leave empty string to generate a unique room name |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
419 """ |
125
f9d63624699f
radio collective integration, first draft
Goffi <goffi@goffi.org>
parents:
124
diff
changeset
|
420 profile = ISATSession(self.session).profile |
268
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
421 try: |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
422 if room_jid != "": |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
423 room_jid = JID(room_jid).userhost() |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
424 except: |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
425 warning('Invalid room jid') |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
426 return |
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
427 self.sat_host.bridge.radiocolLaunch(invited, room_jid, profile) |
125
f9d63624699f
radio collective integration, first draft
Goffi <goffi@goffi.org>
parents:
124
diff
changeset
|
428 |
137 | 429 def jsonrpc_getEntityData(self, jid, keys): |
430 """Get cached data for an entit | |
431 @param jid: jid of contact from who we want data | |
432 @param keys: name of data we want (list) | |
433 @return: requested data""" | |
124
6d1f4a3da29b
server: fixed buggy vcard cache retrieving, fixes avatar issue
Goffi <goffi@goffi.org>
parents:
123
diff
changeset
|
434 profile = ISATSession(self.session).profile |
137 | 435 return self.sat_host.bridge.getEntityData(jid, keys, profile) |
110
dfc02690deb4
browser side: CSS: header, unibox, tabs + drag'n' drop reworked
Adrien Vigneron <adrienvigneron@mailoo.org>
parents:
107
diff
changeset
|
436 |
204
890776a6fdb7
browser + server: vcard is requested when no avatar data is found in cache
Goffi <goffi@goffi.org>
parents:
202
diff
changeset
|
437 def jsonrpc_getCard(self, jid): |
890776a6fdb7
browser + server: vcard is requested when no avatar data is found in cache
Goffi <goffi@goffi.org>
parents:
202
diff
changeset
|
438 """Get VCard for entiry |
890776a6fdb7
browser + server: vcard is requested when no avatar data is found in cache
Goffi <goffi@goffi.org>
parents:
202
diff
changeset
|
439 @param jid: jid of contact from who we want data |
890776a6fdb7
browser + server: vcard is requested when no avatar data is found in cache
Goffi <goffi@goffi.org>
parents:
202
diff
changeset
|
440 @return: id to retrieve the profile""" |
890776a6fdb7
browser + server: vcard is requested when no avatar data is found in cache
Goffi <goffi@goffi.org>
parents:
202
diff
changeset
|
441 profile = ISATSession(self.session).profile |
890776a6fdb7
browser + server: vcard is requested when no avatar data is found in cache
Goffi <goffi@goffi.org>
parents:
202
diff
changeset
|
442 return self.sat_host.bridge.getCard(jid, profile) |
890776a6fdb7
browser + server: vcard is requested when no avatar data is found in cache
Goffi <goffi@goffi.org>
parents:
202
diff
changeset
|
443 |
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
444 def jsonrpc_getParamsUI(self): |
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
445 """Return the parameters XML for profile""" |
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
446 profile = ISATSession(self.session).profile |
318
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
447 d = self.asyncBridgeCall("getParams", Const.SECURITY_LIMIT, Const.APP_NAME, profile) |
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
448 |
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
449 def setAuthorizedParams(d): |
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
450 if self.authorized_params is None: |
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
451 self.authorized_params = {} |
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
452 for cat in minidom.parseString(d.encode('utf-8')).getElementsByTagName("category"): |
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
453 params = cat.getElementsByTagName("param") |
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
454 params_list = [param.getAttribute("name") for param in params] |
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
455 self.authorized_params[cat.getAttribute("name")] = params_list |
218
4e6467efd6bf
browser_side: small improvements for parameters panel
souliane <souliane@mailoo.org>
parents:
215
diff
changeset
|
456 if self.authorized_params: |
4e6467efd6bf
browser_side: small improvements for parameters panel
souliane <souliane@mailoo.org>
parents:
215
diff
changeset
|
457 return d |
4e6467efd6bf
browser_side: small improvements for parameters panel
souliane <souliane@mailoo.org>
parents:
215
diff
changeset
|
458 else: |
4e6467efd6bf
browser_side: small improvements for parameters panel
souliane <souliane@mailoo.org>
parents:
215
diff
changeset
|
459 return None |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
460 |
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
461 d.addCallback(setAuthorizedParams) |
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
462 |
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
463 from sat.tools.xml_tools import paramsXml2xmlUI |
218
4e6467efd6bf
browser_side: small improvements for parameters panel
souliane <souliane@mailoo.org>
parents:
215
diff
changeset
|
464 d.addCallback(lambda d: paramsXml2xmlUI(d) if d else "") |
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
465 |
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
466 return d |
148
8635bc9db9bf
added parameter management to test XMLUI, but it's currently deactivated for security reasons (need some configuration options) + separated mainTabPanel CSS from LiberviaTabPanel
Goffi <goffi@goffi.org>
parents:
140
diff
changeset
|
467 |
229
e632f77c4219
bridge: asyncGetParamA takes a security_limit argument
souliane <souliane@mailoo.org>
parents:
219
diff
changeset
|
468 def jsonrpc_asyncGetParamA(self, param, category, attribute="value"): |
e632f77c4219
bridge: asyncGetParamA takes a security_limit argument
souliane <souliane@mailoo.org>
parents:
219
diff
changeset
|
469 """Return the parameter value for profile""" |
e632f77c4219
bridge: asyncGetParamA takes a security_limit argument
souliane <souliane@mailoo.org>
parents:
219
diff
changeset
|
470 profile = ISATSession(self.session).profile |
317
bbadd490e63c
misc: gather the constants in a single file, as it is done for other frontends
souliane <souliane@mailoo.org>
parents:
309
diff
changeset
|
471 d = self.asyncBridgeCall("asyncGetParamA", param, category, attribute, Const.SECURITY_LIMIT, profile_key=profile) |
229
e632f77c4219
bridge: asyncGetParamA takes a security_limit argument
souliane <souliane@mailoo.org>
parents:
219
diff
changeset
|
472 return d |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
473 |
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
474 def jsonrpc_setParam(self, name, value, category): |
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
475 profile = ISATSession(self.session).profile |
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
476 if category in self.authorized_params and name in self.authorized_params[category]: |
317
bbadd490e63c
misc: gather the constants in a single file, as it is done for other frontends
souliane <souliane@mailoo.org>
parents:
309
diff
changeset
|
477 return self.sat_host.bridge.setParam(name, value, category, Const.SECURITY_LIMIT, profile) |
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
478 else: |
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
479 warning("Trying to set parameter '%s' in category '%s' without authorization!!!" |
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
480 % (name, category)) |
148
8635bc9db9bf
added parameter management to test XMLUI, but it's currently deactivated for security reasons (need some configuration options) + separated mainTabPanel CSS from LiberviaTabPanel
Goffi <goffi@goffi.org>
parents:
140
diff
changeset
|
481 |
299
e4f586fc6101
server and browser side: updated callback system to follow core changes
Goffi <goffi@goffi.org>
parents:
297
diff
changeset
|
482 def jsonrpc_launchAction(self, callback_id, data): |
148
8635bc9db9bf
added parameter management to test XMLUI, but it's currently deactivated for security reasons (need some configuration options) + separated mainTabPanel CSS from LiberviaTabPanel
Goffi <goffi@goffi.org>
parents:
140
diff
changeset
|
483 profile = ISATSession(self.session).profile |
299
e4f586fc6101
server and browser side: updated callback system to follow core changes
Goffi <goffi@goffi.org>
parents:
297
diff
changeset
|
484 d = self.asyncBridgeCall("launchAction", callback_id, data, profile) |
e4f586fc6101
server and browser side: updated callback system to follow core changes
Goffi <goffi@goffi.org>
parents:
297
diff
changeset
|
485 return d |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
486 |
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
487 def jsonrpc_chatStateComposing(self, to_jid_s): |
242
a25aa882e09a
browser_side: add context menu for contact:
souliane <souliane@mailoo.org>
parents:
235
diff
changeset
|
488 """Call the method to process a "composing" state. |
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
489 @param to_jid_s: contact the user is composing to |
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
490 """ |
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
491 profile = ISATSession(self.session).profile |
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
492 self.sat_host.bridge.chatStateComposing(to_jid_s, profile) |
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
493 |
242
a25aa882e09a
browser_side: add context menu for contact:
souliane <souliane@mailoo.org>
parents:
235
diff
changeset
|
494 def jsonrpc_getNewAccountDomain(self): |
a25aa882e09a
browser_side: add context menu for contact:
souliane <souliane@mailoo.org>
parents:
235
diff
changeset
|
495 """@return: the domain for new account creation""" |
a25aa882e09a
browser_side: add context menu for contact:
souliane <souliane@mailoo.org>
parents:
235
diff
changeset
|
496 d = self.asyncBridgeCall("getNewAccountDomain") |
a25aa882e09a
browser_side: add context menu for contact:
souliane <souliane@mailoo.org>
parents:
235
diff
changeset
|
497 return d |
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
498 |
251
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
499 def jsonrpc_confirmationAnswer(self, confirmation_id, result, answer_data): |
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
500 """Send the user's answer to any previous 'askConfirmation' signal""" |
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
501 profile = ISATSession(self.session).profile |
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
502 self.sat_host.bridge.confirmationAnswer(confirmation_id, result, answer_data, profile) |
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
503 |
309
05e264e96a1c
browser_side: make unibox optional
souliane <souliane@mailoo.org>
parents:
308
diff
changeset
|
504 def jsonrpc_syntaxConvert(self, text, syntax_from=Const.SYNTAX_XHTML, syntax_to=Const.SYNTAX_CURRENT): |
282
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
505 """ Convert a text between two syntaxes |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
506 @param text: text to convert |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
507 @param syntax_from: source syntax (e.g. "markdown") |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
508 @param syntax_to: dest syntax (e.g.: "XHTML") |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
509 @param safe: clean resulting XHTML to avoid malicious code if True (forced here) |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
510 @return: converted text """ |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
511 profile = ISATSession(self.session).profile |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
512 return self.sat_host.bridge.syntaxConvert(text, syntax_from, syntax_to, True, profile) |
ae3ec654836d
browser_side: added blog item modification/deletion
souliane <souliane@mailoo.org>
parents:
279
diff
changeset
|
513 |
251
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
514 |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
515 class Register(JSONRPCMethodManager): |
0 | 516 """This class manage the registration procedure with SàT |
517 It provide an api for the browser, check password and setup the web server""" | |
518 | |
519 def __init__(self, sat_host): | |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
520 JSONRPCMethodManager.__init__(self, sat_host) |
0 | 521 self.profiles_waiting={} |
522 self.request=None | |
523 | |
524 def getWaitingRequest(self, profile): | |
525 """Tell if a profile is trying to log in""" | |
526 if self.profiles_waiting.has_key(profile): | |
527 return self.profiles_waiting[profile] | |
528 else: | |
529 return None | |
530 | |
531 def render(self, request): | |
532 """ | |
533 Render method with some hacks: | |
534 - if login is requested, try to login with form data | |
535 - except login, every method is jsonrpc | |
318
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
536 - user doesn't need to be authentified for isRegistered or registerParams, but must be for all other methods |
0 | 537 """ |
538 if request.postpath==['login']: | |
539 return self.login(request) | |
540 _session = request.getSession() | |
541 parsed = jsonrpclib.loads(request.content.read()) | |
318
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
542 method = parsed.get("method") |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
543 if method != "isRegistered" and method != "registerParams": |
0 | 544 #if we don't call login or isRegistered, we need to be identified |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
545 profile = ISATSession(_session).profile |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
546 if not profile: |
0 | 547 #user is not identified, we return a jsonrpc fault |
317
bbadd490e63c
misc: gather the constants in a single file, as it is done for other frontends
souliane <souliane@mailoo.org>
parents:
309
diff
changeset
|
548 fault = jsonrpclib.Fault(Const.ERRNUM_LIBERVIA, "Not allowed") #FIXME: define some standard error codes for libervia |
0 | 549 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc')) |
550 self.request = request | |
551 return jsonrpc.JSONRPC.render(self, request) | |
552 | |
553 def login(self, request): | |
554 """ | |
555 this method is called with the POST information from the registering form | |
556 it test if the password is ok, and log in if it's the case, | |
557 else it return an error | |
558 @param request: request of the register formulaire, must have "login" and "password" as arguments | |
559 @return: A constant indicating the state: | |
560 - BAD REQUEST: something is wrong in the request (bad arguments, profile_key for login) | |
561 - AUTH ERROR: either the profile or the password is wrong | |
562 - ALREADY WAITING: a request has already be made for this profile | |
563 - server.NOT_DONE_YET: the profile is being processed, the return value will be given by self._logged or self._logginError | |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
564 """ |
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
565 |
0 | 566 try: |
66
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
567 if request.args['submit_type'][0] == 'login': |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
568 _login = request.args['login'][0] |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
569 if _login.startswith('@'): |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
570 raise Exception('No profile_key allowed') |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
571 _pass = request.args['login_password'][0] |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
572 |
66
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
573 elif request.args['submit_type'][0] == 'register': |
160
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
574 return self._registerNewAccount(request) |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
575 |
66
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
576 else: |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
577 raise Exception('Unknown submit type') |
0 | 578 except KeyError: |
579 return "BAD REQUEST" | |
580 | |
581 _profile_check = self.sat_host.bridge.getProfileName(_login) | |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
582 |
121 | 583 def profile_pass_cb(_profile_pass): |
584 if not _profile_check or _profile_check != _login or _profile_pass != _pass: | |
585 request.write("AUTH ERROR") | |
586 request.finish() | |
587 return | |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
588 |
121 | 589 if self.profiles_waiting.has_key(_login): |
590 request.write("ALREADY WAITING") | |
591 request.finish() | |
592 return | |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
593 |
121 | 594 if self.sat_host.bridge.isConnected(_login): |
595 request.write(self._logged(_login, request, finish=False)) | |
596 request.finish() | |
597 return | |
598 | |
599 self.profiles_waiting[_login] = request | |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
600 d = self.asyncBridgeCall("asyncConnect", _login) |
155 | 601 return d |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
602 |
121 | 603 def profile_pass_errback(ignore): |
604 error("INTERNAL ERROR: can't check profile password") | |
605 request.write("AUTH ERROR") | |
606 request.finish() | |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
607 |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
608 d = self.asyncBridgeCall("asyncGetParamA", "Password", "Connection", profile_key=_login) |
121 | 609 d.addCallbacks(profile_pass_cb, profile_pass_errback) |
0 | 610 |
611 return server.NOT_DONE_YET | |
612 | |
46 | 613 def _postAccountCreation(self, answer_type, id, data, profile): |
614 """Called when a account has just been created, | |
615 setup stuff has microblog access""" | |
616 def _connected(ignore): | |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
617 mblog_d = self.asyncBridgeCall("setMicroblogAccess", "open", profile) |
46 | 618 mblog_d.addBoth(lambda ignore: self.sat_host.bridge.disconnect(profile)) |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
619 |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
620 d = self.asyncBridgeCall("asyncConnect", profile) |
46 | 621 d.addCallback(_connected) |
622 | |
160
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
623 def _registerNewAccount(self, request): |
46 | 624 """Create a new account, or return error |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
625 @param request: initial login request |
46 | 626 @return: "REGISTRATION" in case of success""" |
54
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
627 #TODO: must be moved in SàT core |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
628 |
46 | 629 try: |
160
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
630 profile = login = request.args['register_login'][0] |
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
631 password = request.args['register_password'][0] #FIXME: password is ignored so far |
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
632 email = request.args['email'][0] |
46 | 633 except KeyError: |
634 return "BAD REQUEST" | |
635 if not re.match(r'^[a-z0-9_-]+$', login, re.IGNORECASE) or \ | |
636 not re.match(r'^.+@.+\..+', email, re.IGNORECASE): | |
637 return "BAD REQUEST" | |
638 | |
160
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
639 def registered(result): |
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
640 request.write('REGISTRATION') |
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
641 request.finish() |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
642 |
160
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
643 def registeringError(failure): |
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
644 reason = str(failure.value) |
295
33e0eb212b14
server side: adapted registeringError reasons to new names in backend
Goffi <goffi@goffi.org>
parents:
282
diff
changeset
|
645 if reason == "ConflictError": |
160
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
646 request.write('ALREADY EXISTS') |
295
33e0eb212b14
server side: adapted registeringError reasons to new names in backend
Goffi <goffi@goffi.org>
parents:
282
diff
changeset
|
647 elif reason == "InternalError": |
160
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
648 request.write('INTERNAL') |
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
649 else: |
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
650 error('Unknown registering error: %s' % (reason,)) |
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
651 request.write('Unknown error (%s)' % reason) |
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
652 request.finish() |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
653 |
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
654 d = self.asyncBridgeCall("registerSatAccount", email, password, profile) |
160
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
655 d.addCallback(registered) |
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
656 d.addErrback(registeringError) |
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
657 return server.NOT_DONE_YET |
46 | 658 |
0 | 659 def __cleanWaiting(self, login): |
660 """Remove login from waiting queue""" | |
661 try: | |
662 del self.profiles_waiting[login] | |
663 except KeyError: | |
664 pass | |
665 | |
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
666 def _logged(self, profile, request, finish=True): |
0 | 667 """Set everything when a user just logged |
668 and return "LOGGED" to the requester""" | |
61 | 669 def result(answer): |
670 if finish: | |
671 request.write(answer) | |
672 request.finish() | |
673 else: | |
674 return answer | |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
675 |
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
676 self.__cleanWaiting(profile) |
0 | 677 _session = request.getSession() |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
678 sat_session = ISATSession(_session) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
679 if sat_session.profile: |
61 | 680 error (('/!\\ Session has already a profile, this should NEVER happen !')) |
681 return result('SESSION_ACTIVE') | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
682 sat_session.profile = profile |
24 | 683 self.sat_host.prof_connected.add(profile) |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
684 |
45
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
685 def onExpire(): |
156 | 686 info ("Session expired (profile=%s)" % (profile,)) |
45
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
687 try: |
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
688 #We purge the queue |
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
689 del self.sat_host.signal_handler.queue[profile] |
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
690 except KeyError: |
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
691 pass |
130 | 692 #and now we disconnect the profile |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
693 self.sat_host.bridge.disconnect(profile) |
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
694 |
45
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
695 _session.notifyOnExpire(onExpire) |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
696 |
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
697 d = defer.Deferred() |
61 | 698 return result('LOGGED') |
0 | 699 |
700 def _logginError(self, login, request, error_type): | |
701 """Something went wrong during loggin, return an error""" | |
702 self.__cleanWaiting(login) | |
703 return error_type | |
704 | |
705 def jsonrpc_isConnected(self): | |
706 _session = self.request.getSession() | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
707 profile = ISATSession(_session).profile |
0 | 708 return self.sat_host.bridge.isConnected(profile) |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
709 |
0 | 710 def jsonrpc_connect(self): |
711 _session = self.request.getSession() | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
712 profile = ISATSession(_session).profile |
0 | 713 if self.profiles_waiting.has_key(profile): |
296
92d76ab67156
server+browser side: fixed bridge errback handling
Goffi <goffi@goffi.org>
parents:
295
diff
changeset
|
714 raise jsonrpclib.Fault(1,'Already waiting') #FIXME: define some standard error codes for libervia |
0 | 715 self.profiles_waiting[profile] = self.request |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
716 self.sat_host.bridge.connect(profile) |
0 | 717 return server.NOT_DONE_YET |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
718 |
0 | 719 def jsonrpc_isRegistered(self): |
720 """Tell if the user is already registered""" | |
721 _session = self.request.getSession() | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
722 profile = ISATSession(_session).profile |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
723 return bool(profile) |
251
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
724 |
318
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
725 def jsonrpc_registerParams(self): |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
726 """Register the frontend specific parameters""" |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
727 params = """ |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
728 <params> |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
729 <individual> |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
730 <category name="%(category_name)s" label="%(category_label)s"> |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
731 <param name="%(param_name)s" label="%(param_label)s" value="true" type="bool" security="0"/> |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
732 </category> |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
733 </individual> |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
734 </params> |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
735 """ % { |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
736 'category_name': Const.ENABLE_UNIBOX_KEY, |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
737 'category_label': _(Const.ENABLE_UNIBOX_KEY), |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
738 'param_name': Const.ENABLE_UNIBOX_PARAM, |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
739 'param_label': _(Const.ENABLE_UNIBOX_PARAM) |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
740 } |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
741 |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
742 self.sat_host.bridge.paramsRegisterApp(params, Const.SECURITY_LIMIT, Const.APP_NAME) |
c12c9a1acf2f
server_side: added support for paramsRegisterApp to define frontend's specific parameters like "Enable unibox"
souliane <souliane@mailoo.org>
parents:
317
diff
changeset
|
743 |
251
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
744 |
0 | 745 class SignalHandler(jsonrpc.JSONRPC): |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
746 |
0 | 747 def __init__(self, sat_host): |
748 Resource.__init__(self) | |
749 self.register=None | |
750 self.sat_host=sat_host | |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
751 self.signalDeferred = {} |
45
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
752 self.queue = {} |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
753 |
0 | 754 def plugRegister(self, register): |
755 self.register = register | |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
756 |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
757 def jsonrpc_getSignals(self): |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
758 """Keep the connection alive until a signal is received, then send it |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
759 @return: (signal, *signal_args)""" |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
760 _session = self.request.getSession() |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
761 profile = ISATSession(_session).profile |
24 | 762 if profile in self.queue: #if we have signals to send in queue |
763 if self.queue[profile]: | |
764 return self.queue[profile].pop(0) | |
765 else: | |
766 #the queue is empty, we delete the profile from queue | |
767 del self.queue[profile] | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
768 _session.lock() #we don't want the session to expire as long as this connection is active |
156 | 769 def unlock(signal, profile): |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
770 _session.unlock() |
156 | 771 try: |
772 source_defer = self.signalDeferred[profile] | |
773 if source_defer.called and source_defer.result[0] == "disconnected": | |
774 info(u"[%s] disconnected" % (profile,)) | |
775 _session.expire() | |
776 except IndexError: | |
777 error("Deferred result should be a tuple with fonction name first") | |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
778 |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
779 self.signalDeferred[profile] = defer.Deferred() |
156 | 780 self.request.notifyFinish().addBoth(unlock, profile) |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
781 return self.signalDeferred[profile] |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
782 |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
783 def getGenericCb(self, function_name): |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
784 """Return a generic function which send all params to signalDeferred.callback |
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
785 function must have profile as last argument""" |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
786 def genericCb(*args): |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
787 profile = args[-1] |
24 | 788 if not profile in self.sat_host.prof_connected: |
789 return | |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
790 if profile in self.signalDeferred: |
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
791 self.signalDeferred[profile].callback((function_name,args[:-1])) |
24 | 792 del self.signalDeferred[profile] |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
793 else: |
24 | 794 if not self.queue.has_key(profile): |
795 self.queue[profile] = [] | |
796 self.queue[profile].append((function_name, args[:-1])) | |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
797 return genericCb |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
798 |
0 | 799 def connected(self, profile): |
800 assert(self.register) #register must be plugged | |
801 request = self.register.getWaitingRequest(profile) | |
802 if request: | |
803 self.register._logged(profile, request) | |
804 | |
156 | 805 def disconnected(self, profile): |
806 if not profile in self.sat_host.prof_connected: | |
807 error("'disconnected' signal received for a not connected profile") | |
808 return | |
809 self.sat_host.prof_connected.remove(profile) | |
810 if profile in self.signalDeferred: | |
811 self.signalDeferred[profile].callback(("disconnected",)) | |
812 del self.signalDeferred[profile] | |
813 else: | |
814 if not self.queue.has_key(profile): | |
815 self.queue[profile] = [] | |
816 self.queue[profile].append(("disconnected",)) | |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
817 |
156 | 818 |
0 | 819 def connectionError(self, error_type, profile): |
820 assert(self.register) #register must be plugged | |
821 request = self.register.getWaitingRequest(profile) | |
822 if request: #The user is trying to log in | |
823 if error_type == "AUTH_ERROR": | |
824 _error_t = "AUTH ERROR" | |
825 else: | |
826 _error_t = "UNKNOWN" | |
827 self.register._logginError(profile, request, _error_t) | |
828 | |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
829 def render(self, request): |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
830 """ |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
831 Render method wich reject access if user is not identified |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
832 """ |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
833 _session = request.getSession() |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
834 parsed = jsonrpclib.loads(request.content.read()) |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
835 profile = ISATSession(_session).profile |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
836 if not profile: |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
837 #user is not identified, we return a jsonrpc fault |
317
bbadd490e63c
misc: gather the constants in a single file, as it is done for other frontends
souliane <souliane@mailoo.org>
parents:
309
diff
changeset
|
838 fault = jsonrpclib.Fault(Const.ERRNUM_LIBERVIA, "Not allowed") #FIXME: define some standard error codes for libervia |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
839 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc')) |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
840 self.request = request |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
841 return jsonrpc.JSONRPC.render(self, request) |
0 | 842 |
127 | 843 class UploadManager(Resource): |
844 """This class manage the upload of a file | |
845 It redirect the stream to SàT core backend""" | |
846 isLeaf = True | |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
847 NAME = 'path' #name use by the FileUpload |
127 | 848 |
849 def __init__(self, sat_host): | |
850 self.sat_host=sat_host | |
851 self.upload_dir = tempfile.mkdtemp() | |
852 self.sat_host.addCleanup(shutil.rmtree, self.upload_dir) | |
853 | |
128 | 854 def getTmpDir(self): |
855 return self.upload_dir | |
856 | |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
857 def _getFileName(self, request): |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
858 """Generate unique filename for a file""" |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
859 raise NotImplementedError |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
860 |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
861 def _fileWritten(self, request, filepath): |
300
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
862 """Called once the file is actually written on disk |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
863 @param request: HTTP request object |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
864 @param filepath: full filepath on the server |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
865 @return: a tuple with the name of the async bridge method |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
866 to be called followed by its arguments. |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
867 """ |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
868 raise NotImplementedError |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
869 |
127 | 870 def render(self, request): |
871 """ | |
872 Render method with some hacks: | |
873 - if login is requested, try to login with form data | |
874 - except login, every method is jsonrpc | |
875 - user doesn't need to be authentified for isRegistered, but must be for all other methods | |
876 """ | |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
877 filename = self._getFileName(request) |
128 | 878 filepath = os.path.join(self.upload_dir, filename) |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
879 #FIXME: the uploaded file is fully loaded in memory at form parsing time so far |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
880 # (see twisted.web.http.Request.requestReceived). A custom requestReceived should |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
881 # be written in the futur. In addition, it is not yet possible to get progression informations |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
882 # (see http://twistedmatrix.com/trac/ticket/288) |
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
883 |
128 | 884 with open(filepath,'w') as f: |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
885 f.write(request.args[self.NAME][0]) |
300
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
886 |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
887 def finish(d): |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
888 error = isinstance(d, Exception) or isinstance (d, Failure) |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
889 request.write('KO' if error else 'OK') |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
890 # TODO: would be great to re-use the original Exception class and message |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
891 # but it is lost in the middle of the backtrace and encapsulated within |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
892 # a DBusException instance --> extract the data from the backtrace? |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
893 request.finish() |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
894 |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
895 d = JSONRPCMethodManager(self.sat_host).asyncBridgeCall(*self._fileWritten(request, filepath)) |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
896 d.addCallbacks(lambda d: finish(d), lambda failure: finish(failure)) |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
897 return server.NOT_DONE_YET |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
898 |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
899 |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
900 class UploadManagerRadioCol(UploadManager): |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
901 NAME = 'song' |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
902 |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
903 def _getFileName(self, request): |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
904 return "%s.ogg" % str(uuid.uuid4()) #XXX: chromium doesn't seem to play song without the .ogg extension, even with audio/ogg mime-type |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
905 |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
906 def _fileWritten(self, request, filepath): |
300
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
907 """Called once the file is actually written on disk |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
908 @param request: HTTP request object |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
909 @param filepath: full filepath on the server |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
910 @return: a tuple with the name of the async bridge method |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
911 to be called followed by its arguments. |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
912 """ |
128 | 913 profile = ISATSession(request.getSession()).profile |
300
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
914 return ("radiocolSongAdded", request.args['referee'][0], filepath, profile) |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
915 |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
916 |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
917 class UploadManagerAvatar(UploadManager): |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
918 NAME = 'avatar_path' |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
919 |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
920 def _getFileName(self, request): |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
921 return str(uuid.uuid4()) |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
922 |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
923 def _fileWritten(self, request, filepath): |
300
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
924 """Called once the file is actually written on disk |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
925 @param request: HTTP request object |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
926 @param filepath: full filepath on the server |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
927 @return: a tuple with the name of the async bridge method |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
928 to be called followed by its arguments. |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
929 """ |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
930 profile = ISATSession(request.getSession()).profile |
300
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
931 return ("setAvatar", filepath, profile) |
4f221f34bdc7
browser_side (plugins radiocol, xep-0054): handle upload errors
souliane <souliane@mailoo.org>
parents:
299
diff
changeset
|
932 |
10 | 933 |
0 | 934 class Libervia(service.Service): |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
935 |
0 | 936 def __init__(self): |
127 | 937 self._cleanup = [] |
317
bbadd490e63c
misc: gather the constants in a single file, as it is done for other frontends
souliane <souliane@mailoo.org>
parents:
309
diff
changeset
|
938 root = ProtectedFile(Const.LIBERVIA_DIR) |
0 | 939 self.signal_handler = SignalHandler(self) |
940 _register = Register(self) | |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
941 _upload_radiocol = UploadManagerRadioCol(self) |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
942 _upload_avatar = UploadManagerAvatar(self) |
0 | 943 self.signal_handler.plugRegister(_register) |
944 self.sessions = {} #key = session value = user | |
24 | 945 self.prof_connected = set() #Profiles connected |
46 | 946 self.action_handler = SATActionIDHandler() |
0 | 947 ## bridge ## |
948 try: | |
949 self.bridge=DBusBridgeFrontend() | |
950 except BridgeExceptionNoService: | |
951 print(u"Can't connect to SàT backend, are you sure it's launched ?") | |
952 sys.exit(1) | |
953 self.bridge.register("connected", self.signal_handler.connected) | |
156 | 954 self.bridge.register("disconnected", self.signal_handler.disconnected) |
0 | 955 self.bridge.register("connectionError", self.signal_handler.connectionError) |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
956 self.bridge.register("actionResult", self.action_handler.actionResultCb) |
117
2e2e10785c33
server side: refactored signal according to SàT's bridge changes + getCardCache handling + updatedValue handling
Goffi <goffi@goffi.org>
parents:
110
diff
changeset
|
957 #core |
251
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
958 for signal_name in ['presenceUpdate', 'newMessage', 'subscribe', 'contactDeleted', 'newContact', 'entityDataUpdated', 'askConfirmation', 'newAlert']: |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
959 self.bridge.register(signal_name, self.signal_handler.getGenericCb(signal_name)) |
117
2e2e10785c33
server side: refactored signal according to SàT's bridge changes + getCardCache handling + updatedValue handling
Goffi <goffi@goffi.org>
parents:
110
diff
changeset
|
960 #plugins |
2e2e10785c33
server side: refactored signal according to SàT's bridge changes + getCardCache handling + updatedValue handling
Goffi <goffi@goffi.org>
parents:
110
diff
changeset
|
961 for signal_name in ['personalEvent', 'roomJoined', 'roomUserJoined', 'roomUserLeft', 'tarotGameStarted', 'tarotGameNew', 'tarotGameChooseContrat', |
275
a763b2ac5d41
bridge + browser_side: bridge signals for games and their callbacks:
souliane <souliane@mailoo.org>
parents:
268
diff
changeset
|
962 'tarotGameShowCards', 'tarotGameInvalidCards', 'tarotGameCardsPlayed', 'tarotGameYourTurn', 'tarotGameScore', 'tarotGamePlayers', |
a763b2ac5d41
bridge + browser_side: bridge signals for games and their callbacks:
souliane <souliane@mailoo.org>
parents:
268
diff
changeset
|
963 'radiocolStarted', 'radiocolPreload', 'radiocolPlay', 'radiocolNoUpload', 'radiocolUploadOk', 'radiocolSongRejected', 'radiocolPlayers', |
a763b2ac5d41
bridge + browser_side: bridge signals for games and their callbacks:
souliane <souliane@mailoo.org>
parents:
268
diff
changeset
|
964 'roomLeft', 'chatStateReceived']: |
117
2e2e10785c33
server side: refactored signal according to SàT's bridge changes + getCardCache handling + updatedValue handling
Goffi <goffi@goffi.org>
parents:
110
diff
changeset
|
965 self.bridge.register(signal_name, self.signal_handler.getGenericCb(signal_name), "plugin") |
77 | 966 self.media_dir = self.bridge.getConfig('','media_dir') |
107
c3fb3292f582
browser side: CSS: changed tabs margin + fixed dragover background for chat panels
Goffi <goffi@goffi.org>
parents:
77
diff
changeset
|
967 self.local_dir = self.bridge.getConfig('','local_dir') |
172
631556a64850
server side: added root redirection to libervia.html
Goffi <goffi@goffi.org>
parents:
165
diff
changeset
|
968 root.putChild('', Redirect('libervia.html')) |
10 | 969 root.putChild('json_signal_api', self.signal_handler) |
970 root.putChild('json_api', MethodHandler(self)) | |
971 root.putChild('register_api', _register) | |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
972 root.putChild('upload_radiocol', _upload_radiocol) |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
973 root.putChild('upload_avatar', _upload_avatar) |
10 | 974 root.putChild('blog', MicroBlog(self)) |
59
d0fa4e96a5e4
server side: 404 error is now sent instead of directory listing when requesting a directory
Goffi <goffi@goffi.org>
parents:
57
diff
changeset
|
975 root.putChild('css', ProtectedFile("server_css/")) |
317
bbadd490e63c
misc: gather the constants in a single file, as it is done for other frontends
souliane <souliane@mailoo.org>
parents:
309
diff
changeset
|
976 root.putChild(os.path.dirname(Const.MEDIA_DIR), ProtectedFile(self.media_dir)) |
bbadd490e63c
misc: gather the constants in a single file, as it is done for other frontends
souliane <souliane@mailoo.org>
parents:
309
diff
changeset
|
977 root.putChild(os.path.dirname(Const.AVATARS_DIR), ProtectedFile(os.path.join(self.local_dir, Const.AVATARS_DIR))) |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
978 root.putChild('radiocol', ProtectedFile(_upload_radiocol.getTmpDir(), defaultType="audio/ogg")) #We cheat for PoC because we know we are on the same host, so we use directly upload dir |
10 | 979 self.site = server.Site(root) |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
980 self.site.sessionFactory = LiberviaSession |
0 | 981 |
127 | 982 def addCleanup(self, callback, *args, **kwargs): |
983 """Add cleaning method to call when service is stopped | |
984 cleaning method will be called in reverse order of they insertion | |
985 @param callback: callable to call on service stop | |
986 @param *args: list of arguments of the callback | |
987 @param **kwargs: list of keyword arguments of the callback""" | |
988 self._cleanup.insert(0, (callback, args, kwargs)) | |
989 | |
0 | 990 def startService(self): |
991 reactor.listenTCP(8080, self.site) | |
127 | 992 |
993 def stopService(self): | |
994 print "launching cleaning methods" | |
995 for callback, args, kwargs in self._cleanup: | |
996 callback(*args, **kwargs) | |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
997 |
0 | 998 def run(self): |
999 reactor.run() | |
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
1000 |
0 | 1001 def stop(self): |
1002 reactor.stop() | |
1003 | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
1004 registerAdapter(SATSession, server.Session, ISATSession) |
317
bbadd490e63c
misc: gather the constants in a single file, as it is done for other frontends
souliane <souliane@mailoo.org>
parents:
309
diff
changeset
|
1005 application = service.Application(Const.APP_NAME) |
0 | 1006 service = Libervia() |
1007 service.setServiceParent(application) |