Server : Apache System : Linux indy02.toastserver.com 3.10.0-962.3.2.lve1.5.85.el7.x86_64 #1 SMP Thu Apr 18 15:18:36 UTC 2024 x86_64 User : palandch ( 1163) PHP Version : 7.1.33 Disable Function : NONE Directory : /home/palandch/www/core/xpdo/transport/ |
<?php
/*
* Copyright 2010-2013 by MODX, LLC.
*
* This file is part of xPDO.
*
* xPDO is free software; you can redistribute it and/or modify it under the
* terms of the GNU General Public License as published by the Free Software
* Foundation; either version 2 of the License, or (at your option) any later
* version.
*
* xPDO is distributed in the hope that it will be useful, but WITHOUT ANY
* WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
* A PARTICULAR PURPOSE. See the GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License along with
* xPDO; if not, write to the Free Software Foundation, Inc., 59 Temple Place,
* Suite 330, Boston, MA 02111-1307 USA
*/
/**
* Defines a class that represents an embedded package within a transportable package.
*
* @package xpdo
* @subpackage transport
*/
/**
* Represents an xPDOTransport embedded within an {@link xPDOTransport} package.
*
* @package xpdo
* @subpackage transport
*/
class xPDOTransportVehicle extends xPDOVehicle {
public $class = 'xPDOTransportVehicle';
/**
* Copies the transport into the vehicle and transforms the payload for storage.
*/
protected function _compilePayload(& $transport) {
parent :: _compilePayload($transport);
$body = array ();
$cacheManager = $transport->xpdo->getCacheManager();
if ($cacheManager) {
if (isset($this->payload['object'])) {
$object = $this->payload['object'];
$fileSource = $object['source'];
$body['source'] = $transport->signature . '/' . $this->payload['class'] . '/' . $this->payload['signature'] . '/';
$fileTarget = $transport->path . $body['source'];
$body['target'] = $object['target'];
$fileName = isset ($object['name']) ? $object['name'] : basename($fileSource);
$body['name'] = $fileName;
if (!is_writable($fileTarget)) {
$cacheManager->writeTree($fileTarget);
}
if (file_exists($fileSource) && is_writable($fileTarget)) {
$copied = false;
if (is_file($fileSource)) {
$copied = $cacheManager->copyFile($fileSource, $fileTarget . $fileName);
}
if (!$copied) {
$transport->xpdo->log(xPDO::LOG_LEVEL_ERROR, "Could not copy file from {$fileSource} to {$fileTarget}{$fileName}");
$body = null;
}
} else {
$transport->xpdo->log(xPDO::LOG_LEVEL_ERROR, "Source file {$fileSource} is missing or {$fileTarget} is not writable");
$body = null;
}
}
}
if (!empty($body)) {
$this->payload['object'] = $body;
}
}
/**
* Install the xPDOTransport represented by this vehicle into the transport host.
*/
public function install(& $transport, $options) {
$installed = $this->_installTransport($transport, $options);
return $installed;
}
/**
* Install the xPDOTransport from the vehicle payload.
*
* @param xPDOTransport $transport The host xPDOTransport instance.
* @param array $options Any optional attributes to apply to the installation.
*/
protected function _installTransport(& $transport, $options) {
$installed = false;
$vOptions = $this->get($transport, $options);
if (isset($vOptions['object']) && isset($vOptions['object']['source']) && isset($vOptions['object']['target']) && isset($vOptions['object']['name'])) {
if ($transport->xpdo->getDebug() === true)
$transport->xpdo->log(xPDO::LOG_LEVEL_DEBUG, "Installing Vehicle: " . print_r($vOptions, true));
$state = isset($vOptions['state']) ? $vOptions['state'] : xPDOTransport::STATE_PACKED;
$pkgSource = $transport->path . $vOptions['object']['source'] . $vOptions['object']['name'];
$pkgTarget = eval($vOptions['object']['target']);
$object = xPDOTransport::retrieve($transport->xpdo, $pkgSource, $pkgTarget, $state);
if ($this->validate($transport, $object, $vOptions)) {
$installed = $object->install($vOptions);
if (!$installed) {
$transport->xpdo->log(xPDO::LOG_LEVEL_ERROR, 'Error installing vehicle: ' . print_r($vOptions, true));
}
elseif (!$this->resolve($transport, $object, $vOptions)) {
$transport->xpdo->log(xPDO::LOG_LEVEL_ERROR, 'Could not resolve vehicle: ' . print_r($vOptions, true));
}
} else {
$transport->xpdo->log(xPDO::LOG_LEVEL_ERROR, 'Could not validate vehicle: ' . print_r($vOptions, true));
}
} else {
$transport->xpdo->log(xPDO::LOG_LEVEL_ERROR, 'Could not load vehicle: ' . print_r($vOptions, true));
}
return $installed;
}
/**
* Uninstalls vehicle artifacts from the transport host.
*/
public function uninstall(& $transport, $options) {
$uninstalled = false;
$vOptions = $this->get($transport, $options);
if (isset($vOptions['object']) && isset($vOptions['object']['source']) && isset($vOptions['object']['target']) && isset($vOptions['object']['name'])) {
if ($transport->xpdo->getDebug() === true)
$transport->xpdo->log(xPDO::LOG_LEVEL_DEBUG, "Installing Vehicle: " . print_r($vOptions, true));
$state = isset($vOptions['state']) ? $vOptions['state'] : xPDOTransport::STATE_UNPACKED;
$pkgSource = $transport->path . $vOptions['object']['source'] . $vOptions['object']['name'];
$pkgTarget = eval($vOptions['object']['target']);
$object = xPDOTransport::retrieve($transport->xpdo, $pkgSource, $pkgTarget, $state);
if ($this->validate($transport, $object, $vOptions)) {
$uninstalled = $object->uninstall($vOptions);
if (!$uninstalled) {
$transport->xpdo->log(xPDO::LOG_LEVEL_ERROR, 'Could not uninstall vehicle: ' . print_r($vOptions, true));
}
elseif (!$this->resolve($transport, $object, $vOptions)) {
$transport->xpdo->log(xPDO::LOG_LEVEL_ERROR, 'Could not resolve vehicle: ' . print_r($vOptions, true));
}
} else {
$transport->xpdo->log(xPDO::LOG_LEVEL_ERROR, 'Could not validate vehicle: ' . print_r($vOptions, true));
}
} else {
$transport->xpdo->log(xPDO::LOG_LEVEL_ERROR, 'Could not load vehicle: ' . print_r($vOptions, true));
}
return $uninstalled;
}
/**
* Put an xPDOTransport representation into a transport package.
*/
public function put(& $transport, & $object, $attributes = array ()) {
if (!isset ($this->payload['class'])) {
$this->payload['class'] = 'xPDOTransportVehicle';
}
if (is_array($object) && isset ($object['source']) && isset ($object['target'])) {
if (!isset($object['name'])) $object['name'] = basename($object['source']);
$this->payload['object'] = $object;
}
parent :: put($transport, $object, $attributes);
}
}