PhpCache\CacheClient\CacheClient

Complexity

Total Complexity

6

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	get()	0	10	1
A	__construct()	0	3	1
A	set()	0	7	1
A	delete()	0	7	1
A	getEntries()	0	10	1
A	quitServer()	0	6	1

<?php

namespace PhpCache\CacheClient;

use PhpCache\IO\CacheIOHandler;

/**
 * Description of newPHPClass.
 *
 * @author dude920228
 */
class CacheClient implements CacheClientInterface
{
    /**
     * @var CacheIOHandler
     */
    private $ioHandler;

    public function __construct(CacheIOHandler $ioHandler)
    {
        $this->ioHandler = $ioHandler;
    }

    public function set(string $key, $package): void
    {
        $socket = $this->ioHandler->createClientSocket();
        $data = ['action' => 'set', 'key' => $key, 'message' => $package];
        $dataString = serialize($data);
        $this->ioHandler->writeToSocket($socket, $dataString);
        $this->ioHandler->closeSocket($socket);
    }

    public function get(string $key)
    {
        $data = ['action' => 'get', 'key' => $key];
        $socket = $this->ioHandler->createClientSocket();
        $dataString = serialize($data);
        $this->ioHandler->writeToSocket($socket, $dataString);
        $recv = $this->ioHandler->readFromSocket($socket);
        $this->ioHandler->closeSocket($socket);

        return unserialize($recv);
    }

    public function delete(string $key): void
    {
        $data = ['action' => 'delete', 'key' => $key];
        $socket = $this->ioHandler->createClientSocket();
        $dataString = serialize($data);
        $this->ioHandler->writeToSocket($socket, $dataString);
        $this->ioHandler->closeSocket($socket);
    }

    public function quitServer(): void
    {
        $data = ['action' => 'quit'];
        $socket = $this->ioHandler->createClientSocket();
        $dataString = serialize($data);
        $this->ioHandler->writeToSocket($socket, $dataString);
    }

    public function getEntries(): array
    {
        $data = ['action' => 'getEntries'];
        $socket = $this->ioHandler->createClientSocket();
        $dataString = serialize($data);
        $this->ioHandler->writeToSocket($socket, $dataString);
        $entries = $this->ioHandler->readFromSocket($socket);
        $this->ioHandler->closeSocket($socket);

        return unserialize($entries);
    }
}