~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/foreign.py

  • Committer: Robert Collins
  • Date: 2009-05-12 05:34:15 UTC
  • mto: This revision was merged to the branch mainline in revision 4593.
  • Revision ID: robertc@robertcollins.net-20090512053415-20rkucg2p211zdui
Check revisions as we cross check the revision index, rather than in a separate pass.

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
1
# Copyright (C) 2008 Canonical Ltd
 
2
#
 
3
# This program is free software; you can redistribute it and/or modify
 
4
# it under the terms of the GNU General Public License as published by
 
5
# the Free Software Foundation; either version 2 of the License, or
 
6
# (at your option) any later version.
 
7
#
 
8
# This program is distributed in the hope that it will be useful,
 
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
 
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
11
# GNU General Public License for more details.
 
12
#
 
13
# You should have received a copy of the GNU General Public License
 
14
# along with this program; if not, write to the Free Software
 
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 
16
 
 
17
 
 
18
"""Foreign branch utilities."""
 
19
 
 
20
 
 
21
from bzrlib.branch import Branch
 
22
from bzrlib.commands import Command, Option
 
23
from bzrlib.repository import Repository
 
24
from bzrlib.revision import Revision
 
25
from bzrlib.lazy_import import lazy_import
 
26
lazy_import(globals(), """
 
27
from bzrlib import (
 
28
    errors,
 
29
    osutils,
 
30
    registry,
 
31
    transform,
 
32
    )
 
33
""")
 
34
 
 
35
class VcsMapping(object):
 
36
    """Describes the mapping between the semantics of Bazaar and a foreign vcs.
 
37
 
 
38
    """
 
39
    # Whether this is an experimental mapping that is still open to changes.
 
40
    experimental = False
 
41
 
 
42
    # Whether this mapping supports exporting and importing all bzr semantics.
 
43
    roundtripping = False
 
44
 
 
45
    # Prefix used when importing native foreign revisions (not roundtripped)
 
46
    # using this mapping.
 
47
    revid_prefix = None
 
48
 
 
49
    def __init__(self, vcs):
 
50
        """Create a new VcsMapping.
 
51
 
 
52
        :param vcs: VCS that this mapping maps to Bazaar
 
53
        """
 
54
        self.vcs = vcs
 
55
 
 
56
    def revision_id_bzr_to_foreign(self, bzr_revid):
 
57
        """Parse a bzr revision id and convert it to a foreign revid.
 
58
 
 
59
        :param bzr_revid: The bzr revision id (a string).
 
60
        :return: A foreign revision id, can be any sort of object.
 
61
        """
 
62
        raise NotImplementedError(self.revision_id_bzr_to_foreign)
 
63
 
 
64
    def revision_id_foreign_to_bzr(self, foreign_revid):
 
65
        """Parse a foreign revision id and convert it to a bzr revid.
 
66
 
 
67
        :param foreign_revid: Foreign revision id, can be any sort of object.
 
68
        :return: A bzr revision id.
 
69
        """
 
70
        raise NotImplementedError(self.revision_id_foreign_to_bzr)
 
71
 
 
72
 
 
73
class VcsMappingRegistry(registry.Registry):
 
74
    """Registry for Bazaar<->foreign VCS mappings.
 
75
 
 
76
    There should be one instance of this registry for every foreign VCS.
 
77
    """
 
78
 
 
79
    def register(self, key, factory, help):
 
80
        """Register a mapping between Bazaar and foreign VCS semantics.
 
81
 
 
82
        The factory must be a callable that takes one parameter: the key.
 
83
        It must produce an instance of VcsMapping when called.
 
84
        """
 
85
        if ":" in key:
 
86
            raise ValueError("mapping name can not contain colon (:)")
 
87
        registry.Registry.register(self, key, factory, help)
 
88
 
 
89
    def set_default(self, key):
 
90
        """Set the 'default' key to be a clone of the supplied key.
 
91
 
 
92
        This method must be called once and only once.
 
93
        """
 
94
        self._set_default_key(key)
 
95
 
 
96
    def get_default(self):
 
97
        """Convenience function for obtaining the default mapping to use."""
 
98
        return self.get(self._get_default_key())
 
99
 
 
100
    def revision_id_bzr_to_foreign(self, revid):
 
101
        """Convert a bzr revision id to a foreign revid."""
 
102
        raise NotImplementedError(self.revision_id_bzr_to_foreign)
 
103
 
 
104
 
 
105
class ForeignRevision(Revision):
 
106
    """A Revision from a Foreign repository. Remembers
 
107
    information about foreign revision id and mapping.
 
108
 
 
109
    """
 
110
 
 
111
    def __init__(self, foreign_revid, mapping, *args, **kwargs):
 
112
        if not "inventory_sha1" in kwargs:
 
113
            kwargs["inventory_sha1"] = ""
 
114
        super(ForeignRevision, self).__init__(*args, **kwargs)
 
115
        self.foreign_revid = foreign_revid
 
116
        self.mapping = mapping
 
117
 
 
118
 
 
119
def show_foreign_properties(rev):
 
120
    """Custom log displayer for foreign revision identifiers.
 
121
 
 
122
    :param rev: Revision object.
 
123
    """
 
124
    # Revision comes directly from a foreign repository
 
125
    if isinstance(rev, ForeignRevision):
 
126
        return rev.mapping.vcs.show_foreign_revid(rev.foreign_revid)
 
127
 
 
128
    # Revision was once imported from a foreign repository
 
129
    try:
 
130
        foreign_revid, mapping = \
 
131
            foreign_vcs_registry.parse_revision_id(rev.revision_id)
 
132
    except errors.InvalidRevisionId:
 
133
        return {}
 
134
 
 
135
    return mapping.vcs.show_foreign_revid(foreign_revid)
 
136
 
 
137
 
 
138
class ForeignVcs(object):
 
139
    """A foreign version control system."""
 
140
 
 
141
    def __init__(self, mapping_registry):
 
142
        self.mapping_registry = mapping_registry
 
143
 
 
144
    def show_foreign_revid(self, foreign_revid):
 
145
        """Prepare a foreign revision id for formatting using bzr log.
 
146
 
 
147
        :param foreign_revid: Foreign revision id.
 
148
        :return: Dictionary mapping string keys to string values.
 
149
        """
 
150
        return { }
 
151
 
 
152
 
 
153
class ForeignVcsRegistry(registry.Registry):
 
154
    """Registry for Foreign VCSes.
 
155
 
 
156
    There should be one entry per foreign VCS. Example entries would be
 
157
    "git", "svn", "hg", "darcs", etc.
 
158
 
 
159
    """
 
160
 
 
161
    def register(self, key, foreign_vcs, help):
 
162
        """Register a foreign VCS.
 
163
 
 
164
        :param key: Prefix of the foreign VCS in revision ids
 
165
        :param foreign_vcs: ForeignVCS instance
 
166
        :param help: Description of the foreign VCS
 
167
        """
 
168
        if ":" in key or "-" in key:
 
169
            raise ValueError("vcs name can not contain : or -")
 
170
        registry.Registry.register(self, key, foreign_vcs, help)
 
171
 
 
172
    def parse_revision_id(self, revid):
 
173
        """Parse a bzr revision and return the matching mapping and foreign
 
174
        revid.
 
175
 
 
176
        :param revid: The bzr revision id
 
177
        :return: tuple with foreign revid and vcs mapping
 
178
        """
 
179
        if not "-" in revid:
 
180
            raise errors.InvalidRevisionId(revid, None)
 
181
        try:
 
182
            foreign_vcs = self.get(revid.split("-")[0])
 
183
        except KeyError:
 
184
            raise errors.InvalidRevisionId(revid, None)
 
185
        return foreign_vcs.mapping_registry.revision_id_bzr_to_foreign(revid)
 
186
 
 
187
 
 
188
foreign_vcs_registry = ForeignVcsRegistry()
 
189
 
 
190
 
 
191
class ForeignRepository(Repository):
 
192
    """A Repository that exists in a foreign version control system.
 
193
 
 
194
    The data in this repository can not be represented natively using
 
195
    Bazaars internal datastructures, but have to converted using a VcsMapping.
 
196
    """
 
197
 
 
198
    # This repository's native version control system
 
199
    vcs = None
 
200
 
 
201
    def has_foreign_revision(self, foreign_revid):
 
202
        """Check whether the specified foreign revision is present.
 
203
 
 
204
        :param foreign_revid: A foreign revision id, in the format used
 
205
                              by this Repository's VCS.
 
206
        """
 
207
        raise NotImplementedError(self.has_foreign_revision)
 
208
 
 
209
    def lookup_bzr_revision_id(self, revid):
 
210
        """Lookup a mapped or roundtripped revision by revision id.
 
211
 
 
212
        :param revid: Bazaar revision id
 
213
        :return: Tuple with foreign revision id and mapping.
 
214
        """
 
215
        raise NotImplementedError(self.lookup_revision_id)
 
216
 
 
217
    def all_revision_ids(self, mapping=None):
 
218
        """See Repository.all_revision_ids()."""
 
219
        raise NotImplementedError(self.all_revision_ids)
 
220
 
 
221
    def get_default_mapping(self):
 
222
        """Get the default mapping for this repository."""
 
223
        raise NotImplementedError(self.get_default_mapping)
 
224
 
 
225
    def get_inventory_xml(self, revision_id):
 
226
        """See Repository.get_inventory_xml()."""
 
227
        return self.serialise_inventory(self.get_inventory(revision_id))
 
228
 
 
229
    def get_inventory_sha1(self, revision_id):
 
230
        """Get the sha1 for the XML representation of an inventory.
 
231
 
 
232
        :param revision_id: Revision id of the inventory for which to return
 
233
         the SHA1.
 
234
        :return: XML string
 
235
        """
 
236
 
 
237
        return osutils.sha_string(self.get_inventory_xml(revision_id))
 
238
 
 
239
    def get_revision_xml(self, revision_id):
 
240
        """Return the XML representation of a revision.
 
241
 
 
242
        :param revision_id: Revision for which to return the XML.
 
243
        :return: XML string
 
244
        """
 
245
        return self._serializer.write_revision_to_string(
 
246
            self.get_revision(revision_id))
 
247
 
 
248
 
 
249
class ForeignBranch(Branch):
 
250
    """Branch that exists in a foreign version control system."""
 
251
 
 
252
    def __init__(self, mapping):
 
253
        self.mapping = mapping
 
254
        super(ForeignBranch, self).__init__()
 
255
 
 
256
    def dpull(self, source, stop_revision=None):
 
257
        """Pull deltas from another branch.
 
258
 
 
259
        :note: This does not, like pull, retain the revision ids from 
 
260
            the source branch and will, rather than adding bzr-specific 
 
261
            metadata, push only those semantics of the revision that can be 
 
262
            natively represented by this branch' VCS.
 
263
 
 
264
        :param source: Source branch
 
265
        :param stop_revision: Revision to pull, defaults to last revision.
 
266
        :return: Dictionary mapping revision ids from the source branch 
 
267
            to new revision ids in the target branch, for each 
 
268
            revision that was pull.
 
269
        """
 
270
        raise NotImplementedError(self.dpull)
 
271
 
 
272
 
 
273
def update_workingtree_fileids(wt, target_tree):
 
274
    """Update the file ids in a working tree based on another tree.
 
275
 
 
276
    :param wt: Working tree in which to update file ids
 
277
    :param target_tree: Tree to retrieve new file ids from, based on path
 
278
    """
 
279
    tt = transform.TreeTransform(wt)
 
280
    try:
 
281
        for f, p, c, v, d, n, k, e in target_tree.iter_changes(wt):
 
282
            if v == (True, False):
 
283
                trans_id = tt.trans_id_tree_path(p[0])
 
284
                tt.unversion_file(trans_id)
 
285
            elif v == (False, True):
 
286
                trans_id = tt.trans_id_tree_path(p[1])
 
287
                tt.version_file(f, trans_id)
 
288
        tt.apply()
 
289
    finally:
 
290
        tt.finalize()
 
291
    if len(wt.get_parent_ids()) == 1:
 
292
        wt.set_parent_trees([(target_tree.get_revision_id(), target_tree)])
 
293
    else:
 
294
        wt.set_last_revision(target_tree.get_revision_id())
 
295
 
 
296
 
 
297
class cmd_dpush(Command):
 
298
    """Push diffs into a foreign version control system without any 
 
299
    Bazaar-specific metadata.
 
300
 
 
301
    This will afterwards rebase the local Bazaar branch on the remote
 
302
    branch unless the --no-rebase option is used, in which case 
 
303
    the two branches will be out of sync. 
 
304
    """
 
305
    hidden = True
 
306
    takes_args = ['location?']
 
307
    takes_options = ['remember', Option('directory',
 
308
            help='Branch to push from, '
 
309
                 'rather than the one containing the working directory.',
 
310
            short_name='d',
 
311
            type=unicode,
 
312
            ),
 
313
            Option('no-rebase', help="Do not rebase after push.")]
 
314
 
 
315
    def run(self, location=None, remember=False, directory=None, 
 
316
            no_rebase=False):
 
317
        from bzrlib import urlutils
 
318
        from bzrlib.bzrdir import BzrDir
 
319
        from bzrlib.errors import BzrCommandError, NoWorkingTree
 
320
        from bzrlib.trace import info
 
321
        from bzrlib.workingtree import WorkingTree
 
322
 
 
323
        if directory is None:
 
324
            directory = "."
 
325
        try:
 
326
            source_wt = WorkingTree.open_containing(directory)[0]
 
327
            source_branch = source_wt.branch
 
328
        except NoWorkingTree:
 
329
            source_branch = Branch.open(directory)
 
330
            source_wt = None
 
331
        stored_loc = source_branch.get_push_location()
 
332
        if location is None:
 
333
            if stored_loc is None:
 
334
                raise BzrCommandError("No push location known or specified.")
 
335
            else:
 
336
                display_url = urlutils.unescape_for_display(stored_loc,
 
337
                        self.outf.encoding)
 
338
                self.outf.write("Using saved location: %s\n" % display_url)
 
339
                location = stored_loc
 
340
 
 
341
        bzrdir = BzrDir.open(location)
 
342
        target_branch = bzrdir.open_branch()
 
343
        dpull = getattr(target_branch, "dpull", None)
 
344
        if dpull is None:
 
345
            raise BzrCommandError("%r is not a foreign branch, use "
 
346
                                  "regular push." % target_branch)
 
347
        target_branch.lock_write()
 
348
        try:
 
349
            revid_map = dpull(source_branch)
 
350
            # We successfully created the target, remember it
 
351
            if source_branch.get_push_location() is None or remember:
 
352
                source_branch.set_push_location(target_branch.base)
 
353
            if not no_rebase:
 
354
                old_last_revid = source_branch.last_revision()
 
355
                source_branch.pull(target_branch, overwrite=True)
 
356
                new_last_revid = source_branch.last_revision()
 
357
                if source_wt is not None and old_last_revid != new_last_revid:
 
358
                    source_wt.lock_write()
 
359
                    try:
 
360
                        target = source_wt.branch.repository.revision_tree(
 
361
                            new_last_revid)
 
362
                        update_workingtree_fileids(source_wt, target)
 
363
                    finally:
 
364
                        source_wt.unlock()
 
365
        finally:
 
366
            target_branch.unlock()