flipbox\craft\hubspot\records\Connection

Complexity

Total Complexity

16

Size/Duplication

Total Lines	126
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	rules()	0	14	1
A	getConnection()	0	24	4
A	beforeSave()	0	12	3
A	afterSave()	0	13	3
A	beforeDelete()	0	12	3
A	afterDelete()	0	10	2

<?php

/**
 * @copyright  Copyright (c) Flipbox Digital Limited
 * @license    https://flipboxfactory.com/software/hubspot/license
 * @link       https://www.flipboxfactory.com/software/hubspot/
 */

namespace flipbox\craft\hubspot\records;

use craft\helpers\ArrayHelper;
use craft\helpers\Component as ComponentHelper;
use flipbox\craft\hubspot\connections\SavableConnectionInterface;
use flipbox\craft\hubspot\HubSpot;
use flipbox\craft\hubspot\validators\ConnectionValidator;
use flipbox\craft\integration\records\IntegrationConnection;
use Flipbox\HubSpot\Connections\ConnectionInterface;
use Flipbox\Skeleton\Helpers\ObjectHelper;

/**
 * @author Flipbox Factory <hello@flipboxfactory.com>
 * @since 1.0.0
 */
class Connection extends IntegrationConnection
{
    /**
     * The table name
     */
    const TABLE_ALIAS = 'hubspot_connections';

    /**
     * @var ConnectionInterface|null
     */
    private $connection;

    /**
     * @inheritdoc
     */
    public function rules()
    {
        return array_merge(
            parent::rules(),
            [
                [
                    [
                        'class'
                    ],
                    ConnectionValidator::class
                ]
            ]
        );
    }

    /**
     * @noinspection PhpDocMissingThrowsInspection
     * @return ConnectionInterface
     */
    public function getConnection(): ConnectionInterface
    {
        if (null === $this->connection) {
            $config = ComponentHelper::mergeSettings([
                'settings' => $this->settings,
                'class' => $this->class
            ]);

            // Apply overrides
            if (!empty($this->handle)) {
                if (null !== ($override = HubSpot::getInstance()->getConnections()->getOverrides($this->handle))) {
                    $config = array_merge($config, $override);
                }
            }

            /** @noinspection PhpUnhandledExceptionInspection */
            $this->connection = ObjectHelper::create(
                $config,
                ConnectionInterface::class
            );
        }

        return $this->connection;
    }

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

    /**
     * @inheritdoc
     */
    public function beforeSave($insert)
    {
        $connection = $this->getConnection();

        if ($connection instanceof SavableConnectionInterface) {
            if (!$connection->beforeSave($insert)) {
                return false;
            }
        }

        return parent::beforeSave($insert);
    }

    /**
     * @inheritdoc
     */
    public function afterSave($insert, $changedAttributes)
    {
        $connection = $this->getConnection();

        if ($connection instanceof SavableConnectionInterface) {
            $connection->afterSave(
                $insert,
                (array)ArrayHelper::getValue($changedAttributes, 'settings', []) ?: []
            );
        }

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

    /**
     * @inheritdoc
     */
    public function beforeDelete()
    {
        $connection = $this->getConnection();

        if ($connection instanceof SavableConnectionInterface) {
            if (!$connection->beforeDelete()) {
                return false;
            }
        }

        return parent::beforeDelete();
    }

    /**
     * @inheritdoc
     */
    public function afterDelete()
    {
        $connection = $this->getConnection();

        if ($connection instanceof SavableConnectionInterface) {
            $connection->afterDelete();
        }

        parent::afterDelete();
    }
}