ManageSchedule.php — JetBackup – Backup, Restore & Migrate 3.1.22.4

backup / src / JetBackup / Ajax / Calls / ManageSchedule.php

backup / src / JetBackup / Ajax / Calls Last commit date

ManageSchedule.php

100 lines

1	<?php
2
3	namespace JetBackup\Ajax\Calls;
4
5	if (!defined( '__JETBACKUP__')) die('Direct access is not allowed');
6
7
8	use JetBackup\Ajax\aAjax;
9	use JetBackup\BackupJob\BackupJob;
10	use JetBackup\Exception\AjaxException;
11	use JetBackup\Exception\DBException;
12	use JetBackup\Exception\FieldsValidationException;
13	use JetBackup\JetBackup;
14	use JetBackup\Schedule\Schedule;
15	use JetBackup\UserInput\UserInput;
16	use SleekDB\Exceptions\InvalidArgumentException;
17	use SleekDB\Exceptions\IOException;
18
19	class ManageSchedule extends aAjax {
20
21	/**
22	* @return int
23	* @throws AjaxException
24	*/
25	private function _getId():int { return $this->getUserInput(JetBackup::ID_FIELD, 0, UserInput::UINT); }
26
27	/**
28	* @return string
29	* @throws AjaxException
30	*/
31	private function _getName():string { return ($this->getUserInput(Schedule::NAME, '', UserInput::STRING)); }
32
33	/**
34	* @return int
35	* @throws AjaxException
36	*/
37	private function _getType():int { return($this->getUserInput(Schedule::TYPE, 0, UserInput::UINT)); }
38
39	/**
40	* @return array\|bool\|float\|int\|mixed\|object
41	* @throws AjaxException
42	*/
43	private function _getIntervals() { return($this->getUserInput(Schedule::INTERVALS, 0, UserInput::UINT\|UserInput::ARRAY, UserInput::UINT)); }
44
45	/**
46	* @return int
47	* @throws AjaxException
48	*/
49	private function _getBackupId():int { return($this->getUserInput(Schedule::BACKUP_ID, 0, UserInput::UINT)); }
50
51	/**
52	* @return void
53	* @throws AjaxException
54	* @throws DBException
55	* @throws IOException
56	* @throws InvalidArgumentException
57	* @throws FieldsValidationException
58	*/
59	public function execute(): void {
60
61	if($this->_getId()) {
62	$schedule = new Schedule($this->_getId());
63	if(!$schedule->getId() \|\| $schedule->isHidden()) throw new AjaxException("Invalid schedule id \"%s\" provided", [$this->_getId()]);
64	} else {
65	$schedule = new Schedule();
66	$schedule->setHidden(false);
67	$schedule->setDefault(false);
68	}
69
70	if($this->isset(Schedule::NAME)) $schedule->setName($this->_getName());
71	if($this->isset(Schedule::TYPE)) $schedule->setType($this->_getType());
72	if($this->isset(Schedule::INTERVALS)) $schedule->setIntervals($this->_getIntervals());
73	if($this->isset(Schedule::BACKUP_ID)) $schedule->setBackupId($this->_getBackupId());
74
75	$schedule->validateFields();
76	$schedule->save();
77
78	$jobs = BackupJob::query()
79	->select([JetBackup::ID_FIELD])
80	->getQuery()
81	->fetch();
82
83	foreach ($jobs as $jobData) {
84	$job = new BackupJob($jobData[JetBackup::ID_FIELD]);
85
86	foreach ($job->getSchedules() as $scheduleItem) {
87	if ($scheduleItem->getId() == $schedule->getId()) {
88	// update next_run on backup job
89	$job->calculateNextRun();
90	$job->save();
91	break;
92	}
93	}
94	}
95
96	$this->setResponseMessage('Success');
97	$this->setResponseData($this->isCLI() ? $schedule->getDisplayCLI() : $schedule->getDisplay());
98
99	}
100	}