Reader.php

<?php
declare(strict_types = 1);

namespace Innmind\LogReader;

use Innmind\Filesystem\File\Content;
use Innmind\Immutable\Sequence;

/**
 * Return a stream of already parsed log lines
 */
final class Reader
{
    private LineParser $parse;

    private function __construct(LineParser $parser)
    {
        $this->parse = $parser;
    }

    #[\NoDiscard]
    public function __invoke(Content $file): Sequence
    {
        /**
         * @psalm-suppress InvalidArgument Due to the empty sequence
         * @var Sequence<Log>
         */
        return $file
            ->lines()
            ->map(static fn($line) => $line->str())
            ->filter(static fn($line) => !$line->empty())
            ->flatMap(fn($line) => ($this->parse)($line)->match(
                static fn($log) => Sequence::of($log),
                static fn() => Sequence::of(), // discard the lines we can't parse
            ));
    }

    public static function of(LineParser $parser): self
    {
        return new self($parser);
    }
}