DNSProvider.php

<?php

namespace App\Di\Provider;

use Clue\React\Redis\Client;
use Clue\React\Redis\Factory;
use Ray\Di\Di\Inject;
use Ray\Di\ProviderInterface;
use React\Cache\CacheInterface;
use React\Dns\Protocol\BinaryDumper;
use React\Dns\Protocol\Parser;
use React\Dns\Query\CachedExecutor;
use React\Dns\Query\Executor;
use React\Dns\Query\RecordCache;
use React\Dns\Query\RetryExecutor;
use React\Dns\Resolver\Resolver;
use React\EventLoop\LoopInterface;
use WyriHaximus\React\Cache\Redis;
use function React\Promise\reject;
use function React\Promise\resolve;

class DNSProvider implements ProviderInterface
{
    protected $loop;

    /**
     * @Inject
     */
    public function __construct(LoopInterface $loop)
    {
        $this->loop = $loop;
    }

    public function get()
    {
        return new Resolver(
            '8.8.8.8:53',
            new CachedExecutor(
                new RetryExecutor(
                    new Executor(
                        $this->loop,
                        new Parser(),
                        new BinaryDumper()
                    )
                ),
                new RecordCache(new class($this->loop) implements CacheInterface {
                    /**
                     * @var Redis
                     */
                    private $redis;

                    private $data = [];

                    public function __construct(LoopInterface $loop)
                    {
                        (new Factory($loop))->createClient()->then(function (Client $client) {
                            $this->redis = new Redis($client, 'react:cache:cns:');
                            foreach ($this->data as $key => $value) {
                                $this->redis->set($key, $value);
                            }
                            $this->data = [];
                        });
                    }

                    public function get($key)
                    {
                        if ($this->redis instanceof Redis) {
                            return $this->redis->get($key);
                        }

                        if (isset($this->data[$key])) {
                            return resolve($this->data[$key]);
                        }

                        return reject();
                    }

                    public function set($key, $value)
                    {
                        if ($this->redis instanceof Redis) {
                            $this->redis->set($key, $value);
                            return;
                        }

                        $this->data[$key] = $value;
                    }

                    public function remove($key)
                    {
                        if ($this->redis instanceof Redis) {
                            $this->redis->remove($key);
                            return;
                        }

                        if (isset($this->data[$key])) {
                            unset($this->data[$key]);
                        }
                    }
                })
            )
        );
    }
}