Serafim\Stream\Filter\Filter

Complexity

Total Complexity

9

Size/Duplication

Total Lines	102
Duplicated Lines	0 %

Coupling/Cohesion

Components	3
Dependencies	3

Test Coverage

Coverage

50%

Importance

Changes

0

<?php
{
    /**
     * @var array<callable>
     */
    protected array $then = [];

This code did not parse for me. Apparently, there is an error somewhere around this line:

Syntax error, unexpected T_ARRAY, expecting T_FUNCTION or T_CONST

    /**
     * @var StreamInterface
     */
    protected StreamInterface $stream;

    /**
     * @var bool
     */
    protected bool $vendor = false;

    /**
     * @param string $vendorDirectory
     * @throws StreamCreatingException
     */
    public function __construct(string $vendorDirectory)
    {
        $this->stream = Stream::new(32);

        $this->stream->onRead(function (string $sources) {
            foreach ($this->then as $handler) {
                $sources = $handler($sources);
            }

            return $sources;
        });

        $this->where(function (string $class, string $pathname) use ($vendorDirectory): bool {
            if ($this->vendor) {
                return true;
            }

            return \strpos($pathname, $vendorDirectory) !== 0;
        });
    }

    /**
     * @return BaseFilter|$this
     */
    public function exceptVendors(): self
    {
        $this->vendor = false;

        return $this;
    }

    /**
     * @internal Attention! Inclusion of all vendor files may cause undefined behavior.
     * @return BaseFilter|$this
     */
    public function withVendors(): self
    {
        $this->vendor = true;

        return $this;
    }

    /**
     * @param string $pathname
     * @return string
     */
    public function pathname(string $pathname): string
    {
        return $this->stream->pathname($pathname);
    }

    /**
     * @param callable $then
     * @return Filter
     */
    public function then(callable $then): self
    {
        $this->then[] = $then;

        return $this;
    }

    /**
     * @param CacheInterface $cache
     * @param callable $then
     * @return Filter
     */
    public function through(CacheInterface $cache, callable $then): self
    {
        return $this->then(function (string $sources) use ($cache, $then) {
            $key = \md5($sources);

            if (! $cache->has($key)) {
                $cache->set($key, $then($sources));
            }

            return $cache->get($key);
        });
    }
}