/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/config.py

  • Committer: A. S. Budden
  • Date: 2011-05-04 13:26:14 UTC
  • mto: (5816.6.16 bazaar_source)
  • mto: This revision was merged to the branch mainline in revision 5835.
  • Revision ID: abudden@gmail.com-20110504132614-3ghb1ajucl6plc5z
Set the parent location of the bound branch to that of the master branch.

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
 
 
69
from bzrlib import commands
 
70
from bzrlib.decorators import needs_write_lock
68
71
from bzrlib.lazy_import import lazy_import
69
72
lazy_import(globals(), """
70
 
import errno
71
 
from fnmatch import fnmatch
 
73
import fnmatch
72
74
import re
73
75
from cStringIO import StringIO
74
76
 
75
77
import bzrlib
76
78
from bzrlib import (
 
79
    atomicfile,
 
80
    bzrdir,
77
81
    debug,
78
82
    errors,
 
83
    lockdir,
79
84
    mail_client,
 
85
    mergetools,
80
86
    osutils,
81
87
    registry,
82
88
    symbol_versioning,
83
89
    trace,
 
90
    transport,
84
91
    ui,
85
92
    urlutils,
86
93
    win32utils,
122
129
STORE_BRANCH = 3
123
130
STORE_GLOBAL = 4
124
131
 
125
 
_ConfigObj = None
126
 
def ConfigObj(*args, **kwargs):
127
 
    global _ConfigObj
128
 
    if _ConfigObj is None:
129
 
        class ConfigObj(configobj.ConfigObj):
130
 
 
131
 
            def get_bool(self, section, key):
132
 
                return self[section].as_bool(key)
133
 
 
134
 
            def get_value(self, section, name):
135
 
                # Try [] for the old DEFAULT section.
136
 
                if section == "DEFAULT":
137
 
                    try:
138
 
                        return self[name]
139
 
                    except KeyError:
140
 
                        pass
141
 
                return self[section][name]
142
 
        _ConfigObj = ConfigObj
143
 
    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
144
176
 
145
177
 
146
178
class Config(object):
149
181
    def __init__(self):
150
182
        super(Config, self).__init__()
151
183
 
 
184
    def config_id(self):
 
185
        """Returns a unique ID for the config."""
 
186
        raise NotImplementedError(self.config_id)
 
187
 
152
188
    def get_editor(self):
153
189
        """Get the users pop up editor."""
154
190
        raise NotImplementedError
178
214
    def _get_signing_policy(self):
179
215
        """Template method to override signature creation policy."""
180
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
 
181
341
    def _get_user_option(self, option_name):
182
342
        """Template method to provide a user option."""
183
343
        return None
184
344
 
185
 
    def get_user_option(self, option_name):
186
 
        """Get a generic option - no special process, no default."""
187
 
        return self._get_user_option(option_name)
188
 
 
189
 
    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):
190
369
        """Get a generic option as a boolean - no special process, no default.
191
370
 
192
371
        :return None if the option doesn't exist or its value can't be
193
372
            interpreted as a boolean. Returns True or False otherwise.
194
373
        """
195
 
        s = self._get_user_option(option_name)
 
374
        s = self.get_user_option(option_name, expand=expand)
196
375
        if s is None:
197
376
            # The option doesn't exist
198
377
            return None
203
382
                          s, option_name)
204
383
        return val
205
384
 
206
 
    def get_user_option_as_list(self, option_name):
 
385
    def get_user_option_as_list(self, option_name, expand=None):
207
386
        """Get a generic option as a list - no special process, no default.
208
387
 
209
388
        :return None if the option doesn't exist. Returns the value as a list
210
389
            otherwise.
211
390
        """
212
 
        l = self._get_user_option(option_name)
 
391
        l = self.get_user_option(option_name, expand=expand)
213
392
        if isinstance(l, (str, unicode)):
214
 
            # 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 ','
215
395
            l = [l]
216
396
        return l
217
397
 
261
441
        the concrete policy type is checked, and finally
262
442
        $EMAIL is examined.
263
443
        If no username can be found, errors.NoWhoami exception is raised.
264
 
 
265
 
        TODO: Check it's reasonably well-formed.
266
444
        """
267
445
        v = os.environ.get('BZR_EMAIL')
268
446
        if v:
269
447
            return v.decode(osutils.get_user_encoding())
270
 
 
271
448
        v = self._get_user_id()
272
449
        if v:
273
450
            return v
274
 
 
275
451
        v = os.environ.get('EMAIL')
276
452
        if v:
277
453
            return v.decode(osutils.get_user_encoding())
278
 
 
 
454
        name, email = _auto_user_id()
 
455
        if name and email:
 
456
            return '%s <%s>' % (name, email)
 
457
        elif email:
 
458
            return email
279
459
        raise errors.NoWhoami()
280
460
 
281
461
    def ensure_username(self):
347
527
        else:
348
528
            return True
349
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
 
350
549
 
351
550
class IniBasedConfig(Config):
352
551
    """A configuration policy that draws from ini files."""
353
552
 
354
 
    def __init__(self, get_filename):
 
553
    def __init__(self, get_filename=symbol_versioning.DEPRECATED_PARAMETER,
 
554
                 file_name=None):
 
555
        """Base class for configuration files using an ini-like syntax.
 
556
 
 
557
        :param file_name: The configuration file path.
 
558
        """
355
559
        super(IniBasedConfig, self).__init__()
356
 
        self._get_filename = get_filename
 
560
        self.file_name = file_name
 
561
        if symbol_versioning.deprecated_passed(get_filename):
 
562
            symbol_versioning.warn(
 
563
                'IniBasedConfig.__init__(get_filename) was deprecated in 2.3.'
 
564
                ' Use file_name instead.',
 
565
                DeprecationWarning,
 
566
                stacklevel=2)
 
567
            if get_filename is not None:
 
568
                self.file_name = get_filename()
 
569
        else:
 
570
            self.file_name = file_name
 
571
        self._content = None
357
572
        self._parser = None
358
573
 
359
 
    def _get_parser(self, file=None):
 
574
    @classmethod
 
575
    def from_string(cls, str_or_unicode, file_name=None, save=False):
 
576
        """Create a config object from a string.
 
577
 
 
578
        :param str_or_unicode: A string representing the file content. This will
 
579
            be utf-8 encoded.
 
580
 
 
581
        :param file_name: The configuration file path.
 
582
 
 
583
        :param _save: Whether the file should be saved upon creation.
 
584
        """
 
585
        conf = cls(file_name=file_name)
 
586
        conf._create_from_string(str_or_unicode, save)
 
587
        return conf
 
588
 
 
589
    def _create_from_string(self, str_or_unicode, save):
 
590
        self._content = StringIO(str_or_unicode.encode('utf-8'))
 
591
        # Some tests use in-memory configs, some other always need the config
 
592
        # file to exist on disk.
 
593
        if save:
 
594
            self._write_config_file()
 
595
 
 
596
    def _get_parser(self, file=symbol_versioning.DEPRECATED_PARAMETER):
360
597
        if self._parser is not None:
361
598
            return self._parser
362
 
        if file is None:
363
 
            input = self._get_filename()
 
599
        if symbol_versioning.deprecated_passed(file):
 
600
            symbol_versioning.warn(
 
601
                'IniBasedConfig._get_parser(file=xxx) was deprecated in 2.3.'
 
602
                ' Use IniBasedConfig(_content=xxx) instead.',
 
603
                DeprecationWarning,
 
604
                stacklevel=2)
 
605
        if self._content is not None:
 
606
            co_input = self._content
 
607
        elif self.file_name is None:
 
608
            raise AssertionError('We have no content to create the config')
364
609
        else:
365
 
            input = file
 
610
            co_input = self.file_name
366
611
        try:
367
 
            self._parser = ConfigObj(input, encoding='utf-8')
 
612
            self._parser = ConfigObj(co_input, encoding='utf-8')
368
613
        except configobj.ConfigObjError, e:
369
614
            raise errors.ParseConfigError(e.errors, e.config.filename)
 
615
        # Make sure self.reload() will use the right file name
 
616
        self._parser.filename = self.file_name
370
617
        return self._parser
371
618
 
 
619
    def reload(self):
 
620
        """Reload the config file from disk."""
 
621
        if self.file_name is None:
 
622
            raise AssertionError('We need a file name to reload the config')
 
623
        if self._parser is not None:
 
624
            self._parser.reload()
 
625
 
372
626
    def _get_matching_sections(self):
373
627
        """Return an ordered list of (section_name, extra_path) pairs.
374
628
 
385
639
        """Override this to define the section used by the config."""
386
640
        return "DEFAULT"
387
641
 
 
642
    def _get_sections(self, name=None):
 
643
        """Returns an iterator of the sections specified by ``name``.
 
644
 
 
645
        :param name: The section name. If None is supplied, the default
 
646
            configurations are yielded.
 
647
 
 
648
        :return: A tuple (name, section, config_id) for all sections that will
 
649
            be walked by user_get_option() in the 'right' order. The first one
 
650
            is where set_user_option() will update the value.
 
651
        """
 
652
        parser = self._get_parser()
 
653
        if name is not None:
 
654
            yield (name, parser[name], self.config_id())
 
655
        else:
 
656
            # No section name has been given so we fallback to the configobj
 
657
            # itself which holds the variables defined outside of any section.
 
658
            yield (None, parser, self.config_id())
 
659
 
 
660
    def _get_options(self, sections=None):
 
661
        """Return an ordered list of (name, value, section, config_id) tuples.
 
662
 
 
663
        All options are returned with their associated value and the section
 
664
        they appeared in. ``config_id`` is a unique identifier for the
 
665
        configuration file the option is defined in.
 
666
 
 
667
        :param sections: Default to ``_get_matching_sections`` if not
 
668
            specified. This gives a better control to daughter classes about
 
669
            which sections should be searched. This is a list of (name,
 
670
            configobj) tuples.
 
671
        """
 
672
        opts = []
 
673
        if sections is None:
 
674
            parser = self._get_parser()
 
675
            sections = []
 
676
            for (section_name, _) in self._get_matching_sections():
 
677
                try:
 
678
                    section = parser[section_name]
 
679
                except KeyError:
 
680
                    # This could happen for an empty file for which we define a
 
681
                    # DEFAULT section. FIXME: Force callers to provide sections
 
682
                    # instead ? -- vila 20100930
 
683
                    continue
 
684
                sections.append((section_name, section))
 
685
        config_id = self.config_id()
 
686
        for (section_name, section) in sections:
 
687
            for (name, value) in section.iteritems():
 
688
                yield (name, parser._quote(value), section_name,
 
689
                       config_id, parser)
 
690
 
388
691
    def _get_option_policy(self, section, option_name):
389
692
        """Return the policy for the given (section, option_name) pair."""
390
693
        return POLICY_NONE
477
780
    def _get_nickname(self):
478
781
        return self.get_user_option('nickname')
479
782
 
480
 
 
481
 
class GlobalConfig(IniBasedConfig):
 
783
    def remove_user_option(self, option_name, section_name=None):
 
784
        """Remove a user option and save the configuration file.
 
785
 
 
786
        :param option_name: The option to be removed.
 
787
 
 
788
        :param section_name: The section the option is defined in, default to
 
789
            the default section.
 
790
        """
 
791
        self.reload()
 
792
        parser = self._get_parser()
 
793
        if section_name is None:
 
794
            section = parser
 
795
        else:
 
796
            section = parser[section_name]
 
797
        try:
 
798
            del section[option_name]
 
799
        except KeyError:
 
800
            raise errors.NoSuchConfigOption(option_name)
 
801
        self._write_config_file()
 
802
 
 
803
    def _write_config_file(self):
 
804
        if self.file_name is None:
 
805
            raise AssertionError('We cannot save, self.file_name is None')
 
806
        conf_dir = os.path.dirname(self.file_name)
 
807
        ensure_config_dir_exists(conf_dir)
 
808
        atomic_file = atomicfile.AtomicFile(self.file_name)
 
809
        self._get_parser().write(atomic_file)
 
810
        atomic_file.commit()
 
811
        atomic_file.close()
 
812
        osutils.copy_ownership_from_path(self.file_name)
 
813
 
 
814
 
 
815
class LockableConfig(IniBasedConfig):
 
816
    """A configuration needing explicit locking for access.
 
817
 
 
818
    If several processes try to write the config file, the accesses need to be
 
819
    serialized.
 
820
 
 
821
    Daughter classes should decorate all methods that update a config with the
 
822
    ``@needs_write_lock`` decorator (they call, directly or indirectly, the
 
823
    ``_write_config_file()`` method. These methods (typically ``set_option()``
 
824
    and variants must reload the config file from disk before calling
 
825
    ``_write_config_file()``), this can be achieved by calling the
 
826
    ``self.reload()`` method. Note that the lock scope should cover both the
 
827
    reading and the writing of the config file which is why the decorator can't
 
828
    be applied to ``_write_config_file()`` only.
 
829
 
 
830
    This should be enough to implement the following logic:
 
831
    - lock for exclusive write access,
 
832
    - reload the config file from disk,
 
833
    - set the new value
 
834
    - unlock
 
835
 
 
836
    This logic guarantees that a writer can update a value without erasing an
 
837
    update made by another writer.
 
838
    """
 
839
 
 
840
    lock_name = 'lock'
 
841
 
 
842
    def __init__(self, file_name):
 
843
        super(LockableConfig, self).__init__(file_name=file_name)
 
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
 
850
        self.transport = transport.get_transport(self.dir)
 
851
        self._lock = lockdir.LockDir(self.transport, 'lock')
 
852
 
 
853
    def _create_from_string(self, unicode_bytes, save):
 
854
        super(LockableConfig, self)._create_from_string(unicode_bytes, False)
 
855
        if save:
 
856
            # We need to handle the saving here (as opposed to IniBasedConfig)
 
857
            # to be able to lock
 
858
            self.lock_write()
 
859
            self._write_config_file()
 
860
            self.unlock()
 
861
 
 
862
    def lock_write(self, token=None):
 
863
        """Takes a write lock in the directory containing the config file.
 
864
 
 
865
        If the directory doesn't exist it is created.
 
866
        """
 
867
        ensure_config_dir_exists(self.dir)
 
868
        return self._lock.lock_write(token)
 
869
 
 
870
    def unlock(self):
 
871
        self._lock.unlock()
 
872
 
 
873
    def break_lock(self):
 
874
        self._lock.break_lock()
 
875
 
 
876
    @needs_write_lock
 
877
    def remove_user_option(self, option_name, section_name=None):
 
878
        super(LockableConfig, self).remove_user_option(option_name,
 
879
                                                       section_name)
 
880
 
 
881
    def _write_config_file(self):
 
882
        if self._lock is None or not self._lock.is_held:
 
883
            # NB: if the following exception is raised it probably means a
 
884
            # missing @needs_write_lock decorator on one of the callers.
 
885
            raise errors.ObjectNotLocked(self)
 
886
        super(LockableConfig, self)._write_config_file()
 
887
 
 
888
 
 
889
class GlobalConfig(LockableConfig):
482
890
    """The configuration that should be used for a specific location."""
483
891
 
 
892
    def __init__(self):
 
893
        super(GlobalConfig, self).__init__(file_name=config_filename())
 
894
 
 
895
    def config_id(self):
 
896
        return 'bazaar'
 
897
 
 
898
    @classmethod
 
899
    def from_string(cls, str_or_unicode, save=False):
 
900
        """Create a config object from a string.
 
901
 
 
902
        :param str_or_unicode: A string representing the file content. This
 
903
            will be utf-8 encoded.
 
904
 
 
905
        :param save: Whether the file should be saved upon creation.
 
906
        """
 
907
        conf = cls()
 
908
        conf._create_from_string(str_or_unicode, save)
 
909
        return conf
 
910
 
484
911
    def get_editor(self):
485
912
        return self._get_user_option('editor')
486
913
 
487
 
    def __init__(self):
488
 
        super(GlobalConfig, self).__init__(config_filename)
489
 
 
 
914
    @needs_write_lock
490
915
    def set_user_option(self, option, value):
491
916
        """Save option and its value in the configuration."""
492
917
        self._set_option(option, value, 'DEFAULT')
498
923
        else:
499
924
            return {}
500
925
 
 
926
    @needs_write_lock
501
927
    def set_alias(self, alias_name, alias_command):
502
928
        """Save the alias in the configuration."""
503
929
        self._set_option(alias_name, alias_command, 'ALIASES')
504
930
 
 
931
    @needs_write_lock
505
932
    def unset_alias(self, alias_name):
506
933
        """Unset an existing alias."""
 
934
        self.reload()
507
935
        aliases = self._get_parser().get('ALIASES')
508
936
        if not aliases or alias_name not in aliases:
509
937
            raise errors.NoSuchAlias(alias_name)
511
939
        self._write_config_file()
512
940
 
513
941
    def _set_option(self, option, value, section):
514
 
        # FIXME: RBC 20051029 This should refresh the parser and also take a
515
 
        # file lock on bazaar.conf.
516
 
        conf_dir = os.path.dirname(self._get_filename())
517
 
        ensure_config_dir_exists(conf_dir)
 
942
        self.reload()
518
943
        self._get_parser().setdefault(section, {})[option] = value
519
944
        self._write_config_file()
520
945
 
521
 
    def _write_config_file(self):
522
 
        path = self._get_filename()
523
 
        f = open(path, 'wb')
524
 
        osutils.copy_ownership_from_path(path)
525
 
        self._get_parser().write(f)
526
 
        f.close()
527
 
 
528
 
 
529
 
class LocationConfig(IniBasedConfig):
 
946
 
 
947
    def _get_sections(self, name=None):
 
948
        """See IniBasedConfig._get_sections()."""
 
949
        parser = self._get_parser()
 
950
        # We don't give access to options defined outside of any section, we
 
951
        # used the DEFAULT section by... default.
 
952
        if name in (None, 'DEFAULT'):
 
953
            # This could happen for an empty file where the DEFAULT section
 
954
            # doesn't exist yet. So we force DEFAULT when yielding
 
955
            name = 'DEFAULT'
 
956
            if 'DEFAULT' not in parser:
 
957
               parser['DEFAULT']= {}
 
958
        yield (name, parser[name], self.config_id())
 
959
 
 
960
    @needs_write_lock
 
961
    def remove_user_option(self, option_name, section_name=None):
 
962
        if section_name is None:
 
963
            # We need to force the default section.
 
964
            section_name = 'DEFAULT'
 
965
        # We need to avoid the LockableConfig implementation or we'll lock
 
966
        # twice
 
967
        super(LockableConfig, self).remove_user_option(option_name,
 
968
                                                       section_name)
 
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
 
 
1025
 
 
1026
class LocationConfig(LockableConfig):
530
1027
    """A configuration object that gives the policy for a location."""
531
1028
 
532
1029
    def __init__(self, location):
533
 
        name_generator = locations_config_filename
534
 
        if (not os.path.exists(name_generator()) and
535
 
                os.path.exists(branches_config_filename())):
536
 
            if sys.platform == 'win32':
537
 
                trace.warning('Please rename %s to %s'
538
 
                              % (branches_config_filename(),
539
 
                                 locations_config_filename()))
540
 
            else:
541
 
                trace.warning('Please rename ~/.bazaar/branches.conf'
542
 
                              ' to ~/.bazaar/locations.conf')
543
 
            name_generator = branches_config_filename
544
 
        super(LocationConfig, self).__init__(name_generator)
 
1030
        super(LocationConfig, self).__init__(
 
1031
            file_name=locations_config_filename())
545
1032
        # local file locations are looked up by local path, rather than
546
1033
        # by file url. This is because the config file is a user
547
1034
        # file, and we would rather not expose the user to file urls.
549
1036
            location = urlutils.local_path_from_url(location)
550
1037
        self.location = location
551
1038
 
 
1039
    def config_id(self):
 
1040
        return 'locations'
 
1041
 
 
1042
    @classmethod
 
1043
    def from_string(cls, str_or_unicode, location, save=False):
 
1044
        """Create a config object from a string.
 
1045
 
 
1046
        :param str_or_unicode: A string representing the file content. This will
 
1047
            be utf-8 encoded.
 
1048
 
 
1049
        :param location: The location url to filter the configuration.
 
1050
 
 
1051
        :param save: Whether the file should be saved upon creation.
 
1052
        """
 
1053
        conf = cls(location)
 
1054
        conf._create_from_string(str_or_unicode, save)
 
1055
        return conf
 
1056
 
552
1057
    def _get_matching_sections(self):
553
1058
        """Return an ordered list of section names matching this location."""
554
 
        sections = self._get_parser()
555
 
        location_names = self.location.split('/')
556
 
        if self.location.endswith('/'):
557
 
            del location_names[-1]
558
 
        matches=[]
559
 
        for section in sections:
560
 
            # location is a local path if possible, so we need
561
 
            # to convert 'file://' urls to local paths if necessary.
562
 
            # This also avoids having file:///path be a more exact
563
 
            # match than '/path'.
564
 
            if section.startswith('file://'):
565
 
                section_path = urlutils.local_path_from_url(section)
566
 
            else:
567
 
                section_path = section
568
 
            section_names = section_path.split('/')
569
 
            if section.endswith('/'):
570
 
                del section_names[-1]
571
 
            names = zip(location_names, section_names)
572
 
            matched = True
573
 
            for name in names:
574
 
                if not fnmatch(name[0], name[1]):
575
 
                    matched = False
576
 
                    break
577
 
            if not matched:
578
 
                continue
579
 
            # so, for the common prefix they matched.
580
 
            # if section is longer, no match.
581
 
            if len(section_names) > len(location_names):
582
 
                continue
583
 
            matches.append((len(section_names), section,
584
 
                            '/'.join(location_names[len(section_names):])))
585
 
        matches.sort(reverse=True)
586
 
        sections = []
587
 
        for (length, section, extra_path) in matches:
588
 
            sections.append((section, extra_path))
 
1059
        matches = list(_iter_for_location_by_parts(self._get_parser(),
 
1060
                                                   self.location))
 
1061
        # put the longest (aka more specific) locations first
 
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
589
1067
            # should we stop looking for parent configs here?
590
1068
            try:
591
1069
                if self._get_parser()[section].as_bool('ignore_parents'):
592
1070
                    break
593
1071
            except KeyError:
594
1072
                pass
595
 
        return sections
 
1073
 
 
1074
    def _get_sections(self, name=None):
 
1075
        """See IniBasedConfig._get_sections()."""
 
1076
        # We ignore the name here as the only sections handled are named with
 
1077
        # the location path and we don't expose embedded sections either.
 
1078
        parser = self._get_parser()
 
1079
        for name, extra_path in self._get_matching_sections():
 
1080
            yield (name, parser[name], self.config_id())
596
1081
 
597
1082
    def _get_option_policy(self, section, option_name):
598
1083
        """Return the policy for the given (section, option_name) pair."""
642
1127
            if policy_key in self._get_parser()[section]:
643
1128
                del self._get_parser()[section][policy_key]
644
1129
 
 
1130
    @needs_write_lock
645
1131
    def set_user_option(self, option, value, store=STORE_LOCATION):
646
1132
        """Save option and its value in the configuration."""
647
1133
        if store not in [STORE_LOCATION,
649
1135
                         STORE_LOCATION_APPENDPATH]:
650
1136
            raise ValueError('bad storage policy %r for %r' %
651
1137
                (store, option))
652
 
        # FIXME: RBC 20051029 This should refresh the parser and also take a
653
 
        # file lock on locations.conf.
654
 
        conf_dir = os.path.dirname(self._get_filename())
655
 
        ensure_config_dir_exists(conf_dir)
 
1138
        self.reload()
656
1139
        location = self.location
657
1140
        if location.endswith('/'):
658
1141
            location = location[:-1]
659
 
        if (not location in self._get_parser() and
660
 
            not location + '/' in self._get_parser()):
661
 
            self._get_parser()[location]={}
662
 
        elif location + '/' in self._get_parser():
 
1142
        parser = self._get_parser()
 
1143
        if not location in parser and not location + '/' in parser:
 
1144
            parser[location] = {}
 
1145
        elif location + '/' in parser:
663
1146
            location = location + '/'
664
 
        self._get_parser()[location][option]=value
 
1147
        parser[location][option]=value
665
1148
        # the allowed values of store match the config policies
666
1149
        self._set_option_policy(location, option, store)
667
 
        self._get_parser().write(file(self._get_filename(), 'wb'))
 
1150
        self._write_config_file()
668
1151
 
669
1152
 
670
1153
class BranchConfig(Config):
671
1154
    """A configuration object giving the policy for a branch."""
672
1155
 
 
1156
    def __init__(self, branch):
 
1157
        super(BranchConfig, self).__init__()
 
1158
        self._location_config = None
 
1159
        self._branch_data_config = None
 
1160
        self._global_config = None
 
1161
        self.branch = branch
 
1162
        self.option_sources = (self._get_location_config,
 
1163
                               self._get_branch_data_config,
 
1164
                               self._get_global_config)
 
1165
 
 
1166
    def config_id(self):
 
1167
        return 'branch'
 
1168
 
673
1169
    def _get_branch_data_config(self):
674
1170
        if self._branch_data_config is None:
675
1171
            self._branch_data_config = TreeConfig(self.branch)
 
1172
            self._branch_data_config.config_id = self.config_id
676
1173
        return self._branch_data_config
677
1174
 
678
1175
    def _get_location_config(self):
746
1243
                return value
747
1244
        return None
748
1245
 
 
1246
    def _get_sections(self, name=None):
 
1247
        """See IniBasedConfig.get_sections()."""
 
1248
        for source in self.option_sources:
 
1249
            for section in source()._get_sections(name):
 
1250
                yield section
 
1251
 
 
1252
    def _get_options(self, sections=None):
 
1253
        opts = []
 
1254
        # First the locations options
 
1255
        for option in self._get_location_config()._get_options():
 
1256
            yield option
 
1257
        # Then the branch options
 
1258
        branch_config = self._get_branch_data_config()
 
1259
        if sections is None:
 
1260
            sections = [('DEFAULT', branch_config._get_parser())]
 
1261
        # FIXME: We shouldn't have to duplicate the code in IniBasedConfig but
 
1262
        # Config itself has no notion of sections :( -- vila 20101001
 
1263
        config_id = self.config_id()
 
1264
        for (section_name, section) in sections:
 
1265
            for (name, value) in section.iteritems():
 
1266
                yield (name, value, section_name,
 
1267
                       config_id, branch_config._get_parser())
 
1268
        # Then the global options
 
1269
        for option in self._get_global_config()._get_options():
 
1270
            yield option
 
1271
 
749
1272
    def set_user_option(self, name, value, store=STORE_BRANCH,
750
1273
        warn_masked=False):
751
1274
        if store == STORE_BRANCH:
769
1292
                        trace.warning('Value "%s" is masked by "%s" from'
770
1293
                                      ' branch.conf', value, mask_value)
771
1294
 
 
1295
    def remove_user_option(self, option_name, section_name=None):
 
1296
        self._get_branch_data_config().remove_option(option_name, section_name)
 
1297
 
772
1298
    def _gpg_signing_command(self):
773
1299
        """See Config.gpg_signing_command."""
774
1300
        return self._get_safe_value('_gpg_signing_command')
775
1301
 
776
 
    def __init__(self, branch):
777
 
        super(BranchConfig, self).__init__()
778
 
        self._location_config = None
779
 
        self._branch_data_config = None
780
 
        self._global_config = None
781
 
        self.branch = branch
782
 
        self.option_sources = (self._get_location_config,
783
 
                               self._get_branch_data_config,
784
 
                               self._get_global_config)
785
 
 
786
1302
    def _post_commit(self):
787
1303
        """See Config.post_commit."""
788
1304
        return self._get_safe_value('_post_commit')
818
1334
            parent_dir = os.path.dirname(path)
819
1335
            if not os.path.isdir(parent_dir):
820
1336
                trace.mutter('creating config parent directory: %r', parent_dir)
821
 
            os.mkdir(parent_dir)
 
1337
                os.mkdir(parent_dir)
822
1338
        trace.mutter('creating config directory: %r', path)
823
1339
        os.mkdir(path)
824
1340
        osutils.copy_ownership_from_path(path)
827
1343
def config_dir():
828
1344
    """Return per-user configuration directory.
829
1345
 
830
 
    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.
831
1349
 
832
1350
    TODO: Global option --config-dir to override this.
833
1351
    """
834
1352
    base = os.environ.get('BZR_HOME', None)
835
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')
836
1358
        if base is None:
837
1359
            base = win32utils.get_appdata_location_unicode()
838
1360
        if base is None:
839
1361
            base = os.environ.get('HOME', None)
 
1362
            if base is not None:
 
1363
                base = base.decode('mbcs')
840
1364
        if base is None:
841
1365
            raise errors.BzrError('You must have one of BZR_HOME, APPDATA,'
842
1366
                                  ' or HOME set')
843
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')
844
1373
    else:
845
 
        # cygwin, linux, and darwin all have a $HOME directory
846
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
 
847
1385
            base = os.path.expanduser("~")
848
1386
        return osutils.pathjoin(base, ".bazaar")
849
1387
 
853
1391
    return osutils.pathjoin(config_dir(), 'bazaar.conf')
854
1392
 
855
1393
 
856
 
def branches_config_filename():
857
 
    """Return per-user configuration ini file filename."""
858
 
    return osutils.pathjoin(config_dir(), 'branches.conf')
859
 
 
860
 
 
861
1394
def locations_config_filename():
862
1395
    """Return per-user configuration ini file filename."""
863
1396
    return osutils.pathjoin(config_dir(), 'locations.conf')
900
1433
        return os.path.expanduser('~/.cache')
901
1434
 
902
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
 
903
1516
def parse_username(username):
904
1517
    """Parse e-mail username and return a (name, address) tuple."""
905
1518
    match = re.match(r'(.*?)\s*<?([\w+.-]+@[\w+.-]+)>?', username)
948
1561
 
949
1562
    def set_option(self, value, name, section=None):
950
1563
        """Set a per-branch configuration option"""
 
1564
        # FIXME: We shouldn't need to lock explicitly here but rather rely on
 
1565
        # higher levels providing the right lock -- vila 20101004
951
1566
        self.branch.lock_write()
952
1567
        try:
953
1568
            self._config.set_option(value, name, section)
954
1569
        finally:
955
1570
            self.branch.unlock()
956
1571
 
 
1572
    def remove_option(self, option_name, section_name=None):
 
1573
        # FIXME: We shouldn't need to lock explicitly here but rather rely on
 
1574
        # higher levels providing the right lock -- vila 20101004
 
1575
        self.branch.lock_write()
 
1576
        try:
 
1577
            self._config.remove_option(option_name, section_name)
 
1578
        finally:
 
1579
            self.branch.unlock()
 
1580
 
957
1581
 
958
1582
class AuthenticationConfig(object):
959
1583
    """The authentication configuration file based on a ini file.
991
1615
        """Save the config file, only tests should use it for now."""
992
1616
        conf_dir = os.path.dirname(self._filename)
993
1617
        ensure_config_dir_exists(conf_dir)
994
 
        self._get_config().write(file(self._filename, 'wb'))
 
1618
        f = file(self._filename, 'wb')
 
1619
        try:
 
1620
            self._get_config().write(f)
 
1621
        finally:
 
1622
            f.close()
995
1623
 
996
1624
    def _set_option(self, section_name, option_name, value):
997
1625
        """Set an authentication configuration option"""
1398
2026
    """A Config that reads/writes a config file on a Transport.
1399
2027
 
1400
2028
    It is a low-level object that considers config data to be name/value pairs
1401
 
    that may be associated with a section.  Assigning meaning to the these
1402
 
    values is done at higher levels like TreeConfig.
 
2029
    that may be associated with a section.  Assigning meaning to these values
 
2030
    is done at higher levels like TreeConfig.
1403
2031
    """
1404
2032
 
1405
2033
    def __init__(self, transport, filename):
1438
2066
            configobj.setdefault(section, {})[name] = value
1439
2067
        self._set_configobj(configobj)
1440
2068
 
 
2069
    def remove_option(self, option_name, section_name=None):
 
2070
        configobj = self._get_configobj()
 
2071
        if section_name is None:
 
2072
            del configobj[option_name]
 
2073
        else:
 
2074
            del configobj[section_name][option_name]
 
2075
        self._set_configobj(configobj)
 
2076
 
1441
2077
    def _get_config_file(self):
1442
2078
        try:
1443
2079
            return StringIO(self._transport.get_bytes(self._filename))
1445
2081
            return StringIO()
1446
2082
 
1447
2083
    def _get_configobj(self):
1448
 
        return ConfigObj(self._get_config_file(), encoding='utf-8')
 
2084
        f = self._get_config_file()
 
2085
        try:
 
2086
            return ConfigObj(f, encoding='utf-8')
 
2087
        finally:
 
2088
            f.close()
1449
2089
 
1450
2090
    def _set_configobj(self, configobj):
1451
2091
        out_file = StringIO()
1452
2092
        configobj.write(out_file)
1453
2093
        out_file.seek(0)
1454
2094
        self._transport.put_file(self._filename, out_file)
 
2095
 
 
2096
 
 
2097
class cmd_config(commands.Command):
 
2098
    __doc__ = """Display, set or remove a configuration option.
 
2099
 
 
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.
 
2107
 
 
2108
    Setting a value is achieved by using name=value without spaces. The value
 
2109
    is set in the most relevant scope and can be checked by displaying the
 
2110
    option again.
 
2111
    """
 
2112
 
 
2113
    takes_args = ['name?']
 
2114
 
 
2115
    takes_options = [
 
2116
        'directory',
 
2117
        # FIXME: This should be a registry option so that plugins can register
 
2118
        # their own config files (or not) -- vila 20101002
 
2119
        commands.Option('scope', help='Reduce the scope to the specified'
 
2120
                        ' configuration file',
 
2121
                        type=unicode),
 
2122
        commands.Option('all',
 
2123
            help='Display all the defined values for the matching options.',
 
2124
            ),
 
2125
        commands.Option('remove', help='Remove the option from'
 
2126
                        ' the configuration file'),
 
2127
        ]
 
2128
 
 
2129
    @commands.display_command
 
2130
    def run(self, name=None, all=False, directory=None, scope=None,
 
2131
            remove=False):
 
2132
        if directory is None:
 
2133
            directory = '.'
 
2134
        directory = urlutils.normalize_url(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)
 
2144
        else:
 
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)
 
2153
            else:
 
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)
 
2159
 
 
2160
    def _get_configs(self, directory, scope=None):
 
2161
        """Iterate the configurations specified by ``directory`` and ``scope``.
 
2162
 
 
2163
        :param directory: Where the configurations are derived from.
 
2164
 
 
2165
        :param scope: A specific config to start from.
 
2166
        """
 
2167
        if scope is not None:
 
2168
            if scope == 'bazaar':
 
2169
                yield GlobalConfig()
 
2170
            elif scope == 'locations':
 
2171
                yield LocationConfig(directory)
 
2172
            elif scope == 'branch':
 
2173
                (_, br, _) = bzrdir.BzrDir.open_containing_tree_or_branch(
 
2174
                    directory)
 
2175
                yield br.get_config()
 
2176
        else:
 
2177
            try:
 
2178
                (_, br, _) = bzrdir.BzrDir.open_containing_tree_or_branch(
 
2179
                    directory)
 
2180
                yield br.get_config()
 
2181
            except errors.NotBranchError:
 
2182
                yield LocationConfig(directory)
 
2183
                yield GlobalConfig()
 
2184
 
 
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()
 
2212
        cur_conf_id = None
 
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):
 
2217
                    if cur_conf_id != conf_id:
 
2218
                        # Explain where the options are defined
 
2219
                        self.outf.write('%s:\n' % (conf_id,))
 
2220
                        cur_conf_id = conf_id
 
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))
 
2229
 
 
2230
    def _set_config_option(self, name, value, directory, scope):
 
2231
        for conf in self._get_configs(directory, scope):
 
2232
            conf.set_user_option(name, value)
 
2233
            break
 
2234
        else:
 
2235
            raise errors.NoSuchConfig(scope)
 
2236
 
 
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.')
 
2241
        removed = False
 
2242
        for conf in self._get_configs(directory, scope):
 
2243
            for (section_name, section, conf_id) in conf._get_sections():
 
2244
                if scope is not None and conf_id != scope:
 
2245
                    # Not the right configuration file
 
2246
                    continue
 
2247
                if name in section:
 
2248
                    if conf_id != conf.config_id():
 
2249
                        conf = self._get_configs(directory, conf_id).next()
 
2250
                    # We use the first section in the first config where the
 
2251
                    # option is defined to remove it
 
2252
                    conf.remove_user_option(name, section_name)
 
2253
                    removed = True
 
2254
                    break
 
2255
            break
 
2256
        else:
 
2257
            raise errors.NoSuchConfig(scope)
 
2258
        if not removed:
 
2259
            raise errors.NoSuchConfigOption(name)