"""Integration tests for lambda function."""

import pytest

from tests.integration.conftest import dockerized_lambda_api_client, mysqlclient_docker


@pytest.mark.jira('ACC-3437', 'ACC-3943')
def test_invoke_lambda(basic_headers):
    """Check ledger_db here."""
    dockerized_lambda = dockerized_lambda_api_client(basic_headers)

    body = {'abacus_event_id': 1,
            'target_type': 'payment_group_payment',
            'target_id': '74',
            'event_name': 'payments_generate',
            'event_date': '2021-03-15 13:27:29.792000'}

    res = dockerized_lambda.post_lambda('2015-03-31', body)
    assert res.status_code == 200
    assert 'status' in res.json(), \
        f"error type was: {res.json()['errorType']}, " \
        f"error message was: {res.json()['errorMessage']}"
    assert res.json()['status'] == 'OK'

    cnx = mysqlclient_docker()

    cursor = cnx.cursor()

    cursor.execute('SELECT * FROM payment_group_payment_account')
    results = cursor.fetchall()
    results_dict = [dict(
        zip(map(lambda x: x[0], cursor.description), row)) for row in results]
    assert len(results_dict) == 1
    assert results_dict[0]['currency_code'] == 'USD'
    assert results_dict[0]['account_id'] == 1
    assert results_dict[0]['payment_group_payment_id'] == 74
    assert results_dict[0]['payment_group_payment_account_id'] == 1
    assert results_dict[0]['current_balance'] == 200.00
    cnx.close()