Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/writer.py
# Copyright (C) 2020 The Software Heritage developers | # Copyright (C) 2020 The Software Heritage developers | ||||
# See the AUTHORS file at the top-level directory of this distribution | # See the AUTHORS file at the top-level directory of this distribution | ||||
# License: GNU General Public License version 3, or any later version | # License: GNU General Public License version 3, or any later version | ||||
# See top-level LICENSE file for more information | # See top-level LICENSE file for more information | ||||
from typing import Any, Dict, Iterable | from typing import Any, Dict, Iterable | ||||
from attr import evolve | from attr import evolve | ||||
from swh.model.model import ( | from swh.model.model import ( | ||||
Content, | Content, | ||||
Directory, | Directory, | ||||
ExtID, | |||||
MetadataAuthority, | MetadataAuthority, | ||||
MetadataFetcher, | MetadataFetcher, | ||||
Origin, | Origin, | ||||
OriginVisit, | OriginVisit, | ||||
OriginVisitStatus, | OriginVisitStatus, | ||||
RawExtrinsicMetadata, | RawExtrinsicMetadata, | ||||
Release, | Release, | ||||
Revision, | Revision, | ||||
▲ Show 20 Lines • Show All 89 Lines • ▼ Show 20 Lines | class JournalWriter: | ||||
) -> None: | ) -> None: | ||||
self.write_additions("raw_extrinsic_metadata", metadata) | self.write_additions("raw_extrinsic_metadata", metadata) | ||||
def metadata_fetcher_add(self, fetchers: Iterable[MetadataFetcher]) -> None: | def metadata_fetcher_add(self, fetchers: Iterable[MetadataFetcher]) -> None: | ||||
self.write_additions("metadata_fetcher", fetchers) | self.write_additions("metadata_fetcher", fetchers) | ||||
def metadata_authority_add(self, authorities: Iterable[MetadataAuthority]) -> None: | def metadata_authority_add(self, authorities: Iterable[MetadataAuthority]) -> None: | ||||
self.write_additions("metadata_authority", authorities) | self.write_additions("metadata_authority", authorities) | ||||
def extid_add(self, extids: Iterable[ExtID]) -> None: | |||||
self.write_additions("extid", extids) |