flipbox\hubspot\services\ResourceAssociations

Complexity

Total Complexity

32

Size/Duplication

Total Lines	281
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	11

Test Coverage

Coverage

6.38%

Importance

Changes

0

16 Methods

Rating	Name	Duplication	Size	Complexity
A	init()	0	8	1
A	findHubSpotIdByElement()	0	5	1
A	findHubSpotId()	0	16	3
A	findElementId()	0	16	3
A	getQuery()	0	4	1
A	associationQuery()	0	9	1
A	existingAssociations()	0	13	4
A	getElementByHubSpotId()	0	11	2
A	findElementByHubSpotId()	0	12	2
A	findHubSpotIdByElementId()	0	13	2
A	query()	0	13	1
A	associations()	0	9	1
B	save()	0	22	6
A	resolveFieldFromQuery()	0	9	2
A	tableAlias()	0	4	1
A	recordClass()	0	4	1

<?php

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

namespace flipbox\hubspot\services;

use Craft;
use craft\base\Element;
use craft\base\ElementInterface;
use craft\errors\ElementNotFoundException;
use craft\helpers\Json;
use flipbox\craft\sortable\associations\db\SortableAssociationQueryInterface;
use flipbox\craft\sortable\associations\records\SortableAssociationInterface;
use flipbox\craft\sortable\associations\services\SortableAssociations;
use flipbox\ember\services\traits\records\Accessor;
use flipbox\ember\validators\MinMaxValidator;
use flipbox\hubspot\db\ResourceAssociationQuery;
use flipbox\hubspot\fields\Resources;

This use statement conflicts with another class in this namespace, flipbox\hubspot\services\Resources.

use flipbox\hubspot\HubSpot;
use flipbox\hubspot\records\ResourceAssociation;

/**
 * @author Flipbox Factory <hello@flipboxfactory.com>
 * @since 1.0.0
 *
 * @method ResourceAssociationQuery parentGetQuery($config = [])
 * @method ResourceAssociation create(array $attributes = [])
 * @method ResourceAssociation find($identifier)
 * @method ResourceAssociation get($identifier)
 * @method ResourceAssociation findByCondition($condition = [])
 * @method ResourceAssociation getByCondition($condition = [])
 * @method ResourceAssociation findByCriteria($criteria = [])
 * @method ResourceAssociation getByCriteria($criteria = [])
 * @method ResourceAssociation[] findAllByCondition($condition = [])
 * @method ResourceAssociation[] getAllByCondition($condition = [])
 * @method ResourceAssociation[] findAllByCriteria($criteria = [])
 * @method ResourceAssociation[] getAllByCriteria($criteria = [])
 */
class ResourceAssociations extends SortableAssociations
{
    use Accessor {
        getQuery as parentGetQuery;
    }

    /**
     * @inheritdoc
     */
    const SOURCE_ATTRIBUTE = ResourceAssociation::SOURCE_ATTRIBUTE;

    /**
     * @inheritdoc
     */
    const TARGET_ATTRIBUTE = ResourceAssociation::TARGET_ATTRIBUTE;

    /**
     * @inheritdoc
     */
    public function init()
    {
        $settings = HubSpot::getInstance()->getSettings();
        $this->cacheDuration = $settings->associationsCacheDuration;
        $this->cacheDependency = $settings->associationsCacheDependency;

        parent::init();
    }

    /**
     * @param ElementInterface $element
     * @param Resources $field
     * @return string|null
     */
    public function findHubSpotIdByElement(ElementInterface $element, Resources $field)
    {
        /** @var Element $element */
        return $this->findHubSpotId($field->id, $element->getId(), $element->siteId);
    }

    /**
     * @noinspection PhpDocMissingThrowsInspection
     *
     * @param string $fieldId
     * @param string $elementId
     * @param string|null $siteId
     * @return null|string
     */
    public function findHubSpotId(string $fieldId, string $elementId, string $siteId = null)
    {
        if ($siteId === null) {
            /** @noinspection PhpUnhandledExceptionInspection */
            $siteId = Craft::$app->getSites()->getCurrentSite()->id;
        }

        $hubSpotId = HubSpot::getInstance()->getResourceAssociations()->getQuery([
            'select' => ['hubSpotId'],
            'elementId' => $elementId,
            'siteId' => $siteId,
            'fieldId' => $fieldId
        ])->scalar();

        return is_string($hubSpotId) ? $hubSpotId : null;
    }

    /**
     * @noinspection PhpDocMissingThrowsInspection
     *
     * @param string $fieldId
     * @param string $elementId
     * @param string|null $siteId
     * @return null|string
     */
    public function findElementId(string $fieldId, string $elementId, string $siteId = null)
    {
        if ($siteId === null) {
            /** @noinspection PhpUnhandledExceptionInspection */
            $siteId = Craft::$app->getSites()->getCurrentSite()->id;
        }

        $elementId = HubSpot::getInstance()->getResourceAssociations()->getQuery([
            'select' => ['elementId'],
            'hubSpotId' => $elementId,
            'siteId' => $siteId,
            'fieldId' => $fieldId
        ])->scalar();

        return is_string($elementId) ? $elementId : null;
    }

    /**
     * @inheritdoc
     * @return ResourceAssociationQuery
     */
    public function getQuery($config = []): SortableAssociationQueryInterface
    {
        return $this->parentGetQuery($config);
    }

    /**
     * @inheritdoc
     * @param ResourceAssociation $record
     * @return ResourceAssociationQuery
     */
    protected function associationQuery(
        SortableAssociationInterface $record
    ): SortableAssociationQueryInterface {
        return $this->query(
            $record->{static::SOURCE_ATTRIBUTE},
            $record->fieldId,

Accessing fieldId on the interface flipbox\craft\sortable\associations\records\SortableAssociationInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

            $record->siteId

Accessing siteId on the interface flipbox\craft\sortable\associations\records\SortableAssociationInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        );
    }

    /**
     * @inheritdoc
     * @param ResourceAssociationQuery $query
     */
    protected function existingAssociations(
        SortableAssociationQueryInterface $query
    ): array {
        $source = $this->resolveStringAttribute($query, 'element');
        $field = $this->resolveStringAttribute($query, 'field');
        $site = $this->resolveStringAttribute($query, 'siteId');

        if ($source === null || $field === null || $site === null) {
            return [];
        }

        return $this->associations($source, $field, $site);
    }


    /**
     * @param string $hubSpotId
     * @return ElementInterface
     * @throws ElementNotFoundException
     */
    public function getElementByHubSpotId(string $hubSpotId): ElementInterface
    {
        if (!$element = $this->findElementByHubSpotId($hubSpotId)) {
            throw new ElementNotFoundException(sprintf(
                "Unable to get element from HubSpot Id: '%s'.",
                $hubSpotId
            ));
        }

        return $element;
    }

    /**
     * @param string $hubSpotId
     * @return ElementInterface|null
     */
    public function findElementByHubSpotId(string $hubSpotId)
    {
        $record = $this->findByCondition([
            'objectId' => $hubSpotId
        ]);

        if ($record === null) {
            return null;
        }

        return $record->getElement();
    }

    /**
     * Find the HubSpot Id by Element Id
     *
     * @param int $id
     * @return string|null
     */
    public function findHubSpotIdByElementId(int $id)
    {
        $hubSpotId = $this->getQuery()
            ->select(['hubSpotId'])
            ->element($id)
            ->scalar();

        if (!$hubSpotId) {
            return null;
        }

        return $hubSpotId;
    }


    /**
     * @param $source
     * @param int $fieldId
     * @param int $siteId
     * @return ResourceAssociationQuery
     */
    private function query(
        $source,
        int $fieldId,
        int $siteId
    ): ResourceAssociationQuery {
        return $this->getQuery()
            ->where([
                static::SOURCE_ATTRIBUTE => $source,
                'fieldId' => $fieldId,
                'siteId' => $siteId
            ])
            ->orderBy(['sortOrder' => SORT_ASC]);
    }

    /**
     * @param $source
     * @param int $fieldId
     * @param int $siteId
     * @return array
     */
    private function associations(
        $source,
        int $fieldId,
        int $siteId
    ): array {
        return $this->query($source, $fieldId, $siteId)
            ->indexBy(static::TARGET_ATTRIBUTE)
            ->all();
    }

    /**
     * @inheritdoc
     * @param bool $validate
     * @throws \Exception
     */
    public function save(
        SortableAssociationQueryInterface $query,
        bool $validate = true
    ): bool {
        if ($validate === true && null !== ($field = $this->resolveFieldFromQuery($query))) {
            $error = '';
            (new MinMaxValidator([
                'min' => $field->min ? (int)$field->min : null,
                'max' => $field->max ? (int)$field->max : null
            ]))->validate($query, $error);

            if (!empty($error)) {
                HubSpot::error(sprintf(
                    "Hubspot Resource failed to save due to the following validation errors: '%s'",
                    Json::encode($error)
                ));
                return false;
            }
        }

        return parent::save($query);
    }

    /**
     * @param SortableAssociationQueryInterface $query
     * @return Resources|null
     */
    protected function resolveFieldFromQuery(
        SortableAssociationQueryInterface $query
    ) {
        if (null === ($fieldId = $this->resolveStringAttribute($query, 'field'))) {
            return null;
        }

        return HubSpot::getInstance()->getResourcesField()->findById($fieldId);
    }

    /**
     * @inheritdoc
     */
    protected static function tableAlias(): string
    {
        return ResourceAssociation::tableAlias();
    }

    /**
     * @inheritdoc
     */
    public static function recordClass(): string
    {
        return ResourceAssociation::class;
    }
}