aboutsummaryrefslogtreecommitdiffstats
path: root/mediagoblin/app.py
diff options
context:
space:
mode:
Diffstat (limited to 'mediagoblin/app.py')
-rw-r--r--mediagoblin/app.py19
1 files changed, 7 insertions, 12 deletions
diff --git a/mediagoblin/app.py b/mediagoblin/app.py
index d124558d..640ffc45 100644
--- a/mediagoblin/app.py
+++ b/mediagoblin/app.py
@@ -17,11 +17,11 @@
import urllib
import routes
-import mongokit
-from paste.deploy.converters import asbool, asint
+from paste.deploy.converters import asbool
from webob import Request, exc
-from mediagoblin import routing, util, models, storage, staticdirect
+from mediagoblin import routing, util, storage, staticdirect
+from mediagoblin.db.open import setup_connection_and_db_from_config
from mediagoblin.globals import setup_globals
from mediagoblin.celery_setup import setup_celery_from_config
@@ -34,7 +34,7 @@ class MediaGoblinApp(object):
"""
Really basic wsgi app using routes and WebOb.
"""
- def __init__(self, connection, database_path,
+ def __init__(self, connection, db,
public_store, queue_store,
staticdirector,
email_sender_address, email_debug_mode,
@@ -48,8 +48,7 @@ class MediaGoblinApp(object):
# Set up database
self.connection = connection
- self.db = connection[database_path]
- models.register_models(connection)
+ self.db = db
# set up routing
self.routing = routing.get_mapper()
@@ -117,11 +116,7 @@ class MediaGoblinApp(object):
def paste_app_factory(global_config, **app_config):
# Get the database connection
- port = app_config.get('db_port')
- if port:
- port = asint(port)
- connection = mongokit.Connection(
- app_config.get('db_host'), port)
+ connection, db = setup_connection_and_db_from_config(app_config)
# Set up the storage systems.
public_store = storage.storage_system_from_paste_config(
@@ -146,7 +141,7 @@ def paste_app_factory(global_config, **app_config):
setup_celery_from_config(app_config, global_config)
mgoblin_app = MediaGoblinApp(
- connection, app_config.get('db_name', 'mediagoblin'),
+ connection, db,
public_store=public_store, queue_store=queue_store,
staticdirector=staticdirector,
email_sender_address=app_config.get(