← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/selftest/testfetch.py

  • Committer: Robert Collins
  • Date: 2005-10-23 11:46:19 UTC
  • Revision ID: robertc@robertcollins.net-20051023114619-cec8ca25207b1344
More quoting at the transport layer bugfixes.

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/selftest/testfetch.py
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
16
16
 
 
17
import os
17
18
import sys
18
 
import os
19
19
 
20
20
import bzrlib.errors
21
21
from bzrlib.selftest.testrevision import make_branches
24
24
from bzrlib.fetch import greedy_fetch
25
25
 
26
26
from bzrlib.selftest import TestCaseInTempDir
27
 
        
 
27
from bzrlib.selftest.HTTPTestUtil import TestCaseWithWebserver
 
28
 
28
29
 
29
30
def has_revision(branch, revision_id):
30
31
    try:
33
34
    except bzrlib.errors.NoSuchRevision:
34
35
        return False
35
36
 
36
 
 
 
37
def fetch_steps(self, br_a, br_b, writable_a):
 
38
    """A foreign test method for testing fetch locally and remotely."""
 
39
    def new_branch(name):
 
40
        os.mkdir(name)
 
41
        return Branch.initialize(name)
 
42
            
 
43
    assert not has_revision(br_b, br_a.revision_history()[3])
 
44
    assert has_revision(br_b, br_a.revision_history()[2])
 
45
    assert len(br_b.revision_history()) == 7
 
46
    assert greedy_fetch(br_b, br_a, br_a.revision_history()[2])[0] == 0
 
47
 
 
48
    # greedy_fetch is not supposed to alter the revision history
 
49
    assert len(br_b.revision_history()) == 7
 
50
    assert not has_revision(br_b, br_a.revision_history()[3])
 
51
 
 
52
    assert len(br_b.revision_history()) == 7
 
53
    assert greedy_fetch(br_b, br_a, br_a.revision_history()[3])[0] == 1
 
54
    assert has_revision(br_b, br_a.revision_history()[3])
 
55
    assert not has_revision(br_a, br_b.revision_history()[6])
 
56
    assert has_revision(br_a, br_b.revision_history()[5])
 
57
 
 
58
    # When a non-branch ancestor is missing, it should be unlisted...
 
59
    # as its not reference from the inventory weave.
 
60
    br_b4 = new_branch('br_4')
 
61
    count, failures = greedy_fetch(br_b4, br_b)
 
62
    self.assertEqual(count, 7)
 
63
    self.assertEqual(failures, [])
 
64
 
 
65
    self.assertEqual(greedy_fetch(writable_a, br_b)[0], 1)
 
66
    assert has_revision(br_a, br_b.revision_history()[3])
 
67
    assert has_revision(br_a, br_b.revision_history()[4])
 
68
        
 
69
    br_b2 = new_branch('br_b2')
 
70
    assert greedy_fetch(br_b2, br_b)[0] == 7
 
71
    assert has_revision(br_b2, br_b.revision_history()[4])
 
72
    assert has_revision(br_b2, br_a.revision_history()[2])
 
73
    assert not has_revision(br_b2, br_a.revision_history()[3])
 
74
 
 
75
    br_a2 = new_branch('br_a2')
 
76
    assert greedy_fetch(br_a2, br_a)[0] == 9
 
77
    assert has_revision(br_a2, br_b.revision_history()[4])
 
78
    assert has_revision(br_a2, br_a.revision_history()[3])
 
79
    assert has_revision(br_a2, br_a.revision_history()[2])
 
80
 
 
81
    br_a3 = new_branch('br_a3')
 
82
    assert greedy_fetch(br_a3, br_a2)[0] == 0
 
83
    for revno in range(4):
 
84
        assert not has_revision(br_a3, br_a.revision_history()[revno])
 
85
    self.assertEqual(greedy_fetch(br_a3, br_a2, br_a.revision_history()[2])[0], 3)
 
86
    fetched = greedy_fetch(br_a3, br_a2, br_a.revision_history()[3])[0]
 
87
    assert fetched == 3, "fetched %d instead of 3" % fetched
 
88
    # InstallFailed should be raised if the branch is missing the revision
 
89
    # that was requested.
 
90
    self.assertRaises(bzrlib.errors.InstallFailed, greedy_fetch, br_a3,
 
91
                      br_a2, 'pizza')
 
92
    # InstallFailed should be raised if the branch is missing a revision
 
93
    # from its own revision history
 
94
    br_a2.append_revision('a-b-c')
 
95
    self.assertRaises(bzrlib.errors.InstallFailed, greedy_fetch, br_a3,
 
96
                      br_a2)
 
97
 
 
98
 
 
99
    #TODO: test that fetch correctly does reweaving when needed. RBC 20051008
37
100
 
38
101
class TestFetch(TestCaseInTempDir):
39
 
    def SKIPPED_old_test_fetch(self):
40
 
        """obsolete: new commit code depends on parents being present
41
 
        so the test data no longer suits this test."""
42
 
        
43
 
        def new_branch(name):
44
 
            os.mkdir(name)
45
 
            return Branch(name, init=True)
46
 
            
47
 
        #highest indices a: 5, b: 7
48
 
        br_a, br_b = make_branches()
49
 
        assert not has_revision(br_b, br_a.revision_history()[3])
50
 
        assert has_revision(br_b, br_a.revision_history()[2])
51
 
        assert len(br_b.revision_history()) == 7
52
 
        assert greedy_fetch(br_b, br_a, br_a.revision_history()[2])[0] == 0
53
 
 
54
 
        # greedy_fetch is not supposed to alter the revision history
55
 
        assert len(br_b.revision_history()) == 7
56
 
        assert not has_revision(br_b, br_a.revision_history()[3])
57
 
 
58
 
        assert len(br_b.revision_history()) == 7
59
 
        assert greedy_fetch(br_b, br_a, br_a.revision_history()[3])[0] == 1
60
 
        assert has_revision(br_b, br_a.revision_history()[3])
61
 
        assert not has_revision(br_a, br_b.revision_history()[3])
62
 
        assert not has_revision(br_a, br_b.revision_history()[4])
63
 
 
64
 
        # When a non-branch ancestor is missing, it should be a failure, not
65
 
        # exception
66
 
        br_a4 = new_branch('br_a4')
67
 
        count, failures = greedy_fetch(br_a4, br_a)
68
 
        assert count == 6
69
 
        assert failures == set((br_b.revision_history()[4],
70
 
                                br_b.revision_history()[5])) 
71
 
 
72
 
        assert greedy_fetch(br_a, br_b)[0] == 4
73
 
        assert has_revision(br_a, br_b.revision_history()[3])
74
 
        assert has_revision(br_a, br_b.revision_history()[4])
75
 
 
76
 
        br_b2 = new_branch('br_b2')
77
 
        assert greedy_fetch(br_b2, br_b)[0] == 7
78
 
        assert has_revision(br_b2, br_b.revision_history()[4])
79
 
        assert has_revision(br_b2, br_a.revision_history()[2])
80
 
        assert not has_revision(br_b2, br_a.revision_history()[3])
81
 
 
82
 
        br_a2 = new_branch('br_a2')
83
 
        assert greedy_fetch(br_a2, br_a)[0] == 9
84
 
        assert has_revision(br_a2, br_b.revision_history()[4])
85
 
        assert has_revision(br_a2, br_a.revision_history()[3])
86
 
 
87
 
        br_a3 = new_branch('br_a3')
88
 
        assert greedy_fetch(br_a3, br_a2)[0] == 0
89
 
        for revno in range(4):
90
 
            assert not has_revision(br_a3, br_a.revision_history()[revno])
91
 
        assert greedy_fetch(br_a3, br_a2, br_a.revision_history()[2])[0] == 3
92
 
        fetched = greedy_fetch(br_a3, br_a2, br_a.revision_history()[3])[0]
93
 
        assert fetched == 3, "fetched %d instead of 3" % fetched
94
 
        # InstallFailed should be raised if the branch is missing the revision
95
 
        # that was requested.
96
 
        self.assertRaises(bzrlib.errors.InstallFailed, greedy_fetch, br_a3,
97
 
                          br_a2, 'pizza')
98
 
        # InstallFailed should be raised if the branch is missing a revision
99
 
        # from its own revision history
100
 
        br_a2.append_revision('a-b-c')
101
 
        self.assertRaises(bzrlib.errors.InstallFailed, greedy_fetch, br_a3,
102
 
                          br_a2)
103
 
 
104
 
 
105
 
 
106
 
if __name__ == '__main__':
107
 
    import unittest
108
 
    unittest.main()
109
 
    
 
102
 
 
103
    def test_fetch(self):
 
104
        #highest indices a: 5, b: 7
 
105
        br_a, br_b = make_branches()
 
106
        fetch_steps(self, br_a, br_b, br_a)
 
107
 
 
108
 
 
109
class TestHttpFetch(TestCaseWithWebserver):
 
110
 
 
111
    def setUp(self):
 
112
        super(TestHttpFetch, self).setUp()
 
113
        self.weblogs = []
 
114
 
 
115
    def test_fetch(self):
 
116
        #highest indices a: 5, b: 7
 
117
        br_a, br_b = make_branches()
 
118
        br_rem_a = Branch.open(self.get_remote_url(br_a._transport.base))
 
119
        fetch_steps(self, br_rem_a, br_b, br_a)
 
120
 
 
121
    def log(self, *args):
 
122
        """Capture web server log messages for introspection."""
 
123
        super(TestHttpFetch, self).log(*args)
 
124
        if args[0].startswith("webserver"):
 
125
            self.weblogs.append(args[0])
 
126
 
 
127
    def test_weaves_are_retrieved_once(self):
 
128
        self.build_tree(("source/", "source/file", "target/"))
 
129
        branch = Branch.initialize("source")
 
130
        branch.add(["file"], ["id"])
 
131
        branch.commit("added file")
 
132
        print >>open("source/file", 'w'), "blah"
 
133
        branch.commit("changed file")
 
134
        target = Branch.initialize("target/")
 
135
        source = Branch.open(self.get_remote_url("source/"))
 
136
        self.assertEqual(greedy_fetch(target, source), (2, []))
 
137
        # this is the path to the literal file. As format changes 
 
138
        # occur it needs to be updated. FIXME: ask the store for the
 
139
        # path.
 
140
        weave_suffix = 'weaves/ce/id.weave HTTP/1.1" 200 -'
 
141
        self.assertEqual(1,
 
142
            len([log for log in self.weblogs if log.endswith(weave_suffix)]))
 
143
        inventory_weave_suffix = 'inventory.weave HTTP/1.1" 200 -'
 
144
        self.assertEqual(1,
 
145
            len([log for log in self.weblogs if log.endswith(
 
146
                inventory_weave_suffix)]))
 
147
        # this r-h check test will prevent regressions, but it currently already 
 
148
        # passes, before the patch to cache-rh is applied :[
 
149
        revision_history_suffix = 'revision-history HTTP/1.1" 200 -'
 
150
        self.assertEqual(1,
 
151
            len([log for log in self.weblogs if log.endswith(
 
152
                revision_history_suffix)]))
 
153
        self.weblogs = []
 
154
        # check there is nothing more to fetch
 
155
        source = Branch.open(self.get_remote_url("source/"))
 
156
        self.assertEqual(greedy_fetch(target, source), (0, []))
 
157
        self.failUnless(self.weblogs[0].endswith('branch-format HTTP/1.1" 200 -'))
 
158
        self.failUnless(self.weblogs[1].endswith('revision-history HTTP/1.1" 200 -'))
 
159
        self.assertEqual(2, len(self.weblogs))