setup/src/Magento/Setup/Validator/ElasticsearchConnectionValidator.php - 2.4-develop - githubmirror/magento2

setup/src/Magento/Setup/Validator/ElasticsearchConnectionValidator.php

67 строк2 KB

Alexandra Zota

ACP2E-4019: CE copyright updates for 2.4.9-beta1

22 окт 2025, 11:23

22 окт 2025, 11:236c2f6e6

<?php
/**
 * Copyright 2020 Adobe
 * All Rights Reserved.
 */

namespace Magento\Setup\Validator;

use Magento\Setup\Exception as SetupException;

/**
 * Connection validator for Elasticsearch configuration
 */
class ElasticsearchConnectionValidator
{
    /**
     * Validate elasticsearch connection
     *
     * Throws exception if unable to connect to Elasticsearch server
     *
     * @param array $options
     * @return bool
     * @throws \Exception
     */
    public function isValidConnection(array $options)
    {
        $config = $this->buildConfig($options);

        $elasticsearchClient = \Elasticsearch\ClientBuilder::fromConfig($config, true);
        $elasticsearchClient->ping();

        return true;
    }

    /**
     * Construct elasticsearch connection string
     *
     * @param array $options
     * @return array
     * @throws SetupException
     */
    private function buildConfig(array $options)
    {
        $hostname = preg_replace('/http[s]?:\/\//i', '', $options['hostname']);
        // @codingStandardsIgnoreStart
        $protocol = parse_url($options['hostname'], PHP_URL_SCHEME);
        // @codingStandardsIgnoreEnd
        if (!$protocol) {
            $protocol = 'http';
        }

        $authString = '';
        if (isset($options['enableAuth']) && true === $options['enableAuth']) {
            if (empty($options['username']) || empty($options['password'])) {
                throw new SetupException(
                    'Search engine misconfiguration. Username and password must be set if authentication is enabled'
                );
            }
            $authString = "{$options['username']}:{$options['password']}@";
        }
        $portString = empty($options['port']) ? '' : ':' . $options['port'];
        $host = $protocol . '://' . $authString . $hostname . $portString;
        $options['hosts'] = [$host];

        return $options;
    }
}