"""Test for the Cachier python package."""

# This file is part of Cachier.
# https://github.com/shaypal5/cachier

# Licensed under the MIT license:
# http://www.opensource.org/licenses/MIT-license
# Copyright (c) 2016, Shay Palachy <shaypal5@gmail.com>

import time
import datetime
from cachier import cachier
from datapy.mongo import get_collection
import random


def _mongo_getter():
    return get_collection('cachier', server_name='production', mode='writing')


# Pickle core tests

@cachier(next_time=True)
def test_int_pickling(int_1, int_2):
    """Add the two given ints."""
    return int_1 + int_2


def test_int_pickling_compare(int_1, int_2):
    """Add the two given ints."""
    return int_1 + int_2


def test_speed():
    """Test speeds"""
    num_of_vals = 10000
    times = []
    for i in range(1, num_of_vals):
        tic = time.time()
        test_int_pickling_compare(i, i + 1)
        toc = time.time()
        times.append(toc - tic)
    print('Non-decorated average = {:.8f}'.format(sum(times) / num_of_vals))

    test_int_pickling.clear_cache()
    times = []
    for i in range(1, num_of_vals):
        tic = time.time()
        test_int_pickling(i, i + 1)
        toc = time.time()
        times.append(toc - tic)
    print('Decorated average = {:.8f}'.format(sum(times) / num_of_vals))


@cachier(next_time=False)
def takes_30_seconds(arg_1, arg_2):
    """Some function."""
    time.sleep(30)
    return 'arg_1:{}, arg_2:{}'.format(arg_1, arg_2)


DELTA = datetime.timedelta(seconds=10)


@cachier(stale_after=DELTA, next_time=False)
def stale_after_seconds(arg_1, arg_2):
    """Some function."""
    return {'arg_1': arg_1, 'arg_2': arg_2}


# Mongo core tests

@cachier(mongetter=_mongo_getter, next_time=True)
def test_mongo_caching(arg_1, arg_2):
    """Some function."""
    return 'arg_1:{}, arg_2:{}'.format(arg_1, arg_2)


@cachier(mongetter=_mongo_getter, next_time=False)
def takes_30_seconds_mongo(arg_1, arg_2):
    """Some function."""
    time.sleep(30)
    return 'arg_1:{}, arg_2:{}'.format(arg_1, arg_2)

MONGO_DELTA = datetime.timedelta(seconds=30)


@cachier(mongetter=_mongo_getter, stale_after=MONGO_DELTA, next_time=False)
def stale_after_mongo(arg_1, arg_2):
    """Some function."""
    return {'arg_1': arg_1, 'arg_2': arg_2}


@cachier()
def _random_num():
    return random.random()


@cachier()
def _random_num_with_arg(a):
    print(a)
    return random.random()


def test_overwrite_cache():
    """Tests that the overwrite feature works correctly."""
    _random_num.clear_cache()
    int1 = _random_num()
    int2 = _random_num()
    assert int2 == int1
    int3 = _random_num(overwrite_cache=True)
    assert int3 != int1
    int4 = _random_num()
    assert int4 == int3

    _random_num_with_arg.clear_cache()
    int1 = _random_num_with_arg('a')
    int2 = _random_num_with_arg('a')
    assert int2 == int1
    int3 = _random_num_with_arg('a', overwrite_cache=True)
    assert int3 != int1
    int4 = _random_num_with_arg('a')
    assert int4 == int3


def test_ignore_cache():
    """Tests that the overwrite feature works correctly."""
    _random_num.clear_cache()
    int1 = _random_num()
    int2 = _random_num()
    assert int2 == int1
    int3 = _random_num(ignore_cache=True)
    assert int3 != int1
    int4 = _random_num()
    assert int4 != int3
    assert int4 == int1

    _random_num_with_arg.clear_cache()
    int1 = _random_num_with_arg('a')
    int2 = _random_num_with_arg('a')
    assert int2 == int1
    int3 = _random_num_with_arg('a', ignore_cache=True)
    assert int3 != int1
    int4 = _random_num_with_arg('a')
    assert int4 != int3
    assert int4 == int1