/brz/remove-bazaar

# Copyright (C) 2008-2010 Jelmer Vernooij <jelmer@samba.org>

from bzrlib.testament import (

    StrictTestament3,

    )

    _tree_to_objects,

        parent_invs, lookup_object, (base_mode, mode), store_updater,

        lookup_file_id):

    if mapping.is_control_file(path):

        return []

    file_id = lookup_file_id(path)

    if ie.kind == "file":

        ie.executable = mode_is_executable(mode)

        if ie.kind == "symlink":

            ie.symlink_target = base_ie.symlink_target

    for pinv in parent_invs:

        if (pie.text_sha1 == ie.text_sha1 and

            pie.executable == ie.executable and

            pie.symlink_target == ie.symlink_target):

        parent_key = (file_id, pie.revision)

        if not parent_key in parent_keys:

            parent_keys.append(parent_key)

        texts.insert_record_stream([

            ChunkedContentFactory((file_id, ie.revision),

                tuple(parent_keys), ie.text_sha1, chunks)])

        old_path = path.decode("utf-8") # Renames are not supported yet

    new_path = path.decode("utf-8")

    invdelta.append((old_path, new_path, file_id, ie))

        store_updater.add_object(blob, ie, path)

    (base_mode, mode), store_updater, lookup_file_id):

    file_id = lookup_file_id(path)

    texts.insert_record_stream([

        ChunkedContentFactory((file_id, ie.revision), (), None, [])])

    """Generate an inventory delta for removed children.

 

    :param base_inv: Base inventory against which to generate the 

        inventory delta.

    :param path: Path to process (unicode)

    :param base_tree: Git Tree base object

    :param existing_children: Children that still exist

    :param lookup_object: Lookup a git object by its SHA1

    :return: Inventory delta, as list

    """

    assert type(path) is unicode

        file_id = base_inv.path2id(c_path)

        assert file_id is not None

        ret.append((c_path, None, file_id, None))

        lookup_object, (base_mode, mode), store_updater,

        lookup_file_id, allow_submodules=False):

    :param path: Path in the tree (str)

    :param name: Name of the tree (str)

    assert type(path) is str

    assert type(name) is str

    file_id = lookup_file_id(path)

        old_path = path.decode("utf-8") # Renames aren't supported yet

    new_path = path.decode("utf-8")

        invdelta.append((old_path, new_path, ie.file_id, ie))

        texts.insert_record_stream([

            ChunkedContentFactory((ie.file_id, ie.revision), (), None, [])])

            subinvdelta, grandchildmodes = import_git_tree(texts, mapping,

                child_path, name, (child_base_hexsha, child_hexsha), base_inv,

                file_id, revision_id, parent_invs, lookup_object, 

                (child_base_mode, child_mode), store_updater, lookup_file_id,

                allow_submodules=allow_submodules)

            subinvdelta, grandchildmodes = import_git_submodule(texts, mapping,

                child_path, name, (child_base_hexsha, child_hexsha), base_inv,

                file_id, revision_id, parent_invs, lookup_object,

                (child_base_mode, child_mode), store_updater, lookup_file_id)

            subinvdelta = import_git_blob(texts, mapping, child_path, name,

                (child_base_hexsha, child_hexsha), base_inv, file_id,

                revision_id, parent_invs, lookup_object,

                (child_base_mode, child_mode), store_updater, lookup_file_id)

        invdelta.extend(remove_disappeared_children(base_inv, old_path,

    store_updater.add_object(tree, ie, path)

def verify_commit_reconstruction(target_git_object_retriever, lookup_object,

    o, rev, ret_tree, parent_trees, mapping, unusual_modes):

    new_unusual_modes = mapping.export_unusual_file_modes(rev)

    if new_unusual_modes != unusual_modes:

        raise AssertionError("unusual modes don't match: %r != %r" % (

            unusual_modes, new_unusual_modes))

    # Verify that we can reconstruct the commit properly

    rec_o = target_git_object_retriever._reconstruct_commit(rev, o.tree, True)

    if rec_o != o:

        raise AssertionError("Reconstructed commit differs: %r != %r" % (

            rec_o, o))

    diff = []

    new_objs = {}

    for path, obj, ie in _tree_to_objects(ret_tree, parent_trees,

        target_git_object_retriever._cache.idmap, unusual_modes, mapping.BZR_DUMMY_FILE):

        old_obj_id = tree_lookup_path(lookup_object, o.tree, path)[1]

        new_objs[path] = obj

        if obj.id != old_obj_id:

            diff.append((path, lookup_object(old_obj_id), obj))

    for (path, old_obj, new_obj) in diff:

        while (old_obj.type_name == "tree" and

               new_obj.type_name == "tree" and

               sorted(old_obj) == sorted(new_obj)):

            for name in old_obj:

                if old_obj[name][0] != new_obj[name][0]:

                    raise AssertionError("Modes for %s differ: %o != %o" %

                        (path, old_obj[name][0], new_obj[name][0]))

                if old_obj[name][1] != new_obj[name][1]:

                    # Found a differing child, delve deeper

                    path = posixpath.join(path, name)

                    old_obj = lookup_object(old_obj[name][1])

                    new_obj = new_objs[path]

                    break

        raise AssertionError("objects differ for %s: %r != %r" % (path,

            old_obj, new_obj))

 

 

    rev, roundtrip_revid, verifiers = mapping.import_commit(o,

            lambda x: target_git_object_retriever.lookup_git_sha(x)[1][0])

    fileid_map = mapping.get_fileid_map(lookup_object, o.tree)

            mapping, "", "", (base_tree, o.tree), base_inv,

            fileid_map.lookup_file_id,

              inv_delta, rev.revision_id, rev.parent_ids, base_inv)

    # FIXME: Check verifiers

    testament = StrictTestament3(rev, inv)

    calculated_verifiers = { "testament3-sha1": testament.as_sha1() }

    if roundtrip_revid is not None:

        original_revid = rev.revision_id

        rev.revision_id = roundtrip_revid

        if calculated_verifiers != verifiers:

            trace.mutter("Testament SHA1 %r for %r did not match %r.",

                         calculated_verifiers["testament3-sha1"],

                         rev.revision_id, verifiers["testament3-sha1"])

            rev.revision_id = original_revid

    store_updater.add_object(o, calculated_verifiers, None)

    store_updater.finish()

    ret_tree = RevisionTree(repo, inv, rev.revision_id)

    trees_cache.add(ret_tree)

        verify_commit_reconstruction(target_git_object_retriever, 

            lookup_object, o, rev, ret_tree, parent_trees, mapping,

            unusual_modes)

            rev, roundtrip_revid, verifiers = mapping.import_commit(o,

                lambda x: None)

            if (repo.has_revision(rev.revision_id) or

                (roundtrip_revid and repo.has_revision(roundtrip_revid))):

                        target_git_object_retriever, trees_cache)

    def fetch_objects(self, determine_wants, mapping, pb=None, limit=None):

        """Fetch objects from a remote server.

 

        :param determine_wants: determine_wants callback

        :param mapping: BzrGitMapping to use

        :param pb: Optional progress bar

        :param limit: Maximum number of commits to import.

        :return: Tuple with pack hint, last imported revision id and remote refs

        """

        raise NotImplementedError(self.fetch_objects)

 

    def fetch(self, revision_id=None, pb=None, find_ghosts=False,

                ret = [self.source.lookup_bzr_revision_id(revid)[0] for revid in interesting_heads if revid not in (None, NULL_REVISION)]

            return [rev for rev in ret if not self.target.has_revision(self.source.lookup_foreign_revision_id(rev))]

        (pack_hint, _, remote_refs) = self.fetch_objects(determine_wants, mapping, pb)

        return remote_refs

class DetermineWantsRecorder(object):

 

    def __init__(self, actual):

        self.actual = actual

        self.wants = []

        self.remote_refs = {}

 

    def __call__(self, refs):

        self.remote_refs = refs

        self.wants = self.actual(refs)

        return self.wants

 

 

        """See `InterGitNonGitRepository`."""

            wants_recorder = DetermineWantsRecorder(determine_wants)

                    wants_recorder, graph_walker, store.get_raw,

                    progress)

                (pack_hint, last_rev) = import_git_objects(self.target, mapping,

                    objects_iter, store, wants_recorder.wants, pb, limit)

                return (pack_hint, last_rev, wants_recorder.remote_refs)

                not isinstance(target, GitRepository) and

                target.texts is not None)

        """See `InterGitNonGitRepository`."""

        remote_refs = self.source._git.get_refs()

        wants = determine_wants(remote_refs)

                (pack_hint, last_rev) = import_git_objects(self.target, mapping,

                return (pack_hint, last_rev, remote_refs)

                not isinstance(target, GitRepository) and

                target.texts is not None)

            refs = self.source._git.fetch(self.target._git, determine_wants,

            return (None, None, refs)

                refs = self.source.bzrdir.root_transport.fetch_pack(

                    determine_wants, graphwalker, f.write, progress)

                return (None, None, refs)

    def fetch(self, revision_id=None, pb=None, find_ghosts=False,

        self.fetch_objects(determine_wants, mapping)