libervia-web: libervia.tac comparison

comparison libervia.tac @ 127:e19a8de8b3de

radio collective first draft

author	Goffi <goffi@goffi.org>
date	Sun, 22 Jan 2012 19:38:05 +0100
parents	f9d63624699f
children	2849ec993d89

comparison

equal deleted inserted replaced

-:adecb2566b53
+:e19a8de8b3de
 from txjsonrpc.web import jsonrpc
 from txjsonrpc import jsonrpclib
 from sat_frontends.bridge.DBus import DBusBridgeFrontend,BridgeExceptionNoService
 from email.mime.text import MIMEText
 from logging import debug, info, warning, error
-import re
+import re, glob
-import glob
+import os.path, sys
-import os.path
+import tempfile, shutil, uuid
-import sys
 from server_side.blog import MicroBlog
 from zope.interface import Interface, Attribute, implements
 TIMEOUT = 10 #Session's time out, after that the user will be disconnected
 LIBERVIA_DIR = "output/"
 if request:
 self.register._logged(profile, request)
 def connectionError(self, error_type, profile):
 assert(self.register) #register must be plugged
-import pdb
-pdb.set_trace()
 request = self.register.getWaitingRequest(profile)
 if request: #The user is trying to log in
 if error_type == "AUTH_ERROR":
 _error_t = "AUTH ERROR"
 else:
 fault = jsonrpclib.Fault(0, "Not allowed") #FIXME: define some standard error codes for libervia
 return jsonrpc.JSONRPC._cbRender(self, fault, request, parsed.get('id'), parsed.get('jsonrpc'))
 self.request = request
 return jsonrpc.JSONRPC.render(self, request)
+class UploadManager(Resource):
+"""This class manage the upload of a file
+It redirect the stream to SàT core backend"""
+isLeaf = True
+def __init__(self, sat_host):
+self.sat_host=sat_host
+self.upload_dir = tempfile.mkdtemp()
+self.sat_host.addCleanup(shutil.rmtree, self.upload_dir)
+def render(self, request):
+"""
+Render method with some hacks:
+- if login is requested, try to login with form data
+- except login, every method is jsonrpc
+- user doesn't need to be authentified for isRegistered, but must be for all other methods
+"""
+filename = str(uuid.uuid4())
+with open(os.path.join(self.upload_dir, filename),'w') as f:
+f.write(request.args['song'][0])
+return "OK"
 class Libervia(service.Service):
 def __init__(self):
+self._cleanup = []
 root = ProtectedFile(LIBERVIA_DIR)
 self.signal_handler = SignalHandler(self)
 _register = Register(self)
+_upload = UploadManager(self)
 self.signal_handler.plugRegister(_register)
 self.sessions = {} #key = session value = user
 self.prof_connected = set() #Profiles connected
 self.action_handler = SATActionIDHandler()
 ## bridge ##
 #core
 for signal_name in ['presenceUpdate', 'newMessage', 'subscribe', 'contactDeleted', 'newContact', 'updatedValue']:
 self.bridge.register(signal_name, self.signal_handler.getGenericCb(signal_name))
 #plugins
 for signal_name in ['personalEvent', 'roomJoined', 'roomUserJoined', 'roomUserLeft', 'tarotGameStarted', 'tarotGameNew', 'tarotGameChooseContrat',
-'tarotGameShowCards', 'tarotGameInvalidCards', 'tarotGameCardsPlayed', 'tarotGameYourTurn', 'tarotGameScore']:
+'tarotGameShowCards', 'tarotGameInvalidCards', 'tarotGameCardsPlayed', 'tarotGameYourTurn', 'tarotGameScore',
+'radiocolStarted']:
 self.bridge.register(signal_name, self.signal_handler.getGenericCb(signal_name), "plugin")
 self.media_dir = self.bridge.getConfig('','media_dir')
 self.local_dir = self.bridge.getConfig('','local_dir')
 root.putChild('json_signal_api', self.signal_handler)
 root.putChild('json_api', MethodHandler(self))
 root.putChild('register_api', _register)
+root.putChild('upload', _upload)
 root.putChild('blog', MicroBlog(self))
 root.putChild('css', ProtectedFile("server_css/"))
 root.putChild(os.path.dirname(MEDIA_DIR), ProtectedFile(self.media_dir))
 root.putChild(os.path.dirname(AVATARS_DIR), ProtectedFile(os.path.join(self.local_dir, AVATARS_DIR)))
 self.site = server.Site(root)
 self.site.sessionFactory = LiberviaSession
+def addCleanup(self, callback, *args, **kwargs):
+"""Add cleaning method to call when service is stopped
+cleaning method will be called in reverse order of they insertion
+@param callback: callable to call on service stop
+@param *args: list of arguments of the callback
+@param **kwargs: list of keyword arguments of the callback"""
+self._cleanup.insert(0, (callback, args, kwargs))
 def startService(self):
 reactor.listenTCP(8080, self.site)
+def stopService(self):
+print "launching cleaning methods"
+for callback, args, kwargs in self._cleanup:
+callback(*args, **kwargs)
 def run(self):
 reactor.run()
 def stop(self):

Mercurial > libervia-web

comparison libervia.tac @ 127:e19a8de8b3de