Startwind\Inventorio\Collector\Package\Dnf\DnfPackageCollector

Complexity

Total Complexity

11

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getIdentifier()	0	3	1
A	collectPackages()	0	23	4
A	collect()	0	9	2
A	collectUpdatablePackages()	0	21	4

<?php

namespace Startwind\Inventorio\Collector\Package\Dnf;

use Startwind\Inventorio\Collector\Collector;
use Startwind\Inventorio\Collector\OperatingSystem\OperatingSystemCollector;
use Startwind\Inventorio\Exec\Runner;

/**
 * This collector returns details about all installed DNF (RPM-based) packages.
 */
class DnfPackageCollector implements Collector
{
    protected const COLLECTION_IDENTIFIER = 'DnfPackages';

    public function getIdentifier(): string
    {
        return self::COLLECTION_IDENTIFIER;
    }

    public function collect(): array
    {
        if (OperatingSystemCollector::getOsFamily() !== OperatingSystemCollector::OS_FAMILY_LINUX) {
            return [];
        }

        return [
            'packages' => $this->collectPackages(),
            'updatable' => $this->collectUpdatablePackages()
        ];
    }

    private function collectPackages(): array
    {
        if (!Runner::getInstance()->commandExists('rpm')) {
            return [];
        }

        $output = Runner::getInstance()->run('rpm -qa --qf \'{"package":"%{NAME}", "version":"%{VERSION}-%{RELEASE}"},\n\'')->getOutput();

        // Format as JSON array
        $output = "[" . preg_replace("/,\n$/", "\n", trim($output)) . "]";

        $packageList = json_decode($output, true);

        if (!is_array($packageList)) {
            return [];
        }

        $result = [];
        foreach ($packageList as $package) {
            $result[$package['package']] = [$package['version']];
        }

        return $result;
    }

    private function collectUpdatablePackages(): array
    {
        if (!Runner::getInstance()->commandExists('dnf')) {
            return [];
        }

        $output = Runner::getInstance()->run('dnf check-update -q || true')->getOutput();
        $lines = explode("\n", $output);

        $packages = [];

        foreach ($lines as $line) {
            if (preg_match('/^(\S+)\s+(\S+)\s+(\S+)/', $line, $matches)) {
                $packages[$matches[1]] = [
                    'currentVersion' => null, // Fedora does not show current version here
                    'newVersion' => $matches[2]
                ];
            }
        }

        return $packages;
    }
}