Surge\LaravelSalesforce\Objects\AbstractObject

Complexity

Total Complexity

21

Size/Duplication

Total Lines	215
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

15 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
B	sendRequest()	0	30	4
A	getType()	0	12	3
A	getVersion()	0	4	1
A	listOrganisationLimits()	0	4	1
A	listAvailableResources()	0	4	1
A	listObjects()	0	4	1
A	describeObject()	0	4	1
A	describeBasicObject()	0	4	1
A	query()	0	8	1
A	get()	0	4	1
A	update()	0	8	1
A	create()	0	12	2
A	delete()	0	4	1
A	report()	0	8	1

<?php

namespace Surge\LaravelSalesforce\Objects;

use GuzzleHttp\Exception\ClientException;
use Surge\LaravelSalesforce\Events\RequestSent;
use Surge\LaravelSalesforce\Events\ResponseReceived;
use Surge\LaravelSalesforce\Exceptions\SalesforceException;
use Surge\LaravelSalesforce\Salesforce;

abstract class AbstractObject implements ObjectInterface
{
    protected $salesforce;

    public $custom = false;

    public function __construct(Salesforce $salesforce)
    {
        $this->salesforce = $salesforce;
    }

    /**
     * @param string $method
     * @param string $url
     * @param array  $options
     *
     * @return object
     */
    protected function sendRequest(string $method, string $url, array $options = [])
    {
        event(new RequestSent([
            'data'  => $options,
            'url'   => $url,
            'class' => get_class($this),
            'type'  => 'REQUEST',
        ]));

        if (config('laravel-salesforce.disable_on_local') && app()->environment('local')) {
            $response = (object)['success' => true, 'totalSize' => 0, 'id' => 'localRequestId', 'OwnerId' => 'localRequestId'];
        } else {
            try {
                $response = json_decode(
                    $this->salesforce->client->request($method, $this->salesforce->baseUrl . $url, $options)
                        ->getBody());
            } catch (ClientException $e) {
                throw new SalesforceException($e->getMessage());
            }
        }

        event(new ResponseReceived([
            'data'  => $response,
            'url'   => $url,
            'class' => get_class($this),
            'type'  => 'RESPONSE',
        ]));

        return $response;
    }

    protected function getType()
    {
        if (isset($this->type)) {
            return $this->type;

The property type does not exist. Did you maybe forget to declare it?

        }

        if ($this->custom === true) {
            return (new \ReflectionClass($this))->getShortName() . '__c';
        }

        return (new \ReflectionClass($this))->getShortName();
    }

    /**
     * Get latest version.
     *
     * @return mixed
     */
    public function getVersion()
    {
        return $this->sendRequest('GET', $this->salesforce->instanceUrl . '/services/data');
    }

    /**
     * Get all organisation limits.
     */
    public function listOrganisationLimits()
    {
        return $this->sendRequest('GET', $this->salesforce->instanceUrl . $this->version['url'] . '/limits');

The property version does not exist. Did you maybe forget to declare it?

    }

    /**
     * List all available resources.
     *
     * @return mixed
     */
    public function listAvailableResources()
    {
        return $this->sendRequest('GET', '');
    }

    /**
     * List all objects.
     *
     * @return mixed
     */
    public function listObjects()
    {
        return $this->sendRequest('GET', '/sobjects');
    }

    /**
     * Describe an object.
     *
     * @param $objectName
     *
     * @return mixed
     */
    public function describeObject($objectName)
    {
        return $this->sendRequest('GET', '/sobjects/' . $objectName . '/describe');
    }

    /**
     * Describe basic object.
     *
     * @param $objectName
     *
     * @return mixed
     */
    public function describeBasicObject($objectName)
    {
        return $this->sendRequest('GET', '/sobjects/' . $objectName);
    }

    /**
     * Run Salesforce query.
     *
     * @param $query
     *
     * @return mixed
     */
    public function query($query)
    {
        return $this->sendRequest('GET', '/query', [
            'query' => [
                'q' => $query,
            ],
        ]);
    }

    /**
     * Get record.
     *
     * @param string $id
     *
     * @param array  $fields
     */
    public function get(string $id, array $fields = [])
    {
        return $this->sendRequest('GET', "/sobjects/" . $this->getType() . "/$id", ['query' => $fields]);
    }

    /**
     * Update.
     *
     * @param  string $id
     * @param         $params
     * @return void
     */
    public function update(string $id, array $params)
    {
        $this->sendRequest('PATCH', "/sobjects/" . $this->getType() . "/$id",
            [
                'json' => $params,
            ]
        );
    }

    /**
     * Insert new account.
     *
     * @param $params
     *
     * @throws SalesforceException
     */
    public function create(array $params)
    {
        $response = $this->sendRequest('POST', "/sobjects/" . $this->getType(), [
            'json' => $params,
        ]);

        if ($response->success !== true) {
            throw new SalesforceException($response->errors);
        }

        return $response;
    }

    /**
     * Delete a given record
     *
     * @param string $id
     * @throws SalesforceException
     */
    public function delete(string $id)
    {
        $this->sendRequest('DELETE', "/sobjects/" . $this->getType() . "/$id");
    }

    /**
     * Get report
     *
     * @param string $id
     * @param bool   $includeDetails
     * @return object
     */
    public function report(string $id, bool $includeDetails = true)
    {
        return $this->sendRequest(
            'GET',
            '/analytics/reports/' . $id,
            ['query' => ['hasDetailRows' => $includeDetails]]
        );
    }
}