nextcloud / server

lib/private/Archive/TAR.php

Indentation +331 added lines, -331 removed lines

@@ -36,355 +36,355 @@
 use Icewind\Streams\CallbackWrapper;
 
 class TAR extends Archive {
-	const PLAIN = 0;
-	const GZIP = 1;
-	const BZIP = 2;
+    const PLAIN = 0;
+    const GZIP = 1;
+    const BZIP = 2;
 
-	private $fileList;
-	private $cachedHeaders;
+    private $fileList;
+    private $cachedHeaders;
 
-	/**
-	 * @var \Archive_Tar tar
-	 */
-	private $tar = null;
-	private $path;
+    /**
+     * @var \Archive_Tar tar
+     */
+    private $tar = null;
+    private $path;
 
-	/**
-	 * @param string $source
-	 */
-	function __construct($source) {
-		$types = array(null, 'gz', 'bz2');
-		$this->path = $source;
-		$this->tar = new \Archive_Tar($source, $types[self::getTarType($source)]);
-	}
+    /**
+     * @param string $source
+     */
+    function __construct($source) {
+        $types = array(null, 'gz', 'bz2');
+        $this->path = $source;
+        $this->tar = new \Archive_Tar($source, $types[self::getTarType($source)]);
+    }
 
-	/**
-	 * try to detect the type of tar compression
-	 *
-	 * @param string $file
-	 * @return integer
-	 */
-	static public function getTarType($file) {
-		if (strpos($file, '.')) {
-			$extension = substr($file, strrpos($file, '.'));
-			switch ($extension) {
-				case '.gz':
-				case '.tgz':
-					return self::GZIP;
-				case '.bz':
-				case '.bz2':
-					return self::BZIP;
-				case '.tar':
-					return self::PLAIN;
-				default:
-					return self::PLAIN;
-			}
-		} else {
-			return self::PLAIN;
-		}
-	}
+    /**
+     * try to detect the type of tar compression
+     *
+     * @param string $file
+     * @return integer
+     */
+    static public function getTarType($file) {
+        if (strpos($file, '.')) {
+            $extension = substr($file, strrpos($file, '.'));
+            switch ($extension) {
+                case '.gz':
+                case '.tgz':
+                    return self::GZIP;
+                case '.bz':
+                case '.bz2':
+                    return self::BZIP;
+                case '.tar':
+                    return self::PLAIN;
+                default:
+                    return self::PLAIN;
+            }
+        } else {
+            return self::PLAIN;
+        }
+    }
 
-	/**
-	 * add an empty folder to the archive
-	 *
-	 * @param string $path
-	 * @return bool
-	 */
-	function addFolder($path) {
-		$tmpBase = \OC::$server->getTempManager()->getTemporaryFolder();
-		if (substr($path, -1, 1) != '/') {
-			$path .= '/';
-		}
-		if ($this->fileExists($path)) {
-			return false;
-		}
-		$parts = explode('/', $path);
-		$folder = $tmpBase;
-		foreach ($parts as $part) {
-			$folder .= '/' . $part;
-			if (!is_dir($folder)) {
-				mkdir($folder);
-			}
-		}
-		$result = $this->tar->addModify(array($tmpBase . $path), '', $tmpBase);
-		rmdir($tmpBase . $path);
-		$this->fileList = false;
-		$this->cachedHeaders = false;
-		return $result;
-	}
+    /**
+     * add an empty folder to the archive
+     *
+     * @param string $path
+     * @return bool
+     */
+    function addFolder($path) {
+        $tmpBase = \OC::$server->getTempManager()->getTemporaryFolder();
+        if (substr($path, -1, 1) != '/') {
+            $path .= '/';
+        }
+        if ($this->fileExists($path)) {
+            return false;
+        }
+        $parts = explode('/', $path);
+        $folder = $tmpBase;
+        foreach ($parts as $part) {
+            $folder .= '/' . $part;
+            if (!is_dir($folder)) {
+                mkdir($folder);
+            }
+        }
+        $result = $this->tar->addModify(array($tmpBase . $path), '', $tmpBase);
+        rmdir($tmpBase . $path);
+        $this->fileList = false;
+        $this->cachedHeaders = false;
+        return $result;
+    }
 
-	/**
-	 * add a file to the archive
-	 *
-	 * @param string $path
-	 * @param string $source either a local file or string data
-	 * @return bool
-	 */
-	function addFile($path, $source = '') {
-		if ($this->fileExists($path)) {
-			$this->remove($path);
-		}
-		if ($source and $source[0] == '/' and file_exists($source)) {
-			$source = file_get_contents($source);
-		}
-		$result = $this->tar->addString($path, $source);
-		$this->fileList = false;
-		$this->cachedHeaders = false;
-		return $result;
-	}
+    /**
+     * add a file to the archive
+     *
+     * @param string $path
+     * @param string $source either a local file or string data
+     * @return bool
+     */
+    function addFile($path, $source = '') {
+        if ($this->fileExists($path)) {
+            $this->remove($path);
+        }
+        if ($source and $source[0] == '/' and file_exists($source)) {
+            $source = file_get_contents($source);
+        }
+        $result = $this->tar->addString($path, $source);
+        $this->fileList = false;
+        $this->cachedHeaders = false;
+        return $result;
+    }
 
-	/**
-	 * rename a file or folder in the archive
-	 *
-	 * @param string $source
-	 * @param string $dest
-	 * @return bool
-	 */
-	function rename($source, $dest) {
-		//no proper way to delete, rename entire archive, rename file and remake archive
-		$tmp = \OCP\Files::tmpFolder();
-		$this->tar->extract($tmp);
-		rename($tmp . $source, $tmp . $dest);
-		$this->tar = null;
-		unlink($this->path);
-		$types = array(null, 'gz', 'bz');
-		$this->tar = new \Archive_Tar($this->path, $types[self::getTarType($this->path)]);
-		$this->tar->createModify(array($tmp), '', $tmp . '/');
-		$this->fileList = false;
-		$this->cachedHeaders = false;
-		return true;
-	}
+    /**
+     * rename a file or folder in the archive
+     *
+     * @param string $source
+     * @param string $dest
+     * @return bool
+     */
+    function rename($source, $dest) {
+        //no proper way to delete, rename entire archive, rename file and remake archive
+        $tmp = \OCP\Files::tmpFolder();
+        $this->tar->extract($tmp);
+        rename($tmp . $source, $tmp . $dest);
+        $this->tar = null;
+        unlink($this->path);
+        $types = array(null, 'gz', 'bz');
+        $this->tar = new \Archive_Tar($this->path, $types[self::getTarType($this->path)]);
+        $this->tar->createModify(array($tmp), '', $tmp . '/');
+        $this->fileList = false;
+        $this->cachedHeaders = false;
+        return true;
+    }
 
-	/**
-	 * @param string $file
-	 */
-	private function getHeader($file) {
-		if (!$this->cachedHeaders) {
-			$this->cachedHeaders = $this->tar->listContent();
-		}
-		foreach ($this->cachedHeaders as $header) {
-			if ($file == $header['filename']
-				or $file . '/' == $header['filename']
-				or '/' . $file . '/' == $header['filename']
-				or '/' . $file == $header['filename']
-			) {
-				return $header;
-			}
-		}
-		return null;
-	}
+    /**
+     * @param string $file
+     */
+    private function getHeader($file) {
+        if (!$this->cachedHeaders) {
+            $this->cachedHeaders = $this->tar->listContent();
+        }
+        foreach ($this->cachedHeaders as $header) {
+            if ($file == $header['filename']
+                or $file . '/' == $header['filename']
+                or '/' . $file . '/' == $header['filename']
+                or '/' . $file == $header['filename']
+            ) {
+                return $header;
+            }
+        }
+        return null;
+    }
 
-	/**
-	 * get the uncompressed size of a file in the archive
-	 *
-	 * @param string $path
-	 * @return int
-	 */
-	function filesize($path) {
-		$stat = $this->getHeader($path);
-		return $stat['size'];
-	}
+    /**
+     * get the uncompressed size of a file in the archive
+     *
+     * @param string $path
+     * @return int
+     */
+    function filesize($path) {
+        $stat = $this->getHeader($path);
+        return $stat['size'];
+    }
 
-	/**
-	 * get the last modified time of a file in the archive
-	 *
-	 * @param string $path
-	 * @return int
-	 */
-	function mtime($path) {
-		$stat = $this->getHeader($path);
-		return $stat['mtime'];
-	}
+    /**
+     * get the last modified time of a file in the archive
+     *
+     * @param string $path
+     * @return int
+     */
+    function mtime($path) {
+        $stat = $this->getHeader($path);
+        return $stat['mtime'];
+    }
 
-	/**
-	 * get the files in a folder
-	 *
-	 * @param string $path
-	 * @return array
-	 */
-	function getFolder($path) {
-		$files = $this->getFiles();
-		$folderContent = array();
-		$pathLength = strlen($path);
-		foreach ($files as $file) {
-			if ($file[0] == '/') {
-				$file = substr($file, 1);
-			}
-			if (substr($file, 0, $pathLength) == $path and $file != $path) {
-				$result = substr($file, $pathLength);
-				if ($pos = strpos($result, '/')) {
-					$result = substr($result, 0, $pos + 1);
-				}
-				if (array_search($result, $folderContent) === false) {
-					$folderContent[] = $result;
-				}
-			}
-		}
-		return $folderContent;
-	}
+    /**
+     * get the files in a folder
+     *
+     * @param string $path
+     * @return array
+     */
+    function getFolder($path) {
+        $files = $this->getFiles();
+        $folderContent = array();
+        $pathLength = strlen($path);
+        foreach ($files as $file) {
+            if ($file[0] == '/') {
+                $file = substr($file, 1);
+            }
+            if (substr($file, 0, $pathLength) == $path and $file != $path) {
+                $result = substr($file, $pathLength);
+                if ($pos = strpos($result, '/')) {
+                    $result = substr($result, 0, $pos + 1);
+                }
+                if (array_search($result, $folderContent) === false) {
+                    $folderContent[] = $result;
+                }
+            }
+        }
+        return $folderContent;
+    }
 
-	/**
-	 * get all files in the archive
-	 *
-	 * @return array
-	 */
-	function getFiles() {
-		if ($this->fileList) {
-			return $this->fileList;
-		}
-		if (!$this->cachedHeaders) {
-			$this->cachedHeaders = $this->tar->listContent();
-		}
-		$files = array();
-		foreach ($this->cachedHeaders as $header) {
-			$files[] = $header['filename'];
-		}
-		$this->fileList = $files;
-		return $files;
-	}
+    /**
+     * get all files in the archive
+     *
+     * @return array
+     */
+    function getFiles() {
+        if ($this->fileList) {
+            return $this->fileList;
+        }
+        if (!$this->cachedHeaders) {
+            $this->cachedHeaders = $this->tar->listContent();
+        }
+        $files = array();
+        foreach ($this->cachedHeaders as $header) {
+            $files[] = $header['filename'];
+        }
+        $this->fileList = $files;
+        return $files;
+    }
 
-	/**
-	 * get the content of a file
-	 *
-	 * @param string $path
-	 * @return string
-	 */
-	function getFile($path) {
-		return $this->tar->extractInString($path);
-	}
+    /**
+     * get the content of a file
+     *
+     * @param string $path
+     * @return string
+     */
+    function getFile($path) {
+        return $this->tar->extractInString($path);
+    }
 
-	/**
-	 * extract a single file from the archive
-	 *
-	 * @param string $path
-	 * @param string $dest
-	 * @return bool
-	 */
-	function extractFile($path, $dest) {
-		$tmp = \OCP\Files::tmpFolder();
-		if (!$this->fileExists($path)) {
-			return false;
-		}
-		if ($this->fileExists('/' . $path)) {
-			$success = $this->tar->extractList(array('/' . $path), $tmp);
-		} else {
-			$success = $this->tar->extractList(array($path), $tmp);
-		}
-		if ($success) {
-			rename($tmp . $path, $dest);
-		}
-		\OCP\Files::rmdirr($tmp);
-		return $success;
-	}
+    /**
+     * extract a single file from the archive
+     *
+     * @param string $path
+     * @param string $dest
+     * @return bool
+     */
+    function extractFile($path, $dest) {
+        $tmp = \OCP\Files::tmpFolder();
+        if (!$this->fileExists($path)) {
+            return false;
+        }
+        if ($this->fileExists('/' . $path)) {
+            $success = $this->tar->extractList(array('/' . $path), $tmp);
+        } else {
+            $success = $this->tar->extractList(array($path), $tmp);
+        }
+        if ($success) {
+            rename($tmp . $path, $dest);
+        }
+        \OCP\Files::rmdirr($tmp);
+        return $success;
+    }
 
-	/**
-	 * extract the archive
-	 *
-	 * @param string $dest
-	 * @return bool
-	 */
-	function extract($dest) {
-		return $this->tar->extract($dest);
-	}
+    /**
+     * extract the archive
+     *
+     * @param string $dest
+     * @return bool
+     */
+    function extract($dest) {
+        return $this->tar->extract($dest);
+    }
 
-	/**
-	 * check if a file or folder exists in the archive
-	 *
-	 * @param string $path
-	 * @return bool
-	 */
-	function fileExists($path) {
-		$files = $this->getFiles();
-		if ((array_search($path, $files) !== false) or (array_search($path . '/', $files) !== false)) {
-			return true;
-		} else {
-			$folderPath = $path;
-			if (substr($folderPath, -1, 1) != '/') {
-				$folderPath .= '/';
-			}
-			$pathLength = strlen($folderPath);
-			foreach ($files as $file) {
-				if (strlen($file) > $pathLength and substr($file, 0, $pathLength) == $folderPath) {
-					return true;
-				}
-			}
-		}
-		if ($path[0] != '/') { //not all programs agree on the use of a leading /
-			return $this->fileExists('/' . $path);
-		} else {
-			return false;
-		}
-	}
+    /**
+     * check if a file or folder exists in the archive
+     *
+     * @param string $path
+     * @return bool
+     */
+    function fileExists($path) {
+        $files = $this->getFiles();
+        if ((array_search($path, $files) !== false) or (array_search($path . '/', $files) !== false)) {
+            return true;
+        } else {
+            $folderPath = $path;
+            if (substr($folderPath, -1, 1) != '/') {
+                $folderPath .= '/';
+            }
+            $pathLength = strlen($folderPath);
+            foreach ($files as $file) {
+                if (strlen($file) > $pathLength and substr($file, 0, $pathLength) == $folderPath) {
+                    return true;
+                }
+            }
+        }
+        if ($path[0] != '/') { //not all programs agree on the use of a leading /
+            return $this->fileExists('/' . $path);
+        } else {
+            return false;
+        }
+    }
 
-	/**
-	 * remove a file or folder from the archive
-	 *
-	 * @param string $path
-	 * @return bool
-	 */
-	function remove($path) {
-		if (!$this->fileExists($path)) {
-			return false;
-		}
-		$this->fileList = false;
-		$this->cachedHeaders = false;
-		//no proper way to delete, extract entire archive, delete file and remake archive
-		$tmp = \OCP\Files::tmpFolder();
-		$this->tar->extract($tmp);
-		\OCP\Files::rmdirr($tmp . $path);
-		$this->tar = null;
-		unlink($this->path);
-		$this->reopen();
-		$this->tar->createModify(array($tmp), '', $tmp);
-		return true;
-	}
+    /**
+     * remove a file or folder from the archive
+     *
+     * @param string $path
+     * @return bool
+     */
+    function remove($path) {
+        if (!$this->fileExists($path)) {
+            return false;
+        }
+        $this->fileList = false;
+        $this->cachedHeaders = false;
+        //no proper way to delete, extract entire archive, delete file and remake archive
+        $tmp = \OCP\Files::tmpFolder();
+        $this->tar->extract($tmp);
+        \OCP\Files::rmdirr($tmp . $path);
+        $this->tar = null;
+        unlink($this->path);
+        $this->reopen();
+        $this->tar->createModify(array($tmp), '', $tmp);
+        return true;
+    }
 
-	/**
-	 * get a file handler
-	 *
-	 * @param string $path
-	 * @param string $mode
-	 * @return resource
-	 */
-	function getStream($path, $mode) {
-		if (strrpos($path, '.') !== false) {
-			$ext = substr($path, strrpos($path, '.'));
-		} else {
-			$ext = '';
-		}
-		$tmpFile = \OCP\Files::tmpFile($ext);
-		if ($this->fileExists($path)) {
-			$this->extractFile($path, $tmpFile);
-		} elseif ($mode == 'r' or $mode == 'rb') {
-			return false;
-		}
-		if ($mode == 'r' or $mode == 'rb') {
-			return fopen($tmpFile, $mode);
-		} else {
-			$handle = fopen($tmpFile, $mode);
-			return CallbackWrapper::wrap($handle, null, null, function () use ($path, $tmpFile) {
-				$this->writeBack($tmpFile, $path);
-			});
-		}
-	}
+    /**
+     * get a file handler
+     *
+     * @param string $path
+     * @param string $mode
+     * @return resource
+     */
+    function getStream($path, $mode) {
+        if (strrpos($path, '.') !== false) {
+            $ext = substr($path, strrpos($path, '.'));
+        } else {
+            $ext = '';
+        }
+        $tmpFile = \OCP\Files::tmpFile($ext);
+        if ($this->fileExists($path)) {
+            $this->extractFile($path, $tmpFile);
+        } elseif ($mode == 'r' or $mode == 'rb') {
+            return false;
+        }
+        if ($mode == 'r' or $mode == 'rb') {
+            return fopen($tmpFile, $mode);
+        } else {
+            $handle = fopen($tmpFile, $mode);
+            return CallbackWrapper::wrap($handle, null, null, function () use ($path, $tmpFile) {
+                $this->writeBack($tmpFile, $path);
+            });
+        }
+    }
 
-	/**
-	 * write back temporary files
-	 */
-	function writeBack($tmpFile, $path) {
-		$this->addFile($path, $tmpFile);
-		unlink($tmpFile);
-	}
+    /**
+     * write back temporary files
+     */
+    function writeBack($tmpFile, $path) {
+        $this->addFile($path, $tmpFile);
+        unlink($tmpFile);
+    }
 
-	/**
-	 * reopen the archive to ensure everything is written
-	 */
-	private function reopen() {
-		if ($this->tar) {
-			$this->tar->_close();
-			$this->tar = null;
-		}
-		$types = array(null, 'gz', 'bz');
-		$this->tar = new \Archive_Tar($this->path, $types[self::getTarType($this->path)]);
-	}
+    /**
+     * reopen the archive to ensure everything is written
+     */
+    private function reopen() {
+        if ($this->tar) {
+            $this->tar->_close();
+            $this->tar = null;
+        }
+        $types = array(null, 'gz', 'bz');
+        $this->tar = new \Archive_Tar($this->path, $types[self::getTarType($this->path)]);
+    }
 }

lib/private/Archive/ZIP.php

Indentation +192 added lines, -192 removed lines

@@ -34,199 +34,199 @@
 use Icewind\Streams\CallbackWrapper;
 
 class ZIP extends Archive{
-	/**
-	 * @var \ZipArchive zip
-	 */
-	private $zip=null;
-	private $path;
+    /**
+     * @var \ZipArchive zip
+     */
+    private $zip=null;
+    private $path;
 
-	/**
-	 * @param string $source
-	 */
-	function __construct($source) {
-		$this->path=$source;
-		$this->zip=new \ZipArchive();
-		if($this->zip->open($source, \ZipArchive::CREATE)) {
-		}else{
-			\OCP\Util::writeLog('files_archive', 'Error while opening archive '.$source, \OCP\Util::WARN);
-		}
-	}
-	/**
-	 * add an empty folder to the archive
-	 * @param string $path
-	 * @return bool
-	 */
-	function addFolder($path) {
-		return $this->zip->addEmptyDir($path);
-	}
-	/**
-	 * add a file to the archive
-	 * @param string $path
-	 * @param string $source either a local file or string data
-	 * @return bool
-	 */
-	function addFile($path, $source='') {
-		if($source and $source[0]=='/' and file_exists($source)) {
-			$result=$this->zip->addFile($source, $path);
-		}else{
-			$result=$this->zip->addFromString($path, $source);
-		}
-		if($result) {
-			$this->zip->close();//close and reopen to save the zip
-			$this->zip->open($this->path);
-		}
-		return $result;
-	}
-	/**
-	 * rename a file or folder in the archive
-	 * @param string $source
-	 * @param string $dest
-	 * @return boolean|null
-	 */
-	function rename($source, $dest) {
-		$source=$this->stripPath($source);
-		$dest=$this->stripPath($dest);
-		$this->zip->renameName($source, $dest);
-	}
-	/**
-	 * get the uncompressed size of a file in the archive
-	 * @param string $path
-	 * @return int
-	 */
-	function filesize($path) {
-		$stat=$this->zip->statName($path);
-		return $stat['size'];
-	}
-	/**
-	 * get the last modified time of a file in the archive
-	 * @param string $path
-	 * @return int
-	 */
-	function mtime($path) {
-		return filemtime($this->path);
-	}
-	/**
-	 * get the files in a folder
-	 * @param string $path
-	 * @return array
-	 */
-	function getFolder($path) {
-		$files=$this->getFiles();
-		$folderContent=array();
-		$pathLength=strlen($path);
-		foreach($files as $file) {
-			if(substr($file, 0, $pathLength)==$path and $file!=$path) {
-				if(strrpos(substr($file, 0, -1), '/')<=$pathLength) {
-					$folderContent[]=substr($file, $pathLength);
-				}
-			}
-		}
-		return $folderContent;
-	}
-	/**
-	 * get all files in the archive
-	 * @return array
-	 */
-	function getFiles() {
-		$fileCount=$this->zip->numFiles;
-		$files=array();
-		for($i=0;$i<$fileCount;$i++) {
-			$files[]=$this->zip->getNameIndex($i);
-		}
-		return $files;
-	}
-	/**
-	 * get the content of a file
-	 * @param string $path
-	 * @return string
-	 */
-	function getFile($path) {
-		return $this->zip->getFromName($path);
-	}
-	/**
-	 * extract a single file from the archive
-	 * @param string $path
-	 * @param string $dest
-	 * @return boolean|null
-	 */
-	function extractFile($path, $dest) {
-		$fp = $this->zip->getStream($path);
-		file_put_contents($dest, $fp);
-	}
-	/**
-	 * extract the archive
-	 * @param string $dest
-	 * @return bool
-	 */
-	function extract($dest) {
-		return $this->zip->extractTo($dest);
-	}
-	/**
-	 * check if a file or folder exists in the archive
-	 * @param string $path
-	 * @return bool
-	 */
-	function fileExists($path) {
-		return ($this->zip->locateName($path)!==false) or ($this->zip->locateName($path.'/')!==false);
-	}
-	/**
-	 * remove a file or folder from the archive
-	 * @param string $path
-	 * @return bool
-	 */
-	function remove($path) {
-		if($this->fileExists($path.'/')) {
-			return $this->zip->deleteName($path.'/');
-		}else{
-			return $this->zip->deleteName($path);
-		}
-	}
-	/**
-	 * get a file handler
-	 * @param string $path
-	 * @param string $mode
-	 * @return resource
-	 */
-	function getStream($path, $mode) {
-		if($mode=='r' or $mode=='rb') {
-			return $this->zip->getStream($path);
-		} else {
-			//since we can't directly get a writable stream,
-			//make a temp copy of the file and put it back
-			//in the archive when the stream is closed
-			if(strrpos($path, '.')!==false) {
-				$ext=substr($path, strrpos($path, '.'));
-			}else{
-				$ext='';
-			}
-			$tmpFile=\OCP\Files::tmpFile($ext);
-			if($this->fileExists($path)) {
-				$this->extractFile($path, $tmpFile);
-			}
-			$handle = fopen($tmpFile, $mode);
-			return CallbackWrapper::wrap($handle, null, null, function () use ($path, $tmpFile) {
-				$this->writeBack($tmpFile, $path);
-			});
-		}
-	}
+    /**
+     * @param string $source
+     */
+    function __construct($source) {
+        $this->path=$source;
+        $this->zip=new \ZipArchive();
+        if($this->zip->open($source, \ZipArchive::CREATE)) {
+        }else{
+            \OCP\Util::writeLog('files_archive', 'Error while opening archive '.$source, \OCP\Util::WARN);
+        }
+    }
+    /**
+     * add an empty folder to the archive
+     * @param string $path
+     * @return bool
+     */
+    function addFolder($path) {
+        return $this->zip->addEmptyDir($path);
+    }
+    /**
+     * add a file to the archive
+     * @param string $path
+     * @param string $source either a local file or string data
+     * @return bool
+     */
+    function addFile($path, $source='') {
+        if($source and $source[0]=='/' and file_exists($source)) {
+            $result=$this->zip->addFile($source, $path);
+        }else{
+            $result=$this->zip->addFromString($path, $source);
+        }
+        if($result) {
+            $this->zip->close();//close and reopen to save the zip
+            $this->zip->open($this->path);
+        }
+        return $result;
+    }
+    /**
+     * rename a file or folder in the archive
+     * @param string $source
+     * @param string $dest
+     * @return boolean|null
+     */
+    function rename($source, $dest) {
+        $source=$this->stripPath($source);
+        $dest=$this->stripPath($dest);
+        $this->zip->renameName($source, $dest);
+    }
+    /**
+     * get the uncompressed size of a file in the archive
+     * @param string $path
+     * @return int
+     */
+    function filesize($path) {
+        $stat=$this->zip->statName($path);
+        return $stat['size'];
+    }
+    /**
+     * get the last modified time of a file in the archive
+     * @param string $path
+     * @return int
+     */
+    function mtime($path) {
+        return filemtime($this->path);
+    }
+    /**
+     * get the files in a folder
+     * @param string $path
+     * @return array
+     */
+    function getFolder($path) {
+        $files=$this->getFiles();
+        $folderContent=array();
+        $pathLength=strlen($path);
+        foreach($files as $file) {
+            if(substr($file, 0, $pathLength)==$path and $file!=$path) {
+                if(strrpos(substr($file, 0, -1), '/')<=$pathLength) {
+                    $folderContent[]=substr($file, $pathLength);
+                }
+            }
+        }
+        return $folderContent;
+    }
+    /**
+     * get all files in the archive
+     * @return array
+     */
+    function getFiles() {
+        $fileCount=$this->zip->numFiles;
+        $files=array();
+        for($i=0;$i<$fileCount;$i++) {
+            $files[]=$this->zip->getNameIndex($i);
+        }
+        return $files;
+    }
+    /**
+     * get the content of a file
+     * @param string $path
+     * @return string
+     */
+    function getFile($path) {
+        return $this->zip->getFromName($path);
+    }
+    /**
+     * extract a single file from the archive
+     * @param string $path
+     * @param string $dest
+     * @return boolean|null
+     */
+    function extractFile($path, $dest) {
+        $fp = $this->zip->getStream($path);
+        file_put_contents($dest, $fp);
+    }
+    /**
+     * extract the archive
+     * @param string $dest
+     * @return bool
+     */
+    function extract($dest) {
+        return $this->zip->extractTo($dest);
+    }
+    /**
+     * check if a file or folder exists in the archive
+     * @param string $path
+     * @return bool
+     */
+    function fileExists($path) {
+        return ($this->zip->locateName($path)!==false) or ($this->zip->locateName($path.'/')!==false);
+    }
+    /**
+     * remove a file or folder from the archive
+     * @param string $path
+     * @return bool
+     */
+    function remove($path) {
+        if($this->fileExists($path.'/')) {
+            return $this->zip->deleteName($path.'/');
+        }else{
+            return $this->zip->deleteName($path);
+        }
+    }
+    /**
+     * get a file handler
+     * @param string $path
+     * @param string $mode
+     * @return resource
+     */
+    function getStream($path, $mode) {
+        if($mode=='r' or $mode=='rb') {
+            return $this->zip->getStream($path);
+        } else {
+            //since we can't directly get a writable stream,
+            //make a temp copy of the file and put it back
+            //in the archive when the stream is closed
+            if(strrpos($path, '.')!==false) {
+                $ext=substr($path, strrpos($path, '.'));
+            }else{
+                $ext='';
+            }
+            $tmpFile=\OCP\Files::tmpFile($ext);
+            if($this->fileExists($path)) {
+                $this->extractFile($path, $tmpFile);
+            }
+            $handle = fopen($tmpFile, $mode);
+            return CallbackWrapper::wrap($handle, null, null, function () use ($path, $tmpFile) {
+                $this->writeBack($tmpFile, $path);
+            });
+        }
+    }
 
-	/**
-	 * write back temporary files
-	 */
-	function writeBack($tmpFile, $path) {
-		$this->addFile($path, $tmpFile);
-		unlink($tmpFile);
-	}
+    /**
+     * write back temporary files
+     */
+    function writeBack($tmpFile, $path) {
+        $this->addFile($path, $tmpFile);
+        unlink($tmpFile);
+    }
 
-	/**
-	 * @param string $path
-	 * @return string
-	 */
-	private function stripPath($path) {
-		if(!$path || $path[0]=='/') {
-			return substr($path, 1);
-		}else{
-			return $path;
-		}
-	}
+    /**
+     * @param string $path
+     * @return string
+     */
+    private function stripPath($path) {
+        if(!$path || $path[0]=='/') {
+            return substr($path, 1);
+        }else{
+            return $path;
+        }
+    }
 }

lib/private/Archive/Archive.php

Indentation +107 added lines, -107 removed lines

@@ -33,111 +33,111 @@
 namespace OC\Archive;
 
 abstract class Archive {
-	/**
-	 * @param $source
-	 */
-	abstract function __construct($source);
-	/**
-	 * add an empty folder to the archive
-	 * @param string $path
-	 * @return bool
-	 */
-	abstract function addFolder($path);
-	/**
-	 * add a file to the archive
-	 * @param string $path
-	 * @param string $source either a local file or string data
-	 * @return bool
-	 */
-	abstract function addFile($path, $source='');
-	/**
-	 * rename a file or folder in the archive
-	 * @param string $source
-	 * @param string $dest
-	 * @return bool
-	 */
-	abstract function rename($source, $dest);
-	/**
-	 * get the uncompressed size of a file in the archive
-	 * @param string $path
-	 * @return int
-	 */
-	abstract function filesize($path);
-	/**
-	 * get the last modified time of a file in the archive
-	 * @param string $path
-	 * @return int
-	 */
-	abstract function mtime($path);
-	/**
-	 * get the files in a folder
-	 * @param string $path
-	 * @return array
-	 */
-	abstract function getFolder($path);
-	/**
-	 * get all files in the archive
-	 * @return array
-	 */
-	abstract function getFiles();
-	/**
-	 * get the content of a file
-	 * @param string $path
-	 * @return string
-	 */
-	abstract function getFile($path);
-	/**
-	 * extract a single file from the archive
-	 * @param string $path
-	 * @param string $dest
-	 * @return bool
-	 */
-	abstract function extractFile($path, $dest);
-	/**
-	 * extract the archive
-	 * @param string $dest
-	 * @return bool
-	 */
-	abstract function extract($dest);
-	/**
-	 * check if a file or folder exists in the archive
-	 * @param string $path
-	 * @return bool
-	 */
-	abstract function fileExists($path);
-	/**
-	 * remove a file or folder from the archive
-	 * @param string $path
-	 * @return bool
-	 */
-	abstract function remove($path);
-	/**
-	 * get a file handler
-	 * @param string $path
-	 * @param string $mode
-	 * @return resource
-	 */
-	abstract function getStream($path, $mode);
-	/**
-	 * add a folder and all its content
-	 * @param string $path
-	 * @param string $source
-	 * @return boolean|null
-	 */
-	function addRecursive($path, $source) {
-		$dh = opendir($source);
-		if(is_resource($dh)) {
-			$this->addFolder($path);
-			while (($file = readdir($dh)) !== false) {
-				if($file=='.' or $file=='..') {
-					continue;
-				}
-				if(is_dir($source.'/'.$file)) {
-					$this->addRecursive($path.'/'.$file, $source.'/'.$file);
-				}else{
-					$this->addFile($path.'/'.$file, $source.'/'.$file);
-				}
-			}
-		}
-	}
+    /**
+     * @param $source
+     */
+    abstract function __construct($source);
+    /**
+     * add an empty folder to the archive
+     * @param string $path
+     * @return bool
+     */
+    abstract function addFolder($path);
+    /**
+     * add a file to the archive
+     * @param string $path
+     * @param string $source either a local file or string data
+     * @return bool
+     */
+    abstract function addFile($path, $source='');
+    /**
+     * rename a file or folder in the archive
+     * @param string $source
+     * @param string $dest
+     * @return bool
+     */
+    abstract function rename($source, $dest);
+    /**
+     * get the uncompressed size of a file in the archive
+     * @param string $path
+     * @return int
+     */
+    abstract function filesize($path);
+    /**
+     * get the last modified time of a file in the archive
+     * @param string $path
+     * @return int
+     */
+    abstract function mtime($path);
+    /**
+     * get the files in a folder
+     * @param string $path
+     * @return array
+     */
+    abstract function getFolder($path);
+    /**
+     * get all files in the archive
+     * @return array
+     */
+    abstract function getFiles();
+    /**
+     * get the content of a file
+     * @param string $path
+     * @return string
+     */
+    abstract function getFile($path);
+    /**
+     * extract a single file from the archive
+     * @param string $path
+     * @param string $dest
+     * @return bool
+     */
+    abstract function extractFile($path, $dest);
+    /**
+     * extract the archive
+     * @param string $dest
+     * @return bool
+     */
+    abstract function extract($dest);
+    /**
+     * check if a file or folder exists in the archive
+     * @param string $path
+     * @return bool
+     */
+    abstract function fileExists($path);
+    /**
+     * remove a file or folder from the archive
+     * @param string $path
+     * @return bool
+     */
+    abstract function remove($path);
+    /**
+     * get a file handler
+     * @param string $path
+     * @param string $mode
+     * @return resource
+     */
+    abstract function getStream($path, $mode);
+    /**
+     * add a folder and all its content
+     * @param string $path
+     * @param string $source
+     * @return boolean|null
+     */
+    function addRecursive($path, $source) {
+        $dh = opendir($source);
+        if(is_resource($dh)) {
+            $this->addFolder($path);
+            while (($file = readdir($dh)) !== false) {
+                if($file=='.' or $file=='..') {
+                    continue;
+                }
+                if(is_dir($source.'/'.$file)) {
+                    $this->addRecursive($path.'/'.$file, $source.'/'.$file);
+                }else{
+                    $this->addFile($path.'/'.$file, $source.'/'.$file);
+                }
+            }
+        }
+    }
 }

lib/private/NaturalSort_DefaultCollator.php

Indentation +10 added lines, -10 removed lines

@@ -25,14 +25,14 @@
 namespace OC;
 
 class NaturalSort_DefaultCollator {
-	public function compare($a, $b) {
-		$result = strcasecmp($a, $b);
-		if ($result === 0) {
-			if ($a === $b) {
-				return 0;
-			}
-			return ($a > $b) ? -1 : 1;
-		}
-		return ($result < 0) ? -1 : 1;
-	}
+    public function compare($a, $b) {
+        $result = strcasecmp($a, $b);
+        if ($result === 0) {
+            if ($a === $b) {
+                return 0;
+            }
+            return ($a > $b) ? -1 : 1;
+        }
+        return ($result < 0) ? -1 : 1;
+    }
 }

lib/private/Migration/BackgroundRepair.php

Indentation +66 added lines, -66 removed lines

@@ -37,81 +37,81 @@
  */
 class BackgroundRepair extends TimedJob {
 
-	/** @var IJobList */
-	private $jobList;
+    /** @var IJobList */
+    private $jobList;
 
-	/** @var ILogger */
-	private $logger;
+    /** @var ILogger */
+    private $logger;
 
-	/** @var EventDispatcher */
-	private $dispatcher;
+    /** @var EventDispatcher */
+    private $dispatcher;
 
-	public function setDispatcher(EventDispatcher $dispatcher) {
-		$this->dispatcher = $dispatcher;
-	}
-	/**
-	 * run the job, then remove it from the job list
-	 *
-	 * @param JobList $jobList
-	 * @param ILogger $logger
-	 */
-	public function execute($jobList, ILogger $logger = null) {
-		// add an interval of 15 mins
-		$this->setInterval(15*60);
+    public function setDispatcher(EventDispatcher $dispatcher) {
+        $this->dispatcher = $dispatcher;
+    }
+    /**
+     * run the job, then remove it from the job list
+     *
+     * @param JobList $jobList
+     * @param ILogger $logger
+     */
+    public function execute($jobList, ILogger $logger = null) {
+        // add an interval of 15 mins
+        $this->setInterval(15*60);
 
-		$this->jobList = $jobList;
-		$this->logger = $logger;
-		parent::execute($jobList, $logger);
-	}
+        $this->jobList = $jobList;
+        $this->logger = $logger;
+        parent::execute($jobList, $logger);
+    }
 
-	/**
-	 * @param array $argument
-	 * @throws \Exception
-	 * @throws \OC\NeedsUpdateException
-	 */
-	protected function run($argument) {
-		if (!isset($argument['app']) || !isset($argument['step'])) {
-			// remove the job - we can never execute it
-			$this->jobList->remove($this, $this->argument);
-			return;
-		}
-		$app = $argument['app'];
+    /**
+     * @param array $argument
+     * @throws \Exception
+     * @throws \OC\NeedsUpdateException
+     */
+    protected function run($argument) {
+        if (!isset($argument['app']) || !isset($argument['step'])) {
+            // remove the job - we can never execute it
+            $this->jobList->remove($this, $this->argument);
+            return;
+        }
+        $app = $argument['app'];
 
-		try {
-			$this->loadApp($app);
-		} catch (NeedsUpdateException $ex) {
-			// as long as the app is not yet done with it's offline migration
-			// we better not start with the live migration
-			return;
-		}
+        try {
+            $this->loadApp($app);
+        } catch (NeedsUpdateException $ex) {
+            // as long as the app is not yet done with it's offline migration
+            // we better not start with the live migration
+            return;
+        }
 
-		$step = $argument['step'];
-		$repair = new Repair([], $this->dispatcher);
-		try {
-			$repair->addStep($step);
-		} catch (\Exception $ex) {
-			$this->logger->logException($ex,[
-				'app' => 'migration'
-			]);
+        $step = $argument['step'];
+        $repair = new Repair([], $this->dispatcher);
+        try {
+            $repair->addStep($step);
+        } catch (\Exception $ex) {
+            $this->logger->logException($ex,[
+                'app' => 'migration'
+            ]);
 
-			// remove the job - we can never execute it
-			$this->jobList->remove($this, $this->argument);
-			return;
-		}
+            // remove the job - we can never execute it
+            $this->jobList->remove($this, $this->argument);
+            return;
+        }
 
-		// execute the repair step
-		$repair->run();
+        // execute the repair step
+        $repair->run();
 
-		// remove the job once executed successfully
-		$this->jobList->remove($this, $this->argument);
-	}
+        // remove the job once executed successfully
+        $this->jobList->remove($this, $this->argument);
+    }
 
-	/**
-	 * @codeCoverageIgnore
-	 * @param $app
-	 * @throws NeedsUpdateException
-	 */
-	protected function loadApp($app) {
-		OC_App::loadApp($app);
-	}
+    /**
+     * @codeCoverageIgnore
+     * @param $app
+     * @throws NeedsUpdateException
+     */
+    protected function loadApp($app) {
+        OC_App::loadApp($app);
+    }
 }

lib/private/Command/AsyncBus.php

Indentation +99 added lines, -99 removed lines

@@ -30,112 +30,112 @@
  * Asynchronous command bus that uses the background job system as backend
  */
 class AsyncBus implements IBus {
-	/**
-	 * @var \OCP\BackgroundJob\IJobList
-	 */
-	private $jobList;
+    /**
+     * @var \OCP\BackgroundJob\IJobList
+     */
+    private $jobList;
 
-	/**
-	 * List of traits for command which require sync execution
-	 *
-	 * @var string[]
-	 */
-	private $syncTraits = [];
+    /**
+     * List of traits for command which require sync execution
+     *
+     * @var string[]
+     */
+    private $syncTraits = [];
 
-	/**
-	 * @param \OCP\BackgroundJob\IJobList $jobList
-	 */
-	function __construct($jobList) {
-		$this->jobList = $jobList;
-	}
+    /**
+     * @param \OCP\BackgroundJob\IJobList $jobList
+     */
+    function __construct($jobList) {
+        $this->jobList = $jobList;
+    }
 
-	/**
-	 * Schedule a command to be fired
-	 *
-	 * @param \OCP\Command\ICommand | callable $command
-	 */
-	public function push($command) {
-		if ($this->canRunAsync($command)) {
-			$this->jobList->add($this->getJobClass($command), $this->serializeCommand($command));
-		} else {
-			$this->runCommand($command);
-		}
-	}
+    /**
+     * Schedule a command to be fired
+     *
+     * @param \OCP\Command\ICommand | callable $command
+     */
+    public function push($command) {
+        if ($this->canRunAsync($command)) {
+            $this->jobList->add($this->getJobClass($command), $this->serializeCommand($command));
+        } else {
+            $this->runCommand($command);
+        }
+    }
 
-	/**
-	 * Require all commands using a trait to be run synchronous
-	 *
-	 * @param string $trait
-	 */
-	public function requireSync($trait) {
-		$this->syncTraits[] = trim($trait, '\\');
-	}
+    /**
+     * Require all commands using a trait to be run synchronous
+     *
+     * @param string $trait
+     */
+    public function requireSync($trait) {
+        $this->syncTraits[] = trim($trait, '\\');
+    }
 
-	/**
-	 * @param \OCP\Command\ICommand | callable $command
-	 */
-	private function runCommand($command) {
-		if ($command instanceof ICommand) {
-			$command->handle();
-		} else {
-			$command();
-		}
-	}
+    /**
+     * @param \OCP\Command\ICommand | callable $command
+     */
+    private function runCommand($command) {
+        if ($command instanceof ICommand) {
+            $command->handle();
+        } else {
+            $command();
+        }
+    }
 
-	/**
-	 * @param \OCP\Command\ICommand | callable $command
-	 * @return string
-	 */
-	private function getJobClass($command) {
-		if ($command instanceof \Closure) {
-			return 'OC\Command\ClosureJob';
-		} else if (is_callable($command)) {
-			return 'OC\Command\CallableJob';
-		} else if ($command instanceof ICommand) {
-			return 'OC\Command\CommandJob';
-		} else {
-			throw new \InvalidArgumentException('Invalid command');
-		}
-	}
+    /**
+     * @param \OCP\Command\ICommand | callable $command
+     * @return string
+     */
+    private function getJobClass($command) {
+        if ($command instanceof \Closure) {
+            return 'OC\Command\ClosureJob';
+        } else if (is_callable($command)) {
+            return 'OC\Command\CallableJob';
+        } else if ($command instanceof ICommand) {
+            return 'OC\Command\CommandJob';
+        } else {
+            throw new \InvalidArgumentException('Invalid command');
+        }
+    }
 
-	/**
-	 * @param \OCP\Command\ICommand | callable $command
-	 * @return string
-	 */
-	private function serializeCommand($command) {
-		if ($command instanceof \Closure) {
-			$serializer = new Serializer();
-			return $serializer->serialize($command);
-		} else if (is_callable($command) or $command instanceof ICommand) {
-			return serialize($command);
-		} else {
-			throw new \InvalidArgumentException('Invalid command');
-		}
-	}
+    /**
+     * @param \OCP\Command\ICommand | callable $command
+     * @return string
+     */
+    private function serializeCommand($command) {
+        if ($command instanceof \Closure) {
+            $serializer = new Serializer();
+            return $serializer->serialize($command);
+        } else if (is_callable($command) or $command instanceof ICommand) {
+            return serialize($command);
+        } else {
+            throw new \InvalidArgumentException('Invalid command');
+        }
+    }
 
-	/**
-	 * @param \OCP\Command\ICommand | callable $command
-	 * @return bool
-	 */
-	private function canRunAsync($command) {
-		$traits = $this->getTraits($command);
-		foreach ($traits as $trait) {
-			if (array_search($trait, $this->syncTraits) !== false) {
-				return false;
-			}
-		}
-		return true;
-	}
+    /**
+     * @param \OCP\Command\ICommand | callable $command
+     * @return bool
+     */
+    private function canRunAsync($command) {
+        $traits = $this->getTraits($command);
+        foreach ($traits as $trait) {
+            if (array_search($trait, $this->syncTraits) !== false) {
+                return false;
+            }
+        }
+        return true;
+    }
 
-	/**
-	 * @param \OCP\Command\ICommand | callable $command
-	 * @return string[]
-	 */
-	private function getTraits($command) {
-		if ($command instanceof ICommand) {
-			return class_uses($command);
-		} else {
-			return [];
-		}
-	}
+    /**
+     * @param \OCP\Command\ICommand | callable $command
+     * @return string[]
+     */
+    private function getTraits($command) {
+        if ($command instanceof ICommand) {
+            return class_uses($command);
+        } else {
+            return [];
+        }
+    }
 }

lib/private/Command/QueueBus.php

Indentation +40 added lines, -40 removed lines

@@ -26,48 +26,48 @@
 use OCP\Command\ICommand;
 
 class QueueBus implements IBus {
-	/**
-	 * @var (ICommand|callable)[]
-	 */
-	private $queue = [];
+    /**
+     * @var (ICommand|callable)[]
+     */
+    private $queue = [];
 
-	/**
-	 * Schedule a command to be fired
-	 *
-	 * @param \OCP\Command\ICommand | callable $command
-	 */
-	public function push($command) {
-		$this->queue[] = $command;
-	}
+    /**
+     * Schedule a command to be fired
+     *
+     * @param \OCP\Command\ICommand | callable $command
+     */
+    public function push($command) {
+        $this->queue[] = $command;
+    }
 
-	/**
-	 * Require all commands using a trait to be run synchronous
-	 *
-	 * @param string $trait
-	 */
-	public function requireSync($trait) {
-	}
+    /**
+     * Require all commands using a trait to be run synchronous
+     *
+     * @param string $trait
+     */
+    public function requireSync($trait) {
+    }
 
-	/**
-	 * @param \OCP\Command\ICommand | callable $command
-	 */
-	private function runCommand($command) {
-		if ($command instanceof ICommand) {
-			// ensure the command can be serialized
-			$serialized = serialize($command);
-			if(strlen($serialized) > 4000) {
-				throw new \InvalidArgumentException('Trying to push a command which serialized form can not be stored in the database (>4000 character)');
-			}
-			$unserialized = unserialize($serialized);
-			$unserialized->handle();
-		} else {
-			$command();
-		}
-	}
+    /**
+     * @param \OCP\Command\ICommand | callable $command
+     */
+    private function runCommand($command) {
+        if ($command instanceof ICommand) {
+            // ensure the command can be serialized
+            $serialized = serialize($command);
+            if(strlen($serialized) > 4000) {
+                throw new \InvalidArgumentException('Trying to push a command which serialized form can not be stored in the database (>4000 character)');
+            }
+            $unserialized = unserialize($serialized);
+            $unserialized->handle();
+        } else {
+            $command();
+        }
+    }
 
-	public function run() {
-		while ($command = array_shift($this->queue)) {
-			$this->runCommand($command);
-		}
-	}
+    public function run() {
+        while ($command = array_shift($this->queue)) {
+            $this->runCommand($command);
+        }
+    }
 }

lib/private/Command/CallableJob.php

Indentation +8 added lines, -8 removed lines

@@ -25,12 +25,12 @@
 use OC\BackgroundJob\QueuedJob;
 
 class CallableJob extends QueuedJob {
-	protected function run($serializedCallable) {
-		$callable = unserialize($serializedCallable);
-		if (is_callable($callable)) {
-			$callable();
-		} else {
-			throw new \InvalidArgumentException('Invalid serialized callable');
-		}
-	}
+    protected function run($serializedCallable) {
+        $callable = unserialize($serializedCallable);
+        if (is_callable($callable)) {
+            $callable();
+        } else {
+            throw new \InvalidArgumentException('Invalid serialized callable');
+        }
+    }
 }

lib/private/Command/ClosureJob.php

Indentation +9 added lines, -9 removed lines

@@ -26,13 +26,13 @@
 use SuperClosure\Serializer;
 
 class ClosureJob extends QueuedJob {
-	protected function run($serializedCallable) {
-		$serializer = new Serializer();
-		$callable = $serializer->unserialize($serializedCallable);
-		if (is_callable($callable)) {
-			$callable();
-		} else {
-			throw new \InvalidArgumentException('Invalid serialized callable');
-		}
-	}
+    protected function run($serializedCallable) {
+        $serializer = new Serializer();
+        $callable = $serializer->unserialize($serializedCallable);
+        if (is_callable($callable)) {
+            $callable();
+        } else {
+            throw new \InvalidArgumentException('Invalid serialized callable');
+        }
+    }
 }