in message_flow/commands/common/command_message_headers.py [0:0]
def in_reply(header: str) -> str:
if not header.startswith(CommandMessageHeaders.COMMAND_HEADER_PREFIX):
raise WrongHeader(f"Command message contains a wrong header {header}")
command_prefix_length = len(CommandMessageHeaders.COMMAND_HEADER_PREFIX)
return (
CommandMessageHeaders.COMMAND_REPLY_PREFIX + header[command_prefix_length:]
)