OCA\Files_Antivirus\CallbackReadDataWrapper

Complexity

Total Complexity

4

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	wrap()	0	13	1
A	open()	0	9	1
A	stream_read()	0	7	2

<?php

namespace OCA\Files_Antivirus;

use Icewind\Streams\CallbackWrapper;
use Icewind\Streams\Wrapper;

class CallbackReadDataWrapper extends CallbackWrapper {
	/**
	 * @var callable
	 */
	protected $readDataCallback;

	/**
	 * Wraps a stream with the provided callbacks
	 *
	 * @param resource $source
	 * @param callable $readData (optional)
	 * @param callable $write (optional)
	 * @param callable $close (optional)
	 * @param callable $readDir (optional)
	 * @return resource
	 *
	 * @throws \BadMethodCallException
	 */
	public static function wrap($source, $readData = null, $write = null, $close = null, $readDir = null, $preClose = null) {
		$context = stream_context_create([
			'callbackReadData' => [
				'source' => $source,
				'readData' => $readData,
				'write' => $write,
				'close' => $close,
				'readDir' => $readDir,
				'preClose' => $preClose
			]
		]);
		return Wrapper::wrapSource($source, $context, 'callbackReadData', self::class);
	}

	protected function open() {
		$context = $this->loadContext('callbackReadData');

		$this->readDataCallback = $context['readData'];
		$this->writeCallback = $context['write'];
		$this->closeCallback = $context['close'];
		$this->readDirCallBack = $context['readDir'];
		return true;
	}

	public function stream_read($count) {
		$result = parent::stream_read($count);
		if (is_callable($this->readDataCallback)) {
			call_user_func($this->readDataCallback, strlen($count), $result);
		}
		return $result;
	}
}