]> kaliko git repositories - mpd-sima.git/blob - sima/launch.py
Renamed a private method
[mpd-sima.git] / sima / launch.py
1 # -*- coding: utf-8 -*-
2 # Copyright (c) 2013, 2014 Jack Kaliko <kaliko@azylum.org>
3 #
4 #  This file is part of sima
5 #
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.
10 #
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.
15 #
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/>.
18 #
19 #
20 """Sima
21 """
22
23 # standard library import
24 import logging
25 import sys
26
27 from importlib import __import__
28 from os.path import isfile
29 ##
30
31 # third parties components
32 ##
33
34 # local import
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
41  # core plugins
42 from .plugins.core.history import History
43 from .plugins.core.mpdoptions import MpdOptions
44 ##
45
46
47 def load_plugins(sima, source):
48     """Handles internal/external plugins
49         sima:   sima.core.Sima instance
50         source: ['internal', 'contrib']
51     """
52     if not sima.config.get('sima', source ):
53         return
54     logger = logging.getLogger('sima')
55     for plugin in sima.config.get('sima', source).split(','):
56         plugin = plugin.strip(' \n')
57         module = 'sima.plugins.{0}.{1}'.format(source, plugin.lower())
58         try:
59             mod_obj = __import__(module, fromlist=[plugin])
60         except ImportError as err:
61             logger.error('Failed to load plugin\'s module: {0} ({1})'.format(module, err))
62             sima.shutdown()
63             sys.exit(1)
64         try:
65             plugin_obj = getattr(mod_obj, plugin)
66         except AttributeError as err:
67             logger.error('Failed to load plugin {0} ({1})'.format(plugin, err))
68             sima.shutdown()
69             sys.exit(1)
70         logger.info('Loading {0} plugin: {name} ({doc})'.format(source, **plugin_obj.info()))
71         sima.register_plugin(plugin_obj)
72
73
74 def start(sopt, restart=False):
75     """starts application
76     """
77     # set logger
78     verbosity = sopt.options.get('verbosity', 'warning')
79     logfile = sopt.options.get('logfile', None)
80     cli_loglevel = getattr(logging, verbosity.upper())
81     set_logger(level=verbosity, logfile=logfile)
82     logger = logging.getLogger('sima')
83     logger.setLevel(cli_loglevel)
84     # loads configuration
85     config = ConfMan(logger, sopt.options).config
86     logger.setLevel(getattr(logging,
87                     config.get('log', 'verbosity').upper()))  # pylint: disable=E1103
88
89     logger.debug('Command line say: {0}'.format(sopt.options))
90     # Create Database
91     db_file = config.get('sima', 'db_file')
92     if (sopt.options.get('create_db', None)
93        or not isfile(db_file)):
94         logger.info('Creating database in "{}"'.format(db_file))
95         open(db_file, 'a').close()
96         SimaDB(db_path=db_file).create_db()
97         if sopt.options.get('create_db', None):
98             logger.info('Done, bye...')
99             sys.exit(0)
100
101     logger.info('Starting...')
102     sima = core.Sima(config)
103
104     # required core plugins
105     sima.register_plugin(History)
106     sima.register_plugin(MpdOptions)
107
108     #  Loading internal plugins
109     load_plugins(sima, 'internal')
110
111     #  Loading contrib plugins
112     load_plugins(sima, 'contrib')
113     # Run as a daemon
114     if config.getboolean('daemon', 'daemon'):
115         if restart:
116             sima.run()
117         else:
118             logger.info('Daemonize process...')
119             sima.start()
120
121     try:
122         sima.foreground()
123     except KeyboardInterrupt:
124         logger.info('Caught KeyboardInterrupt, stopping')
125         sys.exit(0)
126
127
128 def run(sopt, restart=False):
129     """
130     Handles SigHup exception
131     Catches Unhandled exception
132     """
133     # pylint: disable=broad-except
134     try:
135         start(sopt, restart)
136     except SigHup as err:  # SigHup inherit from Exception
137         run(sopt, True)
138     except Exception:  # Unhandled exception
139         exception_log()
140
141 # Script starts here
142 def main():
143     nfo = dict({'version': info.__version__,
144                  'prog': 'sima'})
145     # StartOpt gathers options from command line call (in StartOpt().options)
146     sopt = StartOpt(nfo)
147     run(sopt)
148
149
150 if __name__ == '__main__':
151     main()
152
153 # VIM MODLINE
154 # vim: ai ts=4 sw=4 sts=4 expandtab