storage = LegacyStorage::getInstance(); } /** * Cleanup all missing monitoring nodes from the specified config name * If no config name is specified, the missing nodes are cleaned from all available configs. * Invalid config files and file names are ignored * * USAGE * * icingacli businessprocess cleanup [] * * OPTIONS * * */ public function cleanupAction(): void { $configNames = (array) $this->params->shift() ?: $this->storage->listAllProcessNames(); $foundMissingNode = false; foreach ($configNames as $configName) { if (! $this->storage->hasProcess($configName)) { continue; } try { $bp = $this->storage->loadProcess($configName); } catch (Exception $e) { Logger::error( 'Failed to scan the %s.conf file for missing nodes. Faulty config found.', $configName ); continue; } if (Module::exists('icingadb') && (! $bp->hasBackendName() && IcingadbSupport::useIcingaDbAsBackend()) ) { IcingaDbState::apply($bp); } else { MonitoringState::apply($bp); } $removedNodes = []; foreach (array_keys($bp->getMissingChildren()) as $missingNode) { $node = $bp->getNode($missingNode); $remove = new NodeRemoveAction($node); try { if ($remove->appliesTo($bp)) { $remove->applyTo($bp); $removedNodes[] = $node->getName(); $this->storage->storeProcess($bp); $bp->clearAppliedChanges(); $foundMissingNode = true; } } catch (Exception $e) { Logger::error(sprintf('(%s.conf) %s', $configName, $e->getMessage())); continue; } } if (! empty($removedNodes)) { echo sprintf( 'Removed following %d missing node(s) from %s.conf successfully:', count($removedNodes), $configName ); echo "\n" . implode("\n", $removedNodes) . "\n\n"; } } if (! $foundMissingNode) { echo "No missing node found.\n"; } } }