flipbox\craft\hubspot\fields\Contacts

Complexity

Total Complexity

11

Size/Duplication

Total Lines	102
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getObjectLabel()	0	4	1
A	displayName()	0	4	1
A	defaultSelectionLabel()	0	4	1
A	upsertToHubSpot()	0	11	1
A	readFromHubSpot()	0	9	1
A	handleSyncToHubSpotResponse()	0	24	4
A	getObjectIdFromResponse()	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\fields;

use craft\base\ElementInterface;
use craft\helpers\Json;
use flipbox\craft\hubspot\criteria\ContactCriteria;
use flipbox\craft\hubspot\HubSpot;
use Psr\Http\Message\ResponseInterface;

/**
 * @author Flipbox Factory <hello@flipboxfactory.com>
 * @since 1.0.0
 */
class Contacts extends Objects
{
    /**
     * @inheritdoc
     */
    public function getObjectLabel(): string
    {
        return 'Contact';
    }

    /**
     * @inheritdoc
     */
    public static function displayName(): string
    {
        return HubSpot::t('HubSpot: Contacts');
    }

    /**
     * @inheritdoc
     */
    public static function defaultSelectionLabel(): string
    {
        return HubSpot::t('Add a HubSpot Contact');
    }

    /**
     * @inheritdoc
     * @throws \flipbox\craft\integration\exceptions\ConnectionNotFound
     */
    protected function upsertToHubSpot(
        array $payload,
        string $id = null
    ): ResponseInterface {
        return (new ContactCriteria([
            'connection' => $this->getConnection(),
            'cache' => $this->getCache(),
            'payload' => $payload,
            'id' => $id
        ]))->upsert();
    }

    /**
     * @inheritdoc
     * @throws \flipbox\craft\integration\exceptions\ConnectionNotFound
     * @throws \Exception
     */
    public function readFromHubSpot(
        string $id
    ): ResponseInterface {
        return (new ContactCriteria([
            'connection' => $this->getConnection(),
            'cache' => $this->getCache(),
            'id' => $id
        ]))->read();
    }

    /**
     * @inheritDoc
     * @return bool
     * @throws \Throwable
     */
    protected function handleSyncToHubSpotResponse(
        ResponseInterface $response,
        ElementInterface $element,
        string $objectId = null,
        $transformer = null
    ): bool {

        // 409 = failure because contact already exists
        if ($response->getStatusCode() === 409) {
            $data = Json::decodeIfJson(
                $response->getBody()->getContents()
            );

            $objectId = $data['identityProfile']['vid'] ?? null;

            if ($objectId !==null && $this->addAssociation($element, $objectId)) {
                return $this->syncToHubSpot($element, $objectId, $transformer);
            }

            $response->getBody()->rewind();
        }

        return parent::handleSyncToHubSpotResponse($response, $element, $objectId);
    }

    /**
     * @param ResponseInterface $response
     * @return string|null
     */
    protected function getObjectIdFromResponse(ResponseInterface $response)
    {
        $data = Json::decodeIfJson(
            $response->getBody()->getContents()
        );

        $id = $data['vid'] ?? null;

        return $id ? (string)$id : null;
    }
}