~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/hooks.py

  • Committer: Vincent Ladeuil
  • Date: 2008-09-11 19:36:38 UTC
  • mfrom: (3703 +trunk)
  • mto: (3705.1.1 trunk2)
  • mto: This revision was merged to the branch mainline in revision 3708.
  • Revision ID: v.ladeuil+lp@free.fr-20080911193638-wtjyc1kcmacc6t1f
merge bzr.dev

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2007-2011 Canonical Ltd
 
1
# Copyright (C) 2007 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
12
12
#
13
13
# You should have received a copy of the GNU General Public License
14
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
 
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
16
16
 
17
17
 
18
18
"""Support for plugin hooking logic."""
19
 
 
20
 
from bzrlib import (
21
 
    registry,
22
 
    symbol_versioning,
23
 
    )
24
19
from bzrlib.lazy_import import lazy_import
 
20
from bzrlib.symbol_versioning import deprecated_method, one_five
25
21
lazy_import(globals(), """
26
 
import textwrap
27
 
 
28
22
from bzrlib import (
29
 
    _format_version_tuple,
30
 
    errors,
31
 
    pyutils,
32
 
    )
 
23
        errors,
 
24
        )
33
25
""")
34
26
 
35
27
 
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.config', 'ConfigHooks', '_ConfigHooks'),
76
 
    ('bzrlib.info', 'hooks', 'InfoHooks'),
77
 
    ('bzrlib.lock', 'Lock.hooks', 'LockHooks'),
78
 
    ('bzrlib.merge', 'Merger.hooks', 'MergeHooks'),
79
 
    ('bzrlib.msgeditor', 'hooks', 'MessageEditorHooks'),
80
 
    ('bzrlib.mutabletree', 'MutableTree.hooks', 'MutableTreeHooks'),
81
 
    ('bzrlib.smart.client', '_SmartClient.hooks', 'SmartClientHooks'),
82
 
    ('bzrlib.smart.server', 'SmartTCPServer.hooks', 'SmartServerHooks'),
83
 
    ('bzrlib.status', 'hooks', 'StatusHooks'),
84
 
    ('bzrlib.version_info_formats.format_rio', 'RioVersionInfoBuilder.hooks',
85
 
        'RioVersionInfoBuilderHooks'),
86
 
    ('bzrlib.merge_directive', 'BaseMergeDirective.hooks',
87
 
        'MergeDirectiveHooks'),
88
 
    )
89
 
 
90
 
known_hooks = KnownHooksRegistry()
91
 
for (_hook_module, _hook_attribute, _hook_class) in _builtin_known_hooks:
92
 
    known_hooks.register_lazy_hook(_hook_module, _hook_attribute, _hook_class)
93
 
del _builtin_known_hooks, _hook_module, _hook_attribute, _hook_class
94
 
 
95
 
 
96
 
def known_hooks_key_to_object((module_name, member_name)):
97
 
    """Convert a known_hooks key to a object.
98
 
 
99
 
    :param key: A tuple (module_name, member_name) as found in the keys of
100
 
        the known_hooks registry.
101
 
    :return: The object this specifies.
102
 
    """
103
 
    return pyutils.get_named_object(module_name, member_name)
104
 
 
105
 
 
106
 
@symbol_versioning.deprecated_function(symbol_versioning.deprecated_in((2, 3)))
107
 
def known_hooks_key_to_parent_and_attribute(key):
108
 
    """See KnownHooksRegistry.key_to_parent_and_attribute."""
109
 
    return known_hooks.key_to_parent_and_attribute(key)
110
 
 
111
 
 
112
28
class Hooks(dict):
113
29
    """A dictionary mapping hook name to a list of callables.
114
 
 
 
30
    
115
31
    e.g. ['FOO'] Is the list of items to be called when the
116
32
    FOO hook is triggered.
117
33
    """
118
34
 
119
 
    def __init__(self, module=None, member_name=None):
120
 
        """Create a new hooks dictionary.
121
 
 
122
 
        :param module: The module from which this hooks dictionary should be loaded
123
 
            (used for lazy hooks)
124
 
        :param member_name: Name under which this hooks dictionary should be loaded.
125
 
            (used for lazy hooks)
126
 
        """
 
35
    def __init__(self):
127
36
        dict.__init__(self)
128
37
        self._callable_names = {}
129
 
        self._module = module
130
 
        self._member_name = member_name
131
 
 
132
 
    def add_hook(self, name, doc, introduced, deprecated=None):
133
 
        """Add a hook point to this dictionary.
134
 
 
135
 
        :param name: The name of the hook, for clients to use when registering.
136
 
        :param doc: The docs for the hook.
137
 
        :param introduced: When the hook was introduced (e.g. (0, 15)).
138
 
        :param deprecated: When the hook was deprecated, None for
139
 
            not-deprecated.
140
 
        """
141
 
        if name in self:
142
 
            raise errors.DuplicateKey(name)
143
 
        if self._module:
144
 
            callbacks = _lazy_hooks.setdefault(
145
 
                (self._module, self._member_name, name), [])
146
 
        else:
147
 
            callbacks = None
148
 
        hookpoint = HookPoint(name=name, doc=doc, introduced=introduced,
149
 
                              deprecated=deprecated, callbacks=callbacks)
150
 
        self[name] = hookpoint
151
 
 
152
 
    @symbol_versioning.deprecated_method(symbol_versioning.deprecated_in((2, 4)))
153
 
    def create_hook(self, hook):
154
 
        """Create a hook which can have callbacks registered for it.
155
 
 
156
 
        :param hook: The hook to create. An object meeting the protocol of
157
 
            bzrlib.hooks.HookPoint. It's name is used as the key for future
158
 
            lookups.
159
 
        """
160
 
        if hook.name in self:
161
 
            raise errors.DuplicateKey(hook.name)
162
 
        self[hook.name] = hook
163
 
 
164
 
    def docs(self):
165
 
        """Generate the documentation for this Hooks instance.
166
 
 
167
 
        This introspects all the individual hooks and returns their docs as well.
168
 
        """
169
 
        hook_names = sorted(self.keys())
170
 
        hook_docs = []
171
 
        name = self.__class__.__name__
172
 
        hook_docs.append(name)
173
 
        hook_docs.append("-"*len(name))
174
 
        hook_docs.append("")
175
 
        for hook_name in hook_names:
176
 
            hook = self[hook_name]
177
 
            try:
178
 
                hook_docs.append(hook.docs())
179
 
            except AttributeError:
180
 
                # legacy hook
181
 
                strings = []
182
 
                strings.append(hook_name)
183
 
                strings.append("~" * len(hook_name))
184
 
                strings.append("")
185
 
                strings.append("An old-style hook. For documentation see the __init__ "
186
 
                    "method of '%s'\n" % (name,))
187
 
                hook_docs.extend(strings)
188
 
        return "\n".join(hook_docs)
189
38
 
190
39
    def get_hook_name(self, a_callable):
191
40
        """Get the name for a_callable for UI display.
192
41
 
193
42
        If no name has been registered, the string 'No hook name' is returned.
194
43
        We use a fixed string rather than repr or the callables module because
195
 
        the code names are rarely meaningful for end users and this is not
 
44
        the code names are rarely meaningful for end users and this is not 
196
45
        intended for debugging.
197
46
        """
198
47
        return self._callable_names.get(a_callable, "No hook name")
199
48
 
200
 
    def install_named_hook_lazy(self, hook_name, callable_module,
201
 
        callable_member, name):
202
 
        """Install a_callable in to the hook hook_name lazily, and label it.
 
49
    @deprecated_method(one_five)
 
50
    def install_hook(self, hook_name, a_callable):
 
51
        """Install a_callable in to the hook hook_name.
203
52
 
204
 
        :param hook_name: A hook name. See the __init__ method for the complete
205
 
            list of hooks.
206
 
        :param callable_module: Name of the module in which the callable is
207
 
            present.
208
 
        :param callable_member: Member name of the callable.
209
 
        :param name: A name to associate the callable with, to show users what
210
 
            is running.
 
53
        :param hook_name: A hook name. See the __init__ method of BranchHooks
 
54
            for the complete list of hooks.
 
55
        :param a_callable: The callable to be invoked when the hook triggers.
 
56
            The exact signature will depend on the hook - see the __init__ 
 
57
            method of BranchHooks for details on each hook.
211
58
        """
212
 
        try:
213
 
            hook = self[hook_name]
214
 
        except KeyError:
215
 
            raise errors.UnknownHook(self.__class__.__name__, hook_name)
216
 
        try:
217
 
            hook_lazy = getattr(hook, "hook_lazy")
218
 
        except AttributeError:
219
 
            raise errors.UnsupportedOperation(self.install_named_hook_lazy,
220
 
                self)
221
 
        else:
222
 
            hook_lazy(callable_module, callable_member, name)
 
59
        self.install_named_hook(hook_name, a_callable, None)
223
60
 
224
61
    def install_named_hook(self, hook_name, a_callable, name):
225
62
        """Install a_callable in to the hook hook_name, and label it name.
226
63
 
227
 
        :param hook_name: A hook name. See the __init__ method for the complete
228
 
            list of hooks.
 
64
        :param hook_name: A hook name. See the __init__ method of BranchHooks
 
65
            for the complete list of hooks.
229
66
        :param a_callable: The callable to be invoked when the hook triggers.
230
 
            The exact signature will depend on the hook - see the __init__
231
 
            method for details on each hook.
 
67
            The exact signature will depend on the hook - see the __init__ 
 
68
            method of BranchHooks for details on each hook.
232
69
        :param name: A name to associate a_callable with, to show users what is
233
70
            running.
234
71
        """
235
72
        try:
236
 
            hook = self[hook_name]
 
73
            self[hook_name].append(a_callable)
237
74
        except KeyError:
238
75
            raise errors.UnknownHook(self.__class__.__name__, hook_name)
239
 
        try:
240
 
            # list hooks, old-style, not yet deprecated but less useful.
241
 
            hook.append(a_callable)
242
 
        except AttributeError:
243
 
            hook.hook(a_callable, name)
244
76
        if name is not None:
245
77
            self.name_hook(a_callable, name)
246
78
 
247
 
    def uninstall_named_hook(self, hook_name, label):
248
 
        """Uninstall named hooks.
249
 
 
250
 
        :param hook_name: Hook point name
251
 
        :param label: Label of the callable to uninstall
252
 
        """
253
 
        try:
254
 
            hook = self[hook_name]
255
 
        except KeyError:
256
 
            raise errors.UnknownHook(self.__class__.__name__, hook_name)
257
 
        try:
258
 
            uninstall = getattr(hook, "uninstall")
259
 
        except AttributeError:
260
 
            raise errors.UnsupportedOperation(self.uninstall_named_hook, self)
261
 
        else:
262
 
            uninstall(label)
263
 
 
264
79
    def name_hook(self, a_callable, name):
265
80
        """Associate name with a_callable to show users what is running."""
266
81
        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))