View source
<?php
define('NODESQUIRREL_SECRET_KEY_PATTERN', '/^[0-9a-f]{32}\\:?[0-9a-f]{32}$/');
function backup_migrate_nodesquirrel_check_secret_key($secret_key) {
if ($destination = backup_migrate_nodesquirrel_get_destination($secret_key)) {
if ($destination
->confirm_destination()) {
return $destination;
}
}
return FALSE;
}
function backup_migrate_nodesquirrel_get_destination($secret_key) {
if ($secret_key) {
backup_migrate_include('destinations');
$destination = backup_migrate_create_destination('nodesquirrel', array(
'machine_name' => 'nodesquirrel',
));
$destination->settings['secret_key'] = $secret_key;
return $destination;
}
return NULL;
}
function backup_migrate_nodesquirrel_get_activate_help_text() {
$activate_link = backup_migrate_nodesquirrel_get_activate_link();
return array(
'#type' => 'item',
'#title' => t('Need a Secret Key?'),
'#markup' => t('Visit !nodesquirrel.', array(
'!nodesquirrel' => $activate_link,
)),
'#description' => t('Don\'t worry if you don\'t have an account yet. You can create one when you get there.'),
);
}
function backup_migrate_nodesquirrel_get_activate_link() {
$activate_link = l('nodesquirrel.com/activate', variable_get('nodesquirrel_activate_url', 'http://manage.nodesquirrel.com/activate'), array(
'query' => array(
'url' => url('', array(
'absolute' => TRUE,
)),
'email' => variable_get('site_mail', ''),
'configure' => url($_GET['q'], array(
'absolute' => TRUE,
)),
),
));
return $activate_link;
}
function backup_migrate_nodesquirrel_get_manage_link($destination) {
$url = variable_get('nodesquirrel_manage_url', 'https://manage.nodesquirrel.com') . '/backups/' . $destination
->_get_destination();
return l($url, $url);
}
function backup_migrate_nodesquirrel_get_plan_link() {
$url = variable_get('nodesquirrel_manage_url', 'https://manage.nodesquirrel.com') . '/plan';
return l($url, $url);
}
function backup_migrate_nodesquirrel_settings_path() {
$path = BACKUP_MIGRATE_MENU_PATH . '/settings/destinations/nodesquirrel/edit';
return $path;
}
function backup_migrate_nodesquirrel_settings() {
return drupal_get_form('backup_migrate_nodesquirrel_settings_form');
}
function backup_migrate_nodesquirrel_credentials_settings_form($key = '', $status) {
$collapse = !empty($status);
$form['nodesquirrel_credentials'] = array(
'#type' => 'fieldset',
'#title' => t('NodeSquirrel Credentials'),
'#collapsible' => $collapse,
'#collapsed' => $collapse,
);
$form['nodesquirrel_credentials']['nodesquirrel_secret_key'] = array(
'#type' => 'textfield',
'#title' => t('Secret Key'),
'#size' => 80,
'#default_value' => $key,
);
if (empty($key)) {
$form['nodesquirrel_credentials']['secret_key_help'] = backup_migrate_nodesquirrel_get_activate_help_text();
}
return $form;
}
function backup_migrate_nodesquirrel_info_form() {
$form = array();
$form['nodesquirrel_info'] = array(
'#type' => 'fieldset',
'#title' => t('What is NodeSquirrel?'),
);
$form['nodesquirrel_info']['intro'] = array(
'#type' => 'markup',
'#markup' => t('<p>NodeSquirrel is the cloud backup service for Drupal built by the maintainers of Backup and Migrate. It is secure, reliable and affordable.</p><p>NodeSquirrel is a paid service and profits help support Backup and Migrate.</p><p>Find out more at !nodesquirrel</p>', array(
'!nodesquirrel' => l('nodesquirrel.com', 'http://www.nodesquirrel.com'),
'!add' => l(t('add other offsite destinations'), BACKUP_MIGRATE_MENU_PATH . '/destination/list/add'),
'!bam' => l(t('Backup and Migrate project page'), 'http://drupal.org/project/backup_migrate'),
)),
);
return $form;
}
function backup_migrate_nodesquirrel_status_form($key, $destination, $status) {
$form = array();
$form['nodesquirrel_status'] = array(
'#type' => 'fieldset',
'#title' => t('NodeSquirrel Status'),
);
$form['nodesquirrel_status']['status'] = array(
'#type' => 'item',
'#title' => t('NodeSquirrel Status'),
'#markup' => t('Not Configured. Enter your Secret Key below to get started.'),
);
if ($key && empty($status)) {
$form['nodesquirrel_status']['status']['#markup'] = t('Your secret key does not seem to be valid. Please check that you entered it correctly or visit !ns to generate a new key.', array(
'!ns' => backup_migrate_nodesquirrel_get_activate_link(),
));
}
else {
if (!empty($destination) && is_array($status)) {
if (!empty($status['lifetime_backups_used']) && !empty($status['lifetime_backups']) && $status['lifetime_backups_used'] >= $status['lifetime_backups']) {
$form['nodesquirrel_status']['status']['#markup'] = t('Your !num backup trial has expired. Visit !link to continue backing up.', array(
'!num' => $status['lifetime_backups'],
'!link' => backup_migrate_nodesquirrel_get_plan_link(),
));
}
else {
$form['nodesquirrel_status']['status']['#markup'] = t('Ready to Backup');
if (user_access('perform backup')) {
$form['nodesquirrel_status']['status']['#markup'] .= ' ' . l('(' . t('backup now') . ')', BACKUP_MIGRATE_MENU_PATH);
}
}
if (!empty($status['plan_name'])) {
$form['nodesquirrel_status']['plan_name'] = array(
'#type' => 'item',
'#title' => t('Current Plan'),
'#markup' => check_plain($status['plan_name']),
);
if (isset($status['plan_id']) && strpos($status['plan_id'], 'trial') !== FALSE) {
if (isset($status['lifetime_backups']) && isset($status['lifetime_backups_used'])) {
$remains = $status['lifetime_backups'] - $status['lifetime_backups_used'];
$remains = $remains > 0 ? $remains : t('none');
$form['nodesquirrel_status']['plan_name']['#markup'] .= ' ' . t('(@remains remaining of @backups backup trial)', array(
'@backups' => $status['lifetime_backups'],
'@remains' => $remains,
));
}
if (isset($status['lifespan']) && isset($status['age']) && $status['lifespan'] > 0) {
$remains = ceil(($status['lifespan'] - $status['age']) / 86400);
if ($remains <= 0) {
$form['nodesquirrel_status']['plan_name']['#markup'] .= ' ' . t('(Your !span day trial has expired.)', array(
'!span' => ceil($status['lifespan'] / 86400),
));
}
else {
$form['nodesquirrel_status']['plan_name']['#markup'] .= ' ' . format_plural($remains, '(1 day remaining)', '(!span days remaining)', array(
'!span' => ceil($remains),
));
}
}
}
}
if (isset($status['backups_used'])) {
$form['nodesquirrel_status']['backups_used'] = array(
'#type' => 'item',
'#title' => t('Number of Stored Backups'),
'#markup' => $status['backups_used'] == 0 ? t('None') : number_format($status['backups_used']),
);
}
if (isset($status['last_backup'])) {
$form['nodesquirrel_status']['last_backup'] = array(
'#type' => 'item',
'#title' => t('Last Backup'),
'#markup' => empty($status['last_backup']) ? t('Never') : t('!date (!ago ago)', array(
'!date' => format_date($status['last_backup'], 'small'),
'!ago' => format_interval(time() - $status['last_backup'], 1),
)),
);
}
if ($status['bytes_per_locker']) {
if (isset($status['bytes_used'])) {
$form['nodesquirrel_status']['space'] = array(
'#type' => 'item',
'#title' => t('Storage Space'),
'#markup' => t('!used used of !total (!remaining remaining)', array(
'!used' => backup_migrate_format_size($status['bytes_used']),
'!total' => backup_migrate_format_size($status['bytes_per_locker']),
'!remaining' => backup_migrate_format_size(max(0, $status['bytes_per_locker'] - $status['bytes_used'])),
)),
);
}
else {
$form['nodesquirrel_status']['space'] = array(
'#type' => 'item',
'#title' => t('Total Storage Space'),
'#markup' => t('!total', array(
'!total' => backup_migrate_format_size($status['bytes_per_locker']),
)),
);
}
}
$form['nodesquirrel_status']['manage'] = array(
'#type' => 'item',
'#title' => t('Management Console'),
'#markup' => backup_migrate_nodesquirrel_get_manage_link($destination),
'#description' => t('You can use the NodeSquirrel management console to add and edit your sites, reset your secret key, download and delete backups, and modify your NodeSquirrel account.'),
);
}
}
return $form;
}
function backup_migrate_nodesquirrel_schedule_settings_form($destination, $status) {
backup_migrate_include('sources', 'schedules', 'profiles');
$schedule = backup_migrate_crud_get_item('schedule', 'nodesquirrel');
$default = 60 * 60 * 24;
$form = array();
$form['nodesquirrel_schedule'] = array(
'#type' => 'fieldset',
'#title' => t('Backup Schedule'),
'#description' => t('Set up a schedule to back up your site to NodeSquirrel. You can customize this schedule or add additional schedules in the !schedule.', array(
'!schedule' => l(t('Schedules tab'), BACKUP_MIGRATE_MENU_PATH . '/schedule'),
'!cron' => l(t('cron'), 'http://drupal.org/cron'),
)),
);
$key = 'nodesquirrel_schedule';
$form['nodesquirrel_schedule'][$key] = array();
$defaults = array(
'period' => empty($schedule) ? variable_get('nodesquirrel_schedule', 60 * 60 * 24) : $schedule
->get('period'),
'enabled' => empty($schedule) ? variable_get('nodesquirrel_schedule_enabled', TRUE) : $schedule
->get('enabled'),
'source_id' => empty($schedule) ? variable_get('nodesquirrel_schedule_source_id', 'db') : $schedule
->get('source_id'),
);
$form['nodesquirrel_schedule'][$key]['nodesquirrel_schedule_enabled'] = array(
'#type' => 'checkbox',
'#title' => t('Automatically backup to NodeSquirrel'),
'#default_value' => $defaults['enabled'],
);
$form['nodesquirrel_schedule'][$key]['settings'] = array(
'#type' => 'backup_migrate_dependent',
'#dependencies' => array(
'nodesquirrel_schedule_enabled' => TRUE,
),
);
$form['nodesquirrel_schedule'][$key]['settings']['nodesquirrel_schedule_source_id'] = _backup_migrate_get_source_pulldown($defaults['source_id']);
$options = array(
60 * 60 => t('Once an hour'),
60 * 60 * 24 => t('Once a day'),
60 * 60 * 24 * 7 => t('Once a week'),
);
$period = $defaults['period'];
if (!isset($options[$period])) {
$options[$period] = empty($schedule) ? t('Custom') : $schedule
->get('frequency_description');
}
$form['nodesquirrel_schedule'][$key]['settings']['nodesquirrel_schedule'] = array(
'#type' => 'select',
'#title' => t('Schedule Frequency'),
'#options' => $options,
'#default_value' => $period,
);
return $form;
}
function backup_migrate_nodesquirrel_settings_form($form_state) {
_backup_migrate_message_callback('_backup_migrate_message_browser');
$form = array();
$key = variable_get('nodesquirrel_secret_key', '');
$status = array();
if ($destination = backup_migrate_nodesquirrel_get_destination($key)) {
$status = $destination
->check_limits();
}
$form += backup_migrate_nodesquirrel_info_form();
$form += backup_migrate_nodesquirrel_status_form($key, $destination, $status);
$form += backup_migrate_nodesquirrel_credentials_settings_form($key, $status);
$form += backup_migrate_nodesquirrel_schedule_settings_form($destination, $status);
return system_settings_form($form);
}
class backup_migrate_destination_nodesquirrel extends backup_migrate_destination {
var $supported_ops = array(
'scheduled backup',
'manual backup',
'remote backup',
'restore',
'list files',
'configure',
'delete',
);
var $cache_files = TRUE;
var $save_metadata = FALSE;
function get_name() {
if (empty($this->name)) {
return t('NodeSquirrel');
}
return $this->name;
}
function get_menu_items() {
$items = array();
$path = BACKUP_MIGRATE_MENU_PATH . '/nodesquirrel';
$items[$path] = array(
'title' => t('NodeSquirrel'),
'page callback' => 'backup_migrate_menu_callback',
'page arguments' => array(
'destinations.nodesquirrel',
'backup_migrate_nodesquirrel_settings',
),
'access arguments' => array(
'administer backup and migrate',
),
'weight' => 10,
'type' => MENU_LOCAL_TASK,
);
return $items;
}
function destinations() {
$out = array();
$out['nodesquirrel'] = backup_migrate_create_destination('nodesquirrel', array(
'machine_name' => 'nodesquirrel',
));
if ($secret_key = variable_get('nodesquirrel_secret_key', '')) {
$out['nodesquirrel']->settings['secret_key'] = $secret_key;
}
else {
$out['nodesquirrel']->supported_ops = array(
'manual backup',
'remote backup',
);
}
return $out;
}
function before_backup_form($settings) {
$form = array();
$key = $this
->settings('secret_key');
if (empty($key)) {
$form += backup_migrate_nodesquirrel_info_form();
$form += backup_migrate_nodesquirrel_credentials_settings_form();
}
return $form;
}
function before_backup_form_validate($settings, $form, $form_state) {
if (isset($form_state['values']['nodesquirrel_secret_key'])) {
$key = trim($form_state['values']['nodesquirrel_secret_key']);
if ($error = $this
->vaidate_key($key)) {
form_set_error('secret_key', $error);
}
}
}
function before_backup_form_submit($settings, $form, $form_state) {
if (isset($form_state['values']['nodesquirrel_secret_key'])) {
$this->settings['secret_key'] = $form_state['values']['nodesquirrel_secret_key'];
variable_set('nodesquirrel_secret_key', $this->settings['secret_key']);
}
}
function save_file($file, $settings) {
if ($destination = $this
->_get_destination()) {
srand((double) microtime() * 1000000);
$filename = $file
->filename();
$filesize = filesize($file
->filepath());
$ticket = $this
->_xmlrpc('backups.getUploadTicket', array(
$destination,
$filename,
$filesize,
$file->file_info,
));
if ($ticket) {
$url = $ticket['url'];
if (!empty($ticket['auth']) && ($ticket['auth'] = 'basic')) {
$parts = parse_url($ticket['url']);
list($parts['user'], $parts['pass']) = $this
->get_user_pass();
$url = $this
->glue_url($parts, FALSE);
}
$out = $this
->_post_file($url, 'POST', $ticket['params'], $file);
if ($out->code == 200) {
$confirm = $this
->_xmlrpc('backups.confirmUpload', array(
$destination,
$filename,
$filesize,
));
if ($confirm['success']) {
$url = variable_get('nodesquirrel_manage_url', 'http://manage.nodesquirrel.com') . '/backups/' . $this
->_get_destination();
_backup_migrate_message('Your backup has been saved to your NodeSquirrel account. View it at !account', array(
'!account' => l($url, $url),
));
return $file;
}
else {
_backup_migrate_message('The backup file never made it to the NodeSquirrel backup server. There may have been a network problem. Please try again later');
}
}
else {
$error = !empty($out->headers['x-bams-error']) ? $out->headers['x-bams-error'] : $out->error;
_backup_migrate_message('The NodeSquirrel server returned the following error: %err', array(
'%err' => $error,
), 'error');
}
}
else {
if ($err = xmlrpc_error()) {
}
else {
_backup_migrate_message('The NodeSquirrel server refused the backup but did not specify why. Maybe the server is down.');
}
}
}
return NULL;
}
function load_file($file_id) {
if ($destination = $this
->_get_destination()) {
backup_migrate_include('files');
$file = new backup_file(array(
'filename' => $file_id,
));
$ticket = $this
->_xmlrpc('backups.getDownloadTicket', array(
$destination,
$file_id,
));
if ($ticket && ($url = $ticket['url'])) {
if (!empty($ticket['auth']) && ($ticket['auth'] = 'basic')) {
$parts = parse_url($ticket['url']);
$parts['user'] = @$this->dest_url['user'];
$parts['pass'] = @$this->dest_url['pass'];
$url = $this
->glue_url($parts, FALSE);
}
$out = drupal_http_request($url);
if ($out->code == 200) {
file_put_contents($file
->filepath(), $out->data);
return $file;
}
else {
$error = !empty($out->headers['x-bams-error']) ? $out->headers['x-bams-error'] : $out->error;
_backup_migrate_message('The server returned the following error: %err', array(
'%err' => $error,
), 'error');
}
}
}
return NULL;
}
function delete_file($file_id) {
if ($destination = $this
->_get_destination()) {
$result = $this
->_xmlrpc('backups.deleteFile', array(
$destination,
$file_id,
));
}
}
function _list_files() {
$files = array();
backup_migrate_include('files');
if ($destination = $this
->_get_destination()) {
$file_list = $this
->_xmlrpc('backups.listFiles', array(
$destination,
));
foreach ((array) $file_list as $file) {
$files[$file['filename']] = new backup_file($file);
}
}
return $files;
}
function check_limits() {
if (empty($this->limits)) {
$this->limits = $this
->_xmlrpc('backups.getLimits', array(
$this
->_get_destination(),
));
}
return $this->limits;
}
function confirm_destination() {
return $this
->check_limits();
}
function edit_form() {
$form = parent::edit_form();
if (!$this
->get_id() && !variable_get('nodesquirrel_secret_key', '')) {
drupal_goto(BACKUP_MIGRATE_MENU_PATH . '/nodesquirrel');
}
$form['settings'] = array(
'#tree' => TRUE,
);
$activate_link = backup_migrate_nodesquirrel_get_activate_link();
$key = $this
->settings('secret_key');
if (!empty($_GET['key']) && preg_match(NODESQUIRREL_SECRET_KEY_PATTERN, $_GET['key'])) {
$key = $_GET['key'];
}
$form['settings']['secret_key'] = array(
'#type' => 'textfield',
'#title' => t('Secret Key'),
'#default_value' => $key,
);
$form['settings']['location'] = array(
'#type' => 'value',
'#value' => '',
);
$form['settings']['secret_key_help'] = array(
'#type' => 'item',
'#title' => t('Need a Secret Key?'),
'#markup' => t('Visit !nodesquirrel.', array(
'!nodesquirrel' => $activate_link,
)),
);
return $form;
}
function edit_form_validate($form, &$form_state) {
$key = trim($form_state['values']['settings']['secret_key']);
if ($error = $this
->vaidate_key($key)) {
form_set_error('secret_key', $error);
}
}
function vaidate_key($key) {
$error = FALSE;
if ($key) {
if (!preg_match(NODESQUIRREL_SECRET_KEY_PATTERN, $key)) {
return 'The secret key you entered is not the right format. Please make sure you copy it exactly.';
}
$this->settings['secret_key'] = check_plain($key);
$limits = $this
->check_limits();
if (!$limits) {
$err = xmlrpc_error();
if (!empty($err->code) && $err->code == '401') {
return 'Could not log in to the NodeSquirrel server. Please check that your secret key is correct.';
}
else {
return 'Your site could not be found on NodeSquirrel. Please check that your secret key is correct.';
}
}
}
else {
return 'You must enter a NodeSquirrel secret key.';
}
return FALSE;
}
function edit_form_submit($form, &$form_state) {
$form_state['values']['secret_key'] = check_plain($form_state['values']['settings']['secret_key']);
parent::edit_form_submit($form, $form_state);
}
function _get_destination($warn = TRUE) {
list($id, $key) = $this
->get_user_pass();
return $id;
}
function _get_private_key($warn = TRUE) {
list($id, $key) = $this
->get_user_pass();
return $key;
}
function get_user_pass() {
$key = $this
->settings('secret_key');
$user = substr($key, 0, 32);
$pass = substr($key, strlen($key) - 32);
return array(
$user,
$pass,
);
}
function get_display_location() {
return t('NodeSquirrel.com');
}
function add_scheme($url) {
return 'http://' . $url;
}
function _xmlrpc($method, $args = array()) {
$servers = $this
->_get_endpoints();
return $this
->__xmlrpc($method, $args, $servers);
}
function __xmlrpc($method, $args, $servers, $retry = 3) {
if ($servers && --$retry > 0) {
if ($this
->_sign_request($args)) {
$url = reset($servers);
while ($url) {
$url = $this
->add_scheme($url);
$out = xmlrpc($url, array(
$method => $args,
));
$err = xmlrpc_error();
if ($err && $err->is_error) {
switch ($err->code) {
case '500':
case '503':
case '404':
$url = next($servers);
if (!$url) {
$servers = $this
->_get_endpoints(TRUE, $retry);
return $this
->__xmlrpc($method, $args, $servers, $retry);
}
break;
case '300':
$servers = $this
->_get_endpoints(TRUE, $retry);
return $this
->__xmlrpc($method, $args, $servers, $retry);
break;
case '401':
case '403':
_backup_migrate_message('Couldn\'t log in to NodeSquirrel. The server error was: %err', array(
'%err' => $err->message,
), 'error');
return FALSE;
break;
default:
_backup_migrate_message('The NodeSquirrel server returned the following error: %err', array(
'%err' => $err->message,
), 'error');
return FALSE;
break;
}
}
else {
return $out;
}
}
}
}
}
function _get_hash($time, $nonce) {
if ($private_key = $this
->_get_private_key()) {
$message = $time . ':' . $nonce . ':' . $private_key;
$hash = base64_encode(pack('H*', sha1((str_pad($private_key, 64, chr(0x0)) ^ str_repeat(chr(0x5c), 64)) . pack('H*', sha1((str_pad($private_key, 64, chr(0x0)) ^ str_repeat(chr(0x36), 64)) . $message)))));
return $hash;
}
_backup_migrate_message('You must enter a valid secret key to use NodeSquirrel.', array(), 'error');
return FALSE;
}
function _sign_request(&$args) {
$nonce = md5(mt_rand());
$time = time();
$hash = $this
->_get_hash($time, $nonce);
if ($hash) {
array_unshift($args, $nonce);
array_unshift($args, $time);
array_unshift($args, $hash);
return TRUE;
}
else {
return FALSE;
}
}
function _get_endpoints($refresh = FALSE, $retry = 3) {
$servers = (array) variable_get('nodesquirrel_endpoint_urls', array());
if ($refresh || empty($servers)) {
$servers = array_unique(array_merge($servers, variable_get('nodesquirrel_default_endpoint_urls', array(
'api.nodesquirrel.com/services/xmlrpc',
))));
$new_servers = $this
->__xmlrpc('backups.getEndpoints', array(
$this
->_get_destination(),
'xmlrpc',
), $servers, $retry);
if ($new_servers) {
variable_set('nodesquirrel_endpoint_urls', $new_servers);
$servers = $new_servers;
}
}
return $servers;
}
function _post_file($url, $method = 'GET', $params = array(), $file = NULL, $retry = 3) {
global $db_prefix;
$result = new stdClass();
$uri = parse_url($url);
if ($uri == FALSE) {
$result->error = 'unable to parse URL';
$result->code = -1001;
return $result;
}
if (!isset($uri['scheme'])) {
$result->error = 'missing schema';
$result->code = -1002;
return $result;
}
switch ($uri['scheme']) {
case 'http':
case 'feed':
$port = isset($uri['port']) ? $uri['port'] : 80;
$host = $uri['host'] . ($port != 80 ? ':' . $port : '');
$fp = @fsockopen($uri['host'], $port, $errno, $errstr, 15);
break;
case 'https':
$port = isset($uri['port']) ? $uri['port'] : 443;
$host = $uri['host'] . ($port != 443 ? ':' . $port : '');
$fp = @fsockopen('ssl://' . $uri['host'], $port, $errno, $errstr, 20);
break;
default:
$result->error = 'invalid schema ' . $uri['scheme'];
$result->code = -1003;
return $result;
}
if (!$fp) {
$result->code = -$errno;
$result->error = trim($errstr);
variable_set('drupal_http_request_fails', TRUE);
return $result;
}
$path = isset($uri['path']) ? $uri['path'] : '/';
if (isset($uri['query'])) {
$path .= '?' . $uri['query'];
}
$boundary = '---------------------------' . substr(md5(rand(0, 32000)), 0, 10);
$data_footer = "\r\n--{$boundary}--\r\n";
$data_header = '';
foreach ($params as $key => $value) {
$data_header .= "--{$boundary}\r\n";
$data_header .= "Content-Disposition: form-data; name=\"" . $key . "\"\r\n";
$data_header .= "\r\n" . $value . "\r\n";
$data_header .= "--{$boundary}\r\n";
}
$data_header .= "--{$boundary}\r\n";
$data_header .= "Content-Disposition: form-data; name=\"file\"; filename=\"" . $file
->filename() . "\"\r\n";
$data_header .= "Content-Type: application/octet-stream;\r\n";
$data_header .= "\r\n";
$content_length = strlen($data_header . $data_footer) + filesize($file
->filepath());
$defaults = array(
'Host' => "Host: {$host}",
'Content-type' => "Content-type: multipart/form-data, boundary={$boundary}",
'User-Agent' => 'User-Agent: NodeSquirrel Client/1.x (+http://www.nodesquirrel.com) (Drupal ' . VERSION . '; Backup and Migrate 2.x)',
'Content-Length' => 'Content-Length: ' . $content_length,
);
if (isset($uri['user'])) {
$defaults['Authorization'] = 'Authorization: Basic ' . base64_encode($uri['user'] . (!empty($uri['pass']) ? ":" . $uri['pass'] : ''));
}
$request = $method . ' ' . $path . " HTTP/1.0\r\n";
$request .= implode("\r\n", $defaults);
$request .= "\r\n\r\n";
$result->request = $request;
fwrite($fp, $request);
fwrite($fp, $data_header);
if ($fp_in = fopen($file
->filepath(), 'rb')) {
while (!feof($fp_in)) {
fwrite($fp, fread($fp_in, 1024 * 512));
}
$success = TRUE;
}
@fclose($fp_in);
fwrite($fp, $data_footer);
$response = '';
while (!feof($fp) && ($chunk = fread($fp, 1024))) {
$response .= $chunk;
}
fclose($fp);
if (variable_get('debug_http_request', FALSE)) {
drupal_debug(date('r'));
drupal_debug($request);
drupal_debug($response);
}
list($split, $result->data) = explode("\r\n\r\n", $response, 2);
$split = preg_split("/\r\n|\n|\r/", $split);
list($protocol, $code, $status_message) = explode(' ', trim(array_shift($split)), 3);
$result->protocol = $protocol;
$result->status_message = $status_message;
$result->headers = array();
while ($line = trim(array_shift($split))) {
list($header, $value) = explode(':', $line, 2);
if (isset($result->headers[$header]) && $header == 'Set-Cookie') {
$result->headers[$header] .= ',' . trim($value);
}
else {
$result->headers[$header] = trim($value);
}
}
$responses = array(
100 => 'Continue',
101 => 'Switching Protocols',
200 => 'OK',
201 => 'Created',
202 => 'Accepted',
203 => 'Non-Authoritative Information',
204 => 'No Content',
205 => 'Reset Content',
206 => 'Partial Content',
300 => 'Multiple Choices',
301 => 'Moved Permanently',
302 => 'Found',
303 => 'See Other',
304 => 'Not Modified',
305 => 'Use Proxy',
307 => 'Temporary Redirect',
400 => 'Bad Request',
401 => 'Unauthorized',
402 => 'Payment Required',
403 => 'Forbidden',
404 => 'Not Found',
405 => 'Method Not Allowed',
406 => 'Not Acceptable',
407 => 'Proxy Authentication Required',
408 => 'Request Time-out',
409 => 'Conflict',
410 => 'Gone',
411 => 'Length Required',
412 => 'Precondition Failed',
413 => 'Request Entity Too Large',
414 => 'Request-URI Too Large',
415 => 'Unsupported Media Type',
416 => 'Requested range not satisfiable',
417 => 'Expectation Failed',
500 => 'Internal Server Error',
501 => 'Not Implemented',
502 => 'Bad Gateway',
503 => 'Service Unavailable',
504 => 'Gateway Time-out',
505 => 'HTTP Version not supported',
);
if (!isset($responses[$code])) {
$code = floor($code / 100) * 100;
}
switch ($code) {
case 200:
case 304:
break;
case 301:
case 302:
case 307:
$location = $result->headers['Location'];
if ($retry) {
$result = drupal_http_request($result->headers['Location'], $headers, $method, $data, --$retry);
$result->redirect_code = $result->code;
}
$result->redirect_url = $location;
break;
default:
$result->error = $status_message;
}
$result->code = $code;
return $result;
}
}
