mirror of
https://salsa.debian.org/freeipa-team/freeipa.git
synced 2024-12-25 16:31:08 -06:00
2da6d6e746
A forwardable ticket is still required but we no longer need to send the TGT to the IPA server. A new flag, --delegate, is available if the old behavior is required. Set the minimum n-v-r for mod_auth_kerb and krb5-server to pick up needed patches for S4U2Proxy to work. https://fedorahosted.org/freeipa/ticket/1098 https://fedorahosted.org/freeipa/ticket/2246
733 lines
25 KiB
Python
733 lines
25 KiB
Python
# 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, either version 3 of the License, or
|
|
# (at your option) any later version.
|
|
#
|
|
# 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, see <http://www.gnu.org/licenses/>.
|
|
|
|
"""
|
|
Plugin framework.
|
|
|
|
The classes in this module make heavy use of Python container emulation. If
|
|
you are unfamiliar with this Python feature, see
|
|
http://docs.python.org/ref/sequence-types.html
|
|
"""
|
|
|
|
import re
|
|
import sys
|
|
import inspect
|
|
import threading
|
|
import os
|
|
from os import path
|
|
import subprocess
|
|
import optparse
|
|
import errors
|
|
from config import Env
|
|
import util
|
|
import text
|
|
from text import _
|
|
from base import ReadOnly, NameSpace, lock, islocked, check_name
|
|
from constants import DEFAULT_CONFIG
|
|
from ipapython.ipa_log_manager import *
|
|
|
|
# FIXME: Updated constants.TYPE_ERROR to use this clearer format from wehjit:
|
|
TYPE_ERROR = '%s: need a %r; got a %r: %r'
|
|
|
|
def is_production_mode(obj):
|
|
"""
|
|
If the object has self.env.mode defined and that mode is
|
|
production return True, otherwise return False.
|
|
"""
|
|
if getattr(obj, 'env', None) is None:
|
|
return False
|
|
if getattr(obj.env, 'mode', None) is None:
|
|
return False
|
|
return obj.env.mode == 'production'
|
|
|
|
|
|
class SetProxy(ReadOnly):
|
|
"""
|
|
A read-only container with set/sequence behaviour.
|
|
|
|
This container acts as a proxy to an actual set-like object (a set,
|
|
frozenset, or dict) that is passed to the constructor. To the extent
|
|
possible in Python, this underlying set-like object cannot be modified
|
|
through the SetProxy... which just means you wont do it accidentally.
|
|
"""
|
|
def __init__(self, s):
|
|
"""
|
|
:param s: The target set-like object (a set, frozenset, or dict)
|
|
"""
|
|
allowed = (set, frozenset, dict)
|
|
if type(s) not in allowed:
|
|
raise TypeError('%r not in %r' % (type(s), allowed))
|
|
self.__s = s
|
|
if not is_production_mode(self):
|
|
lock(self)
|
|
|
|
def __len__(self):
|
|
"""
|
|
Return the number of items in this container.
|
|
"""
|
|
return len(self.__s)
|
|
|
|
def __iter__(self):
|
|
"""
|
|
Iterate (in ascending order) through keys.
|
|
"""
|
|
for key in sorted(self.__s):
|
|
yield key
|
|
|
|
def __contains__(self, key):
|
|
"""
|
|
Return True if this container contains ``key``.
|
|
|
|
:param key: The key to test for membership.
|
|
"""
|
|
return key in self.__s
|
|
|
|
|
|
class DictProxy(SetProxy):
|
|
"""
|
|
A read-only container with mapping behaviour.
|
|
|
|
This container acts as a proxy to an actual mapping object (a dict) that
|
|
is passed to the constructor. To the extent possible in Python, this
|
|
underlying mapping object cannot be modified through the DictProxy...
|
|
which just means you wont do it accidentally.
|
|
|
|
Also see `SetProxy`.
|
|
"""
|
|
def __init__(self, d):
|
|
"""
|
|
:param d: The target mapping object (a dict)
|
|
"""
|
|
if type(d) is not dict:
|
|
raise TypeError('%r is not %r' % (type(d), dict))
|
|
self.__d = d
|
|
super(DictProxy, self).__init__(d)
|
|
|
|
def __getitem__(self, key):
|
|
"""
|
|
Return the value corresponding to ``key``.
|
|
|
|
:param key: The key of the value you wish to retrieve.
|
|
"""
|
|
return self.__d[key]
|
|
|
|
def __call__(self):
|
|
"""
|
|
Iterate (in ascending order by key) through values.
|
|
"""
|
|
for key in self:
|
|
yield self.__d[key]
|
|
|
|
|
|
class MagicDict(DictProxy):
|
|
"""
|
|
A mapping container whose values can be accessed as attributes.
|
|
|
|
For example:
|
|
|
|
>>> magic = MagicDict({'the_key': 'the value'})
|
|
>>> magic['the_key']
|
|
'the value'
|
|
>>> magic.the_key
|
|
'the value'
|
|
|
|
This container acts as a proxy to an actual mapping object (a dict) that
|
|
is passed to the constructor. To the extent possible in Python, this
|
|
underlying mapping object cannot be modified through the MagicDict...
|
|
which just means you wont do it accidentally.
|
|
|
|
Also see `DictProxy` and `SetProxy`.
|
|
"""
|
|
|
|
def __getattr__(self, name):
|
|
"""
|
|
Return the value corresponding to ``name``.
|
|
|
|
:param name: The name of the attribute you wish to retrieve.
|
|
"""
|
|
try:
|
|
return self[name]
|
|
except KeyError:
|
|
raise AttributeError('no magic attribute %r' % name)
|
|
|
|
|
|
class Plugin(ReadOnly):
|
|
"""
|
|
Base class for all plugins.
|
|
"""
|
|
|
|
finalize_early = True
|
|
|
|
label = None
|
|
|
|
def __init__(self):
|
|
self.__api = None
|
|
self.__finalize_called = False
|
|
self.__finalized = False
|
|
self.__finalize_lock = threading.RLock()
|
|
cls = self.__class__
|
|
self.name = cls.__name__
|
|
self.module = cls.__module__
|
|
self.fullname = '%s.%s' % (self.module, self.name)
|
|
self.bases = tuple(
|
|
'%s.%s' % (b.__module__, b.__name__) for b in cls.__bases__
|
|
)
|
|
self.doc = _(cls.__doc__)
|
|
if not self.doc.msg:
|
|
self.summary = '<%s>' % self.fullname
|
|
else:
|
|
self.summary = unicode(self.doc).split('\n\n', 1)[0].strip()
|
|
log_mgr.get_logger(self, True)
|
|
if self.label is None:
|
|
self.label = text.FixMe(self.name + '.label')
|
|
if not isinstance(self.label, text.LazyText):
|
|
raise TypeError(
|
|
TYPE_ERROR % (
|
|
self.fullname + '.label',
|
|
text.LazyText,
|
|
type(self.label),
|
|
self.label
|
|
)
|
|
)
|
|
|
|
def __get_api(self):
|
|
"""
|
|
Return `API` instance passed to `set_api()`.
|
|
|
|
If `set_api()` has not yet been called, None is returned.
|
|
"""
|
|
return self.__api
|
|
api = property(__get_api)
|
|
|
|
def finalize(self):
|
|
"""
|
|
Finalize plugin initialization.
|
|
|
|
This method calls `_on_finalize()` and locks the plugin object.
|
|
|
|
Subclasses should not override this method. Custom finalization is done
|
|
in `_on_finalize()`.
|
|
"""
|
|
with self.__finalize_lock:
|
|
assert self.__finalized is False
|
|
if self.__finalize_called:
|
|
# No recursive calls!
|
|
return
|
|
self.__finalize_called = True
|
|
self._on_finalize()
|
|
self.__finalized = True
|
|
if not is_production_mode(self):
|
|
lock(self)
|
|
|
|
def _on_finalize(self):
|
|
"""
|
|
Do custom finalization.
|
|
|
|
This method is called from `finalize()`. Subclasses can override this
|
|
method in order to add custom finalization.
|
|
"""
|
|
pass
|
|
|
|
def ensure_finalized(self):
|
|
"""
|
|
Finalize plugin initialization if it has not yet been finalized.
|
|
"""
|
|
with self.__finalize_lock:
|
|
if not self.__finalized:
|
|
self.finalize()
|
|
|
|
class finalize_attr(object):
|
|
"""
|
|
Create a stub object for plugin attribute that isn't set until the
|
|
finalization of the plugin initialization.
|
|
|
|
When the stub object is accessed, it calls `ensure_finalized()` to make
|
|
sure the plugin initialization is finalized. The stub object is expected
|
|
to be replaced with the actual attribute value during the finalization
|
|
(preferably in `_on_finalize()`), otherwise an `AttributeError` is
|
|
raised.
|
|
|
|
This is used to implement on-demand finalization of plugin
|
|
initialization.
|
|
"""
|
|
__slots__ = ('name', 'value')
|
|
|
|
def __init__(self, name, value=None):
|
|
self.name = name
|
|
self.value = value
|
|
|
|
def __get__(self, obj, cls):
|
|
if obj is None or obj.api is None:
|
|
return self.value
|
|
obj.ensure_finalized()
|
|
try:
|
|
return getattr(obj, self.name)
|
|
except RuntimeError:
|
|
# If the actual attribute value is not set in _on_finalize(),
|
|
# getattr() calls __get__() again, which leads to infinite
|
|
# recursion. This can happen only if the plugin is written
|
|
# badly, so advise the developer about that instead of giving
|
|
# them a generic "maximum recursion depth exceeded" error.
|
|
raise AttributeError(
|
|
"attribute '%s' of plugin '%s' was not set in finalize()" % (self.name, obj.name)
|
|
)
|
|
|
|
def set_api(self, api):
|
|
"""
|
|
Set reference to `API` instance.
|
|
"""
|
|
assert self.__api is None, 'set_api() can only be called once'
|
|
assert api is not None, 'set_api() argument cannot be None'
|
|
self.__api = api
|
|
if not isinstance(api, API):
|
|
return
|
|
for name in api:
|
|
assert not hasattr(self, name)
|
|
setattr(self, name, api[name])
|
|
for name in ('env', 'context'):
|
|
if hasattr(api, name):
|
|
assert not hasattr(self, name)
|
|
setattr(self, name, getattr(api, name))
|
|
|
|
def call(self, executable, *args):
|
|
"""
|
|
Call ``executable`` with ``args`` using subprocess.call().
|
|
|
|
If the call exits with a non-zero exit status,
|
|
`ipalib.errors.SubprocessError` is raised, from which you can retrieve
|
|
the exit code by checking the SubprocessError.returncode attribute.
|
|
|
|
This method does *not* return what ``executable`` sent to stdout... for
|
|
that, use `Plugin.callread()`.
|
|
"""
|
|
argv = (executable,) + args
|
|
self.debug('Calling %r', argv)
|
|
code = subprocess.call(argv)
|
|
if code != 0:
|
|
raise errors.SubprocessError(returncode=code, argv=argv)
|
|
|
|
def __repr__(self):
|
|
"""
|
|
Return 'module_name.class_name()' representation.
|
|
|
|
This representation could be used to instantiate this Plugin
|
|
instance given the appropriate environment.
|
|
"""
|
|
return '%s.%s()' % (
|
|
self.__class__.__module__,
|
|
self.__class__.__name__
|
|
)
|
|
|
|
|
|
class Registrar(DictProxy):
|
|
"""
|
|
Collects plugin classes as they are registered.
|
|
|
|
The Registrar does not instantiate plugins... it only implements the
|
|
override logic and stores the plugins in a namespace per allowed base
|
|
class.
|
|
|
|
The plugins are instantiated when `API.finalize()` is called.
|
|
"""
|
|
def __init__(self, *allowed):
|
|
"""
|
|
:param allowed: Base classes from which plugins accepted by this
|
|
Registrar must subclass.
|
|
"""
|
|
self.__allowed = dict((base, {}) for base in allowed)
|
|
self.__registered = set()
|
|
super(Registrar, self).__init__(
|
|
dict(self.__base_iter())
|
|
)
|
|
|
|
def __base_iter(self):
|
|
for (base, sub_d) in self.__allowed.iteritems():
|
|
if not is_production_mode(self):
|
|
assert inspect.isclass(base)
|
|
name = base.__name__
|
|
if not is_production_mode(self):
|
|
assert not hasattr(self, name)
|
|
setattr(self, name, MagicDict(sub_d))
|
|
yield (name, base)
|
|
|
|
def __findbases(self, klass):
|
|
"""
|
|
Iterates through allowed bases that ``klass`` is a subclass of.
|
|
|
|
Raises `errors.PluginSubclassError` if ``klass`` is not a subclass of
|
|
any allowed base.
|
|
|
|
:param klass: The plugin class to find bases for.
|
|
"""
|
|
if not is_production_mode(self):
|
|
assert inspect.isclass(klass)
|
|
found = False
|
|
for (base, sub_d) in self.__allowed.iteritems():
|
|
if issubclass(klass, base):
|
|
found = True
|
|
yield (base, sub_d)
|
|
if not found:
|
|
raise errors.PluginSubclassError(
|
|
plugin=klass, bases=self.__allowed.keys()
|
|
)
|
|
|
|
def __call__(self, klass, override=False):
|
|
"""
|
|
Register the plugin ``klass``.
|
|
|
|
:param klass: A subclass of `Plugin` to attempt to register.
|
|
:param override: If true, override an already registered plugin.
|
|
"""
|
|
if not inspect.isclass(klass):
|
|
raise TypeError('plugin must be a class; got %r' % klass)
|
|
|
|
# Raise DuplicateError if this exact class was already registered:
|
|
if klass in self.__registered:
|
|
raise errors.PluginDuplicateError(plugin=klass)
|
|
|
|
# Find the base class or raise SubclassError:
|
|
for (base, sub_d) in self.__findbases(klass):
|
|
# Check override:
|
|
if klass.__name__ in sub_d:
|
|
if not override:
|
|
# Must use override=True to override:
|
|
raise errors.PluginOverrideError(
|
|
base=base.__name__,
|
|
name=klass.__name__,
|
|
plugin=klass,
|
|
)
|
|
else:
|
|
if override:
|
|
# There was nothing already registered to override:
|
|
raise errors.PluginMissingOverrideError(
|
|
base=base.__name__,
|
|
name=klass.__name__,
|
|
plugin=klass,
|
|
)
|
|
|
|
# The plugin is okay, add to sub_d:
|
|
sub_d[klass.__name__] = klass
|
|
|
|
# The plugin is okay, add to __registered:
|
|
self.__registered.add(klass)
|
|
|
|
|
|
class API(DictProxy):
|
|
"""
|
|
Dynamic API object through which `Plugin` instances are accessed.
|
|
"""
|
|
|
|
def __init__(self, *allowed):
|
|
self.__d = dict()
|
|
self.__done = set()
|
|
self.register = Registrar(*allowed)
|
|
self.env = Env()
|
|
super(API, self).__init__(self.__d)
|
|
|
|
def __doing(self, name):
|
|
if name in self.__done:
|
|
raise StandardError(
|
|
'%s.%s() already called' % (self.__class__.__name__, name)
|
|
)
|
|
self.__done.add(name)
|
|
|
|
def __do_if_not_done(self, name):
|
|
if name not in self.__done:
|
|
getattr(self, name)()
|
|
|
|
def isdone(self, name):
|
|
return name in self.__done
|
|
|
|
def bootstrap(self, **overrides):
|
|
"""
|
|
Initialize environment variables and logging.
|
|
"""
|
|
self.__doing('bootstrap')
|
|
self.env._bootstrap(**overrides)
|
|
self.env._finalize_core(**dict(DEFAULT_CONFIG))
|
|
object.__setattr__(self, 'log_mgr', log_mgr)
|
|
log = log_mgr.root_logger
|
|
object.__setattr__(self, 'log', log)
|
|
# If logging has already been configured somewhere else (like in the
|
|
# installer), don't add handlers or change levels:
|
|
if log_mgr.configure_state != 'default' or self.env.validate_api:
|
|
return
|
|
|
|
log_mgr.default_level = 'info'
|
|
log_mgr.configure_from_env(self.env, configure_state='api')
|
|
# Add stderr handler:
|
|
level = 'info'
|
|
if self.env.debug:
|
|
level = 'debug'
|
|
else:
|
|
if self.env.context == 'cli':
|
|
if self.env.verbose > 0:
|
|
level = 'info'
|
|
else:
|
|
level = 'warning'
|
|
|
|
if log_mgr.handlers.has_key('console'):
|
|
log_mgr.remove_handler('console')
|
|
log_mgr.create_log_handlers([dict(name='console',
|
|
stream=sys.stderr,
|
|
level=level,
|
|
format=LOGGING_FORMAT_STDERR)])
|
|
# Add file handler:
|
|
if self.env.mode in ('dummy', 'unit_test'):
|
|
return # But not if in unit-test mode
|
|
if self.env.log is None:
|
|
return
|
|
log_dir = path.dirname(self.env.log)
|
|
if not path.isdir(log_dir):
|
|
try:
|
|
os.makedirs(log_dir)
|
|
except OSError:
|
|
log.error('Could not create log_dir %r', log_dir)
|
|
return
|
|
|
|
|
|
level = 'info'
|
|
if self.env.debug:
|
|
level = 'debug'
|
|
try:
|
|
log_mgr.create_log_handlers([dict(name='file',
|
|
filename=self.env.log,
|
|
level=level,
|
|
format=LOGGING_FORMAT_FILE)])
|
|
except IOError, e:
|
|
log.error('Cannot open log file %r: %s', self.env.log, e)
|
|
return
|
|
|
|
def build_global_parser(self, parser=None, context=None):
|
|
"""
|
|
Add global options to an optparse.OptionParser instance.
|
|
"""
|
|
if parser is None:
|
|
parser = optparse.OptionParser()
|
|
parser.disable_interspersed_args()
|
|
parser.add_option('-e', dest='env', metavar='KEY=VAL', action='append',
|
|
help='Set environment variable KEY to VAL',
|
|
)
|
|
parser.add_option('-c', dest='conf', metavar='FILE',
|
|
help='Load configuration from FILE',
|
|
)
|
|
parser.add_option('-d', '--debug', action='store_true',
|
|
help='Produce full debuging output',
|
|
)
|
|
parser.add_option('--delegate', action='store_true',
|
|
help='Delegate the TGT to the IPA server',
|
|
)
|
|
parser.add_option('-v', '--verbose', action='count',
|
|
help='Produce more verbose output. A second -v displays the XML-RPC request',
|
|
)
|
|
if context == 'cli':
|
|
parser.add_option('-a', '--prompt-all', action='store_true',
|
|
help='Prompt for ALL values (even if optional)'
|
|
)
|
|
parser.add_option('-n', '--no-prompt', action='store_false',
|
|
dest='interactive',
|
|
help='Prompt for NO values (even if required)'
|
|
)
|
|
parser.add_option('-f', '--no-fallback', action='store_false',
|
|
dest='fallback',
|
|
help='Only use the server configured in /etc/ipa/default.conf'
|
|
)
|
|
topics = optparse.OptionGroup(parser, "Available help topics",
|
|
"ipa help topics")
|
|
cmds = optparse.OptionGroup(parser, "Available commands",
|
|
"ipa help commands")
|
|
parser.add_option_group(topics)
|
|
parser.add_option_group(cmds)
|
|
|
|
return parser
|
|
|
|
def bootstrap_with_global_options(self, parser=None, context=None):
|
|
parser = self.build_global_parser(parser, context)
|
|
(options, args) = parser.parse_args()
|
|
overrides = {}
|
|
if options.env is not None:
|
|
assert type(options.env) is list
|
|
for item in options.env:
|
|
try:
|
|
(key, value) = item.split('=', 1)
|
|
except ValueError:
|
|
# FIXME: this should raise an IPA exception with an
|
|
# error code.
|
|
# --Jason, 2008-10-31
|
|
pass
|
|
overrides[str(key.strip())] = value.strip()
|
|
for key in ('conf', 'debug', 'verbose', 'prompt_all', 'interactive',
|
|
'fallback', 'delegate'):
|
|
value = getattr(options, key, None)
|
|
if value is not None:
|
|
overrides[key] = value
|
|
if hasattr(options, 'prod'):
|
|
overrides['webui_prod'] = options.prod
|
|
if context is not None:
|
|
overrides['context'] = context
|
|
self.bootstrap(**overrides)
|
|
return (options, args)
|
|
|
|
def load_plugins(self):
|
|
"""
|
|
Load plugins from all standard locations.
|
|
|
|
`API.bootstrap` will automatically be called if it hasn't been
|
|
already.
|
|
"""
|
|
self.__doing('load_plugins')
|
|
self.__do_if_not_done('bootstrap')
|
|
if self.env.mode in ('dummy', 'unit_test'):
|
|
return
|
|
self.import_plugins('ipalib')
|
|
if self.env.in_server:
|
|
self.import_plugins('ipaserver')
|
|
if self.env.context in ('installer', 'updates'):
|
|
self.import_plugins('ipaserver/install/plugins')
|
|
|
|
# FIXME: This method has no unit test
|
|
def import_plugins(self, package):
|
|
"""
|
|
Import modules in ``plugins`` sub-package of ``package``.
|
|
"""
|
|
package = package.replace(os.path.sep, '.')
|
|
subpackage = '%s.plugins' % package
|
|
try:
|
|
parent = __import__(package)
|
|
parts = package.split('.')[1:]
|
|
if parts:
|
|
for part in parts:
|
|
if part == 'plugins':
|
|
plugins = subpackage.plugins
|
|
subpackage = plugins.__name__
|
|
break
|
|
subpackage = parent.__getattribute__(part)
|
|
parent = subpackage
|
|
else:
|
|
plugins = __import__(subpackage).plugins
|
|
except ImportError, e:
|
|
self.log.error(
|
|
'cannot import plugins sub-package %s: %s', subpackage, e
|
|
)
|
|
raise e
|
|
parent_dir = path.dirname(path.abspath(parent.__file__))
|
|
plugins_dir = path.dirname(path.abspath(plugins.__file__))
|
|
if parent_dir == plugins_dir:
|
|
raise errors.PluginsPackageError(
|
|
name=subpackage, file=plugins.__file__
|
|
)
|
|
self.log.debug('importing all plugin modules in %r...', plugins_dir)
|
|
for (name, pyfile) in util.find_modules_in_dir(plugins_dir):
|
|
fullname = '%s.%s' % (subpackage, name)
|
|
self.log.debug('importing plugin module %r', pyfile)
|
|
try:
|
|
__import__(fullname)
|
|
except errors.SkipPluginModule, e:
|
|
self.log.debug(
|
|
'skipping plugin module %s: %s', fullname, e.reason
|
|
)
|
|
except StandardError, e:
|
|
if self.env.startup_traceback:
|
|
import traceback
|
|
self.log.error('could not load plugin module %r\n%s', pyfile, traceback.format_exc())
|
|
raise e
|
|
|
|
def finalize(self):
|
|
"""
|
|
Finalize the registration, instantiate the plugins.
|
|
|
|
`API.bootstrap` will automatically be called if it hasn't been
|
|
already.
|
|
"""
|
|
self.__doing('finalize')
|
|
self.__do_if_not_done('load_plugins')
|
|
|
|
class PluginInstance(object):
|
|
"""
|
|
Represents a plugin instance.
|
|
"""
|
|
|
|
i = 0
|
|
|
|
def __init__(self, klass):
|
|
self.created = self.next()
|
|
self.klass = klass
|
|
self.instance = klass()
|
|
self.bases = []
|
|
|
|
@classmethod
|
|
def next(cls):
|
|
cls.i += 1
|
|
return cls.i
|
|
|
|
class PluginInfo(ReadOnly):
|
|
def __init__(self, p):
|
|
assert isinstance(p, PluginInstance)
|
|
self.created = p.created
|
|
self.name = p.klass.__name__
|
|
self.module = str(p.klass.__module__)
|
|
self.plugin = '%s.%s' % (self.module, self.name)
|
|
self.bases = tuple(b.__name__ for b in p.bases)
|
|
if not is_production_mode(self):
|
|
lock(self)
|
|
|
|
plugins = {}
|
|
tofinalize = set()
|
|
def plugin_iter(base, subclasses):
|
|
for klass in subclasses:
|
|
assert issubclass(klass, base)
|
|
if klass not in plugins:
|
|
plugins[klass] = PluginInstance(klass)
|
|
p = plugins[klass]
|
|
if not is_production_mode(self):
|
|
assert base not in p.bases
|
|
p.bases.append(base)
|
|
if klass.finalize_early or not self.env.plugins_on_demand:
|
|
tofinalize.add(p)
|
|
yield p.instance
|
|
|
|
production_mode = is_production_mode(self)
|
|
for name in self.register:
|
|
base = self.register[name]
|
|
magic = getattr(self.register, name)
|
|
namespace = NameSpace(
|
|
plugin_iter(base, (magic[k] for k in magic))
|
|
)
|
|
if not production_mode:
|
|
assert not (
|
|
name in self.__d or hasattr(self, name)
|
|
)
|
|
self.__d[name] = namespace
|
|
object.__setattr__(self, name, namespace)
|
|
|
|
for p in plugins.itervalues():
|
|
p.instance.set_api(self)
|
|
if not production_mode:
|
|
assert p.instance.api is self
|
|
|
|
for p in tofinalize:
|
|
p.instance.ensure_finalized()
|
|
if not production_mode:
|
|
assert islocked(p.instance) is True
|
|
object.__setattr__(self, '_API__finalized', True)
|
|
tuple(PluginInfo(p) for p in plugins.itervalues())
|
|
object.__setattr__(self, 'plugins',
|
|
tuple(PluginInfo(p) for p in plugins.itervalues())
|
|
)
|