PhpCache\CacheServer\ActionHandler

Complexity

Total Complexity

9

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	handleDelete()	0	6	1
A	handleSet()	0	6	1
A	__invoke()	0	9	2
A	handleGet()	0	11	2
A	handleGetEntries()	0	11	2
A	handleQuit()	0	3	1

<?php

namespace PhpCache\CacheServer;

/**
 * Description of ActionHandler.
 *
 * @author dude920228
 */
class ActionHandler
{
    public function __invoke($data, $bucket, $ioHandler, $connection, $server)
    {
        $action = $data['action'];
        $functionName = 'handle'.ucfirst($action);
        if (!method_exists($this, $functionName)) {
            return false;
        }

        return call_user_func_array([$this, $functionName], [$data, $bucket, $ioHandler, $connection, $server]);
    }

    private function handleSet($data, $bucket, $ioHandler, $connection, $server)
    {
        $package = $data['message'];
        $success = $bucket->store($data['key'], $package);

        return $success;
    }

    private function handleGet($data, $bucket, $ioHandler, $connection, $server)
    {
        $key = $data['key'];
        $package = $bucket->get($key);
        if ($package === false) {
            return false;
        }
        $dataToSend = serialize($package);
        $ioHandler->writeToSocket($connection, $dataToSend);

        return true;
    }

    private function handleDelete($data, $bucket, $ioHandler, $connection, $server)
    {
        $key = $data['key'];
        $success = $bucket->delete($key);

        return $success;
    }

    private function handleGetEntries($data, $bucket, $ioHandler, $connection)
    {
        $entries = $bucket->getEntries();
        $entriesFormatted = [];
        foreach ($entries as $key => $value) {
            $entriesFormatted[$key] = gzuncompress($value['content']);
        }
        $dataToSend = serialize($entriesFormatted);
        $ioHandler->writeToSocket($connection, $dataToSend);

        return true;
    }

    private function handleQuit($data, $bucket, $ioHandler, $connection, $server)
    {
        $server->beforeServiceStop();
    }
}