EventRepository.php

<?php

namespace App\Repositories;

use App\Models\Event;
use App\Models\User;
use Exception;
use PDO;

class EventRepository
{
    public function __construct(
        private PDO $pdo,
        private string $prefix
    ) {}

    public function selectList(): array
    {
        $stmt = $this->pdo->query('
            SELECT c.*, u.email as admin
            FROM ' . $this->prefix . 'charity_event c
            INNER JOIN ' . $this->prefix . 'user_right r ON r.id_charity_event = c.id
            INNER JOIN ' . $this->prefix . 'users u ON u.id = r.id_user
            ORDER BY c.creation_date DESC
        ');

        $stmt->setFetchMode(PDO::FETCH_CLASS, Event::class);
        return $stmt->fetchAll();
    }

    public function selectListByUser(User $user): array
    {
        $stmt = $this->pdo->prepare('
            SELECT c.* 
            FROM ' . $this->prefix . 'charity_event c
            INNER JOIN ' . $this->prefix . 'user_right ur on ur.id_charity_event = c.id
            WHERE ur.id_user = ? 
            ORDER BY c.creation_date DESC
        ');
        $stmt->setFetchMode(PDO::FETCH_CLASS, Event::class);
        $stmt->execute([$user->id]);
        return $stmt->fetchAll();
    }

    public function selectByUserAndId(User $user, int $id): ?Event
    {
        if ($user->role === "ADMIN") {
            $stmt = $this->pdo->prepare('
            SELECT c.* 
            FROM ' . $this->prefix . 'charity_event c
            WHERE c.id = ?
        ');
            $stmt->setFetchMode(PDO::FETCH_CLASS, Event::class);
            $stmt->execute([$id]);
        } else {
            $stmt = $this->pdo->prepare('
                SELECT c.* 
                FROM ' . $this->prefix . 'charity_event c
                INNER JOIN ' . $this->prefix . 'user_right ur on ur.id_charity_event = c.id
                WHERE ur.id_user = ? 
                AND c.id = ?
            ');
            $stmt->setFetchMode(PDO::FETCH_CLASS, Event::class);
            $stmt->execute([$user->id, $id]);
        }

        $event = $stmt->fetch();
        return $event ?: null;
    }

    public function selectByUserAndGuid(User $user, string $guid): ?Event
    {
        if ($user->role === "ADMIN") {
            $stmt = $this->pdo->prepare('
            SELECT c.* 
            FROM ' . $this->prefix . 'charity_event c
            WHERE c.guid = ?
        ');
            $stmt->setFetchMode(PDO::FETCH_CLASS, Event::class);
            $stmt->execute([$guid]);
        } else {
            $stmt = $this->pdo->prepare('
                SELECT c.* 
                FROM ' . $this->prefix . 'charity_event c
                INNER JOIN ' . $this->prefix . 'user_right ur on ur.id_charity_event = c.id
                WHERE ur.id_user = ? 
                AND c.guid = ?
            ');
            $stmt->setFetchMode(PDO::FETCH_CLASS, Event::class);
            $stmt->execute([$user->id, $guid]);
        }

        $event = $stmt->fetch();
        return $event ?: null;
    }

    public function selectByGuid(string $guid): ?Event
    {
        $stmt = $this->pdo->prepare('
            SELECT * 
            FROM ' . $this->prefix . 'charity_event 
            WHERE guid = ?
        ');
        $stmt->setFetchMode(PDO::FETCH_CLASS, Event::class);
        $stmt->execute([$guid]);
        $event = $stmt->fetch();
        return $event ?: null;
    }

    public function insert(string $title): Event
    {
        $this->pdo->beginTransaction();

        try {
            $guid = bin2hex(random_bytes(16));

            $stmt = $this->pdo->prepare('INSERT INTO ' . $this->prefix . 'charity_event (guid, title) VALUES (:guid, :title)');
            $stmt->execute([':guid' => $guid, ':title' => $title]);
            $id = $this->pdo->lastInsertId();

            $stmt = $this->pdo->prepare('INSERT INTO ' . $this->prefix . 'widget_donation_goal_bar (charity_event_guid) VALUES (:guid)');
            $stmt->execute([':guid' => $guid]);

            try {
                $stmt = $this->pdo->prepare('INSERT INTO ' . $this->prefix . 'widget_card (charity_event_guid, description) VALUES (:guid, "")');
                $stmt->execute([':guid' => $guid]);
            } catch (Exception $e) {
                // Table may not exist yet (migration not run) — skip silently
            }

            $this->pdo->commit();

            $event = new Event();
            $event->id = $id;
            $event->guid = $guid;
            $event->title = $title;
            return $event;
        } catch (Exception $e) {
            $this->pdo->rollBack();
            throw $e;
        }
    }

    public function update(Event $event, array $data): void
    {
        $fields = [];
        $params = [];

        if (array_key_exists('title', $data)) {
            $fields[] = 'title = ?';
            $params[] = $data['title'];
        }
        if (array_key_exists('goal', $data)) {
            $fields[] = 'goal = ?';
            $params[] = $data['goal'];
        }

        if (empty($fields)) return;

        $params[] = $event->id;
        $sql = 'UPDATE ' . $this->prefix . 'charity_event SET ' . implode(', ', $fields) . ' WHERE id = ?';
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($params);
    }

    public function delete(Event $event)
    {
        $this->pdo->beginTransaction();

        try {
            $query = 'UPDATE ' . $this->prefix . 'charity_stream
                SET charity_event_id = null
                WHERE charity_event_id = ?';
            $stmt = $this->pdo->prepare($query);
            $stmt->execute([$event->id]);

            $query = 'DELETE FROM ' . $this->prefix . 'user_right
                WHERE id_charity_event = ?';
            $stmt = $this->pdo->prepare($query);
            $stmt->execute([$event->id]);

            $query = 'DELETE FROM ' . $this->prefix . 'widget_donation_goal_bar
                WHERE charity_event_guid = ?';
            $stmt = $this->pdo->prepare($query);
            $stmt->execute([$event->guid]);

            $query = 'DELETE FROM ' . $this->prefix . 'widget_card
                WHERE charity_event_guid = ?';
            try {
                $stmt = $this->pdo->prepare($query);
                $stmt->execute([$event->guid]);
            } catch (Exception $e) {
                // Table may not exist yet — skip silently
            }

            $query = 'DELETE FROM ' . $this->prefix . 'charity_event
                WHERE id = ?';
            $stmt = $this->pdo->prepare($query);
            $stmt->execute([$event->id]);

            $this->pdo->commit();
        } catch (Exception $e) {
            $this->pdo->rollBack();
            throw $e;
        }
    }
}