aboutsummaryrefslogtreecommitdiffstats
path: root/apps/files_external/3rdparty/icewind/streams/src/SeekableWrapper.php
diff options
context:
space:
mode:
Diffstat (limited to 'apps/files_external/3rdparty/icewind/streams/src/SeekableWrapper.php')
-rw-r--r--apps/files_external/3rdparty/icewind/streams/src/SeekableWrapper.php82
1 files changed, 0 insertions, 82 deletions
diff --git a/apps/files_external/3rdparty/icewind/streams/src/SeekableWrapper.php b/apps/files_external/3rdparty/icewind/streams/src/SeekableWrapper.php
deleted file mode 100644
index 1eb06c6294c..00000000000
--- a/apps/files_external/3rdparty/icewind/streams/src/SeekableWrapper.php
+++ /dev/null
@@ -1,82 +0,0 @@
-<?php
-/**
- * SPDX-FileCopyrightText: 2014 Robin Appelman <robin@icewind.nl>
- * SPDX-License-Identifier: MIT
- */
-
-namespace Icewind\Streams;
-
-/**
- * Wrapper that provides callbacks for write, read and close
- *
- * The following options should be passed in the context when opening the stream
- * [
- * 'callback' => [
- * 'source' => resource
- * ]
- * ]
- *
- * All callbacks are called after the operation is executed on the source stream
- */
-class SeekableWrapper extends Wrapper {
- /**
- * @var resource
- */
- protected $cache;
-
- public static function wrap($source) {
- return self::wrapSource($source);
- }
-
- public function dir_opendir($path, $options) {
- return false;
- }
-
- public function stream_open($path, $mode, $options, &$opened_path) {
- $this->loadContext();
- $cache = fopen('php://temp', 'w+');
- if ($cache === false) {
- return false;
- }
- $this->cache = $cache;
- return true;
- }
-
- protected function readTill($position) {
- $current = ftell($this->source);
- if ($position > $current) {
- $data = parent::stream_read($position - $current);
- $cachePosition = ftell($this->cache);
- fseek($this->cache, $current);
- fwrite($this->cache, $data);
- fseek($this->cache, $cachePosition);
- }
- }
-
- public function stream_read($count) {
- $current = ftell($this->cache);
- $this->readTill($current + $count);
- return fread($this->cache, $count);
- }
-
- public function stream_seek($offset, $whence = SEEK_SET) {
- if ($whence === SEEK_SET) {
- $target = $offset;
- } elseif ($whence === SEEK_CUR) {
- $current = ftell($this->cache);
- $target = $current + $offset;
- } else {
- return false;
- }
- $this->readTill($target);
- return fseek($this->cache, $target) === 0;
- }
-
- public function stream_tell() {
- return ftell($this->cache);
- }
-
- public function stream_eof() {
- return parent::stream_eof() and (ftell($this->source) === ftell($this->cache));
- }
-}