"""Jenkins utilities for amazon_datapulse_trigger."""

import jenkins

import config

logger = config.logger


def trigger_job(jenkins_job, jenkins_job_params):
    """Trigger a Jenkins job with parameters."""
    logger.info(
        f'Triggering Jenkins job {jenkins_job} with params {jenkins_job_params}'
    )
    token = config.get_jenkins_token()
    logger.info(
        f'User: {config.JENKINS_USER}, Jenkins URL: {config.JENKINS_URL}, '
        f'Token: {str(token)[:4]}***'
    )
    server = jenkins.Jenkins(
        config.JENKINS_URL,
        username=config.JENKINS_USER,
        password=token,
    )
    queue_id = server.build_job(jenkins_job, jenkins_job_params)
    logger.info(f'Queued to Jenkins job {jenkins_job} with {queue_id=}')

    return queue_id