<?php

/*
 * Copyright 2005 - 2025 Centreon (https://www.centreon.com/)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * https://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 * For more information : contact@centreon.com
 *
 */

declare(strict_types=1);

namespace Core\Infrastructure\RealTime\Repository\Host;

use Centreon\Infrastructure\DatabaseConnection;
use Centreon\Infrastructure\Repository\AbstractRepositoryDRB;
use Core\Application\RealTime\Repository\ReadHostRepositoryInterface;
use Core\Domain\RealTime\Model\Host;

/**
 * @phpstan-import-type _dataHost from DbHostFactory
 */
class DbReadHostRepository extends AbstractRepositoryDRB implements ReadHostRepositoryInterface
{
    /**
     * @param DatabaseConnection $db
     */
    public function __construct(DatabaseConnection $db)
    {
        $this->db = $db;
    }

    /**
     * @inheritDoc
     */
    public function findHostById(int $hostId): ?Host
    {
        return $this->findHost($hostId);
    }

    /**
     * @inheritDoc
     */
    public function findHostByIdAndAccessGroupIds(int $hostId, array $accessGroupIds): ?Host
    {
        if ($accessGroupIds === []) {
            return null;
        }

        $accessGroupRequest = ' INNER JOIN `:dbstg`.`centreon_acl` AS host_acl
            ON host_acl.host_id = h.host_id
            AND host_acl.service_id IS NULL
            AND host_acl.group_id IN (' . implode(',', $accessGroupIds) . ') ';

        return $this->findHost($hostId, $accessGroupRequest);
    }

    /**
     * @inheritDoc
     */
    public function isAllowedToFindHostByAccessGroupIds(int $hostId, array $accessGroupIds): bool
    {
        if ($accessGroupIds === []) {
            return false;
        }

        $request = '
            SELECT COUNT(h.host_id) AS total, 1 AS REALTIME
            FROM `:dbstg`.`hosts` AS h
            INNER JOIN `:dbstg`.`centreon_acl` AS host_acl
                ON host_acl.host_id = h.host_id
                AND host_acl.group_id IN (' . implode(',', $accessGroupIds) . ')
            WHERE h.host_id = :host_id AND h.enabled = 1
        ';

        $statement = $this->db->prepare($this->translateDbName($request));

        $statement->bindValue(':host_id', $hostId, \PDO::PARAM_INT);

        $statement->execute();

        return $statement->fetchColumn() > 0;
    }

    /**
     * Find host request according to accessgroups or not.
     *
     * @param int $hostId
     * @param string|null $accessGroupRequest
     *
     * @return Host|null
     */
    private function findHost(int $hostId, ?string $accessGroupRequest = null): ?Host
    {
        $request = "SELECT
                1 AS REALTIME,
                h.host_id,
                h.name,
                h.address,
                h.output,
                h.alias,
                h.timezone,
                h.flapping,
                h.scheduled_downtime_depth AS `nb_downtime`,
                h.acknowledged,
                i.name AS `monitoring_server_name`,
                h.state AS `status_code`,
                h.perfData AS `performance_data`,
                h.output,
                h.command_line,
                h.notify,
                h.notification_number,
                h.last_state_change AS `last_status_change`,
                h.last_notification,
                h.latency,
                h.execution_time,
                h.percent_state_change AS `status_change_percentage`,
                h.next_check,
                h.last_check,
                h.passive_checks,
                h.active_checks,
                h.last_time_up,
                host_cvl.value AS `severity_level`,
                h.icon_image_alt AS `icon_name`,
                h.icon_image AS `icon_url`,
                h.check_attempt,
                h.max_check_attempts,
                h.state_type
            FROM `:dbstg`.`hosts` AS h
            INNER JOIN `:dbstg`.`instances` AS i ON i.instance_id = h.instance_id
            LEFT JOIN `:dbstg`.`customvariables` AS host_cvl ON host_cvl.host_id = h.host_id
                AND host_cvl.service_id = 0
                AND host_cvl.name = 'CRITICALITY_LEVEL'"
            . ($accessGroupRequest ?? '')
            . "WHERE  h.host_id = :host_id AND h.enabled = '1' AND h.name NOT LIKE '\_Module_BAM%'";

        $statement = $this->db->prepare($this->translateDbName($request));

        $statement->bindValue(':host_id', $hostId, \PDO::PARAM_INT);

        $statement->execute();

        if (($row = $statement->fetch(\PDO::FETCH_ASSOC))) {
            /** @var _dataHost $row */
            return DbHostFactory::createFromRecord($row);
        }

        return null;
    }
}
