AutoresponderDatabaseRepository.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

namespace ILIAS\Mail\Autoresponder;

use ilDBInterface;
use DateTimeImmutable;
use DateTimeZone;
use ilObjectNotFoundException;
use ilDBConstants;

final class AutoresponderDatabaseRepository implements AutoresponderRepository
{
    private const TABLE_NAME = 'mail_auto_responder';

    public function __construct(protected ilDBInterface $db)
    {
    }

    public function findBySenderId(int $sender_id): AutoresponderArrayCollection
    {
        $query = "SELECT * FROM " . self::TABLE_NAME . " WHERE sender_id = " . $this->db->quote(
            $sender_id,
            ilDBConstants::T_INTEGER
        );

        $result = $this->db->query($query);

        $auto_responder_results = new AutoresponderArrayCollection();
        while ($row = $this->db->fetchAssoc($result)) {
            $auto_responder_results->add(
                new AutoresponderDto(
                    (int) $row['sender_id'],
                    (int) $row['receiver_id'],
                    new DateTimeImmutable($row['sent_time'], new DateTimeZone('UTC'))
                )
            );
        }

        return $auto_responder_results;
    }

    public function findByReceiverId(int $receiver_id): AutoresponderArrayCollection
    {
        $query = "SELECT * FROM " . self::TABLE_NAME . " WHERE receiver_id = " . $this->db->quote(
            $receiver_id,
            ilDBConstants::T_INTEGER
        );

        $result = $this->db->query($query);

        $auto_responder_results = new AutoresponderArrayCollection();
        while ($row = $this->db->fetchAssoc($result)) {
            $auto_responder_results->add(
                new AutoresponderDto(
                    (int) $row['sender_id'],
                    (int) $row['receiver_id'],
                    new DateTimeImmutable($row['sent_time'], new DateTimeZone('UTC'))
                )
            );
        }

        return $auto_responder_results;
    }

    public function findBySenderIdAndReceiverId(int $sender_id, int $receiver_id): AutoresponderDto
    {
        $query = "SELECT * FROM " . self::TABLE_NAME . " WHERE sender_id = " . $this->db->quote(
            $sender_id,
            ilDBConstants::T_INTEGER
        ) . " AND receiver_id = " . $this->db->quote($receiver_id, ilDBConstants::T_INTEGER);
        $result = $this->db->query($query);
        $row = $this->db->fetchAssoc($result);
        if (!$row) {
            throw new ilObjectNotFoundException(
                "No auto responder found for sender_id: " . $sender_id . " and receiver_id: " . $receiver_id
            );
        }

        return new AutoresponderDto(
            (int) $row['sender_id'],
            (int) $row['receiver_id'],
            new DateTimeImmutable($row['sent_time'], new DateTimeZone('UTC'))
        );
    }

    public function store(AutoresponderDto $auto_responder): void
    {
        $timestamp_sent_time = $auto_responder->getSentTime()->setTimezone(new DateTimeZone('UTC'))->format(
            'Y-m-d H:i:s'
        );
        $this->db->replace(
            self::TABLE_NAME,
            [
                'sender_id' => [ilDBConstants::T_INTEGER, $auto_responder->getSenderId()],
                'receiver_id' => [ilDBConstants::T_INTEGER, $auto_responder->getReceiverId()]
            ],
            [
                'sent_time' => [ilDBConstants::T_TIMESTAMP, $timestamp_sent_time]
            ]
        );
    }

    public function delete(AutoresponderDto $auto_responder): void
    {
        $this->db->manipulate(
            'DELETE FROM ' . self::TABLE_NAME . ' WHERE sender_id = ' . $this->db->quote(
                $auto_responder->getSenderId(),
                ilDBConstants::T_INTEGER
            ) . ' AND receiver_id = ' . $this->db->quote($auto_responder->getReceiverId(), ilDBConstants::T_INTEGER)
        );
    }

    public function deleteBySenderId(int $sender_id): void
    {
        $this->db->manipulate(
            'DELETE FROM ' . self::TABLE_NAME . ' WHERE sender_id = ' . $this->db->quote(
                $sender_id,
                ilDBConstants::T_INTEGER
            )
        );
    }

    public function exists(int $sender_id, int $receiver_id): bool
    {
        $query = "SELECT 1 existing_record FROM " . self::TABLE_NAME . " WHERE sender_id = " . $this->db->quote(
            $sender_id,
            ilDBConstants::T_INTEGER
        ) . " AND receiver_id = " . $this->db->quote($receiver_id, ilDBConstants::T_INTEGER);
        $result = $this->db->query($query);

        if ($row = $this->db->fetchAssoc($result)) {
            return (int) $row['existing_record'] === 1;
        }

        return false;
    }
}