mercurial-scm/hg: mercurial/commands.py comparison

comparison mercurial/commands.py @ 2509:6350b01d173f

merge with wsgi changes.

author	Vadim Gelfer <vadim.gelfer@gmail.com>
date	Tue, 27 Jun 2006 00:10:41 -0700
parents	158d3d2ae070
children	cbff06469488

comparison

equal deleted inserted replaced

-:ab460a3f0e3a
+:6350b01d173f
 from i18n import gettext as _
 demandload(globals(), "os re sys signal shutil imp urllib pdb")
 demandload(globals(), "fancyopts ui hg util lock revlog templater bundlerepo")
 demandload(globals(), "fnmatch mdiff random signal tempfile time")
 demandload(globals(), "traceback errno socket version struct atexit sets bz2")
-demandload(globals(), "archival changegroup")
+demandload(globals(), "archival cStringIO changegroup email.Parser")
 demandload(globals(), "hgweb.server sshserver")
 class UnknownCommand(Exception):
 """Exception raised if command is not in the command table."""
 class AmbiguousCommand(Exception):
 commit(ui, repo, **commit_opts)
 def nice(node):
 return '%d:%s' % (repo.changelog.rev(node), short(node))
 ui.status(_('changeset %s backs out changeset %s\n') %
 (nice(repo.changelog.tip()), nice(node)))
-if opts['merge'] and op1 != node:
+if op1 != node:
-ui.status(_('merging with changeset %s\n') % nice(op1))
+if opts['merge']:
-doupdate(ui, repo, hex(op1), **opts)
+ui.status(_('merging with changeset %s\n') % nice(op1))
+doupdate(ui, repo, hex(op1), **opts)
-def bundle(ui, repo, fname, dest="default-push", **opts):
+else:
+ui.status(_('the backout changeset is a new head - '
+'do not forget to merge\n'))
+ui.status(_('(use "backout -m" if you want to auto-merge)\n'))
+def bundle(ui, repo, fname, dest=None, **opts):
 """create a changegroup file
 Generate a compressed changegroup file collecting all changesets
 not found in the other repository.
 extension is ".hg".
 Unlike import/export, this exactly preserves all changeset
 contents including permissions, rename data, and revision history.
 """
-dest = ui.expandpath(dest)
+dest = ui.expandpath(dest or 'default-push', dest or 'default')
 other = hg.repository(ui, dest)
 o = repo.findoutgoing(other, force=opts['force'])
 cg = repo.changegroup(o, 'bundle')
 write_bundle(cg, fname)
 Import a list of patches and commit them individually.
 If there are outstanding changes in the working directory, import
 will abort unless given the -f flag.
-If a patch looks like a mail message (its first line starts with
+You can import a patch straight from a mail message.  Even patches
-"From " or looks like an RFC822 header), it will not be applied
+as attachments work (body part must be type text/plain or
-unless the -f option is used.  The importer neither parses nor
+text/x-patch to be used).  Sender and subject line of email
-discards mail headers, so use -f only to override the "mailness"
+message are used as default committer and commit message.  Any
-safety check, not to import a real mail message.
+text/plain body part before first diff is added to commit message.
+If imported patch was generated by hg export, user and description
+from patch override values from message headers and body.  Values
+given on command line with -m and -u override these.
 To read a patch from standard input, use patch name "-".
 """
 patches = (patch1,) + patches
 mailre = re.compile(r'(?:From |[\w-]+:)')
 # attempt to detect the start of a patch
 # (this heuristic is borrowed from quilt)
-diffre = re.compile(r'(?:Index:[ \t]|diff[ \t]|RCS file: |' +
+diffre = re.compile(r'^(?:Index:[ \t]|diff[ \t]|RCS file: |' +
 'retrieving revision [0-9]+(\.[0-9]+)*$|' +
-'(---|\*\*\*)[ \t])')
+'(---|\*\*\*)[ \t])', re.MULTILINE)
 for patch in patches:
 pf = os.path.join(d, patch)
-message = []
+message = None
 user = None
 date = None
 hgpatch = False
+p = email.Parser.Parser()
 if pf == '-':
-f = sys.stdin
+msg = p.parse(sys.stdin)
-fd, tmpname = tempfile.mkstemp(prefix='hg-patch-')
-pf = tmpname
-tmpfp = os.fdopen(fd, 'w')
 ui.status(_("applying patch from stdin\n"))
 else:
-f = open(pf)
+msg = p.parse(file(pf))
-tmpfp, tmpname = None, None
 ui.status(_("applying %s\n") % patch)
+fd, tmpname = tempfile.mkstemp(prefix='hg-patch-')
+tmpfp = os.fdopen(fd, 'w')
 try:
-while True:
+message = msg['Subject']
-line = f.readline()
+if message:
-if not line: break
+message = message.replace('\n\t', ' ')
-if tmpfp: tmpfp.write(line)
+ui.debug('Subject: %s\n' % message)
-line = line.rstrip()
+user = msg['From']
-if (not message and not hgpatch and
+if user:
-mailre.match(line) and not opts['force']):
+ui.debug('From: %s\n' % user)
-if len(line) > 35:
+diffs_seen = 0
-line = line[:32] + '...'
+ok_types = ('text/plain', 'text/x-patch')
-raise util.Abort(_('first line looks like a '
+for part in msg.walk():
-'mail header: ') + line)
+content_type = part.get_content_type()
-if diffre.match(line):
+ui.debug('Content-Type: %s\n' % content_type)
+if content_type not in ok_types:
+continue
+payload = part.get_payload(decode=True)
+m = diffre.search(payload)
+if m:
+ui.debug(_('found patch at byte %d\n') % m.start(0))
+diffs_seen += 1
+hgpatch = False
+fp = cStringIO.StringIO()
+for line in payload[:m.start(0)].splitlines():
+if line.startswith('# HG changeset patch'):
+ui.debug(_('patch generated by hg export\n'))
+hgpatch = True
+elif hgpatch:
+if line.startswith('# User '):
+user = line[7:]
+ui.debug('From: %s\n' % user)
+elif line.startswith("# Date "):
+date = line[7:]
+if not line.startswith('# '):
+fp.write(line)
+fp.write('\n')
+hgpatch = False
+message = fp.getvalue() or message
 if tmpfp:
-for chunk in util.filechunkiter(f):
+tmpfp.write(payload)
-tmpfp.write(chunk)
+if not payload.endswith('\n'):
-break
+tmpfp.write('\n')
-elif hgpatch:
+elif not diffs_seen and message and content_type == 'text/plain':
-# parse values when importing the result of an hg export
+message += '\n' + payload
-if line.startswith("# User "):
-user = line[7:]
-ui.debug(_('User: %s\n') % user)
-elif line.startswith("# Date "):
-date = line[7:]
-elif not line.startswith("# ") and line:
-message.append(line)
-hgpatch = False
-elif line == '# HG changeset patch':
-hgpatch = True
-message = []       # We may have collected garbage
-elif message or line:
-message.append(line)
 if opts['message']:
 # pickup the cmdline msg
 message = opts['message']
 elif message:
 # pickup the patch msg
-message = '\n'.join(message).rstrip()
+message = message.strip()
 else:
 # launch the editor
 message = None
 ui.debug(_('message:\n%s\n') % message)
-if tmpfp: tmpfp.close()
+tmpfp.close()
-files = util.patch(strip, pf, ui)
+if not diffs_seen:
+raise util.Abort(_('no diffs found'))
+files = util.patch(strip, tmpname, ui)
 if len(files) > 0:
 addremove_lock(ui, repo, files, {})
 repo.commit(files, message, user, date)
 finally:
-if tmpname: os.unlink(tmpname)
+os.unlink(tmpname)
 def incoming(ui, repo, source="default", **opts):
 """show new changesets found in source
 Show new changesets found in the specified path/URL or the default
 marked as changed for the next commit and a commit must be
 performed before any further updates are allowed.
 """
 return doupdate(ui, repo, node=node, merge=True, **opts)
-def outgoing(ui, repo, dest="default-push", **opts):
+def outgoing(ui, repo, dest=None, **opts):
 """show changesets not found in destination
 Show changesets not found in the specified destination repository or
 the default push location. These are the changesets that would be pushed
 if a push was requested.
 See pull for valid destination format details.
 """
-dest = ui.expandpath(dest)
+dest = ui.expandpath(dest or 'default-push', dest or 'default')
 if opts['ssh']:
 ui.setconfig("ui", "ssh", opts['ssh'])
 if opts['remotecmd']:
 ui.setconfig("ui", "remotecmd", opts['remotecmd'])
 elif opts['rev']:
 revs = [other.lookup(rev) for rev in opts['rev']]
 modheads = repo.pull(other, heads=revs, force=opts['force'])
 return postincoming(ui, repo, modheads, opts['update'])
-def push(ui, repo, dest="default-push", **opts):
+def push(ui, repo, dest=None, **opts):
 """push changes to the specified destination
 Push changes from the local repository to the given destination.
 This is the symmetrical operation for pull. It helps to move
 ssh://[user@]host[:port][/path]
 Look at the help text for the pull command for important details
 about ssh:// URLs.
 """
-dest = ui.expandpath(dest)
+dest = ui.expandpath(dest or 'default-push', dest or 'default')
 if opts['ssh']:
 ui.setconfig("ui", "ssh", opts['ssh'])
 if opts['remotecmd']:
 ui.setconfig("ui", "remotecmd", opts['remotecmd'])

Mercurial > public > mercurial-scm > hg

comparison mercurial/commands.py @ 2509:6350b01d173f