66
68
ie = inv[inv.path2id(path)]
67
69
if ie.kind in ("file", "symlink"):
68
70
self._idmap.add_entry(sha, "blob", (ie.file_id, ie.revision))
71
elif ie.kind == "directory":
72
self._idmap.add_entry(sha, "tree", (path, ie.revision))
70
self._idmap.add_entry(sha, "tree", (ie.file_id, ie.revision))
74
raise AssertionError()
71
75
rev = self.repository.get_revision(revid)
72
76
commit_obj = revision_to_commit(rev, tree_sha, self._idmap._parent_lookup)
73
77
self._idmap.add_entry(commit_obj.sha().hexdigest(), "commit", (revid, tree_sha))
75
79
def _get_blob(self, fileid, revision):
80
"""Return a Git Blob object from a fileid and revision stored in bzr.
82
:param fileid: File id of the text
83
:param revision: Revision of the text
76
85
text = self.repository.texts.get_record_stream([(fileid, revision)], "unordered", True).next().get_bytes_as("fulltext")
81
def _get_tree(self, fileid, revid):
82
raise NotImplementedError(self._get_tree)
90
def _get_tree(self, path, revid, inv=None):
91
"""Return a Git Tree object from a path and a revision stored in bzr.
93
:param path: path in the tree.
94
:param revision: Revision of the tree.
97
inv = self.repository.get_inventory(revid)
99
fileid = inv.path2id(path)
100
for name, ie in inv[fileid].children.iteritems():
101
if ie.kind == "directory":
102
subtree = self._get_tree(inv.id2path(ie.file_id), revid, inv)
103
tree.add(stat.S_IFDIR, name.encode('UTF-8'), subtree.sha().hexdigest())
104
elif ie.kind == "file":
105
blob = self._get_blob(inv.path2id(ie.file_id), revid)
106
mode = stat.S_IFREG | 0644
109
tree.add(mode, name.encode('UTF-8'), blob.sha().hexdigest())
110
elif ie.kind == "symlink":
111
raise AssertionError("Symlinks not yet supported")
84
115
def _get_commit(self, revid, tree_sha):
85
116
rev = self.repository.get_revision(revid)