~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/config.py

  • Committer: Martin
  • Date: 2011-04-15 21:22:57 UTC
  • mto: This revision was merged to the branch mainline in revision 5797.
  • Revision ID: gzlist@googlemail.com-20110415212257-jgtovwwp4be7egd9
Add release notes

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005-2010 Canonical Ltd
 
1
# Copyright (C) 2005-2011 Canonical Ltd
2
2
#   Authors: Robert Collins <robert.collins@canonical.com>
3
3
#            and others
4
4
#
63
63
"""
64
64
 
65
65
import os
 
66
import string
66
67
import sys
67
68
 
68
69
from bzrlib import commands
69
70
from bzrlib.decorators import needs_write_lock
70
71
from bzrlib.lazy_import import lazy_import
71
72
lazy_import(globals(), """
72
 
import errno
73
73
import fnmatch
74
74
import re
75
75
from cStringIO import StringIO
82
82
    errors,
83
83
    lockdir,
84
84
    mail_client,
 
85
    mergetools,
85
86
    osutils,
86
87
    registry,
87
88
    symbol_versioning,
128
129
STORE_BRANCH = 3
129
130
STORE_GLOBAL = 4
130
131
 
131
 
_ConfigObj = None
132
 
def ConfigObj(*args, **kwargs):
133
 
    global _ConfigObj
134
 
    if _ConfigObj is None:
135
 
        class ConfigObj(configobj.ConfigObj):
136
 
 
137
 
            def get_bool(self, section, key):
138
 
                return self[section].as_bool(key)
139
 
 
140
 
            def get_value(self, section, name):
141
 
                # Try [] for the old DEFAULT section.
142
 
                if section == "DEFAULT":
143
 
                    try:
144
 
                        return self[name]
145
 
                    except KeyError:
146
 
                        pass
147
 
                return self[section][name]
148
 
        _ConfigObj = ConfigObj
149
 
    return _ConfigObj(*args, **kwargs)
 
132
 
 
133
class ConfigObj(configobj.ConfigObj):
 
134
 
 
135
    def __init__(self, infile=None, **kwargs):
 
136
        # We define our own interpolation mechanism calling it option expansion
 
137
        super(ConfigObj, self).__init__(infile=infile,
 
138
                                        interpolation=False,
 
139
                                        **kwargs)
 
140
 
 
141
 
 
142
    def get_bool(self, section, key):
 
143
        return self[section].as_bool(key)
 
144
 
 
145
    def get_value(self, section, name):
 
146
        # Try [] for the old DEFAULT section.
 
147
        if section == "DEFAULT":
 
148
            try:
 
149
                return self[name]
 
150
            except KeyError:
 
151
                pass
 
152
        return self[section][name]
 
153
 
 
154
 
 
155
# FIXME: Until we can guarantee that each config file is loaded once and and
 
156
# only once for a given bzrlib session, we don't want to re-read the file every
 
157
# time we query for an option so we cache the value (bad ! watch out for tests
 
158
# needing to restore the proper value).This shouldn't be part of 2.4.0 final,
 
159
# yell at mgz^W vila and the RM if this is still present at that time
 
160
# -- vila 20110219
 
161
_expand_default_value = None
 
162
def _get_expand_default_value():
 
163
    global _expand_default_value
 
164
    if _expand_default_value is not None:
 
165
        return _expand_default_value
 
166
    conf = GlobalConfig()
 
167
    # Note that we must not use None for the expand value below or we'll run
 
168
    # into infinite recursion. Using False really would be quite silly ;)
 
169
    expand = conf.get_user_option_as_bool('bzr.config.expand', expand=True)
 
170
    if expand is None:
 
171
        # This is an opt-in feature, you *really* need to clearly say you want
 
172
        # to activate it !
 
173
        expand = False
 
174
    _expand_default_value = expand
 
175
    return expand
150
176
 
151
177
 
152
178
class Config(object):
188
214
    def _get_signing_policy(self):
189
215
        """Template method to override signature creation policy."""
190
216
 
 
217
    option_ref_re = None
 
218
 
 
219
    def expand_options(self, string, env=None):
 
220
        """Expand option references in the string in the configuration context.
 
221
 
 
222
        :param string: The string containing option to expand.
 
223
 
 
224
        :param env: An option dict defining additional configuration options or
 
225
            overriding existing ones.
 
226
 
 
227
        :returns: The expanded string.
 
228
        """
 
229
        return self._expand_options_in_string(string, env)
 
230
 
 
231
    def _expand_options_in_list(self, slist, env=None, _ref_stack=None):
 
232
        """Expand options in  a list of strings in the configuration context.
 
233
 
 
234
        :param slist: A list of strings.
 
235
 
 
236
        :param env: An option dict defining additional configuration options or
 
237
            overriding existing ones.
 
238
 
 
239
        :param _ref_stack: Private list containing the options being
 
240
            expanded to detect loops.
 
241
 
 
242
        :returns: The flatten list of expanded strings.
 
243
        """
 
244
        # expand options in each value separately flattening lists
 
245
        result = []
 
246
        for s in slist:
 
247
            value = self._expand_options_in_string(s, env, _ref_stack)
 
248
            if isinstance(value, list):
 
249
                result.extend(value)
 
250
            else:
 
251
                result.append(value)
 
252
        return result
 
253
 
 
254
    def _expand_options_in_string(self, string, env=None, _ref_stack=None):
 
255
        """Expand options in the string in the configuration context.
 
256
 
 
257
        :param string: The string to be expanded.
 
258
 
 
259
        :param env: An option dict defining additional configuration options or
 
260
            overriding existing ones.
 
261
 
 
262
        :param _ref_stack: Private list containing the options being
 
263
            expanded to detect loops.
 
264
 
 
265
        :returns: The expanded string.
 
266
        """
 
267
        if string is None:
 
268
            # Not much to expand there
 
269
            return None
 
270
        if _ref_stack is None:
 
271
            # What references are currently resolved (to detect loops)
 
272
            _ref_stack = []
 
273
        if self.option_ref_re is None:
 
274
            # We want to match the most embedded reference first (i.e. for
 
275
            # '{{foo}}' we will get '{foo}',
 
276
            # for '{bar{baz}}' we will get '{baz}'
 
277
            self.option_ref_re = re.compile('({[^{}]+})')
 
278
        result = string
 
279
        # We need to iterate until no more refs appear ({{foo}} will need two
 
280
        # iterations for example).
 
281
        while True:
 
282
            raw_chunks = self.option_ref_re.split(result)
 
283
            if len(raw_chunks) == 1:
 
284
                # Shorcut the trivial case: no refs
 
285
                return result
 
286
            chunks = []
 
287
            list_value = False
 
288
            # Split will isolate refs so that every other chunk is a ref
 
289
            chunk_is_ref = False
 
290
            for chunk in raw_chunks:
 
291
                if not chunk_is_ref:
 
292
                    if chunk:
 
293
                        # Keep only non-empty strings (or we get bogus empty
 
294
                        # slots when a list value is involved).
 
295
                        chunks.append(chunk)
 
296
                    chunk_is_ref = True
 
297
                else:
 
298
                    name = chunk[1:-1]
 
299
                    if name in _ref_stack:
 
300
                        raise errors.OptionExpansionLoop(string, _ref_stack)
 
301
                    _ref_stack.append(name)
 
302
                    value = self._expand_option(name, env, _ref_stack)
 
303
                    if value is None:
 
304
                        raise errors.ExpandingUnknownOption(name, string)
 
305
                    if isinstance(value, list):
 
306
                        list_value = True
 
307
                        chunks.extend(value)
 
308
                    else:
 
309
                        chunks.append(value)
 
310
                    _ref_stack.pop()
 
311
                    chunk_is_ref = False
 
312
            if list_value:
 
313
                # Once a list appears as the result of an expansion, all
 
314
                # callers will get a list result. This allows a consistent
 
315
                # behavior even when some options in the expansion chain
 
316
                # defined as strings (no comma in their value) but their
 
317
                # expanded value is a list.
 
318
                return self._expand_options_in_list(chunks, env, _ref_stack)
 
319
            else:
 
320
                result = ''.join(chunks)
 
321
        return result
 
322
 
 
323
    def _expand_option(self, name, env, _ref_stack):
 
324
        if env is not None and name in env:
 
325
            # Special case, values provided in env takes precedence over
 
326
            # anything else
 
327
            value = env[name]
 
328
        else:
 
329
            # FIXME: This is a limited implementation, what we really need is a
 
330
            # way to query the bzr config for the value of an option,
 
331
            # respecting the scope rules (That is, once we implement fallback
 
332
            # configs, getting the option value should restart from the top
 
333
            # config, not the current one) -- vila 20101222
 
334
            value = self.get_user_option(name, expand=False)
 
335
            if isinstance(value, list):
 
336
                value = self._expand_options_in_list(value, env, _ref_stack)
 
337
            else:
 
338
                value = self._expand_options_in_string(value, env, _ref_stack)
 
339
        return value
 
340
 
191
341
    def _get_user_option(self, option_name):
192
342
        """Template method to provide a user option."""
193
343
        return None
194
344
 
195
 
    def get_user_option(self, option_name):
196
 
        """Get a generic option - no special process, no default."""
197
 
        return self._get_user_option(option_name)
198
 
 
199
 
    def get_user_option_as_bool(self, option_name):
 
345
    def get_user_option(self, option_name, expand=None):
 
346
        """Get a generic option - no special process, no default.
 
347
 
 
348
        :param option_name: The queried option.
 
349
 
 
350
        :param expand: Whether options references should be expanded.
 
351
 
 
352
        :returns: The value of the option.
 
353
        """
 
354
        if expand is None:
 
355
            expand = _get_expand_default_value()
 
356
        value = self._get_user_option(option_name)
 
357
        if expand:
 
358
            if isinstance(value, list):
 
359
                value = self._expand_options_in_list(value)
 
360
            elif isinstance(value, dict):
 
361
                trace.warning('Cannot expand "%s":'
 
362
                              ' Dicts do not support option expansion'
 
363
                              % (option_name,))
 
364
            else:
 
365
                value = self._expand_options_in_string(value)
 
366
        return value
 
367
 
 
368
    def get_user_option_as_bool(self, option_name, expand=None):
200
369
        """Get a generic option as a boolean - no special process, no default.
201
370
 
202
371
        :return None if the option doesn't exist or its value can't be
203
372
            interpreted as a boolean. Returns True or False otherwise.
204
373
        """
205
 
        s = self._get_user_option(option_name)
 
374
        s = self.get_user_option(option_name, expand=expand)
206
375
        if s is None:
207
376
            # The option doesn't exist
208
377
            return None
213
382
                          s, option_name)
214
383
        return val
215
384
 
216
 
    def get_user_option_as_list(self, option_name):
 
385
    def get_user_option_as_list(self, option_name, expand=None):
217
386
        """Get a generic option as a list - no special process, no default.
218
387
 
219
388
        :return None if the option doesn't exist. Returns the value as a list
220
389
            otherwise.
221
390
        """
222
 
        l = self._get_user_option(option_name)
 
391
        l = self.get_user_option(option_name, expand=expand)
223
392
        if isinstance(l, (str, unicode)):
224
 
            # A single value, most probably the user forgot the final ','
 
393
            # A single value, most probably the user forgot (or didn't care to
 
394
            # add) the final ','
225
395
            l = [l]
226
396
        return l
227
397
 
271
441
        the concrete policy type is checked, and finally
272
442
        $EMAIL is examined.
273
443
        If no username can be found, errors.NoWhoami exception is raised.
274
 
 
275
 
        TODO: Check it's reasonably well-formed.
276
444
        """
277
445
        v = os.environ.get('BZR_EMAIL')
278
446
        if v:
279
447
            return v.decode(osutils.get_user_encoding())
280
 
 
281
448
        v = self._get_user_id()
282
449
        if v:
283
450
            return v
284
 
 
285
451
        v = os.environ.get('EMAIL')
286
452
        if v:
287
453
            return v.decode(osutils.get_user_encoding())
288
 
 
 
454
        name, email = _auto_user_id()
 
455
        if name and email:
 
456
            return '%s <%s>' % (name, email)
 
457
        elif email:
 
458
            return email
289
459
        raise errors.NoWhoami()
290
460
 
291
461
    def ensure_username(self):
357
527
        else:
358
528
            return True
359
529
 
 
530
    def get_merge_tools(self):
 
531
        tools = {}
 
532
        for (oname, value, section, conf_id, parser) in self._get_options():
 
533
            if oname.startswith('bzr.mergetool.'):
 
534
                tool_name = oname[len('bzr.mergetool.'):]
 
535
                tools[tool_name] = value
 
536
        trace.mutter('loaded merge tools: %r' % tools)
 
537
        return tools
 
538
 
 
539
    def find_merge_tool(self, name):
 
540
        # We fake a defaults mechanism here by checking if the given name can 
 
541
        # be found in the known_merge_tools if it's not found in the config.
 
542
        # This should be done through the proposed config defaults mechanism
 
543
        # when it becomes available in the future.
 
544
        command_line = (self.get_user_option('bzr.mergetool.%s' % name,
 
545
                                             expand=False)
 
546
                        or mergetools.known_merge_tools.get(name, None))
 
547
        return command_line
 
548
 
360
549
 
361
550
class IniBasedConfig(Config):
362
551
    """A configuration policy that draws from ini files."""
496
685
        config_id = self.config_id()
497
686
        for (section_name, section) in sections:
498
687
            for (name, value) in section.iteritems():
499
 
                yield (name, value, section_name, config_id)
 
688
                yield (name, parser._quote(value), section_name,
 
689
                       config_id, parser)
500
690
 
501
691
    def _get_option_policy(self, section, option_name):
502
692
        """Return the policy for the given (section, option_name) pair."""
652
842
    def __init__(self, file_name):
653
843
        super(LockableConfig, self).__init__(file_name=file_name)
654
844
        self.dir = osutils.dirname(osutils.safe_unicode(self.file_name))
 
845
        # FIXME: It doesn't matter that we don't provide possible_transports
 
846
        # below since this is currently used only for local config files ;
 
847
        # local transports are not shared. But if/when we start using
 
848
        # LockableConfig for other kind of transports, we will need to reuse
 
849
        # whatever connection is already established -- vila 20100929
655
850
        self.transport = transport.get_transport(self.dir)
656
851
        self._lock = lockdir.LockDir(self.transport, 'lock')
657
852
 
772
967
        super(LockableConfig, self).remove_user_option(option_name,
773
968
                                                       section_name)
774
969
 
 
970
def _iter_for_location_by_parts(sections, location):
 
971
    """Keep only the sessions matching the specified location.
 
972
 
 
973
    :param sections: An iterable of section names.
 
974
 
 
975
    :param location: An url or a local path to match against.
 
976
 
 
977
    :returns: An iterator of (section, extra_path, nb_parts) where nb is the
 
978
        number of path components in the section name, section is the section
 
979
        name and extra_path is the difference between location and the section
 
980
        name.
 
981
    """
 
982
    location_parts = location.rstrip('/').split('/')
 
983
 
 
984
    for section in sections:
 
985
        # location is a local path if possible, so we need
 
986
        # to convert 'file://' urls to local paths if necessary.
 
987
 
 
988
        # FIXME: I don't think the above comment is still up to date,
 
989
        # LocationConfig is always instantiated with an url -- vila 2011-04-07
 
990
 
 
991
        # This also avoids having file:///path be a more exact
 
992
        # match than '/path'.
 
993
 
 
994
        # FIXME: Not sure about the above either, but since the path components
 
995
        # are compared in sync, adding two empty components (//) is likely to
 
996
        # trick the comparison and also trick the check on the number of
 
997
        # components, so we *should* take only the relevant part of the url. On
 
998
        # the other hand, this means 'file://' urls *can't* be used in sections
 
999
        # so more work is probably needed -- vila 2011-04-07
 
1000
 
 
1001
        if section.startswith('file://'):
 
1002
            section_path = urlutils.local_path_from_url(section)
 
1003
        else:
 
1004
            section_path = section
 
1005
        section_parts = section_path.rstrip('/').split('/')
 
1006
 
 
1007
        matched = True
 
1008
        if len(section_parts) > len(location_parts):
 
1009
            # More path components in the section, they can't match
 
1010
            matched = False
 
1011
        else:
 
1012
            # Rely on zip truncating in length to the length of the shortest
 
1013
            # argument sequence.
 
1014
            names = zip(location_parts, section_parts)
 
1015
            for name in names:
 
1016
                if not fnmatch.fnmatch(name[0], name[1]):
 
1017
                    matched = False
 
1018
                    break
 
1019
        if not matched:
 
1020
            continue
 
1021
        # build the path difference between the section and the location
 
1022
        extra_path = '/'.join(location_parts[len(section_parts):])
 
1023
        yield section, extra_path, len(section_parts)
 
1024
 
775
1025
 
776
1026
class LocationConfig(LockableConfig):
777
1027
    """A configuration object that gives the policy for a location."""
806
1056
 
807
1057
    def _get_matching_sections(self):
808
1058
        """Return an ordered list of section names matching this location."""
809
 
        sections = self._get_parser()
810
 
        location_names = self.location.split('/')
811
 
        if self.location.endswith('/'):
812
 
            del location_names[-1]
813
 
        matches=[]
814
 
        for section in sections:
815
 
            # location is a local path if possible, so we need
816
 
            # to convert 'file://' urls to local paths if necessary.
817
 
            # This also avoids having file:///path be a more exact
818
 
            # match than '/path'.
819
 
            if section.startswith('file://'):
820
 
                section_path = urlutils.local_path_from_url(section)
821
 
            else:
822
 
                section_path = section
823
 
            section_names = section_path.split('/')
824
 
            if section.endswith('/'):
825
 
                del section_names[-1]
826
 
            names = zip(location_names, section_names)
827
 
            matched = True
828
 
            for name in names:
829
 
                if not fnmatch.fnmatch(name[0], name[1]):
830
 
                    matched = False
831
 
                    break
832
 
            if not matched:
833
 
                continue
834
 
            # so, for the common prefix they matched.
835
 
            # if section is longer, no match.
836
 
            if len(section_names) > len(location_names):
837
 
                continue
838
 
            matches.append((len(section_names), section,
839
 
                            '/'.join(location_names[len(section_names):])))
 
1059
        matches = list(_iter_for_location_by_parts(self._get_parser(),
 
1060
                                                   self.location))
840
1061
        # put the longest (aka more specific) locations first
841
 
        matches.sort(reverse=True)
842
 
        sections = []
843
 
        for (length, section, extra_path) in matches:
844
 
            sections.append((section, extra_path))
 
1062
        matches.sort(
 
1063
            key=lambda (section, extra_path, length): (length, section),
 
1064
            reverse=True)
 
1065
        for (section, extra_path, length) in matches:
 
1066
            yield section, extra_path
845
1067
            # should we stop looking for parent configs here?
846
1068
            try:
847
1069
                if self._get_parser()[section].as_bool('ignore_parents'):
848
1070
                    break
849
1071
            except KeyError:
850
1072
                pass
851
 
        return sections
852
1073
 
853
1074
    def _get_sections(self, name=None):
854
1075
        """See IniBasedConfig._get_sections()."""
1042
1263
        config_id = self.config_id()
1043
1264
        for (section_name, section) in sections:
1044
1265
            for (name, value) in section.iteritems():
1045
 
                yield (name, value, section_name, config_id)
 
1266
                yield (name, value, section_name,
 
1267
                       config_id, branch_config._get_parser())
1046
1268
        # Then the global options
1047
1269
        for option in self._get_global_config()._get_options():
1048
1270
            yield option
1121
1343
def config_dir():
1122
1344
    """Return per-user configuration directory.
1123
1345
 
1124
 
    By default this is ~/.bazaar/
 
1346
    By default this is %APPDATA%/bazaar/2.0 on Windows, ~/.bazaar on Mac OS X
 
1347
    and Linux.  On Linux, if there is a $XDG_CONFIG_HOME/bazaar directory,
 
1348
    that will be used instead.
1125
1349
 
1126
1350
    TODO: Global option --config-dir to override this.
1127
1351
    """
1128
1352
    base = os.environ.get('BZR_HOME', None)
1129
1353
    if sys.platform == 'win32':
 
1354
        # environ variables on Windows are in user encoding/mbcs. So decode
 
1355
        # before using one
 
1356
        if base is not None:
 
1357
            base = base.decode('mbcs')
1130
1358
        if base is None:
1131
1359
            base = win32utils.get_appdata_location_unicode()
1132
1360
        if base is None:
1133
1361
            base = os.environ.get('HOME', None)
 
1362
            if base is not None:
 
1363
                base = base.decode('mbcs')
1134
1364
        if base is None:
1135
1365
            raise errors.BzrError('You must have one of BZR_HOME, APPDATA,'
1136
1366
                                  ' or HOME set')
1137
1367
        return osutils.pathjoin(base, 'bazaar', '2.0')
 
1368
    elif sys.platform == 'darwin':
 
1369
        if base is None:
 
1370
            # this takes into account $HOME
 
1371
            base = os.path.expanduser("~")
 
1372
        return osutils.pathjoin(base, '.bazaar')
1138
1373
    else:
1139
1374
        if base is None:
 
1375
 
 
1376
            xdg_dir = os.environ.get('XDG_CONFIG_HOME', None)
 
1377
            if xdg_dir is None:
 
1378
                xdg_dir = osutils.pathjoin(os.path.expanduser("~"), ".config")
 
1379
            xdg_dir = osutils.pathjoin(xdg_dir, 'bazaar')
 
1380
            if osutils.isdir(xdg_dir):
 
1381
                trace.mutter(
 
1382
                    "Using configuration in XDG directory %s." % xdg_dir)
 
1383
                return xdg_dir
 
1384
 
1140
1385
            base = os.path.expanduser("~")
1141
1386
        return osutils.pathjoin(base, ".bazaar")
1142
1387
 
1188
1433
        return os.path.expanduser('~/.cache')
1189
1434
 
1190
1435
 
 
1436
def _get_default_mail_domain():
 
1437
    """If possible, return the assumed default email domain.
 
1438
 
 
1439
    :returns: string mail domain, or None.
 
1440
    """
 
1441
    if sys.platform == 'win32':
 
1442
        # No implementation yet; patches welcome
 
1443
        return None
 
1444
    try:
 
1445
        f = open('/etc/mailname')
 
1446
    except (IOError, OSError), e:
 
1447
        return None
 
1448
    try:
 
1449
        domain = f.read().strip()
 
1450
        return domain
 
1451
    finally:
 
1452
        f.close()
 
1453
 
 
1454
 
 
1455
def _auto_user_id():
 
1456
    """Calculate automatic user identification.
 
1457
 
 
1458
    :returns: (realname, email), either of which may be None if they can't be
 
1459
    determined.
 
1460
 
 
1461
    Only used when none is set in the environment or the id file.
 
1462
 
 
1463
    This only returns an email address if we can be fairly sure the 
 
1464
    address is reasonable, ie if /etc/mailname is set on unix.
 
1465
 
 
1466
    This doesn't use the FQDN as the default domain because that may be 
 
1467
    slow, and it doesn't use the hostname alone because that's not normally 
 
1468
    a reasonable address.
 
1469
    """
 
1470
    if sys.platform == 'win32':
 
1471
        # No implementation to reliably determine Windows default mail
 
1472
        # address; please add one.
 
1473
        return None, None
 
1474
 
 
1475
    default_mail_domain = _get_default_mail_domain()
 
1476
    if not default_mail_domain:
 
1477
        return None, None
 
1478
 
 
1479
    import pwd
 
1480
    uid = os.getuid()
 
1481
    try:
 
1482
        w = pwd.getpwuid(uid)
 
1483
    except KeyError:
 
1484
        mutter('no passwd entry for uid %d?' % uid)
 
1485
        return None, None
 
1486
 
 
1487
    # we try utf-8 first, because on many variants (like Linux),
 
1488
    # /etc/passwd "should" be in utf-8, and because it's unlikely to give
 
1489
    # false positives.  (many users will have their user encoding set to
 
1490
    # latin-1, which cannot raise UnicodeError.)
 
1491
    try:
 
1492
        gecos = w.pw_gecos.decode('utf-8')
 
1493
        encoding = 'utf-8'
 
1494
    except UnicodeError:
 
1495
        try:
 
1496
            encoding = osutils.get_user_encoding()
 
1497
            gecos = w.pw_gecos.decode(encoding)
 
1498
        except UnicodeError, e:
 
1499
            mutter("cannot decode passwd entry %s" % w)
 
1500
            return None, None
 
1501
    try:
 
1502
        username = w.pw_name.decode(encoding)
 
1503
    except UnicodeError, e:
 
1504
        mutter("cannot decode passwd entry %s" % w)
 
1505
        return None, None
 
1506
 
 
1507
    comma = gecos.find(',')
 
1508
    if comma == -1:
 
1509
        realname = gecos
 
1510
    else:
 
1511
        realname = gecos[:comma]
 
1512
 
 
1513
    return realname, (username + '@' + default_mail_domain)
 
1514
 
 
1515
 
1191
1516
def parse_username(username):
1192
1517
    """Parse e-mail username and return a (name, address) tuple."""
1193
1518
    match = re.match(r'(.*?)\s*<?([\w+.-]+@[\w+.-]+)>?', username)
1772
2097
class cmd_config(commands.Command):
1773
2098
    __doc__ = """Display, set or remove a configuration option.
1774
2099
 
1775
 
    Display the MATCHING configuration options mentioning their scope (the
1776
 
    configuration file they are defined in). The active value that bzr will
1777
 
    take into account is the first one displayed.
 
2100
    Display the active value for a given option.
 
2101
 
 
2102
    If --all is specified, NAME is interpreted as a regular expression and all
 
2103
    matching options are displayed mentioning their scope. The active value
 
2104
    that bzr will take into account is the first one displayed for each option.
 
2105
 
 
2106
    If no NAME is given, --all .* is implied.
1778
2107
 
1779
2108
    Setting a value is achieved by using name=value without spaces. The value
1780
2109
    is set in the most relevant scope and can be checked by displaying the
1781
2110
    option again.
1782
2111
    """
1783
2112
 
1784
 
    aliases = ['conf']
1785
 
    takes_args = ['matching?']
 
2113
    takes_args = ['name?']
1786
2114
 
1787
2115
    takes_options = [
1788
2116
        'directory',
1791
2119
        commands.Option('scope', help='Reduce the scope to the specified'
1792
2120
                        ' configuration file',
1793
2121
                        type=unicode),
 
2122
        commands.Option('all',
 
2123
            help='Display all the defined values for the matching options.',
 
2124
            ),
1794
2125
        commands.Option('remove', help='Remove the option from'
1795
2126
                        ' the configuration file'),
1796
2127
        ]
1797
2128
 
1798
2129
    @commands.display_command
1799
 
    def run(self, matching=None, directory=None, scope=None, remove=False):
 
2130
    def run(self, name=None, all=False, directory=None, scope=None,
 
2131
            remove=False):
1800
2132
        if directory is None:
1801
2133
            directory = '.'
1802
2134
        directory = urlutils.normalize_url(directory)
1803
 
        if matching is None:
1804
 
            self._show_config('*', directory)
 
2135
        if remove and all:
 
2136
            raise errors.BzrError(
 
2137
                '--all and --remove are mutually exclusive.')
 
2138
        elif remove:
 
2139
            # Delete the option in the given scope
 
2140
            self._remove_config_option(name, directory, scope)
 
2141
        elif name is None:
 
2142
            # Defaults to all options
 
2143
            self._show_matching_options('.*', directory, scope)
1805
2144
        else:
1806
 
            if remove:
1807
 
                self._remove_config_option(matching, directory, scope)
 
2145
            try:
 
2146
                name, value = name.split('=', 1)
 
2147
            except ValueError:
 
2148
                # Display the option(s) value(s)
 
2149
                if all:
 
2150
                    self._show_matching_options(name, directory, scope)
 
2151
                else:
 
2152
                    self._show_value(name, directory, scope)
1808
2153
            else:
1809
 
                pos = matching.find('=')
1810
 
                if pos == -1:
1811
 
                    self._show_config(matching, directory)
1812
 
                else:
1813
 
                    self._set_config_option(matching[:pos], matching[pos+1:],
1814
 
                                            directory, scope)
 
2154
                if all:
 
2155
                    raise errors.BzrError(
 
2156
                        'Only one option can be set.')
 
2157
                # Set the option value
 
2158
                self._set_config_option(name, value, directory, scope)
1815
2159
 
1816
2160
    def _get_configs(self, directory, scope=None):
1817
2161
        """Iterate the configurations specified by ``directory`` and ``scope``.
1838
2182
                yield LocationConfig(directory)
1839
2183
                yield GlobalConfig()
1840
2184
 
1841
 
    def _show_config(self, matching, directory):
1842
 
        # Turn the glob into a regexp
1843
 
        matching_re = re.compile(fnmatch.translate(matching))
 
2185
    def _show_value(self, name, directory, scope):
 
2186
        displayed = False
 
2187
        for c in self._get_configs(directory, scope):
 
2188
            if displayed:
 
2189
                break
 
2190
            for (oname, value, section, conf_id, parser) in c._get_options():
 
2191
                if name == oname:
 
2192
                    # Display only the first value and exit
 
2193
 
 
2194
                    # FIXME: We need to use get_user_option to take policies
 
2195
                    # into account and we need to make sure the option exists
 
2196
                    # too (hence the two for loops), this needs a better API
 
2197
                    # -- vila 20101117
 
2198
                    value = c.get_user_option(name)
 
2199
                    # Quote the value appropriately
 
2200
                    value = parser._quote(value)
 
2201
                    self.outf.write('%s\n' % (value,))
 
2202
                    displayed = True
 
2203
                    break
 
2204
        if not displayed:
 
2205
            raise errors.NoSuchConfigOption(name)
 
2206
 
 
2207
    def _show_matching_options(self, name, directory, scope):
 
2208
        name = re.compile(name)
 
2209
        # We want any error in the regexp to be raised *now* so we need to
 
2210
        # avoid the delay introduced by the lazy regexp.
 
2211
        name._compile_and_collapse()
1844
2212
        cur_conf_id = None
1845
 
        for c in self._get_configs(directory):
1846
 
            for (name, value, section, conf_id) in c._get_options():
1847
 
                if matching_re.search(name):
 
2213
        cur_section = None
 
2214
        for c in self._get_configs(directory, scope):
 
2215
            for (oname, value, section, conf_id, parser) in c._get_options():
 
2216
                if name.search(oname):
1848
2217
                    if cur_conf_id != conf_id:
 
2218
                        # Explain where the options are defined
1849
2219
                        self.outf.write('%s:\n' % (conf_id,))
1850
2220
                        cur_conf_id = conf_id
1851
 
                    self.outf.write('  %s = %s\n' % (name, value))
 
2221
                        cur_section = None
 
2222
                    if (section not in (None, 'DEFAULT')
 
2223
                        and cur_section != section):
 
2224
                        # Display the section if it's not the default (or only)
 
2225
                        # one.
 
2226
                        self.outf.write('  [%s]\n' % (section,))
 
2227
                        cur_section = section
 
2228
                    self.outf.write('  %s = %s\n' % (oname, value))
1852
2229
 
1853
2230
    def _set_config_option(self, name, value, directory, scope):
1854
2231
        for conf in self._get_configs(directory, scope):
1858
2235
            raise errors.NoSuchConfig(scope)
1859
2236
 
1860
2237
    def _remove_config_option(self, name, directory, scope):
 
2238
        if name is None:
 
2239
            raise errors.BzrCommandError(
 
2240
                '--remove expects an option to remove.')
1861
2241
        removed = False
1862
2242
        for conf in self._get_configs(directory, scope):
1863
2243
            for (section_name, section, conf_id) in conf._get_sections():