"""Integration tests for lambda function."""
import operator

import pytest

from tests.integration.conftest import dockerized_lambda_api_client
from tests.integration.utils.db_helper import check_db


@pytest.mark.jira('ACC-4247')
def test_invoke_lambda(basic_headers):
    """Check lambda."""
    dockerized_lambda = dockerized_lambda_api_client(basic_headers)

    check_db(operator.le, 'payment_group_payment_batch')
    check_db(operator.le, 'payment_group_payment_batch_account')

    body = {'abacus_event_id': 1067,
            'target_type': 'payment_group_payment',
            'target_id': '1',
            'event_name': 'send_payments',
            'event_date': '1997-07-16T19:20:30.45+01:00'}

    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'
    assert res.json()['skipped_payoneer'] is False

    check_db(operator.gt, 'payment_group_payment_batch')
    check_db(operator.gt, 'payment_group_payment_batch_account')


@pytest.mark.jira('ACC-6517')
def test_knr_payments_skipped(basic_headers):
    """Check lambda."""
    dockerized_lambda = dockerized_lambda_api_client(basic_headers)

    check_db(operator.le, 'payment_group_payment_batch')
    check_db(operator.le, 'payment_group_payment_batch_account')

    body = {'abacus_event_id': 1068,
            'target_type': 'payment_group_payment',
            'target_id': '2',
            'event_name': 'send_payments',
            'event_date': '1997-07-16T19:20:30.45+01:00'}

    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'
    assert res.json()['skipped_payoneer'] is True

    check_db(operator.gt, 'payment_group_payment_batch')
    check_db(operator.gt, 'payment_group_payment_batch_account')