Method decode_message

gunicorn/dirty/protocol.py:359–401

Decode a complete message (header + payload). Args: data: Complete message bytes Returns: tuple: (msg_type_str, request_id, payload_dict) msg_type_str is the string name (e.g., "request") payload_dict is the dec

(data: bytes)

    @staticmethod
    def decode_message(data: bytes) -> tuple:
        """
        Decode a complete message (header + payload).

        Args:
            data: Complete message bytes

        Returns:
            tuple: (msg_type_str, request_id, payload_dict)
                   msg_type_str is the string name (e.g., "request")
                   payload_dict is the decoded TLV payload as a dict

        Raises:
            DirtyProtocolError: If message is malformed
        """
        msg_type, request_id, length = BinaryProtocol.decode_header(data)

        if len(data) < HEADER_SIZE + length:
            raise DirtyProtocolError(
                f"Incomplete message: expected {HEADER_SIZE + length} bytes, "
                f"got {len(data)}",
                raw_data=data[:50]
            )

        if length == 0:
            # End message has empty payload
            payload_dict = {}
        else:
            payload_data = data[HEADER_SIZE:HEADER_SIZE + length]
            try:
                payload_dict = TLVEncoder.decode_full(payload_data)
            except DirtyProtocolError:
                raise
            except Exception as e:
                raise DirtyProtocolError(
                    f"Failed to decode TLV payload: {e}",
                    raw_data=payload_data[:50]
                )

        # Convert to dict format similar to old JSON protocol
        msg_type_str = MSG_TYPE_TO_STR[msg_type]

        return msg_type_str, request_id, payload_dict

    # -------------------------------------------------------------------------
    # Async API (primary - for DirtyArbiter and DirtyWorker)