OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	08/12/2024 10:36:02 AM	rwxr-xr-x
📄 AbstractHandlerTest.php	2.53 KB	08/12/2024 10:35:59 AM	rw-r--r--
📄 AbstractProcessingHandlerTest.php	4.88 KB	08/12/2024 10:35:59 AM	rw-r--r--
📄 AmqpHandlerTest.php	4.3 KB	08/12/2024 10:35:59 AM	rw-r--r--
📄 BrowserConsoleHandlerTest.php	4.88 KB	08/12/2024 10:35:59 AM	rw-r--r--
📄 BufferHandlerTest.php	5.39 KB	08/12/2024 10:35:59 AM	rw-r--r--
📄 ChromePHPHandlerTest.php	4.9 KB	08/12/2024 10:35:59 AM	rw-r--r--
📄 CouchDBHandlerTest.php	805 bytes	08/12/2024 10:35:59 AM	rw-r--r--
📄 DeduplicationHandlerTest.php	6.2 KB	08/12/2024 10:35:59 AM	rw-r--r--
📄 DoctrineCouchDBHandlerTest.php	1.49 KB	08/12/2024 10:35:59 AM	rw-r--r--
📄 DynamoDbHandlerTest.php	2.31 KB	08/12/2024 10:35:59 AM	rw-r--r--
📄 ElasticaHandlerTest.php	7.74 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 ElasticsearchHandlerTest.php	7.78 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 ErrorLogHandlerTest.php	2.22 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 ExceptionTestHandler.php	567 bytes	08/12/2024 10:36:00 AM	rw-r--r--
📄 FallbackGroupHandlerTest.php	6.17 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 FilterHandlerTest.php	7.43 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 FingersCrossedHandlerTest.php	11.28 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 FirePHPHandlerTest.php	3.12 KB	08/12/2024 10:36:00 AM	rw-r--r--
📁 Fixtures	-	08/12/2024 10:36:32 AM	rwxr-xr-x
📄 FleepHookHandlerTest.php	1.99 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 FlowdockHandlerTest.php	2.74 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 GelfHandlerTest.php	3.59 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 GroupHandlerTest.php	4.97 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 HandlerWrapperTest.php	2.12 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 InsightOpsHandlerTest.php	2.58 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 LogEntriesHandlerTest.php	2.6 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 LogmaticHandlerTest.php	2.87 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 MailHandlerTest.php	2.29 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 MongoDBHandlerTest.php	2.27 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 NativeMailerHandlerTest.php	3.78 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 NewRelicHandlerTest.php	6.04 KB	08/12/2024 10:36:00 AM	rw-r--r--
📄 NoopHandlerTest.php	1.08 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 NullHandlerTest.php	1.27 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 OverflowHandlerTest.php	3.62 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 PHPConsoleHandlerTest.php	10.37 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 ProcessHandlerTest.php	6.91 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 PsrHandlerTest.php	2.47 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 PushoverHandlerTest.php	5.59 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 RedisHandlerTest.php	4.29 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 RedisPubSubHandlerTest.php	2.18 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 RollbarHandlerTest.php	2.52 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 RotatingFileHandlerTest.php	12.63 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 SamplingHandlerTest.php	909 bytes	08/12/2024 10:36:01 AM	rw-r--r--
📁 Slack	-	08/12/2024 10:36:32 AM	rwxr-xr-x
📄 SlackHandlerTest.php	5.68 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 SlackWebhookHandlerTest.php	5 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 SocketHandlerTest.php	9.69 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 StreamHandlerTest.php	9.85 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 SymfonyMailerHandlerTest.php	3.34 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 SyslogHandlerTest.php	1.32 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 SyslogUdpHandlerTest.php	3.97 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 TelegramBotHandlerTest.php	1.87 KB	08/12/2024 10:36:01 AM	rw-r--r--
📄 TestHandlerTest.php	4.05 KB	08/12/2024 10:36:02 AM	rw-r--r--
📄 UdpSocketTest.php	1.79 KB	08/12/2024 10:36:02 AM	rw-r--r--
📄 WhatFailureGroupHandlerTest.php	5.8 KB	08/12/2024 10:36:02 AM	rw-r--r--
📄 ZendMonitorHandlerTest.php	2.21 KB	08/12/2024 10:36:02 AM	rw-r--r--

Editing: ElasticaHandlerTest.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 Monolog\Formatter\ElasticaFormatter;
use Monolog\Formatter\NormalizerFormatter;
use Monolog\Test\TestCase;
use Monolog\Level;
use Elastica\Client;
use Elastica\Request;
use Elastica\Response;
use PHPUnit\Framework\Attributes\DataProvider;
use PHPUnit\Framework\Attributes\Group;

#[Group('Elastica')]
class ElasticaHandlerTest extends TestCase
{
    /**
     * @var Client mock
     */
    protected Client $client;

/**
     * @var array Default handler options
     */
    protected array $options = [
        'index' => 'my_index',
        'type'  => 'doc_type',
    ];

public function setUp(): void
    {
        // Elastica lib required
        if (!class_exists("Elastica\Client")) {
            $this->markTestSkipped("ruflin/elastica not installed");
        }

// base mock Elastica Client object
        $this->client = $this->getMockBuilder('Elastica\Client')
            ->onlyMethods(['addDocuments'])
            ->disableOriginalConstructor()
            ->getMock();
    }

public function tearDown(): void
    {
        parent::tearDown();

unset($this->client);
    }

/**
     * @covers Monolog\Handler\ElasticaHandler::write
     * @covers Monolog\Handler\ElasticaHandler::handleBatch
     * @covers Monolog\Handler\ElasticaHandler::bulkSend
     * @covers Monolog\Handler\ElasticaHandler::getDefaultFormatter
     */
    public function testHandle()
    {
        // log message
        $msg = $this->getRecord(Level::Error, 'log', context: ['foo' => 7, 'bar', 'class' => new \stdClass], datetime: new \DateTimeImmutable("@0"));

// format expected result
        $formatter = new ElasticaFormatter($this->options['index'], $this->options['type']);
        $expected = [$formatter->format($msg)];

// setup ES client mock
        $this->client->expects($this->any())
            ->method('addDocuments')
            ->with($expected);

// perform tests
        $handler = new ElasticaHandler($this->client, $this->options);
        $handler->handle($msg);
        $handler->handleBatch([$msg]);
    }

/**
     * @covers Monolog\Handler\ElasticaHandler::setFormatter
     */
    public function testSetFormatter()
    {
        $handler = new ElasticaHandler($this->client);
        $formatter = new ElasticaFormatter('index_new', 'type_new');
        $handler->setFormatter($formatter);
        $this->assertInstanceOf('Monolog\Formatter\ElasticaFormatter', $handler->getFormatter());
        $this->assertEquals('index_new', $handler->getFormatter()->getIndex());
        $this->assertEquals('type_new', $handler->getFormatter()->getType());
    }

/**
     * @covers                   Monolog\Handler\ElasticaHandler::setFormatter
     */
    public function testSetFormatterInvalid()
    {
        $handler = new ElasticaHandler($this->client);
        $formatter = new NormalizerFormatter();

$this->expectException(\InvalidArgumentException::class);
        $this->expectExceptionMessage('ElasticaHandler is only compatible with ElasticaFormatter');

$handler->setFormatter($formatter);
    }

/**
     * @covers Monolog\Handler\ElasticaHandler::__construct
     * @covers Monolog\Handler\ElasticaHandler::getOptions
     */
    public function testOptions()
    {
        $expected = [
            'index' => $this->options['index'],
            'type' => $this->options['type'],
            'ignore_error' => false,
        ];
        $handler = new ElasticaHandler($this->client, $this->options);
        $this->assertEquals($expected, $handler->getOptions());
    }

/**
     * @covers       Monolog\Handler\ElasticaHandler::bulkSend
     */
    #[DataProvider('providerTestConnectionErrors')]
    public function testConnectionErrors($ignore, $expectedError)
    {
        $clientOpts = ['host' => '127.0.0.1', 'port' => 1];
        $client = new Client($clientOpts);
        $handlerOpts = ['ignore_error' => $ignore];
        $handler = new ElasticaHandler($client, $handlerOpts);

if ($expectedError) {
            $this->expectException($expectedError[0]);
            $this->expectExceptionMessage($expectedError[1]);
            $handler->handle($this->getRecord());
        } else {
            $this->assertFalse($handler->handle($this->getRecord()));
        }
    }

public static function providerTestConnectionErrors(): array
    {
        return [
            [false, ['RuntimeException', 'Error sending messages to Elasticsearch']],
            [true, false],
        ];
    }

/**
     * Integration test using localhost Elastic Search server version 7+
     *
     * @covers Monolog\Handler\ElasticaHandler::__construct
     * @covers Monolog\Handler\ElasticaHandler::handleBatch
     * @covers Monolog\Handler\ElasticaHandler::bulkSend
     * @covers Monolog\Handler\ElasticaHandler::getDefaultFormatter
     */
    public function testHandleIntegrationNewESVersion()
    {
        $msg = $this->getRecord(Level::Error, 'log', context: ['foo' => 7, 'bar', 'class' => new \stdClass], datetime: new \DateTimeImmutable("@0"));

$expected = (array) $msg;
        $expected['datetime'] = $msg['datetime']->format(\DateTime::ISO8601);
        $expected['context'] = [
            'class' => '[object] (stdClass: {})',
            'foo' => 7,
            0 => 'bar',
        ];

$clientOpts = ['url' => 'http://elastic:changeme@127.0.0.1:9200'];
        $client = new Client($clientOpts);

$handler = new ElasticaHandler($client, $this->options);

try {
            $handler->handleBatch([$msg]);
        } catch (\RuntimeException $e) {
            $this->markTestSkipped("Cannot connect to Elastic Search server on localhost");
        }

// check document id from ES server response
        $documentId = $this->getCreatedDocId($client->getLastResponse());
        $this->assertNotEmpty($documentId, 'No elastic document id received');

// retrieve document source from ES and validate
        $document = $this->getDocSourceFromElastic(
            $client,
            $this->options['index'],
            null,
            $documentId
        );
        $this->assertEquals($expected, $document);

// remove test index from ES
        $client->request("/{$this->options['index']}", Request::DELETE);
    }

/**
     * Return last created document id from ES response
     * @param Response $response Elastica Response object
     */
    protected function getCreatedDocId(Response $response): ?string
    {
        $data = $response->getData();

if (!empty($data['items'][0]['index']['_id'])) {
            return $data['items'][0]['index']['_id'];
        }

var_dump('Unexpected response: ', $data);

return null;
    }

/**
     * Retrieve document by id from Elasticsearch
     * @param Client  $client Elastica client
     * @param ?string $type
     */
    protected function getDocSourceFromElastic(Client $client, string $index, $type, string $documentId): array
    {
        if ($type === null) {
            $path  = "/{$index}/_doc/{$documentId}";
        } else {
            $path  = "/{$index}/{$type}/{$documentId}";
        }
        $resp = $client->request($path, Request::GET);
        $data = $resp->getData();
        if (!empty($data['_source'])) {
            return $data['_source'];
        }

return [];
    }
}