upstream/mercurial-mirror Files · tests/test-wireproto.py

revset: lookup descendents for negative arguments to ancestor operator...

revset: lookup descendents for negative arguments to ancestor operator Negative offsets to the `~` operator now search for descendents. The search is aborted when a node has more than one child as we do not have a definition for 'nth child'. Optionally we can introduce such a notion and take the nth child ordered by rev number. The current revset language does provides a short operator for ancestor lookup but not for descendents. This gives user a simple revset to move to the previous changeset, e.g. `hg up '.~1'` but not to the 'next' changeset. With this change userse can now use `.~-1` as a shortcut to move to the next changeset. This fits better into allowing users to specify revisions via revsets and avoiding the need for special `hg next` and `hg prev` operations. The alternative to negative offsets is adding a new operator. We do not have many operators in ascii left that do not require bash escaping (',', '_', and '/' come to mind). If we decide that we should add a more convenient short operator such as ('/', e.g. './1') we can later add it and allow ascendents lookup via negative numbers.

timeless - - Load All Authors

File last commit:

r28861:86db5cb5 default


                r32699:f75d0aa5

default

Download file

             test-wireproto.py
        
                    61 lines
            
             | 1.4 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / tests / test-wireproto.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      from __future__ import absolute_import, print_function

      from mercurial import (

          util,

          wireproto,

      )

      stringio = util.stringio

      class proto(object):

          def __init__(self, args):

              self.args = args

          def getargs(self, spec):

              args = self.args

              args.setdefault('*', {})

              names = spec.split()

              return [args[n] for n in names]

      class clientpeer(wireproto.wirepeer):

          def __init__(self, serverrepo):

              self.serverrepo = serverrepo

          def _capabilities(self):

              return ['batch']

          def _call(self, cmd, **args):

              return wireproto.dispatch(self.serverrepo, proto(args), cmd)

          def _callstream(self, cmd, **args):

              return stringio(self._call(cmd, **args))

          @wireproto.batchable

          def greet(self, name):

              f = wireproto.future()

              yield {'name': mangle(name)}, f

              yield unmangle(f.value)

      class serverrepo(object):

          def greet(self, name):

              return "Hello, " + name

          def filtered(self, name):

              return self

      def mangle(s):

          return ''.join(chr(ord(c) + 1) for c in s)

      def unmangle(s):

          return ''.join(chr(ord(c) - 1) for c in s)

      def greet(repo, proto, name):

          return mangle(repo.greet(unmangle(name)))

      wireproto.commands['greet'] = (greet, 'name',)

      srv = serverrepo()

      clt = clientpeer(srv)

      print(clt.greet("Foobar"))

      b = clt.batch()

      fs = [b.greet(s) for s in ["Fo, =;:<o", "Bar"]]

      b.submit()

      print([f.value for f in fs])

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

				from __future__ import absolute_import, print_function

				from mercurial import (
				util,
				wireproto,
				)
				stringio = util.stringio

				class proto(object):
				def __init__(self, args):
				self.args = args
				def getargs(self, spec):
				args = self.args
				args.setdefault('*', {})
				names = spec.split()
				return [args[n] for n in names]

				class clientpeer(wireproto.wirepeer):
				def __init__(self, serverrepo):
				self.serverrepo = serverrepo

				def _capabilities(self):
				return ['batch']

				def _call(self, cmd, **args):
				return wireproto.dispatch(self.serverrepo, proto(args), cmd)

				def _callstream(self, cmd, **args):
				return stringio(self._call(cmd, **args))

				@wireproto.batchable
				def greet(self, name):
				f = wireproto.future()
				yield {'name': mangle(name)}, f
				yield unmangle(f.value)

				class serverrepo(object):
				def greet(self, name):
				return "Hello, " + name

				def filtered(self, name):
				return self

				def mangle(s):
				return ''.join(chr(ord(c) + 1) for c in s)
				def unmangle(s):
				return ''.join(chr(ord(c) - 1) for c in s)

				def greet(repo, proto, name):
				return mangle(repo.greet(unmangle(name)))

				wireproto.commands['greet'] = (greet, 'name',)

				srv = serverrepo()
				clt = clientpeer(srv)

				print(clt.greet("Foobar"))
				b = clt.batch()
				fs = [b.greet(s) for s in ["Fo, =;:<o", "Bar"]]
				b.submit()
				print([f.value for f in fs])