import os
import time
from test.fixtures import *

import pytest
from mock import patch

from app import export_action_logs_queue
from endpoints.api.logs import ExportOrgLogs, OrgLogs, _validate_logs_arguments
from endpoints.api.test.shared import conduct_api_call
from endpoints.test.shared import client_with_identity


@pytest.mark.skipif(
    os.environ.get("TEST_DATABASE_URI", "").find("mysql") >= 0,
    reason="Queue code is very sensitive to times on MySQL, making this flaky",
)
def test_export_logs(app):
    timecode = time.time()

    def get_time():
        return timecode - 2

    with patch("time.time", get_time):
        with client_with_identity("devtable", app) as cl:
            assert export_action_logs_queue.get() is None
            # Call to export logs.
            body = {
                "callback_url": "http://some/url",
                "callback_email": "a@b.com",
            }

            conduct_api_call(
                cl, ExportOrgLogs, "POST", {"orgname": "buynlarge"}, body, expected_code=200
            )

            # Ensure the request was queued.
            assert export_action_logs_queue.get() is not None


def test_invalid_date_range(app):
    starttime = "02/02/2020"
    endtime = "01/01/2020"
    parsed_starttime, parsed_endtime = _validate_logs_arguments(starttime, endtime)
    assert parsed_starttime >= parsed_endtime

    with client_with_identity("devtable", app) as cl:
        conduct_api_call(
            cl,
            OrgLogs,
            "GET",
            {"orgname": "buynlarge", "starttime": starttime, "endtime": endtime},
            {},
            expected_code=400,
        )