OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	08/12/2024 10:35:58 AM	rwxr-xr-x
📄 AbstractHandler.php	2.71 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 AbstractProcessingHandler.php	1.52 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 AbstractSyslogHandler.php	3.24 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 AmqpHandler.php	5.12 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 BrowserConsoleHandler.php	9.3 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 BufferHandler.php	4.6 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 ChromePHPHandler.php	5.21 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 CouchDBHandler.php	2.64 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 CubeHandler.php	5.48 KB	08/12/2024 10:35:56 AM	rw-r--r--
📁 Curl	-	08/12/2024 10:36:32 AM	rwxr-xr-x
📄 DeduplicationHandler.php	6.42 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 DoctrineCouchDBHandler.php	1.17 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 DynamoDbHandler.php	1.97 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 ElasticaHandler.php	3.72 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 ElasticsearchHandler.php	7.01 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 ErrorLogHandler.php	2.71 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 FallbackGroupHandler.php	1.75 KB	08/12/2024 10:35:56 AM	rw-r--r--
📄 FilterHandler.php	7.12 KB	08/12/2024 10:35:57 AM	rw-r--r--
📁 FingersCrossed	-	08/12/2024 10:36:32 AM	rwxr-xr-x
📄 FingersCrossedHandler.php	8.21 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 FirePHPHandler.php	5.2 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 FleepHookHandler.php	3.57 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 FlowdockHandler.php	3.52 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 FormattableHandlerInterface.php	791 bytes	08/12/2024 10:35:57 AM	rw-r--r--
📄 FormattableHandlerTrait.php	1.29 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 GelfHandler.php	1.48 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 GroupHandler.php	3.32 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 Handler.php	1.27 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 HandlerInterface.php	2.79 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 HandlerWrapper.php	3.41 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 IFTTTHandler.php	2.29 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 InsightOpsHandler.php	2.11 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 LogEntriesHandler.php	1.93 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 LogglyHandler.php	4.17 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 LogmaticHandler.php	2.67 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 MailHandler.php	2.28 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 MandrillHandler.php	2.56 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 MissingExtensionException.php	494 bytes	08/12/2024 10:35:57 AM	rw-r--r--
📄 MongoDBHandler.php	2.39 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 NativeMailerHandler.php	5.05 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 NewRelicHandler.php	5.88 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 NoopHandler.php	950 bytes	08/12/2024 10:35:57 AM	rw-r--r--
📄 NullHandler.php	1.35 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 OverflowHandler.php	4.35 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 PHPConsoleHandler.php	12.22 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 ProcessHandler.php	5.24 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 ProcessableHandlerInterface.php	1.2 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 ProcessableHandlerTrait.php	1.65 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 PsrHandler.php	2.5 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 PushoverHandler.php	8.16 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 RedisHandler.php	2.76 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 RedisPubSubHandler.php	1.71 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 RollbarHandler.php	3.65 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 RotatingFileHandler.php	7.02 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 SamplingHandler.php	3.94 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 SendGridHandler.php	2.97 KB	08/12/2024 10:35:57 AM	rw-r--r--
📁 Slack	-	08/12/2024 10:36:32 AM	rwxr-xr-x
📄 SlackHandler.php	7.25 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 SlackWebhookHandler.php	3.92 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 SocketHandler.php	12.27 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 SqsHandler.php	1.77 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 StreamHandler.php	6.83 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 SymfonyMailerHandler.php	3.55 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 SyslogHandler.php	1.71 KB	08/12/2024 10:35:57 AM	rw-r--r--
📁 SyslogUdp	-	08/12/2024 10:36:32 AM	rwxr-xr-x
📄 SyslogUdpHandler.php	4.78 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 TelegramBotHandler.php	9.51 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 TestHandler.php	6.51 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 WebRequestRecognizerTrait.php	527 bytes	08/12/2024 10:35:57 AM	rw-r--r--
📄 WhatFailureGroupHandler.php	1.94 KB	08/12/2024 10:35:57 AM	rw-r--r--
📄 ZendMonitorHandler.php	2.87 KB	08/12/2024 10:35:57 AM	rw-r--r--

Editing: SocketHandler.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\Level;
use Monolog\LogRecord;

/**
 * Stores to any socket - uses fsockopen() or pfsockopen().
 *
 * @author Pablo de Leon Belloc <pablolb@gmail.com>
 * @see    http://php.net/manual/en/function.fsockopen.php
 */
class SocketHandler extends AbstractProcessingHandler
{
    private string $connectionString;
    private float $connectionTimeout;
    /** @var resource|null */
    private $resource;
    private float $timeout;
    private float $writingTimeout;
    private int|null $lastSentBytes = null;
    private int|null $chunkSize;
    private bool $persistent;
    private int|null $errno = null;
    private string|null $errstr = null;
    private float|null $lastWritingAt = null;

/**
     * @param string     $connectionString  Socket connection string
     * @param bool       $persistent        Flag to enable/disable persistent connections
     * @param float      $timeout           Socket timeout to wait until the request is being aborted
     * @param float      $writingTimeout    Socket timeout to wait until the request should've been sent/written
     * @param float|null $connectionTimeout Socket connect timeout to wait until the connection should've been
     *                                      established
     * @param int|null   $chunkSize         Sets the chunk size. Only has effect during connection in the writing cycle
     *
     * @throws \InvalidArgumentException If an invalid timeout value (less than 0) is passed.
     */
    public function __construct(
        string $connectionString,
        $level = Level::Debug,
        bool $bubble = true,
        bool $persistent = false,
        float $timeout = 0.0,
        float $writingTimeout = 10.0,
        ?float $connectionTimeout = null,
        ?int $chunkSize = null
    ) {
        parent::__construct($level, $bubble);
        $this->connectionString = $connectionString;

if ($connectionTimeout !== null) {
            $this->validateTimeout($connectionTimeout);
        }

$this->connectionTimeout = $connectionTimeout ?? (float) \ini_get('default_socket_timeout');
        $this->persistent = $persistent;
        $this->validateTimeout($timeout);
        $this->timeout = $timeout;
        $this->validateTimeout($writingTimeout);
        $this->writingTimeout = $writingTimeout;
        $this->chunkSize = $chunkSize;
    }

/**
     * Connect (if necessary) and write to the socket
     *
     * @inheritDoc
     *
     * @throws \UnexpectedValueException
     * @throws \RuntimeException
     */
    protected function write(LogRecord $record): void
    {
        $this->connectIfNotConnected();
        $data = $this->generateDataStream($record);
        $this->writeToSocket($data);
    }

/**
     * We will not close a PersistentSocket instance so it can be reused in other requests.
     */
    public function close(): void
    {
        if (!$this->isPersistent()) {
            $this->closeSocket();
        }
    }

/**
     * Close socket, if open
     */
    public function closeSocket(): void
    {
        if (\is_resource($this->resource)) {
            fclose($this->resource);
            $this->resource = null;
        }
    }

/**
     * Set socket connection to be persistent. It only has effect before the connection is initiated.
     *
     * @return $this
     */
    public function setPersistent(bool $persistent): self
    {
        $this->persistent = $persistent;

return $this;
    }

/**
     * Set connection timeout.  Only has effect before we connect.
     *
     * @see http://php.net/manual/en/function.fsockopen.php
     * @return $this
     */
    public function setConnectionTimeout(float $seconds): self
    {
        $this->validateTimeout($seconds);
        $this->connectionTimeout = $seconds;

return $this;
    }

/**
     * Set write timeout. Only has effect before we connect.
     *
     * @see http://php.net/manual/en/function.stream-set-timeout.php
     * @return $this
     */
    public function setTimeout(float $seconds): self
    {
        $this->validateTimeout($seconds);
        $this->timeout = $seconds;

return $this;
    }

/**
     * Set writing timeout. Only has effect during connection in the writing cycle.
     *
     * @param  float $seconds 0 for no timeout
     * @return $this
     */
    public function setWritingTimeout(float $seconds): self
    {
        $this->validateTimeout($seconds);
        $this->writingTimeout = $seconds;

return $this;
    }

/**
     * Set chunk size. Only has effect during connection in the writing cycle.
     *
     * @return $this
     */
    public function setChunkSize(int $bytes): self
    {
        $this->chunkSize = $bytes;

return $this;
    }

/**
     * Get current connection string
     */
    public function getConnectionString(): string
    {
        return $this->connectionString;
    }

/**
     * Get persistent setting
     */
    public function isPersistent(): bool
    {
        return $this->persistent;
    }

/**
     * Get current connection timeout setting
     */
    public function getConnectionTimeout(): float
    {
        return $this->connectionTimeout;
    }

/**
     * Get current in-transfer timeout
     */
    public function getTimeout(): float
    {
        return $this->timeout;
    }

/**
     * Get current local writing timeout
     */
    public function getWritingTimeout(): float
    {
        return $this->writingTimeout;
    }

/**
     * Get current chunk size
     */
    public function getChunkSize(): ?int
    {
        return $this->chunkSize;
    }

/**
     * Check to see if the socket is currently available.
     *
     * UDP might appear to be connected but might fail when writing.  See http://php.net/fsockopen for details.
     */
    public function isConnected(): bool
    {
        return \is_resource($this->resource)
            && !feof($this->resource);  // on TCP - other party can close connection.
    }

/**
     * Wrapper to allow mocking
     *
     * @return resource|false
     */
    protected function pfsockopen()
    {
        return @pfsockopen($this->connectionString, -1, $this->errno, $this->errstr, $this->connectionTimeout);
    }

/**
     * Wrapper to allow mocking
     *
     * @return resource|false
     */
    protected function fsockopen()
    {
        return @fsockopen($this->connectionString, -1, $this->errno, $this->errstr, $this->connectionTimeout);
    }

/**
     * Wrapper to allow mocking
     *
     * @see http://php.net/manual/en/function.stream-set-timeout.php
     */
    protected function streamSetTimeout(): bool
    {
        $seconds = floor($this->timeout);
        $microseconds = round(($this->timeout - $seconds) * 1e6);

if (!\is_resource($this->resource)) {
            throw new \LogicException('streamSetTimeout called but $this->resource is not a resource');
        }

return stream_set_timeout($this->resource, (int) $seconds, (int) $microseconds);
    }

/**
     * Wrapper to allow mocking
     *
     * @see http://php.net/manual/en/function.stream-set-chunk-size.php
     *
     * @return int|false
     */
    protected function streamSetChunkSize(): int|bool
    {
        if (!\is_resource($this->resource)) {
            throw new \LogicException('streamSetChunkSize called but $this->resource is not a resource');
        }

if (null === $this->chunkSize) {
            throw new \LogicException('streamSetChunkSize called but $this->chunkSize is not set');
        }

return stream_set_chunk_size($this->resource, $this->chunkSize);
    }

/**
     * Wrapper to allow mocking
     *
     * @return int|false
     */
    protected function fwrite(string $data): int|bool
    {
        if (!\is_resource($this->resource)) {
            throw new \LogicException('fwrite called but $this->resource is not a resource');
        }

return @fwrite($this->resource, $data);
    }

/**
     * Wrapper to allow mocking
     *
     * @return mixed[]|bool
     */
    protected function streamGetMetadata(): array|bool
    {
        if (!\is_resource($this->resource)) {
            throw new \LogicException('streamGetMetadata called but $this->resource is not a resource');
        }

return stream_get_meta_data($this->resource);
    }

private function validateTimeout(float $value): void
    {
        if ($value < 0) {
            throw new \InvalidArgumentException("Timeout must be 0 or a positive float (got $value)");
        }
    }

private function connectIfNotConnected(): void
    {
        if ($this->isConnected()) {
            return;
        }
        $this->connect();
    }

protected function generateDataStream(LogRecord $record): string
    {
        return (string) $record->formatted;
    }

/**
     * @return resource|null
     */
    protected function getResource()
    {
        return $this->resource;
    }

private function connect(): void
    {
        $this->createSocketResource();
        $this->setSocketTimeout();
        $this->setStreamChunkSize();
    }

private function createSocketResource(): void
    {
        if ($this->isPersistent()) {
            $resource = $this->pfsockopen();
        } else {
            $resource = $this->fsockopen();
        }
        if (\is_bool($resource)) {
            throw new \UnexpectedValueException("Failed connecting to $this->connectionString ($this->errno: $this->errstr)");
        }
        $this->resource = $resource;
    }

private function setSocketTimeout(): void
    {
        if (!$this->streamSetTimeout()) {
            throw new \UnexpectedValueException("Failed setting timeout with stream_set_timeout()");
        }
    }

private function setStreamChunkSize(): void
    {
        if (null !== $this->chunkSize && false === $this->streamSetChunkSize()) {
            throw new \UnexpectedValueException("Failed setting chunk size with stream_set_chunk_size()");
        }
    }

private function writeToSocket(string $data): void
    {
        $length = \strlen($data);
        $sent = 0;
        $this->lastSentBytes = $sent;
        while ($this->isConnected() && $sent < $length) {
            if (0 == $sent) {
                $chunk = $this->fwrite($data);
            } else {
                $chunk = $this->fwrite(substr($data, $sent));
            }
            if ($chunk === false) {
                throw new \RuntimeException("Could not write to socket");
            }
            $sent += $chunk;
            $socketInfo = $this->streamGetMetadata();
            if (\is_array($socketInfo) && (bool) $socketInfo['timed_out']) {
                throw new \RuntimeException("Write timed-out");
            }

if ($this->writingIsTimedOut($sent)) {
                throw new \RuntimeException("Write timed-out, no data sent for `{$this->writingTimeout}` seconds, probably we got disconnected (sent $sent of $length)");
            }
        }
        if (!$this->isConnected() && $sent < $length) {
            throw new \RuntimeException("End-of-file reached, probably we got disconnected (sent $sent of $length)");
        }
    }

private function writingIsTimedOut(int $sent): bool
    {
        // convert to ms
        if (0.0 == $this->writingTimeout) {
            return false;
        }

if ($sent !== $this->lastSentBytes) {
            $this->lastWritingAt = microtime(true);
            $this->lastSentBytes = $sent;

return false;
        } else {
            usleep(100);
        }

if ((microtime(true) - (float) $this->lastWritingAt) >= $this->writingTimeout) {
            $this->closeSocket();

return true;
        }

return false;
    }
}