Xcloner_File_Transfer

Complexity

Total Complexity

11

Size/Duplication

Total Lines	133
Duplicated Lines	0 %

Importance

Changes	6
Bugs	2	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	curl_file_create()	0	11	4
A	transfer_file()	0	71	5
A	get_target()	0	3	1
A	set_target()	0	3	1

<?php
/**
 * XCloner - Backup and Restore backup plugin for Wordpress
 *
 * class-xcloner-file-transfer.php
 * @author Liuta Ovidiu <info@thinkovi.com>
 *
 *        This program 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.
 *
 *        This program 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 this program; if not, write to the Free Software
 *        Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
 *        MA 02110-1301, USA.
 *
 * @link https://github.com/ovidiul/XCloner-Wordpress
 *
 * @modified 7/25/18 1:46 PM
 *
 */

class Xcloner_File_Transfer extends Xcloner_File_System
{

	/**
	 * Target url web address of the restore script
	 * @var string
	 */
	private $target_url;
	/**
	 * Transfer data limit in bytes
	 * @var int
	 */
	private $transfer_limit = 1048576; //bytes 1MB= 1048576 300KB = 358400


	/**
	 * @param $target_url
	 *
	 * @return mixed
	 */
	public function set_target($target_url)
	{
		return $this->target_url = $target_url;
	}

	/**
	 * @return string
	 */
	public function get_target()
	{
		return $this->target_url;
	}


	/**
	 * @param $file
	 * @param int $start
	 * @param string $hash
	 *
	 * @return bool|int
	 * @throws Exception
	 */
	public function transfer_file($file, $start = 0, $hash = "")
	{
		if (!$this->target_url) {
			throw new Exception("Please setup a target url for upload");
		}


		$fp = $this->get_storage_filesystem()->readStream($file);

		fseek($fp, $start, SEEK_SET);

		$binary_data = fread($fp, $this->transfer_limit);

		$tmp_filename = "xcloner_upload_".substr(md5(time()), 0, 5);

		$this->get_tmp_filesystem()->write($tmp_filename, $binary_data);

		$tmp_file_path = $this->get_tmp_filesystem_adapter()->applyPathPrefix($tmp_filename);

		$send_array = array();

		$send_array['file'] = $file;
		$send_array['start'] = $start;
		$send_array['xcloner_action'] = "write_file";
		$send_array['hash'] = $hash;
		#$send_array['blob'] 	= $binary_data;
		$send_array['blob'] = $this->curl_file_create($tmp_file_path, 'application/x-binary', $tmp_filename);

		//$data = http_build_query($send_array);

		$this->get_logger()->info(sprintf("Sending curl request to %s with %s data of file %s starting position %s using temporary file %s",
			$this->target_url, $this->transfer_limit, $file, $start, $tmp_filename));


		$ch = curl_init();
		curl_setopt($ch, CURLOPT_URL, $this->target_url);

		curl_setopt($ch, CURLOPT_POST, 1);
		//curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 1);
		//curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 1);
		curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 60);
		curl_setopt($ch, CURLOPT_TIMEOUT, 1200);
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);

		curl_setopt($ch, CURLOPT_POSTFIELDS, $send_array);
		curl_setopt($ch, CURLOPT_VERBOSE, true);

		$original_result = curl_exec($ch);


		$this->get_tmp_filesystem()->delete($tmp_filename);

		$result = json_decode($original_result);

		if (!$result) {
			throw new Exception("We have received no valid response from the remote host, original message: ".$original_result);
		}

		if ($result->status != 200) {
			throw new Exception($result->response);
		}

		if (ftell($fp) >= $this->get_storage_filesystem()->getSize($file)) {
			$this->get_logger()->info(sprintf("Upload done for file %s to target url %s, transferred a total of %s bytes",
				$file, $this->target_url, ftell($fp)));
			$this->remove_tmp_filesystem();

			return false;
		}

		return ftell($fp);
	}

	/**
	 * @param string $filename
	 * @param string $mimetype
	 * @param string $postname
	 *
	 * @return CURLFile|string
	 */
	private function curl_file_create($filename, $mimetype = '', $postname = '')
	{
		if (!function_exists('curl_file_create')) {

			return "@$filename;filename="
				. ($postname ?: basename($filename))
				. ($mimetype ? ";type=$mimetype" : '');

		} else {

			return curl_file_create($filename, $mimetype, $postname);

		}
	}
}