"""
Upsert users from logs to intercom and home market ID MySQL table.
"""
from typing import Optional

from redis import ConnectionPool, StrictRedis

import handle_user_changes.handler
from handle_user_changes import config
from handle_user_changes.logger import get_logger


redis_pool: Optional[ConnectionPool] = None


def lambda_handler(event, context):
    logger = get_logger(context.aws_request_id)

    global redis_pool
    if not redis_pool:
        redis_pool = ConnectionPool(host=config.REDIS_HOST, port=config.REDIS_PORT, max_connections=50)

    redis_client = StrictRedis(connection_pool=redis_pool)
    return handle_user_changes.handler.handler(event, redis_client, logger)