##// END OF EJS Templates
chistedit: properly show verbose diffs...
Jordi Gutiérrez Hermoso -
r42239:fc009525 default
parent child Browse files
Show More
@@ -1,2271 +1,2272 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 and date
39 # r, roll = like fold, but discard this commit's description and date
40 # d, drop = remove commit from history
40 # d, drop = remove commit from history
41 # m, mess = edit commit message without changing commit content
41 # m, mess = edit commit message without changing commit content
42 # b, base = checkout changeset and apply further changesets from there
42 # b, base = checkout changeset and apply further changesets from there
43 #
43 #
44
44
45 In this file, lines beginning with ``#`` are ignored. You must specify a rule
45 In this file, lines beginning with ``#`` are ignored. You must specify a rule
46 for each revision in your history. For example, if you had meant to add gamma
46 for each revision in your history. For example, if you had meant to add gamma
47 before beta, and then wanted to add delta in the same revision as beta, you
47 before beta, and then wanted to add delta in the same revision as beta, you
48 would reorganize the file to look like this::
48 would reorganize the file to look like this::
49
49
50 pick 030b686bedc4 Add gamma
50 pick 030b686bedc4 Add gamma
51 pick c561b4e977df Add beta
51 pick c561b4e977df Add beta
52 fold 7c2fd3b9020c Add delta
52 fold 7c2fd3b9020c Add delta
53
53
54 # Edit history between c561b4e977df and 7c2fd3b9020c
54 # Edit history between c561b4e977df and 7c2fd3b9020c
55 #
55 #
56 # Commits are listed from least to most recent
56 # Commits are listed from least to most recent
57 #
57 #
58 # Commands:
58 # Commands:
59 # p, pick = use commit
59 # p, pick = use commit
60 # e, edit = use commit, but stop for amending
60 # e, edit = use commit, but stop for amending
61 # f, fold = use commit, but combine it with the one above
61 # f, fold = use commit, but combine it with the one above
62 # r, roll = like fold, but discard this commit's description and date
62 # r, roll = like fold, but discard this commit's description and date
63 # d, drop = remove commit from history
63 # d, drop = remove commit from history
64 # m, mess = edit commit message without changing commit content
64 # m, mess = edit commit message without changing commit content
65 # b, base = checkout changeset and apply further changesets from there
65 # b, base = checkout changeset and apply further changesets from there
66 #
66 #
67
67
68 At which point you close the editor and ``histedit`` starts working. When you
68 At which point you close the editor and ``histedit`` starts working. When you
69 specify a ``fold`` operation, ``histedit`` will open an editor when it folds
69 specify a ``fold`` operation, ``histedit`` will open an editor when it folds
70 those revisions together, offering you a chance to clean up the commit message::
70 those revisions together, offering you a chance to clean up the commit message::
71
71
72 Add beta
72 Add beta
73 ***
73 ***
74 Add delta
74 Add delta
75
75
76 Edit the commit message to your liking, then close the editor. The date used
76 Edit the commit message to your liking, then close the editor. The date used
77 for the commit will be the later of the two commits' dates. For this example,
77 for the commit will be the later of the two commits' dates. For this example,
78 let's assume that the commit message was changed to ``Add beta and delta.``
78 let's assume that the commit message was changed to ``Add beta and delta.``
79 After histedit has run and had a chance to remove any old or temporary
79 After histedit has run and had a chance to remove any old or temporary
80 revisions it needed, the history looks like this::
80 revisions it needed, the history looks like this::
81
81
82 @ 2[tip] 989b4d060121 2009-04-27 18:04 -0500 durin42
82 @ 2[tip] 989b4d060121 2009-04-27 18:04 -0500 durin42
83 | Add beta and delta.
83 | Add beta and delta.
84 |
84 |
85 o 1 081603921c3f 2009-04-27 18:04 -0500 durin42
85 o 1 081603921c3f 2009-04-27 18:04 -0500 durin42
86 | Add gamma
86 | Add gamma
87 |
87 |
88 o 0 d8d2fcd0e319 2009-04-27 18:04 -0500 durin42
88 o 0 d8d2fcd0e319 2009-04-27 18:04 -0500 durin42
89 Add alpha
89 Add alpha
90
90
91 Note that ``histedit`` does *not* remove any revisions (even its own temporary
91 Note that ``histedit`` does *not* remove any revisions (even its own temporary
92 ones) until after it has completed all the editing operations, so it will
92 ones) until after it has completed all the editing operations, so it will
93 probably perform several strip operations when it's done. For the above example,
93 probably perform several strip operations when it's done. For the above example,
94 it had to run strip twice. Strip can be slow depending on a variety of factors,
94 it had to run strip twice. Strip can be slow depending on a variety of factors,
95 so you might need to be a little patient. You can choose to keep the original
95 so you might need to be a little patient. You can choose to keep the original
96 revisions by passing the ``--keep`` flag.
96 revisions by passing the ``--keep`` flag.
97
97
98 The ``edit`` operation will drop you back to a command prompt,
98 The ``edit`` operation will drop you back to a command prompt,
99 allowing you to edit files freely, or even use ``hg record`` to commit
99 allowing you to edit files freely, or even use ``hg record`` to commit
100 some changes as a separate commit. When you're done, any remaining
100 some changes as a separate commit. When you're done, any remaining
101 uncommitted changes will be committed as well. When done, run ``hg
101 uncommitted changes will be committed as well. When done, run ``hg
102 histedit --continue`` to finish this step. If there are uncommitted
102 histedit --continue`` to finish this step. If there are uncommitted
103 changes, you'll be prompted for a new commit message, but the default
103 changes, you'll be prompted for a new commit message, but the default
104 commit message will be the original message for the ``edit`` ed
104 commit message will be the original message for the ``edit`` ed
105 revision, and the date of the original commit will be preserved.
105 revision, and the date of the original commit will be preserved.
106
106
107 The ``message`` operation will give you a chance to revise a commit
107 The ``message`` operation will give you a chance to revise a commit
108 message without changing the contents. It's a shortcut for doing
108 message without changing the contents. It's a shortcut for doing
109 ``edit`` immediately followed by `hg histedit --continue``.
109 ``edit`` immediately followed by `hg histedit --continue``.
110
110
111 If ``histedit`` encounters a conflict when moving a revision (while
111 If ``histedit`` encounters a conflict when moving a revision (while
112 handling ``pick`` or ``fold``), it'll stop in a similar manner to
112 handling ``pick`` or ``fold``), it'll stop in a similar manner to
113 ``edit`` with the difference that it won't prompt you for a commit
113 ``edit`` with the difference that it won't prompt you for a commit
114 message when done. If you decide at this point that you don't like how
114 message when done. If you decide at this point that you don't like how
115 much work it will be to rearrange history, or that you made a mistake,
115 much work it will be to rearrange history, or that you made a mistake,
116 you can use ``hg histedit --abort`` to abandon the new changes you
116 you can use ``hg histedit --abort`` to abandon the new changes you
117 have made and return to the state before you attempted to edit your
117 have made and return to the state before you attempted to edit your
118 history.
118 history.
119
119
120 If we clone the histedit-ed example repository above and add four more
120 If we clone the histedit-ed example repository above and add four more
121 changes, such that we have the following history::
121 changes, such that we have the following history::
122
122
123 @ 6[tip] 038383181893 2009-04-27 18:04 -0500 stefan
123 @ 6[tip] 038383181893 2009-04-27 18:04 -0500 stefan
124 | Add theta
124 | Add theta
125 |
125 |
126 o 5 140988835471 2009-04-27 18:04 -0500 stefan
126 o 5 140988835471 2009-04-27 18:04 -0500 stefan
127 | Add eta
127 | Add eta
128 |
128 |
129 o 4 122930637314 2009-04-27 18:04 -0500 stefan
129 o 4 122930637314 2009-04-27 18:04 -0500 stefan
130 | Add zeta
130 | Add zeta
131 |
131 |
132 o 3 836302820282 2009-04-27 18:04 -0500 stefan
132 o 3 836302820282 2009-04-27 18:04 -0500 stefan
133 | Add epsilon
133 | Add epsilon
134 |
134 |
135 o 2 989b4d060121 2009-04-27 18:04 -0500 durin42
135 o 2 989b4d060121 2009-04-27 18:04 -0500 durin42
136 | Add beta and delta.
136 | Add beta and delta.
137 |
137 |
138 o 1 081603921c3f 2009-04-27 18:04 -0500 durin42
138 o 1 081603921c3f 2009-04-27 18:04 -0500 durin42
139 | Add gamma
139 | Add gamma
140 |
140 |
141 o 0 d8d2fcd0e319 2009-04-27 18:04 -0500 durin42
141 o 0 d8d2fcd0e319 2009-04-27 18:04 -0500 durin42
142 Add alpha
142 Add alpha
143
143
144 If you run ``hg histedit --outgoing`` on the clone then it is the same
144 If you run ``hg histedit --outgoing`` on the clone then it is the same
145 as running ``hg histedit 836302820282``. If you need plan to push to a
145 as running ``hg histedit 836302820282``. If you need plan to push to a
146 repository that Mercurial does not detect to be related to the source
146 repository that Mercurial does not detect to be related to the source
147 repo, you can add a ``--force`` option.
147 repo, you can add a ``--force`` option.
148
148
149 Config
149 Config
150 ------
150 ------
151
151
152 Histedit rule lines are truncated to 80 characters by default. You
152 Histedit rule lines are truncated to 80 characters by default. You
153 can customize this behavior by setting a different length in your
153 can customize this behavior by setting a different length in your
154 configuration file::
154 configuration file::
155
155
156 [histedit]
156 [histedit]
157 linelen = 120 # truncate rule lines at 120 characters
157 linelen = 120 # truncate rule lines at 120 characters
158
158
159 The summary of a change can be customized as well::
159 The summary of a change can be customized as well::
160
160
161 [histedit]
161 [histedit]
162 summary-template = '{rev} {bookmarks} {desc|firstline}'
162 summary-template = '{rev} {bookmarks} {desc|firstline}'
163
163
164 The customized summary should be kept short enough that rule lines
164 The customized summary should be kept short enough that rule lines
165 will fit in the configured line length. See above if that requires
165 will fit in the configured line length. See above if that requires
166 customization.
166 customization.
167
167
168 ``hg histedit`` attempts to automatically choose an appropriate base
168 ``hg histedit`` attempts to automatically choose an appropriate base
169 revision to use. To change which base revision is used, define a
169 revision to use. To change which base revision is used, define a
170 revset in your configuration file::
170 revset in your configuration file::
171
171
172 [histedit]
172 [histedit]
173 defaultrev = only(.) & draft()
173 defaultrev = only(.) & draft()
174
174
175 By default each edited revision needs to be present in histedit commands.
175 By default each edited revision needs to be present in histedit commands.
176 To remove revision you need to use ``drop`` operation. You can configure
176 To remove revision you need to use ``drop`` operation. You can configure
177 the drop to be implicit for missing commits by adding::
177 the drop to be implicit for missing commits by adding::
178
178
179 [histedit]
179 [histedit]
180 dropmissing = True
180 dropmissing = True
181
181
182 By default, histedit will close the transaction after each action. For
182 By default, histedit will close the transaction after each action. For
183 performance purposes, you can configure histedit to use a single transaction
183 performance purposes, you can configure histedit to use a single transaction
184 across the entire histedit. WARNING: This setting introduces a significant risk
184 across the entire histedit. WARNING: This setting introduces a significant risk
185 of losing the work you've done in a histedit if the histedit aborts
185 of losing the work you've done in a histedit if the histedit aborts
186 unexpectedly::
186 unexpectedly::
187
187
188 [histedit]
188 [histedit]
189 singletransaction = True
189 singletransaction = True
190
190
191 """
191 """
192
192
193 from __future__ import absolute_import
193 from __future__ import absolute_import
194
194
195 # chistedit dependencies that are not available everywhere
195 # chistedit dependencies that are not available everywhere
196 try:
196 try:
197 import fcntl
197 import fcntl
198 import termios
198 import termios
199 except ImportError:
199 except ImportError:
200 fcntl = None
200 fcntl = None
201 termios = None
201 termios = None
202
202
203 import functools
203 import functools
204 import os
204 import os
205 import struct
205 import struct
206
206
207 from mercurial.i18n import _
207 from mercurial.i18n import _
208 from mercurial import (
208 from mercurial import (
209 bundle2,
209 bundle2,
210 cmdutil,
210 cmdutil,
211 context,
211 context,
212 copies,
212 copies,
213 destutil,
213 destutil,
214 discovery,
214 discovery,
215 error,
215 error,
216 exchange,
216 exchange,
217 extensions,
217 extensions,
218 hg,
218 hg,
219 logcmdutil,
219 logcmdutil,
220 merge as mergemod,
220 merge as mergemod,
221 mergeutil,
221 mergeutil,
222 node,
222 node,
223 obsolete,
223 obsolete,
224 pycompat,
224 pycompat,
225 registrar,
225 registrar,
226 repair,
226 repair,
227 scmutil,
227 scmutil,
228 state as statemod,
228 state as statemod,
229 util,
229 util,
230 )
230 )
231 from mercurial.utils import (
231 from mercurial.utils import (
232 dateutil,
232 dateutil,
233 stringutil,
233 stringutil,
234 )
234 )
235
235
236 pickle = util.pickle
236 pickle = util.pickle
237 cmdtable = {}
237 cmdtable = {}
238 command = registrar.command(cmdtable)
238 command = registrar.command(cmdtable)
239
239
240 configtable = {}
240 configtable = {}
241 configitem = registrar.configitem(configtable)
241 configitem = registrar.configitem(configtable)
242 configitem('experimental', 'histedit.autoverb',
242 configitem('experimental', 'histedit.autoverb',
243 default=False,
243 default=False,
244 )
244 )
245 configitem('histedit', 'defaultrev',
245 configitem('histedit', 'defaultrev',
246 default=None,
246 default=None,
247 )
247 )
248 configitem('histedit', 'dropmissing',
248 configitem('histedit', 'dropmissing',
249 default=False,
249 default=False,
250 )
250 )
251 configitem('histedit', 'linelen',
251 configitem('histedit', 'linelen',
252 default=80,
252 default=80,
253 )
253 )
254 configitem('histedit', 'singletransaction',
254 configitem('histedit', 'singletransaction',
255 default=False,
255 default=False,
256 )
256 )
257 configitem('ui', 'interface.histedit',
257 configitem('ui', 'interface.histedit',
258 default=None,
258 default=None,
259 )
259 )
260 configitem('histedit', 'summary-template',
260 configitem('histedit', 'summary-template',
261 default='{rev} {desc|firstline}')
261 default='{rev} {desc|firstline}')
262
262
263 # Note for extension authors: ONLY specify testedwith = 'ships-with-hg-core' for
263 # Note for extension authors: ONLY specify testedwith = 'ships-with-hg-core' for
264 # extensions which SHIP WITH MERCURIAL. Non-mainline extensions should
264 # extensions which SHIP WITH MERCURIAL. Non-mainline extensions should
265 # be specifying the version(s) of Mercurial they are tested with, or
265 # be specifying the version(s) of Mercurial they are tested with, or
266 # leave the attribute unspecified.
266 # leave the attribute unspecified.
267 testedwith = 'ships-with-hg-core'
267 testedwith = 'ships-with-hg-core'
268
268
269 actiontable = {}
269 actiontable = {}
270 primaryactions = set()
270 primaryactions = set()
271 secondaryactions = set()
271 secondaryactions = set()
272 tertiaryactions = set()
272 tertiaryactions = set()
273 internalactions = set()
273 internalactions = set()
274
274
275 def geteditcomment(ui, first, last):
275 def geteditcomment(ui, first, last):
276 """ construct the editor comment
276 """ construct the editor comment
277 The comment includes::
277 The comment includes::
278 - an intro
278 - an intro
279 - sorted primary commands
279 - sorted primary commands
280 - sorted short commands
280 - sorted short commands
281 - sorted long commands
281 - sorted long commands
282 - additional hints
282 - additional hints
283
283
284 Commands are only included once.
284 Commands are only included once.
285 """
285 """
286 intro = _("""Edit history between %s and %s
286 intro = _("""Edit history between %s and %s
287
287
288 Commits are listed from least to most recent
288 Commits are listed from least to most recent
289
289
290 You can reorder changesets by reordering the lines
290 You can reorder changesets by reordering the lines
291
291
292 Commands:
292 Commands:
293 """)
293 """)
294 actions = []
294 actions = []
295 def addverb(v):
295 def addverb(v):
296 a = actiontable[v]
296 a = actiontable[v]
297 lines = a.message.split("\n")
297 lines = a.message.split("\n")
298 if len(a.verbs):
298 if len(a.verbs):
299 v = ', '.join(sorted(a.verbs, key=lambda v: len(v)))
299 v = ', '.join(sorted(a.verbs, key=lambda v: len(v)))
300 actions.append(" %s = %s" % (v, lines[0]))
300 actions.append(" %s = %s" % (v, lines[0]))
301 actions.extend([' %s' for l in lines[1:]])
301 actions.extend([' %s' for l in lines[1:]])
302
302
303 for v in (
303 for v in (
304 sorted(primaryactions) +
304 sorted(primaryactions) +
305 sorted(secondaryactions) +
305 sorted(secondaryactions) +
306 sorted(tertiaryactions)
306 sorted(tertiaryactions)
307 ):
307 ):
308 addverb(v)
308 addverb(v)
309 actions.append('')
309 actions.append('')
310
310
311 hints = []
311 hints = []
312 if ui.configbool('histedit', 'dropmissing'):
312 if ui.configbool('histedit', 'dropmissing'):
313 hints.append("Deleting a changeset from the list "
313 hints.append("Deleting a changeset from the list "
314 "will DISCARD it from the edited history!")
314 "will DISCARD it from the edited history!")
315
315
316 lines = (intro % (first, last)).split('\n') + actions + hints
316 lines = (intro % (first, last)).split('\n') + actions + hints
317
317
318 return ''.join(['# %s\n' % l if l else '#\n' for l in lines])
318 return ''.join(['# %s\n' % l if l else '#\n' for l in lines])
319
319
320 class histeditstate(object):
320 class histeditstate(object):
321 def __init__(self, repo):
321 def __init__(self, repo):
322 self.repo = repo
322 self.repo = repo
323 self.actions = None
323 self.actions = None
324 self.keep = None
324 self.keep = None
325 self.topmost = None
325 self.topmost = None
326 self.parentctxnode = None
326 self.parentctxnode = None
327 self.lock = None
327 self.lock = None
328 self.wlock = None
328 self.wlock = None
329 self.backupfile = None
329 self.backupfile = None
330 self.stateobj = statemod.cmdstate(repo, 'histedit-state')
330 self.stateobj = statemod.cmdstate(repo, 'histedit-state')
331 self.replacements = []
331 self.replacements = []
332
332
333 def read(self):
333 def read(self):
334 """Load histedit state from disk and set fields appropriately."""
334 """Load histedit state from disk and set fields appropriately."""
335 if not self.stateobj.exists():
335 if not self.stateobj.exists():
336 cmdutil.wrongtooltocontinue(self.repo, _('histedit'))
336 cmdutil.wrongtooltocontinue(self.repo, _('histedit'))
337
337
338 data = self._read()
338 data = self._read()
339
339
340 self.parentctxnode = data['parentctxnode']
340 self.parentctxnode = data['parentctxnode']
341 actions = parserules(data['rules'], self)
341 actions = parserules(data['rules'], self)
342 self.actions = actions
342 self.actions = actions
343 self.keep = data['keep']
343 self.keep = data['keep']
344 self.topmost = data['topmost']
344 self.topmost = data['topmost']
345 self.replacements = data['replacements']
345 self.replacements = data['replacements']
346 self.backupfile = data['backupfile']
346 self.backupfile = data['backupfile']
347
347
348 def _read(self):
348 def _read(self):
349 fp = self.repo.vfs.read('histedit-state')
349 fp = self.repo.vfs.read('histedit-state')
350 if fp.startswith('v1\n'):
350 if fp.startswith('v1\n'):
351 data = self._load()
351 data = self._load()
352 parentctxnode, rules, keep, topmost, replacements, backupfile = data
352 parentctxnode, rules, keep, topmost, replacements, backupfile = data
353 else:
353 else:
354 data = pickle.loads(fp)
354 data = pickle.loads(fp)
355 parentctxnode, rules, keep, topmost, replacements = data
355 parentctxnode, rules, keep, topmost, replacements = data
356 backupfile = None
356 backupfile = None
357 rules = "\n".join(["%s %s" % (verb, rest) for [verb, rest] in rules])
357 rules = "\n".join(["%s %s" % (verb, rest) for [verb, rest] in rules])
358
358
359 return {'parentctxnode': parentctxnode, "rules": rules, "keep": keep,
359 return {'parentctxnode': parentctxnode, "rules": rules, "keep": keep,
360 "topmost": topmost, "replacements": replacements,
360 "topmost": topmost, "replacements": replacements,
361 "backupfile": backupfile}
361 "backupfile": backupfile}
362
362
363 def write(self, tr=None):
363 def write(self, tr=None):
364 if tr:
364 if tr:
365 tr.addfilegenerator('histedit-state', ('histedit-state',),
365 tr.addfilegenerator('histedit-state', ('histedit-state',),
366 self._write, location='plain')
366 self._write, location='plain')
367 else:
367 else:
368 with self.repo.vfs("histedit-state", "w") as f:
368 with self.repo.vfs("histedit-state", "w") as f:
369 self._write(f)
369 self._write(f)
370
370
371 def _write(self, fp):
371 def _write(self, fp):
372 fp.write('v1\n')
372 fp.write('v1\n')
373 fp.write('%s\n' % node.hex(self.parentctxnode))
373 fp.write('%s\n' % node.hex(self.parentctxnode))
374 fp.write('%s\n' % node.hex(self.topmost))
374 fp.write('%s\n' % node.hex(self.topmost))
375 fp.write('%s\n' % ('True' if self.keep else 'False'))
375 fp.write('%s\n' % ('True' if self.keep else 'False'))
376 fp.write('%d\n' % len(self.actions))
376 fp.write('%d\n' % len(self.actions))
377 for action in self.actions:
377 for action in self.actions:
378 fp.write('%s\n' % action.tostate())
378 fp.write('%s\n' % action.tostate())
379 fp.write('%d\n' % len(self.replacements))
379 fp.write('%d\n' % len(self.replacements))
380 for replacement in self.replacements:
380 for replacement in self.replacements:
381 fp.write('%s%s\n' % (node.hex(replacement[0]), ''.join(node.hex(r)
381 fp.write('%s%s\n' % (node.hex(replacement[0]), ''.join(node.hex(r)
382 for r in replacement[1])))
382 for r in replacement[1])))
383 backupfile = self.backupfile
383 backupfile = self.backupfile
384 if not backupfile:
384 if not backupfile:
385 backupfile = ''
385 backupfile = ''
386 fp.write('%s\n' % backupfile)
386 fp.write('%s\n' % backupfile)
387
387
388 def _load(self):
388 def _load(self):
389 fp = self.repo.vfs('histedit-state', 'r')
389 fp = self.repo.vfs('histedit-state', 'r')
390 lines = [l[:-1] for l in fp.readlines()]
390 lines = [l[:-1] for l in fp.readlines()]
391
391
392 index = 0
392 index = 0
393 lines[index] # version number
393 lines[index] # version number
394 index += 1
394 index += 1
395
395
396 parentctxnode = node.bin(lines[index])
396 parentctxnode = node.bin(lines[index])
397 index += 1
397 index += 1
398
398
399 topmost = node.bin(lines[index])
399 topmost = node.bin(lines[index])
400 index += 1
400 index += 1
401
401
402 keep = lines[index] == 'True'
402 keep = lines[index] == 'True'
403 index += 1
403 index += 1
404
404
405 # Rules
405 # Rules
406 rules = []
406 rules = []
407 rulelen = int(lines[index])
407 rulelen = int(lines[index])
408 index += 1
408 index += 1
409 for i in pycompat.xrange(rulelen):
409 for i in pycompat.xrange(rulelen):
410 ruleaction = lines[index]
410 ruleaction = lines[index]
411 index += 1
411 index += 1
412 rule = lines[index]
412 rule = lines[index]
413 index += 1
413 index += 1
414 rules.append((ruleaction, rule))
414 rules.append((ruleaction, rule))
415
415
416 # Replacements
416 # Replacements
417 replacements = []
417 replacements = []
418 replacementlen = int(lines[index])
418 replacementlen = int(lines[index])
419 index += 1
419 index += 1
420 for i in pycompat.xrange(replacementlen):
420 for i in pycompat.xrange(replacementlen):
421 replacement = lines[index]
421 replacement = lines[index]
422 original = node.bin(replacement[:40])
422 original = node.bin(replacement[:40])
423 succ = [node.bin(replacement[i:i + 40]) for i in
423 succ = [node.bin(replacement[i:i + 40]) for i in
424 range(40, len(replacement), 40)]
424 range(40, len(replacement), 40)]
425 replacements.append((original, succ))
425 replacements.append((original, succ))
426 index += 1
426 index += 1
427
427
428 backupfile = lines[index]
428 backupfile = lines[index]
429 index += 1
429 index += 1
430
430
431 fp.close()
431 fp.close()
432
432
433 return parentctxnode, rules, keep, topmost, replacements, backupfile
433 return parentctxnode, rules, keep, topmost, replacements, backupfile
434
434
435 def clear(self):
435 def clear(self):
436 if self.inprogress():
436 if self.inprogress():
437 self.repo.vfs.unlink('histedit-state')
437 self.repo.vfs.unlink('histedit-state')
438
438
439 def inprogress(self):
439 def inprogress(self):
440 return self.repo.vfs.exists('histedit-state')
440 return self.repo.vfs.exists('histedit-state')
441
441
442
442
443 class histeditaction(object):
443 class histeditaction(object):
444 def __init__(self, state, node):
444 def __init__(self, state, node):
445 self.state = state
445 self.state = state
446 self.repo = state.repo
446 self.repo = state.repo
447 self.node = node
447 self.node = node
448
448
449 @classmethod
449 @classmethod
450 def fromrule(cls, state, rule):
450 def fromrule(cls, state, rule):
451 """Parses the given rule, returning an instance of the histeditaction.
451 """Parses the given rule, returning an instance of the histeditaction.
452 """
452 """
453 ruleid = rule.strip().split(' ', 1)[0]
453 ruleid = rule.strip().split(' ', 1)[0]
454 # ruleid can be anything from rev numbers, hashes, "bookmarks" etc
454 # ruleid can be anything from rev numbers, hashes, "bookmarks" etc
455 # Check for validation of rule ids and get the rulehash
455 # Check for validation of rule ids and get the rulehash
456 try:
456 try:
457 rev = node.bin(ruleid)
457 rev = node.bin(ruleid)
458 except TypeError:
458 except TypeError:
459 try:
459 try:
460 _ctx = scmutil.revsingle(state.repo, ruleid)
460 _ctx = scmutil.revsingle(state.repo, ruleid)
461 rulehash = _ctx.hex()
461 rulehash = _ctx.hex()
462 rev = node.bin(rulehash)
462 rev = node.bin(rulehash)
463 except error.RepoLookupError:
463 except error.RepoLookupError:
464 raise error.ParseError(_("invalid changeset %s") % ruleid)
464 raise error.ParseError(_("invalid changeset %s") % ruleid)
465 return cls(state, rev)
465 return cls(state, rev)
466
466
467 def verify(self, prev, expected, seen):
467 def verify(self, prev, expected, seen):
468 """ Verifies semantic correctness of the rule"""
468 """ Verifies semantic correctness of the rule"""
469 repo = self.repo
469 repo = self.repo
470 ha = node.hex(self.node)
470 ha = node.hex(self.node)
471 self.node = scmutil.resolvehexnodeidprefix(repo, ha)
471 self.node = scmutil.resolvehexnodeidprefix(repo, ha)
472 if self.node is None:
472 if self.node is None:
473 raise error.ParseError(_('unknown changeset %s listed') % ha[:12])
473 raise error.ParseError(_('unknown changeset %s listed') % ha[:12])
474 self._verifynodeconstraints(prev, expected, seen)
474 self._verifynodeconstraints(prev, expected, seen)
475
475
476 def _verifynodeconstraints(self, prev, expected, seen):
476 def _verifynodeconstraints(self, prev, expected, seen):
477 # by default command need a node in the edited list
477 # by default command need a node in the edited list
478 if self.node not in expected:
478 if self.node not in expected:
479 raise error.ParseError(_('%s "%s" changeset was not a candidate')
479 raise error.ParseError(_('%s "%s" changeset was not a candidate')
480 % (self.verb, node.short(self.node)),
480 % (self.verb, node.short(self.node)),
481 hint=_('only use listed changesets'))
481 hint=_('only use listed changesets'))
482 # and only one command per node
482 # and only one command per node
483 if self.node in seen:
483 if self.node in seen:
484 raise error.ParseError(_('duplicated command for changeset %s') %
484 raise error.ParseError(_('duplicated command for changeset %s') %
485 node.short(self.node))
485 node.short(self.node))
486
486
487 def torule(self):
487 def torule(self):
488 """build a histedit rule line for an action
488 """build a histedit rule line for an action
489
489
490 by default lines are in the form:
490 by default lines are in the form:
491 <hash> <rev> <summary>
491 <hash> <rev> <summary>
492 """
492 """
493 ctx = self.repo[self.node]
493 ctx = self.repo[self.node]
494 ui = self.repo.ui
494 ui = self.repo.ui
495 summary = cmdutil.rendertemplate(
495 summary = cmdutil.rendertemplate(
496 ctx, ui.config('histedit', 'summary-template')) or ''
496 ctx, ui.config('histedit', 'summary-template')) or ''
497 summary = summary.splitlines()[0]
497 summary = summary.splitlines()[0]
498 line = '%s %s %s' % (self.verb, ctx, summary)
498 line = '%s %s %s' % (self.verb, ctx, summary)
499 # trim to 75 columns by default so it's not stupidly wide in my editor
499 # trim to 75 columns by default so it's not stupidly wide in my editor
500 # (the 5 more are left for verb)
500 # (the 5 more are left for verb)
501 maxlen = self.repo.ui.configint('histedit', 'linelen')
501 maxlen = self.repo.ui.configint('histedit', 'linelen')
502 maxlen = max(maxlen, 22) # avoid truncating hash
502 maxlen = max(maxlen, 22) # avoid truncating hash
503 return stringutil.ellipsis(line, maxlen)
503 return stringutil.ellipsis(line, maxlen)
504
504
505 def tostate(self):
505 def tostate(self):
506 """Print an action in format used by histedit state files
506 """Print an action in format used by histedit state files
507 (the first line is a verb, the remainder is the second)
507 (the first line is a verb, the remainder is the second)
508 """
508 """
509 return "%s\n%s" % (self.verb, node.hex(self.node))
509 return "%s\n%s" % (self.verb, node.hex(self.node))
510
510
511 def run(self):
511 def run(self):
512 """Runs the action. The default behavior is simply apply the action's
512 """Runs the action. The default behavior is simply apply the action's
513 rulectx onto the current parentctx."""
513 rulectx onto the current parentctx."""
514 self.applychange()
514 self.applychange()
515 self.continuedirty()
515 self.continuedirty()
516 return self.continueclean()
516 return self.continueclean()
517
517
518 def applychange(self):
518 def applychange(self):
519 """Applies the changes from this action's rulectx onto the current
519 """Applies the changes from this action's rulectx onto the current
520 parentctx, but does not commit them."""
520 parentctx, but does not commit them."""
521 repo = self.repo
521 repo = self.repo
522 rulectx = repo[self.node]
522 rulectx = repo[self.node]
523 repo.ui.pushbuffer(error=True, labeled=True)
523 repo.ui.pushbuffer(error=True, labeled=True)
524 hg.update(repo, self.state.parentctxnode, quietempty=True)
524 hg.update(repo, self.state.parentctxnode, quietempty=True)
525 repo.ui.popbuffer()
525 repo.ui.popbuffer()
526 stats = applychanges(repo.ui, repo, rulectx, {})
526 stats = applychanges(repo.ui, repo, rulectx, {})
527 repo.dirstate.setbranch(rulectx.branch())
527 repo.dirstate.setbranch(rulectx.branch())
528 if stats.unresolvedcount:
528 if stats.unresolvedcount:
529 raise error.InterventionRequired(
529 raise error.InterventionRequired(
530 _('Fix up the change (%s %s)') %
530 _('Fix up the change (%s %s)') %
531 (self.verb, node.short(self.node)),
531 (self.verb, node.short(self.node)),
532 hint=_('hg histedit --continue to resume'))
532 hint=_('hg histedit --continue to resume'))
533
533
534 def continuedirty(self):
534 def continuedirty(self):
535 """Continues the action when changes have been applied to the working
535 """Continues the action when changes have been applied to the working
536 copy. The default behavior is to commit the dirty changes."""
536 copy. The default behavior is to commit the dirty changes."""
537 repo = self.repo
537 repo = self.repo
538 rulectx = repo[self.node]
538 rulectx = repo[self.node]
539
539
540 editor = self.commiteditor()
540 editor = self.commiteditor()
541 commit = commitfuncfor(repo, rulectx)
541 commit = commitfuncfor(repo, rulectx)
542 if repo.ui.configbool('rewrite', 'update-timestamp'):
542 if repo.ui.configbool('rewrite', 'update-timestamp'):
543 date = dateutil.makedate()
543 date = dateutil.makedate()
544 else:
544 else:
545 date = rulectx.date()
545 date = rulectx.date()
546 commit(text=rulectx.description(), user=rulectx.user(),
546 commit(text=rulectx.description(), user=rulectx.user(),
547 date=date, extra=rulectx.extra(), editor=editor)
547 date=date, extra=rulectx.extra(), editor=editor)
548
548
549 def commiteditor(self):
549 def commiteditor(self):
550 """The editor to be used to edit the commit message."""
550 """The editor to be used to edit the commit message."""
551 return False
551 return False
552
552
553 def continueclean(self):
553 def continueclean(self):
554 """Continues the action when the working copy is clean. The default
554 """Continues the action when the working copy is clean. The default
555 behavior is to accept the current commit as the new version of the
555 behavior is to accept the current commit as the new version of the
556 rulectx."""
556 rulectx."""
557 ctx = self.repo['.']
557 ctx = self.repo['.']
558 if ctx.node() == self.state.parentctxnode:
558 if ctx.node() == self.state.parentctxnode:
559 self.repo.ui.warn(_('%s: skipping changeset (no changes)\n') %
559 self.repo.ui.warn(_('%s: skipping changeset (no changes)\n') %
560 node.short(self.node))
560 node.short(self.node))
561 return ctx, [(self.node, tuple())]
561 return ctx, [(self.node, tuple())]
562 if ctx.node() == self.node:
562 if ctx.node() == self.node:
563 # Nothing changed
563 # Nothing changed
564 return ctx, []
564 return ctx, []
565 return ctx, [(self.node, (ctx.node(),))]
565 return ctx, [(self.node, (ctx.node(),))]
566
566
567 def commitfuncfor(repo, src):
567 def commitfuncfor(repo, src):
568 """Build a commit function for the replacement of <src>
568 """Build a commit function for the replacement of <src>
569
569
570 This function ensure we apply the same treatment to all changesets.
570 This function ensure we apply the same treatment to all changesets.
571
571
572 - Add a 'histedit_source' entry in extra.
572 - Add a 'histedit_source' entry in extra.
573
573
574 Note that fold has its own separated logic because its handling is a bit
574 Note that fold has its own separated logic because its handling is a bit
575 different and not easily factored out of the fold method.
575 different and not easily factored out of the fold method.
576 """
576 """
577 phasemin = src.phase()
577 phasemin = src.phase()
578 def commitfunc(**kwargs):
578 def commitfunc(**kwargs):
579 overrides = {('phases', 'new-commit'): phasemin}
579 overrides = {('phases', 'new-commit'): phasemin}
580 with repo.ui.configoverride(overrides, 'histedit'):
580 with repo.ui.configoverride(overrides, 'histedit'):
581 extra = kwargs.get(r'extra', {}).copy()
581 extra = kwargs.get(r'extra', {}).copy()
582 extra['histedit_source'] = src.hex()
582 extra['histedit_source'] = src.hex()
583 kwargs[r'extra'] = extra
583 kwargs[r'extra'] = extra
584 return repo.commit(**kwargs)
584 return repo.commit(**kwargs)
585 return commitfunc
585 return commitfunc
586
586
587 def applychanges(ui, repo, ctx, opts):
587 def applychanges(ui, repo, ctx, opts):
588 """Merge changeset from ctx (only) in the current working directory"""
588 """Merge changeset from ctx (only) in the current working directory"""
589 wcpar = repo.dirstate.p1()
589 wcpar = repo.dirstate.p1()
590 if ctx.p1().node() == wcpar:
590 if ctx.p1().node() == wcpar:
591 # edits are "in place" we do not need to make any merge,
591 # edits are "in place" we do not need to make any merge,
592 # just applies changes on parent for editing
592 # just applies changes on parent for editing
593 ui.pushbuffer()
593 ui.pushbuffer()
594 cmdutil.revert(ui, repo, ctx, (wcpar, node.nullid), all=True)
594 cmdutil.revert(ui, repo, ctx, (wcpar, node.nullid), all=True)
595 stats = mergemod.updateresult(0, 0, 0, 0)
595 stats = mergemod.updateresult(0, 0, 0, 0)
596 ui.popbuffer()
596 ui.popbuffer()
597 else:
597 else:
598 try:
598 try:
599 # ui.forcemerge is an internal variable, do not document
599 # ui.forcemerge is an internal variable, do not document
600 repo.ui.setconfig('ui', 'forcemerge', opts.get('tool', ''),
600 repo.ui.setconfig('ui', 'forcemerge', opts.get('tool', ''),
601 'histedit')
601 'histedit')
602 stats = mergemod.graft(repo, ctx, ctx.p1(), ['local', 'histedit'])
602 stats = mergemod.graft(repo, ctx, ctx.p1(), ['local', 'histedit'])
603 finally:
603 finally:
604 repo.ui.setconfig('ui', 'forcemerge', '', 'histedit')
604 repo.ui.setconfig('ui', 'forcemerge', '', 'histedit')
605 return stats
605 return stats
606
606
607 def collapse(repo, firstctx, lastctx, commitopts, skipprompt=False):
607 def collapse(repo, firstctx, lastctx, commitopts, skipprompt=False):
608 """collapse the set of revisions from first to last as new one.
608 """collapse the set of revisions from first to last as new one.
609
609
610 Expected commit options are:
610 Expected commit options are:
611 - message
611 - message
612 - date
612 - date
613 - username
613 - username
614 Commit message is edited in all cases.
614 Commit message is edited in all cases.
615
615
616 This function works in memory."""
616 This function works in memory."""
617 ctxs = list(repo.set('%d::%d', firstctx.rev(), lastctx.rev()))
617 ctxs = list(repo.set('%d::%d', firstctx.rev(), lastctx.rev()))
618 if not ctxs:
618 if not ctxs:
619 return None
619 return None
620 for c in ctxs:
620 for c in ctxs:
621 if not c.mutable():
621 if not c.mutable():
622 raise error.ParseError(
622 raise error.ParseError(
623 _("cannot fold into public change %s") % node.short(c.node()))
623 _("cannot fold into public change %s") % node.short(c.node()))
624 base = firstctx.p1()
624 base = firstctx.p1()
625
625
626 # commit a new version of the old changeset, including the update
626 # commit a new version of the old changeset, including the update
627 # collect all files which might be affected
627 # collect all files which might be affected
628 files = set()
628 files = set()
629 for ctx in ctxs:
629 for ctx in ctxs:
630 files.update(ctx.files())
630 files.update(ctx.files())
631
631
632 # Recompute copies (avoid recording a -> b -> a)
632 # Recompute copies (avoid recording a -> b -> a)
633 copied = copies.pathcopies(base, lastctx)
633 copied = copies.pathcopies(base, lastctx)
634
634
635 # prune files which were reverted by the updates
635 # prune files which were reverted by the updates
636 files = [f for f in files if not cmdutil.samefile(f, lastctx, base)]
636 files = [f for f in files if not cmdutil.samefile(f, lastctx, base)]
637 # commit version of these files as defined by head
637 # commit version of these files as defined by head
638 headmf = lastctx.manifest()
638 headmf = lastctx.manifest()
639 def filectxfn(repo, ctx, path):
639 def filectxfn(repo, ctx, path):
640 if path in headmf:
640 if path in headmf:
641 fctx = lastctx[path]
641 fctx = lastctx[path]
642 flags = fctx.flags()
642 flags = fctx.flags()
643 mctx = context.memfilectx(repo, ctx,
643 mctx = context.memfilectx(repo, ctx,
644 fctx.path(), fctx.data(),
644 fctx.path(), fctx.data(),
645 islink='l' in flags,
645 islink='l' in flags,
646 isexec='x' in flags,
646 isexec='x' in flags,
647 copysource=copied.get(path))
647 copysource=copied.get(path))
648 return mctx
648 return mctx
649 return None
649 return None
650
650
651 if commitopts.get('message'):
651 if commitopts.get('message'):
652 message = commitopts['message']
652 message = commitopts['message']
653 else:
653 else:
654 message = firstctx.description()
654 message = firstctx.description()
655 user = commitopts.get('user')
655 user = commitopts.get('user')
656 date = commitopts.get('date')
656 date = commitopts.get('date')
657 extra = commitopts.get('extra')
657 extra = commitopts.get('extra')
658
658
659 parents = (firstctx.p1().node(), firstctx.p2().node())
659 parents = (firstctx.p1().node(), firstctx.p2().node())
660 editor = None
660 editor = None
661 if not skipprompt:
661 if not skipprompt:
662 editor = cmdutil.getcommiteditor(edit=True, editform='histedit.fold')
662 editor = cmdutil.getcommiteditor(edit=True, editform='histedit.fold')
663 new = context.memctx(repo,
663 new = context.memctx(repo,
664 parents=parents,
664 parents=parents,
665 text=message,
665 text=message,
666 files=files,
666 files=files,
667 filectxfn=filectxfn,
667 filectxfn=filectxfn,
668 user=user,
668 user=user,
669 date=date,
669 date=date,
670 extra=extra,
670 extra=extra,
671 editor=editor)
671 editor=editor)
672 return repo.commitctx(new)
672 return repo.commitctx(new)
673
673
674 def _isdirtywc(repo):
674 def _isdirtywc(repo):
675 return repo[None].dirty(missing=True)
675 return repo[None].dirty(missing=True)
676
676
677 def abortdirty():
677 def abortdirty():
678 raise error.Abort(_('working copy has pending changes'),
678 raise error.Abort(_('working copy has pending changes'),
679 hint=_('amend, commit, or revert them and run histedit '
679 hint=_('amend, commit, or revert them and run histedit '
680 '--continue, or abort with histedit --abort'))
680 '--continue, or abort with histedit --abort'))
681
681
682 def action(verbs, message, priority=False, internal=False):
682 def action(verbs, message, priority=False, internal=False):
683 def wrap(cls):
683 def wrap(cls):
684 assert not priority or not internal
684 assert not priority or not internal
685 verb = verbs[0]
685 verb = verbs[0]
686 if priority:
686 if priority:
687 primaryactions.add(verb)
687 primaryactions.add(verb)
688 elif internal:
688 elif internal:
689 internalactions.add(verb)
689 internalactions.add(verb)
690 elif len(verbs) > 1:
690 elif len(verbs) > 1:
691 secondaryactions.add(verb)
691 secondaryactions.add(verb)
692 else:
692 else:
693 tertiaryactions.add(verb)
693 tertiaryactions.add(verb)
694
694
695 cls.verb = verb
695 cls.verb = verb
696 cls.verbs = verbs
696 cls.verbs = verbs
697 cls.message = message
697 cls.message = message
698 for verb in verbs:
698 for verb in verbs:
699 actiontable[verb] = cls
699 actiontable[verb] = cls
700 return cls
700 return cls
701 return wrap
701 return wrap
702
702
703 @action(['pick', 'p'],
703 @action(['pick', 'p'],
704 _('use commit'),
704 _('use commit'),
705 priority=True)
705 priority=True)
706 class pick(histeditaction):
706 class pick(histeditaction):
707 def run(self):
707 def run(self):
708 rulectx = self.repo[self.node]
708 rulectx = self.repo[self.node]
709 if rulectx.p1().node() == self.state.parentctxnode:
709 if rulectx.p1().node() == self.state.parentctxnode:
710 self.repo.ui.debug('node %s unchanged\n' % node.short(self.node))
710 self.repo.ui.debug('node %s unchanged\n' % node.short(self.node))
711 return rulectx, []
711 return rulectx, []
712
712
713 return super(pick, self).run()
713 return super(pick, self).run()
714
714
715 @action(['edit', 'e'],
715 @action(['edit', 'e'],
716 _('use commit, but stop for amending'),
716 _('use commit, but stop for amending'),
717 priority=True)
717 priority=True)
718 class edit(histeditaction):
718 class edit(histeditaction):
719 def run(self):
719 def run(self):
720 repo = self.repo
720 repo = self.repo
721 rulectx = repo[self.node]
721 rulectx = repo[self.node]
722 hg.update(repo, self.state.parentctxnode, quietempty=True)
722 hg.update(repo, self.state.parentctxnode, quietempty=True)
723 applychanges(repo.ui, repo, rulectx, {})
723 applychanges(repo.ui, repo, rulectx, {})
724 raise error.InterventionRequired(
724 raise error.InterventionRequired(
725 _('Editing (%s), you may commit or record as needed now.')
725 _('Editing (%s), you may commit or record as needed now.')
726 % node.short(self.node),
726 % node.short(self.node),
727 hint=_('hg histedit --continue to resume'))
727 hint=_('hg histedit --continue to resume'))
728
728
729 def commiteditor(self):
729 def commiteditor(self):
730 return cmdutil.getcommiteditor(edit=True, editform='histedit.edit')
730 return cmdutil.getcommiteditor(edit=True, editform='histedit.edit')
731
731
732 @action(['fold', 'f'],
732 @action(['fold', 'f'],
733 _('use commit, but combine it with the one above'))
733 _('use commit, but combine it with the one above'))
734 class fold(histeditaction):
734 class fold(histeditaction):
735 def verify(self, prev, expected, seen):
735 def verify(self, prev, expected, seen):
736 """ Verifies semantic correctness of the fold rule"""
736 """ Verifies semantic correctness of the fold rule"""
737 super(fold, self).verify(prev, expected, seen)
737 super(fold, self).verify(prev, expected, seen)
738 repo = self.repo
738 repo = self.repo
739 if not prev:
739 if not prev:
740 c = repo[self.node].p1()
740 c = repo[self.node].p1()
741 elif not prev.verb in ('pick', 'base'):
741 elif not prev.verb in ('pick', 'base'):
742 return
742 return
743 else:
743 else:
744 c = repo[prev.node]
744 c = repo[prev.node]
745 if not c.mutable():
745 if not c.mutable():
746 raise error.ParseError(
746 raise error.ParseError(
747 _("cannot fold into public change %s") % node.short(c.node()))
747 _("cannot fold into public change %s") % node.short(c.node()))
748
748
749
749
750 def continuedirty(self):
750 def continuedirty(self):
751 repo = self.repo
751 repo = self.repo
752 rulectx = repo[self.node]
752 rulectx = repo[self.node]
753
753
754 commit = commitfuncfor(repo, rulectx)
754 commit = commitfuncfor(repo, rulectx)
755 commit(text='fold-temp-revision %s' % node.short(self.node),
755 commit(text='fold-temp-revision %s' % node.short(self.node),
756 user=rulectx.user(), date=rulectx.date(),
756 user=rulectx.user(), date=rulectx.date(),
757 extra=rulectx.extra())
757 extra=rulectx.extra())
758
758
759 def continueclean(self):
759 def continueclean(self):
760 repo = self.repo
760 repo = self.repo
761 ctx = repo['.']
761 ctx = repo['.']
762 rulectx = repo[self.node]
762 rulectx = repo[self.node]
763 parentctxnode = self.state.parentctxnode
763 parentctxnode = self.state.parentctxnode
764 if ctx.node() == parentctxnode:
764 if ctx.node() == parentctxnode:
765 repo.ui.warn(_('%s: empty changeset\n') %
765 repo.ui.warn(_('%s: empty changeset\n') %
766 node.short(self.node))
766 node.short(self.node))
767 return ctx, [(self.node, (parentctxnode,))]
767 return ctx, [(self.node, (parentctxnode,))]
768
768
769 parentctx = repo[parentctxnode]
769 parentctx = repo[parentctxnode]
770 newcommits = set(c.node() for c in repo.set('(%d::. - %d)',
770 newcommits = set(c.node() for c in repo.set('(%d::. - %d)',
771 parentctx.rev(),
771 parentctx.rev(),
772 parentctx.rev()))
772 parentctx.rev()))
773 if not newcommits:
773 if not newcommits:
774 repo.ui.warn(_('%s: cannot fold - working copy is not a '
774 repo.ui.warn(_('%s: cannot fold - working copy is not a '
775 'descendant of previous commit %s\n') %
775 'descendant of previous commit %s\n') %
776 (node.short(self.node), node.short(parentctxnode)))
776 (node.short(self.node), node.short(parentctxnode)))
777 return ctx, [(self.node, (ctx.node(),))]
777 return ctx, [(self.node, (ctx.node(),))]
778
778
779 middlecommits = newcommits.copy()
779 middlecommits = newcommits.copy()
780 middlecommits.discard(ctx.node())
780 middlecommits.discard(ctx.node())
781
781
782 return self.finishfold(repo.ui, repo, parentctx, rulectx, ctx.node(),
782 return self.finishfold(repo.ui, repo, parentctx, rulectx, ctx.node(),
783 middlecommits)
783 middlecommits)
784
784
785 def skipprompt(self):
785 def skipprompt(self):
786 """Returns true if the rule should skip the message editor.
786 """Returns true if the rule should skip the message editor.
787
787
788 For example, 'fold' wants to show an editor, but 'rollup'
788 For example, 'fold' wants to show an editor, but 'rollup'
789 doesn't want to.
789 doesn't want to.
790 """
790 """
791 return False
791 return False
792
792
793 def mergedescs(self):
793 def mergedescs(self):
794 """Returns true if the rule should merge messages of multiple changes.
794 """Returns true if the rule should merge messages of multiple changes.
795
795
796 This exists mainly so that 'rollup' rules can be a subclass of
796 This exists mainly so that 'rollup' rules can be a subclass of
797 'fold'.
797 'fold'.
798 """
798 """
799 return True
799 return True
800
800
801 def firstdate(self):
801 def firstdate(self):
802 """Returns true if the rule should preserve the date of the first
802 """Returns true if the rule should preserve the date of the first
803 change.
803 change.
804
804
805 This exists mainly so that 'rollup' rules can be a subclass of
805 This exists mainly so that 'rollup' rules can be a subclass of
806 'fold'.
806 'fold'.
807 """
807 """
808 return False
808 return False
809
809
810 def finishfold(self, ui, repo, ctx, oldctx, newnode, internalchanges):
810 def finishfold(self, ui, repo, ctx, oldctx, newnode, internalchanges):
811 parent = ctx.p1().node()
811 parent = ctx.p1().node()
812 hg.updaterepo(repo, parent, overwrite=False)
812 hg.updaterepo(repo, parent, overwrite=False)
813 ### prepare new commit data
813 ### prepare new commit data
814 commitopts = {}
814 commitopts = {}
815 commitopts['user'] = ctx.user()
815 commitopts['user'] = ctx.user()
816 # commit message
816 # commit message
817 if not self.mergedescs():
817 if not self.mergedescs():
818 newmessage = ctx.description()
818 newmessage = ctx.description()
819 else:
819 else:
820 newmessage = '\n***\n'.join(
820 newmessage = '\n***\n'.join(
821 [ctx.description()] +
821 [ctx.description()] +
822 [repo[r].description() for r in internalchanges] +
822 [repo[r].description() for r in internalchanges] +
823 [oldctx.description()]) + '\n'
823 [oldctx.description()]) + '\n'
824 commitopts['message'] = newmessage
824 commitopts['message'] = newmessage
825 # date
825 # date
826 if self.firstdate():
826 if self.firstdate():
827 commitopts['date'] = ctx.date()
827 commitopts['date'] = ctx.date()
828 else:
828 else:
829 commitopts['date'] = max(ctx.date(), oldctx.date())
829 commitopts['date'] = max(ctx.date(), oldctx.date())
830 # if date is to be updated to current
830 # if date is to be updated to current
831 if ui.configbool('rewrite', 'update-timestamp'):
831 if ui.configbool('rewrite', 'update-timestamp'):
832 commitopts['date'] = dateutil.makedate()
832 commitopts['date'] = dateutil.makedate()
833
833
834 extra = ctx.extra().copy()
834 extra = ctx.extra().copy()
835 # histedit_source
835 # histedit_source
836 # note: ctx is likely a temporary commit but that the best we can do
836 # note: ctx is likely a temporary commit but that the best we can do
837 # here. This is sufficient to solve issue3681 anyway.
837 # here. This is sufficient to solve issue3681 anyway.
838 extra['histedit_source'] = '%s,%s' % (ctx.hex(), oldctx.hex())
838 extra['histedit_source'] = '%s,%s' % (ctx.hex(), oldctx.hex())
839 commitopts['extra'] = extra
839 commitopts['extra'] = extra
840 phasemin = max(ctx.phase(), oldctx.phase())
840 phasemin = max(ctx.phase(), oldctx.phase())
841 overrides = {('phases', 'new-commit'): phasemin}
841 overrides = {('phases', 'new-commit'): phasemin}
842 with repo.ui.configoverride(overrides, 'histedit'):
842 with repo.ui.configoverride(overrides, 'histedit'):
843 n = collapse(repo, ctx, repo[newnode], commitopts,
843 n = collapse(repo, ctx, repo[newnode], commitopts,
844 skipprompt=self.skipprompt())
844 skipprompt=self.skipprompt())
845 if n is None:
845 if n is None:
846 return ctx, []
846 return ctx, []
847 hg.updaterepo(repo, n, overwrite=False)
847 hg.updaterepo(repo, n, overwrite=False)
848 replacements = [(oldctx.node(), (newnode,)),
848 replacements = [(oldctx.node(), (newnode,)),
849 (ctx.node(), (n,)),
849 (ctx.node(), (n,)),
850 (newnode, (n,)),
850 (newnode, (n,)),
851 ]
851 ]
852 for ich in internalchanges:
852 for ich in internalchanges:
853 replacements.append((ich, (n,)))
853 replacements.append((ich, (n,)))
854 return repo[n], replacements
854 return repo[n], replacements
855
855
856 @action(['base', 'b'],
856 @action(['base', 'b'],
857 _('checkout changeset and apply further changesets from there'))
857 _('checkout changeset and apply further changesets from there'))
858 class base(histeditaction):
858 class base(histeditaction):
859
859
860 def run(self):
860 def run(self):
861 if self.repo['.'].node() != self.node:
861 if self.repo['.'].node() != self.node:
862 mergemod.update(self.repo, self.node, branchmerge=False, force=True)
862 mergemod.update(self.repo, self.node, branchmerge=False, force=True)
863 return self.continueclean()
863 return self.continueclean()
864
864
865 def continuedirty(self):
865 def continuedirty(self):
866 abortdirty()
866 abortdirty()
867
867
868 def continueclean(self):
868 def continueclean(self):
869 basectx = self.repo['.']
869 basectx = self.repo['.']
870 return basectx, []
870 return basectx, []
871
871
872 def _verifynodeconstraints(self, prev, expected, seen):
872 def _verifynodeconstraints(self, prev, expected, seen):
873 # base can only be use with a node not in the edited set
873 # base can only be use with a node not in the edited set
874 if self.node in expected:
874 if self.node in expected:
875 msg = _('%s "%s" changeset was an edited list candidate')
875 msg = _('%s "%s" changeset was an edited list candidate')
876 raise error.ParseError(
876 raise error.ParseError(
877 msg % (self.verb, node.short(self.node)),
877 msg % (self.verb, node.short(self.node)),
878 hint=_('base must only use unlisted changesets'))
878 hint=_('base must only use unlisted changesets'))
879
879
880 @action(['_multifold'],
880 @action(['_multifold'],
881 _(
881 _(
882 """fold subclass used for when multiple folds happen in a row
882 """fold subclass used for when multiple folds happen in a row
883
883
884 We only want to fire the editor for the folded message once when
884 We only want to fire the editor for the folded message once when
885 (say) four changes are folded down into a single change. This is
885 (say) four changes are folded down into a single change. This is
886 similar to rollup, but we should preserve both messages so that
886 similar to rollup, but we should preserve both messages so that
887 when the last fold operation runs we can show the user all the
887 when the last fold operation runs we can show the user all the
888 commit messages in their editor.
888 commit messages in their editor.
889 """),
889 """),
890 internal=True)
890 internal=True)
891 class _multifold(fold):
891 class _multifold(fold):
892 def skipprompt(self):
892 def skipprompt(self):
893 return True
893 return True
894
894
895 @action(["roll", "r"],
895 @action(["roll", "r"],
896 _("like fold, but discard this commit's description and date"))
896 _("like fold, but discard this commit's description and date"))
897 class rollup(fold):
897 class rollup(fold):
898 def mergedescs(self):
898 def mergedescs(self):
899 return False
899 return False
900
900
901 def skipprompt(self):
901 def skipprompt(self):
902 return True
902 return True
903
903
904 def firstdate(self):
904 def firstdate(self):
905 return True
905 return True
906
906
907 @action(["drop", "d"],
907 @action(["drop", "d"],
908 _('remove commit from history'))
908 _('remove commit from history'))
909 class drop(histeditaction):
909 class drop(histeditaction):
910 def run(self):
910 def run(self):
911 parentctx = self.repo[self.state.parentctxnode]
911 parentctx = self.repo[self.state.parentctxnode]
912 return parentctx, [(self.node, tuple())]
912 return parentctx, [(self.node, tuple())]
913
913
914 @action(["mess", "m"],
914 @action(["mess", "m"],
915 _('edit commit message without changing commit content'),
915 _('edit commit message without changing commit content'),
916 priority=True)
916 priority=True)
917 class message(histeditaction):
917 class message(histeditaction):
918 def commiteditor(self):
918 def commiteditor(self):
919 return cmdutil.getcommiteditor(edit=True, editform='histedit.mess')
919 return cmdutil.getcommiteditor(edit=True, editform='histedit.mess')
920
920
921 def findoutgoing(ui, repo, remote=None, force=False, opts=None):
921 def findoutgoing(ui, repo, remote=None, force=False, opts=None):
922 """utility function to find the first outgoing changeset
922 """utility function to find the first outgoing changeset
923
923
924 Used by initialization code"""
924 Used by initialization code"""
925 if opts is None:
925 if opts is None:
926 opts = {}
926 opts = {}
927 dest = ui.expandpath(remote or 'default-push', remote or 'default')
927 dest = ui.expandpath(remote or 'default-push', remote or 'default')
928 dest, branches = hg.parseurl(dest, None)[:2]
928 dest, branches = hg.parseurl(dest, None)[:2]
929 ui.status(_('comparing with %s\n') % util.hidepassword(dest))
929 ui.status(_('comparing with %s\n') % util.hidepassword(dest))
930
930
931 revs, checkout = hg.addbranchrevs(repo, repo, branches, None)
931 revs, checkout = hg.addbranchrevs(repo, repo, branches, None)
932 other = hg.peer(repo, opts, dest)
932 other = hg.peer(repo, opts, dest)
933
933
934 if revs:
934 if revs:
935 revs = [repo.lookup(rev) for rev in revs]
935 revs = [repo.lookup(rev) for rev in revs]
936
936
937 outgoing = discovery.findcommonoutgoing(repo, other, revs, force=force)
937 outgoing = discovery.findcommonoutgoing(repo, other, revs, force=force)
938 if not outgoing.missing:
938 if not outgoing.missing:
939 raise error.Abort(_('no outgoing ancestors'))
939 raise error.Abort(_('no outgoing ancestors'))
940 roots = list(repo.revs("roots(%ln)", outgoing.missing))
940 roots = list(repo.revs("roots(%ln)", outgoing.missing))
941 if len(roots) > 1:
941 if len(roots) > 1:
942 msg = _('there are ambiguous outgoing revisions')
942 msg = _('there are ambiguous outgoing revisions')
943 hint = _("see 'hg help histedit' for more detail")
943 hint = _("see 'hg help histedit' for more detail")
944 raise error.Abort(msg, hint=hint)
944 raise error.Abort(msg, hint=hint)
945 return repo[roots[0]].node()
945 return repo[roots[0]].node()
946
946
947 # Curses Support
947 # Curses Support
948 try:
948 try:
949 import curses
949 import curses
950
950
951 # Curses requires setting the locale or it will default to the C
951 # Curses requires setting the locale or it will default to the C
952 # locale. This sets the locale to the user's default system
952 # locale. This sets the locale to the user's default system
953 # locale.
953 # locale.
954 import locale
954 import locale
955 locale.setlocale(locale.LC_ALL, r'')
955 locale.setlocale(locale.LC_ALL, r'')
956 except ImportError:
956 except ImportError:
957 curses = None
957 curses = None
958
958
959 KEY_LIST = ['pick', 'edit', 'fold', 'drop', 'mess', 'roll']
959 KEY_LIST = ['pick', 'edit', 'fold', 'drop', 'mess', 'roll']
960 ACTION_LABELS = {
960 ACTION_LABELS = {
961 'fold': '^fold',
961 'fold': '^fold',
962 'roll': '^roll',
962 'roll': '^roll',
963 }
963 }
964
964
965 COLOR_HELP, COLOR_SELECTED, COLOR_OK, COLOR_WARN, COLOR_CURRENT = 1, 2, 3, 4, 5
965 COLOR_HELP, COLOR_SELECTED, COLOR_OK, COLOR_WARN, COLOR_CURRENT = 1, 2, 3, 4, 5
966
966
967 E_QUIT, E_HISTEDIT = 1, 2
967 E_QUIT, E_HISTEDIT = 1, 2
968 E_PAGEDOWN, E_PAGEUP, E_LINEUP, E_LINEDOWN, E_RESIZE = 3, 4, 5, 6, 7
968 E_PAGEDOWN, E_PAGEUP, E_LINEUP, E_LINEDOWN, E_RESIZE = 3, 4, 5, 6, 7
969 MODE_INIT, MODE_PATCH, MODE_RULES, MODE_HELP = 0, 1, 2, 3
969 MODE_INIT, MODE_PATCH, MODE_RULES, MODE_HELP = 0, 1, 2, 3
970
970
971 KEYTABLE = {
971 KEYTABLE = {
972 'global': {
972 'global': {
973 'h': 'next-action',
973 'h': 'next-action',
974 'KEY_RIGHT': 'next-action',
974 'KEY_RIGHT': 'next-action',
975 'l': 'prev-action',
975 'l': 'prev-action',
976 'KEY_LEFT': 'prev-action',
976 'KEY_LEFT': 'prev-action',
977 'q': 'quit',
977 'q': 'quit',
978 'c': 'histedit',
978 'c': 'histedit',
979 'C': 'histedit',
979 'C': 'histedit',
980 'v': 'showpatch',
980 'v': 'showpatch',
981 '?': 'help',
981 '?': 'help',
982 },
982 },
983 MODE_RULES: {
983 MODE_RULES: {
984 'd': 'action-drop',
984 'd': 'action-drop',
985 'e': 'action-edit',
985 'e': 'action-edit',
986 'f': 'action-fold',
986 'f': 'action-fold',
987 'm': 'action-mess',
987 'm': 'action-mess',
988 'p': 'action-pick',
988 'p': 'action-pick',
989 'r': 'action-roll',
989 'r': 'action-roll',
990 ' ': 'select',
990 ' ': 'select',
991 'j': 'down',
991 'j': 'down',
992 'k': 'up',
992 'k': 'up',
993 'KEY_DOWN': 'down',
993 'KEY_DOWN': 'down',
994 'KEY_UP': 'up',
994 'KEY_UP': 'up',
995 'J': 'move-down',
995 'J': 'move-down',
996 'K': 'move-up',
996 'K': 'move-up',
997 'KEY_NPAGE': 'move-down',
997 'KEY_NPAGE': 'move-down',
998 'KEY_PPAGE': 'move-up',
998 'KEY_PPAGE': 'move-up',
999 '0': 'goto', # Used for 0..9
999 '0': 'goto', # Used for 0..9
1000 },
1000 },
1001 MODE_PATCH: {
1001 MODE_PATCH: {
1002 ' ': 'page-down',
1002 ' ': 'page-down',
1003 'KEY_NPAGE': 'page-down',
1003 'KEY_NPAGE': 'page-down',
1004 'KEY_PPAGE': 'page-up',
1004 'KEY_PPAGE': 'page-up',
1005 'j': 'line-down',
1005 'j': 'line-down',
1006 'k': 'line-up',
1006 'k': 'line-up',
1007 'KEY_DOWN': 'line-down',
1007 'KEY_DOWN': 'line-down',
1008 'KEY_UP': 'line-up',
1008 'KEY_UP': 'line-up',
1009 'J': 'down',
1009 'J': 'down',
1010 'K': 'up',
1010 'K': 'up',
1011 },
1011 },
1012 MODE_HELP: {
1012 MODE_HELP: {
1013 },
1013 },
1014 }
1014 }
1015
1015
1016 def screen_size():
1016 def screen_size():
1017 return struct.unpack('hh', fcntl.ioctl(1, termios.TIOCGWINSZ, ' '))
1017 return struct.unpack('hh', fcntl.ioctl(1, termios.TIOCGWINSZ, ' '))
1018
1018
1019 class histeditrule(object):
1019 class histeditrule(object):
1020 def __init__(self, ctx, pos, action='pick'):
1020 def __init__(self, ctx, pos, action='pick'):
1021 self.ctx = ctx
1021 self.ctx = ctx
1022 self.action = action
1022 self.action = action
1023 self.origpos = pos
1023 self.origpos = pos
1024 self.pos = pos
1024 self.pos = pos
1025 self.conflicts = []
1025 self.conflicts = []
1026
1026
1027 def __str__(self):
1027 def __str__(self):
1028 # Some actions ('fold' and 'roll') combine a patch with a previous one.
1028 # Some actions ('fold' and 'roll') combine a patch with a previous one.
1029 # Add a marker showing which patch they apply to, and also omit the
1029 # Add a marker showing which patch they apply to, and also omit the
1030 # description for 'roll' (since it will get discarded). Example display:
1030 # description for 'roll' (since it will get discarded). Example display:
1031 #
1031 #
1032 # #10 pick 316392:06a16c25c053 add option to skip tests
1032 # #10 pick 316392:06a16c25c053 add option to skip tests
1033 # #11 ^roll 316393:71313c964cc5
1033 # #11 ^roll 316393:71313c964cc5
1034 # #12 pick 316394:ab31f3973b0d include mfbt for mozilla-config.h
1034 # #12 pick 316394:ab31f3973b0d include mfbt for mozilla-config.h
1035 # #13 ^fold 316395:14ce5803f4c3 fix warnings
1035 # #13 ^fold 316395:14ce5803f4c3 fix warnings
1036 #
1036 #
1037 # The carets point to the changeset being folded into ("roll this
1037 # The carets point to the changeset being folded into ("roll this
1038 # changeset into the changeset above").
1038 # changeset into the changeset above").
1039 action = ACTION_LABELS.get(self.action, self.action)
1039 action = ACTION_LABELS.get(self.action, self.action)
1040 h = self.ctx.hex()[0:12]
1040 h = self.ctx.hex()[0:12]
1041 r = self.ctx.rev()
1041 r = self.ctx.rev()
1042 desc = self.ctx.description().splitlines()[0].strip()
1042 desc = self.ctx.description().splitlines()[0].strip()
1043 if self.action == 'roll':
1043 if self.action == 'roll':
1044 desc = ''
1044 desc = ''
1045 return "#{0:<2} {1:<6} {2}:{3} {4}".format(
1045 return "#{0:<2} {1:<6} {2}:{3} {4}".format(
1046 self.origpos, action, r, h, desc)
1046 self.origpos, action, r, h, desc)
1047
1047
1048 def checkconflicts(self, other):
1048 def checkconflicts(self, other):
1049 if other.pos > self.pos and other.origpos <= self.origpos:
1049 if other.pos > self.pos and other.origpos <= self.origpos:
1050 if set(other.ctx.files()) & set(self.ctx.files()) != set():
1050 if set(other.ctx.files()) & set(self.ctx.files()) != set():
1051 self.conflicts.append(other)
1051 self.conflicts.append(other)
1052 return self.conflicts
1052 return self.conflicts
1053
1053
1054 if other in self.conflicts:
1054 if other in self.conflicts:
1055 self.conflicts.remove(other)
1055 self.conflicts.remove(other)
1056 return self.conflicts
1056 return self.conflicts
1057
1057
1058 # ============ EVENTS ===============
1058 # ============ EVENTS ===============
1059 def movecursor(state, oldpos, newpos):
1059 def movecursor(state, oldpos, newpos):
1060 '''Change the rule/changeset that the cursor is pointing to, regardless of
1060 '''Change the rule/changeset that the cursor is pointing to, regardless of
1061 current mode (you can switch between patches from the view patch window).'''
1061 current mode (you can switch between patches from the view patch window).'''
1062 state['pos'] = newpos
1062 state['pos'] = newpos
1063
1063
1064 mode, _ = state['mode']
1064 mode, _ = state['mode']
1065 if mode == MODE_RULES:
1065 if mode == MODE_RULES:
1066 # Scroll through the list by updating the view for MODE_RULES, so that
1066 # Scroll through the list by updating the view for MODE_RULES, so that
1067 # even if we are not currently viewing the rules, switching back will
1067 # even if we are not currently viewing the rules, switching back will
1068 # result in the cursor's rule being visible.
1068 # result in the cursor's rule being visible.
1069 modestate = state['modes'][MODE_RULES]
1069 modestate = state['modes'][MODE_RULES]
1070 if newpos < modestate['line_offset']:
1070 if newpos < modestate['line_offset']:
1071 modestate['line_offset'] = newpos
1071 modestate['line_offset'] = newpos
1072 elif newpos > modestate['line_offset'] + state['page_height'] - 1:
1072 elif newpos > modestate['line_offset'] + state['page_height'] - 1:
1073 modestate['line_offset'] = newpos - state['page_height'] + 1
1073 modestate['line_offset'] = newpos - state['page_height'] + 1
1074
1074
1075 # Reset the patch view region to the top of the new patch.
1075 # Reset the patch view region to the top of the new patch.
1076 state['modes'][MODE_PATCH]['line_offset'] = 0
1076 state['modes'][MODE_PATCH]['line_offset'] = 0
1077
1077
1078 def changemode(state, mode):
1078 def changemode(state, mode):
1079 curmode, _ = state['mode']
1079 curmode, _ = state['mode']
1080 state['mode'] = (mode, curmode)
1080 state['mode'] = (mode, curmode)
1081
1081
1082 def makeselection(state, pos):
1082 def makeselection(state, pos):
1083 state['selected'] = pos
1083 state['selected'] = pos
1084
1084
1085 def swap(state, oldpos, newpos):
1085 def swap(state, oldpos, newpos):
1086 """Swap two positions and calculate necessary conflicts in
1086 """Swap two positions and calculate necessary conflicts in
1087 O(|newpos-oldpos|) time"""
1087 O(|newpos-oldpos|) time"""
1088
1088
1089 rules = state['rules']
1089 rules = state['rules']
1090 assert 0 <= oldpos < len(rules) and 0 <= newpos < len(rules)
1090 assert 0 <= oldpos < len(rules) and 0 <= newpos < len(rules)
1091
1091
1092 rules[oldpos], rules[newpos] = rules[newpos], rules[oldpos]
1092 rules[oldpos], rules[newpos] = rules[newpos], rules[oldpos]
1093
1093
1094 # TODO: swap should not know about histeditrule's internals
1094 # TODO: swap should not know about histeditrule's internals
1095 rules[newpos].pos = newpos
1095 rules[newpos].pos = newpos
1096 rules[oldpos].pos = oldpos
1096 rules[oldpos].pos = oldpos
1097
1097
1098 start = min(oldpos, newpos)
1098 start = min(oldpos, newpos)
1099 end = max(oldpos, newpos)
1099 end = max(oldpos, newpos)
1100 for r in pycompat.xrange(start, end + 1):
1100 for r in pycompat.xrange(start, end + 1):
1101 rules[newpos].checkconflicts(rules[r])
1101 rules[newpos].checkconflicts(rules[r])
1102 rules[oldpos].checkconflicts(rules[r])
1102 rules[oldpos].checkconflicts(rules[r])
1103
1103
1104 if state['selected']:
1104 if state['selected']:
1105 makeselection(state, newpos)
1105 makeselection(state, newpos)
1106
1106
1107 def changeaction(state, pos, action):
1107 def changeaction(state, pos, action):
1108 """Change the action state on the given position to the new action"""
1108 """Change the action state on the given position to the new action"""
1109 rules = state['rules']
1109 rules = state['rules']
1110 assert 0 <= pos < len(rules)
1110 assert 0 <= pos < len(rules)
1111 rules[pos].action = action
1111 rules[pos].action = action
1112
1112
1113 def cycleaction(state, pos, next=False):
1113 def cycleaction(state, pos, next=False):
1114 """Changes the action state the next or the previous action from
1114 """Changes the action state the next or the previous action from
1115 the action list"""
1115 the action list"""
1116 rules = state['rules']
1116 rules = state['rules']
1117 assert 0 <= pos < len(rules)
1117 assert 0 <= pos < len(rules)
1118 current = rules[pos].action
1118 current = rules[pos].action
1119
1119
1120 assert current in KEY_LIST
1120 assert current in KEY_LIST
1121
1121
1122 index = KEY_LIST.index(current)
1122 index = KEY_LIST.index(current)
1123 if next:
1123 if next:
1124 index += 1
1124 index += 1
1125 else:
1125 else:
1126 index -= 1
1126 index -= 1
1127 changeaction(state, pos, KEY_LIST[index % len(KEY_LIST)])
1127 changeaction(state, pos, KEY_LIST[index % len(KEY_LIST)])
1128
1128
1129 def changeview(state, delta, unit):
1129 def changeview(state, delta, unit):
1130 '''Change the region of whatever is being viewed (a patch or the list of
1130 '''Change the region of whatever is being viewed (a patch or the list of
1131 changesets). 'delta' is an amount (+/- 1) and 'unit' is 'page' or 'line'.'''
1131 changesets). 'delta' is an amount (+/- 1) and 'unit' is 'page' or 'line'.'''
1132 mode, _ = state['mode']
1132 mode, _ = state['mode']
1133 if mode != MODE_PATCH:
1133 if mode != MODE_PATCH:
1134 return
1134 return
1135 mode_state = state['modes'][mode]
1135 mode_state = state['modes'][mode]
1136 num_lines = len(patchcontents(state))
1136 num_lines = len(patchcontents(state))
1137 page_height = state['page_height']
1137 page_height = state['page_height']
1138 unit = page_height if unit == 'page' else 1
1138 unit = page_height if unit == 'page' else 1
1139 num_pages = 1 + (num_lines - 1) / page_height
1139 num_pages = 1 + (num_lines - 1) / page_height
1140 max_offset = (num_pages - 1) * page_height
1140 max_offset = (num_pages - 1) * page_height
1141 newline = mode_state['line_offset'] + delta * unit
1141 newline = mode_state['line_offset'] + delta * unit
1142 mode_state['line_offset'] = max(0, min(max_offset, newline))
1142 mode_state['line_offset'] = max(0, min(max_offset, newline))
1143
1143
1144 def event(state, ch):
1144 def event(state, ch):
1145 """Change state based on the current character input
1145 """Change state based on the current character input
1146
1146
1147 This takes the current state and based on the current character input from
1147 This takes the current state and based on the current character input from
1148 the user we change the state.
1148 the user we change the state.
1149 """
1149 """
1150 selected = state['selected']
1150 selected = state['selected']
1151 oldpos = state['pos']
1151 oldpos = state['pos']
1152 rules = state['rules']
1152 rules = state['rules']
1153
1153
1154 if ch in (curses.KEY_RESIZE, "KEY_RESIZE"):
1154 if ch in (curses.KEY_RESIZE, "KEY_RESIZE"):
1155 return E_RESIZE
1155 return E_RESIZE
1156
1156
1157 lookup_ch = ch
1157 lookup_ch = ch
1158 if '0' <= ch <= '9':
1158 if '0' <= ch <= '9':
1159 lookup_ch = '0'
1159 lookup_ch = '0'
1160
1160
1161 curmode, prevmode = state['mode']
1161 curmode, prevmode = state['mode']
1162 action = KEYTABLE[curmode].get(lookup_ch, KEYTABLE['global'].get(lookup_ch))
1162 action = KEYTABLE[curmode].get(lookup_ch, KEYTABLE['global'].get(lookup_ch))
1163 if action is None:
1163 if action is None:
1164 return
1164 return
1165 if action in ('down', 'move-down'):
1165 if action in ('down', 'move-down'):
1166 newpos = min(oldpos + 1, len(rules) - 1)
1166 newpos = min(oldpos + 1, len(rules) - 1)
1167 movecursor(state, oldpos, newpos)
1167 movecursor(state, oldpos, newpos)
1168 if selected is not None or action == 'move-down':
1168 if selected is not None or action == 'move-down':
1169 swap(state, oldpos, newpos)
1169 swap(state, oldpos, newpos)
1170 elif action in ('up', 'move-up'):
1170 elif action in ('up', 'move-up'):
1171 newpos = max(0, oldpos - 1)
1171 newpos = max(0, oldpos - 1)
1172 movecursor(state, oldpos, newpos)
1172 movecursor(state, oldpos, newpos)
1173 if selected is not None or action == 'move-up':
1173 if selected is not None or action == 'move-up':
1174 swap(state, oldpos, newpos)
1174 swap(state, oldpos, newpos)
1175 elif action == 'next-action':
1175 elif action == 'next-action':
1176 cycleaction(state, oldpos, next=True)
1176 cycleaction(state, oldpos, next=True)
1177 elif action == 'prev-action':
1177 elif action == 'prev-action':
1178 cycleaction(state, oldpos, next=False)
1178 cycleaction(state, oldpos, next=False)
1179 elif action == 'select':
1179 elif action == 'select':
1180 selected = oldpos if selected is None else None
1180 selected = oldpos if selected is None else None
1181 makeselection(state, selected)
1181 makeselection(state, selected)
1182 elif action == 'goto' and int(ch) < len(rules) and len(rules) <= 10:
1182 elif action == 'goto' and int(ch) < len(rules) and len(rules) <= 10:
1183 newrule = next((r for r in rules if r.origpos == int(ch)))
1183 newrule = next((r for r in rules if r.origpos == int(ch)))
1184 movecursor(state, oldpos, newrule.pos)
1184 movecursor(state, oldpos, newrule.pos)
1185 if selected is not None:
1185 if selected is not None:
1186 swap(state, oldpos, newrule.pos)
1186 swap(state, oldpos, newrule.pos)
1187 elif action.startswith('action-'):
1187 elif action.startswith('action-'):
1188 changeaction(state, oldpos, action[7:])
1188 changeaction(state, oldpos, action[7:])
1189 elif action == 'showpatch':
1189 elif action == 'showpatch':
1190 changemode(state, MODE_PATCH if curmode != MODE_PATCH else prevmode)
1190 changemode(state, MODE_PATCH if curmode != MODE_PATCH else prevmode)
1191 elif action == 'help':
1191 elif action == 'help':
1192 changemode(state, MODE_HELP if curmode != MODE_HELP else prevmode)
1192 changemode(state, MODE_HELP if curmode != MODE_HELP else prevmode)
1193 elif action == 'quit':
1193 elif action == 'quit':
1194 return E_QUIT
1194 return E_QUIT
1195 elif action == 'histedit':
1195 elif action == 'histedit':
1196 return E_HISTEDIT
1196 return E_HISTEDIT
1197 elif action == 'page-down':
1197 elif action == 'page-down':
1198 return E_PAGEDOWN
1198 return E_PAGEDOWN
1199 elif action == 'page-up':
1199 elif action == 'page-up':
1200 return E_PAGEUP
1200 return E_PAGEUP
1201 elif action == 'line-down':
1201 elif action == 'line-down':
1202 return E_LINEDOWN
1202 return E_LINEDOWN
1203 elif action == 'line-up':
1203 elif action == 'line-up':
1204 return E_LINEUP
1204 return E_LINEUP
1205
1205
1206 def makecommands(rules):
1206 def makecommands(rules):
1207 """Returns a list of commands consumable by histedit --commands based on
1207 """Returns a list of commands consumable by histedit --commands based on
1208 our list of rules"""
1208 our list of rules"""
1209 commands = []
1209 commands = []
1210 for rules in rules:
1210 for rules in rules:
1211 commands.append("{0} {1}\n".format(rules.action, rules.ctx))
1211 commands.append("{0} {1}\n".format(rules.action, rules.ctx))
1212 return commands
1212 return commands
1213
1213
1214 def addln(win, y, x, line, color=None):
1214 def addln(win, y, x, line, color=None):
1215 """Add a line to the given window left padding but 100% filled with
1215 """Add a line to the given window left padding but 100% filled with
1216 whitespace characters, so that the color appears on the whole line"""
1216 whitespace characters, so that the color appears on the whole line"""
1217 maxy, maxx = win.getmaxyx()
1217 maxy, maxx = win.getmaxyx()
1218 length = maxx - 1 - x
1218 length = maxx - 1 - x
1219 line = ("{0:<%d}" % length).format(str(line).strip())[:length]
1219 line = ("{0:<%d}" % length).format(str(line).strip())[:length]
1220 if y < 0:
1220 if y < 0:
1221 y = maxy + y
1221 y = maxy + y
1222 if x < 0:
1222 if x < 0:
1223 x = maxx + x
1223 x = maxx + x
1224 if color:
1224 if color:
1225 win.addstr(y, x, line, color)
1225 win.addstr(y, x, line, color)
1226 else:
1226 else:
1227 win.addstr(y, x, line)
1227 win.addstr(y, x, line)
1228
1228
1229 def patchcontents(state):
1229 def patchcontents(state):
1230 repo = state['repo']
1230 repo = state['repo']
1231 rule = state['rules'][state['pos']]
1231 rule = state['rules'][state['pos']]
1232 repo.ui.verbose = True
1232 displayer = logcmdutil.changesetdisplayer(repo.ui, repo, {
1233 displayer = logcmdutil.changesetdisplayer(repo.ui, repo, {
1233 'patch': True, 'verbose': True
1234 "patch": True, "template": "status"
1234 }, buffered=True)
1235 }, buffered=True)
1235 displayer.show(rule.ctx)
1236 displayer.show(rule.ctx)
1236 displayer.close()
1237 displayer.close()
1237 return displayer.hunk[rule.ctx.rev()].splitlines()
1238 return displayer.hunk[rule.ctx.rev()].splitlines()
1238
1239
1239 def _chisteditmain(repo, rules, stdscr):
1240 def _chisteditmain(repo, rules, stdscr):
1240 # initialize color pattern
1241 # initialize color pattern
1241 curses.init_pair(COLOR_HELP, curses.COLOR_WHITE, curses.COLOR_BLUE)
1242 curses.init_pair(COLOR_HELP, curses.COLOR_WHITE, curses.COLOR_BLUE)
1242 curses.init_pair(COLOR_SELECTED, curses.COLOR_BLACK, curses.COLOR_WHITE)
1243 curses.init_pair(COLOR_SELECTED, curses.COLOR_BLACK, curses.COLOR_WHITE)
1243 curses.init_pair(COLOR_WARN, curses.COLOR_BLACK, curses.COLOR_YELLOW)
1244 curses.init_pair(COLOR_WARN, curses.COLOR_BLACK, curses.COLOR_YELLOW)
1244 curses.init_pair(COLOR_OK, curses.COLOR_BLACK, curses.COLOR_GREEN)
1245 curses.init_pair(COLOR_OK, curses.COLOR_BLACK, curses.COLOR_GREEN)
1245 curses.init_pair(COLOR_CURRENT, curses.COLOR_WHITE, curses.COLOR_MAGENTA)
1246 curses.init_pair(COLOR_CURRENT, curses.COLOR_WHITE, curses.COLOR_MAGENTA)
1246
1247
1247 # don't display the cursor
1248 # don't display the cursor
1248 try:
1249 try:
1249 curses.curs_set(0)
1250 curses.curs_set(0)
1250 except curses.error:
1251 except curses.error:
1251 pass
1252 pass
1252
1253
1253 def rendercommit(win, state):
1254 def rendercommit(win, state):
1254 """Renders the commit window that shows the log of the current selected
1255 """Renders the commit window that shows the log of the current selected
1255 commit"""
1256 commit"""
1256 pos = state['pos']
1257 pos = state['pos']
1257 rules = state['rules']
1258 rules = state['rules']
1258 rule = rules[pos]
1259 rule = rules[pos]
1259
1260
1260 ctx = rule.ctx
1261 ctx = rule.ctx
1261 win.box()
1262 win.box()
1262
1263
1263 maxy, maxx = win.getmaxyx()
1264 maxy, maxx = win.getmaxyx()
1264 length = maxx - 3
1265 length = maxx - 3
1265
1266
1266 line = "changeset: {0}:{1:<12}".format(ctx.rev(), ctx)
1267 line = "changeset: {0}:{1:<12}".format(ctx.rev(), ctx)
1267 win.addstr(1, 1, line[:length])
1268 win.addstr(1, 1, line[:length])
1268
1269
1269 line = "user: {0}".format(ctx.user())
1270 line = "user: {0}".format(ctx.user())
1270 win.addstr(2, 1, line[:length])
1271 win.addstr(2, 1, line[:length])
1271
1272
1272 bms = repo.nodebookmarks(ctx.node())
1273 bms = repo.nodebookmarks(ctx.node())
1273 line = "bookmark: {0}".format(' '.join(bms))
1274 line = "bookmark: {0}".format(' '.join(bms))
1274 win.addstr(3, 1, line[:length])
1275 win.addstr(3, 1, line[:length])
1275
1276
1276 line = "files: {0}".format(','.join(ctx.files()))
1277 line = "files: {0}".format(','.join(ctx.files()))
1277 win.addstr(4, 1, line[:length])
1278 win.addstr(4, 1, line[:length])
1278
1279
1279 line = "summary: {0}".format(ctx.description().splitlines()[0])
1280 line = "summary: {0}".format(ctx.description().splitlines()[0])
1280 win.addstr(5, 1, line[:length])
1281 win.addstr(5, 1, line[:length])
1281
1282
1282 conflicts = rule.conflicts
1283 conflicts = rule.conflicts
1283 if len(conflicts) > 0:
1284 if len(conflicts) > 0:
1284 conflictstr = ','.join(map(lambda r: str(r.ctx), conflicts))
1285 conflictstr = ','.join(map(lambda r: str(r.ctx), conflicts))
1285 conflictstr = "changed files overlap with {0}".format(conflictstr)
1286 conflictstr = "changed files overlap with {0}".format(conflictstr)
1286 else:
1287 else:
1287 conflictstr = 'no overlap'
1288 conflictstr = 'no overlap'
1288
1289
1289 win.addstr(6, 1, conflictstr[:length])
1290 win.addstr(6, 1, conflictstr[:length])
1290 win.noutrefresh()
1291 win.noutrefresh()
1291
1292
1292 def helplines(mode):
1293 def helplines(mode):
1293 if mode == MODE_PATCH:
1294 if mode == MODE_PATCH:
1294 help = """\
1295 help = """\
1295 ?: help, k/up: line up, j/down: line down, v: stop viewing patch
1296 ?: help, k/up: line up, j/down: line down, v: stop viewing patch
1296 pgup: prev page, space/pgdn: next page, c: commit, q: abort
1297 pgup: prev page, space/pgdn: next page, c: commit, q: abort
1297 """
1298 """
1298 else:
1299 else:
1299 help = """\
1300 help = """\
1300 ?: help, k/up: move up, j/down: move down, space: select, v: view patch
1301 ?: help, k/up: move up, j/down: move down, space: select, v: view patch
1301 d: drop, e: edit, f: fold, m: mess, p: pick, r: roll
1302 d: drop, e: edit, f: fold, m: mess, p: pick, r: roll
1302 pgup/K: move patch up, pgdn/J: move patch down, c: commit, q: abort
1303 pgup/K: move patch up, pgdn/J: move patch down, c: commit, q: abort
1303 """
1304 """
1304 return help.splitlines()
1305 return help.splitlines()
1305
1306
1306 def renderhelp(win, state):
1307 def renderhelp(win, state):
1307 maxy, maxx = win.getmaxyx()
1308 maxy, maxx = win.getmaxyx()
1308 mode, _ = state['mode']
1309 mode, _ = state['mode']
1309 for y, line in enumerate(helplines(mode)):
1310 for y, line in enumerate(helplines(mode)):
1310 if y >= maxy:
1311 if y >= maxy:
1311 break
1312 break
1312 addln(win, y, 0, line, curses.color_pair(COLOR_HELP))
1313 addln(win, y, 0, line, curses.color_pair(COLOR_HELP))
1313 win.noutrefresh()
1314 win.noutrefresh()
1314
1315
1315 def renderrules(rulesscr, state):
1316 def renderrules(rulesscr, state):
1316 rules = state['rules']
1317 rules = state['rules']
1317 pos = state['pos']
1318 pos = state['pos']
1318 selected = state['selected']
1319 selected = state['selected']
1319 start = state['modes'][MODE_RULES]['line_offset']
1320 start = state['modes'][MODE_RULES]['line_offset']
1320
1321
1321 conflicts = [r.ctx for r in rules if r.conflicts]
1322 conflicts = [r.ctx for r in rules if r.conflicts]
1322 if len(conflicts) > 0:
1323 if len(conflicts) > 0:
1323 line = "potential conflict in %s" % ','.join(map(str, conflicts))
1324 line = "potential conflict in %s" % ','.join(map(str, conflicts))
1324 addln(rulesscr, -1, 0, line, curses.color_pair(COLOR_WARN))
1325 addln(rulesscr, -1, 0, line, curses.color_pair(COLOR_WARN))
1325
1326
1326 for y, rule in enumerate(rules[start:]):
1327 for y, rule in enumerate(rules[start:]):
1327 if y >= state['page_height']:
1328 if y >= state['page_height']:
1328 break
1329 break
1329 if len(rule.conflicts) > 0:
1330 if len(rule.conflicts) > 0:
1330 rulesscr.addstr(y, 0, " ", curses.color_pair(COLOR_WARN))
1331 rulesscr.addstr(y, 0, " ", curses.color_pair(COLOR_WARN))
1331 else:
1332 else:
1332 rulesscr.addstr(y, 0, " ", curses.COLOR_BLACK)
1333 rulesscr.addstr(y, 0, " ", curses.COLOR_BLACK)
1333 if y + start == selected:
1334 if y + start == selected:
1334 addln(rulesscr, y, 2, rule, curses.color_pair(COLOR_SELECTED))
1335 addln(rulesscr, y, 2, rule, curses.color_pair(COLOR_SELECTED))
1335 elif y + start == pos:
1336 elif y + start == pos:
1336 addln(rulesscr, y, 2, rule,
1337 addln(rulesscr, y, 2, rule,
1337 curses.color_pair(COLOR_CURRENT) | curses.A_BOLD)
1338 curses.color_pair(COLOR_CURRENT) | curses.A_BOLD)
1338 else:
1339 else:
1339 addln(rulesscr, y, 2, rule)
1340 addln(rulesscr, y, 2, rule)
1340 rulesscr.noutrefresh()
1341 rulesscr.noutrefresh()
1341
1342
1342 def renderstring(win, state, output):
1343 def renderstring(win, state, output):
1343 maxy, maxx = win.getmaxyx()
1344 maxy, maxx = win.getmaxyx()
1344 length = min(maxy - 1, len(output))
1345 length = min(maxy - 1, len(output))
1345 for y in range(0, length):
1346 for y in range(0, length):
1346 win.addstr(y, 0, output[y])
1347 win.addstr(y, 0, output[y])
1347 win.noutrefresh()
1348 win.noutrefresh()
1348
1349
1349 def renderpatch(win, state):
1350 def renderpatch(win, state):
1350 start = state['modes'][MODE_PATCH]['line_offset']
1351 start = state['modes'][MODE_PATCH]['line_offset']
1351 renderstring(win, state, patchcontents(state)[start:])
1352 renderstring(win, state, patchcontents(state)[start:])
1352
1353
1353 def layout(mode):
1354 def layout(mode):
1354 maxy, maxx = stdscr.getmaxyx()
1355 maxy, maxx = stdscr.getmaxyx()
1355 helplen = len(helplines(mode))
1356 helplen = len(helplines(mode))
1356 return {
1357 return {
1357 'commit': (8, maxx),
1358 'commit': (8, maxx),
1358 'help': (helplen, maxx),
1359 'help': (helplen, maxx),
1359 'main': (maxy - helplen - 8, maxx),
1360 'main': (maxy - helplen - 8, maxx),
1360 }
1361 }
1361
1362
1362 def drawvertwin(size, y, x):
1363 def drawvertwin(size, y, x):
1363 win = curses.newwin(size[0], size[1], y, x)
1364 win = curses.newwin(size[0], size[1], y, x)
1364 y += size[0]
1365 y += size[0]
1365 return win, y, x
1366 return win, y, x
1366
1367
1367 state = {
1368 state = {
1368 'pos': 0,
1369 'pos': 0,
1369 'rules': rules,
1370 'rules': rules,
1370 'selected': None,
1371 'selected': None,
1371 'mode': (MODE_INIT, MODE_INIT),
1372 'mode': (MODE_INIT, MODE_INIT),
1372 'page_height': None,
1373 'page_height': None,
1373 'modes': {
1374 'modes': {
1374 MODE_RULES: {
1375 MODE_RULES: {
1375 'line_offset': 0,
1376 'line_offset': 0,
1376 },
1377 },
1377 MODE_PATCH: {
1378 MODE_PATCH: {
1378 'line_offset': 0,
1379 'line_offset': 0,
1379 }
1380 }
1380 },
1381 },
1381 'repo': repo,
1382 'repo': repo,
1382 }
1383 }
1383
1384
1384 # eventloop
1385 # eventloop
1385 ch = None
1386 ch = None
1386 stdscr.clear()
1387 stdscr.clear()
1387 stdscr.refresh()
1388 stdscr.refresh()
1388 while True:
1389 while True:
1389 try:
1390 try:
1390 oldmode, _ = state['mode']
1391 oldmode, _ = state['mode']
1391 if oldmode == MODE_INIT:
1392 if oldmode == MODE_INIT:
1392 changemode(state, MODE_RULES)
1393 changemode(state, MODE_RULES)
1393 e = event(state, ch)
1394 e = event(state, ch)
1394
1395
1395 if e == E_QUIT:
1396 if e == E_QUIT:
1396 return False
1397 return False
1397 if e == E_HISTEDIT:
1398 if e == E_HISTEDIT:
1398 return state['rules']
1399 return state['rules']
1399 else:
1400 else:
1400 if e == E_RESIZE:
1401 if e == E_RESIZE:
1401 size = screen_size()
1402 size = screen_size()
1402 if size != stdscr.getmaxyx():
1403 if size != stdscr.getmaxyx():
1403 curses.resizeterm(*size)
1404 curses.resizeterm(*size)
1404
1405
1405 curmode, _ = state['mode']
1406 curmode, _ = state['mode']
1406 sizes = layout(curmode)
1407 sizes = layout(curmode)
1407 if curmode != oldmode:
1408 if curmode != oldmode:
1408 state['page_height'] = sizes['main'][0]
1409 state['page_height'] = sizes['main'][0]
1409 # Adjust the view to fit the current screen size.
1410 # Adjust the view to fit the current screen size.
1410 movecursor(state, state['pos'], state['pos'])
1411 movecursor(state, state['pos'], state['pos'])
1411
1412
1412 # Pack the windows against the top, each pane spread across the
1413 # Pack the windows against the top, each pane spread across the
1413 # full width of the screen.
1414 # full width of the screen.
1414 y, x = (0, 0)
1415 y, x = (0, 0)
1415 helpwin, y, x = drawvertwin(sizes['help'], y, x)
1416 helpwin, y, x = drawvertwin(sizes['help'], y, x)
1416 mainwin, y, x = drawvertwin(sizes['main'], y, x)
1417 mainwin, y, x = drawvertwin(sizes['main'], y, x)
1417 commitwin, y, x = drawvertwin(sizes['commit'], y, x)
1418 commitwin, y, x = drawvertwin(sizes['commit'], y, x)
1418
1419
1419 if e in (E_PAGEDOWN, E_PAGEUP, E_LINEDOWN, E_LINEUP):
1420 if e in (E_PAGEDOWN, E_PAGEUP, E_LINEDOWN, E_LINEUP):
1420 if e == E_PAGEDOWN:
1421 if e == E_PAGEDOWN:
1421 changeview(state, +1, 'page')
1422 changeview(state, +1, 'page')
1422 elif e == E_PAGEUP:
1423 elif e == E_PAGEUP:
1423 changeview(state, -1, 'page')
1424 changeview(state, -1, 'page')
1424 elif e == E_LINEDOWN:
1425 elif e == E_LINEDOWN:
1425 changeview(state, +1, 'line')
1426 changeview(state, +1, 'line')
1426 elif e == E_LINEUP:
1427 elif e == E_LINEUP:
1427 changeview(state, -1, 'line')
1428 changeview(state, -1, 'line')
1428
1429
1429 # start rendering
1430 # start rendering
1430 commitwin.erase()
1431 commitwin.erase()
1431 helpwin.erase()
1432 helpwin.erase()
1432 mainwin.erase()
1433 mainwin.erase()
1433 if curmode == MODE_PATCH:
1434 if curmode == MODE_PATCH:
1434 renderpatch(mainwin, state)
1435 renderpatch(mainwin, state)
1435 elif curmode == MODE_HELP:
1436 elif curmode == MODE_HELP:
1436 renderstring(mainwin, state, __doc__.strip().splitlines())
1437 renderstring(mainwin, state, __doc__.strip().splitlines())
1437 else:
1438 else:
1438 renderrules(mainwin, state)
1439 renderrules(mainwin, state)
1439 rendercommit(commitwin, state)
1440 rendercommit(commitwin, state)
1440 renderhelp(helpwin, state)
1441 renderhelp(helpwin, state)
1441 curses.doupdate()
1442 curses.doupdate()
1442 # done rendering
1443 # done rendering
1443 ch = stdscr.getkey()
1444 ch = stdscr.getkey()
1444 except curses.error:
1445 except curses.error:
1445 pass
1446 pass
1446
1447
1447 def _chistedit(ui, repo, *freeargs, **opts):
1448 def _chistedit(ui, repo, *freeargs, **opts):
1448 """interactively edit changeset history via a curses interface
1449 """interactively edit changeset history via a curses interface
1449
1450
1450 Provides a ncurses interface to histedit. Press ? in chistedit mode
1451 Provides a ncurses interface to histedit. Press ? in chistedit mode
1451 to see an extensive help. Requires python-curses to be installed."""
1452 to see an extensive help. Requires python-curses to be installed."""
1452
1453
1453 if curses is None:
1454 if curses is None:
1454 raise error.Abort(_("Python curses library required"))
1455 raise error.Abort(_("Python curses library required"))
1455
1456
1456 # disable color
1457 # disable color
1457 ui._colormode = None
1458 ui._colormode = None
1458
1459
1459 try:
1460 try:
1460 keep = opts.get('keep')
1461 keep = opts.get('keep')
1461 revs = opts.get('rev', [])[:]
1462 revs = opts.get('rev', [])[:]
1462 cmdutil.checkunfinished(repo)
1463 cmdutil.checkunfinished(repo)
1463 cmdutil.bailifchanged(repo)
1464 cmdutil.bailifchanged(repo)
1464
1465
1465 if os.path.exists(os.path.join(repo.path, 'histedit-state')):
1466 if os.path.exists(os.path.join(repo.path, 'histedit-state')):
1466 raise error.Abort(_('history edit already in progress, try '
1467 raise error.Abort(_('history edit already in progress, try '
1467 '--continue or --abort'))
1468 '--continue or --abort'))
1468 revs.extend(freeargs)
1469 revs.extend(freeargs)
1469 if not revs:
1470 if not revs:
1470 defaultrev = destutil.desthistedit(ui, repo)
1471 defaultrev = destutil.desthistedit(ui, repo)
1471 if defaultrev is not None:
1472 if defaultrev is not None:
1472 revs.append(defaultrev)
1473 revs.append(defaultrev)
1473 if len(revs) != 1:
1474 if len(revs) != 1:
1474 raise error.Abort(
1475 raise error.Abort(
1475 _('histedit requires exactly one ancestor revision'))
1476 _('histedit requires exactly one ancestor revision'))
1476
1477
1477 rr = list(repo.set('roots(%ld)', scmutil.revrange(repo, revs)))
1478 rr = list(repo.set('roots(%ld)', scmutil.revrange(repo, revs)))
1478 if len(rr) != 1:
1479 if len(rr) != 1:
1479 raise error.Abort(_('The specified revisions must have '
1480 raise error.Abort(_('The specified revisions must have '
1480 'exactly one common root'))
1481 'exactly one common root'))
1481 root = rr[0].node()
1482 root = rr[0].node()
1482
1483
1483 topmost = repo.dirstate.p1()
1484 topmost = repo.dirstate.p1()
1484 revs = between(repo, root, topmost, keep)
1485 revs = between(repo, root, topmost, keep)
1485 if not revs:
1486 if not revs:
1486 raise error.Abort(_('%s is not an ancestor of working directory') %
1487 raise error.Abort(_('%s is not an ancestor of working directory') %
1487 node.short(root))
1488 node.short(root))
1488
1489
1489 ctxs = []
1490 ctxs = []
1490 for i, r in enumerate(revs):
1491 for i, r in enumerate(revs):
1491 ctxs.append(histeditrule(repo[r], i))
1492 ctxs.append(histeditrule(repo[r], i))
1492 rc = curses.wrapper(functools.partial(_chisteditmain, repo, ctxs))
1493 rc = curses.wrapper(functools.partial(_chisteditmain, repo, ctxs))
1493 curses.echo()
1494 curses.echo()
1494 curses.endwin()
1495 curses.endwin()
1495 if rc is False:
1496 if rc is False:
1496 ui.write(_("histedit aborted\n"))
1497 ui.write(_("histedit aborted\n"))
1497 return 0
1498 return 0
1498 if type(rc) is list:
1499 if type(rc) is list:
1499 ui.status(_("performing changes\n"))
1500 ui.status(_("performing changes\n"))
1500 rules = makecommands(rc)
1501 rules = makecommands(rc)
1501 filename = repo.vfs.join('chistedit')
1502 filename = repo.vfs.join('chistedit')
1502 with open(filename, 'w+') as fp:
1503 with open(filename, 'w+') as fp:
1503 for r in rules:
1504 for r in rules:
1504 fp.write(r)
1505 fp.write(r)
1505 opts['commands'] = filename
1506 opts['commands'] = filename
1506 return _texthistedit(ui, repo, *freeargs, **opts)
1507 return _texthistedit(ui, repo, *freeargs, **opts)
1507 except KeyboardInterrupt:
1508 except KeyboardInterrupt:
1508 pass
1509 pass
1509 return -1
1510 return -1
1510
1511
1511 @command('histedit',
1512 @command('histedit',
1512 [('', 'commands', '',
1513 [('', 'commands', '',
1513 _('read history edits from the specified file'), _('FILE')),
1514 _('read history edits from the specified file'), _('FILE')),
1514 ('c', 'continue', False, _('continue an edit already in progress')),
1515 ('c', 'continue', False, _('continue an edit already in progress')),
1515 ('', 'edit-plan', False, _('edit remaining actions list')),
1516 ('', 'edit-plan', False, _('edit remaining actions list')),
1516 ('k', 'keep', False,
1517 ('k', 'keep', False,
1517 _("don't strip old nodes after edit is complete")),
1518 _("don't strip old nodes after edit is complete")),
1518 ('', 'abort', False, _('abort an edit in progress')),
1519 ('', 'abort', False, _('abort an edit in progress')),
1519 ('o', 'outgoing', False, _('changesets not found in destination')),
1520 ('o', 'outgoing', False, _('changesets not found in destination')),
1520 ('f', 'force', False,
1521 ('f', 'force', False,
1521 _('force outgoing even for unrelated repositories')),
1522 _('force outgoing even for unrelated repositories')),
1522 ('r', 'rev', [], _('first revision to be edited'), _('REV'))] +
1523 ('r', 'rev', [], _('first revision to be edited'), _('REV'))] +
1523 cmdutil.formatteropts,
1524 cmdutil.formatteropts,
1524 _("[OPTIONS] ([ANCESTOR] | --outgoing [URL])"),
1525 _("[OPTIONS] ([ANCESTOR] | --outgoing [URL])"),
1525 helpcategory=command.CATEGORY_CHANGE_MANAGEMENT)
1526 helpcategory=command.CATEGORY_CHANGE_MANAGEMENT)
1526 def histedit(ui, repo, *freeargs, **opts):
1527 def histedit(ui, repo, *freeargs, **opts):
1527 """interactively edit changeset history
1528 """interactively edit changeset history
1528
1529
1529 This command lets you edit a linear series of changesets (up to
1530 This command lets you edit a linear series of changesets (up to
1530 and including the working directory, which should be clean).
1531 and including the working directory, which should be clean).
1531 You can:
1532 You can:
1532
1533
1533 - `pick` to [re]order a changeset
1534 - `pick` to [re]order a changeset
1534
1535
1535 - `drop` to omit changeset
1536 - `drop` to omit changeset
1536
1537
1537 - `mess` to reword the changeset commit message
1538 - `mess` to reword the changeset commit message
1538
1539
1539 - `fold` to combine it with the preceding changeset (using the later date)
1540 - `fold` to combine it with the preceding changeset (using the later date)
1540
1541
1541 - `roll` like fold, but discarding this commit's description and date
1542 - `roll` like fold, but discarding this commit's description and date
1542
1543
1543 - `edit` to edit this changeset (preserving date)
1544 - `edit` to edit this changeset (preserving date)
1544
1545
1545 - `base` to checkout changeset and apply further changesets from there
1546 - `base` to checkout changeset and apply further changesets from there
1546
1547
1547 There are a number of ways to select the root changeset:
1548 There are a number of ways to select the root changeset:
1548
1549
1549 - Specify ANCESTOR directly
1550 - Specify ANCESTOR directly
1550
1551
1551 - Use --outgoing -- it will be the first linear changeset not
1552 - Use --outgoing -- it will be the first linear changeset not
1552 included in destination. (See :hg:`help config.paths.default-push`)
1553 included in destination. (See :hg:`help config.paths.default-push`)
1553
1554
1554 - Otherwise, the value from the "histedit.defaultrev" config option
1555 - Otherwise, the value from the "histedit.defaultrev" config option
1555 is used as a revset to select the base revision when ANCESTOR is not
1556 is used as a revset to select the base revision when ANCESTOR is not
1556 specified. The first revision returned by the revset is used. By
1557 specified. The first revision returned by the revset is used. By
1557 default, this selects the editable history that is unique to the
1558 default, this selects the editable history that is unique to the
1558 ancestry of the working directory.
1559 ancestry of the working directory.
1559
1560
1560 .. container:: verbose
1561 .. container:: verbose
1561
1562
1562 If you use --outgoing, this command will abort if there are ambiguous
1563 If you use --outgoing, this command will abort if there are ambiguous
1563 outgoing revisions. For example, if there are multiple branches
1564 outgoing revisions. For example, if there are multiple branches
1564 containing outgoing revisions.
1565 containing outgoing revisions.
1565
1566
1566 Use "min(outgoing() and ::.)" or similar revset specification
1567 Use "min(outgoing() and ::.)" or similar revset specification
1567 instead of --outgoing to specify edit target revision exactly in
1568 instead of --outgoing to specify edit target revision exactly in
1568 such ambiguous situation. See :hg:`help revsets` for detail about
1569 such ambiguous situation. See :hg:`help revsets` for detail about
1569 selecting revisions.
1570 selecting revisions.
1570
1571
1571 .. container:: verbose
1572 .. container:: verbose
1572
1573
1573 Examples:
1574 Examples:
1574
1575
1575 - A number of changes have been made.
1576 - A number of changes have been made.
1576 Revision 3 is no longer needed.
1577 Revision 3 is no longer needed.
1577
1578
1578 Start history editing from revision 3::
1579 Start history editing from revision 3::
1579
1580
1580 hg histedit -r 3
1581 hg histedit -r 3
1581
1582
1582 An editor opens, containing the list of revisions,
1583 An editor opens, containing the list of revisions,
1583 with specific actions specified::
1584 with specific actions specified::
1584
1585
1585 pick 5339bf82f0ca 3 Zworgle the foobar
1586 pick 5339bf82f0ca 3 Zworgle the foobar
1586 pick 8ef592ce7cc4 4 Bedazzle the zerlog
1587 pick 8ef592ce7cc4 4 Bedazzle the zerlog
1587 pick 0a9639fcda9d 5 Morgify the cromulancy
1588 pick 0a9639fcda9d 5 Morgify the cromulancy
1588
1589
1589 Additional information about the possible actions
1590 Additional information about the possible actions
1590 to take appears below the list of revisions.
1591 to take appears below the list of revisions.
1591
1592
1592 To remove revision 3 from the history,
1593 To remove revision 3 from the history,
1593 its action (at the beginning of the relevant line)
1594 its action (at the beginning of the relevant line)
1594 is changed to 'drop'::
1595 is changed to 'drop'::
1595
1596
1596 drop 5339bf82f0ca 3 Zworgle the foobar
1597 drop 5339bf82f0ca 3 Zworgle the foobar
1597 pick 8ef592ce7cc4 4 Bedazzle the zerlog
1598 pick 8ef592ce7cc4 4 Bedazzle the zerlog
1598 pick 0a9639fcda9d 5 Morgify the cromulancy
1599 pick 0a9639fcda9d 5 Morgify the cromulancy
1599
1600
1600 - A number of changes have been made.
1601 - A number of changes have been made.
1601 Revision 2 and 4 need to be swapped.
1602 Revision 2 and 4 need to be swapped.
1602
1603
1603 Start history editing from revision 2::
1604 Start history editing from revision 2::
1604
1605
1605 hg histedit -r 2
1606 hg histedit -r 2
1606
1607
1607 An editor opens, containing the list of revisions,
1608 An editor opens, containing the list of revisions,
1608 with specific actions specified::
1609 with specific actions specified::
1609
1610
1610 pick 252a1af424ad 2 Blorb a morgwazzle
1611 pick 252a1af424ad 2 Blorb a morgwazzle
1611 pick 5339bf82f0ca 3 Zworgle the foobar
1612 pick 5339bf82f0ca 3 Zworgle the foobar
1612 pick 8ef592ce7cc4 4 Bedazzle the zerlog
1613 pick 8ef592ce7cc4 4 Bedazzle the zerlog
1613
1614
1614 To swap revision 2 and 4, its lines are swapped
1615 To swap revision 2 and 4, its lines are swapped
1615 in the editor::
1616 in the editor::
1616
1617
1617 pick 8ef592ce7cc4 4 Bedazzle the zerlog
1618 pick 8ef592ce7cc4 4 Bedazzle the zerlog
1618 pick 5339bf82f0ca 3 Zworgle the foobar
1619 pick 5339bf82f0ca 3 Zworgle the foobar
1619 pick 252a1af424ad 2 Blorb a morgwazzle
1620 pick 252a1af424ad 2 Blorb a morgwazzle
1620
1621
1621 Returns 0 on success, 1 if user intervention is required (not only
1622 Returns 0 on success, 1 if user intervention is required (not only
1622 for intentional "edit" command, but also for resolving unexpected
1623 for intentional "edit" command, but also for resolving unexpected
1623 conflicts).
1624 conflicts).
1624 """
1625 """
1625 # kludge: _chistedit only works for starting an edit, not aborting
1626 # kludge: _chistedit only works for starting an edit, not aborting
1626 # or continuing, so fall back to regular _texthistedit for those
1627 # or continuing, so fall back to regular _texthistedit for those
1627 # operations.
1628 # operations.
1628 if ui.interface('histedit') == 'curses' and _getgoal(
1629 if ui.interface('histedit') == 'curses' and _getgoal(
1629 pycompat.byteskwargs(opts)) == goalnew:
1630 pycompat.byteskwargs(opts)) == goalnew:
1630 return _chistedit(ui, repo, *freeargs, **opts)
1631 return _chistedit(ui, repo, *freeargs, **opts)
1631 return _texthistedit(ui, repo, *freeargs, **opts)
1632 return _texthistedit(ui, repo, *freeargs, **opts)
1632
1633
1633 def _texthistedit(ui, repo, *freeargs, **opts):
1634 def _texthistedit(ui, repo, *freeargs, **opts):
1634 state = histeditstate(repo)
1635 state = histeditstate(repo)
1635 with repo.wlock() as wlock, repo.lock() as lock:
1636 with repo.wlock() as wlock, repo.lock() as lock:
1636 state.wlock = wlock
1637 state.wlock = wlock
1637 state.lock = lock
1638 state.lock = lock
1638 _histedit(ui, repo, state, *freeargs, **opts)
1639 _histedit(ui, repo, state, *freeargs, **opts)
1639
1640
1640 goalcontinue = 'continue'
1641 goalcontinue = 'continue'
1641 goalabort = 'abort'
1642 goalabort = 'abort'
1642 goaleditplan = 'edit-plan'
1643 goaleditplan = 'edit-plan'
1643 goalnew = 'new'
1644 goalnew = 'new'
1644
1645
1645 def _getgoal(opts):
1646 def _getgoal(opts):
1646 if opts.get(b'continue'):
1647 if opts.get(b'continue'):
1647 return goalcontinue
1648 return goalcontinue
1648 if opts.get(b'abort'):
1649 if opts.get(b'abort'):
1649 return goalabort
1650 return goalabort
1650 if opts.get(b'edit_plan'):
1651 if opts.get(b'edit_plan'):
1651 return goaleditplan
1652 return goaleditplan
1652 return goalnew
1653 return goalnew
1653
1654
1654 def _readfile(ui, path):
1655 def _readfile(ui, path):
1655 if path == '-':
1656 if path == '-':
1656 with ui.timeblockedsection('histedit'):
1657 with ui.timeblockedsection('histedit'):
1657 return ui.fin.read()
1658 return ui.fin.read()
1658 else:
1659 else:
1659 with open(path, 'rb') as f:
1660 with open(path, 'rb') as f:
1660 return f.read()
1661 return f.read()
1661
1662
1662 def _validateargs(ui, repo, state, freeargs, opts, goal, rules, revs):
1663 def _validateargs(ui, repo, state, freeargs, opts, goal, rules, revs):
1663 # TODO only abort if we try to histedit mq patches, not just
1664 # TODO only abort if we try to histedit mq patches, not just
1664 # blanket if mq patches are applied somewhere
1665 # blanket if mq patches are applied somewhere
1665 mq = getattr(repo, 'mq', None)
1666 mq = getattr(repo, 'mq', None)
1666 if mq and mq.applied:
1667 if mq and mq.applied:
1667 raise error.Abort(_('source has mq patches applied'))
1668 raise error.Abort(_('source has mq patches applied'))
1668
1669
1669 # basic argument incompatibility processing
1670 # basic argument incompatibility processing
1670 outg = opts.get('outgoing')
1671 outg = opts.get('outgoing')
1671 editplan = opts.get('edit_plan')
1672 editplan = opts.get('edit_plan')
1672 abort = opts.get('abort')
1673 abort = opts.get('abort')
1673 force = opts.get('force')
1674 force = opts.get('force')
1674 if force and not outg:
1675 if force and not outg:
1675 raise error.Abort(_('--force only allowed with --outgoing'))
1676 raise error.Abort(_('--force only allowed with --outgoing'))
1676 if goal == 'continue':
1677 if goal == 'continue':
1677 if any((outg, abort, revs, freeargs, rules, editplan)):
1678 if any((outg, abort, revs, freeargs, rules, editplan)):
1678 raise error.Abort(_('no arguments allowed with --continue'))
1679 raise error.Abort(_('no arguments allowed with --continue'))
1679 elif goal == 'abort':
1680 elif goal == 'abort':
1680 if any((outg, revs, freeargs, rules, editplan)):
1681 if any((outg, revs, freeargs, rules, editplan)):
1681 raise error.Abort(_('no arguments allowed with --abort'))
1682 raise error.Abort(_('no arguments allowed with --abort'))
1682 elif goal == 'edit-plan':
1683 elif goal == 'edit-plan':
1683 if any((outg, revs, freeargs)):
1684 if any((outg, revs, freeargs)):
1684 raise error.Abort(_('only --commands argument allowed with '
1685 raise error.Abort(_('only --commands argument allowed with '
1685 '--edit-plan'))
1686 '--edit-plan'))
1686 else:
1687 else:
1687 if state.inprogress():
1688 if state.inprogress():
1688 raise error.Abort(_('history edit already in progress, try '
1689 raise error.Abort(_('history edit already in progress, try '
1689 '--continue or --abort'))
1690 '--continue or --abort'))
1690 if outg:
1691 if outg:
1691 if revs:
1692 if revs:
1692 raise error.Abort(_('no revisions allowed with --outgoing'))
1693 raise error.Abort(_('no revisions allowed with --outgoing'))
1693 if len(freeargs) > 1:
1694 if len(freeargs) > 1:
1694 raise error.Abort(
1695 raise error.Abort(
1695 _('only one repo argument allowed with --outgoing'))
1696 _('only one repo argument allowed with --outgoing'))
1696 else:
1697 else:
1697 revs.extend(freeargs)
1698 revs.extend(freeargs)
1698 if len(revs) == 0:
1699 if len(revs) == 0:
1699 defaultrev = destutil.desthistedit(ui, repo)
1700 defaultrev = destutil.desthistedit(ui, repo)
1700 if defaultrev is not None:
1701 if defaultrev is not None:
1701 revs.append(defaultrev)
1702 revs.append(defaultrev)
1702
1703
1703 if len(revs) != 1:
1704 if len(revs) != 1:
1704 raise error.Abort(
1705 raise error.Abort(
1705 _('histedit requires exactly one ancestor revision'))
1706 _('histedit requires exactly one ancestor revision'))
1706
1707
1707 def _histedit(ui, repo, state, *freeargs, **opts):
1708 def _histedit(ui, repo, state, *freeargs, **opts):
1708 opts = pycompat.byteskwargs(opts)
1709 opts = pycompat.byteskwargs(opts)
1709 fm = ui.formatter('histedit', opts)
1710 fm = ui.formatter('histedit', opts)
1710 fm.startitem()
1711 fm.startitem()
1711 goal = _getgoal(opts)
1712 goal = _getgoal(opts)
1712 revs = opts.get('rev', [])
1713 revs = opts.get('rev', [])
1713 nobackup = not ui.configbool('rewrite', 'backup-bundle')
1714 nobackup = not ui.configbool('rewrite', 'backup-bundle')
1714 rules = opts.get('commands', '')
1715 rules = opts.get('commands', '')
1715 state.keep = opts.get('keep', False)
1716 state.keep = opts.get('keep', False)
1716
1717
1717 _validateargs(ui, repo, state, freeargs, opts, goal, rules, revs)
1718 _validateargs(ui, repo, state, freeargs, opts, goal, rules, revs)
1718
1719
1719 hastags = False
1720 hastags = False
1720 if revs:
1721 if revs:
1721 revs = scmutil.revrange(repo, revs)
1722 revs = scmutil.revrange(repo, revs)
1722 ctxs = [repo[rev] for rev in revs]
1723 ctxs = [repo[rev] for rev in revs]
1723 for ctx in ctxs:
1724 for ctx in ctxs:
1724 tags = [tag for tag in ctx.tags() if tag != 'tip']
1725 tags = [tag for tag in ctx.tags() if tag != 'tip']
1725 if not hastags:
1726 if not hastags:
1726 hastags = len(tags)
1727 hastags = len(tags)
1727 if hastags:
1728 if hastags:
1728 if ui.promptchoice(_('warning: tags associated with the given'
1729 if ui.promptchoice(_('warning: tags associated with the given'
1729 ' changeset will be lost after histedit.\n'
1730 ' changeset will be lost after histedit.\n'
1730 'do you want to continue (yN)? $$ &Yes $$ &No'),
1731 'do you want to continue (yN)? $$ &Yes $$ &No'),
1731 default=1):
1732 default=1):
1732 raise error.Abort(_('histedit cancelled\n'))
1733 raise error.Abort(_('histedit cancelled\n'))
1733 # rebuild state
1734 # rebuild state
1734 if goal == goalcontinue:
1735 if goal == goalcontinue:
1735 state.read()
1736 state.read()
1736 state = bootstrapcontinue(ui, state, opts)
1737 state = bootstrapcontinue(ui, state, opts)
1737 elif goal == goaleditplan:
1738 elif goal == goaleditplan:
1738 _edithisteditplan(ui, repo, state, rules)
1739 _edithisteditplan(ui, repo, state, rules)
1739 return
1740 return
1740 elif goal == goalabort:
1741 elif goal == goalabort:
1741 _aborthistedit(ui, repo, state, nobackup=nobackup)
1742 _aborthistedit(ui, repo, state, nobackup=nobackup)
1742 return
1743 return
1743 else:
1744 else:
1744 # goal == goalnew
1745 # goal == goalnew
1745 _newhistedit(ui, repo, state, revs, freeargs, opts)
1746 _newhistedit(ui, repo, state, revs, freeargs, opts)
1746
1747
1747 _continuehistedit(ui, repo, state)
1748 _continuehistedit(ui, repo, state)
1748 _finishhistedit(ui, repo, state, fm)
1749 _finishhistedit(ui, repo, state, fm)
1749 fm.end()
1750 fm.end()
1750
1751
1751 def _continuehistedit(ui, repo, state):
1752 def _continuehistedit(ui, repo, state):
1752 """This function runs after either:
1753 """This function runs after either:
1753 - bootstrapcontinue (if the goal is 'continue')
1754 - bootstrapcontinue (if the goal is 'continue')
1754 - _newhistedit (if the goal is 'new')
1755 - _newhistedit (if the goal is 'new')
1755 """
1756 """
1756 # preprocess rules so that we can hide inner folds from the user
1757 # preprocess rules so that we can hide inner folds from the user
1757 # and only show one editor
1758 # and only show one editor
1758 actions = state.actions[:]
1759 actions = state.actions[:]
1759 for idx, (action, nextact) in enumerate(
1760 for idx, (action, nextact) in enumerate(
1760 zip(actions, actions[1:] + [None])):
1761 zip(actions, actions[1:] + [None])):
1761 if action.verb == 'fold' and nextact and nextact.verb == 'fold':
1762 if action.verb == 'fold' and nextact and nextact.verb == 'fold':
1762 state.actions[idx].__class__ = _multifold
1763 state.actions[idx].__class__ = _multifold
1763
1764
1764 # Force an initial state file write, so the user can run --abort/continue
1765 # Force an initial state file write, so the user can run --abort/continue
1765 # even if there's an exception before the first transaction serialize.
1766 # even if there's an exception before the first transaction serialize.
1766 state.write()
1767 state.write()
1767
1768
1768 tr = None
1769 tr = None
1769 # Don't use singletransaction by default since it rolls the entire
1770 # Don't use singletransaction by default since it rolls the entire
1770 # transaction back if an unexpected exception happens (like a
1771 # transaction back if an unexpected exception happens (like a
1771 # pretxncommit hook throws, or the user aborts the commit msg editor).
1772 # pretxncommit hook throws, or the user aborts the commit msg editor).
1772 if ui.configbool("histedit", "singletransaction"):
1773 if ui.configbool("histedit", "singletransaction"):
1773 # Don't use a 'with' for the transaction, since actions may close
1774 # Don't use a 'with' for the transaction, since actions may close
1774 # and reopen a transaction. For example, if the action executes an
1775 # and reopen a transaction. For example, if the action executes an
1775 # external process it may choose to commit the transaction first.
1776 # external process it may choose to commit the transaction first.
1776 tr = repo.transaction('histedit')
1777 tr = repo.transaction('histedit')
1777 progress = ui.makeprogress(_("editing"), unit=_('changes'),
1778 progress = ui.makeprogress(_("editing"), unit=_('changes'),
1778 total=len(state.actions))
1779 total=len(state.actions))
1779 with progress, util.acceptintervention(tr):
1780 with progress, util.acceptintervention(tr):
1780 while state.actions:
1781 while state.actions:
1781 state.write(tr=tr)
1782 state.write(tr=tr)
1782 actobj = state.actions[0]
1783 actobj = state.actions[0]
1783 progress.increment(item=actobj.torule())
1784 progress.increment(item=actobj.torule())
1784 ui.debug('histedit: processing %s %s\n' % (actobj.verb,
1785 ui.debug('histedit: processing %s %s\n' % (actobj.verb,
1785 actobj.torule()))
1786 actobj.torule()))
1786 parentctx, replacement_ = actobj.run()
1787 parentctx, replacement_ = actobj.run()
1787 state.parentctxnode = parentctx.node()
1788 state.parentctxnode = parentctx.node()
1788 state.replacements.extend(replacement_)
1789 state.replacements.extend(replacement_)
1789 state.actions.pop(0)
1790 state.actions.pop(0)
1790
1791
1791 state.write()
1792 state.write()
1792
1793
1793 def _finishhistedit(ui, repo, state, fm):
1794 def _finishhistedit(ui, repo, state, fm):
1794 """This action runs when histedit is finishing its session"""
1795 """This action runs when histedit is finishing its session"""
1795 hg.updaterepo(repo, state.parentctxnode, overwrite=False)
1796 hg.updaterepo(repo, state.parentctxnode, overwrite=False)
1796
1797
1797 mapping, tmpnodes, created, ntm = processreplacement(state)
1798 mapping, tmpnodes, created, ntm = processreplacement(state)
1798 if mapping:
1799 if mapping:
1799 for prec, succs in mapping.iteritems():
1800 for prec, succs in mapping.iteritems():
1800 if not succs:
1801 if not succs:
1801 ui.debug('histedit: %s is dropped\n' % node.short(prec))
1802 ui.debug('histedit: %s is dropped\n' % node.short(prec))
1802 else:
1803 else:
1803 ui.debug('histedit: %s is replaced by %s\n' % (
1804 ui.debug('histedit: %s is replaced by %s\n' % (
1804 node.short(prec), node.short(succs[0])))
1805 node.short(prec), node.short(succs[0])))
1805 if len(succs) > 1:
1806 if len(succs) > 1:
1806 m = 'histedit: %s'
1807 m = 'histedit: %s'
1807 for n in succs[1:]:
1808 for n in succs[1:]:
1808 ui.debug(m % node.short(n))
1809 ui.debug(m % node.short(n))
1809
1810
1810 if not state.keep:
1811 if not state.keep:
1811 if mapping:
1812 if mapping:
1812 movetopmostbookmarks(repo, state.topmost, ntm)
1813 movetopmostbookmarks(repo, state.topmost, ntm)
1813 # TODO update mq state
1814 # TODO update mq state
1814 else:
1815 else:
1815 mapping = {}
1816 mapping = {}
1816
1817
1817 for n in tmpnodes:
1818 for n in tmpnodes:
1818 if n in repo:
1819 if n in repo:
1819 mapping[n] = ()
1820 mapping[n] = ()
1820
1821
1821 # remove entries about unknown nodes
1822 # remove entries about unknown nodes
1822 nodemap = repo.unfiltered().changelog.nodemap
1823 nodemap = repo.unfiltered().changelog.nodemap
1823 mapping = {k: v for k, v in mapping.items()
1824 mapping = {k: v for k, v in mapping.items()
1824 if k in nodemap and all(n in nodemap for n in v)}
1825 if k in nodemap and all(n in nodemap for n in v)}
1825 scmutil.cleanupnodes(repo, mapping, 'histedit')
1826 scmutil.cleanupnodes(repo, mapping, 'histedit')
1826 hf = fm.hexfunc
1827 hf = fm.hexfunc
1827 fl = fm.formatlist
1828 fl = fm.formatlist
1828 fd = fm.formatdict
1829 fd = fm.formatdict
1829 nodechanges = fd({hf(oldn): fl([hf(n) for n in newn], name='node')
1830 nodechanges = fd({hf(oldn): fl([hf(n) for n in newn], name='node')
1830 for oldn, newn in mapping.iteritems()},
1831 for oldn, newn in mapping.iteritems()},
1831 key="oldnode", value="newnodes")
1832 key="oldnode", value="newnodes")
1832 fm.data(nodechanges=nodechanges)
1833 fm.data(nodechanges=nodechanges)
1833
1834
1834 state.clear()
1835 state.clear()
1835 if os.path.exists(repo.sjoin('undo')):
1836 if os.path.exists(repo.sjoin('undo')):
1836 os.unlink(repo.sjoin('undo'))
1837 os.unlink(repo.sjoin('undo'))
1837 if repo.vfs.exists('histedit-last-edit.txt'):
1838 if repo.vfs.exists('histedit-last-edit.txt'):
1838 repo.vfs.unlink('histedit-last-edit.txt')
1839 repo.vfs.unlink('histedit-last-edit.txt')
1839
1840
1840 def _aborthistedit(ui, repo, state, nobackup=False):
1841 def _aborthistedit(ui, repo, state, nobackup=False):
1841 try:
1842 try:
1842 state.read()
1843 state.read()
1843 __, leafs, tmpnodes, __ = processreplacement(state)
1844 __, leafs, tmpnodes, __ = processreplacement(state)
1844 ui.debug('restore wc to old parent %s\n'
1845 ui.debug('restore wc to old parent %s\n'
1845 % node.short(state.topmost))
1846 % node.short(state.topmost))
1846
1847
1847 # Recover our old commits if necessary
1848 # Recover our old commits if necessary
1848 if not state.topmost in repo and state.backupfile:
1849 if not state.topmost in repo and state.backupfile:
1849 backupfile = repo.vfs.join(state.backupfile)
1850 backupfile = repo.vfs.join(state.backupfile)
1850 f = hg.openpath(ui, backupfile)
1851 f = hg.openpath(ui, backupfile)
1851 gen = exchange.readbundle(ui, f, backupfile)
1852 gen = exchange.readbundle(ui, f, backupfile)
1852 with repo.transaction('histedit.abort') as tr:
1853 with repo.transaction('histedit.abort') as tr:
1853 bundle2.applybundle(repo, gen, tr, source='histedit',
1854 bundle2.applybundle(repo, gen, tr, source='histedit',
1854 url='bundle:' + backupfile)
1855 url='bundle:' + backupfile)
1855
1856
1856 os.remove(backupfile)
1857 os.remove(backupfile)
1857
1858
1858 # check whether we should update away
1859 # check whether we should update away
1859 if repo.unfiltered().revs('parents() and (%n or %ln::)',
1860 if repo.unfiltered().revs('parents() and (%n or %ln::)',
1860 state.parentctxnode, leafs | tmpnodes):
1861 state.parentctxnode, leafs | tmpnodes):
1861 hg.clean(repo, state.topmost, show_stats=True, quietempty=True)
1862 hg.clean(repo, state.topmost, show_stats=True, quietempty=True)
1862 cleanupnode(ui, repo, tmpnodes, nobackup=nobackup)
1863 cleanupnode(ui, repo, tmpnodes, nobackup=nobackup)
1863 cleanupnode(ui, repo, leafs, nobackup=nobackup)
1864 cleanupnode(ui, repo, leafs, nobackup=nobackup)
1864 except Exception:
1865 except Exception:
1865 if state.inprogress():
1866 if state.inprogress():
1866 ui.warn(_('warning: encountered an exception during histedit '
1867 ui.warn(_('warning: encountered an exception during histedit '
1867 '--abort; the repository may not have been completely '
1868 '--abort; the repository may not have been completely '
1868 'cleaned up\n'))
1869 'cleaned up\n'))
1869 raise
1870 raise
1870 finally:
1871 finally:
1871 state.clear()
1872 state.clear()
1872
1873
1873 def _edithisteditplan(ui, repo, state, rules):
1874 def _edithisteditplan(ui, repo, state, rules):
1874 state.read()
1875 state.read()
1875 if not rules:
1876 if not rules:
1876 comment = geteditcomment(ui,
1877 comment = geteditcomment(ui,
1877 node.short(state.parentctxnode),
1878 node.short(state.parentctxnode),
1878 node.short(state.topmost))
1879 node.short(state.topmost))
1879 rules = ruleeditor(repo, ui, state.actions, comment)
1880 rules = ruleeditor(repo, ui, state.actions, comment)
1880 else:
1881 else:
1881 rules = _readfile(ui, rules)
1882 rules = _readfile(ui, rules)
1882 actions = parserules(rules, state)
1883 actions = parserules(rules, state)
1883 ctxs = [repo[act.node]
1884 ctxs = [repo[act.node]
1884 for act in state.actions if act.node]
1885 for act in state.actions if act.node]
1885 warnverifyactions(ui, repo, actions, state, ctxs)
1886 warnverifyactions(ui, repo, actions, state, ctxs)
1886 state.actions = actions
1887 state.actions = actions
1887 state.write()
1888 state.write()
1888
1889
1889 def _newhistedit(ui, repo, state, revs, freeargs, opts):
1890 def _newhistedit(ui, repo, state, revs, freeargs, opts):
1890 outg = opts.get('outgoing')
1891 outg = opts.get('outgoing')
1891 rules = opts.get('commands', '')
1892 rules = opts.get('commands', '')
1892 force = opts.get('force')
1893 force = opts.get('force')
1893
1894
1894 cmdutil.checkunfinished(repo)
1895 cmdutil.checkunfinished(repo)
1895 cmdutil.bailifchanged(repo)
1896 cmdutil.bailifchanged(repo)
1896
1897
1897 topmost = repo.dirstate.p1()
1898 topmost = repo.dirstate.p1()
1898 if outg:
1899 if outg:
1899 if freeargs:
1900 if freeargs:
1900 remote = freeargs[0]
1901 remote = freeargs[0]
1901 else:
1902 else:
1902 remote = None
1903 remote = None
1903 root = findoutgoing(ui, repo, remote, force, opts)
1904 root = findoutgoing(ui, repo, remote, force, opts)
1904 else:
1905 else:
1905 rr = list(repo.set('roots(%ld)', scmutil.revrange(repo, revs)))
1906 rr = list(repo.set('roots(%ld)', scmutil.revrange(repo, revs)))
1906 if len(rr) != 1:
1907 if len(rr) != 1:
1907 raise error.Abort(_('The specified revisions must have '
1908 raise error.Abort(_('The specified revisions must have '
1908 'exactly one common root'))
1909 'exactly one common root'))
1909 root = rr[0].node()
1910 root = rr[0].node()
1910
1911
1911 revs = between(repo, root, topmost, state.keep)
1912 revs = between(repo, root, topmost, state.keep)
1912 if not revs:
1913 if not revs:
1913 raise error.Abort(_('%s is not an ancestor of working directory') %
1914 raise error.Abort(_('%s is not an ancestor of working directory') %
1914 node.short(root))
1915 node.short(root))
1915
1916
1916 ctxs = [repo[r] for r in revs]
1917 ctxs = [repo[r] for r in revs]
1917 if not rules:
1918 if not rules:
1918 comment = geteditcomment(ui, node.short(root), node.short(topmost))
1919 comment = geteditcomment(ui, node.short(root), node.short(topmost))
1919 actions = [pick(state, r) for r in revs]
1920 actions = [pick(state, r) for r in revs]
1920 rules = ruleeditor(repo, ui, actions, comment)
1921 rules = ruleeditor(repo, ui, actions, comment)
1921 else:
1922 else:
1922 rules = _readfile(ui, rules)
1923 rules = _readfile(ui, rules)
1923 actions = parserules(rules, state)
1924 actions = parserules(rules, state)
1924 warnverifyactions(ui, repo, actions, state, ctxs)
1925 warnverifyactions(ui, repo, actions, state, ctxs)
1925
1926
1926 parentctxnode = repo[root].p1().node()
1927 parentctxnode = repo[root].p1().node()
1927
1928
1928 state.parentctxnode = parentctxnode
1929 state.parentctxnode = parentctxnode
1929 state.actions = actions
1930 state.actions = actions
1930 state.topmost = topmost
1931 state.topmost = topmost
1931 state.replacements = []
1932 state.replacements = []
1932
1933
1933 ui.log("histedit", "%d actions to histedit\n", len(actions),
1934 ui.log("histedit", "%d actions to histedit\n", len(actions),
1934 histedit_num_actions=len(actions))
1935 histedit_num_actions=len(actions))
1935
1936
1936 # Create a backup so we can always abort completely.
1937 # Create a backup so we can always abort completely.
1937 backupfile = None
1938 backupfile = None
1938 if not obsolete.isenabled(repo, obsolete.createmarkersopt):
1939 if not obsolete.isenabled(repo, obsolete.createmarkersopt):
1939 backupfile = repair.backupbundle(repo, [parentctxnode],
1940 backupfile = repair.backupbundle(repo, [parentctxnode],
1940 [topmost], root, 'histedit')
1941 [topmost], root, 'histedit')
1941 state.backupfile = backupfile
1942 state.backupfile = backupfile
1942
1943
1943 def _getsummary(ctx):
1944 def _getsummary(ctx):
1944 # a common pattern is to extract the summary but default to the empty
1945 # a common pattern is to extract the summary but default to the empty
1945 # string
1946 # string
1946 summary = ctx.description() or ''
1947 summary = ctx.description() or ''
1947 if summary:
1948 if summary:
1948 summary = summary.splitlines()[0]
1949 summary = summary.splitlines()[0]
1949 return summary
1950 return summary
1950
1951
1951 def bootstrapcontinue(ui, state, opts):
1952 def bootstrapcontinue(ui, state, opts):
1952 repo = state.repo
1953 repo = state.repo
1953
1954
1954 ms = mergemod.mergestate.read(repo)
1955 ms = mergemod.mergestate.read(repo)
1955 mergeutil.checkunresolved(ms)
1956 mergeutil.checkunresolved(ms)
1956
1957
1957 if state.actions:
1958 if state.actions:
1958 actobj = state.actions.pop(0)
1959 actobj = state.actions.pop(0)
1959
1960
1960 if _isdirtywc(repo):
1961 if _isdirtywc(repo):
1961 actobj.continuedirty()
1962 actobj.continuedirty()
1962 if _isdirtywc(repo):
1963 if _isdirtywc(repo):
1963 abortdirty()
1964 abortdirty()
1964
1965
1965 parentctx, replacements = actobj.continueclean()
1966 parentctx, replacements = actobj.continueclean()
1966
1967
1967 state.parentctxnode = parentctx.node()
1968 state.parentctxnode = parentctx.node()
1968 state.replacements.extend(replacements)
1969 state.replacements.extend(replacements)
1969
1970
1970 return state
1971 return state
1971
1972
1972 def between(repo, old, new, keep):
1973 def between(repo, old, new, keep):
1973 """select and validate the set of revision to edit
1974 """select and validate the set of revision to edit
1974
1975
1975 When keep is false, the specified set can't have children."""
1976 When keep is false, the specified set can't have children."""
1976 revs = repo.revs('%n::%n', old, new)
1977 revs = repo.revs('%n::%n', old, new)
1977 if revs and not keep:
1978 if revs and not keep:
1978 if (not obsolete.isenabled(repo, obsolete.allowunstableopt) and
1979 if (not obsolete.isenabled(repo, obsolete.allowunstableopt) and
1979 repo.revs('(%ld::) - (%ld)', revs, revs)):
1980 repo.revs('(%ld::) - (%ld)', revs, revs)):
1980 raise error.Abort(_('can only histedit a changeset together '
1981 raise error.Abort(_('can only histedit a changeset together '
1981 'with all its descendants'))
1982 'with all its descendants'))
1982 if repo.revs('(%ld) and merge()', revs):
1983 if repo.revs('(%ld) and merge()', revs):
1983 raise error.Abort(_('cannot edit history that contains merges'))
1984 raise error.Abort(_('cannot edit history that contains merges'))
1984 root = repo[revs.first()] # list is already sorted by repo.revs()
1985 root = repo[revs.first()] # list is already sorted by repo.revs()
1985 if not root.mutable():
1986 if not root.mutable():
1986 raise error.Abort(_('cannot edit public changeset: %s') % root,
1987 raise error.Abort(_('cannot edit public changeset: %s') % root,
1987 hint=_("see 'hg help phases' for details"))
1988 hint=_("see 'hg help phases' for details"))
1988 return pycompat.maplist(repo.changelog.node, revs)
1989 return pycompat.maplist(repo.changelog.node, revs)
1989
1990
1990 def ruleeditor(repo, ui, actions, editcomment=""):
1991 def ruleeditor(repo, ui, actions, editcomment=""):
1991 """open an editor to edit rules
1992 """open an editor to edit rules
1992
1993
1993 rules are in the format [ [act, ctx], ...] like in state.rules
1994 rules are in the format [ [act, ctx], ...] like in state.rules
1994 """
1995 """
1995 if repo.ui.configbool("experimental", "histedit.autoverb"):
1996 if repo.ui.configbool("experimental", "histedit.autoverb"):
1996 newact = util.sortdict()
1997 newact = util.sortdict()
1997 for act in actions:
1998 for act in actions:
1998 ctx = repo[act.node]
1999 ctx = repo[act.node]
1999 summary = _getsummary(ctx)
2000 summary = _getsummary(ctx)
2000 fword = summary.split(' ', 1)[0].lower()
2001 fword = summary.split(' ', 1)[0].lower()
2001 added = False
2002 added = False
2002
2003
2003 # if it doesn't end with the special character '!' just skip this
2004 # if it doesn't end with the special character '!' just skip this
2004 if fword.endswith('!'):
2005 if fword.endswith('!'):
2005 fword = fword[:-1]
2006 fword = fword[:-1]
2006 if fword in primaryactions | secondaryactions | tertiaryactions:
2007 if fword in primaryactions | secondaryactions | tertiaryactions:
2007 act.verb = fword
2008 act.verb = fword
2008 # get the target summary
2009 # get the target summary
2009 tsum = summary[len(fword) + 1:].lstrip()
2010 tsum = summary[len(fword) + 1:].lstrip()
2010 # safe but slow: reverse iterate over the actions so we
2011 # safe but slow: reverse iterate over the actions so we
2011 # don't clash on two commits having the same summary
2012 # don't clash on two commits having the same summary
2012 for na, l in reversed(list(newact.iteritems())):
2013 for na, l in reversed(list(newact.iteritems())):
2013 actx = repo[na.node]
2014 actx = repo[na.node]
2014 asum = _getsummary(actx)
2015 asum = _getsummary(actx)
2015 if asum == tsum:
2016 if asum == tsum:
2016 added = True
2017 added = True
2017 l.append(act)
2018 l.append(act)
2018 break
2019 break
2019
2020
2020 if not added:
2021 if not added:
2021 newact[act] = []
2022 newact[act] = []
2022
2023
2023 # copy over and flatten the new list
2024 # copy over and flatten the new list
2024 actions = []
2025 actions = []
2025 for na, l in newact.iteritems():
2026 for na, l in newact.iteritems():
2026 actions.append(na)
2027 actions.append(na)
2027 actions += l
2028 actions += l
2028
2029
2029 rules = '\n'.join([act.torule() for act in actions])
2030 rules = '\n'.join([act.torule() for act in actions])
2030 rules += '\n\n'
2031 rules += '\n\n'
2031 rules += editcomment
2032 rules += editcomment
2032 rules = ui.edit(rules, ui.username(), {'prefix': 'histedit'},
2033 rules = ui.edit(rules, ui.username(), {'prefix': 'histedit'},
2033 repopath=repo.path, action='histedit')
2034 repopath=repo.path, action='histedit')
2034
2035
2035 # Save edit rules in .hg/histedit-last-edit.txt in case
2036 # Save edit rules in .hg/histedit-last-edit.txt in case
2036 # the user needs to ask for help after something
2037 # the user needs to ask for help after something
2037 # surprising happens.
2038 # surprising happens.
2038 with repo.vfs('histedit-last-edit.txt', 'wb') as f:
2039 with repo.vfs('histedit-last-edit.txt', 'wb') as f:
2039 f.write(rules)
2040 f.write(rules)
2040
2041
2041 return rules
2042 return rules
2042
2043
2043 def parserules(rules, state):
2044 def parserules(rules, state):
2044 """Read the histedit rules string and return list of action objects """
2045 """Read the histedit rules string and return list of action objects """
2045 rules = [l for l in (r.strip() for r in rules.splitlines())
2046 rules = [l for l in (r.strip() for r in rules.splitlines())
2046 if l and not l.startswith('#')]
2047 if l and not l.startswith('#')]
2047 actions = []
2048 actions = []
2048 for r in rules:
2049 for r in rules:
2049 if ' ' not in r:
2050 if ' ' not in r:
2050 raise error.ParseError(_('malformed line "%s"') % r)
2051 raise error.ParseError(_('malformed line "%s"') % r)
2051 verb, rest = r.split(' ', 1)
2052 verb, rest = r.split(' ', 1)
2052
2053
2053 if verb not in actiontable:
2054 if verb not in actiontable:
2054 raise error.ParseError(_('unknown action "%s"') % verb)
2055 raise error.ParseError(_('unknown action "%s"') % verb)
2055
2056
2056 action = actiontable[verb].fromrule(state, rest)
2057 action = actiontable[verb].fromrule(state, rest)
2057 actions.append(action)
2058 actions.append(action)
2058 return actions
2059 return actions
2059
2060
2060 def warnverifyactions(ui, repo, actions, state, ctxs):
2061 def warnverifyactions(ui, repo, actions, state, ctxs):
2061 try:
2062 try:
2062 verifyactions(actions, state, ctxs)
2063 verifyactions(actions, state, ctxs)
2063 except error.ParseError:
2064 except error.ParseError:
2064 if repo.vfs.exists('histedit-last-edit.txt'):
2065 if repo.vfs.exists('histedit-last-edit.txt'):
2065 ui.warn(_('warning: histedit rules saved '
2066 ui.warn(_('warning: histedit rules saved '
2066 'to: .hg/histedit-last-edit.txt\n'))
2067 'to: .hg/histedit-last-edit.txt\n'))
2067 raise
2068 raise
2068
2069
2069 def verifyactions(actions, state, ctxs):
2070 def verifyactions(actions, state, ctxs):
2070 """Verify that there exists exactly one action per given changeset and
2071 """Verify that there exists exactly one action per given changeset and
2071 other constraints.
2072 other constraints.
2072
2073
2073 Will abort if there are to many or too few rules, a malformed rule,
2074 Will abort if there are to many or too few rules, a malformed rule,
2074 or a rule on a changeset outside of the user-given range.
2075 or a rule on a changeset outside of the user-given range.
2075 """
2076 """
2076 expected = set(c.node() for c in ctxs)
2077 expected = set(c.node() for c in ctxs)
2077 seen = set()
2078 seen = set()
2078 prev = None
2079 prev = None
2079
2080
2080 if actions and actions[0].verb in ['roll', 'fold']:
2081 if actions and actions[0].verb in ['roll', 'fold']:
2081 raise error.ParseError(_('first changeset cannot use verb "%s"') %
2082 raise error.ParseError(_('first changeset cannot use verb "%s"') %
2082 actions[0].verb)
2083 actions[0].verb)
2083
2084
2084 for action in actions:
2085 for action in actions:
2085 action.verify(prev, expected, seen)
2086 action.verify(prev, expected, seen)
2086 prev = action
2087 prev = action
2087 if action.node is not None:
2088 if action.node is not None:
2088 seen.add(action.node)
2089 seen.add(action.node)
2089 missing = sorted(expected - seen) # sort to stabilize output
2090 missing = sorted(expected - seen) # sort to stabilize output
2090
2091
2091 if state.repo.ui.configbool('histedit', 'dropmissing'):
2092 if state.repo.ui.configbool('histedit', 'dropmissing'):
2092 if len(actions) == 0:
2093 if len(actions) == 0:
2093 raise error.ParseError(_('no rules provided'),
2094 raise error.ParseError(_('no rules provided'),
2094 hint=_('use strip extension to remove commits'))
2095 hint=_('use strip extension to remove commits'))
2095
2096
2096 drops = [drop(state, n) for n in missing]
2097 drops = [drop(state, n) for n in missing]
2097 # put the in the beginning so they execute immediately and
2098 # put the in the beginning so they execute immediately and
2098 # don't show in the edit-plan in the future
2099 # don't show in the edit-plan in the future
2099 actions[:0] = drops
2100 actions[:0] = drops
2100 elif missing:
2101 elif missing:
2101 raise error.ParseError(_('missing rules for changeset %s') %
2102 raise error.ParseError(_('missing rules for changeset %s') %
2102 node.short(missing[0]),
2103 node.short(missing[0]),
2103 hint=_('use "drop %s" to discard, see also: '
2104 hint=_('use "drop %s" to discard, see also: '
2104 "'hg help -e histedit.config'")
2105 "'hg help -e histedit.config'")
2105 % node.short(missing[0]))
2106 % node.short(missing[0]))
2106
2107
2107 def adjustreplacementsfrommarkers(repo, oldreplacements):
2108 def adjustreplacementsfrommarkers(repo, oldreplacements):
2108 """Adjust replacements from obsolescence markers
2109 """Adjust replacements from obsolescence markers
2109
2110
2110 Replacements structure is originally generated based on
2111 Replacements structure is originally generated based on
2111 histedit's state and does not account for changes that are
2112 histedit's state and does not account for changes that are
2112 not recorded there. This function fixes that by adding
2113 not recorded there. This function fixes that by adding
2113 data read from obsolescence markers"""
2114 data read from obsolescence markers"""
2114 if not obsolete.isenabled(repo, obsolete.createmarkersopt):
2115 if not obsolete.isenabled(repo, obsolete.createmarkersopt):
2115 return oldreplacements
2116 return oldreplacements
2116
2117
2117 unfi = repo.unfiltered()
2118 unfi = repo.unfiltered()
2118 nm = unfi.changelog.nodemap
2119 nm = unfi.changelog.nodemap
2119 obsstore = repo.obsstore
2120 obsstore = repo.obsstore
2120 newreplacements = list(oldreplacements)
2121 newreplacements = list(oldreplacements)
2121 oldsuccs = [r[1] for r in oldreplacements]
2122 oldsuccs = [r[1] for r in oldreplacements]
2122 # successors that have already been added to succstocheck once
2123 # successors that have already been added to succstocheck once
2123 seensuccs = set().union(*oldsuccs) # create a set from an iterable of tuples
2124 seensuccs = set().union(*oldsuccs) # create a set from an iterable of tuples
2124 succstocheck = list(seensuccs)
2125 succstocheck = list(seensuccs)
2125 while succstocheck:
2126 while succstocheck:
2126 n = succstocheck.pop()
2127 n = succstocheck.pop()
2127 missing = nm.get(n) is None
2128 missing = nm.get(n) is None
2128 markers = obsstore.successors.get(n, ())
2129 markers = obsstore.successors.get(n, ())
2129 if missing and not markers:
2130 if missing and not markers:
2130 # dead end, mark it as such
2131 # dead end, mark it as such
2131 newreplacements.append((n, ()))
2132 newreplacements.append((n, ()))
2132 for marker in markers:
2133 for marker in markers:
2133 nsuccs = marker[1]
2134 nsuccs = marker[1]
2134 newreplacements.append((n, nsuccs))
2135 newreplacements.append((n, nsuccs))
2135 for nsucc in nsuccs:
2136 for nsucc in nsuccs:
2136 if nsucc not in seensuccs:
2137 if nsucc not in seensuccs:
2137 seensuccs.add(nsucc)
2138 seensuccs.add(nsucc)
2138 succstocheck.append(nsucc)
2139 succstocheck.append(nsucc)
2139
2140
2140 return newreplacements
2141 return newreplacements
2141
2142
2142 def processreplacement(state):
2143 def processreplacement(state):
2143 """process the list of replacements to return
2144 """process the list of replacements to return
2144
2145
2145 1) the final mapping between original and created nodes
2146 1) the final mapping between original and created nodes
2146 2) the list of temporary node created by histedit
2147 2) the list of temporary node created by histedit
2147 3) the list of new commit created by histedit"""
2148 3) the list of new commit created by histedit"""
2148 replacements = adjustreplacementsfrommarkers(state.repo, state.replacements)
2149 replacements = adjustreplacementsfrommarkers(state.repo, state.replacements)
2149 allsuccs = set()
2150 allsuccs = set()
2150 replaced = set()
2151 replaced = set()
2151 fullmapping = {}
2152 fullmapping = {}
2152 # initialize basic set
2153 # initialize basic set
2153 # fullmapping records all operations recorded in replacement
2154 # fullmapping records all operations recorded in replacement
2154 for rep in replacements:
2155 for rep in replacements:
2155 allsuccs.update(rep[1])
2156 allsuccs.update(rep[1])
2156 replaced.add(rep[0])
2157 replaced.add(rep[0])
2157 fullmapping.setdefault(rep[0], set()).update(rep[1])
2158 fullmapping.setdefault(rep[0], set()).update(rep[1])
2158 new = allsuccs - replaced
2159 new = allsuccs - replaced
2159 tmpnodes = allsuccs & replaced
2160 tmpnodes = allsuccs & replaced
2160 # Reduce content fullmapping into direct relation between original nodes
2161 # Reduce content fullmapping into direct relation between original nodes
2161 # and final node created during history edition
2162 # and final node created during history edition
2162 # Dropped changeset are replaced by an empty list
2163 # Dropped changeset are replaced by an empty list
2163 toproceed = set(fullmapping)
2164 toproceed = set(fullmapping)
2164 final = {}
2165 final = {}
2165 while toproceed:
2166 while toproceed:
2166 for x in list(toproceed):
2167 for x in list(toproceed):
2167 succs = fullmapping[x]
2168 succs = fullmapping[x]
2168 for s in list(succs):
2169 for s in list(succs):
2169 if s in toproceed:
2170 if s in toproceed:
2170 # non final node with unknown closure
2171 # non final node with unknown closure
2171 # We can't process this now
2172 # We can't process this now
2172 break
2173 break
2173 elif s in final:
2174 elif s in final:
2174 # non final node, replace with closure
2175 # non final node, replace with closure
2175 succs.remove(s)
2176 succs.remove(s)
2176 succs.update(final[s])
2177 succs.update(final[s])
2177 else:
2178 else:
2178 final[x] = succs
2179 final[x] = succs
2179 toproceed.remove(x)
2180 toproceed.remove(x)
2180 # remove tmpnodes from final mapping
2181 # remove tmpnodes from final mapping
2181 for n in tmpnodes:
2182 for n in tmpnodes:
2182 del final[n]
2183 del final[n]
2183 # we expect all changes involved in final to exist in the repo
2184 # we expect all changes involved in final to exist in the repo
2184 # turn `final` into list (topologically sorted)
2185 # turn `final` into list (topologically sorted)
2185 nm = state.repo.changelog.nodemap
2186 nm = state.repo.changelog.nodemap
2186 for prec, succs in final.items():
2187 for prec, succs in final.items():
2187 final[prec] = sorted(succs, key=nm.get)
2188 final[prec] = sorted(succs, key=nm.get)
2188
2189
2189 # computed topmost element (necessary for bookmark)
2190 # computed topmost element (necessary for bookmark)
2190 if new:
2191 if new:
2191 newtopmost = sorted(new, key=state.repo.changelog.rev)[-1]
2192 newtopmost = sorted(new, key=state.repo.changelog.rev)[-1]
2192 elif not final:
2193 elif not final:
2193 # Nothing rewritten at all. we won't need `newtopmost`
2194 # Nothing rewritten at all. we won't need `newtopmost`
2194 # It is the same as `oldtopmost` and `processreplacement` know it
2195 # It is the same as `oldtopmost` and `processreplacement` know it
2195 newtopmost = None
2196 newtopmost = None
2196 else:
2197 else:
2197 # every body died. The newtopmost is the parent of the root.
2198 # every body died. The newtopmost is the parent of the root.
2198 r = state.repo.changelog.rev
2199 r = state.repo.changelog.rev
2199 newtopmost = state.repo[sorted(final, key=r)[0]].p1().node()
2200 newtopmost = state.repo[sorted(final, key=r)[0]].p1().node()
2200
2201
2201 return final, tmpnodes, new, newtopmost
2202 return final, tmpnodes, new, newtopmost
2202
2203
2203 def movetopmostbookmarks(repo, oldtopmost, newtopmost):
2204 def movetopmostbookmarks(repo, oldtopmost, newtopmost):
2204 """Move bookmark from oldtopmost to newly created topmost
2205 """Move bookmark from oldtopmost to newly created topmost
2205
2206
2206 This is arguably a feature and we may only want that for the active
2207 This is arguably a feature and we may only want that for the active
2207 bookmark. But the behavior is kept compatible with the old version for now.
2208 bookmark. But the behavior is kept compatible with the old version for now.
2208 """
2209 """
2209 if not oldtopmost or not newtopmost:
2210 if not oldtopmost or not newtopmost:
2210 return
2211 return
2211 oldbmarks = repo.nodebookmarks(oldtopmost)
2212 oldbmarks = repo.nodebookmarks(oldtopmost)
2212 if oldbmarks:
2213 if oldbmarks:
2213 with repo.lock(), repo.transaction('histedit') as tr:
2214 with repo.lock(), repo.transaction('histedit') as tr:
2214 marks = repo._bookmarks
2215 marks = repo._bookmarks
2215 changes = []
2216 changes = []
2216 for name in oldbmarks:
2217 for name in oldbmarks:
2217 changes.append((name, newtopmost))
2218 changes.append((name, newtopmost))
2218 marks.applychanges(repo, tr, changes)
2219 marks.applychanges(repo, tr, changes)
2219
2220
2220 def cleanupnode(ui, repo, nodes, nobackup=False):
2221 def cleanupnode(ui, repo, nodes, nobackup=False):
2221 """strip a group of nodes from the repository
2222 """strip a group of nodes from the repository
2222
2223
2223 The set of node to strip may contains unknown nodes."""
2224 The set of node to strip may contains unknown nodes."""
2224 with repo.lock():
2225 with repo.lock():
2225 # do not let filtering get in the way of the cleanse
2226 # do not let filtering get in the way of the cleanse
2226 # we should probably get rid of obsolescence marker created during the
2227 # we should probably get rid of obsolescence marker created during the
2227 # histedit, but we currently do not have such information.
2228 # histedit, but we currently do not have such information.
2228 repo = repo.unfiltered()
2229 repo = repo.unfiltered()
2229 # Find all nodes that need to be stripped
2230 # Find all nodes that need to be stripped
2230 # (we use %lr instead of %ln to silently ignore unknown items)
2231 # (we use %lr instead of %ln to silently ignore unknown items)
2231 nm = repo.changelog.nodemap
2232 nm = repo.changelog.nodemap
2232 nodes = sorted(n for n in nodes if n in nm)
2233 nodes = sorted(n for n in nodes if n in nm)
2233 roots = [c.node() for c in repo.set("roots(%ln)", nodes)]
2234 roots = [c.node() for c in repo.set("roots(%ln)", nodes)]
2234 if roots:
2235 if roots:
2235 backup = not nobackup
2236 backup = not nobackup
2236 repair.strip(ui, repo, roots, backup=backup)
2237 repair.strip(ui, repo, roots, backup=backup)
2237
2238
2238 def stripwrapper(orig, ui, repo, nodelist, *args, **kwargs):
2239 def stripwrapper(orig, ui, repo, nodelist, *args, **kwargs):
2239 if isinstance(nodelist, str):
2240 if isinstance(nodelist, str):
2240 nodelist = [nodelist]
2241 nodelist = [nodelist]
2241 state = histeditstate(repo)
2242 state = histeditstate(repo)
2242 if state.inprogress():
2243 if state.inprogress():
2243 state.read()
2244 state.read()
2244 histedit_nodes = {action.node for action
2245 histedit_nodes = {action.node for action
2245 in state.actions if action.node}
2246 in state.actions if action.node}
2246 common_nodes = histedit_nodes & set(nodelist)
2247 common_nodes = histedit_nodes & set(nodelist)
2247 if common_nodes:
2248 if common_nodes:
2248 raise error.Abort(_("histedit in progress, can't strip %s")
2249 raise error.Abort(_("histedit in progress, can't strip %s")
2249 % ', '.join(node.short(x) for x in common_nodes))
2250 % ', '.join(node.short(x) for x in common_nodes))
2250 return orig(ui, repo, nodelist, *args, **kwargs)
2251 return orig(ui, repo, nodelist, *args, **kwargs)
2251
2252
2252 extensions.wrapfunction(repair, 'strip', stripwrapper)
2253 extensions.wrapfunction(repair, 'strip', stripwrapper)
2253
2254
2254 def summaryhook(ui, repo):
2255 def summaryhook(ui, repo):
2255 state = histeditstate(repo)
2256 state = histeditstate(repo)
2256 if not state.inprogress():
2257 if not state.inprogress():
2257 return
2258 return
2258 state.read()
2259 state.read()
2259 if state.actions:
2260 if state.actions:
2260 # i18n: column positioning for "hg summary"
2261 # i18n: column positioning for "hg summary"
2261 ui.write(_('hist: %s (histedit --continue)\n') %
2262 ui.write(_('hist: %s (histedit --continue)\n') %
2262 (ui.label(_('%d remaining'), 'histedit.remaining') %
2263 (ui.label(_('%d remaining'), 'histedit.remaining') %
2263 len(state.actions)))
2264 len(state.actions)))
2264
2265
2265 def extsetup(ui):
2266 def extsetup(ui):
2266 cmdutil.summaryhooks.add('histedit', summaryhook)
2267 cmdutil.summaryhooks.add('histedit', summaryhook)
2267 cmdutil.unfinishedstates.append(
2268 cmdutil.unfinishedstates.append(
2268 ['histedit-state', False, True, _('histedit in progress'),
2269 ['histedit-state', False, True, _('histedit in progress'),
2269 _("use 'hg histedit --continue' or 'hg histedit --abort'")])
2270 _("use 'hg histedit --continue' or 'hg histedit --abort'")])
2270 cmdutil.afterresolvedstates.append(
2271 cmdutil.afterresolvedstates.append(
2271 ['histedit-state', _('hg histedit --continue')])
2272 ['histedit-state', _('hg histedit --continue')])
General Comments 0
You need to be logged in to leave comments. Login now