ZohoClient::getRequestBody() - Code Metrics - Inspection of "Fix - Migrate Guzzle 5 to 6 :" - Wabel/zoho-crm-orm - Measure and Improve Code Quality continuously with Scrutinizer

Completed
Push — 1.0 ( b072ff...1e92f5 )

by Raphaël
created 2016-07-29 17:54 UTC
ZohoClient::getRequestBody() A

↳ Parent: ZohoClient
Complexity

Conditions	2
Paths	2
Size

Total Lines	7
Code Lines	4
Duplication

Lines	0
Ratio	0 %
Importance

Changes	1
Bugs	1	Features	0
Metric	Value
c	1
b	1
f	0
dl	0
loc	7
rs	9.4285
cc	2
eloc	4
nc	2
nop	3
<?php

namespace Wabel\Zoho\CRM;

use GuzzleHttp\Client;
use Wabel\Zoho\CRM\Exception\ZohoCRMResponseException;
use Wabel\Zoho\CRM\Request\Response;
use GuzzleHttp\Psr7\Request;

/**
 * Client for provide interface with Zoho CRM.
 *
 * TODO : Add comments (a lot)
 */
class ZohoClient
{
    /**
     * URL for call request.
     *
     * @var string
     */
    const BASE_URI = 'https://crm.zoho.com/crm/private';

    /**
     * Token used for session of request.
     *
     * @var string
     */
    protected $authtoken;

    /**
     * Instance of the client.
     *
     * @var Client
     */
    protected $zohoRestClient;

    /**
     * Format selected for get request.
     *
     * @var string
     */
    protected $format;

    /**
     * Module selected for get request.
     *
     * @var string
     */
    protected $module;

    /**
     * Construct.
     *
     * @param string $authtoken      Token for connection
     * @param Client $zohoRestClient Guzzl Client for connection [optional]
     */
    public function __construct($authtoken, Client $zohoRestClient = null)
    {
        $this->authtoken = $authtoken;
        // Only XML format is supported for the time being
        $this->format = 'xml';
        $this->zohoRestClient = $zohoRestClient ?: new Client();
    }

    /**
     * Implements convertLead API method.
     *
     * @param $leadId
     * @param $data
     * @param array $params
     *
     * @return Response The Response object
     *
     * @throws ZohoCRMResponseException
     */
    public function convertLead($leadId, $data, $params = array())
    {
        $module = 'Leads';
        $params['leadId'] = $leadId;
        $params['newFormat'] = 1;

        return $this->call($module, 'convertLead', $params, $data);
    }

    /**
     * Implements getFields API method.
     *
     * @return Response The Response object
     */
    public function getFields($module)
    {
        $params['newFormat'] = 1;
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}

        return $this->call($module, 'getFields', array());
    }

    /**
     * Implements deleteRecords API method.
     *
     * @param string $module
     * @param string $id     Id of the record
     *
     * @return Response The Response object
     *
     * @throws ZohoCRMResponseException
     */
    public function deleteRecords($module, $id)
    {
        $params = array(
            'id' => $id,
            'newFormat' => 1,
        );

        return $this->call($module, 'deleteRecords', $params);
    }

    /**
     * Implements getRecordById API method.
     *
     * @param string $module The module to use
     * @param string $id     Id of the record or a list of IDs separated by a semicolon
     *
     * @return Response The Response object
     *
     * @throws ZohoCRMResponseException
     */
    public function getRecordById($module, $id)
    {
        if (strpos($id, ';') === false) {
            $params['id'] = $id;
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}
        } else {
            $params['idlist'] = $id;
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}
        }
        $params['newFormat'] = 1;

        return $this->call($module, 'getRecordById', $params);
    }

    /**
     * Implements getRecords API method.
     *
     * @param $module
     * @param $sortColumnString
     * @param $sortOrderString
     * @param \DateTime $lastModifiedTime
     * @param $selectColumns
     * @param $fromIndex
     * @param $toIndex
     *
     * @return Response The Response object
     *
     * @throws ZohoCRMResponseException
     */
    public function getRecords($module, $sortColumnString = null, $sortOrderString = null, \DateTimeInterface $lastModifiedTime = null, $selectColumns = null, $fromIndex = null, $toIndex = null)
    {
        $params['newFormat'] = 1;
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}
        $params['version'] = 1;
        if ($selectColumns) {
            $params['selectColumns'] = $selectColumns;
        }
        if ($fromIndex) {
            $params['fromIndex'] = $fromIndex;
        }
        if ($toIndex) {
            $params['toIndex'] = $toIndex;
        }
        if ($sortColumnString) {
            $params['sortColumnString'] = $sortColumnString;
        }
        if ($sortOrderString) {
            $params['sortOrderString'] = $sortOrderString;
        }
        if ($lastModifiedTime) {
            $params['lastModifiedTime'] = $lastModifiedTime->format('Y-m-d H:i:s');
        }

        return $this->call($module, 'getRecords', $params);
    }

    /**
     * Implements getDeletedRecordIds API method.

     *
     * @param string             $module
     * @param \DateTimeInterface $lastModifiedTime
     * @param int                $fromIndex
     * @param int                $toIndex
     *
     * @return Response
     *
     * @throws ZohoCRMResponseException
     */
    public function getDeletedRecordIds($module, \DateTimeInterface $lastModifiedTime = null, $fromIndex = null, $toIndex = null)
    {
        $params = [];
        if ($fromIndex) {
0   == false // true
0   == null  // true
123 == false // false
123 == null  // false

// It is often better to use strict comparison
0 === false // false
0 === null  // false
            $params['fromIndex'] = $fromIndex;
        }
        if ($toIndex) {
0   == false // true
0   == null  // true
123 == false // false
123 == null  // false

// It is often better to use strict comparison
0 === false // false
0 === null  // false
            $params['toIndex'] = $toIndex;
        }
        if ($lastModifiedTime) {
            $params['lastModifiedTime'] = $lastModifiedTime->format('Y-m-d H:i:s');
        }

        return $this->call($module, 'getDeletedRecordIds', $params);
    }

    /**
     * Implements getRecords API method.
     *
     * @param $module
     * @param $id
     * @param $parentModule
     * @param null $fromIndex
     * @param null $toIndex
     *
     * @return Response
     *
     * @throws ZohoCRMResponseException
     */
    public function getRelatedRecords($module, $id, $parentModule, $fromIndex = null, $toIndex = null)
    {
        $params['id'] = $id;
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}
        $params['parentModule'] = $parentModule;
        $params['newFormat'] = 1;
        if ($fromIndex) {
            $params['fromIndex'] = $fromIndex;
        }
        if ($toIndex) {
            $params['toIndex'] = $toIndex;
        }

        return $this->call($module, 'getRelatedRecords', $params);
    }

    /**
     * Implements searchRecords API method.
     *
     * @param string    $module
     * @param string    $searchCondition
     * @param int       $fromIndex
     * @param int       $toIndex
     * @param \DateTime $lastModifiedTime
     * @param null      $selectColumns
     *
     * @return Response
     *
     * @throws ZohoCRMResponseException
     */
    public function searchRecords($module, $searchCondition = null, $fromIndex = null, $toIndex = null, $lastModifiedTime = null, $selectColumns = null)
    {
        if ($searchCondition) {
''   == false // true
''   == null  // true
'ab' == false // false
'ab' == null  // false

// It is often better to use strict comparison
'' === false // false
'' === null  // false
            $params['criteria'] = $searchCondition;
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}
        } else {
            $params['criteria'] = '()';
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}
        }
        if ($fromIndex) {
0   == false // true
0   == null  // true
123 == false // false
123 == null  // false

// It is often better to use strict comparison
0 === false // false
0 === null  // false
            $params['fromIndex'] = $fromIndex;
        }
        if ($toIndex) {
0   == false // true
0   == null  // true
123 == false // false
123 == null  // false

// It is often better to use strict comparison
0 === false // false
0 === null  // false
            $params['toIndex'] = $toIndex;
        }
        if ($lastModifiedTime) {
            $params['lastModifiedTime'] = $lastModifiedTime->format('Y-m-d H:i:s');
        }
        if ($selectColumns) {
            $params['selectColumns'] = $selectColumns;
        }

        $params['newFormat'] = 1;

        return $this->call($module, 'searchRecords', $params);
    }

    /**
     * Implements getUsers API method.
     *
     * @param string $type The type of users you want retrieve (among AllUsers, ActiveUsers, DeactiveUsers, AdminUsers and ActiveConfirmedAdmins)
     *
     * @return Response The array of Zoho Beans parsed from the response
     *
     * @throws ZohoCRMResponseException
     */
    public function getUsers($type = 'AllUsers')
    {
        switch ($type) {
            case 'AllUsers':
            case 'ActiveUsers':
            case 'DeactiveUsers':
            case 'AdminUsers':
            case 'ActiveConfirmedAdmins':
                $params['type'] = $type;
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}
                break;
            default :
switch ($expr) {
    default : //wrong
        doSomething();
        break;
}

switch ($expr) {
    default: //right
        doSomething();
        break;
}
                $params['type'] = 'AllUsers';
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}
                break;
        }
        $params['newFormat'] = 1;

        return $this->call('Users', 'getUsers', $params);
    }

    /**
     * Implements insertRecords API method.
     *
     * @param $module
     * @param \SimpleXMLElement$xmlData
     * @param bool $wfTrigger
     * @param int  $duplicateCheck
     * @param bool $isApproval
     *
     * @return Response
     *
     * @throws ZohoCRMResponseException
     */
    public function insertRecords($module, $xmlData, $wfTrigger = null, $duplicateCheck = null, $isApproval = null, $version = 4, $newFormat = 2)
    {
        if ($wfTrigger) {
            $params['wfTrigger'] = 'true';
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}
        }
        if ($duplicateCheck) {
0   == false // true
0   == null  // true
123 == false // false
123 == null  // false

// It is often better to use strict comparison
0 === false // false
0 === null  // false
            $params['duplicateCheck'] = $duplicateCheck;
function myFunction($a) {
    switch ($a) {
        case 'foo':
            $x = 1;
            break;

        case 'bar':
            $x = 2;
            break;
    }

    // $x is potentially undefined here.
    echo $x;
}
        }
        if ($isApproval) {
            $params['isApproval'] = 'true';
        }
        $params['newFormat'] = $newFormat;
        $params['version'] = $version;

        return $this->call($module, 'insertRecords', $params, ['xmlData' => $xmlData->asXML()]);
    }

    /**
     * Implements updateRecords API method.
     *
     * @param $module
     * @param \SimpleXMLElement $xmlData
     * @param string            $id
     * @param bool              $wfTrigger
     *
     * @return Response
     *
     * @throws ZohoCRMResponseException
     */
    public function updateRecords($module, $xmlData, $id = null, $wfTrigger = null, $version = 4, $newFormat = 2)
    {
        $params['newFormat'] = $newFormat;
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}
        $params['version'] = $version;
        if ($wfTrigger) {
            $params['wfTrigger'] = 'true';
        }
        if ($id) {
''   == false // true
''   == null  // true
'ab' == false // false
'ab' == null  // false

// It is often better to use strict comparison
'' === false // false
'' === null  // false
            $params['id'] = $id;
        }

        return $this->call($module, 'updateRecords', $params, ['xmlData' => $xmlData->asXML()]);
    }

    /**
     * Implements uploadFile API method.
     *
     * @param $module
     * @param $id
     * @param $content
     *
     * @return Response
     *
     * @throws ZohoCRMResponseException
     */
    public function uploadFile($module, $id, $content)
    {
        $params['id'] = $id;
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}
        $params['content'] = $content;

        return $this->call($module, 'uploadFile', $params);
    }

    /**
     * Implements downloadFile API method.
     *
     * @param $module
     * @param $id
     *
     * @return Response
     *
     * @throws ZohoCRMResponseException
     */
    public function downloadFile($module, $id)
    {
        $params['id'] = $id;
foreach ($collection as $item) {
    $myArray['foo'] = $item->getFoo();

    if ($item->hasBar()) {
        $myArray['bar'] = $item->getBar();
    }

    // do something with $myArray
}

        return $this->call($module, 'downloadFile', $params);
    }

    /**
     * Returns a list of modules from Zoho.
     */
    public function getModules()
    {
        return $this->call('Info', 'getModules', ['type' => 'api']);
    }


    /**
     * Get the body of the request
     *
     * @param array $params Params
     * @param Object $data Data
     * @return string
     */
    protected function getRequestBody($params, $data, $options)

    {
        if($data){
            return http_build_query($data, '', '&');
        }
        return '';
    }

    
    /**
     * Make the call using the client.
     *
     * @param string                   $module  The module to use
     * @param string                   $command Command to call
     * @param array                    $params  Options
/**
 * @param array $germany
 * @param array $ireland
 */
function finale($germany, $island) {
    return "2:1";
}
     * @param \SimpleXMLElement|string $data    Data to send [optional]
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
     * @param array                    $options Options to add for configurations [optional]
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
     *
     * @return Response
     */
    public function call($module, $command, $getParams = array(), $postParams = array())
    {
        $getParams['authtoken'] = $this->authtoken;
        $getParams['scope'] = 'crmapi';

        $uri = $this->getRequestURI($module, $command);

//        $params = $this->getRequestBody([], $postParams, []);

//        $stream = \GuzzleHttp\Psr7\stream_for($params);
        $response = $this->zohoRestClient->request('POST', $uri, ['query'=>$getParams+$postParams]);
        $zohoResponse = new Response((string)$response->getBody(), $module, $command);
        if ($zohoResponse->ifSuccess()) {
            return $zohoResponse;
        } else {
            throw new ZohoCRMResponseException($zohoResponse);
        }
    }

    /**
     * Get the current request uri.
     *
     * @param  $module The module to use
     * @param string $command Command for get uri
     *
     * @return string
     */
    protected function getRequestURI($module, $command)
    {
        if (empty($module)) {
            throw new \RuntimeException('Zoho CRM module is not set.');
        }
        $parts = array(self::BASE_URI, $this->format, $module, $command);

        return implode('/', $parts);
    }
}

1			<?php
2
3			namespace Wabel\Zoho\CRM;
4
5			use GuzzleHttp\Client;
6			use Wabel\Zoho\CRM\Exception\ZohoCRMResponseException;
7			use Wabel\Zoho\CRM\Request\Response;
8			use GuzzleHttp\Psr7\Request;
9
10			/**
11			* Client for provide interface with Zoho CRM.
12			*
13			* TODO : Add comments (a lot)
14			*/
15			class ZohoClient
16			{
17			/**
18			* URL for call request.
19			*
20			* @var string
21			*/
22			const BASE_URI = 'https://crm.zoho.com/crm/private';
23
24			/**
25			* Token used for session of request.
26			*
27			* @var string
28			*/
29			protected $authtoken;
30
31			/**
32			* Instance of the client.
33			*
34			* @var Client
35			*/
36			protected $zohoRestClient;
37
38			/**
39			* Format selected for get request.
40			*
Wabel / zoho-crm-orm

Push — 1.0 ( b072ff...1e92f5 )

ZohoClient::getRequestBody() A

Complexity

Size

Duplication

Importance

Available Fixes

Duplication Side-by-Side

Filter issues like
