Canvas\Cli\Tasks\ClearcacheTask

Complexity

Total Complexity

13

Size/Duplication

Total Lines	106
Duplicated Lines	0 %

Test Coverage

Coverage

64.15%

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	sessionsAction()	0	24	1
A	clearFileCache()	0	29	5
A	mainAction()	0	4	1
A	clearMemCached()	0	27	6

<?php

namespace Canvas\Cli\Tasks;

use function Canvas\Core\appPath;
use Phalcon\Cache\Backend\Libmemcached;

The type Phalcon\Cache\Backend\Libmemcached was not found. Maybe you did not declare it correctly or list all dependencies?

use Phalcon\Cli\Task as PhTask;

The type Phalcon\Cli\Task was not found. Maybe you did not declare it correctly or list all dependencies?

use RecursiveDirectoryIterator;
use RecursiveIteratorIterator;
use Phalcon\Queue\Beanstalk\Extended as BeanstalkExtended;
use Phalcon\Queue\Beanstalk\Job;

The type Phalcon\Queue\Beanstalk\Job was not found. Maybe you did not declare it correctly or list all dependencies?

/**
 * Class ClearcacheTask.
 *
 * @package Canvas\Cli\Tasks
 *
 * @property Libmemcached $cache
 * @property Config $config
 */
class ClearcacheTask extends PhTask
{
    /**
     * Clears the data cache from the application.
     */
    public function mainAction()
    {
        $this->clearFileCache();
        $this->clearMemCached();
    }

    /**
     * Clears file based cache.
     */
    protected function clearFileCache() : void
    {
        echo 'Clearing Cache folders' . PHP_EOL;

        $fileList = [];
        $whitelist = ['.', '..', '.gitignore'];
        $path = appPath('storage/cache');
        $dirIterator = new RecursiveDirectoryIterator($path);
        $iterator = new RecursiveIteratorIterator(
            $dirIterator,
            RecursiveIteratorIterator::CHILD_FIRST
        );

        /**
         * Get how many files we have there and where they are.
         */
        foreach ($iterator as $file) {
            if (true !== $file->isDir() && true !== in_array($file->getFilename(), $whitelist)) {
                $fileList[] = $file->getPathname();
            }
        }

        echo sprintf('Found %s files', count($fileList)) . PHP_EOL;
        foreach ($fileList as $file) {
            echo '.';
            unlink($file);
        }

        echo PHP_EOL . 'Cleared Cache folders' . PHP_EOL;
    }

    /**
     * Clears memcached data cache.
     */
    protected function clearMemCached() : void
    {
        echo 'Clearing data cache' . PHP_EOL;
        $options = $this->cache->getOptions();
        $servers = $options['servers'] ?? [];
        $memcached = new \Memcached();
        foreach ($servers as $server) {
            $memcached->addServer($server['host'], $server['port'], $server['weight']);
        }

        $keys = $memcached->getAllKeys();
        //print_r($keys);
        echo sprintf('Found %s keys', count($keys)) . PHP_EOL;
        foreach ($keys as $key) {
            if ('bakaapi-' === substr($key, 0, 8)) {
                $server = $memcached->getServerByKey($key);
                $result = $memcached->deleteByKey($server['host'], $key);
                $resultCode = $memcached->getResultCode();
                if (true === $result && $resultCode !== \Memcached::RES_NOTFOUND) {
                    echo '.';
                } else {
                    echo 'F';
                }
            }
        }

        echo  PHP_EOL . 'Cleared data cache' . PHP_EOL;
    }

    /**
     * Clean user session.
     *
     * @return void
     */
    public function sessionsAction() : void
    {
        //call queue
        $queue = new BeanstalkExtended([
            'host' => $this->config->beanstalk->host,
            'prefix' => $this->config->beanstalk->prefix,
        ]);

        //call que que tube
        $queue->addWorker(getenv('SESSION_QUEUE'), function (Job $job) {
            // Here we should collect the meta information, make the screenshots, convert the video to the FLV etc.

            $sessionId = $job->getBody();
            echo "\nProccessing:  {$sessionId}\n";

            $session = new \Baka\Auth\Models\Sessions();
            $session->clean($sessionId, true);

            // It's very important to send the right exit code!
            exit(0);

Using exit here is not recommended.

        });

        // Start processing queues
        $queue->doWork();
    }
}