Phloppy\RespUtils

Complexity

Total Complexity

11

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes	5
Bugs	3	Features	2

3 Methods

Rating	Name	Duplication	Size	Complexity
A	serialize()	0	10	1
C	deserialize()	0	39	8
A	toAssoc()	0	11	2

<?php

namespace Phloppy;

use Phloppy\Exception\CommandException;
use Phloppy\Stream\StreamInterface;

/**
 * Redis protocol implementation.
 *
 * This class implements serialization and deserialization of
 * the redis binary protocol. A lot of the code was inspired by
 * ptrofimov/tinyredisclient.
 */
class RespUtils
{

    /**
     * @param array $args
     *
     * @return mixed
     */
    public static function serialize(array $args)
    {
        return array_reduce(
            $args,
            function ($msg, $arg) {
                return $msg.'$'.strlen($arg)."\r\n".$arg."\r\n";
            },
            '*'.count($args)."\r\n"
        );
    }


    /**
     * @param StreamInterface $stream
     *
     * @return array|int|null|string
     *
     * @throws CommandException
     * @throws \RuntimeException
     */
    public static function deserialize(StreamInterface $stream)
    {
        $rsp = $stream->readLine();

        list($type, $result) = [$rsp[0], trim(substr($rsp, 1, strlen($rsp)))];

        switch ($type) {
            case '-': // ERRORS
                throw new CommandException($result);

            case '+': // SIMPLE STRINGS
                return $result;

            case ':': // INTEGERS
                return (int) $result;

            case '$': // BULK STRINGS
                $result = (int) $result;

                if ($result == -1) {
                    return null;
                }

                return trim($stream->readBytes($result + 2));

            case '*': // ARRAYS
                $cnt = (int)$result;
                $out = [];

                for ($i = 0; $i < $cnt; $i++) {
                    $out[] = static::deserialize($stream);
                }

                return $out;

            default:
                throw new \RuntimeException('unhandled protocol response: '.$rsp);
        }
    }


    /**
     * Map RESP responses to an associative array.
     *
     * @param array $response
     *
     * @return array
     */
    public static function toAssoc(array $response)
    {
        $out = [];

Equals sign not aligned with surrounding assignments; expected 3 spaces but found 1 space

        $count = count($response);

        for ($i = 1; $i < $count; $i += 2) {
            $out[$response[$i - 1]] = $response[$i];
        }

        return $out;
    }
}