~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/lazy_import.py

(vila) Fix test failures blocking package builds. (Vincent Ladeuil)

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
1
# Copyright (C) 2006-2010 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
"""Functionality to create lazy evaluation objects.
 
18
 
 
19
This includes waiting to import a module until it is actually used.
 
20
 
 
21
Most commonly, the 'lazy_import' function is used to import other modules
 
22
in an on-demand fashion. Typically use looks like::
 
23
 
 
24
    from bzrlib.lazy_import import lazy_import
 
25
    lazy_import(globals(), '''
 
26
    from bzrlib import (
 
27
        errors,
 
28
        osutils,
 
29
        branch,
 
30
        )
 
31
    import bzrlib.branch
 
32
    ''')
 
33
 
 
34
Then 'errors, osutils, branch' and 'bzrlib' will exist as lazy-loaded
 
35
objects which will be replaced with a real object on first use.
 
36
 
 
37
In general, it is best to only load modules in this way. This is because
 
38
it isn't safe to pass these variables to other functions before they
 
39
have been replaced. This is especially true for constants, sometimes
 
40
true for classes or functions (when used as a factory, or you want
 
41
to inherit from them).
 
42
"""
 
43
 
 
44
from __future__ import absolute_import
 
45
 
 
46
 
 
47
class ScopeReplacer(object):
 
48
    """A lazy object that will replace itself in the appropriate scope.
 
49
 
 
50
    This object sits, ready to create the real object the first time it is
 
51
    needed.
 
52
    """
 
53
 
 
54
    __slots__ = ('_scope', '_factory', '_name', '_real_obj')
 
55
 
 
56
    # If you to do x = y, setting this to False will disallow access to
 
57
    # members from the second variable (i.e. x). This should normally
 
58
    # be enabled for reasons of thread safety and documentation, but
 
59
    # will be disabled during the selftest command to check for abuse.
 
60
    _should_proxy = True
 
61
 
 
62
    def __init__(self, scope, factory, name):
 
63
        """Create a temporary object in the specified scope.
 
64
        Once used, a real object will be placed in the scope.
 
65
 
 
66
        :param scope: The scope the object should appear in
 
67
        :param factory: A callable that will create the real object.
 
68
            It will be passed (self, scope, name)
 
69
        :param name: The variable name in the given scope.
 
70
        """
 
71
        object.__setattr__(self, '_scope', scope)
 
72
        object.__setattr__(self, '_factory', factory)
 
73
        object.__setattr__(self, '_name', name)
 
74
        object.__setattr__(self, '_real_obj', None)
 
75
        scope[name] = self
 
76
 
 
77
    def _resolve(self):
 
78
        """Return the real object for which this is a placeholder"""
 
79
        name = object.__getattribute__(self, '_name')
 
80
        real_obj = object.__getattribute__(self, '_real_obj')
 
81
        if real_obj is None:
 
82
            # No obj generated previously, so generate from factory and scope.
 
83
            factory = object.__getattribute__(self, '_factory')
 
84
            scope = object.__getattribute__(self, '_scope')
 
85
            obj = factory(self, scope, name)
 
86
            if obj is self:
 
87
                raise errors.IllegalUseOfScopeReplacer(name, msg="Object tried"
 
88
                    " to replace itself, check it's not using its own scope.")
 
89
 
 
90
            # Check if another thread has jumped in while obj was generated.
 
91
            real_obj = object.__getattribute__(self, '_real_obj')
 
92
            if real_obj is None:
 
93
                # Still no prexisting obj, so go ahead and assign to scope and
 
94
                # return. There is still a small window here where races will
 
95
                # not be detected, but safest to avoid additional locking.
 
96
                object.__setattr__(self, '_real_obj', obj)
 
97
                scope[name] = obj
 
98
                return obj
 
99
 
 
100
        # Raise if proxying is disabled as obj has already been generated.
 
101
        if not ScopeReplacer._should_proxy:
 
102
            raise errors.IllegalUseOfScopeReplacer(
 
103
                name, msg="Object already replaced, did you assign it"
 
104
                          " to another variable?")
 
105
        return real_obj
 
106
 
 
107
    def __getattribute__(self, attr):
 
108
        obj = object.__getattribute__(self, '_resolve')()
 
109
        return getattr(obj, attr)
 
110
 
 
111
    def __setattr__(self, attr, value):
 
112
        obj = object.__getattribute__(self, '_resolve')()
 
113
        return setattr(obj, attr, value)
 
114
 
 
115
    def __call__(self, *args, **kwargs):
 
116
        obj = object.__getattribute__(self, '_resolve')()
 
117
        return obj(*args, **kwargs)
 
118
 
 
119
 
 
120
def disallow_proxying():
 
121
    """Disallow lazily imported modules to be used as proxies.
 
122
 
 
123
    Calling this function might cause problems with concurrent imports
 
124
    in multithreaded environments, but will help detecting wasteful
 
125
    indirection, so it should be called when executing unit tests.
 
126
 
 
127
    Only lazy imports that happen after this call are affected.
 
128
    """
 
129
    ScopeReplacer._should_proxy = False
 
130
 
 
131
 
 
132
class ImportReplacer(ScopeReplacer):
 
133
    """This is designed to replace only a portion of an import list.
 
134
 
 
135
    It will replace itself with a module, and then make children
 
136
    entries also ImportReplacer objects.
 
137
 
 
138
    At present, this only supports 'import foo.bar.baz' syntax.
 
139
    """
 
140
 
 
141
    # '_import_replacer_children' is intentionally a long semi-unique name
 
142
    # that won't likely exist elsewhere. This allows us to detect an
 
143
    # ImportReplacer object by using
 
144
    #       object.__getattribute__(obj, '_import_replacer_children')
 
145
    # We can't just use 'isinstance(obj, ImportReplacer)', because that
 
146
    # accesses .__class__, which goes through __getattribute__, and triggers
 
147
    # the replacement.
 
148
    __slots__ = ('_import_replacer_children', '_member', '_module_path')
 
149
 
 
150
    def __init__(self, scope, name, module_path, member=None, children={}):
 
151
        """Upon request import 'module_path' as the name 'module_name'.
 
152
        When imported, prepare children to also be imported.
 
153
 
 
154
        :param scope: The scope that objects should be imported into.
 
155
            Typically this is globals()
 
156
        :param name: The variable name. Often this is the same as the
 
157
            module_path. 'bzrlib'
 
158
        :param module_path: A list for the fully specified module path
 
159
            ['bzrlib', 'foo', 'bar']
 
160
        :param member: The member inside the module to import, often this is
 
161
            None, indicating the module is being imported.
 
162
        :param children: Children entries to be imported later.
 
163
            This should be a map of children specifications.
 
164
            ::
 
165
            
 
166
                {'foo':(['bzrlib', 'foo'], None,
 
167
                    {'bar':(['bzrlib', 'foo', 'bar'], None {})})
 
168
                }
 
169
 
 
170
        Examples::
 
171
 
 
172
            import foo => name='foo' module_path='foo',
 
173
                          member=None, children={}
 
174
            import foo.bar => name='foo' module_path='foo', member=None,
 
175
                              children={'bar':(['foo', 'bar'], None, {}}
 
176
            from foo import bar => name='bar' module_path='foo', member='bar'
 
177
                                   children={}
 
178
            from foo import bar, baz would get translated into 2 import
 
179
            requests. On for 'name=bar' and one for 'name=baz'
 
180
        """
 
181
        if (member is not None) and children:
 
182
            raise ValueError('Cannot supply both a member and children')
 
183
 
 
184
        object.__setattr__(self, '_import_replacer_children', children)
 
185
        object.__setattr__(self, '_member', member)
 
186
        object.__setattr__(self, '_module_path', module_path)
 
187
 
 
188
        # Indirecting through __class__ so that children can
 
189
        # override _import (especially our instrumented version)
 
190
        cls = object.__getattribute__(self, '__class__')
 
191
        ScopeReplacer.__init__(self, scope=scope, name=name,
 
192
                               factory=cls._import)
 
193
 
 
194
    def _import(self, scope, name):
 
195
        children = object.__getattribute__(self, '_import_replacer_children')
 
196
        member = object.__getattribute__(self, '_member')
 
197
        module_path = object.__getattribute__(self, '_module_path')
 
198
        module_python_path = '.'.join(module_path)
 
199
        if member is not None:
 
200
            module = __import__(module_python_path, scope, scope, [member], level=0)
 
201
            return getattr(module, member)
 
202
        else:
 
203
            module = __import__(module_python_path, scope, scope, [], level=0)
 
204
            for path in module_path[1:]:
 
205
                module = getattr(module, path)
 
206
 
 
207
        # Prepare the children to be imported
 
208
        for child_name, (child_path, child_member, grandchildren) in \
 
209
                children.iteritems():
 
210
            # Using self.__class__, so that children get children classes
 
211
            # instantiated. (This helps with instrumented tests)
 
212
            cls = object.__getattribute__(self, '__class__')
 
213
            cls(module.__dict__, name=child_name,
 
214
                module_path=child_path, member=child_member,
 
215
                children=grandchildren)
 
216
        return module
 
217
 
 
218
 
 
219
class ImportProcessor(object):
 
220
    """Convert text that users input into lazy import requests"""
 
221
 
 
222
    # TODO: jam 20060912 This class is probably not strict enough about
 
223
    #       what type of text it allows. For example, you can do:
 
224
    #       import (foo, bar), which is not allowed by python.
 
225
    #       For now, it should be supporting a superset of python import
 
226
    #       syntax which is all we really care about.
 
227
 
 
228
    __slots__ = ['imports', '_lazy_import_class']
 
229
 
 
230
    def __init__(self, lazy_import_class=None):
 
231
        self.imports = {}
 
232
        if lazy_import_class is None:
 
233
            self._lazy_import_class = ImportReplacer
 
234
        else:
 
235
            self._lazy_import_class = lazy_import_class
 
236
 
 
237
    def lazy_import(self, scope, text):
 
238
        """Convert the given text into a bunch of lazy import objects.
 
239
 
 
240
        This takes a text string, which should be similar to normal python
 
241
        import markup.
 
242
        """
 
243
        self._build_map(text)
 
244
        self._convert_imports(scope)
 
245
 
 
246
    def _convert_imports(self, scope):
 
247
        # Now convert the map into a set of imports
 
248
        for name, info in self.imports.iteritems():
 
249
            self._lazy_import_class(scope, name=name, module_path=info[0],
 
250
                                    member=info[1], children=info[2])
 
251
 
 
252
    def _build_map(self, text):
 
253
        """Take a string describing imports, and build up the internal map"""
 
254
        for line in self._canonicalize_import_text(text):
 
255
            if line.startswith('import '):
 
256
                self._convert_import_str(line)
 
257
            elif line.startswith('from '):
 
258
                self._convert_from_str(line)
 
259
            else:
 
260
                raise errors.InvalidImportLine(line,
 
261
                    "doesn't start with 'import ' or 'from '")
 
262
 
 
263
    def _convert_import_str(self, import_str):
 
264
        """This converts a import string into an import map.
 
265
 
 
266
        This only understands 'import foo, foo.bar, foo.bar.baz as bing'
 
267
 
 
268
        :param import_str: The import string to process
 
269
        """
 
270
        if not import_str.startswith('import '):
 
271
            raise ValueError('bad import string %r' % (import_str,))
 
272
        import_str = import_str[len('import '):]
 
273
 
 
274
        for path in import_str.split(','):
 
275
            path = path.strip()
 
276
            if not path:
 
277
                continue
 
278
            as_hunks = path.split(' as ')
 
279
            if len(as_hunks) == 2:
 
280
                # We have 'as' so this is a different style of import
 
281
                # 'import foo.bar.baz as bing' creates a local variable
 
282
                # named 'bing' which points to 'foo.bar.baz'
 
283
                name = as_hunks[1].strip()
 
284
                module_path = as_hunks[0].strip().split('.')
 
285
                if name in self.imports:
 
286
                    raise errors.ImportNameCollision(name)
 
287
                # No children available in 'import foo as bar'
 
288
                self.imports[name] = (module_path, None, {})
 
289
            else:
 
290
                # Now we need to handle
 
291
                module_path = path.split('.')
 
292
                name = module_path[0]
 
293
                if name not in self.imports:
 
294
                    # This is a new import that we haven't seen before
 
295
                    module_def = ([name], None, {})
 
296
                    self.imports[name] = module_def
 
297
                else:
 
298
                    module_def = self.imports[name]
 
299
 
 
300
                cur_path = [name]
 
301
                cur = module_def[2]
 
302
                for child in module_path[1:]:
 
303
                    cur_path.append(child)
 
304
                    if child in cur:
 
305
                        cur = cur[child][2]
 
306
                    else:
 
307
                        next = (cur_path[:], None, {})
 
308
                        cur[child] = next
 
309
                        cur = next[2]
 
310
 
 
311
    def _convert_from_str(self, from_str):
 
312
        """This converts a 'from foo import bar' string into an import map.
 
313
 
 
314
        :param from_str: The import string to process
 
315
        """
 
316
        if not from_str.startswith('from '):
 
317
            raise ValueError('bad from/import %r' % from_str)
 
318
        from_str = from_str[len('from '):]
 
319
 
 
320
        from_module, import_list = from_str.split(' import ')
 
321
 
 
322
        from_module_path = from_module.split('.')
 
323
 
 
324
        for path in import_list.split(','):
 
325
            path = path.strip()
 
326
            if not path:
 
327
                continue
 
328
            as_hunks = path.split(' as ')
 
329
            if len(as_hunks) == 2:
 
330
                # We have 'as' so this is a different style of import
 
331
                # 'import foo.bar.baz as bing' creates a local variable
 
332
                # named 'bing' which points to 'foo.bar.baz'
 
333
                name = as_hunks[1].strip()
 
334
                module = as_hunks[0].strip()
 
335
            else:
 
336
                name = module = path
 
337
            if name in self.imports:
 
338
                raise errors.ImportNameCollision(name)
 
339
            self.imports[name] = (from_module_path, module, {})
 
340
 
 
341
    def _canonicalize_import_text(self, text):
 
342
        """Take a list of imports, and split it into regularized form.
 
343
 
 
344
        This is meant to take regular import text, and convert it to
 
345
        the forms that the rest of the converters prefer.
 
346
        """
 
347
        out = []
 
348
        cur = None
 
349
        continuing = False
 
350
 
 
351
        for line in text.split('\n'):
 
352
            line = line.strip()
 
353
            loc = line.find('#')
 
354
            if loc != -1:
 
355
                line = line[:loc].strip()
 
356
 
 
357
            if not line:
 
358
                continue
 
359
            if cur is not None:
 
360
                if line.endswith(')'):
 
361
                    out.append(cur + ' ' + line[:-1])
 
362
                    cur = None
 
363
                else:
 
364
                    cur += ' ' + line
 
365
            else:
 
366
                if '(' in line and ')' not in line:
 
367
                    cur = line.replace('(', '')
 
368
                else:
 
369
                    out.append(line.replace('(', '').replace(')', ''))
 
370
        if cur is not None:
 
371
            raise errors.InvalidImportLine(cur, 'Unmatched parenthesis')
 
372
        return out
 
373
 
 
374
 
 
375
def lazy_import(scope, text, lazy_import_class=None):
 
376
    """Create lazy imports for all of the imports in text.
 
377
 
 
378
    This is typically used as something like::
 
379
 
 
380
        from bzrlib.lazy_import import lazy_import
 
381
        lazy_import(globals(), '''
 
382
        from bzrlib import (
 
383
            foo,
 
384
            bar,
 
385
            baz,
 
386
            )
 
387
        import bzrlib.branch
 
388
        import bzrlib.transport
 
389
        ''')
 
390
 
 
391
    Then 'foo, bar, baz' and 'bzrlib' will exist as lazy-loaded
 
392
    objects which will be replaced with a real object on first use.
 
393
 
 
394
    In general, it is best to only load modules in this way. This is
 
395
    because other objects (functions/classes/variables) are frequently
 
396
    used without accessing a member, which means we cannot tell they
 
397
    have been used.
 
398
    """
 
399
    # This is just a helper around ImportProcessor.lazy_import
 
400
    proc = ImportProcessor(lazy_import_class=lazy_import_class)
 
401
    return proc.lazy_import(scope, text)
 
402
 
 
403
 
 
404
# The only module that this module depends on is 'bzrlib.errors'. But it
 
405
# can actually be imported lazily, since we only need it if there is a
 
406
# problem.
 
407
 
 
408
lazy_import(globals(), """
 
409
from bzrlib import errors
 
410
""")