'.
$this->l('The module was successfully installed (').
''.$this->l('configure').''.
$this->l(') but the following file already exist. Please, merge the file manually.').''. implode('
', $errors). '
'.
$this->l('The module was successfully installed (').
''.$this->l('configure').''.
$this->l(') but the following file already exist. Please, merge the file manually.').'
'.
$this->l('You have compatibility issues, please fix them before using the module.').'',
'#FFD8D8');
$zones = $this->_api->listZones('pullzone');
if ($this->_api->getLastFaultCode())
{
$ret = array('
'.$this->l('Connection Test Failed.').'',
'#FFD8D8', false);
Configuration::updateValue('CLOUDCACHE_API_ACTIVE', 0);
return $ret;
}
$defaultName = $this->l('prestashop');
// Check if default zone exists
for ($i = 0; $i < count($zones); $i++)
if ($zones[$i]['name'] == $defaultName)
{
$defaultName .= rand(1, 999);
$i = 0;
}
$newZone = false;
// If there is no zones, then create the default one
if (!count($zones) || !Configuration::get('CLOUDCACHE_API_COMPANY_ID'))
{
$origin = (Configuration::get('PS_SSL_ENABLED') ? 'https://' : 'http://').Configuration::get('PS_SHOP_DOMAIN');
$r = $this->createZone('pullzone', array(
'name' => $defaultName,
'origin' => $origin,
'compress' => 1,
));
if (is_array($r))
{
Db::getInstance()->Execute('UPDATE `'._DB_PREFIX_.'cloudcache_zone` SET `name` = \''.pSQL($defaultName).'\', `origin` = \''.pSQL($origin).'\', `compress` = \'1\', `file_type` = \''.pSQL(CLOUDCACHE_FILE_TYPE_ALL).'\', `cdn_url` = \''.pSQL($r['cdn_url']).'\' WHERE `id_zone` = '.(int)$r['id']);
$tmp = substr($r['cdn_url'], strlen($defaultName) + 1);
$companyId = substr($tmp, 0, strlen('netdna-cdn.com') * -1 - 1);
Configuration::updateValue('CLOUDCACHE_API_COMPANY_ID', $companyId);
}
else // If failure, the zonename has probably been taken
{
$defaultName .= rand(1, 999);
$r = $this->createZone('pullzone', array(
'name' => $defaultName,
'origin' => $origin,
'compress' => 1,
));
if (is_array($r))
{
Db::getInstance()->Execute('UPDATE `'._DB_PREFIX_.'cloudcache_zone` SET `name` = \''.pSQL($defaultName).'\', `origin` = \''.pSQL($origin).'\', `compress` = \'1\', `file_type` = \''.pSQL(CLOUDCACHE_FILE_TYPE_ALL).'\', `cdn_url` = \''.pSQL($r['cdn_url']).'\' WHERE `id_zone` = '.(int)$r['id']);
$tmp = substr($r['cdn_url'], strlen($defaultName) + 1);
$companyId = substr($tmp, 0, strlen('netdna-cdn.com') * -1 - 1);
Configuration::updateValue('CLOUDCACHE_API_COMPANY_ID', $companyId);
}
else
return array('
'.$this->l('An error occured, impossible to create a default zone.').'', '#FFD8D8', true);
}
$newZone = $tmp;
}
Configuration::updateValue('CLOUDCACHE_API_ACTIVE', 1);
$ret = array('
'.$this->l('Register').' '.
Configuration::get('PS_SHOP_DOMAIN').' '.
$this->l('on Cloudcache').').
')
', '#D6F5D6', true);
if ($newZone)
$ret['newZone'] = $origin;
return $ret;
}
/*
** Display a custom message for settings update
** $text string Text to be displayed in the message
** $type string (confirm|warn|error) Decides what color will the
** message have (green|yellow)
*/
private function _displayConfirmation($text = '', $type = 'confirm')
{
switch ($type)
{
case 'confirm':
$img = 'ok.gif';
break ;
case 'warn':
$img = 'warn2.png';
break ;
case 'error':
$img = 'disabled.gif';
break ;
default:
die('Invalid type.');
}
return array(
'class' => Tools::safeOutput($type),
'img' => Tools::safeOutput($img),
'text' => (empty($text) ? $this->l('Settings updated') : $text)
);
}
/******************************************************************/
/** Tools methods *************************************************/
/******************************************************************/
function getCurrentURL($htmlEntities = false)
{
$url = $_SERVER['SERVER_NAME'].$_SERVER['REQUEST_URI'];
return (!empty($_SERVER['HTTPS']) ? 'https' : 'http').
'://'.($htmlEntities ? preg_replace('/&/', '&', $url): $url);
}
/**
* @brief Retrieve the bandwith from the selected zone and date range.
*
* @param zoneId Zone Id from which we want to retrieve data
* @param range Range to retrieve (daily, weekly, monthly)
*
* @return Bandwith spent by the selecte zone between the wanted date range.
*/
private function _getZoneTransfer($zoneId, $range)
{
// Associate a range with real date
$allowedRange = array(
'daily' => date('Y-m-d',
mktime(0, 0, 0, date('n'), date('j') - 1, date('Y'))),
'weekly' => date('Y-m-d',
mktime(0, 0, 0, date('n'), date('j') - 7, date('Y'))),
'monthly' => date('Y-m-d',
mktime(0, 0, 0, date('n') - 1, date('j'), date('Y'))),
);
// Retrieve today's date
$today = date('Y-m-d');
// We check the range is correct
if (!array_key_exists($range, $allowedRange))
return -1;
$companyId = Configuration::get('CLOUDCACHE_API_COMPANY_ID');
// Retrieve the data from the server
$r = $this->_api->getTotalTransferStats('report', $companyId, $zoneId,
$allowedRange[$range], $today);
// Check if the transaction went well
if ($this->_api->getLastFaultCode())
return -1;
return 0;
}
/**
* @brief Retrieves Zones from Cloudcache Server and sync with local data
*
* @param type Namespace of the zones to retrieve (pullzone, pushzone, etc)
*
* @return Array describing the zones.
*/
private function _syncZonesWithServer($type)
{
// Send the request to the API server
$cdnZones = array();
if ($type == 'all')
foreach ($this->_api->getAvailableNamespaces() as $namespace)
$cdnZones[$namespace] = $this->_api->listZones($namespace);
else
$cdnZones[$type] = $this->_api->listZones($type);
$zones = array();
// Check if the transaction went well
if (!$this->_api->getLastFaultCode())
{
// Build our custom array from the retieved data
foreach ($cdnZones as $namespace => $cdnZone)
{
foreach ($cdnZone as $zone)
{
$exists = false;
$row = Db::getInstance()->getRow('SELECT `id_zone`, `id_shop`, `origin`, `cdn_url`, `file_type` FROM `'._DB_PREFIX_.'cloudcache_zone` WHERE `id_zone` = '.(int)$zone['id']);
if ($row['id_zone'])
$exists = true;
if ($exists && $row['id_shop'] != $this->context->shop->id)
continue ;
$zones[(int)$zone['id']] = array(
'id_zone' => (int)$zone['id'],
'name' => pSQL($zone['name']),
'origin' => pSQL($exists ? $row['origin'] : $this->l('no data')),
'cdn_url' => pSQL($exists ? $row['cdn_url'] : $this->l('no data')),
'bw_yesterday' => (int)$this->_getZoneTransfer($zone['id'], 'daily'),
'bw_last_week' => (int)$this->_getZoneTransfer($zone['id'], 'weekly'),
'bw_last_month' => (int)$this->_getZoneTransfer($zone['id'], 'monthly'),
'file_type' => pSQL($exists ? $row['file_type'] : 'none'),
'zone_type' => pSQL($namespace),
'id_shop' => (int)$this->context->shop->id,
'id_group_shop' => (int)$this->context->shop->id_group_shop,
);
}
}
// For each zone, update or insert the new data in the database
foreach ($zones as $id_zone => $zone_data)
if ($zone_data['zone_type'] != 'all')
Db::getInstance()->Execute('REPLACE INTO `'._DB_PREFIX_.'cloudcache_zone`
(`'.implode('`,`', array_keys($zone_data)).'`)
VALUES (\''.implode('\', \'', $zone_data).'\')');
return $zones;
}
return false;
}
/**
* @brief Get Zones from the selected zone type.
*
* If the sync flag is setted to true, then retrieve data from Cloudcache servers.
*
* @note Function call thru ajax
*
* @param type Type of zone (Cloudcache namespace)
* @param sync Flag to know if we should ask the Cloudcache servers.
*
* @return Array describing the zones
*/
public function getZones($type, $sync = false)
{
// Check that the $type is correct an harmless for the database
if (!in_array($type, $this->_api->getAvailableNamespaces()))
return $this->context->smarty->assign('confirmMessage',
$this->_displayConfirmation($this->l('Invalid zone type.'), 'error'));
// Check on the database if $sync is false (cache)
$zones = array();
if (!$sync)
{
$d = Db::getInstance()->ExecuteS('
SELECT `id_zone`, `id_shop`, `name`, `origin`, `compress`, `label`, `cdn_url`,
`bw_yesterday`, `bw_last_week`, `bw_last_month`, `file_type`, `zone_type`
FROM `'._DB_PREFIX_.'cloudcache_zone`
WHERE `zone_type` = \''.pSQL($type).'\' AND `id_shop` = '.(int)$this->context->shop->id);
foreach ($d as $line)
$zones[$line['id_zone']] = $line;
}
// if no result or if $sync, load data from API server
if (($sync || !count($zones)) && Configuration::get('CLOUDCACHE_API_ACTIVE'))
$zones = $this->_syncZonesWithServer($type);
// Return the data array
return $zones;
}
/**
* @brief Create a Zone on the Cloudcache Server.
*
* First create the zone thru the API then call the sync function in order to
* update the local data.
*
* @param type Type of the zone (pullzone, pushzone, etc)
* @param values Array describing the zone.
*
* @return True if everything went well, False otherwise
*/
public function createZone($type, $values)
{
// Check that the $type is correct an harmless for the database
if (!in_array($type, $this->_api->getAvailableNamespaces()))
return $this->context->smarty->assign('confirmMessage',
$this->_displayConfirmation($this->l('Invalid zone type.'), 'error'));
// Create the basic zone data
$zone = array(
'name' => pSQL($values['name']),
'origin' => pSQL($values['origin']),
);
// If an optional field is set, add it to the zone
$optionalFields = array('vanity_domain', 'vhost',
'ip', 'compress', 'label');
foreach ($optionalFields as $field)
if (isset($values[$field]) && !empty($values[$field]))
$zone[$field] = pSQL($values[$field]);
// Then send the request to the server
// The server return an array with the new id, vanity_ip and cdn_url
$r = $this->_api->createZone($type, $zone);
// Check if the transaction went well and return result
if ($this->_api->getLastFaultCode())
return $this->_api->getLastFaultString();
/* // Insert the new zone in database */
/* if ($this->_updateZoneSql($r, 'CRE)) */
/* return $this->context->smarty->assign('confirmMessage', */
/* $this->_displayConfirmation($this->l('Unknown internal error.'), 'error')); */
// Sync
$this->_syncZonesWithServer($type);
return $r;
}
/**
* @brief Update the selected zone.
*
* @param type Type of the zone (namespace)
* @param values Values of the updated zone
*
* @return True if OK, false otherwise.
*/
public function updateZone($type, $values)
{
// Check that the $type is correct an harmless for the database
if (!in_array($type, $this->_api->getAvailableNamespaces()))
return $this->context->smarty->assign('confirmMessage',
$this->_displayConfirmation($this->l('Invalid zone type.'), 'error'));
// Create the basic zone data
$zone = array(
'id' => (int)$values['id_zone'],
);
$optionalFields = array('name', 'origin', 'vhost', 'ip', 'compress', 'label');
foreach ($optionalFields as $field)
if (isset($values[$field]) && !empty($values[$field]))
$zone[$field] = pSQL($values[$field]);
// The updateZone return a bool success/error
$r = $this->_api->updateZone($type, (int)$values['id_zone'], $zone);
// Check if the transaction went well
if ($this->_api->getLastFaultCode())
return ; //die('KO '.pSQL($this->_api->getLastFaultString())); // pSQL for XSS
return $r;
}
/**
* @brief Retrieve the paid Bandwith left
*
* @return The bandwith left.
*/
public function getPrepaidBandwidth()
{
// The namespace need to retrieve the bandwith is 'account'
// The server reply the amount of bandwith left
$r = $this->_api->getBandwidth('account');
// Check if the transaction went well
if ($this->_api->getLastFaultCode())
return $this->l('N/A');
// $r /= (1024 * 1024 * 1024 * 1024);
$r /= (1000 * 1000 * 1000 * 1000);
return round($r, 2);
}
}