- 2.x - scripts

This commit is contained in:
Saeed Vaziry
2024-10-06 20:49:59 +02:00
parent c24b4b7333
commit 8b2338cb41
32 changed files with 936 additions and 79 deletions

View File

@ -4,7 +4,7 @@
use App\Models\NotificationChannel;
use App\Models\User;
use Illuminate\Support\Facades\Validator;
use Illuminate\Validation\Rule;
use Illuminate\Validation\ValidationException;
class AddChannel
@ -14,14 +14,12 @@ class AddChannel
*/
public function add(User $user, array $input): void
{
$this->validate($input);
$channel = new NotificationChannel([
'user_id' => $user->id,
'provider' => $input['provider'],
'label' => $input['label'],
'project_id' => isset($input['global']) && $input['global'] ? null : $user->current_project_id,
]);
$this->validateType($channel, $input);
$channel->data = $channel->provider()->createData($input);
$channel->save();
@ -43,23 +41,29 @@ public function add(User $user, array $input): void
$channel->save();
}
/**
* @throws ValidationException
*/
protected function validate(array $input): void
public static function rules(array $input): array
{
Validator::make($input, [
'provider' => 'required|in:'.implode(',', config('core.notification_channels_providers')),
$rules = [
'provider' => [
'required',
Rule::in(config('core.notification_channels_providers')),
],
'label' => 'required',
])->validate();
];
return array_merge($rules, static::providerRules($input));
}
/**
* @throws ValidationException
*/
protected function validateType(NotificationChannel $channel, array $input): void
private static function providerRules(array $input): array
{
Validator::make($input, $channel->provider()->createRules($input))
->validate();
if (! isset($input['provider'])) {
return [];
}
$notificationChannel = new NotificationChannel([
'provider' => $input['provider'],
]);
return $notificationChannel->provider()->createRules($input);
}
}

View File

@ -4,31 +4,22 @@
use App\Models\NotificationChannel;
use App\Models\User;
use Illuminate\Support\Facades\Validator;
use Illuminate\Validation\ValidationException;
class EditChannel
{
public function edit(NotificationChannel $notificationChannel, User $user, array $input): void
{
$this->validate($input);
$notificationChannel->label = $input['label'];
$notificationChannel->project_id = isset($input['global']) && $input['global'] ? null : $user->current_project_id;
$notificationChannel->fill([
'label' => $input['label'],
'project_id' => isset($input['global']) && $input['global'] ? null : $user->current_project_id,
]);
$notificationChannel->save();
}
/**
* @throws ValidationException
*/
private function validate(array $input): void
public static function rules(array $input): array
{
$rules = [
'label' => [
'required',
],
return [
'label' => 'required',
];
Validator::make($input, $rules)->validate();
}
}

View File

@ -4,29 +4,27 @@
use App\Models\Script;
use App\Models\User;
use Illuminate\Support\Facades\Validator;
class CreateScript
{
public function create(User $user, array $input): Script
{
$this->validate($input);
$script = new Script([
'user_id' => $user->id,
'name' => $input['name'],
'content' => $input['content'],
'project_id' => isset($input['global']) && $input['global'] ? null : $user->current_project_id,
]);
$script->save();
return $script;
}
private function validate(array $input): void
public static function rules(): array
{
Validator::make($input, [
return [
'name' => ['required', 'string', 'max:255'],
'content' => ['required', 'string'],
])->validate();
];
}
}

View File

@ -3,26 +3,26 @@
namespace App\Actions\Script;
use App\Models\Script;
use Illuminate\Support\Facades\Validator;
use App\Models\User;
class EditScript
{
public function edit(Script $script, array $input): Script
public function edit(Script $script, User $user, array $input): Script
{
$this->validate($input);
$script->name = $input['name'];
$script->content = $input['content'];
$script->project_id = isset($input['global']) && $input['global'] ? null : $user->current_project_id;
$script->save();
return $script;
}
private function validate(array $input): void
public static function rules(): array
{
Validator::make($input, [
return [
'name' => ['required', 'string', 'max:255'],
'content' => ['required', 'string'],
])->validate();
];
}
}

View File

@ -7,30 +7,28 @@
use App\Models\ScriptExecution;
use App\Models\Server;
use App\Models\ServerLog;
use Illuminate\Support\Facades\Validator;
use Illuminate\Validation\Rule;
class ExecuteScript
{
public function execute(Script $script, Server $server, array $input): ScriptExecution
public function execute(Script $script, array $input): ScriptExecution
{
$this->validate($server, $input);
$execution = new ScriptExecution([
'script_id' => $script->id,
'server_id' => $input['server'],
'user' => $input['user'],
'variables' => $input['variables'] ?? [],
'status' => ScriptExecutionStatus::EXECUTING,
]);
$execution->save();
dispatch(function () use ($execution, $server, $script) {
dispatch(function () use ($execution, $script) {
$content = $execution->getContent();
$log = ServerLog::make($server, 'script-'.$script->id.'-'.strtotime('now'));
$log = ServerLog::make($execution->server, 'script-'.$script->id.'-'.strtotime('now'));
$log->save();
$execution->server_log_id = $log->id;
$execution->save();
$server->os()->runScript('~/', $content, $log, $execution->user);
$execution->server->os()->runScript('~/', $content, $log, $execution->user);
$execution->status = ScriptExecutionStatus::COMPLETED;
$execution->save();
})->catch(function () use ($execution) {
@ -41,14 +39,23 @@ public function execute(Script $script, Server $server, array $input): ScriptExe
return $execution;
}
private function validate(Server $server, array $input): void
public static function rules(array $input): array
{
Validator::make($input, [
if (isset($input['server'])) {
/** @var ?Server $server */
$server = Server::query()->find($input['server']);
}
return [
'server' => [
'required',
Rule::exists('servers', 'id'),
],
'user' => [
'required',
Rule::in([
'root',
$server->ssh_user,
isset($server) ? $server?->ssh_user : null,
]),
],
'variables' => 'array',
@ -57,6 +64,6 @@ private function validate(Server $server, array $input): void
'string',
'max:255',
],
])->validate();
];
}
}