2008-12-10 22:14:05 -06:00
|
|
|
# Authors:
|
|
|
|
# Jason Gerard DeRose <jderose@redhat.com>
|
|
|
|
#
|
|
|
|
# Copyright (C) 2008 Red Hat
|
|
|
|
# see file 'COPYING' for use and warranty information
|
|
|
|
#
|
|
|
|
# This program is free software; you can redistribute it and/or
|
|
|
|
# modify it under the terms of the GNU General Public License as
|
|
|
|
# published by the Free Software Foundation; version 2 only
|
|
|
|
#
|
|
|
|
# This program is distributed in the hope that it will be useful,
|
|
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
# GNU General Public License for more details.
|
|
|
|
#
|
|
|
|
# You should have received a copy of the GNU General Public License
|
|
|
|
# along with this program; if not, write to the Free Software
|
|
|
|
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
|
|
|
|
|
|
|
"""
|
|
|
|
Parameter system for command plugins.
|
|
|
|
"""
|
|
|
|
|
2008-12-11 23:39:50 -06:00
|
|
|
from types import NoneType
|
2008-12-10 22:14:05 -06:00
|
|
|
from plugable import ReadOnly, lock, check_name
|
2008-12-11 19:07:54 -06:00
|
|
|
from constants import NULLS, TYPE_ERROR, CALLABLE_ERROR
|
2008-12-10 22:14:05 -06:00
|
|
|
|
|
|
|
|
|
|
|
def parse_param_spec(spec):
|
|
|
|
"""
|
|
|
|
Parse a param spec into to (name, kw).
|
|
|
|
|
|
|
|
The ``spec`` string determines the param name, whether the param is
|
|
|
|
required, and whether the param is multivalue according the following
|
|
|
|
syntax:
|
|
|
|
|
|
|
|
====== ===== ======== ==========
|
|
|
|
Spec Name Required Multivalue
|
|
|
|
====== ===== ======== ==========
|
|
|
|
'var' 'var' True False
|
|
|
|
'var?' 'var' False False
|
|
|
|
'var*' 'var' False True
|
|
|
|
'var+' 'var' True True
|
|
|
|
====== ===== ======== ==========
|
|
|
|
|
|
|
|
For example,
|
|
|
|
|
|
|
|
>>> parse_param_spec('login')
|
|
|
|
('login', {'required': True, 'multivalue': False})
|
|
|
|
>>> parse_param_spec('gecos?')
|
|
|
|
('gecos', {'required': False, 'multivalue': False})
|
|
|
|
>>> parse_param_spec('telephone_numbers*')
|
|
|
|
('telephone_numbers', {'required': False, 'multivalue': True})
|
|
|
|
>>> parse_param_spec('group+')
|
|
|
|
('group', {'required': True, 'multivalue': True})
|
|
|
|
|
|
|
|
:param spec: A spec string.
|
|
|
|
"""
|
|
|
|
if type(spec) is not str:
|
|
|
|
raise_TypeError(spec, str, 'spec')
|
|
|
|
if len(spec) < 2:
|
|
|
|
raise ValueError(
|
|
|
|
'param spec must be at least 2 characters; got %r' % spec
|
|
|
|
)
|
|
|
|
_map = {
|
|
|
|
'?': dict(required=False, multivalue=False),
|
|
|
|
'*': dict(required=False, multivalue=True),
|
|
|
|
'+': dict(required=True, multivalue=True),
|
|
|
|
}
|
|
|
|
end = spec[-1]
|
|
|
|
if end in _map:
|
|
|
|
return (spec[:-1], _map[end])
|
|
|
|
return (spec, dict(required=True, multivalue=False))
|
|
|
|
|
|
|
|
|
2008-12-11 21:30:59 -06:00
|
|
|
class DefaultFrom(ReadOnly):
|
|
|
|
"""
|
|
|
|
Derive a default value from other supplied values.
|
|
|
|
|
|
|
|
For example, say you wanted to create a default for the user's login from
|
|
|
|
the user's first and last names. It could be implemented like this:
|
|
|
|
|
|
|
|
>>> login = DefaultFrom(lambda first, last: first[0] + last)
|
|
|
|
>>> login(first='John', last='Doe')
|
|
|
|
'JDoe'
|
|
|
|
|
|
|
|
If you do not explicitly provide keys when you create a DefaultFrom
|
|
|
|
instance, the keys are implicitly derived from your callback by
|
|
|
|
inspecting ``callback.func_code.co_varnames``. The keys are available
|
|
|
|
through the ``DefaultFrom.keys`` instance attribute, like this:
|
|
|
|
|
|
|
|
>>> login.keys
|
|
|
|
('first', 'last')
|
|
|
|
|
|
|
|
The callback is available through the ``DefaultFrom.callback`` instance
|
|
|
|
attribute, like this:
|
|
|
|
|
|
|
|
>>> login.callback # doctest:+ELLIPSIS
|
|
|
|
<function <lambda> at 0x...>
|
|
|
|
>>> login.callback.func_code.co_varnames # The keys
|
|
|
|
('first', 'last')
|
|
|
|
|
|
|
|
The keys can be explicitly provided as optional positional arguments after
|
|
|
|
the callback. For example, this is equivalent to the ``login`` instance
|
|
|
|
above:
|
|
|
|
|
|
|
|
>>> login2 = DefaultFrom(lambda a, b: a[0] + b, 'first', 'last')
|
|
|
|
>>> login2.keys
|
|
|
|
('first', 'last')
|
|
|
|
>>> login2.callback.func_code.co_varnames # Not the keys
|
|
|
|
('a', 'b')
|
|
|
|
>>> login2(first='John', last='Doe')
|
|
|
|
'JDoe'
|
|
|
|
|
|
|
|
If any keys are missing when calling your DefaultFrom instance, your
|
|
|
|
callback is not called and None is returned. For example:
|
|
|
|
|
|
|
|
>>> login(first='John', lastname='Doe') is None
|
|
|
|
True
|
|
|
|
>>> login() is None
|
|
|
|
True
|
|
|
|
|
|
|
|
Any additional keys are simply ignored, like this:
|
|
|
|
|
|
|
|
>>> login(last='Doe', first='John', middle='Whatever')
|
|
|
|
'JDoe'
|
|
|
|
|
|
|
|
As above, because `DefaultFrom.__call__` takes only pure keyword
|
|
|
|
arguments, they can be supplied in any order.
|
|
|
|
|
|
|
|
Of course, the callback need not be a lambda expression. This third
|
|
|
|
example is equivalent to both the ``login`` and ``login2`` instances
|
|
|
|
above:
|
|
|
|
|
|
|
|
>>> def get_login(first, last):
|
|
|
|
... return first[0] + last
|
|
|
|
...
|
|
|
|
>>> login3 = DefaultFrom(get_login)
|
|
|
|
>>> login3.keys
|
|
|
|
('first', 'last')
|
|
|
|
>>> login3.callback.func_code.co_varnames
|
|
|
|
('first', 'last')
|
|
|
|
>>> login3(first='John', last='Doe')
|
|
|
|
'JDoe'
|
|
|
|
"""
|
|
|
|
|
|
|
|
def __init__(self, callback, *keys):
|
|
|
|
"""
|
|
|
|
:param callback: The callable to call when all keys are present.
|
|
|
|
:param keys: Optional keys used for source values.
|
|
|
|
"""
|
|
|
|
if not callable(callback):
|
|
|
|
raise TypeError('callback must be callable; got %r' % callback)
|
|
|
|
self.callback = callback
|
|
|
|
if len(keys) == 0:
|
|
|
|
fc = callback.func_code
|
|
|
|
self.keys = fc.co_varnames[:fc.co_argcount]
|
|
|
|
else:
|
|
|
|
self.keys = keys
|
|
|
|
for key in self.keys:
|
|
|
|
if type(key) is not str:
|
|
|
|
raise_TypeError(key, str, 'keys')
|
|
|
|
lock(self)
|
|
|
|
|
|
|
|
def __call__(self, **kw):
|
|
|
|
"""
|
|
|
|
If all keys are present, calls the callback; otherwise returns None.
|
|
|
|
|
|
|
|
:param kw: The keyword arguments.
|
|
|
|
"""
|
|
|
|
vals = tuple(kw.get(k, None) for k in self.keys)
|
|
|
|
if None in vals:
|
|
|
|
return
|
|
|
|
try:
|
|
|
|
return self.callback(*vals)
|
|
|
|
except StandardError:
|
|
|
|
pass
|
|
|
|
|
|
|
|
|
2008-12-10 22:14:05 -06:00
|
|
|
class Param(ReadOnly):
|
|
|
|
"""
|
2008-12-11 23:39:50 -06:00
|
|
|
Base class for all parameters.
|
2008-12-10 22:14:05 -06:00
|
|
|
"""
|
|
|
|
|
2008-12-11 23:39:50 -06:00
|
|
|
kwargs = (
|
|
|
|
('cli_name', str, None),
|
|
|
|
('doc', str, ''),
|
|
|
|
('required', bool, True),
|
|
|
|
('multivalue', bool, False),
|
|
|
|
('primary_key', bool, False),
|
|
|
|
('normalizer', callable, None),
|
|
|
|
('default_from', callable, None),
|
|
|
|
('flags', frozenset, frozenset()),
|
|
|
|
|
|
|
|
# The 'default' kwarg gets appended in Param.__init__():
|
|
|
|
# ('default', self.type, None),
|
2008-12-10 22:14:05 -06:00
|
|
|
)
|
|
|
|
|
2008-12-11 23:39:50 -06:00
|
|
|
# This is a dummy type so that most of the functionality of Param can be
|
|
|
|
# unit tested directly without always creating a subclass; however, real
|
|
|
|
# (direct) subclasses should *always* override this class attribute:
|
|
|
|
type = NoneType # This isn't very useful in the real world!
|
|
|
|
|
|
|
|
def __init__(self, name, **kw):
|
|
|
|
assert type(self.type) is type
|
2008-12-10 22:14:05 -06:00
|
|
|
self.param_spec = name
|
2008-12-11 23:39:50 -06:00
|
|
|
self.__kw = dict(kw)
|
|
|
|
if not ('required' in kw or 'multivalue' in kw):
|
2008-12-11 21:30:59 -06:00
|
|
|
(name, kw_from_spec) = parse_param_spec(name)
|
2008-12-11 23:39:50 -06:00
|
|
|
kw.update(kw_from_spec)
|
2008-12-10 22:14:05 -06:00
|
|
|
self.name = check_name(name)
|
2008-12-11 23:39:50 -06:00
|
|
|
if kw.get('cli_name', None) is None:
|
|
|
|
kw['cli_name'] = self.name
|
|
|
|
df = kw.get('default_from', None)
|
2008-12-11 21:30:59 -06:00
|
|
|
if callable(df) and not isinstance(df, DefaultFrom):
|
2008-12-11 23:39:50 -06:00
|
|
|
kw['default_from'] = DefaultFrom(df)
|
|
|
|
self.__clonekw = kw
|
|
|
|
self.kwargs += (('default', self.type, None),)
|
|
|
|
for (key, kind, default) in self.kwargs:
|
|
|
|
value = kw.get(key, default)
|
|
|
|
if value is not None:
|
2008-12-11 19:07:54 -06:00
|
|
|
if (
|
2008-12-11 21:30:59 -06:00
|
|
|
type(kind) is type and type(value) is not kind
|
|
|
|
or
|
2008-12-11 19:07:54 -06:00
|
|
|
type(kind) is tuple and not isinstance(value, kind)
|
|
|
|
):
|
|
|
|
raise TypeError(
|
|
|
|
TYPE_ERROR % (key, kind, value, type(value))
|
|
|
|
)
|
|
|
|
elif kind is callable and not callable(value):
|
|
|
|
raise TypeError(
|
|
|
|
CALLABLE_ERROR % (key, value, type(value))
|
|
|
|
)
|
|
|
|
if hasattr(self, key):
|
|
|
|
raise ValueError('kwarg %r conflicts with attribute on %s' % (
|
|
|
|
key, self.__class__.__name__)
|
|
|
|
)
|
|
|
|
setattr(self, key, value)
|
2008-12-11 21:30:59 -06:00
|
|
|
check_name(self.cli_name)
|
2008-12-10 22:14:05 -06:00
|
|
|
lock(self)
|
|
|
|
|
|
|
|
def normalize(self, value):
|
|
|
|
"""
|
2008-12-11 21:30:59 -06:00
|
|
|
Normalize ``value`` using normalizer callback.
|
|
|
|
|
|
|
|
For example:
|
|
|
|
|
|
|
|
>>> param = Str('telephone',
|
|
|
|
... normalizer=lambda value: value.replace('.', '-')
|
|
|
|
... )
|
|
|
|
>>> param.normalize(u'800.123.4567')
|
|
|
|
u'800-123-4567'
|
|
|
|
|
|
|
|
(Note that `Str` is a subclass of `Param`.)
|
|
|
|
|
|
|
|
If this `Param` instance was created with a normalizer callback and
|
|
|
|
``value`` is a unicode instance, the normalizer callback is called and
|
|
|
|
*its* return value is returned.
|
|
|
|
|
|
|
|
On the other hand, if this `Param` instance was *not* created with a
|
|
|
|
normalizer callback, if ``value`` is *not* a unicode instance, or if an
|
|
|
|
exception is caught when calling the normalizer callback, ``value`` is
|
|
|
|
returned unchanged.
|
|
|
|
|
|
|
|
:param value: A proposed value for this parameter.
|
2008-12-10 22:14:05 -06:00
|
|
|
"""
|
2008-12-11 21:30:59 -06:00
|
|
|
if self.normalizer is None:
|
2008-12-10 22:14:05 -06:00
|
|
|
return value
|
|
|
|
if self.multivalue:
|
|
|
|
if type(value) in (tuple, list):
|
|
|
|
return tuple(
|
|
|
|
self.__normalize_scalar(v) for v in value
|
|
|
|
)
|
|
|
|
return (self.__normalize_scalar(value),) # Return a tuple
|
|
|
|
return self.__normalize_scalar(value)
|
|
|
|
|
|
|
|
def __normalize_scalar(self, value):
|
|
|
|
"""
|
|
|
|
Normalize a scalar value.
|
|
|
|
|
2008-12-11 23:39:50 -06:00
|
|
|
This method is called once for each value in a multivalue.
|
2008-12-10 22:14:05 -06:00
|
|
|
"""
|
|
|
|
if type(value) is not unicode:
|
|
|
|
return value
|
|
|
|
try:
|
2008-12-11 21:30:59 -06:00
|
|
|
return self.normalizer(value)
|
2008-12-10 22:14:05 -06:00
|
|
|
except StandardError:
|
|
|
|
return value
|
|
|
|
|
|
|
|
def convert(self, value):
|
|
|
|
if value in NULLS:
|
|
|
|
return
|
|
|
|
if self.multivalue:
|
|
|
|
if type(value) in (tuple, list):
|
|
|
|
values = filter(
|
|
|
|
lambda val: val not in NULLS,
|
|
|
|
(self._convert_scalar(v, i) for (i, v) in enumerate(value))
|
|
|
|
)
|
|
|
|
if len(values) == 0:
|
|
|
|
return
|
|
|
|
return tuple(values)
|
|
|
|
return (scalar(value, 0),) # Return a tuple
|
|
|
|
return scalar(value)
|
|
|
|
|
|
|
|
def _convert_scalar(self, value, index=None):
|
|
|
|
"""
|
|
|
|
Implement in subclass.
|
|
|
|
"""
|
|
|
|
raise NotImplementedError(
|
|
|
|
'%s.%s()' % (self.__class__.__name__, '_convert_scalar')
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
class Bool(Param):
|
|
|
|
"""
|
|
|
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
|
|
class Int(Param):
|
|
|
|
"""
|
|
|
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
|
|
class Float(Param):
|
|
|
|
"""
|
|
|
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
|
|
class Bytes(Param):
|
|
|
|
"""
|
|
|
|
|
|
|
|
"""
|
|
|
|
|
2008-12-11 23:39:50 -06:00
|
|
|
type = str
|
|
|
|
|
|
|
|
def __init__(self, name, **kw):
|
|
|
|
kwargs = dict(
|
|
|
|
minlength=(int, None),
|
|
|
|
maxlength=(int, None),
|
|
|
|
length=(int, None),
|
|
|
|
pattern=(str, None),
|
|
|
|
)
|
|
|
|
|
|
|
|
|
2008-12-10 22:14:05 -06:00
|
|
|
|
|
|
|
class Str(Param):
|
|
|
|
"""
|
|
|
|
|
|
|
|
"""
|
|
|
|
|
2008-12-11 23:39:50 -06:00
|
|
|
type = unicode
|
|
|
|
|
|
|
|
def __init__(self, name, **kw):
|
|
|
|
super(Str, self).__init__(name, **kw)
|
2008-12-10 22:14:05 -06:00
|
|
|
|
|
|
|
def _convert_scalar(self, value, index=None):
|
|
|
|
if type(value) in (self.type, int, float, bool):
|
|
|
|
return self.type(value)
|
|
|
|
raise TypeError(
|
|
|
|
'Can only implicitly convert int, float, or bool; got %r' % value
|
|
|
|
)
|