Blame view
sources/lib/private/files/stream/oc.php
2.88 KB
|
03e52840d
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 |
<?php
/**
* Copyright (c) 2013 Robin Appelman <icewind@owncloud.com>
* This file is licensed under the Affero General Public License version 3 or
* later.
* See the COPYING-README file.
*/
namespace OC\Files\Stream;
/**
* a stream wrappers for ownCloud's virtual filesystem
*/
class OC {
/**
* @var \OC\Files\View
*/
static private $rootView;
private $path;
|
|
6d9380f96
|
21 22 23 24 |
/** * @var resource */ |
|
03e52840d
|
25 |
private $dirSource; |
|
6d9380f96
|
26 27 28 29 |
/** * @var resource */ |
|
03e52840d
|
30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 |
private $fileSource;
private $meta;
private function setup(){
if (!self::$rootView) {
self::$rootView = new \OC\Files\View('');
}
}
public function stream_open($path, $mode, $options, &$opened_path) {
$this->setup();
$path = substr($path, strlen('oc://'));
$this->path = $path;
$this->fileSource = self::$rootView->fopen($path, $mode);
if (is_resource($this->fileSource)) {
$this->meta = stream_get_meta_data($this->fileSource);
}
return is_resource($this->fileSource);
}
public function stream_seek($offset, $whence = SEEK_SET) {
fseek($this->fileSource, $offset, $whence);
}
public function stream_tell() {
return ftell($this->fileSource);
}
public function stream_read($count) {
return fread($this->fileSource, $count);
}
public function stream_write($data) {
return fwrite($this->fileSource, $data);
}
public function stream_set_option($option, $arg1, $arg2) {
switch ($option) {
case STREAM_OPTION_BLOCKING:
stream_set_blocking($this->fileSource, $arg1);
break;
case STREAM_OPTION_READ_TIMEOUT:
stream_set_timeout($this->fileSource, $arg1, $arg2);
break;
case STREAM_OPTION_WRITE_BUFFER:
stream_set_write_buffer($this->fileSource, $arg1, $arg2);
}
}
public function stream_stat() {
return fstat($this->fileSource);
}
public function stream_lock($mode) {
flock($this->fileSource, $mode);
}
public function stream_flush() {
return fflush($this->fileSource);
}
public function stream_eof() {
return feof($this->fileSource);
}
public function url_stat($path) {
$this->setup();
$path = substr($path, strlen('oc://'));
if (self::$rootView->file_exists($path)) {
return self::$rootView->stat($path);
} else {
return false;
}
}
public function stream_close() {
fclose($this->fileSource);
}
public function unlink($path) {
$this->setup();
$path = substr($path, strlen('oc://'));
return self::$rootView->unlink($path);
}
public function dir_opendir($path, $options) {
$this->setup();
$path = substr($path, strlen('oc://'));
$this->path = $path;
$this->dirSource = self::$rootView->opendir($path);
if (is_resource($this->dirSource)) {
$this->meta = stream_get_meta_data($this->dirSource);
}
return is_resource($this->dirSource);
}
public function dir_readdir() {
return readdir($this->dirSource);
}
public function dir_closedir() {
closedir($this->dirSource);
}
public function dir_rewinddir() {
rewinddir($this->dirSource);
}
}
|