aboutsummaryrefslogtreecommitdiffstats
path: root/mediagoblin/app.py
diff options
context:
space:
mode:
Diffstat (limited to 'mediagoblin/app.py')
-rw-r--r--mediagoblin/app.py37
1 files changed, 26 insertions, 11 deletions
diff --git a/mediagoblin/app.py b/mediagoblin/app.py
index ae6db8f7..59b943dd 100644
--- a/mediagoblin/app.py
+++ b/mediagoblin/app.py
@@ -21,6 +21,8 @@ import mongokit
from webob import Request, exc
from mediagoblin import routing, util, models, storage, staticdirect
+from mediagoblin.globals import setup_globals
+from mediagoblin.celery_setup import setup_celery_from_config
class Error(Exception): pass
@@ -53,6 +55,15 @@ class MediaGoblinApp(object):
# set up staticdirector tool
self.staticdirector = staticdirector
+ # certain properties need to be accessed globally eg from
+ # validators, etc, which might not access to the request
+ # object.
+ setup_globals(
+ db_connection=connection,
+ database=self.db,
+ public_store=self.public_store,
+ queue_store=self.queue_store)
+
def __call__(self, environ, start_response):
request = Request(environ)
path_info = request.path_info
@@ -71,7 +82,7 @@ class MediaGoblinApp(object):
if request.GET:
new_path_info = '%s?%s' % (
new_path_info, urllib.urlencode(request.GET))
- redirect = exc.HTTPTemporaryRedirect(location=new_path_info)
+ redirect = exc.HTTPFound(location=new_path_info)
return request.get_response(redirect)(environ, start_response)
# Okay, no matches. 404 time!
@@ -97,33 +108,37 @@ class MediaGoblinApp(object):
return controller(request)(environ, start_response)
-def paste_app_factory(global_config, **kw):
+def paste_app_factory(global_config, **app_config):
# Get the database connection
connection = mongokit.Connection(
- kw.get('db_host'), kw.get('db_port'))
+ app_config.get('db_host'), app_config.get('db_port'))
# Set up the storage systems.
public_store = storage.storage_system_from_paste_config(
- kw, 'publicstore')
+ app_config, 'publicstore')
queue_store = storage.storage_system_from_paste_config(
- kw, 'queuestore')
+ app_config, 'queuestore')
# Set up the staticdirect system
- if kw.has_key('direct_remote_path'):
+ if app_config.has_key('direct_remote_path'):
staticdirector = staticdirect.RemoteStaticDirect(
- kw['direct_remote_path'].strip())
- elif kw.has_key('direct_remote_paths'):
+ app_config['direct_remote_path'].strip())
+ elif app_config.has_key('direct_remote_paths'):
+ direct_remote_path_lines = app_config[
+ 'direct_remote_paths'].strip().splitlines()
staticdirector = staticdirect.MultiRemoteStaticDirect(
dict([line.strip().split(' ', 1)
- for line in kw['direct_remote_paths'].strip().splitlines()]))
+ for line in direct_remote_path_lines]))
else:
raise ImproperlyConfigured(
"One of direct_remote_path or direct_remote_paths must be provided")
+ setup_celery_from_config(app_config, global_config)
+
mgoblin_app = MediaGoblinApp(
- connection, kw.get('db_name', 'mediagoblin'),
+ connection, app_config.get('db_name', 'mediagoblin'),
public_store=public_store, queue_store=queue_store,
staticdirector=staticdirector,
- user_template_path=kw.get('local_templates'))
+ user_template_path=app_config.get('local_templates'))
return mgoblin_app