def receive_messages()

in backend-printing/helper/storage.py [0:0]

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

    def receive_messages(self) -> list[dict]:
        """Receive messages from the queue

        Returns:
            list[QueueMessage]: list of messages
        """
        return_messages = []
        try:
            raw_messages = self.storage_queue_client.receive_messages(
                max_messages=MAX_ITEMS_TO_FETCH
            )
            for messages in raw_messages.by_page():
                for message in messages:
                    message_content = json.loads(
                        message.content.decode("utf-8").replace("'", '"')
                    )
                    if "blob_guid" in message_content:
                        blob_data = self._get_document_from_blob(message_content)
                        message_content = json.loads(
                            blob_data.decode("utf-8").replace("'", '"')
                        )
                    return_messages.append((message, message_content))
            return return_messages
        except Exception as e:
            raise Exception(f"Error occurred while receiving messages: {e}")