Padosoft\SuperCache\Console\CleanOrphanedKeysCommand::handleOnCluster()

Complexity

Conditions	9
Paths	5

Size

Total Lines	53
Code Lines	24

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function handleOnCluster(): void
    {
        // Tenta di acquisire un lock globale
        $lockAcquired = $this->superCache->lock('clean_orphans:lock', $this->option('connection_name'), 300);
        if (!$lockAcquired) {
            return;
        }
        // Purtroppo lo scan non funziona sul cluster per cui va eseguito su ogni nodo (master)
        $array_nodi = $this->getClusterNodesService->getClusterNodes($this->option('connection_name'));

        foreach ($array_nodi as $node) {
            [$host, $port] = explode(':', $node);

            // Per ogni shard vado a cercare i bussolotti (SET) dei tags che contengono le chiavi
            for ($i = 0; $i < $this->numShards; $i++) {
                // Inserisco nel pattern supercache: così sonop sicura di trovare solo i SET che riguardano il contesto della supercache
                $shard_key = '*' . config('supercache.prefix') . 'tag:*:shard:' . $i;
                // Creo una connessione persistente perchè considerando la durata dell'elaborazione si evita che dopo 30 secondi muoia tutto!
                $connection = $this->redis->getNativeRedisConnection($this->option('connection_name'), $host, $port);

                $cursor = null;
                do {
                    $response = $connection['connection']->scan($cursor, $shard_key);

                    if ($response === false) {
                        //Nessuna chiave trovata ...
                        break;
                    }

                    foreach ($response as $key) {
                        // Ho trovato un bussolotto che matcha, vado a recuperare i membri del SET
                        $members = $connection['connection']->sMembers($key);
                        foreach ($members as $member) {
                            // Controllo che la chiave sia morta, ma ATTENZIONE non posso usare la connessione che ho già perchè sono su un singolo nodo, mentre nel bussolotto potrebbero esserci chiavi in sharding diversi
                            if ($this->redis->getRedisConnection($this->option('connection_name'))->exists($member)) {
                                // La chiave è viva! vado avanti
                                continue;
                            }
                            // Altrimenti rimuovo i cadaveri dal bussolotto e dai tags
                            // Qui posso usare la connessione che già ho in quanto sto modificando il bussolotto che sicuramente è nello shard corretto del nodo
                            $connection['connection']->srem($key, $member);
                            // Rimuovo anche i tag, che però potrebbero essere in un altro nodo quindi uso una nuova connessione
                            $this->redis->getRedisConnection($this->option('connection_name'))->del($member . ':tags');
                        }
                    }
                } while ($cursor !== 0); // Continua fino a completamento

                // Chiudo la connessione
                $connection['connection']->close();
            }
        }
        // Rilascio il lock globale
        $this->superCache->unLock('clean_orphans:lock', $this->option('connection_name'));
    }