mc-cms-namelessmc/modules/Core/includes/endpoints/ServerInfoEndpoint.php

<?php
use Symfony\Component\HttpFoundation\Response;

class ServerInfoEndpoint extends KeyAuthEndpoint {

    public function __construct() {
        $this->_route = 'minecraft/server-info';
        $this->_module = 'Core';
        $this->_description = 'Update the Minecraft server information NamelessMC tracks';
        $this->_method = 'POST';
    }

    public function execute(Nameless2API $api): void {
        $api->validateParams($_POST, ['server-id']);
        if (!isset($_POST['players'])) {
            $api->throwError(Nameless2API::ERROR_INVALID_POST_CONTENTS, 'players');
        }

        $server_id = $_POST['server-id'];
        // Ensure server exists
        $server_query = $api->getDb()->get('mc_servers', ['id', $server_id]);

        if (!$server_query->count() || $server_query->first()->bedrock) {
            $api->throwError(CoreApiErrors::ERROR_INVALID_SERVER_ID, $server_id);
        }

        if (isset($_POST['verify_command'])) {
            Settings::set('minecraft_verify_command', $_POST['verify_command']);
        }

        try {
            $api->getDb()->insert('query_results', [
                'server_id' => $_POST['server-id'],
                'queried_at' => date('U'),
                'players_online' => count($_POST['players']),
                'groups' => isset($_POST['groups']) ? json_encode($_POST['groups']) : '[]'
            ]);

            if (file_exists(ROOT_PATH . DIRECTORY_SEPARATOR . 'cache' . DIRECTORY_SEPARATOR . sha1('server_query_cache') . '.cache')) {
                $query_cache = file_get_contents(ROOT_PATH . DIRECTORY_SEPARATOR . 'cache' . DIRECTORY_SEPARATOR . sha1('server_query_cache') . '.cache');
                $query_cache = json_decode($query_cache);
                if (isset($query_cache->query_interval)) {
                    $query_interval = unserialize($query_cache->query_interval->data);
                } else {
                    $query_interval = 10;
                }

                $to_cache = [
                    'query_interval' => [
                        'time' => date('U'),
                        'expire' => 0,
                        'data' => serialize($query_interval)
                    ],
                    'last_query' => [
                        'time' => date('U'),
                        'expire' => 0,
                        'data' => serialize(date('U'))
                    ]
                ];

                // Store in cache file
                file_put_contents(ROOT_PATH . DIRECTORY_SEPARATOR . 'cache' . DIRECTORY_SEPARATOR . sha1('server_query_cache') . '.cache', json_encode($to_cache));
            }
        } catch (Exception $e) {
            $api->throwError(CoreApiErrors::ERROR_UNABLE_TO_UPDATE_SERVER_INFO, $e->getMessage(), Response::HTTP_INTERNAL_SERVER_ERROR);
        }

        $cache = new Cache(['name' => 'nameless', 'extension' => '.cache', 'path' => ROOT_PATH . '/cache/']);

        if (Settings::get('mc_integration')) {
            $cache->setCache('minecraft_last_online');
            try {
                $integration = Integrations::getInstance()->getIntegration('Minecraft');

                foreach ($_POST['players'] as $uuid => $player) {
                    $integrationUser = new IntegrationUser($integration, $uuid, 'identifier');
                    if ($integrationUser->exists()) {
                        $this->updateUsername($integrationUser, $player);
                        $cache->store($integrationUser->data()->identifier, [date('U'), $server_id]);

                        if (isset($player['placeholders']) && count($player['placeholders'])) {
                            $this->updatePlaceholders($integrationUser->getUser(), $player);
                        }
                    }
                }
            } catch (Exception $e) {
                $api->throwError(CoreApiErrors::ERROR_UNABLE_TO_UPDATE_SERVER_INFO, $e->getMessage(), Response::HTTP_INTERNAL_SERVER_ERROR);
            }
        }

        // Server query
        try {
            $query_type = Settings::get('query_type', 'internal');
            if ($query_type == 'plugin') {
                $players_list = [];
                foreach ($_POST['players'] as $uuid => $player) {
                    $players_list[] = ['id' => $uuid, 'name' => $player['name']];
                }

                $cache->setCache('latest_query');
                $cache->store($server_id, [
                    'player_count' => count($_POST['players']),
                    'player_count_max' => $_POST['max_players'],
                    'player_list' => $players_list,
                    'motd' => $_POST['motd']
                ], intval($_POST['interval_seconds'] ?? 10) * 2);
            }
        } catch (Exception $e) {
            $api->throwError(CoreApiErrors::ERROR_UNABLE_TO_UPDATE_SERVER_INFO, $e->getMessage(), Response::HTTP_INTERNAL_SERVER_ERROR);
        }

        $api->returnArray(array_merge(['message' => $api->getLanguage()->get('api', 'server_info_updated')]));
    }

    private function updateUsername(IntegrationUser $integrationUser, array $player): void {
        if ($player['name'] != $integrationUser->data()->username) {
            $integrationUser->update([
                'username' => Output::getClean($player['name'])
            ]);
        }
    }

    private function updatePlaceholders(User $user, $player): void {
        if ($user->exists()) {
            $user->savePlaceholders($_POST['server-id'], $player['placeholders']);
        }
    }
}