Plinker\Core\Client

Complexity

Total Complexity

12

Size/Duplication

Total Lines	134
Duplicated Lines	0 %

Test Coverage

Coverage

80.48%

Importance

Changes

0

3 Methods

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

<?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;
        }

        // json decode (unpack) response body
        if (empty($response['body']) || !($body = json_decode($response['body'], true))) {
            $response['error'] = 'Failed to decode payload, invalid json';
            return $response;
        }

        // verify and decode response
        if (!($body = $this->signer->decode($body))) {
            return [
                'body' => $response['body'],
                "code" => 422,
                "error" => 'Failed to decode payload'
            ];
        }

        //
        return $body;
    }
}