equal
deleted
inserted
replaced
305 |
305 |
306 @interfaceutil.implementer(repository.ipeercommands) |
306 @interfaceutil.implementer(repository.ipeercommands) |
307 class localpeer(repository.peer): |
307 class localpeer(repository.peer): |
308 '''peer for a local repo; reflects only the most recent API''' |
308 '''peer for a local repo; reflects only the most recent API''' |
309 |
309 |
310 def __init__(self, repo, caps=None, path=None): |
310 def __init__(self, repo, caps=None, path=None, remotehidden=False): |
311 super(localpeer, self).__init__(repo.ui, path=path) |
311 super(localpeer, self).__init__( |
|
312 repo.ui, path=path, remotehidden=remotehidden |
|
313 ) |
|
314 |
|
315 if remotehidden: |
|
316 msg = _( |
|
317 b"ignoring `--remote-hidden` request\n" |
|
318 b"(access to hidden changeset for %r not " |
|
319 b"supported yet)\n" |
|
320 ) % type(self) |
|
321 self.ui.warn(msg) |
312 |
322 |
313 if caps is None: |
323 if caps is None: |
314 caps = moderncaps.copy() |
324 caps = moderncaps.copy() |
315 self._repo = repo.filtered(b'served') |
325 self._repo = repo.filtered(b'served') |
316 |
326 |
453 @interfaceutil.implementer(repository.ipeerlegacycommands) |
463 @interfaceutil.implementer(repository.ipeerlegacycommands) |
454 class locallegacypeer(localpeer): |
464 class locallegacypeer(localpeer): |
455 """peer extension which implements legacy methods too; used for tests with |
465 """peer extension which implements legacy methods too; used for tests with |
456 restricted capabilities""" |
466 restricted capabilities""" |
457 |
467 |
458 def __init__(self, repo, path=None): |
468 def __init__(self, repo, path=None, remotehidden=False): |
459 super(locallegacypeer, self).__init__(repo, caps=legacycaps, path=path) |
469 super(locallegacypeer, self).__init__( |
|
470 repo, caps=legacycaps, path=path, remotehidden=remotehidden |
|
471 ) |
460 |
472 |
461 # Begin of baselegacywirecommands interface. |
473 # Begin of baselegacywirecommands interface. |
462 |
474 |
463 def between(self, pairs): |
475 def between(self, pairs): |
464 return self._repo.between(pairs) |
476 return self._repo.between(pairs) |
1655 return sub.checknested(subpath[len(prefix) + 1 :]) |
1667 return sub.checknested(subpath[len(prefix) + 1 :]) |
1656 else: |
1668 else: |
1657 parts.pop() |
1669 parts.pop() |
1658 return False |
1670 return False |
1659 |
1671 |
1660 def peer(self, path=None): |
1672 def peer(self, path=None, remotehidden=False): |
1661 return localpeer(self, path=path) # not cached to avoid reference cycle |
1673 return localpeer( |
|
1674 self, path=path, remotehidden=remotehidden |
|
1675 ) # not cached to avoid reference cycle |
1662 |
1676 |
1663 def unfiltered(self): |
1677 def unfiltered(self): |
1664 """Return unfiltered version of the repository |
1678 """Return unfiltered version of the repository |
1665 |
1679 |
1666 Intended to be overwritten by filtered repo.""" |
1680 Intended to be overwritten by filtered repo.""" |