Gecko [ fernandoquevedodop.com ]

Name	Size	Permission
__pycache__	[ DIR ]	drwxr-xr-x
cext	[ DIR ]	drwxr-xr-x
cffi	[ DIR ]	drwxr-xr-x
defaultrc	[ DIR ]	drwxr-xr-x
dirstateutils	[ DIR ]	drwxr-xr-x
helptext	[ DIR ]	drwxr-xr-x
hgweb	[ DIR ]	drwxr-xr-x
interfaces	[ DIR ]	drwxr-xr-x
locale	[ DIR ]	drwxr-xr-x
pure	[ DIR ]	drwxr-xr-x
revlogutils	[ DIR ]	drwxr-xr-x
templates	[ DIR ]	drwxr-xr-x
testing	[ DIR ]	drwxr-xr-x
thirdparty	[ DIR ]	drwxr-xr-x
upgrade_utils	[ DIR ]	drwxr-xr-x
utils	[ DIR ]	drwxr-xr-x
__init__.py	416 B	-rw-r--r--
__modulepolicy__.py	61 B	-rw-r--r--
__version__.py	60 B	-rw-r--r--
ancestor.py	12.51 KB	-rw-r--r--
archival.py	11.59 KB	-rw-r--r--
bookmarks.py	34.74 KB	-rw-r--r--
branchmap.py	31.58 KB	-rw-r--r--
bundle2.py	86.74 KB	-rw-r--r--
bundlecaches.py	13.6 KB	-rw-r--r--
bundlerepo.py	23.29 KB	-rw-r--r--
cacheutil.py	827 B	-rw-r--r--
changegroup.py	65.72 KB	-rw-r--r--
changelog.py	19.72 KB	-rw-r--r--
chgserver.py	26.25 KB	-rw-r--r--
cmdutil.py	131.98 KB	-rw-r--r--
color.py	17.93 KB	-rw-r--r--
commands.py	257.93 KB	-rw-r--r--
commandserver.py	24.59 KB	-rw-r--r--
commit.py	18.52 KB	-rw-r--r--
config.py	8.59 KB	-rw-r--r--
configitems.py	46.49 KB	-rw-r--r--
context.py	100.53 KB	-rw-r--r--
copies.py	46.01 KB	-rw-r--r--
crecord.py	70.99 KB	-rw-r--r--
dagop.py	39.57 KB	-rw-r--r--
dagparser.py	15.13 KB	-rw-r--r--
debugcommands.py	154.84 KB	-rw-r--r--
destutil.py	17.07 KB	-rw-r--r--
diffhelper.py	2.32 KB	-rw-r--r--
diffutil.py	4.52 KB	-rw-r--r--
dirstate.py	51.01 KB	-rw-r--r--
dirstateguard.py	3.09 KB	-rw-r--r--
dirstatemap.py	23.77 KB	-rw-r--r--
discovery.py	22 KB	-rw-r--r--
dispatch.py	46.19 KB	-rw-r--r--
dummycert.pem	2.19 KB	-rw-r--r--
encoding.py	22.89 KB	-rw-r--r--
error.py	17.88 KB	-rw-r--r--
exchange.py	94.65 KB	-rw-r--r--
extensions.py	30.6 KB	-rw-r--r--
exthelper.py	11.83 KB	-rw-r--r--
fancyopts.py	11.3 KB	-rw-r--r--
filelog.py	8.58 KB	-rw-r--r--
filemerge.py	39.67 KB	-rw-r--r--
fileset.py	18.66 KB	-rw-r--r--
filesetlang.py	10.34 KB	-rw-r--r--
formatter.py	26.34 KB	-rw-r--r--
graphmod.py	16.76 KB	-rw-r--r--
grep.py	7.26 KB	-rw-r--r--
hbisect.py	10.89 KB	-rw-r--r--
help.py	36.74 KB	-rw-r--r--
hg.py	51.95 KB	-rw-r--r--
hook.py	11.53 KB	-rw-r--r--
httpconnection.py	4.27 KB	-rw-r--r--
httppeer.py	20.71 KB	-rw-r--r--
i18n.py	4.05 KB	-rw-r--r--
keepalive.py	27.1 KB	-rw-r--r--
linelog.py	14.94 KB	-rw-r--r--
localrepo.py	140.97 KB	-rw-r--r--
lock.py	11.89 KB	-rw-r--r--
logcmdutil.py	42.53 KB	-rw-r--r--
logexchange.py	4.98 KB	-rw-r--r--
loggingutil.py	3.93 KB	-rw-r--r--
lsprof.py	4.25 KB	-rw-r--r--
lsprofcalltree.py	2.74 KB	-rw-r--r--
mail.py	17.09 KB	-rw-r--r--
manifest.py	75.45 KB	-rw-r--r--
match.py	52.06 KB	-rw-r--r--
mdiff.py	17.37 KB	-rw-r--r--
merge.py	90.09 KB	-rw-r--r--
mergestate.py	31.37 KB	-rw-r--r--
mergeutil.py	502 B	-rw-r--r--
metadata.py	32.33 KB	-rw-r--r--
minifileset.py	3.54 KB	-rw-r--r--
minirst.py	29.13 KB	-rw-r--r--
namespaces.py	8.19 KB	-rw-r--r--
narrowspec.py	11.57 KB	-rw-r--r--
node.py	2.07 KB	-rw-r--r--
obsolete.py	36.76 KB	-rw-r--r--
obsutil.py	35.84 KB	-rw-r--r--
parser.py	25.68 KB	-rw-r--r--
patch.py	102 KB	-rw-r--r--
pathutil.py	12.21 KB	-rw-r--r--
phases.py	32.54 KB	-rw-r--r--
policy.py	4.74 KB	-rw-r--r--
posix.py	23.05 KB	-rw-r--r--
profiling.py	8.64 KB	-rw-r--r--
progress.py	10.92 KB	-rw-r--r--
pushkey.py	1.67 KB	-rw-r--r--
pvec.py	6.01 KB	-rw-r--r--
pycompat.py	16.33 KB	-rw-r--r--
rcutil.py	3.57 KB	-rw-r--r--
registrar.py	17.78 KB	-rw-r--r--
repair.py	18.46 KB	-rw-r--r--
repocache.py	4.49 KB	-rw-r--r--
repoview.py	16.89 KB	-rw-r--r--
requirements.py	4.64 KB	-rw-r--r--
revlog.py	117.08 KB	-rw-r--r--
revset.py	87.27 KB	-rw-r--r--
revsetlang.py	28.47 KB	-rw-r--r--
rewriteutil.py	8.47 KB	-rw-r--r--
scmposix.py	2.57 KB	-rw-r--r--
scmutil.py	75.72 KB	-rw-r--r--
scmwindows.py	3.37 KB	-rw-r--r--
server.py	7.05 KB	-rw-r--r--
setdiscovery.py	18 KB	-rw-r--r--
shelve.py	38.04 KB	-rw-r--r--
similar.py	3.97 KB	-rw-r--r--
simplemerge.py	16.86 KB	-rw-r--r--
smartset.py	33.65 KB	-rw-r--r--
sparse.py	26.37 KB	-rw-r--r--
sshpeer.py	22.56 KB	-rw-r--r--
sslutil.py	35.54 KB	-rw-r--r--
stack.py	762 B	-rw-r--r--
state.py	11.99 KB	-rw-r--r--
statichttprepo.py	7.92 KB	-rw-r--r--
statprof.py	32.16 KB	-rw-r--r--
store.py	25.27 KB	-rw-r--r--
streamclone.py	30.73 KB	-rw-r--r--
strip.py	8.72 KB	-rw-r--r--
subrepo.py	70.89 KB	-rw-r--r--
subrepoutil.py	17.42 KB	-rw-r--r--
tagmerge.py	11.29 KB	-rw-r--r--
tags.py	29.67 KB	-rw-r--r--
templatefilters.py	15.11 KB	-rw-r--r--
templatefuncs.py	30.14 KB	-rw-r--r--
templatekw.py	34.12 KB	-rw-r--r--
templater.py	37.7 KB	-rw-r--r--
templateutil.py	35.66 KB	-rw-r--r--
transaction.py	25.97 KB	-rw-r--r--
treediscovery.py	5.92 KB	-rw-r--r--
txnutil.py	1.02 KB	-rw-r--r--
ui.py	80.23 KB	-rw-r--r--
unionrepo.py	9.72 KB	-rw-r--r--
upgrade.py	14.59 KB	-rw-r--r--
url.py	24.56 KB	-rw-r--r--
urllibcompat.py	5.94 KB	-rw-r--r--
util.py	95.18 KB	-rw-r--r--
verify.py	21.8 KB	-rw-r--r--
vfs.py	24.93 KB	-rw-r--r--
win32.py	22.04 KB	-rw-r--r--
windows.py	21.77 KB	-rw-r--r--
wireprotoframing.py	64.95 KB	-rw-r--r--
wireprotoserver.py	17.38 KB	-rw-r--r--
wireprototypes.py	13.07 KB	-rw-r--r--
wireprotov1peer.py	21.51 KB	-rw-r--r--
wireprotov1server.py	26.33 KB	-rw-r--r--
worker.py	15.47 KB	-rw-r--r--
zstd.cpython-310-x86_64-linux-...	570.78 KB	-rw-r--r--

Code Editor : changelog.py

# changelog.py - changelog class for mercurial
#
# Copyright 2005-2007 Olivia Mackall <olivia@selenic.com>
#
# This software may be used and distributed according to the terms of the
# GNU General Public License version 2 or any later version.

from __future__ import absolute_import

from .i18n import _
from .node import (
    bin,
    hex,
)
from .thirdparty import attr

from . import (
    encoding,
    error,
    metadata,
    pycompat,
    revlog,
)
from .utils import (
    dateutil,
    stringutil,
)
from .revlogutils import (
    constants as revlog_constants,
    flagutil,
)

_defaultextra = {b'branch': b'default'}

def _string_escape(text):
    """
    >>> from .pycompat import bytechr as chr
    >>> d = {b'nl': chr(10), b'bs': chr(92), b'cr': chr(13), b'nul': chr(0)}
    >>> s = b"ab%(nl)scd%(bs)s%(bs)sn%(nul)s12ab%(cr)scd%(bs)s%(nl)s" % d
    >>> s
    'ab\\ncd\\\\\\\\n\\x0012ab\\rcd\\\\\\n'
    >>> res = _string_escape(s)
    >>> s == _string_unescape(res)
    True
    """
    # subset of the string_escape codec
    text = (
        text.replace(b'\\', b'\\\\')
        .replace(b'\n', b'\\n')
        .replace(b'\r', b'\\r')
    )
    return text.replace(b'\0', b'\\0')

def _string_unescape(text):
    if b'\\0' in text:
        # fix up \0 without getting into trouble with \\0
        text = text.replace(b'\\\\', b'\\\\\n')
        text = text.replace(b'\\0', b'\0')
        text = text.replace(b'\n', b'')
    return stringutil.unescapestr(text)

def decodeextra(text):
    """
    >>> from .pycompat import bytechr as chr
    >>> sorted(decodeextra(encodeextra({b'foo': b'bar', b'baz': chr(0) + b'2'})
    ...                    ).items())
    [('baz', '\\x002'), ('branch', 'default'), ('foo', 'bar')]
    >>> sorted(decodeextra(encodeextra({b'foo': b'bar',
    ...                                 b'baz': chr(92) + chr(0) + b'2'})
    ...                    ).items())
    [('baz', '\\\\\\x002'), ('branch', 'default'), ('foo', 'bar')]
    """
    extra = _defaultextra.copy()
    for l in text.split(b'\0'):
        if l:
            k, v = _string_unescape(l).split(b':', 1)
            extra[k] = v
    return extra

def encodeextra(d):
    # keys must be sorted to produce a deterministic changelog entry
    items = [_string_escape(b'%s:%s' % (k, d[k])) for k in sorted(d)]
    return b"\0".join(items)

def stripdesc(desc):
    """strip trailing whitespace and leading and trailing empty lines"""
    return b'\n'.join([l.rstrip() for l in desc.splitlines()]).strip(b'\n')

class appender(object):
    """the changelog index must be updated last on disk, so we use this class
    to delay writes to it"""

def __init__(self, vfs, name, mode, buf):
        self.data = buf
        fp = vfs(name, mode)
        self.fp = fp
        self.offset = fp.tell()
        self.size = vfs.fstat(fp).st_size
        self._end = self.size

def end(self):
        return self._end

def tell(self):
        return self.offset

def flush(self):
        pass

@property
    def closed(self):
        return self.fp.closed

def close(self):
        self.fp.close()

def seek(self, offset, whence=0):
        '''virtual file offset spans real file and data'''
        if whence == 0:
            self.offset = offset
        elif whence == 1:
            self.offset += offset
        elif whence == 2:
            self.offset = self.end() + offset
        if self.offset < self.size:
            self.fp.seek(self.offset)

def read(self, count=-1):
        '''only trick here is reads that span real file and data'''
        ret = b""
        if self.offset < self.size:
            s = self.fp.read(count)
            ret = s
            self.offset += len(s)
            if count > 0:
                count -= len(s)
        if count != 0:
            doff = self.offset - self.size
            self.data.insert(0, b"".join(self.data))
            del self.data[1:]
            s = self.data[0][doff : doff + count]
            self.offset += len(s)
            ret += s
        return ret

def write(self, s):
        self.data.append(bytes(s))
        self.offset += len(s)
        self._end += len(s)

def __enter__(self):
        self.fp.__enter__()
        return self

def __exit__(self, *args):
        return self.fp.__exit__(*args)

class _divertopener(object):
    def __init__(self, opener, target):
        self._opener = opener
        self._target = target

def __call__(self, name, mode=b'r', checkambig=False, **kwargs):
        if name != self._target:
            return self._opener(name, mode, **kwargs)
        return self._opener(name + b".a", mode, **kwargs)

def __getattr__(self, attr):
        return getattr(self._opener, attr)

def _delayopener(opener, target, buf):
    """build an opener that stores chunks in 'buf' instead of 'target'"""

def _delay(name, mode=b'r', checkambig=False, **kwargs):
        if name != target:
            return opener(name, mode, **kwargs)
        assert not kwargs
        return appender(opener, name, mode, buf)

return _delay

@attr.s
class _changelogrevision(object):
    # Extensions might modify _defaultextra, so let the constructor below pass
    # it in
    extra = attr.ib()
    manifest = attr.ib()
    user = attr.ib(default=b'')
    date = attr.ib(default=(0, 0))
    files = attr.ib(default=attr.Factory(list))
    filesadded = attr.ib(default=None)
    filesremoved = attr.ib(default=None)
    p1copies = attr.ib(default=None)
    p2copies = attr.ib(default=None)
    description = attr.ib(default=b'')
    branchinfo = attr.ib(default=(_defaultextra[b'branch'], False))

class changelogrevision(object):
    """Holds results of a parsed changelog revision.

Changelog revisions consist of multiple pieces of data, including
    the manifest node, user, and date. This object exposes a view into
    the parsed object.
    """

__slots__ = (
        '_offsets',
        '_text',
        '_sidedata',
        '_cpsd',
        '_changes',
    )

def __new__(cls, cl, text, sidedata, cpsd):
        if not text:
            return _changelogrevision(extra=_defaultextra, manifest=cl.nullid)

self = super(changelogrevision, cls).__new__(cls)
        # We could return here and implement the following as an __init__.
        # But doing it here is equivalent and saves an extra function call.

# format used:
        # nodeid\n        : manifest node in ascii
        # user\n          : user, no \n or \r allowed
        # time tz extra\n : date (time is int or float, timezone is int)
        #                 : extra is metadata, encoded and separated by '\0'
        #                 : older versions ignore it
        # files\n\n       : files modified by the cset, no \n or \r allowed
        # (.*)            : comment (free text, ideally utf-8)
        #
        # changelog v0 doesn't use extra

nl1 = text.index(b'\n')
        nl2 = text.index(b'\n', nl1 + 1)
        nl3 = text.index(b'\n', nl2 + 1)

# The list of files may be empty. Which means nl3 is the first of the
        # double newline that precedes the description.
        if text[nl3 + 1 : nl3 + 2] == b'\n':
            doublenl = nl3
        else:
            doublenl = text.index(b'\n\n', nl3 + 1)

self._offsets = (nl1, nl2, nl3, doublenl)
        self._text = text
        self._sidedata = sidedata
        self._cpsd = cpsd
        self._changes = None

return self

@property
    def manifest(self):
        return bin(self._text[0 : self._offsets[0]])

@property
    def user(self):
        off = self._offsets
        return encoding.tolocal(self._text[off[0] + 1 : off[1]])

@property
    def _rawdate(self):
        off = self._offsets
        dateextra = self._text[off[1] + 1 : off[2]]
        return dateextra.split(b' ', 2)[0:2]

@property
    def _rawextra(self):
        off = self._offsets
        dateextra = self._text[off[1] + 1 : off[2]]
        fields = dateextra.split(b' ', 2)
        if len(fields) != 3:
            return None

return fields[2]

@property
    def date(self):
        raw = self._rawdate
        time = float(raw[0])
        # Various tools did silly things with the timezone.
        try:
            timezone = int(raw[1])
        except ValueError:
            timezone = 0

return time, timezone

@property
    def extra(self):
        raw = self._rawextra
        if raw is None:
            return _defaultextra

return decodeextra(raw)

@property
    def changes(self):
        if self._changes is not None:
            return self._changes
        if self._cpsd:
            changes = metadata.decode_files_sidedata(self._sidedata)
        else:
            changes = metadata.ChangingFiles(
                touched=self.files or (),
                added=self.filesadded or (),
                removed=self.filesremoved or (),
                p1_copies=self.p1copies or {},
                p2_copies=self.p2copies or {},
            )
        self._changes = changes
        return changes

@property
    def files(self):
        if self._cpsd:
            return sorted(self.changes.touched)
        off = self._offsets
        if off[2] == off[3]:
            return []

return self._text[off[2] + 1 : off[3]].split(b'\n')

@property
    def filesadded(self):
        if self._cpsd:
            return self.changes.added
        else:
            rawindices = self.extra.get(b'filesadded')
        if rawindices is None:
            return None
        return metadata.decodefileindices(self.files, rawindices)

@property
    def filesremoved(self):
        if self._cpsd:
            return self.changes.removed
        else:
            rawindices = self.extra.get(b'filesremoved')
        if rawindices is None:
            return None
        return metadata.decodefileindices(self.files, rawindices)

@property
    def p1copies(self):
        if self._cpsd:
            return self.changes.copied_from_p1
        else:
            rawcopies = self.extra.get(b'p1copies')
        if rawcopies is None:
            return None
        return metadata.decodecopies(self.files, rawcopies)

@property
    def p2copies(self):
        if self._cpsd:
            return self.changes.copied_from_p2
        else:
            rawcopies = self.extra.get(b'p2copies')
        if rawcopies is None:
            return None
        return metadata.decodecopies(self.files, rawcopies)

@property
    def description(self):
        return encoding.tolocal(self._text[self._offsets[3] + 2 :])

@property
    def branchinfo(self):
        extra = self.extra
        return encoding.tolocal(extra.get(b"branch")), b'close' in extra

class changelog(revlog.revlog):
    def __init__(self, opener, trypending=False, concurrencychecker=None):
        """Load a changelog revlog using an opener.

If ``trypending`` is true, we attempt to load the index from a
        ``00changelog.i.a`` file instead of the default ``00changelog.i``.
        The ``00changelog.i.a`` file contains index (and possibly inline
        revision) data for a transaction that hasn't been finalized yet.
        It exists in a separate file to facilitate readers (such as
        hooks processes) accessing data before a transaction is finalized.

``concurrencychecker`` will be passed to the revlog init function, see
        the documentation there.
        """
        revlog.revlog.__init__(
            self,
            opener,
            target=(revlog_constants.KIND_CHANGELOG, None),
            radix=b'00changelog',
            checkambig=True,
            mmaplargeindex=True,
            persistentnodemap=opener.options.get(b'persistent-nodemap', False),
            concurrencychecker=concurrencychecker,
            trypending=trypending,
        )

if self._initempty and (self._format_version == revlog.REVLOGV1):
            # changelogs don't benefit from generaldelta.

self._format_flags &= ~revlog.FLAG_GENERALDELTA
            self._generaldelta = False

# Delta chains for changelogs tend to be very small because entries
        # tend to be small and don't delta well with each. So disable delta
        # chains.
        self._storedeltachains = False

self._realopener = opener
        self._delayed = False
        self._delaybuf = None
        self._divert = False
        self._filteredrevs = frozenset()
        self._filteredrevs_hashcache = {}
        self._copiesstorage = opener.options.get(b'copies-storage')

@property
    def filteredrevs(self):
        return self._filteredrevs

@filteredrevs.setter
    def filteredrevs(self, val):
        # Ensure all updates go through this function
        assert isinstance(val, frozenset)
        self._filteredrevs = val
        self._filteredrevs_hashcache = {}

def _write_docket(self, tr):
        if not self._delayed:
            super(changelog, self)._write_docket(tr)

def delayupdate(self, tr):
        """delay visibility of index updates to other readers"""
        if self._docket is None and not self._delayed:
            if len(self) == 0:
                self._divert = True
                if self._realopener.exists(self._indexfile + b'.a'):
                    self._realopener.unlink(self._indexfile + b'.a')
                self.opener = _divertopener(self._realopener, self._indexfile)
            else:
                self._delaybuf = []
                self.opener = _delayopener(
                    self._realopener, self._indexfile, self._delaybuf
                )
            self._segmentfile.opener = self.opener
            self._segmentfile_sidedata.opener = self.opener
        self._delayed = True
        tr.addpending(b'cl-%i' % id(self), self._writepending)
        tr.addfinalize(b'cl-%i' % id(self), self._finalize)

def _finalize(self, tr):
        """finalize index updates"""
        self._delayed = False
        self.opener = self._realopener
        self._segmentfile.opener = self.opener
        self._segmentfile_sidedata.opener = self.opener
        # move redirected index data back into place
        if self._docket is not None:
            self._write_docket(tr)
        elif self._divert:
            assert not self._delaybuf
            tmpname = self._indexfile + b".a"
            nfile = self.opener.open(tmpname)
            nfile.close()
            self.opener.rename(tmpname, self._indexfile, checkambig=True)
        elif self._delaybuf:
            fp = self.opener(self._indexfile, b'a', checkambig=True)
            fp.write(b"".join(self._delaybuf))
            fp.close()
            self._delaybuf = None
        self._divert = False
        # split when we're done
        self._enforceinlinesize(tr)

def _writepending(self, tr):
        """create a file containing the unfinalized state for
        pretxnchangegroup"""
        if self._docket:
            return self._docket.write(tr, pending=True)
        if self._delaybuf:
            # make a temporary copy of the index
            fp1 = self._realopener(self._indexfile)
            pendingfilename = self._indexfile + b".a"
            # register as a temp file to ensure cleanup on failure
            tr.registertmp(pendingfilename)
            # write existing data
            fp2 = self._realopener(pendingfilename, b"w")
            fp2.write(fp1.read())
            # add pending data
            fp2.write(b"".join(self._delaybuf))
            fp2.close()
            # switch modes so finalize can simply rename
            self._delaybuf = None
            self._divert = True
            self.opener = _divertopener(self._realopener, self._indexfile)
            self._segmentfile.opener = self.opener
            self._segmentfile_sidedata.opener = self.opener

if self._divert:
            return True

return False

def _enforceinlinesize(self, tr):
        if not self._delayed:
            revlog.revlog._enforceinlinesize(self, tr)

def read(self, nodeorrev):
        """Obtain data from a parsed changelog revision.

Returns a 6-tuple of:

- manifest node in binary
           - author/user as a localstr
           - date as a 2-tuple of (time, timezone)
           - list of files
           - commit message as a localstr
           - dict of extra metadata

Unless you need to access all fields, consider calling
        ``changelogrevision`` instead, as it is faster for partial object
        access.
        """
        d = self._revisiondata(nodeorrev)
        sidedata = self.sidedata(nodeorrev)
        copy_sd = self._copiesstorage == b'changeset-sidedata'
        c = changelogrevision(self, d, sidedata, copy_sd)
        return (c.manifest, c.user, c.date, c.files, c.description, c.extra)

def changelogrevision(self, nodeorrev):
        """Obtain a ``changelogrevision`` for a node or revision."""
        text = self._revisiondata(nodeorrev)
        sidedata = self.sidedata(nodeorrev)
        return changelogrevision(
            self, text, sidedata, self._copiesstorage == b'changeset-sidedata'
        )

def readfiles(self, nodeorrev):
        """
        short version of read that only returns the files modified by the cset
        """
        text = self.revision(nodeorrev)
        if not text:
            return []
        last = text.index(b"\n\n")
        l = text[:last].split(b'\n')
        return l[3:]

def add(
        self,
        manifest,
        files,
        desc,
        transaction,
        p1,
        p2,
        user,
        date=None,
        extra=None,
    ):
        # Convert to UTF-8 encoded bytestrings as the very first
        # thing: calling any method on a localstr object will turn it
        # into a str object and the cached UTF-8 string is thus lost.
        user, desc = encoding.fromlocal(user), encoding.fromlocal(desc)

user = user.strip()
        # An empty username or a username with a "\n" will make the
        # revision text contain two "\n\n" sequences -> corrupt
        # repository since read cannot unpack the revision.
        if not user:
            raise error.StorageError(_(b"empty username"))
        if b"\n" in user:
            raise error.StorageError(
                _(b"username %r contains a newline") % pycompat.bytestr(user)
            )

desc = stripdesc(desc)

if date:
            parseddate = b"%d %d" % dateutil.parsedate(date)
        else:
            parseddate = b"%d %d" % dateutil.makedate()
        if extra:
            branch = extra.get(b"branch")
            if branch in (b"default", b""):
                del extra[b"branch"]
            elif branch in (b".", b"null", b"tip"):
                raise error.StorageError(
                    _(b'the name \'%s\' is reserved') % branch
                )
        sortedfiles = sorted(files.touched)
        flags = 0
        sidedata = None
        if self._copiesstorage == b'changeset-sidedata':
            if files.has_copies_info:
                flags |= flagutil.REVIDX_HASCOPIESINFO
            sidedata = metadata.encode_files_sidedata(files)

if extra:
            extra = encodeextra(extra)
            parseddate = b"%s %s" % (parseddate, extra)
        l = [hex(manifest), user, parseddate] + sortedfiles + [b"", desc]
        text = b"\n".join(l)
        rev = self.addrevision(
            text, transaction, len(self), p1, p2, sidedata=sidedata, flags=flags
        )
        return self.node(rev)

def branchinfo(self, rev):
        """return the branch name and open/close state of a revision

This function exists because creating a changectx object
        just to access this is costly."""
        return self.changelogrevision(rev).branchinfo

def _nodeduplicatecallback(self, transaction, rev):
        # keep track of revisions that got "re-added", eg: unbunde of know rev.
        #
        # We track them in a list to preserve their order from the source bundle
        duplicates = transaction.changes.setdefault(b'revduplicates', [])
        duplicates.append(rev)

${this.title}

Code Editor : changelog.py