← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/tests/test_store.py

Compare URLs in RemoteRepository.__eq__, rather than '_client' attributes.

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/tests/test_store.py
1
 
# Copyright (C) 2005 by Canonical Development Ltd
2
 
 
 
1
# Copyright (C) 2005 Canonical Ltd
 
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
5
5
# the Free Software Foundation; either version 2 of the License, or
6
6
# (at your option) any later version.
7
 
 
 
7
#
8
8
# This program is distributed in the hope that it will be useful,
9
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
11
11
# GNU General Public License for more details.
12
 
 
 
12
#
13
13
# You should have received a copy of the GNU General Public License
14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
20
20
import os
21
21
import gzip
22
22
 
 
23
import bzrlib.errors as errors
23
24
from bzrlib.errors import BzrError, UnlistableStore, NoSuchFile
24
 
from bzrlib.store import copy_all
25
25
from bzrlib.transport.local import LocalTransport
26
26
from bzrlib.store.text import TextStore
27
 
from bzrlib.tests import TestCase, TestCaseInTempDir
 
27
from bzrlib.tests import TestCase, TestCaseInTempDir, TestCaseWithTransport
28
28
import bzrlib.store as store
 
29
import bzrlib.transactions as transactions
29
30
import bzrlib.transport as transport
30
31
from bzrlib.transport.memory import MemoryTransport
31
32
 
37
38
        f = store.get(fileid)
38
39
        self.assertEqual(f.read(), value)
39
40
 
 
41
    def test_add_str_deprecated(self):
 
42
        os.mkdir('a')
 
43
        store = self.get_store('a')
 
44
        self.callDeprecated(['Passing a string to Store.add'
 
45
                             ' was deprecated in version 0.11.'],
 
46
                            store.add, 'foo', '1')
 
47
        self.assertEqual('foo', store.get('1').read())
 
48
 
40
49
    def fill_store(self, store):
41
50
        store.add(StringIO('hello'), 'a')
42
51
        store.add(StringIO('other'), 'b')
47
56
        """Test copying"""
48
57
        os.mkdir('a')
49
58
        store_a = self.get_store('a')
50
 
        store_a.add('foo', '1')
 
59
        store_a.add(StringIO('foo'), '1')
51
60
        os.mkdir('b')
52
61
        store_b = self.get_store('b')
53
 
        copy_all(store_a, store_b)
 
62
        store_b.copy_all_ids(store_a)
54
63
        self.assertEqual(store_a.get('1').read(), 'foo')
55
64
        self.assertEqual(store_b.get('1').read(), 'foo')
56
65
        # TODO: Switch the exception form UnlistableStore to
80
89
class TestCompressedTextStore(TestCaseInTempDir, TestStores):
81
90
 
82
91
    def get_store(self, path=u'.'):
83
 
        t = LocalTransport(path)
 
92
        t = transport.get_transport(path)
84
93
        return TextStore(t, compressed=True)
85
94
 
86
95
    def test_total_size(self):
101
110
class TestMemoryStore(TestCase):
102
111
    
103
112
    def get_store(self):
104
 
        return store.ImmutableMemoryStore()
 
113
        return TextStore(MemoryTransport())
105
114
    
106
 
    def test_imports(self):
107
 
        from bzrlib.store import ImmutableMemoryStore
108
 
 
109
115
    def test_add_and_retrieve(self):
110
116
        store = self.get_store()
111
117
        store.add(StringIO('hello'), 'aa')
140
146
class TestTextStore(TestCaseInTempDir, TestStores):
141
147
 
142
148
    def get_store(self, path=u'.'):
143
 
        t = LocalTransport(path)
 
149
        t = transport.get_transport(path)
144
150
        return TextStore(t, compressed=False)
145
151
 
146
152
    def test_total_size(self):
158
164
class TestMixedTextStore(TestCaseInTempDir, TestStores):
159
165
 
160
166
    def get_store(self, path=u'.', compressed=True):
161
 
        t = LocalTransport(path)
 
167
        t = transport.get_transport(path)
162
168
        return TextStore(t, compressed=compressed)
163
169
 
164
170
    def test_get_mixed(self):
387
393
        to_store = TextStore(MemoryTransport(),
388
394
                             prefixed=True, compressed=True)
389
395
        to_store.register_suffix('sig')
390
 
        copy_all(from_store, to_store)
 
396
        to_store.copy_all_ids(from_store)
391
397
        self.assertEqual(1, len(to_store))
392
398
        self.assertEqual(set(['foo']), set(to_store.__iter__()))
393
399
        self.assertEqual('content', to_store.get('foo').read())
397
403
    def test_relpath_escaped(self):
398
404
        my_store = store.TransportStore(MemoryTransport())
399
405
        self.assertEqual('%25', my_store._relpath('%'))
 
406
 
 
407
    def test_escaped_uppercase(self):
 
408
        """Uppercase letters are escaped for safety on Windows"""
 
409
        my_store = store.TransportStore(MemoryTransport(), escaped=True)
 
410
        # a particularly perverse file-id! :-)
 
411
        self.assertEquals(my_store._escape_file_id('C:<>'), '%43%3a%3c%3e')
 
412
 
 
413
 
 
414
class TestVersionFileStore(TestCaseWithTransport):
 
415
 
 
416
    def setUp(self):
 
417
        super(TestVersionFileStore, self).setUp()
 
418
        self.vfstore = store.versioned.VersionedFileStore(MemoryTransport())
 
419
 
 
420
    def test_get_weave_registers_dirty_in_write(self):
 
421
        transaction = transactions.WriteTransaction()
 
422
        vf = self.vfstore.get_weave_or_empty('id', transaction)
 
423
        transaction.finish()
 
424
        self.assertRaises(errors.OutSideTransaction, vf.add_lines, 'b', [], [])
 
425
        transaction = transactions.WriteTransaction()
 
426
        vf = self.vfstore.get_weave('id', transaction)
 
427
        transaction.finish()
 
428
        self.assertRaises(errors.OutSideTransaction, vf.add_lines, 'b', [], [])
 
429
 
 
430
    def test_get_weave_or_empty_readonly_fails(self):
 
431
        transaction = transactions.ReadOnlyTransaction()
 
432
        vf = self.assertRaises(errors.ReadOnlyError,
 
433
                               self.vfstore.get_weave_or_empty,
 
434
                               'id',
 
435
                               transaction)
 
436
 
 
437
    def test_get_weave_readonly_cant_write(self):
 
438
        transaction = transactions.WriteTransaction()
 
439
        vf = self.vfstore.get_weave_or_empty('id', transaction)
 
440
        transaction.finish()
 
441
        transaction = transactions.ReadOnlyTransaction()
 
442
        vf = self.vfstore.get_weave_or_empty('id', transaction)
 
443
        self.assertRaises(errors.ReadOnlyError, vf.add_lines, 'b', [], [])
 
444