Mercurial > libervia-web
annotate libervia.tac @ 281:36ce989c73a5
browser_side: more customizable rich text editor
| author | souliane <souliane@mailoo.org> |
|---|---|
| date | Mon, 09 Dec 2013 15:34:03 +0100 |
| parents | 2d6bd975a72d |
| children | ae3ec654836d |
| 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 | |
| 36 from sat_frontends.bridge.DBus import DBusBridgeFrontend,BridgeExceptionNoService | |
| 46 | 37 from logging import debug, info, warning, error |
| 127 | 38 import re, glob |
| 39 import os.path, sys | |
| 40 import tempfile, shutil, uuid | |
| 10 | 41 from server_side.blog import MicroBlog |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
42 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
|
43 from xml.dom import minidom |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
44 |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
45 |
|
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
46 #import time |
| 10 | 47 |
| 154 | 48 TIMEOUT = 300 #Session's time out, after that the user will be disconnected |
| 36 | 49 LIBERVIA_DIR = "output/" |
| 77 | 50 MEDIA_DIR = "media/" |
|
110
dfc02690deb4
browser side: CSS: header, unibox, tabs + drag'n' drop reworked
Adrien Vigneron <adrienvigneron@mailoo.org>
parents:
107
diff
changeset
|
51 AVATARS_DIR = "avatars/" |
| 77 | 52 CARDS_DIR = "games/cards/tarot" |
| 0 | 53 |
|
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
54 # Security limit for Libervia (get/set params) |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
55 SECURITY_LIMIT = 0 |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
56 |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
57 class ISATSession(Interface): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
58 profile = Attribute("Sat profile") |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
59 jid = Attribute("JID associated with the profile") |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
60 |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
61 class SATSession(object): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
62 implements(ISATSession) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
63 def __init__(self, session): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
64 self.profile = None |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
65 self.jid = None |
|
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 class LiberviaSession(server.Session): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
68 sessionTimeout = TIMEOUT |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
69 |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
70 def __init__(self, *args, **kwargs): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
71 self.__lock = False |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
72 server.Session.__init__(self, *args, **kwargs) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
73 |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
74 def lock(self): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
75 """Prevent session from expiring""" |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
76 self.__lock = True |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
77 self._expireCall.reset(sys.maxint) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
78 |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
79 def unlock(self): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
80 """Allow session to expire again, and touch it""" |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
81 self.__lock = False |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
82 self.touch() |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
83 |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
84 def touch(self): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
85 if not self.__lock: |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
86 server.Session.touch(self) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
87 |
|
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
|
88 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
|
89 """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
|
90 |
|
d0fa4e96a5e4
server side: 404 error is now sent instead of directory listing when requesting a directory
Goffi <goffi@goffi.org>
parents:
57
diff
changeset
|
91 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
|
92 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
|
93 |
| 46 | 94 class SATActionIDHandler(object): |
|
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
95 """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
|
96 ID_LIFETIME = 30 #after this time (in seconds), action_id will be suppressed and action result will be ignored |
| 46 | 97 |
| 98 def __init__(self): | |
| 99 self.waiting_ids = {} | |
| 100 | |
|
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
101 def waitForId(self, callback, action_id, profile, *args, **kwargs): |
| 46 | 102 """Wait for an action result |
| 103 @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
|
104 @param action_id: action_id to wait for |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
105 @param profile: %(doc_profile)s |
| 46 | 106 @param *args: additional argument to pass to callback |
| 107 @param **kwargs: idem""" | |
|
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
108 action_tuple = (action_id, profile) |
|
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
109 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
|
110 reactor.callLater(self.ID_LIFETIME, self.purgeID, action_tuple) |
| 46 | 111 |
|
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
112 def purgeID(self, action_tuple): |
|
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
113 """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
|
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 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
|
116 del self.waiting_ids[action_tuple] |
| 46 | 117 |
|
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
118 def actionResultCb(self, answer_type, action_id, data, profile): |
| 46 | 119 """Manage the actionResult signal""" |
|
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
120 action_tuple = (action_id, profile) |
|
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
121 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
|
122 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
|
123 del self.waiting_ids[action_tuple] |
|
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
124 callback(answer_type, action_id, data, *args, **kwargs) |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
125 |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
126 class JSONRPCMethodManager(jsonrpc.JSONRPC): |
| 0 | 127 |
| 128 def __init__(self, sat_host): | |
| 129 jsonrpc.JSONRPC.__init__(self) | |
| 130 self.sat_host=sat_host | |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
131 |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
132 def asyncBridgeCall(self, method_name, *args, **kwargs): |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
133 """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
|
134 @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
|
135 @return: a deferred which trigger the result |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
136 |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
137 """ |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
138 d = defer.Deferred() |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
139 |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
140 def _callback(*args): |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
141 if not args: |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
142 d.callback(None) |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
143 else: |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
144 if len(args) != 1: |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
145 Exception("Multiple return arguments not supported") |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
146 d.callback(args[0]) |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
147 |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
148 def _errback(result): |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
149 d.errback(Failure(unicode(result))) |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
150 |
|
277
ea2d4f464b5a
server side: fixed bad async bridge calls management
Goffi <goffi@goffi.org>
parents:
275
diff
changeset
|
151 kwargs["callback"] = _callback |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
152 kwargs["errback"] = _errback |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
153 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
|
154 return d |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
155 |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
156 |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
157 class MethodHandler(JSONRPCMethodManager): |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
158 |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
159 def __init__(self, sat_host): |
|
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
160 JSONRPCMethodManager.__init__(self, sat_host) |
|
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
161 self.authorized_params = None |
| 0 | 162 |
| 163 def render(self, request): | |
| 1 | 164 self.session = request.getSession() |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
165 profile = ISATSession(self.session).profile |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
166 if not profile: |
| 0 | 167 #user is not identified, we return a jsonrpc fault |
| 168 parsed = jsonrpclib.loads(request.content.read()) | |
| 169 fault = jsonrpclib.Fault(0, "Not allowed") #FIXME: define some standard error codes for libervia | |
| 170 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc')) | |
| 171 return jsonrpc.JSONRPC.render(self, request) | |
| 19 | 172 |
| 173 def jsonrpc_getProfileJid(self): | |
| 174 """Return the jid of the profile""" | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
175 sat_session = ISATSession(self.session) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
176 profile = sat_session.profile |
| 61 | 177 sat_session.jid = JID(self.sat_host.bridge.getParamA("JabberID", "Connection", profile_key=profile)) |
| 178 return sat_session.jid.full() | |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
179 |
| 156 | 180 def jsonrpc_disconnect(self): |
| 181 """Disconnect the profile""" | |
| 182 sat_session = ISATSession(self.session) | |
| 183 profile = sat_session.profile | |
| 184 self.sat_host.bridge.disconnect(profile) | |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
185 |
| 0 | 186 def jsonrpc_getContacts(self): |
| 187 """Return all passed args.""" | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
188 profile = ISATSession(self.session).profile |
| 1 | 189 return self.sat_host.bridge.getContacts(profile) |
| 20 | 190 |
|
54
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
191 def jsonrpc_addContact(self, entity, name, groups): |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
192 """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
|
193 profile = ISATSession(self.session).profile |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
194 self.sat_host.bridge.addContact(entity, profile) |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
195 self.sat_host.bridge.updateContact(entity, name, groups, profile) |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
196 |
|
55
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
197 def jsonrpc_delContact(self, entity): |
|
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
198 """Remove contact from contacts list""" |
|
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
199 profile = ISATSession(self.session).profile |
|
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
200 self.sat_host.bridge.delContact(entity, profile) |
|
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
201 |
|
57
e552a67b933d
Contact update + add dedication in About dialog
Goffi <goffi@goffi.org>
parents:
55
diff
changeset
|
202 def jsonrpc_updateContact(self, entity, name, groups): |
|
e552a67b933d
Contact update + add dedication in About dialog
Goffi <goffi@goffi.org>
parents:
55
diff
changeset
|
203 """Update contact's roster item""" |
|
e552a67b933d
Contact update + add dedication in About dialog
Goffi <goffi@goffi.org>
parents:
55
diff
changeset
|
204 profile = ISATSession(self.session).profile |
|
e552a67b933d
Contact update + add dedication in About dialog
Goffi <goffi@goffi.org>
parents:
55
diff
changeset
|
205 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
|
206 |
|
54
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
207 def jsonrpc_subscription(self, sub_type, entity, name, groups): |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
208 """Confirm (or infirm) subscription, |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
209 and setup user roster in case of subscription""" |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
210 profile = ISATSession(self.session).profile |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
211 self.sat_host.bridge.subscription(sub_type, entity, profile) |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
212 if sub_type == 'subscribed': |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
213 self.sat_host.bridge.updateContact(entity, name, groups, profile) |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
214 |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
215 def jsonrpc_getWaitingSub(self): |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
216 """Return list of room already joined by user""" |
|
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
217 profile = ISATSession(self.session).profile |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
218 return self.sat_host.bridge.getWaitingSub(profile) |
|
54
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
219 |
|
279
2d6bd975a72d
browser_side: set your own presence status and display those of others
souliane <souliane@mailoo.org>
parents:
277
diff
changeset
|
220 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
|
221 """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
|
222 @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
|
223 @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
|
224 """ |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
225 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
|
226 self.sat_host.bridge.setPresence('', presence, 0, {'': status}, profile) |
| 20 | 227 |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
228 |
|
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
229 def jsonrpc_sendMessage(self, to_jid, msg, subject, _type, options={}): |
| 19 | 230 """send message""" |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
231 profile = ISATSession(self.session).profile |
|
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
232 return self.sat_host.bridge.sendMessage(to_jid, msg, subject, _type, options, profile) |
| 0 | 233 |
|
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 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
|
235 """ Send microblog message |
|
aa76793da353
server + browser: message warning level/sending refactoring:
Goffi <goffi@goffi.org>
parents:
179
diff
changeset
|
236 @param _type: one of "PUBLIC", "GROUP" |
|
aa76793da353
server + browser: message warning level/sending refactoring:
Goffi <goffi@goffi.org>
parents:
179
diff
changeset
|
237 @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
|
238 @param text: microblog's text |
|
aa76793da353
server + browser: message warning level/sending refactoring:
Goffi <goffi@goffi.org>
parents:
179
diff
changeset
|
239 """ |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
240 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
|
241 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
|
242 |
|
201
aa76793da353
server + browser: message warning level/sending refactoring:
Goffi <goffi@goffi.org>
parents:
179
diff
changeset
|
243 if _type in ("PUBLIC", "GROUP") and text: |
|
aa76793da353
server + browser: message warning level/sending refactoring:
Goffi <goffi@goffi.org>
parents:
179
diff
changeset
|
244 if _type == "PUBLIC": |
|
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
245 #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
|
246 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
|
247 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
|
248 else: |
|
133
4ad621df9e34
browser side: group blog is now used to send all microblogs
Goffi <goffi@goffi.org>
parents:
132
diff
changeset
|
249 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
|
250 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
|
251 else: |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
252 raise Exception("Invalid data") |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
253 |
|
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
|
254 def jsonrpc_sendMblogComment(self, node, text, extra={}): |
|
202
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
255 """ Send microblog message |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
256 @param node: url of the comments node |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
257 @param text: comment |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
258 """ |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
259 profile = ISATSession(self.session).profile |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
260 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
|
261 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
|
262 else: |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
263 raise Exception("Invalid data") |
|
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
264 |
|
132
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
265 def jsonrpc_getLastMblogs(self, publisher_jid, max_item): |
|
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
266 """Get last microblogs posted by a contact |
|
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
267 @param publisher_jid: jid of the publisher |
|
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
268 @param max_item: number of items to ask |
|
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
269 @return list of microblog data (dict)""" |
|
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
270 profile = ISATSession(self.session).profile |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
271 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
|
272 return d |
|
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
273 |
|
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
274 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
|
275 """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
|
276 @param publishers_type: one of "ALL", "GROUP", "JID" |
|
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
277 @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
|
278 @param max_item: number of items to ask |
|
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
279 @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
|
280 profile = ISATSession(self.session).profile |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
281 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
|
282 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
|
283 return d |
|
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
284 |
|
202
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
285 def jsonrpc_getMblogComments(self, service, node): |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
286 """Get all comments of given node |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
287 @param service: jid of the service hosting the node |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
288 @param node: comments node |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
289 """ |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
290 profile = ISATSession(self.session).profile |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
291 d = self.asyncBridgeCall("getGroupBlogComments", service, node, profile) |
|
202
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
292 return d |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
293 |
|
2bc6cf004e61
browser, server: comments handling:
Goffi <goffi@goffi.org>
parents:
201
diff
changeset
|
294 |
| 20 | 295 def jsonrpc_getPresenceStatus(self): |
| 296 """Get Presence information for connected contacts""" | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
297 profile = ISATSession(self.session).profile |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
298 return self.sat_host.bridge.getPresenceStatus(profile) |
| 20 | 299 |
| 123 | 300 def jsonrpc_getHistory(self, from_jid, to_jid, size, between): |
| 19 | 301 """Return history for the from_jid/to_jid couple""" |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
302 sat_session = ISATSession(self.session) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
303 profile = sat_session.profile |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
304 sat_jid = sat_session.jid |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
305 if not sat_jid: |
| 19 | 306 error("No jid saved for this profile") |
| 307 return {} | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
308 if JID(from_jid).userhost() != sat_jid.userhost() and JID(to_jid).userhost() != sat_jid.userhost(): |
| 19 | 309 error("Trying to get history from a different jid, maybe a hack attempt ?") |
| 310 return {} | |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
311 d = self.asyncBridgeCall("getHistory", from_jid, to_jid, size, between, profile) |
| 123 | 312 def show(result_dbus): |
| 313 result = [] | |
| 314 for line in result_dbus: | |
| 315 #XXX: we have to do this stupid thing because Python D-Bus use its own types instead of standard types | |
| 316 # 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
|
317 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
|
318 result.append((float(timestamp), unicode(from_jid), unicode(to_jid), unicode(message), unicode(mess_type), dict(extra))) |
| 123 | 319 return result |
| 320 d.addCallback(show) | |
| 321 return d | |
| 19 | 322 |
| 50 | 323 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
|
324 """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
|
325 @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
|
326 """ |
| 50 | 327 profile = ISATSession(self.session).profile |
| 328 try: | |
|
266
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
329 if room_jid != "": |
|
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
330 room_jid = JID(room_jid).userhost() |
| 50 | 331 except: |
| 332 warning('Invalid room jid') | |
| 333 return | |
|
266
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
334 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
|
335 return d |
|
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
336 |
|
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
337 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
|
338 """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
|
339 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
|
340 try: |
|
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
341 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
|
342 except: |
|
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
343 warning('Invalid room jid') |
|
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
344 return |
|
cc778206b7ae
bridge: added inviteMUC + modify joinMUC to make it accept room_jid = ""
souliane <souliane@mailoo.org>
parents:
261
diff
changeset
|
345 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
|
346 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
|
347 self.sat_host.bridge.inviteMUC(contact_jid, service, room_id, {}, profile) |
| 50 | 348 |
|
179
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
349 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
|
350 """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
|
351 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
|
352 try: |
|
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
353 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
|
354 except: |
|
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
355 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
|
356 return |
|
8475a29d7214
closing a group chat widget now leave the muc room (bug 11)
Goffi <goffi@goffi.org>
parents:
172
diff
changeset
|
357 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
|
358 |
| 121 | 359 def jsonrpc_getRoomsJoined(self): |
|
30
7684e3ceb12d
server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents:
24
diff
changeset
|
360 """Return list of room already joined by user""" |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
361 profile = ISATSession(self.session).profile |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
362 return self.sat_host.bridge.getRoomsJoined(profile) |
|
30
7684e3ceb12d
server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents:
24
diff
changeset
|
363 |
|
268
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
364 def jsonrpc_launchTarotGame(self, other_players, room_jid=""): |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
365 """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
|
366 @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
|
367 """ |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
368 profile = ISATSession(self.session).profile |
|
268
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
369 try: |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
370 if room_jid != "": |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
371 room_jid = JID(room_jid).userhost() |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
372 except: |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
373 warning('Invalid room jid') |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
374 return |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
375 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
|
376 |
| 36 | 377 def jsonrpc_getTarotCardsPaths(self): |
| 378 """Give the path of all the tarot cards""" | |
| 77 | 379 _join = os.path.join |
| 380 _media_dir = _join(self.sat_host.media_dir,'') | |
| 381 return map(lambda x: _join(MEDIA_DIR, x[len(_media_dir):]),glob.glob(_join(_media_dir,CARDS_DIR,'*_*.png'))); | |
| 36 | 382 |
|
37
b306aa090438
Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents:
36
diff
changeset
|
383 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
|
384 """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
|
385 profile = ISATSession(self.session).profile |
|
153
ada146bac8fe
server side: fixed tarotGameReady call
Goffi <goffi@goffi.org>
parents:
151
diff
changeset
|
386 self.sat_host.bridge.tarotGameReady(player, referee, profile) |
| 36 | 387 |
|
37
b306aa090438
Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents:
36
diff
changeset
|
388 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
|
389 """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
|
390 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
|
391 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
|
392 |
|
39
305e81c7a32c
Tarot game: a game can now be finished
Goffi <goffi@goffi.org>
parents:
38
diff
changeset
|
393 def jsonrpc_tarotGamePlayCards(self, player_nick, referee, cards): |
| 128 | 394 """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
|
395 profile = ISATSession(self.session).profile |
|
39
305e81c7a32c
Tarot game: a game can now be finished
Goffi <goffi@goffi.org>
parents:
38
diff
changeset
|
396 self.sat_host.bridge.tarotGamePlayCards(player_nick, referee, cards, profile) |
| 36 | 397 |
|
268
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
398 def jsonrpc_launchRadioCollective(self, invited, room_jid=""): |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
399 """Create a room, invite people, and start a radio collective |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
400 @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
|
401 """ |
|
125
f9d63624699f
radio collective integration, first draft
Goffi <goffi@goffi.org>
parents:
124
diff
changeset
|
402 profile = ISATSession(self.session).profile |
|
268
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
403 try: |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
404 if room_jid != "": |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
405 room_jid = JID(room_jid).userhost() |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
406 except: |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
407 warning('Invalid room jid') |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
408 return |
|
79970bf6af93
browser_side: added class RoomAndContactsChooser:
souliane <souliane@mailoo.org>
parents:
266
diff
changeset
|
409 self.sat_host.bridge.radiocolLaunch(invited, room_jid, profile) |
|
125
f9d63624699f
radio collective integration, first draft
Goffi <goffi@goffi.org>
parents:
124
diff
changeset
|
410 |
| 137 | 411 def jsonrpc_getEntityData(self, jid, keys): |
| 412 """Get cached data for an entit | |
| 413 @param jid: jid of contact from who we want data | |
| 414 @param keys: name of data we want (list) | |
| 415 @return: requested data""" | |
|
124
6d1f4a3da29b
server: fixed buggy vcard cache retrieving, fixes avatar issue
Goffi <goffi@goffi.org>
parents:
123
diff
changeset
|
416 profile = ISATSession(self.session).profile |
| 137 | 417 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
|
418 |
|
204
890776a6fdb7
browser + server: vcard is requested when no avatar data is found in cache
Goffi <goffi@goffi.org>
parents:
202
diff
changeset
|
419 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
|
420 """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
|
421 @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
|
422 @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
|
423 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
|
424 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
|
425 |
|
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
426 def jsonrpc_getParamsUI(self): |
|
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
427 """Return the parameters XML for profile""" |
|
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
428 profile = ISATSession(self.session).profile |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
429 d = self.asyncBridgeCall("getParams", SECURITY_LIMIT, profile) |
|
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
430 |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
431 def setAuthorizedParams(d): |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
432 if self.authorized_params is None: |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
433 self.authorized_params = {} |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
434 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
|
435 params = cat.getElementsByTagName("param") |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
436 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
|
437 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
|
438 if self.authorized_params: |
|
4e6467efd6bf
browser_side: small improvements for parameters panel
souliane <souliane@mailoo.org>
parents:
215
diff
changeset
|
439 return d |
|
4e6467efd6bf
browser_side: small improvements for parameters panel
souliane <souliane@mailoo.org>
parents:
215
diff
changeset
|
440 else: |
|
4e6467efd6bf
browser_side: small improvements for parameters panel
souliane <souliane@mailoo.org>
parents:
215
diff
changeset
|
441 return None |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
442 |
|
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
443 d.addCallback(setAuthorizedParams) |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
444 |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
445 from sat.tools.xml_tools import paramsXml2xmlUI |
|
218
4e6467efd6bf
browser_side: small improvements for parameters panel
souliane <souliane@mailoo.org>
parents:
215
diff
changeset
|
446 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
|
447 |
|
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
448 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
|
449 |
|
229
e632f77c4219
bridge: asyncGetParamA takes a security_limit argument
souliane <souliane@mailoo.org>
parents:
219
diff
changeset
|
450 def jsonrpc_asyncGetParamA(self, param, category, attribute="value"): |
|
e632f77c4219
bridge: asyncGetParamA takes a security_limit argument
souliane <souliane@mailoo.org>
parents:
219
diff
changeset
|
451 """Return the parameter value for profile""" |
|
e632f77c4219
bridge: asyncGetParamA takes a security_limit argument
souliane <souliane@mailoo.org>
parents:
219
diff
changeset
|
452 profile = ISATSession(self.session).profile |
|
e632f77c4219
bridge: asyncGetParamA takes a security_limit argument
souliane <souliane@mailoo.org>
parents:
219
diff
changeset
|
453 d = self.asyncBridgeCall("asyncGetParamA", param, category, attribute, SECURITY_LIMIT, profile_key=profile) |
|
e632f77c4219
bridge: asyncGetParamA takes a security_limit argument
souliane <souliane@mailoo.org>
parents:
219
diff
changeset
|
454 return d |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
455 |
|
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
456 def jsonrpc_setParam(self, name, value, category): |
|
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
457 profile = ISATSession(self.session).profile |
|
215
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
458 if category in self.authorized_params and name in self.authorized_params[category]: |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
459 return self.sat_host.bridge.setParam(name, value, category, SECURITY_LIMIT, profile) |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
460 else: |
|
e830a0c60d32
server side: added the security_limit to setParam
souliane <souliane@mailoo.org>
parents:
214
diff
changeset
|
461 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
|
462 % (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
|
463 |
|
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
|
464 def jsonrpc_launchAction(self, action_type, data): |
|
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
|
465 profile = ISATSession(self.session).profile |
|
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
|
466 return self.sat_host.bridge.launchAction(action_type, data, profile) |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
467 |
|
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
468 def jsonrpc_chatStateComposing(self, to_jid_s): |
|
242
a25aa882e09a
browser_side: add context menu for contact:
souliane <souliane@mailoo.org>
parents:
235
diff
changeset
|
469 """Call the method to process a "composing" state. |
|
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
470 @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
|
471 """ |
|
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
472 profile = ISATSession(self.session).profile |
|
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
473 self.sat_host.bridge.chatStateComposing(to_jid_s, profile) |
|
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
474 |
|
242
a25aa882e09a
browser_side: add context menu for contact:
souliane <souliane@mailoo.org>
parents:
235
diff
changeset
|
475 def jsonrpc_getNewAccountDomain(self): |
|
a25aa882e09a
browser_side: add context menu for contact:
souliane <souliane@mailoo.org>
parents:
235
diff
changeset
|
476 """@return: the domain for new account creation""" |
|
a25aa882e09a
browser_side: add context menu for contact:
souliane <souliane@mailoo.org>
parents:
235
diff
changeset
|
477 d = self.asyncBridgeCall("getNewAccountDomain") |
|
a25aa882e09a
browser_side: add context menu for contact:
souliane <souliane@mailoo.org>
parents:
235
diff
changeset
|
478 return d |
|
214
7b26be266ab1
plugin XEP-0085: Chat State Notifications
souliane <souliane@mailoo.org>
parents:
204
diff
changeset
|
479 |
|
251
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
480 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
|
481 """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
|
482 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
|
483 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
|
484 |
|
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
485 |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
486 class Register(JSONRPCMethodManager): |
| 0 | 487 """This class manage the registration procedure with SàT |
| 488 It provide an api for the browser, check password and setup the web server""" | |
| 489 | |
| 490 def __init__(self, sat_host): | |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
491 JSONRPCMethodManager.__init__(self, sat_host) |
| 0 | 492 self.profiles_waiting={} |
| 493 self.request=None | |
| 494 | |
| 495 def getWaitingRequest(self, profile): | |
| 496 """Tell if a profile is trying to log in""" | |
| 497 if self.profiles_waiting.has_key(profile): | |
| 498 return self.profiles_waiting[profile] | |
| 499 else: | |
| 500 return None | |
| 501 | |
| 502 def render(self, request): | |
| 503 """ | |
| 504 Render method with some hacks: | |
| 505 - if login is requested, try to login with form data | |
| 506 - except login, every method is jsonrpc | |
| 507 - user doesn't need to be authentified for isRegistered, but must be for all other methods | |
| 508 """ | |
| 509 if request.postpath==['login']: | |
| 510 return self.login(request) | |
| 511 _session = request.getSession() | |
| 512 parsed = jsonrpclib.loads(request.content.read()) | |
| 513 if parsed.get("method")!="isRegistered": | |
| 514 #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
|
515 profile = ISATSession(_session).profile |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
516 if not profile: |
| 0 | 517 #user is not identified, we return a jsonrpc fault |
| 518 fault = jsonrpclib.Fault(0, "Not allowed") #FIXME: define some standard error codes for libervia | |
| 519 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc')) | |
| 520 self.request = request | |
| 521 return jsonrpc.JSONRPC.render(self, request) | |
| 522 | |
| 523 def login(self, request): | |
| 524 """ | |
| 525 this method is called with the POST information from the registering form | |
| 526 it test if the password is ok, and log in if it's the case, | |
| 527 else it return an error | |
| 528 @param request: request of the register formulaire, must have "login" and "password" as arguments | |
| 529 @return: A constant indicating the state: | |
| 530 - BAD REQUEST: something is wrong in the request (bad arguments, profile_key for login) | |
| 531 - AUTH ERROR: either the profile or the password is wrong | |
| 532 - ALREADY WAITING: a request has already be made for this profile | |
| 533 - 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
|
534 """ |
|
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
535 |
| 0 | 536 try: |
|
66
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
537 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
|
538 _login = request.args['login'][0] |
|
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
539 if _login.startswith('@'): |
|
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
540 raise Exception('No profile_key allowed') |
|
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
541 _pass = request.args['login_password'][0] |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
542 |
|
66
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
543 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
|
544 return self._registerNewAccount(request) |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
545 |
|
66
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
546 else: |
|
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
547 raise Exception('Unknown submit type') |
| 0 | 548 except KeyError: |
| 549 return "BAD REQUEST" | |
| 550 | |
| 551 _profile_check = self.sat_host.bridge.getProfileName(_login) | |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
552 |
| 121 | 553 def profile_pass_cb(_profile_pass): |
| 554 if not _profile_check or _profile_check != _login or _profile_pass != _pass: | |
| 555 request.write("AUTH ERROR") | |
| 556 request.finish() | |
| 557 return | |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
558 |
| 121 | 559 if self.profiles_waiting.has_key(_login): |
| 560 request.write("ALREADY WAITING") | |
| 561 request.finish() | |
| 562 return | |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
563 |
| 121 | 564 if self.sat_host.bridge.isConnected(_login): |
| 565 request.write(self._logged(_login, request, finish=False)) | |
| 566 request.finish() | |
| 567 return | |
| 568 | |
| 569 self.profiles_waiting[_login] = request | |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
570 d = self.asyncBridgeCall("asyncConnect", _login) |
| 155 | 571 return d |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
572 |
| 121 | 573 def profile_pass_errback(ignore): |
| 574 error("INTERNAL ERROR: can't check profile password") | |
| 575 request.write("AUTH ERROR") | |
| 576 request.finish() | |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
577 |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
578 d = self.asyncBridgeCall("asyncGetParamA", "Password", "Connection", profile_key=_login) |
| 121 | 579 d.addCallbacks(profile_pass_cb, profile_pass_errback) |
| 0 | 580 |
| 581 return server.NOT_DONE_YET | |
| 582 | |
| 46 | 583 def _postAccountCreation(self, answer_type, id, data, profile): |
| 584 """Called when a account has just been created, | |
| 585 setup stuff has microblog access""" | |
| 586 def _connected(ignore): | |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
587 mblog_d = self.asyncBridgeCall("setMicroblogAccess", "open", profile) |
| 46 | 588 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
|
589 |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
590 d = self.asyncBridgeCall("asyncConnect", profile) |
| 46 | 591 d.addCallback(_connected) |
| 592 | |
|
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
|
593 def _registerNewAccount(self, request): |
| 46 | 594 """Create a new account, or return error |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
595 @param request: initial login request |
| 46 | 596 @return: "REGISTRATION" in case of success""" |
|
54
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
597 #TODO: must be moved in SàT core |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
598 |
| 46 | 599 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
|
600 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
|
601 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
|
602 email = request.args['email'][0] |
| 46 | 603 except KeyError: |
| 604 return "BAD REQUEST" | |
| 605 if not re.match(r'^[a-z0-9_-]+$', login, re.IGNORECASE) or \ | |
| 606 not re.match(r'^.+@.+\..+', email, re.IGNORECASE): | |
| 607 return "BAD REQUEST" | |
| 608 | |
|
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
|
609 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
|
610 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
|
611 request.finish() |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
612 |
|
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
|
613 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
|
614 reason = str(failure.value) |
|
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
615 if reason == "CONFLICT": |
|
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
616 request.write('ALREADY EXISTS') |
|
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
617 elif reason == "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
|
618 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
|
619 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
|
620 #import pdb |
|
6f913f5adca8
server side: registration refactoring first draft; main registration code is moved to SàT backend
Goffi <goffi@goffi.org>
parents:
156
diff
changeset
|
621 #pdb.set_trace() |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
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 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
|
624 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
|
625 request.finish() |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
626 |
|
219
36673d19c87e
server side: better async bridge calls handling
Goffi <goffi@goffi.org>
parents:
218
diff
changeset
|
627 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
|
628 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
|
629 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
|
630 return server.NOT_DONE_YET |
| 46 | 631 |
| 0 | 632 def __cleanWaiting(self, login): |
| 633 """Remove login from waiting queue""" | |
| 634 try: | |
| 635 del self.profiles_waiting[login] | |
| 636 except KeyError: | |
| 637 pass | |
| 638 | |
|
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
639 def _logged(self, profile, request, finish=True): |
| 0 | 640 """Set everything when a user just logged |
| 641 and return "LOGGED" to the requester""" | |
| 61 | 642 def result(answer): |
| 643 if finish: | |
| 644 request.write(answer) | |
| 645 request.finish() | |
| 646 else: | |
| 647 return answer | |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
648 |
|
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
649 self.__cleanWaiting(profile) |
| 0 | 650 _session = request.getSession() |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
651 sat_session = ISATSession(_session) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
652 if sat_session.profile: |
| 61 | 653 error (('/!\\ Session has already a profile, this should NEVER happen !')) |
| 654 return result('SESSION_ACTIVE') | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
655 sat_session.profile = profile |
| 24 | 656 self.sat_host.prof_connected.add(profile) |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
657 |
|
45
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
658 def onExpire(): |
| 156 | 659 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
|
660 try: |
|
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
661 #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
|
662 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
|
663 except KeyError: |
|
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
664 pass |
| 130 | 665 #and now we disconnect the profile |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
666 self.sat_host.bridge.disconnect(profile) |
|
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
667 |
|
45
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
668 _session.notifyOnExpire(onExpire) |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
669 |
|
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
670 d = defer.Deferred() |
| 61 | 671 return result('LOGGED') |
| 0 | 672 |
| 673 def _logginError(self, login, request, error_type): | |
| 674 """Something went wrong during loggin, return an error""" | |
| 675 self.__cleanWaiting(login) | |
| 676 return error_type | |
| 677 | |
| 678 def jsonrpc_isConnected(self): | |
| 679 _session = self.request.getSession() | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
680 profile = ISATSession(_session).profile |
| 0 | 681 return self.sat_host.bridge.isConnected(profile) |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
682 |
| 0 | 683 def jsonrpc_connect(self): |
| 684 _session = self.request.getSession() | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
685 profile = ISATSession(_session).profile |
| 0 | 686 if self.profiles_waiting.has_key(profile): |
| 687 raise jsonrpclib.Fault('1','Already waiting') #FIXME: define some standard error codes for libervia | |
| 688 self.profiles_waiting[profile] = self.request | |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
689 self.sat_host.bridge.connect(profile) |
| 0 | 690 return server.NOT_DONE_YET |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
691 |
| 0 | 692 def jsonrpc_isRegistered(self): |
| 693 """Tell if the user is already registered""" | |
| 694 _session = self.request.getSession() | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
695 profile = ISATSession(_session).profile |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
696 return bool(profile) |
|
251
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
697 |
|
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
698 |
| 0 | 699 class SignalHandler(jsonrpc.JSONRPC): |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
700 |
| 0 | 701 def __init__(self, sat_host): |
| 702 Resource.__init__(self) | |
| 703 self.register=None | |
| 704 self.sat_host=sat_host | |
|
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
705 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
|
706 self.queue = {} |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
707 |
| 0 | 708 def plugRegister(self, register): |
| 709 self.register = register | |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
710 |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
711 def jsonrpc_getSignals(self): |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
712 """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
|
713 @return: (signal, *signal_args)""" |
|
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
714 _session = self.request.getSession() |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
715 profile = ISATSession(_session).profile |
| 24 | 716 if profile in self.queue: #if we have signals to send in queue |
| 717 if self.queue[profile]: | |
| 718 return self.queue[profile].pop(0) | |
| 719 else: | |
| 720 #the queue is empty, we delete the profile from queue | |
| 721 del self.queue[profile] | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
722 _session.lock() #we don't want the session to expire as long as this connection is active |
| 156 | 723 def unlock(signal, profile): |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
724 _session.unlock() |
| 156 | 725 try: |
| 726 source_defer = self.signalDeferred[profile] | |
| 727 if source_defer.called and source_defer.result[0] == "disconnected": | |
| 728 info(u"[%s] disconnected" % (profile,)) | |
| 729 _session.expire() | |
| 730 except IndexError: | |
| 731 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
|
732 |
|
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
733 self.signalDeferred[profile] = defer.Deferred() |
| 156 | 734 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
|
735 return self.signalDeferred[profile] |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
736 |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
737 def getGenericCb(self, function_name): |
|
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
738 """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
|
739 function must have profile as last argument""" |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
740 def genericCb(*args): |
|
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
741 profile = args[-1] |
| 24 | 742 if not profile in self.sat_host.prof_connected: |
| 743 return | |
|
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
744 if profile in self.signalDeferred: |
|
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
745 self.signalDeferred[profile].callback((function_name,args[:-1])) |
| 24 | 746 del self.signalDeferred[profile] |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
747 else: |
| 24 | 748 if not self.queue.has_key(profile): |
| 749 self.queue[profile] = [] | |
| 750 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
|
751 return genericCb |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
752 |
| 0 | 753 def connected(self, profile): |
| 754 assert(self.register) #register must be plugged | |
| 755 request = self.register.getWaitingRequest(profile) | |
| 756 if request: | |
| 757 self.register._logged(profile, request) | |
| 758 | |
| 156 | 759 def disconnected(self, profile): |
| 760 if not profile in self.sat_host.prof_connected: | |
| 761 error("'disconnected' signal received for a not connected profile") | |
| 762 return | |
| 763 self.sat_host.prof_connected.remove(profile) | |
| 764 if profile in self.signalDeferred: | |
| 765 self.signalDeferred[profile].callback(("disconnected",)) | |
| 766 del self.signalDeferred[profile] | |
| 767 else: | |
| 768 if not self.queue.has_key(profile): | |
| 769 self.queue[profile] = [] | |
| 770 self.queue[profile].append(("disconnected",)) | |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
771 |
| 156 | 772 |
| 0 | 773 def connectionError(self, error_type, profile): |
| 774 assert(self.register) #register must be plugged | |
| 775 request = self.register.getWaitingRequest(profile) | |
| 776 if request: #The user is trying to log in | |
| 777 if error_type == "AUTH_ERROR": | |
| 778 _error_t = "AUTH ERROR" | |
| 779 else: | |
| 780 _error_t = "UNKNOWN" | |
| 781 self.register._logginError(profile, request, _error_t) | |
| 782 | |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
783 def render(self, request): |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
784 """ |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
785 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
|
786 """ |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
787 _session = request.getSession() |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
788 parsed = jsonrpclib.loads(request.content.read()) |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
789 profile = ISATSession(_session).profile |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
790 if not profile: |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
791 #user is not identified, we return a jsonrpc fault |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
792 fault = jsonrpclib.Fault(0, "Not allowed") #FIXME: define some standard error codes for libervia |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
793 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
|
794 self.request = request |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
795 return jsonrpc.JSONRPC.render(self, request) |
| 0 | 796 |
| 127 | 797 class UploadManager(Resource): |
| 798 """This class manage the upload of a file | |
| 799 It redirect the stream to SàT core backend""" | |
| 800 isLeaf = True | |
|
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
801 NAME = 'path' #name use by the FileUpload |
| 127 | 802 |
| 803 def __init__(self, sat_host): | |
| 804 self.sat_host=sat_host | |
| 805 self.upload_dir = tempfile.mkdtemp() | |
| 806 self.sat_host.addCleanup(shutil.rmtree, self.upload_dir) | |
| 807 | |
| 128 | 808 def getTmpDir(self): |
| 809 return self.upload_dir | |
| 810 | |
|
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
811 def _getFileName(self, request): |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
812 """Generate unique filename for a file""" |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
813 raise NotImplementedError |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
814 |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
815 def _fileWritten(self, request, filepath): |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
816 """Called once the file is actually written on disk""" |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
817 raise NotImplementedError |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
818 |
| 127 | 819 def render(self, request): |
| 820 """ | |
| 821 Render method with some hacks: | |
| 822 - if login is requested, try to login with form data | |
| 823 - except login, every method is jsonrpc | |
| 824 - user doesn't need to be authentified for isRegistered, but must be for all other methods | |
| 825 """ | |
|
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
826 #start = time.time() |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
827 filename = self._getFileName(request) |
| 128 | 828 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
|
829 #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
|
830 # (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
|
831 # 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
|
832 # (see http://twistedmatrix.com/trac/ticket/288) |
|
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
833 |
| 128 | 834 with open(filepath,'w') as f: |
|
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
835 f.write(request.args[self.NAME][0]) |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
836 self._fileWritten(request, filepath) |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
837 #end = time.time() |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
838 #print "time spent in render: %fs" % (end - start) |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
839 return "OK" |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
840 |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
841 class UploadManagerRadioCol(UploadManager): |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
842 NAME = 'song' |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
843 |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
844 def _getFileName(self, request): |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
845 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
|
846 |
|
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
847 def _fileWritten(self, request, filepath): |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
848 """Called once the file is actually written on disk""" |
| 128 | 849 profile = ISATSession(request.getSession()).profile |
| 850 self.sat_host.bridge.radiocolSongAdded(request.args['referee'][0], filepath, profile) | |
|
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
851 |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
852 class UploadManagerAvatar(UploadManager): |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
853 NAME = 'avatar_path' |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
854 |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
855 def _getFileName(self, request): |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
856 return str(uuid.uuid4()) |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
857 |
|
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
858 def _fileWritten(self, request, filepath): |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
859 """Called once the file is actually written on disk""" |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
860 profile = ISATSession(request.getSession()).profile |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
861 print u"fichier écrit:", filepath |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
862 self.sat_host.bridge.setAvatar(filepath, profile) |
| 10 | 863 |
| 0 | 864 class Libervia(service.Service): |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
865 |
| 0 | 866 def __init__(self): |
| 127 | 867 self._cleanup = [] |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
868 root = ProtectedFile(LIBERVIA_DIR) |
| 0 | 869 self.signal_handler = SignalHandler(self) |
| 870 _register = Register(self) | |
|
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
871 _upload_radiocol = UploadManagerRadioCol(self) |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
872 _upload_avatar = UploadManagerAvatar(self) |
| 0 | 873 self.signal_handler.plugRegister(_register) |
| 874 self.sessions = {} #key = session value = user | |
| 24 | 875 self.prof_connected = set() #Profiles connected |
| 46 | 876 self.action_handler = SATActionIDHandler() |
| 0 | 877 ## bridge ## |
| 878 try: | |
| 879 self.bridge=DBusBridgeFrontend() | |
| 880 except BridgeExceptionNoService: | |
| 881 print(u"Can't connect to SàT backend, are you sure it's launched ?") | |
| 882 sys.exit(1) | |
| 883 self.bridge.register("connected", self.signal_handler.connected) | |
| 156 | 884 self.bridge.register("disconnected", self.signal_handler.disconnected) |
| 0 | 885 self.bridge.register("connectionError", self.signal_handler.connectionError) |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
886 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
|
887 #core |
|
251
24335e82fef0
plugin XEP-249: added parameter Misc / Auto-join MUC on invitation:
souliane <souliane@mailoo.org>
parents:
242
diff
changeset
|
888 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
|
889 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
|
890 #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
|
891 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
|
892 '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
|
893 '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
|
894 '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
|
895 self.bridge.register(signal_name, self.signal_handler.getGenericCb(signal_name), "plugin") |
| 77 | 896 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
|
897 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
|
898 root.putChild('', Redirect('libervia.html')) |
| 10 | 899 root.putChild('json_signal_api', self.signal_handler) |
| 900 root.putChild('json_api', MethodHandler(self)) | |
| 901 root.putChild('register_api', _register) | |
|
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
902 root.putChild('upload_radiocol', _upload_radiocol) |
|
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
903 root.putChild('upload_avatar', _upload_avatar) |
| 10 | 904 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
|
905 root.putChild('css', ProtectedFile("server_css/")) |
| 77 | 906 root.putChild(os.path.dirname(MEDIA_DIR), ProtectedFile(self.media_dir)) |
|
110
dfc02690deb4
browser side: CSS: header, unibox, tabs + drag'n' drop reworked
Adrien Vigneron <adrienvigneron@mailoo.org>
parents:
107
diff
changeset
|
907 root.putChild(os.path.dirname(AVATARS_DIR), ProtectedFile(os.path.join(self.local_dir, AVATARS_DIR))) |
|
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
908 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 | 909 self.site = server.Site(root) |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
910 self.site.sessionFactory = LiberviaSession |
| 0 | 911 |
| 127 | 912 def addCleanup(self, callback, *args, **kwargs): |
| 913 """Add cleaning method to call when service is stopped | |
| 914 cleaning method will be called in reverse order of they insertion | |
| 915 @param callback: callable to call on service stop | |
| 916 @param *args: list of arguments of the callback | |
| 917 @param **kwargs: list of keyword arguments of the callback""" | |
| 918 self._cleanup.insert(0, (callback, args, kwargs)) | |
| 919 | |
| 0 | 920 def startService(self): |
| 921 reactor.listenTCP(8080, self.site) | |
| 127 | 922 |
| 923 def stopService(self): | |
| 924 print "launching cleaning methods" | |
| 925 for callback, args, kwargs in self._cleanup: | |
| 926 callback(*args, **kwargs) | |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
927 |
| 0 | 928 def run(self): |
| 929 reactor.run() | |
|
258
53c7f0237f1e
removed trailing spaces in libervia.tac
Goffi <goffi@goffi.org>
parents:
251
diff
changeset
|
930 |
| 0 | 931 def stop(self): |
| 932 reactor.stop() | |
| 933 | |
| 934 | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
935 registerAdapter(SATSession, server.Session, ISATSession) |
| 0 | 936 application = service.Application('Libervia') |
| 937 service = Libervia() | |
| 938 service.setServiceParent(application) |