#if windows

  $ PYTHONPATH="$TESTDIR/../contrib;$PYTHONPATH"

#else

  $ PYTHONPATH="$TESTDIR/../contrib:$PYTHONPATH"

#endif

  $ export PYTHONPATH

  $ hg init repo

  $ cd repo

  >>> import re

  >>> from hgclient import readchannel, runcommand, check

  >>> @check

  ... def hellomessage(server):

  ...     ch, data = readchannel(server)

  ...     # escaping python tests output not supported

  ...     print '%c, %r' % (ch, re.sub('encoding: [a-zA-Z0-9-]+',

  ...                                  'encoding: ***', data))

  ... 

  ...     # run an arbitrary command to make sure the next thing the server

  ...     # sends isn't part of the hello message

  ...     runcommand(server, ['id'])

  >>> from hgclient import check

  >>> @check

  ... def unknowncommand(server):

  ...     server.stdin.write('unknowncommand\n')

  >>> from hgclient import readchannel, runcommand, check

  >>> @check

  ... def checkruncommand(server):

  ...     # hello block

  ...     readchannel(server)

  ... 

  ...     # no args

  ...     runcommand(server, [])

  ... 

  ...     # global options

  ...     runcommand(server, ['id', '--quiet'])

  ... 

  ...     # make sure global options don't stick through requests

  ...     runcommand(server, ['id'])

  ... 

  ...     # --config

  ...     runcommand(server, ['id', '--config', 'ui.quiet=True'])

  ... 

  ...     # make sure --config doesn't stick

  ...     runcommand(server, ['id'])

  ... 

  ...     # negative return code should be masked

  ...     runcommand(server, ['id', '-runknown'])

  >>> 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.stdin.close()

  ... 

  ...     # server exits with 1 if the pipe closed while reading the command

  ...     print 'server exit code =', server.wait()

  >>> import cStringIO

  >>> from hgclient import readchannel, runcommand, check

  >>> @check

  ... def serverinput(server):

  ...     readchannel(server)

  ... 

  ...     patch = """

  ... # HG changeset patch

  ... # User test

  ... # Date 0 0

  ... # Node ID c103a3dec114d882c98382d684d8af798d09d857

  ... # Parent  0000000000000000000000000000000000000000

  ... 1

  ... 

  ... diff -r 000000000000 -r c103a3dec114 a

  ... --- /dev/null	Thu Jan 01 00:00:00 1970 +0000

  ... +++ b/a	Thu Jan 01 00:00:00 1970 +0000

  ... @@ -0,0 +1,1 @@

  ... +1

  ... """

  ... 

  ...     runcommand(server, ['import', '-'], input=cStringIO.StringIO(patch))

  ...     runcommand(server, ['log'])

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'])

  $ rm foo/bar

check that local configs for the cached repo aren't inherited when -R is used:

  $ 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

  ...     # show it

  ...     runcommand(server, ['showconfig'], outfilter=sep)

  ... 

  ...     # but not for this repo

  ...     runcommand(server, ['init', 'foo'])

  ...     runcommand(server, ['-R', 'foo', 'showconfig', 'ui', 'defaults'])

  $ rm -R foo

#if windows

  $ PYTHONPATH="$TESTTMP/repo;$PYTHONPATH"

#else

  $ PYTHONPATH="$TESTTMP/repo:$PYTHONPATH"

#endif

  $ cat <<EOF > hook.py

  > import sys

  > def hook(**args):

  >     print 'hook talking'

  >     print 'now try to read something: %r' % sys.stdin.read()

  > EOF

  >>> import cStringIO

  >>> from hgclient import readchannel, runcommand, check

  >>> @check

  ... def hookoutput(server):

  ...     readchannel(server)

  ...     runcommand(server, ['--config',

  ...                         'hooks.pre-identify=python:hook.hook',

  ...                         'id'],

  ...                input=cStringIO.StringIO('some input'))

   runcommand --config hooks.pre-identify=python:hook.hook id

  $ rm hook.py*

  $ 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')

  ...     runcommand(server, ['tip'])

  ...     runcommand(server, ['status'])

  >>> import os

  >>> from hgclient import readchannel, runcommand, check

  >>> @check

  ... def bookmarks(server):

  ...     readchannel(server)

  ...     runcommand(server, ['bookmarks'])

  ... 

  ...     # changes .hg/bookmarks

  ...     os.system('hg bookmark -i bm1')

  ...     os.system('hg bookmark -i bm2')

  ...     runcommand(server, ['bookmarks'])

  ... 

  ...     # changes .hg/bookmarks.current

  ...     os.system('hg upd bm1 -q')

  ...     runcommand(server, ['bookmarks'])

  ... 

  ...     runcommand(server, ['bookmarks', 'bm3'])

  ...     f = open('a', 'ab')

  ...     f.write('a\n')

  ...     f.close()

  ...     runcommand(server, ['commit', '-Amm'])

  ...     runcommand(server, ['bookmarks'])

  >>> 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(server, ['id', '-t', '-r', '0'])

  >>> import os

  >>> from hgclient import readchannel, runcommand, check

  >>> @check

  ... def setphase(server):

  ...     readchannel(server)

  ...     runcommand(server, ['phase', '-r', '.'])

  ...     os.system('hg phase -r . -p')

  ...     runcommand(server, ['phase', '-r', '.'])

  $ 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(server, ['rollback'])

  ...     runcommand(server, ['phase', '-r', '.'])

  >>> import os

  >>> from hgclient import readchannel, runcommand, check

  >>> @check

  ... def branch(server):

  ...     readchannel(server)

  ...     runcommand(server, ['branch'])

  ...     os.system('hg branch foo')

  ...     runcommand(server, ['branch'])

  ...     os.system('hg branch default')

  $ 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')

  ...     f.write('')

  ...     f.close()

  ...     f = open('.hgignore', 'ab')

  ...     f.write('ignored-file')

  ...     f.close()

  ...     runcommand(server, ['status', '-i', '-u'])

  >>> import os

  >>> from hgclient import readchannel, sep, runcommand, check

  >>> @check

  ... def phasecacheafterstrip(server):

  ...     readchannel(server)

  ... 

  ...     # create new head, 5:731265503d86

  ...     runcommand(server, ['update', '-C', '0'])

  ...     f = open('a', 'ab')

  ...     f.write('a\n')

  ...     f.close()

  ...     runcommand(server, ['commit', '-Am.', 'a'])

  ...     runcommand(server, ['log', '-Gq'])

  ... 

  ...     # make it public; draft marker moves to 4:7966c8e3734d

  ...     runcommand(server, ['phase', '-p', '.'])

  ...     # load _phasecache.phaseroots

  ...     runcommand(server, ['phase', '.'], outfilter=sep)

  ... 

  ...     # strip 1::4 outside server

  ...     os.system('hg -q --config extensions.mq= strip 1')

  ... 

  ...     # shouldn't raise "7966c8e3734d: no node!"

  ...     runcommand(server, ['branches'])