def decode_message()

in transcoder/source/file/LineDelimitedFileMessageSource.py [0:0]

• 9 lines of code
• 7 McCabe index (conditional complexity)

    def decode_message(self, record):
        """Performs line decoding and message skip bytes for line encoded cases"""
        message = record
        if self.line_encoding == LineEncoding.BASE_64.value:
            message = base64.b64decode(record)
        elif self.line_encoding == LineEncoding.BASE_64_URL_SAFE.value:
            message = base64.urlsafe_b64decode(record)

        if self.message_skip_bytes > 0 and isinstance(message, bytes):
            # print(''.join('{:02x}'.format(x) for x in message))
            message = message[self.message_skip_bytes:]
            # print(''.join('{:02x}'.format(x) for x in message))

        return message