<?php

/**
 * @package Dotclear
 * @subpackage Core
 *
 * @copyright Olivier Meunier & Association Dotclear
 * @copyright AGPL-3.0
 */
declare(strict_types=1);

namespace Dotclear\Core;

use Dotclear\Database\Cursor;
use Dotclear\Database\MetaRecord;
use Dotclear\Database\Statement\DeleteStatement;
use Dotclear\Database\Statement\JoinStatement;
use Dotclear\Database\Statement\SelectStatement;
use Dotclear\Database\Statement\TruncateStatement;
use Dotclear\Helper\Network\Http;
use Dotclear\Exception\BadRequestException;
use Dotclear\Interface\Core\LogInterface;
use Dotclear\Schema\Extension\Log as ExtLog;
use Throwable;

/**
 * @brief   Core log handler.
 *
 * @since   2.28, container services have been added to constructor
 * @since   2.36, constructor arguments has been replaced by Core instance
 */
class Log implements LogInterface
{
    /**
     * Full log table name (including db prefix).
     */
    protected string $log_table;

    /**
     * Full user table name (including db prefix).
     */
    protected string $user_table;

    /**
     * Constructs a new instance.
     *
     * @param   Core    $core   The core container
     */
    public function __construct(
        protected Core $core
    ) {
        $this->log_table  = $this->core->db()->con()->prefix() . self::LOG_TABLE_NAME;
        $this->user_table = $this->core->db()->con()->prefix() . $this->core->auth()::USER_TABLE_NAME;
    }

    /**
     * Get log table name.
     *
     * @deprecated since 2.28, use App::log()::LOG_TABLE_NAME instead
     *
     * @return  string  The log database table name
     */
    public function getTable(): string
    {
        $this->core->deprecated()->set('App::log()::LOG_TABLE_NAME', '2.28');

        return self::LOG_TABLE_NAME;
    }

    public function openLogCursor(): Cursor
    {
        return $this->core->db()->con()->openCursor($this->log_table);
    }

    public function getLogs(array $params = [], bool $count_only = false): MetaRecord
    {
        $sql = new SelectStatement();

        if ($count_only) {
            $sql->column($sql->count('log_id'));
        } else {
            $sql->columns([
                'L.log_id',
                'L.user_id',
                'L.log_table',
                'L.log_dt',
                'L.log_ip',
                'L.log_msg',
                'L.blog_id',
                'U.user_name',
                'U.user_firstname',
                'U.user_displayname',
                'U.user_url',
            ]);
        }

        $sql->from($sql->alias($this->log_table, 'L'));

        if (!$count_only) {
            $sql->join(
                (new JoinStatement())
                ->left()
                ->from($sql->alias($this->user_table, 'U'))
                ->on('U.user_id = L.user_id')
                ->statement()
            );
        }

        if (!empty($params['blog_id']) && is_string($params['blog_id'])) {
            if ($params['blog_id'] === '*') {
                // Nothing to add here
            } else {
                $sql->where('L.blog_id = ' . $sql->quote($params['blog_id']));
            }
        } else {
            $sql->where('L.blog_id = ' . $sql->quote($this->core->blog()->id()));
        }

        if (!empty($params['user_id'])
            && (is_string($params['user_id']) || is_array($params['user_id']))) {
            $list = $sql->sanitizeIn($params['user_id'], 'string', false);
            if ($list !== []) {
                $sql->and('L.user_id' . $sql->in($list));
            }
        }

        if (!empty($params['log_ip'])
            && (is_string($params['log_ip']) || is_array($params['log_ip']))) {
            $list = $sql->sanitizeIn($params['log_ip'], 'string', false);
            if ($list !== []) {
                $sql->and('log_ip' . $sql->in($list));
            }
        }

        if (!empty($params['log_table'])
            && (is_string($params['log_table']) || is_array($params['log_table']))) {
            $list = $sql->sanitizeIn($params['log_table'], 'string', false);
            if ($list !== []) {
                $sql->and('log_table' . $sql->in($list));
            }
        }

        if (!$count_only) {
            if (!empty($params['order']) && is_string($params['order'])) {
                $sql->order($sql->escape($params['order']));
            } else {
                $sql->order('log_dt DESC');
            }
        }

        if (!$count_only && !empty($params['limit'])) {
            $values = is_array($params['limit']) ? array_values($params['limit']) : [$params['limit']];
            // Make $values an array of integer values
            $values = array_map(fn (mixed $v): int => is_numeric($v) ? (int) $v : 0, $values);

            /**
             * @var array{0: int, 1?: int}  $limit
             */
            $limit = [
                $values[0],
            ];
            if (isset($values[1])) {
                $limit[1] = $values[1];
            }

            $sql->limit($limit);
        }

        $rs = $sql->select();
        if ($rs instanceof MetaRecord) {
            $rs->extend(ExtLog::class);
        }

        return $rs ?? MetaRecord::newFromArray([]);
    }

    public function addLog(Cursor $cur): int
    {
        $this->core->db()->con()->writeLock($this->log_table);

        try {
            # Get ID
            $sql = new SelectStatement();
            $sql
                ->column($sql->max('log_id'))
                ->from($this->log_table);

            $rs = $sql->select();

            $cur->setIntField('log_id', $rs instanceof MetaRecord ? $rs->cardinal() + 1 : 1);

            if ($cur->strField('log_msg') === '') {
                throw new BadRequestException(__('No log message.'));
            }

            if ($cur->strField('log_table') === '') {
                $cur->setStrField('log_table', 'none');
            }

            if ($cur->strField('user_id') === '') {
                $cur->setStrField('user_id', 'unknown');
            }

            if ($cur->strField('blog_id') === '') {
                $cur->setStrField('blog_id', $this->core->blog()->id());
            }

            if ($cur->strField('log_ip') === '') {
                $cur->setStrField('log_ip', Http::realIP());
            }

            if ($cur->strField('log_dt') === '') {
                $cur->setStrField('log_dt', date('Y-m-d H:i:s'));
            }

            # --BEHAVIOR-- coreBeforeLogCreate -- Log, Cursor
            $this->core->behavior()->callBehavior('coreBeforeLogCreate', $this, $cur);

            $cur->insert();
            $this->core->db()->con()->unlock();
        } catch (Throwable $throwable) {
            $this->core->db()->con()->unlock();

            throw $throwable;
        }

        # --BEHAVIOR-- coreAfterLogCreate -- Log, Cursor
        $this->core->behavior()->callBehavior('coreAfterLogCreate', $this, $cur);

        return $cur->intField('log_id');
    }

    public function delLog(int $id): void
    {
        $sql = new DeleteStatement();
        $sql
            ->from($this->log_table)
            ->where('log_id = ' . $id)
            ->delete();
    }

    public function delLogs($id, bool $all = false): void
    {
        if ($all) {
            $this->delAllLogs();
        } elseif (is_int($id)) {
            $this->delLog($id);
        } else {
            $sql = new DeleteStatement();

            $ids = $sql->sanitizeIn($id, 'int', false);
            if ($ids !== []) {
                $sql
                    ->from($this->log_table)
                    ->where('log_id ' . $sql->in($ids))
                    ->delete();
            }
        }
    }

    public function delAllLogs(): void
    {
        $sql = new TruncateStatement();
        $sql
            ->from($this->log_table)
            ->run();
    }
}
