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