##// END OF EJS Templates
histedit: access status fields by name rather than index
Martin von Zweigbergk -
r22923:9e893247 default
parent child Browse files
Show More
@@ -1,945 +1,945 b''
1 # histedit.py - interactive history editing for mercurial
1 # histedit.py - interactive history editing for mercurial
2 #
2 #
3 # Copyright 2009 Augie Fackler <raf@durin42.com>
3 # Copyright 2009 Augie Fackler <raf@durin42.com>
4 #
4 #
5 # This software may be used and distributed according to the terms of the
5 # This software may be used and distributed according to the terms of the
6 # GNU General Public License version 2 or any later version.
6 # GNU General Public License version 2 or any later version.
7 """interactive history editing
7 """interactive history editing
8
8
9 With this extension installed, Mercurial gains one new command: histedit. Usage
9 With this extension installed, Mercurial gains one new command: histedit. Usage
10 is as follows, assuming the following history::
10 is as follows, assuming the following history::
11
11
12 @ 3[tip] 7c2fd3b9020c 2009-04-27 18:04 -0500 durin42
12 @ 3[tip] 7c2fd3b9020c 2009-04-27 18:04 -0500 durin42
13 | Add delta
13 | Add delta
14 |
14 |
15 o 2 030b686bedc4 2009-04-27 18:04 -0500 durin42
15 o 2 030b686bedc4 2009-04-27 18:04 -0500 durin42
16 | Add gamma
16 | Add gamma
17 |
17 |
18 o 1 c561b4e977df 2009-04-27 18:04 -0500 durin42
18 o 1 c561b4e977df 2009-04-27 18:04 -0500 durin42
19 | Add beta
19 | Add beta
20 |
20 |
21 o 0 d8d2fcd0e319 2009-04-27 18:04 -0500 durin42
21 o 0 d8d2fcd0e319 2009-04-27 18:04 -0500 durin42
22 Add alpha
22 Add alpha
23
23
24 If you were to run ``hg histedit c561b4e977df``, you would see the following
24 If you were to run ``hg histedit c561b4e977df``, you would see the following
25 file open in your editor::
25 file open in your editor::
26
26
27 pick c561b4e977df Add beta
27 pick c561b4e977df Add beta
28 pick 030b686bedc4 Add gamma
28 pick 030b686bedc4 Add gamma
29 pick 7c2fd3b9020c Add delta
29 pick 7c2fd3b9020c Add delta
30
30
31 # Edit history between c561b4e977df and 7c2fd3b9020c
31 # Edit history between c561b4e977df and 7c2fd3b9020c
32 #
32 #
33 # Commits are listed from least to most recent
33 # Commits are listed from least to most recent
34 #
34 #
35 # Commands:
35 # Commands:
36 # p, pick = use commit
36 # p, pick = use commit
37 # e, edit = use commit, but stop for amending
37 # e, edit = use commit, but stop for amending
38 # f, fold = use commit, but combine it with the one above
38 # f, fold = use commit, but combine it with the one above
39 # r, roll = like fold, but discard this commit's description
39 # r, roll = like fold, but discard this commit's description
40 # d, drop = remove commit from history
40 # d, drop = remove commit from history
41 # m, mess = edit message without changing commit content
41 # m, mess = edit message without changing commit content
42 #
42 #
43
43
44 In this file, lines beginning with ``#`` are ignored. You must specify a rule
44 In this file, lines beginning with ``#`` are ignored. You must specify a rule
45 for each revision in your history. For example, if you had meant to add gamma
45 for each revision in your history. For example, if you had meant to add gamma
46 before beta, and then wanted to add delta in the same revision as beta, you
46 before beta, and then wanted to add delta in the same revision as beta, you
47 would reorganize the file to look like this::
47 would reorganize the file to look like this::
48
48
49 pick 030b686bedc4 Add gamma
49 pick 030b686bedc4 Add gamma
50 pick c561b4e977df Add beta
50 pick c561b4e977df Add beta
51 fold 7c2fd3b9020c Add delta
51 fold 7c2fd3b9020c Add delta
52
52
53 # Edit history between c561b4e977df and 7c2fd3b9020c
53 # Edit history between c561b4e977df and 7c2fd3b9020c
54 #
54 #
55 # Commits are listed from least to most recent
55 # Commits are listed from least to most recent
56 #
56 #
57 # Commands:
57 # Commands:
58 # p, pick = use commit
58 # p, pick = use commit
59 # e, edit = use commit, but stop for amending
59 # e, edit = use commit, but stop for amending
60 # f, fold = use commit, but combine it with the one above
60 # f, fold = use commit, but combine it with the one above
61 # r, roll = like fold, but discard this commit's description
61 # r, roll = like fold, but discard this commit's description
62 # d, drop = remove commit from history
62 # d, drop = remove commit from history
63 # m, mess = edit message without changing commit content
63 # m, mess = edit message without changing commit content
64 #
64 #
65
65
66 At which point you close the editor and ``histedit`` starts working. When you
66 At which point you close the editor and ``histedit`` starts working. When you
67 specify a ``fold`` operation, ``histedit`` will open an editor when it folds
67 specify a ``fold`` operation, ``histedit`` will open an editor when it folds
68 those revisions together, offering you a chance to clean up the commit message::
68 those revisions together, offering you a chance to clean up the commit message::
69
69
70 Add beta
70 Add beta
71 ***
71 ***
72 Add delta
72 Add delta
73
73
74 Edit the commit message to your liking, then close the editor. For
74 Edit the commit message to your liking, then close the editor. For
75 this example, let's assume that the commit message was changed to
75 this example, let's assume that the commit message was changed to
76 ``Add beta and delta.`` After histedit has run and had a chance to
76 ``Add beta and delta.`` After histedit has run and had a chance to
77 remove any old or temporary revisions it needed, the history looks
77 remove any old or temporary revisions it needed, the history looks
78 like this::
78 like this::
79
79
80 @ 2[tip] 989b4d060121 2009-04-27 18:04 -0500 durin42
80 @ 2[tip] 989b4d060121 2009-04-27 18:04 -0500 durin42
81 | Add beta and delta.
81 | Add beta and delta.
82 |
82 |
83 o 1 081603921c3f 2009-04-27 18:04 -0500 durin42
83 o 1 081603921c3f 2009-04-27 18:04 -0500 durin42
84 | Add gamma
84 | Add gamma
85 |
85 |
86 o 0 d8d2fcd0e319 2009-04-27 18:04 -0500 durin42
86 o 0 d8d2fcd0e319 2009-04-27 18:04 -0500 durin42
87 Add alpha
87 Add alpha
88
88
89 Note that ``histedit`` does *not* remove any revisions (even its own temporary
89 Note that ``histedit`` does *not* remove any revisions (even its own temporary
90 ones) until after it has completed all the editing operations, so it will
90 ones) until after it has completed all the editing operations, so it will
91 probably perform several strip operations when it's done. For the above example,
91 probably perform several strip operations when it's done. For the above example,
92 it had to run strip twice. Strip can be slow depending on a variety of factors,
92 it had to run strip twice. Strip can be slow depending on a variety of factors,
93 so you might need to be a little patient. You can choose to keep the original
93 so you might need to be a little patient. You can choose to keep the original
94 revisions by passing the ``--keep`` flag.
94 revisions by passing the ``--keep`` flag.
95
95
96 The ``edit`` operation will drop you back to a command prompt,
96 The ``edit`` operation will drop you back to a command prompt,
97 allowing you to edit files freely, or even use ``hg record`` to commit
97 allowing you to edit files freely, or even use ``hg record`` to commit
98 some changes as a separate commit. When you're done, any remaining
98 some changes as a separate commit. When you're done, any remaining
99 uncommitted changes will be committed as well. When done, run ``hg
99 uncommitted changes will be committed as well. When done, run ``hg
100 histedit --continue`` to finish this step. You'll be prompted for a
100 histedit --continue`` to finish this step. You'll be prompted for a
101 new commit message, but the default commit message will be the
101 new commit message, but the default commit message will be the
102 original message for the ``edit`` ed revision.
102 original message for the ``edit`` ed revision.
103
103
104 The ``message`` operation will give you a chance to revise a commit
104 The ``message`` operation will give you a chance to revise a commit
105 message without changing the contents. It's a shortcut for doing
105 message without changing the contents. It's a shortcut for doing
106 ``edit`` immediately followed by `hg histedit --continue``.
106 ``edit`` immediately followed by `hg histedit --continue``.
107
107
108 If ``histedit`` encounters a conflict when moving a revision (while
108 If ``histedit`` encounters a conflict when moving a revision (while
109 handling ``pick`` or ``fold``), it'll stop in a similar manner to
109 handling ``pick`` or ``fold``), it'll stop in a similar manner to
110 ``edit`` with the difference that it won't prompt you for a commit
110 ``edit`` with the difference that it won't prompt you for a commit
111 message when done. If you decide at this point that you don't like how
111 message when done. If you decide at this point that you don't like how
112 much work it will be to rearrange history, or that you made a mistake,
112 much work it will be to rearrange history, or that you made a mistake,
113 you can use ``hg histedit --abort`` to abandon the new changes you
113 you can use ``hg histedit --abort`` to abandon the new changes you
114 have made and return to the state before you attempted to edit your
114 have made and return to the state before you attempted to edit your
115 history.
115 history.
116
116
117 If we clone the histedit-ed example repository above and add four more
117 If we clone the histedit-ed example repository above and add four more
118 changes, such that we have the following history::
118 changes, such that we have the following history::
119
119
120 @ 6[tip] 038383181893 2009-04-27 18:04 -0500 stefan
120 @ 6[tip] 038383181893 2009-04-27 18:04 -0500 stefan
121 | Add theta
121 | Add theta
122 |
122 |
123 o 5 140988835471 2009-04-27 18:04 -0500 stefan
123 o 5 140988835471 2009-04-27 18:04 -0500 stefan
124 | Add eta
124 | Add eta
125 |
125 |
126 o 4 122930637314 2009-04-27 18:04 -0500 stefan
126 o 4 122930637314 2009-04-27 18:04 -0500 stefan
127 | Add zeta
127 | Add zeta
128 |
128 |
129 o 3 836302820282 2009-04-27 18:04 -0500 stefan
129 o 3 836302820282 2009-04-27 18:04 -0500 stefan
130 | Add epsilon
130 | Add epsilon
131 |
131 |
132 o 2 989b4d060121 2009-04-27 18:04 -0500 durin42
132 o 2 989b4d060121 2009-04-27 18:04 -0500 durin42
133 | Add beta and delta.
133 | Add beta and delta.
134 |
134 |
135 o 1 081603921c3f 2009-04-27 18:04 -0500 durin42
135 o 1 081603921c3f 2009-04-27 18:04 -0500 durin42
136 | Add gamma
136 | Add gamma
137 |
137 |
138 o 0 d8d2fcd0e319 2009-04-27 18:04 -0500 durin42
138 o 0 d8d2fcd0e319 2009-04-27 18:04 -0500 durin42
139 Add alpha
139 Add alpha
140
140
141 If you run ``hg histedit --outgoing`` on the clone then it is the same
141 If you run ``hg histedit --outgoing`` on the clone then it is the same
142 as running ``hg histedit 836302820282``. If you need plan to push to a
142 as running ``hg histedit 836302820282``. If you need plan to push to a
143 repository that Mercurial does not detect to be related to the source
143 repository that Mercurial does not detect to be related to the source
144 repo, you can add a ``--force`` option.
144 repo, you can add a ``--force`` option.
145 """
145 """
146
146
147 try:
147 try:
148 import cPickle as pickle
148 import cPickle as pickle
149 pickle.dump # import now
149 pickle.dump # import now
150 except ImportError:
150 except ImportError:
151 import pickle
151 import pickle
152 import errno
152 import errno
153 import os
153 import os
154 import sys
154 import sys
155
155
156 from mercurial import cmdutil
156 from mercurial import cmdutil
157 from mercurial import discovery
157 from mercurial import discovery
158 from mercurial import error
158 from mercurial import error
159 from mercurial import copies
159 from mercurial import copies
160 from mercurial import context
160 from mercurial import context
161 from mercurial import hg
161 from mercurial import hg
162 from mercurial import node
162 from mercurial import node
163 from mercurial import repair
163 from mercurial import repair
164 from mercurial import scmutil
164 from mercurial import scmutil
165 from mercurial import util
165 from mercurial import util
166 from mercurial import obsolete
166 from mercurial import obsolete
167 from mercurial import merge as mergemod
167 from mercurial import merge as mergemod
168 from mercurial.lock import release
168 from mercurial.lock import release
169 from mercurial.i18n import _
169 from mercurial.i18n import _
170
170
171 cmdtable = {}
171 cmdtable = {}
172 command = cmdutil.command(cmdtable)
172 command = cmdutil.command(cmdtable)
173
173
174 testedwith = 'internal'
174 testedwith = 'internal'
175
175
176 # i18n: command names and abbreviations must remain untranslated
176 # i18n: command names and abbreviations must remain untranslated
177 editcomment = _("""# Edit history between %s and %s
177 editcomment = _("""# Edit history between %s and %s
178 #
178 #
179 # Commits are listed from least to most recent
179 # Commits are listed from least to most recent
180 #
180 #
181 # Commands:
181 # Commands:
182 # p, pick = use commit
182 # p, pick = use commit
183 # e, edit = use commit, but stop for amending
183 # e, edit = use commit, but stop for amending
184 # f, fold = use commit, but combine it with the one above
184 # f, fold = use commit, but combine it with the one above
185 # r, roll = like fold, but discard this commit's description
185 # r, roll = like fold, but discard this commit's description
186 # d, drop = remove commit from history
186 # d, drop = remove commit from history
187 # m, mess = edit message without changing commit content
187 # m, mess = edit message without changing commit content
188 #
188 #
189 """)
189 """)
190
190
191 def commitfuncfor(repo, src):
191 def commitfuncfor(repo, src):
192 """Build a commit function for the replacement of <src>
192 """Build a commit function for the replacement of <src>
193
193
194 This function ensure we apply the same treatment to all changesets.
194 This function ensure we apply the same treatment to all changesets.
195
195
196 - Add a 'histedit_source' entry in extra.
196 - Add a 'histedit_source' entry in extra.
197
197
198 Note that fold have its own separated logic because its handling is a bit
198 Note that fold have its own separated logic because its handling is a bit
199 different and not easily factored out of the fold method.
199 different and not easily factored out of the fold method.
200 """
200 """
201 phasemin = src.phase()
201 phasemin = src.phase()
202 def commitfunc(**kwargs):
202 def commitfunc(**kwargs):
203 phasebackup = repo.ui.backupconfig('phases', 'new-commit')
203 phasebackup = repo.ui.backupconfig('phases', 'new-commit')
204 try:
204 try:
205 repo.ui.setconfig('phases', 'new-commit', phasemin,
205 repo.ui.setconfig('phases', 'new-commit', phasemin,
206 'histedit')
206 'histedit')
207 extra = kwargs.get('extra', {}).copy()
207 extra = kwargs.get('extra', {}).copy()
208 extra['histedit_source'] = src.hex()
208 extra['histedit_source'] = src.hex()
209 kwargs['extra'] = extra
209 kwargs['extra'] = extra
210 return repo.commit(**kwargs)
210 return repo.commit(**kwargs)
211 finally:
211 finally:
212 repo.ui.restoreconfig(phasebackup)
212 repo.ui.restoreconfig(phasebackup)
213 return commitfunc
213 return commitfunc
214
214
215 def applychanges(ui, repo, ctx, opts):
215 def applychanges(ui, repo, ctx, opts):
216 """Merge changeset from ctx (only) in the current working directory"""
216 """Merge changeset from ctx (only) in the current working directory"""
217 wcpar = repo.dirstate.parents()[0]
217 wcpar = repo.dirstate.parents()[0]
218 if ctx.p1().node() == wcpar:
218 if ctx.p1().node() == wcpar:
219 # edition ar "in place" we do not need to make any merge,
219 # edition ar "in place" we do not need to make any merge,
220 # just applies changes on parent for edition
220 # just applies changes on parent for edition
221 cmdutil.revert(ui, repo, ctx, (wcpar, node.nullid), all=True)
221 cmdutil.revert(ui, repo, ctx, (wcpar, node.nullid), all=True)
222 stats = None
222 stats = None
223 else:
223 else:
224 try:
224 try:
225 # ui.forcemerge is an internal variable, do not document
225 # ui.forcemerge is an internal variable, do not document
226 repo.ui.setconfig('ui', 'forcemerge', opts.get('tool', ''),
226 repo.ui.setconfig('ui', 'forcemerge', opts.get('tool', ''),
227 'histedit')
227 'histedit')
228 stats = mergemod.graft(repo, ctx, ctx.p1(), ['local', 'histedit'])
228 stats = mergemod.graft(repo, ctx, ctx.p1(), ['local', 'histedit'])
229 finally:
229 finally:
230 repo.ui.setconfig('ui', 'forcemerge', '', 'histedit')
230 repo.ui.setconfig('ui', 'forcemerge', '', 'histedit')
231 return stats
231 return stats
232
232
233 def collapse(repo, first, last, commitopts):
233 def collapse(repo, first, last, commitopts):
234 """collapse the set of revisions from first to last as new one.
234 """collapse the set of revisions from first to last as new one.
235
235
236 Expected commit options are:
236 Expected commit options are:
237 - message
237 - message
238 - date
238 - date
239 - username
239 - username
240 Commit message is edited in all cases.
240 Commit message is edited in all cases.
241
241
242 This function works in memory."""
242 This function works in memory."""
243 ctxs = list(repo.set('%d::%d', first, last))
243 ctxs = list(repo.set('%d::%d', first, last))
244 if not ctxs:
244 if not ctxs:
245 return None
245 return None
246 base = first.parents()[0]
246 base = first.parents()[0]
247
247
248 # commit a new version of the old changeset, including the update
248 # commit a new version of the old changeset, including the update
249 # collect all files which might be affected
249 # collect all files which might be affected
250 files = set()
250 files = set()
251 for ctx in ctxs:
251 for ctx in ctxs:
252 files.update(ctx.files())
252 files.update(ctx.files())
253
253
254 # Recompute copies (avoid recording a -> b -> a)
254 # Recompute copies (avoid recording a -> b -> a)
255 copied = copies.pathcopies(base, last)
255 copied = copies.pathcopies(base, last)
256
256
257 # prune files which were reverted by the updates
257 # prune files which were reverted by the updates
258 def samefile(f):
258 def samefile(f):
259 if f in last.manifest():
259 if f in last.manifest():
260 a = last.filectx(f)
260 a = last.filectx(f)
261 if f in base.manifest():
261 if f in base.manifest():
262 b = base.filectx(f)
262 b = base.filectx(f)
263 return (a.data() == b.data()
263 return (a.data() == b.data()
264 and a.flags() == b.flags())
264 and a.flags() == b.flags())
265 else:
265 else:
266 return False
266 return False
267 else:
267 else:
268 return f not in base.manifest()
268 return f not in base.manifest()
269 files = [f for f in files if not samefile(f)]
269 files = [f for f in files if not samefile(f)]
270 # commit version of these files as defined by head
270 # commit version of these files as defined by head
271 headmf = last.manifest()
271 headmf = last.manifest()
272 def filectxfn(repo, ctx, path):
272 def filectxfn(repo, ctx, path):
273 if path in headmf:
273 if path in headmf:
274 fctx = last[path]
274 fctx = last[path]
275 flags = fctx.flags()
275 flags = fctx.flags()
276 mctx = context.memfilectx(repo,
276 mctx = context.memfilectx(repo,
277 fctx.path(), fctx.data(),
277 fctx.path(), fctx.data(),
278 islink='l' in flags,
278 islink='l' in flags,
279 isexec='x' in flags,
279 isexec='x' in flags,
280 copied=copied.get(path))
280 copied=copied.get(path))
281 return mctx
281 return mctx
282 return None
282 return None
283
283
284 if commitopts.get('message'):
284 if commitopts.get('message'):
285 message = commitopts['message']
285 message = commitopts['message']
286 else:
286 else:
287 message = first.description()
287 message = first.description()
288 user = commitopts.get('user')
288 user = commitopts.get('user')
289 date = commitopts.get('date')
289 date = commitopts.get('date')
290 extra = commitopts.get('extra')
290 extra = commitopts.get('extra')
291
291
292 parents = (first.p1().node(), first.p2().node())
292 parents = (first.p1().node(), first.p2().node())
293 editor = None
293 editor = None
294 if not commitopts.get('rollup'):
294 if not commitopts.get('rollup'):
295 editor = cmdutil.getcommiteditor(edit=True, editform='histedit.fold')
295 editor = cmdutil.getcommiteditor(edit=True, editform='histedit.fold')
296 new = context.memctx(repo,
296 new = context.memctx(repo,
297 parents=parents,
297 parents=parents,
298 text=message,
298 text=message,
299 files=files,
299 files=files,
300 filectxfn=filectxfn,
300 filectxfn=filectxfn,
301 user=user,
301 user=user,
302 date=date,
302 date=date,
303 extra=extra,
303 extra=extra,
304 editor=editor)
304 editor=editor)
305 return repo.commitctx(new)
305 return repo.commitctx(new)
306
306
307 def pick(ui, repo, ctx, ha, opts):
307 def pick(ui, repo, ctx, ha, opts):
308 oldctx = repo[ha]
308 oldctx = repo[ha]
309 if oldctx.parents()[0] == ctx:
309 if oldctx.parents()[0] == ctx:
310 ui.debug('node %s unchanged\n' % ha)
310 ui.debug('node %s unchanged\n' % ha)
311 return oldctx, []
311 return oldctx, []
312 hg.update(repo, ctx.node())
312 hg.update(repo, ctx.node())
313 stats = applychanges(ui, repo, oldctx, opts)
313 stats = applychanges(ui, repo, oldctx, opts)
314 if stats and stats[3] > 0:
314 if stats and stats[3] > 0:
315 raise error.InterventionRequired(_('Fix up the change and run '
315 raise error.InterventionRequired(_('Fix up the change and run '
316 'hg histedit --continue'))
316 'hg histedit --continue'))
317 # drop the second merge parent
317 # drop the second merge parent
318 commit = commitfuncfor(repo, oldctx)
318 commit = commitfuncfor(repo, oldctx)
319 n = commit(text=oldctx.description(), user=oldctx.user(),
319 n = commit(text=oldctx.description(), user=oldctx.user(),
320 date=oldctx.date(), extra=oldctx.extra())
320 date=oldctx.date(), extra=oldctx.extra())
321 if n is None:
321 if n is None:
322 ui.warn(_('%s: empty changeset\n')
322 ui.warn(_('%s: empty changeset\n')
323 % node.hex(ha))
323 % node.hex(ha))
324 return ctx, []
324 return ctx, []
325 new = repo[n]
325 new = repo[n]
326 return new, [(oldctx.node(), (n,))]
326 return new, [(oldctx.node(), (n,))]
327
327
328
328
329 def edit(ui, repo, ctx, ha, opts):
329 def edit(ui, repo, ctx, ha, opts):
330 oldctx = repo[ha]
330 oldctx = repo[ha]
331 hg.update(repo, ctx.node())
331 hg.update(repo, ctx.node())
332 applychanges(ui, repo, oldctx, opts)
332 applychanges(ui, repo, oldctx, opts)
333 raise error.InterventionRequired(
333 raise error.InterventionRequired(
334 _('Make changes as needed, you may commit or record as needed now.\n'
334 _('Make changes as needed, you may commit or record as needed now.\n'
335 'When you are finished, run hg histedit --continue to resume.'))
335 'When you are finished, run hg histedit --continue to resume.'))
336
336
337 def rollup(ui, repo, ctx, ha, opts):
337 def rollup(ui, repo, ctx, ha, opts):
338 rollupopts = opts.copy()
338 rollupopts = opts.copy()
339 rollupopts['rollup'] = True
339 rollupopts['rollup'] = True
340 return fold(ui, repo, ctx, ha, rollupopts)
340 return fold(ui, repo, ctx, ha, rollupopts)
341
341
342 def fold(ui, repo, ctx, ha, opts):
342 def fold(ui, repo, ctx, ha, opts):
343 oldctx = repo[ha]
343 oldctx = repo[ha]
344 hg.update(repo, ctx.node())
344 hg.update(repo, ctx.node())
345 stats = applychanges(ui, repo, oldctx, opts)
345 stats = applychanges(ui, repo, oldctx, opts)
346 if stats and stats[3] > 0:
346 if stats and stats[3] > 0:
347 raise error.InterventionRequired(
347 raise error.InterventionRequired(
348 _('Fix up the change and run hg histedit --continue'))
348 _('Fix up the change and run hg histedit --continue'))
349 n = repo.commit(text='fold-temp-revision %s' % ha, user=oldctx.user(),
349 n = repo.commit(text='fold-temp-revision %s' % ha, user=oldctx.user(),
350 date=oldctx.date(), extra=oldctx.extra())
350 date=oldctx.date(), extra=oldctx.extra())
351 if n is None:
351 if n is None:
352 ui.warn(_('%s: empty changeset')
352 ui.warn(_('%s: empty changeset')
353 % node.hex(ha))
353 % node.hex(ha))
354 return ctx, []
354 return ctx, []
355 return finishfold(ui, repo, ctx, oldctx, n, opts, [])
355 return finishfold(ui, repo, ctx, oldctx, n, opts, [])
356
356
357 def finishfold(ui, repo, ctx, oldctx, newnode, opts, internalchanges):
357 def finishfold(ui, repo, ctx, oldctx, newnode, opts, internalchanges):
358 parent = ctx.parents()[0].node()
358 parent = ctx.parents()[0].node()
359 hg.update(repo, parent)
359 hg.update(repo, parent)
360 ### prepare new commit data
360 ### prepare new commit data
361 commitopts = opts.copy()
361 commitopts = opts.copy()
362 commitopts['user'] = ctx.user()
362 commitopts['user'] = ctx.user()
363 # commit message
363 # commit message
364 if opts.get('rollup'):
364 if opts.get('rollup'):
365 newmessage = ctx.description()
365 newmessage = ctx.description()
366 else:
366 else:
367 newmessage = '\n***\n'.join(
367 newmessage = '\n***\n'.join(
368 [ctx.description()] +
368 [ctx.description()] +
369 [repo[r].description() for r in internalchanges] +
369 [repo[r].description() for r in internalchanges] +
370 [oldctx.description()]) + '\n'
370 [oldctx.description()]) + '\n'
371 commitopts['message'] = newmessage
371 commitopts['message'] = newmessage
372 # date
372 # date
373 commitopts['date'] = max(ctx.date(), oldctx.date())
373 commitopts['date'] = max(ctx.date(), oldctx.date())
374 extra = ctx.extra().copy()
374 extra = ctx.extra().copy()
375 # histedit_source
375 # histedit_source
376 # note: ctx is likely a temporary commit but that the best we can do here
376 # note: ctx is likely a temporary commit but that the best we can do here
377 # This is sufficient to solve issue3681 anyway
377 # This is sufficient to solve issue3681 anyway
378 extra['histedit_source'] = '%s,%s' % (ctx.hex(), oldctx.hex())
378 extra['histedit_source'] = '%s,%s' % (ctx.hex(), oldctx.hex())
379 commitopts['extra'] = extra
379 commitopts['extra'] = extra
380 phasebackup = repo.ui.backupconfig('phases', 'new-commit')
380 phasebackup = repo.ui.backupconfig('phases', 'new-commit')
381 try:
381 try:
382 phasemin = max(ctx.phase(), oldctx.phase())
382 phasemin = max(ctx.phase(), oldctx.phase())
383 repo.ui.setconfig('phases', 'new-commit', phasemin, 'histedit')
383 repo.ui.setconfig('phases', 'new-commit', phasemin, 'histedit')
384 n = collapse(repo, ctx, repo[newnode], commitopts)
384 n = collapse(repo, ctx, repo[newnode], commitopts)
385 finally:
385 finally:
386 repo.ui.restoreconfig(phasebackup)
386 repo.ui.restoreconfig(phasebackup)
387 if n is None:
387 if n is None:
388 return ctx, []
388 return ctx, []
389 hg.update(repo, n)
389 hg.update(repo, n)
390 replacements = [(oldctx.node(), (newnode,)),
390 replacements = [(oldctx.node(), (newnode,)),
391 (ctx.node(), (n,)),
391 (ctx.node(), (n,)),
392 (newnode, (n,)),
392 (newnode, (n,)),
393 ]
393 ]
394 for ich in internalchanges:
394 for ich in internalchanges:
395 replacements.append((ich, (n,)))
395 replacements.append((ich, (n,)))
396 return repo[n], replacements
396 return repo[n], replacements
397
397
398 def drop(ui, repo, ctx, ha, opts):
398 def drop(ui, repo, ctx, ha, opts):
399 return ctx, [(repo[ha].node(), ())]
399 return ctx, [(repo[ha].node(), ())]
400
400
401
401
402 def message(ui, repo, ctx, ha, opts):
402 def message(ui, repo, ctx, ha, opts):
403 oldctx = repo[ha]
403 oldctx = repo[ha]
404 hg.update(repo, ctx.node())
404 hg.update(repo, ctx.node())
405 stats = applychanges(ui, repo, oldctx, opts)
405 stats = applychanges(ui, repo, oldctx, opts)
406 if stats and stats[3] > 0:
406 if stats and stats[3] > 0:
407 raise error.InterventionRequired(
407 raise error.InterventionRequired(
408 _('Fix up the change and run hg histedit --continue'))
408 _('Fix up the change and run hg histedit --continue'))
409 message = oldctx.description()
409 message = oldctx.description()
410 commit = commitfuncfor(repo, oldctx)
410 commit = commitfuncfor(repo, oldctx)
411 editor = cmdutil.getcommiteditor(edit=True, editform='histedit.mess')
411 editor = cmdutil.getcommiteditor(edit=True, editform='histedit.mess')
412 new = commit(text=message, user=oldctx.user(), date=oldctx.date(),
412 new = commit(text=message, user=oldctx.user(), date=oldctx.date(),
413 extra=oldctx.extra(),
413 extra=oldctx.extra(),
414 editor=editor)
414 editor=editor)
415 newctx = repo[new]
415 newctx = repo[new]
416 if oldctx.node() != newctx.node():
416 if oldctx.node() != newctx.node():
417 return newctx, [(oldctx.node(), (new,))]
417 return newctx, [(oldctx.node(), (new,))]
418 # We didn't make an edit, so just indicate no replaced nodes
418 # We didn't make an edit, so just indicate no replaced nodes
419 return newctx, []
419 return newctx, []
420
420
421 def findoutgoing(ui, repo, remote=None, force=False, opts={}):
421 def findoutgoing(ui, repo, remote=None, force=False, opts={}):
422 """utility function to find the first outgoing changeset
422 """utility function to find the first outgoing changeset
423
423
424 Used by initialisation code"""
424 Used by initialisation code"""
425 dest = ui.expandpath(remote or 'default-push', remote or 'default')
425 dest = ui.expandpath(remote or 'default-push', remote or 'default')
426 dest, revs = hg.parseurl(dest, None)[:2]
426 dest, revs = hg.parseurl(dest, None)[:2]
427 ui.status(_('comparing with %s\n') % util.hidepassword(dest))
427 ui.status(_('comparing with %s\n') % util.hidepassword(dest))
428
428
429 revs, checkout = hg.addbranchrevs(repo, repo, revs, None)
429 revs, checkout = hg.addbranchrevs(repo, repo, revs, None)
430 other = hg.peer(repo, opts, dest)
430 other = hg.peer(repo, opts, dest)
431
431
432 if revs:
432 if revs:
433 revs = [repo.lookup(rev) for rev in revs]
433 revs = [repo.lookup(rev) for rev in revs]
434
434
435 outgoing = discovery.findcommonoutgoing(repo, other, revs, force=force)
435 outgoing = discovery.findcommonoutgoing(repo, other, revs, force=force)
436 if not outgoing.missing:
436 if not outgoing.missing:
437 raise util.Abort(_('no outgoing ancestors'))
437 raise util.Abort(_('no outgoing ancestors'))
438 roots = list(repo.revs("roots(%ln)", outgoing.missing))
438 roots = list(repo.revs("roots(%ln)", outgoing.missing))
439 if 1 < len(roots):
439 if 1 < len(roots):
440 msg = _('there are ambiguous outgoing revisions')
440 msg = _('there are ambiguous outgoing revisions')
441 hint = _('see "hg help histedit" for more detail')
441 hint = _('see "hg help histedit" for more detail')
442 raise util.Abort(msg, hint=hint)
442 raise util.Abort(msg, hint=hint)
443 return repo.lookup(roots[0])
443 return repo.lookup(roots[0])
444
444
445 actiontable = {'p': pick,
445 actiontable = {'p': pick,
446 'pick': pick,
446 'pick': pick,
447 'e': edit,
447 'e': edit,
448 'edit': edit,
448 'edit': edit,
449 'f': fold,
449 'f': fold,
450 'fold': fold,
450 'fold': fold,
451 'r': rollup,
451 'r': rollup,
452 'roll': rollup,
452 'roll': rollup,
453 'd': drop,
453 'd': drop,
454 'drop': drop,
454 'drop': drop,
455 'm': message,
455 'm': message,
456 'mess': message,
456 'mess': message,
457 }
457 }
458
458
459 @command('histedit',
459 @command('histedit',
460 [('', 'commands', '',
460 [('', 'commands', '',
461 _('Read history edits from the specified file.')),
461 _('Read history edits from the specified file.')),
462 ('c', 'continue', False, _('continue an edit already in progress')),
462 ('c', 'continue', False, _('continue an edit already in progress')),
463 ('k', 'keep', False,
463 ('k', 'keep', False,
464 _("don't strip old nodes after edit is complete")),
464 _("don't strip old nodes after edit is complete")),
465 ('', 'abort', False, _('abort an edit in progress')),
465 ('', 'abort', False, _('abort an edit in progress')),
466 ('o', 'outgoing', False, _('changesets not found in destination')),
466 ('o', 'outgoing', False, _('changesets not found in destination')),
467 ('f', 'force', False,
467 ('f', 'force', False,
468 _('force outgoing even for unrelated repositories')),
468 _('force outgoing even for unrelated repositories')),
469 ('r', 'rev', [], _('first revision to be edited'))],
469 ('r', 'rev', [], _('first revision to be edited'))],
470 _("ANCESTOR | --outgoing [URL]"))
470 _("ANCESTOR | --outgoing [URL]"))
471 def histedit(ui, repo, *freeargs, **opts):
471 def histedit(ui, repo, *freeargs, **opts):
472 """interactively edit changeset history
472 """interactively edit changeset history
473
473
474 This command edits changesets between ANCESTOR and the parent of
474 This command edits changesets between ANCESTOR and the parent of
475 the working directory.
475 the working directory.
476
476
477 With --outgoing, this edits changesets not found in the
477 With --outgoing, this edits changesets not found in the
478 destination repository. If URL of the destination is omitted, the
478 destination repository. If URL of the destination is omitted, the
479 'default-push' (or 'default') path will be used.
479 'default-push' (or 'default') path will be used.
480
480
481 For safety, this command is aborted, also if there are ambiguous
481 For safety, this command is aborted, also if there are ambiguous
482 outgoing revisions which may confuse users: for example, there are
482 outgoing revisions which may confuse users: for example, there are
483 multiple branches containing outgoing revisions.
483 multiple branches containing outgoing revisions.
484
484
485 Use "min(outgoing() and ::.)" or similar revset specification
485 Use "min(outgoing() and ::.)" or similar revset specification
486 instead of --outgoing to specify edit target revision exactly in
486 instead of --outgoing to specify edit target revision exactly in
487 such ambiguous situation. See :hg:`help revsets` for detail about
487 such ambiguous situation. See :hg:`help revsets` for detail about
488 selecting revisions.
488 selecting revisions.
489
489
490 Returns 0 on success, 1 if user intervention is required (not only
490 Returns 0 on success, 1 if user intervention is required (not only
491 for intentional "edit" command, but also for resolving unexpected
491 for intentional "edit" command, but also for resolving unexpected
492 conflicts).
492 conflicts).
493 """
493 """
494 lock = wlock = None
494 lock = wlock = None
495 try:
495 try:
496 wlock = repo.wlock()
496 wlock = repo.wlock()
497 lock = repo.lock()
497 lock = repo.lock()
498 _histedit(ui, repo, *freeargs, **opts)
498 _histedit(ui, repo, *freeargs, **opts)
499 finally:
499 finally:
500 release(lock, wlock)
500 release(lock, wlock)
501
501
502 def _histedit(ui, repo, *freeargs, **opts):
502 def _histedit(ui, repo, *freeargs, **opts):
503 # TODO only abort if we try and histedit mq patches, not just
503 # TODO only abort if we try and histedit mq patches, not just
504 # blanket if mq patches are applied somewhere
504 # blanket if mq patches are applied somewhere
505 mq = getattr(repo, 'mq', None)
505 mq = getattr(repo, 'mq', None)
506 if mq and mq.applied:
506 if mq and mq.applied:
507 raise util.Abort(_('source has mq patches applied'))
507 raise util.Abort(_('source has mq patches applied'))
508
508
509 # basic argument incompatibility processing
509 # basic argument incompatibility processing
510 outg = opts.get('outgoing')
510 outg = opts.get('outgoing')
511 cont = opts.get('continue')
511 cont = opts.get('continue')
512 abort = opts.get('abort')
512 abort = opts.get('abort')
513 force = opts.get('force')
513 force = opts.get('force')
514 rules = opts.get('commands', '')
514 rules = opts.get('commands', '')
515 revs = opts.get('rev', [])
515 revs = opts.get('rev', [])
516 goal = 'new' # This invocation goal, in new, continue, abort
516 goal = 'new' # This invocation goal, in new, continue, abort
517 if force and not outg:
517 if force and not outg:
518 raise util.Abort(_('--force only allowed with --outgoing'))
518 raise util.Abort(_('--force only allowed with --outgoing'))
519 if cont:
519 if cont:
520 if util.any((outg, abort, revs, freeargs, rules)):
520 if util.any((outg, abort, revs, freeargs, rules)):
521 raise util.Abort(_('no arguments allowed with --continue'))
521 raise util.Abort(_('no arguments allowed with --continue'))
522 goal = 'continue'
522 goal = 'continue'
523 elif abort:
523 elif abort:
524 if util.any((outg, revs, freeargs, rules)):
524 if util.any((outg, revs, freeargs, rules)):
525 raise util.Abort(_('no arguments allowed with --abort'))
525 raise util.Abort(_('no arguments allowed with --abort'))
526 goal = 'abort'
526 goal = 'abort'
527 else:
527 else:
528 if os.path.exists(os.path.join(repo.path, 'histedit-state')):
528 if os.path.exists(os.path.join(repo.path, 'histedit-state')):
529 raise util.Abort(_('history edit already in progress, try '
529 raise util.Abort(_('history edit already in progress, try '
530 '--continue or --abort'))
530 '--continue or --abort'))
531 if outg:
531 if outg:
532 if revs:
532 if revs:
533 raise util.Abort(_('no revisions allowed with --outgoing'))
533 raise util.Abort(_('no revisions allowed with --outgoing'))
534 if len(freeargs) > 1:
534 if len(freeargs) > 1:
535 raise util.Abort(
535 raise util.Abort(
536 _('only one repo argument allowed with --outgoing'))
536 _('only one repo argument allowed with --outgoing'))
537 else:
537 else:
538 revs.extend(freeargs)
538 revs.extend(freeargs)
539 if len(revs) != 1:
539 if len(revs) != 1:
540 raise util.Abort(
540 raise util.Abort(
541 _('histedit requires exactly one ancestor revision'))
541 _('histedit requires exactly one ancestor revision'))
542
542
543
543
544 if goal == 'continue':
544 if goal == 'continue':
545 (parentctxnode, rules, keep, topmost, replacements) = readstate(repo)
545 (parentctxnode, rules, keep, topmost, replacements) = readstate(repo)
546 parentctx = repo[parentctxnode]
546 parentctx = repo[parentctxnode]
547 parentctx, repl = bootstrapcontinue(ui, repo, parentctx, rules, opts)
547 parentctx, repl = bootstrapcontinue(ui, repo, parentctx, rules, opts)
548 replacements.extend(repl)
548 replacements.extend(repl)
549 elif goal == 'abort':
549 elif goal == 'abort':
550 (parentctxnode, rules, keep, topmost, replacements) = readstate(repo)
550 (parentctxnode, rules, keep, topmost, replacements) = readstate(repo)
551 mapping, tmpnodes, leafs, _ntm = processreplacement(repo, replacements)
551 mapping, tmpnodes, leafs, _ntm = processreplacement(repo, replacements)
552 ui.debug('restore wc to old parent %s\n' % node.short(topmost))
552 ui.debug('restore wc to old parent %s\n' % node.short(topmost))
553 # check whether we should update away
553 # check whether we should update away
554 parentnodes = [c.node() for c in repo[None].parents()]
554 parentnodes = [c.node() for c in repo[None].parents()]
555 for n in leafs | set([parentctxnode]):
555 for n in leafs | set([parentctxnode]):
556 if n in parentnodes:
556 if n in parentnodes:
557 hg.clean(repo, topmost)
557 hg.clean(repo, topmost)
558 break
558 break
559 else:
559 else:
560 pass
560 pass
561 cleanupnode(ui, repo, 'created', tmpnodes)
561 cleanupnode(ui, repo, 'created', tmpnodes)
562 cleanupnode(ui, repo, 'temp', leafs)
562 cleanupnode(ui, repo, 'temp', leafs)
563 os.unlink(os.path.join(repo.path, 'histedit-state'))
563 os.unlink(os.path.join(repo.path, 'histedit-state'))
564 return
564 return
565 else:
565 else:
566 cmdutil.checkunfinished(repo)
566 cmdutil.checkunfinished(repo)
567 cmdutil.bailifchanged(repo)
567 cmdutil.bailifchanged(repo)
568
568
569 topmost, empty = repo.dirstate.parents()
569 topmost, empty = repo.dirstate.parents()
570 if outg:
570 if outg:
571 if freeargs:
571 if freeargs:
572 remote = freeargs[0]
572 remote = freeargs[0]
573 else:
573 else:
574 remote = None
574 remote = None
575 root = findoutgoing(ui, repo, remote, force, opts)
575 root = findoutgoing(ui, repo, remote, force, opts)
576 else:
576 else:
577 rr = list(repo.set('roots(%ld)', scmutil.revrange(repo, revs)))
577 rr = list(repo.set('roots(%ld)', scmutil.revrange(repo, revs)))
578 if len(rr) != 1:
578 if len(rr) != 1:
579 raise util.Abort(_('The specified revisions must have '
579 raise util.Abort(_('The specified revisions must have '
580 'exactly one common root'))
580 'exactly one common root'))
581 root = rr[0].node()
581 root = rr[0].node()
582
582
583 keep = opts.get('keep', False)
583 keep = opts.get('keep', False)
584 revs = between(repo, root, topmost, keep)
584 revs = between(repo, root, topmost, keep)
585 if not revs:
585 if not revs:
586 raise util.Abort(_('%s is not an ancestor of working directory') %
586 raise util.Abort(_('%s is not an ancestor of working directory') %
587 node.short(root))
587 node.short(root))
588
588
589 ctxs = [repo[r] for r in revs]
589 ctxs = [repo[r] for r in revs]
590 if not rules:
590 if not rules:
591 rules = '\n'.join([makedesc(c) for c in ctxs])
591 rules = '\n'.join([makedesc(c) for c in ctxs])
592 rules += '\n\n'
592 rules += '\n\n'
593 rules += editcomment % (node.short(root), node.short(topmost))
593 rules += editcomment % (node.short(root), node.short(topmost))
594 rules = ui.edit(rules, ui.username())
594 rules = ui.edit(rules, ui.username())
595 # Save edit rules in .hg/histedit-last-edit.txt in case
595 # Save edit rules in .hg/histedit-last-edit.txt in case
596 # the user needs to ask for help after something
596 # the user needs to ask for help after something
597 # surprising happens.
597 # surprising happens.
598 f = open(repo.join('histedit-last-edit.txt'), 'w')
598 f = open(repo.join('histedit-last-edit.txt'), 'w')
599 f.write(rules)
599 f.write(rules)
600 f.close()
600 f.close()
601 else:
601 else:
602 if rules == '-':
602 if rules == '-':
603 f = sys.stdin
603 f = sys.stdin
604 else:
604 else:
605 f = open(rules)
605 f = open(rules)
606 rules = f.read()
606 rules = f.read()
607 f.close()
607 f.close()
608 rules = [l for l in (r.strip() for r in rules.splitlines())
608 rules = [l for l in (r.strip() for r in rules.splitlines())
609 if l and not l.startswith('#')]
609 if l and not l.startswith('#')]
610 rules = verifyrules(rules, repo, ctxs)
610 rules = verifyrules(rules, repo, ctxs)
611
611
612 parentctx = repo[root].parents()[0]
612 parentctx = repo[root].parents()[0]
613 replacements = []
613 replacements = []
614
614
615
615
616 while rules:
616 while rules:
617 writestate(repo, parentctx.node(), rules, keep, topmost, replacements)
617 writestate(repo, parentctx.node(), rules, keep, topmost, replacements)
618 action, ha = rules.pop(0)
618 action, ha = rules.pop(0)
619 ui.debug('histedit: processing %s %s\n' % (action, ha))
619 ui.debug('histedit: processing %s %s\n' % (action, ha))
620 actfunc = actiontable[action]
620 actfunc = actiontable[action]
621 parentctx, replacement_ = actfunc(ui, repo, parentctx, ha, opts)
621 parentctx, replacement_ = actfunc(ui, repo, parentctx, ha, opts)
622 replacements.extend(replacement_)
622 replacements.extend(replacement_)
623
623
624 hg.update(repo, parentctx.node())
624 hg.update(repo, parentctx.node())
625
625
626 mapping, tmpnodes, created, ntm = processreplacement(repo, replacements)
626 mapping, tmpnodes, created, ntm = processreplacement(repo, replacements)
627 if mapping:
627 if mapping:
628 for prec, succs in mapping.iteritems():
628 for prec, succs in mapping.iteritems():
629 if not succs:
629 if not succs:
630 ui.debug('histedit: %s is dropped\n' % node.short(prec))
630 ui.debug('histedit: %s is dropped\n' % node.short(prec))
631 else:
631 else:
632 ui.debug('histedit: %s is replaced by %s\n' % (
632 ui.debug('histedit: %s is replaced by %s\n' % (
633 node.short(prec), node.short(succs[0])))
633 node.short(prec), node.short(succs[0])))
634 if len(succs) > 1:
634 if len(succs) > 1:
635 m = 'histedit: %s'
635 m = 'histedit: %s'
636 for n in succs[1:]:
636 for n in succs[1:]:
637 ui.debug(m % node.short(n))
637 ui.debug(m % node.short(n))
638
638
639 if not keep:
639 if not keep:
640 if mapping:
640 if mapping:
641 movebookmarks(ui, repo, mapping, topmost, ntm)
641 movebookmarks(ui, repo, mapping, topmost, ntm)
642 # TODO update mq state
642 # TODO update mq state
643 if obsolete._enabled:
643 if obsolete._enabled:
644 markers = []
644 markers = []
645 # sort by revision number because it sound "right"
645 # sort by revision number because it sound "right"
646 for prec in sorted(mapping, key=repo.changelog.rev):
646 for prec in sorted(mapping, key=repo.changelog.rev):
647 succs = mapping[prec]
647 succs = mapping[prec]
648 markers.append((repo[prec],
648 markers.append((repo[prec],
649 tuple(repo[s] for s in succs)))
649 tuple(repo[s] for s in succs)))
650 if markers:
650 if markers:
651 obsolete.createmarkers(repo, markers)
651 obsolete.createmarkers(repo, markers)
652 else:
652 else:
653 cleanupnode(ui, repo, 'replaced', mapping)
653 cleanupnode(ui, repo, 'replaced', mapping)
654
654
655 cleanupnode(ui, repo, 'temp', tmpnodes)
655 cleanupnode(ui, repo, 'temp', tmpnodes)
656 os.unlink(os.path.join(repo.path, 'histedit-state'))
656 os.unlink(os.path.join(repo.path, 'histedit-state'))
657 if os.path.exists(repo.sjoin('undo')):
657 if os.path.exists(repo.sjoin('undo')):
658 os.unlink(repo.sjoin('undo'))
658 os.unlink(repo.sjoin('undo'))
659
659
660 def gatherchildren(repo, ctx):
660 def gatherchildren(repo, ctx):
661 # is there any new commit between the expected parent and "."
661 # is there any new commit between the expected parent and "."
662 #
662 #
663 # note: does not take non linear new change in account (but previous
663 # note: does not take non linear new change in account (but previous
664 # implementation didn't used them anyway (issue3655)
664 # implementation didn't used them anyway (issue3655)
665 newchildren = [c.node() for c in repo.set('(%d::.)', ctx)]
665 newchildren = [c.node() for c in repo.set('(%d::.)', ctx)]
666 if ctx.node() != node.nullid:
666 if ctx.node() != node.nullid:
667 if not newchildren:
667 if not newchildren:
668 # `ctx` should match but no result. This means that
668 # `ctx` should match but no result. This means that
669 # currentnode is not a descendant from ctx.
669 # currentnode is not a descendant from ctx.
670 msg = _('%s is not an ancestor of working directory')
670 msg = _('%s is not an ancestor of working directory')
671 hint = _('use "histedit --abort" to clear broken state')
671 hint = _('use "histedit --abort" to clear broken state')
672 raise util.Abort(msg % ctx, hint=hint)
672 raise util.Abort(msg % ctx, hint=hint)
673 newchildren.pop(0) # remove ctx
673 newchildren.pop(0) # remove ctx
674 return newchildren
674 return newchildren
675
675
676 def bootstrapcontinue(ui, repo, parentctx, rules, opts):
676 def bootstrapcontinue(ui, repo, parentctx, rules, opts):
677 action, currentnode = rules.pop(0)
677 action, currentnode = rules.pop(0)
678 ctx = repo[currentnode]
678 ctx = repo[currentnode]
679
679
680 newchildren = gatherchildren(repo, parentctx)
680 newchildren = gatherchildren(repo, parentctx)
681
681
682 # Commit dirty working directory if necessary
682 # Commit dirty working directory if necessary
683 new = None
683 new = None
684 m, a, r, d = repo.status()[:4]
684 s = repo.status()
685 if m or a or r or d:
685 if s.modified or s.added or s.removed or s.deleted:
686 # prepare the message for the commit to comes
686 # prepare the message for the commit to comes
687 if action in ('f', 'fold', 'r', 'roll'):
687 if action in ('f', 'fold', 'r', 'roll'):
688 message = 'fold-temp-revision %s' % currentnode
688 message = 'fold-temp-revision %s' % currentnode
689 else:
689 else:
690 message = ctx.description()
690 message = ctx.description()
691 editopt = action in ('e', 'edit', 'm', 'mess')
691 editopt = action in ('e', 'edit', 'm', 'mess')
692 canonaction = {'e': 'edit', 'm': 'mess', 'p': 'pick'}
692 canonaction = {'e': 'edit', 'm': 'mess', 'p': 'pick'}
693 editform = 'histedit.%s' % canonaction.get(action, action)
693 editform = 'histedit.%s' % canonaction.get(action, action)
694 editor = cmdutil.getcommiteditor(edit=editopt, editform=editform)
694 editor = cmdutil.getcommiteditor(edit=editopt, editform=editform)
695 commit = commitfuncfor(repo, ctx)
695 commit = commitfuncfor(repo, ctx)
696 new = commit(text=message, user=ctx.user(),
696 new = commit(text=message, user=ctx.user(),
697 date=ctx.date(), extra=ctx.extra(),
697 date=ctx.date(), extra=ctx.extra(),
698 editor=editor)
698 editor=editor)
699 if new is not None:
699 if new is not None:
700 newchildren.append(new)
700 newchildren.append(new)
701
701
702 replacements = []
702 replacements = []
703 # track replacements
703 # track replacements
704 if ctx.node() not in newchildren:
704 if ctx.node() not in newchildren:
705 # note: new children may be empty when the changeset is dropped.
705 # note: new children may be empty when the changeset is dropped.
706 # this happen e.g during conflicting pick where we revert content
706 # this happen e.g during conflicting pick where we revert content
707 # to parent.
707 # to parent.
708 replacements.append((ctx.node(), tuple(newchildren)))
708 replacements.append((ctx.node(), tuple(newchildren)))
709
709
710 if action in ('f', 'fold', 'r', 'roll'):
710 if action in ('f', 'fold', 'r', 'roll'):
711 if newchildren:
711 if newchildren:
712 # finalize fold operation if applicable
712 # finalize fold operation if applicable
713 if new is None:
713 if new is None:
714 new = newchildren[-1]
714 new = newchildren[-1]
715 else:
715 else:
716 newchildren.pop() # remove new from internal changes
716 newchildren.pop() # remove new from internal changes
717 foldopts = opts
717 foldopts = opts
718 if action in ('r', 'roll'):
718 if action in ('r', 'roll'):
719 foldopts = foldopts.copy()
719 foldopts = foldopts.copy()
720 foldopts['rollup'] = True
720 foldopts['rollup'] = True
721 parentctx, repl = finishfold(ui, repo, parentctx, ctx, new,
721 parentctx, repl = finishfold(ui, repo, parentctx, ctx, new,
722 foldopts, newchildren)
722 foldopts, newchildren)
723 replacements.extend(repl)
723 replacements.extend(repl)
724 else:
724 else:
725 # newchildren is empty if the fold did not result in any commit
725 # newchildren is empty if the fold did not result in any commit
726 # this happen when all folded change are discarded during the
726 # this happen when all folded change are discarded during the
727 # merge.
727 # merge.
728 replacements.append((ctx.node(), (parentctx.node(),)))
728 replacements.append((ctx.node(), (parentctx.node(),)))
729 elif newchildren:
729 elif newchildren:
730 # otherwise update "parentctx" before proceeding to further operation
730 # otherwise update "parentctx" before proceeding to further operation
731 parentctx = repo[newchildren[-1]]
731 parentctx = repo[newchildren[-1]]
732 return parentctx, replacements
732 return parentctx, replacements
733
733
734
734
735 def between(repo, old, new, keep):
735 def between(repo, old, new, keep):
736 """select and validate the set of revision to edit
736 """select and validate the set of revision to edit
737
737
738 When keep is false, the specified set can't have children."""
738 When keep is false, the specified set can't have children."""
739 ctxs = list(repo.set('%n::%n', old, new))
739 ctxs = list(repo.set('%n::%n', old, new))
740 if ctxs and not keep:
740 if ctxs and not keep:
741 if (not obsolete._enabled and
741 if (not obsolete._enabled and
742 repo.revs('(%ld::) - (%ld)', ctxs, ctxs)):
742 repo.revs('(%ld::) - (%ld)', ctxs, ctxs)):
743 raise util.Abort(_('cannot edit history that would orphan nodes'))
743 raise util.Abort(_('cannot edit history that would orphan nodes'))
744 if repo.revs('(%ld) and merge()', ctxs):
744 if repo.revs('(%ld) and merge()', ctxs):
745 raise util.Abort(_('cannot edit history that contains merges'))
745 raise util.Abort(_('cannot edit history that contains merges'))
746 root = ctxs[0] # list is already sorted by repo.set
746 root = ctxs[0] # list is already sorted by repo.set
747 if not root.mutable():
747 if not root.mutable():
748 raise util.Abort(_('cannot edit immutable changeset: %s') % root)
748 raise util.Abort(_('cannot edit immutable changeset: %s') % root)
749 return [c.node() for c in ctxs]
749 return [c.node() for c in ctxs]
750
750
751
751
752 def writestate(repo, parentnode, rules, keep, topmost, replacements):
752 def writestate(repo, parentnode, rules, keep, topmost, replacements):
753 fp = open(os.path.join(repo.path, 'histedit-state'), 'w')
753 fp = open(os.path.join(repo.path, 'histedit-state'), 'w')
754 pickle.dump((parentnode, rules, keep, topmost, replacements), fp)
754 pickle.dump((parentnode, rules, keep, topmost, replacements), fp)
755 fp.close()
755 fp.close()
756
756
757 def readstate(repo):
757 def readstate(repo):
758 """Returns a tuple of (parentnode, rules, keep, topmost, replacements).
758 """Returns a tuple of (parentnode, rules, keep, topmost, replacements).
759 """
759 """
760 try:
760 try:
761 fp = open(os.path.join(repo.path, 'histedit-state'))
761 fp = open(os.path.join(repo.path, 'histedit-state'))
762 except IOError, err:
762 except IOError, err:
763 if err.errno != errno.ENOENT:
763 if err.errno != errno.ENOENT:
764 raise
764 raise
765 raise util.Abort(_('no histedit in progress'))
765 raise util.Abort(_('no histedit in progress'))
766 return pickle.load(fp)
766 return pickle.load(fp)
767
767
768
768
769 def makedesc(c):
769 def makedesc(c):
770 """build a initial action line for a ctx `c`
770 """build a initial action line for a ctx `c`
771
771
772 line are in the form:
772 line are in the form:
773
773
774 pick <hash> <rev> <summary>
774 pick <hash> <rev> <summary>
775 """
775 """
776 summary = ''
776 summary = ''
777 if c.description():
777 if c.description():
778 summary = c.description().splitlines()[0]
778 summary = c.description().splitlines()[0]
779 line = 'pick %s %d %s' % (c, c.rev(), summary)
779 line = 'pick %s %d %s' % (c, c.rev(), summary)
780 # trim to 80 columns so it's not stupidly wide in my editor
780 # trim to 80 columns so it's not stupidly wide in my editor
781 return util.ellipsis(line, 80)
781 return util.ellipsis(line, 80)
782
782
783 def verifyrules(rules, repo, ctxs):
783 def verifyrules(rules, repo, ctxs):
784 """Verify that there exists exactly one edit rule per given changeset.
784 """Verify that there exists exactly one edit rule per given changeset.
785
785
786 Will abort if there are to many or too few rules, a malformed rule,
786 Will abort if there are to many or too few rules, a malformed rule,
787 or a rule on a changeset outside of the user-given range.
787 or a rule on a changeset outside of the user-given range.
788 """
788 """
789 parsed = []
789 parsed = []
790 expected = set(str(c) for c in ctxs)
790 expected = set(str(c) for c in ctxs)
791 seen = set()
791 seen = set()
792 for r in rules:
792 for r in rules:
793 if ' ' not in r:
793 if ' ' not in r:
794 raise util.Abort(_('malformed line "%s"') % r)
794 raise util.Abort(_('malformed line "%s"') % r)
795 action, rest = r.split(' ', 1)
795 action, rest = r.split(' ', 1)
796 ha = rest.strip().split(' ', 1)[0]
796 ha = rest.strip().split(' ', 1)[0]
797 try:
797 try:
798 ha = str(repo[ha]) # ensure its a short hash
798 ha = str(repo[ha]) # ensure its a short hash
799 except error.RepoError:
799 except error.RepoError:
800 raise util.Abort(_('unknown changeset %s listed') % ha)
800 raise util.Abort(_('unknown changeset %s listed') % ha)
801 if ha not in expected:
801 if ha not in expected:
802 raise util.Abort(
802 raise util.Abort(
803 _('may not use changesets other than the ones listed'))
803 _('may not use changesets other than the ones listed'))
804 if ha in seen:
804 if ha in seen:
805 raise util.Abort(_('duplicated command for changeset %s') % ha)
805 raise util.Abort(_('duplicated command for changeset %s') % ha)
806 seen.add(ha)
806 seen.add(ha)
807 if action not in actiontable:
807 if action not in actiontable:
808 raise util.Abort(_('unknown action "%s"') % action)
808 raise util.Abort(_('unknown action "%s"') % action)
809 parsed.append([action, ha])
809 parsed.append([action, ha])
810 missing = sorted(expected - seen) # sort to stabilize output
810 missing = sorted(expected - seen) # sort to stabilize output
811 if missing:
811 if missing:
812 raise util.Abort(_('missing rules for changeset %s') % missing[0],
812 raise util.Abort(_('missing rules for changeset %s') % missing[0],
813 hint=_('do you want to use the drop action?'))
813 hint=_('do you want to use the drop action?'))
814 return parsed
814 return parsed
815
815
816 def processreplacement(repo, replacements):
816 def processreplacement(repo, replacements):
817 """process the list of replacements to return
817 """process the list of replacements to return
818
818
819 1) the final mapping between original and created nodes
819 1) the final mapping between original and created nodes
820 2) the list of temporary node created by histedit
820 2) the list of temporary node created by histedit
821 3) the list of new commit created by histedit"""
821 3) the list of new commit created by histedit"""
822 allsuccs = set()
822 allsuccs = set()
823 replaced = set()
823 replaced = set()
824 fullmapping = {}
824 fullmapping = {}
825 # initialise basic set
825 # initialise basic set
826 # fullmapping record all operation recorded in replacement
826 # fullmapping record all operation recorded in replacement
827 for rep in replacements:
827 for rep in replacements:
828 allsuccs.update(rep[1])
828 allsuccs.update(rep[1])
829 replaced.add(rep[0])
829 replaced.add(rep[0])
830 fullmapping.setdefault(rep[0], set()).update(rep[1])
830 fullmapping.setdefault(rep[0], set()).update(rep[1])
831 new = allsuccs - replaced
831 new = allsuccs - replaced
832 tmpnodes = allsuccs & replaced
832 tmpnodes = allsuccs & replaced
833 # Reduce content fullmapping into direct relation between original nodes
833 # Reduce content fullmapping into direct relation between original nodes
834 # and final node created during history edition
834 # and final node created during history edition
835 # Dropped changeset are replaced by an empty list
835 # Dropped changeset are replaced by an empty list
836 toproceed = set(fullmapping)
836 toproceed = set(fullmapping)
837 final = {}
837 final = {}
838 while toproceed:
838 while toproceed:
839 for x in list(toproceed):
839 for x in list(toproceed):
840 succs = fullmapping[x]
840 succs = fullmapping[x]
841 for s in list(succs):
841 for s in list(succs):
842 if s in toproceed:
842 if s in toproceed:
843 # non final node with unknown closure
843 # non final node with unknown closure
844 # We can't process this now
844 # We can't process this now
845 break
845 break
846 elif s in final:
846 elif s in final:
847 # non final node, replace with closure
847 # non final node, replace with closure
848 succs.remove(s)
848 succs.remove(s)
849 succs.update(final[s])
849 succs.update(final[s])
850 else:
850 else:
851 final[x] = succs
851 final[x] = succs
852 toproceed.remove(x)
852 toproceed.remove(x)
853 # remove tmpnodes from final mapping
853 # remove tmpnodes from final mapping
854 for n in tmpnodes:
854 for n in tmpnodes:
855 del final[n]
855 del final[n]
856 # we expect all changes involved in final to exist in the repo
856 # we expect all changes involved in final to exist in the repo
857 # turn `final` into list (topologically sorted)
857 # turn `final` into list (topologically sorted)
858 nm = repo.changelog.nodemap
858 nm = repo.changelog.nodemap
859 for prec, succs in final.items():
859 for prec, succs in final.items():
860 final[prec] = sorted(succs, key=nm.get)
860 final[prec] = sorted(succs, key=nm.get)
861
861
862 # computed topmost element (necessary for bookmark)
862 # computed topmost element (necessary for bookmark)
863 if new:
863 if new:
864 newtopmost = sorted(new, key=repo.changelog.rev)[-1]
864 newtopmost = sorted(new, key=repo.changelog.rev)[-1]
865 elif not final:
865 elif not final:
866 # Nothing rewritten at all. we won't need `newtopmost`
866 # Nothing rewritten at all. we won't need `newtopmost`
867 # It is the same as `oldtopmost` and `processreplacement` know it
867 # It is the same as `oldtopmost` and `processreplacement` know it
868 newtopmost = None
868 newtopmost = None
869 else:
869 else:
870 # every body died. The newtopmost is the parent of the root.
870 # every body died. The newtopmost is the parent of the root.
871 newtopmost = repo[sorted(final, key=repo.changelog.rev)[0]].p1().node()
871 newtopmost = repo[sorted(final, key=repo.changelog.rev)[0]].p1().node()
872
872
873 return final, tmpnodes, new, newtopmost
873 return final, tmpnodes, new, newtopmost
874
874
875 def movebookmarks(ui, repo, mapping, oldtopmost, newtopmost):
875 def movebookmarks(ui, repo, mapping, oldtopmost, newtopmost):
876 """Move bookmark from old to newly created node"""
876 """Move bookmark from old to newly created node"""
877 if not mapping:
877 if not mapping:
878 # if nothing got rewritten there is not purpose for this function
878 # if nothing got rewritten there is not purpose for this function
879 return
879 return
880 moves = []
880 moves = []
881 for bk, old in sorted(repo._bookmarks.iteritems()):
881 for bk, old in sorted(repo._bookmarks.iteritems()):
882 if old == oldtopmost:
882 if old == oldtopmost:
883 # special case ensure bookmark stay on tip.
883 # special case ensure bookmark stay on tip.
884 #
884 #
885 # This is arguably a feature and we may only want that for the
885 # This is arguably a feature and we may only want that for the
886 # active bookmark. But the behavior is kept compatible with the old
886 # active bookmark. But the behavior is kept compatible with the old
887 # version for now.
887 # version for now.
888 moves.append((bk, newtopmost))
888 moves.append((bk, newtopmost))
889 continue
889 continue
890 base = old
890 base = old
891 new = mapping.get(base, None)
891 new = mapping.get(base, None)
892 if new is None:
892 if new is None:
893 continue
893 continue
894 while not new:
894 while not new:
895 # base is killed, trying with parent
895 # base is killed, trying with parent
896 base = repo[base].p1().node()
896 base = repo[base].p1().node()
897 new = mapping.get(base, (base,))
897 new = mapping.get(base, (base,))
898 # nothing to move
898 # nothing to move
899 moves.append((bk, new[-1]))
899 moves.append((bk, new[-1]))
900 if moves:
900 if moves:
901 marks = repo._bookmarks
901 marks = repo._bookmarks
902 for mark, new in moves:
902 for mark, new in moves:
903 old = marks[mark]
903 old = marks[mark]
904 ui.note(_('histedit: moving bookmarks %s from %s to %s\n')
904 ui.note(_('histedit: moving bookmarks %s from %s to %s\n')
905 % (mark, node.short(old), node.short(new)))
905 % (mark, node.short(old), node.short(new)))
906 marks[mark] = new
906 marks[mark] = new
907 marks.write()
907 marks.write()
908
908
909 def cleanupnode(ui, repo, name, nodes):
909 def cleanupnode(ui, repo, name, nodes):
910 """strip a group of nodes from the repository
910 """strip a group of nodes from the repository
911
911
912 The set of node to strip may contains unknown nodes."""
912 The set of node to strip may contains unknown nodes."""
913 ui.debug('should strip %s nodes %s\n' %
913 ui.debug('should strip %s nodes %s\n' %
914 (name, ', '.join([node.short(n) for n in nodes])))
914 (name, ', '.join([node.short(n) for n in nodes])))
915 lock = None
915 lock = None
916 try:
916 try:
917 lock = repo.lock()
917 lock = repo.lock()
918 # Find all node that need to be stripped
918 # Find all node that need to be stripped
919 # (we hg %lr instead of %ln to silently ignore unknown item
919 # (we hg %lr instead of %ln to silently ignore unknown item
920 nm = repo.changelog.nodemap
920 nm = repo.changelog.nodemap
921 nodes = sorted(n for n in nodes if n in nm)
921 nodes = sorted(n for n in nodes if n in nm)
922 roots = [c.node() for c in repo.set("roots(%ln)", nodes)]
922 roots = [c.node() for c in repo.set("roots(%ln)", nodes)]
923 for c in roots:
923 for c in roots:
924 # We should process node in reverse order to strip tip most first.
924 # We should process node in reverse order to strip tip most first.
925 # but this trigger a bug in changegroup hook.
925 # but this trigger a bug in changegroup hook.
926 # This would reduce bundle overhead
926 # This would reduce bundle overhead
927 repair.strip(ui, repo, c)
927 repair.strip(ui, repo, c)
928 finally:
928 finally:
929 release(lock)
929 release(lock)
930
930
931 def summaryhook(ui, repo):
931 def summaryhook(ui, repo):
932 if not os.path.exists(repo.join('histedit-state')):
932 if not os.path.exists(repo.join('histedit-state')):
933 return
933 return
934 (parentctxnode, rules, keep, topmost, replacements) = readstate(repo)
934 (parentctxnode, rules, keep, topmost, replacements) = readstate(repo)
935 if rules:
935 if rules:
936 # i18n: column positioning for "hg summary"
936 # i18n: column positioning for "hg summary"
937 ui.write(_('hist: %s (histedit --continue)\n') %
937 ui.write(_('hist: %s (histedit --continue)\n') %
938 (ui.label(_('%d remaining'), 'histedit.remaining') %
938 (ui.label(_('%d remaining'), 'histedit.remaining') %
939 len(rules)))
939 len(rules)))
940
940
941 def extsetup(ui):
941 def extsetup(ui):
942 cmdutil.summaryhooks.add('histedit', summaryhook)
942 cmdutil.summaryhooks.add('histedit', summaryhook)
943 cmdutil.unfinishedstates.append(
943 cmdutil.unfinishedstates.append(
944 ['histedit-state', False, True, _('histedit in progress'),
944 ['histedit-state', False, True, _('histedit in progress'),
945 _("use 'hg histedit --continue' or 'hg histedit --abort'")])
945 _("use 'hg histedit --continue' or 'hg histedit --abort'")])
General Comments 0
You need to be logged in to leave comments. Login now