"""Test filter and schema validators"""
from unittest import TestCase
from voluptuous import Schema
from es_client.exceptions import FailedValidation
from es_client.helpers.schemacheck import SchemaCheck
from curator.exceptions import ConfigurationError
from curator.validators.filter_functions import validfilters, singlefilter


def shared_result(config, action):
    """Test functions should be able to reuse this"""
    return SchemaCheck(
        config,
        Schema(validfilters(action)),
        'filters',
        'testing'
    ).result()

class TestFilters(TestCase):
    def test_single_raises_configuration_error(self):
        data = {'max_num_segments': 1, 'exclude': True}
        self.assertRaises(
            ConfigurationError,
            singlefilter,
            'forcemerge',
            data
        )

class TestFilterTypes(TestCase):
    def test_alias(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'alias',
                'aliases' : ['alias1', 'alias2'],
                'exclude' : False,
            }
        ]
        self.assertEqual(config, shared_result(config, action))
    def test_age(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'age',
                'direction' : 'older',
                'unit' : 'days',
                'unit_count' : 1,
                'source' : 'field_stats',
                'field'  : '@timestamp',
            }
        ]
        self.assertEqual(config, shared_result(config, action))
    def test_age_with_string_unit_count(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'age',
                'direction' : 'older',
                'unit' : 'days',
                'unit_count' : "1",
                'source' : 'field_stats',
                'field'  : '@timestamp',
            }
        ]
        result = shared_result(config, action)
        self.assertEqual(1, result[0]['unit_count'])
    def test_allocated(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'allocated',
                'key' : 'foo',
                'value' : 'bar',
                'allocation_type' : 'require',
                'exclude' : False,
            }
        ]
        self.assertEqual(config, shared_result(config, action))
    def test_closed(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'closed',
                'exclude' : False,
            }
        ]
        self.assertEqual(config, shared_result(config, action))
    def test_count(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'count',
                'count' : 1,
                'reverse' : True,
                'exclude' : False,
            }
        ]
        self.assertEqual(config, shared_result(config, action))
    def test_forcemerged(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'forcemerged',
                'max_num_segments' : 1,
                'exclude' : False,
            }
        ]
        self.assertEqual(config, shared_result(config, action))
    def test_kibana(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'kibana',
                'exclude' : False,
            }
        ]
        self.assertEqual(config, shared_result(config, action))
    def test_opened(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'opened',
                'exclude' : False,
            }
        ]
        self.assertEqual(config, shared_result(config, action))
    def test_space_name_age(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'space',
                'disk_space' : 1,
                'use_age' : True,
                'exclude' : False,
                'source' : 'name',
                'timestring' : '%Y.%m.%d',
            }
        ]
        self.assertEqual(config, shared_result(config, action))
    def test_space_name_age_string_float(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'space',
                'disk_space' : "1.0",
                'use_age' : True,
                'exclude' : False,
                'source' : 'name',
                'timestring' : '%Y.%m.%d',
            }
        ]
        result = shared_result(config, action)
        self.assertEqual(1.0, result[0]['disk_space'])
    def test_space_name_age_no_ts(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'space',
                'disk_space' : 1,
                'use_age' : True,
                'exclude' : False,
                'source' : 'name',
            }
        ]
        schema = SchemaCheck(
            config,
            Schema(validfilters(action)),
            'filters',
            'testing'
        )
        self.assertRaises(FailedValidation, schema.result)
    def test_space_field_stats_age(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'space',
                'disk_space' : 1,
                'use_age' : True,
                'exclude' : False,
                'source' : 'field_stats',
                'field' : '@timestamp',
            }
        ]
        self.assertEqual(config, shared_result(config, action))
    def test_space_field_stats_age_no_field(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'space',
                'disk_space' : 1,
                'use_age' : True,
                'exclude' : False,
                'source' : 'field_stats',
            }
        ]
        schema = SchemaCheck(
            config,
            Schema(validfilters(action)),
            'filters',
            'testing'
        )
        self.assertRaises(FailedValidation, schema.result)
    def test_space_creation_date_age(self):
        action = 'delete_indices'
        config = [
            {
                'filtertype' : 'space',
                'disk_space' : 1,
                'use_age' : True,
                'exclude' : False,
                'source' : 'creation_date',
            }
        ]
        self.assertEqual(config, shared_result(config, action))
    def test_state(self):
        action = 'delete_snapshots'
        config = [
            {
                'filtertype' : 'state',
                'state' : 'SUCCESS',
                'exclude' : False,
            }
        ]
        self.assertEqual(config, shared_result(config, action))
    def test_shards(self):
        action = 'shrink'
        config = [
            {
                'filtertype' : 'shards',
                'number_of_shards' : 5,
                'shard_filter_behavior': 'greater_than',
                'exclude' : False,
            }
        ]
        self.assertEqual(config, shared_result(config, action))