64 lines
3.2 KiB
PHP
64 lines
3.2 KiB
PHP
<?php
|
|
|
|
namespace Modules\Automation\Http\Controllers;
|
|
|
|
use App\Http\Controllers\Controller;
|
|
use Illuminate\Http\RedirectResponse;
|
|
use Illuminate\Http\Request;
|
|
use Illuminate\View\View;
|
|
use Modules\Automation\Contracts\ActionRegistry;
|
|
use Modules\Automation\Contracts\TriggerRegistry;
|
|
use Modules\Automation\Models\Automation;
|
|
use Modules\Automation\Models\AutomationRun;
|
|
use Modules\Automation\Services\AutomationRunner;
|
|
|
|
final class AutomationController extends Controller
|
|
{
|
|
public function index(TriggerRegistry $triggers, ActionRegistry $actions): View
|
|
{
|
|
return view('automation::admin.index', ['automations' => Automation::withCount(['steps', 'runs'])->latest()->paginate(20), 'recentRuns' => AutomationRun::with('automation')->latest()->limit(15)->get(), 'triggers' => $triggers->all(), 'actions' => $actions->all()]);
|
|
}
|
|
|
|
public function store(Request $request, TriggerRegistry $triggers): RedirectResponse
|
|
{
|
|
$data = $request->validate(['name' => ['required', 'string', 'max:255'], 'description' => ['nullable', 'string'], 'trigger_type' => ['required', 'string'], 'status' => ['required', 'in:draft,active,paused'], 'next_run_at' => ['nullable', 'date'], 'trigger_config' => ['nullable', 'json']]);
|
|
abort_unless($triggers->has($data['trigger_type']), 422, 'Unknown trigger type.');
|
|
$data['trigger_config'] = filled($data['trigger_config'] ?? null) ? json_decode($data['trigger_config'], true, 512, JSON_THROW_ON_ERROR) : [];
|
|
$data['stop_on_failure'] = $request->boolean('stop_on_failure');
|
|
$data['created_by'] = $request->user()->id;
|
|
Automation::create($data);
|
|
|
|
return back()->with('status', 'Automation created.');
|
|
}
|
|
|
|
public function addStep(Request $request, Automation $automation, ActionRegistry $actions): RedirectResponse
|
|
{
|
|
$data = $request->validate(['action_type' => ['required', 'string'], 'name' => ['nullable', 'string', 'max:255'], 'configuration' => ['nullable', 'json']]);
|
|
abort_unless(array_key_exists($data['action_type'], $actions->all()), 422, 'Unknown action type.');
|
|
$automation->steps()->create(['position' => (int) $automation->steps()->max('position') + 1, 'action_type' => $data['action_type'], 'name' => $data['name'] ?? null, 'configuration' => filled($data['configuration'] ?? null) ? json_decode($data['configuration'], true, 512, JSON_THROW_ON_ERROR) : [], 'is_enabled' => true]);
|
|
|
|
return back()->with('status', 'Automation step added.');
|
|
}
|
|
|
|
public function run(Automation $automation, AutomationRunner $runner): RedirectResponse
|
|
{
|
|
$run = $runner->dispatch($automation, ['initiated_by' => request()->user()->id], 'manual');
|
|
|
|
return back()->with('status', "Automation queued as {$run->execution_id}.");
|
|
}
|
|
|
|
public function toggle(Automation $automation): RedirectResponse
|
|
{
|
|
$automation->update(['status' => $automation->status === 'active' ? 'paused' : 'active']);
|
|
|
|
return back()->with('status', 'Automation status updated.');
|
|
}
|
|
|
|
public function destroy(Automation $automation): RedirectResponse
|
|
{
|
|
$automation->delete();
|
|
|
|
return back()->with('status','Automation deleted.');
|
|
}
|
|
}
|