oskarb/Scheduler
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add generic api schema and scripts model

Browse Source
This commit is contained in:
Oskar-Mikael
2025-08-30 18:20:24 +02:00
parent 774d1cf45f
commit f6993d463d
18 changed files with 493 additions and 192 deletions
Download Patch File Download Diff File Expand all files Collapse all files

82
app/Bots/GenericApi.php Normal file
View File

@@ -0,0 +1,82 @@
<?php
namespace App\Bots;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\GuzzleException;
use Illuminate\Support\Facades\Log;
class GenericApi implements BotContract
{
protected array $config;
protected Client $client;
public function __construct(array $config = [])
{
$this->config = $config;
}
public function run(): void
{
try {
$this->client = new Client();
$options = [];
if (!empty($this->config['headers'])) {
$options['headers'] = json_decode($this->config['headers'], true);
}
if (!empty($this->config['body'])) {
$options['json'] = json_decode($this->config['body'], true);
}
$this->client->request(
$this->config['method'] ?? 'GET',
$this->config['url'],
$options
);
} catch (GuzzleException $e) {
Log::error("Call to {$this->config['url']} failed" . $e->getMessage());
}
}
public static function configSchema(): array
{
return [
'url' => [
'type' => 'string',
'label' => 'API URL',
'rules' => [
'required',
'url',
]
],
'method' => [
'type' => 'string',
'label' => 'HTTP Method',
'rules' => [
'required',
'in:GET,POST,PUT,DELETE,PATCH',
]
],
'headers' => [
'type' => 'json',
'label' => 'Request Headers (JSON)',
'rules' => [
'nullable',
'json',
]
],
'body' => [
'type' => 'json',
'label' => 'Request Body (JSON)',
'rules' => [
'nullable',
'json',
]
],
];
}
}

70
app/Bots/Mattermost.php
View File

@@ -4,6 +4,9 @@ namespace App\Bots;
use App\Bots\BotContract;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\ClientException;
use GuzzleHttp\Exception\GuzzleException;
use GuzzleHttp\RequestOptions;
use Illuminate\Support\Facades\Log;
class Mattermost implements BotContract
@@ -25,49 +28,48 @@ class Mattermost implements BotContract
public function run(): void
{
try {
$request = new \GuzzleHttp\Psr7\Request(
$this->client->request(
$this->config['method'] ?? 'POST',
$this->config['endpoint'],
['Content-Type' => 'application/json'],
json_encode($this->config['body'] ?? [])
[
'json' => json_decode($this->config['body'] ?? '', true),
]
);
$res = $this->client->send($request);
// $res = $this->client->put('users/me/status/custom', [
// 'json' => [
// 'emoji' => 'house',
// 'text' => 'Working Home',
// 'status' => 'online',
// ]
// ]);
if ($res->getStatusCode() === 200) {
Log::info("Mattermost home status updated successfully.");
} else {
Log::error("Failed to update Mattermost status. HTTP Status: " . $res->getStatusCode());
}
} catch (\Exception $e) {
Log::error("Error updating Mattermost status: " . $e->getMessage());
} catch (GuzzleException $e) {
Log::error("Call to Mattermost failed. " . $e->getMessage());
}
}
public static function configSchema(): array
{
return [
'endpoint' => ['type' => 'string', 'label' => 'API Endpoint', 'rules' => [
'required',
'string',
'max:255',
]],
'method' => ['type' => 'string', 'label' => 'HTTP Method', 'default' => 'POST', 'rules' => [
'required',
'in:GET,POST,PUT,DELETE,PATCH',
]],
'body' => ['type' => 'array', 'label' => 'Request Body (JSON)', 'rules' => [
'nullable',
'array',
]],
'endpoint' => [
'type' => 'string',
'label' => 'API Endpoint',
'rules' => [
'required',
'string',
'max:255',
]
],
'method' => [
'type' => 'string',
'label' => 'HTTP Method',
'default' => 'POST',
'rules' => [
'required',
'in:GET,POST,PUT,DELETE,PATCH',
]
],
'body' => [
'type' => 'json',
'label' => 'Request Body (JSON)',
'rules' => [
'nullable',
'string',
'json',
]
],
];
}
}

46
app/Bots/Mattermost/RemoveStatus.php
View File

@@ -1,46 +0,0 @@
<?php
namespace App\Bots\Mattermost;
use App\Bots\BotContract;
use GuzzleHttp\Client;
use Illuminate\Support\Facades\Log;
class RemoveStatus implements BotContract
{
protected Client $client;
public function __construct(private ?array $config = [])
{
$this->client = new Client([
'base_uri' => rtrim(config('scheduler.mattermost.server_url'), '/') . '/api/v4/',
'headers' => [
'Authorization' => 'Bearer ' . config('scheduler.mattermost.access_token'),
],
]);
}
public function run(): void
{
try {
$res = $this->client->delete('users/me/status/custom');
if ($res->getStatusCode() === 200) {
Log::info("Mattermost status cleared");
} else {
Log::error("Failed to update Mattermost status. HTTP Status: " . $res->getStatusCode());
}
} catch (\Exception $e) {
Log::error("Error updating Mattermost status: " . $e->getMessage());
}
}
public static function configSchema(): array
{
return [
'endpoint' => ['type' => 'string', 'label' => 'API Endpoint'],
'method' => ['type' => 'string', 'label' => 'HTTP Method', 'default' => 'POST'],
'body' => ['type' => 'array', 'label' => 'Request Body (JSON)'],
];
}
}

54
app/Bots/Mattermost/WednesdayHomeStatus.php
View File

@@ -1,54 +0,0 @@
<?php
namespace App\Bots\Mattermost;
use App\Bots\BotContract;
use GuzzleHttp\Client;
use Illuminate\Support\Facades\Log;
class WednesdayHomeStatus implements BotContract
{
protected Client $client;
public function __construct(private ?array $config = [])
{
$this->client = new Client([
'base_uri' => rtrim(config('scheduler.mattermost.server_url'), '/') . '/api/v4/',
'headers' => [
'Authorization' => 'Bearer ' . config('scheduler.mattermost.access_token'),
'Accept' => 'application/json',
'Content-Type' => 'application/json',
],
]);
}
public function run(): void
{
try {
$res = $this->client->put('users/me/status/custom', [
'json' => [
'emoji' => 'house',
'text' => 'Working Home',
'status' => 'online',
]
]);
if ($res->getStatusCode() === 200) {
Log::info("Mattermost home status updated successfully.");
} else {
Log::error("Failed to update Mattermost status. HTTP Status: " . $res->getStatusCode());
}
} catch (\Exception $e) {
Log::error("Error updating Mattermost status: " . $e->getMessage());
}
}
public static function configSchema(): array
{
return [
'endpoint' => ['type' => 'string', 'label' => 'API Endpoint'],
'method' => ['type' => 'string', 'label' => 'HTTP Method', 'default' => 'POST'],
'body' => ['type' => 'array', 'label' => 'Request Body (JSON)'],
];
}
}

43
app/Livewire/BotsList.php
View File

@@ -2,6 +2,8 @@
namespace App\Livewire;
use App\Models\Bot;
use Jantinnerezo\LivewireAlert\Facades\LivewireAlert;
use Livewire\Component;
class BotsList extends Component
@@ -25,6 +27,47 @@ class BotsList extends Component
}
}
public function deleteBot(int $botId): void
{
$bot = \App\Models\Bot::find($botId);
if ($bot) {
LivewireAlert::title('Are you sure you want to delete ' . $bot->name . '?')
->asConfirm()
->onConfirm('confirmDelete', [$bot])
->show();
}
}
public function confirmDelete(Bot $bot): void
{
$bot->delete();
$this->bots = \App\Models\Bot::all(); // Refresh the list
flash()->success("Bot '{$bot->name}' has been deleted.");
}
public function runBot($botId)
{
$bot = \App\Models\Bot::find($botId);
if ($bot) {
LivewireAlert::title('Are you sure you want to run ' . $bot->name . '?')
->asConfirm()
->onConfirm('confirmRunBot', [$bot])
->show();
}
}
public function confirmRunBot(Bot $bot): void
{
// Dispatch the job to run the bot
$class = new $bot->class($bot->config ?? []);
$class->run();
flash()->success("Bot '{$bot->name}' is being executed.");
}
public function render()
{
return view('livewire.bots-list');

77
app/Livewire/CreateEditBot.php
View File

@@ -3,6 +3,7 @@
namespace App\Livewire;
use App\Bots\BotContract;
use App\Models\Bot;
use Cron\CronExpression;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\File;
@@ -14,6 +15,8 @@ use Lorisleiva\CronTranslator\CronTranslator;
class CreateEditBot extends Component
{
public ?Bot $bot = null;
public string $name = '';
public string $class = '';
@@ -24,7 +27,7 @@ class CreateEditBot extends Component
public string $cron_text = 'Every minute';
public string $config = '{}';
public array $config = [];
public array $classList = [];
@@ -32,17 +35,18 @@ class CreateEditBot extends Component
public string $routeName = '';
public function mount(?int $bot = null)
public function mount()
{
$this->routeName = URL::current() === route('bots.create') ? 'Create Bot' : 'Edit Bot';
$bot = \App\Models\Bot::find($bot);
if ($bot) {
$this->name = $bot->name;
$this->class = $bot->class;
$this->schedule = $bot->schedule;
$this->enabled = $bot->enabled;
$this->cron_text = \Lorisleiva\CronTranslator\CronTranslator::translate($bot->schedule);
if ($this->bot) {
$this->name = $this->bot->name;
$this->class = $this->bot->class;
$this->config = $this->bot->config ?? [];
$this->schedule = $this->bot->schedule;
$this->enabled = $this->bot->enabled;
$this->cron_text = CronTranslator::translate($this->bot->schedule);
$this->configSchema = $this->bot->class::configSchema();
}
$basePath = $basePath ?? app_path('Bots');
@@ -60,7 +64,7 @@ class CreateEditBot extends Component
? $class::label()
: class_basename($class);
$this->classList[$label] = $class;
$this->classList[$class] = $label;
}
}
}
@@ -119,32 +123,31 @@ class CreateEditBot extends Component
return;
}
if (URL::current() !== route('bots.create')) {
$bot = \App\Models\Bot::where('name', $this->name)->first();
if ($bot) {
$bot->update([
'name' => $this->name,
'class' => $this->class,
'enabled' => $this->enabled,
'schedule' => $this->schedule,
]);
if ($this->routeName !== 'Create Bot') {
$this->bot->update([
'name' => $this->name,
'class' => $this->class,
'enabled' => $this->enabled,
'schedule' => $this->schedule,
'config' => $this->config,
]);
flash()->success('Bot updated successfully.');
flash()->success('Bot updated successfully.');
return;
}
return;
} else {
\App\Models\Bot::create([
'name' => $this->name,
'class' => $this->class,
'enabled' => $this->enabled,
'schedule' => $this->schedule,
'config' => $this->config,
]);
}
flash()->success('Bot created successfully.');
$this->reset(['name', 'namespace', 'class', 'enabled', 'schedule']);
$this->reset(['name', 'class', 'enabled', 'schedule', 'config', 'configSchema']);
}
public function updatedSchedule($value)
@@ -157,6 +160,34 @@ class CreateEditBot extends Component
}
}
protected function validationAttributes(): array
{
$attributes = [];
foreach ($this->configSchema as $field => $meta) {
$attributes["config.$field"] = $meta['label'];
}
$attributes['name'] = 'Bot Name';
$attributes['schedule'] = 'Schedule';
$attributes['class'] = 'Bot Schema';
return $attributes;
}
public function prettify(string $field): void
{
if (isset($this->config[$field])) {
if (json_validate($this->config[$field])) {
$decoded = json_decode($this->config[$field], true);
$this->config[$field] = json_encode($decoded, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES);
$this->resetErrorBag("config.$field");
} else {
$this->addError("config.$field", 'Invalid JSON format.');
}
}
}
public function render()
{
return view('livewire.create-edit-bot');

12
app/Models/Bot.php
View File

@@ -31,9 +31,17 @@ class Bot extends Model
);
}
public function cronToHuman(): Attribute
public function cronToHuman(): Attribute
{
return Attribute::make(
get: fn () => CronTranslator::translate($this->schedule));
get: fn() => CronTranslator::translate($this->schedule)
);
}
public function className(): Attribute
{
return Attribute::make(
get: fn() => class_basename($this->class)
);
}
}

10
app/Models/Scripts.php Normal file
View File

@@ -0,0 +1,10 @@
<?php
namespace App\Models;
use Illuminate\Database\Eloquent\Model;
class Scripts extends Model
{
//
}