# -*- coding: utf-8 -*-
#
# Copyright 2012-2014 Romain Dorgueil
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

from rdc.etl.error import AbstractError
from rdc.etl.io import STDIN
from rdc.etl.transform import Transform

class Filter(Transform):
    """Filter out hashes from the stream depending on the :attr:`filter` callable return value, when called with the
    current hash as parameter.

    Can be used as a decorator on a filter callable.

    .. attribute:: filter

        A callable used to filter the hashes. If return value is True for a given hash, then the hash will be yield to
        output. Otherwise, it will be burnt.


    Example::

        >>> from rdc.etl.transform.filter import Filter
        >>> from rdc.etl.hash import Hash

        >>> @Filter
        ... def my_filter(hash, channel):
        ...     return hash['keepme'] == True

        >>> list(my_filter(
        ...         (('foo', 'bar'), ('keepme', True), ),
        ...         (('foo', 'baz'), ('keepme', False), ),
        ...     ))
        [H{'foo': 'bar', 'keepme': True}]

    """

    def __init__(self, filter=None):
        super(SimpleFilter, self).__init__()
        self.filter = filter or self.filter

    def filter(self, hash, channel=STDIN):
        raise AbstractError(self.filter)

    def transform(self, hash, channel=STDIN):
        if not self.filter or not callable(self.filter):
            raise RuntimeError('No callable provided to ' + self.__class__.__name__ + '.')

        if self.filter(hash, channel=STDIN):
            yield hash


# For BC, deprecated.
# todo remove in 2.0
SimpleFilter = Filter


# -*- coding: utf-8 -*-
#
# Copyright 2012-2014 Romain Dorgueil
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

from rdc.etl.error import AbstractError
from rdc.etl.io import STDIN
from rdc.etl.transform import Transform

class Filter(Transform):
    """Filter out hashes from the stream depending on the :attr:`filter` callable return value, when called with the
    current hash as parameter.

    Can be used as a decorator on a filter callable.

    .. attribute:: filter

        A callable used to filter the hashes. If return value is True for a given hash, then the hash will be yield to
        output. Otherwise, it will be burnt.


    Example::

        >>> from rdc.etl.transform.filter import Filter
        >>> from rdc.etl.hash import Hash

        >>> @Filter
        ... def my_filter(hash, channel):
        ...     return hash['keepme'] == True

        >>> list(my_filter(
        ...         (('foo', 'bar'), ('keepme', True), ),
        ...         (('foo', 'baz'), ('keepme', False), ),
        ...     ))
        [H{'foo': 'bar', 'keepme': True}]

    """

    def __init__(self, filter=None):
        super(SimpleFilter, self).__init__()
        self.filter = filter or self.filter

    def filter(self, hash, channel=STDIN):
        raise AbstractError(self.filter)

    def transform(self, hash, channel=STDIN):
        if not self.filter or not callable(self.filter):
            raise RuntimeError('No callable provided to ' + self.__class__.__name__ + '.')

        if self.filter(hash, channel):
            yield hash


# For BC, deprecated.
# todo remove in 2.0
SimpleFilter = Filter


fix bug in filter, pass the right channel by position instead of STDIN by name (allows a lambda or callable to call the channel somethingelse than channel, for example, and allow usage of multiple inputs)