Innmind\Server\Status\Server\Disk\UnixDisk

Complexity

Total Complexity

5

Size/Duplication

Total Lines	95
Duplicated Lines	0 %

Test Coverage

Coverage

97.78%

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	parse()	0	52	1
A	volumes()	0	4	1
A	get()	0	5	1
A	run()	0	10	2

<?php
declare(strict_types = 1);

namespace Innmind\Server\Status\Server\Disk;

use Innmind\Server\Status\{
    Server\Disk,
    Server\Disk\Volume\MountPoint,
    Server\Disk\Volume\Usage,
    Server\Memory\Bytes,
    Exception\DiskUsageNotAccessible
};
use Innmind\Immutable\{
    MapInterface,
    Str,
    StreamInterface,
    Sequence,
    Map
};
use Symfony\Component\Process\Process;

final class UnixDisk implements Disk
{
    private static $columns = [
        'Size' => 'size',
        'Used' => 'used',
        'Avail' => 'available',
        'Use%' => 'usage',
        'Capacity' => 'usage',
        'Mounted' => 'mountPoint',
    ];

    /**
     * {@inheritdoc}
     */
    public function volumes(): MapInterface
    {
        return $this->parse(
            $this->run('df -lh')
        );
    }

    public function get(MountPoint $point): Volume
    {
        return $this
            ->volumes()
            ->get((string) $point);
    }

    private function run(string $command): Str
    {
        $process = new Process($command);

$command of type string is incompatible with the type array expected by parameter $command of Symfony\Component\Process\Process::__construct().

        $process->run();

        if (!$process->isSuccessful()) {
            throw new DiskUsageNotAccessible;
        }

        return new Str($process->getOutput());
    }

    /**
     * @return MapInterface<string, Volume>
     */
    private function parse(Str $output): MapInterface
    {
        $lines = $output
            ->trim()
            ->split("\n");
        $columns = $lines
            ->first()
            ->pregSplit('~ +~')
            ->reduce(
                new Sequence,
                static function(Sequence $columns, Str $column): Sequence {
                    $column = (string) $column;

                    return $columns->add(self::$columns[$column] ?? $column);
                }
            );

        return $lines
            ->drop(1)
            ->reduce(
                new Sequence,
                static function(Sequence $lines, Str $line) use ($columns): Sequence {
                    return $lines->add(
                        $line->pregSplit('~ +~', $columns->size())
                    );
                }
            )
            ->map(function(StreamInterface $parts) use ($columns): Volume {
                return new Volume(
                    new MountPoint(
                        (string) $parts->get($columns->indexOf('mountPoint'))
                    ),
                    Bytes::of(
                        (string) $parts->get($columns->indexOf('size'))
                    ),
                    Bytes::of(
                        (string) $parts->get($columns->indexOf('available'))
                    ),
                    Bytes::of(
                        (string) $parts->get($columns->indexOf('used'))
                    ),
                    new Usage(
                        (float) (string) $parts->get($columns->indexOf('usage'))
                    )
                );
            })
            ->reduce(
                new Map('string', Volume::class),
                static function(Map $volumes, Volume $volume): Map {
                    return $volumes->put(
                        (string) $volume->mountPoint(),
                        $volume
                    );
                }
            );
    }
}