1
# Copyright (C) 2007 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17
"""An adapter between a Git Repository and a Bazaar Branch"""
24
from bzrlib.plugins.git.gitlib import model
27
class GitRepository(repository.Repository):
28
"""An adapter to git repositories for bzr."""
30
def __init__(self, gitdir, lockfiles):
32
self.control_files = lockfiles
33
gitdirectory = gitdir.transport.local_abspath('.')
34
self._git = model.GitModel(gitdirectory)
35
self._revision_cache = {}
37
def _ancestor_revisions(self, revision_ids):
38
if revision_ids is not None:
39
git_revisions = [gitrevid_from_bzr(r) for r in revision_ids]
42
for lines in self._git.ancestor_lines(git_revisions):
43
yield self.parse_rev(lines)
48
def get_revision_graph(self, revision_id=None):
49
if revision_id is None:
52
revisions = [revision_id]
53
return self.get_revision_graph_with_ghosts(revisions).get_ancestors()
55
def get_revision_graph_with_ghosts(self, revision_ids=None):
56
result = deprecated_graph.Graph()
57
for revision in self._ancestor_revisions(revision_ids):
58
result.add_node(revision.revision_id, revision.parent_ids)
59
self._revision_cache[revision.revision_id] = revision
62
def get_revision(self, revision_id):
63
if revision_id in self._revision_cache:
64
return self._revision_cache[revision_id]
65
raw = self._git.rev_list([gitrevid_from_bzr(revision_id)], max_count=1,
67
return self.parse_rev(raw)
69
def has_revision(self, revision_id):
71
self.get_revision(revision_id)
72
except NoSuchRevision:
77
def get_revisions(self, revisions):
78
return [self.get_revision(r) for r in revisions]
80
def parse_rev(self, raw):
81
# first field is the rev itself.
82
# then its 'field value'
88
revision_id = bzrrevid_from_git(raw[0][:-1])
90
#if field.startswith('author '):
91
# committer = field[7:]
92
if field.startswith('parent '):
93
parents.append(bzrrevid_from_git(field.split()[1]))
94
elif field.startswith('committer '):
95
commit_fields = field.split()
97
committer = ' '.join(commit_fields[1:-3])
98
timestamp = commit_fields[-2]
99
timezone = commit_fields[-1]
100
elif field.startswith('tree '):
101
tree_id = field.split()[1]
103
log.append(field[4:])
108
result = Revision(revision_id)
109
result.parent_ids = parents
111
result.inventory_sha1 = ""
112
result.timezone = timezone and int(timezone)
113
result.timestamp = float(timestamp)
114
result.committer = committer
115
result.properties['git-tree-id'] = tree_id
118
def revision_trees(self, revids):
120
yield self.revision_tree(revid)
122
def revision_tree(self, revision_id):
123
return GitRevisionTree(self, revision_id)
125
def get_inventory(self, revision_id):
126
revision = self.get_revision(revision_id)
127
inventory = GitInventory(revision_id)
128
tree_id = revision.properties['git-tree-id']
129
type_map = {'blob': 'file', 'tree': 'directory' }
130
def get_inventory(tree_id, prefix):
131
for perms, type, obj_id, name in self._git.get_inventory(tree_id):
132
full_path = prefix + name
137
executable = (perms[-3] in ('1', '3', '5', '7'))
138
entry = GitEntry(full_path, type_map[type], revision_id,
139
text_sha1, executable)
140
inventory.entries[full_path] = entry
142
get_inventory(obj_id, full_path+'/')
143
get_inventory(tree_id, '')
147
class GitRevisionTree(object):
149
def __init__(self, repository, revision_id):
150
self.repository = repository
151
self.revision_id = revision_id
152
self.inventory = repository.get_inventory(revision_id)
154
def get_file(self, file_id):
155
return iterablefile.IterableFile(self.get_file_lines(file_id))
157
def get_file_lines(self, file_id):
158
obj_id = self.inventory[file_id].text_sha1
159
return self.repository._git.cat_file('blob', obj_id)
161
def is_executable(self, file_id):
162
return self.inventory[file_id].executable
165
class GitInventory(object):
167
def __init__(self, revision_id):
169
self.root = GitEntry('', 'directory', revision_id)
170
self.entries[''] = self.root
172
def __getitem__(self, key):
173
return self.entries[key]
175
def iter_entries(self):
176
return iter(sorted(self.entries.items()))
178
def iter_entries_by_dir(self):
179
return self.iter_entries()
182
return len(self.entries)
185
class GitEntry(object):
187
def __init__(self, path, kind, revision, text_sha1=None, executable=False,
192
self.executable = executable
193
self.name = osutils.basename(path)
195
self.parent_id = None
197
self.parent_id = osutils.dirname(path)
198
self.revision = revision
199
self.symlink_target = None
200
self.text_sha1 = text_sha1
201
self.text_size = None
204
return "GitEntry(%r, %r, %r, %r)" % (self.path, self.kind,
205
self.revision, self.parent_id)
added
removed
gitlib/git_repository.py
