Source code for duct.outputs.logger

"""
.. module:: logger
   :synopsis: Output which sends events to the standard logging output
   :no-index:

.. moduleauthor:: Colin Alston <colin@tamvera.com>
"""
import logging

from duct.objects import Output

log = logging.getLogger(__name__)




class Logger(Output):
    """Logger output

    :param logfile: Logfile (default: write to standard log)
    :type logfile: str
    """

    def __init__(self, *a, **kw):
        super().__init__(*a, **kw)
        if self.config.get('logfile'):
            self.logfile = open(  # pylint: disable=consider-using-with
                self.config.get('logfile'), 'at', encoding='utf-8')
        else:
            self.logfile = None



    async def stop(self):
        if self.logfile:
            self.logfile.close()




    async def eventsReceived(self, events):
        for ev in events:
            if self.logfile:
                self.logfile.write(repr(ev) + '\n')
            else:
                log.info(repr(ev))