addArgument('sources', InputArgument::REQUIRED, 'The sources/packages will be deleted, comma separated'); $this->addOption('all', 'A', null, 'Delete all downloaded and locked sources/packages'); } public function initialize(InputInterface $input, OutputInterface $output): void { if ($input->getOption('all')) { $input->setArgument('sources', ''); } parent::initialize($input, $output); } /** * @throws FileSystemException */ public function handle(): int { try { // get source list that will be downloaded $sources = array_map('trim', array_filter(explode(',', $this->getArgument('sources')))); if (empty($sources)) { logger()->notice('Removing downloads/ directory ...'); FileSystem::removeDir(DOWNLOAD_PATH); logger()->info('Removed downloads/ dir!'); return static::SUCCESS; } $chosen_sources = $sources; $deleted_sources = []; foreach ($chosen_sources as $source) { $source = trim($source); foreach ([$source, Downloader::getPreBuiltLockName($source)] as $name) { if (LockFile::get($name)) { $deleted_sources[] = $name; } } } foreach ($deleted_sources as $lock_name) { $lock = LockFile::get($lock_name); // remove download file/dir if exists if ($lock['source_type'] === SPC_SOURCE_ARCHIVE) { if (file_exists($path = FileSystem::convertPath(DOWNLOAD_PATH . '/' . $lock['filename']))) { logger()->info('Deleting file ' . $path); unlink($path); } else { logger()->warning("Source/Package [{$lock_name}] file not found, skip deleting file."); } } else { if (is_dir($path = FileSystem::convertPath(DOWNLOAD_PATH . '/' . $lock['dirname']))) { logger()->info('Deleting dir ' . $path); FileSystem::removeDir($path); } else { logger()->warning("Source/Package [{$lock_name}] directory not found, skip deleting dir."); } } // remove locked sources LockFile::put($lock_name, null); } logger()->info('Delete success!'); return static::SUCCESS; } catch (DownloaderException $e) { logger()->error($e->getMessage()); return static::FAILURE; } catch (WrongUsageException $e) { logger()->critical($e->getMessage()); return static::FAILURE; } } }