<?php

namespace Shm\ShmBlueprints\Auth;

use Illuminate\Support\Arr;
use Sentry\Util\Str;
use Shm\Shm;
use Shm\ShmAuth\Auth;
use Shm\ShmAuth\AuthToken;
use Shm\ShmDB\mDB;
use Shm\ShmEmail\ShmEmail;
use Shm\ShmTypes\BaseType;
use Shm\ShmTypes\Classes\EventClasses\ShmEventPostLoginPayload;
use Shm\ShmTypes\Classes\EventClasses\ShmEventPostRegisterPayload;
use Shm\ShmUtils\I18n;

use Shm\ShmUtils\Response;
use Shm\ShmTypes\StructureType;
use Shm\ShmTypes\Classes\ShmEventPayload;
use Shm\ShmUtils\Config;
use Shm\ShmUtils\ShmInit;

/**
 * Base authentication class
 * 
 * This abstract class provides common functionality for all authentication
 * handlers including structure management, validation, and token handling.
 */
abstract class ShmAuthBase
{
    public ?string $title = null;
    public ?string $key = null;

    public bool $saveToSession = false;

    public function session($saveToSession = true): self
    {
        $this->saveToSession = $saveToSession;
        return $this;
    }

    /**
     * Authentication structures
     * @var StructureType[]
     */
    public array $_authStructures = [];

    /**
     * Registration structures
     * @var StructureType[]
     */
    public array $_regStructures = [];

    public ?string $description = null;
    public mixed $pipeline = null;


    public function currentStructure(): ?StructureType
    {
        $currentAuthStructure = null;
        foreach ($this->_authStructures as $authStructure) {
            if ($authStructure->collection == Auth::getAuthCollection()) {
                $currentAuthStructure = $authStructure;
                break;
            }
        }


        if (!$currentAuthStructure) {
            Response::unauthorized();
        }

        return $currentAuthStructure;
    }



    public $errorAccountNotFound = "Ваша учетная запись не найдена.";


    /**
     * Validate that required keys have values
     * 
     * @param array $keys Required keys to validate
     * @param array $params Parameters to validate
     * @throws \Exception If validation fails
     */
    public function hasValueValidator(array $keys, array $params): void
    {
        foreach ($keys as $key) {
            if (!isset($params[$key]) || empty($params[$key])) {
                Response::validation(I18n::get('fill_required_fields'));
            }
        }
    }


    /**
     * Check if email is valid
     * 
     * @param string $email Email to validate
     * @return bool True if email is valid
     */
    public function isEmail(string $email): bool
    {
        return filter_var($email, FILTER_VALIDATE_EMAIL) !== false;
    }

    public function __construct()
    {
        // Constructor implementation
    }


    /**
     * Set authentication structures
     * 
     * @param array $authStructures Authentication structures
     * @return static
     */
    public function auth(array $authStructures): static
    {
        $this->_authStructures = $authStructures;
        return $this;
    }

    /**
     * Set registration structures
     * 
     * @param array $regStructures Registration structures
     * @return static
     */
    public function reg(array $regStructures): static
    {
        $this->_regStructures = $regStructures;

        return $this;
    }

    public function deviceInfoStructure()
    {
        return Shm::structure([
            'name' => Shm::string(),
            'model' => Shm::string(),
            'platform' => Shm::string(),
            'uuid' => Shm::string(),
        ]);
    }

    public function  authToken(StructureType $structure,  $_id, $args): string
    {




        $deviceInfo = $args['deviceInfo'] ?? null;
        if ($deviceInfo) {


            if (isset($deviceInfo['_id'])) {
                unset($deviceInfo['_id']);
            }

            try {

                mDB::_collection("devices")->updateOne(
                    [
                        ...$deviceInfo,
                        'user' => mDB::id($_id),
                    ],
                    [
                        '$set' => [
                            ...$deviceInfo,
                            'auth_collection' => $structure->collection,
                            'user' => mDB::id($_id)

                        ],
                    ],
                    [
                        'upsert' => true,
                    ]
                );
            } catch (\Exception $e) {

                ShmInit::sendOnError($e);


                $deviceInfo = null;
            }
        }


        //Проверка есть ли поле email в структуре
        $emailField = $structure->findItemByType(Shm::email())?->key ?? null;

        $cancelKey = null;
        if ($emailField) {
            $email = $structure->findOne(['_id' => $_id])[$emailField] ?? null;
            if ($email && $this->isEmail($email)) {

                $cancelKey = hash("sha512", time() . bin2hex(openssl_random_pseudo_bytes(32) . $_id));


                [
                    $body,
                    $subject
                ] = ShmMailTpl::successLogin($cancelKey);

                $this->sendEmail(
                    $email,
                    $subject,
                    $body
                );
            }
        }

        $payload = new ShmEventPayload();
        $payload->postLoginPayload = new ShmEventPostLoginPayload();
        $payload->postLoginPayload->user_id = $_id;
        $structure->callEventPostLogin($payload);


        $authToken = new AuthToken();
        $authToken->structure($structure);
        $authToken->userId($_id);
        $authToken->cancelKey($cancelKey);
        $authToken->saveToSession($this->saveToSession);
        return $authToken->generate();
    }




    public function make(): ?array
    {
        return [];
    }


    public function sendEmail($mailTo, $subject, $body)
    {

        $ShmEmail = ShmEmail::create()
            ->mailTo($mailTo)
            ->subject($subject)
            ->body($body);

        $ShmEmail->send();
    }



    public function forceProtect($startDataString)
    {

        if (ShmInit::isDev()) return;

        if (!$startDataString) return;
        // Определяем, какие ключи из $_SERVER будем использовать для формирования уникального идентификатора
        $keysToInclude = [
            'REMOTE_ADDR',         // IP-адрес клиента
            'HTTP_USER_AGENT',     // User-Agent клиента
            'HTTP_ACCEPT_LANGUAGE', // Языковые настройки
            'HTTP_ACCEPT',         // Заголовок Accept
            'HTTP_CONNECTION',     // Тип соединения
            'HTTP_HOST',           // Хост
        ];

        // Инициализируем пустую строку для хранения данных
        $dataString = $startDataString;

        // Проходим по каждому ключу и добавляем его значение к строке, если оно существует
        foreach ($keysToInclude as $key) {
            if (isset($_SERVER[$key])) {
                $dataString .= $_SERVER[$key];
            }
        }

        // Генерируем SHA-512 хэш-сумму из строки
        $hash = hash('sha512', $dataString);

        // Получаем коллекцию из базы данных
        $collection = mDB::collection("_auth_locks");

        $attempt = $collection->findOne(['hash' => $hash]);

        $currentTime = time();

        if ($attempt) {

            $lastAttemptTime = $attempt->last_attempt;
            $attempts = $attempt->attempts;

            // Сообщение о блокировке
            if ($attempts >= 10 && $currentTime - 60 < $lastAttemptTime) {
                Response::validation(I18n::get('too_many_attempts'));
            }

            // Проверка, прошло ли больше одной минуты
            if ($currentTime - 60 > $lastAttemptTime) {
                // Сбрасываем счетчик, если прошло больше одной минуты
                $collection->updateOne(
                    ['hash' => $hash],
                    ['$set' => ['attempts' => 1, 'last_attempt' => $currentTime]]
                );
            } else {
                // Увеличиваем счетчик
                $collection->updateOne(
                    ['hash' => $hash],
                    ['$inc' => ['attempts' => 1], '$set' => ['last_attempt' => $currentTime]]
                );
            }
        } else {
            // Создаем новый документ, если его нет
            $collection->insertOne([
                'hash' => $hash,
                'attempts' => 1,
                'last_attempt' => $currentTime
            ]);
        }
    }


    public function findAuthUserAndStructure(BaseType | null $field, $value, array $match, $password = null): ?array
    {



        foreach ($this->_authStructures as $authStructure) {




            if ($field) {

                $findField = $authStructure->findItemByType($field)?->key;



                if (!$findField) {
                    continue;
                }

                $match  = [

                    $findField => $value,
                    ...$match
                ];
            } else {
                $match  = [

                    ...$match
                ];
            }



            if ($password) {
                $passwordField = $authStructure->findItemByType(Shm::password())?->key;

                if (!$passwordField) {
                    continue;
                }


                if ($passwordField) {

                    $match  = [

                        ...$match,
                        $passwordField => Auth::getPassword($password)
                    ];
                }
            }



            $user = $authStructure->findOne(
                $match
            );



            if ($user) {

                return [$user, $authStructure];
            }
        }
        return null;
    }

    public function regNewUser(BaseType | null $field, $value, array $set): ?array
    {


        $regStructure = $this->_regStructures[0] ?? null;

        if (!$regStructure) {
            Shm::error($this->errorAccountNotFound);
        }


        if ($field) {

            $findField = $regStructure->findItemByType($field)?->key;
            if (!$findField) {
                Shm::error($this->errorAccountNotFound);
            }



            $set  = [

                $findField => $value,
                ...$set
            ];
        } else {
            $set  = [

                ...$set
            ];
        }



        $insert = $regStructure->insertOne($set);



        $user = $regStructure->findOne(
            [
                "_id" => $insert->getInsertedId()
            ]
        );

        if ($user) {

            $payload = new ShmEventPayload();
            $payload->postRegisterPayload = new ShmEventPostRegisterPayload();
            $payload->postRegisterPayload->user_id = $user['_id'] ?? null;


            $regStructure->callEventPostRegister($payload);


            return [$user, $regStructure];
        }

        return null;
    }

    protected function validatePhoneSetRequest(int $phone): array
    {
        Auth::authenticateOrThrow();

        $this->forceProtect((string) $phone);

        $currentAuthStructure = $this->currentStructure();
        $phoneField = $currentAuthStructure->findItemByType(Shm::phone())?->key;

        if (!$phoneField) {
            Response::validation(I18n::get('auth_phone_not_supported'));
        }

        $user = $currentAuthStructure->findOne([
            '_id' => Auth::getAuthID(),
        ]);

        if (!$user) {
            Response::validation(I18n::get('access_denied'));
        }

        $currentPhone = $user[$phoneField] ?? null;
        if ($currentPhone && (int) $currentPhone === $phone) {
            Response::validation(I18n::get('phone_same_as_current'));
        }

        $authUserAndStructure = $this->findAuthUserAndStructure(Shm::phone(), $phone, []);
        if ($authUserAndStructure) {
            [$existingUser] = $authUserAndStructure;
            if ((string) ($existingUser['_id'] ?? '') !== (string) Auth::getAuthID()) {
                Shm::error(I18n::get('phone_already_used'));
            }
        }

        return [$phoneField, $currentAuthStructure, $user];
    }

    protected function setPhoneForCurrentUser(int $phone, string $phoneField, StructureType $currentAuthStructure): bool
    {
        foreach ($this->_authStructures as $authStructure) {
            $phoneFieldLocal = $authStructure->findItemByType(Shm::phone())?->key;
            if (!$phoneFieldLocal) {
                continue;
            }

            $authStructure->updateOne(
                [
                    $phoneFieldLocal => $phone,
                ],
                [
                    '$unset' => [
                        $phoneFieldLocal => 1,
                    ],
                ]
            );
        }

        $currentAuthStructure->updateOne(
            [
                '_id' => Auth::getAuthID(),
            ],
            [
                '$set' => [
                    $phoneField => $phone,
                ],
            ]
        );

        return true;
    }
}
