260 lines
7.9 KiB
PHP
260 lines
7.9 KiB
PHP
<?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;
|
|
}
|
|
}
|
|
}
|