GdaemonTaskRepository::addCmd() - Code Metrics - Inspection of "Update repositories. Add nullable server_id in gda..." - et-nik/gameap - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — develop ( e53634...2c9913 )

by Nikita
created 2019-10-06 22:59 UTC
GdaemonTaskRepository::addCmd() A

↳ Parent: GdaemonTaskRepository
Complexity

Conditions	1
Paths	1
Size

Total Lines	8
Code Lines	6
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	0
CRAP Score	2
Importance

Changes
Metric	Value
eloc	6
c	0
b	0
f	0
dl	0
loc	8
ccs	0
cts	1
cp	0
rs	10
cc	1
nc	1
nop	3
crap	2
<?php

namespace Gameap\Repositories;

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

/**
 * Class GdaemonTaskRepository
*/
class GdaemonTaskRepository extends Repository
{
    public function __construct(GdaemonTask $gdaemonTask)
    {
        $this->model = $gdaemonTask;
    }
    
    public function getAll($perPage = 20)
    {
        $gdaemonTasks = GdaemonTask::orderBy('id', 'DESC')->paginate($perPage);
        return $gdaemonTasks;
    }

    /**
     * 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, '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;
    }

    /**
     * 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)
    {
        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})")]);
        } else if ($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)
    {
        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')
    {
        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)
    {
        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

Push — develop ( e53634...2c9913 )

GdaemonTaskRepository::addCmd() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like
