Adding upstream version 0.20.0.upstream/0.20.0upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 67 insertions, 0 deletions

diff --git a/vendor/gipfl/influxdb/src/Escape.php b/vendor/gipfl/influxdb/src/Escape.php
new file mode 100644
index 0000000..e6cb555
--- /dev/null
+++ b/vendor/gipfl/influxdb/src/Escape.php
@@ -0,0 +1,67 @@
+<?php
+
+namespace gipfl\InfluxDb;
+
+use InvalidArgumentException;
+use function addcslashes;
+use function ctype_digit;
+use function is_bool;
+use function is_int;
+use function is_null;
+use function preg_match;
+use function strpos;
+
+abstract class Escape
+{
+    const ESCAPE_COMMA_SPACE = ' ,\\';
+
+    const ESCAPE_COMMA_EQUAL_SPACE = ' =,\\';
+
+    const ESCAPE_DOUBLE_QUOTES = '"\\';
+
+    const NULL = 'null';
+
+    const TRUE = 'true';
+
+    const FALSE = 'false';
+
+    public static function measurement($value)
+    {
+        static::assertNoNewline($value);
+        return addcslashes($value, self::ESCAPE_COMMA_SPACE);
+    }
+
+    public static function key($value)
+    {
+        static::assertNoNewline($value);
+        return addcslashes($value, self::ESCAPE_COMMA_EQUAL_SPACE);
+    }
+
+    public static function tagValue($value)
+    {
+        static::assertNoNewline($value);
+        return addcslashes($value, self::ESCAPE_COMMA_EQUAL_SPACE);
+    }
+
+    public static function fieldValue($value)
+    {
+        // Faster checks first
+        if (is_int($value) || ctype_digit($value) || preg_match('/^-\d+$/', $value)) {
+            return "{$value}i";
+        } elseif (is_bool($value)) {
+            return $value ? self::TRUE : self::FALSE;
+        } elseif (is_null($value)) {
+            return self::NULL;
+        } else {
+            static::assertNoNewline($value);
+            return '"' . addcslashes($value, self::ESCAPE_DOUBLE_QUOTES) . '"';
+        }
+    }
+
+    protected static function assertNoNewline($value)
+    {
+        if (strpos($value, "\n") !== false) {
+            throw new InvalidArgumentException('Newlines are forbidden in InfluxDB line protocol');
+        }
+    }
+}