1
 
# Copyright (C) 2008, 2009, 2010 Canonical Ltd
 
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.
 
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.
 
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
 
18
 
"""Foreign branch utilities."""
 
21
 
from bzrlib.branch import (
 
25
 
from bzrlib.commands import Command, Option
 
26
 
from bzrlib.repository import Repository
 
27
 
from bzrlib.revision import Revision
 
28
 
from bzrlib.lazy_import import lazy_import
 
29
 
lazy_import(globals(), """
 
38
 
class VcsMapping(object):
 
39
 
    """Describes the mapping between the semantics of Bazaar and a foreign VCS.
 
42
 
    # Whether this is an experimental mapping that is still open to changes.
 
45
 
    # Whether this mapping supports exporting and importing all bzr semantics.
 
48
 
    # Prefix used when importing revisions native to the foreign VCS (as
 
49
 
    # opposed to roundtripping bzr-native revisions) using this mapping.
 
52
 
    def __init__(self, vcs):
 
53
 
        """Create a new VcsMapping.
 
55
 
        :param vcs: VCS that this mapping maps to Bazaar
 
59
 
    def revision_id_bzr_to_foreign(self, bzr_revid):
 
60
 
        """Parse a bzr revision id and convert it to a foreign revid.
 
62
 
        :param bzr_revid: The bzr revision id (a string).
 
63
 
        :return: A foreign revision id, can be any sort of object.
 
65
 
        raise NotImplementedError(self.revision_id_bzr_to_foreign)
 
67
 
    def revision_id_foreign_to_bzr(self, foreign_revid):
 
68
 
        """Parse a foreign revision id and convert it to a bzr revid.
 
70
 
        :param foreign_revid: Foreign revision id, can be any sort of object.
 
71
 
        :return: A bzr revision id.
 
73
 
        raise NotImplementedError(self.revision_id_foreign_to_bzr)
 
76
 
class VcsMappingRegistry(registry.Registry):
 
77
 
    """Registry for Bazaar<->foreign VCS mappings.
 
79
 
    There should be one instance of this registry for every foreign VCS.
 
82
 
    def register(self, key, factory, help):
 
83
 
        """Register a mapping between Bazaar and foreign VCS semantics.
 
85
 
        The factory must be a callable that takes one parameter: the key.
 
86
 
        It must produce an instance of VcsMapping when called.
 
89
 
            raise ValueError("mapping name can not contain colon (:)")
 
90
 
        registry.Registry.register(self, key, factory, help)
 
92
 
    def set_default(self, key):
 
93
 
        """Set the 'default' key to be a clone of the supplied key.
 
95
 
        This method must be called once and only once.
 
97
 
        self._set_default_key(key)
 
99
 
    def get_default(self):
 
100
 
        """Convenience function for obtaining the default mapping to use."""
 
101
 
        return self.get(self._get_default_key())
 
103
 
    def revision_id_bzr_to_foreign(self, revid):
 
104
 
        """Convert a bzr revision id to a foreign revid."""
 
105
 
        raise NotImplementedError(self.revision_id_bzr_to_foreign)
 
108
 
class ForeignRevision(Revision):
 
109
 
    """A Revision from a Foreign repository. Remembers
 
110
 
    information about foreign revision id and mapping.
 
114
 
    def __init__(self, foreign_revid, mapping, *args, **kwargs):
 
115
 
        if not "inventory_sha1" in kwargs:
 
116
 
            kwargs["inventory_sha1"] = ""
 
117
 
        super(ForeignRevision, self).__init__(*args, **kwargs)
 
118
 
        self.foreign_revid = foreign_revid
 
119
 
        self.mapping = mapping
 
122
 
class ForeignVcs(object):
 
123
 
    """A foreign version control system."""
 
127
 
    repository_format = None
 
129
 
    def __init__(self, mapping_registry, abbreviation=None):
 
130
 
        """Create a new foreign vcs instance.
 
132
 
        :param mapping_registry: Registry with mappings for this VCS.
 
133
 
        :param abbreviation: Optional abbreviation ('bzr', 'svn', 'git', etc)
 
135
 
        self.abbreviation = abbreviation
 
136
 
        self.mapping_registry = mapping_registry
 
138
 
    def show_foreign_revid(self, foreign_revid):
 
139
 
        """Prepare a foreign revision id for formatting using bzr log.
 
141
 
        :param foreign_revid: Foreign revision id.
 
142
 
        :return: Dictionary mapping string keys to string values.
 
146
 
    def serialize_foreign_revid(self, foreign_revid):
 
147
 
        """Serialize a foreign revision id for this VCS.
 
149
 
        :param foreign_revid: Foreign revision id
 
150
 
        :return: Bytestring with serialized revid, will not contain any 
 
153
 
        raise NotImplementedError(self.serialize_foreign_revid)
 
156
 
class ForeignVcsRegistry(registry.Registry):
 
157
 
    """Registry for Foreign VCSes.
 
159
 
    There should be one entry per foreign VCS. Example entries would be
 
160
 
    "git", "svn", "hg", "darcs", etc.
 
164
 
    def register(self, key, foreign_vcs, help):
 
165
 
        """Register a foreign VCS.
 
167
 
        :param key: Prefix of the foreign VCS in revision ids
 
168
 
        :param foreign_vcs: ForeignVCS instance
 
169
 
        :param help: Description of the foreign VCS
 
171
 
        if ":" in key or "-" in key:
 
172
 
            raise ValueError("vcs name can not contain : or -")
 
173
 
        registry.Registry.register(self, key, foreign_vcs, help)
 
175
 
    def parse_revision_id(self, revid):
 
176
 
        """Parse a bzr revision and return the matching mapping and foreign
 
179
 
        :param revid: The bzr revision id
 
180
 
        :return: tuple with foreign revid and vcs mapping
 
182
 
        if not ":" in revid or not "-" in revid:
 
183
 
            raise errors.InvalidRevisionId(revid, None)
 
185
 
            foreign_vcs = self.get(revid.split("-")[0])
 
187
 
            raise errors.InvalidRevisionId(revid, None)
 
188
 
        return foreign_vcs.mapping_registry.revision_id_bzr_to_foreign(revid)
 
191
 
foreign_vcs_registry = ForeignVcsRegistry()
 
194
 
class ForeignRepository(Repository):
 
195
 
    """A Repository that exists in a foreign version control system.
 
197
 
    The data in this repository can not be represented natively using
 
198
 
    Bazaars internal datastructures, but have to converted using a VcsMapping.
 
201
 
    # This repository's native version control system
 
204
 
    def has_foreign_revision(self, foreign_revid):
 
205
 
        """Check whether the specified foreign revision is present.
 
207
 
        :param foreign_revid: A foreign revision id, in the format used
 
208
 
                              by this Repository's VCS.
 
210
 
        raise NotImplementedError(self.has_foreign_revision)
 
212
 
    def lookup_bzr_revision_id(self, revid):
 
213
 
        """Lookup a mapped or roundtripped revision by revision id.
 
215
 
        :param revid: Bazaar revision id
 
216
 
        :return: Tuple with foreign revision id and mapping.
 
218
 
        raise NotImplementedError(self.lookup_revision_id)
 
220
 
    def all_revision_ids(self, mapping=None):
 
221
 
        """See Repository.all_revision_ids()."""
 
222
 
        raise NotImplementedError(self.all_revision_ids)
 
224
 
    def get_default_mapping(self):
 
225
 
        """Get the default mapping for this repository."""
 
226
 
        raise NotImplementedError(self.get_default_mapping)
 
229
 
class ForeignBranch(Branch):
 
230
 
    """Branch that exists in a foreign version control system."""
 
232
 
    def __init__(self, mapping):
 
233
 
        self.mapping = mapping
 
234
 
        super(ForeignBranch, self).__init__()
 
237
 
def update_workingtree_fileids(wt, target_tree):
 
238
 
    """Update the file ids in a working tree based on another tree.
 
240
 
    :param wt: Working tree in which to update file ids
 
241
 
    :param target_tree: Tree to retrieve new file ids from, based on path
 
243
 
    tt = transform.TreeTransform(wt)
 
245
 
        for f, p, c, v, d, n, k, e in target_tree.iter_changes(wt):
 
246
 
            if v == (True, False):
 
247
 
                trans_id = tt.trans_id_tree_path(p[0])
 
248
 
                tt.unversion_file(trans_id)
 
249
 
            elif v == (False, True):
 
250
 
                trans_id = tt.trans_id_tree_path(p[1])
 
251
 
                tt.version_file(f, trans_id)
 
255
 
    if len(wt.get_parent_ids()) == 1:
 
256
 
        wt.set_parent_trees([(target_tree.get_revision_id(), target_tree)])
 
258
 
        wt.set_last_revision(target_tree.get_revision_id())
 
261
 
class cmd_dpush(Command):
 
262
 
    __doc__ = """Push into a different VCS without any custom bzr metadata.
 
264
 
    This will afterwards rebase the local branch on the remote
 
265
 
    branch unless the --no-rebase option is used, in which case 
 
266
 
    the two branches will be out of sync after the push. 
 
269
 
    takes_args = ['location?']
 
273
 
               help='Branch to push from, '
 
274
 
               'rather than the one containing the working directory.',
 
278
 
        Option('no-rebase', help="Do not rebase after push."),
 
280
 
               help='Refuse to push if there are uncommitted changes in'
 
281
 
               ' the working tree, --no-strict disables the check.'),
 
284
 
    def run(self, location=None, remember=False, directory=None,
 
285
 
            no_rebase=False, strict=None):
 
286
 
        from bzrlib import urlutils
 
287
 
        from bzrlib.bzrdir import BzrDir
 
288
 
        from bzrlib.errors import BzrCommandError, NoWorkingTree
 
289
 
        from bzrlib.workingtree import WorkingTree
 
291
 
        if directory is None:
 
294
 
            source_wt = WorkingTree.open_containing(directory)[0]
 
295
 
            source_branch = source_wt.branch
 
296
 
        except NoWorkingTree:
 
297
 
            source_branch = Branch.open(directory)
 
299
 
        if source_wt is not None:
 
300
 
            source_wt.check_changed_or_out_of_date(
 
301
 
                strict, 'dpush_strict',
 
302
 
                more_error='Use --no-strict to force the push.',
 
303
 
                more_warning='Uncommitted changes will not be pushed.')
 
304
 
        stored_loc = source_branch.get_push_location()
 
306
 
            if stored_loc is None:
 
307
 
                raise BzrCommandError("No push location known or specified.")
 
309
 
                display_url = urlutils.unescape_for_display(stored_loc,
 
311
 
                self.outf.write("Using saved location: %s\n" % display_url)
 
312
 
                location = stored_loc
 
314
 
        bzrdir = BzrDir.open(location)
 
315
 
        target_branch = bzrdir.open_branch()
 
316
 
        target_branch.lock_write()
 
319
 
                push_result = source_branch.lossy_push(target_branch)
 
320
 
            except errors.LossyPushToSameVCS:
 
321
 
                raise BzrCommandError("%r and %r are in the same VCS, lossy "
 
322
 
                    "push not necessary. Please use regular push." %
 
323
 
                    (source_branch, target_branch))
 
324
 
            # We successfully created the target, remember it
 
325
 
            if source_branch.get_push_location() is None or remember:
 
326
 
                source_branch.set_push_location(target_branch.base)
 
328
 
                old_last_revid = source_branch.last_revision()
 
329
 
                source_branch.pull(target_branch, overwrite=True)
 
330
 
                new_last_revid = source_branch.last_revision()
 
331
 
                if source_wt is not None and old_last_revid != new_last_revid:
 
332
 
                    source_wt.lock_write()
 
334
 
                        target = source_wt.branch.repository.revision_tree(
 
336
 
                        update_workingtree_fileids(source_wt, target)
 
339
 
            push_result.report(self.outf)
 
341
 
            target_branch.unlock()
 
344
 
class InterToForeignBranch(InterBranch):
 
346
 
    def lossy_push(self, stop_revision=None):
 
347
 
        """Push deltas into another branch.
 
349
 
        :note: This does not, like push, retain the revision ids from 
 
350
 
            the source branch and will, rather than adding bzr-specific 
 
351
 
            metadata, push only those semantics of the revision that can be 
 
352
 
            natively represented by this branch' VCS.
 
354
 
        :param target: Target branch
 
355
 
        :param stop_revision: Revision to push, defaults to last revision.
 
356
 
        :return: BranchPushResult with an extra member revidmap: 
 
357
 
            A dictionary mapping revision ids from the target branch 
 
358
 
            to new revision ids in the target branch, for each 
 
359
 
            revision that was pushed.
 
361
 
        raise NotImplementedError(self.lossy_push)