ovidiul / XCloner-Wordpress

restore/xcloner_restore.php

Indentation +32 added lines, -32 removed lines

@@ -158,15 +158,15 @@ 
 	}
 	
 	private function friendly_error_type($type) {
-	    static $levels=null;
-	    if ($levels===null) {
-	        $levels=[];
-	        foreach (get_defined_constants() as $key=>$value) {
-	            if (strpos($key,'E_')!==0) {continue;}
+		static $levels=null;
+		if ($levels===null) {
+			$levels=[];
+			foreach (get_defined_constants() as $key=>$value) {
+				if (strpos($key,'E_')!==0) {continue;}
 					$levels[$value]= $key; //substr($key,2);
-	        }
-	    }
-	    return (isset($levels[$type]) ? $levels[$type] : "Error #{$type}");
+			}
+		}
+		return (isset($levels[$type]) ? $levels[$type] : "Error #{$type}");
 	}
 	
 	public function get_logger_filename()
@@ -887,19 +887,19 @@ 
 	}
 	
 	private function return_bytes($val) {
-	    $val = trim($val);
-	    $last = strtolower($val[strlen($val)-1]);
-	    switch($last) {
-	        // The 'G' modifier is available since PHP 5.1.0
-	        case 'g':
-	            $val *= 1024;
-	        case 'm':
-	            $val *= 1024;
-	        case 'k':
-	            $val *= 1024;
-	    }
+		$val = trim($val);
+		$last = strtolower($val[strlen($val)-1]);
+		switch($last) {
+			// The 'G' modifier is available since PHP 5.1.0
+			case 'g':
+				$val *= 1024;
+			case 'm':
+				$val *= 1024;
+			case 'k':
+				$val *= 1024;
+		}
 	
-	    return $val;
+		return $val;
 	}
 	
 	public function is_multipart($backup_name)
@@ -947,7 +947,7 @@ 
 	{
 		$direction = strtolower($direction);
 		
-	    usort($array, create_function('$a, $b', '
+		usort($array, create_function('$a, $b', '
 	        $a = $a["' . $field . '"];
 	        $b = $b["' . $field . '"];
 	
@@ -959,7 +959,7 @@ 
 	        return ($a ' . ($direction == 'desc' ? '>' : '<') .' $b) ? -1 : 1;
 	    '));
 	
-	    return true;
+		return true;
 	}
 		
 	public static function send_response($status = 200, $response)
@@ -999,10 +999,10 @@ 
 					$m[3] = "";
 					
 					$data = 's:'.strlen(($m[3])).':\"'.($m[3]).'\";';
-	              //return $this->unescape_quotes($data);
+				  //return $this->unescape_quotes($data);
 	              
-	              return $data;
-	            }, $query);
+				  return $data;
+				}, $query);
 	}
 	
 	private function unescape_quotes($value) {
@@ -1019,14 +1019,14 @@ 
 	private function has_serialized($s)
 	{
 		if(
-		    stristr($s, '{' ) != false &&
-		    stristr($s, '}' ) != false &&
-		    stristr($s, ';' ) != false &&
-		    stristr($s, ':' ) != false
-		    ){
-		    return true;
+			stristr($s, '{' ) != false &&
+			stristr($s, '}' ) != false &&
+			stristr($s, ';' ) != false &&
+			stristr($s, ':' ) != false
+			){
+			return true;
 		}else{
-		    return false;
+			return false;
 		}
 
 	}

includes/class-xcloner-database.php

Indentation +4 added lines, -4 removed lines

@@ -284,7 +284,7 @@ 
 					$this->log(sprintf(__("Excluding table %s.%s from backup"), $table, $database));
 				}
 			$inc++;
-        }
+		}
 
 		return $tablesList;
 
@@ -507,7 +507,7 @@ 
 					$buffer = "";
 					$this->countRecords++;
 
-	                foreach ($arr as $key => $value) {
+					foreach ($arr as $key => $value) {
 						$value = $this->_real_escape($value);
 						
 						if(method_exists($this, 'remove_placeholder_escape')){
@@ -538,8 +538,8 @@ 
 		$line = ("\n#\n# Table structure for table `$tableName`\n#\n\n");
 		$this->fs->get_tmp_filesystem_append()->write($dumpfile, $line);
 
-        if ($this->dbDropSyntax)
-        {
+		if ($this->dbDropSyntax)
+		{
 			$line = ("\nDROP table IF EXISTS `$tableName`;\n");
 			$this->fs->get_tmp_filesystem_append()->write($dumpfile, $line);
 		}

admin/partials/xcloner_manage_backups_page.php

Indentation +32 added lines, -32 removed lines

@@ -6,7 +6,7 @@ 
 $storage_selection = "";
 
 if (isset($_GET['storage_selection']) and $_GET['storage_selection']) {
-    $storage_selection = $xcloner_sanitization->sanitize_input_as_string($_GET['storage_selection']);
+	$storage_selection = $xcloner_sanitization->sanitize_input_as_string($_GET['storage_selection']);
 }
 
 $backup_list = $xcloner_file_system->get_backup_archives_list($storage_selection);
@@ -34,7 +34,7 @@ 
 
             <?php foreach ($available_storages as $storage => $text): ?>
                 <option value="<?php echo $storage ?>"<?php if ($storage == $storage_selection)
-                    echo "selected" ?>><?php echo $text ?></option>
+					echo "selected" ?>><?php echo $text ?></option>
             <?php endforeach ?>
         </select>
         <?php endif ?>
@@ -61,21 +61,21 @@ 
 
 
         <?php
-        $i = 0;
-        foreach ($backup_list as $file_info):?>
+		$i = 0;
+		foreach ($backup_list as $file_info):?>
             <?php
-            if ($storage_selection == "gdrive") {
-                $file_info['path'] = $file_info['filename'] . "." . $file_info['extension'];
-            }
-            $file_exists_on_local_storage = true;
-
-            if ($storage_selection) {
-                if (!$xcloner_file_system->get_storage_filesystem()->has($file_info['path'])) {
-                    $file_exists_on_local_storage = false;
-                }
-            }
-
-            ?>
+			if ($storage_selection == "gdrive") {
+				$file_info['path'] = $file_info['filename'] . "." . $file_info['extension'];
+			}
+			$file_exists_on_local_storage = true;
+
+			if ($storage_selection) {
+				if (!$xcloner_file_system->get_storage_filesystem()->has($file_info['path'])) {
+					$file_exists_on_local_storage = false;
+				}
+			}
+
+			?>
             <?php if (!isset($file_info['parent'])): ?>
 
                 <tr>
@@ -91,12 +91,12 @@ 
                         <?php if (!$file_exists_on_local_storage): ?>
                             <a href="#"
                                title="<?php echo __("File does not exists on local storage",
-                                   "xcloner-backup-and-restore") ?>"><i
+								   "xcloner-backup-and-restore") ?>"><i
                                         class="material-icons backup_warning">warning</i></a>
                         <?php endif ?>
                         <?php
-                        if (isset($file_info['childs']) and is_array($file_info['childs'])):
-                            ?>
+						if (isset($file_info['childs']) and is_array($file_info['childs'])):
+							?>
                             <a href="#" title="expand" class="expand-multipart add"><i
                                         class="material-icons">add</i></a>
                             <a href="#" title="collapse" class="expand-multipart remove"><i class="material-icons">remove</i></a>
@@ -105,17 +105,17 @@ 
                                     <li>
                                         <?php echo $child[0] ?> (<?php echo size_format($child[2]) ?>)
                                         <?php
-                                        $child_exists_on_local_storage = true;
-                                        if ($storage_selection) {
-                                            if (!$xcloner_file_system->get_storage_filesystem()->has($child[0])) {
-                                                $child_exists_on_local_storage = false;
-                                            }
-                                        }
-                                        ?>
+										$child_exists_on_local_storage = true;
+										if ($storage_selection) {
+											if (!$xcloner_file_system->get_storage_filesystem()->has($child[0])) {
+												$child_exists_on_local_storage = false;
+											}
+										}
+										?>
                                         <?php if (!$child_exists_on_local_storage): ?>
                                             <a href="#"
                                                title="<?php echo __("File does not exists on local storage",
-                                                   "xcloner-backup-and-restore") ?>"><i
+												   "xcloner-backup-and-restore") ?>"><i
                                                         class="material-icons backup_warning">warning</i></a>
                                         <?php endif ?>
                                         <?php if (!$storage_selection) : ?>
@@ -123,12 +123,12 @@ 
                                                title="Download Backup"><i class="material-icons">file_download</i></a>
                                             <a href="#<?php echo $child[0] ?>" class="list-backup-content"
                                                title="<?php echo __('List Backup Content',
-                                                   'xcloner-backup-and-restore') ?>"><i
+												   'xcloner-backup-and-restore') ?>"><i
                                                         class="material-icons">folder_open</i></a>
                                         <?php elseif ($storage_selection != "gdrive" && !$xcloner_file_system->get_storage_filesystem()->has($child[0])): ?>
                                             <a href="#<?php echo $child[0] ?>" class="copy-remote-to-local"
                                                title="<?php echo __('Push Backup To Local Storage',
-                                                   'xcloner-backup-and-restore') ?>"><i
+												   'xcloner-backup-and-restore') ?>"><i
                                                         class="material-icons">file_upload</i></a>
                                         <?php endif ?>
                                     </li>
@@ -137,7 +137,7 @@ 
                         <?php endif; ?>
                     </td>
                     <td><?php if (isset($file_info['timestamp']))
-                            echo date("Y-m-d H:i", $file_info['timestamp']) ?></td>
+							echo date("Y-m-d H:i", $file_info['timestamp']) ?></td>
                     <td><?php echo size_format($file_info['size']) ?></td>
                     <td>
                         <?php if (!$storage_selection): ?>
@@ -148,7 +148,7 @@ 
                             <?php if (sizeof($available_storages)): ?>
                                 <a href="#<?php echo $file_info['basename'] ?>" class="cloud-upload"
                                    title="<?php echo __('Send Backup To Remote Storage',
-                                       'xcloner-backup-and-restore') ?>"><i
+									   'xcloner-backup-and-restore') ?>"><i
                                             class="material-icons">cloud_upload</i></a>
                             <?php endif ?>
                             <a href="#<?php echo $file_info['basename'] ?>" class="list-backup-content"
@@ -220,7 +220,7 @@ 
                 <div class="row">
                     <div class="col s12 label">
                         <label><?php echo sprintf(__('Send %s to remote storage', 'xcloner-backup-and-restore'),
-                                "<span class='backup_name'></span>") ?></label>
+								"<span class='backup_name'></span>") ?></label>
                     </div>
                     <div class="input-field col s8 m10">
                         <select name="transfer_storage" id="transfer_storage" class="validate" required>

includes/class-xcloner-remote-storage.php

Indentation +44 added lines, -44 removed lines

@@ -170,60 +170,60 @@
 
 		foreach($this->storage_fields as $main_key=>$array){
 
-		    if(is_array($array)) {
-                foreach ($array as $key => $type) {
+			if(is_array($array)) {
+				foreach ($array as $key => $type) {
 
-                    if( $type == "raw") {
-                        add_filter("pre_update_option_" . $this->storage_fields['option_prefix'] . $key,
-                            function ($value) {
+					if( $type == "raw") {
+						add_filter("pre_update_option_" . $this->storage_fields['option_prefix'] . $key,
+							function ($value) {
 
-                                return $this->simple_crypt($value, 'e');
+								return $this->simple_crypt($value, 'e');
 
-                            }, 10, 1);
+							}, 10, 1);
 
-                        add_filter("option_" . $this->storage_fields['option_prefix'] . $key, function ($value) {
+						add_filter("option_" . $this->storage_fields['option_prefix'] . $key, function ($value) {
 
-                            return $this->simple_crypt($value, 'd');
+							return $this->simple_crypt($value, 'd');
 
-                        }, 10, 1);
-                    }
+						}, 10, 1);
+					}
 
-                }
-            }
-        }
+				}
+			}
+		}
 
 	}
 
-    /**
-     * Encrypts and Decrypt a string based on openssl lib
-     *
-     * @param $string
-     * @param string $action
-     * @return string
-     */
-    private function simple_crypt( $string, $action = 'e' ) {
-        // you may change these values to your own
-        $secret_key = NONCE_KEY;
-        $secret_iv = NONCE_SALT;
-
-        $output = $string;
-        $encrypt_method = "AES-256-CBC";
-        $key = hash( 'sha256', $secret_key );
-        $iv = substr( hash( 'sha256', $secret_iv ), 0, 16 );
-
-        if( $action == 'e' && function_exists('openssl_encrypt')) {
-            $output = base64_encode( openssl_encrypt( $string, $encrypt_method, $key, 0, $iv ) );
-        }
-        else if( $action == 'd' && function_exists('openssl_decrypt') && base64_decode( $string )){
-            $decrypt = openssl_decrypt( base64_decode( $string ), $encrypt_method, $key, 0, $iv );
-            if($decrypt) {
-                //we check if decrypt was succesful
-                $output = $decrypt;
-            }
-        }
-
-        return $output;
-    }
+	/**
+	 * Encrypts and Decrypt a string based on openssl lib
+	 *
+	 * @param $string
+	 * @param string $action
+	 * @return string
+	 */
+	private function simple_crypt( $string, $action = 'e' ) {
+		// you may change these values to your own
+		$secret_key = NONCE_KEY;
+		$secret_iv = NONCE_SALT;
+
+		$output = $string;
+		$encrypt_method = "AES-256-CBC";
+		$key = hash( 'sha256', $secret_key );
+		$iv = substr( hash( 'sha256', $secret_iv ), 0, 16 );
+
+		if( $action == 'e' && function_exists('openssl_encrypt')) {
+			$output = base64_encode( openssl_encrypt( $string, $encrypt_method, $key, 0, $iv ) );
+		}
+		else if( $action == 'd' && function_exists('openssl_decrypt') && base64_decode( $string )){
+			$decrypt = openssl_decrypt( base64_decode( $string ), $encrypt_method, $key, 0, $iv );
+			if($decrypt) {
+				//we check if decrypt was succesful
+				$output = $decrypt;
+			}
+		}
+
+		return $output;
+	}
 
 	private function get_xcloner_container() {
 		return $this->xcloner_container;

includes/class-xcloner-archive.php

Indentation +513 added lines, -513 removed lines

@@ -36,171 +36,171 @@ 
  */
 class Xcloner_Archive extends Tar
 {
-    /**
-     * Process file size per API request
-     * @var float|int
-     */
-    private $file_size_per_request_limit = 52428800; //50MB = 52428800; 1MB = 1048576
-    /**
-     * Files count to process per API request
-     * @var int
-     */
-    private $files_to_process_per_request = 250; //block of 512 bytes
-    /**
-     * Compression level, 0-uncompressed, 9-maximum compression
-     * @var int
-     */
-    private $compression_level = 0; //0-9 , 0 uncompressed
-    /**
-     * Split backup size limit
-     * Create a new backup archive file once the set size is reached
-     * @var float|int
-     */
-    private $xcloner_split_backup_limit = 2048; //2048MB
-    /**
-     * Number of processed bytes
-     * @var int
-     */
-    private $processed_size_bytes = 0;
-
-    /**
-     * Archive name
-     * @var string
-     */
-    private $archive_name;
-    /**
-     * @var Tar
-     */
-    private $backup_archive;
-    /**
-     * @var Xcloner_File_System
-     */
-    private $filesystem;
-    /**
-     * @var Xcloner_Logger
-     */
-    private $logger;
-    /**
-     * @var Xcloner_Settings
-     */
-    private $xcloner_settings;
-
-    /**
-     * [__construct description]
-     * @param Xcloner $xcloner_container XCloner Container
-     * @param string $archive_name Achive Name
-     */
-    public function __construct(Xcloner $xcloner_container, $archive_name = "")
-    {
-        $this->filesystem = $xcloner_container->get_xcloner_filesystem();
-        $this->logger = $xcloner_container->get_xcloner_logger()->withName("xcloner_archive");
-        $this->xcloner_settings = $xcloner_container->get_xcloner_settings();
-
-        if ($value = $this->xcloner_settings->get_xcloner_option('xcloner_size_limit_per_request')) {
-            $this->file_size_per_request_limit = $value * 1024 * 1024;
-        } //MB
-
-        if ($value = $this->xcloner_settings->get_xcloner_option('xcloner_files_to_process_per_request')) {
-            $this->files_to_process_per_request = $value;
-        }
+	/**
+	 * Process file size per API request
+	 * @var float|int
+	 */
+	private $file_size_per_request_limit = 52428800; //50MB = 52428800; 1MB = 1048576
+	/**
+	 * Files count to process per API request
+	 * @var int
+	 */
+	private $files_to_process_per_request = 250; //block of 512 bytes
+	/**
+	 * Compression level, 0-uncompressed, 9-maximum compression
+	 * @var int
+	 */
+	private $compression_level = 0; //0-9 , 0 uncompressed
+	/**
+	 * Split backup size limit
+	 * Create a new backup archive file once the set size is reached
+	 * @var float|int
+	 */
+	private $xcloner_split_backup_limit = 2048; //2048MB
+	/**
+	 * Number of processed bytes
+	 * @var int
+	 */
+	private $processed_size_bytes = 0;
+
+	/**
+	 * Archive name
+	 * @var string
+	 */
+	private $archive_name;
+	/**
+	 * @var Tar
+	 */
+	private $backup_archive;
+	/**
+	 * @var Xcloner_File_System
+	 */
+	private $filesystem;
+	/**
+	 * @var Xcloner_Logger
+	 */
+	private $logger;
+	/**
+	 * @var Xcloner_Settings
+	 */
+	private $xcloner_settings;
+
+	/**
+	 * [__construct description]
+	 * @param Xcloner $xcloner_container XCloner Container
+	 * @param string $archive_name Achive Name
+	 */
+	public function __construct(Xcloner $xcloner_container, $archive_name = "")
+	{
+		$this->filesystem = $xcloner_container->get_xcloner_filesystem();
+		$this->logger = $xcloner_container->get_xcloner_logger()->withName("xcloner_archive");
+		$this->xcloner_settings = $xcloner_container->get_xcloner_settings();
+
+		if ($value = $this->xcloner_settings->get_xcloner_option('xcloner_size_limit_per_request')) {
+			$this->file_size_per_request_limit = $value * 1024 * 1024;
+		} //MB
+
+		if ($value = $this->xcloner_settings->get_xcloner_option('xcloner_files_to_process_per_request')) {
+			$this->files_to_process_per_request = $value;
+		}
 
-        if ($value = get_option('xcloner_backup_compression_level')) {
-            $this->compression_level = $value;
-        }
+		if ($value = get_option('xcloner_backup_compression_level')) {
+			$this->compression_level = $value;
+		}
 
-        if ($value = get_option('xcloner_split_backup_limit')) {
-            $this->xcloner_split_backup_limit = $value;
-        }
+		if ($value = get_option('xcloner_split_backup_limit')) {
+			$this->xcloner_split_backup_limit = $value;
+		}
 
-        $this->xcloner_split_backup_limit = $this->xcloner_split_backup_limit * 1024 * 1024; //transform to bytes
+		$this->xcloner_split_backup_limit = $this->xcloner_split_backup_limit * 1024 * 1024; //transform to bytes
 
-        if (isset($archive_name) && $archive_name) {
-            $this->set_archive_name($archive_name);
-        }
-    }
+		if (isset($archive_name) && $archive_name) {
+			$this->set_archive_name($archive_name);
+		}
+	}
 
-    /*
+	/*
      * Rename backup archive
      *
      * @param string $old_name
      * @param string $new_name
      *
      */
-    public function rename_archive($old_name, $new_name)
-    {
-        $this->logger->info(sprintf("Renaming backup archive %s to %s", $old_name, $new_name));
-        $storage_filesystem = $this->filesystem->get_storage_filesystem();
-        $storage_filesystem->rename($old_name, $new_name);
-    }
-
-    /*
+	public function rename_archive($old_name, $new_name)
+	{
+		$this->logger->info(sprintf("Renaming backup archive %s to %s", $old_name, $new_name));
+		$storage_filesystem = $this->filesystem->get_storage_filesystem();
+		$storage_filesystem->rename($old_name, $new_name);
+	}
+
+	/*
      *
      * Set the backup archive name
      *
      */
-    public function set_archive_name($name = "", $part = 0)
-    {
+	public function set_archive_name($name = "", $part = 0)
+	{
 
-        $this->archive_name = $this->filesystem->process_backup_name($name);
+		$this->archive_name = $this->filesystem->process_backup_name($name);
 
-        if ($diff_timestamp_start = $this->filesystem->get_diff_timestamp_start()) {
-            //$this->archive_name = $this->archive_name."-diff-".date("Y-m-d_H-i",$diff_timestamp_start);
-            $new_name = $this->archive_name;
+		if ($diff_timestamp_start = $this->filesystem->get_diff_timestamp_start()) {
+			//$this->archive_name = $this->archive_name."-diff-".date("Y-m-d_H-i",$diff_timestamp_start);
+			$new_name = $this->archive_name;
 
-            if (!stristr($new_name, "-diff")) {
-                $new_name = $this->archive_name . "-diff" . date("Y-m-d_H-i", $diff_timestamp_start);
-            }
+			if (!stristr($new_name, "-diff")) {
+				$new_name = $this->archive_name . "-diff" . date("Y-m-d_H-i", $diff_timestamp_start);
+			}
 
-            $this->archive_name = $new_name;
+			$this->archive_name = $new_name;
 
-        }
+		}
 
-        if (isset($part) and $part) {
-            $new_name = preg_replace('/-part(\d*)/', "-part" . $part, $this->archive_name);
-            if (!stristr($new_name, "-part")) {
-                $new_name = $this->archive_name . "-part" . $part;
-            }
+		if (isset($part) and $part) {
+			$new_name = preg_replace('/-part(\d*)/', "-part" . $part, $this->archive_name);
+			if (!stristr($new_name, "-part")) {
+				$new_name = $this->archive_name . "-part" . $part;
+			}
 
-            $this->archive_name = $new_name;
-        }
+			$this->archive_name = $new_name;
+		}
 
-        return $this;
-    }
+		return $this;
+	}
 
-    /*
+	/*
      *
      * Returns the backup archive name
      *
      * @return string archive name
      */
-    public function get_archive_name()
-    {
-        return $this->archive_name;
-    }
+	public function get_archive_name()
+	{
+		return $this->archive_name;
+	}
 
-    /*
+	/*
      *
      * Returns the multipart naming for the backup archive
      *
      * @return string multi-part backup name
      */
-    public function get_archive_name_multipart()
-    {
-        $new_name = preg_replace('/-part(\d*)/', "", $this->archive_name);
-        return $new_name . "-multipart" . $this->xcloner_settings->get_backup_extension_name(".csv");
-    }
+	public function get_archive_name_multipart()
+	{
+		$new_name = preg_replace('/-part(\d*)/', "", $this->archive_name);
+		return $new_name . "-multipart" . $this->xcloner_settings->get_backup_extension_name(".csv");
+	}
 
-    /*
+	/*
      *
      * Returns the full backup name including extension
      *
      */
-    public function get_archive_name_with_extension()
-    {
-        return $this->archive_name . $this->xcloner_settings->get_backup_extension_name();
-    }
+	public function get_archive_name_with_extension()
+	{
+		return $this->archive_name . $this->xcloner_settings->get_backup_extension_name();
+	}
 
-    /*
+	/*
      *
      * Send notification error by E-Mail
      *
@@ -213,31 +213,31 @@ 
      *
      * @return bool
      */
-    public function send_notification_error($to, $from, $subject, $backup_name, $params, $error_message)
-    {
+	public function send_notification_error($to, $from, $subject, $backup_name, $params, $error_message)
+	{
 
-        $body = "";
-        $body .= sprintf(__("Backup Site Url: %s"), get_site_url());
-        $body .= "<br /><>";
+		$body = "";
+		$body .= sprintf(__("Backup Site Url: %s"), get_site_url());
+		$body .= "<br /><>";
 
-        $body .= sprintf(__("Error Message: %s"), $error_message);
+		$body .= sprintf(__("Error Message: %s"), $error_message);
 
-        $this->logger->info(sprintf("Sending backup error notification to %s", $to));
+		$this->logger->info(sprintf("Sending backup error notification to %s", $to));
 
-        $admin_email = get_option("admin_email");
+		$admin_email = get_option("admin_email");
 
-        $headers = array('Content-Type: text/html; charset=UTF-8');
+		$headers = array('Content-Type: text/html; charset=UTF-8');
 
-        if ($admin_email and $from) {
-            $headers[] = 'From: ' . $from . ' <' . $admin_email . '>';
-        }
+		if ($admin_email and $from) {
+			$headers[] = 'From: ' . $from . ' <' . $admin_email . '>';
+		}
 
-        $return = wp_mail($to, $subject, $body, $headers);
+		$return = wp_mail($to, $subject, $body, $headers);
 
-        return $return;
-    }
+		return $return;
+	}
 
-    /*
+	/*
      *
      * Send backup archive notfication by E-Mail
      *
@@ -251,480 +251,480 @@ 
      *
      * @return bool
      */
-    public function send_notification(
-        $to,
-        $from,
-        $subject,
-        $backup_name,
-        $params,
-        $error_message = "",
-        $additional = array()
-    ) {
-        if (!$from) {
-            $from = "XCloner Backup";
-        }
+	public function send_notification(
+		$to,
+		$from,
+		$subject,
+		$backup_name,
+		$params,
+		$error_message = "",
+		$additional = array()
+	) {
+		if (!$from) {
+			$from = "XCloner Backup";
+		}
 
-        if (($error_message)) {
-            return $this->send_notification_error($to, $from, $subject, $backup_name, $params, $error_message);
-        }
+		if (($error_message)) {
+			return $this->send_notification_error($to, $from, $subject, $backup_name, $params, $error_message);
+		}
 
-        $params = (array)$params;
+		$params = (array)$params;
 
-        if (!$subject) {
-            $subject = sprintf(__("New backup generated %s"), $backup_name);
-        }
+		if (!$subject) {
+			$subject = sprintf(__("New backup generated %s"), $backup_name);
+		}
 
-        $body = sprintf(__("Generated Backup Size: %s"), size_format($this->filesystem->get_backup_size($backup_name)));
-        $body .= "<br /><br />";
+		$body = sprintf(__("Generated Backup Size: %s"), size_format($this->filesystem->get_backup_size($backup_name)));
+		$body .= "<br /><br />";
 
-        if (isset($additional['lines_total'])) {
-            $body .= sprintf(__("Total files added: %s"), $additional['lines_total']);
-            $body .= "<br /><br />";
-        }
+		if (isset($additional['lines_total'])) {
+			$body .= sprintf(__("Total files added: %s"), $additional['lines_total']);
+			$body .= "<br /><br />";
+		}
 
-        $backup_parts = $this->filesystem->get_multipart_files($backup_name);
+		$backup_parts = $this->filesystem->get_multipart_files($backup_name);
 
-        if (!$backups_counter = sizeof($backup_parts)) {
-            $backups_counter = 1;
-        }
+		if (!$backups_counter = sizeof($backup_parts)) {
+			$backups_counter = 1;
+		}
 
-        $body .= sprintf(__("Backup Parts: %s"), $backups_counter);
-        $body .= "<br />";
+		$body .= sprintf(__("Backup Parts: %s"), $backups_counter);
+		$body .= "<br />";
 
-        if (sizeof($backup_parts)) {
-            $body .= implode("<br />", $backup_parts);
-            $body .= "<br />";
-        }
+		if (sizeof($backup_parts)) {
+			$body .= implode("<br />", $backup_parts);
+			$body .= "<br />";
+		}
 
-        $body .= "<br />";
+		$body .= "<br />";
 
-        $body .= sprintf(__("Backup Site Url: %s"), get_site_url());
-        $body .= "<br />";
+		$body .= sprintf(__("Backup Site Url: %s"), get_site_url());
+		$body .= "<br />";
 
-        if (isset($params['backup_params']->backup_comments)) {
-            $body .= __("Backup Comments: ") . $params['backup_params']->backup_comments;
-            $body .= "<br /><br />";
-        }
+		if (isset($params['backup_params']->backup_comments)) {
+			$body .= __("Backup Comments: ") . $params['backup_params']->backup_comments;
+			$body .= "<br /><br />";
+		}
 
-        if ($this->xcloner_settings->get_xcloner_option('xcloner_enable_log')) {
-            $body .= __("Latest 50 Log Lines: ") . "<br />" . implode("<br />\n",
-                                                                        $this->logger->getLastDebugLines(50));
-        }
+		if ($this->xcloner_settings->get_xcloner_option('xcloner_enable_log')) {
+			$body .= __("Latest 50 Log Lines: ") . "<br />" . implode("<br />\n",
+																		$this->logger->getLastDebugLines(50));
+		}
 
-        $attachments = $this->filesystem->get_backup_attachments();
+		$attachments = $this->filesystem->get_backup_attachments();
 
-        $attachments_archive = $this->xcloner_settings->get_xcloner_tmp_path() . DS . "info.tgz";
+		$attachments_archive = $this->xcloner_settings->get_xcloner_tmp_path() . DS . "info.tgz";
 
-        $tar = new Tar();
-        $tar->create($attachments_archive);
+		$tar = new Tar();
+		$tar->create($attachments_archive);
 
-        foreach ($attachments as $key => $file) {
-            $tar->addFile($file, basename($file));
-        }
-        $tar->close();
+		foreach ($attachments as $key => $file) {
+			$tar->addFile($file, basename($file));
+		}
+		$tar->close();
 
-        $this->logger->info(sprintf("Sending backup notification to %s", $to));
+		$this->logger->info(sprintf("Sending backup notification to %s", $to));
 
-        $admin_email = get_option("admin_email");
+		$admin_email = get_option("admin_email");
 
-        $headers = array('Content-Type: text/html; charset=UTF-8', 'From: ' . $from . ' <' . $admin_email . '>');
+		$headers = array('Content-Type: text/html; charset=UTF-8', 'From: ' . $from . ' <' . $admin_email . '>');
 
-        $return = wp_mail($to, $subject, $body, $headers, array($attachments_archive));
+		$return = wp_mail($to, $subject, $body, $headers, array($attachments_archive));
 
-        return $return;
-    }
+		return $return;
+	}
 
-    /*
+	/*
      *
      * Incremental Backup method
      *
      */
-    public function start_incremental_backup($backup_params, $extra_params, $init)
-    {
-        $return = array();
+	public function start_incremental_backup($backup_params, $extra_params, $init)
+	{
+		$return = array();
 
-        if (!isset($extra_params['backup_part'])) {
-            $extra_params['backup_part'] = 0;
-        }
+		if (!isset($extra_params['backup_part'])) {
+			$extra_params['backup_part'] = 0;
+		}
 
-        $return['extra']['backup_part'] = $extra_params['backup_part'];
+		$return['extra']['backup_part'] = $extra_params['backup_part'];
 
-        if (isset($extra_params['backup_archive_name'])) {
-            $this->set_archive_name($extra_params['backup_archive_name'], $return['extra']['backup_part']);
-        } else {
-            $this->set_archive_name($backup_params['backup_name']);
-        }
+		if (isset($extra_params['backup_archive_name'])) {
+			$this->set_archive_name($extra_params['backup_archive_name'], $return['extra']['backup_part']);
+		} else {
+			$this->set_archive_name($backup_params['backup_name']);
+		}
 
-        if (!$this->get_archive_name()) {
-            $this->set_archive_name();
-        }
+		if (!$this->get_archive_name()) {
+			$this->set_archive_name();
+		}
 
-        $this->backup_archive = new Tar();
-        $this->backup_archive->setCompression($this->compression_level);
+		$this->backup_archive = new Tar();
+		$this->backup_archive->setCompression($this->compression_level);
 
-        $archive_info = $this->filesystem->get_storage_path_file_info($this->get_archive_name_with_extension());
+		$archive_info = $this->filesystem->get_storage_path_file_info($this->get_archive_name_with_extension());
 
-        if ($init) {
-            $this->logger->info(sprintf(__("Initializing the backup archive %s"), $this->get_archive_name()));
+		if ($init) {
+			$this->logger->info(sprintf(__("Initializing the backup archive %s"), $this->get_archive_name()));
 
-            $this->backup_archive->create($archive_info->getPath() . DS . $archive_info->getFilename());
+			$this->backup_archive->create($archive_info->getPath() . DS . $archive_info->getFilename());
 
-            $return['extra']['backup_init'] = 1;
+			$return['extra']['backup_init'] = 1;
 
-        } else {
-            $this->logger->info(sprintf(__("Opening for append the backup archive %s"), $this->get_archive_name()));
+		} else {
+			$this->logger->info(sprintf(__("Opening for append the backup archive %s"), $this->get_archive_name()));
 
-            $this->backup_archive->openForAppend($archive_info->getPath() . DS . $archive_info->getFilename());
+			$this->backup_archive->openForAppend($archive_info->getPath() . DS . $archive_info->getFilename());
 
-            $return['extra']['backup_init'] = 0;
+			$return['extra']['backup_init'] = 0;
 
-        }
+		}
 
-        $return['extra']['backup_archive_name'] = $this->get_archive_name();
-        $return['extra']['backup_archive_name_full'] = $this->get_archive_name_with_extension();
+		$return['extra']['backup_archive_name'] = $this->get_archive_name();
+		$return['extra']['backup_archive_name_full'] = $this->get_archive_name_with_extension();
 
-        if (!isset($extra_params['start_at_line'])) {
-            $extra_params['start_at_line'] = 0;
-        }
+		if (!isset($extra_params['start_at_line'])) {
+			$extra_params['start_at_line'] = 0;
+		}
 
-        if (!isset($extra_params['start_at_byte'])) {
-            $extra_params['start_at_byte'] = 0;
-        }
+		if (!isset($extra_params['start_at_byte'])) {
+			$extra_params['start_at_byte'] = 0;
+		}
 
-        if (!$this->filesystem->get_tmp_filesystem()->has($this->filesystem->get_included_files_handler())) {
-            $this->logger->error(sprintf("Missing the includes file handler %s, aborting...",
-                $this->filesystem->get_included_files_handler()));
+		if (!$this->filesystem->get_tmp_filesystem()->has($this->filesystem->get_included_files_handler())) {
+			$this->logger->error(sprintf("Missing the includes file handler %s, aborting...",
+				$this->filesystem->get_included_files_handler()));
 
-            $return['finished'] = 1;
-            return $return;
-        }
+			$return['finished'] = 1;
+			return $return;
+		}
 
-        $included_files_handler = $this->filesystem->get_included_files_handler(1);
+		$included_files_handler = $this->filesystem->get_included_files_handler(1);
 
-        $file = new SplFileObject($included_files_handler);
+		$file = new SplFileObject($included_files_handler);
 
-        $file->seek(PHP_INT_MAX);
+		$file->seek(PHP_INT_MAX);
 
-        $return['extra']['lines_total'] = ($file->key() - 1);
+		$return['extra']['lines_total'] = ($file->key() - 1);
 
-        //we skip the first CSV line with headers
-        if (!$extra_params['start_at_line']) {
-            $file->seek(1);
-        } else {
-            $file->seek($extra_params['start_at_line'] + 1);
-        }
+		//we skip the first CSV line with headers
+		if (!$extra_params['start_at_line']) {
+			$file->seek(1);
+		} else {
+			$file->seek($extra_params['start_at_line'] + 1);
+		}
 
-        $this->processed_size_bytes = 0;
+		$this->processed_size_bytes = 0;
 
-        $counter = 0;
+		$counter = 0;
 
-        $start_byte = $extra_params['start_at_byte'];
+		$start_byte = $extra_params['start_at_byte'];
 
-        $byte_limit = 0;
+		$byte_limit = 0;
 
-        while (!$file->eof() and $counter <= $this->files_to_process_per_request) {
-            $current_line_str = $file->current();
+		while (!$file->eof() and $counter <= $this->files_to_process_per_request) {
+			$current_line_str = $file->current();
 
-            $line = str_getcsv($current_line_str);
+			$line = str_getcsv($current_line_str);
 
-            $relative_path = stripslashes($line[0]);
+			$relative_path = stripslashes($line[0]);
 
-            $start_filesystem = "start_filesystem";
+			$start_filesystem = "start_filesystem";
 
-            if (isset($line[4])) {
-                $start_filesystem = $line[4];
-            }
+			if (isset($line[4])) {
+				$start_filesystem = $line[4];
+			}
 
-            //$adapter = $this->filesystem->get_adapter($start_filesystem);
+			//$adapter = $this->filesystem->get_adapter($start_filesystem);
 
-            if (!$relative_path || !$this->filesystem->get_filesystem($start_filesystem)->has($relative_path)) {
-                if ($relative_path != "") {
-                    $this->logger->error(sprintf("Could not add file %b to backup archive, file not found",
-                        $relative_path));
-                }
+			if (!$relative_path || !$this->filesystem->get_filesystem($start_filesystem)->has($relative_path)) {
+				if ($relative_path != "") {
+					$this->logger->error(sprintf("Could not add file %b to backup archive, file not found",
+						$relative_path));
+				}
 
-                $extra_params['start_at_line']++;
-                $file->next();
-                continue;
-            }
+				$extra_params['start_at_line']++;
+				$file->next();
+				continue;
+			}
 
-            $file_info = $this->filesystem->get_filesystem($start_filesystem)->getMetadata($relative_path);
+			$file_info = $this->filesystem->get_filesystem($start_filesystem)->getMetadata($relative_path);
 
-            if (!isset($file_info['size'])) {
-                $file_info['size'] = 0;
-            }
+			if (!isset($file_info['size'])) {
+				$file_info['size'] = 0;
+			}
 
-            if ($start_filesystem == "tmp_filesystem") {
-                $file_info['archive_prefix_path'] = $this->xcloner_settings->get_xcloner_tmp_path_suffix();
-            }
+			if ($start_filesystem == "tmp_filesystem") {
+				$file_info['archive_prefix_path'] = $this->xcloner_settings->get_xcloner_tmp_path_suffix();
+			}
 
-            $byte_limit = (int)$this->file_size_per_request_limit / 512;
+			$byte_limit = (int)$this->file_size_per_request_limit / 512;
 
-            $append = 0;
+			$append = 0;
 
-            if ($file_info['size'] > $byte_limit * 512 or $start_byte) {
-                $append = 1;
-            }
+			if ($file_info['size'] > $byte_limit * 512 or $start_byte) {
+				$append = 1;
+			}
 
-            if (!isset($return['extra']['backup_size'])) {
-                $return['extra']['backup_size'] = 0;
-            }
+			if (!isset($return['extra']['backup_size'])) {
+				$return['extra']['backup_size'] = 0;
+			}
 
-            $return['extra']['backup_size'] = $archive_info->getSize();
+			$return['extra']['backup_size'] = $archive_info->getSize();
 
-            $estimated_new_size = $return['extra']['backup_size'] + $file_info['size'];
+			$estimated_new_size = $return['extra']['backup_size'] + $file_info['size'];
 
-            //we create a new backup part if we reach the Split Achive Limit
-            if ($this->xcloner_split_backup_limit and ($estimated_new_size > $this->xcloner_split_backup_limit) and (!$start_byte)) {
-                $this->logger->info(sprintf("Backup size limit %s bytes reached, file add estimate %s, attempt to create a new archive ",
-                    $this->xcloner_split_backup_limit, $estimated_new_size));
-                list($archive_info, $return['extra']['backup_part']) = $this->create_new_backup_part($return['extra']['backup_part']);
+			//we create a new backup part if we reach the Split Achive Limit
+			if ($this->xcloner_split_backup_limit and ($estimated_new_size > $this->xcloner_split_backup_limit) and (!$start_byte)) {
+				$this->logger->info(sprintf("Backup size limit %s bytes reached, file add estimate %s, attempt to create a new archive ",
+					$this->xcloner_split_backup_limit, $estimated_new_size));
+				list($archive_info, $return['extra']['backup_part']) = $this->create_new_backup_part($return['extra']['backup_part']);
 
-                if ($file_info['size'] > $this->xcloner_split_backup_limit) {
-                    $this->logger->info(sprintf("Excluding %s file as it's size(%s) is bigger than the backup split limit of %s and it won't fit a single backup file",
-                        $file_info['path'], $file_info['size'], $this->xcloner_split_backup_limit));
-                    $extra_params['start_at_line']++;
-                }
+				if ($file_info['size'] > $this->xcloner_split_backup_limit) {
+					$this->logger->info(sprintf("Excluding %s file as it's size(%s) is bigger than the backup split limit of %s and it won't fit a single backup file",
+						$file_info['path'], $file_info['size'], $this->xcloner_split_backup_limit));
+					$extra_params['start_at_line']++;
+				}
 
-                $return['extra']['start_at_line'] = $extra_params['start_at_line'];
-                $return['extra']['start_at_byte'] = 0;
+				$return['extra']['start_at_line'] = $extra_params['start_at_line'];
+				$return['extra']['start_at_byte'] = 0;
 
-                $return['finished'] = 0;
+				$return['finished'] = 0;
 
-                return $return;
-            }
+				return $return;
+			}
 
-            list($bytes_wrote, $last_position) = $this->add_file_to_archive($file_info, $start_byte, $byte_limit,
-                $append, $start_filesystem);
-            $this->processed_size_bytes += $bytes_wrote;
+			list($bytes_wrote, $last_position) = $this->add_file_to_archive($file_info, $start_byte, $byte_limit,
+				$append, $start_filesystem);
+			$this->processed_size_bytes += $bytes_wrote;
 
-            //echo" - processed ".$this->processed_size_bytes." bytes ".$this->file_size_per_request_limit." last_position:".$last_position." \n";
-            $return['extra']['processed_file'] = $file_info['path'];
-            $return['extra']['processed_file_size'] = $file_info['size'];
-            $return['extra']['backup_size'] = $archive_info->getSize();
+			//echo" - processed ".$this->processed_size_bytes." bytes ".$this->file_size_per_request_limit." last_position:".$last_position." \n";
+			$return['extra']['processed_file'] = $file_info['path'];
+			$return['extra']['processed_file_size'] = $file_info['size'];
+			$return['extra']['backup_size'] = $archive_info->getSize();
 
-            if ($last_position > 0) {
-                $start_byte = $last_position;
-            } else {
-                $extra_params['start_at_line']++;
-                $file->next();
-                $start_byte = 0;
-                $counter++;
-            }
+			if ($last_position > 0) {
+				$start_byte = $last_position;
+			} else {
+				$extra_params['start_at_line']++;
+				$file->next();
+				$start_byte = 0;
+				$counter++;
+			}
 
-            if ($this->processed_size_bytes >= $this->file_size_per_request_limit) {
-                clearstatcache();
-                $return['extra']['backup_size'] = $archive_info->getSize();
+			if ($this->processed_size_bytes >= $this->file_size_per_request_limit) {
+				clearstatcache();
+				$return['extra']['backup_size'] = $archive_info->getSize();
 
-                $return['finished'] = 0;
-                $return['extra']['start_at_line'] = $extra_params['start_at_line'];
-                $return['extra']['start_at_byte'] = $last_position;
-                $this->logger->info(sprintf("Reached the maximum %s request data limit, returning response",
-                    $this->file_size_per_request_limit));
-                return $return;
-            }
-        }
+				$return['finished'] = 0;
+				$return['extra']['start_at_line'] = $extra_params['start_at_line'];
+				$return['extra']['start_at_byte'] = $last_position;
+				$this->logger->info(sprintf("Reached the maximum %s request data limit, returning response",
+					$this->file_size_per_request_limit));
+				return $return;
+			}
+		}
 
-        if (!$file->eof()) {
-            clearstatcache();
-            $return['extra']['backup_size'] = $archive_info->getSize();
+		if (!$file->eof()) {
+			clearstatcache();
+			$return['extra']['backup_size'] = $archive_info->getSize();
 
-            $return['finished'] = 0;
-            $return['extra']['start_at_line'] = $extra_params['start_at_line'];
-            $return['extra']['start_at_byte'] = $last_position;
-            $this->logger->info(sprintf("We have reached the maximum files to process per request limit of %s, returning response",
-                $this->files_to_process_per_request));
+			$return['finished'] = 0;
+			$return['extra']['start_at_line'] = $extra_params['start_at_line'];
+			$return['extra']['start_at_byte'] = $last_position;
+			$this->logger->info(sprintf("We have reached the maximum files to process per request limit of %s, returning response",
+				$this->files_to_process_per_request));
 
-            return $return;
-        }
+			return $return;
+		}
 
-        //close the backup archive by adding 2*512 blocks of zero bytes
-        $this->logger->info(sprintf("Closing the backup archive %s with 2*512 zero bytes blocks.",
-            $this->get_archive_name_with_extension()));
-        $this->backup_archive->close();
+		//close the backup archive by adding 2*512 blocks of zero bytes
+		$this->logger->info(sprintf("Closing the backup archive %s with 2*512 zero bytes blocks.",
+			$this->get_archive_name_with_extension()));
+		$this->backup_archive->close();
 
-        /**
-         * XCloner HOOK backup_archive_finished.
-         *
-         * This will get triggered when a backup archive is finished writing.
-         */
-        //do_action('backup_archive_finished', $this->backup_archive, $this);
+		/**
+		 * XCloner HOOK backup_archive_finished.
+		 *
+		 * This will get triggered when a backup archive is finished writing.
+		 */
+		//do_action('backup_archive_finished', $this->backup_archive, $this);
 
-        //updating archive_info
-        $archive_info = $this->filesystem->get_storage_path_file_info($this->get_archive_name_with_extension());
+		//updating archive_info
+		$archive_info = $this->filesystem->get_storage_path_file_info($this->get_archive_name_with_extension());
 
-        if ($return['extra']['backup_part']) {
-            $this->write_multipart_file($this->get_archive_name_with_extension());
-        }
+		if ($return['extra']['backup_part']) {
+			$this->write_multipart_file($this->get_archive_name_with_extension());
+		}
 
-        $return['extra']['start_at_line'] = $extra_params['start_at_line'] - 1;
+		$return['extra']['start_at_line'] = $extra_params['start_at_line'] - 1;
 
-        if (isset($file_info)) {
-            $return['extra']['processed_file'] = $file_info['path'];
-            $return['extra']['processed_file_size'] = $file_info['size'];
-        }
+		if (isset($file_info)) {
+			$return['extra']['processed_file'] = $file_info['path'];
+			$return['extra']['processed_file_size'] = $file_info['size'];
+		}
 
-        clearstatcache();
-        $return['extra']['backup_size'] = $archive_info->getSize();
+		clearstatcache();
+		$return['extra']['backup_size'] = $archive_info->getSize();
 
-        $return['finished'] = 1;
-        return $return;
-    }
+		$return['finished'] = 1;
+		return $return;
+	}
 
-    /*
+	/*
      *
      * Write multipart file components
      *
      */
-    private function write_multipart_file($path)
-    {
-        $path = $this->get_archive_name_with_extension();
+	private function write_multipart_file($path)
+	{
+		$path = $this->get_archive_name_with_extension();
 
-        $file = $this->filesystem->get_filesystem("storage_filesystem_append")->getMetadata($path);
-        //print_r($file_info);
-        $line = '"' . $file['path'] . '","' . $file['timestamp'] . '","' . $file['size'] . '"' . PHP_EOL;
+		$file = $this->filesystem->get_filesystem("storage_filesystem_append")->getMetadata($path);
+		//print_r($file_info);
+		$line = '"' . $file['path'] . '","' . $file['timestamp'] . '","' . $file['size'] . '"' . PHP_EOL;
 
 
-        $this->filesystem->get_filesystem("storage_filesystem_append")
-            ->write($this->get_archive_name_multipart(), $line);
-    }
+		$this->filesystem->get_filesystem("storage_filesystem_append")
+			->write($this->get_archive_name_multipart(), $line);
+	}
 
-    /*
+	/*
      *
      * Create a new backup part
      *
      */
-    private function create_new_backup_part($part = 0)
-    {
-        //close the backup archive by adding 2*512 blocks of zero bytes
-        $this->logger->info(sprintf("Closing the backup archive %s with 2*512 zero bytes blocks.",
-            $this->get_archive_name_with_extension()));
-        $this->backup_archive->close();
-
-        if (!$part) {
-            $old_name = $this->get_archive_name_with_extension();
-            $this->set_archive_name($this->get_archive_name(), ++$part);
-            $this->rename_archive($old_name, $this->get_archive_name_with_extension());
-
-            if ($this->filesystem->get_storage_filesystem()->has($this->get_archive_name_multipart())) {
-                $this->filesystem->get_storage_filesystem()->delete($this->get_archive_name_multipart());
-            }
-
-            $this->write_multipart_file($this->get_archive_name_with_extension());
-
-        } else {
-            $this->logger->info(sprintf("Creating new multipart info file %s",
-                $this->get_archive_name_with_extension()));
-            $this->write_multipart_file($this->get_archive_name_with_extension());
-        }
+	private function create_new_backup_part($part = 0)
+	{
+		//close the backup archive by adding 2*512 blocks of zero bytes
+		$this->logger->info(sprintf("Closing the backup archive %s with 2*512 zero bytes blocks.",
+			$this->get_archive_name_with_extension()));
+		$this->backup_archive->close();
+
+		if (!$part) {
+			$old_name = $this->get_archive_name_with_extension();
+			$this->set_archive_name($this->get_archive_name(), ++$part);
+			$this->rename_archive($old_name, $this->get_archive_name_with_extension());
+
+			if ($this->filesystem->get_storage_filesystem()->has($this->get_archive_name_multipart())) {
+				$this->filesystem->get_storage_filesystem()->delete($this->get_archive_name_multipart());
+			}
+
+			$this->write_multipart_file($this->get_archive_name_with_extension());
+
+		} else {
+			$this->logger->info(sprintf("Creating new multipart info file %s",
+				$this->get_archive_name_with_extension()));
+			$this->write_multipart_file($this->get_archive_name_with_extension());
+		}
 
-        $this->set_archive_name($this->get_archive_name(), ++$part);
+		$this->set_archive_name($this->get_archive_name(), ++$part);
 
-        $this->logger->info(sprintf("Creating new backup archive part %s", $this->get_archive_name_with_extension()));
+		$this->logger->info(sprintf("Creating new backup archive part %s", $this->get_archive_name_with_extension()));
 
-        $this->backup_archive = new Tar();
-        $this->backup_archive->setCompression($this->compression_level);
-        $archive_info = $this->filesystem->get_storage_path_file_info($this->get_archive_name_with_extension());
-        $this->backup_archive->create($archive_info->getPath() . DS . $archive_info->getFilename());
+		$this->backup_archive = new Tar();
+		$this->backup_archive->setCompression($this->compression_level);
+		$archive_info = $this->filesystem->get_storage_path_file_info($this->get_archive_name_with_extension());
+		$this->backup_archive->create($archive_info->getPath() . DS . $archive_info->getFilename());
 
-        return array($archive_info, $part);
+		return array($archive_info, $part);
 
-    }
+	}
 
-    /*
+	/*
      *
      * Add file to archive
      *
      */
-    public function add_file_to_archive($file_info, $start_at_byte, $byte_limit = 0, $append, $filesystem)
-    {
-
-        $start_adapter = $this->filesystem->get_adapter($filesystem);
-        $start_filesystem = $this->filesystem->get_adapter($filesystem);
-
-        if (!$file_info['path']) {
-            return;
-        }
-
-        if (isset($file_info['archive_prefix_path'])) {
-            $file_info['target_path'] = $file_info['archive_prefix_path'] . "/" . $file_info['path'];
-        } else {
-            $file_info['target_path'] = $file_info['path'];
-        }
-
-        $last_position = $start_at_byte;
-
-        //$start_adapter = $this->filesystem->get_start_adapter();
-
-        if (!$append) {
-            $bytes_wrote = $file_info['size'];
-            $this->logger->info(sprintf("Adding %s bytes of file %s to archive %s ", $bytes_wrote,
-                $file_info['target_path'], $this->get_archive_name_with_extension()));
-            $this->backup_archive->addFile($start_adapter->applyPathPrefix($file_info['path']),
-                $file_info['target_path']);
-        } else {
-            $tmp_file = md5($file_info['path']);
-
-            //we isolate file to tmp if we are at byte 0, the starting point of file reading
-            if (!$start_at_byte) {
-                $this->logger->info(sprintf("Copying %s file to tmp filesystem file %s to prevent reading changes",
-                    $file_info['path'], $tmp_file));
-                $file_stream = $start_filesystem->readStream($file_info['path']);
-
-                if (is_resource($file_stream['stream'])) {
-                    $this->filesystem->get_tmp_filesystem()->writeStream($tmp_file, $file_stream['stream']);
-                }
-            }
-
-            if ($this->filesystem->get_tmp_filesystem()->has($tmp_file)) {
-                $is_tmp = 1;
-                $last_position = $this->backup_archive->appendFileData($this->filesystem->get_tmp_filesystem_adapter()
-                                                        ->applyPathPrefix($tmp_file),
-                    $file_info['target_path'], $start_at_byte, $byte_limit);
-            } else {
-                $is_tmp = 0;
-                $last_position = $this->backup_archive->appendFileData($start_adapter->applyPathPrefix($file_info['path']),
-                    $file_info['target_path'], $start_at_byte, $byte_limit);
-            }
-
-
-            if ($last_position == -1) {
-                $bytes_wrote = $file_info['size'] - $start_at_byte;
-            } else {
-                $bytes_wrote = $last_position - $start_at_byte;
-            }
+	public function add_file_to_archive($file_info, $start_at_byte, $byte_limit = 0, $append, $filesystem)
+	{
 
+		$start_adapter = $this->filesystem->get_adapter($filesystem);
+		$start_filesystem = $this->filesystem->get_adapter($filesystem);
 
-            if ($is_tmp) {
-                $this->logger->info(sprintf("Appended %s bytes, starting position %s, of tmp file %s (%s) to archive %s ",
-                    $bytes_wrote, $start_at_byte, $tmp_file, $file_info['target_path'], $this->get_archive_name()));
-            } else {
-                $this->logger->info(sprintf("Appended %s bytes, starting position %s, of original file %s to archive %s ",
-                    $bytes_wrote, $start_at_byte, $file_info['target_path'], $tmp_file, $this->get_archive_name()));
-            }
+		if (!$file_info['path']) {
+			return;
+		}
 
-            //we delete here the isolated tmp file
-            if ($last_position == -1) {
-                if ($this->filesystem->get_tmp_filesystem_adapter()->has($tmp_file)) {
-                    $this->logger->info(sprintf("Deleting %s from the tmp filesystem", $tmp_file));
-                    $this->filesystem->get_tmp_filesystem_adapter()->delete($tmp_file);
-                }
-            }
+		if (isset($file_info['archive_prefix_path'])) {
+			$file_info['target_path'] = $file_info['archive_prefix_path'] . "/" . $file_info['path'];
+		} else {
+			$file_info['target_path'] = $file_info['path'];
+		}
 
-        }
+		$last_position = $start_at_byte;
+
+		//$start_adapter = $this->filesystem->get_start_adapter();
+
+		if (!$append) {
+			$bytes_wrote = $file_info['size'];
+			$this->logger->info(sprintf("Adding %s bytes of file %s to archive %s ", $bytes_wrote,
+				$file_info['target_path'], $this->get_archive_name_with_extension()));
+			$this->backup_archive->addFile($start_adapter->applyPathPrefix($file_info['path']),
+				$file_info['target_path']);
+		} else {
+			$tmp_file = md5($file_info['path']);
+
+			//we isolate file to tmp if we are at byte 0, the starting point of file reading
+			if (!$start_at_byte) {
+				$this->logger->info(sprintf("Copying %s file to tmp filesystem file %s to prevent reading changes",
+					$file_info['path'], $tmp_file));
+				$file_stream = $start_filesystem->readStream($file_info['path']);
+
+				if (is_resource($file_stream['stream'])) {
+					$this->filesystem->get_tmp_filesystem()->writeStream($tmp_file, $file_stream['stream']);
+				}
+			}
+
+			if ($this->filesystem->get_tmp_filesystem()->has($tmp_file)) {
+				$is_tmp = 1;
+				$last_position = $this->backup_archive->appendFileData($this->filesystem->get_tmp_filesystem_adapter()
+														->applyPathPrefix($tmp_file),
+					$file_info['target_path'], $start_at_byte, $byte_limit);
+			} else {
+				$is_tmp = 0;
+				$last_position = $this->backup_archive->appendFileData($start_adapter->applyPathPrefix($file_info['path']),
+					$file_info['target_path'], $start_at_byte, $byte_limit);
+			}
+
+
+			if ($last_position == -1) {
+				$bytes_wrote = $file_info['size'] - $start_at_byte;
+			} else {
+				$bytes_wrote = $last_position - $start_at_byte;
+			}
+
+
+			if ($is_tmp) {
+				$this->logger->info(sprintf("Appended %s bytes, starting position %s, of tmp file %s (%s) to archive %s ",
+					$bytes_wrote, $start_at_byte, $tmp_file, $file_info['target_path'], $this->get_archive_name()));
+			} else {
+				$this->logger->info(sprintf("Appended %s bytes, starting position %s, of original file %s to archive %s ",
+					$bytes_wrote, $start_at_byte, $file_info['target_path'], $tmp_file, $this->get_archive_name()));
+			}
+
+			//we delete here the isolated tmp file
+			if ($last_position == -1) {
+				if ($this->filesystem->get_tmp_filesystem_adapter()->has($tmp_file)) {
+					$this->logger->info(sprintf("Deleting %s from the tmp filesystem", $tmp_file));
+					$this->filesystem->get_tmp_filesystem_adapter()->delete($tmp_file);
+				}
+			}
 
-        return array($bytes_wrote, $last_position);
-    }
+		}
 
-    /**
-     * Open a TAR archive and put the file cursor at the end for data appending
-     *
-     * If $file is empty, the tar file will be created in memory
-     *
-     * @param string $file
-     * @throws ArchiveIOException
-     */
-    /*
+		return array($bytes_wrote, $last_position);
+	}
+
+	/**
+	 * Open a TAR archive and put the file cursor at the end for data appending
+	 *
+	 * If $file is empty, the tar file will be created in memory
+	 *
+	 * @param string $file
+	 * @throws ArchiveIOException
+	 */
+	/*
     public function openForAppend($file = '')
     {
         $this->file   = $file;
@@ -754,17 +754,17 @@ 
     }
     */
 
-    /**
-     * Append data to a file to the current TAR archive using an existing file in the filesystem
-     *
-     * @param string $file path to the original file
-     * @param int $start starting reading position in file
-     * @param int $end end position in reading multiple with 512
-     * @param string|FileInfo $fileinfo either the name to us in archive (string) or a FileInfo oject with
-     * all meta data, empty to take from original
-     * @throws ArchiveIOException
-     */
-    /*
+	/**
+	 * Append data to a file to the current TAR archive using an existing file in the filesystem
+	 *
+	 * @param string $file path to the original file
+	 * @param int $start starting reading position in file
+	 * @param int $end end position in reading multiple with 512
+	 * @param string|FileInfo $fileinfo either the name to us in archive (string) or a FileInfo oject with
+	 * all meta data, empty to take from original
+	 * @throws ArchiveIOException
+	 */
+	/*
      * public function appendFileData($file, $fileinfo = '', $start = 0, $limit = 0)
     {
 		$end = $start+($limit*512);
@@ -820,15 +820,15 @@ 
         return $last_position;
     }*/
 
-    /**
-     * Adds a file to a TAR archive by appending it's data
-     *
-     * @param string $archive name of the archive file
-     * @param string $file name of the file to read data from
-     * @param string $start start position from where to start reading data
-     * @throws ArchiveIOException
-     */
-    /*public function addFileToArchive($archive, $file, $start = 0)
+	/**
+	 * Adds a file to a TAR archive by appending it's data
+	 *
+	 * @param string $archive name of the archive file
+	 * @param string $file name of the file to read data from
+	 * @param string $start start position from where to start reading data
+	 * @throws ArchiveIOException
+	 */
+	/*public function addFileToArchive($archive, $file, $start = 0)
     {
         $this->openForAppend($archive);
         return $start = $this->appendFileData($file, $start, $this->file_size_per_request_limit);

includes/class-xcloner.php

Indentation +21 added lines, -21 removed lines

@@ -321,7 +321,7 @@ 
 		$this->loader->add_action( 'plugins_loaded', $plugin_i18n, 'load_plugin_textdomain' );
 
 		//wp_localize_script( 'ajax-script', 'my_ajax_object',
-        //   array( 'ajax_url' => admin_url( 'admin-ajax.php' ) ) );
+		//   array( 'ajax_url' => admin_url( 'admin-ajax.php' ) ) );
 
 	}
 
@@ -357,8 +357,8 @@ 
 
 	private function define_plugin_settings(){
 		/**
-		* register wporg_settings_init to the admin_init action hook
-		*/
+		 * register wporg_settings_init to the admin_init action hook
+		 */
 
 		$this->xcloner_settings = new XCloner_Settings($this);
 
@@ -513,15 +513,15 @@ 
 	}
 
 	function friendly_error_type($type) {
-	    static $levels=null;
-	    if ($levels===null) {
-	        $levels=[];
-	        foreach (get_defined_constants() as $key=>$value) {
-	            if (strpos($key,'E_')!==0) {continue;}
+		static $levels=null;
+		if ($levels===null) {
+			$levels=[];
+			foreach (get_defined_constants() as $key=>$value) {
+				if (strpos($key,'E_')!==0) {continue;}
 					$levels[$value]= $key; //substr($key,2);
-	        }
-	    }
-	    return (isset($levels[$type]) ? $levels[$type] : "Error #{$type}");
+			}
+		}
+		return (isset($levels[$type]) ? $levels[$type] : "Error #{$type}");
 	}
 
 	private function define_ajax_hooks()
@@ -563,24 +563,24 @@ 
 			add_action( 'wp_ajax_restore_backup', 				array($xcloner_api,'restore_backup')  );
 			add_action( 'admin_notices', 						array($this, 'xcloner_error_admin_notices' ));
 
-        }
+		}
 
-        //Do a pre-update backup of targeted files
-        if($this->get_xcloner_settings()->get_xcloner_option('xcloner_enable_pre_update_backup'))
-        {
+		//Do a pre-update backup of targeted files
+		if($this->get_xcloner_settings()->get_xcloner_option('xcloner_enable_pre_update_backup'))
+		{
 			add_action("pre_auto_update", array($this, "pre_auto_update"), 1, 3);
 		}
 	}
 
 	function add_plugin_action_links($links, $file) {
-        if ($file == plugin_basename(dirname(dirname(__FILE__)) . '/xcloner.php'))
+		if ($file == plugin_basename(dirname(dirname(__FILE__)) . '/xcloner.php'))
 		{
 			$links[] = '<a href="admin.php?page=xcloner_settings_page">'.__('Settings', 'xcloner-backup-and-restore').'</a>';
 			$links[] = '<a href="admin.php?page=xcloner_generate_backups_page">'.__('Generate Backup', 'xcloner-backup-and-restore').'</a>';
 		}
 
-        return $links;
-    }
+		return $links;
+	}
 
 	public function xcloner_error_admin_notices() {
 			settings_errors( 'xcloner_error_message' );
@@ -664,9 +664,9 @@ 
 	function xcloner_display()
 	{
 		// check user capabilities
-	    if (!current_user_can('manage_options')) {
-	        return;
-	    }
+		if (!current_user_can('manage_options')) {
+			return;
+		}
 
 		$page = sanitize_key($_GET['page']);
 

includes/class-xcloner-api.php

Indentation +889 added lines, -889 removed lines

@@ -43,905 +43,905 @@ 
 class Xcloner_Api
 {
 
-    private $xcloner_database;
-    private $xcloner_settings;
-    private $xcloner_file_system;
-    private $xcloner_requirements;
-    private $xcloner_sanitization;
-    private $archive_system;
-    private $form_params;
-    private $logger;
-    private $xcloner_container;
-
-    /**
-     * XCloner_Api construct class
-     *
-     * @param Xcloner $xcloner_container [description]
-     */
-    public function __construct(Xcloner $xcloner_container)
-    {
-        global $wpdb;
-
-        if (WP_DEBUG) {
-            error_reporting(0);
-        }
-
-        if (ob_get_length()) {
-            ob_end_clean();
-        }
-        ob_start();
-
-        $wpdb->show_errors = false;
-
-        $this->xcloner_container = $xcloner_container;
-
-        $this->xcloner_settings = $xcloner_container->get_xcloner_settings();
-        $this->logger = $xcloner_container->get_xcloner_logger()->withName("xcloner_api");
-        $this->xcloner_file_system = $xcloner_container->get_xcloner_filesystem();
-        $this->xcloner_sanitization = $xcloner_container->get_xcloner_sanitization();
-        $this->xcloner_requirements = $xcloner_container->get_xcloner_requirements();
-        $this->archive_system = $xcloner_container->get_archive_system();
-        $this->xcloner_database = $xcloner_container->get_xcloner_database();
-        $this->xcloner_scheduler = $xcloner_container->get_xcloner_scheduler();
-
-        if (isset($_POST['API_ID'])) {
-            $this->logger->info("Processing ajax request ID " . substr($this->xcloner_sanitization->sanitize_input_as_string($_POST['API_ID']),
-                    0, 15));
-        }
-
-    }
-
-    /**
-     * Get XCloner Container
-     * @return XCloner return the XCloner container
-     */
-    public function get_xcloner_container()
-    {
-        return $this->xcloner_container;
-    }
-
-    /**
-     * Check if user has access to this class
-     * @return die() returns die() if user is not allowed
-     * @link http://www.wordpress.org
-     */
-    private function check_access()
-    {
-        if (function_exists('current_user_can') && !current_user_can('manage_options')) {
-            die("Not allowed access here!");
-        }
-    }
-
-    /**
-     * Initialize the database connection
-     */
-    public function init_db()
-    {
-        return;
-
-
-        $data['dbHostname'] = $this->xcloner_settings->get_db_hostname();
-        $data['dbUsername'] = $this->xcloner_settings->get_db_username();
-        $data['dbPassword'] = $this->xcloner_settings->get_db_password();
-        $data['dbDatabase'] = $this->xcloner_settings->get_db_database();
-
-
-        $data['recordsPerSession'] = $this->xcloner_settings->get_xcloner_option('xcloner_database_records_per_request');
-        $data['TEMP_DBPROCESS_FILE'] = $this->xcloner_settings->get_xcloner_tmp_path() . DS . ".database";
-        $data['TEMP_DUMP_FILE'] = $this->xcloner_settings->get_xcloner_tmp_path() . DS . "database-sql.sql";
-
-        try {
-            $this->xcloner_database->init($data);
-
-        } catch (Exception $e) {
-
-            $this->send_response($e->getMessage());
-            $this->logger->error($e->getMessage());
-
-        }
-
-        return $this->xcloner_database;
-
-
-    }
-
-    /*
+	private $xcloner_database;
+	private $xcloner_settings;
+	private $xcloner_file_system;
+	private $xcloner_requirements;
+	private $xcloner_sanitization;
+	private $archive_system;
+	private $form_params;
+	private $logger;
+	private $xcloner_container;
+
+	/**
+	 * XCloner_Api construct class
+	 *
+	 * @param Xcloner $xcloner_container [description]
+	 */
+	public function __construct(Xcloner $xcloner_container)
+	{
+		global $wpdb;
+
+		if (WP_DEBUG) {
+			error_reporting(0);
+		}
+
+		if (ob_get_length()) {
+			ob_end_clean();
+		}
+		ob_start();
+
+		$wpdb->show_errors = false;
+
+		$this->xcloner_container = $xcloner_container;
+
+		$this->xcloner_settings = $xcloner_container->get_xcloner_settings();
+		$this->logger = $xcloner_container->get_xcloner_logger()->withName("xcloner_api");
+		$this->xcloner_file_system = $xcloner_container->get_xcloner_filesystem();
+		$this->xcloner_sanitization = $xcloner_container->get_xcloner_sanitization();
+		$this->xcloner_requirements = $xcloner_container->get_xcloner_requirements();
+		$this->archive_system = $xcloner_container->get_archive_system();
+		$this->xcloner_database = $xcloner_container->get_xcloner_database();
+		$this->xcloner_scheduler = $xcloner_container->get_xcloner_scheduler();
+
+		if (isset($_POST['API_ID'])) {
+			$this->logger->info("Processing ajax request ID " . substr($this->xcloner_sanitization->sanitize_input_as_string($_POST['API_ID']),
+					0, 15));
+		}
+
+	}
+
+	/**
+	 * Get XCloner Container
+	 * @return XCloner return the XCloner container
+	 */
+	public function get_xcloner_container()
+	{
+		return $this->xcloner_container;
+	}
+
+	/**
+	 * Check if user has access to this class
+	 * @return die() returns die() if user is not allowed
+	 * @link http://www.wordpress.org
+	 */
+	private function check_access()
+	{
+		if (function_exists('current_user_can') && !current_user_can('manage_options')) {
+			die("Not allowed access here!");
+		}
+	}
+
+	/**
+	 * Initialize the database connection
+	 */
+	public function init_db()
+	{
+		return;
+
+
+		$data['dbHostname'] = $this->xcloner_settings->get_db_hostname();
+		$data['dbUsername'] = $this->xcloner_settings->get_db_username();
+		$data['dbPassword'] = $this->xcloner_settings->get_db_password();
+		$data['dbDatabase'] = $this->xcloner_settings->get_db_database();
+
+
+		$data['recordsPerSession'] = $this->xcloner_settings->get_xcloner_option('xcloner_database_records_per_request');
+		$data['TEMP_DBPROCESS_FILE'] = $this->xcloner_settings->get_xcloner_tmp_path() . DS . ".database";
+		$data['TEMP_DUMP_FILE'] = $this->xcloner_settings->get_xcloner_tmp_path() . DS . "database-sql.sql";
+
+		try {
+			$this->xcloner_database->init($data);
+
+		} catch (Exception $e) {
+
+			$this->send_response($e->getMessage());
+			$this->logger->error($e->getMessage());
+
+		}
+
+		return $this->xcloner_database;
+
+
+	}
+
+	/*
      * Save Schedule API
      */
-    public function save_schedule()
-    {
-        global $wpdb;
-
-        $this->check_access();
-
-        $scheduler = $this->xcloner_scheduler;
-        $params = array();
-        $schedule = array();
-        $response = array();
-
-        if (isset($_POST['data'])) {
-            $params = json_decode(stripslashes($_POST['data']));
-        }
-
-        $this->process_params($params);
-
-        if (isset($_POST['id'])) {
-
-            $this->form_params['backup_params']['backup_name'] = $this->xcloner_sanitization->sanitize_input_as_string($_POST['backup_name']);
-            $this->form_params['backup_params']['email_notification'] = $this->xcloner_sanitization->sanitize_input_as_string($_POST['email_notification']);
-            if ($_POST['diff_start_date']) {
-                $this->form_params['backup_params']['diff_start_date'] = strtotime($this->xcloner_sanitization->sanitize_input_as_string($_POST['diff_start_date']));
-            } else {
-                $this->form_params['backup_params']['diff_start_date'] = "";
-            }
-            $this->form_params['backup_params']['schedule_name'] = $this->xcloner_sanitization->sanitize_input_as_string($_POST['schedule_name']);
-            $this->form_params['backup_params']['start_at'] = strtotime($_POST['schedule_start_date']);
-            $this->form_params['backup_params']['schedule_frequency'] = $this->xcloner_sanitization->sanitize_input_as_string($_POST['schedule_frequency']);
-            $this->form_params['backup_params']['schedule_storage'] = $this->xcloner_sanitization->sanitize_input_as_string($_POST['schedule_storage']);
-            $this->form_params['database'] = (stripslashes($this->xcloner_sanitization->sanitize_input_as_raw($_POST['table_params'])));
-            $this->form_params['excluded_files'] = (stripslashes($this->xcloner_sanitization->sanitize_input_as_raw($_POST['excluded_files'])));
-
-            //$this->form_params['backup_params']['backup_type'] = $this->xcloner_sanitization->sanitize_input_as_string($_POST['backup_type']);
-
-            $tables = explode(PHP_EOL, $this->form_params['database']);
-            $return = array();
-
-            foreach ($tables as $table) {
-                $table = str_replace("\r", "", $table);
-                $data = explode(".", $table);
-                if (isset($data[1])) {
-                    $return[$data[0]][] = $data[1];
-                }
-            }
-
-            $this->form_params['database'] = ($return);
-
-            $excluded_files = explode(PHP_EOL, $this->form_params['excluded_files']);
-            $return = array();
-
-            foreach ($excluded_files as $file) {
-                $file = str_replace("\r", "", $file);
-                if ($file) {
-                    $return[] = $file;
-                }
-            }
-
-            $this->form_params['excluded_files'] = ($return);
-
-            $schedule['start_at'] = $this->form_params['backup_params']['start_at'];
-
-            if (!isset($_POST['status'])) {
-                $schedule['status'] = 0;
-            } else {
-                $schedule['status'] = $this->xcloner_sanitization->sanitize_input_as_int($_POST['status']);
-            }
-        } else {
-
-            $schedule['status'] = 1;
-            $schedule['start_at'] = strtotime($this->form_params['backup_params']['schedule_start_date'] .
-                " " . $this->form_params['backup_params']['schedule_start_time']);
-
-            if ($schedule['start_at'] <= time()) {
-                $schedule['start_at'] = "";
-            }
-        }
-
-        if (!$schedule['start_at']) {
-            $schedule['start_at'] = date('Y-m-d H:i:s', time());
-        } else {
-            $schedule['start_at'] = date('Y-m-d H:i:s',
-                $schedule['start_at'] - (get_option('gmt_offset') * HOUR_IN_SECONDS));
-        }
-
-        $schedule['name'] = $this->form_params['backup_params']['schedule_name'];
-        $schedule['recurrence'] = $this->form_params['backup_params']['schedule_frequency'];
-        if (!isset($this->form_params['backup_params']['schedule_storage'])) {
-            $this->form_params['backup_params']['schedule_storage'] = "";
-        }
-        $schedule['remote_storage'] = $this->form_params['backup_params']['schedule_storage'];
-        //$schedule['backup_type'] = $this->form_params['backup_params']['backup_type'];
-        $schedule['params'] = json_encode($this->form_params);
-
-        if (!isset($_POST['id'])) {
-            $wpdb->insert(
-                $wpdb->prefix . 'xcloner_scheduler',
-                $schedule,
-                array(
-                    '%s',
-                    '%s'
-                )
-            );
-        } else {
-            $wpdb->update(
-                $wpdb->prefix . 'xcloner_scheduler',
-                $schedule,
-                array('id' => $_POST['id']),
-                array(
-                    '%s',
-                    '%s'
-                )
-            );
-        }
-        if (isset($_POST['id'])) {
-            $scheduler->update_cron_hook($_POST['id']);
-        }
-
-        if ($wpdb->last_error) {
-            $response['error'] = 1;
-            $response['error_message'] = $wpdb->last_error/*."--".$wpdb->last_query*/
-            ;
-
-        }
-
-        $scheduler->update_wp_cron_hooks();
-        $response['finished'] = 1;
-
-        $this->send_response($response);
-    }
-
-    /*
+	public function save_schedule()
+	{
+		global $wpdb;
+
+		$this->check_access();
+
+		$scheduler = $this->xcloner_scheduler;
+		$params = array();
+		$schedule = array();
+		$response = array();
+
+		if (isset($_POST['data'])) {
+			$params = json_decode(stripslashes($_POST['data']));
+		}
+
+		$this->process_params($params);
+
+		if (isset($_POST['id'])) {
+
+			$this->form_params['backup_params']['backup_name'] = $this->xcloner_sanitization->sanitize_input_as_string($_POST['backup_name']);
+			$this->form_params['backup_params']['email_notification'] = $this->xcloner_sanitization->sanitize_input_as_string($_POST['email_notification']);
+			if ($_POST['diff_start_date']) {
+				$this->form_params['backup_params']['diff_start_date'] = strtotime($this->xcloner_sanitization->sanitize_input_as_string($_POST['diff_start_date']));
+			} else {
+				$this->form_params['backup_params']['diff_start_date'] = "";
+			}
+			$this->form_params['backup_params']['schedule_name'] = $this->xcloner_sanitization->sanitize_input_as_string($_POST['schedule_name']);
+			$this->form_params['backup_params']['start_at'] = strtotime($_POST['schedule_start_date']);
+			$this->form_params['backup_params']['schedule_frequency'] = $this->xcloner_sanitization->sanitize_input_as_string($_POST['schedule_frequency']);
+			$this->form_params['backup_params']['schedule_storage'] = $this->xcloner_sanitization->sanitize_input_as_string($_POST['schedule_storage']);
+			$this->form_params['database'] = (stripslashes($this->xcloner_sanitization->sanitize_input_as_raw($_POST['table_params'])));
+			$this->form_params['excluded_files'] = (stripslashes($this->xcloner_sanitization->sanitize_input_as_raw($_POST['excluded_files'])));
+
+			//$this->form_params['backup_params']['backup_type'] = $this->xcloner_sanitization->sanitize_input_as_string($_POST['backup_type']);
+
+			$tables = explode(PHP_EOL, $this->form_params['database']);
+			$return = array();
+
+			foreach ($tables as $table) {
+				$table = str_replace("\r", "", $table);
+				$data = explode(".", $table);
+				if (isset($data[1])) {
+					$return[$data[0]][] = $data[1];
+				}
+			}
+
+			$this->form_params['database'] = ($return);
+
+			$excluded_files = explode(PHP_EOL, $this->form_params['excluded_files']);
+			$return = array();
+
+			foreach ($excluded_files as $file) {
+				$file = str_replace("\r", "", $file);
+				if ($file) {
+					$return[] = $file;
+				}
+			}
+
+			$this->form_params['excluded_files'] = ($return);
+
+			$schedule['start_at'] = $this->form_params['backup_params']['start_at'];
+
+			if (!isset($_POST['status'])) {
+				$schedule['status'] = 0;
+			} else {
+				$schedule['status'] = $this->xcloner_sanitization->sanitize_input_as_int($_POST['status']);
+			}
+		} else {
+
+			$schedule['status'] = 1;
+			$schedule['start_at'] = strtotime($this->form_params['backup_params']['schedule_start_date'] .
+				" " . $this->form_params['backup_params']['schedule_start_time']);
+
+			if ($schedule['start_at'] <= time()) {
+				$schedule['start_at'] = "";
+			}
+		}
+
+		if (!$schedule['start_at']) {
+			$schedule['start_at'] = date('Y-m-d H:i:s', time());
+		} else {
+			$schedule['start_at'] = date('Y-m-d H:i:s',
+				$schedule['start_at'] - (get_option('gmt_offset') * HOUR_IN_SECONDS));
+		}
+
+		$schedule['name'] = $this->form_params['backup_params']['schedule_name'];
+		$schedule['recurrence'] = $this->form_params['backup_params']['schedule_frequency'];
+		if (!isset($this->form_params['backup_params']['schedule_storage'])) {
+			$this->form_params['backup_params']['schedule_storage'] = "";
+		}
+		$schedule['remote_storage'] = $this->form_params['backup_params']['schedule_storage'];
+		//$schedule['backup_type'] = $this->form_params['backup_params']['backup_type'];
+		$schedule['params'] = json_encode($this->form_params);
+
+		if (!isset($_POST['id'])) {
+			$wpdb->insert(
+				$wpdb->prefix . 'xcloner_scheduler',
+				$schedule,
+				array(
+					'%s',
+					'%s'
+				)
+			);
+		} else {
+			$wpdb->update(
+				$wpdb->prefix . 'xcloner_scheduler',
+				$schedule,
+				array('id' => $_POST['id']),
+				array(
+					'%s',
+					'%s'
+				)
+			);
+		}
+		if (isset($_POST['id'])) {
+			$scheduler->update_cron_hook($_POST['id']);
+		}
+
+		if ($wpdb->last_error) {
+			$response['error'] = 1;
+			$response['error_message'] = $wpdb->last_error/*."--".$wpdb->last_query*/
+			;
+
+		}
+
+		$scheduler->update_wp_cron_hooks();
+		$response['finished'] = 1;
+
+		$this->send_response($response);
+	}
+
+	/*
      *
      * Backup Files API
      *
      */
-    public function backup_files()
-    {
-        $this->check_access();
-
-        $params = json_decode(stripslashes($_POST['data']));
-
-        $init = (int)$_POST['init'];
-
-        if ($params === null) {
-            die('{"status":false,"msg":"The post_data parameter must be valid JSON"}');
-        }
-
-        $this->process_params($params);
-
-        $return['finished'] = 1;
-
-        //$return = $this->archive_system->start_incremental_backup($this->form_params['backup_params'], $this->form_params['extra'], $init);
-        try {
-            $return = $this->archive_system->start_incremental_backup($this->form_params['backup_params'],
-                $this->form_params['extra'], $init);
-        } catch (Exception $e) {
-            $return = array();
-            $return['error'] = true;
-            $return['status'] = 500;
-            $return['error_message'] = $e->getMessage();
-
-            return $this->send_response($return, $hash = 1);
-        }
-
-        if ($return['finished']) {
-            $return['extra']['backup_parent'] = $this->archive_system->get_archive_name_with_extension();
-            if ($this->xcloner_file_system->is_part($this->archive_system->get_archive_name_with_extension())) {
-                $return['extra']['backup_parent'] = $this->archive_system->get_archive_name_multipart();
-            }
-        }
-
-        $data = $return;
-
-        //check if backup is finished
-        if ($return['finished']) {
-            if (isset($this->form_params['backup_params']['email_notification']) and $to = $this->form_params['backup_params']['email_notification']) {
-                try {
-                    $from = "";
-                    $subject = "";
-                    $additional['lines_total'] = $return['extra']['lines_total'];
-                    $this->archive_system->send_notification($to, $from, $subject, $return['extra']['backup_parent'],
-                        $this->form_params, "", $additional);
-                } catch (Exception $e) {
-                    $this->logger->error($e->getMessage());
-                }
-            }
-            $this->xcloner_file_system->remove_tmp_filesystem();
-        }
-
-        return $this->send_response($data, $hash = 1);
-    }
-
-    /*
+	public function backup_files()
+	{
+		$this->check_access();
+
+		$params = json_decode(stripslashes($_POST['data']));
+
+		$init = (int)$_POST['init'];
+
+		if ($params === null) {
+			die('{"status":false,"msg":"The post_data parameter must be valid JSON"}');
+		}
+
+		$this->process_params($params);
+
+		$return['finished'] = 1;
+
+		//$return = $this->archive_system->start_incremental_backup($this->form_params['backup_params'], $this->form_params['extra'], $init);
+		try {
+			$return = $this->archive_system->start_incremental_backup($this->form_params['backup_params'],
+				$this->form_params['extra'], $init);
+		} catch (Exception $e) {
+			$return = array();
+			$return['error'] = true;
+			$return['status'] = 500;
+			$return['error_message'] = $e->getMessage();
+
+			return $this->send_response($return, $hash = 1);
+		}
+
+		if ($return['finished']) {
+			$return['extra']['backup_parent'] = $this->archive_system->get_archive_name_with_extension();
+			if ($this->xcloner_file_system->is_part($this->archive_system->get_archive_name_with_extension())) {
+				$return['extra']['backup_parent'] = $this->archive_system->get_archive_name_multipart();
+			}
+		}
+
+		$data = $return;
+
+		//check if backup is finished
+		if ($return['finished']) {
+			if (isset($this->form_params['backup_params']['email_notification']) and $to = $this->form_params['backup_params']['email_notification']) {
+				try {
+					$from = "";
+					$subject = "";
+					$additional['lines_total'] = $return['extra']['lines_total'];
+					$this->archive_system->send_notification($to, $from, $subject, $return['extra']['backup_parent'],
+						$this->form_params, "", $additional);
+				} catch (Exception $e) {
+					$this->logger->error($e->getMessage());
+				}
+			}
+			$this->xcloner_file_system->remove_tmp_filesystem();
+		}
+
+		return $this->send_response($data, $hash = 1);
+	}
+
+	/*
      *
      * Backup Database API
      *
      */
-    public function backup_database()
-    {
-        $this->check_access();
+	public function backup_database()
+	{
+		$this->check_access();
 
-        $params = json_decode(stripslashes($_POST['data']));
+		$params = json_decode(stripslashes($_POST['data']));
 
-        $init = (int)$_POST['init'];
+		$init = (int)$_POST['init'];
 
-        if ($params === null) {
-            die('{"status":false,"msg":"The post_data parameter must be valid JSON"}');
-        }
+		if ($params === null) {
+			die('{"status":false,"msg":"The post_data parameter must be valid JSON"}');
+		}
 
-        $this->process_params($params);
+		$this->process_params($params);
 
-        //$xcloner_database = $this->init_db();
-        $return = $this->xcloner_database->start_database_recursion($this->form_params['database'],
-            $this->form_params['extra'], $init);
+		//$xcloner_database = $this->init_db();
+		$return = $this->xcloner_database->start_database_recursion($this->form_params['database'],
+			$this->form_params['extra'], $init);
 
-        if (isset($return['error']) and $return['error']) {
-            $data['finished'] = 1;
-        } else {
-            $data['finished'] = $return['finished'];
-        }
+		if (isset($return['error']) and $return['error']) {
+			$data['finished'] = 1;
+		} else {
+			$data['finished'] = $return['finished'];
+		}
 
-        $data['extra'] = $return;
+		$data['extra'] = $return;
 
-        return $this->send_response($data, $hash = 1);
-    }
+		return $this->send_response($data, $hash = 1);
+	}
 
-    /*
+	/*
      *
      * Scan Filesystem API
      *
      */
-    public function scan_filesystem()
-    {
-        $this->check_access();
+	public function scan_filesystem()
+	{
+		$this->check_access();
 
-        $params = json_decode(stripslashes($_POST['data']));
-        $init = (int)$_POST['init'];
+		$params = json_decode(stripslashes($_POST['data']));
+		$init = (int)$_POST['init'];
 
-        if ($params === null) {
-            die('{"status":false,"msg":"The post_data parameter must be valid JSON"}');
-        }
+		if ($params === null) {
+			die('{"status":false,"msg":"The post_data parameter must be valid JSON"}');
+		}
 
-        $hash = $this->process_params($params);
+		$hash = $this->process_params($params);
 
-        $this->xcloner_file_system->set_excluded_files($this->form_params['excluded_files']);
+		$this->xcloner_file_system->set_excluded_files($this->form_params['excluded_files']);
 
-        $return = $this->xcloner_file_system->start_file_recursion($init);
+		$return = $this->xcloner_file_system->start_file_recursion($init);
 
-        $data["finished"] = !$return;
-        $data["total_files_num"] = $this->xcloner_file_system->get_scanned_files_num();
-        $data["last_logged_file"] = $this->xcloner_file_system->last_logged_file();
-        $data["total_files_size"] = sprintf("%.2f",
-            $this->xcloner_file_system->get_scanned_files_total_size() / (1024 * 1024));
+		$data["finished"] = !$return;
+		$data["total_files_num"] = $this->xcloner_file_system->get_scanned_files_num();
+		$data["last_logged_file"] = $this->xcloner_file_system->last_logged_file();
+		$data["total_files_size"] = sprintf("%.2f",
+			$this->xcloner_file_system->get_scanned_files_total_size() / (1024 * 1024));
 
-        return $this->send_response($data, $hash = 1);
-    }
+		return $this->send_response($data, $hash = 1);
+	}
 
-    /*
+	/*
      *
      * Process params sent by the user
      *
      */
-    private function process_params($params)
-    {
-        if (isset($params->hash)) {
-            $this->xcloner_settings->set_hash($params->hash);
-        }
-
-        $this->form_params['extra'] = array();
-        $this->form_params['backup_params'] = array();
-
-        $this->form_params['database'] = array();
-
-        if (isset($params->backup_params)) {
-            foreach ($params->backup_params as $param) {
-                $this->form_params['backup_params'][$param->name] = $this->xcloner_sanitization->sanitize_input_as_string($param->value);
-                $this->logger->debug("Adding form parameter " . $param->name . "." . $param->value . "\n", array(
-                    'POST',
-                    'fields filter'
-                ));
-            }
-        }
-
-        $this->form_params['database'] = array();
-
-        if (isset($params->table_params)) {
-            foreach ($params->table_params as $param) {
-                $this->form_params['database'][$param->parent][] = $this->xcloner_sanitization->sanitize_input_as_raw($param->id);
-                $this->logger->debug("Adding database filter " . $param->parent . "." . $param->id . "\n", array(
-                    'POST',
-                    'database filter'
-                ));
-            }
-        }
-
-        $this->form_params['excluded_files'] = array();
-        if (isset($params->files_params)) {
-            foreach ($params->files_params as $param) {
-                $this->form_params['excluded_files'][] = $this->xcloner_sanitization->sanitize_input_as_relative_path($param->id);
-            }
-
-            $unique_exclude_files = array();
-
-            foreach ($params->files_params as $key => $param) {
-                if (!in_array($param->parent, $this->form_params['excluded_files'])) {
-                    //$this->form_params['excluded_files'][] = $this->xcloner_sanitization->sanitize_input_as_relative_path($param->id);
-                    $unique_exclude_files[] = $param->id;
-                    $this->logger->debug("Adding file filter " . $param->id . "\n", array(
-                        'POST',
-                        'exclude files filter'
-                    ));
-                }
-            }
-            $this->form_params['excluded_files'] = (array)$unique_exclude_files;
-
-        }
-
-        //$this->form_params['excluded_files'] =  array_merge($this->form_params['excluded_files'], $this->exclude_files_by_default);
-
-        if (isset($params->extra)) {
-            foreach ($params->extra as $key => $value) {
-                $this->form_params['extra'][$key] = $this->xcloner_sanitization->sanitize_input_as_raw($value);
-            }
-        }
-
-        if (isset($this->form_params['backup_params']['diff_start_date']) and $this->form_params['backup_params']['diff_start_date']) {
-            $this->form_params['backup_params']['diff_start_date'] = strtotime($this->form_params['backup_params']['diff_start_date']);
-            $this->xcloner_file_system->set_diff_timestamp_start($this->form_params['backup_params']['diff_start_date']);
-        }
-
-        return $this->xcloner_settings->get_hash();
-    }
-
-    /*
+	private function process_params($params)
+	{
+		if (isset($params->hash)) {
+			$this->xcloner_settings->set_hash($params->hash);
+		}
+
+		$this->form_params['extra'] = array();
+		$this->form_params['backup_params'] = array();
+
+		$this->form_params['database'] = array();
+
+		if (isset($params->backup_params)) {
+			foreach ($params->backup_params as $param) {
+				$this->form_params['backup_params'][$param->name] = $this->xcloner_sanitization->sanitize_input_as_string($param->value);
+				$this->logger->debug("Adding form parameter " . $param->name . "." . $param->value . "\n", array(
+					'POST',
+					'fields filter'
+				));
+			}
+		}
+
+		$this->form_params['database'] = array();
+
+		if (isset($params->table_params)) {
+			foreach ($params->table_params as $param) {
+				$this->form_params['database'][$param->parent][] = $this->xcloner_sanitization->sanitize_input_as_raw($param->id);
+				$this->logger->debug("Adding database filter " . $param->parent . "." . $param->id . "\n", array(
+					'POST',
+					'database filter'
+				));
+			}
+		}
+
+		$this->form_params['excluded_files'] = array();
+		if (isset($params->files_params)) {
+			foreach ($params->files_params as $param) {
+				$this->form_params['excluded_files'][] = $this->xcloner_sanitization->sanitize_input_as_relative_path($param->id);
+			}
+
+			$unique_exclude_files = array();
+
+			foreach ($params->files_params as $key => $param) {
+				if (!in_array($param->parent, $this->form_params['excluded_files'])) {
+					//$this->form_params['excluded_files'][] = $this->xcloner_sanitization->sanitize_input_as_relative_path($param->id);
+					$unique_exclude_files[] = $param->id;
+					$this->logger->debug("Adding file filter " . $param->id . "\n", array(
+						'POST',
+						'exclude files filter'
+					));
+				}
+			}
+			$this->form_params['excluded_files'] = (array)$unique_exclude_files;
+
+		}
+
+		//$this->form_params['excluded_files'] =  array_merge($this->form_params['excluded_files'], $this->exclude_files_by_default);
+
+		if (isset($params->extra)) {
+			foreach ($params->extra as $key => $value) {
+				$this->form_params['extra'][$key] = $this->xcloner_sanitization->sanitize_input_as_raw($value);
+			}
+		}
+
+		if (isset($this->form_params['backup_params']['diff_start_date']) and $this->form_params['backup_params']['diff_start_date']) {
+			$this->form_params['backup_params']['diff_start_date'] = strtotime($this->form_params['backup_params']['diff_start_date']);
+			$this->xcloner_file_system->set_diff_timestamp_start($this->form_params['backup_params']['diff_start_date']);
+		}
+
+		return $this->xcloner_settings->get_hash();
+	}
+
+	/*
      *
      * Get file list for tree view API
      *
      */
-    public function get_file_system_action()
-    {
-        $this->check_access();
-
-        $folder = $this->xcloner_sanitization->sanitize_input_as_relative_path($_POST['id']);
-
-        $data = array();
-
-        if ($folder == "#") {
-
-            $folder = "/";
-            $data[] = array(
-                'id' => $folder,
-                'parent' => '#',
-                'text' => $this->xcloner_settings->get_xcloner_start_path(),
-                //'children' => true,
-                'state' => array('selected' => false, 'opened' => true),
-                'icon' => plugin_dir_url(dirname(__FILE__)) . "/admin/assets/file-icon-root.png"
-            );
-        }
-
-        try {
-            $files = $this->xcloner_file_system->list_directory($folder);
-        } catch (Exception $e) {
-
-            print $e->getMessage();
-            $this->logger->error($e->getMessage());
-
-            return;
-        }
-
-        $type = array();
-        foreach ($files as $key => $row) {
-            $type[$key] = $row['type'];
-        }
-        array_multisort($type, SORT_ASC, $files);
-
-        foreach ($files as $file) {
-            $children = false;
-            $text = $file['basename'];
-
-            if ($file['type'] == "dir") {
-                $children = true;
-            } else {
-                $text .= " (" . $this->xcloner_requirements->file_format_size($file['size']) . ")";
-            }
-
-            if ($this->xcloner_file_system->is_excluded($file)) {
-                $selected = true;
-            } else {
-                $selected = false;
-            }
-
-            $data[] = array(
-                'id' => $file['path'],
-                'parent' => $folder,
-                'text' => $text,
-                //'title' => "test",
-                'children' => $children,
-                'state' => array('selected' => $selected, 'opened' => false, "checkbox_disabled" => $selected),
-                'icon' => plugin_dir_url(dirname(__FILE__)) . "/admin/assets/file-icon-" . strtolower(substr($file['type'],
-                        0, 1)) . ".png"
-            );
-        }
-
-
-        return $this->send_response($data, 0);
-    }
-
-    /*
+	public function get_file_system_action()
+	{
+		$this->check_access();
+
+		$folder = $this->xcloner_sanitization->sanitize_input_as_relative_path($_POST['id']);
+
+		$data = array();
+
+		if ($folder == "#") {
+
+			$folder = "/";
+			$data[] = array(
+				'id' => $folder,
+				'parent' => '#',
+				'text' => $this->xcloner_settings->get_xcloner_start_path(),
+				//'children' => true,
+				'state' => array('selected' => false, 'opened' => true),
+				'icon' => plugin_dir_url(dirname(__FILE__)) . "/admin/assets/file-icon-root.png"
+			);
+		}
+
+		try {
+			$files = $this->xcloner_file_system->list_directory($folder);
+		} catch (Exception $e) {
+
+			print $e->getMessage();
+			$this->logger->error($e->getMessage());
+
+			return;
+		}
+
+		$type = array();
+		foreach ($files as $key => $row) {
+			$type[$key] = $row['type'];
+		}
+		array_multisort($type, SORT_ASC, $files);
+
+		foreach ($files as $file) {
+			$children = false;
+			$text = $file['basename'];
+
+			if ($file['type'] == "dir") {
+				$children = true;
+			} else {
+				$text .= " (" . $this->xcloner_requirements->file_format_size($file['size']) . ")";
+			}
+
+			if ($this->xcloner_file_system->is_excluded($file)) {
+				$selected = true;
+			} else {
+				$selected = false;
+			}
+
+			$data[] = array(
+				'id' => $file['path'],
+				'parent' => $folder,
+				'text' => $text,
+				//'title' => "test",
+				'children' => $children,
+				'state' => array('selected' => $selected, 'opened' => false, "checkbox_disabled" => $selected),
+				'icon' => plugin_dir_url(dirname(__FILE__)) . "/admin/assets/file-icon-" . strtolower(substr($file['type'],
+						0, 1)) . ".png"
+			);
+		}
+
+
+		return $this->send_response($data, 0);
+	}
+
+	/*
      *
      * Get databases/tables list for frontend tree display API
      *
      */
-    public function get_database_tables_action()
-    {
-        $this->check_access();
-
-        $database = $this->xcloner_sanitization->sanitize_input_as_raw($_POST['id']);
-
-        $data = array();
-
-        $xcloner_backup_only_wp_tables = $this->xcloner_settings->get_xcloner_option('xcloner_backup_only_wp_tables');
-
-        if ($database == "#") {
-            try {
-                $return = $this->xcloner_database->get_all_databases();
-            } catch (Exception $e) {
-                $this->logger->error($e->getMessage());
-            }
-
-            foreach ($return as $database) {
-                if ($xcloner_backup_only_wp_tables and $database['name'] != $this->xcloner_settings->get_db_database()) {
-                    continue;
-                }
-
-                $state = array();
-
-                if ($database['name'] == $this->xcloner_settings->get_db_database()) {
-                    $state['selected'] = true;
-                    if ($database['num_tables'] < 25) {
-                        $state['opened'] = false;
-                    }
-                }
-
-                $data[] = array(
-                    'id' => $database['name'],
-                    'parent' => '#',
-                    'text' => $database['name'] . " (" . (int)$database['num_tables'] . ")",
-                    'children' => true,
-                    'state' => $state,
-                    'icon' => plugin_dir_url(dirname(__FILE__)) . "/admin/assets/database-icon.png"
-                );
-            }
-
-        } else {
-
-            try {
-                $return = $this->xcloner_database->list_tables($database, "", 1);
-            } catch (Exception $e) {
-                $this->logger->error($e->getMessage());
-            }
-
-            foreach ($return as $table) {
-                $state = array();
-
-                if ($xcloner_backup_only_wp_tables and !stristr($table['name'],
-                        $this->xcloner_settings->get_table_prefix())) {
-                    continue;
-                }
-
-                if (isset($database['name']) and $database['name'] == $this->xcloner_settings->get_db_database()) {
-                    $state = array('selected' => true);
-                }
-
-                $data[] = array(
-                    'id' => $database . "." . $table['name'],
-                    'parent' => $database,
-                    'text' => $table['name'] . " (" . (int)$table['records'] . ")",
-                    'children' => false,
-                    'state' => $state,
-                    'icon' => plugin_dir_url(dirname(__FILE__)) . "/admin/assets/table-icon.png"
-                );
-            }
-        }
-
-        return $this->send_response($data, 0);
-    }
-
-    /*
+	public function get_database_tables_action()
+	{
+		$this->check_access();
+
+		$database = $this->xcloner_sanitization->sanitize_input_as_raw($_POST['id']);
+
+		$data = array();
+
+		$xcloner_backup_only_wp_tables = $this->xcloner_settings->get_xcloner_option('xcloner_backup_only_wp_tables');
+
+		if ($database == "#") {
+			try {
+				$return = $this->xcloner_database->get_all_databases();
+			} catch (Exception $e) {
+				$this->logger->error($e->getMessage());
+			}
+
+			foreach ($return as $database) {
+				if ($xcloner_backup_only_wp_tables and $database['name'] != $this->xcloner_settings->get_db_database()) {
+					continue;
+				}
+
+				$state = array();
+
+				if ($database['name'] == $this->xcloner_settings->get_db_database()) {
+					$state['selected'] = true;
+					if ($database['num_tables'] < 25) {
+						$state['opened'] = false;
+					}
+				}
+
+				$data[] = array(
+					'id' => $database['name'],
+					'parent' => '#',
+					'text' => $database['name'] . " (" . (int)$database['num_tables'] . ")",
+					'children' => true,
+					'state' => $state,
+					'icon' => plugin_dir_url(dirname(__FILE__)) . "/admin/assets/database-icon.png"
+				);
+			}
+
+		} else {
+
+			try {
+				$return = $this->xcloner_database->list_tables($database, "", 1);
+			} catch (Exception $e) {
+				$this->logger->error($e->getMessage());
+			}
+
+			foreach ($return as $table) {
+				$state = array();
+
+				if ($xcloner_backup_only_wp_tables and !stristr($table['name'],
+						$this->xcloner_settings->get_table_prefix())) {
+					continue;
+				}
+
+				if (isset($database['name']) and $database['name'] == $this->xcloner_settings->get_db_database()) {
+					$state = array('selected' => true);
+				}
+
+				$data[] = array(
+					'id' => $database . "." . $table['name'],
+					'parent' => $database,
+					'text' => $table['name'] . " (" . (int)$table['records'] . ")",
+					'children' => false,
+					'state' => $state,
+					'icon' => plugin_dir_url(dirname(__FILE__)) . "/admin/assets/table-icon.png"
+				);
+			}
+		}
+
+		return $this->send_response($data, 0);
+	}
+
+	/*
      *
      * Get schedule by id API
      *
      */
-    public function get_schedule_by_id()
-    {
-        $this->check_access();
+	public function get_schedule_by_id()
+	{
+		$this->check_access();
 
-        $schedule_id = $this->xcloner_sanitization->sanitize_input_as_int($_GET['id']);
-        $scheduler = $this->xcloner_scheduler;
-        $data = $scheduler->get_schedule_by_id($schedule_id);
+		$schedule_id = $this->xcloner_sanitization->sanitize_input_as_int($_GET['id']);
+		$scheduler = $this->xcloner_scheduler;
+		$data = $scheduler->get_schedule_by_id($schedule_id);
 
-        $data['start_at'] = date("Y-m-d H:i",
-            strtotime($data['start_at']) + (get_option('gmt_offset') * HOUR_IN_SECONDS));
-        if (isset($data['backup_params']->diff_start_date) && $data['backup_params']->diff_start_date != "") {
-            $data['backup_params']->diff_start_date = date("Y-m-d", ($data['backup_params']->diff_start_date));
-        }
+		$data['start_at'] = date("Y-m-d H:i",
+			strtotime($data['start_at']) + (get_option('gmt_offset') * HOUR_IN_SECONDS));
+		if (isset($data['backup_params']->diff_start_date) && $data['backup_params']->diff_start_date != "") {
+			$data['backup_params']->diff_start_date = date("Y-m-d", ($data['backup_params']->diff_start_date));
+		}
 
-        return $this->send_response($data);
-    }
+		return $this->send_response($data);
+	}
 
-    /*
+	/*
      *
      * Get Schedule list API
      *
      */
-    public function get_scheduler_list()
-    {
-        $this->check_access();
+	public function get_scheduler_list()
+	{
+		$this->check_access();
 
-        $scheduler = $this->xcloner_scheduler;
-        $data = $scheduler->get_scheduler_list();
-        $return['data'] = array();
+		$scheduler = $this->xcloner_scheduler;
+		$data = $scheduler->get_scheduler_list();
+		$return['data'] = array();
 
-        foreach ($data as $res) {
-            $action = "<a href=\"#" . $res->id . "\" class=\"edit\" title='Edit'> <i class=\"material-icons \">edit</i></a>
+		foreach ($data as $res) {
+			$action = "<a href=\"#" . $res->id . "\" class=\"edit\" title='Edit'> <i class=\"material-icons \">edit</i></a>
 					<a href=\"#" . $res->id . "\" class=\"delete\" title='Delete'><i class=\"material-icons  \">delete</i></a>";
-            if ($res->status) {
-                $status = '<i class="material-icons active status">timer</i>';
-            } else {
-                $status = '<i class="material-icons status inactive">timer_off</i>';
-            }
-
-            $next_run_time = wp_next_scheduled('xcloner_scheduler_' . $res->id, array($res->id));
-
-            $next_run = date(get_option('date_format') . " " . get_option('time_format'), $next_run_time);
-
-            $remote_storage = $res->remote_storage;
-
-            if (!$next_run_time >= time()) {
-                $next_run = " ";
-            }
-
-            if (trim($next_run)) {
-                $date_text = date(get_option('date_format') . " " . get_option('time_format'),
-                    $next_run_time + (get_option('gmt_offset') * HOUR_IN_SECONDS));
-
-                if ($next_run_time >= time()) {
-                    $next_run = "in " . human_time_diff($next_run_time, time());
-                } else {
-                    $next_run = __("executed", 'xcloner-backup-and-restore');
-                }
-
-                $next_run = "<a href='#' title='" . $date_text . "'>" . $next_run . "</a>";
-                //$next_run .=" ($date_text)";
-            }
-
-            $backup_text = "";
-            $backup_size = "";
-            $backup_time = "";
-
-            if ($res->last_backup) {
-                if ($this->xcloner_file_system->get_storage_filesystem()->has($res->last_backup)) {
-                    $metadata = $this->xcloner_file_system->get_storage_filesystem()->getMetadata($res->last_backup);
-                    $backup_size = size_format($this->xcloner_file_system->get_backup_size($res->last_backup));
-                    $backup_time = date(get_option('date_format') . " " . get_option('time_format'),
-                        $metadata['timestamp'] + (get_option('gmt_offset') * HOUR_IN_SECONDS));
-                }
-
-                $backup_text = "<span title='" . $backup_time . "' class='shorten_string'>" . $res->last_backup . " (" . $backup_size . ")</span>";
-            }
-
-            $schedules = wp_get_schedules();
-
-            if (isset($schedules[$res->recurrence])) {
-                $res->recurrence = $schedules[$res->recurrence]['display'];
-            }
-
-            $return['data'][] = array(
-                $res->id,
-                $res->name,
-                $res->recurrence,/*$res->start_at,*/
-                $next_run,
-                $remote_storage,
-                $backup_text,
-                $status,
-                $action
-            );
-        }
-
-        return $this->send_response($return, 0);
-    }
-
-    /*
+			if ($res->status) {
+				$status = '<i class="material-icons active status">timer</i>';
+			} else {
+				$status = '<i class="material-icons status inactive">timer_off</i>';
+			}
+
+			$next_run_time = wp_next_scheduled('xcloner_scheduler_' . $res->id, array($res->id));
+
+			$next_run = date(get_option('date_format') . " " . get_option('time_format'), $next_run_time);
+
+			$remote_storage = $res->remote_storage;
+
+			if (!$next_run_time >= time()) {
+				$next_run = " ";
+			}
+
+			if (trim($next_run)) {
+				$date_text = date(get_option('date_format') . " " . get_option('time_format'),
+					$next_run_time + (get_option('gmt_offset') * HOUR_IN_SECONDS));
+
+				if ($next_run_time >= time()) {
+					$next_run = "in " . human_time_diff($next_run_time, time());
+				} else {
+					$next_run = __("executed", 'xcloner-backup-and-restore');
+				}
+
+				$next_run = "<a href='#' title='" . $date_text . "'>" . $next_run . "</a>";
+				//$next_run .=" ($date_text)";
+			}
+
+			$backup_text = "";
+			$backup_size = "";
+			$backup_time = "";
+
+			if ($res->last_backup) {
+				if ($this->xcloner_file_system->get_storage_filesystem()->has($res->last_backup)) {
+					$metadata = $this->xcloner_file_system->get_storage_filesystem()->getMetadata($res->last_backup);
+					$backup_size = size_format($this->xcloner_file_system->get_backup_size($res->last_backup));
+					$backup_time = date(get_option('date_format') . " " . get_option('time_format'),
+						$metadata['timestamp'] + (get_option('gmt_offset') * HOUR_IN_SECONDS));
+				}
+
+				$backup_text = "<span title='" . $backup_time . "' class='shorten_string'>" . $res->last_backup . " (" . $backup_size . ")</span>";
+			}
+
+			$schedules = wp_get_schedules();
+
+			if (isset($schedules[$res->recurrence])) {
+				$res->recurrence = $schedules[$res->recurrence]['display'];
+			}
+
+			$return['data'][] = array(
+				$res->id,
+				$res->name,
+				$res->recurrence,/*$res->start_at,*/
+				$next_run,
+				$remote_storage,
+				$backup_text,
+				$status,
+				$action
+			);
+		}
+
+		return $this->send_response($return, 0);
+	}
+
+	/*
      *
      * Delete Schedule by ID API
      *
      */
-    public function delete_schedule_by_id()
-    {
-        $this->check_access();
+	public function delete_schedule_by_id()
+	{
+		$this->check_access();
 
-        $schedule_id = $this->xcloner_sanitization->sanitize_input_as_int($_GET['id']);
-        $scheduler = $this->xcloner_scheduler;
-        $data['finished'] = $scheduler->delete_schedule_by_id($schedule_id);
+		$schedule_id = $this->xcloner_sanitization->sanitize_input_as_int($_GET['id']);
+		$scheduler = $this->xcloner_scheduler;
+		$data['finished'] = $scheduler->delete_schedule_by_id($schedule_id);
 
-        return $this->send_response($data);
-    }
+		return $this->send_response($data);
+	}
 
-    /*
+	/*
      *
      * Delete backup by name from the storage path
      *
      */
-    public function delete_backup_by_name()
-    {
-        $this->check_access();
+	public function delete_backup_by_name()
+	{
+		$this->check_access();
 
-        $backup_name = $this->xcloner_sanitization->sanitize_input_as_string($_POST['name']);
-        $storage_selection = $this->xcloner_sanitization->sanitize_input_as_string($_POST['storage_selection']);
+		$backup_name = $this->xcloner_sanitization->sanitize_input_as_string($_POST['name']);
+		$storage_selection = $this->xcloner_sanitization->sanitize_input_as_string($_POST['storage_selection']);
 
-        $data['finished'] = $this->xcloner_file_system->delete_backup_by_name($backup_name, $storage_selection);
+		$data['finished'] = $this->xcloner_file_system->delete_backup_by_name($backup_name, $storage_selection);
 
-        return $this->send_response($data);
-    }
+		return $this->send_response($data);
+	}
 
-    public function list_backup_files()
-    {
-        $this->check_access();
+	public function list_backup_files()
+	{
+		$this->check_access();
 
-        $backup_parts = array();
+		$backup_parts = array();
 
-        $source_backup_file = $this->xcloner_sanitization->sanitize_input_as_string($_POST['file']);
-        $start = $this->xcloner_sanitization->sanitize_input_as_int($_POST['start']);
-        $return['part'] = $this->xcloner_sanitization->sanitize_input_as_int($_POST['part']);
+		$source_backup_file = $this->xcloner_sanitization->sanitize_input_as_string($_POST['file']);
+		$start = $this->xcloner_sanitization->sanitize_input_as_int($_POST['start']);
+		$return['part'] = $this->xcloner_sanitization->sanitize_input_as_int($_POST['part']);
 
-        $backup_file = $source_backup_file;
+		$backup_file = $source_backup_file;
 
-        if ($this->xcloner_file_system->is_multipart($backup_file)) {
-            $backup_parts = $this->xcloner_file_system->get_multipart_files($backup_file);
-            $backup_file = $backup_parts[$return['part']];
-        }
+		if ($this->xcloner_file_system->is_multipart($backup_file)) {
+			$backup_parts = $this->xcloner_file_system->get_multipart_files($backup_file);
+			$backup_file = $backup_parts[$return['part']];
+		}
 
-        try {
-            $tar = new Tar();
-            $tar->open($this->xcloner_settings->get_xcloner_store_path() . DS . $backup_file, $start);
+		try {
+			$tar = new Tar();
+			$tar->open($this->xcloner_settings->get_xcloner_store_path() . DS . $backup_file, $start);
 
-            $data = $tar->contents(get_option('xcloner_files_to_process_per_request'));
-        } catch (Exception $e) {
-            $return['error'] = true;
-            $return['message'] = $e->getMessage();
-            $this->send_response($return, 0);
-        }
+			$data = $tar->contents(get_option('xcloner_files_to_process_per_request'));
+		} catch (Exception $e) {
+			$return['error'] = true;
+			$return['message'] = $e->getMessage();
+			$this->send_response($return, 0);
+		}
 
-        $return['files'] = array();
-        $return['finished'] = 1;
-        $return['total_size'] = filesize($this->xcloner_settings->get_xcloner_store_path() . DS . $backup_file);
-        $i = 0;
+		$return['files'] = array();
+		$return['finished'] = 1;
+		$return['total_size'] = filesize($this->xcloner_settings->get_xcloner_store_path() . DS . $backup_file);
+		$i = 0;
 
-        if (isset($data['extracted_files']) and is_array($data['extracted_files'])) {
-            foreach ($data['extracted_files'] as $file) {
-                $return['files'][$i]['path'] = $file->getPath();
-                $return['files'][$i]['size'] = $file->getSize();
-                $return['files'][$i]['mtime'] = date(get_option('date_format') . " " . get_option('time_format'),
-                    $file->getMtime());
+		if (isset($data['extracted_files']) and is_array($data['extracted_files'])) {
+			foreach ($data['extracted_files'] as $file) {
+				$return['files'][$i]['path'] = $file->getPath();
+				$return['files'][$i]['size'] = $file->getSize();
+				$return['files'][$i]['mtime'] = date(get_option('date_format') . " " . get_option('time_format'),
+					$file->getMtime());
 
-                $i++;
-            }
-        }
+				$i++;
+			}
+		}
 
-        if (isset($data['start'])) {
-            $return['start'] = $data['start'];
-            $return['finished'] = 0;
-        } else {
-            if ($this->xcloner_file_system->is_multipart($source_backup_file)) {
-                $return['start'] = 0;
+		if (isset($data['start'])) {
+			$return['start'] = $data['start'];
+			$return['finished'] = 0;
+		} else {
+			if ($this->xcloner_file_system->is_multipart($source_backup_file)) {
+				$return['start'] = 0;
 
-                ++$return['part'];
+				++$return['part'];
 
-                if ($return['part'] < sizeof($backup_parts)) {
-                    $return['finished'] = 0;
-                }
+				if ($return['part'] < sizeof($backup_parts)) {
+					$return['finished'] = 0;
+				}
 
-            }
-        }
+			}
+		}
 
-        $this->send_response($return, 0);
-    }
+		$this->send_response($return, 0);
+	}
 
-    /*
+	/*
      * Copy remote backup to local storage
      */
-    public function copy_backup_remote_to_local()
-    {
+	public function copy_backup_remote_to_local()
+	{
 
-        $this->check_access();
+		$this->check_access();
 
-        $backup_file = $this->xcloner_sanitization->sanitize_input_as_string($_POST['file']);
-        $storage_type = $this->xcloner_sanitization->sanitize_input_as_string($_POST['storage_type']);
+		$backup_file = $this->xcloner_sanitization->sanitize_input_as_string($_POST['file']);
+		$storage_type = $this->xcloner_sanitization->sanitize_input_as_string($_POST['storage_type']);
 
-        $xcloner_remote_storage = $this->get_xcloner_container()->get_xcloner_remote_storage();
+		$xcloner_remote_storage = $this->get_xcloner_container()->get_xcloner_remote_storage();
 
-        $return = array();
+		$return = array();
 
-        try {
-            if (method_exists($xcloner_remote_storage, "copy_backup_remote_to_local")) {
-                $return = call_user_func_array(array(
-                    $xcloner_remote_storage,
-                    "copy_backup_remote_to_local"
-                ), array($backup_file, $storage_type));
-            }
-        } catch (Exception $e) {
+		try {
+			if (method_exists($xcloner_remote_storage, "copy_backup_remote_to_local")) {
+				$return = call_user_func_array(array(
+					$xcloner_remote_storage,
+					"copy_backup_remote_to_local"
+				), array($backup_file, $storage_type));
+			}
+		} catch (Exception $e) {
 
-            $return['error'] = 1;
-            $return['message'] = $e->getMessage();
-        }
+			$return['error'] = 1;
+			$return['message'] = $e->getMessage();
+		}
 
-        if (!$return) {
-            $return['error'] = 1;
-            $return['message'] = "Upload failed, please check the error log for more information!";
-        }
+		if (!$return) {
+			$return['error'] = 1;
+			$return['message'] = "Upload failed, please check the error log for more information!";
+		}
 
 
-        $this->send_response($return, 0);
+		$this->send_response($return, 0);
 
-    }
+	}
 
-    /*
+	/*
      *
      * Upload backup to remote API
      *
      */
-    public function upload_backup_to_remote()
-    {
-        $this->check_access();
+	public function upload_backup_to_remote()
+	{
+		$this->check_access();
 
-        $backup_file = $this->xcloner_sanitization->sanitize_input_as_string($_POST['file']);
-        $storage_type = $this->xcloner_sanitization->sanitize_input_as_string($_POST['storage_type']);
+		$backup_file = $this->xcloner_sanitization->sanitize_input_as_string($_POST['file']);
+		$storage_type = $this->xcloner_sanitization->sanitize_input_as_string($_POST['storage_type']);
 
-        $xcloner_remote_storage = $this->get_xcloner_container()->get_xcloner_remote_storage();
+		$xcloner_remote_storage = $this->get_xcloner_container()->get_xcloner_remote_storage();
 
-        $return = array();
+		$return = array();
 
-        try {
-            if (method_exists($xcloner_remote_storage, "upload_backup_to_storage")) {
-                $return = call_user_func_array(array(
-                    $xcloner_remote_storage,
-                    "upload_backup_to_storage"
-                ), array($backup_file, $storage_type));
-            }
-        } catch (Exception $e) {
+		try {
+			if (method_exists($xcloner_remote_storage, "upload_backup_to_storage")) {
+				$return = call_user_func_array(array(
+					$xcloner_remote_storage,
+					"upload_backup_to_storage"
+				), array($backup_file, $storage_type));
+			}
+		} catch (Exception $e) {
 
-            $return['error'] = 1;
-            $return['message'] = $e->getMessage();
-        }
+			$return['error'] = 1;
+			$return['message'] = $e->getMessage();
+		}
 
-        if (!$return) {
-            $return['error'] = 1;
-            $return['message'] = "Upload failed, please check the error log for more information!";
-        }
+		if (!$return) {
+			$return['error'] = 1;
+			$return['message'] = "Upload failed, please check the error log for more information!";
+		}
 
 
-        $this->send_response($return, 0);
+		$this->send_response($return, 0);
 
-    }
+	}
 
-    /*
+	/*
      *
      * Remote Storage Status Save
      *
      */
-    public function remote_storage_save_status()
-    {
-        $this->check_access();
+	public function remote_storage_save_status()
+	{
+		$this->check_access();
 
-        $xcloner_remote_storage = $this->get_xcloner_container()->get_xcloner_remote_storage();
+		$xcloner_remote_storage = $this->get_xcloner_container()->get_xcloner_remote_storage();
 
-        $return['finished'] = $xcloner_remote_storage->change_storage_status($_POST['id'], $_POST['value']);
+		$return['finished'] = $xcloner_remote_storage->change_storage_status($_POST['id'], $_POST['value']);
 
-        $this->send_response($return, 0);
-    }
+		$this->send_response($return, 0);
+	}
 
 
-    public function download_restore_script()
-    {
-        $this->check_access();
+	public function download_restore_script()
+	{
+		$this->check_access();
 
-        @ob_end_clean();
+		@ob_end_clean();
 
-        $adapter = new Local(dirname(__DIR__), LOCK_EX, 'SKIP_LINKS');
-        $xcloner_plugin_filesystem = new Filesystem($adapter, new Config([
-            'disable_asserts' => true,
-        ]));
+		$adapter = new Local(dirname(__DIR__), LOCK_EX, 'SKIP_LINKS');
+		$xcloner_plugin_filesystem = new Filesystem($adapter, new Config([
+			'disable_asserts' => true,
+		]));
 
-        /* Generate PHAR FILE
+		/* Generate PHAR FILE
         $file = 'restore/vendor.built';
 
         if(file_exists($file))
@@ -957,178 +957,178 @@ 
         $phar2->setStub($phar2->createDefaultStub('vendor/autoload.php', 'vendor/autoload.php'));
          * */
 
-        $tmp_file = $this->xcloner_settings->get_xcloner_tmp_path() . DS . "xcloner-restore.tgz";
+		$tmp_file = $this->xcloner_settings->get_xcloner_tmp_path() . DS . "xcloner-restore.tgz";
 
-        $tar = new Tar();
-        $tar->create($tmp_file);
+		$tar = new Tar();
+		$tar->create($tmp_file);
 
-        $tar->addFile(dirname(__DIR__) . "/restore/vendor.build.txt", "vendor.phar");
-        //$tar->addFile(dirname(__DIR__)."/restore/vendor.tgz", "vendor.tgz");
+		$tar->addFile(dirname(__DIR__) . "/restore/vendor.build.txt", "vendor.phar");
+		//$tar->addFile(dirname(__DIR__)."/restore/vendor.tgz", "vendor.tgz");
 
-        $files = $xcloner_plugin_filesystem->listContents("vendor/", true);
-        foreach ($files as $file) {
-            $tar->addFile(dirname(__DIR__) . DS . $file['path'], $file['path']);
-        }
+		$files = $xcloner_plugin_filesystem->listContents("vendor/", true);
+		foreach ($files as $file) {
+			$tar->addFile(dirname(__DIR__) . DS . $file['path'], $file['path']);
+		}
 
-        $content = file_get_contents(dirname(__DIR__) . "/restore/xcloner_restore.php");
-        $content = str_replace("define('AUTH_KEY', '');", "define('AUTH_KEY', '" . md5(AUTH_KEY) . "');", $content);
+		$content = file_get_contents(dirname(__DIR__) . "/restore/xcloner_restore.php");
+		$content = str_replace("define('AUTH_KEY', '');", "define('AUTH_KEY', '" . md5(AUTH_KEY) . "');", $content);
 
-        $tar->addData("xcloner_restore.php", $content);
+		$tar->addData("xcloner_restore.php", $content);
 
-        $tar->close();
+		$tar->close();
 
-        if (file_exists($tmp_file)) {
-            header('Content-Description: File Transfer');
-            header('Content-Type: application/octet-stream');
-            header('Content-Disposition: attachment; filename="' . basename($tmp_file) . '"');
-            header('Expires: 0');
-            header('Cache-Control: must-revalidate');
-            header('Pragma: public');
-            header('Content-Length: ' . filesize($tmp_file));
-            readfile($tmp_file);
+		if (file_exists($tmp_file)) {
+			header('Content-Description: File Transfer');
+			header('Content-Type: application/octet-stream');
+			header('Content-Disposition: attachment; filename="' . basename($tmp_file) . '"');
+			header('Expires: 0');
+			header('Cache-Control: must-revalidate');
+			header('Pragma: public');
+			header('Content-Length: ' . filesize($tmp_file));
+			readfile($tmp_file);
 
-        }
+		}
 
-        @unlink($tmp_file);
-        exit;
-    }
+		@unlink($tmp_file);
+		exit;
+	}
 
-    /*
+	/*
      *
      * Download backup by Name from the Storage Path
      *
      */
-    public function download_backup_by_name()
-    {
-        $this->check_access();
+	public function download_backup_by_name()
+	{
+		$this->check_access();
 
-        @ob_end_clean();
+		@ob_end_clean();
 
-        $backup_name = $this->xcloner_sanitization->sanitize_input_as_string($_GET['name']);
+		$backup_name = $this->xcloner_sanitization->sanitize_input_as_string($_GET['name']);
 
 
-        $metadata = $this->xcloner_file_system->get_storage_filesystem()->getMetadata($backup_name);
-        $read_stream = $this->xcloner_file_system->get_storage_filesystem()->readStream($backup_name);
+		$metadata = $this->xcloner_file_system->get_storage_filesystem()->getMetadata($backup_name);
+		$read_stream = $this->xcloner_file_system->get_storage_filesystem()->readStream($backup_name);
 
 
-        header('Pragma: public');
-        header('Expires: 0');
-        header('Cache-Control: must-revalidate, post-check=0, pre-check=0');
-        header('Cache-Control: private', false);
-        header('Content-Transfer-Encoding: binary');
-        header('Content-Disposition: attachment; filename="' . $metadata['path'] . '";');
-        header('Content-Type: application/octet-stream');
-        header('Content-Length: ' . $metadata['size']);
+		header('Pragma: public');
+		header('Expires: 0');
+		header('Cache-Control: must-revalidate, post-check=0, pre-check=0');
+		header('Cache-Control: private', false);
+		header('Content-Transfer-Encoding: binary');
+		header('Content-Disposition: attachment; filename="' . $metadata['path'] . '";');
+		header('Content-Type: application/octet-stream');
+		header('Content-Length: ' . $metadata['size']);
 
-        @ob_end_clean();
+		@ob_end_clean();
 
-        $chunkSize = 1024 * 1024;
-        while (!feof($read_stream)) {
-            $buffer = fread($read_stream, $chunkSize);
-            echo $buffer;
-        }
-        fclose($read_stream);
-        exit;
+		$chunkSize = 1024 * 1024;
+		while (!feof($read_stream)) {
+			$buffer = fread($read_stream, $chunkSize);
+			echo $buffer;
+		}
+		fclose($read_stream);
+		exit;
 
-    }
+	}
 
-    /*
+	/*
      * Restore upload backup
      */
-    public function restore_upload_backup()
-    {
-        $this->check_access();
+	public function restore_upload_backup()
+	{
+		$this->check_access();
 
-        $return['part'] = 0;
-        $return['total_parts'] = 0;
-        $return['uploaded_size'] = 0;
-        $is_multipart = 0;
+		$return['part'] = 0;
+		$return['total_parts'] = 0;
+		$return['uploaded_size'] = 0;
+		$is_multipart = 0;
 
-        $file = $this->xcloner_sanitization->sanitize_input_as_string($_POST['file']);
-        $hash = $this->xcloner_sanitization->sanitize_input_as_string($_POST['hash']);
+		$file = $this->xcloner_sanitization->sanitize_input_as_string($_POST['file']);
+		$hash = $this->xcloner_sanitization->sanitize_input_as_string($_POST['hash']);
 
-        if (isset($_POST['part'])) {
-            $return['part'] = $this->xcloner_sanitization->sanitize_input_as_int($_POST['part']);
-        }
+		if (isset($_POST['part'])) {
+			$return['part'] = $this->xcloner_sanitization->sanitize_input_as_int($_POST['part']);
+		}
 
-        if (isset($_POST['uploaded_size'])) {
-            $return['uploaded_size'] = $this->xcloner_sanitization->sanitize_input_as_int($_POST['uploaded_size']);
-        }
+		if (isset($_POST['uploaded_size'])) {
+			$return['uploaded_size'] = $this->xcloner_sanitization->sanitize_input_as_int($_POST['uploaded_size']);
+		}
 
-        $start = $this->xcloner_sanitization->sanitize_input_as_string($_POST['start']);
-        $target_url = $this->xcloner_sanitization->sanitize_input_as_string($_POST['target_url']);
+		$start = $this->xcloner_sanitization->sanitize_input_as_string($_POST['start']);
+		$target_url = $this->xcloner_sanitization->sanitize_input_as_string($_POST['target_url']);
 
-        $return['total_size'] = $this->xcloner_file_system->get_backup_size($file);
+		$return['total_size'] = $this->xcloner_file_system->get_backup_size($file);
 
-        if ($this->xcloner_file_system->is_multipart($file)) {
-            $backup_parts = $this->xcloner_file_system->get_multipart_files($file);
+		if ($this->xcloner_file_system->is_multipart($file)) {
+			$backup_parts = $this->xcloner_file_system->get_multipart_files($file);
 
-            $return['total_parts'] = sizeof($backup_parts) + 1;
+			$return['total_parts'] = sizeof($backup_parts) + 1;
 
-            if ($return['part'] and isset($backup_parts[$return['part'] - 1])) {
-                $file = $backup_parts[$return['part'] - 1];
-            }
+			if ($return['part'] and isset($backup_parts[$return['part'] - 1])) {
+				$file = $backup_parts[$return['part'] - 1];
+			}
 
-            $is_multipart = 1;
-        }
+			$is_multipart = 1;
+		}
 
-        try {
+		try {
 
-            $xcloner_file_transfer = $this->get_xcloner_container()->get_xcloner_file_transfer();
-            $xcloner_file_transfer->set_target($target_url);
-            $return['start'] = $xcloner_file_transfer->transfer_file($file, $start, $hash);
+			$xcloner_file_transfer = $this->get_xcloner_container()->get_xcloner_file_transfer();
+			$xcloner_file_transfer->set_target($target_url);
+			$return['start'] = $xcloner_file_transfer->transfer_file($file, $start, $hash);
 
-        } catch (Exception $e) {
+		} catch (Exception $e) {
 
-            $return = array();
-            $return['error'] = true;
-            $return['status'] = 500;
-            $return['message'] = "CURL communication error with the restore host. " . $e->getMessage();
-            $this->send_response($return, 0);
+			$return = array();
+			$return['error'] = true;
+			$return['status'] = 500;
+			$return['message'] = "CURL communication error with the restore host. " . $e->getMessage();
+			$this->send_response($return, 0);
 
-        }
+		}
 
-        $return['status'] = 200;
+		$return['status'] = 200;
 
-        //we have finished the upload
-        if (!$return['start'] and $is_multipart) {
-            $return['part']++;
-            $return['uploaded_size'] += $this->xcloner_file_system->get_storage_filesystem()->getSize($file);
-        }
+		//we have finished the upload
+		if (!$return['start'] and $is_multipart) {
+			$return['part']++;
+			$return['uploaded_size'] += $this->xcloner_file_system->get_storage_filesystem()->getSize($file);
+		}
 
-        $this->send_response($return, 0);
-    }
+		$this->send_response($return, 0);
+	}
 
-    /*
+	/*
      * Restore backup
      */
-    public function restore_backup()
-    {
-        $this->check_access();
+	public function restore_backup()
+	{
+		$this->check_access();
 
-        define("XCLONER_PLUGIN_ACCESS", 1);
-        include_once(dirname(__DIR__) . DS . "restore" . DS . "xcloner_restore.php");
+		define("XCLONER_PLUGIN_ACCESS", 1);
+		include_once(dirname(__DIR__) . DS . "restore" . DS . "xcloner_restore.php");
 
-        return;
-    }
+		return;
+	}
 
-    /*
+	/*
      *
      * Send the json response back
      *
      */
-    private function send_response($data, $attach_hash = 1)
-    {
+	private function send_response($data, $attach_hash = 1)
+	{
 
-        if ($attach_hash and null !== $this->xcloner_settings->get_hash()) {
-            $data['hash'] = $this->xcloner_settings->get_hash();
-        }
+		if ($attach_hash and null !== $this->xcloner_settings->get_hash()) {
+			$data['hash'] = $this->xcloner_settings->get_hash();
+		}
 
-        if (ob_get_length()) {
-            ob_clean();
-        }
-        wp_send_json($data);
+		if (ob_get_length()) {
+			ob_clean();
+		}
+		wp_send_json($data);
 
-        die();
-    }
+		die();
+	}
 }

includes/class-xcloner-i18n.php

Indentation +13 added lines, -13 removed lines

@@ -41,21 +41,21 @@
 class Xcloner_i18n
 {
 
-    /**
-     * Load the plugin text domain for translation.
-     *
-     * @since    1.0.0
-     */
-    public function load_plugin_textdomain()
-    {
+	/**
+	 * Load the plugin text domain for translation.
+	 *
+	 * @since    1.0.0
+	 */
+	public function load_plugin_textdomain()
+	{
 
-        load_plugin_textdomain(
-            'xcloner-backup-and-restore',
-            false,
-            dirname(dirname(plugin_basename(__FILE__))) . '/languages/'
-        );
+		load_plugin_textdomain(
+			'xcloner-backup-and-restore',
+			false,
+			dirname(dirname(plugin_basename(__FILE__))) . '/languages/'
+		);
 
-    }
+	}
 
 
 }

includes/class-xcloner-file-system.php

Indentation +957 added lines, -957 removed lines

@@ -37,848 +37,848 @@ 
 class Xcloner_File_System
 {
 
-    private $excluded_files = "";
-    private $additional_regex_patterns = array();
-    private $excluded_files_by_default = array("administrator/backups", "wp-content/backups");
-    private $included_files_handler = "backup_files.csv";
-    private $temp_dir_handler = ".dir";
-    public $filesystem;
-    public $tmp_filesystem;
-    public $storage_filesystem;
-    private $xcloner_container;
-    private $diff_timestamp_start = "";
-
-    private $logger;
-    private $start_adapter;
-    private $tmp_adapter;
-    private $storage_adapter;
-    private $xcloner_settings;
-    private $start_filesystem;
-    private $tmp_filesystem_append;
-    private $storage_filesystem_append;
-
-    private $files_counter;
-    private $files_size;
-    private $last_logged_file;
-    private $folders_to_process_per_session = 25;
-    private $backup_archive_extensions = array("tar", "tgz", "tar.gz", "gz", "csv");
-    private $backup_name_tags = array('[time]', '[hostname]', '[domain]');
-
-    /**
-     * Xcloner_File_System constructor.
-     * @param Xcloner $xcloner_container
-     * @param string $hash
-     */
-    public function __construct(Xcloner $xcloner_container, $hash = "")
-    {
-        $this->xcloner_container = $xcloner_container;
-
-        $this->logger = $xcloner_container->get_xcloner_logger()->withName("xcloner_file_system");
-        $this->xcloner_settings = $xcloner_container->get_xcloner_settings();
-
-        try {
-
-            $this->start_adapter = new Local($this->xcloner_settings->get_xcloner_start_path(), LOCK_EX, 'SKIP_LINKS');
-            $this->start_filesystem = new Filesystem($this->start_adapter, new Config([
-                'disable_asserts' => true,
-            ]));
-
-            $this->tmp_adapter = new Local($this->xcloner_settings->get_xcloner_tmp_path(), LOCK_EX, 'SKIP_LINKS');
-            $this->tmp_filesystem = new Filesystem($this->tmp_adapter, new Config([
-                'disable_asserts' => true,
-            ]));
-            $adapter = new Local($this->xcloner_settings->get_xcloner_tmp_path(), LOCK_EX | FILE_APPEND, 'SKIP_LINKS');
-            $this->tmp_filesystem_append = new Filesystem($adapter, new Config([
-                'disable_asserts' => true,
-            ]));
-
-            $adapter = new Local($this->xcloner_settings->get_xcloner_store_path(), LOCK_EX, 'SKIP_LINKS');
-            $this->storage_filesystem = new Filesystem($adapter, new Config([
-                'disable_asserts' => true,
-            ]));
-
-            $this->storage_adapter = new Local($this->xcloner_settings->get_xcloner_store_path(), FILE_APPEND,
-                'SKIP_LINKS');
-            $this->storage_filesystem_append = new Filesystem($this->storage_adapter, new Config([
-                'disable_asserts' => true,
-            ]));
-        } catch (Exception $e) {
-            $this->logger->error("Filesystem Initialization Error: " . $e->getMessage());
-        }
-
-
-        if ($value = get_option('xcloner_directories_to_scan_per_request')) {
-            $this->folders_to_process_per_session = $value;
-        }
-
-    }
-
-    /**
-     * Set differential timestamp date
-     * @param string $timestamp
-     */
-    public function set_diff_timestamp_start($timestamp = "")
-    {
-        if ($timestamp) {
-            $this->logger->info(sprintf("Setting Differential Timestamp To %s", date("Y-m-d", $timestamp)), array(
-                "FILESYSTEM",
-                "DIFF"
-            ));
-            $this->diff_timestamp_start = $timestamp;
-        }
-    }
-
-    /**
-     * Gets the differential timestamp date
-     * @return string
-     */
-    public function get_diff_timestamp_start()
-    {
-        return $this->diff_timestamp_start;
-    }
-
-    private function get_xcloner_container()
-    {
-        return $this->xcloner_container;
-    }
-
-    public function set_hash($hash)
-    {
-        $this->xcloner_settings->set_hash($hash);
-    }
-
-    public function get_hash($hash)
-    {
-        $this->xcloner_settings->get_hash();
-    }
-
-    public function get_tmp_filesystem()
-    {
-        return $this->tmp_filesystem;
-    }
-
-    public function get_storage_filesystem($remote_storage_selection = "")
-    {
-        if ($remote_storage_selection != "") {
-            $remote_storage = $this->get_xcloner_container()->get_xcloner_remote_storage();
-            $method = "get_" . $remote_storage_selection . "_filesystem";
-
-            if (!method_exists($remote_storage, $method)) {
-                return false;
-            }
-
-            list($adapter, $filesystem) = $remote_storage->$method();
-
-            return $filesystem;
-        }
-
-        return $this->storage_filesystem;
-    }
-
-    public function get_tmp_filesystem_adapter()
-    {
-        return $this->tmp_adapter;
-    }
-
-    public function get_tmp_filesystem_append()
-    {
-        return $this->tmp_filesystem_append;
-    }
-
-    public function get_start_adapter()
-    {
-        return $this->start_adapter;
-    }
-
-    public function get_start_filesystem()
-    {
-        return $this->start_filesystem;
-    }
-
-    public function get_logger()
-    {
-        return $this->logger;
-    }
-
-    public function get_start_path_file_info($file)
-    {
-        $info = $this->getMetadataFull('start_adapter', $file);
-
-        return $this->start_filesystem->normalizeFileInfo($info);
-    }
-
-    public function get_storage_path_file_info($file)
-    {
-        return $this->getMetadataFull('storage_adapter', $file);
-    }
-
-    public function get_included_files_handler($metadata = 0)
-    {
-        $path = $this->included_files_handler;
-        if (!$metadata) {
-            return $path;
-        }
-
-        $spl_info = $this->getMetadataFull('tmp_adapter', $path);
-
-        return $spl_info;
-
-    }
-
-    public function get_temp_dir_handler()
-    {
-        return $this->temp_dir_handler;
-    }
-
-    public function get_latest_backup()
-    {
-        $files = $this->get_backup_archives_list();
-
-        if (is_array($files)) {
-            $this->sort_by($files, "timestamp", "desc");
-        }
-
-        $new_list = array();
-
-        foreach ($files as $key => $file) {
-            if (!isset($file['parent'])) {
-                $new_list[] = ($files[$key]);
-            }
-        }
-
-        if (isset($new_list[0])) {
-            return $new_list[0];
-        }
-    }
-
-    public function get_latest_backups()
-    {
-        $files = $this->get_backup_archives_list();
-
-        if (is_array($files)) {
-            $this->sort_by($files, "timestamp", "desc");
-        }
-
-        $new_list = array();
-
-        foreach ($files as $key => $file) {
-            if (!isset($file['parent'])) {
-                $new_list[] = ($files[$key]);
-            }
-        }
-
-        return $new_list;
-    }
-
-    public function get_storage_usage()
-    {
-        $files = $this->get_backup_archives_list();
-        $total = 0;
-
-        if (is_array($files)) {
-            foreach ($files as $file) {
-                $total += $file['size'];
-            }
-        }
-
-        return $total;
-    }
-
-    public function is_part($backup_name)
-    {
-        if (stristr($backup_name, "-part")) {
-            return true;
-        }
-
-        return false;
-    }
-
-    public function is_multipart($backup_name)
-    {
-        if (stristr($backup_name, "-multipart")) {
-            return true;
-        }
-
-        return false;
-    }
-
-    public function get_backup_size($backup_name)
-    {
-        $backup_size = $this->get_storage_filesystem()->getSize($backup_name);
-        if ($this->is_multipart($backup_name)) {
-            $backup_parts = $this->get_multipart_files($backup_name);
-            foreach ($backup_parts as $part_file) {
-                $backup_size += $this->get_storage_filesystem()->getSize($part_file);
-            }
-        }
-
-        return $backup_size;
-    }
-
-    public function get_multipart_files($backup_name, $storage_selection = "")
-    {
-        $files = array();
-
-        if ($this->is_multipart($backup_name)) {
-            $lines = explode(PHP_EOL, $this->get_storage_filesystem($storage_selection)->read($backup_name));
-            foreach ($lines as $line) {
-                if ($line) {
-                    $data = str_getcsv($line);
-                    $files[] = $data[0];
-                }
-            }
-        }
-
-        return $files;
-    }
-
-    public function delete_backup_by_name($backup_name, $storage_selection = "")
-    {
-        if ($this->is_multipart($backup_name)) {
-            $lines = explode(PHP_EOL, $this->get_storage_filesystem($storage_selection)->read($backup_name));
-            foreach ($lines as $line) {
-                if ($line) {
-                    $data = str_getcsv($line);
-                    $this->get_storage_filesystem($storage_selection)->delete($data[0]);
-                }
-            }
-        }
-
-        if ($this->get_storage_filesystem($storage_selection)->delete($backup_name)) {
-            $return = true;
-        } else {
-            $return = false;
-        }
-
-        return $return;
-    }
-
-    public function getMetadataFull($adapter = "storage_adapter", $path)
-    {
-        $location = $this->$adapter->applyPathPrefix($path);
-        $spl_info = new SplFileInfo($location);
-
-        return ($spl_info);
-    }
-
-
-    public function get_backup_archives_list($storage_selection = "")
-    {
-        $list = array();
-
-
-        if (method_exists($this->get_storage_filesystem($storage_selection), "listContents")) {
-            $list = $this->get_storage_filesystem($storage_selection)->listContents();
-        }
-
-        $backup_files = array();
-        $parents = array();
-
-        foreach ($list as $file_info) {
-            if (isset($file_info['extension']) and $file_info['extension'] == "csv") {
-                $data = array();
-
-                $lines = explode(PHP_EOL, $this->get_storage_filesystem($storage_selection)->read($file_info['path']));
-                foreach ($lines as $line) {
-                    if ($line) {
-                        $data = str_getcsv($line);
-                        if (is_array($data)) {
-                            $parents[$data[0]] = $file_info['basename'];
-                            $file_info['childs'][] = $data;
-                            $file_info['size'] += $data[2];
-                        }
-                    }
-                }
-
-            }
-
-            if ($file_info['type'] == 'file' and isset($file_info['extension']) and in_array($file_info['extension'],
-                    $this->backup_archive_extensions)) {
-                $backup_files[$file_info['path']] = $file_info;
-            }
-        }
-
-        foreach ($backup_files as $key => $file_info) {
-            if (!isset($backup_files[$key]['timestamp'])) {
-                //$backup_files[$key]['timestamp'] = $this->get_storage_filesystem($storage_selection)->getTimestamp($file_info['path']);
-            }
-
-            if (isset($parents[$file_info['basename']])) {
-                $backup_files[$key]['parent'] = $parents[$file_info['basename']];
-            }
-        }
-
-        return $backup_files;
-    }
-
-    public function start_file_recursion($init = 0)
-    {
-        if ($init) {
-            $this->logger->info(sprintf(__("Starting the filesystem scanner on root folder %s"),
-                $this->xcloner_settings->get_xcloner_start_path()));
-            $this->do_system_init();
-        }
-
-        if ($this->tmp_filesystem->has($this->get_temp_dir_handler())) {
-            //.dir exists, we presume we have files to iterate
-            $content = $this->tmp_filesystem->read($this->get_temp_dir_handler());
-            $files = array_filter(explode("\n", $content));
-            $this->tmp_filesystem->delete($this->get_temp_dir_handler());
-
-            $counter = 0;
-            foreach ($files as $file) {
-                if ($counter < $this->folders_to_process_per_session) {
-                    $this->build_files_list($file);
-                    $counter++;
-                } else {
-                    $this->tmp_filesystem_append->write($this->get_temp_dir_handler(), $file . "\n");
-                }
-            }
-        } else {
-            $this->build_files_list();
-        }
-
-        if ($this->scan_finished()) {
-            $metadata_dumpfile = $this->get_tmp_filesystem()->getMetadata("index.html");
-            $this->store_file($metadata_dumpfile, 'tmp_filesystem');
-            $this->files_counter++;
-
-            //adding included dump file to the included files list
-            if ($this->get_tmp_filesystem()->has($this->get_included_files_handler())) {
-                $metadata_dumpfile = $this->get_tmp_filesystem()->getMetadata($this->get_included_files_handler());
-                $this->store_file($metadata_dumpfile, 'tmp_filesystem');
-                $this->files_counter++;
-            }
-
-            //adding a default index.html to the temp xcloner folder
-            if (!$this->get_tmp_filesystem()->has("index.html")) {
-                $this->get_tmp_filesystem()->write("index.html", "");
-            }
-
-            //adding the default log file
-            if ($this->get_tmp_filesystem()->has($this->xcloner_settings->get_logger_filename(1))) {
-                $metadata_dumpfile = $this->get_tmp_filesystem()->getMetadata($this->xcloner_settings->get_logger_filename(1));
-                $this->store_file($metadata_dumpfile, 'tmp_filesystem');
-                $this->files_counter++;
-            }
-
-            return false;
-        }
-
-        return true;
-    }
-
-    public function get_backup_attachments()
-    {
-        $return = array();
-
-        $files_list_file = $this->xcloner_settings->get_xcloner_tmp_path() . DS . $this->get_included_files_handler();
-        if (file_exists($files_list_file)) {
-            $return[] = $files_list_file;
-        }
-
-        if ($this->xcloner_settings->get_xcloner_option('xcloner_enable_log')) {
-            $log_file = $this->xcloner_settings->get_xcloner_tmp_path() . DS . $this->xcloner_settings->get_logger_filename(1);
-            if (!file_exists($log_file)) {
-                $log_file = $this->xcloner_settings->get_xcloner_store_path() . DS . $this->xcloner_settings->get_logger_filename();
-            }
-
-            if (file_exists($log_file)) {
-                $return[] = $log_file;
-            }
-        }
-
-        return $return;
-    }
-
-    public function remove_tmp_filesystem()
-    {
-        //delete the temporary folder
-        $this->logger->debug(sprintf("Deleting the temporary storage folder %s",
-            $this->xcloner_settings->get_xcloner_tmp_path()));
-
-        $contents = $this->get_tmp_filesystem()->listContents();
-
-        if (is_array($contents)) {
-            foreach ($contents as $file_info) {
-                $this->get_tmp_filesystem()->delete($file_info['path']);
-            }
-        }
-
-        @rmdir($this->xcloner_settings->get_xcloner_tmp_path());
-
-        return;
-    }
-
-    public function cleanup_tmp_directories()
-    {
-        $adapter = new Local($this->xcloner_settings->get_xcloner_tmp_path(false), LOCK_EX | FILE_APPEND, 'SKIP_LINKS');
-        $tmp_filesystem = new Filesystem($adapter, new Config([
-            'disable_asserts' => true,
-        ]));
-
-        $contents = $tmp_filesystem->listContents();
-
-        foreach ($contents as $file) {
-
-            if (preg_match("/.xcloner-(.*)/", $file['path'])) {
-                if ($file['timestamp'] < strtotime("-1days")) {
-                    $tmp_filesystem->deleteDir($file['path']);
-                    $this->logger->debug(sprintf("Delete temporary directory %s", $file['path']));
-                }
-            }
-        }
-
-        return true;
-    }
-
-    private function do_system_init()
-    {
-        $this->files_counter = 0;
-
-        if (!$this->storage_filesystem->has("index.html")) {
-            $this->storage_filesystem->write("index.html", "");
-        }
-
-        if (!$this->tmp_filesystem->has("index.html")) {
-            $this->tmp_filesystem->write("index.html", "");
-        }
-
-        if ($this->tmp_filesystem->has($this->get_included_files_handler())) {
-            $this->tmp_filesystem->delete($this->get_included_files_handler());
-        }
-
-        if ($this->tmp_filesystem->has($this->get_temp_dir_handler())) {
-            $this->tmp_filesystem->delete($this->get_temp_dir_handler());
-        }
-    }
-
-    public function get_scanned_files_num()
-    {
-        return $this->files_counter;
-    }
-
-    public function get_scanned_files_total_size()
-    {
-        return $this->files_size;
-    }
-
-    public function last_logged_file()
-    {
-        return $this->last_logged_file;
-    }
-
-    public static function is_regex($regex)
-    {
-        return preg_match("/^\^(.*)\$$/i", $regex);
-    }
+	private $excluded_files = "";
+	private $additional_regex_patterns = array();
+	private $excluded_files_by_default = array("administrator/backups", "wp-content/backups");
+	private $included_files_handler = "backup_files.csv";
+	private $temp_dir_handler = ".dir";
+	public $filesystem;
+	public $tmp_filesystem;
+	public $storage_filesystem;
+	private $xcloner_container;
+	private $diff_timestamp_start = "";
+
+	private $logger;
+	private $start_adapter;
+	private $tmp_adapter;
+	private $storage_adapter;
+	private $xcloner_settings;
+	private $start_filesystem;
+	private $tmp_filesystem_append;
+	private $storage_filesystem_append;
+
+	private $files_counter;
+	private $files_size;
+	private $last_logged_file;
+	private $folders_to_process_per_session = 25;
+	private $backup_archive_extensions = array("tar", "tgz", "tar.gz", "gz", "csv");
+	private $backup_name_tags = array('[time]', '[hostname]', '[domain]');
+
+	/**
+	 * Xcloner_File_System constructor.
+	 * @param Xcloner $xcloner_container
+	 * @param string $hash
+	 */
+	public function __construct(Xcloner $xcloner_container, $hash = "")
+	{
+		$this->xcloner_container = $xcloner_container;
+
+		$this->logger = $xcloner_container->get_xcloner_logger()->withName("xcloner_file_system");
+		$this->xcloner_settings = $xcloner_container->get_xcloner_settings();
+
+		try {
+
+			$this->start_adapter = new Local($this->xcloner_settings->get_xcloner_start_path(), LOCK_EX, 'SKIP_LINKS');
+			$this->start_filesystem = new Filesystem($this->start_adapter, new Config([
+				'disable_asserts' => true,
+			]));
+
+			$this->tmp_adapter = new Local($this->xcloner_settings->get_xcloner_tmp_path(), LOCK_EX, 'SKIP_LINKS');
+			$this->tmp_filesystem = new Filesystem($this->tmp_adapter, new Config([
+				'disable_asserts' => true,
+			]));
+			$adapter = new Local($this->xcloner_settings->get_xcloner_tmp_path(), LOCK_EX | FILE_APPEND, 'SKIP_LINKS');
+			$this->tmp_filesystem_append = new Filesystem($adapter, new Config([
+				'disable_asserts' => true,
+			]));
+
+			$adapter = new Local($this->xcloner_settings->get_xcloner_store_path(), LOCK_EX, 'SKIP_LINKS');
+			$this->storage_filesystem = new Filesystem($adapter, new Config([
+				'disable_asserts' => true,
+			]));
+
+			$this->storage_adapter = new Local($this->xcloner_settings->get_xcloner_store_path(), FILE_APPEND,
+				'SKIP_LINKS');
+			$this->storage_filesystem_append = new Filesystem($this->storage_adapter, new Config([
+				'disable_asserts' => true,
+			]));
+		} catch (Exception $e) {
+			$this->logger->error("Filesystem Initialization Error: " . $e->getMessage());
+		}
+
+
+		if ($value = get_option('xcloner_directories_to_scan_per_request')) {
+			$this->folders_to_process_per_session = $value;
+		}
+
+	}
+
+	/**
+	 * Set differential timestamp date
+	 * @param string $timestamp
+	 */
+	public function set_diff_timestamp_start($timestamp = "")
+	{
+		if ($timestamp) {
+			$this->logger->info(sprintf("Setting Differential Timestamp To %s", date("Y-m-d", $timestamp)), array(
+				"FILESYSTEM",
+				"DIFF"
+			));
+			$this->diff_timestamp_start = $timestamp;
+		}
+	}
+
+	/**
+	 * Gets the differential timestamp date
+	 * @return string
+	 */
+	public function get_diff_timestamp_start()
+	{
+		return $this->diff_timestamp_start;
+	}
+
+	private function get_xcloner_container()
+	{
+		return $this->xcloner_container;
+	}
+
+	public function set_hash($hash)
+	{
+		$this->xcloner_settings->set_hash($hash);
+	}
+
+	public function get_hash($hash)
+	{
+		$this->xcloner_settings->get_hash();
+	}
+
+	public function get_tmp_filesystem()
+	{
+		return $this->tmp_filesystem;
+	}
+
+	public function get_storage_filesystem($remote_storage_selection = "")
+	{
+		if ($remote_storage_selection != "") {
+			$remote_storage = $this->get_xcloner_container()->get_xcloner_remote_storage();
+			$method = "get_" . $remote_storage_selection . "_filesystem";
+
+			if (!method_exists($remote_storage, $method)) {
+				return false;
+			}
+
+			list($adapter, $filesystem) = $remote_storage->$method();
+
+			return $filesystem;
+		}
+
+		return $this->storage_filesystem;
+	}
+
+	public function get_tmp_filesystem_adapter()
+	{
+		return $this->tmp_adapter;
+	}
+
+	public function get_tmp_filesystem_append()
+	{
+		return $this->tmp_filesystem_append;
+	}
+
+	public function get_start_adapter()
+	{
+		return $this->start_adapter;
+	}
+
+	public function get_start_filesystem()
+	{
+		return $this->start_filesystem;
+	}
+
+	public function get_logger()
+	{
+		return $this->logger;
+	}
+
+	public function get_start_path_file_info($file)
+	{
+		$info = $this->getMetadataFull('start_adapter', $file);
+
+		return $this->start_filesystem->normalizeFileInfo($info);
+	}
+
+	public function get_storage_path_file_info($file)
+	{
+		return $this->getMetadataFull('storage_adapter', $file);
+	}
+
+	public function get_included_files_handler($metadata = 0)
+	{
+		$path = $this->included_files_handler;
+		if (!$metadata) {
+			return $path;
+		}
+
+		$spl_info = $this->getMetadataFull('tmp_adapter', $path);
+
+		return $spl_info;
+
+	}
+
+	public function get_temp_dir_handler()
+	{
+		return $this->temp_dir_handler;
+	}
+
+	public function get_latest_backup()
+	{
+		$files = $this->get_backup_archives_list();
+
+		if (is_array($files)) {
+			$this->sort_by($files, "timestamp", "desc");
+		}
+
+		$new_list = array();
+
+		foreach ($files as $key => $file) {
+			if (!isset($file['parent'])) {
+				$new_list[] = ($files[$key]);
+			}
+		}
+
+		if (isset($new_list[0])) {
+			return $new_list[0];
+		}
+	}
+
+	public function get_latest_backups()
+	{
+		$files = $this->get_backup_archives_list();
+
+		if (is_array($files)) {
+			$this->sort_by($files, "timestamp", "desc");
+		}
+
+		$new_list = array();
+
+		foreach ($files as $key => $file) {
+			if (!isset($file['parent'])) {
+				$new_list[] = ($files[$key]);
+			}
+		}
+
+		return $new_list;
+	}
+
+	public function get_storage_usage()
+	{
+		$files = $this->get_backup_archives_list();
+		$total = 0;
+
+		if (is_array($files)) {
+			foreach ($files as $file) {
+				$total += $file['size'];
+			}
+		}
+
+		return $total;
+	}
+
+	public function is_part($backup_name)
+	{
+		if (stristr($backup_name, "-part")) {
+			return true;
+		}
+
+		return false;
+	}
+
+	public function is_multipart($backup_name)
+	{
+		if (stristr($backup_name, "-multipart")) {
+			return true;
+		}
+
+		return false;
+	}
+
+	public function get_backup_size($backup_name)
+	{
+		$backup_size = $this->get_storage_filesystem()->getSize($backup_name);
+		if ($this->is_multipart($backup_name)) {
+			$backup_parts = $this->get_multipart_files($backup_name);
+			foreach ($backup_parts as $part_file) {
+				$backup_size += $this->get_storage_filesystem()->getSize($part_file);
+			}
+		}
+
+		return $backup_size;
+	}
+
+	public function get_multipart_files($backup_name, $storage_selection = "")
+	{
+		$files = array();
+
+		if ($this->is_multipart($backup_name)) {
+			$lines = explode(PHP_EOL, $this->get_storage_filesystem($storage_selection)->read($backup_name));
+			foreach ($lines as $line) {
+				if ($line) {
+					$data = str_getcsv($line);
+					$files[] = $data[0];
+				}
+			}
+		}
+
+		return $files;
+	}
+
+	public function delete_backup_by_name($backup_name, $storage_selection = "")
+	{
+		if ($this->is_multipart($backup_name)) {
+			$lines = explode(PHP_EOL, $this->get_storage_filesystem($storage_selection)->read($backup_name));
+			foreach ($lines as $line) {
+				if ($line) {
+					$data = str_getcsv($line);
+					$this->get_storage_filesystem($storage_selection)->delete($data[0]);
+				}
+			}
+		}
+
+		if ($this->get_storage_filesystem($storage_selection)->delete($backup_name)) {
+			$return = true;
+		} else {
+			$return = false;
+		}
+
+		return $return;
+	}
+
+	public function getMetadataFull($adapter = "storage_adapter", $path)
+	{
+		$location = $this->$adapter->applyPathPrefix($path);
+		$spl_info = new SplFileInfo($location);
+
+		return ($spl_info);
+	}
+
+
+	public function get_backup_archives_list($storage_selection = "")
+	{
+		$list = array();
+
+
+		if (method_exists($this->get_storage_filesystem($storage_selection), "listContents")) {
+			$list = $this->get_storage_filesystem($storage_selection)->listContents();
+		}
+
+		$backup_files = array();
+		$parents = array();
+
+		foreach ($list as $file_info) {
+			if (isset($file_info['extension']) and $file_info['extension'] == "csv") {
+				$data = array();
+
+				$lines = explode(PHP_EOL, $this->get_storage_filesystem($storage_selection)->read($file_info['path']));
+				foreach ($lines as $line) {
+					if ($line) {
+						$data = str_getcsv($line);
+						if (is_array($data)) {
+							$parents[$data[0]] = $file_info['basename'];
+							$file_info['childs'][] = $data;
+							$file_info['size'] += $data[2];
+						}
+					}
+				}
+
+			}
+
+			if ($file_info['type'] == 'file' and isset($file_info['extension']) and in_array($file_info['extension'],
+					$this->backup_archive_extensions)) {
+				$backup_files[$file_info['path']] = $file_info;
+			}
+		}
+
+		foreach ($backup_files as $key => $file_info) {
+			if (!isset($backup_files[$key]['timestamp'])) {
+				//$backup_files[$key]['timestamp'] = $this->get_storage_filesystem($storage_selection)->getTimestamp($file_info['path']);
+			}
+
+			if (isset($parents[$file_info['basename']])) {
+				$backup_files[$key]['parent'] = $parents[$file_info['basename']];
+			}
+		}
+
+		return $backup_files;
+	}
+
+	public function start_file_recursion($init = 0)
+	{
+		if ($init) {
+			$this->logger->info(sprintf(__("Starting the filesystem scanner on root folder %s"),
+				$this->xcloner_settings->get_xcloner_start_path()));
+			$this->do_system_init();
+		}
+
+		if ($this->tmp_filesystem->has($this->get_temp_dir_handler())) {
+			//.dir exists, we presume we have files to iterate
+			$content = $this->tmp_filesystem->read($this->get_temp_dir_handler());
+			$files = array_filter(explode("\n", $content));
+			$this->tmp_filesystem->delete($this->get_temp_dir_handler());
+
+			$counter = 0;
+			foreach ($files as $file) {
+				if ($counter < $this->folders_to_process_per_session) {
+					$this->build_files_list($file);
+					$counter++;
+				} else {
+					$this->tmp_filesystem_append->write($this->get_temp_dir_handler(), $file . "\n");
+				}
+			}
+		} else {
+			$this->build_files_list();
+		}
+
+		if ($this->scan_finished()) {
+			$metadata_dumpfile = $this->get_tmp_filesystem()->getMetadata("index.html");
+			$this->store_file($metadata_dumpfile, 'tmp_filesystem');
+			$this->files_counter++;
+
+			//adding included dump file to the included files list
+			if ($this->get_tmp_filesystem()->has($this->get_included_files_handler())) {
+				$metadata_dumpfile = $this->get_tmp_filesystem()->getMetadata($this->get_included_files_handler());
+				$this->store_file($metadata_dumpfile, 'tmp_filesystem');
+				$this->files_counter++;
+			}
+
+			//adding a default index.html to the temp xcloner folder
+			if (!$this->get_tmp_filesystem()->has("index.html")) {
+				$this->get_tmp_filesystem()->write("index.html", "");
+			}
+
+			//adding the default log file
+			if ($this->get_tmp_filesystem()->has($this->xcloner_settings->get_logger_filename(1))) {
+				$metadata_dumpfile = $this->get_tmp_filesystem()->getMetadata($this->xcloner_settings->get_logger_filename(1));
+				$this->store_file($metadata_dumpfile, 'tmp_filesystem');
+				$this->files_counter++;
+			}
+
+			return false;
+		}
+
+		return true;
+	}
+
+	public function get_backup_attachments()
+	{
+		$return = array();
+
+		$files_list_file = $this->xcloner_settings->get_xcloner_tmp_path() . DS . $this->get_included_files_handler();
+		if (file_exists($files_list_file)) {
+			$return[] = $files_list_file;
+		}
+
+		if ($this->xcloner_settings->get_xcloner_option('xcloner_enable_log')) {
+			$log_file = $this->xcloner_settings->get_xcloner_tmp_path() . DS . $this->xcloner_settings->get_logger_filename(1);
+			if (!file_exists($log_file)) {
+				$log_file = $this->xcloner_settings->get_xcloner_store_path() . DS . $this->xcloner_settings->get_logger_filename();
+			}
+
+			if (file_exists($log_file)) {
+				$return[] = $log_file;
+			}
+		}
+
+		return $return;
+	}
+
+	public function remove_tmp_filesystem()
+	{
+		//delete the temporary folder
+		$this->logger->debug(sprintf("Deleting the temporary storage folder %s",
+			$this->xcloner_settings->get_xcloner_tmp_path()));
+
+		$contents = $this->get_tmp_filesystem()->listContents();
+
+		if (is_array($contents)) {
+			foreach ($contents as $file_info) {
+				$this->get_tmp_filesystem()->delete($file_info['path']);
+			}
+		}
+
+		@rmdir($this->xcloner_settings->get_xcloner_tmp_path());
+
+		return;
+	}
+
+	public function cleanup_tmp_directories()
+	{
+		$adapter = new Local($this->xcloner_settings->get_xcloner_tmp_path(false), LOCK_EX | FILE_APPEND, 'SKIP_LINKS');
+		$tmp_filesystem = new Filesystem($adapter, new Config([
+			'disable_asserts' => true,
+		]));
+
+		$contents = $tmp_filesystem->listContents();
+
+		foreach ($contents as $file) {
+
+			if (preg_match("/.xcloner-(.*)/", $file['path'])) {
+				if ($file['timestamp'] < strtotime("-1days")) {
+					$tmp_filesystem->deleteDir($file['path']);
+					$this->logger->debug(sprintf("Delete temporary directory %s", $file['path']));
+				}
+			}
+		}
+
+		return true;
+	}
+
+	private function do_system_init()
+	{
+		$this->files_counter = 0;
+
+		if (!$this->storage_filesystem->has("index.html")) {
+			$this->storage_filesystem->write("index.html", "");
+		}
+
+		if (!$this->tmp_filesystem->has("index.html")) {
+			$this->tmp_filesystem->write("index.html", "");
+		}
+
+		if ($this->tmp_filesystem->has($this->get_included_files_handler())) {
+			$this->tmp_filesystem->delete($this->get_included_files_handler());
+		}
+
+		if ($this->tmp_filesystem->has($this->get_temp_dir_handler())) {
+			$this->tmp_filesystem->delete($this->get_temp_dir_handler());
+		}
+	}
+
+	public function get_scanned_files_num()
+	{
+		return $this->files_counter;
+	}
+
+	public function get_scanned_files_total_size()
+	{
+		return $this->files_size;
+	}
+
+	public function last_logged_file()
+	{
+		return $this->last_logged_file;
+	}
+
+	public static function is_regex($regex)
+	{
+		return preg_match("/^\^(.*)\$$/i", $regex);
+	}
 
-    public function set_excluded_files($excluded_files = array())
-    {
-        if (!is_array($excluded_files)) {
-            $excluded_files = array();
-        }
+	public function set_excluded_files($excluded_files = array())
+	{
+		if (!is_array($excluded_files)) {
+			$excluded_files = array();
+		}
 
-        foreach ($excluded_files as $excl) {
+		foreach ($excluded_files as $excl) {
 
-            if ($this->is_regex($excl)) {
-                $this->additional_regex_patterns[] = $excl;
-            }
-        }
+			if ($this->is_regex($excl)) {
+				$this->additional_regex_patterns[] = $excl;
+			}
+		}
 
-        $this->excluded_files = array_merge($excluded_files, $this->excluded_files_by_default);
+		$this->excluded_files = array_merge($excluded_files, $this->excluded_files_by_default);
 
-        return $this->excluded_files;
-    }
+		return $this->excluded_files;
+	}
 
-    public function get_excluded_files()
-    {
-        return $this->excluded_files_by_default;
-    }
+	public function get_excluded_files()
+	{
+		return $this->excluded_files_by_default;
+	}
 
-    public function list_directory($path)
-    {
-        return $this->start_filesystem->listContents($path);
-    }
+	public function list_directory($path)
+	{
+		return $this->start_filesystem->listContents($path);
+	}
 
-    public function build_files_list($folder = "")
-    {
-        $this->logger->debug(sprintf(("Building the files system list")));
+	public function build_files_list($folder = "")
+	{
+		$this->logger->debug(sprintf(("Building the files system list")));
 
-        //if we start with the root folder(empty value), we initializa the file system
-        if (!$folder) {
+		//if we start with the root folder(empty value), we initializa the file system
+		if (!$folder) {
 
-        }
+		}
 
-        try {
+		try {
 
-            $files = $this->start_filesystem->listContents($folder);
-            foreach ($files as $file) {
-                if (!is_readable($this->xcloner_settings->get_xcloner_start_path() . DS . $file['path'])) {
-                    $this->logger->info(sprintf(__("Excluding %s from the filesystem list, file not readable"),
-                        $file['path']), array(
-                        "FILESYSTEM SCAN",
-                        "NOT READABLE"
-                    ));
-                } elseif (!$matching_pattern = $this->is_excluded($file)) {
-                    $this->logger->info(sprintf(__("Adding %s to the filesystem list"), $file['path']), array(
-                        "FILESYSTEM SCAN",
-                        "INCLUDE"
-                    ));
-                    $file['visibility'] = $this->start_filesystem->getVisibility($file['path']);
-                    if ($this->store_file($file)) {
-                        $this->files_counter++;
-                    }
-                    if (isset($file['size'])) {
-                        $this->files_size += $file['size'];
-                    }
-
-                } else {
-                    $this->logger->info(sprintf(__("Excluding %s from the filesystem list, matching pattern %s"),
-                        $file['path'], $matching_pattern), array(
-                        "FILESYSTEM SCAN",
-                        "EXCLUDE"
-                    ));
-                }
-            }
+			$files = $this->start_filesystem->listContents($folder);
+			foreach ($files as $file) {
+				if (!is_readable($this->xcloner_settings->get_xcloner_start_path() . DS . $file['path'])) {
+					$this->logger->info(sprintf(__("Excluding %s from the filesystem list, file not readable"),
+						$file['path']), array(
+						"FILESYSTEM SCAN",
+						"NOT READABLE"
+					));
+				} elseif (!$matching_pattern = $this->is_excluded($file)) {
+					$this->logger->info(sprintf(__("Adding %s to the filesystem list"), $file['path']), array(
+						"FILESYSTEM SCAN",
+						"INCLUDE"
+					));
+					$file['visibility'] = $this->start_filesystem->getVisibility($file['path']);
+					if ($this->store_file($file)) {
+						$this->files_counter++;
+					}
+					if (isset($file['size'])) {
+						$this->files_size += $file['size'];
+					}
+
+				} else {
+					$this->logger->info(sprintf(__("Excluding %s from the filesystem list, matching pattern %s"),
+						$file['path'], $matching_pattern), array(
+						"FILESYSTEM SCAN",
+						"EXCLUDE"
+					));
+				}
+			}
 
-        } catch (Exception $e) {
+		} catch (Exception $e) {
 
-            $this->logger->error($e->getMessage());
+			$this->logger->error($e->getMessage());
 
-        }
+		}
 
-    }
+	}
 
-    public function estimate_read_write_time()
-    {
-        $tmp_file = ".xcloner" . substr(md5(time()), 0, 5);
+	public function estimate_read_write_time()
+	{
+		$tmp_file = ".xcloner" . substr(md5(time()), 0, 5);
 
-        $start_time = microtime(true);
+		$start_time = microtime(true);
 
-        $data = str_repeat(rand(0, 9), 1024 * 1024); //write 1MB data
+		$data = str_repeat(rand(0, 9), 1024 * 1024); //write 1MB data
 
-        try {
-            $this->tmp_filesystem->write($tmp_file, $data);
+		try {
+			$this->tmp_filesystem->write($tmp_file, $data);
 
-            $end_time = microtime(true) - $start_time;
+			$end_time = microtime(true) - $start_time;
 
-            $return['writing_time'] = $end_time;
+			$return['writing_time'] = $end_time;
 
-            $return['reading_time'] = $this->estimate_reading_time($tmp_file);
+			$return['reading_time'] = $this->estimate_reading_time($tmp_file);
 
-            $this->tmp_filesystem->delete($tmp_file);
+			$this->tmp_filesystem->delete($tmp_file);
 
-        } catch (Exception $e) {
+		} catch (Exception $e) {
 
-            $this->logger->error($e->getMessage());
+			$this->logger->error($e->getMessage());
 
-        }
+		}
 
-        return $return;
-    }
+		return $return;
+	}
 
-    public function backup_storage_cleanup()
-    {
-        $this->logger->info(sprintf(("Cleaning the backup storage on matching rules")));
+	public function backup_storage_cleanup()
+	{
+		$this->logger->info(sprintf(("Cleaning the backup storage on matching rules")));
 
-        $_storage_size = 0;
-        $_backup_files_list = array();
+		$_storage_size = 0;
+		$_backup_files_list = array();
 
-        //rule date limit
-        $current_timestamp = strtotime("-" . $this->xcloner_settings->get_xcloner_option('xcloner_cleanup_retention_limit_days') . " days");
+		//rule date limit
+		$current_timestamp = strtotime("-" . $this->xcloner_settings->get_xcloner_option('xcloner_cleanup_retention_limit_days') . " days");
 
-        $files = $this->storage_filesystem->listContents();
+		$files = $this->storage_filesystem->listContents();
 
-        if (is_array($files)) {
-            foreach ($files as $file) {
-                if (isset($file['extension']) and in_array($file['extension'], $this->backup_archive_extensions)) {
-                    $_storage_size += $file['size']; //bytes
-                    $_backup_files_list[] = $file;
-                }
-            }
-        }
+		if (is_array($files)) {
+			foreach ($files as $file) {
+				if (isset($file['extension']) and in_array($file['extension'], $this->backup_archive_extensions)) {
+					$_storage_size += $file['size']; //bytes
+					$_backup_files_list[] = $file;
+				}
+			}
+		}
 
 
-        $this->sort_by($_backup_files_list, "timestamp", "asc");
+		$this->sort_by($_backup_files_list, "timestamp", "asc");
 
-        $_backups_counter = sizeof($_backup_files_list);
+		$_backups_counter = sizeof($_backup_files_list);
 
-        foreach ($_backup_files_list as $file) {
-            //processing rule folder capacity
-            if ($this->xcloner_settings->get_xcloner_option('xcloner_cleanup_capacity_limit') &&
-                $_storage_size >= ($set_storage_limit = 1024 * 1024 * $this->xcloner_settings->get_xcloner_option('xcloner_cleanup_capacity_limit')))    //bytes
-            {
-                $this->storage_filesystem->delete($file['path']);
-                $_storage_size -= $file['size'];
-                $this->logger->info("Deleting backup " . $file['path'] . " matching rule", array(
-                    "STORAGE SIZE LIMIT",
-                    $_storage_size . " >= " . $set_storage_limit
-                ));
-            }
-
-            //processing rule days limit
-            if ($this->xcloner_settings->get_xcloner_option('xcloner_cleanup_retention_limit_days') && $current_timestamp >= $file['timestamp']) {
-                $this->storage_filesystem->delete($file['path']);
-                $this->logger->info("Deleting backup " . $file['path'] . " matching rule", array(
-                    "RETENTION LIMIT TIMESTAMP",
-                    $file['timestamp'] . " =< " . $this->xcloner_settings->get_xcloner_option('xcloner_cleanup_retention_limit_days')
-                ));
-            }
-
-            //processing backup countert limit
-            if ($this->xcloner_settings->get_xcloner_option('xcloner_cleanup_retention_limit_archives') && $_backups_counter >= $this->xcloner_settings->get_xcloner_option('xcloner_cleanup_retention_limit_archives')) {
-                $this->storage_filesystem->delete($file['path']);
-                $_backups_counter--;
-                $this->logger->info("Deleting backup " . $file['path'] . " matching rule", array(
-                    "BACKUP QUANTITY LIMIT",
-                    $_backups_counter . " >= " . $this->xcloner_settings->get_xcloner_option('xcloner_cleanup_retention_limit_archives')
-                ));
-            }
+		foreach ($_backup_files_list as $file) {
+			//processing rule folder capacity
+			if ($this->xcloner_settings->get_xcloner_option('xcloner_cleanup_capacity_limit') &&
+				$_storage_size >= ($set_storage_limit = 1024 * 1024 * $this->xcloner_settings->get_xcloner_option('xcloner_cleanup_capacity_limit')))    //bytes
+			{
+				$this->storage_filesystem->delete($file['path']);
+				$_storage_size -= $file['size'];
+				$this->logger->info("Deleting backup " . $file['path'] . " matching rule", array(
+					"STORAGE SIZE LIMIT",
+					$_storage_size . " >= " . $set_storage_limit
+				));
+			}
+
+			//processing rule days limit
+			if ($this->xcloner_settings->get_xcloner_option('xcloner_cleanup_retention_limit_days') && $current_timestamp >= $file['timestamp']) {
+				$this->storage_filesystem->delete($file['path']);
+				$this->logger->info("Deleting backup " . $file['path'] . " matching rule", array(
+					"RETENTION LIMIT TIMESTAMP",
+					$file['timestamp'] . " =< " . $this->xcloner_settings->get_xcloner_option('xcloner_cleanup_retention_limit_days')
+				));
+			}
+
+			//processing backup countert limit
+			if ($this->xcloner_settings->get_xcloner_option('xcloner_cleanup_retention_limit_archives') && $_backups_counter >= $this->xcloner_settings->get_xcloner_option('xcloner_cleanup_retention_limit_archives')) {
+				$this->storage_filesystem->delete($file['path']);
+				$_backups_counter--;
+				$this->logger->info("Deleting backup " . $file['path'] . " matching rule", array(
+					"BACKUP QUANTITY LIMIT",
+					$_backups_counter . " >= " . $this->xcloner_settings->get_xcloner_option('xcloner_cleanup_retention_limit_archives')
+				));
+			}
 
 
-        }
+		}
 
-    }
+	}
 
-    public function estimate_reading_time($tmp_file)
-    {
-        $this->logger->debug(sprintf(("Estimating file system reading time")));
+	public function estimate_reading_time($tmp_file)
+	{
+		$this->logger->debug(sprintf(("Estimating file system reading time")));
 
-        $start_time = microtime(true);
+		$start_time = microtime(true);
 
-        if ($this->tmp_filesystem->has($tmp_file)) {
-            $this->tmp_filesystem->read($tmp_file);
-        }
-
-        $end_time = microtime(true) - $start_time;
-
-        return $end_time;
-
-    }
-
-    public function process_backup_name($name = "", $max_length = 100)
-    {
-        if (!$name) {
-            $name = $this->xcloner_settings->get_default_backup_name();
-        }
-
-        foreach ($this->backup_name_tags as $tag) {
-            if ($tag == '[time]') {
-                $name = str_replace($tag, date("Y-m-d_H-i"), $name);
-            } elseif ($tag == '[hostname]') {
-                $name = str_replace($tag, gethostname(), $name);
-            } elseif ($tag == '[domain]') {
-                $domain = parse_url(admin_url(), PHP_URL_HOST);
-                $name = str_replace($tag, $domain, $name);
-            }
-        }
-
-        if ($max_length) {
-            $name = substr($name, 0, $max_length);
-        }
-
-        return $name;
-    }
-
-    public function sort_by(&$array, $field, $direction = 'asc')
-    {
-        if (strtolower($direction) == "desc" || $direction == SORT_DESC) {
-            $direction = SORT_DESC;
-        } else {
-            $direction = SORT_ASC;
-        }
-
-        $array = $this->array_orderby($array, $field, $direction);
-
-        return true;
-    }
-
-    private function array_orderby()
-    {
-        $args = func_get_args();
-        $data = array_shift($args);
-
-        foreach ($args as $n => $field) {
-            if (is_string($field)) {
-                $tmp = array();
-                foreach ($data as $key => $row) {
-                    if (is_array($row)) {
-                        $tmp[$key] = $row[$field];
-                    } else {
-                        $tmp[$key] = $row->$field;
-                    }
-                }
-                $args[$n] = $tmp;
-            }
-        }
-        $args[] = &$data;
-
-        call_user_func_array('array_multisort', $args);
-
-        return array_pop($args);
-    }
-
-    private function check_file_diff_time($file)
-    {
-        if ($this->get_diff_timestamp_start() != "") {
-            $fileMeta = $this->getMetadataFull("start_adapter", $file['path']);
-            $timestamp = $fileMeta->getMTime();
-            if ($timestamp < $fileMeta->getCTime()) {
-                $timestamp = $fileMeta->getCTime();
-            }
-
-            if ($timestamp <= $this->get_diff_timestamp_start()) {
-                return " file DIFF timestamp " . $timestamp . " < " . $this->diff_timestamp_start;
-            }
-        }
-
-        return false;
-    }
-
-    public function is_excluded($file)
-    {
-        $this->logger->debug(sprintf(("Checking if %s is excluded"), $file['path']));
-
-        if ($xcloner_exclude_files_larger_than_mb = $this->xcloner_settings->get_xcloner_option('xcloner_exclude_files_larger_than_mb')) {
-            if (isset($file['size']) && $file['size'] > $this->calc_to_bytes($xcloner_exclude_files_larger_than_mb)) {
-                return "> " . $xcloner_exclude_files_larger_than_mb . "MB";
-            }
-        }
-
-        if (!is_array($this->excluded_files) || !sizeof($this->excluded_files)) {
-            $this->set_excluded_files();
-        }
-
-        if (is_array($this->excluded_files)) {
-            foreach ($this->excluded_files as $excluded_file_pattern) {
-                if ($excluded_file_pattern == "/") {
-                    $needle = "$";
-                } else {
-                    $needle = "$" . $excluded_file_pattern;
-                }
-
-                if (strstr("$" . $file['path'], $needle)) {
-                    return $excluded_file_pattern;
-                }
-            }
-        }
-
-        if ($regex = $this->is_excluded_regex($file)) {
-            return $regex;
-        }
-
-        if ($file['type'] == "file") {
-            $check_file_diff_timestamp = $this->check_file_diff_time($file);
-            if ($check_file_diff_timestamp) {
-                return $check_file_diff_timestamp;
-            }
-        }
-
-        return false;
-    }
-
-    /*REGEX examples
+		if ($this->tmp_filesystem->has($tmp_file)) {
+			$this->tmp_filesystem->read($tmp_file);
+		}
+
+		$end_time = microtime(true) - $start_time;
+
+		return $end_time;
+
+	}
+
+	public function process_backup_name($name = "", $max_length = 100)
+	{
+		if (!$name) {
+			$name = $this->xcloner_settings->get_default_backup_name();
+		}
+
+		foreach ($this->backup_name_tags as $tag) {
+			if ($tag == '[time]') {
+				$name = str_replace($tag, date("Y-m-d_H-i"), $name);
+			} elseif ($tag == '[hostname]') {
+				$name = str_replace($tag, gethostname(), $name);
+			} elseif ($tag == '[domain]') {
+				$domain = parse_url(admin_url(), PHP_URL_HOST);
+				$name = str_replace($tag, $domain, $name);
+			}
+		}
+
+		if ($max_length) {
+			$name = substr($name, 0, $max_length);
+		}
+
+		return $name;
+	}
+
+	public function sort_by(&$array, $field, $direction = 'asc')
+	{
+		if (strtolower($direction) == "desc" || $direction == SORT_DESC) {
+			$direction = SORT_DESC;
+		} else {
+			$direction = SORT_ASC;
+		}
+
+		$array = $this->array_orderby($array, $field, $direction);
+
+		return true;
+	}
+
+	private function array_orderby()
+	{
+		$args = func_get_args();
+		$data = array_shift($args);
+
+		foreach ($args as $n => $field) {
+			if (is_string($field)) {
+				$tmp = array();
+				foreach ($data as $key => $row) {
+					if (is_array($row)) {
+						$tmp[$key] = $row[$field];
+					} else {
+						$tmp[$key] = $row->$field;
+					}
+				}
+				$args[$n] = $tmp;
+			}
+		}
+		$args[] = &$data;
+
+		call_user_func_array('array_multisort', $args);
+
+		return array_pop($args);
+	}
+
+	private function check_file_diff_time($file)
+	{
+		if ($this->get_diff_timestamp_start() != "") {
+			$fileMeta = $this->getMetadataFull("start_adapter", $file['path']);
+			$timestamp = $fileMeta->getMTime();
+			if ($timestamp < $fileMeta->getCTime()) {
+				$timestamp = $fileMeta->getCTime();
+			}
+
+			if ($timestamp <= $this->get_diff_timestamp_start()) {
+				return " file DIFF timestamp " . $timestamp . " < " . $this->diff_timestamp_start;
+			}
+		}
+
+		return false;
+	}
+
+	public function is_excluded($file)
+	{
+		$this->logger->debug(sprintf(("Checking if %s is excluded"), $file['path']));
+
+		if ($xcloner_exclude_files_larger_than_mb = $this->xcloner_settings->get_xcloner_option('xcloner_exclude_files_larger_than_mb')) {
+			if (isset($file['size']) && $file['size'] > $this->calc_to_bytes($xcloner_exclude_files_larger_than_mb)) {
+				return "> " . $xcloner_exclude_files_larger_than_mb . "MB";
+			}
+		}
+
+		if (!is_array($this->excluded_files) || !sizeof($this->excluded_files)) {
+			$this->set_excluded_files();
+		}
+
+		if (is_array($this->excluded_files)) {
+			foreach ($this->excluded_files as $excluded_file_pattern) {
+				if ($excluded_file_pattern == "/") {
+					$needle = "$";
+				} else {
+					$needle = "$" . $excluded_file_pattern;
+				}
+
+				if (strstr("$" . $file['path'], $needle)) {
+					return $excluded_file_pattern;
+				}
+			}
+		}
+
+		if ($regex = $this->is_excluded_regex($file)) {
+			return $regex;
+		}
+
+		if ($file['type'] == "file") {
+			$check_file_diff_timestamp = $this->check_file_diff_time($file);
+			if ($check_file_diff_timestamp) {
+				return $check_file_diff_timestamp;
+			}
+		}
+
+		return false;
+	}
+
+	/*REGEX examples
      *
     * exclude all except .php file
     * PATTERN: ^(.*)\.(.+)$(?<!(php))
@@ -910,163 +910,163 @@ 
     * exclude the backup folders
     * PATTERN: (^|^\/)(wp-content\/backups|administrator\/backups)(.*)$";
     */
-    private function is_excluded_regex($file)
-    {
-        //$this->logger->debug(sprintf(("Checking if %s is excluded"), $file['path']));
-
-        $regex_patterns = explode(PHP_EOL, $this->xcloner_settings->get_xcloner_option('xcloner_regex_exclude'));
-
-        if (is_array($this->additional_regex_patterns)) {
-            $regex_patterns = array_merge($regex_patterns, $this->additional_regex_patterns);
-        }
-
-        //print_r($regex_patterns);exit;
-
-        if (is_array($regex_patterns)) {
-            //$this->excluded_files = array();
-            //$this->excluded_files[] ="(.*)\.(git)(.*)$";
-            //$this->excluded_files[] ="wp-content\/backups(.*)$";
-
-            foreach ($regex_patterns as $excluded_file_pattern) {
-
-                if (substr($excluded_file_pattern, strlen($excluded_file_pattern) - 1,
-                        strlen($excluded_file_pattern)) == "\r") {
-                    $excluded_file_pattern = substr($excluded_file_pattern, 0, strlen($excluded_file_pattern) - 1);
-                }
-
-                if ($file['path'] == "/") {
-                    $needle = "/";
-                } else {
-                    $needle = "/" . $file['path'];
-                }
-                //echo $needle."---".$excluded_file_pattern."---\n";
-
-                if (@preg_match("/(^|^\/)" . $excluded_file_pattern . "/i", $needle)) {
-                    return $excluded_file_pattern;
-                }
-            }
-        }
-
-        return false;
-    }
-
-    public function store_file($file, $storage = 'start_filesystem')
-    {
-        $this->logger->debug(sprintf("Storing %s in the backup list", $file['path']));
-
-        if (!isset($file['size'])) {
-            $file['size'] = 0;
-        }
-        if (!isset($file['visibility'])) {
-            $file['visibility'] = "private";
-        }
-
-        $csv_filename = str_replace('"', '""', $file['path']);
-
-        $line = '"' . ($csv_filename) . '","' . $file['timestamp'] . '","' . $file['size'] . '","' . $file['visibility'] . '","' . $storage . '"' . PHP_EOL;
-
-        $this->last_logged_file = $file['path'];
-
-        if ($file['type'] == "dir") {
-            try {
-                $this->tmp_filesystem_append->write($this->get_temp_dir_handler(), $file['path'] . "\n");
-            } catch (Exception $e) {
-                $this->logger->error($e->getMessage());
-            }
-        }
-
-        if ($this->get_diff_timestamp_start()) {
-            if ($file['type'] != "file" && $response = $this->check_file_diff_time($file)) {
-                $this->logger->info(sprintf("Directory %s archiving skipped on differential backup %s", $file['path'],
-                    $response), array(
-                    "FILESYSTEM SCAN",
-                    "DIR DIFF"
-                ));
-
-                return false;
-            }
-        }
-
-        try {
-            if (!$this->tmp_filesystem_append->has($this->get_included_files_handler())) {
-                //adding fix for UTF-8 CSV preview
-                $start_line = "\xEF\xBB\xBF" . '"Filename","Timestamp","Size","Visibility","Storage"' . PHP_EOL;
-                $this->tmp_filesystem_append->write($this->get_included_files_handler(), $start_line);
-            }
-
-            $this->tmp_filesystem_append->write($this->get_included_files_handler(), $line);
-
-        } catch (Exception $e) {
-
-            $this->logger->error($e->getMessage());
-        }
-
-        return true;
-    }
-
-    public function get_fileystem_handler()
-    {
-        return $this;
-    }
-
-    public function get_filesystem($system = "")
-    {
-        if ($system == "storage_filesystem_append") {
-            return $this->storage_filesystem_append;
-        } elseif ($system == "tmp_filesystem_append") {
-            return $this->tmp_filesystem_append;
-        } elseif ($system == "tmp_filesystem") {
-            return $this->tmp_filesystem;
-        } elseif ($system == "storage_filesystem") {
-            return $this->storage_filesystem;
-        } else {
-            return $this->start_filesystem;
-        }
-    }
-
-    public function get_adapter($system)
-    {
-        if ($system == "tmp_filesystem") {
-            return $this->tmp_adapter;
-        } elseif ($system == "storage_filesystem") {
-            return $this->storage_adapter;
-        } else {
-            return $this->start_adapter;
-        }
-    }
-
-    /**
-     * File scan finished
-     * Method called when file scan is finished
-     *
-     * @return bool
-     */
-    private function scan_finished()
-    {
-        if ($this->tmp_filesystem_append->has($this->get_temp_dir_handler()) &&
-            $this->tmp_filesystem_append->getSize($this->get_temp_dir_handler())) {
-            return false;
-        }
-
-        if ($this->tmp_filesystem->has($this->get_temp_dir_handler())) {
-            $this->tmp_filesystem->delete($this->get_temp_dir_handler());
-        }
-
-        $this->logger->debug(sprintf(("File scan finished")));
-
-        return true;
-    }
-
-    /**
-     * Calculate bytes from MB value
-     *
-     * @param int $mb_size
-     *
-     * @return float|int
-     */
-    private function calc_to_bytes($mb_size)
-    {
-        return $mb_size * (1024 * 1024);
-    }
+	private function is_excluded_regex($file)
+	{
+		//$this->logger->debug(sprintf(("Checking if %s is excluded"), $file['path']));
+
+		$regex_patterns = explode(PHP_EOL, $this->xcloner_settings->get_xcloner_option('xcloner_regex_exclude'));
+
+		if (is_array($this->additional_regex_patterns)) {
+			$regex_patterns = array_merge($regex_patterns, $this->additional_regex_patterns);
+		}
+
+		//print_r($regex_patterns);exit;
+
+		if (is_array($regex_patterns)) {
+			//$this->excluded_files = array();
+			//$this->excluded_files[] ="(.*)\.(git)(.*)$";
+			//$this->excluded_files[] ="wp-content\/backups(.*)$";
+
+			foreach ($regex_patterns as $excluded_file_pattern) {
+
+				if (substr($excluded_file_pattern, strlen($excluded_file_pattern) - 1,
+						strlen($excluded_file_pattern)) == "\r") {
+					$excluded_file_pattern = substr($excluded_file_pattern, 0, strlen($excluded_file_pattern) - 1);
+				}
+
+				if ($file['path'] == "/") {
+					$needle = "/";
+				} else {
+					$needle = "/" . $file['path'];
+				}
+				//echo $needle."---".$excluded_file_pattern."---\n";
+
+				if (@preg_match("/(^|^\/)" . $excluded_file_pattern . "/i", $needle)) {
+					return $excluded_file_pattern;
+				}
+			}
+		}
+
+		return false;
+	}
+
+	public function store_file($file, $storage = 'start_filesystem')
+	{
+		$this->logger->debug(sprintf("Storing %s in the backup list", $file['path']));
+
+		if (!isset($file['size'])) {
+			$file['size'] = 0;
+		}
+		if (!isset($file['visibility'])) {
+			$file['visibility'] = "private";
+		}
+
+		$csv_filename = str_replace('"', '""', $file['path']);
+
+		$line = '"' . ($csv_filename) . '","' . $file['timestamp'] . '","' . $file['size'] . '","' . $file['visibility'] . '","' . $storage . '"' . PHP_EOL;
+
+		$this->last_logged_file = $file['path'];
+
+		if ($file['type'] == "dir") {
+			try {
+				$this->tmp_filesystem_append->write($this->get_temp_dir_handler(), $file['path'] . "\n");
+			} catch (Exception $e) {
+				$this->logger->error($e->getMessage());
+			}
+		}
+
+		if ($this->get_diff_timestamp_start()) {
+			if ($file['type'] != "file" && $response = $this->check_file_diff_time($file)) {
+				$this->logger->info(sprintf("Directory %s archiving skipped on differential backup %s", $file['path'],
+					$response), array(
+					"FILESYSTEM SCAN",
+					"DIR DIFF"
+				));
+
+				return false;
+			}
+		}
+
+		try {
+			if (!$this->tmp_filesystem_append->has($this->get_included_files_handler())) {
+				//adding fix for UTF-8 CSV preview
+				$start_line = "\xEF\xBB\xBF" . '"Filename","Timestamp","Size","Visibility","Storage"' . PHP_EOL;
+				$this->tmp_filesystem_append->write($this->get_included_files_handler(), $start_line);
+			}
+
+			$this->tmp_filesystem_append->write($this->get_included_files_handler(), $line);
+
+		} catch (Exception $e) {
+
+			$this->logger->error($e->getMessage());
+		}
+
+		return true;
+	}
+
+	public function get_fileystem_handler()
+	{
+		return $this;
+	}
+
+	public function get_filesystem($system = "")
+	{
+		if ($system == "storage_filesystem_append") {
+			return $this->storage_filesystem_append;
+		} elseif ($system == "tmp_filesystem_append") {
+			return $this->tmp_filesystem_append;
+		} elseif ($system == "tmp_filesystem") {
+			return $this->tmp_filesystem;
+		} elseif ($system == "storage_filesystem") {
+			return $this->storage_filesystem;
+		} else {
+			return $this->start_filesystem;
+		}
+	}
+
+	public function get_adapter($system)
+	{
+		if ($system == "tmp_filesystem") {
+			return $this->tmp_adapter;
+		} elseif ($system == "storage_filesystem") {
+			return $this->storage_adapter;
+		} else {
+			return $this->start_adapter;
+		}
+	}
+
+	/**
+	 * File scan finished
+	 * Method called when file scan is finished
+	 *
+	 * @return bool
+	 */
+	private function scan_finished()
+	{
+		if ($this->tmp_filesystem_append->has($this->get_temp_dir_handler()) &&
+			$this->tmp_filesystem_append->getSize($this->get_temp_dir_handler())) {
+			return false;
+		}
+
+		if ($this->tmp_filesystem->has($this->get_temp_dir_handler())) {
+			$this->tmp_filesystem->delete($this->get_temp_dir_handler());
+		}
+
+		$this->logger->debug(sprintf(("File scan finished")));
+
+		return true;
+	}
+
+	/**
+	 * Calculate bytes from MB value
+	 *
+	 * @param int $mb_size
+	 *
+	 * @return float|int
+	 */
+	private function calc_to_bytes($mb_size)
+	{
+		return $mb_size * (1024 * 1024);
+	}
 
 }