ininitial froxlor commit;
'reverted' old-style update-process; removed billing-classes, -functions and -templates; some sql-fixes;
This commit is contained in:
561
lib/classes/aps/class.ApsInstaller.php
Normal file
561
lib/classes/aps/class.ApsInstaller.php
Normal file
@@ -0,0 +1,561 @@
|
||||
<?php
|
||||
|
||||
/**
|
||||
* Implementation of the Application Packaging Standard from SwSoft/Parallels
|
||||
* http://apsstandard.com
|
||||
*
|
||||
* Copyright (c) 2003-2009 the SysCP 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.syscp.org/misc/COPYING.txt
|
||||
*
|
||||
* @copyright (c) the authors
|
||||
* @author Sven Skrabal <info@nexpa.de>
|
||||
* @license GPLv2 http://files.syscp.org/misc/COPYING.txt
|
||||
* @package Cron
|
||||
* @version $Id: class.ApsInstaller.php 2724 2009-06-07 14:18:02Z flo $
|
||||
* @todo logging
|
||||
* run with user uid/gid
|
||||
* folder truncation/tar all files
|
||||
*/
|
||||
|
||||
class ApsInstaller extends ApsParser
|
||||
{
|
||||
private $db = false;
|
||||
private $db_root = false;
|
||||
private $DomainPath = '';
|
||||
private $Domain = '';
|
||||
private $RealPath = '';
|
||||
private $RootDir = '';
|
||||
private $Hosts = '';
|
||||
|
||||
/**
|
||||
* constructor of class. setup some basic variables
|
||||
*
|
||||
* @param settings array with the global settings from syscp
|
||||
* @param db instance of the database class from syscp
|
||||
* @param db_root instance of the database class from syscp with root permissions
|
||||
*/
|
||||
|
||||
public function __construct($settings, $db, $db_root)
|
||||
{
|
||||
$this->db = $db;
|
||||
$this->db_root = $db_root;
|
||||
$this->RootDir = dirname(dirname(__FILE__)) . '/';
|
||||
$this->Hosts = $settings['system']['mysql_access_host'];
|
||||
}
|
||||
|
||||
/**
|
||||
* main function of class which handles all
|
||||
*/
|
||||
|
||||
public function InstallHandler()
|
||||
{
|
||||
chdir($this->RootDir);
|
||||
$result = $this->db->query('SELECT * FROM `' . TABLE_APS_TASKS . '` AS `t` INNER JOIN `' . TABLE_APS_INSTANCES . '` AS `i` ON `t`.`InstanceID` = `i`.`ID` INNER JOIN `' . TABLE_APS_PACKAGES . '` AS `p` ON `i`.`PackageID` = `p`.`ID` INNER JOIN `' . TABLE_PANEL_CUSTOMERS . '` AS `c` ON `i`.`CustomerID` = `c`.`customerid` WHERE `TASK` NOT IN (' . TASK_SYSTEM_UPDATE . ', ' . TASK_SYSTEM_DOWNLOAD . ')');
|
||||
|
||||
while($Row = $this->db->fetch_array($result))
|
||||
{
|
||||
//check for existing aps xml file
|
||||
|
||||
if(!file_exists($this->RootDir . 'packages/' . $Row['Path'] . '/APP-META.xml'))
|
||||
{
|
||||
$this->db->query('UPDATE `' . TABLE_APS_INSTANCES . '` SET `Status` = ' . INSTANCE_ERROR . ' WHERE `ID` = ' . $this->db->escape($Row['InstanceID']));
|
||||
continue;
|
||||
}
|
||||
|
||||
//get contents and parse them
|
||||
|
||||
$XmlContent = file_get_contents($this->RootDir . 'packages/' . $Row['Path'] . '/APP-META.xml');
|
||||
$Xml = new SimpleXMLElement($XmlContent);
|
||||
|
||||
//check for unparseable xml data
|
||||
|
||||
if($Xml == false)
|
||||
{
|
||||
$this->db->query('UPDATE `' . TABLE_APS_INSTANCES . '` SET `Status` = ' . INSTANCE_ERROR . ' WHERE `ID` = ' . $this->db->escape($Row['InstanceID']));
|
||||
continue;
|
||||
}
|
||||
|
||||
$Task = $Row['Task'];
|
||||
$this->DomainPath = '';
|
||||
$this->Domain = '';
|
||||
$this->RealPath = '';
|
||||
|
||||
//lock instance so installation cannot be canceled from the panel
|
||||
|
||||
$this->db->query('UPDATE `' . TABLE_APS_INSTANCES . '` SET `Status` = ' . INSTANCE_TASK_ACTIVE . ' WHERE `ID` = ' . $this->db->escape($Row['InstanceID']));
|
||||
|
||||
//setup environment with data for domain/installation location
|
||||
|
||||
self::PrepareBasics($Row);
|
||||
|
||||
//create database if necessary and setup environment variables
|
||||
|
||||
self::PrepareDatabase($Xml, $Row, $Task);
|
||||
|
||||
//unpack installation scripts and package files if necessary
|
||||
|
||||
if(self::PrepareFiles($Xml, $Row, $Task))
|
||||
{
|
||||
//setup environment variables fetched from installation wizard
|
||||
|
||||
self::PrepareWizardData($Xml, $Row, $Task);
|
||||
|
||||
//run installation scripts from packages
|
||||
|
||||
self::RunInstaller($Xml, $Row, $Task);
|
||||
}
|
||||
|
||||
//remove installation scripts
|
||||
|
||||
self::CleanupData($Xml, $Row, $Task);
|
||||
unset($Xml);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* run the installation script and log errors if there are some
|
||||
*
|
||||
* @param xml instance of a valid xml object with a parsed APP-META.xml file
|
||||
* @param row current entry from the database for app to handle
|
||||
* @param task numeric code to specify what to do
|
||||
* @return success true/error false
|
||||
*/
|
||||
|
||||
private function RunInstaller($Xml, $Row, $Task)
|
||||
{
|
||||
//installation
|
||||
|
||||
if($Task == TASK_INSTALL)
|
||||
{
|
||||
//setup right path and run installation script
|
||||
|
||||
chdir($this->RealPath . $this->DomainPath . '/install_scripts/');
|
||||
$Return = array();
|
||||
$ReturnStatus = 0;
|
||||
$Return = safe_exec('php ' . escapeshellcmd($this->RealPath . $this->DomainPath . '/install_scripts/configure install'), $ReturnStatus);
|
||||
|
||||
if($ReturnStatus != 0)
|
||||
{
|
||||
//write output of script on error into database for admin
|
||||
|
||||
$Buffer = '';
|
||||
$Count = 0;
|
||||
foreach($Return as $Line)
|
||||
{
|
||||
$Count+= 1;
|
||||
$Buffer.= $Line;
|
||||
|
||||
if($Count != count($Return))$Buffer.= "\n";
|
||||
}
|
||||
|
||||
//FIXME error logging
|
||||
|
||||
echo ("error : installer\n" . $Buffer . "\n");
|
||||
$this->db->query('UPDATE `' . TABLE_APS_INSTANCES . '` SET `Status` = ' . INSTANCE_ERROR . ' WHERE `ID` = ' . $this->db->escape($Row['InstanceID']));
|
||||
return false;
|
||||
}
|
||||
else
|
||||
{
|
||||
//installation succeeded
|
||||
//chown all files if installtion script has created some new files. otherwise customers cannot edit the files via ftp
|
||||
|
||||
safe_exec('chown ' . (int)$Row['guid'] . ':' . (int)$Row['guid'] . ' -R ' . escapeshellarg($this->RealPath . $this->DomainPath . '/'));
|
||||
|
||||
//update database
|
||||
|
||||
$this->db->query('UPDATE `' . TABLE_APS_INSTANCES . '` SET `Status` = ' . INSTANCE_SUCCESS . ' WHERE `ID` = ' . $this->db->escape($Row['InstanceID']));
|
||||
return true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* remove installation scripts from filesystem and remove tasks and update the database
|
||||
*
|
||||
* @param xml instance of a valid xml object with a parsed APP-META.xml file
|
||||
* @param row current entry from the database for app to handle
|
||||
* @param task numeric code to specify what to do
|
||||
*/
|
||||
|
||||
private function CleanupData($Xml, $Row, $Task)
|
||||
{
|
||||
chdir($this->RootDir);
|
||||
|
||||
if($Task == TASK_INSTALL)
|
||||
{
|
||||
//cleanup installation
|
||||
|
||||
self::UnlinkRecursive($this->RealPath . $this->DomainPath . '/install_scripts/');
|
||||
|
||||
//remove task
|
||||
|
||||
$this->db->query('DELETE FROM `' . TABLE_APS_TASKS . '` WHERE `Task` = ' . TASK_INSTALL . ' AND `InstanceID` = ' . $this->db->escape($Row['InstanceID']));
|
||||
}
|
||||
elseif($Task == TASK_REMOVE)
|
||||
{
|
||||
//FIXME cleanup installation
|
||||
//remove files from: $this->RealPath . $this->DomainPath . '/'
|
||||
//remove permissions
|
||||
//drop database
|
||||
|
||||
$XmlDb = $Xml->requirements->children('http://apstandard.com/ns/1/db');
|
||||
|
||||
if($XmlDb->db->id)
|
||||
{
|
||||
//database management
|
||||
|
||||
$Database = 'web' . $Row['CustomerID'] . 'aps' . $Row['InstanceID'];
|
||||
foreach(array_map('trim', explode(',', $this->Hosts)) as $DatabaseHost)
|
||||
{
|
||||
$this->db_root->query('REVOKE ALL PRIVILEGES ON * . * FROM `' . $this->db->escape($Database) . '`@`' . $this->db->escape($DatabaseHost) . '`');
|
||||
$this->db_root->query('REVOKE ALL PRIVILEGES ON `' . $this->db->escape($Database) . '` . * FROM `' . $this->db->escape($Database) . '`@`' . $this->db->escape($DatabaseHost) . '`');
|
||||
$this->db_root->query('DELETE FROM `mysql`.`user` WHERE `User` = "' . $this->db->escape($Database) . '" AND `Host` = "' . $this->db->escape($DatabaseHost) . '"');
|
||||
}
|
||||
|
||||
$this->db_root->query('DROP DATABASE IF EXISTS `' . $this->db->escape($Database) . '`');
|
||||
$this->db_root->query('FLUSH PRIVILEGES');
|
||||
}
|
||||
|
||||
//remove task & delete package instance + settings
|
||||
|
||||
$this->db->query('DELETE FROM `' . TABLE_APS_TASKS . '` WHERE `Task` = ' . TASK_REMOVE . ' AND `InstanceID` = ' . $this->db->escape($Row['InstanceID']));
|
||||
$this->db->query('DELETE FROM `' . TABLE_APS_INSTANCES . '` WHERE `ID` = ' . $this->db->escape($Row['InstanceID']));
|
||||
$this->db->query('DELETE FROM `' . TABLE_APS_SETTINGS . '` WHERE `InstanceID` = ' . $this->db->escape($Row['InstanceID']));
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* setup all environment variables from the wizard, they're all needed by the installation script
|
||||
*
|
||||
* @param xml instance of a valid xml object with a parsed APP-META.xml file
|
||||
* @param row current entry from the database for app to handle
|
||||
* @param task numeric code to specify what to do
|
||||
*/
|
||||
|
||||
private function PrepareWizardData($Xml, $Row, $Task)
|
||||
{
|
||||
//data collected by wizard
|
||||
//FIXME install_only parameter/reconfigure
|
||||
|
||||
$result = $this->db->query('SELECT * FROM `' . TABLE_APS_SETTINGS . '` WHERE `InstanceID` = ' . $this->db->escape($Row['InstanceID']));
|
||||
|
||||
while($Row2 = $this->db->fetch_array($result))
|
||||
{
|
||||
//skip APS internal data
|
||||
|
||||
if($Row2['Name'] == 'main_location'
|
||||
|| $Row2['Name'] == 'main_domain'
|
||||
|| $Row2['Name'] == 'main_database_password'
|
||||
|| $Row2['Name'] == 'license')continue;
|
||||
putenv('SETTINGS_' . $Row2['Name'] . '=' . $Row2['Value']);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* extract all needed files from the aps packages
|
||||
*
|
||||
* @param xml instance of a valid xml object with a parsed APP-META.xml file
|
||||
* @param row current entry from the database for app to handle
|
||||
* @param task numeric code to specify what to do
|
||||
* @return success true/error false
|
||||
*/
|
||||
|
||||
private function PrepareFiles($Xml, $Row, $Task)
|
||||
{
|
||||
if($Task == TASK_INSTALL)
|
||||
{
|
||||
//FIXME truncate customer directory
|
||||
//remove files from: $this->RealPath . $this->DomainPath . '/*'
|
||||
|
||||
if(!file_exists($this->RealPath . $this->DomainPath . '/'))mkdir($this->RealPath . $this->DomainPath . '/', 0777, true);
|
||||
|
||||
//extract all files and chown them to the customer guid
|
||||
|
||||
if(self::ExtractZip($this->RootDir . 'packages/' . $Row['Path'] . '/' . $Row['Path'], $Xml->mapping['path'], $this->RealPath . $this->DomainPath . '/') == false
|
||||
|| self::ExtractZip($this->RootDir . 'packages/' . $Row['Path'] . '/' . $Row['Path'], 'scripts', $this->RealPath . $this->DomainPath . '/install_scripts/') == false)
|
||||
{
|
||||
$this->db->query('UPDATE `' . TABLE_APS_INSTANCES . '` SET `Status` = ' . INSTANCE_ERROR . ' WHERE `ID` = ' . $this->db->escape($Row['InstanceID']));
|
||||
|
||||
//FIXME clean up already installed data
|
||||
//remove files from: $this->RealPath . $this->DomainPath . '/*'
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
safe_exec('chown ' . (int)$Row['guid'] . ':' . (int)$Row['guid'] . ' -R ' . escapeshellarg($this->RealPath . $this->DomainPath . '/'));
|
||||
}
|
||||
else
|
||||
{
|
||||
if(self::ExtractZip($this->RootDir . 'packages/' . $Row['Path'] . '/' . $Row['Path'], 'scripts', $this->RealPath . $this->DomainPath . '/install_scripts/') == false)
|
||||
{
|
||||
$this->db->query('UPDATE `' . TABLE_APS_INSTANCES . '` SET `Status` = ' . INSTANCE_ERROR . ' WHERE `ID` = ' . $this->db->escape($Row['InstanceID']));
|
||||
|
||||
//clean up already installed data
|
||||
|
||||
self::UnlinkRecursive($this->RealPath . $this->DomainPath . '/install_scripts/');
|
||||
return false;
|
||||
}
|
||||
|
||||
//set right file owner
|
||||
|
||||
safe_exec('chown ' . (int)$Row['guid'] . ':' . (int)$Row['guid'] . ' -R ' . escapeshellarg($this->RealPath . $this->DomainPath . '/'));
|
||||
}
|
||||
|
||||
//recursive mappings
|
||||
|
||||
self::PrepareMappings($Xml->mapping, $Xml->mapping['url'], $this->RealPath . $this->DomainPath . '/');
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* setup path environment variables for the installation script
|
||||
*
|
||||
* @param parentmapping instance of parsed xml file, current mapping position
|
||||
* @param url relative path for application specifying the current path within the mapping tree
|
||||
* @param path absolute path for application specifying the current path within the mapping tree
|
||||
*/
|
||||
|
||||
private function PrepareMappings($ParentMapping, $Url, $Path)
|
||||
{
|
||||
//check for special PHP permissions
|
||||
//must be done with xpath otherwise check not possible (XML parser problem with attributes)
|
||||
|
||||
$ParentMapping->registerXPathNamespace('p', 'http://apstandard.com/ns/1/php');
|
||||
$Result = $ParentMapping->xpath('p:permissions');
|
||||
|
||||
if($Result[0]['writable'] == 'true')
|
||||
{
|
||||
//fixing file permissions to writeable
|
||||
|
||||
if(is_dir($Path))
|
||||
{
|
||||
chmod($Path, 0775);
|
||||
}
|
||||
else
|
||||
{
|
||||
chmod($Path, 0664);
|
||||
}
|
||||
}
|
||||
|
||||
if($Result[0]['readable'] == 'false')
|
||||
{
|
||||
//fixing file permissions to non readable
|
||||
|
||||
if(is_dir($Path))
|
||||
{
|
||||
chmod($Path, 0333);
|
||||
}
|
||||
else
|
||||
{
|
||||
chmod($Path, 0222);
|
||||
}
|
||||
}
|
||||
|
||||
//set environment variables
|
||||
|
||||
$EnvVariable = str_replace("/", "_", $Url);
|
||||
putenv('WEB_' . $EnvVariable . '_DIR=' . $Path);
|
||||
|
||||
//resolve deeper mappings
|
||||
|
||||
foreach($ParentMapping->mapping as $Mapping)
|
||||
{
|
||||
//recursive check of other mappings
|
||||
|
||||
if($Url == '/')
|
||||
{
|
||||
self::PrepareMappings($Mapping, $Url . $Mapping['url'], $Path . $Mapping['url']);
|
||||
}
|
||||
else
|
||||
{
|
||||
self::PrepareMappings($Mapping, $Url . '/' . $Mapping['url'], $Path . '/' . $Mapping['url']);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* setup domain environment variables for the installation script
|
||||
*
|
||||
* @param xml instance of a valid xml object with a parsed APP-META.xml file
|
||||
*/
|
||||
|
||||
private function PrepareBasics($Row)
|
||||
{
|
||||
//domain
|
||||
|
||||
$result = $this->db->query('SELECT * FROM `' . TABLE_APS_SETTINGS . '` WHERE `InstanceID` = ' . $this->db->escape($Row['InstanceID']) . ' AND `Name` = "main_domain"');
|
||||
$Row3 = $this->db->fetch_array($result);
|
||||
$result2 = $this->db->query('SELECT * FROM `' . TABLE_PANEL_DOMAINS . '` WHERE `id` = ' . $this->db->escape($Row3['Value']));
|
||||
$Row3 = $this->db->fetch_array($result2);
|
||||
$this->Domain = $Row3['domain'];
|
||||
$this->RealPath = $Row3['documentroot'];
|
||||
|
||||
//location
|
||||
|
||||
$result3 = $this->db->query('SELECT * FROM `' . TABLE_APS_SETTINGS . '` WHERE `InstanceID` = ' . $this->db->escape($Row['InstanceID']) . ' AND `Name` = "main_location"');
|
||||
$Row3 = $this->db->fetch_array($result3);
|
||||
$this->DomainPath = $Row3['Value'];
|
||||
|
||||
//if application is directly installed on domain remove / at the end
|
||||
|
||||
if($this->DomainPath == '')$this->RealPath = substr($this->RealPath, 0, strlen($this->RealPath) - 1);
|
||||
|
||||
//url environment variables
|
||||
|
||||
putenv('BASE_URL_HOST=' . $this->Domain);
|
||||
putenv('BASE_URL_PATH=' . $this->DomainPath . '/');
|
||||
putenv('BASE_URL_SCHEME=http');
|
||||
}
|
||||
|
||||
/**
|
||||
* create a database if necessary and setup environment variables
|
||||
*
|
||||
* @param xml instance of a valid xml object with a parsed APP-META.xml file
|
||||
* @param row current entry from the database for app to handle
|
||||
* @param task numeric code to specify what to do
|
||||
*/
|
||||
|
||||
private function PrepareDatabase($Xml, $Row, $Task)
|
||||
{
|
||||
global $db_root;
|
||||
$XmlDb = $Xml->requirements->children('http://apstandard.com/ns/1/db');
|
||||
|
||||
if($XmlDb->db->id)
|
||||
{
|
||||
//database management
|
||||
|
||||
$NewDatabase = 'web' . $Row['CustomerID'] . 'aps' . $Row['InstanceID'];
|
||||
$result = $this->db->query('SELECT * FROM `' . TABLE_APS_SETTINGS . '` WHERE `InstanceID` = ' . $this->db->escape($Row['InstanceID']) . ' AND `Name` = "main_database_password"');
|
||||
$Row3 = $this->db->fetch_array($result);
|
||||
$DbPassword = $Row3['Value'];
|
||||
|
||||
if($Task == TASK_INSTALL)
|
||||
{
|
||||
$this->db_root->query('DROP DATABASE IF EXISTS `' . $this->db->escape($NewDatabase) . '`');
|
||||
$this->db_root->query('CREATE DATABASE IF NOT EXISTS `' . $this->db->escape($NewDatabase) . '`');
|
||||
foreach(array_map('trim', explode(',', $this->Hosts)) as $DatabaseHost)
|
||||
{
|
||||
$this->db_root->query('GRANT ALL PRIVILEGES ON `' . $this->db->escape($NewDatabase) . '`.* TO `' . $this->db->escape($NewDatabase) . '`@`' . $this->db->escape($DatabaseHost) . '` IDENTIFIED BY \'password\'');
|
||||
$this->db_root->query('SET PASSWORD FOR `' . $this->db->escape($NewDatabase) . '`@`' . $this->db->escape($DatabaseHost) . '` = PASSWORD(\'' . $DbPassword . '\')');
|
||||
}
|
||||
|
||||
$this->db_root->query('FLUSH PRIVILEGES');
|
||||
}
|
||||
|
||||
//get first mysql access host
|
||||
|
||||
$AccessHosts = array_map('trim', explode(',', $this->Hosts));
|
||||
|
||||
//environment variables
|
||||
|
||||
putenv('DB_' . $XmlDb->db->id . '_TYPE=mysql');
|
||||
putenv('DB_' . $XmlDb->db->id . '_NAME=' . $NewDatabase);
|
||||
putenv('DB_' . $XmlDb->db->id . '_LOGIN=' . $NewDatabase);
|
||||
putenv('DB_' . $XmlDb->db->id . '_PASSWORD=' . $DbPassword);
|
||||
putenv('DB_' . $XmlDb->db->id . '_HOST=' . $AccessHosts[0]);
|
||||
putenv('DB_' . $XmlDb->db->id . '_PORT=3306');
|
||||
putenv('DB_' . $XmlDb->db->id . '_VERSION=' . mysql_get_server_info());
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* extract complete directories from a zipfile
|
||||
*
|
||||
* @param filename path to zipfile to extract
|
||||
* @param directory which directory in zipfile to extract
|
||||
* @param destination destination directory for files to extract
|
||||
* @return success true/error false
|
||||
*/
|
||||
|
||||
private function ExtractZip($Filename, $Directory, $Destination)
|
||||
{
|
||||
if(!file_exists($Filename))return false;
|
||||
|
||||
//fix slash notation for correct paths
|
||||
|
||||
if(substr($Directory, -1, 1) == '/')$Directory = substr($Directory, 0, strlen($Directory) - 1);
|
||||
|
||||
if(substr($Destination, -1, 1) != '/')$Destination.= '/';
|
||||
|
||||
//open zipfile to read its contents
|
||||
|
||||
$ZipHandle = zip_open(realpath($Filename));
|
||||
|
||||
if(is_resource($ZipHandle))
|
||||
{
|
||||
while($ZipEntry = zip_read($ZipHandle))
|
||||
{
|
||||
if(substr(zip_entry_name($ZipEntry), 0, strlen($Directory)) == $Directory)
|
||||
{
|
||||
//fix relative path from zipfile
|
||||
|
||||
$NewPath = zip_entry_name($ZipEntry);
|
||||
$NewPath = substr($NewPath, strlen($Directory));
|
||||
|
||||
//directory
|
||||
|
||||
if(substr($NewPath, -1, 1) == '/')
|
||||
{
|
||||
if(!file_exists($Destination . $NewPath))mkdir($Destination . $NewPath, 0777, true);
|
||||
}
|
||||
else
|
||||
{
|
||||
//files
|
||||
|
||||
if(zip_entry_open($ZipHandle, $ZipEntry))
|
||||
{
|
||||
$File = fopen($Destination . $NewPath, "wb");
|
||||
|
||||
if($File)
|
||||
{
|
||||
while($Line = zip_entry_read($ZipEntry))
|
||||
{
|
||||
fwrite($File, $Line);
|
||||
}
|
||||
|
||||
fclose($File);
|
||||
}
|
||||
else
|
||||
{
|
||||
return false;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
zip_close($ZipHandle);
|
||||
return true;
|
||||
}
|
||||
else
|
||||
{
|
||||
$ReturnLines = array();
|
||||
$ReturnVal = - 1;
|
||||
|
||||
//on 64 bit systems the zip functions can fail -> use exec to extract the files
|
||||
|
||||
$ReturnLines = safe_exec('unzip -o -qq ' . escapeshellarg(realpath($Filename)) . ' ' . escapeshellarg($Directory . '/*') . ' -d ' . escapeshellarg(sys_get_temp_dir()), $ReturnVal);
|
||||
|
||||
if($ReturnVal == 0)
|
||||
{
|
||||
//fix absolute structure of extracted data
|
||||
|
||||
if(!file_exists($Destination))mkdir($Destination, 0777, true);
|
||||
safe_exec('cp -Rf ' . sys_get_temp_dir() . '/' . $Directory . '/*' . ' ' . escapeshellarg($Destination));
|
||||
self::UnlinkRecursive(sys_get_temp_dir() . '/' . $Directory . '/');
|
||||
return true;
|
||||
}
|
||||
else
|
||||
{
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
?>
|
||||
3249
lib/classes/aps/class.ApsParser.php
Normal file
3249
lib/classes/aps/class.ApsParser.php
Normal file
File diff suppressed because it is too large
Load Diff
269
lib/classes/aps/class.ApsUpdater.php
Normal file
269
lib/classes/aps/class.ApsUpdater.php
Normal file
@@ -0,0 +1,269 @@
|
||||
<?php
|
||||
|
||||
/**
|
||||
* Implementation of the Application Packaging Standard from SwSoft/Parallels
|
||||
* http://apsstandard.com
|
||||
*
|
||||
* Copyright (c) 2003-2009 the SysCP 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.syscp.org/misc/COPYING.txt
|
||||
*
|
||||
* @copyright (c) the authors
|
||||
* @author Sven Skrabal <info@nexpa.de>
|
||||
* @license GPLv2 http://files.syscp.org/misc/COPYING.txt
|
||||
* @package Cron
|
||||
* @version $Id: class.ApsUpdater.php 2724 2009-06-07 14:18:02Z flo $
|
||||
* @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 $db = false;
|
||||
private $RequestDomain = '';
|
||||
private $RootUrl = '';
|
||||
private $RootDir = '';
|
||||
|
||||
/**
|
||||
* constructor of class. setup some basic variables needed by class
|
||||
*
|
||||
* @param db instance of the database class from syscp
|
||||
*/
|
||||
|
||||
public function __construct($db)
|
||||
{
|
||||
$this->db = $db;
|
||||
$this->RequestDomain = 'apscatalog.com';
|
||||
$this->RootUrl = '/1/';
|
||||
$this->RootDir = dirname(dirname(__FILE__)) . '/';
|
||||
}
|
||||
|
||||
/**
|
||||
* Main function of class which handles all around the update mechanism
|
||||
*/
|
||||
|
||||
public function UpdateHandler()
|
||||
{
|
||||
chdir($this->RootDir);
|
||||
|
||||
//return if allow_url_fopen is disabled
|
||||
|
||||
if(ini_get('allow_url_fopen') == '0')
|
||||
{
|
||||
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 = $this->db->query('SELECT * FROM `' . TABLE_APS_TASKS . '` WHERE `Task` IN (' . TASK_SYSTEM_UPDATE . ', ' . TASK_SYSTEM_DOWNLOAD . ')');
|
||||
|
||||
if($this->db->num_rows($Result) == 0)
|
||||
{
|
||||
return;
|
||||
}
|
||||
|
||||
//query first task -> updater can only do one job within a run
|
||||
|
||||
$Task = $this->db->fetch_array($Result);
|
||||
$this->db->query('DELETE FROM `' . TABLE_APS_TASKS . '` WHERE `Task` = ' . $Task['Task']);
|
||||
|
||||
//fetch all vendors
|
||||
|
||||
$Vendors = self::FetchSubUrls($this->RootUrl);
|
||||
foreach($Vendors as $Vendor)
|
||||
{
|
||||
//fetch all applications from vendors
|
||||
|
||||
$Applications = self::FetchSubUrls($this->RootUrl . $Vendor);
|
||||
foreach($Applications as $Application)
|
||||
{
|
||||
//get newest version of package which is already installed
|
||||
|
||||
$CurrentVersion = '';
|
||||
$Result = $this->db->query('SELECT * FROM `' . TABLE_APS_PACKAGES . '` WHERE `Name` = "' . $this->db->escape(substr($Application, 0, -1)) . '"');
|
||||
|
||||
while($Row = $this->db->fetch_array($Result))
|
||||
{
|
||||
if(version_compare($Row['Version'] . '-' . $Row['Release'], $CurrentVersion) == 1)
|
||||
{
|
||||
$CurrentVersion = $Row['Version'] . '-' . $Row['Release'];
|
||||
}
|
||||
}
|
||||
|
||||
if($this->db->num_rows($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);
|
||||
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
|
||||
|
||||
$Url = str_replace(' ', '%20', $Url);
|
||||
|
||||
//get content from website url
|
||||
|
||||
$Content = @file_get_contents('http://' . $this->RequestDomain . $Url . '.aps' . $Downloads[0]);
|
||||
|
||||
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);
|
||||
|
||||
//get content from website url
|
||||
|
||||
$Content = @file('http://' . $this->RequestDomain . $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;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
?>
|
||||
Reference in New Issue
Block a user