def __init__()

in messages/message.py [0:0]

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

    def __init__(self, **kwargs):
        queued_message = kwargs.pop("QueuedMessage")
        if queued_message.message_attributes is not None:
            ma = queued_message.message_attributes
            try:
                self.uuid_key = queued_message.message_attributes \
                    .get('UUID').get('StringValue')
            except ValueError:
                raise ValueError("Missing uuid from queued message")
            expiration_date = queued_message.message_attributes \
                .get('ExpirationDateTimeInUtc').get('StringValue')
            self.no_more_occurrences = bool(queued_message.message_attributes
                                            .get('NoMoreOccurrences')
                                            .get('StringValue'))
            if ma.get('IceBreaker'):
                self.ice_breaker = queued_message.message_attributes \
                    .get('IceBreaker').get('StringValue')
            else:
                self.ice_breaker = ""

            if ma.get('BotNames'):
                self.bot_names = queued_message.message_attributes \
                    .get('BotNames').get('StringValue')
            else:
                self.bot_names = ''

            if ma.get('RequiredBots'):
                self.required_bots = queued_message.message_attributes \
                    .get('RequiredBots').get('StringValue')
            else:
                self.required_bots = ''

            self.voice_id = queued_message.message_attributes \
                .get('Voice').get('StringValue')
            person_name = queued_message.message_attributes \
                .get('PersonName').get('StringValue')
            self.person_name = person_name
            try:
                if expiration_date:
                    self.expiration_datetime_in_utc = \
                        arrow.get(expiration_date)
            except ValueError:
                raise ValueError("Unable to parse expiration date")
        self.body = queued_message.body
        if self.expiration_datetime_in_utc < arrow.utcnow():
            print "%s < %s:%s" % (self.expiration_datetime_in_utc,
                                  arrow.utcnow(), True)
            self.is_expired = True
        else:
            print "%s>%s:%s" % (self.expiration_datetime_in_utc,
                                arrow.utcnow(), False)
            self.is_expired = False
        self.original_message = kwargs.get("Message", "")