Ekho\Logstash\Lumberjack\Encoder

Complexity

Total Complexity

18

Size/Duplication

Total Lines	108
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

97.96%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	toCompressedFrame()	0	6	1
C	deepGet()	0	22	8
A	toFrame()	0	23	2
A	stringifyValue()	0	12	3
A	deepKeys()	0	14	4

<?php
namespace Ekho\Logstash\Lumberjack;

class Encoder implements EncoderInterface
{
    /**
     * @param array $hash
     * @param int $sequence
     * @return string
     */
    public function toCompressedFrame($hash, $sequence)
    {
        $frame = $this->toFrame($hash, $sequence);
        $compressedFrame = gzcompress($frame);
        return pack("AANA".strlen($compressedFrame), "1", "C", strlen($compressedFrame), $compressedFrame);
    }

    /**
     * @param array $hash
     * @param int $sequence
     * @return string
     */
    public function toFrame($hash, $sequence)
    {
        $frame = array("1", "D", $sequence);
        $pack = "AAN";
        $keys = $this->deepKeys($hash);
        array_push($frame, count($keys));
        $pack .= "N";
        foreach ($keys as $k) {
            $val = $this->deepGet($hash, $k);
            $keyLength = strlen($k);
            $valLength = strlen($val);
            array_push($frame, $keyLength);
            $pack .= "N";
            array_push($frame, $k);
            $pack .= "A{$keyLength}";
            array_push($frame, $valLength);
            $pack .= "N";
            array_push($frame, $val);
            $pack .= "A{$valLength}";
        }
        array_unshift($frame, $pack);
        return call_user_func_array('pack', $frame);
    }

    /**
     * @param array $hash
     * @param string $key
     * @return null|string
     */
    private function deepGet($hash, $key)
    {
        if ($key === null) {
            return $this->stringifyValue($hash);
        }

        if (is_array($hash) && array_key_exists($key, $hash)) {
            return $this->stringifyValue($hash[$key]);
        }

        if (strpos($key, '.') === false) {
            if (!is_array($hash) || !array_key_exists($key, $hash)) {
                return null;
            }

            return $this->stringifyValue($hash[$key]);
        }
        
        list($key, $subkey) = explode('.', $key, 2);

        return isset($hash[$key]) ? $this->deepGet($hash[$key], $subkey) : null;
    }

    /**
     * @param mixed $value
     * @return string
     */
    private function stringifyValue($value)
    {
        if (is_scalar($value)) {
            if (is_bool($value)) {
                $value = (int) $value;
            }

            return (string) $value;
        }

        return json_encode($value);
    }

    /**
     * @param array $hash
     * @param string $prefix
     * @return array
     */
    private function deepKeys($hash, $prefix = "")
    {
        $keys = array();
        foreach ($hash as $k => $v) {
            if (is_scalar($v)) {
                array_push($keys, "{$prefix}{$k}");
            }
            if (is_array($v)) {
                $keys = array_merge($keys, $this->deepKeys($hash[$k], "{$prefix}{$k}."));
            }
        }

        return $keys;
    }
}