+global\Xcloner_Scheduler::_xcloner_scheduler_callback()

Complexity

Conditions	23
Paths	5764

Size

Total Lines

170

Duplication

Lines	2
Ratio	1.18 %

Importance

Changes

0

<?php
	private function _xcloner_scheduler_callback( $id, $schedule ) {
		set_time_limit( 0 );

		$xcloner = new XCloner();
		$xcloner->init();
		$this->set_xcloner_container( $xcloner );

		#$hash = $this->xcloner_settings->get_hash();
		#$this->get_xcloner_container()->get_xcloner_settings()->set_hash($hash);

		//$this->xcloner_settings 		= $this->get_xcloner_container()->get_xcloner_settings();		
		$this->xcloner_file_system    = $this->get_xcloner_container()->get_xcloner_filesystem();
		$this->xcloner_encryption    = $this->get_xcloner_container()->get_xcloner_encryption();
		$this->xcloner_database       = $this->get_xcloner_container()->get_xcloner_database();
		$this->archive_system         = $this->get_xcloner_container()->get_archive_system();
		$this->logger                 = $this->get_xcloner_container()->get_xcloner_logger()->withName( "xcloner_scheduler" );
		$this->xcloner_remote_storage = $this->get_xcloner_container()->get_xcloner_remote_storage();

		$this->logger->info( sprintf( "New schedule hash is %s", $this->xcloner_settings->get_hash() ) );

		if ( isset( $schedule['backup_params']->diff_start_date ) && $schedule['backup_params']->diff_start_date ) {
			$this->xcloner_file_system->set_diff_timestamp_start( $schedule['backup_params']->diff_start_date );
		}

		if ( $schedule['recurrence'] == "single" ) {
			$this->disable_single_cron( $schedule['id'] );
		}

		if ( ! $schedule ) {
			$this->logger->info( sprintf( "Could not load schedule with id'%s'", $id ), array( "CRON" ) );

			return;
		}

		//echo $this->get_xcloner_container()->get_xcloner_settings()->get_hash(); exit;

		$this->update_hash( $schedule['id'], $this->xcloner_settings->get_hash() );

		$this->logger->info( sprintf( "Starting cron schedule '%s'", $schedule['name'] ), array( "CRON" ) );

		$this->xcloner_file_system->set_excluded_files( json_decode( $schedule['excluded_files'] ) );

		$init     = 1;
		$continue = 1;

		while ( $continue ) {
			$continue = $this->xcloner_file_system->start_file_recursion( $init );

			$init = 0;
		}

		$this->logger->info( sprintf( "File scan finished" ), array( "CRON" ) );

		$this->logger->info( sprintf( "Starting the database backup" ), array( "CRON" ) );

		$init               = 1;
		$return['finished'] = 0;

$return was never initialized. Although not strictly required by PHP, it is generally a good practice to add $return = array(); before regardless.

		while ( ! $return['finished'] ) {
			$return = $this->xcloner_database->start_database_recursion( (array) json_decode( $schedule['table_params'] ), $return, $init );
			$init   = 0;
		}

		$this->logger->info( sprintf( "Database backup done" ), array( "CRON" ) );

		$this->logger->info( sprintf( "Starting file archive process" ), array( "CRON" ) );

		$init               = 0;
		$return['finished'] = 0;
		$return['extra']    = array();

		while ( ! $return['finished'] ) {
			$return = $this->archive_system->start_incremental_backup( (array) $schedule['backup_params'], $return['extra'], $init );
			$init   = 0;
		}
		$this->logger->info( sprintf( "File archive process FINISHED." ), array( "CRON" ) );

		//getting the last backup archive file
		$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();
		}

		//Updating schedule last backup archive
		$this->update_last_backup( $schedule['id'], $return['extra']['backup_parent'] );

		//Encrypting the backup archive
		$return_encrypted['finished'] = 0;

$return_encrypted was never initialized. Although not strictly required by PHP, it is generally a good practice to add $return_encrypted = array(); before regardless.

		$return_encrypted['start'] = 0;
		$return_encrypted['iv'] = '';
		$return_encrypted['target_file'] = '';
		$part = 0;
		$backup_parts = array();

		if( $schedule['backup_params']->backup_encrypt){
			$this->logger->info( sprintf( "Encrypting backup archive %s.", $return['extra']['backup_parent'] ), array( "CRON" ) );

			$backup_file = $return['extra']['backup_parent'];

			if ($this->xcloner_file_system->is_multipart($return['extra']['backup_parent'])) {
				$backup_parts = $this->xcloner_file_system->get_multipart_files($return['extra']['backup_parent']);
				$backup_file = $backup_parts[$part];
			}

			while ( ! $return_encrypted['finished'] ) {
				$return_encrypted = $this->xcloner_encryption->encrypt_file(
											$backup_file,
											"",
											"",
											"",
											"",
											true,
											true
				);

				if($return_encrypted['finished']) {
					++$part;

					if ($part < sizeof($backup_parts)) {
						$return_encrypted['finished'] = 0;
						$backup_file = $backup_parts[$part];
					}
				}
			}
		}

		//Sending backup to remote storage
		if ( isset( $schedule['remote_storage'] ) && $schedule['remote_storage'] && array_key_exists( $schedule['remote_storage'], $this->xcloner_remote_storage->get_available_storages() ) ) {
			$backup_file = $return['extra']['backup_parent'];

			$this->logger->info( sprintf( "Transferring backup to remote storage %s", strtoupper( $schedule['remote_storage'] ) ), array( "CRON" ) );

			if ( method_exists( $this->xcloner_remote_storage, "upload_backup_to_storage" ) ) {
				call_user_func_array( array(
					$this->xcloner_remote_storage,
					"upload_backup_to_storage"
				), array( $backup_file, $schedule['remote_storage'] ) );
			}
		}

		//Sending email notification
		if ( isset( $schedule['backup_params']->email_notification ) and $to = $schedule['backup_params']->email_notification ) {
			try {
				$from                      = "";
				$additional['lines_total'] = $return['extra']['lines_total'];

$additional was never initialized. Although not strictly required by PHP, it is generally a good practice to add $additional = array(); before regardless.

				$subject                   = sprintf( __( "%s - new backup generated %s" ), $schedule['name'], $return['extra']['backup_parent'] );

The function __ was not found. Maybe you did not declare it correctly or list all dependencies?

				$this->archive_system->send_notification( $to, $from, $subject, $return['extra']['backup_parent'], $schedule, "", $additional );

			} catch ( Exception $e ) {
				$this->logger->error( $e->getMessage() );
			}
		}

		//CHECK IF WE SHOULD DELETE BACKUP AFTER REMOTE TRANSFER IS DONE
		if ( $schedule['remote_storage'] && $this->xcloner_settings->get_xcloner_option( 'xcloner_cleanup_delete_after_remote_transfer' ) ) {
			$this->logger->info( sprintf( "Deleting %s from local storage matching rule xcloner_cleanup_delete_after_remote_transfer", $return['extra']['backup_parent'] ) );
			$this->xcloner_file_system->delete_backup_by_name( $return['extra']['backup_parent'] );

		}

		//Removing the tmp filesystem used for backup
		$this->xcloner_file_system->remove_tmp_filesystem();

		//Backup Storage Cleanup
		$this->xcloner_file_system->backup_storage_cleanup();

		//Filesystem Cleanup
		$this->xcloner_file_system->cleanup_tmp_directories();
	}