"""Lambda schedule_auto_add function module."""
import json

from kafka_utils.consumer.source.mapping import EventSourceMessage
from lambdacommon.common_config import logger

from schedule_auto_add.processor import ScheduleAutoAddProcessor


def handler(event, context):
    """Lambda entry point."""
    try:
        event_messages = EventSourceMessage(event)
        for __, event_message in event_messages:
            event_value = json.loads(event_message.value)
            logger.info(f'Event value: {event_value}')
            ScheduleAutoAddProcessor(event=event_value).process()
    except Exception as e:
        logger.exception(str(e))
        raise e
    return {'status': 'OK'}