misc_pterodactyl-panel/app/Jobs/Schedule/RunTaskJob.php

132 lines
3.7 KiB
PHP
Raw Normal View History

2017-09-17 04:10:00 +00:00
<?php
namespace Pterodactyl\Jobs\Schedule;
use Exception;
use Pterodactyl\Jobs\Job;
2020-10-06 03:46:41 +00:00
use Carbon\CarbonImmutable;
use Pterodactyl\Models\Task;
2017-09-17 04:10:00 +00:00
use InvalidArgumentException;
use Pterodactyl\Models\Schedule;
2017-09-17 04:10:00 +00:00
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\DispatchesJobs;
use Pterodactyl\Services\Backups\InitiateBackupService;
use Pterodactyl\Repositories\Wings\DaemonPowerRepository;
use Pterodactyl\Repositories\Wings\DaemonCommandRepository;
2017-09-17 04:10:00 +00:00
class RunTaskJob extends Job implements ShouldQueue
{
2021-01-23 20:33:34 +00:00
use DispatchesJobs;
use InteractsWithQueue;
use SerializesModels;
2017-09-17 04:10:00 +00:00
/**
2020-10-06 03:46:41 +00:00
* @var \Pterodactyl\Models\Task
2017-09-17 04:10:00 +00:00
*/
public $task;
2021-04-24 22:06:21 +00:00
/**
* @var bool
*/
public $now;
2017-09-17 04:10:00 +00:00
/**
* RunTaskJob constructor.
*/
2021-04-24 22:06:21 +00:00
public function __construct(Task $task, $now = false)
2017-09-17 04:10:00 +00:00
{
$this->queue = config('pterodactyl.queues.standard');
2017-09-17 04:10:00 +00:00
$this->task = $task;
2021-04-24 22:06:21 +00:00
$this->now = $now;
2017-09-17 04:10:00 +00:00
}
/**
* Run the job and send actions to the daemon running the server.
*
* @throws \Throwable
2017-09-17 04:10:00 +00:00
*/
public function handle(
DaemonCommandRepository $commandRepository,
InitiateBackupService $backupService,
DaemonPowerRepository $powerRepository
2017-09-17 04:10:00 +00:00
) {
2021-04-24 22:06:21 +00:00
// Do not process a task that is not set to active, unless it's been trigger by the run now API.
if ($this->task->schedule->is_active && !$this->now) {
$this->markTaskNotQueued();
$this->markScheduleComplete();
return;
}
2020-10-06 03:46:41 +00:00
$server = $this->task->server;
2018-05-13 14:50:56 +00:00
// Perform the provided task against the daemon.
2020-10-06 03:46:41 +00:00
switch ($this->task->action) {
2017-09-17 04:10:00 +00:00
case 'power':
2020-10-06 03:46:41 +00:00
$powerRepository->setServer($server)->send($this->task->payload);
2017-09-17 04:10:00 +00:00
break;
case 'command':
2020-10-06 03:46:41 +00:00
$commandRepository->setServer($server)->send($this->task->payload);
2017-09-17 04:10:00 +00:00
break;
case 'backup':
2020-11-09 23:35:57 +00:00
$backupService->setIgnoredFiles(explode(PHP_EOL, $this->task->payload))->handle($server, null, true);
break;
2017-09-17 04:10:00 +00:00
default:
throw new InvalidArgumentException('Cannot run a task that points to a non-existent action.');
2017-09-17 04:10:00 +00:00
}
$this->markTaskNotQueued();
2020-10-06 03:46:41 +00:00
$this->queueNextTask();
2017-09-17 04:10:00 +00:00
}
/**
* Handle a failure while sending the action to the daemon or otherwise processing the job.
*/
public function failed(Exception $exception = null)
{
$this->markTaskNotQueued();
$this->markScheduleComplete();
}
/**
* Get the next task in the schedule and queue it for running after the defined period of wait time.
*/
2020-10-06 03:46:41 +00:00
private function queueNextTask()
2017-09-17 04:10:00 +00:00
{
2020-10-06 03:46:41 +00:00
/** @var \Pterodactyl\Models\Task|null $nextTask */
$nextTask = Task::query()->where('schedule_id', $this->task->schedule_id)
->where('sequence_id', $this->task->sequence_id + 1)
->first();
2017-09-17 04:10:00 +00:00
if (is_null($nextTask)) {
$this->markScheduleComplete();
return;
}
2020-10-06 03:46:41 +00:00
$nextTask->update(['is_queued' => true]);
2021-04-24 22:06:21 +00:00
$this->dispatch((new self($nextTask, $this->now))->delay($nextTask->time_offset));
2017-09-17 04:10:00 +00:00
}
/**
* Marks the parent schedule as being complete.
*/
private function markScheduleComplete()
{
2020-10-06 03:46:41 +00:00
$this->task->schedule()->update([
'is_processing' => false,
'last_run_at' => CarbonImmutable::now()->toDateTimeString(),
]);
2017-09-17 04:10:00 +00:00
}
/**
* Mark a specific task as no longer being queued.
*/
private function markTaskNotQueued()
{
2020-10-06 03:46:41 +00:00
$this->task->update(['is_queued' => false]);
2017-09-17 04:10:00 +00:00
}
}