Mercurial > libervia-web

annotate libervia.tac @ 330:e43a1a0b4f23

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
reverted changeset c144b603fb93 (bug 7)
author Goffi <goffi@goffi.org>
date Sat, 11 Jan 2014 18:30:10 +0100
parents
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
330
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
1 #!/usr/bin/python
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
2 # -*- coding: utf-8 -*-
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
3
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
4 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
5 Libervia: a Salut à Toi frontend
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
6 Copyright (C) 2011, 2012, 2013 Jérôme Poisson <goffi@goffi.org>
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
7
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
8 This program is free software: you can redistribute it and/or modify
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
9 it under the terms of the GNU Affero General Public License as published by
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
10 the Free Software Foundation, either version 3 of the License, or
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
11 (at your option) any later version.
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
12
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
13 This program is distributed in the hope that it will be useful,
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
14 but WITHOUT ANY WARRANTY; without even the implied warranty of
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
16 GNU Affero General Public License for more details.
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
17
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
18 You should have received a copy of the GNU Affero General Public License
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
19 along with this program. If not, see <http://www.gnu.org/licenses/>.
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
20 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
21
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
22 from twisted.application import internet, service
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
23 from twisted.internet import glib2reactor
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
24 glib2reactor.install()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
25 from twisted.internet import reactor, defer
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
26 from twisted.web import server
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
27 from twisted.web import error as weberror
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
28 from twisted.web.static import File
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
29 from twisted.web.resource import Resource, NoResource
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
30 from twisted.web.util import Redirect
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
31 from twisted.python.components import registerAdapter
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
32 from twisted.python.failure import Failure
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
33 from twisted.words.protocols.jabber.jid import JID
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
34 from txjsonrpc.web import jsonrpc
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
35 from txjsonrpc import jsonrpclib
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
36
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
37 from logging import debug, info, warning, error
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
38 import re, glob
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
39 import os.path, sys
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
40 import tempfile, shutil, uuid
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
41 from zope.interface import Interface, Attribute, implements
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
42 from xml.dom import minidom
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
43
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
44 from constants import Const
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
45 from server_side.blog import MicroBlog
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
46 from sat_frontends.bridge.DBus import DBusBridgeFrontend, BridgeExceptionNoService
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
47 from sat.core.i18n import _, D_
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
48
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
49
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
50 class ISATSession(Interface):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
51 profile = Attribute("Sat profile")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
52 jid = Attribute("JID associated with the profile")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
53
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
54 class SATSession(object):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
55 implements(ISATSession)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
56 def __init__(self, session):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
57 self.profile = None
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
58 self.jid = None
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
59
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
60 class LiberviaSession(server.Session):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
61 sessionTimeout = Const.TIMEOUT
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
62
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
63 def __init__(self, *args, **kwargs):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
64 self.__lock = False
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
65 server.Session.__init__(self, *args, **kwargs)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
66
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
67 def lock(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
68 """Prevent session from expiring"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
69 self.__lock = True
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
70 self._expireCall.reset(sys.maxint)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
71
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
72 def unlock(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
73 """Allow session to expire again, and touch it"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
74 self.__lock = False
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
75 self.touch()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
76
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
77 def touch(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
78 if not self.__lock:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
79 server.Session.touch(self)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
80
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
81 class ProtectedFile(File):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
82 """A File class which doens't show directory listing"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
83
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
84 def directoryListing(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
85 return NoResource()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
86
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
87 class SATActionIDHandler(object):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
88 """Manage SàT action action_id lifecycle"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
89 ID_LIFETIME = 30 #after this time (in seconds), action_id will be suppressed and action result will be ignored
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
90
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
91 def __init__(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
92 self.waiting_ids = {}
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
93
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
94 def waitForId(self, callback, action_id, profile, *args, **kwargs):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
95 """Wait for an action result
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
96 @param callback: method to call when action gave a result back
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
97 @param action_id: action_id to wait for
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
98 @param profile: %(doc_profile)s
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
99 @param *args: additional argument to pass to callback
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
100 @param **kwargs: idem"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
101 action_tuple = (action_id, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
102 self.waiting_ids[action_tuple] = (callback, args, kwargs)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
103 reactor.callLater(self.ID_LIFETIME, self.purgeID, action_tuple)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
104
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
105 def purgeID(self, action_tuple):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
106 """Called when an action_id has not be handled in time"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
107 if action_tuple in self.waiting_ids:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
108 warning ("action of action_id %s [%s] has not been managed, action_id is now ignored" % action_tuple)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
109 del self.waiting_ids[action_tuple]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
110
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
111 def actionResultCb(self, answer_type, action_id, data, profile):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
112 """Manage the actionResult signal"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
113 action_tuple = (action_id, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
114 if action_tuple in self.waiting_ids:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
115 callback, args, kwargs = self.waiting_ids[action_tuple]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
116 del self.waiting_ids[action_tuple]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
117 callback(answer_type, action_id, data, *args, **kwargs)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
118
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
119 class JSONRPCMethodManager(jsonrpc.JSONRPC):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
120
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
121 def __init__(self, sat_host):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
122 jsonrpc.JSONRPC.__init__(self)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
123 self.sat_host=sat_host
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
124
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
125 def asyncBridgeCall(self, method_name, *args, **kwargs):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
126 """Call an asynchrone bridge method and return a deferred
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
127 @param method_name: name of the method as a unicode
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
128 @return: a deferred which trigger the result
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
129
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
130 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
131 d = defer.Deferred()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
132
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
133 def _callback(*args):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
134 if not args:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
135 d.callback(None)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
136 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
137 if len(args) != 1:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
138 Exception("Multiple return arguments not supported")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
139 d.callback(args[0])
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
140
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
141 def _errback(result):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
142 d.errback(Failure(jsonrpclib.Fault(Const.ERRNUM_BRIDGE_ERRBACK, unicode(result))))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
143
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
144 kwargs["callback"] = _callback
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
145 kwargs["errback"] = _errback
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
146 getattr(self.sat_host.bridge, method_name)(*args, **kwargs)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
147 return d
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
148
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
149
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
150 class MethodHandler(JSONRPCMethodManager):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
151
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
152 def __init__(self, sat_host):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
153 JSONRPCMethodManager.__init__(self, sat_host)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
154 self.authorized_params = None
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
155
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
156 def render(self, request):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
157 self.session = request.getSession()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
158 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
159 if not profile:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
160 #user is not identified, we return a jsonrpc fault
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
161 parsed = jsonrpclib.loads(request.content.read())
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
162 fault = jsonrpclib.Fault(Const.ERRNUM_LIBERVIA, "Not allowed") #FIXME: define some standard error codes for libervia
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
163 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc'))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
164 return jsonrpc.JSONRPC.render(self, request)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
165
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
166 def jsonrpc_getProfileJid(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
167 """Return the jid of the profile"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
168 sat_session = ISATSession(self.session)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
169 profile = sat_session.profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
170 sat_session.jid = JID(self.sat_host.bridge.getParamA("JabberID", "Connection", profile_key=profile))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
171 return sat_session.jid.full()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
172
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
173 def jsonrpc_disconnect(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
174 """Disconnect the profile"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
175 sat_session = ISATSession(self.session)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
176 profile = sat_session.profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
177 self.sat_host.bridge.disconnect(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
178
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
179 def jsonrpc_getContacts(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
180 """Return all passed args."""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
181 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
182 return self.sat_host.bridge.getContacts(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
183
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
184 def jsonrpc_addContact(self, entity, name, groups):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
185 """Subscribe to contact presence, and add it to the given groups"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
186 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
187 self.sat_host.bridge.addContact(entity, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
188 self.sat_host.bridge.updateContact(entity, name, groups, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
189
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
190 def jsonrpc_delContact(self, entity):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
191 """Remove contact from contacts list"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
192 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
193 self.sat_host.bridge.delContact(entity, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
194
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
195 def jsonrpc_updateContact(self, entity, name, groups):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
196 """Update contact's roster item"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
197 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
198 self.sat_host.bridge.updateContact(entity, name, groups, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
199
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
200 def jsonrpc_subscription(self, sub_type, entity, name, groups):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
201 """Confirm (or infirm) subscription,
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
202 and setup user roster in case of subscription"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
203 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
204 self.sat_host.bridge.subscription(sub_type, entity, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
205 if sub_type == 'subscribed':
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
206 self.sat_host.bridge.updateContact(entity, name, groups, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
207
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
208 def jsonrpc_getWaitingSub(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
209 """Return list of room already joined by user"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
210 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
211 return self.sat_host.bridge.getWaitingSub(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
212
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
213 def jsonrpc_setStatus(self, presence, status):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
214 """Change the presence and/or status
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
215 @param presence: value from ("", "chat", "away", "dnd", "xa")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
216 @param status: any string to describe your status
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
217 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
218 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
219 self.sat_host.bridge.setPresence('', presence, 0, {'': status}, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
220
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
221
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
222 def jsonrpc_sendMessage(self, to_jid, msg, subject, type_, options={}):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
223 """send message"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
224 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
225 return self.asyncBridgeCall("sendMessage", to_jid, msg, subject, type_, options, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
226
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
227 def jsonrpc_sendMblog(self, type_, dest, text, extra={}):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
228 """ Send microblog message
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
229 @param type_: one of "PUBLIC", "GROUP"
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
230 @param dest: destinees (list of groups, ignored for "PUBLIC")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
231 @param text: microblog's text
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
232 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
233 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
234 extra['allow_comments'] = 'True'
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
235
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
236 if not type_: # auto-detect
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
237 type_ = "PUBLIC" if dest == [] else "GROUP"
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
238
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
239 if type_ in ("PUBLIC", "GROUP") and text:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
240 if type_ == "PUBLIC":
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
241 #This text if for the public microblog
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
242 print "sending public blog"
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
243 return self.sat_host.bridge.sendGroupBlog("PUBLIC", [], text, extra, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
244 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
245 print "sending group blog"
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
246 return self.sat_host.bridge.sendGroupBlog("GROUP", [dest], text, extra, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
247 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
248 raise Exception("Invalid data")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
249
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
250 def jsonrpc_deleteMblog(self, pub_data, comments):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
251 """Delete a microblog node
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
252 @param pub_data: a tuple (service, comment node identifier, item identifier)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
253 @param comments: comments node identifier (for main item) or False
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
254 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
255 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
256 return self.sat_host.bridge.deleteGroupBlog(pub_data, comments if comments else '', profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
257
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
258 def jsonrpc_updateMblog(self, pub_data, comments, message, extra={}):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
259 """Modify a microblog node
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
260 @param pub_data: a tuple (service, comment node identifier, item identifier)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
261 @param comments: comments node identifier (for main item) or False
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
262 @param message: new message
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
263 @param extra: dict which option name as key, which can be:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
264 - allow_comments: True to accept an other level of comments, False else (default: False)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
265 - rich: if present, contain rich text in currently selected syntax
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
266 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
267 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
268 if comments:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
269 extra['allow_comments'] = 'True'
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
270 return self.sat_host.bridge.updateGroupBlog(pub_data, comments if comments else '', message, extra, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
271
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
272 def jsonrpc_sendMblogComment(self, node, text, extra={}):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
273 """ Send microblog message
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
274 @param node: url of the comments node
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
275 @param text: comment
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
276 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
277 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
278 if node and text:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
279 return self.sat_host.bridge.sendGroupBlogComment(node, text, extra, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
280 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
281 raise Exception("Invalid data")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
282
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
283 def jsonrpc_getLastMblogs(self, publisher_jid, max_item):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
284 """Get last microblogs posted by a contact
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
285 @param publisher_jid: jid of the publisher
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
286 @param max_item: number of items to ask
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
287 @return list of microblog data (dict)"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
288 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
289 d = self.asyncBridgeCall("getLastGroupBlogs", publisher_jid, max_item, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
290 return d
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
291
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
292 def jsonrpc_getMassiveLastMblogs(self, publishers_type, publishers_list, max_item):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
293 """Get lasts microblogs posted by several contacts at once
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
294 @param publishers_type: one of "ALL", "GROUP", "JID"
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
295 @param publishers_list: list of publishers type (empty list of all, list of groups or list of jids)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
296 @param max_item: number of items to ask
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
297 @return: dictionary key=publisher's jid, value=list of microblog data (dict)"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
298 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
299 d = self.asyncBridgeCall("getMassiveLastGroupBlogs", publishers_type, publishers_list, max_item, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
300 self.sat_host.bridge.massiveSubscribeGroupBlogs(publishers_type, publishers_list, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
301 return d
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
302
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
303 def jsonrpc_getMblogComments(self, service, node):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
304 """Get all comments of given node
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
305 @param service: jid of the service hosting the node
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
306 @param node: comments node
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
307 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
308 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
309 d = self.asyncBridgeCall("getGroupBlogComments", service, node, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
310 return d
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
311
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
312
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
313 def jsonrpc_getPresenceStatus(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
314 """Get Presence information for connected contacts"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
315 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
316 return self.sat_host.bridge.getPresenceStatus(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
317
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
318 def jsonrpc_getHistory(self, from_jid, to_jid, size, between):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
319 """Return history for the from_jid/to_jid couple"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
320 sat_session = ISATSession(self.session)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
321 profile = sat_session.profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
322 sat_jid = sat_session.jid
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
323 if not sat_jid:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
324 error("No jid saved for this profile")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
325 return {}
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
326 if JID(from_jid).userhost() != sat_jid.userhost() and JID(to_jid).userhost() != sat_jid.userhost():
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
327 error("Trying to get history from a different jid, maybe a hack attempt ?")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
328 return {}
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
329 d = self.asyncBridgeCall("getHistory", from_jid, to_jid, size, between, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
330 def show(result_dbus):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
331 result = []
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
332 for line in result_dbus:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
333 #XXX: we have to do this stupid thing because Python D-Bus use its own types instead of standard types
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
334 # and txJsonRPC doesn't accept D-Bus types, resulting in a empty query
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
335 timestamp, from_jid, to_jid, message, mess_type, extra = line
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
336 result.append((float(timestamp), unicode(from_jid), unicode(to_jid), unicode(message), unicode(mess_type), dict(extra)))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
337 return result
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
338 d.addCallback(show)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
339 return d
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
340
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
341 def jsonrpc_joinMUC(self, room_jid, nick):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
342 """Join a Multi-User Chat room
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
343 @room_jid: leave empty string to generate a unique name
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
344 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
345 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
346 try:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
347 if room_jid != "":
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
348 room_jid = JID(room_jid).userhost()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
349 except:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
350 warning('Invalid room jid')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
351 return
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
352 d = self.asyncBridgeCall("joinMUC", room_jid, nick, {}, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
353 return d
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
354
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
355 def jsonrpc_inviteMUC(self, contact_jid, room_jid):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
356 """Invite a user to a Multi-User Chat room"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
357 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
358 try:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
359 room_jid = JID(room_jid).userhost()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
360 except:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
361 warning('Invalid room jid')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
362 return
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
363 room_id = room_jid.split("@")[0]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
364 service = room_jid.split("@")[1]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
365 self.sat_host.bridge.inviteMUC(contact_jid, service, room_id, {}, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
366
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
367 def jsonrpc_mucLeave(self, room_jid):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
368 """Quit a Multi-User Chat room"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
369 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
370 try:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
371 room_jid = JID(room_jid)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
372 except:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
373 warning('Invalid room jid')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
374 return
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
375 self.sat_host.bridge.mucLeave(room_jid.userhost(), profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
376
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
377 def jsonrpc_getRoomsJoined(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
378 """Return list of room already joined by user"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
379 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
380 return self.sat_host.bridge.getRoomsJoined(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
381
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
382 def jsonrpc_launchTarotGame(self, other_players, room_jid=""):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
383 """Create a room, invite the other players and start a Tarot game
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
384 @param room_jid: leave empty string to generate a unique room name
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
385 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
386 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
387 try:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
388 if room_jid != "":
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
389 room_jid = JID(room_jid).userhost()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
390 except:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
391 warning('Invalid room jid')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
392 return
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
393 self.sat_host.bridge.tarotGameLaunch(other_players, room_jid, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
394
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
395 def jsonrpc_getTarotCardsPaths(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
396 """Give the path of all the tarot cards"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
397 _join = os.path.join
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
398 _media_dir = _join(self.sat_host.media_dir,'')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
399 return map(lambda x: _join(Const.MEDIA_DIR, x[len(_media_dir):]), glob.glob(_join(_media_dir, Const.CARDS_DIR, '*_*.png')));
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
400
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
401 def jsonrpc_tarotGameReady(self, player, referee):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
402 """Tell to the server that we are ready to start the game"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
403 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
404 self.sat_host.bridge.tarotGameReady(player, referee, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
405
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
406 def jsonrpc_tarotGameContratChoosed(self, player_nick, referee, contrat):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
407 """Tell to the server that we are ready to start the game"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
408 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
409 self.sat_host.bridge.tarotGameContratChoosed(player_nick, referee, contrat, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
410
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
411 def jsonrpc_tarotGamePlayCards(self, player_nick, referee, cards):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
412 """Tell to the server the cards we want to put on the table"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
413 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
414 self.sat_host.bridge.tarotGamePlayCards(player_nick, referee, cards, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
415
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
416 def jsonrpc_launchRadioCollective(self, invited, room_jid=""):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
417 """Create a room, invite people, and start a radio collective
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
418 @param room_jid: leave empty string to generate a unique room name
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
419 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
420 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
421 try:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
422 if room_jid != "":
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
423 room_jid = JID(room_jid).userhost()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
424 except:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
425 warning('Invalid room jid')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
426 return
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
427 self.sat_host.bridge.radiocolLaunch(invited, room_jid, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
428
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
429 def jsonrpc_getEntityData(self, jid, keys):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
430 """Get cached data for an entit
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
431 @param jid: jid of contact from who we want data
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
432 @param keys: name of data we want (list)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
433 @return: requested data"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
434 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
435 return self.sat_host.bridge.getEntityData(jid, keys, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
436
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
437 def jsonrpc_getCard(self, jid):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
438 """Get VCard for entiry
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
439 @param jid: jid of contact from who we want data
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
440 @return: id to retrieve the profile"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
441 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
442 return self.sat_host.bridge.getCard(jid, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
443
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
444 def jsonrpc_getParamsUI(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
445 """Return the parameters XML for profile"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
446 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
447 d = self.asyncBridgeCall("getParams", Const.SECURITY_LIMIT, Const.APP_NAME, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
448
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
449 def setAuthorizedParams(d):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
450 if self.authorized_params is None:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
451 self.authorized_params = {}
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
452 for cat in minidom.parseString(d.encode('utf-8')).getElementsByTagName("category"):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
453 params = cat.getElementsByTagName("param")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
454 params_list = [param.getAttribute("name") for param in params]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
455 self.authorized_params[cat.getAttribute("name")] = params_list
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
456 if self.authorized_params:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
457 return d
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
458 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
459 return None
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
460
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
461 d.addCallback(setAuthorizedParams)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
462
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
463 from sat.tools.xml_tools import paramsXml2xmlUI
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
464 d.addCallback(lambda d: paramsXml2xmlUI(d) if d else "")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
465
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
466 return d
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
467
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
468 def jsonrpc_asyncGetParamA(self, param, category, attribute="value"):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
469 """Return the parameter value for profile"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
470 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
471 d = self.asyncBridgeCall("asyncGetParamA", param, category, attribute, Const.SECURITY_LIMIT, profile_key=profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
472 return d
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
473
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
474 def jsonrpc_setParam(self, name, value, category):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
475 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
476 if category in self.authorized_params and name in self.authorized_params[category]:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
477 return self.sat_host.bridge.setParam(name, value, category, Const.SECURITY_LIMIT, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
478 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
479 warning("Trying to set parameter '%s' in category '%s' without authorization!!!"
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
480 % (name, category))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
481
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
482 def jsonrpc_launchAction(self, callback_id, data):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
483 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
484 d = self.asyncBridgeCall("launchAction", callback_id, data, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
485 return d
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
486
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
487 def jsonrpc_chatStateComposing(self, to_jid_s):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
488 """Call the method to process a "composing" state.
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
489 @param to_jid_s: contact the user is composing to
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
490 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
491 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
492 self.sat_host.bridge.chatStateComposing(to_jid_s, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
493
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
494 def jsonrpc_getNewAccountDomain(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
495 """@return: the domain for new account creation"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
496 d = self.asyncBridgeCall("getNewAccountDomain")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
497 return d
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
498
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
499 def jsonrpc_confirmationAnswer(self, confirmation_id, result, answer_data):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
500 """Send the user's answer to any previous 'askConfirmation' signal"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
501 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
502 self.sat_host.bridge.confirmationAnswer(confirmation_id, result, answer_data, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
503
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
504 def jsonrpc_syntaxConvert(self, text, syntax_from=Const.SYNTAX_XHTML, syntax_to=Const.SYNTAX_CURRENT):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
505 """ Convert a text between two syntaxes
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
506 @param text: text to convert
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
507 @param syntax_from: source syntax (e.g. "markdown")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
508 @param syntax_to: dest syntax (e.g.: "XHTML")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
509 @param safe: clean resulting XHTML to avoid malicious code if True (forced here)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
510 @return: converted text """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
511 profile = ISATSession(self.session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
512 return self.sat_host.bridge.syntaxConvert(text, syntax_from, syntax_to, True, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
513
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
514
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
515 class Register(JSONRPCMethodManager):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
516 """This class manage the registration procedure with SàT
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
517 It provide an api for the browser, check password and setup the web server"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
518
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
519 def __init__(self, sat_host):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
520 JSONRPCMethodManager.__init__(self, sat_host)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
521 self.profiles_waiting={}
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
522 self.request=None
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
523
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
524 def getWaitingRequest(self, profile):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
525 """Tell if a profile is trying to log in"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
526 if self.profiles_waiting.has_key(profile):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
527 return self.profiles_waiting[profile]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
528 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
529 return None
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
530
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
531 def render(self, request):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
532 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
533 Render method with some hacks:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
534 - if login is requested, try to login with form data
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
535 - except login, every method is jsonrpc
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
536 - user doesn't need to be authentified for isRegistered or registerParams, but must be for all other methods
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
537 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
538 if request.postpath==['login']:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
539 return self.login(request)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
540 _session = request.getSession()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
541 parsed = jsonrpclib.loads(request.content.read())
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
542 method = parsed.get("method")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
543 if method != "isRegistered" and method != "registerParams":
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
544 #if we don't call login or isRegistered, we need to be identified
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
545 profile = ISATSession(_session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
546 if not profile:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
547 #user is not identified, we return a jsonrpc fault
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
548 fault = jsonrpclib.Fault(Const.ERRNUM_LIBERVIA, "Not allowed") #FIXME: define some standard error codes for libervia
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
549 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc'))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
550 self.request = request
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
551 return jsonrpc.JSONRPC.render(self, request)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
552
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
553 def login(self, request):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
554 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
555 this method is called with the POST information from the registering form
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
556 it test if the password is ok, and log in if it's the case,
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
557 else it return an error
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
558 @param request: request of the register formulaire, must have "login" and "password" as arguments
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
559 @return: A constant indicating the state:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
560 - BAD REQUEST: something is wrong in the request (bad arguments, profile_key for login)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
561 - AUTH ERROR: either the profile or the password is wrong
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
562 - ALREADY WAITING: a request has already be made for this profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
563 - server.NOT_DONE_YET: the profile is being processed, the return value will be given by self._logged or self._logginError
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
564 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
565
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
566 try:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
567 if request.args['submit_type'][0] == 'login':
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
568 _login = request.args['login'][0]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
569 if _login.startswith('@'):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
570 raise Exception('No profile_key allowed')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
571 _pass = request.args['login_password'][0]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
572
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
573 elif request.args['submit_type'][0] == 'register':
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
574 return self._registerNewAccount(request)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
575
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
576 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
577 raise Exception('Unknown submit type')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
578 except KeyError:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
579 return "BAD REQUEST"
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
580
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
581 _profile_check = self.sat_host.bridge.getProfileName(_login)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
582
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
583 def profile_pass_cb(_profile_pass):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
584 if not _profile_check or _profile_check != _login or _profile_pass != _pass:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
585 request.write("AUTH ERROR")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
586 request.finish()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
587 return
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
588
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
589 if self.profiles_waiting.has_key(_login):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
590 request.write("ALREADY WAITING")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
591 request.finish()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
592 return
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
593
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
594 if self.sat_host.bridge.isConnected(_login):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
595 request.write(self._logged(_login, request, finish=False))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
596 request.finish()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
597 return
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
598
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
599 self.profiles_waiting[_login] = request
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
600 d = self.asyncBridgeCall("asyncConnect", _login)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
601 return d
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
602
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
603 def profile_pass_errback(ignore):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
604 error("INTERNAL ERROR: can't check profile password")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
605 request.write("AUTH ERROR")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
606 request.finish()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
607
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
608 d = self.asyncBridgeCall("asyncGetParamA", "Password", "Connection", profile_key=_login)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
609 d.addCallbacks(profile_pass_cb, profile_pass_errback)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
610
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
611 return server.NOT_DONE_YET
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
612
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
613 def _postAccountCreation(self, answer_type, id, data, profile):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
614 """Called when a account has just been created,
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
615 setup stuff has microblog access"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
616 def _connected(ignore):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
617 mblog_d = self.asyncBridgeCall("setMicroblogAccess", "open", profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
618 mblog_d.addBoth(lambda ignore: self.sat_host.bridge.disconnect(profile))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
619
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
620 d = self.asyncBridgeCall("asyncConnect", profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
621 d.addCallback(_connected)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
622
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
623 def _registerNewAccount(self, request):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
624 """Create a new account, or return error
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
625 @param request: initial login request
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
626 @return: "REGISTRATION" in case of success"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
627 #TODO: must be moved in SàT core
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
628
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
629 try:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
630 profile = login = request.args['register_login'][0]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
631 password = request.args['register_password'][0] #FIXME: password is ignored so far
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
632 email = request.args['email'][0]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
633 except KeyError:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
634 return "BAD REQUEST"
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
635 if not re.match(r'^[a-z0-9_-]+$', login, re.IGNORECASE) or \
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
636 not re.match(r'^.+@.+\..+', email, re.IGNORECASE):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
637 return "BAD REQUEST"
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
638
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
639 def registered(result):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
640 request.write('REGISTRATION')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
641 request.finish()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
642
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
643 def registeringError(failure):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
644 reason = str(failure.value)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
645 if reason == "ConflictError":
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
646 request.write('ALREADY EXISTS')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
647 elif reason == "InternalError":
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
648 request.write('INTERNAL')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
649 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
650 error('Unknown registering error: %s' % (reason,))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
651 request.write('Unknown error (%s)' % reason)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
652 request.finish()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
653
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
654 d = self.asyncBridgeCall("registerSatAccount", email, password, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
655 d.addCallback(registered)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
656 d.addErrback(registeringError)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
657 return server.NOT_DONE_YET
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
658
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
659 def __cleanWaiting(self, login):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
660 """Remove login from waiting queue"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
661 try:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
662 del self.profiles_waiting[login]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
663 except KeyError:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
664 pass
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
665
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
666 def _logged(self, profile, request, finish=True):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
667 """Set everything when a user just logged
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
668 and return "LOGGED" to the requester"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
669 def result(answer):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
670 if finish:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
671 request.write(answer)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
672 request.finish()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
673 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
674 return answer
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
675
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
676 self.__cleanWaiting(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
677 _session = request.getSession()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
678 sat_session = ISATSession(_session)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
679 if sat_session.profile:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
680 error (('/!\\ Session has already a profile, this should NEVER happen !'))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
681 return result('SESSION_ACTIVE')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
682 sat_session.profile = profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
683 self.sat_host.prof_connected.add(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
684
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
685 def onExpire():
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
686 info ("Session expired (profile=%s)" % (profile,))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
687 try:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
688 #We purge the queue
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
689 del self.sat_host.signal_handler.queue[profile]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
690 except KeyError:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
691 pass
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
692 #and now we disconnect the profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
693 self.sat_host.bridge.disconnect(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
694
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
695 _session.notifyOnExpire(onExpire)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
696
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
697 d = defer.Deferred()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
698 return result('LOGGED')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
699
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
700 def _logginError(self, login, request, error_type):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
701 """Something went wrong during loggin, return an error"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
702 self.__cleanWaiting(login)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
703 return error_type
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
704
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
705 def jsonrpc_isConnected(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
706 _session = self.request.getSession()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
707 profile = ISATSession(_session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
708 return self.sat_host.bridge.isConnected(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
709
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
710 def jsonrpc_connect(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
711 _session = self.request.getSession()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
712 profile = ISATSession(_session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
713 if self.profiles_waiting.has_key(profile):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
714 raise jsonrpclib.Fault(1,'Already waiting') #FIXME: define some standard error codes for libervia
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
715 self.profiles_waiting[profile] = self.request
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
716 self.sat_host.bridge.connect(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
717 return server.NOT_DONE_YET
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
718
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
719 def jsonrpc_isRegistered(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
720 """Tell if the user is already registered"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
721 _session = self.request.getSession()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
722 profile = ISATSession(_session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
723 return bool(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
724
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
725 def jsonrpc_registerParams(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
726 """Register the frontend specific parameters"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
727 params = """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
728 <params>
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
729 <individual>
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
730 <category name="%(category_name)s" label="%(category_label)s">
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
731 <param name="%(param_name)s" label="%(param_label)s" value="false" type="bool" security="0"/>
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
732 </category>
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
733 </individual>
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
734 </params>
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
735 """ % {
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
736 'category_name': Const.ENABLE_UNIBOX_KEY,
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
737 'category_label': _(Const.ENABLE_UNIBOX_KEY),
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
738 'param_name': Const.ENABLE_UNIBOX_PARAM,
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
739 'param_label': _(Const.ENABLE_UNIBOX_PARAM)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
740 }
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
741
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
742 self.sat_host.bridge.paramsRegisterApp(params, Const.SECURITY_LIMIT, Const.APP_NAME)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
743
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
744
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
745 class SignalHandler(jsonrpc.JSONRPC):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
746
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
747 def __init__(self, sat_host):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
748 Resource.__init__(self)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
749 self.register=None
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
750 self.sat_host=sat_host
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
751 self.signalDeferred = {}
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
752 self.queue = {}
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
753
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
754 def plugRegister(self, register):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
755 self.register = register
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
756
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
757 def jsonrpc_getSignals(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
758 """Keep the connection alive until a signal is received, then send it
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
759 @return: (signal, *signal_args)"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
760 _session = self.request.getSession()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
761 profile = ISATSession(_session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
762 if profile in self.queue: #if we have signals to send in queue
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
763 if self.queue[profile]:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
764 return self.queue[profile].pop(0)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
765 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
766 #the queue is empty, we delete the profile from queue
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
767 del self.queue[profile]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
768 _session.lock() #we don't want the session to expire as long as this connection is active
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
769 def unlock(signal, profile):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
770 _session.unlock()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
771 try:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
772 source_defer = self.signalDeferred[profile]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
773 if source_defer.called and source_defer.result[0] == "disconnected":
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
774 info(u"[%s] disconnected" % (profile,))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
775 _session.expire()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
776 except IndexError:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
777 error("Deferred result should be a tuple with fonction name first")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
778
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
779 self.signalDeferred[profile] = defer.Deferred()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
780 self.request.notifyFinish().addBoth(unlock, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
781 return self.signalDeferred[profile]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
782
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
783 def getGenericCb(self, function_name):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
784 """Return a generic function which send all params to signalDeferred.callback
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
785 function must have profile as last argument"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
786 def genericCb(*args):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
787 profile = args[-1]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
788 if not profile in self.sat_host.prof_connected:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
789 return
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
790 if profile in self.signalDeferred:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
791 self.signalDeferred[profile].callback((function_name,args[:-1]))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
792 del self.signalDeferred[profile]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
793 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
794 if not self.queue.has_key(profile):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
795 self.queue[profile] = []
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
796 self.queue[profile].append((function_name, args[:-1]))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
797 return genericCb
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
798
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
799 def connected(self, profile):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
800 assert(self.register) #register must be plugged
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
801 request = self.register.getWaitingRequest(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
802 if request:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
803 self.register._logged(profile, request)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
804
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
805 def disconnected(self, profile):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
806 if not profile in self.sat_host.prof_connected:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
807 error("'disconnected' signal received for a not connected profile")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
808 return
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
809 self.sat_host.prof_connected.remove(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
810 if profile in self.signalDeferred:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
811 self.signalDeferred[profile].callback(("disconnected",))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
812 del self.signalDeferred[profile]
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
813 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
814 if not self.queue.has_key(profile):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
815 self.queue[profile] = []
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
816 self.queue[profile].append(("disconnected",))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
817
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
818
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
819 def connectionError(self, error_type, profile):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
820 assert(self.register) #register must be plugged
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
821 request = self.register.getWaitingRequest(profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
822 if request: #The user is trying to log in
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
823 if error_type == "AUTH_ERROR":
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
824 _error_t = "AUTH ERROR"
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
825 else:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
826 _error_t = "UNKNOWN"
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
827 self.register._logginError(profile, request, _error_t)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
828
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
829 def render(self, request):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
830 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
831 Render method wich reject access if user is not identified
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
832 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
833 _session = request.getSession()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
834 parsed = jsonrpclib.loads(request.content.read())
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
835 profile = ISATSession(_session).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
836 if not profile:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
837 #user is not identified, we return a jsonrpc fault
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
838 fault = jsonrpclib.Fault(Const.ERRNUM_LIBERVIA, "Not allowed") #FIXME: define some standard error codes for libervia
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
839 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc'))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
840 self.request = request
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
841 return jsonrpc.JSONRPC.render(self, request)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
842
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
843 class UploadManager(Resource):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
844 """This class manage the upload of a file
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
845 It redirect the stream to SàT core backend"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
846 isLeaf = True
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
847 NAME = 'path' #name use by the FileUpload
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
848
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
849 def __init__(self, sat_host):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
850 self.sat_host=sat_host
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
851 self.upload_dir = tempfile.mkdtemp()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
852 self.sat_host.addCleanup(shutil.rmtree, self.upload_dir)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
853
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
854 def getTmpDir(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
855 return self.upload_dir
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
856
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
857 def _getFileName(self, request):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
858 """Generate unique filename for a file"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
859 raise NotImplementedError
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
860
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
861 def _fileWritten(self, request, filepath):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
862 """Called once the file is actually written on disk
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
863 @param request: HTTP request object
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
864 @param filepath: full filepath on the server
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
865 @return: a tuple with the name of the async bridge method
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
866 to be called followed by its arguments.
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
867 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
868 raise NotImplementedError
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
869
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
870 def render(self, request):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
871 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
872 Render method with some hacks:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
873 - if login is requested, try to login with form data
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
874 - except login, every method is jsonrpc
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
875 - user doesn't need to be authentified for isRegistered, but must be for all other methods
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
876 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
877 filename = self._getFileName(request)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
878 filepath = os.path.join(self.upload_dir, filename)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
879 #FIXME: the uploaded file is fully loaded in memory at form parsing time so far
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
880 # (see twisted.web.http.Request.requestReceived). A custom requestReceived should
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
881 # be written in the futur. In addition, it is not yet possible to get progression informations
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
882 # (see http://twistedmatrix.com/trac/ticket/288)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
883
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
884 with open(filepath,'w') as f:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
885 f.write(request.args[self.NAME][0])
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
886
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
887 def finish(d):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
888 error = isinstance(d, Exception) or isinstance (d, Failure)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
889 request.write('KO' if error else 'OK')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
890 # TODO: would be great to re-use the original Exception class and message
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
891 # but it is lost in the middle of the backtrace and encapsulated within
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
892 # a DBusException instance --> extract the data from the backtrace?
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
893 request.finish()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
894
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
895 d = JSONRPCMethodManager(self.sat_host).asyncBridgeCall(*self._fileWritten(request, filepath))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
896 d.addCallbacks(lambda d: finish(d), lambda failure: finish(failure))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
897 return server.NOT_DONE_YET
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
898
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
899
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
900 class UploadManagerRadioCol(UploadManager):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
901 NAME = 'song'
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
902
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
903 def _getFileName(self, request):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
904 return "%s.ogg" % str(uuid.uuid4()) #XXX: chromium doesn't seem to play song without the .ogg extension, even with audio/ogg mime-type
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
905
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
906 def _fileWritten(self, request, filepath):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
907 """Called once the file is actually written on disk
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
908 @param request: HTTP request object
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
909 @param filepath: full filepath on the server
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
910 @return: a tuple with the name of the async bridge method
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
911 to be called followed by its arguments.
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
912 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
913 profile = ISATSession(request.getSession()).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
914 return ("radiocolSongAdded", request.args['referee'][0], filepath, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
915
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
916
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
917 class UploadManagerAvatar(UploadManager):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
918 NAME = 'avatar_path'
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
919
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
920 def _getFileName(self, request):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
921 return str(uuid.uuid4())
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
922
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
923 def _fileWritten(self, request, filepath):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
924 """Called once the file is actually written on disk
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
925 @param request: HTTP request object
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
926 @param filepath: full filepath on the server
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
927 @return: a tuple with the name of the async bridge method
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
928 to be called followed by its arguments.
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
929 """
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
930 profile = ISATSession(request.getSession()).profile
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
931 return ("setAvatar", filepath, profile)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
932
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
933
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
934 class Libervia(service.Service):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
935
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
936 def __init__(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
937 self._cleanup = []
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
938 root = ProtectedFile(Const.LIBERVIA_DIR)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
939 self.signal_handler = SignalHandler(self)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
940 _register = Register(self)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
941 _upload_radiocol = UploadManagerRadioCol(self)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
942 _upload_avatar = UploadManagerAvatar(self)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
943 self.signal_handler.plugRegister(_register)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
944 self.sessions = {} #key = session value = user
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
945 self.prof_connected = set() #Profiles connected
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
946 self.action_handler = SATActionIDHandler()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
947 ## bridge ##
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
948 try:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
949 self.bridge=DBusBridgeFrontend()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
950 except BridgeExceptionNoService:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
951 print(u"Can't connect to SàT backend, are you sure it's launched ?")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
952 sys.exit(1)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
953 self.bridge.register("connected", self.signal_handler.connected)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
954 self.bridge.register("disconnected", self.signal_handler.disconnected)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
955 self.bridge.register("connectionError", self.signal_handler.connectionError)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
956 self.bridge.register("actionResult", self.action_handler.actionResultCb)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
957 #core
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
958 for signal_name in ['presenceUpdate', 'newMessage', 'subscribe', 'contactDeleted', 'newContact', 'entityDataUpdated', 'askConfirmation', 'newAlert', 'paramUpdate']:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
959 self.bridge.register(signal_name, self.signal_handler.getGenericCb(signal_name))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
960 #plugins
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
961 for signal_name in ['personalEvent', 'roomJoined', 'roomUserJoined', 'roomUserLeft', 'tarotGameStarted', 'tarotGameNew', 'tarotGameChooseContrat',
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
962 'tarotGameShowCards', 'tarotGameInvalidCards', 'tarotGameCardsPlayed', 'tarotGameYourTurn', 'tarotGameScore', 'tarotGamePlayers',
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
963 'radiocolStarted', 'radiocolPreload', 'radiocolPlay', 'radiocolNoUpload', 'radiocolUploadOk', 'radiocolSongRejected', 'radiocolPlayers',
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
964 'roomLeft', 'chatStateReceived']:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
965 self.bridge.register(signal_name, self.signal_handler.getGenericCb(signal_name), "plugin")
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
966 self.media_dir = self.bridge.getConfig('','media_dir')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
967 self.local_dir = self.bridge.getConfig('','local_dir')
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
968 root.putChild('', Redirect('libervia.html'))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
969 root.putChild('json_signal_api', self.signal_handler)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
970 root.putChild('json_api', MethodHandler(self))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
971 root.putChild('register_api', _register)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
972 root.putChild('upload_radiocol', _upload_radiocol)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
973 root.putChild('upload_avatar', _upload_avatar)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
974 root.putChild('blog', MicroBlog(self))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
975 root.putChild('css', ProtectedFile("server_css/"))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
976 root.putChild(os.path.dirname(Const.MEDIA_DIR), ProtectedFile(self.media_dir))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
977 root.putChild(os.path.dirname(Const.AVATARS_DIR), ProtectedFile(os.path.join(self.local_dir, Const.AVATARS_DIR)))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
978 root.putChild('radiocol', ProtectedFile(_upload_radiocol.getTmpDir(), defaultType="audio/ogg")) #We cheat for PoC because we know we are on the same host, so we use directly upload dir
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
979 self.site = server.Site(root)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
980 self.site.sessionFactory = LiberviaSession
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
981
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
982 def addCleanup(self, callback, *args, **kwargs):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
983 """Add cleaning method to call when service is stopped
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
984 cleaning method will be called in reverse order of they insertion
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
985 @param callback: callable to call on service stop
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
986 @param *args: list of arguments of the callback
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
987 @param **kwargs: list of keyword arguments of the callback"""
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
988 self._cleanup.insert(0, (callback, args, kwargs))
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
989
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
990 def startService(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
991 reactor.listenTCP(8080, self.site)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
992
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
993 def stopService(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
994 print "launching cleaning methods"
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
995 for callback, args, kwargs in self._cleanup:
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
996 callback(*args, **kwargs)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
997
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
998 def run(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
999 reactor.run()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
1000
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
1001 def stop(self):
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
1002 reactor.stop()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
1003
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
1004 registerAdapter(SATSession, server.Session, ISATSession)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
1005 application = service.Application(Const.APP_NAME)
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
1006 service = Libervia()
e43a1a0b4f23 reverted changeset c144b603fb93 (bug 7)
Goffi <goffi@goffi.org>
parents:
diff changeset
1007 service.setServiceParent(application)