~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/hooks.py

  • Committer: Jelmer Vernooij
  • Date: 2012-01-24 13:14:06 UTC
  • mto: (6445.4.5 nested-trees-spec)
  • mto: This revision was merged to the branch mainline in revision 6518.
  • Revision ID: jelmer@samba.org-20120124131406-wedftkorbpv37bm0
Import nested tree doc from devnotes.

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.transport', 'Transport.hooks', 'TransportHooks'),
 
87
    ('bzrlib.version_info_formats.format_rio', 'RioVersionInfoBuilder.hooks',
 
88
        'RioVersionInfoBuilderHooks'),
 
89
    ('bzrlib.merge_directive', 'BaseMergeDirective.hooks',
 
90
        'MergeDirectiveHooks'),
 
91
    )
 
92
 
 
93
known_hooks = KnownHooksRegistry()
 
94
for (_hook_module, _hook_attribute, _hook_class) in _builtin_known_hooks:
 
95
    known_hooks.register_lazy_hook(_hook_module, _hook_attribute, _hook_class)
 
96
del _builtin_known_hooks, _hook_module, _hook_attribute, _hook_class
63
97
 
64
98
 
65
99
def known_hooks_key_to_object((module_name, member_name)):
69
103
        the known_hooks registry.
70
104
    :return: The object this specifies.
71
105
    """
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
 
106
    return pyutils.get_named_object(module_name, member_name)
 
107
 
 
108
 
 
109
@symbol_versioning.deprecated_function(symbol_versioning.deprecated_in((2, 3)))
 
110
def known_hooks_key_to_parent_and_attribute(key):
 
111
    """See KnownHooksRegistry.key_to_parent_and_attribute."""
 
112
    return known_hooks.key_to_parent_and_attribute(key)
90
113
 
91
114
 
92
115
class Hooks(dict):
96
119
    FOO hook is triggered.
97
120
    """
98
121
 
99
 
    def __init__(self):
 
122
    def __init__(self, module=None, member_name=None):
 
123
        """Create a new hooks dictionary.
 
124
 
 
125
        :param module: The module from which this hooks dictionary should be loaded
 
126
            (used for lazy hooks)
 
127
        :param member_name: Name under which this hooks dictionary should be loaded.
 
128
            (used for lazy hooks)
 
129
        """
100
130
        dict.__init__(self)
101
131
        self._callable_names = {}
102
 
 
 
132
        self._lazy_callable_names = {}
 
133
        self._module = module
 
134
        self._member_name = member_name
 
135
 
 
136
    def add_hook(self, name, doc, introduced, deprecated=None):
 
137
        """Add a hook point to this dictionary.
 
138
 
 
139
        :param name: The name of the hook, for clients to use when registering.
 
140
        :param doc: The docs for the hook.
 
141
        :param introduced: When the hook was introduced (e.g. (0, 15)).
 
142
        :param deprecated: When the hook was deprecated, None for
 
143
            not-deprecated.
 
144
        """
 
145
        if name in self:
 
146
            raise errors.DuplicateKey(name)
 
147
        if self._module:
 
148
            callbacks = _lazy_hooks.setdefault(
 
149
                (self._module, self._member_name, name), [])
 
150
        else:
 
151
            callbacks = None
 
152
        hookpoint = HookPoint(name=name, doc=doc, introduced=introduced,
 
153
                              deprecated=deprecated, callbacks=callbacks)
 
154
        self[name] = hookpoint
 
155
 
 
156
    @symbol_versioning.deprecated_method(symbol_versioning.deprecated_in((2, 4)))
103
157
    def create_hook(self, hook):
104
158
        """Create a hook which can have callbacks registered for it.
105
159
 
145
199
        the code names are rarely meaningful for end users and this is not
146
200
        intended for debugging.
147
201
        """
148
 
        return self._callable_names.get(a_callable, "No hook name")
 
202
        name = self._callable_names.get(a_callable, None)
 
203
        if name is None and a_callable is not None:
 
204
            name = self._lazy_callable_names.get((a_callable.__module__,
 
205
                                                  a_callable.__name__),
 
206
                                                 None)
 
207
        if name is None:
 
208
            return 'No hook name'
 
209
        return name
 
210
 
 
211
 
 
212
    def install_named_hook_lazy(self, hook_name, callable_module,
 
213
        callable_member, name):
 
214
        """Install a_callable in to the hook hook_name lazily, and label it.
 
215
 
 
216
        :param hook_name: A hook name. See the __init__ method for the complete
 
217
            list of hooks.
 
218
        :param callable_module: Name of the module in which the callable is
 
219
            present.
 
220
        :param callable_member: Member name of the callable.
 
221
        :param name: A name to associate the callable with, to show users what
 
222
            is running.
 
223
        """
 
224
        try:
 
225
            hook = self[hook_name]
 
226
        except KeyError:
 
227
            raise errors.UnknownHook(self.__class__.__name__, hook_name)
 
228
        try:
 
229
            hook_lazy = getattr(hook, "hook_lazy")
 
230
        except AttributeError:
 
231
            raise errors.UnsupportedOperation(self.install_named_hook_lazy,
 
232
                self)
 
233
        else:
 
234
            hook_lazy(callable_module, callable_member, name)
 
235
        if name is not None:
 
236
            self.name_hook_lazy(callable_module, callable_member, name)
149
237
 
150
238
    def install_named_hook(self, hook_name, a_callable, name):
151
239
        """Install a_callable in to the hook hook_name, and label it name.
152
240
 
153
 
        :param hook_name: A hook name. See the __init__ method of BranchHooks
154
 
            for the complete list of hooks.
 
241
        :param hook_name: A hook name. See the __init__ method for the complete
 
242
            list of hooks.
155
243
        :param a_callable: The callable to be invoked when the hook triggers.
156
244
            The exact signature will depend on the hook - see the __init__
157
 
            method of BranchHooks for details on each hook.
 
245
            method for details on each hook.
158
246
        :param name: A name to associate a_callable with, to show users what is
159
247
            running.
160
248
        """
170
258
        if name is not None:
171
259
            self.name_hook(a_callable, name)
172
260
 
 
261
    def uninstall_named_hook(self, hook_name, label):
 
262
        """Uninstall named hooks.
 
263
 
 
264
        :param hook_name: Hook point name
 
265
        :param label: Label of the callable to uninstall
 
266
        """
 
267
        try:
 
268
            hook = self[hook_name]
 
269
        except KeyError:
 
270
            raise errors.UnknownHook(self.__class__.__name__, hook_name)
 
271
        try:
 
272
            uninstall = getattr(hook, "uninstall")
 
273
        except AttributeError:
 
274
            raise errors.UnsupportedOperation(self.uninstall_named_hook, self)
 
275
        else:
 
276
            uninstall(label)
 
277
 
173
278
    def name_hook(self, a_callable, name):
174
279
        """Associate name with a_callable to show users what is running."""
175
280
        self._callable_names[a_callable] = name
176
281
 
 
282
    def name_hook_lazy(self, callable_module, callable_member, callable_name):
 
283
        self._lazy_callable_names[(callable_module, callable_member)]= \
 
284
            callable_name
 
285
 
177
286
 
178
287
class HookPoint(object):
179
288
    """A single hook that clients can register to be called back when it fires.
180
289
 
181
290
    :ivar name: The name of the hook.
 
291
    :ivar doc: The docs for using the hook.
182
292
    :ivar introduced: A version tuple specifying what version the hook was
183
293
        introduced in. None indicates an unknown version.
184
294
    :ivar deprecated: A version tuple specifying what version the hook was
185
295
        deprecated or superseded in. None indicates that the hook is not
186
296
        superseded or deprecated. If the hook is superseded then the doc
187
297
        should describe the recommended replacement hook to register for.
188
 
    :ivar doc: The docs for using the hook.
189
298
    """
190
299
 
191
 
    def __init__(self, name, doc, introduced, deprecated):
 
300
    def __init__(self, name, doc, introduced, deprecated=None, callbacks=None):
192
301
        """Create a HookPoint.
193
302
 
194
303
        :param name: The name of the hook, for clients to use when registering.
201
310
        self.__doc__ = doc
202
311
        self.introduced = introduced
203
312
        self.deprecated = deprecated
204
 
        self._callbacks = []
205
 
        self._callback_names = {}
 
313
        if callbacks is None:
 
314
            self._callbacks = []
 
315
        else:
 
316
            self._callbacks = callbacks
206
317
 
207
318
    def docs(self):
208
319
        """Generate the documentation for this HookPoint.
217
328
            introduced_string = _format_version_tuple(self.introduced)
218
329
        else:
219
330
            introduced_string = 'unknown'
220
 
        strings.append('Introduced in: %s' % introduced_string)
 
331
        strings.append(gettext('Introduced in: %s') % introduced_string)
221
332
        if self.deprecated:
222
333
            deprecated_string = _format_version_tuple(self.deprecated)
223
 
            strings.append('Deprecated in: %s' % deprecated_string)
 
334
            strings.append(gettext('Deprecated in: %s') % deprecated_string)
224
335
        strings.append('')
225
336
        strings.extend(textwrap.wrap(self.__doc__,
226
337
            break_long_words=False))
228
339
        return '\n'.join(strings)
229
340
 
230
341
    def __eq__(self, other):
231
 
        return (type(other) == type(self) and 
232
 
            other.__dict__ == self.__dict__)
 
342
        return (type(other) == type(self) and other.__dict__ == self.__dict__)
 
343
 
 
344
    def hook_lazy(self, callback_module, callback_member, callback_label):
 
345
        """Lazily register a callback to be called when this HookPoint fires.
 
346
 
 
347
        :param callback_module: Module of the callable to use when this
 
348
            HookPoint fires.
 
349
        :param callback_member: Member name of the callback.
 
350
        :param callback_label: A label to show in the UI while this callback is
 
351
            processing.
 
352
        """
 
353
        obj_getter = registry._LazyObjectGetter(callback_module,
 
354
            callback_member)
 
355
        self._callbacks.append((obj_getter, callback_label))
233
356
 
234
357
    def hook(self, callback, callback_label):
235
358
        """Register a callback to be called when this HookPoint fires.
238
361
        :param callback_label: A label to show in the UI while this callback is
239
362
            processing.
240
363
        """
241
 
        self._callbacks.append(callback)
242
 
        if callback_label is not None:
243
 
            self._callback_names[callback] = callback_label
 
364
        obj_getter = registry._ObjectGetter(callback)
 
365
        self._callbacks.append((obj_getter, callback_label))
 
366
 
 
367
    def uninstall(self, label):
 
368
        """Uninstall the callback with the specified label.
 
369
 
 
370
        :param label: Label of the entry to uninstall
 
371
        """
 
372
        entries_to_remove = []
 
373
        for entry in self._callbacks:
 
374
            (entry_callback, entry_label) = entry
 
375
            if entry_label == label:
 
376
                entries_to_remove.append(entry)
 
377
        if entries_to_remove == []:
 
378
            raise KeyError("No entry with label %r" % label)
 
379
        for entry in entries_to_remove:
 
380
            self._callbacks.remove(entry)
244
381
 
245
382
    def __iter__(self):
246
 
        return iter(self._callbacks)
 
383
        return (callback.get_obj() for callback, name in self._callbacks)
247
384
 
248
385
    def __len__(self):
249
386
        return len(self._callbacks)
253
390
        strings.append("<%s(" % type(self).__name__)
254
391
        strings.append(self.name)
255
392
        strings.append("), callbacks=[")
256
 
        for callback in self._callbacks:
257
 
            strings.append(repr(callback))
 
393
        callbacks = self._callbacks
 
394
        for (callback, callback_name) in callbacks:
 
395
            strings.append(repr(callback.get_obj()))
258
396
            strings.append("(")
259
 
            strings.append(self._callback_names[callback])
 
397
            strings.append(callback_name)
260
398
            strings.append("),")
261
 
        if len(self._callbacks) == 1:
 
399
        if len(callbacks) == 1:
262
400
            strings[-1] = ")"
263
401
        strings.append("]>")
264
402
        return ''.join(strings)
303
441
        hooks = known_hooks_key_to_object(hook_key)
304
442
        segments.append(hooks.docs())
305
443
    return '\n'.join(segments)
 
444
 
 
445
 
 
446
# Lazily registered hooks. Maps (module, name, hook_name) tuples
 
447
# to lists of tuples with objectgetters and names
 
448
_lazy_hooks = {}
 
449
 
 
450
 
 
451
def install_lazy_named_hook(hookpoints_module, hookpoints_name, hook_name,
 
452
    a_callable, name):
 
453
    """Install a callable in to a hook lazily, and label it name.
 
454
 
 
455
    :param hookpoints_module: Module name of the hook points.
 
456
    :param hookpoints_name: Name of the hook points.
 
457
    :param hook_name: A hook name.
 
458
    :param callable: a callable to call for the hook.
 
459
    :param name: A name to associate a_callable with, to show users what is
 
460
        running.
 
461
    """
 
462
    key = (hookpoints_module, hookpoints_name, hook_name)
 
463
    obj_getter = registry._ObjectGetter(a_callable)
 
464
    _lazy_hooks.setdefault(key, []).append((obj_getter, name))