#require no-rhg no-chg

XXX-RHG this test hangs if `hg` is really `rhg`. This was hidden by the use of

`alias hg=rhg` by run-tests.py. With such alias removed, this test is revealed

buggy. This need to be resolved sooner than later.

XXX-CHG this test hangs if `hg` is really `chg`. This was hidden by the use of

`alias hg=chg` by run-tests.py. With such alias removed, this test is revealed

buggy. This need to be resolved sooner than later.

#if windows

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

#else

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

#endif

  $ export PYTHONPATH

typical client does not want echo-back messages, so test without it:

  $ grep -v '^promptecho ' < $HGRCPATH >> $HGRCPATH.new

  $ mv $HGRCPATH.new $HGRCPATH

  $ hg init repo

  $ cd repo

  >>> from __future__ import absolute_import

  >>> import os

  >>> import sys

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

  >>> @check

  ... def hellomessage(server):

  ...     ch, data = readchannel(server)

  ...     bprint(b'%c, %r' % (ch, data))

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

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

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

  o, 'capabilities: getencoding runcommand\nencoding: *\npid: *' (glob)

  *** runcommand id

  000000000000 tip

  >>> from hgclient import check

  >>> @check

  ... def unknowncommand(server):

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

  abort: unknown command unknowncommand

  >>> from hgclient import check, readchannel, runcommand

  >>> @check

  ... def checkruncommand(server):

  ...     # hello block

  ...     readchannel(server)

  ... 

  ...     # no args

  ...     runcommand(server, [])

  ... 

  ...     # global options

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

  ... 

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

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

  ... 

  ...     # --config

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

  ... 

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

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

  ... 

  ...     # negative return code should be masked

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

  *** runcommand 

  Mercurial Distributed SCM

  basic commands:

   add           add the specified files on the next commit

   annotate      show changeset information by line for each file

   clone         make a copy of an existing repository

   commit        commit the specified files or all outstanding changes

   diff          diff repository (or selected files)

   export        dump the header and diffs for one or more changesets

   forget        forget the specified files on the next commit

   init          create a new repository in the given directory

   log           show revision history of entire repository or files

   merge         merge another revision into working directory

   pull          pull changes from the specified source

   push          push changes to the specified destination

   remove        remove the specified files on the next commit

   serve         start stand-alone webserver

   status        show changed files in the working directory

   summary       summarize working directory state

   update        update working directory (or switch revisions)

  (use 'hg help' for the full list of commands or 'hg -v' for details)

  *** runcommand id --quiet

  000000000000

  *** runcommand id

  000000000000 tip

  *** runcommand id --config ui.quiet=True

  000000000000

  *** runcommand id

  000000000000 tip

  *** runcommand id -runknown

  abort: unknown revision 'unknown'

   [10]

  >>> from hgclient import bprint, check, readchannel

  >>> @check

  ... def inputeof(server):

  ...     readchannel(server)

  ...     server.stdin.write(b'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

  ...     bprint(b'server exit code =', b'%d' % server.wait())

  server exit code = 1

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

  >>> @check

  ... def serverinput(server):

  ...     readchannel(server)

  ... 

  ...     patch = b"""

  ... # 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, [b'import', b'-'], input=stringio(patch))

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

  *** runcommand import -

  applying patch from stdin

  *** runcommand log

  changeset:   0:eff892de26ec

  tag:         tip

  user:        test

  date:        Thu Jan 01 00:00:00 1970 +0000

  summary:     1

check strict parsing of early options:

  >>> import os

  >>> from hgclient import check, readchannel, runcommand

  >>> os.environ['HGPLAIN'] = '+strictflags'

  >>> @check

  ... def cwd(server):

  ...     readchannel(server)

  ...     runcommand(server, [b'log', b'-b', b'--config=alias.log=!echo pwned',

  ...                         b'default'])

  *** runcommand log -b --config=alias.log=!echo pwned default

  abort: unknown revision '--config=alias.log=!echo pwned'

   [255]

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

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

  >>> @check

  ... def serverinput(server):

  ...     readchannel(server)

  ...     rules = b'pick eff892de26ec\n'

  ...     runcommand(server, [b'histedit', b'0', b'--commands=-',

  ...                         b'--config', b'extensions.histedit='],

  ...                input=stringio(rules))

  *** runcommand histedit 0 --commands=- --config extensions.histedit=

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, [b'--cwd', b'foo', b'st', b'bar'])

  ...     runcommand(server, [b'st', b'foo/bar'])

  *** runcommand --cwd foo st bar

  ? bar

  *** runcommand st foo/bar

  ? 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

#if no-extraextensions

  >>> 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

  ...     # show it

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

  ... 

  ...     # but not for this repo

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

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

  *** runcommand showconfig

  bundle.mainreporoot=$TESTTMP/repo

  chgserver.idletimeout=60

  devel.all-warnings=true

  devel.default-date=0 0

  extensions.fsmonitor= (fsmonitor !)

  largefiles.usercache=$TESTTMP/.cache/largefiles

  lfs.usercache=$TESTTMP/.cache/lfs

  ui.slash=True

  ui.interactive=False

  ui.detailed-exit-code=True

  ui.merge=internal:merge

  ui.mergemarkers=detailed

  ui.ssh=* (glob)

  ui.timeout.warn=15

  ui.foo=bar

  ui.nontty=true

  web.address=localhost

  web\.ipv6=(?:True|False) (re)

  web.server-header=testing stub value

  *** runcommand init foo

  *** runcommand -R foo showconfig ui defaults

  ui.slash=True

  ui.interactive=False

  ui.detailed-exit-code=True

  ui.merge=internal:merge

  ui.mergemarkers=detailed

  ui.ssh=* (glob)

  ui.timeout.warn=15

  ui.nontty=true

#endif

  $ rm -R foo

#if windows

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

#else

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

#endif

  $ cat <<EOF > hook.py

  > import sys

  > from hgclient import bprint

  > def hook(**args):

  >     bprint(b'hook talking')

  >     bprint(b'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, [b'--config',

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

  ...                         b'id'],

  ...                input=stringio(b'some input'))

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

  eff892de26ec tip

  hook talking

  now try to read something: ''

Clean hook cached version

  $ 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, [b'status'])

  ...     os.system('hg ci -Am2')

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

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

  *** runcommand status

  M a

  *** runcommand tip

  changeset:   1:d3a0a68be6de

  tag:         tip

  user:        test

  date:        Thu Jan 01 00:00:00 1970 +0000

  summary:     2

  *** runcommand status

  >>> import os

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

  >>> @check

  ... def bookmarks(server):

  ...     readchannel(server)

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

  ... 

  ...     # changes .hg/bookmarks

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

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

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

  ... 

  ...     # changes .hg/bookmarks.current

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

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

  ... 

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

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

  ...     f.write(b'a\n') and None

  ...     f.close()

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

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

  ...     bprint(b'')

  *** runcommand bookmarks

  no bookmarks set

  *** runcommand bookmarks

     bm1                       1:d3a0a68be6de

     bm2                       1:d3a0a68be6de

  *** runcommand bookmarks

   * bm1                       1:d3a0a68be6de

     bm2                       1:d3a0a68be6de

  *** runcommand bookmarks bm3

  *** runcommand commit -Amm

  *** runcommand bookmarks

     bm1                       1:d3a0a68be6de

     bm2                       1:d3a0a68be6de

   * bm3                       2:aef17e88f5f0

  >>> import os

  >>> from hgclient import check, readchannel, runcommand

  >>> @check

  ... def tagscache(server):

  ...     readchannel(server)

  ...     runcommand(server, [b'id', b'-t', b'-r', b'0'])

  ...     os.system('hg tag -r 0 foo')

  ...     runcommand(server, [b'id', b'-t', b'-r', b'0'])

  *** runcommand id -t -r 0

  *** runcommand id -t -r 0

  foo

  >>> import os

  >>> from hgclient import check, readchannel, runcommand

  >>> @check

  ... def setphase(server):

  ...     readchannel(server)

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

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

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

  *** runcommand phase -r .

  3: draft

  *** runcommand phase -r .

  3: public

  $ echo a >> a

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

  >>> @check

  ... def rollback(server):

  ...     readchannel(server)

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

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

  ...     runcommand(server, [b'rollback'])

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

  ...     bprint(b'')

  *** runcommand phase -r . -p

  no phases changed

  *** runcommand commit -Am.

  *** runcommand rollback

  repository tip rolled back to revision 3 (undo commit)

  working directory now based on revision 3

  *** runcommand phase -r .

  3: public

  >>> import os

  >>> from hgclient import check, readchannel, runcommand

  >>> @check

  ... def branch(server):

  ...     readchannel(server)

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

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

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

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

  *** runcommand branch

  default

  marked working directory as branch foo

  (branches are permanent and global, did you want a bookmark?)

  *** runcommand 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 bprint, check, readchannel, runcommand

  >>> @check

  ... def hgignore(server):

  ...     readchannel(server)

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

  ...     f = open('ignored-file', 'ab')

  ...     f.write(b'') and None

  ...     f.close()

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

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

  ...     f.close()

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

  ...     bprint(b'')