Mercurial > libervia-web
annotate libervia.tac @ 151:a159cc29b556
server side: file upload is now more generic:
- RadioCol upload is managed by a specialized class
- A new Avatar upload specialized class is used to set avatar
browser side: radiocol.py has been updated to follow upload change
author | Goffi <goffi@goffi.org> |
---|---|
date | Fri, 28 Dec 2012 01:05:22 +0100 |
parents | 8635bc9db9bf |
children | ada146bac8fe |
rev | line source |
---|---|
0 | 1 #!/usr/bin/python |
2 # -*- coding: utf-8 -*- | |
3 | |
4 """ | |
5 Libervia: a Salut à Toi frontend | |
131 | 6 Copyright (C) 2011, 2012 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 | |
46 | 22 #You need do adapt the following consts to your server |
23 _REG_EMAIL_FROM = "NOREPLY@libervia.org" | |
24 _REG_EMAIL_SERVER = "localhost" | |
25 _REG_ADMIN_EMAIL = "goffi@goffi.org" | |
26 _NEW_ACCOUNT_SERVER = "localhost" | |
27 _NEW_ACCOUNT_DOMAIN = "tazar.int" | |
28 _NEW_ACCOUNT_RESOURCE = "libervia" | |
29 | |
0 | 30 from twisted.application import internet, service |
31 from twisted.internet import glib2reactor | |
32 glib2reactor.install() | |
33 from twisted.internet import reactor, defer | |
46 | 34 from twisted.mail.smtp import sendmail |
0 | 35 from twisted.web import server |
36 from twisted.web import error as weberror | |
37 from twisted.web.static import File | |
61 | 38 from twisted.web.resource import Resource, NoResource |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
39 from twisted.python.components import registerAdapter |
10 | 40 from twisted.words.protocols.jabber.jid import JID |
0 | 41 from txjsonrpc.web import jsonrpc |
42 from txjsonrpc import jsonrpclib | |
43 from sat_frontends.bridge.DBus import DBusBridgeFrontend,BridgeExceptionNoService | |
46 | 44 from email.mime.text import MIMEText |
45 from logging import debug, info, warning, error | |
127 | 46 import re, glob |
47 import os.path, sys | |
48 import tempfile, shutil, uuid | |
10 | 49 from server_side.blog import MicroBlog |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
50 from zope.interface import Interface, Attribute, implements |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
51 #import time |
10 | 52 |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
53 TIMEOUT = 600 #Session's time out, after that the user will be disconnected |
36 | 54 LIBERVIA_DIR = "output/" |
77 | 55 MEDIA_DIR = "media/" |
110
dfc02690deb4
browser side: CSS: header, unibox, tabs + drag'n' drop reworked
Adrien Vigneron <adrienvigneron@mailoo.org>
parents:
107
diff
changeset
|
56 AVATARS_DIR = "avatars/" |
77 | 57 CARDS_DIR = "games/cards/tarot" |
0 | 58 |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
59 class ISATSession(Interface): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
60 profile = Attribute("Sat profile") |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
61 jid = Attribute("JID associated with the profile") |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
62 |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
63 class SATSession(object): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
64 implements(ISATSession) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
65 def __init__(self, session): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
66 self.profile = None |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
67 self.jid = None |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
68 |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
69 class LiberviaSession(server.Session): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
70 sessionTimeout = TIMEOUT |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
71 |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
72 def __init__(self, *args, **kwargs): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
73 self.__lock = False |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
74 server.Session.__init__(self, *args, **kwargs) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
75 |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
76 def lock(self): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
77 """Prevent session from expiring""" |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
78 self.__lock = True |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
79 self._expireCall.reset(sys.maxint) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
80 |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
81 def unlock(self): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
82 """Allow session to expire again, and touch it""" |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
83 self.__lock = False |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
84 self.touch() |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
85 |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
86 def touch(self): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
87 if not self.__lock: |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
88 server.Session.touch(self) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
89 |
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
|
90 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
|
91 """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
|
92 |
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 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
|
94 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
|
95 |
46 | 96 class SATActionIDHandler(object): |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
97 """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
|
98 ID_LIFETIME = 30 #after this time (in seconds), action_id will be suppressed and action result will be ignored |
46 | 99 |
100 def __init__(self): | |
101 self.waiting_ids = {} | |
102 | |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
103 def waitForId(self, callback, action_id, profile, *args, **kwargs): |
46 | 104 """Wait for an action result |
105 @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
|
106 @param action_id: action_id to wait for |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
107 @param profile: %(doc_profile)s |
46 | 108 @param *args: additional argument to pass to callback |
109 @param **kwargs: idem""" | |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
110 action_tuple = (action_id, profile) |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
111 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
|
112 reactor.callLater(self.ID_LIFETIME, self.purgeID, action_tuple) |
46 | 113 |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
114 def purgeID(self, action_tuple): |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
115 """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
|
116 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
|
117 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
|
118 del self.waiting_ids[action_tuple] |
46 | 119 |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
120 def actionResultCb(self, answer_type, action_id, data, profile): |
46 | 121 """Manage the actionResult signal""" |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
122 action_tuple = (action_id, profile) |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
123 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
|
124 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
|
125 del self.waiting_ids[action_tuple] |
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
126 callback(answer_type, action_id, data, *args, **kwargs) |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
127 |
0 | 128 class MethodHandler(jsonrpc.JSONRPC): |
129 | |
130 def __init__(self, sat_host): | |
131 jsonrpc.JSONRPC.__init__(self) | |
132 self.sat_host=sat_host | |
133 | |
134 def render(self, request): | |
1 | 135 self.session = request.getSession() |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
136 profile = ISATSession(self.session).profile |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
137 if not profile: |
0 | 138 #user is not identified, we return a jsonrpc fault |
139 parsed = jsonrpclib.loads(request.content.read()) | |
140 fault = jsonrpclib.Fault(0, "Not allowed") #FIXME: define some standard error codes for libervia | |
141 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc')) | |
142 return jsonrpc.JSONRPC.render(self, request) | |
19 | 143 |
144 def jsonrpc_getProfileJid(self): | |
145 """Return the jid of the profile""" | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
146 sat_session = ISATSession(self.session) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
147 profile = sat_session.profile |
61 | 148 sat_session.jid = JID(self.sat_host.bridge.getParamA("JabberID", "Connection", profile_key=profile)) |
149 return sat_session.jid.full() | |
0 | 150 |
151 def jsonrpc_getContacts(self): | |
152 """Return all passed args.""" | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
153 profile = ISATSession(self.session).profile |
1 | 154 return self.sat_host.bridge.getContacts(profile) |
20 | 155 |
54
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
156 def jsonrpc_addContact(self, entity, name, groups): |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
157 """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
|
158 profile = ISATSession(self.session).profile |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
159 self.sat_host.bridge.addContact(entity, profile) |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
160 self.sat_host.bridge.updateContact(entity, name, groups, profile) |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
161 |
55
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
162 def jsonrpc_delContact(self, entity): |
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
163 """Remove contact from contacts list""" |
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
164 profile = ISATSession(self.session).profile |
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
165 self.sat_host.bridge.delContact(entity, profile) |
d5266c41ca24
Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents:
54
diff
changeset
|
166 |
57
e552a67b933d
Contact update + add dedication in About dialog
Goffi <goffi@goffi.org>
parents:
55
diff
changeset
|
167 def jsonrpc_updateContact(self, entity, name, groups): |
e552a67b933d
Contact update + add dedication in About dialog
Goffi <goffi@goffi.org>
parents:
55
diff
changeset
|
168 """Update contact's roster item""" |
e552a67b933d
Contact update + add dedication in About dialog
Goffi <goffi@goffi.org>
parents:
55
diff
changeset
|
169 profile = ISATSession(self.session).profile |
e552a67b933d
Contact update + add dedication in About dialog
Goffi <goffi@goffi.org>
parents:
55
diff
changeset
|
170 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
|
171 |
54
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
172 def jsonrpc_subscription(self, sub_type, entity, name, groups): |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
173 """Confirm (or infirm) subscription, |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
174 and setup user roster in case of subscription""" |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
175 profile = ISATSession(self.session).profile |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
176 self.sat_host.bridge.subscription(sub_type, entity, profile) |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
177 if sub_type == 'subscribed': |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
178 self.sat_host.bridge.updateContact(entity, name, groups, profile) |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
179 |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
180 def jsonrpc_getWaitingSub(self): |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
181 """Return list of room already joined by user""" |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
182 profile = ISATSession(self.session).profile |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
183 return self.sat_host.bridge.getWaitingSub(profile) |
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
184 |
20 | 185 def jsonrpc_setStatus(self, status): |
186 """Change the status""" | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
187 profile = ISATSession(self.session).profile |
20 | 188 self.sat_host.bridge.setPresence('', '', 0, {'':status}, profile) |
189 | |
19 | 190 |
191 def jsonrpc_sendMessage(self, to_jid, msg, subject, type): | |
192 """send message""" | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
193 profile = ISATSession(self.session).profile |
19 | 194 return self.sat_host.bridge.sendMessage(to_jid, msg, subject, type, profile) |
0 | 195 |
11
331c093e4eb3
magicBox is now able to send global microblog
Goffi <goffi@goffi.org>
parents:
10
diff
changeset
|
196 def jsonrpc_sendMblog(self, raw_text): |
331c093e4eb3
magicBox is now able to send global microblog
Goffi <goffi@goffi.org>
parents:
10
diff
changeset
|
197 """Parse raw_text of the microblog box, and send message consequently""" |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
198 profile = ISATSession(self.session).profile |
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
199 match = re.match(r'@(.+?): *(.*$)', raw_text) |
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
200 if match: |
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
201 recip = match.group(1) |
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
202 text = match.group(2) |
133
4ad621df9e34
browser side: group blog is now used to send all microblogs
Goffi <goffi@goffi.org>
parents:
132
diff
changeset
|
203 #if recip == '@' and text: |
4ad621df9e34
browser side: group blog is now used to send all microblogs
Goffi <goffi@goffi.org>
parents:
132
diff
changeset
|
204 # #This text if for the public microblog |
4ad621df9e34
browser side: group blog is now used to send all microblogs
Goffi <goffi@goffi.org>
parents:
132
diff
changeset
|
205 # return self.sat_host.bridge.sendPersonalEvent("MICROBLOG", {'content':text}, profile) |
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
206 if recip == '@' and text: |
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
207 #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
|
208 print "sending public blog" |
4ad621df9e34
browser side: group blog is now used to send all microblogs
Goffi <goffi@goffi.org>
parents:
132
diff
changeset
|
209 return self.sat_host.bridge.sendGroupBlog("PUBLIC", [], text, profile) |
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
210 else: |
133
4ad621df9e34
browser side: group blog is now used to send all microblogs
Goffi <goffi@goffi.org>
parents:
132
diff
changeset
|
211 print "sending group blog" |
4ad621df9e34
browser side: group blog is now used to send all microblogs
Goffi <goffi@goffi.org>
parents:
132
diff
changeset
|
212 return self.sat_host.bridge.sendGroupBlog("GROUP", [recip], text, profile) |
132
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
213 |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
214 def jsonrpc_getLastMblogs(self, publisher_jid, max_item): |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
215 """Get last microblogs posted by a contact |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
216 @param publisher_jid: jid of the publisher |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
217 @param max_item: number of items to ask |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
218 @return list of microblog data (dict)""" |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
219 profile = ISATSession(self.session).profile |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
220 d = defer.Deferred() |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
221 self.sat_host.bridge.getLastGroupBlogs(publisher_jid, max_item, profile, callback=d.callback, errback=d.errback) |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
222 return d |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
223 |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
224 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
|
225 """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
|
226 @param publishers_type: one of "ALL", "GROUP", "JID" |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
227 @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
|
228 @param max_item: number of items to ask |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
229 @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
|
230 profile = ISATSession(self.session).profile |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
231 d = defer.Deferred() |
30d8e328559b
server & browser side: microblogging refactoring first draft
Goffi <goffi@goffi.org>
parents:
131
diff
changeset
|
232 self.sat_host.bridge.getMassiveLastGroupBlogs(publishers_type, publishers_list, max_item, profile, callback=d.callback, errback=d.errback) |
135
ceef355156de
server + browser side: groupblog subscription + fixed blog insertion order
Goffi <goffi@goffi.org>
parents:
133
diff
changeset
|
233 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
|
234 return d |
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
235 |
20 | 236 def jsonrpc_getPresenceStatus(self): |
237 """Get Presence information for connected contacts""" | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
238 profile = ISATSession(self.session).profile |
20 | 239 return self.sat_host.bridge.getPresenceStatus(profile) |
240 | |
123 | 241 def jsonrpc_getHistory(self, from_jid, to_jid, size, between): |
19 | 242 """Return history for the from_jid/to_jid couple""" |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
243 sat_session = ISATSession(self.session) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
244 profile = sat_session.profile |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
245 sat_jid = sat_session.jid |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
246 if not sat_jid: |
19 | 247 error("No jid saved for this profile") |
248 return {} | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
249 if JID(from_jid).userhost() != sat_jid.userhost() and JID(to_jid).userhost() != sat_jid.userhost(): |
19 | 250 error("Trying to get history from a different jid, maybe a hack attempt ?") |
251 return {} | |
123 | 252 d = defer.Deferred() |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
253 self.sat_host.bridge.getHistory(from_jid, to_jid, size, between, profile, callback=d.callback, errback=d.errback) |
123 | 254 def show(result_dbus): |
255 result = [] | |
256 for line in result_dbus: | |
257 #XXX: we have to do this stupid thing because Python D-Bus use its own types instead of standard types | |
258 # and txJsonRPC doesn't accept D-Bus types, resulting in a empty query | |
137 | 259 timestamp, from_jid, to_jid, message, mess_type = line |
260 result.append((float(timestamp), unicode(from_jid), unicode(to_jid), unicode(message), unicode(mess_type))) | |
123 | 261 return result |
262 d.addCallback(show) | |
263 return d | |
19 | 264 |
50 | 265 def jsonrpc_joinMUC(self, room_jid, nick): |
266 """Join a Multi-User Chat room""" | |
267 profile = ISATSession(self.session).profile | |
268 try: | |
269 room_jid = JID(room_jid) | |
270 except: | |
271 warning('Invalid room jid') | |
272 return | |
125
f9d63624699f
radio collective integration, first draft
Goffi <goffi@goffi.org>
parents:
124
diff
changeset
|
273 self.sat_host.bridge.joinMUC(room_jid.userhost(), nick, {}, profile) |
50 | 274 |
121 | 275 def jsonrpc_getRoomsJoined(self): |
30
7684e3ceb12d
server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents:
24
diff
changeset
|
276 """Return list of room already joined by user""" |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
277 profile = ISATSession(self.session).profile |
121 | 278 return self.sat_host.bridge.getRoomsJoined(profile) |
30
7684e3ceb12d
server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents:
24
diff
changeset
|
279 |
24 | 280 def jsonrpc_launchTarotGame(self, other_players): |
281 """Create a room, invite the other players and start a Tarot game""" | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
282 profile = ISATSession(self.session).profile |
24 | 283 self.sat_host.bridge.tarotGameLaunch(other_players, profile) |
11
331c093e4eb3
magicBox is now able to send global microblog
Goffi <goffi@goffi.org>
parents:
10
diff
changeset
|
284 |
36 | 285 def jsonrpc_getTarotCardsPaths(self): |
286 """Give the path of all the tarot cards""" | |
77 | 287 _join = os.path.join |
288 _media_dir = _join(self.sat_host.media_dir,'') | |
289 return map(lambda x: _join(MEDIA_DIR, x[len(_media_dir):]),glob.glob(_join(_media_dir,CARDS_DIR,'*_*.png'))); | |
36 | 290 |
37
b306aa090438
Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents:
36
diff
changeset
|
291 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
|
292 """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
|
293 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
|
294 self.sat_host.bridge.tarotGameReady(player, referee) |
36 | 295 |
37
b306aa090438
Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents:
36
diff
changeset
|
296 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
|
297 """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
|
298 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
|
299 self.sat_host.bridge.tarotGameContratChoosed(player_nick, referee, contrat, profile) |
39
305e81c7a32c
Tarot game: a game can now be finished
Goffi <goffi@goffi.org>
parents:
38
diff
changeset
|
300 |
305e81c7a32c
Tarot game: a game can now be finished
Goffi <goffi@goffi.org>
parents:
38
diff
changeset
|
301 def jsonrpc_tarotGamePlayCards(self, player_nick, referee, cards): |
128 | 302 """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
|
303 profile = ISATSession(self.session).profile |
39
305e81c7a32c
Tarot game: a game can now be finished
Goffi <goffi@goffi.org>
parents:
38
diff
changeset
|
304 self.sat_host.bridge.tarotGamePlayCards(player_nick, referee, cards, profile) |
36 | 305 |
125
f9d63624699f
radio collective integration, first draft
Goffi <goffi@goffi.org>
parents:
124
diff
changeset
|
306 def jsonrpc_launchRadioCollective(self, invited): |
f9d63624699f
radio collective integration, first draft
Goffi <goffi@goffi.org>
parents:
124
diff
changeset
|
307 """Create a room, invite people, and start a radio collective""" |
f9d63624699f
radio collective integration, first draft
Goffi <goffi@goffi.org>
parents:
124
diff
changeset
|
308 profile = ISATSession(self.session).profile |
f9d63624699f
radio collective integration, first draft
Goffi <goffi@goffi.org>
parents:
124
diff
changeset
|
309 self.sat_host.bridge.radiocolLaunch(invited, profile) |
f9d63624699f
radio collective integration, first draft
Goffi <goffi@goffi.org>
parents:
124
diff
changeset
|
310 |
137 | 311 def jsonrpc_getEntityData(self, jid, keys): |
312 """Get cached data for an entit | |
313 @param jid: jid of contact from who we want data | |
314 @param keys: name of data we want (list) | |
315 @return: requested data""" | |
124
6d1f4a3da29b
server: fixed buggy vcard cache retrieving, fixes avatar issue
Goffi <goffi@goffi.org>
parents:
123
diff
changeset
|
316 profile = ISATSession(self.session).profile |
137 | 317 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
|
318 |
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
|
319 #def jsonrpc_getParamsUI(self): |
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
|
320 # """Return the parameters XMLUI for 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
|
321 # 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
|
322 # d = defer.Deferred() |
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
|
323 # self.sat_host.bridge.getParamsUI(profile, callback=d.callback, errback=d.errback) |
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
|
324 # #d.addCallback(lambda result: unicode(result)) |
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
|
325 # return d |
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
|
326 |
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
|
327 #def jsonrpc_setParam(self, name, value, category): |
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
|
328 # 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
|
329 # return self.sat_host.bridge.setParam(name, value, category, 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
|
330 |
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
|
331 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
|
332 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
|
333 return self.sat_host.bridge.launchAction(action_type, data, 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
|
334 |
0 | 335 class Register(jsonrpc.JSONRPC): |
336 """This class manage the registration procedure with SàT | |
337 It provide an api for the browser, check password and setup the web server""" | |
338 | |
339 def __init__(self, sat_host): | |
340 jsonrpc.JSONRPC.__init__(self) | |
341 self.sat_host=sat_host | |
342 self.profiles_waiting={} | |
343 self.request=None | |
344 | |
345 def getWaitingRequest(self, profile): | |
346 """Tell if a profile is trying to log in""" | |
347 if self.profiles_waiting.has_key(profile): | |
348 return self.profiles_waiting[profile] | |
349 else: | |
350 return None | |
351 | |
352 def render(self, request): | |
353 """ | |
354 Render method with some hacks: | |
355 - if login is requested, try to login with form data | |
356 - except login, every method is jsonrpc | |
357 - user doesn't need to be authentified for isRegistered, but must be for all other methods | |
358 """ | |
359 if request.postpath==['login']: | |
360 return self.login(request) | |
361 _session = request.getSession() | |
362 parsed = jsonrpclib.loads(request.content.read()) | |
363 if parsed.get("method")!="isRegistered": | |
364 #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
|
365 profile = ISATSession(_session).profile |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
366 if not profile: |
0 | 367 #user is not identified, we return a jsonrpc fault |
368 fault = jsonrpclib.Fault(0, "Not allowed") #FIXME: define some standard error codes for libervia | |
369 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc')) | |
370 self.request = request | |
371 return jsonrpc.JSONRPC.render(self, request) | |
372 | |
373 def login(self, request): | |
374 """ | |
375 this method is called with the POST information from the registering form | |
376 it test if the password is ok, and log in if it's the case, | |
377 else it return an error | |
378 @param request: request of the register formulaire, must have "login" and "password" as arguments | |
379 @return: A constant indicating the state: | |
380 - BAD REQUEST: something is wrong in the request (bad arguments, profile_key for login) | |
381 - AUTH ERROR: either the profile or the password is wrong | |
382 - ALREADY WAITING: a request has already be made for this profile | |
383 - server.NOT_DONE_YET: the profile is being processed, the return value will be given by self._logged or self._logginError | |
384 """ | |
385 try: | |
66
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
386 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
|
387 _login = request.args['login'][0] |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
388 if _login.startswith('@'): |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
389 raise Exception('No profile_key allowed') |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
390 _pass = request.args['login_password'][0] |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
391 |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
392 elif request.args['submit_type'][0] == 'register': |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
393 return self._registerNewAccount(request.args) |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
394 |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
395 else: |
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
396 raise Exception('Unknown submit type') |
0 | 397 except KeyError: |
398 return "BAD REQUEST" | |
399 | |
400 _profile_check = self.sat_host.bridge.getProfileName(_login) | |
401 | |
121 | 402 def profile_pass_cb(_profile_pass): |
403 if not _profile_check or _profile_check != _login or _profile_pass != _pass: | |
404 request.write("AUTH ERROR") | |
405 request.finish() | |
406 return | |
407 | |
408 if self.profiles_waiting.has_key(_login): | |
409 request.write("ALREADY WAITING") | |
410 request.finish() | |
411 return | |
412 | |
413 if self.sat_host.bridge.isConnected(_login): | |
414 request.write(self._logged(_login, request, finish=False)) | |
415 request.finish() | |
416 return | |
417 | |
418 self.profiles_waiting[_login] = request | |
419 self.sat_host.bridge.connect(_login) | |
0 | 420 |
121 | 421 def profile_pass_errback(ignore): |
422 error("INTERNAL ERROR: can't check profile password") | |
423 request.write("AUTH ERROR") | |
424 request.finish() | |
425 | |
426 d = defer.Deferred() | |
427 self.sat_host.bridge.asyncGetParamA("Password", "Connection", profile_key=_login, callback=d.callback, errback=d.errback) | |
428 d.addCallbacks(profile_pass_cb, profile_pass_errback) | |
0 | 429 |
430 return server.NOT_DONE_YET | |
431 | |
46 | 432 def _postAccountCreation(self, answer_type, id, data, profile): |
433 """Called when a account has just been created, | |
434 setup stuff has microblog access""" | |
435 def _connected(ignore): | |
436 mblog_d = defer.Deferred() | |
437 self.sat_host.bridge.setMicroblogAccess("open", profile, lambda: mblog_d.callback(None), mblog_d.errback) | |
438 mblog_d.addBoth(lambda ignore: self.sat_host.bridge.disconnect(profile)) | |
439 | |
440 d = defer.Deferred() | |
441 self.sat_host.bridge.asyncConnect(profile, lambda: d.callback(None), d.errback) | |
442 d.addCallback(_connected) | |
443 | |
444 def _registerNewAccount(self, args): | |
445 """Create a new account, or return error | |
446 @param args: dict of args as given by the form | |
447 @return: "REGISTRATION" in case of success""" | |
54
f25c4077f6b9
addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents:
50
diff
changeset
|
448 #TODO: must be moved in SàT core |
46 | 449 try: |
66
9d8e79ac4c9c
Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents:
61
diff
changeset
|
450 profile = login = args['register_login'][0] |
67 | 451 password = args['register_password'][0] #FIXME: password is ignored so far |
46 | 452 email = args['email'][0] |
453 except KeyError: | |
454 return "BAD REQUEST" | |
455 if not re.match(r'^[a-z0-9_-]+$', login, re.IGNORECASE) or \ | |
456 not re.match(r'^.+@.+\..+', email, re.IGNORECASE): | |
457 return "BAD REQUEST" | |
458 #_charset = [chr(i) for i in range(0x21,0x7F)] #XXX: this charset seems to have some issues with openfire | |
459 _charset = [chr(i) for i in range(0x30,0x3A) + range(0x41,0x5B) + range (0x61,0x7B)] | |
460 import random | |
461 random.seed() | |
462 password = ''.join([random.choice(_charset) for i in range(15)]) | |
463 | |
464 if login in self.sat_host.bridge.getProfilesList(): #FIXME: must use a deferred + create a new profile check method | |
465 return "ALREADY EXISTS" | |
466 | |
467 #we now create the profile | |
468 self.sat_host.bridge.createProfile(login) | |
469 #FIXME: values must be in a config file instead of hardcoded | |
470 self.sat_host.bridge.setParam("JabberID", "%s@%s/%s" % (login, _NEW_ACCOUNT_DOMAIN, _NEW_ACCOUNT_RESOURCE), "Connection", profile) | |
471 self.sat_host.bridge.setParam("Server", _NEW_ACCOUNT_SERVER, "Connection", profile) | |
472 self.sat_host.bridge.setParam("Password", password, "Connection", profile) | |
473 #and the account | |
61 | 474 action_id = self.sat_host.bridge.registerNewAccount(login, password, email, _NEW_ACCOUNT_DOMAIN, 5222) |
140
09a512d9a0c0
server side: fixed getHistory call and action result management
Goffi <goffi@goffi.org>
parents:
137
diff
changeset
|
475 self.sat_host.action_handler.waitForId(self._postAccountCreation, action_id, profile) |
46 | 476 |
477 #time to send the email | |
478 | |
479 _email_host = _REG_EMAIL_SERVER | |
480 _email_from = _REG_EMAIL_FROM | |
481 | |
482 def email_ok(ignore): | |
483 print ("Account creation email sent to %s" % email) | |
484 | |
485 def email_ko(ignore): | |
486 #TODO: return error code to user | |
487 error ("Failed to send email to %s" % email) | |
488 | |
489 body = (u"""Welcome to Libervia, a Salut à Toi project part | |
490 | |
491 /!\\ WARNING, THIS IS ONLY A TECHNICAL DEMO, DON'T USE THIS ACCOUNT FOR ANY SERIOUS PURPOSE /!\\ | |
492 | |
493 Here are your connection informations: | |
494 login: %(login)s | |
495 password: %(password)s | |
496 | |
50 | 497 Your Jabber ID (JID) is: %(jid)s |
498 | |
46 | 499 Any feedback welcome |
500 | |
501 Cheers | |
50 | 502 Goffi""" % { 'login': login, 'password': password, 'jid':"%s@%s" % (login, _NEW_ACCOUNT_DOMAIN) }).encode('utf-8') |
46 | 503 msg = MIMEText(body, 'plain', 'UTF-8') |
504 msg['Subject'] = 'Libervia account created' | |
505 msg['From'] = _email_from | |
506 msg['To'] = email | |
507 | |
508 d = sendmail(_email_host, _email_from, email, msg.as_string()) | |
509 d.addCallbacks(email_ok, email_ko) | |
510 | |
511 #email to the administrator | |
512 | |
513 body = (u"""New account created: %(login)s [%(email)s]""" % { 'login': login, 'email': email }).encode('utf-8') | |
514 msg = MIMEText(body, 'plain', 'UTF-8') | |
515 msg['Subject'] = 'Libervia new account created' | |
516 msg['From'] = _email_from | |
517 msg['To'] = _REG_ADMIN_EMAIL | |
518 | |
61 | 519 d = sendmail(_email_host, _email_from, _REG_ADMIN_EMAIL, msg.as_string()) |
46 | 520 d.addCallbacks(email_ok, email_ko) |
521 return "REGISTRATION" | |
522 | |
0 | 523 def __cleanWaiting(self, login): |
524 """Remove login from waiting queue""" | |
525 try: | |
526 del self.profiles_waiting[login] | |
527 except KeyError: | |
528 pass | |
529 | |
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
530 def _logged(self, profile, request, finish=True): |
0 | 531 """Set everything when a user just logged |
532 and return "LOGGED" to the requester""" | |
61 | 533 def result(answer): |
534 if finish: | |
535 request.write(answer) | |
536 request.finish() | |
537 else: | |
538 return answer | |
539 | |
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
540 self.__cleanWaiting(profile) |
0 | 541 _session = request.getSession() |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
542 sat_session = ISATSession(_session) |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
543 if sat_session.profile: |
61 | 544 error (('/!\\ Session has already a profile, this should NEVER happen !')) |
545 return result('SESSION_ACTIVE') | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
546 sat_session.profile = profile |
24 | 547 self.sat_host.prof_connected.add(profile) |
45
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
548 |
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
549 def onExpire(): |
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
550 try: |
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
551 #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
|
552 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
|
553 except KeyError: |
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
554 pass |
130 | 555 #and now we disconnect the profile |
45
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
556 self.sat_host.bridge.disconnect(profile) |
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
557 |
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
558 _session.notifyOnExpire(onExpire) |
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
559 |
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
560 d = defer.Deferred() |
61 | 561 return result('LOGGED') |
0 | 562 |
563 def _logginError(self, login, request, error_type): | |
564 """Something went wrong during loggin, return an error""" | |
565 self.__cleanWaiting(login) | |
566 return error_type | |
567 | |
568 def jsonrpc_isConnected(self): | |
569 _session = self.request.getSession() | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
570 profile = ISATSession(_session).profile |
0 | 571 return self.sat_host.bridge.isConnected(profile) |
572 | |
573 def jsonrpc_connect(self): | |
574 _session = self.request.getSession() | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
575 profile = ISATSession(_session).profile |
0 | 576 if self.profiles_waiting.has_key(profile): |
577 raise jsonrpclib.Fault('1','Already waiting') #FIXME: define some standard error codes for libervia | |
578 self.profiles_waiting[profile] = self.request | |
579 self.sat_host.bridge.connect(profile) | |
580 return server.NOT_DONE_YET | |
581 | |
582 def jsonrpc_isRegistered(self): | |
583 """Tell if the user is already registered""" | |
584 _session = self.request.getSession() | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
585 profile = ISATSession(_session).profile |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
586 return bool(profile) |
0 | 587 |
588 class SignalHandler(jsonrpc.JSONRPC): | |
589 | |
590 def __init__(self, sat_host): | |
591 Resource.__init__(self) | |
592 self.register=None | |
593 self.sat_host=sat_host | |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
594 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
|
595 self.queue = {} |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
596 |
0 | 597 def plugRegister(self, register): |
598 self.register = register | |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
599 |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
600 def jsonrpc_getSignals(self): |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
601 """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
|
602 @return: (signal, *signal_args)""" |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
603 _session = self.request.getSession() |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
604 profile = ISATSession(_session).profile |
24 | 605 if profile in self.queue: #if we have signals to send in queue |
606 if self.queue[profile]: | |
607 return self.queue[profile].pop(0) | |
608 else: | |
609 #the queue is empty, we delete the profile from queue | |
610 del self.queue[profile] | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
611 _session.lock() #we don't want the session to expire as long as this connection is active |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
612 def unlock(ignore): |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
613 _session.unlock() |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
614 self.signalDeferred[profile] = defer.Deferred() |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
615 self.request.notifyFinish().addBoth(unlock) |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
616 return self.signalDeferred[profile] |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
617 |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
618 def getGenericCb(self, function_name): |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
619 """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
|
620 function must have profile as last argument""" |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
621 def genericCb(*args): |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
622 profile = args[-1] |
24 | 623 if not profile in self.sat_host.prof_connected: |
624 return | |
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
625 if profile in self.signalDeferred: |
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
626 self.signalDeferred[profile].callback((function_name,args[:-1])) |
24 | 627 del self.signalDeferred[profile] |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
628 else: |
24 | 629 if not self.queue.has_key(profile): |
630 self.queue[profile] = [] | |
631 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
|
632 return genericCb |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
633 |
0 | 634 def connected(self, profile): |
635 assert(self.register) #register must be plugged | |
636 request = self.register.getWaitingRequest(profile) | |
637 if request: | |
638 self.register._logged(profile, request) | |
639 | |
640 def connectionError(self, error_type, profile): | |
641 assert(self.register) #register must be plugged | |
642 request = self.register.getWaitingRequest(profile) | |
643 if request: #The user is trying to log in | |
644 if error_type == "AUTH_ERROR": | |
645 _error_t = "AUTH ERROR" | |
646 else: | |
647 _error_t = "UNKNOWN" | |
648 self.register._logginError(profile, request, _error_t) | |
649 | |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
650 def render(self, request): |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
651 """ |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
652 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
|
653 """ |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
654 _session = request.getSession() |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
655 parsed = jsonrpclib.loads(request.content.read()) |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
656 profile = ISATSession(_session).profile |
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
657 if not profile: |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
658 #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
|
659 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
|
660 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
|
661 self.request = request |
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
662 return jsonrpc.JSONRPC.render(self, request) |
0 | 663 |
127 | 664 class UploadManager(Resource): |
665 """This class manage the upload of a file | |
666 It redirect the stream to SàT core backend""" | |
667 isLeaf = True | |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
668 NAME = 'path' #name use by the FileUpload |
127 | 669 |
670 def __init__(self, sat_host): | |
671 self.sat_host=sat_host | |
672 self.upload_dir = tempfile.mkdtemp() | |
673 self.sat_host.addCleanup(shutil.rmtree, self.upload_dir) | |
674 | |
128 | 675 def getTmpDir(self): |
676 return self.upload_dir | |
677 | |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
678 def _getFileName(self, request): |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
679 """Generate unique filename for a file""" |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
680 raise NotImplementedError |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
681 |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
682 def _fileWritten(self, request, filepath): |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
683 """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
|
684 raise NotImplementedError |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
685 |
127 | 686 def render(self, request): |
687 """ | |
688 Render method with some hacks: | |
689 - if login is requested, try to login with form data | |
690 - except login, every method is jsonrpc | |
691 - user doesn't need to be authentified for isRegistered, but must be for all other methods | |
692 """ | |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
693 #start = time.time() |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
694 filename = self._getFileName(request) |
128 | 695 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
|
696 #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
|
697 # (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
|
698 # be written in the futur. In addition, it is not yet possible to get progression informations |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
699 # (see http://twistedmatrix.com/trac/ticket/288) |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
700 |
128 | 701 with open(filepath,'w') as f: |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
702 f.write(request.args[self.NAME][0]) |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
703 self._fileWritten(request, filepath) |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
704 #end = time.time() |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
705 #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
|
706 return "OK" |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
707 |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
708 class UploadManagerRadioCol(UploadManager): |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
709 NAME = 'song' |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
710 |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
711 def _getFileName(self, request): |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
712 return "%s.ogg" % str(uuid.uuid4()) #XXX: chromium doesn't seem to play song without the .ogg extension, even with audio/ogg mime-type |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
713 |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
714 def _fileWritten(self, request, filepath): |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
715 """Called once the file is actually written on disk""" |
128 | 716 profile = ISATSession(request.getSession()).profile |
717 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
|
718 |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
719 class UploadManagerAvatar(UploadManager): |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
720 NAME = 'avatar_path' |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
721 |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
722 def _getFileName(self, request): |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
723 return str(uuid.uuid4()) |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
724 |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
725 def _fileWritten(self, request, filepath): |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
726 """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
|
727 profile = ISATSession(request.getSession()).profile |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
728 print u"fichier écrit:", filepath |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
729 self.sat_host.bridge.setAvatar(filepath, profile) |
10 | 730 |
0 | 731 class Libervia(service.Service): |
732 | |
733 def __init__(self): | |
127 | 734 self._cleanup = [] |
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
|
735 root = ProtectedFile(LIBERVIA_DIR) |
0 | 736 self.signal_handler = SignalHandler(self) |
737 _register = Register(self) | |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
738 _upload_radiocol = UploadManagerRadioCol(self) |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
739 _upload_avatar = UploadManagerAvatar(self) |
0 | 740 self.signal_handler.plugRegister(_register) |
741 self.sessions = {} #key = session value = user | |
24 | 742 self.prof_connected = set() #Profiles connected |
46 | 743 self.action_handler = SATActionIDHandler() |
0 | 744 ## bridge ## |
745 try: | |
746 self.bridge=DBusBridgeFrontend() | |
747 except BridgeExceptionNoService: | |
748 print(u"Can't connect to SàT backend, are you sure it's launched ?") | |
749 sys.exit(1) | |
750 self.bridge.register("connected", self.signal_handler.connected) | |
751 self.bridge.register("connectionError", self.signal_handler.connectionError) | |
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
|
752 self.bridge.register("actionResult", self.action_handler.actionResultCb) |
2e2e10785c33
server side: refactored signal according to SàT's bridge changes + getCardCache handling + updatedValue handling
Goffi <goffi@goffi.org>
parents:
110
diff
changeset
|
753 #core |
137 | 754 for signal_name in ['presenceUpdate', 'newMessage', 'subscribe', 'contactDeleted', 'newContact', 'entityDataUpdated']: |
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
755 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
|
756 #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
|
757 for signal_name in ['personalEvent', 'roomJoined', 'roomUserJoined', 'roomUserLeft', 'tarotGameStarted', 'tarotGameNew', 'tarotGameChooseContrat', |
127 | 758 'tarotGameShowCards', 'tarotGameInvalidCards', 'tarotGameCardsPlayed', 'tarotGameYourTurn', 'tarotGameScore', |
130 | 759 'radiocolStarted', 'radiocolPreload', 'radiocolPlay', 'radiocolNoUpload', 'radiocolUploadOk', 'radiocolSongRejected']: |
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
|
760 self.bridge.register(signal_name, self.signal_handler.getGenericCb(signal_name), "plugin") |
77 | 761 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
|
762 self.local_dir = self.bridge.getConfig('','local_dir') |
10 | 763 root.putChild('json_signal_api', self.signal_handler) |
764 root.putChild('json_api', MethodHandler(self)) | |
765 root.putChild('register_api', _register) | |
151
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
766 root.putChild('upload_radiocol', _upload_radiocol) |
a159cc29b556
server side: file upload is now more generic:
Goffi <goffi@goffi.org>
parents:
148
diff
changeset
|
767 root.putChild('upload_avatar', _upload_avatar) |
10 | 768 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
|
769 root.putChild('css', ProtectedFile("server_css/")) |
77 | 770 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
|
771 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
|
772 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 | 773 self.site = server.Site(root) |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
774 self.site.sessionFactory = LiberviaSession |
0 | 775 |
127 | 776 def addCleanup(self, callback, *args, **kwargs): |
777 """Add cleaning method to call when service is stopped | |
778 cleaning method will be called in reverse order of they insertion | |
779 @param callback: callable to call on service stop | |
780 @param *args: list of arguments of the callback | |
781 @param **kwargs: list of keyword arguments of the callback""" | |
782 self._cleanup.insert(0, (callback, args, kwargs)) | |
783 | |
0 | 784 def startService(self): |
785 reactor.listenTCP(8080, self.site) | |
127 | 786 |
787 def stopService(self): | |
788 print "launching cleaning methods" | |
789 for callback, args, kwargs in self._cleanup: | |
790 callback(*args, **kwargs) | |
1 | 791 |
0 | 792 def run(self): |
793 reactor.run() | |
794 | |
795 def stop(self): | |
796 reactor.stop() | |
797 | |
798 | |
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
799 registerAdapter(SATSession, server.Session, ISATSession) |
0 | 800 application = service.Application('Libervia') |
801 service = Libervia() | |
802 service.setServiceParent(application) |