comparison mercurial/debugcommands.py @ 37084:f0b6fbea00cf

stringutil: bulk-replace call sites to point to new module

This might conflict with other patches floating around, sorry.

37083:f99d64e8a4e4

    util,
    vfs as vfsmod,
    wireprotoframing,
    wireprotoserver,
)
from .utils import dateutil

release = lockmod.release

command = registrar.command()

    fm.write('encoding', _("checking encoding (%s)...\n"), encoding.encoding)
    err = None
    try:
        codecs.lookup(pycompat.sysstr(encoding.encoding))
    except LookupError as inst:
        err = util.forcebytestr(inst)
        problems += 1
    fm.condwrite(err, 'encodingerror', _(" %s\n"
                 " (check that your locale is properly set)\n"), err)

    # Python

                mpatch,
                osutil,
            )
            dir(bdiff), dir(mpatch), dir(base85), dir(osutil) # quiet pyflakes
        except Exception as inst:
            err = util.forcebytestr(inst)
            problems += 1
        fm.condwrite(err, 'extensionserror', " %s\n", err)

    compengines = util.compengines._engines.values()
    fm.write('compengines', _('checking registered compression engines (%s)\n'),

            # template found, check if it is working
            err = None
            try:
                templater.templater.frommapfile(m)
            except Exception as inst:
                err = util.forcebytestr(inst)
                p = None
            fm.condwrite(err, 'defaulttemplateerror', " %s\n", err)
        else:
            p = None
        fm.condwrite(p, 'defaulttemplate',

    username = None
    err = None
    try:
        username = ui.username()
    except error.Abort as e:
        err = util.forcebytestr(e)
        problems += 1

    fm.condwrite(username, 'username',  _("checking username (%s)\n"), username)
    fm.condwrite(err, 'usernameerror', _("checking username...\n %s\n"
        " (specify a username in your configuration file)\n"), err)

        r = target.pushkey(namespace, key, old, new)
        ui.status(pycompat.bytestr(r) + '\n')
        return not r
    else:
        for k, v in sorted(target.listkeys(namespace).iteritems()):
            ui.write("%s\t%s\n" % (util.escapestr(k),
                                   util.escapestr(v)))

@command('debugpvec', [], _('A B'))
def debugpvec(ui, repo, a, b=None):
    ca = scmutil.revsingle(repo, a)
    cb = scmutil.revsingle(repo, b)

            if not stdin:
                raise error.Abort(_('cannot call raw/raw+ on this peer'))

            # Concatenate the data together.
            data = ''.join(l.lstrip() for l in lines)
            data = util.unescapestr(data)
            stdin.write(data)

            if action == 'raw+':
                stdin.flush()
        elif action == 'flush':

                    key = fields[0]
                    value = ''
                else:
                    key, value = fields

                args[key] = util.unescapestr(value)

            if batchedcommands is not None:
                batchedcommands.append((command, args))
                continue

            if 'PUSHFILE' in args:
                with open(args['PUSHFILE'], r'rb') as fh:
                    del args['PUSHFILE']
                    res, output = peer._callpush(command, fh,
                                                 **pycompat.strkwargs(args))
                    ui.status(_('result: %s\n') % util.escapedata(res))
                    ui.status(_('remote output: %s\n') %
                              util.escapedata(output))
            else:
                res = peer._call(command, **pycompat.strkwargs(args))
                ui.status(_('response: %s\n') % util.escapedata(res))

        elif action == 'batchbegin':
            if batchedcommands is not None:
                raise error.Abort(_('nested batchbegin not allowed'))

            # difficult to normalize requests into function calls. It is easier
            # to bypass this layer and normalize to commands + args.
            ui.status(_('sending batch with %d sub-commands\n') %
                      len(batchedcommands))
            for i, chunk in enumerate(peer._submitbatch(batchedcommands)):
                ui.status(_('response #%d: %s\n') % (i, util.escapedata(chunk)))

            batchedcommands = None

        elif action.startswith('httprequest '):
            if not opener:

37084:f0b6fbea00cf

    util,
    vfs as vfsmod,
    wireprotoframing,
    wireprotoserver,
)
from .utils import (
    dateutil,
    stringutil,
)

release = lockmod.release

command = registrar.command()

    fm.write('encoding', _("checking encoding (%s)...\n"), encoding.encoding)
    err = None
    try:
        codecs.lookup(pycompat.sysstr(encoding.encoding))
    except LookupError as inst:
        err = stringutil.forcebytestr(inst)
        problems += 1
    fm.condwrite(err, 'encodingerror', _(" %s\n"
                 " (check that your locale is properly set)\n"), err)

    # Python

                mpatch,
                osutil,
            )
            dir(bdiff), dir(mpatch), dir(base85), dir(osutil) # quiet pyflakes
        except Exception as inst:
            err = stringutil.forcebytestr(inst)
            problems += 1
        fm.condwrite(err, 'extensionserror', " %s\n", err)

    compengines = util.compengines._engines.values()
    fm.write('compengines', _('checking registered compression engines (%s)\n'),

            # template found, check if it is working
            err = None
            try:
                templater.templater.frommapfile(m)
            except Exception as inst:
                err = stringutil.forcebytestr(inst)
                p = None
            fm.condwrite(err, 'defaulttemplateerror', " %s\n", err)
        else:
            p = None
        fm.condwrite(p, 'defaulttemplate',

    username = None
    err = None
    try:
        username = ui.username()
    except error.Abort as e:
        err = stringutil.forcebytestr(e)
        problems += 1

    fm.condwrite(username, 'username',  _("checking username (%s)\n"), username)
    fm.condwrite(err, 'usernameerror', _("checking username...\n %s\n"
        " (specify a username in your configuration file)\n"), err)

        r = target.pushkey(namespace, key, old, new)
        ui.status(pycompat.bytestr(r) + '\n')
        return not r
    else:
        for k, v in sorted(target.listkeys(namespace).iteritems()):
            ui.write("%s\t%s\n" % (stringutil.escapestr(k),
                                   stringutil.escapestr(v)))

@command('debugpvec', [], _('A B'))
def debugpvec(ui, repo, a, b=None):
    ca = scmutil.revsingle(repo, a)
    cb = scmutil.revsingle(repo, b)

            if not stdin:
                raise error.Abort(_('cannot call raw/raw+ on this peer'))

            # Concatenate the data together.
            data = ''.join(l.lstrip() for l in lines)
            data = stringutil.unescapestr(data)
            stdin.write(data)

            if action == 'raw+':
                stdin.flush()
        elif action == 'flush':

                    key = fields[0]
                    value = ''
                else:
                    key, value = fields

                args[key] = stringutil.unescapestr(value)

            if batchedcommands is not None:
                batchedcommands.append((command, args))
                continue

            if 'PUSHFILE' in args:
                with open(args['PUSHFILE'], r'rb') as fh:
                    del args['PUSHFILE']
                    res, output = peer._callpush(command, fh,
                                                 **pycompat.strkwargs(args))
                    ui.status(_('result: %s\n') % stringutil.escapedata(res))
                    ui.status(_('remote output: %s\n') %
                              stringutil.escapedata(output))
            else:
                res = peer._call(command, **pycompat.strkwargs(args))
                ui.status(_('response: %s\n') % stringutil.escapedata(res))

        elif action == 'batchbegin':
            if batchedcommands is not None:
                raise error.Abort(_('nested batchbegin not allowed'))

            # difficult to normalize requests into function calls. It is easier
            # to bypass this layer and normalize to commands + args.
            ui.status(_('sending batch with %d sub-commands\n') %
                      len(batchedcommands))
            for i, chunk in enumerate(peer._submitbatch(batchedcommands)):
                ui.status(_('response #%d: %s\n') %
                          (i, stringutil.escapedata(chunk)))

            batchedcommands = None

        elif action.startswith('httprequest '):
            if not opener: