Mercurial > libervia-web
annotate libervia.tac @ 46:c3ee630914ba
Account creation
* browser side:
- login dialog has been extended to manage subscription
* server side:
- SATActionIDHandler to manage replies to action
- account is created on subscribtion form, a password is created, and 2 emails are send (one to user, one to administrator)
- access of main microblog is set to open
| author | Goffi <goffi@goffi.org> |
|---|---|
| date | Thu, 26 May 2011 16:43:30 +0200 |
| parents | 7f106052326f |
| children | 72c51a4839cc |
| rev | line source |
|---|---|
| 0 | 1 #!/usr/bin/python |
| 2 # -*- coding: utf-8 -*- | |
| 3 | |
| 4 """ | |
| 5 Libervia: a Salut à Toi frontend | |
| 6 Copyright (C) 2011 Jérôme Poisson (goffi@goffi.org) | |
| 7 | |
| 8 This program is free software: you can redistribute it and/or modify | |
| 9 it under the terms of the GNU 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 | |
| 38 from twisted.web.resource import Resource | |
|
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 | |
|
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
46 import re |
| 36 | 47 import glob |
| 48 import os.path | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
49 import sys |
| 10 | 50 from server_side.blog import MicroBlog |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
51 from zope.interface import Interface, Attribute, implements |
| 10 | 52 |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
53 TIMEOUT = 10 #Session's time out, after that the user will be disconnected |
| 36 | 54 LIBERVIA_DIR = "output/" |
| 55 CARDS_DIR = "cards/" | |
| 0 | 56 |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
57 class ISATSession(Interface): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
58 profile = Attribute("Sat profile") |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
59 jid = Attribute("JID associated with the profile") |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
60 |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
61 class SATSession(object): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
62 implements(ISATSession) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
63 def __init__(self, session): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
64 self.profile = None |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
65 self.jid = None |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
66 |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
67 class LiberviaSession(server.Session): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
68 sessionTimeout = TIMEOUT |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
69 |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
70 def __init__(self, *args, **kwargs): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
71 self.__lock = False |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
72 server.Session.__init__(self, *args, **kwargs) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
73 |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
74 def lock(self): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
75 """Prevent session from expiring""" |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
76 self.__lock = True |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
77 self._expireCall.reset(sys.maxint) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
78 |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
79 def unlock(self): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
80 """Allow session to expire again, and touch it""" |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
81 self.__lock = False |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
82 self.touch() |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
83 |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
84 def touch(self): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
85 if not self.__lock: |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
86 server.Session.touch(self) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
87 |
| 46 | 88 class SATActionIDHandler(object): |
| 89 """Manage SàT action id lifecycle""" | |
| 90 ID_LIFETIME = 30 #after this time (in seconds), id will be suppressed and action result will be ignored | |
| 91 | |
| 92 def __init__(self): | |
| 93 self.waiting_ids = {} | |
| 94 | |
| 95 def waitForId(self, id, callback, *args, **kwargs): | |
| 96 """Wait for an action result | |
| 97 @param id: id to wait for | |
| 98 @param callback: method to call when action gave a result back | |
| 99 @param *args: additional argument to pass to callback | |
| 100 @param **kwargs: idem""" | |
| 101 self.waiting_ids[id] = (callback, args, kwargs) | |
| 102 reactor.callLater(self.ID_LIFETIME, self.purgeID, id) | |
| 103 | |
| 104 def purgeID(self, id): | |
| 105 """Called when an id has not be handled in time""" | |
| 106 if id in self.waiting_ids: | |
| 107 warning ("action of id %s has not been managed, id is now ignored" % id) | |
| 108 del self.waiting_ids[id] | |
| 109 | |
| 110 def actionResultCb(self, answer_type, id, data): | |
| 111 """Manage the actionResult signal""" | |
| 112 if id in self.waiting_ids: | |
| 113 callback, args, kwargs = self.waiting_ids[id] | |
| 114 del self.waiting_ids[id] | |
| 115 callback(answer_type, id, data, *args, **kwargs) | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
116 |
| 0 | 117 class MethodHandler(jsonrpc.JSONRPC): |
| 118 | |
| 119 def __init__(self, sat_host): | |
| 120 jsonrpc.JSONRPC.__init__(self) | |
| 121 self.sat_host=sat_host | |
| 122 | |
| 123 def render(self, request): | |
| 1 | 124 self.session = request.getSession() |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
125 profile = ISATSession(self.session).profile |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
126 if not profile: |
| 0 | 127 #user is not identified, we return a jsonrpc fault |
| 128 parsed = jsonrpclib.loads(request.content.read()) | |
| 129 fault = jsonrpclib.Fault(0, "Not allowed") #FIXME: define some standard error codes for libervia | |
| 130 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc')) | |
| 131 return jsonrpc.JSONRPC.render(self, request) | |
| 19 | 132 |
| 133 def jsonrpc_getProfileJid(self): | |
| 134 """Return the jid of the profile""" | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
135 sat_session = ISATSession(self.session) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
136 profile = sat_session.profile |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
137 sat_session.sat_jid = JID(self.sat_host.bridge.getParamA("JabberID", "Connection", profile_key=profile)) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
138 return sat_session.sat_jid.full() |
| 0 | 139 |
| 140 def jsonrpc_getContacts(self): | |
| 141 """Return all passed args.""" | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
142 profile = ISATSession(self.session).profile |
| 1 | 143 return self.sat_host.bridge.getContacts(profile) |
| 20 | 144 |
| 145 def jsonrpc_setStatus(self, status): | |
| 146 """Change the status""" | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
147 profile = ISATSession(self.session).profile |
| 20 | 148 print "new status received:", status |
| 149 self.sat_host.bridge.setPresence('', '', 0, {'':status}, profile) | |
| 150 | |
| 19 | 151 |
| 152 def jsonrpc_sendMessage(self, to_jid, msg, subject, type): | |
| 153 """send message""" | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
154 profile = ISATSession(self.session).profile |
| 19 | 155 return self.sat_host.bridge.sendMessage(to_jid, msg, subject, type, profile) |
| 0 | 156 |
|
11
331c093e4eb3
magicBox is now able to send global microblog
Goffi <goffi@goffi.org>
parents:
10
diff
changeset
|
157 def jsonrpc_sendMblog(self, raw_text): |
|
331c093e4eb3
magicBox is now able to send global microblog
Goffi <goffi@goffi.org>
parents:
10
diff
changeset
|
158 """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
|
159 profile = ISATSession(self.session).profile |
|
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
160 match = re.match(r'@(.+?): *(.*$)', raw_text) |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
161 if match: |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
162 recip = match.group(1) |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
163 text = match.group(2) |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
164 if recip == '@' and text: |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
165 #This text if for the public microblog |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
166 print "Sending message to everybody" |
|
11
331c093e4eb3
magicBox is now able to send global microblog
Goffi <goffi@goffi.org>
parents:
10
diff
changeset
|
167 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
|
168 else: |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
169 return self.sat_host.bridge.sendGroupBlog([recip], text, profile) |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
170 |
| 20 | 171 def jsonrpc_getPresenceStatus(self): |
| 172 """Get Presence information for connected contacts""" | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
173 profile = ISATSession(self.session).profile |
| 20 | 174 return self.sat_host.bridge.getPresenceStatus(profile) |
| 175 | |
| 19 | 176 def jsonrpc_getHistory(self, from_jid, to_jid, size): |
| 177 """Return history for the from_jid/to_jid couple""" | |
| 178 #FIXME: this method should definitely be asynchrone, need to fix it !!! | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
179 sat_session = ISATSession(self.session) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
180 profile = sat_session.profile |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
181 sat_jid = sat_session.jid |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
182 if not sat_jid: |
| 19 | 183 error("No jid saved for this profile") |
| 184 return {} | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
185 if JID(from_jid).userhost() != sat_jid.userhost() and JID(to_jid).userhost() != sat_jid.userhost(): |
| 19 | 186 error("Trying to get history from a different jid, maybe a hack attempt ?") |
| 187 return {} | |
| 24 | 188 return self.sat_host.bridge.getHistory(from_jid, to_jid, size) |
| 19 | 189 |
|
30
7684e3ceb12d
server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents:
24
diff
changeset
|
190 def jsonrpc_getRoomJoined(self): |
|
7684e3ceb12d
server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents:
24
diff
changeset
|
191 """Return list of room already joined by user""" |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
192 profile = ISATSession(self.session).profile |
|
30
7684e3ceb12d
server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents:
24
diff
changeset
|
193 return self.sat_host.bridge.getRoomJoined(profile) |
|
7684e3ceb12d
server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents:
24
diff
changeset
|
194 |
| 24 | 195 def jsonrpc_launchTarotGame(self, other_players): |
| 196 """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
|
197 profile = ISATSession(self.session).profile |
| 24 | 198 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
|
199 |
| 36 | 200 def jsonrpc_getTarotCardsPaths(self): |
| 201 """Give the path of all the tarot cards""" | |
| 202 return map(lambda x: x[len(LIBERVIA_DIR):],glob.glob(os.path.join(LIBERVIA_DIR,CARDS_DIR,'*_*.png'))); | |
| 203 | |
|
37
b306aa090438
Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents:
36
diff
changeset
|
204 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
|
205 """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
|
206 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
|
207 self.sat_host.bridge.tarotGameReady(player, referee) |
| 36 | 208 |
|
37
b306aa090438
Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents:
36
diff
changeset
|
209 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
|
210 """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
|
211 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
|
212 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
|
213 |
|
305e81c7a32c
Tarot game: a game can now be finished
Goffi <goffi@goffi.org>
parents:
38
diff
changeset
|
214 def jsonrpc_tarotGamePlayCards(self, player_nick, referee, cards): |
|
305e81c7a32c
Tarot game: a game can now be finished
Goffi <goffi@goffi.org>
parents:
38
diff
changeset
|
215 """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
|
216 profile = ISATSession(self.session).profile |
|
39
305e81c7a32c
Tarot game: a game can now be finished
Goffi <goffi@goffi.org>
parents:
38
diff
changeset
|
217 self.sat_host.bridge.tarotGamePlayCards(player_nick, referee, cards, profile) |
| 36 | 218 |
| 0 | 219 class Register(jsonrpc.JSONRPC): |
| 220 """This class manage the registration procedure with SàT | |
| 221 It provide an api for the browser, check password and setup the web server""" | |
| 222 | |
| 223 def __init__(self, sat_host): | |
| 224 jsonrpc.JSONRPC.__init__(self) | |
| 225 self.sat_host=sat_host | |
| 226 self.profiles_waiting={} | |
| 227 self.request=None | |
| 228 | |
| 229 def getWaitingRequest(self, profile): | |
| 230 """Tell if a profile is trying to log in""" | |
| 231 if self.profiles_waiting.has_key(profile): | |
| 232 return self.profiles_waiting[profile] | |
| 233 else: | |
| 234 return None | |
| 235 | |
|
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
236 def _fillMblogNodes(self, result, session): |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
237 """Fill the microblog nodes association for this session""" |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
238 session.sat_mblog_nodes = dict(result) |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
239 |
| 0 | 240 def render(self, request): |
| 241 """ | |
| 242 Render method with some hacks: | |
| 243 - if login is requested, try to login with form data | |
| 244 - except login, every method is jsonrpc | |
| 245 - user doesn't need to be authentified for isRegistered, but must be for all other methods | |
| 246 """ | |
| 247 if request.postpath==['login']: | |
| 248 return self.login(request) | |
| 249 _session = request.getSession() | |
| 250 parsed = jsonrpclib.loads(request.content.read()) | |
| 251 if parsed.get("method")!="isRegistered": | |
| 252 #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
|
253 profile = ISATSession(_session).profile |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
254 if not profile: |
| 0 | 255 #user is not identified, we return a jsonrpc fault |
| 256 fault = jsonrpclib.Fault(0, "Not allowed") #FIXME: define some standard error codes for libervia | |
| 257 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc')) | |
| 258 self.request = request | |
| 259 return jsonrpc.JSONRPC.render(self, request) | |
| 260 | |
| 261 def login(self, request): | |
| 262 """ | |
| 263 this method is called with the POST information from the registering form | |
| 264 it test if the password is ok, and log in if it's the case, | |
| 265 else it return an error | |
| 266 @param request: request of the register formulaire, must have "login" and "password" as arguments | |
| 267 @return: A constant indicating the state: | |
| 268 - BAD REQUEST: something is wrong in the request (bad arguments, profile_key for login) | |
| 269 - AUTH ERROR: either the profile or the password is wrong | |
| 270 - ALREADY WAITING: a request has already be made for this profile | |
| 271 - server.NOT_DONE_YET: the profile is being processed, the return value will be given by self._logged or self._logginError | |
| 272 """ | |
| 46 | 273 if 'new_account' in request.args: |
| 274 return self._registerNewAccount(request.args) | |
| 275 | |
| 0 | 276 try: |
| 277 _login = request.args['login'][0] | |
| 278 if _login.startswith('@'): | |
| 279 raise Exception('No profile_key allowed') | |
| 280 _pass = request.args['password'][0] | |
| 281 except KeyError: | |
| 282 return "BAD REQUEST" | |
| 283 | |
| 284 _profile_check = self.sat_host.bridge.getProfileName(_login) | |
| 285 _profile_pass = self.sat_host.bridge.getParamA("Password", "Connection", profile_key=_login) | |
| 286 | |
| 287 if not _profile_check or _profile_check != _login or _profile_pass != _pass: | |
| 288 return "AUTH ERROR" | |
| 289 | |
| 290 if self.profiles_waiting.has_key(_login): | |
| 291 return "ALREADY WAITING" | |
| 292 | |
| 293 if self.sat_host.bridge.isConnected(_login): | |
|
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
294 return self._logged(_login, request, finish=False) |
| 0 | 295 |
| 296 self.profiles_waiting[_login] = request | |
| 297 self.sat_host.bridge.connect(_login) | |
| 298 return server.NOT_DONE_YET | |
| 299 | |
| 46 | 300 def _postAccountCreation(self, answer_type, id, data, profile): |
| 301 """Called when a account has just been created, | |
| 302 setup stuff has microblog access""" | |
| 303 def _connected(ignore): | |
| 304 mblog_d = defer.Deferred() | |
| 305 self.sat_host.bridge.setMicroblogAccess("open", profile, lambda: mblog_d.callback(None), mblog_d.errback) | |
| 306 mblog_d.addBoth(lambda ignore: self.sat_host.bridge.disconnect(profile)) | |
| 307 | |
| 308 d = defer.Deferred() | |
| 309 self.sat_host.bridge.asyncConnect(profile, lambda: d.callback(None), d.errback) | |
| 310 d.addCallback(_connected) | |
| 311 | |
| 312 def _registerNewAccount(self, args): | |
| 313 """Create a new account, or return error | |
| 314 @param args: dict of args as given by the form | |
| 315 @return: "REGISTRATION" in case of success""" | |
| 316 try: | |
| 317 profile = login = args['login'][0] | |
| 318 email = args['email'][0] | |
| 319 except KeyError: | |
| 320 return "BAD REQUEST" | |
| 321 if not re.match(r'^[a-z0-9_-]+$', login, re.IGNORECASE) or \ | |
| 322 not re.match(r'^.+@.+\..+', email, re.IGNORECASE): | |
| 323 return "BAD REQUEST" | |
| 324 #_charset = [chr(i) for i in range(0x21,0x7F)] #XXX: this charset seems to have some issues with openfire | |
| 325 _charset = [chr(i) for i in range(0x30,0x3A) + range(0x41,0x5B) + range (0x61,0x7B)] | |
| 326 import random | |
| 327 random.seed() | |
| 328 password = ''.join([random.choice(_charset) for i in range(15)]) | |
| 329 | |
| 330 if login in self.sat_host.bridge.getProfilesList(): #FIXME: must use a deferred + create a new profile check method | |
| 331 return "ALREADY EXISTS" | |
| 332 | |
| 333 #we now create the profile | |
| 334 self.sat_host.bridge.createProfile(login) | |
| 335 #FIXME: values must be in a config file instead of hardcoded | |
| 336 self.sat_host.bridge.setParam("JabberID", "%s@%s/%s" % (login, _NEW_ACCOUNT_DOMAIN, _NEW_ACCOUNT_RESOURCE), "Connection", profile) | |
| 337 self.sat_host.bridge.setParam("Server", _NEW_ACCOUNT_SERVER, "Connection", profile) | |
| 338 self.sat_host.bridge.setParam("Password", password, "Connection", profile) | |
| 339 #and the account | |
| 340 action_id = self.sat_host.bridge.registerNewAccount(login, password, email, "tazar.int", 5222) | |
| 341 self.sat_host.action_handler.waitForId(action_id, self._postAccountCreation, profile) | |
| 342 | |
| 343 #time to send the email | |
| 344 | |
| 345 _email_host = _REG_EMAIL_SERVER | |
| 346 _email_from = _REG_EMAIL_FROM | |
| 347 | |
| 348 def email_ok(ignore): | |
| 349 print ("Account creation email sent to %s" % email) | |
| 350 | |
| 351 def email_ko(ignore): | |
| 352 #TODO: return error code to user | |
| 353 error ("Failed to send email to %s" % email) | |
| 354 | |
| 355 body = (u"""Welcome to Libervia, a Salut à Toi project part | |
| 356 | |
| 357 /!\\ WARNING, THIS IS ONLY A TECHNICAL DEMO, DON'T USE THIS ACCOUNT FOR ANY SERIOUS PURPOSE /!\\ | |
| 358 | |
| 359 Here are your connection informations: | |
| 360 login: %(login)s | |
| 361 password: %(password)s | |
| 362 | |
| 363 Any feedback welcome | |
| 364 | |
| 365 Cheers | |
| 366 Goffi""" % { 'login': login, 'password': password }).encode('utf-8') | |
| 367 msg = MIMEText(body, 'plain', 'UTF-8') | |
| 368 msg['Subject'] = 'Libervia account created' | |
| 369 msg['From'] = _email_from | |
| 370 msg['To'] = email | |
| 371 | |
| 372 d = sendmail(_email_host, _email_from, email, msg.as_string()) | |
| 373 d.addCallbacks(email_ok, email_ko) | |
| 374 | |
| 375 #email to the administrator | |
| 376 | |
| 377 body = (u"""New account created: %(login)s [%(email)s]""" % { 'login': login, 'email': email }).encode('utf-8') | |
| 378 msg = MIMEText(body, 'plain', 'UTF-8') | |
| 379 msg['Subject'] = 'Libervia new account created' | |
| 380 msg['From'] = _email_from | |
| 381 msg['To'] = _REG_ADMIN_EMAIL | |
| 382 | |
| 383 d = sendmail(_email_host, _email_from, email, msg.as_string()) | |
| 384 d.addCallbacks(email_ok, email_ko) | |
| 385 print "rturn REGISTRATION" | |
| 386 return "REGISTRATION" | |
| 387 | |
| 0 | 388 def __cleanWaiting(self, login): |
| 389 """Remove login from waiting queue""" | |
| 390 try: | |
| 391 del self.profiles_waiting[login] | |
| 392 except KeyError: | |
| 393 pass | |
| 394 | |
|
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
395 def _logged(self, profile, request, finish=True): |
| 0 | 396 """Set everything when a user just logged |
| 397 and return "LOGGED" to the requester""" | |
|
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
398 self.__cleanWaiting(profile) |
| 0 | 399 _session = request.getSession() |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
400 sat_session = ISATSession(_session) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
401 if sat_session.profile: |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
402 error (_('/!\\ Session has already a profile, this should NEVER happen !')) |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
403 sat_session.profile = profile |
| 24 | 404 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
|
405 |
|
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
406 def onExpire(): |
|
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
407 try: |
|
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
408 #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
|
409 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
|
410 except KeyError: |
|
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
411 pass |
|
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
412 #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
|
413 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
|
414 |
|
7f106052326f
server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents:
44
diff
changeset
|
415 _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
|
416 |
|
14
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
417 d = defer.Deferred() |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
418 self.sat_host.bridge.getMblogNodes(profile, d.callback, d.errback) |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
419 d.addCallback(self._fillMblogNodes, _session) |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
420 if finish: |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
421 request.write('LOGGED') |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
422 request.finish() |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
423 else: |
|
9bf8ed012adc
- Group microblog management, first draft
Goffi <goffi@goffi.org>
parents:
11
diff
changeset
|
424 return "LOGGED" |
| 0 | 425 |
| 426 def _logginError(self, login, request, error_type): | |
| 427 """Something went wrong during loggin, return an error""" | |
| 428 self.__cleanWaiting(login) | |
| 429 return error_type | |
| 430 | |
| 431 def jsonrpc_isConnected(self): | |
| 432 _session = self.request.getSession() | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
433 profile = ISATSession(_session).profile |
| 0 | 434 return self.sat_host.bridge.isConnected(profile) |
| 435 | |
| 436 def jsonrpc_connect(self): | |
| 437 _session = self.request.getSession() | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
438 profile = ISATSession(_session).profile |
| 0 | 439 if self.profiles_waiting.has_key(profile): |
| 440 raise jsonrpclib.Fault('1','Already waiting') #FIXME: define some standard error codes for libervia | |
| 441 self.profiles_waiting[profile] = self.request | |
| 442 self.sat_host.bridge.connect(profile) | |
| 443 return server.NOT_DONE_YET | |
| 444 | |
| 445 def jsonrpc_isRegistered(self): | |
| 446 """Tell if the user is already registered""" | |
| 447 _session = self.request.getSession() | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
448 profile = ISATSession(_session).profile |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
449 return bool(profile) |
| 0 | 450 |
| 451 class SignalHandler(jsonrpc.JSONRPC): | |
| 452 | |
| 453 def __init__(self, sat_host): | |
| 454 Resource.__init__(self) | |
| 455 self.register=None | |
| 456 self.sat_host=sat_host | |
|
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
457 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
|
458 self.queue = {} |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
459 |
| 0 | 460 def plugRegister(self, register): |
| 461 self.register = register | |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
462 |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
463 def jsonrpc_getSignals(self): |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
464 """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
|
465 @return: (signal, *signal_args)""" |
|
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
466 _session = self.request.getSession() |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
467 profile = ISATSession(_session).profile |
| 24 | 468 if profile in self.queue: #if we have signals to send in queue |
| 469 if self.queue[profile]: | |
| 470 return self.queue[profile].pop(0) | |
| 471 else: | |
| 472 #the queue is empty, we delete the profile from queue | |
| 473 del self.queue[profile] | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
474 _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
|
475 def unlock(ignore): |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
476 _session.unlock() |
|
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
477 self.signalDeferred[profile] = defer.Deferred() |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
478 self.request.notifyFinish().addBoth(unlock) |
|
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
479 return self.signalDeferred[profile] |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
480 |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
481 def getGenericCb(self, function_name): |
|
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
482 """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
|
483 function must have profile as last argument""" |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
484 def genericCb(*args): |
|
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
485 profile = args[-1] |
| 24 | 486 if not profile in self.sat_host.prof_connected: |
| 487 return | |
|
3
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
488 if profile in self.signalDeferred: |
|
154d4caa57f4
server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents:
2
diff
changeset
|
489 self.signalDeferred[profile].callback((function_name,args[:-1])) |
| 24 | 490 del self.signalDeferred[profile] |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
491 else: |
| 24 | 492 if not self.queue.has_key(profile): |
| 493 self.queue[profile] = [] | |
| 494 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
|
495 return genericCb |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
496 |
| 0 | 497 def connected(self, profile): |
| 498 assert(self.register) #register must be plugged | |
| 499 request = self.register.getWaitingRequest(profile) | |
| 500 if request: | |
| 501 self.register._logged(profile, request) | |
| 502 | |
| 503 def connectionError(self, error_type, profile): | |
| 504 assert(self.register) #register must be plugged | |
| 505 request = self.register.getWaitingRequest(profile) | |
| 506 if request: #The user is trying to log in | |
| 507 if error_type == "AUTH_ERROR": | |
| 508 _error_t = "AUTH ERROR" | |
| 509 else: | |
| 510 _error_t = "UNKNOWN" | |
| 511 self.register._logginError(profile, request, _error_t) | |
| 512 | |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
513 def render(self, request): |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
514 """ |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
515 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
|
516 """ |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
517 _session = request.getSession() |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
518 parsed = jsonrpclib.loads(request.content.read()) |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
519 profile = ISATSession(_session).profile |
|
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
520 if not profile: |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
521 #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
|
522 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
|
523 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
|
524 self.request = request |
|
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
525 return jsonrpc.JSONRPC.render(self, request) |
| 0 | 526 |
| 10 | 527 |
| 0 | 528 class Libervia(service.Service): |
| 529 | |
| 530 def __init__(self): | |
| 36 | 531 root = File(LIBERVIA_DIR) |
| 0 | 532 self.signal_handler = SignalHandler(self) |
| 533 _register = Register(self) | |
| 534 self.signal_handler.plugRegister(_register) | |
| 535 self.sessions = {} #key = session value = user | |
| 24 | 536 self.prof_connected = set() #Profiles connected |
| 46 | 537 self.action_handler = SATActionIDHandler() |
| 0 | 538 ## bridge ## |
| 539 try: | |
| 540 self.bridge=DBusBridgeFrontend() | |
| 541 except BridgeExceptionNoService: | |
| 542 print(u"Can't connect to SàT backend, are you sure it's launched ?") | |
| 543 sys.exit(1) | |
| 544 self.bridge.register("connected", self.signal_handler.connected) | |
| 545 self.bridge.register("connectionError", self.signal_handler.connectionError) | |
| 46 | 546 self.bridge.register("actionResult", self.action_handler.actionResultCb, "request") |
|
37
b306aa090438
Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents:
36
diff
changeset
|
547 for signal_name in ['presenceUpdate', 'personalEvent', 'newMessage', 'roomJoined', 'roomUserJoined', 'roomUserLeft', 'tarotGameStarted', 'tarotGameNew', |
|
41
7782a786b2f0
Tarot game: score is now shown (need to use XMLUI later)
Goffi <goffi@goffi.org>
parents:
39
diff
changeset
|
548 'tarotGameChooseContrat', 'tarotGameShowCards', 'tarotGameInvalidCards', 'tarotGameCardsPlayed', 'tarotGameYourTurn', 'tarotGameScore']: |
|
2
669c531a857e
signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents:
1
diff
changeset
|
549 self.bridge.register(signal_name, self.signal_handler.getGenericCb(signal_name)) |
| 10 | 550 root.putChild('json_signal_api', self.signal_handler) |
| 551 root.putChild('json_api', MethodHandler(self)) | |
| 552 root.putChild('register_api', _register) | |
| 553 root.putChild('blog', MicroBlog(self)) | |
| 554 root.putChild('css', File("server_css/")) | |
| 555 self.site = server.Site(root) | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
556 self.site.sessionFactory = LiberviaSession |
| 0 | 557 |
| 558 def startService(self): | |
| 559 reactor.listenTCP(8080, self.site) | |
| 1 | 560 |
| 0 | 561 def run(self): |
| 562 reactor.run() | |
| 563 | |
| 564 def stop(self): | |
| 565 reactor.stop() | |
| 566 | |
| 567 | |
|
44
2744dd31e8a5
server side: Session management refactoring
Goffi <goffi@goffi.org>
parents:
41
diff
changeset
|
568 registerAdapter(SATSession, server.Session, ISATSession) |
| 0 | 569 application = service.Application('Libervia') |
| 570 service = Libervia() | |
| 571 service.setServiceParent(application) |