Show More
@@ -15,6 +15,10 b' import time' | |||
|
15 | 15 | import weakref |
|
16 | 16 | |
|
17 | 17 | from concurrent import futures |
|
18 | from typing import ( | |
|
19 | Optional, | |
|
20 | ) | |
|
21 | ||
|
18 | 22 | from .i18n import _ |
|
19 | 23 | from .node import ( |
|
20 | 24 | bin, |
@@ -526,7 +530,7 b' def _readrequires(vfs, allowmissing):' | |||
|
526 | 530 | return set(read(b'requires').splitlines()) |
|
527 | 531 | |
|
528 | 532 | |
|
529 | def makelocalrepository(baseui, path, intents=None): | |
|
533 | def makelocalrepository(baseui, path: bytes, intents=None): | |
|
530 | 534 | """Create a local repository object. |
|
531 | 535 | |
|
532 | 536 | Given arguments needed to construct a local repository, this function |
@@ -845,7 +849,13 b' def makelocalrepository(baseui, path, in' | |||
|
845 | 849 | ) |
|
846 | 850 | |
|
847 | 851 | |
|
848 | def loadhgrc(ui, wdirvfs, hgvfs, requirements, sharedvfs=None): | |
|
852 | def loadhgrc( | |
|
853 | ui, | |
|
854 | wdirvfs: vfsmod.vfs, | |
|
855 | hgvfs: vfsmod.vfs, | |
|
856 | requirements, | |
|
857 | sharedvfs: Optional[vfsmod.vfs] = None, | |
|
858 | ): | |
|
849 | 859 | """Load hgrc files/content into a ui instance. |
|
850 | 860 | |
|
851 | 861 | This is called during repository opening to load any additional |
@@ -1323,15 +1333,15 b' class localrepository:' | |||
|
1323 | 1333 | self, |
|
1324 | 1334 | baseui, |
|
1325 | 1335 | ui, |
|
1326 | origroot, | |
|
1327 | wdirvfs, | |
|
1328 | hgvfs, | |
|
1336 | origroot: bytes, | |
|
1337 | wdirvfs: vfsmod.vfs, | |
|
1338 | hgvfs: vfsmod.vfs, | |
|
1329 | 1339 | requirements, |
|
1330 | 1340 | supportedrequirements, |
|
1331 | sharedpath, | |
|
1341 | sharedpath: bytes, | |
|
1332 | 1342 | store, |
|
1333 | cachevfs, | |
|
1334 | wcachevfs, | |
|
1343 | cachevfs: vfsmod.vfs, | |
|
1344 | wcachevfs: vfsmod.vfs, | |
|
1335 | 1345 | features, |
|
1336 | 1346 | intents=None, |
|
1337 | 1347 | ): |
@@ -1977,7 +1987,7 b' class localrepository:' | |||
|
1977 | 1987 | def __iter__(self): |
|
1978 | 1988 | return iter(self.changelog) |
|
1979 | 1989 | |
|
1980 | def revs(self, expr, *args): | |
|
1990 | def revs(self, expr: bytes, *args): | |
|
1981 | 1991 | """Find revisions matching a revset. |
|
1982 | 1992 | |
|
1983 | 1993 | The revset is specified as a string ``expr`` that may contain |
@@ -1993,7 +2003,7 b' class localrepository:' | |||
|
1993 | 2003 | tree = revsetlang.spectree(expr, *args) |
|
1994 | 2004 | return revset.makematcher(tree)(self) |
|
1995 | 2005 | |
|
1996 | def set(self, expr, *args): | |
|
2006 | def set(self, expr: bytes, *args): | |
|
1997 | 2007 | """Find revisions matching a revset and emit changectx instances. |
|
1998 | 2008 | |
|
1999 | 2009 | This is a convenience wrapper around ``revs()`` that iterates the |
@@ -2005,7 +2015,7 b' class localrepository:' | |||
|
2005 | 2015 | for r in self.revs(expr, *args): |
|
2006 | 2016 | yield self[r] |
|
2007 | 2017 | |
|
2008 | def anyrevs(self, specs, user=False, localalias=None): | |
|
2018 | def anyrevs(self, specs: bytes, user=False, localalias=None): | |
|
2009 | 2019 | """Find revisions matching one of the given revsets. |
|
2010 | 2020 | |
|
2011 | 2021 | Revset aliases from the configuration are not expanded by default. To |
@@ -2030,7 +2040,7 b' class localrepository:' | |||
|
2030 | 2040 | m = revset.matchany(None, specs, localalias=localalias) |
|
2031 | 2041 | return m(self) |
|
2032 | 2042 | |
|
2033 | def url(self): | |
|
2043 | def url(self) -> bytes: | |
|
2034 | 2044 | return b'file:' + self.root |
|
2035 | 2045 | |
|
2036 | 2046 | def hook(self, name, throw=False, **args): |
@@ -2229,7 +2239,7 b' class localrepository:' | |||
|
2229 | 2239 | return b'store' |
|
2230 | 2240 | return None |
|
2231 | 2241 | |
|
2232 | def wjoin(self, f, *insidef): | |
|
2242 | def wjoin(self, f: bytes, *insidef: bytes) -> bytes: | |
|
2233 | 2243 | return self.vfs.reljoin(self.root, f, *insidef) |
|
2234 | 2244 | |
|
2235 | 2245 | def setparents(self, p1, p2=None): |
@@ -2238,17 +2248,17 b' class localrepository:' | |||
|
2238 | 2248 | self[None].setparents(p1, p2) |
|
2239 | 2249 | self._quick_access_changeid_invalidate() |
|
2240 | 2250 | |
|
2241 | def filectx(self, path, changeid=None, fileid=None, changectx=None): | |
|
2251 | def filectx(self, path: bytes, changeid=None, fileid=None, changectx=None): | |
|
2242 | 2252 | """changeid must be a changeset revision, if specified. |
|
2243 | 2253 | fileid can be a file revision or node.""" |
|
2244 | 2254 | return context.filectx( |
|
2245 | 2255 | self, path, changeid, fileid, changectx=changectx |
|
2246 | 2256 | ) |
|
2247 | 2257 | |
|
2248 | def getcwd(self): | |
|
2258 | def getcwd(self) -> bytes: | |
|
2249 | 2259 | return self.dirstate.getcwd() |
|
2250 | 2260 | |
|
2251 | def pathto(self, f, cwd=None): | |
|
2261 | def pathto(self, f: bytes, cwd: Optional[bytes] = None) -> bytes: | |
|
2252 | 2262 | return self.dirstate.pathto(f, cwd) |
|
2253 | 2263 | |
|
2254 | 2264 | def _loadfilter(self, filter): |
@@ -2300,14 +2310,21 b' class localrepository:' | |||
|
2300 | 2310 | def adddatafilter(self, name, filter): |
|
2301 | 2311 | self._datafilters[name] = filter |
|
2302 | 2312 | |
|
2303 | def wread(self, filename): | |
|
2313 | def wread(self, filename: bytes) -> bytes: | |
|
2304 | 2314 | if self.wvfs.islink(filename): |
|
2305 | 2315 | data = self.wvfs.readlink(filename) |
|
2306 | 2316 | else: |
|
2307 | 2317 | data = self.wvfs.read(filename) |
|
2308 | 2318 | return self._filter(self._encodefilterpats, filename, data) |
|
2309 | 2319 | |
|
2310 | def wwrite(self, filename, data, flags, backgroundclose=False, **kwargs): | |
|
2320 | def wwrite( | |
|
2321 | self, | |
|
2322 | filename: bytes, | |
|
2323 | data: bytes, | |
|
2324 | flags: bytes, | |
|
2325 | backgroundclose=False, | |
|
2326 | **kwargs | |
|
2327 | ) -> int: | |
|
2311 | 2328 | """write ``data`` into ``filename`` in the working directory |
|
2312 | 2329 | |
|
2313 | 2330 | This returns length of written (maybe decoded) data. |
@@ -2325,7 +2342,7 b' class localrepository:' | |||
|
2325 | 2342 | self.wvfs.setflags(filename, False, False) |
|
2326 | 2343 | return len(data) |
|
2327 | 2344 | |
|
2328 | def wwritedata(self, filename, data): | |
|
2345 | def wwritedata(self, filename: bytes, data: bytes) -> bytes: | |
|
2329 | 2346 | return self._filter(self._decodefilterpats, filename, data) |
|
2330 | 2347 | |
|
2331 | 2348 | def currenttransaction(self): |
@@ -3520,13 +3537,13 b' def aftertrans(files):' | |||
|
3520 | 3537 | return a |
|
3521 | 3538 | |
|
3522 | 3539 | |
|
3523 | def undoname(fn): | |
|
3540 | def undoname(fn: bytes) -> bytes: | |
|
3524 | 3541 | base, name = os.path.split(fn) |
|
3525 | 3542 | assert name.startswith(b'journal') |
|
3526 | 3543 | return os.path.join(base, name.replace(b'journal', b'undo', 1)) |
|
3527 | 3544 | |
|
3528 | 3545 | |
|
3529 | def instance(ui, path, create, intents=None, createopts=None): | |
|
3546 | def instance(ui, path: bytes, create, intents=None, createopts=None): | |
|
3530 | 3547 | |
|
3531 | 3548 | # prevent cyclic import localrepo -> upgrade -> localrepo |
|
3532 | 3549 | from . import upgrade |
@@ -3543,7 +3560,7 b' def instance(ui, path, create, intents=N' | |||
|
3543 | 3560 | return repo |
|
3544 | 3561 | |
|
3545 | 3562 | |
|
3546 | def islocal(path): | |
|
3563 | def islocal(path: bytes) -> bool: | |
|
3547 | 3564 | return True |
|
3548 | 3565 | |
|
3549 | 3566 | |
@@ -3801,7 +3818,7 b' def filterknowncreateopts(ui, createopts' | |||
|
3801 | 3818 | return {k: v for k, v in createopts.items() if k not in known} |
|
3802 | 3819 | |
|
3803 | 3820 | |
|
3804 | def createrepository(ui, path, createopts=None, requirements=None): | |
|
3821 | def createrepository(ui, path: bytes, createopts=None, requirements=None): | |
|
3805 | 3822 | """Create a new repository in a vfs. |
|
3806 | 3823 | |
|
3807 | 3824 | ``path`` path to the new repo's working directory. |
General Comments 0
You need to be logged in to leave comments.
Login now