comparison tests/test-commandserver.t @ 33922:1a6707b43d05

tests: update test-commandserver to pass our import checker

33921:a4c1333b2eda

  $ mv $HGRCPATH.new $HGRCPATH

  $ hg init repo
  $ cd repo

  >>> from __future__ import print_function
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def hellomessage(server):
  ...     ch, data = readchannel(server)
  ...     print('%c, %r' % (ch, data))
  ...     # run an arbitrary command to make sure the next thing the server

  >>> @check
  ... def unknowncommand(server):
  ...     server.stdin.write('unknowncommand\n')
  abort: unknown command unknowncommand

  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def checkruncommand(server):
  ...     # hello block
  ...     readchannel(server)
  ... 

  000000000000 tip
  *** runcommand id -runknown
  abort: unknown revision 'unknown'!
   [255]

  >>> from hgclient import readchannel, check
  >>> @check
  ... def inputeof(server):
  ...     readchannel(server)
  ...     server.stdin.write('runcommand\n')
  ...     # close stdin while server is waiting for input

  ... 
  ...     # server exits with 1 if the pipe closed while reading the command
  ...     print('server exit code =', server.wait())
  server exit code = 1

  >>> from hgclient import readchannel, runcommand, check, stringio
  >>> @check
  ... def serverinput(server):
  ...     readchannel(server)
  ... 
  ...     patch = """

  

check that "histedit --commands=-" can read rules from the input channel:

  >>> import cStringIO
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def serverinput(server):
  ...     readchannel(server)
  ...     rules = 'pick eff892de26ec\n'
  ...     runcommand(server, ['histedit', '0', '--commands=-',

check that --cwd doesn't persist between requests:

  $ mkdir foo
  $ touch foo/bar
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def cwd(server):
  ...     readchannel(server)
  ...     runcommand(server, ['--cwd', 'foo', 'st', 'bar'])
  ...     runcommand(server, ['st', 'foo/bar'])

  $ cat <<EOF >> .hg/hgrc
  > [ui]
  > foo = bar
  > EOF

  >>> from hgclient import readchannel, sep, runcommand, check
  >>> @check
  ... def localhgrc(server):
  ...     readchannel(server)
  ... 
  ...     # the cached repo local hgrc contains ui.foo=bar, so showconfig should

  > def hook(**args):
  >     print('hook talking')
  >     print('now try to read something: %r' % sys.stdin.read())
  > EOF

  >>> from hgclient import readchannel, runcommand, check, stringio
  >>> @check
  ... def hookoutput(server):
  ...     readchannel(server)
  ...     runcommand(server, ['--config',
  ...                         'hooks.pre-identify=python:hook.hook',

  $ rm hook.py*
  $ rm -Rf __pycache__

  $ echo a >> a
  >>> import os
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def outsidechanges(server):
  ...     readchannel(server)
  ...     runcommand(server, ['status'])
  ...     os.system('hg ci -Am2')

  summary:     2
  
  *** runcommand status

  >>> import os
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def bookmarks(server):
  ...     readchannel(server)
  ...     runcommand(server, ['bookmarks'])
  ... 

     bm2                       1:d3a0a68be6de
   * bm3                       2:aef17e88f5f0
  

  >>> import os
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def tagscache(server):
  ...     readchannel(server)
  ...     runcommand(server, ['id', '-t', '-r', '0'])
  ...     os.system('hg tag -r 0 foo')

  
  *** runcommand id -t -r 0
  foo

  >>> import os
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def setphase(server):
  ...     readchannel(server)
  ...     runcommand(server, ['phase', '-r', '.'])
  ...     os.system('hg phase -r . -p')

  3: draft
  *** runcommand phase -r .
  3: public

  $ echo a >> a
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def rollback(server):
  ...     readchannel(server)
  ...     runcommand(server, ['phase', '-r', '.', '-p'])
  ...     runcommand(server, ['commit', '-Am.'])

  *** runcommand phase -r .
  3: public
  

  >>> import os
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def branch(server):
  ...     readchannel(server)
  ...     runcommand(server, ['branch'])
  ...     os.system('hg branch foo')

  marked working directory as branch default
  (branches are permanent and global, did you want a bookmark?)

  $ touch .hgignore
  >>> import os
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def hgignore(server):
  ...     readchannel(server)
  ...     runcommand(server, ['commit', '-Am.'])
  ...     f = open('ignored-file', 'ab')

cache of non-public revisions should be invalidated on repository change
(issue4855):

  >>> import os
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def phasesetscacheaftercommit(server):
  ...     readchannel(server)
  ...     # load _phasecache._phaserevs and _phasesets
  ...     runcommand(server, ['log', '-qr', 'draft()'])

  5:41f6602d1c4f
  6:10501e202c35
  

  >>> import os
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def phasesetscacheafterstrip(server):
  ...     readchannel(server)
  ...     # load _phasecache._phaserevs and _phasesets
  ...     runcommand(server, ['log', '-qr', 'draft()'])

  

cache of phase roots should be invalidated on strip (issue3827):

  >>> import os
  >>> from hgclient import readchannel, sep, runcommand, check
  >>> @check
  ... def phasecacheafterstrip(server):
  ...     readchannel(server)
  ... 
  ...     # create new head, 5:731265503d86

in-memory cache must be reloaded if transaction is aborted. otherwise
changelog and manifest would have invalid node:

  $ echo a >> a
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def txabort(server):
  ...     readchannel(server)
  ...     runcommand(server, ['commit', '--config', 'hooks.pretxncommit=false',
  ...                         '-mfoo'])

  > [experimental]
  > stabilization=createmarkers
  > EOF

  >>> import os
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def obsolete(server):
  ...     readchannel(server)
  ... 
  ...     runcommand(server, ['up', 'null'])

  > [extensions]
  > mq =
  > EOF

  >>> import os
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def mqoutsidechanges(server):
  ...     readchannel(server)
  ... 
  ...     # load repo.mq

  patch queue now empty
  *** runcommand qqueue --active
  foo

  $ cat <<EOF > dbgui.py
  > import os, sys
  > from mercurial import commands, registrar
  > cmdtable = {}
  > command = registrar.command(cmdtable)
  > @command(b"debuggetpass", norepo=True)
  > def debuggetpass(ui):

  $ cat <<EOF >> .hg/hgrc
  > [extensions]
  > dbgui = dbgui.py
  > EOF

  >>> from hgclient import readchannel, runcommand, check, stringio
  >>> @check
  ... def getpass(server):
  ...     readchannel(server)
  ...     runcommand(server, ['debuggetpass', '--config',
  ...                         'ui.interactive=True'],

run commandserver in commandserver, which is silly but should work:

  >>> from __future__ import print_function
  >>> from hgclient import readchannel, runcommand, check, stringio
  >>> @check
  ... def nested(server):
  ...     print('%c, %r' % readchannel(server))
  ...     class nestedserver(object):
  ...         stdin = stringio('getencoding\n')

start without repository:

  $ cd ..

  >>> from __future__ import print_function
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def hellomessage(server):
  ...     ch, data = readchannel(server)
  ...     print('%c, %r' % (ch, data))
  ...     # run an arbitrary command to make sure the next thing the server

  o, 'capabilities: getencoding runcommand\nencoding: *\npid: *' (glob)
  *** runcommand id
  abort: there is no Mercurial repository here (.hg not found)
   [255]

  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def startwithoutrepo(server):
  ...     readchannel(server)
  ...     runcommand(server, ['init', 'repo2'])
  ...     runcommand(server, ['id', '-R', 'repo2'])

  $ hg update -q

#if unix-socket unix-permissions

  >>> from __future__ import print_function
  >>> from hgclient import unixserver, readchannel, runcommand, check, stringio
  >>> server = unixserver('.hg/server.sock', '.hg/server.log')
  >>> def hellomessage(conn):
  ...     ch, data = readchannel(conn)
  ...     print('%c, %r' % (ch, data))
  ...     runcommand(conn, ['id'])

  $ cat <<EOF >> .hg/hgrc
  > [cmdserver]
  > log = inexistent/path.log
  > EOF
  >>> from __future__ import print_function
  >>> from hgclient import unixserver, readchannel, check
  >>> server = unixserver('.hg/server.sock', '.hg/server.log')
  >>> def earlycrash(conn):
  ...     while True:
  ...         try:
  ...             ch, data = readchannel(conn)

  $ echo foo > foo
  $ hg add foo

(failure before finalization)

  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def abort(server):
  ...     readchannel(server)
  ...     runcommand(server, ['commit',
  ...                         '--config', 'hooks.pretxncommit=false',

  *** runcommand log
  *** runcommand verify -q

(failure after finalization)

  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def abort(server):
  ...     readchannel(server)
  ...     runcommand(server, ['commit',
  ...                         '--config', 'failafterfinalize.fail=true',

  $ hg add bar
  $ hg commit -mbar bar

(failure before finalization)

  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def abort(server):
  ...     readchannel(server)
  ...     runcommand(server, ['commit',
  ...                         '--config', 'hooks.pretxncommit=false',

  0 bar (bar)
  *** runcommand verify -q

(failure after finalization)

  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def abort(server):
  ...     readchannel(server)
  ...     runcommand(server, ['commit',
  ...                         '--config', 'failafterfinalize.fail=true',

try trivial merge after update: cache of audited paths should be discarded,
and the merge should fail (issue5628)

  $ hg up -q null
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def merge(server):
  ...     readchannel(server)
  ...     # audit a/poisoned as a good path
  ...     runcommand(server, ['up', '-qC', '2'])

cache of repo.auditor should be discarded, so matcher would never traverse
symlinks:

  $ hg up -qC 0
  $ touch ../merge-symlink-out/poisoned
  >>> from hgclient import readchannel, runcommand, check
  >>> @check
  ... def files(server):
  ...     readchannel(server)
  ...     runcommand(server, ['up', '-qC', '2'])
  ...     # audit a/poisoned as a good path

33922:1a6707b43d05

  $ mv $HGRCPATH.new $HGRCPATH

  $ hg init repo
  $ cd repo

  >>> from __future__ import absolute_import, print_function
  >>> import os
  >>> import sys
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def hellomessage(server):
  ...     ch, data = readchannel(server)
  ...     print('%c, %r' % (ch, data))
  ...     # run an arbitrary command to make sure the next thing the server

  >>> @check
  ... def unknowncommand(server):
  ...     server.stdin.write('unknowncommand\n')
  abort: unknown command unknowncommand

  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def checkruncommand(server):
  ...     # hello block
  ...     readchannel(server)
  ... 

  000000000000 tip
  *** runcommand id -runknown
  abort: unknown revision 'unknown'!
   [255]

  >>> from hgclient import check, readchannel
  >>> @check
  ... def inputeof(server):
  ...     readchannel(server)
  ...     server.stdin.write('runcommand\n')
  ...     # close stdin while server is waiting for input

  ... 
  ...     # server exits with 1 if the pipe closed while reading the command
  ...     print('server exit code =', server.wait())
  server exit code = 1

  >>> from hgclient import check, readchannel, runcommand, stringio
  >>> @check
  ... def serverinput(server):
  ...     readchannel(server)
  ... 
  ...     patch = """

  

check that "histedit --commands=-" can read rules from the input channel:

  >>> import cStringIO
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def serverinput(server):
  ...     readchannel(server)
  ...     rules = 'pick eff892de26ec\n'
  ...     runcommand(server, ['histedit', '0', '--commands=-',

check that --cwd doesn't persist between requests:

  $ mkdir foo
  $ touch foo/bar
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def cwd(server):
  ...     readchannel(server)
  ...     runcommand(server, ['--cwd', 'foo', 'st', 'bar'])
  ...     runcommand(server, ['st', 'foo/bar'])

  $ cat <<EOF >> .hg/hgrc
  > [ui]
  > foo = bar
  > EOF

  >>> from hgclient import check, readchannel, runcommand, sep
  >>> @check
  ... def localhgrc(server):
  ...     readchannel(server)
  ... 
  ...     # the cached repo local hgrc contains ui.foo=bar, so showconfig should

  > def hook(**args):
  >     print('hook talking')
  >     print('now try to read something: %r' % sys.stdin.read())
  > EOF

  >>> from hgclient import check, readchannel, runcommand, stringio
  >>> @check
  ... def hookoutput(server):
  ...     readchannel(server)
  ...     runcommand(server, ['--config',
  ...                         'hooks.pre-identify=python:hook.hook',

  $ rm hook.py*
  $ rm -Rf __pycache__

  $ echo a >> a
  >>> import os
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def outsidechanges(server):
  ...     readchannel(server)
  ...     runcommand(server, ['status'])
  ...     os.system('hg ci -Am2')

  summary:     2
  
  *** runcommand status

  >>> import os
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def bookmarks(server):
  ...     readchannel(server)
  ...     runcommand(server, ['bookmarks'])
  ... 

     bm2                       1:d3a0a68be6de
   * bm3                       2:aef17e88f5f0
  

  >>> import os
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def tagscache(server):
  ...     readchannel(server)
  ...     runcommand(server, ['id', '-t', '-r', '0'])
  ...     os.system('hg tag -r 0 foo')

  
  *** runcommand id -t -r 0
  foo

  >>> import os
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def setphase(server):
  ...     readchannel(server)
  ...     runcommand(server, ['phase', '-r', '.'])
  ...     os.system('hg phase -r . -p')

  3: draft
  *** runcommand phase -r .
  3: public

  $ echo a >> a
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def rollback(server):
  ...     readchannel(server)
  ...     runcommand(server, ['phase', '-r', '.', '-p'])
  ...     runcommand(server, ['commit', '-Am.'])

  *** runcommand phase -r .
  3: public
  

  >>> import os
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def branch(server):
  ...     readchannel(server)
  ...     runcommand(server, ['branch'])
  ...     os.system('hg branch foo')

  marked working directory as branch default
  (branches are permanent and global, did you want a bookmark?)

  $ touch .hgignore
  >>> import os
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def hgignore(server):
  ...     readchannel(server)
  ...     runcommand(server, ['commit', '-Am.'])
  ...     f = open('ignored-file', 'ab')

cache of non-public revisions should be invalidated on repository change
(issue4855):

  >>> import os
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def phasesetscacheaftercommit(server):
  ...     readchannel(server)
  ...     # load _phasecache._phaserevs and _phasesets
  ...     runcommand(server, ['log', '-qr', 'draft()'])

  5:41f6602d1c4f
  6:10501e202c35
  

  >>> import os
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def phasesetscacheafterstrip(server):
  ...     readchannel(server)
  ...     # load _phasecache._phaserevs and _phasesets
  ...     runcommand(server, ['log', '-qr', 'draft()'])

  

cache of phase roots should be invalidated on strip (issue3827):

  >>> import os
  >>> from hgclient import check, readchannel, runcommand, sep
  >>> @check
  ... def phasecacheafterstrip(server):
  ...     readchannel(server)
  ... 
  ...     # create new head, 5:731265503d86

in-memory cache must be reloaded if transaction is aborted. otherwise
changelog and manifest would have invalid node:

  $ echo a >> a
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def txabort(server):
  ...     readchannel(server)
  ...     runcommand(server, ['commit', '--config', 'hooks.pretxncommit=false',
  ...                         '-mfoo'])

  > [experimental]
  > stabilization=createmarkers
  > EOF

  >>> import os
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def obsolete(server):
  ...     readchannel(server)
  ... 
  ...     runcommand(server, ['up', 'null'])

  > [extensions]
  > mq =
  > EOF

  >>> import os
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def mqoutsidechanges(server):
  ...     readchannel(server)
  ... 
  ...     # load repo.mq

  patch queue now empty
  *** runcommand qqueue --active
  foo

  $ cat <<EOF > dbgui.py
  > import os
  > import sys
  > from mercurial import commands, registrar
  > cmdtable = {}
  > command = registrar.command(cmdtable)
  > @command(b"debuggetpass", norepo=True)
  > def debuggetpass(ui):

  $ cat <<EOF >> .hg/hgrc
  > [extensions]
  > dbgui = dbgui.py
  > EOF

  >>> from hgclient import check, readchannel, runcommand, stringio
  >>> @check
  ... def getpass(server):
  ...     readchannel(server)
  ...     runcommand(server, ['debuggetpass', '--config',
  ...                         'ui.interactive=True'],

run commandserver in commandserver, which is silly but should work:

  >>> from __future__ import print_function
  >>> from hgclient import check, readchannel, runcommand, stringio
  >>> @check
  ... def nested(server):
  ...     print('%c, %r' % readchannel(server))
  ...     class nestedserver(object):
  ...         stdin = stringio('getencoding\n')

start without repository:

  $ cd ..

  >>> from __future__ import print_function
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def hellomessage(server):
  ...     ch, data = readchannel(server)
  ...     print('%c, %r' % (ch, data))
  ...     # run an arbitrary command to make sure the next thing the server

  o, 'capabilities: getencoding runcommand\nencoding: *\npid: *' (glob)
  *** runcommand id
  abort: there is no Mercurial repository here (.hg not found)
   [255]

  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def startwithoutrepo(server):
  ...     readchannel(server)
  ...     runcommand(server, ['init', 'repo2'])
  ...     runcommand(server, ['id', '-R', 'repo2'])

  $ hg update -q

#if unix-socket unix-permissions

  >>> from __future__ import print_function
  >>> from hgclient import check, readchannel, runcommand, stringio, unixserver
  >>> server = unixserver('.hg/server.sock', '.hg/server.log')
  >>> def hellomessage(conn):
  ...     ch, data = readchannel(conn)
  ...     print('%c, %r' % (ch, data))
  ...     runcommand(conn, ['id'])

  $ cat <<EOF >> .hg/hgrc
  > [cmdserver]
  > log = inexistent/path.log
  > EOF
  >>> from __future__ import print_function
  >>> from hgclient import check, readchannel, unixserver
  >>> server = unixserver('.hg/server.sock', '.hg/server.log')
  >>> def earlycrash(conn):
  ...     while True:
  ...         try:
  ...             ch, data = readchannel(conn)

  $ echo foo > foo
  $ hg add foo

(failure before finalization)

  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def abort(server):
  ...     readchannel(server)
  ...     runcommand(server, ['commit',
  ...                         '--config', 'hooks.pretxncommit=false',

  *** runcommand log
  *** runcommand verify -q

(failure after finalization)

  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def abort(server):
  ...     readchannel(server)
  ...     runcommand(server, ['commit',
  ...                         '--config', 'failafterfinalize.fail=true',

  $ hg add bar
  $ hg commit -mbar bar

(failure before finalization)

  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def abort(server):
  ...     readchannel(server)
  ...     runcommand(server, ['commit',
  ...                         '--config', 'hooks.pretxncommit=false',

  0 bar (bar)
  *** runcommand verify -q

(failure after finalization)

  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def abort(server):
  ...     readchannel(server)
  ...     runcommand(server, ['commit',
  ...                         '--config', 'failafterfinalize.fail=true',

try trivial merge after update: cache of audited paths should be discarded,
and the merge should fail (issue5628)

  $ hg up -q null
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def merge(server):
  ...     readchannel(server)
  ...     # audit a/poisoned as a good path
  ...     runcommand(server, ['up', '-qC', '2'])

cache of repo.auditor should be discarded, so matcher would never traverse
symlinks:

  $ hg up -qC 0
  $ touch ../merge-symlink-out/poisoned
  >>> from hgclient import check, readchannel, runcommand
  >>> @check
  ... def files(server):
  ...     readchannel(server)
  ...     runcommand(server, ['up', '-qC', '2'])
  ...     # audit a/poisoned as a good path