ladill-care/app/Http/Controllers/Care/ServiceQueueController.php

<?php

namespace App\Http\Controllers\Care;

use App\Http\Controllers\Controller;
use App\Http\Controllers\Care\Concerns\ScopesToAccount;
use App\Models\Branch;
use App\Services\Queue\QueueClient;
use Illuminate\Http\Client\RequestException;
use Illuminate\Http\RedirectResponse;
use Illuminate\Http\Request;
use Illuminate\View\View;

class ServiceQueueController extends Controller
{
    use ScopesToAccount;

    public function index(Request $request, QueueClient $queue): View|RedirectResponse
    {
        $this->authorizeAbility($request, 'service_queues.console');
        $organization = $this->organization($request);

        if (! $this->integrationEnabled($organization)) {
            return redirect()->route('care.settings')->with('error', 'Enable Ladill Queue integration in settings first.');
        }

        $owner = $this->ownerRef($request);

        try {
            $counters = $queue->counters($owner);
        } catch (RequestException $e) {
            if ($queue->configured() && $e->response?->status() === 403) {
                try {
                    $queue->syncIntegration($owner, true);
                    $counters = $queue->counters($owner);
                } catch (RequestException) {
                    return redirect()->route('care.settings')->with('error', 'Ladill Queue integration is not enabled. Save settings with Queue integration checked, and enable Care in Queue settings.');
                }
            } else {
                return redirect()->route('care.settings')->with('error', 'Could not reach Ladill Queue. Check API keys and enable integration in Queue settings.');
            }
        }

        return view('care.service-queues.index', compact('counters', 'organization'));
    }

    public function console(Request $request, string $counterUuid, QueueClient $queue): View|RedirectResponse
    {
        $this->authorizeAbility($request, 'service_queues.console');
        $organization = $this->organization($request);
        $owner = $this->ownerRef($request);

        if (! $this->integrationEnabled($organization)) {
            return redirect()->route('care.settings');
        }

        try {
            $state = $queue->console($owner, $counterUuid);
        } catch (RequestException) {
            return redirect()->route('care.service-queues.index')->with('error', 'Counter console unavailable.');
        }

        return view('care.service-queues.console', [
            'state' => $state,
            'counterUuid' => $counterUuid,
            'organization' => $organization,
        ]);
    }

    public function action(Request $request, string $counterUuid, QueueClient $queue): RedirectResponse
    {
        $this->authorizeAbility($request, 'service_queues.console');
        $owner = $this->ownerRef($request);

        $validated = $request->validate([
            'action' => ['required', 'string'],
            'queue_uuid' => ['nullable', 'uuid'],
            'ticket_uuid' => ['nullable', 'uuid'],
            'to_queue_uuid' => ['nullable', 'uuid'],
            'reason' => ['nullable', 'string', 'max:500'],
        ]);

        try {
            $result = $queue->consoleAction($owner, $counterUuid, $validated);
        } catch (RequestException $e) {
            $message = $e->response?->json('message')
                ?: $e->response?->json('error')
                ?: 'Queue action failed. Try again.';

            return back()->with('error', is_string($message) ? $message : 'Queue action failed. Try again.');
        }

        $success = match ($validated['action']) {
            'transfer' => sprintf(
                'Handed off %s to %s. Ticket number unchanged.',
                (string) ($result['ticket_number'] ?? 'ticket'),
                (string) data_get($result, 'queue.name', 'next queue'),
            ),
            'call_next' => ! empty($result['ticket_number'])
                ? "Called {$result['ticket_number']}."
                : 'No tickets waiting in that queue.',
            'available' => 'Counter marked available.',
            'offline' => 'Counter went offline.',
            default => 'Queue updated.',
        };

        return back()->with('success', $success);
    }

    protected function integrationEnabled(\App\Models\Organization $organization): bool
    {
        return (bool) data_get($organization->settings, 'queue_integration_enabled', false);
    }
}