def message_handler()

in message_flow/commands/consumer/command_dispatcher.py [0:0]
33 lines of code
3 McCabe index (conditional complexity)

    def message_handler(self, message: IMessage) -> None:
        _logger.debug(
            "Got command %s, with payload %s.",
            message.get_required_header(CommandMessageHeaders.COMMAND_TYPE),
            message.payload,
        )  # noqa: WPS323
        command_handler: Optional[
            CommandHandler
        ] = self._command_handlers.find_target_method(message)

        if command_handler is None:
            _logger.debug(
                "Command %s doesn't have a handler.",
                message.get_required_header(CommandMessageHeaders.COMMAND_TYPE),
            )  # noqa: WPS323
            return

        command_handler_params = CommandHandlerParams(message)
        command_message = CommandMessage(
            message.get_id(),
            self._deserializer.deserialize(
                command_handler.command_class, message.payload
            ),
            command_handler_params.correlation_headers,
            message,
        )
        replies: CommandResult = self._invoke(command_handler, command_message)

        if replies is None:
            return

        self._send_replies(replies, command_handler_params)
        _logger.info(
            "Command %s, with payload %s processed.",
            message.get_required_header(CommandMessageHeaders.COMMAND_TYPE),
            message.payload,
        )  # noqa: WPS323