<?php
/**
 * Copyright (c) 2012 Robin Appelman <icewind@owncloud.com>
 * This file is licensed under the Affero General Public License version 3 or
 * later.
 * See the COPYING-README file.
 */

namespace OC\Files\Storage;

class Archive extends Common {
	/**
	 * underlying local storage used for missing functions
	 *
	 * @var \OC_Archive
	 */
	private $archive;
	private $path;
	private static $mounted = array();
	private static $enableAutomount = true;
	private static $rootView;

	private function stripPath($path) { //files should never start with /
		if (!$path || $path[0] == '/') {
			$path = substr($path, 1);
		}
		return $path;
	}

	public function __construct($params) {
		$this->archive = \OC_Archive::open($params['archive']);
		$this->path = $params['archive'];
	}

	public function mkdir($path) {
		$path = $this->stripPath($path);
		return $this->archive->addFolder($path);
	}

	public function rmdir($path) {
		$path = $this->stripPath($path);
		return $this->archive->remove($path . '/');
	}

	public function opendir($path) {
		if (substr($path, -1) !== '/') {
			$path .= '/';
		}
		$path = $this->stripPath($path);
		$files = $this->archive->getFolder($path);
		$content = array();
		foreach ($files as $file) {
			if (substr($file, -1) == '/') {
				$file = substr($file, 0, -1);
			}
			if ($file and strpos($file, '/') === false) {
				$content[] = $file;
			}
		}
		$id = md5($this->path . $path);
		\OC\Files\Stream\Dir::register($id, $content);
		return opendir('fakedir://' . $id);
	}

	public function stat($path) {
		$ctime = -1;
		$path = $this->stripPath($path);
		if ($path == '') {
			$stat = stat($this->path);
			$stat['size'] = 0;
		} else {
			if ($this->is_dir($path)) {
				$stat = array('size' => 0);
				$stat['mtime'] = filemtime($this->path);
			} else {
				$stat = array();
				$stat['mtime'] = $this->archive->mtime($path);
				$stat['size'] = $this->archive->filesize($path);
				if (!$stat['mtime']) {
					$stat['mtime'] = time();
				}
			}
		}
		$stat['ctime'] = $ctime;
		return $stat;
	}

	public function filetype($path) {
		$path = $this->stripPath($path);
		if ($path == '') {
			return 'dir';
		}
		if (substr($path, -1) == '/') {
			return $this->archive->fileExists($path) ? 'dir' : 'file';
		} else {
			return $this->archive->fileExists($path . '/') ? 'dir' : 'file';
		}
	}

	public function isReadable($path) {
		return is_readable($this->path);
	}

	public function isUpdatable($path) {
		return is_writable($this->path);
	}

	public function file_exists($path) {
		$path = $this->stripPath($path);
		if ($path == '') {
			return file_exists($this->path);
		}
		return $this->archive->fileExists($path);
	}

	public function unlink($path) {
		$path = $this->stripPath($path);
		return $this->archive->remove($path);
	}

	public function fopen($path, $mode) {
		$path = $this->stripPath($path);
		return $this->archive->getStream($path, $mode);
	}

	public function free_space($path) {
		return 0;
	}

	public function touch($path, $mtime = null) {
		if (is_null($mtime)) {
			$tmpFile = \OCP\Files::tmpFile();
			$this->archive->extractFile($path, $tmpFile);
			$this->archive->addfile($path, $tmpFile);
			return true;
		} else {
			return false; //not supported
		}
	}

	private function toTmpFile($path) {
		$tmpFile = \OCP\Files::tmpFile();
		$this->archive->extractFile($path, $tmpFile);
		return $tmpFile;
	}

	public function file_put_contents($path, $data) {
		$path = $this->stripPath($path);
		return $this->archive->addFile($path, $data);
	}

	public function file_get_contents($path) {
		$path = $this->stripPath($path);
		return $this->archive->getFile($path);
	}

	/**
	 * automount paths from file hooks
	 *
	 * @param array $params
	 */
	public static function autoMount($params) {
		if (!self::$enableAutomount) {
			return;
		}
		$path = $params['path'];
		if (!self::$rootView) {
			self::$rootView = new \OC_FilesystemView('');
		}
		self::$enableAutomount=false;//prevent recursion
		$supported = array('zip', 'tar.gz', 'tar.bz2', 'tgz');
		foreach ($supported as $type) {
			$ext = '.' . $type . '/';
			if (($pos = strpos(strtolower($path), $ext)) !== false) {
				$archive = substr($path, 0, $pos + strlen($ext) - 1);
				if (self::$rootView->file_exists($archive) and  array_search($archive, self::$mounted) === false) {
					$localArchive = self::$rootView->getLocalFile($archive);
					\OC\Files\Filesystem::mount('\OC\Files\Storage\Archive', array('archive' => $localArchive), $archive . '/');
					self::$mounted[] = $archive;
				}
			}
		}
		self::$enableAutomount = true;
	}

	public function rename($path1, $path2) {
		return $this->archive->rename($path1, $path2);
	}

	public function hasUpdated($path, $time) {
		return $this->filemtime($this->path) > $time;
	}

	public function getId() {
		return 'archive::' . md5($this->path);
	}
}