annotate libervia.tac @ 83:68d360caeecb

New widget system: first draft - adaptation of Adrien's design - widgets are now based on a flextable - widgets now use a base class LiberviaWidget (the name is to avoid confustion with pyjamas' widgets) - widgets have a title, and setting/close buttons
author Goffi <goffi@goffi.org>
date Sun, 26 Jun 2011 03:04:17 +0200
parents 975e6be24e11
children c3fb3292f582
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
1 #!/usr/bin/python
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
2 # -*- coding: utf-8 -*-
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
3
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
4 """
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
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
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
7
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
8 This program is free software: you can redistribute it and/or modify
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
9 it under the terms of the GNU Affero General Public License as published by
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
10 the Free Software Foundation, either version 3 of the License, or
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
11 (at your option) any later version.
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
12
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
13 This program is distributed in the hope that it will be useful,
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
14 but WITHOUT ANY WARRANTY; without even the implied warranty of
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
16 GNU Affero General Public License for more details.
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
17
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
18 You should have received a copy of the GNU Affero General Public License
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
19 along with this program. If not, see <http://www.gnu.org/licenses/>.
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
20 """
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
21
46
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
22 #You need do adapt the following consts to your server
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
23 _REG_EMAIL_FROM = "NOREPLY@libervia.org"
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
24 _REG_EMAIL_SERVER = "localhost"
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
25 _REG_ADMIN_EMAIL = "goffi@goffi.org"
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
26 _NEW_ACCOUNT_SERVER = "localhost"
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
27 _NEW_ACCOUNT_DOMAIN = "tazar.int"
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
28 _NEW_ACCOUNT_RESOURCE = "libervia"
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
29
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
30 from twisted.application import internet, service
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
31 from twisted.internet import glib2reactor
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
32 glib2reactor.install()
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
33 from twisted.internet import reactor, defer
46
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
34 from twisted.mail.smtp import sendmail
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
35 from twisted.web import server
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
36 from twisted.web import error as weberror
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
37 from twisted.web.static import File
61
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
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
c28a4840e1a8 server: microblog resource
Goffi <goffi@goffi.org>
parents: 3
diff changeset
40 from twisted.words.protocols.jabber.jid import JID
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
41 from txjsonrpc.web import jsonrpc
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
42 from txjsonrpc import jsonrpclib
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
43 from sat_frontends.bridge.DBus import DBusBridgeFrontend,BridgeExceptionNoService
46
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
44 from email.mime.text import MIMEText
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
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
1d406077b49b Tarot Game: first draft
Goffi <goffi@goffi.org>
parents: 35
diff changeset
47 import glob
1d406077b49b Tarot Game: first draft
Goffi <goffi@goffi.org>
parents: 35
diff changeset
48 import os.path
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
49 import sys
10
c28a4840e1a8 server: microblog resource
Goffi <goffi@goffi.org>
parents: 3
diff changeset
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
c28a4840e1a8 server: microblog resource
Goffi <goffi@goffi.org>
parents: 3
diff changeset
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
1d406077b49b Tarot Game: first draft
Goffi <goffi@goffi.org>
parents: 35
diff changeset
54 LIBERVIA_DIR = "output/"
77
975e6be24e11 media paths update
Goffi <goffi@goffi.org>
parents: 67
diff changeset
55 MEDIA_DIR = "media/"
975e6be24e11 media paths update
Goffi <goffi@goffi.org>
parents: 67
diff changeset
56 CARDS_DIR = "games/cards/tarot"
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
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
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
95 class SATActionIDHandler(object):
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
96 """Manage SàT action id lifecycle"""
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
97 ID_LIFETIME = 30 #after this time (in seconds), id will be suppressed and action result will be ignored
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
98
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
99 def __init__(self):
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
100 self.waiting_ids = {}
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
101
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
102 def waitForId(self, id, callback, *args, **kwargs):
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
103 """Wait for an action result
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
104 @param id: id to wait for
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
105 @param callback: method to call when action gave a result back
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
106 @param *args: additional argument to pass to callback
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
107 @param **kwargs: idem"""
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
108 self.waiting_ids[id] = (callback, args, kwargs)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
109 reactor.callLater(self.ID_LIFETIME, self.purgeID, id)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
110
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
111 def purgeID(self, id):
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
112 """Called when an id has not be handled in time"""
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
113 if id in self.waiting_ids:
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
114 warning ("action of id %s has not been managed, id is now ignored" % id)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
115 del self.waiting_ids[id]
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
116
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
117 def actionResultCb(self, answer_type, id, data):
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
118 """Manage the actionResult signal"""
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
119 if id in self.waiting_ids:
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
120 callback, args, kwargs = self.waiting_ids[id]
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
121 del self.waiting_ids[id]
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
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
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
124 class MethodHandler(jsonrpc.JSONRPC):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
125
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
126 def __init__(self, sat_host):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
127 jsonrpc.JSONRPC.__init__(self)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
128 self.sat_host=sat_host
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
129
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
130 def render(self, request):
1
0a7c685faa53 ContactPanel: first draft
Goffi <goffi@goffi.org>
parents: 0
diff changeset
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
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
134 #user is not identified, we return a jsonrpc fault
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
135 parsed = jsonrpclib.loads(request.content.read())
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
136 fault = jsonrpclib.Fault(0, "Not allowed") #FIXME: define some standard error codes for libervia
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
137 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc'))
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
138 return jsonrpc.JSONRPC.render(self, request)
19
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
139
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
140 def jsonrpc_getProfileJid(self):
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
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
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
144 sat_session.jid = JID(self.sat_host.bridge.getParamA("JabberID", "Connection", profile_key=profile))
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
145 return sat_session.jid.full()
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
146
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
147 def jsonrpc_getContacts(self):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
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
0a7c685faa53 ContactPanel: first draft
Goffi <goffi@goffi.org>
parents: 0
diff changeset
150 return self.sat_host.bridge.getContacts(profile)
20
8f4b1a8914c3 - User status is now updated
Goffi <goffi@goffi.org>
parents: 19
diff changeset
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
8f4b1a8914c3 - User status is now updated
Goffi <goffi@goffi.org>
parents: 19
diff changeset
181 def jsonrpc_setStatus(self, status):
8f4b1a8914c3 - User status is now updated
Goffi <goffi@goffi.org>
parents: 19
diff changeset
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
8f4b1a8914c3 - User status is now updated
Goffi <goffi@goffi.org>
parents: 19
diff changeset
184 self.sat_host.bridge.setPresence('', '', 0, {'':status}, profile)
8f4b1a8914c3 - User status is now updated
Goffi <goffi@goffi.org>
parents: 19
diff changeset
185
19
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
186
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
187 def jsonrpc_sendMessage(self, to_jid, msg, subject, type):
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
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
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
190 return self.sat_host.bridge.sendMessage(to_jid, msg, subject, type, profile)
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
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
8f4b1a8914c3 - User status is now updated
Goffi <goffi@goffi.org>
parents: 19
diff changeset
205 def jsonrpc_getPresenceStatus(self):
8f4b1a8914c3 - User status is now updated
Goffi <goffi@goffi.org>
parents: 19
diff changeset
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
8f4b1a8914c3 - User status is now updated
Goffi <goffi@goffi.org>
parents: 19
diff changeset
208 return self.sat_host.bridge.getPresenceStatus(profile)
8f4b1a8914c3 - User status is now updated
Goffi <goffi@goffi.org>
parents: 19
diff changeset
209
19
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
210 def jsonrpc_getHistory(self, from_jid, to_jid, size):
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
211 """Return history for the from_jid/to_jid couple"""
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
212 #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
213 sat_session = ISATSession(self.session)
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
214 profile = sat_session.profile
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
215 sat_jid = sat_session.jid
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
216 if not sat_jid:
19
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
217 error("No jid saved for this profile")
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
218 return {}
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
219 if JID(from_jid).userhost() != sat_jid.userhost() and JID(to_jid).userhost() != sat_jid.userhost():
19
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
220 error("Trying to get history from a different jid, maybe a hack attempt ?")
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
221 return {}
24
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
222 return self.sat_host.bridge.getHistory(from_jid, to_jid, size)
19
e8e3704eb97f Added basic chat panel
Goffi <goffi@goffi.org>
parents: 14
diff changeset
223
50
72c51a4839cc MUC group joining
Goffi <goffi@goffi.org>
parents: 46
diff changeset
224 def jsonrpc_joinMUC(self, room_jid, nick):
72c51a4839cc MUC group joining
Goffi <goffi@goffi.org>
parents: 46
diff changeset
225 """Join a Multi-User Chat room"""
72c51a4839cc MUC group joining
Goffi <goffi@goffi.org>
parents: 46
diff changeset
226 profile = ISATSession(self.session).profile
72c51a4839cc MUC group joining
Goffi <goffi@goffi.org>
parents: 46
diff changeset
227 try:
72c51a4839cc MUC group joining
Goffi <goffi@goffi.org>
parents: 46
diff changeset
228 room_jid = JID(room_jid)
72c51a4839cc MUC group joining
Goffi <goffi@goffi.org>
parents: 46
diff changeset
229 except:
72c51a4839cc MUC group joining
Goffi <goffi@goffi.org>
parents: 46
diff changeset
230 warning('Invalid room jid')
72c51a4839cc MUC group joining
Goffi <goffi@goffi.org>
parents: 46
diff changeset
231 return
72c51a4839cc MUC group joining
Goffi <goffi@goffi.org>
parents: 46
diff changeset
232 self.sat_host.bridge.joinMUC(room_jid.host, room_jid.user, nick, profile)
72c51a4839cc MUC group joining
Goffi <goffi@goffi.org>
parents: 46
diff changeset
233
30
7684e3ceb12d server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents: 24
diff changeset
234 def jsonrpc_getRoomJoined(self):
7684e3ceb12d server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents: 24
diff changeset
235 """Return list of room already joined by user"""
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
236 profile = ISATSession(self.session).profile
30
7684e3ceb12d server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents: 24
diff changeset
237 return self.sat_host.bridge.getRoomJoined(profile)
7684e3ceb12d server_side: added getRoomJoined method
Goffi <goffi@goffi.org>
parents: 24
diff changeset
238
24
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
239 def jsonrpc_launchTarotGame(self, other_players):
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
240 """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
241 profile = ISATSession(self.session).profile
24
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
242 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
243
36
1d406077b49b Tarot Game: first draft
Goffi <goffi@goffi.org>
parents: 35
diff changeset
244 def jsonrpc_getTarotCardsPaths(self):
1d406077b49b Tarot Game: first draft
Goffi <goffi@goffi.org>
parents: 35
diff changeset
245 """Give the path of all the tarot cards"""
77
975e6be24e11 media paths update
Goffi <goffi@goffi.org>
parents: 67
diff changeset
246 _join = os.path.join
975e6be24e11 media paths update
Goffi <goffi@goffi.org>
parents: 67
diff changeset
247 _media_dir = _join(self.sat_host.media_dir,'')
975e6be24e11 media paths update
Goffi <goffi@goffi.org>
parents: 67
diff changeset
248 return map(lambda x: _join(MEDIA_DIR, x[len(_media_dir):]),glob.glob(_join(_media_dir,CARDS_DIR,'*_*.png')));
36
1d406077b49b Tarot Game: first draft
Goffi <goffi@goffi.org>
parents: 35
diff changeset
249
37
b306aa090438 Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents: 36
diff changeset
250 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
251 """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
252 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
253 self.sat_host.bridge.tarotGameReady(player, referee)
36
1d406077b49b Tarot Game: first draft
Goffi <goffi@goffi.org>
parents: 35
diff changeset
254
37
b306aa090438 Tarot game: game launching (first hand showed), and contract selection
Goffi <goffi@goffi.org>
parents: 36
diff changeset
255 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
256 """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
257 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
258 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
259
305e81c7a32c Tarot game: a game can now be finished
Goffi <goffi@goffi.org>
parents: 38
diff changeset
260 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
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
39
305e81c7a32c Tarot game: a game can now be finished
Goffi <goffi@goffi.org>
parents: 38
diff changeset
263 self.sat_host.bridge.tarotGamePlayCards(player_nick, referee, cards, profile)
36
1d406077b49b Tarot Game: first draft
Goffi <goffi@goffi.org>
parents: 35
diff changeset
264
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
265 class Register(jsonrpc.JSONRPC):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
266 """This class manage the registration procedure with SàT
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
267 It provide an api for the browser, check password and setup the web server"""
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
268
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
269 def __init__(self, sat_host):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
270 jsonrpc.JSONRPC.__init__(self)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
271 self.sat_host=sat_host
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
272 self.profiles_waiting={}
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
273 self.request=None
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
274
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
275 def getWaitingRequest(self, profile):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
276 """Tell if a profile is trying to log in"""
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
277 if self.profiles_waiting.has_key(profile):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
278 return self.profiles_waiting[profile]
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
279 else:
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
280 return None
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
281
14
9bf8ed012adc - Group microblog management, first draft
Goffi <goffi@goffi.org>
parents: 11
diff changeset
282 def _fillMblogNodes(self, result, session):
9bf8ed012adc - Group microblog management, first draft
Goffi <goffi@goffi.org>
parents: 11
diff changeset
283 """Fill the microblog nodes association for this session"""
9bf8ed012adc - Group microblog management, first draft
Goffi <goffi@goffi.org>
parents: 11
diff changeset
284 session.sat_mblog_nodes = dict(result)
9bf8ed012adc - Group microblog management, first draft
Goffi <goffi@goffi.org>
parents: 11
diff changeset
285
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
286 def render(self, request):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
287 """
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
288 Render method with some hacks:
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
289 - if login is requested, try to login with form data
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
290 - except login, every method is jsonrpc
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
291 - user doesn't need to be authentified for isRegistered, but must be for all other methods
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
292 """
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
293 if request.postpath==['login']:
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
294 return self.login(request)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
295 _session = request.getSession()
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
296 parsed = jsonrpclib.loads(request.content.read())
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
297 if parsed.get("method")!="isRegistered":
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
298 #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
299 profile = ISATSession(_session).profile
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
300 if not profile:
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
301 #user is not identified, we return a jsonrpc fault
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
302 fault = jsonrpclib.Fault(0, "Not allowed") #FIXME: define some standard error codes for libervia
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
303 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc'))
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
304 self.request = request
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
305 return jsonrpc.JSONRPC.render(self, request)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
306
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
307 def login(self, request):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
308 """
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
309 this method is called with the POST information from the registering form
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
310 it test if the password is ok, and log in if it's the case,
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
311 else it return an error
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
312 @param request: request of the register formulaire, must have "login" and "password" as arguments
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
313 @return: A constant indicating the state:
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
314 - BAD REQUEST: something is wrong in the request (bad arguments, profile_key for login)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
315 - AUTH ERROR: either the profile or the password is wrong
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
316 - ALREADY WAITING: a request has already be made for this profile
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
317 - server.NOT_DONE_YET: the profile is being processed, the return value will be given by self._logged or self._logginError
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
318 """
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
319 try:
66
9d8e79ac4c9c Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents: 61
diff changeset
320 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
321 _login = request.args['login'][0]
9d8e79ac4c9c Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents: 61
diff changeset
322 if _login.startswith('@'):
9d8e79ac4c9c Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents: 61
diff changeset
323 raise Exception('No profile_key allowed')
9d8e79ac4c9c Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents: 61
diff changeset
324 _pass = request.args['login_password'][0]
9d8e79ac4c9c Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents: 61
diff changeset
325
9d8e79ac4c9c Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents: 61
diff changeset
326 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
327 return self._registerNewAccount(request.args)
9d8e79ac4c9c Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents: 61
diff changeset
328
9d8e79ac4c9c Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents: 61
diff changeset
329 else:
9d8e79ac4c9c Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents: 61
diff changeset
330 raise Exception('Unknown submit type')
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
331 except KeyError:
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
332 return "BAD REQUEST"
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
333
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
334 _profile_check = self.sat_host.bridge.getProfileName(_login)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
335 _profile_pass = self.sat_host.bridge.getParamA("Password", "Connection", profile_key=_login)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
336
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
337 if not _profile_check or _profile_check != _login or _profile_pass != _pass:
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
338 return "AUTH ERROR"
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
339
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
340 if self.profiles_waiting.has_key(_login):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
341 return "ALREADY WAITING"
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
342
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
343 if self.sat_host.bridge.isConnected(_login):
14
9bf8ed012adc - Group microblog management, first draft
Goffi <goffi@goffi.org>
parents: 11
diff changeset
344 return self._logged(_login, request, finish=False)
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
345
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
346 self.profiles_waiting[_login] = request
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
347 self.sat_host.bridge.connect(_login)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
348 return server.NOT_DONE_YET
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
349
46
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
350 def _postAccountCreation(self, answer_type, id, data, profile):
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
351 """Called when a account has just been created,
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
352 setup stuff has microblog access"""
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
353 def _connected(ignore):
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
354 mblog_d = defer.Deferred()
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
355 self.sat_host.bridge.setMicroblogAccess("open", profile, lambda: mblog_d.callback(None), mblog_d.errback)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
356 mblog_d.addBoth(lambda ignore: self.sat_host.bridge.disconnect(profile))
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
357
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
358 d = defer.Deferred()
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
359 self.sat_host.bridge.asyncConnect(profile, lambda: d.callback(None), d.errback)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
360 d.addCallback(_connected)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
361
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
362 def _registerNewAccount(self, args):
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
363 """Create a new account, or return error
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
364 @param args: dict of args as given by the form
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
365 @return: "REGISTRATION" in case of success"""
54
f25c4077f6b9 addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents: 50
diff changeset
366 #TODO: must be moved in SàT core
46
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
367 try:
66
9d8e79ac4c9c Login/Register box: integration of Adrien Vigneron's design
Goffi <goffi@goffi.org>
parents: 61
diff changeset
368 profile = login = args['register_login'][0]
67
b096facaa5b3 registration fix
Goffi <goffi@goffi.org>
parents: 66
diff changeset
369 password = args['register_password'][0] #FIXME: password is ignored so far
46
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
370 email = args['email'][0]
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
371 except KeyError:
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
372 return "BAD REQUEST"
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
373 if not re.match(r'^[a-z0-9_-]+$', login, re.IGNORECASE) or \
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
374 not re.match(r'^.+@.+\..+', email, re.IGNORECASE):
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
375 return "BAD REQUEST"
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
376 #_charset = [chr(i) for i in range(0x21,0x7F)] #XXX: this charset seems to have some issues with openfire
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
377 _charset = [chr(i) for i in range(0x30,0x3A) + range(0x41,0x5B) + range (0x61,0x7B)]
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
378 import random
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
379 random.seed()
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
380 password = ''.join([random.choice(_charset) for i in range(15)])
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
381
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
382 if login in self.sat_host.bridge.getProfilesList(): #FIXME: must use a deferred + create a new profile check method
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
383 return "ALREADY EXISTS"
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
384
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
385 #we now create the profile
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
386 self.sat_host.bridge.createProfile(login)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
387 #FIXME: values must be in a config file instead of hardcoded
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
388 self.sat_host.bridge.setParam("JabberID", "%s@%s/%s" % (login, _NEW_ACCOUNT_DOMAIN, _NEW_ACCOUNT_RESOURCE), "Connection", profile)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
389 self.sat_host.bridge.setParam("Server", _NEW_ACCOUNT_SERVER, "Connection", profile)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
390 self.sat_host.bridge.setParam("Password", password, "Connection", profile)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
391 #and the account
61
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
392 action_id = self.sat_host.bridge.registerNewAccount(login, password, email, _NEW_ACCOUNT_DOMAIN, 5222)
46
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
393 self.sat_host.action_handler.waitForId(action_id, self._postAccountCreation, profile)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
394
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
395 #time to send the email
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
396
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
397 _email_host = _REG_EMAIL_SERVER
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
398 _email_from = _REG_EMAIL_FROM
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
399
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
400 def email_ok(ignore):
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
401 print ("Account creation email sent to %s" % email)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
402
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
403 def email_ko(ignore):
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
404 #TODO: return error code to user
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
405 error ("Failed to send email to %s" % email)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
406
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
407 body = (u"""Welcome to Libervia, a Salut à Toi project part
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
408
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
409 /!\\ WARNING, THIS IS ONLY A TECHNICAL DEMO, DON'T USE THIS ACCOUNT FOR ANY SERIOUS PURPOSE /!\\
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
410
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
411 Here are your connection informations:
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
412 login: %(login)s
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
413 password: %(password)s
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
414
50
72c51a4839cc MUC group joining
Goffi <goffi@goffi.org>
parents: 46
diff changeset
415 Your Jabber ID (JID) is: %(jid)s
72c51a4839cc MUC group joining
Goffi <goffi@goffi.org>
parents: 46
diff changeset
416
46
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
417 Any feedback welcome
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
418
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
419 Cheers
50
72c51a4839cc MUC group joining
Goffi <goffi@goffi.org>
parents: 46
diff changeset
420 Goffi""" % { 'login': login, 'password': password, 'jid':"%s@%s" % (login, _NEW_ACCOUNT_DOMAIN) }).encode('utf-8')
46
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
421 msg = MIMEText(body, 'plain', 'UTF-8')
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
422 msg['Subject'] = 'Libervia account created'
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
423 msg['From'] = _email_from
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
424 msg['To'] = email
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
425
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
426 d = sendmail(_email_host, _email_from, email, msg.as_string())
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
427 d.addCallbacks(email_ok, email_ko)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
428
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
429 #email to the administrator
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
430
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
431 body = (u"""New account created: %(login)s [%(email)s]""" % { 'login': login, 'email': email }).encode('utf-8')
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
432 msg = MIMEText(body, 'plain', 'UTF-8')
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
433 msg['Subject'] = 'Libervia new account created'
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
434 msg['From'] = _email_from
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
435 msg['To'] = _REG_ADMIN_EMAIL
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
436
61
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
437 d = sendmail(_email_host, _email_from, _REG_ADMIN_EMAIL, msg.as_string())
46
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
438 d.addCallbacks(email_ok, email_ko)
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
439 return "REGISTRATION"
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
440
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
441 def __cleanWaiting(self, login):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
442 """Remove login from waiting queue"""
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
443 try:
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
444 del self.profiles_waiting[login]
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
445 except KeyError:
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
446 pass
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
447
14
9bf8ed012adc - Group microblog management, first draft
Goffi <goffi@goffi.org>
parents: 11
diff changeset
448 def _logged(self, profile, request, finish=True):
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
449 """Set everything when a user just logged
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
450 and return "LOGGED" to the requester"""
61
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
451 def result(answer):
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
452 if finish:
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
453 request.write(answer)
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
454 request.finish()
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
455 else:
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
456 return answer
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
457
14
9bf8ed012adc - Group microblog management, first draft
Goffi <goffi@goffi.org>
parents: 11
diff changeset
458 self.__cleanWaiting(profile)
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
459 _session = request.getSession()
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
460 sat_session = ISATSession(_session)
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
461 if sat_session.profile:
61
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
462 error (('/!\\ Session has already a profile, this should NEVER happen !'))
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
463 return result('SESSION_ACTIVE')
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
464 sat_session.profile = profile
24
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
465 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
466
7f106052326f server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents: 44
diff changeset
467 def onExpire():
7f106052326f server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents: 44
diff changeset
468 try:
7f106052326f server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents: 44
diff changeset
469 #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
470 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
471 except KeyError:
7f106052326f server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents: 44
diff changeset
472 pass
7f106052326f server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents: 44
diff changeset
473 #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
474 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
475
7f106052326f server side: user is now disconnected on session end, and queue is purged
Goffi <goffi@goffi.org>
parents: 44
diff changeset
476 _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
477
14
9bf8ed012adc - Group microblog management, first draft
Goffi <goffi@goffi.org>
parents: 11
diff changeset
478 d = defer.Deferred()
9bf8ed012adc - Group microblog management, first draft
Goffi <goffi@goffi.org>
parents: 11
diff changeset
479 self.sat_host.bridge.getMblogNodes(profile, d.callback, d.errback)
9bf8ed012adc - Group microblog management, first draft
Goffi <goffi@goffi.org>
parents: 11
diff changeset
480 d.addCallback(self._fillMblogNodes, _session)
61
80c490e6a1a7 server side: misc stuff:
Goffi <goffi@goffi.org>
parents: 59
diff changeset
481 return result('LOGGED')
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
482
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
483 def _logginError(self, login, request, error_type):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
484 """Something went wrong during loggin, return an error"""
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
485 self.__cleanWaiting(login)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
486 return error_type
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
487
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
488 def jsonrpc_isConnected(self):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
489 _session = self.request.getSession()
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
490 profile = ISATSession(_session).profile
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
491 return self.sat_host.bridge.isConnected(profile)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
492
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
493 def jsonrpc_connect(self):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
494 _session = self.request.getSession()
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
495 profile = ISATSession(_session).profile
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
496 if self.profiles_waiting.has_key(profile):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
497 raise jsonrpclib.Fault('1','Already waiting') #FIXME: define some standard error codes for libervia
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
498 self.profiles_waiting[profile] = self.request
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
499 self.sat_host.bridge.connect(profile)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
500 return server.NOT_DONE_YET
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
501
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
502 def jsonrpc_isRegistered(self):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
503 """Tell if the user is already registered"""
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
504 _session = self.request.getSession()
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
505 profile = ISATSession(_session).profile
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
506 return bool(profile)
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
507
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
508 class SignalHandler(jsonrpc.JSONRPC):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
509
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
510 def __init__(self, sat_host):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
511 Resource.__init__(self)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
512 self.register=None
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
513 self.sat_host=sat_host
3
154d4caa57f4 server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents: 2
diff changeset
514 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
515 self.queue = {}
2
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
516
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
517 def plugRegister(self, register):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
518 self.register = register
2
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
519
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
520 def jsonrpc_getSignals(self):
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
521 """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
522 @return: (signal, *signal_args)"""
3
154d4caa57f4 server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents: 2
diff changeset
523 _session = self.request.getSession()
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
524 profile = ISATSession(_session).profile
24
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
525 if profile in self.queue: #if we have signals to send in queue
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
526 if self.queue[profile]:
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
527 return self.queue[profile].pop(0)
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
528 else:
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
529 #the queue is empty, we delete the profile from queue
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
530 del self.queue[profile]
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
531 _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
532 def unlock(ignore):
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
533 _session.unlock()
3
154d4caa57f4 server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents: 2
diff changeset
534 self.signalDeferred[profile] = defer.Deferred()
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
535 self.request.notifyFinish().addBoth(unlock)
3
154d4caa57f4 server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents: 2
diff changeset
536 return self.signalDeferred[profile]
2
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
537
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
538 def getGenericCb(self, function_name):
3
154d4caa57f4 server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents: 2
diff changeset
539 """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
540 function must have profile as last argument"""
2
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
541 def genericCb(*args):
3
154d4caa57f4 server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents: 2
diff changeset
542 profile = args[-1]
24
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
543 if not profile in self.sat_host.prof_connected:
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
544 return
3
154d4caa57f4 server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents: 2
diff changeset
545 if profile in self.signalDeferred:
154d4caa57f4 server side: proper profile management in signals generic callback
Goffi <goffi@goffi.org>
parents: 2
diff changeset
546 self.signalDeferred[profile].callback((function_name,args[:-1]))
24
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
547 del self.signalDeferred[profile]
2
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
548 else:
24
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
549 if not self.queue.has_key(profile):
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
550 self.queue[profile] = []
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
551 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
552 return genericCb
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
553
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
554 def connected(self, profile):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
555 assert(self.register) #register must be plugged
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
556 request = self.register.getWaitingRequest(profile)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
557 if request:
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
558 self.register._logged(profile, request)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
559
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
560 def connectionError(self, error_type, profile):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
561 assert(self.register) #register must be plugged
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
562 request = self.register.getWaitingRequest(profile)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
563 if request: #The user is trying to log in
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
564 if error_type == "AUTH_ERROR":
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
565 _error_t = "AUTH ERROR"
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
566 else:
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
567 _error_t = "UNKNOWN"
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
568 self.register._logginError(profile, request, _error_t)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
569
2
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
570 def render(self, request):
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
571 """
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
572 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
573 """
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
574 _session = request.getSession()
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
575 parsed = jsonrpclib.loads(request.content.read())
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
576 profile = ISATSession(_session).profile
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
577 if not profile:
2
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
578 #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
579 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
580 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
581 self.request = request
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
582 return jsonrpc.JSONRPC.render(self, request)
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
583
10
c28a4840e1a8 server: microblog resource
Goffi <goffi@goffi.org>
parents: 3
diff changeset
584
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
585 class Libervia(service.Service):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
586
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
587 def __init__(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
588 root = ProtectedFile(LIBERVIA_DIR)
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
589 self.signal_handler = SignalHandler(self)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
590 _register = Register(self)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
591 self.signal_handler.plugRegister(_register)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
592 self.sessions = {} #key = session value = user
24
28e203f13144 server side: misc stuff
Goffi <goffi@goffi.org>
parents: 20
diff changeset
593 self.prof_connected = set() #Profiles connected
46
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
594 self.action_handler = SATActionIDHandler()
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
595 ## bridge ##
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
596 try:
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
597 self.bridge=DBusBridgeFrontend()
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
598 except BridgeExceptionNoService:
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
599 print(u"Can't connect to SàT backend, are you sure it's launched ?")
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
600 sys.exit(1)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
601 self.bridge.register("connected", self.signal_handler.connected)
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
602 self.bridge.register("connectionError", self.signal_handler.connectionError)
46
c3ee630914ba Account creation
Goffi <goffi@goffi.org>
parents: 45
diff changeset
603 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
604 for signal_name in ['presenceUpdate', 'personalEvent', 'newMessage', 'roomJoined', 'roomUserJoined', 'roomUserLeft', 'tarotGameStarted', 'tarotGameNew',
54
f25c4077f6b9 addind contact + subscription management + misc
Goffi <goffi@goffi.org>
parents: 50
diff changeset
605 'tarotGameChooseContrat', 'tarotGameShowCards', 'tarotGameInvalidCards', 'tarotGameCardsPlayed', 'tarotGameYourTurn', 'tarotGameScore',
55
d5266c41ca24 Roster list update, contact deletion + some refactoring
Goffi <goffi@goffi.org>
parents: 54
diff changeset
606 'subscribe', 'contactDeleted', 'newContact']:
2
669c531a857e signals handling and first draft of microblogging
Goffi <goffi@goffi.org>
parents: 1
diff changeset
607 self.bridge.register(signal_name, self.signal_handler.getGenericCb(signal_name))
77
975e6be24e11 media paths update
Goffi <goffi@goffi.org>
parents: 67
diff changeset
608 self.media_dir = self.bridge.getConfig('','media_dir')
10
c28a4840e1a8 server: microblog resource
Goffi <goffi@goffi.org>
parents: 3
diff changeset
609 root.putChild('json_signal_api', self.signal_handler)
c28a4840e1a8 server: microblog resource
Goffi <goffi@goffi.org>
parents: 3
diff changeset
610 root.putChild('json_api', MethodHandler(self))
c28a4840e1a8 server: microblog resource
Goffi <goffi@goffi.org>
parents: 3
diff changeset
611 root.putChild('register_api', _register)
c28a4840e1a8 server: microblog resource
Goffi <goffi@goffi.org>
parents: 3
diff changeset
612 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
613 root.putChild('css', ProtectedFile("server_css/"))
77
975e6be24e11 media paths update
Goffi <goffi@goffi.org>
parents: 67
diff changeset
614 root.putChild(os.path.dirname(MEDIA_DIR), ProtectedFile(self.media_dir))
10
c28a4840e1a8 server: microblog resource
Goffi <goffi@goffi.org>
parents: 3
diff changeset
615 self.site = server.Site(root)
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
616 self.site.sessionFactory = LiberviaSession
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
617
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
618 def startService(self):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
619 reactor.listenTCP(8080, self.site)
1
0a7c685faa53 ContactPanel: first draft
Goffi <goffi@goffi.org>
parents: 0
diff changeset
620
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
621 def run(self):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
622 reactor.run()
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
623
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
624 def stop(self):
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
625 reactor.stop()
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
626
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
627
44
2744dd31e8a5 server side: Session management refactoring
Goffi <goffi@goffi.org>
parents: 41
diff changeset
628 registerAdapter(SATSession, server.Session, ISATSession)
0
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
629 application = service.Application('Libervia')
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
630 service = Libervia()
140cec48224a Initial commit
Goffi <goffi@goffi.org>
parents:
diff changeset
631 service.setServiceParent(application)