app/utils/message_parser.py

"""
Message normalization helpers for Notiflow.
"""

from __future__ import annotations

import re


class MessageParser:
    """Normalize incoming business messages before they reach the agents."""

    _whitespace_pattern = re.compile(r"\s+")

    def parse(self, message: str) -> str:
        """Normalize a message for downstream LLM processing."""
        if message is None:
            return ""
        normalized = str(message).strip().lower()
        normalized = self._whitespace_pattern.sub(" ", normalized)
        return normalized


def parse_message(message: str) -> str:
    """Convenience wrapper used by the backend entry point."""
    return MessageParser().parse(message)