~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/hooks.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2010-05-21 13:36:51 UTC
  • mfrom: (5243.2.1 readdir_cleanup)
  • Revision ID: pqm@pqm.ubuntu.com-20100521133651-p62dndo2giy5ls21
(lifeless) Some cleanups to the readdir pyrex code for a little efficiency
 and to avoid compile warnings. (John A Meinel)

Show diffs side-by-side

added added

removed removed

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