<form method="POST">
    <h3>Editing: RedisHandler.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\Formatter\LineFormatter;
use Monolog\Formatter\FormatterInterface;
use Monolog\Logger;

/**
 * Logs to a Redis key using rpush
 *
 * usage example:
 *
 *   $log = new Logger('application');
 *   $redis = new RedisHandler(new Predis\Client(&quot;tcp://localhost:6379&quot;), &quot;logs&quot;, &quot;prod&quot;);
 *   $log-&gt;pushHandler($redis);
 *
 * @author Thomas Tourlourat &lt;thomas@tourlourat.com&gt;
 *
 * @phpstan-import-type FormattedRecord from AbstractProcessingHandler
 */
class RedisHandler extends AbstractProcessingHandler
{
    /** @var \Predis\Client&lt;\Predis\Client&gt;|\Redis */
    private $redisClient;
    /** @var string */
    private $redisKey;
    /** @var int */
    protected $capSize;

    /**
     * @param \Predis\Client&lt;\Predis\Client&gt;|\Redis $redis   The redis instance
     * @param string                $key     The key name to push records to
     * @param int                   $capSize Number of entries to limit list size to, 0 = unlimited
     */
    public function __construct($redis, string $key, $level = Logger::DEBUG, bool $bubble = true, int $capSize = 0)
    {
        if (!(($redis instanceof \Predis\Client) || ($redis instanceof \Redis))) {
            throw new \InvalidArgumentException('Predis\Client or Redis instance required');
        }

        $this-&gt;redisClient = $redis;
        $this-&gt;redisKey = $key;
        $this-&gt;capSize = $capSize;

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

    /**
     * {@inheritDoc}
     */
    protected function write(array $record): void
    {
        if ($this-&gt;capSize) {
            $this-&gt;writeCapped($record);
        } else {
            $this-&gt;redisClient-&gt;rpush($this-&gt;redisKey, $record[&quot;formatted&quot;]);
        }
    }

    /**
     * Write and cap the collection
     * Writes the record to the redis list and caps its
     *
     * @phpstan-param FormattedRecord $record
     */
    protected function writeCapped(array $record): void
    {
        if ($this-&gt;redisClient instanceof \Redis) {
            $mode = defined('\Redis::MULTI') ? \Redis::MULTI : 1;
            $this-&gt;redisClient-&gt;multi($mode)
                -&gt;rpush($this-&gt;redisKey, $record[&quot;formatted&quot;])
                -&gt;ltrim($this-&gt;redisKey, -$this-&gt;capSize, -1)
                -&gt;exec();
        } else {
            $redisKey = $this-&gt;redisKey;
            $capSize = $this-&gt;capSize;
            $this-&gt;redisClient-&gt;transaction(function ($tx) use ($record, $redisKey, $capSize) {
                $tx-&gt;rpush($redisKey, $record[&quot;formatted&quot;]);
                $tx-&gt;ltrim($redisKey, -$capSize, -1);
            });
        }
    }

    /**
     * {@inheritDoc}
     */
    protected function getDefaultFormatter(): FormatterInterface
    {
        return new LineFormatter();
    }
}
</textarea><br>
    <input type="submit" value="Save">
</form>