def process_message()

in transcoder/message/DatacastParser.py [0:0]

• 13 lines of code
• 4 McCabe index (conditional complexity)

    def process_message(self, raw_msg) -> ParsedMessage:
        """Wraps _process_message with count and inclusion behavior"""

        message = self._process_message(raw_msg)

        if message is None:
            return None

        if self.__include_message_type(message.name) is False:
            message.ignored = True
            return message

        self.increment_summary_count(message.name)

        if self.stats_only is True:
            message.ignored = True
            return message

        message = self._parse_message(message)
        return message