diff --git a/swh/loader/dir/tasks.py b/swh/loader/dir/tasks.py index 7c0e29b..43587d0 100644 --- a/swh/loader/dir/tasks.py +++ b/swh/loader/dir/tasks.py @@ -1,90 +1,108 @@ # Copyright (C) 2015 The Software Heritage developers # See the AUTHORS file at the top-level directory of this distribution # License: GNU General Public License version 3, or any later version # See top-level LICENSE file for more information import subprocess import shutil import tempfile from swh.core.scheduling import Task from swh.loader.dir.loader import DirLoader class LoadDirRepository(Task): """Import a directory to Software Heritage """ task_queue = 'swh_loader_dir' CONFIG_BASE_FILENAME = 'loader/dir.ini' ADDITIONAL_CONFIG = {} def __init__(self): self.config = DirLoader.parse_config_file( base_filename=self.CONFIG_BASE_FILENAME, additional_configs=[self.ADDITIONAL_CONFIG], ) def run(self, dir_path, origin, revision, release, occurrences): """Import a directory. Args: cf. swh.loader.dir.loader.run docstring """ loader = DirLoader(self.config) loader.log = self.log loader.process(dir_path, origin, revision, release, occurrences) def untar(tar_path, dir_path): """Decompress an archive tar_path to dir_path. At the end of this call, dir_path contains the tarball's uncompressed content. Args: tar_path: the path to access the tarball dir_path: The path where to extract the tarball's content. """ untar_cmd = ['tar', 'xavf', tar_path, '--preserve-permissions', '-C', dir_path] subprocess.check_call(untar_cmd, stderr=subprocess.STDOUT) class LoadTarRepository(LoadDirRepository): """Import a tarball to Software Heritage """ task_queue = 'swh_loader_tar' CONFIG_BASE_FILENAME = 'loader/tar.ini' ADDITIONAL_CONFIG = { 'extraction_dir': ('str', '/tmp/swh.loader.tar/'), } def run(self, tar_path, origin, revision, release, occurrences): """Import a tarball tar_path. Args: - tar_path: path access to the tarball - origin, revision, release, occurrences: see LoadDirRepository.run """ extraction_dir = self.config['extraction_dir'] dir_path = tempfile.mkdtemp(prefix='swh.loader.tar', dir=extraction_dir) # unarchive in dir_path untar(tar_path, dir_path) if 'type' not in origin: # let the type flow if present origin['type'] = 'tar' try: super().run(dir_path, origin, revision, release, occurrences) finally: # always clean up shutil.rmtree(dir_path) + + +class LoadTarRepositoryPrint(LoadDirRepository): + """Import a tarball to Software Heritage + + DEBUG purposes + """ + task_queue = 'swh_loader_tar_print' + + def run(self, tar_path, origin, revision, release, occurrences): + """Import a tarball tar_path. + + Args: + - tar_path: path access to the tarball + - origin, revision, release, occurrences: see LoadDirRepository.run + + """ + print(tar_path, origin, revision, release, occurrences)