@@ -30,156 +30,156 @@ |
||
| 30 | 30 | |
| 31 | 31 | |
| 32 | 32 | class OC_FileChunking { |
| 33 | - protected $info; |
|
| 34 | - protected $cache; |
|
| 35 | - |
|
| 36 | - /** |
|
| 37 | - * TTL of chunks |
|
| 38 | - * |
|
| 39 | - * @var int |
|
| 40 | - */ |
|
| 41 | - protected $ttl; |
|
| 42 | - |
|
| 43 | - static public function decodeName($name) { |
|
| 44 | - preg_match('/(?P<name>.*)-chunking-(?P<transferid>\d+)-(?P<chunkcount>\d+)-(?P<index>\d+)/', $name, $matches); |
|
| 45 | - return $matches; |
|
| 46 | - } |
|
| 47 | - |
|
| 48 | - /** |
|
| 49 | - * @param string[] $info |
|
| 50 | - */ |
|
| 51 | - public function __construct($info) { |
|
| 52 | - $this->info = $info; |
|
| 53 | - $this->ttl = \OC::$server->getConfig()->getSystemValue('cache_chunk_gc_ttl', 86400); |
|
| 54 | - } |
|
| 55 | - |
|
| 56 | - public function getPrefix() { |
|
| 57 | - $name = $this->info['name']; |
|
| 58 | - $transferid = $this->info['transferid']; |
|
| 59 | - |
|
| 60 | - return $name.'-chunking-'.$transferid.'-'; |
|
| 61 | - } |
|
| 62 | - |
|
| 63 | - protected function getCache() { |
|
| 64 | - if (!isset($this->cache)) { |
|
| 65 | - $this->cache = new \OC\Cache\File(); |
|
| 66 | - } |
|
| 67 | - return $this->cache; |
|
| 68 | - } |
|
| 69 | - |
|
| 70 | - /** |
|
| 71 | - * Stores the given $data under the given $key - the number of stored bytes is returned |
|
| 72 | - * |
|
| 73 | - * @param string $index |
|
| 74 | - * @param resource $data |
|
| 75 | - * @return int |
|
| 76 | - */ |
|
| 77 | - public function store($index, $data) { |
|
| 78 | - $cache = $this->getCache(); |
|
| 79 | - $name = $this->getPrefix().$index; |
|
| 80 | - $cache->set($name, $data, $this->ttl); |
|
| 81 | - |
|
| 82 | - return $cache->size($name); |
|
| 83 | - } |
|
| 84 | - |
|
| 85 | - public function isComplete() { |
|
| 86 | - $prefix = $this->getPrefix(); |
|
| 87 | - $cache = $this->getCache(); |
|
| 88 | - $chunkcount = (int)$this->info['chunkcount']; |
|
| 89 | - |
|
| 90 | - for($i=($chunkcount-1); $i >= 0; $i--) { |
|
| 91 | - if (!$cache->hasKey($prefix.$i)) { |
|
| 92 | - return false; |
|
| 93 | - } |
|
| 94 | - } |
|
| 95 | - |
|
| 96 | - return true; |
|
| 97 | - } |
|
| 98 | - |
|
| 99 | - /** |
|
| 100 | - * Assembles the chunks into the file specified by the path. |
|
| 101 | - * Chunks are deleted afterwards. |
|
| 102 | - * |
|
| 103 | - * @param resource $f target path |
|
| 104 | - * |
|
| 105 | - * @return integer assembled file size |
|
| 106 | - * |
|
| 107 | - * @throws \OC\InsufficientStorageException when file could not be fully |
|
| 108 | - * assembled due to lack of free space |
|
| 109 | - */ |
|
| 110 | - public function assemble($f) { |
|
| 111 | - $cache = $this->getCache(); |
|
| 112 | - $prefix = $this->getPrefix(); |
|
| 113 | - $count = 0; |
|
| 114 | - for ($i = 0; $i < $this->info['chunkcount']; $i++) { |
|
| 115 | - $chunk = $cache->get($prefix.$i); |
|
| 116 | - // remove after reading to directly save space |
|
| 117 | - $cache->remove($prefix.$i); |
|
| 118 | - $count += fwrite($f, $chunk); |
|
| 119 | - // let php release the memory to work around memory exhausted error with php 5.6 |
|
| 120 | - $chunk = null; |
|
| 121 | - } |
|
| 122 | - |
|
| 123 | - return $count; |
|
| 124 | - } |
|
| 125 | - |
|
| 126 | - /** |
|
| 127 | - * Returns the size of the chunks already present |
|
| 128 | - * @return integer size in bytes |
|
| 129 | - */ |
|
| 130 | - public function getCurrentSize() { |
|
| 131 | - $cache = $this->getCache(); |
|
| 132 | - $prefix = $this->getPrefix(); |
|
| 133 | - $total = 0; |
|
| 134 | - for ($i = 0; $i < $this->info['chunkcount']; $i++) { |
|
| 135 | - $total += $cache->size($prefix.$i); |
|
| 136 | - } |
|
| 137 | - return $total; |
|
| 138 | - } |
|
| 139 | - |
|
| 140 | - /** |
|
| 141 | - * Removes all chunks which belong to this transmission |
|
| 142 | - */ |
|
| 143 | - public function cleanup() { |
|
| 144 | - $cache = $this->getCache(); |
|
| 145 | - $prefix = $this->getPrefix(); |
|
| 146 | - for($i=0; $i < $this->info['chunkcount']; $i++) { |
|
| 147 | - $cache->remove($prefix.$i); |
|
| 148 | - } |
|
| 149 | - } |
|
| 150 | - |
|
| 151 | - /** |
|
| 152 | - * Removes one specific chunk |
|
| 153 | - * @param string $index |
|
| 154 | - */ |
|
| 155 | - public function remove($index) { |
|
| 156 | - $cache = $this->getCache(); |
|
| 157 | - $prefix = $this->getPrefix(); |
|
| 158 | - $cache->remove($prefix.$index); |
|
| 159 | - } |
|
| 160 | - |
|
| 161 | - /** |
|
| 162 | - * Assembles the chunks into the file specified by the path. |
|
| 163 | - * Also triggers the relevant hooks and proxies. |
|
| 164 | - * |
|
| 165 | - * @param \OC\Files\Storage\Storage $storage storage |
|
| 166 | - * @param string $path target path relative to the storage |
|
| 167 | - * @return bool true on success or false if file could not be created |
|
| 168 | - * |
|
| 169 | - * @throws \OC\ServerNotAvailableException |
|
| 170 | - */ |
|
| 171 | - public function file_assemble($storage, $path) { |
|
| 172 | - // use file_put_contents as method because that best matches what this function does |
|
| 173 | - if (\OC\Files\Filesystem::isValidPath($path)) { |
|
| 174 | - $target = $storage->fopen($path, 'w'); |
|
| 175 | - if ($target) { |
|
| 176 | - $count = $this->assemble($target); |
|
| 177 | - fclose($target); |
|
| 178 | - return $count > 0; |
|
| 179 | - } else { |
|
| 180 | - return false; |
|
| 181 | - } |
|
| 182 | - } |
|
| 183 | - return false; |
|
| 184 | - } |
|
| 33 | + protected $info; |
|
| 34 | + protected $cache; |
|
| 35 | + |
|
| 36 | + /** |
|
| 37 | + * TTL of chunks |
|
| 38 | + * |
|
| 39 | + * @var int |
|
| 40 | + */ |
|
| 41 | + protected $ttl; |
|
| 42 | + |
|
| 43 | + static public function decodeName($name) { |
|
| 44 | + preg_match('/(?P<name>.*)-chunking-(?P<transferid>\d+)-(?P<chunkcount>\d+)-(?P<index>\d+)/', $name, $matches); |
|
| 45 | + return $matches; |
|
| 46 | + } |
|
| 47 | + |
|
| 48 | + /** |
|
| 49 | + * @param string[] $info |
|
| 50 | + */ |
|
| 51 | + public function __construct($info) { |
|
| 52 | + $this->info = $info; |
|
| 53 | + $this->ttl = \OC::$server->getConfig()->getSystemValue('cache_chunk_gc_ttl', 86400); |
|
| 54 | + } |
|
| 55 | + |
|
| 56 | + public function getPrefix() { |
|
| 57 | + $name = $this->info['name']; |
|
| 58 | + $transferid = $this->info['transferid']; |
|
| 59 | + |
|
| 60 | + return $name.'-chunking-'.$transferid.'-'; |
|
| 61 | + } |
|
| 62 | + |
|
| 63 | + protected function getCache() { |
|
| 64 | + if (!isset($this->cache)) { |
|
| 65 | + $this->cache = new \OC\Cache\File(); |
|
| 66 | + } |
|
| 67 | + return $this->cache; |
|
| 68 | + } |
|
| 69 | + |
|
| 70 | + /** |
|
| 71 | + * Stores the given $data under the given $key - the number of stored bytes is returned |
|
| 72 | + * |
|
| 73 | + * @param string $index |
|
| 74 | + * @param resource $data |
|
| 75 | + * @return int |
|
| 76 | + */ |
|
| 77 | + public function store($index, $data) { |
|
| 78 | + $cache = $this->getCache(); |
|
| 79 | + $name = $this->getPrefix().$index; |
|
| 80 | + $cache->set($name, $data, $this->ttl); |
|
| 81 | + |
|
| 82 | + return $cache->size($name); |
|
| 83 | + } |
|
| 84 | + |
|
| 85 | + public function isComplete() { |
|
| 86 | + $prefix = $this->getPrefix(); |
|
| 87 | + $cache = $this->getCache(); |
|
| 88 | + $chunkcount = (int)$this->info['chunkcount']; |
|
| 89 | + |
|
| 90 | + for($i=($chunkcount-1); $i >= 0; $i--) { |
|
| 91 | + if (!$cache->hasKey($prefix.$i)) { |
|
| 92 | + return false; |
|
| 93 | + } |
|
| 94 | + } |
|
| 95 | + |
|
| 96 | + return true; |
|
| 97 | + } |
|
| 98 | + |
|
| 99 | + /** |
|
| 100 | + * Assembles the chunks into the file specified by the path. |
|
| 101 | + * Chunks are deleted afterwards. |
|
| 102 | + * |
|
| 103 | + * @param resource $f target path |
|
| 104 | + * |
|
| 105 | + * @return integer assembled file size |
|
| 106 | + * |
|
| 107 | + * @throws \OC\InsufficientStorageException when file could not be fully |
|
| 108 | + * assembled due to lack of free space |
|
| 109 | + */ |
|
| 110 | + public function assemble($f) { |
|
| 111 | + $cache = $this->getCache(); |
|
| 112 | + $prefix = $this->getPrefix(); |
|
| 113 | + $count = 0; |
|
| 114 | + for ($i = 0; $i < $this->info['chunkcount']; $i++) { |
|
| 115 | + $chunk = $cache->get($prefix.$i); |
|
| 116 | + // remove after reading to directly save space |
|
| 117 | + $cache->remove($prefix.$i); |
|
| 118 | + $count += fwrite($f, $chunk); |
|
| 119 | + // let php release the memory to work around memory exhausted error with php 5.6 |
|
| 120 | + $chunk = null; |
|
| 121 | + } |
|
| 122 | + |
|
| 123 | + return $count; |
|
| 124 | + } |
|
| 125 | + |
|
| 126 | + /** |
|
| 127 | + * Returns the size of the chunks already present |
|
| 128 | + * @return integer size in bytes |
|
| 129 | + */ |
|
| 130 | + public function getCurrentSize() { |
|
| 131 | + $cache = $this->getCache(); |
|
| 132 | + $prefix = $this->getPrefix(); |
|
| 133 | + $total = 0; |
|
| 134 | + for ($i = 0; $i < $this->info['chunkcount']; $i++) { |
|
| 135 | + $total += $cache->size($prefix.$i); |
|
| 136 | + } |
|
| 137 | + return $total; |
|
| 138 | + } |
|
| 139 | + |
|
| 140 | + /** |
|
| 141 | + * Removes all chunks which belong to this transmission |
|
| 142 | + */ |
|
| 143 | + public function cleanup() { |
|
| 144 | + $cache = $this->getCache(); |
|
| 145 | + $prefix = $this->getPrefix(); |
|
| 146 | + for($i=0; $i < $this->info['chunkcount']; $i++) { |
|
| 147 | + $cache->remove($prefix.$i); |
|
| 148 | + } |
|
| 149 | + } |
|
| 150 | + |
|
| 151 | + /** |
|
| 152 | + * Removes one specific chunk |
|
| 153 | + * @param string $index |
|
| 154 | + */ |
|
| 155 | + public function remove($index) { |
|
| 156 | + $cache = $this->getCache(); |
|
| 157 | + $prefix = $this->getPrefix(); |
|
| 158 | + $cache->remove($prefix.$index); |
|
| 159 | + } |
|
| 160 | + |
|
| 161 | + /** |
|
| 162 | + * Assembles the chunks into the file specified by the path. |
|
| 163 | + * Also triggers the relevant hooks and proxies. |
|
| 164 | + * |
|
| 165 | + * @param \OC\Files\Storage\Storage $storage storage |
|
| 166 | + * @param string $path target path relative to the storage |
|
| 167 | + * @return bool true on success or false if file could not be created |
|
| 168 | + * |
|
| 169 | + * @throws \OC\ServerNotAvailableException |
|
| 170 | + */ |
|
| 171 | + public function file_assemble($storage, $path) { |
|
| 172 | + // use file_put_contents as method because that best matches what this function does |
|
| 173 | + if (\OC\Files\Filesystem::isValidPath($path)) { |
|
| 174 | + $target = $storage->fopen($path, 'w'); |
|
| 175 | + if ($target) { |
|
| 176 | + $count = $this->assemble($target); |
|
| 177 | + fclose($target); |
|
| 178 | + return $count > 0; |
|
| 179 | + } else { |
|
| 180 | + return false; |
|
| 181 | + } |
|
| 182 | + } |
|
| 183 | + return false; |
|
| 184 | + } |
|
| 185 | 185 | } |
@@ -85,9 +85,9 @@ discard block |
||
| 85 | 85 | public function isComplete() { |
| 86 | 86 | $prefix = $this->getPrefix(); |
| 87 | 87 | $cache = $this->getCache(); |
| 88 | - $chunkcount = (int)$this->info['chunkcount']; |
|
| 88 | + $chunkcount = (int) $this->info['chunkcount']; |
|
| 89 | 89 | |
| 90 | - for($i=($chunkcount-1); $i >= 0; $i--) { |
|
| 90 | + for ($i = ($chunkcount - 1); $i >= 0; $i--) { |
|
| 91 | 91 | if (!$cache->hasKey($prefix.$i)) { |
| 92 | 92 | return false; |
| 93 | 93 | } |
@@ -143,7 +143,7 @@ discard block |
||
| 143 | 143 | public function cleanup() { |
| 144 | 144 | $cache = $this->getCache(); |
| 145 | 145 | $prefix = $this->getPrefix(); |
| 146 | - for($i=0; $i < $this->info['chunkcount']; $i++) { |
|
| 146 | + for ($i = 0; $i < $this->info['chunkcount']; $i++) { |
|
| 147 | 147 | $cache->remove($prefix.$i); |
| 148 | 148 | } |
| 149 | 149 | } |
@@ -29,118 +29,118 @@ |
||
| 29 | 29 | * |
| 30 | 30 | */ |
| 31 | 31 | class OC_Hook{ |
| 32 | - public static $thrownExceptions = []; |
|
| 32 | + public static $thrownExceptions = []; |
|
| 33 | 33 | |
| 34 | - static private $registered = array(); |
|
| 34 | + static private $registered = array(); |
|
| 35 | 35 | |
| 36 | - /** |
|
| 37 | - * connects a function to a hook |
|
| 38 | - * |
|
| 39 | - * @param string $signalClass class name of emitter |
|
| 40 | - * @param string $signalName name of signal |
|
| 41 | - * @param string|object $slotClass class name of slot |
|
| 42 | - * @param string $slotName name of slot |
|
| 43 | - * @return bool |
|
| 44 | - * |
|
| 45 | - * This function makes it very easy to connect to use hooks. |
|
| 46 | - * |
|
| 47 | - * TODO: write example |
|
| 48 | - */ |
|
| 49 | - static public function connect($signalClass, $signalName, $slotClass, $slotName ) { |
|
| 50 | - // If we're trying to connect to an emitting class that isn't |
|
| 51 | - // yet registered, register it |
|
| 52 | - if( !array_key_exists($signalClass, self::$registered )) { |
|
| 53 | - self::$registered[$signalClass] = array(); |
|
| 54 | - } |
|
| 55 | - // If we're trying to connect to an emitting method that isn't |
|
| 56 | - // yet registered, register it with the emitting class |
|
| 57 | - if( !array_key_exists( $signalName, self::$registered[$signalClass] )) { |
|
| 58 | - self::$registered[$signalClass][$signalName] = array(); |
|
| 59 | - } |
|
| 36 | + /** |
|
| 37 | + * connects a function to a hook |
|
| 38 | + * |
|
| 39 | + * @param string $signalClass class name of emitter |
|
| 40 | + * @param string $signalName name of signal |
|
| 41 | + * @param string|object $slotClass class name of slot |
|
| 42 | + * @param string $slotName name of slot |
|
| 43 | + * @return bool |
|
| 44 | + * |
|
| 45 | + * This function makes it very easy to connect to use hooks. |
|
| 46 | + * |
|
| 47 | + * TODO: write example |
|
| 48 | + */ |
|
| 49 | + static public function connect($signalClass, $signalName, $slotClass, $slotName ) { |
|
| 50 | + // If we're trying to connect to an emitting class that isn't |
|
| 51 | + // yet registered, register it |
|
| 52 | + if( !array_key_exists($signalClass, self::$registered )) { |
|
| 53 | + self::$registered[$signalClass] = array(); |
|
| 54 | + } |
|
| 55 | + // If we're trying to connect to an emitting method that isn't |
|
| 56 | + // yet registered, register it with the emitting class |
|
| 57 | + if( !array_key_exists( $signalName, self::$registered[$signalClass] )) { |
|
| 58 | + self::$registered[$signalClass][$signalName] = array(); |
|
| 59 | + } |
|
| 60 | 60 | |
| 61 | - // don't connect hooks twice |
|
| 62 | - foreach (self::$registered[$signalClass][$signalName] as $hook) { |
|
| 63 | - if ($hook['class'] === $slotClass and $hook['name'] === $slotName) { |
|
| 64 | - return false; |
|
| 65 | - } |
|
| 66 | - } |
|
| 67 | - // Connect the hook handler to the requested emitter |
|
| 68 | - self::$registered[$signalClass][$signalName][] = array( |
|
| 69 | - "class" => $slotClass, |
|
| 70 | - "name" => $slotName |
|
| 71 | - ); |
|
| 61 | + // don't connect hooks twice |
|
| 62 | + foreach (self::$registered[$signalClass][$signalName] as $hook) { |
|
| 63 | + if ($hook['class'] === $slotClass and $hook['name'] === $slotName) { |
|
| 64 | + return false; |
|
| 65 | + } |
|
| 66 | + } |
|
| 67 | + // Connect the hook handler to the requested emitter |
|
| 68 | + self::$registered[$signalClass][$signalName][] = array( |
|
| 69 | + "class" => $slotClass, |
|
| 70 | + "name" => $slotName |
|
| 71 | + ); |
|
| 72 | 72 | |
| 73 | - // No chance for failure ;-) |
|
| 74 | - return true; |
|
| 75 | - } |
|
| 73 | + // No chance for failure ;-) |
|
| 74 | + return true; |
|
| 75 | + } |
|
| 76 | 76 | |
| 77 | - /** |
|
| 78 | - * emits a signal |
|
| 79 | - * |
|
| 80 | - * @param string $signalClass class name of emitter |
|
| 81 | - * @param string $signalName name of signal |
|
| 82 | - * @param mixed $params default: array() array with additional data |
|
| 83 | - * @return bool true if slots exists or false if not |
|
| 84 | - * @throws \OC\HintException |
|
| 85 | - * @throws \OC\ServerNotAvailableException Emits a signal. To get data from the slot use references! |
|
| 86 | - * |
|
| 87 | - * TODO: write example |
|
| 88 | - */ |
|
| 89 | - static public function emit($signalClass, $signalName, $params = []) { |
|
| 77 | + /** |
|
| 78 | + * emits a signal |
|
| 79 | + * |
|
| 80 | + * @param string $signalClass class name of emitter |
|
| 81 | + * @param string $signalName name of signal |
|
| 82 | + * @param mixed $params default: array() array with additional data |
|
| 83 | + * @return bool true if slots exists or false if not |
|
| 84 | + * @throws \OC\HintException |
|
| 85 | + * @throws \OC\ServerNotAvailableException Emits a signal. To get data from the slot use references! |
|
| 86 | + * |
|
| 87 | + * TODO: write example |
|
| 88 | + */ |
|
| 89 | + static public function emit($signalClass, $signalName, $params = []) { |
|
| 90 | 90 | |
| 91 | - // Return false if no hook handlers are listening to this |
|
| 92 | - // emitting class |
|
| 93 | - if( !array_key_exists($signalClass, self::$registered )) { |
|
| 94 | - return false; |
|
| 95 | - } |
|
| 91 | + // Return false if no hook handlers are listening to this |
|
| 92 | + // emitting class |
|
| 93 | + if( !array_key_exists($signalClass, self::$registered )) { |
|
| 94 | + return false; |
|
| 95 | + } |
|
| 96 | 96 | |
| 97 | - // Return false if no hook handlers are listening to this |
|
| 98 | - // emitting method |
|
| 99 | - if( !array_key_exists( $signalName, self::$registered[$signalClass] )) { |
|
| 100 | - return false; |
|
| 101 | - } |
|
| 97 | + // Return false if no hook handlers are listening to this |
|
| 98 | + // emitting method |
|
| 99 | + if( !array_key_exists( $signalName, self::$registered[$signalClass] )) { |
|
| 100 | + return false; |
|
| 101 | + } |
|
| 102 | 102 | |
| 103 | - // Call all slots |
|
| 104 | - foreach( self::$registered[$signalClass][$signalName] as $i ) { |
|
| 105 | - try { |
|
| 106 | - call_user_func( array( $i["class"], $i["name"] ), $params ); |
|
| 107 | - } catch (Exception $e){ |
|
| 108 | - self::$thrownExceptions[] = $e; |
|
| 109 | - \OC::$server->getLogger()->logException($e); |
|
| 110 | - if($e instanceof \OC\HintException) { |
|
| 111 | - throw $e; |
|
| 112 | - } |
|
| 113 | - if($e instanceof \OC\ServerNotAvailableException) { |
|
| 114 | - throw $e; |
|
| 115 | - } |
|
| 116 | - } |
|
| 117 | - } |
|
| 103 | + // Call all slots |
|
| 104 | + foreach( self::$registered[$signalClass][$signalName] as $i ) { |
|
| 105 | + try { |
|
| 106 | + call_user_func( array( $i["class"], $i["name"] ), $params ); |
|
| 107 | + } catch (Exception $e){ |
|
| 108 | + self::$thrownExceptions[] = $e; |
|
| 109 | + \OC::$server->getLogger()->logException($e); |
|
| 110 | + if($e instanceof \OC\HintException) { |
|
| 111 | + throw $e; |
|
| 112 | + } |
|
| 113 | + if($e instanceof \OC\ServerNotAvailableException) { |
|
| 114 | + throw $e; |
|
| 115 | + } |
|
| 116 | + } |
|
| 117 | + } |
|
| 118 | 118 | |
| 119 | - return true; |
|
| 120 | - } |
|
| 119 | + return true; |
|
| 120 | + } |
|
| 121 | 121 | |
| 122 | - /** |
|
| 123 | - * clear hooks |
|
| 124 | - * @param string $signalClass |
|
| 125 | - * @param string $signalName |
|
| 126 | - */ |
|
| 127 | - static public function clear($signalClass='', $signalName='') { |
|
| 128 | - if ($signalClass) { |
|
| 129 | - if ($signalName) { |
|
| 130 | - self::$registered[$signalClass][$signalName]=array(); |
|
| 131 | - }else{ |
|
| 132 | - self::$registered[$signalClass]=array(); |
|
| 133 | - } |
|
| 134 | - }else{ |
|
| 135 | - self::$registered=array(); |
|
| 136 | - } |
|
| 137 | - } |
|
| 122 | + /** |
|
| 123 | + * clear hooks |
|
| 124 | + * @param string $signalClass |
|
| 125 | + * @param string $signalName |
|
| 126 | + */ |
|
| 127 | + static public function clear($signalClass='', $signalName='') { |
|
| 128 | + if ($signalClass) { |
|
| 129 | + if ($signalName) { |
|
| 130 | + self::$registered[$signalClass][$signalName]=array(); |
|
| 131 | + }else{ |
|
| 132 | + self::$registered[$signalClass]=array(); |
|
| 133 | + } |
|
| 134 | + }else{ |
|
| 135 | + self::$registered=array(); |
|
| 136 | + } |
|
| 137 | + } |
|
| 138 | 138 | |
| 139 | - /** |
|
| 140 | - * DO NOT USE! |
|
| 141 | - * For unit tests ONLY! |
|
| 142 | - */ |
|
| 143 | - static public function getHooks() { |
|
| 144 | - return self::$registered; |
|
| 145 | - } |
|
| 139 | + /** |
|
| 140 | + * DO NOT USE! |
|
| 141 | + * For unit tests ONLY! |
|
| 142 | + */ |
|
| 143 | + static public function getHooks() { |
|
| 144 | + return self::$registered; |
|
| 145 | + } |
|
| 146 | 146 | } |
@@ -28,7 +28,7 @@ discard block |
||
| 28 | 28 | * along with this program. If not, see <http://www.gnu.org/licenses/> |
| 29 | 29 | * |
| 30 | 30 | */ |
| 31 | -class OC_Hook{ |
|
| 31 | +class OC_Hook { |
|
| 32 | 32 | public static $thrownExceptions = []; |
| 33 | 33 | |
| 34 | 34 | static private $registered = array(); |
@@ -46,15 +46,15 @@ discard block |
||
| 46 | 46 | * |
| 47 | 47 | * TODO: write example |
| 48 | 48 | */ |
| 49 | - static public function connect($signalClass, $signalName, $slotClass, $slotName ) { |
|
| 49 | + static public function connect($signalClass, $signalName, $slotClass, $slotName) { |
|
| 50 | 50 | // If we're trying to connect to an emitting class that isn't |
| 51 | 51 | // yet registered, register it |
| 52 | - if( !array_key_exists($signalClass, self::$registered )) { |
|
| 52 | + if (!array_key_exists($signalClass, self::$registered)) { |
|
| 53 | 53 | self::$registered[$signalClass] = array(); |
| 54 | 54 | } |
| 55 | 55 | // If we're trying to connect to an emitting method that isn't |
| 56 | 56 | // yet registered, register it with the emitting class |
| 57 | - if( !array_key_exists( $signalName, self::$registered[$signalClass] )) { |
|
| 57 | + if (!array_key_exists($signalName, self::$registered[$signalClass])) { |
|
| 58 | 58 | self::$registered[$signalClass][$signalName] = array(); |
| 59 | 59 | } |
| 60 | 60 | |
@@ -90,27 +90,27 @@ discard block |
||
| 90 | 90 | |
| 91 | 91 | // Return false if no hook handlers are listening to this |
| 92 | 92 | // emitting class |
| 93 | - if( !array_key_exists($signalClass, self::$registered )) { |
|
| 93 | + if (!array_key_exists($signalClass, self::$registered)) { |
|
| 94 | 94 | return false; |
| 95 | 95 | } |
| 96 | 96 | |
| 97 | 97 | // Return false if no hook handlers are listening to this |
| 98 | 98 | // emitting method |
| 99 | - if( !array_key_exists( $signalName, self::$registered[$signalClass] )) { |
|
| 99 | + if (!array_key_exists($signalName, self::$registered[$signalClass])) { |
|
| 100 | 100 | return false; |
| 101 | 101 | } |
| 102 | 102 | |
| 103 | 103 | // Call all slots |
| 104 | - foreach( self::$registered[$signalClass][$signalName] as $i ) { |
|
| 104 | + foreach (self::$registered[$signalClass][$signalName] as $i) { |
|
| 105 | 105 | try { |
| 106 | - call_user_func( array( $i["class"], $i["name"] ), $params ); |
|
| 107 | - } catch (Exception $e){ |
|
| 106 | + call_user_func(array($i["class"], $i["name"]), $params); |
|
| 107 | + } catch (Exception $e) { |
|
| 108 | 108 | self::$thrownExceptions[] = $e; |
| 109 | 109 | \OC::$server->getLogger()->logException($e); |
| 110 | - if($e instanceof \OC\HintException) { |
|
| 110 | + if ($e instanceof \OC\HintException) { |
|
| 111 | 111 | throw $e; |
| 112 | 112 | } |
| 113 | - if($e instanceof \OC\ServerNotAvailableException) { |
|
| 113 | + if ($e instanceof \OC\ServerNotAvailableException) { |
|
| 114 | 114 | throw $e; |
| 115 | 115 | } |
| 116 | 116 | } |
@@ -124,15 +124,15 @@ discard block |
||
| 124 | 124 | * @param string $signalClass |
| 125 | 125 | * @param string $signalName |
| 126 | 126 | */ |
| 127 | - static public function clear($signalClass='', $signalName='') { |
|
| 127 | + static public function clear($signalClass = '', $signalName = '') { |
|
| 128 | 128 | if ($signalClass) { |
| 129 | 129 | if ($signalName) { |
| 130 | - self::$registered[$signalClass][$signalName]=array(); |
|
| 131 | - }else{ |
|
| 132 | - self::$registered[$signalClass]=array(); |
|
| 130 | + self::$registered[$signalClass][$signalName] = array(); |
|
| 131 | + } else { |
|
| 132 | + self::$registered[$signalClass] = array(); |
|
| 133 | 133 | } |
| 134 | - }else{ |
|
| 135 | - self::$registered=array(); |
|
| 134 | + } else { |
|
| 135 | + self::$registered = array(); |
|
| 136 | 136 | } |
| 137 | 137 | } |
| 138 | 138 | |
@@ -128,10 +128,10 @@ |
||
| 128 | 128 | if ($signalClass) { |
| 129 | 129 | if ($signalName) { |
| 130 | 130 | self::$registered[$signalClass][$signalName]=array(); |
| 131 | - }else{ |
|
| 131 | + } else{ |
|
| 132 | 132 | self::$registered[$signalClass]=array(); |
| 133 | 133 | } |
| 134 | - }else{ |
|
| 134 | + } else{ |
|
| 135 | 135 | self::$registered=array(); |
| 136 | 136 | } |
| 137 | 137 | } |
@@ -271,8 +271,9 @@ |
||
| 271 | 271 | } |
| 272 | 272 | foreach ($dirs as $dir) { |
| 273 | 273 | foreach ($exts as $ext) { |
| 274 | - if ($check_fn("$dir/$name" . $ext)) |
|
| 275 | - return true; |
|
| 274 | + if ($check_fn("$dir/$name" . $ext)) { |
|
| 275 | + return true; |
|
| 276 | + } |
|
| 276 | 277 | } |
| 277 | 278 | } |
| 278 | 279 | return false; |
@@ -131,7 +131,7 @@ discard block |
||
| 131 | 131 | /** |
| 132 | 132 | * Make a computer file size |
| 133 | 133 | * @param string $str file size in human readable format |
| 134 | - * @return float|bool a file size in bytes |
|
| 134 | + * @return integer a file size in bytes |
|
| 135 | 135 | * |
| 136 | 136 | * Makes 2kB to 2048. |
| 137 | 137 | * |
@@ -529,7 +529,7 @@ discard block |
||
| 529 | 529 | * |
| 530 | 530 | * @param string $path |
| 531 | 531 | * @param \OCP\Files\FileInfo $rootInfo (optional) |
| 532 | - * @return array |
|
| 532 | + * @return string |
|
| 533 | 533 | * @throws \OCP\Files\NotFoundException |
| 534 | 534 | */ |
| 535 | 535 | public static function getStorageInfo($path, $rootInfo = null) { |
@@ -64,7 +64,7 @@ discard block |
||
| 64 | 64 | } else { |
| 65 | 65 | $url = OC::$server->getURLGenerator()->getAbsoluteURL(OC::$server->getURLGenerator()->linkTo('', 'public.php').'?service='.$service); |
| 66 | 66 | } |
| 67 | - return $url . (($add_slash && $service[strlen($service) - 1] != '/') ? '/' : ''); |
|
| 67 | + return $url.(($add_slash && $service[strlen($service) - 1] != '/') ? '/' : ''); |
|
| 68 | 68 | } |
| 69 | 69 | |
| 70 | 70 | /** |
@@ -114,18 +114,18 @@ discard block |
||
| 114 | 114 | return "?"; |
| 115 | 115 | } |
| 116 | 116 | if ($bytes < 1024) { |
| 117 | - return $bytes . "B"; |
|
| 117 | + return $bytes."B"; |
|
| 118 | 118 | } |
| 119 | 119 | $bytes = round($bytes / 1024, 1); |
| 120 | 120 | if ($bytes < 1024) { |
| 121 | - return $bytes . "K"; |
|
| 121 | + return $bytes."K"; |
|
| 122 | 122 | } |
| 123 | 123 | $bytes = round($bytes / 1024, 1); |
| 124 | 124 | if ($bytes < 1024) { |
| 125 | - return $bytes . "M"; |
|
| 125 | + return $bytes."M"; |
|
| 126 | 126 | } |
| 127 | 127 | $bytes = round($bytes / 1024, 1); |
| 128 | - return $bytes . "G"; |
|
| 128 | + return $bytes."G"; |
|
| 129 | 129 | } |
| 130 | 130 | |
| 131 | 131 | /** |
@@ -271,7 +271,7 @@ discard block |
||
| 271 | 271 | } |
| 272 | 272 | foreach ($dirs as $dir) { |
| 273 | 273 | foreach ($exts as $ext) { |
| 274 | - if ($check_fn("$dir/$name" . $ext)) |
|
| 274 | + if ($check_fn("$dir/$name".$ext)) |
|
| 275 | 275 | return true; |
| 276 | 276 | } |
| 277 | 277 | } |
@@ -342,7 +342,7 @@ discard block |
||
| 342 | 342 | $ext = ''; |
| 343 | 343 | } |
| 344 | 344 | |
| 345 | - $newpath = $path . '/' . $filename; |
|
| 345 | + $newpath = $path.'/'.$filename; |
|
| 346 | 346 | if ($view->file_exists($newpath)) { |
| 347 | 347 | if (preg_match_all('/\((\d+)\)/', $name, $matches, PREG_OFFSET_CAPTURE)) { |
| 348 | 348 | //Replace the last "(number)" with "(number+1)" |
@@ -358,11 +358,11 @@ discard block |
||
| 358 | 358 | do { |
| 359 | 359 | if ($offset) { |
| 360 | 360 | //Replace the last "(number)" with "(number+1)" |
| 361 | - $newname = substr_replace($name, '(' . $counter . ')', $offset, $match_length); |
|
| 361 | + $newname = substr_replace($name, '('.$counter.')', $offset, $match_length); |
|
| 362 | 362 | } else { |
| 363 | - $newname = $name . ' (' . $counter . ')'; |
|
| 363 | + $newname = $name.' ('.$counter.')'; |
|
| 364 | 364 | } |
| 365 | - $newpath = $path . '/' . $newname . $ext; |
|
| 365 | + $newpath = $path.'/'.$newname.$ext; |
|
| 366 | 366 | $counter++; |
| 367 | 367 | } while ($view->file_exists($newpath)); |
| 368 | 368 | } |
@@ -425,7 +425,7 @@ discard block |
||
| 425 | 425 | * @return int number of bytes representing |
| 426 | 426 | */ |
| 427 | 427 | public static function maxUploadFilesize($dir, $freeSpace = null) { |
| 428 | - if (is_null($freeSpace) || $freeSpace < 0){ |
|
| 428 | + if (is_null($freeSpace) || $freeSpace < 0) { |
|
| 429 | 429 | $freeSpace = self::freeSpace($dir); |
| 430 | 430 | } |
| 431 | 431 | return min($freeSpace, self::uploadLimit()); |
@@ -443,7 +443,7 @@ discard block |
||
| 443 | 443 | $freeSpace = max($freeSpace, 0); |
| 444 | 444 | return $freeSpace; |
| 445 | 445 | } else { |
| 446 | - return (INF > 0)? INF: PHP_INT_MAX; // work around https://bugs.php.net/bug.php?id=69188 |
|
| 446 | + return (INF > 0) ? INF: PHP_INT_MAX; // work around https://bugs.php.net/bug.php?id=69188 |
|
| 447 | 447 | } |
| 448 | 448 | } |
| 449 | 449 | |
@@ -456,9 +456,9 @@ discard block |
||
| 456 | 456 | $ini = \OC::$server->getIniWrapper(); |
| 457 | 457 | $upload_max_filesize = OCP\Util::computerFileSize($ini->get('upload_max_filesize')); |
| 458 | 458 | $post_max_size = OCP\Util::computerFileSize($ini->get('post_max_size')); |
| 459 | - if ((int)$upload_max_filesize === 0 and (int)$post_max_size === 0) { |
|
| 459 | + if ((int) $upload_max_filesize === 0 and (int) $post_max_size === 0) { |
|
| 460 | 460 | return INF; |
| 461 | - } elseif ((int)$upload_max_filesize === 0 or (int)$post_max_size === 0) { |
|
| 461 | + } elseif ((int) $upload_max_filesize === 0 or (int) $post_max_size === 0) { |
|
| 462 | 462 | return max($upload_max_filesize, $post_max_size); //only the non 0 value counts |
| 463 | 463 | } else { |
| 464 | 464 | return min($upload_max_filesize, $post_max_size); |
@@ -510,9 +510,9 @@ discard block |
||
| 510 | 510 | if (empty($paths)) { |
| 511 | 511 | $paths = '/usr/local/bin /usr/bin /opt/bin /bin'; |
| 512 | 512 | } else { |
| 513 | - $paths = str_replace(':',' ',getenv('PATH')); |
|
| 513 | + $paths = str_replace(':', ' ', getenv('PATH')); |
|
| 514 | 514 | } |
| 515 | - $command = 'find ' . $paths . ' -name ' . escapeshellarg($program) . ' 2> /dev/null'; |
|
| 515 | + $command = 'find '.$paths.' -name '.escapeshellarg($program).' 2> /dev/null'; |
|
| 516 | 516 | exec($command, $output, $returnCode); |
| 517 | 517 | if (count($output) > 0) { |
| 518 | 518 | $result = escapeshellcmd($output[0]); |
@@ -597,7 +597,7 @@ discard block |
||
| 597 | 597 | $ownerId = $storage->getOwner($path); |
| 598 | 598 | $ownerDisplayName = ''; |
| 599 | 599 | $owner = \OC::$server->getUserManager()->get($ownerId); |
| 600 | - if($owner) { |
|
| 600 | + if ($owner) { |
|
| 601 | 601 | $ownerDisplayName = $owner->getDisplayName(); |
| 602 | 602 | } |
| 603 | 603 | |
@@ -49,607 +49,607 @@ |
||
| 49 | 49 | * Collection of useful functions |
| 50 | 50 | */ |
| 51 | 51 | class OC_Helper { |
| 52 | - private static $templateManager; |
|
| 53 | - |
|
| 54 | - /** |
|
| 55 | - * Creates an absolute url for public use |
|
| 56 | - * @param string $service id |
|
| 57 | - * @param bool $add_slash |
|
| 58 | - * @return string the url |
|
| 59 | - * |
|
| 60 | - * Returns a absolute url to the given service. |
|
| 61 | - */ |
|
| 62 | - public static function linkToPublic($service, $add_slash = false) { |
|
| 63 | - if ($service === 'files') { |
|
| 64 | - $url = OC::$server->getURLGenerator()->getAbsoluteURL('/s'); |
|
| 65 | - } else { |
|
| 66 | - $url = OC::$server->getURLGenerator()->getAbsoluteURL(OC::$server->getURLGenerator()->linkTo('', 'public.php').'?service='.$service); |
|
| 67 | - } |
|
| 68 | - return $url . (($add_slash && $service[strlen($service) - 1] != '/') ? '/' : ''); |
|
| 69 | - } |
|
| 70 | - |
|
| 71 | - /** |
|
| 72 | - * Make a human file size |
|
| 73 | - * @param int $bytes file size in bytes |
|
| 74 | - * @return string a human readable file size |
|
| 75 | - * |
|
| 76 | - * Makes 2048 to 2 kB. |
|
| 77 | - */ |
|
| 78 | - public static function humanFileSize($bytes) { |
|
| 79 | - if ($bytes < 0) { |
|
| 80 | - return "?"; |
|
| 81 | - } |
|
| 82 | - if ($bytes < 1024) { |
|
| 83 | - return "$bytes B"; |
|
| 84 | - } |
|
| 85 | - $bytes = round($bytes / 1024, 0); |
|
| 86 | - if ($bytes < 1024) { |
|
| 87 | - return "$bytes KB"; |
|
| 88 | - } |
|
| 89 | - $bytes = round($bytes / 1024, 1); |
|
| 90 | - if ($bytes < 1024) { |
|
| 91 | - return "$bytes MB"; |
|
| 92 | - } |
|
| 93 | - $bytes = round($bytes / 1024, 1); |
|
| 94 | - if ($bytes < 1024) { |
|
| 95 | - return "$bytes GB"; |
|
| 96 | - } |
|
| 97 | - $bytes = round($bytes / 1024, 1); |
|
| 98 | - if ($bytes < 1024) { |
|
| 99 | - return "$bytes TB"; |
|
| 100 | - } |
|
| 101 | - |
|
| 102 | - $bytes = round($bytes / 1024, 1); |
|
| 103 | - return "$bytes PB"; |
|
| 104 | - } |
|
| 105 | - |
|
| 106 | - /** |
|
| 107 | - * Make a php file size |
|
| 108 | - * @param int $bytes file size in bytes |
|
| 109 | - * @return string a php parseable file size |
|
| 110 | - * |
|
| 111 | - * Makes 2048 to 2k and 2^41 to 2048G |
|
| 112 | - */ |
|
| 113 | - public static function phpFileSize($bytes) { |
|
| 114 | - if ($bytes < 0) { |
|
| 115 | - return "?"; |
|
| 116 | - } |
|
| 117 | - if ($bytes < 1024) { |
|
| 118 | - return $bytes . "B"; |
|
| 119 | - } |
|
| 120 | - $bytes = round($bytes / 1024, 1); |
|
| 121 | - if ($bytes < 1024) { |
|
| 122 | - return $bytes . "K"; |
|
| 123 | - } |
|
| 124 | - $bytes = round($bytes / 1024, 1); |
|
| 125 | - if ($bytes < 1024) { |
|
| 126 | - return $bytes . "M"; |
|
| 127 | - } |
|
| 128 | - $bytes = round($bytes / 1024, 1); |
|
| 129 | - return $bytes . "G"; |
|
| 130 | - } |
|
| 131 | - |
|
| 132 | - /** |
|
| 133 | - * Make a computer file size |
|
| 134 | - * @param string $str file size in human readable format |
|
| 135 | - * @return float|bool a file size in bytes |
|
| 136 | - * |
|
| 137 | - * Makes 2kB to 2048. |
|
| 138 | - * |
|
| 139 | - * Inspired by: http://www.php.net/manual/en/function.filesize.php#92418 |
|
| 140 | - */ |
|
| 141 | - public static function computerFileSize($str) { |
|
| 142 | - $str = strtolower($str); |
|
| 143 | - if (is_numeric($str)) { |
|
| 144 | - return floatval($str); |
|
| 145 | - } |
|
| 146 | - |
|
| 147 | - $bytes_array = array( |
|
| 148 | - 'b' => 1, |
|
| 149 | - 'k' => 1024, |
|
| 150 | - 'kb' => 1024, |
|
| 151 | - 'mb' => 1024 * 1024, |
|
| 152 | - 'm' => 1024 * 1024, |
|
| 153 | - 'gb' => 1024 * 1024 * 1024, |
|
| 154 | - 'g' => 1024 * 1024 * 1024, |
|
| 155 | - 'tb' => 1024 * 1024 * 1024 * 1024, |
|
| 156 | - 't' => 1024 * 1024 * 1024 * 1024, |
|
| 157 | - 'pb' => 1024 * 1024 * 1024 * 1024 * 1024, |
|
| 158 | - 'p' => 1024 * 1024 * 1024 * 1024 * 1024, |
|
| 159 | - ); |
|
| 160 | - |
|
| 161 | - $bytes = floatval($str); |
|
| 162 | - |
|
| 163 | - if (preg_match('#([kmgtp]?b?)$#si', $str, $matches) && !empty($bytes_array[$matches[1]])) { |
|
| 164 | - $bytes *= $bytes_array[$matches[1]]; |
|
| 165 | - } else { |
|
| 166 | - return false; |
|
| 167 | - } |
|
| 168 | - |
|
| 169 | - $bytes = round($bytes); |
|
| 170 | - |
|
| 171 | - return $bytes; |
|
| 172 | - } |
|
| 173 | - |
|
| 174 | - /** |
|
| 175 | - * Recursive copying of folders |
|
| 176 | - * @param string $src source folder |
|
| 177 | - * @param string $dest target folder |
|
| 178 | - * |
|
| 179 | - */ |
|
| 180 | - static function copyr($src, $dest) { |
|
| 181 | - if (is_dir($src)) { |
|
| 182 | - if (!is_dir($dest)) { |
|
| 183 | - mkdir($dest); |
|
| 184 | - } |
|
| 185 | - $files = scandir($src); |
|
| 186 | - foreach ($files as $file) { |
|
| 187 | - if ($file != "." && $file != "..") { |
|
| 188 | - self::copyr("$src/$file", "$dest/$file"); |
|
| 189 | - } |
|
| 190 | - } |
|
| 191 | - } elseif (file_exists($src) && !\OC\Files\Filesystem::isFileBlacklisted($src)) { |
|
| 192 | - copy($src, $dest); |
|
| 193 | - } |
|
| 194 | - } |
|
| 195 | - |
|
| 196 | - /** |
|
| 197 | - * Recursive deletion of folders |
|
| 198 | - * @param string $dir path to the folder |
|
| 199 | - * @param bool $deleteSelf if set to false only the content of the folder will be deleted |
|
| 200 | - * @return bool |
|
| 201 | - */ |
|
| 202 | - static function rmdirr($dir, $deleteSelf = true) { |
|
| 203 | - if (is_dir($dir)) { |
|
| 204 | - $files = new RecursiveIteratorIterator( |
|
| 205 | - new RecursiveDirectoryIterator($dir, RecursiveDirectoryIterator::SKIP_DOTS), |
|
| 206 | - RecursiveIteratorIterator::CHILD_FIRST |
|
| 207 | - ); |
|
| 208 | - |
|
| 209 | - foreach ($files as $fileInfo) { |
|
| 210 | - /** @var SplFileInfo $fileInfo */ |
|
| 211 | - if ($fileInfo->isLink()) { |
|
| 212 | - unlink($fileInfo->getPathname()); |
|
| 213 | - } else if ($fileInfo->isDir()) { |
|
| 214 | - rmdir($fileInfo->getRealPath()); |
|
| 215 | - } else { |
|
| 216 | - unlink($fileInfo->getRealPath()); |
|
| 217 | - } |
|
| 218 | - } |
|
| 219 | - if ($deleteSelf) { |
|
| 220 | - rmdir($dir); |
|
| 221 | - } |
|
| 222 | - } elseif (file_exists($dir)) { |
|
| 223 | - if ($deleteSelf) { |
|
| 224 | - unlink($dir); |
|
| 225 | - } |
|
| 226 | - } |
|
| 227 | - if (!$deleteSelf) { |
|
| 228 | - return true; |
|
| 229 | - } |
|
| 230 | - |
|
| 231 | - return !file_exists($dir); |
|
| 232 | - } |
|
| 233 | - |
|
| 234 | - /** |
|
| 235 | - * @return \OC\Files\Type\TemplateManager |
|
| 236 | - */ |
|
| 237 | - static public function getFileTemplateManager() { |
|
| 238 | - if (!self::$templateManager) { |
|
| 239 | - self::$templateManager = new \OC\Files\Type\TemplateManager(); |
|
| 240 | - } |
|
| 241 | - return self::$templateManager; |
|
| 242 | - } |
|
| 243 | - |
|
| 244 | - /** |
|
| 245 | - * detect if a given program is found in the search PATH |
|
| 246 | - * |
|
| 247 | - * @param string $name |
|
| 248 | - * @param bool $path |
|
| 249 | - * @internal param string $program name |
|
| 250 | - * @internal param string $optional search path, defaults to $PATH |
|
| 251 | - * @return bool true if executable program found in path |
|
| 252 | - */ |
|
| 253 | - public static function canExecute($name, $path = false) { |
|
| 254 | - // path defaults to PATH from environment if not set |
|
| 255 | - if ($path === false) { |
|
| 256 | - $path = getenv("PATH"); |
|
| 257 | - } |
|
| 258 | - // we look for an executable file of that name |
|
| 259 | - $exts = [""]; |
|
| 260 | - $check_fn = "is_executable"; |
|
| 261 | - // Default check will be done with $path directories : |
|
| 262 | - $dirs = explode(PATH_SEPARATOR, $path); |
|
| 263 | - // WARNING : We have to check if open_basedir is enabled : |
|
| 264 | - $obd = OC::$server->getIniWrapper()->getString('open_basedir'); |
|
| 265 | - if ($obd != "none") { |
|
| 266 | - $obd_values = explode(PATH_SEPARATOR, $obd); |
|
| 267 | - if (count($obd_values) > 0 and $obd_values[0]) { |
|
| 268 | - // open_basedir is in effect ! |
|
| 269 | - // We need to check if the program is in one of these dirs : |
|
| 270 | - $dirs = $obd_values; |
|
| 271 | - } |
|
| 272 | - } |
|
| 273 | - foreach ($dirs as $dir) { |
|
| 274 | - foreach ($exts as $ext) { |
|
| 275 | - if ($check_fn("$dir/$name" . $ext)) |
|
| 276 | - return true; |
|
| 277 | - } |
|
| 278 | - } |
|
| 279 | - return false; |
|
| 280 | - } |
|
| 281 | - |
|
| 282 | - /** |
|
| 283 | - * copy the contents of one stream to another |
|
| 284 | - * |
|
| 285 | - * @param resource $source |
|
| 286 | - * @param resource $target |
|
| 287 | - * @return array the number of bytes copied and result |
|
| 288 | - */ |
|
| 289 | - public static function streamCopy($source, $target) { |
|
| 290 | - if (!$source or !$target) { |
|
| 291 | - return array(0, false); |
|
| 292 | - } |
|
| 293 | - $bufSize = 8192; |
|
| 294 | - $result = true; |
|
| 295 | - $count = 0; |
|
| 296 | - while (!feof($source)) { |
|
| 297 | - $buf = fread($source, $bufSize); |
|
| 298 | - $bytesWritten = fwrite($target, $buf); |
|
| 299 | - if ($bytesWritten !== false) { |
|
| 300 | - $count += $bytesWritten; |
|
| 301 | - } |
|
| 302 | - // note: strlen is expensive so only use it when necessary, |
|
| 303 | - // on the last block |
|
| 304 | - if ($bytesWritten === false |
|
| 305 | - || ($bytesWritten < $bufSize && $bytesWritten < strlen($buf)) |
|
| 306 | - ) { |
|
| 307 | - // write error, could be disk full ? |
|
| 308 | - $result = false; |
|
| 309 | - break; |
|
| 310 | - } |
|
| 311 | - } |
|
| 312 | - return array($count, $result); |
|
| 313 | - } |
|
| 314 | - |
|
| 315 | - /** |
|
| 316 | - * Adds a suffix to the name in case the file exists |
|
| 317 | - * |
|
| 318 | - * @param string $path |
|
| 319 | - * @param string $filename |
|
| 320 | - * @return string |
|
| 321 | - */ |
|
| 322 | - public static function buildNotExistingFileName($path, $filename) { |
|
| 323 | - $view = \OC\Files\Filesystem::getView(); |
|
| 324 | - return self::buildNotExistingFileNameForView($path, $filename, $view); |
|
| 325 | - } |
|
| 326 | - |
|
| 327 | - /** |
|
| 328 | - * Adds a suffix to the name in case the file exists |
|
| 329 | - * |
|
| 330 | - * @param string $path |
|
| 331 | - * @param string $filename |
|
| 332 | - * @return string |
|
| 333 | - */ |
|
| 334 | - public static function buildNotExistingFileNameForView($path, $filename, \OC\Files\View $view) { |
|
| 335 | - if ($path === '/') { |
|
| 336 | - $path = ''; |
|
| 337 | - } |
|
| 338 | - if ($pos = strrpos($filename, '.')) { |
|
| 339 | - $name = substr($filename, 0, $pos); |
|
| 340 | - $ext = substr($filename, $pos); |
|
| 341 | - } else { |
|
| 342 | - $name = $filename; |
|
| 343 | - $ext = ''; |
|
| 344 | - } |
|
| 345 | - |
|
| 346 | - $newpath = $path . '/' . $filename; |
|
| 347 | - if ($view->file_exists($newpath)) { |
|
| 348 | - if (preg_match_all('/\((\d+)\)/', $name, $matches, PREG_OFFSET_CAPTURE)) { |
|
| 349 | - //Replace the last "(number)" with "(number+1)" |
|
| 350 | - $last_match = count($matches[0]) - 1; |
|
| 351 | - $counter = $matches[1][$last_match][0] + 1; |
|
| 352 | - $offset = $matches[0][$last_match][1]; |
|
| 353 | - $match_length = strlen($matches[0][$last_match][0]); |
|
| 354 | - } else { |
|
| 355 | - $counter = 2; |
|
| 356 | - $match_length = 0; |
|
| 357 | - $offset = false; |
|
| 358 | - } |
|
| 359 | - do { |
|
| 360 | - if ($offset) { |
|
| 361 | - //Replace the last "(number)" with "(number+1)" |
|
| 362 | - $newname = substr_replace($name, '(' . $counter . ')', $offset, $match_length); |
|
| 363 | - } else { |
|
| 364 | - $newname = $name . ' (' . $counter . ')'; |
|
| 365 | - } |
|
| 366 | - $newpath = $path . '/' . $newname . $ext; |
|
| 367 | - $counter++; |
|
| 368 | - } while ($view->file_exists($newpath)); |
|
| 369 | - } |
|
| 370 | - |
|
| 371 | - return $newpath; |
|
| 372 | - } |
|
| 373 | - |
|
| 374 | - /** |
|
| 375 | - * Returns an array with all keys from input lowercased or uppercased. Numbered indices are left as is. |
|
| 376 | - * |
|
| 377 | - * @param array $input The array to work on |
|
| 378 | - * @param int $case Either MB_CASE_UPPER or MB_CASE_LOWER (default) |
|
| 379 | - * @param string $encoding The encoding parameter is the character encoding. Defaults to UTF-8 |
|
| 380 | - * @return array |
|
| 381 | - * |
|
| 382 | - * Returns an array with all keys from input lowercased or uppercased. Numbered indices are left as is. |
|
| 383 | - * based on http://www.php.net/manual/en/function.array-change-key-case.php#107715 |
|
| 384 | - * |
|
| 385 | - */ |
|
| 386 | - public static function mb_array_change_key_case($input, $case = MB_CASE_LOWER, $encoding = 'UTF-8') { |
|
| 387 | - $case = ($case != MB_CASE_UPPER) ? MB_CASE_LOWER : MB_CASE_UPPER; |
|
| 388 | - $ret = array(); |
|
| 389 | - foreach ($input as $k => $v) { |
|
| 390 | - $ret[mb_convert_case($k, $case, $encoding)] = $v; |
|
| 391 | - } |
|
| 392 | - return $ret; |
|
| 393 | - } |
|
| 394 | - |
|
| 395 | - /** |
|
| 396 | - * performs a search in a nested array |
|
| 397 | - * @param array $haystack the array to be searched |
|
| 398 | - * @param string $needle the search string |
|
| 399 | - * @param mixed $index optional, only search this key name |
|
| 400 | - * @return mixed the key of the matching field, otherwise false |
|
| 401 | - * |
|
| 402 | - * performs a search in a nested array |
|
| 403 | - * |
|
| 404 | - * taken from http://www.php.net/manual/en/function.array-search.php#97645 |
|
| 405 | - */ |
|
| 406 | - public static function recursiveArraySearch($haystack, $needle, $index = null) { |
|
| 407 | - $aIt = new RecursiveArrayIterator($haystack); |
|
| 408 | - $it = new RecursiveIteratorIterator($aIt); |
|
| 409 | - |
|
| 410 | - while ($it->valid()) { |
|
| 411 | - if (((isset($index) AND ($it->key() == $index)) OR (!isset($index))) AND ($it->current() == $needle)) { |
|
| 412 | - return $aIt->key(); |
|
| 413 | - } |
|
| 414 | - |
|
| 415 | - $it->next(); |
|
| 416 | - } |
|
| 417 | - |
|
| 418 | - return false; |
|
| 419 | - } |
|
| 420 | - |
|
| 421 | - /** |
|
| 422 | - * calculates the maximum upload size respecting system settings, free space and user quota |
|
| 423 | - * |
|
| 424 | - * @param string $dir the current folder where the user currently operates |
|
| 425 | - * @param int $freeSpace the number of bytes free on the storage holding $dir, if not set this will be received from the storage directly |
|
| 426 | - * @return int number of bytes representing |
|
| 427 | - */ |
|
| 428 | - public static function maxUploadFilesize($dir, $freeSpace = null) { |
|
| 429 | - if (is_null($freeSpace) || $freeSpace < 0){ |
|
| 430 | - $freeSpace = self::freeSpace($dir); |
|
| 431 | - } |
|
| 432 | - return min($freeSpace, self::uploadLimit()); |
|
| 433 | - } |
|
| 434 | - |
|
| 435 | - /** |
|
| 436 | - * Calculate free space left within user quota |
|
| 437 | - * |
|
| 438 | - * @param string $dir the current folder where the user currently operates |
|
| 439 | - * @return int number of bytes representing |
|
| 440 | - */ |
|
| 441 | - public static function freeSpace($dir) { |
|
| 442 | - $freeSpace = \OC\Files\Filesystem::free_space($dir); |
|
| 443 | - if ($freeSpace < \OCP\Files\FileInfo::SPACE_UNLIMITED) { |
|
| 444 | - $freeSpace = max($freeSpace, 0); |
|
| 445 | - return $freeSpace; |
|
| 446 | - } else { |
|
| 447 | - return (INF > 0)? INF: PHP_INT_MAX; // work around https://bugs.php.net/bug.php?id=69188 |
|
| 448 | - } |
|
| 449 | - } |
|
| 450 | - |
|
| 451 | - /** |
|
| 452 | - * Calculate PHP upload limit |
|
| 453 | - * |
|
| 454 | - * @return int PHP upload file size limit |
|
| 455 | - */ |
|
| 456 | - public static function uploadLimit() { |
|
| 457 | - $ini = \OC::$server->getIniWrapper(); |
|
| 458 | - $upload_max_filesize = OCP\Util::computerFileSize($ini->get('upload_max_filesize')); |
|
| 459 | - $post_max_size = OCP\Util::computerFileSize($ini->get('post_max_size')); |
|
| 460 | - if ((int)$upload_max_filesize === 0 and (int)$post_max_size === 0) { |
|
| 461 | - return INF; |
|
| 462 | - } elseif ((int)$upload_max_filesize === 0 or (int)$post_max_size === 0) { |
|
| 463 | - return max($upload_max_filesize, $post_max_size); //only the non 0 value counts |
|
| 464 | - } else { |
|
| 465 | - return min($upload_max_filesize, $post_max_size); |
|
| 466 | - } |
|
| 467 | - } |
|
| 468 | - |
|
| 469 | - /** |
|
| 470 | - * Checks if a function is available |
|
| 471 | - * |
|
| 472 | - * @param string $function_name |
|
| 473 | - * @return bool |
|
| 474 | - */ |
|
| 475 | - public static function is_function_enabled($function_name) { |
|
| 476 | - if (!function_exists($function_name)) { |
|
| 477 | - return false; |
|
| 478 | - } |
|
| 479 | - $ini = \OC::$server->getIniWrapper(); |
|
| 480 | - $disabled = explode(',', $ini->get('disable_functions')); |
|
| 481 | - $disabled = array_map('trim', $disabled); |
|
| 482 | - if (in_array($function_name, $disabled)) { |
|
| 483 | - return false; |
|
| 484 | - } |
|
| 485 | - $disabled = explode(',', $ini->get('suhosin.executor.func.blacklist')); |
|
| 486 | - $disabled = array_map('trim', $disabled); |
|
| 487 | - if (in_array($function_name, $disabled)) { |
|
| 488 | - return false; |
|
| 489 | - } |
|
| 490 | - return true; |
|
| 491 | - } |
|
| 492 | - |
|
| 493 | - /** |
|
| 494 | - * Try to find a program |
|
| 495 | - * |
|
| 496 | - * @param string $program |
|
| 497 | - * @return null|string |
|
| 498 | - */ |
|
| 499 | - public static function findBinaryPath($program) { |
|
| 500 | - $memcache = \OC::$server->getMemCacheFactory()->createDistributed('findBinaryPath'); |
|
| 501 | - if ($memcache->hasKey($program)) { |
|
| 502 | - return $memcache->get($program); |
|
| 503 | - } |
|
| 504 | - $result = null; |
|
| 505 | - if (self::is_function_enabled('exec')) { |
|
| 506 | - $exeSniffer = new ExecutableFinder(); |
|
| 507 | - // Returns null if nothing is found |
|
| 508 | - $result = $exeSniffer->find($program); |
|
| 509 | - if (empty($result)) { |
|
| 510 | - $paths = getenv('PATH'); |
|
| 511 | - if (empty($paths)) { |
|
| 512 | - $paths = '/usr/local/bin /usr/bin /opt/bin /bin'; |
|
| 513 | - } else { |
|
| 514 | - $paths = str_replace(':',' ',getenv('PATH')); |
|
| 515 | - } |
|
| 516 | - $command = 'find ' . $paths . ' -name ' . escapeshellarg($program) . ' 2> /dev/null'; |
|
| 517 | - exec($command, $output, $returnCode); |
|
| 518 | - if (count($output) > 0) { |
|
| 519 | - $result = escapeshellcmd($output[0]); |
|
| 520 | - } |
|
| 521 | - } |
|
| 522 | - } |
|
| 523 | - // store the value for 5 minutes |
|
| 524 | - $memcache->set($program, $result, 300); |
|
| 525 | - return $result; |
|
| 526 | - } |
|
| 527 | - |
|
| 528 | - /** |
|
| 529 | - * Calculate the disc space for the given path |
|
| 530 | - * |
|
| 531 | - * @param string $path |
|
| 532 | - * @param \OCP\Files\FileInfo $rootInfo (optional) |
|
| 533 | - * @return array |
|
| 534 | - * @throws \OCP\Files\NotFoundException |
|
| 535 | - */ |
|
| 536 | - public static function getStorageInfo($path, $rootInfo = null) { |
|
| 537 | - // return storage info without adding mount points |
|
| 538 | - $includeExtStorage = \OC::$server->getSystemConfig()->getValue('quota_include_external_storage', false); |
|
| 539 | - |
|
| 540 | - if (!$rootInfo) { |
|
| 541 | - $rootInfo = \OC\Files\Filesystem::getFileInfo($path, $includeExtStorage ? 'ext' : false); |
|
| 542 | - } |
|
| 543 | - if (!$rootInfo instanceof \OCP\Files\FileInfo) { |
|
| 544 | - throw new \OCP\Files\NotFoundException(); |
|
| 545 | - } |
|
| 546 | - $used = $rootInfo->getSize(); |
|
| 547 | - if ($used < 0) { |
|
| 548 | - $used = 0; |
|
| 549 | - } |
|
| 550 | - $quota = \OCP\Files\FileInfo::SPACE_UNLIMITED; |
|
| 551 | - $storage = $rootInfo->getStorage(); |
|
| 552 | - $sourceStorage = $storage; |
|
| 553 | - if ($storage->instanceOfStorage('\OCA\Files_Sharing\SharedStorage')) { |
|
| 554 | - $includeExtStorage = false; |
|
| 555 | - $sourceStorage = $storage->getSourceStorage(); |
|
| 556 | - } |
|
| 557 | - if ($includeExtStorage) { |
|
| 558 | - if ($storage->instanceOfStorage('\OC\Files\Storage\Home') |
|
| 559 | - || $storage->instanceOfStorage('\OC\Files\ObjectStore\HomeObjectStoreStorage') |
|
| 560 | - ) { |
|
| 561 | - /** @var \OC\Files\Storage\Home $storage */ |
|
| 562 | - $userInstance = $storage->getUser(); |
|
| 563 | - $user = ($userInstance === null) ? null : $userInstance->getUID(); |
|
| 564 | - } else { |
|
| 565 | - $user = \OC::$server->getUserSession()->getUser()->getUID(); |
|
| 566 | - } |
|
| 567 | - if ($user) { |
|
| 568 | - $quota = OC_Util::getUserQuota($user); |
|
| 569 | - } else { |
|
| 570 | - $quota = \OCP\Files\FileInfo::SPACE_UNLIMITED; |
|
| 571 | - } |
|
| 572 | - if ($quota !== \OCP\Files\FileInfo::SPACE_UNLIMITED) { |
|
| 573 | - // always get free space / total space from root + mount points |
|
| 574 | - return self::getGlobalStorageInfo(); |
|
| 575 | - } |
|
| 576 | - } |
|
| 577 | - |
|
| 578 | - // TODO: need a better way to get total space from storage |
|
| 579 | - if ($sourceStorage->instanceOfStorage('\OC\Files\Storage\Wrapper\Quota')) { |
|
| 580 | - /** @var \OC\Files\Storage\Wrapper\Quota $storage */ |
|
| 581 | - $quota = $sourceStorage->getQuota(); |
|
| 582 | - } |
|
| 583 | - $free = $sourceStorage->free_space($rootInfo->getInternalPath()); |
|
| 584 | - if ($free >= 0) { |
|
| 585 | - $total = $free + $used; |
|
| 586 | - } else { |
|
| 587 | - $total = $free; //either unknown or unlimited |
|
| 588 | - } |
|
| 589 | - if ($total > 0) { |
|
| 590 | - if ($quota > 0 && $total > $quota) { |
|
| 591 | - $total = $quota; |
|
| 592 | - } |
|
| 593 | - // prevent division by zero or error codes (negative values) |
|
| 594 | - $relative = round(($used / $total) * 10000) / 100; |
|
| 595 | - } else { |
|
| 596 | - $relative = 0; |
|
| 597 | - } |
|
| 598 | - |
|
| 599 | - $ownerId = $storage->getOwner($path); |
|
| 600 | - $ownerDisplayName = ''; |
|
| 601 | - $owner = \OC::$server->getUserManager()->get($ownerId); |
|
| 602 | - if($owner) { |
|
| 603 | - $ownerDisplayName = $owner->getDisplayName(); |
|
| 604 | - } |
|
| 605 | - |
|
| 606 | - return [ |
|
| 607 | - 'free' => $free, |
|
| 608 | - 'used' => $used, |
|
| 609 | - 'quota' => $quota, |
|
| 610 | - 'total' => $total, |
|
| 611 | - 'relative' => $relative, |
|
| 612 | - 'owner' => $ownerId, |
|
| 613 | - 'ownerDisplayName' => $ownerDisplayName, |
|
| 614 | - ]; |
|
| 615 | - } |
|
| 616 | - |
|
| 617 | - /** |
|
| 618 | - * Get storage info including all mount points and quota |
|
| 619 | - * |
|
| 620 | - * @return array |
|
| 621 | - */ |
|
| 622 | - private static function getGlobalStorageInfo() { |
|
| 623 | - $quota = OC_Util::getUserQuota(\OCP\User::getUser()); |
|
| 624 | - |
|
| 625 | - $rootInfo = \OC\Files\Filesystem::getFileInfo('', 'ext'); |
|
| 626 | - $used = $rootInfo['size']; |
|
| 627 | - if ($used < 0) { |
|
| 628 | - $used = 0; |
|
| 629 | - } |
|
| 630 | - |
|
| 631 | - $total = $quota; |
|
| 632 | - $free = $quota - $used; |
|
| 633 | - |
|
| 634 | - if ($total > 0) { |
|
| 635 | - if ($quota > 0 && $total > $quota) { |
|
| 636 | - $total = $quota; |
|
| 637 | - } |
|
| 638 | - // prevent division by zero or error codes (negative values) |
|
| 639 | - $relative = round(($used / $total) * 10000) / 100; |
|
| 640 | - } else { |
|
| 641 | - $relative = 0; |
|
| 642 | - } |
|
| 643 | - |
|
| 644 | - return array('free' => $free, 'used' => $used, 'total' => $total, 'relative' => $relative); |
|
| 645 | - |
|
| 646 | - } |
|
| 647 | - |
|
| 648 | - /** |
|
| 649 | - * Returns whether the config file is set manually to read-only |
|
| 650 | - * @return bool |
|
| 651 | - */ |
|
| 652 | - public static function isReadOnlyConfigEnabled() { |
|
| 653 | - return \OC::$server->getConfig()->getSystemValue('config_is_read_only', false); |
|
| 654 | - } |
|
| 52 | + private static $templateManager; |
|
| 53 | + |
|
| 54 | + /** |
|
| 55 | + * Creates an absolute url for public use |
|
| 56 | + * @param string $service id |
|
| 57 | + * @param bool $add_slash |
|
| 58 | + * @return string the url |
|
| 59 | + * |
|
| 60 | + * Returns a absolute url to the given service. |
|
| 61 | + */ |
|
| 62 | + public static function linkToPublic($service, $add_slash = false) { |
|
| 63 | + if ($service === 'files') { |
|
| 64 | + $url = OC::$server->getURLGenerator()->getAbsoluteURL('/s'); |
|
| 65 | + } else { |
|
| 66 | + $url = OC::$server->getURLGenerator()->getAbsoluteURL(OC::$server->getURLGenerator()->linkTo('', 'public.php').'?service='.$service); |
|
| 67 | + } |
|
| 68 | + return $url . (($add_slash && $service[strlen($service) - 1] != '/') ? '/' : ''); |
|
| 69 | + } |
|
| 70 | + |
|
| 71 | + /** |
|
| 72 | + * Make a human file size |
|
| 73 | + * @param int $bytes file size in bytes |
|
| 74 | + * @return string a human readable file size |
|
| 75 | + * |
|
| 76 | + * Makes 2048 to 2 kB. |
|
| 77 | + */ |
|
| 78 | + public static function humanFileSize($bytes) { |
|
| 79 | + if ($bytes < 0) { |
|
| 80 | + return "?"; |
|
| 81 | + } |
|
| 82 | + if ($bytes < 1024) { |
|
| 83 | + return "$bytes B"; |
|
| 84 | + } |
|
| 85 | + $bytes = round($bytes / 1024, 0); |
|
| 86 | + if ($bytes < 1024) { |
|
| 87 | + return "$bytes KB"; |
|
| 88 | + } |
|
| 89 | + $bytes = round($bytes / 1024, 1); |
|
| 90 | + if ($bytes < 1024) { |
|
| 91 | + return "$bytes MB"; |
|
| 92 | + } |
|
| 93 | + $bytes = round($bytes / 1024, 1); |
|
| 94 | + if ($bytes < 1024) { |
|
| 95 | + return "$bytes GB"; |
|
| 96 | + } |
|
| 97 | + $bytes = round($bytes / 1024, 1); |
|
| 98 | + if ($bytes < 1024) { |
|
| 99 | + return "$bytes TB"; |
|
| 100 | + } |
|
| 101 | + |
|
| 102 | + $bytes = round($bytes / 1024, 1); |
|
| 103 | + return "$bytes PB"; |
|
| 104 | + } |
|
| 105 | + |
|
| 106 | + /** |
|
| 107 | + * Make a php file size |
|
| 108 | + * @param int $bytes file size in bytes |
|
| 109 | + * @return string a php parseable file size |
|
| 110 | + * |
|
| 111 | + * Makes 2048 to 2k and 2^41 to 2048G |
|
| 112 | + */ |
|
| 113 | + public static function phpFileSize($bytes) { |
|
| 114 | + if ($bytes < 0) { |
|
| 115 | + return "?"; |
|
| 116 | + } |
|
| 117 | + if ($bytes < 1024) { |
|
| 118 | + return $bytes . "B"; |
|
| 119 | + } |
|
| 120 | + $bytes = round($bytes / 1024, 1); |
|
| 121 | + if ($bytes < 1024) { |
|
| 122 | + return $bytes . "K"; |
|
| 123 | + } |
|
| 124 | + $bytes = round($bytes / 1024, 1); |
|
| 125 | + if ($bytes < 1024) { |
|
| 126 | + return $bytes . "M"; |
|
| 127 | + } |
|
| 128 | + $bytes = round($bytes / 1024, 1); |
|
| 129 | + return $bytes . "G"; |
|
| 130 | + } |
|
| 131 | + |
|
| 132 | + /** |
|
| 133 | + * Make a computer file size |
|
| 134 | + * @param string $str file size in human readable format |
|
| 135 | + * @return float|bool a file size in bytes |
|
| 136 | + * |
|
| 137 | + * Makes 2kB to 2048. |
|
| 138 | + * |
|
| 139 | + * Inspired by: http://www.php.net/manual/en/function.filesize.php#92418 |
|
| 140 | + */ |
|
| 141 | + public static function computerFileSize($str) { |
|
| 142 | + $str = strtolower($str); |
|
| 143 | + if (is_numeric($str)) { |
|
| 144 | + return floatval($str); |
|
| 145 | + } |
|
| 146 | + |
|
| 147 | + $bytes_array = array( |
|
| 148 | + 'b' => 1, |
|
| 149 | + 'k' => 1024, |
|
| 150 | + 'kb' => 1024, |
|
| 151 | + 'mb' => 1024 * 1024, |
|
| 152 | + 'm' => 1024 * 1024, |
|
| 153 | + 'gb' => 1024 * 1024 * 1024, |
|
| 154 | + 'g' => 1024 * 1024 * 1024, |
|
| 155 | + 'tb' => 1024 * 1024 * 1024 * 1024, |
|
| 156 | + 't' => 1024 * 1024 * 1024 * 1024, |
|
| 157 | + 'pb' => 1024 * 1024 * 1024 * 1024 * 1024, |
|
| 158 | + 'p' => 1024 * 1024 * 1024 * 1024 * 1024, |
|
| 159 | + ); |
|
| 160 | + |
|
| 161 | + $bytes = floatval($str); |
|
| 162 | + |
|
| 163 | + if (preg_match('#([kmgtp]?b?)$#si', $str, $matches) && !empty($bytes_array[$matches[1]])) { |
|
| 164 | + $bytes *= $bytes_array[$matches[1]]; |
|
| 165 | + } else { |
|
| 166 | + return false; |
|
| 167 | + } |
|
| 168 | + |
|
| 169 | + $bytes = round($bytes); |
|
| 170 | + |
|
| 171 | + return $bytes; |
|
| 172 | + } |
|
| 173 | + |
|
| 174 | + /** |
|
| 175 | + * Recursive copying of folders |
|
| 176 | + * @param string $src source folder |
|
| 177 | + * @param string $dest target folder |
|
| 178 | + * |
|
| 179 | + */ |
|
| 180 | + static function copyr($src, $dest) { |
|
| 181 | + if (is_dir($src)) { |
|
| 182 | + if (!is_dir($dest)) { |
|
| 183 | + mkdir($dest); |
|
| 184 | + } |
|
| 185 | + $files = scandir($src); |
|
| 186 | + foreach ($files as $file) { |
|
| 187 | + if ($file != "." && $file != "..") { |
|
| 188 | + self::copyr("$src/$file", "$dest/$file"); |
|
| 189 | + } |
|
| 190 | + } |
|
| 191 | + } elseif (file_exists($src) && !\OC\Files\Filesystem::isFileBlacklisted($src)) { |
|
| 192 | + copy($src, $dest); |
|
| 193 | + } |
|
| 194 | + } |
|
| 195 | + |
|
| 196 | + /** |
|
| 197 | + * Recursive deletion of folders |
|
| 198 | + * @param string $dir path to the folder |
|
| 199 | + * @param bool $deleteSelf if set to false only the content of the folder will be deleted |
|
| 200 | + * @return bool |
|
| 201 | + */ |
|
| 202 | + static function rmdirr($dir, $deleteSelf = true) { |
|
| 203 | + if (is_dir($dir)) { |
|
| 204 | + $files = new RecursiveIteratorIterator( |
|
| 205 | + new RecursiveDirectoryIterator($dir, RecursiveDirectoryIterator::SKIP_DOTS), |
|
| 206 | + RecursiveIteratorIterator::CHILD_FIRST |
|
| 207 | + ); |
|
| 208 | + |
|
| 209 | + foreach ($files as $fileInfo) { |
|
| 210 | + /** @var SplFileInfo $fileInfo */ |
|
| 211 | + if ($fileInfo->isLink()) { |
|
| 212 | + unlink($fileInfo->getPathname()); |
|
| 213 | + } else if ($fileInfo->isDir()) { |
|
| 214 | + rmdir($fileInfo->getRealPath()); |
|
| 215 | + } else { |
|
| 216 | + unlink($fileInfo->getRealPath()); |
|
| 217 | + } |
|
| 218 | + } |
|
| 219 | + if ($deleteSelf) { |
|
| 220 | + rmdir($dir); |
|
| 221 | + } |
|
| 222 | + } elseif (file_exists($dir)) { |
|
| 223 | + if ($deleteSelf) { |
|
| 224 | + unlink($dir); |
|
| 225 | + } |
|
| 226 | + } |
|
| 227 | + if (!$deleteSelf) { |
|
| 228 | + return true; |
|
| 229 | + } |
|
| 230 | + |
|
| 231 | + return !file_exists($dir); |
|
| 232 | + } |
|
| 233 | + |
|
| 234 | + /** |
|
| 235 | + * @return \OC\Files\Type\TemplateManager |
|
| 236 | + */ |
|
| 237 | + static public function getFileTemplateManager() { |
|
| 238 | + if (!self::$templateManager) { |
|
| 239 | + self::$templateManager = new \OC\Files\Type\TemplateManager(); |
|
| 240 | + } |
|
| 241 | + return self::$templateManager; |
|
| 242 | + } |
|
| 243 | + |
|
| 244 | + /** |
|
| 245 | + * detect if a given program is found in the search PATH |
|
| 246 | + * |
|
| 247 | + * @param string $name |
|
| 248 | + * @param bool $path |
|
| 249 | + * @internal param string $program name |
|
| 250 | + * @internal param string $optional search path, defaults to $PATH |
|
| 251 | + * @return bool true if executable program found in path |
|
| 252 | + */ |
|
| 253 | + public static function canExecute($name, $path = false) { |
|
| 254 | + // path defaults to PATH from environment if not set |
|
| 255 | + if ($path === false) { |
|
| 256 | + $path = getenv("PATH"); |
|
| 257 | + } |
|
| 258 | + // we look for an executable file of that name |
|
| 259 | + $exts = [""]; |
|
| 260 | + $check_fn = "is_executable"; |
|
| 261 | + // Default check will be done with $path directories : |
|
| 262 | + $dirs = explode(PATH_SEPARATOR, $path); |
|
| 263 | + // WARNING : We have to check if open_basedir is enabled : |
|
| 264 | + $obd = OC::$server->getIniWrapper()->getString('open_basedir'); |
|
| 265 | + if ($obd != "none") { |
|
| 266 | + $obd_values = explode(PATH_SEPARATOR, $obd); |
|
| 267 | + if (count($obd_values) > 0 and $obd_values[0]) { |
|
| 268 | + // open_basedir is in effect ! |
|
| 269 | + // We need to check if the program is in one of these dirs : |
|
| 270 | + $dirs = $obd_values; |
|
| 271 | + } |
|
| 272 | + } |
|
| 273 | + foreach ($dirs as $dir) { |
|
| 274 | + foreach ($exts as $ext) { |
|
| 275 | + if ($check_fn("$dir/$name" . $ext)) |
|
| 276 | + return true; |
|
| 277 | + } |
|
| 278 | + } |
|
| 279 | + return false; |
|
| 280 | + } |
|
| 281 | + |
|
| 282 | + /** |
|
| 283 | + * copy the contents of one stream to another |
|
| 284 | + * |
|
| 285 | + * @param resource $source |
|
| 286 | + * @param resource $target |
|
| 287 | + * @return array the number of bytes copied and result |
|
| 288 | + */ |
|
| 289 | + public static function streamCopy($source, $target) { |
|
| 290 | + if (!$source or !$target) { |
|
| 291 | + return array(0, false); |
|
| 292 | + } |
|
| 293 | + $bufSize = 8192; |
|
| 294 | + $result = true; |
|
| 295 | + $count = 0; |
|
| 296 | + while (!feof($source)) { |
|
| 297 | + $buf = fread($source, $bufSize); |
|
| 298 | + $bytesWritten = fwrite($target, $buf); |
|
| 299 | + if ($bytesWritten !== false) { |
|
| 300 | + $count += $bytesWritten; |
|
| 301 | + } |
|
| 302 | + // note: strlen is expensive so only use it when necessary, |
|
| 303 | + // on the last block |
|
| 304 | + if ($bytesWritten === false |
|
| 305 | + || ($bytesWritten < $bufSize && $bytesWritten < strlen($buf)) |
|
| 306 | + ) { |
|
| 307 | + // write error, could be disk full ? |
|
| 308 | + $result = false; |
|
| 309 | + break; |
|
| 310 | + } |
|
| 311 | + } |
|
| 312 | + return array($count, $result); |
|
| 313 | + } |
|
| 314 | + |
|
| 315 | + /** |
|
| 316 | + * Adds a suffix to the name in case the file exists |
|
| 317 | + * |
|
| 318 | + * @param string $path |
|
| 319 | + * @param string $filename |
|
| 320 | + * @return string |
|
| 321 | + */ |
|
| 322 | + public static function buildNotExistingFileName($path, $filename) { |
|
| 323 | + $view = \OC\Files\Filesystem::getView(); |
|
| 324 | + return self::buildNotExistingFileNameForView($path, $filename, $view); |
|
| 325 | + } |
|
| 326 | + |
|
| 327 | + /** |
|
| 328 | + * Adds a suffix to the name in case the file exists |
|
| 329 | + * |
|
| 330 | + * @param string $path |
|
| 331 | + * @param string $filename |
|
| 332 | + * @return string |
|
| 333 | + */ |
|
| 334 | + public static function buildNotExistingFileNameForView($path, $filename, \OC\Files\View $view) { |
|
| 335 | + if ($path === '/') { |
|
| 336 | + $path = ''; |
|
| 337 | + } |
|
| 338 | + if ($pos = strrpos($filename, '.')) { |
|
| 339 | + $name = substr($filename, 0, $pos); |
|
| 340 | + $ext = substr($filename, $pos); |
|
| 341 | + } else { |
|
| 342 | + $name = $filename; |
|
| 343 | + $ext = ''; |
|
| 344 | + } |
|
| 345 | + |
|
| 346 | + $newpath = $path . '/' . $filename; |
|
| 347 | + if ($view->file_exists($newpath)) { |
|
| 348 | + if (preg_match_all('/\((\d+)\)/', $name, $matches, PREG_OFFSET_CAPTURE)) { |
|
| 349 | + //Replace the last "(number)" with "(number+1)" |
|
| 350 | + $last_match = count($matches[0]) - 1; |
|
| 351 | + $counter = $matches[1][$last_match][0] + 1; |
|
| 352 | + $offset = $matches[0][$last_match][1]; |
|
| 353 | + $match_length = strlen($matches[0][$last_match][0]); |
|
| 354 | + } else { |
|
| 355 | + $counter = 2; |
|
| 356 | + $match_length = 0; |
|
| 357 | + $offset = false; |
|
| 358 | + } |
|
| 359 | + do { |
|
| 360 | + if ($offset) { |
|
| 361 | + //Replace the last "(number)" with "(number+1)" |
|
| 362 | + $newname = substr_replace($name, '(' . $counter . ')', $offset, $match_length); |
|
| 363 | + } else { |
|
| 364 | + $newname = $name . ' (' . $counter . ')'; |
|
| 365 | + } |
|
| 366 | + $newpath = $path . '/' . $newname . $ext; |
|
| 367 | + $counter++; |
|
| 368 | + } while ($view->file_exists($newpath)); |
|
| 369 | + } |
|
| 370 | + |
|
| 371 | + return $newpath; |
|
| 372 | + } |
|
| 373 | + |
|
| 374 | + /** |
|
| 375 | + * Returns an array with all keys from input lowercased or uppercased. Numbered indices are left as is. |
|
| 376 | + * |
|
| 377 | + * @param array $input The array to work on |
|
| 378 | + * @param int $case Either MB_CASE_UPPER or MB_CASE_LOWER (default) |
|
| 379 | + * @param string $encoding The encoding parameter is the character encoding. Defaults to UTF-8 |
|
| 380 | + * @return array |
|
| 381 | + * |
|
| 382 | + * Returns an array with all keys from input lowercased or uppercased. Numbered indices are left as is. |
|
| 383 | + * based on http://www.php.net/manual/en/function.array-change-key-case.php#107715 |
|
| 384 | + * |
|
| 385 | + */ |
|
| 386 | + public static function mb_array_change_key_case($input, $case = MB_CASE_LOWER, $encoding = 'UTF-8') { |
|
| 387 | + $case = ($case != MB_CASE_UPPER) ? MB_CASE_LOWER : MB_CASE_UPPER; |
|
| 388 | + $ret = array(); |
|
| 389 | + foreach ($input as $k => $v) { |
|
| 390 | + $ret[mb_convert_case($k, $case, $encoding)] = $v; |
|
| 391 | + } |
|
| 392 | + return $ret; |
|
| 393 | + } |
|
| 394 | + |
|
| 395 | + /** |
|
| 396 | + * performs a search in a nested array |
|
| 397 | + * @param array $haystack the array to be searched |
|
| 398 | + * @param string $needle the search string |
|
| 399 | + * @param mixed $index optional, only search this key name |
|
| 400 | + * @return mixed the key of the matching field, otherwise false |
|
| 401 | + * |
|
| 402 | + * performs a search in a nested array |
|
| 403 | + * |
|
| 404 | + * taken from http://www.php.net/manual/en/function.array-search.php#97645 |
|
| 405 | + */ |
|
| 406 | + public static function recursiveArraySearch($haystack, $needle, $index = null) { |
|
| 407 | + $aIt = new RecursiveArrayIterator($haystack); |
|
| 408 | + $it = new RecursiveIteratorIterator($aIt); |
|
| 409 | + |
|
| 410 | + while ($it->valid()) { |
|
| 411 | + if (((isset($index) AND ($it->key() == $index)) OR (!isset($index))) AND ($it->current() == $needle)) { |
|
| 412 | + return $aIt->key(); |
|
| 413 | + } |
|
| 414 | + |
|
| 415 | + $it->next(); |
|
| 416 | + } |
|
| 417 | + |
|
| 418 | + return false; |
|
| 419 | + } |
|
| 420 | + |
|
| 421 | + /** |
|
| 422 | + * calculates the maximum upload size respecting system settings, free space and user quota |
|
| 423 | + * |
|
| 424 | + * @param string $dir the current folder where the user currently operates |
|
| 425 | + * @param int $freeSpace the number of bytes free on the storage holding $dir, if not set this will be received from the storage directly |
|
| 426 | + * @return int number of bytes representing |
|
| 427 | + */ |
|
| 428 | + public static function maxUploadFilesize($dir, $freeSpace = null) { |
|
| 429 | + if (is_null($freeSpace) || $freeSpace < 0){ |
|
| 430 | + $freeSpace = self::freeSpace($dir); |
|
| 431 | + } |
|
| 432 | + return min($freeSpace, self::uploadLimit()); |
|
| 433 | + } |
|
| 434 | + |
|
| 435 | + /** |
|
| 436 | + * Calculate free space left within user quota |
|
| 437 | + * |
|
| 438 | + * @param string $dir the current folder where the user currently operates |
|
| 439 | + * @return int number of bytes representing |
|
| 440 | + */ |
|
| 441 | + public static function freeSpace($dir) { |
|
| 442 | + $freeSpace = \OC\Files\Filesystem::free_space($dir); |
|
| 443 | + if ($freeSpace < \OCP\Files\FileInfo::SPACE_UNLIMITED) { |
|
| 444 | + $freeSpace = max($freeSpace, 0); |
|
| 445 | + return $freeSpace; |
|
| 446 | + } else { |
|
| 447 | + return (INF > 0)? INF: PHP_INT_MAX; // work around https://bugs.php.net/bug.php?id=69188 |
|
| 448 | + } |
|
| 449 | + } |
|
| 450 | + |
|
| 451 | + /** |
|
| 452 | + * Calculate PHP upload limit |
|
| 453 | + * |
|
| 454 | + * @return int PHP upload file size limit |
|
| 455 | + */ |
|
| 456 | + public static function uploadLimit() { |
|
| 457 | + $ini = \OC::$server->getIniWrapper(); |
|
| 458 | + $upload_max_filesize = OCP\Util::computerFileSize($ini->get('upload_max_filesize')); |
|
| 459 | + $post_max_size = OCP\Util::computerFileSize($ini->get('post_max_size')); |
|
| 460 | + if ((int)$upload_max_filesize === 0 and (int)$post_max_size === 0) { |
|
| 461 | + return INF; |
|
| 462 | + } elseif ((int)$upload_max_filesize === 0 or (int)$post_max_size === 0) { |
|
| 463 | + return max($upload_max_filesize, $post_max_size); //only the non 0 value counts |
|
| 464 | + } else { |
|
| 465 | + return min($upload_max_filesize, $post_max_size); |
|
| 466 | + } |
|
| 467 | + } |
|
| 468 | + |
|
| 469 | + /** |
|
| 470 | + * Checks if a function is available |
|
| 471 | + * |
|
| 472 | + * @param string $function_name |
|
| 473 | + * @return bool |
|
| 474 | + */ |
|
| 475 | + public static function is_function_enabled($function_name) { |
|
| 476 | + if (!function_exists($function_name)) { |
|
| 477 | + return false; |
|
| 478 | + } |
|
| 479 | + $ini = \OC::$server->getIniWrapper(); |
|
| 480 | + $disabled = explode(',', $ini->get('disable_functions')); |
|
| 481 | + $disabled = array_map('trim', $disabled); |
|
| 482 | + if (in_array($function_name, $disabled)) { |
|
| 483 | + return false; |
|
| 484 | + } |
|
| 485 | + $disabled = explode(',', $ini->get('suhosin.executor.func.blacklist')); |
|
| 486 | + $disabled = array_map('trim', $disabled); |
|
| 487 | + if (in_array($function_name, $disabled)) { |
|
| 488 | + return false; |
|
| 489 | + } |
|
| 490 | + return true; |
|
| 491 | + } |
|
| 492 | + |
|
| 493 | + /** |
|
| 494 | + * Try to find a program |
|
| 495 | + * |
|
| 496 | + * @param string $program |
|
| 497 | + * @return null|string |
|
| 498 | + */ |
|
| 499 | + public static function findBinaryPath($program) { |
|
| 500 | + $memcache = \OC::$server->getMemCacheFactory()->createDistributed('findBinaryPath'); |
|
| 501 | + if ($memcache->hasKey($program)) { |
|
| 502 | + return $memcache->get($program); |
|
| 503 | + } |
|
| 504 | + $result = null; |
|
| 505 | + if (self::is_function_enabled('exec')) { |
|
| 506 | + $exeSniffer = new ExecutableFinder(); |
|
| 507 | + // Returns null if nothing is found |
|
| 508 | + $result = $exeSniffer->find($program); |
|
| 509 | + if (empty($result)) { |
|
| 510 | + $paths = getenv('PATH'); |
|
| 511 | + if (empty($paths)) { |
|
| 512 | + $paths = '/usr/local/bin /usr/bin /opt/bin /bin'; |
|
| 513 | + } else { |
|
| 514 | + $paths = str_replace(':',' ',getenv('PATH')); |
|
| 515 | + } |
|
| 516 | + $command = 'find ' . $paths . ' -name ' . escapeshellarg($program) . ' 2> /dev/null'; |
|
| 517 | + exec($command, $output, $returnCode); |
|
| 518 | + if (count($output) > 0) { |
|
| 519 | + $result = escapeshellcmd($output[0]); |
|
| 520 | + } |
|
| 521 | + } |
|
| 522 | + } |
|
| 523 | + // store the value for 5 minutes |
|
| 524 | + $memcache->set($program, $result, 300); |
|
| 525 | + return $result; |
|
| 526 | + } |
|
| 527 | + |
|
| 528 | + /** |
|
| 529 | + * Calculate the disc space for the given path |
|
| 530 | + * |
|
| 531 | + * @param string $path |
|
| 532 | + * @param \OCP\Files\FileInfo $rootInfo (optional) |
|
| 533 | + * @return array |
|
| 534 | + * @throws \OCP\Files\NotFoundException |
|
| 535 | + */ |
|
| 536 | + public static function getStorageInfo($path, $rootInfo = null) { |
|
| 537 | + // return storage info without adding mount points |
|
| 538 | + $includeExtStorage = \OC::$server->getSystemConfig()->getValue('quota_include_external_storage', false); |
|
| 539 | + |
|
| 540 | + if (!$rootInfo) { |
|
| 541 | + $rootInfo = \OC\Files\Filesystem::getFileInfo($path, $includeExtStorage ? 'ext' : false); |
|
| 542 | + } |
|
| 543 | + if (!$rootInfo instanceof \OCP\Files\FileInfo) { |
|
| 544 | + throw new \OCP\Files\NotFoundException(); |
|
| 545 | + } |
|
| 546 | + $used = $rootInfo->getSize(); |
|
| 547 | + if ($used < 0) { |
|
| 548 | + $used = 0; |
|
| 549 | + } |
|
| 550 | + $quota = \OCP\Files\FileInfo::SPACE_UNLIMITED; |
|
| 551 | + $storage = $rootInfo->getStorage(); |
|
| 552 | + $sourceStorage = $storage; |
|
| 553 | + if ($storage->instanceOfStorage('\OCA\Files_Sharing\SharedStorage')) { |
|
| 554 | + $includeExtStorage = false; |
|
| 555 | + $sourceStorage = $storage->getSourceStorage(); |
|
| 556 | + } |
|
| 557 | + if ($includeExtStorage) { |
|
| 558 | + if ($storage->instanceOfStorage('\OC\Files\Storage\Home') |
|
| 559 | + || $storage->instanceOfStorage('\OC\Files\ObjectStore\HomeObjectStoreStorage') |
|
| 560 | + ) { |
|
| 561 | + /** @var \OC\Files\Storage\Home $storage */ |
|
| 562 | + $userInstance = $storage->getUser(); |
|
| 563 | + $user = ($userInstance === null) ? null : $userInstance->getUID(); |
|
| 564 | + } else { |
|
| 565 | + $user = \OC::$server->getUserSession()->getUser()->getUID(); |
|
| 566 | + } |
|
| 567 | + if ($user) { |
|
| 568 | + $quota = OC_Util::getUserQuota($user); |
|
| 569 | + } else { |
|
| 570 | + $quota = \OCP\Files\FileInfo::SPACE_UNLIMITED; |
|
| 571 | + } |
|
| 572 | + if ($quota !== \OCP\Files\FileInfo::SPACE_UNLIMITED) { |
|
| 573 | + // always get free space / total space from root + mount points |
|
| 574 | + return self::getGlobalStorageInfo(); |
|
| 575 | + } |
|
| 576 | + } |
|
| 577 | + |
|
| 578 | + // TODO: need a better way to get total space from storage |
|
| 579 | + if ($sourceStorage->instanceOfStorage('\OC\Files\Storage\Wrapper\Quota')) { |
|
| 580 | + /** @var \OC\Files\Storage\Wrapper\Quota $storage */ |
|
| 581 | + $quota = $sourceStorage->getQuota(); |
|
| 582 | + } |
|
| 583 | + $free = $sourceStorage->free_space($rootInfo->getInternalPath()); |
|
| 584 | + if ($free >= 0) { |
|
| 585 | + $total = $free + $used; |
|
| 586 | + } else { |
|
| 587 | + $total = $free; //either unknown or unlimited |
|
| 588 | + } |
|
| 589 | + if ($total > 0) { |
|
| 590 | + if ($quota > 0 && $total > $quota) { |
|
| 591 | + $total = $quota; |
|
| 592 | + } |
|
| 593 | + // prevent division by zero or error codes (negative values) |
|
| 594 | + $relative = round(($used / $total) * 10000) / 100; |
|
| 595 | + } else { |
|
| 596 | + $relative = 0; |
|
| 597 | + } |
|
| 598 | + |
|
| 599 | + $ownerId = $storage->getOwner($path); |
|
| 600 | + $ownerDisplayName = ''; |
|
| 601 | + $owner = \OC::$server->getUserManager()->get($ownerId); |
|
| 602 | + if($owner) { |
|
| 603 | + $ownerDisplayName = $owner->getDisplayName(); |
|
| 604 | + } |
|
| 605 | + |
|
| 606 | + return [ |
|
| 607 | + 'free' => $free, |
|
| 608 | + 'used' => $used, |
|
| 609 | + 'quota' => $quota, |
|
| 610 | + 'total' => $total, |
|
| 611 | + 'relative' => $relative, |
|
| 612 | + 'owner' => $ownerId, |
|
| 613 | + 'ownerDisplayName' => $ownerDisplayName, |
|
| 614 | + ]; |
|
| 615 | + } |
|
| 616 | + |
|
| 617 | + /** |
|
| 618 | + * Get storage info including all mount points and quota |
|
| 619 | + * |
|
| 620 | + * @return array |
|
| 621 | + */ |
|
| 622 | + private static function getGlobalStorageInfo() { |
|
| 623 | + $quota = OC_Util::getUserQuota(\OCP\User::getUser()); |
|
| 624 | + |
|
| 625 | + $rootInfo = \OC\Files\Filesystem::getFileInfo('', 'ext'); |
|
| 626 | + $used = $rootInfo['size']; |
|
| 627 | + if ($used < 0) { |
|
| 628 | + $used = 0; |
|
| 629 | + } |
|
| 630 | + |
|
| 631 | + $total = $quota; |
|
| 632 | + $free = $quota - $used; |
|
| 633 | + |
|
| 634 | + if ($total > 0) { |
|
| 635 | + if ($quota > 0 && $total > $quota) { |
|
| 636 | + $total = $quota; |
|
| 637 | + } |
|
| 638 | + // prevent division by zero or error codes (negative values) |
|
| 639 | + $relative = round(($used / $total) * 10000) / 100; |
|
| 640 | + } else { |
|
| 641 | + $relative = 0; |
|
| 642 | + } |
|
| 643 | + |
|
| 644 | + return array('free' => $free, 'used' => $used, 'total' => $total, 'relative' => $relative); |
|
| 645 | + |
|
| 646 | + } |
|
| 647 | + |
|
| 648 | + /** |
|
| 649 | + * Returns whether the config file is set manually to read-only |
|
| 650 | + * @return bool |
|
| 651 | + */ |
|
| 652 | + public static function isReadOnlyConfigEnabled() { |
|
| 653 | + return \OC::$server->getConfig()->getSystemValue('config_is_read_only', false); |
|
| 654 | + } |
|
| 655 | 655 | } |
@@ -26,14 +26,14 @@ |
||
| 26 | 26 | use OCP\AutoloadNotAllowedException; |
| 27 | 27 | |
| 28 | 28 | class RegularJob extends \OC\BackgroundJob\Job { |
| 29 | - public function run($argument) { |
|
| 30 | - try { |
|
| 31 | - if (is_callable($argument)) { |
|
| 32 | - call_user_func($argument); |
|
| 33 | - } |
|
| 34 | - } catch (AutoloadNotAllowedException $e) { |
|
| 35 | - // job is from a disabled app, ignore |
|
| 36 | - return null; |
|
| 37 | - } |
|
| 38 | - } |
|
| 29 | + public function run($argument) { |
|
| 30 | + try { |
|
| 31 | + if (is_callable($argument)) { |
|
| 32 | + call_user_func($argument); |
|
| 33 | + } |
|
| 34 | + } catch (AutoloadNotAllowedException $e) { |
|
| 35 | + // job is from a disabled app, ignore |
|
| 36 | + return null; |
|
| 37 | + } |
|
| 38 | + } |
|
| 39 | 39 | } |
@@ -24,12 +24,12 @@ |
||
| 24 | 24 | namespace OC\BackgroundJob\Legacy; |
| 25 | 25 | |
| 26 | 26 | class QueuedJob extends \OC\BackgroundJob\QueuedJob { |
| 27 | - public function run($argument) { |
|
| 28 | - $class = $argument['klass']; |
|
| 29 | - $method = $argument['method']; |
|
| 30 | - $parameters = $argument['parameters']; |
|
| 31 | - if (is_callable(array($class, $method))) { |
|
| 32 | - call_user_func(array($class, $method), $parameters); |
|
| 33 | - } |
|
| 34 | - } |
|
| 27 | + public function run($argument) { |
|
| 28 | + $class = $argument['klass']; |
|
| 29 | + $method = $argument['method']; |
|
| 30 | + $parameters = $argument['parameters']; |
|
| 31 | + if (is_callable(array($class, $method))) { |
|
| 32 | + call_user_func(array($class, $method), $parameters); |
|
| 33 | + } |
|
| 34 | + } |
|
| 35 | 35 | } |
@@ -26,67 +26,67 @@ |
||
| 26 | 26 | use OCP\Settings\IIconSection; |
| 27 | 27 | |
| 28 | 28 | class Section implements IIconSection { |
| 29 | - /** @var string */ |
|
| 30 | - private $id; |
|
| 31 | - /** @var string */ |
|
| 32 | - private $name; |
|
| 33 | - /** @var int */ |
|
| 34 | - private $priority; |
|
| 35 | - /** @var string */ |
|
| 36 | - private $icon; |
|
| 29 | + /** @var string */ |
|
| 30 | + private $id; |
|
| 31 | + /** @var string */ |
|
| 32 | + private $name; |
|
| 33 | + /** @var int */ |
|
| 34 | + private $priority; |
|
| 35 | + /** @var string */ |
|
| 36 | + private $icon; |
|
| 37 | 37 | |
| 38 | - /** |
|
| 39 | - * @param string $id |
|
| 40 | - * @param string $name |
|
| 41 | - * @param int $priority |
|
| 42 | - * @param string $icon |
|
| 43 | - */ |
|
| 44 | - public function __construct($id, $name, $priority, $icon = '') { |
|
| 45 | - $this->id = $id; |
|
| 46 | - $this->name = $name; |
|
| 47 | - $this->priority = $priority; |
|
| 48 | - $this->icon = $icon; |
|
| 49 | - } |
|
| 38 | + /** |
|
| 39 | + * @param string $id |
|
| 40 | + * @param string $name |
|
| 41 | + * @param int $priority |
|
| 42 | + * @param string $icon |
|
| 43 | + */ |
|
| 44 | + public function __construct($id, $name, $priority, $icon = '') { |
|
| 45 | + $this->id = $id; |
|
| 46 | + $this->name = $name; |
|
| 47 | + $this->priority = $priority; |
|
| 48 | + $this->icon = $icon; |
|
| 49 | + } |
|
| 50 | 50 | |
| 51 | - /** |
|
| 52 | - * returns the ID of the section. It is supposed to be a lower case string, |
|
| 53 | - * e.g. 'ldap' |
|
| 54 | - * |
|
| 55 | - * @returns string |
|
| 56 | - */ |
|
| 57 | - public function getID() { |
|
| 58 | - return $this->id; |
|
| 59 | - } |
|
| 51 | + /** |
|
| 52 | + * returns the ID of the section. It is supposed to be a lower case string, |
|
| 53 | + * e.g. 'ldap' |
|
| 54 | + * |
|
| 55 | + * @returns string |
|
| 56 | + */ |
|
| 57 | + public function getID() { |
|
| 58 | + return $this->id; |
|
| 59 | + } |
|
| 60 | 60 | |
| 61 | - /** |
|
| 62 | - * returns the translated name as it should be displayed, e.g. 'LDAP / AD |
|
| 63 | - * integration'. Use the L10N service to translate it. |
|
| 64 | - * |
|
| 65 | - * @return string |
|
| 66 | - */ |
|
| 67 | - public function getName() { |
|
| 68 | - return $this->name; |
|
| 69 | - } |
|
| 61 | + /** |
|
| 62 | + * returns the translated name as it should be displayed, e.g. 'LDAP / AD |
|
| 63 | + * integration'. Use the L10N service to translate it. |
|
| 64 | + * |
|
| 65 | + * @return string |
|
| 66 | + */ |
|
| 67 | + public function getName() { |
|
| 68 | + return $this->name; |
|
| 69 | + } |
|
| 70 | 70 | |
| 71 | - /** |
|
| 72 | - * @return int whether the form should be rather on the top or bottom of |
|
| 73 | - * the settings navigation. The sections are arranged in ascending order of |
|
| 74 | - * the priority values. It is required to return a value between 0 and 99. |
|
| 75 | - * |
|
| 76 | - * E.g.: 70 |
|
| 77 | - */ |
|
| 78 | - public function getPriority() { |
|
| 79 | - return $this->priority; |
|
| 80 | - } |
|
| 71 | + /** |
|
| 72 | + * @return int whether the form should be rather on the top or bottom of |
|
| 73 | + * the settings navigation. The sections are arranged in ascending order of |
|
| 74 | + * the priority values. It is required to return a value between 0 and 99. |
|
| 75 | + * |
|
| 76 | + * E.g.: 70 |
|
| 77 | + */ |
|
| 78 | + public function getPriority() { |
|
| 79 | + return $this->priority; |
|
| 80 | + } |
|
| 81 | 81 | |
| 82 | - /** |
|
| 83 | - * returns the relative path to an 16*16 icon describing the section. |
|
| 84 | - * e.g. '/core/img/places/files.svg' |
|
| 85 | - * |
|
| 86 | - * @returns string |
|
| 87 | - * @since 12 |
|
| 88 | - */ |
|
| 89 | - public function getIcon() { |
|
| 90 | - return $this->icon; |
|
| 91 | - } |
|
| 82 | + /** |
|
| 83 | + * returns the relative path to an 16*16 icon describing the section. |
|
| 84 | + * e.g. '/core/img/places/files.svg' |
|
| 85 | + * |
|
| 86 | + * @returns string |
|
| 87 | + * @since 12 |
|
| 88 | + */ |
|
| 89 | + public function getIcon() { |
|
| 90 | + return $this->icon; |
|
| 91 | + } |
|
| 92 | 92 | } |
@@ -46,7 +46,7 @@ discard block |
||
| 46 | 46 | private $manager; |
| 47 | 47 | |
| 48 | 48 | public function __construct(Manager $manager = null) { |
| 49 | - if($manager !== null) { |
|
| 49 | + if ($manager !== null) { |
|
| 50 | 50 | $this->manager = $manager; |
| 51 | 51 | } else { |
| 52 | 52 | // fix DI for Jobs |
@@ -62,7 +62,7 @@ discard block |
||
| 62 | 62 | */ |
| 63 | 63 | public function execute($jobList, ILogger $logger = null) { |
| 64 | 64 | // add an interval of 15 mins |
| 65 | - $this->setInterval(15*60); |
|
| 65 | + $this->setInterval(15 * 60); |
|
| 66 | 66 | |
| 67 | 67 | $this->jobList = $jobList; |
| 68 | 68 | $this->logger = $logger; |
@@ -36,56 +36,56 @@ |
||
| 36 | 36 | */ |
| 37 | 37 | class RemoveOrphaned extends TimedJob { |
| 38 | 38 | |
| 39 | - /** @var IJobList */ |
|
| 40 | - private $jobList; |
|
| 39 | + /** @var IJobList */ |
|
| 40 | + private $jobList; |
|
| 41 | 41 | |
| 42 | - /** @var ILogger */ |
|
| 43 | - private $logger; |
|
| 42 | + /** @var ILogger */ |
|
| 43 | + private $logger; |
|
| 44 | 44 | |
| 45 | - /** @var Manager */ |
|
| 46 | - private $manager; |
|
| 45 | + /** @var Manager */ |
|
| 46 | + private $manager; |
|
| 47 | 47 | |
| 48 | - public function __construct(Manager $manager = null) { |
|
| 49 | - if($manager !== null) { |
|
| 50 | - $this->manager = $manager; |
|
| 51 | - } else { |
|
| 52 | - // fix DI for Jobs |
|
| 53 | - $this->manager = \OC::$server->getSettingsManager(); |
|
| 54 | - } |
|
| 55 | - } |
|
| 48 | + public function __construct(Manager $manager = null) { |
|
| 49 | + if($manager !== null) { |
|
| 50 | + $this->manager = $manager; |
|
| 51 | + } else { |
|
| 52 | + // fix DI for Jobs |
|
| 53 | + $this->manager = \OC::$server->getSettingsManager(); |
|
| 54 | + } |
|
| 55 | + } |
|
| 56 | 56 | |
| 57 | - /** |
|
| 58 | - * run the job, then remove it from the job list |
|
| 59 | - * |
|
| 60 | - * @param JobList $jobList |
|
| 61 | - * @param ILogger|null $logger |
|
| 62 | - */ |
|
| 63 | - public function execute($jobList, ILogger $logger = null) { |
|
| 64 | - // add an interval of 15 mins |
|
| 65 | - $this->setInterval(15*60); |
|
| 57 | + /** |
|
| 58 | + * run the job, then remove it from the job list |
|
| 59 | + * |
|
| 60 | + * @param JobList $jobList |
|
| 61 | + * @param ILogger|null $logger |
|
| 62 | + */ |
|
| 63 | + public function execute($jobList, ILogger $logger = null) { |
|
| 64 | + // add an interval of 15 mins |
|
| 65 | + $this->setInterval(15*60); |
|
| 66 | 66 | |
| 67 | - $this->jobList = $jobList; |
|
| 68 | - $this->logger = $logger; |
|
| 69 | - parent::execute($jobList, $logger); |
|
| 70 | - } |
|
| 67 | + $this->jobList = $jobList; |
|
| 68 | + $this->logger = $logger; |
|
| 69 | + parent::execute($jobList, $logger); |
|
| 70 | + } |
|
| 71 | 71 | |
| 72 | - /** |
|
| 73 | - * @param array $argument |
|
| 74 | - * @throws \Exception |
|
| 75 | - * @throws \OC\NeedsUpdateException |
|
| 76 | - */ |
|
| 77 | - protected function run($argument) { |
|
| 78 | - try { |
|
| 79 | - \OC_App::loadApps(); |
|
| 80 | - } catch (NeedsUpdateException $ex) { |
|
| 81 | - // only run when apps are up to date |
|
| 82 | - return; |
|
| 83 | - } |
|
| 72 | + /** |
|
| 73 | + * @param array $argument |
|
| 74 | + * @throws \Exception |
|
| 75 | + * @throws \OC\NeedsUpdateException |
|
| 76 | + */ |
|
| 77 | + protected function run($argument) { |
|
| 78 | + try { |
|
| 79 | + \OC_App::loadApps(); |
|
| 80 | + } catch (NeedsUpdateException $ex) { |
|
| 81 | + // only run when apps are up to date |
|
| 82 | + return; |
|
| 83 | + } |
|
| 84 | 84 | |
| 85 | - $this->manager->checkForOrphanedClassNames(); |
|
| 85 | + $this->manager->checkForOrphanedClassNames(); |
|
| 86 | 86 | |
| 87 | - // remove the job once executed successfully |
|
| 88 | - $this->jobList->remove($this); |
|
| 89 | - } |
|
| 87 | + // remove the job once executed successfully |
|
| 88 | + $this->jobList->remove($this); |
|
| 89 | + } |
|
| 90 | 90 | |
| 91 | 91 | } |
@@ -28,105 +28,105 @@ |
||
| 28 | 28 | use ZipStreamer\ZipStreamer; |
| 29 | 29 | |
| 30 | 30 | class Streamer { |
| 31 | - // array of regexp. Matching user agents will get tar instead of zip |
|
| 32 | - private $preferTarFor = [ '/macintosh|mac os x/i' ]; |
|
| 31 | + // array of regexp. Matching user agents will get tar instead of zip |
|
| 32 | + private $preferTarFor = [ '/macintosh|mac os x/i' ]; |
|
| 33 | 33 | |
| 34 | - // streamer instance |
|
| 35 | - private $streamerInstance; |
|
| 34 | + // streamer instance |
|
| 35 | + private $streamerInstance; |
|
| 36 | 36 | |
| 37 | - public function __construct(){ |
|
| 38 | - /** @var \OCP\IRequest */ |
|
| 39 | - $request = \OC::$server->getRequest(); |
|
| 37 | + public function __construct(){ |
|
| 38 | + /** @var \OCP\IRequest */ |
|
| 39 | + $request = \OC::$server->getRequest(); |
|
| 40 | 40 | |
| 41 | - if ($request->isUserAgent($this->preferTarFor)) { |
|
| 42 | - $this->streamerInstance = new TarStreamer(); |
|
| 43 | - } else { |
|
| 44 | - $this->streamerInstance = new ZipStreamer(['zip64' => PHP_INT_SIZE !== 4]); |
|
| 45 | - } |
|
| 46 | - } |
|
| 41 | + if ($request->isUserAgent($this->preferTarFor)) { |
|
| 42 | + $this->streamerInstance = new TarStreamer(); |
|
| 43 | + } else { |
|
| 44 | + $this->streamerInstance = new ZipStreamer(['zip64' => PHP_INT_SIZE !== 4]); |
|
| 45 | + } |
|
| 46 | + } |
|
| 47 | 47 | |
| 48 | - /** |
|
| 49 | - * Send HTTP headers |
|
| 50 | - * @param string $name |
|
| 51 | - */ |
|
| 52 | - public function sendHeaders($name){ |
|
| 53 | - $extension = $this->streamerInstance instanceof ZipStreamer ? '.zip' : '.tar'; |
|
| 54 | - $fullName = $name . $extension; |
|
| 55 | - $this->streamerInstance->sendHeaders($fullName); |
|
| 56 | - } |
|
| 48 | + /** |
|
| 49 | + * Send HTTP headers |
|
| 50 | + * @param string $name |
|
| 51 | + */ |
|
| 52 | + public function sendHeaders($name){ |
|
| 53 | + $extension = $this->streamerInstance instanceof ZipStreamer ? '.zip' : '.tar'; |
|
| 54 | + $fullName = $name . $extension; |
|
| 55 | + $this->streamerInstance->sendHeaders($fullName); |
|
| 56 | + } |
|
| 57 | 57 | |
| 58 | - /** |
|
| 59 | - * Stream directory recursively |
|
| 60 | - * @param string $dir |
|
| 61 | - * @param string $internalDir |
|
| 62 | - */ |
|
| 63 | - public function addDirRecursive($dir, $internalDir='') { |
|
| 64 | - $dirname = basename($dir); |
|
| 65 | - $rootDir = $internalDir . $dirname; |
|
| 66 | - if (!empty($rootDir)) { |
|
| 67 | - $this->streamerInstance->addEmptyDir($rootDir); |
|
| 68 | - } |
|
| 69 | - $internalDir .= $dirname . '/'; |
|
| 70 | - // prevent absolute dirs |
|
| 71 | - $internalDir = ltrim($internalDir, '/'); |
|
| 58 | + /** |
|
| 59 | + * Stream directory recursively |
|
| 60 | + * @param string $dir |
|
| 61 | + * @param string $internalDir |
|
| 62 | + */ |
|
| 63 | + public function addDirRecursive($dir, $internalDir='') { |
|
| 64 | + $dirname = basename($dir); |
|
| 65 | + $rootDir = $internalDir . $dirname; |
|
| 66 | + if (!empty($rootDir)) { |
|
| 67 | + $this->streamerInstance->addEmptyDir($rootDir); |
|
| 68 | + } |
|
| 69 | + $internalDir .= $dirname . '/'; |
|
| 70 | + // prevent absolute dirs |
|
| 71 | + $internalDir = ltrim($internalDir, '/'); |
|
| 72 | 72 | |
| 73 | - $files= \OC\Files\Filesystem::getDirectoryContent($dir); |
|
| 74 | - foreach($files as $file) { |
|
| 75 | - $filename = $file['name']; |
|
| 76 | - $file = $dir . '/' . $filename; |
|
| 77 | - if(\OC\Files\Filesystem::is_file($file)) { |
|
| 78 | - $filesize = \OC\Files\Filesystem::filesize($file); |
|
| 79 | - $fileTime = \OC\Files\Filesystem::filemtime($file); |
|
| 80 | - $fh = \OC\Files\Filesystem::fopen($file, 'r'); |
|
| 81 | - $this->addFileFromStream($fh, $internalDir . $filename, $filesize, $fileTime); |
|
| 82 | - fclose($fh); |
|
| 83 | - }elseif(\OC\Files\Filesystem::is_dir($file)) { |
|
| 84 | - $this->addDirRecursive($file, $internalDir); |
|
| 85 | - } |
|
| 86 | - } |
|
| 87 | - } |
|
| 73 | + $files= \OC\Files\Filesystem::getDirectoryContent($dir); |
|
| 74 | + foreach($files as $file) { |
|
| 75 | + $filename = $file['name']; |
|
| 76 | + $file = $dir . '/' . $filename; |
|
| 77 | + if(\OC\Files\Filesystem::is_file($file)) { |
|
| 78 | + $filesize = \OC\Files\Filesystem::filesize($file); |
|
| 79 | + $fileTime = \OC\Files\Filesystem::filemtime($file); |
|
| 80 | + $fh = \OC\Files\Filesystem::fopen($file, 'r'); |
|
| 81 | + $this->addFileFromStream($fh, $internalDir . $filename, $filesize, $fileTime); |
|
| 82 | + fclose($fh); |
|
| 83 | + }elseif(\OC\Files\Filesystem::is_dir($file)) { |
|
| 84 | + $this->addDirRecursive($file, $internalDir); |
|
| 85 | + } |
|
| 86 | + } |
|
| 87 | + } |
|
| 88 | 88 | |
| 89 | - /** |
|
| 90 | - * Add a file to the archive at the specified location and file name. |
|
| 91 | - * |
|
| 92 | - * @param string $stream Stream to read data from |
|
| 93 | - * @param string $internalName Filepath and name to be used in the archive. |
|
| 94 | - * @param int $size Filesize |
|
| 95 | - * @param int|bool $time File mtime as int, or false |
|
| 96 | - * @return bool $success |
|
| 97 | - */ |
|
| 98 | - public function addFileFromStream($stream, $internalName, $size, $time) { |
|
| 99 | - $options = []; |
|
| 100 | - if ($time) { |
|
| 101 | - $options = [ |
|
| 102 | - 'timestamp' => $time |
|
| 103 | - ]; |
|
| 104 | - } |
|
| 89 | + /** |
|
| 90 | + * Add a file to the archive at the specified location and file name. |
|
| 91 | + * |
|
| 92 | + * @param string $stream Stream to read data from |
|
| 93 | + * @param string $internalName Filepath and name to be used in the archive. |
|
| 94 | + * @param int $size Filesize |
|
| 95 | + * @param int|bool $time File mtime as int, or false |
|
| 96 | + * @return bool $success |
|
| 97 | + */ |
|
| 98 | + public function addFileFromStream($stream, $internalName, $size, $time) { |
|
| 99 | + $options = []; |
|
| 100 | + if ($time) { |
|
| 101 | + $options = [ |
|
| 102 | + 'timestamp' => $time |
|
| 103 | + ]; |
|
| 104 | + } |
|
| 105 | 105 | |
| 106 | - if ($this->streamerInstance instanceof ZipStreamer) { |
|
| 107 | - return $this->streamerInstance->addFileFromStream($stream, $internalName, $options); |
|
| 108 | - } else { |
|
| 109 | - return $this->streamerInstance->addFileFromStream($stream, $internalName, $size, $options); |
|
| 110 | - } |
|
| 111 | - } |
|
| 106 | + if ($this->streamerInstance instanceof ZipStreamer) { |
|
| 107 | + return $this->streamerInstance->addFileFromStream($stream, $internalName, $options); |
|
| 108 | + } else { |
|
| 109 | + return $this->streamerInstance->addFileFromStream($stream, $internalName, $size, $options); |
|
| 110 | + } |
|
| 111 | + } |
|
| 112 | 112 | |
| 113 | - /** |
|
| 114 | - * Add an empty directory entry to the archive. |
|
| 115 | - * |
|
| 116 | - * @param string $dirName Directory Path and name to be added to the archive. |
|
| 117 | - * @return bool $success |
|
| 118 | - */ |
|
| 119 | - public function addEmptyDir($dirName){ |
|
| 120 | - return $this->streamerInstance->addEmptyDir($dirName); |
|
| 121 | - } |
|
| 113 | + /** |
|
| 114 | + * Add an empty directory entry to the archive. |
|
| 115 | + * |
|
| 116 | + * @param string $dirName Directory Path and name to be added to the archive. |
|
| 117 | + * @return bool $success |
|
| 118 | + */ |
|
| 119 | + public function addEmptyDir($dirName){ |
|
| 120 | + return $this->streamerInstance->addEmptyDir($dirName); |
|
| 121 | + } |
|
| 122 | 122 | |
| 123 | - /** |
|
| 124 | - * Close the archive. |
|
| 125 | - * A closed archive can no longer have new files added to it. After |
|
| 126 | - * closing, the file is completely written to the output stream. |
|
| 127 | - * @return bool $success |
|
| 128 | - */ |
|
| 129 | - public function finalize(){ |
|
| 130 | - return $this->streamerInstance->finalize(); |
|
| 131 | - } |
|
| 123 | + /** |
|
| 124 | + * Close the archive. |
|
| 125 | + * A closed archive can no longer have new files added to it. After |
|
| 126 | + * closing, the file is completely written to the output stream. |
|
| 127 | + * @return bool $success |
|
| 128 | + */ |
|
| 129 | + public function finalize(){ |
|
| 130 | + return $this->streamerInstance->finalize(); |
|
| 131 | + } |
|
| 132 | 132 | } |
@@ -29,12 +29,12 @@ discard block |
||
| 29 | 29 | |
| 30 | 30 | class Streamer { |
| 31 | 31 | // array of regexp. Matching user agents will get tar instead of zip |
| 32 | - private $preferTarFor = [ '/macintosh|mac os x/i' ]; |
|
| 32 | + private $preferTarFor = ['/macintosh|mac os x/i']; |
|
| 33 | 33 | |
| 34 | 34 | // streamer instance |
| 35 | 35 | private $streamerInstance; |
| 36 | 36 | |
| 37 | - public function __construct(){ |
|
| 37 | + public function __construct() { |
|
| 38 | 38 | /** @var \OCP\IRequest */ |
| 39 | 39 | $request = \OC::$server->getRequest(); |
| 40 | 40 | |
@@ -49,9 +49,9 @@ discard block |
||
| 49 | 49 | * Send HTTP headers |
| 50 | 50 | * @param string $name |
| 51 | 51 | */ |
| 52 | - public function sendHeaders($name){ |
|
| 52 | + public function sendHeaders($name) { |
|
| 53 | 53 | $extension = $this->streamerInstance instanceof ZipStreamer ? '.zip' : '.tar'; |
| 54 | - $fullName = $name . $extension; |
|
| 54 | + $fullName = $name.$extension; |
|
| 55 | 55 | $this->streamerInstance->sendHeaders($fullName); |
| 56 | 56 | } |
| 57 | 57 | |
@@ -60,27 +60,27 @@ discard block |
||
| 60 | 60 | * @param string $dir |
| 61 | 61 | * @param string $internalDir |
| 62 | 62 | */ |
| 63 | - public function addDirRecursive($dir, $internalDir='') { |
|
| 63 | + public function addDirRecursive($dir, $internalDir = '') { |
|
| 64 | 64 | $dirname = basename($dir); |
| 65 | - $rootDir = $internalDir . $dirname; |
|
| 65 | + $rootDir = $internalDir.$dirname; |
|
| 66 | 66 | if (!empty($rootDir)) { |
| 67 | 67 | $this->streamerInstance->addEmptyDir($rootDir); |
| 68 | 68 | } |
| 69 | - $internalDir .= $dirname . '/'; |
|
| 69 | + $internalDir .= $dirname.'/'; |
|
| 70 | 70 | // prevent absolute dirs |
| 71 | 71 | $internalDir = ltrim($internalDir, '/'); |
| 72 | 72 | |
| 73 | - $files= \OC\Files\Filesystem::getDirectoryContent($dir); |
|
| 74 | - foreach($files as $file) { |
|
| 73 | + $files = \OC\Files\Filesystem::getDirectoryContent($dir); |
|
| 74 | + foreach ($files as $file) { |
|
| 75 | 75 | $filename = $file['name']; |
| 76 | - $file = $dir . '/' . $filename; |
|
| 77 | - if(\OC\Files\Filesystem::is_file($file)) { |
|
| 76 | + $file = $dir.'/'.$filename; |
|
| 77 | + if (\OC\Files\Filesystem::is_file($file)) { |
|
| 78 | 78 | $filesize = \OC\Files\Filesystem::filesize($file); |
| 79 | 79 | $fileTime = \OC\Files\Filesystem::filemtime($file); |
| 80 | 80 | $fh = \OC\Files\Filesystem::fopen($file, 'r'); |
| 81 | - $this->addFileFromStream($fh, $internalDir . $filename, $filesize, $fileTime); |
|
| 81 | + $this->addFileFromStream($fh, $internalDir.$filename, $filesize, $fileTime); |
|
| 82 | 82 | fclose($fh); |
| 83 | - }elseif(\OC\Files\Filesystem::is_dir($file)) { |
|
| 83 | + }elseif (\OC\Files\Filesystem::is_dir($file)) { |
|
| 84 | 84 | $this->addDirRecursive($file, $internalDir); |
| 85 | 85 | } |
| 86 | 86 | } |
@@ -116,7 +116,7 @@ discard block |
||
| 116 | 116 | * @param string $dirName Directory Path and name to be added to the archive. |
| 117 | 117 | * @return bool $success |
| 118 | 118 | */ |
| 119 | - public function addEmptyDir($dirName){ |
|
| 119 | + public function addEmptyDir($dirName) { |
|
| 120 | 120 | return $this->streamerInstance->addEmptyDir($dirName); |
| 121 | 121 | } |
| 122 | 122 | |
@@ -126,7 +126,7 @@ discard block |
||
| 126 | 126 | * closing, the file is completely written to the output stream. |
| 127 | 127 | * @return bool $success |
| 128 | 128 | */ |
| 129 | - public function finalize(){ |
|
| 129 | + public function finalize() { |
|
| 130 | 130 | return $this->streamerInstance->finalize(); |
| 131 | 131 | } |
| 132 | 132 | } |
@@ -80,7 +80,7 @@ |
||
| 80 | 80 | $fh = \OC\Files\Filesystem::fopen($file, 'r'); |
| 81 | 81 | $this->addFileFromStream($fh, $internalDir . $filename, $filesize, $fileTime); |
| 82 | 82 | fclose($fh); |
| 83 | - }elseif(\OC\Files\Filesystem::is_dir($file)) { |
|
| 83 | + } elseif(\OC\Files\Filesystem::is_dir($file)) { |
|
| 84 | 84 | $this->addDirRecursive($file, $internalDir); |
| 85 | 85 | } |
| 86 | 86 | } |
@@ -34,158 +34,158 @@ |
||
| 34 | 34 | use \OCP\ILogger; |
| 35 | 35 | |
| 36 | 36 | class Factory implements ICacheFactory { |
| 37 | - const NULL_CACHE = '\\OC\\Memcache\\NullCache'; |
|
| 38 | - |
|
| 39 | - /** |
|
| 40 | - * @var string $globalPrefix |
|
| 41 | - */ |
|
| 42 | - private $globalPrefix; |
|
| 43 | - |
|
| 44 | - /** |
|
| 45 | - * @var ILogger $logger |
|
| 46 | - */ |
|
| 47 | - private $logger; |
|
| 48 | - |
|
| 49 | - /** |
|
| 50 | - * @var string $localCacheClass |
|
| 51 | - */ |
|
| 52 | - private $localCacheClass; |
|
| 53 | - |
|
| 54 | - /** |
|
| 55 | - * @var string $distributedCacheClass |
|
| 56 | - */ |
|
| 57 | - private $distributedCacheClass; |
|
| 58 | - |
|
| 59 | - /** |
|
| 60 | - * @var string $lockingCacheClass |
|
| 61 | - */ |
|
| 62 | - private $lockingCacheClass; |
|
| 63 | - |
|
| 64 | - /** |
|
| 65 | - * @param string $globalPrefix |
|
| 66 | - * @param ILogger $logger |
|
| 67 | - * @param string|null $localCacheClass |
|
| 68 | - * @param string|null $distributedCacheClass |
|
| 69 | - * @param string|null $lockingCacheClass |
|
| 70 | - */ |
|
| 71 | - public function __construct($globalPrefix, ILogger $logger, |
|
| 72 | - $localCacheClass = null, $distributedCacheClass = null, $lockingCacheClass = null) |
|
| 73 | - { |
|
| 74 | - $this->logger = $logger; |
|
| 75 | - $this->globalPrefix = $globalPrefix; |
|
| 76 | - |
|
| 77 | - if (!$localCacheClass) { |
|
| 78 | - $localCacheClass = self::NULL_CACHE; |
|
| 79 | - } |
|
| 80 | - if (!$distributedCacheClass) { |
|
| 81 | - $distributedCacheClass = $localCacheClass; |
|
| 82 | - } |
|
| 83 | - |
|
| 84 | - $missingCacheMessage = 'Memcache {class} not available for {use} cache'; |
|
| 85 | - $missingCacheHint = 'Is the matching PHP module installed and enabled?'; |
|
| 86 | - if (!class_exists($localCacheClass) || !$localCacheClass::isAvailable()) { |
|
| 87 | - if (\OC::$CLI && !defined('PHPUNIT_RUN')) { |
|
| 88 | - // CLI should not hard-fail on broken memcache |
|
| 89 | - $this->logger->info($missingCacheMessage, [ |
|
| 90 | - 'class' => $localCacheClass, |
|
| 91 | - 'use' => 'local', |
|
| 92 | - 'app' => 'cli' |
|
| 93 | - ]); |
|
| 94 | - $localCacheClass = self::NULL_CACHE; |
|
| 95 | - } else { |
|
| 96 | - throw new \OC\HintException(strtr($missingCacheMessage, [ |
|
| 97 | - '{class}' => $localCacheClass, '{use}' => 'local' |
|
| 98 | - ]), $missingCacheHint); |
|
| 99 | - } |
|
| 100 | - } |
|
| 101 | - if (!class_exists($distributedCacheClass) || !$distributedCacheClass::isAvailable()) { |
|
| 102 | - if (\OC::$CLI && !defined('PHPUNIT_RUN')) { |
|
| 103 | - // CLI should not hard-fail on broken memcache |
|
| 104 | - $this->logger->info($missingCacheMessage, [ |
|
| 105 | - 'class' => $distributedCacheClass, |
|
| 106 | - 'use' => 'distributed', |
|
| 107 | - 'app' => 'cli' |
|
| 108 | - ]); |
|
| 109 | - $distributedCacheClass = self::NULL_CACHE; |
|
| 110 | - } else { |
|
| 111 | - throw new \OC\HintException(strtr($missingCacheMessage, [ |
|
| 112 | - '{class}' => $distributedCacheClass, '{use}' => 'distributed' |
|
| 113 | - ]), $missingCacheHint); |
|
| 114 | - } |
|
| 115 | - } |
|
| 116 | - if (!($lockingCacheClass && class_exists($distributedCacheClass) && $lockingCacheClass::isAvailable())) { |
|
| 117 | - // don't fallback since the fallback might not be suitable for storing lock |
|
| 118 | - $lockingCacheClass = self::NULL_CACHE; |
|
| 119 | - } |
|
| 120 | - |
|
| 121 | - $this->localCacheClass = $localCacheClass; |
|
| 122 | - $this->distributedCacheClass = $distributedCacheClass; |
|
| 123 | - $this->lockingCacheClass = $lockingCacheClass; |
|
| 124 | - } |
|
| 125 | - |
|
| 126 | - /** |
|
| 127 | - * create a cache instance for storing locks |
|
| 128 | - * |
|
| 129 | - * @param string $prefix |
|
| 130 | - * @return \OCP\IMemcache |
|
| 131 | - */ |
|
| 132 | - public function createLocking($prefix = '') { |
|
| 133 | - return new $this->lockingCacheClass($this->globalPrefix . '/' . $prefix); |
|
| 134 | - } |
|
| 135 | - |
|
| 136 | - /** |
|
| 137 | - * create a distributed cache instance |
|
| 138 | - * |
|
| 139 | - * @param string $prefix |
|
| 140 | - * @return \OC\Memcache\Cache |
|
| 141 | - */ |
|
| 142 | - public function createDistributed($prefix = '') { |
|
| 143 | - return new $this->distributedCacheClass($this->globalPrefix . '/' . $prefix); |
|
| 144 | - } |
|
| 145 | - |
|
| 146 | - /** |
|
| 147 | - * create a local cache instance |
|
| 148 | - * |
|
| 149 | - * @param string $prefix |
|
| 150 | - * @return \OC\Memcache\Cache |
|
| 151 | - */ |
|
| 152 | - public function createLocal($prefix = '') { |
|
| 153 | - return new $this->localCacheClass($this->globalPrefix . '/' . $prefix); |
|
| 154 | - } |
|
| 155 | - |
|
| 156 | - /** |
|
| 157 | - * @see \OC\Memcache\Factory::createDistributed() |
|
| 158 | - * @param string $prefix |
|
| 159 | - * @return \OC\Memcache\Cache |
|
| 160 | - */ |
|
| 161 | - public function create($prefix = '') { |
|
| 162 | - return $this->createDistributed($prefix); |
|
| 163 | - } |
|
| 164 | - |
|
| 165 | - /** |
|
| 166 | - * check memcache availability |
|
| 167 | - * |
|
| 168 | - * @return bool |
|
| 169 | - */ |
|
| 170 | - public function isAvailable() { |
|
| 171 | - return ($this->distributedCacheClass !== self::NULL_CACHE); |
|
| 172 | - } |
|
| 173 | - |
|
| 174 | - /** |
|
| 175 | - * @see \OC\Memcache\Factory::createLocal() |
|
| 176 | - * @param string $prefix |
|
| 177 | - * @return Cache |
|
| 178 | - */ |
|
| 179 | - public function createLowLatency($prefix = '') { |
|
| 180 | - return $this->createLocal($prefix); |
|
| 181 | - } |
|
| 182 | - |
|
| 183 | - /** |
|
| 184 | - * check local memcache availability |
|
| 185 | - * |
|
| 186 | - * @return bool |
|
| 187 | - */ |
|
| 188 | - public function isAvailableLowLatency() { |
|
| 189 | - return ($this->localCacheClass !== self::NULL_CACHE); |
|
| 190 | - } |
|
| 37 | + const NULL_CACHE = '\\OC\\Memcache\\NullCache'; |
|
| 38 | + |
|
| 39 | + /** |
|
| 40 | + * @var string $globalPrefix |
|
| 41 | + */ |
|
| 42 | + private $globalPrefix; |
|
| 43 | + |
|
| 44 | + /** |
|
| 45 | + * @var ILogger $logger |
|
| 46 | + */ |
|
| 47 | + private $logger; |
|
| 48 | + |
|
| 49 | + /** |
|
| 50 | + * @var string $localCacheClass |
|
| 51 | + */ |
|
| 52 | + private $localCacheClass; |
|
| 53 | + |
|
| 54 | + /** |
|
| 55 | + * @var string $distributedCacheClass |
|
| 56 | + */ |
|
| 57 | + private $distributedCacheClass; |
|
| 58 | + |
|
| 59 | + /** |
|
| 60 | + * @var string $lockingCacheClass |
|
| 61 | + */ |
|
| 62 | + private $lockingCacheClass; |
|
| 63 | + |
|
| 64 | + /** |
|
| 65 | + * @param string $globalPrefix |
|
| 66 | + * @param ILogger $logger |
|
| 67 | + * @param string|null $localCacheClass |
|
| 68 | + * @param string|null $distributedCacheClass |
|
| 69 | + * @param string|null $lockingCacheClass |
|
| 70 | + */ |
|
| 71 | + public function __construct($globalPrefix, ILogger $logger, |
|
| 72 | + $localCacheClass = null, $distributedCacheClass = null, $lockingCacheClass = null) |
|
| 73 | + { |
|
| 74 | + $this->logger = $logger; |
|
| 75 | + $this->globalPrefix = $globalPrefix; |
|
| 76 | + |
|
| 77 | + if (!$localCacheClass) { |
|
| 78 | + $localCacheClass = self::NULL_CACHE; |
|
| 79 | + } |
|
| 80 | + if (!$distributedCacheClass) { |
|
| 81 | + $distributedCacheClass = $localCacheClass; |
|
| 82 | + } |
|
| 83 | + |
|
| 84 | + $missingCacheMessage = 'Memcache {class} not available for {use} cache'; |
|
| 85 | + $missingCacheHint = 'Is the matching PHP module installed and enabled?'; |
|
| 86 | + if (!class_exists($localCacheClass) || !$localCacheClass::isAvailable()) { |
|
| 87 | + if (\OC::$CLI && !defined('PHPUNIT_RUN')) { |
|
| 88 | + // CLI should not hard-fail on broken memcache |
|
| 89 | + $this->logger->info($missingCacheMessage, [ |
|
| 90 | + 'class' => $localCacheClass, |
|
| 91 | + 'use' => 'local', |
|
| 92 | + 'app' => 'cli' |
|
| 93 | + ]); |
|
| 94 | + $localCacheClass = self::NULL_CACHE; |
|
| 95 | + } else { |
|
| 96 | + throw new \OC\HintException(strtr($missingCacheMessage, [ |
|
| 97 | + '{class}' => $localCacheClass, '{use}' => 'local' |
|
| 98 | + ]), $missingCacheHint); |
|
| 99 | + } |
|
| 100 | + } |
|
| 101 | + if (!class_exists($distributedCacheClass) || !$distributedCacheClass::isAvailable()) { |
|
| 102 | + if (\OC::$CLI && !defined('PHPUNIT_RUN')) { |
|
| 103 | + // CLI should not hard-fail on broken memcache |
|
| 104 | + $this->logger->info($missingCacheMessage, [ |
|
| 105 | + 'class' => $distributedCacheClass, |
|
| 106 | + 'use' => 'distributed', |
|
| 107 | + 'app' => 'cli' |
|
| 108 | + ]); |
|
| 109 | + $distributedCacheClass = self::NULL_CACHE; |
|
| 110 | + } else { |
|
| 111 | + throw new \OC\HintException(strtr($missingCacheMessage, [ |
|
| 112 | + '{class}' => $distributedCacheClass, '{use}' => 'distributed' |
|
| 113 | + ]), $missingCacheHint); |
|
| 114 | + } |
|
| 115 | + } |
|
| 116 | + if (!($lockingCacheClass && class_exists($distributedCacheClass) && $lockingCacheClass::isAvailable())) { |
|
| 117 | + // don't fallback since the fallback might not be suitable for storing lock |
|
| 118 | + $lockingCacheClass = self::NULL_CACHE; |
|
| 119 | + } |
|
| 120 | + |
|
| 121 | + $this->localCacheClass = $localCacheClass; |
|
| 122 | + $this->distributedCacheClass = $distributedCacheClass; |
|
| 123 | + $this->lockingCacheClass = $lockingCacheClass; |
|
| 124 | + } |
|
| 125 | + |
|
| 126 | + /** |
|
| 127 | + * create a cache instance for storing locks |
|
| 128 | + * |
|
| 129 | + * @param string $prefix |
|
| 130 | + * @return \OCP\IMemcache |
|
| 131 | + */ |
|
| 132 | + public function createLocking($prefix = '') { |
|
| 133 | + return new $this->lockingCacheClass($this->globalPrefix . '/' . $prefix); |
|
| 134 | + } |
|
| 135 | + |
|
| 136 | + /** |
|
| 137 | + * create a distributed cache instance |
|
| 138 | + * |
|
| 139 | + * @param string $prefix |
|
| 140 | + * @return \OC\Memcache\Cache |
|
| 141 | + */ |
|
| 142 | + public function createDistributed($prefix = '') { |
|
| 143 | + return new $this->distributedCacheClass($this->globalPrefix . '/' . $prefix); |
|
| 144 | + } |
|
| 145 | + |
|
| 146 | + /** |
|
| 147 | + * create a local cache instance |
|
| 148 | + * |
|
| 149 | + * @param string $prefix |
|
| 150 | + * @return \OC\Memcache\Cache |
|
| 151 | + */ |
|
| 152 | + public function createLocal($prefix = '') { |
|
| 153 | + return new $this->localCacheClass($this->globalPrefix . '/' . $prefix); |
|
| 154 | + } |
|
| 155 | + |
|
| 156 | + /** |
|
| 157 | + * @see \OC\Memcache\Factory::createDistributed() |
|
| 158 | + * @param string $prefix |
|
| 159 | + * @return \OC\Memcache\Cache |
|
| 160 | + */ |
|
| 161 | + public function create($prefix = '') { |
|
| 162 | + return $this->createDistributed($prefix); |
|
| 163 | + } |
|
| 164 | + |
|
| 165 | + /** |
|
| 166 | + * check memcache availability |
|
| 167 | + * |
|
| 168 | + * @return bool |
|
| 169 | + */ |
|
| 170 | + public function isAvailable() { |
|
| 171 | + return ($this->distributedCacheClass !== self::NULL_CACHE); |
|
| 172 | + } |
|
| 173 | + |
|
| 174 | + /** |
|
| 175 | + * @see \OC\Memcache\Factory::createLocal() |
|
| 176 | + * @param string $prefix |
|
| 177 | + * @return Cache |
|
| 178 | + */ |
|
| 179 | + public function createLowLatency($prefix = '') { |
|
| 180 | + return $this->createLocal($prefix); |
|
| 181 | + } |
|
| 182 | + |
|
| 183 | + /** |
|
| 184 | + * check local memcache availability |
|
| 185 | + * |
|
| 186 | + * @return bool |
|
| 187 | + */ |
|
| 188 | + public function isAvailableLowLatency() { |
|
| 189 | + return ($this->localCacheClass !== self::NULL_CACHE); |
|
| 190 | + } |
|
| 191 | 191 | } |
@@ -130,7 +130,7 @@ discard block |
||
| 130 | 130 | * @return \OCP\IMemcache |
| 131 | 131 | */ |
| 132 | 132 | public function createLocking($prefix = '') { |
| 133 | - return new $this->lockingCacheClass($this->globalPrefix . '/' . $prefix); |
|
| 133 | + return new $this->lockingCacheClass($this->globalPrefix.'/'.$prefix); |
|
| 134 | 134 | } |
| 135 | 135 | |
| 136 | 136 | /** |
@@ -140,7 +140,7 @@ discard block |
||
| 140 | 140 | * @return \OC\Memcache\Cache |
| 141 | 141 | */ |
| 142 | 142 | public function createDistributed($prefix = '') { |
| 143 | - return new $this->distributedCacheClass($this->globalPrefix . '/' . $prefix); |
|
| 143 | + return new $this->distributedCacheClass($this->globalPrefix.'/'.$prefix); |
|
| 144 | 144 | } |
| 145 | 145 | |
| 146 | 146 | /** |
@@ -150,7 +150,7 @@ discard block |
||
| 150 | 150 | * @return \OC\Memcache\Cache |
| 151 | 151 | */ |
| 152 | 152 | public function createLocal($prefix = '') { |
| 153 | - return new $this->localCacheClass($this->globalPrefix . '/' . $prefix); |
|
| 153 | + return new $this->localCacheClass($this->globalPrefix.'/'.$prefix); |
|
| 154 | 154 | } |
| 155 | 155 | |
| 156 | 156 | /** |