StreamRepository.php

<?php

namespace App\Repositories;

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

class StreamRepository
{
    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_stream c
            INNER JOIN ' . $this->prefix . 'user_right r ON r.id_charity_stream = 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, Stream::class);
        return $stmt->fetchAll();
    }

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

    public function selectListByUser(User $user): array
    {
        $stmt = $this->pdo->prepare('
            SELECT c.*, u.email as admin
            FROM ' . $this->prefix . 'charity_stream c
            INNER JOIN ' . $this->prefix . 'user_right ur on ur.id_charity_stream = c.id
            INNER JOIN ' . $this->prefix . 'users u ON u.id = ur.id_user
            WHERE ur.id_user = :id_user

            UNION 

            SELECT c.*, u.email as admin
            FROM ' . $this->prefix . 'charity_stream c
            INNER JOIN ' . $this->prefix . 'user_right ur on ur.id_charity_event = c.charity_event_id
            INNER JOIN ' . $this->prefix . 'users u ON u.id = ur.id_user
            WHERE ur.id_user = :id_user

            ORDER BY creation_date DESC
        ');
        $stmt->setFetchMode(PDO::FETCH_CLASS, Stream::class);
        $stmt->execute([':id_user' => $user->id]);
        return $stmt->fetchAll();
    }

    public function selectListByEvent(Event $event): array
    {
        $stmt = $this->pdo->prepare('
            SELECT *
            FROM ' . $this->prefix . 'charity_stream
            WHERE charity_event_id = :id
        ');
        $stmt->setFetchMode(PDO::FETCH_CLASS, Stream::class);
        $stmt->execute([':id' => $event->id]);
        return $stmt->fetchAll();
    }

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

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

    public function insert(string $form_slug, string $organization_slug, string $title, ?int $parent = null, string $form_type = 'Donation'): Stream
    {
        $guid = bin2hex(random_bytes(16));

        $this->pdo->beginTransaction();

        try {
            $query = 'INSERT INTO ' . $this->prefix . 'charity_stream (guid, form_slug, form_type, organization_slug, title, charity_event_id)
                VALUES (:guid, :form_slug, :form_type, :organization_slug, :title, :charity_event_id)';
            $stmt = $this->pdo->prepare($query);
            $stmt->execute([
                ':guid' => $guid,
                ':form_slug' => $form_slug,
                ':form_type' => $form_type,
                ':organization_slug' => $organization_slug,
                ':title' => $title,
                ':charity_event_id' => $parent
            ]);

            $id = $this->pdo->lastInsertId();

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

            $query = 'INSERT INTO ' . $this->prefix . 'widget_alert_box (charity_stream_guid, alert_duration, message_template, sound_volume)
                VALUES (:guid, 5, "{pseudo} vient de donner {amount}<br/>{message}", 50)';
            $stmt = $this->pdo->prepare($query);
            $stmt->execute([
                ':guid' => $guid
            ]);

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

            $this->pdo->commit();

            $stream = new Stream();
            $stream->id = $id;
            $stream->guid = $guid;
            $stream->form_slug = $form_slug;
            $stream->form_type = $form_type;
            $stream->organization_slug = $organization_slug;
            $stream->title = $title;
            return $stream;
        } catch (Exception $e) {
            $this->pdo->rollBack();
            throw $e;
        }
    }

    public function updateEventLink(Stream $stream, ?int $eventId): void
    {
        $stmt = $this->pdo->prepare('
            UPDATE ' . $this->prefix . 'charity_stream
            SET charity_event_id = ?
            WHERE id = ?
        ');
        $stmt->execute([$eventId, $stream->id]);
        $stream->charity_event_id = $eventId;
    }

    public function update(Stream $stream, 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 (array_key_exists('is_test_mode', $data)) {
            $fields[] = 'is_test_mode = ?';
            $params[] = (int) $data['is_test_mode'];
        }
        if (array_key_exists('test_amount', $data)) {
            $fields[] = 'test_amount = ?';
            $params[] = (int) $data['test_amount'];
        }

        if (empty($fields)) return;

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

    public function delete(Stream $stream): void
    {
        $this->pdo->beginTransaction();

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

            $query = 'DELETE FROM ' . $this->prefix . 'widget_alert_box
                WHERE charity_stream_guid = ?';
            $stmt = $this->pdo->prepare($query);
            $stmt->execute([$stream->guid]);

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

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

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

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