"""Logger for stream_asset_mezzanine_audio_flac 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 AssetMezzanineAudioFlacEventMessage


class AssetMezzanineAudioFlacEventLogger(ContentLambdaLogger):
    """AssetMezzanineAudioFlacEventLogger."""

    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 = AssetMezzanineAudioFlacEventMessage(
                msk_message.value, msk_message.topic, deserializer)
        except EventProducerMessageException:
            return
        self.data.update({
            'filename': event.filename,
            'asset_type': event.asset_type,
            'asset_final_id': event.asset_final_id,
        })