~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/hooks.py

  • Committer: Parth Malwankar
  • Date: 2010-06-12 02:58:42 UTC
  • mto: This revision was merged to the branch mainline in revision 5291.
  • Revision ID: parth.malwankar@gmail.com-20100612025842-amc5em04efepm069
reduced STEP in recordcounter to allow more frequent updates
on progress bar for slower connections.

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
 
    )
 
25
        _format_version_tuple,
 
26
        errors,
 
27
        )
 
28
from bzrlib.help_topics import help_as_plain_text
33
29
""")
34
30
 
35
31
 
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
 
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')
93
63
 
94
64
 
95
65
def known_hooks_key_to_object((module_name, member_name)):
99
69
        the known_hooks registry.
100
70
    :return: The object this specifies.
101
71
    """
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)
 
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
109
90
 
110
91
 
111
92
class Hooks(dict):
115
96
    FOO hook is triggered.
116
97
    """
117
98
 
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
 
        """
 
99
    def __init__(self):
126
100
        dict.__init__(self)
127
101
        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)))
 
102
 
152
103
    def create_hook(self, hook):
153
104
        """Create a hook which can have callbacks registered for it.
154
105
 
196
147
        """
197
148
        return self._callable_names.get(a_callable, "No hook name")
198
149
 
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
150
    def install_named_hook(self, hook_name, a_callable, name):
224
151
        """Install a_callable in to the hook hook_name, and label it name.
225
152
 
226
 
        :param hook_name: A hook name. See the __init__ method for the complete
227
 
            list of hooks.
 
153
        :param hook_name: A hook name. See the __init__ method of BranchHooks
 
154
            for the complete list of hooks.
228
155
        :param a_callable: The callable to be invoked when the hook triggers.
229
156
            The exact signature will depend on the hook - see the __init__
230
 
            method for details on each hook.
 
157
            method of BranchHooks for details on each hook.
231
158
        :param name: A name to associate a_callable with, to show users what is
232
159
            running.
233
160
        """
243
170
        if name is not None:
244
171
            self.name_hook(a_callable, name)
245
172
 
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
173
    def name_hook(self, a_callable, name):
265
174
        """Associate name with a_callable to show users what is running."""
266
175
        self._callable_names[a_callable] = name
270
179
    """A single hook that clients can register to be called back when it fires.
271
180
 
272
181
    :ivar name: The name of the hook.
273
 
    :ivar doc: The docs for using the hook.
274
182
    :ivar introduced: A version tuple specifying what version the hook was
275
183
        introduced in. None indicates an unknown version.
276
184
    :ivar deprecated: A version tuple specifying what version the hook was
277
185
        deprecated or superseded in. None indicates that the hook is not
278
186
        superseded or deprecated. If the hook is superseded then the doc
279
187
        should describe the recommended replacement hook to register for.
 
188
    :ivar doc: The docs for using the hook.
280
189
    """
281
190
 
282
 
    def __init__(self, name, doc, introduced, deprecated=None, callbacks=None):
 
191
    def __init__(self, name, doc, introduced, deprecated):
283
192
        """Create a HookPoint.
284
193
 
285
194
        :param name: The name of the hook, for clients to use when registering.
292
201
        self.__doc__ = doc
293
202
        self.introduced = introduced
294
203
        self.deprecated = deprecated
295
 
        if callbacks is None:
296
 
            self._callbacks = []
297
 
        else:
298
 
            self._callbacks = callbacks
 
204
        self._callbacks = []
 
205
        self._callback_names = {}
299
206
 
300
207
    def docs(self):
301
208
        """Generate the documentation for this HookPoint.
321
228
        return '\n'.join(strings)
322
229
 
323
230
    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))
 
231
        return (type(other) == type(self) and 
 
232
            other.__dict__ == self.__dict__)
338
233
 
339
234
    def hook(self, callback, callback_label):
340
235
        """Register a callback to be called when this HookPoint fires.
343
238
        :param callback_label: A label to show in the UI while this callback is
344
239
            processing.
345
240
        """
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)
 
241
        self._callbacks.append(callback)
 
242
        if callback_label is not None:
 
243
            self._callback_names[callback] = callback_label
363
244
 
364
245
    def __iter__(self):
365
 
        return (callback.get_obj() for callback, name in self._callbacks)
 
246
        return iter(self._callbacks)
366
247
 
367
248
    def __len__(self):
368
249
        return len(self._callbacks)
372
253
        strings.append("<%s(" % type(self).__name__)
373
254
        strings.append(self.name)
374
255
        strings.append("), callbacks=[")
375
 
        callbacks = self._callbacks
376
 
        for (callback, callback_name) in callbacks:
377
 
            strings.append(repr(callback.get_obj()))
 
256
        for callback in self._callbacks:
 
257
            strings.append(repr(callback))
378
258
            strings.append("(")
379
 
            strings.append(callback_name)
 
259
            strings.append(self._callback_names[callback])
380
260
            strings.append("),")
381
 
        if len(callbacks) == 1:
 
261
        if len(self._callbacks) == 1:
382
262
            strings[-1] = ")"
383
263
        strings.append("]>")
384
264
        return ''.join(strings)
423
303
        hooks = known_hooks_key_to_object(hook_key)
424
304
        segments.append(hooks.docs())
425
305
    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))