"""Kick-off script for awal-ingestion-flow-control orchestration."""
import json

from boto3 import client as boto_client
import config
from config import app_logger as log


def main():
    """Logic used by Jenkins to start the flow control Lambda."""
    log.info(f'Invoking {config.LAMBDA_NAME}.')

    lambda_payload = {
        'MAX_STATE_MACHINES': int(config.MAX_STATE_MACHINES),
        'SFN_START_DELAY': int(config.SFN_START_DELAY),
        'SFN_BATCH_SIZE': int(config.SFN_BATCH_SIZE),
    }

    aws_lambda_client = boto_client('lambda', region_name='us-east-1')
    aws_lambda_client.invoke(
        FunctionName=f'{config.ENVIRONMENT}-{config.LAMBDA_NAME}',
        InvocationType='Event',
        Payload=bytes(json.dumps(lambda_payload), 'utf-8'),
    )

    log.info(f'Invoked {config.LAMBDA_NAME}.')


if __name__ == '__main__':
    main()