InfluxDB\Adapter\WriterTrait

Complexity

Total Complexity

19

Size/Duplication

Total Lines	119
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	convertSerializable()	0	4	1
A	convertString()	0	4	1
A	convertInteger()	0	4	1
A	convertDouble()	0	4	1
A	convertBoolean()	0	4	2
A	messageToLineProtocol()	0	23	3
A	prepareMessageSection()	0	18	4
A	tagsToString()	0	12	2
A	pointsToString()	0	16	3
A	addSlashes()	0	12	1

<?php
namespace InfluxDB\Adapter;

use DateTime;

trait WriterTrait
{
    public function messageToLineProtocol(array $message, array $tags = [])
    {
        if (!array_key_exists("points", $message)) {
            return;
        }

        $message = $this->prepareMessageSection($message);
        $message["tags"] = array_replace_recursive($tags, $message["tags"]);

        $lines = [];
        foreach ($message["points"] as $point) {
            $point = $this->prepareMessageSection($point, $message["time"]);
            $tags = array_replace_recursive($message["tags"], $point["tags"]);

            $tagLine = $this->tagsToString($tags);

            $lines[] = sprintf(
                "%s%s %s %d", $point["measurement"], $tagLine, $this->pointsToString($point["fields"]), $point["time"]
            );
        }

        return implode("\n", $lines);
    }

    private function prepareMessageSection(array $message, $unixepoch = false)
    {
        if (!array_key_exists("tags", $message)) {
            $message["tags"] = [];
        }

        if (!$unixepoch) {
            $unixepoch = (int)(microtime(true) * 1e9);
        }

        if (array_key_exists("time", $message)) {
            $dt = new DateTime($message["time"]);
            $unixepoch = (int)($dt->format("U") * 1e9);
        }
        $message["time"] = $unixepoch;

        return $message;
    }

    protected function tagsToString(array $tags)
    {
        $tagLine = "";
        if (count($tags) > 0) {
            array_walk($tags, function (&$value, $key) {
                $value = "{$this->addSlashes($key)}={$this->addSlashes($value)}";
            });
            $tagLine = sprintf(",%s", implode(",", $tags));
        }

        return $tagLine;
    }

    protected function pointsToString(array $elements)
    {
        array_walk($elements, function (&$value, $key) {
            $dataType = gettype($value);
            if (!in_array($dataType, ["string", "double", "boolean", "integer"])) {
                $dataType = "serializable";
            }
            $dataType = ucfirst($dataType);
            if ($dataType!='Null') {
                $value = call_user_func([$this, "convert{$dataType}"], $value);
                $value = "{$this->addSlashes($key)}={$value}";
            }
        });
        $elements = array_filter($elements);
        return implode(",", $elements);
    }

    protected function convertSerializable($value)
    {
        return "{$value}";
    }

    protected function convertString($value)
    {
        return "\"{$value}\"";
    }

    protected function convertInteger($value)
    {
        return "{$value}i" ;
    }

    protected function convertDouble($value)
    {
        return $value;
    }

    protected function convertBoolean($value)
    {
        return (($value) ? "true" : "false");
    }

    /**
     * Returns strings with space, comma, or equals sign characters backslashed per Influx write protocol syntax
     *
     * @param string $value
     * @return string
     */
    private function addSlashes($value)
    {
        return str_replace([
            ' ',
            ',',
            '='
        ], [
            '\ ',
            '\,',
            '\='
        ], $value);
    }
}