<?php
declare(strict_types=1);

namespace MailAccountAdmin\Repositories;

use MailAccountAdmin\Exceptions\AccountNotFoundException;
use MailAccountAdmin\Models\Account;
use PDO;

class AccountRepository extends BaseRepository
{
    public function fetchAccountList(string $filterByDomain = null): array
    {
        $queryWhere = '';
        $queryParams = [];
        if (!empty($filterByDomain)) {
            $queryWhere = 'WHERE REGEXP_REPLACE(username, "^.*@", "") LIKE :domain';
            $queryParams['domain'] = str_replace('*', '%', $filterByDomain);
        }

        $query = '
            SELECT
                mail_users.*,
                REGEXP_REPLACE(username, "^.*@", "") AS domain,
                COUNT(alias_id) AS alias_count
            FROM mail_users
            LEFT JOIN mail_aliases ON mail_users.user_id = mail_aliases.user_id
            ' . $queryWhere . '
            GROUP BY username
            ORDER BY domain, username
        ';

        $statement = $this->pdo->prepare($query);
        $statement->execute($queryParams);
        $rows = $statement->fetchAll(PDO::FETCH_ASSOC);

        // Create Account models from rows
        $accountList = [];
        foreach ($rows as $row) {
            $accountList[] = Account::createFromArray($row);
        }
        return $accountList;
    }

    public function fetchAccountById(int $accountId): Account
    {
        $statement = $this->pdo->prepare('SELECT * FROM mail_users WHERE user_id = :user_id LIMIT 1');
        $statement->execute(['user_id' => $accountId]);

        if ($statement->rowCount() < 1) {
            throw new AccountNotFoundException("Account with user ID '$accountId' was not found.");
        }

        $row = $statement->fetch(PDO::FETCH_ASSOC);
        return Account::createFromArray($row);
    }
}