49
48
# set, but at the moment that's not true -- mbp 20070814 --
50
49
# https://bugs.launchpad.net/bzr/+bug/132376
52
_mod_branch.BranchFormat.get_default_format(),
51
_mod_branch.format_registry.get_default(),
53
52
bzrdir.BzrDirFormat.get_default_format().get_branch_format())
55
54
def test_get_set_default_format(self):
56
55
# set the format and then set it back again
57
old_format = _mod_branch.BranchFormat.get_default_format()
58
_mod_branch.BranchFormat.set_default_format(SampleBranchFormat())
56
old_format = _mod_branch.format_registry.get_default()
57
_mod_branch.format_registry.set_default(SampleBranchFormat())
60
59
# the default branch format is used by the meta dir format
61
60
# which is not the default bzrdir format at this point
63
62
result = dir.create_branch()
64
63
self.assertEqual(result, 'A branch')
66
_mod_branch.BranchFormat.set_default_format(old_format)
65
_mod_branch.format_registry.set_default(old_format)
67
66
self.assertEqual(old_format,
68
_mod_branch.BranchFormat.get_default_format())
67
_mod_branch.format_registry.get_default())
71
70
class TestBranchFormat5(tests.TestCaseWithTransport):
102
101
# recursive section - that is, it appends the branch name.
105
class SampleBranchFormat(_mod_branch.BranchFormat):
104
class SampleBranchFormat(_mod_branch.BranchFormatMetadir):
106
105
"""A sample format
108
107
this format is initializable, unsupported to aid in testing the
109
108
open and open_downlevel routines.
112
def get_format_string(self):
112
def get_format_string(cls):
113
113
"""See BzrBranchFormat.get_format_string()."""
114
114
return "Sample branch format."
116
def initialize(self, a_bzrdir, name=None):
116
def initialize(self, a_bzrdir, name=None, repository=None,
117
append_revisions_only=None):
117
118
"""Format 4 branches cannot be created."""
118
119
t = a_bzrdir.get_branch_transport(self, name=name)
119
120
t.put_bytes('format', self.get_format_string())
131
133
SampleSupportedBranchFormatString = "Sample supported branch format."
133
135
# And the format class can then reference the constant to avoid skew.
134
class SampleSupportedBranchFormat(_mod_branch.BranchFormat):
136
class SampleSupportedBranchFormat(_mod_branch.BranchFormatMetadir):
135
137
"""A sample supported format."""
137
def get_format_string(self):
140
def get_format_string(cls):
138
141
"""See BzrBranchFormat.get_format_string()."""
139
142
return SampleSupportedBranchFormatString
141
def initialize(self, a_bzrdir, name=None):
144
def initialize(self, a_bzrdir, name=None, append_revisions_only=None):
142
145
t = a_bzrdir.get_branch_transport(self, name=name)
143
146
t.put_bytes('format', self.get_format_string())
144
147
return 'A branch'
146
def open(self, transport, name=None, _found=False, ignore_fallbacks=False):
149
def open(self, transport, name=None, _found=False, ignore_fallbacks=False,
150
possible_transports=None):
147
151
return "opened supported branch."
154
class SampleExtraBranchFormat(_mod_branch.BranchFormat):
155
"""A sample format that is not usable in a metadir."""
157
def get_format_string(self):
158
# This format is not usable in a metadir.
161
def network_name(self):
162
# Network name always has to be provided.
165
def initialize(self, a_bzrdir, name=None):
166
raise NotImplementedError(self.initialize)
168
def open(self, transport, name=None, _found=False, ignore_fallbacks=False,
169
possible_transports=None):
170
raise NotImplementedError(self.open)
150
173
class TestBzrBranchFormat(tests.TestCaseWithTransport):
151
174
"""Tests for the BzrBranchFormat facility."""
159
182
dir = format._matchingbzrdir.initialize(url)
160
183
dir.create_repository()
161
184
format.initialize(dir)
162
found_format = _mod_branch.BranchFormat.find_format(dir)
163
self.failUnless(isinstance(found_format, format.__class__))
185
found_format = _mod_branch.BranchFormatMetadir.find_format(dir)
186
self.assertIsInstance(found_format, format.__class__)
164
187
check_format(_mod_branch.BzrBranchFormat5(), "bar")
166
189
def test_find_format_factory(self):
169
192
factory = _mod_branch.MetaDirBranchFormatFactory(
170
193
SampleSupportedBranchFormatString,
171
194
"bzrlib.tests.test_branch", "SampleSupportedBranchFormat")
172
_mod_branch.BranchFormat.register_format(factory)
173
self.addCleanup(_mod_branch.BranchFormat.unregister_format, factory)
195
_mod_branch.format_registry.register(factory)
196
self.addCleanup(_mod_branch.format_registry.remove, factory)
174
197
b = _mod_branch.Branch.open(self.get_url())
175
198
self.assertEqual(b, "opened supported branch.")
200
def test_from_string(self):
201
self.assertIsInstance(
202
SampleBranchFormat.from_string("Sample branch format."),
204
self.assertRaises(ValueError,
205
SampleBranchFormat.from_string, "Different branch format.")
177
207
def test_find_format_not_branch(self):
178
208
dir = bzrdir.BzrDirMetaFormat1().initialize(self.get_url())
179
209
self.assertRaises(errors.NotBranchError,
180
_mod_branch.BranchFormat.find_format,
210
_mod_branch.BranchFormatMetadir.find_format,
183
213
def test_find_format_unknown_format(self):
184
214
dir = bzrdir.BzrDirMetaFormat1().initialize(self.get_url())
185
215
SampleBranchFormat().initialize(dir)
186
216
self.assertRaises(errors.UnknownFormatError,
187
_mod_branch.BranchFormat.find_format,
217
_mod_branch.BranchFormatMetadir.find_format,
190
220
def test_register_unregister_format(self):
221
# Test the deprecated format registration functions
191
222
format = SampleBranchFormat()
192
223
# make a control dir
193
224
dir = bzrdir.BzrDirMetaFormat1().initialize(self.get_url())
195
226
format.initialize(dir)
196
227
# register a format for it.
197
_mod_branch.BranchFormat.register_format(format)
228
self.applyDeprecated(symbol_versioning.deprecated_in((2, 4, 0)),
229
_mod_branch.BranchFormat.register_format, format)
198
230
# which branch.Open will refuse (not supported)
199
231
self.assertRaises(errors.UnsupportedFormatError,
200
232
_mod_branch.Branch.open, self.get_url())
204
236
format.open(dir),
205
237
bzrdir.BzrDir.open(self.get_url()).open_branch(unsupported=True))
206
238
# unregister the format
207
_mod_branch.BranchFormat.unregister_format(format)
239
self.applyDeprecated(symbol_versioning.deprecated_in((2, 4, 0)),
240
_mod_branch.BranchFormat.unregister_format, format)
208
241
self.make_branch_and_tree('bar')
244
class TestBranchFormatRegistry(tests.TestCase):
247
super(TestBranchFormatRegistry, self).setUp()
248
self.registry = _mod_branch.BranchFormatRegistry()
250
def test_default(self):
251
self.assertIs(None, self.registry.get_default())
252
format = SampleBranchFormat()
253
self.registry.set_default(format)
254
self.assertEquals(format, self.registry.get_default())
256
def test_register_unregister_format(self):
257
format = SampleBranchFormat()
258
self.registry.register(format)
259
self.assertEquals(format,
260
self.registry.get("Sample branch format."))
261
self.registry.remove(format)
262
self.assertRaises(KeyError, self.registry.get,
263
"Sample branch format.")
265
def test_get_all(self):
266
format = SampleBranchFormat()
267
self.assertEquals([], self.registry._get_all())
268
self.registry.register(format)
269
self.assertEquals([format], self.registry._get_all())
271
def test_register_extra(self):
272
format = SampleExtraBranchFormat()
273
self.assertEquals([], self.registry._get_all())
274
self.registry.register_extra(format)
275
self.assertEquals([format], self.registry._get_all())
277
def test_register_extra_lazy(self):
278
self.assertEquals([], self.registry._get_all())
279
self.registry.register_extra_lazy("bzrlib.tests.test_branch",
280
"SampleExtraBranchFormat")
281
formats = self.registry._get_all()
282
self.assertEquals(1, len(formats))
283
self.assertIsInstance(formats[0], SampleExtraBranchFormat)
211
286
#Used by TestMetaDirBranchFormatFactory
212
287
FakeLazyFormat = None
261
336
def test_layout(self):
262
337
branch = self.make_branch('a', format=self.get_format_name())
263
self.failUnlessExists('a/.bzr/branch/last-revision')
264
self.failIfExists('a/.bzr/branch/revision-history')
265
self.failIfExists('a/.bzr/branch/references')
338
self.assertPathExists('a/.bzr/branch/last-revision')
339
self.assertPathDoesNotExist('a/.bzr/branch/revision-history')
340
self.assertPathDoesNotExist('a/.bzr/branch/references')
267
342
def test_config(self):
268
343
"""Ensure that all configuration data is stored in the branch"""
269
344
branch = self.make_branch('a', format=self.get_format_name())
270
branch.set_parent('http://bazaar-vcs.org')
271
self.failIfExists('a/.bzr/branch/parent')
272
self.assertEqual('http://bazaar-vcs.org', branch.get_parent())
273
branch.set_push_location('sftp://bazaar-vcs.org')
345
branch.set_parent('http://example.com')
346
self.assertPathDoesNotExist('a/.bzr/branch/parent')
347
self.assertEqual('http://example.com', branch.get_parent())
348
branch.set_push_location('sftp://example.com')
274
349
config = branch.get_config()._get_branch_data_config()
275
self.assertEqual('sftp://bazaar-vcs.org',
350
self.assertEqual('sftp://example.com',
276
351
config.get_user_option('push_location'))
277
branch.set_bound_location('ftp://bazaar-vcs.org')
278
self.failIfExists('a/.bzr/branch/bound')
279
self.assertEqual('ftp://bazaar-vcs.org', branch.get_bound_location())
352
branch.set_bound_location('ftp://example.com')
353
self.assertPathDoesNotExist('a/.bzr/branch/bound')
354
self.assertEqual('ftp://example.com', branch.get_bound_location())
281
356
def test_set_revision_history(self):
282
357
builder = self.make_branch_builder('.', format=self.get_format_name())
287
362
branch = builder.get_branch()
288
363
branch.lock_write()
289
364
self.addCleanup(branch.unlock)
290
branch.set_revision_history(['foo', 'bar'])
291
branch.set_revision_history(['foo'])
365
self.applyDeprecated(symbol_versioning.deprecated_in((2, 4, 0)),
366
branch.set_revision_history, ['foo', 'bar'])
367
self.applyDeprecated(symbol_versioning.deprecated_in((2, 4, 0)),
368
branch.set_revision_history, ['foo'])
292
369
self.assertRaises(errors.NotLefthandHistory,
293
branch.set_revision_history, ['bar'])
370
self.applyDeprecated, symbol_versioning.deprecated_in((2, 4, 0)),
371
branch.set_revision_history, ['bar'])
295
373
def do_checkout_test(self, lightweight=False):
296
374
tree = self.make_branch_and_tree('source',
309
387
subtree.commit('a subtree file')
310
388
subsubtree.commit('a subsubtree file')
311
389
tree.branch.create_checkout('target', lightweight=lightweight)
312
self.failUnlessExists('target')
313
self.failUnlessExists('target/subtree')
314
self.failUnlessExists('target/subtree/file')
315
self.failUnlessExists('target/subtree/subsubtree/file')
390
self.assertPathExists('target')
391
self.assertPathExists('target/subtree')
392
self.assertPathExists('target/subtree/file')
393
self.assertPathExists('target/subtree/subsubtree/file')
316
394
subbranch = _mod_branch.Branch.open('target/subtree/subsubtree')
318
396
self.assertEndsWith(subbranch.base, 'source/subtree/subsubtree/')
475
553
self.assertEqual(('path3', 'location3'),
476
554
branch.get_reference_info('file-id'))
556
def _recordParentMapCalls(self, repo):
557
self._parent_map_calls = []
558
orig_get_parent_map = repo.revisions.get_parent_map
559
def get_parent_map(q):
561
self._parent_map_calls.extend([e[0] for e in q])
562
return orig_get_parent_map(q)
563
repo.revisions.get_parent_map = get_parent_map
478
566
class TestBranchReference(tests.TestCaseWithTransport):
479
567
"""Tests for the branch reference facility."""
481
569
def test_create_open_reference(self):
482
570
bzrdirformat = bzrdir.BzrDirMetaFormat1()
483
t = transport.get_transport(self.get_url('.'))
571
t = self.get_transport()
485
573
dir = bzrdirformat.initialize(self.get_url('repo'))
486
574
dir.create_repository()
581
669
super(TestBranchOptions, self).setUp()
582
670
self.branch = self.make_branch('.')
583
self.config = self.branch.get_config()
671
self.config_stack = self.branch.get_config_stack()
585
673
def check_append_revisions_only(self, expected_value, value=None):
586
674
"""Set append_revisions_only in config and check its interpretation."""
587
675
if value is not None:
588
self.config.set_user_option('append_revisions_only', value)
676
self.config_stack.set('append_revisions_only', value)
589
677
self.assertEqual(expected_value,
590
self.branch._get_append_revisions_only())
678
self.branch.get_append_revisions_only())
592
680
def test_valid_append_revisions_only(self):
593
681
self.assertEquals(None,
594
self.config.get_user_option('append_revisions_only'))
682
self.config_stack.get('append_revisions_only'))
595
683
self.check_append_revisions_only(None)
596
684
self.check_append_revisions_only(False, 'False')
597
685
self.check_append_revisions_only(True, 'True')
644
733
r.new_revid = "same-revid"
647
self.assertEqual("No revisions to pull.\n", f.getvalue())
650
class _StubLockable(object):
651
"""Helper for TestRunWithWriteLockedTarget."""
653
def __init__(self, calls, unlock_exc=None):
655
self.unlock_exc = unlock_exc
657
def lock_write(self):
658
self.calls.append('lock_write')
661
self.calls.append('unlock')
662
if self.unlock_exc is not None:
663
raise self.unlock_exc
666
class _ErrorFromCallable(Exception):
667
"""Helper for TestRunWithWriteLockedTarget."""
670
class _ErrorFromUnlock(Exception):
671
"""Helper for TestRunWithWriteLockedTarget."""
674
class TestRunWithWriteLockedTarget(tests.TestCase):
675
"""Tests for _run_with_write_locked_target."""
678
tests.TestCase.setUp(self)
681
def func_that_returns_ok(self):
682
self._calls.append('func called')
685
def func_that_raises(self):
686
self._calls.append('func called')
687
raise _ErrorFromCallable()
689
def test_success_unlocks(self):
690
lockable = _StubLockable(self._calls)
691
result = _mod_branch._run_with_write_locked_target(
692
lockable, self.func_that_returns_ok)
693
self.assertEqual('ok', result)
694
self.assertEqual(['lock_write', 'func called', 'unlock'], self._calls)
696
def test_exception_unlocks_and_propagates(self):
697
lockable = _StubLockable(self._calls)
698
self.assertRaises(_ErrorFromCallable,
699
_mod_branch._run_with_write_locked_target,
700
lockable, self.func_that_raises)
701
self.assertEqual(['lock_write', 'func called', 'unlock'], self._calls)
703
def test_callable_succeeds_but_error_during_unlock(self):
704
lockable = _StubLockable(self._calls, unlock_exc=_ErrorFromUnlock())
705
self.assertRaises(_ErrorFromUnlock,
706
_mod_branch._run_with_write_locked_target,
707
lockable, self.func_that_returns_ok)
708
self.assertEqual(['lock_write', 'func called', 'unlock'], self._calls)
710
def test_error_during_unlock_does_not_mask_original_error(self):
711
lockable = _StubLockable(self._calls, unlock_exc=_ErrorFromUnlock())
712
self.assertRaises(_ErrorFromCallable,
713
_mod_branch._run_with_write_locked_target,
714
lockable, self.func_that_raises)
715
self.assertEqual(['lock_write', 'func called', 'unlock'], self._calls)
736
self.assertEqual("No revisions or tags to pull.\n", f.getvalue())