~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/hooks.py

  • Committer: Patch Queue Manager
  • Date: 2016-04-21 05:06:57 UTC
  • mfrom: (6603.4.1 bzr)
  • Revision ID: pqm@pqm.ubuntu.com-20160421050657-ygnzfybewvudf1j9
(richard-wilbur) Use initial_comment as commit_message for lp_propose.(Shawn
 Wang) (Shawn Wang)

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
 
from bzrlib.symbol_versioning import deprecated_method
22
26
lazy_import(globals(), """
23
27
import textwrap
24
28
 
25
29
from bzrlib import (
26
 
        _format_version_tuple,
27
 
        errors,
28
 
        )
29
 
from bzrlib.help_topics import help_as_plain_text
 
30
    _format_version_tuple,
 
31
    errors,
 
32
    pyutils,
 
33
    )
 
34
from bzrlib.i18n import gettext
30
35
""")
31
36
 
32
37
 
33
 
known_hooks = registry.Registry()
34
 
# known_hooks registry contains
35
 
# tuple of (module, member name) which is the hook point
36
 
# module where the specific hooks are defined
37
 
# callable to get the empty specific Hooks for that attribute
38
 
known_hooks.register_lazy(('bzrlib.branch', 'Branch.hooks'), 'bzrlib.branch',
39
 
    'BranchHooks')
40
 
known_hooks.register_lazy(('bzrlib.bzrdir', 'BzrDir.hooks'), 'bzrlib.bzrdir',
41
 
    'BzrDirHooks')
42
 
known_hooks.register_lazy(('bzrlib.commands', 'Command.hooks'),
43
 
    'bzrlib.commands', 'CommandHooks')
44
 
known_hooks.register_lazy(('bzrlib.info', 'hooks'),
45
 
    'bzrlib.info', 'InfoHooks')
46
 
known_hooks.register_lazy(('bzrlib.lock', 'Lock.hooks'), 'bzrlib.lock',
47
 
    'LockHooks')
48
 
known_hooks.register_lazy(('bzrlib.merge', 'Merger.hooks'), 'bzrlib.merge',
49
 
    'MergeHooks')
50
 
known_hooks.register_lazy(('bzrlib.msgeditor', 'hooks'), 'bzrlib.msgeditor',
51
 
    'MessageEditorHooks')
52
 
known_hooks.register_lazy(('bzrlib.mutabletree', 'MutableTree.hooks'),
53
 
    'bzrlib.mutabletree', 'MutableTreeHooks')
54
 
known_hooks.register_lazy(('bzrlib.smart.client', '_SmartClient.hooks'),
55
 
    'bzrlib.smart.client', 'SmartClientHooks')
56
 
known_hooks.register_lazy(('bzrlib.smart.server', 'SmartTCPServer.hooks'),
57
 
    'bzrlib.smart.server', 'SmartServerHooks')
58
 
known_hooks.register_lazy(
59
 
    ('bzrlib.version_info_formats.format_rio', 'RioVersionInfoBuilder.hooks'),
60
 
    'bzrlib.version_info_formats.format_rio', 'RioVersionInfoBuilderHooks')
61
 
known_hooks.register_lazy(
62
 
    ('bzrlib.merge_directive', 'BaseMergeDirective.hooks'),
63
 
    '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
64
97
 
65
98
 
66
99
def known_hooks_key_to_object((module_name, member_name)):
70
103
        the known_hooks registry.
71
104
    :return: The object this specifies.
72
105
    """
73
 
    return registry._LazyObjectGetter(module_name, member_name).get_obj()
74
 
 
75
 
 
76
 
def known_hooks_key_to_parent_and_attribute((module_name, member_name)):
77
 
    """Convert a known_hooks key to a object.
78
 
 
79
 
    :param key: A tuple (module_name, member_name) as found in the keys of
80
 
        the known_hooks registry.
81
 
    :return: The object this specifies.
82
 
    """
83
 
    member_list = member_name.rsplit('.', 1)
84
 
    if len(member_list) == 2:
85
 
        parent_name, attribute = member_list
86
 
    else:
87
 
        parent_name = None
88
 
        attribute = member_name
89
 
    parent = known_hooks_key_to_object((module_name, parent_name))
90
 
    return parent, attribute
 
106
    return pyutils.get_named_object(module_name, member_name)
91
107
 
92
108
 
93
109
class Hooks(dict):
97
113
    FOO hook is triggered.
98
114
    """
99
115
 
100
 
    def __init__(self):
 
116
    def __init__(self, module=None, member_name=None):
 
117
        """Create a new hooks dictionary.
 
118
 
 
119
        :param module: The module from which this hooks dictionary should be loaded
 
120
            (used for lazy hooks)
 
121
        :param member_name: Name under which this hooks dictionary should be loaded.
 
122
            (used for lazy hooks)
 
123
        """
101
124
        dict.__init__(self)
102
125
        self._callable_names = {}
103
 
 
104
 
    def create_hook(self, hook):
105
 
        """Create a hook which can have callbacks registered for it.
106
 
 
107
 
        :param hook: The hook to create. An object meeting the protocol of
108
 
            bzrlib.hooks.HookPoint. It's name is used as the key for future
109
 
            lookups.
 
126
        self._lazy_callable_names = {}
 
127
        self._module = module
 
128
        self._member_name = member_name
 
129
 
 
130
    def add_hook(self, name, doc, introduced, deprecated=None):
 
131
        """Add a hook point to this dictionary.
 
132
 
 
133
        :param name: The name of the hook, for clients to use when registering.
 
134
        :param doc: The docs for the hook.
 
135
        :param introduced: When the hook was introduced (e.g. (0, 15)).
 
136
        :param deprecated: When the hook was deprecated, None for
 
137
            not-deprecated.
110
138
        """
111
 
        if hook.name in self:
112
 
            raise errors.DuplicateKey(hook.name)
113
 
        self[hook.name] = hook
 
139
        if name in self:
 
140
            raise errors.DuplicateKey(name)
 
141
        if self._module:
 
142
            callbacks = _lazy_hooks.setdefault(
 
143
                (self._module, self._member_name, name), [])
 
144
        else:
 
145
            callbacks = None
 
146
        hookpoint = HookPoint(name=name, doc=doc, introduced=introduced,
 
147
                              deprecated=deprecated, callbacks=callbacks)
 
148
        self[name] = hookpoint
114
149
 
115
150
    def docs(self):
116
151
        """Generate the documentation for this Hooks instance.
146
181
        the code names are rarely meaningful for end users and this is not
147
182
        intended for debugging.
148
183
        """
149
 
        return self._callable_names.get(a_callable, "No hook name")
 
184
        name = self._callable_names.get(a_callable, None)
 
185
        if name is None and a_callable is not None:
 
186
            name = self._lazy_callable_names.get((a_callable.__module__,
 
187
                                                  a_callable.__name__),
 
188
                                                 None)
 
189
        if name is None:
 
190
            return 'No hook name'
 
191
        return name
 
192
 
 
193
 
 
194
    def install_named_hook_lazy(self, hook_name, callable_module,
 
195
        callable_member, name):
 
196
        """Install a_callable in to the hook hook_name lazily, and label it.
 
197
 
 
198
        :param hook_name: A hook name. See the __init__ method for the complete
 
199
            list of hooks.
 
200
        :param callable_module: Name of the module in which the callable is
 
201
            present.
 
202
        :param callable_member: Member name of the callable.
 
203
        :param name: A name to associate the callable with, to show users what
 
204
            is running.
 
205
        """
 
206
        try:
 
207
            hook = self[hook_name]
 
208
        except KeyError:
 
209
            raise errors.UnknownHook(self.__class__.__name__, hook_name)
 
210
        try:
 
211
            hook_lazy = getattr(hook, "hook_lazy")
 
212
        except AttributeError:
 
213
            raise errors.UnsupportedOperation(self.install_named_hook_lazy,
 
214
                self)
 
215
        else:
 
216
            hook_lazy(callable_module, callable_member, name)
 
217
        if name is not None:
 
218
            self.name_hook_lazy(callable_module, callable_member, name)
150
219
 
151
220
    def install_named_hook(self, hook_name, a_callable, name):
152
221
        """Install a_callable in to the hook hook_name, and label it name.
153
222
 
154
 
        :param hook_name: A hook name. See the __init__ method of BranchHooks
155
 
            for the complete list of hooks.
 
223
        :param hook_name: A hook name. See the __init__ method for the complete
 
224
            list of hooks.
156
225
        :param a_callable: The callable to be invoked when the hook triggers.
157
226
            The exact signature will depend on the hook - see the __init__
158
 
            method of BranchHooks for details on each hook.
 
227
            method for details on each hook.
159
228
        :param name: A name to associate a_callable with, to show users what is
160
229
            running.
161
230
        """
171
240
        if name is not None:
172
241
            self.name_hook(a_callable, name)
173
242
 
 
243
    def uninstall_named_hook(self, hook_name, label):
 
244
        """Uninstall named hooks.
 
245
 
 
246
        :param hook_name: Hook point name
 
247
        :param label: Label of the callable to uninstall
 
248
        """
 
249
        try:
 
250
            hook = self[hook_name]
 
251
        except KeyError:
 
252
            raise errors.UnknownHook(self.__class__.__name__, hook_name)
 
253
        try:
 
254
            uninstall = getattr(hook, "uninstall")
 
255
        except AttributeError:
 
256
            raise errors.UnsupportedOperation(self.uninstall_named_hook, self)
 
257
        else:
 
258
            uninstall(label)
 
259
 
174
260
    def name_hook(self, a_callable, name):
175
261
        """Associate name with a_callable to show users what is running."""
176
262
        self._callable_names[a_callable] = name
177
263
 
 
264
    def name_hook_lazy(self, callable_module, callable_member, callable_name):
 
265
        self._lazy_callable_names[(callable_module, callable_member)]= \
 
266
            callable_name
 
267
 
178
268
 
179
269
class HookPoint(object):
180
270
    """A single hook that clients can register to be called back when it fires.
181
271
 
182
272
    :ivar name: The name of the hook.
 
273
    :ivar doc: The docs for using the hook.
183
274
    :ivar introduced: A version tuple specifying what version the hook was
184
275
        introduced in. None indicates an unknown version.
185
276
    :ivar deprecated: A version tuple specifying what version the hook was
186
277
        deprecated or superseded in. None indicates that the hook is not
187
278
        superseded or deprecated. If the hook is superseded then the doc
188
279
        should describe the recommended replacement hook to register for.
189
 
    :ivar doc: The docs for using the hook.
190
280
    """
191
281
 
192
 
    def __init__(self, name, doc, introduced, deprecated):
 
282
    def __init__(self, name, doc, introduced, deprecated=None, callbacks=None):
193
283
        """Create a HookPoint.
194
284
 
195
285
        :param name: The name of the hook, for clients to use when registering.
202
292
        self.__doc__ = doc
203
293
        self.introduced = introduced
204
294
        self.deprecated = deprecated
205
 
        self._callbacks = []
206
 
        self._callback_names = {}
 
295
        if callbacks is None:
 
296
            self._callbacks = []
 
297
        else:
 
298
            self._callbacks = callbacks
207
299
 
208
300
    def docs(self):
209
301
        """Generate the documentation for this HookPoint.
218
310
            introduced_string = _format_version_tuple(self.introduced)
219
311
        else:
220
312
            introduced_string = 'unknown'
221
 
        strings.append('Introduced in: %s' % introduced_string)
 
313
        strings.append(gettext('Introduced in: %s') % introduced_string)
222
314
        if self.deprecated:
223
315
            deprecated_string = _format_version_tuple(self.deprecated)
224
 
            strings.append('Deprecated in: %s' % deprecated_string)
 
316
            strings.append(gettext('Deprecated in: %s') % deprecated_string)
225
317
        strings.append('')
226
318
        strings.extend(textwrap.wrap(self.__doc__,
227
319
            break_long_words=False))
229
321
        return '\n'.join(strings)
230
322
 
231
323
    def __eq__(self, other):
232
 
        return (type(other) == type(self) and 
233
 
            other.__dict__ == self.__dict__)
 
324
        return (type(other) == type(self) and other.__dict__ == self.__dict__)
 
325
 
 
326
    def hook_lazy(self, callback_module, callback_member, callback_label):
 
327
        """Lazily register a callback to be called when this HookPoint fires.
 
328
 
 
329
        :param callback_module: Module of the callable to use when this
 
330
            HookPoint fires.
 
331
        :param callback_member: Member name of the callback.
 
332
        :param callback_label: A label to show in the UI while this callback is
 
333
            processing.
 
334
        """
 
335
        obj_getter = registry._LazyObjectGetter(callback_module,
 
336
            callback_member)
 
337
        self._callbacks.append((obj_getter, callback_label))
234
338
 
235
339
    def hook(self, callback, callback_label):
236
340
        """Register a callback to be called when this HookPoint fires.
239
343
        :param callback_label: A label to show in the UI while this callback is
240
344
            processing.
241
345
        """
242
 
        self._callbacks.append(callback)
243
 
        if callback_label is not None:
244
 
            self._callback_names[callback] = callback_label
 
346
        obj_getter = registry._ObjectGetter(callback)
 
347
        self._callbacks.append((obj_getter, callback_label))
 
348
 
 
349
    def uninstall(self, label):
 
350
        """Uninstall the callback with the specified label.
 
351
 
 
352
        :param label: Label of the entry to uninstall
 
353
        """
 
354
        entries_to_remove = []
 
355
        for entry in self._callbacks:
 
356
            (entry_callback, entry_label) = entry
 
357
            if entry_label == label:
 
358
                entries_to_remove.append(entry)
 
359
        if entries_to_remove == []:
 
360
            raise KeyError("No entry with label %r" % label)
 
361
        for entry in entries_to_remove:
 
362
            self._callbacks.remove(entry)
245
363
 
246
364
    def __iter__(self):
247
 
        return iter(self._callbacks)
 
365
        return (callback.get_obj() for callback, name in self._callbacks)
248
366
 
249
367
    def __len__(self):
250
368
        return len(self._callbacks)
254
372
        strings.append("<%s(" % type(self).__name__)
255
373
        strings.append(self.name)
256
374
        strings.append("), callbacks=[")
257
 
        for callback in self._callbacks:
258
 
            strings.append(repr(callback))
 
375
        callbacks = self._callbacks
 
376
        for (callback, callback_name) in callbacks:
 
377
            strings.append(repr(callback.get_obj()))
259
378
            strings.append("(")
260
 
            strings.append(self._callback_names[callback])
 
379
            strings.append(callback_name)
261
380
            strings.append("),")
262
 
        if len(self._callbacks) == 1:
 
381
        if len(callbacks) == 1:
263
382
            strings[-1] = ")"
264
383
        strings.append("]>")
265
384
        return ''.join(strings)
277
396
 
278
397
  yyy.hooks.install_named_hook("xxx", ...)
279
398
 
280
 
See `Using hooks`_ in the User Guide for examples.
281
 
 
282
 
.. _Using hooks: ../user-guide/hooks.html
 
399
See :doc:`Using hooks<../user-guide/hooks>` in the User Guide for examples.
283
400
 
284
401
The class that contains each hook is given before the hooks it supplies. For
285
402
instance, BranchHooks as the class is the hooks class for
306
423
        hooks = known_hooks_key_to_object(hook_key)
307
424
        segments.append(hooks.docs())
308
425
    return '\n'.join(segments)
 
426
 
 
427
 
 
428
# Lazily registered hooks. Maps (module, name, hook_name) tuples
 
429
# to lists of tuples with objectgetters and names
 
430
_lazy_hooks = {}
 
431
 
 
432
 
 
433
def install_lazy_named_hook(hookpoints_module, hookpoints_name, hook_name,
 
434
    a_callable, name):
 
435
    """Install a callable in to a hook lazily, and label it name.
 
436
 
 
437
    :param hookpoints_module: Module name of the hook points.
 
438
    :param hookpoints_name: Name of the hook points.
 
439
    :param hook_name: A hook name.
 
440
    :param callable: a callable to call for the hook.
 
441
    :param name: A name to associate a_callable with, to show users what is
 
442
        running.
 
443
    """
 
444
    key = (hookpoints_module, hookpoints_name, hook_name)
 
445
    obj_getter = registry._ObjectGetter(a_callable)
 
446
    _lazy_hooks.setdefault(key, []).append((obj_getter, name))