89
89
def record_iter_changes(self, workingtree, basis_revid, iter_changes):
91
for (file_id, path, changed_content, versioned, parent, name, kind,
92
executable) in iter_changes:
93
if kind[1] in ("directory",):
91
for change in iter_changes:
92
if change.kind[1] in ("directory",):
94
93
self._inv_delta.append(
95
(path[0], path[1], file_id, entry_factory[kind[1]](
96
file_id, name[1], parent[1])))
97
if kind[0] in ("file", "symlink"):
98
self._blobs[path[0].encode("utf-8")] = None
94
(change.path[0], change.path[1], change.file_id,
95
entry_factory[change.kind[1]](
96
change.file_id, change.name[1], change.parent_id[1])))
97
if change.kind[0] in ("file", "symlink"):
98
self._blobs[change.path[0].encode("utf-8")] = None
99
99
self._any_changes = True
100
if change.path[1] == "":
103
103
self._any_changes = True
105
self._inv_delta.append((path[0], path[1], file_id, None))
106
self._blobs[path[0].encode("utf-8")] = None
104
if change.path[1] is None:
105
self._inv_delta.append((change.path[0], change.path[1], change.file_id, None))
106
self._blobs[change.path[0].encode("utf-8")] = None
109
entry_kls = entry_factory[kind[1]]
109
entry_kls = entry_factory[change.kind[1]]
111
raise KeyError("unknown kind %s" % kind[1])
112
entry = entry_kls(file_id, name[1], parent[1])
113
if kind[1] == "file":
114
entry.executable = executable[1]
111
raise KeyError("unknown kind %s" % change.kind[1])
112
entry = entry_kls(change.file_id, change.name[1], change.parent_id[1])
113
if change.kind[1] == "file":
114
entry.executable = change.executable[1]
116
f, st = workingtree.get_file_with_stat(path[1])
116
f, st = workingtree.get_file_with_stat(change.path[1])
118
118
blob.data = f.read()
122
122
entry.text_sha1 = osutils.sha_string(blob.data)
123
123
self.store.add_object(blob)
125
elif kind[1] == "symlink":
126
symlink_target = workingtree.get_symlink_target(path[1])
125
elif change.kind[1] == "symlink":
126
symlink_target = workingtree.get_symlink_target(change.path[1])
128
128
blob.data = symlink_target.encode("utf-8")
129
129
self.store.add_object(blob)
131
131
entry.symlink_target = symlink_target
133
elif kind[1] == "tree-reference":
134
sha = read_submodule_head(workingtree.abspath(path[1]))
135
reference_revision = workingtree.get_reference_revision(path[1])
133
elif change.kind[1] == "tree-reference":
134
sha = read_submodule_head(workingtree.abspath(change.path[1]))
135
reference_revision = workingtree.get_reference_revision(change.path[1])
136
136
entry.reference_revision = reference_revision
139
raise AssertionError("Unknown kind %r" % kind[1])
140
mode = object_mode(kind[1], executable[1])
141
self._inv_delta.append((path[0], path[1], file_id, entry))
142
encoded_new_path = path[1].encode("utf-8")
139
raise AssertionError("Unknown kind %r" % change.kind[1])
140
mode = object_mode(change.kind[1], change.executable[1])
141
self._inv_delta.append((change.path[0], change.path[1], change.file_id, entry))
142
encoded_new_path = change.path[1].encode("utf-8")
143
143
self._blobs[encoded_new_path] = (mode, sha)
144
144
if st is not None:
145
yield path[1], (entry.text_sha1, st)
146
if self._mapping.generate_file_id(encoded_new_path) != file_id:
147
self._override_fileids[encoded_new_path] = file_id
149
self._override_fileids[encoded_new_path] = None
145
yield change.path[1], (entry.text_sha1, st)
146
if self._mapping.generate_file_id(encoded_new_path) != change.file_id:
147
self._override_fileids[encoded_new_path] = change.file_id
150
148
if not seen_root and len(self.parents) == 0:
151
149
raise RootMissing()
152
150
if getattr(workingtree, "basis_tree", False):
164
162
self._blobs[entry.path] = (entry.mode, entry.sha)
165
163
if not self._lossy:
167
fileid_map = dict(basis_tree._fileid_map.file_ids)
168
except AttributeError:
170
for path, file_id in viewitems(self._override_fileids):
171
if not isinstance(path, bytes):
172
raise TypeError(path)
174
if path in fileid_map:
177
if not isinstance(file_id, bytes):
178
raise TypeError(file_id)
179
fileid_map[path] = file_id
181
fileid_blob = self._mapping.export_fileid_map(fileid_map)
184
if fileid_blob is not None:
185
if self._mapping.BZR_FILE_IDS_FILE is None:
186
raise SettingCustomFileIdsUnsupported(fileid_map)
187
self.store.add_object(fileid_blob)
188
self._blobs[self._mapping.BZR_FILE_IDS_FILE] = (
189
stat.S_IFREG | 0o644, fileid_blob.id)
191
self._blobs[self._mapping.BZR_FILE_IDS_FILE] = None
164
if self._override_fileids:
165
raise SettingCustomFileIdsUnsupported(self._override_fileids)
192
166
self.new_inventory = None
194
168
def update_basis(self, tree):
262
236
return self.repository.revision_tree(self._new_revision_id)
264
238
def get_basis_delta(self):
265
# TODO(jelmer): remove this logic when lp:~jelmer/brz/remaining lands
266
for (oldpath, newpath, file_id, entry) in self._inv_delta:
267
if entry is not None:
268
entry.revision = self._new_revision_id
269
239
return self._inv_delta
271
241
def update_basis_by_delta(self, revid, delta):