##// END OF EJS Templates
[PATCH] Unintuive use...
mpm@selenic.com -
r404:a1ecef49 default
parent child Browse files
Show More
@@ -1,811 +1,823
1 1 # commands.py - command processing for mercurial
2 2 #
3 3 # Copyright 2005 Matt Mackall <mpm@selenic.com>
4 4 #
5 5 # This software may be used and distributed according to the terms
6 6 # of the GNU General Public License, incorporated herein by reference.
7 7
8 8 import os, re, sys, signal
9 9 import fancyopts, ui, hg
10 10 from demandload import *
11 11 demandload(globals(), "mdiff time hgweb traceback random signal errno")
12 12
13 13 class UnknownCommand(Exception): pass
14 14
15 15 def filterfiles(filters, files):
16 16 l = [ x for x in files if x in filters ]
17 17
18 18 for t in filters:
19 19 if t and t[-1] != os.sep: t += os.sep
20 20 l += [ x for x in files if x.startswith(t) ]
21 21 return l
22 22
23 23 def relfilter(repo, files):
24 24 if os.getcwd() != repo.root:
25 25 p = os.getcwd()[len(repo.root) + 1: ]
26 26 return filterfiles([p], files)
27 27 return files
28 28
29 29 def relpath(repo, args):
30 30 if os.getcwd() != repo.root:
31 31 p = os.getcwd()[len(repo.root) + 1: ]
32 32 return [ os.path.normpath(os.path.join(p, x)) for x in args ]
33 33 return args
34 34
35 35 def dodiff(ui, repo, path, files = None, node1 = None, node2 = None):
36 36 def date(c):
37 37 return time.asctime(time.gmtime(float(c[2].split(' ')[0])))
38 38
39 39 if node2:
40 40 change = repo.changelog.read(node2)
41 41 mmap2 = repo.manifest.read(change[0])
42 42 (c, a, d) = repo.diffrevs(node1, node2)
43 43 def read(f): return repo.file(f).read(mmap2[f])
44 44 date2 = date(change)
45 45 else:
46 46 date2 = time.asctime()
47 47 (c, a, d, u) = repo.diffdir(path, node1)
48 48 if not node1:
49 49 node1 = repo.dirstate.parents()[0]
50 50 def read(f): return file(os.path.join(repo.root, f)).read()
51 51
52 52 if ui.quiet:
53 53 r = None
54 54 else:
55 55 hexfunc = ui.verbose and hg.hex or hg.short
56 56 r = [hexfunc(node) for node in [node1, node2] if node]
57 57
58 58 change = repo.changelog.read(node1)
59 59 mmap = repo.manifest.read(change[0])
60 60 date1 = date(change)
61 61
62 62 if files:
63 63 c, a, d = map(lambda x: filterfiles(files, x), (c, a, d))
64 64
65 65 for f in c:
66 66 to = None
67 67 if f in mmap:
68 68 to = repo.file(f).read(mmap[f])
69 69 tn = read(f)
70 70 sys.stdout.write(mdiff.unidiff(to, date1, tn, date2, f, r))
71 71 for f in a:
72 72 to = None
73 73 tn = read(f)
74 74 sys.stdout.write(mdiff.unidiff(to, date1, tn, date2, f, r))
75 75 for f in d:
76 76 to = repo.file(f).read(mmap[f])
77 77 tn = None
78 78 sys.stdout.write(mdiff.unidiff(to, date1, tn, date2, f, r))
79 79
80 80 def show_changeset(ui, repo, rev=0, changenode=None, filelog=None):
81 81 """show a single changeset or file revision"""
82 82 changelog = repo.changelog
83 83 if filelog:
84 84 log = filelog
85 85 filerev = rev
86 86 node = filenode = filelog.node(filerev)
87 87 changerev = filelog.linkrev(filenode)
88 88 changenode = changenode or changelog.node(changerev)
89 89 else:
90 90 log = changelog
91 91 changerev = rev
92 92 if changenode is None:
93 93 changenode = changelog.node(changerev)
94 94 elif not changerev:
95 95 rev = changerev = changelog.rev(changenode)
96 96 node = changenode
97 97
98 98 if ui.quiet:
99 99 ui.write("%d:%s\n" % (rev, hg.hex(node)))
100 100 return
101 101
102 102 changes = changelog.read(changenode)
103 103
104 104 parents = [(log.rev(parent), hg.hex(parent))
105 105 for parent in log.parents(node)
106 106 if ui.debugflag or parent != hg.nullid]
107 107 if not ui.debugflag and len(parents) == 1 and parents[0][0] == rev-1:
108 108 parents = []
109 109
110 110 if filelog:
111 111 ui.write("revision: %d:%s\n" % (filerev, hg.hex(filenode)))
112 112 for parent in parents:
113 113 ui.write("parent: %d:%s\n" % parent)
114 114 ui.status("changeset: %d:%s\n" % (changerev, hg.hex(changenode)))
115 115 else:
116 116 ui.write("changeset: %d:%s\n" % (changerev, hg.hex(changenode)))
117 117 for tag in repo.nodetags(changenode):
118 118 ui.status("tag: %s\n" % tag)
119 119 for parent in parents:
120 120 ui.write("parent: %d:%s\n" % parent)
121 121 ui.note("manifest: %d:%s\n" % (repo.manifest.rev(changes[0]),
122 122 hg.hex(changes[0])))
123 123 ui.status("user: %s\n" % changes[1])
124 124 ui.status("date: %s\n" % time.asctime(
125 125 time.localtime(float(changes[2].split(' ')[0]))))
126 126 ui.note("files: %s\n" % " ".join(changes[3]))
127 127 description = changes[4].strip()
128 128 if description:
129 129 if ui.verbose:
130 130 ui.status("description:\n")
131 131 ui.status(description)
132 132 ui.status("\n")
133 133 else:
134 134 ui.status("summary: %s\n" % description.splitlines()[0])
135 135 ui.status("\n")
136 136
137 137 def help(ui, cmd=None):
138 138 '''show help for a given command or all commands'''
139 139 if cmd:
140 140 try:
141 141 i = find(cmd)
142 142 ui.write("%s\n\n" % i[2])
143 143
144 144 if i[1]:
145 145 for s, l, d, c in i[1]:
146 146 opt=' '
147 147 if s: opt = opt + '-' + s + ' '
148 148 if l: opt = opt + '--' + l + ' '
149 149 if d: opt = opt + '(' + str(d) + ')'
150 150 ui.write(opt, "\n")
151 151 if c: ui.write(' %s\n' % c)
152 152 ui.write("\n")
153 153
154 154 ui.write(i[0].__doc__, "\n")
155 155 except UnknownCommand:
156 156 ui.warn("hg: unknown command %s\n" % cmd)
157 157 sys.exit(0)
158 158 else:
159 159 ui.status('hg commands:\n\n')
160 160
161 161 h = {}
162 162 for e in table.values():
163 163 f = e[0]
164 164 if f.__name__.startswith("debug"): continue
165 165 d = ""
166 166 if f.__doc__:
167 167 d = f.__doc__.splitlines(0)[0].rstrip()
168 168 h[f.__name__] = d
169 169
170 170 fns = h.keys()
171 171 fns.sort()
172 172 m = max(map(len, fns))
173 173 for f in fns:
174 174 ui.status(' %-*s %s\n' % (m, f, h[f]))
175 175
176 176 # Commands start here, listed alphabetically
177 177
178 178 def add(ui, repo, file, *files):
179 179 '''add the specified files on the next commit'''
180 180 repo.add(relpath(repo, (file,) + files))
181 181
182 182 def addremove(ui, repo, *files):
183 183 """add all new files, delete all missing files"""
184 184 if files:
185 185 files = relpath(repo, files)
186 186 d = []
187 187 u = []
188 188 for f in files:
189 189 p = repo.wjoin(f)
190 190 s = repo.dirstate.state(f)
191 191 isfile = os.path.isfile(p)
192 192 if s != 'r' and not isfile:
193 193 d.append(f)
194 194 elif s not in 'nmai' and isfile:
195 195 u.append(f)
196 196 else:
197 197 (c, a, d, u) = repo.diffdir(repo.root)
198 198 repo.add(u)
199 199 repo.remove(d)
200 200
201 201 def annotate(u, repo, file, *files, **ops):
202 202 """show changeset information per file line"""
203 203 def getnode(rev):
204 204 return hg.short(repo.changelog.node(rev))
205 205
206 206 def getname(rev):
207 207 try:
208 208 return bcache[rev]
209 209 except KeyError:
210 210 cl = repo.changelog.read(repo.changelog.node(rev))
211 211 name = cl[1]
212 212 f = name.find('@')
213 213 if f >= 0:
214 214 name = name[:f]
215 215 bcache[rev] = name
216 216 return name
217 217
218 218 bcache = {}
219 219 opmap = [['user', getname], ['number', str], ['changeset', getnode]]
220 220 if not ops['user'] and not ops['changeset']:
221 221 ops['number'] = 1
222 222
223 223 node = repo.dirstate.parents()[0]
224 224 if ops['revision']:
225 225 node = repo.changelog.lookup(ops['revision'])
226 226 change = repo.changelog.read(node)
227 227 mmap = repo.manifest.read(change[0])
228 228 maxuserlen = 0
229 229 maxchangelen = 0
230 230 for f in relpath(repo, (file,) + files):
231 231 lines = repo.file(f).annotate(mmap[f])
232 232 pieces = []
233 233
234 234 for o, f in opmap:
235 235 if ops[o]:
236 236 l = [ f(n) for n,t in lines ]
237 237 m = max(map(len, l))
238 238 pieces.append([ "%*s" % (m, x) for x in l])
239 239
240 240 for p,l in zip(zip(*pieces), lines):
241 241 u.write(" ".join(p) + ": " + l[1])
242 242
243 243 def cat(ui, repo, file, rev = []):
244 244 """output the latest or given revision of a file"""
245 245 r = repo.file(relpath(repo, [file])[0])
246 246 n = r.tip()
247 247 if rev: n = r.lookup(rev)
248 248 sys.stdout.write(r.read(n))
249 249
250 250 def commit(ui, repo, *files, **opts):
251 251 """commit the specified files or all outstanding changes"""
252 252 text = opts['text']
253 253 if not text and opts['logfile']:
254 254 try: text = open(opts['logfile']).read()
255 255 except IOError: pass
256 256
257 257 if opts['addremove']:
258 258 addremove(ui, repo, *files)
259 259 repo.commit(relpath(repo, files), text, opts['user'], opts['date'])
260 260
261 261 def copy(ui, repo, source, dest):
262 262 """mark a file as copied or renamed for the next commit"""
263 263 return repo.copy(*relpath(repo, (source, dest)))
264 264
265 265 def debugaddchangegroup(ui, repo):
266 266 data = sys.stdin.read()
267 267 repo.addchangegroup(data)
268 268
269 269 def debugchangegroup(ui, repo, roots):
270 270 newer = repo.newer(map(repo.lookup, roots))
271 271 for chunk in repo.changegroup(newer):
272 272 sys.stdout.write(chunk)
273 273
274 274 def debugindex(ui, file):
275 275 r = hg.revlog(open, file, "")
276 276 print " rev offset length base linkrev"+\
277 277 " p1 p2 nodeid"
278 278 for i in range(r.count()):
279 279 e = r.index[i]
280 280 print "% 6d % 9d % 7d % 6d % 7d %s.. %s.. %s.." % (
281 281 i, e[0], e[1], e[2], e[3],
282 282 hg.hex(e[4][:5]), hg.hex(e[5][:5]), hg.hex(e[6][:5]))
283 283
284 284 def debugindexdot(ui, file):
285 285 r = hg.revlog(open, file, "")
286 286 print "digraph G {"
287 287 for i in range(r.count()):
288 288 e = r.index[i]
289 289 print "\t%d -> %d" % (r.rev(e[4]), i)
290 290 if e[5] != hg.nullid:
291 291 print "\t%d -> %d" % (r.rev(e[5]), i)
292 292 print "}"
293 293
294 294 def diff(ui, repo, *files, **opts):
295 295 """diff working directory (or selected files)"""
296 296 revs = []
297 297 if opts['rev']:
298 298 revs = map(lambda x: repo.lookup(x), opts['rev'])
299 299
300 300 if len(revs) > 2:
301 301 self.ui.warn("too many revisions to diff\n")
302 302 sys.exit(1)
303 303
304 304 if files:
305 305 files = relpath(repo, files)
306 306 else:
307 307 files = relpath(repo, [""])
308 308
309 309 dodiff(ui, repo, os.getcwd(), files, *revs)
310 310
311 311 def export(ui, repo, changeset):
312 312 """dump the changeset header and diffs for a revision"""
313 313 node = repo.lookup(changeset)
314 314 prev, other = repo.changelog.parents(node)
315 315 change = repo.changelog.read(node)
316 316 print "# HG changeset patch"
317 317 print "# User %s" % change[1]
318 318 print "# Node ID %s" % hg.hex(node)
319 319 print "# Parent %s" % hg.hex(prev)
320 320 print
321 321 if other != hg.nullid:
322 322 print "# Parent %s" % hg.hex(other)
323 323 print change[4].rstrip()
324 324 print
325 325
326 326 dodiff(ui, repo, "", None, prev, node)
327 327
328 328 def forget(ui, repo, file, *files):
329 329 """don't add the specified files on the next commit"""
330 330 repo.forget(relpath(repo, (file,) + files))
331 331
332 332 def heads(ui, repo):
333 333 """show current repository heads"""
334 334 for n in repo.changelog.heads():
335 335 show_changeset(ui, repo, changenode=n)
336 336
337 337 def history(ui, repo):
338 338 """show the changelog history"""
339 339 for i in range(repo.changelog.count() - 1, -1, -1):
340 340 show_changeset(ui, repo, rev=i)
341 341
342 342 def identify(ui, repo):
343 343 """print information about the working copy"""
344 344 parents = [p for p in repo.dirstate.parents() if p != hg.nullid]
345 345 if not parents:
346 346 ui.write("unknown\n")
347 347 return
348 348
349 349 hexfunc = ui.verbose and hg.hex or hg.short
350 350 (c, a, d, u) = repo.diffdir(repo.root)
351 351 output = ["%s%s" % ('+'.join([hexfunc(parent) for parent in parents]),
352 352 (c or a or d) and "+" or "")]
353 353
354 354 if not ui.quiet:
355 355 # multiple tags for a single parent separated by '/'
356 356 parenttags = ['/'.join(tags)
357 357 for tags in map(repo.nodetags, parents) if tags]
358 358 # tags for multiple parents separated by ' + '
359 359 output.append(' + '.join(parenttags))
360 360
361 361 ui.write("%s\n" % ' '.join(output))
362 362
363 363 def init(ui, source=None, **opts):
364 364 """create a new repository or copy an existing one"""
365 365
366 366 if source:
367 367 paths = {}
368 368 for name, path in ui.configitems("paths"):
369 369 paths[name] = path
370 370
371 371 if source in paths: source = paths[source]
372 372
373 373 link = 0
374 374 if not source.startswith("http://"):
375 375 d1 = os.stat(os.getcwd()).st_dev
376 376 d2 = os.stat(source).st_dev
377 377 if d1 == d2: link = 1
378 378
379 379 if link:
380 380 ui.debug("copying by hardlink\n")
381 381 os.system("cp -al %s/.hg .hg" % source)
382 382 try:
383 383 os.remove(".hg/dirstate")
384 384 except: pass
385 385
386 386 repo = hg.repository(ui, ".")
387 387
388 388 else:
389 389 repo = hg.repository(ui, ".", create=1)
390 390 other = hg.repository(ui, source)
391 391 cg = repo.getchangegroup(other)
392 392 repo.addchangegroup(cg)
393 393
394 394 f = repo.opener("hgrc", "w")
395 395 f.write("[paths]\n")
396 396 f.write("default = %s\n" % source)
397 397
398 398 if opts['update']:
399 399 update(ui, repo)
400 400 else:
401 401 repo = hg.repository(ui, ".", create=1)
402 402
403 403 def log(ui, repo, f):
404 404 """show the revision history of a single file"""
405 405 f = relpath(repo, [f])[0]
406 406
407 407 r = repo.file(f)
408 408 for i in range(r.count() - 1, -1, -1):
409 409 show_changeset(ui, repo, filelog=r, rev=i)
410 410
411 411 def manifest(ui, repo, rev = []):
412 412 """output the latest or given revision of the project manifest"""
413 413 n = repo.manifest.tip()
414 414 if rev:
415 415 n = repo.manifest.lookup(rev)
416 416 m = repo.manifest.read(n)
417 417 mf = repo.manifest.readflags(n)
418 418 files = m.keys()
419 419 files.sort()
420 420
421 421 for f in files:
422 422 ui.write("%40s %3s %s\n" % (hg.hex(m[f]), mf[f] and "755" or "644", f))
423 423
424 424 def parents(ui, repo, node = None):
425 425 '''show the parents of the current working dir'''
426 426 if node:
427 427 p = repo.changelog.parents(repo.lookup(hg.bin(node)))
428 428 else:
429 429 p = repo.dirstate.parents()
430 430
431 431 for n in p:
432 432 if n != hg.nullid:
433 433 show_changeset(ui, repo, changenode=n)
434 434
435 435 def patch(ui, repo, patch1, *patches, **opts):
436 436 """import an ordered set of patches"""
437 437 try:
438 438 import psyco
439 439 psyco.full()
440 440 except:
441 441 pass
442 442
443 443 patches = (patch1,) + patches
444 444
445 445 d = opts["base"]
446 446 strip = opts["strip"]
447 447 quiet = opts["quiet"] and "> /dev/null" or ""
448 448
449 449 for patch in patches:
450 450 ui.status("applying %s\n" % patch)
451 451 pf = os.path.join(d, patch)
452 452
453 453 text = ""
454 454 for l in file(pf):
455 455 if l[:4] == "--- ": break
456 456 text += l
457 457
458 458 # make sure text isn't empty
459 459 if not text: text = "imported patch %s\n" % patch
460 460
461 461 f = os.popen("patch -p%d < %s" % (strip, pf))
462 462 files = []
463 463 for l in f.read().splitlines():
464 464 l.rstrip('\r\n');
465 465 if not quiet:
466 466 print l
467 467 if l[:14] == 'patching file ':
468 468 files.append(l[14:])
469 469 f.close()
470 470
471 471 if len(files) > 0:
472 472 addremove(ui, repo, *files)
473 473 repo.commit(files, text)
474 474
475 def pull(ui, repo, source="default"):
475 def pull(ui, repo, source="default", **opts):
476 476 """pull changes from the specified source"""
477 477 paths = {}
478 478 for name, path in ui.configitems("paths"):
479 479 paths[name] = path
480 480
481 if source in paths: source = paths[source]
481 if source in paths:
482 source = paths[source]
483
484 ui.status('pulling from %s\n' % (source))
482 485
483 486 other = hg.repository(ui, source)
484 487 cg = repo.getchangegroup(other)
485 repo.addchangegroup(cg)
488 r = repo.addchangegroup(cg)
489 if cg and not r:
490 if opts['update']:
491 return update(ui, repo)
492 else:
493 ui.status("(run 'hg update' to get a working copy)\n")
494
495 return r
486 496
487 497 def push(ui, repo, dest="default-push"):
488 498 """push changes to the specified destination"""
489 499 paths = {}
490 500 for name, path in ui.configitems("paths"):
491 501 paths[name] = path
492 502
493 503 if dest in paths: dest = paths[dest]
494 504
495 505 if not dest.startswith("ssh://"):
496 506 ui.warn("abort: can only push to ssh:// destinations currently\n")
497 507 return 1
498 508
499 509 m = re.match(r'ssh://(([^@]+)@)?([^:/]+)(:(\d+))?(/(.*))?', dest)
500 510 if not m:
501 511 ui.warn("abort: couldn't parse destination %s\n" % dest)
502 512 return 1
503 513
504 514 user, host, port, path = map(m.group, (2, 3, 5, 7))
505 515 host = user and ("%s@%s" % (user, host)) or host
506 516 port = port and (" -p %s") % port or ""
507 517 path = path or ""
508 518
509 519 sport = random.randrange(30000, 60000)
510 520 cmd = "ssh %s%s -R %d:localhost:%d 'cd %s; hg pull http://localhost:%d/'"
511 521 cmd = cmd % (host, port, sport+1, sport, path, sport+1)
512 522
513 523 child = os.fork()
514 524 if not child:
515 525 sys.stdout = file("/dev/null", "w")
516 526 sys.stderr = sys.stdout
517 527 hgweb.server(repo.root, "pull", "", "localhost", sport)
518 528 else:
519 529 r = os.system(cmd)
520 530 os.kill(child, signal.SIGTERM)
521 531 return r
522 532
523 533 def rawcommit(ui, repo, *flist, **rc):
524 534 "raw commit interface"
525 535
526 536 text = rc['text']
527 537 if not text and rc['logfile']:
528 538 try: text = open(rc['logfile']).read()
529 539 except IOError: pass
530 540 if not text and not rc['logfile']:
531 541 print "missing commit text"
532 542 return 1
533 543
534 544 files = relpath(repo, list(flist))
535 545 if rc['files']:
536 546 files += open(rc['files']).read().splitlines()
537 547
538 548 repo.rawcommit(files, text, rc['user'], rc['date'], *rc['parent'])
539 549
540 550 def recover(ui, repo):
541 551 """roll back an interrupted transaction"""
542 552 repo.recover()
543 553
544 554 def remove(ui, repo, file, *files):
545 555 """remove the specified files on the next commit"""
546 556 repo.remove(relpath(repo, (file,) + files))
547 557
548 558 def serve(ui, repo, **opts):
549 559 """export the repository via HTTP"""
550 560 hgweb.server(repo.root, opts["name"], opts["templates"],
551 561 opts["address"], opts["port"])
552 562
553 563 def status(ui, repo):
554 564 '''show changed files in the working directory
555 565
556 566 C = changed
557 567 A = added
558 568 R = removed
559 569 ? = not tracked'''
560 570
561 571 (c, a, d, u) = repo.diffdir(os.getcwd())
562 572 (c, a, d, u) = map(lambda x: relfilter(repo, x), (c, a, d, u))
563 573
564 574 for f in c: print "C", f
565 575 for f in a: print "A", f
566 576 for f in d: print "R", f
567 577 for f in u: print "?", f
568 578
569 579 def tag(ui, repo, name, rev = None, **opts):
570 580 """add a tag for the current tip or a given revision"""
571 581
572 582 if name == "tip":
573 583 ui.warn("abort: 'tip' is a reserved name!\n")
574 584 return -1
575 585
576 586 (c, a, d, u) = repo.diffdir(repo.root)
577 587 for x in (c, a, d, u):
578 588 if ".hgtags" in x:
579 589 ui.warn("abort: working copy of .hgtags is changed!\n")
580 590 ui.status("(please commit .hgtags manually)\n")
581 591 return -1
582 592
583 593 if rev:
584 594 r = hg.hex(repo.lookup(rev))
585 595 else:
586 596 r = hg.hex(repo.changelog.tip())
587 597
588 598 add = 0
589 599 if not os.path.exists(repo.wjoin(".hgtags")): add = 1
590 600 repo.wfile(".hgtags", "a").write("%s %s\n" % (r, name))
591 601 if add: repo.add([".hgtags"])
592 602
593 603 if not opts['text']:
594 604 opts['text'] = "Added tag %s for changeset %s" % (name, r)
595 605
596 606 repo.commit([".hgtags"], opts['text'], opts['user'], opts['date'])
597 607
598 608 def tags(ui, repo):
599 609 """list repository tags"""
600 610
601 611 l = repo.tagslist()
602 612 l.reverse()
603 613 for t,n in l:
604 614 try:
605 615 r = repo.changelog.rev(n)
606 616 except KeyError:
607 617 r = "?"
608 618 print "%-30s %5d:%s" % (t, repo.changelog.rev(n), hg.hex(n))
609 619
610 620 def tip(ui, repo):
611 621 """show the tip revision"""
612 622 n = repo.changelog.tip()
613 623 show_changeset(ui, repo, changenode=n)
614 624
615 625 def undo(ui, repo):
616 626 """undo the last transaction"""
617 627 repo.undo()
618 628
619 629 def update(ui, repo, node=None, merge=False, clean=False):
620 630 '''update or merge working directory
621 631
622 632 If there are no outstanding changes in the working directory and
623 633 there is a linear relationship between the current version and the
624 634 requested version, the result is the requested version.
625 635
626 636 Otherwise the result is a merge between the contents of the
627 637 current working directory and the requested version. Files that
628 638 changed between either parent are marked as changed for the next
629 639 commit and a commit must be performed before any further updates
630 640 are allowed.
631 641 '''
632 642 node = node and repo.lookup(node) or repo.changelog.tip()
633 643 return repo.update(node, allow=merge, force=clean)
634 644
635 645 def verify(ui, repo):
636 646 """verify the integrity of the repository"""
637 647 return repo.verify()
638 648
639 649 # Command options and aliases are listed here, alphabetically
640 650
641 651 table = {
642 652 "add": (add, [], "hg add [files]"),
643 653 "addremove": (addremove, [], "hg addremove [files]"),
644 654 "ann|annotate": (annotate,
645 655 [('r', 'revision', '', 'revision'),
646 656 ('u', 'user', None, 'show user'),
647 657 ('n', 'number', None, 'show revision number'),
648 658 ('c', 'changeset', None, 'show changeset')],
649 659 'hg annotate [-u] [-c] [-n] [-r id] [files]'),
650 660 "cat|dump": (cat, [], 'hg cat <file> [rev]'),
651 661 "commit|ci": (commit,
652 662 [('t', 'text', "", 'commit text'),
653 663 ('A', 'addremove', None, 'run add/remove during commit'),
654 664 ('l', 'logfile', "", 'commit text file'),
655 665 ('d', 'date', "", 'data'),
656 666 ('u', 'user', "", 'user')],
657 667 'hg commit [files]'),
658 668 "copy": (copy, [], 'hg copy <source> <dest>'),
659 669 "debugaddchangegroup": (debugaddchangegroup, [], 'debugaddchangegroup'),
660 670 "debugchangegroup": (debugchangegroup, [], 'debugchangegroup [roots]'),
661 671 "debugindex": (debugindex, [], 'debugindex <file>'),
662 672 "debugindexdot": (debugindexdot, [], 'debugindexdot <file>'),
663 673 "diff": (diff, [('r', 'rev', [], 'revision')],
664 674 'hg diff [-r A] [-r B] [files]'),
665 675 "export": (export, [], "hg export <changeset>"),
666 676 "forget": (forget, [], "hg forget [files]"),
667 677 "heads": (heads, [], 'hg heads'),
668 678 "history": (history, [], 'hg history'),
669 679 "help": (help, [], 'hg help [command]'),
670 680 "identify|id": (identify, [], 'hg identify'),
671 681 "init": (init, [('u', 'update', None, 'update after init')],
672 682 'hg init [options] [url]'),
673 683 "log": (log, [], 'hg log <file>'),
674 684 "manifest|dumpmanifest": (manifest, [], 'hg manifest [rev]'),
675 685 "parents": (parents, [], 'hg parents [node]'),
676 686 "patch|import": (patch,
677 687 [('p', 'strip', 1, 'path strip'),
678 688 ('b', 'base', "", 'base path'),
679 689 ('q', 'quiet', "", 'silence diff')],
680 690 "hg import [options] patches"),
681 "pull|merge": (pull, [], 'hg pull [source]'),
691 "pull|merge": (pull,
692 [('u', 'update', None, 'update working directory')],
693 'hg pull [options] [source]'),
682 694 "push": (push, [], 'hg push <destination>'),
683 695 "rawcommit": (rawcommit,
684 696 [('p', 'parent', [], 'parent'),
685 697 ('d', 'date', "", 'data'),
686 698 ('u', 'user', "", 'user'),
687 699 ('F', 'files', "", 'file list'),
688 700 ('t', 'text', "", 'commit text'),
689 701 ('l', 'logfile', "", 'commit text file')],
690 702 'hg rawcommit [options] [files]'),
691 703 "recover": (recover, [], "hg recover"),
692 704 "remove": (remove, [], "hg remove [files]"),
693 705 "serve": (serve, [('p', 'port', 8000, 'listen port'),
694 706 ('a', 'address', '', 'interface address'),
695 707 ('n', 'name', os.getcwd(), 'repository name'),
696 708 ('t', 'templates', "", 'template map')],
697 709 "hg serve [options]"),
698 710 "status": (status, [], 'hg status'),
699 711 "tag": (tag, [('t', 'text', "", 'commit text'),
700 712 ('d', 'date', "", 'date'),
701 713 ('u', 'user', "", 'user')],
702 714 'hg tag [options] <name> [rev]'),
703 715 "tags": (tags, [], 'hg tags'),
704 716 "tip": (tip, [], 'hg tip'),
705 717 "undo": (undo, [], 'hg undo'),
706 718 "update|up|checkout|co|resolve": (update,
707 719 [('m', 'merge', None,
708 720 'allow merging of conflicts'),
709 721 ('C', 'clean', None,
710 722 'overwrite locally modified files')],
711 723 'hg update [options] [node]'),
712 724 "verify": (verify, [], 'hg verify'),
713 725 }
714 726
715 727 norepo = "init branch help debugindex debugindexdot"
716 728
717 729 def find(cmd):
718 730 i = None
719 731 for e in table.keys():
720 732 if re.match("(%s)$" % e, cmd):
721 733 return table[e]
722 734
723 735 raise UnknownCommand(cmd)
724 736
725 737 class SignalInterrupt(Exception): pass
726 738
727 739 def catchterm(*args):
728 740 raise SignalInterrupt
729 741
730 742 def run():
731 743 sys.exit(dispatch(sys.argv[1:]))
732 744
733 745 def dispatch(args):
734 746 options = {}
735 747 opts = [('v', 'verbose', None, 'verbose'),
736 748 ('d', 'debug', None, 'debug'),
737 749 ('q', 'quiet', None, 'quiet'),
738 750 ('p', 'profile', None, 'profile'),
739 751 ('y', 'noninteractive', None, 'run non-interactively'),
740 752 ]
741 753
742 754 args = fancyopts.fancyopts(args, opts, options,
743 755 'hg [options] <command> [options] [files]')
744 756
745 757 if not args:
746 758 cmd = "help"
747 759 else:
748 760 cmd, args = args[0], args[1:]
749 761
750 762 u = ui.ui(options["verbose"], options["debug"], options["quiet"],
751 763 not options["noninteractive"])
752 764
753 765 try:
754 766 i = find(cmd)
755 767 except UnknownCommand:
756 768 u.warn("hg: unknown command '%s'\n" % cmd)
757 769 help(u)
758 770 sys.exit(1)
759 771
760 772 signal.signal(signal.SIGTERM, catchterm)
761 773
762 774 cmdoptions = {}
763 775 try:
764 776 args = fancyopts.fancyopts(args, i[1], cmdoptions, i[2])
765 777 except fancyopts.getopt.GetoptError, inst:
766 778 u.warn("hg %s: %s\n" % (cmd, inst))
767 779 help(u, cmd)
768 780 sys.exit(-1)
769 781
770 782 if cmd not in norepo.split():
771 783 repo = hg.repository(ui = u)
772 784 d = lambda: i[0](u, repo, *args, **cmdoptions)
773 785 else:
774 786 d = lambda: i[0](u, *args, **cmdoptions)
775 787
776 788 try:
777 789 if options['profile']:
778 790 import hotshot, hotshot.stats
779 791 prof = hotshot.Profile("hg.prof")
780 792 r = prof.runcall(d)
781 793 prof.close()
782 794 stats = hotshot.stats.load("hg.prof")
783 795 stats.strip_dirs()
784 796 stats.sort_stats('time', 'calls')
785 797 stats.print_stats(40)
786 798 return r
787 799 else:
788 800 return d()
789 801 except SignalInterrupt:
790 802 u.warn("killed!\n")
791 803 except KeyboardInterrupt:
792 804 u.warn("interrupted!\n")
793 805 except IOError, inst:
794 806 if hasattr(inst, "code"):
795 807 u.warn("abort: %s\n" % inst)
796 808 elif hasattr(inst, "reason"):
797 809 u.warn("abort: error %d: %s\n" % (inst.reason[0], inst.reason[1]))
798 810 elif hasattr(inst, "args") and inst[0] == errno.EPIPE:
799 811 u.warn("broken pipe\n")
800 812 else:
801 813 raise
802 814 except TypeError, inst:
803 815 # was this an argument error?
804 816 tb = traceback.extract_tb(sys.exc_info()[2])
805 817 if len(tb) > 2: # no
806 818 raise
807 819 u.debug(inst, "\n")
808 820 u.warn("%s: invalid arguments\n" % i[0].__name__)
809 821 help(u, cmd)
810 822 sys.exit(-1)
811 823
@@ -1,38 +1,40
1 1 + mkdir test
2 2 + cd test
3 3 + echo foo
4 4 + hg init
5 5 + hg addremove
6 6 + hg commit -t 1
7 7 + hg verify
8 8 checking changesets
9 9 checking manifests
10 10 crosschecking files in changesets and manifests
11 11 checking files
12 12 1 files, 1 changesets, 1 total revisions
13 13 + cd ..
14 14 + mkdir branch
15 15 + cd branch
16 16 + hg init ../test
17 17 + hg co
18 18 + echo bar
19 19 + hg commit -t 2
20 20 + cd ../test
21 21 + hg pull ../branch
22 pulling from ../branch
22 23 searching for changes
23 24 adding changesets
24 25 adding manifests
25 26 adding file revisions
26 27 modified 1 files, added 1 changesets and 1 new revisions
28 (run 'hg update' to get a working copy)
27 29 + hg verify
28 30 checking changesets
29 31 checking manifests
30 32 crosschecking files in changesets and manifests
31 33 checking files
32 34 1 files, 2 changesets, 2 total revisions
33 35 + hg co
34 36 + cat foo
35 37 foo
36 38 bar
37 39 + hg manifest
38 40 6f4310b00b9a147241b071a60c28a650827fb03d 644 foo
General Comments 0
You need to be logged in to leave comments. Login now