~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/hooks.py

Merge bzr.dev to resolve conflicts

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
1
# Copyright (C) 2007-2011 Canonical Ltd
 
2
#
 
3
# This program is free software; you can redistribute it and/or modify
 
4
# it under the terms of the GNU General Public License as published by
 
5
# the Free Software Foundation; either version 2 of the License, or
 
6
# (at your option) any later version.
 
7
#
 
8
# This program is distributed in the hope that it will be useful,
 
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
 
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
11
# GNU General Public License for more details.
 
12
#
 
13
# You should have received a copy of the GNU General Public License
 
14
# along with this program; if not, write to the Free Software
 
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 
16
 
 
17
 
 
18
"""Support for plugin hooking logic."""
 
19
 
 
20
from bzrlib import (
 
21
    registry,
 
22
    symbol_versioning,
 
23
    )
 
24
from bzrlib.lazy_import import lazy_import
 
25
lazy_import(globals(), """
 
26
import textwrap
 
27
 
 
28
from bzrlib import (
 
29
    _format_version_tuple,
 
30
    errors,
 
31
    pyutils,
 
32
    )
 
33
""")
 
34
 
 
35
 
 
36
class KnownHooksRegistry(registry.Registry):
 
37
    # known_hooks registry contains
 
38
    # tuple of (module, member name) which is the hook point
 
39
    # module where the specific hooks are defined
 
40
    # callable to get the empty specific Hooks for that attribute
 
41
 
 
42
    def register_lazy_hook(self, hook_module_name, hook_member_name,
 
43
            hook_factory_member_name):
 
44
        self.register_lazy((hook_module_name, hook_member_name),
 
45
            hook_module_name, hook_factory_member_name)
 
46
 
 
47
    def iter_parent_objects(self):
 
48
        """Yield (hook_key, (parent_object, attr)) tuples for every registered
 
49
        hook, where 'parent_object' is the object that holds the hook
 
50
        instance.
 
51
 
 
52
        This is useful for resetting/restoring all the hooks to a known state,
 
53
        as is done in bzrlib.tests.TestCase._clear_hooks.
 
54
        """
 
55
        for key in self.keys():
 
56
            yield key, self.key_to_parent_and_attribute(key)
 
57
 
 
58
    def key_to_parent_and_attribute(self, (module_name, member_name)):
 
59
        """Convert a known_hooks key to a (parent_obj, attr) pair.
 
60
 
 
61
        :param key: A tuple (module_name, member_name) as found in the keys of
 
62
            the known_hooks registry.
 
63
        :return: The parent_object of the hook and the name of the attribute on
 
64
            that parent object where the hook is kept.
 
65
        """
 
66
        parent_mod, parent_member, attr = pyutils.calc_parent_name(module_name,
 
67
            member_name)
 
68
        return pyutils.get_named_object(parent_mod, parent_member), attr
 
69
 
 
70
 
 
71
_builtin_known_hooks = (
 
72
    ('bzrlib.branch', 'Branch.hooks', 'BranchHooks'),
 
73
    ('bzrlib.bzrdir', 'BzrDir.hooks', 'BzrDirHooks'),
 
74
    ('bzrlib.commands', 'Command.hooks', 'CommandHooks'),
 
75
    ('bzrlib.info', 'hooks', 'InfoHooks'),
 
76
    ('bzrlib.lock', 'Lock.hooks', 'LockHooks'),
 
77
    ('bzrlib.merge', 'Merger.hooks', 'MergeHooks'),
 
78
    ('bzrlib.msgeditor', 'hooks', 'MessageEditorHooks'),
 
79
    ('bzrlib.mutabletree', 'MutableTree.hooks', 'MutableTreeHooks'),
 
80
    ('bzrlib.smart.client', '_SmartClient.hooks', 'SmartClientHooks'),
 
81
    ('bzrlib.smart.server', 'SmartTCPServer.hooks', 'SmartServerHooks'),
 
82
    ('bzrlib.status', 'hooks', 'StatusHooks'),
 
83
    ('bzrlib.version_info_formats.format_rio', 'RioVersionInfoBuilder.hooks',
 
84
        'RioVersionInfoBuilderHooks'),
 
85
    ('bzrlib.merge_directive', 'BaseMergeDirective.hooks',
 
86
        'MergeDirectiveHooks'),
 
87
    )
 
88
 
 
89
known_hooks = KnownHooksRegistry()
 
90
for (_hook_module, _hook_attribute, _hook_class) in _builtin_known_hooks:
 
91
    known_hooks.register_lazy_hook(_hook_module, _hook_attribute, _hook_class)
 
92
del _builtin_known_hooks, _hook_module, _hook_attribute, _hook_class
 
93
 
 
94
 
 
95
def known_hooks_key_to_object((module_name, member_name)):
 
96
    """Convert a known_hooks key to a object.
 
97
 
 
98
    :param key: A tuple (module_name, member_name) as found in the keys of
 
99
        the known_hooks registry.
 
100
    :return: The object this specifies.
 
101
    """
 
102
    return pyutils.get_named_object(module_name, member_name)
 
103
 
 
104
 
 
105
@symbol_versioning.deprecated_function(symbol_versioning.deprecated_in((2, 3)))
 
106
def known_hooks_key_to_parent_and_attribute(key):
 
107
    """See KnownHooksRegistry.key_to_parent_and_attribute."""
 
108
    return known_hooks.key_to_parent_and_attribute(key)
 
109
 
 
110
 
 
111
class Hooks(dict):
 
112
    """A dictionary mapping hook name to a list of callables.
 
113
 
 
114
    e.g. ['FOO'] Is the list of items to be called when the
 
115
    FOO hook is triggered.
 
116
    """
 
117
 
 
118
    def __init__(self, module=None, member_name=None):
 
119
        """Create a new hooks dictionary.
 
120
 
 
121
        :param module: The module from which this hooks dictionary should be loaded
 
122
            (used for lazy hooks)
 
123
        :param member_name: Name under which this hooks dictionary should be loaded.
 
124
            (used for lazy hooks)
 
125
        """
 
126
        dict.__init__(self)
 
127
        self._callable_names = {}
 
128
        self._module = module
 
129
        self._member_name = member_name
 
130
 
 
131
    def add_hook(self, name, doc, introduced, deprecated=None):
 
132
        """Add a hook point to this dictionary.
 
133
 
 
134
        :param name: The name of the hook, for clients to use when registering.
 
135
        :param doc: The docs for the hook.
 
136
        :param introduced: When the hook was introduced (e.g. (0, 15)).
 
137
        :param deprecated: When the hook was deprecated, None for
 
138
            not-deprecated.
 
139
        """
 
140
        if name in self:
 
141
            raise errors.DuplicateKey(name)
 
142
        if self._module:
 
143
            callbacks = _lazy_hooks.setdefault(
 
144
                (self._module, self._member_name, name), [])
 
145
        else:
 
146
            callbacks = None
 
147
        hookpoint = HookPoint(name=name, doc=doc, introduced=introduced,
 
148
                              deprecated=deprecated, callbacks=callbacks)
 
149
        self[name] = hookpoint
 
150
 
 
151
    @symbol_versioning.deprecated_method(symbol_versioning.deprecated_in((2, 4)))
 
152
    def create_hook(self, hook):
 
153
        """Create a hook which can have callbacks registered for it.
 
154
 
 
155
        :param hook: The hook to create. An object meeting the protocol of
 
156
            bzrlib.hooks.HookPoint. It's name is used as the key for future
 
157
            lookups.
 
158
        """
 
159
        if hook.name in self:
 
160
            raise errors.DuplicateKey(hook.name)
 
161
        self[hook.name] = hook
 
162
 
 
163
    def docs(self):
 
164
        """Generate the documentation for this Hooks instance.
 
165
 
 
166
        This introspects all the individual hooks and returns their docs as well.
 
167
        """
 
168
        hook_names = sorted(self.keys())
 
169
        hook_docs = []
 
170
        name = self.__class__.__name__
 
171
        hook_docs.append(name)
 
172
        hook_docs.append("-"*len(name))
 
173
        hook_docs.append("")
 
174
        for hook_name in hook_names:
 
175
            hook = self[hook_name]
 
176
            try:
 
177
                hook_docs.append(hook.docs())
 
178
            except AttributeError:
 
179
                # legacy hook
 
180
                strings = []
 
181
                strings.append(hook_name)
 
182
                strings.append("~" * len(hook_name))
 
183
                strings.append("")
 
184
                strings.append("An old-style hook. For documentation see the __init__ "
 
185
                    "method of '%s'\n" % (name,))
 
186
                hook_docs.extend(strings)
 
187
        return "\n".join(hook_docs)
 
188
 
 
189
    def get_hook_name(self, a_callable):
 
190
        """Get the name for a_callable for UI display.
 
191
 
 
192
        If no name has been registered, the string 'No hook name' is returned.
 
193
        We use a fixed string rather than repr or the callables module because
 
194
        the code names are rarely meaningful for end users and this is not
 
195
        intended for debugging.
 
196
        """
 
197
        return self._callable_names.get(a_callable, "No hook name")
 
198
 
 
199
    def install_named_hook_lazy(self, hook_name, callable_module,
 
200
        callable_member, name):
 
201
        """Install a_callable in to the hook hook_name lazily, and label it.
 
202
 
 
203
        :param hook_name: A hook name. See the __init__ method for the complete
 
204
            list of hooks.
 
205
        :param callable_module: Name of the module in which the callable is
 
206
            present.
 
207
        :param callable_member: Member name of the callable.
 
208
        :param name: A name to associate the callable with, to show users what
 
209
            is running.
 
210
        """
 
211
        try:
 
212
            hook = self[hook_name]
 
213
        except KeyError:
 
214
            raise errors.UnknownHook(self.__class__.__name__, hook_name)
 
215
        try:
 
216
            hook_lazy = getattr(hook, "hook_lazy")
 
217
        except AttributeError:
 
218
            raise errors.UnsupportedOperation(self.install_named_hook_lazy,
 
219
                self)
 
220
        else:
 
221
            hook_lazy(callable_module, callable_member, name)
 
222
 
 
223
    def install_named_hook(self, hook_name, a_callable, name):
 
224
        """Install a_callable in to the hook hook_name, and label it name.
 
225
 
 
226
        :param hook_name: A hook name. See the __init__ method for the complete
 
227
            list of hooks.
 
228
        :param a_callable: The callable to be invoked when the hook triggers.
 
229
            The exact signature will depend on the hook - see the __init__
 
230
            method for details on each hook.
 
231
        :param name: A name to associate a_callable with, to show users what is
 
232
            running.
 
233
        """
 
234
        try:
 
235
            hook = self[hook_name]
 
236
        except KeyError:
 
237
            raise errors.UnknownHook(self.__class__.__name__, hook_name)
 
238
        try:
 
239
            # list hooks, old-style, not yet deprecated but less useful.
 
240
            hook.append(a_callable)
 
241
        except AttributeError:
 
242
            hook.hook(a_callable, name)
 
243
        if name is not None:
 
244
            self.name_hook(a_callable, name)
 
245
 
 
246
    def uninstall_named_hook(self, hook_name, label):
 
247
        """Uninstall named hooks.
 
248
 
 
249
        :param hook_name: Hook point name
 
250
        :param label: Label of the callable to uninstall
 
251
        """
 
252
        try:
 
253
            hook = self[hook_name]
 
254
        except KeyError:
 
255
            raise errors.UnknownHook(self.__class__.__name__, hook_name)
 
256
        try:
 
257
            uninstall = getattr(hook, "uninstall")
 
258
        except AttributeError:
 
259
            raise errors.UnsupportedOperation(self.install_named_hook_lazy,
 
260
                self)
 
261
        else:
 
262
            uninstall(label)
 
263
 
 
264
    def name_hook(self, a_callable, name):
 
265
        """Associate name with a_callable to show users what is running."""
 
266
        self._callable_names[a_callable] = name
 
267
 
 
268
 
 
269
class HookPoint(object):
 
270
    """A single hook that clients can register to be called back when it fires.
 
271
 
 
272
    :ivar name: The name of the hook.
 
273
    :ivar doc: The docs for using the hook.
 
274
    :ivar introduced: A version tuple specifying what version the hook was
 
275
        introduced in. None indicates an unknown version.
 
276
    :ivar deprecated: A version tuple specifying what version the hook was
 
277
        deprecated or superseded in. None indicates that the hook is not
 
278
        superseded or deprecated. If the hook is superseded then the doc
 
279
        should describe the recommended replacement hook to register for.
 
280
    """
 
281
 
 
282
    def __init__(self, name, doc, introduced, deprecated=None, callbacks=None):
 
283
        """Create a HookPoint.
 
284
 
 
285
        :param name: The name of the hook, for clients to use when registering.
 
286
        :param doc: The docs for the hook.
 
287
        :param introduced: When the hook was introduced (e.g. (0, 15)).
 
288
        :param deprecated: When the hook was deprecated, None for
 
289
            not-deprecated.
 
290
        """
 
291
        self.name = name
 
292
        self.__doc__ = doc
 
293
        self.introduced = introduced
 
294
        self.deprecated = deprecated
 
295
        if callbacks is None:
 
296
            self._callbacks = []
 
297
        else:
 
298
            self._callbacks = callbacks
 
299
 
 
300
    def docs(self):
 
301
        """Generate the documentation for this HookPoint.
 
302
 
 
303
        :return: A string terminated in \n.
 
304
        """
 
305
        strings = []
 
306
        strings.append(self.name)
 
307
        strings.append('~'*len(self.name))
 
308
        strings.append('')
 
309
        if self.introduced:
 
310
            introduced_string = _format_version_tuple(self.introduced)
 
311
        else:
 
312
            introduced_string = 'unknown'
 
313
        strings.append('Introduced in: %s' % introduced_string)
 
314
        if self.deprecated:
 
315
            deprecated_string = _format_version_tuple(self.deprecated)
 
316
            strings.append('Deprecated in: %s' % deprecated_string)
 
317
        strings.append('')
 
318
        strings.extend(textwrap.wrap(self.__doc__,
 
319
            break_long_words=False))
 
320
        strings.append('')
 
321
        return '\n'.join(strings)
 
322
 
 
323
    def __eq__(self, other):
 
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))
 
338
 
 
339
    def hook(self, callback, callback_label):
 
340
        """Register a callback to be called when this HookPoint fires.
 
341
 
 
342
        :param callback: The callable to use when this HookPoint fires.
 
343
        :param callback_label: A label to show in the UI while this callback is
 
344
            processing.
 
345
        """
 
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)
 
363
 
 
364
    def __iter__(self):
 
365
        return (callback.get_obj() for callback, name in self._callbacks)
 
366
 
 
367
    def __len__(self):
 
368
        return len(self._callbacks)
 
369
 
 
370
    def __repr__(self):
 
371
        strings = []
 
372
        strings.append("<%s(" % type(self).__name__)
 
373
        strings.append(self.name)
 
374
        strings.append("), callbacks=[")
 
375
        callbacks = self._callbacks
 
376
        for (callback, callback_name) in callbacks:
 
377
            strings.append(repr(callback.get_obj()))
 
378
            strings.append("(")
 
379
            strings.append(callback_name)
 
380
            strings.append("),")
 
381
        if len(callbacks) == 1:
 
382
            strings[-1] = ")"
 
383
        strings.append("]>")
 
384
        return ''.join(strings)
 
385
 
 
386
 
 
387
_help_prefix = \
 
388
"""
 
389
Hooks
 
390
=====
 
391
 
 
392
Introduction
 
393
------------
 
394
 
 
395
A hook of type *xxx* of class *yyy* needs to be registered using::
 
396
 
 
397
  yyy.hooks.install_named_hook("xxx", ...)
 
398
 
 
399
See :doc:`Using hooks<../user-guide/hooks>` in the User Guide for examples.
 
400
 
 
401
The class that contains each hook is given before the hooks it supplies. For
 
402
instance, BranchHooks as the class is the hooks class for
 
403
`bzrlib.branch.Branch.hooks`.
 
404
 
 
405
Each description also indicates whether the hook runs on the client (the
 
406
machine where bzr was invoked) or the server (the machine addressed by
 
407
the branch URL).  These may be, but are not necessarily, the same machine.
 
408
 
 
409
Plugins (including hooks) are run on the server if all of these is true:
 
410
 
 
411
  * The connection is via a smart server (accessed with a URL starting with
 
412
    "bzr://", "bzr+ssh://" or "bzr+http://", or accessed via a "http://"
 
413
    URL when a smart server is available via HTTP).
 
414
 
 
415
  * The hook is either server specific or part of general infrastructure rather
 
416
    than client specific code (such as commit).
 
417
 
 
418
"""
 
419
 
 
420
def hooks_help_text(topic):
 
421
    segments = [_help_prefix]
 
422
    for hook_key in sorted(known_hooks.keys()):
 
423
        hooks = known_hooks_key_to_object(hook_key)
 
424
        segments.append(hooks.docs())
 
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))