# -------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See LICENSE.txt in the project root for
# license information.
# -------------------------------------------------------------------------
from datetime import datetime, timedelta
import json

from msrest.serialization import UTC
import pytest

from azure.monitor.query import LogsQueryClient
from azure.monitor.query._helpers import construct_iso8601
from devtools_testutils import AzureRecordedTestCase


class TestLogsTimespans(AzureRecordedTestCase):

    def test_query_no_duration(self, recorded_test, monitor_info):
        client = self.create_client_from_credential(LogsQueryClient, self.get_credential(LogsQueryClient))
        query = """AppRequests |
        where TimeGenerated > ago(12h) |
        summarize avgRequestDuration=avg(DurationMs) by bin(TimeGenerated, 10m), _ResourceId"""

        def callback(request):
            dic = json.loads(request.http_request.body)
            assert dic.get('timespan') is None
        # returns LogsQueryResult
        client.query_workspace(monitor_info['workspace_id'], query, timespan=None)

    def test_query_start_and_end_time(self, recorded_test, monitor_info):
        client = self.create_client_from_credential(LogsQueryClient, self.get_credential(LogsQueryClient))
        query = "AppRequests | take 5"

        end_time = datetime(2022, 11, 8)
        start_time = end_time - timedelta(days=3)

        def callback(request):
            dic = json.loads(request.http_request.body)
            assert dic.get('timespan') is not None

        client.query_workspace(monitor_info['workspace_id'], query, timespan=(start_time, end_time), raw_request_hook=callback)

    def test_query_duration_and_start_time(self, recorded_test, monitor_info):
        client = self.create_client_from_credential(LogsQueryClient, self.get_credential(LogsQueryClient))
        query = "AppRequests | take 5"

        end_time = datetime(2022, 11, 8)
        start_time = end_time - timedelta(days=3)
        duration = timedelta(days=3)

        def callback(request):
            dic = json.loads(request.http_request.body)
            assert '/PT259200.0S' in dic.get('timespan')

        client.query_workspace(monitor_info['workspace_id'], query, timespan=(start_time,duration), raw_request_hook=callback)

    def test_query_duration_only(self, recorded_test, monitor_info):
        client = self.create_client_from_credential(LogsQueryClient, self.get_credential(LogsQueryClient))
        query = "AppRequests | take 5"

        duration = timedelta(days=3)

        def callback(request):
            dic = json.loads(request.http_request.body)
            assert 'PT259200.0S' in dic.get('timespan')

        client.query_workspace(monitor_info['workspace_id'], query, timespan=duration, raw_request_hook=callback)

    def test_duration_to_iso8601(self):
        d1 = timedelta(days=1)
        d2 = timedelta(weeks=1)
        d3 = timedelta(weeks=3, days=4)
        d4 = timedelta(seconds=10)
        d5 = timedelta(microseconds=1000)
        d6 = timedelta(milliseconds=100000)
        d7 = timedelta(hours=24, days=1)

        assert construct_iso8601(timespan=d1) == 'PT86400.0S'
        assert construct_iso8601(timespan=d2) == 'PT604800.0S'
        assert construct_iso8601(timespan=d3) == 'PT2160000.0S'
        assert construct_iso8601(timespan=d4) == 'PT10.0S'
        assert construct_iso8601(timespan=d5) == 'PT0.001S'
        assert construct_iso8601(timespan=d5) == 'PT0.001S'
        assert construct_iso8601(timespan=d7) == 'PT172800.0S'

        with pytest.raises(ValueError, match="timespan must be a timedelta or a tuple."):
            construct_iso8601(timespan=(datetime.now(UTC())))