134 lines
3.2 KiB
Python
134 lines
3.2 KiB
Python
import functools
|
|
from pprint import pprint as _pprint
|
|
|
|
import itertools
|
|
from colorama import Fore, Style
|
|
|
|
from bonobo import settings
|
|
from bonobo.config import Configurable, Option
|
|
from bonobo.config.processors import ContextProcessor
|
|
from bonobo.structs.bags import Bag
|
|
from bonobo.util.objects import ValueHolder
|
|
from bonobo.util.term import CLEAR_EOL
|
|
from bonobo.constants import NOT_MODIFIED
|
|
|
|
__all__ = [
|
|
'identity',
|
|
'Limit',
|
|
'Tee',
|
|
'count',
|
|
'pprint',
|
|
'PrettyPrinter',
|
|
'noop',
|
|
]
|
|
|
|
|
|
def identity(x):
|
|
return x
|
|
|
|
|
|
class Limit(Configurable):
|
|
"""
|
|
Creates a Limit() node, that will only let go through the first n rows (defined by the `limit` option), unmodified.
|
|
|
|
.. attribute:: limit
|
|
|
|
Number of rows to let go through.
|
|
|
|
"""
|
|
limit = Option(positional=True, default=10)
|
|
|
|
@ContextProcessor
|
|
def counter(self, context):
|
|
yield ValueHolder(0)
|
|
|
|
def call(self, counter, *args, **kwargs):
|
|
counter += 1
|
|
if counter <= self.limit:
|
|
yield NOT_MODIFIED
|
|
|
|
|
|
def Tee(f):
|
|
from bonobo.constants import NOT_MODIFIED
|
|
|
|
@functools.wraps(f)
|
|
def wrapped(*args, **kwargs):
|
|
nonlocal f
|
|
f(*args, **kwargs)
|
|
return NOT_MODIFIED
|
|
|
|
return wrapped
|
|
|
|
|
|
def count(counter, *args, **kwargs):
|
|
counter += 1
|
|
|
|
|
|
@ContextProcessor.decorate(count)
|
|
def _count_counter(self, context):
|
|
counter = ValueHolder(0)
|
|
yield counter
|
|
context.send(Bag(counter._value))
|
|
|
|
|
|
class PrettyPrinter(Configurable):
|
|
def call(self, *args, **kwargs):
|
|
formater = self._format_quiet if settings.QUIET else self._format_console
|
|
|
|
for i, (item, value) in enumerate(itertools.chain(enumerate(args), kwargs.items())):
|
|
print(formater(i, item, value))
|
|
|
|
def _format_quiet(self, i, item, value):
|
|
return ' '.join(((' ' if i else '-'), str(item), ':', str(value).strip()))
|
|
|
|
def _format_console(self, i, item, value):
|
|
return ' '.join(
|
|
((' ' if i else '•'), str(item), '=', str(value).strip().replace('\n', '\n' + CLEAR_EOL), CLEAR_EOL)
|
|
)
|
|
|
|
|
|
pprint = PrettyPrinter()
|
|
pprint.__name__ = 'pprint'
|
|
|
|
|
|
def PrettyPrint(title_keys=('title', 'name', 'id'), print_values=True, sort=True):
|
|
from bonobo.constants import NOT_MODIFIED
|
|
|
|
def _pprint(*args, **kwargs):
|
|
nonlocal title_keys, sort, print_values
|
|
|
|
row = args[0]
|
|
for key in title_keys:
|
|
if key in row:
|
|
print(Style.BRIGHT, row.get(key), Style.RESET_ALL, sep='')
|
|
break
|
|
|
|
if print_values:
|
|
for k in sorted(row) if sort else row:
|
|
print(
|
|
' • ',
|
|
Fore.BLUE,
|
|
k,
|
|
Style.RESET_ALL,
|
|
' : ',
|
|
Fore.BLACK,
|
|
'(',
|
|
type(row[k]).__name__,
|
|
')',
|
|
Style.RESET_ALL,
|
|
' ',
|
|
repr(row[k]),
|
|
CLEAR_EOL,
|
|
)
|
|
|
|
yield NOT_MODIFIED
|
|
|
|
_pprint.__name__ = 'pprint'
|
|
|
|
return _pprint
|
|
|
|
|
|
def noop(*args, **kwargs): # pylint: disable=unused-argument
|
|
from bonobo.constants import NOT_MODIFIED
|
|
return NOT_MODIFIED
|