Source code for scrolls.importer

class MessageImporter(object):
    """Deals with newly arrived Messages"""

    def __init__(self, dependencies):
        self.repository = dependencies.getMessageRepository()
        self.stats = dependencies.getStatisticRepository()
        self.count = dependencies.getCounterFactory()
        self.counters = [
            self.count.byHostname(),
            self.count.byApp(),
            self.count.byHour()
        ]

    def import_(self, messages):
        """Handles a batch of new messages

        Will persist and aggregate them. If the batch is empty, will return
        immediately.

        Args:
            messages (list): List of Message objects to be imported.
        """
        if messages == []:
            return
        self.repository.add(messages)
        for counter in self.counters:
            for message in messages:
                counter.add(message)
            self.stats.update(counter.name, counter.counts)
            counter.reset()