GdaemonTaskRepository::concatOutput() - Code Metrics - et-nik/gameap - Measure and Improve Code Quality continuously with Scrutinizer

GdaemonTaskRepository::concatOutput() A
last analyzed 2024-08-08 21:45 UTC

↳ Parent: GdaemonTaskRepository
Complexity

Conditions	5
Paths	4
Size

Total Lines	16
Code Lines	10
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	0
CRAP Score	30
Importance

Changes
Metric	Value
eloc	10
dl	0
loc	16
ccs	0
cts	6
cp	0
rs	9.6111
c	0
b	0
f	0
cc	5
nc	4
nop	2
crap	30
<?php

namespace Gameap\Repositories;

use Gameap\Exceptions\Repositories\GdaemonTaskRepository\EmptyServerStartCommandException;
use Gameap\Exceptions\Repositories\GdaemonTaskRepository\GdaemonTaskRepositoryException;
use Gameap\Exceptions\Repositories\GdaemonTaskRepository\InvalidServerStartCommandException;
use Gameap\Exceptions\Repositories\RecordExistExceptions;
use Gameap\Models\GdaemonTask;
use Gameap\Models\Server;
use Illuminate\Support\Facades\DB;
use PDO;

class GdaemonTaskRepository extends Repository
{
    public function __construct(GdaemonTask $gdaemonTask)
    {
        $this->model = $gdaemonTask;
    }

    public function getAll($perPage = 20)
    {
        return GdaemonTask::orderBy('id', 'DESC')->paginate($perPage);
    }

    /**
     * Create new starting of game server task
     *
     * @param Server $server
     * @param int $runAftId
     * @return int Gdaemon Task ID
     *
     * @throws RecordExistExceptions
     * @throws InvalidServerStartCommandException
     * @throws EmptyServerStartCommandException
     */
    public function addServerStart(Server $server, int $runAftId = 0)
    {
        $this->workingTaskNotExistOrFail($server, GdaemonTask::TASK_SERVER_START, 'Server start task is already exists');
        $this->serverCommandCorrectOrFail($server);

        return GdaemonTask::create([
            'run_aft_id'          => $runAftId,
            'dedicated_server_id' => $server->ds_id,
            'server_id'           => $server->id,
            'task'                => GdaemonTask::TASK_SERVER_START,
        ])->id;
    }

    /**
     * Create new stopping of game server task
     *
     * @param Server $server
     * @param int $runAftId
     * @return int Gdaemon Task ID
     *
     * @throws RecordExistExceptions
     */
    public function addServerStop(Server $server, int $runAftId = 0)
    {
        $this->workingTaskNotExistOrFail($server, GdaemonTask::TASK_SERVER_STOP, 'Server stop task is already exists');

        return GdaemonTask::create([
            'run_aft_id'          => $runAftId,
            'dedicated_server_id' => $server->ds_id,
            'server_id'           => $server->id,
            'task'                => GdaemonTask::TASK_SERVER_STOP,
        ])->id;
    }

    /**
     * @param Server $server
     * @param int    $runAftId
     *
     * @return int Gdaemon Task ID
     *
     * @throws RecordExistExceptions
     * @throws InvalidServerStartCommandException
     * @throws EmptyServerStartCommandException
     */
    public function addServerRestart(Server $server, int $runAftId = 0)
    {
        $this->workingTaskNotExistOrFail($server, GdaemonTask::TASK_SERVER_RESTART, 'Server restart task is already exists');
        $this->serverCommandCorrectOrFail($server);

        return GdaemonTask::create([
            'run_aft_id'          => $runAftId,
            'dedicated_server_id' => $server->ds_id,
            'server_id'           => $server->id,
            'task'                => GdaemonTask::TASK_SERVER_RESTART,
        ])->id;
    }

    /**
     * @param Server $server
     * @param int    $runAftId
     *
     * @return int Gdaemon Task ID
     *
     * @throws RecordExistExceptions
     */
    public function addServerUpdate(Server $server, int $runAftId = 0)
    {
        $this->workingTaskNotExistOrFail(
            $server,
            [GdaemonTask::TASK_SERVER_UPDATE, GdaemonTask::TASK_SERVER_INSTALL],
            'Server update/install task is already exists'
        );
        
        return GdaemonTask::create([
            'run_aft_id'          => $runAftId,
            'dedicated_server_id' => $server->ds_id,
            'server_id'           => $server->id,
            'task'                => GdaemonTask::TASK_SERVER_UPDATE,
        ])->id;
    }

    public function addServerInstall(Server $server, int $runAftId = 0)
    {
        $this->workingTaskNotExistOrFail(
            $server,
            [GdaemonTask::TASK_SERVER_UPDATE, GdaemonTask::TASK_SERVER_INSTALL],
            'Server update/install task is already exists'
        );

        return GdaemonTask::create([
            'run_aft_id'          => $runAftId,
            'dedicated_server_id' => $server->ds_id,
            'server_id'           => $server->id,
            'task'                => GdaemonTask::TASK_SERVER_INSTALL,
        ])->id;
    }

    /**
     * Remove server files
     *
     * @param Server $server
     * @param int    $runAftId
     * @return int Gdaemon Task ID
     *
     * @throws RecordExistExceptions
     */
    public function addServerDelete(Server $server, int $runAftId = 0)
    {
        $this->workingTaskNotExistOrFail($server, GdaemonTask::TASK_SERVER_DELETE, 'Server delete task is already exists');
        
        return GdaemonTask::create([
            'run_aft_id'          => $runAftId,
            'dedicated_server_id' => $server->ds_id,
            'server_id'           => $server->id,
            'task'                => GdaemonTask::TASK_SERVER_DELETE,
        ])->id;
    }

    /**
     * @param $cmd
     * @param $dedicatedServerId
     * @param int $runAftId
     * @return mixed
     */
    public function addCmd($cmd, $dedicatedServerId, int $runAftId = 0)
    {
        return GdaemonTask::create([
            'run_aft_id'          => $runAftId,
            'dedicated_server_id' => $dedicatedServerId,
            'task'                => GdaemonTask::TASK_CMD_EXEC,
            'cmd'                 => $cmd,
        ])->id;
    }

    /**
     * @param int $serverId
     * @param string|array $task
     * @param string|array $status
     *
     * @return mixed
     */
    public function getTasks(int $serverId, $task, $status)
    {
        if (is_array($task)) {
            $taskQuery = GdaemonTask::whereIn('task', $task)->where([['server_id', '=', $serverId]]);
        } else {
            $taskQuery = GdaemonTask::where([
                ['task', '=', $task],
                ['server_id', '=', $serverId],
            ]);
        }

        $taskQuery = is_array($status)
            ? $taskQuery->whereIn('status', $status)
            : $taskQuery->where('status', '=', $status);

        return $taskQuery->get();
    }

    /**
     * Get working or waiting task id. Return 0 if task is not one
     *
     * @param int $serverId
     * @param $task
     * @return int
     */
    public function getOneWorkingTaskId(int $serverId, $task)
    {
        $tasks = $this->getTasks($serverId, $task, [GdaemonTask::STATUS_WAITING, GdaemonTask::STATUS_WORKING]);

        return (count($tasks) === 1)
            ? $tasks->first()->id
            : 0;
    }

    /**
     * @param GdaemonTask $gdaemonTask
     * @param string $output
     */
    public function concatOutput(GdaemonTask $gdaemonTask, string $output): void
    {
        if (empty($output)) {
            return;
        }

        $qoutedOutput = DB::connection()->getPdo()->quote($output);

        $dbDriver = DB::connection()->getPDO()->getAttribute(PDO::ATTR_DRIVER_NAME);

        if ($dbDriver === 'mysql') {
            $gdaemonTask->update(['output' => DB::raw("CONCAT(IFNULL(output,''), {$qoutedOutput})")]);
        } elseif ($dbDriver === 'sqlite' || $dbDriver === 'pgsql') {
            $gdaemonTask->update(['output' => DB::raw("COALESCE(output, '') || {$qoutedOutput}")]);
        } else {
            $gdaemonTask->update(['output' => $gdaemonTask->output . $output]);
        }
    }

    /**
     * @param GdaemonTask $gdaemonTask
     *
     * @throws GdaemonTaskRepositoryException
     */
    public function cancel(GdaemonTask $gdaemonTask): void
    {
        if ($gdaemonTask->status != GdaemonTask::STATUS_WAITING) {
            throw new GdaemonTaskRepositoryException(__('gdaemon_tasks.cancel_fail_cannot_be_canceled'));
            throw new GdaemonTaskRepositoryException(/** @scrutinizer ignore-type */ __('gdaemon_tasks.cancel_fail_cannot_be_canceled'));
        }

        $gdaemonTask->status = GdaemonTask::STATUS_CANCELED;
        $gdaemonTask->save();
    }

    /**
     * @param Server $server
     * @param string|array $task task name
     * @param string $failMsg Failure message
     *
     * @throws RecordExistExceptions
     */
    private function workingTaskNotExistOrFail(Server $server, $task, $failMsg = 'Task is already exists'): void
    {
        if (is_array($task)) {
            $taskQuery = GdaemonTask::whereIn('task', $task)->where([['server_id', '=', $server->id]]);
        } else {
            $taskQuery = GdaemonTask::where([
                ['task', '=', $task],
                ['server_id', '=', $server->id],
                ['dedicated_server_id', '=', $server->ds_id],
            ]);
        }

        $taskExist = $taskQuery->whereIn('status', [
            GdaemonTask::STATUS_WAITING,
            GdaemonTask::STATUS_WORKING,
        ])->exists();

        if ($taskExist) {
            throw new RecordExistExceptions($failMsg);
        }
    }

    /**
     * @param Server $server
     *
     * @throws InvalidServerStartCommandException
     * @throws EmptyServerStartCommandException
     */
    private function serverCommandCorrectOrFail(Server $server): void
    {
        if (empty($server->start_command)) {
            throw new EmptyServerStartCommandException(__('gdaemon_tasks.empty_server_start_command'));
            throw new EmptyServerStartCommandException(/** @scrutinizer ignore-type */ __('gdaemon_tasks.empty_server_start_command'));
        }
    }
}

et-nik / gameap

GdaemonTaskRepository::concatOutput() A last analyzed 2024-08-08 21:45 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

GdaemonTaskRepository::concatOutput() A
last analyzed 2024-08-08 21:45 UTC
