from __future__ import absolute_import, unicode_literals

import os
import sys
import types

from celery.app.defaults import strtobool
from celery.utils import import_from_cwd

from djcelery.compat import setenv

DEFAULT_APPS = ('django.contrib.auth',
                'django.contrib.contenttypes',
                'django.contrib.sessions',
                'django.contrib.admin',
                'django.contrib.admindocs',
                'djcelery')

DEFAULTS = {'ROOT_URLCONF': 'djcelery.monproj.urls',
            'DATABASE_ENGINE': 'sqlite3',
            'DATABASE_NAME': 'djcelerymon.db',
            'DATABASES': {'default': {
                            'ENGINE': 'django.db.backends.sqlite3',
                            'NAME': 'djcelerymon.db'}},
            'BROKER_URL': 'amqp://',
            'SITE_ID': 1,
            'INSTALLED_APPS': DEFAULT_APPS,
            'DEBUG': strtobool(os.environ.get('DJCELERYMON_DEBUG', '0'))}


def default_settings(name='__default_settings__'):
    c = type(name, (types.ModuleType, ), DEFAULTS)(name)
    c.__dict__.update({'__file__': __file__})
    sys.modules[name] = c
    return name


def configure():
    from celery import current_app
    from celery.loaders.default import DEFAULT_CONFIG_MODULE
    from django.conf import settings

    app = current_app
    conf = {}

    if not settings.configured:
        if 'loader' in app.__dict__ and app.loader.configured:
            conf = current_app.loader.conf
        else:
            os.environ.pop('CELERY_LOADER', None)
            settings_module = os.environ.get('CELERY_CONFIG_MODULE',
                                             DEFAULT_CONFIG_MODULE)
            try:
                import_from_cwd(settings_module)
            except ImportError:
                settings_module = default_settings()
        settings.configure(SETTINGS_MODULE=settings_module,
                           **dict(DEFAULTS, **conf))


def run_monitor(argv):
    from .management.commands import djcelerymon
    djcelerymon.Command().run_from_argv([argv[0], 'djcelerymon'] + argv[1:])


def main(argv=sys.argv):
    from django.core import management
    setenv('CELERY_LOADER', 'default')
    configure()
    management.call_command('syncdb')
    run_monitor(argv)

if __name__ == '__main__':
    main()