/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/hooks.py

(jelmer) Use the absolute_import feature everywhere in bzrlib,
 and add a source test to make sure it's used everywhere. (Jelmer Vernooij)

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2007-2010 Canonical Ltd
 
1
# Copyright (C) 2007-2011 Canonical Ltd
2
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
16
16
 
17
 
 
18
17
"""Support for plugin hooking logic."""
19
 
from bzrlib import registry
 
18
 
 
19
from __future__ import absolute_import
 
20
 
 
21
from bzrlib import (
 
22
    registry,
 
23
    symbol_versioning,
 
24
    )
20
25
from bzrlib.lazy_import import lazy_import
21
26
lazy_import(globals(), """
22
27
import textwrap
23
28
 
24
29
from bzrlib import (
25
 
        _format_version_tuple,
26
 
        errors,
27
 
        )
28
 
from bzrlib.help_topics import help_as_plain_text
 
30
    _format_version_tuple,
 
31
    errors,
 
32
    pyutils,
 
33
    )
 
34
from bzrlib.i18n import gettext
29
35
""")
30
36
 
31
37
 
32
 
known_hooks = registry.Registry()
33
 
# known_hooks registry contains
34
 
# tuple of (module, member name) which is the hook point
35
 
# module where the specific hooks are defined
36
 
# callable to get the empty specific Hooks for that attribute
37
 
known_hooks.register_lazy(('bzrlib.branch', 'Branch.hooks'), 'bzrlib.branch',
38
 
    'BranchHooks')
39
 
known_hooks.register_lazy(('bzrlib.bzrdir', 'BzrDir.hooks'), 'bzrlib.bzrdir',
40
 
    'BzrDirHooks')
41
 
known_hooks.register_lazy(('bzrlib.commands', 'Command.hooks'),
42
 
    'bzrlib.commands', 'CommandHooks')
43
 
known_hooks.register_lazy(('bzrlib.info', 'hooks'),
44
 
    'bzrlib.info', 'InfoHooks')
45
 
known_hooks.register_lazy(('bzrlib.lock', 'Lock.hooks'), 'bzrlib.lock',
46
 
    'LockHooks')
47
 
known_hooks.register_lazy(('bzrlib.merge', 'Merger.hooks'), 'bzrlib.merge',
48
 
    'MergeHooks')
49
 
known_hooks.register_lazy(('bzrlib.msgeditor', 'hooks'), 'bzrlib.msgeditor',
50
 
    'MessageEditorHooks')
51
 
known_hooks.register_lazy(('bzrlib.mutabletree', 'MutableTree.hooks'),
52
 
    'bzrlib.mutabletree', 'MutableTreeHooks')
53
 
known_hooks.register_lazy(('bzrlib.smart.client', '_SmartClient.hooks'),
54
 
    'bzrlib.smart.client', 'SmartClientHooks')
55
 
known_hooks.register_lazy(('bzrlib.smart.server', 'SmartTCPServer.hooks'),
56
 
    'bzrlib.smart.server', 'SmartServerHooks')
57
 
known_hooks.register_lazy(
58
 
    ('bzrlib.version_info_formats.format_rio', 'RioVersionInfoBuilder.hooks'),
59
 
    'bzrlib.version_info_formats.format_rio', 'RioVersionInfoBuilderHooks')
60
 
known_hooks.register_lazy(
61
 
    ('bzrlib.merge_directive', 'BaseMergeDirective.hooks'),
62
 
    'bzrlib.merge_directive', 'MergeDirectiveHooks')
 
38
class KnownHooksRegistry(registry.Registry):
 
39
    # known_hooks registry contains
 
40
    # tuple of (module, member name) which is the hook point
 
41
    # module where the specific hooks are defined
 
42
    # callable to get the empty specific Hooks for that attribute
 
43
 
 
44
    def register_lazy_hook(self, hook_module_name, hook_member_name,
 
45
            hook_factory_member_name):
 
46
        self.register_lazy((hook_module_name, hook_member_name),
 
47
            hook_module_name, hook_factory_member_name)
 
48
 
 
49
    def iter_parent_objects(self):
 
50
        """Yield (hook_key, (parent_object, attr)) tuples for every registered
 
51
        hook, where 'parent_object' is the object that holds the hook
 
52
        instance.
 
53
 
 
54
        This is useful for resetting/restoring all the hooks to a known state,
 
55
        as is done in bzrlib.tests.TestCase._clear_hooks.
 
56
        """
 
57
        for key in self.keys():
 
58
            yield key, self.key_to_parent_and_attribute(key)
 
59
 
 
60
    def key_to_parent_and_attribute(self, (module_name, member_name)):
 
61
        """Convert a known_hooks key to a (parent_obj, attr) pair.
 
62
 
 
63
        :param key: A tuple (module_name, member_name) as found in the keys of
 
64
            the known_hooks registry.
 
65
        :return: The parent_object of the hook and the name of the attribute on
 
66
            that parent object where the hook is kept.
 
67
        """
 
68
        parent_mod, parent_member, attr = pyutils.calc_parent_name(module_name,
 
69
            member_name)
 
70
        return pyutils.get_named_object(parent_mod, parent_member), attr
 
71
 
 
72
 
 
73
_builtin_known_hooks = (
 
74
    ('bzrlib.branch', 'Branch.hooks', 'BranchHooks'),
 
75
    ('bzrlib.controldir', 'ControlDir.hooks', 'ControlDirHooks'),
 
76
    ('bzrlib.commands', 'Command.hooks', 'CommandHooks'),
 
77
    ('bzrlib.config', 'ConfigHooks', '_ConfigHooks'),
 
78
    ('bzrlib.info', 'hooks', 'InfoHooks'),
 
79
    ('bzrlib.lock', 'Lock.hooks', 'LockHooks'),
 
80
    ('bzrlib.merge', 'Merger.hooks', 'MergeHooks'),
 
81
    ('bzrlib.msgeditor', 'hooks', 'MessageEditorHooks'),
 
82
    ('bzrlib.mutabletree', 'MutableTree.hooks', 'MutableTreeHooks'),
 
83
    ('bzrlib.smart.client', '_SmartClient.hooks', 'SmartClientHooks'),
 
84
    ('bzrlib.smart.server', 'SmartTCPServer.hooks', 'SmartServerHooks'),
 
85
    ('bzrlib.status', 'hooks', 'StatusHooks'),
 
86
    ('bzrlib.version_info_formats.format_rio', 'RioVersionInfoBuilder.hooks',
 
87
        'RioVersionInfoBuilderHooks'),
 
88
    ('bzrlib.merge_directive', 'BaseMergeDirective.hooks',
 
89
        'MergeDirectiveHooks'),
 
90
    )
 
91
 
 
92
known_hooks = KnownHooksRegistry()
 
93
for (_hook_module, _hook_attribute, _hook_class) in _builtin_known_hooks:
 
94
    known_hooks.register_lazy_hook(_hook_module, _hook_attribute, _hook_class)
 
95
del _builtin_known_hooks, _hook_module, _hook_attribute, _hook_class
63
96
 
64
97
 
65
98
def known_hooks_key_to_object((module_name, member_name)):
69
102
        the known_hooks registry.
70
103
    :return: The object this specifies.
71
104
    """
72
 
    return registry._LazyObjectGetter(module_name, member_name).get_obj()
73
 
 
74
 
 
75
 
def known_hooks_key_to_parent_and_attribute((module_name, member_name)):
76
 
    """Convert a known_hooks key to a object.
77
 
 
78
 
    :param key: A tuple (module_name, member_name) as found in the keys of
79
 
        the known_hooks registry.
80
 
    :return: The object this specifies.
81
 
    """
82
 
    member_list = member_name.rsplit('.', 1)
83
 
    if len(member_list) == 2:
84
 
        parent_name, attribute = member_list
85
 
    else:
86
 
        parent_name = None
87
 
        attribute = member_name
88
 
    parent = known_hooks_key_to_object((module_name, parent_name))
89
 
    return parent, attribute
 
105
    return pyutils.get_named_object(module_name, member_name)
 
106
 
 
107
 
 
108
@symbol_versioning.deprecated_function(symbol_versioning.deprecated_in((2, 3)))
 
109
def known_hooks_key_to_parent_and_attribute(key):
 
110
    """See KnownHooksRegistry.key_to_parent_and_attribute."""
 
111
    return known_hooks.key_to_parent_and_attribute(key)
90
112
 
91
113
 
92
114
class Hooks(dict):
96
118
    FOO hook is triggered.
97
119
    """
98
120
 
99
 
    def __init__(self):
 
121
    def __init__(self, module=None, member_name=None):
 
122
        """Create a new hooks dictionary.
 
123
 
 
124
        :param module: The module from which this hooks dictionary should be loaded
 
125
            (used for lazy hooks)
 
126
        :param member_name: Name under which this hooks dictionary should be loaded.
 
127
            (used for lazy hooks)
 
128
        """
100
129
        dict.__init__(self)
101
130
        self._callable_names = {}
102
 
 
 
131
        self._lazy_callable_names = {}
 
132
        self._module = module
 
133
        self._member_name = member_name
 
134
 
 
135
    def add_hook(self, name, doc, introduced, deprecated=None):
 
136
        """Add a hook point to this dictionary.
 
137
 
 
138
        :param name: The name of the hook, for clients to use when registering.
 
139
        :param doc: The docs for the hook.
 
140
        :param introduced: When the hook was introduced (e.g. (0, 15)).
 
141
        :param deprecated: When the hook was deprecated, None for
 
142
            not-deprecated.
 
143
        """
 
144
        if name in self:
 
145
            raise errors.DuplicateKey(name)
 
146
        if self._module:
 
147
            callbacks = _lazy_hooks.setdefault(
 
148
                (self._module, self._member_name, name), [])
 
149
        else:
 
150
            callbacks = None
 
151
        hookpoint = HookPoint(name=name, doc=doc, introduced=introduced,
 
152
                              deprecated=deprecated, callbacks=callbacks)
 
153
        self[name] = hookpoint
 
154
 
 
155
    @symbol_versioning.deprecated_method(symbol_versioning.deprecated_in((2, 4)))
103
156
    def create_hook(self, hook):
104
157
        """Create a hook which can have callbacks registered for it.
105
158
 
145
198
        the code names are rarely meaningful for end users and this is not
146
199
        intended for debugging.
147
200
        """
148
 
        return self._callable_names.get(a_callable, "No hook name")
 
201
        name = self._callable_names.get(a_callable, None)
 
202
        if name is None and a_callable is not None:
 
203
            name = self._lazy_callable_names.get((a_callable.__module__,
 
204
                                                  a_callable.__name__),
 
205
                                                 None)
 
206
        if name is None:
 
207
            return 'No hook name'
 
208
        return name
 
209
 
 
210
 
 
211
    def install_named_hook_lazy(self, hook_name, callable_module,
 
212
        callable_member, name):
 
213
        """Install a_callable in to the hook hook_name lazily, and label it.
 
214
 
 
215
        :param hook_name: A hook name. See the __init__ method for the complete
 
216
            list of hooks.
 
217
        :param callable_module: Name of the module in which the callable is
 
218
            present.
 
219
        :param callable_member: Member name of the callable.
 
220
        :param name: A name to associate the callable with, to show users what
 
221
            is running.
 
222
        """
 
223
        try:
 
224
            hook = self[hook_name]
 
225
        except KeyError:
 
226
            raise errors.UnknownHook(self.__class__.__name__, hook_name)
 
227
        try:
 
228
            hook_lazy = getattr(hook, "hook_lazy")
 
229
        except AttributeError:
 
230
            raise errors.UnsupportedOperation(self.install_named_hook_lazy,
 
231
                self)
 
232
        else:
 
233
            hook_lazy(callable_module, callable_member, name)
 
234
        if name is not None:
 
235
            self.name_hook_lazy(callable_module, callable_member, name)
149
236
 
150
237
    def install_named_hook(self, hook_name, a_callable, name):
151
238
        """Install a_callable in to the hook hook_name, and label it name.
152
239
 
153
 
        :param hook_name: A hook name. See the __init__ method of BranchHooks
154
 
            for the complete list of hooks.
 
240
        :param hook_name: A hook name. See the __init__ method for the complete
 
241
            list of hooks.
155
242
        :param a_callable: The callable to be invoked when the hook triggers.
156
243
            The exact signature will depend on the hook - see the __init__
157
 
            method of BranchHooks for details on each hook.
 
244
            method for details on each hook.
158
245
        :param name: A name to associate a_callable with, to show users what is
159
246
            running.
160
247
        """
170
257
        if name is not None:
171
258
            self.name_hook(a_callable, name)
172
259
 
 
260
    def uninstall_named_hook(self, hook_name, label):
 
261
        """Uninstall named hooks.
 
262
 
 
263
        :param hook_name: Hook point name
 
264
        :param label: Label of the callable to uninstall
 
265
        """
 
266
        try:
 
267
            hook = self[hook_name]
 
268
        except KeyError:
 
269
            raise errors.UnknownHook(self.__class__.__name__, hook_name)
 
270
        try:
 
271
            uninstall = getattr(hook, "uninstall")
 
272
        except AttributeError:
 
273
            raise errors.UnsupportedOperation(self.uninstall_named_hook, self)
 
274
        else:
 
275
            uninstall(label)
 
276
 
173
277
    def name_hook(self, a_callable, name):
174
278
        """Associate name with a_callable to show users what is running."""
175
279
        self._callable_names[a_callable] = name
176
280
 
 
281
    def name_hook_lazy(self, callable_module, callable_member, callable_name):
 
282
        self._lazy_callable_names[(callable_module, callable_member)]= \
 
283
            callable_name
 
284
 
177
285
 
178
286
class HookPoint(object):
179
287
    """A single hook that clients can register to be called back when it fires.
180
288
 
181
289
    :ivar name: The name of the hook.
 
290
    :ivar doc: The docs for using the hook.
182
291
    :ivar introduced: A version tuple specifying what version the hook was
183
292
        introduced in. None indicates an unknown version.
184
293
    :ivar deprecated: A version tuple specifying what version the hook was
185
294
        deprecated or superseded in. None indicates that the hook is not
186
295
        superseded or deprecated. If the hook is superseded then the doc
187
296
        should describe the recommended replacement hook to register for.
188
 
    :ivar doc: The docs for using the hook.
189
297
    """
190
298
 
191
 
    def __init__(self, name, doc, introduced, deprecated):
 
299
    def __init__(self, name, doc, introduced, deprecated=None, callbacks=None):
192
300
        """Create a HookPoint.
193
301
 
194
302
        :param name: The name of the hook, for clients to use when registering.
201
309
        self.__doc__ = doc
202
310
        self.introduced = introduced
203
311
        self.deprecated = deprecated
204
 
        self._callbacks = []
205
 
        self._callback_names = {}
 
312
        if callbacks is None:
 
313
            self._callbacks = []
 
314
        else:
 
315
            self._callbacks = callbacks
206
316
 
207
317
    def docs(self):
208
318
        """Generate the documentation for this HookPoint.
217
327
            introduced_string = _format_version_tuple(self.introduced)
218
328
        else:
219
329
            introduced_string = 'unknown'
220
 
        strings.append('Introduced in: %s' % introduced_string)
 
330
        strings.append(gettext('Introduced in: %s') % introduced_string)
221
331
        if self.deprecated:
222
332
            deprecated_string = _format_version_tuple(self.deprecated)
223
 
            strings.append('Deprecated in: %s' % deprecated_string)
 
333
            strings.append(gettext('Deprecated in: %s') % deprecated_string)
224
334
        strings.append('')
225
335
        strings.extend(textwrap.wrap(self.__doc__,
226
336
            break_long_words=False))
228
338
        return '\n'.join(strings)
229
339
 
230
340
    def __eq__(self, other):
231
 
        return (type(other) == type(self) and 
232
 
            other.__dict__ == self.__dict__)
 
341
        return (type(other) == type(self) and other.__dict__ == self.__dict__)
 
342
 
 
343
    def hook_lazy(self, callback_module, callback_member, callback_label):
 
344
        """Lazily register a callback to be called when this HookPoint fires.
 
345
 
 
346
        :param callback_module: Module of the callable to use when this
 
347
            HookPoint fires.
 
348
        :param callback_member: Member name of the callback.
 
349
        :param callback_label: A label to show in the UI while this callback is
 
350
            processing.
 
351
        """
 
352
        obj_getter = registry._LazyObjectGetter(callback_module,
 
353
            callback_member)
 
354
        self._callbacks.append((obj_getter, callback_label))
233
355
 
234
356
    def hook(self, callback, callback_label):
235
357
        """Register a callback to be called when this HookPoint fires.
238
360
        :param callback_label: A label to show in the UI while this callback is
239
361
            processing.
240
362
        """
241
 
        self._callbacks.append(callback)
242
 
        if callback_label is not None:
243
 
            self._callback_names[callback] = callback_label
 
363
        obj_getter = registry._ObjectGetter(callback)
 
364
        self._callbacks.append((obj_getter, callback_label))
 
365
 
 
366
    def uninstall(self, label):
 
367
        """Uninstall the callback with the specified label.
 
368
 
 
369
        :param label: Label of the entry to uninstall
 
370
        """
 
371
        entries_to_remove = []
 
372
        for entry in self._callbacks:
 
373
            (entry_callback, entry_label) = entry
 
374
            if entry_label == label:
 
375
                entries_to_remove.append(entry)
 
376
        if entries_to_remove == []:
 
377
            raise KeyError("No entry with label %r" % label)
 
378
        for entry in entries_to_remove:
 
379
            self._callbacks.remove(entry)
244
380
 
245
381
    def __iter__(self):
246
 
        return iter(self._callbacks)
 
382
        return (callback.get_obj() for callback, name in self._callbacks)
247
383
 
248
384
    def __len__(self):
249
385
        return len(self._callbacks)
253
389
        strings.append("<%s(" % type(self).__name__)
254
390
        strings.append(self.name)
255
391
        strings.append("), callbacks=[")
256
 
        for callback in self._callbacks:
257
 
            strings.append(repr(callback))
 
392
        callbacks = self._callbacks
 
393
        for (callback, callback_name) in callbacks:
 
394
            strings.append(repr(callback.get_obj()))
258
395
            strings.append("(")
259
 
            strings.append(self._callback_names[callback])
 
396
            strings.append(callback_name)
260
397
            strings.append("),")
261
 
        if len(self._callbacks) == 1:
 
398
        if len(callbacks) == 1:
262
399
            strings[-1] = ")"
263
400
        strings.append("]>")
264
401
        return ''.join(strings)
276
413
 
277
414
  yyy.hooks.install_named_hook("xxx", ...)
278
415
 
279
 
See `Using hooks`_ in the User Guide for examples.
280
 
 
281
 
.. _Using hooks: ../user-guide/hooks.html
 
416
See :doc:`Using hooks<../user-guide/hooks>` in the User Guide for examples.
282
417
 
283
418
The class that contains each hook is given before the hooks it supplies. For
284
419
instance, BranchHooks as the class is the hooks class for
305
440
        hooks = known_hooks_key_to_object(hook_key)
306
441
        segments.append(hooks.docs())
307
442
    return '\n'.join(segments)
 
443
 
 
444
 
 
445
# Lazily registered hooks. Maps (module, name, hook_name) tuples
 
446
# to lists of tuples with objectgetters and names
 
447
_lazy_hooks = {}
 
448
 
 
449
 
 
450
def install_lazy_named_hook(hookpoints_module, hookpoints_name, hook_name,
 
451
    a_callable, name):
 
452
    """Install a callable in to a hook lazily, and label it name.
 
453
 
 
454
    :param hookpoints_module: Module name of the hook points.
 
455
    :param hookpoints_name: Name of the hook points.
 
456
    :param hook_name: A hook name.
 
457
    :param callable: a callable to call for the hook.
 
458
    :param name: A name to associate a_callable with, to show users what is
 
459
        running.
 
460
    """
 
461
    key = (hookpoints_module, hookpoints_name, hook_name)
 
462
    obj_getter = registry._ObjectGetter(a_callable)
 
463
    _lazy_hooks.setdefault(key, []).append((obj_getter, name))