<?php

/**
 * Implementation of the Application Packaging Standard from SwSoft/Parallels
 * http://apsstandard.com
 *
 * This file is part of the Froxlor project.
 * Copyright (c) 2003-2009 the SysCP Team (see authors).
 * Copyright (c) 2010 the Froxlor Team (see authors).
 *
 * For the full copyright and license information, please view the COPYING
 * file that was distributed with this source code. You can also view the
 * COPYING file online at http://files.froxlor.org/misc/COPYING.txt
 *
 * @copyright  (c) the authors
 * @author     Florian Lippert <flo@syscp.org> (2003-2009)
 * @author     Froxlor team <team@froxlor.org> (2010-)
 * @license    GPLv2 http://files.froxlor.org/misc/COPYING.txt
 * @package    APS
 *
 * @todo		logging
 *				install specific packages by name
 *				other solution than using url_fopen
 *				move url for distributionserver into panel
 */

class ApsUpdater extends ApsParser {

	private $settings = array();
	private $RequestDomain = '';
	private $RootUrl = '';
	private $RootDir = '';
	
	/**
	 * FroxlorLogger
	 * @var FroxlorLogger
	 */
	private $_cronlog = null;

	/**
	 * constructor of class. setup some basic variables needed by class
	 *
	 * @param	cronlog		instance of the froxlor logger
	 */
	public function __construct($cronlog) {

		$this->RequestDomain = 'apscatalog.com';
		$this->RootUrl = '/1/';
		$this->RootDir = dirname(dirname(dirname(dirname(__FILE__)))) . '/';
		$this->_cronlog = $cronlog;
	}

	/**
	 * Main function of class which handles all around the update mechanism
	 */
	public function UpdateHandler() {

		$this->_cronlog->logAction(CRON_ACTION, LOG_NOTICE, "Changing directory to '" . $this->RootDir . "'");
		chdir($this->RootDir);

		//return if allow_url_fopen is disabled
		if (!ini_get('allow_url_fopen')) {
			$this->_cronlog->logAction(CRON_ACTION, LOG_ERROR, "The APS updater cronjob requires that allow_url_fopen is enabled for the PHP CLI binary!");
			echo "The APS updater cronjob requires that allow_url_fopen is enabled for the PHP CLI binary!\n";
			return;
		}

		//return if no task exists
		$Result_stmt = Database::query("SELECT * FROM `" . TABLE_APS_TASKS . "` WHERE `Task` IN (" . TASK_SYSTEM_UPDATE . ", " . TASK_SYSTEM_DOWNLOAD . ")");

		if (Database::num_rows() == 0) {
			$this->_cronlog->logAction(CRON_ACTION, LOG_NOTICE, "No tasks for ApsUpdater");
			return;
		}

		//query first task -> updater can only do one job within a run
		$Task = $Result_stmt->fetch(PDO::FETCH_ASSOC);
		$del_stmt = Database::prepare("
			DELETE FROM `" . TABLE_APS_TASKS . "` WHERE `Task` = :task
		");
		Database::pexecute($del_stmt, array('task' => $Task['Task']));

		//fetch all vendors
		$this->_cronlog->logAction(CRON_ACTION, LOG_NOTICE, "Fetching all Vendors from '" . $this->RootUrl . "'");
		$Vendors = self::FetchSubUrls($this->RootUrl);

		if ($Vendors !== false) {

			foreach ($Vendors as $Vendor) {

				//fetch all applications from vendors
				$this->_cronlog->logAction(CRON_ACTION, LOG_NOTICE, "Fetching all from Vendor '" . $Vendor. "'");
				$Applications = self::FetchSubUrls($this->RootUrl . $Vendor);

				if ($Applications !== false) {

					foreach ($Applications as $Application) {

						//get newest version of package which is already installed
						$this->_cronlog->logAction(CRON_ACTION, LOG_NOTICE, "Checking application '" . substr($Application, 0, -1) . "'");

						$CurrentVersion = '';
						$Result_stmt = Database::prepare("
							SELECT * FROM `" . TABLE_APS_PACKAGES . "` WHERE `Name` = :name
						");
						Database::pexecute($Result_stmt, array('name' => substr($Application, 0, -1)));
						$numrows_result = Database::num_rows();

						while ($Row = $Result_stmt->fetch(PDO::FETCH_ASSOC)) {
							if (version_compare($Row['Version'] . '-' . $Row['Release'], $CurrentVersion) == 1) {
								$CurrentVersion = $Row['Version'] . '-' . $Row['Release'];
							}
						}

						if ($numrows_result!= 0) {
							//package already installed in system, search for newer version
							if ($Task['Task'] != TASK_SYSTEM_UPDATE) {
								continue;
							}

							//fetch different versions of application from distribution server
							$NewerVersion = '';
							$Versions = self::FetchSubUrls($this->RootUrl . $Vendor . $Application);

							if ($Versions !== false) {
								foreach ($Versions as $Version) {
									$OnlineVersion = substr($Version, 0, -1);
									//is package newer than current version?
									if (version_compare($OnlineVersion, $CurrentVersion) == 1) {
										//is new package newer than another one found before?
										if (version_compare($OnlineVersion, $NewerVersion) == 1) {
											$NewerVersion = $OnlineVersion;
										}
									}
								}

								if ($NewerVersion != '') {
									//download package as an update
									self::DownloadPackage($this->RootUrl . $Vendor . $Application . $NewerVersion, substr($Application, 0, -1), $NewerVersion);
									continue;
								}
							}

						} else {

							if ($Task['Task'] != TASK_SYSTEM_DOWNLOAD) {
								continue;
							}

							//new packages
							$NewVersion = '';
							$Versions = self::FetchSubUrls($this->RootUrl . $Vendor . $Application);

							foreach ($Versions as $Version) {
								$OnlineVersion = substr($Version, 0, -1);
								//is package newer than another one found before?
								if (version_compare($OnlineVersion, $NewVersion) == 1) {
									$NewVersion = $OnlineVersion;
								}
							}

							if ($NewVersion != '') {
								//download package as a new one
								self::DownloadPackage($this->RootUrl . $Vendor . $Application . $NewVersion, substr($Application, 0, -1), $NewVersion);
								continue;
							}
						}
					}
				}
			}
		}
	}

	/**
	 * download a package from the distribution server and move the downloaded file in the temporary directory
	 *
	 * @param	url				url to download
	 * @param	application		string identifying the application name
	 * @param	version			string identifying the application version
	 * @return	success true/error false
	 */
	private function DownloadPackage($Url, $Application, $Version) {

		$Downloads = self::FetchSubUrls($Url . '/');

		//make url valid
		$path = dirname($Url);
		$file = urlencode(basename($Url));
		$file_url = 'http://' . $this->RequestDomain . $path . '/' . $file . '.aps' . $Downloads[0];

		//get content from website url
		$this->_cronlog->logAction(CRON_ACTION, LOG_NOTICE, "Downloading '" . $file_url . "'");
		$Content = @file_get_contents($file_url);

		if ($Content != false) {
			//open file to write contents on disk
			$FileHandle = fopen($this->RootDir . 'temp/' . $Application . '-' . $Version . '.app.zip', 'wb');

			if ($FileHandle == true) {
				//write results to disk
				fwrite($FileHandle, $Content);
				fclose($FileHandle);

				//set right permissions
				chmod($this->RootDir . 'temp/' . $Application . '-' . $Version . '.app.zip', 0664);
				return true;

			} else {
				return false;
			}
		} else {
			return false;
		}
	}

	/**
	 * fetch html content of distribution server and parse all information
	 *
	 * @param	requestdomain	domain to aps-/mirrorserver with package api
	 * @param	url				url to fetch sub links from
	 * @return	error false/success array with relative sub links
	 */
	private function FetchSubUrls($Url) {

		$Return = array();

		//make url valid
		$Url = str_replace(' ', '%20', $Url);
		$file_url = 'http://' . $this->RequestDomain . $Url;

		//get content from website url
		$Content = @file($file_url);

		if ($Content !== false) {

			foreach ($Content as $Temp) {
				//skip empty lines
				if ($Temp != "\r\n"
					&& $Temp != "\r"
					&& $Temp != "\n"
					&& $Temp != ""
				) {
					//remove unwanted characters
					$Temp = trim($Temp);

					//grep URLs which match defined format
					if (preg_match("/^<a href=\"(.+)\".+class=\"(vendor|application|version|packager)\"/", $Temp, $Matches)) {
						if (!in_array(urldecode($Matches[1]), $Return)) {
							$Return[] = urldecode($Matches[1]);
						}
					}
				}
			}
			return $Return;
		} else {
			return false;
		}
	}
}