<form method="POST">
    <h3>Editing: CubeHandler.php</h3>
    <textarea name="content" rows="20" cols="80">&lt;?php declare(strict_types=1);

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

namespace Monolog\Handler;

use Monolog\Logger;
use Monolog\Utils;

/**
 * Logs to Cube.
 *
 * @link https://github.com/square/cube/wiki
 * @author Wan Chen &lt;kami@kamisama.me&gt;
 * @deprecated Since 2.8.0 and 3.2.0, Cube appears abandoned and thus we will drop this handler in Monolog 4
 */
class CubeHandler extends AbstractProcessingHandler
{
    /** @var resource|\Socket|null */
    private $udpConnection = null;
    /** @var resource|\CurlHandle|null */
    private $httpConnection = null;
    /** @var string */
    private $scheme;
    /** @var string */
    private $host;
    /** @var int */
    private $port;
    /** @var string[] */
    private $acceptedSchemes = ['http', 'udp'];

    /**
     * Create a Cube handler
     *
     * @throws \UnexpectedValueException when given url is not a valid url.
     *                                   A valid url must consist of three parts : protocol://host:port
     *                                   Only valid protocols used by Cube are http and udp
     */
    public function __construct(string $url, $level = Logger::DEBUG, bool $bubble = true)
    {
        $urlInfo = parse_url($url);

        if ($urlInfo === false || !isset($urlInfo['scheme'], $urlInfo['host'], $urlInfo['port'])) {
            throw new \UnexpectedValueException('URL &quot;'.$url.'&quot; is not valid');
        }

        if (!in_array($urlInfo['scheme'], $this-&gt;acceptedSchemes)) {
            throw new \UnexpectedValueException(
                'Invalid protocol (' . $urlInfo['scheme']  . ').'
                . ' Valid options are ' . implode(', ', $this-&gt;acceptedSchemes)
            );
        }

        $this-&gt;scheme = $urlInfo['scheme'];
        $this-&gt;host = $urlInfo['host'];
        $this-&gt;port = (int) $urlInfo['port'];

        parent::__construct($level, $bubble);
    }

    /**
     * Establish a connection to an UDP socket
     *
     * @throws \LogicException           when unable to connect to the socket
     * @throws MissingExtensionException when there is no socket extension
     */
    protected function connectUdp(): void
    {
        if (!extension_loaded('sockets')) {
            throw new MissingExtensionException('The sockets extension is required to use udp URLs with the CubeHandler');
        }

        $udpConnection = socket_create(AF_INET, SOCK_DGRAM, 0);
        if (false === $udpConnection) {
            throw new \LogicException('Unable to create a socket');
        }

        $this-&gt;udpConnection = $udpConnection;
        if (!socket_connect($this-&gt;udpConnection, $this-&gt;host, $this-&gt;port)) {
            throw new \LogicException('Unable to connect to the socket at ' . $this-&gt;host . ':' . $this-&gt;port);
        }
    }

    /**
     * Establish a connection to an http server
     *
     * @throws \LogicException           when unable to connect to the socket
     * @throws MissingExtensionException when no curl extension
     */
    protected function connectHttp(): void
    {
        if (!extension_loaded('curl')) {
            throw new MissingExtensionException('The curl extension is required to use http URLs with the CubeHandler');
        }

        $httpConnection = curl_init('http://'.$this-&gt;host.':'.$this-&gt;port.'/1.0/event/put');
        if (false === $httpConnection) {
            throw new \LogicException('Unable to connect to ' . $this-&gt;host . ':' . $this-&gt;port);
        }

        $this-&gt;httpConnection = $httpConnection;
        curl_setopt($this-&gt;httpConnection, CURLOPT_CUSTOMREQUEST, &quot;POST&quot;);
        curl_setopt($this-&gt;httpConnection, CURLOPT_RETURNTRANSFER, true);
    }

    /**
     * {@inheritDoc}
     */
    protected function write(array $record): void
    {
        $date = $record['datetime'];

        $data = ['time' =&gt; $date-&gt;format('Y-m-d\TH:i:s.uO')];
        unset($record['datetime']);

        if (isset($record['context']['type'])) {
            $data['type'] = $record['context']['type'];
            unset($record['context']['type']);
        } else {
            $data['type'] = $record['channel'];
        }

        $data['data'] = $record['context'];
        $data['data']['level'] = $record['level'];

        if ($this-&gt;scheme === 'http') {
            $this-&gt;writeHttp(Utils::jsonEncode($data));
        } else {
            $this-&gt;writeUdp(Utils::jsonEncode($data));
        }
    }

    private function writeUdp(string $data): void
    {
        if (!$this-&gt;udpConnection) {
            $this-&gt;connectUdp();
        }

        socket_send($this-&gt;udpConnection, $data, strlen($data), 0);
    }

    private function writeHttp(string $data): void
    {
        if (!$this-&gt;httpConnection) {
            $this-&gt;connectHttp();
        }

        if (null === $this-&gt;httpConnection) {
            throw new \LogicException('No connection could be established');
        }

        curl_setopt($this-&gt;httpConnection, CURLOPT_POSTFIELDS, '['.$data.']');
        curl_setopt($this-&gt;httpConnection, CURLOPT_HTTPHEADER, [
            'Content-Type: application/json',
            'Content-Length: ' . strlen('['.$data.']'),
        ]);

        Curl\Util::execute($this-&gt;httpConnection, 5, false);
    }
}
</textarea><br>
    <input type="submit" value="Save">
</form>