<?php declare(strict_types=1);
/*
 * This file is part of Aplus Framework Database Library.
 *
 * (c) Natan Felles <natanfelles@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
namespace Framework\Database\Debug;

use Framework\Database\Database;
use Framework\Debug\Collector;

/**
 * Class DatabaseCollector.
 *
 * @package database
 */
class DatabaseCollector extends Collector
{
    protected Database $database;

    public function setDatabase(Database $database) : static
    {
        $this->database = $database;
        return $this;
    }

    public function getServerInfo() : string
    {
        return $this->database->getConnection()->server_info;
    }

    public function getActivities() : array
    {
        $activities = [];
        foreach ($this->getData() as $index => $data) {
            $activities[] = [
                'collector' => $this->getName(),
                'class' => static::class,
                'description' => 'Run statement ' . ($index + 1),
                'start' => $data['start'],
                'end' => $data['end'],
            ];
        }
        return $activities;
    }

    public function getContents() : string
    {
        \ob_start();
        if (!isset($this->database)) {
            echo '<p>This collector has not been added to a Database instance.</p>';
            return \ob_get_clean(); // @phpstan-ignore-line
        }
        echo $this->showHeader();
        if (!$this->hasData()) {
            echo '<p>Did not run statements.</p>';
            return \ob_get_clean(); // @phpstan-ignore-line
        }
        $count = \count($this->getData()); ?>
        <p>Ran <?= $count ?> statement<?= $count === 1 ? '' : 's' ?>:</p>
        <table>
            <thead>
            <tr>
                <th>#</th>
                <th title="Seconds">Time</th>
                <th>Statement</th>
                <th title="Affected rows or Rows in set">Rows</th>
            </tr>
            </thead>
            <tbody>
            <?php foreach ($this->getData() as $index => $item): ?>
                <tr>
                    <td><?= $index + 1 ?></td>
                    <td><?= \round($item['end'] - $item['start'], 6) ?></td>
                    <td>
                        <pre><code class="language-sql"><?=
                                \htmlentities($item['statement'])
                ?></code></pre>
                    </td>
                    <td<?= isset($item['description'])
                        ? ' title="' . \htmlentities($item['description']) . '"'
                        : ''?>><?= \htmlentities((string) $item['rows']) ?></td>
                </tr>
            <?php endforeach ?>
            </tbody>
        </table>
        <?php
        return \ob_get_clean(); // @phpstan-ignore-line
    }

    protected function showHeader() : string
    {
        $config = $this->database->getConfig();
        \ob_start();
        ?>
        <p title="<?= 'Connected to ' . \htmlentities($this->getHostInfo()) ?>">
            <strong>Host:</strong> <?= $config['host'] ?? 'localhost' ?>
        </p>
        <?php
        if (\str_contains($this->getHostInfo(), 'TCP/IP')) {
            if (isset($config['port'])) {
                ?>
                <p><strong>Port:</strong> <?= \htmlentities((string) $config['port']) ?></p>
                <?php
            }
        } elseif (isset($config['socket'])) { ?>
            <p><strong>Socket:</strong> <?= \htmlentities($config['socket']) ?></p>
            <?php
        }
        ?>
        <p><strong>Server Info:</strong> <?= \htmlentities($this->getServerInfo()) ?></p>
        <?php
        return \ob_get_clean(); // @phpstan-ignore-line
    }

    protected function getHostInfo() : string
    {
        return $this->database->getConnection()->host_info;
    }
}