From: Scott Worley Date: Sat, 13 Jun 2020 16:56:32 +0000 (-0700) Subject: polymorphic fetch() X-Git-Tag: 2.0.0~21 X-Git-Url: http://git.scottworley.com/pinch/commitdiff_plain/b3ea39b882d1f48781edff1863181274753b32b5?ds=inline polymorphic fetch() --- diff --git a/pinch.py b/pinch.py index a90ec3b..58f7a32 100644 --- a/pinch.py +++ b/pinch.py @@ -113,21 +113,6 @@ class TarrableSearchPath(SearchPath, ABC): # pylint: disable=abstract-method old_git_revision: str table: Dict[str, ChannelTableEntry] - def fetch(self, v: Verification, section: str, - conf: configparser.SectionProxy) -> str: - if 'git_repo' not in conf or 'release_name' not in conf: - raise Exception( - 'Cannot update unpinned channel "%s" (Run "pin" before "update")' % - section) - - if 'channel_url' in conf: - return fetch_with_nix_prefetch_url( - v, conf['tarball_url'], Digest16( - conf['tarball_sha256'])) - - ensure_git_rev_available(v, self) - return git_get_tarball(v, self) - class GitSearchPath(TarrableSearchPath): def pin(self, v: Verification, conf: configparser.SectionProxy) -> None: @@ -139,6 +124,16 @@ class GitSearchPath(TarrableSearchPath): conf['release_name'] = git_revision_name(v, self) conf['git_revision'] = self.git_revision + def fetch(self, v: Verification, section: str, + conf: configparser.SectionProxy) -> str: + if 'git_repo' not in conf or 'release_name' not in conf: + raise Exception( + 'Cannot update unpinned channel "%s" (Run "pin" before "update")' % + section) + + ensure_git_rev_available(v, self) + return git_get_tarball(v, self) + class ChannelSearchPath(TarrableSearchPath): def pin(self, v: Verification, conf: configparser.SectionProxy) -> None: @@ -152,6 +147,19 @@ class ChannelSearchPath(TarrableSearchPath): conf['tarball_sha256'] = self.table['nixexprs.tar.xz'].digest conf['git_revision'] = self.git_revision + # Lint TODO: Put tarball_url and tarball_sha256 in ChannelSearchPath + # pylint: disable=no-self-use + def fetch(self, v: Verification, section: str, + conf: configparser.SectionProxy) -> str: + if 'git_repo' not in conf or 'release_name' not in conf: + raise Exception( + 'Cannot update unpinned channel "%s" (Run "pin" before "update")' % + section) + + return fetch_with_nix_prefetch_url( + v, conf['tarball_url'], Digest16( + conf['tarball_sha256'])) + def compare(a: str, b: str) -> Tuple[List[str], List[str], List[str]]: