mercurial/ui.py

40589:054d0fcba2c4

            raise error.StdioError(err)
        finally:
            self._blockedtimes['stdio_blocked'] += \
                (util.timer() - starttime) * 1000

    def flush(self):
        # opencode timeblockedsection because this is a critical path
        starttime = util.timer()
        try:
            try:

    def prompt(self, msg, default="y"):
        """Prompt user with msg, read response.
        If ui is not interactive, the default is returned.
        """
        if not self.interactive():
            self._write(self._fmsgout, msg, ' ', label='ui.prompt')
            self._write(self._fmsgout, default or '', "\n",
                        label='ui.promptecho')
            return default
        self._writenobuf(self._fmsgout, msg, label='ui.prompt')
        self.flush()
        try:
            r = self._readline()
            if not r:
                r = default
            if self.configbool('ui', 'promptecho'):
                self._write(self._fmsgout, r, "\n", label='ui.promptecho')
            return r
        except EOFError:
            raise error.ResponseExpected()

    @staticmethod

        while True:
            r = self.prompt(msg, resps[default])
            if r.lower() in resps:
                return resps.index(r.lower())
            # TODO: shouldn't it be a warning?
            self._write(self._fmsgout, _("unrecognized response\n"))

    def getpass(self, prompt=None, default=None):
        if not self.interactive():
            return default
        try:
            self._write(self._fmsgerr, prompt or _('password: '),
                        label='ui.prompt')
            # disable getpass() only if explicitly specified. it's still valid
            # to interact with tty even if fin is not a tty.
            with self.timeblockedsection('stdio'):
                if self.configbool('ui', 'nontty'):
                    l = self._fin.readline()

        '''write status message to output (if ui.quiet is False)

        This adds an output label of "ui.status".
        '''
        if not self.quiet:
            opts[r'label'] = opts.get(r'label', '') + ' ui.status'
            self._write(self._fmsgout, *msg, **opts)

    def warn(self, *msg, **opts):
        '''write warning message to output (stderr)

        This adds an output label of "ui.warning".
        '''
        opts[r'label'] = opts.get(r'label', '') + ' ui.warning'
        self._write(self._fmsgerr, *msg, **opts)

    def error(self, *msg, **opts):
        '''write error message to output (stderr)

        This adds an output label of "ui.error".
        '''
        opts[r'label'] = opts.get(r'label', '') + ' ui.error'
        self._write(self._fmsgerr, *msg, **opts)

    def note(self, *msg, **opts):
        '''write note to output (if ui.verbose is True)

        This adds an output label of "ui.note".
        '''
        if self.verbose:
            opts[r'label'] = opts.get(r'label', '') + ' ui.note'
            self._write(self._fmsgout, *msg, **opts)

    def debug(self, *msg, **opts):
        '''write debug message to output (if ui.debugflag is True)

        This adds an output label of "ui.debug".
        '''
        if self.debugflag:
            opts[r'label'] = opts.get(r'label', '') + ' ui.debug'
            self._write(self._fmsgout, *msg, **opts)

    def edit(self, text, user, extra=None, editform=None, pending=None,
             repopath=None, action=None):
        if action is None:
            self.develwarn('action is None but will soon be a required '

    if name == b'stdio':
        return ui.fout, ui.ferr
    if name == b'stderr':
        return ui.ferr, ui.ferr
    raise error.Abort(b'invalid ui.message-output destination: %s' % name)

40590:83dd8c63a0c6

            raise error.StdioError(err)
        finally:
            self._blockedtimes['stdio_blocked'] += \
                (util.timer() - starttime) * 1000

    def _writemsg(self, dest, *args, **opts):
        _writemsgwith(self._write, dest, *args, **opts)

    def _writemsgnobuf(self, dest, *args, **opts):
        _writemsgwith(self._writenobuf, dest, *args, **opts)

    def flush(self):
        # opencode timeblockedsection because this is a critical path
        starttime = util.timer()
        try:
            try:

    def prompt(self, msg, default="y"):
        """Prompt user with msg, read response.
        If ui is not interactive, the default is returned.
        """
        if not self.interactive():
            self._writemsg(self._fmsgout, msg, ' ', type='prompt')
            self._writemsg(self._fmsgout, default or '', "\n",
                           type='promptecho')
            return default
        self._writemsgnobuf(self._fmsgout, msg, type='prompt')
        self.flush()
        try:
            r = self._readline()
            if not r:
                r = default
            if self.configbool('ui', 'promptecho'):
                self._writemsg(self._fmsgout, r, "\n", type='promptecho')
            return r
        except EOFError:
            raise error.ResponseExpected()

    @staticmethod

        while True:
            r = self.prompt(msg, resps[default])
            if r.lower() in resps:
                return resps.index(r.lower())
            # TODO: shouldn't it be a warning?
            self._writemsg(self._fmsgout, _("unrecognized response\n"))

    def getpass(self, prompt=None, default=None):
        if not self.interactive():
            return default
        try:
            self._writemsg(self._fmsgerr, prompt or _('password: '),
                           type='prompt')
            # disable getpass() only if explicitly specified. it's still valid
            # to interact with tty even if fin is not a tty.
            with self.timeblockedsection('stdio'):
                if self.configbool('ui', 'nontty'):
                    l = self._fin.readline()

        '''write status message to output (if ui.quiet is False)

        This adds an output label of "ui.status".
        '''
        if not self.quiet:
            self._writemsg(self._fmsgout, type='status', *msg, **opts)

    def warn(self, *msg, **opts):
        '''write warning message to output (stderr)

        This adds an output label of "ui.warning".
        '''
        self._writemsg(self._fmsgerr, type='warning', *msg, **opts)

    def error(self, *msg, **opts):
        '''write error message to output (stderr)

        This adds an output label of "ui.error".
        '''
        self._writemsg(self._fmsgerr, type='error', *msg, **opts)

    def note(self, *msg, **opts):
        '''write note to output (if ui.verbose is True)

        This adds an output label of "ui.note".
        '''
        if self.verbose:
            self._writemsg(self._fmsgout, type='note', *msg, **opts)

    def debug(self, *msg, **opts):
        '''write debug message to output (if ui.debugflag is True)

        This adds an output label of "ui.debug".
        '''
        if self.debugflag:
            self._writemsg(self._fmsgout, type='debug', *msg, **opts)

    def edit(self, text, user, extra=None, editform=None, pending=None,
             repopath=None, action=None):
        if action is None:
            self.develwarn('action is None but will soon be a required '

    if name == b'stdio':
        return ui.fout, ui.ferr
    if name == b'stderr':
        return ui.ferr, ui.ferr
    raise error.Abort(b'invalid ui.message-output destination: %s' % name)

def _writemsgwith(write, dest, *args, **opts):
    """Write ui message with the given ui._write*() function

    The specified message type is translated to 'ui.<type>' label if the dest
    isn't a structured channel, so that the message will be colorized.
    """
    # TODO: maybe change 'type' to a mandatory option
    if r'type' in opts and not getattr(dest, 'structured', False):
        opts[r'label'] = opts.get(r'label', '') + ' ui.%s' % opts.pop(r'type')
    write(dest, *args, **opts)