Changeset View
Changeset View
Standalone View
Standalone View
swh/deposit/loader/loader.py
| Show First 20 Lines • Show All 43 Lines • ▼ Show 20 Lines | def load(self, *, archive_url, deposit_meta_url, deposit_update_url): | ||||
| return BufferedLoader.load( | return BufferedLoader.load( | ||||
| self, | self, | ||||
| archive_url=archive_url, | archive_url=archive_url, | ||||
| deposit_meta_url=deposit_meta_url, | deposit_meta_url=deposit_meta_url, | ||||
| deposit_update_url=deposit_update_url) | deposit_update_url=deposit_update_url) | ||||
| def prepare_origin_visit(self, *, deposit_meta_url, **kwargs): | def prepare_origin_visit(self, *, deposit_meta_url, **kwargs): | ||||
| self.metadata = self.deposit_client.metadata_get( | self.metadata = self.deposit_client.metadata_get( | ||||
| deposit_meta_url, log=self.log) | deposit_meta_url) | ||||
| self.origin = self.metadata['origin'] | self.origin = self.metadata['origin'] | ||||
| self.visit_date = None | self.visit_date = None | ||||
| def prepare(self, *, archive_url, deposit_meta_url, deposit_update_url): | def prepare(self, *, archive_url, deposit_meta_url, deposit_update_url): | ||||
| """Prepare the loading by first retrieving the deposit's raw archive | """Prepare the loading by first retrieving the deposit's raw archive | ||||
| content. | content. | ||||
| """ | """ | ||||
| self.deposit_update_url = deposit_update_url | self.deposit_update_url = deposit_update_url | ||||
| self.deposit_client.status_update(deposit_update_url, 'loading') | self.deposit_client.status_update(deposit_update_url, 'loading') | ||||
| temporary_directory = tempfile.TemporaryDirectory() | temporary_directory = tempfile.TemporaryDirectory() | ||||
| self.temporary_directory = temporary_directory | self.temporary_directory = temporary_directory | ||||
| archive_path = os.path.join(temporary_directory.name, 'archive.zip') | archive_path = os.path.join(temporary_directory.name, 'archive.zip') | ||||
| archive = self.deposit_client.archive_get( | archive = self.deposit_client.archive_get( | ||||
| archive_url, archive_path, log=self.log) | archive_url, archive_path) | ||||
| metadata = self.metadata | metadata = self.metadata | ||||
| revision = metadata['revision'] | revision = metadata['revision'] | ||||
| branch_name = metadata['branch_name'] | branch_name = metadata['branch_name'] | ||||
| self.origin_metadata = metadata['origin_metadata'] | self.origin_metadata = metadata['origin_metadata'] | ||||
| self.prepare_metadata() | self.prepare_metadata() | ||||
| super().prepare(tar_path=archive, | super().prepare(tar_path=archive, | ||||
| ▲ Show 20 Lines • Show All 65 Lines • Show Last 20 Lines | |||||