Changeset View
Changeset View
Standalone View
Standalone View
swh/loader/package/loader.py
| Show First 20 Lines • Show All 701 Lines • ▼ Show 20 Lines | ) -> Tuple[str, from_disk.Directory]: | ||||
| logger.debug("uncompressed_path: %s", uncompressed_path) | logger.debug("uncompressed_path: %s", uncompressed_path) | ||||
| directory = from_disk.Directory.from_disk( | directory = from_disk.Directory.from_disk( | ||||
| path=uncompressed_path.encode("utf-8"), | path=uncompressed_path.encode("utf-8"), | ||||
| max_content_length=self.max_content_size, | max_content_length=self.max_content_size, | ||||
| ) | ) | ||||
| contents, skipped_contents, directories = from_disk.iter_directory(directory) | contents, skipped_contents, directories = from_disk.iter_directory(directory) | ||||
| logger.debug("Number of skipped contents: %s", len(skipped_contents)) | logger.debug("Number of skipped contents: %s", len(skipped_contents)) | ||||
| self.storage.skipped_content_add(skipped_contents) | self.storage.skipped_content_add(skipped_contents) | ||||
| logger.debug("Number of contents: %s", len(contents)) | logger.debug("Number of contents: %s", len(contents)) | ||||
| self.storage.content_add(contents) | self.storage.content_add(contents) | ||||
| logger.debug("Number of directories: %s", len(directories)) | logger.debug("Number of directories: %s", len(directories)) | ||||
| self.storage.directory_add(directories) | self.storage.directory_add(directories) | ||||
| ▲ Show 20 Lines • Show All 42 Lines • ▼ Show 20 Lines | ) -> Optional[Tuple[Sha1Git, Sha1Git]]: | ||||
| revision=CoreSWHID(object_type=ObjectType.REVISION, object_id=revision.id), | revision=CoreSWHID(object_type=ObjectType.REVISION, object_id=revision.id), | ||||
| ) | ) | ||||
| self._load_metadata_objects([original_artifact_metadata]) | self._load_metadata_objects([original_artifact_metadata]) | ||||
| logger.debug("Revision: %s", revision) | logger.debug("Revision: %s", revision) | ||||
| self.storage.revision_add([revision]) | self.storage.revision_add([revision]) | ||||
| assert directory.hash | assert directory.hash | ||||
| print(f"rev is {revision.id.hex()}") | |||||
| print(f"rev is {directory.hash.hex()}") | |||||
| return (revision.id, directory.hash) | return (revision.id, directory.hash) | ||||
| def _load_snapshot( | def _load_snapshot( | ||||
| self, | self, | ||||
| default_version: str, | default_version: str, | ||||
| revisions: Dict[str, List[Tuple[str, bytes]]], | revisions: Dict[str, List[Tuple[str, bytes]]], | ||||
| extra_branches: Dict[bytes, Mapping[str, Any]], | extra_branches: Dict[bytes, Mapping[str, Any]], | ||||
| ) -> Optional[Snapshot]: | ) -> Optional[Snapshot]: | ||||
| ▲ Show 20 Lines • Show All 224 Lines • Show Last 20 Lines | |||||