Zabbix

<?php

/*

** 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 Affero General Public License as published by the Free Software Foundation, version 3.

**

** 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 Affero General Public License for more details.

**

** You should have received a copy of the GNU Affero General Public License along with this program.

** If not, see <https://www.gnu.org/licenses/>.

**/

​

​

/**

 * 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;

    }

​