flipbox\patron\salesforce\connections\PatronConnection

Complexity

Total Complexity

17

Size/Duplication

Total Lines	163
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	10

Test Coverage

Coverage

0%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	displayName()	0	4	1
A	rules()	0	25	1
A	afterSave()	0	18	4
A	getResourceUrl()	0	8	2
A	getSettingsHtml()	0	14	1
A	getRecord()	0	23	5
A	getInstanceUrl()	0	4	1
A	prepareInstanceRequest()	0	12	2

<?php

/**
 * @copyright  Copyright (c) Flipbox Digital Limited
 * @license    https://github.com/flipboxfactory/patron-salesforce/blob/master/LICENSE
 * @link       https://github.com/flipboxfactory/patron-salesforce
 */

namespace flipbox\patron\salesforce\connections;

use Craft;
use craft\helpers\ArrayHelper;
use flipbox\craft\integration\connections\AbstractSaveableConnection;
use flipbox\craft\salesforce\connections\SavableConnectionInterface;
use flipbox\craft\salesforce\Force;
use flipbox\patron\records\Provider;
use Psr\Http\Message\RequestInterface;
use Stevenmaguire\OAuth2\Client\Provider\Salesforce;
use Zend\Diactoros\Uri;

/**
 * @author Flipbox Factory <hello@flipboxfactory.com>
 * @since 1.0.0
 */
class PatronConnection extends AbstractSaveableConnection implements SavableConnectionInterface
{
    use AccessTokenAuthorizationTrait;

    /**
     * @var string
     */
    public $version;

    /**
     * @var string|int
     */
    public $provider;

    /**
     * @inheritdoc
     */
    public static function displayName(): string
    {
        return Craft::t('patron-salesforce', 'Patron OAuth Token');
    }

    /**
     * @inheritdoc
     */
    public function rules()
    {
        return array_merge(
            parent::rules(),
            [
                [
                    [
                        'version',
                        'provider'
                    ],
                    'required'
                ],
                [
                    [
                        'version',
                        'provider'
                    ],
                    'safe',
                    'on' => [
                        static::SCENARIO_DEFAULT
                    ]
                ]
            ]
        );
    }

    /**
     * @inheritdoc
     * @throws \Throwable
     */
    public function afterSave(bool $isNew, array $changedAttributes)
    {
        // Delete existing lock
        if (null !== ($provider = ArrayHelper::getValue($changedAttributes, 'provider'))) {
            $condition = [
                (is_numeric($provider) ? 'id' : 'handle') => $provider,
                'enabled' => null
            ];

            if (null !== ($provider = Provider::findOne($condition))) {
                $provider->removeLock(Force::getInstance());
            }
        }

        $this->getRecord(false)->addLock(Force::getInstance());

\flipbox\craft\salesforce\Force::getInstance() is of type object<yii\base\Module>|null, but the function expects a object<craft\base\PluginInterface>.

        parent::afterSave($isNew, $changedAttributes);
    }

    /**
     * @inheritdoc
     * @throws \yii\base\InvalidConfigException
     */
    public function getResourceUrl(): string
    {
        $version = $this->version;

        return $this->getInstanceUrl() .
            '/services/data' .
            (!empty($version) ? ('/' . $version) : '');
    }

    /**
     * @inheritdoc
     *
     * @throws \Twig_Error_Loader
     * @throws \yii\base\Exception
     */
    public function getSettingsHtml(): string
    {
        $providers = Provider::find()
            ->class(Salesforce::class)
            ->enabled(null);

        return Craft::$app->view->renderTemplate(
            'patron-salesforce/connections/configuration',
            [
                'connection' => $this,
                'providers' => $providers->all()
            ]
        );
    }

    /**
     * @param bool $restricted
     * @return Provider
     */
    protected function getRecord(bool $restricted = true): Provider
    {
        // Get provider from settings
        if (null !== ($provider = $this->provider ?? null)) {
            $condition = [
                (is_numeric($provider) ? 'id' : 'handle') => $provider
            ];

            if ($restricted !== true) {
                $condition['enabled'] = null;
            }

            $provider = Provider::findOne($condition);
        }

        if (!$provider instanceof Provider) {
            $provider = new Provider();
        }

        $provider->class = Salesforce::class;

        return $provider;
    }

    /**
     * @inheritdoc
     * @throws \yii\base\InvalidConfigException
     */
    public function getInstanceUrl(): string
    {
        return rtrim($this->getProvider()->getDomain(), '/');
    }

    /**
     * @param RequestInterface $request
     * @return RequestInterface
     * @throws \yii\base\InvalidConfigException
     */
    public function prepareInstanceRequest(RequestInterface $request): RequestInterface
    {
        $request = $request->withUri(
            new Uri($this->getResourceUrl())
        );

        foreach ($this->getProvider()->getHeaders() as $key => $value) {
            $request = $request->withAddedHeader($key, $value);
        }

        return $request;
    }
}