v1.2.5.406

rainloop/v/1.2.5.406/app/libraries/KeenIO/Service/KeenIO.php

@@ -0,0 +1,215 @@
+<?php
+
+namespace KeenIO\Service;
+
+use KeenIO\Http\Adaptor\AdaptorInterface
+    , KeenIO\Http\Adaptor\Buzz as BuzzHttpAdaptor
+    ;
+
+/**
+ * Class KeenIO
+ *
+ * @package KeenIO\Service
+ */
+final class KeenIO
+{
+    private static $projectId;
+    private static $apiKey;
+    private static $httpAdaptor;
+
+    public static function getApiKey()
+    {
+        return self::$apiKey;
+    }
+
+    /**
+     * @param $value
+     * @throws \Exception
+     */
+    public static function setApiKey($value)
+    {
+        if (!ctype_alnum($value)) {
+            throw new \Exception(sprintf("API Key '%s' contains invalid characters or spaces.", $value));
+        }
+
+        self::$apiKey = $value;
+    }
+
+    public static function getProjectId()
+    {
+        return self::$projectId;
+    }
+
+    /**
+     * @param $value
+     * @throws \Exception
+     */
+    public static function setProjectId($value)
+    {
+        // Validate collection name
+        if (!ctype_alnum($value)) {
+            throw new \Exception(
+                "Project ID '" . $value . "' contains invalid characters or spaces."
+            );
+        }
+
+        self::$projectId = $value;
+    }
+
+    /**
+     * @return BuzzHttpAdaptor
+     */
+    public static function getHttpAdaptor()
+    {
+        if (!self::$httpAdaptor) {
+            self::$httpAdaptor = new BuzzHttpAdaptor(self::getApiKey());
+        }
+
+        return self::$httpAdaptor;
+
+    }
+
+    /**
+     * @param AdaptorInterface $httpAdaptor
+     */
+    public static function setHttpAdaptor(AdaptorInterface $httpAdaptor)
+    {
+        self::$httpAdaptor = $httpAdaptor;
+    }
+
+    /**
+     * @param $projectId
+     * @param $apiKey
+     */
+    public static function configure($projectId, $apiKey)
+    {
+        self::setProjectId($projectId);
+        self::setApiKey($apiKey);
+    }
+
+    /**
+     * add an event to KeenIO
+     *
+     * @param $collectionName
+     * @param $parameters
+     * @return mixed
+     * @throws \Exception
+     */
+    public static function addEvent($collectionName, $parameters = array())
+    {
+        self::validateConfiguration();
+
+        if (!ctype_alnum($collectionName)) {
+            throw new \Exception(
+                sprintf("Collection name '%s' contains invalid characters or spaces.", $collectionName)
+            );
+        }
+
+        $url = sprintf(
+            'https://api.keen.io/3.0/projects/%s/events/%s',
+            self::getProjectId(),
+            $collectionName
+        );
+
+        $response = self::getHttpAdaptor()->doPost($url, $parameters);
+        $json = json_decode($response);
+
+        return $json->created;
+    }
+
+    /**
+     * get a scoped key for an array of filters
+     *
+     * @param $filters
+     * @return string
+     */
+    public static function getScopedKey($filters)
+    {
+        self::validateConfiguration();
+
+        $filterArray = array('filters' => $filters);
+        $filterJson = self::padString(json_encode($filterArray));
+
+        $ivLength = mcrypt_get_iv_size(MCRYPT_RIJNDAEL_128, MCRYPT_MODE_CBC);
+        $iv = mcrypt_create_iv($ivLength);
+
+        $encrypted = mcrypt_encrypt(MCRYPT_RIJNDAEL_128, self::getApiKey(), $filterJson, MCRYPT_MODE_CBC, $iv);
+
+        $ivHex = bin2hex($iv);
+        $encryptedHex = bin2hex($encrypted);
+
+        $scopedKey = $ivHex . $encryptedHex;
+
+        return $scopedKey;
+    }
+
+    /**
+     * decrypt a scoped key (primarily used for testing)
+     *
+     * @param $scopedKey
+     * @return mixed
+     */
+    public static function decryptScopedKey($scopedKey)
+    {
+        $ivLength = mcrypt_get_iv_size(MCRYPT_RIJNDAEL_128, MCRYPT_MODE_CBC) * 2;
+        $ivHex = substr($scopedKey, 0, $ivLength);
+
+        $encryptedHex = substr($scopedKey, $ivLength);
+
+        $resultPadded = mcrypt_decrypt(
+            MCRYPT_RIJNDAEL_128,
+            self::getApiKey(),
+            pack('H*', $encryptedHex),
+            MCRYPT_MODE_CBC,
+            pack('H*', $ivHex)
+        );
+
+        $result = self::unpadString($resultPadded);
+
+        $filterArray = json_decode($result, true);
+
+        return $filterArray['filters'];
+    }
+
+
+    /**
+     * implement PKCS7 padding
+     *
+     * @param $string
+     * @param int $blockSize
+     * @return string
+     */
+    protected static function padString($string, $blockSize = 32)
+    {
+        $paddingSize = $blockSize - (strlen($string) % $blockSize);
+        $string .= str_repeat(chr($paddingSize), $paddingSize);
+
+        return $string;
+    }
+
+    /**
+     * remove padding for a PKCS7-padded string
+     *
+     * @param $string
+     * @return string
+     */
+    protected static function unpadString($string)
+    {
+        $len = strlen($string);
+        $pad = ord($string[$len - 1]);
+
+        return substr($string, 0, $len - $pad);
+    }
+
+
+    protected static function validateConfiguration()
+    {
+        // Validate configuration
+        if (!self::getProjectId()) {
+            throw new \Exception('Keen IO has not been configured');
+        }
+//        if (!self::getProjectId() or !self::getApiKey()) {
+//            throw new \Exception('Keen IO has not been configured');
+//        }
+    }
+}