repository = $repository; } /** * Create a new task for a given schedule and store it in the database. * * @throws \Pterodactyl\Exceptions\Http\HttpForbiddenException * @throws \Pterodactyl\Exceptions\Model\DataValidationException * @throws \Pterodactyl\Exceptions\Service\ServiceLimitExceededException * @throws \Illuminate\Contracts\Container\BindingResolutionException */ public function store(StoreTaskRequest $request, Server $server, Schedule $schedule): array { $limit = config('pterodactyl.client_features.schedules.per_schedule_task_limit', 10); if ($schedule->tasks()->count() >= $limit) { throw new ServiceLimitExceededException("Schedules may not have more than {$limit} tasks associated with them. Creating this task would put this schedule over the limit."); } if ($server->backup_limit === 0 && $request->action === 'backup') { throw new HttpForbiddenException("A backup task cannot be created when the server's backup limit is set to 0."); } /** @var \Pterodactyl\Models\Task|null $lastTask */ $lastTask = $schedule->tasks()->orderByDesc('sequence_id')->first(); /** @var \Pterodactyl\Models\Task $task */ $task = $this->repository->create([ 'schedule_id' => $schedule->id, 'sequence_id' => ($lastTask->sequence_id ?? 0) + 1, 'action' => $request->input('action'), 'payload' => $request->input('payload') ?? '', 'time_offset' => $request->input('time_offset'), 'continue_on_failure' => (bool) $request->input('continue_on_failure'), ]); return $this->fractal->item($task) ->transformWith(TaskTransformer::class) ->toArray(); } /** * Updates a given task for a server. * * @throws \Pterodactyl\Exceptions\Http\HttpForbiddenException * @throws \Pterodactyl\Exceptions\Model\DataValidationException * @throws \Pterodactyl\Exceptions\Repository\RecordNotFoundException * @throws \Illuminate\Contracts\Container\BindingResolutionException */ public function update(StoreTaskRequest $request, Server $server, Schedule $schedule, Task $task): array { if ($schedule->id !== $task->schedule_id || $server->id !== $schedule->server_id) { throw new NotFoundHttpException(); } if ($server->backup_limit === 0 && $request->action === 'backup') { throw new HttpForbiddenException("A backup task cannot be created when the server's backup limit is set to 0."); } $this->repository->update($task->id, [ 'action' => $request->input('action'), 'payload' => $request->input('payload') ?? '', 'time_offset' => $request->input('time_offset'), 'continue_on_failure' => (bool) $request->input('continue_on_failure'), ]); return $this->fractal->item($task->refresh()) ->transformWith(TaskTransformer::class) ->toArray(); } /** * Delete a given task for a schedule. If there are subsequent tasks stored in the database * for this schedule their sequence IDs are decremented properly. * * This uses the UpdateScheduleRequest intentionally -- there is no permission specific * to deleting a given task on a schedule, so we'll assume if you have permission to edit * a schedule that you can then remove a task from said schedule. * * @throws \Exception */ public function delete(DeleteScheduleRequest $request, Server $server, Schedule $schedule, Task $task): Response { $schedule->tasks()->where('sequence_id', '>', $task->sequence_id)->update([ 'sequence_id' => $schedule->tasks()->getConnection()->raw('(sequence_id - 1)'), ]); $task->delete(); return $this->returnNoContent(); } }