. /** * @package moodlecore * @subpackage backup-plan * @copyright 2010 onwards Eloy Lafuente (stronk7) {@link http://stronk7.com} * @license http://www.gnu.org/copyleft/gpl.html GNU GPL v3 or later */ /** * Abstract class defining the basis for one execution (backup/restore) task * * TODO: Finish phpdocs */ abstract class base_task implements checksumable, executable, loggable { protected $name; // One simple name for identification purposes protected $plan; // Plan this is part of protected $settings; // One array of base_setting elements to define this task protected $steps; // One array of base_step elements protected $built; // Flag to know if one task has been built protected $executed; // Flag to know if one task has been executed /** * Constructor - instantiates one object of this class */ public function __construct($name, $plan = null) { if (!is_null($plan) && !($plan instanceof base_plan)) { throw new base_task_exception('wrong_base_plan_specified'); } $this->name = $name; $this->plan = $plan; $this->settings = array(); $this->steps = array(); $this->built = false; $this->executed = false; if (!is_null($plan)) { // Add the task to the plan if specified $plan->add_task($this); } } public function get_name() { return $this->name; } public function get_steps() { return $this->steps; } public function get_settings() { return $this->settings; } public function get_setting($name) { // First look in task settings $result = null; foreach ($this->settings as $key => $setting) { if ($setting->get_name() == $name) { if ($result != null) { throw new base_task_exception('multiple_settings_by_name_found', $name); } else { $result = $setting; } } } if ($result) { return $result; } else { // Fallback to plan settings return $this->plan->get_setting($name); } } public function setting_exists($name) { return $this->plan->setting_exists($name); } public function get_setting_value($name) { return $this->get_setting($name)->get_value(); } public function get_courseid() { return $this->plan->get_courseid(); } public function get_basepath() { return $this->plan->get_basepath(); } public function get_taskbasepath() { return $this->get_basepath(); } public function get_logger() { return $this->plan->get_logger(); } public function log($message, $level, $a = null, $depth = null, $display = false) { backup_helper::log($message, $level, $a, $depth, $display, $this->get_logger()); } public function add_step($step) { if (! $step instanceof base_step) { throw new base_task_exception('wrong_base_step_specified'); } // link the step with the task $step->set_task($this); $this->steps[] = $step; } public function set_plan($plan) { if (! $plan instanceof base_plan) { throw new base_task_exception('wrong_base_plan_specified'); } $this->plan = $plan; $this->define_settings(); // Settings are defined when plan & task are linked } /** * Function responsible for building the steps of any task * (must set the $built property to true) */ public abstract function build(); /** * Function responsible for executing the steps of any task * (setting the $executed property to true) */ public function execute() { if (!$this->built) { throw new base_task_exception('base_task_not_built', $this->name); } if ($this->executed) { throw new base_task_exception('base_task_already_executed', $this->name); } foreach ($this->steps as $step) { $result = $step->execute(); // If step returns array, it will be forwarded to plan // (TODO: shouldn't be array but proper result object) if (is_array($result) and !empty($result)) { $this->plan->add_result($result); } } // Mark as executed if any step has been executed if (!empty($this->steps)) { $this->executed = true; } } /** * Destroy all circular references. It helps PHP 5.2 a lot! */ public function destroy() { // Before reseting anything, call destroy recursively foreach ($this->steps as $step) { $step->destroy(); } foreach ($this->settings as $setting) { $setting->destroy(); } // Everything has been destroyed recursively, now we can reset safely $this->steps = array(); $this->setting = array(); $this->plan = null; } public function is_checksum_correct($checksum) { return $this->calculate_checksum() === $checksum; } public function calculate_checksum() { // Let's do it using name and settings and steps return md5($this->name . '-' . backup_general_helper::array_checksum_recursive($this->settings) . backup_general_helper::array_checksum_recursive($this->steps)); } /** * Add the given info to the current plan's results. * * @see base_plan::add_result() * @param array $result associative array describing a result of a task/step */ public function add_result($result) { if (!is_null($this->plan)) { $this->plan->add_result($result); } else { debugging('Attempting to add a result of a task not binded with a plan', DEBUG_DEVELOPER); } } /** * Return the current plan's results * * @return array|null */ public function get_results() { if (!is_null($this->plan)) { return $this->plan->get_results(); } else { debugging('Attempting to get results of a task not binded with a plan', DEBUG_DEVELOPER); return null; } } // Protected API starts here /** * This function is invoked on activity creation in order to add all the settings * that are associated with one task. The function will, directly, inject the settings * in the task. */ protected abstract function define_settings(); protected function add_setting($setting) { if (! $setting instanceof base_setting) { throw new base_setting_exception('wrong_base_setting_specified'); } $this->settings[] = $setting; } } /* * Exception class used by all the @base_task stuff */ class base_task_exception extends moodle_exception { public function __construct($errorcode, $a=NULL, $debuginfo=null) { parent::__construct($errorcode, '', '', $a, $debuginfo); } }