Zabbix

<?php

/*

** Zabbix

** Copyright (C) 2001-2025 Zabbix SIA

**

** This program is free software; you can redistribute it and/or modify

** it under the terms of the GNU General Public License as published by

** the Free Software Foundation; either version 2 of the License, or

** (at your option) any later version.

**

** This program is distributed in the hope that it will be useful,

** but WITHOUT ANY WARRANTY; without even the implied warranty of

** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

** GNU General Public License for more details.

**

** You should have received a copy of the GNU General Public License

** along with this program; if not, write to the Free Software

** Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.

**/

​

​

/**

 * A helper class for working with Elasticsearch.

 */

class CElasticsearchHelper {

​

    const MAX_RESULT_WINDOW = 10000;

    const KEEP_CONTEXT_PERIOD = '10s';

​

    private static $scroll_id;

    private static $scrolls;

​

    /**

     * Perform request to Elasticsearch.

     *

     * @param string $method      HTTP method to be used to perform request

     * @param string $endpoint    requested url

     * @param mixed  $request     data to be sent

     *

     * @return string    result

     */

    private static function request($method, $endpoint, $request = null) {

        $time_start = microtime(true);

        $options = [

            'http' => [

                'header'  => "Content-Type: application/json; charset=UTF-8",

                'method'  => $method,

                'ignore_errors' => true // To get error messages from Elasticsearch.

            ]

        ];

​

        if ($request) {

            $request = json_encode($request);

            $options['http']['content'] = $request;

        }

​

        try {

            $result = file_get_contents($endpoint, false, stream_context_create($options));

        }

        catch (Exception $e) {

            error($e->getMessage());

        }

​

        CProfiler::getInstance()->profileElasticsearch(microtime(true) - $time_start, $method, $endpoint, $request);

​

        return $result;

    }

​

    /**

     * Get Elasticsearch endpoint for scroll API requests.

     * Endpoint should be in following format: <Elasticsearch url>/<indices>/<values>/<action><query string>.

     *

     * @param string $endpoint    endpoint of the initial request

     *

     * @return array    parsed result

     */

    private static function getScrollApiEndpoint($endpoint) {

        $url = $endpoint;

​

        for ($i = 0; $i < 2; $i++) {

            if (($pos = strrpos($url, '/')) !== false) {

                $url = substr($url, 0, $pos);

            }

            else {

                // Endpoint is in different format, no way to get scroll API url.

                error(_s('Elasticsearch error: %1$s.',

                        _('cannot perform Scroll API request, data could be truncated'))

                );

​

                return null;

            }