JCFirebase\JCFirebase

Complexity

Total Complexity

23

Size/Duplication

Total Lines	163
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	2
Bugs	0	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	setAuth()	0	5	3
B	getPathURI()	0	34	6
A	get()	0	8	1
A	getShallow()	0	9	1
A	put()	0	5	1
A	post()	0	5	1
A	patch()	0	5	1
A	delete()	0	5	1
A	mergeRequestOptions()	0	13	3
A	mergeRequestPathURI()	0	9	3
A	refreshToken()	0	3	1

<?php
/**
 * Created by PhpStorm.
 * User: jaredchu
 * Date: 11/29/16
 * Time: 3:47 PM
 */

namespace JCFirebase;

use Requests;
use JCFirebase\JCFirebaseOption;
use JCFirebase\OAuth;

/**
 * Class JCFirebase
 * @package JCFirebase
 * reference https://www.firebase.com/docs/rest/api/
 */
class JCFirebase
{
    public $firebaseURI;
    public $firebaseDefaultPath;


    /**
     * @var OAuth
     */
    protected $auth;

    public $requestHeader = array(
        'accept' => 'application/json',
        'contentType' => 'application/json; charset=utf-8',
        'dataType' => 'json'
    );

    public $requestOptions = array();

    public function __construct($firebaseURI,$firebaseSerivceAccount = '',$firebaseDefaultPath = '/')
    {
        $this->firebaseURI = $firebaseURI;
        $this->firebaseDefaultPath = $firebaseDefaultPath;
        $this->setAuth($firebaseSerivceAccount);
    }

    public function setAuth($firebaseServiceAccount){
        if(isset($firebaseServiceAccount['key']) && isset($firebaseServiceAccount['iss'])){
            $this->auth = new OAuth($firebaseServiceAccount['key'],$firebaseServiceAccount['iss']);
        }
    }

    public function getPathURI($path = '',$print = ''){
        //remove last slash from firebaseURI
        $template = '/';
	    $this->firebaseURI = rtrim($this->firebaseURI,$template);
	    $path = rtrim($path,$template);
	    $path = ltrim($path,$template);

        //check https
        if(strpos($this->firebaseURI, 'http://') !== false){
            throw new \Exception("https is required.");
        }

        //check firebaseURI
        if(empty($this->firebaseURI)){
            throw new \Exception("firebase URI is required");
        }

        if(strpos($this->firebaseDefaultPath,"/") !== 0){
        	throw new \Exception("firebase default path must contain /");
        }

        $pathURI = $this->firebaseURI.$this->firebaseDefaultPath.$path.".json";

        //set query data
        $queryData = array();
        if(!empty($print)){
            $queryData[JCFirebaseOption::OPTION_PRINT] = $print;
        }
        if(!empty($queryData)){
            $pathURI = $pathURI . '?' . http_build_query($queryData);
        }

        return $pathURI;
    }

    /**
     * @param string $path
     * @param array $options
     * @return \Requests_Response
     */
    public function get($path = '',$options = array()){
        $this->refreshToken();

        return Requests::get(
            $this->mergeRequestPathURI($path,$options),$this->requestHeader,
            $this->mergeRequestOptions($options)

It seems like $this->mergeRequestOptions($options) targeting JCFirebase\JCFirebase::mergeRequestOptions() can also be of type string; however, Requests::get() does only seem to accept array, maybe add an additional type check?

        );
    }

    public function getShallow($path = '',$options = array()){
        $this->refreshToken();

        return Requests::get($this->getPathURI(
            $path). '?' . http_build_query(array(JCFirebaseOption::OPTION_SHALLOW => JCFirebaseOption::SHALLOW_TRUE)),
            $this->requestHeader,
            $this->mergeRequestOptions($options)

It seems like $this->mergeRequestOptions($options) targeting JCFirebase\JCFirebase::mergeRequestOptions() can also be of type string; however, Requests::get() does only seem to accept array, maybe add an additional type check?

        );
    }

    /**
     * @param string $path
     * @param array $options
     * @return \Requests_Response
     */
    public function put($path = '',$options = array()){
        $this->refreshToken();

        return Requests::put($this->getPathURI($path),$this->requestHeader,$this->mergeRequestOptions($options,true));

It seems like $this->mergeRequestOptions($options, true) targeting JCFirebase\JCFirebase::mergeRequestOptions() can also be of type string; however, Requests::put() does only seem to accept array, maybe add an additional type check?

    }

    /**
     * @param string $path
     * @param array $options
     * @return \Requests_Response
     */
    public function post($path = '',$options = array()){
        $this->refreshToken();

        return Requests::post($this->getPathURI($path),$this->requestHeader,$this->mergeRequestOptions($options,true));

It seems like $this->mergeRequestOptions($options, true) targeting JCFirebase\JCFirebase::mergeRequestOptions() can also be of type string; however, Requests::post() does only seem to accept array, maybe add an additional type check?

    }

    /**
     * @param string $path
     * @param array $options
     * @return \Requests_Response
     */
    public function patch($path = '',$options = array()){
        $this->refreshToken();

        return Requests::patch($this->getPathURI($path),$this->requestHeader,$this->mergeRequestOptions($options,true));

It seems like $this->mergeRequestOptions($options, true) targeting JCFirebase\JCFirebase::mergeRequestOptions() can also be of type string; however, Requests::patch() does only seem to accept array, maybe add an additional type check?

    }

    /**
     * @param string $path
     * @param array $options
     * @return \Requests_Response
     */
    public function delete($path = '',$options = array()){
        $this->refreshToken();

        return Requests::delete($this->getPathURI($path),$this->requestHeader,$this->mergeRequestOptions($options));

It seems like $this->mergeRequestOptions($options) targeting JCFirebase\JCFirebase::mergeRequestOptions() can also be of type string; however, Requests::delete() does only seem to accept array, maybe add an additional type check?

    }

    protected function mergeRequestOptions($options = array(),$jsonEncode = false){
        $requestOptions = array();

        if(isset($options['data'])){
            $requestOptions = array_merge($options['data'],$requestOptions);
        }

        if($jsonEncode){
            $requestOptions = json_encode($requestOptions);
        }

        return $requestOptions;
    }

    protected function mergeRequestPathURI($path='',$options = array(),$reqType = JCFirebaseOption::REQ_TYPE_GET){
        $print = '';
        if(isset($options['print'])){
            if(JCFirebaseOption::isAllowPrint($reqType,$options['print'])){
                $print = $options['print'];
            }
        }
        return $this->getPathURI($path,$print);
    }

    protected function refreshToken(){
        $this->requestHeader['Authorization'] = 'Bearer '. $this->auth->getAccessToken();
    }
}