1 # -*- coding: utf-8 -*-
2 # Copyright (c) 2013, 2014 Jack Kaliko <kaliko@azylum.org>
4 # This file is part of sima
6 # sima is free software: you can redistribute it and/or modify
7 # it under the terms of the GNU General Public License as published by
8 # the Free Software Foundation, either version 3 of the License, or
9 # (at your option) any later version.
11 # sima is distributed in the hope that it will be useful,
12 # but WITHOUT ANY WARRANTY; without even the implied warranty of
13 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 # GNU General Public License for more details.
16 # You should have received a copy of the GNU General Public License
17 # along with sima. If not, see <http://www.gnu.org/licenses/>.
23 # standard library import
27 from importlib import __import__
28 from os.path import isfile
31 # third parties components
35 from . import core, info
36 from .lib.logger import set_logger
37 from .lib.simadb import SimaDB
38 from .utils.config import ConfMan
39 from .utils.startopt import StartOpt
40 from .utils.utils import exception_log, SigHup
42 from .plugins.core.history import History
43 from .plugins.core.mpdoptions import MpdOptions
44 from .plugins.core.uniq import Uniq
48 def load_plugins(sima, source):
49 """Handles internal/external plugins
50 sima: sima.core.Sima instance
51 source: ['internal', 'contrib']
53 if not sima.config.get('sima', source):
55 logger = logging.getLogger('sima')
56 for plugin in sima.config.get('sima', source).split(','):
57 plugin = plugin.strip(' \n')
58 module = 'sima.plugins.{0}.{1}'.format(source, plugin.lower())
60 mod_obj = __import__(module, fromlist=[plugin])
61 except ImportError as err:
62 logger.error('Failed to load plugin\'s module: ' +
63 '{0} ({1})'.format(module, err))
67 plugin_obj = getattr(mod_obj, plugin)
68 except AttributeError as err:
69 logger.error('Failed to load plugin {0} ({1})'.format(plugin, err))
72 logger.info('Loading {0} plugin: {name} ({doc})'.format(
73 source, **plugin_obj.info()))
74 sima.register_plugin(plugin_obj)
77 def start(sopt, restart=False):
81 verbosity = sopt.options.get('verbosity', 'warning')
82 logfile = sopt.options.get('logfile', None)
83 set_logger(verbosity, logfile)
85 config = ConfMan(sopt.options).config
86 logfile = config.get('log', 'logfile')
87 verbosity = config.get('log', 'verbosity')
88 set_logger(verbosity, logfile)
89 logger = logging.getLogger('sima')
90 logger.debug('Command line say: {0}'.format(sopt.options))
92 db_file = config.get('sima', 'db_file')
93 if (sopt.options.get('create_db', None)
94 or not isfile(db_file)):
95 logger.info('Creating database in "{}"'.format(db_file))
96 open(db_file, 'a').close()
97 SimaDB(db_path=db_file).create_db()
98 if sopt.options.get('create_db', None):
99 logger.info('Done, bye...')
102 logger.info('Starting...')
103 sima = core.Sima(config)
105 # required core plugins
106 core_plugins = [History, MpdOptions, Uniq]
107 for cplgn in core_plugins:
108 logger.debug('Register core {name} ({doc})'.format(**cplgn.info()))
109 sima.register_plugin(cplgn)
111 # Loading internal plugins
112 load_plugins(sima, 'internal')
114 # Loading contrib plugins
115 load_plugins(sima, 'contrib')
118 if config.getboolean('daemon', 'daemon'):
122 logger.info('Daemonize process...')
127 except KeyboardInterrupt:
128 logger.info('Caught KeyboardInterrupt, stopping')
132 def run(sopt, restart=False):
134 Handles SigHup exception
135 Catches Unhandled exception
137 # pylint: disable=broad-except
140 except SigHup: # SigHup inherit from Exception
142 except Exception: # Unhandled exception
148 nfo = dict({'version': info.__version__,
150 # StartOpt gathers options from command line call (in StartOpt().options)
155 if __name__ == '__main__':
159 # vim: ai ts=4 sw=4 sts=4 expandtab