~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/config.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2011-04-05 14:47:26 UTC
  • mfrom: (5752.2.11 2.4-windows-lfstat)
  • Revision ID: pqm@pqm.ubuntu.com-20110405144726-zi3lj2kwvjml4kx5
(jameinel) Add osutils.lstat/fstat so that even on Windows lstat(fname) ==
 fstat(open(fname).fileno()) (John A Meinel)

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
 
257
437
 
258
438
        Something similar to 'Martin Pool <mbp@sourcefrog.net>'
259
439
 
260
 
        $BZR_EMAIL can be set to override this (as well as the
261
 
        deprecated $BZREMAIL), then
 
440
        $BZR_EMAIL can be set to override this, then
262
441
        the concrete policy type is checked, and finally
263
442
        $EMAIL is examined.
264
 
        If none is found, a reasonable default is (hopefully)
265
 
        created.
266
 
 
267
 
        TODO: Check it's reasonably well-formed.
 
443
        If no username can be found, errors.NoWhoami exception is raised.
268
444
        """
269
445
        v = os.environ.get('BZR_EMAIL')
270
446
        if v:
271
447
            return v.decode(osutils.get_user_encoding())
272
 
 
273
448
        v = self._get_user_id()
274
449
        if v:
275
450
            return v
276
 
 
277
451
        v = os.environ.get('EMAIL')
278
452
        if v:
279
453
            return v.decode(osutils.get_user_encoding())
280
 
 
281
454
        name, email = _auto_user_id()
282
 
        if name:
 
455
        if name and email:
283
456
            return '%s <%s>' % (name, email)
284
 
        else:
 
457
        elif email:
285
458
            return email
 
459
        raise errors.NoWhoami()
 
460
 
 
461
    def ensure_username(self):
 
462
        """Raise errors.NoWhoami if username is not set.
 
463
 
 
464
        This method relies on the username() function raising the error.
 
465
        """
 
466
        self.username()
286
467
 
287
468
    def signature_checking(self):
288
469
        """What is the current policy for signature checking?."""
346
527
        else:
347
528
            return True
348
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
 
349
549
 
350
550
class IniBasedConfig(Config):
351
551
    """A configuration policy that draws from ini files."""
352
552
 
353
 
    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
        """
354
559
        super(IniBasedConfig, self).__init__()
355
 
        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
356
572
        self._parser = None
357
573
 
358
 
    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):
359
597
        if self._parser is not None:
360
598
            return self._parser
361
 
        if file is None:
362
 
            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')
363
609
        else:
364
 
            input = file
 
610
            co_input = self.file_name
365
611
        try:
366
 
            self._parser = ConfigObj(input, encoding='utf-8')
 
612
            self._parser = ConfigObj(co_input, encoding='utf-8')
367
613
        except configobj.ConfigObjError, e:
368
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
369
617
        return self._parser
370
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
 
371
626
    def _get_matching_sections(self):
372
627
        """Return an ordered list of (section_name, extra_path) pairs.
373
628
 
384
639
        """Override this to define the section used by the config."""
385
640
        return "DEFAULT"
386
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
 
387
691
    def _get_option_policy(self, section, option_name):
388
692
        """Return the policy for the given (section, option_name) pair."""
389
693
        return POLICY_NONE
476
780
    def _get_nickname(self):
477
781
        return self.get_user_option('nickname')
478
782
 
479
 
 
480
 
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):
481
890
    """The configuration that should be used for a specific location."""
482
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
 
483
911
    def get_editor(self):
484
912
        return self._get_user_option('editor')
485
913
 
486
 
    def __init__(self):
487
 
        super(GlobalConfig, self).__init__(config_filename)
488
 
 
 
914
    @needs_write_lock
489
915
    def set_user_option(self, option, value):
490
916
        """Save option and its value in the configuration."""
491
917
        self._set_option(option, value, 'DEFAULT')
497
923
        else:
498
924
            return {}
499
925
 
 
926
    @needs_write_lock
500
927
    def set_alias(self, alias_name, alias_command):
501
928
        """Save the alias in the configuration."""
502
929
        self._set_option(alias_name, alias_command, 'ALIASES')
503
930
 
 
931
    @needs_write_lock
504
932
    def unset_alias(self, alias_name):
505
933
        """Unset an existing alias."""
 
934
        self.reload()
506
935
        aliases = self._get_parser().get('ALIASES')
507
936
        if not aliases or alias_name not in aliases:
508
937
            raise errors.NoSuchAlias(alias_name)
510
939
        self._write_config_file()
511
940
 
512
941
    def _set_option(self, option, value, section):
513
 
        # FIXME: RBC 20051029 This should refresh the parser and also take a
514
 
        # file lock on bazaar.conf.
515
 
        conf_dir = os.path.dirname(self._get_filename())
516
 
        ensure_config_dir_exists(conf_dir)
 
942
        self.reload()
517
943
        self._get_parser().setdefault(section, {})[option] = value
518
944
        self._write_config_file()
519
945
 
520
 
    def _write_config_file(self):
521
 
        path = self._get_filename()
522
 
        f = open(path, 'wb')
523
 
        osutils.copy_ownership_from_path(path)
524
 
        self._get_parser().write(f)
525
 
        f.close()
526
 
 
527
 
 
528
 
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
 
 
971
class LocationConfig(LockableConfig):
529
972
    """A configuration object that gives the policy for a location."""
530
973
 
531
974
    def __init__(self, location):
532
 
        name_generator = locations_config_filename
533
 
        if (not os.path.exists(name_generator()) and
534
 
                os.path.exists(branches_config_filename())):
535
 
            if sys.platform == 'win32':
536
 
                trace.warning('Please rename %s to %s'
537
 
                              % (branches_config_filename(),
538
 
                                 locations_config_filename()))
539
 
            else:
540
 
                trace.warning('Please rename ~/.bazaar/branches.conf'
541
 
                              ' to ~/.bazaar/locations.conf')
542
 
            name_generator = branches_config_filename
543
 
        super(LocationConfig, self).__init__(name_generator)
 
975
        super(LocationConfig, self).__init__(
 
976
            file_name=locations_config_filename())
544
977
        # local file locations are looked up by local path, rather than
545
978
        # by file url. This is because the config file is a user
546
979
        # file, and we would rather not expose the user to file urls.
548
981
            location = urlutils.local_path_from_url(location)
549
982
        self.location = location
550
983
 
 
984
    def config_id(self):
 
985
        return 'locations'
 
986
 
 
987
    @classmethod
 
988
    def from_string(cls, str_or_unicode, location, save=False):
 
989
        """Create a config object from a string.
 
990
 
 
991
        :param str_or_unicode: A string representing the file content. This will
 
992
            be utf-8 encoded.
 
993
 
 
994
        :param location: The location url to filter the configuration.
 
995
 
 
996
        :param save: Whether the file should be saved upon creation.
 
997
        """
 
998
        conf = cls(location)
 
999
        conf._create_from_string(str_or_unicode, save)
 
1000
        return conf
 
1001
 
551
1002
    def _get_matching_sections(self):
552
1003
        """Return an ordered list of section names matching this location."""
553
1004
        sections = self._get_parser()
570
1021
            names = zip(location_names, section_names)
571
1022
            matched = True
572
1023
            for name in names:
573
 
                if not fnmatch(name[0], name[1]):
 
1024
                if not fnmatch.fnmatch(name[0], name[1]):
574
1025
                    matched = False
575
1026
                    break
576
1027
            if not matched:
581
1032
                continue
582
1033
            matches.append((len(section_names), section,
583
1034
                            '/'.join(location_names[len(section_names):])))
 
1035
        # put the longest (aka more specific) locations first
584
1036
        matches.sort(reverse=True)
585
1037
        sections = []
586
1038
        for (length, section, extra_path) in matches:
593
1045
                pass
594
1046
        return sections
595
1047
 
 
1048
    def _get_sections(self, name=None):
 
1049
        """See IniBasedConfig._get_sections()."""
 
1050
        # We ignore the name here as the only sections handled are named with
 
1051
        # the location path and we don't expose embedded sections either.
 
1052
        parser = self._get_parser()
 
1053
        for name, extra_path in self._get_matching_sections():
 
1054
            yield (name, parser[name], self.config_id())
 
1055
 
596
1056
    def _get_option_policy(self, section, option_name):
597
1057
        """Return the policy for the given (section, option_name) pair."""
598
1058
        # check for the old 'recurse=False' flag
641
1101
            if policy_key in self._get_parser()[section]:
642
1102
                del self._get_parser()[section][policy_key]
643
1103
 
 
1104
    @needs_write_lock
644
1105
    def set_user_option(self, option, value, store=STORE_LOCATION):
645
1106
        """Save option and its value in the configuration."""
646
1107
        if store not in [STORE_LOCATION,
648
1109
                         STORE_LOCATION_APPENDPATH]:
649
1110
            raise ValueError('bad storage policy %r for %r' %
650
1111
                (store, option))
651
 
        # FIXME: RBC 20051029 This should refresh the parser and also take a
652
 
        # file lock on locations.conf.
653
 
        conf_dir = os.path.dirname(self._get_filename())
654
 
        ensure_config_dir_exists(conf_dir)
 
1112
        self.reload()
655
1113
        location = self.location
656
1114
        if location.endswith('/'):
657
1115
            location = location[:-1]
658
 
        if (not location in self._get_parser() and
659
 
            not location + '/' in self._get_parser()):
660
 
            self._get_parser()[location]={}
661
 
        elif location + '/' in self._get_parser():
 
1116
        parser = self._get_parser()
 
1117
        if not location in parser and not location + '/' in parser:
 
1118
            parser[location] = {}
 
1119
        elif location + '/' in parser:
662
1120
            location = location + '/'
663
 
        self._get_parser()[location][option]=value
 
1121
        parser[location][option]=value
664
1122
        # the allowed values of store match the config policies
665
1123
        self._set_option_policy(location, option, store)
666
 
        self._get_parser().write(file(self._get_filename(), 'wb'))
 
1124
        self._write_config_file()
667
1125
 
668
1126
 
669
1127
class BranchConfig(Config):
670
1128
    """A configuration object giving the policy for a branch."""
671
1129
 
 
1130
    def __init__(self, branch):
 
1131
        super(BranchConfig, self).__init__()
 
1132
        self._location_config = None
 
1133
        self._branch_data_config = None
 
1134
        self._global_config = None
 
1135
        self.branch = branch
 
1136
        self.option_sources = (self._get_location_config,
 
1137
                               self._get_branch_data_config,
 
1138
                               self._get_global_config)
 
1139
 
 
1140
    def config_id(self):
 
1141
        return 'branch'
 
1142
 
672
1143
    def _get_branch_data_config(self):
673
1144
        if self._branch_data_config is None:
674
1145
            self._branch_data_config = TreeConfig(self.branch)
 
1146
            self._branch_data_config.config_id = self.config_id
675
1147
        return self._branch_data_config
676
1148
 
677
1149
    def _get_location_config(self):
745
1217
                return value
746
1218
        return None
747
1219
 
 
1220
    def _get_sections(self, name=None):
 
1221
        """See IniBasedConfig.get_sections()."""
 
1222
        for source in self.option_sources:
 
1223
            for section in source()._get_sections(name):
 
1224
                yield section
 
1225
 
 
1226
    def _get_options(self, sections=None):
 
1227
        opts = []
 
1228
        # First the locations options
 
1229
        for option in self._get_location_config()._get_options():
 
1230
            yield option
 
1231
        # Then the branch options
 
1232
        branch_config = self._get_branch_data_config()
 
1233
        if sections is None:
 
1234
            sections = [('DEFAULT', branch_config._get_parser())]
 
1235
        # FIXME: We shouldn't have to duplicate the code in IniBasedConfig but
 
1236
        # Config itself has no notion of sections :( -- vila 20101001
 
1237
        config_id = self.config_id()
 
1238
        for (section_name, section) in sections:
 
1239
            for (name, value) in section.iteritems():
 
1240
                yield (name, value, section_name,
 
1241
                       config_id, branch_config._get_parser())
 
1242
        # Then the global options
 
1243
        for option in self._get_global_config()._get_options():
 
1244
            yield option
 
1245
 
748
1246
    def set_user_option(self, name, value, store=STORE_BRANCH,
749
1247
        warn_masked=False):
750
1248
        if store == STORE_BRANCH:
768
1266
                        trace.warning('Value "%s" is masked by "%s" from'
769
1267
                                      ' branch.conf', value, mask_value)
770
1268
 
 
1269
    def remove_user_option(self, option_name, section_name=None):
 
1270
        self._get_branch_data_config().remove_option(option_name, section_name)
 
1271
 
771
1272
    def _gpg_signing_command(self):
772
1273
        """See Config.gpg_signing_command."""
773
1274
        return self._get_safe_value('_gpg_signing_command')
774
1275
 
775
 
    def __init__(self, branch):
776
 
        super(BranchConfig, self).__init__()
777
 
        self._location_config = None
778
 
        self._branch_data_config = None
779
 
        self._global_config = None
780
 
        self.branch = branch
781
 
        self.option_sources = (self._get_location_config,
782
 
                               self._get_branch_data_config,
783
 
                               self._get_global_config)
784
 
 
785
1276
    def _post_commit(self):
786
1277
        """See Config.post_commit."""
787
1278
        return self._get_safe_value('_post_commit')
817
1308
            parent_dir = os.path.dirname(path)
818
1309
            if not os.path.isdir(parent_dir):
819
1310
                trace.mutter('creating config parent directory: %r', parent_dir)
820
 
            os.mkdir(parent_dir)
 
1311
                os.mkdir(parent_dir)
821
1312
        trace.mutter('creating config directory: %r', path)
822
1313
        os.mkdir(path)
823
1314
        osutils.copy_ownership_from_path(path)
826
1317
def config_dir():
827
1318
    """Return per-user configuration directory.
828
1319
 
829
 
    By default this is ~/.bazaar/
 
1320
    By default this is %APPDATA%/bazaar/2.0 on Windows, ~/.bazaar on Mac OS X
 
1321
    and Linux.  On Linux, if there is a $XDG_CONFIG_HOME/bazaar directory,
 
1322
    that will be used instead.
830
1323
 
831
1324
    TODO: Global option --config-dir to override this.
832
1325
    """
833
1326
    base = os.environ.get('BZR_HOME', None)
834
1327
    if sys.platform == 'win32':
 
1328
        # environ variables on Windows are in user encoding/mbcs. So decode
 
1329
        # before using one
 
1330
        if base is not None:
 
1331
            base = base.decode('mbcs')
835
1332
        if base is None:
836
1333
            base = win32utils.get_appdata_location_unicode()
837
1334
        if base is None:
838
1335
            base = os.environ.get('HOME', None)
 
1336
            if base is not None:
 
1337
                base = base.decode('mbcs')
839
1338
        if base is None:
840
1339
            raise errors.BzrError('You must have one of BZR_HOME, APPDATA,'
841
1340
                                  ' or HOME set')
842
1341
        return osutils.pathjoin(base, 'bazaar', '2.0')
 
1342
    elif sys.platform == 'darwin':
 
1343
        if base is None:
 
1344
            # this takes into account $HOME
 
1345
            base = os.path.expanduser("~")
 
1346
        return osutils.pathjoin(base, '.bazaar')
843
1347
    else:
844
 
        # cygwin, linux, and darwin all have a $HOME directory
845
1348
        if base is None:
 
1349
 
 
1350
            xdg_dir = os.environ.get('XDG_CONFIG_HOME', None)
 
1351
            if xdg_dir is None:
 
1352
                xdg_dir = osutils.pathjoin(os.path.expanduser("~"), ".config")
 
1353
            xdg_dir = osutils.pathjoin(xdg_dir, 'bazaar')
 
1354
            if osutils.isdir(xdg_dir):
 
1355
                trace.mutter(
 
1356
                    "Using configuration in XDG directory %s." % xdg_dir)
 
1357
                return xdg_dir
 
1358
 
846
1359
            base = os.path.expanduser("~")
847
1360
        return osutils.pathjoin(base, ".bazaar")
848
1361
 
852
1365
    return osutils.pathjoin(config_dir(), 'bazaar.conf')
853
1366
 
854
1367
 
855
 
def branches_config_filename():
856
 
    """Return per-user configuration ini file filename."""
857
 
    return osutils.pathjoin(config_dir(), 'branches.conf')
858
 
 
859
 
 
860
1368
def locations_config_filename():
861
1369
    """Return per-user configuration ini file filename."""
862
1370
    return osutils.pathjoin(config_dir(), 'locations.conf')
899
1407
        return os.path.expanduser('~/.cache')
900
1408
 
901
1409
 
 
1410
def _get_default_mail_domain():
 
1411
    """If possible, return the assumed default email domain.
 
1412
 
 
1413
    :returns: string mail domain, or None.
 
1414
    """
 
1415
    if sys.platform == 'win32':
 
1416
        # No implementation yet; patches welcome
 
1417
        return None
 
1418
    try:
 
1419
        f = open('/etc/mailname')
 
1420
    except (IOError, OSError), e:
 
1421
        return None
 
1422
    try:
 
1423
        domain = f.read().strip()
 
1424
        return domain
 
1425
    finally:
 
1426
        f.close()
 
1427
 
 
1428
 
902
1429
def _auto_user_id():
903
1430
    """Calculate automatic user identification.
904
1431
 
905
 
    Returns (realname, email).
 
1432
    :returns: (realname, email), either of which may be None if they can't be
 
1433
    determined.
906
1434
 
907
1435
    Only used when none is set in the environment or the id file.
908
1436
 
909
 
    This previously used the FQDN as the default domain, but that can
910
 
    be very slow on machines where DNS is broken.  So now we simply
911
 
    use the hostname.
 
1437
    This only returns an email address if we can be fairly sure the 
 
1438
    address is reasonable, ie if /etc/mailname is set on unix.
 
1439
 
 
1440
    This doesn't use the FQDN as the default domain because that may be 
 
1441
    slow, and it doesn't use the hostname alone because that's not normally 
 
1442
    a reasonable address.
912
1443
    """
913
 
    import socket
914
 
 
915
1444
    if sys.platform == 'win32':
916
 
        name = win32utils.get_user_name_unicode()
917
 
        if name is None:
918
 
            raise errors.BzrError("Cannot autodetect user name.\n"
919
 
                                  "Please, set your name with command like:\n"
920
 
                                  'bzr whoami "Your Name <name@domain.com>"')
921
 
        host = win32utils.get_host_name_unicode()
922
 
        if host is None:
923
 
            host = socket.gethostname()
924
 
        return name, (name + '@' + host)
925
 
 
926
 
    try:
927
 
        import pwd
928
 
        uid = os.getuid()
929
 
        try:
930
 
            w = pwd.getpwuid(uid)
931
 
        except KeyError:
932
 
            raise errors.BzrCommandError('Unable to determine your name.  '
933
 
                'Please use "bzr whoami" to set it.')
934
 
 
935
 
        # we try utf-8 first, because on many variants (like Linux),
936
 
        # /etc/passwd "should" be in utf-8, and because it's unlikely to give
937
 
        # false positives.  (many users will have their user encoding set to
938
 
        # latin-1, which cannot raise UnicodeError.)
939
 
        try:
940
 
            gecos = w.pw_gecos.decode('utf-8')
941
 
            encoding = 'utf-8'
942
 
        except UnicodeError:
943
 
            try:
944
 
                encoding = osutils.get_user_encoding()
945
 
                gecos = w.pw_gecos.decode(encoding)
946
 
            except UnicodeError:
947
 
                raise errors.BzrCommandError('Unable to determine your name.  '
948
 
                   'Use "bzr whoami" to set it.')
949
 
        try:
950
 
            username = w.pw_name.decode(encoding)
951
 
        except UnicodeError:
952
 
            raise errors.BzrCommandError('Unable to determine your name.  '
953
 
                'Use "bzr whoami" to set it.')
954
 
 
955
 
        comma = gecos.find(',')
956
 
        if comma == -1:
957
 
            realname = gecos
958
 
        else:
959
 
            realname = gecos[:comma]
960
 
        if not realname:
961
 
            realname = username
962
 
 
963
 
    except ImportError:
964
 
        import getpass
965
 
        try:
966
 
            user_encoding = osutils.get_user_encoding()
967
 
            realname = username = getpass.getuser().decode(user_encoding)
968
 
        except UnicodeDecodeError:
969
 
            raise errors.BzrError("Can't decode username as %s." % \
970
 
                    user_encoding)
971
 
 
972
 
    return realname, (username + '@' + socket.gethostname())
 
1445
        # No implementation to reliably determine Windows default mail
 
1446
        # address; please add one.
 
1447
        return None, None
 
1448
 
 
1449
    default_mail_domain = _get_default_mail_domain()
 
1450
    if not default_mail_domain:
 
1451
        return None, None
 
1452
 
 
1453
    import pwd
 
1454
    uid = os.getuid()
 
1455
    try:
 
1456
        w = pwd.getpwuid(uid)
 
1457
    except KeyError:
 
1458
        mutter('no passwd entry for uid %d?' % uid)
 
1459
        return None, None
 
1460
 
 
1461
    # we try utf-8 first, because on many variants (like Linux),
 
1462
    # /etc/passwd "should" be in utf-8, and because it's unlikely to give
 
1463
    # false positives.  (many users will have their user encoding set to
 
1464
    # latin-1, which cannot raise UnicodeError.)
 
1465
    try:
 
1466
        gecos = w.pw_gecos.decode('utf-8')
 
1467
        encoding = 'utf-8'
 
1468
    except UnicodeError:
 
1469
        try:
 
1470
            encoding = osutils.get_user_encoding()
 
1471
            gecos = w.pw_gecos.decode(encoding)
 
1472
        except UnicodeError, e:
 
1473
            mutter("cannot decode passwd entry %s" % w)
 
1474
            return None, None
 
1475
    try:
 
1476
        username = w.pw_name.decode(encoding)
 
1477
    except UnicodeError, e:
 
1478
        mutter("cannot decode passwd entry %s" % w)
 
1479
        return None, None
 
1480
 
 
1481
    comma = gecos.find(',')
 
1482
    if comma == -1:
 
1483
        realname = gecos
 
1484
    else:
 
1485
        realname = gecos[:comma]
 
1486
 
 
1487
    return realname, (username + '@' + default_mail_domain)
973
1488
 
974
1489
 
975
1490
def parse_username(username):
1020
1535
 
1021
1536
    def set_option(self, value, name, section=None):
1022
1537
        """Set a per-branch configuration option"""
 
1538
        # FIXME: We shouldn't need to lock explicitly here but rather rely on
 
1539
        # higher levels providing the right lock -- vila 20101004
1023
1540
        self.branch.lock_write()
1024
1541
        try:
1025
1542
            self._config.set_option(value, name, section)
1026
1543
        finally:
1027
1544
            self.branch.unlock()
1028
1545
 
 
1546
    def remove_option(self, option_name, section_name=None):
 
1547
        # FIXME: We shouldn't need to lock explicitly here but rather rely on
 
1548
        # higher levels providing the right lock -- vila 20101004
 
1549
        self.branch.lock_write()
 
1550
        try:
 
1551
            self._config.remove_option(option_name, section_name)
 
1552
        finally:
 
1553
            self.branch.unlock()
 
1554
 
1029
1555
 
1030
1556
class AuthenticationConfig(object):
1031
1557
    """The authentication configuration file based on a ini file.
1063
1589
        """Save the config file, only tests should use it for now."""
1064
1590
        conf_dir = os.path.dirname(self._filename)
1065
1591
        ensure_config_dir_exists(conf_dir)
1066
 
        self._get_config().write(file(self._filename, 'wb'))
 
1592
        f = file(self._filename, 'wb')
 
1593
        try:
 
1594
            self._get_config().write(f)
 
1595
        finally:
 
1596
            f.close()
1067
1597
 
1068
1598
    def _set_option(self, section_name, option_name, value):
1069
1599
        """Set an authentication configuration option"""
1470
2000
    """A Config that reads/writes a config file on a Transport.
1471
2001
 
1472
2002
    It is a low-level object that considers config data to be name/value pairs
1473
 
    that may be associated with a section.  Assigning meaning to the these
1474
 
    values is done at higher levels like TreeConfig.
 
2003
    that may be associated with a section.  Assigning meaning to these values
 
2004
    is done at higher levels like TreeConfig.
1475
2005
    """
1476
2006
 
1477
2007
    def __init__(self, transport, filename):
1510
2040
            configobj.setdefault(section, {})[name] = value
1511
2041
        self._set_configobj(configobj)
1512
2042
 
 
2043
    def remove_option(self, option_name, section_name=None):
 
2044
        configobj = self._get_configobj()
 
2045
        if section_name is None:
 
2046
            del configobj[option_name]
 
2047
        else:
 
2048
            del configobj[section_name][option_name]
 
2049
        self._set_configobj(configobj)
 
2050
 
1513
2051
    def _get_config_file(self):
1514
2052
        try:
1515
2053
            return StringIO(self._transport.get_bytes(self._filename))
1517
2055
            return StringIO()
1518
2056
 
1519
2057
    def _get_configobj(self):
1520
 
        return ConfigObj(self._get_config_file(), encoding='utf-8')
 
2058
        f = self._get_config_file()
 
2059
        try:
 
2060
            return ConfigObj(f, encoding='utf-8')
 
2061
        finally:
 
2062
            f.close()
1521
2063
 
1522
2064
    def _set_configobj(self, configobj):
1523
2065
        out_file = StringIO()
1524
2066
        configobj.write(out_file)
1525
2067
        out_file.seek(0)
1526
2068
        self._transport.put_file(self._filename, out_file)
 
2069
 
 
2070
 
 
2071
class cmd_config(commands.Command):
 
2072
    __doc__ = """Display, set or remove a configuration option.
 
2073
 
 
2074
    Display the active value for a given option.
 
2075
 
 
2076
    If --all is specified, NAME is interpreted as a regular expression and all
 
2077
    matching options are displayed mentioning their scope. The active value
 
2078
    that bzr will take into account is the first one displayed for each option.
 
2079
 
 
2080
    If no NAME is given, --all .* is implied.
 
2081
 
 
2082
    Setting a value is achieved by using name=value without spaces. The value
 
2083
    is set in the most relevant scope and can be checked by displaying the
 
2084
    option again.
 
2085
    """
 
2086
 
 
2087
    takes_args = ['name?']
 
2088
 
 
2089
    takes_options = [
 
2090
        'directory',
 
2091
        # FIXME: This should be a registry option so that plugins can register
 
2092
        # their own config files (or not) -- vila 20101002
 
2093
        commands.Option('scope', help='Reduce the scope to the specified'
 
2094
                        ' configuration file',
 
2095
                        type=unicode),
 
2096
        commands.Option('all',
 
2097
            help='Display all the defined values for the matching options.',
 
2098
            ),
 
2099
        commands.Option('remove', help='Remove the option from'
 
2100
                        ' the configuration file'),
 
2101
        ]
 
2102
 
 
2103
    @commands.display_command
 
2104
    def run(self, name=None, all=False, directory=None, scope=None,
 
2105
            remove=False):
 
2106
        if directory is None:
 
2107
            directory = '.'
 
2108
        directory = urlutils.normalize_url(directory)
 
2109
        if remove and all:
 
2110
            raise errors.BzrError(
 
2111
                '--all and --remove are mutually exclusive.')
 
2112
        elif remove:
 
2113
            # Delete the option in the given scope
 
2114
            self._remove_config_option(name, directory, scope)
 
2115
        elif name is None:
 
2116
            # Defaults to all options
 
2117
            self._show_matching_options('.*', directory, scope)
 
2118
        else:
 
2119
            try:
 
2120
                name, value = name.split('=', 1)
 
2121
            except ValueError:
 
2122
                # Display the option(s) value(s)
 
2123
                if all:
 
2124
                    self._show_matching_options(name, directory, scope)
 
2125
                else:
 
2126
                    self._show_value(name, directory, scope)
 
2127
            else:
 
2128
                if all:
 
2129
                    raise errors.BzrError(
 
2130
                        'Only one option can be set.')
 
2131
                # Set the option value
 
2132
                self._set_config_option(name, value, directory, scope)
 
2133
 
 
2134
    def _get_configs(self, directory, scope=None):
 
2135
        """Iterate the configurations specified by ``directory`` and ``scope``.
 
2136
 
 
2137
        :param directory: Where the configurations are derived from.
 
2138
 
 
2139
        :param scope: A specific config to start from.
 
2140
        """
 
2141
        if scope is not None:
 
2142
            if scope == 'bazaar':
 
2143
                yield GlobalConfig()
 
2144
            elif scope == 'locations':
 
2145
                yield LocationConfig(directory)
 
2146
            elif scope == 'branch':
 
2147
                (_, br, _) = bzrdir.BzrDir.open_containing_tree_or_branch(
 
2148
                    directory)
 
2149
                yield br.get_config()
 
2150
        else:
 
2151
            try:
 
2152
                (_, br, _) = bzrdir.BzrDir.open_containing_tree_or_branch(
 
2153
                    directory)
 
2154
                yield br.get_config()
 
2155
            except errors.NotBranchError:
 
2156
                yield LocationConfig(directory)
 
2157
                yield GlobalConfig()
 
2158
 
 
2159
    def _show_value(self, name, directory, scope):
 
2160
        displayed = False
 
2161
        for c in self._get_configs(directory, scope):
 
2162
            if displayed:
 
2163
                break
 
2164
            for (oname, value, section, conf_id, parser) in c._get_options():
 
2165
                if name == oname:
 
2166
                    # Display only the first value and exit
 
2167
 
 
2168
                    # FIXME: We need to use get_user_option to take policies
 
2169
                    # into account and we need to make sure the option exists
 
2170
                    # too (hence the two for loops), this needs a better API
 
2171
                    # -- vila 20101117
 
2172
                    value = c.get_user_option(name)
 
2173
                    # Quote the value appropriately
 
2174
                    value = parser._quote(value)
 
2175
                    self.outf.write('%s\n' % (value,))
 
2176
                    displayed = True
 
2177
                    break
 
2178
        if not displayed:
 
2179
            raise errors.NoSuchConfigOption(name)
 
2180
 
 
2181
    def _show_matching_options(self, name, directory, scope):
 
2182
        name = re.compile(name)
 
2183
        # We want any error in the regexp to be raised *now* so we need to
 
2184
        # avoid the delay introduced by the lazy regexp.
 
2185
        name._compile_and_collapse()
 
2186
        cur_conf_id = None
 
2187
        cur_section = None
 
2188
        for c in self._get_configs(directory, scope):
 
2189
            for (oname, value, section, conf_id, parser) in c._get_options():
 
2190
                if name.search(oname):
 
2191
                    if cur_conf_id != conf_id:
 
2192
                        # Explain where the options are defined
 
2193
                        self.outf.write('%s:\n' % (conf_id,))
 
2194
                        cur_conf_id = conf_id
 
2195
                        cur_section = None
 
2196
                    if (section not in (None, 'DEFAULT')
 
2197
                        and cur_section != section):
 
2198
                        # Display the section if it's not the default (or only)
 
2199
                        # one.
 
2200
                        self.outf.write('  [%s]\n' % (section,))
 
2201
                        cur_section = section
 
2202
                    self.outf.write('  %s = %s\n' % (oname, value))
 
2203
 
 
2204
    def _set_config_option(self, name, value, directory, scope):
 
2205
        for conf in self._get_configs(directory, scope):
 
2206
            conf.set_user_option(name, value)
 
2207
            break
 
2208
        else:
 
2209
            raise errors.NoSuchConfig(scope)
 
2210
 
 
2211
    def _remove_config_option(self, name, directory, scope):
 
2212
        if name is None:
 
2213
            raise errors.BzrCommandError(
 
2214
                '--remove expects an option to remove.')
 
2215
        removed = False
 
2216
        for conf in self._get_configs(directory, scope):
 
2217
            for (section_name, section, conf_id) in conf._get_sections():
 
2218
                if scope is not None and conf_id != scope:
 
2219
                    # Not the right configuration file
 
2220
                    continue
 
2221
                if name in section:
 
2222
                    if conf_id != conf.config_id():
 
2223
                        conf = self._get_configs(directory, conf_id).next()
 
2224
                    # We use the first section in the first config where the
 
2225
                    # option is defined to remove it
 
2226
                    conf.remove_user_option(name, section_name)
 
2227
                    removed = True
 
2228
                    break
 
2229
            break
 
2230
        else:
 
2231
            raise errors.NoSuchConfig(scope)
 
2232
        if not removed:
 
2233
            raise errors.NoSuchConfigOption(name)