API Demo

<?php
namespace App\Shared\Services;

use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;
use Exception;

class DirectusService
{
    private Client $httpClient;
    private string $baseUrl;
    private ?string $accessToken = null;
    private array $config;

    public function __construct()
    {
        $this->config = [
            'base_url' => $_ENV['DIRECTUS_URL'] ?? 'http://localhost:8055',
            'email' => $_ENV['DIRECTUS_EMAIL'] ?? '',
            'password' => $_ENV['DIRECTUS_PASSWORD'] ?? '',
            'timeout' => 30,
            'connect_timeout' => 10
        ];

        $this->baseUrl = rtrim($this->config['base_url'], '/');
        
        $this->httpClient = new Client([
            'base_uri' => $this->baseUrl,
            'timeout' => $this->config['timeout'],
            'connect_timeout' => $this->config['connect_timeout'],
            'headers' => [
                'Content-Type' => 'application/json',
                'Accept' => 'application/json'
            ]
        ]);
    }

    /**
     * Authenticate and get access token
     */
    public function authenticate(): bool
    {
        try {
            $response = $this->httpClient->post('/auth/login', [
                'json' => [
                    'email' => $this->config['email'],
                    'password' => $this->config['password']
                ]
            ]);

            $data = json_decode($response->getBody(), true);
            
            if (isset($data['data']['access_token'])) {
                $this->accessToken = $data['data']['access_token'];
                return true;
            }

            return false;
        } catch (RequestException $e) {
            error_log('Directus authentication failed: ' . $e->getMessage());
            return false;
        }
    }

    /**
     * Get all collections
     */
    public function getCollections(): array
    {
        try {
            $response = $this->makeRequest('/collections', [], 'GET');
            return $response['data'] ?? [];
        } catch (Exception $e) {
            error_log('Failed to get collections: ' . $e->getMessage());
            return [];
        }
    }

    /**
     * Get items from a collection
     */
    public function getItems(string $collection, array $params = []): array
    {
        try {
            $queryString = !empty($params) ? '?' . http_build_query($params) : '';
            $response = $this->makeRequest("/items/{$collection}{$queryString}", [], 'GET');
            return $response['data'] ?? [];
        } catch (Exception $e) {
            error_log("Failed to get items from {$collection}: " . $e->getMessage());
            return [];
        }
    }
}

<?php
namespace App\Backend\Controllers;

use App\Backend\Core\BaseController;
use App\Shared\Services\DirectusService;
use Exception;

class ApiController extends BaseController
{
    private DirectusService $directusService;

    public function __construct()
    {
        parent::__construct();
        $this->directusService = new DirectusService();
    }

    /**
     * Get all collections
     * GET /api/collections
     */
    public function collections(): void
    {
        try {
            $collections = $this->directusService->getCollections();
            
            $this->response->json([
                'success' => true,
                'data' => $collections,
                'meta' => [
                    'total' => count($collections),
                    'timestamp' => date('c')
                ]
            ]);
        } catch (Exception $e) {
            $this->response->json([
                'success' => false,
                'error' => 'Failed to fetch collections',
                'message' => $e->getMessage()
            ], 500);
        }
    }

    /**
     * Get items from collection
     * GET /api/items/{collection}
     */
    public function getItems(string $collection): void
    {
        try {
            $params = $this->request->getQueryParams();
            
            // Parse common query parameters
            $filters = [
                'limit' => $params['limit'] ?? 50,
                'offset' => $params['offset'] ?? 0,
                'sort' => $params['sort'] ?? null,
                'filter' => $params['filter'] ?? null,
                'fields' => $params['fields'] ?? '*'
            ];

            $items = $this->directusService->getItems($collection, array_filter($filters));

            $this->response->json([
                'success' => true,
                'data' => $items,
                'meta' => [
                    'collection' => $collection,
                    'count' => count($items),
                    'filters' => $filters,
                    'timestamp' => date('c')
                ]
            ]);
        } catch (Exception $e) {
            $this->response->json([
                'success' => false,
                'error' => "Failed to fetch items from {$collection}",
                'message' => $e->getMessage()
            ], 500);
        }
    }
}

<?php
namespace App\Frontend\Controllers;

use App\Backend\Core\BaseController;
use App\Shared\Services\DirectusService;

class ProductController extends BaseController
{
    private DirectusService $directus;

    public function __construct()
    {
        parent::__construct();
        $this->directus = new DirectusService();
    }

    /**
     * Display product listing page
     */
    public function index()
    {
        // Get products from Directus
        $products = $this->directus->getItems('products', [
            'limit' => 12,
            'sort' => '-date_created',
            'filter' => ['status' => 'published'],
            'fields' => 'id,name,description,price,image,category.name'
        ]);

        // Get product categories
        $categories = $this->directus->getItems('categories', [
            'sort' => 'name',
            'fields' => 'id,name,slug'
        ]);

        return $this->view->render('products/index', [
            'title' => 'Our Products',
            'products' => $products,
            'categories' => $categories,
            'total_products' => count($products)
        ]);
    }

    /**
     * Display single product
     */
    public function show(string $id)
    {
        // Get product with related data
        $product = $this->directus->getItem('products', $id);

        if (!$product) {
            return $this->response->redirect(route('products.index'), 404);
        }

        // Get related products
        $relatedProducts = $this->directus->getItems('products', [
            'limit' => 4,
            'filter' => [
                'category' => $product['category'],
                'id' => ['_neq' => $id]
            ]
        ]);

        return $this->view->render('products/show', [
            'title' => $product['name'],
            'product' => $product,
            'related_products' => $relatedProducts
        ]);
    }
}