flipbox\craft\integration\records\IntegrationConnection

Complexity

Total Complexity

13

Size/Duplication

Total Lines	171
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	init()	0	7	1
A	instantiate()	0	5	1
A	populateRecord()	0	5	1
A	find()	0	11	1
A	findByCondition()	0	9	3
A	rules()	0	31	1
A	afterSave()	0	5	1
A	getSettingsValue()	0	5	1
A	setSettingsValue()	0	8	1
A	ensureSettings()	0	12	2

<?php

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

namespace flipbox\craft\integration\records;

use Craft;
use craft\helpers\Json;
use flipbox\craft\ember\helpers\ModelHelper;
use flipbox\craft\ember\models\HandleRulesTrait;
use flipbox\craft\ember\records\ActiveRecordWithId;
use flipbox\craft\integration\connections\ConnectionInterface;
use flipbox\craft\integration\queries\IntegrationConnectionQuery;
use yii\validators\UniqueValidator;

/**
 * @author Flipbox Factory <hello@flipboxfactory.com>
 * @since 2.0.0
 *
 * @property string $class
 * @property array $settings
 */
abstract class IntegrationConnection extends ActiveRecordWithId implements ConnectionInterface
{
    use HandleRulesTrait;

    /**
     * The query class this record uses
     */
    const QUERY_CLASS = IntegrationConnectionQuery::class;

    /**
     * @inheritdoc
     */
    public function init()
    {
        parent::init();

        // Always this class
        $this->class = static::class;
    }

    /**
     * @inheritdoc
     */
    public static function instantiate($row)
    {
        $class = $row['class'] ?? static::class;
        return new $class;
    }

    /**
     * @param static $record
     * @param $row
     */
    public static function populateRecord($record, $row)
    {
        parent::populateRecord($record, $row);
        $record->setOldAttribute('settings', $record->ensureSettings());
    }

    /*******************************************
     * QUERY
     *******************************************/
    /**
     * @noinspection PhpDocMissingThrowsInspection
     * @return IntegrationConnectionQuery
     */
    public static function find(): IntegrationConnectionQuery
    {
        /** @noinspection PhpIncompatibleReturnTypeInspection */
        /** @noinspection PhpUnhandledExceptionInspection */
        return Craft::createObject(
            static::QUERY_CLASS,
            [
                get_called_class()
            ]
        );
    }

    /**
     * @inheritdoc
     */
    protected static function findByCondition($condition)
    {
        if (!is_numeric($condition) && is_string($condition)) {
            $condition = ['handle' => $condition];
        }

        /** @noinspection PhpInternalEntityUsedInspection */
        return parent::findByCondition($condition);
    }


    /*******************************************
     * RULES
     *******************************************/

    /**
     * @inheritdoc
     */
    public function rules()
    {
        return array_merge(
            parent::rules(),
            $this->handleRules(),
            [
                [
                    [
                        'class'
                    ],
                    'required'
                ],
                [
                    [
                        'handle'
                    ],
                    UniqueValidator::class
                ],
                [
                    [
                        'class',
                        'settings'
                    ],
                    'safe',
                    'on' => [
                        ModelHelper::SCENARIO_DEFAULT
                    ]
                ]
            ]
        );
    }


    /*******************************************
     * EVENTS
     *******************************************/

    /**
     * @param bool $insert
     * @param array $changedAttributes
     */
    public function afterSave($insert, $changedAttributes)
    {
        parent::afterSave($insert, $changedAttributes);
        $this->ensureSettings();
    }


    /*******************************************
     * SETTINGS
     *******************************************/

    /**
     * @param string $attribute
     * @return mixed
     */
    public function getSettingsValue(string $attribute)
    {
        $settings = $this->ensureSettings();
        return $settings[$attribute] ?? null;
    }

    /**
     * @param string $attribute
     * @param $value
     * @return $this
     */
    public function setSettingsValue(string $attribute, $value)
    {
        $settings = $this->ensureSettings();
        $settings[$attribute] = $value;

        $this->setAttribute('settings', $settings);
        return $this;
    }

    /**
     * @return array|null
     */
    protected function ensureSettings()
    {
        $settings = $this->getAttribute('settings');

        if (is_string($settings)) {
            $settings = Json::decodeIfJson($settings);
        }

        $this->setAttribute('settings', $settings);

        return $settings;
    }
}