import logging

import sys

import multiprocessing


config_lock = multiprocessing.Lock()


class _LoggingConfigurator(object):

    is_done = False

    def setup(self):
        with config_lock:
            if not self.is_done:
                # Double check, so we only configure once.
                handler = logging.StreamHandler(sys.stdout)
                handler.lock = multiprocessing.RLock()
                logging.basicConfig(format='{asctime} | {levelname:8.8} | '
                                           '{name:15.15} | {message}',
                                    style='{',
                                    handlers=[handler],
                                    level=logging.DEBUG)
                logging.getLogger('').setLevel(logging.ERROR)
                global configurator
                configurator = _SkipLoggingConfigurator()
            else:
                pass

    def get_logger(self, name):
        self.setup()
        return logging.getLogger(name)


class _SkipLoggingConfigurator(object):

    @staticmethod
    def get_logger(name):
        return logging.getLogger(name)


configurator = _LoggingConfigurator()


def get_logger(name):
    logger = configurator.get_logger(name.split('.')[-1])
    logger.setLevel(logging.DEBUG)
    return logger