Yiisoft\Yii\Debug\Collector\Stream\FilesystemStreamProxy

Complexity

Total Complexity

42

Size/Duplication

Total Lines	247
Duplicated Lines	0 %

Importance

Changes

0

30 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	__call()	0	7	1
A	stream_flush()	0	3	1
A	stream_open()	0	4	1
A	stream_stat()	0	3	1
A	stream_lock()	0	3	1
A	__get()	0	3	1
A	register()	0	14	2
A	mkdir()	0	12	2
A	unlink()	0	9	2
A	dir_rewinddir()	0	3	1
A	stream_eof()	0	3	1
A	stream_cast()	0	3	1
A	stream_seek()	0	3	1
A	rmdir()	0	11	2
A	dir_opendir()	0	3	1
A	__destruct()	0	13	3
A	stream_write()	0	10	2
A	stream_set_option()	0	3	1
A	stream_close()	0	3	1
A	stream_truncate()	0	3	1
A	rename()	0	11	2
A	stream_metadata()	0	3	1
A	dir_readdir()	0	9	2
A	url_stat()	0	3	1
A	unregister()	0	7	2
A	stream_read()	0	9	2
A	stream_tell()	0	3	1
A	isIgnored()	0	5	2
A	dir_closedir()	0	3	1

<?php

declare(strict_types=1);

namespace Yiisoft\Yii\Debug\Collector\Stream;

use Yiisoft\Strings\CombinedRegexp;
use Yiisoft\Yii\Debug\Helper\BacktraceIgnoreMatcher;
use Yiisoft\Yii\Debug\Helper\StreamWrapper\StreamWrapper;
use Yiisoft\Yii\Debug\Helper\StreamWrapper\StreamWrapperInterface;

use const SEEK_SET;

final class FilesystemStreamProxy implements StreamWrapperInterface
{
    public static bool $registered = false;
    /**
     * @var resource|null
     */
    public $context;
    public StreamWrapper $decorated;
    public bool $ignored = false;

    public static ?FilesystemStreamCollector $collector = null;
    public static array $ignoredPathPatterns = [];
    public static array $ignoredClasses = [];
    public array $operations = [];

    public function __construct()
    {
        $this->decorated = new StreamWrapper();
        $this->decorated->context = $this->context;
    }

    public function __call(string $name, array $arguments)
    {
        try {
            self::unregister();
            return $this->decorated->{$name}(...$arguments);
        } finally {
            self::register();
        }
    }

    public function __destruct()
    {
        if (self::$collector === null) {
            return;
        }
        foreach ($this->operations as $name => $operation) {
            self::$collector->collect(
                operation: $name,
                path: $operation['path'],
                args: $operation['args'],
            );
        }
        self::unregister();
    }

    public function __get(string $name)
    {
        return $this->decorated->{$name};
    }

    public static function register(): void
    {
        if (self::$registered) {
            return;
        }
        /**
         * It's important to trigger autoloader before unregistering the file stream handler
         */
        class_exists(BacktraceIgnoreMatcher::class);
        class_exists(StreamWrapper::class);
        class_exists(CombinedRegexp::class);
        stream_wrapper_unregister('file');
        stream_wrapper_register('file', self::class, STREAM_IS_URL);
        self::$registered = true;
    }

    public static function unregister(): void
    {
        if (!self::$registered) {
            return;
        }
        @stream_wrapper_restore('file');

It seems like you do not handle an error condition for stream_wrapper_restore(). This can introduce security issues, and is generally not recommended.

        self::$registered = false;
    }

    private function isIgnored(): bool
    {
        $backtrace = debug_backtrace();
        return BacktraceIgnoreMatcher::isIgnoredByClass($backtrace, self::$ignoredClasses)
            || BacktraceIgnoreMatcher::isIgnoredByFile($backtrace, self::$ignoredPathPatterns);
    }

    public function stream_open(string $path, string $mode, int $options, ?string &$opened_path): bool

Method name "FilesystemStreamProxy::stream_open" is not in camel caps format

    {
        $this->ignored = $this->isIgnored();
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function stream_read(int $count): string|false

Method name "FilesystemStreamProxy::stream_read" is not in camel caps format

    {
        if (!$this->ignored) {
            $this->operations['read'] = [
                'path' => $this->decorated->filename,
                'args' => [],
            ];
        }
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function stream_set_option(int $option, int $arg1, ?int $arg2): bool

Method name "FilesystemStreamProxy::stream_set_option" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function stream_tell(): int

Method name "FilesystemStreamProxy::stream_tell" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function stream_eof(): bool

Method name "FilesystemStreamProxy::stream_eof" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function stream_seek(int $offset, int $whence = SEEK_SET): bool

Method name "FilesystemStreamProxy::stream_seek" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function stream_cast(int $castAs)

Method name "FilesystemStreamProxy::stream_cast" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function stream_stat(): array|false

Method name "FilesystemStreamProxy::stream_stat" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function dir_closedir(): bool

Method name "FilesystemStreamProxy::dir_closedir" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function dir_opendir(string $path, int $options): bool

Method name "FilesystemStreamProxy::dir_opendir" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function dir_readdir(): false|string

Method name "FilesystemStreamProxy::dir_readdir" is not in camel caps format

    {
        if (!$this->ignored) {
            $this->operations['readdir'] = [
                'path' => $this->decorated->filename,
                'args' => [],
            ];
        }
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function dir_rewinddir(): bool

Method name "FilesystemStreamProxy::dir_rewinddir" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function mkdir(string $path, int $mode, int $options): bool
    {
        if (!$this->isIgnored()) {
            $this->operations['mkdir'] = [
                'path' => $path,
                'args' => [
                    'mode' => $mode,
                    'options' => $options,
                ],
            ];
        }
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function rename(string $path_from, string $path_to): bool
    {
        if (!$this->isIgnored()) {
            $this->operations['rename'] = [
                'path' => $path_from,
                'args' => [
                    'path_to' => $path_to,
                ],
            ];
        }
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function rmdir(string $path, int $options): bool
    {
        if (!$this->isIgnored()) {
            $this->operations['rmdir'] = [
                'path' => $path,
                'args' => [
                    'options' => $options,
                ],
            ];
        }
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function stream_close(): void

Method name "FilesystemStreamProxy::stream_close" is not in camel caps format

    {
        $this->__call(__FUNCTION__, func_get_args());
    }

    public function stream_flush(): bool

Method name "FilesystemStreamProxy::stream_flush" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function stream_lock(int $operation): bool

Method name "FilesystemStreamProxy::stream_lock" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function stream_metadata(string $path, int $option, mixed $value): bool

Method name "FilesystemStreamProxy::stream_metadata" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function stream_truncate(int $new_size): bool

Method name "FilesystemStreamProxy::stream_truncate" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function stream_write(string $data): int

Method name "FilesystemStreamProxy::stream_write" is not in camel caps format

    {
        if (!$this->ignored) {
            $this->operations['write'] = [
                'path' => $this->decorated->filename,
                'args' => [],
            ];
        }

        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function unlink(string $path): bool
    {
        if (!$this->isIgnored()) {
            $this->operations['unlink'] = [
                'path' => $path,
                'args' => [],
            ];
        }
        return $this->__call(__FUNCTION__, func_get_args());
    }

    public function url_stat(string $path, int $flags): array|false

Method name "FilesystemStreamProxy::url_stat" is not in camel caps format

    {
        return $this->__call(__FUNCTION__, func_get_args());
    }
}