"""Lambda gda-sforce-kafka-sync function module."""

from lambdacommon.common_config import logger

from src.salesforce_consumer import SalesforceConsumer  # noqa


def handler(event, context):
    """Lambda entry point."""
    try:
        with SalesforceConsumer(
                with_delay=True, external_test=False) as sf_poller_with_delay:
            sf_poller_with_delay.process_contacts()
        with SalesforceConsumer(
                with_delay=False, external_test=False) as sf_poller_without_delay:
            sf_poller_without_delay.process_contacts()
        with SalesforceConsumer(
                with_delay=True, external_test=True) as sf_poller_external_test:
            sf_poller_external_test.process_contacts()
        return {'status': 'OK'}
    except Exception as e:
        logger.exception(str(e))
        raise e