Plinker\Core\Client

Complexity

Total Complexity

12

Size/Duplication

Total Lines	147
Duplicated Lines	0 %

Test Coverage

Coverage

71.74%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__get()	0	11	2
A	__construct()	0	10	3
C	__call()	0	74	7

<?php
/*
 +------------------------------------------------------------------------+
 | Plinker-RPC PHP                                                        |
 +------------------------------------------------------------------------+
 | Copyright (c)2017-2018 (https://github.com/plinker-rpc/core)           |
 +------------------------------------------------------------------------+
 | This source file is subject to MIT License                             |
 | that is bundled with this package in the file LICENSE.                 |
 |                                                                        |
 | If you did not receive a copy of the license and are unable to         |
 | obtain it through the world-wide-web, please send an email             |
 | to license@cherone.co.uk so we can send you a copy immediately.        |
 +------------------------------------------------------------------------+
 | Authors: Lawrence Cherone <lawrence@cherone.co.uk>                     |
 +------------------------------------------------------------------------+
 */

namespace Plinker\Core {
    /**
     * Plinker\Core\Client
     */
    final class Client
    {
        /**
         * @var
         */
        private $component = [];

        /**
         * @var
         */
        private $chaining = false;

        /**
         * @var
         */
        private $config;

        /**
         * @var
         */
        private $curl;

        /**
         * @var
         */
        private $signer;

        /**
         * Class construct
         *
         * @param  string $server  - server enpoint url
         * @param  array  $config  - config array which holds object configuration
         * @return void
         */
        public function __construct($server, array $config = [])
        {
            $this->config = array_merge([
                "server" => $server,
                "secret" => null
            ], $config);

            // check and set client timeout
            if (!isset($this->config["timeout"]) || !is_numeric($this->config["timeout"])) {
                $this->config["timeout"] = 10;
            }
        }

        /**
         * Magic getter method, which sets component
         *
         * @param  string $component
         * @return object
         */
        public function __get($component)
        {
            // on first call reset component array and enable chaining
            if (!$this->chaining) {
                $this->component = [];
                $this->chaining = true;
            }

            $this->component[] = ucfirst($component);

            return $this;
        }

        /**
         * Magic caller method, which calls component
         *
         * @param string $action
         * @param array  $params
         * @return array
         */
        public function __call($action, $params)
        {
            // set chaining state
            $this->chaining = false;

            // load curl
            if (!$this->curl) {
                $this->curl = new Lib\Curl([
                    'server' => $this->config['server'],
                    'timeout' => $this->config['timeout']
                ]);
            }

            // load signer
            if (!$this->signer) {
                $this->signer = new Lib\Signer([
                    'secret' => $this->config['secret']
                ]);
            }

            // change params array into numeric
            $params = array_values($params);

            // unset local private key
            unset($this->config["plinker"]["private_key"]);

            // encode payload
            $payload = $this->signer->encode([
                "component" => implode('\\', $this->component),
                "config" => $this->config,
                "action" => $action,
                "params" => $params
            ]);

            // post request to plinker server
            $response = $this->curl->post($this->config["server"], $payload, [
                "PLINKER: ".$payload["token"]
            ]);

            // check curl error
            if (!empty($response['error'])) {
                return $response;
            }

            // decode json
            $body = json_decode($response['body'], true);

            // json decode (unpack) response body
            if (empty($body['data'])) {
                return [
                    'body'  => $response['body'],
                    "code"  => 422,
                    "error" => 'Failed to decode payload, invalid response'
                ];
            }

            // verify and decode response
            try {
                $body = $this->signer->decode($body);
            } catch (\Exception $e) {
                return [
                    'body'  => $response['body'],
                    "code"  => 401,
                    "error" => $e->getMessage()
                ];
            }

            // check if $body is Exception
            if ($body instanceof \Exception) {
                throw $body;
            }

            //
            return $body;
        }
    }

}