"""Logger for cdc queue_move_history events."""

from content_utils.logging.logger import ContentLambdaLogger
from kafka_utils.consumer.source.msk import MSKMessage
from kafka_utils.exceptions import EventProducerMessageException

from src.logic.event_message import QueueMoveHistoryEventMessage


class QueueMoveHistoryEventLogger(ContentLambdaLogger):
    """QueueMoveHistoryEventLogger class."""

    def start(self, msk_message: MSKMessage = None, event_key=None, deserializer=None):
        """Begin processing."""
        super().start(msk_message, event_key)
        if deserializer is None:
            return
        try:
            event = QueueMoveHistoryEventMessage(
                msk_message.value, msk_message.topic, deserializer)
        except EventProducerMessageException:
            return
        self.data.update({
            'queue_move_history_id': event.queue_move_history_id,
            'review_queue_id': event.review_queue_id,
            'queue_name': event.queue_name,
            'moved_by_user_id': event.moved_by_user_id,
        })